Skip to content

Commit

Permalink
tls: rx: don't try to keep the skbs always on the list
Browse files Browse the repository at this point in the history
I thought that having the skb either always on the ctx->rx_list
or ctx->recv_pkt will simplify the handling, as we would not
have to remember to flip it from one to the other on exit paths.

This became a little harder to justify with the fix for BPF
sockmaps. Subsequent changes will make the situation even worse.
Queue the skbs only when really needed.

Signed-off-by: Jakub Kicinski <kuba@kernel.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
Jakub Kicinski authored and David S. Miller committed Jul 18, 2022
1 parent 4cbc325 commit 008141d
Showing 1 changed file with 12 additions and 11 deletions.
23 changes: 12 additions & 11 deletions net/tls/tls_sw.c
Original file line number Diff line number Diff line change
Expand Up @@ -1861,8 +1861,11 @@ int tls_sw_recvmsg(struct sock *sk,
if (psock) {
chunk = sk_msg_recvmsg(sk, psock, msg, len,
flags);
if (chunk > 0)
goto leave_on_list;
if (chunk > 0) {
decrypted += chunk;
len -= chunk;
continue;
}
}
goto recv_end;
}
Expand Down Expand Up @@ -1908,14 +1911,14 @@ int tls_sw_recvmsg(struct sock *sk,

ctx->recv_pkt = NULL;
__strp_unpause(&ctx->strp);
__skb_queue_tail(&ctx->rx_list, skb);

if (async) {
/* TLS 1.2-only, to_decrypt must be text length */
chunk = min_t(int, to_decrypt, len);
leave_on_list:
put_on_rx_list:
decrypted += chunk;
len -= chunk;
__skb_queue_tail(&ctx->rx_list, skb);
continue;
}
/* TLS 1.3 may have updated the length by more than overhead */
Expand All @@ -1925,8 +1928,6 @@ int tls_sw_recvmsg(struct sock *sk,
bool partially_consumed = chunk > len;

if (bpf_strp_enabled) {
/* BPF may try to queue the skb */
__skb_unlink(skb, &ctx->rx_list);
err = sk_psock_tls_strp_read(psock, skb);
if (err != __SK_PASS) {
rxm->offset = rxm->offset + rxm->full_len;
Expand All @@ -1935,31 +1936,31 @@ int tls_sw_recvmsg(struct sock *sk,
consume_skb(skb);
continue;
}
__skb_queue_tail(&ctx->rx_list, skb);
}

if (partially_consumed)
chunk = len;

err = skb_copy_datagram_msg(skb, rxm->offset,
msg, chunk);
if (err < 0)
if (err < 0) {
__skb_queue_tail(&ctx->rx_list, skb);
goto recv_end;
}

if (is_peek)
goto leave_on_list;
goto put_on_rx_list;

if (partially_consumed) {
rxm->offset += chunk;
rxm->full_len -= chunk;
goto leave_on_list;
goto put_on_rx_list;
}
}

decrypted += chunk;
len -= chunk;

__skb_unlink(skb, &ctx->rx_list);
consume_skb(skb);

/* Return full control message to userspace before trying
Expand Down

0 comments on commit 008141d

Please sign in to comment.