Home
last modified time | relevance | path

Searched defs:waiter (Results 1 – 25 of 137) sorted by relevance

123456

/external/sandboxed-api/sandboxed_api/sandbox2/util/
Dpid_waiter_test.cc52 PidWaiter waiter(1, std::move(mock_wait_pid)); in TEST() local
61 PidWaiter waiter(1, std::move(mock_wait_pid)); in TEST() local
76 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
95 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
110 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
125 PidWaiter waiter(kFirstPid, std::move(mock_wait_pid)); in TEST() local
150 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
171 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
191 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
214 PidWaiter waiter(kPrioPid, std::move(mock_wait_pid)); in TEST() local
/external/trusty/musl/src/thread/
Dpthread_cond_timedwait.c25 struct waiter { struct
26 struct waiter *prev, *next; argument
27 volatile int state, barrier;
28 volatile int *notify;
/external/musl/src/thread/
Dpthread_cond_timedwait.c25 struct waiter { struct
26 struct waiter *prev, *next; argument
27 volatile int state, barrier;
28 volatile int *notify;
/external/angle/third_party/abseil-cpp/absl/synchronization/internal/
Dwaiter_test.cc79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
119 TypeParam waiter; in TYPED_TEST_P() local
136 TypeParam waiter; in TYPED_TEST_P() local
146 TypeParam waiter; in TYPED_TEST_P() local
/external/abseil-cpp/absl/synchronization/internal/
Dwaiter_test.cc79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
116 TypeParam waiter; in TYPED_TEST_P() local
133 TypeParam waiter; in TYPED_TEST_P() local
143 TypeParam waiter; in TYPED_TEST_P() local
/external/cronet/stable/third_party/abseil-cpp/absl/synchronization/internal/
Dwaiter_test.cc79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
116 TypeParam waiter; in TYPED_TEST_P() local
133 TypeParam waiter; in TYPED_TEST_P() local
143 TypeParam waiter; in TYPED_TEST_P() local
/external/cronet/tot/third_party/abseil-cpp/absl/synchronization/internal/
Dwaiter_test.cc79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
116 TypeParam waiter; in TYPED_TEST_P() local
133 TypeParam waiter; in TYPED_TEST_P() local
143 TypeParam waiter; in TYPED_TEST_P() local
/external/grpc-grpc/src/ruby/qps/
Dclient.rb103 def wait_to_issue(waiter) argument
109 def unary_ping_ponger(req, stub, config,waiter) argument
117 def streaming_ping_ponger(req, stub, config, waiter) argument
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/
DWaiterResourceTest.java42 RestJsonWithWaitersWaiter waiter = RestJsonWithWaitersWaiter.builder() in closeSyncWaiter_customizedClientProvided_shouldNotCloseClient() local
52 RestJsonWithWaitersAsyncWaiter waiter = RestJsonWithWaitersAsyncWaiter.builder() in closeAsyncWaiter_customizedClientAndExecutorServiceProvided_shouldNotClose() local
/external/llvm-libc/src/__support/threads/linux/
DCndVar.cpp31 CndWaiter waiter; in wait() local
91 CndWaiter *waiter = waitq_front; in broadcast() local
/external/cronet/stable/third_party/llvm-libc/src/src/__support/threads/linux/
DCndVar.cpp31 CndWaiter waiter; in wait() local
91 CndWaiter *waiter = waitq_front; in broadcast() local
/external/cronet/tot/third_party/llvm-libc/src/src/__support/threads/linux/
DCndVar.cpp31 CndWaiter waiter; in wait() local
91 CndWaiter *waiter = waitq_front; in broadcast() local
/external/aws-sdk-java-v2/services/dynamodb/src/test/java/software/amazon/awssdk/services/dynamodb/
DWaitersUserAgentTest.java83 DynamoDbWaiter waiter = dynamoDbClient.waiter(); in syncWaiters_shouldHaveWaitersUserAgent() local
94 DynamoDbAsyncWaiter waiter = dynamoDbAsyncClient.waiter(); in asyncWaiters_shouldHaveWaitersUserAgent() local
/external/igt-gpu-tools/tests/i915/
Dgem_sync.c772 struct waiter { struct
785 static void *waiter(void *arg) in waiter() argument
/external/python/cpython3/Lib/asyncio/
Dproactor_events.py50 def __init__(self, loop, sock, protocol, waiter=None, argument
185 def __init__(self, loop, sock, protocol, waiter=None, argument
464 waiter=None, extra=None): argument
608 def __init__(self, loop, sock, protocol, waiter=None, argument
642 def _make_socket_transport(self, sock, protocol, waiter=None, argument
648 self, rawsock, protocol, sslcontext, waiter=None, argument
663 address=None, waiter=None, extra=None): argument
667 def _make_duplex_pipe_transport(self, sock, protocol, waiter=None, argument
672 def _make_read_pipe_transport(self, sock, protocol, waiter=None, argument
676 def _make_write_pipe_transport(self, sock, protocol, waiter=None, argument
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/waiters/
DWaiterTest.java57 Waiter<String> waiter = Waiter.builder(String.class) in concurrentWaiterOperations_shouldBeThreadSafe() local
76 Waiter<String> waiter = Waiter.builder(String.class) in requestOverrideConfig_shouldTakePrecedence() local
DAsyncWaiterTest.java74 AsyncWaiter<String> waiter = AsyncWaiter.builder(String.class) in concurrentWaiterOperations_shouldBeThreadSafe() local
94 AsyncWaiter<String> waiter = AsyncWaiter.builder(String.class) in requestOverrideConfig_shouldTakePrecedence() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DCancelledAwaitStressTest.kt18 val waiter = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractFuture.java1317 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1320 abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); in putNext()
1395 void putThread(Waiter waiter, Thread newValue) { in putThread()
1400 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1435 Waiter waiter = future.waiters; in gasWaiters() local
1474 void putThread(Waiter waiter, Thread newValue) { in putThread()
1479 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1520 void putThread(Waiter waiter, Thread newValue) { in putThread()
1525 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
/external/cronet/stable/base/synchronization/
Dwaitable_event_posix.cc326 Waiter* waiter) NO_THREAD_SAFETY_ANALYSIS { in EnqueueMany()
408 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue()
416 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue()
/external/cronet/tot/base/synchronization/
Dwaitable_event_posix.cc326 Waiter* waiter) NO_THREAD_SAFETY_ANALYSIS { in EnqueueMany()
408 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue()
416 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue()
/external/openscreen/platform/impl/
Dsocket_handle_waiter_posix_unittest.cc50 TestingSocketHandleWaiter waiter; in TEST() local
71 TestingSocketHandleWaiter waiter; in TEST() local
/external/federated-compute/fcp/base/
Dclock.cc72 const std::shared_ptr<Clock::Waiter>& waiter) { in WakeupWithDeadline()
118 for (const auto& waiter : wakeup_calls) { in DispatchWakeups() local
/external/crosvm/cros_async/src/
Dsync.rs8 mod waiter; module
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/it/java/software/amazon/awssdk/transfer/s3/
DS3TransferManagerUploadPauseResumeIntegrationTest.java160 AsyncWaiter<ListPartsResponse> waiter = AsyncWaiter.builder(ListPartsResponse.class) in verifyMultipartUploadIdNotExist() local
170 … Waiter<ListMultipartUploadsResponse> waiter = Waiter.builder(ListMultipartUploadsResponse.class) in waitUntilMultipartUploadExists() local

123456