From 0ab46454d49fdc76a471c4142c35c6a5af40c828 Mon Sep 17 00:00:00 2001 From: Linus Nordberg Date: Mon, 28 Nov 2016 00:01:33 +0100 Subject: Don't pass 0 to multiprocessing.Pipe.poll(). Documentation says to pass nothing for no blocking. --- tools/merge_fetch.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'tools/merge_fetch.py') diff --git a/tools/merge_fetch.py b/tools/merge_fetch.py index 801f9cf..e0a6243 100755 --- a/tools/merge_fetch.py +++ b/tools/merge_fetch.py @@ -119,7 +119,7 @@ def merge_fetch_worker(args, localconfig, storagenode, pipe): to_fetch = set() while True: ## Read all messages from parent. - while pipe.poll(0): + while pipe.poll(): msg = pipe.recv() if len(msg) < 2: continue @@ -201,7 +201,7 @@ def merge_fetch_parallel(args, config, localconfig): storagenodes[name]]) continue logging.info("polling %s", name) - while pipe.poll(0): + while pipe.poll(): msg = pipe.recv() if len(msg) < 2: continue -- cgit v1.1