| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 68 if (process.upLoadInfo.batchIndex != 0u) { in UpdateProcess()
69 … LOGD("[ProcessNotifier] update upload process index: %" PRIu32, process.upLoadInfo.batchIndex); in UpdateProcess()
70 syncProcess.tableProcess[process.tableName].upLoadInfo = process.upLoadInfo; in UpdateProcess()
138 return syncProcess.tableProcess.at(tableName).upLoadInfo.batchIndex; in GetUploadBatchIndex()
152 syncProcess.tableProcess[tableName].upLoadInfo.batchIndex = 0; in ResetUploadBatchIndex()
162 return syncProcess.tableProcess.at(tableName).upLoadInfo.successCount; in GetLastUploadSuccessCount()
|
| H A D | cloud_syncer_extend.cpp | 52 info.upLoadInfo.total = static_cast<uint32_t>(param.count); in ReloadUploadInfoIfNeed()
63 info.upLoadInfo.total += lastSuccessCount; in ReloadUploadInfoIfNeed()
64 info.upLoadInfo.successCount += lastSuccessCount; in ReloadUploadInfoIfNeed()
145 info.upLoadInfo.failCount = info.upLoadInfo.total - info.upLoadInfo.successCount; in NotifyUploadFailed()
155 innerProcessInfo.upLoadInfo.insertCount += insertInfo.successCount; in BatchInsert()
200 innerProcessInfo.upLoadInfo.updateCount += updateInfo.successCount; in BatchUpdate()
490 …if (info.upLoadInfo.successCount + info.upLoadInfo.failCount != info.upLoadInfo.total) { // LCOV_E… in ChkIgnoredProcess()
497 info.upLoadInfo.batchIndex++; in ChkIgnoredProcess()
675 innerProcessInfo.upLoadInfo.total = 0; // count is zero in UpdateProcessInfoWithoutUpload()
929 info.upLoadInfo.batchIndex = ++batchIndex; in HandleBatchUpload()
[all …]
|
| H A D | icloud_syncer.h | 54 Info upLoadInfo; member
|
| H A D | cloud_syncer.cpp | 1239 bool lastBatch = innerProcessInfo.upLoadInfo.successCount == innerProcessInfo.upLoadInfo.total; in DoBatchUpload()
1319 innerProcessInfo.upLoadInfo.total); in PreProcessBatchUpload()
1327 ret = CloudSyncUtils::UpdateExtendTime(uploadData, innerProcessInfo.upLoadInfo.total, in PreProcessBatchUpload()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_sync_utils_test.cpp | 182 … table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
183 table1->second.upLoadInfo.total, table1->second.upLoadInfo.successCount, in GetCallback()
184 table1->second.upLoadInfo.failCount); in GetCallback()
204 … EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
205 EXPECT_EQ(expect.second.upLoadInfo.total, real->second.upLoadInfo.total); in GetCallback()
206 … EXPECT_EQ(expect.second.upLoadInfo.successCount, real->second.upLoadInfo.successCount); in GetCallback()
207 … EXPECT_EQ(expect.second.upLoadInfo.failCount, real->second.upLoadInfo.failCount); in GetCallback()
|
| H A D | distributeddb_cloud_kv_test.cpp | 329 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
617 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
628 EXPECT_EQ(table.second.upLoadInfo.total, 2u);
772 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
966 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
1186 EXPECT_EQ(table.second.upLoadInfo.total, 0u);
1229 EXPECT_EQ(table.second.upLoadInfo.total, 10u);
1272 EXPECT_EQ(table.second.upLoadInfo.total, 3u);
1377 EXPECT_EQ(table.second.upLoadInfo.total, 10u);
2639 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
[all …]
|
| H A D | cloud_syncer_test.h | 169 …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 D | distributeddb_cloud_syncer_download_assets_test.cpp | 2290 EXPECT_EQ(info.upLoadInfo.batchIndex, expectProcess[index].upLoadInfo.batchIndex); in __anon32d7e6602e02()
2291 EXPECT_EQ(info.upLoadInfo.total, expectProcess[index].upLoadInfo.total); in __anon32d7e6602e02()
2292 EXPECT_EQ(info.upLoadInfo.successCount, expectProcess[index].upLoadInfo.successCount); in __anon32d7e6602e02()
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 614 EXPECT_EQ(table.second.upLoadInfo.failCount, 0u);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 1059 EXPECT_EQ(table.second.upLoadInfo.total, 10u);
1060 EXPECT_EQ(table.second.upLoadInfo.failCount, 3u);
1061 EXPECT_EQ(table.second.upLoadInfo.successCount, 7u);
1098 EXPECT_EQ(table.second.upLoadInfo.total, 5u);
1099 EXPECT_EQ(table.second.upLoadInfo.failCount, 0u);
1100 EXPECT_EQ(table.second.upLoadInfo.successCount, 5u);
1135 EXPECT_EQ(table.second.upLoadInfo.batchIndex, 4u);
1136 EXPECT_EQ(table.second.upLoadInfo.total, 70u);
1137 EXPECT_EQ(table.second.upLoadInfo.failCount, 0u);
1138 EXPECT_EQ(table.second.upLoadInfo.successCount, 70u);
|
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 795 … table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
796 table1->second.upLoadInfo.total, table1->second.upLoadInfo.successCount, in GetCallback()
797 table1->second.upLoadInfo.failCount); in GetCallback()
817 … EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
818 EXPECT_EQ(expect.second.upLoadInfo.total, real->second.upLoadInfo.total); in GetCallback()
819 … EXPECT_EQ(expect.second.upLoadInfo.successCount, real->second.upLoadInfo.successCount); in GetCallback()
820 … EXPECT_EQ(expect.second.upLoadInfo.failCount, real->second.upLoadInfo.failCount); in GetCallback()
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 453 … if (!CheckSyncCount(actualTableProcessInfo.upLoadInfo, expectTableProcessInfo.upLoadInfo)) { in CheckSyncProcess()
856 ASSERT_EQ(taskInfo->second.upLoadInfo.total, 30u);
|
| /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 | 479 … table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
480 table1->second.upLoadInfo.total, table1->second.upLoadInfo.successCount, in GetCallback()
481 table1->second.upLoadInfo.failCount); in GetCallback()
501 … EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
502 EXPECT_EQ(expect.second.upLoadInfo.total, real->second.upLoadInfo.total); in GetCallback()
503 … EXPECT_EQ(expect.second.upLoadInfo.successCount, real->second.upLoadInfo.successCount); in GetCallback()
504 … EXPECT_EQ(expect.second.upLoadInfo.failCount, real->second.upLoadInfo.failCount); in GetCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | store_types.h | 182 Info upLoadInfo; member
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.cpp | 682 table.upload.total = value.upLoadInfo.total; in GetDBProcessCB()
683 table.upload.success = value.upLoadInfo.successCount; in GetDBProcessCB()
684 table.upload.failed = value.upLoadInfo.failCount; in GetDBProcessCB()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 747 table.upload.total = value.upLoadInfo.total; in GetDBProcessCB()
748 table.upload.success = value.upLoadInfo.successCount; in GetDBProcessCB()
749 table.upload.failed = value.upLoadInfo.failCount; in GetDBProcessCB()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 638 EXPECT_EQ(table.second.upLoadInfo.total, 1u);
|