/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | meta_data.h | 77 void GetPeerWaterMark(const DeviceID &deviceId, uint64_t &outValue, bool isNeedHash = true); 79 int SavePeerWaterMark(const DeviceID &deviceId, uint64_t inValue, bool isNeedHash); 85 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash); 87 …int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, const std::string &tableNam… 120 …leteSyncWaterMark(const std::string &deviceId, const WaterMark &waterMark, bool isNeedHash = true); 128 int SetDbCreateTime(const DeviceID &deviceId, uint64_t inValue, bool isNeedHash); 147 int GetWaterMarkInfoFromDB(const std::string &dev, bool isNeedHash, WatermarkInfo &info); 178 …int SaveMetaDataValue(const DeviceID &deviceId, const MetaDataValue &inValue, bool isNeedHash = tr… 181 void GetMetaDataValue(const DeviceID &deviceId, MetaDataValue &outValue, bool isNeedHash); 201 void GetHashDeviceId(const DeviceID &deviceId, DeviceID &hashDeviceId, bool isNeedHash); [all …]
|
H A D | meta_data.cpp | 119 GetMetaDataValue(deviceId, metadata, isNeedHash); in GetPeerWaterMark() 127 GetMetaDataValue(deviceId, metadata, isNeedHash); in SavePeerWaterMark() 130 return SaveMetaDataValue(deviceId, metadata, isNeedHash); in SavePeerWaterMark() 156 int Metadata::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) in EraseDeviceWaterMark() argument 158 return EraseDeviceWaterMark(deviceId, isNeedHash, ""); in EraseDeviceWaterMark() 181 int errCode = SavePeerWaterMark(deviceId, 0, isNeedHash); in EraseDeviceWaterMark() 212 GetHashDeviceId(deviceId, hashDeviceId, isNeedHash); in SaveMetaDataValue() 227 GetHashDeviceId(deviceId, hashDeviceId, isNeedHash); in GetMetaDataValue() 364 if (!isNeedHash) { in GetHashDeviceId() 502 GetHashDeviceId(deviceId, hashDeviceId, isNeedHash); in SetDbCreateTime() [all …]
|
H A D | syncer_proxy.cpp | 107 int SyncerProxy::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) in EraseDeviceWaterMark() argument 109 return EraseDeviceWaterMark(deviceId, isNeedHash, ""); in EraseDeviceWaterMark() 112 int SyncerProxy::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, in EraseDeviceWaterMark() argument 119 return syncer_->EraseDeviceWaterMark(deviceId, isNeedHash, tableName); in EraseDeviceWaterMark()
|
H A D | query_sync_water_mark_helper.h | 69 …tRecvDeleteSyncWaterMark(const std::string &deviceId, const WaterMark &waterMark, bool isNeedHash); 79 …t ResetRecvQueryWaterMark(const DeviceID &deviceId, const std::string &tableName, bool isNeedHash); 121 DeviceID GetHashDeleteSyncDeviceId(const DeviceID &deviceId, bool isNeedHash = true);
|
H A D | query_sync_water_mark_helper.cpp | 324 bool isNeedHash) in SetRecvDeleteSyncWaterMark() argument 326 std::string hashId = GetHashDeleteSyncDeviceId(deviceId, isNeedHash); in SetRecvDeleteSyncWaterMark() 408 …ceID QuerySyncWaterMarkHelper::GetHashDeleteSyncDeviceId(const DeviceID &deviceId, bool isNeedHash) in GetHashDeleteSyncDeviceId() argument 414 (isNeedHash ? DBCommon::TransferHashString(deviceId) : deviceId); in GetHashDeleteSyncDeviceId() 520 bool isNeedHash) in ResetRecvQueryWaterMark() argument 525 (isNeedHash ? DBCommon::TransferHashString(deviceId) : deviceId); in ResetRecvQueryWaterMark()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_syncer.cpp | 49 int SingleVerSyncer::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) in EraseDeviceWaterMark() argument 51 return EraseDeviceWaterMark(deviceId, isNeedHash, ""); in EraseDeviceWaterMark() 54 int SingleVerSyncer::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, in EraseDeviceWaterMark() argument 68 int errCode = metadata->EraseDeviceWaterMark(deviceId, isNeedHash, tableName); in EraseDeviceWaterMark()
|
H A D | single_ver_syncer.h | 31 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) override; 34 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash,
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
H A D | multi_ver_syncer.cpp | 61 int MultiVerSyncer::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) in EraseDeviceWaterMark() argument 63 return EraseDeviceWaterMark(deviceId, isNeedHash, ""); in EraseDeviceWaterMark() 66 int MultiVerSyncer::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, in EraseDeviceWaterMark() argument
|
H A D | multi_ver_syncer.h | 33 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) override; 36 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash,
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/ |
H A D | syncer_proxy.h | 63 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) override; 66 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash,
|
H A D | isyncer.h | 82 virtual int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) = 0; 85 virtual int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash,
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_storage_engine.h | 94 int EraseDeviceWaterMark(const std::set<std::string> &removeDevices, bool isNeedHash); 96 std::set<std::string> &removeDevices, bool &isNeedHash) const;
|
H A D | sqlite_single_ver_storage_engine.cpp | 50 …VerStorageEngine::EraseDeviceWaterMark(const std::set<std::string> &removeDevices, bool isNeedHash) in EraseDeviceWaterMark() argument 65 int errCode = kvStore->EraseDeviceWaterMark(devId, isNeedHash); in EraseDeviceWaterMark() 77 std::set<std::string> &removeDevices, bool &isNeedHash) const in GetRemoveDataDevices() 90 isNeedHash = false; in GetRemoveDataDevices() 106 bool isNeedHash = true; in EraseDeviceWaterMark() local 108 errCode = GetRemoveDataDevices(handle, dataItem, removeDevices, isNeedHash); in EraseDeviceWaterMark() 121 errCode = EraseDeviceWaterMark(removeDevices, isNeedHash); in EraseDeviceWaterMark()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | sync_able_engine.cpp | 76 int SyncAbleEngine::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, const std::s… in EraseDeviceWaterMark() argument 84 return syncer_.EraseDeviceWaterMark(deviceId, isNeedHash, tableName); in EraseDeviceWaterMark()
|
H A D | sync_able_engine.h | 40 …int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash, const std::string &tableNam…
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | sync_able_kvdb.h | 79 int EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash);
|
H A D | sync_able_kvdb.cpp | 322 int SyncAbleKvDB::EraseDeviceWaterMark(const std::string &deviceId, bool isNeedHash) in EraseDeviceWaterMark() argument 330 return syncer_.EraseDeviceWaterMark(deviceId, isNeedHash); in EraseDeviceWaterMark()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_relational_store.cpp | 596 bool isNeedHash = false; in RemoveDeviceData() local 600 isNeedHash = true; in RemoveDeviceData() 607 if (isNeedHash) { in RemoveDeviceData() 619 return RemoveDeviceDataInner(hashDeviceId, device, tableName, isNeedHash); in RemoveDeviceData() 863 const std::string &tableName, bool isNeedHash) in RemoveDeviceDataInner() argument 868 if (!isNeedHash) { in RemoveDeviceDataInner()
|
H A D | sqlite_relational_store.h | 142 const std::string &tableName, bool isNeedHash);
|