| Index: net/proxy/multi_threaded_proxy_resolver_unittest.cc
|
| diff --git a/net/proxy/multi_threaded_proxy_resolver_unittest.cc b/net/proxy/multi_threaded_proxy_resolver_unittest.cc
|
| index 6c26d6aed175902e5b52ada46652f84e71fb96b2..6f239eeeacdc2da5678b5d803806eee8b4b56502 100644
|
| --- a/net/proxy/multi_threaded_proxy_resolver_unittest.cc
|
| +++ b/net/proxy/multi_threaded_proxy_resolver_unittest.cc
|
| @@ -26,9 +26,14 @@
|
| #include "net/proxy/mock_proxy_resolver.h"
|
| #include "net/proxy/proxy_info.h"
|
| #include "net/proxy/proxy_resolver_factory.h"
|
| +#include "net/test/gtest_util.h"
|
| +#include "testing/gmock/include/gmock/gmock.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| #include "url/gurl.h"
|
|
|
| +using net::test::IsError;
|
| +using net::test::IsOk;
|
| +
|
| using base::ASCIIToUTF16;
|
|
|
| namespace net {
|
| @@ -207,7 +212,7 @@ class MultiThreadedProxyResolverTest : public testing::Test {
|
| ProxyResolverScriptData::FromUTF8("pac script bytes"), &resolver_,
|
| ready_callback.callback(), &request);
|
| EXPECT_TRUE(request);
|
| - ASSERT_EQ(OK, ready_callback.WaitForResult());
|
| + ASSERT_THAT(ready_callback.WaitForResult(), IsOk());
|
|
|
| // Verify that the script data reaches the synchronous resolver factory.
|
| ASSERT_EQ(1u, factory_->script_data().size());
|
| @@ -244,7 +249,7 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_Basic) {
|
| ProxyInfo results0;
|
| rv = resolver().GetProxyForURL(GURL("http://request0"), &results0,
|
| callback0.callback(), NULL, log0.bound());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Wait for request 0 to finish.
|
| rv = callback0.WaitForResult();
|
| @@ -267,19 +272,19 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_Basic) {
|
| ProxyInfo results1;
|
| rv = resolver().GetProxyForURL(GURL("http://request1"), &results1,
|
| callback1.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| TestCompletionCallback callback2;
|
| ProxyInfo results2;
|
| rv = resolver().GetProxyForURL(GURL("http://request2"), &results2,
|
| callback2.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| TestCompletionCallback callback3;
|
| ProxyInfo results3;
|
| rv = resolver().GetProxyForURL(GURL("http://request3"), &results3,
|
| callback3.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Wait for the requests to finish (they must finish in the order they were
|
| // started, which is what we check for from their magic return value)
|
| @@ -316,7 +321,7 @@ TEST_F(MultiThreadedProxyResolverTest,
|
| BoundTestNetLog log0;
|
| rv = resolver().GetProxyForURL(GURL("http://request0"), &results0,
|
| callback0.callback(), &request0, log0.bound());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Start 2 more requests (request1 and request2).
|
|
|
| @@ -325,7 +330,7 @@ TEST_F(MultiThreadedProxyResolverTest,
|
| BoundTestNetLog log1;
|
| rv = resolver().GetProxyForURL(GURL("http://request1"), &results1,
|
| callback1.callback(), NULL, log1.bound());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| ProxyResolver::RequestHandle request2;
|
| TestCompletionCallback callback2;
|
| @@ -333,7 +338,7 @@ TEST_F(MultiThreadedProxyResolverTest,
|
| BoundTestNetLog log2;
|
| rv = resolver().GetProxyForURL(GURL("http://request2"), &results2,
|
| callback2.callback(), &request2, log2.bound());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Unblock the worker thread so the requests can continue running.
|
| factory().resolvers()[0]->WaitUntilBlocked();
|
| @@ -401,7 +406,7 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
|
| rv =
|
| resolver().GetProxyForURL(GURL("http://request0"), &results0,
|
| callback0.callback(), &request0, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Wait until requests 0 reaches the worker thread.
|
| factory().resolvers()[0]->WaitUntilBlocked();
|
| @@ -412,7 +417,7 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
|
| ProxyInfo results1;
|
| rv = resolver().GetProxyForURL(GURL("http://request1"), &results1,
|
| callback1.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| ProxyResolver::RequestHandle request2;
|
| TestCompletionCallback callback2;
|
| @@ -420,13 +425,13 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
|
| rv =
|
| resolver().GetProxyForURL(GURL("http://request2"), &results2,
|
| callback2.callback(), &request2, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| TestCompletionCallback callback3;
|
| ProxyInfo results3;
|
| rv = resolver().GetProxyForURL(GURL("http://request3"), &results3,
|
| callback3.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Cancel request0 (inprogress) and request2 (pending).
|
| resolver().CancelRequest(request0);
|
| @@ -471,19 +476,19 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequestByDeleting) {
|
| ProxyInfo results0;
|
| rv = resolver().GetProxyForURL(GURL("http://request0"), &results0,
|
| callback0.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| TestCompletionCallback callback1;
|
| ProxyInfo results1;
|
| rv = resolver().GetProxyForURL(GURL("http://request1"), &results1,
|
| callback1.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| TestCompletionCallback callback2;
|
| ProxyInfo results2;
|
| rv = resolver().GetProxyForURL(GURL("http://request2"), &results2,
|
| callback2.callback(), NULL, BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Wait until request 0 reaches the worker thread.
|
| factory().resolvers()[0]->WaitUntilBlocked();
|
| @@ -531,7 +536,7 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
|
| rv = resolver().GetProxyForURL(GURL("http://request0"), &results[0],
|
| callback[0].callback(), &request[0],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
|
|
| // Wait for request 0 to finish.
|
| rv = callback[0].WaitForResult();
|
| @@ -548,12 +553,12 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
|
| rv = resolver().GetProxyForURL(GURL("http://request1"), &results[1],
|
| callback[1].callback(), &request[1],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| factory().resolvers()[0]->WaitUntilBlocked();
|
| rv = resolver().GetProxyForURL(GURL("http://request2"), &results[2],
|
| callback[2].callback(), &request[2],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| EXPECT_EQ(0, callback[2].WaitForResult());
|
| ASSERT_EQ(2u, factory().resolvers().size());
|
|
|
| @@ -563,12 +568,12 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
|
| rv = resolver().GetProxyForURL(GURL("http://request3"), &results[3],
|
| callback[3].callback(), &request[3],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| factory().resolvers()[1]->WaitUntilBlocked();
|
| rv = resolver().GetProxyForURL(GURL("http://request4"), &results[4],
|
| callback[4].callback(), &request[4],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| EXPECT_EQ(0, callback[4].WaitForResult());
|
|
|
| // We should now have a total of 3 threads, each with its own ProxyResolver
|
| @@ -590,15 +595,15 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
|
| rv = resolver().GetProxyForURL(GURL("http://request5"), &results[5],
|
| callback[5].callback(), &request[5],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| rv = resolver().GetProxyForURL(GURL("http://request6"), &results[6],
|
| callback[6].callback(), &request[6],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| rv = resolver().GetProxyForURL(GURL("http://request7"), &results[7],
|
| callback[7].callback(), &request[7],
|
| BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| resolver().CancelRequest(request[5]);
|
| resolver().CancelRequest(request[6]);
|
|
|
| @@ -646,7 +651,7 @@ TEST_F(MultiThreadedProxyResolverTest, OneThreadBlocked) {
|
| callback[0].callback(), &request[0],
|
| BoundNetLog());
|
|
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| factory().resolvers()[0]->WaitUntilBlocked();
|
|
|
| // Start 3 more requests -- they should all be serviced by thread #2
|
| @@ -656,7 +661,7 @@ TEST_F(MultiThreadedProxyResolverTest, OneThreadBlocked) {
|
| rv = resolver().GetProxyForURL(
|
| GURL(base::StringPrintf("http://request%d", i)), &results[i],
|
| callback[i].callback(), &request[i], BoundNetLog());
|
| - EXPECT_EQ(ERR_IO_PENDING, rv);
|
| + EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
|
| }
|
|
|
| // Wait for the three requests to complete (they should complete in FIFO
|
| @@ -704,7 +709,7 @@ TEST_F(MultiThreadedProxyResolverTest, ProxyResolverFactoryError) {
|
| ProxyResolverScriptData::FromUTF8("pac script bytes"),
|
| &resolver, ready_callback.callback(), &request));
|
| EXPECT_TRUE(request);
|
| - EXPECT_EQ(ERR_PAC_SCRIPT_FAILED, ready_callback.WaitForResult());
|
| + EXPECT_THAT(ready_callback.WaitForResult(), IsError(ERR_PAC_SCRIPT_FAILED));
|
| EXPECT_FALSE(resolver);
|
| }
|
|
|
| @@ -755,7 +760,7 @@ TEST_F(MultiThreadedProxyResolverTest, DeleteRequestInFactoryCallback) {
|
| base::Unretained(&request)),
|
| &request));
|
| EXPECT_TRUE(request);
|
| - EXPECT_EQ(OK, callback.WaitForResult());
|
| + EXPECT_THAT(callback.WaitForResult(), IsOk());
|
| }
|
|
|
| // Test that deleting the factory with a request in-progress works correctly.
|
|
|