Home
last modified time | relevance | path

Searched defs:waiters (Results 1 – 25 of 685) sorted by relevance

12345678910>>...28

/aosp_15_r20/external/cronet/net/socket/
H A Dwebsocket_endpoint_lock_manager_unittest.cc90 FakeWaiter waiters[2]; in TEST_F() local
112 FakeWaiter waiters[2]; in TEST_F() local
125 FakeWaiter waiters[2]; in TEST_F() local
163 FakeWaiter waiters[2]; in TEST_F() local
198 FakeWaiter waiters[2]; in TEST_F() local
219 FakeWaiter waiters[3]; in TEST_F() local
242 FakeWaiter waiters[2]; in TEST_F() local
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/io/
Dscheduled_io.rs107 waiters: Mutex<Waiters>, field
241 let mut waiters = self.waiters.lock(); in wake() localVariable
317 let mut waiters = self.waiters.lock(); in poll_readiness() localVariable
367 let mut waiters = self.waiters.lock(); in clear_wakers() localVariable
460 let mut waiters = scheduled_io.waiters.lock(); in poll() localVariable
504 let waiters = scheduled_io.waiters.lock(); in poll() localVariable
554 let mut waiters = self.scheduled_io.waiters.lock(); in drop() localVariable
/aosp_15_r20/frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/
DAdnRecordCache.java91 ArrayList<Message> waiters = mAdnLikeWaiters.valueAt(i); in clearWaiters() local
264 ArrayList<Message> waiters; in requestLoadAllAdnLike() local
323 notifyWaiters(ArrayList<Message> waiters, AsyncResult ar) { in notifyWaiters()
349 ArrayList<Message> waiters; in handleMessage() local
384 protected void setAdnLikeWriters(int key, ArrayList<Message> waiters) { in setAdnLikeWriters()
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/
Dnotify.rs213 waiters: Mutex<WaitList>, field
619 let mut waiters = self.waiters.lock(); in notify_with_strategy() localVariable
664 let mut waiters = self.waiters.lock(); in notify_waiters() localVariable
962 let mut waiters = notify.waiters.lock(); in poll_notified() localVariable
1063 let mut waiters = notify.waiters.lock(); in poll_notified() localVariable
1165 let mut waiters = notify.waiters.lock(); in drop() localVariable
Dbatch_semaphore.rs36 waiters: Mutex<Waitlist>, field
243 let mut waiters = self.waiters.lock(); in close() localVariable
311 let mut waiters = lock.take().unwrap_or_else(|| self.waiters.lock()); in add_permits_locked() localVariable
416 let mut waiters = loop { in poll_acquire() localVariable
697 let mut waiters = self.semaphore.waiters.lock(); in drop() localVariable
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/model/service/
H A DWaiters.java26 private Map<String, WaiterDefinition> waiters; field in Waiters
33 private Waiters(Map<String, WaiterDefinition> waiters) { in Waiters()
45 public void setWaiters(Map<String, WaiterDefinition> waiters) { in setWaiters()
/aosp_15_r20/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
H A DEventCount.h53 EventCount(MaxSizeVector<Waiter>& waiters) in EventCount()
135 const uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; in Notify() local
211 const uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; variable
/aosp_15_r20/external/rust/android-crates-io/crates/futures-util/src/lock/
Dmutex.rs24 waiters: StdMutex<Slab<Waiter>>, field
164 let mut waiters = self.waiters.lock().unwrap(); in remove_waker() localVariable
189 let mut waiters = self.waiters.lock().unwrap(); in unlock() localVariable
241 let mut waiters = mutex.waiters.lock().unwrap(); in poll() localVariable
350 let mut waiters = mutex.waiters.lock().unwrap(); in poll() localVariable
/aosp_15_r20/frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/uicc/
DAdnRecordCacheTest.java64 protected void setAdnLikeWriters(int key, ArrayList<Message> waiters) { in setAdnLikeWriters()
112 ArrayList<Message> waiters = new ArrayList<>(); in resetTest() local
293 ArrayList<Message> waiters = new ArrayList<>(); in requestLoadAllAdnLike_AlreadyLoadingEf() local
/aosp_15_r20/external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/
H A Drun_handler_test.cc148 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
194 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
483 Eigen::MaxSizeVector<internal::Waiter> waiters(1); in TEST_P() local
554 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
/aosp_15_r20/external/tensorflow/tensorflow/core/framework/
H A Drun_handler_test.cc119 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
152 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
438 Eigen::MaxSizeVector<internal::Waiter> waiters(1); in TEST() local
509 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
H A DBlockingCoroutineDispatcherMixedStealingStressTest.kt62 …val waiters = Thread.getAllStackTraces().keys.count { (it.state == Thread.State.TIMED_WAITING || i… in testBlockingProgressPreventedExternal() constant
/aosp_15_r20/external/eigen/unsupported/test/
H A Dcxx11_eventcount.cpp28 MaxSizeVector<EventCount::Waiter> waiters(1); in test_basic_eventcount() local
85 MaxSizeVector<EventCount::Waiter> waiters(kThreads); in test_stress_eventcount() local
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/model/intermediate/
H A DIntermediateModel.java52 private Map<String, WaiterDefinition> waiters; field in IntermediateModel
94 Map<String, WaiterDefinition> waiters, in IntermediateModel()
/aosp_15_r20/art/test/1932-monitor-events-misc/src/art/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/art/test/jvmti-common/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/art/test/1930-monitor-info/src/art/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/
H A DMutexTest.kt92 val waiters = 10000 in testUnconfinedStackOverflow() constant
/aosp_15_r20/art/test/1933-monitor-current-contended/src/art/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/art/test/1934-jvmti-signal-thread/src/art/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/art/test/1931-monitor-events/src/art/
H A DMonitors.java79 public final Thread[] waiters; field in Monitors.MonitorUsage
86 Thread[] waiters, in MonitorUsage()
/aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/
H A DMonitor.java1037 int waiters = guard.waiterCount++; in beginWaitingFor() local
1048 int waiters = --guard.waiterCount; in endWaitingFor() local
/aosp_15_r20/external/crosvm/cros_async/src/sync/
H A Dcv.rs69 waiters: UnsafeCell<WaiterList>, field
249 let waiters = unsafe { &mut *self.waiters.get() }; in notify_one() localVariable
349 let waiters = unsafe { &mut *self.waiters.get() }; in cancel_waiter() localVariable
/aosp_15_r20/external/aws-sdk-java-v2/services/keyspaces/src/main/resources/codegen-resources/
H A Dwaiters-2.json3 "waiters": { object
/aosp_15_r20/external/aws-sdk-java-v2/services/iottwinmaker/src/main/resources/codegen-resources/
H A Dwaiters-2.json3 "waiters": { object

12345678910>>...28