Index: net/proxy/proxy_resolver_v8_tracing_unittest.cc |
diff --git a/net/proxy/proxy_resolver_v8_tracing_unittest.cc b/net/proxy/proxy_resolver_v8_tracing_unittest.cc |
index b8a9dafcd36134eee5e605087ba813e6de036173..888dd18af57d30ddf26219bf0aa4b8166c4a607e 100644 |
--- a/net/proxy/proxy_resolver_v8_tracing_unittest.cc |
+++ b/net/proxy/proxy_resolver_v8_tracing_unittest.cc |
@@ -159,10 +159,9 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -186,9 +185,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://throw-an-error/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(ERR_PAC_SCRIPT_FAILED, callback.WaitForResult()); |
@@ -214,9 +212,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -251,9 +248,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -298,9 +294,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -351,9 +346,8 @@ |
TestCompletionCallback callback2; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, |
- callback1.callback(), &req, |
+ callback1.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback1.WaitForResult()); |
@@ -364,9 +358,8 @@ |
// The first request took 2 restarts, hence on g_iteration=3. |
EXPECT_EQ("166.155.144.11:3", proxy_info.proxy_server().ToURI()); |
- scoped_ptr<ProxyResolver::Request> req2; |
resolver->GetProxyForURL(GURL("http://foopy/req2"), &proxy_info, |
- callback2.callback(), &req2, |
+ callback2.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback2.WaitForResult()); |
@@ -398,9 +391,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -438,9 +430,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -470,9 +461,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -511,9 +501,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -552,9 +541,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -599,7 +587,7 @@ |
const size_t kNumRequests = 5; |
ProxyInfo proxy_info[kNumRequests]; |
- scoped_ptr<ProxyResolver::Request> request[kNumRequests]; |
+ ProxyResolver::RequestHandle request[kNumRequests]; |
for (size_t i = 0; i < kNumRequests; ++i) { |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info[i], |
@@ -608,7 +596,7 @@ |
} |
for (size_t i = 0; i < kNumRequests; ++i) { |
- request[i].reset(); |
+ resolver->CancelRequest(request[i]); |
} |
} |
@@ -626,8 +614,8 @@ |
ProxyInfo proxy_info1; |
ProxyInfo proxy_info2; |
- scoped_ptr<ProxyResolver::Request> request1; |
- scoped_ptr<ProxyResolver::Request> request2; |
+ ProxyResolver::RequestHandle request1; |
+ ProxyResolver::RequestHandle request2; |
TestCompletionCallback callback; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info1, |
@@ -637,7 +625,7 @@ |
callback.callback(), &request2, |
mock_bindings.CreateBindings()); |
- request1.reset(); |
+ resolver->CancelRequest(request1); |
EXPECT_EQ(OK, callback.WaitForResult()); |
} |
@@ -655,8 +643,8 @@ |
ProxyInfo proxy_info1; |
ProxyInfo proxy_info2; |
- scoped_ptr<ProxyResolver::Request> request1; |
- scoped_ptr<ProxyResolver::Request> request2; |
+ ProxyResolver::RequestHandle request1; |
+ ProxyResolver::RequestHandle request2; |
TestCompletionCallback callback; |
resolver->GetProxyForURL(GURL("http://throw-an-error/"), &proxy_info1, |
@@ -665,10 +653,10 @@ |
// Wait until the first request has finished running on the worker thread. |
// Cancel the first request, while it is running its completion task on |
- // the origin thread. Reset deletes Request opject which cancels the request. |
- mock_bindings.RunOnError( |
- base::Bind(&scoped_ptr<ProxyResolver::Request>::reset, |
- base::Unretained(&request1), nullptr)); |
+ // the origin thread. |
+ mock_bindings.RunOnError(base::Bind(&ProxyResolverV8Tracing::CancelRequest, |
+ base::Unretained(resolver.get()), |
+ request1)); |
// Start another request, to make sure it is able to complete. |
resolver->GetProxyForURL(GURL("http://i-have-no-idea-what-im-doing/"), |
@@ -758,8 +746,8 @@ |
ProxyInfo proxy_info1; |
ProxyInfo proxy_info2; |
- scoped_ptr<ProxyResolver::Request> request1; |
- scoped_ptr<ProxyResolver::Request> request2; |
+ ProxyResolver::RequestHandle request1; |
+ ProxyResolver::RequestHandle request2; |
resolver->GetProxyForURL(GURL("http://foo/req1"), &proxy_info1, |
base::Bind(&CrashCallback), &request1, |
@@ -773,8 +761,8 @@ |
host_resolver.WaitUntilRequestIsReceived(); |
- request1.reset(); |
- request2.reset(); |
+ resolver->CancelRequest(request1); |
+ resolver->CancelRequest(request2); |
EXPECT_EQ(2, host_resolver.num_cancelled_requests()); |
@@ -783,8 +771,9 @@ |
// should have been cancelled. |
} |
-void CancelRequestAndPause(scoped_ptr<ProxyResolver::Request>* request) { |
- request->reset(); |
+void CancelRequestAndPause(ProxyResolverV8Tracing* resolver, |
+ ProxyResolver::RequestHandle request) { |
+ resolver->CancelRequest(request); |
// Sleep for a little bit. This makes it more likely for the worker |
// thread to have returned from its call, and serves as a regression |
@@ -803,13 +792,14 @@ |
CreateResolver(mock_bindings.CreateBindings(), "dns.js"); |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> request; |
+ ProxyResolver::RequestHandle request; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
base::Bind(&CrashCallback), &request, |
mock_bindings.CreateBindings()); |
- host_resolver.SetAction(base::Bind(CancelRequestAndPause, &request)); |
+ host_resolver.SetAction( |
+ base::Bind(CancelRequestAndPause, resolver.get(), request)); |
host_resolver.WaitUntilRequestIsReceived(); |
} |
@@ -824,7 +814,7 @@ |
CreateResolver(mock_bindings.CreateBindings(), "dns.js"); |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> request; |
+ ProxyResolver::RequestHandle request; |
resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
base::Bind(&CrashCallback), &request, |
@@ -834,7 +824,7 @@ |
// work whatever the delay is here, but it is most useful if the delay |
// is large enough to allow a task to be posted back. |
base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(10)); |
- request.reset(); |
+ resolver->CancelRequest(request); |
EXPECT_EQ(0u, host_resolver.num_resolve()); |
} |
@@ -908,9 +898,8 @@ |
TestCompletionCallback callback; |
ProxyInfo proxy_info; |
- scoped_ptr<ProxyResolver::Request> req; |
resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, |
- callback.callback(), &req, |
+ callback.callback(), NULL, |
mock_bindings.CreateBindings()); |
EXPECT_EQ(OK, callback.WaitForResult()); |
@@ -982,14 +971,13 @@ |
const size_t kNumResults = kNumResolvers * kNumIterations; |
TestCompletionCallback callback[kNumResults]; |
ProxyInfo proxy_info[kNumResults]; |
- scoped_ptr<ProxyResolver::Request> request[kNumResults]; |
for (size_t i = 0; i < kNumResults; ++i) { |
size_t resolver_i = i % kNumResolvers; |
resolver[resolver_i]->GetProxyForURL( |
- GURL("http://foo/"), &proxy_info[i], callback[i].callback(), |
- &request[i], resolver_i == 3 ? mock_bindings3.CreateBindings() |
- : mock_bindings0.CreateBindings()); |
+ GURL("http://foo/"), &proxy_info[i], callback[i].callback(), NULL, |
+ resolver_i == 3 ? mock_bindings3.CreateBindings() |
+ : mock_bindings0.CreateBindings()); |
} |
// ------------------------ |