comparison mercurial/bundle2.py @ 42417:a97b12f726e4

narrow: pass the bundle to bundle2.widen_bundle() instead of generating there

This will make the code in narrowwirepeer.py more better for further
refactoring.

Differential Revision: https://phab.mercurial-scm.org/D6438

42416:8381b7067f17

    repo.ui.debug('applying stream bundle\n')
    streamclone.applybundlev2(repo, part, filecount, bytecount,
                              requirements)

def widen_bundle(repo, oldmatcher, newmatcher, common, known, cgversion,
                 ellipses):
    """generates bundle2 for widening a narrow clone

    repo is the localrepository instance
    oldmatcher matches what the client already has
    newmatcher matches what the client needs (including what it already has)
    common is set of common heads between server and client
    known is a set of revs known on the client side (used in ellipses)
    cgversion is the changegroup version to send
    ellipses is boolean value telling whether to send ellipses data or not

    returns bundle2 of the data required for extending
    """
    bundler = bundle20(repo.ui)
    commonnodes = set()
    cl = repo.changelog
    for r in repo.revs("::%ln", common):
        commonnodes.add(cl.node(r))
    if commonnodes:

42417:a97b12f726e4

    repo.ui.debug('applying stream bundle\n')
    streamclone.applybundlev2(repo, part, filecount, bytecount,
                              requirements)

def widen_bundle(bundler, repo, oldmatcher, newmatcher, common,
                 known, cgversion, ellipses):
    """generates bundle2 for widening a narrow clone

    bundler is the bundle to which data should be added
    repo is the localrepository instance
    oldmatcher matches what the client already has
    newmatcher matches what the client needs (including what it already has)
    common is set of common heads between server and client
    known is a set of revs known on the client side (used in ellipses)
    cgversion is the changegroup version to send
    ellipses is boolean value telling whether to send ellipses data or not

    returns bundle2 of the data required for extending
    """
    commonnodes = set()
    cl = repo.changelog
    for r in repo.revs("::%ln", common):
        commonnodes.add(cl.node(r))
    if commonnodes: