Update simdht_worker.py

This commit is contained in:
Mr Chen
2019-01-11 14:56:03 +08:00
parent 97c02f00a0
commit 557aabfaf8
-3
View File
@@ -350,7 +350,6 @@ class Master(Thread):
self.name = threading.currentThread().getName()
print self.name, 'started'
while True:
while self.metadata_queue.qsize() > 0:
self.got_torrent()
address, binhash, dtype = self.queue.get()
@@ -399,8 +398,6 @@ class Master(Thread):
print 'n_d_pt', self.n_downloading_pt, 'n_d_lt', self.n_downloading_lt,
self.n_reqs = self.n_valid = self.n_new = 0
self.check_db_size()
def log_announce(self, binhash, address=None):
self.queue.put([address, binhash, 'pt'])