mercurial/wireprotov2server.py

37721:f7673845b167

    wireproto,
    wireprotoframing,
    wireprototypes,
)

FRAMINGTYPE = b'application/mercurial-exp-framing-0003'

HTTP_WIREPROTO_V2 = wireprototypes.HTTP_WIREPROTO_V2

def handlehttpv2request(rctx, req, res, checkperm, urlparts):
    from .hgweb import common as hgwebcommon

                                                    rsp.data)
    elif isinstance(rsp, wireprototypes.cborresponse):
        encoded = cbor.dumps(rsp.value, canonical=True)
        action, meta = reactor.onbytesresponseready(outstream,
                                                    command['requestid'],
                                                    encoded,
                                                    iscbor=True)
    else:
        action, meta = reactor.onapplicationerror(
            _('unhandled response type from wire proto command'))

    if action == 'sendframes':

37722:89a16704114c

    wireproto,
    wireprotoframing,
    wireprototypes,
)

FRAMINGTYPE = b'application/mercurial-exp-framing-0004'

HTTP_WIREPROTO_V2 = wireprototypes.HTTP_WIREPROTO_V2

def handlehttpv2request(rctx, req, res, checkperm, urlparts):
    from .hgweb import common as hgwebcommon

                                                    rsp.data)
    elif isinstance(rsp, wireprototypes.cborresponse):
        encoded = cbor.dumps(rsp.value, canonical=True)
        action, meta = reactor.onbytesresponseready(outstream,
                                                    command['requestid'],
                                                    encoded)
    else:
        action, meta = reactor.onapplicationerror(
            _('unhandled response type from wire proto command'))

    if action == 'sendframes':