5 * Copyright (C) 2007 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
31 #include <sys/ioctl.h>
32 #include <sys/socket.h>
33 #include <netinet/in.h>
34 #include <arpa/inet.h>
36 #include <net/route.h>
38 #include <linux/netlink.h>
39 #include <linux/rtnetlink.h>
44 #include <hal/libhal.h>
48 static DBusConnection *connection = NULL;
50 static GSList *drivers = NULL;
52 int connman_iface_register(struct connman_iface_driver *driver)
54 DBG("driver %p", driver);
56 drivers = g_slist_append(drivers, driver);
61 void connman_iface_unregister(struct connman_iface_driver *driver)
63 DBG("driver %p", driver);
65 drivers = g_slist_remove(drivers, driver);
68 static GSList *interfaces = NULL;
70 struct connman_iface *__connman_iface_find(int index)
74 for (list = interfaces; list; list = list->next) {
75 struct connman_iface *iface = list->data;
77 if (iface->index == index)
84 void __connman_iface_list(DBusMessageIter *iter)
90 for (list = interfaces; list; list = list->next) {
91 struct connman_iface *iface = list->data;
93 dbus_message_iter_append_basic(iter,
94 DBUS_TYPE_OBJECT_PATH, &iface->path);
98 int connman_iface_update(struct connman_iface *iface,
99 enum connman_iface_state state)
103 iface->state = state;
105 str = __connman_iface_state2string(iface->state);
107 g_dbus_emit_signal(connection, iface->path,
108 CONNMAN_IFACE_INTERFACE, "StateChanged",
109 DBUS_TYPE_STRING, &str, DBUS_TYPE_INVALID);
112 case CONNMAN_IFACE_STATE_OFF:
113 __connman_dhcp_release(iface);
116 case CONNMAN_IFACE_STATE_ENABLED:
117 if (iface->type == CONNMAN_IFACE_TYPE_80211) {
118 if (iface->driver->connect)
119 iface->driver->connect(iface, NULL);
123 case CONNMAN_IFACE_STATE_CARRIER:
124 __connman_dhcp_request(iface);
127 case CONNMAN_IFACE_STATE_SHUTDOWN:
128 __connman_dhcp_release(iface);
129 if (iface->driver->shutdown)
130 iface->driver->shutdown(iface);
140 void connman_iface_indicate_carrier(struct connman_iface *iface, int carrier)
142 DBG("iface %p carrier %d", iface, carrier);
145 int connman_iface_get_ipv4(struct connman_iface *iface,
146 struct connman_ipv4 *ipv4)
153 if ((iface->flags & CONNMAN_IFACE_FLAG_RTNL) == 0)
156 DBG("iface %p ipv4 %p", iface, ipv4);
158 memset(&req, 0, sizeof(req));
159 req.hdr.nlmsg_len = sizeof(req.hdr) + sizeof(req.msg);
160 req.hdr.nlmsg_type = RTM_GETADDR;
161 req.hdr.nlmsg_flags = NLM_F_REQUEST | NLM_F_DUMP;
162 req.hdr.nlmsg_pid = 0;
163 req.hdr.nlmsg_seq = 4711;
164 req.msg.rtgen_family = AF_INET;
166 __connman_rtnl_send(&req, sizeof(req));
171 int connman_iface_set_ipv4(struct connman_iface *iface,
172 struct connman_ipv4 *ipv4)
176 struct sockaddr_in *addr;
180 if ((iface->flags & CONNMAN_IFACE_FLAG_RTNL) == 0)
183 DBG("iface %p ipv4 %p", iface, ipv4);
185 sk = socket(PF_INET, SOCK_DGRAM, 0);
189 memset(&ifr, 0, sizeof(ifr));
190 ifr.ifr_ifindex = iface->index;
192 if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
197 DBG("ifname %s", ifr.ifr_name);
199 addr = (struct sockaddr_in *) &ifr.ifr_addr;
200 addr->sin_family = AF_INET;
201 addr->sin_addr = ipv4->address;
203 err = ioctl(sk, SIOCSIFADDR, &ifr);
206 DBG("address setting failed (%s)", strerror(errno));
208 addr = (struct sockaddr_in *) &ifr.ifr_netmask;
209 addr->sin_family = AF_INET;
210 addr->sin_addr = ipv4->netmask;
212 err = ioctl(sk, SIOCSIFNETMASK, &ifr);
215 DBG("netmask setting failed (%s)", strerror(errno));
217 addr = (struct sockaddr_in *) &ifr.ifr_broadaddr;
218 addr->sin_family = AF_INET;
219 addr->sin_addr = ipv4->broadcast;
221 err = ioctl(sk, SIOCSIFBRDADDR, &ifr);
224 DBG("broadcast setting failed (%s)", strerror(errno));
226 memset(&rt, 0, sizeof(rt));
227 rt.rt_flags = RTF_UP | RTF_GATEWAY;
229 addr = (struct sockaddr_in *) &rt.rt_dst;
230 addr->sin_family = AF_INET;
231 addr->sin_addr.s_addr = INADDR_ANY;
233 addr = (struct sockaddr_in *) &rt.rt_gateway;
234 addr->sin_family = AF_INET;
235 addr->sin_addr = ipv4->gateway;
237 addr = (struct sockaddr_in *) &rt.rt_genmask;
238 addr->sin_family = AF_INET;
239 addr->sin_addr.s_addr = INADDR_ANY;
241 err = ioctl(sk, SIOCADDRT, &rt);
246 DBG("default route failed (%s)", strerror(errno));
250 sprintf(cmd, "echo \"nameserver %s\" | resolvconf -a %s",
251 inet_ntoa(ipv4->nameserver), ifr.ifr_name);
260 int connman_iface_clear_ipv4(struct connman_iface *iface)
263 struct sockaddr_in *addr;
267 if ((iface->flags & CONNMAN_IFACE_FLAG_RTNL) == 0)
270 DBG("iface %p", iface);
272 sk = socket(PF_INET, SOCK_DGRAM, 0);
276 memset(&ifr, 0, sizeof(ifr));
277 ifr.ifr_ifindex = iface->index;
279 if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
284 DBG("ifname %s", ifr.ifr_name);
286 addr = (struct sockaddr_in *) &ifr.ifr_addr;
287 addr->sin_family = AF_INET;
288 addr->sin_addr.s_addr = INADDR_ANY;
290 //err = ioctl(sk, SIOCDIFADDR, &ifr);
291 err = ioctl(sk, SIOCSIFADDR, &ifr);
295 if (err < 0 && errno != EADDRNOTAVAIL) {
296 DBG("address removal failed (%s)", strerror(errno));
300 sprintf(cmd, "resolvconf -d %s", ifr.ifr_name);
309 static DBusMessage *scan_iface(DBusConnection *conn,
310 DBusMessage *msg, void *data)
312 struct connman_iface *iface = data;
313 struct connman_iface_driver *driver = iface->driver;
316 DBG("conn %p", conn);
318 reply = dbus_message_new_method_return(msg);
325 dbus_message_append_args(reply, DBUS_TYPE_INVALID);
330 static void append_entry(DBusMessageIter *dict,
331 const char *key, int type, void *val)
333 DBusMessageIter entry, value;
334 const char *signature;
336 dbus_message_iter_open_container(dict, DBUS_TYPE_DICT_ENTRY,
339 dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key);
342 case DBUS_TYPE_STRING:
343 signature = DBUS_TYPE_STRING_AS_STRING;
345 case DBUS_TYPE_UINT16:
346 signature = DBUS_TYPE_UINT16_AS_STRING;
349 signature = DBUS_TYPE_VARIANT_AS_STRING;
353 dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT,
355 dbus_message_iter_append_basic(&value, type, val);
356 dbus_message_iter_close_container(&entry, &value);
358 dbus_message_iter_close_container(dict, &entry);
361 static DBusMessage *get_properties(DBusConnection *conn,
362 DBusMessage *msg, void *data)
364 struct connman_iface *iface = data;
366 DBusMessageIter array, dict;
369 DBG("conn %p", conn);
371 reply = dbus_message_new_method_return(msg);
375 dbus_message_iter_init_append(reply, &array);
377 dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
378 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
379 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
380 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
382 str = __connman_iface_type2string(iface->type);
383 append_entry(&dict, "Type", DBUS_TYPE_STRING, &str);
385 str = __connman_iface_state2string(iface->state);
386 append_entry(&dict, "State", DBUS_TYPE_STRING, &str);
388 if (iface->type == CONNMAN_IFACE_TYPE_80211) {
389 dbus_uint16_t signal = 75;
390 append_entry(&dict, "Signal", DBUS_TYPE_UINT16, &signal);
393 str = __connman_iface_policy2string(iface->policy);
394 append_entry(&dict, "Policy", DBUS_TYPE_STRING, &str);
396 if (iface->device.driver != NULL)
397 append_entry(&dict, "Driver",
398 DBUS_TYPE_STRING, &iface->device.driver);
400 if (iface->device.vendor != NULL)
401 append_entry(&dict, "Vendor",
402 DBUS_TYPE_STRING, &iface->device.vendor);
404 if (iface->device.product != NULL)
405 append_entry(&dict, "Product",
406 DBUS_TYPE_STRING, &iface->device.product);
408 dbus_message_iter_close_container(&array, &dict);
413 static DBusMessage *get_state(DBusConnection *conn,
414 DBusMessage *msg, void *data)
416 struct connman_iface *iface = data;
420 DBG("conn %p", conn);
422 reply = dbus_message_new_method_return(msg);
426 state = __connman_iface_state2string(iface->state);
428 dbus_message_append_args(reply, DBUS_TYPE_STRING, &state,
434 static DBusMessage *get_signal(DBusConnection *conn,
435 DBusMessage *msg, void *data)
437 struct connman_iface *iface = data;
439 dbus_uint16_t signal;
441 DBG("conn %p", conn);
443 reply = dbus_message_new_method_return(msg);
447 if (iface->type == CONNMAN_IFACE_TYPE_80211)
452 dbus_message_append_args(reply, DBUS_TYPE_UINT16, &signal,
458 static DBusMessage *get_policy(DBusConnection *conn,
459 DBusMessage *msg, void *data)
461 struct connman_iface *iface = data;
465 DBG("conn %p", conn);
467 reply = dbus_message_new_method_return(msg);
471 policy = __connman_iface_policy2string(iface->policy);
473 dbus_message_append_args(reply, DBUS_TYPE_STRING, &policy,
479 static DBusMessage *set_policy(DBusConnection *conn,
480 DBusMessage *msg, void *data)
482 struct connman_iface *iface = data;
484 enum connman_iface_policy new_policy;
487 DBG("conn %p", conn);
489 dbus_message_get_args(msg, NULL, DBUS_TYPE_STRING, &policy,
492 new_policy = __connman_iface_string2policy(policy);
494 reply = dbus_message_new_method_return(msg);
498 dbus_message_append_args(reply, DBUS_TYPE_INVALID);
500 if (iface->policy != new_policy) {
501 iface->policy = new_policy;
502 __connman_iface_store(iface);
504 if (new_policy == CONNMAN_IFACE_POLICY_AUTO) {
505 if (iface->driver->activate)
506 iface->driver->activate(iface);
508 connman_iface_update(iface,
509 CONNMAN_IFACE_STATE_SHUTDOWN);
511 policy = __connman_iface_policy2string(new_policy);
513 g_dbus_emit_signal(conn, iface->path, CONNMAN_IFACE_INTERFACE,
514 "PolicyChanged", DBUS_TYPE_STRING, &policy,
521 static void append_network(DBusMessage *reply,
522 struct connman_iface *iface, gboolean secrets)
524 DBusMessageIter array, dict;
526 dbus_message_iter_init_append(reply, &array);
528 dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
529 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
530 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
531 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
533 switch (iface->type) {
534 case CONNMAN_IFACE_TYPE_80211:
535 if (iface->network.essid != NULL)
536 append_entry(&dict, "ESSID",
537 DBUS_TYPE_STRING, &iface->network.essid);
538 if (secrets == TRUE && iface->network.psk != NULL)
539 append_entry(&dict, "PSK",
540 DBUS_TYPE_STRING, &iface->network.psk);
546 dbus_message_iter_close_container(&array, &dict);
549 static DBusMessage *get_network(DBusConnection *conn,
550 DBusMessage *msg, void *data)
552 struct connman_iface *iface = data;
555 DBG("conn %p", conn);
557 reply = dbus_message_new_method_return(msg);
561 append_network(reply, iface, TRUE);
566 static DBusMessage *set_network(DBusConnection *conn,
567 DBusMessage *msg, void *data)
569 struct connman_iface *iface = data;
570 DBusMessage *reply, *signal;
571 DBusMessageIter array, dict;
572 gboolean changed = FALSE;
574 DBG("conn %p", conn);
576 dbus_message_iter_init(msg, &array);
578 dbus_message_iter_recurse(&array, &dict);
580 while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
581 DBusMessageIter entry, value;
582 const char *key, *val;
584 dbus_message_iter_recurse(&dict, &entry);
585 dbus_message_iter_get_basic(&entry, &key);
587 dbus_message_iter_next(&entry);
589 dbus_message_iter_recurse(&entry, &value);
591 //type = dbus_message_iter_get_arg_type(&value);
592 dbus_message_iter_get_basic(&value, &val);
594 if (g_strcasecmp(key, "ESSID") == 0) {
595 g_free(iface->network.essid);
596 iface->network.essid = g_strdup(val);
597 if (iface->driver->set_network)
598 iface->driver->set_network(iface, val);
602 if (g_strcasecmp(key, "PSK") == 0) {
603 g_free(iface->network.psk);
604 iface->network.psk = g_strdup(val);
605 if (iface->driver->set_network)
606 iface->driver->set_passphrase(iface, val);
610 dbus_message_iter_next(&dict);
613 reply = dbus_message_new_method_return(msg);
617 dbus_message_append_args(reply, DBUS_TYPE_INVALID);
619 if (changed == TRUE) {
620 __connman_iface_store(iface);
622 signal = dbus_message_new_signal(iface->path,
623 CONNMAN_IFACE_INTERFACE, "NetworkChanged");
624 if (signal != NULL) {
625 append_network(signal, iface, FALSE);
626 dbus_connection_send(conn, signal, NULL);
627 dbus_message_unref(signal);
634 static void append_ipv4(DBusMessage *reply, struct connman_iface *iface)
636 DBusMessageIter array, dict;
639 dbus_message_iter_init_append(reply, &array);
641 dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
642 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
643 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
644 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
646 str = __connman_ipv4_method2string(iface->ipv4.method);
647 append_entry(&dict, "Method", DBUS_TYPE_STRING, &str);
649 if (iface->ipv4.address.s_addr != INADDR_ANY) {
650 str = inet_ntoa(iface->ipv4.address);
651 append_entry(&dict, "Address", DBUS_TYPE_STRING, &str);
654 if (iface->ipv4.netmask.s_addr != INADDR_ANY) {
655 str = inet_ntoa(iface->ipv4.netmask);
656 append_entry(&dict, "Netmask", DBUS_TYPE_STRING, &str);
659 if (iface->ipv4.gateway.s_addr != INADDR_ANY) {
660 str = inet_ntoa(iface->ipv4.gateway);
661 append_entry(&dict, "Gateway", DBUS_TYPE_STRING, &str);
664 dbus_message_iter_close_container(&array, &dict);
667 static DBusMessage *get_ipv4(DBusConnection *conn,
668 DBusMessage *msg, void *data)
670 struct connman_iface *iface = data;
673 DBG("conn %p", conn);
675 reply = dbus_message_new_method_return(msg);
679 append_ipv4(reply, iface);
684 static DBusMessage *set_ipv4(DBusConnection *conn,
685 DBusMessage *msg, void *data)
687 struct connman_iface *iface = data;
688 DBusMessage *reply, *signal;
689 DBusMessageIter array, dict;
690 gboolean changed = FALSE;
692 DBG("conn %p", conn);
694 dbus_message_iter_init(msg, &array);
696 dbus_message_iter_recurse(&array, &dict);
698 while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
699 DBusMessageIter entry, value;
700 const char *key, *val;
701 enum connman_ipv4_method method;
704 dbus_message_iter_recurse(&dict, &entry);
705 dbus_message_iter_get_basic(&entry, &key);
707 dbus_message_iter_next(&entry);
709 dbus_message_iter_recurse(&entry, &value);
711 //type = dbus_message_iter_get_arg_type(&value);
712 dbus_message_iter_get_basic(&value, &val);
714 if (g_strcasecmp(key, "Method") == 0) {
715 method = __connman_ipv4_string2method(val);
716 if (iface->ipv4.method != method) {
717 iface->ipv4.method = method;
722 if (g_strcasecmp(key, "Address") == 0) {
723 addr = inet_addr(val);
724 if (iface->ipv4.address.s_addr != addr) {
725 iface->ipv4.address.s_addr = addr;
730 if (g_strcasecmp(key, "Netmask") == 0) {
731 addr = inet_addr(val);
732 if (iface->ipv4.netmask.s_addr != addr) {
733 iface->ipv4.netmask.s_addr = addr;
738 if (g_strcasecmp(key, "Gateway") == 0) {
739 addr = inet_addr(val);
740 if (iface->ipv4.gateway.s_addr != addr) {
741 iface->ipv4.gateway.s_addr = addr;
746 dbus_message_iter_next(&dict);
749 reply = dbus_message_new_method_return(msg);
753 dbus_message_append_args(reply, DBUS_TYPE_INVALID);
755 if (changed == TRUE) {
756 __connman_iface_store(iface);
758 signal = dbus_message_new_signal(iface->path,
759 CONNMAN_IFACE_INTERFACE, "IPv4Changed");
760 if (signal != NULL) {
761 append_ipv4(signal, iface);
762 dbus_connection_send(conn, signal, NULL);
763 dbus_message_unref(signal);
770 static GDBusMethodTable iface_methods[] = {
771 { "Scan", "", "", scan_iface },
772 { "GetProperties", "", "a{sv}", get_properties },
773 { "GetState", "", "s", get_state },
774 { "GetSignal", "", "q", get_signal },
775 { "GetPolicy", "", "s", get_policy },
776 { "SetPolicy", "s", "", set_policy },
777 { "GetNetwork", "", "a{sv}", get_network },
778 { "SetNetwork", "a{sv}", "", set_network },
779 { "GetIPv4", "", "a{sv}", get_ipv4 },
780 { "SetIPv4", "a{sv}", "", set_ipv4 },
784 static GDBusSignalTable iface_signals[] = {
785 { "StateChanged", "s" },
786 { "SignalChanged", "q" },
787 { "PolicyChanged", "s" },
788 { "NetworkChanged", "a{sv}" },
789 { "IPv4Changed", "a{sv}" },
793 static void device_free(void *data)
795 struct connman_iface *iface = data;
797 DBG("iface %p", iface);
799 connman_iface_clear_ipv4(iface);
801 if (iface->driver && iface->driver->remove)
802 iface->driver->remove(iface);
806 g_free(iface->sysfs);
807 g_free(iface->identifier);
808 g_free(iface->network.essid);
809 g_free(iface->device.driver);
810 g_free(iface->device.vendor);
811 g_free(iface->device.product);
815 static void detect_device_info(LibHalContext *ctx, struct connman_iface *iface)
817 char *parent, *subsys, *value;
819 parent = libhal_device_get_property_string(ctx, iface->udi,
820 "info.parent", NULL);
822 subsys = libhal_device_get_property_string(ctx, iface->udi,
823 "linux.subsystem", NULL);
825 value = libhal_device_get_property_string(ctx, iface->udi,
826 "info.linux.driver", NULL);
828 value = libhal_device_get_property_string(ctx, parent,
829 "info.linux.driver", NULL);
831 iface->device.driver = g_strdup(value);
834 if (strcmp(subsys, "net") == 0) {
835 value = libhal_device_get_property_string(ctx, parent,
836 "info.vendor", NULL);
838 iface->device.vendor = g_strdup(value);
840 value = libhal_device_get_property_string(ctx, parent,
841 "info.product", NULL);
843 iface->device.product = g_strdup(value);
847 static int probe_device(LibHalContext *ctx,
848 struct connman_iface_driver *driver, const char *udi)
850 DBusConnection *conn;
851 struct connman_iface *iface;
855 DBG("ctx %p driver %p udi %s", ctx, driver, udi);
860 iface = g_try_new0(struct connman_iface, 1);
864 temp = g_path_get_basename(udi);
865 iface->path = g_strdup_printf("%s/%s", CONNMAN_IFACE_BASEPATH, temp);
868 iface->udi = g_strdup(udi);
870 DBG("iface %p path %s", iface, iface->path);
872 sysfs = libhal_device_get_property_string(ctx, udi,
873 "linux.sysfs_path", NULL);
875 iface->sysfs = g_strdup(sysfs);
877 detect_device_info(ctx, iface);
881 if (g_str_has_prefix(driver->capability, "net") == TRUE)
882 iface->index = libhal_device_get_property_int(ctx, udi,
883 "net.linux.ifindex", NULL);
885 iface->type = CONNMAN_IFACE_TYPE_UNKNOWN;
887 iface->state = CONNMAN_IFACE_STATE_UNKNOWN;
888 iface->policy = CONNMAN_IFACE_POLICY_UNKNOWN;
890 err = driver->probe(iface);
896 __connman_iface_create_identifier(iface);
898 __connman_iface_init_via_inet(iface);
900 iface->driver = driver;
902 __connman_iface_load(iface);
904 conn = libhal_ctx_get_dbus_connection(ctx);
906 g_dbus_register_object(conn, iface->path, iface, device_free);
908 interfaces = g_slist_append(interfaces, iface);
910 if (iface->flags & CONNMAN_IFACE_FLAG_IPV4) {
911 if (driver->get_ipv4)
912 driver->get_ipv4(iface, &iface->ipv4);
914 connman_iface_get_ipv4(iface, &iface->ipv4);
916 DBG("address %s", inet_ntoa(iface->ipv4.address));
919 g_dbus_register_interface(conn, iface->path,
920 CONNMAN_IFACE_INTERFACE,
921 iface_methods, iface_signals, NULL);
923 DBG("iface %p identifier %s", iface, iface->identifier);
925 g_dbus_emit_signal(conn, CONNMAN_MANAGER_PATH,
926 CONNMAN_MANAGER_INTERFACE,
928 DBUS_TYPE_OBJECT_PATH, &iface->path,
931 if (iface->policy == CONNMAN_IFACE_POLICY_AUTO) {
932 if (driver->activate)
933 driver->activate(iface);
939 static void device_added(LibHalContext *ctx, const char *udi)
943 DBG("ctx %p udi %s", ctx, udi);
945 for (list = drivers; list; list = list->next) {
946 struct connman_iface_driver *driver = list->data;
948 if (driver->capability == NULL)
951 if (libhal_device_query_capability(ctx, udi,
952 driver->capability, NULL) == TRUE) {
953 if (probe_device(ctx, driver, udi) == 0)
959 static void device_removed(LibHalContext *ctx, const char *udi)
961 DBusConnection *conn;
964 DBG("ctx %p udi %s", ctx, udi);
966 conn = libhal_ctx_get_dbus_connection(ctx);
968 for (list = interfaces; list; list = list->next) {
969 struct connman_iface *iface = list->data;
971 if (strcmp(udi, iface->udi) == 0) {
972 g_dbus_emit_signal(conn, CONNMAN_MANAGER_PATH,
973 CONNMAN_MANAGER_INTERFACE,
975 DBUS_TYPE_OBJECT_PATH, &iface->path,
977 interfaces = g_slist_remove(interfaces, iface);
978 g_dbus_unregister_interface(conn, iface->path,
979 CONNMAN_IFACE_INTERFACE);
980 g_dbus_unregister_object(conn, iface->path);
986 static void probe_driver(LibHalContext *ctx,
987 struct connman_iface_driver *driver)
992 DBG("ctx %p driver %p", ctx, driver);
994 list = libhal_find_device_by_capability(ctx,
995 driver->capability, &num, NULL);
1000 probe_device(ctx, driver, *tmp);
1004 libhal_free_string_array(list);
1008 static void find_devices(LibHalContext *ctx)
1014 for (list = drivers; list; list = list->next) {
1015 struct connman_iface_driver *driver = list->data;
1017 DBG("driver %p", driver);
1019 if (driver->capability == NULL)
1022 probe_driver(ctx, driver);
1026 static LibHalContext *hal_ctx = NULL;
1028 static void hal_init(void *data)
1030 DBusConnection *conn = data;
1032 DBG("conn %p", conn);
1034 if (hal_ctx != NULL)
1037 hal_ctx = libhal_ctx_new();
1038 if (hal_ctx == NULL)
1041 if (libhal_ctx_set_dbus_connection(hal_ctx, conn) == FALSE) {
1042 libhal_ctx_free(hal_ctx);
1046 if (libhal_ctx_init(hal_ctx, NULL) == FALSE) {
1047 libhal_ctx_free(hal_ctx);
1051 libhal_ctx_set_device_added(hal_ctx, device_added);
1052 libhal_ctx_set_device_removed(hal_ctx, device_removed);
1054 //libhal_ctx_set_device_new_capability(hal_ctx, new_capability);
1055 //libhal_ctx_set_device_lost_capability(hal_ctx, lost_capability);
1057 find_devices(hal_ctx);
1060 static void hal_cleanup(void *data)
1062 DBusConnection *conn = data;
1065 DBG("conn %p", conn);
1067 if (hal_ctx == NULL)
1070 for (list = interfaces; list; list = list->next) {
1071 struct connman_iface *iface = list->data;
1073 DBG("path %s", iface->path);
1075 g_dbus_emit_signal(conn, CONNMAN_MANAGER_PATH,
1076 CONNMAN_MANAGER_INTERFACE,
1078 DBUS_TYPE_OBJECT_PATH, &iface->path,
1081 g_dbus_unregister_interface(conn, iface->path,
1082 CONNMAN_IFACE_INTERFACE);
1084 g_dbus_unregister_object(conn, iface->path);
1087 g_slist_free(interfaces);
1091 libhal_ctx_shutdown(hal_ctx, NULL);
1093 libhal_ctx_free(hal_ctx);
1098 static guint hal_watch = 0;
1100 int __connman_iface_init(DBusConnection *conn)
1102 DBG("conn %p", conn);
1104 connection = dbus_connection_ref(conn);
1105 if (connection == NULL)
1108 hal_init(connection);
1110 hal_watch = g_dbus_add_watch(connection, "org.freedesktop.Hal",
1111 hal_init, hal_cleanup, connection, NULL);
1116 void __connman_iface_cleanup(void)
1118 DBG("conn %p", connection);
1120 g_dbus_remove_watch(connection, hal_watch);
1122 hal_cleanup(connection);
1124 dbus_connection_unref(connection);