masscollaborationlabs/p2pfs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use a tuple to store host and port.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-06 10:28:15 -04:00
parent b9a4fb0876
commit f72e9bf17d
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
p2pfs/core/server.py
View file

@ -31,8 +31,7 @@ class MessageServer:
_SOCKET_TIMEOUT = 5
def __init__(self, host, port, loop=None):
self._host = host
self._port = port
self._address = (host, port)
self._loop = loop
self._compressor = zstd.ZstdCompressor()
@ -42,9 +41,9 @@ class MessageServer:
self._writers = set()
async def start(self):
logger.info('Start listening on {}'.format((self._host, self._port)))
logger.info('Start listening on {}'.format(self._address))
# start server
await asyncio.start_server(self.__new_connection, self._host, self._port, loop=self._loop)
await asyncio.start_server(self.__new_connection, *self._address, loop=self._loop)
async def stop(self):
for writer in self._writers: