Remove peers member.
We don't have to maintain the list of peers since we only connect when needed.
This commit is contained in:
parent
f5776ed9cd
commit
a755f21fd1
2 changed files with 0 additions and 12 deletions
|
@ -18,7 +18,6 @@ class Peer(MessageServer):
|
|||
self._serverconfig = (server, server_port)
|
||||
self._server_sock = None
|
||||
|
||||
self._peers = {}
|
||||
# (remote filename) <-> (local filename)
|
||||
self._file_map = {}
|
||||
|
||||
|
@ -83,9 +82,6 @@ class Peer(MessageServer):
|
|||
del self._publish_results[filename]
|
||||
return is_success, message
|
||||
|
||||
def peers(self):
|
||||
return tuple(self._peers.values())
|
||||
|
||||
def list_file(self):
|
||||
self._write_message(self._server_sock, {
|
||||
'type': MessageType.REQUEST_FILE_LIST,
|
||||
|
@ -156,11 +152,6 @@ class Peer(MessageServer):
|
|||
|
||||
return True, 'File {} dowloaded to {}'.format(file, destination)
|
||||
|
||||
def _client_connected(self, client):
|
||||
assert isinstance(client, socket.socket)
|
||||
self._peers[client] = None
|
||||
logger.debug(self._peers.values())
|
||||
|
||||
def _process_message(self, client, message):
|
||||
if message['type'] == MessageType.REPLY_REGISTER:
|
||||
logger.info('Successfully registered with id {}'.format(message['id']))
|
||||
|
|
|
@ -24,9 +24,6 @@ class TrackerTerminal(cmd.Cmd):
|
|||
|
||||
print(tabulate(file_list, headers=headers))
|
||||
|
||||
def do_list_peers(self, arg):
|
||||
print(tabulate(self._tracker.peers(), headers=['UUID', 'IP/Port']))
|
||||
|
||||
def do_list_chunkinfo(self, arg):
|
||||
print(self._tracker.chunkinfo())
|
||||
|
||||
|
|
Loading…
Reference in a new issue