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/chromium/quic_http_stream.h" | 5 #include "net/quic/chromium/quic_http_stream.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <utility> | 10 #include <utility> |
(...skipping 447 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
458 SpdyHeaderBlock trailers, | 458 SpdyHeaderBlock trailers, |
459 size_t* spdy_headers_frame_length, | 459 size_t* spdy_headers_frame_length, |
460 QuicStreamOffset* offset) { | 460 QuicStreamOffset* offset) { |
461 return server_maker_.MakeResponseHeadersPacket( | 461 return server_maker_.MakeResponseHeadersPacket( |
462 packet_number, stream_id_, !kIncludeVersion, fin, std::move(trailers), | 462 packet_number, stream_id_, !kIncludeVersion, fin, std::move(trailers), |
463 spdy_headers_frame_length, offset); | 463 spdy_headers_frame_length, offset); |
464 } | 464 } |
465 | 465 |
466 std::unique_ptr<QuicReceivedPacket> ConstructClientRstStreamPacket( | 466 std::unique_ptr<QuicReceivedPacket> ConstructClientRstStreamPacket( |
467 QuicPacketNumber packet_number) { | 467 QuicPacketNumber packet_number) { |
468 return client_maker_.MakeRstPacket( | 468 return client_maker_.MakeRstPacket(packet_number, true, stream_id_, |
469 packet_number, true, stream_id_, | 469 QUIC_RST_ACKNOWLEDGEMENT); |
470 AdjustErrorForVersion(QUIC_RST_ACKNOWLEDGEMENT, GetParam())); | |
471 } | 470 } |
472 | 471 |
473 std::unique_ptr<QuicReceivedPacket> ConstructClientRstStreamCancelledPacket( | 472 std::unique_ptr<QuicReceivedPacket> ConstructClientRstStreamCancelledPacket( |
474 QuicPacketNumber packet_number) { | 473 QuicPacketNumber packet_number) { |
475 return client_maker_.MakeRstPacket(packet_number, !kIncludeVersion, | 474 return client_maker_.MakeRstPacket(packet_number, !kIncludeVersion, |
476 stream_id_, QUIC_STREAM_CANCELLED); | 475 stream_id_, QUIC_STREAM_CANCELLED); |
477 } | 476 } |
478 | 477 |
479 std::unique_ptr<QuicReceivedPacket> | 478 std::unique_ptr<QuicReceivedPacket> |
480 ConstructClientRstStreamVaryMismatchPacket(QuicPacketNumber packet_number) { | 479 ConstructClientRstStreamVaryMismatchPacket(QuicPacketNumber packet_number) { |
(...skipping 1579 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2060 EXPECT_TRUE(AtEof()); | 2059 EXPECT_TRUE(AtEof()); |
2061 | 2060 |
2062 // QuicHttpStream::GetTotalSent/ReceivedBytes includes only headers. | 2061 // QuicHttpStream::GetTotalSent/ReceivedBytes includes only headers. |
2063 EXPECT_EQ(static_cast<int64_t>(spdy_request_headers_frame_length), | 2062 EXPECT_EQ(static_cast<int64_t>(spdy_request_headers_frame_length), |
2064 stream_->GetTotalSentBytes()); | 2063 stream_->GetTotalSentBytes()); |
2065 EXPECT_EQ(0, stream_->GetTotalReceivedBytes()); | 2064 EXPECT_EQ(0, stream_->GetTotalReceivedBytes()); |
2066 } | 2065 } |
2067 | 2066 |
2068 } // namespace test | 2067 } // namespace test |
2069 } // namespace net | 2068 } // namespace net |
OLD | NEW |