Home
last modified time | relevance | path

Searched refs:subscriberId (Results 1 - 25 of 42) sorted by relevance

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/data/
H A Dtemplate_data.cpp52 ret = ret && SetValue(node[GET_NAME(subscriberId)], subscriberId); in Marshal()
62 if (!GetValue(node, GET_NAME(subscriberId), subscriberId)) { in Unmarshal()
64 if (GetValue(node, GET_NAME(subscriberId), subId)) { in Unmarshal()
65 subscriberId = std::to_string(subId); in Unmarshal()
75 TemplateRootNode::TemplateRootNode(const std::string &uri, const std::string &bundleName, const int64_t subscriberId, in TemplateRootNode() argument
77 : uri(uri), bundleName(bundleName), subscriberId(std::to_string(subscriberId)), userId(userId), tpl(tpl) in TemplateRootNode()
92 const std::string &uri, const std::string &bundleName, int64_t subscriberId, int32_ in TemplateData()
91 TemplateData( const std::string &uri, const std::string &bundleName, int64_t subscriberId, int32_t userId, const Template &tpl) TemplateData() argument
102 GenId(const std::string &uri, const std::string &bundleName, int64_t subscriberId) GenId() argument
146 Add(const std::string &uri, const int32_t userId, const std::string &bundleName, const int64_t subscriberId, const Template &aTemplate) Add() argument
164 Delete( const std::string &uri, const int32_t userId, const std::string &bundleName, const int64_t subscriberId) Delete() argument
[all...]
H A Dpublished_data.cpp44 : KvData(Id(GenId(node.key, node.bundleName, node.subscriberId), node.userId)), value(node) in PublishedData()
76 ret = ret && SetValue(node[GET_NAME(subscriberId)], subscriberId); in Marshal()
87 ret = ret && GetValue(node, GET_NAME(subscriberId), subscriberId); in Unmarshal()
97 PublishedDataNode::PublishedDataNode(const std::string &key, const std::string &bundleName, int64_t subscriberId, in PublishedDataNode() argument
99 : VersionData(-1), key(key), bundleName(bundleName), subscriberId(subscriberId), value(std::move(value)), in PublishedDataNode()
161 std::string PublishedData::GenId(const std::string &key, const std::string &bundleName, int64_t subscriberId) in GenId() argument
163 return key + "_" + std::to_string(subscriberId) in GenId()
226 UpdateTimestamp( const std::string &key, const std::string &bundleName, int64_t subscriberId, const int32_t userId) UpdateTimestamp() argument
[all...]
H A Dtemplate_data.h45 TemplateRootNode(const std::string &uri, const std::string &bundleName, const int64_t subscriberId,
53 std::string subscriberId; member
59 TemplateData(const std::string &uri, const std::string &bundleName, int64_t subscriberId, int32_t userId,
62 static std::string GenId(const std::string &uri, const std::string &bundleName, int64_t subscriberId);
65 const int64_t subscriberId, const Template &aTemplate);
67 const std::string &uri, const int32_t userId, const std::string &bundleName, const int64_t subscriberId);
H A Dpublished_data.h36 PublishedDataNode(const std::string &key, const std::string &bundleName, int64_t subscriberId,
43 int64_t subscriberId = 0; member in OHOS::DataShare::final
55 const std::string &key, const std::string &bundleName, int64_t subscriberId, const int32_t userId);
58 static std::string GenId(const std::string &key, const std::string &bundleName, int64_t subscriberId);
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp27 std::shared_ptr<DataShareServiceProxy> proxy, const std::vector<std::string> &uris, int64_t subscriberId, in AddObservers()
35 std::for_each(uris.begin(), uris.end(), [&keys, &subscriberId](auto &uri) { in AddObservers()
36 keys.emplace_back(uri, subscriberId); in AddObservers()
43 [&proxy, subscriber, &subscriberId, this](const std::vector<Key> &firstAddKeys, in AddObservers()
54 auto subResults = proxy->SubscribePublishedData(firstAddUris, subscriberId, serviceCallback_); in AddObservers()
59 failedKeys.emplace_back(subResult.key_, subscriberId); in AddObservers()
85 for (auto const &[subscriberId, uris] : keysMap) { in DelObservers()
86 auto results = proxy->UnSubscribePublishedData(uris, subscriberId); in DelObservers()
94 std::shared_ptr<DataShareServiceProxy> proxy, const std::vector<std::string> &uris, int64_t subscriberId) in DelObservers()
105 std::for_each(uris.begin(), uris.end(), [&keys, &subscriberId](aut in DelObservers()
26 AddObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, const std::vector<std::string> &uris, int64_t subscriberId, const PublishedDataCallback &callback) AddObservers() argument
93 DelObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, const std::vector<std::string> &uris, int64_t subscriberId) DelObservers() argument
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/
H A Dpublished_data_controller.cpp44 const std::vector<std::string> &uris, int64_t subscriberId, in SubscribePublishedData()
52 return PublishedDataSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, subscriberId, callback); in SubscribePublishedData()
56 const std::vector<std::string> &uris, int64_t subscriberId) in UnSubscribePublishedData()
66 return PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subscriberId); in UnSubscribePublishedData()
70 const std::vector<std::string> &uris, int64_t subscriberId) in EnableSubscribePublishedData()
77 return PublishedDataSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, uris, subscriberId); in EnableSubscribePublishedData()
81 const std::vector<std::string> &uris, int64_t subscriberId) in DisableSubscribePublishedData()
88 return PublishedDataSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, uris, subscriberId); in DisableSubscribePublishedData()
43 SubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback) SubscribePublishedData() argument
55 UnSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, int64_t subscriberId) UnSubscribePublishedData() argument
69 EnableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, int64_t subscriberId) EnableSubscribePublishedData() argument
80 DisableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, int64_t subscriberId) DisableSubscribePublishedData() argument
H A Dpersistent_data_controller.cpp23 int PersistentDataController::AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl) in AddQueryTemplate() argument
30 return proxy->AddQueryTemplate(uri, subscriberId, tpl); in AddQueryTemplate()
33 int PersistentDataController::DelQueryTemplate(const std::string &uri, int64_t subscriberId) in DelQueryTemplate() argument
40 return proxy->DelQueryTemplate(uri, subscriberId); in DelQueryTemplate()
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/include/
H A Dpublished_data_controller.h35 int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback);
38 int64_t subscriberId);
41 int64_t subscriberId);
44 int64_t subscriberId);
H A Dpersistent_data_controller.h30 int AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl);
32 int DelQueryTemplate(const std::string &uri, int64_t subscriberId);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Drdb_subscriber_manager.cpp33 return TemplateData::Query(Id(TemplateData::GenId(key.uri, key.bundleName, key.subscriberId), userId), tpl) == E_OK; in Get()
38 auto status = TemplateData::Add(key.uri, userId, key.bundleName, key.subscriberId, tpl); in Add()
48 auto status = TemplateData::Delete(key.uri, userId, key.bundleName, key.subscriberId); in Delete()
57 Key::Key(const std::string &uri, int64_t subscriberId, const std::string &bundleName) in Key() argument
58 : uri(uri), subscriberId(subscriberId), bundleName(bundleName) in Key()
64 return uri == rhs.uri && subscriberId == rhs.subscriberId && bundleName == rhs.bundleName; in operator ==()
79 if (subscriberId < rhs.subscriberId) { in operator <()
362 Emit(const std::string &uri, int64_t subscriberId, std::shared_ptr<Context> context) Emit() argument
[all...]
H A Dpublished_data_subscriber_manager.cpp128 Id(PublishedData::GenId(key.key, key.bundleName, key.subscriberId), userId), publishedResult[key]); in Emit()
131 data.subscriberId); in Emit()
145 result.datas_.emplace_back(key.key, key.subscriberId, PublishedDataNode::MoveTo(publishedResult[key])); in Emit()
215 PublishedDataKey::PublishedDataKey(const std::string &key, const std::string &bundle, const int64_t subscriberId) in PublishedDataKey() argument
216 : key(key), bundleName(bundle), subscriberId(subscriberId) in PublishedDataKey()
240 return subscriberId < rhs.subscriberId; in operator <()
260 return key == rhs.key && bundleName == rhs.bundleName && subscriberId == rhs.subscriberId; in operator ==()
[all...]
H A Drdb_subscriber_manager.h32 Key(const std::string &uri, int64_t subscriberId, const std::string &bundleName);
40 const int64_t subscriberId; member
64 void Emit(const std::string &uri, int64_t subscriberId, std::shared_ptr<Context> context);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_service_stub.cpp118 int64_t subscriberId; in OnAddTemplate() local
120 if (!ITypesUtil::Unmarshal(data, uri, subscriberId, tpl.predicates_, tpl.scheduler_)) { in OnAddTemplate()
124 int32_t status = AddTemplate(uri, subscriberId, tpl); in OnAddTemplate()
135 int64_t subscriberId; in OnDelTemplate() local
136 if (!ITypesUtil::Unmarshal(data, uri, subscriberId)) { in OnDelTemplate()
140 int32_t status = DelTemplate(uri, subscriberId); in OnDelTemplate()
254 int64_t subscriberId; in OnSubscribePublishedData() local
255 if (!ITypesUtil::Unmarshal(data, uris, subscriberId)) { in OnSubscribePublishedData()
264 std::vector<OperationResult> results = SubscribePublishedData(uris, subscriberId, observer); in OnSubscribePublishedData()
275 int64_t subscriberId; in OnUnsubscribePublishedData() local
291 int64_t subscriberId; OnEnablePubSubs() local
307 int64_t subscriberId; OnDisablePubSubs() local
[all...]
H A Didata_share_service.h63 virtual int32_t AddTemplate(const std::string &uri, const int64_t subscriberId, const Template &tplt) = 0;
64 virtual int32_t DelTemplate(const std::string &uri, const int64_t subscriberId) = 0;
76 const int64_t subscriberId, const sptr<IDataProxyPublishedDataObserver> observer) = 0;
78 const int64_t subscriberId) = 0;
80 const int64_t subscriberId) = 0;
82 const int64_t subscriberId) = 0;
H A Ddata_share_service_impl.cpp203 int32_t DataShareServiceImpl::AddTemplate(const std::string &uri, const int64_t subscriberId, const Template &tplt) in AddTemplate() argument
207 tpltId.subscriberId_ = subscriberId; in AddTemplate()
212 ZLOGI("Add template, uri %{private}s, subscriberId %{public}" PRIi64 ", bundleName %{public}s," in AddTemplate()
214 uri.c_str(), subscriberId, tpltId.bundleName_.c_str(), tplt.predicates_.size()); in AddTemplate()
223 int32_t DataShareServiceImpl::DelTemplate(const std::string &uri, const int64_t subscriberId) in DelTemplate() argument
227 tpltId.subscriberId_ = subscriberId; in DelTemplate()
232 ZLOGI("Delete template, uri %{private}s, subscriberId %{public}" PRIi64 ", bundleName %{public}s.", in DelTemplate()
233 DistributedData::Anonymous::Change(uri).c_str(), subscriberId, tpltId.bundleName_.c_str()); in DelTemplate()
362 const int64_t subscriberId, const sptr<IDataProxyPublishedDataObserver> observer)
375 PublishedDataKey key(uri, callerBundleName, subscriberId);
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Dpublished_data_subscriber_manager.h35 PublishedObserverMapKey(const std::string &uri, int64_t subscriberId) : uri_(uri), subscriberId_(subscriberId) in PublishedObserverMapKey()
84 const std::vector<std::string> &uris, int64_t subscriberId, const PublishedDataCallback &callback);
86 const std::vector<std::string> &uris, int64_t subscriberId);
89 const std::vector<std::string> &uris, int64_t subscriberId);
91 const std::vector<std::string> &uris, int64_t subscriberId);
H A Ddata_share_service_proxy.h39 int AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl) override;
41 int DelQueryTemplate(const std::string &uri, int64_t subscriberId) override;
59 std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId,
63 const std::vector<std::string> &uris, int64_t subscriberId) override;
66 const std::vector<std::string> &uris, int64_t subscriberId) override;
69 const std::vector<std::string> &uris, int64_t subscriberId) override;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Ddata_share_service_impl_test.cpp165 int64_t subscriberId = 0; in HWTEST_F() local
173 auto result = dataShareServiceImpl.AddTemplate(uri, subscriberId, tpl); in HWTEST_F()
175 result = dataShareServiceImpl.DelTemplate(uri, subscriberId); in HWTEST_F()
180 result = dataShareServiceImpl.AddTemplate(uri, subscriberId, tpl); in HWTEST_F()
182 result = dataShareServiceImpl.DelTemplate(uri, subscriberId); in HWTEST_F()
322 int64_t subscriberId = TEST_SUB_ID; in HWTEST_F() local
326 std::vector<OperationResult> result = dataShareServiceImpl.SubscribePublishedData(uris, subscriberId, observer); in HWTEST_F()
332 result = dataShareServiceImpl.UnsubscribePublishedData(uris, subscriberId); in HWTEST_F()
351 int64_t subscriberId = 0; in HWTEST_F() local
352 std::vector<OperationResult> result = dataShareServiceImpl.SubscribePublishedData(uris, subscriberId, observe in HWTEST_F()
376 int64_t subscriberId = TEST_SUB_ID; HWTEST_F() local
403 int64_t subscriberId = 0; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp118 const std::vector<std::string> &uris, int64_t subscriberId) in AddObservers()
127 std::for_each(uris.begin(), uris.end(), [&keys, &subscriberId](auto &uri) { in AddObservers()
128 keys.emplace_back(uri, subscriberId); in AddObservers()
135 [&dataShareHelper, &subscriberId, this](const std::vector<Key> &firstAddKeys, in AddObservers()
144 auto subResults = dataShareHelper->SubscribePublishedData(firstAddUris, subscriberId, in AddObservers()
152 failedKeys.emplace_back(subResult.key_, subscriberId); in AddObservers()
163 const std::vector<std::string> &uris, int64_t subscriberId)
171 std::for_each(uris.begin(), uris.end(), [&keys, &subscriberId](auto &uri) {
172 keys.emplace_back(uri, subscriberId);
175 [&dataShareHelper, &subscriberId,
117 AddObservers(napi_env env, napi_value callback, const std::vector<std::string> &uris, int64_t subscriberId) AddObservers() argument
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Dscheduler_manager.cpp110 ", bundleName=%{public}s.", reminderTime, now, key.subscriberId, key.bundleName.c_str()); in SetTimer()
115 duration, key.subscriberId, key.bundleName.c_str()); in SetTimer()
118 ZLOGD("has current taskId, uri is %{private}s, subscriberId is %{public}" PRId64 ", bundleName is %{public}s", in SetTimer()
119 DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in SetTimer()
125 ZLOGI("schedule notify start, uri is %{private}s, subscriberId is %{public}" PRId64 ", bundleName is " in SetTimer()
127 key.subscriberId, key.bundleName.c_str()); in SetTimer()
146 ZLOGI("create new task success, uri is %{public}s, subscriberId is %{public}" PRId64 ", bundleName is %{public}s", in SetTimer()
147 DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in SetTimer()
157 DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in ExecuteSchedulerSQL()
162 DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, ke in ExecuteSchedulerSQL()
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/common/include/
H A Didata_share_service.h48 virtual int AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl) = 0;
50 virtual int DelQueryTemplate(const std::string &uri, int64_t subscriberId) = 0;
69 int64_t subscriberId, const sptr<IDataProxyPublishedDataObserver> &observer) = 0;
72 int64_t subscriberId) = 0;
75 int64_t subscriberId) = 0;
78 int64_t subscriberId) = 0;
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_helper_impl.cpp311 int DataShareHelperImpl::AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl) in AddQueryTemplate() argument
321 return persistentDataCtl->AddQueryTemplate(uri, subscriberId, tpl); in AddQueryTemplate()
324 int DataShareHelperImpl::DelQueryTemplate(const std::string &uri, int64_t subscriberId) in DelQueryTemplate() argument
334 return persistentDataCtl->DelQueryTemplate(uri, subscriberId); in DelQueryTemplate()
414 int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback) in SubscribePublishedData()
425 return publishedDataCtl->SubscribePublishedData(this, uris, subscriberId, callback); in SubscribePublishedData()
429 int64_t subscriberId) in UnsubscribePublishedData()
440 return publishedDataCtl->UnSubscribePublishedData(this, uris, subscriberId); in UnsubscribePublishedData()
444 int64_t subscriberId) in EnablePubSubs()
452 return publishedDataCtl->EnableSubscribePublishedData(this, uris, subscriberId); in EnablePubSubs()
413 SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback) SubscribePublishedData() argument
428 UnsubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId) UnsubscribePublishedData() argument
443 EnablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) EnablePubSubs() argument
455 DisablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) DisablePubSubs() argument
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/include/
H A Ddatashare_helper_impl.h71 int AddQueryTemplate(const string &uri, int64_t subscriberId, Template &tpl) override;
73 int DelQueryTemplate(const string &uri, int64_t subscriberId) override;
91 std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId,
95 int64_t subscriberId) override;
97 std::vector<OperationResult> EnablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) override;
99 std::vector<OperationResult> DisablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) override;
/foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/
H A Dabnormal_branch_test.cpp152 int64_t subscriberId = 0; in HWTEST_F() local
155 proxy, uris, subscriberId, callback); in HWTEST_F()
180 int64_t subscriberId = 0; in HWTEST_F() local
184 results = PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subscriberId); in HWTEST_F()
210 int64_t subscriberId = 0; in HWTEST_F() local
212 proxy, uris, subscriberId); in HWTEST_F()
236 int64_t subscriberId = 0; in HWTEST_F() local
238 proxy, uris, subscriberId); in HWTEST_F()
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/
H A Dnapi_subscriber_manager.h78 NapiPublishedObserverMapKey(const std::string &uri, int64_t subscriberId) : uri_(uri), in NapiPublishedObserverMapKey()
79 subscriberId_(subscriberId){}; in NapiPublishedObserverMapKey()
109 int64_t subscriberId);
111 const std::vector<std::string> &uris, int64_t subscriberId);

Completed in 18 milliseconds

12