Home
last modified time | relevance | path

Searched refs:syncData (Results 1 – 22 of 22) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp769 CloudSyncData syncData(g_tableName);
777 syncData.insData.rowid.push_back(1);
803 syncData.tableName = "";
810 syncData.tableName = g_tableName;
817 syncData.insData.extend.clear();
827 syncData.insData.extend.pop_back();
838 syncData.tableName = "noneTable";
1093 CloudSyncData syncData(g_tableName);
1152 CloudSyncData syncData(g_tableName);
1204 CloudSyncData syncData(g_tableName);
[all …]
H A Ddistributeddb_storage_rd_single_ver_natural_executor_test.cpp513 NotifyMigrateSyncData syncData; variable
517 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
544 NotifyMigrateSyncData syncData; variable
548 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
552 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
555 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
557 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
559 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
561 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
567 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_NOT_SUPPORT);
[all …]
H A Ddistributeddb_storage_sqlite_single_ver_natural_executor_test.cpp910 NotifyMigrateSyncData syncData; variable
914 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), -E_INVALID_DB);
930 EXPECT_EQ(executor->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
935 EXPECT_EQ(executor->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
983 NotifyMigrateSyncData syncData; variable
987 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
1014 NotifyMigrateSyncData syncData; variable
1022 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
1027 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
1029 EXPECT_EQ(g_handle->MigrateSyncDataByVersion(0u, syncData, items), SQL_STATE_ERR);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_engine.cpp141 if (syncData.committedData == nullptr) { in MigrateSyncDataByVersion()
143 if (syncData.committedData == nullptr) { in MigrateSyncDataByVersion()
193 NotifyMigrateSyncData &syncData) in ReleaseHandleTransiently() argument
256 NotifyMigrateSyncData syncData; in MigrateSyncData() local
263 syncData.isPermitForceWrite = in MigrateSyncData()
277 if (!syncData.isRemote) { in MigrateSyncData()
281 if (syncData.committedData != nullptr) { in MigrateSyncData()
283 syncData.committedData = nullptr; in MigrateSyncData()
1050 const auto &isRemote = syncData.isRemote; in CommitNotifyForMigrateCache()
1052 auto &committedData = syncData.committedData; in CommitNotifyForMigrateCache()
[all …]
H A Dsqlite_single_ver_storage_engine.h81 NotifyMigrateSyncData &syncData);
86 NotifyMigrateSyncData &syncData, uint64_t &curMigrateVer);
119 void CommitNotifyForMigrateCache(NotifyMigrateSyncData &syncData) const;
H A Dsqlite_single_ver_storage_executor_cache.cpp257 …ingleVerStorageExecutor::MigrateDataItem(DataItem &dataItem, const NotifyMigrateSyncData &syncData) in MigrateDataItem() argument
261 notify.committedData = syncData.committedData; in MigrateDataItem()
263 syncData.isPermitForceWrite); in MigrateDataItem()
337 …torageExecutor::MigrateDataItems(std::vector<DataItem> &dataItems, NotifyMigrateSyncData &syncData) in MigrateDataItems() argument
339 syncData.isRemote = ((dataItems[0].flag & DataItem::LOCAL_FLAG) == 0); in MigrateDataItems()
340 syncData.isRemoveDeviceData = (dataItems[0].flag & DataItem::REMOVE_DEVICE_DATA_FLAG) != 0 || in MigrateDataItems()
352 if (syncData.isRemoveDeviceData) { in MigrateDataItems()
353 errCode = GetEntriesForNotifyRemoveDevData(item, syncData.entries); in MigrateDataItems()
370 errCode = MigrateDataItem(item, syncData); in MigrateDataItems()
381 …leVerStorageExecutor::MigrateSyncDataByVersion(uint64_t recordVer, NotifyMigrateSyncData &syncData, in MigrateSyncDataByVersion() argument
[all …]
H A Dsqlite_single_ver_storage_executor.h140 int MigrateSyncDataByVersion(uint64_t recordVer, NotifyMigrateSyncData &syncData,
313 int MigrateDataItems(std::vector<DataItem> &dataItems, NotifyMigrateSyncData &syncData);
315 int MigrateDataItem(DataItem &dataItem, const NotifyMigrateSyncData &syncData);
H A Dsqlite_cloud_kv_executor_utils.h146 static int GetCloudVersionRecord(bool isMemory, sqlite3_stmt *stmt, CloudSyncData &syncData);
148 …DefaultCloudVersionRecord(const std::string &key, const std::string &dev, CloudSyncData &syncData);
H A Dsqlite_cloud_kv_executor_utils.cpp1132 auto &[errCode, syncData] = res; in GetLocalCloudVersionInner()
1165 errCode = GetCloudVersionRecord(isMemory, stmt, syncData); in GetLocalCloudVersionInner()
1167 InitDefaultCloudVersionRecord(key, tempDev, syncData); in GetLocalCloudVersionInner()
1173 …dKvExecutorUtils::GetCloudVersionRecord(bool isMemory, sqlite3_stmt *stmt, CloudSyncData &syncData) in GetCloudVersionRecord() argument
1188 errCode = GetCloudDataForSync(config, recorder, stmt, syncData, detail); in GetCloudVersionRecord()
1193 CloudSyncData &syncData) in InitDefaultCloudVersionRecord() argument
1202 syncData.insData.record.push_back(std::move(defaultRecord)); in InitDefaultCloudVersionRecord()
1205 syncData.insData.extend.push_back(std::move(defaultExtend)); in InitDefaultCloudVersionRecord()
1206 syncData.insData.assets.emplace_back(); in InitDefaultCloudVersionRecord()
1209 syncData.insData.hashKey.push_back(bytesHashKey); in InitDefaultCloudVersionRecord()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Dmock_relational_sync_able_storage.h28 int CallFillReferenceData(CloudSyncData &syncData) in CallFillReferenceData() argument
30 return RelationalSyncAbleStorage::FillReferenceData(syncData); in CallFillReferenceData()
H A Ddistributeddb_cloud_save_cloud_data_test.cpp1429 CloudSyncData syncData("FillReferenceGid001"); variable
1432 EXPECT_EQ(syncData.tableName, tableName); in __anon2ff534420802()
1441 syncData.insData.rowid.push_back(1); // rowid is 1
1443 syncData.updData.rowid.push_back(2); // rowid is 2
1445 syncData.delData.rowid.push_back(3); // rowid is 3
1448 CheckCloudBatchData(syncData.insData, true);
1449 CheckCloudBatchData(syncData.updData, true);
1450 CheckCloudBatchData(syncData.delData, false);
1464 CloudSyncData syncData("FillReferenceGid002"); variable
1465 syncData.insData.rowid.push_back(1); // rowid is 1
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp661 SyncEntry &syncData, int sendCode, int mode) in FillDataRequestPacket() argument
684 packet->SetData(syncData.entries); in FillDataRequestPacket()
723 SyncEntry syncData; in RequestStart() local
725 errCode = GetMatchData(context, syncData); in RequestStart()
836 SyncEntry syncData; in PullResponseStart() local
838 int errCode = GetMatchData(context, syncData); in PullResponseStart()
1402 SyncEntry syncData; in ReSend() local
1497 SyncEntry syncData; in CheckPermitSendData() local
1655 int innerCode = InterceptData(syncData); in GetReSendData()
1666 … int compressCode = GenericSingleVerKvEntry::Compress(syncData.entries, syncData.compressedEntries, in GetReSendData()
[all …]
H A Dsingle_ver_data_sync.h142 SyncEntry &syncData, int sendCode, int mode);
223 int GetReSendData(SyncEntry &syncData, SingleVerSyncTaskContext *context,
231 DataSyncReSendInfo reSendInfo, SyncEntry &syncData, int sendCode);
/ohos5.0/foundation/communication/dsoftbus/core/common/dfx/interface/include/form/
H A Dtrans_event_form.h123 int32_t syncData; member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1542 int RelationalSyncAbleStorage::FillReferenceData(CloudSyncData &syncData) in FillReferenceData() argument
1545 int errCode = GetReferenceGid(syncData.tableName, syncData.insData, referenceGid); in FillReferenceData()
1550 …errCode = FillReferenceDataIntoExtend(syncData.insData.rowid, referenceGid, syncData.insData.exten… in FillReferenceData()
1555 errCode = GetReferenceGid(syncData.tableName, syncData.updData, referenceGid); in FillReferenceData()
1560 … return FillReferenceDataIntoExtend(syncData.updData.rowid, referenceGid, syncData.updData.extend); in FillReferenceData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp621 SyncEntry syncData {.entries = {kvEntry}}; variable
623 ASSERT_TRUE(GenericSingleVerKvEntry::Compress(syncData.entries, syncData.compressedEntries,
629 packet->SetData(syncData.entries);
630 packet->SetCompressData(syncData.compressedEntries);
/ohos5.0/foundation/communication/dsoftbus/core/common/dfx/event/src/convert/
H A Dtrans_event_converter.h131 TRANS_ALARM_ASSIGNER(Int32, SyncData, syncData)
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.h146 int MigrateSyncDataByVersion(uint64_t recordVer, NotifyMigrateSyncData &syncData,
H A Drd_single_ver_storage_executor.cpp590 …leVerStorageExecutor::MigrateSyncDataByVersion(uint64_t recordVer, NotifyMigrateSyncData &syncData, in MigrateSyncDataByVersion() argument
/ohos5.0/foundation/communication/dsoftbus/tests/core/common/dfx/event/unittest/
H A Dtrans_event_test.cpp221 .syncData = 13,
/ohos5.0/foundation/communication/dsoftbus/tests/core/common/dfx/event/unittest/mock/
H A Dtrans_hisysevent_matcher.h156 MatchTransAlarmNameTypeExtraInt32Param(params, ++index, extra.syncData);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h231 int FillReferenceData(CloudSyncData &syncData);