| /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/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/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | blocking_counter.h | 63 class BlockingCounter {
65 explicit BlockingCounter(int initial_count);
67 BlockingCounter(const BlockingCounter&) = delete;
68 BlockingCounter& operator=(const BlockingCounter&) = delete;
|
| D | blocking_counter.cc | 31 BlockingCounter::BlockingCounter(int initial_count) in BlockingCounter() function in absl::BlockingCounter
38 bool BlockingCounter::DecrementCount() { in DecrementCount()
50 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()
67 BlockingCounter counter(0); in TEST()
73 EXPECT_DEATH(BlockingCounter counter(-1), in TEST()
|
| D | blocking_counter_benchmark.cc | 26 absl::BlockingCounter counter{iterations}; in BM_BlockingCounter_SingleThread()
42 static absl::BlockingCounter* counter = in BM_BlockingCounter_DecrementCount()
43 new absl::BlockingCounter{std::numeric_limits<int>::max()}; in BM_BlockingCounter_DecrementCount()
64 absl::BlockingCounter counter{num_threads}; in BM_BlockingCounter_Wait()
|
| /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()
|
| /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/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()
|
| /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>(
|