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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
// Copyright 2017 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromeos/ash/components/tether/network_connection_handler_tether_delegate.h"
#include "base/containers/contains.h"
#include "base/functional/bind.h"
#include "base/functional/callback_helpers.h"
#include "chromeos/ash/components/multidevice/logging/logging.h"
#include "chromeos/ash/components/tether/active_host.h"
#include "chromeos/ash/components/tether/tether_connector.h"
#include "chromeos/ash/components/tether/tether_disconnector.h"
namespace ash {
namespace tether {
namespace {
void OnFailedDisconnectionFromPreviousHost(
const std::string& tether_network_guid,
const std::string& error_name) {
PA_LOG(ERROR) << "Failed to disconnect from previously-active host. "
<< "GUID: " << tether_network_guid << ", Error: " << error_name;
}
} // namespace
NetworkConnectionHandlerTetherDelegate::Callbacks::Callbacks(
base::OnceClosure success_callback,
StringErrorCallback error_callback)
: success_callback(std::move(success_callback)),
error_callback(std::move(error_callback)) {}
NetworkConnectionHandlerTetherDelegate::Callbacks::Callbacks(Callbacks&&) =
default;
NetworkConnectionHandlerTetherDelegate::Callbacks::~Callbacks() = default;
NetworkConnectionHandlerTetherDelegate::NetworkConnectionHandlerTetherDelegate(
NetworkConnectionHandler* network_connection_handler,
ActiveHost* active_host,
TetherConnector* tether_connector,
TetherDisconnector* tether_disconnector)
: network_connection_handler_(network_connection_handler),
active_host_(active_host),
tether_connector_(tether_connector),
tether_disconnector_(tether_disconnector) {
network_connection_handler_->SetTetherDelegate(this);
}
NetworkConnectionHandlerTetherDelegate::
~NetworkConnectionHandlerTetherDelegate() {
// If there are still pending callbacks, invoke them here. It should never be
// possible for the Tether component to shut down with pending callbacks.
for (auto& entry : request_num_to_callbacks_map_) {
std::move(entry.second.error_callback)
.Run(NetworkConnectionHandler::kErrorConnectFailed);
}
network_connection_handler_->SetTetherDelegate(nullptr);
}
void NetworkConnectionHandlerTetherDelegate::DisconnectFromNetwork(
const std::string& tether_network_guid,
base::OnceClosure success_callback,
StringErrorCallback error_callback) {
int request_num = next_request_num_++;
request_num_to_callbacks_map_.emplace(
request_num,
Callbacks(std::move(success_callback), std::move(error_callback)));
tether_disconnector_->DisconnectFromNetwork(
tether_network_guid,
base::BindOnce(&NetworkConnectionHandlerTetherDelegate::OnRequestSuccess,
weak_ptr_factory_.GetWeakPtr(), request_num),
base::BindOnce(&NetworkConnectionHandlerTetherDelegate::OnRequestError,
weak_ptr_factory_.GetWeakPtr(), request_num),
TetherSessionCompletionLogger::SessionCompletionReason::
USER_DISCONNECTED);
}
void NetworkConnectionHandlerTetherDelegate::ConnectToNetwork(
const std::string& tether_network_guid,
base::OnceClosure success_callback,
StringErrorCallback error_callback) {
if (active_host_->GetActiveHostStatus() ==
ActiveHost::ActiveHostStatus::CONNECTED) {
if (active_host_->GetTetherNetworkGuid() == tether_network_guid) {
PA_LOG(WARNING) << "Received a request to connect to Tether network with "
<< "GUID " << tether_network_guid << ", but that network "
<< "is already connected. Ignoring this request.";
std::move(error_callback).Run(NetworkConnectionHandler::kErrorConnected);
return;
}
std::string previous_host_guid = active_host_->GetTetherNetworkGuid();
DCHECK(!previous_host_guid.empty());
PA_LOG(VERBOSE) << "Connection requested to GUID " << tether_network_guid
<< ", but there is already an active connection. "
<< "Disconnecting from network with GUID "
<< previous_host_guid << ".";
DisconnectFromNetwork(previous_host_guid, base::DoNothing(),
base::BindOnce(&OnFailedDisconnectionFromPreviousHost,
previous_host_guid));
}
int request_num = next_request_num_++;
request_num_to_callbacks_map_.emplace(
request_num,
Callbacks(std::move(success_callback), std::move(error_callback)));
tether_connector_->ConnectToNetwork(
tether_network_guid,
base::BindOnce(&NetworkConnectionHandlerTetherDelegate::OnRequestSuccess,
weak_ptr_factory_.GetWeakPtr(), request_num),
base::BindOnce(&NetworkConnectionHandlerTetherDelegate::OnRequestError,
weak_ptr_factory_.GetWeakPtr(), request_num));
}
void NetworkConnectionHandlerTetherDelegate::OnRequestSuccess(int request_num) {
DCHECK(base::Contains(request_num_to_callbacks_map_, request_num));
std::move(request_num_to_callbacks_map_.at(request_num).success_callback)
.Run();
request_num_to_callbacks_map_.erase(request_num);
}
void NetworkConnectionHandlerTetherDelegate::OnRequestError(
int request_num,
const std::string& error_name) {
DCHECK(base::Contains(request_num_to_callbacks_map_, request_num));
std::move(request_num_to_callbacks_map_.at(request_num).error_callback)
.Run(error_name);
request_num_to_callbacks_map_.erase(request_num);
}
} // namespace tether
} // namespace ash
|
