1 files changed, 61 insertions, 43 deletions

diff --git a/net/tipc/subscr.c b/net/tipc/subscr.c
index b71dbc0ae8f9..72c339e432aa 100644
--- a/net/tipc/subscr.c
+++ b/net/tipc/subscr.c
@@ -50,34 +50,6 @@ struct tipc_subscriber {
         struct list_head subscription_list;
 };
 
-static void subscr_conn_msg_event(struct net *net, int conid,
-                                  struct sockaddr_tipc *addr, void *usr_data,
-                                  void *buf, size_t len);
-static void *subscr_named_msg_event(int conid);
-static void subscr_conn_shutdown_event(int conid, void *usr_data);
-
-static atomic_t subscription_count = ATOMIC_INIT(0);
-
-static struct sockaddr_tipc topsrv_addr __read_mostly = {
-        .family                 = AF_TIPC,
-        .addrtype               = TIPC_ADDR_NAMESEQ,
-        .addr.nameseq.type      = TIPC_TOP_SRV,
-        .addr.nameseq.lower     = TIPC_TOP_SRV,
-        .addr.nameseq.upper     = TIPC_TOP_SRV,
-        .scope                  = TIPC_NODE_SCOPE
-};
-
-static struct tipc_server topsrv __read_mostly = {
-        .saddr                  = &topsrv_addr,
-        .imp                    = TIPC_CRITICAL_IMPORTANCE,
-        .type                   = SOCK_SEQPACKET,
-        .max_rcvbuf_size        = sizeof(struct tipc_subscr),
-        .name                   = "topology_server",
-        .tipc_conn_recvmsg      = subscr_conn_msg_event,
-        .tipc_conn_new          = subscr_named_msg_event,
-        .tipc_conn_shutdown     = subscr_conn_shutdown_event,
-};
-
 /**
  * htohl - convert value to endianness used by destination
  * @in: value to convert
@@ -94,6 +66,7 @@ static void subscr_send_event(struct tipc_subscription *sub, u32 found_lower,
                               u32 found_upper, u32 event, u32 port_ref,
                               u32 node)
 {
+        struct tipc_net *tn = net_generic(sub->net, tipc_net_id);
         struct tipc_subscriber *subscriber = sub->subscriber;
         struct kvec msg_sect;
 
@@ -104,8 +77,8 @@ static void subscr_send_event(struct tipc_subscription *sub, u32 found_lower,
         sub->evt.found_upper = htohl(found_upper, sub->swap);
         sub->evt.port.ref = htohl(port_ref, sub->swap);
         sub->evt.port.node = htohl(node, sub->swap);
-        tipc_conn_sendmsg(&topsrv, subscriber->conid, NULL, msg_sect.iov_base,
-                          msg_sect.iov_len);
+        tipc_conn_sendmsg(tn->topsrv, subscriber->conid, NULL,
+                          msg_sect.iov_base, msg_sect.iov_len);
 }
 
 /**
@@ -146,6 +119,7 @@ static void subscr_timeout(unsigned long data)
 {
         struct tipc_subscription *sub = (struct tipc_subscription *)data;
         struct tipc_subscriber *subscriber = sub->subscriber;
+        struct tipc_net *tn = net_generic(sub->net, tipc_net_id);
 
         /* The spin lock per subscriber is used to protect its members */
         spin_lock_bh(&subscriber->lock);
@@ -170,7 +144,7 @@ static void subscr_timeout(unsigned long data)
 
         /* Now destroy subscription */
         kfree(sub);
-        atomic_dec(&subscription_count);
+        atomic_dec(&tn->subscription_count);
 }
 
 /**
@@ -180,10 +154,12 @@ static void subscr_timeout(unsigned long data)
  */
 static void subscr_del(struct tipc_subscription *sub)
 {
+        struct tipc_net *tn = net_generic(sub->net, tipc_net_id);
+
         tipc_nametbl_unsubscribe(sub);
         list_del(&sub->subscription_list);
         kfree(sub);
-        atomic_dec(&subscription_count);
+        atomic_dec(&tn->subscription_count);
 }
 
 /**
@@ -191,9 +167,12 @@ static void subscr_del(struct tipc_subscription *sub)
  *
  * Note: Must call it in process context since it might sleep.
  */
-static void subscr_terminate(struct tipc_subscriber *subscriber)
+static void subscr_terminate(struct tipc_subscription *sub)
 {
-        tipc_conn_terminate(&topsrv, subscriber->conid);
+        struct tipc_subscriber *subscriber = sub->subscriber;
+        struct tipc_net *tn = net_generic(sub->net, tipc_net_id);
+
+        tipc_conn_terminate(tn->topsrv, subscriber->conid);
 }
 
 static void subscr_release(struct tipc_subscriber *subscriber)
@@ -263,7 +242,9 @@ static void subscr_cancel(struct tipc_subscr *s,
  */
 static int subscr_subscribe(struct net *net, struct tipc_subscr *s,
                             struct tipc_subscriber *subscriber,
-                            struct tipc_subscription **sub_p) {
+                            struct tipc_subscription **sub_p)
+{
+        struct tipc_net *tn = net_generic(net, tipc_net_id);
         struct tipc_subscription *sub;
         int swap;
 
@@ -278,7 +259,7 @@ static int subscr_subscribe(struct net *net, struct tipc_subscr *s,
         }
 
         /* Refuse subscription if global limit exceeded */
-        if (atomic_read(&subscription_count) >= TIPC_MAX_SUBSCRIPTIONS) {
+        if (atomic_read(&tn->subscription_count) >= TIPC_MAX_SUBSCRIPTIONS) {
                 pr_warn("Subscription rejected, limit reached (%u)\n",
                         TIPC_MAX_SUBSCRIPTIONS);
                 return -EINVAL;
@@ -309,7 +290,7 @@ static int subscr_subscribe(struct net *net, struct tipc_subscr *s,
         sub->subscriber = subscriber;
         sub->swap = swap;
         memcpy(&sub->evt.s, s, sizeof(struct tipc_subscr));
-        atomic_inc(&subscription_count);
+        atomic_inc(&tn->subscription_count);
         if (sub->timeout != TIPC_WAIT_FOREVER) {
                 setup_timer(&sub->timer, subscr_timeout, (unsigned long)sub);
                 mod_timer(&sub->timer, jiffies + sub->timeout);
@@ -336,7 +317,7 @@ static void subscr_conn_msg_event(struct net *net, int conid,
         if (subscr_subscribe(net, (struct tipc_subscr *)buf, subscriber,
                              &sub) < 0) {
                 spin_unlock_bh(&subscriber->lock);
-                subscr_terminate(subscriber);
+                subscr_terminate(sub);
                 return;
         }
         if (sub)
@@ -344,7 +325,6 @@ static void subscr_conn_msg_event(struct net *net, int conid,
         spin_unlock_bh(&subscriber->lock);
 }
 
-
 /* Handle one request to establish a new subscriber */
 static void *subscr_named_msg_event(int conid)
 {
@@ -363,12 +343,50 @@ static void *subscr_named_msg_event(int conid)
         return (void *)subscriber;
 }
 
-int tipc_subscr_start(void)
+int tipc_subscr_start(struct net *net)
 {
-        return tipc_server_start(&topsrv);
+        struct tipc_net *tn = net_generic(net, tipc_net_id);
+        const char name[] = "topology_server";
+        struct tipc_server *topsrv;
+        struct sockaddr_tipc *saddr;
+
+        saddr = kzalloc(sizeof(*saddr), GFP_ATOMIC);
+        if (!saddr)
+                return -ENOMEM;
+        saddr->family                   = AF_TIPC;
+        saddr->addrtype                 = TIPC_ADDR_NAMESEQ;
+        saddr->addr.nameseq.type        = TIPC_TOP_SRV;
+        saddr->addr.nameseq.lower       = TIPC_TOP_SRV;
+        saddr->addr.nameseq.upper       = TIPC_TOP_SRV;
+        saddr->scope                    = TIPC_NODE_SCOPE;
+
+        topsrv = kzalloc(sizeof(*topsrv), GFP_ATOMIC);
+        if (!topsrv) {
+                kfree(saddr);
+                return -ENOMEM;
+        }
+        topsrv->net                     = net;
+        topsrv->saddr                   = saddr;
+        topsrv->imp                     = TIPC_CRITICAL_IMPORTANCE;
+        topsrv->type                    = SOCK_SEQPACKET;
+        topsrv->max_rcvbuf_size         = sizeof(struct tipc_subscr);
+        topsrv->tipc_conn_recvmsg       = subscr_conn_msg_event;
+        topsrv->tipc_conn_new           = subscr_named_msg_event;
+        topsrv->tipc_conn_shutdown      = subscr_conn_shutdown_event;
+
+        strncpy(topsrv->name, name, strlen(name) + 1);
+        tn->topsrv = topsrv;
+        atomic_set(&tn->subscription_count, 0);
+
+        return tipc_server_start(topsrv);
 }
 
-void tipc_subscr_stop(void)
+void tipc_subscr_stop(struct net *net)
 {
-        tipc_server_stop(&topsrv);
+        struct tipc_net *tn = net_generic(net, tipc_net_id);
+        struct tipc_server *topsrv = tn->topsrv;
+
+        tipc_server_stop(topsrv);
+        kfree(topsrv->saddr);
+        kfree(topsrv);
 }