| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_meta_data.cpp | 39 localMark = cloudMetaVals_[tableName].localMark; in GetLocalWaterMark()
60 cloudMetaVals_[tableName].localMark = std::max(localMark, cloudMetaVals_[tableName].localMark); in GetLocalWaterMarkByType()
92 cloudMetaVal.localMark = localMark; in SetLocalWaterMark()
96 iter->second.localMark = localMark; in SetLocalWaterMark()
109 cloudMetaVal.localMark = std::max(localMark, cloudMetaVal.localMark); in SetLocalWaterMarkByType()
111 cloudMetaVal.deleteLocalMark = localMark; in SetLocalWaterMarkByType()
113 cloudMetaVal.updateLocalMark = localMark; in SetLocalWaterMarkByType()
135 Timestamp localMark = 0; in SetCloudWaterMark() local
138 localMark = iter->second.localMark; in SetCloudWaterMark()
146 cloudMetaVal.localMark = localMark; in SetCloudWaterMark()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_meta_data.h | 36 int GetLocalWaterMark(const TableName &tableName, Timestamp &localMark);
37 …int GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark);
40 int SetLocalWaterMark(const TableName &tableName, Timestamp localMark);
41 … int SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark);
52 Timestamp localMark = 0u; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 42 int GetLocalWaterMark(const std::string &tableName, Timestamp &localMark);
44 …t GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
46 int PutLocalWaterMark(const std::string &tableName, Timestamp &localMark);
48 int PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
66 …int GetUploadCount(const QuerySyncObject &query, const Timestamp &localMark, bool isCloudForcePush,
|
| H A D | icloud_sync_storage_interface.h | 233 [[gnu::unused]] const CloudWaterType &type, Timestamp localMark)
|
| /ohos5.0/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
65 return cloudMetaData_->GetLocalWaterMark(AppendWithUserIfNeed(tableName), localMark); in GetLocalWaterMark()
78 … return cloudMetaData_->GetLocalWaterMarkByType(AppendWithUserIfNeed(tableName), mode, localMark); in GetLocalWaterMarkByMode()
81 int StorageProxy::PutLocalWaterMark(const std::string &tableName, Timestamp &localMark) in PutLocalWaterMark() argument
91 return cloudMetaData_->SetLocalWaterMark(AppendWithUserIfNeed(tableName), localMark); in PutLocalWaterMark()
94 …eProxy::PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark) in PutWaterMarkByMode() argument
104 … return cloudMetaData_->SetLocalWaterMarkByType(AppendWithUserIfNeed(tableName), mode, localMark); in PutWaterMarkByMode()
192 int StorageProxy::GetUploadCount(const std::string &tableName, const Timestamp &localMark, in GetUploadCount() argument
205 return store_->GetUploadCount(query, localMark, isCloudForcePush, false, count); in GetUploadCount()
208 int StorageProxy::GetUploadCount(const QuerySyncObject &query, const Timestamp &localMark, in GetUploadCount() argument
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync_utils.cpp | 407 WaterMark localMark, UpdateWaterMark &isUpdate) in GetFullSyncDataTimeRange() argument
409 Timestamp maxTimestamp = localMark; in GetFullSyncDataTimeRange()
410 Timestamp minTimestamp = localMark; in GetFullSyncDataTimeRange()
428 WaterMark localMark, WaterMark deleteLocalMark, UpdateWaterMark &isUpdate) in GetQuerySyncDataTimeRange() argument
430 SyncTimeRange dataTimeRange = {localMark, deleteLocalMark, localMark, deleteLocalMark}; in GetQuerySyncDataTimeRange()
480 SyncTimeRange SingleVerDataSyncUtils::GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, … in GetSyncDataTimeRange() argument
484 return SingleVerDataSyncUtils::GetFullSyncDataTimeRange(inData, localMark, isUpdate); in GetSyncDataTimeRange()
486 … return SingleVerDataSyncUtils::GetQuerySyncDataTimeRange(inData, localMark, deleteMark, isUpdate); in GetSyncDataTimeRange()
|
| H A D | single_ver_data_sync_utils.h | 80 …yncTimeRange GetFullSyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark,
83 …ncTimeRange GetQuerySyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark,
92 …static SyncTimeRange GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark delete…
|
| H A D | single_ver_data_sync.cpp | 457 WaterMark localMark = 0; in GetSyncDataTimeRange() local
467 WaterMark localMark = 0; in SaveLocalWaterMark() local
474 if (localMark >= dataTimeRange.endTime) { in SaveLocalWaterMark()
486 if (localMark >= dataTimeRange.endTime) { in SaveLocalWaterMark()
603 WaterMark localMark = 0; in DealRemoveDeviceDataByAck() local
666 WaterMark localMark = 0; in FillDataRequestPacket() local
673 GetLocalWaterMark(curType, id, context, localMark); in FillDataRequestPacket()
804 WaterMark localMark = 0; in PullRequestStart() local
812 SyncTimeRange dataTime = {localMark, deleteMark, localMark, deleteMark}; in PullRequestStart()
1590 WaterMark localMark = 0; in SetAckPacket() local
[all …]
|
| H A D | single_ver_data_packet.cpp | 263 void DataRequestPacket::SetWaterMark(WaterMark localMark, WaterMark peerMark, WaterMark deletedWate… in SetWaterMark() argument
265 localWaterMark_ = localMark; in SetWaterMark()
|
| H A D | single_ver_data_packet.h | 94 void SetWaterMark(WaterMark localMark, WaterMark peerMark, WaterMark deletedWatermark);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.h | 100 …loadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp localMark) override;
|
| H A D | sqlite_cloud_kv_store.cpp | 543 Timestamp localMark) in ReleaseUploadRecord() argument
545 recorder_.ReleaseUploadRecord(tableName, type, localMark); in ReleaseUploadRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.h | 114 Timestamp localMark = 0u; member
168 int PreCheckUpload(TaskId &taskId, const TableName &tableName, Timestamp &localMark);
|
| H A D | cloud_syncer.cpp | 1172 …ncer::PreCheckUpload(CloudSyncer::TaskId &taskId, const TableName &tableName, Timestamp &localMark) in PreCheckUpload() argument
1258 storageProxy_->ReleaseUploadRecord(tableName, uploadParam.mode, uploadParam.localMark); in PutWaterMarkAfterBatchUpload()
1264 errCode = storageProxy_->PutWaterMarkByMode(tableName, uploadParam.mode, uploadParam.localMark); in PutWaterMarkAfterBatchUpload()
1280 Timestamp localMark = 0u; in DoUpload() local
1281 ret = PreCheckUpload(taskId, tableName, localMark); in DoUpload()
1286 ReloadWaterMarkIfNeed(taskId, localMark); in DoUpload()
1328 uploadParam.taskId, uploadParam.localMark); in PreProcessBatchUpload()
|
| H A D | cloud_syncer_extend.cpp | 914 uploadParam.localMark = res.second; in GetLocalWater()
946 RecordWaterMark(uploadParam.taskId, uploadParam.localMark); in HandleBatchUpload()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_common.h | 110 … static int SerializeWaterMark(Timestamp localMark, const std::string &cloudMark, Value &blobMeta);
|
| /ohos5.0/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
548 parcel.WriteUInt64(localMark); in SerializeWaterMark()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 229 …loadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp localMark) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 2151 Timestamp localMark) in ReleaseUploadRecord() argument
2153 uploadRecorder_.ReleaseUploadRecord(tableName, type, localMark); in ReleaseUploadRecord()
|