comparison mercurial/bundle2.py @ 21611:71b7b3f79a3c

bundle2: use the new ``part.params`` dictionary

We use the new ``part.params`` dictionary to access the value of parameters instead of
creating one from the part's attributes.

21610:d6056805f8f4

        part.addparam('return', '%i' % ret, mandatory=False)
    assert not inpart.read()

@parthandler('b2x:reply:changegroup')
def handlechangegroup(op, inpart):
    p = dict(inpart.advisoryparams)
    ret = int(p['return'])
    op.records.add('changegroup', {'return': ret}, int(p['in-reply-to']))

@parthandler('b2x:check:heads')
def handlechangegroup(op, inpart):
    """check that head of the repo did not change

        op.reply = bundle20(op.ui, caps)

@parthandler('b2x:error:abort')
def handlereplycaps(op, inpart):
    """Used to transmit abort error over the wire"""
    manargs = dict(inpart.mandatoryparams)
    advargs = dict(inpart.advisoryparams)
    raise util.Abort(manargs['message'], hint=advargs.get('hint'))

@parthandler('b2x:error:unknownpart')
def handlereplycaps(op, inpart):
    """Used to transmit unknown part error over the wire"""
    manargs = dict(inpart.mandatoryparams)
    raise UnknownPartError(manargs['parttype'])

@parthandler('b2x:error:pushraced')
def handlereplycaps(op, inpart):
    """Used to transmit push race error over the wire"""
    manargs = dict(inpart.mandatoryparams)
    raise error.ResponseError(_('push failed:'), manargs['message'])

21611:71b7b3f79a3c

        part.addparam('return', '%i' % ret, mandatory=False)
    assert not inpart.read()

@parthandler('b2x:reply:changegroup')
def handlechangegroup(op, inpart):
    ret = int(inpart.params['return'])
    replyto = int(inpart.params['in-reply-to'])
    op.records.add('changegroup', {'return': ret}, replyto)

@parthandler('b2x:check:heads')
def handlechangegroup(op, inpart):
    """check that head of the repo did not change

        op.reply = bundle20(op.ui, caps)

@parthandler('b2x:error:abort')
def handlereplycaps(op, inpart):
    """Used to transmit abort error over the wire"""
    raise util.Abort(inpart.params['message'], hint=inpart.params.get('hint'))

@parthandler('b2x:error:unknownpart')
def handlereplycaps(op, inpart):
    """Used to transmit unknown part error over the wire"""
    raise UnknownPartError(inpart.params['parttype'])

@parthandler('b2x:error:pushraced')
def handlereplycaps(op, inpart):
    """Used to transmit push race error over the wire"""
    raise error.ResponseError(_('push failed:'), inpart.params['message'])