diff options
| -rwxr-xr-x | tools/merge_fetch.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/tools/merge_fetch.py b/tools/merge_fetch.py index c66dc03..af05209 100755 --- a/tools/merge_fetch.py +++ b/tools/merge_fetch.py @@ -142,9 +142,10 @@ def merge_fetch_worker(args, localconfig, storagenode, pipe): read_parent_messages(pipe, to_fetch) # Drain pipe. ## Ask node for more entries. - for ehash in get_new_entries(name, url, own_key, paths): - pipe.send(('NEWENTRY', ehash)) - read_parent_messages(pipe, to_fetch) # Drain pipe. + if not to_fetch: + for ehash in get_new_entries(name, url, own_key, paths): + pipe.send(('NEWENTRY', ehash)) + read_parent_messages(pipe, to_fetch) # Drain pipe. ## Wait some if nothing to do. if not to_fetch: |