| /external/rust/crates/tokio/src/ |
| D | coop.rs | 225 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting() localVariable
228 drop(coop); in bugeting()
234 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting() localVariable
236 drop(coop); in bugeting()
240 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting() localVariable
242 coop.made_progress(); in bugeting()
243 drop(coop); in bugeting()
247 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting() localVariable
249 coop.made_progress(); in bugeting()
250 drop(coop); in bugeting()
[all …]
|
| D | lib.rs | 375 pub(crate) mod coop; module
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 475 let coop = ready!(crate::coop::poll_proceed(cx)); in poll_closed() localVariable
482 coop.made_progress(); in poll_closed()
495 coop.made_progress(); in poll_closed()
513 coop.made_progress(); in poll_closed()
727 let coop = ready!(crate::coop::poll_proceed(cx)); in poll_recv() localVariable
733 coop.made_progress(); in poll_recv()
739 coop.made_progress(); in poll_recv()
753 coop.made_progress(); in poll_recv()
774 coop.made_progress(); in poll_recv()
|
| D | batch_semaphore.rs | 440 let coop = ready!(crate::coop::poll_proceed(cx)); in poll() localVariable
450 coop.made_progress(); in poll()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | join.rs | 209 let coop = ready!(crate::coop::poll_proceed(cx)); in poll() localVariable
234 coop.made_progress(); in poll()
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | sleep.rs | 229 let coop = ready!(crate::coop::poll_proceed(cx)); in poll_elapsed() localVariable
232 coop.made_progress(); in poll_elapsed()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | chan.rs | 220 let coop = ready!(crate::coop::poll_proceed(cx)); in recv() localVariable
230 coop.made_progress(); in recv()
241 coop.made_progress(); in recv()
259 coop.made_progress(); in recv()
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | registration.rs | 156 let coop = ready!(crate::coop::poll_proceed(cx)); in poll_ready() localVariable
163 coop.made_progress(); in poll_ready()
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 7 use crate::coop;
182 struct Reset(coop::Budget); in block_in_place()
195 coop::set(self.0); in block_in_place()
262 let _reset = Reset(coop::stop()); in block_in_place()
348 coop::budget(|| { in run_task()
367 if coop::has_budget_remaining() { in run_task()
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_iter.rs | 7 async fn coop() { in coop() function
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | task.rs | 40 crate::coop::stop(); in poll()
|
| /external/rust/crates/tokio/src/task/ |
| D | unconstrained.rs | 24 crate::coop::with_unconstrained(|| inner.poll(cx))
|
| D | local.rs | 514 Some(task) => crate::coop::budget(|| task.run()), in tick()
634 if let Poll::Ready(output) = crate::coop::budget(|| f.poll(cx)) { in poll()
|
| /external/rust/crates/tokio/src/process/ |
| D | mod.rs | 848 let coop = ready!(crate::coop::poll_proceed(cx)); in poll() localVariable
858 coop.made_progress(); in poll()
|
| /external/rust/crates/tokio/tests/ |
| D | fs_file.rs | 54 async fn coop() { in coop() function
|
| D | rt_common.rs | 993 fn coop() {
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 111 if let Ready(v) = crate::coop::budget(|| f.as_mut().poll(&mut cx)) { in block_on()
|
| D | basic_scheduler.rs | 213 if let Ready(v) = crate::coop::budget(|| future.as_mut().poll(&mut cx)) { in block_on()
254 Entry::Schedule(task) => crate::coop::budget(|| task.run()), in block_on()
|
| D | enter.rs | 176 if let Ready(v) = crate::coop::budget(|| f.as_mut().poll(&mut cx)) {
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 263 if let Ready(v) = crate::coop::budget(|| f.as_mut().poll(&mut cx)) { in block_on()
|
| /external/protobuf/docs/ |
| D | options.md | 45 * Website: http://www.plausible.coop
|
| /external/llvm-project/mlir/include/mlir/Dialect/SPIRV/ |
| D | SPIRVCooperativeMatrixOps.td | 246 coop-matrix-store-op ::= `spv.CooperativeMatrixStoreNV `
|
| /external/icu/icu4c/source/test/testdata/ |
| D | regextst.txt | 2112 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
2113 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
2114 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
2115 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
2116 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
2117 …]+)*@[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*\.(([0-9]{1,3})|([a-zA-Z]{2,3})|(aero|coop|info|museum|name))$…
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 85 - coop: expose an `unconstrained()` opt-out ([#3547])
584 - coop: returning `Poll::Pending` no longer decrements the task budget ([#2549])
|
| /external/python/cpython2/Modules/_ctypes/libffi/ |
| D | ChangeLog | 3375 Author: Landon Fuller <landonf@plausible.coop>
|