|
@ -279,7 +279,7 @@ class SessionManager(object): |
|
|
'paused': sum(not s._can_send.is_set() for s in self.sessions), |
|
|
'paused': sum(not s._can_send.is_set() for s in self.sessions), |
|
|
'pid': os.getpid(), |
|
|
'pid': os.getpid(), |
|
|
'peers': self.peer_mgr.info(), |
|
|
'peers': self.peer_mgr.info(), |
|
|
'requests': sum(s.processing_count for s in self.sessions), |
|
|
'requests': sum(s.unanswered_request_count() for s in self.sessions), |
|
|
'sessions': self.session_count(), |
|
|
'sessions': self.session_count(), |
|
|
'sessions_with_subs': self.session_count_with_subs(), |
|
|
'sessions_with_subs': self.session_count_with_subs(), |
|
|
'subs': self._sub_count(), |
|
|
'subs': self._sub_count(), |
|
@ -299,7 +299,7 @@ class SessionManager(object): |
|
|
session.protocol_version_string(), |
|
|
session.protocol_version_string(), |
|
|
session.cost, |
|
|
session.cost, |
|
|
session.extra_cost(), |
|
|
session.extra_cost(), |
|
|
session.processing_count, |
|
|
session.unanswered_request_count(), |
|
|
session.txs_sent, |
|
|
session.txs_sent, |
|
|
session.sub_count(), |
|
|
session.sub_count(), |
|
|
session.recv_count, session.recv_size, |
|
|
session.recv_count, session.recv_size, |
|
@ -316,7 +316,7 @@ class SessionManager(object): |
|
|
len(sessions), |
|
|
len(sessions), |
|
|
sum(s.cost for s in sessions), |
|
|
sum(s.cost for s in sessions), |
|
|
group.retained_cost, |
|
|
group.retained_cost, |
|
|
sum(s.processing_count for s in sessions), |
|
|
sum(s.unanswered_request_count() for s in sessions), |
|
|
sum(s.txs_sent for s in sessions), |
|
|
sum(s.txs_sent for s in sessions), |
|
|
sum(s.sub_count() for s in sessions), |
|
|
sum(s.sub_count() for s in sessions), |
|
|
sum(s.recv_count for s in sessions), |
|
|
sum(s.recv_count for s in sessions), |
|
|