| /external/swiftshader/third_party/marl/include/marl/ |
| D | conditionvariable.h | 36 class ConditionVariable {
38 MARL_NO_EXPORT inline ConditionVariable(
74 ConditionVariable(const ConditionVariable&) = delete;
75 ConditionVariable(ConditionVariable&&) = delete;
76 ConditionVariable& operator=(const ConditionVariable&) = delete;
77 ConditionVariable& operator=(ConditionVariable&&) = delete;
86 ConditionVariable::ConditionVariable( in ConditionVariable() function
90 void ConditionVariable::notify_one() { in notify_one()
105 void ConditionVariable::notify_all() { in notify_all()
121 void ConditionVariable::wait(marl::lock& lock, Predicate&& pred) { in wait()
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_posix.cc | 19 ConditionVariable::ConditionVariable(Lock* user_lock) in ConditionVariable() function in base::ConditionVariable
46 ConditionVariable::~ConditionVariable() { in ~ConditionVariable()
65 void ConditionVariable::Wait() { in Wait()
78 void ConditionVariable::TimedWait(const TimeDelta& max_time) { in TimedWait()
132 void ConditionVariable::Broadcast() { in Broadcast()
137 void ConditionVariable::Signal() { in Signal()
|
| D | condition_variable.h | 86 class BASE_EXPORT ConditionVariable {
89 explicit ConditionVariable(Lock* user_lock);
91 ~ConditionVariable();
119 DISALLOW_COPY_AND_ASSIGN(ConditionVariable);
|
| D | condition_variable_unittest.cc | 96 ConditionVariable* work_is_available();
97 ConditionVariable* all_threads_have_ids();
98 ConditionVariable* no_more_tasks();
130 ConditionVariable work_is_available_; // To tell threads there is work.
133 ConditionVariable all_threads_have_ids_; // All threads are running.
134 ConditionVariable no_more_tasks_; // Task count is zero.
160 ConditionVariable cv1(&lock); in TEST_F()
164 ConditionVariable cv(&lock); in TEST_F()
180 ConditionVariable cv(&lock); in TEST_F()
223 ConditionVariable cv(&lock); in TEST_F()
[all …]
|
| /external/swiftshader/third_party/marl/src/ |
| D | conditionvariable_test.cpp | 22 TEST_F(WithoutBoundScheduler, ConditionVariable) { in TEST_F() argument
26 marl::ConditionVariable cv; in TEST_F()
65 TEST_P(WithBoundScheduler, ConditionVariable) { in TEST_P() argument
69 marl::ConditionVariable cv; in TEST_P()
116 marl::ConditionVariable cv; in TEST_P()
|
| /external/libchrome/base/task_scheduler/ |
| D | scheduler_lock.h | 61 std::unique_ptr<ConditionVariable> CreateConditionVariable() {
62 return std::unique_ptr<ConditionVariable>(new ConditionVariable(this));
|
| D | scheduler_lock_impl.h | 16 class ConditionVariable; variable
35 std::unique_ptr<ConditionVariable> CreateConditionVariable();
|
| D | scheduler_lock_impl.cc | 150 std::unique_ptr<ConditionVariable>
152 return std::unique_ptr<ConditionVariable>(new ConditionVariable(&lock_)); in CreateConditionVariable()
|
| D | task_tracker.h | 30 class ConditionVariable; variable
307 const std::unique_ptr<ConditionVariable> flush_cv_;
|
| D | scheduler_worker_pool_impl.h | 285 std::unique_ptr<ConditionVariable> idle_workers_stack_cv_for_testing_;
314 std::unique_ptr<ConditionVariable> num_workers_cleaned_up_for_testing_cv_;
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/drm/ |
| D | OfflineLicenseHelper.java | 19 import android.os.ConditionVariable;
39 private final ConditionVariable conditionVariable;
155 conditionVariable = new ConditionVariable(); in OfflineLicenseHelper()
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | rpc_server_pool_spec.rb | 45 wait_cv = ConditionVariable.new
98 wait_forever_cv = ConditionVariable.new
|
| /external/exoplayer/tree/testutils/src/main/java/com/google/android/exoplayer2/testutil/ |
| D | HostActivity.java | 25 import android.os.ConditionVariable;
95 private @MonotonicNonNull ConditionVariable hostedTestStartedCondition;
123 hostedTestStartedCondition = new ConditionVariable(); in runTest()
|
| D | MediaPeriodAsserts.java | 33 import com.google.android.exoplayer2.util.ConditionVariable;
203 ConditionVariable preparedCondition = new ConditionVariable(); in prepareAndGetTrackGroups()
|
| D | ExoHostedTest.java | 20 import android.os.ConditionVariable;
67 private final ConditionVariable testFinished;
109 this.testFinished = new ConditionVariable(); in ExoHostedTest()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/mediacodec/ |
| D | AsynchronousMediaCodecBufferEnqueuer.java | 28 import com.google.android.exoplayer2.util.ConditionVariable;
58 private final ConditionVariable conditionVariable;
72 /* conditionVariable= */ new ConditionVariable()); in AsynchronousMediaCodecBufferEnqueuer()
77 MediaCodec codec, HandlerThread handlerThread, ConditionVariable conditionVariable) { in AsynchronousMediaCodecBufferEnqueuer()
|
| /external/exoplayer/tree/extensions/cronet/src/test/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceTest.java | 32 import android.os.ConditionVariable;
884 final ConditionVariable startCondition = buildUrlRequestStartedCondition(); in connectTimeout()
923 final ConditionVariable startCondition = buildUrlRequestStartedCondition(); in connectInterrupted()
963 final ConditionVariable startCondition = buildUrlRequestStartedCondition(); in connectResponseBeforeTimeout()
996 final ConditionVariable startCondition = buildUrlRequestStartedCondition(); in redirectIncreasesConnectionTimeout()
1222 final ConditionVariable startCondition = buildReadStartedCondition(); in readInterrupted()
1253 final ConditionVariable startCondition = buildReadStartedCondition(); in readByteBufferInterrupted()
1404 private ConditionVariable buildReadStartedCondition() { in buildReadStartedCondition()
1405 final ConditionVariable startedCondition = new ConditionVariable(); in buildReadStartedCondition()
1416 private ConditionVariable buildUrlRequestStartedCondition() { in buildUrlRequestStartedCondition()
[all …]
|
| /external/exoplayer/tree/testutils/src/test/java/com/google/android/exoplayer2/testutil/ |
| D | FakeClockTest.java | 20 import android.os.ConditionVariable;
152 final ConditionVariable handlerFinished = new ConditionVariable(); in waitForHandler()
|
| /external/exoplayer/tree/library/dash/src/test/java/com/google/android/exoplayer2/source/dash/offline/ |
| D | DownloadServiceDashTest.java | 47 import com.google.android.exoplayer2.util.ConditionVariable;
73 private ConditionVariable pauseDownloadCondition;
185 pauseDownloadCondition = new ConditionVariable(); in removeBeforeDownloadComplete()
|
| /external/grpc-grpc/src/ruby/lib/grpc/ |
| D | notifier.rb | 24 @cvar = ConditionVariable.new
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | port_test.cc | 47 TEST(ConditionVariable, WaitForMilliseconds_Timeout) { in TEST() argument
63 TEST(ConditionVariable, WaitForMilliseconds_Signalled) { in TEST() argument
|
| /external/libchrome/base/test/ |
| D | scoped_task_environment.cc | 83 ConditionVariable can_run_tasks_cv_;
86 ConditionVariable task_completed_;
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/util/ |
| D | ConditionVariable.java | 22 public class ConditionVariable { class
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/mediacodec/ |
| D | AsynchronousMediaCodecBufferEnqueuerTest.java | 29 import com.google.android.exoplayer2.util.ConditionVariable;
50 @Mock private ConditionVariable mockConditionVariable;
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_handling_driver.rb | 41 client_started_cv = ConditionVariable.new
|