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

add outbound and incoming connection counts to connection status

Browse source
This commit is contained in:
Jack Robison 2020-04-22 13:38:38 -04:00
parent 5e8b7e03af
commit 5a39e53ed2
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lbry/connection_manager.py
View file

@ -42,8 +42,7 @@ class ConnectionManager:
self.outgoing_connected.add(host_and_port)
def connection_received(self, host_and_port: str):
# self.incoming_connected.add(host_and_port)
pass
self.incoming_connected.add(host_and_port)
def outgoing_connection_lost(self, host_and_port: str):
if self._running and host_and_port in self.outgoing_connected:
@ -62,7 +61,9 @@ class ConnectionManager:
'total_sent': 0,
'total_received': 0,
'max_incoming_mbs': 0.0,
'max_outgoing_mbs': 0.0
'max_outgoing_mbs': 0.0,
'outbound_connections': 0,
'incoming_connections': 0
}
while True:
@ -87,6 +88,8 @@ class ConnectionManager:
self._max_outgoing_mbs = max(self._max_outgoing_mbs, self._status['total_outgoing_mbs'])
self._status['max_incoming_mbs'] = self._max_incoming_mbs
self._status['max_outgoing_mbs'] = self._max_outgoing_mbs
self._status['outbound_connections'] = len(self.outgoing_connected)
self._status['incoming_connections'] = len(self.incoming_connected)
def stop(self):
if self._task: