1 files changed, 9 insertions, 1 deletions

diff --git a/net/ipv4/tcp.c b/net/ipv4/tcp.c
index 0c31be306572..bccc4c270087 100644
--- a/net/ipv4/tcp.c
+++ b/net/ipv4/tcp.c
@@ -485,6 +485,14 @@ static void tcp_tx_timestamp(struct sock *sk, u16 tsflags)
         }
 }
 
+static inline bool tcp_stream_is_readable(const struct tcp_sock *tp,
+                                          int target, struct sock *sk)
+{
+        return (tp->rcv_nxt - tp->copied_seq >= target) ||
+                (sk->sk_prot->stream_memory_read ?
+                sk->sk_prot->stream_memory_read(sk) : false);
+}
+
 /*
  *      Wait for a TCP event.
  *
@@ -554,7 +562,7 @@ __poll_t tcp_poll(struct file *file, struct socket *sock, poll_table *wait)
                     tp->urg_data)
                         target++;
 
-                if (tp->rcv_nxt - tp->copied_seq >= target)
+                if (tcp_stream_is_readable(tp, target, sk))
                         mask |= EPOLLIN | EPOLLRDNORM;
 
                 if (!(sk->sk_shutdown & SEND_SHUTDOWN)) {