mercurial/worker.py
changeset 45376 26eb62bd0550
parent 44248 12491abf93bd
child 45390 7d24201b6447
equal deleted inserted replaced
45375:8c466bcb0879 45376:26eb62bd0550
   209     oldchldhandler = signal.signal(signal.SIGCHLD, sigchldhandler)
   209     oldchldhandler = signal.signal(signal.SIGCHLD, sigchldhandler)
   210     ui.flush()
   210     ui.flush()
   211     parentpid = os.getpid()
   211     parentpid = os.getpid()
   212     pipes = []
   212     pipes = []
   213     retval = {}
   213     retval = {}
   214     for pargs in partition(args, workers):
   214     for pargs in partition(args, min(workers, len(args))):
   215         # Every worker gets its own pipe to send results on, so we don't have to
   215         # Every worker gets its own pipe to send results on, so we don't have to
   216         # implement atomic writes larger than PIPE_BUF. Each forked process has
   216         # implement atomic writes larger than PIPE_BUF. Each forked process has
   217         # its own pipe's descriptors in the local variables, and the parent
   217         # its own pipe's descriptors in the local variables, and the parent
   218         # process has the full list of pipe descriptors (and it doesn't really
   218         # process has the full list of pipe descriptors (and it doesn't really
   219         # care what order they're in).
   219         # care what order they're in).