equal
deleted
inserted
replaced
259 return fp.read() |
259 return fp.read() |
260 finally: |
260 finally: |
261 # if using keepalive, allow connection to be reused |
261 # if using keepalive, allow connection to be reused |
262 fp.close() |
262 fp.close() |
263 |
263 |
|
264 def lookup(self, key): |
|
265 try: |
|
266 d = self.do_cmd("lookup", key = key).read() |
|
267 return bin(d[:-1]) |
|
268 except: |
|
269 self.ui.warn('Not able to look up revision named "%s"\n' % (key,)) |
|
270 raise |
|
271 |
264 def heads(self): |
272 def heads(self): |
265 d = self.do_read("heads") |
273 d = self.do_read("heads") |
266 try: |
274 try: |
267 return map(bin, d[:-1].split(" ")) |
275 return map(bin, d[:-1].split(" ")) |
268 except: |
276 except: |
290 raise |
298 raise |
291 |
299 |
292 def changegroup(self, nodes, kind): |
300 def changegroup(self, nodes, kind): |
293 n = " ".join(map(hex, nodes)) |
301 n = " ".join(map(hex, nodes)) |
294 f = self.do_cmd("changegroup", roots=n) |
302 f = self.do_cmd("changegroup", roots=n) |
|
303 |
|
304 def zgenerator(f): |
|
305 zd = zlib.decompressobj() |
|
306 try: |
|
307 for chnk in f: |
|
308 yield zd.decompress(chnk) |
|
309 except httplib.HTTPException, inst: |
|
310 raise IOError(None, _('connection ended unexpectedly')) |
|
311 yield zd.flush() |
|
312 |
|
313 return util.chunkbuffer(zgenerator(util.filechunkiter(f))) |
|
314 |
|
315 def changegroupsubset(self, bases, heads, source): |
|
316 baselst = " ".join([hex(n) for n in bases]) |
|
317 headlst = " ".join([hex(n) for n in heads]) |
|
318 f = self.do_cmd("changegroupsubset", bases=baselst, heads=headlst) |
295 |
319 |
296 def zgenerator(f): |
320 def zgenerator(f): |
297 zd = zlib.decompressobj() |
321 zd = zlib.decompressobj() |
298 try: |
322 try: |
299 for chnk in f: |
323 for chnk in f: |