##// END OF EJS Templates
compare-disco: move case parsing into its own function...
marmoute -
r50357:ef0b0f94 default
parent child Browse files
Show More
@@ -1,217 +1,221 b''
1 1 #!/usr/bin/env python3
2 2 # compare various algorithm variants for a given case
3 3 #
4 4 # search-discovery-case REPO LOCAL_CASE REMOTE_CASE
5 5 #
6 6 # The description for the case input uses the same format as the ouput of
7 7 # search-discovery-case
8 8
9 9 import json
10 10 import os
11 11 import subprocess
12 12 import sys
13 13
14 14 this_script = os.path.abspath(sys.argv[0])
15 15 script_name = os.path.basename(this_script)
16 16 this_dir = os.path.dirname(this_script)
17 17 hg_dir = os.path.join(this_dir, '..', '..')
18 18 HG_REPO = os.path.normpath(hg_dir)
19 19 HG_BIN = os.path.join(HG_REPO, 'hg')
20 20
21 21
22 22 SUBSET_PATH = os.path.join(HG_REPO, 'contrib', 'perf-utils', 'subsetmaker.py')
23 23
24 24 CMD_BASE = (
25 25 HG_BIN,
26 26 'debugdiscovery',
27 27 '--template',
28 28 'json',
29 29 '--config',
30 30 'extensions.subset=%s' % SUBSET_PATH,
31 31 )
32 32
33 33 # --old
34 34 # --nonheads
35 35 #
36 36 # devel.discovery.exchange-heads=True
37 37 # devel.discovery.grow-sample=True
38 38 # devel.discovery.grow-sample.dynamic=True
39 39
40 40 VARIANTS = {
41 41 'tree-discovery': ('--old',),
42 42 'set-discovery-basic': (
43 43 '--config',
44 44 'devel.discovery.exchange-heads=no',
45 45 '--config',
46 46 'devel.discovery.grow-sample=no',
47 47 '--config',
48 48 'devel.discovery.grow-sample.dynamic=no',
49 49 '--config',
50 50 'devel.discovery.randomize=yes',
51 51 ),
52 52 'set-discovery-heads': (
53 53 '--config',
54 54 'devel.discovery.exchange-heads=yes',
55 55 '--config',
56 56 'devel.discovery.grow-sample=no',
57 57 '--config',
58 58 'devel.discovery.grow-sample.dynamic=no',
59 59 '--config',
60 60 'devel.discovery.randomize=yes',
61 61 ),
62 62 'set-discovery-grow-sample': (
63 63 '--config',
64 64 'devel.discovery.exchange-heads=yes',
65 65 '--config',
66 66 'devel.discovery.grow-sample=yes',
67 67 '--config',
68 68 'devel.discovery.grow-sample.dynamic=no',
69 69 '--config',
70 70 'devel.discovery.randomize=yes',
71 71 ),
72 72 'set-discovery-dynamic-sample': (
73 73 '--config',
74 74 'devel.discovery.exchange-heads=yes',
75 75 '--config',
76 76 'devel.discovery.grow-sample=yes',
77 77 '--config',
78 78 'devel.discovery.grow-sample.dynamic=yes',
79 79 '--config',
80 80 'devel.discovery.randomize=yes',
81 81 ),
82 82 'set-discovery-default': (
83 83 '--config',
84 84 'devel.discovery.randomize=yes',
85 85 ),
86 86 }
87 87
88 88 VARIANTS_KEYS = [
89 89 'tree-discovery',
90 90 'set-discovery-basic',
91 91 'set-discovery-heads',
92 92 'set-discovery-grow-sample',
93 93 'set-discovery-dynamic-sample',
94 94 'set-discovery-default',
95 95 ]
96 96
97 97 assert set(VARIANTS.keys()) == set(VARIANTS_KEYS)
98 98
99 99
100 def parse_case(case):
101 case_type, case_args = case.split('-', 1)
102 case = (case_type,) + tuple(int(x) for x in case_args.split('-'))
103 return case
104
105
100 106 def format_case(case):
101 107 return '-'.join(str(s) for s in case)
102 108
103 109
104 110 def to_revsets(case):
105 111 t = case[0]
106 112 if t == 'scratch':
107 113 return 'not scratch(all(), %d, "%d")' % (case[1], case[2])
108 114 elif t == 'randomantichain':
109 115 return '::randomantichain(all(), "%d")' % case[1]
110 116 elif t == 'rev':
111 117 return '::%d' % case[1]
112 118 else:
113 119 assert False
114 120
115 121
116 122 def compare(
117 123 repo,
118 124 local_case,
119 125 remote_case,
120 126 display_header=True,
121 127 display_case=True,
122 128 ):
123 129 case = (repo, local_case, remote_case)
124 130 if display_header:
125 131 pieces = ['#']
126 132 if display_case:
127 133 pieces += [
128 134 "repo",
129 135 "local-subset",
130 136 "remote-subset",
131 137 ]
132 138
133 139 pieces += [
134 140 "discovery-variant",
135 141 "roundtrips",
136 142 "queries",
137 143 "revs",
138 144 "local-heads",
139 145 "common-heads",
140 146 "undecided-initial",
141 147 "undecided-common",
142 148 "undecided-missing",
143 149 ]
144 150 print(*pieces)
145 151 for variant in VARIANTS_KEYS:
146 152 res = process(case, VARIANTS[variant])
147 153 revs = res["nb-revs"]
148 154 local_heads = res["nb-head-local"]
149 155 common_heads = res["nb-common-heads"]
150 156 roundtrips = res["total-roundtrips"]
151 157 queries = res["total-queries"]
152 158 pieces = []
153 159 if display_case:
154 160 pieces += [
155 161 repo,
156 162 format_case(local_case),
157 163 format_case(remote_case),
158 164 ]
159 165 pieces += [
160 166 variant,
161 167 roundtrips,
162 168 queries,
163 169 revs,
164 170 local_heads,
165 171 common_heads,
166 172 ]
167 173 if 'tree-discovery' not in variant:
168 174 undecided_common = res["nb-ini_und-common"]
169 175 undecided_missing = res["nb-ini_und-missing"]
170 176 undecided = undecided_common + undecided_missing
171 177 pieces += [
172 178 undecided,
173 179 undecided_common,
174 180 undecided_missing,
175 181 ]
176 182 print(*pieces)
177 183 return 0
178 184
179 185
180 186 def process(case, variant):
181 187 (repo, left, right) = case
182 188 cmd = list(CMD_BASE)
183 189 cmd.append('-R')
184 190 cmd.append(repo)
185 191 cmd.append('--local-as-revs')
186 192 cmd.append(to_revsets(left))
187 193 cmd.append('--remote-as-revs')
188 194 cmd.append(to_revsets(right))
189 195 cmd.extend(variant)
190 196 s = subprocess.Popen(cmd, stdout=subprocess.PIPE)
191 197 out, err = s.communicate()
192 198 return json.loads(out)[0]
193 199
194 200
195 201 if __name__ == '__main__':
196 202
197 203 argv = sys.argv[:]
198 204
199 205 kwargs = {}
200 206 # primitive arg parsing
201 207 if '--no-header' in argv:
202 208 kwargs['display_header'] = False
203 209 argv = [a for a in argv if a != '--no-header']
204 210 if '--no-case' in argv:
205 211 kwargs['display_case'] = False
206 212 argv = [a for a in argv if a != '--no-case']
207 213
208 214 if len(argv) != 4:
209 215 usage = f'USAGE: {script_name} REPO LOCAL_CASE REMOTE_CASE'
210 216 print(usage, file=sys.stderr)
211 217 sys.exit(128)
212 218 repo = argv[1]
213 local_case = argv[2].split('-')
214 local_case = (local_case[0],) + tuple(int(x) for x in local_case[1:])
215 remote_case = argv[3].split('-')
216 remote_case = (remote_case[0],) + tuple(int(x) for x in remote_case[1:])
219 local_case = parse_case(argv[2])
220 remote_case = parse_case(argv[3])
217 221 sys.exit(compare(repo, local_case, remote_case, **kwargs))
General Comments 0
You need to be logged in to leave comments. Login now