blob: 1992a8f8626b9ece3d0f14ce0067522fc9a43580 (
plain)
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
|
// Copyright (c) 2012 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 "remoting/host/dns_blackhole_checker.h"
#include "googleurl/src/gurl.h"
#include "net/url_request/url_fetcher.h"
#include "net/url_request/url_request_context_getter.h"
namespace remoting {
// Default prefix added to the base talkgadget URL.
const char kDefaultHostTalkGadgetPrefix[] = "chromoting-host";
// The base talkgadget URL.
const char kTalkGadgetUrl[] = ".talkgadget.google.com/talkgadget/"
"oauth/chrome-remote-desktop-host";
DnsBlackholeChecker::DnsBlackholeChecker(
scoped_refptr<net::URLRequestContextGetter> url_request_context_getter,
std::string talkgadget_prefix)
: url_request_context_getter_(url_request_context_getter),
talkgadget_prefix_(talkgadget_prefix) {
}
DnsBlackholeChecker::~DnsBlackholeChecker() {
}
// This is called in response to the TalkGadget http request initiated from
// CheckStatus().
void DnsBlackholeChecker::OnURLFetchComplete(const net::URLFetcher* source) {
int response = source->GetResponseCode();
bool allow = false;
if (source->GetResponseCode() == 200) {
LOG(INFO) << "Successfully connected to host talkgadget.";
allow = true;
} else {
LOG(INFO) << "Unable to connect to host talkgadget (" << response << ")";
}
url_fetcher_.reset(NULL);
callback_.Run(allow);
callback_.Reset();
}
void DnsBlackholeChecker::CheckForDnsBlackhole(
const base::Callback<void(bool)>& callback) {
// Make sure we're not currently in the middle of a connection check.
if (!url_fetcher_.get()) {
DCHECK(callback_.is_null());
callback_ = callback;
std::string talkgadget_url("https://");
if (talkgadget_prefix_.empty()) {
talkgadget_url += kDefaultHostTalkGadgetPrefix;
} else {
talkgadget_url += talkgadget_prefix_;
}
talkgadget_url += kTalkGadgetUrl;
LOG(INFO) << "Verifying connection to " << talkgadget_url;
url_fetcher_.reset(net::URLFetcher::Create(GURL(talkgadget_url),
net::URLFetcher::GET, this));
url_fetcher_->SetRequestContext(url_request_context_getter_.get());
url_fetcher_->Start();
} else {
LOG(INFO) << "Pending connection check";
}
}
} // namespace remoting
|
