equal
deleted
inserted
replaced
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). |