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

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

Issue 1613513003: Early connection migration in QUIC. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@home
Patch Set: Typo fixed. Created 4 years, 10 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/quic_session.h" 5 #include "net/quic/quic_session.h"
6 6
7 #include "base/stl_util.h" 7 #include "base/stl_util.h"
8 #include "base/strings/string_number_conversions.h" 8 #include "base/strings/string_number_conversions.h"
9 #include "base/strings/stringprintf.h" 9 #include "base/strings/stringprintf.h"
10 #include "net/quic/crypto/proof_verifier.h" 10 #include "net/quic/crypto/proof_verifier.h"
(...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after
125 if (dynamic_stream_map_.find(id) != dynamic_stream_map_.end()) { 125 if (dynamic_stream_map_.find(id) != dynamic_stream_map_.end()) {
126 QUIC_BUG << ENDPOINT << "Stream failed to close under OnConnectionClosed"; 126 QUIC_BUG << ENDPOINT << "Stream failed to close under OnConnectionClosed";
127 CloseStream(id); 127 CloseStream(id);
128 } 128 }
129 } 129 }
130 } 130 }
131 131
132 void QuicSession::OnSuccessfulVersionNegotiation( 132 void QuicSession::OnSuccessfulVersionNegotiation(
133 const QuicVersion& /*version*/) {} 133 const QuicVersion& /*version*/) {}
134 134
135 void QuicSession::OnPathDegrading() {}
136
135 void QuicSession::OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) { 137 void QuicSession::OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) {
136 // Stream may be closed by the time we receive a WINDOW_UPDATE, so we can't 138 // Stream may be closed by the time we receive a WINDOW_UPDATE, so we can't
137 // assume that it still exists. 139 // assume that it still exists.
138 QuicStreamId stream_id = frame.stream_id; 140 QuicStreamId stream_id = frame.stream_id;
139 if (stream_id == kConnectionLevelId) { 141 if (stream_id == kConnectionLevelId) {
140 // This is a window update that applies to the connection, rather than an 142 // This is a window update that applies to the connection, rather than an
141 // individual stream. 143 // individual stream.
142 DVLOG(1) << ENDPOINT << "Received connection level flow control window " 144 DVLOG(1) << ENDPOINT << "Received connection level flow control window "
143 "update with byte offset: " 145 "update with byte offset: "
144 << frame.byte_offset; 146 << frame.byte_offset;
(...skipping 685 matching lines...) Expand 10 before | Expand all | Expand 10 after
830 832
831 size_t QuicSession::MaxAvailableStreams() const { 833 size_t QuicSession::MaxAvailableStreams() const {
832 return max_open_incoming_streams_ * kMaxAvailableStreamsMultiplier; 834 return max_open_incoming_streams_ * kMaxAvailableStreamsMultiplier;
833 } 835 }
834 836
835 bool QuicSession::IsIncomingStream(QuicStreamId id) const { 837 bool QuicSession::IsIncomingStream(QuicStreamId id) const {
836 return id % 2 != next_outgoing_stream_id_ % 2; 838 return id % 2 != next_outgoing_stream_id_ % 2;
837 } 839 }
838 840
839 } // namespace net 841 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698