| 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 |