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_http_stream.h" | 5 #include "net/quic/quic_http_stream.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "net/base/chunked_upload_data_stream.h" | 9 #include "net/base/chunked_upload_data_stream.h" |
10 #include "net/base/elements_upload_data_stream.h" | 10 #include "net/base/elements_upload_data_stream.h" |
(...skipping 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
258 response_headers_ = maker_.GetResponseHeaders(status); | 258 response_headers_ = maker_.GetResponseHeaders(status); |
259 response_data_ = body; | 259 response_data_ = body; |
260 } | 260 } |
261 | 261 |
262 scoped_ptr<QuicEncryptedPacket> ConstructDataPacket( | 262 scoped_ptr<QuicEncryptedPacket> ConstructDataPacket( |
263 QuicPacketSequenceNumber sequence_number, | 263 QuicPacketSequenceNumber sequence_number, |
264 bool should_include_version, | 264 bool should_include_version, |
265 bool fin, | 265 bool fin, |
266 QuicStreamOffset offset, | 266 QuicStreamOffset offset, |
267 base::StringPiece data) { | 267 base::StringPiece data) { |
268 return maker_.MakeDataPacket( | 268 return maker_.MakeDataPacket(sequence_number, stream_id_, |
269 sequence_number, stream_id_, should_include_version, fin, offset, data); | 269 should_include_version, fin, offset, data); |
270 } | 270 } |
271 | 271 |
272 scoped_ptr<QuicEncryptedPacket> ConstructRequestHeadersPacket( | 272 scoped_ptr<QuicEncryptedPacket> ConstructRequestHeadersPacket( |
273 QuicPacketSequenceNumber sequence_number, | 273 QuicPacketSequenceNumber sequence_number, |
274 bool fin) { | 274 bool fin) { |
275 return maker_.MakeRequestHeadersPacket( | 275 return maker_.MakeRequestHeadersPacket( |
276 sequence_number, stream_id_, kIncludeVersion, fin, request_headers_); | 276 sequence_number, stream_id_, PACKET_8BYTE_CONNECTION_ID, |
| 277 kIncludeVersion, fin, request_headers_); |
277 } | 278 } |
278 | 279 |
279 scoped_ptr<QuicEncryptedPacket> ConstructResponseHeadersPacket( | 280 scoped_ptr<QuicEncryptedPacket> ConstructResponseHeadersPacket( |
280 QuicPacketSequenceNumber sequence_number, | 281 QuicPacketSequenceNumber sequence_number, |
281 bool fin) { | 282 bool fin) { |
282 return maker_.MakeResponseHeadersPacket( | 283 return maker_.MakeResponseHeadersPacket( |
283 sequence_number, stream_id_, !kIncludeVersion, fin, response_headers_); | 284 sequence_number, stream_id_, PACKET_0BYTE_CONNECTION_ID, |
| 285 !kIncludeVersion, fin, response_headers_); |
284 } | 286 } |
285 | 287 |
286 scoped_ptr<QuicEncryptedPacket> ConstructRstStreamPacket( | 288 scoped_ptr<QuicEncryptedPacket> ConstructRstStreamPacket( |
287 QuicPacketSequenceNumber sequence_number) { | 289 QuicPacketSequenceNumber sequence_number) { |
288 return maker_.MakeRstPacket( | 290 return maker_.MakeRstPacket( |
289 sequence_number, true, stream_id_, | 291 sequence_number, PACKET_8BYTE_CONNECTION_ID, true, stream_id_, |
290 AdjustErrorForVersion(QUIC_RST_ACKNOWLEDGEMENT, GetParam())); | 292 AdjustErrorForVersion(QUIC_RST_ACKNOWLEDGEMENT, GetParam())); |
291 } | 293 } |
292 | 294 |
293 scoped_ptr<QuicEncryptedPacket> ConstructAckAndRstStreamPacket( | 295 scoped_ptr<QuicEncryptedPacket> ConstructAckAndRstStreamPacket( |
294 QuicPacketSequenceNumber sequence_number) { | 296 QuicPacketSequenceNumber sequence_number) { |
295 return maker_.MakeAckAndRstPacket( | 297 return maker_.MakeAckAndRstPacket(sequence_number, !kIncludeVersion, |
296 sequence_number, !kIncludeVersion, stream_id_, QUIC_STREAM_CANCELLED, | 298 stream_id_, QUIC_STREAM_CANCELLED, 2, 1, |
297 2, 1, !kIncludeCongestionFeedback); | 299 !kIncludeCongestionFeedback); |
298 } | 300 } |
299 | 301 |
300 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( | 302 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( |
301 QuicPacketSequenceNumber sequence_number, | 303 QuicPacketSequenceNumber sequence_number, |
302 QuicPacketSequenceNumber largest_received, | 304 QuicPacketSequenceNumber largest_received, |
303 QuicPacketSequenceNumber least_unacked) { | 305 QuicPacketSequenceNumber least_unacked) { |
304 return maker_.MakeAckPacket(sequence_number, largest_received, | 306 return maker_.MakeAckPacket(sequence_number, PACKET_8BYTE_CONNECTION_ID, |
305 least_unacked, !kIncludeCongestionFeedback); | 307 largest_received, least_unacked, |
| 308 !kIncludeCongestionFeedback); |
306 } | 309 } |
307 | 310 |
308 BoundNetLog net_log_; | 311 BoundNetLog net_log_; |
309 bool use_closing_stream_; | 312 bool use_closing_stream_; |
310 MockSendAlgorithm* send_algorithm_; | 313 MockSendAlgorithm* send_algorithm_; |
311 TestReceiveAlgorithm* receive_algorithm_; | 314 TestReceiveAlgorithm* receive_algorithm_; |
312 scoped_refptr<TestTaskRunner> runner_; | 315 scoped_refptr<TestTaskRunner> runner_; |
313 scoped_ptr<MockWrite[]> mock_writes_; | 316 scoped_ptr<MockWrite[]> mock_writes_; |
314 MockClock clock_; | 317 MockClock clock_; |
315 TestQuicConnection* connection_; | 318 TestQuicConnection* connection_; |
(...skipping 458 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
774 // Set Delegate to nullptr and make sure EffectivePriority returns highest | 777 // Set Delegate to nullptr and make sure EffectivePriority returns highest |
775 // priority. | 778 // priority. |
776 reliable_stream->SetDelegate(nullptr); | 779 reliable_stream->SetDelegate(nullptr); |
777 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, | 780 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, |
778 reliable_stream->EffectivePriority()); | 781 reliable_stream->EffectivePriority()); |
779 reliable_stream->SetDelegate(delegate); | 782 reliable_stream->SetDelegate(delegate); |
780 } | 783 } |
781 | 784 |
782 } // namespace test | 785 } // namespace test |
783 } // namespace net | 786 } // namespace net |
OLD | NEW |