| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_channel.cc | 121 mutex_lock l(mu_); // could use reader lock
129 mutex_lock l(mu_);
143 mutex mu_; member in class:__anon39535::CachingGrpcChannelCache
144 std::unordered_map<string, SharedGrpcChannelPtr> channels_ GUARDED_BY(mu_);
167 mutex_lock l(mu_); // could use reader lock
189 mutex_lock l(mu_);
201 mutex mu_; member in class:__anon39535::MultiGrpcChannelCache
204 std::unordered_map<string, GrpcChannelCache*> target_caches_ GUARDED_BY(mu_);
|
| grpc_testlib_ops.cc | 53 ctx->set_output_ref(0, &mu_, &output_);
58 mutex mu_; member in class:tensorflow::test::InvalidRefType
|
| grpc_call.h | 171 mutex_lock l(mu_);
181 mutex_lock l(mu_);
187 mutex_lock l(mu_);
262 mutex mu_; member in class:tensorflow::Call
263 std::function<void()> cancel_callback_ GUARDED_BY(mu_);
|
| grpc_session.h | 106 mutex mu_; member in class:tensorflow::GrpcSession
109 string handle_ GUARDED_BY(mu_);
112 int64 current_graph_version_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/framework/ |
| op.cc | 52 mutex_lock lock(mu_);
68 mutex_lock lock(mu_);
77 // Note: Can't hold mu_ while calling Export() below.
106 mutex_lock lock(mu_);
114 mutex_lock lock(mu_);
124 mutex_lock lock(mu_);
143 mutex_lock lock(mu_);
148 mutex_lock lock(mu_);
153 mutex_lock lock(mu_);
|
| reader_base.cc | 34 mutex_lock lock(mu_);
39 mutex_lock lock(mu_);
44 mutex_lock lock(mu_);
57 mutex_lock lock(mu_);
66 mutex_lock lock(mu_);
82 mutex_lock lock(mu_);
155 mutex_lock lock(mu_);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| critical_section.cc | 36 mutex_lock lock(mu_);
48 mutex_lock ml(mu_);
65 mutex_lock ml(mu_);
82 tf_shared_lock ml(mu_);
88 mutex mu_; member in class:tensorflow::CriticalSection
89 std::deque<std::function<void()>> closures_ GUARDED_BY(mu_);
90 bool is_locked_ GUARDED_BY(mu_);
91 condition_variable queue_empty_cv_ GUARDED_BY(mu_);
|
| fifo_queue.h | 52 mutex_lock lock(mu_);
61 EXCLUSIVE_LOCKS_REQUIRED(mu_);
|
| priority_queue.h | 72 mutex_lock lock(mu_);
81 EXCLUSIVE_LOCKS_REQUIRED(mu_);
|
| conditional_accumulator_base.cc | 38 mutex_lock lock(mu_);
71 mutex_lock l(mu_);
77 [this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) {
109 mutex_lock lock(mu_);
167 mutex_lock lock(mu_);
177 // DeregisterCallback because the mutex mu_ ensures that the
|
| barrier_ops.cc | 111 mutex_lock lock(mu_);
189 mutex_lock lock(mu_);
206 mutex_lock lock(mu_);
256 mutex_lock lock(mu_);
279 mutex_lock lock(mu_);
297 ~Barrier() override EXCLUSIVE_LOCKS_REQUIRED(mu_) {
298 mutex_lock lock(mu_);
311 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
409 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
410 // CloseQueueLocked may only be called with mu_ held
428 mutex mu_; member in class:tensorflow::barrier::Barrier
[all...] |
| /external/tensorflow/tensorflow/core/lib/histogram/ |
| histogram.h | 132 mutable mutex mu_; member in class:tensorflow::histogram::ThreadSafeHistogram
133 Histogram histogram_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| range_dataset_op.cc | 97 mutex_lock l(mu_);
114 mutex_lock l(mu_);
121 mutex_lock l(mu_);
127 mutex mu_; member in class:tensorflow::__anon39752::RangeDatasetOp::Dataset::Iterator
128 int64 next_ GUARDED_BY(mu_);
|
| shuffle_dataset_op.cc | 82 mutex_lock l(mu_);
160 mutex_lock l(mu_);
205 mutex_lock l(mu_);
272 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
278 void ResetRngs() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
286 mutex mu_; member in class:tensorflow::__anon39756::ShuffleDatasetOpBase::ShuffleDatasetBase::Iterator
287 std::unique_ptr<std::vector<Tensor>[]> buffer_ GUARDED_BY(mu_);
288 std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
289 const int64 seed_ GUARDED_BY(mu_);
290 const int64 seed2_ GUARDED_BY(mu_);
297 int64 num_random_samples_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39756::ShuffleDatasetOpBase::ShuffleDatasetBase::Iterator
381 mutable mutex mu_; member in class:tensorflow::__anon39756::ShuffleDatasetOp::ReshufflingDataset
[all...] |
| tensor_slice_dataset_op.cc | 114 mutex_lock l(mu_);
135 mutex_lock l(mu_);
142 mutex_lock l(mu_);
148 mutex mu_; member in class:tensorflow::__anon39765::TensorSliceDatasetOp::Dataset::Iterator
149 int64 i_ GUARDED_BY(mu_);
|
| zip_dataset_op.cc | 110 mutex_lock l(mu_);
136 mutex_lock l(mu_);
149 mutex_lock l(mu_);
161 mutex mu_; member in class:tensorflow::__anon39768::ZipDatasetOp::Dataset::Iterator
162 std::vector<std::unique_ptr<IteratorBase>> input_impls_ GUARDED_BY(mu_);
|
| flat_map_dataset_op.cc | 134 mutex_lock l(mu_);
172 mutex_lock l(mu_);
199 mutex_lock l(mu_);
240 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
248 EXCLUSIVE_LOCKS_REQUIRED(mu_) {
257 mutex mu_; member in class:tensorflow::__anon39741::FlatMapDatasetOp::Dataset::Iterator
258 size_t element_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39741::FlatMapDatasetOp::Dataset::Iterator
259 std::unique_ptr<IteratorBase> input_impl_ GUARDED_BY(mu_);
260 std::unique_ptr<IteratorBase> current_element_iterator_ GUARDED_BY(mu_);
261 std::vector<Tensor> captured_func_inputs_ GUARDED_BY(mu_);
[all...] |
| sparse_tensor_slice_dataset_op.cc | 96 mutex_lock l(mu_);
155 mutex_lock l(mu_);
172 mutex_lock l(mu_);
194 mutex mu_; member in class:tensorflow::__anon39758::Dataset::Iterator
195 sparse::GroupIterable group_iterable_ GUARDED_BY(mu_);
196 sparse::GroupIterable::IteratorStep iter_ GUARDED_BY(mu_);
197 int64 i_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39758::Dataset::Iterator
199 int64 next_non_empty_i_ GUARDED_BY(mu_) = kNextNonEmptyUnknown; member in class:tensorflow::__anon39758::Dataset::Iterator
200 Tensor next_indices_ GUARDED_BY(mu_);
201 Tensor next_values_ GUARDED_BY(mu_);
[all...] |
| reader_dataset_ops.cc | 135 mutex_lock l(mu_);
171 mutex_lock l(mu_);
187 mutex_lock l(mu_);
208 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) {
237 void ResetStreamsLocked() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
244 mutex mu_; member in class:tensorflow::__anon39753::TextLineDatasetOp::Dataset::Iterator
246 GUARDED_BY(mu_);
247 std::unique_ptr<io::ZlibInputStream> zlib_input_stream_ GUARDED_BY(mu_);
249 GUARDED_BY(mu_);
250 size_t current_file_index_ GUARDED_BY(mu_) = 0 member in class:tensorflow::__anon39753::TextLineDatasetOp::Dataset::Iterator
480 mutex mu_; member in class:tensorflow::__anon39753::FixedLengthRecordDatasetOp::Dataset::Iterator
481 size_t current_file_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39753::FixedLengthRecordDatasetOp::Dataset::Iterator
485 int64 file_pos_limit_ GUARDED_BY(mu_) = -1; member in class:tensorflow::__anon39753::FixedLengthRecordDatasetOp::Dataset::Iterator
672 mutex mu_; member in class:tensorflow::__anon39753::TFRecordDatasetOp::Dataset::Iterator
673 size_t current_file_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::__anon39753::TFRecordDatasetOp::Dataset::Iterator
[all...] |
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| process_state.cc | 111 mutex_lock lock(mu_);
166 &mem_desc_map_, gpu_allocator, md, &mu_);
183 mutex_lock lock(mu_);
240 tf_shared_lock lock(mu_);
251 mutex_lock lock(mu_);
296 &mem_desc_map_, cuda_host_allocators_.back(), md, &mu_));
305 mutex_lock lock(mu_);
|
| /external/tensorflow/tensorflow/cc/training/ |
| queue_runner.h | 120 mutex mu_; member in class:tensorflow::QueueRunner
122 Status status_ GUARDED_BY(mu_);
123 Status enqueue_status_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/contrib/nccl/kernels/ |
| nccl_manager.h | 117 mutex mu_; member in class:tensorflow::NcclManager
121 GUARDED_BY(mu_);
128 device_to_comm_streams_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| base_rendezvous_mgr.cc | 58 mutex_lock l(mu_);
107 mutex_lock l(mu_);
122 mutex_lock l(mu_);
156 mutex_lock l(mu_);
178 mutex_lock l(mu_);
183 mutex_lock l(mu_);
192 mutex_lock l(mu_);
211 mutex_lock l(mu_);
334 mutex_lock l(mu_);
366 mutex_lock l(mu_);
[all...] |
| worker_cache_logger.cc | 48 mutex_lock l(mu_);
60 mutex_lock l(mu_);
73 mutex_lock l(mu_);
|
| worker_session.cc | 39 mutex_lock l(mu_);
84 mutex mu_; member in class:tensorflow::__anon39550::WorkerFreeListCache
85 std::unordered_map<string, WorkerState> workers_ GUARDED_BY(mu_);
|
