mirror of https://lore.kernel.org/lkml/
 help / color / mirror / Atom feed
From: Michal Luczaj <mhal@rbox.co>
To: Stefano Garzarella <sgarzare@redhat.com>
Cc: "David S. Miller" <davem@davemloft.net>,
	Eric Dumazet <edumazet@google.com>,
	Jakub Kicinski <kuba@kernel.org>, Paolo Abeni <pabeni@redhat.com>,
	Simon Horman <horms@kernel.org>,
	virtualization@lists.linux.dev, netdev@vger.kernel.org,
	linux-kernel@vger.kernel.org
Subject: Re: [PATCH net] vsock: Ignore signal/timeout on connect() if already established
Date: Tue, 18 Nov 2025 23:02:17 +0100	[thread overview]
Message-ID: <98e2ac89-34e9-42d9-bfcf-e81e7a04504d@rbox.co> (raw)
In-Reply-To: <dh6gl6xzufrxk23dwei3dcyljjlspjx3gwdhi6o3umtltpypkw@ef4n6llndg5p>

On 11/18/25 10:51, Stefano Garzarella wrote:
> On Mon, Nov 17, 2025 at 09:57:25PM +0100, Michal Luczaj wrote:
>> ...
>> +static void vsock_reset_interrupted(struct sock *sk)
>> +{
>> +	struct vsock_sock *vsk = vsock_sk(sk);
>> +
>> +	/* Try to cancel VIRTIO_VSOCK_OP_REQUEST skb sent out by
>> +	 * transport->connect().
>> +	 */
>> +	vsock_transport_cancel_pkt(vsk);
>> +
>> +	/* Listener might have already responded with VIRTIO_VSOCK_OP_RESPONSE.
>> +	 * Its handling expects our sk_state == TCP_SYN_SENT, which hereby we
>> +	 * break. In such case VIRTIO_VSOCK_OP_RST will follow.
>> +	 */
>> +	sk->sk_state = TCP_CLOSE;
>> +	sk->sk_socket->state = SS_UNCONNECTED;
>> +}
>> +
>> static int vsock_connect(struct socket *sock, struct sockaddr *addr,
>> 			 int addr_len, int flags)
>> {
>> @@ -1661,18 +1678,33 @@ static int vsock_connect(struct socket *sock, struct sockaddr *addr,
>> 		timeout = schedule_timeout(timeout);
>> 		lock_sock(sk);
>>
>> +		/* Connection established. Whatever happens to socket once we
>> +		 * release it, that's not connect()'s concern. No need to go
>> +		 * into signal and timeout handling. Call it a day.
>> +		 *
>> +		 * Note that allowing to "reset" an already established socket
>> +		 * here is racy and insecure.
>> +		 */
>> +		if (sk->sk_state == TCP_ESTABLISHED)
>> +			break;
>> +
>> +		/* If connection was _not_ established and a signal/timeout came
>> +		 * to be, we want the socket's state reset. User space may want
>> +		 * to retry.
>> +		 *
>> +		 * sk_state != TCP_ESTABLISHED implies that socket is not on
>> +		 * vsock_connected_table. We keep the binding and the transport
>> +		 * assigned.
>> +		 */
>> 		if (signal_pending(current)) {
>> 			err = sock_intr_errno(timeout);
>> -			sk->sk_state = sk->sk_state == TCP_ESTABLISHED ? TCP_CLOSING : TCP_CLOSE;
>> -			sock->state = SS_UNCONNECTED;
>> -			vsock_transport_cancel_pkt(vsk);
>> -			vsock_remove_connected(vsk);
>> +			vsock_reset_interrupted(sk);
>> 			goto out_wait;
>> -		} else if ((sk->sk_state != TCP_ESTABLISHED) && (timeout == 0)) {
>> +		}
>> +
>> +		if (timeout == 0) {
>> 			err = -ETIMEDOUT;
>> -			sk->sk_state = TCP_CLOSE;
>> -			sock->state = SS_UNCONNECTED;
>> -			vsock_transport_cancel_pkt(vsk);
>> +			vsock_reset_interrupted(sk);
>> 			goto out_wait;
> 
> I'm fine with the change, but now both code blocks are the same, so
> can we unify them?
> I mean something like this:
> 		if (signal_pending(current) || timeout == 0 {
> 			err = timeout == 0 ? -ETIMEDOUT : sock_intr_errno(timeout);
> 			...
> 		}
> 
> Maybe at that point we can also remove the vsock_reset_interrupted()
> function and put the code right there.
> 
> BTW I don't have a strong opinion, what do you prefer?

Sure, no problem.

But I've realized invoking `sock_intr_errno(timeout)` is unnecessary.
`timeout` can't be MAX_SCHEDULE_TIMEOUT, so the call always evaluates to
-EINTR, right?

  reply	other threads:[~2025-11-18 22:02 UTC|newest]

Thread overview: 12+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2025-11-17 20:57 Michal Luczaj
2025-11-18  9:51 ` Stefano Garzarella
2025-11-18 22:02   ` Michal Luczaj [this message]
2025-11-19 10:36     ` Stefano Garzarella
2025-11-19 14:09       ` Michal Luczaj
2025-11-19 16:31         ` Stefano Garzarella
2025-11-19 19:52           ` Michal Luczaj
2025-11-20 21:12             ` Michal Luczaj
2025-11-21  9:21               ` Stefano Garzarella
2025-11-23 21:46                 ` Michal Luczaj
2025-11-24 11:49                   ` Stefano Garzarella
2026-01-23 16:52                     ` Michal Luczaj

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=98e2ac89-34e9-42d9-bfcf-e81e7a04504d@rbox.co \
    --to=mhal@rbox.co \
    --cc=davem@davemloft.net \
    --cc=edumazet@google.com \
    --cc=horms@kernel.org \
    --cc=kuba@kernel.org \
    --cc=linux-kernel@vger.kernel.org \
    --cc=netdev@vger.kernel.org \
    --cc=pabeni@redhat.com \
    --cc=sgarzare@redhat.com \
    --cc=virtualization@lists.linux.dev \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox

all inboxes | Powered by JetHome®