Home
last modified time | relevance | path

Searched refs:worker_queue (Results 1 – 25 of 138) sorted by relevance

123456

/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/boto/glacier/
H A Dconcurrent.py71 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 Dconcurrent.py71 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 Dconcurrent.py71 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 Dconcurrent.py71 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 Dlbbroker.go105 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 Dlbbroker.go105 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 Dlbbroker.go105 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 Dlbbroker.go105 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 Daec_dump_impl.cc58 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 Daec_dump_impl.cc58 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 Daec_dump_impl.cc58 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 Dtest_concurrent.py36 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 Dtest_concurrent.py36 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 Dtest_concurrent.py36 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 Dtest_concurrent.py36 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 Daec_dump_impl.cc60 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 Dthreads.c286 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 Dthreads.c286 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 Dthreads.c286 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 Dthreads.c286 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 Drpc_server.rb67 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 Drpc_server.rb67 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 Drpc_server.rb67 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 Daec_dump_impl.cc60 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 Daec_dump_impl.cc60 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()

123456