LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

logging

Browse source
This commit is contained in:
Jack Robison 2019-04-17 14:27:44 -04:00
parent 5b1398b588
commit 987f175fcc
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbrynet/extras/daemon/Daemon.py
View file

@ -521,6 +521,7 @@ class Daemon(metaclass=JSONRPCServerType):
await response.prepare(request) await response.prepare(request)
wrote = 0 wrote = 0
async for blob_info, decrypted in stream.aiter_read_stream(skip_blobs): async for blob_info, decrypted in stream.aiter_read_stream(skip_blobs):
log.info("streamed blob %i/%i", blob_info.blob_num + 1, len(stream.descriptor.blobs) - 1)
if (blob_info.blob_num == len(stream.descriptor.blobs) - 2) or (len(decrypted) + wrote >= size): if (blob_info.blob_num == len(stream.descriptor.blobs) - 2) or (len(decrypted) + wrote >= size):
decrypted += b'\x00' * (size - len(decrypted) - wrote) decrypted += b'\x00' * (size - len(decrypted) - wrote)
await response.write_eof(decrypted) await response.write_eof(decrypted)
@ -528,7 +529,6 @@ class Daemon(metaclass=JSONRPCServerType):
else: else:
await response.write(decrypted) await response.write(decrypted)
wrote += len(decrypted) wrote += len(decrypted)
log.info("streamed blob %i/%i", blob_info.blob_num + 1, len(stream.descriptor.blobs) - 1)
response.force_close() response.force_close()
return response return response