minor changes for debugging

This commit is contained in:
Vadim Ushakov 2021-10-20 14:02:00 +07:00
parent abbd2c51f0
commit b9ec7124f9
2 changed files with 8 additions and 1 deletions

View file

@ -1,3 +1,4 @@
import logging
import time import time
import itertools import itertools
@ -94,6 +95,7 @@ class SiteAnnouncerPlugin(object):
tracker_ip, tracker_port = tracker_address.rsplit(":", 1) tracker_ip, tracker_port = tracker_address.rsplit(":", 1)
tracker_peer = Peer(str(tracker_ip), int(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
#tracker_peer.log_level = logging.INFO
connection_pool[tracker_address] = tracker_peer connection_pool[tracker_address] = tracker_peer
res = tracker_peer.request("announce", request) res = tracker_peer.request("announce", request)

View file

@ -1357,8 +1357,13 @@ class Site(object):
else: else:
peers = list(self.peers.values()) peers = list(self.peers.values())
self.log.info("%s" % peers)
self.log.info("%s" % need_more)
peers = peers[0:need_more * 50]
found_more = sorted( found_more = sorted(
peers[0:need_more * 50], peers,
key=lambda peer: peer.reputation, key=lambda peer: peer.reputation,
reverse=True reverse=True
)[0:need_more * 2] )[0:need_more * 2]