| /external/openscreen/third_party/abseil/src/absl/synchronization/internal/ |
| D | waiter.cc | 63 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 …]
|
| D | waiter.h | 65 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()
|
| D | per_thread_sem.cc | 44 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()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 63 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 …]
|
| D | waiter.h | 65 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()
|
| D | per_thread_sem.cc | 44 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 ABSL_INTERNAL_C_SYMBOL()
93 !absl::synchronization_internal::Waiter::GetWaiter(identity)->Wait(t); in ABSL_INTERNAL_C_SYMBOL()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 62 if (!is_idle && ticker - wait_start > Waiter::kIdlePeriods) { in MaybeBecomeIdle()
134 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
138 Waiter::~Waiter() = default;
140 bool Waiter::Wait(KernelTimeout t) { in Wait()
173 void Waiter::Post() { in Post()
180 void Waiter::Poke() { in Poke()
213 Waiter::Waiter() { in Waiter() function in absl::synchronization_internal::Waiter
228 Waiter::~Waiter() { in ~Waiter()
240 bool Waiter::Wait(KernelTimeout t) { in Wait()
278 void Waiter::Post() { in Post()
[all …]
|
| D | waiter.h | 69 class Waiter {
72 Waiter();
75 Waiter(const Waiter&) = delete;
76 Waiter& operator=(const Waiter&) = delete;
79 ~Waiter();
95 static Waiter* GetWaiter(base_internal::ThreadIdentity* identity) { in GetWaiter()
97 sizeof(Waiter) <= sizeof(base_internal::ThreadIdentity::WaiterState), in GetWaiter()
99 return reinterpret_cast<Waiter*>(identity->waiter_state.data); in GetWaiter()
|
| D | per_thread_sem.cc | 44 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()
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 63 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 …]
|
| D | waiter.h | 65 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;
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 63 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 …]
|
| D | waiter.h | 65 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;
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 63 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 …]
|
| D | waiter.h | 65 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;
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 170 newUpdater(Waiter.class, Thread.class, "thread"),
171 newUpdater(Waiter.class, Waiter.class, "next"),
172 newUpdater(AbstractFuture.class, Waiter.class, "waiters"),
201 private static final class Waiter { class in AbstractFuture
202 static final Waiter TOMBSTONE = new Waiter(false /* ignored param */);
205 @CheckForNull volatile Waiter next;
211 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
213 Waiter() { in Waiter() method in AbstractFuture.Waiter
220 void setNext(@CheckForNull Waiter next) { in setNext()
247 private void removeWaiter(Waiter node) { in removeWaiter()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 170 newUpdater(Waiter.class, Thread.class, "thread"),
171 newUpdater(Waiter.class, Waiter.class, "next"),
172 newUpdater(AbstractFuture.class, Waiter.class, "waiters"),
201 private static final class Waiter { class in AbstractFuture
202 static final Waiter TOMBSTONE = new Waiter(false /* ignored param */);
205 @CheckForNull volatile Waiter next;
211 Waiter(boolean unused) {} in Waiter() method in AbstractFuture.Waiter
213 Waiter() { in Waiter() method in AbstractFuture.Waiter
220 void setNext(@CheckForNull Waiter next) { in setNext()
247 private void removeWaiter(Waiter node) { in removeWaiter()
[all …]
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | EventCount.h | 51 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 …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 22 type WaitList = LinkedList<Waiter, <Waiter as linked_list::Link>::Target>;
218 struct Waiter { struct
220 pointers: linked_list::Pointers<Waiter>, argument
233 impl<> Waiter { impl
234 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
253 waiter: UnsafeCell<Waiter>,
391 waiter: UnsafeCell::new(Waiter { in notified()
733 fn project(self: Pin<&mut Self>) -> (&Notify, &mut State, &UnsafeCell<Waiter>) { in project() argument
951 unsafe impl linked_list::Link for Waiter { implementation
952 type Handle = NonNull<Waiter>;
[all …]
|
| D | batch_semaphore.rs | 45 queue: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>,
73 node: Waiter,
80 struct Waiter { struct
106 pointers: linked_list::Pointers<Waiter>, argument
116 impl<> Waiter { impl
117 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
354 node: Pin<&mut Waiter>, in poll_acquire() argument
484 impl Waiter { impl
489 Waiter { in new()
574 node: Waiter::new(num_permits), in new()
[all …]
|
| D | broadcast.rs | 326 waiters: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>,
350 struct Waiter { struct
358 pointers: linked_list::Pointers<Waiter>, argument
365 impl<> Waiter { impl
366 unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
382 waiter: UnsafeCell<Waiter>,
866 waiter: Option<(&UnsafeCell<Waiter>, &Waker)>, in recv_ref() argument
1138 waiter: UnsafeCell::new(Waiter { in new()
1149 fn project(self: Pin<&mut Self>) -> (&mut Receiver<T>, &UnsafeCell<Waiter>) { in project() argument
1206 unsafe impl linked_list::Link for Waiter { implementation
[all …]
|
| /external/rust/crates/once_cell/src/ |
| D | imp_std.rs | 24 queue: AtomicPtr<Waiter>,
25 _marker: PhantomData<*mut Waiter>,
138 const INCOMPLETE_PTR: *mut Waiter = INCOMPLETE as *mut Waiter;
139 const COMPLETE_PTR: *mut Waiter = COMPLETE as *mut Waiter;
148 struct Waiter { struct
151 next: *mut Waiter, argument
156 queue: &'a AtomicPtr<Waiter>,
157 new_queue: *mut Waiter,
187 fn initialize_or_wait(queue: &AtomicPtr<Waiter>, mut init: Option<&mut dyn FnMut() -> bool>) { in initialize_or_wait() argument
220 fn wait(queue: &AtomicPtr<Waiter>, mut curr_queue: *mut Waiter) { in wait() argument
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/ |
| D | mpmcqueue.h | 128 struct Waiter { struct
130 Waiter* next; argument
131 Waiter* prev; argument
135 void PushWaiter(Waiter* waiter);
138 void RemoveWaiter(Waiter* waiter);
142 Waiter* TopWaiter();
145 Waiter waiters_; // Head of waiting thread queue
|
| /external/rust/crates/tokio/src/runtime/io/ |
| D | scheduled_io.rs | 35 type WaitList = LinkedList<Waiter, <Waiter as linked_list::Link>::Target>;
53 struct Waiter {
54 pointers: linked_list::Pointers<Waiter>,
69 impl<> Waiter { impl
70 … unsafe fn addr_of_pointers(self: NonNull<Self>) -> NonNull<linked_list::Pointers<Waiter>> {
83 waiter: UnsafeCell<Waiter>,
390 waiter: UnsafeCell::new(Waiter {
401 unsafe impl linked_list::Link for Waiter {
402 type Handle = NonNull<Waiter>;
403 type Target = Waiter;
[all …]
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.h | 52 using Waiter = FutexWaiter; variable
54 using Waiter = SemWaiter;
56 using Waiter = PthreadWaiter;
58 using Waiter = Win32Waiter;
60 using Waiter = StdcppWaiter;
|