Show More
@@ -211,7 +211,7 b' def _posixworker(ui, func, staticargs, a' | |||||
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 |
General Comments 0
You need to be logged in to leave comments.
Login now