From 54ce2ddaa1d6e2fba9b9a8c86c359153fca49721 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Fri, 11 Jan 2019 14:56:03 +0800 Subject: [PATCH] Update simdht_worker.py --- plugins/simdht/workers/simdht_worker.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/plugins/simdht/workers/simdht_worker.py b/plugins/simdht/workers/simdht_worker.py index 7e3a583cb..dc4624f6a 100755 --- a/plugins/simdht/workers/simdht_worker.py +++ b/plugins/simdht/workers/simdht_worker.py @@ -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'])