Send signal when service strength changes
[connman] / src / service.c
index c3d4e20..a799477 100644 (file)
@@ -42,6 +42,8 @@ struct connman_service {
        enum connman_service_state state;
        connman_uint8_t strength;
        connman_bool_t favorite;
+       connman_bool_t hidden;
+       GTimeVal modified;
        unsigned int order;
        char *name;
        char *passphrase;
@@ -71,6 +73,34 @@ void __connman_service_list(DBusMessageIter *iter)
        g_sequence_foreach(service_list, append_path, iter);
 }
 
+struct find_data {
+       const char *path;
+       struct connman_service *service;
+};
+
+static void compare_path(gpointer value, gpointer user_data)
+{
+       struct connman_service *service = value;
+       struct find_data *data = user_data;
+
+       if (data->service != NULL)
+               return;
+
+       if (g_strcmp0(service->path, data->path) == 0)
+               data->service = service;
+}
+
+static struct connman_service *find_service(const char *path)
+{
+       struct find_data data = { .path = path, .service = NULL };
+
+       DBG("path %s", path);
+
+       g_sequence_foreach(service_list, compare_path, &data);
+
+       return data.service;
+}
+
 static const char *type2string(enum connman_service_type type)
 {
        switch (type) {
@@ -112,8 +142,8 @@ static const char *security2string(enum connman_service_security security)
                return "wep";
        case CONNMAN_SERVICE_SECURITY_WPA:
                return "wpa";
-       case CONNMAN_SERVICE_SECURITY_WPA2:
-               return "wpa2";
+       case CONNMAN_SERVICE_SECURITY_RSN:
+               return "rsn";
        }
 
        return NULL;
@@ -173,15 +203,45 @@ static void state_changed(struct connman_service *service)
        g_dbus_send_message(connection, signal);
 }
 
+static void strength_changed(struct connman_service *service)
+{
+       DBusMessage *signal;
+       DBusMessageIter entry, value;
+       const char *key = "Strength";
+
+       if (service->path == NULL)
+               return;
+
+       if (service->strength == 0)
+               return;
+
+       signal = dbus_message_new_signal(service->path,
+                               CONNMAN_SERVICE_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_STRING_AS_STRING, &value);
+       dbus_message_iter_append_basic(&value, DBUS_TYPE_BYTE,
+                                                       &service->strength);
+       dbus_message_iter_close_container(&entry, &value);
+
+       g_dbus_send_message(connection, signal);
+}
+
 static DBusMessage *get_properties(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
        DBusMessage *reply;
        DBusMessageIter array, dict;
        const char *str;
 
-       DBG("conn %p", conn);
+       DBG("service %p", service);
 
        reply = dbus_message_new_method_return(msg);
        if (reply == NULL)
@@ -237,14 +297,14 @@ static DBusMessage *get_properties(DBusConnection *conn,
 }
 
 static DBusMessage *set_property(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
        DBusMessageIter iter, value;
        const char *name;
        int type;
 
-       DBG("conn %p", conn);
+       DBG("service %p", service);
 
        if (dbus_message_iter_init(msg, &iter) == FALSE)
                return __connman_error_invalid_arguments(msg);
@@ -292,6 +352,9 @@ static gboolean connect_timeout(gpointer user_data)
 
        service->timeout = 0;
 
+       if (service->network != NULL)
+               __connman_network_disconnect(service->network);
+
        if (service->pending != NULL) {
                DBusMessage *reply;
 
@@ -301,15 +364,20 @@ static gboolean connect_timeout(gpointer user_data)
 
                dbus_message_unref(service->pending);
                service->pending = NULL;
+
+               __connman_service_indicate_state(service,
+                                       CONNMAN_SERVICE_STATE_FAILURE);
        }
 
        return FALSE;
 }
 
 static DBusMessage *connect_service(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
+
+       DBG("service %p", service);
 
        if (service->pending != NULL)
                return __connman_error_in_progress(msg);
@@ -320,10 +388,13 @@ static DBusMessage *connect_service(DBusConnection *conn,
        if (service->network != NULL) {
                int err;
 
+               if (service->hidden == TRUE)
+                       return __connman_error_invalid_service(msg);
+
                connman_network_set_string(service->network,
                                "WiFi.Passphrase", service->passphrase);
 
-               err = connman_network_connect(service->network);
+               err = __connman_network_connect(service->network);
                if (err < 0 && err != -EINPROGRESS)
                        return __connman_error_failed(msg, -err);
 
@@ -351,9 +422,11 @@ static DBusMessage *connect_service(DBusConnection *conn,
 }
 
 static DBusMessage *disconnect_service(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
+
+       DBG("service %p", service);
 
        if (service->pending != NULL) {
                DBusMessage *reply;
@@ -393,20 +466,20 @@ static DBusMessage *disconnect_service(DBusConnection *conn,
 }
 
 static DBusMessage *remove_service(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
+
+       DBG("service %p", service);
 
        if (service->type == CONNMAN_SERVICE_TYPE_ETHERNET)
                return __connman_error_not_supported(msg);
 
-       if (service->network != NULL) {
-               int err;
+       if (service->favorite == FALSE)
+               return __connman_error_not_supported(msg);
 
-               err = __connman_network_disconnect(service->network);
-               if (err < 0 && err != -EINPROGRESS)
-                       return __connman_error_failed(msg, -err);
-       }
+       if (service->network != NULL)
+               __connman_network_disconnect(service->network);
 
        connman_service_set_favorite(service, FALSE);
        __connman_storage_save_service(service);
@@ -415,24 +488,67 @@ static DBusMessage *remove_service(DBusConnection *conn,
 }
 
 static DBusMessage *move_before(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
+       struct connman_service *target;
+       const char *path;
+       GSequenceIter *src, *dst;
+
+       DBG("service %p", service);
+
+       dbus_message_get_args(msg, NULL, DBUS_TYPE_OBJECT_PATH, &path,
+                                                       DBUS_TYPE_INVALID);
 
        if (service->favorite == FALSE)
                return __connman_error_not_supported(msg);
 
+       target = find_service(path);
+       if (target == NULL || target->favorite == FALSE || target == service)
+               return __connman_error_invalid_service(msg);
+
+       DBG("target %s", target->identifier);
+
+       g_get_current_time(&service->modified);
+       __connman_storage_save_service(service);
+
+       src = g_hash_table_lookup(service_hash, service->identifier);
+       dst = g_hash_table_lookup(service_hash, target->identifier);
+
+#if 0
+       g_sequence_move(src, dst);
+
+       __connman_profile_changed();
+
+       return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
+#endif
        return __connman_error_not_implemented(msg);
 }
 
 static DBusMessage *move_after(DBusConnection *conn,
-                                       DBusMessage *msg, void *data)
+                                       DBusMessage *msg, void *user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
+       struct connman_service *target;
+       const char *path;
+
+       DBG("service %p", service);
+
+       dbus_message_get_args(msg, NULL, DBUS_TYPE_OBJECT_PATH, &path,
+                                                       DBUS_TYPE_INVALID);
 
        if (service->favorite == FALSE)
                return __connman_error_not_supported(msg);
 
+       target = find_service(path);
+       if (target == NULL || target->favorite == FALSE || target == service)
+               return __connman_error_invalid_service(msg);
+
+       DBG("target %s", target->identifier);
+
+       g_get_current_time(&service->modified);
+       __connman_storage_save_service(service);
+
        return __connman_error_not_implemented(msg);
 }
 
@@ -453,9 +569,9 @@ static GDBusSignalTable service_signals[] = {
        { },
 };
 
-static void service_free(gpointer data)
+static void service_free(gpointer user_data)
 {
-       struct connman_service *service = data;
+       struct connman_service *service = user_data;
        char *path = service->path;
 
        DBG("service %p", service);
@@ -491,12 +607,12 @@ static void service_free(gpointer data)
 }
 
 /**
- * connman_service_put:
+ * __connman_service_put:
  * @service: service structure
  *
  * Release service if no longer needed
  */
-void connman_service_put(struct connman_service *service)
+void __connman_service_put(struct connman_service *service)
 {
        DBG("service %p", service);
 
@@ -523,6 +639,7 @@ static void __connman_service_initialize(struct connman_service *service)
        service->state    = CONNMAN_SERVICE_STATE_UNKNOWN;
 
        service->favorite = FALSE;
+       service->hidden = FALSE;
 
        service->order = 0;
 }
@@ -570,7 +687,7 @@ struct connman_service *connman_service_ref(struct connman_service *service)
  */
 void connman_service_unref(struct connman_service *service)
 {
-       connman_service_put(service);
+       __connman_service_put(service);
 }
 
 static gint service_compare(gconstpointer a, gconstpointer b,
@@ -579,6 +696,13 @@ static gint service_compare(gconstpointer a, gconstpointer b,
        struct connman_service *service_a = (void *) a;
        struct connman_service *service_b = (void *) b;
 
+       if (service_a->state != service_b->state) {
+               if (service_a->state == CONNMAN_SERVICE_STATE_READY)
+                       return -1;
+               if (service_b->state == CONNMAN_SERVICE_STATE_READY)
+                       return 1;
+       }
+
        if (service_a->order > service_b->order)
                return -1;
 
@@ -610,7 +734,7 @@ int connman_service_set_favorite(struct connman_service *service,
        if (iter == NULL)
                return -ENOENT;
 
-       if (service->favorite)
+       if (service->favorite == favorite)
                return -EALREADY;
 
        service->favorite = favorite;
@@ -656,6 +780,8 @@ int __connman_service_set_carrier(struct connman_service *service,
 int __connman_service_indicate_state(struct connman_service *service,
                                        enum connman_service_state state)
 {
+       GSequenceIter *iter;
+
        DBG("service %p state %d", service, state);
 
        if (service == NULL)
@@ -695,6 +821,8 @@ int __connman_service_indicate_state(struct connman_service *service,
                        service->pending = NULL;
                }
 
+               g_get_current_time(&service->modified);
+               __connman_storage_save_service(service);
        }
 
        if (state == CONNMAN_SERVICE_STATE_FAILURE) {
@@ -711,18 +839,34 @@ int __connman_service_indicate_state(struct connman_service *service,
                        dbus_message_unref(service->pending);
                        service->pending = NULL;
                }
+
+               service->state = CONNMAN_SERVICE_STATE_IDLE;
+               state_changed(service);
        }
 
+       iter = g_hash_table_lookup(service_hash, service->identifier);
+       if (iter != NULL)
+               g_sequence_sort_changed(iter, service_compare, NULL);
+
+       __connman_profile_changed();
+
+       return 0;
+}
+
+int __connman_service_indicate_default(struct connman_service *service)
+{
+       DBG("service %p", service);
+
        return 0;
 }
 
 /**
- * connman_service_lookup:
+ * __connman_service_lookup:
  * @identifier: service identifier
  *
  * Look up a service by identifier (reference count will not be increased)
  */
-struct connman_service *connman_service_lookup(const char *identifier)
+static struct connman_service *__connman_service_lookup(const char *identifier)
 {
        GSequenceIter *iter;
 
@@ -734,12 +878,12 @@ struct connman_service *connman_service_lookup(const char *identifier)
 }
 
 /**
- * connman_service_get:
+ * __connman_service_get:
  * @identifier: service identifier
  *
  * Look up a service by identifier or create a new one if not found
  */
-struct connman_service *connman_service_get(const char *identifier)
+static struct connman_service *__connman_service_get(const char *identifier)
 {
        struct connman_service *service;
        GSequenceIter *iter;
@@ -777,6 +921,7 @@ struct connman_service *connman_service_get(const char *identifier)
 static int service_register(struct connman_service *service)
 {
        const char *path = __connman_profile_active_path();
+       GSequenceIter *iter;
 
        DBG("service %p", service);
 
@@ -792,6 +937,12 @@ static int service_register(struct connman_service *service)
                                        service_methods, service_signals,
                                                        NULL, service, NULL);
 
+       __connman_storage_load_service(service);
+
+       iter = g_hash_table_lookup(service_hash, service->identifier);
+       if (iter != NULL)
+               g_sequence_sort_changed(iter, service_compare, NULL);
+
        __connman_profile_changed();
 
        return 0;
@@ -816,7 +967,7 @@ struct connman_service *__connman_service_lookup_from_device(struct connman_devi
        name = g_strdup_printf("%s_%s",
                                __connman_device_get_type(device), ident);
 
-       service = connman_service_lookup(name);
+       service = __connman_service_lookup(name);
 
        g_free(name);
 
@@ -865,12 +1016,12 @@ struct connman_service *__connman_service_create_from_device(struct connman_devi
        name = g_strdup_printf("%s_%s",
                                __connman_device_get_type(device), ident);
 
-       service = connman_service_get(name);
+       service = __connman_service_get(name);
        if (service == NULL)
                goto done;
 
        if (service->path != NULL) {
-               connman_service_put(service);
+               __connman_service_put(service);
                service = NULL;
                goto done;
        }
@@ -910,7 +1061,7 @@ struct connman_service *__connman_service_lookup_from_network(struct connman_net
        name = g_strdup_printf("%s_%s_%s",
                        __connman_network_get_type(network), ident, group);
 
-       service = connman_service_lookup(name);
+       service = __connman_service_lookup(name);
 
        g_free(name);
 
@@ -959,8 +1110,8 @@ static enum connman_service_mode convert_wifi_security(const char *security)
                return CONNMAN_SERVICE_SECURITY_WEP;
        else if (g_str_equal(security, "wpa") == TRUE)
                return CONNMAN_SERVICE_SECURITY_WPA;
-       else if (g_str_equal(security, "wpa2") == TRUE)
-               return CONNMAN_SERVICE_SECURITY_WPA2;
+       else if (g_str_equal(security, "rsn") == TRUE)
+               return CONNMAN_SERVICE_SECURITY_RSN;
        else
                return CONNMAN_SERVICE_SECURITY_UNKNOWN;
 }
@@ -976,6 +1127,11 @@ static void update_from_network(struct connman_service *service,
        if (str != NULL) {
                g_free(service->name);
                service->name = g_strdup(str);
+               service->hidden = FALSE;
+       } else {
+               g_free(service->name);
+               service->name = NULL;
+               service->hidden = TRUE;
        }
 
        service->strength = connman_network_get_uint8(network, "Strength");
@@ -989,6 +1145,8 @@ static void update_from_network(struct connman_service *service,
        if (service->strength > strength && service->network != NULL) {
                connman_network_unref(service->network);
                service->network = NULL;
+
+               strength_changed(service);
        }
 
        if (service->network == NULL) {
@@ -1029,7 +1187,7 @@ struct connman_service *__connman_service_create_from_network(struct connman_net
        name = g_strdup_printf("%s_%s_%s",
                        __connman_network_get_type(network), ident, group);
 
-       service = connman_service_get(name);
+       service = __connman_service_get(name);
        if (service == NULL)
                goto done;
 
@@ -1038,13 +1196,15 @@ struct connman_service *__connman_service_create_from_network(struct connman_net
 
                __connman_profile_changed();
 
-               connman_service_put(service);
+               __connman_service_put(service);
                service = NULL;
                goto done;
        }
 
        service->type = convert_network_type(network);
 
+       service->state = CONNMAN_SERVICE_STATE_IDLE;
+
        update_from_network(service, network);
 
        service_register(service);
@@ -1060,7 +1220,7 @@ static int service_load(struct connman_service *service)
        GKeyFile *keyfile;
        gchar *pathname, *data = NULL;
        gsize length;
-       char *str;
+       gchar *str;
 
        DBG("service %p", service);
 
@@ -1100,6 +1260,13 @@ static int service_load(struct connman_service *service)
        }
 
        str = g_key_file_get_string(keyfile,
+                               service->identifier, "Modified", NULL);
+       if (str != NULL) {
+               g_time_val_from_iso8601(str, &service->modified);
+               g_free(str);
+       }
+
+       str = g_key_file_get_string(keyfile,
                                service->identifier, "Passphrase", NULL);
        if (str != NULL) {
                g_free(service->passphrase);
@@ -1116,6 +1283,7 @@ static int service_save(struct connman_service *service)
        GKeyFile *keyfile;
        gchar *pathname, *data = NULL;
        gsize length;
+       gchar *str;
 
        DBG("service %p", service);
 
@@ -1140,6 +1308,10 @@ static int service_save(struct connman_service *service)
        g_free(data);
 
 update:
+       if (service->name != NULL)
+               g_key_file_set_string(keyfile, service->identifier,
+                                               "Name", service->name);
+
        switch (service->type) {
        case CONNMAN_SERVICE_TYPE_UNKNOWN:
        case CONNMAN_SERVICE_TYPE_ETHERNET:
@@ -1151,6 +1323,13 @@ update:
                break;
        }
 
+       str = g_time_val_to_iso8601(&service->modified);
+       if (str != NULL) {
+               g_key_file_set_string(keyfile, service->identifier,
+                                                       "Modified", str);
+               g_free(str);
+       }
+
        if (service->passphrase != NULL)
                g_key_file_set_string(keyfile, service->identifier,
                                        "Passphrase", service->passphrase);