Index: net/proxy/mojo_proxy_resolver_impl.cc |
diff --git a/net/proxy/mojo_proxy_resolver_impl.cc b/net/proxy/mojo_proxy_resolver_impl.cc |
index c300b6eff0dc5604a27b1aa804f38781fb3e978f..b2704382fb09f5f391c421b195e1cef62ad173f0 100644 |
--- a/net/proxy/mojo_proxy_resolver_impl.cc |
+++ b/net/proxy/mojo_proxy_resolver_impl.cc |
@@ -8,15 +8,11 @@ |
#include "mojo/common/url_type_converters.h" |
#include "net/base/net_errors.h" |
#include "net/log/net_log.h" |
-#include "net/proxy/load_state_change_coalescer.h" |
#include "net/proxy/mojo_proxy_type_converters.h" |
#include "net/proxy/proxy_info.h" |
#include "net/proxy/proxy_resolver_script_data.h" |
namespace net { |
-namespace { |
-const int kLoadStateChangeCoalesceTimeoutMilliseconds = 10; |
-} |
class MojoProxyResolverImpl::Job : public mojo::ErrorHandler { |
public: |
@@ -27,9 +23,6 @@ class MojoProxyResolverImpl::Job : public mojo::ErrorHandler { |
void Start(); |
- // Invoked when the LoadState for this job changes. |
- void LoadStateChanged(LoadState load_state); |
- |
net::ProxyResolver::RequestHandle request_handle() { return request_handle_; } |
private: |
@@ -40,8 +33,6 @@ class MojoProxyResolverImpl::Job : public mojo::ErrorHandler { |
void GetProxyDone(int error); |
- void SendLoadStateChanged(LoadState load_state); |
- |
MojoProxyResolverImpl* resolver_; |
interfaces::ProxyResolverRequestClientPtr client_; |
@@ -49,33 +40,19 @@ class MojoProxyResolverImpl::Job : public mojo::ErrorHandler { |
GURL url_; |
net::ProxyResolver::RequestHandle request_handle_; |
bool done_; |
- LoadStateChangeCoalescer load_state_change_coalescer_; |
DISALLOW_COPY_AND_ASSIGN(Job); |
}; |
MojoProxyResolverImpl::MojoProxyResolverImpl( |
- scoped_ptr<net::ProxyResolver> resolver, |
- const base::Callback< |
- void(const net::ProxyResolver::LoadStateChangedCallback&)>& |
- load_state_change_callback_setter) |
+ scoped_ptr<net::ProxyResolver> resolver) |
: resolver_(resolver.Pass()) { |
- load_state_change_callback_setter.Run(base::Bind( |
- &MojoProxyResolverImpl::LoadStateChanged, base::Unretained(this))); |
} |
MojoProxyResolverImpl::~MojoProxyResolverImpl() { |
STLDeleteElements(&resolve_jobs_); |
} |
-void MojoProxyResolverImpl::LoadStateChanged( |
- net::ProxyResolver::RequestHandle handle, |
- LoadState load_state) { |
- auto it = request_handle_to_job_.find(handle); |
- DCHECK(it != request_handle_to_job_.end()); |
- it->second->LoadStateChanged(load_state); |
-} |
- |
void MojoProxyResolverImpl::GetProxyForUrl( |
const mojo::String& url, |
interfaces::ProxyResolverRequestClientPtr client) { |
@@ -103,13 +80,7 @@ MojoProxyResolverImpl::Job::Job( |
client_(client.Pass()), |
url_(url), |
request_handle_(nullptr), |
- done_(false), |
- load_state_change_coalescer_( |
- base::Bind(&MojoProxyResolverImpl::Job::SendLoadStateChanged, |
- base::Unretained(this)), |
- base::TimeDelta::FromMilliseconds( |
- kLoadStateChangeCoalesceTimeoutMilliseconds), |
- LOAD_STATE_RESOLVING_PROXY_FOR_URL) { |
+ done_(false) { |
} |
MojoProxyResolverImpl::Job::~Job() { |
@@ -130,10 +101,6 @@ void MojoProxyResolverImpl::Job::Start() { |
std::make_pair(request_handle_, this)); |
} |
-void MojoProxyResolverImpl::Job::LoadStateChanged(LoadState load_state) { |
- load_state_change_coalescer_.LoadStateChanged(load_state); |
-} |
- |
void MojoProxyResolverImpl::Job::GetProxyDone(int error) { |
done_ = true; |
DVLOG(1) << "GetProxyForUrl(" << url_ << ") finished with error " << error |
@@ -154,8 +121,4 @@ void MojoProxyResolverImpl::Job::OnConnectionError() { |
resolver_->DeleteJob(this); |
} |
-void MojoProxyResolverImpl::Job::SendLoadStateChanged(LoadState load_state) { |
- client_->LoadStateChanged(load_state); |
-} |
- |
} // namespace net |