Show More
@@ -62,7 +62,7 b' def findcommonincoming(repo, remote, hea' | |||
|
62 | 62 | if allknown: |
|
63 | 63 | return (heads, False, heads) |
|
64 | 64 | |
|
65 | res = setdiscovery.findcommonheads(repo.ui, repo, remote, | |
|
65 | res = setdiscovery.findcommonheads(repo.ui, repo, remote, heads, | |
|
66 | 66 | abortwhenunrelated=not force, |
|
67 | 67 | ancestorsof=ancestorsof) |
|
68 | 68 | 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, heads=None, | |
|
134 | 134 | initialsamplesize=100, |
|
135 | 135 | fullsamplesize=200, |
|
136 | 136 | abortwhenunrelated=True, |
@@ -155,11 +155,15 b' def findcommonheads(ui, local, remote,' | |||
|
155 | 155 | sample = _limitsample(ownheads, initialsamplesize) |
|
156 | 156 | # indices between sample and externalized version must match |
|
157 | 157 | sample = list(sample) |
|
158 | batch = remote.iterbatch() | |
|
159 | batch.heads() | |
|
160 |
|
|
|
161 | batch.submit() | |
|
162 | srvheadhashes, yesno = batch.results() | |
|
158 | if heads: | |
|
159 | srvheadhashes = heads | |
|
160 | yesno = remote.known(dag.externalizeall(sample)) | |
|
161 | else: | |
|
162 | batch = remote.iterbatch() | |
|
163 | batch.heads() | |
|
164 | batch.known(dag.externalizeall(sample)) | |
|
165 | batch.submit() | |
|
166 | srvheadhashes, yesno = batch.results() | |
|
163 | 167 | |
|
164 | 168 | if cl.tip() == nullid: |
|
165 | 169 | if srvheadhashes != [nullid]: |
General Comments 0
You need to be logged in to leave comments.
Login now