Home
last modified time | relevance | path

Searched refs:peerWaterMark (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dmeta_data.cpp120 outValue = metadata.peerWaterMark; in GetPeerWaterMark()
128 metadata.peerWaterMark = inValue; in SavePeerWaterMark()
384 WaterMark peerWaterMark; in GetRecvQueryWaterMark() local
385 GetPeerWaterMark(deviceId, peerWaterMark); in GetRecvQueryWaterMark()
386 waterMark = std::max(queryWaterMark.recvWaterMark, peerWaterMark); in GetRecvQueryWaterMark()
466 WaterMark peerWaterMark; in GetRecvDeleteSyncWaterMark() local
467 GetPeerWaterMark(deviceId, peerWaterMark); in GetRecvDeleteSyncWaterMark()
468 waterMark = std::max(deleteWaterMark.recvWaterMark, peerWaterMark); in GetRecvDeleteSyncWaterMark()
666 info.receiveMark = metadata.peerWaterMark; in GetWaterMarkInfoFromDB()
H A Dmeta_data.h34 uint64_t peerWaterMark = 0; member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.cpp453 WaterMark peerWaterMark; in DataPacketSyncerPartDeSerialization() local
462 totPacketLen += parcel.ReadUInt64(peerWaterMark); in DataPacketSyncerPartDeSerialization()
486 packet->SetPeerWaterMark(peerWaterMark); in DataPacketSyncerPartDeSerialization()