1 /*
2 * Copyright (C) 2008 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17 #include <stdarg.h>
18 #include <stdio.h>
19 #include <stdlib.h>
20 #include <string.h>
21 #include <errno.h>
22
23 #define LOG_TAG "Netd"
24
25 #include <cutils/log.h>
26
27 #include <netutils/ifc.h>
28 #include <sysutils/NetlinkEvent.h>
29 #include "NetlinkHandler.h"
30 #include "NetlinkManager.h"
31 #include "ResponseCode.h"
32
33 static const char *kUpdated = "updated";
34 static const char *kRemoved = "removed";
35
NetlinkHandler(NetlinkManager * nm,int listenerSocket,int format)36 NetlinkHandler::NetlinkHandler(NetlinkManager *nm, int listenerSocket,
37 int format) :
38 NetlinkListener(listenerSocket, format) {
39 mNm = nm;
40 }
41
~NetlinkHandler()42 NetlinkHandler::~NetlinkHandler() {
43 }
44
start()45 int NetlinkHandler::start() {
46 return this->startListener();
47 }
48
stop()49 int NetlinkHandler::stop() {
50 return this->stopListener();
51 }
52
onEvent(NetlinkEvent * evt)53 void NetlinkHandler::onEvent(NetlinkEvent *evt) {
54 const char *subsys = evt->getSubsystem();
55 if (!subsys) {
56 ALOGW("No subsystem found in netlink event");
57 return;
58 }
59
60 if (!strcmp(subsys, "net")) {
61 int action = evt->getAction();
62 const char *iface = evt->findParam("INTERFACE");
63
64 if (action == evt->NlActionAdd) {
65 notifyInterfaceAdded(iface);
66 } else if (action == evt->NlActionRemove) {
67 notifyInterfaceRemoved(iface);
68 } else if (action == evt->NlActionChange) {
69 evt->dump();
70 notifyInterfaceChanged("nana", true);
71 } else if (action == evt->NlActionLinkUp) {
72 notifyInterfaceLinkChanged(iface, true);
73 } else if (action == evt->NlActionLinkDown) {
74 notifyInterfaceLinkChanged(iface, false);
75 } else if (action == evt->NlActionAddressUpdated ||
76 action == evt->NlActionAddressRemoved) {
77 const char *address = evt->findParam("ADDRESS");
78 const char *flags = evt->findParam("FLAGS");
79 const char *scope = evt->findParam("SCOPE");
80 if (action == evt->NlActionAddressRemoved && iface && address) {
81 int resetMask = strchr(address, ':') ? RESET_IPV6_ADDRESSES : RESET_IPV4_ADDRESSES;
82 resetMask |= RESET_IGNORE_INTERFACE_ADDRESS;
83 if (int ret = ifc_reset_connections(iface, resetMask)) {
84 ALOGE("ifc_reset_connections failed on iface %s for address %s (%s)", iface,
85 address, strerror(ret));
86 }
87 }
88 if (iface && flags && scope) {
89 notifyAddressChanged(action, address, iface, flags, scope);
90 }
91 } else if (action == evt->NlActionRdnss) {
92 const char *lifetime = evt->findParam("LIFETIME");
93 const char *servers = evt->findParam("SERVERS");
94 if (lifetime && servers) {
95 notifyInterfaceDnsServers(iface, lifetime, servers);
96 }
97 } else if (action == evt->NlActionRouteUpdated ||
98 action == evt->NlActionRouteRemoved) {
99 const char *route = evt->findParam("ROUTE");
100 const char *gateway = evt->findParam("GATEWAY");
101 const char *iface = evt->findParam("INTERFACE");
102 if (route && (gateway || iface)) {
103 notifyRouteChange(action, route, gateway, iface);
104 }
105 }
106
107 } else if (!strcmp(subsys, "qlog")) {
108 const char *alertName = evt->findParam("ALERT_NAME");
109 const char *iface = evt->findParam("INTERFACE");
110 notifyQuotaLimitReached(alertName, iface);
111
112 } else if (!strcmp(subsys, "xt_idletimer")) {
113 const char *label = evt->findParam("INTERFACE");
114 const char *state = evt->findParam("STATE");
115 const char *timestamp = evt->findParam("TIME_NS");
116 if (state)
117 notifyInterfaceClassActivity(label, !strcmp("active", state), timestamp);
118
119 #if !LOG_NDEBUG
120 } else if (strcmp(subsys, "platform") && strcmp(subsys, "backlight")) {
121 /* It is not a VSYNC or a backlight event */
122 ALOGV("unexpected event from subsystem %s", subsys);
123 #endif
124 }
125 }
126
notify(int code,const char * format,...)127 void NetlinkHandler::notify(int code, const char *format, ...) {
128 char *msg;
129 va_list args;
130 va_start(args, format);
131 if (vasprintf(&msg, format, args) >= 0) {
132 mNm->getBroadcaster()->sendBroadcast(code, msg, false);
133 free(msg);
134 } else {
135 SLOGE("Failed to send notification: vasprintf: %s", strerror(errno));
136 }
137 va_end(args);
138 }
139
notifyInterfaceAdded(const char * name)140 void NetlinkHandler::notifyInterfaceAdded(const char *name) {
141 notify(ResponseCode::InterfaceChange, "Iface added %s", name);
142 }
143
notifyInterfaceRemoved(const char * name)144 void NetlinkHandler::notifyInterfaceRemoved(const char *name) {
145 notify(ResponseCode::InterfaceChange, "Iface removed %s", name);
146 }
147
notifyInterfaceChanged(const char * name,bool isUp)148 void NetlinkHandler::notifyInterfaceChanged(const char *name, bool isUp) {
149 notify(ResponseCode::InterfaceChange,
150 "Iface changed %s %s", name, (isUp ? "up" : "down"));
151 }
152
notifyInterfaceLinkChanged(const char * name,bool isUp)153 void NetlinkHandler::notifyInterfaceLinkChanged(const char *name, bool isUp) {
154 notify(ResponseCode::InterfaceChange,
155 "Iface linkstate %s %s", name, (isUp ? "up" : "down"));
156 }
157
notifyQuotaLimitReached(const char * name,const char * iface)158 void NetlinkHandler::notifyQuotaLimitReached(const char *name, const char *iface) {
159 notify(ResponseCode::BandwidthControl, "limit alert %s %s", name, iface);
160 }
161
notifyInterfaceClassActivity(const char * name,bool isActive,const char * timestamp)162 void NetlinkHandler::notifyInterfaceClassActivity(const char *name,
163 bool isActive, const char *timestamp) {
164 if (timestamp == NULL)
165 notify(ResponseCode::InterfaceClassActivity,
166 "IfaceClass %s %s", isActive ? "active" : "idle", name);
167 else
168 notify(ResponseCode::InterfaceClassActivity,
169 "IfaceClass %s %s %s", isActive ? "active" : "idle", name, timestamp);
170 }
171
notifyAddressChanged(int action,const char * addr,const char * iface,const char * flags,const char * scope)172 void NetlinkHandler::notifyAddressChanged(int action, const char *addr,
173 const char *iface, const char *flags,
174 const char *scope) {
175 notify(ResponseCode::InterfaceAddressChange,
176 "Address %s %s %s %s %s",
177 (action == NetlinkEvent::NlActionAddressUpdated) ? kUpdated : kRemoved,
178 addr, iface, flags, scope);
179 }
180
notifyInterfaceDnsServers(const char * iface,const char * lifetime,const char * servers)181 void NetlinkHandler::notifyInterfaceDnsServers(const char *iface,
182 const char *lifetime,
183 const char *servers) {
184 notify(ResponseCode::InterfaceDnsInfo, "DnsInfo servers %s %s %s",
185 iface, lifetime, servers);
186 }
187
notifyRouteChange(int action,const char * route,const char * gateway,const char * iface)188 void NetlinkHandler::notifyRouteChange(int action, const char *route,
189 const char *gateway, const char *iface) {
190 notify(ResponseCode::RouteChange,
191 "Route %s %s%s%s%s%s",
192 (action == NetlinkEvent::NlActionRouteUpdated) ? kUpdated : kRemoved,
193 route,
194 *gateway ? " via " : "",
195 gateway,
196 *iface ? " dev " : "",
197 iface);
198 }
199