From 5af351a2349c78a304cdbe3b6f5f1828390cfa62 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Mon, 4 Feb 2019 17:33:25 -0500 Subject: [PATCH] reflector logging --- lbrynet/stream/reflector/client.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/lbrynet/stream/reflector/client.py b/lbrynet/stream/reflector/client.py index 117afa53e..2c12b33d6 100644 --- a/lbrynet/stream/reflector/client.py +++ b/lbrynet/stream/reflector/client.py @@ -33,6 +33,8 @@ class StreamReflectorClient(asyncio.Protocol): def connection_lost(self, exc: typing.Optional[Exception]): self.transport = None self.connected.clear() + if self.reflected_blobs: + log.info("Finished sending reflector %i blobs", len(self.reflected_blobs)) def data_received(self, data): try: @@ -81,8 +83,11 @@ class StreamReflectorClient(asyncio.Protocol): if self.blob_manager.get_blob(blob.blob_hash, blob.length).get_is_verified(): needed.append(blob.blob_hash) log.info("Sent reflector descriptor %s", sd_blob.blob_hash[:8]) + self.reflected_blobs.append(sd_blob.blob_hash) else: log.warning("Reflector failed to receive descriptor %s", sd_blob.blob_hash[:8]) + if needed: + log.info("Reflector needs %i blobs for %s", len(needed), sd_blob.blob_hash[:8]) return sent_sd, needed async def send_blob(self, blob_hash: str):