comparison mercurial/worker.py @ 30412:7bc25549e084

worker: allow waitforworkers to be non-blocking

This patch adds a boolean flag to waitforworkers and makes it non-blocking
if set to True.

This is to make it possible that we can reap our workers while keep other
unrelated children untouched, after receiving SIGCHLD.

30411:47de34f79f93

            try:
                os.kill(p, signal.SIGTERM)
            except OSError as err:
                if err.errno != errno.ESRCH:
                    raise
    def waitforworkers():
        for pid in pids:
            st = _exitstatus(os.waitpid(pid, 0)[1])
            if st and not problem[0]:
                problem[0] = st
                killworkers()
    for pargs in partition(args, workers):
        pid = os.fork()

30412:7bc25549e084

            try:
                os.kill(p, signal.SIGTERM)
            except OSError as err:
                if err.errno != errno.ESRCH:
                    raise
    def waitforworkers(blocking=True):
        for pid in pids:
            p, st = os.waitpid(pid, 0 if blocking else os.WNOHANG)
            if p:
                st = _exitstatus(st)
            if st and not problem[0]:
                problem[0] = st
                killworkers()
    for pargs in partition(args, workers):
        pid = os.fork()