Home
last modified time | relevance | path

Searched refs:changeInfo (Results 1 - 25 of 127) sorted by relevance

123456

/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_local_db_observer.cpp28 RdbStoreObserver::ChangeInfo changeInfo; in OnChange() local
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()
36 observer_->OnChange(origin, fields, std::move(changeInfo)); in OnChange()
40 RdbStoreObserver::ChangeInfo &changeInfo, RdbStoreObserver::ChangeType changeType) in Convert()
46 changeInfo.try_emplace(dataInfo.tableName); in Convert()
50 changeInfo[dataInfo.tableName][changeType].push_back(std::move(primaryKey)); in Convert()
39 Convert(const DistributedDB::ChangedData &dataInfo, RdbStoreObserver::ChangeInfo &changeInfo, RdbStoreObserver::ChangeType changeType) Convert() argument
H A Drdb_notifier_stub.cpp90 int32_t RdbNotifierStub::OnChange(const Origin &origin, const PrimaryFields &primaries, ChangeInfo &&changeInfo) in OnChange() argument
93 changeNotifier_(origin, primaries, std::move(changeInfo)); in OnChange()
102 ChangeInfo changeInfo; in OnChangeInner() local
103 if (!ITypesUtil::Unmarshal(data, origin, primaries, changeInfo)) { in OnChangeInner()
107 return OnChange(origin, primaries, std::move(changeInfo)); in OnChangeInner()
/foundation/ability/ability_runtime/test/unittest/data_ability_observer_proxy_test/
H A Ddata_ability_observer_proxy_test.cpp82 ChangeInfo changeInfo; in HWTEST_F() local
83 changeInfo.data_ = new int(0); in HWTEST_F()
84 changeInfo.size_ = sizeof(int); in HWTEST_F()
89 proxy->OnChangeExt(changeInfo); in HWTEST_F()
91 if (changeInfo.data_ != nullptr) in HWTEST_F()
93 free(changeInfo.data_); in HWTEST_F()
94 changeInfo.data_ = nullptr; in HWTEST_F()
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/
H A Dcloud_thumbnail_observer.cpp39 void CloudThumbnailObserver::OnChange(const ChangeInfo &changeInfo) in OnChange() argument
42 if (changeInfo.changeType_ != ChangeType::INSERT) { in OnChange()
43 MEDIA_DEBUG_LOG("change type is %{public}d, not insert", changeInfo.changeType_); in OnChange()
46 for (auto &uri : changeInfo.uris_) { in OnChange()
/foundation/ability/ability_runtime/services/dataobsmgr/src/
H A Ddataobs_mgr_service.cpp170 ChangeInfo changeInfo = { ChangeInfo::ChangeType::OTHER, { uri } }; in NotifyChange() local
171 handler_->SubmitTask([this, uri, changeInfo]() { in NotifyChange()
176 dataObsMgrInnerExt_->HandleNotifyChange(changeInfo); in NotifyChange()
257 Status DataObsMgrService::NotifyChangeExt(const ChangeInfo &changeInfo) in NotifyChangeExt() argument
270 Status result = DeepCopyChangeInfo(changeInfo, changes); in NotifyChangeExt()
275 changeInfo.changeType_, changeInfo.uris_.size(), changeInfo.data_ == nullptr, changeInfo.size_); in NotifyChangeExt()
285 changeInfo in NotifyChangeExt()
[all...]
H A Ddataobs_mgr_proxy.cpp212 Status DataObsManagerProxy::NotifyChangeExt(const ChangeInfo &changeInfo) in NotifyChangeExt() argument
222 if (!ChangeInfo::Marshalling(changeInfo, data)) { in NotifyChangeExt()
224 "changeInfo marshalling error, changeType:%{public}ud, num:%{public}zu," in NotifyChangeExt()
226 changeInfo.changeType_, changeInfo.uris_.size(), changeInfo.data_ == nullptr, changeInfo.size_); in NotifyChangeExt()
235 error, changeInfo.changeType_, changeInfo.uris_.size(), changeInfo in NotifyChangeExt()
[all...]
H A Ddataobs_mgr_inner_ext.cpp83 Status DataObsMgrInnerExt::HandleNotifyChange(const ChangeInfo &changeInfo) in HandleNotifyChange() argument
89 for (auto &uri : changeInfo.uris_) { in HandleNotifyChange()
101 changeInfo.changeType_, changeInfo.uris_.size(), changeInfo.data_ == nullptr, changeInfo.size_); in HandleNotifyChange()
107 { changeInfo.changeType_, move(value), changeInfo.data_, changeInfo.size_, changeInfo in HandleNotifyChange()
[all...]
H A Ddata_ability_observer_stub.cpp76 ChangeInfo changeInfo; in OnChangeExtInner() local
77 if (!ChangeInfo::Unmarshalling(changeInfo, data)) { in OnChangeExtInner()
80 OnChangeExt(changeInfo); in OnChangeExtInner()
H A Ddata_ability_observer_proxy.cpp52 * @param changeInfo Indicates the info of the data to operate.
54 void DataAbilityObserverProxy::OnChangeExt(const ChangeInfo &changeInfo) in OnChangeExt() argument
65 if (!ChangeInfo::Marshalling(changeInfo, data)) { in OnChangeExt()
66 TAG_LOGE(AAFwkTag::DBOBSMGR, "changeInfo marshalling fail"); in OnChangeExt()
H A Ddataobs_mgr_stub.cpp146 ChangeInfo changeInfo; in NotifyChangeExtInner() local
147 if (!ChangeInfo::Unmarshalling(changeInfo, data)) { in NotifyChangeExtInner()
151 reply.WriteInt32(NotifyChangeExt(changeInfo)); in NotifyChangeExtInner()
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_store_subscribe_test.cpp31 using CheckOnChangeFunc = std::function<void(RdbStoreObserver::ChangeInfo &changeInfo)>;
40 const Origin &origin, const PrimaryFields &fields, RdbStoreObserver::ChangeInfo &&changeInfo) override;
136 void SubObserver::OnChange(const Origin &origin, const PrimaryFields &fields, RdbStoreObserver::ChangeInfo &&changeInfo) in OnChange() argument
140 checkOnChangeFunc_(changeInfo); in OnChange()
196 observer->RegisterCallback([](RdbStoreObserver::ChangeInfo &changeInfo) { in RegisterCheckInsertCallback()
197 ASSERT_EQ(changeInfo.size(), 1u); in RegisterCheckInsertCallback()
198 EXPECT_TRUE(changeInfo["local_test"][1].empty()); in RegisterCheckInsertCallback()
199 EXPECT_TRUE(changeInfo["local_test"][2].empty()); // 2 is delete subscript in RegisterCheckInsertCallback()
200 EXPECT_EQ(std::get<int64_t>(changeInfo["local_test"][0][0]), 1); in RegisterCheckInsertCallback()
208 observer->RegisterCallback([](RdbStoreObserver::ChangeInfo &changeInfo) { in RegisterCheckUpdateCallback()
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_helper.cpp276 * @param changeInfo Indicates the info of the data to operate.
278 void DataShareHelper::NotifyChangeExt(const DataShareObserver::ChangeInfo &changeInfo) in NotifyChangeExt() argument
286 ErrCode ret = obsMgrClient->NotifyChangeExt(ObserverImpl::ConvertInfo(changeInfo)); in NotifyChangeExt()
299 DataShareObserver::ChangeInfo changeInfo; in ConvertInfo() local
300 changeInfo.changeType_ = static_cast<const DataShareObserver::ChangeType>(info.changeType_); in ConvertInfo()
301 changeInfo.uris_ = std::move(info.uris_); in ConvertInfo()
302 changeInfo.data_ = info.data_; in ConvertInfo()
303 changeInfo.size_ = info.size_; in ConvertInfo()
304 changeInfo.valueBuckets_ = std::move(info.valueBuckets_); in ConvertInfo()
305 return changeInfo; in ConvertInfo()
310 AAFwk::ChangeInfo changeInfo; ConvertInfo() local
[all...]
/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/
H A Dmock.h33 void OnChangeExt(const ChangeInfo &changeInfo) override
35 onChangeCall_ += changeInfo.uris_.size();
36 changeInfo_ = changeInfo;
/foundation/multimedia/audio_framework/services/audio_policy/server/src/
H A Daudio_stream_collector.cpp170 [&sessionId](const std::shared_ptr<AudioRendererChangeInfo> &changeInfo) { in GetPipeType()
171 return changeInfo->sessionId == sessionId; in GetPipeType()
185 [&pipeType](const std::shared_ptr<AudioRendererChangeInfo> &changeInfo) { in ExistStreamForPipe()
186 return changeInfo->rendererInfo.pipeType == pipeType; in ExistStreamForPipe()
198 [&sessionId](const std::shared_ptr<AudioRendererChangeInfo> &changeInfo) { in GetRendererDeviceInfo()
199 return changeInfo->sessionId == sessionId; in GetRendererDeviceInfo()
386 [&sessionId](const std::shared_ptr<AudioRendererChangeInfo> &changeInfo) { in CheckRendererInfoChanged()
387 return changeInfo->sessionId == sessionId; in CheckRendererInfoChanged()
698 for (const auto &changeInfo : audioRendererChangeInfos_) { in GetStreamType()
699 if (changeInfo in GetStreamType()
[all...]
/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/
H A Dnapi_datashare_observer.cpp33 void NAPIDataShareObserver::OnChange(const ChangeInfo &changeInfo) in OnChange() argument
36 observer_->OnChange(changeInfo, true); in OnChange()
/foundation/distributeddatamgr/relational_store/test/ndk/unittest/
H A Drdb_store_test.cpp1072 void LocalDataChangeObserverCallback1(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) in LocalDataChangeObserverCallback1() argument
1075 EXPECT_EQ(DISTRIBUTED_CHANGE_INFO_VERSION, changeInfo[i]->version); in LocalDataChangeObserverCallback1()
1077 EXPECT_EQ(strcmp(changeInfo[i]->tableName, "store_test"), 0); in LocalDataChangeObserverCallback1()
1078 EXPECT_EQ(RDB_DATA_CHANGE, changeInfo[i]->ChangeType); in LocalDataChangeObserverCallback1()
1080 EXPECT_EQ(1, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback1()
1081 EXPECT_EQ(TYPE_INT64, changeInfo[i]->inserted.type); in LocalDataChangeObserverCallback1()
1083 EXPECT_EQ(2, changeInfo[i]->inserted.data->integer); in LocalDataChangeObserverCallback1()
1085 EXPECT_EQ(0, changeInfo[i]->updated.count); in LocalDataChangeObserverCallback1()
1087 EXPECT_EQ(0, changeInfo[i]->deleted.count); in LocalDataChangeObserverCallback1()
1116 void LocalDataChangeObserverCallback2(void *context, const Rdb_ChangeInfo **changeInfo, uint32_ argument
1167 LocalDataChangeObserverCallback3(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback3() argument
1245 LocalDataChangeObserverCallback4(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback4() argument
1283 LocalDataChangeObserverCallback5(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback5() argument
1342 LocalDataChangeObserverCallback6(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback6() argument
1402 LocalDataChangeObserverCallback7(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback7() argument
1408 LocalDataChangeObserverCallback8(void *context, const Rdb_ChangeInfo **changeInfo, uint32_t count) LocalDataChangeObserverCallback8() argument
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_rdb_store_observer.cpp59 void NapiRdbStoreObserver::OnChange(const Origin &origin, const PrimaryFields &fields, ChangeInfo &&changeInfo) in OnChange() argument
62 RdbStoreObserver::OnChange(origin, fields, std::move(changeInfo)); in OnChange()
66 for (auto it = changeInfo.begin(); it != changeInfo.end(); ++it) { in OnChange()
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/
H A Dcloud_sync_observer.cpp45 void CloudSyncObserver::OnChange(const ChangeInfo &changeInfo) in OnChange() argument
47 CloudSyncNotifyInfo notifyInfo = {changeInfo.uris_, changeInfo.changeType_}; in OnChange()
/foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/mock/
H A Ddata_ability_observer_stub.cpp77 ChangeInfo changeInfo; in OnChangeExtInner() local
78 if (!ChangeInfo::Unmarshalling(changeInfo, data)) { in OnChangeExtInner()
81 OnChangeExt(changeInfo); in OnChangeExtInner()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/include/
H A Dnotify_test.h30 void OnChange(const ChangeInfo &changeInfo) override
32 changeInfo_ = changeInfo;
/foundation/filemanagement/dfs_service/interfaces/kits/js/cloudfilesync/
H A Dcloud_sync_napi.h36 AAFwk::ChangeInfo changeInfo; member
107 UvChangeMsg(napi_env env, napi_ref ref, AAFwk::ChangeInfo &changeInfo, std::string strUri) in UvChangeMsg() argument
108 : env_(env), ref_(ref), changeInfo_(changeInfo), strUri_(std::move(strUri)) in UvChangeMsg()
160 void OnchangeExt(const AAFwk::ChangeInfo &changeInfo);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_notifier_proxy.cpp49 int32_t RdbNotifierProxy::OnChange(const Origin &origin, const PrimaryFields &primaries, ChangeInfo &&changeInfo) in OnChange() argument
56 if (!ITypesUtil::Marshal(data, origin, primaries, changeInfo)) { in OnChange()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drdb_notifier_stub.h34 ChangeInfo &&changeInfo)>;
41 int32_t OnChange(const Origin &origin, const PrimaryFields &primaries, ChangeInfo &&changeInfo) override;
/foundation/multimedia/audio_framework/frameworks/cj/src/
H A Dmultimedia_audio_common.cpp64 void Convert2CAudioCapturerChangeInfo(CAudioCapturerChangeInfo &cInfo, const AudioCapturerChangeInfo &changeInfo, in Convert2CAudioCapturerChangeInfo() argument
67 cInfo.muted = changeInfo.muted; in Convert2CAudioCapturerChangeInfo()
68 cInfo.streamId = changeInfo.sessionId; in Convert2CAudioCapturerChangeInfo()
69 Convert2CAudioCapturerInfo(cInfo.audioCapturerInfo, changeInfo.capturerInfo); in Convert2CAudioCapturerChangeInfo()
70 Convert2CArrDeviceDescriptorByDeviceInfo(cInfo.deviceDescriptors, changeInfo.inputDeviceInfo, errorCode); in Convert2CAudioCapturerChangeInfo()
/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_client_test/
H A Dmock_data_obs_manager_onchange_callback.h28 MOCK_METHOD1(OnChangeExt, void(const ChangeInfo &changeInfo));

Completed in 12 milliseconds

123456