| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-threadpool-0.1.17/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/tokio-threadpool/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/tokio-threadpool/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-threadpool-0.1.18/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-threadpool-0.1.18/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/tokio-threadpool-0.1.18/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/tokio-threadpool/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/tokio-threadpool/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-threadpool-0.1.17/tests/ |
| H A D | blocking.rs | 30 let res = blocking(|| { in basic()
57 let res = blocking(|| { in other_executors_can_run_inside_blocking()
85 blocking(|| { in notify_task_on_capacity()
122 blocking(|| { in capacity_is_use_it_or_lose_it()
132 blocking(|| { in capacity_is_use_it_or_lose_it()
207 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
223 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
265 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
272 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
327 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/irc/ergo/ergo-2.8.0/irc/ |
| H A D | responsebuffer.go | 180 rb.session.SendRawMessage(message, blocking)
183 func (rb *ResponseBuffer) sendBatchEnd(blocking bool) {
190 rb.session.SendRawMessage(message, blocking)
238 func (rb *ResponseBuffer) Send(blocking bool) error {
239 return rb.flushInternal(true, blocking)
246 func (rb *ResponseBuffer) Flush(blocking bool) error {
247 return rb.flushInternal(false, blocking)
282 rb.sendBatchStart(blocking)
291 rb.session.SendRawMessage(message, blocking)
304 rb.session.SendRawMessage(message, blocking)
[all …]
|
| /dports/deskutils/xpad/xpad-5.4.0/src/ |
| H A D | xpad-session-manager.c | 113 if (blocking) in xpad_session_manager_start_interact_callback()
115 blocking = FALSE; in xpad_session_manager_start_interact_callback()
145 blocking = TRUE; in xpad_session_manager_start_interact()
153 blocking = FALSE; in xpad_session_manager_start_interact()
164 if (!blocking) in xpad_session_manager_stop_interact()
404 if (blocking) in xpad_session_manager_die()
406 blocking = FALSE; in xpad_session_manager_die()
423 if (blocking) in xpad_session_manager_shutdown_cancelled()
425 blocking = FALSE; in xpad_session_manager_shutdown_cancelled()
439 if (blocking) in xpad_session_manager_save_complete()
[all …]
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/tokio-threadpool-0.1.14/tests/ |
| H A D | blocking.rs | 29 let res = blocking(|| { in basic()
62 blocking(|| { in notify_task_on_capacity()
99 blocking(|| { in capacity_is_use_it_or_lose_it()
109 blocking(|| { in capacity_is_use_it_or_lose_it()
132 let res = blocking(|| unreachable!()).map_err(|_| panic!()); in capacity_is_use_it_or_lose_it()
184 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
200 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
242 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
249 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
304 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/tokio-threadpool-0.1.14/tests/ |
| H A D | blocking.rs | 29 let res = blocking(|| { in basic()
62 blocking(|| { in notify_task_on_capacity()
99 blocking(|| { in capacity_is_use_it_or_lose_it()
109 blocking(|| { in capacity_is_use_it_or_lose_it()
132 let res = blocking(|| unreachable!()).map_err(|_| panic!()); in capacity_is_use_it_or_lose_it()
184 blocking(|| { in blocking_thread_does_not_take_over_shutdown_worker_thread()
200 let res = blocking(|| {}).unwrap(); in blocking_thread_does_not_take_over_shutdown_worker_thread()
242 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
249 let res = blocking(|| { in blocking_one_time_gets_capacity_for_multiple_blocks()
304 let res = blocking(|| { in shutdown()
[all …]
|
| /dports/databases/py-redis2/redis-py-2.10.6/redis/ |
| H A D | lock.py | 18 blocking=True, blocking_timeout=None, thread_local=True): argument
73 self.blocking = blocking
84 self.acquire(blocking=True)
90 def acquire(self, blocking=None, blocking_timeout=None): argument
103 if blocking is None:
104 blocking = self.blocking
114 if not blocking:
|
| /dports/devel/py-distributed/distributed-2021.11.2/docs/source/ |
| H A D | api.rst | 78 Most methods and functions can be used equally well within a blocking or
80 IOLoop then you should yield or await otherwise blocking operations
88 # blocking
90 future = client.submit(func, *args) # immediate, no blocking/async difference
91 result = client.gather(future) # blocking
95 future = client.submit(func, *args) # immediate, no blocking/async difference
96 result = yield client.gather(future) # non-blocking/asynchronous
100 future = client.submit(func, *args) # immediate, no blocking/async difference
101 result = await client.gather(future) # non-blocking/asynchronous
|
| /dports/devel/arcanist-lib/arcanist-b2e715f/src/hardpoint/ |
| H A D | ArcanistHardpointTask.php | 212 $blocking = array();
216 $blocking[$key] = $request;
220 $this->blockingRequests = $blocking;
222 return $blocking;
226 $blocking = array();
230 $blocking[$key] = $future;
234 $this->blockingFutures = $blocking;
236 return $blocking;
|
| /dports/devel/arcanist/arcanist-b2e715f/src/hardpoint/ |
| H A D | ArcanistHardpointTask.php | 212 $blocking = array();
216 $blocking[$key] = $request;
220 $this->blockingRequests = $blocking;
222 return $blocking;
226 $blocking = array();
230 $blocking[$key] = $future;
234 $this->blockingFutures = $blocking;
236 return $blocking;
|
| /dports/editors/neovim/neovim-0.6.1/test/functional/terminal/ |
| H A D | ex_terminal_spec.lua | 101 eq({ blocking=false, mode='nt' }, nvim('get_mode'))
103 eq({ blocking=false, mode='t' }, nvim('get_mode'))
105 eq({ blocking=false, mode='nt' }, nvim('get_mode'))
111 eq({ blocking=false, mode='t' }, nvim('get_mode'))
113 eq({ blocking=false, mode='nt' }, nvim('get_mode'))
118 eq({ blocking=false, mode='nt' }, nvim('get_mode'))
120 eq({ blocking=false, mode='nt' }, nvim('get_mode'))
122 eq({ blocking=false, mode='t' }, nvim('get_mode'))
|
| /dports/sysutils/liburcu/userspace-rcu-0.13.0/include/urcu/static/ |
| H A D | wfstack.h | 164 ___cds_wfs_node_sync_next(struct cds_wfs_node *node, int blocking) in ___cds_wfs_node_sync_next() argument
173 if (!blocking) in ___cds_wfs_node_sync_next()
188 ___cds_wfs_pop(cds_wfs_stack_ptr_t u_stack, int *state, int blocking) in ___cds_wfs_pop() argument
201 next = ___cds_wfs_node_sync_next(&head->node, blocking); in ___cds_wfs_pop()
202 if (!blocking && next == CDS_WFS_WOULDBLOCK) { in ___cds_wfs_pop()
211 if (!blocking) { in ___cds_wfs_pop()
401 ___cds_wfs_next(struct cds_wfs_node *node, int blocking) in ___cds_wfs_next() argument
405 next = ___cds_wfs_node_sync_next(node, blocking); in ___cds_wfs_next()
|
| /dports/devel/vexcl/vexcl-1.4.3/vexcl/ |
| H A D | vector.hpp | 818 if (blocking) in write_data()
849 if (blocking) in write_data()
872 if (blocking) in read_data()
904 if (blocking) in read_data()
1001 dv.read_data(0, dv.size(), hv.data(), blocking); in copy()
1016 dv.read_data(0, dv.size(), hv, blocking); in copy()
1047 dv.write_data(0, dv.size(), hv, blocking); in copy()
1077 dv.read_data(0, dv.size(), hv, blocking, q); in copy()
1114 dv.write_data(0, dv.size(), hv, blocking, q); in copy()
1156 OutputIterator result, bool blocking = true) in copy() argument
[all …]
|
| /dports/databases/p5-Mango/Mango-1.30/t/ |
| H A D | collection.t | 31 # Insert documents blocking
74 # Update documents blocking
97 # Remove one document blocking
131 # Get options blocking
134 # Get options non-blocking
166 # Aggregate collection blocking
247 # Save document blocking
263 # Save document non-blocking
312 # Drop collection blocking
318 # Drop collection non-blocking
[all …]
|
| /dports/lang/intel-compute-runtime/compute-runtime-21.52.22081/opencl/test/unit_test/command_queue/ |
| H A D | buffer_operations_fixture.h | 44 void enqueueWriteBuffer(cl_bool blocking = EnqueueWriteBufferTraits::blocking) {
48 blocking);
55 void enqueueWriteBuffer(bool blocking, void *inputData, int size) { in enqueueWriteBuffer()
59 blocking, in enqueueWriteBuffer()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/node_modules/set-blocking/ |
| H A D | CHANGELOG.md | 6 # [2.0.0](https://github.com/yargs/set-blocking/compare/v1.0.0...v2.0.0) (2016-05-17)
11 … check ([#3](https://github.com/yargs/set-blocking/issues/3)) ([66ce277](https://github.com/yargs/…
16 * stdio/stderr will not be set to blocking if isTTY === false
26 * implemented shim for stream._handle.setBlocking ([6bde0c0](https://github.com/yargs/set-blocking/…
|
| /dports/www/npm-node14/npm-6.14.8/lib/node_modules/npm/node_modules/set-blocking/ |
| H A D | CHANGELOG.md | 6 # [2.0.0](https://github.com/yargs/set-blocking/compare/v1.0.0...v2.0.0) (2016-05-17)
11 … check ([#3](https://github.com/yargs/set-blocking/issues/3)) ([66ce277](https://github.com/yargs/…
16 * stdio/stderr will not be set to blocking if isTTY === false
26 * implemented shim for stream._handle.setBlocking ([6bde0c0](https://github.com/yargs/set-blocking/…
|
| /dports/www/npm-node16/npm-6.14.8/lib/node_modules/npm/node_modules/set-blocking/ |
| H A D | CHANGELOG.md | 6 # [2.0.0](https://github.com/yargs/set-blocking/compare/v1.0.0...v2.0.0) (2016-05-17)
11 … check ([#3](https://github.com/yargs/set-blocking/issues/3)) ([66ce277](https://github.com/yargs/…
16 * stdio/stderr will not be set to blocking if isTTY === false
26 * implemented shim for stream._handle.setBlocking ([6bde0c0](https://github.com/yargs/set-blocking/…
|