Home
last modified time | relevance | path

Searched refs:tableProcess (Results 1 – 17 of 17) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dprocess_notifier.cpp52 syncProcess.tableProcess[table] = tableInfo; in InitSyncProcess()
135 if (syncProcess.tableProcess.find(tableName) == syncProcess.tableProcess.end()) { in GetUploadBatchIndex()
138 return syncProcess.tableProcess.at(tableName).upLoadInfo.batchIndex; in GetUploadBatchIndex()
148 if (syncProcess.tableProcess.find(tableName) == syncProcess.tableProcess.end()) { in ResetUploadBatchIndex()
152 syncProcess.tableProcess[tableName].upLoadInfo.batchIndex = 0; in ResetUploadBatchIndex()
159 if (syncProcess.tableProcess.find(tableName) == syncProcess_.tableProcess.end()) { in GetLastUploadSuccessCount()
162 return syncProcess.tableProcess.at(tableName).upLoadInfo.successCount; in GetLastUploadSuccessCount()
178 if (syncProcess.tableProcess.find(process.tableName) != syncProcess.tableProcess.end()) { in GetDownloadInfoByTableName()
191 for (auto &item : syncProcess_.tableProcess) { in SetAllTableFinish()
195 for (auto &item : syncProcess.second.tableProcess) { in SetAllTableFinish()
[all …]
H A Dcloud_syncer_extend.cpp1199 syncProcess.tableProcess = notifier->GetCurrentTableProcess(); in GetCloudTaskStatus()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_db_sync_utils_test.cpp173 ASSERT_NE(syncProcess.tableProcess.empty(), true); in GetCallback()
176 auto table1 = syncProcess.tableProcess.find(item); in GetCallback()
177 if (table1 != syncProcess.tableProcess.end()) { in GetCallback()
196 for (auto &expect : head.tableProcess) { in GetCallback()
197 auto real = syncProcess.tableProcess.find(expect.first); in GetCallback()
198 ASSERT_NE(real, syncProcess.tableProcess.end()); in GetCallback()
H A Ddistributeddb_cloud_kv_test.cpp328 for (const auto &table : lastProcess_.tableProcess) {
333 for (const auto &table : lastProcess_.tableProcess) {
616 for (const auto &table : lastProcess_.tableProcess) {
627 for (const auto &table : lastProcess_.tableProcess) {
635 for (const auto &table : lastProcess_.tableProcess) {
771 for (const auto &table : lastProcess_.tableProcess) {
939 for (const auto &table : lastProcess_.tableProcess) {
965 for (const auto &table : lastProcess_.tableProcess) {
1183 for (const auto &table : lastProcess_.tableProcess) {
1228 for (const auto &table : lastProcess_.tableProcess) {
[all …]
H A Dcloud_syncer_test.h169 …return this->process_[taskId].tableProcess[this->GetCurrentContextTableName()].upLoadInfo.successC… in GetUploadSuccessCount()
174 …return this->process_[taskId].tableProcess[this->GetCurrentContextTableName()].upLoadInfo.failCoun… in GetUploadFailCount()
H A Ddistributeddb_cloud_kv_syncer_test.cpp625 std::map<std::string, TableProcessInfo> tableProcess(item.second.tableProcess); in __anon644cd9970e02() local
626 insertCount = tableProcess["sync_data"].downLoadInfo.insertCount; in __anon644cd9970e02()
H A Ddistributeddb_cloud_syncer_lock_test.cpp613 for (const auto &table : g_syncProcess.tableProcess) {
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp2288 for (const auto &[tableName, info]: g_syncProcess.tableProcess) { in __anon32d7e6602e02()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp455 … syncProcess.tableProcess.insert_or_assign(g_tables[0], std::move(infos[g_arrayHalfSub * i])); in InitProcessForCleanCloudData1()
456 … syncProcess.tableProcess.insert_or_assign(g_tables[1], std::move(infos[g_arrayHalfSub * i + 1])); in InitProcessForCleanCloudData1()
470 ASSERT_NE(syncProcess.tableProcess.empty(), true); in GetCallback()
473 auto table1 = syncProcess.tableProcess.find(item); in GetCallback()
474 if (table1 != syncProcess.tableProcess.end()) { in GetCallback()
493 for (auto &expect : head.tableProcess) { in GetCallback()
494 auto real = syncProcess.tableProcess.find(expect.first); in GetCallback()
495 ASSERT_NE(real, syncProcess.tableProcess.end()); in GetCallback()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_interfaces_relational_sync_test.cpp646 … syncProcess.tableProcess.insert_or_assign(g_tables[0], std::move(infos[g_arrayHalfSub * i])); in InitProcessForTest1()
647 … syncProcess.tableProcess.insert_or_assign(g_tables[1], std::move(infos[g_arrayHalfSub * i + 1])); in InitProcessForTest1()
684 … syncProcess.tableProcess.insert_or_assign(g_tables[0], std::move(infos[g_arrayHalfSub * i])); in InitProcessForMannualSync1()
728 … syncProcess.tableProcess.insert_or_assign(g_tables[0], std::move(infos[g_arrayHalfSub * i])); in InitProcessForTest2()
772 … syncProcess.tableProcess.insert_or_assign(g_tables[0], std::move(infos[g_arrayHalfSub * i])); in InitProcessForTest9()
786 ASSERT_NE(syncProcess.tableProcess.empty(), true); in GetCallback()
789 auto table1 = syncProcess.tableProcess.find(item); in GetCallback()
790 if (table1 != syncProcess.tableProcess.end()) { in GetCallback()
809 for (auto &expect : head.tableProcess) { in GetCallback()
810 auto real = syncProcess.tableProcess.find(expect.first); in GetCallback()
[all …]
H A Ddistributeddb_cloud_task_merge_test.cpp435 EXPECT_EQ(item.second.tableProcess.size(), 1u); in __anonb94ae3c60f02()
436 for (const auto &table : item.second.tableProcess) { in __anonb94ae3c60f02()
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp1058 for (const auto &table : lastProcess_.tableProcess) {
1097 for (const auto &table : lastProcess_.tableProcess) {
1134 for (const auto &table : lastProcess_.tableProcess) {
H A Ddistributeddb_cloud_check_sync_test.cpp443 for (const auto &itInner : actualSyncProcess.tableProcess) { in CheckSyncProcess()
445 … if (expectSyncProcess.tableProcess.find(tableName) == expectSyncProcess.tableProcess.end()) { in CheckSyncProcess()
449 … TableProcessInfo expectTableProcessInfo = expectSyncProcess.tableProcess.find(tableName)->second; in CheckSyncProcess()
823 retSyncProcess = lastProcess->second.tableProcess; in __anonc8f560be1202()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dstore_types.h188 std::map<std::string, TableProcessInfo> tableProcess; member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_multi_sub_user_test.cpp637 for (const auto &table : lastProcess_.tableProcess) {
641 for (const auto &table : lastProcess_.tableProcess) {
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_general_store.cpp680 for (auto [key, value] : process.tableProcess) { in GetDBProcessCB()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp745 for (auto [key, value] : process.tableProcess) { in GetDBProcessCB()