comparison hgext/remotefilelog/__init__.py @ 40563:525dcf5c1d41

remotefilelog: remove some BC code related to streamclone

Since remotefilelog is now moved to core and we have
streamclone._walkstreamfiles() in core, we don't need to have the backward
compatibility code.

People with old mercurial version should use remotefilelog from hg-experimental
repo as IMO remotefilelog will go under a good refactoring and old clients will
break.

# no-check-commit foo_bar function name

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

40562:b35a096b9bff

    repair,
    repoview,
    revset,
    scmutil,
    smartset,
    templatekw,
    util,
)
from . import (
    constants,

)

# ensures debug commands are registered
hgdebugcommands.command

try:
    from mercurial import streamclone
    streamclone._walkstreamfiles
    hasstreamclone = True
except Exception:
    hasstreamclone = False

cmdtable = {}
command = registrar.command(cmdtable)

configtable = {}
configitem = registrar.configitem(configtable)

                        opts['excludepattern'] = '\0'.join(repo.excludepattern)
                    return remote._callstream('stream_out_shallow', **opts)
                else:
                    return orig()
            extensions.wrapfunction(remote, 'stream_out', stream_out_shallow)
        if hasstreamclone:
            def stream_wrap(orig, op):
                setup_streamout(op.repo, op.remote)
                return orig(op)
            extensions.wrapfunction(
                streamclone, 'maybeperformlegacystreamclone', stream_wrap)

            def canperformstreamclone(orig, pullop, bundle2=False):
                # remotefilelog is currently incompatible with the
                # bundle2 flavor of streamclones, so force us to use
                # v1 instead.
                if 'v2' in pullop.remotebundle2caps.get('stream', []):
                    pullop.remotebundle2caps['stream'] = [
                        c for c in pullop.remotebundle2caps['stream']
                        if c != 'v2']
                if bundle2:
                    return False, None
                supported, requirements = orig(pullop, bundle2=bundle2)
                if requirements is not None:
                    requirements.add(constants.SHALLOWREPO_REQUIREMENT)
                return supported, requirements
            extensions.wrapfunction(
                streamclone, 'canperformstreamclone', canperformstreamclone)
        else:
            def stream_in_shallow(orig, repo, remote, requirements):
                setup_streamout(repo, remote)
                requirements.add(constants.SHALLOWREPO_REQUIREMENT)
                return orig(repo, remote, requirements)
            extensions.wrapfunction(
                localrepo.localrepository, 'stream_in', stream_in_shallow)

    try:
        orig(ui, repo, *args, **opts)
    finally:
        if opts.get('shallow'):

40563:525dcf5c1d41

    repair,
    repoview,
    revset,
    scmutil,
    smartset,
    streamclone,
    templatekw,
    util,
)
from . import (
    constants,

)

# ensures debug commands are registered
hgdebugcommands.command

cmdtable = {}
command = registrar.command(cmdtable)

configtable = {}
configitem = registrar.configitem(configtable)

                        opts['excludepattern'] = '\0'.join(repo.excludepattern)
                    return remote._callstream('stream_out_shallow', **opts)
                else:
                    return orig()
            extensions.wrapfunction(remote, 'stream_out', stream_out_shallow)
        def stream_wrap(orig, op):
            setup_streamout(op.repo, op.remote)
            return orig(op)
        extensions.wrapfunction(
            streamclone, 'maybeperformlegacystreamclone', stream_wrap)

        def canperformstreamclone(orig, pullop, bundle2=False):
            # remotefilelog is currently incompatible with the
            # bundle2 flavor of streamclones, so force us to use
            # v1 instead.
            if 'v2' in pullop.remotebundle2caps.get('stream', []):
                pullop.remotebundle2caps['stream'] = [
                    c for c in pullop.remotebundle2caps['stream']
                    if c != 'v2']
            if bundle2:
                return False, None
            supported, requirements = orig(pullop, bundle2=bundle2)
            if requirements is not None:
                requirements.add(constants.SHALLOWREPO_REQUIREMENT)
            return supported, requirements
        extensions.wrapfunction(
            streamclone, 'canperformstreamclone', canperformstreamclone)

    try:
        orig(ui, repo, *args, **opts)
    finally:
        if opts.get('shallow'):