| /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 (autoSyncInterval_ == AUTO_SYNC_INTERVAL || 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()
143 if (task_ != nullptr && (changedData.tableData.size() > 0 || isFull)) { in ExecuteTask()
147 int errCode = task_(changedData, rdbNotifyConfi in ExecuteTask()
[all...] |
| /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()
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 std::map<std::string, std::map<std::string, Assets>> GetAssetsFromStore(const ObjectRecord& changedData);
183 std::map<std::string, ObjectRecord> GetObjectData(const ObjectRecord& changedData, SaveInfo& saveInfo,
|
| /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
203 ret = CloudSyncUtils::GetCloudPkVals(localInfo.primaryKeys, changedData.field, localInfo.logInfo.dataKey, in SaveChangedDataByType()
206 ret = CloudSyncUtils::GetCloudPkVals(datum, changedData.field, localInfo.logInfo.dataKey, cloudPkVals); in SaveChangedDataByType()
211 InsertOrReplaceChangedDataByType(type, cloudPkVals, changedData); in SaveChangedDataByType()
394 param.changedData.primaryData[ChangeType::OP_UPDATE].size()); in SaveChangedData()
409 param.downloadData.data[dataIndex], param.changedData, dataInf in SaveChangedData()
566 InsertOrReplaceChangedDataByType(ChangeType type, std::vector<Type> &pkVal, ChangedData &changedData) InsertOrReplaceChangedDataByType() argument
[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 DataInfoWithLog &localInfo,
108 ChangedData &changedData);
|
| H A D | cloud_syncer.cpp | 504 ret = CloudSyncUtils::GetCloudPkVals(datum, param.changedData.field, in UpdateChangedData()
510 param.changedData.primaryData[ChangeType::OP_INSERT].push_back(primaryValues); in UpdateChangedData()
523 size_t size = param.changedData.primaryData[ChangeType::OP_UPDATE].size(); in UpdateChangedData()
528 if (param.changedData.primaryData[ChangeType::OP_UPDATE][updateIndex].empty()) { in UpdateChangedData()
533 param.changedData.primaryData[ChangeType::OP_UPDATE][updateIndex][0] = in UpdateChangedData()
692 // changedData.primaryData should have no member inside in DownloadAssets()
855 if (!CloudSyncUtils::IsChangeDataEmpty(param.changedData)) { in SaveData()
856 LOGE("[CloudSyncer] changedData.primaryData should have no member inside."); in SaveData()
936 bool CloudSyncer::NeedNotifyChangedData(const ChangedData &changedData) in NeedNotifyChangedData() argument
947 if (changedData in NeedNotifyChangedData()
954 NotifyChangedData(ChangedData &&changedData) NotifyChangedData() argument
1068 ChangedData changedData; SaveDataNotifyProcess() local
[all...] |
| H A D | icloud_syncer.h | 65 ChangedData changedData; member
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/mock/include/ |
| H A D | mock_flat_object_watcher.h | 28 const std::string &sessionid, const std::vector<std::string> &changedData, bool enableTransfer) override
|
| H A D | mock_object_watcher.h | 30 void OnChanged(const std::string &sessionid, const std::vector<std::string> &changedData) override
|
| /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) = 0;
|
| H A D | distributed_objectstore_impl.h | 72 const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) override;
|
| H A D | flat_object_storage_engine.h | 50 void NotifyChange(const std::string &sessionId, const std::map<std::string, std::vector<uint8_t>> &changedData);
|
| H A D | object_storage_engine.h | 37 const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) = 0;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 791 param.changedData.field.push_back(pkField); in HWTEST_F()
915 ChangedData changedData; in HWTEST_F() local
916 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true); in HWTEST_F()
917 changedData.primaryData[OP_INSERT] = {{}}; in HWTEST_F()
918 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true); in HWTEST_F()
919 changedData.primaryData[OP_UPDATE] = {{}}; in HWTEST_F()
920 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), true); in HWTEST_F()
921 changedData.primaryData[OP_DELETE] = {{}}; in HWTEST_F()
922 EXPECT_EQ(utilsObj.IsChangeDataEmpty(changedData), false); in HWTEST_F()
|
| /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()
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()
446 NotifyChange(const std::string &sessionId, const std::map<std::string, std::vector<uint8_t>> &changedData) NotifyChange() argument
|
| H A D | distributed_object_store_impl.cpp | 214 const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) in OnChanged()
218 for (const auto &str : changedData) { in OnChanged()
213 OnChanged( const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) OnChanged() argument
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | delay_notify.h | 35 void UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull = false);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 266 std::vector<DistributedDB::VBucket> changedData; in Execute() local
267 auto status = delegate_->ExecuteSql({ sql, {}, false }, changedData); in Execute()
270 changedData.size()); in Execute()
325 std::vector<DistributedDB::VBucket> changedData; in Insert() local
333 auto status = delegate_->ExecuteSql({ sql, std::move(bindArgs), false }, changedData); in Insert()
339 status, Anonymous::Change(sql).c_str(), changedData.size(), time); in Insert()
389 std::vector<DistributedDB::VBucket> changedData; in Update() local
397 auto status = delegate_->ExecuteSql({ sqlIn, std::move(bindArgs), false }, changedData); in Update()
400 changedData.size()); in Update()
420 std::vector<DistributedDB::VBucket> changedData; in Replace() local
[all...] |
| /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 isChangedData) override;
274 void FilterChangeDataByDetailsType(ChangedData &changedData, uint32_t type);
297 const std::string &deviceName, const ChangedData &changedData, bool isChangedData, int &observerCnt);
|
| /foundation/distributeddatamgr/data_object/interfaces/innerkits/ |
| H A D | distributed_object.h | 169 virtual void OnChanged(const std::string &sessionid, const std::vector<std::string> &changedData) = 0;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 791 const std::string &deviceName, const ChangedData &changedData, bool isChangedData, int &observerCnt) in ExecuteDataChangeCallback()
798 ChangedData observerChangeData = changedData; in ExecuteDataChangeCallback()
807 ChangedData &&changedData, bool isChangedData) in TriggerObserverAction()
811 ConcurrentAdapter::ScheduleTask([this, deviceName, changedData, isChangedData] () mutable { in TriggerObserverAction()
816 ExecuteDataChangeCallback(item, deviceName, changedData, isChangedData, observerCnt); in TriggerObserverAction()
1325 ChangedData changedData; in CleanCloudData() local
1326 changedData.type = ChangedDataType::DATA; in CleanCloudData()
1327 changedData.tableName = notifyTableName; in CleanCloudData()
1336 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec); in CleanCloudData()
1337 TriggerObserverAction("CLOUD", std::move(changedData), tru in CleanCloudData()
789 ExecuteDataChangeCallback( const std::pair<uint64_t, std::map<const StoreObserver *, RelationalObserverAction>> &item, const std::string &deviceName, const ChangedData &changedData, bool isChangedData, int &observerCnt) ExecuteDataChangeCallback() argument
806 TriggerObserverAction(const std::string &deviceName, ChangedData &&changedData, bool isChangedData) TriggerObserverAction() argument
1523 FilterChangeDataByDetailsType(ChangedData &changedData, uint32_t type) FilterChangeDataByDetailsType() argument
[all...] |
| /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);
|
| /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)>;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 2062 ChangedData changedData; in HWTEST_F() local
2063 changedData.type = ChangedDataType::DATA; in HWTEST_F()
2064 changedData.tableName = g_sharedTableName1; in HWTEST_F()
2068 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec); in HWTEST_F()
2069 g_observer->SetExpectedResult(changedData); in HWTEST_F()
2188 ChangedData changedData; in HWTEST_F() local
2189 changedData.type = ChangedDataType::DATA; in HWTEST_F()
2190 changedData.tableName = g_tableName2; in HWTEST_F()
2194 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec); in HWTEST_F()
2195 g_observer->SetExpectedResult(changedData); in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.h | 67 void TriggerObserverAction(const std::string &deviceName, ChangedData &&changedData, bool isChangedData) override;
|