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

notifications_in_flight_metric

Browse source
This commit is contained in:
Jack Robison 2020-06-16 23:07:19 -04:00
parent 50ecb0dac9
commit 28838c1759
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
2 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbry/wallet/ledger.py
View file

@ -697,7 +697,7 @@ class Ledger(metaclass=LedgerRegistry):
local_height, height local_height, height
) )
return False return False
log.warning( log.debug(
"local history does not contain %s, requested height %i", tx.id, height "local history does not contain %s, requested height %i", tx.id, height
) )
return False return False

14
lbry/wallet/server/session.py
View file

@ -165,6 +165,10 @@ class SessionManager:
"address_history", "Time to fetch an address history", "address_history", "Time to fetch an address history",
namespace=NAMESPACE, buckets=HISTOGRAM_BUCKETS namespace=NAMESPACE, buckets=HISTOGRAM_BUCKETS
) )
notifications_in_flight_metric = Gauge(
"notifications_in_flight", "Count of notifications in flight",
namespace=NAMESPACE
)
def __init__(self, env: 'Env', db: LBRYLevelDB, bp: LBRYBlockProcessor, daemon: 'Daemon', mempool: 'MemPool', def __init__(self, env: 'Env', db: LBRYLevelDB, bp: LBRYBlockProcessor, daemon: 'Daemon', mempool: 'MemPool',
shutdown_event: asyncio.Event): shutdown_event: asyncio.Event):
@ -934,9 +938,13 @@ class LBRYElectrumX(SessionBase):
method = 'blockchain.scripthash.subscribe' method = 'blockchain.scripthash.subscribe'
else: else:
method = 'blockchain.address.subscribe' method = 'blockchain.address.subscribe'
status = await self.address_status(hashX) try:
self.session_mgr.address_history_metric.observe(time.perf_counter() - start) self.session_mgr.notifications_in_flight_metric.inc()
await self.send_notification(method, (alias, status)) status = await self.address_status(hashX)
self.session_mgr.address_history_metric.observe(time.perf_counter() - start)
await self.send_notification(method, (alias, status))
finally:
self.session_mgr.notifications_in_flight_metric.dec()
touched = touched.intersection(self.hashX_subs) touched = touched.intersection(self.hashX_subs)
if touched or (height_changed and self.mempool_statuses): if touched or (height_changed and self.mempool_statuses):