Index: net/quic/chromium/quic_http_stream_test.cc |
diff --git a/net/quic/chromium/quic_http_stream_test.cc b/net/quic/chromium/quic_http_stream_test.cc |
index da5f35b3a9e6bb906c3b392148403c3b7da63434..b1aae1a2a727cb3e498ee60b2a553bfa85a90771 100644 |
--- a/net/quic/chromium/quic_http_stream_test.cc |
+++ b/net/quic/chromium/quic_http_stream_test.cc |
@@ -103,8 +103,11 @@ class AutoClosingStream : public QuicHttpStream { |
public: |
explicit AutoClosingStream( |
const base::WeakPtr<QuicChromiumClientSession>& session, |
- HttpServerProperties* http_server_properties) |
- : QuicHttpStream(session, http_server_properties) {} |
+ HttpServerProperties* http_server_properties, |
+ bool mark_quic_broken_when_network_suspected) |
+ : QuicHttpStream(session, |
+ http_server_properties, |
+ mark_quic_broken_when_network_suspected) {} |
void OnHeadersAvailable(const SpdyHeaderBlock& headers, |
size_t frame_len) override { |
@@ -207,6 +210,7 @@ class QuicHttpStreamTest : public ::testing::TestWithParam<QuicVersion> { |
: use_closing_stream_(false), |
crypto_config_(crypto_test_utils::ProofVerifierForTesting()), |
read_buffer_(new IOBufferWithSize(4096)), |
+ mark_quic_broken_when_network_suspected_(false), |
promise_id_(kServerDataStreamId1), |
stream_id_(kClientDataStreamId1), |
connection_id_(2), |
@@ -332,16 +336,21 @@ class QuicHttpStreamTest : public ::testing::TestWithParam<QuicVersion> { |
session_->CryptoConnect(callback.callback()); |
EXPECT_TRUE(session_->IsCryptoHandshakeConfirmed()); |
stream_.reset(use_closing_stream_ |
- ? new AutoClosingStream(session_->GetWeakPtr(), |
- &http_server_properties_) |
- : new QuicHttpStream(session_->GetWeakPtr(), |
- &http_server_properties_)); |
- |
- promised_stream_.reset(use_closing_stream_ |
- ? new AutoClosingStream(session_->GetWeakPtr(), |
- &http_server_properties_) |
- : new QuicHttpStream(session_->GetWeakPtr(), |
- &http_server_properties_)); |
+ ? new AutoClosingStream( |
+ session_->GetWeakPtr(), &http_server_properties_, |
+ mark_quic_broken_when_network_suspected_) |
+ : new QuicHttpStream( |
+ session_->GetWeakPtr(), &http_server_properties_, |
+ mark_quic_broken_when_network_suspected_)); |
+ |
+ promised_stream_.reset( |
+ use_closing_stream_ |
+ ? new AutoClosingStream(session_->GetWeakPtr(), |
+ &http_server_properties_, |
+ mark_quic_broken_when_network_suspected_) |
+ : new QuicHttpStream(session_->GetWeakPtr(), |
+ &http_server_properties_, |
+ mark_quic_broken_when_network_suspected_)); |
push_promise_[":path"] = "/bar"; |
push_promise_[":authority"] = "www.example.org"; |
@@ -584,6 +593,7 @@ class QuicHttpStreamTest : public ::testing::TestWithParam<QuicVersion> { |
string request_data_; |
string response_data_; |
QuicClientPushPromiseIndex push_promise_index_; |
+ bool mark_quic_broken_when_network_suspected_; |
Bence
2017/04/03 19:02:59
This member is always false, so consider a file-sc
Ryan Hamilton
2017/04/05 19:26:20
Done.
Bence
2017/04/05 23:49:46
Sorry, I was rather thinking of setting kMarkQuicB
Ryan Hamilton
2017/04/08 00:07:23
I see. As it happens, I ended up reverting the cha
|
// For server push testing |
std::unique_ptr<QuicHttpStream> promised_stream_; |
@@ -725,7 +735,8 @@ TEST_P(QuicHttpStreamTest, LoadTimingTwoRequests) { |
stream_->SendRequest(headers_, &response_, callback_.callback())); |
// Start a second request. |
- QuicHttpStream stream2(session_->GetWeakPtr(), &http_server_properties_); |
+ QuicHttpStream stream2(session_->GetWeakPtr(), &http_server_properties_, |
+ mark_quic_broken_when_network_suspected_); |
TestCompletionCallback callback2; |
EXPECT_EQ(OK, |
stream2.InitializeStream(&request_, DEFAULT_PRIORITY, |