| /ohos5.0/base/notification/common_event_service/tools/test/systemtest/cem/ |
| H A D | common_event_command_publish_system_test.cpp | 41 std::mutex mtx; variable
129 mtx.unlock(); in OnReceiveEvent()
140 mtx.unlock(); in OnReceiveEvent()
167 mtx.lock();
199 mtx.unlock();
227 mtx.lock();
259 mtx.unlock();
287 mtx.lock();
319 mtx.unlock();
347 mtx.lock();
[all …]
|
| /ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_csync.cpp | 104 ffrt::mutex mtx; member
293 ffrt::mutex mtx; variable
308 std::unique_lock lk(mtx);
563 ffrt::mutex mtx; variable
566 NotifyOneTest(mtx, cv);
568 WaitUtilFlagTest_1(mtx, cv);
569 WaitUtilFlagTest_2(mtx, cv);
570 WaitForTest_1(mtx, cv);
571 WaitForTest_2(mtx, cv);
572 WaitForTest_3(mtx, cv);
[all …]
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr_client/source/ |
| H A D | remote_register.c | 45 MUTEX_Lock(g_remoteRegister.mtx); in SAMGR_RegisterServiceApi()
48 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_RegisterServiceApi()
71 MUTEX_Lock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
74 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
79 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
112 SAMGR_Free(g_remoteRegister.mtx); in ClearRegistry()
113 g_remoteRegister.mtx = NULL; in ClearRegistry()
133 g_remoteRegister.mtx = MUTEX_InitValue(); in InitializeRegistry()
|
| H A D | remote_register_rpc.c | 51 MUTEX_Lock(g_remoteRegister.mtx); in SAMGR_RegisterServiceApi()
63 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_RegisterServiceApi()
88 MUTEX_Lock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
91 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
96 MUTEX_Unlock(g_remoteRegister.mtx); in SAMGR_FindServiceApi()
129 SAMGR_Free(g_remoteRegister.mtx); in ClearRegistry()
130 g_remoteRegister.mtx = NULL; in ClearRegistry()
152 g_remoteRegister.mtx = MUTEX_InitValue(); in ClientInitializeRegistry()
|
| /ohos5.0/base/notification/common_event_service/services/test/unittest/ |
| H A D | common_event_publish_ordered_event_unit_test.cpp | 41 std::mutex mtx; variable
152 mtx.lock();
173 mtx.unlock();
251 mtx.lock();
266 mtx.unlock();
299 mtx.lock();
312 mtx.unlock();
591 mtx.lock();
648 mtx.lock();
705 mtx.lock();
[all …]
|
| H A D | common_event_freeze_test.cpp | 55 std::mutex mtx; variable
384 mtx.unlock(); in AsyncProcess()
416 mtx.lock();
424 while (!mtx.try_lock()) {
446 mtx.unlock();
478 mtx.lock();
486 while (!mtx.try_lock()) {
506 mtx.unlock();
|
| /ohos5.0/base/security/asset/services/db_operator/src/ |
| H A D | database.rs | 52 pub(crate) mtx: Mutex<i32>,
153 let _lock = db.db_lock.mtx.lock().unwrap(); in get_db()
279 let _lock = self.db_lock.mtx.lock().unwrap(); in close_db()
315 let _lock = self.db_lock.mtx.lock().unwrap(); in get_version()
522 let _lock = self.db_lock.mtx.lock().unwrap(); in delete_datas()
531 let _lock = self.db_lock.mtx.lock().unwrap(); in delete_specific_condition_datas()
557 let _lock = self.db_lock.mtx.lock().unwrap(); in update_datas()
580 let _lock = self.db_lock.mtx.lock().unwrap(); in is_data_exists()
610 let _lock = self.db_lock.mtx.lock().unwrap(); in query_datas()
645 let _lock = self.db_lock.mtx.lock().unwrap(); in query_data_count()
[all …]
|
| /ohos5.0/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/common/ |
| H A D | fixed_size_list.h | 35 std::lock_guard<std::mutex> lock(mtx); in add()
45 std::lock_guard<std::mutex> lock(mtx); in find_if()
58 std::lock_guard<std::mutex> lock(mtx); in clear()
81 mutable std::mutex mtx; // mutable to allow const methods to lock the mutex variable
|
| /ohos5.0/foundation/arkui/napi/interfaces/inner_api/cjffi/native/ |
| H A D | ffi_remote_data.h | 44 std::lock_guard<std::mutex> lock(mtx); in GetFFIData()
50 std::lock_guard<std::mutex> lock(mtx); in GetRemoteData()
58 std::lock_guard<std::mutex> lock(mtx); in RemoveFFIData()
63 std::lock_guard<std::mutex> lock(mtx); in RemoveRemoteData()
76 std::mutex mtx; variable
|
| H A D | ffi_remote_data.cpp | 42 std::lock_guard<std::mutex> lock(mtx); in StoreFFIData()
55 std::lock_guard<std::mutex> lock(mtx); in StoreRemoteData()
61 std::lock_guard<std::mutex> lock(mtx); in NewFFIDataId()
|
| /ohos5.0/drivers/liteos/hievent/src/ |
| H A D | hievent_driver.c | 71 LosMux mtx; member
169 (VOID)LOS_MuxAcquire(&g_hieventDev.mtx); in HieventRead()
210 (VOID)LOS_MuxRelease(&g_hieventDev.mtx); in HieventRead()
278 (VOID)LOS_MuxAcquire(&g_hieventDev.mtx); in HieventWriteInternal()
316 (VOID)LOS_MuxRelease(&g_hieventDev.mtx); in HieventWriteInternal()
368 (void)LOS_MuxInit(&g_hieventDev.mtx, NULL); in HieventDeviceInit()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/render_context/ |
| H A D | shader_cache.h | 32 explicit OptionalLockGuard(std::mutex& m): mtx(m), status(m.try_lock()) {} in OptionalLockGuard()
37 mtx.unlock(); in ~OptionalLockGuard()
44 std::mutex& mtx; member
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr_server/source/ |
| H A D | samgr_server.c | 130 MUTEX_Lock(server->mtx); in MessageHandle()
168 MUTEX_Lock(server->mtx); in ProcEndpoint()
192 MUTEX_Unlock(server->mtx); in ProcEndpoint()
209 MUTEX_Lock(server->mtx); in ProcPutFeature()
213 MUTEX_Unlock(server->mtx); in ProcPutFeature()
220 MUTEX_Unlock(server->mtx); in ProcPutFeature()
232 MUTEX_Unlock(server->mtx); in ProcPutFeature()
241 MUTEX_Unlock(server->mtx); in ProcPutFeature()
303 MUTEX_Lock(server->mtx); in ProcGetFeature()
306 MUTEX_Unlock(server->mtx); in ProcGetFeature()
[all …]
|
| H A D | samgr_server_rpc.c | 225 MUTEX_Lock(server->mtx); in MessageHandle()
269 MUTEX_Lock(server->mtx); in ProcEndpoint()
294 MUTEX_Unlock(server->mtx); in ProcEndpoint()
316 MUTEX_Lock(server->mtx); in ProcPutFeature()
320 MUTEX_Unlock(server->mtx); in ProcPutFeature()
327 MUTEX_Unlock(server->mtx); in ProcPutFeature()
343 MUTEX_Unlock(server->mtx); in ProcPutFeature()
351 MUTEX_Unlock(server->mtx); in ProcPutFeature()
418 MUTEX_Lock(server->mtx); in ProcGetFeature()
421 MUTEX_Unlock(server->mtx); in ProcGetFeature()
[all …]
|
| /ohos5.0/foundation/ai/intelligent_voice_framework/tests/unittest/intell_voice_test/src/ |
| H A D | wait_for_result.cpp | 24 std::unique_lock<std::mutex> lock(mtx); in Wait()
31 std::lock_guard<std::mutex> lock(mtx); in SetIsReady()
|
| /ohos5.0/base/theme/wallpaper_mgr/frameworks/kits/extension/src/ |
| H A D | js_wallpaper_extension_ability.cpp | 39 std::mutex JsWallpaperExtensionAbility::mtx; member in OHOS::AbilityRuntime::JsWallpaperExtensionAbility
45 std::lock_guard<std::mutex> lock(mtx); in Create()
56 std::lock_guard<std::mutex> lock(mtx); in ~JsWallpaperExtensionAbility()
242 std::lock_guard<std::mutex> lock(mtx); in RegisterWallpaperCallback()
267 std::lock_guard<std::mutex> lock(mtx); in RegisterWallpaperCallback()
|
| /ohos5.0/base/print/print_fwk/frameworks/kits/extension/src/ |
| H A D | js_print_extension.cpp | 39 std::mutex JsPrintExtension::mtx; member in OHOS::AbilityRuntime::JsPrintExtension
54 std::lock_guard<std::mutex> lock(mtx); in ~JsPrintExtension()
331 std::lock_guard<std::mutex> lock(mtx); in Callback()
354 std::lock_guard<std::mutex> lock(mtx); in Callback()
375 std::lock_guard<std::mutex> lock(mtx); in Callback()
400 std::lock_guard<std::mutex> lock(mtx); in Callback()
421 std::lock_guard<std::mutex> lock(mtx); in Callback()
446 std::lock_guard<std::mutex> lock(mtx); in Callback()
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/src/ |
| H A D | network_latency_controller.cpp | 73 std::unique_lock<std::mutex> lk(mtx); in Init()
147 std::unique_lock<std::mutex> lk(mtx); in AddRequest()
160 std::unique_lock<std::mutex> lk(mtx); in DelRequest()
|
| /ohos5.0/base/hiviewdfx/hilog/frameworks/libhilog/param/ |
| H A D | properties.cpp | 338 static shared_timed_mutex* mtx = new shared_timed_mutex; in GetDomainLevel() local
341 ReadLock lock(*mtx); in GetDomainLevel()
348 InsertLock lock(*mtx); in GetDomainLevel()
367 static shared_timed_mutex* mtx = new shared_timed_mutex; in GetTagLevel() local
370 ReadLock lock(*mtx); in GetTagLevel()
377 InsertLock lock(*mtx); in GetTagLevel()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/unwinder/include/ |
| H A D | thread_context.h | 39 std::mutex mtx; member
58 std::unique_lock<std::mutex> lock(mtx); in ~ThreadContext()
|
| /ohos5.0/foundation/resourceschedule/ffrt/docs/ |
| H A D | user_guide.md | 1050 ffrt::mutex mtx;
1053 mtx.lock();
1055 mtx.unlock();
1123 ffrt::shared_mutex mtx;
1126 mtx.lock();
1128 mtx.unlock();
2509 ffrt_mutex_t* mtx;
2574 ffrt_mutex_t mtx;
2593 ffrt_mutex_t mtx;
2694 ffrt_rwlock_t* mtx;
[all …]
|
| /ohos5.0/foundation/arkui/ace_engine/interfaces/inner_api/form_render/src/ |
| H A D | form_renderer_dispatcher_impl.cpp | 62 std::mutex mtx; in DispatchPointerEvent() member
68 std::unique_lock<std::mutex> lock(serializedResultData->mtx); in DispatchPointerEvent()
72 std::unique_lock<std::mutex> lock(serializedResultData->mtx); in DispatchPointerEvent()
|
| /ohos5.0/foundation/systemabilitymgr/samgr/services/samgr/native/source/ |
| H A D | samgr_time_handler.cpp | 29 static mutex mtx; variable
34 lock_guard<mutex> autoLock(mtx); in GetInstance()
|
| /ohos5.0/foundation/graphic/graphic_utils_lite/frameworks/diagram/vertexprimitive/ |
| H A D | geometry_bezier_arc.cpp | 207 TransAffine mtx = TransAffine::TransAffineRotation(angle); in Init() local
208 mtx *= TransAffine::TransAffineTranslation(cx, cy); in Init()
211 mtx.Transform(bezierArcModel_.GetVertices() + i, bezierArcModel_.GetVertices() + i + 1); in Init()
|
| /ohos5.0/base/notification/common_event_service/frameworks/native/test/unittest/ |
| H A D | common_event_subscribe_test.cpp | 45 std::mutex mtx; variable
76 mtx.unlock(); in OnReceiveEvent()
174 mtx.lock();
189 while (!mtx.try_lock()) {
200 mtx.unlock();
|