This commit is contained in:
mickael
2019-01-05 22:57:57 +00:00

View File

@@ -121,7 +121,7 @@ class WorkerThread():
if self.done.is_set(): break
time.sleep(0.01)
if self.thread:
_log("thread %s terminated", self.id)
_log("thread terminated", self.id)
class Proxywatchd():
@@ -179,6 +179,7 @@ class Proxywatchd():
self.collected.extend(wt.collect())
def submit_collected(self):
_log("watchd main thread: updating %d entries"%len(self.collected))
self._prep_db()
query = 'UPDATE proxylist SET failed=?,tested=?,dronebl=?,country=?,proto=?,duration=?,success_count=?,total_duration=? WHERE proxy=?'
args = [ (job.failcount, job.nextcheck, 1, 'unknown', job.proto, job.success_count, job.total_duration, job.duration, job.proxy) for job in self.collected ]