QuicChromiumClientStream handle Read() after trailers are received but not yet delivered

net/quic/chromium/bidirectional_stream_quic_impl.cc

Index: net/quic/chromium/bidirectional_stream_quic_impl.cc
diff --git a/net/quic/chromium/bidirectional_stream_quic_impl.cc b/net/quic/chromium/bidirectional_stream_quic_impl.cc
index 0fb1119f5700407871a8d315faf92282cc19145a..e46675211b48f44aa81edd81f1531727f06c95b9 100644
--- a/net/quic/chromium/bidirectional_stream_quic_impl.cc
+++ b/net/quic/chromium/bidirectional_stream_quic_impl.cc
@@ -241,19 +241,8 @@ void BidirectionalStreamQuicImpl::OnHeadersAvailable(
     if (delegate_)
       delegate_->OnHeadersReceived(headers);
   } else {
-    if (stream_->IsDoneReading()) {

[xunjieli, 2016/10/07 17:15:35]

This block is removed because now we always have OnDataAvailable() after
OnHeadersAvailable(trailers), and we can do OnFinRead() in OnDataAvailable().

We can't do OnFinRead() here because it will invoke OnClose() which will reset
QuicChromiumClientStream::|delegate_| so we won't get OnDataAvailable().

-      // If the write side is closed, OnFinRead() will call
-      // BidirectionalStreamQuicImpl::OnClose().
-      stream_->OnFinRead();
-    }
-    if (!delegate_)
-      return;
-    // Complete any remaining read. The task is posted because
-    // |delegate_|->OnTrailersReceived() might destroy |this|.
-    base::ThreadTaskRunnerHandle::Get()->PostTask(
-        FROM_HERE, base::Bind(&BidirectionalStreamQuicImpl::OnDataAvailable,
-                              weak_factory_.GetWeakPtr()));
-    delegate_->OnTrailersReceived(headers);
+    if (delegate_)
+      delegate_->OnTrailersReceived(headers);
     // |this| can be destroyed after this point.
   }
 }