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 410 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
421 return GetCryptoStream()->encryption_established(); | 421 return GetCryptoStream()->encryption_established(); |
422 } | 422 } |
423 | 423 |
424 bool QuicSession::IsCryptoHandshakeConfirmed() { | 424 bool QuicSession::IsCryptoHandshakeConfirmed() { |
425 return GetCryptoStream()->handshake_confirmed(); | 425 return GetCryptoStream()->handshake_confirmed(); |
426 } | 426 } |
427 | 427 |
428 void QuicSession::OnConfigNegotiated() { | 428 void QuicSession::OnConfigNegotiated() { |
429 connection_->SetFromConfig(config_); | 429 connection_->SetFromConfig(config_); |
430 | 430 |
431 uint32 max_streams = config_.MaxStreamsPerConnection(); | 431 uint32_t max_streams = config_.MaxStreamsPerConnection(); |
432 if (perspective() == Perspective::IS_SERVER) { | 432 if (perspective() == Perspective::IS_SERVER) { |
433 // A server should accept a small number of additional streams beyond the | 433 // A server should accept a small number of additional streams beyond the |
434 // limit sent to the client. This helps avoid early connection termination | 434 // limit sent to the client. This helps avoid early connection termination |
435 // when FIN/RSTs for old streams are lost or arrive out of order. | 435 // when FIN/RSTs for old streams are lost or arrive out of order. |
436 // Use a minimum number of additional streams, or a percentage increase, | 436 // Use a minimum number of additional streams, or a percentage increase, |
437 // whichever is larger. | 437 // whichever is larger. |
438 max_streams = max(max_streams + kMaxStreamsMinimumIncrement, | 438 max_streams = |
439 static_cast<uint32>(max_streams * kMaxStreamsMultiplier)); | 439 max(max_streams + kMaxStreamsMinimumIncrement, |
| 440 static_cast<uint32_t>(max_streams * kMaxStreamsMultiplier)); |
440 | 441 |
441 if (config_.HasReceivedConnectionOptions()) { | 442 if (config_.HasReceivedConnectionOptions()) { |
442 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kAFCW)) { | 443 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kAFCW)) { |
443 // The following variations change the initial receive flow control | 444 // The following variations change the initial receive flow control |
444 // window sizes. | 445 // window sizes. |
445 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kIFW5)) { | 446 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kIFW5)) { |
446 AdjustInitialFlowControlWindows(32 * 1024); | 447 AdjustInitialFlowControlWindows(32 * 1024); |
447 } | 448 } |
448 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kIFW6)) { | 449 if (ContainsQuicTag(config_.ReceivedConnectionOptions(), kIFW6)) { |
449 AdjustInitialFlowControlWindows(64 * 1024); | 450 AdjustInitialFlowControlWindows(64 * 1024); |
(...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
809 } | 810 } |
810 } | 811 } |
811 return false; | 812 return false; |
812 } | 813 } |
813 | 814 |
814 bool QuicSession::IsIncomingStream(QuicStreamId id) const { | 815 bool QuicSession::IsIncomingStream(QuicStreamId id) const { |
815 return id % 2 != next_outgoing_stream_id_ % 2; | 816 return id % 2 != next_outgoing_stream_id_ % 2; |
816 } | 817 } |
817 | 818 |
818 } // namespace net | 819 } // namespace net |
OLD | NEW |