| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_single_ver_sync_db_Interface.cpp | 33 …esFromItems(std::vector<SingleVerKvEntry *> &entries, const std::vector<VirtualDataItem> &dataItem… in GetEntriesFromItems()
132 …leVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
138 int VirtualSingleVerSyncDBInterface::GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToke… in GetSyncDataNext()
230 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
255 std::vector<VirtualDataItem> dataItems; in GetSyncDataNext() local
272 std::vector<VirtualDataItem> &dataItems, ContinueToken &continueStmtToken) const in GetSyncData()
304 int VirtualSingleVerSyncDBInterface::GetSyncDataNext(std::vector<VirtualDataItem>& dataItems, in GetSyncDataNext()
313 int VirtualSingleVerSyncDBInterface::PutSyncData(std::vector<VirtualDataItem>& dataItems, in PutSyncData()
417 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
499 std::vector<VirtualDataItem> dataItems; in PutSyncDataWithQuery() local
|
| H A D | virtual_relational_ver_sync_db_interface.cpp | 26 …tEntriesFromItems(std::vector<SingleVerKvEntry *> &entries, const std::vector<DataItem> &dataItems) in GetEntriesFromItems()
76 std::vector<DataItem> dataItems; in PutSyncDataWithQuery() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store.cpp | 52 …void ProcessContinueToken(const DeviceID &deviceID, const std::vector<DataItem> &dataItems, int &e… in ProcessContinueToken()
78 void ProcessContinueToken(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken()
87 void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync()
135 …GetKvEntriesByDataItems(std::vector<SingleVerKvEntry *> &entries, std::vector<DataItem> &dataItems) in GetKvEntriesByDataItems()
152 …bool CanHoldDeletedData(const std::vector<DataItem> &dataItems, const DataSizeSpecInfo &dataSizeIn… in CanHoldDeletedData()
628 std::vector<DataItem> dataItems; in GetSyncData() local
710 std::vector<DataItem> dataItems; in GetSyncData() local
732 int SQLiteSingleVerNaturalStore::GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, in GetSyncDataForQuerySync()
794 std::vector<DataItem> dataItems; in GetSyncDataNext() local
873 std::vector<DataItem> dataItems; in PutSyncDataWithQuery() local
[all …]
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 127 std::vector<DataItem> &dataItems, uint64_t &minVerIncurCacheDb) const in GetMinVersionCacheData()
302 int SQLiteSingleVerStorageExecutor::CheckDataWithQuery(std::vector<DataItem> &dataItems) in CheckDataWithQuery()
337 int SQLiteSingleVerStorageExecutor::MigrateDataItems(std::vector<DataItem> &dataItems, NotifyMigrat… in MigrateDataItems()
382 std::vector<DataItem> &dataItems) in MigrateSyncDataByVersion()
842 …iteSingleVerStorageExecutor::ProcessTimestampForSyncDataInCacheDB(std::vector<DataItem> &dataItems) in ProcessTimestampForSyncDataInCacheDB()
|
| H A D | sqlite_single_ver_storage_executor_subscribe.cpp | 75 const DeviceInfo &deviceInfo, std::vector<DataItem> &dataItems) in CheckMissQueryDataItems()
96 …teSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, in CheckDataWithQuery()
|
| H A D | sqlite_single_ver_storage_engine.cpp | 100 const std::vector<DataItem> &dataItems) in EraseDeviceWaterMark()
150 std::vector<DataItem> dataItems; in MigrateSyncDataByVersion() local
|
| H A D | sqlite_single_ver_storage_executor.cpp | 500 int SQLiteSingleVerStorageExecutor::GetSyncDataItems(std::vector<DataItem> &dataItems, sqlite3_stmt… in GetSyncDataItems()
537 int SQLiteSingleVerStorageExecutor::GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t… in GetSyncDataByTimestamp()
551 int SQLiteSingleVerStorageExecutor::GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems,… in GetDeletedSyncDataByTimestamp()
566 int AppendDataItem(std::vector<DataItem> &dataItems, const DataItem &item, size_t &dataTotalSize, s… in AppendDataItem()
1963 …ingleVerStorageExecutor::GetAllDataItems(sqlite3_stmt *statement, std::vector<DataItem> &dataItems, in GetAllDataItems()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | sync_generic_interface.h | 30 virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
55 virtual int GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken, in GetSyncDataNext()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_register_observer_test.cpp | 693 static void PreSyncDataForRegisterObserver014(Timestamp time, vector<DataItem> &dataItems) in PreSyncDataForRegisterObserver014()
757 vector<DataItem> dataItems; variable
805 vector<DataItem> dataItems; variable
|
| H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 189 std::vector<DataItem> dataItems; variable
|
| H A D | distributeddb_storage_single_ver_natural_store_testcase.cpp | 191 std::vector<DataItem> dataItems; in GetSyncData004() local
249 std::vector<DataItem> dataItems; in GetSyncData005() local
285 std::vector<DataItem> dataItems; in GetSyncData006() local
|
| H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 257 std::vector<DataItem> dataItems; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | intercepted_data_impl.cpp | 64 InterceptedDataImpl::InterceptedDataImpl(std::vector<SingleVerKvEntry *> dataItems, in InterceptedDataImpl()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_storage_executor.cpp | 506 int RdSingleVerStorageExecutor::GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t app… in GetSyncDataByTimestamp()
512 int RdSingleVerStorageExecutor::GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, siz… in GetDeletedSyncDataByTimestamp()
591 std::vector<DataItem> &dataItems) in MigrateSyncDataByVersion()
596 int RdSingleVerStorageExecutor::GetMinVersionCacheData(std::vector<DataItem> &dataItems, in GetMinVersionCacheData()
652 …RdSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, in CheckDataWithQuery()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.cpp | 25 const std::vector<FieldInfo> &fieldInfoList, std::vector<DataItem> &dataItems) in TransformTableData()
41 int DataTransformer::TransformDataItem(const std::vector<DataItem> &dataItems, in TransformDataItem()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 340 …GetKvEntriesByDataItems(std::vector<SingleVerKvEntry *> &entries, std::vector<DataItem> &dataItems) in GetKvEntriesByDataItems()
368 static bool CanHoldDeletedData(const std::vector<DataItem> &dataItems, const DataSizeSpecInfo &data… in CanHoldDeletedData()
379 static void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync()
403 int RelationalSyncAbleStorage::GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, in GetSyncDataForQuerySync()
475 std::vector<DataItem> dataItems; in GetSyncDataNext() local
495 std::vector<DataItem> dataItems; in ConvertEntries() local
517 std::vector<DataItem> dataItems = ConvertEntries(entries); in PutSyncDataWithQuery() local
534 …onalSyncAbleStorage::SaveSyncDataItems(const QueryObject &object, std::vector<DataItem> &dataItems, in SaveSyncDataItems()
576 … RelationalSyncAbleStorage::PutSyncData(const QueryObject &query, std::vector<DataItem> &dataItems, in PutSyncData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 576 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataTest()
588 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataNextTest()
599 const std::vector<DataItem> &dataItems, const std::string &deviceName) in PutSyncDataTest()
606 const std::vector<DataItem> &dataItems, const std::string &deviceName, const QueryObject &query) in PutSyncDataTest()
626 …utedDBToolsUnitTest::ConvertItemsToSingleVerEntry(const std::vector<DistributedDB::DataItem> &data… in ConvertItemsToSingleVerEntry()
643 std::vector<DistributedDB::DataItem> &dataItems) in ConvertSingleVerEntryToItems()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_device_identifier_test.cpp | 495 std::vector<DataItem> dataItems; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_data_sync.cpp | 632 const std::vector<MultiVerKvEntry *> &dataItems, int retCode, const Message *message) in SendAckPacket()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1123 std::vector<DataItem> &dataItems, DataItem &&item) in AppendData()
1163 int SQLiteSingleVerRelationalStorageExecutor::GetSyncDataByQuery(std::vector<DataItem> &dataItems, … in GetSyncDataByQuery()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 358 std::vector<SendDataItem> dataItems; in DataPacketDeSerialization() local
|