Home
last modified time | relevance | path

Searched refs:SaveLocalWaterMark (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp813 EXPECT_EQ(meta.SaveLocalWaterMark("D1", w2), E_OK);
830 EXPECT_EQ(meta.SaveLocalWaterMark("D2", w3), E_OK);
876 EXPECT_EQ(meta.SaveLocalWaterMark("D1", w1), E_OK);
1221 EXPECT_EQ(meta.SaveLocalWaterMark("D1", w2), E_OK);
1238 EXPECT_EQ(meta.SaveLocalWaterMark("D2", w3), E_OK);
1284 EXPECT_EQ(meta.SaveLocalWaterMark("D1", w1), E_OK);
1505 EXPECT_EQ(meta.SaveLocalWaterMark(deviceA, setWaterMark), E_OK);
1506 EXPECT_EQ(meta.SaveLocalWaterMark(deviceB, setWaterMark), E_OK);
1633 EXPECT_EQ(meta.SaveLocalWaterMark("D1", value), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp464 int SingleVerDataSync::SaveLocalWaterMark(SyncType syncType, const SingleVerSyncTaskContext *contex… in SaveLocalWaterMark() function in DistributedDB::SingleVerDataSync
478 errCode = metadata_->SaveLocalWaterMark(deviceId, dataTimeRange.endTime); in SaveLocalWaterMark()
579 metadata_->SaveLocalWaterMark(context->GetDeviceId(), 0); in RemoveDeviceDataHandle()
760 SaveLocalWaterMark(curType, context, tmpDataTime); in RequestStart()
870 SaveLocalWaterMark(curType, context, tmpDataTime); in PullResponseStart()
1300 int errCode = SaveLocalWaterMark(curType, context, in DealWaterMarkException()
1428 errCode = SaveLocalWaterMark(curType, context, dataTime, true); in ReSend()
H A Dsingle_ver_data_sync.h168 int SaveLocalWaterMark(SyncType syncType, const SingleVerSyncTaskContext *context,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dmeta_data.h75 int SaveLocalWaterMark(const DeviceID &deviceId, uint64_t inValue);
H A Dmeta_data.cpp105 int Metadata::SaveLocalWaterMark(const DeviceID &deviceId, uint64_t inValue) in SaveLocalWaterMark() function in DistributedDB::Metadata