X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fnotifier.c;h=b328a2adbfaae03f371739324d30893fc51c759b;hb=b8162e19cfc7b3ce25b72983c0df4de6e14cbafe;hp=ec04d954f079fd61759ca5a4c8525235dd0b6cbb;hpb=f425974003005b7587b59bba7cfeb8b1ac6aa7b0;p=framework%2Fconnectivity%2Fconnman.git diff --git a/src/notifier.c b/src/notifier.c index ec04d95..b328a2a 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-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 @@ -30,6 +30,9 @@ 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) { @@ -72,169 +75,89 @@ void connman_notifier_unregister(struct connman_notifier *notifier) #define MAX_TECHNOLOGIES 10 -static volatile gint registered[MAX_TECHNOLOGIES]; -static volatile gint enabled[MAX_TECHNOLOGIES]; -static volatile gint connected[MAX_TECHNOLOGIES]; +static int connected[MAX_TECHNOLOGIES]; +static int online[MAX_TECHNOLOGIES]; -void __connman_notifier_list_registered(DBusMessageIter *iter) +static connman_bool_t notifier_is_online(void) { - int i; - - for (i = 0; i < 10; i++) { - const char *type = __connman_service_type2string(i); - - if (type == NULL) - continue; + unsigned int i; - if (g_atomic_int_get(®istered[i]) > 0) - dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &type); + __sync_synchronize(); + for (i = 0; i < MAX_TECHNOLOGIES; i++) { + if (online[i] > 0) + return TRUE; } + + return FALSE; } -void __connman_notifier_list_enabled(DBusMessageIter *iter) +connman_bool_t __connman_notifier_is_connected(void) { - int i; - - for (i = 0; i < 10; i++) { - const char *type = __connman_service_type2string(i); + unsigned int i; - if (type == NULL) - continue; - - if (g_atomic_int_get(&enabled[i]) > 0) - dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &type); + __sync_synchronize(); + for (i = 0; i < MAX_TECHNOLOGIES; i++) { + if (connected[i] > 0) + return TRUE; } + + return FALSE; } -void __connman_notifier_list_connected(DBusMessageIter *iter) +static const char *evaluate_notifier_state(void) { - int i; + if (notifier_is_online() == TRUE) + return "online"; - for (i = 0; i < 10; i++) { - const char *type = __connman_service_type2string(i); + if (__connman_notifier_is_connected() == TRUE) + return "ready"; - if (type == NULL) - continue; + if ( __connman_technology_get_offlinemode() == TRUE) + return "offline"; - if (g_atomic_int_get(&connected[i]) > 0) - dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &type); - } + return "idle"; } -static void technology_registered(enum connman_service_type type, - connman_bool_t registered) +const char *__connman_notifier_get_state(void) { - DBusMessage *signal; - DBusMessageIter entry, value, iter; - const char *key = "AvailableTechnologies"; - - DBG("type %d registered %d", type, registered); - - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "PropertyChanged"); - if (signal == NULL) - return; - - dbus_message_iter_init_append(signal, &entry); - - dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key); - - dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, - DBUS_TYPE_ARRAY_AS_STRING DBUS_TYPE_STRING_AS_STRING, - &value); - - dbus_message_iter_open_container(&value, DBUS_TYPE_ARRAY, - DBUS_TYPE_STRING_AS_STRING, &iter); - __connman_notifier_list_registered(&iter); - dbus_message_iter_close_container(&value, &iter); - - dbus_message_iter_close_container(&entry, &value); - - g_dbus_send_message(connection, signal); + return notifier_state; } -static void technology_enabled(enum connman_service_type type, - connman_bool_t enabled) +static void state_changed(void) { - GSList *list; - DBusMessage *signal; - DBusMessageIter entry, value, iter; - const char *key = "EnabledTechnologies"; - - DBG("type %d enabled %d", type, enabled); + const char *state; - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "PropertyChanged"); - if (signal == NULL) - goto done; + state = evaluate_notifier_state(); - dbus_message_iter_init_append(signal, &entry); - - dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key); - - dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, - DBUS_TYPE_ARRAY_AS_STRING DBUS_TYPE_STRING_AS_STRING, - &value); - - dbus_message_iter_open_container(&value, DBUS_TYPE_ARRAY, - DBUS_TYPE_STRING_AS_STRING, &iter); - __connman_notifier_list_enabled(&iter); - dbus_message_iter_close_container(&value, &iter); - - dbus_message_iter_close_container(&entry, &value); + if (g_strcmp0(state, notifier_state) == 0) + return; - g_dbus_send_message(connection, signal); + notifier_state = state; -done: - for (list = notifier_list; list; list = list->next) { - struct connman_notifier *notifier = list->data; - - if (notifier->service_enabled) - notifier->service_enabled(type, enabled); - } + connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH, + CONNMAN_MANAGER_INTERFACE, "State", + DBUS_TYPE_STRING, ¬ifier_state); } static void technology_connected(enum connman_service_type type, connman_bool_t connected) { - DBusMessage *signal; - DBusMessageIter entry, value, iter; - const char *key = "ConnectedTechnologies"; - DBG("type %d connected %d", type, connected); - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "PropertyChanged"); - if (signal == NULL) - return; - - dbus_message_iter_init_append(signal, &entry); - - dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key); - - dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, - DBUS_TYPE_ARRAY_AS_STRING DBUS_TYPE_STRING_AS_STRING, - &value); - - dbus_message_iter_open_container(&value, DBUS_TYPE_ARRAY, - DBUS_TYPE_STRING_AS_STRING, &iter); - __connman_notifier_list_connected(&iter); - dbus_message_iter_close_container(&value, &iter); - - dbus_message_iter_close_container(&entry, &value); - - g_dbus_send_message(connection, signal); + __connman_technology_set_connected(type, connected); + state_changed(); } -void __connman_notifier_register(enum connman_service_type type) +void __connman_notifier_connect(enum connman_service_type type) { DBG("type %d", type); switch (type) { case CONNMAN_SERVICE_TYPE_UNKNOWN: + case CONNMAN_SERVICE_TYPE_SYSTEM: + case CONNMAN_SERVICE_TYPE_GPS: + case CONNMAN_SERVICE_TYPE_VPN: + case CONNMAN_SERVICE_TYPE_GADGET: return; case CONNMAN_SERVICE_TYPE_ETHERNET: case CONNMAN_SERVICE_TYPE_WIFI: @@ -244,73 +167,42 @@ void __connman_notifier_register(enum connman_service_type type) break; } - if (g_atomic_int_exchange_and_add(®istered[type], 1) == 0) - technology_registered(type, TRUE); + if (__sync_fetch_and_add(&connected[type], 1) == 0) + technology_connected(type, TRUE); } -void __connman_notifier_unregister(enum connman_service_type type) +void __connman_notifier_enter_online(enum connman_service_type type) { DBG("type %d", type); - switch (type) { - case CONNMAN_SERVICE_TYPE_UNKNOWN: - return; - case CONNMAN_SERVICE_TYPE_ETHERNET: - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_WIMAX: - case CONNMAN_SERVICE_TYPE_BLUETOOTH: - case CONNMAN_SERVICE_TYPE_CELLULAR: - break; - } - - if (g_atomic_int_dec_and_test(®istered[type]) == TRUE) - technology_registered(type, FALSE); + if (__sync_fetch_and_add(&online[type], 1) == 0) + state_changed(); } -void __connman_notifier_enable(enum connman_service_type type) +void __connman_notifier_leave_online(enum connman_service_type type) { DBG("type %d", type); - switch (type) { - case CONNMAN_SERVICE_TYPE_UNKNOWN: - return; - case CONNMAN_SERVICE_TYPE_ETHERNET: - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_WIMAX: - case CONNMAN_SERVICE_TYPE_BLUETOOTH: - case CONNMAN_SERVICE_TYPE_CELLULAR: - break; - } - - if (g_atomic_int_exchange_and_add(&enabled[type], 1) == 0) - technology_enabled(type, TRUE); + if (__sync_fetch_and_sub(&online[type], 1) == 1) + state_changed(); } -void __connman_notifier_disable(enum connman_service_type type) +void __connman_notifier_disconnect(enum connman_service_type type) { DBG("type %d", type); - switch (type) { - case CONNMAN_SERVICE_TYPE_UNKNOWN: + __sync_synchronize(); + if (connected[type] == 0) { + connman_error("notifier disconnect underflow"); return; - case CONNMAN_SERVICE_TYPE_ETHERNET: - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_WIMAX: - case CONNMAN_SERVICE_TYPE_BLUETOOTH: - case CONNMAN_SERVICE_TYPE_CELLULAR: - break; } - if (g_atomic_int_dec_and_test(&enabled[type]) == TRUE) - technology_enabled(type, FALSE); -} - -void __connman_notifier_connect(enum connman_service_type type) -{ - DBG("type %d", type); - switch (type) { case CONNMAN_SERVICE_TYPE_UNKNOWN: + case CONNMAN_SERVICE_TYPE_SYSTEM: + case CONNMAN_SERVICE_TYPE_GPS: + case CONNMAN_SERVICE_TYPE_VPN: + case CONNMAN_SERVICE_TYPE_GADGET: return; case CONNMAN_SERVICE_TYPE_ETHERNET: case CONNMAN_SERVICE_TYPE_WIFI: @@ -320,94 +212,79 @@ void __connman_notifier_connect(enum connman_service_type type) break; } - if (g_atomic_int_exchange_and_add(&connected[type], 1) == 0) - technology_connected(type, TRUE); + if (__sync_fetch_and_sub(&connected[type], 1) != 1) + return; + + technology_connected(type, FALSE); } -void __connman_notifier_disconnect(enum connman_service_type type) +void __connman_notifier_default_changed(struct connman_service *service) { - DBG("type %d", type); + GSList *list; - switch (type) { - case CONNMAN_SERVICE_TYPE_UNKNOWN: - return; - case CONNMAN_SERVICE_TYPE_ETHERNET: - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_WIMAX: - case CONNMAN_SERVICE_TYPE_BLUETOOTH: - case CONNMAN_SERVICE_TYPE_CELLULAR: - break; - } + for (list = notifier_list; list; list = list->next) { + struct connman_notifier *notifier = list->data; - if (g_atomic_int_dec_and_test(&connected[type]) == TRUE) - technology_connected(type, FALSE); + if (notifier->default_changed) + notifier->default_changed(service); + } } -static void technology_default(enum connman_service_type type) +void __connman_notifier_service_add(struct connman_service *service, + const char *name) { - DBusMessage *signal; - DBusMessageIter entry, value; - const char *str, *key = "DefaultTechnology"; + GSList *list; - str = __connman_service_type2string(type); - if (str == NULL) - return; + for (list = notifier_list; list; list = list->next) { + struct connman_notifier *notifier = list->data; - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "PropertyChanged"); - if (signal == NULL) - return; + if (notifier->service_add) + notifier->service_add(service, name); + } +} + +void __connman_notifier_service_remove(struct connman_service *service) +{ + GSList *list; - dbus_message_iter_init_append(signal, &entry); + if (g_hash_table_lookup(service_hash, service) != NULL) { + /* + * This is a tempory check for consistency. It can be + * removed when there are no reports for the following + * error message. + */ + connman_error("Service state machine inconsistency detected."); - dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key); + g_hash_table_remove(service_hash, service); + } - dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, - DBUS_TYPE_STRING_AS_STRING, &value); - dbus_message_iter_append_basic(&value, DBUS_TYPE_STRING, &str); - dbus_message_iter_close_container(&entry, &value); + for (list = notifier_list; list; list = list->next) { + struct connman_notifier *notifier = list->data; - g_dbus_send_message(connection, signal); + if (notifier->service_remove) + notifier->service_remove(service); + } } -void __connman_notifier_default_changed(struct connman_service *service) +void __connman_notifier_proxy_changed(struct connman_service *service) { - enum connman_service_type type = connman_service_get_type(service); GSList *list; - technology_default(type); - for (list = notifier_list; list; list = list->next) { struct connman_notifier *notifier = list->data; - if (notifier->default_changed) - notifier->default_changed(service); + if (notifier->proxy_changed) + notifier->proxy_changed(service); } } static void offlinemode_changed(dbus_bool_t enabled) { - DBusMessage *signal; - DBusMessageIter entry, value; - const char *key = "OfflineMode"; - DBG("enabled %d", enabled); - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "PropertyChanged"); - if (signal == NULL) - return; - - dbus_message_iter_init_append(signal, &entry); - - dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key); - - dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, - DBUS_TYPE_BOOLEAN_AS_STRING, &value); - dbus_message_iter_append_basic(&value, DBUS_TYPE_BOOLEAN, &enabled); - dbus_message_iter_close_container(&entry, &value); - - g_dbus_send_message(connection, signal); + connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH, + CONNMAN_MANAGER_INTERFACE, "OfflineMode", + DBUS_TYPE_BOOLEAN, &enabled); } void __connman_notifier_offlinemode(connman_bool_t enabled) @@ -416,9 +293,8 @@ void __connman_notifier_offlinemode(connman_bool_t enabled) DBG("enabled %d", enabled); - __connman_profile_changed(FALSE); - offlinemode_changed(enabled); + state_changed(); for (list = notifier_list; list; list = list->next) { struct connman_notifier *notifier = list->data; @@ -428,25 +304,76 @@ void __connman_notifier_offlinemode(connman_bool_t enabled) } } -connman_bool_t __connman_notifier_is_enabled(enum connman_service_type type) +static void notify_idle_state(connman_bool_t idle) { - DBG("type %d", type); + GSList *list; + + DBG("idle %d", idle); + + for (list = notifier_list; list; list = list->next) { + 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; + connman_bool_t found; + + for (list = notifier_list; list; list = list->next) { + 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) != NULL; + + switch (state) { + case CONNMAN_SERVICE_STATE_UNKNOWN: + case CONNMAN_SERVICE_STATE_FAILURE: + case CONNMAN_SERVICE_STATE_DISCONNECT: + case CONNMAN_SERVICE_STATE_IDLE: + if (found == FALSE) + 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 == TRUE) + break; + + g_hash_table_insert(service_hash, service, service); + if (old_size == 0) + notify_idle_state(FALSE); - switch (type) { - case CONNMAN_SERVICE_TYPE_UNKNOWN: - return FALSE; - case CONNMAN_SERVICE_TYPE_ETHERNET: - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_WIMAX: - case CONNMAN_SERVICE_TYPE_BLUETOOTH: - case CONNMAN_SERVICE_TYPE_CELLULAR: break; } +} - if (g_atomic_int_get(&enabled[type]) > 0) - return TRUE; +void __connman_notifier_ipconfig_changed(struct connman_service *service, + struct connman_ipconfig *ipconfig) +{ + GSList *list; - return FALSE; + for (list = notifier_list; list; list = list->next) { + struct connman_notifier *notifier = list->data; + + if (notifier->ipconfig_changed) + notifier->ipconfig_changed(service, ipconfig); + } } int __connman_notifier_init(void) @@ -455,6 +382,11 @@ int __connman_notifier_init(void) 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; } @@ -462,5 +394,8 @@ void __connman_notifier_cleanup(void) { DBG(""); + g_hash_table_destroy(service_hash); + service_hash = NULL; + dbus_connection_unref(connection); }