mercurial/commandserver.py

40634:5542bc9125c9

    def run(self):
        ui = self.ui
        # redirect stdio to null device so that broken extensions or in-process
        # hooks will never cause corruption of channel protocol.
        with procutil.protectedstdio(ui.fin, ui.fout) as (fin, fout):
            try:
                sv = server(ui, self.repo, fin, fout)
                return sv.serve()
            finally:
                sv.cleanup()

def _initworkerprocess():

40635:9683dfb6f13a

    def run(self):
        ui = self.ui
        # redirect stdio to null device so that broken extensions or in-process
        # hooks will never cause corruption of channel protocol.
        with procutil.protectedstdio(ui.fin, ui.fout) as (fin, fout):
            sv = server(ui, self.repo, fin, fout)
            try:
                return sv.serve()
            finally:
                sv.cleanup()

def _initworkerprocess():