summaryrefslogtreecommitdiffstats
path: root/net/quic/quic_stream_sequencer.cc
diff options
context:
space:
mode:
Diffstat (limited to 'net/quic/quic_stream_sequencer.cc')
-rw-r--r--net/quic/quic_stream_sequencer.cc8
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();
}