From 804fed265909fb0f1448de265ecd8cfcbced8cf9 Mon Sep 17 00:00:00 2001 From: HelloZeroNet Date: Tue, 14 Apr 2015 02:37:31 +0200 Subject: [PATCH] on updates connect to real peer ip, connect using pex in passive mode, referrer typo fix --- src/File/FileRequest.py | 4 ++-- src/Peer/Peer.py | 2 +- src/Site/Site.py | 2 +- src/Ui/UiRequest.py | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/File/FileRequest.py b/src/File/FileRequest.py index a6224df7..b17d6b7b 100644 --- a/src/File/FileRequest.py +++ b/src/File/FileRequest.py @@ -68,7 +68,7 @@ class FileRequest: site.onFileDone(params["inner_path"]) # Trigger filedone if params["inner_path"].endswith("content.json"): # Download every changed file from peer - peer = site.addPeer(*params["peer"], return_peer = True) # Add or get peer + peer = site.addPeer(self.connection.ip, self.connection.port, return_peer = True) # Add or get peer site.onComplete.once(lambda: site.publish(inner_path=params["inner_path"]), "publish_%s" % params["inner_path"]) # On complete publish to other peers gevent.spawn( lambda: site.downloadContent(params["inner_path"], peer=peer) @@ -136,7 +136,7 @@ class FileRequest: random.shuffle(peers) packed_peers = [peer.packAddress() for peer in peers if peer.key not in got_peer_keys][0:params["need"]] if added: - self.log.debug("Added %s peers to %s using PEX, sending back %s" % (added, site, len(packed_peers))) + self.log.debug("Added %s peers to %s using pex, sending back %s" % (added, site, len(packed_peers))) self.response({"peers": packed_peers}) diff --git a/src/Peer/Peer.py b/src/Peer/Peer.py index 755eddbc..a1410e86 100644 --- a/src/Peer/Peer.py +++ b/src/Peer/Peer.py @@ -159,7 +159,7 @@ class Peer: address = self.unpackAddress(peer) if (site.addPeer(*address)): added += 1 if added: - self.log.debug("Added peers using PEX: %s" % added) + self.log.debug("Added peers using pex: %s" % added) return added diff --git a/src/Site/Site.py b/src/Site/Site.py index 78f51e17..8f83850e 100644 --- a/src/Site/Site.py +++ b/src/Site/Site.py @@ -415,7 +415,7 @@ class Site: if connected < need: # Need more than we have for peer in self.peers.values(): if not peer.connection or not peer.connection.connected: # No peer connection or disconnected - peer.connect() + peer.pex() # Initiate peer exchange if peer.connection and peer.connection.connected: connected += 1 # Successfully connected if connected >= need: break return connected diff --git a/src/Ui/UiRequest.py b/src/Ui/UiRequest.py index d0a0c8c8..59946761 100644 --- a/src/Ui/UiRequest.py +++ b/src/Ui/UiRequest.py @@ -198,7 +198,7 @@ class UiRequest(object): referer = self.env.get("HTTP_REFERER") if referer and match: # Only allow same site to receive media if not self.isMediaRequestAllowed(match.group("address"), referer): - return self.error403("Media referer error") # Referer not starts same address as requested path + return self.error403("Media referrer error") # Referrer not starts same address as requested path if match: # Looks like a valid path address = match.group("address")