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

Side by Side Diff: net/tools/quic/end_to_end_test.cc

Issue 663013003: Removing QUIC_VERSION_18. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@Change_QUIC_pacing_granularity_77587738
Patch Set: Created 6 years, 2 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 unified diff | Download patch
« no previous file with comments | « net/quic/quic_session_test.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 <stddef.h> 5 #include <stddef.h>
6 #include <string> 6 #include <string>
7 #include <sys/epoll.h> 7 #include <sys/epoll.h>
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/basictypes.h" 10 #include "base/basictypes.h"
(...skipping 744 matching lines...) Expand 10 before | Expand all | Expand 10 after
755 VerifyCleanConnection(false); 755 VerifyCleanConnection(false);
756 } 756 }
757 757
758 TEST_P(EndToEndTest, DoNotSetResumeWriteAlarmIfConnectionFlowControlBlocked) { 758 TEST_P(EndToEndTest, DoNotSetResumeWriteAlarmIfConnectionFlowControlBlocked) {
759 // Regression test for b/14677858. 759 // Regression test for b/14677858.
760 // Test that the resume write alarm is not set in QuicConnection::OnCanWrite 760 // Test that the resume write alarm is not set in QuicConnection::OnCanWrite
761 // if currently connection level flow control blocked. If set, this results in 761 // if currently connection level flow control blocked. If set, this results in
762 // an infinite loop in the EpollServer, as the alarm fires and is immediately 762 // an infinite loop in the EpollServer, as the alarm fires and is immediately
763 // rescheduled. 763 // rescheduled.
764 ASSERT_TRUE(Initialize()); 764 ASSERT_TRUE(Initialize());
765 if (negotiated_version_ < QUIC_VERSION_19) {
766 return;
767 }
768 client_->client()->WaitForCryptoHandshakeConfirmed(); 765 client_->client()->WaitForCryptoHandshakeConfirmed();
769 766
770 // Ensure both stream and connection level are flow control blocked by setting 767 // Ensure both stream and connection level are flow control blocked by setting
771 // the send window offset to 0. 768 // the send window offset to 0.
772 const uint64 kFlowControlWindow = 769 const uint64 kFlowControlWindow =
773 server_config_.GetInitialFlowControlWindowToSend(); 770 server_config_.GetInitialFlowControlWindowToSend();
774 QuicSpdyClientStream* stream = client_->GetOrCreateStream(); 771 QuicSpdyClientStream* stream = client_->GetOrCreateStream();
775 QuicSession* session = client_->client()->session(); 772 QuicSession* session = client_->client()->session();
776 QuicFlowControllerPeer::SetSendWindowOffset(stream->flow_controller(), 0); 773 QuicFlowControllerPeer::SetSendWindowOffset(stream->flow_controller(), 0);
777 QuicFlowControllerPeer::SetSendWindowOffset(session->flow_controller(), 0); 774 QuicFlowControllerPeer::SetSendWindowOffset(session->flow_controller(), 0);
(...skipping 460 matching lines...) Expand 10 before | Expand all | Expand 10 after
1238 const uint32 kClientSessionIFCW = 234567; 1235 const uint32 kClientSessionIFCW = 234567;
1239 set_client_initial_stream_flow_control_receive_window(kClientStreamIFCW); 1236 set_client_initial_stream_flow_control_receive_window(kClientStreamIFCW);
1240 set_client_initial_session_flow_control_receive_window(kClientSessionIFCW); 1237 set_client_initial_session_flow_control_receive_window(kClientSessionIFCW);
1241 1238
1242 const uint32 kServerStreamIFCW = 654321; 1239 const uint32 kServerStreamIFCW = 654321;
1243 const uint32 kServerSessionIFCW = 765432; 1240 const uint32 kServerSessionIFCW = 765432;
1244 set_server_initial_stream_flow_control_receive_window(kServerStreamIFCW); 1241 set_server_initial_stream_flow_control_receive_window(kServerStreamIFCW);
1245 set_server_initial_session_flow_control_receive_window(kServerSessionIFCW); 1242 set_server_initial_session_flow_control_receive_window(kServerSessionIFCW);
1246 1243
1247 ASSERT_TRUE(Initialize()); 1244 ASSERT_TRUE(Initialize());
1248 if (negotiated_version_ <= QUIC_VERSION_19) { 1245 if (negotiated_version_ == QUIC_VERSION_19) {
1249 return; 1246 return;
1250 } 1247 }
1251 1248
1252 // Values are exchanged during crypto handshake, so wait for that to finish. 1249 // Values are exchanged during crypto handshake, so wait for that to finish.
1253 client_->client()->WaitForCryptoHandshakeConfirmed(); 1250 client_->client()->WaitForCryptoHandshakeConfirmed();
1254 server_thread_->WaitForCryptoHandshakeConfirmed(); 1251 server_thread_->WaitForCryptoHandshakeConfirmed();
1255 1252
1256 // Open a data stream to make sure the stream level flow control is updated. 1253 // Open a data stream to make sure the stream level flow control is updated.
1257 QuicSpdyClientStream* stream = client_->GetOrCreateStream(); 1254 QuicSpdyClientStream* stream = client_->GetOrCreateStream();
1258 stream->SendBody("hello", false); 1255 stream->SendBody("hello", false);
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after
1360 QuicSession* session = dispatcher->session_map().begin()->second; 1357 QuicSession* session = dispatcher->session_map().begin()->second;
1361 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( 1358 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset(
1362 session).size()); 1359 session).size());
1363 server_thread_->Resume(); 1360 server_thread_->Resume();
1364 } 1361 }
1365 1362
1366 } // namespace 1363 } // namespace
1367 } // namespace test 1364 } // namespace test
1368 } // namespace tools 1365 } // namespace tools
1369 } // namespace net 1366 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_session_test.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698