Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.cpp77 timeRange_.deleteEndTime = 0; in FinishGetData()
87 …meRange_.beginTime >= timeRange_.endTime && timeRange_.deleteBeginTime >= timeRange_.deleteEndTime; in IsGetAllDataFinished()
128 …errCode = SQLiteUtils::BindInt64ToStatement(stmt, 2, timeRange_.deleteEndTime); // 2 means end time in GetDeletedDataStmt()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_types.h143 Timestamp deleteEndTime = static_cast<Timestamp>(INT64_MAX); member
147 return (beginTime <= endTime && deleteBeginTime <= deleteEndTime); in IsValid()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp220 …reSendInfo.end, reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, sequenceId, reSendInfo.packe… in ReSendData()
223 reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, reSendInfo.packetId}; in ReSendData()
489 if (deleteDataWaterMark >= dataTimeRange.deleteEndTime) { in SaveLocalWaterMark()
503 dataTimeRange.deleteEndTime); in SaveLocalWaterMark()
504 …e = metadata_->SetSendDeleteSyncWaterMark(context->GetDeleteSyncId(), dataTimeRange.deleteEndTime); in SaveLocalWaterMark()
644 reSendInfo.deleteEndTime = dataTimeRange.deleteEndTime; in UpdateSendInfo()
656 …reSendInfo.start, reSendInfo.end, reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, maxSequenc… in UpdateSendInfo()
742 SetSessionEndTimestamp(std::max(dataTime.endTime, dataTime.deleteEndTime)); in RequestStart()
857 SetSessionEndTimestamp(std::max(dataTime.endTime, dataTime.deleteEndTime)); in PullResponseStart()
879 WaterMark tmpPeerDeletedWatermark = dataTime.deleteEndTime; in UpdateQueryPeerWaterMark()
[all …]
H A Dsingle_ver_data_sync_utils.cpp446 if (dataTimeRange.deleteEndTime < tempStamp) { in GetQuerySyncDataTimeRange()
447 dataTimeRange.deleteEndTime = tempStamp; in GetQuerySyncDataTimeRange()
463 tmpDataTime.deleteEndTime += 1; in ReviseLocalMark()
H A Dsingle_ver_data_sync.h37 Timestamp deleteEndTime = 0; member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_continue_token.cpp29 … deleteTimeRanges_(MulDevTimeRanges{{"", {timeRange.deleteBeginTime, timeRange.deleteEndTime}}})
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_query_sync_test.cpp293 Timestamp deleteEndTime = g_store->GetCurrentTimestamp(); variable
294 …EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{0, deleteBeginTime, 0, deleteEndTime}, spec…
362 Timestamp deleteEndTime = g_store->GetCurrentTimestamp(); variable
363 …ew (std::nothrow) SQLiteSingleVerContinueToken{SyncTimeRange{0, deleteBeginTime, 0, deleteEndTime},
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.cpp425 … if (data.timestamp >= timeRange.deleteBeginTime && data.timestamp < timeRange.deleteEndTime) { in GetSyncData()