| 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 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 134 header.fec_flag = false; | 134 header.fec_flag = false; |
| 135 header.fec_group = 0; | 135 header.fec_group = 0; |
| 136 | 136 |
| 137 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); | 137 QuicAckFrame ack(largest_received, QuicTime::Zero(), least_unacked); |
| 138 | 138 |
| 139 QuicCongestionFeedbackFrame feedback; | 139 QuicCongestionFeedbackFrame feedback; |
| 140 feedback.type = kTCP; | 140 feedback.type = kTCP; |
| 141 feedback.tcp.accumulated_number_of_lost_packets = 0; | 141 feedback.tcp.accumulated_number_of_lost_packets = 0; |
| 142 feedback.tcp.receive_window = 256000; | 142 feedback.tcp.receive_window = 256000; |
| 143 | 143 |
| 144 QuicFramer framer(kQuicVersion1, QuicTime::Zero(), false); | 144 QuicFramer framer(QuicVersionMax(), QuicTime::Zero(), false); |
| 145 QuicFrames frames; | 145 QuicFrames frames; |
| 146 frames.push_back(QuicFrame(&ack)); | 146 frames.push_back(QuicFrame(&ack)); |
| 147 frames.push_back(QuicFrame(&feedback)); | 147 frames.push_back(QuicFrame(&feedback)); |
| 148 scoped_ptr<QuicPacket> packet( | 148 scoped_ptr<QuicPacket> packet( |
| 149 framer.ConstructFrameDataPacket(header, frames).packet); | 149 framer.ConstructFrameDataPacket(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 std::string GetRequestString(const std::string& method, | 154 std::string GetRequestString(const std::string& method, |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 186 QuicStreamOffset offset, | 186 QuicStreamOffset offset, |
| 187 base::StringPiece data) { | 187 base::StringPiece data) { |
| 188 InitializeHeader(sequence_number, should_include_version); | 188 InitializeHeader(sequence_number, should_include_version); |
| 189 QuicStreamFrame frame(stream_id, fin, offset, data); | 189 QuicStreamFrame frame(stream_id, fin, offset, data); |
| 190 return ConstructPacket(header_, QuicFrame(&frame)).release(); | 190 return ConstructPacket(header_, QuicFrame(&frame)).release(); |
| 191 } | 191 } |
| 192 | 192 |
| 193 scoped_ptr<QuicEncryptedPacket> ConstructPacket( | 193 scoped_ptr<QuicEncryptedPacket> ConstructPacket( |
| 194 const QuicPacketHeader& header, | 194 const QuicPacketHeader& header, |
| 195 const QuicFrame& frame) { | 195 const QuicFrame& frame) { |
| 196 QuicFramer framer(kQuicVersion1, QuicTime::Zero(), false); | 196 QuicFramer framer(QuicVersionMax(), QuicTime::Zero(), false); |
| 197 QuicFrames frames; | 197 QuicFrames frames; |
| 198 frames.push_back(frame); | 198 frames.push_back(frame); |
| 199 scoped_ptr<QuicPacket> packet( | 199 scoped_ptr<QuicPacket> packet( |
| 200 framer.ConstructFrameDataPacket(header, frames).packet); | 200 framer.ConstructFrameDataPacket(header, frames).packet); |
| 201 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( | 201 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( |
| 202 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); | 202 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); |
| 203 } | 203 } |
| 204 | 204 |
| 205 void InitializeHeader(QuicPacketSequenceNumber sequence_number, | 205 void InitializeHeader(QuicPacketSequenceNumber sequence_number, |
| 206 bool should_include_version) { | 206 bool should_include_version) { |
| (...skipping 536 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 743 | 743 |
| 744 CreateSession(); | 744 CreateSession(); |
| 745 | 745 |
| 746 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); | 746 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); |
| 747 SendRequestAndExpectHttpResponse("hello from http"); | 747 SendRequestAndExpectHttpResponse("hello from http"); |
| 748 ExpectBrokenAlternateProtocolMapping(); | 748 ExpectBrokenAlternateProtocolMapping(); |
| 749 } | 749 } |
| 750 | 750 |
| 751 } // namespace test | 751 } // namespace test |
| 752 } // namespace net | 752 } // namespace net |
| OLD | NEW |