| /ohos5.0/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; typedef
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 if (changeType == ChangeType::INSERT) { in AddNewNotify()
42 ChangeType sendType = static_cast<ChangeType>(NotifyTypeChangeMap[changeType]); in AddNewNotify()
59 if (handleData.orgInfo.type == ChangeType::OTHER) { in Handle()
60 AddNewNotify(newHandleData, { Uri(PhotoColumn::PHOTO_URI_PREFIX) }, ChangeType::DELETE); in Handle()
[all …]
|
| H A D | cloud_sync_notify_handler.cpp | 33 using ChangeType = DataShare::DataShareObserver::ChangeType; typedef
157 void CloudSyncNotifyHandler::HandleExtraEvent(const std::list<Uri> &uris, const ChangeType &type) in HandleExtraEvent()
167 void CloudSyncNotifyHandler::ThumbnailObserverOnChange(const list<Uri> &uris, const ChangeType &typ… in ThumbnailObserverOnChange()
171 case ChangeType::INSERT: in ThumbnailObserverOnChange()
174 case ChangeType::DELETE: in ThumbnailObserverOnChange()
209 if (notifyInfo_.type == ChangeType::DELETE) { in MakeResponsibilityChain()
217 if (notifyInfo_.type == ChangeType::UPDATE || notifyInfo_.type == ChangeType::OTHER) { in MakeResponsibilityChain()
|
| H A D | notify_handler.cpp | 25 using ChangeType = AAFwk::ChangeInfo::ChangeType; typedef
35 … obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(notifyInfo.first), notifyInfo.second}); in Handle()
|
| H A D | analysis_handler.cpp | 30 using ChangeType = DataShare::DataShareObserver::ChangeType; typedef
84 ChangeType changeType = static_cast<ChangeType>(NotifyType::NOTIFY_UPDATE); in AddNewNotify()
103 if (handleData.orgInfo.type == ChangeType::OTHER) { in Handle()
|
| H A D | cloud_album_handler.cpp | 39 using ChangeType = DataShare::DataShareObserver::ChangeType; typedef
168 if (handleData.orgInfo.type == ChangeType::DELETE) { in Handle()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/src/ |
| H A D | notify_test.cpp | 196 const DataShareObserver::ChangeType &changeType) in CheckInfo()
201 if (changeType == DataShareObserver::ChangeType::OTHER) { in CheckInfo()
204 } else if (changeType == DataShareObserver::ChangeType::INSERT) { in CheckInfo()
207 } else if (changeType == DataShareObserver::ChangeType::UPDATE) { in CheckInfo()
210 } else if (changeType == DataShareObserver::ChangeType::DELETE) { in CheckInfo()
218 changeType == DataShareObserver::ChangeType::OTHER) { in CheckInfo()
221 changeType == DataShareObserver::ChangeType::OTHER) { in CheckInfo()
234 const DataShareObserver::ChangeType &changeType) in CheckCloudSyncNotify()
604 emptyHandleData.orgInfo.type = DataShareObserver::ChangeType::OTHER;
628 emptyHandleData.orgInfo.type = DataShareObserver::ChangeType::OTHER;
[all …]
|
| /ohos5.0/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()
|
| /ohos5.0/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} };
155 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
159 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2 } });
163 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri3 } });
196 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
235 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
270 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
307 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
347 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
378 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
[all …]
|
| /ohos5.0/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()
47 funcsMap_[ProfileType::CHAR_PROFILE * ChangeType::ADD] = in Init()
77 case ProfileType::DEVICE_PROFILE * ChangeType::ADD: in NotifyProfileChange()
79 case ProfileType::DEVICE_PROFILE * ChangeType::UPDATE: in NotifyProfileChange()
81 case ProfileType::DEVICE_PROFILE * ChangeType::DELETE: in NotifyProfileChange()
83 case ProfileType::SERVICE_PROFILE * ChangeType::ADD: in NotifyProfileChange()
85 case ProfileType::SERVICE_PROFILE * ChangeType::UPDATE: in NotifyProfileChange()
87 case ProfileType::SERVICE_PROFILE * ChangeType::DELETE: in NotifyProfileChange()
89 case ProfileType::CHAR_PROFILE * ChangeType::ADD: in NotifyProfileChange()
91 case ProfileType::CHAR_PROFILE * ChangeType::UPDATE: in NotifyProfileChange()
[all …]
|
| /ohos5.0/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 change… 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);
252 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_UPDATE);
285 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_DELETE);
309 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT);
342 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_UPDATE);
[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);
187 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_UPDATE);
220 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_DELETE);
244 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT);
277 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_UPDATE);
310 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_DELETE);
|
| /ohos5.0/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::IN… in ExportChangeType()
42 …SetNamedProperty(env, changeType, "DELETE", static_cast<int32_t>(DataShareObserver::ChangeType::DE… in ExportChangeType()
43 …SetNamedProperty(env, changeType, "UPDATE", static_cast<int32_t>(DataShareObserver::ChangeType::UP… in ExportChangeType()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_mtp/include/ |
| H A D | ptp_media_sync_observer.h | 39 DataShare::DataShareObserver::ChangeType type;
57 void SendPhotoEvent(ChangeType changeType, std::string suffixString);
59 void SendEventToPTP(int32_t suff_int, ChangeType changeType);
|
| /ohos5.0/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);
186 NotifyProfileChange(ProfileType::TRUST_DEVICE_PROFILE, ChangeType::ADD, dbKey, dbValue);
787 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::ADD, dbKey, dbValue);
802 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::UPDATE, dbKey, dbValue);
817 NotifyProfileChange(ProfileType::DEVICE_PROFILE, ChangeType::DELETE, dbKey, dbValue);
832 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::ADD, dbKey, dbValue);
847 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::UPDATE, dbKey, dbValue);
862 NotifyProfileChange(ProfileType::SERVICE_PROFILE, ChangeType::DELETE, dbKey, dbValue);
877 NotifyProfileChange(ProfileType::CHAR_PROFILE, ChangeType::ADD, dbKey, dbValue);
892 NotifyProfileChange(ProfileType::CHAR_PROFILE, ChangeType::UPDATE, dbKey, dbValue);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/include/ |
| H A D | device_matrix.h | 51 enum ChangeType : uint32_t { enum
74 LevelType type = LevelType::DYNAMIC, ChangeType changeType = ChangeType::CHANGE_ALL);
76 const StoreMetaData &metaData, ChangeType type = ChangeType::CHANGE_ALL);
|
| /ohos5.0/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;
272 code = ProfileType::DEVICE_PROFILE * ChangeType::UPDATE;
274 code = ProfileType::DEVICE_PROFILE * ChangeType::DELETE;
276 code = ProfileType::SERVICE_PROFILE * ChangeType::ADD;
278 code = ProfileType::SERVICE_PROFILE * ChangeType::UPDATE;
280 code = ProfileType::SERVICE_PROFILE * ChangeType::DELETE;
282 code = ProfileType::CHAR_PROFILE * ChangeType::ADD;
284 code = ProfileType::CHAR_PROFILE * ChangeType::UPDATE;
286 code = ProfileType::CHAR_PROFILE * ChangeType::DELETE;
|
| /ohos5.0/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::OP_DELETE); in SaveChangedData()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/ |
| H A D | datashare_observer.h | 33 enum ChangeType : uint32_t { enum
45 ChangeType changeType_ = INVAILD;
|
| /ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/dataobs_manager/include/ |
| H A D | dataobs_mgr_changeinfo.h | 26 enum ChangeType : uint32_t { enum
40 ChangeType changeType_ = INVAILD;
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/include/ |
| H A D | cloud_sync_notify_handler.h | 47 …ObserverOnChange(const std::list<Uri> &uris, const DataShare::DataShareObserver::ChangeType &type);
55 …HandleExtraEvent(const std::list<Uri> &uris, const DataShare::DataShareObserver::ChangeType &type);
|
| /ohos5.0/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, db… in HandleAddChange()
190 …SubscribeProfileManager::GetInstance().NotifyProfileChange(profileType, ChangeType::UPDATE, dbKey,… in HandleUpdateChange()
201 …SubscribeProfileManager::GetInstance().NotifyProfileChange(profileType, ChangeType::DELETE, dbKey,… in HandleDeleteChange()
219 itemSwitchValue, ChangeType::UPDATE); in HandleSwitchUpdateChange()
232 …ng& characteristicProfileKey, const std::string& characteristicProfileValue, ChangeType changeType) in GenerateSwitchNotify()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_notify.cpp | 36 using ChangeType = AAFwk::ChangeInfo::ChangeType; typedef
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()
|
| /ohos5.0/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);
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.h | 83 using ChangeType = OHOS::DistributedData::DeviceMatrix::ChangeType; variable
134 ChangeType ConvertType(SyncMode syncMode) const;
|