/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/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 | 43 mutex_lock l(mu_); in StartCancel() 75 mutex_lock l(mu_); in StartCancel() 87 mutex_lock l(mu_); in RegisterCallback() 125 mutex_lock l(mu_); in RegisterChild() 151 mutex_lock l(mu_); in DeregisterChild() 184 mutex_lock lock(mu_); in TryDeregisterCallback() 205 mutex_lock lock(mu_); in IsCancelling()
|
D | op.cc | 60 mutex_lock lock(mu_); in Register() 110 mutex_lock lock(mu_); in LookUpSlow() 140 mutex_lock lock(mu_); in GetRegisteredOps() 149 mutex_lock lock(mu_); in GetOpRegistrationData() 157 mutex_lock lock(mu_); in SetWatcher() 167 mutex_lock lock(mu_); in Export() 186 mutex_lock lock(mu_); in DeferRegistrations() 191 mutex_lock lock(mu_); in ClearDeferredRegistrations() 196 mutex_lock lock(mu_); in ProcessRegistrations()
|
/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 | partial_run_mgr.cc | 24 mutex_lock l(mu_); in FindOrCreate() 44 mutex_lock l(mu_); in ExecutorDone() 62 mutex_lock l(mu_); in ExecutorDone() 71 mutex_lock l(mu_); in PartialRunDone() 87 mutex_lock l(mu_); in PartialRunDone()
|
/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/platform/ |
D | mutex.h | 145 class SCOPED_LOCKABLE mutex_lock { 149 explicit mutex_lock(mutex_type& mu) EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(&mu) { in mutex_lock() function 153 mutex_lock(mutex_type& mu, std::try_to_lock_t) EXCLUSIVE_LOCK_FUNCTION(mu) in mutex_lock() function 162 mutex_lock(mutex_lock&& ml) noexcept EXCLUSIVE_LOCK_FUNCTION(ml.mu_) in mutex_lock() function 166 ~mutex_lock() UNLOCK_FUNCTION() { in UNLOCK_FUNCTION() 180 #define mutex_lock(x) static_assert(0, "mutex_lock_decl_missing_var_name"); macro 227 void wait(mutex_lock& lock); 229 std::cv_status wait_for(mutex_lock& lock, 235 friend ConditionResult WaitForMilliseconds(mutex_lock* mu, 245 inline ConditionResult WaitForMilliseconds(mutex_lock* mu, in WaitForMilliseconds()
|
/external/tensorflow/tensorflow/core/common_runtime/ |
D | session_state.cc | 27 mutex_lock l(state_lock_); in GetTensor() 38 mutex_lock l(state_lock_); in AddTensor() 47 mutex_lock l(state_lock_); in DeleteTensor() 56 mutex_lock l(state_lock_); in GetNewId() 61 mutex_lock l(lock_); in AddTensor() 72 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/c/ |
D | python_api.cc | 24 mutex_lock l(graph->mu); in AddControlInput() 39 mutex_lock l(graph->mu); in SetAttr() 47 mutex_lock l(graph->mu); in ClearAttr() 53 mutex_lock l(graph->mu); in SetRequestedDevice() 60 mutex_lock l(graph->mu); in UpdateEdge() 100 mutex_lock l(graph->mu); in RemoveAllControlInputs() 112 mutex_lock l(graph->mu); in SetRequireShapeInferenceFns() 126 mutex_lock l(graph->mu); in GetHandleShapeAndType() 156 tensorflow::mutex_lock l(graph->mu); in SetHandleShapeAndType() 173 mutex_lock l(graph->mu); in AddWhileInputHack()
|
/external/tensorflow/tensorflow/core/platform/default/ |
D | unbounded_work_queue.cc | 31 mutex_lock l(work_queue_mu_); in ~UnboundedWorkQueue() 44 mutex_lock l(thread_pool_mu_); in ~UnboundedWorkQueue() 58 mutex_lock l(work_queue_mu_); in Schedule() 70 mutex_lock l(thread_pool_mu_); in Schedule() 84 mutex_lock l(work_queue_mu_); in PooledThreadFunc()
|
D | notification.h | 36 mutex_lock l(mu_); in ~Notification() 40 mutex_lock l(mu_); in Notify() 52 mutex_lock l(mu_); in WaitForNotification() 65 mutex_lock l(mu_); in WaitForNotificationWithTimeout()
|
/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 | 102 mutex_lock lock(state.allocator_mutex_); in GetOrCreateXlaDeviceAllocator() 229 mutex_lock lock(mu_); in ~XlaDevice() 252 mutex_lock lock(mu_); in GetAllocator() 272 mutex_lock lock(mu_); in EnsureDeviceContextOk() 377 mutex_lock lock(mu_); in UseGpuDeviceInfo() 383 mutex_lock lock(mu_); in TryGetDeviceContext() 428 mutex_lock lock(mu_); in Sync() 448 mutex_lock lock(mu_); in Sync() 488 mutex_lock lock(mu_); in MakeTensorFromProto() 512 mutex_lock lock(mu_); in MakeTensorFromProto() [all …]
|
/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()
|
/external/tensorflow/tensorflow/core/common_runtime/eager/ |
D | context.cc | 244 tensorflow::mutex_lock l(executor_map_mu_); in SetExecutorForThread() 255 mutex_lock l(executor_map_mu_); in ClearCachesAndThreadExecutors() 268 mutex_lock ml(cache_mu_); in ClearCachesAndDefaultExecutor() 278 mutex_lock ml(policy_map_mu_); in SetThreadLocalDevicePlacementPolicy() 294 mutex_lock ml(policy_map_mu_); in SetThreadLocalMirroringPolicy() 320 mutex_lock l(remote_state_mu_); in CloseAndClearAllRemoteContexts() 372 mutex_lock l(keep_alive_thread_shutdown_mu_); in WaitForAndCloseRemoteContexts() 383 mutex_lock l(remote_state_mu_); in WaitForAndCloseRemoteContexts() 388 mutex_lock l(executor_map_mu_); in WaitForAndCloseRemoteContexts() 429 mutex_lock l(keep_alive_thread_shutdown_mu_); in ~EagerContext() [all …]
|
D | eager_executor.cc | 34 tensorflow::mutex_lock l(node_queue_mutex_); in ~EagerExecutor() 45 tensorflow::mutex_lock l(node_queue_mutex_); in ShutDown() 105 tensorflow::mutex_lock l(node_queue_mutex_); in SyncExecute() 132 tensorflow::mutex_lock l(node_queue_mutex_); in AddOrExecute() 164 tensorflow::mutex_lock l(node_queue_mutex_); in WaitForAllPendingNodes() 169 mutex_lock* lock) { in WaitForAllPendingNodesLocked() 190 tensorflow::mutex_lock l(node_queue_mutex_); in ClearError() 217 mutex_lock l(node_queue_mutex_); in NodeDone() 304 tensorflow::mutex_lock l(node_queue_mutex_); in Run() 354 tensorflow::mutex_lock l(node_queue_mutex_); in MoveToUnfinished()
|
/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() 71 mutex_lock lock(mu_); in UpdateLRU() 107 mutex_lock l(mu_); in MaybeFetch() 123 mutex_lock l(block->mu); in MaybeFetch() 232 mutex_lock lock(mu_); in ValidateAndUpdateFileSignature() 248 mutex_lock lock(mu_); in CacheSize() 254 mutex_lock lock(mu_); in Prune() 270 mutex_lock lock(mu_); in Flush() 278 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/lib/monitoring/ |
D | collection_registry.cc | 31 mutex_lock l(mu_); in ConsumeCollectedMetrics() 38 mutex_lock l(mu_); in CollectMetricDescriptor() 73 mutex_lock l(mu_); in Register() 90 mutex_lock l(mu_); in Unregister() 98 mutex_lock l(mu_); in CollectMetrics()
|
/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
D | gpu_debug_info_manager.cc | 26 tensorflow::mutex_lock lock(mutex_); in RegisterModule() 44 tensorflow::mutex_lock lock(mutex_); in UnregisterModule() 66 tensorflow::mutex_lock lock(mutex_); in OnModuleStart() 71 tensorflow::mutex_lock lock(mutex_); in OnModuleStop() 80 tensorflow::mutex_lock lock(mutex_); in StartTracing() 88 tensorflow::mutex_lock lock(mutex_); in StopTracing()
|