Index: net/quic/quic_stream_factory_test.cc |
diff --git a/net/quic/quic_stream_factory_test.cc b/net/quic/quic_stream_factory_test.cc |
index c8da53ce761c46ee916fa88bd5dfb89cdd6bf715..173d4c904d344deb67d4d6fb5c0d610741df78e7 100644 |
--- a/net/quic/quic_stream_factory_test.cc |
+++ b/net/quic/quic_stream_factory_test.cc |
@@ -42,9 +42,14 @@ |
#include "net/ssl/channel_id_service.h" |
#include "net/ssl/default_channel_id_store.h" |
#include "net/test/cert_test_util.h" |
+#include "net/test/gtest_util.h" |
#include "net/test/test_data_directory.h" |
+#include "testing/gmock/include/gmock/gmock.h" |
#include "testing/gtest/include/gtest/gtest.h" |
+using net::test::IsError; |
+using net::test::IsOk; |
+ |
using std::string; |
using std::vector; |
@@ -410,7 +415,7 @@ class QuicStreamFactoryTestBase { |
/*cert_verify_flags=*/0, url, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
stream.reset(); |
@@ -569,7 +574,7 @@ TEST_P(QuicStreamFactoryTest, Create) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -657,7 +662,7 @@ TEST_P(QuicStreamFactoryTest, GoAway) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -686,7 +691,7 @@ TEST_P(QuicStreamFactoryTest, GoAwayForConnectionMigrationWithPortOnly) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1086,7 +1091,7 @@ TEST_P(QuicStreamFactoryTest, Goaway) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1105,7 +1110,7 @@ TEST_P(QuicStreamFactoryTest, Goaway) { |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1153,10 +1158,10 @@ TEST_P(QuicStreamFactoryTest, MaxOpenStream) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback()); |
if (i == 0) { |
- EXPECT_EQ(ERR_IO_PENDING, rv); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(rv, IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
} else { |
- EXPECT_EQ(OK, rv); |
+ EXPECT_THAT(rv, IsOk()); |
} |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream); |
@@ -1179,7 +1184,7 @@ TEST_P(QuicStreamFactoryTest, MaxOpenStream) { |
streams.front()->Close(false); |
// Trigger exchange of RSTs that in turn allow progress for the last |
// stream. |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
EXPECT_TRUE(socket_data.AllReadDataConsumed()); |
EXPECT_TRUE(socket_data.AllWriteDataConsumed()); |
@@ -1207,7 +1212,7 @@ TEST_P(QuicStreamFactoryTest, ResolutionErrorInCreate) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(ERR_NAME_NOT_RESOLVED, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsError(ERR_NAME_NOT_RESOLVED)); |
EXPECT_TRUE(socket_data.AllReadDataConsumed()); |
EXPECT_TRUE(socket_data.AllWriteDataConsumed()); |
@@ -1226,7 +1231,7 @@ TEST_P(QuicStreamFactoryTest, ConnectErrorInCreate) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(ERR_ADDRESS_IN_USE, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsError(ERR_ADDRESS_IN_USE)); |
EXPECT_TRUE(socket_data.AllReadDataConsumed()); |
EXPECT_TRUE(socket_data.AllWriteDataConsumed()); |
@@ -1315,7 +1320,7 @@ TEST_P(QuicStreamFactoryTest, CloseAllSessions) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
HttpRequestInfo request_info; |
EXPECT_EQ(OK, stream->InitializeStream(&request_info, DEFAULT_PRIORITY, |
@@ -1335,7 +1340,7 @@ TEST_P(QuicStreamFactoryTest, CloseAllSessions) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
stream = request2.CreateStream(); |
stream.reset(); // Will reset stream 3. |
@@ -1371,7 +1376,7 @@ TEST_P(QuicStreamFactoryTest, OnIPAddressChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
HttpRequestInfo request_info; |
EXPECT_EQ(OK, stream->InitializeStream(&request_info, DEFAULT_PRIORITY, |
@@ -1392,7 +1397,7 @@ TEST_P(QuicStreamFactoryTest, OnIPAddressChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
stream = request2.CreateStream(); |
stream.reset(); // Will reset stream 3. |
@@ -1424,7 +1429,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnect) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1474,7 +1479,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnect) { |
// Verify that response headers on the migrated socket were delivered to the |
// stream. |
- EXPECT_EQ(OK, stream->ReadResponseHeaders(callback_.callback())); |
+ EXPECT_THAT(stream->ReadResponseHeaders(callback_.callback()), IsOk()); |
EXPECT_EQ(200, response.headers->response_code()); |
// Create a new request for the same destination and verify that a |
@@ -1488,7 +1493,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnect) { |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1536,7 +1541,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnected) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1596,7 +1601,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnected) { |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1635,7 +1640,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoNetworks) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1688,7 +1693,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoNetworks) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1736,7 +1741,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoNewNetwork) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1787,7 +1792,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoNewNetwork) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1837,7 +1842,7 @@ TEST_P(QuicStreamFactoryTest, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1890,7 +1895,7 @@ TEST_P(QuicStreamFactoryTest, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1945,7 +1950,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNonMigratableStream) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1996,7 +2001,7 @@ TEST_P(QuicStreamFactoryTest, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2043,7 +2048,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoOpenStreams) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2080,7 +2085,7 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoOpenStreams) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2123,7 +2128,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarly) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2176,7 +2181,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarly) { |
// Verify that response headers on the migrated socket were delivered to the |
// stream. |
- EXPECT_EQ(OK, stream->ReadResponseHeaders(callback_.callback())); |
+ EXPECT_THAT(stream->ReadResponseHeaders(callback_.callback()), IsOk()); |
EXPECT_EQ(200, response.headers->response_code()); |
// Create a new request for the same destination and verify that a |
@@ -2190,7 +2195,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarly) { |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -2243,7 +2248,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarlyNoNewNetwork) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2298,7 +2303,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarlyNonMigratableStream) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2353,7 +2358,7 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarlyConnectionMigrationDisabled) { |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2414,7 +2419,7 @@ TEST_P(QuicStreamFactoryTest, OnSSLConfigChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
HttpRequestInfo request_info; |
EXPECT_EQ(OK, stream->InitializeStream(&request_info, DEFAULT_PRIORITY, |
@@ -2434,7 +2439,7 @@ TEST_P(QuicStreamFactoryTest, OnSSLConfigChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
stream = request2.CreateStream(); |
stream.reset(); // Will reset stream 3. |
@@ -2469,7 +2474,7 @@ TEST_P(QuicStreamFactoryTest, OnCertAdded) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
HttpRequestInfo request_info; |
EXPECT_EQ(OK, stream->InitializeStream(&request_info, DEFAULT_PRIORITY, |
@@ -2490,7 +2495,7 @@ TEST_P(QuicStreamFactoryTest, OnCertAdded) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
stream = request2.CreateStream(); |
stream.reset(); // Will reset stream 3. |
@@ -2525,7 +2530,7 @@ TEST_P(QuicStreamFactoryTest, OnCACertChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
HttpRequestInfo request_info; |
EXPECT_EQ(OK, stream->InitializeStream(&request_info, DEFAULT_PRIORITY, |
@@ -2546,7 +2551,7 @@ TEST_P(QuicStreamFactoryTest, OnCACertChanged) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
stream = request2.CreateStream(); |
stream.reset(); // Will reset stream 3. |
@@ -3699,7 +3704,7 @@ TEST_P(QuicStreamFactoryTest, EnableDelayTcpRace) { |
crypto_client_stream_factory_.last_stream()->SendOnCryptoHandshakeEvent( |
QuicSession::HANDSHAKE_CONFIRMED); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -3997,7 +4002,7 @@ TEST_P(QuicStreamFactoryTest, ServerPushSessionAffinity) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -4046,7 +4051,7 @@ TEST_P(QuicStreamFactoryTest, ServerPushPrivacyModeMismatch) { |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream = request.CreateStream(); |
EXPECT_TRUE(stream.get()); |
@@ -4074,7 +4079,7 @@ TEST_P(QuicStreamFactoryTest, ServerPushPrivacyModeMismatch) { |
EXPECT_EQ(0, QuicStreamFactoryPeer::GetNumPushStreamsCreated(factory_.get())); |
EXPECT_EQ(index->GetPromised(kDefaultUrl), nullptr); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -4104,7 +4109,7 @@ TEST_P(QuicStreamFactoryTest, PoolByOrigin) { |
request1.Request(destination1, privacy_mode_, |
/*cert_verify_flags=*/0, url_, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream1 = request1.CreateStream(); |
EXPECT_TRUE(stream1.get()); |
EXPECT_TRUE(HasActiveSession(host_port_pair_)); |
@@ -4217,7 +4222,7 @@ TEST_P(QuicStreamFactoryWithDestinationTest, InvalidCertificate) { |
/*cert_verify_flags=*/0, url, "GET", |
net_log_, callback_.callback())); |
- EXPECT_EQ(ERR_QUIC_HANDSHAKE_FAILED, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsError(ERR_QUIC_HANDSHAKE_FAILED)); |
EXPECT_TRUE(AllDataConsumed()); |
} |
@@ -4252,7 +4257,7 @@ TEST_P(QuicStreamFactoryWithDestinationTest, SharedCertificate) { |
request1.Request(destination, privacy_mode_, |
/*cert_verify_flags=*/0, url1, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream1 = request1.CreateStream(); |
EXPECT_TRUE(stream1.get()); |
EXPECT_TRUE(HasActiveSession(origin1_)); |
@@ -4386,7 +4391,7 @@ TEST_P(QuicStreamFactoryWithDestinationTest, DisjointCertificate) { |
request1.Request(destination, privacy_mode_, |
/*cert_verify_flags=*/0, url1, "GET", net_log_, |
callback_.callback())); |
- EXPECT_EQ(OK, callback_.WaitForResult()); |
+ EXPECT_THAT(callback_.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream1 = request1.CreateStream(); |
EXPECT_TRUE(stream1.get()); |
EXPECT_TRUE(HasActiveSession(origin1_)); |
@@ -4397,7 +4402,7 @@ TEST_P(QuicStreamFactoryWithDestinationTest, DisjointCertificate) { |
request2.Request(destination, privacy_mode_, |
/*cert_verify_flags=*/0, url2, "GET", net_log_, |
callback2.callback())); |
- EXPECT_EQ(OK, callback2.WaitForResult()); |
+ EXPECT_THAT(callback2.WaitForResult(), IsOk()); |
std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream(); |
EXPECT_TRUE(stream2.get()); |