| /test/xts/acts/commonlibrary/thirdparty/musl/entry/src/main/cpp/ |
| D | threadsndk1.cpp | 32 mtx_t mutex; member
40 mtx_lock(&gCallOnce.mutex); in DoOnce()
42 mtx_unlock(&gCallOnce.mutex); in DoOnce()
50 mtx_init(&gCallOnce.mutex, mtx_plain); in CallOnce()
66 mtx_destroy(&gCallOnce.mutex); in CallOnce()
72 mtx_t mutex; member
79 mtx_lock(&pparam->mutex); in CndBroadcastThread()
81 cnd_wait(&pparam->cond, &pparam->mutex); in CndBroadcastThread()
83 mtx_unlock(&pparam->mutex); in CndBroadcastThread()
94 mtx_init(¶m.mutex, mtx_plain); in Cnd_broadcast()
[all …]
|
| D | fnmatchndk1.cpp | 38 mtx_t mutex; member
46 mtx_lock(&(pparam->mutex)); in CndTimedWaitTime64Thread()
51 mtx_unlock(&(pparam->mutex)); in CndTimedWaitTime64Thread()
65 mtx_init(&(param.mutex), mtx_plain); in Cnd_timedWait_time64_One()
66 mtx_lock(&(param.mutex)); in Cnd_timedWait_time64_One()
72 ret = __cnd_timedwait_time64(&(param.cnd), &(param.mutex), &ts); in Cnd_timedWait_time64_One()
75 mtx_unlock(&(param.mutex)); in Cnd_timedWait_time64_One()
76 mtx_destroy(&(param.mutex)); in Cnd_timedWait_time64_One()
92 mtx_init(&(param.mutex), mtx_plain); in Cnd_timedWait_time64_Two()
93 mtx_lock(&(param.mutex)); in Cnd_timedWait_time64_Two()
[all …]
|
| D | pthreadndk1.cpp | 38 pthread_mutex_t mutex; member
46 pthread_mutex_lock(&gPthreadAtForkParam.mutex); in PthreadAtForkPrepare()
51 pthread_mutex_unlock(&gPthreadAtForkParam.mutex); in PthreadAtForkParent()
56 pthread_mutex_unlock(&gPthreadAtForkParam.mutex); in PthreadAtForkChild()
61 pthread_mutex_lock(&gPthreadAtForkParam.mutex); in PthreadAtForkThread()
63 pthread_mutex_unlock(&gPthreadAtForkParam.mutex); in PthreadAtForkThread()
69 gPthreadAtForkParam.mutex = PTHREAD_MUTEX_INITIALIZER; in PThreadAtFork()
78 pthread_mutex_lock(&gPthreadAtForkParam.mutex); in PThreadAtFork()
80 pthread_mutex_unlock(&gPthreadAtForkParam.mutex); in PThreadAtFork()
587 pthread_mutex_t mutex; member
[all …]
|
| D | threadsndk.cpp | 319 mtx_t mutex; in Cnd_wait() local
322 mtx_lock(&mutex); in Cnd_wait()
323 int backParam = cnd_wait(&cond, &mutex); in Cnd_wait()
324 mtx_unlock(&mutex); in Cnd_wait()
326 mtx_destroy(&mutex); in Cnd_wait()
350 mtx_t mutex; in Cndtimewaittest() local
353 mtx_lock(&mutex); in Cndtimewaittest()
354 int backParam = cnd_timedwait(&cond, &mutex, &time_point); in Cndtimewaittest()
355 mtx_unlock(&mutex); in Cndtimewaittest()
357 mtx_destroy(&mutex); in Cndtimewaittest()
|
| /test/testfwk/arkxtest/uitest/record/ |
| D | ui_record.h | 88 mutable shared_ptr<mutex> cout_lock = make_shared<std::mutex>();
89 mutable shared_ptr<mutex> csv_lock = make_shared<std::mutex>();
90 mutable std::mutex g_clickMut;
93 mutable std::mutex widgetsMut;
96 std::mutex timerMut;
138 std::lock_guard<std::mutex> lock(mut); in ProcessData()
144 std::mutex mut;
|
| D | keyevent_tracker.cpp | 74 std::string KeyeventTracker::WriteCombinationData(shared_ptr<mutex> &cout_lock) in WriteCombinationData()
82 std::lock_guard<mutex> guard(*cout_lock); in WriteCombinationData()
90 std::string KeyeventTracker::WriteSingleData(KeyEventInfo &info, shared_ptr<mutex> &cout_lock) in WriteSingleData()
94 std::lock_guard<mutex> guard(*cout_lock); in WriteSingleData()
104 …nlohmann::json KeyeventTracker::WriteCombinationData(ofstream& outFile, shared_ptr<mutex> &csv_loc… in WriteCombinationData()
120 std::lock_guard<mutex> guard(*csv_lock); in WriteCombinationData()
127 …eyeventTracker::WriteSingleData(KeyEventInfo &info, ofstream &outFile, shared_ptr<mutex> &csv_lock) in WriteSingleData()
138 std::lock_guard<mutex> guard(*csv_lock); in WriteSingleData()
|
| D | keyevent_tracker.h | 111 std::string WriteCombinationData(shared_ptr<mutex> &cout_lock);
112 std::string WriteSingleData(KeyEventInfo &info, shared_ptr<mutex> &cout_lock);
114 nlohmann::json WriteCombinationData(ofstream &outFile, shared_ptr<mutex> &csv_lock);
115 …nlohmann::json WriteSingleData(KeyEventInfo &info, ofstream &outFile, shared_ptr<mutex> &csv_lock);
|
| /test/xts/acts/multimedia/media/media_cpp_standard/audioDecEncNdk/src/ |
| D | ADecEncNdkSample.cpp | 44 unique_lock<mutex> lock(acodecSignal_->inMutexDec_); in AdecAsyncNeedInputData()
57 unique_lock<mutex> lock(acodecSignal_->inMutexEnc_); in AdecAsyncNewOutputData()
84 unique_lock<mutex> lock(acodecSignal_->inMutexEnc_); in AencAsyncNeedInputData()
97 unique_lock<mutex> lock(acodecSignal_->outMutexEnc_); in AencAsyncNewOutputData()
206 unique_lock<mutex> lock(acodecSignal_->inMutexDec_); in ResetDecParam()
211 unique_lock<mutex> lock2(acodecSignal_->inMutexEnc_); in ResetDecParam()
229 unique_lock<mutex> lock(acodecSignal_->inMutexEnc_); in ResetEncParam()
234 unique_lock<mutex> lock2(acodecSignal_->outMutexEnc_); in ResetEncParam()
248 unique_lock<mutex> lock(acodecSignal_->inMutexDec_); in StopDec()
249 unique_lock<mutex> lock2(acodecSignal_->inMutexEnc_); in StopDec()
[all …]
|
| /test/xts/acts/multimedia/media/media_cpp_standard/videoDecEncNdk/src/ |
| D | VDecEncNdkSample.cpp | 55 unique_lock<mutex> lock(vcodecSignal_->inMutexDec_); in VdecAsyncNeedInputData()
69 unique_lock<mutex> lock(vcodecSignal_->outMutexDec_); in VdecAsyncNewOutputData()
96 unique_lock<mutex> lock(vcodecSignal_->outMutexEnc_); in VencAsyncNewOutputData()
171 unique_lock<mutex> lockIn(vcodecSignal_->inMutexDec_); in ResetDecParam()
175 unique_lock<mutex> lockOut(vcodecSignal_->outMutexDec_); in ResetDecParam()
188 unique_lock<mutex> lockOut(vcodecSignal_->outMutexEnc_); in ResetEncParam()
272 unique_lock<mutex> lock(vcodecSignal_->inMutexDec_); in StopDec()
273 unique_lock<mutex> lock2(vcodecSignal_->outMutexDec_); in StopDec()
278 unique_lock<mutex> lockIn(vcodecSignal_->inMutexDec_); in StopDec()
283 unique_lock<mutex> lockOut(vcodecSignal_->outMutexDec_); in StopDec()
[all …]
|
| /test/xts/device_attest/interfaces/innerkits/native_cpp/src/ |
| D | devattest_client.cpp | 39 std::lock_guard<std::mutex> lock(clientLock_); in GetDeviceProfileService()
57 std::lock_guard<std::mutex> lock(clientLock_); in GetDeviceProfileService()
71 std::unique_lock<std::mutex> lock(clientLock_); in LoadDevAttestProfile()
100 std::lock_guard<std::mutex> lock(clientLock_); in LoadSystemAbilitySuccess()
111 std::lock_guard<std::mutex> lock(clientLock_); in LoadSystemAbilityFail()
|
| /test/xts/acts/distributed_schedule_lite/system_ability_manager_hal/utils/ |
| D | samgr_maintenance.c | 30 MUTEX_Lock(samgr->mutex); in SAMGR_PrintServices()
39 MUTEX_Unlock(samgr->mutex); in SAMGR_PrintServices()
60 MUTEX_Lock(samgr->mutex); in SAMGR_PrintServices()
62 MUTEX_Unlock(samgr->mutex); in SAMGR_PrintServices()
|
| /test/xts/dcts/distributedhardware/distributedscreentest/ |
| D | decoder_demo.cpp | 140 unique_lock<mutex> inLock(signal_->inMutex_); in Stop()
150 unique_lock<mutex> outLock(signal_->outMutex_); in Stop()
235 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
294 unique_lock<mutex> lock(signal_->outMutex_); in OutputFunc()
324 unique_lock<mutex> lock(signal_->inMutex_); in OnInputBufferAvailable()
332 unique_lock<mutex> lock(signal_->outMutex_); in OnOutputBufferAvailable()
|
| D | decoder_demo.h | 33 std::mutex inMutex_;
34 std::mutex outMutex_;
|
| /test/ostest/wukong/common/include/ |
| D | wukong_logger.h | 99 std::mutex mtxQueue_;
105 std::mutex mtxThreadWait_;
|
| /test/xts/acts/multimedia/media/media_cpp_standard/videoDecEncNdk/include/ |
| D | VDecEncNdkSample.h | 41 std::mutex inMutexDec_;
42 std::mutex outMutexDec_;
51 std::mutex outMutexEnc_;
|
| /test/xts/acts/multimedia/media/media_cpp_standard/audioDecEncNdk/include/ |
| D | ADecEncNdkSample.h | 39 std::mutex inMutexDec_;
48 std::mutex inMutexEnc_;
49 std::mutex outMutexEnc_;
|
| /test/xts/hats/hdf/display/composer/benchmark/ |
| D | display_benchmark_ut_test.cpp | 55 std::mutex vblankMutex_;
88 std::unique_lock<std::mutex> lg(vblankMutex_); in NotifyVblank()
100 std::unique_lock<std::mutex> lck(vblankMutex_); in WaitVblank()
|
| /test/xts/acts/bundlemanager/zlib/actszlibtest/ |
| D | ActsZlibTest.cpp | 43 std::mutex gzMutex_;
44 std::mutex puMutex_;
45 std::mutex file_mutex;
49 std::lock_guard<std::mutex> lock(puMutex_); in pull()
62 std::lock_guard<std::mutex> lock(puMutex_); in push()
69 std::lock_guard<std::mutex> lock(gzMutex_); in TestGzPrintf()
159 std::lock_guard<std::mutex> lock(file_mutex);
793 std::lock_guard<std::mutex> lock(file_mutex);
855 std::lock_guard<std::mutex> lock(file_mutex);
883 std::lock_guard<std::mutex> lock(file_mutex);
[all …]
|
| /test/xts/hats/hdf/camera/cameraHdi/buffer_manager/ |
| D | buffer_manager_utest.h | 68 std::mutex lock_;
171 std::mutex streamLock_;
177 std::mutex deviceLock;
|
| /test/ostest/wukong/common/src/ |
| D | wukong_logger.cpp | 45 std::mutex LOCK_PRINT_BUFFER;
86 std::unique_lock<std::mutex> lk(mtxThreadWait_); in Start()
163 std::unique_lock<std::mutex> lk(self->mtxThreadWait_); in Run()
|
| /test/xts/acts/kernel_lite/futex_posix/src/ |
| D | PthreadMutexTest.cpp | 122 pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; member
128 EXPECT_EQ(pthread_mutex_lock(&g_st1.mutex), 0) << "> return errno"; in PthreadProduce()
131 EXPECT_EQ(pthread_cond_wait(&g_st1.notempty, &g_st1.mutex), 0); in PthreadProduce()
139 EXPECT_EQ(pthread_mutex_unlock(&g_st1.mutex), 0) << "> return errno"; in PthreadProduce()
148 EXPECT_EQ(pthread_mutex_lock(&g_st1.mutex), 0) << "> return errno"; in PthreadConsume()
151 EXPECT_EQ(pthread_cond_wait(&g_st1.notempty, &g_st1.mutex), 0); in PthreadConsume()
159 EXPECT_EQ(pthread_mutex_unlock(&g_st1.mutex), 0) << "> return errno"; in PthreadConsume()
|
| /test/testfwk/arkxtest/uitest/connection/ |
| D | ipc_transactor.cpp | 199 mutex mtx; in PublishCallerAndWaitForBackcaller()
200 unique_lock<mutex> lock(mtx); in PublishCallerAndWaitForBackcaller()
225 mutex mtx; in WaitForPublishedCaller()
226 unique_lock<mutex> lock(mtx); in WaitForPublishedCaller()
381 mutex mtx; in SendBroadcastCommand()
382 unique_lock<mutex> lock(mtx); in SendBroadcastCommand()
|
| /test/testfwk/arkxtest/uitest/addon/ |
| D | extension_executor.cpp | 86 static mutex g_callThroughLock;
87 static mutex g_captureLock;
88 static mutex g_recordRunningLock;
160 unique_lock<mutex> guard(g_callThroughLock, std::adopt_lock); in CallThroughMessage()
224 unique_lock<mutex> guard(g_captureLock); in StopCapture()
250 unique_lock<mutex> guard(g_captureLock); in StartCapture()
|
| /test/testfwk/arkxtest/uitest/server/ |
| D | system_ui_controller.cpp | 311 std::lock_guard<std::mutex> dumpLocker(dumpMtx); // disallow concurrent dumpUi in GetUiWindows()
352 std::lock_guard<std::mutex> dumpLocker(dumpMtx); // disallow concurrent dumpUi in GetWidgetsInWindow()
619 mutex mtx; in ConnectToSysAbility()
620 unique_lock<mutex> uLock(mtx); in ConnectToSysAbility()
682 mutex mtx; in DisConnectFromSysAbility()
683 unique_lock<mutex> uLock(mtx); in DisConnectFromSysAbility()
796 explicit OnSaLoadCallback(mutex &mutex): mutex_(mutex) {}; in OnSaLoadCallback() argument
818 mutex &mutex_;
832 mutex lock; in GetHidumperInfo()
|
| /test/xts/device_attest/interfaces/innerkits/native_cpp/include/ |
| D | devattest_client.h | 44 std::mutex clientLock_;
|