|
@@ -143,10 +143,12 @@ class Channel(network.Connection):
|
|
|
|
|
|
def send_msg(self, msg):
|
|
|
"""Send the given NetMsg on the channel."""
|
|
|
+ self.cellhandler.perfstats.bytes_sent += msg.size()
|
|
|
self.peer.received(self.cellhandler.myaddr, msg)
|
|
|
|
|
|
def received(self, peeraddr, msg):
|
|
|
"""Callback when a message is received from the network."""
|
|
|
+ self.cellhandler.perfstats.bytes_received += msg.size()
|
|
|
if isinstance(msg, CircuitCellMsg):
|
|
|
circid, cell = msg.circid, msg.cell
|
|
|
self.circuithandlers[circid].received_cell(cell, peeraddr, self.peer)
|