| /ohos5.0/base/notification/distributed_notification_service/services/distributed/src/ |
| H A D | distributed_database_callback.cpp | 28 … DistributedDatabaseCallback::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
33 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetInsertEntries(); in OnChange()
36 …callback_.OnInsert(changeNotification.GetDeviceId(), entry.key.ToString(), entry.value.ToString()); in OnChange()
41 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetUpdateEntries(); in OnChange()
44 …callback_.OnUpdate(changeNotification.GetDeviceId(), entry.key.ToString(), entry.value.ToString()); in OnChange()
49 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetDeleteEntries(); in OnChange()
52 …callback_.OnDelete(changeNotification.GetDeviceId(), entry.key.ToString(), entry.value.ToString()); in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | ikvstore_observer.cpp | 48 void KvStoreObserverProxy::OnChange(const ChangeNotification &changeNotification) in OnChange() argument
56 int64_t insertSize = ITypesUtil::GetTotalSize(changeNotification.GetInsertEntries()); in OnChange()
57 int64_t updateSize = ITypesUtil::GetTotalSize(changeNotification.GetUpdateEntries()); in OnChange()
58 int64_t deleteSize = ITypesUtil::GetTotalSize(changeNotification.GetDeleteEntries()); in OnChange()
66 if (!ITypesUtil::Marshal(data, changeNotification)) { in OnChange()
71 …if (!ITypesUtil::Marshal(data, changeNotification.GetDeviceId(), uint32_t(changeNotification.IsCle… in OnChange()
72 !ITypesUtil::MarshalToBuffer(changeNotification.GetInsertEntries(), insertSize, data) || in OnChange()
73 !ITypesUtil::MarshalToBuffer(changeNotification.GetUpdateEntries(), updateSize, data) || in OnChange()
74 !ITypesUtil::MarshalToBuffer(changeNotification.GetDeleteEntries(), deleteSize, data)) { in OnChange()
|
| H A D | kvstore_observer_client.cpp | 34 void KvStoreObserverClient::OnChange(const ChangeNotification &changeNotification) in OnChange() argument
39 kvStoreObserver_->OnChange(changeNotification); in OnChange()
|
| H A D | kvstore_observer_nb_impl.h | 75 …AppChangeNotification changeNotification(insertListTmp, updateListTmp, deletedListTmp, std::string… in OnChange()
76 appKvStoreObserver_->OnChange(changeNotification); in OnChange()
|
| H A D | kvstore_observer_client.h | 33 void OnChange(const ChangeNotification &changeNotification) override;
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/src/subscribemanager/ |
| H A D | profile_change_handler.cpp | 76 void ProfileChangeHandler::OnChange(const ChangeNotification& changeNotification) in OnChange() argument
79 const auto& insertedEntries = changeNotification.GetInsertEntries(); in OnChange()
80 const auto& updatedEntries = changeNotification.GetUpdateEntries(); in OnChange()
81 const auto& deletedEntries = changeNotification.GetDeleteEntries(); in OnChange()
177 NotifyProfileChangedLocked(changeNotification, filterInfo, profileEventNotifier); in NotifyProfileChanged()
191 profileEventNotifier->OnProfileChanged(changeNotification); in NotifyProfileChangedLocked()
204 const auto& profileEntries = changeNotification.GetProfileEntries(); in NotifyProfileChangedLocked()
209 bool isLocal = changeNotification.IsLocal(); in NotifyProfileChangedLocked()
210 std::string deviceId = changeNotification.GetDeviceId(); in NotifyProfileChangedLocked()
216 const ProfileChangeNotification& changeNotification, in FilterChangedProfileLocked() argument
[all …]
|
| H A D | profile_event_notifier_proxy.cpp | 59 …id ProfileEventNotifierProxy::OnProfileChanged(const ProfileChangeNotification& changeNotification) in OnProfileChanged() argument
68 if (!changeNotification.Marshalling(data)) { in OnProfileChanged()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
| H A D | version_info_manager.cpp | 258 void VersionInfoManager::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
261 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
262 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
264 HandleVersionAddChange(changeNotification.GetInsertEntries()); in OnChange()
266 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
267 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
269 HandleVersionUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
271 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
272 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
274 HandleVersionDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| H A D | meta_info_manager.cpp | 340 void MetaInfoManager::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
343 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
344 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
346 HandleMetaCapabilityAddChange(changeNotification.GetInsertEntries()); in OnChange()
348 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
349 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
351 HandleMetaCapabilityUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
353 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
354 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
356 HandleMetaCapabilityDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| H A D | capability_info_manager.cpp | 333 void CapabilityInfoManager::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
336 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
337 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
339 HandleCapabilityAddChange(changeNotification.GetInsertEntries()); in OnChange()
341 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
342 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
344 HandleCapabilityUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
346 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
347 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
349 HandleCapabilityDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/include/subscribemanager/ |
| H A D | profile_change_handler.h | 36 void OnChange(const DistributedKv::ChangeNotification& changeNotification) override;
47 void NotifyProfileChanged(const ProfileChangeNotification& changeNotification,
50 const ProfileChangeNotification& changeNotification,
52 void NotifyProfileChangedLocked(const ProfileChangeNotification& changeNotification,
|
| H A D | profile_event_notifier_proxy.h | 30 void OnProfileChanged(const ProfileChangeNotification& changeNotification) override;
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 53 void KvDataChangeListener::OnChange(const DistributedKv::ChangeNotification& changeNotification) in OnChange() argument
59 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
60 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
61 HandleAddChange(changeNotification.GetInsertEntries()); in OnChange()
63 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
64 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
65 HandleUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
67 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
68 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
69 HandleDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| /ohos5.0/base/notification/distributed_notification_service/services/distributed/test/unittest/ |
| H A D | distributed_database_callback_test.cpp | 83 DistributedKv::ChangeNotification changeNotification(
85 databaseCallback_->OnChange(changeNotification);
119 DistributedKv::ChangeNotification changeNotification(
121 databaseCallback_->OnChange(changeNotification);
155 DistributedKv::ChangeNotification changeNotification(
157 databaseCallback_->OnChange(changeNotification);
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | distributed_data_change_listener.cpp | 62 void DistributedDataChangeListener::OnChange(const ChangeNotification &changeNotification) in OnChange() argument
65 const vector<Entry>& inserts = changeNotification.GetInsertEntries(); in OnChange()
80 const vector<Entry>& deletes = changeNotification.GetDeleteEntries(); in OnChange()
91 const vector<Entry>& updates = changeNotification.GetUpdateEntries(); in OnChange()
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/src/ |
| H A D | profile_event_notifier_stub.cpp | 93 ProfileChangeNotification changeNotification; variable
94 if (!changeNotification.Unmarshalling(data)) {
98 profileEventCb_->OnProfileChanged(changeNotification);
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/dbadapter/src/ |
| H A D | mock_db_change_listener.cpp | 27 void MockDBChangeListener::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
29 (void)changeNotification; in OnChange()
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/mission/ |
| H A D | distributed_mission_info_test.cpp | 160 …DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), std::move(updateEnt…
163 distributedDataChangeListener.OnChange(changeNotification);
176 distributedDataChangeListener.OnChange(changeNotification);
210 …DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), std::move(updateEnt…
213 distributedDataChangeListener.OnChange(changeNotification);
461 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries),
463 distributedDataChangeListener.OnChange(changeNotification);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/include/ |
| H A D | ikvstore_observer.h | 38 virtual void OnChange(const ChangeNotification &changeNotification) = 0;
55 void OnChange(const ChangeNotification &changeNotification) override;
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/ |
| H A D | profile_proxy_test.cpp | 120 ProfileChangeNotification changeNotification; variable
122 eventCb.OnProfileChanged(changeNotification);
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/ |
| H A D | distributed_data_change_listener.h | 29 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/dbadapter/include/ |
| H A D | mock_db_change_listener.h | 29 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/include/ |
| H A D | iprofile_event_callback.h | 37 virtual void OnProfileChanged(const ProfileChangeNotification& changeNotification) {} in OnProfileChanged() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | kvstore_observer.h | 50 API_EXPORT virtual void OnChange(const ChangeNotification &changeNotification) {} in OnChange() argument
|
| /ohos5.0/base/notification/distributed_notification_service/services/distributed/include/ |
| H A D | distributed_database_callback.h | 49 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
|