/* * * Connection Manager * * Copyright (C) 2007-2012 Intel Corporation. All rights reserved. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License version 2 as * published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA * */ #ifdef HAVE_CONFIG_H #include #endif #include #include #include #include #define CONNMAN_API_SUBJECT_TO_CHANGE #include #include #include #include #include #include #include #define PS_DBUS_SERVICE "com.tcore.ps" #define TELEPHONY_DBUS_SERVICE "org.tizen.telephony" #define PS_MASTER_INTERFACE PS_DBUS_SERVICE ".master" #define PS_MODEM_INTERFACE PS_DBUS_SERVICE ".modem" #define PS_SERVICE_INTERFACE PS_DBUS_SERVICE ".service" #define PS_CONTEXT_INTERFACE PS_DBUS_SERVICE ".context" /* methods */ #define GET_MODEMS "GetModems" #define GET_SERVICES "GetServices" #define GET_CONTEXTS "GetContexts" #define ACTIVATE_CONTEXT "Activate" #define DEACTIVATE_CONTEXT "Deactivate" #define GET_PROPERTIES "GetProperties" #define SET_PROPERTY "SetProperties" /* signals */ #define MODEM_ADDED "ModemAdded" #define MODEM_REMOVED "ModemRemoved" #define SERVICE_ADDED "ServiceAdded" #define SERVICE_REMOVED "ServiceRemoved" #define CONTEXT_ADDED "ContextAdded" #define CONTEXT_REMOVED "ContextRemoved" #define PROPERTY_CHANGED "PropertyChanged" #define TIMEOUT 130000 #define STRING2BOOL(a) (!(g_strcmp0(a, "TRUE")) ? (TRUE):(FALSE)) static DBusConnection *connection; static GHashTable *modem_hash; static GHashTable *service_hash; static GHashTable *network_hash; struct telephony_service { char *path; gpointer p_modem; char *act; gboolean roaming; /* global roaming state */ gboolean ps_attached; /* packet service is available */ }; struct telephony_modem { char *path; char *operator; gboolean powered; gboolean sim_init; gboolean flight_mode; gboolean data_allowed; gboolean roaming_allowed; struct connman_device *device; struct telephony_service *s_service; }; struct telephony_network { char *path; int if_index; gboolean routing_only; gboolean ipv6_link_only; struct connman_network *network; enum connman_ipconfig_method ipv4_method; struct connman_ipaddress *ipv4_address; enum connman_ipconfig_method ipv6_method; struct connman_ipaddress *ipv6_address; }; static int telephony_default_subscription_id = 0; /* function prototype */ static void telephony_connect(DBusConnection *connection, void *user_data); static void telephony_disconnect(DBusConnection *connection, void *user_data); static void __remove_modem(gpointer data); static void __remove_service(gpointer data); static void __remove_network(gpointer data); static int __modem_probe(struct connman_device *device); static void __modem_remove(struct connman_device *device); static int __modem_enable(struct connman_device *device); static int __modem_disable(struct connman_device *device); static int __network_probe(struct connman_network *network); static void __network_remove(struct connman_network *network); static int __network_connect(struct connman_network *network); static int __network_disconnect(struct connman_network *network); /* dbus request and reply */ static int __dbus_request(const char *service, const char *path, const char *interface, const char *method, DBusPendingCallNotifyFunction notify, void *user_data, DBusFreeFunction free_function, int type, ...); static int __request_get_modems(void); static void __response_get_modems(DBusPendingCall *call, void *user_data); static int __request_get_services(const char *path); static void __response_get_services(DBusPendingCall *call, void *user_data); static int __request_get_contexts(struct telephony_modem *modem); static void __response_get_contexts(DBusPendingCall *call, void *user_data); static int __request_network_activate(struct connman_network *network); static void __response_network_activate(DBusPendingCall *call, void *user_data); static int __request_network_deactivate(struct connman_network *network); /* telephony internal function */ static void __add_modem(const char *path, DBusMessageIter *prop); static void __add_service(struct telephony_modem *modem, const char *service_path, DBusMessageIter *prop); static void __add_connman_device(const char *modem_path, const char *operator); static void __remove_connman_device(struct telephony_modem *modem); static void __remove_connman_networks(struct connman_device *device); static int __add_context(struct connman_device *device, const char *path, DBusMessageIter *prop); /* signal handler */ static gboolean __changed_modem(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __added_modem(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __removed_modem(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __changed_service(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __added_service(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __removed_service(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __changed_context(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __added_context(DBusConnection *connection, DBusMessage *message, void *user_data); static gboolean __removed_context(DBusConnection *connection, DBusMessage *message, void *user_data); /* device driver */ static struct connman_device_driver modem_driver = { .name = "device", .type = CONNMAN_DEVICE_TYPE_CELLULAR, .probe = __modem_probe, .remove = __modem_remove, .enable = __modem_enable, .disable = __modem_disable, }; /* network driver */ static struct connman_network_driver network_driver = { .name = "network", .type = CONNMAN_NETWORK_TYPE_CELLULAR, .probe = __network_probe, .remove = __network_remove, .connect = __network_connect, .disconnect = __network_disconnect, }; static int tech_probe(struct connman_technology *technology) { return 0; } static void tech_remove(struct connman_technology *technology) { return; } static struct connman_technology_driver tech_driver = { .name = "cellular", .type = CONNMAN_SERVICE_TYPE_CELLULAR, .probe = tech_probe, .remove = tech_remove, }; /* local function */ static void telephony_connect(DBusConnection *connection, void *user_data) { DBG("connection %p", connection); modem_hash = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, __remove_modem); service_hash = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, __remove_service); network_hash = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, __remove_network); __request_get_modems(); } static void telephony_disconnect(DBusConnection *connection, void *user_data) { DBG("connection %p", connection); if (modem_hash != NULL) { g_hash_table_destroy(modem_hash); modem_hash = NULL; } if (network_hash != NULL) { g_hash_table_destroy(network_hash); network_hash = NULL; } } static void __remove_modem(gpointer data) { struct telephony_modem *modem = data; __remove_connman_device(modem); g_free(modem->path); g_free(modem->operator); g_free(modem); } static void __remove_service(gpointer data) { struct telephony_service *service = data; g_free(service->path); g_free(service->act); g_free(service); } static void __remove_network(gpointer data) { struct telephony_network *info = data; struct connman_device *device; device = connman_network_get_device(info->network); if (device != NULL) connman_device_remove_network(device, info->network); connman_network_unref(info->network); g_free(info->path); connman_ipaddress_free(info->ipv4_address); connman_ipaddress_free(info->ipv6_address); g_free(info); } static void __set_device_powered(struct telephony_modem *modem, gboolean powered) { DBG("set modem(%s) powered(%d)", modem->path, powered); if (modem->device) connman_device_set_powered(modem->device, powered); } static int __check_device_powered(const char *path, gboolean powered) { struct telephony_modem *modem = g_hash_table_lookup(modem_hash, path); if (modem == NULL) return -ENODEV; DBG("check modem (%s) powered (%d)", modem->path, modem->powered); if (modem->powered == powered) return -EALREADY; return 0; } static int __modem_probe(struct connman_device *device) { DBG("device %p", device); return 0; } static void __modem_remove(struct connman_device *device) { DBG("device %p", device); } static int __modem_enable(struct connman_device *device) { const char *path = connman_device_get_string(device, "Path"); DBG("device %p, path, %s", device, path); return __check_device_powered(path, TRUE); } static int __modem_disable(struct connman_device *device) { const char *path = connman_device_get_string(device, "Path"); DBG("device %p, path, %s", device, path); return __check_device_powered(path, FALSE); } static int __network_probe(struct connman_network *network) { DBG("network_prove network(%p)", network); return 0; } static int __network_connect(struct connman_network *network) { DBG("network %p", network); return __request_network_activate(network); } static int __network_disconnect(struct connman_network *network) { DBG("network %p", network); if (connman_network_get_associating(network) == TRUE) connman_network_clear_associating(network); connman_network_set_associating(network, FALSE); return __request_network_deactivate(network); } static void __network_remove(struct connman_network *network) { char const *path = connman_network_get_string(network, "Path"); DBG("network %p path %s", network, path); g_hash_table_remove(network_hash, path); } static int __dbus_request(const char *service, const char *path, const char *interface, const char *method, DBusPendingCallNotifyFunction notify, void *user_data, DBusFreeFunction free_function, int type, ...) { DBusMessage *message; DBusPendingCall *call; dbus_bool_t ok; va_list va; DBG("path %s %s.%s", path, interface, method); if (path == NULL) return -EINVAL; message = dbus_message_new_method_call(service, path, interface, method); if (message == NULL) return -ENOMEM; dbus_message_set_auto_start(message, FALSE); va_start(va, type); ok = dbus_message_append_args_valist(message, type, va); va_end(va); if (!ok) { dbus_message_unref(message); return -ENOMEM; } if (dbus_connection_send_with_reply(connection, message, &call, TIMEOUT) == FALSE) { connman_error("Failed to call %s.%s", interface, method); dbus_message_unref(message); return -EINVAL; } if (call == NULL) { connman_error("D-Bus connection not available"); dbus_message_unref(message); return -EINVAL; } dbus_pending_call_set_notify(call, notify, user_data, free_function); dbus_message_unref(message); return -EINPROGRESS; } static int __request_get_modems(void) { DBG("request get modem"); /* call connect master */ return __dbus_request(PS_DBUS_SERVICE, "/", PS_MASTER_INTERFACE, GET_MODEMS, __response_get_modems, NULL, NULL, DBUS_TYPE_INVALID); } static void __response_get_modems(DBusPendingCall *call, void *user_data) { DBusMessage *reply; DBusError error; DBusMessageIter args, dict; DBG(""); reply = dbus_pending_call_steal_reply(call); dbus_error_init(&error); if (dbus_set_error_from_message(&error, reply)) { connman_error("GetModems() %s %s", error.name, error.message); dbus_error_free(&error); goto done; } DBG("message signature (%s)", dbus_message_get_signature(reply)); if (dbus_message_iter_init(reply, &args) == FALSE) goto done; dbus_message_iter_recurse(&args, &dict); /* DBG("message type (%d) dic(%d)", * dbus_message_iter_get_arg_type(&dict), DBUS_TYPE_DICT_ENTRY); */ while (dbus_message_iter_get_arg_type(&dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry, property; const char *modem_path; dbus_message_iter_recurse(&dict, &entry); dbus_message_iter_get_basic(&entry, &modem_path); DBG("modem path (%s)", modem_path); dbus_message_iter_next(&entry); dbus_message_iter_recurse(&entry, &property); __add_modem(modem_path, &property); dbus_message_iter_next(&dict); } done: dbus_message_unref(reply); dbus_pending_call_unref(call); } static int __request_get_services(const char *path) { DBG("request get service"); return __dbus_request(PS_DBUS_SERVICE, path, PS_MODEM_INTERFACE, GET_SERVICES, __response_get_services, g_strdup(path), g_free, DBUS_TYPE_INVALID); } static void __response_get_services(DBusPendingCall *call, void *user_data) { DBusMessage *reply; DBusError error; DBusMessageIter args, dict; const char *path = user_data; struct telephony_modem *modem; modem = g_hash_table_lookup(modem_hash, path); DBG(""); reply = dbus_pending_call_steal_reply(call); dbus_error_init(&error); if (dbus_set_error_from_message(&error, reply)) { connman_error("GetServices() %s %s", error.name, error.message); dbus_error_free(&error); goto done; } if (modem == NULL || modem->device == NULL) goto done; DBG("message signature (%s)", dbus_message_get_signature(reply)); if (dbus_message_iter_init(reply, &args) == FALSE) goto done; dbus_message_iter_recurse(&args, &dict); /* DBG("message type (%d) dic(%d)", * dbus_message_iter_get_arg_type(&dict), DBUS_TYPE_DICT_ENTRY); */ while (dbus_message_iter_get_arg_type(&dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry, property; const char *service_path; dbus_message_iter_recurse(&dict, &entry); dbus_message_iter_get_basic(&entry, &service_path); DBG("service path (%s)", service_path); dbus_message_iter_next(&entry); dbus_message_iter_recurse(&entry, &property); __add_service(modem, service_path, &property); dbus_message_iter_next(&dict); } done: dbus_message_unref(reply); dbus_pending_call_unref(call); } static int __request_get_contexts(struct telephony_modem *modem) { DBG("request get contexts"); return __dbus_request(PS_DBUS_SERVICE, modem->s_service->path, PS_SERVICE_INTERFACE, GET_CONTEXTS, __response_get_contexts, g_strdup(modem->path), g_free, DBUS_TYPE_INVALID); } static void __response_get_contexts(DBusPendingCall *call, void *user_data) { DBusError error; DBusMessage *reply; DBusMessageIter args, dict; const char *path = user_data; struct telephony_modem *modem; DBG(""); modem = g_hash_table_lookup(modem_hash, path); if (modem == NULL) return; if (modem->s_service == NULL) return; if (modem->device == NULL) return; reply = dbus_pending_call_steal_reply(call); dbus_error_init(&error); if (dbus_set_error_from_message(&error, reply)) { connman_error("GetContexts() %s %s", error.name, error.message); dbus_error_free(&error); goto done; } DBG("message signature (%s)", dbus_message_get_signature(reply)); if (dbus_message_iter_init(reply, &args) == FALSE) goto done; dbus_message_iter_recurse(&args, &dict); while (dbus_message_iter_get_arg_type(&dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry, property; const char *context_path; dbus_message_iter_recurse(&dict, &entry); dbus_message_iter_get_basic(&entry, &context_path); DBG("context path (%s)", context_path); dbus_message_iter_next(&entry); dbus_message_iter_recurse(&entry, &property); __add_context(modem->device, context_path, &property); dbus_message_iter_next(&dict); } done: dbus_message_unref(reply); dbus_pending_call_unref(call); } static int __request_network_activate(struct connman_network *network) { int n_modems; const char *path = NULL; struct telephony_modem *modem = NULL; n_modems = g_hash_table_size(modem_hash); path = connman_network_get_string(network, "Path"); modem = connman_device_get_data(connman_network_get_device(network)); DBG("network %p, path %s, modem %s[%d]", network, path, modem->path, telephony_default_subscription_id); if (modem && n_modems > 1 && g_str_has_suffix(path, "_1") == TRUE) { char *subscribe_id = g_strdup_printf("%d", telephony_default_subscription_id); if (g_str_has_suffix(modem->path, subscribe_id) != TRUE) { g_free(subscribe_id); return -ENOLINK; } g_free(subscribe_id); } return __dbus_request(PS_DBUS_SERVICE, path, PS_CONTEXT_INTERFACE, ACTIVATE_CONTEXT, __response_network_activate, g_strdup(path), NULL, DBUS_TYPE_INVALID); } static gboolean __check_network_available(struct connman_network *network) { if (network == NULL || connman_network_get_device(network) == NULL) return FALSE; return TRUE; } static void __response_network_activate(DBusPendingCall *call, void *user_data) { DBG("network activation response"); DBusError error; DBusMessage *reply; struct telephony_network *info; const char *path = user_data; info = g_hash_table_lookup(network_hash, path); reply = dbus_pending_call_steal_reply(call); if (info == NULL) goto done; if (__check_network_available(info->network) == FALSE) { g_hash_table_remove(network_hash, path); goto done; } dbus_error_init(&error); if (dbus_set_error_from_message(&error, reply)) { connman_error("connection activate() %s %s", error.name, error.message); if (connman_network_get_associating(info->network) == TRUE) connman_network_set_error(info->network, CONNMAN_NETWORK_ERROR_ASSOCIATE_FAIL); if (connman_network_get_connecting(info->network) == TRUE) connman_network_set_error(info->network, CONNMAN_NETWORK_ERROR_CONNECT_FAIL); if (connman_network_get_index(info->network) < 0) connman_network_set_error(info->network, CONNMAN_NETWORK_ERROR_ASSOCIATE_FAIL); dbus_error_free(&error); goto done; } done: dbus_message_unref(reply); dbus_pending_call_unref(call); } static int __request_network_deactivate(struct connman_network *network) { const char *path = connman_network_get_string(network, "Path"); DBG("network %p, path %s", network, path); return __dbus_request(PS_DBUS_SERVICE, path, PS_CONTEXT_INTERFACE, DEACTIVATE_CONTEXT, NULL, NULL, NULL, DBUS_TYPE_INVALID); } static void __response_get_default_subscription_id(DBusPendingCall *call, void *user_data) { DBusMessage *reply; DBusError error; DBusMessageIter args; DBG(""); reply = dbus_pending_call_steal_reply(call); dbus_error_init(&error); if (dbus_set_error_from_message(&error, reply)) { connman_error("GetDefaultDataSubscription() %s %s", error.name, error.message); dbus_error_free(&error); goto done; } DBG("message signature (%s)", dbus_message_get_signature(reply)); if (dbus_message_iter_init(reply, &args) == FALSE) goto done; dbus_message_iter_get_basic(&args, &telephony_default_subscription_id); DBG("default subscription: %d", telephony_default_subscription_id); done: dbus_message_unref(reply); dbus_pending_call_unref(call); } static int __request_get_default_subscription_id(const char *path) { int ret; char *telephony_modem_path = NULL; telephony_modem_path = g_strdup_printf("/org/tizen/telephony%s", path); DBG("request get default subscription id %s", telephony_modem_path); ret = __dbus_request(TELEPHONY_DBUS_SERVICE, telephony_modem_path, "org.tizen.telephony.Network", "GetDefaultDataSubscription", __response_get_default_subscription_id, NULL, NULL, DBUS_TYPE_INVALID); g_free(telephony_modem_path); return ret; } static void __add_modem(const char *path, DBusMessageIter *prop) { struct telephony_modem *modem; modem = g_hash_table_lookup(modem_hash, path); if (modem != NULL) return; modem = g_try_new0(struct telephony_modem, 1); if (modem == NULL) return; modem->path = g_strdup(path); modem->device = NULL; modem->s_service = NULL; g_hash_table_insert(modem_hash, g_strdup(path), modem); while (dbus_message_iter_get_arg_type(prop) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *tmp; dbus_message_iter_recurse(prop, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &tmp); DBG("key (%s) value(%s)", key, tmp); if (g_strcmp0(key, "powered") == 0) { modem->powered = STRING2BOOL(tmp); } else if (g_strcmp0(key, "operator") == 0) { modem->operator = g_strdup(tmp); } else if (g_strcmp0(key, "sim_init") == 0) { modem->sim_init = STRING2BOOL(tmp); } else if (g_strcmp0(key, "flight_mode") == 0) { modem->flight_mode = STRING2BOOL(tmp); } else if (g_strcmp0(key, "roaming_allowed") == 0) { modem->roaming_allowed = STRING2BOOL(tmp); } else if (g_strcmp0(key, "data_allowed") == 0) { modem->data_allowed = STRING2BOOL(tmp); } dbus_message_iter_next(prop); } __add_connman_device(path, modem->operator); __set_device_powered(modem, modem->powered); if (g_hash_table_size(modem_hash) > 1) __request_get_default_subscription_id(modem->path); if (modem->powered != TRUE) { DBG("modem is not powered"); return; } __request_get_services(modem->path); } static void __add_service(struct telephony_modem *modem, const char *service_path, DBusMessageIter *prop) { struct telephony_service *service; if (modem->s_service != NULL) return; service = g_try_new0(struct telephony_service, 1); if (service == NULL) return; service->path = g_strdup(service_path); service->p_modem = modem; g_hash_table_insert(service_hash, g_strdup(service_path), service); while (dbus_message_iter_get_arg_type(prop) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *tmp; dbus_message_iter_recurse(prop, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &tmp); DBG("key (%s) value(%s)", key, tmp); if (g_strcmp0(key, "roaming") == 0) { service->roaming = STRING2BOOL(tmp); } else if (g_strcmp0(key, "act") == 0) { service->act = g_strdup(tmp); } else if (g_strcmp0(key, "ps_attached") == 0) { service->ps_attached = STRING2BOOL(tmp); } dbus_message_iter_next(prop); } modem->s_service = service; __request_get_contexts(modem); } static char *__get_ident(const char *path) { char *pos; if (*path != '/') return NULL; pos = strrchr(path, '/'); if (pos == NULL) return NULL; return pos + 1; } static void __add_connman_device(const char *modem_path, const char *operator) { char* ident = NULL; struct telephony_modem *modem; struct connman_device *device; DBG("path %s operator %s", modem_path, operator); if (modem_path == NULL) return; if (operator == NULL) return; modem = g_hash_table_lookup(modem_hash, modem_path); if (modem == NULL) return; if (modem->device) { if (!g_strcmp0(operator, connman_device_get_ident(modem->device))) return; __remove_connman_device(modem); } if (strlen(operator) == 0) return; device = connman_device_create(operator, CONNMAN_DEVICE_TYPE_CELLULAR); if (device == NULL) return; ident = g_strdup_printf("%s_%s", __get_ident(modem_path), operator); connman_device_set_ident(device, ident); g_free(ident); connman_device_set_string(device, "Path", modem_path); connman_device_set_data(device, modem); if (connman_device_register(device) < 0) { connman_error("Failed to register cellular device"); connman_device_unref(device); return; } modem->device = device; } static void __remove_connman_device(struct telephony_modem *modem) { DBG("modem %p path %s device %p", modem, modem->path, modem->device); if (modem->device == NULL) return; __remove_connman_networks(modem->device); connman_device_unregister(modem->device); connman_device_unref(modem->device); modem->device = NULL; } static void __remove_connman_networks(struct connman_device *device) { GHashTableIter iter; gpointer key, value; GSList *info_list = NULL; GSList *list; if (network_hash == NULL) return; g_hash_table_iter_init(&iter, network_hash); while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) { struct telephony_network *info = value; if (connman_network_get_device(info->network) != device) continue; info_list = g_slist_append(info_list, info); } for (list = info_list; list != NULL; list = list->next) { struct telephony_network *info = list->data; connman_device_remove_network(device, info->network); } g_slist_free(info_list); } static gboolean connman_ipaddress_updated(struct connman_ipaddress *ipaddress, const char *address, const char *gateway) { if (ipaddress == NULL || address == NULL) return FALSE; if (g_strcmp0(ipaddress->local, address) != 0) return TRUE; if (g_strcmp0(ipaddress->gateway, gateway) != 0) return TRUE; return FALSE; } static void __set_network_connected(struct telephony_network *network, gboolean connected) { gboolean setip = FALSE; DBG("network %p connected %d", network, connected); connman_network_set_index(network->network, network->if_index); if (connman_network_get_connected(network->network) == connected) return; switch (network->ipv4_method) { case CONNMAN_IPCONFIG_METHOD_UNKNOWN: case CONNMAN_IPCONFIG_METHOD_DHCP: case CONNMAN_IPCONFIG_METHOD_AUTO: case CONNMAN_IPCONFIG_METHOD_OFF: connman_network_set_ipv4_method(network->network, network->ipv4_method); break; case CONNMAN_IPCONFIG_METHOD_MANUAL: case CONNMAN_IPCONFIG_METHOD_FIXED: connman_network_set_ipv4_method(network->network, network->ipv4_method); connman_network_set_ipaddress(network->network, network->ipv4_address); setip = TRUE; break; } switch (network->ipv6_method) { case CONNMAN_IPCONFIG_METHOD_UNKNOWN: case CONNMAN_IPCONFIG_METHOD_OFF: case CONNMAN_IPCONFIG_METHOD_DHCP: break; case CONNMAN_IPCONFIG_METHOD_AUTO: connman_network_set_ipv6_method(network->network, network->ipv6_method); setip = TRUE; break; case CONNMAN_IPCONFIG_METHOD_MANUAL: case CONNMAN_IPCONFIG_METHOD_FIXED: connman_network_set_ipv6_method(network->network, network->ipv6_method); connman_network_set_ipaddress(network->network, network->ipv6_address); setip = TRUE; break; } if (setip == TRUE) connman_network_set_connected(network->network, connected); } static gboolean __set_network_context( struct telephony_network *network, DBusMessageIter *dict) { int index = 0; gboolean active = FALSE; gboolean routing_only = FALSE; gboolean ipv4_updated = FALSE; gboolean ipv6_updated = FALSE; gboolean ipv6_link_only = FALSE; gboolean default_internet = FALSE; gboolean active_proxy = FALSE; char **proxies = NULL; const char *dev_name = NULL; const char *proxy_addr = NULL; char *ipv4_addr = NULL, *ipv4_gw = NULL, *ipv4_netmask = NULL, *ipv4_dns1 = NULL, *ipv4_dns2 = NULL; char *ipv6_addr = NULL, *ipv6_gw = NULL, *ipv6_netmask = NULL, *ipv6_dns1 = NULL, *ipv6_dns2 = NULL; struct connman_service *service; while (dbus_message_iter_get_arg_type(dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *value; dbus_message_iter_recurse(dict, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); if (g_strcmp0(key, "dev_name") == 0) { dbus_message_iter_get_basic(&entry, &dev_name); DBG("dev_name (%s)", dev_name); } else if (g_strcmp0(key, "proxy") == 0) { dbus_message_iter_get_basic(&entry, &proxy_addr); DBG("proxy_addr (%s)", proxy_addr); } else if (g_strcmp0(key, "ipv4_address") == 0) { dbus_message_iter_get_basic(&entry, &ipv4_addr); DBG("ipv4_addr (%s)", ipv4_addr); } else if (g_strcmp0(key, "ipv4_gateway") == 0) { dbus_message_iter_get_basic(&entry, &ipv4_gw); DBG("ipv4_gw (%s)", ipv4_gw); } else if (g_strcmp0(key, "ipv4_netmask") == 0) { dbus_message_iter_get_basic(&entry, &ipv4_netmask); DBG("ipv4_netmask (%s)", ipv4_netmask); } else if (g_strcmp0(key, "ipv4_dns1") == 0) { dbus_message_iter_get_basic(&entry, &ipv4_dns1); DBG("ipv4_dns1 (%s)", ipv4_dns1); } else if (g_strcmp0(key, "ipv4_dns2") == 0) { dbus_message_iter_get_basic(&entry, &ipv4_dns2); DBG("ipv4_dns2 (%s)", ipv4_dns2); } else if (g_strcmp0(key, "ipv6_address") == 0) { dbus_message_iter_get_basic(&entry, &ipv6_addr); DBG("ipv6 address (%s)", ipv6_addr); } else if (g_strcmp0(key, "ipv6_gateway") == 0) { dbus_message_iter_get_basic(&entry, &ipv6_gw); DBG("ipv6_gw (%s)", ipv6_gw); } else if (g_strcmp0(key, "ipv6_netmask") == 0) { dbus_message_iter_get_basic(&entry, &ipv6_netmask); DBG("ipv6_netmask (%s)", ipv6_netmask); } else if (g_strcmp0(key, "ipv6_dns1") == 0) { dbus_message_iter_get_basic(&entry, &ipv6_dns1); DBG("ipv6_dns1 (%s)", ipv6_dns1); } else if (g_strcmp0(key, "ipv6_dns2") == 0) { dbus_message_iter_get_basic(&entry, &ipv6_dns2); DBG("ipv6_dns2 (%s)", ipv6_dns2); } else if (g_strcmp0(key, "active") == 0) { dbus_message_iter_get_basic(&entry, &value); DBG("active (%s)", value); active = STRING2BOOL(value); } else if (g_strcmp0(key, "routing_only") == 0) { dbus_message_iter_get_basic(&entry, &value); DBG("routing_only (%s)", value); routing_only = STRING2BOOL(value); network->routing_only = routing_only; } else if (g_strcmp0(key, "ipv6_link_only") == 0) { dbus_message_iter_get_basic(&entry, &value); DBG("ipv6_link_only (%s)", value); ipv6_link_only = STRING2BOOL(value); network->ipv6_link_only = ipv6_link_only; } else if (g_strcmp0(key, "default_internet_conn") == 0) { dbus_message_iter_get_basic(&entry, &value); DBG("default_internet (%s)", value); default_internet = STRING2BOOL(value); } dbus_message_iter_next(dict); } if(routing_only){ //context active does not effect the connman service status. //it only for setting the routing path. DBG("routing_only(%d), active(%d)", routing_only, active); return active; } if (g_strcmp0(proxy_addr, ":") == 0) proxy_addr = NULL; if (g_strcmp0(ipv4_addr, "0.0.0.0") == 0) ipv4_addr = NULL; if (g_strcmp0(ipv4_gw, "0.0.0.0") == 0) ipv4_gw = NULL; if (g_strcmp0(ipv4_netmask, "0.0.0.0") == 0) ipv4_netmask = NULL; if (g_strcmp0(ipv4_dns1, "0.0.0.0") == 0) ipv4_dns1 = NULL; if (g_strcmp0(ipv4_dns2, "0.0.0.0") == 0) ipv4_dns2 = NULL; if (g_strcmp0(ipv6_addr, "::") == 0) ipv6_addr = NULL; if (g_strcmp0(ipv6_gw, "::") == 0) ipv6_gw = NULL; if (g_strcmp0(ipv6_netmask, "::") == 0) ipv6_netmask = NULL; if (g_strcmp0(ipv6_dns1, "::") == 0) ipv6_dns1 = NULL; if (g_strcmp0(ipv6_dns2, "::") == 0) ipv6_dns2 = NULL; connman_network_set_bool(network->network, "DefaultInternet", (bool)default_internet); service = connman_service_lookup_from_network(network->network); if (service == NULL) return FALSE; if (connman_setting_get_bool("SingleConnectedTechnology") == TRUE) { /* Wi-Fi technology is always a top priority */ if (active == TRUE && connman_service_is_no_ref_user_pdn_connection(service) == TRUE && connman_service_get_type(connman_service_get_default_connection()) == CONNMAN_SERVICE_TYPE_WIFI) { __request_network_deactivate(network->network); return FALSE; } } /* interface index set */ if (dev_name != NULL) { index = connman_inet_ifindex(dev_name); network->if_index = index; DBG("interface index %d", index); } /* proxy set */ if (active == TRUE && connman_network_get_connected(network->network) == TRUE) active_proxy = TRUE; proxies = connman_service_get_proxy_servers(service); if (proxies != NULL) { if (proxy_addr == NULL) connman_service_set_proxy(service, proxy_addr, active_proxy); else if (g_strcmp0(proxy_addr, proxies[0]) != 0) connman_service_set_proxy(service, proxy_addr, active_proxy); } else if (proxy_addr != NULL) connman_service_set_proxy(service, proxy_addr, active_proxy); if (proxies != NULL) g_strfreev(proxies); __connman_service_nameserver_clear(service); /* ipv4 set */ if (network->ipv4_address == NULL) network->ipv4_address = connman_ipaddress_alloc(CONNMAN_IPCONFIG_TYPE_IPV4); if (network->ipv4_address == NULL) return FALSE; if (ipv4_addr == NULL && active == TRUE) network->ipv4_method = CONNMAN_IPCONFIG_METHOD_OFF; else network->ipv4_method = CONNMAN_IPCONFIG_METHOD_FIXED; connman_network_set_ipv4_method(network->network, network->ipv4_method); ipv4_updated = connman_ipaddress_updated(network->ipv4_address, ipv4_addr, ipv4_gw); if (ipv4_updated == TRUE) connman_ipaddress_set_ipv4(network->ipv4_address, ipv4_addr, ipv4_netmask, ipv4_gw); if (ipv4_dns1) #if defined TIZEN_EXT __connman_service_nameserver_append(service, ipv4_dns1, FALSE, CONNMAN_IPCONFIG_TYPE_IPV4); #else __connman_service_nameserver_append(service, ipv4_dns1, FALSE); #endif //if (ipv4_dns2) if (ipv4_dns2 && !ipv4_dns1) #if defined TIZEN_EXT __connman_service_nameserver_append(service, ipv4_dns2, FALSE, CONNMAN_IPCONFIG_TYPE_IPV4); #else __connman_service_nameserver_append(service, ipv4_dns2, FALSE); #endif /* ipv6 set */ if (network->ipv6_address == NULL) network->ipv6_address = connman_ipaddress_alloc(CONNMAN_IPCONFIG_TYPE_IPV6); if (network->ipv6_address == NULL) return FALSE; if(ipv6_link_only) network->ipv6_method = CONNMAN_IPCONFIG_METHOD_AUTO; else network->ipv6_method = CONNMAN_IPCONFIG_METHOD_FIXED; if (ipv6_addr == NULL) network->ipv6_method = CONNMAN_IPCONFIG_METHOD_OFF; connman_network_set_ipv6_method(network->network, network->ipv6_method); ipv6_updated = connman_ipaddress_updated(network->ipv6_address, ipv6_addr, ipv6_gw); if (ipv6_updated == TRUE) connman_ipaddress_set_ipv6(network->ipv6_address, ipv6_addr, 64, ipv6_gw); if (ipv6_dns1) #if defined TIZEN_EXT __connman_service_nameserver_append(service, ipv6_dns1, FALSE, CONNMAN_IPCONFIG_TYPE_IPV6); #else __connman_service_nameserver_append(service, ipv6_dns1, FALSE); #endif //if (ipv6_dns2) if (ipv6_dns2 && !ipv6_dns1) #if defined TIZEN_EXT __connman_service_nameserver_append(service, ipv6_dns2, FALSE, CONNMAN_IPCONFIG_TYPE_IPV6); #else __connman_service_nameserver_append(service, ipv6_dns2, FALSE); #endif if (active == TRUE && connman_network_get_connected(network->network) == TRUE) { if (ipv4_updated == TRUE || ipv6_updated == TRUE) { DBG("IPv4 updated %d, IPv6 updated %d", ipv4_updated, ipv6_updated); __set_network_connected(network, FALSE); } else { DBG("Already connected"); return active; } } if (active == TRUE) connman_network_set_associating(network->network, TRUE); return active; } static int __add_context(struct connman_device *device, const char *path, DBusMessageIter *prop) { char *ident; gboolean active = FALSE; struct telephony_modem *modem = connman_device_get_data(device); struct connman_network *network; struct telephony_network *info; DBG("modem %p device %p path %s", modem, device, path); ident = __get_ident(path); network = connman_device_get_network(device, ident); if (network != NULL) return -EALREADY; info = g_hash_table_lookup(network_hash, path); if (info != NULL) { DBG("path %p already exists with device %p", path, connman_network_get_device(info->network)); if (connman_network_get_device(info->network)) return -EALREADY; g_hash_table_remove(network_hash, path); } network = connman_network_create(ident, CONNMAN_NETWORK_TYPE_CELLULAR); if (network == NULL) return -ENOMEM; info = g_try_new0(struct telephony_network, 1); if (info == NULL) { connman_network_unref(network); return -ENOMEM; } info->path = g_strdup(path); connman_ipaddress_clear(info->ipv4_address); connman_ipaddress_clear(info->ipv6_address); info->network = network; connman_network_set_string(network, "Path", path); connman_network_set_name(network, path); connman_network_set_group(network, ident); g_hash_table_insert(network_hash, g_strdup(path), info); connman_network_set_available(network, TRUE); connman_network_set_bool(network, "Roaming", (bool)modem->s_service->roaming); if (connman_device_add_network(device, network) != 0) { g_hash_table_remove(network_hash, path); return -EIO; } active = __set_network_context(info, prop); if(info->routing_only){ int err = 0; struct connman_service *routing_service; struct connman_ipconfig *routing_ipconfig; if(!active) return TRUE; routing_service = connman_service_lookup_from_network(info->network); routing_ipconfig = __connman_service_get_ip4config(routing_service); err = __connman_ipconfig_gateway_add(routing_ipconfig, routing_service); DBG("set gateway rv(%d)", err); return TRUE; } if (active == TRUE && (connman_network_get_associating(network) == TRUE || connman_network_get_connecting(network) == TRUE)) __set_network_connected(info, active); return 0; } static gboolean __changed_modem(DBusConnection *connection, DBusMessage *message, void *user_data) { gboolean old_powered; DBusMessageIter args, dict; struct telephony_modem *modem; const char *path = dbus_message_get_path(message); DBG("modem changed signal %s", path); modem = g_hash_table_lookup(modem_hash, path); if (modem == NULL) { DBG("modem object does not exists"); return TRUE; } old_powered = modem->powered; DBG("message signature (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); while (dbus_message_iter_get_arg_type(&dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *tmp; dbus_message_iter_recurse(&dict, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &tmp); DBG("key(%s), value(%s)", key, tmp); if (g_strcmp0(key, "powered") == 0) { modem->powered = STRING2BOOL(tmp); } else if (g_strcmp0(key, "operator") == 0) { modem->operator = g_strdup(tmp); } else if (g_strcmp0(key, "sim_init") == 0) { modem->sim_init = STRING2BOOL(tmp); } else if (g_strcmp0(key, "flight_mode") == 0) { modem->flight_mode = STRING2BOOL(tmp); } else if (g_strcmp0(key, "roaming_allowed") == 0) { modem->roaming_allowed = STRING2BOOL(tmp); } else if (g_strcmp0(key, "data_allowed") == 0) { modem->data_allowed = STRING2BOOL(tmp); } dbus_message_iter_next(&dict); } if (modem->device == NULL) __add_connman_device(path, modem->operator); if (old_powered != modem->powered) __set_device_powered(modem, modem->powered); if (modem->powered != TRUE) { DBG("modem is not powered"); return TRUE; } if (modem->s_service == NULL) { __request_get_services(modem->path); return TRUE; } DBG("modem(%s) flight mode(%d) data allowed(%d)", modem->path, modem->flight_mode, modem->data_allowed); return TRUE; } static gboolean __added_modem(DBusConnection *connection, DBusMessage *message, void *user_data) { const char *modem_path = NULL; DBusMessageIter args, dict, tmp; DBG("modem added signal (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); memcpy(&tmp, &dict, sizeof(struct DBusMessageIter)); while (dbus_message_iter_get_arg_type(&tmp) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *value; dbus_message_iter_recurse(&tmp, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &value); DBG("key (%s) value(%s)", key, value); if (g_strcmp0(key, "path") == 0) modem_path = g_strdup(value); dbus_message_iter_next(&tmp); } if (modem_path != NULL) __add_modem(modem_path, &dict); return TRUE; } static gboolean __removed_modem(DBusConnection *connection, DBusMessage *message, void *user_data) { DBusMessageIter iter; const char *modem_path; DBG("modem removed signal"); if (dbus_message_iter_init(message, &iter) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_get_basic(&iter, &modem_path); g_hash_table_remove(modem_hash, modem_path); return TRUE; } static gboolean __changed_service(DBusConnection *connection, DBusMessage *message, void *user_data) { DBusMessageIter args, dict; struct telephony_modem *modem; gboolean roaming_option = TRUE; struct telephony_service *s_service; const char *service_path = dbus_message_get_path(message); DBG("service changed signal %s", service_path); s_service = g_hash_table_lookup(service_hash, service_path); if (s_service == NULL) { DBG("service object does not exists"); return TRUE; } modem = s_service->p_modem; if (modem == NULL) { DBG("modem object does not exists"); return TRUE; } DBG("message signature (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); while (dbus_message_iter_get_arg_type(&dict) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *tmp; dbus_message_iter_recurse(&dict, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &tmp); DBG("key(%s), value(%s)", key, tmp); if (g_strcmp0(key, "roaming") == 0) { s_service->roaming = STRING2BOOL(tmp); } else if (g_strcmp0(key, "act") == 0) { s_service->act = g_strdup(tmp); } else if (g_strcmp0(key, "ps_attached") == 0) { s_service->ps_attached = STRING2BOOL(tmp); } dbus_message_iter_next(&dict); } roaming_option &= (!s_service->roaming && !modem->roaming_allowed) || modem->roaming_allowed; return TRUE; } static gboolean __added_service(DBusConnection *connection, DBusMessage *message, void *user_data) { struct telephony_modem *modem; const char *service_path = NULL; DBusMessageIter args, dict, tmp; const char *path = dbus_message_get_path(message); DBG("service added signal %s", path); modem = g_hash_table_lookup(modem_hash, path); if (modem == NULL || modem->device == NULL) return TRUE; DBG("message signature (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); memcpy(&tmp, &dict, sizeof(struct DBusMessageIter)); while (dbus_message_iter_get_arg_type(&tmp) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *value; dbus_message_iter_recurse(&tmp, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &value); DBG("key (%s) value(%s)", key, value); if (g_strcmp0(key, "path") == 0) service_path = value; dbus_message_iter_next(&tmp); } if (service_path != NULL) __add_service(modem, service_path, &dict); return TRUE; } static gboolean __removed_service(DBusConnection *connection, DBusMessage *message, void *user_data) { DBusMessageIter iter; const char *service_path; DBG("service removed signal"); if (dbus_message_iter_init(message, &iter) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_get_basic(&iter, &service_path); g_hash_table_remove(service_hash, service_path); return TRUE; } static gboolean __changed_context(DBusConnection *connection, DBusMessage *message, void *user_data) { gboolean active = FALSE; DBusMessageIter args, dict; struct telephony_network *info; const char *path = dbus_message_get_path(message); DBG("network changed signal %s", path); info = g_hash_table_lookup(network_hash, path); if (info == NULL) return TRUE; if (__check_network_available(info->network) == FALSE) { g_hash_table_remove(network_hash, path); return TRUE; } if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); active = __set_network_context(info, &dict); if(info->routing_only){ int err = 0; struct connman_service *routing_service; struct connman_ipconfig *routing_ipconfig; if(!active) return TRUE; routing_service = connman_service_lookup_from_network(info->network); routing_ipconfig = __connman_service_get_ip4config(routing_service); err = __connman_ipconfig_gateway_add(routing_ipconfig, routing_service); DBG("set gateway rv(%d)", err); return TRUE; } __set_network_connected(info, active); if (active == FALSE && connman_network_get_connecting(info->network) == TRUE) connman_network_set_connected(info->network, FALSE); return TRUE; } static gboolean __added_context(DBusConnection *connection, DBusMessage *message, void *user_data) { const char *network_path = NULL; DBusMessageIter args, dict, tmp; struct telephony_modem *modem = NULL; struct telephony_service *service = NULL; const char *path = dbus_message_get_path(message); DBG("network added signal %s", path); service = g_hash_table_lookup(service_hash, path); if (service == NULL || service->p_modem == NULL) return TRUE; modem = service->p_modem; if (modem == NULL || modem->device == NULL) return TRUE; DBG("message signature (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_recurse(&args, &dict); memcpy(&tmp, &dict, sizeof(struct DBusMessageIter)); while (dbus_message_iter_get_arg_type(&tmp) != DBUS_TYPE_INVALID) { DBusMessageIter entry; const char *key, *value; dbus_message_iter_recurse(&tmp, &entry); dbus_message_iter_get_basic(&entry, &key); dbus_message_iter_next(&entry); dbus_message_iter_get_basic(&entry, &value); DBG("key (%s) value(%s)", key, value); if (g_strcmp0(key, "path") == 0) network_path = g_strdup(value); dbus_message_iter_next(&tmp); } if (network_path != NULL) __add_context(modem->device, network_path, &dict); return TRUE; } static gboolean __removed_context(DBusConnection *connection, DBusMessage *message, void *user_data) { DBusMessageIter iter; const char *network_path = NULL; struct telephony_service *service = NULL; const char *path = dbus_message_get_path(message); DBG("network removed signal %s", path); service = g_hash_table_lookup(service_hash, path); if (service == NULL || service->p_modem == NULL) return TRUE; if (dbus_message_iter_init(message, &iter) == FALSE) { DBG("error to read message"); return TRUE; } dbus_message_iter_get_basic(&iter, &network_path); g_hash_table_remove(network_hash, network_path); return TRUE; } static gboolean __changed_default_subscription(DBusConnection *connection, DBusMessage *message, void *user_data) { DBusMessageIter args; DBG("message signature (%s)", dbus_message_get_signature(message)); if (dbus_message_iter_init(message, &args) == FALSE) return TRUE; dbus_message_iter_get_basic(&args, &telephony_default_subscription_id); DBG("default subscription: %d", telephony_default_subscription_id); return TRUE; } /* telephony initialization */ static guint watch = 0; static guint modem_watch = 0; static guint modem_added_watch = 0; static guint modem_removed_watch = 0; static guint service_watch = 0; static guint service_added_watch = 0; static guint service_removed_watch = 0; static guint context_watch = 0; static guint context_added_watch = 0; static guint context_removed_watch = 0; static guint default_subscription_watch = 0; static int telephony_init(void) { int err; DBG("telephony plugin"); connection = connman_dbus_get_connection(); if (connection == NULL) return -EIO; /* telephony watch */ watch = g_dbus_add_service_watch(connection, PS_DBUS_SERVICE, telephony_connect, telephony_disconnect, NULL, NULL); modem_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_MODEM_INTERFACE, PROPERTY_CHANGED, __changed_modem, NULL, NULL); modem_added_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_MASTER_INTERFACE, MODEM_ADDED, __added_modem, NULL, NULL); modem_removed_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_MASTER_INTERFACE, MODEM_REMOVED, __removed_modem, NULL, NULL); service_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_SERVICE_INTERFACE, PROPERTY_CHANGED, __changed_service, NULL, NULL); service_added_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_MODEM_INTERFACE, SERVICE_ADDED, __added_service, NULL, NULL); service_removed_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_MODEM_INTERFACE, SERVICE_REMOVED, __removed_service, NULL, NULL); context_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_CONTEXT_INTERFACE, PROPERTY_CHANGED, __changed_context, NULL, NULL); context_added_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_SERVICE_INTERFACE, CONTEXT_ADDED, __added_context, NULL, NULL); context_removed_watch = g_dbus_add_signal_watch(connection, NULL, NULL, PS_SERVICE_INTERFACE, CONTEXT_REMOVED, __removed_context, NULL, NULL); default_subscription_watch = g_dbus_add_signal_watch(connection, NULL, NULL, "org.tizen.telephony.Network", "DefaultDataSubscription", __changed_default_subscription, NULL, NULL); if (watch == 0 || modem_watch == 0 || modem_added_watch == 0 || modem_removed_watch == 0 || service_watch == 0 || service_added_watch == 0 || context_watch == 0 || service_removed_watch == 0 || context_added_watch == 0 || context_removed_watch == 0 || default_subscription_watch == 0) { err = -EIO; goto remove; } err = connman_network_driver_register(&network_driver); if (err < 0) goto remove; err = connman_device_driver_register(&modem_driver); if (err < 0) { connman_network_driver_unregister(&network_driver); goto remove; } err = connman_technology_driver_register(&tech_driver); if (err < 0) { connman_device_driver_unregister(&modem_driver); connman_network_driver_unregister(&network_driver); goto remove; } return 0; remove: g_dbus_remove_watch(connection, watch); g_dbus_remove_watch(connection, modem_watch); g_dbus_remove_watch(connection, modem_added_watch); g_dbus_remove_watch(connection, modem_removed_watch); g_dbus_remove_watch(connection, service_watch); g_dbus_remove_watch(connection, service_added_watch); g_dbus_remove_watch(connection, service_removed_watch); g_dbus_remove_watch(connection, context_watch); g_dbus_remove_watch(connection, context_added_watch); g_dbus_remove_watch(connection, context_removed_watch); g_dbus_remove_watch(connection, default_subscription_watch); dbus_connection_unref(connection); return err; } static void telephony_exit(void) { g_dbus_remove_watch(connection, watch); g_dbus_remove_watch(connection, modem_watch); g_dbus_remove_watch(connection, modem_added_watch); g_dbus_remove_watch(connection, modem_removed_watch); g_dbus_remove_watch(connection, service_watch); g_dbus_remove_watch(connection, service_added_watch); g_dbus_remove_watch(connection, service_removed_watch); g_dbus_remove_watch(connection, context_watch); g_dbus_remove_watch(connection, context_added_watch); g_dbus_remove_watch(connection, context_removed_watch); g_dbus_remove_watch(connection, default_subscription_watch); telephony_disconnect(connection, NULL); connman_device_driver_unregister(&modem_driver); connman_network_driver_unregister(&network_driver); dbus_connection_unref(connection); } CONNMAN_PLUGIN_DEFINE(telephony, "Samsung Telephony Framework plug-in", VERSION, CONNMAN_PLUGIN_PRIORITY_DEFAULT, telephony_init, telephony_exit)