5 * Copyright (C) 2007-2009 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
29 #include <sys/ioctl.h>
30 #include <arpa/inet.h>
32 #include <net/route.h>
41 struct connman_element *element;
46 static GSList *gateway_list = NULL;
48 static struct gateway_data *find_gateway(int index, const char *gateway)
55 for (list = gateway_list; list; list = list->next) {
56 struct gateway_data *data = list->data;
58 if (data->gateway == NULL)
61 if (data->index == index &&
62 g_str_equal(data->gateway, gateway) == TRUE)
69 static int set_route(struct connman_element *element, const char *gateway)
73 struct sockaddr_in *addr;
76 DBG("element %p", element);
78 sk = socket(PF_INET, SOCK_DGRAM, 0);
82 memset(&ifr, 0, sizeof(ifr));
83 ifr.ifr_ifindex = element->index;
85 if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
90 DBG("ifname %s", ifr.ifr_name);
92 memset(&rt, 0, sizeof(rt));
93 rt.rt_flags = RTF_UP | RTF_HOST;
95 addr = (struct sockaddr_in *) &rt.rt_dst;
96 addr->sin_family = AF_INET;
97 addr->sin_addr.s_addr = inet_addr(gateway);
99 addr = (struct sockaddr_in *) &rt.rt_gateway;
100 addr->sin_family = AF_INET;
101 addr->sin_addr.s_addr = INADDR_ANY;
103 addr = (struct sockaddr_in *) &rt.rt_genmask;
104 addr->sin_family = AF_INET;
105 addr->sin_addr.s_addr = INADDR_ANY;
107 rt.rt_dev = ifr.ifr_name;
109 err = ioctl(sk, SIOCADDRT, &rt);
111 connman_error("Setting host gateway route failed (%s)",
114 memset(&rt, 0, sizeof(rt));
115 rt.rt_flags = RTF_UP | RTF_GATEWAY;
117 addr = (struct sockaddr_in *) &rt.rt_dst;
118 addr->sin_family = AF_INET;
119 addr->sin_addr.s_addr = INADDR_ANY;
121 addr = (struct sockaddr_in *) &rt.rt_gateway;
122 addr->sin_family = AF_INET;
123 addr->sin_addr.s_addr = inet_addr(gateway);
125 addr = (struct sockaddr_in *) &rt.rt_genmask;
126 addr->sin_family = AF_INET;
127 addr->sin_addr.s_addr = INADDR_ANY;
129 err = ioctl(sk, SIOCADDRT, &rt);
131 connman_error("Setting default route failed (%s)",
139 static int del_route(struct connman_element *element, const char *gateway)
143 struct sockaddr_in *addr;
146 DBG("element %p", element);
148 sk = socket(PF_INET, SOCK_DGRAM, 0);
152 memset(&ifr, 0, sizeof(ifr));
153 ifr.ifr_ifindex = element->index;
155 if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
160 DBG("ifname %s", ifr.ifr_name);
162 memset(&rt, 0, sizeof(rt));
163 rt.rt_flags = RTF_UP | RTF_GATEWAY;
165 addr = (struct sockaddr_in *) &rt.rt_dst;
166 addr->sin_family = AF_INET;
167 addr->sin_addr.s_addr = INADDR_ANY;
169 addr = (struct sockaddr_in *) &rt.rt_gateway;
170 addr->sin_family = AF_INET;
171 addr->sin_addr.s_addr = inet_addr(gateway);
173 addr = (struct sockaddr_in *) &rt.rt_genmask;
174 addr->sin_family = AF_INET;
175 addr->sin_addr.s_addr = INADDR_ANY;
177 err = ioctl(sk, SIOCDELRT, &rt);
179 connman_error("Removing default route failed (%s)",
187 static DBusConnection *connection;
189 static void emit_default_signal(struct connman_element *element)
192 DBusMessageIter entry, value;
193 const char *key = "Default";
195 signal = dbus_message_new_signal(element->path,
196 CONNMAN_CONNECTION_INTERFACE, "PropertyChanged");
200 dbus_message_iter_init_append(signal, &entry);
202 dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key);
204 dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT,
205 DBUS_TYPE_BOOLEAN_AS_STRING, &value);
206 dbus_message_iter_append_basic(&value, DBUS_TYPE_BOOLEAN,
208 dbus_message_iter_close_container(&entry, &value);
210 g_dbus_send_message(connection, signal);
213 static void find_element(struct connman_element *element, gpointer user_data)
215 struct gateway_data *data = user_data;
217 DBG("element %p name %s", element, element->name);
219 if (data->element != NULL)
222 if (element->index != data->index)
225 data->element = element;
228 static struct gateway_data *add_gateway(int index, const char *gateway)
230 struct gateway_data *data;
231 struct connman_service *service;
233 data = g_try_new0(struct gateway_data, 1);
238 data->gateway = g_strdup(gateway);
239 data->active = FALSE;
240 data->element = NULL;
242 __connman_element_foreach(NULL, CONNMAN_ELEMENT_TYPE_CONNECTION,
245 service = __connman_element_get_service(data->element);
246 data->order = __connman_service_get_order(service);
248 gateway_list = g_slist_append(gateway_list, data);
253 static void connection_newgateway(int index, const char *gateway)
255 struct gateway_data *data;
257 DBG("index %d gateway %s", index, gateway);
259 data = find_gateway(index, gateway);
266 static void set_default_gateway(struct gateway_data *data)
268 struct connman_element *element = data->element;
269 struct connman_service *service = NULL;
271 DBG("gateway %s", data->gateway);
273 if (set_route(element, data->gateway) < 0)
276 service = __connman_element_get_service(element);
277 __connman_service_indicate_default(service);
280 static struct gateway_data *find_default_gateway(void)
282 struct gateway_data *found = NULL;
283 unsigned int order = 0;
286 for (list = gateway_list; list; list = list->next) {
287 struct gateway_data *data = list->data;
289 if (found == NULL || data->order > order) {
298 static void remove_gateway(struct gateway_data *data)
300 DBG("gateway %s", data->gateway);
302 gateway_list = g_slist_remove(gateway_list, data);
304 if (data->active == TRUE)
305 del_route(data->element, data->gateway);
307 g_free(data->gateway);
311 static void connection_delgateway(int index, const char *gateway)
313 struct gateway_data *data;
315 DBG("index %d gateway %s", index, gateway);
317 data = find_gateway(index, gateway);
319 data->active = FALSE;
321 data = find_default_gateway();
323 set_default_gateway(data);
326 static struct connman_rtnl connection_rtnl = {
327 .name = "connection",
328 .newgateway = connection_newgateway,
329 .delgateway = connection_delgateway,
332 static DBusMessage *get_properties(DBusConnection *conn,
333 DBusMessage *msg, void *data)
335 struct connman_element *element = data;
337 DBusMessageIter array, dict;
338 connman_uint8_t strength;
339 const char *device, *network;
342 DBG("conn %p", conn);
344 if (__connman_security_check_privilege(msg,
345 CONNMAN_SECURITY_PRIVILEGE_PUBLIC) < 0)
346 return __connman_error_permission_denied(msg);
348 reply = dbus_message_new_method_return(msg);
352 dbus_message_iter_init_append(reply, &array);
354 dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
355 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
356 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
357 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
359 type = connman_element_get_string(element, "Type");
361 connman_dbus_dict_append_variant(&dict, "Type",
362 DBUS_TYPE_STRING, &type);
364 strength = connman_element_get_uint8(element, "Strength");
366 connman_dbus_dict_append_variant(&dict, "Strength",
367 DBUS_TYPE_BYTE, &strength);
369 if (element->devname != NULL)
370 connman_dbus_dict_append_variant(&dict, "Interface",
371 DBUS_TYPE_STRING, &element->devname);
373 connman_dbus_dict_append_variant(&dict, "Default",
374 DBUS_TYPE_BOOLEAN, &element->enabled);
376 device = __connman_element_get_device_path(element);
378 connman_dbus_dict_append_variant(&dict, "Device",
379 DBUS_TYPE_OBJECT_PATH, &device);
381 network = __connman_element_get_network_path(element);
383 connman_dbus_dict_append_variant(&dict, "Network",
384 DBUS_TYPE_OBJECT_PATH, &network);
386 __connman_element_append_ipv4(element, &dict);
388 dbus_message_iter_close_container(&array, &dict);
393 static DBusMessage *set_property(DBusConnection *conn,
394 DBusMessage *msg, void *data)
396 DBusMessageIter iter, value;
400 DBG("conn %p", conn);
402 if (dbus_message_iter_init(msg, &iter) == FALSE)
403 return __connman_error_invalid_arguments(msg);
405 dbus_message_iter_get_basic(&iter, &name);
406 dbus_message_iter_next(&iter);
407 dbus_message_iter_recurse(&iter, &value);
409 if (__connman_security_check_privilege(msg,
410 CONNMAN_SECURITY_PRIVILEGE_MODIFY) < 0)
411 return __connman_error_permission_denied(msg);
413 type = dbus_message_iter_get_arg_type(&value);
415 return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
418 static GDBusMethodTable connection_methods[] = {
419 { "GetProperties", "", "a{sv}", get_properties },
420 { "SetProperty", "sv", "", set_property },
424 static GDBusSignalTable connection_signals[] = {
425 { "PropertyChanged", "sv" },
429 static void append_connections(DBusMessageIter *entry)
431 DBusMessageIter value, iter;
432 const char *key = "Connections";
434 dbus_message_iter_append_basic(entry, DBUS_TYPE_STRING, &key);
436 dbus_message_iter_open_container(entry, DBUS_TYPE_VARIANT,
437 DBUS_TYPE_ARRAY_AS_STRING DBUS_TYPE_OBJECT_PATH_AS_STRING,
440 dbus_message_iter_open_container(&value, DBUS_TYPE_ARRAY,
441 DBUS_TYPE_OBJECT_PATH_AS_STRING, &iter);
442 __connman_element_list(NULL, CONNMAN_ELEMENT_TYPE_CONNECTION, &iter);
443 dbus_message_iter_close_container(&value, &iter);
445 dbus_message_iter_close_container(entry, &value);
448 static void emit_connections_signal(void)
451 DBusMessageIter entry;
455 signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH,
456 CONNMAN_MANAGER_INTERFACE, "PropertyChanged");
460 dbus_message_iter_init_append(signal, &entry);
462 append_connections(&entry);
464 g_dbus_send_message(connection, signal);
467 static int register_interface(struct connman_element *element)
469 DBG("element %p name %s path %s",
470 element, element->name, element->path);
472 if (g_dbus_register_interface(connection, element->path,
473 CONNMAN_CONNECTION_INTERFACE,
474 connection_methods, connection_signals,
475 NULL, element, NULL) == FALSE) {
476 connman_error("Failed to register %s connection", element->path);
480 emit_connections_signal();
485 static void unregister_interface(struct connman_element *element)
487 DBG("element %p name %s", element, element->name);
489 emit_connections_signal();
491 g_dbus_unregister_interface(connection, element->path,
492 CONNMAN_CONNECTION_INTERFACE);
495 static struct gateway_data *find_active_gateway(void)
501 for (list = gateway_list; list; list = list->next) {
502 struct gateway_data *data = list->data;
503 if (data->active == TRUE)
510 static int connection_probe(struct connman_element *element)
512 struct connman_service *service = NULL;
513 const char *gateway = NULL;
514 struct gateway_data *active_gateway = NULL;
515 struct gateway_data *new_gateway = NULL;
517 DBG("element %p name %s", element, element->name);
519 if (element->parent == NULL)
522 if (element->parent->type != CONNMAN_ELEMENT_TYPE_IPV4)
525 connman_element_get_value(element,
526 CONNMAN_PROPERTY_ID_IPV4_GATEWAY, &gateway);
528 DBG("gateway %s", gateway);
530 if (register_interface(element) < 0)
532 service = __connman_element_get_service(element);
533 __connman_service_indicate_state(service,
534 CONNMAN_SERVICE_STATE_READY);
535 connman_element_set_enabled(element, TRUE);
536 emit_default_signal(element);
541 active_gateway = find_active_gateway();
542 new_gateway = add_gateway(element->index, gateway);
544 if (active_gateway == NULL) {
545 set_default_gateway(new_gateway);
549 if (new_gateway->order >= active_gateway->order) {
550 del_route(active_gateway->element, active_gateway->gateway);
557 static void connection_remove(struct connman_element *element)
559 struct connman_service *service;
560 const char *gateway = NULL;
561 struct gateway_data *data = NULL;
563 DBG("element %p name %s", element, element->name);
565 service = __connman_element_get_service(element);
566 __connman_service_indicate_state(service,
567 CONNMAN_SERVICE_STATE_DISCONNECT);
569 connman_element_set_enabled(element, FALSE);
570 emit_default_signal(element);
572 unregister_interface(element);
574 connman_element_get_value(element,
575 CONNMAN_PROPERTY_ID_IPV4_GATEWAY, &gateway);
577 DBG("gateway %s", gateway);
582 data = find_gateway(element->index, gateway);
586 remove_gateway(data);
589 static struct connman_driver connection_driver = {
590 .name = "connection",
591 .type = CONNMAN_ELEMENT_TYPE_CONNECTION,
592 .priority = CONNMAN_DRIVER_PRIORITY_LOW,
593 .probe = connection_probe,
594 .remove = connection_remove,
597 int __connman_connection_init(void)
601 connection = connman_dbus_get_connection();
603 if (connman_rtnl_register(&connection_rtnl) < 0)
604 connman_error("Failed to setup RTNL gateway driver");
606 connman_rtnl_send_getroute();
608 return connman_driver_register(&connection_driver);
611 void __connman_connection_cleanup(void)
617 connman_driver_unregister(&connection_driver);
619 connman_rtnl_unregister(&connection_rtnl);
621 for (list = gateway_list; list; list = list->next) {
622 struct gateway_data *data = list->data;
624 DBG("index %d gateway %s", data->index, data->gateway);
626 g_free(data->gateway);
631 g_slist_free(gateway_list);
634 dbus_connection_unref(connection);
637 static void update_order(void)
641 for (list = gateway_list; list; list = list->next) {
642 struct gateway_data *data = list->data;
643 struct connman_service *service;
645 service = __connman_element_get_service(data->element);
646 data->order = __connman_service_get_order(service);
650 void __connman_connection_update_gateway(void)
652 struct gateway_data *active_gateway, *default_gateway;
656 active_gateway = find_active_gateway();
657 default_gateway = find_default_gateway();
659 if (active_gateway && active_gateway != default_gateway)
660 del_route(active_gateway->element, active_gateway->gateway);