| Index: net/quic/reliable_quic_stream_test.cc
|
| diff --git a/net/quic/reliable_quic_stream_test.cc b/net/quic/reliable_quic_stream_test.cc
|
| index 389d910a020f4c448320f4cec89af78eed5f2dde..3b47362050dc18a26693f0bbd08aa56823f125e0 100644
|
| --- a/net/quic/reliable_quic_stream_test.cc
|
| +++ b/net/quic/reliable_quic_stream_test.cc
|
| @@ -134,7 +134,7 @@ TEST_F(ReliableQuicStreamTest, WriteAllData) {
|
| 1 + QuicPacketCreator::StreamFramePacketOverhead(
|
| connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion,
|
| PACKET_6BYTE_SEQUENCE_NUMBER, NOT_IN_FEC_GROUP);
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(kDataLen, true)));
|
| stream_->WriteOrBufferData(kData1, false);
|
| EXPECT_FALSE(write_blocked_list_->HasWriteBlockedStreams());
|
| @@ -154,7 +154,7 @@ TEST_F(ReliableQuicStreamTest, BlockIfOnlySomeDataConsumed) {
|
|
|
| // Write some data and no fin. If we consume some but not all of the data,
|
| // we should be write blocked a not all the data was consumed.
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(1, false)));
|
| stream_->WriteOrBufferData(StringPiece(kData1, 2), false);
|
| ASSERT_EQ(1u, write_blocked_list_->NumBlockedStreams());
|
| @@ -168,7 +168,7 @@ TEST_F(ReliableQuicStreamTest, BlockIfFinNotConsumedWithData) {
|
| // we should be write blocked because the fin was not consumed.
|
| // (This should never actually happen as the fin should be sent out with the
|
| // last data)
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(2, false)));
|
| stream_->WriteOrBufferData(StringPiece(kData1, 2), true);
|
| ASSERT_EQ(1u, write_blocked_list_->NumBlockedStreams());
|
| @@ -179,7 +179,7 @@ TEST_F(ReliableQuicStreamTest, BlockIfSoloFinNotConsumed) {
|
|
|
| // Write no data and a fin. If we consume nothing we should be write blocked,
|
| // as the fin was not consumed.
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(0, false)));
|
| stream_->WriteOrBufferData(StringPiece(), true);
|
| ASSERT_EQ(1u, write_blocked_list_->NumBlockedStreams());
|
| @@ -193,7 +193,7 @@ TEST_F(ReliableQuicStreamTest, WriteOrBufferData) {
|
| 1 + QuicPacketCreator::StreamFramePacketOverhead(
|
| connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion,
|
| PACKET_6BYTE_SEQUENCE_NUMBER, NOT_IN_FEC_GROUP);
|
| - EXPECT_CALL(*session_, WritevData(_, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(_, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(kDataLen - 1, false)));
|
| stream_->WriteOrBufferData(kData1, false);
|
| EXPECT_TRUE(write_blocked_list_->HasWriteBlockedStreams());
|
| @@ -203,14 +203,14 @@ TEST_F(ReliableQuicStreamTest, WriteOrBufferData) {
|
|
|
| // Make sure we get the tail of the first write followed by the bytes_consumed
|
| InSequence s;
|
| - EXPECT_CALL(*session_, WritevData(_, _, 1, _, _, _)).
|
| + EXPECT_CALL(*session_, WritevData(_, _, _, _, _)).
|
| WillOnce(Return(QuicConsumedData(1, false)));
|
| - EXPECT_CALL(*session_, WritevData(_, _, 1, _, _, _)).
|
| + EXPECT_CALL(*session_, WritevData(_, _, _, _, _)).
|
| WillOnce(Return(QuicConsumedData(kDataLen - 2, false)));
|
| stream_->OnCanWrite();
|
|
|
| // And finally the end of the bytes_consumed.
|
| - EXPECT_CALL(*session_, WritevData(_, _, 1, _, _, _)).
|
| + EXPECT_CALL(*session_, WritevData(_, _, _, _, _)).
|
| WillOnce(Return(QuicConsumedData(2, true)));
|
| stream_->OnCanWrite();
|
| }
|
| @@ -237,7 +237,7 @@ TEST_F(ReliableQuicStreamTest, RstAlwaysSentIfNoFinSent) {
|
| EXPECT_FALSE(rst_sent());
|
|
|
| // Write some data, with no FIN.
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(1, false)));
|
| stream_->WriteOrBufferData(StringPiece(kData1, 1), false);
|
| EXPECT_FALSE(fin_sent());
|
| @@ -260,7 +260,7 @@ TEST_F(ReliableQuicStreamTest, RstNotSentIfFinSent) {
|
| EXPECT_FALSE(rst_sent());
|
|
|
| // Write some data, with FIN.
|
| - EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce(
|
| + EXPECT_CALL(*session_, WritevData(kStreamId, _, _, _, _)).WillOnce(
|
| Return(QuicConsumedData(1, true)));
|
| stream_->WriteOrBufferData(StringPiece(kData1, 1), true);
|
| EXPECT_TRUE(fin_sent());
|
|
|