Index: net/tools/quic/quic_simple_server_stream_test.cc |
diff --git a/net/tools/quic/quic_simple_server_stream_test.cc b/net/tools/quic/quic_simple_server_stream_test.cc |
index 91b8adad8119969de40392d65afcb4c4cab077a9..32775745692ed3395f60f3be0902e9b4a3f094ee 100644 |
--- a/net/tools/quic/quic_simple_server_stream_test.cc |
+++ b/net/tools/quic/quic_simple_server_stream_test.cc |
@@ -93,7 +93,7 @@ class MockQuicSimpleServerSession : public QuicSimpleServerSession { |
crypto_config) { |
set_max_open_incoming_streams(kMaxStreamsForTest); |
set_max_open_outgoing_streams(kMaxStreamsForTest); |
- ON_CALL(*this, WritevData(_, _, _, _, _, _)) |
+ ON_CALL(*this, WritevData(_, _, _, _, _)) |
.WillByDefault(testing::Return(QuicConsumedData(0, false))); |
} |
@@ -102,12 +102,11 @@ class MockQuicSimpleServerSession : public QuicSimpleServerSession { |
MOCK_METHOD2(OnConnectionClosed, |
void(QuicErrorCode error, ConnectionCloseSource source)); |
MOCK_METHOD1(CreateIncomingDynamicStream, QuicSpdyStream*(QuicStreamId id)); |
- MOCK_METHOD6(WritevData, |
+ MOCK_METHOD5(WritevData, |
QuicConsumedData(QuicStreamId id, |
QuicIOVector data, |
QuicStreamOffset offset, |
bool fin, |
- FecProtection fec_protection, |
QuicAckListenerInterface*)); |
MOCK_METHOD2(OnStreamHeaders, |
void(QuicStreamId stream_id, StringPiece headers_data)); |
@@ -209,7 +208,7 @@ INSTANTIATE_TEST_CASE_P(Tests, |
::testing::ValuesIn(QuicSupportedVersions())); |
TEST_P(QuicSimpleServerStreamTest, TestFraming) { |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(AnyNumber()) |
.WillRepeatedly(Invoke(MockQuicSpdySession::ConsumeAllData)); |
stream_->OnStreamHeaders(headers_string_); |
@@ -223,7 +222,7 @@ TEST_P(QuicSimpleServerStreamTest, TestFraming) { |
} |
TEST_P(QuicSimpleServerStreamTest, TestFramingOnePacket) { |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(AnyNumber()) |
.WillRepeatedly(Invoke(MockQuicSpdySession::ConsumeAllData)); |
@@ -238,7 +237,7 @@ TEST_P(QuicSimpleServerStreamTest, TestFramingOnePacket) { |
} |
TEST_P(QuicSimpleServerStreamTest, SendQuicRstStreamNoErrorInStopReading) { |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(AnyNumber()) |
.WillRepeatedly(Invoke(MockQuicSpdySession::ConsumeAllData)); |
@@ -261,7 +260,7 @@ TEST_P(QuicSimpleServerStreamTest, TestFramingExtraData) { |
// We'll automatically write out an error (headers + body) |
EXPECT_CALL(session_, WriteHeaders(_, _, _, _, _)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.WillOnce(Invoke(MockQuicSpdySession::ConsumeAllData)); |
EXPECT_CALL(session_, SendRstStream(_, QUIC_STREAM_NO_ERROR, _)).Times(0); |
@@ -298,7 +297,7 @@ TEST_P(QuicSimpleServerStreamTest, SendResponseWithIllegalResponseStatus) { |
InSequence s; |
EXPECT_CALL(session_, WriteHeaders(stream_->id(), _, false, _, nullptr)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData( |
strlen(QuicSimpleServerStream::kErrorResponseBody), true))); |
@@ -355,7 +354,7 @@ TEST_P(QuicSimpleServerStreamTest, SendResponseWithValidHeaders) { |
InSequence s; |
EXPECT_CALL(session_, WriteHeaders(stream_->id(), _, false, _, nullptr)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData(body.length(), true))); |
@@ -394,7 +393,7 @@ TEST_P(QuicSimpleServerStreamTest, SendReponseWithPushResources) { |
::net::test::kClientDataStreamId1, |
*request_headers)); |
EXPECT_CALL(session_, WriteHeaders(stream_->id(), _, false, _, nullptr)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData(body.length(), true))); |
QuicSimpleServerStreamPeer::SendResponse(stream_); |
@@ -440,7 +439,7 @@ TEST_P(QuicSimpleServerStreamTest, PushResponseOnServerInitiatedStream) { |
EXPECT_CALL(session_, |
WriteHeaders(kServerInitiatedStreamId, _, false, |
server_initiated_stream->priority(), nullptr)); |
- EXPECT_CALL(session_, WritevData(kServerInitiatedStreamId, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(kServerInitiatedStreamId, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData(kBody.size(), true))); |
server_initiated_stream->PushResponse(headers); |
@@ -462,7 +461,7 @@ TEST_P(QuicSimpleServerStreamTest, TestSendErrorResponse) { |
InSequence s; |
EXPECT_CALL(session_, WriteHeaders(_, _, _, _, _)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData(3, true))); |
@@ -482,7 +481,7 @@ TEST_P(QuicSimpleServerStreamTest, InvalidMultipleContentLength) { |
headers_string_ = SpdyUtils::SerializeUncompressedHeaders(request_headers); |
EXPECT_CALL(session_, WriteHeaders(_, _, _, _, _)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(AnyNumber()) |
.WillRepeatedly(Invoke(MockQuicSpdySession::ConsumeAllData)); |
stream_->OnStreamHeaders(headers_string_); |
@@ -503,7 +502,7 @@ TEST_P(QuicSimpleServerStreamTest, InvalidLeadingNullContentLength) { |
headers_string_ = SpdyUtils::SerializeUncompressedHeaders(request_headers); |
EXPECT_CALL(session_, WriteHeaders(_, _, _, _, _)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(AnyNumber()) |
.WillRepeatedly(Invoke(MockQuicSpdySession::ConsumeAllData)); |
stream_->OnStreamHeaders(headers_string_); |
@@ -537,7 +536,7 @@ TEST_P(QuicSimpleServerStreamTest, SendQuicRstStreamNoErrorWithEarlyResponse) { |
InSequence s; |
EXPECT_CALL(session_, WriteHeaders(stream_->id(), _, _, _, _)); |
- EXPECT_CALL(session_, WritevData(_, _, _, _, _, _)) |
+ EXPECT_CALL(session_, WritevData(_, _, _, _, _)) |
.Times(1) |
.WillOnce(Return(QuicConsumedData(3, true))); |
if (GetParam() > QUIC_VERSION_28) { |