Home
last modified time | relevance | path

Searched refs:GetSyncData (Results 1 – 21 of 21) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_query_sync_test.cpp218 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
226 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
258 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
275 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{time3, 0, time3 + 1, 0},
390 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
471 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
524 g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries);
572 g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries);
668 EXPECT_EQ(g_store->GetSyncData(queryObj2, SyncTimeRange{}, specInfo, token, entries), E_OK);
741 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
[all …]
H A Ddistributeddb_relational_get_data_test.cpp388 int errCode = store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries);
444 EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries), E_OK);
494 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
520 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
575 int errCode = store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries);
934 EXPECT_EQ(store->GetSyncData(query, timeRange, DataSizeSpecInfo {}, token, entries), E_OK);
976 EXPECT_EQ(store->GetSyncData(query, timeRange, DataSizeSpecInfo {}, token, entries), E_OK);
1279 int errCode = store->GetSyncData(query, {}, sizeInfo, token, entries);
1289 store->GetSyncData(query2, {}, sizeInfo, token, entries2);
1473 EXPECT_EQ(store->GetSyncData(query, {}, DataSizeSpecInfo {}, token, entries), E_OK);
[all …]
H A Ddistributeddb_relational_encrypted_db_test.cpp265 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
367 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
423 … EXPECT_NE(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
444 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
H A Ddistributeddb_storage_subscribe_query_test.cpp742 EXPECT_EQ(store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h65 int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems,
77 int GetSyncData(const Key& key, VirtualDataItem& dataItem);
83 int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries,
86 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
153 int GetSyncData(Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo,
H A Dvirtual_single_ver_sync_db_Interface.cpp132 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataIt… in GetSyncData() function in DistributedDB::VirtualSingleVerSyncDBInterface
207 int VirtualSingleVerSyncDBInterface::GetSyncData(const Key &key, VirtualDataItem &dataItem) in GetSyncData() function in DistributedDB::VirtualSingleVerSyncDBInterface
226 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, in GetSyncData() function in DistributedDB::VirtualSingleVerSyncDBInterface
231 int errCode = GetSyncData(begin, end, dataSizeInfo, dataItems, continueStmtToken); in GetSyncData()
271 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, const DataSizeSpec… in GetSyncData() function in DistributedDB::VirtualSingleVerSyncDBInterface
402 int VirtualSingleVerSyncDBInterface::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData() function in DistributedDB::VirtualSingleVerSyncDBInterface
H A Drelational_virtual_device.h33 int GetSyncData(const std::string &tableName, const std::string &hashKey, VirtualRowData &data);
H A Drelational_virtual_device.cpp37 int RelationalVirtualDevice::GetSyncData(const std::string &tableName, in GetSyncData() function in DistributedDB::RelationalVirtualDevice
H A Dkv_virtual_device.cpp32 return syncAble->GetSyncData(key, item); in GetData()
H A Dvirtual_relational_ver_sync_db_interface.h57 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
H A Dvirtual_relational_ver_sync_db_interface.cpp124 int VirtualRelationalVerSyncDBInterface::GetSyncData(QueryObject &query, in GetSyncData() function in DistributedDB::VirtualRelationalVerSyncDBInterface
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp411 …void GetSyncData(sqlite3 *db, std::map<std::string, DataValue> &dataMap, const std::string &tableN… in GetSyncData() function
499 GetSyncData(db, dataMap, tableName, fieldInfoList); in CheckData()
2845 GetSyncData(db, dataMap, g_tableName, g_fieldInfoList);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h30 virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData() function
40 … virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries, in GetSyncData() function
48 virtual int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store.h77 …int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, ContinueToken &c…
80 int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries,
83 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
H A Dsqlite_single_ver_natural_store.cpp619 int SQLiteSingleVerNaturalStore::GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerK… in GetSyncData() function in DistributedDB::SQLiteSingleVerNaturalStore
629 errCode = GetSyncData(begin, end, dataItems, continueStmtToken, dataSizeInfo); in GetSyncData()
654 int SQLiteSingleVerNaturalStore::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> … in GetSyncData() function in DistributedDB::SQLiteSingleVerNaturalStore
689 int SQLiteSingleVerNaturalStore::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData() function in DistributedDB::SQLiteSingleVerNaturalStore
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_auto_launch_test.cpp318 void GetSyncData(const std::string &storeId) in GetSyncData() function
329 …kvStore->GetSyncData(0, UINT64_MAX / 2, entries, token, syncDataSizeInfo); // half of the max time… in GetSyncData()
670 GetSyncData(storeId); in DelayAutoLaunchCycle()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h79 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp376 … errCode = storage_->GetSyncData(waterMarkInfo.beginTime, waterMarkInfo.endTime, outData, token, in GetUnsyncData()
380 errCode = storage_->GetSyncData(queryObj, waterMarkInfo, syncDataSizeInfo, token, outData); in GetUnsyncData()
1635 … errCode = storage_->GetSyncData(reSendInfo.start, reSendInfo.end + 1, syncData.entries, token, in GetReSendData()
1639 …errCode = storage_->GetSyncData(queryObj, SyncTimeRange { reSendInfo.start, reSendInfo.deleteDataS… in GetReSendData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp1064 …int errCode = static_cast<SyncGenericInterface *>(syncInterface_)->GetSyncData(localWaterMark, MAX… in GetSyncDataSize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.cpp580 int errCode = store->GetSyncData(syncInputArg.begin_, syncInputArg.end_, entries, in GetSyncDataTest()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp441 int RelationalSyncAbleStorage::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData() function in DistributedDB::RelationalSyncAbleStorage