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);
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]);
+ EXPECT_EQ(1u, out_len);
+ EXPECT_EQ(kQBIC, out[0]);
}
TEST_F(QuicConfigTest, ProcessClientHello) {
QuicConfig client_config;
QuicTagVector cgst;
- cgst.push_back(kINAR);
+ cgst.push_back(kTSTP);
cgst.push_back(kQBIC);
client_config.set_congestion_feedback(cgst, kQBIC);
client_config.set_idle_connection_state_lifetime(
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(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) {
2 * kInitialStreamFlowControlWindowForTest);
server_config.SetInitialSessionFlowControlWindowToSend(
2 * kInitialSessionFlowControlWindowForTest);
+ server_config.SetSocketReceiveBufferToSend(kDefaultSocketReceiveBuffer);
CryptoHandshakeMessage msg;
server_config.ToHandshakeMessage(&msg);
string error_details;
2 * kInitialStreamFlowControlWindowForTest);
EXPECT_EQ(config_.ReceivedInitialSessionFlowControlWindowBytes(),
2 * kInitialSessionFlowControlWindowForTest);
+ EXPECT_EQ(config_.ReceivedSocketReceiveBuffer(),
+ kDefaultSocketReceiveBuffer);
}
TEST_F(QuicConfigTest, MissingOptionalValuesInCHLO) {
QuicConfig server_config;
QuicTagVector cgst;
cgst.push_back(kQBIC);
- cgst.push_back(kINAR);
+ cgst.push_back(kTSTP);
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(kTSTP);
+ server_config.set_congestion_feedback(cgst, kTSTP);
CryptoHandshakeMessage msg;
string error_details;