Home
last modified time | relevance | path

Searched refs:localWaterMark (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_upload_recorder.cpp47 Timestamp localWaterMark) in ReleaseUploadRecord() argument
52 if (it->second <= static_cast<int64_t>(localWaterMark)) { in ReleaseUploadRecord()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dmeta_data.cpp102 outValue = metadata.localWaterMark; in GetLocalWaterMark()
110 metadata.localWaterMark = inValue; in SaveLocalWaterMark()
405 WaterMark localWaterMark; in GetSendQueryWaterMark() local
406 GetLocalWaterMark(deviceId, localWaterMark); in GetSendQueryWaterMark()
407 waterMark = std::max(queryWaterMark.sendWaterMark, localWaterMark); in GetSendQueryWaterMark()
445 WaterMark localWaterMark; in GetSendDeleteSyncWaterMark() local
446 GetLocalWaterMark(deviceId, localWaterMark); in GetSendDeleteSyncWaterMark()
447 waterMark = std::max(deleteWaterMark.sendWaterMark, localWaterMark); in GetSendDeleteSyncWaterMark()
665 info.sendMark = metadata.localWaterMark; in GetWaterMarkInfoFromDB()
H A Dmeta_data.h33 uint64_t localWaterMark = 0; member
H A Dgeneric_syncer.cpp1040 uint64_t localWaterMark = 0; in GetSyncDataSize() local
1059 metadata->GetLocalWaterMark(device, localWaterMark); in GetSyncDataSize()
1064 …int errCode = static_cast<SyncGenericInterface *>(syncInterface_)->GetSyncData(localWaterMark, MAX… in GetSyncDataSize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp575 uint64_t localWaterMark = 0; in IsCurrentSyncTaskCanBeSkippedInner() local
576 int errCode = GetCorrectedSendWaterMarkForCurrentTask(operation, localWaterMark); in IsCurrentSyncTaskCanBeSkippedInner()
581 if (localWaterMark > maxTimestampInDb) { in IsCurrentSyncTaskCanBeSkippedInner()
583 STR_MASK(deviceId_), localWaterMark, maxTimestampInDb); in IsCurrentSyncTaskCanBeSkippedInner()
H A Dsingle_ver_serialize_manager.cpp452 WaterMark localWaterMark; in DataPacketSyncerPartDeSerialization() local
461 totPacketLen += parcel.ReadUInt64(localWaterMark); in DataPacketSyncerPartDeSerialization()
485 packet->SetLocalWaterMark(localWaterMark); in DataPacketSyncerPartDeSerialization()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_upload_recorder.h32 …eleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWaterMark);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h156 …eleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWaterMark);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp685 …ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWaterMark) in ReleaseUploadRecord() argument
691 store_->ReleaseUploadRecord(table, type, localWaterMark); in ReleaseUploadRecord()