HomeSort by relevance Sort by last modified time
    Searched refs:BlockingCounter (Results 1 - 25 of 25) sorted by null

  /external/gemmlowp/test/
test_blocking_counter.cc 26 Thread(BlockingCounter* blocking_counter, int number_of_times_to_decrement)
59 BlockingCounter* const blocking_counter_;
66 void test_blocking_counter(BlockingCounter* blocking_counter, int num_threads,
87 BlockingCounter* blocking_counter = new BlockingCounter;
  /external/tensorflow/tensorflow/core/lib/core/
blocking_counter.h 26 class BlockingCounter {
28 BlockingCounter(int initial_count)
34 ~BlockingCounter() {}
blocking_counter_test.cc 25 BlockingCounter bc(0);
30 BlockingCounter bc(2);
41 BlockingCounter bc(N);
60 BlockingCounter bc(num_shards);
threadpool.cc 153 BlockingCounter counter(num_shards_used);
  /external/tensorflow/tensorflow/contrib/boosted_trees/lib/utils/
parallel_for.cc 35 BlockingCounter counter(num_shards_used - 1);
  /external/tensorflow/tensorflow/compiler/xla/service/cpu/
runtime_fork_join.cc 85 tensorflow::BlockingCounter bc(num_partitions - 1);
  /external/tensorflow/tensorflow/core/util/
work_sharder.cc 82 BlockingCounter counter(num_shards_used - 1);
example_proto_fast_parsing.cc 436 BlockingCounter counter(n - 1);
    [all...]
  /external/tensorflow/tensorflow/cc/training/
coordinator_test.cc 76 void StartSettingStatus(const Status& status, BlockingCounter* counter,
107 void SetStatusThread(const Status& status, BlockingCounter* counter,
179 BlockingCounter counter(3);
queue_runner.h 124 std::unique_ptr<BlockingCounter> counter_;
queue_runner.cc 97 counter_.reset(new BlockingCounter(runs_));
  /external/gemmlowp/internal/
multi_thread_gemm.h 147 // A BlockingCounter lets one thread to wait for N events to occur.
150 class BlockingCounter {
152 BlockingCounter() : count_(0), initial_count_(0) {
157 ~BlockingCounter() {
192 // to hit the BlockingCounter.
194 ScopedProfilingLabel label("BlockingCounter::Wait");
237 explicit Worker(BlockingCounter* counter_to_decrement_when_ready)
351 // pointer to the master's thread BlockingCounter object, to notify the
353 BlockingCounter* const counter_to_decrement_when_ready_;
418 // The BlockingCounter used to wait for the workers
    [all...]
  /external/tensorflow/tensorflow/core/grappler/costs/
measuring_cost_estimator.cc 63 BlockingCounter barrier(measurement_steps_);
  /external/tensorflow/tensorflow/core/kernels/data/
unbounded_thread_pool_test.cc 118 BlockingCounter bc(round_size);
  /external/tensorflow/tensorflow/core/kernels/
xsmm_conv2d.cc 238 BlockingCounter count(num_threads);
256 BlockingCounter count(num_threads);
368 BlockingCounter counter(num_threads);
sparse_matmul_op.cc 815 static inline std::unique_ptr<BlockingCounter> CreateSparseSlices(
823 // returns the list of the pieces in "slices". It returns a BlockingCounter
825 static inline std::unique_ptr<BlockingCounter> CreateDenseSlices(
831 // BlockingCounter which should be used to wait for the shuffle operations to
833 static inline BlockingCounter* ShuffleMatrix(
    [all...]
clustering_ops.cc 412 BlockingCounter counter(num_threads - 1);
quantization_utils.h     [all...]
  /external/tensorflow/tensorflow/compiler/xla/service/gpu/
nccl_all_reduce_thunk.cc 145 absl::optional<tensorflow::BlockingCounter> done_;
  /external/tensorflow/tensorflow/core/common_runtime/eager/
context.cc 172 BlockingCounter counter(static_cast<int>(remote_contexts_.size()));
310 BlockingCounter blocking_counter(static_cast<int>(remote_contexts_.size()));
  /external/tensorflow/tensorflow/contrib/factorization/kernels/
wals_solver_ops.cc 213 BlockingCounter counter(shards.size());
  /external/tensorflow/tensorflow/core/kernels/data/experimental/
matching_files_dataset_op.cc 319 BlockingCounter counter(children.size());
  /external/tensorflow/tensorflow/lite/tools/accuracy/ilsvrc/
imagenet_model_evaluator.cc 313 BlockingCounter counter(num_threads_);
  /external/tensorflow/tensorflow/core/distributed_runtime/
master_session.cc 165 BlockingCounter all_done(waiting_for);
466 BlockingCounter done(num);
539 BlockingCounter pending_;
    [all...]
  /external/tensorflow/tensorflow/core/platform/cloud/
ram_file_block_cache_test.cc 480 BlockingCounter counter(callers);

Completed in 181 milliseconds