Index: net/quic/quic_stream_sequencer.cc |
diff --git a/net/quic/quic_stream_sequencer.cc b/net/quic/quic_stream_sequencer.cc |
index 055ed970f56d718bbee7e368a894f154a03b6483..a9b2e977b962ccbea1a114932468fc7cf60e53c8 100644 |
--- a/net/quic/quic_stream_sequencer.cc |
+++ b/net/quic/quic_stream_sequencer.cc |
@@ -119,6 +119,7 @@ bool QuicStreamSequencer::OnStreamFrame(const QuicStreamFrame& frame) { |
data.iovec()[i].iov_len); |
} |
num_bytes_consumed_ += bytes_consumed; |
+ stream_->flow_controller()->AddBytesConsumed(bytes_consumed); |
stream_->MaybeSendWindowUpdate(); |
if (MaybeCloseStream()) { |
@@ -146,6 +147,7 @@ bool QuicStreamSequencer::OnStreamFrame(const QuicStreamFrame& frame) { |
byte_offset, string(static_cast<char*>(iov.iov_base), iov.iov_len))); |
byte_offset += iov.iov_len; |
num_bytes_buffered_ += iov.iov_len; |
+ stream_->flow_controller()->AddBytesBuffered(iov.iov_len); |
} |
return true; |
} |
@@ -297,6 +299,8 @@ void QuicStreamSequencer::RecordBytesConsumed(size_t bytes_consumed) { |
num_bytes_consumed_ += bytes_consumed; |
num_bytes_buffered_ -= bytes_consumed; |
+ stream_->flow_controller()->AddBytesConsumed(bytes_consumed); |
+ stream_->flow_controller()->RemoveBytesBuffered(bytes_consumed); |
stream_->MaybeSendWindowUpdate(); |
} |