mercurial/bundle2.py

33043:18c2489ac96d

    Raise an exception to highlight the fact that no transaction was expected
    to be created"""
    raise TransactionUnavailable()

def applybundle1(repo, cg, tr, source, url, **kwargs):
    # the transactiongetter won't be used, but we might as well set it
    op = bundleoperation(repo, lambda: tr)
    _processchangegroup(op, cg, tr, source, url, **kwargs)
    return op

def applybundle(repo, unbundler, tr, source=None, url=None, **kwargs):
    # transform me into unbundler.apply() as soon as the freeze is lifted
    if isinstance(unbundler, unbundle20):
        tr.hookargs['bundle2'] = '1'
        if source is not None and 'source' not in tr.hookargs:
            tr.hookargs['source'] = source
        if url is not None and 'url' not in tr.hookargs:
            tr.hookargs['url'] = url
        return processbundle(repo, unbundler, lambda: tr)
    else:
        return applybundle1(repo, unbundler, tr, source, url, **kwargs)

def processbundle(repo, unbundler, transactiongetter=None, op=None):
    """This function process a bundle, apply effect to/from a repo

    It iterates over each part then searches for and uses the proper handling

33044:1d2b68952950

    Raise an exception to highlight the fact that no transaction was expected
    to be created"""
    raise TransactionUnavailable()

def applybundle(repo, unbundler, tr, source=None, url=None, **kwargs):
    # transform me into unbundler.apply() as soon as the freeze is lifted
    if isinstance(unbundler, unbundle20):
        tr.hookargs['bundle2'] = '1'
        if source is not None and 'source' not in tr.hookargs:
            tr.hookargs['source'] = source
        if url is not None and 'url' not in tr.hookargs:
            tr.hookargs['url'] = url
        return processbundle(repo, unbundler, lambda: tr)
    else:
        # the transactiongetter won't be used, but we might as well set it
        op = bundleoperation(repo, lambda: tr)
        _processchangegroup(op, unbundler, tr, source, url, **kwargs)
        return op

def processbundle(repo, unbundler, transactiongetter=None, op=None):
    """This function process a bundle, apply effect to/from a repo

    It iterates over each part then searches for and uses the proper handling