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

Unified Diff: net/proxy/multi_threaded_proxy_resolver_unittest.cc

Issue 1439053002: Change ProxyResolver::GetProxyForURL() to take a scoped_ptr<Request>* rather than a RequestHandle* (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Restore scoped_ptr to mock and nits Created 4 years, 10 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/proxy/multi_threaded_proxy_resolver.cc ('k') | net/proxy/proxy_resolver.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 5c29864acad37dc634301c198d1cdc6d14f1da70..1eaed5fde0667cb811c9630f2226eaa84296bd57 100644
--- a/net/proxy/multi_threaded_proxy_resolver_unittest.cc
+++ b/net/proxy/multi_threaded_proxy_resolver_unittest.cc
@@ -46,7 +46,7 @@ class MockProxyResolver : public ProxyResolver {
int GetProxyForURL(const GURL& query_url,
ProxyInfo* results,
const CompletionCallback& callback,
- RequestHandle* request,
+ scoped_ptr<Request>* request,
const BoundNetLog& net_log) override {
if (resolve_latency_ != base::TimeDelta())
base::PlatformThread::Sleep(resolve_latency_);
@@ -65,13 +65,6 @@ class MockProxyResolver : public ProxyResolver {
return request_count_++;
}
- void CancelRequest(RequestHandle request) override { NOTREACHED(); }
-
- LoadState GetLoadState(RequestHandle request) const override {
- NOTREACHED();
- return LOAD_STATE_IDLE;
- }
-
int request_count() const { return request_count_; }
void SetResolveLatency(base::TimeDelta latency) {
@@ -120,7 +113,7 @@ class BlockableProxyResolver : public MockProxyResolver {
int GetProxyForURL(const GURL& query_url,
ProxyInfo* results,
const CompletionCallback& callback,
- RequestHandle* request,
+ scoped_ptr<Request>* request,
const BoundNetLog& net_log) override {
if (should_block_) {
blocked_.Signal();
@@ -308,7 +301,7 @@ TEST_F(MultiThreadedProxyResolverTest,
factory().resolvers()[0]->Block();
// Start request 0.
- ProxyResolver::RequestHandle request0;
+ scoped_ptr<ProxyResolver::Request> request0;
TestCompletionCallback callback0;
ProxyInfo results0;
BoundTestNetLog log0;
@@ -325,7 +318,7 @@ TEST_F(MultiThreadedProxyResolverTest,
callback1.callback(), NULL, log1.bound());
EXPECT_EQ(ERR_IO_PENDING, rv);
- ProxyResolver::RequestHandle request2;
+ scoped_ptr<ProxyResolver::Request> request2;
TestCompletionCallback callback2;
ProxyInfo results2;
BoundTestNetLog log2;
@@ -393,7 +386,7 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
factory().resolvers()[0]->Block();
// Start request 0.
- ProxyResolver::RequestHandle request0;
+ scoped_ptr<ProxyResolver::Request> request0;
TestCompletionCallback callback0;
ProxyInfo results0;
rv =
@@ -412,7 +405,7 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
callback1.callback(), NULL, BoundNetLog());
EXPECT_EQ(ERR_IO_PENDING, rv);
- ProxyResolver::RequestHandle request2;
+ scoped_ptr<ProxyResolver::Request> request2;
TestCompletionCallback callback2;
ProxyInfo results2;
rv =
@@ -427,8 +420,8 @@ TEST_F(MultiThreadedProxyResolverTest, SingleThread_CancelRequest) {
EXPECT_EQ(ERR_IO_PENDING, rv);
// Cancel request0 (inprogress) and request2 (pending).
- resolver().CancelRequest(request0);
- resolver().CancelRequest(request2);
+ request0.reset();
+ request2.reset();
// Unblock the worker thread so the requests can continue running.
factory().resolvers()[0]->Unblock();
@@ -522,7 +515,7 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
int rv;
TestCompletionCallback callback[kNumRequests];
ProxyInfo results[kNumRequests];
- ProxyResolver::RequestHandle request[kNumRequests];
+ scoped_ptr<ProxyResolver::Request> request[kNumRequests];
// Start request 0 -- this should run on thread 0 as there is nothing else
// going on right now.
@@ -597,8 +590,8 @@ TEST_F(MultiThreadedProxyResolverTest, ThreeThreads_Basic) {
callback[7].callback(), &request[7],
BoundNetLog());
EXPECT_EQ(ERR_IO_PENDING, rv);
- resolver().CancelRequest(request[5]);
- resolver().CancelRequest(request[6]);
+ request[5].reset();
+ request[6].reset();
EXPECT_EQ(2, callback[7].WaitForResult());
@@ -634,7 +627,7 @@ TEST_F(MultiThreadedProxyResolverTest, OneThreadBlocked) {
const int kNumRequests = 4;
TestCompletionCallback callback[kNumRequests];
ProxyInfo results[kNumRequests];
- ProxyResolver::RequestHandle request[kNumRequests];
+ scoped_ptr<ProxyResolver::Request> request[kNumRequests];
// Start a request that will block the first thread.
« no previous file with comments | « net/proxy/multi_threaded_proxy_resolver.cc ('k') | net/proxy/proxy_resolver.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698