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

Lazy connection to server for peer.

Browse source
This commit is contained in:
Yuxin Wang 2018-09-30 10:10:15 -04:00
parent cc5bbc4701
commit d6601b0cec
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
p2pfs/core/peer.py
View file

@ -15,6 +15,9 @@ class Peer(MessageServer):
def __init__(self, host, port, server, server_port):
super().__init__(host, port)
self._serverconfig = (server, server_port)
self._server_sock = None
self._peers = {}
# (remote filename) <-> (local filename)
self._file_map = {}
@ -32,12 +35,14 @@ class Peer(MessageServer):
self._download_lock = threading.Lock()
self._download_results = {}
def start(self):
# socket connected to server
try:
self._server_sock = self._connect(server, server_port)
self._server_sock = self._connect(*self._serverconfig)
except ConnectionRefusedError:
logger.error('Server connection refused!')
exit(1)
super().start()
def publish(self, file):
path, filename = os.path.split(file)