Home
last modified time | relevance | path

Searched refs:wake_list (Results 1 – 17 of 17) sorted by relevance

/external/rust/crates/tokio/src/util/
Dmod.rs29 mod wake_list; module
38 pub(crate) use wake_list::WakeList;
/external/libchromeos-rs/src/sync/
Dcv.rs223 let (mut wake_list, all_readers) = get_wake_list(waiters); in notify_one()
242 if !wake_list.is_empty() { in notify_one()
245 unsafe { (*muptr).transfer_waiters(&mut wake_list, all_readers) }; in notify_one()
252 for w in wake_list { in notify_one()
284 let mut wake_list = unsafe { (*self.waiters.get()).take() }; in notify_all() localVariable
294 if !wake_list.is_empty() { in notify_all()
297 unsafe { (*muptr).transfer_waiters(&mut wake_list, false) }; in notify_all()
301 for w in &wake_list { in notify_all()
309 for w in wake_list { in notify_all()
362 let (mut wake_list, all_readers) = if wake_next || waiting_for == WaitingFor::None { in cancel_waiter()
[all …]
Dmu.rs459 let (wake_list, set_on_release) = get_wake_list(waiters); in unlock_slow()
466 if wake_list.is_empty() { in unlock_slow()
491 for w in wake_list { in unlock_slow()
659 let (wake_list, set_on_release) = in cancel_waiter()
672 if wake_list.is_empty() { in cancel_waiter()
700 for w in wake_list { in cancel_waiter()
/external/crosvm/cros_async/src/sync/
Dcv.rs247 let wake_list = get_wake_list(waiters); in notify_one() localVariable
266 for w in wake_list { in notify_one()
303 let wake_list = unsafe { (*self.waiters.get()).take() }; in notify_all() localVariable
310 for w in &wake_list { in notify_all()
318 for w in wake_list { in notify_all()
355 let wake_list = if wake_next || waiting_for == WaitingFor::None { in cancel_waiter() localVariable
376 for w in wake_list { in cancel_waiter()
Dmu.rs464 let (wake_list, set_on_release) = get_wake_list(waiters); in unlock_slow()
471 if wake_list.is_empty() { in unlock_slow()
496 for w in wake_list { in unlock_slow()
567 let (wake_list, set_on_release) = if wake_next || waiting_for == WaitingFor::None { in cancel_waiter()
579 if wake_list.is_empty() { in cancel_waiter()
607 for w in wake_list { in cancel_waiter()
/external/webrtc/third_party/abseil-cpp/absl/synchronization/
Dmutex.cc2098 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2332 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2344 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2362 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2369 if (!wake_list->cond_waiter) { in UnlockSlow()
2371 (now - wake_list->waitp->contention_start_cycles); in UnlockSlow()
2374 wake_list->waitp->contention_start_cycles = now; in UnlockSlow()
2375 wake_list->waitp->should_submit_contention_data = true; in UnlockSlow()
2377 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2378 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/cronet/third_party/abseil-cpp/absl/synchronization/
Dmutex.cc2116 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2350 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2362 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2380 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2387 if (!wake_list->cond_waiter) { in UnlockSlow()
2389 (now - wake_list->waitp->contention_start_cycles); in UnlockSlow()
2392 wake_list->waitp->contention_start_cycles = now; in UnlockSlow()
2393 wake_list->waitp->should_submit_contention_data = true; in UnlockSlow()
2395 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2396 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/angle/third_party/abseil-cpp/absl/synchronization/
Dmutex.cc2107 PerThreadSynch* wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2339 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2351 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2369 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2376 if (!wake_list->cond_waiter) { in UnlockSlow()
2378 (now - wake_list->waitp->contention_start_cycles); in UnlockSlow()
2381 wake_list->waitp->contention_start_cycles = now; in UnlockSlow()
2382 wake_list->waitp->should_submit_contention_data = true; in UnlockSlow()
2384 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2385 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/abseil-cpp/absl/synchronization/
Dmutex.cc2069 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2303 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2315 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2333 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2339 if (!wake_list->cond_waiter) { in UnlockSlow()
2340 wait_cycles += (now - wake_list->waitp->contention_start_cycles); in UnlockSlow()
2341 wake_list->waitp->contention_start_cycles = now; in UnlockSlow()
2343 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2344 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/
Dmutex.cc2078 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2312 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2324 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2342 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2348 if (!wake_list->cond_waiter) { in UnlockSlow()
2349 wait_cycles += (now - wake_list->waitp->contention_start_cycles); in UnlockSlow()
2350 wake_list->waitp->contention_start_cycles = now; in UnlockSlow()
2352 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2353 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/libtextclassifier/abseil-cpp/absl/synchronization/
Dmutex.cc2042 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2276 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2288 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2306 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2307 int64_t enqueue_timestamp = wake_list->waitp->contention_start_cycles; in UnlockSlow()
2308 bool cond_waiter = wake_list->cond_waiter; in UnlockSlow()
2310 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2311 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/openscreen/third_party/abseil/src/absl/synchronization/
Dmutex.cc2042 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2276 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2288 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2306 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2307 int64_t enqueue_timestamp = wake_list->waitp->contention_start_cycles; in UnlockSlow()
2308 bool cond_waiter = wake_list->cond_waiter; in UnlockSlow()
2310 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2311 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/
Dmutex.cc2053 PerThreadSynch *wake_list = kPerThreadSynchNull; // list of threads to wake in UnlockSlow() local
2287 h = DequeueAllWakeable(h, pw, &wake_list); in UnlockSlow()
2299 ABSL_RAW_CHECK(wake_list != kPerThreadSynchNull, in UnlockSlow()
2317 if (wake_list != kPerThreadSynchNull) { in UnlockSlow()
2318 int64_t enqueue_timestamp = wake_list->waitp->contention_start_cycles; in UnlockSlow()
2319 bool cond_waiter = wake_list->cond_waiter; in UnlockSlow()
2321 wake_list = Wakeup(wake_list); // wake waiters in UnlockSlow()
2322 } while (wake_list != kPerThreadSynchNull); in UnlockSlow()
/external/bcc/libbpf-tools/x86/
Dvmlinux_505.h27616 struct llist_head wake_list; member
Dvmlinux.h27616 struct llist_head wake_list; member
/external/libabigail/tests/data/test-diff-filter/
Dtest-PR27569-v1.abi69794 …<var-decl name="wake_list" type-id="77df194e" visibility="default" filepath="kernel/sched/sched.h"…
Dtest-PR27569-v0.abi69780 …<var-decl name="wake_list" type-id="77df194e" visibility="default" filepath="kernel/sched/sched.h"…