Show More
@@ -88,7 +88,7 b' def _posixworker(ui, func, staticargs, a' | |||||
88 | workers = _numworkers(ui) |
|
88 | workers = _numworkers(ui) | |
89 | oldhandler = signal.getsignal(signal.SIGINT) |
|
89 | oldhandler = signal.getsignal(signal.SIGINT) | |
90 | signal.signal(signal.SIGINT, signal.SIG_IGN) |
|
90 | signal.signal(signal.SIGINT, signal.SIG_IGN) | |
91 |
pids, problem = |
|
91 | pids, problem = set(), [0] | |
92 | def killworkers(): |
|
92 | def killworkers(): | |
93 | # if one worker bails, there's no good reason to wait for the rest |
|
93 | # if one worker bails, there's no good reason to wait for the rest | |
94 | for p in pids: |
|
94 | for p in pids: | |
@@ -118,8 +118,7 b' def _posixworker(ui, func, staticargs, a' | |||||
118 | os._exit(255) |
|
118 | os._exit(255) | |
119 | # other exceptions are allowed to propagate, we rely |
|
119 | # other exceptions are allowed to propagate, we rely | |
120 | # on lock.py's pid checks to avoid release callbacks |
|
120 | # on lock.py's pid checks to avoid release callbacks | |
121 |
pids.a |
|
121 | pids.add(pid) | |
122 | pids.reverse() |
|
|||
123 | os.close(wfd) |
|
122 | os.close(wfd) | |
124 | fp = os.fdopen(rfd, 'rb', 0) |
|
123 | fp = os.fdopen(rfd, 'rb', 0) | |
125 | t = threading.Thread(target=waitforworkers) |
|
124 | t = threading.Thread(target=waitforworkers) |
General Comments 0
You need to be logged in to leave comments.
Login now