mercurial/commandserver.py

29510:19205a0e2bf1

            _restoreio(ui, fin, fout)

class _requesthandler(socketserver.StreamRequestHandler):
    def handle(self):
        ui = self.server.ui
        repo = self.server.repo
        sv = None
        try:
            sv = server(ui, repo, self.rfile, self.wfile)
            try:
                sv.serve()
            # handle exceptions that may be raised by command server. most of
            # known exceptions are caught by dispatch.
            except error.Abort as inst:

            else:
                cerr = channeledoutput(self.wfile, 'e')
            traceback.print_exc(file=cerr)
            raise

class unixservice(object):
    """
    Listens on unix domain socket and forks server per connection
    """
    def __init__(self, ui, repo, opts):

29511:540c01a18bb7

            _restoreio(ui, fin, fout)

class _requesthandler(socketserver.StreamRequestHandler):
    def handle(self):
        ui = self.server.ui
        sv = None
        try:
            sv = self._createcmdserver()
            try:
                sv.serve()
            # handle exceptions that may be raised by command server. most of
            # known exceptions are caught by dispatch.
            except error.Abort as inst:

            else:
                cerr = channeledoutput(self.wfile, 'e')
            traceback.print_exc(file=cerr)
            raise

    def _createcmdserver(self):
        ui = self.server.ui
        repo = self.server.repo
        return server(ui, repo, self.rfile, self.wfile)

class unixservice(object):
    """
    Listens on unix domain socket and forks server per connection
    """
    def __init__(self, ui, repo, opts):