| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| D | virtual_single_ver_sync_db_Interface.cpp | 32 …esFromItems(std::vector<SingleVerKvEntry *> &entries, const std::vector<VirtualDataItem> &dataItem… in GetEntriesFromItems()
130 …leVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
136 int VirtualSingleVerSyncDBInterface::GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToke… in GetSyncDataNext()
228 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
253 std::vector<VirtualDataItem> dataItems; in GetSyncDataNext() local
270 std::vector<VirtualDataItem> &dataItems, ContinueToken &continueStmtToken) const in GetSyncData()
302 int VirtualSingleVerSyncDBInterface::GetSyncDataNext(std::vector<VirtualDataItem>& dataItems, in GetSyncDataNext()
311 int VirtualSingleVerSyncDBInterface::PutSyncData(std::vector<VirtualDataItem>& dataItems, in PutSyncData()
407 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
482 std::vector<VirtualDataItem> dataItems; in PutSyncDataWithQuery() local
|
| 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
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| D | sqlite_single_ver_natural_store.cpp | 50 …void ProcessContinueToken(const DeviceID &deviceID, const std::vector<DataItem> &dataItems, int &e… in ProcessContinueToken()
76 void ProcessContinueToken(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken()
85 void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync()
133 …GetKvEntriesByDataItems(std::vector<SingleVerKvEntry *> &entries, std::vector<DataItem> &dataItems) in GetKvEntriesByDataItems()
150 …bool CanHoldDeletedData(const std::vector<DataItem> &dataItems, const DataSizeSpecInfo &dataSizeIn… in CanHoldDeletedData()
665 std::vector<DataItem> dataItems; in GetSyncData() local
691 …ingleVerNaturalStore::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
747 std::vector<DataItem> dataItems; in GetSyncData() local
769 int SQLiteSingleVerNaturalStore::GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, in GetSyncDataForQuerySync()
831 std::vector<DataItem> dataItems; in GetSyncDataNext() local
[all …]
|
| 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()
|
| 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()
|
| D | sqlite_single_ver_storage_engine.cpp | 127 const std::vector<DataItem> &dataItems) in EraseDeviceWaterMark()
177 std::vector<DataItem> dataItems; in MigrateSyncDataByVersion() local
|
| D | sqlite_single_ver_storage_executor.cpp | 515 int SQLiteSingleVerStorageExecutor::GetSyncDataItems(std::vector<DataItem> &dataItems, sqlite3_stmt… in GetSyncDataItems()
552 int SQLiteSingleVerStorageExecutor::GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t… in GetSyncDataByTimestamp()
566 int SQLiteSingleVerStorageExecutor::GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems,… in GetDeletedSyncDataByTimestamp()
581 int AppendDataItem(std::vector<DataItem> &dataItems, const DataItem &item, size_t &dataTotalSize, s… in AppendDataItem()
2001 …ingleVerStorageExecutor::GetAllDataItems(sqlite3_stmt *statement, std::vector<DataItem> &dataItems, in GetAllDataItems()
|
| D | sqlite_single_ver_relational_storage_executor.cpp | 1055 std::vector<DataItem> &dataItems, DataItem &&item) in AppendData()
1095 int SQLiteSingleVerRelationalStorageExecutor::GetSyncDataByQuery(std::vector<DataItem> &dataItems, … in GetSyncDataByQuery()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| D | relational_sync_able_storage.cpp | 293 …GetKvEntriesByDataItems(std::vector<SingleVerKvEntry *> &entries, std::vector<DataItem> &dataItems) in GetKvEntriesByDataItems()
321 static bool CanHoldDeletedData(const std::vector<DataItem> &dataItems, const DataSizeSpecInfo &data… in CanHoldDeletedData()
332 static void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync()
356 int RelationalSyncAbleStorage::GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, in GetSyncDataForQuerySync()
428 std::vector<DataItem> dataItems; in GetSyncDataNext() local
448 std::vector<DataItem> dataItems; in ConvertEntries() local
470 std::vector<DataItem> dataItems = ConvertEntries(entries); in PutSyncDataWithQuery() local
487 …onalSyncAbleStorage::SaveSyncDataItems(const QueryObject &object, std::vector<DataItem> &dataItems, in SaveSyncDataItems()
533 … RelationalSyncAbleStorage::PutSyncData(const QueryObject &query, std::vector<DataItem> &dataItems, in PutSyncData()
|
| 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()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| D | sync_generic_interface.h | 29 virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
54 virtual int GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken, in GetSyncDataNext()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| 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
|
| 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
|
| D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 253 std::vector<DataItem> dataItems; variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| D | intercepted_data_impl.cpp | 64 InterceptedDataImpl::InterceptedDataImpl(std::vector<SingleVerKvEntry *> dataItems, in InterceptedDataImpl()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| D | distributeddb_tools_unit_test.cpp | 573 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataTest()
585 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataNextTest()
596 const std::vector<DataItem> &dataItems, const std::string &deviceName) in PutSyncDataTest()
603 const std::vector<DataItem> &dataItems, const std::string &deviceName, const QueryObject &query) in PutSyncDataTest()
623 …utedDBToolsUnitTest::ConvertItemsToSingleVerEntry(const std::vector<DistributedDB::DataItem> &data… in ConvertItemsToSingleVerEntry()
640 std::vector<DistributedDB::DataItem> &dataItems) in ConvertSingleVerEntryToItems()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| D | distributeddb_interfaces_device_identifier_test.cpp | 495 std::vector<DataItem> dataItems; variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| D | multi_ver_data_sync.cpp | 630 const std::vector<MultiVerKvEntry *> &dataItems, int retCode, const Message *message) in SendAckPacket()
|
| D | single_ver_serialize_manager.cpp | 363 std::vector<SendDataItem> dataItems; in DataPacketDeSerialization() local
|