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