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);
247 data->order = __connman_service_get_order(service);
249 gateway_list = g_slist_append(gateway_list, data);
254 static void connection_newgateway(int index, const char *gateway)
256 struct gateway_data *data;
258 DBG("index %d gateway %s", index, gateway);
260 data = find_gateway(index, gateway);
267 static void set_default_gateway(struct gateway_data *data)
269 struct connman_element *element = data->element;
270 struct connman_service *service = NULL;
272 DBG("gateway %s", data->gateway);
274 if (set_route(element, data->gateway) < 0)
277 service = __connman_element_get_service(element);
278 __connman_service_indicate_default(service);
281 static struct gateway_data *find_default_gateway(void)
283 struct gateway_data *found = NULL;
286 for (list = gateway_list; list; list = list->next) {
287 struct gateway_data *data = list->data;
288 /* just return the last one for now */
295 static void remove_gateway(struct gateway_data *data)
297 DBG("gateway %s", data->gateway);
299 gateway_list = g_slist_remove(gateway_list, data);
301 if (data->active == TRUE)
302 del_route(data->element, data->gateway);
304 g_free(data->gateway);
308 static void connection_delgateway(int index, const char *gateway)
310 struct gateway_data *data;
312 DBG("index %d gateway %s", index, gateway);
314 data = find_gateway(index, gateway);
316 data->active = FALSE;
318 data = find_default_gateway();
320 set_default_gateway(data);
323 static struct connman_rtnl connection_rtnl = {
324 .name = "connection",
325 .newgateway = connection_newgateway,
326 .delgateway = connection_delgateway,
329 static DBusMessage *get_properties(DBusConnection *conn,
330 DBusMessage *msg, void *data)
332 struct connman_element *element = data;
334 DBusMessageIter array, dict;
335 connman_uint8_t strength;
336 const char *device, *network;
339 DBG("conn %p", conn);
341 if (__connman_security_check_privilege(msg,
342 CONNMAN_SECURITY_PRIVILEGE_PUBLIC) < 0)
343 return __connman_error_permission_denied(msg);
345 reply = dbus_message_new_method_return(msg);
349 dbus_message_iter_init_append(reply, &array);
351 dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
352 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
353 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
354 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
356 type = connman_element_get_string(element, "Type");
358 connman_dbus_dict_append_variant(&dict, "Type",
359 DBUS_TYPE_STRING, &type);
361 strength = connman_element_get_uint8(element, "Strength");
363 connman_dbus_dict_append_variant(&dict, "Strength",
364 DBUS_TYPE_BYTE, &strength);
366 if (element->devname != NULL)
367 connman_dbus_dict_append_variant(&dict, "Interface",
368 DBUS_TYPE_STRING, &element->devname);
370 connman_dbus_dict_append_variant(&dict, "Default",
371 DBUS_TYPE_BOOLEAN, &element->enabled);
373 device = __connman_element_get_device_path(element);
375 connman_dbus_dict_append_variant(&dict, "Device",
376 DBUS_TYPE_OBJECT_PATH, &device);
378 network = __connman_element_get_network_path(element);
380 connman_dbus_dict_append_variant(&dict, "Network",
381 DBUS_TYPE_OBJECT_PATH, &network);
383 __connman_element_append_ipv4(element, &dict);
385 dbus_message_iter_close_container(&array, &dict);
390 static DBusMessage *set_property(DBusConnection *conn,
391 DBusMessage *msg, void *data)
393 DBusMessageIter iter, value;
397 DBG("conn %p", conn);
399 if (dbus_message_iter_init(msg, &iter) == FALSE)
400 return __connman_error_invalid_arguments(msg);
402 dbus_message_iter_get_basic(&iter, &name);
403 dbus_message_iter_next(&iter);
404 dbus_message_iter_recurse(&iter, &value);
406 if (__connman_security_check_privilege(msg,
407 CONNMAN_SECURITY_PRIVILEGE_MODIFY) < 0)
408 return __connman_error_permission_denied(msg);
410 type = dbus_message_iter_get_arg_type(&value);
412 return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
415 static GDBusMethodTable connection_methods[] = {
416 { "GetProperties", "", "a{sv}", get_properties },
417 { "SetProperty", "sv", "", set_property },
421 static GDBusSignalTable connection_signals[] = {
422 { "PropertyChanged", "sv" },
426 static void append_connections(DBusMessageIter *entry)
428 DBusMessageIter value, iter;
429 const char *key = "Connections";
431 dbus_message_iter_append_basic(entry, DBUS_TYPE_STRING, &key);
433 dbus_message_iter_open_container(entry, DBUS_TYPE_VARIANT,
434 DBUS_TYPE_ARRAY_AS_STRING DBUS_TYPE_OBJECT_PATH_AS_STRING,
437 dbus_message_iter_open_container(&value, DBUS_TYPE_ARRAY,
438 DBUS_TYPE_OBJECT_PATH_AS_STRING, &iter);
439 __connman_element_list(NULL, CONNMAN_ELEMENT_TYPE_CONNECTION, &iter);
440 dbus_message_iter_close_container(&value, &iter);
442 dbus_message_iter_close_container(entry, &value);
445 static void emit_connections_signal(void)
448 DBusMessageIter entry;
452 signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH,
453 CONNMAN_MANAGER_INTERFACE, "PropertyChanged");
457 dbus_message_iter_init_append(signal, &entry);
459 append_connections(&entry);
461 g_dbus_send_message(connection, signal);
464 static int register_interface(struct connman_element *element)
466 DBG("element %p name %s path %s",
467 element, element->name, element->path);
469 if (g_dbus_register_interface(connection, element->path,
470 CONNMAN_CONNECTION_INTERFACE,
471 connection_methods, connection_signals,
472 NULL, element, NULL) == FALSE) {
473 connman_error("Failed to register %s connection", element->path);
477 emit_connections_signal();
482 static void unregister_interface(struct connman_element *element)
484 DBG("element %p name %s", element, element->name);
486 emit_connections_signal();
488 g_dbus_unregister_interface(connection, element->path,
489 CONNMAN_CONNECTION_INTERFACE);
492 static struct gateway_data *find_active_gateway(void)
498 for (list = gateway_list; list; list = list->next) {
499 struct gateway_data *data = list->data;
500 if (data->active == TRUE)
507 static int connection_probe(struct connman_element *element)
509 struct connman_service *service = NULL;
510 const char *gateway = NULL;
511 struct gateway_data *active_gateway = NULL;
512 struct gateway_data *new_gateway = NULL;
514 DBG("element %p name %s", element, element->name);
516 if (element->parent == NULL)
519 if (element->parent->type != CONNMAN_ELEMENT_TYPE_IPV4)
522 connman_element_get_value(element,
523 CONNMAN_PROPERTY_ID_IPV4_GATEWAY, &gateway);
525 DBG("gateway %s", gateway);
527 if (register_interface(element) < 0)
529 service = __connman_element_get_service(element);
530 __connman_service_indicate_state(service,
531 CONNMAN_SERVICE_STATE_READY);
532 connman_element_set_enabled(element, TRUE);
533 emit_default_signal(element);
538 active_gateway = find_active_gateway();
539 new_gateway = add_gateway(element->index, gateway);
541 if (active_gateway == NULL) {
542 set_default_gateway(new_gateway);
546 if (new_gateway->order >= active_gateway->order) {
547 del_route(active_gateway->element, active_gateway->gateway);
554 static void connection_remove(struct connman_element *element)
556 struct connman_service *service;
557 const char *gateway = NULL;
558 struct gateway_data *data = NULL;
560 DBG("element %p name %s", element, element->name);
562 service = __connman_element_get_service(element);
563 __connman_service_indicate_state(service,
564 CONNMAN_SERVICE_STATE_DISCONNECT);
566 connman_element_set_enabled(element, FALSE);
567 emit_default_signal(element);
569 unregister_interface(element);
571 connman_element_get_value(element,
572 CONNMAN_PROPERTY_ID_IPV4_GATEWAY, &gateway);
574 DBG("gateway %s", gateway);
579 data = find_gateway(element->index, gateway);
583 remove_gateway(data);
586 static struct connman_driver connection_driver = {
587 .name = "connection",
588 .type = CONNMAN_ELEMENT_TYPE_CONNECTION,
589 .priority = CONNMAN_DRIVER_PRIORITY_LOW,
590 .probe = connection_probe,
591 .remove = connection_remove,
594 int __connman_connection_init(void)
598 connection = connman_dbus_get_connection();
600 if (connman_rtnl_register(&connection_rtnl) < 0)
601 connman_error("Failed to setup RTNL gateway driver");
603 connman_rtnl_send_getroute();
605 return connman_driver_register(&connection_driver);
608 void __connman_connection_cleanup(void)
614 connman_driver_unregister(&connection_driver);
616 connman_rtnl_unregister(&connection_rtnl);
618 for (list = gateway_list; list; list = list->next) {
619 struct gateway_data *data = list->data;
621 DBG("index %d gateway %s", data->index, data->gateway);
623 g_free(data->gateway);
628 g_slist_free(gateway_list);
631 dbus_connection_unref(connection);
634 static void update_order(void)
638 for (list = gateway_list; list; list = list->next) {
639 struct gateway_data *data = list->data;
640 struct connman_service *service;
642 service = __connman_element_get_service(data->element);
644 data->order = __connman_service_get_order(service);
648 void __connman_connection_update_gateway(void)
650 struct gateway_data *active_gateway, *default_gateway;
654 active_gateway = find_active_gateway();
655 default_gateway = find_default_gateway();
657 if (active_gateway && active_gateway != default_gateway)
658 del_route(active_gateway->element, active_gateway->gateway);