Searched refs:peerWatermark (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.h | 192 WaterMark peerWatermark, WaterMark peerDeletedWatermark);
|
| H A D | single_ver_data_sync.cpp | 890 … const SingleVerSyncTaskContext *context, WaterMark peerWatermark, WaterMark peerDeletedWatermark) in UpdatePeerWaterMark() argument
892 if (peerWatermark == 0 && peerDeletedWatermark == 0) { in UpdatePeerWaterMark()
897 errCode = metadata_->SavePeerWaterMark(context->GetDeviceId(), peerWatermark, true); in UpdatePeerWaterMark()
899 if (peerWatermark != 0) { in UpdatePeerWaterMark()
900 … LOGD("label=%s,dev=%s,endTime=%" PRIu64, label_.c_str(), STR_MASK(GetDeviceId()), peerWatermark); in UpdatePeerWaterMark()
901 … errCode = metadata_->SetRecvQueryWaterMark(queryId, context->GetDeviceId(), peerWatermark); in UpdatePeerWaterMark()
|