250 result = dag.headsetofconnecteds(common.bases) |
250 result = dag.headsetofconnecteds(common.bases) |
251 # common.bases can include nullrev, but our contract requires us to not |
251 # common.bases can include nullrev, but our contract requires us to not |
252 # return any heads in that case, so discard that |
252 # return any heads in that case, so discard that |
253 result.discard(nullrev) |
253 result.discard(nullrev) |
254 elapsed = util.timer() - start |
254 elapsed = util.timer() - start |
255 progress.update(None) |
255 progress.complete() |
256 ui.debug("%d total queries in %.4fs\n" % (roundtrips, elapsed)) |
256 ui.debug("%d total queries in %.4fs\n" % (roundtrips, elapsed)) |
257 msg = ('found %d common and %d unknown server heads,' |
257 msg = ('found %d common and %d unknown server heads,' |
258 ' %d roundtrips in %.4fs\n') |
258 ' %d roundtrips in %.4fs\n') |
259 missing = set(result) - set(srvheads) |
259 missing = set(result) - set(srvheads) |
260 ui.log('discovery', msg, len(result), len(missing), roundtrips, |
260 ui.log('discovery', msg, len(result), len(missing), roundtrips, |