Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1222)

Unified Diff: net/quic/core/quic_headers_stream_test.cc

Issue 2430973004: Landing Recent QUIC changes until 10:38 AM, Oct 17, 2016 UTC-4 (Closed)
Patch Set: Improving flagsaver logging Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/core/quic_headers_stream.cc ('k') | net/quic/core/quic_packet_generator.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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
« no previous file with comments | « net/quic/core/quic_headers_stream.cc ('k') | net/quic/core/quic_packet_generator.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698