diff options
Diffstat (limited to 'net/quic/quic_stream_sequencer.cc')
-rw-r--r-- | net/quic/quic_stream_sequencer.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/net/quic/quic_stream_sequencer.cc b/net/quic/quic_stream_sequencer.cc index 8f59064..61b4f7c 100644 --- a/net/quic/quic_stream_sequencer.cc +++ b/net/quic/quic_stream_sequencer.cc @@ -67,7 +67,7 @@ bool QuicStreamSequencer::OnStreamFrame(const QuicStreamFrame& frame) { data.iovec()[i].iov_len); } num_bytes_consumed_ += bytes_consumed; - stream_->flow_controller()->AddBytesConsumed(bytes_consumed); + stream_->AddBytesConsumed(bytes_consumed); stream_->MaybeSendWindowUpdate(); if (MaybeCloseStream()) { @@ -95,7 +95,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); + stream_->AddBytesBuffered(iov.iov_len); } return true; } @@ -247,8 +247,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_->AddBytesConsumed(bytes_consumed); + stream_->RemoveBytesBuffered(bytes_consumed); stream_->MaybeSendWindowUpdate(); } |