/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 77 DistributedRdb::RdbChangedData changedData; in StartTimer() local 133 DistributedRdb::RdbChangedData changedData; in ExecuteTask() local [all...] |
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/fuzztest/objectstore_fuzzer/ |
H A D | objectstore_fuzzer.cpp | 39 OnChanged( const std::string &sessionid, const std::vector<std::string> &changedData, bool enableTransfer) OnChanged() argument
|
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
H A D | js_watcher.cpp | 283 void WatcherImpl::OnChanged(const std::string &sessionid, const std::vector<std::string> &changedData)
in OnChanged() argument
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
H A D | flat_object_storage_engine.cpp | 466 std::vector<std::string> changedData; in OnChange() local 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 | 213 OnChanged( const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) OnChanged() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | icloud_syncer.h | 65 ChangedData changedData; member
|
H A D | cloud_sync_utils.cpp | 130 bool CloudSyncUtils::IsChangeDataEmpty(const ChangedData &changedData) in IsChangeDataEmpty() argument 197 int CloudSyncUtils::SaveChangedDataByType(const VBucket &datum, ChangedData &changedData, in SaveChangedDataByType() argument 566 InsertOrReplaceChangedDataByType(ChangeType type, std::vector<Type> &pkVal, ChangedData &changedData) InsertOrReplaceChangedDataByType() argument [all...] |
H A D | cloud_syncer.cpp | 936 bool CloudSyncer::NeedNotifyChangedData(const ChangedData &changedData) in NeedNotifyChangedData() argument 954 NotifyChangedData(ChangedData &&changedData) NotifyChangedData() argument 1068 ChangedData changedData; SaveDataNotifyProcess() local [all...] |
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/ |
H A D | object_store_test.cpp | 55 OnChanged( const std::string &sessionid, const std::vector<std::string> &changedData, bool enableTransfer) OnChanged() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | rdb_general_store_test.cpp | 857 DistributedDB::ChangedData changedData;
in HWTEST_F() local
|
H A D | kvdb_general_store_test.cpp | 652 DistributedDB::ChangedData changedData; in HWTEST_F() local
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_general_store.cpp | 266 std::vector<DistributedDB::VBucket> changedData; in Execute() local 325 std::vector<DistributedDB::VBucket> changedData; in Insert() local 389 std::vector<DistributedDB::VBucket> changedData; in Update() local 420 std::vector<DistributedDB::VBucket> changedData; in Replace() local [all...] |
/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 2188 ChangedData changedData; in HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | distributeddb_cloud_db_proxy_test.cpp | 915 ChangedData changedData; in HWTEST_F() local
|
/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
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_cloud_kv_store.cpp | 314 void SqliteCloudKvStore::TriggerObserverAction(const std::string &deviceName, ChangedData &&changedData, in TriggerObserverAction() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
H A D | relational_store_sqlite_ext.cpp | 730 DistributedDB::ChangedData changedData; in SaveChangedData() local
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | distributeddb_tools_unit_test.cpp | 813 void RelationalStoreObserverUnitTest::SetExpectedResult(const DistributedDB::ChangedData &changedData) in SetExpectedResult() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_manager.cpp | 397 void ObjectStoreManager::NotifyChange(ObjectRecord &changedData)
in NotifyChange() argument 422 std::map<std::string, ObjectRecord> ObjectStoreManager::GetObjectData(const ObjectRecord& changedData,
in GetObjectData() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_sync_able_storage.cpp | 1325 ChangedData changedData; in CleanCloudData() local 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...] |