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

dont run empty queries

Browse source
This commit is contained in:
Lex Berezhny 2019-07-16 13:57:22 -04:00
parent 8e64b1840d
commit 31284e0c5e
2 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -3425,7 +3425,7 @@ class Daemon(metaclass=JSONRPCServerType):
page_size=page_size,
top_level=not include_replies
)
if 'items' in cmnt_list:
if cmnt_list.get('items', None):
items = cmnt_list['items']
chnl_uris = {cmnt['channel_url'] for cmnt in items if 'channel_url' in cmnt}
claims = await self.resolve(tuple(chnl_uris))

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

@ -133,9 +133,10 @@ class LBRYSessionManager(SessionManager):
command = self.get_command_tracking_info(command_name)
command['finished'] += 1
command['total_time'] += elapsed
command['execution_time'] += (metrics[command_name]['total'] - metrics['execute_query']['total'])
command['query_time'] += metrics['execute_query']['total']
command['query_count'] += metrics['execute_query']['calls']
if 'execute_query' in metrics:
command['execution_time'] += (metrics[command_name]['total'] - metrics['execute_query']['total'])
command['query_time'] += metrics['execute_query']['total']
command['query_count'] += metrics['execute_query']['calls']
for func_name, func_metrics in metrics.items():
reader = self.reader_metrics.setdefault(func_name, {})
for key in func_metrics:
@ -239,10 +240,12 @@ class LBRYElectrumX(ElectrumX):
return result
async def claimtrie_search(self, **kwargs):
return await self.run_and_cache_query('search', reader.search_to_bytes, kwargs)
if kwargs:
return await self.run_and_cache_query('search', reader.search_to_bytes, kwargs)
async def claimtrie_resolve(self, *urls):
return await self.run_and_cache_query('resolve', reader.resolve_to_bytes, urls)
if urls:
return await self.run_and_cache_query('resolve', reader.resolve_to_bytes, urls)
async def get_server_height(self):
return self.bp.height