Show More
@@ -145,9 +145,6 def unescapearg(escaped): | |||
|
145 | 145 | |
|
146 | 146 | # client side |
|
147 | 147 | |
|
148 | def todict(**args): | |
|
149 | return args | |
|
150 | ||
|
151 | 148 | class wirepeer(peer.peerrepository): |
|
152 | 149 | |
|
153 | 150 | def batch(self): |
@@ -166,7 +163,7 class wirepeer(peer.peerrepository): | |||
|
166 | 163 | def lookup(self, key): |
|
167 | 164 | self.requirecap('lookup', _('look up remote revision')) |
|
168 | 165 | f = future() |
|
169 |
yield |
|
|
166 | yield {'key': encoding.fromlocal(key)}, f | |
|
170 | 167 | d = f.value |
|
171 | 168 | success, data = d[:-1].split(" ", 1) |
|
172 | 169 | if int(success): |
@@ -186,7 +183,7 class wirepeer(peer.peerrepository): | |||
|
186 | 183 | @batchable |
|
187 | 184 | def known(self, nodes): |
|
188 | 185 | f = future() |
|
189 |
yield |
|
|
186 | yield {'nodes': encodelist(nodes)}, f | |
|
190 | 187 | d = f.value |
|
191 | 188 | try: |
|
192 | 189 | yield [bool(int(f)) for f in d] |
@@ -236,10 +233,10 class wirepeer(peer.peerrepository): | |||
|
236 | 233 | yield False, None |
|
237 | 234 | f = future() |
|
238 | 235 | self.ui.debug('preparing pushkey for "%s:%s"\n' % (namespace, key)) |
|
239 |
yield |
|
|
240 |
|
|
|
241 |
|
|
|
242 |
|
|
|
236 | yield {'namespace': encoding.fromlocal(namespace), | |
|
237 | 'key': encoding.fromlocal(key), | |
|
238 | 'old': encoding.fromlocal(old), | |
|
239 | 'new': encoding.fromlocal(new)}, f | |
|
243 | 240 | d = f.value |
|
244 | 241 | d, output = d.split('\n', 1) |
|
245 | 242 | try: |
@@ -257,7 +254,7 class wirepeer(peer.peerrepository): | |||
|
257 | 254 | yield {}, None |
|
258 | 255 | f = future() |
|
259 | 256 | self.ui.debug('preparing listkeys for "%s"\n' % namespace) |
|
260 |
yield |
|
|
257 | yield {'namespace': encoding.fromlocal(namespace)}, f | |
|
261 | 258 | d = f.value |
|
262 | 259 | r = {} |
|
263 | 260 | for l in d.splitlines(): |
General Comments 0
You need to be logged in to leave comments.
Login now