Searched refs:g_processCondition (Results 1 – 5 of 5) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_sync_utils_test.cpp | 29 std::condition_variable g_processCondition; variable
189 g_processCondition.notify_one(); in GetCallback()
212 g_processCondition.notify_one(); in GetCallback()
240 … bool result = g_processCondition.wait_for(lock, std::chrono::seconds(waitTime), [&syncProcess]() { in WaitForSyncFinish()
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 112 std::condition_variable g_processCondition; variable
297 bool result = g_processCondition.wait_for( in WaitForSyncFinish()
312 g_processCondition.notify_one(); in CallSync()
605 g_processCondition.notify_one(); in DataStatusTest001()
627 g_processCondition.notify_one(); in DataStatusTest003()
658 g_processCondition.notify_one(); in DataStatusTest004()
700 g_processCondition.notify_one(); in DataStatusTest005()
734 g_processCondition.notify_one(); in DataStatusTest006()
768 g_processCondition.notify_one(); in DataStatusTest007()
1974 g_processCondition.notify_one(); in __anon32d7e6602702()
[all …]
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 80 std::condition_variable g_processCondition; variable
701 g_processCondition.notify_all(); in __anon6ad9bb3f0902()
706 bool result = g_processCondition.wait_for(lock, std::chrono::seconds(WAIT_TIME),
722 bool result = g_processCondition.wait_for(lock, std::chrono::seconds(WAIT_TIME),
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 55 std::condition_variable g_processCondition; variable
1557 g_processCondition.notify_one(); in __anon239839ae0802()
1939 g_processCondition.notify_one(); in __anon239839ae0f02()
1946 g_processCondition.wait(lock, []() { in __anon239839ae1002()
1976 g_processCondition.notify_one(); in __anon239839ae1102()
1984 g_processCondition.wait(lock, []() { in __anon239839ae1202()
2036 g_processCondition.notify_one(); in __anon239839ae1302()
2043 g_processCondition.wait(lock, []() { in __anon239839ae1402()
2122 g_processCondition.notify_one(); in __anon239839ae1502()
2129 g_processCondition.wait(lock, []() { in __anon239839ae1602()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 57 std::condition_variable g_processCondition; variable
486 g_processCondition.notify_one(); in GetCallback()
509 g_processCondition.notify_one(); in GetCallback()
540 … bool result = g_processCondition.wait_for(lock, std::chrono::seconds(waitTime), [&syncProcess]() { in WaitForSyncFinish()
|