| /developtools/profiler/device/services/profiler_service/src/ |
| D | profiler_data_repeater.cpp | 30 std::unique_lock<std::mutex> lock(mutex_); in Size() local
36 std::unique_lock<std::mutex> lock(mutex_); in Reset() local
43 std::unique_lock<std::mutex> lock(mutex_); in Close() local
53 std::unique_lock<std::mutex> lock(mutex_); in PutPluginData() local
62 slotCondVar_.wait(lock); in PutPluginData()
69 lock.unlock(); in PutPluginData()
77 std::unique_lock<std::mutex> lock(mutex_); in TakePluginData() local
79 itemCondVar_.wait(lock); in TakePluginData()
87 lock.unlock(); in TakePluginData()
95 std::unique_lock<std::mutex> lock(mutex_); in TakePluginData() local
[all …]
|
| /developtools/profiler/device/services/plugin_service/src/ |
| D | plugin_session.cpp | 55 std::unique_lock<std::mutex> lock(mutex_); in Create() local
59 auto pluginService = pluginService_.lock(); // promote to shared_ptr in Create()
80 std::unique_lock<std::mutex> lock(mutex_); in Destroy() local
85 auto pluginService = pluginService_.lock(); in Destroy()
104 std::unique_lock<std::mutex> lock(mutex_); in IsAvailable() local
110 std::unique_lock<std::mutex> lock(mutex_); in GetState() local
116 std::unique_lock<std::mutex> lock(mutex_); in Invalidate() local
122 std::unique_lock<std::mutex> lock(mutex_); in Start() local
126 auto pluginService = pluginService_.lock(); in Start()
139 std::unique_lock<std::mutex> lock(mutex_); in Refresh() local
[all …]
|
| D | plugin_session_manager.cpp | 39 auto pluginSvc = pluginService_.lock(); in CheckPluginSha256()
97 std::unique_lock<std::mutex> lock(mutex_); in CreatePluginSessions() local
117 std::unique_lock<std::mutex> lock(mutex_); in CreatePluginSessions() local
127 std::unique_lock<std::mutex> lock(mutex_); in RemovePluginSessions() local
141 std::unique_lock<std::mutex> lock(mutex_); in InvalidatePluginSessions() local
158 std::unique_lock<std::mutex> lock(mutex_); in StartPluginSessions() local
176 std::unique_lock<std::mutex> lock(mutex_); in StopPluginSessions() local
193 std::unique_lock<std::mutex> lock(mutex_); in RefreshPluginSession() local
209 std::unique_lock<std::mutex> lock(mutex_); in CheckStatus() local
227 std::unique_lock<std::mutex> lock(mutex_); in GetStatus() local
|
| /developtools/profiler/device/base/src/ |
| D | std_semaphore.cpp | 23 std::unique_lock<std::mutex> lock(mutex_); in Wait() local
25 condVar_.wait(lock); in Wait()
33 std::unique_lock<std::mutex> lock(mutex_); in TryWait() local
48 std::unique_lock<std::mutex> lock(mutex_); in TimedWait() local
53 condVar_.wait_until(lock, timePoint); in TimedWait()
61 std::unique_lock<std::mutex> lock(mutex_); in Post() local
|
| D | epoll_event_poller.cpp | 53 std::unique_lock<std::mutex> lock(mutex_); in AddFileDescriptor() local
60 std::unique_lock<std::mutex> lock(mutex_); in RemoveFileDescriptor() local
122 std::unique_lock<std::mutex> lock(mutex_); in Run() local
186 std::unique_lock<std::mutex> lock(mutex_); in Init() local
205 std::unique_lock<std::mutex> lock(mutex_); in Finalize() local
233 std::unique_lock<std::mutex> lock(mutex_); in Start() local
|
| /developtools/profiler/device/plugins/native_daemon/src/ |
| D | stack_data_repeater.cpp | 34 std::unique_lock<std::mutex> lock(mutex_); in Size() local
40 std::unique_lock<std::mutex> lock(mutex_); in Reset() local
47 std::unique_lock<std::mutex> lock(mutex_); in Close() local
59 std::unique_lock<std::mutex> lock(mutex_); in PutRawStack() local
67 slotCondVar_.wait(lock); in PutRawStack()
93 lock.unlock(); in PutRawStack()
102 std::unique_lock<std::mutex> lock(mutex_); in TakeRawData() local
104 itemCondVar_.wait(lock); in TakeRawData()
126 lock.unlock(); in TakeRawData()
|
| /developtools/profiler/device/plugins/xpower_plugin/src/ |
| D | power_message_queue.cpp | 37 std::unique_lock<std::mutex> lock(mutex_); in ShutDown() local
47 std::unique_lock<std::mutex> lock(mutex_); in WaitAndPop() local
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() local
70 if (emptyCon_.wait_for(lock, realTime, [&] { return !dataQueue_.empty(); })) { in WaitAndPopBatch()
81 lock.unlock(); in WaitAndPopBatch()
|
| /developtools/profiler/tools/smaps_show/ |
| D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /developtools/hdc/src/common/ |
| D | circle_buffer.cpp | 48 std::unique_lock<std::mutex> lock(mutex_); in Malloc() local
80 std::unique_lock<std::mutex> lock(mutex_); in Free() local
89 std::unique_lock<std::mutex> lock(mutex_); in FreeMemory() local
148 std::unique_lock<std::mutex> lock(timerMutex_); in TimerSleep() local
149 timerCv_.wait_for(lock, std::chrono::seconds(1)); in TimerSleep()
154 std::unique_lock<std::mutex> lock(timerMutex_); in TimerNotify() local
|
| D | file_descriptor.cpp | 276 std::unique_lock<std::mutex> lock(writeMutex); in PushWrite() local
282 std::unique_lock<std::mutex> lock(writeMutex); in PopWrite() local
293 std::unique_lock<std::mutex> lock(writeMutex); in NotifyWrite() local
299 std::unique_lock<std::mutex> lock(writeMutex); in WaitWrite() local
300 writeCond.wait(lock, [&]() { return !writeQueue.empty() || !workContinue; }); in WaitWrite()
314 std::unique_lock<std::mutex> lock(writeMutex); in CtxFileIOWrite() local
|
| D | uart.h | 244 std::unique_lock<std::mutex> lock(mutex); in Request()
251 std::unique_lock<std::mutex> lock(mutex); in Sent()
327 std::unique_lock<std::mutex> lock(mutex); in Wait()
328 cv.wait(lock, [=] { return hasWaitPkg.find(sessionId) == hasWaitPkg.end(); }); in Wait()
334 std::unique_lock<std::mutex> lock(mutex); in Free()
342 std::unique_lock<std::mutex> lock(mutex); in WaitFree()
343 cv.wait_for(lock, std::chrono::milliseconds(WAIT_RESPONSE_TIME_OUT_MS), in WaitFree()
|
| /developtools/profiler/device/plugins/ftrace_plugin/src/ |
| D | ftrace_module.cpp | 33 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginRegisterWriter() local
43 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginStartSession() local
58 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginReportBasicData() local
69 std::unique_lock<std::mutex> lock(g_mutex); in TracePluginStopSession() local
|
| D | result_transporter.cpp | 99 std::unique_lock<std::mutex> lock(mutex_); in Submit() local
103 lock.unlock(); in Submit()
112 lock.unlock(); in Submit()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | uart_wrapper.rs | 178 let mtx = instance.lock().await; in get_package()
181 let vec = vec.lock().await; in get_package()
184 let data_mtx = arc.lock().await; in get_package()
193 let mut mtx = instance.lock().await; in put_package()
196 let mut vec = vec.lock().await; in put_package()
210 let mtx = instance.lock().await; in update_package()
213 let vec = vec.lock().await; in update_package()
216 let mut data_mtx = arc.lock().await; in update_package()
226 let mtx = instance.lock().await; in get_stop_flag()
229 let v = flag.lock().await; in get_stop_flag()
[all …]
|
| D | buffer.rs | 82 let mut wr = arc_wr.lock().await; in put()
96 let mut wr = guard.lock().await; in send_channel_message()
115 let mut wr = arc_wr.lock().await; in end()
144 let mut wr = arc_wr.lock().await; in put()
179 let wr = arc_wr.lock().await; in put()
259 let mut rd = arc_rd.lock().await; in recv()
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | hdcfile.rs | 70 let mut map = map.lock().await; in put()
76 let map = arc.lock().await; in exsit()
83 let mut map = arc.lock().await; in remove()
89 let map = arc.lock().await; in get()
97 let mut file_task = task.lock().await; in check_local_path()
138 let mut task = task.lock().await; in begin_transfer()
160 let mut task = task.lock().await; in set_master_parameters()
243 let task = task.lock().await; in put_file_check()
254 let task = &mut task.lock().await; in check_slaver()
294 let mut task = task.lock().await; in transfer_next()
[all …]
|
| D | jdwp.rs | 76 let map = map.lock().await; in send_fd_to_target()
97 let trackers = trackers.lock().await; in send_process_list()
117 let mut trackers_lock = self.trackers.lock().await; in add_tracker()
128 let map = map.lock().await; in get_process_list()
141 let map = map.lock().await; in get_process_list_with_pkg_name()
180 let mut map = node_map.lock().await; in handle_client()
254 let node_map_value = node_map.lock().await; in start_data_looper()
281 let mut node_map_value = node_map.lock().await; in start_data_looper()
308 let node_map_value = node_map.lock().await; in create_fd_event_poll()
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | daemon_app.rs | 63 let mut map = map.lock().await; in put()
69 let map = arc.lock().await; in exsit()
76 let mut map = arc.lock().await; in remove()
82 let map = arc.lock().await; in get()
90 let mut task = arc.lock().await; in do_app_check()
135 let mut task = arc.lock().await; in put_app_finish()
201 let task = arc.lock().await; in do_app_install()
231 let task = arc.lock().await; in on_transfer_finish()
272 let mut task = arc.lock().await; in command_dispatch()
|
| /developtools/profiler/device/plugins/api/src/ |
| D | command_poller.cpp | 51 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/integration_verification/tools/fotff/rec/ |
| D | fotff_test.go | 37 lock sync.Mutex member
89 f.lock.Lock()
92 f.lock.Unlock()
120 f.lock.Lock()
123 f.lock.Unlock()
|
| /developtools/profiler/device/plugins/ftrace_plugin/test/app/ |
| D | busy_workers.cpp | 51 std::unique_lock<std::mutex> lock(mutex_); in Down() local
53 cv_.wait(lock); in Down()
60 std::unique_lock<std::mutex> lock(mutex_); in Up() local
|
| /developtools/profiler/device/services/profiler_service/test/unittest/ |
| D | plugin_service_stubs.cpp | 29 auto stub = instance.lock(); in GetInstance()
223 std::unique_lock<std::mutex> lock(mutex_); in GetPluginContext() local
234 std::unique_lock<std::mutex> lock(mutex_); in GetPluginContextById() local
262 std::unique_lock<std::mutex> lock(mutex_); in AddPluginInfo() local
266 std::unique_lock<std::mutex> lock(mutex_); in AddPluginInfo() local
311 std::unique_lock<std::mutex> lock(mutex_); in RemovePluginInfo() local
|
| /developtools/profiler/device/plugins/diskio_plugin/include/ |
| D | io_stats.h | 155 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/hiperf/src/ |
| D | subcommand.cpp | 162 std::lock_guard<std::mutex> lock(g_subCommandMutex); in RegisterSubCommand() local
173 std::lock_guard<std::mutex> lock(g_subCommandMutex); in ClearSubCommands() local
185 std::lock_guard<std::mutex> lock(g_subCommandMutex); in FindSubCommand() local
|
| D | debug_logger.cpp | 110 std::lock_guard<std::recursive_mutex> lock(logMutex_); in Log() local
114 std::lock_guard<std::recursive_mutex> lock(logMutex_); in Log() local
172 std::lock_guard<std::recursive_mutex> lock(logMutex_); in SetLogPath() local
250 std::lock_guard<std::recursive_mutex> lock(logMutex_); in OpenLog() local
|