| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 64 if (process.downLoadInfo.batchIndex != 0u) { in UpdateProcess()
65 LOGD("[ProcessNotifier] update download process index: %" PRIu32, process.downLoadInfo.batchIndex); in UpdateProcess()
68 if (process.upLoadInfo.batchIndex != 0u) { in UpdateProcess()
69 LOGD("[ProcessNotifier] update upload process index: %" PRIu32, process.upLoadInfo.batchIndex); in UpdateProcess()
138 return syncProcess.tableProcess.at(tableName).upLoadInfo.batchIndex; in GetUploadBatchIndex()
153 syncProcess.tableProcess[tableName].upLoadInfo.batchIndex = 0; in ResetUploadBatchIndex()
|
| H A D | cloud_syncer_extend.cpp | 524 info.upLoadInfo.batchIndex++; in ChkIgnoredProcess()
941 uint32_t batchIndex = GetCurrentTableUploadBatchIndex(); in HandleBatchUpload() local
949 info.upLoadInfo.batchIndex = ++batchIndex; in HandleBatchUpload()
|
| H A D | cloud_syncer.cpp | 860 param.info.downLoadInfo.batchIndex += 1; in SaveData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_sync_utils_test.cpp | 178 LOGI("table[%s], table process status:%d, [downloadInfo](batchIndex:%u, total:%u, successCount:%u, " in GetCallback()
179 "failCount:%u) [uploadInfo](batchIndex:%u, total:%u, successCount:%u,failCount:%u", in GetCallback()
180 item.c_str(), table1->second.process, table1->second.downLoadInfo.batchIndex, in GetCallback()
182 table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
200 EXPECT_EQ(expect.second.downLoadInfo.batchIndex, real->second.downLoadInfo.batchIndex); in GetCallback()
204 EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 1899 EXPECT_EQ(info.upLoadInfo.batchIndex, expectProcess[index].upLoadInfo.batchIndex); in HWTEST_F()
2369 EXPECT_EQ(info.upLoadInfo.batchIndex, expectProcess[index].upLoadInfo.batchIndex); in HWTEST_F()
|
| H A D | distributeddb_cloud_kv_test.cpp | 997 * @tc.steps:step3. Check upLoadInfo.batchIndex of two users. in HWTEST_F()
998 * @tc.expected: Both users have a upLoadInfo.batchIndex of 1. in HWTEST_F()
1001 EXPECT_EQ(table.second.upLoadInfo.batchIndex, 1u); in HWTEST_F()
1483 EXPECT_EQ(table.second.upLoadInfo.batchIndex, 3u); in HWTEST_F()
1529 * @tc.steps:step3. sync and check upLoadInfo.batchIndex. in HWTEST_F()
1534 EXPECT_EQ(table.second.upLoadInfo.batchIndex, 2u); in HWTEST_F()
|
| /foundation/multimodalinput/input/service/event_resample/src/ |
| H A D | event_resample.cpp | 152 ssize_t batchIndex = FindBatch(inputEvent_.deviceId, inputEvent_.sourceType); in UpdateBatch() local
153 if (batchIndex >= 0) { in UpdateBatch()
154 Batch& batch = batches_.at(batchIndex); in UpdateBatch()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | store_types.h | 171 uint32_t batchIndex = 0; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 476 LOGI("table[%s], table process status:%d, [downloadInfo](batchIndex:%u, total:%u, successCount:%u, " in GetCallback()
477 "failCount:%u) [uploadInfo](batchIndex:%u, total:%u, successCount:%u,failCount:%u", in GetCallback()
478 item.c_str(), table1->second.process, table1->second.downLoadInfo.batchIndex, in GetCallback()
480 table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
498 EXPECT_EQ(expect.second.downLoadInfo.batchIndex, real->second.downLoadInfo.batchIndex); in GetCallback()
502 EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 440 if (actualInfo.batchIndex != expectInfo.batchIndex) { in CheckSyncCount()
635 EXPECT_EQ(actualUploadInfo.batchIndex, expectUploadInfo.batchIndex); in CheckUploadInfo()
646 EXPECT_EQ(actualDownloadInfo.batchIndex, expectDownloadInfo.batchIndex); in CheckDownloadInfo()
|
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 791 LOGI("table[%s], table process status:%d, [downloadInfo](batchIndex:%u, total:%u, successCount:%u, " in GetCallback()
792 "failCount:%u) [uploadInfo](batchIndex:%u, total:%u, successCount:%u,failCount:%u", in GetCallback()
793 item.c_str(), table1->second.process, table1->second.downLoadInfo.batchIndex, in GetCallback()
795 table1->second.downLoadInfo.failCount, table1->second.upLoadInfo.batchIndex, in GetCallback()
813 EXPECT_EQ(expect.second.downLoadInfo.batchIndex, real->second.downLoadInfo.batchIndex); in GetCallback()
817 EXPECT_EQ(expect.second.upLoadInfo.batchIndex, real->second.upLoadInfo.batchIndex); in GetCallback()
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 1177 EXPECT_EQ(table.second.upLoadInfo.batchIndex, 4u); in HWTEST_F()
|
| /foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/ |
| H A D | render_system.cpp | 1551 uint32_t batchIndex = 0;
1568 if (batchIndex == 0) {
1597 if (++batchIndex == MAX_BATCH_OBJECT_COUNT) {
1598 batchIndex = 0;
1690 uint32_t batchIndex = 0;
1701 if (batchIndex == 0) {
1734 meshData->submeshes[i].material, false, false, materialIndices[i], batchIndex, 1U, false);
1737 if (++batchIndex == MAX_BATCH_OBJECT_COUNT) {
1738 batchIndex = 0;
|