| Index: net/quic/quic_connection.cc
|
| diff --git a/net/quic/quic_connection.cc b/net/quic/quic_connection.cc
|
| index 7dda3c7b2c13f6bc192634ecf996a8511eb56da1..c96fb42e35ae04f687dda51e8b5badbab0137128 100644
|
| --- a/net/quic/quic_connection.cc
|
| +++ b/net/quic/quic_connection.cc
|
| @@ -694,6 +694,7 @@ bool QuicConnection::OnStreamFrame(const QuicStreamFrame& frame) {
|
| return false;
|
| }
|
| visitor_->OnStreamFrame(frame);
|
| + visitor_->PostProcessAfterData();
|
| stats_.stream_bytes_received += frame.frame_length;
|
| should_last_packet_instigate_acks_ = true;
|
| return connected_;
|
| @@ -882,6 +883,7 @@ bool QuicConnection::OnRstStreamFrame(const QuicRstStreamFrame& frame) {
|
| << " with error: "
|
| << QuicUtils::StreamErrorToString(frame.error_code);
|
| visitor_->OnRstStream(frame);
|
| + visitor_->PostProcessAfterData();
|
| should_last_packet_instigate_acks_ = true;
|
| return connected_;
|
| }
|
| @@ -912,6 +914,7 @@ bool QuicConnection::OnGoAwayFrame(const QuicGoAwayFrame& frame) {
|
|
|
| goaway_received_ = true;
|
| visitor_->OnGoAway(frame);
|
| + visitor_->PostProcessAfterData();
|
| should_last_packet_instigate_acks_ = true;
|
| return connected_;
|
| }
|
| @@ -925,6 +928,7 @@ bool QuicConnection::OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) {
|
| << "WINDOW_UPDATE_FRAME received for stream: " << frame.stream_id
|
| << " with byte offset: " << frame.byte_offset;
|
| visitor_->OnWindowUpdateFrame(frame);
|
| + visitor_->PostProcessAfterData();
|
| should_last_packet_instigate_acks_ = true;
|
| return connected_;
|
| }
|
| @@ -937,6 +941,7 @@ bool QuicConnection::OnBlockedFrame(const QuicBlockedFrame& frame) {
|
| DVLOG(1) << ENDPOINT
|
| << "BLOCKED_FRAME received for stream: " << frame.stream_id;
|
| visitor_->OnBlockedFrame(frame);
|
| + visitor_->PostProcessAfterData();
|
| should_last_packet_instigate_acks_ = true;
|
| return connected_;
|
| }
|
| @@ -1332,6 +1337,7 @@ void QuicConnection::OnCanWrite() {
|
| { // Limit the scope of the bundler. ACK inclusion happens elsewhere.
|
| ScopedPacketBundler bundler(this, NO_ACK);
|
| visitor_->OnCanWrite();
|
| + visitor_->PostProcessAfterData();
|
| }
|
|
|
| // After the visitor writes, it may have caused the socket to become write
|
|
|