equal
deleted
inserted
replaced
47 mergeutil, |
47 mergeutil, |
48 namespaces, |
48 namespaces, |
49 narrowspec, |
49 narrowspec, |
50 obsolete, |
50 obsolete, |
51 pathutil, |
51 pathutil, |
52 peer, |
|
53 phases, |
52 phases, |
54 pushkey, |
53 pushkey, |
55 pycompat, |
54 pycompat, |
56 repository, |
55 repository, |
57 repoview, |
56 repoview, |
64 tags as tagsmod, |
63 tags as tagsmod, |
65 transaction, |
64 transaction, |
66 txnutil, |
65 txnutil, |
67 util, |
66 util, |
68 vfs as vfsmod, |
67 vfs as vfsmod, |
|
68 wireprotov1peer, |
69 ) |
69 ) |
70 from .utils import ( |
70 from .utils import ( |
71 procutil, |
71 procutil, |
72 stringutil, |
72 stringutil, |
73 ) |
73 ) |
150 return wrapper |
150 return wrapper |
151 |
151 |
152 moderncaps = {'lookup', 'branchmap', 'pushkey', 'known', 'getbundle', |
152 moderncaps = {'lookup', 'branchmap', 'pushkey', 'known', 'getbundle', |
153 'unbundle'} |
153 'unbundle'} |
154 legacycaps = moderncaps.union({'changegroupsubset'}) |
154 legacycaps = moderncaps.union({'changegroupsubset'}) |
|
155 |
|
156 class localiterbatcher(wireprotov1peer.iterbatcher): |
|
157 def __init__(self, local): |
|
158 super(localiterbatcher, self).__init__() |
|
159 self.local = local |
|
160 |
|
161 def submit(self): |
|
162 # submit for a local iter batcher is a noop |
|
163 pass |
|
164 |
|
165 def results(self): |
|
166 for name, args, opts, resref in self.calls: |
|
167 resref.set(getattr(self.local, name)(*args, **opts)) |
|
168 yield resref.value |
155 |
169 |
156 class localpeer(repository.peer): |
170 class localpeer(repository.peer): |
157 '''peer for a local repo; reflects only the most recent API''' |
171 '''peer for a local repo; reflects only the most recent API''' |
158 |
172 |
159 def __init__(self, repo, caps=None): |
173 def __init__(self, repo, caps=None): |
271 # End of _basewirecommands interface. |
285 # End of _basewirecommands interface. |
272 |
286 |
273 # Begin of peer interface. |
287 # Begin of peer interface. |
274 |
288 |
275 def iterbatch(self): |
289 def iterbatch(self): |
276 return peer.localiterbatcher(self) |
290 return localiterbatcher(self) |
277 |
291 |
278 # End of peer interface. |
292 # End of peer interface. |
279 |
293 |
280 class locallegacypeer(repository.legacypeer, localpeer): |
294 class locallegacypeer(repository.legacypeer, localpeer): |
281 '''peer extension which implements legacy methods too; used for tests with |
295 '''peer extension which implements legacy methods too; used for tests with |