From 75b977dff93df6b32f7b800a73d5cf79c7885483 Mon Sep 17 00:00:00 2001 From: Kay Kurokawa Date: Mon, 6 Nov 2017 19:48:47 -0500 Subject: [PATCH] we just have one supplier not a list of suppliers --- lbrynet/core/server/DHTHashAnnouncer.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/lbrynet/core/server/DHTHashAnnouncer.py b/lbrynet/core/server/DHTHashAnnouncer.py index d00fa50a3..a1989bc88 100644 --- a/lbrynet/core/server/DHTHashAnnouncer.py +++ b/lbrynet/core/server/DHTHashAnnouncer.py @@ -20,7 +20,7 @@ class DHTHashAnnouncer(object): def __init__(self, dht_node, peer_port): self.dht_node = dht_node self.peer_port = peer_port - self.suppliers = [] + self.supplier = None self.next_manage_call = None self.hash_queue = collections.deque() self._concurrent_announcers = 0 @@ -62,7 +62,7 @@ class DHTHashAnnouncer(object): self._manage_call_lc.stop() def add_supplier(self, supplier): - self.suppliers.append(supplier) + self.supplier = supplier def immediate_announce(self, blob_hashes): if self.peer_port is not None: @@ -76,8 +76,8 @@ class DHTHashAnnouncer(object): @defer.inlineCallbacks def _announce_available_hashes(self): log.debug('Announcing available hashes') - for supplier in self.suppliers: - hashes = yield supplier.hashes_to_announce() + if self.supplier: + hashes = yield self.supplier.hashes_to_announce() yield self._announce_hashes(hashes) @defer.inlineCallbacks @@ -155,10 +155,10 @@ class DHTHashAnnouncer(object): stored_to = {} for _, announced_to in announcer_results: stored_to.update(announced_to) + log.info('Took %s seconds to announce %s hashes', time.time() - start, len(hashes)) seconds_per_blob = (time.time() - start) / len(hashes) - for supplier in self.suppliers: - supplier.set_single_hash_announce_duration(seconds_per_blob) + self.supplier.set_single_hash_announce_duration(seconds_per_blob) defer.returnValue(stored_to)