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
|
"""Performance tests for object store"""
from time import time
import sys
import stat
from git.test.performance.lib import (
TestBigRepoR,
GlobalsItemDeletorMetaCls
)
class PerfBaseDeletorMetaClass(GlobalsItemDeletorMetaCls):
ModuleToDelete = 'TestObjDBPerformanceBase'
class TestObjDBPerformanceBase(TestBigRepoR):
__metaclass__ = PerfBaseDeletorMetaClass
#{ Configuration
RepoCls = None # to be set by subclass
#} END configuration
def test_random_access_test(self):
repo = self.rorepo
# GET COMMITS
st = time()
root_commit = repo.commit(self.head_sha_2k)
commits = list(root_commit.traverse())
nc = len(commits)
elapsed = time() - st
print >> sys.stderr, "%s: Retrieved %i commits from ObjectStore in %g s ( %f commits / s )" % (type(repo.odb), nc, elapsed, nc / elapsed)
# GET TREES
# walk all trees of all commits
st = time()
blobs_per_commit = list()
nt = 0
for commit in commits:
tree = commit.tree
blobs = list()
for item in tree.traverse():
nt += 1
if item.type == 'blob':
blobs.append(item)
# direct access for speed
# END while trees are there for walking
blobs_per_commit.append(blobs)
# END for each commit
elapsed = time() - st
print >> sys.stderr, "%s: Retrieved %i objects from %i commits in %g s ( %f objects / s )" % (type(repo.odb), nt, len(commits), elapsed, nt / elapsed)
# GET BLOBS
st = time()
nb = 0
too_many = 15000
data_bytes = 0
for blob_list in blobs_per_commit:
for blob in blob_list:
data_bytes += len(blob.data_stream.read())
# END for each blobsha
nb += len(blob_list)
if nb > too_many:
break
# END for each bloblist
elapsed = time() - st
print >> sys.stderr, "%s: Retrieved %i blob (%i KiB) and their data in %g s ( %f blobs / s, %f KiB / s )" % (type(repo.odb), nb, data_bytes/1000, elapsed, nb / elapsed, (data_bytes / 1000) / elapsed)
|
