mirror of
https://github.com/torvalds/linux.git
synced 2026-05-30 01:53:29 +02:00
tcp: add data-race annotations for TCP_NLA_SNDQ_SIZE
tcp_get_timestamping_opt_stats() intentionally runs lockless, we must
add READ_ONCE() and WRITE_ONCE() annotations to keep KCSAN happy.
Fixes: 87ecc95d81 ("tcp: add send queue size stat in SCM_TIMESTAMPING_OPT_STATS")
Signed-off-by: Eric Dumazet <edumazet@google.com>
Link: https://patch.msgid.link/20260416200319.3608680-7-edumazet@google.com
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
This commit is contained in:
parent
faa886ad3c
commit
124199444d
|
|
@ -4456,7 +4456,9 @@ struct sk_buff *tcp_get_timestamping_opt_stats(const struct sock *sk,
|
|||
nla_put_u32(stats, TCP_NLA_DELIVERED, READ_ONCE(tp->delivered));
|
||||
nla_put_u32(stats, TCP_NLA_DELIVERED_CE, READ_ONCE(tp->delivered_ce));
|
||||
|
||||
nla_put_u32(stats, TCP_NLA_SNDQ_SIZE, tp->write_seq - tp->snd_una);
|
||||
nla_put_u32(stats, TCP_NLA_SNDQ_SIZE,
|
||||
max_t(int, 0,
|
||||
READ_ONCE(tp->write_seq) - READ_ONCE(tp->snd_una)));
|
||||
nla_put_u8(stats, TCP_NLA_CA_STATE, inet_csk(sk)->icsk_ca_state);
|
||||
|
||||
nla_put_u64_64bit(stats, TCP_NLA_BYTES_SENT, tp->bytes_sent,
|
||||
|
|
|
|||
|
|
@ -3912,7 +3912,7 @@ static void tcp_snd_una_update(struct tcp_sock *tp, u32 ack)
|
|||
sock_owned_by_me((struct sock *)tp);
|
||||
tp->bytes_acked += delta;
|
||||
tcp_snd_sne_update(tp, ack);
|
||||
tp->snd_una = ack;
|
||||
WRITE_ONCE(tp->snd_una, ack);
|
||||
}
|
||||
|
||||
static void tcp_rcv_sne_update(struct tcp_sock *tp, u32 seq)
|
||||
|
|
@ -7240,7 +7240,7 @@ tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb)
|
|||
if (sk->sk_socket)
|
||||
sk_wake_async(sk, SOCK_WAKE_IO, POLL_OUT);
|
||||
|
||||
tp->snd_una = TCP_SKB_CB(skb)->ack_seq;
|
||||
WRITE_ONCE(tp->snd_una, TCP_SKB_CB(skb)->ack_seq);
|
||||
tp->snd_wnd = ntohs(th->window) << tp->rx_opt.snd_wscale;
|
||||
tcp_init_wl(tp, TCP_SKB_CB(skb)->seq);
|
||||
|
||||
|
|
|
|||
|
|
@ -4153,7 +4153,7 @@ static void tcp_connect_init(struct sock *sk)
|
|||
tp->snd_wnd = 0;
|
||||
tcp_init_wl(tp, 0);
|
||||
tcp_write_queue_purge(sk);
|
||||
tp->snd_una = tp->write_seq;
|
||||
WRITE_ONCE(tp->snd_una, tp->write_seq);
|
||||
tp->snd_sml = tp->write_seq;
|
||||
tp->snd_up = tp->write_seq;
|
||||
WRITE_ONCE(tp->snd_nxt, tp->write_seq);
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user