From 2e482d67cc4447ead7a53d547273f264c08af0fb Mon Sep 17 00:00:00 2001 From: Noah Levitt Date: Wed, 16 Sep 2015 18:18:43 +0000 Subject: [PATCH] more patience waiting for warc writer thread --- warcprox/tests/test_warcprox.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/warcprox/tests/test_warcprox.py b/warcprox/tests/test_warcprox.py index 0331c7b..a994810 100755 --- a/warcprox/tests/test_warcprox.py +++ b/warcprox/tests/test_warcprox.py @@ -395,6 +395,7 @@ def test_dedup_http(http_daemon, warcprox_, archiving_proxies, playback_proxies) assert response.content == b'I am the warcprox test payload! ffffffffff!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5) @@ -457,6 +458,7 @@ def test_dedup_https(https_daemon, warcprox_, archiving_proxies, playback_proxie assert response.content == b'I am the warcprox test payload! hhhhhhhhhh!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5) @@ -486,6 +488,7 @@ def test_limits(http_daemon, warcprox_, archiving_proxies): assert response.content == b'I am the warcprox test payload! jjjjjjjjjj!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5) @@ -509,6 +512,7 @@ def test_dedup_buckets(https_daemon, http_daemon, warcprox_, archiving_proxies, assert response.content == b'I am the warcprox test payload! llllllllll!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5) @@ -532,6 +536,7 @@ def test_dedup_buckets(https_daemon, http_daemon, warcprox_, archiving_proxies, assert response.content == b'I am the warcprox test payload! llllllllll!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5) @@ -558,6 +563,7 @@ def test_dedup_buckets(https_daemon, http_daemon, warcprox_, archiving_proxies, assert response.content == b'I am the warcprox test payload! llllllllll!\n' # wait for writer thread to process + time.sleep(0.5) while not warcprox_.warc_writer_thread.idle: time.sleep(0.5)