From 6888a5aae19973384f96d5ed9528a7a81eefb0af Mon Sep 17 00:00:00 2001 From: Matt Martz Date: Mon, 10 Mar 2014 12:19:08 -0500 Subject: [PATCH] Use socket logic to determine proper number of threads for upload --- speedtest_cli.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/speedtest_cli.py b/speedtest_cli.py index a2c7017..f4bf1f9 100755 --- a/speedtest_cli.py +++ b/speedtest_cli.py @@ -808,6 +808,8 @@ class Speedtest(object): cons_thread.join(timeout=0.1) self._results.download = (sum(finished) / (time.time() - start)) + if self._results.download > 100000: + self.config['threads']['upload'] = 8 return self._results.download def upload(self, callback=None): @@ -843,7 +845,7 @@ class Speedtest(object): callback(thread.i, size_count, end=True) del thread - q = Queue(6) + q = Queue(self.config['threads']['upload']) prod_thread = threading.Thread(target=producer, args=(q, sizes, size_count)) cons_thread = threading.Thread(target=consumer, args=(q, size_count))