equal
deleted
inserted
replaced
224 os._exit(ret & 255) |
224 os._exit(ret & 255) |
225 pids.add(pid) |
225 pids.add(pid) |
226 selector = selectors.DefaultSelector() |
226 selector = selectors.DefaultSelector() |
227 for rfd, wfd in pipes: |
227 for rfd, wfd in pipes: |
228 os.close(wfd) |
228 os.close(wfd) |
229 selector.register(os.fdopen(rfd, 'rb', 0), selectors.EVENT_READ) |
229 selector.register(os.fdopen(rfd, 'rb'), selectors.EVENT_READ) |
230 |
230 |
231 def cleanup(): |
231 def cleanup(): |
232 signal.signal(signal.SIGINT, oldhandler) |
232 signal.signal(signal.SIGINT, oldhandler) |
233 waitforworkers() |
233 waitforworkers() |
234 signal.signal(signal.SIGCHLD, oldchldhandler) |
234 signal.signal(signal.SIGCHLD, oldchldhandler) |