diff --git a/lbry/lbry/blob_exchange/client.py b/lbry/lbry/blob_exchange/client.py index c4c8bde30..f69decb0c 100644 --- a/lbry/lbry/blob_exchange/client.py +++ b/lbry/lbry/blob_exchange/client.py @@ -151,7 +151,7 @@ class BlobExchangeClientProtocol(asyncio.Protocol): return self._blob_bytes_received, self.close() msg = f"downloading {self.blob.blob_hash[:8]} from {self.peer_address}:{self.peer_port}," \ f" timeout in {self.peer_timeout}" - log.info(msg) + log.debug(msg) msg = f"downloaded {self.blob.blob_hash[:8]} from {self.peer_address}:{self.peer_port}" await asyncio.wait_for(self.writer.finished, self.peer_timeout, loop=self.loop) log.info("%s at %fMB/s", msg, diff --git a/lbry/lbry/dht/blob_announcer.py b/lbry/lbry/dht/blob_announcer.py index 22d12a550..5b9cb0848 100644 --- a/lbry/lbry/dht/blob_announcer.py +++ b/lbry/lbry/dht/blob_announcer.py @@ -22,13 +22,12 @@ class BlobAnnouncer: if peers > 4: return blob_hash else: - log.warning("failed to announce %s, could only find %d peers, retrying soon.", blob_hash[:8], peers) + log.debug("failed to announce %s, could only find %d peers, retrying soon.", blob_hash[:8], peers) except Exception as err: if isinstance(err, asyncio.CancelledError): raise err log.warning("error announcing %s: %s", blob_hash[:8], str(err)) - async def _announce(self, batch_size: typing.Optional[int] = 10): while batch_size: if not self.node.joined.is_set(): diff --git a/lbry/lbry/dht/node.py b/lbry/lbry/dht/node.py index 625db46b5..57fb9baa1 100644 --- a/lbry/lbry/dht/node.py +++ b/lbry/lbry/dht/node.py @@ -88,10 +88,10 @@ class Node: ) stored_to = [node_id for node_id, contacted in stored_to_tup if contacted] if stored_to: - log.info("Stored %s to %i of %i attempted peers", binascii.hexlify(hash_value).decode()[:8], + log.debug("Stored %s to %i of %i attempted peers", binascii.hexlify(hash_value).decode()[:8], len(stored_to), len(peers)) else: - log.warning("Failed announcing %s, stored to 0 peers", blob_hash[:8]) + log.debug("Failed announcing %s, stored to 0 peers", blob_hash[:8]) return stored_to def stop(self) -> None: