Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(468)

Unified Diff: net/quic/core/quic_flow_controller_test.cc

Issue 2901773004: Landing Recent QUIC changes until May 20, 2017. (Closed)
Patch Set: Disable quic_restart_flag_quic_big_endian_connection_id_server until tests can be fixed. Created 3 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/core/quic_flow_controller.cc ('k') | net/quic/core/quic_framer.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/core/quic_flow_controller_test.cc
diff --git a/net/quic/core/quic_flow_controller_test.cc b/net/quic/core/quic_flow_controller_test.cc
index 95019d89f536d84f216d8d87f0dd95b497011f65..0c17adb306231a666a9c1177894ab0d3695fda8d 100644
--- a/net/quic/core/quic_flow_controller_test.cc
+++ b/net/quic/core/quic_flow_controller_test.cc
@@ -38,9 +38,7 @@ class QuicFlowControllerTest : public QuicTest {
: stream_id_(1234),
send_window_(kInitialSessionFlowControlWindowForTest),
receive_window_(kInitialSessionFlowControlWindowForTest),
- connection_(&helper_, &alarm_factory_, Perspective::IS_CLIENT) {
- FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune = true;
- }
+ connection_(&helper_, &alarm_factory_, Perspective::IS_CLIENT) {}
void Initialize() {
flow_controller_.reset(new QuicFlowController(
@@ -167,13 +165,7 @@ TEST_F(QuicFlowControllerTest, OnlySendBlockedFrameOncePerOffset) {
TEST_F(QuicFlowControllerTest, ReceivingBytesFastIncreasesFlowWindow) {
// This test will generate two WINDOW_UPDATE frames.
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_))
- .Times(1);
- } else {
- EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_))
- .Times(2);
- }
+ EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_)).Times(1);
Initialize();
flow_controller_->set_auto_tune_receive_window(true);
@@ -203,32 +195,16 @@ TEST_F(QuicFlowControllerTest, ReceivingBytesFastIncreasesFlowWindow) {
EXPECT_FALSE(flow_controller_->FlowControlViolation());
EXPECT_EQ(kInitialSessionFlowControlWindowForTest - receive_offset,
QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_CALL(
- session_flow_controller_,
- EnsureWindowAtLeast(kInitialSessionFlowControlWindowForTest * 2 * 1.5));
- }
+ EXPECT_CALL(
+ session_flow_controller_,
+ EnsureWindowAtLeast(kInitialSessionFlowControlWindowForTest * 2 * 1.5));
// Consume enough bytes to send a WINDOW_UPDATE frame.
flow_controller_->AddBytesConsumed(threshold + 1);
// Result is that once again we have a fully open receive window.
EXPECT_FALSE(flow_controller_->FlowControlViolation());
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_EQ(
- 2 * kInitialSessionFlowControlWindowForTest,
- QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
- } else {
- EXPECT_EQ(
- kInitialSessionFlowControlWindowForTest,
- QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
-
- // Move time forward, but by less than two RTTs. Then receive and consume
- // some more, forcing a second WINDOW_UPDATE with an increased max window
- // size.
- EXPECT_CALL(
- session_flow_controller_,
- EnsureWindowAtLeast(kInitialSessionFlowControlWindowForTest * 2 * 1.5));
- }
+ EXPECT_EQ(2 * kInitialSessionFlowControlWindowForTest,
+ QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
connection_.AdvanceTime(QuicTime::Delta::FromMilliseconds(2 * kRtt - 1));
receive_offset += threshold + 1;
@@ -295,13 +271,7 @@ TEST_F(QuicFlowControllerTest, ReceivingBytesFastNoAutoTune) {
TEST_F(QuicFlowControllerTest, ReceivingBytesNormalStableFlowWindow) {
// This test will generate two WINDOW_UPDATE frames.
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_))
- .Times(1);
- } else {
- EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_))
- .Times(2);
- }
+ EXPECT_CALL(connection_, SendWindowUpdate(stream_id_, ::testing::_)).Times(1);
Initialize();
flow_controller_->set_auto_tune_receive_window(true);
@@ -330,24 +300,15 @@ TEST_F(QuicFlowControllerTest, ReceivingBytesNormalStableFlowWindow) {
EXPECT_FALSE(flow_controller_->FlowControlViolation());
EXPECT_EQ(kInitialSessionFlowControlWindowForTest - receive_offset,
QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_CALL(
- session_flow_controller_,
- EnsureWindowAtLeast(kInitialSessionFlowControlWindowForTest * 2 * 1.5));
- }
+ EXPECT_CALL(
+ session_flow_controller_,
+ EnsureWindowAtLeast(kInitialSessionFlowControlWindowForTest * 2 * 1.5));
flow_controller_->AddBytesConsumed(threshold + 1);
// Result is that once again we have a fully open receive window.
EXPECT_FALSE(flow_controller_->FlowControlViolation());
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_EQ(
- 2 * kInitialSessionFlowControlWindowForTest,
- QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
- } else {
- EXPECT_EQ(
- kInitialSessionFlowControlWindowForTest,
- QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
- }
+ EXPECT_EQ(2 * kInitialSessionFlowControlWindowForTest,
+ QuicFlowControllerPeer::ReceiveWindowSize(flow_controller_.get()));
// Move time forward, but by more than two RTTs. Then receive and consume
// some more, forcing a second WINDOW_UPDATE with unchanged max window size.
@@ -361,11 +322,7 @@ TEST_F(QuicFlowControllerTest, ReceivingBytesNormalStableFlowWindow) {
QuicByteCount new_threshold =
QuicFlowControllerPeer::WindowUpdateThreshold(flow_controller_.get());
- if (FLAGS_quic_reloadable_flag_quic_flow_control_faster_autotune) {
- EXPECT_EQ(new_threshold, 2 * threshold);
- } else {
- EXPECT_EQ(new_threshold, threshold);
- }
+ EXPECT_EQ(new_threshold, 2 * threshold);
}
TEST_F(QuicFlowControllerTest, ReceivingBytesNormalNoAutoTune) {
« no previous file with comments | « net/quic/core/quic_flow_controller.cc ('k') | net/quic/core/quic_framer.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698