OLD | NEW |
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 "base/basictypes.h" | 5 #include "base/basictypes.h" |
6 #include "base/compiler_specific.h" | 6 #include "base/compiler_specific.h" |
7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
9 #include "net/base/capturing_net_log.h" | 9 #include "net/base/capturing_net_log.h" |
10 #include "net/base/net_log_unittest.h" | 10 #include "net/base/net_log_unittest.h" |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
57 | 57 |
58 class QuicNetworkTransactionTest : public PlatformTest { | 58 class QuicNetworkTransactionTest : public PlatformTest { |
59 protected: | 59 protected: |
60 QuicNetworkTransactionTest() | 60 QuicNetworkTransactionTest() |
61 : clock_(new MockClock), | 61 : clock_(new MockClock), |
62 ssl_config_service_(new SSLConfigServiceDefaults), | 62 ssl_config_service_(new SSLConfigServiceDefaults), |
63 proxy_service_(ProxyService::CreateDirect()), | 63 proxy_service_(ProxyService::CreateDirect()), |
64 compressor_(new QuicSpdyCompressor()), | 64 compressor_(new QuicSpdyCompressor()), |
65 auth_handler_factory_( | 65 auth_handler_factory_( |
66 HttpAuthHandlerFactory::CreateDefault(&host_resolver_)), | 66 HttpAuthHandlerFactory::CreateDefault(&host_resolver_)), |
| 67 random_generator_(0), |
67 hanging_data_(NULL, 0, NULL, 0) { | 68 hanging_data_(NULL, 0, NULL, 0) { |
68 request_.method = "GET"; | 69 request_.method = "GET"; |
69 request_.url = GURL("http://www.google.com/"); | 70 request_.url = GURL("http://www.google.com/"); |
70 request_.load_flags = 0; | 71 request_.load_flags = 0; |
71 } | 72 } |
72 | 73 |
73 virtual void SetUp() { | 74 virtual void SetUp() { |
74 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); | 75 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); |
75 base::MessageLoop::current()->RunUntilIdle(); | 76 base::MessageLoop::current()->RunUntilIdle(); |
76 } | 77 } |
77 | 78 |
78 virtual void TearDown() { | 79 virtual void TearDown() { |
79 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); | 80 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); |
80 // Empty the current queue. | 81 // Empty the current queue. |
81 base::MessageLoop::current()->RunUntilIdle(); | 82 base::MessageLoop::current()->RunUntilIdle(); |
82 PlatformTest::TearDown(); | 83 PlatformTest::TearDown(); |
83 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); | 84 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); |
84 base::MessageLoop::current()->RunUntilIdle(); | 85 base::MessageLoop::current()->RunUntilIdle(); |
85 HttpStreamFactory::set_use_alternate_protocols(false); | 86 HttpStreamFactory::set_use_alternate_protocols(false); |
86 HttpStreamFactory::SetNextProtos(std::vector<NextProto>()); | 87 HttpStreamFactory::SetNextProtos(std::vector<NextProto>()); |
87 } | 88 } |
88 | 89 |
89 scoped_ptr<QuicEncryptedPacket> ConstructRstPacket( | 90 scoped_ptr<QuicEncryptedPacket> ConstructRstPacket( |
90 QuicPacketSequenceNumber num, | 91 QuicPacketSequenceNumber num, |
91 QuicStreamId stream_id) { | 92 QuicStreamId stream_id) { |
92 QuicPacketHeader header; | 93 QuicPacketHeader header; |
93 header.public_header.guid = 0xDEADBEEF; | 94 header.public_header.guid = random_generator_.RandUint64(); |
94 header.public_header.reset_flag = false; | 95 header.public_header.reset_flag = false; |
95 header.public_header.version_flag = false; | 96 header.public_header.version_flag = false; |
96 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 97 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
97 header.packet_sequence_number = num; | 98 header.packet_sequence_number = num; |
98 header.entropy_flag = false; | 99 header.entropy_flag = false; |
99 header.fec_flag = false; | 100 header.fec_flag = false; |
100 header.fec_group = 0; | 101 header.fec_group = 0; |
101 | 102 |
102 QuicRstStreamFrame rst(stream_id, QUIC_STREAM_NO_ERROR); | 103 QuicRstStreamFrame rst(stream_id, QUIC_STREAM_NO_ERROR); |
103 return scoped_ptr<QuicEncryptedPacket>( | 104 return scoped_ptr<QuicEncryptedPacket>( |
104 ConstructPacket(header, QuicFrame(&rst))); | 105 ConstructPacket(header, QuicFrame(&rst))); |
105 } | 106 } |
106 | 107 |
107 scoped_ptr<QuicEncryptedPacket> ConstructConnectionClosePacket( | 108 scoped_ptr<QuicEncryptedPacket> ConstructConnectionClosePacket( |
108 QuicPacketSequenceNumber num) { | 109 QuicPacketSequenceNumber num) { |
109 QuicPacketHeader header; | 110 QuicPacketHeader header; |
110 header.public_header.guid = 0xDEADBEEF; | 111 header.public_header.guid = random_generator_.RandUint64(); |
111 header.public_header.reset_flag = false; | 112 header.public_header.reset_flag = false; |
112 header.public_header.version_flag = false; | 113 header.public_header.version_flag = false; |
113 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 114 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
114 header.packet_sequence_number = num; | 115 header.packet_sequence_number = num; |
115 header.entropy_flag = false; | 116 header.entropy_flag = false; |
116 header.fec_flag = false; | 117 header.fec_flag = false; |
117 header.fec_group = 0; | 118 header.fec_group = 0; |
118 | 119 |
119 QuicConnectionCloseFrame close; | 120 QuicConnectionCloseFrame close; |
120 close.error_code = QUIC_CRYPTO_VERSION_NOT_SUPPORTED; | 121 close.error_code = QUIC_CRYPTO_VERSION_NOT_SUPPORTED; |
121 close.error_details = "Time to panic!"; | 122 close.error_details = "Time to panic!"; |
122 return scoped_ptr<QuicEncryptedPacket>( | 123 return scoped_ptr<QuicEncryptedPacket>( |
123 ConstructPacket(header, QuicFrame(&close))); | 124 ConstructPacket(header, QuicFrame(&close))); |
124 } | 125 } |
125 | 126 |
126 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( | 127 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( |
127 QuicPacketSequenceNumber largest_received, | 128 QuicPacketSequenceNumber largest_received, |
128 QuicPacketSequenceNumber least_unacked) { | 129 QuicPacketSequenceNumber least_unacked) { |
129 QuicPacketHeader header; | 130 QuicPacketHeader header; |
130 header.public_header.guid = 0xDEADBEEF; | 131 header.public_header.guid = random_generator_.RandUint64(); |
131 header.public_header.reset_flag = false; | 132 header.public_header.reset_flag = false; |
132 header.public_header.version_flag = false; | 133 header.public_header.version_flag = false; |
133 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 134 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
134 header.packet_sequence_number = 2; | 135 header.packet_sequence_number = 2; |
135 header.entropy_flag = false; | 136 header.entropy_flag = false; |
136 header.fec_flag = false; | 137 header.fec_flag = false; |
137 header.fec_group = 0; | 138 header.fec_group = 0; |
138 | 139 |
139 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); | 140 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); |
140 | 141 |
(...skipping 707 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
848 SendRequestAndExpectHttpResponse("hello from http"); | 849 SendRequestAndExpectHttpResponse("hello from http"); |
849 | 850 |
850 ExpectBrokenAlternateProtocolMapping(); | 851 ExpectBrokenAlternateProtocolMapping(); |
851 | 852 |
852 EXPECT_TRUE(quic_data.at_read_eof()); | 853 EXPECT_TRUE(quic_data.at_read_eof()); |
853 EXPECT_TRUE(quic_data.at_write_eof()); | 854 EXPECT_TRUE(quic_data.at_write_eof()); |
854 } | 855 } |
855 | 856 |
856 } // namespace test | 857 } // namespace test |
857 } // namespace net | 858 } // namespace net |
OLD | NEW |