Home
last modified time | relevance | path

Searched refs:lk (Results 1 - 25 of 62) sorted by relevance

123

/foundation/resourceschedule/ffrt/interfaces/kits/cpp/
H A Dcondition_variable.h51 std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp, Pred&& pred) noexcept
54 if (wait_until(lk, tp) == cv_status::timeout) {
62 cv_status wait_until(std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp) noexcept
64 return _wait_for(lk, tp - Clock::now());
68 cv_status wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleep_time) noexcept
70 return _wait_for(lk, sleep_time);
75 std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleepTime, Pred&& pred) noexcept
77 return wait_until(lk, std::chrono::steady_clock::now() + sleepTime, std::forward<Pred>(pred));
81 void wait(std::unique_lock<mutex>& lk, Pred&& pred) in wait() argument
84 wait(lk); in wait()
88 wait(std::unique_lock<mutex>& lk) wait() argument
[all...]
/foundation/resourceschedule/ffrt/src/sync/
H A Dwait_queue.cpp31 void WaitQueue::ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task) in ThreadWait() argument
42 lk->unlock(); in ThreadWait()
45 lk->lock(); in ThreadWait()
48 bool WaitQueue::ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, in ThreadWaitUntil() argument
62 lk->unlock(); in ThreadWaitUntil()
76 lk->lock(); in ThreadWaitUntil()
80 void WaitQueue::SuspendAndWait(mutexPrivate* lk) in SuspendAndWait() argument
85 ThreadWait(&ctx->wn, lk, LegacyMode(task), task); in SuspendAndWait()
93 lk->unlock(); // Unlock needs to be in wqlock protection, guaranteed to be executed before lk in SuspendAndWait()
[all...]
H A Dwait_queue.h57 std::mutex lk; member
68 void SuspendAndWait(mutexPrivate* lk);
69 bool SuspendAndWaitUntil(mutexPrivate* lk, const TimePoint& tp) noexcept;
93 void ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task);
94 bool ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, const TimePoint& tp, bool legacyMode, CPUEUTask* task);
H A Drecord_condition_variable.h26 cv_status WaitFor(std::unique_lock<RecordMutex>& lk, const std::chrono::duration<Rep, Period>& sleep_time) noexcept
35 auto ret = ffrt_cond_timedwait(&cv_, lk.mutex()->GetMutex(), &ts);
H A Dshared_mutex.cpp108 std::unique_lock<std::mutex> lk(ctx->wn.wl); in Wait()
110 ctx->wn.cv.wait(lk); in Wait()
136 std::unique_lock<std::mutex> lk(wue->wl); in NotifyOne()
157 std::unique_lock<std::mutex> lk(wue->wl); in NotifyAll()
/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/
H A Dwifi_direct_event_queue.h31 std::lock_guard<std::mutex> lk(m_); in Push()
38 std::unique_lock<std::mutex> lk(m_); in WaitAndPop()
39 c_.wait(lk, [&] { return !queue_.empty(); }); in WaitAndPop()
48 std::lock_guard<std::mutex> lk(m_); in Process()
56 std::lock_guard<std::mutex> lk(m_); in Clear()
/foundation/multimedia/image_effect/frameworks/native/render_environment/render_thread/worker/
H A Drender_thread.h78 std::unique_lock<std::mutex> lk(cvMutex); in AddTask()
79 cvFull.wait(lk, [this]() { return (m_localMsgQueue->GetSize() < this->qSize) || (!m_isWorking); }); in AddTask()
85 lk.unlock(); in AddTask()
92 std::unique_lock<std::mutex> lk(cvMutex); in ClearTask()
96 lk.unlock(); in ClearTask()
126 std::unique_lock<std::mutex> lk(cvMutex); in Run()
127 bool cvRet = cvEmpty.wait_for(lk, std::chrono::milliseconds(TIME_FOR_WAITING_TASK), in Run()
132 lk.unlock(); in Run()
138 lk.unlock(); in Run()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_hf/
H A Dhfp_hf_service.cpp168 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect()
192 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect()
215 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices()
228 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState()
247 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum()
268 std::lock_guard<std::recursive_mutex> lk(mutex_); in ConnectSco()
290 std::lock_guard<std::recursive_mutex> lk(mutex_); in DisconnectSco()
312 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates()
329 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState()
347 std::lock_guard<std::recursive_mutex> lk(mutex in GetScoState()
[all...]
/foundation/graphic/graphic_3d/3d_widget_adapter/src/
H A Dgraphics_task.cpp69 std::lock_guard<std::mutex> lk(messageQueueMut_); in PushSyncMessage()
81 std::lock_guard<std::mutex> lk(messageQueueMut_); in PushAsyncMessage()
98 std::lock_guard<std::mutex> lk(messageQueueMut_); in ~GraphicsTask()
132 std::unique_lock<std::mutex> lk(messageQueueMut_); in EngineThread()
133 messageQueueCnd_.wait(lk, [this] { return !messageQueue_.empty(); }); in EngineThread()
137 lk.unlock(); in EngineThread()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/
H A Dble_adapter.cpp174 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in EnableTask()
248 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in DisableTask()
314 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartOrStopAdvAndScan()
475 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalAddress()
483 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalName()
491 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetLocalName()
516 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetDeviceName()
556 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in ReadRemoteDeviceNameByGatt()
586 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetDeviceUuids()
599 std::lock_guard<std::recursive_mutex> lk(pimp in GetPairedDevices()
[all...]
/foundation/multimedia/av_codec/test/unittest/hcodec_test/helper/
H A Dtester_capi.cpp42 lock_guard<mutex> lk(tester->inputMtx_); in OnNeedInputData()
55 lock_guard<mutex> lk(tester->outputMtx_); in OnNewOutputData()
66 lock_guard<mutex> lk(tester->inputMtx_); in OnNeedInputBuffer()
80 lock_guard<mutex> lk(tester->outputMtx_); in OnNewOutputBuffer()
198 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer()
202 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer()
210 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer()
214 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer()
358 unique_lock<mutex> lk(inputMtx_); in WaitForInput()
360 inputCond_.wait(lk, [thi in WaitForInput()
[all...]
H A Dtester_codecbase.cpp38 lock_guard<mutex> lk(tester_->inputMtx_); in OnInputBufferAvailable()
54 lock_guard<mutex> lk(tester_->outputMtx_); in OnOutputBufferAvailable()
143 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer()
147 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer()
383 unique_lock<mutex> lk(inputMtx_); in WaitForInput()
385 inputCond_.wait(lk, [this] { in WaitForInput()
389 bool ret = inputCond_.wait_for(lk, chrono::milliseconds(opt_.timeout), [this] { in WaitForInput()
444 unique_lock<mutex> lk(outputMtx_); in WaitForOutput()
446 outputCond_.wait(lk, [this] { in WaitForOutput()
450 bool waitRes = outputCond_.wait_for(lk, chron in WaitForOutput()
[all...]
/foundation/multimedia/image_framework/plugins/manager/src/framework/
H A Dplugin_fw.cpp43 UniqueWriteGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in Register()
51 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in CreateObject()
61 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in CreateObject()
71 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in PluginFwGetClassInfo()
/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dfuture.h38 std::unique_lock lk(this->m_mtx);
39 wait_(lk); variable
45 std::unique_lock<mutex> lk(m_mtx);
46 return m_cv.wait_for(lk, waitTime, [this] { return get_derived().has_value(); }) ? future_status::ready :
53 std::unique_lock<mutex> lk(m_mtx);
54 return m_cv.wait_until(lk, tp, [this] { return get_derived().has_value(); }) ? future_status::ready :
59 void wait_(std::unique_lock<mutex>& lk) const noexcept
61 m_cv.wait(lk, [this] { return get_derived().has_value(); });
79 std::unique_lock<mutex> lk(this->m_mtx);
88 std::unique_lock<mutex> lk(thi
[all...]
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp540 std::unique_lock lk(mtx); in HWTEST_F()
541 cv.wait_for(lk, 1us); in HWTEST_F()
549 std::unique_lock lk(mtx); in HWTEST_F()
550 cv.wait_for(lk, 1us); in HWTEST_F()
572 std::unique_lock lk(mtx); in NotifyOneTest()
573 cv.wait(lk, [&] { return flag; }); in NotifyOneTest()
574 EXPECT_TRUE(lk.owns_lock()); in NotifyOneTest()
584 std::unique_lock lk(mtx); in NotifyOneTest()
604 std::unique_lock lk(mtx); in WaitUntilTimeoutTest()
605 EXPECT_EQ(static_cast<int>(cv.wait_until(lk, st in WaitUntilTimeoutTest()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/client/
H A Dtcp_client.cpp67 std::unique_lock<std::shared_mutex> lk(mutex_); in Connect()
90 std::unique_lock<std::shared_mutex> lk(mutex_); in Disconnect()
110 std::unique_lock<std::shared_mutex> lk(mutex_); in Send()
115 lk.unlock(); in Send()
H A Dudp_client.cpp41 std::unique_lock<std::shared_mutex> lk(mutex_); in Connect()
77 std::unique_lock<std::shared_mutex> lk(mutex_); in Disconnect()
96 std::unique_lock<std::shared_mutex> lk(mutex_); in Send()
/foundation/communication/netmanager_base/utils/common_utils/include/
H A Dtiny_count_down_latch.h35 std::unique_lock<std::mutex> lk(mtx_); in Await()
37 return conditionVar_.wait_for(lk, time, [this] { return count_ == 0; }); in Await()
/foundation/filemanagement/app_file_service/tests/unittests/backup_api/backup_impl/
H A Dsvc_death_recipient_test.cpp69 unique_lock<mutex> lk(lock_); in HWTEST_F()
70 g_cv.wait(lk, [&] { return true; }); in HWTEST_F()
/foundation/CastEngine/castengine_wifi_display/services/configuration/src/
H A Dconfig.cpp35 std::shared_lock<std::shared_mutex> lk(mutex_); in GetConfig()
53 std::shared_lock<std::shared_mutex> lk(mutex_); in GetConfig()
67 std::shared_lock<std::shared_mutex> lk(mutex_); in GetConfig()
89 std::unique_lock<std::shared_mutex> lk(mutex_); in SetConfig()
112 std::unique_lock<std::shared_mutex> lk(mutex_); in SetConfig()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_ag/
H A Dhfp_ag_service.cpp153 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect()
184 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect()
204 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices()
216 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState()
237 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState()
254 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum()
265 std::lock_guard<std::recursive_mutex> lk(mutex_); in ProcessEvent()
321 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates()
338 std::lock_guard<std::recursive_mutex> lk(mutex_); in ConnectSco()
362 std::lock_guard<std::recursive_mutex> lk(mutex in DisconnectSco()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_service.cpp151 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect()
176 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect()
271 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates()
288 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState()
308 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices()
322 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState()
342 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum()
384 std::lock_guard<std::recursive_mutex> lk(mutex_); in ProcessEvent()
436 std::lock_guard<std::recursive_mutex> lk(mutex_); in HidHostFindDeviceByLcid()
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/src/
H A Dnetwork_latency_controller.cpp73 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()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/classic/
H A Dclassic_adapter.cpp535 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBondableMode()
543 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetBondableMode()
558 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartBtDiscovery()
585 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in CancelBtDiscovery()
606 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in IsBtDiscovering()
614 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBtDiscoveryEndMillis()
999 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryResult()
1026 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in FindRemoteDevice()
1042 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryComplete()
1066 std::lock_guard<std::recursive_mutex> lk(pimp in DiscoverRemoteName()
[all...]
/foundation/communication/netmanager_ext/frameworks/native/mdnsclient/src/
H A Dmdns_client.cpp190 std::unique_lock<std::mutex> lk(g_loadMutex); in LoadSaOnDemand()
191 if (!g_cv.wait_for(lk, std::chrono::seconds(LOAD_SA_TIMEOUT), in LoadSaOnDemand()
194 lk.unlock(); in LoadSaOnDemand()
197 lk.unlock(); in LoadSaOnDemand()

Completed in 15 milliseconds

123