| /external/webrtc/rtc_base/ |
| D | event_unittest.cc | 20 ASSERT_TRUE(event.Wait(0)); in TEST()
25 ASSERT_FALSE(event.Wait(0)); in TEST()
28 ASSERT_TRUE(event.Wait(0)); in TEST()
29 ASSERT_TRUE(event.Wait(0)); in TEST()
32 ASSERT_FALSE(event.Wait(0)); in TEST()
37 ASSERT_FALSE(event.Wait(0)); in TEST()
40 ASSERT_TRUE(event.Wait(0)); in TEST()
41 ASSERT_FALSE(event.Wait(0)); in TEST()
58 while (!me->stop_event_.Wait(0)) { in ThreadFn()
60 me->reader_->Wait(Event::kForever); in ThreadFn()
[all …]
|
| D | operations_chain_unittest.cc | 86 unblock_operation_event->Wait(Event::kForever); in StartAsynchronousOperation()
209 operation_tracker_proxy.Initialize()->Wait(Event::kForever); in TEST()
211 operation_tracker_proxy.PostSynchronousOperation()->Wait(Event::kForever); in TEST()
216 operation_tracker_proxy.Initialize()->Wait(Event::kForever); in TEST()
223 EXPECT_FALSE(async_operation_completed_event->Wait(0)); in TEST()
226 async_operation_completed_event->Wait(Event::kForever); in TEST()
241 EXPECT_TRUE(event0.Wait(0)); in TEST()
247 EXPECT_TRUE(event1.Wait(0)); in TEST()
252 operation_tracker_proxy.Initialize()->Wait(Event::kForever); in TEST()
264 sync_operation_completed_event->Wait(Event::kForever); in TEST()
[all …]
|
| /external/webrtc/modules/video_coding/utility/ |
| D | quality_scaler_unittest.cc | 136 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
144 EXPECT_FALSE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
152 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
167 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
181 EXPECT_FALSE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
197 EXPECT_EQ(kDownScaleExpected, handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
205 EXPECT_FALSE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
212 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
219 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
223 EXPECT_TRUE(handler_->event.Wait(kDefaultTimeoutMs)); in TEST_P()
[all …]
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 48 void Wait() { in Wait() function in absl::synchronization_internal::SimpleSemaphore
86 Wait(t->timeout); in TimingThread()
105 t.identity2_written.Wait(); in TestTiming()
113 Wait(t.timeout); in TestTiming()
130 static bool Wait(KernelTimeout t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
131 return PerThreadSem::Wait(t); in Wait()
135 static bool Wait(absl::Time t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
136 return Wait(KernelTimeout(t)); in Wait()
157 EXPECT_FALSE(Wait(start + delay)); in TEST_F()
167 EXPECT_FALSE(Wait(negative_timeout)); in TEST_F()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 49 void Wait() { in Wait() function in absl::synchronization_internal::SimpleSemaphore
87 Wait(t->timeout); in TimingThread()
106 t.identity2_written.Wait(); in TestTiming()
114 Wait(t.timeout); in TestTiming()
131 static bool Wait(KernelTimeout t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
132 return PerThreadSem::Wait(t); in Wait()
136 static bool Wait(absl::Time t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
137 return Wait(KernelTimeout(t)); in Wait()
158 EXPECT_FALSE(Wait(start + delay)); in TEST_F()
168 EXPECT_FALSE(Wait(negative_timeout)); in TEST_F()
[all …]
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 48 void Wait() { in Wait() function in absl::synchronization_internal::SimpleSemaphore
86 Wait(t->timeout); in TimingThread()
105 t.identity2_written.Wait(); in TestTiming()
113 Wait(t.timeout); in TestTiming()
130 static bool Wait(KernelTimeout t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
131 return PerThreadSem::Wait(t); in Wait()
135 static bool Wait(absl::Time t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
136 return Wait(KernelTimeout(t)); in Wait()
157 EXPECT_FALSE(Wait(start + delay)); in TEST_F()
167 EXPECT_FALSE(Wait(negative_timeout)); in TEST_F()
[all …]
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 49 void Wait() { in Wait() function in absl::synchronization_internal::SimpleSemaphore
87 Wait(t->timeout); in TimingThread()
106 t.identity2_written.Wait(); in TestTiming()
114 Wait(t.timeout); in TestTiming()
131 static bool Wait(KernelTimeout t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
132 return PerThreadSem::Wait(t); in Wait()
136 static bool Wait(absl::Time t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
137 return Wait(KernelTimeout(t)); in Wait()
158 EXPECT_FALSE(Wait(start + delay)); in TEST_F()
168 EXPECT_FALSE(Wait(negative_timeout)); in TEST_F()
[all …]
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 49 void Wait() { in Wait() function in absl::synchronization_internal::SimpleSemaphore
87 Wait(t->timeout); in TimingThread()
106 t.identity2_written.Wait(); in TestTiming()
114 Wait(t.timeout); in TestTiming()
131 static bool Wait(KernelTimeout t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
132 return PerThreadSem::Wait(t); in Wait()
136 static bool Wait(absl::Time t) { in Wait() function in absl::synchronization_internal::PerThreadSemTest
137 return Wait(KernelTimeout(t)); in Wait()
158 EXPECT_FALSE(Wait(start + delay)); in TEST_F()
168 EXPECT_FALSE(Wait(negative_timeout)); in TEST_F()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Target/AMDGPU/ |
| D | SIInsertWaitcnts.cpp | 169 void addWait(AMDGPU::Waitcnt &Wait, InstCounterType T, unsigned Count) { in addWait() argument
172 Wait.VmCnt = std::min(Wait.VmCnt, Count); in addWait()
175 Wait.ExpCnt = std::min(Wait.ExpCnt, Count); in addWait()
178 Wait.LgkmCnt = std::min(Wait.LgkmCnt, Count); in addWait()
181 Wait.VsCnt = std::min(Wait.VsCnt, Count); in addWait()
274 bool simplifyWaitcnt(AMDGPU::Waitcnt &Wait) const;
277 AMDGPU::Waitcnt &Wait) const;
278 void applyWaitcnt(const AMDGPU::Waitcnt &Wait);
721 bool WaitcntBrackets::simplifyWaitcnt(AMDGPU::Waitcnt &Wait) const { in simplifyWaitcnt()
722 return simplifyWaitcnt(VM_CNT, Wait.VmCnt) | in simplifyWaitcnt()
[all …]
|
| /external/llvm-project/llvm/lib/Target/AMDGPU/ |
| D | SIInsertWaitcnts.cpp | 189 void addWait(AMDGPU::Waitcnt &Wait, InstCounterType T, unsigned Count) { in addWait() argument
192 Wait.VmCnt = std::min(Wait.VmCnt, Count); in addWait()
195 Wait.ExpCnt = std::min(Wait.ExpCnt, Count); in addWait()
198 Wait.LgkmCnt = std::min(Wait.LgkmCnt, Count); in addWait()
201 Wait.VsCnt = std::min(Wait.VsCnt, Count); in addWait()
273 bool simplifyWaitcnt(AMDGPU::Waitcnt &Wait) const;
276 AMDGPU::Waitcnt &Wait) const;
277 void applyWaitcnt(const AMDGPU::Waitcnt &Wait);
733 bool WaitcntBrackets::simplifyWaitcnt(AMDGPU::Waitcnt &Wait) const { in simplifyWaitcnt()
734 return simplifyWaitcnt(VM_CNT, Wait.VmCnt) | in simplifyWaitcnt()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.MathClient/ |
| D | MathClient.cs | 31 MathExamples.DivAsyncExample(client).Wait(); in Main()
33 MathExamples.FibExample(client).Wait(); in Main()
35 MathExamples.SumExample(client).Wait(); in Main()
37 MathExamples.DivManyExample(client).Wait(); in Main()
39 MathExamples.DependendRequestsExample(client).Wait(); in Main()
41 channel.ShutdownAsync().Wait(); in Main()
|
| /external/webrtc/video/adaptation/ |
| D | quality_scaler_resource_unittest.cc | 98 event.Wait(kDefaultTimeout); in QualityScalerResourceTest()
107 event.Wait(kDefaultTimeout); in ~QualityScalerResourceTest()
124 callback->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
133 callback->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
148 callback1->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
149 callback2->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
150 callback3->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
161 EXPECT_TRUE(callback1->qp_usage_handled_event()->Wait(0)); in TEST_F()
166 callback1->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
167 callback2->qp_usage_handled_event()->Wait(kDefaultTimeout); in TEST_F()
|
| /external/webrtc/api/task_queue/ |
| D | task_queue_test.cc | 50 EXPECT_TRUE(event.Wait(1000)); in TEST_P()
72 EXPECT_TRUE(ran.Wait(1000)); in TEST_P()
81 EXPECT_TRUE(event.Wait(1000)); in TEST_P()
92 EXPECT_TRUE(event.Wait(1000)); in TEST_P()
107 EXPECT_TRUE(event.Wait(1000)); in TEST_P()
131 EXPECT_TRUE(e.Wait(1000)); in TEST_P()
144 EXPECT_TRUE(deleted.Wait(1000)); in TEST_P()
145 EXPECT_FALSE(run.Wait(0)); // and should not run. in TEST_P()
189 EXPECT_TRUE(event.Wait(1000)); in TEST_P()
203 bool Wait(int give_up_after_ms) { return event_.Wait(give_up_after_ms); } in TEST_P() function in webrtc::__anonc5a519800111::TEST_P::BlockingCounter
[all …]
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | wait_set_unittest.cc | 70 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results, hss); in TEST_F()
87 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results, hss); in TEST_F()
100 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results, hss); in TEST_F()
114 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results, hss); in TEST_F()
125 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results, hss); in TEST_F()
135 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results); in TEST_F()
152 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results); in TEST_F()
177 wait_set.Wait(nullptr, &num_ready_handles, ready_handles, ready_results); in TEST_F()
205 wait_set.Wait(nullptr, &num_ready_handles, &ready_handle, &ready_result); in TEST_F()
211 wait_set.Wait(nullptr, &num_ready_handles, &ready_handle, &ready_result); in TEST_F()
[all …]
|
| /external/libchrome/base/threading/ |
| D | thread_local_unittest.cc | 91 done.Wait(); in TEST()
97 done.Wait(); in TEST()
106 done.Wait(); in TEST()
111 done.Wait(); in TEST()
118 done.Wait(); in TEST()
126 done.Wait(); in TEST()
131 done.Wait(); in TEST()
138 done.Wait(); in TEST()
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | sync_handle_registry_unittest.cc | 40 registry()->Wait(stop_flags, 2); in TEST_F()
49 registry()->Wait(stop_flags, 2); in TEST_F()
78 registry()->Wait(stop_flags, 3); in TEST_F()
92 registry()->Wait(stop_flags, 3); in TEST_F()
123 registry->Wait(&stop_flag, 1); in TEST_F()
132 registry()->Wait(&stop_flag, 1); in TEST_F()
154 registry->Wait(&stop_flag, 1); in TEST_F()
165 registry()->Wait(&stop_flag, 1); in TEST_F()
190 registry->Wait(&stop_flag, 1); in TEST_F()
199 registry()->Wait(&stop_flag, 1); in TEST_F()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | GrpcEnvironmentTest.cs | 38 GrpcEnvironment.ReleaseAsync().Wait(); in InitializeAndShutdownGrpcEnvironment()
47 GrpcEnvironment.ReleaseAsync().Wait(); in SubsequentInvocations()
48 GrpcEnvironment.ReleaseAsync().Wait(); in SubsequentInvocations()
57 GrpcEnvironment.ReleaseAsync().Wait(); in InitializeAfterShutdown()
60 GrpcEnvironment.ReleaseAsync().Wait(); in InitializeAfterShutdown()
88 GrpcEnvironment.ReleaseAsync().Wait(); in ShuttingDownEventIsFired()
|
| D | ServerTest.cs | 39 server.ShutdownAsync().Wait(); in StartAndShutdownServer()
50 server.KillAsync().Wait(); in StartAndKillServer()
66 server.ShutdownAsync().Wait(); in PickUnusedPort()
81 server.ShutdownAsync().Wait(); in StartThrowsWithUnboundPorts()
95 server.ShutdownAsync().Wait(); in CannotModifyAfterStarted()
102 server.ShutdownAsync().Wait(); in UnstartedServerCanBeShutdown()
|
| /external/webrtc/rtc_base/synchronization/ |
| D | yield_policy_unittest.cc | 33 event.Wait(Event::kForever); in TEST()
39 event.Wait(Event::kForever); in TEST()
56 events[0].Wait(Event::kForever); in TEST()
59 events[1].Wait(Event::kForever); in TEST()
65 events[2].Wait(Event::kForever); in TEST()
|
| /external/webrtc/call/ |
| D | bitrate_estimator_tests.cc | 47 bool Wait() { return callback_.Wait(); } in Wait() function in webrtc::__anon1d17443a0111::LogObserver
79 bool Wait() { return done_.Wait(test::CallTest::kDefaultTimeoutMs); } in Wait() function in webrtc::__anon1d17443a0111::LogObserver::Callback
261 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
274 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
285 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
294 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
307 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
316 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
328 EXPECT_TRUE(receiver_log_.Wait()); in TEST_F()
|
| /external/webrtc/video/ |
| D | call_stats_unittest.cc | 79 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
118 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
148 ASSERT_TRUE(ev1.Wait(100)); in TEST_F()
149 ASSERT_TRUE(ev2.Wait(100)); in TEST_F()
161 ASSERT_TRUE(ev1.Wait(100)); in TEST_F()
178 event.Wait(rtc::Event::kForever); in TEST_F()
243 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
290 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
307 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
311 EXPECT_TRUE(event.Wait(1000)); in TEST_F()
|
| /external/webrtc/modules/utility/source/ |
| D | process_thread_impl_unittest.cc | 100 EXPECT_TRUE(event.Wait(kEventWaitTimeout)); in TEST()
124 EXPECT_TRUE(event.Wait(kEventWaitTimeout)); in TEST()
150 EXPECT_TRUE(event.Wait(kEventWaitTimeout)); in TEST()
159 EXPECT_FALSE(event.Wait(20)); in TEST()
188 EXPECT_TRUE(event.Wait(milliseconds + 50)); in ProcessCallAfterAFewMs()
245 EXPECT_TRUE(event.Wait(1000)); in TEST()
289 EXPECT_TRUE(started.Wait(kEventWaitTimeout)); in TEST()
291 EXPECT_TRUE(called.Wait(kEventWaitTimeout)); in TEST()
310 EXPECT_TRUE(task_ran.Wait(kEventWaitTimeout)); in TEST()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/gprpp/ |
| D | sync.h | 108 int Wait(Mutex* mu) { return Wait(mu, gpr_inf_future(GPR_CLOCK_REALTIME)); } in Wait() function
109 int Wait(Mutex* mu, const gpr_timespec& deadline) { in Wait() function
116 Wait(mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in WaitUntil()
124 if (Wait(mu, deadline)) return true; in WaitUntil()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | blocking_counter_test.cc | 26 bc.Wait(); in TEST()
33 bc.Wait(); in TEST()
46 bc.Wait(); in TEST()
67 bc.Wait(); in BM_BlockingCounter()
|
| /external/libchrome/base/task_scheduler/ |
| D | scheduler_worker_pool_impl_unittest.cc | 74 event->Wait(); in WaitWithoutBlockingObserver()
296 task_running.Wait(); in TEST_P()
354 task_running.Wait(); in TEST_P()
423 task_1_running.Wait(); in TEST_F()
424 task_2_running.Wait(); in TEST_F()
531 count_waiter->Wait(); in TEST_F()
578 workers_flooded.Wait(); in FloodPool()
733 cleanup_thread_running.Wait(); in TEST_F()
761 top_idle_thread_running.Wait(); in TEST_F()
828 thread_running.Wait(); in TEST_F()
[all …]
|