| /foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/ |
| H A D | pub_sub_feature.c | 39 feature->relations.topic = -1;
in Init()
40 feature->relations.callbacks.consumer = NULL;
in Init()
41 UtilsListInit(&feature->relations.callbacks.node);
in Init()
42 UtilsListInit(&feature->relations.node);
in Init()
101 UTILS_DL_LIST *list = &feature->relations.node;
in GetRelation()
|
| H A D | pub_sub_feature.h | 47 Relation relations;
member
|
| H A D | pub_sub_implement.c | 62 Relation *head = &broadcast->feature->relations;
in AddTopic()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_server_impl.cpp | 354 OhCloudExtHashMap *relations = nullptr; in DoSubscribe() local
356 auto status = OhCloudExtCloudSyncSubscribe(server.get(), databases.get(), expire, &relations, &errs); in DoSubscribe()
357 if (status != ERRNO_SUCCESS || relations == nullptr) { in DoSubscribe()
360 auto pRelations = std::shared_ptr<OhCloudExtHashMap>(relations, [](auto *relations) { in DoSubscribe()
361 OhCloudExtHashMapFree(relations); in DoSubscribe()
387 int32_t CloudServerImpl::SaveSubscription(int32_t userId, std::shared_ptr<OhCloudExtHashMap> relations, in SaveSubscription() argument
414 status = OhCloudExtHashMapIterGetKeyValuePair(relations.get(), &keys, &values); in SaveSubscription()
459 OhCloudExtHashMap *relations = nullptr; in SaveRelation() local
460 status = OhCloudExtRelationSetGetRelations(pRelationSet.get(), &relations); in SaveRelation()
478 GetRelation(std::shared_ptr<OhCloudExtHashMap> relations, DBRelation &dbRelation) GetRelation() argument
567 DoUnsubscribe(std::shared_ptr<OhCloudExtCloudSync> server, std::shared_ptr<OhCloudExtHashMap> relations, const std::vector<std::string> &bundles, DBSub &sub) DoUnsubscribe() argument
[all...] |
| H A D | cloud_server_impl.h | 58 int32_t SaveSubscription(int32_t userId, std::shared_ptr<OhCloudExtHashMap> relations,
62 int32_t GetRelation(std::shared_ptr<OhCloudExtHashMap> relations, DBRelation &dbRelation);
64 std::shared_ptr<OhCloudExtHashMap> relations, const std::vector<std::string> &bundles, DBSub &sub);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | subscription.cpp | 24 SetValue(node[GET_NAME(relations)], relations); in Marshal()
32 GetValue(node, GET_NAME(relations), relations); in Unmarshal()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
| H A D | cloud_extension.rs | 600 /// Return a Hashmap of subscription relations, in the form HashMap<String, RelationSet>, and Vector
608 relations: *mut *const OhCloudExtHashMap,
611 if server.is_null() || dbs.is_null() || relations.is_null() || err.is_null() {
632 *relations = OhCloudExtHashMap::new(result, SafetyCheckId::HashMap).into_ptr();
649 /// Pass a batch of unsubscription orders to a CloudSync pointer, with target relations.
656 relations: *const OhCloudExtHashMap,
659 if server.is_null() || relations.is_null() || err.is_null() {
668 let relations = match OhCloudExtHashMap::get_inner_ref(relations, SafetyCheckId::HashMap) {
672 let relations
[all...] |
| H A D | cloud_ext_types.rs | 1022 /// Create a RelationSet instance by bundle name, and relations. Relations can be created by
1031 relations: *mut OhCloudExtHashMap,
1035 if relations.is_null() {
1040 let relations = match OhCloudExtHashMap::get_inner(relations, SafetyCheckId::HashMap) {
1044 match relations {
1094 /// Get relations from a RelationSet pointer. Parameter `relations` be updated
1099 relations: *mut *const OhCloudExtHashMap,
1101 if relation.is_null() || relations
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/include/ |
| H A D | cloud_extension.h | 326 * relations [OUT] HashMap<String, RelationSet>, bundle name as key
334 OhCloudExtHashMap **relations,
339 * @brief Pass a batch of unsubscription orders to a CloudSync pointer, with target relations.
341 * relations [IN] HashMap<String, Vec<String>>, bundle name as key, ids as value
347 const OhCloudExtHashMap *relations,
|
| H A D | cloud_ext_types.h | 529 * @brief Create a RelationSet instance by bundle name, and relations.
530 * @param relations [IN] HashMap<String, String>, Database alias as key, subscription id and time generated
538 OhCloudExtHashMap *relations
552 * @brief Get relations from a RelationSet pointer.
553 * @param relations [OUT] HashMap<String, u32>, Database alias as key, subscription id and time generated
557 int OhCloudExtRelationSetGetRelations(const OhCloudExtRelationSet *re, OhCloudExtHashMap **relations);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | subscription_test.cpp | 43 relation.relations = testRelation; in HWTEST_F()
48 ASSERT_EQ(node["relations"], testRelation); in HWTEST_F()
61 node["relations"] = testRelation; in HWTEST_F()
66 ASSERT_EQ(relation.relations, testRelation); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | subscription.h | 28 std::map<std::string, std::string> relations; member
|