| 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 "net/quic/quic_stream_factory.h" | 5 #include "net/quic/quic_stream_factory.h" |
| 6 | 6 |
| 7 #include "base/run_loop.h" | 7 #include "base/run_loop.h" |
| 8 #include "base/strings/string_util.h" | 8 #include "base/strings/string_util.h" |
| 9 #include "net/cert/cert_verifier.h" | 9 #include "net/cert/cert_verifier.h" |
| 10 #include "net/dns/mock_host_resolver.h" | 10 #include "net/dns/mock_host_resolver.h" |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 101 header.entropy_flag = false; | 101 header.entropy_flag = false; |
| 102 header.fec_flag = false; | 102 header.fec_flag = false; |
| 103 header.fec_group = 0; | 103 header.fec_group = 0; |
| 104 | 104 |
| 105 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); | 105 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); |
| 106 QuicCongestionFeedbackFrame feedback; | 106 QuicCongestionFeedbackFrame feedback; |
| 107 feedback.type = kTCP; | 107 feedback.type = kTCP; |
| 108 feedback.tcp.accumulated_number_of_lost_packets = 0; | 108 feedback.tcp.accumulated_number_of_lost_packets = 0; |
| 109 feedback.tcp.receive_window = 16000; | 109 feedback.tcp.receive_window = 16000; |
| 110 | 110 |
| 111 QuicFramer framer(QuicVersionMax(), QuicTime::Zero(), false); | 111 QuicFramer framer(QuicSupportedVersions(), QuicTime::Zero(), false); |
| 112 QuicFrames frames; | 112 QuicFrames frames; |
| 113 frames.push_back(QuicFrame(&ack)); | 113 frames.push_back(QuicFrame(&ack)); |
| 114 frames.push_back(QuicFrame(&feedback)); | 114 frames.push_back(QuicFrame(&feedback)); |
| 115 scoped_ptr<QuicPacket> packet( | 115 scoped_ptr<QuicPacket> packet( |
| 116 framer.BuildUnsizedDataPacket(header, frames).packet); | 116 framer.BuildUnsizedDataPacket(header, frames).packet); |
| 117 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( | 117 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( |
| 118 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); | 118 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); |
| 119 } | 119 } |
| 120 | 120 |
| 121 // Returns a newly created packet to send congestion feedback data. | 121 // Returns a newly created packet to send congestion feedback data. |
| (...skipping 13 matching lines...) Expand all Loading... |
| 135 frame.tcp.accumulated_number_of_lost_packets = 0; | 135 frame.tcp.accumulated_number_of_lost_packets = 0; |
| 136 frame.tcp.receive_window = 16000; | 136 frame.tcp.receive_window = 16000; |
| 137 | 137 |
| 138 return scoped_ptr<QuicEncryptedPacket>( | 138 return scoped_ptr<QuicEncryptedPacket>( |
| 139 ConstructPacket(header, QuicFrame(&frame))); | 139 ConstructPacket(header, QuicFrame(&frame))); |
| 140 } | 140 } |
| 141 | 141 |
| 142 scoped_ptr<QuicEncryptedPacket> ConstructPacket( | 142 scoped_ptr<QuicEncryptedPacket> ConstructPacket( |
| 143 const QuicPacketHeader& header, | 143 const QuicPacketHeader& header, |
| 144 const QuicFrame& frame) { | 144 const QuicFrame& frame) { |
| 145 QuicFramer framer(QuicVersionMax(), QuicTime::Zero(), false); | 145 QuicFramer framer(QuicSupportedVersions(), QuicTime::Zero(), false); |
| 146 QuicFrames frames; | 146 QuicFrames frames; |
| 147 frames.push_back(frame); | 147 frames.push_back(frame); |
| 148 scoped_ptr<QuicPacket> packet( | 148 scoped_ptr<QuicPacket> packet( |
| 149 framer.BuildUnsizedDataPacket(header, frames).packet); | 149 framer.BuildUnsizedDataPacket(header, frames).packet); |
| 150 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( | 150 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( |
| 151 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); | 151 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); |
| 152 } | 152 } |
| 153 | 153 |
| 154 MockHostResolver host_resolver_; | 154 MockHostResolver host_resolver_; |
| 155 DeterministicMockClientSocketFactory socket_factory_; | 155 DeterministicMockClientSocketFactory socket_factory_; |
| (...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 478 QuicStreamFactoryPeer::GetOrCreateCryptoConfig(&factory_, | 478 QuicStreamFactoryPeer::GetOrCreateCryptoConfig(&factory_, |
| 479 host_port_proxy_pair2); | 479 host_port_proxy_pair2); |
| 480 DCHECK(crypto_config2); | 480 DCHECK(crypto_config2); |
| 481 QuicCryptoClientConfig::CachedState* cached2 = | 481 QuicCryptoClientConfig::CachedState* cached2 = |
| 482 crypto_config2->LookupOrCreate(host_port_proxy_pair2.first.host()); | 482 crypto_config2->LookupOrCreate(host_port_proxy_pair2.first.host()); |
| 483 EXPECT_EQ(cached1->source_address_token(), cached2->source_address_token()); | 483 EXPECT_EQ(cached1->source_address_token(), cached2->source_address_token()); |
| 484 } | 484 } |
| 485 | 485 |
| 486 } // namespace test | 486 } // namespace test |
| 487 } // namespace net | 487 } // namespace net |
| OLD | NEW |