Home
last modified time | relevance | path

Searched refs:cv (Results 1 – 25 of 171) sorted by relevance

1234567

/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp325 cv.notify_one();
355 cv.notify_one(); in NotifyOneTest()
385 cv.notify_one(); in WaitUntilTimeoutTest()
415 cv.notify_one(); in WaitUtilFlagTest_1()
443 cv.notify_one(); in WaitUtilFlagTest_2()
471 cv.notify_one(); in WaitForTest_1()
566 NotifyOneTest(mtx, cv);
570 WaitForTest_1(mtx, cv);
571 WaitForTest_2(mtx, cv);
572 WaitForTest_3(mtx, cv);
[all …]
/ohos5.0/base/account/os_account/frameworks/account_iam/test/unittest/include/
H A Daccount_iam_client_test_callback.h42 cv.notify_one(); in OnAcquireInfo()
50 cv.notify_one(); in OnResult()
53 std::condition_variable cv; variable
74 cv.notify_one(); in OnCredentialInfo()
77 std::condition_variable cv; variable
98 cv.notify_one(); in OnEnrolledId()
101 std::condition_variable cv; variable
122 cv.notify_one(); in OnResult()
125 std::condition_variable cv; variable
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/transaction/
H A Drs_render_thread_client.cpp39 auto cv = std::make_shared<std::condition_variable>(); in ExecuteSynchronousTask() local
41 renderThread.PostTask([task, cv, &renderThread]() { in ExecuteSynchronousTask()
46 cv->notify_all(); in ExecuteSynchronousTask()
48 cv->wait_for(lock, std::chrono::nanoseconds(task->GetTimeout())); in ExecuteSynchronousTask()
/ohos5.0/foundation/ai/ai_engine/
H A DCMakeLists.txt16 interfaces/kits/cv/image_classification/ic_callback.h
17 interfaces/kits/cv/image_classification/ic_constants.h
18 interfaces/kits/cv/image_classification/ic_retcode.h
19 interfaces/kits/cv/image_classification/ic_sdk.h
/ohos5.0/base/account/os_account/frameworks/domain_account/test/moduletest/src/
H A Dmock_domain_create_domain_account_callback.cpp42 cv.notify_one(); in OnResult()
52 cv.notify_one(); in OnResult()
62 cv.notify_one(); in OnResult()
68 cv.notify_one(); in OnResult()
H A Ddomain_account_client_module_test.cpp241 testCallback->cv.wait_for(
304 testCallback->cv.wait_for(
359 testCallback->cv.wait_for(
613 testCallback->cv.wait_for(
637 testCallback->cv.wait_for(
748 testCallback->cv.wait_for(
782 testCallback->cv.wait_for(
805 testCallback->cv.wait_for(
829 testCallback->cv.wait_for(
934 testCallback->cv.wait_for(
[all …]
H A Dmock_domain_has_domain_info_callback.cpp43 cv.notify_one(); in OnResult()
63 cv.notify_one(); in OnResult()
H A Dmock_domain_auth_callback.cpp49 cv.notify_one(); in OnResult()
58 cv.notify_one(); in OnResult()
/ohos5.0/foundation/arkui/napi/interfaces/inner_api/cjffi/ark_interop/
H A Dark_interop_engine.cpp177 std::condition_variable cv; in ARKTS_DestroyEngine() local
179 engine->eventHandler->PostTask([engine, &cv, &isComplete] { in ARKTS_DestroyEngine()
182 cv.notify_one(); in ARKTS_DestroyEngine()
187 cv.wait_for(lock, std::chrono::seconds(1)); in ARKTS_DestroyEngine()
297 std::condition_variable cv; in ARKTS_CreateEngineWithNewThread() local
299 auto postSuccess = handler->PostTask([&result, &cv, &createComplete] { in ARKTS_CreateEngineWithNewThread()
302 cv.notify_one(); in ARKTS_CreateEngineWithNewThread()
309 cv.wait_for(lock, std::chrono::milliseconds(1)); in ARKTS_CreateEngineWithNewThread()
/ohos5.0/base/account/os_account/frameworks/account_iam/test/unittest/src/
H A Daccount_iam_client_test.cpp299 testCallback->cv.wait_for(
357 testCallback->cv.wait_for(
476 testCallback->cv.wait_for(
494 testCallback->cv.wait_for(
560 testCallback->cv.wait_for(
582 testCallback->cv.wait_for(
602 testCallback->cv.wait_for(
670 testCallback->cv.wait_for(
901 testCallback->cv.wait_for(
1105 testCallback->cv.wait_for(
[all …]
/ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audiocapturer/test/unittest/capturer_test/src/
H A Daudio_fast_capturer_unit_test.cpp98 std::condition_variable cv; variable
100 cb->Install([&count, &audioCapturer, &mutex, &cv](size_t length) { in __anone372d4180202()
102 cv.notify_one(); in __anone372d4180202()
124 cv.wait_for(lock, 1s, [&count] { in __anone372d4180302()
/ohos5.0/docs/zh-cn/release-notes/changelogs/OpenHarmony_4.1.3.1/
H A Dchangelogs-pixelmap.md39 案例1：openCV在处理pixelmap的位图数据时需要通过pixelmap的位图数据构建openCV中的cv::Mat, 需要增加step入参，
44 cv::Mat srv(rows: bitmap.height, cols: bitmap.width, type: CV_8UC4, data: imagePixels);
50 cv::Mat srv(rows: bitmap.height, cols: bitmap.width, type: CV_8UC4, data: imagePixels, step: rowSiz…
/ohos5.0/base/hiviewdfx/hiview/plugins/performance/timer/
H A DSceneTimerOhImpl.cpp66 cv.wait_for(uniqueLock, interval); in Loop()
71 cv.wait(uniqueLock); in Loop()
83 cv.notify_all(); // remember this in FillRecordAndNotify()
174 cv.notify_all(); in RemoveRecordAndNotify()
/ohos5.0/foundation/ai/ai_engine/services/client/
H A DCMakeLists.txt10 include_directories(../../../../../foundation/ai/ai_engine/interfaces/kits/cv/image_classification)
35 algorithm_sdk/cv/image_classification/include/ic_sdk_impl.h
36 algorithm_sdk/cv/image_classification/source/ic_sdk.cpp
37 algorithm_sdk/cv/image_classification/source/ic_sdk_impl.cpp
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_auto_launch_test.cpp265 std::condition_variable cv; variable
278 cv.notify_one(); in __anonaf6a41ef0202()
326 cv.wait(lock, [&finished] {return finished;}); in __anonaf6a41ef0402()
342 std::condition_variable cv; variable
354 cv.notify_one(); in __anonaf6a41ef0502()
404 cv.wait(lock, [&finished] {return finished;}); in __anonaf6a41ef0702()
486 std::condition_variable cv; variable
498 cv.notify_one(); in __anonaf6a41ef0802()
542 cv.wait(lock, [&finished] {return finished;}); in __anonaf6a41ef0a02()
564 std::condition_variable cv; variable
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dscpuworker_manager.cpp61 sleepCtl[qos].cv.notify_all(); in ~SCPUWorkerManager()
165 if (ctl.cv.wait_for(lk, std::chrono::seconds(waiting_seconds), [this, thread] { in WorkerIdleAction()
184 ctl.cv.wait(lk, [this, thread] { in WorkerIdleAction()
211 ctl.cv.notify_one(); in WakeupWorkers()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp80 std::condition_variable cv; in Sync() local
82 const auto callback = [&callCount, &syncProcess, &processMutex, &cv]( in Sync()
95 cv.notify_all(); in Sync()
101 cv.wait(uniqueLock, [&syncProcess]() { in Sync()
408 std::condition_variable cv; variable
420 cv.notify_all(); in __anon9cf3a58a0502()
428 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&finished]() { in __anon9cf3a58a0602()
718 std::condition_variable cv; variable
719 cloudSyncer->SetCurrentTaskInfo([&callCount, &cv](const std::map<std::string, SyncProcess> &) { in __anon9cf3a58a0b02()
725 cv.notify_all(); in __anon9cf3a58a0b02()
[all …]
/ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/unwinder/
H A Dthread_context.cpp155 it->second->cv.notify_all(); in ReleaseThread()
177 if (threadContext->cv.wait_for(lock, g_timeOut) == std::cv_status::timeout) { in CollectThreadContext()
197 ctxPtr->cv.notify_all(); in CopyContextAndWaitTimeout()
221 ctxPtr->cv.notify_all(); in CopyContextAndWaitTimeout()
222 ctxPtr->cv.wait_for(lock, g_timeOut); in CopyContextAndWaitTimeout()
/ohos5.0/foundation/bundlemanager/bundle_tool/frameworks/include/bundle_tool_callback/
H A Dbundle_tool_callback_stub.h32 BundleToolCallbackStub(std::condition_variable &cv, std::mutex &mutex, bool &dataReady) in BundleToolCallbackStub() argument
33 : cv_(cv), mutex_(mutex), dataReady_(dataReady) in BundleToolCallbackStub()
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/network/
H A Ddownload_manager_impl.cpp140 downloadCondition->cv.notify_all(); in Download()
151 downloadCondition->cv.notify_all(); in Download()
166 downloadCondition->cv.notify_all(); in Download()
250 downloadCondition->cv.notify_all(); in DownloadSync()
263 downloadCondition->cv.notify_all(); in DownloadSync()
298 downloadCondition->cv.notify_all(); in OnFail()
336 downloadCondition->cv.wait_for( in HandleDownloadResult()
361 downloadCondition->cv.wait_for( in HandleDownloadResult()
/ohos5.0/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_quota_policy.cpp135 std::for_each(recv.begin(), recv.end(), [this](const auto &cv) { in __anond094590c0202() argument
136 EXPECT_EQ(cv.networkmatchrule.simId, GetQuota().networkmatchrule.simId); in __anond094590c0202()
137 EXPECT_EQ(cv.networkmatchrule.ident, GetQuota().networkmatchrule.ident); in __anond094590c0202()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dref_object.cpp128 bool RefObject::WaitLockedUntil(std::condition_variable &cv, in WaitLockedUntil() argument
141 cv.wait_for(lock, std::chrono::seconds(seconds)); in WaitLockedUntil()
145 cv.wait(lock); in WaitLockedUntil()
/ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/free_install/
H A Dservice_center_connection.h32 ServiceCenterConnection(int32_t &connectState, std::condition_variable &cv, in ServiceCenterConnection() argument
34 : connectState_(connectState), cv_(cv), connectAbilityMgr_(connectAbilityMgr) in ServiceCenterConnection()
/ohos5.0/foundation/arkui/napi/test/unittest/cj_native/
H A Dtest_ark_interop.cpp820 std::condition_variable cv; in TEST_F() local
828 cv.notify_one(); in TEST_F()
843 cv.wait_for(lock, std::chrono::milliseconds(checkDuration)); in TEST_F()
861 std::condition_variable cv; variable
862 auto funcId = local.StoreAsyncFunc([&isComplete, &cv] { in __anon2e6194971202()
865 cv.notify_one(); in __anon2e6194971202()
873 cv.wait_for(lock, std::chrono::milliseconds(checkDuration));
914 std::condition_variable cv; in main() local
918 auto success = handler->PostTask([&ret, &cv, &globalEngine] { in main()
922 cv.notify_all(); in main()
[all …]
/ohos5.0/base/account/os_account/frameworks/domain_account/test/moduletest/include/
H A Dmock_domain_has_domain_info_callback.h36 std::condition_variable cv; variable
55 std::condition_variable cv; variable

1234567