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

logging

Browse source
This commit is contained in:
Jack Robison 2020-05-27 00:55:48 -04:00
parent 4217bbbea6
commit 70464a23d2
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 8 additions and 0 deletions

8
lbry/wallet/server/mempool.py
View file

@ -213,10 +213,18 @@ class MemPool:
continue continue
hashes = {hex_str_to_hash(hh) for hh in hex_hashes} hashes = {hex_str_to_hash(hh) for hh in hex_hashes}
async with self.lock: async with self.lock:
start = time.perf_counter()
touched = await self._process_mempool(hashes) touched = await self._process_mempool(hashes)
duration = time.perf_counter() - start
if duration >= 1:
self.logger.info("processed mempool in %s", duration)
synchronized_event.set() synchronized_event.set()
synchronized_event.clear() synchronized_event.clear()
start = time.perf_counter()
await self.api.on_mempool(touched, height) await self.api.on_mempool(touched, height)
duration = time.perf_counter() - start
if duration >= 1:
self.logger.info("sent history notifications in %s", duration)
try: try:
# we wait up to `refresh_secs` but go early if a broadcast happens (which triggers wakeup event) # we wait up to `refresh_secs` but go early if a broadcast happens (which triggers wakeup event)
await asyncio.wait_for(self.wakeup.wait(), timeout=self.refresh_secs) await asyncio.wait_for(self.wakeup.wait(), timeout=self.refresh_secs)