Searched refs:awaiter (Results 1 – 9 of 9) sorted by relevance
114 awaiter: UnsafeCell::new(None), in allocate()455 let mut awaiter = None; in run() localVariable457 awaiter = (*raw.header).take(None); in run()464 if let Some(w) = awaiter { in run()523 let mut awaiter = None; in run() localVariable525 awaiter = (*raw.header).take(None); in run()532 if let Some(w) = awaiter { in run()574 let mut awaiter = None; in run() localVariable576 awaiter = (*raw.header).take(None); in run()583 if let Some(w) = awaiter { in run()[all …]
22 pub(crate) awaiter: UnsafeCell<Option<Waker>>, field53 let waker = unsafe { (*self.awaiter.get()).take() }; in take()109 abort_on_panic(|| (*self.awaiter.get()) = Some(waker.clone())); in register()119 if let Some(w) = unsafe { (*self.awaiter.get()).take() } { in register()
180 for (auto &awaiter : group->awaiters) in mlirAsyncRuntimeAddTokenToGroup() local181 awaiter(); in mlirAsyncRuntimeAddTokenToGroup()215 for (auto &awaiter : token->awaiters) in mlirAsyncRuntimeEmplaceToken() local216 awaiter(); in mlirAsyncRuntimeEmplaceToken()
207 private suspend fun awaiter() { in <lambda>() method in kotlinx.coroutines.exceptions.StackTraceRecoveryTest215 val await = suspend { awaiter() } in <lambda>()
44 bool await_suspend(std::experimental::coroutine_handle<> awaiter) { return false; } in await_suspend()
450 val awaiter = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant455 assertNull(awaiter.await()) in <lambda>()
846 public Runnable awaiter(final CountDownLatch latch) {
863 public Runnable awaiter(final CountDownLatch latch) {