Changeset View
Changeset View
Standalone View
Standalone View
contrib/tracing/p2p_monitor.py
Show First 20 Lines • Show All 90 Lines • ▼ Show 20 Lines | class Peer: | ||||
connection_type = "" | connection_type = "" | ||||
last_messages: List[Message] = [] | last_messages: List[Message] = [] | ||||
total_inbound_msgs = 0 | total_inbound_msgs = 0 | ||||
total_inbound_bytes = 0 | total_inbound_bytes = 0 | ||||
total_outbound_msgs = 0 | total_outbound_msgs = 0 | ||||
total_outbound_bytes = 0 | total_outbound_bytes = 0 | ||||
def __init__(self, id, address, connection_type): | def __init__(self, peer_id, address, connection_type): | ||||
self.id = id | self.id = peer_id | ||||
self.address = address | self.address = address | ||||
self.connection_type = connection_type | self.connection_type = connection_type | ||||
self.last_messages = [] | self.last_messages = [] | ||||
def add_message(self, message): | def add_message(self, message): | ||||
self.last_messages.append(message) | self.last_messages.append(message) | ||||
if len(self.last_messages) > 25: | if len(self.last_messages) > 25: | ||||
self.last_messages.pop(0) | self.last_messages.pop(0) | ||||
▲ Show 20 Lines • Show All 151 Lines • Show Last 20 Lines |