#include "net/quic/crypto/crypto_protocol.h"
#include "net/quic/quic_flags.h"
#include "net/quic/quic_protocol.h"
-#include "net/quic/quic_sent_packet_manager.h"
#include "net/quic/quic_time.h"
#include "net/quic/quic_utils.h"
#include "net/quic/test_tools/quic_test_utils.h"
};
TEST_F(QuicConfigTest, ToHandshakeMessage) {
- ValueRestore<bool> old_flag(&FLAGS_enable_quic_pacing, false);
config_.SetDefaults();
config_.SetInitialFlowControlWindowToSend(
kInitialSessionFlowControlWindowForTest);
config_.set_idle_connection_state_lifetime(QuicTime::Delta::FromSeconds(5),
QuicTime::Delta::FromSeconds(2));
config_.set_max_streams_per_connection(4, 2);
+ config_.SetSocketReceiveBufferToSend(kDefaultSocketReceiveBuffer);
CryptoHandshakeMessage msg;
config_.ToHandshakeMessage(&msg);
EXPECT_EQ(QUIC_NO_ERROR, error);
EXPECT_EQ(kInitialSessionFlowControlWindowForTest, value);
+ error = msg.GetUint32(kSRBF, &value);
+ EXPECT_EQ(QUIC_NO_ERROR, error);
+ EXPECT_EQ(kDefaultSocketReceiveBuffer, value);
+
const QuicTag* out;
size_t out_len;
error = msg.GetTaglist(kCGST, &out, &out_len);
EXPECT_EQ(kQBIC, *out);
}
-TEST_F(QuicConfigTest, ToHandshakeMessageWithPacing) {
- ValueRestore<bool> old_flag(&FLAGS_enable_quic_pacing, true);
-
- config_.SetDefaults();
- CryptoHandshakeMessage msg;
- config_.ToHandshakeMessage(&msg);
-
- const QuicTag* out;
- size_t out_len;
- EXPECT_EQ(QUIC_NO_ERROR, msg.GetTaglist(kCGST, &out, &out_len));
- EXPECT_EQ(2u, out_len);
- EXPECT_EQ(kPACE, out[0]);
- EXPECT_EQ(kQBIC, out[1]);
-}
-
TEST_F(QuicConfigTest, ProcessClientHello) {
QuicConfig client_config;
QuicTagVector cgst;
- cgst.push_back(kINAR);
cgst.push_back(kQBIC);
client_config.set_congestion_feedback(cgst, kQBIC);
client_config.set_idle_connection_state_lifetime(
- QuicTime::Delta::FromSeconds(2 * kDefaultTimeoutSecs),
- QuicTime::Delta::FromSeconds(kDefaultTimeoutSecs));
+ QuicTime::Delta::FromSeconds(2 * kMaximumIdleTimeoutSecs),
+ QuicTime::Delta::FromSeconds(kMaximumIdleTimeoutSecs));
client_config.set_max_streams_per_connection(
2 * kDefaultMaxStreamsPerConnection, kDefaultMaxStreamsPerConnection);
client_config.SetInitialRoundTripTimeUsToSend(
2 * kInitialStreamFlowControlWindowForTest);
client_config.SetInitialSessionFlowControlWindowToSend(
2 * kInitialSessionFlowControlWindowForTest);
+ client_config.SetSocketReceiveBufferToSend(kDefaultSocketReceiveBuffer);
QuicTagVector copt;
copt.push_back(kTBBR);
- client_config.SetCongestionOptionsToSend(copt);
+ copt.push_back(kFHDR);
+ client_config.SetConnectionOptionsToSend(copt);
CryptoHandshakeMessage msg;
client_config.ToHandshakeMessage(&msg);
string error_details;
EXPECT_EQ(QUIC_NO_ERROR, error);
EXPECT_TRUE(config_.negotiated());
EXPECT_EQ(kQBIC, config_.congestion_feedback());
- EXPECT_EQ(QuicTime::Delta::FromSeconds(kDefaultTimeoutSecs),
+ EXPECT_EQ(QuicTime::Delta::FromSeconds(kMaximumIdleTimeoutSecs),
config_.idle_connection_state_lifetime());
EXPECT_EQ(kDefaultMaxStreamsPerConnection,
config_.max_streams_per_connection());
EXPECT_EQ(10 * base::Time::kMicrosecondsPerMillisecond,
config_.ReceivedInitialRoundTripTimeUs());
EXPECT_FALSE(config_.HasReceivedLossDetection());
- EXPECT_TRUE(config_.HasReceivedCongestionOptions());
- EXPECT_EQ(1u, config_.ReceivedCongestionOptions().size());
- EXPECT_EQ(config_.ReceivedCongestionOptions()[0], kTBBR);
+ EXPECT_TRUE(config_.HasReceivedConnectionOptions());
+ EXPECT_EQ(2u, config_.ReceivedConnectionOptions().size());
+ EXPECT_EQ(config_.ReceivedConnectionOptions()[0], kTBBR);
+ EXPECT_EQ(config_.ReceivedConnectionOptions()[1], kFHDR);
EXPECT_EQ(config_.ReceivedInitialFlowControlWindowBytes(),
2 * kInitialSessionFlowControlWindowForTest);
EXPECT_EQ(config_.ReceivedInitialStreamFlowControlWindowBytes(),
2 * kInitialStreamFlowControlWindowForTest);
EXPECT_EQ(config_.ReceivedInitialSessionFlowControlWindowBytes(),
2 * kInitialSessionFlowControlWindowForTest);
+ EXPECT_EQ(config_.ReceivedSocketReceiveBuffer(),
+ kDefaultSocketReceiveBuffer);
}
TEST_F(QuicConfigTest, ProcessServerHello) {
cgst.push_back(kQBIC);
server_config.set_congestion_feedback(cgst, kQBIC);
server_config.set_idle_connection_state_lifetime(
- QuicTime::Delta::FromSeconds(kDefaultTimeoutSecs / 2),
- QuicTime::Delta::FromSeconds(kDefaultTimeoutSecs / 2));
+ QuicTime::Delta::FromSeconds(kMaximumIdleTimeoutSecs / 2),
+ QuicTime::Delta::FromSeconds(kMaximumIdleTimeoutSecs / 2));
server_config.set_max_streams_per_connection(
kDefaultMaxStreamsPerConnection / 2,
kDefaultMaxStreamsPerConnection / 2);
2 * kInitialStreamFlowControlWindowForTest);
server_config.SetInitialSessionFlowControlWindowToSend(
2 * kInitialSessionFlowControlWindowForTest);
+ server_config.SetSocketReceiveBufferToSend(kDefaultSocketReceiveBuffer);
CryptoHandshakeMessage msg;
server_config.ToHandshakeMessage(&msg);
string error_details;
EXPECT_EQ(QUIC_NO_ERROR, error);
EXPECT_TRUE(config_.negotiated());
EXPECT_EQ(kQBIC, config_.congestion_feedback());
- EXPECT_EQ(QuicTime::Delta::FromSeconds(kDefaultTimeoutSecs / 2),
+ EXPECT_EQ(QuicTime::Delta::FromSeconds(kMaximumIdleTimeoutSecs / 2),
config_.idle_connection_state_lifetime());
EXPECT_EQ(kDefaultMaxStreamsPerConnection / 2,
config_.max_streams_per_connection());
2 * kInitialStreamFlowControlWindowForTest);
EXPECT_EQ(config_.ReceivedInitialSessionFlowControlWindowBytes(),
2 * kInitialSessionFlowControlWindowForTest);
+ EXPECT_EQ(config_.ReceivedSocketReceiveBuffer(),
+ kDefaultSocketReceiveBuffer);
}
TEST_F(QuicConfigTest, MissingOptionalValuesInCHLO) {
TEST_F(QuicConfigTest, OutOfBoundSHLO) {
QuicConfig server_config;
server_config.set_idle_connection_state_lifetime(
- QuicTime::Delta::FromSeconds(2 * kDefaultTimeoutSecs),
- QuicTime::Delta::FromSeconds(2 * kDefaultTimeoutSecs));
+ QuicTime::Delta::FromSeconds(2 * kMaximumIdleTimeoutSecs),
+ QuicTime::Delta::FromSeconds(2 * kMaximumIdleTimeoutSecs));
CryptoHandshakeMessage msg;
server_config.ToHandshakeMessage(&msg);
QuicConfig server_config;
QuicTagVector cgst;
cgst.push_back(kQBIC);
- cgst.push_back(kINAR);
+ cgst.push_back(kTBBR);
server_config.set_congestion_feedback(cgst, kQBIC);
CryptoHandshakeMessage msg;
QuicConfig server_config;
server_config.SetDefaults();
QuicTagVector cgst;
- cgst.push_back(kINAR);
- server_config.set_congestion_feedback(cgst, kINAR);
+ cgst.push_back(kTBBR);
+ server_config.set_congestion_feedback(cgst, kTBBR);
CryptoHandshakeMessage msg;
string error_details;