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

logging

Browse source
This commit is contained in:
Jack Robison 2019-02-03 15:43:25 -05:00
parent 3f98b16800
commit 0a027cf2de
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lbrynet/stream/stream_manager.py
View file

@ -135,6 +135,7 @@ class StreamManager:
binascii.unhexlify(file_info['download_directory']).decode(), file_info['status'], file_info['claim'] binascii.unhexlify(file_info['download_directory']).decode(), file_info['status'], file_info['claim']
) for file_info in file_infos ) for file_info in file_infos
]) ])
log.info("Started stream manager with %i files", len(file_infos))
async def resume(self): async def resume(self):
if not self.node: if not self.node:
@ -153,7 +154,6 @@ class StreamManager:
sd_hashes = await self.storage.get_streams_to_re_reflect() sd_hashes = await self.storage.get_streams_to_re_reflect()
streams = list(filter(lambda s: s.sd_hash in sd_hashes, self.streams)) streams = list(filter(lambda s: s.sd_hash in sd_hashes, self.streams))
batch = [] batch = []
total = len(streams)
while streams: while streams:
stream = streams.pop() stream = streams.pop()
if not stream.fully_reflected.is_set(): if not stream.fully_reflected.is_set():
@ -164,8 +164,6 @@ class StreamManager:
batch = [] batch = []
if batch: if batch:
await asyncio.gather(*batch) await asyncio.gather(*batch)
if total:
log.info("uploaded %i streams to reflector", total)
await asyncio.sleep(300, loop=self.loop) await asyncio.sleep(300, loop=self.loop)
async def start(self): async def start(self):