/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/boto/glacier/ |
H A D | concurrent.py | 71 worker_queue.put((i, part_size)) 73 worker_queue.put(_END_SENTINEL) 132 worker_queue = Queue() 144 worker_queue, filename) 188 def __init__(self, worker_queue, result_queue): argument 190 self._worker_queue = worker_queue 218 worker_queue, result_queue, num_retries=5, argument 302 worker_queue = Queue() 305 self._start_download_threads(result_queue, worker_queue) 352 def _start_download_threads(self, result_queue, worker_queue): argument [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/boto/glacier/ |
H A D | concurrent.py | 71 worker_queue.put((i, part_size)) 73 worker_queue.put(_END_SENTINEL) 132 worker_queue = Queue() 144 worker_queue, filename) 188 def __init__(self, worker_queue, result_queue): argument 190 self._worker_queue = worker_queue 218 worker_queue, result_queue, num_retries=5, argument 302 worker_queue = Queue() 305 self._start_download_threads(result_queue, worker_queue) 352 def _start_download_threads(self, result_queue, worker_queue): argument [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/boto/glacier/ |
H A D | concurrent.py | 71 worker_queue.put((i, part_size)) 73 worker_queue.put(_END_SENTINEL) 132 worker_queue = Queue() 144 worker_queue, filename) 188 def __init__(self, worker_queue, result_queue): argument 190 self._worker_queue = worker_queue 218 worker_queue, result_queue, num_retries=5, argument 302 worker_queue = Queue() 305 self._start_download_threads(result_queue, worker_queue) 352 def _start_download_threads(self, result_queue, worker_queue): argument [all …]
|
/dports/devel/py-boto/boto-2.49.0/boto/glacier/ |
H A D | concurrent.py | 71 worker_queue.put((i, part_size)) 73 worker_queue.put(_END_SENTINEL) 132 worker_queue = Queue() 144 worker_queue, filename) 188 def __init__(self, worker_queue, result_queue): argument 190 self._worker_queue = worker_queue 218 worker_queue, result_queue, num_retries=5, argument 302 worker_queue = Queue() 305 self._start_download_threads(result_queue, worker_queue) 352 def _start_download_threads(self, result_queue, worker_queue): argument [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | lbbroker.go | 105 worker_queue := make([]string, 0, 10) 116 if len(worker_queue) > 0 { 128 if !(len(worker_queue) < NBR_WORKERS) { 131 worker_queue = append(worker_queue, worker_id) 167 backend.Send(worker_queue[0], zmq.SNDMORE) 174 worker_queue = worker_queue[1:]
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | lbbroker.go | 105 worker_queue := make([]string, 0, 10) 116 if len(worker_queue) > 0 { 128 if !(len(worker_queue) < NBR_WORKERS) { 131 worker_queue = append(worker_queue, worker_id) 167 backend.Send(worker_queue[0], zmq.SNDMORE) 174 worker_queue = worker_queue[1:]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | lbbroker.go | 105 worker_queue := make([]string, 0, 10) 116 if len(worker_queue) > 0 { 128 if !(len(worker_queue) < NBR_WORKERS) { 131 worker_queue = append(worker_queue, worker_id) 167 backend.Send(worker_queue[0], zmq.SNDMORE) 174 worker_queue = worker_queue[1:]
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | lbbroker.go | 105 worker_queue := make([]string, 0, 10) 116 if len(worker_queue) > 0 { 128 if !(len(worker_queue) < NBR_WORKERS) { 131 worker_queue = append(worker_queue, worker_id) 167 backend.Send(worker_queue[0], zmq.SNDMORE) 174 worker_queue = worker_queue[1:]
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 58 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 61 worker_queue_(worker_queue), in AecDumpImpl() 169 rtc::TaskQueue* worker_queue) { in Create() argument 170 RTC_DCHECK(worker_queue); in Create() 180 worker_queue); in Create() 185 rtc::TaskQueue* worker_queue) { in Create() argument 186 RTC_DCHECK(worker_queue); in Create() 192 worker_queue); in Create() 197 rtc::TaskQueue* worker_queue) { in Create() argument 198 RTC_DCHECK(worker_queue); in Create() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 58 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 61 worker_queue_(worker_queue), in AecDumpImpl() 169 rtc::TaskQueue* worker_queue) { in Create() argument 170 RTC_DCHECK(worker_queue); in Create() 180 worker_queue); in Create() 185 rtc::TaskQueue* worker_queue) { in Create() argument 186 RTC_DCHECK(worker_queue); in Create() 192 worker_queue); in Create() 197 rtc::TaskQueue* worker_queue) { in Create() argument 198 RTC_DCHECK(worker_queue); in Create() [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 58 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 61 worker_queue_(worker_queue), in AecDumpImpl() 169 rtc::TaskQueue* worker_queue) { in Create() argument 170 RTC_DCHECK(worker_queue); in Create() 180 worker_queue); in Create() 185 rtc::TaskQueue* worker_queue) { in Create() argument 186 RTC_DCHECK(worker_queue); in Create() 192 worker_queue); in Create() 197 rtc::TaskQueue* worker_queue) { in Create() argument 198 RTC_DCHECK(worker_queue); in Create() [all …]
|
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/tests/unit/glacier/ |
H A D | test_concurrent.py | 36 worker_queue, filename): argument 38 self.worker_queue = worker_queue 47 def _start_download_threads(self, results_queue, worker_queue): argument 49 self.worker_queue = worker_queue 89 q = uploader.worker_queue 118 q = downloader.worker_queue
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/tests/unit/glacier/ |
H A D | test_concurrent.py | 36 worker_queue, filename): argument 38 self.worker_queue = worker_queue 47 def _start_download_threads(self, results_queue, worker_queue): argument 49 self.worker_queue = worker_queue 89 q = uploader.worker_queue 118 q = downloader.worker_queue
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/tests/unit/glacier/ |
H A D | test_concurrent.py | 36 worker_queue, filename): argument 38 self.worker_queue = worker_queue 47 def _start_download_threads(self, results_queue, worker_queue): argument 49 self.worker_queue = worker_queue 89 q = uploader.worker_queue 118 q = downloader.worker_queue
|
/dports/devel/py-boto/boto-2.49.0/tests/unit/glacier/ |
H A D | test_concurrent.py | 36 worker_queue, filename): argument 38 self.worker_queue = worker_queue 47 def _start_download_threads(self, results_queue, worker_queue): argument 49 self.worker_queue = worker_queue 89 q = uploader.worker_queue 118 q = downloader.worker_queue
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 60 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 63 worker_queue_(worker_queue), in AecDumpImpl() 234 rtc::TaskQueue* worker_queue) { in Create() argument 235 RTC_DCHECK(worker_queue); in Create() 240 worker_queue); in Create() 245 rtc::TaskQueue* worker_queue) { in Create() argument 247 max_log_size_bytes, worker_queue); in Create() 252 rtc::TaskQueue* worker_queue) { in Create() argument 253 return Create(FileWrapper(handle), max_log_size_bytes, worker_queue); in Create()
|
/dports/math/fftw3-float/fftw-3.3.9/threads/ |
H A D | threads.c | 286 static struct worker *worker_queue; variable 326 q->cdr = worker_queue; in enqueue() 327 worker_queue = q; in enqueue() 336 q = worker_queue; in dequeue() 338 worker_queue = q->cdr; in dequeue() 365 while (worker_queue) { in kill_workforce() 366 struct worker *q = worker_queue; in kill_workforce() 367 worker_queue = q->cdr; in kill_workforce() 385 worker_queue = 0; in X()
|
/dports/math/fftw3/fftw-3.3.9/threads/ |
H A D | threads.c | 286 static struct worker *worker_queue; variable 326 q->cdr = worker_queue; in enqueue() 327 worker_queue = q; in enqueue() 336 q = worker_queue; in dequeue() 338 worker_queue = q->cdr; in dequeue() 365 while (worker_queue) { in kill_workforce() 366 struct worker *q = worker_queue; in kill_workforce() 367 worker_queue = q->cdr; in kill_workforce() 385 worker_queue = 0; in X()
|
/dports/math/fftw3-long/fftw-3.3.9/threads/ |
H A D | threads.c | 286 static struct worker *worker_queue; variable 326 q->cdr = worker_queue; in enqueue() 327 worker_queue = q; in enqueue() 336 q = worker_queue; in dequeue() 338 worker_queue = q->cdr; in dequeue() 365 while (worker_queue) { in kill_workforce() 366 struct worker *q = worker_queue; in kill_workforce() 367 worker_queue = q->cdr; in kill_workforce() 385 worker_queue = 0; in X()
|
/dports/math/fftw3-quad/fftw-3.3.9/threads/ |
H A D | threads.c | 286 static struct worker *worker_queue; variable 326 q->cdr = worker_queue; in enqueue() 327 worker_queue = q; in enqueue() 336 q = worker_queue; in dequeue() 338 worker_queue = q->cdr; in dequeue() 365 while (worker_queue) { in kill_workforce() 366 struct worker *q = worker_queue; in kill_workforce() 367 worker_queue = q->cdr; in kill_workforce() 385 worker_queue = 0; in X()
|
/dports/devel/grpc130/grpc-1.30.2/src/ruby/lib/grpc/generic/ |
H A D | rpc_server.rb | 67 worker_queue = @ready_workers.pop 69 fail 'worker already has a task waiting' unless worker_queue.empty? 70 worker_queue << [blk, args] 99 worker_queue = @ready_workers.pop 100 worker_queue << [proc { throw :exit }, []] 134 def loop_execute_jobs(worker_queue) argument 137 blk, args = worker_queue.pop 144 fail('received a task while busy') unless worker_queue.empty? 147 @ready_workers << worker_queue
|
/dports/devel/grpc134/grpc-1.34.1/src/ruby/lib/grpc/generic/ |
H A D | rpc_server.rb | 67 worker_queue = @ready_workers.pop 69 fail 'worker already has a task waiting' unless worker_queue.empty? 70 worker_queue << [blk, args] 99 worker_queue = @ready_workers.pop 100 worker_queue << [proc { throw :exit }, []] 134 def loop_execute_jobs(worker_queue) argument 137 blk, args = worker_queue.pop 144 fail('received a task while busy') unless worker_queue.empty? 147 @ready_workers << worker_queue
|
/dports/devel/grpc/grpc-1.42.0/src/ruby/lib/grpc/generic/ |
H A D | rpc_server.rb | 67 worker_queue = @ready_workers.pop 69 fail 'worker already has a task waiting' unless worker_queue.empty? 70 worker_queue << [blk, args] 99 worker_queue = @ready_workers.pop 100 worker_queue << [proc { throw :exit }, []] 134 def loop_execute_jobs(worker_queue) argument 137 blk, args = worker_queue.pop 144 fail('received a task while busy') unless worker_queue.empty? 147 @ready_workers << worker_queue
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 60 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 63 worker_queue_(worker_queue), in AecDumpImpl() 246 rtc::TaskQueue* worker_queue) { in Create() argument 247 RTC_DCHECK(worker_queue); in Create() 252 worker_queue); in Create() 257 rtc::TaskQueue* worker_queue) { in Create() argument 259 max_log_size_bytes, worker_queue); in Create() 264 rtc::TaskQueue* worker_queue) { in Create() argument 265 return Create(FileWrapper(handle), max_log_size_bytes, worker_queue); in Create()
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/modules/audio_processing/aec_dump/ |
H A D | aec_dump_impl.cc | 60 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument 63 worker_queue_(worker_queue), in AecDumpImpl() 240 rtc::TaskQueue* worker_queue) { in Create() argument 241 RTC_DCHECK(worker_queue); in Create() 246 worker_queue); in Create() 251 rtc::TaskQueue* worker_queue) { in Create() argument 253 max_log_size_bytes, worker_queue); in Create() 258 rtc::TaskQueue* worker_queue) { in Create() argument 259 return Create(FileWrapper(handle), max_log_size_bytes, worker_queue); in Create()
|