comparison mercurial/exchange.py @ 21070:408877d491fb

bundle2: feed a binary stream to `peer.unbundle`

This input will have to travel over the wire anyway, so we feed the peer method
with a simple binary stream and rely on the server side to use `readbundle`
to create the python object.

The test output changes because the bundle is created marginally sooner and the
debug output interleaves in a different way.

21069:0a9cae236738

    # add the changegroup bundle
    cg = changegroup.getlocalbundle(pushop.repo, 'push', pushop.outgoing)
    cgpart = bundle2.bundlepart('CHANGEGROUP', data=cg.getchunks())
    bundler.addpart(cgpart)
    stream = util.chunkbuffer(bundler.getchunks())
    sent = bundle2.unbundle20(pushop.repo.ui, stream)
    reply = pushop.remote.unbundle(sent, ['force'], 'push')
    try:
        op = bundle2.processbundle(pushop.repo, reply)
    except KeyError, exc:
        raise util.Abort('missing support for %s' % exc)
    cgreplies = op.records.getreplies(cgpart.id)

21070:408877d491fb

    # add the changegroup bundle
    cg = changegroup.getlocalbundle(pushop.repo, 'push', pushop.outgoing)
    cgpart = bundle2.bundlepart('CHANGEGROUP', data=cg.getchunks())
    bundler.addpart(cgpart)
    stream = util.chunkbuffer(bundler.getchunks())
    reply = pushop.remote.unbundle(stream, ['force'], 'push')
    try:
        op = bundle2.processbundle(pushop.repo, reply)
    except KeyError, exc:
        raise util.Abort('missing support for %s' % exc)
    cgreplies = op.records.getreplies(cgpart.id)