Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(67)

Side by Side Diff: net/quic/quic_http_stream_test.cc

Issue 804813010: QUIC - enabled FLAGS_allow_truncated_connection_ids_for_quic (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Enable FLAGS_allow_truncated_connection_ids_for_quic by default Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698