| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | change_notification.cpp | 33 const std::vector<Entry> &ChangeNotification::GetInsertEntries() const in GetInsertEntries() function in OHOS::DistributedKv::ChangeNotification
|
| H A D | ikvstore_observer.cpp | 56 int64_t insertSize = ITypesUtil::GetTotalSize(changeNotification.GetInsertEntries()); in OnChange()
72 !ITypesUtil::MarshalToBuffer(changeNotification.GetInsertEntries(), insertSize, data) || in OnChange()
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | change_notification.h | 45 API_EXPORT const std::vector<Entry> &GetInsertEntries() const;
|
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 59 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
60 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
61 HandleAddChange(changeNotification.GetInsertEntries()); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | types_util_test.cpp | 110 ASSERT_EQ(changeOut.GetInsertEntries().size(), 1UL); in HWTEST_F()
111 EXPECT_EQ(changeOut.GetInsertEntries().front().key.ToString(), std::string("insert")); in HWTEST_F()
112 EXPECT_EQ(changeOut.GetInsertEntries().front().value.ToString(), std::string("insert_value")); in HWTEST_F()
|
| H A D | blob_test.cpp | 325 int64_t insertSize = ITypesUtil::GetTotalSize(changeIn.GetInsertEntries()); in HWTEST_F()
328 ASSERT_TRUE(ITypesUtil::MarshalToBuffer(changeIn.GetInsertEntries(), insertSize, parcel)); in HWTEST_F()
|
| H A D | single_kvstore_client_test.cpp | 111 insertEntries_ = changeNotification.GetInsertEntries(); in OnChange()
|
| H A D | device_kvstore_test.cpp | 128 insertEntries_ = changeNotification.GetInsertEntries(); in OnChange()
|
| H A D | local_subscribe_store_test.cpp | 123 insertEntries_ = changeNotification.GetInsertEntries(); in OnChange()
|
| H A D | local_subscribe_device_store_test.cpp | 113 insertEntries_ = changeNotification.GetInsertEntries(); in OnChange()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
| H A D | version_info_manager.cpp | 261 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
262 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
264 HandleVersionAddChange(changeNotification.GetInsertEntries()); in OnChange()
|
| H A D | capability_info_manager.cpp | 336 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
337 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
339 HandleCapabilityAddChange(changeNotification.GetInsertEntries()); in OnChange()
|
| H A D | meta_info_manager.cpp | 374 if (!changeNotification.GetInsertEntries().empty() && in OnChange()
375 changeNotification.GetInsertEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
377 HandleMetaCapabilityAddChange(changeNotification.GetInsertEntries()); in OnChange()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | distributed_data_change_listener.cpp | 65 const vector<Entry>& inserts = changeNotification.GetInsertEntries(); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | observer_bridge.cpp | 103 auto inserted = ObserverBridge::ConvertDB(data.GetInsertEntries(), 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 | 79 const auto& insertedEntries = changeNotification.GetInsertEntries(); 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 | 914 status = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
915 CHECK_RETURN((status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries failed!", status); in SetValue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_impl.cpp | 400 std::vector<Entry> insertEntries = c.GetInsertEntries(); in ChangeNotificationToCChangeNotification()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | single_store_impl_test.cpp | 47 insert_ = notification.GetInsertEntries();
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_util.cpp | 984 statusMsg = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
985 ASSERT((statusMsg.status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries 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 | 948 status = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
949 CHECK_RETURN((status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries failed!", status); in SetValue()
|