mercurial/worker.py

30421: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()

30422: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()