Home
last modified time | relevance | path

Searched refs:mutex_lock (Results 1 – 25 of 476) sorted by relevance

12345678910>>...20

/external/tensorflow/tensorflow/cc/training/
Dcoordinator.cc40 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 …]
Dqueue_runner.cc37 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/
Dtracking_allocator.cc44 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 …]
Dcancellation.cc43 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()
Dop.cc60 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/
Dcall_options.cc25 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()
Dpartial_run_mgr.cc24 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/kernels/data/
Dsplit_utils.cc29 mutex_lock l(mu_); in GetNext()
41 mutex_lock l(mu_); in Reset()
49 mutex_lock l(mu_); in Save()
56 mutex_lock l(mu_); in Restore()
69 mutex_lock l(mu_); in GetNext()
83 mutex_lock l(mu_); in Reset()
92 mutex_lock l(mu_); in Save()
104 mutex_lock l(mu_); in Restore()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_allocator_retry_test.cc40 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/data/service/
Dworker_impl.cc61 mutex_lock l(mu_); in ~DataServiceWorkerImpl()
95 mutex_lock l(mu_); in Start()
102 mutex_lock l(mu_); in ProcessTask()
124 mutex_lock l(task.mu); in EnsureTaskInitialized()
185 mutex_lock l(mu_); in GetElement()
210 mutex_lock l(mu_); in GetElement()
223 mutex_lock l(mu_); in GetWorkerTasks()
237 mutex_lock l(mu_); in TaskCompletionThread()
249 mutex_lock l(mu_); in TaskCompletionThread()
261 mutex_lock l(mu_); in SendTaskUpdates()
[all …]
/external/tensorflow/tensorflow/c/
Dpython_api.cc24 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()
64 mutex_lock l(graph->mu); in RemoveAllControlInputs()
76 mutex_lock l(graph->mu); in SetRequireShapeInferenceFns()
90 mutex_lock l(graph->mu); in GetHandleShapeAndType()
121 tensorflow::mutex_lock l(graph->mu); in SetHandleShapeAndType()
139 mutex_lock l(graph->mu); in AddWhileInputHack()
/external/tensorflow/tensorflow/core/common_runtime/
Dsession_state.cc27 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()
Dscoped_allocator_mgr.cc28 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()
117 mutex_lock l(mu_); in ~ScopedAllocatorMgr()
130 mutex_lock l(mu_); in Cleanup()
141 mutex_lock l(mu_); in GetContainer()
/external/tensorflow/tensorflow/core/platform/
Dmutex.h145 class TF_SCOPED_LOCKABLE mutex_lock {
149 explicit mutex_lock(mutex_type& mu) TF_EXCLUSIVE_LOCK_FUNCTION(mu) in mutex_lock() function
154 mutex_lock(mutex_type& mu, std::try_to_lock_t) TF_EXCLUSIVE_LOCK_FUNCTION(mu) in mutex_lock() function
163 mutex_lock(mutex_lock&& ml) noexcept TF_EXCLUSIVE_LOCK_FUNCTION(ml.mu_) in mutex_lock() function
167 ~mutex_lock() TF_UNLOCK_FUNCTION() { in TF_UNLOCK_FUNCTION()
181 #define mutex_lock(x) static_assert(0, "mutex_lock_decl_missing_var_name"); macro
229 void wait(mutex_lock& lock);
231 std::cv_status wait_for(mutex_lock& lock,
237 friend ConditionResult WaitForMilliseconds(mutex_lock* mu,
247 inline ConditionResult WaitForMilliseconds(mutex_lock* mu, in WaitForMilliseconds()
Dram_file_system.h111 mutex_lock m(mu_); in NewRandomAccessFile()
122 mutex_lock m(mu_); in NewWritableFile()
132 mutex_lock m(mu_); in NewAppendableFile()
154 mutex_lock m(mu_); in GetChildren()
166 mutex_lock m(mu_); in GetMatchingPaths()
178 mutex_lock m(mu_); in Stat()
198 mutex_lock m(mu_); in DeleteFile()
222 mutex_lock m(mu_); in GetFileSize()
232 mutex_lock m(mu_); in RenameFile()
/external/tensorflow/tensorflow/core/platform/default/
Dunbounded_work_queue.cc31 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()
Dnotification.h36 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/
Dfake_clock_env.cc28 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()
/external/tensorflow/tensorflow/core/kernels/
Dtensor_array.h189 mutex_lock l(mu_); in WriteOrAggregate()
197 mutex_lock l(mu_); in WriteOrAggregateMany()
225 mutex_lock l(mu_); in Read()
232 mutex_lock l(mu_); in ReadMany()
247 mutex_lock l(mu_); in ElemShape()
252 mutex_lock l(mu_); in SetElemShape()
263 mutex_lock l(mu_); in DebugString()
269 mutex_lock l(mu_); in IsClosed()
275 mutex_lock l(mu_); in Size()
283 mutex_lock l(mu_); in SetMarkedSize()
[all …]
/external/tensorflow/tensorflow/compiler/jit/
Dxla_device.cc117 mutex_lock lock(state.allocator_mutex_); in GetOrCreateXlaDeviceAllocator()
230 mutex_lock lock(mu_); in ~XlaDevice()
253 mutex_lock lock(mu_); in GetAllocator()
273 mutex_lock lock(mu_); in EnsureDeviceContextOk()
378 mutex_lock lock(mu_); in UseGpuDeviceInfo()
384 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()
505 mutex_lock lock(mu_); in MakeTensorFromProto()
[all …]
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext.cc213 mutex_lock l(device_type_list_mu_); in InitPrioritizedDeviceTypeList()
337 tensorflow::mutex_lock l(executor_map_mu_); in SetExecutorForThread()
351 tensorflow::mutex_lock l(executor_map_mu_); in SetExecutorForThread()
369 mutex_lock l(executor_map_mu_); in ClearCachesAndThreadExecutors()
382 mutex_lock ml(cache_mu_); in ClearCachesAndDefaultExecutor()
389 mutex_lock ml(metadata_mu_); in ClearCachesAndDefaultExecutor()
397 mutex_lock ml(policy_map_mu_); in SetThreadLocalDevicePlacementPolicy()
427 mutex_lock l(remote_state_mu_); in CloseAndClearAllRemoteContexts()
483 mutex_lock l(keep_alive_thread_shutdown_mu_); in WaitForAndCloseRemoteContexts()
494 mutex_lock l(remote_state_mu_); in WaitForAndCloseRemoteContexts()
[all …]
/external/tensorflow/tensorflow/core/platform/cloud/
Dram_file_block_cache.cc25 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/
Dhistogram.cc233 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/
Dcollection_registry.cc31 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/
Dxla_debug_info_manager.cc25 tensorflow::mutex_lock lock(mutex_); in RegisterModule()
43 tensorflow::mutex_lock lock(mutex_); in UnregisterModule()
65 tensorflow::mutex_lock lock(mutex_); in OnModuleStart()
70 tensorflow::mutex_lock lock(mutex_); in OnModuleStop()
79 tensorflow::mutex_lock lock(mutex_); in StartTracing()
87 tensorflow::mutex_lock lock(mutex_); in StopTracing()

12345678910>>...20