Home
last modified time | relevance | path

Searched refs:Waiter (Results 1 – 25 of 724) sorted by relevance

12345678910>>...29

/aosp_15_r20/external/openscreen/third_party/abseil/src/absl/synchronization/internal/
H A Dwaiter.cc63 if (!is_idle && ticker - wait_start > Waiter::kIdlePeriods) { in MaybeBecomeIdle()
70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
74 Waiter::~Waiter() = default;
76 bool Waiter::Wait(KernelTimeout t) { in Wait()
109 void Waiter::Post() { in Post()
116 void Waiter::Poke() { in Poke()
149 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
164 Waiter::~Waiter() { in ~Waiter()
176 bool Waiter::Wait(KernelTimeout t) { in Wait()
214 void Waiter::Post() { in Post()
[all …]
H A Dwaiter.h65 class Waiter {
68 Waiter();
71 Waiter(const Waiter&) = delete;
72 Waiter& operator=(const Waiter&) = delete;
75 ~Waiter();
91 static Waiter* GetWaiter(base_internal::ThreadIdentity* identity) { in GetWaiter()
93 sizeof(Waiter) <= sizeof(base_internal::ThreadIdentity::WaiterState), in GetWaiter()
95 return reinterpret_cast<Waiter*>(identity->waiter_state.data); in GetWaiter()
H A Dper_thread_sem.cc44 new (Waiter::GetWaiter(identity)) Waiter(); in Init()
51 Waiter::GetWaiter(identity)->~Waiter(); in Destroy()
59 if (wait_start && (ticker - wait_start > Waiter::kIdlePeriods) && !is_idle) { in Tick()
61 Waiter::GetWaiter(identity)->Poke(); in Tick()
73 absl::synchronization_internal::Waiter::GetWaiter(identity)->Post(); in AbslInternalPerThreadSemPost()
93 !absl::synchronization_internal::Waiter::GetWaiter(identity)->Wait(t); in AbslInternalPerThreadSemWait()
/aosp_15_r20/external/guava/guava/src/com/google/common/util/concurrent/
H A DAbstractFuture.java167 newUpdater(Waiter.class, Thread.class, "thread"),
168 newUpdater(Waiter.class, Waiter.class, "next"),
169 newUpdater(AbstractFuture.class, Waiter.class, "waiters"),
202 private static final class Waiter { class in AbstractFuture
203 static final Waiter TOMBSTONE = new Waiter(false /* ignored param */);
206 @CheckForNull volatile Waiter next;
212 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
214 Waiter() { in Waiter() method in AbstractFuture.Waiter
221 void setNext(@CheckForNull Waiter next) { in setNext()
248 private void removeWaiter(Waiter node) { in removeWaiter()
[all …]
/aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/
H A DAbstractFuture.java167 newUpdater(Waiter.class, Thread.class, "thread"),
168 newUpdater(Waiter.class, Waiter.class, "next"),
169 newUpdater(AbstractFuture.class, Waiter.class, "waiters"),
202 private static final class Waiter { class in AbstractFuture
203 static final Waiter TOMBSTONE = new Waiter(false /* ignored param */);
206 @CheckForNull volatile Waiter next;
212 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
214 Waiter() { in Waiter() method in AbstractFuture.Waiter
221 void setNext(@CheckForNull Waiter next) { in setNext()
248 private void removeWaiter(Waiter node) { in removeWaiter()
[all …]
/aosp_15_r20/external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/
H A Dwaiter.cc63 if (!is_idle && ticker - wait_start > Waiter::kIdlePeriods) { in MaybeBecomeIdle()
70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
74 bool Waiter::Wait(KernelTimeout t) { in Wait()
107 void Waiter::Post() { in Post()
114 void Waiter::Poke() { in Poke()
147 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
162 bool Waiter::Wait(KernelTimeout t) { in Wait()
200 void Waiter::Post() { in Post()
206 void Waiter::Poke() { in Poke()
211 void Waiter::InternalCondVarPoke() { in InternalCondVarPoke()
[all …]
H A Dwaiter.h65 class Waiter {
68 Waiter();
71 Waiter(const Waiter&) = delete;
72 Waiter& operator=(const Waiter&) = delete;
88 static Waiter* GetWaiter(base_internal::ThreadIdentity* identity) { in GetWaiter()
90 sizeof(Waiter) <= sizeof(base_internal::ThreadIdentity::WaiterState), in GetWaiter()
92 return reinterpret_cast<Waiter*>(identity->waiter_state.data); in GetWaiter()
110 ~Waiter() = delete;
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/
Dwaiter.cc63 if (!is_idle && ticker - wait_start > Waiter::kIdlePeriods) { in MaybeBecomeIdle()
70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
74 bool Waiter::Wait(KernelTimeout t) { in Wait()
107 void Waiter::Post() { in Post()
114 void Waiter::Poke() { in Poke()
147 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
162 bool Waiter::Wait(KernelTimeout t) { in Wait()
200 void Waiter::Post() { in Post()
206 void Waiter::Poke() { in Poke()
211 void Waiter::InternalCondVarPoke() { in InternalCondVarPoke()
[all …]
Dwaiter.h65 class Waiter {
68 Waiter();
71 Waiter(const Waiter&) = delete;
72 Waiter& operator=(const Waiter&) = delete;
88 static Waiter* GetWaiter(base_internal::ThreadIdentity* identity) { in GetWaiter()
90 sizeof(Waiter) <= sizeof(base_internal::ThreadIdentity::WaiterState), in GetWaiter()
92 return reinterpret_cast<Waiter*>(identity->waiter_state.data); in GetWaiter()
110 ~Waiter() = delete;
/aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/synchronization/internal/
H A Dwaiter.cc63 if (!is_idle && ticker - wait_start > Waiter::kIdlePeriods) { in MaybeBecomeIdle()
70 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
74 bool Waiter::Wait(KernelTimeout t) { in Wait()
107 void Waiter::Post() { in Post()
114 void Waiter::Poke() { in Poke()
147 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
162 bool Waiter::Wait(KernelTimeout t) { in Wait()
200 void Waiter::Post() { in Post()
206 void Waiter::Poke() { in Poke()
211 void Waiter::InternalCondVarPoke() { in InternalCondVarPoke()
[all …]
H A Dwaiter.h65 class Waiter {
68 Waiter();
71 Waiter(const Waiter&) = delete;
72 Waiter& operator=(const Waiter&) = delete;
88 static Waiter* GetWaiter(base_internal::ThreadIdentity* identity) { in GetWaiter()
90 sizeof(Waiter) <= sizeof(base_internal::ThreadIdentity::WaiterState), in GetWaiter()
92 return reinterpret_cast<Waiter*>(identity->waiter_state.data); in GetWaiter()
110 ~Waiter() = delete;
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/
Dnotify.rs22 type WaitList = LinkedList<Waiter, <Waiter as linked_list::Link>::Target>;
23 type GuardedWaitList = GuardedLinkedList<Waiter, <Waiter as linked_list::Link>::Target>;
217 struct Waiter { struct
219 pointers: linked_list::Pointers<Waiter>, argument
238 impl Waiter { argument
239 fn new() -> Waiter { in new()
240 Waiter { in new()
250 impl<> Waiter { impl
251 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
337 guard: Pin<&'a Waiter>, in new() argument
[all …]
Dbroadcast.rs331 waiters: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>,
355 struct Waiter { struct
363 pointers: linked_list::Pointers<Waiter>, argument
369 impl Waiter { implementation
381 impl<> Waiter { impl
382 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
398 waiter: UnsafeCell<Waiter>,
835 list: GuardedLinkedList<Waiter, <Waiter as linked_list::Link>::Target>,
853 unguarded_list: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>, in new() argument
854 guard: Pin<&'a Waiter>, in new() argument
[all …]
Dbatch_semaphore.rs44 queue: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>,
72 node: Waiter,
79 struct Waiter { struct
105 pointers: linked_list::Pointers<Waiter>, argument
115 impl<> Waiter { impl
116 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
401 node: Pin<&mut Waiter>, in poll_acquire() argument
533 impl Waiter { impl
538 Waiter { in new()
625 node: Waiter::new(num_permits), in new()
[all …]
/aosp_15_r20/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
H A DEventCount.h51 class Waiter;
53 EventCount(MaxSizeVector<Waiter>& waiters) in EventCount()
79 void CommitWait(Waiter* w) { in CommitWait()
81 w->state = Waiter::kNotSignaled; in CommitWait()
149 Waiter* w = &waiters_[state & kStackMask]; in Notify()
159 Waiter* w = &waiters_[state & kStackMask]; in Notify()
167 class Waiter {
207 MaxSizeVector<Waiter>& waiters_;
220 void Park(Waiter* w) { in Park()
222 while (w->state != Waiter::kSignaled) { in Park()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/io/
Dscheduled_io.rs110 type WaitList = LinkedList<Waiter, <Waiter as linked_list::Link>::Target>;
125 struct Waiter { struct
126 pointers: linked_list::Pointers<Waiter>, argument
141 impl<> Waiter { impl
142 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
155 waiter: UnsafeCell<Waiter>,
396 waiter: UnsafeCell::new(Waiter { in readiness_fut()
407 unsafe impl linked_list::Link for Waiter { implementation
408 type Handle = NonNull<Waiter>;
409 type Target = Waiter;
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sys/sync/condvar/
H A Ditron.rs58 let mut waiter = waiter_queue::Waiter::new(); in wait()
82 let mut waiter = waiter_queue::Waiter::new(); in wait_timeout()
129 first: NonNull<Waiter>,
130 last: NonNull<Waiter>,
136 pub struct Waiter { struct
142 prev: Option<NonNull<Waiter>>, argument
143 next: Option<NonNull<Waiter>>, argument
146 unsafe impl Send for Waiter {} implementation
147 unsafe impl Sync for Waiter {} implementation
149 impl Waiter { impl
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sys/sync/condvar/
H A Ditron.rs57 let mut waiter = waiter_queue::Waiter::new(); in wait()
81 let mut waiter = waiter_queue::Waiter::new(); in wait_timeout()
128 first: NonNull<Waiter>,
129 last: NonNull<Waiter>,
135 pub struct Waiter { struct
141 prev: Option<NonNull<Waiter>>, argument
142 next: Option<NonNull<Waiter>>, argument
145 unsafe impl Send for Waiter {} implementation
146 unsafe impl Sync for Waiter {} implementation
148 impl Waiter { implementation
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sys/sync/condvar/
H A Ditron.rs58 let mut waiter = waiter_queue::Waiter::new(); in wait()
82 let mut waiter = waiter_queue::Waiter::new(); in wait_timeout()
129 first: NonNull<Waiter>,
130 last: NonNull<Waiter>,
136 pub struct Waiter { struct
142 prev: Option<NonNull<Waiter>>, argument
143 next: Option<NonNull<Waiter>>, argument
146 unsafe impl Send for Waiter {} implementation
147 unsafe impl Sync for Waiter {} implementation
149 impl Waiter { impl
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sys/sync/condvar/
H A Ditron.rs57 let mut waiter = waiter_queue::Waiter::new(); in wait()
81 let mut waiter = waiter_queue::Waiter::new(); in wait_timeout()
128 first: NonNull<Waiter>,
129 last: NonNull<Waiter>,
135 pub struct Waiter { struct
141 prev: Option<NonNull<Waiter>>, argument
142 next: Option<NonNull<Waiter>>, argument
145 unsafe impl Send for Waiter {} implementation
146 unsafe impl Sync for Waiter {} implementation
148 impl Waiter { impl
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sys/sync/condvar/
H A Ditron.rs58 let mut waiter = waiter_queue::Waiter::new(); in wait()
82 let mut waiter = waiter_queue::Waiter::new(); in wait_timeout()
129 first: NonNull<Waiter>,
130 last: NonNull<Waiter>,
136 pub struct Waiter { struct
142 prev: Option<NonNull<Waiter>>, argument
143 next: Option<NonNull<Waiter>>, argument
146 unsafe impl Send for Waiter {} implementation
147 unsafe impl Sync for Waiter {} implementation
149 impl Waiter { implementation
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/once_cell/src/
Dimp_std.rs23 queue: AtomicPtr<Waiter>,
128 const INCOMPLETE_PTR: *mut Waiter = INCOMPLETE as *mut Waiter;
129 const COMPLETE_PTR: *mut Waiter = COMPLETE as *mut Waiter;
138 struct Waiter { struct
141 next: *mut Waiter, argument
146 queue: &'a AtomicPtr<Waiter>,
147 new_queue: *mut Waiter,
177 fn initialize_or_wait(queue: &AtomicPtr<Waiter>, mut init: Option<&mut dyn FnMut() -> bool>) { in initialize_or_wait() argument
210 fn wait(queue: &AtomicPtr<Waiter>, mut curr_queue: *mut Waiter) { in wait() argument
213 let node = Waiter { in wait()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/test/test-utils/src/main/java/software/amazon/awssdk/testutils/
H A DWaiter.java34 public final class Waiter<T> { class
35 private static final Logger log = Logger.loggerFor(Waiter.class);
46 private Waiter(Supplier<T> thingToTry) { in Waiter() method in Waiter
55 public static <T> Waiter<T> run(Supplier<T> thingToTry) { in run()
56 return new Waiter<>(thingToTry); in run()
64 public Waiter<T> until(Predicate<T> whenToStop) { in until()
75 public Waiter<T> failOn(Predicate<T> whenToFail) { in failOn()
86 public final Waiter<T> untilException(Class<? extends Throwable>... whenToStopOnException) { in untilException()
95 public final Waiter<T> ignoringException(Class<? extends Throwable>... whatToIgnore) { in ignoringException()
/aosp_15_r20/external/tensorflow/tensorflow/core/framework/
H A Drun_handler.h146 struct Waiter { struct
147 Waiter() { in Waiter() function
153 Waiter* next; argument
154 Waiter* prev; argument
177 void SetWaiter(uint64 version, Waiter* waiter, mutex* mutex);
206 Waiter queue_waiters_ TF_GUARDED_BY(waiters_mu_);
212 Waiter* sub_thread_pool_waiter_ TF_GUARDED_BY(run_handler_waiter_mu_);
227 Eigen::MaxSizeVector<Waiter>* queue_waiters);
299 Eigen::MaxSizeVector<Waiter>* queue_waiters_;
/aosp_15_r20/external/crosvm/cros_async/src/sync/
H A Dwaiter.rs129 pub struct Waiter { struct
132 cancel: fn(usize, &Waiter, bool), argument
138 impl Waiter { implementation
159 cancel: fn(usize, &Waiter, bool), in new() argument
162 ) -> Waiter { in new() argument
163 Waiter { in new()
233 waiter: &'w Waiter,
292 intrusive_adapter!(pub WaiterAdapter = Arc<Waiter>: Waiter { link: AtomicLink });

12345678910>>...29