mercurial/wireproto.py

37484:c22fd3c4c23e

    transportversion = wireprototypes.TRANSPORTS[proto.name]['version']
    commandtable = commandsv2 if transportversion == 2 else commands
    func, spec = commandtable[command]

    args = proto.getargs(spec)
    return func(repo, proto, *args)

def options(cmd, keys, others):
    opts = {}
    for k in keys:
        if k in others:

        prefercompressed = False

    return wireprototypes.streamres(
        gen=chunks, prefer_uncompressed=not prefercompressed)

@wireprotocommand('heads', permission='pull')
def heads(repo, proto):
    h = repo.heads()
    return wireprototypes.bytesresponse(encodelist(h) + '\n')

@wireprotocommand('hello', permission='pull')

                                                   manargs, advargs))
            except error.PushRaced as exc:
                bundler.newpart('error:pushraced',
                                [('message', stringutil.forcebytestr(exc))])
            return wireprototypes.streamreslegacy(gen=bundler.getchunks())

37485:0b7475ea38cf

    transportversion = wireprototypes.TRANSPORTS[proto.name]['version']
    commandtable = commandsv2 if transportversion == 2 else commands
    func, spec = commandtable[command]

    args = proto.getargs(spec)

    # Version 1 protocols define arguments as a list. Version 2 uses a dict.
    if isinstance(args, list):
        return func(repo, proto, *args)
    elif isinstance(args, dict):
        return func(repo, proto, **args)
    else:
        raise error.ProgrammingError('unexpected type returned from '
                                     'proto.getargs(): %s' % type(args))

def options(cmd, keys, others):
    opts = {}
    for k in keys:
        if k in others:

        prefercompressed = False

    return wireprototypes.streamres(
        gen=chunks, prefer_uncompressed=not prefercompressed)

@wireprotocommand('heads', permission='pull', transportpolicy=POLICY_V1_ONLY)
def heads(repo, proto):
    h = repo.heads()
    return wireprototypes.bytesresponse(encodelist(h) + '\n')

@wireprotocommand('hello', permission='pull')

                                                   manargs, advargs))
            except error.PushRaced as exc:
                bundler.newpart('error:pushraced',
                                [('message', stringutil.forcebytestr(exc))])
            return wireprototypes.streamreslegacy(gen=bundler.getchunks())

# Wire protocol version 2 commands only past this point.

@wireprotocommand('heads', args='publiconly', permission='pull',
                  transportpolicy=POLICY_V2_ONLY)
def headsv2(repo, proto, publiconly=False):
    if publiconly:
        repo = repo.filtered('immutable')

    return wireprototypes.cborresponse(repo.heads())