Home
last modified time | relevance | path

Searched refs:RdbStoreObserver (Results 1 – 25 of 34) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_local_db_observer.cpp28 RdbStoreObserver::ChangeInfo changeInfo; in OnChange()
30 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_INSERT); in OnChange()
31 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_UPDATE); in OnChange()
32 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_DELETE); in OnChange()
35 RdbStoreObserver::PrimaryFields fields; in OnChange()
40 RdbStoreObserver::ChangeInfo &changeInfo, RdbStoreObserver::ChangeType changeType) in Convert()
42 if (changeType < RdbStoreObserver::ChangeType::CHG_TYPE_INSERT || in Convert()
43 changeType >= RdbStoreObserver::ChangeType::CHG_TYPE_BUTT) { in Convert()
48 RdbStoreObserver::PrimaryKey primaryKey; in Convert()
H A Drd_connection.cpp199 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) in Subscribe()
205 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) in Unsubscribe()
H A Drdb_store.cpp473 int RdbStore::Subscribe(const SubscribeOption& option, RdbStoreObserver *observer) in Subscribe()
480 int RdbStore::UnSubscribe(const SubscribeOption& option, RdbStoreObserver *observer) in UnSubscribe()
487 …SubscribeObserver(const SubscribeOption& option, const std::shared_ptr<RdbStoreObserver> &observer) in SubscribeObserver()
494 …subscribeObserver(const SubscribeOption& option, const std::shared_ptr<RdbStoreObserver> &observer) in UnsubscribeObserver()
H A Drdb_store_impl.cpp422 int RdbStoreImpl::SubscribeLocal(const SubscribeOption& option, RdbStoreObserver *observer) in SubscribeLocal()
438 int RdbStoreImpl::SubscribeLocalShared(const SubscribeOption& option, RdbStoreObserver *observer) in SubscribeLocalShared()
466 const std::shared_ptr<RdbStoreObserver> &observer) in SubscribeLocalDetail()
480 int RdbStoreImpl::SubscribeRemote(const SubscribeOption& option, RdbStoreObserver *observer) in SubscribeRemote()
489 int RdbStoreImpl::Subscribe(const SubscribeOption &option, RdbStoreObserver *observer) in Subscribe()
503 int RdbStoreImpl::UnSubscribeLocal(const SubscribeOption& option, RdbStoreObserver *observer) in UnSubscribeLocal()
537 int RdbStoreImpl::UnSubscribeLocalShared(const SubscribeOption& option, RdbStoreObserver *observer) in UnSubscribeLocalShared()
599 const std::shared_ptr<RdbStoreObserver> &observer) in UnsubscribeLocalDetail()
613 int RdbStoreImpl::UnSubscribeRemote(const SubscribeOption& option, RdbStoreObserver *observer) in UnSubscribeRemote()
622 int RdbStoreImpl::UnSubscribe(const SubscribeOption &option, RdbStoreObserver *observer) in UnSubscribe()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drdb_store_impl.h53 DistributedRdb::RdbStoreObserver *getObserver() in getObserver()
59 DistributedRdb::RdbStoreObserver *observer_ = nullptr;
70 DistributedRdb::RdbStoreObserver *getObserver() in getObserver()
76 DistributedRdb::RdbStoreObserver *observer_ = nullptr;
125 int Subscribe(const SubscribeOption &option, RdbStoreObserver *observer) override;
126 int UnSubscribe(const SubscribeOption &option, RdbStoreObserver *observer) override;
193 int SubscribeLocal(const SubscribeOption &option, RdbStoreObserver *observer);
194 int SubscribeLocalShared(const SubscribeOption &option, RdbStoreObserver *observer);
196 int SubscribeRemote(const SubscribeOption &option, RdbStoreObserver *observer);
197 int UnSubscribeLocal(const SubscribeOption &option, RdbStoreObserver *observer);
[all …]
H A Drdb_local_db_observer.h28 …explicit RdbStoreLocalDbObserver(const std::shared_ptr<RdbStoreObserver> &observer) : observer_(ob… in RdbStoreLocalDbObserver()
31 std::shared_ptr<RdbStoreObserver> GetObserver() in GetObserver()
37 … void Convert(const DistributedDB::ChangedData &dataInfo, RdbStoreObserver::ChangeInfo &changeInfo,
38 RdbStoreObserver::ChangeType changeType);
39 std::shared_ptr<RdbStoreObserver> observer_ = nullptr;
H A Drdb_service_proxy.h30 RdbStoreObserver *observer = nullptr;
50 RdbStoreObserver *observer) override;
53 RdbStoreObserver *observer) override;
92 using ChangeInfo = RdbStoreObserver::ChangeInfo;
93 using PrimaryFields = RdbStoreObserver::PrimaryFields;
H A Drd_connection.h54 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) override;
56 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) override;
H A Dsqlite_connection.h63 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) override;
65 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) override;
111 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer);
H A Dconnection.h67 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) = 0;
69 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) = 0;
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_store_impl.h38 class NDKStoreObserver : public OHOS::DistributedRdb::RdbStoreObserver {
41 using RdbStoreObserver = OHOS::DistributedRdb::RdbStoreObserver; variable
56 std::vector<RdbStoreObserver::PrimaryKey> &primaryKey);
57 size_t GetKeyInfoSize(RdbStoreObserver::ChangeInfo &&changeInfo);
58 int32_t GetKeyDataType(std::vector<RdbStoreObserver::PrimaryKey> &primaryKey);
H A Drelational_store.cpp1007 size_t NDKStoreObserver::GetKeyInfoSize(RdbStoreObserver::ChangeInfo &&changeInfo) in GetKeyInfoSize()
1011 … size += it->second[RdbStoreObserver::CHG_TYPE_INSERT].size() * sizeof(Rdb_KeyInfo::Rdb_KeyData); in GetKeyInfoSize()
1018 int32_t NDKStoreObserver::GetKeyDataType(std::vector<RdbStoreObserver::PrimaryKey> &primaryKey) in GetKeyDataType()
1033 …const Origin &origin, const RdbStoreObserver::PrimaryFields &fields, RdbStoreObserver::ChangeInfo … in OnChange()
1044 GetKeyInfoSize(std::forward<RdbStoreObserver::ChangeInfo &&>(changeInfo)); in OnChange()
1064 … infos[index]->updated.type = GetKeyDataType(it->second[RdbStoreObserver::CHG_TYPE_UPDATE]); in OnChange()
1066 … infos[index]->deleted.type = GetKeyDataType(it->second[RdbStoreObserver::CHG_TYPE_DELETE]); in OnChange()
1067 ConvertKeyInfoData(data, it->second[RdbStoreObserver::CHG_TYPE_INSERT]); in OnChange()
1072 it->second[RdbStoreObserver::CHG_TYPE_DELETE]); in OnChange()
1083 RdbStoreObserver::OnChange(); in OnChange()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_store_subscribe_test.cpp31 using CheckOnChangeFunc = std::function<void(RdbStoreObserver::ChangeInfo &changeInfo)>;
33 class SubObserver : public RdbStoreObserver {
195 observer->RegisterCallback([](RdbStoreObserver::ChangeInfo &changeInfo) { in RegisterCheckInsertCallback()
207 observer->RegisterCallback([](RdbStoreObserver::ChangeInfo &changeInfo) { in RegisterCheckUpdateCallback()
316 observer_->RegisterCallback([](RdbStoreObserver::ChangeInfo &) { ASSERT_TRUE(false); }); in __anonb9bbbf4f0302()
317 observer2->RegisterCallback([](RdbStoreObserver::ChangeInfo &) { ASSERT_TRUE(false); }); in __anonb9bbbf4f0402()
365 observer_->RegisterCallback([](RdbStoreObserver::ChangeInfo &) { ASSERT_TRUE(false); }); in __anonb9bbbf4f0502()
398 observer_->RegisterCallback([](RdbStoreObserver::ChangeInfo &changeInfo) { in __anonb9bbbf4f0602()
432 observer_->RegisterCallback([num](RdbStoreObserver::ChangeInfo &changeInfo) { in __anonb9bbbf4f0702()
479 observer_->RegisterCallback([num](RdbStoreObserver::ChangeInfo &changeInfo) { in __anonb9bbbf4f0802()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
H A Drdb_store.h74 using RdbStoreObserver = DistributedRdb::RdbStoreObserver; variable
75 using PRIKey = RdbStoreObserver::PrimaryKey;
590 virtual int Subscribe(const SubscribeOption& option, RdbStoreObserver *observer);
595 virtual int UnSubscribe(const SubscribeOption& option, RdbStoreObserver *observer);
600 …ubscribeObserver(const SubscribeOption& option, const std::shared_ptr<RdbStoreObserver> &observer);
605 …ubscribeObserver(const SubscribeOption& option, const std::shared_ptr<RdbStoreObserver> &observer);
H A Drdb_service.h51 RdbStoreObserver *observer) = 0;
54 RdbStoreObserver *observer) = 0;
H A Drdb_notifier.h23 using ChangeInfo = RdbStoreObserver::ChangeInfo;
H A Drdb_types.h267 class RdbStoreObserver {
275 virtual ~RdbStoreObserver() {}; in ~RdbStoreObserver()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Dsqlite_connection.h64 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) override;
66 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer) override;
112 const std::shared_ptr<DistributedRdb::RdbStoreObserver> &observer);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/include/
H A Dnapi_rdb_store_observer.h23 class NapiRdbStoreObserver : public DistributedRdb::RdbStoreObserver, public NapiUvQueue {
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/
H A Dnapi_rdb_store_observer.h25 class NapiRdbStoreObserver : public DistributedRdb::RdbStoreObserver,
/ohos5.0/foundation/filemanagement/dfs_service/test/unittests/clouddisk_database/include/
H A Dclouddisk_rdbstore_mock.h155 MOCK_METHOD2(Subscribe, int(const SubscribeOption &option, RdbStoreObserver *observer));
156 MOCK_METHOD2(UnSubscribe, int(const SubscribeOption &option, RdbStoreObserver *observer));
/ohos5.0/foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/mock/
H A Drdb_store_mock.h154 MOCK_METHOD2(Subscribe, int(const SubscribeOption &option, RdbStoreObserver *observer));
155 MOCK_METHOD2(UnSubscribe, int(const SubscribeOption &option, RdbStoreObserver *observer));
/ohos5.0/foundation/bundlemanager/app_domain_verify/test/unittest/mock/include/
H A Dmock_rdb.h255 int Subscribe(const SubscribeOption& option, RdbStoreObserver* observer) override in Subscribe()
260 int UnSubscribe(const SubscribeOption& option, RdbStoreObserver* observer) override in UnSubscribe()
/ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/include/
H A Dmock_app_provision_info.h260 virtual int Subscribe(const SubscribeOption& option, RdbStoreObserver *observer) in Subscribe()
265 virtual int UnSubscribe(const SubscribeOption& option, RdbStoreObserver *observer) in UnSubscribe()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_service_impl.h66 …int32_t Subscribe(const RdbSyncerParam &param, const SubscribeOption &option, RdbStoreObserver *ob…
69 RdbStoreObserver *observer) override;

12