| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_local_db_observer.cpp | 28 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 D | rd_connection.cpp | 199 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) in Subscribe()
205 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) in Unsubscribe()
|
| H A D | rdb_store.cpp | 473 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 D | rdb_store_impl.cpp | 422 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 D | rdb_store_impl.h | 53 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 D | rdb_local_db_observer.h | 28 …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 D | rdb_service_proxy.h | 30 RdbStoreObserver *observer = nullptr;
50 RdbStoreObserver *observer) override;
53 RdbStoreObserver *observer) override;
92 using ChangeInfo = RdbStoreObserver::ChangeInfo;
93 using PrimaryFields = RdbStoreObserver::PrimaryFields;
|
| H A D | rd_connection.h | 54 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) override;
56 const std::shared_ptr<DistributedRdb::RdbStoreObserver>& observer) override;
|
| H A D | sqlite_connection.h | 63 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 D | connection.h | 67 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 D | relational_store_impl.h | 38 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 D | relational_store.cpp | 1007 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 D | rdb_store_subscribe_test.cpp | 31 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 D | rdb_store.h | 74 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 D | rdb_service.h | 51 RdbStoreObserver *observer) = 0;
54 RdbStoreObserver *observer) = 0;
|
| H A D | rdb_notifier.h | 23 using ChangeInfo = RdbStoreObserver::ChangeInfo;
|
| H A D | rdb_types.h | 267 class RdbStoreObserver {
275 virtual ~RdbStoreObserver() {}; in ~RdbStoreObserver()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| H A D | sqlite_connection.h | 64 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 D | napi_rdb_store_observer.h | 23 class NapiRdbStoreObserver : public DistributedRdb::RdbStoreObserver, public NapiUvQueue {
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/ |
| H A D | napi_rdb_store_observer.h | 25 class NapiRdbStoreObserver : public DistributedRdb::RdbStoreObserver,
|
| /ohos5.0/foundation/filemanagement/dfs_service/test/unittests/clouddisk_database/include/ |
| H A D | clouddisk_rdbstore_mock.h | 155 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 D | rdb_store_mock.h | 154 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 D | mock_rdb.h | 255 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 D | mock_app_provision_info.h | 260 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 D | rdb_service_impl.h | 66 …int32_t Subscribe(const RdbSyncerParam ¶m, const SubscribeOption &option, RdbStoreObserver *ob…
69 RdbStoreObserver *observer) override;
|