[TIPC]: Cosmetic changes to TIPC connect() code
authorAllan Stephens <allan.stephens@windriver.com>
Tue, 15 Apr 2008 07:20:37 +0000 (00:20 -0700)
committerDavid S. Miller <davem@davemloft.net>
Tue, 15 Apr 2008 07:20:37 +0000 (00:20 -0700)
This patch fixes TIPC's connect routine to conform to Linux
kernel style norms of indentation, line length, etc.

Signed-off-by: Allan Stephens <allan.stephens@windriver.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
net/tipc/socket.c

index 348e4ff881abab31d228cb0ea8b8b571a9cb36fc..df1960384364883c0f74ce5f31a0939c73fdcabf 100644 (file)
@@ -1248,77 +1248,78 @@ static void wakeupdispatch(struct tipc_port *tport)
 static int connect(struct socket *sock, struct sockaddr *dest, int destlen,
                   int flags)
 {
-   struct tipc_sock *tsock = tipc_sk(sock->sk);
-   struct sockaddr_tipc *dst = (struct sockaddr_tipc *)dest;
-   struct msghdr m = {NULL,};
-   struct sk_buff *buf;
-   struct tipc_msg *msg;
-   int res;
-
-   /* For now, TIPC does not allow use of connect() with DGRAM or RDM types */
-
-   if (sock->state == SS_READY)
-          return -EOPNOTSUPP;
-
-   /* For now, TIPC does not support the non-blocking form of connect() */
-
-   if (flags & O_NONBLOCK)
-          return -EWOULDBLOCK;
-
-   /* Issue Posix-compliant error code if socket is in the wrong state */
-
-   if (sock->state == SS_LISTENING)
-          return -EOPNOTSUPP;
-   if (sock->state == SS_CONNECTING)
-          return -EALREADY;
-   if (sock->state != SS_UNCONNECTED)
-          return -EISCONN;
-
-   /*
-    * Reject connection attempt using multicast address
-    *
-    * Note: send_msg() validates the rest of the address fields,
-    *       so there's no need to do it here
-    */
-
-   if (dst->addrtype == TIPC_ADDR_MCAST)
-          return -EINVAL;
-
-   /* Send a 'SYN-' to destination */
-
-   m.msg_name = dest;
-   m.msg_namelen = destlen;
-   if ((res = send_msg(NULL, sock, &m, 0)) < 0) {
-          sock->state = SS_DISCONNECTING;
-          return res;
-   }
-
-   if (mutex_lock_interruptible(&tsock->lock))
-          return -ERESTARTSYS;
-
-   /* Wait for destination's 'ACK' response */
-
-   res = wait_event_interruptible_timeout(*sock->sk->sk_sleep,
-                                         skb_queue_len(&sock->sk->sk_receive_queue),
-                                         sock->sk->sk_rcvtimeo);
-   buf = skb_peek(&sock->sk->sk_receive_queue);
-   if (res > 0) {
-          msg = buf_msg(buf);
-          res = auto_connect(sock, tsock, msg);
-          if (!res) {
-                  if (!msg_data_sz(msg))
-                          advance_queue(tsock);
-          }
-   } else {
-          if (res == 0) {
-                  res = -ETIMEDOUT;
-          } else
-                  { /* leave "res" unchanged */ }
-          sock->state = SS_DISCONNECTING;
-   }
-
-   mutex_unlock(&tsock->lock);
-   return res;
+       struct tipc_sock *tsock = tipc_sk(sock->sk);
+       struct sockaddr_tipc *dst = (struct sockaddr_tipc *)dest;
+       struct msghdr m = {NULL,};
+       struct sk_buff *buf;
+       struct tipc_msg *msg;
+       int res;
+
+       /* For now, TIPC does not allow use of connect() with DGRAM/RDM types */
+
+       if (sock->state == SS_READY)
+               return -EOPNOTSUPP;
+
+       /* For now, TIPC does not support the non-blocking form of connect() */
+
+       if (flags & O_NONBLOCK)
+               return -EWOULDBLOCK;
+
+       /* Issue Posix-compliant error code if socket is in the wrong state */
+
+       if (sock->state == SS_LISTENING)
+               return -EOPNOTSUPP;
+       if (sock->state == SS_CONNECTING)
+               return -EALREADY;
+       if (sock->state != SS_UNCONNECTED)
+               return -EISCONN;
+
+       /*
+        * Reject connection attempt using multicast address
+        *
+        * Note: send_msg() validates the rest of the address fields,
+        *       so there's no need to do it here
+        */
+
+       if (dst->addrtype == TIPC_ADDR_MCAST)
+               return -EINVAL;
+
+       /* Send a 'SYN-' to destination */
+
+       m.msg_name = dest;
+       m.msg_namelen = destlen;
+       res = send_msg(NULL, sock, &m, 0);
+       if (res < 0) {
+               sock->state = SS_DISCONNECTING;
+               return res;
+       }
+
+       if (mutex_lock_interruptible(&tsock->lock))
+               return -ERESTARTSYS;
+
+       /* Wait for destination's 'ACK' response */
+
+       res = wait_event_interruptible_timeout(*sock->sk->sk_sleep,
+                       skb_queue_len(&sock->sk->sk_receive_queue),
+                       sock->sk->sk_rcvtimeo);
+       buf = skb_peek(&sock->sk->sk_receive_queue);
+       if (res > 0) {
+               msg = buf_msg(buf);
+               res = auto_connect(sock, tsock, msg);
+               if (!res) {
+                       if (!msg_data_sz(msg))
+                               advance_queue(tsock);
+               }
+       } else {
+               if (res == 0)
+                       res = -ETIMEDOUT;
+               else
+                       ; /* leave "res" unchanged */
+               sock->state = SS_DISCONNECTING;
+       }
+
+       mutex_unlock(&tsock->lock);
+       return res;
 }
 
 /**