Show More
@@ -280,6 +280,10 b' def _posixworker(ui, func, staticargs, a' | |||
|
280 | 280 | selector = selectors.DefaultSelector() |
|
281 | 281 | for rfd, wfd in pipes: |
|
282 | 282 | os.close(wfd) |
|
283 | # The stream has to be unbuffered. Otherwise, if all data is read from | |
|
284 | # the raw file into the buffer, the selector thinks that the FD is not | |
|
285 | # ready to read while pickle.load() could read from the buffer. This | |
|
286 | # would delay the processing of readable items. | |
|
283 | 287 | selector.register(os.fdopen(rfd, 'rb', 0), selectors.EVENT_READ) |
|
284 | 288 | |
|
285 | 289 | def cleanup(): |
General Comments 0
You need to be logged in to leave comments.
Login now