Home
last modified time | relevance | path

Searched refs:changeNotification (Results 1 - 25 of 36) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dikvstore_observer.cpp48 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.IsClear())) || in OnChange()
72 !ITypesUtil::MarshalToBuffer(changeNotification.GetInsertEntries(), insertSize, data) || in OnChange()
73 !ITypesUtil::MarshalToBuffer(changeNotification.GetUpdateEntries(), updateSize, data) || in OnChange()
74 !ITypesUtil::MarshalToBuffer(changeNotification in OnChange()
[all...]
H A Dkvstore_observer_client.cpp34 void KvStoreObserverClient::OnChange(const ChangeNotification &changeNotification) in OnChange() argument
39 kvStoreObserver_->OnChange(changeNotification); in OnChange()
H A Dkvstore_observer_nb_impl.h75 AppChangeNotification changeNotification(insertListTmp, updateListTmp, deletedListTmp, std::string(), false); in OnChange()
76 appKvStoreObserver_->OnChange(changeNotification); in OnChange()
H A Dkvstore_observer_client.h33 void OnChange(const ChangeNotification &changeNotification) override;
/foundation/deviceprofile/device_info_manager/old/services/core/include/subscribemanager/
H A Dprofile_change_handler.h36 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 Dprofile_event_notifier_proxy.h30 void OnProfileChanged(const ProfileChangeNotification& changeNotification) override;
/foundation/deviceprofile/device_info_manager/old/services/core/src/subscribemanager/
H A Dprofile_change_handler.cpp76 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()
153 void ProfileChangeHandler::NotifyProfileChanged(const ProfileChangeNotification& changeNotification, in NotifyProfileChanged() argument
175 FilterChangedProfileLocked(subscribeInfo, changeNotification, service2Index, filterInfo); in NotifyProfileChanged()
177 NotifyProfileChangedLocked(changeNotification, filterInfo, profileEventNotifier); in NotifyProfileChanged()
182 void ProfileChangeHandler::NotifyProfileChangedLocked(const ProfileChangeNotification& changeNotification, in NotifyProfileChangedLocked() argument
191 profileEventNotifier->OnProfileChanged(changeNotification); in NotifyProfileChangedLocked()
204 const auto& profileEntries = changeNotification in NotifyProfileChangedLocked()
215 FilterChangedProfileLocked(const SubscribeInfo& subscribeInfo, const ProfileChangeNotification& changeNotification, const Service2Index& service2Index, FilterInfo& filterInfo) FilterChangedProfileLocked() argument
[all...]
H A Dprofile_event_notifier_proxy.cpp59 void ProfileEventNotifierProxy::OnProfileChanged(const ProfileChangeNotification& changeNotification) in OnProfileChanged() argument
68 if (!changeNotification.Marshalling(data)) { in OnProfileChanged()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/dbadapter/src/
H A Dmock_db_change_listener.cpp27 void MockDBChangeListener::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
29 (void)changeNotification; in OnChange()
/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/
H A Dkv_data_change_listener.cpp53 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 in OnChange()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/
H A Dversion_info_manager.cpp258 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 in OnChange()
[all...]
H A Dcapability_info_manager.cpp333 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 in OnChange()
[all...]
H A Dmeta_info_manager.cpp371 void MetaInfoManager::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange() argument
374 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
375 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
377 HandleMetaCapabilityAddChange(changeNotification.GetInsertEntries()); in OnChange()
379 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
380 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
382 HandleMetaCapabilityUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
384 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
385 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
387 HandleMetaCapabilityDeleteChange(changeNotification in OnChange()
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddistributed_data_change_listener.cpp62 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()
/foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/src/
H A Dprofile_event_notifier_stub.cpp93 ProfileChangeNotification changeNotification; in OnProfileChangedInner() local
94 if (!changeNotification.Unmarshalling(data)) { in OnProfileChangedInner()
98 profileEventCb_->OnProfileChanged(changeNotification); in OnProfileChangedInner()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/include/
H A Dikvstore_observer.h38 virtual void OnChange(const ChangeNotification &changeNotification) = 0;
55 void OnChange(const ChangeNotification &changeNotification) override;
/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/
H A Dprofile_proxy_test.cpp120 ProfileChangeNotification changeNotification; in HWTEST_F() local
122 eventCb.OnProfileChanged(changeNotification); in HWTEST_F()
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddistributed_data_change_listener.h29 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/dbadapter/include/
H A Dmock_db_change_listener.h29 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/mission/
H A Ddistributed_mission_info_test.cpp160 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), std::move(updateEntries), in HWTEST_F()
163 distributedDataChangeListener.OnChange(changeNotification); in HWTEST_F()
176 distributedDataChangeListener.OnChange(changeNotification); in HWTEST_F()
210 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), std::move(updateEntries), in HWTEST_F()
213 distributedDataChangeListener.OnChange(changeNotification); in HWTEST_F()
461 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), in HWTEST_F()
463 distributedDataChangeListener.OnChange(changeNotification); in HWTEST_F()
/foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/include/
H A Diprofile_event_callback.h37 virtual void OnProfileChanged(const ProfileChangeNotification& changeNotification) {} in OnProfileChanged() argument
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dkvstore_observer.h50 API_EXPORT virtual void OnChange(const ChangeNotification &changeNotification) {} in OnChange() argument
/foundation/deviceprofile/device_info_manager/old/tools/dp/include/
H A Ddp_command.h60 void OnProfileChanged(const ProfileChangeNotification& changeNotification) override;
/foundation/deviceprofile/device_info_manager/services/core/include/deviceprofilemanager/listener/
H A Dkv_data_change_listener.h33 void OnChange(const DistributedKv::ChangeNotification& changeNotification) override;
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/resourcemanager/
H A Dversion_info_manager.h54 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;

Completed in 10 milliseconds

12