We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f135ae9 commit dd5ad29Copy full SHA for dd5ad29
1 file changed
receptor/protocol.py
@@ -71,7 +71,6 @@ async def watch_queue(self):
71
def connection_made(self, transport):
72
self.peername = transport.get_extra_info('peername')
73
self.transport = transport
74
- self.greeted = False
75
connected_peers_guage.inc()
76
self.incoming_buffer = DataBuffer(loop=self.loop)
77
self.loop.create_task(self.wait_greeting())
@@ -100,7 +99,6 @@ async def wait_greeting(self):
100
99
self.transport.close()
101
102
def handle_handshake(self, data):
103
- self.greeted = True
104
self.id = data["id"]
105
self.meta = data.get("meta", {})
106
self.receptor.add_connection(self)
0 commit comments