5 * Copyright (C) 2007-2008 Intel Corporation. All rights reserved.
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
28 #include <sys/socket.h>
30 #include <linux/netlink.h>
31 #include <linux/rtnetlink.h>
33 #include <connman/plugin.h>
34 #include <connman/driver.h>
35 #include <connman/log.h>
37 static GStaticMutex ethernet_mutex = G_STATIC_MUTEX_INIT;
38 static GSList *ethernet_list = NULL;
40 static GStaticMutex element_mutex = G_STATIC_MUTEX_INIT;
41 static GSList *element_list = NULL;
43 static void create_element(struct connman_element *parent,
44 enum connman_element_type type)
46 struct connman_element *element;
48 DBG("parent %p name %s", parent, parent->name);
50 element = connman_element_create();
53 element->netdev.index = parent->netdev.index;
54 element->netdev.name = g_strdup(parent->netdev.name);
56 g_static_mutex_lock(&element_mutex);
57 element_list = g_slist_append(element_list, element);
58 g_static_mutex_unlock(&element_mutex);
60 connman_element_register(element, parent);
63 static void remove_elements(struct connman_element *parent)
65 GSList *list = element_list;
67 DBG("parent %p name %s", parent, parent->name);
69 g_static_mutex_lock(&element_mutex);
72 GSList *next = list->next;
73 struct connman_element *element = list->data;
75 if (element->netdev.index != parent->netdev.index) {
80 element_list = g_slist_delete_link(element_list, list);
82 connman_element_unregister(element);
84 connman_element_unref(element);
89 g_static_mutex_unlock(&element_mutex);
92 static void rtnl_link(struct nlmsghdr *hdr, const char *type)
95 struct ifinfomsg *msg;
98 msg = (struct ifinfomsg *) NLMSG_DATA(hdr);
99 bytes = IFLA_PAYLOAD(hdr);
101 DBG("%s ifi_index %d ifi_flags 0x%04x",
102 type, msg->ifi_index, msg->ifi_flags);
104 g_static_mutex_lock(ðernet_mutex);
106 for (list = ethernet_list; list; list = list->next) {
107 struct connman_element *element = list->data;
109 if (element->type != CONNMAN_ELEMENT_TYPE_DEVICE)
112 if (element->netdev.index != msg->ifi_index)
115 if ((element->netdev.flags & IFF_RUNNING) ==
116 (msg->ifi_flags & IFF_RUNNING))
119 element->netdev.flags = msg->ifi_flags;
121 if (msg->ifi_flags & IFF_RUNNING) {
124 create_element(element, CONNMAN_ELEMENT_TYPE_DHCP);
125 create_element(element, CONNMAN_ELEMENT_TYPE_ZEROCONF);
129 remove_elements(element);
133 g_static_mutex_unlock(ðernet_mutex);
136 static gboolean rtnl_event(GIOChannel *chan, GIOCondition cond, gpointer data)
138 unsigned char buf[1024];
143 if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
146 memset(buf, 0, sizeof(buf));
148 err = g_io_channel_read(chan, (gchar *) buf, sizeof(buf), &len);
150 if (err == G_IO_ERROR_AGAIN)
155 DBG("buf %p len %zd", buf, len);
158 struct nlmsghdr *hdr = ptr;
159 struct nlmsgerr *err;
161 if (!NLMSG_OK(hdr, len))
164 DBG("len %d type %d flags 0x%04x seq %d",
165 hdr->nlmsg_len, hdr->nlmsg_type,
166 hdr->nlmsg_flags, hdr->nlmsg_seq);
168 switch (hdr->nlmsg_type) {
170 err = NLMSG_DATA(hdr);
171 DBG("ERROR %d (%s)", -err->error,
172 strerror(-err->error));
176 rtnl_link(hdr, "NEWLINK");
180 rtnl_link(hdr, "DELLINK");
184 len -= hdr->nlmsg_len;
185 ptr += hdr->nlmsg_len;
191 static GIOChannel *channel = NULL;
193 static int rtnl_request(void)
200 struct sockaddr_nl addr;
205 memset(&req, 0, sizeof(req));
206 req.hdr.nlmsg_len = sizeof(req.hdr) + sizeof(req.msg);
207 req.hdr.nlmsg_type = RTM_GETLINK;
208 req.hdr.nlmsg_flags = NLM_F_REQUEST | NLM_F_DUMP;
209 req.hdr.nlmsg_pid = 0;
210 req.hdr.nlmsg_seq = 42;
211 req.msg.rtgen_family = AF_INET;
213 sk = g_io_channel_unix_get_fd(channel);
215 memset(&addr, 0, sizeof(addr));
216 addr.nl_family = AF_NETLINK;
218 return sendto(sk, &req, sizeof(req), 0,
219 (struct sockaddr *) &addr, sizeof(addr));
222 static int ethernet_probe(struct connman_element *element)
224 DBG("element %p name %s", element, element->name);
226 g_static_mutex_lock(ðernet_mutex);
227 ethernet_list = g_slist_append(ethernet_list, element);
228 g_static_mutex_unlock(ðernet_mutex);
235 static void ethernet_remove(struct connman_element *element)
237 DBG("element %p name %s", element, element->name);
239 remove_elements(element);
241 g_static_mutex_lock(ðernet_mutex);
242 ethernet_list = g_slist_remove(ethernet_list, element);
243 g_static_mutex_unlock(ðernet_mutex);
246 static struct connman_driver ethernet_driver = {
248 .type = CONNMAN_ELEMENT_TYPE_DEVICE,
249 .subtype = CONNMAN_ELEMENT_SUBTYPE_ETHERNET,
250 .probe = ethernet_probe,
251 .remove = ethernet_remove,
254 static int rtnl_init(void)
256 struct sockaddr_nl addr;
261 sk = socket(PF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE);
265 memset(&addr, 0, sizeof(addr));
266 addr.nl_family = AF_NETLINK;
267 addr.nl_groups = RTMGRP_LINK;
269 if (bind(sk, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
275 channel = g_io_channel_unix_new(sk);
276 g_io_channel_set_close_on_unref(channel, TRUE);
278 g_io_add_watch(channel, G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
284 static void rtnl_cleanup(void)
288 g_io_channel_shutdown(channel, TRUE, NULL);
289 g_io_channel_unref(channel);
294 static int ethernet_init(void)
302 err = connman_driver_register(ðernet_driver);
311 static void ethernet_exit(void)
313 connman_driver_unregister(ðernet_driver);
318 CONNMAN_PLUGIN_DEFINE("ethernet", "Ethernet interface plugin", VERSION,
319 ethernet_init, ethernet_exit)