Comments
Patch
@@ -705,19 +705,19 @@ def _pushb2ctx(pushop, bundler):
cgversions = b2caps.get('changegroup')
if cgversions: # 3.1 and 3.2 ship with an empty value
cgversions = [v for v in cgversions
if v in changegroup.supportedoutgoingversions(
pushop.repo)]
if not cgversions:
raise ValueError(_('no common changegroup version'))
version = max(cgversions)
- cg = changegroup.getlocalchangegroupraw(pushop.repo, 'push',
- pushop.outgoing,
- version=version)
+ emitter = changegroup.changegroupemitter.fromoutgoing(pushop.repo,
+ pushop.outgoing)
+ cg = emitter.emitchangegroupdata(version, 'push')
cgpart = bundler.newpart('changegroup', data=cg)
if cgversions:
cgpart.addparam('version', version)
if 'treemanifest' in pushop.repo.requirements:
cgpart.addparam('treemanifest', '1')
def handlereply(op):
"""extract addchangegroup returns from server reply"""
cgreplies = op.records.getreplies(cgpart.id)
@@ -1560,27 +1560,25 @@ def _getbundlechangegrouppart(bundler, r
cgversions = b2caps.get('changegroup')
if cgversions: # 3.1 and 3.2 ship with an empty value
cgversions = [v for v in cgversions
if v in changegroup.supportedoutgoingversions(repo)]
if not cgversions:
raise ValueError(_('no common changegroup version'))
version = max(cgversions)
outgoing = changegroup.computeoutgoing(repo, heads, common)
- cg = changegroup.getlocalchangegroupraw(repo, source, outgoing,
- bundlecaps=bundlecaps,
- version=version)
-
+ emitter = changegroup.changegroupemitter.fromoutgoing(repo, outgoing)
+ cg = emitter.emitchangegroupdata(version, source, bundlecaps=bundlecaps)
if not cg:
return
part = bundler.newpart('changegroup', data=cg)
if cgversions:
part.addparam('version', version)
- part.addparam('nbchanges', str(len(outgoing.missing)), mandatory=False)
+ part.addparam('nbchanges', str(emitter.changesetcount), mandatory=False)
if 'treemanifest' in repo.requirements:
part.addparam('treemanifest', '1')
@getbundle2partsgenerator('listkeys')
def _getbundlelistkeysparts(bundler, repo, source, bundlecaps=None,
b2caps=None, **kwargs):
"""add parts containing listkeys namespaces to the requested bundle"""
listkeys = kwargs.get('listkeys', ())