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
|
// Copyright (c) 2011 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/base/single_request_host_resolver.h"
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/compiler_specific.h"
#include "base/logging.h"
#include "net/base/net_errors.h"
namespace net {
SingleRequestHostResolver::SingleRequestHostResolver(HostResolver* resolver)
: resolver_(resolver),
cur_request_(NULL),
ALLOW_THIS_IN_INITIALIZER_LIST(callback_(
base::Bind(&SingleRequestHostResolver::OnResolveCompletion,
base::Unretained(this)))) {
DCHECK(resolver_ != NULL);
}
SingleRequestHostResolver::~SingleRequestHostResolver() {
Cancel();
}
int SingleRequestHostResolver::Resolve(
const HostResolver::RequestInfo& info, AddressList* addresses,
const CompletionCallback& callback, const BoundNetLog& net_log) {
DCHECK(addresses);
DCHECK_EQ(false, callback.is_null());
DCHECK(cur_request_callback_.is_null()) << "resolver already in use";
HostResolver::RequestHandle request = NULL;
// We need to be notified of completion before |callback| is called, so that
// we can clear out |cur_request_*|.
CompletionCallback transient_callback =
callback.is_null() ? CompletionCallback() : callback_;
int rv = resolver_->Resolve(
info, addresses, transient_callback, &request, net_log);
if (rv == ERR_IO_PENDING) {
DCHECK_EQ(false, callback.is_null());
// Cleared in OnResolveCompletion().
cur_request_ = request;
cur_request_callback_ = callback;
}
return rv;
}
void SingleRequestHostResolver::Cancel() {
if (!cur_request_callback_.is_null()) {
resolver_->CancelRequest(cur_request_);
cur_request_ = NULL;
cur_request_callback_.Reset();
}
}
void SingleRequestHostResolver::OnResolveCompletion(int result) {
DCHECK(cur_request_);
DCHECK_EQ(false, cur_request_callback_.is_null());
CompletionCallback callback = cur_request_callback_;
// Clear the outstanding request information.
cur_request_ = NULL;
cur_request_callback_.Reset();
// Call the user's original callback.
callback.Run(result);
}
} // namespace net
|
