| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | blocking_counter.h | 61 class BlockingCounter {
63 explicit BlockingCounter(int initial_count) in BlockingCounter() function
66 BlockingCounter(const BlockingCounter&) = delete;
67 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 27 bool BlockingCounter::DecrementCount() { in DecrementCount()
39 void BlockingCounter::Wait() { in Wait()
|
| D | blocking_counter_test.cc | 28 void PauseAndDecreaseCounter(BlockingCounter* counter, int* done) { in PauseAndDecreaseCounter()
40 BlockingCounter counter(num_workers); in TEST()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | blocking_counter.h | 61 class BlockingCounter {
63 explicit BlockingCounter(int initial_count) in BlockingCounter() function
66 BlockingCounter(const BlockingCounter&) = delete;
67 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 27 bool BlockingCounter::DecrementCount() { in DecrementCount()
39 void BlockingCounter::Wait() { in Wait()
|
| D | blocking_counter_test.cc | 28 void PauseAndDecreaseCounter(BlockingCounter* counter, int* done) { in PauseAndDecreaseCounter()
40 BlockingCounter counter(num_workers); in TEST()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | blocking_counter.h | 61 class BlockingCounter {
63 explicit BlockingCounter(int initial_count) in BlockingCounter() function
66 BlockingCounter(const BlockingCounter&) = delete;
67 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 27 bool BlockingCounter::DecrementCount() { in DecrementCount()
39 void BlockingCounter::Wait() { in Wait()
|
| D | blocking_counter_test.cc | 28 void PauseAndDecreaseCounter(BlockingCounter* counter, int* done) { in PauseAndDecreaseCounter()
40 BlockingCounter counter(num_workers); in TEST()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | blocking_counter.h | 61 class BlockingCounter {
63 explicit BlockingCounter(int initial_count) in BlockingCounter() function
66 BlockingCounter(const BlockingCounter&) = delete;
67 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 27 bool BlockingCounter::DecrementCount() { in DecrementCount()
39 void BlockingCounter::Wait() { in Wait()
|
| D | blocking_counter_test.cc | 28 void PauseAndDecreaseCounter(BlockingCounter* counter, int* done) { in PauseAndDecreaseCounter()
40 BlockingCounter counter(num_workers); in TEST()
|
| /external/abseil-cpp/absl/synchronization/ |
| D | blocking_counter.h | 61 class BlockingCounter {
63 explicit BlockingCounter(int initial_count) in BlockingCounter() function
66 BlockingCounter(const BlockingCounter&) = delete;
67 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 27 bool BlockingCounter::DecrementCount() { in DecrementCount()
39 void BlockingCounter::Wait() { in Wait()
|
| D | blocking_counter_test.cc | 28 void PauseAndDecreaseCounter(BlockingCounter* counter, int* done) { in PauseAndDecreaseCounter()
40 BlockingCounter counter(num_workers); in TEST()
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | collective_permute_thunk.cc | 42 using tensorflow::BlockingCounter;
47 void WaitAndLogIfStuck(tensorflow::BlockingCounter* counter, in WaitAndLogIfStuck()
119 StatusOr<std::shared_ptr<BlockingCounter>> SubmitParticipant(
124 BlockingCounter all_arrived_{key_.num_participants};
127 std::shared_ptr<BlockingCounter> returned_blocking_counter_{
128 std::make_shared<BlockingCounter>(key_.num_participants)};
159 StatusOr<std::shared_ptr<BlockingCounter>> Rendezvous::SubmitParticipant( in SubmitParticipant()
172 std::make_shared<BlockingCounter>(key_.num_participants); in SubmitParticipant()
260 TF_ASSIGN_OR_RETURN(std::shared_ptr<BlockingCounter> final_sync, in ExecuteOnStream()
|
| D | nccl_utils.h | 115 absl::BlockingCounter* counter);
125 absl::BlockingCounter* counter_;
|
| /external/gemmlowp/test/ |
| D | test_blocking_counter.cc | 28 Thread(BlockingCounter* blocking_counter, int number_of_times_to_decrement) in Thread()
82 BlockingCounter* const blocking_counter_;
95 void test_blocking_counter(BlockingCounter* blocking_counter, int num_threads, in test_blocking_counter()
116 BlockingCounter* blocking_counter = new BlockingCounter; in test_blocking_counter()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | blocking_counter_test.cc | 25 BlockingCounter bc(0); in TEST()
30 BlockingCounter bc(2); in TEST()
41 BlockingCounter bc(N); in TEST()
59 BlockingCounter bc(num_shards); in BM_BlockingCounter()
|
| /external/ruy/ruy/ |
| D | blocking_counter.cc | 23 void BlockingCounter::Reset(int initial_count) { in Reset()
30 bool BlockingCounter::DecrementCount() { in DecrementCount()
42 void BlockingCounter::Wait(const Duration spin_duration) { in Wait()
|
| D | blocking_counter.h | 35 class BlockingCounter {
37 BlockingCounter() : count_(0) {} in BlockingCounter() function
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | blocking_counter.h | 26 class BlockingCounter {
28 BlockingCounter(int initial_count) in BlockingCounter() function
34 ~BlockingCounter() {} in ~BlockingCounter()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | collective_ops_utils.h | 123 void WaitAndLogIfStuck(tensorflow::BlockingCounter* counter, in WaitAndLogIfStuck()
230 std::shared_ptr<tensorflow::BlockingCounter> blocking_counter = p.second; in SubmitParticipant()
270 StatusOr<std::pair<O, std::shared_ptr<tensorflow::BlockingCounter>>>
303 tensorflow::BlockingCounter all_participants_present_{
307 std::shared_ptr<tensorflow::BlockingCounter> returned_blocking_counter_{
308 std::make_shared<tensorflow::BlockingCounter>(
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | collective_param_resolver_local_test.cc | 321 BlockingCounter start(NUM_DEVS - 1); in TEST_F()
322 BlockingCounter done(NUM_DEVS - 1); in TEST_F()
351 BlockingCounter done(NUM_DEVS); in TEST_F()
370 BlockingCounter start(NUM_DEVS - 1); in TEST_F()
371 BlockingCounter done(NUM_DEVS - 1); in TEST_F()
401 BlockingCounter done(NUM_DEVS); in TEST_F()
454 BlockingCounter done(NUM_DEVS); in TEST_F()
|
| /external/tensorflow/tensorflow/cc/training/ |
| D | coordinator_test.cc | 76 void StartSettingStatus(const Status& status, BlockingCounter* counter, in StartSettingStatus()
107 void SetStatusThread(const Status& status, BlockingCounter* counter, in SetStatusThread()
179 BlockingCounter counter(3); in TEST()
|