Home
last modified time | relevance | path

Searched refs:pullEndWatermark (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h82 …equestRecv(SingleVerSyncTaskContext *context, const Message *message, WaterMark &pullEndWatermark);
201 WaterMark &pullEndWatermark) const;
H A Dsingle_ver_sync_state_machine.h203 void AddPullResponseTarget(const Message *inMsg, WaterMark pullEndWatermark);
H A Dsingle_ver_data_sync.cpp987 WaterMark &pullEndWatermark) in DataRequestRecv() argument
1010 GetPullEndWatermark(context, packet, pullEndWatermark); in DataRequestRecv()
1017 if (pullEndWatermark > 0 && !storage_->IsReadable()) { // pull mode in DataRequestRecv()
1018 pullEndWatermark = 0; in DataRequestRecv()
1270 WaterMark &pullEndWatermark) const in GetPullEndWatermark()
1280 pullEndWatermark = endMark - static_cast<WaterMark>(offset); in GetPullEndWatermark()
1282 … "label=%s,dev=%s", endMark, offset, pullEndWatermark, label_.c_str(), STR_MASK(GetDeviceId())); in GetPullEndWatermark()
H A Dsingle_ver_sync_state_machine.cpp990 … SingleVerSyncStateMachine::AddPullResponseTarget(const Message *inMsg, WaterMark pullEndWatermark) in AddPullResponseTarget() argument
994 if (pullEndWatermark == 0) { in AddPullResponseTarget()
1018 targetTmp->SetEndWaterMark(pullEndWatermark); in AddPullResponseTarget()