equal
deleted
inserted
replaced
131 def sigchldhandler(signum, frame): |
131 def sigchldhandler(signum, frame): |
132 waitforworkers(blocking=False) |
132 waitforworkers(blocking=False) |
133 if problem[0]: |
133 if problem[0]: |
134 killworkers() |
134 killworkers() |
135 oldchldhandler = signal.signal(signal.SIGCHLD, sigchldhandler) |
135 oldchldhandler = signal.signal(signal.SIGCHLD, sigchldhandler) |
|
136 ui.flush() |
136 for pargs in partition(args, workers): |
137 for pargs in partition(args, workers): |
137 pid = os.fork() |
138 pid = os.fork() |
138 if pid == 0: |
139 if pid == 0: |
139 signal.signal(signal.SIGINT, oldhandler) |
140 signal.signal(signal.SIGINT, oldhandler) |
140 signal.signal(signal.SIGCHLD, oldchldhandler) |
141 signal.signal(signal.SIGCHLD, oldchldhandler) |