Index: net/quic/quic_config.cc |
diff --git a/net/quic/quic_config.cc b/net/quic/quic_config.cc |
deleted file mode 100644 |
index 803ae7f517146a0ed03cb41867fdd99a9cd498ec..0000000000000000000000000000000000000000 |
--- a/net/quic/quic_config.cc |
+++ /dev/null |
@@ -1,682 +0,0 @@ |
-// Copyright (c) 2013 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "net/quic/quic_config.h" |
- |
-#include <algorithm> |
- |
-#include "base/logging.h" |
-#include "net/quic/crypto/crypto_handshake_message.h" |
-#include "net/quic/crypto/crypto_protocol.h" |
-#include "net/quic/quic_utils.h" |
- |
-using std::min; |
-using std::string; |
- |
-namespace net { |
- |
-// Reads the value corresponding to |name_| from |msg| into |out|. If the |
-// |name_| is absent in |msg| and |presence| is set to OPTIONAL |out| is set |
-// to |default_value|. |
-QuicErrorCode ReadUint32(const CryptoHandshakeMessage& msg, |
- QuicTag tag, |
- QuicConfigPresence presence, |
- uint32 default_value, |
- uint32* out, |
- string* error_details) { |
- DCHECK(error_details != nullptr); |
- QuicErrorCode error = msg.GetUint32(tag, out); |
- switch (error) { |
- case QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND: |
- if (presence == PRESENCE_REQUIRED) { |
- *error_details = "Missing " + QuicUtils::TagToString(tag); |
- break; |
- } |
- error = QUIC_NO_ERROR; |
- *out = default_value; |
- break; |
- case QUIC_NO_ERROR: |
- break; |
- default: |
- *error_details = "Bad " + QuicUtils::TagToString(tag); |
- break; |
- } |
- return error; |
-} |
- |
- |
-QuicConfigValue::QuicConfigValue(QuicTag tag, |
- QuicConfigPresence presence) |
- : tag_(tag), |
- presence_(presence) { |
-} |
-QuicConfigValue::~QuicConfigValue() {} |
- |
-QuicNegotiableValue::QuicNegotiableValue(QuicTag tag, |
- QuicConfigPresence presence) |
- : QuicConfigValue(tag, presence), |
- negotiated_(false) { |
-} |
-QuicNegotiableValue::~QuicNegotiableValue() {} |
- |
-QuicNegotiableUint32::QuicNegotiableUint32(QuicTag tag, |
- QuicConfigPresence presence) |
- : QuicNegotiableValue(tag, presence), |
- max_value_(0), |
- default_value_(0) { |
-} |
-QuicNegotiableUint32::~QuicNegotiableUint32() {} |
- |
-void QuicNegotiableUint32::set(uint32 max, uint32 default_value) { |
- DCHECK_LE(default_value, max); |
- max_value_ = max; |
- default_value_ = default_value; |
-} |
- |
-uint32 QuicNegotiableUint32::GetUint32() const { |
- if (negotiated()) { |
- return negotiated_value_; |
- } |
- return default_value_; |
-} |
- |
-void QuicNegotiableUint32::ToHandshakeMessage( |
- CryptoHandshakeMessage* out) const { |
- if (negotiated()) { |
- out->SetValue(tag_, negotiated_value_); |
- } else { |
- out->SetValue(tag_, max_value_); |
- } |
-} |
- |
-QuicErrorCode QuicNegotiableUint32::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(!negotiated()); |
- DCHECK(error_details != nullptr); |
- uint32 value; |
- QuicErrorCode error = ReadUint32(peer_hello, |
- tag_, |
- presence_, |
- default_value_, |
- &value, |
- error_details); |
- if (error != QUIC_NO_ERROR) { |
- return error; |
- } |
- if (hello_type == SERVER && value > max_value_) { |
- *error_details = |
- "Invalid value received for " + QuicUtils::TagToString(tag_); |
- return QUIC_INVALID_NEGOTIATED_VALUE; |
- } |
- |
- set_negotiated(true); |
- negotiated_value_ = min(value, max_value_); |
- return QUIC_NO_ERROR; |
-} |
- |
-QuicNegotiableTag::QuicNegotiableTag(QuicTag tag, QuicConfigPresence presence) |
- : QuicNegotiableValue(tag, presence), |
- negotiated_tag_(0), |
- default_value_(0) { |
-} |
- |
-QuicNegotiableTag::~QuicNegotiableTag() {} |
- |
-void QuicNegotiableTag::set(const QuicTagVector& possible, |
- QuicTag default_value) { |
- DCHECK(ContainsQuicTag(possible, default_value)); |
- possible_values_ = possible; |
- default_value_ = default_value; |
-} |
- |
-QuicTag QuicNegotiableTag::GetTag() const { |
- if (negotiated()) { |
- return negotiated_tag_; |
- } |
- return default_value_; |
-} |
- |
-void QuicNegotiableTag::ToHandshakeMessage(CryptoHandshakeMessage* out) const { |
- if (negotiated()) { |
- // Because of the way we serialize and parse handshake messages we can |
- // serialize this as value and still parse it as a vector. |
- out->SetValue(tag_, negotiated_tag_); |
- } else { |
- out->SetVector(tag_, possible_values_); |
- } |
-} |
- |
-QuicErrorCode QuicNegotiableTag::ReadVector( |
- const CryptoHandshakeMessage& msg, |
- const QuicTag** out, |
- size_t* out_length, |
- string* error_details) const { |
- DCHECK(error_details != nullptr); |
- QuicErrorCode error = msg.GetTaglist(tag_, out, out_length); |
- switch (error) { |
- case QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND: |
- if (presence_ == PRESENCE_REQUIRED) { |
- *error_details = "Missing " + QuicUtils::TagToString(tag_); |
- break; |
- } |
- error = QUIC_NO_ERROR; |
- *out_length = 1; |
- *out = &default_value_; |
- |
- case QUIC_NO_ERROR: |
- break; |
- default: |
- *error_details = "Bad " + QuicUtils::TagToString(tag_); |
- break; |
- } |
- return error; |
-} |
- |
-QuicErrorCode QuicNegotiableTag::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(!negotiated()); |
- DCHECK(error_details != nullptr); |
- const QuicTag* received_tags; |
- size_t received_tags_length; |
- QuicErrorCode error = ReadVector(peer_hello, &received_tags, |
- &received_tags_length, error_details); |
- if (error != QUIC_NO_ERROR) { |
- return error; |
- } |
- |
- if (hello_type == SERVER) { |
- if (received_tags_length != 1 || |
- !ContainsQuicTag(possible_values_, *received_tags)) { |
- *error_details = "Invalid " + QuicUtils::TagToString(tag_); |
- return QUIC_INVALID_NEGOTIATED_VALUE; |
- } |
- negotiated_tag_ = *received_tags; |
- } else { |
- QuicTag negotiated_tag; |
- if (!QuicUtils::FindMutualTag(possible_values_, |
- received_tags, |
- received_tags_length, |
- QuicUtils::LOCAL_PRIORITY, |
- &negotiated_tag, |
- nullptr)) { |
- *error_details = "Unsupported " + QuicUtils::TagToString(tag_); |
- return QUIC_CRYPTO_MESSAGE_PARAMETER_NO_OVERLAP; |
- } |
- negotiated_tag_ = negotiated_tag; |
- } |
- |
- set_negotiated(true); |
- return QUIC_NO_ERROR; |
-} |
- |
-QuicFixedUint32::QuicFixedUint32(QuicTag tag, QuicConfigPresence presence) |
- : QuicConfigValue(tag, presence), |
- has_send_value_(false), |
- has_receive_value_(false) { |
-} |
-QuicFixedUint32::~QuicFixedUint32() {} |
- |
-bool QuicFixedUint32::HasSendValue() const { |
- return has_send_value_; |
-} |
- |
-uint32 QuicFixedUint32::GetSendValue() const { |
- LOG_IF(DFATAL, !has_send_value_) |
- << "No send value to get for tag:" << QuicUtils::TagToString(tag_); |
- return send_value_; |
-} |
- |
-void QuicFixedUint32::SetSendValue(uint32 value) { |
- has_send_value_ = true; |
- send_value_ = value; |
-} |
- |
-bool QuicFixedUint32::HasReceivedValue() const { |
- return has_receive_value_; |
-} |
- |
-uint32 QuicFixedUint32::GetReceivedValue() const { |
- LOG_IF(DFATAL, !has_receive_value_) |
- << "No receive value to get for tag:" << QuicUtils::TagToString(tag_); |
- return receive_value_; |
-} |
- |
-void QuicFixedUint32::SetReceivedValue(uint32 value) { |
- has_receive_value_ = true; |
- receive_value_ = value; |
-} |
- |
-void QuicFixedUint32::ToHandshakeMessage(CryptoHandshakeMessage* out) const { |
- if (has_send_value_) { |
- out->SetValue(tag_, send_value_); |
- } |
-} |
- |
-QuicErrorCode QuicFixedUint32::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(error_details != nullptr); |
- QuicErrorCode error = peer_hello.GetUint32(tag_, &receive_value_); |
- switch (error) { |
- case QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND: |
- if (presence_ == PRESENCE_OPTIONAL) { |
- return QUIC_NO_ERROR; |
- } |
- *error_details = "Missing " + QuicUtils::TagToString(tag_); |
- break; |
- case QUIC_NO_ERROR: |
- has_receive_value_ = true; |
- break; |
- default: |
- *error_details = "Bad " + QuicUtils::TagToString(tag_); |
- break; |
- } |
- return error; |
-} |
- |
-QuicFixedTag::QuicFixedTag(QuicTag name, |
- QuicConfigPresence presence) |
- : QuicConfigValue(name, presence), |
- has_send_value_(false), |
- has_receive_value_(false) { |
-} |
- |
-QuicFixedTag::~QuicFixedTag() {} |
- |
-bool QuicFixedTag::HasSendValue() const { |
- return has_send_value_; |
-} |
- |
-uint32 QuicFixedTag::GetSendValue() const { |
- LOG_IF(DFATAL, !has_send_value_) |
- << "No send value to get for tag:" << QuicUtils::TagToString(tag_); |
- return send_value_; |
-} |
- |
-void QuicFixedTag::SetSendValue(uint32 value) { |
- has_send_value_ = true; |
- send_value_ = value; |
-} |
- |
-bool QuicFixedTag::HasReceivedValue() const { |
- return has_receive_value_; |
-} |
- |
-uint32 QuicFixedTag::GetReceivedValue() const { |
- LOG_IF(DFATAL, !has_receive_value_) |
- << "No receive value to get for tag:" << QuicUtils::TagToString(tag_); |
- return receive_value_; |
-} |
- |
-void QuicFixedTag::SetReceivedValue(uint32 value) { |
- has_receive_value_ = true; |
- receive_value_ = value; |
-} |
- |
-void QuicFixedTag::ToHandshakeMessage(CryptoHandshakeMessage* out) const { |
- if (has_send_value_) { |
- out->SetValue(tag_, send_value_); |
- } |
-} |
- |
-QuicErrorCode QuicFixedTag::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(error_details != nullptr); |
- QuicErrorCode error = peer_hello.GetUint32(tag_, &receive_value_); |
- switch (error) { |
- case QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND: |
- if (presence_ == PRESENCE_OPTIONAL) { |
- return QUIC_NO_ERROR; |
- } |
- *error_details = "Missing " + QuicUtils::TagToString(tag_); |
- break; |
- case QUIC_NO_ERROR: |
- has_receive_value_ = true; |
- break; |
- default: |
- *error_details = "Bad " + QuicUtils::TagToString(tag_); |
- break; |
- } |
- return error; |
-} |
- |
-QuicFixedTagVector::QuicFixedTagVector(QuicTag name, |
- QuicConfigPresence presence) |
- : QuicConfigValue(name, presence), |
- has_send_values_(false), |
- has_receive_values_(false) { |
-} |
- |
-QuicFixedTagVector::~QuicFixedTagVector() {} |
- |
-bool QuicFixedTagVector::HasSendValues() const { |
- return has_send_values_; |
-} |
- |
-QuicTagVector QuicFixedTagVector::GetSendValues() const { |
- LOG_IF(DFATAL, !has_send_values_) |
- << "No send values to get for tag:" << QuicUtils::TagToString(tag_); |
- return send_values_; |
-} |
- |
-void QuicFixedTagVector::SetSendValues(const QuicTagVector& values) { |
- has_send_values_ = true; |
- send_values_ = values; |
-} |
- |
-bool QuicFixedTagVector::HasReceivedValues() const { |
- return has_receive_values_; |
-} |
- |
-QuicTagVector QuicFixedTagVector::GetReceivedValues() const { |
- LOG_IF(DFATAL, !has_receive_values_) |
- << "No receive value to get for tag:" << QuicUtils::TagToString(tag_); |
- return receive_values_; |
-} |
- |
-void QuicFixedTagVector::SetReceivedValues(const QuicTagVector& values) { |
- has_receive_values_ = true; |
- receive_values_ = values; |
-} |
- |
-void QuicFixedTagVector::ToHandshakeMessage(CryptoHandshakeMessage* out) const { |
- if (has_send_values_) { |
- out->SetVector(tag_, send_values_); |
- } |
-} |
- |
-QuicErrorCode QuicFixedTagVector::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(error_details != nullptr); |
- const QuicTag* received_tags; |
- size_t received_tags_length; |
- QuicErrorCode error = |
- peer_hello.GetTaglist(tag_, &received_tags, &received_tags_length); |
- switch (error) { |
- case QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND: |
- if (presence_ == PRESENCE_OPTIONAL) { |
- return QUIC_NO_ERROR; |
- } |
- *error_details = "Missing " + QuicUtils::TagToString(tag_); |
- break; |
- case QUIC_NO_ERROR: |
- DVLOG(1) << "Received Connection Option tags from receiver."; |
- has_receive_values_ = true; |
- for (size_t i = 0; i < received_tags_length; ++i) { |
- receive_values_.push_back(received_tags[i]); |
- } |
- break; |
- default: |
- *error_details = "Bad " + QuicUtils::TagToString(tag_); |
- break; |
- } |
- return error; |
-} |
- |
-QuicConfig::QuicConfig() |
- : max_time_before_crypto_handshake_(QuicTime::Delta::Zero()), |
- max_idle_time_before_crypto_handshake_(QuicTime::Delta::Zero()), |
- max_undecryptable_packets_(0), |
- congestion_feedback_(kCGST, PRESENCE_OPTIONAL), |
- connection_options_(kCOPT, PRESENCE_OPTIONAL), |
- idle_connection_state_lifetime_seconds_(kICSL, PRESENCE_REQUIRED), |
- silent_close_(kSCLS, PRESENCE_OPTIONAL), |
- max_streams_per_connection_(kMSPC, PRESENCE_REQUIRED), |
- bytes_for_connection_id_(kTCID, PRESENCE_OPTIONAL), |
- initial_round_trip_time_us_(kIRTT, PRESENCE_OPTIONAL), |
- initial_stream_flow_control_window_bytes_(kSFCW, PRESENCE_OPTIONAL), |
- initial_session_flow_control_window_bytes_(kCFCW, PRESENCE_OPTIONAL), |
- socket_receive_buffer_(kSRBF, PRESENCE_OPTIONAL) { |
- SetDefaults(); |
-} |
- |
-QuicConfig::~QuicConfig() {} |
- |
-void QuicConfig::SetConnectionOptionsToSend( |
- const QuicTagVector& connection_options) { |
- connection_options_.SetSendValues(connection_options); |
-} |
- |
-bool QuicConfig::HasReceivedConnectionOptions() const { |
- return connection_options_.HasReceivedValues(); |
-} |
- |
-QuicTagVector QuicConfig::ReceivedConnectionOptions() const { |
- return connection_options_.GetReceivedValues(); |
-} |
- |
-bool QuicConfig::HasSendConnectionOptions() const { |
- return connection_options_.HasSendValues(); |
-} |
- |
-QuicTagVector QuicConfig::SendConnectionOptions() const { |
- return connection_options_.GetSendValues(); |
-} |
- |
-void QuicConfig::SetIdleConnectionStateLifetime( |
- QuicTime::Delta max_idle_connection_state_lifetime, |
- QuicTime::Delta default_idle_conection_state_lifetime) { |
- idle_connection_state_lifetime_seconds_.set( |
- static_cast<uint32>(max_idle_connection_state_lifetime.ToSeconds()), |
- static_cast<uint32>(default_idle_conection_state_lifetime.ToSeconds())); |
-} |
- |
-QuicTime::Delta QuicConfig::IdleConnectionStateLifetime() const { |
- return QuicTime::Delta::FromSeconds( |
- idle_connection_state_lifetime_seconds_.GetUint32()); |
-} |
- |
-void QuicConfig::SetSilentClose(bool silent_close) { |
- silent_close_.set(silent_close ? 1 : 0, silent_close ? 1 : 0); |
-} |
- |
-bool QuicConfig::SilentClose() const { |
- return silent_close_.GetUint32() > 0; |
-} |
- |
-void QuicConfig::SetMaxStreamsPerConnection(size_t max_streams, |
- size_t default_streams) { |
- max_streams_per_connection_.set(max_streams, default_streams); |
-} |
- |
-uint32 QuicConfig::MaxStreamsPerConnection() const { |
- return max_streams_per_connection_.GetUint32(); |
-} |
- |
-bool QuicConfig::HasSetBytesForConnectionIdToSend() const { |
- return bytes_for_connection_id_.HasSendValue(); |
-} |
- |
-void QuicConfig::SetBytesForConnectionIdToSend(uint32 bytes) { |
- bytes_for_connection_id_.SetSendValue(bytes); |
-} |
- |
-bool QuicConfig::HasReceivedBytesForConnectionId() const { |
- return bytes_for_connection_id_.HasReceivedValue(); |
-} |
- |
-uint32 QuicConfig::ReceivedBytesForConnectionId() const { |
- return bytes_for_connection_id_.GetReceivedValue(); |
-} |
- |
-void QuicConfig::SetInitialRoundTripTimeUsToSend(uint32 rtt) { |
- initial_round_trip_time_us_.SetSendValue(rtt); |
-} |
- |
-bool QuicConfig::HasReceivedInitialRoundTripTimeUs() const { |
- return initial_round_trip_time_us_.HasReceivedValue(); |
-} |
- |
-uint32 QuicConfig::ReceivedInitialRoundTripTimeUs() const { |
- return initial_round_trip_time_us_.GetReceivedValue(); |
-} |
- |
-bool QuicConfig::HasInitialRoundTripTimeUsToSend() const { |
- return initial_round_trip_time_us_.HasSendValue(); |
-} |
- |
-uint32 QuicConfig::GetInitialRoundTripTimeUsToSend() const { |
- return initial_round_trip_time_us_.GetSendValue(); |
-} |
- |
-void QuicConfig::SetInitialStreamFlowControlWindowToSend(uint32 window_bytes) { |
- if (window_bytes < kMinimumFlowControlSendWindow) { |
- LOG(DFATAL) << "Initial stream flow control receive window (" |
- << window_bytes << ") cannot be set lower than default (" |
- << kMinimumFlowControlSendWindow << ")."; |
- window_bytes = kMinimumFlowControlSendWindow; |
- } |
- initial_stream_flow_control_window_bytes_.SetSendValue(window_bytes); |
-} |
- |
-uint32 QuicConfig::GetInitialStreamFlowControlWindowToSend() const { |
- return initial_stream_flow_control_window_bytes_.GetSendValue(); |
-} |
- |
-bool QuicConfig::HasReceivedInitialStreamFlowControlWindowBytes() const { |
- return initial_stream_flow_control_window_bytes_.HasReceivedValue(); |
-} |
- |
-uint32 QuicConfig::ReceivedInitialStreamFlowControlWindowBytes() const { |
- return initial_stream_flow_control_window_bytes_.GetReceivedValue(); |
-} |
- |
-void QuicConfig::SetInitialSessionFlowControlWindowToSend(uint32 window_bytes) { |
- if (window_bytes < kMinimumFlowControlSendWindow) { |
- LOG(DFATAL) << "Initial session flow control receive window (" |
- << window_bytes << ") cannot be set lower than default (" |
- << kMinimumFlowControlSendWindow << ")."; |
- window_bytes = kMinimumFlowControlSendWindow; |
- } |
- initial_session_flow_control_window_bytes_.SetSendValue(window_bytes); |
-} |
- |
-uint32 QuicConfig::GetInitialSessionFlowControlWindowToSend() const { |
- return initial_session_flow_control_window_bytes_.GetSendValue(); |
-} |
- |
-bool QuicConfig::HasReceivedInitialSessionFlowControlWindowBytes() const { |
- return initial_session_flow_control_window_bytes_.HasReceivedValue(); |
-} |
- |
-uint32 QuicConfig::ReceivedInitialSessionFlowControlWindowBytes() const { |
- return initial_session_flow_control_window_bytes_.GetReceivedValue(); |
-} |
- |
-void QuicConfig::SetSocketReceiveBufferToSend(uint32 tcp_receive_window) { |
- socket_receive_buffer_.SetSendValue(tcp_receive_window); |
-} |
- |
-uint32 QuicConfig::GetSocketReceiveBufferToSend() const { |
- return socket_receive_buffer_.GetSendValue(); |
-} |
- |
-bool QuicConfig::HasReceivedSocketReceiveBuffer() const { |
- return socket_receive_buffer_.HasReceivedValue(); |
-} |
- |
-uint32 QuicConfig::ReceivedSocketReceiveBuffer() const { |
- return socket_receive_buffer_.GetReceivedValue(); |
-} |
- |
-bool QuicConfig::negotiated() const { |
- // TODO(ianswett): Add the negotiated parameters once and iterate over all |
- // of them in negotiated, ToHandshakeMessage, ProcessClientHello, and |
- // ProcessServerHello. |
- return idle_connection_state_lifetime_seconds_.negotiated() && |
- max_streams_per_connection_.negotiated(); |
-} |
- |
-void QuicConfig::SetDefaults() { |
- QuicTagVector congestion_feedback; |
- // TODO(alyssar) stop sending this once QUIC_VERSION_23 is sunset. |
- // This field was required until version 22 was removed but by the time |
- // QUIC_VERSION_23 is sunset, no users of QUIC_VERSION_24 should be expecting |
- // it. |
- congestion_feedback.push_back(kQBIC); |
- congestion_feedback_.set(congestion_feedback, kQBIC); |
- idle_connection_state_lifetime_seconds_.set(kMaximumIdleTimeoutSecs, |
- kDefaultIdleTimeoutSecs); |
- silent_close_.set(1, 0); |
- SetMaxStreamsPerConnection(kDefaultMaxStreamsPerConnection, |
- kDefaultMaxStreamsPerConnection); |
- max_time_before_crypto_handshake_ = |
- QuicTime::Delta::FromSeconds(kMaxTimeForCryptoHandshakeSecs); |
- max_idle_time_before_crypto_handshake_ = |
- QuicTime::Delta::FromSeconds(kInitialIdleTimeoutSecs); |
- max_undecryptable_packets_ = kDefaultMaxUndecryptablePackets; |
- |
- SetInitialStreamFlowControlWindowToSend(kMinimumFlowControlSendWindow); |
- SetInitialSessionFlowControlWindowToSend(kMinimumFlowControlSendWindow); |
-} |
- |
-void QuicConfig::ToHandshakeMessage(CryptoHandshakeMessage* out) const { |
- congestion_feedback_.ToHandshakeMessage(out); |
- idle_connection_state_lifetime_seconds_.ToHandshakeMessage(out); |
- silent_close_.ToHandshakeMessage(out); |
- max_streams_per_connection_.ToHandshakeMessage(out); |
- bytes_for_connection_id_.ToHandshakeMessage(out); |
- initial_round_trip_time_us_.ToHandshakeMessage(out); |
- initial_stream_flow_control_window_bytes_.ToHandshakeMessage(out); |
- initial_session_flow_control_window_bytes_.ToHandshakeMessage(out); |
- socket_receive_buffer_.ToHandshakeMessage(out); |
- connection_options_.ToHandshakeMessage(out); |
-} |
- |
-QuicErrorCode QuicConfig::ProcessPeerHello( |
- const CryptoHandshakeMessage& peer_hello, |
- HelloType hello_type, |
- string* error_details) { |
- DCHECK(error_details != nullptr); |
- |
- QuicErrorCode error = QUIC_NO_ERROR; |
- if (error == QUIC_NO_ERROR) { |
- error = idle_connection_state_lifetime_seconds_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = |
- silent_close_.ProcessPeerHello(peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = max_streams_per_connection_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = bytes_for_connection_id_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = initial_round_trip_time_us_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = initial_stream_flow_control_window_bytes_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = initial_session_flow_control_window_bytes_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = socket_receive_buffer_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- if (error == QUIC_NO_ERROR) { |
- error = connection_options_.ProcessPeerHello( |
- peer_hello, hello_type, error_details); |
- } |
- return error; |
-} |
- |
-} // namespace net |