equal
deleted
inserted
replaced
2314 opts = wireproto.options('', ['heads', 'common'], others) |
2314 opts = wireproto.options('', ['heads', 'common'], others) |
2315 for k, v in opts.iteritems(): |
2315 for k, v in opts.iteritems(): |
2316 if k in ('heads', 'common'): |
2316 if k in ('heads', 'common'): |
2317 opts[k] = wireproto.decodelist(v) |
2317 opts[k] = wireproto.decodelist(v) |
2318 obsdata = _getobsmarkersstream(repo, **opts) |
2318 obsdata = _getobsmarkersstream(repo, **opts) |
2319 length = '%20i' % len(obsdata.getvalue()) |
2319 finaldata = StringIO() |
2320 def data(): |
2320 obsdata = obsdata.getvalue() |
2321 yield length |
2321 finaldata.write('%20i' % len(obsdata)) |
2322 for c in proto.groupchunks(obsdata): |
2322 finaldata.write(obsdata) |
2323 yield c |
2323 finaldata.seek(0) |
2324 return wireproto.streamres(data()) |
2324 return wireproto.streamres(proto.groupchunks(finaldata)) |
2325 |
2325 |
2326 def _obsrelsethashtree(repo): |
2326 def _obsrelsethashtree(repo): |
2327 cache = [] |
2327 cache = [] |
2328 unfi = repo.unfiltered() |
2328 unfi = repo.unfiltered() |
2329 for i in unfi: |
2329 for i in unfi: |