| 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 |