1 files changed, 19 insertions, 19 deletions

diff --git a/net/tipc/subscr.c b/net/tipc/subscr.c
index 022a2f21be04..531227208ae2 100644
--- a/net/tipc/subscr.c
+++ b/net/tipc/subscr.c
@@ -235,22 +235,11 @@ static void tipc_subscrp_cancel(struct tipc_subscr *s,
 
 static struct tipc_subscription *tipc_subscrp_create(struct net *net,
                                                      struct tipc_subscr *s,
-                                                     struct tipc_subscriber *subscriber)
+                                                     int swap)
 {
         struct tipc_net *tn = net_generic(net, tipc_net_id);
         struct tipc_subscription *sub;
-        u32 filter;
-        int swap;
-
-        /* Determine subscriber's endianness */
-        swap = !(s->filter & (TIPC_SUB_PORTS | TIPC_SUB_SERVICE));
-
-        /* Detect & process a subscription cancellation request */
-        if (s->filter & htohl(TIPC_SUB_CANCEL, swap)) {
-                s->filter &= ~htohl(TIPC_SUB_CANCEL, swap);
-                tipc_subscrp_cancel(s, subscriber);
-                return NULL;
-        }
+        u32 filter = htohl(s->filter, swap);
 
         /* Refuse subscription if global limit exceeded */
         if (atomic_read(&tn->subscription_count) >= TIPC_MAX_SUBSCRIPTIONS) {
@@ -268,7 +257,6 @@ static struct tipc_subscription *tipc_subscrp_create(struct net *net,
 
         /* Initialize subscription object */
         sub->net = net;
-        filter = htohl(s->filter, swap);
         if (((filter & TIPC_SUB_PORTS) && (filter & TIPC_SUB_SERVICE)) ||
             (htohl(s->seq.lower, swap) > htohl(s->seq.upper, swap))) {
                 pr_warn("Subscription rejected, illegal request\n");
@@ -284,13 +272,13 @@ static struct tipc_subscription *tipc_subscrp_create(struct net *net,
 }
 
 static void tipc_subscrp_subscribe(struct net *net, struct tipc_subscr *s,
-                                   struct tipc_subscriber *subscriber)
+                                   struct tipc_subscriber *subscriber, int swap)
 {
         struct tipc_net *tn = net_generic(net, tipc_net_id);
         struct tipc_subscription *sub = NULL;
         u32 timeout;
 
-        sub = tipc_subscrp_create(net, s, subscriber);
+        sub = tipc_subscrp_create(net, s, swap);
         if (!sub)
                 return tipc_conn_terminate(tn->topsrv, subscriber->conid);
 
@@ -299,7 +287,7 @@ static void tipc_subscrp_subscribe(struct net *net, struct tipc_subscr *s,
         spin_unlock_bh(&subscriber->lock);
 
         sub->subscriber = subscriber;
-        timeout = htohl(sub->evt.s.timeout, sub->swap);
+        timeout = htohl(sub->evt.s.timeout, swap);
         if (!mod_timer(&sub->timer, jiffies + msecs_to_jiffies(timeout)))
                 tipc_subscrb_get(subscriber);
         tipc_nametbl_subscribe(sub);
@@ -316,8 +304,20 @@ static void tipc_subscrb_rcv_cb(struct net *net, int conid,
                                 struct sockaddr_tipc *addr, void *usr_data,
                                 void *buf, size_t len)
 {
-        tipc_subscrp_subscribe(net, (struct tipc_subscr *)buf,
-                               (struct tipc_subscriber *)usr_data);
+        struct tipc_subscriber *subscriber = usr_data;
+        struct tipc_subscr *s = (struct tipc_subscr *)buf;
+        int swap;
+
+        /* Determine subscriber's endianness */
+        swap = !(s->filter & (TIPC_SUB_PORTS | TIPC_SUB_SERVICE));
+
+        /* Detect & process a subscription cancellation request */
+        if (s->filter & htohl(TIPC_SUB_CANCEL, swap)) {
+                s->filter &= ~htohl(TIPC_SUB_CANCEL, swap);
+                return tipc_subscrp_cancel(s, subscriber);
+        }
+
+        tipc_subscrp_subscribe(net, s, subscriber, swap);
 }
 
 /* Handle one request to establish a new subscriber */