]> www.infradead.org Git - users/dwmw2/linux.git/commitdiff
af_unix: Clean up error paths in unix_stream_connect().
authorKuniyuki Iwashima <kuniyu@amazon.com>
Fri, 13 Dec 2024 11:08:40 +0000 (20:08 +0900)
committerPaolo Abeni <pabeni@redhat.com>
Tue, 17 Dec 2024 11:08:27 +0000 (12:08 +0100)
The label order is weird in unix_stream_connect(), and all NULL checks
are unnecessary if reordered.

Let's clean up the error paths to make it easy to set a drop reason
for each path.

While at it, a comment with the old style is updated.

Signed-off-by: Kuniyuki Iwashima <kuniyu@amazon.com>
Signed-off-by: Paolo Abeni <pabeni@redhat.com>
net/unix/af_unix.c

index 23f419f561b83455207534a12d2aa3f68ce48cec..21e17e739f88acaef674c92edfe6119c77d9941b 100644 (file)
@@ -1563,15 +1563,14 @@ static int unix_stream_connect(struct socket *sock, struct sockaddr *uaddr,
        timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);
 
        /* First of all allocate resources.
-          If we will make it after state is locked,
-          we will have to recheck all again in any case.
+        * If we will make it after state is locked,
+        * we will have to recheck all again in any case.
         */
 
        /* create new sock for complete connection */
        newsk = unix_create1(net, NULL, 0, sock->type);
        if (IS_ERR(newsk)) {
                err = PTR_ERR(newsk);
-               newsk = NULL;
                goto out;
        }
 
@@ -1579,7 +1578,7 @@ static int unix_stream_connect(struct socket *sock, struct sockaddr *uaddr,
        skb = sock_wmalloc(newsk, 1, 0, GFP_KERNEL);
        if (!skb) {
                err = -ENOMEM;
-               goto out;
+               goto out_free_sk;
        }
 
 restart:
@@ -1587,8 +1586,7 @@ restart:
        other = unix_find_other(net, sunaddr, addr_len, sk->sk_type);
        if (IS_ERR(other)) {
                err = PTR_ERR(other);
-               other = NULL;
-               goto out;
+               goto out_free_skb;
        }
 
        unix_state_lock(other);
@@ -1613,11 +1611,12 @@ restart:
                }
 
                timeo = unix_wait_for_peer(other, timeo);
+               sock_put(other);
 
                err = sock_intr_errno(timeo);
                if (signal_pending(current))
-                       goto out;
-               sock_put(other);
+                       goto out_free_skb;
+
                goto restart;
        }
 
@@ -1702,15 +1701,13 @@ restart:
        return 0;
 
 out_unlock:
-       if (other)
-               unix_state_unlock(other);
-
-out:
+       unix_state_unlock(other);
+       sock_put(other);
+out_free_skb:
        kfree_skb(skb);
-       if (newsk)
-               unix_release_sock(newsk, 0);
-       if (other)
-               sock_put(other);
+out_free_sk:
+       unix_release_sock(newsk, 0);
+out:
        return err;
 }