Home
last modified time | relevance | path

Searched refs:SQLiteSingleVerContinueToken (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_continue_token.cpp21 SQLiteSingleVerContinueToken::SQLiteSingleVerContinueToken(Timestamp begin, Timestamp end) in SQLiteSingleVerContinueToken() function in DistributedDB::SQLiteSingleVerContinueToken
25 SQLiteSingleVerContinueToken::SQLiteSingleVerContinueToken( in SQLiteSingleVerContinueToken() function in DistributedDB::SQLiteSingleVerContinueToken
32 SQLiteSingleVerContinueToken::SQLiteSingleVerContinueToken(MulDevTimeRanges timeRanges) in SQLiteSingleVerContinueToken() function in DistributedDB::SQLiteSingleVerContinueToken
36 SQLiteSingleVerContinueToken::~SQLiteSingleVerContinueToken() in ~SQLiteSingleVerContinueToken()
39 bool SQLiteSingleVerContinueToken::CheckValid() const in CheckValid()
49 Timestamp SQLiteSingleVerContinueToken::GetQueryEndTime() const in GetQueryEndTime()
84 void SQLiteSingleVerContinueToken::FinishGetQueryData() in FinishGetQueryData()
89 void SQLiteSingleVerContinueToken::FinishGetDeletedData() in FinishGetDeletedData()
104 bool SQLiteSingleVerContinueToken::IsQuerySync() const in IsQuerySync()
109 QueryObject SQLiteSingleVerContinueToken::GetQuery() const in GetQuery()
[all …]
H A Dsqlite_single_ver_continue_token.h25 class SQLiteSingleVerContinueToken {
28 SQLiteSingleVerContinueToken(Timestamp begin, Timestamp end);
31 SQLiteSingleVerContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObject);
34 explicit SQLiteSingleVerContinueToken(MulDevTimeRanges timeRanges);
36 ~SQLiteSingleVerContinueToken();
H A Dsqlite_cloud_kv_executor_utils.h34 SQLiteSingleVerContinueToken &token, CloudSyncData &data);
156 … static bool UpdateBeginTimeForMemoryDB(SQLiteSingleVerContinueToken &token, CloudSyncData &data);
H A Dsqlite_single_ver_natural_store.cpp53 SQLiteSingleVerContinueToken *&token) in ProcessContinueToken()
79 SQLiteSingleVerContinueToken *&token) in ProcessContinueToken()
88 SQLiteSingleVerContinueToken *&token) in ProcessContinueTokenForQuerySync()
661 auto token = new (std::nothrow) SQLiteSingleVerContinueToken(begin, end); in GetSyncData()
703 auto token = new (std::nothrow) SQLiteSingleVerContinueToken(timeRange, query); in GetSyncData()
733 SQLiteSingleVerContinueToken *&continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataForQuerySync()
795 auto token = static_cast<SQLiteSingleVerContinueToken *>(continueStmtToken); in GetSyncDataNext()
823 auto token = static_cast<SQLiteSingleVerContinueToken *>(continueStmtToken); in GetSyncDataNext()
851 auto token = static_cast<SQLiteSingleVerContinueToken *>(continueStmtToken); in ReleaseContinueToken()
H A Dsqlite_cloud_kv_store.cpp185 auto token = new (std::nothrow) SQLiteSingleVerContinueToken(timeRange, object); in GetCloudData()
203 auto token = static_cast<SQLiteSingleVerContinueToken *>(continueStmtToken); in GetCloudDataNext()
229 auto token = static_cast<SQLiteSingleVerContinueToken *>(continueStmtToken); in ReleaseCloudDataToken()
H A Dsqlite_single_ver_natural_store.h294 …int GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, SQLiteSingleVerContinueToken *&conti…
H A Dsqlite_cloud_kv_executor_utils.cpp28 const CloudUploadRecorder &recorder, SQLiteSingleVerContinueToken &token, CloudSyncData &data) in GetCloudData()
72 bool SqliteCloudKvExecutorUtils::UpdateBeginTimeForMemoryDB(SQLiteSingleVerContinueToken &token, Cl… in UpdateBeginTimeForMemoryDB()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_query_sync_test.cpp326 … ContinueToken token = new (std::nothrow) SQLiteSingleVerContinueToken{SyncTimeRange{}, queryObj};
344 …token = new (std::nothrow) SQLiteSingleVerContinueToken{SyncTimeRange{time3, 0, time3 + 1}, queryO…
363 …token = new (std::nothrow) SQLiteSingleVerContinueToken{SyncTimeRange{0, deleteBeginTime, 0, delet…