Index: net/quic/quic_http_stream_test.cc |
diff --git a/net/quic/quic_http_stream_test.cc b/net/quic/quic_http_stream_test.cc |
index a172c2486b56191e00135e16785da7c084209315..a22bb74f099a9b7ec501c497fd44e058ff469cdb 100644 |
--- a/net/quic/quic_http_stream_test.cc |
+++ b/net/quic/quic_http_stream_test.cc |
@@ -82,11 +82,6 @@ class TestQuicConnection : public QuicConnection { |
class TestReceiveAlgorithm : public ReceiveAlgorithmInterface { |
public: |
- virtual bool GenerateCongestionFeedback( |
- QuicCongestionFeedbackFrame* /*congestion_feedback*/) { |
- return false; |
- } |
- |
MOCK_METHOD3(RecordIncomingPacket, |
void(QuicByteCount, QuicPacketSequenceNumber, QuicTime)); |
}; |
@@ -265,15 +260,19 @@ class QuicHttpStreamTest : public ::testing::TestWithParam<QuicVersion> { |
bool fin, |
QuicStreamOffset offset, |
base::StringPiece data) { |
- return maker_.MakeDataPacket( |
- sequence_number, stream_id_, should_include_version, fin, offset, data); |
+ return maker_.MakeDataPacket(sequence_number, stream_id_, |
+ should_include_version, fin, offset, data); |
} |
scoped_ptr<QuicEncryptedPacket> ConstructRequestHeadersPacket( |
QuicPacketSequenceNumber sequence_number, |
- bool fin) { |
- return maker_.MakeRequestHeadersPacket( |
- sequence_number, stream_id_, kIncludeVersion, fin, request_headers_); |
+ bool fin, |
+ RequestPriority request_priority) { |
+ QuicPriority priority = |
+ ConvertRequestPriorityToQuicPriority(request_priority); |
+ return maker_.MakeRequestHeadersPacket(sequence_number, stream_id_, |
+ kIncludeVersion, fin, priority, |
+ request_headers_); |
} |
scoped_ptr<QuicEncryptedPacket> ConstructResponseHeadersPacket( |
@@ -361,7 +360,7 @@ TEST_P(QuicHttpStreamTest, IsConnectionReusable) { |
TEST_P(QuicHttpStreamTest, GetRequest) { |
SetRequest("GET", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, kFin, DEFAULT_PRIORITY)); |
Initialize(); |
request_.method = "GET"; |
@@ -400,7 +399,7 @@ TEST_P(QuicHttpStreamTest, GetRequest) { |
// Regression test for http://crbug.com/288128 |
TEST_P(QuicHttpStreamTest, GetRequestLargeResponse) { |
SetRequest("GET", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, kFin, DEFAULT_PRIORITY)); |
Initialize(); |
request_.method = "GET"; |
@@ -463,7 +462,7 @@ TEST_P(QuicHttpStreamTest, SessionClosedBeforeSendRequest) { |
// Regression test for http://crbug.com/409871 |
TEST_P(QuicHttpStreamTest, SessionClosedBeforeReadResponseHeaders) { |
SetRequest("GET", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, kFin, DEFAULT_PRIORITY)); |
Initialize(); |
request_.method = "GET"; |
@@ -482,7 +481,7 @@ TEST_P(QuicHttpStreamTest, SessionClosedBeforeReadResponseHeaders) { |
TEST_P(QuicHttpStreamTest, SendPostRequest) { |
SetRequest("POST", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, !kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, !kFin, DEFAULT_PRIORITY)); |
AddWrite(ConstructDataPacket(2, kIncludeVersion, kFin, 0, kUploadData)); |
AddWrite(ConstructAckPacket(3, 3, 1)); |
@@ -530,7 +529,7 @@ TEST_P(QuicHttpStreamTest, SendPostRequest) { |
TEST_P(QuicHttpStreamTest, SendChunkedPostRequest) { |
SetRequest("POST", "/", DEFAULT_PRIORITY); |
size_t chunk_size = strlen(kUploadData); |
- AddWrite(ConstructRequestHeadersPacket(1, !kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, !kFin, DEFAULT_PRIORITY)); |
AddWrite(ConstructDataPacket(2, kIncludeVersion, !kFin, 0, kUploadData)); |
AddWrite(ConstructDataPacket(3, kIncludeVersion, kFin, chunk_size, |
kUploadData)); |
@@ -583,7 +582,7 @@ TEST_P(QuicHttpStreamTest, SendChunkedPostRequest) { |
TEST_P(QuicHttpStreamTest, SendChunkedPostRequestWithFinalEmptyDataPacket) { |
SetRequest("POST", "/", DEFAULT_PRIORITY); |
size_t chunk_size = strlen(kUploadData); |
- AddWrite(ConstructRequestHeadersPacket(1, !kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, !kFin, DEFAULT_PRIORITY)); |
AddWrite(ConstructDataPacket(2, kIncludeVersion, !kFin, 0, kUploadData)); |
AddWrite(ConstructDataPacket(3, kIncludeVersion, kFin, chunk_size, "")); |
AddWrite(ConstructAckPacket(4, 3, 1)); |
@@ -633,7 +632,7 @@ TEST_P(QuicHttpStreamTest, SendChunkedPostRequestWithFinalEmptyDataPacket) { |
TEST_P(QuicHttpStreamTest, SendChunkedPostRequestWithOneEmptyDataPacket) { |
SetRequest("POST", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, !kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, !kFin, DEFAULT_PRIORITY)); |
AddWrite(ConstructDataPacket(2, kIncludeVersion, kFin, 0, "")); |
AddWrite(ConstructAckPacket(3, 3, 1)); |
Initialize(); |
@@ -681,7 +680,7 @@ TEST_P(QuicHttpStreamTest, SendChunkedPostRequestWithOneEmptyDataPacket) { |
TEST_P(QuicHttpStreamTest, DestroyedEarly) { |
SetRequest("GET", "/", DEFAULT_PRIORITY); |
- AddWrite(ConstructRequestHeadersPacket(1, kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, kFin, DEFAULT_PRIORITY)); |
AddWrite(ConstructAckAndRstStreamPacket(2)); |
use_closing_stream_ = true; |
Initialize(); |
@@ -709,7 +708,7 @@ TEST_P(QuicHttpStreamTest, DestroyedEarly) { |
TEST_P(QuicHttpStreamTest, Priority) { |
SetRequest("GET", "/", MEDIUM); |
- AddWrite(ConstructRequestHeadersPacket(1, kFin)); |
+ AddWrite(ConstructRequestHeadersPacket(1, kFin, MEDIUM)); |
AddWrite(ConstructAckAndRstStreamPacket(2)); |
use_closing_stream_ = true; |
Initialize(); |