mercurial/commandserver.py

29541:9631ff5ebbeb

            return sv.serve()
        finally:
            sv.cleanup()
            _restoreio(ui, fin, fout)

class _requesthandler(socketserver.StreamRequestHandler):
    def handle(self):
        # use a different process group from the master process, making this
        # process pass kernel "is_current_pgrp_orphaned" check so signals like
        # SIGTSTP, SIGTTIN, SIGTTOU are not ignored.
        os.setpgid(0, 0)
        # change random state otherwise forked request handlers would have a
        # same state inherited from parent.
        random.seed()
        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:

            # also write traceback to error channel. otherwise client cannot
            # see it because it is written to server's stderr by default.
            if sv:
                cerr = sv.cerr
            else:
                cerr = channeledoutput(self.wfile, 'e')
            traceback.print_exc(file=cerr)
            raise
        finally:
            # trigger __del__ since ForkingMixIn uses os._exit
            gc.collect()

    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
    """

29542:6011ad3b0a42

            return sv.serve()
        finally:
            sv.cleanup()
            _restoreio(ui, fin, fout)

class _requesthandler(socketserver.BaseRequestHandler):
    def handle(self):
        # use a different process group from the master process, making this
        # process pass kernel "is_current_pgrp_orphaned" check so signals like
        # SIGTSTP, SIGTTIN, SIGTTOU are not ignored.
        os.setpgid(0, 0)
        # change random state otherwise forked request handlers would have a
        # same state inherited from parent.
        random.seed()
        ui = self.server.ui

        conn = self.request
        fin = conn.makefile('rb')
        fout = conn.makefile('wb')
        sv = None
        try:
            sv = self._createcmdserver(conn, fin, fout)
            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:

            # also write traceback to error channel. otherwise client cannot
            # see it because it is written to server's stderr by default.
            if sv:
                cerr = sv.cerr
            else:
                cerr = channeledoutput(fout, 'e')
            traceback.print_exc(file=cerr)
            raise
        finally:
            fin.close()
            try:
                fout.close()  # implicit flush() may cause another EPIPE
            except IOError as inst:
                if inst.errno != errno.EPIPE:
                    raise
            # trigger __del__ since ForkingMixIn uses os._exit
            gc.collect()

    def _createcmdserver(self, conn, fin, fout):
        ui = self.server.ui
        repo = self.server.repo
        return server(ui, repo, fin, fout)

class unixservice(object):
    """
    Listens on unix domain socket and forks server per connection
    """