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

remove dead code

Browse source
This commit is contained in:
Jack Robison 2021-07-27 16:19:08 -04:00 committed by Victor Shyba
parent cd1ce32377
commit e94a2c7c94
1 changed files with 0 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -263,16 +263,6 @@ class SessionManager:
await self._start_external_servers() await self._start_external_servers()
paused = False paused = False
async def _log_sessions(self):
"""Periodically log sessions."""
log_interval = self.env.log_sessions
if log_interval:
while True:
await sleep(log_interval)
data = self._session_data(for_log=True)
for line in text.sessions_lines(data):
self.logger.info(line)
self.logger.info(json.dumps(self._get_info()))
def _group_map(self): def _group_map(self):
group_map = defaultdict(list) group_map = defaultdict(list)
@ -376,23 +366,6 @@ class SessionManager:
'version': lbry.__version__, 'version': lbry.__version__,
} }
def _session_data(self, for_log):
"""Returned to the RPC 'sessions' call."""
now = time.time()
sessions = sorted(self.sessions.values(), key=lambda s: s.start_time)
return [(session.session_id,
session.flags(),
session.peer_address_str(for_log=for_log),
session.client_version,
session.protocol_version_string(),
session.count_pending_items(),
session.txs_sent,
session.sub_count(),
session.recv_count, session.recv_size,
session.send_count, session.send_size,
now - session.start_time)
for session in sessions]
def _group_data(self): def _group_data(self):
"""Returned to the RPC 'groups' call.""" """Returned to the RPC 'groups' call."""
result = [] result = []
@ -537,10 +510,6 @@ class SessionManager:
return lines return lines
async def rpc_sessions(self):
"""Return statistics about connected sessions."""
return self._session_data(for_log=False)
# async def rpc_reorg(self, count): # async def rpc_reorg(self, count):
# """Force a reorg of the given number of blocks. # """Force a reorg of the given number of blocks.
# #
@ -576,7 +545,6 @@ class SessionManager:
# because we connect to ourself # because we connect to ourself
await asyncio.wait([ await asyncio.wait([
self._clear_stale_sessions(), self._clear_stale_sessions(),
self._log_sessions(),
self._manage_servers() self._manage_servers()
]) ])
finally: finally:
@ -748,16 +716,6 @@ class SessionBase(RPCSession):
def toggle_logging(self): def toggle_logging(self):
self.log_me = not self.log_me self.log_me = not self.log_me
def flags(self):
"""Status flags."""
status = self.kind[0]
if self.is_closing():
status += 'C'
if self.log_me:
status += 'L'
status += str(self._concurrency.max_concurrent)
return status
def connection_made(self, transport): def connection_made(self, transport):
"""Handle an incoming client connection.""" """Handle an incoming client connection."""
super().connection_made(transport) super().connection_made(transport)