HomeSort by relevance Sort by last modified time
    Searched refs:mu_ (Results 101 - 125 of 279) sorted by null

1 2 3 45 6 7 8 91011>>

  /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
SimpleThreadPool.h 36 std::unique_lock<std::mutex> l(mu_);
60 std::unique_lock<std::mutex> l(mu_);
87 std::unique_lock<std::mutex> l(mu_);
112 mu_.unlock();
115 mu_.lock();
137 std::mutex mu_; member in class:Eigen::SimpleThreadPoolTempl
  /external/tensorflow/tensorflow/core/kernels/
conditional_accumulator_base_op.h 57 mutex_lock l(mu_);
61 ctx->set_output_ref(0, &mu_, accumulator_handle_.AccessTensor(ctx));
87 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
112 mutex mu_; member in class:tensorflow::ConditionalAccumulatorBaseOp
113 PersistentTensor accumulator_handle_ GUARDED_BY(mu_);
114 bool accumulator_handle_set_ GUARDED_BY(mu_);
queue_base.h 73 mutex_lock lock(mu_);
95 // called once mu_ is released). Returns true if any progress was
129 EXCLUSIVE_LOCKS_REQUIRED(mu_);
149 mutable mutex mu_; member in class:tensorflow::QueueBase
150 bool closed_ GUARDED_BY(mu_);
156 DoneCallback done_callback; // must be run outside mu_
160 RunCallback run_callback; // must be run while holding mu_
177 std::deque<Attempt> enqueue_attempts_ GUARDED_BY(mu_);
178 std::deque<Attempt> dequeue_attempts_ GUARDED_BY(mu_);
logging_ops.cc 70 mutex_lock l(mu_);
84 mutex mu_; member in class:tensorflow::PrintOp
85 int64 call_counter_ GUARDED_BY(mu_) = 0; member in class:tensorflow::PrintOp
typed_queue.h 44 std::vector<SubQueue> queues_ GUARDED_BY(mu_);
66 mutex_lock lock(mu_);
113 mutex_lock l(mu_);
fifo_queue_op.cc 50 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
lookup_table_op.cc 52 mutex_lock l(mu_);
62 mutex_lock l(mu_);
76 mutex_lock l(mu_);
99 mutex_lock l(mu_);
129 mutex_lock l(mu_);
143 mutable mutex mu_; member in class:tensorflow::lookup::final
144 std::unordered_map<K, V> table_ GUARDED_BY(mu_);
162 mutex_lock l(mu_);
173 mutex_lock l(mu_);
196 mutex_lock l(mu_);
273 mutable mutex mu_; member in class:tensorflow::lookup::final
638 mutable mutex mu_; member in class:tensorflow::lookup::final
    [all...]
  /external/tensorflow/tensorflow/core/kernels/data/
skip_dataset_op.cc 118 mutex_lock l(mu_); // TODO(mrry): Make locking less conservative.
153 mutex_lock l(mu_);
166 mutex_lock l(mu_);
177 mutex mu_; member in class:tensorflow::__anon39757::SkipDatasetOp::Dataset::FiniteIterator
178 int64 i_ GUARDED_BY(mu_);
179 std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
take_dataset_op.cc 119 mutex_lock l(mu_); // TODO(mrry): Make locking less conservative.
140 mutex_lock l(mu_);
153 mutex_lock l(mu_);
164 mutex mu_; member in class:tensorflow::__anon39762::TakeDatasetOp::Dataset::FiniteIterator
165 int64 i_ GUARDED_BY(mu_);
166 std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
parallel_interleave_dataset_op.cc 192 mutex_lock l(mu_);
206 mutex_lock l(mu_);
311 // WorkerState's fields are all protected by mu_;
349 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
383 mutex_lock l(mu_);
391 mutex_lock l(mu_);
407 mutex_lock l(mu_);
421 mutex_lock l(mu_);
450 mutex mu_; member in class:tensorflow::__anon39748::ParallelInterleaveDatasetOp::Dataset::Iterator
458 std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
470 size_t next_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39748::ParallelInterleaveDatasetOp::Dataset::Iterator
472 size_t block_count_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39748::ParallelInterleaveDatasetOp::Dataset::Iterator
474 bool cancelled_ GUARDED_BY(mu_) = false; member in class:tensorflow::__anon39748::ParallelInterleaveDatasetOp::Dataset::Iterator
    [all...]
interleave_dataset_op.cc 156 void AdvanceToNextInCycle() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
161 void AdvancePosition() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
171 mutex_lock l(mu_);
214 mutex_lock l(mu_);
232 mutex_lock l(mu_);
251 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
270 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
296 mutex mu_; member in class:tensorflow::__anon39743::InterleaveDatasetOp::Dataset::Iterator
297 const std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
299 GUARDED_BY(mu_);
301 size_t cycle_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39743::InterleaveDatasetOp::Dataset::Iterator
302 int64 block_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39743::InterleaveDatasetOp::Dataset::Iterator
303 bool end_of_input_ GUARDED_BY(mu_) = false; member in class:tensorflow::__anon39743::InterleaveDatasetOp::Dataset::Iterator
304 size_t num_open_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39743::InterleaveDatasetOp::Dataset::Iterator
    [all...]
  /external/compiler-rt/lib/sanitizer_common/
sanitizer_symbolizer.h 126 // its method should be protected by |mu_|.
131 mu_(synchronized_by) {}
139 BlockingMutex *mu_; member in class:__sanitizer::final::ModuleNameOwner
161 BlockingMutex mu_; member in class:__sanitizer::final
  /external/tensorflow/tensorflow/core/distributed_runtime/
worker_cache_partial.cc 31 mutex_lock lock(mu_); // could use reader lock
79 mutex_lock lock(mu_);
89 mutex_lock lock(mu_);
recent_request_ids.cc 32 mutex_lock l(mu_);
cluster_function_library_runtime.h 52 mutable mutex mu_; member in class:tensorflow::ClusterFunctionLibraryRuntime
72 std::vector<FunctionData> function_data_ GUARDED_BY(mu_);
  /external/tensorflow/tensorflow/core/framework/
rendezvous.cc 158 mu_.lock();
162 mu_.unlock();
179 mu_.unlock();
186 mu_.unlock();
201 mu_.lock();
205 mu_.unlock();
221 mu_.unlock();
229 mu_.unlock();
242 mutex_lock l(mu_);
294 mutex mu_; member in class:tensorflow::LocalRendezvousImpl
    [all...]
  /build/kati/
stats.h 40 mutable mutex mu_; member in class:Stats
  /external/tensorflow/tensorflow/core/common_runtime/
executor.h 180 mutable mutex mu_; member in class:tensorflow::ExecutorBarrier
181 int pending_ GUARDED_BY(mu_) = 0; member in class:tensorflow::ExecutorBarrier
182 Status status_ GUARDED_BY(mu_);
190 mutex_lock l(mu_);
  /external/tensorflow/tensorflow/core/lib/histogram/
histogram.cc 233 mutex_lock l(mu_);
238 mutex_lock l(mu_);
243 mutex_lock l(mu_);
249 mutex_lock l(mu_);
254 mutex_lock l(mu_);
259 mutex_lock l(mu_);
264 mutex_lock l(mu_);
269 mutex_lock l(mu_);
274 mutex_lock l(mu_);
  /external/tensorflow/tensorflow/contrib/tensorboard/db/
summary_db_writer.cc 187 Status CreateNewId(int64* id) LOCKS_EXCLUDED(mu_) {
188 mutex_lock lock(mu_);
221 int64 MakeRandomId() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
227 mutex mu_; member in class:tensorflow::__anon39434::IdAllocator
230 int tier_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39434::IdAllocator
418 int64 run_id() LOCKS_EXCLUDED(mu_) {
419 mutex_lock lock(mu_);
425 LOCKS_EXCLUDED(mu_) {
428 mutex_lock lock(mu_);
441 const SummaryMetadata& metadata) LOCKS_EXCLUDED(mu_) {
645 mutex mu_; member in class:tensorflow::__anon39434::RunMetadata
650 int64 experiment_id_ GUARDED_BY(mu_) = kAbsent; member in class:tensorflow::__anon39434::RunMetadata
651 int64 run_id_ GUARDED_BY(mu_) = kAbsent; member in class:tensorflow::__anon39434::RunMetadata
652 int64 user_id_ GUARDED_BY(mu_) = kAbsent; member in class:tensorflow::__anon39434::RunMetadata
653 double experiment_started_time_ GUARDED_BY(mu_) = 0.0; member in class:tensorflow::__anon39434::RunMetadata
654 double run_started_time_ GUARDED_BY(mu_) = 0.0; member in class:tensorflow::__anon39434::RunMetadata
903 mutex mu_; member in class:tensorflow::__anon39434::SeriesWriter
908 uint64 count_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39434::SeriesWriter
909 int64 last_rowid_ GUARDED_BY(mu_) = kAbsent; member in class:tensorflow::__anon39434::SeriesWriter
911 uint64 unflushed_bytes_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39434::SeriesWriter
913 int64 dangling_step_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39434::SeriesWriter
914 double dangling_computed_time_ GUARDED_BY(mu_) = 0.0; member in class:tensorflow::__anon39434::SeriesWriter
963 mutex mu_; member in class:tensorflow::__anon39434::RunWriter
    [all...]
summary_file_writer.cc 47 mutex_lock ml(mu_);
59 mutex_lock ml(mu_);
133 mutex_lock ml(mu_);
149 Status InternalFlush() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
165 mutex mu_; member in class:tensorflow::__anon39436::SummaryFileWriter
166 std::vector<std::unique_ptr<Event>> queue_ GUARDED_BY(mu_);
168 std::unique_ptr<EventsWriter> events_writer_ GUARDED_BY(mu_);
170 GUARDED_BY(mu_);
  /external/tensorflow/tensorflow/contrib/kafka/kernels/
kafka_dataset_ops.cc 115 mutex_lock l(mu_);
171 mutex_lock l(mu_);
187 mutex_lock l(mu_);
214 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) {
296 void ResetStreamsLocked() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
302 mutex mu_; member in class:tensorflow::KafkaDatasetOp::Dataset::Iterator
303 size_t current_topic_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::KafkaDatasetOp::Dataset::Iterator
304 int64 offset_ GUARDED_BY(mu_) = 0; member in class:tensorflow::KafkaDatasetOp::Dataset::Iterator
305 int64 limit_ GUARDED_BY(mu_) = -1; member in class:tensorflow::KafkaDatasetOp::Dataset::Iterator
306 std::unique_ptr<RdKafka::TopicPartition> topic_partition_ GUARDED_BY(mu_);
    [all...]
  /external/tensorflow/tensorflow/contrib/boosted_trees/resources/
quantile_stream_resource.h 48 tensorflow::mutex* mutex() { return &mu_; }
88 tensorflow::mutex mu_; member in class:tensorflow::boosted_trees::QuantileStreamResource
  /external/tensorflow/tensorflow/contrib/tensor_forest/kernels/v4/
decision-tree-resource.h 60 mutex* get_mutex() { return &mu_; }
74 mutex mu_; member in class:tensorflow::tensorforest::DecisionTreeResource
fertile-stats-resource.h 59 mutex* get_mutex() { return &mu_; }
85 mutex mu_; member in class:tensorflow::tensorforest::FertileStatsResource

Completed in 1060 milliseconds

1 2 3 45 6 7 8 91011>>