Home
last modified time | relevance | path

Searched refs:finishCount (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_task_merge_test.cpp280 size_t finishCount = 0u; variable
281 …auto callback1 = [&callbackCv, &callbackMutex, &finishCount](const std::map<std::string, SyncProce… in __anonb94ae3c60302()
286 finishCount++; in __anonb94ae3c60302()
288 LOGW("current finish %zu", finishCount); in __anonb94ae3c60302()
309 callbackCv.wait(callbackLock, [&finishCount]() { in __anonb94ae3c60402()
310 return (finishCount >= 1u); in __anonb94ae3c60402()
H A Ddistributeddb_cloud_check_sync_test.cpp1308 size_t finishCount = 0u; variable
1320 finishCount++; in __anonc8f560be1602()
1339 callbackCv.wait(callbackLock, [&finishCount]() { in __anonc8f560be1702()
1379 size_t finishCount = 0u; variable
1385 finishCount++; in __anonc8f560be1802()
1402 callbackCv.wait(callbackLock, [&finishCount]() { in __anonc8f560be1902()
1442 size_t finishCount = 0u; variable
1448 finishCount++; in __anonc8f560be1a02()
1464 callbackCv.wait(callbackLock, [&finishCount]() { in __anonc8f560be1b02()
1581 size_t finishCount = 0u; variable
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_mock_sync_module_test.cpp216 int finishCount = 0; in AutoLaunchCheck001() local
221 std::thread t = std::thread([&finishCount, &mockAutoLaunch, &id, &userId, &mutex, &cv] { in AutoLaunchCheck001()
223 finishCount++; in AutoLaunchCheck001()
224 if (finishCount == loopCount) { in AutoLaunchCheck001()
231 cv.wait(lock, [&finishCount, &loopCount]() { return finishCount == loopCount; }); in AutoLaunchCheck001()
245 std::atomic<int> finishCount = 0; in AbilitySync004() local
250 std::thread t = std::thread([&context, &finishCount, &cv] { in AbilitySync004()
253 finishCount++; in AbilitySync004()
254 if (finishCount == loopCount) { in AbilitySync004()
260 cv.wait(lock, [&]() { return finishCount == loopCount; }); in AbilitySync004()