OLD | NEW |
---|---|
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/test_tools/quic_test_packet_maker.h" | 5 #include "net/quic/test_tools/quic_test_packet_maker.h" |
6 | 6 |
7 #include <list> | 7 #include <list> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/memory/ptr_util.h" | 10 #include "base/memory/ptr_util.h" |
(...skipping 346 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
357 QuicTestPacketMaker::MakeRequestHeadersAndMultipleDataFramesPacket( | 357 QuicTestPacketMaker::MakeRequestHeadersAndMultipleDataFramesPacket( |
358 QuicPacketNumber packet_number, | 358 QuicPacketNumber packet_number, |
359 QuicStreamId stream_id, | 359 QuicStreamId stream_id, |
360 bool should_include_version, | 360 bool should_include_version, |
361 bool fin, | 361 bool fin, |
362 SpdyPriority priority, | 362 SpdyPriority priority, |
363 SpdyHeaderBlock headers, | 363 SpdyHeaderBlock headers, |
364 size_t* spdy_headers_frame_length, | 364 size_t* spdy_headers_frame_length, |
365 const std::vector<std::string>& data_writes) { | 365 const std::vector<std::string>& data_writes) { |
366 InitializeHeader(packet_number, should_include_version); | 366 InitializeHeader(packet_number, should_include_version); |
367 SpdySerializedFrame spdy_frame; | 367 SpdySerializedFrame spdy_frame; |
Bence
2016/11/21 17:50:45
Could you please combine this line with assignment
| |
368 if (spdy_request_framer_.protocol_version() == SPDY3) { | 368 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); |
369 SpdySynStreamIR syn_stream(stream_id, std::move(headers)); | 369 headers_frame.set_fin(fin); |
370 syn_stream.set_fin(fin); | 370 headers_frame.set_weight(Spdy3PriorityToHttp2Weight(priority)); |
371 syn_stream.set_priority(priority); | 371 headers_frame.set_has_priority(true); |
372 spdy_frame = spdy_request_framer_.SerializeSynStream(syn_stream); | 372 spdy_frame = spdy_request_framer_.SerializeFrame(headers_frame); |
373 } else { | 373 |
374 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); | |
375 headers_frame.set_fin(fin); | |
376 headers_frame.set_weight(Spdy3PriorityToHttp2Weight(priority)); | |
377 headers_frame.set_has_priority(true); | |
378 spdy_frame = spdy_request_framer_.SerializeFrame(headers_frame); | |
379 } | |
380 if (spdy_headers_frame_length) { | 374 if (spdy_headers_frame_length) { |
381 *spdy_headers_frame_length = spdy_frame.size(); | 375 *spdy_headers_frame_length = spdy_frame.size(); |
382 } | 376 } |
383 QuicStreamFrame frame( | 377 QuicStreamFrame frame( |
384 kHeadersStreamId, false, 0, | 378 kHeadersStreamId, false, 0, |
385 base::StringPiece(spdy_frame.data(), spdy_frame.size())); | 379 base::StringPiece(spdy_frame.data(), spdy_frame.size())); |
386 | 380 |
387 QuicFrames frames; | 381 QuicFrames frames; |
388 frames.push_back(QuicFrame(&frame)); | 382 frames.push_back(QuicFrame(&frame)); |
389 | 383 |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
425 QuicTestPacketMaker::MakeRequestHeadersPacket(QuicPacketNumber packet_number, | 419 QuicTestPacketMaker::MakeRequestHeadersPacket(QuicPacketNumber packet_number, |
426 QuicStreamId stream_id, | 420 QuicStreamId stream_id, |
427 bool should_include_version, | 421 bool should_include_version, |
428 bool fin, | 422 bool fin, |
429 SpdyPriority priority, | 423 SpdyPriority priority, |
430 SpdyHeaderBlock headers, | 424 SpdyHeaderBlock headers, |
431 size_t* spdy_headers_frame_length, | 425 size_t* spdy_headers_frame_length, |
432 QuicStreamOffset* offset) { | 426 QuicStreamOffset* offset) { |
433 InitializeHeader(packet_number, should_include_version); | 427 InitializeHeader(packet_number, should_include_version); |
434 SpdySerializedFrame spdy_frame; | 428 SpdySerializedFrame spdy_frame; |
435 if (spdy_request_framer_.protocol_version() == SPDY3) { | 429 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); |
436 SpdySynStreamIR syn_stream(stream_id, std::move(headers)); | 430 headers_frame.set_fin(fin); |
437 syn_stream.set_fin(fin); | 431 headers_frame.set_weight(Spdy3PriorityToHttp2Weight(priority)); |
438 syn_stream.set_priority(priority); | 432 headers_frame.set_has_priority(true); |
439 spdy_frame = spdy_request_framer_.SerializeSynStream(syn_stream); | 433 spdy_frame = spdy_request_framer_.SerializeFrame(headers_frame); |
440 } else { | 434 |
441 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); | |
442 headers_frame.set_fin(fin); | |
443 headers_frame.set_weight(Spdy3PriorityToHttp2Weight(priority)); | |
444 headers_frame.set_has_priority(true); | |
445 spdy_frame = spdy_request_framer_.SerializeFrame(headers_frame); | |
446 } | |
447 if (spdy_headers_frame_length) { | 435 if (spdy_headers_frame_length) { |
448 *spdy_headers_frame_length = spdy_frame.size(); | 436 *spdy_headers_frame_length = spdy_frame.size(); |
449 } | 437 } |
450 if (offset != nullptr) { | 438 if (offset != nullptr) { |
451 QuicStreamFrame frame( | 439 QuicStreamFrame frame( |
452 kHeadersStreamId, false, *offset, | 440 kHeadersStreamId, false, *offset, |
453 base::StringPiece(spdy_frame.data(), spdy_frame.size())); | 441 base::StringPiece(spdy_frame.data(), spdy_frame.size())); |
454 *offset += spdy_frame.size(); | 442 *offset += spdy_frame.size(); |
455 return MakePacket(header_, QuicFrame(&frame)); | 443 return MakePacket(header_, QuicFrame(&frame)); |
456 } else { | 444 } else { |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
536 QuicTestPacketMaker::MakeResponseHeadersPacket( | 524 QuicTestPacketMaker::MakeResponseHeadersPacket( |
537 QuicPacketNumber packet_number, | 525 QuicPacketNumber packet_number, |
538 QuicStreamId stream_id, | 526 QuicStreamId stream_id, |
539 bool should_include_version, | 527 bool should_include_version, |
540 bool fin, | 528 bool fin, |
541 SpdyHeaderBlock headers, | 529 SpdyHeaderBlock headers, |
542 size_t* spdy_headers_frame_length, | 530 size_t* spdy_headers_frame_length, |
543 QuicStreamOffset* offset) { | 531 QuicStreamOffset* offset) { |
544 InitializeHeader(packet_number, should_include_version); | 532 InitializeHeader(packet_number, should_include_version); |
545 SpdySerializedFrame spdy_frame; | 533 SpdySerializedFrame spdy_frame; |
546 if (spdy_response_framer_.protocol_version() == SPDY3) { | 534 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); |
547 SpdySynReplyIR syn_reply(stream_id, std::move(headers)); | 535 headers_frame.set_fin(fin); |
548 syn_reply.set_fin(fin); | 536 spdy_frame = spdy_response_framer_.SerializeFrame(headers_frame); |
549 spdy_frame = spdy_response_framer_.SerializeSynReply(syn_reply); | 537 |
550 } else { | |
551 SpdyHeadersIR headers_frame(stream_id, std::move(headers)); | |
552 headers_frame.set_fin(fin); | |
553 spdy_frame = spdy_response_framer_.SerializeFrame(headers_frame); | |
554 } | |
555 if (spdy_headers_frame_length) { | 538 if (spdy_headers_frame_length) { |
556 *spdy_headers_frame_length = spdy_frame.size(); | 539 *spdy_headers_frame_length = spdy_frame.size(); |
557 } | 540 } |
558 if (offset != nullptr) { | 541 if (offset != nullptr) { |
559 QuicStreamFrame frame( | 542 QuicStreamFrame frame( |
560 kHeadersStreamId, false, *offset, | 543 kHeadersStreamId, false, *offset, |
561 base::StringPiece(spdy_frame.data(), spdy_frame.size())); | 544 base::StringPiece(spdy_frame.data(), spdy_frame.size())); |
562 *offset += spdy_frame.size(); | 545 *offset += spdy_frame.size(); |
563 return MakePacket(header_, QuicFrame(&frame)); | 546 return MakePacket(header_, QuicFrame(&frame)); |
564 } else { | 547 } else { |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
655 header_.public_header.connection_id = connection_id_; | 638 header_.public_header.connection_id = connection_id_; |
656 header_.public_header.reset_flag = false; | 639 header_.public_header.reset_flag = false; |
657 header_.public_header.version_flag = should_include_version; | 640 header_.public_header.version_flag = should_include_version; |
658 header_.public_header.packet_number_length = PACKET_1BYTE_PACKET_NUMBER; | 641 header_.public_header.packet_number_length = PACKET_1BYTE_PACKET_NUMBER; |
659 header_.packet_number = packet_number; | 642 header_.packet_number = packet_number; |
660 header_.entropy_flag = false; | 643 header_.entropy_flag = false; |
661 } | 644 } |
662 | 645 |
663 } // namespace test | 646 } // namespace test |
664 } // namespace net | 647 } // namespace net |
OLD | NEW |