1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
package stats
import (
"os"
"path/filepath"
"testing"
"time"
"github.com/stretchr/testify/require"
"gitlab.com/gitlab-org/gitaly/internal/git"
"gitlab.com/gitlab-org/gitaly/internal/git/gittest"
"gitlab.com/gitlab-org/gitaly/internal/testhelper"
"gitlab.com/gitlab-org/gitaly/internal/testhelper/testcfg"
)
func TestRepositoryProfile(t *testing.T) {
cfg := testcfg.Build(t)
testRepo, testRepoPath, cleanup := gittest.InitBareRepoAt(t, cfg.Storages[0])
defer cleanup()
ctx, cancel := testhelper.Context()
defer cancel()
hasBitmap, err := HasBitmap(testRepoPath)
require.NoError(t, err)
require.False(t, hasBitmap, "repository should not have a bitmap initially")
unpackedObjects, err := UnpackedObjects(testRepoPath)
require.NoError(t, err)
require.Zero(t, unpackedObjects)
packfiles, err := GetPackfiles(testRepoPath)
require.NoError(t, err)
require.Empty(t, packfiles)
packfilesCount, err := PackfilesCount(testRepoPath)
require.NoError(t, err)
require.Zero(t, packfilesCount)
blobs := 10
blobIDs := gittest.WriteBlobs(t, testRepoPath, blobs)
unpackedObjects, err = UnpackedObjects(testRepoPath)
require.NoError(t, err)
require.Equal(t, int64(blobs), unpackedObjects)
gitCmdFactory := git.NewExecCommandFactory(cfg)
looseObjects, err := LooseObjects(ctx, gitCmdFactory, testRepo)
require.NoError(t, err)
require.Equal(t, int64(blobs), looseObjects)
for _, blobID := range blobIDs {
commitID := gittest.CommitBlobWithName(t, cfg, testRepoPath, blobID, blobID, "adding another blob....")
testhelper.MustRunCommand(t, nil, "git", "-C", testRepoPath, "update-ref", "refs/heads/"+blobID, commitID)
}
// write a loose object
gittest.WriteBlobs(t, testRepoPath, 1)
testhelper.MustRunCommand(t, nil, "git", "-C", testRepoPath, "repack", "-A", "-b", "-d")
unpackedObjects, err = UnpackedObjects(testRepoPath)
require.NoError(t, err)
require.Zero(t, unpackedObjects)
looseObjects, err = LooseObjects(ctx, gitCmdFactory, testRepo)
require.NoError(t, err)
require.Equal(t, int64(1), looseObjects)
// let a ms elapse for the OS to recognize the blobs have been written after the packfile
time.Sleep(1 * time.Millisecond)
// write another loose object
blobID := gittest.WriteBlobs(t, testRepoPath, 1)[0]
// due to OS semantics, ensure that the blob has a timestamp that is after the packfile
theFuture := time.Now().Add(10 * time.Minute)
require.NoError(t, os.Chtimes(filepath.Join(testRepoPath, "objects", blobID[0:2], blobID[2:]), theFuture, theFuture))
unpackedObjects, err = UnpackedObjects(testRepoPath)
require.NoError(t, err)
require.Equal(t, int64(1), unpackedObjects)
looseObjects, err = LooseObjects(ctx, gitCmdFactory, testRepo)
require.NoError(t, err)
require.Equal(t, int64(2), looseObjects)
}
|