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/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 "net/quic/crypto/proof_verifier.h" | 8 #include "net/quic/crypto/proof_verifier.h" |
9 #include "net/quic/quic_connection.h" | 9 #include "net/quic/quic_connection.h" |
10 #include "net/quic/quic_flags.h" | 10 #include "net/quic/quic_flags.h" |
(...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
265 // individual stream. | 265 // individual stream. |
266 DVLOG(1) << ENDPOINT | 266 DVLOG(1) << ENDPOINT |
267 << "Received connection level flow control window update with " | 267 << "Received connection level flow control window update with " |
268 "byte offset: " << frames[i].byte_offset; | 268 "byte offset: " << frames[i].byte_offset; |
269 if (flow_controller_->UpdateSendWindowOffset(frames[i].byte_offset)) { | 269 if (flow_controller_->UpdateSendWindowOffset(frames[i].byte_offset)) { |
270 connection_window_updated = true; | 270 connection_window_updated = true; |
271 } | 271 } |
272 continue; | 272 continue; |
273 } | 273 } |
274 | 274 |
275 if (connection_->version() <= QUIC_VERSION_21 && | 275 if (connection_->version() < QUIC_VERSION_21 && |
276 (stream_id == kCryptoStreamId || stream_id == kHeadersStreamId)) { | 276 (stream_id == kCryptoStreamId || stream_id == kHeadersStreamId)) { |
277 DLOG(DFATAL) << "WindowUpdate for stream " << stream_id << " in version " | 277 DLOG(DFATAL) << "WindowUpdate for stream " << stream_id << " in version " |
278 << QuicVersionToString(connection_->version()); | 278 << QuicVersionToString(connection_->version()); |
279 return; | 279 return; |
280 } | 280 } |
281 | 281 |
282 ReliableQuicStream* stream = GetStream(stream_id); | 282 ReliableQuicStream* stream = GetStream(stream_id); |
283 if (stream) { | 283 if (stream) { |
284 stream->OnWindowUpdateFrame(frames[i]); | 284 stream->OnWindowUpdateFrame(frames[i]); |
285 } | 285 } |
(...skipping 479 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
765 } | 765 } |
766 for (DataStreamMap::iterator it = stream_map_.begin(); | 766 for (DataStreamMap::iterator it = stream_map_.begin(); |
767 it != stream_map_.end(); ++it) { | 767 it != stream_map_.end(); ++it) { |
768 if (version <= QUIC_VERSION_16) { | 768 if (version <= QUIC_VERSION_16) { |
769 it->second->flow_controller()->Disable(); | 769 it->second->flow_controller()->Disable(); |
770 } | 770 } |
771 } | 771 } |
772 } | 772 } |
773 | 773 |
774 } // namespace net | 774 } // namespace net |
OLD | NEW |