| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | change_notification.cpp | 43 const std::vector<Entry> &ChangeNotification::GetDeleteEntries() const in GetDeleteEntries() function in OHOS::DistributedKv::ChangeNotification
|
| H A D | ikvstore_observer.cpp | 58 int64_t deleteSize = ITypesUtil::GetTotalSize(changeNotification.GetDeleteEntries()); in OnChange()
74 !ITypesUtil::MarshalToBuffer(changeNotification.GetDeleteEntries(), deleteSize, data)) { in OnChange()
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | change_notification.h | 55 API_EXPORT const std::vector<Entry> &GetDeleteEntries() const;
|
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 67 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
68 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
69 HandleDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | types_util_test.cpp | 116 ASSERT_EQ(changeOut.GetDeleteEntries().size(), 1UL); in HWTEST_F()
117 EXPECT_EQ(changeOut.GetDeleteEntries().front().key.ToString(), std::string("delete")); in HWTEST_F()
118 EXPECT_EQ(changeOut.GetDeleteEntries().front().value.ToString(), std::string("delete_value")); in HWTEST_F()
|
| H A D | blob_test.cpp | 327 int64_t deleteSize = ITypesUtil::GetTotalSize(changeIn.GetDeleteEntries()); in HWTEST_F()
330 ASSERT_TRUE(ITypesUtil::MarshalToBuffer(changeIn.GetDeleteEntries(), deleteSize, parcel)); in HWTEST_F()
|
| H A D | single_kvstore_client_test.cpp | 113 deleteEntries_ = changeNotification.GetDeleteEntries(); in OnChange()
|
| H A D | device_kvstore_test.cpp | 130 deleteEntries_ = changeNotification.GetDeleteEntries(); in OnChange()
|
| H A D | local_subscribe_store_test.cpp | 125 deleteEntries_ = changeNotification.GetDeleteEntries(); in OnChange()
|
| H A D | local_subscribe_device_store_test.cpp | 115 deleteEntries_ = changeNotification.GetDeleteEntries(); in OnChange()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
| H A D | version_info_manager.cpp | 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 | capability_info_manager.cpp | 346 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
347 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
349 HandleCapabilityDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| H A D | meta_info_manager.cpp | 384 if (!changeNotification.GetDeleteEntries().empty() && in OnChange()
385 changeNotification.GetDeleteEntries().size() <= MAX_DB_RECORD_SIZE) { in OnChange()
387 HandleMetaCapabilityDeleteChange(changeNotification.GetDeleteEntries()); in OnChange()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | distributed_data_change_listener.cpp | 80 const vector<Entry>& deletes = changeNotification.GetDeleteEntries(); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | observer_bridge.cpp | 105 auto deleted = ObserverBridge::ConvertDB(data.GetDeleteEntries(), deviceId, convert_); in OnChange()
|
| H A D | kv_types_util.cpp | 87 notification.GetDeleteEntries(), notification.GetDeviceId(), notification.IsClear()); in Marshalling()
|
| /foundation/deviceprofile/device_info_manager/old/services/core/src/subscribemanager/ |
| H A D | profile_change_handler.cpp | 81 const auto& deletedEntries = changeNotification.GetDeleteEntries(); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_kv_store.cpp | 650 notification.GetDeleteEntries().size()); in OnChange()
|
| H A D | js_util.cpp | 926 status = SetValue(env, in.GetDeleteEntries(), deleteEntries, hasSchema); in SetValue()
927 CHECK_RETURN((status == napi_ok) || (deleteEntries == nullptr), "GetDeleteEntries failed!", status); in SetValue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_impl.cpp | 402 std::vector<Entry> deleteEntries = c.GetDeleteEntries(); in ChangeNotificationToCChangeNotification()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | single_store_impl_test.cpp | 49 delete_ = notification.GetDeleteEntries();
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_util.cpp | 996 statusMsg = SetValue(env, in.GetDeleteEntries(), deleteEntries, hasSchema); in SetValue()
997 ASSERT((statusMsg.status == napi_ok) || (deleteEntries == nullptr), "GetDeleteEntries failed!", statusMsg); in SetValue()
|
| H A D | js_single_kv_store.cpp | 855 notification.GetDeleteEntries().size()); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_util.cpp | 960 status = SetValue(env, in.GetDeleteEntries(), deleteEntries, hasSchema); in SetValue()
961 CHECK_RETURN((status == napi_ok) || (deleteEntries == nullptr), "GetDeleteEntries failed!", status); in SetValue()
|