tcp: factorize logic into tcp_epollin_ready()
Both tcp_data_ready() and tcp_stream_is_readable() share the same logic. Add tcp_epollin_ready() helper to avoid duplication. Signed-off-by: Eric Dumazet <edumazet@google.com> Cc: Arjun Roy <arjunroy@google.com> Cc: Wei Wang <weiwan@google.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
committed by
David S. Miller
parent
f969dc5a88
commit
05dc72aba3
@@ -1442,6 +1442,18 @@ static inline bool tcp_rmem_pressure(const struct sock *sk)
|
||||
return atomic_read(&sk->sk_rmem_alloc) > threshold;
|
||||
}
|
||||
|
||||
static inline bool tcp_epollin_ready(const struct sock *sk, int target)
|
||||
{
|
||||
const struct tcp_sock *tp = tcp_sk(sk);
|
||||
int avail = READ_ONCE(tp->rcv_nxt) - READ_ONCE(tp->copied_seq);
|
||||
|
||||
if (avail <= 0)
|
||||
return false;
|
||||
|
||||
return (avail >= target) || tcp_rmem_pressure(sk) ||
|
||||
(tcp_receive_window(tp) <= inet_csk(sk)->icsk_ack.rcv_mss);
|
||||
}
|
||||
|
||||
extern void tcp_openreq_init_rwin(struct request_sock *req,
|
||||
const struct sock *sk_listener,
|
||||
const struct dst_entry *dst);
|
||||
|
||||
Reference in New Issue
Block a user