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

Extract a common _reset() method.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-10 20:33:32 -04:00
parent 81c58c540b
commit fbd2b1f699
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
p2pfs/core/tracker.py
View file

@ -24,14 +24,17 @@ class Tracker(MessageServer):
def peers(self):
return tuple(self._peers.values())
def _reset(self):
self._peers = {}
self._file_list = {}
self._chunkinfo = {}
async def stop(self):
await super().stop()
if len(self._peers) != 0:
logger.warning('Peers dict not fully cleared {}'.format(self._peers))
self._peers = {}
self._file_list = {}
self._chunkinfo = {}
self._reset()
async def _process_connection(self, reader, writer):
assert isinstance(reader, asyncio.StreamReader) and isinstance(writer, asyncio.StreamWriter)