| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_meta_data.h | 52 Timestamp localMark = 0u; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_meta_data.cpp | 29 int CloudMetaData::GetLocalWaterMark(const TableName &tableName, Timestamp &localMark) in GetLocalWaterMark() argument
43 int CloudMetaData::GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark) in GetLocalWaterMarkByType() argument
78 SetLocalWaterMark(const TableName &tableName, Timestamp localMark) SetLocalWaterMark() argument
101 SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark) SetLocalWaterMarkByType() argument
135 Timestamp localMark = 0; SetCloudWaterMark() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.h | 114 Timestamp localMark = 0u; member
|
| H A D | cloud_syncer.cpp | 1172 int CloudSyncer::PreCheckUpload(CloudSyncer::TaskId &taskId, const TableName &tableName, Timestamp &localMark) in PreCheckUpload() argument
1280 Timestamp localMark = 0u; in DoUpload() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | icloud_sync_storage_interface.h | 228 ReleaseUploadRecord([[gnu::unused]] const std::string &tableName, [[gnu::unused]] const CloudWaterType &type, Timestamp localMark) ReleaseUploadRecord() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync_utils.cpp | 480 SyncTimeRange SingleVerDataSyncUtils::GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark deleteMark, in GetSyncDataTimeRange() argument
406 GetFullSyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark, UpdateWaterMark &isUpdate) GetFullSyncDataTimeRange() argument
427 GetQuerySyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark, WaterMark deleteLocalMark, UpdateWaterMark &isUpdate) GetQuerySyncDataTimeRange() argument
|
| H A D | single_ver_data_packet.cpp | 267 void DataRequestPacket::SetWaterMark(WaterMark localMark, WaterMark peerMark, WaterMark deletedWatermark) in SetWaterMark() argument
|
| H A D | single_ver_data_sync.cpp | 458 WaterMark localMark = 0; in GetSyncDataTimeRange() local
468 WaterMark localMark = 0; in SaveLocalWaterMark() local
604 WaterMark localMark = 0; in DealRemoveDeviceDataByAck() local
667 WaterMark localMark = 0; FillDataRequestPacket() local
805 WaterMark localMark = 0; PullRequestStart() local
1601 WaterMark localMark = 0; SetAckPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 55 int StorageProxy::GetLocalWaterMark(const std::string &tableName, Timestamp &localMark) in GetLocalWaterMark() argument
68 int StorageProxy::GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark) in GetLocalWaterMarkByMode() argument
81 int StorageProxy::PutLocalWaterMark(const std::string &tableName, Timestamp &localMark) in PutLocalWaterMark() argument
94 int StorageProxy::PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark) in PutWaterMarkByMode() argument
192 int StorageProxy::GetUploadCount(const std::string &tableName, const Timestamp &localMark, in GetUploadCount() argument
208 GetUploadCount(const QuerySyncObject &query, const Timestamp &localMark, bool isCloudForcePush, bool isCompensatedTask, int64_t &count) GetUploadCount() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 542 ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp localMark) ReleaseUploadRecord() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 543 int DBCommon::SerializeWaterMark(Timestamp localMark, const std::string &cloudMark, Value &blobMeta) in SerializeWaterMark() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 2153 ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp localMark) ReleaseUploadRecord() argument
|