Always call addPeer command with strip ip address and int port
This commit is contained in:
parent
5f33516054
commit
1eacc26ef9
2 changed files with 2 additions and 2 deletions
|
@ -87,7 +87,7 @@ class SiteAnnouncerPlugin(object):
|
||||||
tracker_peer = connection_pool.get(tracker_address) # Re-use tracker connection if possible
|
tracker_peer = connection_pool.get(tracker_address) # Re-use tracker connection if possible
|
||||||
if not tracker_peer:
|
if not tracker_peer:
|
||||||
tracker_ip, tracker_port = tracker_address.split(":")
|
tracker_ip, tracker_port = tracker_address.split(":")
|
||||||
tracker_peer = Peer(tracker_ip, tracker_port, connection_server=self.site.connection_server)
|
tracker_peer = Peer(str(tracker_ip), int(tracker_port), connection_server=self.site.connection_server)
|
||||||
tracker_peer.is_tracker_connection = True
|
tracker_peer.is_tracker_connection = True
|
||||||
connection_pool[tracker_address] = tracker_peer
|
connection_pool[tracker_address] = tracker_peer
|
||||||
|
|
||||||
|
|
|
@ -41,7 +41,7 @@ class ContentDbPlugin(object):
|
||||||
num = 0
|
num = 0
|
||||||
num_hashfield = 0
|
num_hashfield = 0
|
||||||
for row in res:
|
for row in res:
|
||||||
peer = site.addPeer(row["address"], row["port"])
|
peer = site.addPeer(str(row["address"]), row["port"])
|
||||||
if not peer: # Already exist
|
if not peer: # Already exist
|
||||||
continue
|
continue
|
||||||
if row["hashfield"]:
|
if row["hashfield"]:
|
||||||
|
|
Loading…
Reference in a new issue