| /foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/ |
| H A D | uri_convert_handler.cpp | 26 using ChangeType = DataShare::DataShareObserver::ChangeType;
27 unordered_map<ChangeType, NotifyType> NotifyTypeChangeMap = {
28 {ChangeType::INSERT, NotifyType::NOTIFY_ADD},
29 {ChangeType::UPDATE, NotifyType::NOTIFY_UPDATE},
30 {ChangeType::DELETE, NotifyType::NOTIFY_REMOVE},
34 const list<Uri> &sendUris, const ChangeType &changeType) in AddNewNotify()
39 ChangeType sendType = static_cast<ChangeType>(NotifyTypeChangeMap[changeType]); in AddNewNotify()
56 if (handleData.orgInfo.type == ChangeType in Handle()
[all...] |
| H A D | cloud_sync_notify_handler.cpp | 31 using ChangeType = DataShare::DataShareObserver::ChangeType;
133 void CloudSyncNotifyHandler::HandleExtraEvent(const std::list<Uri> &uris, const ChangeType &type) in HandleExtraEvent()
143 void CloudSyncNotifyHandler::ThumbnailObserverOnChange(const list<Uri> &uris, const ChangeType &type) in ThumbnailObserverOnChange()
147 case ChangeType::INSERT: in ThumbnailObserverOnChange()
150 case ChangeType::DELETE: in ThumbnailObserverOnChange()
189 if (notifyInfo_.type == ChangeType::UPDATE || notifyInfo_.type == ChangeType::OTHER) { in MakeResponsibilityChain()
|
| H A D | notify_handler.cpp | 25 using ChangeType = AAFwk::ChangeInfo::ChangeType;
35 obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(notifyInfo.first), notifyInfo.second}); in Handle()
|
| H A D | analysis_handler.cpp | 30 using ChangeType = DataShare::DataShareObserver::ChangeType;
83 ChangeType changeType = static_cast<ChangeType>(NotifyType::NOTIFY_UPDATE); in AddNewNotify()
102 if (handleData.orgInfo.type == ChangeType::OTHER) { in Handle()
103 MEDIA_INFO_LOG("Update the AnalysisAlbum for ChangeType being OTHER"); in Handle()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/src/ |
| H A D | notify_test.cpp | 97 EXPECT_EQ(obs->changeInfo_.changeType_, static_cast<DataShareObserver::ChangeType>(notifyType)); in CheckFileNotify()
135 void CheckAlbumNotify(NotifyType notifyType, DataShareObserver::ChangeType changeType) in CheckAlbumNotify()
188 static_cast<DataShareObserver::ChangeType>(NotifyType::NOTIFY_ADD)); in CheckCloseAssetNotify()
191 static_cast<DataShareObserver::ChangeType>(NotifyType::NOTIFY_UPDATE)); in CheckCloseAssetNotify()
202 const DataShareObserver::ChangeType &changeType) in CheckInfo()
207 if (changeType == DataShareObserver::ChangeType::OTHER) { in CheckInfo()
209 static_cast<DataShareObserver::ChangeType>(NotifyType::NOTIFY_REMOVE)); in CheckInfo()
210 } else if (changeType == DataShareObserver::ChangeType::INSERT) { in CheckInfo()
212 static_cast<DataShareObserver::ChangeType>(NotifyType::NOTIFY_ADD)); in CheckInfo()
213 } else if (changeType == DataShareObserver::ChangeType in CheckInfo()
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_local_db_observer.cpp | 30 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_INSERT); in OnChange()
31 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_UPDATE); in OnChange()
32 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_DELETE); in OnChange()
40 RdbStoreObserver::ChangeInfo &changeInfo, RdbStoreObserver::ChangeType changeType) in Convert()
42 if (changeType < RdbStoreObserver::ChangeType::CHG_TYPE_INSERT || in Convert()
43 changeType >= RdbStoreObserver::ChangeType::CHG_TYPE_BUTT) { in Convert()
|
| /foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/ |
| H A D | dataobs_mgr_inner_ext_test.cpp | 119 ChangeInfo changeInfo = { ChangeInfo::ChangeType::OTHER, {uri1} }; in HWTEST_F()
155 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
159 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2 } }); in HWTEST_F()
163 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri3 } }); in HWTEST_F()
196 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
204 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2, uri3 } }); in HWTEST_F()
235 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
239 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri12, uri123, uri14, uri2 } }); in HWTEST_F()
270 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
274 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType in HWTEST_F()
[all...] |
| /foundation/deviceprofile/device_info_manager/services/core/src/subscribeprofilemanager/ |
| H A D | subscribe_profile_manager.cpp | 35 funcsMap_[ProfileType::DEVICE_PROFILE * ChangeType::ADD] = in Init()
37 funcsMap_[ProfileType::DEVICE_PROFILE * ChangeType::UPDATE] = in Init()
39 funcsMap_[ProfileType::DEVICE_PROFILE * ChangeType::DELETE] = in Init()
41 funcsMap_[ProfileType::SERVICE_PROFILE * ChangeType::ADD] = in Init()
43 funcsMap_[ProfileType::SERVICE_PROFILE * ChangeType::UPDATE] = in Init()
45 funcsMap_[ProfileType::SERVICE_PROFILE * ChangeType::DELETE] = in Init()
47 funcsMap_[ProfileType::CHAR_PROFILE * ChangeType::ADD] = in Init()
49 funcsMap_[ProfileType::CHAR_PROFILE * ChangeType::UPDATE] = in Init()
51 funcsMap_[ProfileType::CHAR_PROFILE * ChangeType::DELETE] = in Init()
71 int32_t SubscribeProfileManager::NotifyProfileChange(ProfileType profileType, ChangeType changeTyp
[all...] |
| /foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/ |
| H A D | napi_datashare_const_properties.cpp | 41 SetNamedProperty(env, changeType, "INSERT", static_cast<int32_t>(DataShareObserver::ChangeType::INSERT));
in ExportChangeType()
42 SetNamedProperty(env, changeType, "DELETE", static_cast<int32_t>(DataShareObserver::ChangeType::DELETE));
in ExportChangeType()
43 SetNamedProperty(env, changeType, "UPDATE", static_cast<int32_t>(DataShareObserver::ChangeType::UPDATE));
in ExportChangeType()
60 DECLARE_NAPI_PROPERTY("ChangeType", ExportChangeType(env)),
in InitConstProperties()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_table_without_primary_key_sync_test.cpp | 80 void InitExpectChangedData(ChangedDataType dataType, int64_t count, ChangeType changeType) in InitExpectChangedData()
92 void InitExpectChangedDataByDetailsType(ChangedDataType dataType, int64_t count, ChangeType changeType, in InitExpectChangedDataByDetailsType()
123 InitExpectChangedDataByDetailsType(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT, in TestChangedDataInTrackerTable()
134 InitExpectChangedDataByDetailsType(ChangedDataType::DATA, cloudCount, ChangeType::OP_UPDATE, in TestChangedDataInTrackerTable()
145 InitExpectChangedDataByDetailsType(ChangedDataType::DATA, cloudCount, ChangeType::OP_DELETE, in TestChangedDataInTrackerTable()
219 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT); in HWTEST_F()
252 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_UPDATE); in HWTEST_F()
285 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_DELETE); in HWTEST_F()
309 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT); in HWTEST_F()
342 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType in HWTEST_F()
[all...] |
| H A D | distributeddb_cloud_table_compound_primary_key_sync_test.cpp | 72 void InitExpectChangedData(ChangedDataType dataType, int64_t count, ChangeType changeType) in InitExpectChangedData()
154 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT); in HWTEST_F()
187 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_UPDATE); in HWTEST_F()
220 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_DELETE); in HWTEST_F()
244 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT); in HWTEST_F()
277 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_UPDATE); in HWTEST_F()
310 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_DELETE); in HWTEST_F()
|
| /foundation/ability/ability_runtime/interfaces/inner_api/dataobs_manager/include/ |
| H A D | dataobs_mgr_changeinfo.h | 26 enum ChangeType : uint32_t {
40 ChangeType changeType_ = INVAILD;
|
| /foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/include/ |
| H A D | cloud_sync_notify_handler.h | 47 void ThumbnailObserverOnChange(const std::list<Uri> &uris, const DataShare::DataShareObserver::ChangeType &type);
55 void HandleExtraEvent(const std::list<Uri> &uris, const DataShare::DataShareObserver::ChangeType &type);
|
| H A D | cloud_sync_observer.h | 33 DataShare::DataShareObserver::ChangeType type;
|
| H A D | base_handler.h | 27 std::unordered_map<DataShare::DataShareObserver::ChangeType, std::list<Uri>> notifyInfo;
|
| /foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/ |
| H A D | datashare_observer.h | 33 enum ChangeType : uint32_t {
45 ChangeType changeType_ = INVAILD;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/include/ |
| H A D | device_matrix.h | 51 enum ChangeType : uint32_t {
74 LevelType type = LevelType::DYNAMIC, ChangeType changeType = ChangeType::CHANGE_ALL);
76 const StoreMetaData &metaData, ChangeType type = ChangeType::CHANGE_ALL);
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/include/ |
| H A D | lnn_data_cloud_sync.h | 71 } ChangeType; typedef
79 int32_t LnnDBDataChangeSyncToCache(const char *key, const char *value, ChangeType changeType);
|
| /foundation/deviceprofile/device_info_manager/radar/test/unittest/ |
| H A D | dp_radar_helper_test.cpp | 270 int32_t code = ProfileType::DEVICE_PROFILE * ChangeType::ADD; in HWTEST_F()
272 code = ProfileType::DEVICE_PROFILE * ChangeType::UPDATE; in HWTEST_F()
274 code = ProfileType::DEVICE_PROFILE * ChangeType::DELETE; in HWTEST_F()
276 code = ProfileType::SERVICE_PROFILE * ChangeType::ADD; in HWTEST_F()
278 code = ProfileType::SERVICE_PROFILE * ChangeType::UPDATE; in HWTEST_F()
280 code = ProfileType::SERVICE_PROFILE * ChangeType::DELETE; in HWTEST_F()
282 code = ProfileType::CHAR_PROFILE * ChangeType::ADD; in HWTEST_F()
284 code = ProfileType::CHAR_PROFILE * ChangeType::UPDATE; in HWTEST_F()
286 code = ProfileType::CHAR_PROFILE * ChangeType::DELETE; in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.h | 38 static ChangeType OpTypeToChangeType(OpType strategy);
63 ChangeType type);
107 static void InsertOrReplaceChangedDataByType(ChangeType type, std::vector<Type> &pkVal,
|
| H A D | cloud_sync_utils.cpp | 49 ChangeType CloudSyncUtils::OpTypeToChangeType(OpType strategy) in OpTypeToChangeType()
132 return changedData.primaryData[ChangeType::OP_INSERT].empty() || in IsChangeDataEmpty()
133 changedData.primaryData[ChangeType::OP_UPDATE].empty() || in IsChangeDataEmpty()
134 changedData.primaryData[ChangeType::OP_DELETE].empty(); in IsChangeDataEmpty()
198 const DataInfoWithLog &localInfo, ChangeType type) in SaveChangedDataByType()
202 if (type == ChangeType::OP_DELETE) { in SaveChangedDataByType()
394 param.changedData.primaryData[ChangeType::OP_UPDATE].size()); in SaveChangedData()
409 param.downloadData.data[dataIndex], param.changedData, dataInfo.localInfo, ChangeType::OP_INSERT); in SaveChangedData()
414 dataInfo.localInfo, ChangeType::OP_UPDATE); in SaveChangedData()
420 dataInfo.localInfo, ChangeType in SaveChangedData()
[all...] |
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 179 SubscribeProfileManager::GetInstance().NotifyProfileChange(profileType, ChangeType::ADD, dbKey, dbValue); in HandleAddChange()
190 SubscribeProfileManager::GetInstance().NotifyProfileChange(profileType, ChangeType::UPDATE, dbKey, dbValue); in HandleUpdateChange()
201 SubscribeProfileManager::GetInstance().NotifyProfileChange(profileType, ChangeType::DELETE, dbKey, dbValue); in HandleDeleteChange()
219 itemSwitchValue, ChangeType::UPDATE); in HandleSwitchUpdateChange()
232 const std::string& characteristicProfileKey, const std::string& characteristicProfileValue, ChangeType changeType) in GenerateSwitchNotify()
|
| /foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
| H A D | subscribe_profile_manager_test.cpp | 171 NotifyProfileChange(ProfileType::PROFILE_TYPE_MAX, ChangeType::CHANGE_TYPE_MAX, dbKey, dbValue); in HWTEST_F()
186 NotifyProfileChange(ProfileType::TRUST_DEVICE_PROFILE, ChangeType::ADD, dbKey, dbValue); in HWTEST_F()
787 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::ADD, dbKey, dbValue); in HWTEST_F()
802 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::UPDATE, dbKey, dbValue); in HWTEST_F()
817 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::DELETE, dbKey, dbValue); in HWTEST_F()
832 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::ADD, dbKey, dbValue); in HWTEST_F()
847 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::UPDATE, dbKey, dbValue); in HWTEST_F()
862 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::DELETE, dbKey, dbValue); in HWTEST_F()
877 NotifyProfileChange(ProfileType::CHAR_PROFILE, ChangeType::ADD, dbKey, dbValue); in HWTEST_F()
892 NotifyProfileChange(ProfileType::CHAR_PROFILE, ChangeType in HWTEST_F()
[all...] |
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_notify.cpp | 36 using ChangeType = AAFwk::ChangeInfo::ChangeType;
103 ChangeType changeType; in SendAlbumSub()
105 changeType = ChangeType::INSERT; in SendAlbumSub()
107 changeType = ChangeType::DELETE; in SendAlbumSub()
122 return obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(type), uris}); in SolveAlbumUri()
137 ret = obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(type), uris}); in PushNotifyDataMap()
|
| /foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/ |
| H A D | cloud_thumbnail_observer.cpp | 42 if (changeInfo.changeType_ != ChangeType::INSERT) {
in OnChange()
|