X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fservice.c;h=01e01f276297ec088c2672255e7c9f8941a26599;hb=6c8213f23b60fb46e6cd2572a6adc7ce4da13691;hp=8a7e4238f8ef440af0f3c67fb9848b83ba68d2ac;hpb=277eb409c909f4f7361bf441984656b0a7941de3;p=framework%2Fconnectivity%2Fconnman.git diff --git a/src/service.c b/src/service.c index 8a7e423..01e01f2 100644 --- a/src/service.c +++ b/src/service.c @@ -2,7 +2,7 @@ * * Connection Manager * - * Copyright (C) 2007-2010 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 @@ -28,8 +28,10 @@ #include #include #include +#include #include +#include #include "connman.h" @@ -40,6 +42,8 @@ static DBusConnection *connection = NULL; static GSequence *service_list = NULL; static GHashTable *service_hash = NULL; static GSList *counter_list = NULL; +static unsigned int autoconnect_timeout = 0; +static struct connman_service *current_default = NULL; struct connman_stats { connman_bool_t valid; @@ -112,6 +116,8 @@ struct connman_service { connman_bool_t wps; int online_check_count; connman_bool_t do_split_routing; + connman_bool_t new_service; + connman_bool_t hidden_service; }; struct find_data { @@ -318,8 +324,11 @@ static int service_load(struct connman_service *service) DBG("service %p", service); keyfile = connman_storage_load_service(service->identifier); - if (keyfile == NULL) + if (keyfile == NULL) { + service->new_service = TRUE; return -EIO; + } else + service->new_service = FALSE; switch (service->type) { case CONNMAN_SERVICE_TYPE_UNKNOWN: @@ -478,6 +487,9 @@ static int service_load(struct connman_service *service) service->pac = str; } + service->hidden_service = g_key_file_get_boolean(keyfile, + service->identifier, "Hidden", NULL); + done: g_key_file_free(keyfile); @@ -492,7 +504,10 @@ static int service_save(struct connman_service *service) const char *cst_str = NULL; int err = 0; - DBG("service %p", service); + DBG("service %p new %d", service, service->new_service); + + if (service->new_service == TRUE) + return -ESRCH; keyfile = __connman_storage_open_service(service->identifier); if (keyfile == NULL) @@ -657,6 +672,10 @@ static int service_save(struct connman_service *service) g_key_file_remove_key(keyfile, service->identifier, "Proxy.URL", NULL); + if (service->hidden_service == TRUE) + g_key_file_set_boolean(keyfile, service->identifier, "Hidden", + TRUE); + done: __connman_storage_save_service(keyfile, service->identifier); @@ -1252,6 +1271,13 @@ static void default_changed(void) { struct connman_service *service = __connman_service_get_default(); + if (service == current_default) + return; + + __connman_service_timeserver_changed(current_default, NULL); + + current_default = service; + __connman_notifier_default_changed(service); } @@ -1459,6 +1485,21 @@ static void append_dnsconfig(DBusMessageIter *iter, void *user_data) } } +static void append_ts(DBusMessageIter *iter, void *user_data) +{ + GSList *list = user_data; + + while (list != NULL) { + char *timeserver = list->data; + + if (timeserver != NULL) + dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, + ×erver); + + list = g_slist_next(list); + } +} + static void append_tsconfig(DBusMessageIter *iter, void *user_data) { struct connman_service *service = user_data; @@ -1474,32 +1515,32 @@ static void append_tsconfig(DBusMessageIter *iter, void *user_data) } } -static void append_domain(DBusMessageIter *iter, void *user_data) +static void append_domainconfig(DBusMessageIter *iter, void *user_data) { struct connman_service *service = user_data; + int i; - if (is_connected(service) == FALSE && - is_connecting(service) == FALSE) - return; - - if (service->domainname == NULL) + if (service->domains == NULL) return; - dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &service->domainname); + for (i = 0; service->domains[i]; i++) + dbus_message_iter_append_basic(iter, + DBUS_TYPE_STRING, &service->domains[i]); } -static void append_domainconfig(DBusMessageIter *iter, void *user_data) +static void append_domain(DBusMessageIter *iter, void *user_data) { struct connman_service *service = user_data; - int i; - if (service->domains == NULL) + if (is_connected(service) == FALSE && + is_connecting(service) == FALSE) return; - for (i = 0; service->domains[i]; i++) + if (service->domains != NULL) + append_domainconfig(iter, user_data); + else if (service->domainname != NULL) dbus_message_iter_append_basic(iter, - DBUS_TYPE_STRING, &service->domains[i]); + DBUS_TYPE_STRING, &service->domainname); } static void append_proxies(DBusMessageIter *iter, void *user_data) @@ -1715,6 +1756,15 @@ static void proxy_configuration_changed(struct connman_service *service) proxy_changed(service); } +static void timeservers_configuration_changed(struct connman_service *service) +{ + connman_dbus_property_changed_array(service->path, + CONNMAN_SERVICE_INTERFACE, + "Timeservers.Configuration", + DBUS_TYPE_STRING, + append_tsconfig, service); +} + static void link_changed(struct connman_service *service) { connman_dbus_property_changed_dict(service->path, @@ -2015,6 +2065,7 @@ static void append_properties(DBusMessageIter *dict, dbus_bool_t limited, struct connman_service *service) { const char *str; + GSList *list; str = __connman_service_type2string(service->type); if (str != NULL) @@ -2094,6 +2145,17 @@ static void append_properties(DBusMessageIter *dict, dbus_bool_t limited, connman_dbus_dict_append_array(dict, "Nameservers.Configuration", DBUS_TYPE_STRING, append_dnsconfig, service); + if (service->state == CONNMAN_SERVICE_STATE_READY || + service->state == CONNMAN_SERVICE_STATE_ONLINE) + list = __connman_timeserver_get_all(service); + else + list = NULL; + + connman_dbus_dict_append_array(dict, "Timeservers", + DBUS_TYPE_STRING, append_ts, list); + + g_slist_free_full(list, g_free); + connman_dbus_dict_append_array(dict, "Timeservers.Configuration", DBUS_TYPE_STRING, append_tsconfig, service); @@ -2178,6 +2240,14 @@ int __connman_service_get_index(struct connman_service *service) return -1; } +void __connman_service_set_hidden(struct connman_service *service) +{ + if (service == NULL || service->hidden == TRUE) + return; + + service->hidden_service = TRUE; +} + void __connman_service_set_domainname(struct connman_service *service, const char *domainname) { @@ -2428,6 +2498,17 @@ int __connman_service_timeserver_remove(struct connman_service *service, return 0; } +void __connman_service_timeserver_changed(struct connman_service *service, + GSList *ts_list) +{ + if (service == NULL) + return; + + connman_dbus_property_changed_array(service->path, + CONNMAN_SERVICE_INTERFACE, "Timeservers", + DBUS_TYPE_STRING, append_ts, ts_list); +} + void __connman_service_set_pac(struct connman_service *service, const char *pac) { @@ -2468,21 +2549,76 @@ void __connman_service_set_agent_identity(struct connman_service *service, service->agent_identity); } -void __connman_service_set_passphrase(struct connman_service *service, - const char* passphrase) +static int check_passphrase(enum connman_service_security security, + const char *passphrase) { + guint i; + gsize length; + + if (passphrase == NULL) + return 0; + + length = strlen(passphrase); + + switch (security) { + case CONNMAN_SERVICE_SECURITY_PSK: + case CONNMAN_SERVICE_SECURITY_WPA: + case CONNMAN_SERVICE_SECURITY_RSN: + /* A raw key is always 64 bytes length, + * its content is in hex representation. + * A PSK key must be between [8..63]. + */ + if (length == 64) { + for (i = 0; i < 64; i++) + if (!isxdigit((unsigned char) + passphrase[i])) + return -ENOKEY; + } else if (length < 8 || length > 63) + return -ENOKEY; + break; + case CONNMAN_SERVICE_SECURITY_WEP: + /* length of WEP key is 10 or 26 + * length of WEP passphrase is 5 or 13 + */ + if (length == 10 || length == 26) { + for (i = 0; i < length; i++) + if (!isxdigit((unsigned char) + passphrase[i])) + return -ENOKEY; + } else if (length != 5 && length != 13) + return -ENOKEY; + break; + case CONNMAN_SERVICE_SECURITY_UNKNOWN: + case CONNMAN_SERVICE_SECURITY_NONE: + case CONNMAN_SERVICE_SECURITY_8021X: + break; + } + + return 0; +} + +int __connman_service_set_passphrase(struct connman_service *service, + const char *passphrase) +{ + int err = 0; + if (service->immutable == TRUE || service->hidden == TRUE) - return; + return -EINVAL; - g_free(service->passphrase); - service->passphrase = g_strdup(passphrase); + err = check_passphrase(service->security, passphrase); - if (service->network != NULL) - connman_network_set_string(service->network, - "WiFi.Passphrase", - service->passphrase); + if (err == 0) { + g_free(service->passphrase); + service->passphrase = g_strdup(passphrase); - service_save(service); + if (service->network != NULL) + connman_network_set_string(service->network, + "WiFi.Passphrase", + service->passphrase); + service_save(service); + } + + return err; } void __connman_service_set_agent_passphrase(struct connman_service *service, @@ -2799,7 +2935,8 @@ static DBusMessage *set_property(DBusConnection *conn, return __connman_error_invalid_arguments(msg); index = connman_network_get_index(service->network); - gw = __connman_ipconfig_get_gateway_from_index(index); + gw = __connman_ipconfig_get_gateway_from_index(index, + CONNMAN_IPCONFIG_TYPE_ALL); if (gw && strlen(gw)) __connman_service_nameserver_del_routes(service, @@ -2847,10 +2984,15 @@ static DBusMessage *set_property(DBusConnection *conn, while (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_STRING) { const char *val; + GSList *new_head; + dbus_message_iter_get_basic(&entry, &val); - list = g_slist_prepend(list, strdup(val)); - count++; + new_head = __connman_timeserver_add_list(list, val); + if (list != new_head) { + count++; + list = new_head; + } dbus_message_iter_next(&entry); } @@ -2869,6 +3011,7 @@ static DBusMessage *set_property(DBusConnection *conn, } service_save(service); + timeservers_configuration_changed(service); __connman_timeserver_sync(service); } else if (g_str_equal(name, "Domains.Configuration") == TRUE) { @@ -3019,48 +3162,132 @@ static connman_bool_t is_ignore(struct connman_service *service) return FALSE; } -void __connman_service_auto_connect(void) +struct preferred_tech_data { + GSequence *preferred_list; + enum connman_service_type type; +}; + +static void preferred_tech_add_by_type(gpointer data, gpointer user_data) { - struct connman_service *service = NULL; - GSequenceIter *iter; + struct connman_service *service = data; + struct preferred_tech_data *tech_data = user_data; - DBG(""); + if (service->type == tech_data->type) { + g_sequence_append(tech_data->preferred_list, service); - if (__connman_session_mode() == TRUE) { - DBG("Session mode enabled: auto connect disabled"); - return; + DBG("type %d service %p %s", tech_data->type, service, + service->name); } +} - iter = g_sequence_get_begin_iter(service_list); +static GSequence* preferred_tech_list_get(GSequence *list) +{ + unsigned int *tech_array; + struct preferred_tech_data tech_data; + int i; + + tech_array = connman_setting_get_uint_list("PreferredTechnologies"); + if (tech_array == NULL) + return NULL; + + tech_data.preferred_list = g_sequence_new(NULL); + + for (i = 0; tech_array[i] != 0; i += 1) { + tech_data.type = tech_array[i]; + g_sequence_foreach(service_list, preferred_tech_add_by_type, + &tech_data); + } + + return tech_data.preferred_list; +} + +static connman_bool_t auto_connect_service(GSequenceIter* iter, + connman_bool_t preferred) +{ + struct connman_service *service = NULL; while (g_sequence_iter_is_end(iter) == FALSE) { service = g_sequence_get(iter); if (service->pending != NULL) - return; + return TRUE; if (is_connecting(service) == TRUE) - return; + return TRUE; - if (service->favorite == FALSE) - return; + if (service->favorite == FALSE) { + if (preferred == TRUE) + goto next_service; + return FALSE; + } - if (is_connected(service) == TRUE) - return; + if (is_connected(service) == TRUE) { + if (preferred == TRUE && service->state != + CONNMAN_SERVICE_STATE_ONLINE) + goto next_service; + return TRUE; + } if (is_ignore(service) == FALSE && service->state == - CONNMAN_SERVICE_STATE_IDLE) + CONNMAN_SERVICE_STATE_IDLE) break; + next_service: service = NULL; iter = g_sequence_iter_next(iter); } if (service != NULL) { + + DBG("service %p %s %s", service, service->name, + (preferred == TRUE)? "preferred": "auto"); + service->userconnect = FALSE; __connman_service_connect(service); + return TRUE; } + return FALSE; +} + +static gboolean run_auto_connect(gpointer data) +{ + GSequenceIter *iter = NULL; + GSequence *preferred_tech; + + autoconnect_timeout = 0; + + DBG(""); + + preferred_tech = preferred_tech_list_get(service_list); + if (preferred_tech != NULL) + iter = g_sequence_get_begin_iter(preferred_tech); + + if (iter == NULL || auto_connect_service(iter, TRUE) == FALSE) + iter = g_sequence_get_begin_iter(service_list); + + if (iter != NULL) + auto_connect_service(iter, FALSE); + + if (preferred_tech != NULL) + g_sequence_free(preferred_tech); + + return FALSE; +} + +void __connman_service_auto_connect(void) +{ + DBG(""); + + if (__connman_session_mode() == TRUE) { + DBG("Session mode enabled: auto connect disabled"); + return; + } + + if (autoconnect_timeout != 0) + return; + + autoconnect_timeout = g_timeout_add_seconds(0, run_auto_connect, NULL); } static void remove_timeout(struct connman_service *service) @@ -3329,6 +3556,18 @@ static void apply_relevant_default_downgrade(struct connman_service *service) def_service->state = CONNMAN_SERVICE_STATE_READY; } +static void switch_default_service(struct connman_service *default_service, + struct connman_service *downgrade_service) +{ + GSequenceIter *src, *dst; + + apply_relevant_default_downgrade(default_service); + src = g_hash_table_lookup(service_hash, downgrade_service->identifier); + dst = g_hash_table_lookup(service_hash, default_service->identifier); + g_sequence_move(src, dst); + downgrade_state(downgrade_service); +} + static DBusMessage *move_service(DBusConnection *conn, DBusMessage *msg, void *user_data, gboolean before) @@ -3336,7 +3575,6 @@ static DBusMessage *move_service(DBusConnection *conn, struct connman_service *service = user_data; struct connman_service *target; const char *path; - GSequenceIter *src, *dst; enum connman_ipconfig_method target4, target6; enum connman_ipconfig_method service4, service6; @@ -3424,24 +3662,16 @@ static DBusMessage *move_service(DBusConnection *conn, service_save(service); service_save(target); - src = g_hash_table_lookup(service_hash, service->identifier); - dst = g_hash_table_lookup(service_hash, target->identifier); - /* * If the service which goes down is the default service and is * online, we downgrade directly its state to ready so: * the service which goes up, needs to recompute its state which * is triggered via downgrading it - if relevant - to state ready. */ - if (before == TRUE) { - apply_relevant_default_downgrade(target); - g_sequence_move(src, dst); - downgrade_state(service); - } else { - apply_relevant_default_downgrade(service); - g_sequence_move(dst, src); - downgrade_state(target); - } + if (before == TRUE) + switch_default_service(target, service); + else + switch_default_service(service, target); __connman_connection_update_gateway(); @@ -3476,40 +3706,7 @@ static struct _services_notify { GHashTable *remove; } *services_notify; -static void append_removed(gpointer key, gpointer value, gpointer user_data) -{ - char *objpath = key; - DBusMessageIter *iter = user_data; - - DBG("removed %s", objpath); - dbus_message_iter_append_basic(iter, DBUS_TYPE_OBJECT_PATH, &objpath); -} - -static void service_send_removed(void) -{ - DBusMessage *signal; - DBusMessageIter iter, array; - - signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "ServicesRemoved"); - if (signal == NULL) - return; - - dbus_message_iter_init_append(signal, &iter); - dbus_message_iter_open_container(&iter, DBUS_TYPE_ARRAY, - DBUS_TYPE_OBJECT_PATH_AS_STRING, &array); - - g_hash_table_foreach(services_notify->remove, append_removed, &array); - - dbus_message_iter_close_container(&iter, &array); - - dbus_connection_send(connection, signal, NULL); - dbus_message_unref(signal); - - g_hash_table_remove_all(services_notify->remove); -} - -static void service_send_added_foreach(gpointer data, gpointer user_data) +static void service_append_added_foreach(gpointer data, gpointer user_data) { struct connman_service *service = data; DBusMessageIter *iter = user_data; @@ -3519,57 +3716,73 @@ static void service_send_added_foreach(gpointer data, gpointer user_data) return; } - DBG("added %s", service->path); - if (g_hash_table_lookup(services_notify->add, service->path) != NULL) { + DBG("new %s", service->path); + append_struct(service, iter); g_hash_table_remove(services_notify->add, service->path); } else { + DBG("changed %s", service->path); + append_struct_service(iter, NULL, service); } } -static void service_send_added_ordered(DBusMessageIter *iter, void *user_data) +static void service_append_ordered(DBusMessageIter *iter, void *user_data) +{ + if (service_list != NULL) + g_sequence_foreach(service_list, + service_append_added_foreach, iter); +} + +static void append_removed(gpointer key, gpointer value, gpointer user_data) { - g_sequence_foreach(service_list, service_send_added_foreach, iter); + char *objpath = key; + DBusMessageIter *iter = user_data; + + DBG("removed %s", objpath); + dbus_message_iter_append_basic(iter, DBUS_TYPE_OBJECT_PATH, &objpath); } -static void service_send_added(void) +static gboolean service_send_changed(gpointer data) { DBusMessage *signal; + DBusMessageIter iter, array; + + DBG(""); signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH, - CONNMAN_MANAGER_INTERFACE, "ServicesAdded"); + CONNMAN_MANAGER_INTERFACE, "ServicesChanged"); if (signal == NULL) - return; + return FALSE; __connman_dbus_append_objpath_dict_array(signal, - service_send_added_ordered, NULL); + service_append_ordered, NULL); + + dbus_message_iter_init_append(signal, &iter); + dbus_message_iter_open_container(&iter, DBUS_TYPE_ARRAY, + DBUS_TYPE_OBJECT_PATH_AS_STRING, &array); + + g_hash_table_foreach(services_notify->remove, append_removed, &array); + + dbus_message_iter_close_container(&iter, &array); dbus_connection_send(connection, signal, NULL); dbus_message_unref(signal); + g_hash_table_remove_all(services_notify->remove); g_hash_table_remove_all(services_notify->add); -} - -static gboolean service_send_signals(gpointer data) -{ - if (g_hash_table_size(services_notify->remove) > 0) - service_send_removed(); - - if (g_hash_table_size(services_notify->add) > 0) - service_send_added(); services_notify->id = 0; return FALSE; } -static void service_schedule_signals(void) +static void service_schedule_changed(void) { if (services_notify->id != 0) - g_source_remove(services_notify->id); + return; - services_notify->id = g_timeout_add(100, service_send_signals, NULL); + services_notify->id = g_timeout_add(100, service_send_changed, NULL); } static void service_schedule_added(struct connman_service *service) @@ -3577,9 +3790,9 @@ static void service_schedule_added(struct connman_service *service) DBG("service %p", service); g_hash_table_remove(services_notify->remove, service->path); - g_hash_table_insert(services_notify->add, service->path, service); + g_hash_table_replace(services_notify->add, service->path, service); - service_schedule_signals(); + service_schedule_changed(); } static void service_schedule_removed(struct connman_service *service) @@ -3592,28 +3805,40 @@ static void service_schedule_removed(struct connman_service *service) } g_hash_table_remove(services_notify->add, service->path); - g_hash_table_insert(services_notify->remove, g_strdup(service->path), + g_hash_table_replace(services_notify->remove, g_strdup(service->path), NULL); - service_schedule_signals(); -} - -static GDBusMethodTable service_methods[] = { - { "GetProperties", "", "a{sv}", get_properties }, - { "SetProperty", "sv", "", set_property }, - { "ClearProperty", "s", "", clear_property }, - { "Connect", "", "", connect_service, - G_DBUS_METHOD_FLAG_ASYNC }, - { "Disconnect", "", "", disconnect_service }, - { "Remove", "", "", remove_service }, - { "MoveBefore", "o", "", move_before }, - { "MoveAfter", "o", "", move_after }, - { "ResetCounters", "", "", reset_counters }, + service_schedule_changed(); +} + +static const GDBusMethodTable service_methods[] = { + { GDBUS_DEPRECATED_METHOD("GetProperties", + NULL, GDBUS_ARGS({ "properties", "a{sv}" }), + get_properties) }, + { GDBUS_METHOD("SetProperty", + GDBUS_ARGS({ "name", "s" }, { "value", "v" }), + NULL, set_property) }, + { GDBUS_METHOD("ClearProperty", + GDBUS_ARGS({ "name", "s" }), NULL, + clear_property) }, + { GDBUS_ASYNC_METHOD("Connect", NULL, NULL, + connect_service) }, + { GDBUS_METHOD("Disconnect", NULL, NULL, + disconnect_service) }, + { GDBUS_METHOD("Remove", NULL, NULL, remove_service) }, + { GDBUS_METHOD("MoveBefore", + GDBUS_ARGS({ "service", "o" }), NULL, + move_before) }, + { GDBUS_METHOD("MoveAfter", + GDBUS_ARGS({ "service", "o" }), NULL, + move_after) }, + { GDBUS_METHOD("ResetCounters", NULL, NULL, reset_counters) }, { }, }; -static GDBusSignalTable service_signals[] = { - { "PropertyChanged", "sv" }, +static const GDBusSignalTable service_signals[] = { + { GDBUS_SIGNAL("PropertyChanged", + GDBUS_ARGS({ "name", "s" }, { "value", "v" })) }, { }, }; @@ -4064,7 +4289,10 @@ int __connman_service_set_favorite(struct connman_service *service, favorite_changed(service); - g_sequence_sort_changed(iter, service_compare, NULL); + if (g_sequence_get_length(service_list) > 1) { + g_sequence_sort_changed(iter, service_compare, NULL); + service_schedule_changed(); + } __connman_connection_update_gateway(); @@ -4115,6 +4343,13 @@ void __connman_service_set_string(struct connman_service *service, } } +void __connman_service_set_userconnect(struct connman_service *service, + connman_bool_t userconnect) +{ + if (service != NULL) + service->userconnect = userconnect; +} + static void service_complete(struct connman_service *service) { reply_pending(service, EIO); @@ -4132,19 +4367,24 @@ static void report_error_cb(struct connman_service *service, if (retry == TRUE) __connman_service_connect(service); else { + /* It is not relevant to stay on Failure state + * when failing is due to wrong user input */ + service->state = CONNMAN_SERVICE_STATE_IDLE; + service_complete(service); __connman_connection_update_gateway(); - __connman_device_request_scan(CONNMAN_DEVICE_TYPE_UNKNOWN); } } -void __connman_service_add_passphrase(struct connman_service *service, +int __connman_service_add_passphrase(struct connman_service *service, const gchar *passphrase) { + int err = 0; + switch (service->security) { case CONNMAN_SERVICE_SECURITY_WEP: case CONNMAN_SERVICE_SECURITY_PSK: - __connman_service_set_passphrase(service, passphrase); + err = __connman_service_set_passphrase(service, passphrase); break; case CONNMAN_SERVICE_SECURITY_8021X: __connman_service_set_agent_passphrase(service, @@ -4160,18 +4400,63 @@ void __connman_service_add_passphrase(struct connman_service *service, break; } + return err; +} + +static int check_wpspin(struct connman_service *service, const char *wpspin) +{ + int length; + guint i; + + if (wpspin == NULL) + return 0; + + length = strlen(wpspin); + + /* If 0, it will mean user wants to use PBC method */ + if (length == 0) { + connman_network_set_string(service->network, + "WiFi.PinWPS", NULL); + return 0; + } + + /* A WPS PIN is always 8 chars length, + * its content is in digit representation. + */ + if (length != 8) + return -ENOKEY; + + for (i = 0; i < 8; i++) + if (!isdigit((unsigned char) wpspin[i])) + return -ENOKEY; + + connman_network_set_string(service->network, "WiFi.PinWPS", wpspin); + + return 0; } static void request_input_cb (struct connman_service *service, connman_bool_t values_received, const char *name, int name_len, const char *identity, const char *passphrase, - void *user_data) + gboolean wps, const char *wpspin, + const char *error, void *user_data) { struct connman_device *device; + int err = 0; DBG ("RequestInput return, %p", service); + if (error != NULL) { + DBG("error: %s", error); + + if (g_strcmp0(error, + "net.connman.Agent.Error.Canceled") == 0) { + err = -EINVAL; + goto done; + } + } + if (service->hidden == TRUE && name_len > 0 && name_len <= 32) { device = connman_network_get_device(service->network); __connman_device_request_hidden_scan(device, @@ -4180,23 +4465,45 @@ static void request_input_cb (struct connman_service *service, } if (values_received == FALSE || service->hidden == TRUE) { - service_complete(service); - __connman_connection_update_gateway(); - __connman_device_request_scan(CONNMAN_DEVICE_TYPE_UNKNOWN); - return; + err = -EINVAL; + goto done; + } + + if (wps == TRUE && service->network != NULL) { + err = check_wpspin(service, wpspin); + if (err < 0) + goto done; + + connman_network_set_bool(service->network, "WiFi.UseWPS", wps); } if (identity != NULL) __connman_service_set_agent_identity(service, identity); if (passphrase != NULL) - __connman_service_add_passphrase(service, passphrase); + err = __connman_service_add_passphrase(service, passphrase); - __connman_service_connect(service); + done: + if (err >= 0) { + __connman_service_connect(service); + + /* Never cache agent provided credentials */ + __connman_service_set_agent_identity(service, NULL); + __connman_service_set_agent_passphrase(service, NULL); + } else if (err == -ENOKEY) { + __connman_service_indicate_error(service, + CONNMAN_SERVICE_ERROR_INVALID_KEY); + __connman_agent_report_error(service, + error2string(service->error), + report_error_cb, NULL); + } else { + /* It is not relevant to stay on Failure state + * when failing is due to wrong user input */ + service->state = CONNMAN_SERVICE_STATE_IDLE; - /* Never cache agent provided credentials */ - __connman_service_set_agent_identity(service, NULL); - __connman_service_set_agent_passphrase(service, NULL); + service_complete(service); + __connman_connection_update_gateway(); + } } static void downgrade_connected_services(void) @@ -4222,10 +4529,41 @@ static void downgrade_connected_services(void) } } +static int service_update_preferred_order(struct connman_service *default_service, + struct connman_service *new_service, + enum connman_service_state new_state) +{ + unsigned int *tech_array; + int i; + + if (default_service == NULL || default_service == new_service || + default_service->state != new_state ) + return 0; + + tech_array = connman_setting_get_uint_list("PreferredTechnologies"); + if (tech_array != NULL) { + + for (i = 0; tech_array[i] != 0; i += 1) { + if (default_service->type == tech_array[i]) + return -EALREADY; + + if (new_service->type == tech_array[i]) { + switch_default_service(new_service, + default_service); + return 0; + } + } + return -EAGAIN; + } + + return -EALREADY; +} + static int service_indicate_state(struct connman_service *service) { enum connman_service_state old_state, new_state; struct connman_service *def_service; + int result; GSequenceIter *iter; if (service == NULL) @@ -4247,11 +4585,17 @@ static int service_indicate_state(struct connman_service *service) def_service = __connman_service_get_default(); if (new_state == CONNMAN_SERVICE_STATE_ONLINE) { - if (def_service != NULL && def_service != service && - def_service->state == CONNMAN_SERVICE_STATE_ONLINE) - return -EALREADY; + result = service_update_preferred_order(def_service, + service, new_state); + if (result == -EALREADY) + return result; + if (result == -EAGAIN) + __connman_service_auto_connect(); } + if (old_state == CONNMAN_SERVICE_STATE_ONLINE) + __connman_notifier_leave_online(service->type); + service->state = new_state; state_changed(service); @@ -4263,7 +4607,12 @@ static int service_indicate_state(struct connman_service *service) } if (new_state == CONNMAN_SERVICE_STATE_CONFIGURATION) { - if (__connman_stats_service_register(service) == 0) { + if (service->new_service == FALSE && + __connman_stats_service_register(service) == 0) { + /* + * For new services the statistics are updated after + * we have successfully connected. + */ __connman_stats_get(service, FALSE, &service->stats.data); __connman_stats_get(service, TRUE, @@ -4277,13 +4626,28 @@ static int service_indicate_state(struct connman_service *service) reconnect = get_reconnect_state(service); if (reconnect == TRUE) __connman_service_auto_connect(); - - __connman_device_request_scan(CONNMAN_DEVICE_TYPE_UNKNOWN); } if (new_state == CONNMAN_SERVICE_STATE_READY) { enum connman_ipconfig_method method; + if (service->new_service == TRUE && + __connman_stats_service_register(service) == 0) { + /* + * This is normally done after configuring state + * but for new service do this after we have connected + * successfully. + */ + __connman_stats_get(service, FALSE, + &service->stats.data); + __connman_stats_get(service, TRUE, + &service->stats_roaming.data); + } + + service->new_service = FALSE; + + service_update_preferred_order(def_service, service, new_state); + set_reconnect_state(service, TRUE); __connman_service_set_favorite(service, TRUE); @@ -4325,7 +4689,7 @@ static int service_indicate_state(struct connman_service *service) } else if (new_state == CONNMAN_SERVICE_STATE_DISCONNECT) { def_service = __connman_service_get_default(); - if (__connman_notifier_count_connected() == 0 && + if (__connman_notifier_is_connected() == FALSE && def_service != NULL && def_service->provider != NULL) __connman_provider_disconnect(def_service->provider); @@ -4357,19 +4721,21 @@ static int service_indicate_state(struct connman_service *service) report_error_cb, NULL) == -EIO) return 0; service_complete(service); - - __connman_device_request_scan(CONNMAN_DEVICE_TYPE_UNKNOWN); } else service->error = CONNMAN_SERVICE_ERROR_UNKNOWN; iter = g_hash_table_lookup(service_hash, service->identifier); - if (iter != NULL) + if (iter != NULL && g_sequence_get_length(service_list) > 1) { g_sequence_sort_changed(iter, service_compare, NULL); + service_schedule_changed(); + } __connman_connection_update_gateway(); - if (new_state == CONNMAN_SERVICE_STATE_ONLINE) + if (new_state == CONNMAN_SERVICE_STATE_ONLINE) { + __connman_notifier_enter_online(service->type); default_changed(); + } return 0; } @@ -4432,12 +4798,7 @@ int __connman_service_clear_error(struct connman_service *service) int __connman_service_indicate_default(struct connman_service *service) { - struct connman_service *current = __connman_service_get_default(); - - DBG("service %p default %p", service, current); - - if (current == service) - return 0; + DBG("service %p", service); default_changed(); @@ -4558,12 +4919,13 @@ int __connman_service_online_check_failed(struct connman_service *service, DBG("service %p type %d count %d", service, type, service->online_check_count); - if (type == CONNMAN_IPCONFIG_TYPE_IPV4) - /* currently we only retry IPv6 stuff */ - return 0; - - if (service->online_check_count != 1) + /* currently we only retry IPv6 stuff */ + if (type == CONNMAN_IPCONFIG_TYPE_IPV4 || + service->online_check_count != 1) { + connman_warn("Online check failed for %p %s", service, + service->name); return 0; + } service->online_check_count = 0; @@ -4890,13 +5252,6 @@ int __connman_service_connect(struct connman_service *service) return -EINPROGRESS; } - __connman_service_ipconfig_indicate_state(service, - CONNMAN_SERVICE_STATE_FAILURE, - CONNMAN_IPCONFIG_TYPE_IPV4); - __connman_service_ipconfig_indicate_state(service, - CONNMAN_SERVICE_STATE_FAILURE, - CONNMAN_IPCONFIG_TYPE_IPV6); - if (service->network != NULL) __connman_network_disconnect(service->network); else if (service->type == CONNMAN_SERVICE_TYPE_VPN && @@ -5075,8 +5430,10 @@ static int service_register(struct connman_service *service) NULL, service, NULL); iter = g_hash_table_lookup(service_hash, service->identifier); - if (iter != NULL) + if (iter != NULL && g_sequence_get_length(service_list) > 1) { g_sequence_sort_changed(iter, service_compare, NULL); + service_schedule_changed(); + } __connman_connection_update_gateway(); @@ -5374,7 +5731,7 @@ void __connman_service_update_ordering(void) GSequenceIter *iter; iter = g_sequence_get_begin_iter(service_list); - if (iter != NULL) + if (iter != NULL && g_sequence_get_length(service_list) > 1) g_sequence_sort_changed(iter, service_compare, NULL); } @@ -5476,8 +5833,10 @@ static void update_from_network(struct connman_service *service, service->network = connman_network_ref(network); iter = g_hash_table_lookup(service_hash, service->identifier); - if (iter != NULL) + if (iter != NULL && g_sequence_get_length(service_list) > 1) { g_sequence_sort_changed(iter, service_compare, NULL); + service_schedule_changed(); + } } /** @@ -5492,7 +5851,8 @@ struct connman_service * __connman_service_create_from_network(struct connman_ne struct connman_device *device; const char *ident, *group; char *name; - int index; + unsigned int *auto_connect_types; + int i, index; DBG("network %p", network); @@ -5526,6 +5886,16 @@ struct connman_service * __connman_service_create_from_network(struct connman_ne service->type = convert_network_type(network); + auto_connect_types = connman_setting_get_uint_list("DefaultAutoConnectTechnologies"); + service->autoconnect = FALSE; + for (i = 0; auto_connect_types != NULL && + auto_connect_types[i] != 0; i++) { + if (service->type == auto_connect_types[i]) { + service->autoconnect = TRUE; + break; + } + } + switch (service->type) { case CONNMAN_SERVICE_TYPE_UNKNOWN: case CONNMAN_SERVICE_TYPE_SYSTEM: @@ -5534,13 +5904,11 @@ struct connman_service * __connman_service_create_from_network(struct connman_ne case CONNMAN_SERVICE_TYPE_GPS: case CONNMAN_SERVICE_TYPE_VPN: case CONNMAN_SERVICE_TYPE_GADGET: - service->autoconnect = FALSE; + case CONNMAN_SERVICE_TYPE_WIFI: + case CONNMAN_SERVICE_TYPE_CELLULAR: break; case CONNMAN_SERVICE_TYPE_ETHERNET: service->favorite = TRUE; - case CONNMAN_SERVICE_TYPE_WIFI: - case CONNMAN_SERVICE_TYPE_CELLULAR: - service->autoconnect = TRUE; break; } @@ -5561,7 +5929,7 @@ struct connman_service * __connman_service_create_from_network(struct connman_ne if (service->favorite == TRUE) { device = connman_network_get_device(service->network); - if (device && __connman_device_scanning(device) == FALSE) + if (device && connman_device_get_scanning(device) == FALSE) __connman_service_auto_connect(); } @@ -5631,8 +5999,10 @@ roaming: sorting: if (need_sort == TRUE) { iter = g_hash_table_lookup(service_hash, service->identifier); - if (iter != NULL) + if (iter != NULL && g_sequence_get_length(service_list) > 1) { g_sequence_sort_changed(iter, service_compare, NULL); + service_schedule_changed(); + } } } @@ -5646,6 +6016,8 @@ void __connman_service_remove_from_network(struct connman_network *network) if (service == NULL) return; + service->ignore = TRUE; + __connman_connection_gateway_remove(service, CONNMAN_IPCONFIG_TYPE_ALL); @@ -5739,6 +6111,11 @@ void __connman_service_cleanup(void) DBG(""); + if (autoconnect_timeout != 0) { + g_source_remove(autoconnect_timeout); + autoconnect_timeout = 0; + } + list = service_list; service_list = NULL; g_sequence_free(list); @@ -5751,7 +6128,7 @@ void __connman_service_cleanup(void) if (services_notify->id != 0) { g_source_remove(services_notify->id); - service_send_signals(NULL); + service_send_changed(NULL); g_hash_table_destroy(services_notify->remove); g_hash_table_destroy(services_notify->add); }