Home
last modified time | relevance | path

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

12345678910>>...19

/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/platform/default/
Dmutex.h29 #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/
Dcontext.cc119 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 …]
Deager_executor.cc23 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/
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.cc31 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()
Dop.cc53 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/
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/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()
Dbase_rendezvous_mgr.cc58 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/
Deager_service_impl.h46 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/
Dpython_api.cc24 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/
Dsession_state.cc24 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()
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/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.cc97 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/
Dtemporary_memory_manager.cc29 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/
Dcache_dataset_ops.cc127 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 …]
Dprefetch_dataset_op.cc95 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/
Dram_file_block_cache.cc25 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/
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/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()

12345678910>>...19