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
|
// Copyright 2014 The Chromium OS 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 "apmanager/shill_proxy.h"
#include <base/bind.h>
#include <chromeos/dbus/service_constants.h>
#include <chromeos/errors/error.h>
using std::string;
namespace apmanager {
// static.
const char ShillProxy::kManagerPath[] = "/";
ShillProxy::ShillProxy() {}
ShillProxy::~ShillProxy() {}
void ShillProxy::Init(const scoped_refptr<dbus::Bus>& bus) {
CHECK(!manager_proxy_) << "Already init";
manager_proxy_.reset(
new org::chromium::flimflam::ManagerProxy(
bus, shill::kFlimflamServiceName, dbus::ObjectPath(kManagerPath)));
// This will connect the name owner changed signal in DBus object proxy,
// The callback will be invoked as soon as service is avalilable. and will
// be cleared after it is invoked. So this will be an one time callback.
manager_proxy_->GetObjectProxy()->WaitForServiceToBeAvailable(
base::Bind(&ShillProxy::OnServiceAvailable, base::Unretained(this)));
// This will continuously monitor the name owner of the service. However,
// it does not connect the name owner changed signal in DBus object proxy
// for some reason. In order to connect the name owner changed signal,
// either WaitForServiceToBeAvaiable or ConnectToSignal need to be invoked.
// Since we're not interested in any signals from Shill proxy,
// WaitForServiceToBeAvailable is used.
manager_proxy_->GetObjectProxy()->SetNameOwnerChangedCallback(
base::Bind(&ShillProxy::OnServiceNameChanged, base::Unretained(this)));
}
void ShillProxy::ClaimInterface(const string& interface_name) {
CHECK(manager_proxy_) << "Proxy not initialize yet";
chromeos::ErrorPtr error;
if (!manager_proxy_->ClaimInterface(kServiceName, interface_name, &error)) {
// Ignore unknown object error (when shill is not running). Only report
// internal error from shill.
if (error->GetCode() != DBUS_ERROR_UNKNOWN_OBJECT) {
LOG(ERROR) << "Failed to claim interface from shill: "
<< error->GetCode() << " " << error->GetMessage();
}
}
claimed_interfaces_.insert(interface_name);
}
void ShillProxy::ReleaseInterface(const string& interface_name) {
CHECK(manager_proxy_) << "Proxy not initialize yet";
chromeos::ErrorPtr error;
if (!manager_proxy_->ReleaseInterface(kServiceName, interface_name, &error)) {
// Ignore unknown object error (when shill is not running). Only report
// internal error from shill.
if (error->GetCode() != DBUS_ERROR_UNKNOWN_OBJECT) {
LOG(ERROR) << "Failed to release interface from shill: "
<< error->GetCode() << " " << error->GetMessage();
}
}
claimed_interfaces_.erase(interface_name);
}
void ShillProxy::OnServiceAvailable(bool service_available) {
LOG(INFO) << "OnServiceAvailabe " << service_available;
// Nothing to be done if proxy service not available.
if (!service_available) {
return;
}
// Claim all interfaces from shill DBus service in case this is a new
// instance.
for (const auto& interface : claimed_interfaces_) {
chromeos::ErrorPtr error;
if (!manager_proxy_->ClaimInterface(kServiceName, interface, &error)) {
LOG(ERROR) << "Failed to claim interface from shill: "
<< error->GetCode() << " " << error->GetMessage();
}
}
}
void ShillProxy::OnServiceNameChanged(const string& old_owner,
const string& new_owner) {
LOG(INFO) << "OnServiceNameChanged old " << old_owner
<< " new " << new_owner;
// Nothing to be done if no owner is attached to the shill service.
if (new_owner.empty()) {
return;
}
OnServiceAvailable(true);
}
} // namespace apmanager
|
