Skip to content

Commit e062fe9

Browse files
committed
tls: splice_read: fix accessing pre-processed records
recvmsg() will put peek()ed and partially read records onto the rx_list. splice_read() needs to consult that list otherwise it may miss data. Align with recvmsg() and also put partially-read records onto rx_list. tls_sw_advance_skb() is pretty pointless now and will be removed in net-next. Fixes: 692d7b5 ("tls: Fix recvmsg() to be able to peek across multiple records") Signed-off-by: Jakub Kicinski <kuba@kernel.org>
1 parent d87d67f commit e062fe9

File tree

1 file changed

+25
-8
lines changed

1 file changed

+25
-8
lines changed

net/tls/tls_sw.c

Lines changed: 25 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2005,6 +2005,7 @@ ssize_t tls_sw_splice_read(struct socket *sock, loff_t *ppos,
20052005
struct sock *sk = sock->sk;
20062006
struct sk_buff *skb;
20072007
ssize_t copied = 0;
2008+
bool from_queue;
20082009
int err = 0;
20092010
long timeo;
20102011
int chunk;
@@ -2014,14 +2015,20 @@ ssize_t tls_sw_splice_read(struct socket *sock, loff_t *ppos,
20142015

20152016
timeo = sock_rcvtimeo(sk, flags & SPLICE_F_NONBLOCK);
20162017

2017-
skb = tls_wait_data(sk, NULL, flags & SPLICE_F_NONBLOCK, timeo, &err);
2018-
if (!skb)
2019-
goto splice_read_end;
2018+
from_queue = !skb_queue_empty(&ctx->rx_list);
2019+
if (from_queue) {
2020+
skb = __skb_dequeue(&ctx->rx_list);
2021+
} else {
2022+
skb = tls_wait_data(sk, NULL, flags & SPLICE_F_NONBLOCK, timeo,
2023+
&err);
2024+
if (!skb)
2025+
goto splice_read_end;
20202026

2021-
err = decrypt_skb_update(sk, skb, NULL, &chunk, &zc, false);
2022-
if (err < 0) {
2023-
tls_err_abort(sk, -EBADMSG);
2024-
goto splice_read_end;
2027+
err = decrypt_skb_update(sk, skb, NULL, &chunk, &zc, false);
2028+
if (err < 0) {
2029+
tls_err_abort(sk, -EBADMSG);
2030+
goto splice_read_end;
2031+
}
20252032
}
20262033

20272034
/* splice does not support reading control messages */
@@ -2037,7 +2044,17 @@ ssize_t tls_sw_splice_read(struct socket *sock, loff_t *ppos,
20372044
if (copied < 0)
20382045
goto splice_read_end;
20392046

2040-
tls_sw_advance_skb(sk, skb, copied);
2047+
if (!from_queue) {
2048+
ctx->recv_pkt = NULL;
2049+
__strp_unpause(&ctx->strp);
2050+
}
2051+
if (chunk < rxm->full_len) {
2052+
__skb_queue_head(&ctx->rx_list, skb);
2053+
rxm->offset += len;
2054+
rxm->full_len -= len;
2055+
} else {
2056+
consume_skb(skb);
2057+
}
20412058

20422059
splice_read_end:
20432060
release_sock(sk);

0 commit comments

Comments
 (0)