backup/warcprox
1
0
Fork 0
mirror of https://github.com/internetarchive/warcprox.git synced 2025-01-18 13:22:09 +01:00
Code Issues Projects Releases Activity

fix zero-indexing of warc_writer_threads so they can be disabled via empty list

Browse Source
This commit is contained in:
Pascal Jürgens 2017-08-18 15:52:34 +02:00
parent 13ee68ce4a
commit 940af4e888
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
warcprox/controller.py
View File

@ -176,7 +176,7 @@ class WarcproxController(object):
assert(all(
wwt.dedup_db is self.warc_writer_threads[0].dedup_db
for wwt in self.warc_writer_threads))
if self.warc_writer_threads[0].dedup_db:
if any((t.dedup_db for t in self.warc_writer_threads)):
self.warc_writer_threads[0].dedup_db.start()
for wwt in self.warc_writer_threads:
@ -211,7 +211,7 @@ class WarcproxController(object):
if self.proxy.stats_db:
self.proxy.stats_db.stop()
if self.warc_writer_threads[0].dedup_db:
if any((t.dedup_db for t in self.warc_writer_threads)):
self.warc_writer_threads[0].dedup_db.close()
self.proxy_thread.join()