| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | change_notification.cpp | 38 const std::vector<Entry> &ChangeNotification::GetUpdateEntries() const in GetUpdateEntries() function in OHOS::DistributedKv::ChangeNotification
|
| H A D | ikvstore_observer.cpp | 57 int64_t updateSize = ITypesUtil::GetTotalSize(changeNotification.GetUpdateEntries()); in OnChange()
73 !ITypesUtil::MarshalToBuffer(changeNotification.GetUpdateEntries(), updateSize, data) || in OnChange()
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | change_notification.h | 50 API_EXPORT const std::vector<Entry> &GetUpdateEntries() const;
|
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 63 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
64 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
65 HandleUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | types_util_test.cpp | 113 ASSERT_EQ(changeOut.GetUpdateEntries().size(), 1UL); in HWTEST_F()
114 EXPECT_EQ(changeOut.GetUpdateEntries().front().key.ToString(), std::string("update")); in HWTEST_F()
115 EXPECT_EQ(changeOut.GetUpdateEntries().front().value.ToString(), std::string("update_value")); in HWTEST_F()
|
| H A D | blob_test.cpp | 326 int64_t updateSize = ITypesUtil::GetTotalSize(changeIn.GetUpdateEntries()); in HWTEST_F()
329 ASSERT_TRUE(ITypesUtil::MarshalToBuffer(changeIn.GetUpdateEntries(), updateSize, parcel)); in HWTEST_F()
|
| H A D | single_kvstore_client_test.cpp | 112 updateEntries_ = changeNotification.GetUpdateEntries(); in OnChange()
|
| H A D | device_kvstore_test.cpp | 129 updateEntries_ = changeNotification.GetUpdateEntries(); in OnChange()
|
| H A D | local_subscribe_store_test.cpp | 124 updateEntries_ = changeNotification.GetUpdateEntries(); in OnChange()
|
| H A D | local_subscribe_device_store_test.cpp | 114 updateEntries_ = changeNotification.GetUpdateEntries(); in OnChange()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
| H A D | version_info_manager.cpp | 266 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
267 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
269 HandleVersionUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
|
| H A D | capability_info_manager.cpp | 341 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
342 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
344 HandleCapabilityUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
|
| H A D | meta_info_manager.cpp | 379 if (!changeNotification.GetUpdateEntries().empty() && in OnChange()
380 changeNotification.GetUpdateEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
382 HandleMetaCapabilityUpdateChange(changeNotification.GetUpdateEntries()); in OnChange()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | distributed_data_change_listener.cpp | 91 const vector<Entry>& updates = changeNotification.GetUpdateEntries(); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | observer_bridge.cpp | 104 auto updated = ObserverBridge::ConvertDB(data.GetUpdateEntries(), deviceId, convert_); in OnChange()
|
| H A D | kv_types_util.cpp | 86 return ITypesUtil::Marshal(parcel, notification.GetInsertEntries(), notification.GetUpdateEntries(), in Marshalling()
|
| /foundation/deviceprofile/device_info_manager/old/services/core/src/subscribemanager/ |
| H A D | profile_change_handler.cpp | 80 const auto& updatedEntries = changeNotification.GetUpdateEntries(); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_kv_store.cpp | 649 notification.GetInsertEntries().size(), notification.GetUpdateEntries().size(), in OnChange()
|
| H A D | js_util.cpp | 920 status = SetValue(env, in.GetUpdateEntries(), updateEntries, hasSchema); in SetValue()
921 CHECK_RETURN((status == napi_ok) || (updateEntries == nullptr), "GetUpdateEntries failed!", status); in SetValue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_impl.cpp | 401 std::vector<Entry> updateEntries = c.GetUpdateEntries(); in ChangeNotificationToCChangeNotification()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | single_store_impl_test.cpp | 48 update_ = notification.GetUpdateEntries();
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_util.cpp | 990 statusMsg = SetValue(env, in.GetUpdateEntries(), updateEntries, hasSchema); in SetValue()
991 ASSERT((statusMsg.status == napi_ok) || (updateEntries == nullptr), "GetUpdateEntries failed!", statusMsg); in SetValue()
|
| H A D | js_single_kv_store.cpp | 854 notification.GetInsertEntries().size(), notification.GetUpdateEntries().size(), in OnChange()
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_util.cpp | 954 status = SetValue(env, in.GetUpdateEntries(), updateEntries, hasSchema); in SetValue()
955 CHECK_RETURN((status == napi_ok) || (updateEntries == nullptr), "GetUpdateEntries failed!", status); in SetValue()
|