Home
last modified time | relevance | path

Searched refs:g_cv (Results 1 - 14 of 14) sorted by relevance

/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_policy_callback.cpp48 std::condition_variable g_cv; member
69 g_cv.notify_all(); in NetUidPolicyChange()
77 g_cv.notify_all(); in NetUidRuleChange()
84 g_cv.notify_all(); in NetQuotaPolicyChange()
96 g_cv.notify_all(); in NetMeteredIfacesChange()
103 g_cv.notify_all(); in NetBackgroundPolicyChange()
180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv in HWTEST_F()
[all...]
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/
H A Dut_net_policy_callback.cpp48 std::condition_variable g_cv; member
69 g_cv.notify_all(); in NetUidPolicyChange()
77 g_cv.notify_all(); in NetUidRuleChange()
84 g_cv.notify_all(); in NetQuotaPolicyChange()
96 g_cv.notify_all(); in NetMeteredIfacesChange()
103 g_cv.notify_all(); in NetBackgroundPolicyChange()
180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv in HWTEST_F()
[all...]
/foundation/filemanagement/app_file_service/tests/unittests/backup_api/backup_impl/
H A Dsvc_death_recipient_test.cpp30 static condition_variable g_cv; member
47 g_cv.notify_all(); in CallBack()
70 g_cv.wait(lk, [&] { return true; }); in HWTEST_F()
/foundation/communication/netmanager_ext/test/mdnsmanager/unittest/mdns_manager_test/
H A Dmdns_manager_test.cpp59 std::condition_variable g_cv; member
81 g_cv.notify_one();
103 g_cv.notify_one();
117 g_cv.notify_one();
137 g_cv.notify_one();
213 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_register == TIME_TWO_MS; })) { in DoTestForMdnsClient()
218 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_found >= TIME_FOUR_MS; })) { in DoTestForMdnsClient()
222 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_resolve >= TIME_ONE_MS; })) { in DoTestForMdnsClient()
226 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_resolve >= TIME_TWO_MS; })) { in DoTestForMdnsClient()
231 if (!g_cv in DoTestForMdnsClient()
[all...]
/foundation/communication/netmanager_ext/frameworks/native/mdnsclient/src/
H A Dmdns_client.cpp35 std::condition_variable g_cv; member
43 g_cv.notify_one(); in OnLoadSystemAbilitySuccess()
49 g_cv.notify_one(); in OnLoadSystemAbilityFail()
191 if (!g_cv.wait_for(lk, std::chrono::seconds(LOAD_SA_TIMEOUT), in LoadSaOnDemand()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_auto_launch_test.cpp607 std::condition_variable g_cv; member
623 g_cv.notify_one(); in ConflictNotifierCallback()
634 g_cv.notify_one(); in TestAutoLaunchNotifier()
693 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
706 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
716 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
796 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
895 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
907 g_cv.wait(lock, [] {return g_finished;}); in HWTEST_F()
917 g_cv in HWTEST_F()
[all...]
/foundation/communication/netmanager_ext/frameworks/native/netfirewallclient/src/
H A Dnetfirewall_client.cpp33 std::condition_variable g_cv; member
43 g_cv.notify_one(); in OnLoadSystemAbilitySuccess()
201 if (!g_cv.wait_for(lk, std::chrono::seconds(WAIT_REMOTE_TIME_SEC), in LoadSaOnDemand()
/foundation/communication/bluetooth_service/test/unittest/ble/
H A Dble_test.cpp42 std::condition_variable g_cv; member
75 g_cv.wait(lock); in EnableBle()
94 g_cv.wait(lock); in DisableBle()
178 g_cv.notify_all(); in OnStateChanged()
/foundation/communication/netmanager_ext/frameworks/native/netshareclient/src/
H A Dnetworkshare_client.cpp32 std::condition_variable g_cv; member
41 g_cv.notify_one(); in OnLoadSystemAbilitySuccess()
226 g_cv.wait_for(uniqueLock, std::chrono::seconds(WAIT_REMOTE_TIME_SEC), in GetProxy()
/foundation/multimedia/av_codec/test/moduletest/vcodec/hdrcodec/src/InnerAPI/
H A Dhdrcodec_inner_ndk_sample.cpp33 std::condition_variable g_cv; member
116 g_cv.notify_all(); in OnOutputBufferAvailable()
182 g_cv.notify_all(); in InputFunc()
361 g_cv.wait(lock, []() { in WaitForEos()
/foundation/multimedia/av_codec/test/moduletest/vcodec/hdrcodec/src/
H A Dhdrcodec_ndk_sample.cpp31 std::condition_variable g_cv; member
104 g_cv.notify_all(); in VencOutputDataReady()
304 g_cv.notify_all(); in InputFunc()
474 g_cv.wait(lock, []() { in WaitForEos()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp61 static std::condition_variable g_cv; member
241 g_cv.notify_one();
257 g_cv.notify_one(); in ClientObserverFunc()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_ext_test.cpp47 std::condition_variable g_cv; member
69 g_cv.notify_one(); in ClientObserverFunc()
79 g_cv.notify_one(); in ClientObserverFunc2()
99 g_cv.wait(lock, []() { in WaitAndResetNotifyWithLock()
173 g_cv.wait(lock, []() { in ExecSqlAndWaitForObserver()
730 bool isEqual = g_cv.wait_for(lock, std::chrono::seconds(1), [this, dataCounts]() { // 1 is wait time in HWTEST_F()
746 isEqual = g_cv.wait_for(lock, std::chrono::seconds(1), [this]() { // 1 is wait time in HWTEST_F()
1458 g_cv.notify_one();
1569 g_cv.wait(lock, []() { in HWTEST_F()
/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/
H A Dsocket_exec.cpp93 std::condition_variable g_cv; member
173 g_cv.notify_one(); in NotifyRegisterEvent()
185 g_cv.notify_one(); in NewInstanceWithConstructor()
1867 g_cv.wait(lock, [&manager, &clientId]() { in WaitForManagerReady()

Completed in 16 milliseconds