Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
cext	[ DIR ]	drwxr-xr-x
cffi	[ DIR ]	drwxr-xr-x
defaultrc	[ DIR ]	drwxr-xr-x
dirstateutils	[ DIR ]	drwxr-xr-x
helptext	[ DIR ]	drwxr-xr-x
hgweb	[ DIR ]	drwxr-xr-x
interfaces	[ DIR ]	drwxr-xr-x
locale	[ DIR ]	drwxr-xr-x
pure	[ DIR ]	drwxr-xr-x
revlogutils	[ DIR ]	drwxr-xr-x
templates	[ DIR ]	drwxr-xr-x
testing	[ DIR ]	drwxr-xr-x
thirdparty	[ DIR ]	drwxr-xr-x
upgrade_utils	[ DIR ]	drwxr-xr-x
utils	[ DIR ]	drwxr-xr-x
__init__.py	416 B	-rw-r--r--
__modulepolicy__.py	61 B	-rw-r--r--
__version__.py	60 B	-rw-r--r--
ancestor.py	12.51 KB	-rw-r--r--
archival.py	11.59 KB	-rw-r--r--
bookmarks.py	34.74 KB	-rw-r--r--
branchmap.py	31.58 KB	-rw-r--r--
bundle2.py	86.74 KB	-rw-r--r--
bundlecaches.py	13.6 KB	-rw-r--r--
bundlerepo.py	23.29 KB	-rw-r--r--
cacheutil.py	827 B	-rw-r--r--
changegroup.py	65.72 KB	-rw-r--r--
changelog.py	19.72 KB	-rw-r--r--
chgserver.py	26.25 KB	-rw-r--r--
cmdutil.py	131.98 KB	-rw-r--r--
color.py	17.93 KB	-rw-r--r--
commands.py	257.93 KB	-rw-r--r--
commandserver.py	24.59 KB	-rw-r--r--
commit.py	18.52 KB	-rw-r--r--
config.py	8.59 KB	-rw-r--r--
configitems.py	46.49 KB	-rw-r--r--
context.py	100.53 KB	-rw-r--r--
copies.py	46.01 KB	-rw-r--r--
crecord.py	70.99 KB	-rw-r--r--
dagop.py	39.57 KB	-rw-r--r--
dagparser.py	15.13 KB	-rw-r--r--
debugcommands.py	154.84 KB	-rw-r--r--
destutil.py	17.07 KB	-rw-r--r--
diffhelper.py	2.32 KB	-rw-r--r--
diffutil.py	4.52 KB	-rw-r--r--
dirstate.py	51.01 KB	-rw-r--r--
dirstateguard.py	3.09 KB	-rw-r--r--
dirstatemap.py	23.77 KB	-rw-r--r--
discovery.py	22 KB	-rw-r--r--
dispatch.py	46.19 KB	-rw-r--r--
dummycert.pem	2.19 KB	-rw-r--r--
encoding.py	22.89 KB	-rw-r--r--
error.py	17.88 KB	-rw-r--r--
exchange.py	94.65 KB	-rw-r--r--
extensions.py	30.6 KB	-rw-r--r--
exthelper.py	11.83 KB	-rw-r--r--
fancyopts.py	11.3 KB	-rw-r--r--
filelog.py	8.58 KB	-rw-r--r--
filemerge.py	39.67 KB	-rw-r--r--
fileset.py	18.66 KB	-rw-r--r--
filesetlang.py	10.34 KB	-rw-r--r--
formatter.py	26.34 KB	-rw-r--r--
graphmod.py	16.76 KB	-rw-r--r--
grep.py	7.26 KB	-rw-r--r--
hbisect.py	10.89 KB	-rw-r--r--
help.py	36.74 KB	-rw-r--r--
hg.py	51.95 KB	-rw-r--r--
hook.py	11.53 KB	-rw-r--r--
httpconnection.py	4.27 KB	-rw-r--r--
httppeer.py	20.71 KB	-rw-r--r--
i18n.py	4.05 KB	-rw-r--r--
keepalive.py	27.1 KB	-rw-r--r--
linelog.py	14.94 KB	-rw-r--r--
localrepo.py	140.97 KB	-rw-r--r--
lock.py	11.89 KB	-rw-r--r--
logcmdutil.py	42.53 KB	-rw-r--r--
logexchange.py	4.98 KB	-rw-r--r--
loggingutil.py	3.93 KB	-rw-r--r--
lsprof.py	4.25 KB	-rw-r--r--
lsprofcalltree.py	2.74 KB	-rw-r--r--
mail.py	17.09 KB	-rw-r--r--
manifest.py	75.45 KB	-rw-r--r--
match.py	52.06 KB	-rw-r--r--
mdiff.py	17.37 KB	-rw-r--r--
merge.py	90.09 KB	-rw-r--r--
mergestate.py	31.37 KB	-rw-r--r--
mergeutil.py	502 B	-rw-r--r--
metadata.py	32.33 KB	-rw-r--r--
minifileset.py	3.54 KB	-rw-r--r--
minirst.py	29.13 KB	-rw-r--r--
namespaces.py	8.19 KB	-rw-r--r--
narrowspec.py	11.57 KB	-rw-r--r--
node.py	2.07 KB	-rw-r--r--
obsolete.py	36.76 KB	-rw-r--r--
obsutil.py	35.84 KB	-rw-r--r--
parser.py	25.68 KB	-rw-r--r--
patch.py	102 KB	-rw-r--r--
pathutil.py	12.21 KB	-rw-r--r--
phases.py	32.54 KB	-rw-r--r--
policy.py	4.74 KB	-rw-r--r--
posix.py	23.05 KB	-rw-r--r--
profiling.py	8.64 KB	-rw-r--r--
progress.py	10.92 KB	-rw-r--r--
pushkey.py	1.67 KB	-rw-r--r--
pvec.py	6.01 KB	-rw-r--r--
pycompat.py	16.33 KB	-rw-r--r--
rcutil.py	3.57 KB	-rw-r--r--
registrar.py	17.78 KB	-rw-r--r--
repair.py	18.46 KB	-rw-r--r--
repocache.py	4.49 KB	-rw-r--r--
repoview.py	16.89 KB	-rw-r--r--
requirements.py	4.64 KB	-rw-r--r--
revlog.py	117.08 KB	-rw-r--r--
revset.py	87.27 KB	-rw-r--r--
revsetlang.py	28.47 KB	-rw-r--r--
rewriteutil.py	8.47 KB	-rw-r--r--
scmposix.py	2.57 KB	-rw-r--r--
scmutil.py	75.72 KB	-rw-r--r--
scmwindows.py	3.37 KB	-rw-r--r--
server.py	7.05 KB	-rw-r--r--
setdiscovery.py	18 KB	-rw-r--r--
shelve.py	38.04 KB	-rw-r--r--
similar.py	3.97 KB	-rw-r--r--
simplemerge.py	16.86 KB	-rw-r--r--
smartset.py	33.65 KB	-rw-r--r--
sparse.py	26.37 KB	-rw-r--r--
sshpeer.py	22.56 KB	-rw-r--r--
sslutil.py	35.54 KB	-rw-r--r--
stack.py	762 B	-rw-r--r--
state.py	11.99 KB	-rw-r--r--
statichttprepo.py	7.92 KB	-rw-r--r--
statprof.py	32.16 KB	-rw-r--r--
store.py	25.27 KB	-rw-r--r--
streamclone.py	30.73 KB	-rw-r--r--
strip.py	8.72 KB	-rw-r--r--
subrepo.py	70.89 KB	-rw-r--r--
subrepoutil.py	17.42 KB	-rw-r--r--
tagmerge.py	11.29 KB	-rw-r--r--
tags.py	29.67 KB	-rw-r--r--
templatefilters.py	15.11 KB	-rw-r--r--
templatefuncs.py	30.14 KB	-rw-r--r--
templatekw.py	34.12 KB	-rw-r--r--
templater.py	37.7 KB	-rw-r--r--
templateutil.py	35.66 KB	-rw-r--r--
transaction.py	25.97 KB	-rw-r--r--
treediscovery.py	5.92 KB	-rw-r--r--
txnutil.py	1.02 KB	-rw-r--r--
ui.py	80.23 KB	-rw-r--r--
unionrepo.py	9.72 KB	-rw-r--r--
upgrade.py	14.59 KB	-rw-r--r--
url.py	24.56 KB	-rw-r--r--
urllibcompat.py	5.94 KB	-rw-r--r--
util.py	95.18 KB	-rw-r--r--
verify.py	21.8 KB	-rw-r--r--
vfs.py	24.93 KB	-rw-r--r--
win32.py	22.04 KB	-rw-r--r--
windows.py	21.77 KB	-rw-r--r--
wireprotoframing.py	64.95 KB	-rw-r--r--
wireprotoserver.py	17.38 KB	-rw-r--r--
wireprototypes.py	13.07 KB	-rw-r--r--
wireprotov1peer.py	21.51 KB	-rw-r--r--
wireprotov1server.py	26.33 KB	-rw-r--r--
worker.py	15.47 KB	-rw-r--r--
zstd.cpython-310-x86_64-linux-...	570.78 KB	-rw-r--r--

Code Editor : wireprotoserver.py

# Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
# Copyright 2005-2007 Olivia Mackall <olivia@selenic.com>
#
# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from __future__ import absolute_import

import contextlib
import struct
import threading

from .i18n import _
from . import (
    encoding,
    error,
    pycompat,
    util,
    wireprototypes,
    wireprotov1server,
)
from .interfaces import util as interfaceutil
from .utils import (
    compression,
    stringutil,
)

stringio = util.stringio

urlerr = util.urlerr
urlreq = util.urlreq

HTTP_OK = 200

HGTYPE = b'application/mercurial-0.1'
HGTYPE2 = b'application/mercurial-0.2'
HGERRTYPE = b'application/hg-error'

SSHV1 = wireprototypes.SSHV1

def decodevaluefromheaders(req, headerprefix):
    """Decode a long value from multiple HTTP request headers.

Returns the value as a bytes, not a str.
    """
    chunks = []
    i = 1
    while True:
        v = req.headers.get(b'%s-%d' % (headerprefix, i))
        if v is None:
            break
        chunks.append(pycompat.bytesurl(v))
        i += 1

return b''.join(chunks)

@interfaceutil.implementer(wireprototypes.baseprotocolhandler)
class httpv1protocolhandler(object):
    def __init__(self, req, ui, checkperm):
        self._req = req
        self._ui = ui
        self._checkperm = checkperm
        self._protocaps = None

@property
    def name(self):
        return b'http-v1'

def getargs(self, args):
        knownargs = self._args()
        data = {}
        keys = args.split()
        for k in keys:
            if k == b'*':
                star = {}
                for key in knownargs.keys():
                    if key != b'cmd' and key not in keys:
                        star[key] = knownargs[key][0]
                data[b'*'] = star
            else:
                data[k] = knownargs[k][0]
        return [data[k] for k in keys]

def _args(self):
        args = self._req.qsparams.asdictoflists()
        postlen = int(self._req.headers.get(b'X-HgArgs-Post', 0))
        if postlen:
            args.update(
                urlreq.parseqs(
                    self._req.bodyfh.read(postlen), keep_blank_values=True
                )
            )
            return args

argvalue = decodevaluefromheaders(self._req, b'X-HgArg')
        args.update(urlreq.parseqs(argvalue, keep_blank_values=True))
        return args

def getprotocaps(self):
        if self._protocaps is None:
            value = decodevaluefromheaders(self._req, b'X-HgProto')
            self._protocaps = set(value.split(b' '))
        return self._protocaps

def getpayload(self):
        # Existing clients *always* send Content-Length.
        length = int(self._req.headers[b'Content-Length'])

# If httppostargs is used, we need to read Content-Length
        # minus the amount that was consumed by args.
        length -= int(self._req.headers.get(b'X-HgArgs-Post', 0))
        return util.filechunkiter(self._req.bodyfh, limit=length)

@contextlib.contextmanager
    def mayberedirectstdio(self):
        oldout = self._ui.fout
        olderr = self._ui.ferr

out = util.stringio()

try:
            self._ui.fout = out
            self._ui.ferr = out
            yield out
        finally:
            self._ui.fout = oldout
            self._ui.ferr = olderr

def client(self):
        return b'remote:%s:%s:%s' % (
            self._req.urlscheme,
            urlreq.quote(self._req.remotehost or b''),
            urlreq.quote(self._req.remoteuser or b''),
        )

def addcapabilities(self, repo, caps):
        caps.append(b'batch')

caps.append(
            b'httpheader=%d' % repo.ui.configint(b'server', b'maxhttpheaderlen')
        )
        if repo.ui.configbool(b'experimental', b'httppostargs'):
            caps.append(b'httppostargs')

# FUTURE advertise 0.2rx once support is implemented
        # FUTURE advertise minrx and mintx after consulting config option
        caps.append(b'httpmediatype=0.1rx,0.1tx,0.2tx')

compengines = wireprototypes.supportedcompengines(
            repo.ui, compression.SERVERROLE
        )
        if compengines:
            comptypes = b','.join(
                urlreq.quote(e.wireprotosupport().name) for e in compengines
            )
            caps.append(b'compression=%s' % comptypes)

return caps

def checkperm(self, perm):
        return self._checkperm(perm)

# This method exists mostly so that extensions like remotefilelog can
# disable a kludgey legacy method only over http. As of early 2018,
# there are no other known users, so with any luck we can discard this
# hook if remotefilelog becomes a first-party extension.
def iscmd(cmd):
    return cmd in wireprotov1server.commands

def handlewsgirequest(rctx, req, res, checkperm):
    """Possibly process a wire protocol request.

If the current request is a wire protocol request, the request is
    processed by this function.

``req`` is a ``parsedrequest`` instance.
    ``res`` is a ``wsgiresponse`` instance.

Returns a bool indicating if the request was serviced. If set, the caller
    should stop processing the request, as a response has already been issued.
    """
    # Avoid cycle involving hg module.
    from .hgweb import common as hgwebcommon

repo = rctx.repo

# HTTP version 1 wire protocol requests are denoted by a "cmd" query
    # string parameter. If it isn't present, this isn't a wire protocol
    # request.
    if b'cmd' not in req.qsparams:
        return False

cmd = req.qsparams[b'cmd']

# The "cmd" request parameter is used by both the wire protocol and hgweb.
    # While not all wire protocol commands are available for all transports,
    # if we see a "cmd" value that resembles a known wire protocol command, we
    # route it to a protocol handler. This is better than routing possible
    # wire protocol requests to hgweb because it prevents hgweb from using
    # known wire protocol commands and it is less confusing for machine
    # clients.
    if not iscmd(cmd):
        return False

# The "cmd" query string argument is only valid on the root path of the
    # repo. e.g. ``/?cmd=foo``, ``/repo?cmd=foo``. URL paths within the repo
    # like ``/blah?cmd=foo`` are not allowed. So don't recognize the request
    # in this case. We send an HTTP 404 for backwards compatibility reasons.
    if req.dispatchpath:
        res.status = hgwebcommon.statusmessage(404)
        res.headers[b'Content-Type'] = HGTYPE
        # TODO This is not a good response to issue for this request. This
        # is mostly for BC for now.
        res.setbodybytes(b'0\n%s\n' % b'Not Found')
        return True

proto = httpv1protocolhandler(
        req, repo.ui, lambda perm: checkperm(rctx, req, perm)
    )

# The permissions checker should be the only thing that can raise an
    # ErrorResponse. It is kind of a layer violation to catch an hgweb
    # exception here. So consider refactoring into a exception type that
    # is associated with the wire protocol.
    try:
        _callhttp(repo, req, res, proto, cmd)
    except hgwebcommon.ErrorResponse as e:
        for k, v in e.headers:
            res.headers[k] = v
        res.status = hgwebcommon.statusmessage(
            e.code, stringutil.forcebytestr(e)
        )
        # TODO This response body assumes the failed command was
        # "unbundle." That assumption is not always valid.
        res.setbodybytes(b'0\n%s\n' % stringutil.forcebytestr(e))

return True

def _httpresponsetype(ui, proto, prefer_uncompressed):
    """Determine the appropriate response type and compression settings.

Returns a tuple of (mediatype, compengine, engineopts).
    """
    # Determine the response media type and compression engine based
    # on the request parameters.

if b'0.2' in proto.getprotocaps():
        # All clients are expected to support uncompressed data.
        if prefer_uncompressed:
            return HGTYPE2, compression._noopengine(), {}

# Now find an agreed upon compression format.
        compformats = wireprotov1server.clientcompressionsupport(proto)
        for engine in wireprototypes.supportedcompengines(
            ui, compression.SERVERROLE
        ):
            if engine.wireprotosupport().name in compformats:
                opts = {}
                level = ui.configint(b'server', b'%slevel' % engine.name())
                if level is not None:
                    opts[b'level'] = level

return HGTYPE2, engine, opts

# No mutually supported compression format. Fall back to the
        # legacy protocol.

# Don't allow untrusted settings because disabling compression or
    # setting a very high compression level could lead to flooding
    # the server's network or CPU.
    opts = {b'level': ui.configint(b'server', b'zliblevel')}
    return HGTYPE, util.compengines[b'zlib'], opts

def _callhttp(repo, req, res, proto, cmd):
    # Avoid cycle involving hg module.
    from .hgweb import common as hgwebcommon

def genversion2(gen, engine, engineopts):
        # application/mercurial-0.2 always sends a payload header
        # identifying the compression engine.
        name = engine.wireprotosupport().name
        assert 0 < len(name) < 256
        yield struct.pack(b'B', len(name))
        yield name

for chunk in gen:
            yield chunk

def setresponse(code, contenttype, bodybytes=None, bodygen=None):
        if code == HTTP_OK:
            res.status = b'200 Script output follows'
        else:
            res.status = hgwebcommon.statusmessage(code)

res.headers[b'Content-Type'] = contenttype

if bodybytes is not None:
            res.setbodybytes(bodybytes)
        if bodygen is not None:
            res.setbodygen(bodygen)

if not wireprotov1server.commands.commandavailable(cmd, proto):
        setresponse(
            HTTP_OK,
            HGERRTYPE,
            _(
                b'requested wire protocol command is not available over '
                b'HTTP'
            ),
        )
        return

proto.checkperm(wireprotov1server.commands[cmd].permission)

rsp = wireprotov1server.dispatch(repo, proto, cmd)

if isinstance(rsp, bytes):
        setresponse(HTTP_OK, HGTYPE, bodybytes=rsp)
    elif isinstance(rsp, wireprototypes.bytesresponse):
        setresponse(HTTP_OK, HGTYPE, bodybytes=rsp.data)
    elif isinstance(rsp, wireprototypes.streamreslegacy):
        setresponse(HTTP_OK, HGTYPE, bodygen=rsp.gen)
    elif isinstance(rsp, wireprototypes.streamres):
        gen = rsp.gen

# This code for compression should not be streamres specific. It
        # is here because we only compress streamres at the moment.
        mediatype, engine, engineopts = _httpresponsetype(
            repo.ui, proto, rsp.prefer_uncompressed
        )
        gen = engine.compressstream(gen, engineopts)

if mediatype == HGTYPE2:
            gen = genversion2(gen, engine, engineopts)

setresponse(HTTP_OK, mediatype, bodygen=gen)
    elif isinstance(rsp, wireprototypes.pushres):
        rsp = b'%d\n%s' % (rsp.res, rsp.output)
        setresponse(HTTP_OK, HGTYPE, bodybytes=rsp)
    elif isinstance(rsp, wireprototypes.pusherr):
        rsp = b'0\n%s\n' % rsp.res
        res.drain = True
        setresponse(HTTP_OK, HGTYPE, bodybytes=rsp)
    elif isinstance(rsp, wireprototypes.ooberror):
        setresponse(HTTP_OK, HGERRTYPE, bodybytes=rsp.message)
    else:
        raise error.ProgrammingError(b'hgweb.protocol internal failure', rsp)

def _sshv1respondbytes(fout, value):
    """Send a bytes response for protocol version 1."""
    fout.write(b'%d\n' % len(value))
    fout.write(value)
    fout.flush()

def _sshv1respondstream(fout, source):
    write = fout.write
    for chunk in source.gen:
        write(chunk)
    fout.flush()

def _sshv1respondooberror(fout, ferr, rsp):
    ferr.write(b'%s\n-\n' % rsp)
    ferr.flush()
    fout.write(b'\n')
    fout.flush()

@interfaceutil.implementer(wireprototypes.baseprotocolhandler)
class sshv1protocolhandler(object):
    """Handler for requests services via version 1 of SSH protocol."""

def __init__(self, ui, fin, fout):
        self._ui = ui
        self._fin = fin
        self._fout = fout
        self._protocaps = set()

@property
    def name(self):
        return wireprototypes.SSHV1

def getargs(self, args):
        data = {}
        keys = args.split()
        for n in pycompat.xrange(len(keys)):
            argline = self._fin.readline()[:-1]
            arg, l = argline.split()
            if arg not in keys:
                raise error.Abort(_(b"unexpected parameter %r") % arg)
            if arg == b'*':
                star = {}
                for k in pycompat.xrange(int(l)):
                    argline = self._fin.readline()[:-1]
                    arg, l = argline.split()
                    val = self._fin.read(int(l))
                    star[arg] = val
                data[b'*'] = star
            else:
                val = self._fin.read(int(l))
                data[arg] = val
        return [data[k] for k in keys]

def getprotocaps(self):
        return self._protocaps

def getpayload(self):
        # We initially send an empty response. This tells the client it is
        # OK to start sending data. If a client sees any other response, it
        # interprets it as an error.
        _sshv1respondbytes(self._fout, b'')

# The file is in the form:
        #
        # <chunk size>\n<chunk>
        # ...
        # 0\n
        count = int(self._fin.readline())
        while count:
            yield self._fin.read(count)
            count = int(self._fin.readline())

@contextlib.contextmanager
    def mayberedirectstdio(self):
        yield None

def client(self):
        client = encoding.environ.get(b'SSH_CLIENT', b'').split(b' ', 1)[0]
        return b'remote:ssh:' + client

def addcapabilities(self, repo, caps):
        if self.name == wireprototypes.SSHV1:
            caps.append(b'protocaps')
        caps.append(b'batch')
        return caps

def checkperm(self, perm):
        pass

def _runsshserver(ui, repo, fin, fout, ev):
    # This function operates like a state machine of sorts. The following
    # states are defined:
    #
    # protov1-serving
    #    Server is in protocol version 1 serving mode. Commands arrive on
    #    new lines. These commands are processed in this state, one command
    #    after the other.
    #
    # shutdown
    #    The server is shutting down, possibly in reaction to a client event.
    #
    # And here are their transitions:
    #
    # protov1-serving -> shutdown
    #    When server receives an empty request or encounters another
    #    error.

state = b'protov1-serving'
    proto = sshv1protocolhandler(ui, fin, fout)

while not ev.is_set():
        if state == b'protov1-serving':
            # Commands are issued on new lines.
            request = fin.readline()[:-1]

# Empty lines signal to terminate the connection.
            if not request:
                state = b'shutdown'
                continue

available = wireprotov1server.commands.commandavailable(
                request, proto
            )

# This command isn't available. Send an empty response and go
            # back to waiting for a new command.
            if not available:
                _sshv1respondbytes(fout, b'')
                continue

rsp = wireprotov1server.dispatch(repo, proto, request)
            repo.ui.fout.flush()
            repo.ui.ferr.flush()

if isinstance(rsp, bytes):
                _sshv1respondbytes(fout, rsp)
            elif isinstance(rsp, wireprototypes.bytesresponse):
                _sshv1respondbytes(fout, rsp.data)
            elif isinstance(rsp, wireprototypes.streamres):
                _sshv1respondstream(fout, rsp)
            elif isinstance(rsp, wireprototypes.streamreslegacy):
                _sshv1respondstream(fout, rsp)
            elif isinstance(rsp, wireprototypes.pushres):
                _sshv1respondbytes(fout, b'')
                _sshv1respondbytes(fout, b'%d' % rsp.res)
            elif isinstance(rsp, wireprototypes.pusherr):
                _sshv1respondbytes(fout, rsp.res)
            elif isinstance(rsp, wireprototypes.ooberror):
                _sshv1respondooberror(fout, ui.ferr, rsp.message)
            else:
                raise error.ProgrammingError(
                    b'unhandled response type from '
                    b'wire protocol command: %s' % rsp
                )

elif state == b'shutdown':
            break

else:
            raise error.ProgrammingError(
                b'unhandled ssh server state: %s' % state
            )

class sshserver(object):
    def __init__(self, ui, repo, logfh=None):
        self._ui = ui
        self._repo = repo
        self._fin, self._fout = ui.protectfinout()

# Log write I/O to stdout and stderr if configured.
        if logfh:
            self._fout = util.makeloggingfileobject(
                logfh, self._fout, b'o', logdata=True
            )
            ui.ferr = util.makeloggingfileobject(
                logfh, ui.ferr, b'e', logdata=True
            )

def serve_forever(self):
        self.serveuntil(threading.Event())
        self._ui.restorefinout(self._fin, self._fout)

def serveuntil(self, ev):
        """Serve until a threading.Event is set."""
        _runsshserver(self._ui, self._repo, self._fin, self._fout, ev)

${this.title}

Code Editor : wireprotoserver.py