Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(105)

Side by Side Diff: net/quic/reliable_quic_stream.cc

Issue 288313003: Land Recent QUIC Changes. (Closed) Base URL: https://chromium.googlesource.com/chromium/src
Patch Set: implemented rch's comments Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698