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

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

Issue 1411063004: Remove insecure QUIC support (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: enough! Created 5 years, 1 month 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/test_tools/quic_test_utils.cc ('k') | net/tools/quic/quic_client.h » ('j') | 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"
11 #include "base/memory/scoped_ptr.h" 11 #include "base/memory/scoped_ptr.h"
12 #include "base/memory/singleton.h" 12 #include "base/memory/singleton.h"
13 #include "base/strings/string_number_conversions.h" 13 #include "base/strings/string_number_conversions.h"
14 #include "base/synchronization/waitable_event.h" 14 #include "base/synchronization/waitable_event.h"
15 #include "base/threading/platform_thread.h" 15 #include "base/threading/platform_thread.h"
16 #include "base/time/time.h" 16 #include "base/time/time.h"
17 #include "net/base/ip_endpoint.h" 17 #include "net/base/ip_endpoint.h"
18 #include "net/quic/congestion_control/tcp_cubic_sender.h" 18 #include "net/quic/congestion_control/tcp_cubic_sender.h"
19 #include "net/quic/crypto/aes_128_gcm_12_encrypter.h" 19 #include "net/quic/crypto/aes_128_gcm_12_encrypter.h"
20 #include "net/quic/crypto/null_encrypter.h" 20 #include "net/quic/crypto/null_encrypter.h"
21 #include "net/quic/quic_flags.h" 21 #include "net/quic/quic_flags.h"
22 #include "net/quic/quic_framer.h" 22 #include "net/quic/quic_framer.h"
23 #include "net/quic/quic_packet_creator.h" 23 #include "net/quic/quic_packet_creator.h"
24 #include "net/quic/quic_protocol.h" 24 #include "net/quic/quic_protocol.h"
25 #include "net/quic/quic_server_id.h" 25 #include "net/quic/quic_server_id.h"
26 #include "net/quic/quic_utils.h" 26 #include "net/quic/quic_utils.h"
27 #include "net/quic/test_tools/crypto_test_utils.h"
27 #include "net/quic/test_tools/quic_connection_peer.h" 28 #include "net/quic/test_tools/quic_connection_peer.h"
28 #include "net/quic/test_tools/quic_flow_controller_peer.h" 29 #include "net/quic/test_tools/quic_flow_controller_peer.h"
29 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" 30 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h"
30 #include "net/quic/test_tools/quic_session_peer.h" 31 #include "net/quic/test_tools/quic_session_peer.h"
31 #include "net/quic/test_tools/quic_spdy_session_peer.h" 32 #include "net/quic/test_tools/quic_spdy_session_peer.h"
32 #include "net/quic/test_tools/quic_test_utils.h" 33 #include "net/quic/test_tools/quic_test_utils.h"
33 #include "net/quic/test_tools/reliable_quic_stream_peer.h" 34 #include "net/quic/test_tools/reliable_quic_stream_peer.h"
34 #include "net/test/gtest_util.h" 35 #include "net/test/gtest_util.h"
35 #include "net/tools/epoll_server/epoll_server.h" 36 #include "net/tools/epoll_server/epoll_server.h"
36 #include "net/tools/quic/quic_epoll_connection_helper.h" 37 #include "net/tools/quic/quic_epoll_connection_helper.h"
(...skipping 12 matching lines...) Expand all
49 #include "net/tools/quic/test_tools/quic_test_client.h" 50 #include "net/tools/quic/test_tools/quic_test_client.h"
50 #include "net/tools/quic/test_tools/quic_test_server.h" 51 #include "net/tools/quic/test_tools/quic_test_server.h"
51 #include "net/tools/quic/test_tools/server_thread.h" 52 #include "net/tools/quic/test_tools/server_thread.h"
52 #include "testing/gtest/include/gtest/gtest.h" 53 #include "testing/gtest/include/gtest/gtest.h"
53 54
54 using base::StringPiece; 55 using base::StringPiece;
55 using base::WaitableEvent; 56 using base::WaitableEvent;
56 using net::EpollServer; 57 using net::EpollServer;
57 using net::IPAddressNumber; 58 using net::IPAddressNumber;
58 using net::test::ConstructEncryptedPacket; 59 using net::test::ConstructEncryptedPacket;
60 using net::test::CryptoTestUtils;
59 using net::test::GenerateBody; 61 using net::test::GenerateBody;
60 using net::test::Loopback4; 62 using net::test::Loopback4;
61 using net::test::MockQuicConnectionDebugVisitor; 63 using net::test::MockQuicConnectionDebugVisitor;
62 using net::test::QuicConnectionPeer; 64 using net::test::QuicConnectionPeer;
63 using net::test::QuicFlowControllerPeer; 65 using net::test::QuicFlowControllerPeer;
64 using net::test::QuicSentPacketManagerPeer; 66 using net::test::QuicSentPacketManagerPeer;
65 using net::test::QuicSessionPeer; 67 using net::test::QuicSessionPeer;
66 using net::test::QuicSpdySessionPeer; 68 using net::test::QuicSpdySessionPeer;
67 using net::test::ReliableQuicStreamPeer; 69 using net::test::ReliableQuicStreamPeer;
68 using net::test::TestWriterFactory; 70 using net::test::TestWriterFactory;
(...skipping 199 matching lines...) Expand 10 before | Expand all | Expand 10 after
268 AddToCache("/bar", 200, "OK", kBarResponseBody); 270 AddToCache("/bar", 200, "OK", kBarResponseBody);
269 } 271 }
270 272
271 ~EndToEndTest() override { 273 ~EndToEndTest() override {
272 // TODO(rtenneti): port RecycleUnusedPort if needed. 274 // TODO(rtenneti): port RecycleUnusedPort if needed.
273 // RecycleUnusedPort(server_address_.port()); 275 // RecycleUnusedPort(server_address_.port());
274 QuicInMemoryCachePeer::ResetForTests(); 276 QuicInMemoryCachePeer::ResetForTests();
275 } 277 }
276 278
277 QuicTestClient* CreateQuicClient(QuicPacketWriterWrapper* writer) { 279 QuicTestClient* CreateQuicClient(QuicPacketWriterWrapper* writer) {
278 QuicTestClient* client = new QuicTestClient( 280 QuicTestClient* client =
279 server_address_, server_hostname_, 281 new QuicTestClient(server_address_, server_hostname_, client_config_,
280 /*secure=*/true, client_config_, client_supported_versions_); 282 client_supported_versions_);
281 client->UseWriter(writer); 283 client->UseWriter(writer);
282 client->Connect(); 284 client->Connect();
283 return client; 285 return client;
284 } 286 }
285 287
286 void set_client_initial_stream_flow_control_receive_window(uint32 window) { 288 void set_client_initial_stream_flow_control_receive_window(uint32 window) {
287 CHECK(client_.get() == nullptr); 289 CHECK(client_.get() == nullptr);
288 DVLOG(1) << "Setting client initial stream flow control window: " << window; 290 DVLOG(1) << "Setting client initial stream flow control window: " << window;
289 client_config_.SetInitialStreamFlowControlWindowToSend(window); 291 client_config_.SetInitialStreamFlowControlWindowToSend(window);
290 } 292 }
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
366 } 368 }
367 369
368 void TearDown() override { 370 void TearDown() override {
369 ASSERT_TRUE(initialized_) << "You must call Initialize() in every test " 371 ASSERT_TRUE(initialized_) << "You must call Initialize() in every test "
370 << "case. Otherwise, your test will leak memory."; 372 << "case. Otherwise, your test will leak memory.";
371 StopServer(); 373 StopServer();
372 } 374 }
373 375
374 void StartServer() { 376 void StartServer() {
375 server_thread_.reset(new ServerThread( 377 server_thread_.reset(new ServerThread(
376 new QuicTestServer(server_config_, server_supported_versions_), 378 new QuicTestServer(CryptoTestUtils::ProofSourceForTesting(),
377 /*is_secure=*/true, server_address_, 379 server_config_, server_supported_versions_),
378 strike_register_no_startup_period_)); 380 server_address_, strike_register_no_startup_period_));
379 server_thread_->Initialize(); 381 server_thread_->Initialize();
380 server_address_ = IPEndPoint(server_address_.address(), 382 server_address_ = IPEndPoint(server_address_.address(),
381 server_thread_->GetPort()); 383 server_thread_->GetPort());
382 QuicDispatcher* dispatcher = 384 QuicDispatcher* dispatcher =
383 QuicServerPeer::GetDispatcher(server_thread_->server()); 385 QuicServerPeer::GetDispatcher(server_thread_->server());
384 TestWriterFactory* packet_writer_factory = new TestWriterFactory(); 386 TestWriterFactory* packet_writer_factory = new TestWriterFactory();
385 QuicDispatcherPeer::SetPacketWriterFactory(dispatcher, 387 QuicDispatcherPeer::SetPacketWriterFactory(dispatcher,
386 packet_writer_factory); 388 packet_writer_factory);
387 QuicDispatcherPeer::UseWriter(dispatcher, server_writer_); 389 QuicDispatcherPeer::UseWriter(dispatcher, server_writer_);
388 390
(...skipping 1702 matching lines...) Expand 10 before | Expand all | Expand 10 after
2091 // There will be buffered data to write in the client's stream. 2093 // There will be buffered data to write in the client's stream.
2092 ReliableQuicStream* stream = client_->client()->session()->GetStream(5); 2094 ReliableQuicStream* stream = client_->client()->session()->GetStream(5);
2093 EXPECT_TRUE(stream != nullptr && stream->HasBufferedData()); 2095 EXPECT_TRUE(stream != nullptr && stream->HasBufferedData());
2094 } 2096 }
2095 } 2097 }
2096 2098
2097 } // namespace 2099 } // namespace
2098 } // namespace test 2100 } // namespace test
2099 } // namespace tools 2101 } // namespace tools
2100 } // namespace net 2102 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/test_tools/quic_test_utils.cc ('k') | net/tools/quic/quic_client.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698