X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fnotifier.c;h=a39d54c7a69a41a19eaf4b45ea049fae99801f7f;hb=refs%2Ftags%2Fupstream%2F1.38;hp=03367d4e1e100749f21c3b94bb0ff94b15330f7b;hpb=f69628b56b92b6e3d2bc7dbead9afcdce8c762cc;p=platform%2Fupstream%2Fconnman.git diff --git a/src/notifier.c b/src/notifier.c index 03367d4..a39d54c 100644 --- a/src/notifier.c +++ b/src/notifier.c @@ -2,7 +2,7 @@ * * Connection Manager * - * Copyright (C) 2007-2009 Intel Corporation. All rights reserved. + * Copyright (C) 2007-2013 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 @@ -23,9 +23,16 @@ #include #endif +#include + #include "connman.h" +static DBusConnection *connection = NULL; + static GSList *notifier_list = NULL; +static GHashTable *service_hash = NULL; + +static const char *notifier_state; static gint compare_priority(gconstpointer a, gconstpointer b) { @@ -43,11 +50,11 @@ static gint compare_priority(gconstpointer a, gconstpointer b) * * Returns: %0 on success */ -int connman_notifier_register(struct connman_notifier *notifier) +int connman_notifier_register(const struct connman_notifier *notifier) { DBG("notifier %p name %s", notifier, notifier->name); - notifier_list = g_slist_insert_sorted(notifier_list, notifier, + notifier_list = g_slist_insert_sorted(notifier_list, (void*)notifier, compare_priority); return 0; @@ -59,206 +66,328 @@ int connman_notifier_register(struct connman_notifier *notifier) * * Remove a previously registered notifier module */ -void connman_notifier_unregister(struct connman_notifier *notifier) +void connman_notifier_unregister(const struct connman_notifier *notifier) { DBG("notifier %p name %s", notifier, notifier->name); notifier_list = g_slist_remove(notifier_list, notifier); } -static void device_enabled(enum connman_device_type type, - connman_bool_t enabled) -{ - GSList *list; - - DBG("type %d enabled %d", type, enabled); +static int connected[MAX_CONNMAN_SERVICE_TYPES]; +static int online[MAX_CONNMAN_SERVICE_TYPES]; - for (list = notifier_list; list; list = list->next) { - struct connman_notifier *notifier = list->data; +static bool notifier_is_online(void) +{ + unsigned int i; - if (notifier->device_enabled) - notifier->device_enabled(type, enabled); + __sync_synchronize(); + for (i = 0; i < MAX_CONNMAN_SERVICE_TYPES; i++) { + if (online[i] > 0) + return true; } + + return false; } -static void device_registered(enum connman_device_type type, - connman_bool_t registered) +bool __connman_notifier_is_connected(void) { - DBG("type %d registered %d", type, registered); + unsigned int i; + + __sync_synchronize(); + for (i = 0; i < MAX_CONNMAN_SERVICE_TYPES; i++) { + if (connected[i] > 0) + return true; + } + + return false; } -static const char *type2string(enum connman_device_type type) +static const char *evaluate_notifier_state(void) { - switch (type) { - case CONNMAN_DEVICE_TYPE_UNKNOWN: - case CONNMAN_DEVICE_TYPE_MBM: - case CONNMAN_DEVICE_TYPE_HSO: - case CONNMAN_DEVICE_TYPE_NOZOMI: - case CONNMAN_DEVICE_TYPE_HUAWEI: - case CONNMAN_DEVICE_TYPE_NOVATEL: - case CONNMAN_DEVICE_TYPE_VENDOR: - break; - case CONNMAN_DEVICE_TYPE_ETHERNET: - return "ethernet"; - case CONNMAN_DEVICE_TYPE_WIFI: - return "wifi"; - case CONNMAN_DEVICE_TYPE_WIMAX: - return "wimax"; - case CONNMAN_DEVICE_TYPE_BLUETOOTH: - return "bluetooth"; - case CONNMAN_DEVICE_TYPE_GPS: - return "gps"; - } + if (notifier_is_online()) + return "online"; - return NULL; + if (__connman_notifier_is_connected()) + return "ready"; + + if (__connman_technology_get_offlinemode()) + return "offline"; + + return "idle"; } -static volatile gint registered[20]; -static volatile gint enabled[20]; +const char *__connman_notifier_get_state(void) +{ + return notifier_state; +} -void __connman_notifier_device_type_list(gboolean powered, - DBusMessageIter *iter) +static void state_changed(void) { - int i; + const char *state; - for (i = 0; i < 10; i++) { - const char *type = type2string(i); - gint count; + state = evaluate_notifier_state(); - if (type == NULL) - continue; + if (g_strcmp0(state, notifier_state) == 0) + return; - if (powered == TRUE) - count = g_atomic_int_get(&enabled[i]); - else - count = g_atomic_int_get(®istered[i]); + notifier_state = state; - if (count > 0) - dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &type); - } + connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH, + CONNMAN_MANAGER_INTERFACE, "State", + DBUS_TYPE_STRING, ¬ifier_state); } -void __connman_notifier_device_type_register(enum connman_device_type type) +void __connman_notifier_connect(enum connman_service_type type) { DBG("type %d", type); switch (type) { - case CONNMAN_DEVICE_TYPE_UNKNOWN: - case CONNMAN_DEVICE_TYPE_MBM: - case CONNMAN_DEVICE_TYPE_HSO: - case CONNMAN_DEVICE_TYPE_NOZOMI: - case CONNMAN_DEVICE_TYPE_HUAWEI: - case CONNMAN_DEVICE_TYPE_NOVATEL: - case CONNMAN_DEVICE_TYPE_VENDOR: + case CONNMAN_SERVICE_TYPE_UNKNOWN: + case CONNMAN_SERVICE_TYPE_SYSTEM: + case CONNMAN_SERVICE_TYPE_GPS: + case CONNMAN_SERVICE_TYPE_VPN: return; - case CONNMAN_DEVICE_TYPE_ETHERNET: - case CONNMAN_DEVICE_TYPE_WIFI: - case CONNMAN_DEVICE_TYPE_WIMAX: - case CONNMAN_DEVICE_TYPE_BLUETOOTH: - case CONNMAN_DEVICE_TYPE_GPS: - if (g_atomic_int_exchange_and_add(®istered[type], 1) == 0) - device_registered(type, TRUE); + case CONNMAN_SERVICE_TYPE_ETHERNET: + case CONNMAN_SERVICE_TYPE_GADGET: + case CONNMAN_SERVICE_TYPE_WIFI: + case CONNMAN_SERVICE_TYPE_BLUETOOTH: + case CONNMAN_SERVICE_TYPE_CELLULAR: + case CONNMAN_SERVICE_TYPE_P2P: break; } + + if (__sync_fetch_and_add(&connected[type], 1) == 0) { + __connman_technology_set_connected(type, true); + state_changed(); + } } -void __connman_notifier_device_type_unregister(enum connman_device_type type) +void __connman_notifier_enter_online(enum connman_service_type type) { DBG("type %d", type); - switch (type) { - case CONNMAN_DEVICE_TYPE_UNKNOWN: - case CONNMAN_DEVICE_TYPE_MBM: - case CONNMAN_DEVICE_TYPE_HSO: - case CONNMAN_DEVICE_TYPE_NOZOMI: - case CONNMAN_DEVICE_TYPE_HUAWEI: - case CONNMAN_DEVICE_TYPE_NOVATEL: - case CONNMAN_DEVICE_TYPE_VENDOR: - return; - case CONNMAN_DEVICE_TYPE_ETHERNET: - case CONNMAN_DEVICE_TYPE_WIFI: - case CONNMAN_DEVICE_TYPE_WIMAX: - case CONNMAN_DEVICE_TYPE_BLUETOOTH: - case CONNMAN_DEVICE_TYPE_GPS: - if (g_atomic_int_dec_and_test(®istered[type]) == TRUE) - device_registered(type, FALSE); - break; - } + if (__sync_fetch_and_add(&online[type], 1) == 0) + state_changed(); } -void __connman_notifier_device_type_increase(enum connman_device_type type) +void __connman_notifier_leave_online(enum connman_service_type type) { DBG("type %d", type); - switch (type) { - case CONNMAN_DEVICE_TYPE_UNKNOWN: - case CONNMAN_DEVICE_TYPE_MBM: - case CONNMAN_DEVICE_TYPE_HSO: - case CONNMAN_DEVICE_TYPE_NOZOMI: - case CONNMAN_DEVICE_TYPE_HUAWEI: - case CONNMAN_DEVICE_TYPE_NOVATEL: - case CONNMAN_DEVICE_TYPE_VENDOR: - return; - case CONNMAN_DEVICE_TYPE_ETHERNET: - case CONNMAN_DEVICE_TYPE_WIFI: - case CONNMAN_DEVICE_TYPE_WIMAX: - case CONNMAN_DEVICE_TYPE_BLUETOOTH: - case CONNMAN_DEVICE_TYPE_GPS: - if (g_atomic_int_exchange_and_add(&enabled[type], 1) == 0) - device_enabled(type, TRUE); - break; - } + if (__sync_fetch_and_sub(&online[type], 1) == 1) + state_changed(); } -void __connman_notifier_device_type_decrease(enum connman_device_type type) +void __connman_notifier_disconnect(enum connman_service_type type) { DBG("type %d", type); + __sync_synchronize(); + if (connected[type] == 0) { + connman_error("notifier disconnect underflow"); + return; + } + switch (type) { - case CONNMAN_DEVICE_TYPE_UNKNOWN: - case CONNMAN_DEVICE_TYPE_MBM: - case CONNMAN_DEVICE_TYPE_HSO: - case CONNMAN_DEVICE_TYPE_NOZOMI: - case CONNMAN_DEVICE_TYPE_HUAWEI: - case CONNMAN_DEVICE_TYPE_NOVATEL: - case CONNMAN_DEVICE_TYPE_VENDOR: + case CONNMAN_SERVICE_TYPE_UNKNOWN: + case CONNMAN_SERVICE_TYPE_SYSTEM: + case CONNMAN_SERVICE_TYPE_GPS: + case CONNMAN_SERVICE_TYPE_VPN: return; - case CONNMAN_DEVICE_TYPE_ETHERNET: - case CONNMAN_DEVICE_TYPE_WIFI: - case CONNMAN_DEVICE_TYPE_WIMAX: - case CONNMAN_DEVICE_TYPE_BLUETOOTH: - case CONNMAN_DEVICE_TYPE_GPS: - if (g_atomic_int_dec_and_test(&enabled[type]) == TRUE) - device_enabled(type, FALSE); + case CONNMAN_SERVICE_TYPE_ETHERNET: + case CONNMAN_SERVICE_TYPE_GADGET: + case CONNMAN_SERVICE_TYPE_WIFI: + case CONNMAN_SERVICE_TYPE_BLUETOOTH: + case CONNMAN_SERVICE_TYPE_CELLULAR: + case CONNMAN_SERVICE_TYPE_P2P: break; } + + if (__sync_fetch_and_sub(&connected[type], 1) != 1) + return; + + __connman_technology_set_connected(type, false); + state_changed(); +} + +void __connman_notifier_default_changed(struct connman_service *service) +{ + GSList *list; + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->default_changed) + notifier->default_changed(service); + } +} + +void __connman_notifier_service_add(struct connman_service *service, + const char *name) +{ + GSList *list; + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->service_add) + notifier->service_add(service, name); + } +} + +void __connman_notifier_service_remove(struct connman_service *service) +{ + GSList *list; + + if (g_hash_table_lookup(service_hash, service)) { + /* + * This is a temporary check for consistency. It can be + * removed when there are no reports for the following + * error message. + */ + connman_error("Service state machine inconsistency detected."); + + g_hash_table_remove(service_hash, service); + } + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->service_remove) + notifier->service_remove(service); + } } -void __connman_notifier_offline_mode(connman_bool_t enabled) +void __connman_notifier_proxy_changed(struct connman_service *service) { GSList *list; + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->proxy_changed) + notifier->proxy_changed(service); + } +} + +static void offlinemode_changed(dbus_bool_t enabled) +{ DBG("enabled %d", enabled); - __connman_profile_changed(FALSE); + connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH, + CONNMAN_MANAGER_INTERFACE, "OfflineMode", + DBUS_TYPE_BOOLEAN, &enabled); +} + +void __connman_notifier_offlinemode(bool enabled) +{ + GSList *list; + + DBG("enabled %d", enabled); + + offlinemode_changed(enabled); + state_changed(); for (list = notifier_list; list; list = list->next) { - struct connman_notifier *notifier = list->data; + const struct connman_notifier *notifier = list->data; if (notifier->offline_mode) notifier->offline_mode(enabled); } } +static void notify_idle_state(bool idle) +{ + GSList *list; + + DBG("idle %d", idle); + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->idle_state) + notifier->idle_state(idle); + } +} + +void __connman_notifier_service_state_changed(struct connman_service *service, + enum connman_service_state state) +{ + GSList *list; + unsigned int old_size; + bool found; + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->service_state_changed) + notifier->service_state_changed(service, state); + } + + old_size = g_hash_table_size(service_hash); + found = g_hash_table_lookup(service_hash, service); + + switch (state) { + case CONNMAN_SERVICE_STATE_UNKNOWN: + case CONNMAN_SERVICE_STATE_FAILURE: + case CONNMAN_SERVICE_STATE_DISCONNECT: + case CONNMAN_SERVICE_STATE_IDLE: + if (!found) + break; + + g_hash_table_remove(service_hash, service); + if (old_size == 1) + notify_idle_state(true); + + break; + case CONNMAN_SERVICE_STATE_ASSOCIATION: + case CONNMAN_SERVICE_STATE_CONFIGURATION: + case CONNMAN_SERVICE_STATE_READY: + case CONNMAN_SERVICE_STATE_ONLINE: + if (found) + break; + + g_hash_table_insert(service_hash, service, service); + if (old_size == 0) + notify_idle_state(false); + + break; + } +} + +void __connman_notifier_ipconfig_changed(struct connman_service *service, + struct connman_ipconfig *ipconfig) +{ + GSList *list; + + for (list = notifier_list; list; list = list->next) { + const struct connman_notifier *notifier = list->data; + + if (notifier->ipconfig_changed) + notifier->ipconfig_changed(service, ipconfig); + } +} + int __connman_notifier_init(void) { DBG(""); + connection = connman_dbus_get_connection(); + + service_hash = g_hash_table_new_full(g_direct_hash, g_direct_equal, + NULL, NULL); + + notifier_state = evaluate_notifier_state(); + return 0; } void __connman_notifier_cleanup(void) { DBG(""); + + g_hash_table_destroy(service_hash); + service_hash = NULL; + + dbus_connection_unref(connection); }