Searched refs:result_queue (Results 1 – 2 of 2) sorted by relevance
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/glacier/ |
| D | concurrent.py | 133 result_queue = Queue()
143 self._start_upload_threads(result_queue, upload_id,
146 self._wait_for_upload_threads(hash_chunks, result_queue,
160 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
162 result = result_queue.get()
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
181 upload_id, worker_queue, result_queue)
188 def __init__(self, worker_queue, result_queue): argument
191 self._result_queue = result_queue
218 worker_queue, result_queue, num_retries=5, argument
[all …]
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
| D | test_concurrent.py | 41 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
51 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
140 result_queue = Queue()
143 'upload_id', job_queue, result_queue, num_retries=1,
150 result = result_queue.get(timeout=1)
159 result_queue = Queue()
162 'upload_id', job_queue, result_queue, num_retries=2,
|