/external/tensorflow/tensorflow/cc/training/ |
D | coordinator.cc | 40 mutex_lock l(mu_); in RegisterRunner() 46 mutex_lock l(runners_lock_); in RegisterRunner() 52 mutex_lock l(runners_lock_); in AllRunnersStopped() 62 mutex_lock l(mu_); in RequestStop() 73 mutex_lock l(mu_); in ShouldStop() 80 mutex_lock l(mu_); in Join() 88 mutex_lock l(runners_lock_); in Join() 98 mutex_lock l(status_lock_); in ReportStatus() 107 mutex_lock l(status_lock_); in GetStatus() 112 mutex_lock l(mu_); in WaitForStop() [all …]
|
D | queue_runner.cc | 37 mutex_lock l(cb_mu_); in AddErrorCallback() 42 mutex_lock l(cb_mu_); in ClearErrorCallbacks() 113 mutex_lock l(mu_); in Start() 141 mutex_lock l(mu_); in Join() 147 mutex_lock l(mu_); in UpdateStatus() 156 mutex_lock l(cb_mu_); in UpdateStatus() 172 mutex_lock l(mu_); in Run() 181 mutex_lock l(mu_); in Run() 203 mutex_lock l(mu_); in GetStatus() 212 mutex_lock l(*cg_mu_); in ExportCostGraph() [all …]
|
/external/tensorflow/tensorflow/core/platform/default/ |
D | mutex.h | 29 #undef mutex_lock 63 class SCOPED_LOCKABLE mutex_lock { 67 explicit mutex_lock(mutex_type& mu) EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(&mu) { in mutex_lock() function 71 mutex_lock(mutex_type& mu, std::try_to_lock_t) EXCLUSIVE_LOCK_FUNCTION(mu) in mutex_lock() function 80 mutex_lock(mutex_lock&& ml) noexcept EXCLUSIVE_LOCK_FUNCTION(ml.mu_) in mutex_lock() function 84 ~mutex_lock() UNLOCK_FUNCTION() { in UNLOCK_FUNCTION() 98 #define mutex_lock(x) static_assert(0, "mutex_lock_decl_missing_var_name"); macro 145 void wait(mutex_lock& lock); 147 std::cv_status wait_for(mutex_lock& lock, in wait_for() 160 friend ConditionResult WaitForMilliseconds(mutex_lock* mu, [all …]
|
/external/tensorflow/tensorflow/core/common_runtime/eager/ |
D | context.cc | 119 mutex_lock l(async_map_mu_); in Async() 126 tensorflow::mutex_lock l(async_map_mu_); in SetAsyncForThread() 145 mutex_lock ml(cache_mu_); in ClearCaches() 154 mutex_lock ml(policy_map_mu_); in SetThreadLocalDevicePlacementPolicy() 159 mutex_lock ml(policy_map_mu_); in GetDevicePlacementPolicy() 208 mutex_lock l(keep_alive_thread_shutdown_mu_); in ~EagerContext() 231 mutex_lock l(functions_mu_); in FindFunctionByName() 237 mutex_lock l(functions_mu_); in FindFunctionOpData() 242 mutex_lock l(functions_mu_); in FindFunctionDef() 264 mutex_lock l(metadata_mu_); in RegisterRunMetadataListener() [all …]
|
D | eager_executor.cc | 23 tensorflow::mutex_lock l(node_queue_mutex_); in ~EagerExecutor() 29 tensorflow::mutex_lock l(next_id_mutex_); in NextId() 34 tensorflow::mutex_lock l(node_queue_mutex_); in EnableAsync() 43 tensorflow::mutex_lock l(node_queue_mutex_); in Add() 76 tensorflow::mutex_lock l(node_queue_mutex_); in WaitImpl() 95 tensorflow::mutex_lock l(node_queue_mutex_); in ClearError() 106 tensorflow::mutex_lock l(node_queue_mutex_); in status() 114 tensorflow::mutex_lock l(node_queue_mutex_); in Run() 123 tensorflow::mutex_lock l(node_queue_mutex_); in Run()
|
/external/tensorflow/tensorflow/core/framework/ |
D | tracking_allocator.cc | 44 mutex_lock lock(mu_); in AllocateRaw() 57 mutex_lock lock(mu_); in AllocateRaw() 67 mutex_lock lock(mu_); in AllocateRaw() 88 mutex_lock lock(mu_); in DeallocateRaw() 98 mutex_lock lock(mu_); in DeallocateRaw() 118 mutex_lock lock(mu_); in RequestedSize() 131 mutex_lock lock(mu_); in AllocatedSize() 144 mutex_lock lock(mu_); in AllocationId() 166 mutex_lock lock(mu_); in GetSizes() 178 mutex_lock lock(mu_); in GetRecordsAndUnRef() [all …]
|
D | cancellation.cc | 31 mutex_lock l(mu_); in Reset() 39 mutex_lock l(mu_); in StartCancel() 55 mutex_lock l(mu_); in StartCancel() 63 mutex_lock l(mu_); in get_cancellation_token() 69 mutex_lock l(mu_); in RegisterCallback() 99 mutex_lock lock(mu_); in TryDeregisterCallback()
|
D | op.cc | 53 mutex_lock lock(mu_); in Register() 84 mutex_lock lock(mu_); in LookUpSlow() 126 mutex_lock lock(mu_); in GetRegisteredOps() 135 mutex_lock lock(mu_); in GetOpRegistrationData() 143 mutex_lock lock(mu_); in SetWatcher() 153 mutex_lock lock(mu_); in Export() 172 mutex_lock lock(mu_); in DeferRegistrations() 177 mutex_lock lock(mu_); in ClearDeferredRegistrations() 182 mutex_lock lock(mu_); in ProcessRegistrations()
|
/external/tensorflow/tensorflow/core/common_runtime/gpu/ |
D | gpu_allocator_retry_test.cc | 40 mutex_lock l(mu_); in AllocateRaw() 52 mutex_lock l(mu_); in DeallocateRaw() 80 mutex_lock l(mu_); in WaitTurn() 94 mutex_lock l(mu_); in Done() 135 mutex_lock l(mu_); in LaunchConsumerThreads() 157 mutex_lock l(mu_); in JoinConsumerThreads() 196 mutex_lock l(mu_); in TEST_F() 222 mutex_lock l(mu_); in TEST_F() 245 mutex_lock l(mu_); in TEST_F()
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | call_options.cc | 25 mutex_lock l(mu_); in StartCancel() 35 mutex_lock l(mu_); in SetCancelCallback() 40 mutex_lock l(mu_); in ClearCancelCallback() 45 mutex_lock l(mu_); in GetTimeout() 50 mutex_lock l(mu_); in SetTimeout()
|
D | base_rendezvous_mgr.cc | 58 mutex_lock l(mu_); in FindOrCreate() 107 mutex_lock l(mu_); in Cleanup() 122 mutex_lock l(mu_); in CleanupAll() 156 mutex_lock l(mu_); in Initialize() 178 mutex_lock l(mu_); in session() 183 mutex_lock l(mu_); in is_initialized() 192 mutex_lock l(mu_); in Send() 211 mutex_lock l(mu_); in ValidateDevices() 337 mutex_lock l(mu_); in RecvLocalAsync() 369 mutex_lock l(mu_); in StartAbort() [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
D | eager_service_impl.h | 46 mutex_lock l(gc_thread_shutdown_mu_); in EagerServiceImpl() 54 mutex_lock l(contexts_mu_); in EagerServiceImpl() 69 mutex_lock l(gc_thread_shutdown_mu_); in ~EagerServiceImpl() 75 mutex_lock l(contexts_mu_); in ~EagerServiceImpl() 125 mutex_lock l(tensors_mu_); in AddOperationOutputs() 135 mutex_lock l(tensors_mu_); in GetTensorHandle() 149 mutex_lock l(tensors_mu_); in DeleteTensorHandle() 164 mutex_lock l(last_accessed_mu_); in RecordAccess() 169 mutex_lock l(last_accessed_mu_); in IsStale()
|
/external/tensorflow/tensorflow/c/ |
D | python_api.cc | 24 mutex_lock l(graph->mu); in AddControlInput() 39 mutex_lock l(graph->mu); in SetAttr() 48 mutex_lock l(graph->mu); in ClearAttr() 54 mutex_lock l(graph->mu); in SetRequestedDevice() 61 mutex_lock l(graph->mu); in UpdateEdge() 101 mutex_lock l(graph->mu); in RemoveAllControlInputs() 113 mutex_lock l(graph->mu); in SetRequireShapeInferenceFns() 127 mutex_lock l(graph->mu); in GetHandleShapeAndType() 157 tensorflow::mutex_lock l(graph->mu); in SetHandleShapeAndType() 174 mutex_lock l(graph->mu); in AddWhileInputHack()
|
/external/tensorflow/tensorflow/core/common_runtime/ |
D | session_state.cc | 24 mutex_lock l(state_lock_); in GetTensor() 35 mutex_lock l(state_lock_); in AddTensor() 44 mutex_lock l(state_lock_); in DeleteTensor() 53 mutex_lock l(state_lock_); in GetNewId() 58 mutex_lock l(lock_); in AddTensor() 68 mutex_lock l(lock_); in SaveTensors()
|
D | scoped_allocator_mgr.cc | 28 mutex_lock l(mu_); in AddScopedAllocator() 60 mutex_lock l(mu_); in GetAllocator() 76 mutex_lock l(mu_); in GetInstance() 89 mutex_lock l(mu_); in Drop() 102 mutex_lock l(mu_); in ~ScopedAllocatorContainer() 118 mutex_lock l(mu_); in ~ScopedAllocatorMgr() 131 mutex_lock l(mu_); in Cleanup() 142 mutex_lock l(mu_); in GetContainer()
|
/external/tensorflow/tensorflow/core/kernels/batching_util/ |
D | fake_clock_env.cc | 28 mutex_lock l(mu_); in AdvanceByMicroseconds() 44 mutex_lock l(mu_); in BlockUntilSleepingThread() 59 mutex_lock l(mu_); in BlockUntilThreadsAsleep() 70 mutex_lock l(mu_); in NowMicros() 82 mutex_lock l(mu_); in SleepForMicroseconds()
|
D | batch_scheduler.h | 199 mutex_lock l(mu_); in AddTask() 208 mutex_lock l(mu_); in RemoveTask() 222 mutex_lock l(mu_); in num_tasks() 230 mutex_lock l(mu_); in empty() 239 mutex_lock l(mu_); in task() 249 mutex_lock l(mu_); in mutable_task() 258 mutex_lock l(mu_); in size()
|
/external/tensorflow/tensorflow/core/kernels/ |
D | tensor_array.h | 191 mutex_lock l(mu_); in WriteOrAggregate() 199 mutex_lock l(mu_); in WriteOrAggregateMany() 227 mutex_lock l(mu_); in Read() 234 mutex_lock l(mu_); in ReadMany() 249 mutex_lock l(mu_); in ElemShape() 254 mutex_lock l(mu_); in SetElemShape() 265 mutex_lock l(mu_); in DebugString() 271 mutex_lock l(mu_); in IsClosed() 277 mutex_lock l(mu_); in Size() 285 mutex_lock l(mu_); in SetMarkedSize() [all …]
|
/external/tensorflow/tensorflow/compiler/jit/ |
D | xla_device.cc | 97 mutex_lock lock(state.allocator_mutex_); in GetOrCreateXlaDeviceAllocator() 222 mutex_lock lock(mu_); in ~XlaDevice() 241 mutex_lock lock(mu_); in GetAllocator() 259 mutex_lock lock(mu_); in EnsureDeviceContextOk() 352 mutex_lock lock(mu_); in UseGpuDeviceInfo() 360 mutex_lock lock(mu_); in FillContextMap() 393 mutex_lock lock(mu_); in Sync() 413 mutex_lock lock(mu_); in Sync() 455 mutex_lock lock(mu_); in MakeTensorFromProto() 474 mutex_lock lock(mu_); in SetAllowsSyncOnCompletion() [all …]
|
/external/tensorflow/tensorflow/stream_executor/ |
D | temporary_memory_manager.cc | 29 mutex_lock lock(mutex_); in ForceDeallocateAll() 39 mutex_lock lock(mutex_); in MarkFinalized() 52 mutex_lock lock(mutex_); in DeallocateFinalizedTemporaries() 69 mutex_lock lock(mutex_); in IsFinalized() 85 mutex_lock lock(mutex_); in HasAllocated() 110 mutex_lock lock(mutex_); in AllocateArrayBase()
|
/external/tensorflow/tensorflow/core/kernels/data/ |
D | cache_dataset_ops.cc | 127 mutex_lock l(mu_); in Initialize() 134 mutex_lock l(mu_); in GetNextInternal() 146 mutex_lock l(mu_); in SaveInternal() 152 mutex_lock l(mu_); in RestoreInternal() 214 mutex_lock l(mu_); in GetNextInternal() 262 mutex_lock l(mu_); in SaveInternal() 298 mutex_lock l(mu_); in RestoreInternal() 450 mutex_lock l(mu_); in GetNextInternal() 494 mutex_lock l(mu_); in SaveInternal() 503 mutex_lock l(mu_); in RestoreInternal() [all …]
|
D | prefetch_dataset_op.cc | 95 mutex_lock l(mu_); in ~Iterator() 110 mutex_lock l(mu_); in GetNextInternal() 139 mutex_lock parent_l(parent_mu_); in GetNextInternal() 140 mutex_lock l(mu_); in GetNextInternal() 163 mutex_lock parent_l(parent_mu_); in SaveInternal() 164 mutex_lock l(mu_); in SaveInternal() 187 mutex_lock parent_l(parent_mu_); in RestoreInternal() 188 mutex_lock l(mu_); in RestoreInternal() 287 mutex_lock l(mu_); in PrefetchThread() 305 mutex_lock parent_l(parent_mu_); in PrefetchThread() [all …]
|
/external/tensorflow/tensorflow/core/platform/cloud/ |
D | ram_file_block_cache.cc | 25 mutex_lock l(block->mu); in BlockNotStale() 35 mutex_lock lock(mu_); in Lookup() 68 mutex_lock lock(mu_); in UpdateLRU() 104 mutex_lock l(mu_); in MaybeFetch() 118 mutex_lock l(block->mu); in MaybeFetch() 222 mutex_lock lock(mu_); in ValidateAndUpdateFileSignature() 238 mutex_lock lock(mu_); in CacheSize() 244 mutex_lock lock(mu_); in Prune() 260 mutex_lock lock(mu_); in Flush() 268 mutex_lock lock(mu_); in RemoveFile()
|
/external/tensorflow/tensorflow/core/lib/histogram/ |
D | histogram.cc | 233 mutex_lock l(mu_); in DecodeFromProto() 238 mutex_lock l(mu_); in Clear() 243 mutex_lock l(mu_); in Add() 249 mutex_lock l(mu_); in EncodeToProto() 254 mutex_lock l(mu_); in Median() 259 mutex_lock l(mu_); in Percentile() 264 mutex_lock l(mu_); in Average() 269 mutex_lock l(mu_); in StandardDeviation() 274 mutex_lock l(mu_); in ToString()
|
/external/tensorflow/tensorflow/core/common_runtime/sycl/ |
D | sycl_allocator.cc | 39 mutex_lock lock(mu_); in AllocateRaw() 60 mutex_lock lock(mu_); in DeallocateRaw() 70 mutex_lock lock(mu_); in GetStats() 75 mutex_lock l(mu_); in ClearStats() 82 mutex_lock lock(mu_); in RequestedSize()
|