In case of timeout make sure to cancel network operation
[connman] / src / service.c
1 /*
2  *
3  *  Connection Manager
4  *
5  *  Copyright (C) 2007-2009  Intel Corporation. All rights reserved.
6  *
7  *  This program is free software; you can redistribute it and/or modify
8  *  it under the terms of the GNU General Public License version 2 as
9  *  published by the Free Software Foundation.
10  *
11  *  This program is distributed in the hope that it will be useful,
12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  *  GNU General Public License for more details.
15  *
16  *  You should have received a copy of the GNU General Public License
17  *  along with this program; if not, write to the Free Software
18  *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
19  *
20  */
21
22 #ifdef HAVE_CONFIG_H
23 #include <config.h>
24 #endif
25
26 #include <gdbus.h>
27
28 #include "connman.h"
29
30 static DBusConnection *connection = NULL;
31
32 static GSequence *service_list = NULL;
33 static GHashTable *service_hash = NULL;
34
35 struct connman_service {
36         gint refcount;
37         char *identifier;
38         char *path;
39         enum connman_service_type type;
40         enum connman_service_mode mode;
41         enum connman_service_security security;
42         enum connman_service_state state;
43         connman_uint8_t strength;
44         connman_bool_t favorite;
45         unsigned int order;
46         char *name;
47         char *passphrase;
48         char *profile;
49         struct connman_device *device;
50         struct connman_network *network;
51         DBusMessage *pending;
52         guint timeout;
53 };
54
55 static void append_path(gpointer value, gpointer user_data)
56 {
57         struct connman_service *service = value;
58         DBusMessageIter *iter = user_data;
59
60         if (service->path == NULL)
61                 return;
62
63         dbus_message_iter_append_basic(iter, DBUS_TYPE_OBJECT_PATH,
64                                                         &service->path);
65 }
66
67 void __connman_service_list(DBusMessageIter *iter)
68 {
69         DBG("");
70
71         g_sequence_foreach(service_list, append_path, iter);
72 }
73
74 static const char *type2string(enum connman_service_type type)
75 {
76         switch (type) {
77         case CONNMAN_SERVICE_TYPE_UNKNOWN:
78                 break;
79         case CONNMAN_SERVICE_TYPE_ETHERNET:
80                 return "ethernet";
81         case CONNMAN_SERVICE_TYPE_WIFI:
82                 return "wifi";
83         case CONNMAN_SERVICE_TYPE_WIMAX:
84                 return "wimax";
85         }
86
87         return NULL;
88 }
89
90 static const char *mode2string(enum connman_service_mode mode)
91 {
92         switch (mode) {
93         case CONNMAN_SERVICE_MODE_UNKNOWN:
94                 break;
95         case CONNMAN_SERVICE_MODE_MANAGED:
96                 return "managed";
97         case CONNMAN_SERVICE_MODE_ADHOC:
98                 return "adhoc";
99         }
100
101         return NULL;
102 }
103
104 static const char *security2string(enum connman_service_security security)
105 {
106         switch (security) {
107         case CONNMAN_SERVICE_SECURITY_UNKNOWN:
108                 break;
109         case CONNMAN_SERVICE_SECURITY_NONE:
110                 return "none";
111         case CONNMAN_SERVICE_SECURITY_WEP:
112                 return "wep";
113         case CONNMAN_SERVICE_SECURITY_WPA:
114                 return "wpa";
115         case CONNMAN_SERVICE_SECURITY_WPA2:
116                 return "wpa2";
117         }
118
119         return NULL;
120 }
121
122 static const char *state2string(enum connman_service_state state)
123 {
124         switch (state) {
125         case CONNMAN_SERVICE_STATE_UNKNOWN:
126                 break;
127         case CONNMAN_SERVICE_STATE_IDLE:
128                 return "idle";
129         case CONNMAN_SERVICE_STATE_CARRIER:
130                 return "carrier";
131         case CONNMAN_SERVICE_STATE_ASSOCIATION:
132                 return "association";
133         case CONNMAN_SERVICE_STATE_CONFIGURATION:
134                 return "configuration";
135         case CONNMAN_SERVICE_STATE_READY:
136                 return "ready";
137         case CONNMAN_SERVICE_STATE_DISCONNECT:
138                 return "disconnect";
139         case CONNMAN_SERVICE_STATE_FAILURE:
140                 return "failure";
141         }
142
143         return NULL;
144 }
145
146 static void state_changed(struct connman_service *service)
147 {
148         DBusMessage *signal;
149         DBusMessageIter entry, value;
150         const char *str, *key = "State";
151
152         if (service->path == NULL)
153                 return;
154
155         str = state2string(service->state);
156         if (str == NULL)
157                 return;
158
159         signal = dbus_message_new_signal(service->path,
160                                 CONNMAN_SERVICE_INTERFACE, "PropertyChanged");
161         if (signal == NULL)
162                 return;
163
164         dbus_message_iter_init_append(signal, &entry);
165
166         dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &key);
167
168         dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT,
169                                         DBUS_TYPE_STRING_AS_STRING, &value);
170         dbus_message_iter_append_basic(&value, DBUS_TYPE_STRING, &str);
171         dbus_message_iter_close_container(&entry, &value);
172
173         g_dbus_send_message(connection, signal);
174 }
175
176 static DBusMessage *get_properties(DBusConnection *conn,
177                                         DBusMessage *msg, void *user_data)
178 {
179         struct connman_service *service = user_data;
180         DBusMessage *reply;
181         DBusMessageIter array, dict;
182         const char *str;
183
184         DBG("service %p", service);
185
186         reply = dbus_message_new_method_return(msg);
187         if (reply == NULL)
188                 return NULL;
189
190         dbus_message_iter_init_append(reply, &array);
191
192         dbus_message_iter_open_container(&array, DBUS_TYPE_ARRAY,
193                         DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
194                         DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
195                         DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
196
197         str = type2string(service->type);
198         if (str != NULL)
199                 connman_dbus_dict_append_variant(&dict, "Type",
200                                                 DBUS_TYPE_STRING, &str);
201
202         str = mode2string(service->mode);
203         if (str != NULL)
204                 connman_dbus_dict_append_variant(&dict, "Mode",
205                                                 DBUS_TYPE_STRING, &str);
206
207         str = security2string(service->security);
208         if (str != NULL)
209                 connman_dbus_dict_append_variant(&dict, "Security",
210                                                 DBUS_TYPE_STRING, &str);
211
212         str = state2string(service->state);
213         if (str != NULL)
214                 connman_dbus_dict_append_variant(&dict, "State",
215                                                 DBUS_TYPE_STRING, &str);
216
217         if (service->strength > 0)
218                 connman_dbus_dict_append_variant(&dict, "Strength",
219                                         DBUS_TYPE_BYTE, &service->strength);
220
221         connman_dbus_dict_append_variant(&dict, "Favorite",
222                                         DBUS_TYPE_BOOLEAN, &service->favorite);
223
224         if (service->name != NULL)
225                 connman_dbus_dict_append_variant(&dict, "Name",
226                                         DBUS_TYPE_STRING, &service->name);
227
228         if (service->passphrase != NULL &&
229                         __connman_security_check_privilege(msg,
230                                 CONNMAN_SECURITY_PRIVILEGE_SECRET) == 0)
231                 connman_dbus_dict_append_variant(&dict, "Passphrase",
232                                 DBUS_TYPE_STRING, &service->passphrase);
233
234         dbus_message_iter_close_container(&array, &dict);
235
236         return reply;
237 }
238
239 static DBusMessage *set_property(DBusConnection *conn,
240                                         DBusMessage *msg, void *user_data)
241 {
242         struct connman_service *service = user_data;
243         DBusMessageIter iter, value;
244         const char *name;
245         int type;
246
247         DBG("service %p", service);
248
249         if (dbus_message_iter_init(msg, &iter) == FALSE)
250                 return __connman_error_invalid_arguments(msg);
251
252         dbus_message_iter_get_basic(&iter, &name);
253         dbus_message_iter_next(&iter);
254         dbus_message_iter_recurse(&iter, &value);
255
256         if (__connman_security_check_privilege(msg,
257                                         CONNMAN_SECURITY_PRIVILEGE_MODIFY) < 0)
258                 return __connman_error_permission_denied(msg);
259
260         type = dbus_message_iter_get_arg_type(&value);
261
262         if (g_str_equal(name, "Passphrase") == TRUE) {
263                 const char *passphrase;
264
265                 if (type != DBUS_TYPE_STRING)
266                         return __connman_error_invalid_arguments(msg);
267
268                 if (__connman_security_check_privilege(msg,
269                                         CONNMAN_SECURITY_PRIVILEGE_SECRET) < 0)
270                         return __connman_error_permission_denied(msg);
271
272                 dbus_message_iter_get_basic(&value, &passphrase);
273
274                 g_free(service->passphrase);
275                 service->passphrase = g_strdup(passphrase);
276
277                 if (service->network != NULL)
278                         connman_network_set_string(service->network,
279                                 "WiFi.Passphrase", service->passphrase);
280
281                 __connman_storage_save_service(service);
282         }
283
284         return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
285 }
286
287 static gboolean connect_timeout(gpointer user_data)
288 {
289         struct connman_service *service = user_data;
290
291         DBG("service %p", service);
292
293         service->timeout = 0;
294
295         if (service->network != NULL)
296                 __connman_network_disconnect(service->network);
297
298         if (service->pending != NULL) {
299                 DBusMessage *reply;
300
301                 reply = __connman_error_operation_timeout(service->pending);
302                 if (reply != NULL)
303                         g_dbus_send_message(connection, reply);
304
305                 dbus_message_unref(service->pending);
306                 service->pending = NULL;
307
308                 __connman_service_indicate_state(service,
309                                         CONNMAN_SERVICE_STATE_FAILURE);
310         }
311
312         return FALSE;
313 }
314
315 static DBusMessage *connect_service(DBusConnection *conn,
316                                         DBusMessage *msg, void *user_data)
317 {
318         struct connman_service *service = user_data;
319
320         DBG("service %p", service);
321
322         if (service->pending != NULL)
323                 return __connman_error_in_progress(msg);
324
325         if (service->state == CONNMAN_SERVICE_STATE_READY)
326                 return __connman_error_already_connected(msg);
327
328         if (service->network != NULL) {
329                 int err;
330
331                 connman_network_set_string(service->network,
332                                 "WiFi.Passphrase", service->passphrase);
333
334                 err = connman_network_connect(service->network);
335                 if (err < 0 && err != -EINPROGRESS)
336                         return __connman_error_failed(msg, -err);
337
338                 service->pending = dbus_message_ref(msg);
339
340                 service->timeout = g_timeout_add_seconds(45,
341                                                 connect_timeout, service);
342
343                 return NULL;
344         } else if (service->device != NULL) {
345                 if (service->favorite == FALSE)
346                         return __connman_error_no_carrier(msg);
347
348                 if (__connman_device_connect(service->device) < 0)
349                         return __connman_error_failed(msg, EINVAL);
350
351                 service->pending = dbus_message_ref(msg);
352                 service->timeout = g_timeout_add_seconds(15,
353                                                 connect_timeout, service);
354
355                 return NULL;
356         }
357
358         return __connman_error_not_supported(msg);
359 }
360
361 static DBusMessage *disconnect_service(DBusConnection *conn,
362                                         DBusMessage *msg, void *user_data)
363 {
364         struct connman_service *service = user_data;
365
366         DBG("service %p", service);
367
368         if (service->pending != NULL) {
369                 DBusMessage *reply;
370
371                 reply = __connman_error_operation_aborted(service->pending);
372                 if (reply != NULL)
373                         g_dbus_send_message(conn, reply);
374
375                 dbus_message_unref(service->pending);
376                 service->pending = NULL;
377
378                 return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
379         }
380
381         if (service->network != NULL) {
382                 int err;
383
384                 err = __connman_network_disconnect(service->network);
385                 if (err < 0 && err != -EINPROGRESS)
386                         return __connman_error_failed(msg, -err);
387
388                 return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
389         } else if (service->device != NULL) {
390                 int err;
391
392                 if (service->favorite == FALSE)
393                         return __connman_error_no_carrier(msg);
394
395                 err = __connman_device_disconnect(service->device);
396                 if (err < 0)
397                         return __connman_error_failed(msg, -err);
398
399                 return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
400         }
401
402         return __connman_error_not_supported(msg);
403 }
404
405 static DBusMessage *remove_service(DBusConnection *conn,
406                                         DBusMessage *msg, void *user_data)
407 {
408         struct connman_service *service = user_data;
409
410         DBG("service %p", service);
411
412         if (service->type == CONNMAN_SERVICE_TYPE_ETHERNET)
413                 return __connman_error_not_supported(msg);
414
415         if (service->network != NULL) {
416                 int err;
417
418                 err = __connman_network_disconnect(service->network);
419                 if (err < 0 && err != -EINPROGRESS)
420                         return __connman_error_failed(msg, -err);
421         }
422
423         connman_service_set_favorite(service, FALSE);
424         __connman_storage_save_service(service);
425
426         return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
427 }
428
429 static DBusMessage *move_before(DBusConnection *conn,
430                                         DBusMessage *msg, void *user_data)
431 {
432         struct connman_service *service = user_data;
433
434         DBG("service %p", service);
435
436         if (service->favorite == FALSE)
437                 return __connman_error_not_supported(msg);
438
439         return __connman_error_not_implemented(msg);
440 }
441
442 static DBusMessage *move_after(DBusConnection *conn,
443                                         DBusMessage *msg, void *user_data)
444 {
445         struct connman_service *service = user_data;
446
447         DBG("service %p", service);
448
449         if (service->favorite == FALSE)
450                 return __connman_error_not_supported(msg);
451
452         return __connman_error_not_implemented(msg);
453 }
454
455 static GDBusMethodTable service_methods[] = {
456         { "GetProperties", "",   "a{sv}", get_properties     },
457         { "SetProperty",   "sv", "",      set_property       },
458         { "Connect",       "",   "",      connect_service,
459                                                 G_DBUS_METHOD_FLAG_ASYNC },
460         { "Disconnect",    "",   "",      disconnect_service },
461         { "Remove",        "",   "",      remove_service     },
462         { "MoveBefore",    "o",  "",      move_before        },
463         { "MoveAfter",     "o",  "",      move_after         },
464         { },
465 };
466
467 static GDBusSignalTable service_signals[] = {
468         { "PropertyChanged", "sv" },
469         { },
470 };
471
472 static void service_free(gpointer user_data)
473 {
474         struct connman_service *service = user_data;
475         char *path = service->path;
476
477         DBG("service %p", service);
478
479         g_hash_table_remove(service_hash, service->identifier);
480
481         if (service->timeout > 0)
482                 g_source_remove(service->timeout);
483
484         if (service->pending != NULL) {
485                 dbus_message_unref(service->pending);
486                 service->pending = NULL;
487         }
488
489         service->path = NULL;
490
491         if (path != NULL) {
492                 __connman_profile_changed();
493
494                 g_dbus_unregister_interface(connection, path,
495                                                 CONNMAN_SERVICE_INTERFACE);
496                 g_free(path);
497         }
498
499         if (service->network != NULL)
500                 connman_network_unref(service->network);
501
502         g_free(service->profile);
503         g_free(service->name);
504         g_free(service->passphrase);
505         g_free(service->identifier);
506         g_free(service);
507 }
508
509 /**
510  * __connman_service_put:
511  * @service: service structure
512  *
513  * Release service if no longer needed
514  */
515 void __connman_service_put(struct connman_service *service)
516 {
517         DBG("service %p", service);
518
519         if (g_atomic_int_dec_and_test(&service->refcount) == TRUE) {
520                 GSequenceIter *iter;
521
522                 iter = g_hash_table_lookup(service_hash, service->identifier);
523                 if (iter != NULL)
524                         g_sequence_remove(iter);
525                 else
526                         service_free(service);
527         }
528 }
529
530 static void __connman_service_initialize(struct connman_service *service)
531 {
532         DBG("service %p", service);
533
534         service->refcount = 1;
535
536         service->type     = CONNMAN_SERVICE_TYPE_UNKNOWN;
537         service->mode     = CONNMAN_SERVICE_MODE_UNKNOWN;
538         service->security = CONNMAN_SERVICE_SECURITY_UNKNOWN;
539         service->state    = CONNMAN_SERVICE_STATE_UNKNOWN;
540
541         service->favorite = FALSE;
542
543         service->order = 0;
544 }
545
546 /**
547  * connman_service_create:
548  *
549  * Allocate a new service.
550  *
551  * Returns: a newly-allocated #connman_service structure
552  */
553 struct connman_service *connman_service_create(void)
554 {
555         struct connman_service *service;
556
557         service = g_try_new0(struct connman_service, 1);
558         if (service == NULL)
559                 return NULL;
560
561         DBG("service %p", service);
562
563         __connman_service_initialize(service);
564
565         return service;
566 }
567
568 /**
569  * connman_service_ref:
570  * @service: service structure
571  *
572  * Increase reference counter of service
573  */
574 struct connman_service *connman_service_ref(struct connman_service *service)
575 {
576         g_atomic_int_inc(&service->refcount);
577
578         return service;
579 }
580
581 /**
582  * connman_service_unref:
583  * @service: service structure
584  *
585  * Decrease reference counter of service
586  */
587 void connman_service_unref(struct connman_service *service)
588 {
589         __connman_service_put(service);
590 }
591
592 static gint service_compare(gconstpointer a, gconstpointer b,
593                                                         gpointer user_data)
594 {
595         struct connman_service *service_a = (void *) a;
596         struct connman_service *service_b = (void *) b;
597
598         if (service_a->state != service_b->state) {
599                 if (service_a->state == CONNMAN_SERVICE_STATE_READY)
600                         return -1;
601                 if (service_b->state == CONNMAN_SERVICE_STATE_READY)
602                         return 1;
603         }
604
605         if (service_a->order > service_b->order)
606                 return -1;
607
608         if (service_a->order < service_b->order)
609                 return 1;
610
611         if (service_a->favorite == TRUE && service_b->favorite == FALSE)
612                 return -1;
613
614         if (service_a->favorite == FALSE && service_b->favorite == TRUE)
615                 return 1;
616
617         return (gint) service_b->strength - (gint) service_a->strength;
618 }
619
620 /**
621  * connman_service_set_favorite:
622  * @service: service structure
623  * @favorite: favorite value
624  *
625  * Change the favorite setting of service
626  */
627 int connman_service_set_favorite(struct connman_service *service,
628                                                 connman_bool_t favorite)
629 {
630         GSequenceIter *iter;
631
632         iter = g_hash_table_lookup(service_hash, service->identifier);
633         if (iter == NULL)
634                 return -ENOENT;
635
636         if (service->favorite == favorite)
637                 return -EALREADY;
638
639         service->favorite = favorite;
640
641         g_sequence_sort_changed(iter, service_compare, NULL);
642
643         __connman_profile_changed();
644
645         return 0;
646 }
647
648 int __connman_service_set_carrier(struct connman_service *service,
649                                                 connman_bool_t carrier)
650 {
651         DBG("service %p carrier %d", service, carrier);
652
653         if (service == NULL)
654                 return -EINVAL;
655
656         switch (service->type) {
657         case CONNMAN_SERVICE_TYPE_UNKNOWN:
658         case CONNMAN_SERVICE_TYPE_WIFI:
659         case CONNMAN_SERVICE_TYPE_WIMAX:
660                 return -EINVAL;
661         case CONNMAN_SERVICE_TYPE_ETHERNET:
662                 break;
663         }
664
665         if (carrier == FALSE) {
666                 service->state = CONNMAN_SERVICE_STATE_DISCONNECT;
667                 state_changed(service);
668
669                 service->state = CONNMAN_SERVICE_STATE_IDLE;
670                 state_changed(service);
671         } else {
672                 service->state = CONNMAN_SERVICE_STATE_CARRIER;
673                 state_changed(service);
674         }
675
676         return connman_service_set_favorite(service, carrier);
677 }
678
679 int __connman_service_indicate_state(struct connman_service *service,
680                                         enum connman_service_state state)
681 {
682         GSequenceIter *iter;
683
684         DBG("service %p state %d", service, state);
685
686         if (service == NULL)
687                 return -EINVAL;
688
689         if (state == CONNMAN_SERVICE_STATE_CARRIER)
690                 return __connman_service_set_carrier(service, TRUE);
691
692         if (service->state == state)
693                 return -EALREADY;
694
695         if (service->state == CONNMAN_SERVICE_STATE_IDLE &&
696                                 state == CONNMAN_SERVICE_STATE_DISCONNECT)
697                 return -EINVAL;
698
699         if (state == CONNMAN_SERVICE_STATE_IDLE &&
700                         service->state != CONNMAN_SERVICE_STATE_DISCONNECT) {
701                 service->state = CONNMAN_SERVICE_STATE_DISCONNECT;
702                 state_changed(service);
703         }
704
705         service->state = state;
706         state_changed(service);
707
708         if (state == CONNMAN_SERVICE_STATE_READY) {
709                 connman_service_set_favorite(service, TRUE);
710                 __connman_storage_save_service(service);
711
712                 if (service->timeout > 0)
713                         g_source_remove(service->timeout);
714
715                 if (service->pending != NULL) {
716                         g_dbus_send_reply(connection, service->pending,
717                                                         DBUS_TYPE_INVALID);
718
719                         dbus_message_unref(service->pending);
720                         service->pending = NULL;
721                 }
722         }
723
724         if (state == CONNMAN_SERVICE_STATE_FAILURE) {
725                 if (service->timeout > 0)
726                         g_source_remove(service->timeout);
727
728                 if (service->pending != NULL) {
729                         DBusMessage *reply;
730
731                         reply = __connman_error_failed(service->pending, EIO);
732                         if (reply != NULL)
733                                 g_dbus_send_message(connection, reply);
734
735                         dbus_message_unref(service->pending);
736                         service->pending = NULL;
737                 }
738
739                 service->state = CONNMAN_SERVICE_STATE_IDLE;
740                 state_changed(service);
741         }
742
743         iter = g_hash_table_lookup(service_hash, service->identifier);
744         if (iter != NULL)
745                 g_sequence_sort_changed(iter, service_compare, NULL);
746
747         __connman_profile_changed();
748
749         return 0;
750 }
751
752 /**
753  * __connman_service_lookup:
754  * @identifier: service identifier
755  *
756  * Look up a service by identifier (reference count will not be increased)
757  */
758 static struct connman_service *__connman_service_lookup(const char *identifier)
759 {
760         GSequenceIter *iter;
761
762         iter = g_hash_table_lookup(service_hash, identifier);
763         if (iter != NULL)
764                 return g_sequence_get(iter);
765
766         return NULL;
767 }
768
769 /**
770  * __connman_service_get:
771  * @identifier: service identifier
772  *
773  * Look up a service by identifier or create a new one if not found
774  */
775 static struct connman_service *__connman_service_get(const char *identifier)
776 {
777         struct connman_service *service;
778         GSequenceIter *iter;
779
780         iter = g_hash_table_lookup(service_hash, identifier);
781         if (iter != NULL) {
782                 service = g_sequence_get(iter);
783                 if (service != NULL)
784                         g_atomic_int_inc(&service->refcount);
785                 return service;
786         }
787
788         service = g_try_new0(struct connman_service, 1);
789         if (service == NULL)
790                 return NULL;
791
792         DBG("service %p", service);
793
794         __connman_service_initialize(service);
795
796         service->identifier = g_strdup(identifier);
797
798         service->profile = g_strdup(__connman_profile_active_ident());
799
800         __connman_storage_load_service(service);
801
802         iter = g_sequence_insert_sorted(service_list, service,
803                                                 service_compare, NULL);
804
805         g_hash_table_insert(service_hash, service->identifier, iter);
806
807         return service;
808 }
809
810 static int service_register(struct connman_service *service)
811 {
812         const char *path = __connman_profile_active_path();
813         GSequenceIter *iter;
814
815         DBG("service %p", service);
816
817         if (service->path != NULL)
818                 return -EALREADY;
819
820         service->path = g_strdup_printf("%s/%s", path, service->identifier);
821
822         DBG("path %s", service->path);
823
824         g_dbus_register_interface(connection, service->path,
825                                         CONNMAN_SERVICE_INTERFACE,
826                                         service_methods, service_signals,
827                                                         NULL, service, NULL);
828
829         __connman_storage_load_service(service);
830
831         iter = g_hash_table_lookup(service_hash, service->identifier);
832         if (iter != NULL)
833                 g_sequence_sort_changed(iter, service_compare, NULL);
834
835         __connman_profile_changed();
836
837         return 0;
838 }
839
840 /**
841  * connman_service_lookup_from_device:
842  * @device: device structure
843  *
844  * Look up a service by device (reference count will not be increased)
845  */
846 struct connman_service *__connman_service_lookup_from_device(struct connman_device *device)
847 {
848         struct connman_service *service;
849         const char *ident;
850         char *name;
851
852         ident = __connman_device_get_ident(device);
853         if (ident == NULL)
854                 return NULL;
855
856         name = g_strdup_printf("%s_%s",
857                                 __connman_device_get_type(device), ident);
858
859         service = __connman_service_lookup(name);
860
861         g_free(name);
862
863         return service;
864 }
865
866 static enum connman_service_type convert_device_type(struct connman_device *device)
867 {
868         enum connman_device_type type = connman_device_get_type(device);
869
870         switch (type) {
871         case CONNMAN_DEVICE_TYPE_UNKNOWN:
872         case CONNMAN_DEVICE_TYPE_VENDOR:
873         case CONNMAN_DEVICE_TYPE_WIFI:
874         case CONNMAN_DEVICE_TYPE_WIMAX:
875         case CONNMAN_DEVICE_TYPE_BLUETOOTH:
876         case CONNMAN_DEVICE_TYPE_GPS:
877         case CONNMAN_DEVICE_TYPE_HSO:
878         case CONNMAN_DEVICE_TYPE_NOZOMI:
879         case CONNMAN_DEVICE_TYPE_HUAWEI:
880         case CONNMAN_DEVICE_TYPE_NOVATEL:
881                 break;
882         case CONNMAN_DEVICE_TYPE_ETHERNET:
883                 return CONNMAN_SERVICE_TYPE_ETHERNET;
884         }
885
886         return CONNMAN_SERVICE_TYPE_UNKNOWN;
887 }
888
889 /**
890  * connman_service_create_from_device:
891  * @device: device structure
892  *
893  * Look up service by device and if not found, create one
894  */
895 struct connman_service *__connman_service_create_from_device(struct connman_device *device)
896 {
897         struct connman_service *service;
898         const char *ident;
899         char *name;
900
901         ident = __connman_device_get_ident(device);
902         if (ident == NULL)
903                 return NULL;
904
905         name = g_strdup_printf("%s_%s",
906                                 __connman_device_get_type(device), ident);
907
908         service = __connman_service_get(name);
909         if (service == NULL)
910                 goto done;
911
912         if (service->path != NULL) {
913                 __connman_service_put(service);
914                 service = NULL;
915                 goto done;
916         }
917
918         service->type = convert_device_type(device);
919
920         service->device = device;
921
922         service_register(service);
923
924 done:
925         g_free(name);
926
927         return service;
928 }
929
930 /**
931  * connman_service_lookup_from_network:
932  * @network: network structure
933  *
934  * Look up a service by network (reference count will not be increased)
935  */
936 struct connman_service *__connman_service_lookup_from_network(struct connman_network *network)
937 {
938         struct connman_service *service;
939         const char *ident, *group;
940         char *name;
941
942         ident = __connman_network_get_ident(network);
943         if (ident == NULL)
944                 return NULL;
945
946         group = __connman_network_get_group(network);
947         if (group == NULL)
948                 return NULL;
949
950         name = g_strdup_printf("%s_%s_%s",
951                         __connman_network_get_type(network), ident, group);
952
953         service = __connman_service_lookup(name);
954
955         g_free(name);
956
957         return service;
958 }
959
960 static enum connman_service_type convert_network_type(struct connman_network *network)
961 {
962         enum connman_network_type type = connman_network_get_type(network);
963
964         switch (type) {
965         case CONNMAN_NETWORK_TYPE_UNKNOWN:
966         case CONNMAN_NETWORK_TYPE_VENDOR:
967         case CONNMAN_NETWORK_TYPE_BLUETOOTH_PAN:
968         case CONNMAN_NETWORK_TYPE_BLUETOOTH_DUN:
969         case CONNMAN_NETWORK_TYPE_HSO:
970                 break;
971         case CONNMAN_NETWORK_TYPE_WIFI:
972                 return CONNMAN_SERVICE_TYPE_WIFI;
973         case CONNMAN_NETWORK_TYPE_WIMAX:
974                 return CONNMAN_SERVICE_TYPE_WIMAX;
975         }
976
977         return CONNMAN_SERVICE_TYPE_UNKNOWN;
978 }
979
980 static enum connman_service_mode convert_wifi_mode(const char *mode)
981 {
982         if (mode == NULL)
983                 return CONNMAN_SERVICE_MODE_UNKNOWN;
984         else if (g_str_equal(mode, "managed") == TRUE)
985                 return CONNMAN_SERVICE_MODE_MANAGED;
986         else if (g_str_equal(mode, "adhoc") == TRUE)
987                 return CONNMAN_SERVICE_MODE_ADHOC;
988         else
989                 return CONNMAN_SERVICE_MODE_UNKNOWN;
990 }
991
992 static enum connman_service_mode convert_wifi_security(const char *security)
993 {
994         if (security == NULL)
995                 return CONNMAN_SERVICE_SECURITY_UNKNOWN;
996         else if (g_str_equal(security, "none") == TRUE)
997                 return CONNMAN_SERVICE_SECURITY_NONE;
998         else if (g_str_equal(security, "wep") == TRUE)
999                 return CONNMAN_SERVICE_SECURITY_WEP;
1000         else if (g_str_equal(security, "wpa") == TRUE)
1001                 return CONNMAN_SERVICE_SECURITY_WPA;
1002         else if (g_str_equal(security, "wpa2") == TRUE)
1003                 return CONNMAN_SERVICE_SECURITY_WPA2;
1004         else
1005                 return CONNMAN_SERVICE_SECURITY_UNKNOWN;
1006 }
1007
1008 static void update_from_network(struct connman_service *service,
1009                                         struct connman_network *network)
1010 {
1011         connman_uint8_t strength = service->strength;
1012         GSequenceIter *iter;
1013         const char *str;
1014
1015         str = connman_network_get_string(network, "Name");
1016         if (str != NULL) {
1017                 g_free(service->name);
1018                 service->name = g_strdup(str);
1019         }
1020
1021         service->strength = connman_network_get_uint8(network, "Strength");
1022
1023         str = connman_network_get_string(network, "WiFi.Mode");
1024         service->mode = convert_wifi_mode(str);
1025
1026         str = connman_network_get_string(network, "WiFi.Security");
1027         service->security = convert_wifi_security(str);
1028
1029         if (service->strength > strength && service->network != NULL) {
1030                 connman_network_unref(service->network);
1031                 service->network = NULL;
1032         }
1033
1034         if (service->network == NULL) {
1035                 service->network = connman_network_ref(network);
1036
1037                 str = connman_network_get_string(network, "WiFi.Passphrase");
1038                 if (str != NULL) {
1039                         g_free(service->passphrase);
1040                         service->passphrase = g_strdup(str);
1041                 }
1042         }
1043
1044         iter = g_hash_table_lookup(service_hash, service->identifier);
1045         if (iter != NULL)
1046                 g_sequence_sort_changed(iter, service_compare, NULL);
1047 }
1048
1049 /**
1050  * connman_service_create_from_network:
1051  * @network: network structure
1052  *
1053  * Look up service by network and if not found, create one
1054  */
1055 struct connman_service *__connman_service_create_from_network(struct connman_network *network)
1056 {
1057         struct connman_service *service;
1058         const char *ident, *group;
1059         char *name;
1060
1061         ident = __connman_network_get_ident(network);
1062         if (ident == NULL)
1063                 return NULL;
1064
1065         group = __connman_network_get_group(network);
1066         if (group == NULL)
1067                 return NULL;
1068
1069         name = g_strdup_printf("%s_%s_%s",
1070                         __connman_network_get_type(network), ident, group);
1071
1072         service = __connman_service_get(name);
1073         if (service == NULL)
1074                 goto done;
1075
1076         if (service->path != NULL) {
1077                 update_from_network(service, network);
1078
1079                 __connman_profile_changed();
1080
1081                 __connman_service_put(service);
1082                 service = NULL;
1083                 goto done;
1084         }
1085
1086         service->type = convert_network_type(network);
1087
1088         service->state = CONNMAN_SERVICE_STATE_IDLE;
1089
1090         update_from_network(service, network);
1091
1092         service_register(service);
1093
1094 done:
1095         g_free(name);
1096
1097         return service;
1098 }
1099
1100 static int service_load(struct connman_service *service)
1101 {
1102         GKeyFile *keyfile;
1103         gchar *pathname, *data = NULL;
1104         gsize length;
1105         char *str;
1106
1107         DBG("service %p", service);
1108
1109         if (service->profile == NULL)
1110                 return -EINVAL;
1111
1112         pathname = g_strdup_printf("%s/%s.conf", STORAGEDIR, service->profile);
1113         if (pathname == NULL)
1114                 return -ENOMEM;
1115
1116         keyfile = g_key_file_new();
1117
1118         if (g_file_get_contents(pathname, &data, &length, NULL) == FALSE) {
1119                 g_free(pathname);
1120                 return -ENOENT;
1121         }
1122
1123         g_free(pathname);
1124
1125         if (g_key_file_load_from_data(keyfile, data, length,
1126                                                         0, NULL) == FALSE) {
1127                 g_free(data);
1128                 return -EILSEQ;
1129         }
1130
1131         g_free(data);
1132
1133         switch (service->type) {
1134         case CONNMAN_SERVICE_TYPE_UNKNOWN:
1135         case CONNMAN_SERVICE_TYPE_ETHERNET:
1136                 break;
1137         case CONNMAN_SERVICE_TYPE_WIFI:
1138         case CONNMAN_SERVICE_TYPE_WIMAX:
1139                 service->favorite = g_key_file_get_boolean(keyfile,
1140                                 service->identifier, "Favorite", NULL);
1141                 break;
1142         }
1143
1144         str = g_key_file_get_string(keyfile,
1145                                 service->identifier, "Passphrase", NULL);
1146         if (str != NULL) {
1147                 g_free(service->passphrase);
1148                 service->passphrase = str;
1149         }
1150
1151         g_key_file_free(keyfile);
1152
1153         return 0;
1154 }
1155
1156 static int service_save(struct connman_service *service)
1157 {
1158         GKeyFile *keyfile;
1159         gchar *pathname, *data = NULL;
1160         gsize length;
1161
1162         DBG("service %p", service);
1163
1164         if (service->profile == NULL)
1165                 return -EINVAL;
1166
1167         pathname = g_strdup_printf("%s/%s.conf", STORAGEDIR, service->profile);
1168         if (pathname == NULL)
1169                 return -ENOMEM;
1170
1171         keyfile = g_key_file_new();
1172
1173         if (g_file_get_contents(pathname, &data, &length, NULL) == FALSE)
1174                 goto update;
1175
1176         if (length > 0) {
1177                 if (g_key_file_load_from_data(keyfile, data, length,
1178                                                         0, NULL) == FALSE)
1179                         goto done;
1180         }
1181
1182         g_free(data);
1183
1184 update:
1185         if (service->name != NULL)
1186                 g_key_file_set_string(keyfile, service->identifier,
1187                                                 "Name", service->name);
1188
1189         switch (service->type) {
1190         case CONNMAN_SERVICE_TYPE_UNKNOWN:
1191         case CONNMAN_SERVICE_TYPE_ETHERNET:
1192                 break;
1193         case CONNMAN_SERVICE_TYPE_WIFI:
1194         case CONNMAN_SERVICE_TYPE_WIMAX:
1195                 g_key_file_set_boolean(keyfile, service->identifier,
1196                                         "Favorite", service->favorite);
1197                 break;
1198         }
1199
1200         if (service->passphrase != NULL)
1201                 g_key_file_set_string(keyfile, service->identifier,
1202                                         "Passphrase", service->passphrase);
1203
1204         data = g_key_file_to_data(keyfile, &length, NULL);
1205
1206         if (g_file_set_contents(pathname, data, length, NULL) == FALSE)
1207                 connman_error("Failed to store service information");
1208
1209 done:
1210         g_free(data);
1211
1212         g_key_file_free(keyfile);
1213
1214         g_free(pathname);
1215
1216         return 0;
1217 }
1218
1219 static struct connman_storage service_storage = {
1220         .name           = "service",
1221         .priority       = CONNMAN_STORAGE_PRIORITY_LOW,
1222         .service_load   = service_load,
1223         .service_save   = service_save,
1224 };
1225
1226 int __connman_service_init(void)
1227 {
1228         DBG("");
1229
1230         connection = connman_dbus_get_connection();
1231
1232         if (connman_storage_register(&service_storage) < 0)
1233                 connman_error("Failed to register service storage");
1234
1235         service_hash = g_hash_table_new_full(g_str_hash, g_str_equal,
1236                                                                 NULL, NULL);
1237
1238         service_list = g_sequence_new(service_free);
1239
1240         return 0;
1241 }
1242
1243 void __connman_service_cleanup(void)
1244 {
1245         DBG("");
1246
1247         g_sequence_free(service_list);
1248         service_list = NULL;
1249
1250         g_hash_table_destroy(service_hash);
1251         service_hash = NULL;
1252
1253         connman_storage_unregister(&service_storage);
1254
1255         dbus_connection_unref(connection);
1256 }