| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | delay_notify.cpp | 43 void DelayNotify::UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull) in UpdateNotify() argument
48 for (auto& [k, v] : changedData.tableData) { in UpdateNotify()
77 DistributedRdb::RdbChangedData changedData; in StartTimer() local
82 changedData.tableData = changedData_.tableData; in StartTimer()
96 if (changedData.tableData.empty()) { in StartTimer()
118 task_(changedData, rdbNotifyConfig); in StartTimer()
133 DistributedRdb::RdbChangedData changedData; in ExecuteTask() local
137 changedData.tableData = std::move(changedData_.tableData); in ExecuteTask()
144 if (task_ != nullptr && (changedData.tableData.size() > 0 || isFull)) { in ExecuteTask()
148 int errCode = task_(changedData, rdbNotifyConfig); in ExecuteTask()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_data_listener.cpp | 37 std::map<std::string, std::vector<uint8_t>> changedData {}; in OnChange() local
40 changedData.insert_or_assign(std::move(key), entry.value); in OnChange()
44 changedData.insert_or_assign(std::move(key), entry.value); in OnChange()
46 DistributedObject::ObjectStoreManager::GetInstance()->NotifyChange(changedData); in OnChange()
|
| H A D | object_manager.h | 98 void NotifyChange(ObjectRecord &changedData);
170 …ap<std::string, std::map<std::string, Assets>> GetAssetsFromStore(const ObjectRecord& changedData);
183 …std::map<std::string, ObjectRecord> GetObjectData(const ObjectRecord& changedData, SaveInfo& saveI…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 130 bool CloudSyncUtils::IsChangeDataEmpty(const ChangedData &changedData) in IsChangeDataEmpty() argument
132 return changedData.primaryData[ChangeType::OP_INSERT].empty() || in IsChangeDataEmpty()
133 changedData.primaryData[ChangeType::OP_UPDATE].empty() || in IsChangeDataEmpty()
134 changedData.primaryData[ChangeType::OP_DELETE].empty(); in IsChangeDataEmpty()
197 int CloudSyncUtils::SaveChangedDataByType(const VBucket &datum, ChangedData &changedData, in SaveChangedDataByType() argument
206 …ret = CloudSyncUtils::GetCloudPkVals(datum, changedData.field, localInfo.logInfo.dataKey, cloudPkV… in SaveChangedDataByType()
211 InsertOrReplaceChangedDataByType(type, cloudPkVals, changedData); in SaveChangedDataByType()
394 param.changedData.primaryData[ChangeType::OP_UPDATE].size()); in SaveChangedData()
567 ChangedData &changedData) in InsertOrReplaceChangedDataByType() argument
570 for (auto &changePkValList : changedData.primaryData) { in InsertOrReplaceChangedDataByType()
[all …]
|
| H A D | cloud_sync_utils.h | 52 static bool IsChangeDataEmpty(const ChangedData &changedData);
62 …static int SaveChangedDataByType(const VBucket &datum, ChangedData &changedData, const DataInfoWit…
108 ChangedData &changedData);
|
| H A D | cloud_syncer.cpp | 855 if (!CloudSyncUtils::IsChangeDataEmpty(param.changedData)) { in SaveData()
947 if (changedData.primaryData[OP_INSERT].empty() && changedData.primaryData[OP_UPDATE].empty() && in NeedNotifyChangedData()
948 changedData.primaryData[OP_DELETE].empty()) { in NeedNotifyChangedData()
954 int CloudSyncer::NotifyChangedData(ChangedData &&changedData) in NotifyChangedData() argument
956 if (!NeedNotifyChangedData(changedData)) { in NotifyChangedData()
1013 param.changedData.tableName = param.info.tableName; in SaveDataInTransaction()
1014 param.changedData.field = param.pkColNames; in SaveDataInTransaction()
1015 param.changedData.type = ChangedDataType::DATA; in SaveDataInTransaction()
1068 ChangedData changedData; in SaveDataNotifyProcess() local
1079 param.changedData = changedData; in SaveDataNotifyProcess()
[all …]
|
| H A D | icloud_syncer.h | 65 ChangedData changedData; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 786 param.changedData.field.push_back(pkField);
910 ChangedData changedData; variable
911 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true);
912 changedData.primaryData[OP_INSERT] = {{}};
913 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true);
914 changedData.primaryData[OP_UPDATE] = {{}};
915 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true);
916 changedData.primaryData[OP_DELETE] = {{}};
917 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), false);
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 447 … const std::map<std::string, std::vector<uint8_t>> &changedData) in NotifyChange() argument
454 for (const auto &item : changedData) { in NotifyChange()
466 std::vector<std::string> changedData; in OnChange() local
473 changedData.push_back(tmp.substr(FIELDS_PREFIX_LEN)); in OnChange()
481 changedData.push_back(tmp.substr(FIELDS_PREFIX_LEN)); in OnChange()
484 this->OnChanged(sessionId_, changedData, true); in OnChange()
|
| H A D | distributed_object_store_impl.cpp | 214 const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) in OnChanged() argument
218 for (const auto &str : changedData) { in OnChanged()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 278 std::vector<DistributedDB::VBucket> changedData; in Execute() local
279 auto status = delegate_->ExecuteSql({ sql, {}, false }, changedData); in Execute()
282 changedData.size()); in Execute()
337 std::vector<DistributedDB::VBucket> changedData; in Insert() local
351 status, Anonymous::Change(sql).c_str(), changedData.size(), time); in Insert()
401 std::vector<DistributedDB::VBucket> changedData; in Update() local
412 changedData.size()); in Update()
432 std::vector<DistributedDB::VBucket> changedData; in Replace() local
923 std::vector<DistributedDB::VBucket> changedData; in QuerySql() local
928 changedData.size()); in QuerySql()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 31 std::function<void(const std::string &device, ChangedData &&changedData, bool isChangedData)>;
111 …void TriggerObserverAction(const std::string &deviceName, ChangedData &&changedData, bool isChange…
273 void FilterChangeDataByDetailsType(ChangedData &changedData, uint32_t type);
296 …const std::string &deviceName, const ChangedData &changedData, bool isChangedData, int &observerCn…
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/mock/include/ |
| H A D | mock_object_watcher.h | 30 … void OnChanged(const std::string &sessionid, const std::vector<std::string> &changedData) override in OnChanged() argument
|
| H A D | mock_flat_object_watcher.h | 28 …const std::string &sessionid, const std::vector<std::string> &changedData, bool enableTransfer) ov… in OnChanged() argument
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/ |
| H A D | watcher.h | 30 …const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) = …
|
| H A D | object_storage_engine.h | 37 …const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) = …
|
| H A D | distributed_objectstore_impl.h | 72 …const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) ov…
|
| H A D | flat_object_storage_engine.h | 50 …ange(const std::string &sessionId, const std::map<std::string, std::vector<uint8_t>> &changedData);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 789 ChangedData observerChangeData = changedData; in ExecuteDataChangeCallback()
798 ChangedData &&changedData, bool isChangedData) in TriggerObserverAction() argument
802 ConcurrentAdapter::ScheduleTask([this, deviceName, changedData, isChangedData] () mutable { in TriggerObserverAction()
1316 ChangedData changedData; in CleanCloudData() local
1317 changedData.type = ChangedDataType::DATA; in CleanCloudData()
1318 changedData.tableName = notifyTableName; in CleanCloudData()
1327 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec); in CleanCloudData()
1328 TriggerObserverAction("CLOUD", std::move(changedData), true); in CleanCloudData()
1517 changedData.field = {}; in FilterChangeDataByDetailsType()
1519 changedData.primaryData[i].clear(); in FilterChangeDataByDetailsType()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | delay_notify.h | 35 void UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull = false);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 314 …SqliteCloudKvStore::TriggerObserverAction(const std::string &deviceName, ChangedData &&changedData, in TriggerObserverAction() argument
323 for (auto &changeValList : changedData.primaryData) { in TriggerObserverAction()
327 …int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, deviceName, changedData, isChange… in TriggerObserverAction()
331 ChangedData observerChangeData = changedData; in TriggerObserverAction()
|
| /ohos5.0/foundation/distributeddatamgr/data_object/interfaces/innerkits/ |
| H A D | distributed_object.h | 169 …tual void OnChanged(const std::string &sessionid, const std::vector<std::string> &changedData) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 402 int StorageProxy::NotifyChangedData(const std::string &deviceName, ChangedData &&changedData) in NotifyChangedData() argument
409 store_->GetAndResetServerObserverData(changedData.tableName, changeProperties); in NotifyChangedData()
410 changedData.properties = changeProperties; in NotifyChangedData()
411 store_->TriggerObserverAction(deviceName, std::move(changedData), true); in NotifyChangedData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | relational_store_connection.h | 31 std::function<void(const std::string &device, ChangedData &&changedData, bool isChangedData)>;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.h | 84 void OnDataChange(CHANGE_FLAG flag, const std::list<DistributedDB::Entry>& changedData);
|