Home
last modified time | relevance | path

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

12

/test/xts/acts/multimedia/media/media_cpp_standard/audioDecEncNdk/src/
H A DADecEncNdkSample.cpp44 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()
210 lock.unlock(); in ResetDecParam()
229 unique_lock<mutex> lock(acodecSignal_->inMutexEnc_); in ResetEncParam()
233 lock.unlock(); in ResetEncParam()
248 unique_lock<mutex> lock(acodecSignal_->inMutexDec_); in StopDec()
251 lock in StopDec()
[all...]
/test/xts/acts/commonlibrary/thirdparty/musl/entry/src/main/cpp/
H A Dpthreadndk1.cpp1164 pthread_rwlock_t lock; in PThreadRwLockDestroy() local
1165 pthread_rwlock_init(&lock, nullptr); in PThreadRwLockDestroy()
1166 int ret = pthread_rwlock_destroy(&lock); in PThreadRwLockDestroy()
1174 pthread_rwlock_t lock; in PThreadRwLockInit() local
1175 int ret = pthread_rwlock_init(&lock, nullptr); in PThreadRwLockInit()
1176 pthread_rwlock_destroy(&lock); in PThreadRwLockInit()
1184 pthread_rwlock_t lock; in PThreadRwLockRdLock() local
1185 pthread_rwlock_init(&lock, nullptr); in PThreadRwLockRdLock()
1186 int ret = pthread_rwlock_rdlock(&lock); in PThreadRwLockRdLock()
1187 pthread_rwlock_unlock(&lock); in PThreadRwLockRdLock()
1196 pthread_rwlock_t lock; PThreadRwLockTimedRdLock() local
1211 pthread_rwlock_t lock; PThreadRwLockTimedWrLock() local
1226 pthread_rwlock_t lock; PThreadRwLockTryRdLock() local
1238 pthread_rwlock_t lock; PThreadRwLockTryWrLock() local
1250 pthread_rwlock_t lock; PThreadRwLockUnLock() local
1262 pthread_rwlock_t lock; PThreadRwLockWrLock() local
1419 pthread_spinlock_t lock; PThreadSpinInit() local
1429 pthread_spinlock_t lock; PThreadSpinDestroy() local
1439 pthread_spinlock_t lock; PThreadSpinLock() local
1451 pthread_spinlock_t lock; PThreadSpinTryLock() local
1463 pthread_spinlock_t lock; PThreadSpinUnLock() local
[all...]
/test/xts/device_attest/interfaces/innerkits/native_cpp/src/
H A Ddevattest_client.cpp38 std::lock_guard<std::mutex> lock(clientLock_); in GetDeviceProfileService()
56 std::lock_guard<std::mutex> lock(clientLock_); in GetDeviceProfileService()
70 std::unique_lock<std::mutex> lock(clientLock_); in LoadDevAttestProfile()
88 proxyConVar_.wait_for(lock, std::chrono::milliseconds(ATTEST_LOADSA_TIMEOUT_MS)); in LoadDevAttestProfile()
94 std::unique_lock<std::mutex> lock(clientLock_); in LoadSystemAbilitySuccess()
96 lock.unlock(); in LoadSystemAbilitySuccess()
103 std::unique_lock<std::mutex> lock(clientLock_); in LoadSystemAbilityFail()
105 lock.unlock(); in LoadSystemAbilityFail()
/test/xts/acts/multimedia/media/media_cpp_standard/videoDecEncNdk/src/
H A DVDecEncNdkSample.cpp55 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()
272 unique_lock<mutex> lock(vcodecSignal_->inMutexDec_); in StopDec()
275 lock.unlock(); in StopDec()
297 unique_lock<mutex> lock(vcodecSignal_->inMutexDec_); in FlushDec()
300 lock.unlock(); in FlushDec()
322 unique_lock<mutex> lock(vcodecSignal_->inMutexDec_); in ResetDec()
325 lock.unlock(); in ResetDec()
349 unique_lock<mutex> lock(vcodecSignal in ReleaseDec()
[all...]
/test/xts/hats/kernel/syscalls/fileio/fcntl/
H A DFcntlApiTest.cpp91 * @tc.desc : fcntl set file lock success and return unlock by get lock check.
103 struct flock lock = { in HWTEST_F() local
110 ret = fcntl(fd, F_SETLK, &lock); in HWTEST_F()
116 EXPECT_EQ(lockCheck.l_whence, lock.l_whence); in HWTEST_F()
117 EXPECT_EQ(lockCheck.l_start, lock.l_start); in HWTEST_F()
118 EXPECT_EQ(lockCheck.l_len, lock.l_len); in HWTEST_F()
145 * @tc.desc : fcntl set invalid nullptr lock fail, errno EFAULT.
193 * @tc.desc : fcntl set lock success.
204 struct flock lock in HWTEST_F() local
232 struct flock lock = { HWTEST_F() local
[all...]
/test/xts/acts/multimedia/av_codec/vcodec/swdecoder/src/
H A Dvideodec_ndk_sample.cpp122 unique_lock<mutex> lock(signal->inMutex_); in VdecInputDataReady()
135 unique_lock<mutex> lock(signal->outMutex_); in VdecOutputDataReady()
287 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
290 lock.unlock(); in StopInloop()
402 unique_lock<mutex> lock(signal_->outMutex_); in OutputFunc()
403 signal_->outCond_.wait(lock, [this]() { in OutputFunc()
419 lock.unlock(); in OutputFunc()
568 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc_AVCC()
569 signal_->inCond_.wait(lock, [this]() { in InputFunc_AVCC()
583 lock in InputFunc_AVCC()
[all...]
/test/xts/acts/multimedia/av_codec/vcodec/encoder/src/
H A Dvideoenc_ndk_sample.cpp91 unique_lock<mutex> lock(signal->inMutex_); in VencInputDataReady()
117 unique_lock<mutex> lock(signal->outMutex_); in VencOutputDataReady()
231 unique_lock<mutex> lock(signal_->inMutex_); in state_EOS()
232 signal_->inCond_.wait(lock, [this]() { return signal_->inIdxQueue_.size() > 0; }); in state_EOS()
236 lock.unlock(); in state_EOS()
258 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
262 lock.unlock(); in StopInloop()
563 unique_lock<mutex> lock(signal_->inMutex_); in RandomEOS()
618 unique_lock<mutex> lock(signal_->inMutex_); in SetEOS()
671 unique_lock<mutex> lock(signal in PushData()
[all...]
H A Dvideoenc_api11_sample.cpp70 unique_lock<mutex> lock(signal->inMutex_); in onEncInputBufferAvailable()
79 unique_lock<mutex> lock(signal->outMutex_); in onEncOutputBufferAvailable()
263 unique_lock<mutex> lock(signal_->inMutex_); in state_EOS()
264 signal_->inCond_.wait(lock, [this]() { return signal_->inIdxQueue_.size() > 0; }); in state_EOS()
269 lock.unlock(); in state_EOS()
292 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
296 lock.unlock(); in StopInloop()
584 unique_lock<mutex> lock(signal_->inMutex_); in RandomEOS()
647 unique_lock<mutex> lock(signal_->inMutex_); in SetEOS()
753 unique_lock<mutex> lock(signal in PushData()
[all...]
/test/testfwk/arkxtest/testserver/test/unittest/
H A Dstart_test_server.cpp40 std::unique_lock<std::mutex> lock(locatorMutex_); in InitLoadState()
46 std::unique_lock<std::mutex> lock(locatorMutex_); in WaitLoadStateChange()
47 auto wait = locatorCond_.wait_for(lock, std::chrono::milliseconds(TESTSERVER_LOAD_TIMEOUT_MS), [this] { in WaitLoadStateChange()
65 std::unique_lock<std::mutex> lock(locatorMutex_);
74 std::unique_lock<std::mutex> lock(locatorMutex_);
/test/xts/acts/multimedia/av_codec/vcodec/hwdecoder/src/
H A Dvideodec_ndk_sample.cpp147 unique_lock<mutex> lock(signal->inMutex_); in VdecInputDataReady()
173 unique_lock<mutex> lock(signal->outMutex_); in VdecOutputDataReady()
352 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
356 lock.unlock(); in StopInloop()
478 unique_lock<mutex> lock(signal_->inMutex_); in InputFuncTest()
479 signal_->inCond_.wait(lock, [this]() { in InputFuncTest()
493 lock.unlock(); in InputFuncTest()
641 unique_lock<mutex> lock(signal_->outMutex_); in OutputFuncTest()
642 signal_->outCond_.wait(lock, [this]() { in OutputFuncTest()
657 lock in OutputFuncTest()
[all...]
/test/xts/acts/multimedia/audio/ohaudioNdktest/
H A DActsOhaudioNdkTest.cpp84 std::lock_guard lock(mutex); in HWTEST()
100 std::unique_lock lock(mutex); in HWTEST()
101 cv.wait_for(lock, 1s, [&count] { in HWTEST()
105 lock.unlock(); in HWTEST()
/test/testfwk/arkxtest/testserver/src/client/
H A Dtest_server_client.cpp44 std::unique_lock<std::mutex> lock(locatorMutex_); in InitLoadState()
50 std::unique_lock<std::mutex> lock(locatorMutex_); in WaitLoadStateChange()
51 auto wait = locatorCond_.wait_for(lock, std::chrono::milliseconds(TESTSERVER_LOAD_TIMEOUT_MS), [this] { in WaitLoadStateChange()
73 std::unique_lock<std::mutex> lock(locatorMutex_);
84 std::unique_lock<std::mutex> lock(locatorMutex_);
/test/xts/acts/multimedia/av_codec/audio_decoder/src/
H A Davcodec_audio_avbuffer_decoder_demo.cpp68 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
78 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
242 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
243 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
391 unique_lock<mutex> lock(signal_->inMutex_); in Stop()
406 unique_lock<mutex> lock(signal_->outMutex_); in Stop()
433 unique_lock<mutex> lock(signal_->inMutex_); in Flush()
449 unique_lock<mutex> lock(signal_->outMutex_); in Flush()
524 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
525 signal_->inCond_.wait(lock, [thi in InputFunc()
[all...]
/test/xts/acts/multimedia/av_codec/audio_encoder/src/
H A Davcodec_audio_avbuffer_encoder_demo.cpp168 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
178 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
265 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
266 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
357 unique_lock<mutex> lock(signal_->inMutex_); in Stop()
372 unique_lock<mutex> lock(signal_->outMutex_); in Stop()
392 unique_lock<mutex> lock(signal_->inMutex_); in Flush()
408 unique_lock<mutex> lock(signal_->outMutex_); in Flush()
454 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
455 signal_->inCond_.wait(lock, [thi in InputFunc()
[all...]
/test/xts/acts/bundlemanager/zlib/actszlibtest/
H A DActsZlibTest.cpp49 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); in HWTEST_F()
793 std::lock_guard<std::mutex> lock(file_mutex); in HWTEST_F()
855 std::lock_guard<std::mutex> lock(file_mutex); in HWTEST_F()
883 std::lock_guard<std::mutex> lock(file_mutex); in HWTEST_F()
906 std::lock_guard<std::mutex> lock(file_mutex); in HWTEST_F()
928 std::lock_guard<std::mutex> lock(file_mutex); in HWTEST_F()
949 std::lock_guard<std::mutex> lock(file_mute in HWTEST_F()
[all...]
/test/testfwk/arkxtest/uitest/addon/
H A Dscreen_copy.cpp131 unique_lock<mutex> lock(frameLock_); in Destroy()
134 lock.unlock(); in Destroy()
171 frameLock_.lock(); in PollAndNotifyFrames()
251 unique_lock<mutex> lock(frameLock_); in WaitAndConsumeFrames()
252 frameCond_.wait(lock); in WaitAndConsumeFrames()
259 lock.unlock(); in WaitAndConsumeFrames()
/test/xts/dcts/distributedhardware/distributedscreentest/
H A Ddecoder_demo.cpp235 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
237 lock, [this]() { return signal_->inQueue_.size() > 0 && signal_->availableInputBufferQueue_.size() > 0; }); in InputFunc()
296 unique_lock<mutex> lock(signal_->outMutex_); in OutputFunc()
297 signal_->outCond_.wait(lock, [this]() { return signal_->outQueue_.size() > 0; }); in OutputFunc()
326 unique_lock<mutex> lock(signal_->inMutex_); in OnInputBufferAvailable()
336 unique_lock<mutex> lock(signal_->outMutex_); in OnOutputBufferAvailable()
/test/xts/acts/multimedia/av_codec/vcodec/hdrcodec/src/
H A Dhdrcodec_ndk_sample.cpp52 unique_lock<mutex> lock(signal->inMutex_); in VdecInputDataReady()
305 unique_lock<mutex> lock(decSignal->inMutex_); in InputFunc()
306 decSignal->inCond_.wait(lock, [this]() { in InputFunc()
320 lock.unlock(); in InputFunc()
446 unique_lock<mutex> lock(decSignal->inMutex_); in StopInloop()
450 lock.unlock(); in StopInloop()
470 unique_lock<mutex> lock(mtx); in WaitForEos()
471 g_cv.wait(lock, []() { in WaitForEos()
/test/xts/hats/hdf/nfc/secureElement_additional/
H A Dnfc_services_test.cpp109 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
137 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
165 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
196 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
227 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
254 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
281 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
311 std::lock_guard<std::recursive_mutex> lock(mLock_); in HWTEST_F()
/test/ostest/wukong/common/src/
H A Dwukong_logger.cpp72 std::lock_guard<std::mutex> lock(wukongMutex_); in GetInstance()
123 LOCK_PRINT_BUFFER.lock(); in Print()
141 // write lock avoid write conflicts in Print()
158 mtxQueue_.lock(); in Print()
198 self->mtxQueue_.lock(); in Run()
/test/testfwk/arkxtest/uitest/connection/
H A Dipc_transactor.cpp202 unique_lock<mutex> lock(mtx); in PublishCallerAndWaitForBackcaller()
217 } while (tries < PUBLISH_MAX_RETIES && condition.wait_for(lock, period) == cv_status::timeout); in PublishCallerAndWaitForBackcaller()
228 unique_lock<mutex> lock(mtx); in WaitForPublishedCaller()
248 auto ret = condition.wait_for(lock, timeout); in WaitForPublishedCaller()
385 unique_lock<mutex> lock(mtx); in SendBroadcastCommand()
398 if (condition.wait_for(lock, timeout) == cv_status::timeout) { in SendBroadcastCommand()
/test/xts/acts/multimedia/audio_ndk/oh_audio_render_test/src/
H A Doh_audio_render_unit_test.cpp1120 std::lock_guard lock(mutex); in HWTEST()
1133 std::unique_lock lock(mutex); in HWTEST()
1134 cv.wait_for(lock, 1s, [&count] { in HWTEST()
1138 lock.unlock(); in HWTEST()
1181 std::lock_guard lock(mutex); in HWTEST()
1194 std::unique_lock lock(mutex); in HWTEST()
1195 cv.wait_for(lock, 1s, [&count] { in HWTEST()
1199 lock.unlock(); in HWTEST()
1282 std::lock_guard lock(mutex); in HWTEST()
1295 std::unique_lock lock(mute in HWTEST()
[all...]
/test/xts/hats/powermgr/power/hdi_power/common/
H A Dhdi_power_test.cpp207 std::lock_guard<std::mutex> lock(g_mutex); in ReadFile()
317 std::string lock = lockValue;
318 EXPECT_FALSE(lock.empty());
319 auto pos = lock.find(testName);
320 EXPECT_TRUE(pos != std::string::npos) << "HdfPowerHdiTest006 failed lock: " << lock;
/test/testfwk/arkxtest/uitest/cj/
H A Duitest_ffi.cpp124 unique_lock<mutex> lock(g_gcQueueMutex); in CJTransact()
129 lock.unlock(); in CJTransact()
208 unique_lock<mutex> lock(g_gcQueueMutex); in CJ_UITestObjDelete()
/test/xts/hats/hdf/camera/cameraHdi/buffer_manager/
H A Dbuffer_manager_utest.cpp289 std::mutex lock; in HWTEST_F() local
291 std::thread dispatchBufferTask([&running, &idleList, &busyList, &bufferPool, &lock, &realFrameCount] { in HWTEST_F()
293 std::lock_guard<std::mutex> l(lock); in HWTEST_F()
306 std::thread acquireBufferTask([&running, &bufferPool, &lock, &inuseBufferList] { in HWTEST_F()
310 std::lock_guard<std::mutex> l(lock); in HWTEST_F()
315 std::thread returnBufferTask([&running, &lock, &inuseBufferList, &bufferPool, &busyList, &idleList] { in HWTEST_F()
319 std::lock_guard<std::mutex> l(lock); in HWTEST_F()

Completed in 25 milliseconds

12