Add new connection log.

This commit is contained in:
Yuxin Wang 2018-10-06 22:52:02 -04:00
parent 1db203575f
commit 3f579fc25e

View file

@ -25,6 +25,7 @@ class Tracker(MessageServer):
async def _process_connection(self, reader, writer):
assert isinstance(reader, asyncio.StreamReader) and isinstance(writer, asyncio.StreamWriter)
logger.info('New connection from {}'.format(writer.get_extra_info('peername')))
self._peers[writer] = None
while not reader.at_eof():
message = await self._read_message(reader)