Home
last modified time | relevance | path

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

12345678910>>...18

/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/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/platform/
Dmutex.h145 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/
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()
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/
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()
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/
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()
Dbatch_scheduler.h199 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/
Dtensor_array.h191 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/
Dxla_device.cc102 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/
Dsycl_allocator.cc39 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/
Dcontext.cc244 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 …]
Deager_executor.cc34 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/
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/gpu/
Dgpu_debug_info_manager.cc26 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()

12345678910>>...18