Home
last modified time | relevance | path

Searched refs:subscriberId_ (Results 1 - 21 of 21) sorted by relevance

/foundation/resourceschedule/device_standby/plugins/message_listener/src/
H A Dinput_manager_listener.cpp36 subscriberId_ = MMI::InputManager::GetInstance()->SubscribeSwitchEvent( in StartListener()
41 STANDBYSERVICE_LOGD("start input manager listner, result is %{public}d", subscriberId_); in StartListener()
47 if (subscriberId_ < 0) { in StopListener()
51 MMI::InputManager::GetInstance()->UnsubscribeSwitchEvent(subscriberId_); in StopListener()
53 subscriberId_ = 0; in StopListener()
/foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/
H A Ddatashare_template.h56 int64_t subscriberId_; member
61 return subscriberId_ == tplId.subscriberId_ && bundleName_ == tplId.bundleName_; in operator ==()
69 if (subscriberId_ != tplId.subscriberId_) { in operator <()
70 return subscriberId_ < tplId.subscriberId_; in operator <()
101 int64_t subscriberId_; member
/foundation/distributeddatamgr/data_share/frameworks/native/common/src/
H A Ddatashare_template.cpp26 : key_(key), subscriberId_(subscriberId) in PublishedDataItem()
34 subscriberId_ = std::move(item.subscriberId_); in PublishedDataItem()
44 subscriberId_ = std::move(item.subscriberId_); in operator =()
81 sptr<Ashmem> mem = Ashmem::CreateAshmem((key_ + std::to_string(subscriberId_)).c_str(), size); in Set()
H A Ddatashare_itypes_utils.cpp89 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling()
95 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
113 return ITypesUtil::Unmarshal(parcel, templateId.subscriberId_, templateId.bundleName_); in Unmarshalling()
119 return ITypesUtil::Marshal(parcel, templateId.subscriberId_, templateId.bundleName_); in Marshalling()
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Dpublished_data_subscriber_manager.h34 int64_t subscriberId_; member
35 PublishedObserverMapKey(const std::string &uri, int64_t subscriberId) : uri_(uri), subscriberId_(subscriberId) in PublishedObserverMapKey()
46 return clearUri_ == node.clearUri_ && subscriberId_ == node.subscriberId_; in operator ==()
57 return subscriberId_ < node.subscriberId_; in operator <()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Ddata_share_subscriber_managers_test.cpp104 tpltId.subscriberId_ = TEST_SUB_ID; in HWTEST_F()
112 DataShare::Key key(DATA_SHARE_URI_TEST, tpltId.subscriberId_, tpltId.bundleName_); in HWTEST_F()
160 tpltId.subscriberId_ = TEST_SUB_ID;
162 DataShare::Key key(context->uri, tpltId.subscriberId_, tpltId.bundleName_);
183 tpltId.subscriberId_ = TEST_SUB_ID; in HWTEST_F()
185 DataShare::Key key(context->uri, tpltId.subscriberId_, tpltId.bundleName_); in HWTEST_F()
202 tpltId.subscriberId_ = TEST_SUB_ID; in HWTEST_F()
204 DataShare::PublishedDataKey key(context->uri, tpltId.bundleName_, tpltId.subscriberId_); in HWTEST_F()
H A Ddata_share_service_impl_test.cpp273 tplId.subscriberId_ = TEST_SUB_ID; in HWTEST_F()
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/
H A Dnapi_subscriber_manager.h77 int64_t subscriberId_; member
79 subscriberId_(subscriberId){}; in NapiPublishedObserverMapKey()
82 return uri_ == node.uri_ && subscriberId_ == node.subscriberId_; in operator ==()
93 return subscriberId_ < node.subscriberId_; in operator <()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_types_util.cpp52 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling()
58 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
70 return ITypesUtil::Unmarshal(parcel, templateId.subscriberId_, templateId.bundleName_); in Unmarshalling()
76 return ITypesUtil::Marshal(parcel, templateId.subscriberId_, templateId.bundleName_); in Marshalling()
H A Ddata_share_service_impl.cpp207 tpltId.subscriberId_ = subscriberId; in AddTemplate()
217 Key(uri, tpltId.subscriberId_, tpltId.bundleName_), context->currentUserId, tplt); in AddTemplate()
218 RdbSubscriberManager::GetInstance().Emit(context->uri, tpltId.subscriberId_, context); in AddTemplate()
227 tpltId.subscriberId_ = subscriberId; in DelTemplate()
236 Key(uri, tpltId.subscriberId_, tpltId.bundleName_), context->currentUserId); in DelTemplate()
282 publishedData.emplace_back(context->uri, context->calledBundleName, item.subscriberId_);
313 Key(context->uri, id.subscriberId_, id.bundleName_), observer, context, binderInfo_.executors);
327 Key(context->uri, id.subscriberId_, id.bundleName_), context->callerTokenId);
341 Key(context->uri, id.subscriberId_, id.bundleName_), context);
355 Key(context->uri, id.subscriberId_, i
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp83 keysMap[key.subscriberId_].emplace_back(key.uri_); in DelObservers()
200 keysMap[key.subscriberId_].emplace_back(key.uri_);
216 Key key(data.key_, data.subscriberId_);
224 PublishedObserverMapKey key(data.key_, data.subscriberId_);
231 value.datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
236 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
252 node.datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
269 PublishedObserverMapKey mapKey(data.key_, data.subscriberId_);
273 results[obs.observer_].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
282 num, obsVector.size(), DataShareStringUtils::Anonymous(key.uri_).c_str(), key.subscriberId_);
[all...]
H A Ddata_share_service_proxy.cpp300 LOG_ERROR("Observer is nullptr, subscriberId: %{public}" PRId64, templateId.subscriberId_); in SubscribeRdbData()
309 if (!ITypesUtil::Marshal(data, uris, templateId.subscriberId_, templateId.bundleName_)) { in SubscribeRdbData()
340 if (!ITypesUtil::Marshal(data, uris, templateId.subscriberId_, templateId.bundleName_)) { in UnSubscribeRdbData()
367 if (!ITypesUtil::Marshal(data, uris, templateId.subscriberId_, templateId.bundleName_)) { in EnableSubscribeRdbData()
394 if (!ITypesUtil::Marshal(data, uris, templateId.subscriberId_, templateId.bundleName_)) { in DisableSubscribeRdbData()
H A Drdb_subscriber_manager.cpp226 DataShareStringUtils::Anonymous(key.uri_).c_str(), key.templateId_.subscriberId_);
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp193 Key key(data.key_, data.subscriberId_);
198 Key key(data.key_, data.subscriberId_);
204 lastChangeNodeMap_[key].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
207 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
225 node.datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
/foundation/resourceschedule/device_standby/plugins/message_listener/include/
H A Dinput_manager_listener.h40 int32_t subscriberId_ {0};
/foundation/distributeddatamgr/data_share/test/native/unittest/datashareproxy_test/
H A Dproxydatas_with_permission_test.cpp217 EXPECT_EQ(publishedDataItem.subscriberId_, SUBSCRIBER_ID); in HWTEST_F()
265 EXPECT_EQ(publishedDataItem.subscriberId_, SUBSCRIBER_ID); in HWTEST_F()
287 tplId.subscriberId_ = SUBSCRIBER_ID; in HWTEST_F()
293 EXPECT_EQ(changeNode.templateId_.subscriberId_, tplId.subscriberId_); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/strategies/
H A Dpublish_strategy.cpp45 PublishedDataNode node(context->uri, context->calledBundleName, item.subscriberId_, context->currentUserId, in Execute()
/foundation/distributeddatamgr/data_share/frameworks/js/napi/common/src/
H A Ddatashare_js_utils.cpp361 napi_value subscriberId = Convert2JSValue(env, std::to_string(templateId.subscriberId_)); in Convert2JSValue()
411 subscriberId = Convert2JSValue(env, std::to_string(publishedDataItem.subscriberId_)); in Convert2JSValue()
578 templateId.subscriberId_ = atoll(strSubId.c_str()); in Convert2TemplateId()
620 publishedDataItem.subscriberId_ = atoll(strSubId.c_str()); in UnwrapPublishedDataItem()
/foundation/ability/form_fwk/services/src/
H A Dform_data_proxy_record.cpp269 templateId.subscriberId_ = search.subscribeId; in SubscribeRdbFormData()
349 templateId.subscriberId_ = search.subscribeId; in UnsubscribeFormData()
621 templateId.subscriberId_ = search.subscribeId; in SetRdbSubsState()
790 templateId.subscriberId_ = record.subscribeId; in RetryFailureRdbSubscribes()
/foundation/resourceschedule/device_standby/plugins/test/unittest/
H A Dstandby_plugin_unit_test.cpp880 inputManagerListener->subscriberId_ = -1; in HWTEST_F()
884 EXPECT_TRUE(inputManagerListener->subscriberId_ <= 0); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Drdb_subscriber_manager.cpp337 changeNode.templateId_.subscriberId_ = key.subscriberId; in Notify()

Completed in 13 milliseconds