tipc: simplify signature of tipc_find_service()

We reduce the signature of tipc_find_service() and
tipc_create_service(). The reason for doing this might not
be obvious, but we plan to let struct tipc_uaddr contain
information that is relevant for these functions in a later
commit.

Signed-off-by: Jon Maloy <jmaloy@redhat.com>
Acked-by: Ying Xue <ying.xue@windriver.com>
Acked-by: Hoang Le <hoang.h.le@dektech.com.au>
Acked-by: Tung Nguyen <tung.q.nguyen@dektech.com.au>
Acked-by: Xin Long <lucien.xin@gmail.com>
Signed-off-by: David S. Miller <davem@davemloft.net>

diff --git a/net/tipc/name_table.c b/net/tipc/name_table.c
index f6a1b78a807e3327881d02b039a0d4e25cb0d375..73d9f49662e408d170be172de3f45b676952f050 100644 (file)
--- a/net/tipc/name_table.c
+++ b/net/tipc/name_table.c
@@ -249,25 +249,30 @@ static struct publication *tipc_publ_create(struct tipc_uaddr *ua,
 
 /**
  * tipc_service_create - create a service structure for the specified 'type'
- * @type: service type
- * @hd: name_table services list
+ * @net: network namespace
+ * @ua: address representing the service to be bound
  *
  * Allocates a single range structure and sets it to all 0's.
  */
-static struct tipc_service *tipc_service_create(u32 type, struct hlist_head *hd)
+static struct tipc_service *tipc_service_create(struct net *net,
+                                               struct tipc_uaddr *ua)
 {
-       struct tipc_service *service = kzalloc(sizeof(*service), GFP_ATOMIC);
+       struct name_table *nt = tipc_name_table(net);
+       struct tipc_service *service;
+       struct hlist_head *hd;
 
+       service = kzalloc(sizeof(*service), GFP_ATOMIC);
        if (!service) {
                pr_warn("Service creation failed, no memory\n");
                return NULL;
        }
 
        spin_lock_init(&service->lock);
-       service->type = type;
+       service->type = ua->sr.type;
        service->ranges = RB_ROOT;
        INIT_HLIST_NODE(&service->service_list);
        INIT_LIST_HEAD(&service->subscriptions);
+       hd = &nt->services[hash(ua->sr.type)];
        hlist_add_head_rcu(&service->service_list, hd);
        return service;
 }
@@ -455,15 +460,16 @@ static void tipc_service_subscribe(struct tipc_service *service,
        }
 }
 
-static struct tipc_service *tipc_service_find(struct net *net, u32 type)
+static struct tipc_service *tipc_service_find(struct net *net,
+                                             struct tipc_uaddr *ua)
 {
        struct name_table *nt = tipc_name_table(net);
        struct hlist_head *service_head;
        struct tipc_service *service;
 
-       service_head = &nt->services[hash(type)];
+       service_head = &nt->services[hash(ua->sr.type)];
        hlist_for_each_entry_rcu(service, service_head, service_list) {
-               if (service->type == type)
+               if (service->type == ua->sr.type)
                        return service;
        }
        return NULL;
@@ -474,7 +480,6 @@ struct publication *tipc_nametbl_insert_publ(struct net *net,
                                             struct tipc_socket_addr *sk,
                                             u32 key)
 {
-       struct name_table *nt = tipc_name_table(net);
        struct tipc_service *sc;
        struct publication *p;
        u32 type = ua->sr.type;
@@ -488,9 +493,9 @@ struct publication *tipc_nametbl_insert_publ(struct net *net,
                         type, ua->sr.lower, ua->sr.upper, sk->node);
                return NULL;
        }
-       sc = tipc_service_find(net, type);
+       sc = tipc_service_find(net, ua);
        if (!sc)
-               sc = tipc_service_create(type, &nt->services[hash(type)]);
+               sc = tipc_service_create(net, ua);
        if (sc && tipc_service_insert_publ(net, sc, p))
                return p;
        kfree(p);
@@ -510,7 +515,7 @@ struct publication *tipc_nametbl_remove_publ(struct net *net,
        u32 lower = ua->sr.lower;
        bool last;
 
-       sc = tipc_service_find(net, ua->sr.type);
+       sc = tipc_service_find(net, ua);
        if (!sc)
                return NULL;
 
@@ -582,7 +587,7 @@ bool tipc_nametbl_lookup_anycast(struct net *net,
                return true;
 
        rcu_read_lock();
-       sc = tipc_service_find(net, ua->sr.type);
+       sc = tipc_service_find(net, ua);
        if (unlikely(!sc))
                goto exit;
 
@@ -635,7 +640,7 @@ bool tipc_nametbl_lookup_group(struct net *net, struct tipc_uaddr *ua,
 
        *dstcnt = 0;
        rcu_read_lock();
-       sc = tipc_service_find(net, ua->sa.type);
+       sc = tipc_service_find(net, ua);
        if (unlikely(!sc))
                goto exit;
 
@@ -679,7 +684,7 @@ void tipc_nametbl_lookup_mcast_sockets(struct net *net, struct tipc_uaddr *ua,
        u32 scope = ua->scope;
 
        rcu_read_lock();
-       sc = tipc_service_find(net, ua->sr.type);
+       sc = tipc_service_find(net, ua);
        if (!sc)
                goto exit;
 
@@ -708,7 +713,7 @@ void tipc_nametbl_lookup_mcast_nodes(struct net *net, struct tipc_uaddr *ua,
        struct publication *p;
 
        rcu_read_lock();
-       sc = tipc_service_find(net, ua->sr.type);
+       sc = tipc_service_find(net, ua);
        if (!sc)
                goto exit;
 
@@ -726,7 +731,7 @@ exit:
 /* tipc_nametbl_build_group - build list of communication group members
  */
 void tipc_nametbl_build_group(struct net *net, struct tipc_group *grp,
-                             u32 type, u32 scope)
+                             struct tipc_uaddr *ua)
 {
        struct service_range *sr;
        struct tipc_service *sc;
@@ -734,7 +739,7 @@ void tipc_nametbl_build_group(struct net *net, struct tipc_group *grp,
        struct rb_node *n;
 
        rcu_read_lock();
-       sc = tipc_service_find(net, type);
+       sc = tipc_service_find(net, ua);
        if (!sc)
                goto exit;
 
@@ -742,9 +747,10 @@ void tipc_nametbl_build_group(struct net *net, struct tipc_group *grp,
        for (n = rb_first(&sc->ranges); n; n = rb_next(n)) {
                sr = container_of(n, struct service_range, tree_node);
                list_for_each_entry(p, &sr->all_publ, all_publ) {
-                       if (p->scope != scope)
+                       if (p->scope != ua->scope)
                                continue;
-                       tipc_group_add_member(grp, p->sk.node, p->sk.ref, p->sr.lower);
+                       tipc_group_add_member(grp, p->sk.node, p->sk.ref,
+                                             p->sr.lower);
                }
        }
        spin_unlock_bh(&sc->lock);
@@ -826,17 +832,18 @@ void tipc_nametbl_withdraw(struct net *net, struct tipc_uaddr *ua,
  */
 bool tipc_nametbl_subscribe(struct tipc_subscription *sub)
 {
-       struct name_table *nt = tipc_name_table(sub->net);
        struct tipc_net *tn = tipc_net(sub->net);
        struct tipc_subscr *s = &sub->evt.s;
        u32 type = tipc_sub_read(s, seq.type);
        struct tipc_service *sc;
+       struct tipc_uaddr ua;
        bool res = true;
 
+       tipc_uaddr(&ua, TIPC_SERVICE_RANGE, TIPC_NODE_SCOPE, type, 0, 0);
        spin_lock_bh(&tn->nametbl_lock);
-       sc = tipc_service_find(sub->net, type);
+       sc = tipc_service_find(sub->net, &ua);
        if (!sc)
-               sc = tipc_service_create(type, &nt->services[hash(type)]);
+               sc = tipc_service_create(sub->net, &ua);
        if (sc) {
                spin_lock_bh(&sc->lock);
                tipc_service_subscribe(sc, sub);
@@ -861,9 +868,11 @@ void tipc_nametbl_unsubscribe(struct tipc_subscription *sub)
        struct tipc_subscr *s = &sub->evt.s;
        u32 type = tipc_sub_read(s, seq.type);
        struct tipc_service *sc;
+       struct tipc_uaddr ua;
 
+       tipc_uaddr(&ua, TIPC_SERVICE_RANGE, TIPC_NODE_SCOPE, type, 0, 0);
        spin_lock_bh(&tn->nametbl_lock);
-       sc = tipc_service_find(sub->net, type);
+       sc = tipc_service_find(sub->net, &ua);
        if (!sc)
                goto exit;
 
@@ -1052,6 +1061,7 @@ static int tipc_nl_service_list(struct net *net, struct tipc_nl_msg *msg,
        struct tipc_net *tn = tipc_net(net);
        struct tipc_service *service = NULL;
        struct hlist_head *head;
+       struct tipc_uaddr ua;
        int err;
        int i;
 
@@ -1065,7 +1075,9 @@ static int tipc_nl_service_list(struct net *net, struct tipc_nl_msg *msg,
 
                if (*last_type ||
                    (!i && *last_key && (*last_lower == *last_key))) {
-                       service = tipc_service_find(net, *last_type);
+                       tipc_uaddr(&ua, TIPC_SERVICE_RANGE, TIPC_NODE_SCOPE,
+                                  *last_type, *last_lower, *last_lower);
+                       service = tipc_service_find(net, &ua);
                        if (!service)
                                return -EPIPE;
                } else {

diff --git a/net/tipc/name_table.h b/net/tipc/name_table.h
index b20b694c1284e4338e2f1df558c9cdb8f3d2559e..c7c9a3ddd420890b4479384b20ee345f185b255f 100644 (file)
--- a/net/tipc/name_table.h
+++ b/net/tipc/name_table.h
@@ -120,7 +120,7 @@ bool tipc_nametbl_lookup_group(struct net *net, struct tipc_uaddr *ua,
                               struct list_head *dsts, int *dstcnt,
                               u32 exclude, bool mcast);
 void tipc_nametbl_build_group(struct net *net, struct tipc_group *grp,
-                             u32 type, u32 domain);
+                             struct tipc_uaddr *ua);
 struct publication *tipc_nametbl_publish(struct net *net, struct tipc_uaddr *ua,
                                         struct tipc_socket_addr *sk, u32 key);
 void tipc_nametbl_withdraw(struct net *net, struct tipc_uaddr *ua,

diff --git a/net/tipc/socket.c b/net/tipc/socket.c
index a7f86f22c03a77dc04d527c89e9186633a1eb955..117a472a8e61ce548ba34a4f7de2455628b14a52 100644 (file)
--- a/net/tipc/socket.c
+++ b/net/tipc/socket.c
@@ -3075,9 +3075,9 @@ static int tipc_sk_join(struct tipc_sock *tsk, struct tipc_group_req *mreq)
        msg_set_lookup_scope(hdr, mreq->scope);
        msg_set_nametype(hdr, mreq->type);
        msg_set_dest_droppable(hdr, true);
-       tipc_nametbl_build_group(net, grp, mreq->type, mreq->scope);
        tipc_uaddr(&ua, TIPC_SERVICE_RANGE, mreq->scope,
                   mreq->type, mreq->instance, mreq->instance);
+       tipc_nametbl_build_group(net, grp, &ua);
        rc = tipc_sk_publish(tsk, &ua);
        if (rc) {
                tipc_group_delete(net, grp);