plugins/ofono.c

   1 /*
   2  *
   3  *  Connection Manager
   4  *
   5  *  Copyright (C) 2007-2010  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
  28 #include <gdbus.h>
  29 #include <string.h>
  30
  31 #define CONNMAN_API_SUBJECT_TO_CHANGE
  32 #include <connman/plugin.h>
  33 #include <connman/element.h>
  34 #include <connman/device.h>
  35 #include <connman/network.h>
  36 #include <connman/dbus.h>
  37 #include <connman/inet.h>
  38 #include <connman/log.h>
  39
  40 #define OFONO_SERVICE                   "org.ofono"
  41
  42 #define OFONO_MANAGER_INTERFACE         OFONO_SERVICE ".Manager"
  43 #define OFONO_MODEM_INTERFACE           OFONO_SERVICE ".Modem"
  44 #define OFONO_GPRS_INTERFACE            OFONO_SERVICE ".DataConnectionManager"
  45 #define OFONO_SIM_INTERFACE             OFONO_SERVICE ".SimManager"
  46 #define OFONO_PRI_CONTEXT_INTERFACE     OFONO_SERVICE ".PrimaryDataContext"
  47 #define OFONO_REGISTRATION_INTERFACE    OFONO_SERVICE ".NetworkRegistration"
  48
  49 #define PROPERTY_CHANGED                "PropertyChanged"
  50 #define GET_PROPERTIES                  "GetProperties"
  51 #define SET_PROPERTY                    "SetProperty"
  52 #define CREATE_CONTEXT                  "CreateContext"
  53
  54 #define TIMEOUT 5000
  55
  56 #define CONTEXT_NAME "3G Connection"
  57 #define CONTEXT_TYPE "internet"
  58
  59 static DBusConnection *connection;
  60
  61 static GHashTable *modem_hash = NULL;
  62
  63 struct modem_data {
  64         char *path;
  65         struct connman_device *device;
  66         gboolean available;
  67 };
  68
  69 static int modem_probe(struct connman_device *device)
  70 {
  71         DBG("device %p", device);
  72
  73         return 0;
  74 }
  75
  76 static void modem_remove(struct connman_device *device)
  77 {
  78         DBG("device %p", device);
  79 }
  80
  81 static void powered_reply(DBusPendingCall *call, void *user_data)
  82 {
  83         DBusMessage *reply;
  84         DBusError error;
  85
  86         DBG("");
  87
  88         dbus_error_init(&error);
  89
  90         reply = dbus_pending_call_steal_reply(call);
  91
  92         if (dbus_set_error_from_message(&error, reply)) {
  93                 connman_error("%s", error.message);
  94                 dbus_error_free(&error);
  95         }
  96
  97         dbus_message_unref(reply);
  98
  99         dbus_pending_call_unref(call);
 100 }
 101
 102 static int gprs_change_powered(const char *path, dbus_bool_t powered)
 103 {
 104         DBusMessage *message;
 105         DBusMessageIter iter;
 106         DBusPendingCall *call;
 107
 108         DBG("path %s powered %d", path, powered);
 109
 110         if (path == NULL)
 111                 return -EINVAL;
 112
 113         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 114                                         OFONO_GPRS_INTERFACE, SET_PROPERTY);
 115         if (message == NULL)
 116                 return -ENOMEM;
 117
 118         dbus_message_set_auto_start(message, FALSE);
 119
 120         dbus_message_iter_init_append(message, &iter);
 121         connman_dbus_property_append_basic(&iter, "Powered",
 122                                                 DBUS_TYPE_BOOLEAN, &powered);
 123
 124         if (dbus_connection_send_with_reply(connection, message,
 125                                                 &call, TIMEOUT) == FALSE) {
 126                 connman_error("Failed to change powered property");
 127                 dbus_message_unref(message);
 128                 return -EINVAL;
 129         }
 130
 131         if (call == NULL) {
 132                 connman_error("D-Bus connection not available");
 133                 dbus_message_unref(message);
 134                 return -EINVAL;
 135         }
 136
 137         dbus_pending_call_set_notify(call, powered_reply, (void *)path, NULL);
 138
 139         dbus_message_unref(message);
 140
 141         return -EINPROGRESS;
 142 }
 143
 144 static int modem_enable(struct connman_device *device)
 145 {
 146         const char *path = connman_device_get_string(device, "Path");
 147
 148         DBG("device %p, path, %s", device, path);
 149
 150         return gprs_change_powered(path, TRUE);
 151 }
 152
 153 static int modem_disable(struct connman_device *device)
 154 {
 155         const char *path = connman_device_get_string(device, "Path");
 156
 157         DBG("device %p, path %s", device, path);
 158
 159         return gprs_change_powered(path, FALSE);
 160 }
 161
 162 static struct connman_device_driver modem_driver = {
 163         .name           = "modem",
 164         .type           = CONNMAN_DEVICE_TYPE_CELLULAR,
 165         .probe          = modem_probe,
 166         .remove         = modem_remove,
 167         .enable         = modem_enable,
 168         .disable        = modem_disable,
 169 };
 170
 171 static char *get_ident(const char *path)
 172 {
 173         char *ident, *pos;
 174
 175         if (*path != '/')
 176                 return NULL;
 177
 178         ident = g_strdup(path + 1);
 179
 180         pos = ident;
 181
 182         while ((pos = strchr(pos, '/')) != NULL)
 183                 *pos = '_';
 184
 185         return ident;
 186 }
 187
 188 static void create_service(struct connman_network *network)
 189 {
 190         const char *path;
 191         char *group;
 192
 193         DBG("");
 194
 195         path = connman_network_get_string(network, "Path");
 196
 197         group = get_ident(path);
 198
 199         connman_network_set_group(network, group);
 200
 201         g_free(group);
 202 }
 203
 204 static void set_network_name_reply(DBusPendingCall *call, void *user_data)
 205 {
 206         struct connman_network *network = user_data;
 207         DBusMessage *reply;
 208         DBusMessageIter array, dict;
 209
 210         DBG("network %p", network);
 211
 212         reply = dbus_pending_call_steal_reply(call);
 213
 214         if (dbus_message_iter_init(reply, &array) == FALSE)
 215                 goto done;
 216
 217         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
 218                 goto done;
 219
 220         dbus_message_iter_recurse(&array, &dict);
 221
 222         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
 223                 DBusMessageIter entry, value;
 224                 const char *key;
 225
 226                 dbus_message_iter_recurse(&dict, &entry);
 227                 dbus_message_iter_get_basic(&entry, &key);
 228
 229                 dbus_message_iter_next(&entry);
 230                 dbus_message_iter_recurse(&entry, &value);
 231
 232                 if (g_str_equal(key, "Operator") == TRUE) {
 233                         const char *name;
 234
 235                         dbus_message_iter_get_basic(&value, &name);
 236                         connman_network_set_name(network, name);
 237                         create_service(network);
 238                 }
 239
 240                 dbus_message_iter_next(&dict);
 241         }
 242 done:
 243         dbus_message_unref(reply);
 244
 245         dbus_pending_call_unref(call);
 246 }
 247
 248 static void set_network_name(struct connman_network *network)
 249 {
 250         struct connman_device *device;
 251         DBusMessage *message;
 252         DBusPendingCall *call;
 253         const char *path;
 254
 255         device = connman_network_get_device(network);
 256
 257         path = connman_device_get_string(device, "Path");
 258         if (path == NULL)
 259                 return;
 260
 261         DBG("path %s", path);
 262
 263         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 264                                 OFONO_REGISTRATION_INTERFACE, GET_PROPERTIES);
 265         if (message == NULL)
 266                 return;
 267
 268         dbus_message_set_auto_start(message, FALSE);
 269
 270         if (dbus_connection_send_with_reply(connection, message,
 271                                                 &call, TIMEOUT) == FALSE) {
 272                 connman_error("Failed to get operator");
 273                 goto done;
 274         }
 275
 276         if (call == NULL) {
 277                 connman_error("D-Bus connection not available");
 278                 goto done;
 279         }
 280
 281         dbus_pending_call_set_notify(call, set_network_name_reply,
 282                                                 (void *)network, NULL);
 283
 284 done:
 285         dbus_message_unref(message);
 286 }
 287
 288 static void config_network_reply(DBusPendingCall *call, void *user_data)
 289 {
 290         struct connman_network *network = user_data;
 291         DBusMessage *reply;
 292         DBusMessageIter array, dict;
 293         gboolean internet_type = FALSE;
 294
 295         DBG("network %p", network);
 296
 297         reply = dbus_pending_call_steal_reply(call);
 298
 299         if (dbus_message_iter_init(reply, &array) == FALSE)
 300                 goto done;
 301
 302         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
 303                 goto done;
 304
 305         dbus_message_iter_recurse(&array, &dict);
 306
 307         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
 308                 DBusMessageIter entry, value;
 309                 const char *key;
 310
 311                 dbus_message_iter_recurse(&dict, &entry);
 312                 dbus_message_iter_get_basic(&entry, &key);
 313
 314                 dbus_message_iter_next(&entry);
 315                 dbus_message_iter_recurse(&entry, &value);
 316
 317                 if (g_str_equal(key, "Type") == TRUE) {
 318                         const char *type;
 319
 320                         dbus_message_iter_get_basic(&value, &type);
 321                         if (g_strcmp0(type, "internet") == 0) {
 322                                 internet_type = TRUE;
 323
 324                                 connman_network_set_protocol(network,
 325                                                 CONNMAN_NETWORK_PROTOCOL_IP);
 326                                 set_network_name(network);
 327                         } else {
 328                                 internet_type = FALSE;
 329
 330                                 connman_network_set_protocol(network,
 331                                         CONNMAN_NETWORK_PROTOCOL_UNKNOWN);
 332                         }
 333                 }
 334
 335                 dbus_message_iter_next(&dict);
 336         }
 337
 338 done:
 339         dbus_message_unref(reply);
 340
 341         dbus_pending_call_unref(call);
 342 }
 343
 344 static void config_network(struct connman_network *network, const char *path)
 345 {
 346         DBusMessage *message;
 347         DBusPendingCall *call;
 348
 349         DBG("path %s", path);
 350
 351         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 352                                 OFONO_PRI_CONTEXT_INTERFACE, GET_PROPERTIES);
 353         if (message == NULL)
 354                 return;
 355
 356         dbus_message_set_auto_start(message, FALSE);
 357
 358         if (dbus_connection_send_with_reply(connection, message,
 359                                                 &call, TIMEOUT) == FALSE) {
 360                 connman_error("Failed to get Primary Context");
 361                 goto done;
 362         }
 363
 364         if (call == NULL) {
 365                 connman_error("D-Bus connection not available");
 366                 goto done;
 367         }
 368
 369         dbus_pending_call_set_notify(call, config_network_reply,
 370                                                 (void *)network, NULL);
 371
 372 done:
 373         dbus_message_unref(message);
 374 }
 375
 376 static int network_probe(struct connman_network *network)
 377 {
 378         const char *path;
 379
 380         path = connman_network_get_string(network, "Path");
 381
 382         DBG("network %p path %s", network, path);
 383
 384         config_network(network, path);
 385
 386         return 0;
 387 }
 388
 389 static struct connman_network *pending_network;
 390
 391 static gboolean pending_network_is_available(
 392                 struct connman_network *pending_network)
 393 {
 394         struct connman_device *device;
 395         struct connman_network *network;
 396         const char *identifier;
 397         char *ident;
 398
 399         /* Modem may be removed during waiting for active reply */
 400         device  = connman_network_get_device(pending_network);
 401         if (device == NULL)
 402                 return FALSE;
 403
 404         identifier = connman_network_get_identifier(pending_network);
 405
 406         ident = g_strdup(identifier);
 407
 408         connman_network_unref(pending_network);
 409
 410         /* network may be removed during waiting for active reply */
 411         network = connman_device_get_network(device, ident);
 412
 413         g_free(ident);
 414
 415         if (network == NULL)
 416                 return FALSE;
 417
 418         return TRUE;
 419 }
 420
 421 static void set_active_reply(DBusPendingCall *call, void *user_data)
 422 {
 423         DBusMessage *reply;
 424         DBusError error;
 425         struct connman_network *network = user_data;
 426
 427         DBG("network %p", network);
 428
 429         reply = dbus_pending_call_steal_reply(call);
 430
 431         if (pending_network_is_available(network) == FALSE)
 432                 goto done;
 433
 434         dbus_error_init(&error);
 435         if (dbus_set_error_from_message(&error, reply)) {
 436                 if (connman_network_get_index(network) < 0)
 437                         connman_network_set_error(network,
 438                                 CONNMAN_NETWORK_ERROR_ASSOCIATE_FAIL);
 439
 440                 pending_network = NULL;
 441
 442                 connman_error("%s", error.message);
 443
 444                 dbus_error_free(&error);
 445         } else
 446                 pending_network = network;
 447
 448 done:
 449         dbus_message_unref(reply);
 450
 451         dbus_pending_call_unref(call);
 452 }
 453
 454 static int set_network_active(struct connman_network *network,
 455                                                 dbus_bool_t active)
 456 {
 457         DBusMessage *message;
 458         DBusPendingCall *call;
 459         DBusMessageIter iter;
 460
 461         const char *path = connman_network_get_string(network, "Path");
 462
 463         DBG("network %p, path %s, active %d", network, path, active);
 464
 465         if (path == NULL)
 466                 return -EINVAL;
 467
 468         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 469                                 OFONO_PRI_CONTEXT_INTERFACE, SET_PROPERTY);
 470         if (message == NULL)
 471                 return -ENOMEM;
 472
 473         dbus_message_set_auto_start(message, FALSE);
 474
 475         dbus_message_iter_init_append(message, &iter);
 476         connman_dbus_property_append_basic(&iter, "Active",
 477                                                 DBUS_TYPE_BOOLEAN, &active);
 478
 479         if (dbus_connection_send_with_reply(connection, message,
 480                                         &call, TIMEOUT * 10) == FALSE) {
 481                 connman_error("Failed to connect service");
 482                 dbus_message_unref(message);
 483                 return -EINVAL;
 484         }
 485
 486         if (call == NULL) {
 487                 connman_error("D-Bus connection not available");
 488                 dbus_message_unref(message);
 489                 return -EINVAL;
 490         }
 491
 492         connman_network_ref(network);
 493
 494         dbus_pending_call_set_notify(call, set_active_reply, network, NULL);
 495
 496         dbus_message_unref(message);
 497
 498         if (active == TRUE)
 499                 return -EINPROGRESS;
 500
 501         return 0;
 502 }
 503
 504 static void set_apn_reply(DBusPendingCall *call, void *user_data)
 505 {
 506         DBusMessage *reply;
 507         DBusError error;
 508
 509         reply = dbus_pending_call_steal_reply(call);
 510
 511         dbus_error_init(&error);
 512         if (dbus_set_error_from_message(&error, reply)) {
 513                 connman_error("%s", error.message);
 514
 515                 dbus_error_free(&error);
 516         }
 517
 518         dbus_message_unref(reply);
 519
 520         dbus_pending_call_unref(call);
 521 }
 522
 523 static void set_apn(struct connman_network *network)
 524 {
 525         DBusMessage *message;
 526         DBusPendingCall *call;
 527         DBusMessageIter iter;
 528         const char *apn, *path;
 529
 530         apn = connman_network_get_string(network, "Cellular.APN");
 531         if (apn == NULL)
 532                 return;
 533
 534         path = connman_network_get_string(network, "Path");
 535         if (path == NULL)
 536                 return;
 537
 538         DBG("path %s, apn %s", path, apn);
 539
 540         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 541                                 OFONO_PRI_CONTEXT_INTERFACE, SET_PROPERTY);
 542         if (message == NULL)
 543                 return;
 544
 545         dbus_message_set_auto_start(message, FALSE);
 546
 547         dbus_message_iter_init_append(message, &iter);
 548         connman_dbus_property_append_basic(&iter, "AccessPointName",
 549                                                 DBUS_TYPE_STRING, &apn);
 550
 551         if (dbus_connection_send_with_reply(connection, message,
 552                                         &call, TIMEOUT) == FALSE) {
 553                 dbus_message_unref(message);
 554                 return;
 555         }
 556
 557         if (call == NULL) {
 558                 connman_error("D-Bus connection not available");
 559                 dbus_message_unref(message);
 560                 return;
 561         }
 562
 563         dbus_pending_call_set_notify(call, set_apn_reply, NULL, NULL);
 564
 565         dbus_message_unref(message);
 566 }
 567
 568 static int network_connect(struct connman_network *network)
 569 {
 570         if (connman_network_get_index(network) >= 0)
 571                 return -EISCONN;
 572
 573         return set_network_active(network, TRUE);
 574 }
 575
 576 static int network_disconnect(struct connman_network *network)
 577 {
 578         if (connman_network_get_index(network) < 0)
 579                 return -ENOTCONN;
 580
 581         return set_network_active(network, FALSE);
 582 }
 583
 584 static void network_remove(struct connman_network *network)
 585 {
 586         DBG("network %p", network);
 587 }
 588
 589 static int network_setup(struct connman_network *network, const char *key)
 590 {
 591         DBG("");
 592
 593         if (g_strcmp0(key, "Cellular.APN") == 0)
 594                 set_apn(network);
 595
 596         return 0;
 597 }
 598
 599 static struct connman_network_driver network_driver = {
 600         .name           = "network",
 601         .type           = CONNMAN_NETWORK_TYPE_CELLULAR,
 602         .probe          = network_probe,
 603         .remove         = network_remove,
 604         .connect        = network_connect,
 605         .disconnect     = network_disconnect,
 606         .setup          = network_setup,
 607 };
 608
 609 static void add_network(struct connman_device *device, const char *path)
 610 {
 611         struct connman_network *network;
 612         char *ident, *mcc, *mnc;
 613         const char *mcc_mnc;
 614
 615         DBG("device %p path %s", device, path);
 616
 617         network = connman_device_get_network(device, path);
 618         if (network != NULL)
 619                 return;
 620
 621         ident = get_ident(path);
 622
 623         network = connman_network_create(ident,
 624                                         CONNMAN_NETWORK_TYPE_CELLULAR);
 625         if (network == NULL)
 626                 return;
 627
 628         g_free(ident);
 629
 630         connman_network_set_string(network, "Path", path);
 631         connman_network_set_available(network, TRUE);
 632         connman_network_set_index(network, -1);
 633
 634         mcc_mnc = connman_device_get_string(device, "MCC_MNC");
 635         if (mcc_mnc != NULL) {
 636                 mcc = g_strndup(mcc_mnc, 3);
 637                 connman_network_set_string(network, "Cellular.MCC", mcc);
 638                 g_free(mcc);
 639
 640                 mnc = g_strdup(mcc_mnc + 3);
 641                 connman_network_set_string(network, "Cellular.MNC", mnc);
 642                 g_free(mnc);
 643         }
 644
 645         connman_device_add_network(device, network);
 646 }
 647
 648 static void add_networks(struct connman_device *device, DBusMessageIter *array)
 649 {
 650         DBusMessageIter entry;
 651
 652         DBG("");
 653
 654         dbus_message_iter_recurse(array, &entry);
 655
 656         while (dbus_message_iter_get_arg_type(&entry) ==
 657                                         DBUS_TYPE_OBJECT_PATH) {
 658                 const char *path;
 659
 660                 dbus_message_iter_get_basic(&entry, &path);
 661
 662                 add_network(device, path);
 663
 664                 dbus_message_iter_next(&entry);
 665         }
 666 }
 667
 668 static void create_context_reply(DBusPendingCall *call, void *user_data)
 669 {
 670         DBusMessage *reply;
 671         DBusError error;
 672
 673         DBG("");
 674
 675         dbus_error_init(&error);
 676
 677         reply = dbus_pending_call_steal_reply(call);
 678
 679         if (dbus_set_error_from_message(&error, reply)) {
 680                 connman_error("%s", error.message);
 681                 dbus_error_free(&error);
 682         }
 683
 684         dbus_message_unref(reply);
 685
 686         dbus_pending_call_unref(call);
 687 }
 688
 689 static void add_default_context(DBusMessageIter *array,
 690                 const char *path, const char *name, const char *type)
 691 {
 692         DBusMessageIter entry;
 693         DBusMessage *message;
 694         DBusPendingCall *call;
 695
 696         if (path == NULL)
 697                 return;
 698
 699         DBG("");
 700
 701         dbus_message_iter_recurse(array, &entry);
 702
 703         if (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_OBJECT_PATH)
 704                 return;
 705
 706         DBG("path %s, name %s, type %s", path, name, type);
 707
 708         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 709                                         OFONO_GPRS_INTERFACE, CREATE_CONTEXT);
 710         if (message == NULL)
 711                 return;
 712
 713         dbus_message_set_auto_start(message, FALSE);
 714
 715         dbus_message_append_args(message, DBUS_TYPE_STRING,
 716                                         &name, DBUS_TYPE_STRING,
 717                                                 &type, DBUS_TYPE_INVALID);
 718
 719         if (dbus_connection_send_with_reply(connection, message,
 720                                                 &call, TIMEOUT) == FALSE) {
 721                 connman_error("Failed to create default context");
 722                 dbus_message_unref(message);
 723                 return;
 724         }
 725
 726         if (call == NULL) {
 727                 connman_error("D-Bus connection not available");
 728                 dbus_message_unref(message);
 729                 return;
 730         }
 731
 732         dbus_pending_call_set_notify(call, create_context_reply, NULL, NULL);
 733
 734         dbus_message_unref(message);
 735 }
 736
 737 static void check_networks_reply(DBusPendingCall *call, void *user_data)
 738 {
 739         struct connman_device *device = user_data;
 740         DBusMessage *reply;
 741         DBusMessageIter array, dict, contexts;
 742         dbus_bool_t attached;
 743
 744         DBG("device %p", device);
 745
 746         reply = dbus_pending_call_steal_reply(call);
 747
 748         if (dbus_message_iter_init(reply, &array) == FALSE)
 749                 goto done;
 750
 751         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
 752                 goto done;
 753
 754         dbus_message_iter_recurse(&array, &dict);
 755
 756         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
 757                 DBusMessageIter entry, value;
 758                 const char *key;
 759
 760                 dbus_message_iter_recurse(&dict, &entry);
 761                 dbus_message_iter_get_basic(&entry, &key);
 762
 763                 dbus_message_iter_next(&entry);
 764                 dbus_message_iter_recurse(&entry, &value);
 765
 766                 DBG("key %s", key);
 767
 768                 if (g_str_equal(key, "Attached") == TRUE) {
 769                         dbus_message_iter_get_basic(&value, &attached);
 770                         DBG("Attached %d", attached);
 771                 } else if (g_str_equal(key, "PrimaryContexts") == TRUE) {
 772                         const char *path;
 773
 774                         path = connman_device_get_string(device, "Path");
 775                         contexts = value;
 776                         add_default_context(&contexts, path,
 777                                         CONTEXT_NAME, CONTEXT_TYPE);
 778                 } else if (g_str_equal(key, "Status") == TRUE) {
 779                         const char *status;
 780
 781                         dbus_message_iter_get_basic(&value, &status);
 782                         /* FIXME: add roaming support */
 783                 } else if (g_str_equal(key, "Powered") == TRUE) {
 784                         dbus_bool_t powered;
 785
 786                         dbus_message_iter_get_basic(&value, &powered);
 787
 788                         connman_device_set_powered(device, powered);
 789                 }
 790
 791                 dbus_message_iter_next(&dict);
 792         }
 793
 794         if (attached == TRUE)
 795                 add_networks(device, &contexts);
 796
 797 done:
 798         dbus_message_unref(reply);
 799
 800         dbus_pending_call_unref(call);
 801 }
 802
 803 static void check_networks(struct modem_data *modem)
 804 {
 805         DBusMessage *message;
 806         DBusPendingCall *call;
 807         struct connman_device *device;
 808
 809         DBG("modem %p", modem);
 810
 811         if (modem == NULL)
 812                 return;
 813
 814         device = modem->device;
 815         if (device == NULL)
 816                 return;
 817
 818         message = dbus_message_new_method_call(OFONO_SERVICE, modem->path,
 819                                         OFONO_GPRS_INTERFACE, GET_PROPERTIES);
 820         if (message == NULL)
 821                 return;
 822
 823         dbus_message_set_auto_start(message, FALSE);
 824
 825         if (dbus_connection_send_with_reply(connection, message,
 826                                                 &call, TIMEOUT) == FALSE) {
 827                 connman_error("Failed to get ofono GPRS");
 828                 goto done;
 829         }
 830
 831         if (call == NULL) {
 832                 connman_error("D-Bus connection not available");
 833                 goto done;
 834         }
 835
 836         dbus_pending_call_set_notify(call, check_networks_reply,
 837                                                 (void *)device, NULL);
 838
 839 done:
 840         dbus_message_unref(message);
 841 }
 842
 843 static void add_device(const char *path, const char *imsi,
 844                                         unsigned char mnc_length)
 845 {
 846         struct modem_data *modem;
 847         struct connman_device *device;
 848         char *mcc_mnc;
 849
 850         DBG("path %s imsi %s mnc_length %d", path, imsi, mnc_length);
 851
 852         if (path == NULL)
 853                 return;
 854
 855         if (imsi == NULL)
 856                 return;
 857
 858         modem = g_hash_table_lookup(modem_hash, path);
 859         if (modem == NULL)
 860                 return;
 861
 862         device = connman_device_create(imsi, CONNMAN_DEVICE_TYPE_CELLULAR);
 863         if (device == NULL)
 864                 return;
 865
 866         connman_device_set_ident(device, imsi);
 867
 868         connman_device_set_mode(device, CONNMAN_DEVICE_MODE_NETWORK_MULTIPLE);
 869
 870         connman_device_set_string(device, "Path", path);
 871
 872         if (mnc_length == 2 || mnc_length == 3) {
 873                 mcc_mnc = g_strndup(imsi, mnc_length + 3);
 874                 connman_device_set_string(device, "MCC_MNC", mcc_mnc);
 875                 g_free(mcc_mnc);
 876         }
 877
 878         if (connman_device_register(device) < 0) {
 879                 connman_device_unref(device);
 880                 return;
 881         }
 882
 883         modem->device = device;
 884
 885         check_networks(modem);
 886 }
 887
 888 static void sim_properties_reply(DBusPendingCall *call, void *user_data)
 889 {
 890         const char *path = user_data;
 891         const char *imsi;
 892         /* If MobileNetworkCodeLength is not provided, mnc_length is 0 */
 893         unsigned char mnc_length = 0;
 894         DBusMessage *reply;
 895         DBusMessageIter array, dict;
 896
 897         DBG("path %s", path);
 898
 899         reply = dbus_pending_call_steal_reply(call);
 900
 901         if (dbus_message_iter_init(reply, &array) == FALSE)
 902                 goto done;
 903
 904         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
 905                 goto done;
 906
 907         dbus_message_iter_recurse(&array, &dict);
 908
 909         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
 910                 DBusMessageIter entry, value;
 911                 const char *key;
 912
 913                 dbus_message_iter_recurse(&dict, &entry);
 914                 dbus_message_iter_get_basic(&entry, &key);
 915
 916                 dbus_message_iter_next(&entry);
 917                 dbus_message_iter_recurse(&entry, &value);
 918
 919                 if (g_str_equal(key, "SubscriberIdentity") == TRUE)
 920                         dbus_message_iter_get_basic(&value, &imsi);
 921                 else if (g_str_equal(key, "MobileNetworkCodeLength") == TRUE)
 922                         dbus_message_iter_get_basic(&value,
 923                                                 (void *) &mnc_length);
 924
 925                 dbus_message_iter_next(&dict);
 926         }
 927
 928         add_device(path, imsi, mnc_length);
 929
 930 done:
 931         dbus_message_unref(reply);
 932
 933         dbus_pending_call_unref(call);
 934 }
 935
 936 static void get_imsi(const char *path)
 937 {
 938         DBusMessage *message;
 939         DBusPendingCall *call;
 940
 941         DBG("path %s", path);
 942
 943         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 944                                 OFONO_SIM_INTERFACE, GET_PROPERTIES);
 945         if (message == NULL)
 946                 return;
 947
 948         dbus_message_set_auto_start(message, FALSE);
 949
 950         if (dbus_connection_send_with_reply(connection, message,
 951                                                 &call, TIMEOUT) == FALSE) {
 952                 connman_error("Failed to get ofono modem sim");
 953                 goto done;
 954         }
 955
 956         if (call == NULL) {
 957                 connman_error("D-Bus connection not available");
 958                 goto done;
 959         }
 960
 961         dbus_pending_call_set_notify(call, sim_properties_reply,
 962                                                 (void *)path, NULL);
 963
 964 done:
 965         dbus_message_unref(message);
 966 }
 967
 968 static int modem_change_powered(const char *path, dbus_bool_t powered)
 969 {
 970         DBusMessage *message;
 971         DBusMessageIter iter;
 972         DBusPendingCall *call;
 973
 974         DBG("path %s powered %d", path, powered);
 975
 976         if (path == NULL)
 977                 return -EINVAL;
 978
 979         message = dbus_message_new_method_call(OFONO_SERVICE, path,
 980                                         OFONO_MODEM_INTERFACE, SET_PROPERTY);
 981         if (message == NULL)
 982                 return -ENOMEM;
 983
 984         dbus_message_set_auto_start(message, FALSE);
 985
 986         dbus_message_iter_init_append(message, &iter);
 987         connman_dbus_property_append_basic(&iter, "Powered",
 988                                                 DBUS_TYPE_BOOLEAN, &powered);
 989
 990         if (dbus_connection_send_with_reply(connection, message,
 991                                                 &call, TIMEOUT) == FALSE) {
 992                 connman_error("Failed to change powered property");
 993                 dbus_message_unref(message);
 994                 return -EINVAL;
 995         }
 996
 997         if (call == NULL) {
 998                 connman_error("D-Bus connection not available");
 999                 dbus_message_unref(message);
1000                 return -EINVAL;
1001         }
1002
1003         dbus_pending_call_set_notify(call, powered_reply, NULL, NULL);
1004
1005         dbus_message_unref(message);
1006
1007         return -EINPROGRESS;
1008 }
1009
1010 static struct modem_data *add_modem(const char *path)
1011 {
1012         struct modem_data *modem;
1013
1014         if (path == NULL)
1015                 return NULL;
1016
1017         modem = g_hash_table_lookup(modem_hash, path);
1018         if (modem != NULL) {
1019                 modem->available = TRUE;
1020
1021                 return modem;
1022         }
1023
1024         modem = g_try_new0(struct modem_data, 1);
1025         if (modem == NULL)
1026                 return NULL;
1027
1028         modem->path = g_strdup(path);
1029         modem->device = NULL;
1030         modem->available = TRUE;
1031
1032         g_hash_table_insert(modem_hash, g_strdup(path), modem);
1033
1034         return modem;
1035 }
1036
1037 static gboolean modem_has_gprs(DBusMessageIter *array)
1038 {
1039         DBusMessageIter entry;
1040
1041         dbus_message_iter_recurse(array, &entry);
1042
1043         while (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_STRING) {
1044                 const char *interface;
1045
1046                 dbus_message_iter_get_basic(&entry, &interface);
1047
1048                 if (g_strcmp0(OFONO_GPRS_INTERFACE, interface) == 0)
1049                         return TRUE;
1050
1051                 dbus_message_iter_next(&entry);
1052         }
1053
1054         return FALSE;
1055 }
1056
1057 static void modem_properties_reply(DBusPendingCall *call, void *user_data)
1058 {
1059         DBusMessage *reply;
1060         DBusMessageIter array, dict;
1061         const char *path = user_data;
1062
1063         DBG("path %s", path);
1064
1065         reply = dbus_pending_call_steal_reply(call);
1066
1067         if (dbus_message_iter_init(reply, &array) == FALSE)
1068                 goto done;
1069
1070         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
1071                 goto done;
1072
1073         dbus_message_iter_recurse(&array, &dict);
1074
1075         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
1076                 DBusMessageIter entry, value;
1077                 const char *key;
1078                 dbus_bool_t powered;
1079
1080                 dbus_message_iter_recurse(&dict, &entry);
1081                 dbus_message_iter_get_basic(&entry, &key);
1082
1083                 dbus_message_iter_next(&entry);
1084                 dbus_message_iter_recurse(&entry, &value);
1085
1086                 if (g_str_equal(key, "Powered") == TRUE) {
1087                         dbus_message_iter_get_basic(&value, &powered);
1088
1089                         if (powered == FALSE) {
1090                                 modem_change_powered(path, TRUE);
1091                                 break;
1092                         }
1093                 } else if (g_str_equal(key, "Interfaces") == TRUE) {
1094                         if (modem_has_gprs(&value) == TRUE)
1095                                 get_imsi(path);
1096                 }
1097
1098                 dbus_message_iter_next(&dict);
1099         }
1100
1101 done:
1102         dbus_message_unref(reply);
1103
1104         dbus_pending_call_unref(call);
1105 }
1106
1107 static void get_modem_properties(struct modem_data *modem)
1108 {
1109         DBusMessage *message;
1110         DBusPendingCall *call;
1111
1112         DBG("path %s", modem->path);
1113
1114         if (modem->path == NULL)
1115                 return;
1116
1117         message = dbus_message_new_method_call(OFONO_SERVICE, modem->path,
1118                                 OFONO_MODEM_INTERFACE, GET_PROPERTIES);
1119         if (message == NULL)
1120                 return;
1121
1122         dbus_message_set_auto_start(message, FALSE);
1123
1124         if (dbus_connection_send_with_reply(connection, message,
1125                                                 &call, TIMEOUT) == FALSE) {
1126                 connman_error("Failed to get ofono modem");
1127                 goto done;
1128         }
1129
1130         if (call == NULL) {
1131                 connman_error("D-Bus connection not available");
1132                 goto done;
1133         }
1134
1135         dbus_pending_call_set_notify(call, modem_properties_reply,
1136                                                 (void *)modem->path, NULL);
1137
1138 done:
1139         dbus_message_unref(message);
1140 }
1141
1142 static void mask_unavailable(gpointer key, gpointer value, gpointer user_data)
1143 {
1144         struct modem_data *modem = value;
1145
1146         modem->available = FALSE;
1147 }
1148
1149 static void modems_set_unavailable()
1150 {
1151         g_hash_table_foreach(modem_hash, mask_unavailable, NULL);
1152 }
1153
1154 static void cleanup_modem(gpointer key, gpointer value, gpointer user_data)
1155 {
1156         struct modem_data *modem = value;
1157
1158         if (modem->available == FALSE)
1159                 g_hash_table_remove(modem_hash, key);
1160 }
1161
1162 static void cleanup_modems()
1163 {
1164         g_hash_table_foreach(modem_hash, cleanup_modem, NULL);
1165 }
1166
1167 static void update_modems(DBusMessageIter *array)
1168 {
1169         DBusMessageIter entry;
1170
1171         dbus_message_iter_recurse(array, &entry);
1172
1173         modems_set_unavailable();
1174
1175         while (dbus_message_iter_get_arg_type(&entry) ==
1176                                         DBUS_TYPE_OBJECT_PATH) {
1177                 const char *path;
1178                 struct modem_data *modem;
1179
1180                 dbus_message_iter_get_basic(&entry, &path);
1181
1182                 modem = add_modem(path);
1183                 if (modem != NULL)
1184                         get_modem_properties(modem);
1185
1186                 dbus_message_iter_next(&entry);
1187         }
1188
1189         cleanup_modems();
1190 }
1191
1192 static void manager_properties_reply(DBusPendingCall *call, void *user_data)
1193 {
1194         DBusMessage *reply;
1195         DBusMessageIter array, dict;
1196
1197         DBG("");
1198
1199         reply = dbus_pending_call_steal_reply(call);
1200
1201         if (dbus_message_iter_init(reply, &array) == FALSE)
1202                 goto done;
1203
1204         if (dbus_message_iter_get_arg_type(&array) != DBUS_TYPE_ARRAY)
1205                 goto done;
1206
1207         dbus_message_iter_recurse(&array, &dict);
1208
1209         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
1210                 DBusMessageIter entry, value;
1211                 const char *key;
1212
1213                 dbus_message_iter_recurse(&dict, &entry);
1214                 dbus_message_iter_get_basic(&entry, &key);
1215
1216                 dbus_message_iter_next(&entry);
1217                 dbus_message_iter_recurse(&entry, &value);
1218
1219                 if (g_str_equal(key, "Modems") == TRUE) {
1220                         update_modems(&value);
1221                         break;
1222                 }
1223
1224                 dbus_message_iter_next(&dict);
1225         }
1226
1227 done:
1228         dbus_message_unref(reply);
1229
1230         dbus_pending_call_unref(call);
1231 }
1232
1233 static void modem_remove_device(struct modem_data *modem)
1234 {
1235         if (modem->device == NULL)
1236                 return;
1237
1238         connman_device_unregister(modem->device);
1239         connman_device_unref(modem->device);
1240
1241         modem->device = NULL;
1242 }
1243
1244 static void remove_modem(gpointer data)
1245 {
1246         struct modem_data *modem = data;
1247
1248         g_free(modem->path);
1249
1250         modem_remove_device(modem);
1251
1252         g_free(modem);
1253 }
1254
1255 static void ofono_connect(DBusConnection *connection, void *user_data)
1256 {
1257         DBusMessage *message;
1258         DBusPendingCall *call;
1259
1260         DBG("connection %p", connection);
1261
1262         modem_hash = g_hash_table_new_full(g_str_hash, g_str_equal,
1263                                                 g_free, remove_modem);
1264
1265         message = dbus_message_new_method_call(OFONO_SERVICE, "/",
1266                                 OFONO_MANAGER_INTERFACE, GET_PROPERTIES);
1267         if (message == NULL)
1268                 return;
1269
1270         dbus_message_set_auto_start(message, FALSE);
1271
1272         if (dbus_connection_send_with_reply(connection, message,
1273                                                 &call, TIMEOUT) == FALSE) {
1274                 connman_error("Failed to get ofono modems");
1275                 goto done;
1276         }
1277
1278         if (call == NULL) {
1279                 connman_error("D-Bus connection not available");
1280                 goto done;
1281         }
1282
1283         dbus_pending_call_set_notify(call, manager_properties_reply,
1284                                                                 NULL, NULL);
1285
1286 done:
1287         dbus_message_unref(message);
1288
1289 }
1290
1291 static void ofono_disconnect(DBusConnection *connection, void *user_data)
1292 {
1293         DBG("connection %p", connection);
1294
1295         if (modem_hash == NULL)
1296                 return;
1297
1298         g_hash_table_destroy(modem_hash);
1299
1300         modem_hash = NULL;
1301 }
1302
1303 static gboolean modem_changed(DBusConnection *connection, DBusMessage *message,
1304                                 void *user_data)
1305 {
1306         const char *path = dbus_message_get_path(message);
1307         struct modem_data *modem;
1308         DBusMessageIter iter, value;
1309         const char *key;
1310
1311         DBG("path %s", path);
1312
1313         modem = g_hash_table_lookup(modem_hash, path);
1314         if (modem == NULL)
1315                 return TRUE;
1316
1317         if (dbus_message_iter_init(message, &iter) == FALSE)
1318                 return TRUE;
1319
1320         dbus_message_iter_get_basic(&iter, &key);
1321
1322         dbus_message_iter_next(&iter);
1323         dbus_message_iter_recurse(&iter, &value);
1324
1325         if (g_str_equal(key, "Powered") == TRUE) {
1326                 dbus_bool_t powered;
1327
1328                 dbus_message_iter_get_basic(&value, &powered);
1329                 if (powered == TRUE)
1330                         return TRUE;
1331
1332                 modem_remove_device(modem);
1333         } else if (g_str_equal(key, "Interfaces") == TRUE) {
1334                 if (modem_has_gprs(&value) == TRUE) {
1335                         if (modem->device == NULL)
1336                                 get_imsi(modem->path);
1337                 } else if (modem->device != NULL)
1338                         modem_remove_device(modem);
1339         }
1340
1341         return TRUE;
1342 }
1343
1344 static gboolean gprs_changed(DBusConnection *connection, DBusMessage *message,
1345                                 void *user_data)
1346 {
1347         const char *path = dbus_message_get_path(message);
1348         struct modem_data *modem;
1349         DBusMessageIter iter, value;
1350         const char *key;
1351
1352         DBG("path %s", path);
1353
1354         modem = g_hash_table_lookup(modem_hash, path);
1355         if (modem == NULL)
1356                 return TRUE;
1357
1358         if (dbus_message_iter_init(message, &iter) == FALSE)
1359                 return TRUE;
1360
1361         dbus_message_iter_get_basic(&iter, &key);
1362
1363         dbus_message_iter_next(&iter);
1364         dbus_message_iter_recurse(&iter, &value);
1365
1366         if (g_str_equal(key, "Attached") == TRUE) {
1367                 dbus_bool_t attached;
1368
1369                 dbus_message_iter_get_basic(&value, &attached);
1370
1371                 DBG("Attached %d", attached);
1372
1373                 if (attached == TRUE)
1374                         check_networks(modem);
1375                 else if (modem->device != NULL)
1376                         connman_device_remove_all_networks(modem->device);
1377
1378         } else if (g_str_equal(key, "Status") == TRUE) {
1379                 const char *status;
1380                 dbus_message_iter_get_basic(&value, &status);
1381
1382                 DBG("status %s", status);
1383
1384                 /* FIXME: add roaming support */
1385         } else if (g_str_equal(key, "PrimaryContexts") == TRUE) {
1386                 check_networks(modem);
1387         } else if (g_str_equal(key, "Powered") == TRUE) {
1388                 dbus_bool_t powered;
1389
1390                 if (modem->device == NULL)
1391                         return TRUE;
1392
1393                 dbus_message_iter_get_basic(&value, &powered);
1394                 connman_device_set_powered(modem->device, powered);
1395         }
1396
1397         return TRUE;
1398 }
1399
1400 static gboolean manager_changed(DBusConnection *connection,
1401                                 DBusMessage *message, void *user_data)
1402 {
1403         const char *path = dbus_message_get_path(message);
1404         DBusMessageIter iter, value;
1405         const char *key;
1406
1407         DBG("path %s", path);
1408
1409         if (dbus_message_iter_init(message, &iter) == FALSE)
1410                 return TRUE;
1411
1412         dbus_message_iter_get_basic(&iter, &key);
1413
1414         dbus_message_iter_next(&iter);
1415         dbus_message_iter_recurse(&iter, &value);
1416
1417         if (g_str_equal(key, "Modems") == TRUE)
1418                 update_modems(&value);
1419
1420         return TRUE;
1421 }
1422
1423 static void get_dns(DBusMessageIter *array, struct connman_element *parent)
1424 {
1425         DBusMessageIter entry;
1426         gchar *nameserver = NULL, *nameserver_old = NULL;
1427
1428         DBG("");
1429
1430         dbus_message_iter_recurse(array, &entry);
1431
1432         while (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_STRING) {
1433                 const char *dns;
1434
1435                 dbus_message_iter_get_basic(&entry, &dns);
1436
1437                 DBG("dns %s", dns);
1438
1439                 if (nameserver == NULL) {
1440
1441                         nameserver = g_strdup(dns);
1442                 } else {
1443
1444                         nameserver_old = nameserver;
1445                         nameserver = g_strdup_printf("%s %s",
1446                                                 nameserver_old, dns);
1447                         g_free(nameserver_old);
1448                 }
1449
1450                 dbus_message_iter_next(&entry);
1451         }
1452
1453         parent->ipv4.nameserver = nameserver;
1454 }
1455
1456 static void update_settings(DBusMessageIter *array,
1457                         struct connman_element *parent)
1458 {
1459         DBusMessageIter dict;
1460         const char *interface = NULL;
1461
1462         DBG("");
1463
1464         if (dbus_message_iter_get_arg_type(array) != DBUS_TYPE_ARRAY)
1465                 return;
1466
1467         dbus_message_iter_recurse(array, &dict);
1468
1469         while (dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY) {
1470                 DBusMessageIter entry, value;
1471                 const char *key;
1472
1473                 dbus_message_iter_recurse(&dict, &entry);
1474                 dbus_message_iter_get_basic(&entry, &key);
1475
1476                 dbus_message_iter_next(&entry);
1477                 dbus_message_iter_recurse(&entry, &value);
1478
1479                 if (g_str_equal(key, "Interface") == TRUE) {
1480                         int index;
1481
1482                         dbus_message_iter_get_basic(&value, &interface);
1483
1484                         DBG("interface %s", interface);
1485
1486                         index = connman_inet_ifindex(interface);
1487                         if (index >= 0) {
1488                                 connman_network_set_index(
1489                                         pending_network, index);
1490                         } else {
1491                                 connman_error("Can not find interface %s",
1492                                                                 interface);
1493                                 break;
1494                         }
1495                 } else if (g_str_equal(key, "Method") == TRUE) {
1496                         const char *method;
1497
1498                         dbus_message_iter_get_basic(&value, &method);
1499                         if (g_strcmp0(method, "static") == 0) {
1500
1501                                 parent->ipv4.method =
1502                                         CONNMAN_IPCONFIG_METHOD_FIXED;
1503                         } else if (g_strcmp0(method, "dhcp") == 0) {
1504
1505                                 parent->ipv4.method =
1506                                         CONNMAN_IPCONFIG_METHOD_DHCP;
1507                                 break;
1508                         }
1509                 } else if (g_str_equal(key, "Address") == TRUE) {
1510                         const char *address;
1511
1512                         dbus_message_iter_get_basic(&value, &address);
1513
1514                         DBG("address %s", address);
1515
1516                         parent->ipv4.address = g_strdup(address);
1517                 } else if (g_str_equal(key, "Netmask") == TRUE) {
1518                         const char *netmask;
1519
1520                         dbus_message_iter_get_basic(&value, &netmask);
1521
1522                         DBG("netmask %s", netmask);
1523
1524                         parent->ipv4.netmask = g_strdup(netmask);
1525                 } else if (g_str_equal(key, "DomainNameServers") == TRUE) {
1526
1527                         get_dns(&value, parent);
1528                 } else if (g_str_equal(key, "Gateway") == TRUE) {
1529                         const char *gateway;
1530
1531                         dbus_message_iter_get_basic(&value, &gateway);
1532
1533                         DBG("gateway %s", gateway);
1534
1535                         parent->ipv4.gateway = g_strdup(gateway);
1536                 }
1537
1538                 dbus_message_iter_next(&dict);
1539         }
1540
1541         /* deactive, oFono send NULL inteface before deactive signal */
1542         if (interface == NULL)
1543                 connman_network_set_index(pending_network, -1);
1544 }
1545
1546 static void cleanup_ipconfig(struct connman_element *parent)
1547 {
1548         g_free(parent->ipv4.address);
1549         parent->ipv4.address = NULL;
1550
1551         g_free(parent->ipv4.netmask);
1552         parent->ipv4.netmask = NULL;
1553
1554         g_free(parent->ipv4.nameserver);
1555         parent->ipv4.nameserver = NULL;
1556
1557         g_free(parent->ipv4.gateway);
1558         parent->ipv4.gateway = NULL;
1559
1560         parent->ipv4.method = CONNMAN_IPCONFIG_METHOD_UNKNOWN;
1561 }
1562
1563 static int static_network_set_connected(
1564                 struct connman_network *pending_network,
1565                                 struct connman_element *parent,
1566                                         connman_bool_t connected)
1567 {
1568         if (connected == TRUE) {
1569                 struct connman_element *element;
1570
1571                 if (parent->ipv4.address == NULL)
1572                         goto failed;
1573
1574                 if (parent->ipv4.netmask == NULL)
1575                         goto failed;
1576
1577                 element = connman_element_create(NULL);
1578                 if (element == NULL) {
1579                         connman_error("Can not create connman_element");
1580                         return -ENOMEM;
1581                 }
1582
1583                 element->type = CONNMAN_ELEMENT_TYPE_IPV4;
1584                 element->index = parent->index;
1585
1586                 if (connman_element_register(element, parent) < 0) {
1587                         connman_element_unref(element);
1588                         goto failed;
1589                 }
1590         } else
1591                 cleanup_ipconfig(parent);
1592
1593         connman_network_set_connected(pending_network, connected);
1594
1595         return 0;
1596
1597 failed:
1598         connman_network_set_error(pending_network,
1599                 CONNMAN_NETWORK_ERROR_ASSOCIATE_FAIL);
1600
1601         cleanup_ipconfig(parent);
1602
1603         return -EINVAL;
1604 }
1605
1606 static gboolean pri_context_changed(DBusConnection *connection,
1607                                         DBusMessage *message, void *user_data)
1608 {
1609         const char *path = dbus_message_get_path(message);
1610         struct connman_element *parent;
1611         const char *pending_path;
1612         DBusMessageIter iter, value;
1613         const char *key;
1614
1615         DBG("pending_network %p, path %s", pending_network, path);
1616
1617         if (pending_network == NULL)
1618                 return TRUE;
1619
1620         pending_path = connman_network_get_string(pending_network, "Path");
1621         if (g_strcmp0(pending_path, path) != 0)
1622                 return TRUE;
1623
1624         parent = connman_network_get_element(pending_network);
1625
1626         if (dbus_message_iter_init(message, &iter) == FALSE)
1627                 return TRUE;
1628
1629         dbus_message_iter_get_basic(&iter, &key);
1630
1631         dbus_message_iter_next(&iter);
1632         dbus_message_iter_recurse(&iter, &value);
1633
1634         if (g_str_equal(key, "Settings") == TRUE) {
1635
1636                 update_settings(&value, parent);
1637         } else if (g_str_equal(key, "Active") == TRUE) {
1638                 dbus_bool_t active;
1639
1640                 dbus_message_iter_get_basic(&value, &active);
1641
1642                 switch (parent->ipv4.method) {
1643                 case CONNMAN_IPCONFIG_METHOD_UNKNOWN:
1644                 case CONNMAN_IPCONFIG_METHOD_OFF:
1645                 case CONNMAN_IPCONFIG_METHOD_MANUAL:
1646                         break;
1647                 case CONNMAN_IPCONFIG_METHOD_FIXED:
1648                         connman_network_set_method(pending_network,
1649                                                 CONNMAN_IPCONFIG_METHOD_FIXED);
1650
1651                         if (static_network_set_connected(
1652                                         pending_network, parent, active) < 0)
1653                                 set_network_active(pending_network, FALSE);
1654                         break;
1655                 case CONNMAN_IPCONFIG_METHOD_DHCP:
1656                         connman_network_set_method(pending_network,
1657                                                 CONNMAN_IPCONFIG_METHOD_DHCP);
1658                         connman_network_set_connected(pending_network, active);
1659                         break;
1660                 }
1661
1662                 pending_network = NULL;
1663         }
1664
1665         return TRUE;
1666 }
1667
1668 static guint watch;
1669 static guint gprs_watch;
1670 static guint modem_watch;
1671 static guint manager_watch;
1672 static guint context_watch;
1673
1674 static int ofono_init(void)
1675 {
1676         int err;
1677
1678         connection = connman_dbus_get_connection();
1679         if (connection == NULL)
1680                 return -EIO;
1681
1682         watch = g_dbus_add_service_watch(connection, OFONO_SERVICE,
1683                         ofono_connect, ofono_disconnect, NULL, NULL);
1684
1685         gprs_watch = g_dbus_add_signal_watch(connection, NULL, NULL,
1686                                                 OFONO_GPRS_INTERFACE,
1687                                                 PROPERTY_CHANGED,
1688                                                 gprs_changed,
1689                                                 NULL, NULL);
1690
1691         modem_watch = g_dbus_add_signal_watch(connection, NULL, NULL,
1692                                                 OFONO_MODEM_INTERFACE,
1693                                                 PROPERTY_CHANGED,
1694                                                 modem_changed,
1695                                                 NULL, NULL);
1696
1697         manager_watch = g_dbus_add_signal_watch(connection, NULL, NULL,
1698                                                 OFONO_MANAGER_INTERFACE,
1699                                                 PROPERTY_CHANGED,
1700                                                 manager_changed,
1701                                                 NULL, NULL);
1702
1703         context_watch = g_dbus_add_signal_watch(connection, NULL, NULL,
1704                                                 OFONO_PRI_CONTEXT_INTERFACE,
1705                                                 PROPERTY_CHANGED,
1706                                                 pri_context_changed,
1707                                                 NULL, NULL);
1708
1709         if (watch == 0 || gprs_watch == 0 || modem_watch == 0 ||
1710                         manager_watch == 0 || context_watch == 0) {
1711                 err = -EIO;
1712                 goto remove;
1713         }
1714
1715         err = connman_network_driver_register(&network_driver);
1716         if (err < 0)
1717                 goto remove;
1718
1719         err = connman_device_driver_register(&modem_driver);
1720         if (err < 0) {
1721                 connman_network_driver_unregister(&network_driver);
1722                 goto remove;
1723         }
1724
1725         return 0;
1726
1727 remove:
1728         g_dbus_remove_watch(connection, watch);
1729         g_dbus_remove_watch(connection, gprs_watch);
1730         g_dbus_remove_watch(connection, modem_watch);
1731         g_dbus_remove_watch(connection, manager_watch);
1732         g_dbus_remove_watch(connection, context_watch);
1733
1734         dbus_connection_unref(connection);
1735
1736         return err;
1737 }
1738
1739 static void ofono_exit(void)
1740 {
1741         g_dbus_remove_watch(connection, watch);
1742         g_dbus_remove_watch(connection, gprs_watch);
1743         g_dbus_remove_watch(connection, modem_watch);
1744         g_dbus_remove_watch(connection, manager_watch);
1745         g_dbus_remove_watch(connection, context_watch);
1746
1747         ofono_disconnect(connection, NULL);
1748
1749         connman_device_driver_unregister(&modem_driver);
1750         connman_network_driver_unregister(&network_driver);
1751
1752         dbus_connection_unref(connection);
1753 }
1754
1755 CONNMAN_PLUGIN_DEFINE(ofono, "oFono telephony plugin", VERSION,
1756                 CONNMAN_PLUGIN_PRIORITY_DEFAULT, ofono_init, ofono_exit)