technology: Change enabled to a boolean and refactor accordingly
[platform/upstream/connman.git] / src / technology.c
1 /*
2  *
3  *  Connection Manager
4  *
5  *  Copyright (C) 2007-2012  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 <errno.h>
27 #include <string.h>
28
29 #include <gdbus.h>
30
31 #include "connman.h"
32
33 static DBusConnection *connection;
34
35 static GSList *technology_list = NULL;
36
37 /*
38  * List of devices with no technology associated with them either because of
39  * no compiled in support or the driver is not yet loaded.
40 */
41 static GSList *techless_device_list = NULL;
42 static GHashTable *rfkill_list;
43
44 static connman_bool_t global_offlinemode;
45
46 struct connman_rfkill {
47         unsigned int index;
48         enum connman_service_type type;
49         connman_bool_t softblock;
50         connman_bool_t hardblock;
51 };
52
53 struct connman_technology {
54         int refcount;
55         enum connman_service_type type;
56         char *path;
57         GSList *device_list;
58         connman_bool_t enabled;
59         char *regdom;
60         connman_bool_t connected;
61
62         connman_bool_t tethering;
63         char *tethering_ident;
64         char *tethering_passphrase;
65
66         connman_bool_t enable_persistent; /* Save the tech state */
67
68         struct connman_technology_driver *driver;
69         void *driver_data;
70
71         DBusMessage *pending_reply;
72         guint pending_timeout;
73
74         GSList *scan_pending;
75
76         connman_bool_t rfkill_driven;
77         connman_bool_t softblocked;
78         connman_bool_t hardblocked;
79         connman_bool_t dbus_registered;
80 };
81
82 static GSList *driver_list = NULL;
83
84 static gint compare_priority(gconstpointer a, gconstpointer b)
85 {
86         const struct connman_technology_driver *driver1 = a;
87         const struct connman_technology_driver *driver2 = b;
88
89         return driver2->priority - driver1->priority;
90 }
91
92 static void rfkill_check(gpointer key, gpointer value, gpointer user_data)
93 {
94         struct connman_rfkill *rfkill = value;
95         enum connman_service_type type = GPOINTER_TO_INT(user_data);
96
97         /* Calling _technology_rfkill_add will update the tech. */
98         if (rfkill->type == type)
99                 __connman_technology_add_rfkill(rfkill->index, type,
100                                 rfkill->softblock, rfkill->hardblock);
101 }
102
103 /**
104  * connman_technology_driver_register:
105  * @driver: Technology driver definition
106  *
107  * Register a new technology driver
108  *
109  * Returns: %0 on success
110  */
111 int connman_technology_driver_register(struct connman_technology_driver *driver)
112 {
113         GSList *list;
114         struct connman_device *device;
115         enum connman_service_type type;
116
117         DBG("Registering %s driver", driver->name);
118
119         driver_list = g_slist_insert_sorted(driver_list, driver,
120                                                         compare_priority);
121
122         if (techless_device_list == NULL)
123                 goto check_rfkill;
124
125         /*
126          * Check for technology less devices if this driver
127          * can service any of them.
128         */
129         for (list = techless_device_list; list; list = list->next) {
130                 device = list->data;
131
132                 type = __connman_device_get_service_type(device);
133                 if (type != driver->type)
134                         continue;
135
136                 techless_device_list = g_slist_remove(techless_device_list,
137                                                                 device);
138
139                 __connman_technology_add_device(device);
140         }
141
142 check_rfkill:
143         /* Check for orphaned rfkill switches. */
144         g_hash_table_foreach(rfkill_list, rfkill_check,
145                                         GINT_TO_POINTER(driver->type));
146
147         return 0;
148 }
149
150 /**
151  * connman_technology_driver_unregister:
152  * @driver: Technology driver definition
153  *
154  * Remove a previously registered technology driver
155  */
156 void connman_technology_driver_unregister(struct connman_technology_driver *driver)
157 {
158         GSList *list;
159         struct connman_technology *technology;
160
161         DBG("Unregistering driver %p name %s", driver, driver->name);
162
163         for (list = technology_list; list; list = list->next) {
164                 technology = list->data;
165
166                 if (technology->driver == NULL)
167                         continue;
168
169                 if (technology->type == driver->type) {
170                         technology->driver->remove(technology);
171                         technology->driver = NULL;
172                 }
173         }
174
175         driver_list = g_slist_remove(driver_list, driver);
176 }
177
178 static void tethering_changed(struct connman_technology *technology)
179 {
180         connman_bool_t tethering = technology->tethering;
181
182         connman_dbus_property_changed_basic(technology->path,
183                                 CONNMAN_TECHNOLOGY_INTERFACE, "Tethering",
184                                                 DBUS_TYPE_BOOLEAN, &tethering);
185 }
186
187 void connman_technology_tethering_notify(struct connman_technology *technology,
188                                                         connman_bool_t enabled)
189 {
190         GSList *list;
191
192         DBG("technology %p enabled %u", technology, enabled);
193
194         if (technology->tethering == enabled)
195                 return;
196
197         technology->tethering = enabled;
198
199         tethering_changed(technology);
200
201         if (enabled == TRUE)
202                 __connman_tethering_set_enabled();
203         else {
204                 for (list = technology_list; list; list = list->next) {
205                         struct connman_technology *other_tech = list->data;
206                         if (other_tech->tethering == TRUE)
207                                 break;
208                 }
209                 if (list == NULL)
210                         __connman_tethering_set_disabled();
211         }
212 }
213
214 static int set_tethering(struct connman_technology *technology,
215                                 connman_bool_t enabled)
216 {
217         const char *ident, *passphrase, *bridge;
218
219         ident = technology->tethering_ident;
220         passphrase = technology->tethering_passphrase;
221
222         if (technology->driver == NULL ||
223                         technology->driver->set_tethering == NULL)
224                 return -EOPNOTSUPP;
225
226         bridge = __connman_tethering_get_bridge();
227         if (bridge == NULL)
228                 return -EOPNOTSUPP;
229
230         if (technology->type == CONNMAN_SERVICE_TYPE_WIFI &&
231             (ident == NULL || passphrase == NULL))
232                 return -EINVAL;
233
234         return technology->driver->set_tethering(technology, ident, passphrase,
235                                                         bridge, enabled);
236 }
237
238 void connman_technology_regdom_notify(struct connman_technology *technology,
239                                                         const char *alpha2)
240 {
241         DBG("");
242
243         if (alpha2 == NULL)
244                 connman_error("Failed to set regulatory domain");
245         else
246                 DBG("Regulatory domain set to %s", alpha2);
247
248         g_free(technology->regdom);
249         technology->regdom = g_strdup(alpha2);
250 }
251
252 static int set_regdom_by_device(struct connman_technology *technology,
253                                                         const char *alpha2)
254 {
255         GSList *list;
256
257         for (list = technology->device_list; list; list = list->next) {
258                 struct connman_device *device = list->data;
259
260                 if (connman_device_set_regdom(device, alpha2) != 0)
261                         return -ENOTSUP;
262         }
263
264         return 0;
265 }
266
267 int connman_technology_set_regdom(const char *alpha2)
268 {
269         GSList *list;
270
271         for (list = technology_list; list; list = list->next) {
272                 struct connman_technology *technology = list->data;
273
274                 if (set_regdom_by_device(technology, alpha2) != 0) {
275                         if (technology->driver == NULL)
276                                 continue;
277
278                         if (technology->driver->set_regdom != NULL)
279                                 technology->driver->set_regdom(technology,
280                                                                 alpha2);
281                 }
282         }
283
284         return 0;
285 }
286
287 static void free_rfkill(gpointer data)
288 {
289         struct connman_rfkill *rfkill = data;
290
291         g_free(rfkill);
292 }
293
294 static const char *get_name(enum connman_service_type type)
295 {
296         switch (type) {
297         case CONNMAN_SERVICE_TYPE_UNKNOWN:
298         case CONNMAN_SERVICE_TYPE_SYSTEM:
299         case CONNMAN_SERVICE_TYPE_GPS:
300         case CONNMAN_SERVICE_TYPE_VPN:
301         case CONNMAN_SERVICE_TYPE_GADGET:
302                 break;
303         case CONNMAN_SERVICE_TYPE_ETHERNET:
304                 return "Wired";
305         case CONNMAN_SERVICE_TYPE_WIFI:
306                 return "WiFi";
307         case CONNMAN_SERVICE_TYPE_WIMAX:
308                 return "WiMAX";
309         case CONNMAN_SERVICE_TYPE_BLUETOOTH:
310                 return "Bluetooth";
311         case CONNMAN_SERVICE_TYPE_CELLULAR:
312                 return "Cellular";
313         }
314
315         return NULL;
316 }
317
318 static void technology_save(struct connman_technology *technology)
319 {
320         GKeyFile *keyfile;
321         gchar *identifier;
322
323         DBG("technology %p", technology);
324
325         keyfile = __connman_storage_load_global();
326         if (keyfile == NULL)
327                 keyfile = g_key_file_new();
328
329         identifier = g_strdup_printf("%s", get_name(technology->type));
330         if (identifier == NULL)
331                 goto done;
332
333         g_key_file_set_boolean(keyfile, identifier, "Enable",
334                                 technology->enable_persistent);
335
336         if (technology->tethering_ident != NULL)
337                 g_key_file_set_string(keyfile, identifier,
338                                         "Tethering.Identifier",
339                                         technology->tethering_ident);
340
341         if (technology->tethering_passphrase != NULL)
342                 g_key_file_set_string(keyfile, identifier,
343                                         "Tethering.Passphrase",
344                                         technology->tethering_passphrase);
345
346 done:
347         g_free(identifier);
348
349         __connman_storage_save_global(keyfile);
350
351         g_key_file_free(keyfile);
352
353         return;
354 }
355
356 static void technology_load(struct connman_technology *technology)
357 {
358         GKeyFile *keyfile;
359         gchar *identifier;
360         GError *error = NULL;
361         connman_bool_t enable;
362
363         DBG("technology %p", technology);
364
365         keyfile = __connman_storage_load_global();
366         /* Fallback on disabling technology if file not found. */
367         if (keyfile == NULL) {
368                 if (technology->type == CONNMAN_SERVICE_TYPE_ETHERNET)
369                         /* We enable ethernet by default */
370                         technology->enable_persistent = TRUE;
371                 else
372                         technology->enable_persistent = FALSE;
373                 return;
374         }
375
376         identifier = g_strdup_printf("%s", get_name(technology->type));
377         if (identifier == NULL)
378                 goto done;
379
380         enable = g_key_file_get_boolean(keyfile, identifier, "Enable", &error);
381         if (error == NULL)
382                 technology->enable_persistent = enable;
383         else {
384                 if (technology->type == CONNMAN_SERVICE_TYPE_ETHERNET)
385                         technology->enable_persistent = TRUE;
386                 else
387                         technology->enable_persistent = FALSE;
388
389                 technology_save(technology);
390                 g_clear_error(&error);
391         }
392
393         technology->tethering_ident = g_key_file_get_string(keyfile,
394                                 identifier, "Tethering.Identifier", NULL);
395
396         technology->tethering_passphrase = g_key_file_get_string(keyfile,
397                                 identifier, "Tethering.Passphrase", NULL);
398 done:
399         g_free(identifier);
400
401         g_key_file_free(keyfile);
402
403         return;
404 }
405
406 connman_bool_t __connman_technology_get_offlinemode(void)
407 {
408         return global_offlinemode;
409 }
410
411 static void connman_technology_save_offlinemode()
412 {
413         GKeyFile *keyfile;
414
415         keyfile = __connman_storage_load_global();
416         if (keyfile == NULL)
417                 keyfile = g_key_file_new();
418
419         g_key_file_set_boolean(keyfile, "global",
420                                         "OfflineMode", global_offlinemode);
421
422         __connman_storage_save_global(keyfile);
423
424         g_key_file_free(keyfile);
425
426         return;
427 }
428
429 static connman_bool_t connman_technology_load_offlinemode()
430 {
431         GKeyFile *keyfile;
432         GError *error = NULL;
433         connman_bool_t offlinemode;
434
435         /* If there is a error, we enable offlinemode */
436         keyfile = __connman_storage_load_global();
437         if (keyfile == NULL)
438                 return FALSE;
439
440         offlinemode = g_key_file_get_boolean(keyfile, "global",
441                                                 "OfflineMode", &error);
442         if (error != NULL) {
443                 offlinemode = FALSE;
444                 g_clear_error(&error);
445         }
446
447         g_key_file_free(keyfile);
448
449         return offlinemode;
450 }
451
452 static void append_properties(DBusMessageIter *iter,
453                 struct connman_technology *technology)
454 {
455         DBusMessageIter dict;
456         const char *str;
457
458         connman_dbus_dict_open(iter, &dict);
459
460         str = get_name(technology->type);
461         if (str != NULL)
462                 connman_dbus_dict_append_basic(&dict, "Name",
463                                                 DBUS_TYPE_STRING, &str);
464
465         str = __connman_service_type2string(technology->type);
466         if (str != NULL)
467                 connman_dbus_dict_append_basic(&dict, "Type",
468                                                 DBUS_TYPE_STRING, &str);
469
470         __sync_synchronize();
471         connman_dbus_dict_append_basic(&dict, "Powered",
472                                         DBUS_TYPE_BOOLEAN,
473                                         &technology->enabled);
474
475         connman_dbus_dict_append_basic(&dict, "Connected",
476                                         DBUS_TYPE_BOOLEAN,
477                                         &technology->connected);
478
479         connman_dbus_dict_append_basic(&dict, "Tethering",
480                                         DBUS_TYPE_BOOLEAN,
481                                         &technology->tethering);
482
483         if (technology->tethering_ident != NULL)
484                 connman_dbus_dict_append_basic(&dict, "TetheringIdentifier",
485                                         DBUS_TYPE_STRING,
486                                         &technology->tethering_ident);
487
488         if (technology->tethering_passphrase != NULL)
489                 connman_dbus_dict_append_basic(&dict, "TetheringPassphrase",
490                                         DBUS_TYPE_STRING,
491                                         &technology->tethering_passphrase);
492
493         connman_dbus_dict_close(iter, &dict);
494 }
495
496 static void technology_added_signal(struct connman_technology *technology)
497 {
498         DBusMessage *signal;
499         DBusMessageIter iter;
500
501         signal = dbus_message_new_signal(CONNMAN_MANAGER_PATH,
502                         CONNMAN_MANAGER_INTERFACE, "TechnologyAdded");
503         if (signal == NULL)
504                 return;
505
506         dbus_message_iter_init_append(signal, &iter);
507         dbus_message_iter_append_basic(&iter, DBUS_TYPE_OBJECT_PATH,
508                                                         &technology->path);
509         append_properties(&iter, technology);
510
511         dbus_connection_send(connection, signal, NULL);
512         dbus_message_unref(signal);
513 }
514
515 static void technology_removed_signal(struct connman_technology *technology)
516 {
517         g_dbus_emit_signal(connection, CONNMAN_MANAGER_PATH,
518                         CONNMAN_MANAGER_INTERFACE, "TechnologyRemoved",
519                         DBUS_TYPE_OBJECT_PATH, &technology->path,
520                         DBUS_TYPE_INVALID);
521 }
522
523 static DBusMessage *get_properties(DBusConnection *conn,
524                                         DBusMessage *message, void *user_data)
525 {
526         struct connman_technology *technology = user_data;
527         DBusMessage *reply;
528         DBusMessageIter iter;
529
530         reply = dbus_message_new_method_return(message);
531         if (reply == NULL)
532                 return NULL;
533
534         dbus_message_iter_init_append(reply, &iter);
535         append_properties(&iter, technology);
536
537         return reply;
538 }
539
540 void __connman_technology_list_struct(DBusMessageIter *array)
541 {
542         GSList *list;
543         DBusMessageIter entry;
544
545         for (list = technology_list; list; list = list->next) {
546                 struct connman_technology *technology = list->data;
547
548                 if (technology->path == NULL ||
549                                 (technology->rfkill_driven == TRUE &&
550                                  technology->hardblocked == TRUE))
551                         continue;
552
553                 dbus_message_iter_open_container(array, DBUS_TYPE_STRUCT,
554                                 NULL, &entry);
555                 dbus_message_iter_append_basic(&entry, DBUS_TYPE_OBJECT_PATH,
556                                 &technology->path);
557                 append_properties(&entry, technology);
558                 dbus_message_iter_close_container(array, &entry);
559         }
560 }
561
562 static gboolean technology_pending_reply(gpointer user_data)
563 {
564         struct connman_technology *technology = user_data;
565         DBusMessage *reply;
566
567         /* Power request timedout, send ETIMEDOUT. */
568         if (technology->pending_reply != NULL) {
569                 reply = __connman_error_failed(technology->pending_reply, ETIMEDOUT);
570                 if (reply != NULL)
571                         g_dbus_send_message(connection, reply);
572
573                 dbus_message_unref(technology->pending_reply);
574                 technology->pending_reply = NULL;
575                 technology->pending_timeout = 0;
576         }
577
578         return FALSE;
579 }
580
581 static int technology_affect_devices(struct connman_technology *technology,
582                                                 connman_bool_t enable_device)
583 {
584         GSList *list;
585         int err = 0;
586
587         for (list = technology->device_list; list; list = list->next) {
588                 struct connman_device *device = list->data;
589
590                 if (enable_device == TRUE)
591                         err = __connman_device_enable(device);
592                 else
593                         err = __connman_device_disable(device);
594         }
595
596         return err;
597 }
598
599 static int technology_enable(struct connman_technology *technology,
600                                                 connman_bool_t hardblock)
601 {
602         DBG("technology %p enable", technology);
603
604         __sync_synchronize();
605         if (technology->enabled == TRUE)
606                 return -EALREADY;
607
608         if (technology->pending_reply != NULL)
609                 return -EBUSY;
610
611         if (hardblock == TRUE && technology->enable_persistent == FALSE)
612                 return 0;
613
614         __connman_rfkill_block(technology->type, FALSE);
615
616         return technology_affect_devices(technology, TRUE);
617 }
618
619 static int technology_disable(struct connman_technology *technology,
620                                                 connman_bool_t hardblock)
621 {
622         DBG("technology %p disable", technology);
623
624         __sync_synchronize();
625         if (technology->enabled == FALSE)
626                 return -EALREADY;
627
628         if (technology->pending_reply != NULL)
629                 return -EBUSY;
630
631         if (technology->tethering == TRUE)
632                 set_tethering(technology, FALSE);
633
634         if (hardblock == FALSE)
635                 __connman_rfkill_block(technology->type, TRUE);
636
637         return technology_affect_devices(technology, FALSE);
638 }
639
640 static DBusMessage *set_powered(struct connman_technology *technology,
641                                 DBusMessage *msg, connman_bool_t powered)
642 {
643         DBusMessage *reply = NULL;
644         int err = 0;
645
646         if (technology->rfkill_driven && technology->hardblocked == TRUE) {
647                 err = -EACCES;
648                 goto make_reply;
649         }
650
651         if (powered == TRUE)
652                 err = technology_enable(technology, FALSE);
653         else
654                 err = technology_disable(technology, FALSE);
655
656         if (err != -EBUSY) {
657                 technology->enable_persistent = powered;
658                 technology_save(technology);
659         }
660
661 make_reply:
662         if (err == -EINPROGRESS) {
663                 technology->pending_reply = dbus_message_ref(msg);
664                 technology->pending_timeout = g_timeout_add_seconds(10,
665                                         technology_pending_reply, technology);
666         } else if (err == -EALREADY) {
667                 if (powered == TRUE)
668                         reply = __connman_error_already_enabled(msg);
669                 else
670                         reply = __connman_error_already_disabled(msg);
671         } else if (err < 0)
672                 reply = __connman_error_failed(msg, -err);
673         else
674                 reply = g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
675
676         return reply;
677 }
678
679 static DBusMessage *set_property(DBusConnection *conn,
680                                         DBusMessage *msg, void *data)
681 {
682         struct connman_technology *technology = data;
683         DBusMessageIter iter, value;
684         const char *name;
685         int type;
686
687         DBG("conn %p", conn);
688
689         if (dbus_message_iter_init(msg, &iter) == FALSE)
690                 return __connman_error_invalid_arguments(msg);
691
692         if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_STRING)
693                 return __connman_error_invalid_arguments(msg);
694
695         dbus_message_iter_get_basic(&iter, &name);
696         dbus_message_iter_next(&iter);
697
698         if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_VARIANT)
699                 return __connman_error_invalid_arguments(msg);
700
701         dbus_message_iter_recurse(&iter, &value);
702
703         type = dbus_message_iter_get_arg_type(&value);
704
705         DBG("property %s", name);
706
707         if (g_str_equal(name, "Tethering") == TRUE) {
708                 int err;
709                 connman_bool_t tethering;
710
711                 if (type != DBUS_TYPE_BOOLEAN)
712                         return __connman_error_invalid_arguments(msg);
713
714                 dbus_message_iter_get_basic(&value, &tethering);
715
716                 if (technology->tethering == tethering) {
717                         if (tethering == FALSE)
718                                 return __connman_error_already_disabled(msg);
719                         else
720                                 return __connman_error_already_enabled(msg);
721                 }
722
723                 err = set_tethering(technology, tethering);
724                 if (err < 0)
725                         return __connman_error_failed(msg, -err);
726
727         } else if (g_str_equal(name, "TetheringIdentifier") == TRUE) {
728                 const char *str;
729
730                 dbus_message_iter_get_basic(&value, &str);
731
732                 if (technology->type != CONNMAN_SERVICE_TYPE_WIFI)
733                         return __connman_error_not_supported(msg);
734
735                 if (strlen(str) < 1 || strlen(str) > 32)
736                         return __connman_error_invalid_arguments(msg);
737
738                 if (g_strcmp0(technology->tethering_ident, str) != 0) {
739                         g_free(technology->tethering_ident);
740                         technology->tethering_ident = g_strdup(str);
741                         technology_save(technology);
742
743                         connman_dbus_property_changed_basic(technology->path,
744                                                 CONNMAN_TECHNOLOGY_INTERFACE,
745                                                 "TetheringIdentifier",
746                                                 DBUS_TYPE_STRING,
747                                                 &technology->tethering_ident);
748                 }
749         } else if (g_str_equal(name, "TetheringPassphrase") == TRUE) {
750                 const char *str;
751
752                 dbus_message_iter_get_basic(&value, &str);
753
754                 if (technology->type != CONNMAN_SERVICE_TYPE_WIFI)
755                         return __connman_error_not_supported(msg);
756
757                 if (strlen(str) < 8 || strlen(str) > 63)
758                         return __connman_error_passphrase_required(msg);
759
760                 if (g_strcmp0(technology->tethering_passphrase, str) != 0) {
761                         g_free(technology->tethering_passphrase);
762                         technology->tethering_passphrase = g_strdup(str);
763                         technology_save(technology);
764
765                         connman_dbus_property_changed_basic(technology->path,
766                                         CONNMAN_TECHNOLOGY_INTERFACE,
767                                         "TetheringPassphrase",
768                                         DBUS_TYPE_STRING,
769                                         &technology->tethering_passphrase);
770                 }
771         } else if (g_str_equal(name, "Powered") == TRUE) {
772                 connman_bool_t enable;
773
774                 if (type != DBUS_TYPE_BOOLEAN)
775                         return __connman_error_invalid_arguments(msg);
776
777                 dbus_message_iter_get_basic(&value, &enable);
778
779                 return set_powered(technology, msg, enable);
780         } else
781                 return __connman_error_invalid_property(msg);
782
783         return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
784 }
785
786 static struct connman_technology *technology_find(enum connman_service_type type)
787 {
788         GSList *list;
789
790         DBG("type %d", type);
791
792         for (list = technology_list; list; list = list->next) {
793                 struct connman_technology *technology = list->data;
794
795                 if (technology->type == type)
796                         return technology;
797         }
798
799         return NULL;
800 }
801
802 static void reply_scan_pending(struct connman_technology *technology, int err)
803 {
804         DBusMessage *reply;
805
806         DBG("technology %p err %d", technology, err);
807
808         while (technology->scan_pending != NULL) {
809                 DBusMessage *msg = technology->scan_pending->data;
810
811                 DBG("reply to %s", dbus_message_get_sender(msg));
812
813                 if (err == 0)
814                         reply = g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
815                 else
816                         reply = __connman_error_failed(msg, -err);
817                 g_dbus_send_message(connection, reply);
818                 dbus_message_unref(msg);
819
820                 technology->scan_pending =
821                         g_slist_delete_link(technology->scan_pending,
822                                         technology->scan_pending);
823         }
824 }
825
826 void __connman_technology_scan_started(struct connman_device *device)
827 {
828         DBG("device %p", device);
829 }
830
831 void __connman_technology_scan_stopped(struct connman_device *device)
832 {
833         int count = 0;
834         struct connman_technology *technology;
835         enum connman_service_type type;
836         GSList *list;
837
838         type = __connman_device_get_service_type(device);
839         technology = technology_find(type);
840
841         DBG("technology %p device %p", technology, device);
842
843         if (technology == NULL)
844                 return;
845
846         for (list = technology->device_list; list != NULL; list = list->next) {
847                 struct connman_device *other_device = list->data;
848
849                 if (device == other_device)
850                         continue;
851
852                 if (__connman_device_get_service_type(other_device) != type)
853                         continue;
854
855                 if (connman_device_get_scanning(other_device) == TRUE)
856                         count += 1;
857         }
858
859         if (count == 0)
860                 reply_scan_pending(technology, 0);
861 }
862
863 void __connman_technology_notify_regdom_by_device(struct connman_device *device,
864                                                 int result, const char *alpha2)
865 {
866         struct connman_technology *technology;
867         enum connman_service_type type;
868
869         type = __connman_device_get_service_type(device);
870         technology = technology_find(type);
871
872         if (technology == NULL)
873                 return;
874
875         if (result < 0) {
876                 if (technology->driver != NULL &&
877                                 technology->driver->set_regdom != NULL) {
878                         technology->driver->set_regdom(technology, alpha2);
879                         return;
880                 }
881
882                 alpha2 = NULL;
883         }
884
885         connman_technology_regdom_notify(technology, alpha2);
886 }
887
888 static DBusMessage *scan(DBusConnection *conn, DBusMessage *msg, void *data)
889 {
890         struct connman_technology *technology = data;
891         int err;
892
893         DBG ("technology %p request from %s", technology,
894                         dbus_message_get_sender(msg));
895
896         dbus_message_ref(msg);
897         technology->scan_pending =
898                 g_slist_prepend(technology->scan_pending, msg);
899
900         err = __connman_device_request_scan(technology->type);
901         if (err < 0)
902                 reply_scan_pending(technology, err);
903
904         return NULL;
905 }
906
907 static const GDBusMethodTable technology_methods[] = {
908         { GDBUS_DEPRECATED_METHOD("GetProperties",
909                         NULL, GDBUS_ARGS({ "properties", "a{sv}" }),
910                         get_properties) },
911         { GDBUS_ASYNC_METHOD("SetProperty",
912                         GDBUS_ARGS({ "name", "s" }, { "value", "v" }),
913                         NULL, set_property) },
914         { GDBUS_ASYNC_METHOD("Scan", NULL, NULL, scan) },
915         { },
916 };
917
918 static const GDBusSignalTable technology_signals[] = {
919         { GDBUS_SIGNAL("PropertyChanged",
920                         GDBUS_ARGS({ "name", "s" }, { "value", "v" })) },
921         { },
922 };
923
924 static gboolean technology_dbus_register(struct connman_technology *technology)
925 {
926         if (technology->dbus_registered == TRUE ||
927                                 (technology->rfkill_driven &&
928                                  technology->hardblocked == TRUE))
929                 return TRUE;
930
931         if (g_dbus_register_interface(connection, technology->path,
932                                 CONNMAN_TECHNOLOGY_INTERFACE,
933                                 technology_methods, technology_signals,
934                                 NULL, technology, NULL) == FALSE) {
935                 connman_error("Failed to register %s", technology->path);
936                 return FALSE;
937         }
938
939         technology_added_signal(technology);
940         technology->dbus_registered = TRUE;
941
942         return TRUE;
943 }
944
945 static struct connman_technology *technology_get(enum connman_service_type type)
946 {
947         struct connman_technology *technology;
948         struct connman_technology_driver *driver = NULL;
949         const char *str;
950         GSList *list;
951         int err;
952
953         DBG("type %d", type);
954
955         str = __connman_service_type2string(type);
956         if (str == NULL)
957                 return NULL;
958
959         technology = technology_find(type);
960         if (technology != NULL) {
961                 __sync_fetch_and_add(&technology->refcount, 1);
962                 return technology;
963         }
964
965         /* First check if we have a driver for this technology type */
966         for (list = driver_list; list; list = list->next) {
967                 driver = list->data;
968
969                 if (driver->type == type)
970                         break;
971                 else
972                         driver = NULL;
973         }
974
975         if (driver == NULL) {
976                 DBG("No matching driver found for %s.",
977                                 __connman_service_type2string(type));
978                 return NULL;
979         }
980
981         technology = g_try_new0(struct connman_technology, 1);
982         if (technology == NULL)
983                 return NULL;
984
985         technology->refcount = 1;
986
987         technology->rfkill_driven = FALSE;
988         technology->softblocked = FALSE;
989
990         if (type == CONNMAN_SERVICE_TYPE_ETHERNET)
991                 technology->hardblocked = FALSE;
992         else
993                 technology->hardblocked = TRUE;
994
995         technology->type = type;
996         technology->path = g_strdup_printf("%s/technology/%s",
997                                                         CONNMAN_PATH, str);
998
999         technology->device_list = NULL;
1000
1001         technology->pending_reply = NULL;
1002
1003         technology_load(technology);
1004
1005         if (technology_dbus_register(technology) == FALSE) {
1006                 g_free(technology);
1007                 return NULL;
1008         }
1009
1010         technology_list = g_slist_prepend(technology_list, technology);
1011
1012         technology->driver = driver;
1013         err = driver->probe(technology);
1014         if (err != 0)
1015                 DBG("Driver probe failed for technology %p", technology);
1016
1017         DBG("technology %p", technology);
1018
1019         return technology;
1020 }
1021
1022 static void technology_dbus_unregister(struct connman_technology *technology)
1023 {
1024         if (technology->dbus_registered == FALSE)
1025                 return;
1026
1027         technology_removed_signal(technology);
1028         g_dbus_unregister_interface(connection, technology->path,
1029                 CONNMAN_TECHNOLOGY_INTERFACE);
1030
1031         technology->dbus_registered = FALSE;
1032 }
1033
1034 static void technology_put(struct connman_technology *technology)
1035 {
1036         DBG("technology %p", technology);
1037
1038         if (__sync_sub_and_fetch(&technology->refcount, 1) > 0)
1039                 return;
1040
1041         reply_scan_pending(technology, -EINTR);
1042
1043         if (technology->driver) {
1044                 technology->driver->remove(technology);
1045                 technology->driver = NULL;
1046         }
1047
1048         technology_list = g_slist_remove(technology_list, technology);
1049
1050         technology_dbus_unregister(technology);
1051
1052         g_slist_free(technology->device_list);
1053
1054         g_free(technology->path);
1055         g_free(technology->regdom);
1056         g_free(technology->tethering_ident);
1057         g_free(technology->tethering_passphrase);
1058         g_free(technology);
1059 }
1060
1061 void __connman_technology_add_interface(enum connman_service_type type,
1062                                 int index, const char *name, const char *ident)
1063 {
1064         struct connman_technology *technology;
1065
1066         switch (type) {
1067         case CONNMAN_SERVICE_TYPE_UNKNOWN:
1068         case CONNMAN_SERVICE_TYPE_SYSTEM:
1069                 return;
1070         case CONNMAN_SERVICE_TYPE_ETHERNET:
1071         case CONNMAN_SERVICE_TYPE_WIFI:
1072         case CONNMAN_SERVICE_TYPE_WIMAX:
1073         case CONNMAN_SERVICE_TYPE_BLUETOOTH:
1074         case CONNMAN_SERVICE_TYPE_CELLULAR:
1075         case CONNMAN_SERVICE_TYPE_GPS:
1076         case CONNMAN_SERVICE_TYPE_VPN:
1077         case CONNMAN_SERVICE_TYPE_GADGET:
1078                 break;
1079         }
1080
1081         connman_info("Adding interface %s [ %s ]", name,
1082                                 __connman_service_type2string(type));
1083
1084         technology = technology_find(type);
1085
1086         if (technology == NULL || technology->driver == NULL
1087                         || technology->driver->add_interface == NULL)
1088                 return;
1089
1090         technology->driver->add_interface(technology,
1091                                         index, name, ident);
1092 }
1093
1094 void __connman_technology_remove_interface(enum connman_service_type type,
1095                                 int index, const char *name, const char *ident)
1096 {
1097         struct connman_technology *technology;
1098
1099         switch (type) {
1100         case CONNMAN_SERVICE_TYPE_UNKNOWN:
1101         case CONNMAN_SERVICE_TYPE_SYSTEM:
1102                 return;
1103         case CONNMAN_SERVICE_TYPE_ETHERNET:
1104         case CONNMAN_SERVICE_TYPE_WIFI:
1105         case CONNMAN_SERVICE_TYPE_WIMAX:
1106         case CONNMAN_SERVICE_TYPE_BLUETOOTH:
1107         case CONNMAN_SERVICE_TYPE_CELLULAR:
1108         case CONNMAN_SERVICE_TYPE_GPS:
1109         case CONNMAN_SERVICE_TYPE_VPN:
1110         case CONNMAN_SERVICE_TYPE_GADGET:
1111                 break;
1112         }
1113
1114         connman_info("Remove interface %s [ %s ]", name,
1115                                 __connman_service_type2string(type));
1116
1117         technology = technology_find(type);
1118
1119         if (technology == NULL || technology->driver == NULL)
1120                 return;
1121
1122         if (technology->driver->remove_interface)
1123                 technology->driver->remove_interface(technology, index);
1124 }
1125
1126 int __connman_technology_add_device(struct connman_device *device)
1127 {
1128         struct connman_technology *technology;
1129         enum connman_service_type type;
1130
1131         DBG("device %p", device);
1132
1133         type = __connman_device_get_service_type(device);
1134
1135         technology = technology_get(type);
1136         if (technology == NULL) {
1137                 /*
1138                  * Since no driver can be found for this device at the moment we
1139                  * add it to the techless device list.
1140                 */
1141                 techless_device_list = g_slist_prepend(techless_device_list,
1142                                                                 device);
1143
1144                 return -ENXIO;
1145         }
1146
1147         if (technology->enable_persistent &&
1148                                         global_offlinemode == FALSE &&
1149                                         technology->hardblocked == FALSE) {
1150                 int err = __connman_device_enable(device);
1151                 /*
1152                  * connman_technology_add_device() calls __connman_device_enable()
1153                  * but since the device is already enabled, the calls does not
1154                  * propagate through to connman_technology_enabled via
1155                  * connman_device_set_powered.
1156                  */
1157                 if (err == -EALREADY)
1158                         __connman_technology_enabled(type);
1159         }
1160         /* if technology persistent state is offline or hardblocked */
1161         if (technology->enable_persistent == FALSE ||
1162                                         technology->hardblocked == TRUE)
1163                 __connman_device_disable(device);
1164
1165         technology->device_list = g_slist_prepend(technology->device_list,
1166                                                                 device);
1167
1168         return 0;
1169 }
1170
1171 int __connman_technology_remove_device(struct connman_device *device)
1172 {
1173         struct connman_technology *technology;
1174         enum connman_service_type type;
1175
1176         DBG("device %p", device);
1177
1178         type = __connman_device_get_service_type(device);
1179
1180         technology = technology_find(type);
1181         if (technology == NULL) {
1182                 techless_device_list = g_slist_remove(techless_device_list,
1183                                                                 device);
1184                 return -ENXIO;
1185         }
1186
1187         technology->device_list = g_slist_remove(technology->device_list,
1188                                                                 device);
1189         technology_put(technology);
1190
1191         return 0;
1192 }
1193
1194 static void powered_changed(struct connman_technology *technology)
1195 {
1196         if (technology->pending_reply != NULL) {
1197                 g_dbus_send_reply(connection,
1198                                 technology->pending_reply, DBUS_TYPE_INVALID);
1199                 dbus_message_unref(technology->pending_reply);
1200                 technology->pending_reply = NULL;
1201
1202                 g_source_remove(technology->pending_timeout);
1203                 technology->pending_timeout = 0;
1204         }
1205
1206         __sync_synchronize();
1207         connman_dbus_property_changed_basic(technology->path,
1208                         CONNMAN_TECHNOLOGY_INTERFACE, "Powered",
1209                         DBUS_TYPE_BOOLEAN, &technology->enabled);
1210 }
1211
1212 static int technology_enabled(struct connman_technology *technology)
1213 {
1214         __sync_synchronize();
1215         if (technology->enabled == TRUE)
1216                 return -EALREADY;
1217
1218         technology->enabled = TRUE;
1219
1220         powered_changed(technology);
1221
1222         return 0;
1223 }
1224
1225 int __connman_technology_enabled(enum connman_service_type type)
1226 {
1227         struct connman_technology *technology;
1228
1229         technology = technology_find(type);
1230         if (technology == NULL)
1231                 return -ENXIO;
1232
1233         return technology_enabled(technology);
1234 }
1235
1236 static int technology_disabled(struct connman_technology *technology)
1237 {
1238         __sync_synchronize();
1239         if (technology->enabled == FALSE)
1240                 return -EALREADY;
1241
1242         technology->enabled = FALSE;
1243
1244         powered_changed(technology);
1245
1246         return 0;
1247 }
1248
1249 int __connman_technology_disabled(enum connman_service_type type)
1250 {
1251         struct connman_technology *technology;
1252
1253         technology = technology_find(type);
1254         if (technology == NULL)
1255                 return -ENXIO;
1256
1257         return technology_disabled(technology);
1258 }
1259
1260 int __connman_technology_set_offlinemode(connman_bool_t offlinemode)
1261 {
1262         GSList *list;
1263         int err = -EINVAL;
1264
1265         if (global_offlinemode == offlinemode)
1266                 return 0;
1267
1268         DBG("offlinemode %s", offlinemode ? "On" : "Off");
1269
1270         /*
1271          * This is a bit tricky. When you set offlinemode, there is no
1272          * way to differentiate between attempting offline mode and
1273          * resuming offlinemode from last saved profile. We need that
1274          * information in rfkill_update, otherwise it falls back on the
1275          * technology's persistent state. Hence we set the offline mode here
1276          * but save it & call the notifier only if its successful.
1277          */
1278
1279         global_offlinemode = offlinemode;
1280
1281         /* Traverse technology list, enable/disable each technology. */
1282         for (list = technology_list; list; list = list->next) {
1283                 struct connman_technology *technology = list->data;
1284
1285                 if (offlinemode)
1286                         err = technology_disable(technology, FALSE);
1287
1288                 if (!offlinemode && technology->enable_persistent)
1289                         err = technology_enable(technology, FALSE);
1290         }
1291
1292         if (err == 0 || err == -EINPROGRESS || err == -EALREADY) {
1293                 connman_technology_save_offlinemode();
1294                 __connman_notifier_offlinemode(offlinemode);
1295         } else
1296                 global_offlinemode = connman_technology_load_offlinemode();
1297
1298         return err;
1299 }
1300
1301 void __connman_technology_set_connected(enum connman_service_type type,
1302                 connman_bool_t connected)
1303 {
1304         struct connman_technology *technology;
1305
1306         technology = technology_find(type);
1307         if (technology == NULL)
1308                 return;
1309
1310         DBG("technology %p connected %d", technology, connected);
1311
1312         technology->connected = connected;
1313
1314         connman_dbus_property_changed_basic(technology->path,
1315                         CONNMAN_TECHNOLOGY_INTERFACE, "Connected",
1316                         DBUS_TYPE_BOOLEAN, &connected);
1317 }
1318
1319 static connman_bool_t technology_apply_rfkill_change(struct connman_technology *technology,
1320                                                 connman_bool_t softblock,
1321                                                 connman_bool_t hardblock)
1322 {
1323         gboolean apply = TRUE;
1324         GList *start, *list;
1325
1326         if (technology->hardblocked == hardblock)
1327                 goto softblock_change;
1328
1329         start = g_hash_table_get_values(rfkill_list);
1330         for (list = start; list != NULL; list = list->next) {
1331                 struct connman_rfkill *rfkill = list->data;
1332
1333                 if (rfkill->type != technology->type)
1334                         continue;
1335
1336                 if (rfkill->hardblock != hardblock)
1337                         apply = FALSE;
1338         }
1339
1340         g_list_free(start);
1341
1342         if (apply == FALSE)
1343                 goto softblock_change;
1344
1345         technology->hardblocked = hardblock;
1346
1347         if (hardblock == TRUE) {
1348                 DBG("%s is switched off.", get_name(technology->type));
1349                 technology_disable(technology, TRUE);
1350                 technology_dbus_unregister(technology);
1351         } else {
1352                 technology_enable(technology, TRUE);
1353                 technology_dbus_register(technology);
1354         }
1355
1356 softblock_change:
1357         technology->softblocked = softblock;
1358
1359         return technology->hardblocked;
1360 }
1361
1362 int __connman_technology_add_rfkill(unsigned int index,
1363                                         enum connman_service_type type,
1364                                                 connman_bool_t softblock,
1365                                                 connman_bool_t hardblock)
1366 {
1367         struct connman_technology *technology;
1368         struct connman_rfkill *rfkill;
1369
1370         DBG("index %u type %d soft %u hard %u", index, type,
1371                                                         softblock, hardblock);
1372
1373         rfkill = g_hash_table_lookup(rfkill_list, GINT_TO_POINTER(index));
1374         if (rfkill != NULL)
1375                 goto done;
1376
1377         rfkill = g_try_new0(struct connman_rfkill, 1);
1378         if (rfkill == NULL)
1379                 return -ENOMEM;
1380
1381         rfkill->index = index;
1382         rfkill->type = type;
1383         rfkill->softblock = softblock;
1384         rfkill->hardblock = hardblock;
1385
1386         g_hash_table_insert(rfkill_list, GINT_TO_POINTER(index), rfkill);
1387
1388 done:
1389         technology = technology_get(type);
1390         /* If there is no driver for this type, ignore it. */
1391         if (technology == NULL)
1392                 return -ENXIO;
1393
1394         technology->rfkill_driven = TRUE;
1395
1396         /* If hardblocked, there is no need to handle softblocked state */
1397         if (technology_apply_rfkill_change(technology,
1398                                         softblock, hardblock) == TRUE)
1399                 return 0;
1400
1401         /*
1402          * Depending on softblocked state we unblock/block according to
1403          * offlinemode and persistente state.
1404          */
1405         if (technology->softblocked == TRUE &&
1406                                 global_offlinemode == FALSE &&
1407                                 technology->enable_persistent == TRUE)
1408                 return __connman_rfkill_block(type, FALSE);
1409         else if (technology->softblocked == FALSE &&
1410                                 global_offlinemode == TRUE &&
1411                                 technology->enable_persistent == FALSE)
1412                 return __connman_rfkill_block(type, TRUE);
1413
1414         return 0;
1415 }
1416
1417 int __connman_technology_update_rfkill(unsigned int index,
1418                                         enum connman_service_type type,
1419                                                 connman_bool_t softblock,
1420                                                 connman_bool_t hardblock)
1421 {
1422         struct connman_technology *technology;
1423         struct connman_rfkill *rfkill;
1424
1425         DBG("index %u soft %u hard %u", index, softblock, hardblock);
1426
1427         rfkill = g_hash_table_lookup(rfkill_list, GINT_TO_POINTER(index));
1428         if (rfkill == NULL)
1429                 return -ENXIO;
1430
1431         if (rfkill->softblock == softblock &&
1432                                 rfkill->hardblock == hardblock)
1433                 return 0;
1434
1435         rfkill->softblock = softblock;
1436         rfkill->hardblock = hardblock;
1437
1438         technology = technology_find(type);
1439         /* If there is no driver for this type, ignore it. */
1440         if (technology == NULL)
1441                 return -ENXIO;
1442
1443         /* If hardblocked, there is no need to handle softblocked state */
1444         if (technology_apply_rfkill_change(technology,
1445                                         softblock, hardblock) == TRUE)
1446                 return 0;
1447
1448         if (global_offlinemode == TRUE)
1449                 return 0;
1450
1451         /*
1452          * Depending on softblocked state we unblock/block according to
1453          * persistent state.
1454          */
1455         if (technology->softblocked == TRUE &&
1456                                 technology->enable_persistent == TRUE)
1457                 return __connman_rfkill_block(type, FALSE);
1458         else if (technology->softblocked == FALSE &&
1459                                 technology->enable_persistent == FALSE)
1460                 return __connman_rfkill_block(type, TRUE);
1461
1462         return 0;
1463 }
1464
1465 int __connman_technology_remove_rfkill(unsigned int index,
1466                                         enum connman_service_type type)
1467 {
1468         struct connman_technology *technology;
1469         struct connman_rfkill *rfkill;
1470
1471         DBG("index %u", index);
1472
1473         rfkill = g_hash_table_lookup(rfkill_list, GINT_TO_POINTER(index));
1474         if (rfkill == NULL)
1475                 return -ENXIO;
1476
1477         g_hash_table_remove(rfkill_list, GINT_TO_POINTER(index));
1478
1479         technology = technology_find(type);
1480         if (technology == NULL)
1481                 return -ENXIO;
1482
1483         technology_put(technology);
1484
1485         return 0;
1486 }
1487
1488 int __connman_technology_init(void)
1489 {
1490         DBG("");
1491
1492         connection = connman_dbus_get_connection();
1493
1494         rfkill_list = g_hash_table_new_full(g_direct_hash, g_direct_equal,
1495                                                         NULL, free_rfkill);
1496
1497         global_offlinemode = connman_technology_load_offlinemode();
1498
1499         /* This will create settings file if it is missing */
1500         connman_technology_save_offlinemode();
1501
1502         return 0;
1503 }
1504
1505 void __connman_technology_cleanup(void)
1506 {
1507         DBG("");
1508
1509         g_hash_table_destroy(rfkill_list);
1510
1511         dbus_connection_unref(connection);
1512 }