Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

reflector logging

Browse source
This commit is contained in:
Jack Robison 2019-02-04 17:33:25 -05:00
parent b9934a7eb7
commit 5af351a234
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbrynet/stream/reflector/client.py
View file

@ -33,6 +33,8 @@ class StreamReflectorClient(asyncio.Protocol):
def connection_lost(self, exc: typing.Optional[Exception]): def connection_lost(self, exc: typing.Optional[Exception]):
self.transport = None self.transport = None
self.connected.clear() self.connected.clear()
if self.reflected_blobs:
log.info("Finished sending reflector %i blobs", len(self.reflected_blobs))
def data_received(self, data): def data_received(self, data):
try: try:
@ -81,8 +83,11 @@ class StreamReflectorClient(asyncio.Protocol):
if self.blob_manager.get_blob(blob.blob_hash, blob.length).get_is_verified(): if self.blob_manager.get_blob(blob.blob_hash, blob.length).get_is_verified():
needed.append(blob.blob_hash) needed.append(blob.blob_hash)
log.info("Sent reflector descriptor %s", sd_blob.blob_hash[:8]) log.info("Sent reflector descriptor %s", sd_blob.blob_hash[:8])
self.reflected_blobs.append(sd_blob.blob_hash)
else: else:
log.warning("Reflector failed to receive descriptor %s", sd_blob.blob_hash[:8]) 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 return sent_sd, needed
async def send_blob(self, blob_hash: str): async def send_blob(self, blob_hash: str):