Index: net/quic/reliable_quic_stream.cc |
diff --git a/net/quic/reliable_quic_stream.cc b/net/quic/reliable_quic_stream.cc |
index aefdb4126be6e4bd19b1344a6f0505229a75b7c5..e1068905961950dfb60a3481018b21c6878e896e 100644 |
--- a/net/quic/reliable_quic_stream.cc |
+++ b/net/quic/reliable_quic_stream.cc |
@@ -160,16 +160,10 @@ bool ReliableQuicStream::OnStreamFrame(const QuicStreamFrame& frame) { |
session_->connection()->SendConnectionClose(QUIC_FLOW_CONTROL_ERROR); |
return false; |
} |
- MaybeSendWindowUpdate(); |
return accepted; |
} |
-void ReliableQuicStream::MaybeSendWindowUpdate() { |
- flow_controller_.MaybeSendWindowUpdate(session()->connection()); |
- connection_flow_controller_->MaybeSendWindowUpdate(session()->connection()); |
-} |
- |
int ReliableQuicStream::num_frames_received() const { |
return sequencer_.num_frames_received(); |
} |
@@ -460,7 +454,10 @@ void ReliableQuicStream::AddBytesSent(uint64 bytes) { |
void ReliableQuicStream::AddBytesConsumed(uint64 bytes) { |
if (flow_controller_.IsEnabled()) { |
flow_controller_.AddBytesConsumed(bytes); |
+ flow_controller_.MaybeSendWindowUpdate(session()->connection()); |
+ |
connection_flow_controller_->AddBytesConsumed(bytes); |
+ connection_flow_controller_->MaybeSendWindowUpdate(session()->connection()); |
} |
} |