diff --git a/mercurial/bundle2.py b/mercurial/bundle2.py --- a/mercurial/bundle2.py +++ b/mercurial/bundle2.py @@ -503,12 +503,12 @@ class unbundle20(object): payloadsize = self._unpack(_fpayloadsize)[0] self.ui.debug('payload chunk size: %i\n' % payloadsize) payload = ''.join(payload) - current = part(parttype, manparams, advparams, data=payload) + current = bundlepart(parttype, manparams, advparams, data=payload) current.id = partid return current -class part(object): +class bundlepart(object): """A bundle2 part contains application level payload The part `type` is used to route the part to the application level @@ -598,9 +598,9 @@ def handlechangegroup(op, inpart): if op.reply is not None: # This is definitly not the final form of this # return. But one need to start somewhere. - op.reply.addpart(part('reply:changegroup', (), - [('in-reply-to', str(inpart.id)), - ('return', '%i' % ret)])) + op.reply.addpart(bundlepart('reply:changegroup', (), + [('in-reply-to', str(inpart.id)), + ('return', '%i' % ret)])) @parthandler('reply:changegroup') def handlechangegroup(op, inpart): diff --git a/mercurial/exchange.py b/mercurial/exchange.py --- a/mercurial/exchange.py +++ b/mercurial/exchange.py @@ -604,7 +604,7 @@ def getbundle(repo, source, heads=None, yield 'HG10UN' for c in cg.getchunks(): yield c - part = bundle2.part('changegroup', data=cgchunks()) + part = bundle2.bundlepart('changegroup', data=cgchunks()) bundler.addpart(part) return bundle2.unbundle20(repo.ui, util.chunkbuffer(bundler.getchunks())) diff --git a/tests/test-bundle2.t b/tests/test-bundle2.t --- a/tests/test-bundle2.t +++ b/tests/test-bundle2.t @@ -37,8 +37,9 @@ Create an extension to test bundle2 API > def pinghandler(op, part): > op.ui.write('received ping request (id %i)\n' % part.id) > if op.reply is not None: - > op.reply.addpart(bundle2.part('test:pong', - > [('in-reply-to', str(part.id))])) + > rpart = bundle2.bundlepart('test:pong', + > [('in-reply-to', str(part.id))]) + > op.reply.addpart(rpart) > > @command('bundle2', > [('', 'param', [], 'stream level parameter'), @@ -70,28 +71,28 @@ Create an extension to test bundle2 API > yield 'HG10UN' > for c in cg.getchunks(): > yield c - > part = bundle2.part('changegroup', data=cgchunks()) + > part = bundle2.bundlepart('changegroup', data=cgchunks()) > bundler.addpart(part) > > if opts['parts']: - > part = bundle2.part('test:empty') + > part = bundle2.bundlepart('test:empty') > bundler.addpart(part) > # add a second one to make sure we handle multiple parts - > part = bundle2.part('test:empty') + > part = bundle2.bundlepart('test:empty') > bundler.addpart(part) - > part = bundle2.part('test:song', data=ELEPHANTSSONG) + > part = bundle2.bundlepart('test:song', data=ELEPHANTSSONG) > bundler.addpart(part) - > part = bundle2.part('test:math', - > [('pi', '3.14'), ('e', '2.72')], - > [('cooking', 'raw')], - > '42') + > part = bundle2.bundlepart('test:math', + > [('pi', '3.14'), ('e', '2.72')], + > [('cooking', 'raw')], + > '42') > bundler.addpart(part) > if opts['unknown']: - > part = bundle2.part('test:UNKNOWN', - > data='some random content') + > part = bundle2.bundlepart('test:UNKNOWN', + > data='some random content') > bundler.addpart(part) > if opts['parts']: - > part = bundle2.part('test:ping') + > part = bundle2.bundlepart('test:ping') > bundler.addpart(part) > > if path is None: