Index: net/quic/core/quic_headers_stream_test.cc |
diff --git a/net/quic/core/quic_headers_stream_test.cc b/net/quic/core/quic_headers_stream_test.cc |
index cdb0ad594fa5ebe897657f2bc5eeee06164a370c..2a9f469ea22dab62799dbb526c6cfc3bb56a1470 100644 |
--- a/net/quic/core/quic_headers_stream_test.cc |
+++ b/net/quic/core/quic_headers_stream_test.cc |
@@ -260,13 +260,6 @@ class QuicHeadersStreamTest : public ::testing::TestWithParam<TestParamsTuple> { |
return QuicConsumedData(consumed, false); |
} |
- QuicConsumedData SaveIovShort(const QuicIOVector& data) { |
- const iovec* iov = data.iov; |
- int consumed = 1; |
- saved_data_.append(static_cast<char*>(iov[0].iov_base), consumed); |
- return QuicConsumedData(consumed, false); |
- } |
- |
QuicConsumedData SaveIovAndNotifyAckListener( |
const QuicIOVector& data, |
QuicAckListenerInterface* ack_listener) { |
@@ -634,6 +627,7 @@ TEST_P(QuicHeadersStreamTest, NonEmptyHeaderHOLBlockedTime) { |
} |
TEST_P(QuicHeadersStreamTest, ProcessLargeRawData) { |
+ headers_stream_->set_max_uncompressed_header_bytes(256 * 1024); |
// We want to create a frame that is more than the SPDY Framer's max control |
// frame size, which is 16K, but less than the HPACK decoders max decode |
// buffer size, which is 32K. |
@@ -999,68 +993,6 @@ TEST_P(QuicHeadersStreamTest, WritevStreamData) { |
} |
} |
-TEST_P(QuicHeadersStreamTest, WritevStreamDataFinOnly) { |
- FLAGS_quic_bugfix_fhol_writev_fin_only_v2 = true; |
- struct iovec iov; |
- string data; |
- |
- EXPECT_CALL(session_, |
- WritevData(headers_stream_, kHeadersStreamId, _, _, false, _)) |
- .WillOnce(WithArgs<2, 5>( |
- Invoke(this, &QuicHeadersStreamTest::SaveIovAndNotifyAckListener))); |
- |
- QuicConsumedData consumed_data = headers_stream_->WritevStreamData( |
- kClientDataStreamId1, MakeIOVector(data, &iov), 0, true, nullptr); |
- |
- EXPECT_EQ(consumed_data.bytes_consumed, 0u); |
- EXPECT_EQ(consumed_data.fin_consumed, true); |
-} |
- |
-TEST_P(QuicHeadersStreamTest, WritevStreamDataSendBlocked) { |
- FLAGS_quic_bugfix_fhol_writev_fin_only_v2 = true; |
- QuicStreamId id = kClientDataStreamId1; |
- QuicStreamOffset offset = 0; |
- struct iovec iov; |
- string data; |
- |
- // This test will issue a write that will require fragmenting into |
- // multiple HTTP/2 DATA frames. It will ensure that only 1 frame |
- // will go out in the case that the underlying session becomes write |
- // blocked. Buffering is required to preserve framing, but the |
- // amount of buffering is limited to one HTTP/2 data frame. |
- const int kMinDataFrames = 4; |
- const size_t data_len = kSpdyInitialFrameSizeLimit * kMinDataFrames + 1024; |
- // Set headers stream send window large enough for data written below. |
- headers_stream_->flow_controller()->UpdateSendWindowOffset(data_len * 2 * 4); |
- test::GenerateBody(&data, data_len); |
- |
- bool fin = true; |
- // So force the underlying |WritevData| to consume only 1 byte. |
- // In that case, |WritevStreamData| should consume just one |
- // HTTP/2 data frame's worth of data. |
- EXPECT_CALL(session_, |
- WritevData(headers_stream_, kHeadersStreamId, _, _, false, _)) |
- .WillOnce( |
- WithArgs<2>(Invoke(this, &QuicHeadersStreamTest::SaveIovShort))); |
- |
- QuicConsumedData consumed_data = headers_stream_->WritevStreamData( |
- id, MakeIOVector(data, &iov), offset, fin, nullptr); |
- |
- // bytes_consumed is max HTTP/2 data frame size minus the HTTP/2 |
- // data header size. |
- EXPECT_EQ(consumed_data.bytes_consumed, |
- kSpdyInitialFrameSizeLimit - |
- SpdyConstants::GetDataFrameMinimumSize(HTTP2)); |
- EXPECT_EQ(consumed_data.fin_consumed, false); |
- |
- // If session already blocked, then bytes_consumed should be zero. |
- consumed_data = headers_stream_->WritevStreamData( |
- id, MakeIOVector(data, &iov), offset, fin, nullptr); |
- |
- EXPECT_EQ(consumed_data.bytes_consumed, 0u); |
- EXPECT_EQ(consumed_data.fin_consumed, false); |
-} |
- |
} // namespace |
} // namespace test |
} // namespace net |