Home
last modified time | relevance | path

Searched defs:Waiter (Results 1 – 25 of 37) sorted by relevance

12

/external/crosvm/cros_async/src/sync/
Dwaiter.rs116 pub struct Waiter { struct
119 cancel: fn(usize, &Waiter, bool), argument
125 impl Waiter { argument
146 cancel: fn(usize, &Waiter, bool), in new()
149 ) -> Waiter { in new()
/external/libchromeos-rs/src/sync/
Dwaiter.rs121 pub struct Waiter { struct
129 impl Waiter { argument
150 cancel: fn(usize, &Waiter, bool) -> bool, in new()
153 ) -> Waiter { in new()
194 pub fn set_cancel(&self, c: fn(usize, &Waiter, bool) -> bool, data: usize) { in set_cancel()
Dmu.rs70 fn new_waiter(raw: &RawMutex) -> Arc<Waiter>; in new_waiter()
94 fn new_waiter(raw: &RawMutex) -> Arc<Waiter> { in new_waiter()
125 fn new_waiter(raw: &RawMutex) -> Arc<Waiter> { in new_waiter()
609 fn cancel_waiter(&self, waiter: &Waiter, wake_next: bool) -> bool { in cancel_waiter()
643 .map(|front| front as *const Waiter == waiter as *const Waiter) in cancel_waiter() constant
653 let mut cursor = unsafe { waiters.cursor_mut_from_ptr(waiter as *const Waiter) }; in cancel_waiter() constant
714 fn cancel_waiter(raw: usize, waiter: &Waiter, wake_next: bool) -> bool { in cancel_waiter()
/external/rust/crates/tokio/src/sync/
Dbatch_semaphore.rs75 struct Waiter { struct
101 pointers: linked_list::Pointers<Waiter>, argument
104 _p: PhantomPinned,
299 node: Pin<&mut Waiter>, in poll_acquire()
406 impl Waiter { implementation
469 fn project(self: Pin<&mut Self>) -> (Pin<&mut Waiter>, &Semaphore, u32, &mut bool) { in project()
568 unsafe impl linked_list::Link for Waiter { implementation
578 fn as_raw(handle: &Self::Handle) -> NonNull<Waiter> { in as_raw()
582 unsafe fn from_raw(ptr: NonNull<Waiter>) -> NonNull<Waiter> { in from_raw()
586 unsafe fn pointers(mut target: NonNull<Waiter>) -> NonNull<linked_list::Pointers<Waiter>> { in pointers()
Dnotify.rs129 struct Waiter { struct
131 pointers: linked_list::Pointers<Waiter>, argument
153 waiter: UnsafeCell<Waiter>, argument
515 fn project(self: Pin<&mut Self>) -> (&Notify, &mut State, &UnsafeCell<Waiter>) { in project()
716 unsafe impl linked_list::Link for Waiter { implementation
720 fn as_raw(handle: &NonNull<Waiter>) -> NonNull<Waiter> { in as_raw()
724 unsafe fn from_raw(ptr: NonNull<Waiter>) -> NonNull<Waiter> { in from_raw()
728 unsafe fn pointers(mut target: NonNull<Waiter>) -> NonNull<linked_list::Pointers<Waiter>> { in pointers()
Dbroadcast.rs350 struct Waiter { struct
358 pointers: linked_list::Pointers<Waiter>, argument
374 waiter: UnsafeCell<Waiter>, argument
697 waiter: Option<(&UnsafeCell<Waiter>, &Waker)>, in recv_ref()
966 fn project(self: Pin<&mut Self>) -> (&mut Receiver<T>, &UnsafeCell<Waiter>) { in project()
1023 unsafe impl linked_list::Link for Waiter { implementation
1027 fn as_raw(handle: &NonNull<Waiter>) -> NonNull<Waiter> { in as_raw()
1031 unsafe fn from_raw(ptr: NonNull<Waiter>) -> NonNull<Waiter> { in from_raw()
1035 unsafe fn pointers(mut target: NonNull<Waiter>) -> NonNull<linked_list::Pointers<Waiter>> { in pointers()
/external/tensorflow/tensorflow/core/framework/
Drun_handler.h145 struct Waiter { struct
146 Waiter() { in Waiter() function
152 Waiter* next; argument
153 Waiter* prev; argument
/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
DSimpleThreadPool.h124 struct Waiter { struct
139 MaxSizeVector<Waiter*> waiters_; // Stack of waiting threads. argument
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/
Dmpmcqueue.h128 struct Waiter { struct
130 Waiter* next; argument
131 Waiter* prev; argument
/external/rust/crates/once_cell/src/
Dimp_std.rs49 struct Waiter { struct
52 next: *const Waiter, argument
196 next: (current_state & !STATE_MASK) as *const Waiter, in wait() constant
198 let me = &node as *const Waiter as usize; in wait() constant
227 let mut queue = (state_and_queue & !STATE_MASK) as *const Waiter; in drop() constant
/external/openscreen/third_party/abseil/src/absl/synchronization/internal/
Dwaiter.cc70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
149 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
236 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
357 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
Dkernel_timeout.h42 class Waiter; variable
125 friend class Waiter; variable
/external/angle/third_party/abseil-cpp/absl/synchronization/internal/
Dwaiter.cc70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
149 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
236 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
357 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
Dkernel_timeout.h42 class Waiter; variable
125 friend class Waiter; variable
/external/abseil-cpp/absl/synchronization/internal/
Dkernel_timeout.h41 class Waiter; variable
148 friend class Waiter; variable
Dwaiter.cc126 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
205 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
292 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
413 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
/external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/
Dkernel_timeout.h41 class Waiter; variable
148 friend class Waiter; variable
Dwaiter.cc126 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
205 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
292 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
413 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/
Dkernel_timeout.h41 class Waiter; variable
124 friend class Waiter; variable
Dwaiter.cc134 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
213 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
300 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
421 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
/external/libtextclassifier/abseil-cpp/absl/synchronization/internal/
Dkernel_timeout.h41 class Waiter; variable
124 friend class Waiter; variable
Dwaiter.cc134 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
213 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
300 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
421 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractFuture.java191 private static final class Waiter { class in AbstractFuture
201 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
203 Waiter() { in Waiter() method in AbstractFuture.Waiter
1334 AtomicReferenceFieldUpdater<Waiter, Thread> waiterThreadUpdater, in SafeAtomicHelper()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractFuture.java191 private static final class Waiter { class in AbstractFuture
201 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
203 Waiter() { in Waiter() method in AbstractFuture.Waiter
1336 AtomicReferenceFieldUpdater<Waiter, Thread> waiterThreadUpdater, in SafeAtomicHelper()
/external/rust/crates/futures-util/src/lock/
Dmutex.rs48 enum Waiter { enum
53 impl Waiter { impl

12