From 0c91fd396e4e895ccdcf16cb9c643ccb066d11aa Mon Sep 17 00:00:00 2001 From: shortcutme Date: Thu, 8 Feb 2018 17:51:10 +0100 Subject: [PATCH] De-duplicate peers before publishing --- src/Site/Site.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/Site/Site.py b/src/Site/Site.py index 79f26ec3..b7fcd411 100644 --- a/src/Site/Site.py +++ b/src/Site/Site.py @@ -493,9 +493,7 @@ class Site(object): if event_done: event_done.set(True) break # All peers done, or published engouht - peer = peers.pop(0) - if peer in peers: # Remove duplicate - peers.remove(peer) + peer = peers.pop() if peer in published: continue if peer.last_content_json_update == content_json_modified: @@ -558,6 +556,8 @@ class Site(object): if len(peers) < limit * 2: # Add more, non-connected peers if necessary peers += self.getRecentPeers(limit * 2) + peers = set(peers) + self.log.info("Publishing %s to %s/%s peers (connected: %s) diffs: %s (%.2fk)..." % ( inner_path, limit, len(self.peers), num_connected_peers, diffs.keys(), float(len(str(diffs))) / 1024 ))