Chromium Code Reviews| 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 |