Show More
@@ -57,7 +57,7 b' def findcommonincoming(repo, remote, hea' | |||
|
57 | 57 | if all(knownnode(h) for h in heads): |
|
58 | 58 | return (heads, False, heads) |
|
59 | 59 | |
|
60 |
res = setdiscovery.findcommonheads(repo.ui, repo, remote, |
|
|
60 | res = setdiscovery.findcommonheads(repo.ui, repo, remote, | |
|
61 | 61 | abortwhenunrelated=not force, |
|
62 | 62 | ancestorsof=ancestorsof) |
|
63 | 63 | common, anyinc, srvheads = res |
@@ -130,7 +130,7 b' def _limitsample(sample, desiredlen):' | |||
|
130 | 130 | sample = set(random.sample(sample, desiredlen)) |
|
131 | 131 | return sample |
|
132 | 132 | |
|
133 |
def findcommonheads(ui, local, remote, |
|
|
133 | def findcommonheads(ui, local, remote, | |
|
134 | 134 | initialsamplesize=100, |
|
135 | 135 | fullsamplesize=200, |
|
136 | 136 | abortwhenunrelated=True, |
@@ -155,15 +155,11 b' def findcommonheads(ui, local, remote, h' | |||
|
155 | 155 | sample = _limitsample(ownheads, initialsamplesize) |
|
156 | 156 | # indices between sample and externalized version must match |
|
157 | 157 | sample = list(sample) |
|
158 | if heads: | |
|
159 | srvheadhashes = heads | |
|
160 |
|
|
|
161 | else: | |
|
162 | batch = remote.iterbatch() | |
|
163 | batch.heads() | |
|
164 | batch.known(dag.externalizeall(sample)) | |
|
165 | batch.submit() | |
|
166 | srvheadhashes, yesno = batch.results() | |
|
158 | batch = remote.iterbatch() | |
|
159 | batch.heads() | |
|
160 | batch.known(dag.externalizeall(sample)) | |
|
161 | batch.submit() | |
|
162 | srvheadhashes, yesno = batch.results() | |
|
167 | 163 | |
|
168 | 164 | if cl.tip() == nullid: |
|
169 | 165 | if srvheadhashes != [nullid]: |
General Comments 0
You need to be logged in to leave comments.
Login now