| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_auto_launch_test.cpp | 274 statusMap[identifier] = status; in __anonaf6a41ef0202()
276 if (statusMap.size() == 2) { // A and B in __anonaf6a41ef0202()
311 statusMap.clear();
327 EXPECT_TRUE(statusMap[g_identifierA] == WRITE_CLOSED);
328 EXPECT_TRUE(statusMap[g_identifierB] == WRITE_CLOSED);
351 statusMap[identifier] = status; in __anonaf6a41ef0502()
388 statusMap.clear();
405 EXPECT_TRUE(statusMap[g_identifierA] == WRITE_CLOSED);
406 EXPECT_TRUE(statusMap.size() == 1);
495 statusMap[identifier] = status; in __anonaf6a41ef0802()
[all …]
|
| H A D | distributeddb_tools_unit_test.cpp | 951 [&statuses, this](const std::map<std::string, DBStatus>& statusMap) { in SyncTest() argument
952 statuses = statusMap; in SyncTest()
973 [&statuses, this](const std::map<std::string, DBStatus>& statusMap) { in SyncTest() argument
974 statuses = statusMap; in SyncTest()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_sync_check_test.cpp | 1192 ASSERT_TRUE(statusMap.size() == devices.size()); in PrepareForSyncMergeTest()
1193 for (const auto &pair : statusMap) { in PrepareForSyncMergeTest()
1236 ASSERT_TRUE(statusMap.size() == devices.size()); in __anon6e997c5f1b02()
1237 for (const auto &pair : statusMap) { in __anon6e997c5f1b02()
1287 for (const auto &pair : statusMap) { in __anon6e997c5f1c02()
1361 for (const auto &pair : statusMap) { in __anon6e997c5f1f02()
1407 for (const auto &pair : statusMap) { in PrePareForQuerySyncMergeTest()
1462 for (const auto &pair : statusMap) { in __anon6e997c5f2102()
1502 for (const auto &pair : statusMap) { in __anon6e997c5f2202()
1559 for (const auto &pair : statusMap) { in __anon6e997c5f2302()
[all …]
|
| H A D | distributeddb_relational_multi_user_test.cpp | 200 std::map<std::string, std::vector<TableStatus>> statusMap; in CheckSyncTest() local
201 SyncStatusCallback callBack = [&statusMap]( in CheckSyncTest()
203 statusMap = devicesMap; in CheckSyncTest()
210 for (const auto &pair : statusMap) { in CheckSyncTest()
217 statusMap.clear(); in CheckSyncTest()
236 statusMap.clear(); in CheckSyncTest()
281 statusMap = devicesMap; in CheckSyncResult()
305 syncCondVar_.wait(lock, [status, &statusMap]() { in CheckSyncResult()
309 return !statusMap.empty(); in CheckSyncResult()
314 EXPECT_EQ(statusMap.size(), devices.size()); in CheckSyncResult()
[all …]
|
| H A D | distributeddb_single_ver_p2p_permission_sync_test.cpp | 742 [&result](const std::map<std::string, DBStatus>& statusMap) { in __anone28338ea0c02() argument
743 result = statusMap; in __anone28338ea0c02()
747 [&result2](const std::map<std::string, DBStatus>& statusMap) { in __anone28338ea0d02() argument
748 result2 = statusMap; in __anone28338ea0d02()
752 [&result3](const std::map<std::string, DBStatus>& statusMap) { in __anone28338ea0e02() argument
753 result3 = statusMap; in __anone28338ea0e02()
|
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 334 std::map<std::string, std::vector<TableStatus>> statusMap; in BlockSync() local
335 SyncStatusCallback callBack = [&statusMap]( in BlockSync()
337 statusMap = devicesMap; in BlockSync()
341 for (const auto &tablesRes : statusMap) { in BlockSync()
1142 std::map<std::string, std::vector<TableStatus>> statusMap; variable
1143 SyncStatusCallback callBack = [&statusMap, &syncMutex, &syncCv](
1145 statusMap = devicesMap; in __anond45d0a2b0602()
1275 SyncOperation::UserCallback callBack = [](const std::map<std::string, int> &statusMap) { in __anond45d0a2b0c02() argument
1276 for (const auto &entry : statusMap) { in __anond45d0a2b0c02()
1317 SyncOperation::UserCallback callBack = [](const std::map<std::string, int> &statusMap) { in __anond45d0a2b0d02() argument
[all …]
|
| H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 586 auto callback = [&result](const std::map<std::string, DBStatus>& statusMap) { in __anonb4f3bed90f02() argument
587 result = statusMap; in __anonb4f3bed90f02()
|
| /ohos5.0/base/update/updateservice/services/core/ability/callback/src/ |
| H A D | base_callback_utils.cpp | 44 static std::map<UpgradeStatus, EventId> statusMap = { in ProgressCallback() local
59 for (auto iter = statusMap.begin(); iter != statusMap.end(); iter++) { in ProgressCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/common/ |
| H A D | distributeddb_tools_test.cpp | 141 [&statuses, &syncLock, &syncCondVar](const std::map<std::string, DBStatus>& statusMap) { in SyncTestWithQuery() argument
142 statuses = statusMap; in SyncTestWithQuery()
163 [&statuses, &syncLock, &syncCondVar](const std::map<std::string, DBStatus>& statusMap) { in SyncTest() argument
164 statuses = statusMap; in SyncTest()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| H A D | distributeddb_nb_autolaunch_test.cpp | 678 auto syncCallBack = [testDeviceName](const std::map<std::string, DBStatus> &statusMap) { in __anon463a8f8c0402() argument
679 auto iter = statusMap.find(testDeviceName); in __anon463a8f8c0402()
680 EXPECT_NE(iter, statusMap.end()); in __anon463a8f8c0402()
|
| H A D | distributeddb_nb_enable_sync_by_closed_db_test.cpp | 666 auto syncCallBack = [testDeviceName](const std::map<std::string, DBStatus> &statusMap) { in __anon8c0224f30402() argument
667 auto iter = statusMap.find(testDeviceName); in __anon8c0224f30402()
668 EXPECT_NE(iter, statusMap.end()); in __anon8c0224f30402()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 2297 [devices, this](const std::map<std::string, DBStatus>& statusMap) { in __anon195527440502() argument
2298 ASSERT_EQ(statusMap.size(), devices.size()); in __anon195527440502()
2299 for (const auto &pair : statusMap) { in __anon195527440502()
|