Home
last modified time | relevance | path

Searched refs:lock (Results 1 - 25 of 83) sorted by relevance

1234

/developtools/profiler/device/services/profiler_service/src/
H A Dprofiler_data_repeater.cpp30 std::unique_lock<std::mutex> lock(mutex_); in Size()
36 std::unique_lock<std::mutex> lock(mutex_); in Reset()
43 std::unique_lock<std::mutex> lock(mutex_); in Close()
53 std::unique_lock<std::mutex> lock(mutex_); in PutPluginData()
62 slotCondVar_.wait(lock); in PutPluginData()
69 lock.unlock(); in PutPluginData()
77 std::unique_lock<std::mutex> lock(mutex_); in TakePluginData()
79 itemCondVar_.wait(lock); in TakePluginData()
87 lock.unlock(); in TakePluginData()
95 std::unique_lock<std::mutex> lock(mutex in TakePluginData()
[all...]
/developtools/profiler/device/plugins/native_daemon/src/
H A Dstack_data_repeater.cpp37 std::unique_lock<std::mutex> lock(mutex_); in Size()
43 std::unique_lock<std::mutex> lock(mutex_); in Reset()
50 std::unique_lock<std::mutex> lock(mutex_); in Close()
61 std::unique_lock<std::mutex> lock(cacheMutex_); in GetRawStack()
72 std::unique_lock<std::mutex> lock(cacheMutex_); in ReturnRawStack()
81 std::unique_lock<std::mutex> lock(mutex_); in PutRawStackArray()
87 slotCondVar_.wait(lock); in PutRawStackArray()
95 lock.unlock(); in PutRawStackArray()
103 std::unique_lock<std::mutex> lock(mutex_); in PutRawStack()
111 slotCondVar_.wait(lock); in PutRawStack()
[all...]
/developtools/profiler/device/services/plugin_service/src/
H A Dplugin_session.cpp55 std::unique_lock<std::mutex> lock(mutex_); in Create()
59 auto pluginService = pluginService_.lock(); // promote to shared_ptr in Create()
80 std::unique_lock<std::mutex> lock(mutex_); in Destroy()
85 auto pluginService = pluginService_.lock(); in Destroy()
104 std::unique_lock<std::mutex> lock(mutex_); in IsAvailable()
110 std::unique_lock<std::mutex> lock(mutex_); in GetState()
116 std::unique_lock<std::mutex> lock(mutex_); in Invalidate()
122 std::unique_lock<std::mutex> lock(mutex_); in Start()
126 auto pluginService = pluginService_.lock(); in Start()
139 std::unique_lock<std::mutex> lock(mutex in Refresh()
[all...]
H A Dplugin_session_manager.cpp39 auto pluginSvc = pluginService_.lock(); in CheckPluginSha256()
97 std::unique_lock<std::mutex> lock(mutex_); in CreatePluginSessions()
117 std::unique_lock<std::mutex> lock(mutex_); in CreatePluginSessions()
127 std::unique_lock<std::mutex> lock(mutex_); in RemovePluginSessions()
141 std::unique_lock<std::mutex> lock(mutex_); in InvalidatePluginSessions()
158 std::unique_lock<std::mutex> lock(mutex_); in StartPluginSessions()
176 std::unique_lock<std::mutex> lock(mutex_); in StopPluginSessions()
193 std::unique_lock<std::mutex> lock(mutex_); in RefreshPluginSession()
209 std::unique_lock<std::mutex> lock(mutex_); in CheckStatus()
227 std::unique_lock<std::mutex> lock(mutex in GetStatus()
[all...]
/developtools/profiler/device/base/src/
H A Dstd_semaphore.cpp23 std::unique_lock<std::mutex> lock(mutex_); in Wait()
25 condVar_.wait(lock); in Wait()
33 std::unique_lock<std::mutex> lock(mutex_); in TryWait()
48 std::unique_lock<std::mutex> lock(mutex_); in TimedWait()
53 condVar_.wait_until(lock, timePoint); in TimedWait()
61 std::unique_lock<std::mutex> lock(mutex_); in Post()
H A Depoll_event_poller.cpp53 std::unique_lock<std::mutex> lock(mutex_); in AddFileDescriptor()
60 std::unique_lock<std::mutex> lock(mutex_); in RemoveFileDescriptor()
122 std::unique_lock<std::mutex> lock(mutex_); in Run()
186 std::unique_lock<std::mutex> lock(mutex_); in Init()
205 std::unique_lock<std::mutex> lock(mutex_); in Finalize()
233 std::unique_lock<std::mutex> lock(mutex_); in Start()
/developtools/hapsigner/hapsigntool_cpp/codesigning/fsverity/include/
H A Dthread_pool.h41 std::unique_lock<std::mutex> lock(m_queueMutex); in ThreadPool()
43 m_condition.wait(lock, [this] { return m_stop || !m_tasks.empty(); }); in ThreadPool()
49 lock.unlock(); in ThreadPool()
51 lock.lock(); in ThreadPool()
67 std::unique_lock<std::mutex> lock(m_queueMutex);
69 m_conditionMax.wait(lock);
81 std::unique_lock<std::mutex> lock(m_queueMutex); in ~ThreadPool()
/developtools/profiler/device/plugins/xpower_plugin/src/
H A Dpower_message_queue.cpp37 std::unique_lock<std::mutex> lock(mutex_); in ShutDown()
47 std::unique_lock<std::mutex> lock(mutex_); in WaitAndPop()
51 if (emptyCon_.wait_for(lock, realTime, [&] { return !dataQueue_.empty(); })) { in WaitAndPop()
57 lock.unlock(); in WaitAndPop()
65 std::unique_lock<std::mutex> lock(mutex_); in WaitAndPopBatch()
70 if (emptyCon_.wait_for(lock, realTime, [&] { return !dataQueue_.empty(); })) { in WaitAndPopBatch()
81 lock.unlock(); in WaitAndPopBatch()
/developtools/hdc/hdc_rust/src/transfer/
H A Duart_wrapper.rs181 let mtx = instance.lock().await;
184 let vec = vec.lock().await;
190 let data_mtx = arc.lock().await;
199 let mut mtx = instance.lock().await;
202 let mut vec = vec.lock().await;
216 let mtx = instance.lock().await;
219 let vec = vec.lock().await;
225 let mut data_mtx = arc.lock().await;
235 let mtx = instance.lock().await;
238 let v = flag.lock()
[all...]
H A Dbase.rs49 let mut mutex = arc.lock().await;
55 let mutex = arc.lock().await;
/developtools/profiler/device/plugins/ftrace_plugin/src/
H A Dftrace_module.cpp33 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginRegisterWriter()
43 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginStartSession()
58 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginReportBasicData()
69 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginStopSession()
H A Dresult_transporter.cpp99 std::unique_lock<std::mutex> lock(mutex_); in Submit()
103 lock.unlock(); in Submit()
112 lock.unlock(); in Submit()
/developtools/hdc/src/common/
H A Dcircle_buffer.cpp48 std::unique_lock<std::mutex> lock(mutex_); in Malloc()
80 std::unique_lock<std::mutex> lock(mutex_); in Free()
93 std::unique_lock<std::mutex> lock(mutex_); in FreeMemory()
152 std::unique_lock<std::mutex> lock(timerMutex_); in TimerSleep()
153 timerCv_.wait_for(lock, std::chrono::seconds(1)); in TimerSleep()
158 std::unique_lock<std::mutex> lock(timerMutex_); in TimerNotify()
/developtools/global_resource_tool/src/
H A Dthread_pool.cpp48 std::unique_lock<std::mutex> lock(queueMutex_); in Stop()
73 std::unique_lock<std::mutex> lock(this->queueMutex_); in WorkInThread()
75 this->condition_.wait(lock, [this] { return !this->running_ || !this->tasks_.empty(); }); in WorkInThread()
/developtools/hdc/hdc_rust/src/daemon_lib/
H A Ddaemon_app.rs66 let mut map = map.lock().await;
72 let map = arc.lock().await;
79 let mut map = arc.lock().await;
85 let map = arc.lock().await;
99 let map = arc.lock().await;
105 let mut task = _iter.1.lock().await;
112 let map = arc.lock().await;
115 let task = _iter.1.lock().await;
154 let mut task = arc.lock().await;
211 let mut task = arc.lock()
[all...]
H A Dshell.rs255 let mut child_lock = pty_process.child.lock().await;
270 let mut child_lock = pty_process.child.lock().await;
365 let map = pty_child_map.lock().await;
375 let mut map = pty_child_map.lock().await;
381 let mut map = pty_child_map.lock().await;
400 let map = pty_map.lock().await;
409 let mut map = pty_map.lock().await;
416 let mut map = pty_map.lock().await;
424 let map = pty_map.lock().await;
431 let mut child = pty_child.lock()
[all...]
/developtools/hdc/hdc_rust/src/common/
H A Dhdcfile.rs77 let mut map = map.lock().await;
83 let map = arc.lock().await;
90 let mut map = arc.lock().await;
96 let map = arc.lock().await;
103 let map = arc.lock().await;
109 let mut task = _iter.1.lock().await;
121 let map = arc.lock().await;
124 let task = _iter.1.lock().await;
143 let mut file_task = task.lock().await;
216 let mut task = task.lock()
[all...]
H A Dforward.rs138 let mut map = instance.lock().await;
147 let map = instance.lock().await;
150 let info = value.lock().await;
163 let map = instance.lock().await;
173 let info = value.lock().await;
186 let mut map = instance.lock().await;
219 let mut wr = arc_wr.lock().await;
231 let mut wr = arc_wr.lock().await;
262 let join_handle = arc_listener.lock().await;
285 let mut map = map.lock()
[all...]
/developtools/hdc/hdc_rust/src/cffi/host/
H A Dhost_usb.cpp386 std::unique_lock<std::mutex> lock(hUSB->lockDeviceHandle); in OpenDeviceMyNeed()
415 std::unique_lock<std::mutex> lock(ep->mutexIo); in OpenDeviceMyNeed()
453 hUSB->lockDeviceHandle.lock(); in OpenDeviceMyNeed()
456 std::unique_lock<std::mutex> lock(ep->mutexIo); in OpenDeviceMyNeed()
464 ep->cv.wait(lock, [ep]() { return ep->isComplete; }); in OpenDeviceMyNeed()
485 hUSB->lockDeviceHandle.lock(); in OpenDeviceMyNeed()
490 std::unique_lock<std::mutex> lock(ep->mutexIo); in OpenDeviceMyNeed()
498 ep->cv.wait(lock, [ep]() { return ep->isComplete; }); in OpenDeviceMyNeed()
576 lockMapDaemon.lock(); in OpenDeviceMyNeed()
609 lockMapDaemon.lock(); in OpenDeviceMyNeed()
[all...]
/developtools/profiler/device/plugins/api/src/
H A Dcommand_poller.cpp51 auto pluginManager = pluginManager_.lock(); // promote to shared_ptr in OnCreateSessionCmd()
82 auto pluginManager = pluginManager_.lock(); // promote to shared_ptr in OnDestroySessionCmd()
102 auto pluginManager = pluginManager_.lock(); // promote to shared_ptr in OnStartSessionCmd()
117 auto pluginManager = pluginManager_.lock(); // promote to shared_ptr in OnStopSessionCmd()
131 auto pluginManager = pluginManager_.lock(); // promote to shared_ptr in OnReportBasicDataCmd()
/developtools/profiler/device/plugins/network_profiler/client/src/
H A Dnetwork_profiler.cpp52 std::unique_lock<std::mutex> lock(g_mtx); in GetInstance()
91 std::unique_lock<std::mutex> lock(g_mtx); in CheckNetworkProfilerParam()
159 std::unique_lock<std::mutex> lock(g_cachedMtx); in SendCachedData()
171 std::unique_lock<std::mutex> lock(g_cachedMtx); in NetworkProfiling()
198 auto holder = weakClient.lock(); in NetworkProfilerSendData()
/developtools/hdc/hdc_rust/src/host/
H A Dhost_app.rs66 let mut map = arc_map.lock().await;
75 let map = arc_map.lock().await;
81 let mut map = arc_map.lock().await;
87 let map = arc_map.lock().await;
109 let mut task = arc_task.lock().await;
184 let task = arc_task.lock().await;
199 let mut task = arc_task.lock().await;
261 let mut task = arc_task.lock().await;
370 let task = arc_task.lock().await;
/developtools/profiler/device/services/profiler_service/test/unittest/
H A Dplugin_service_stubs.cpp29 auto stub = instance.lock(); in GetInstance()
223 std::unique_lock<std::mutex> lock(mutex_); in GetPluginContext()
234 std::unique_lock<std::mutex> lock(mutex_); in GetPluginContextById()
262 std::unique_lock<std::mutex> lock(mutex_); in AddPluginInfo()
266 std::unique_lock<std::mutex> lock(mutex_); in AddPluginInfo()
311 std::unique_lock<std::mutex> lock(mutex_); in RemovePluginInfo()
/developtools/profiler/device/plugins/diskio_plugin/include/
H A Dio_stats.h155 std::unique_lock<std::mutex> lock(mutex_); in PutCpuStatsData()
168 lock.unlock(); in PutCpuStatsData()
189 std::unique_lock<std::mutex> lock(mutex_); in PutIoStatsData()
202 lock.unlock(); in PutIoStatsData()
/developtools/profiler/host/smartperf/client/client_command/
H A Dheartbeat.cpp68 std::unique_lock<std::mutex> lock(mtx); in UpdatestartTime()
71 lock.unlock(); in UpdatestartTime()

Completed in 14 milliseconds

1234