comparison mercurial/exchange.py @ 21141:d8dd19e09ed4

bundle2: advertise bundle2 caps in server capabilities

We can now retrieve them from the server during push. The capabilities are
encoded the same way as in `replycaps` part (with an extra layer of urlquoting
to escape separators).

21140:4aeb8da68090

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from i18n import _
from node import hex, nullid
import errno
import util, scmutil, changegroup, base85
import discovery, phases, obsolete, bookmarks, bundle2

def readbundle(ui, fh, fname, vfs=None):
    header = changegroup.readexactly(fh, 4)

    """push data to the remote using bundle2

    The only currently supported type of data is changegroup but this will
    evolve in the future."""
    # Send known head to the server for race detection.
    bundler = bundle2.bundle20(pushop.ui)
    bundler.addpart(bundle2.bundlepart('replycaps'))
    if not pushop.force:
        part = bundle2.bundlepart('CHECK:HEADS', data=iter(pushop.remoteheads))
        bundler.addpart(part)
    # add the changegroup bundle

21141:d8dd19e09ed4

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from i18n import _
from node import hex, nullid
import errno, urllib
import util, scmutil, changegroup, base85
import discovery, phases, obsolete, bookmarks, bundle2

def readbundle(ui, fh, fname, vfs=None):
    header = changegroup.readexactly(fh, 4)

    """push data to the remote using bundle2

    The only currently supported type of data is changegroup but this will
    evolve in the future."""
    # Send known head to the server for race detection.
    capsblob = urllib.unquote(pushop.remote.capable('bundle2'))
    caps = bundle2.decodecaps(capsblob)
    bundler = bundle2.bundle20(pushop.ui, caps)
    bundler.addpart(bundle2.bundlepart('replycaps'))
    if not pushop.force:
        part = bundle2.bundlepart('CHECK:HEADS', data=iter(pushop.remoteheads))
        bundler.addpart(part)
    # add the changegroup bundle