# HG changeset patch # User Yuya Nishihara # Date 1521946685 -32400 # Node ID 6715e8035b4ff9379a80f5413a4e9148114ab256 # Parent 0216232f21abdd5b574f4c5d2df306581d22409d procutil: introduce context-manager interface for protect/restorestdio The code looks slightly cleaner since it was pretty easy to pass arguments in wrong order. diff -r 0216232f21ab -r 6715e8035b4f mercurial/commandserver.py --- a/mercurial/commandserver.py Sun Mar 25 11:40:30 2018 +0900 +++ b/mercurial/commandserver.py Sun Mar 25 11:58:05 2018 +0900 @@ -318,13 +318,12 @@ ui = self.ui # redirect stdio to null device so that broken extensions or in-process # hooks will never cause corruption of channel protocol. - fin, fout = procutil.protectstdio(ui.fin, ui.fout) - try: - sv = server(ui, self.repo, fin, fout) - return sv.serve() - finally: - sv.cleanup() - procutil.restorestdio(ui.fin, ui.fout, fin, fout) + 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(): # use a different process group from the master process, in order to: diff -r 0216232f21ab -r 6715e8035b4f mercurial/utils/procutil.py --- a/mercurial/utils/procutil.py Sun Mar 25 11:40:30 2018 +0900 +++ b/mercurial/utils/procutil.py Sun Mar 25 11:58:05 2018 +0900 @@ -9,6 +9,7 @@ from __future__ import absolute_import +import contextlib import imp import io import os @@ -240,6 +241,15 @@ os.dup2(f.fileno(), uif.fileno()) f.close() +@contextlib.contextmanager +def protectedstdio(uin, uout): + """Run code block with protected standard streams""" + fin, fout = protectstdio(uin, uout) + try: + yield fin, fout + finally: + restorestdio(uin, uout, fin, fout) + def shellenviron(environ=None): """return environ with optional override, useful for shelling out""" def py2shell(val):