1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "net/proxy/mojo_proxy_resolver_impl.h"
#include "base/stl_util.h"
#include "mojo/common/url_type_converters.h"
#include "net/base/net_errors.h"
#include "net/log/net_log.h"
#include "net/proxy/mojo_proxy_resolver_v8_tracing_bindings.h"
#include "net/proxy/mojo_proxy_type_converters.h"
#include "net/proxy/proxy_info.h"
#include "net/proxy/proxy_resolver_script_data.h"
#include "net/proxy/proxy_resolver_v8_tracing.h"
namespace net {
class MojoProxyResolverImpl::Job {
public:
Job(interfaces::ProxyResolverRequestClientPtr client,
MojoProxyResolverImpl* resolver,
const GURL& url);
~Job();
void Start();
private:
// Mojo error handler. This is invoked in response to the client
// disconnecting, indicating cancellation.
void OnConnectionError();
void GetProxyDone(int error);
MojoProxyResolverImpl* resolver_;
interfaces::ProxyResolverRequestClientPtr client_;
ProxyInfo result_;
GURL url_;
net::ProxyResolver::RequestHandle request_handle_;
bool done_;
DISALLOW_COPY_AND_ASSIGN(Job);
};
MojoProxyResolverImpl::MojoProxyResolverImpl(
scoped_ptr<ProxyResolverV8Tracing> resolver)
: resolver_(resolver.Pass()) {
}
MojoProxyResolverImpl::~MojoProxyResolverImpl() {
STLDeleteElements(&resolve_jobs_);
}
void MojoProxyResolverImpl::GetProxyForUrl(
const mojo::String& url,
interfaces::ProxyResolverRequestClientPtr client) {
DVLOG(1) << "GetProxyForUrl(" << url << ")";
Job* job = new Job(client.Pass(), this, url.To<GURL>());
bool inserted = resolve_jobs_.insert(job).second;
DCHECK(inserted);
job->Start();
}
void MojoProxyResolverImpl::DeleteJob(Job* job) {
size_t num_erased = resolve_jobs_.erase(job);
DCHECK(num_erased);
delete job;
}
MojoProxyResolverImpl::Job::Job(
interfaces::ProxyResolverRequestClientPtr client,
MojoProxyResolverImpl* resolver,
const GURL& url)
: resolver_(resolver),
client_(client.Pass()),
url_(url),
request_handle_(nullptr),
done_(false) {}
MojoProxyResolverImpl::Job::~Job() {
if (request_handle_ && !done_)
resolver_->resolver_->CancelRequest(request_handle_);
}
void MojoProxyResolverImpl::Job::Start() {
resolver_->resolver_->GetProxyForURL(
url_, &result_, base::Bind(&Job::GetProxyDone, base::Unretained(this)),
&request_handle_,
make_scoped_ptr(new MojoProxyResolverV8TracingBindings<
interfaces::ProxyResolverRequestClient>(client_.get())));
client_.set_connection_error_handler(base::Bind(
&MojoProxyResolverImpl::Job::OnConnectionError, base::Unretained(this)));
}
void MojoProxyResolverImpl::Job::GetProxyDone(int error) {
done_ = true;
DVLOG(1) << "GetProxyForUrl(" << url_ << ") finished with error " << error
<< ". " << result_.proxy_list().size() << " Proxies returned:";
for (const auto& proxy : result_.proxy_list().GetAll()) {
DVLOG(1) << proxy.ToURI();
}
mojo::Array<interfaces::ProxyServerPtr> result;
if (error == OK) {
result = mojo::Array<interfaces::ProxyServerPtr>::From(
result_.proxy_list().GetAll());
}
client_->ReportResult(error, result.Pass());
resolver_->DeleteJob(this);
}
void MojoProxyResolverImpl::Job::OnConnectionError() {
resolver_->DeleteJob(this);
}
} // namespace net
|
