Record received and sent requests
This commit is contained in:
parent
22c682f393
commit
c122dc108a
2 changed files with 5 additions and 0 deletions
|
@ -344,6 +344,7 @@ class Connection(object):
|
|||
else:
|
||||
self.log("Unknown response: %s" % message)
|
||||
elif cmd:
|
||||
self.server.num_recv += 1
|
||||
if cmd == "handshake":
|
||||
self.handleHandshake(message)
|
||||
else:
|
||||
|
@ -397,6 +398,8 @@ class Connection(object):
|
|||
stat_key = message.get("cmd", "unknown")
|
||||
if stat_key == "response":
|
||||
stat_key = "response: %s" % self.last_cmd_recv
|
||||
else:
|
||||
self.server.num_sent += 1
|
||||
|
||||
self.server.stat_sent[stat_key]["num"] += 1
|
||||
if streaming:
|
||||
|
|
|
@ -44,6 +44,8 @@ class ConnectionServer:
|
|||
self.stat_sent = defaultdict(lambda: defaultdict(int))
|
||||
self.bytes_recv = 0
|
||||
self.bytes_sent = 0
|
||||
self.num_recv = 0
|
||||
self.num_sent = 0
|
||||
|
||||
# Bittorrent style peerid
|
||||
self.peer_id = "-ZN0%s-%s" % (config.version.replace(".", ""), CryptHash.random(12, "base64"))
|
||||
|
|
Loading…
Reference in a new issue