153 roundtrips += 1 |
153 roundtrips += 1 |
154 ownheads = dag.heads() |
154 ownheads = dag.heads() |
155 sample = _limitsample(ownheads, initialsamplesize) |
155 sample = _limitsample(ownheads, initialsamplesize) |
156 # indices between sample and externalized version must match |
156 # indices between sample and externalized version must match |
157 sample = list(sample) |
157 sample = list(sample) |
158 batch = remote.iterbatch() |
158 |
159 batch.heads() |
159 with remote.commandexecutor() as e: |
160 batch.known(dag.externalizeall(sample)) |
160 fheads = e.callcommand('heads', {}) |
161 batch.submit() |
161 fknown = e.callcommand('known', { |
162 srvheadhashes, yesno = batch.results() |
162 'nodes': dag.externalizeall(sample), |
|
163 }) |
|
164 |
|
165 srvheadhashes, yesno = fheads.result(), fknown.result() |
163 |
166 |
164 if cl.tip() == nullid: |
167 if cl.tip() == nullid: |
165 if srvheadhashes != [nullid]: |
168 if srvheadhashes != [nullid]: |
166 return [nullid], True, srvheadhashes |
169 return [nullid], True, srvheadhashes |
167 return [nullid], False, [] |
170 return [nullid], False, [] |