OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/reliable_quic_stream.h" | 5 #include "net/quic/reliable_quic_stream.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "net/quic/iovector.h" | 8 #include "net/quic/iovector.h" |
9 #include "net/quic/quic_flow_controller.h" | 9 #include "net/quic/quic_flow_controller.h" |
10 #include "net/quic/quic_session.h" | 10 #include "net/quic/quic_session.h" |
(...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
123 fin_sent_(false), | 123 fin_sent_(false), |
124 rst_sent_(false), | 124 rst_sent_(false), |
125 is_server_(session_->is_server()), | 125 is_server_(session_->is_server()), |
126 flow_controller_( | 126 flow_controller_( |
127 session_->connection()->version(), | 127 session_->connection()->version(), |
128 id_, | 128 id_, |
129 is_server_, | 129 is_server_, |
130 session_->config()->HasReceivedInitialFlowControlWindowBytes() ? | 130 session_->config()->HasReceivedInitialFlowControlWindowBytes() ? |
131 session_->config()->ReceivedInitialFlowControlWindowBytes() : | 131 session_->config()->ReceivedInitialFlowControlWindowBytes() : |
132 kDefaultFlowControlSendWindow, | 132 kDefaultFlowControlSendWindow, |
133 session_->connection()->max_flow_control_receive_window_bytes(), | 133 session_->max_flow_control_receive_window_bytes(), |
134 session_->connection()->max_flow_control_receive_window_bytes()), | 134 session_->max_flow_control_receive_window_bytes()), |
135 connection_flow_controller_(session_->connection()->flow_controller()) { | 135 connection_flow_controller_(session_->flow_controller()) { |
136 } | 136 } |
137 | 137 |
138 ReliableQuicStream::~ReliableQuicStream() { | 138 ReliableQuicStream::~ReliableQuicStream() { |
139 } | 139 } |
140 | 140 |
141 bool ReliableQuicStream::OnStreamFrame(const QuicStreamFrame& frame) { | 141 bool ReliableQuicStream::OnStreamFrame(const QuicStreamFrame& frame) { |
142 if (read_side_closed_) { | 142 if (read_side_closed_) { |
143 DVLOG(1) << ENDPOINT << "Ignoring frame " << frame.stream_id; | 143 DVLOG(1) << ENDPOINT << "Ignoring frame " << frame.stream_id; |
144 // We don't want to be reading: blackhole the data. | 144 // We don't want to be reading: blackhole the data. |
145 return true; | 145 return true; |
(...skipping 317 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
463 connection_flow_controller_->AddBytesConsumed(bytes); | 463 connection_flow_controller_->AddBytesConsumed(bytes); |
464 } | 464 } |
465 } | 465 } |
466 | 466 |
467 bool ReliableQuicStream::IsFlowControlBlocked() { | 467 bool ReliableQuicStream::IsFlowControlBlocked() { |
468 return flow_controller_.IsBlocked() || | 468 return flow_controller_.IsBlocked() || |
469 connection_flow_controller_->IsBlocked(); | 469 connection_flow_controller_->IsBlocked(); |
470 } | 470 } |
471 | 471 |
472 } // namespace net | 472 } // namespace net |
OLD | NEW |