--- src/gprs.c | 147 ++++++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 133 insertions(+), 14 deletions(-)
diff --git a/src/gprs.c b/src/gprs.c index 7ef81d5..06f6555 100644 --- a/src/gprs.c +++ b/src/gprs.c @@ -43,6 +43,7 @@ #include "common.h" #include "storage.h" #include "idmap.h" +#include "gprs-provision.h" #define GPRS_FLAG_ATTACHING 0x1 #define GPRS_FLAG_RECHECK 0x2 @@ -83,6 +84,7 @@ struct ofono_gprs { const struct ofono_gprs_driver *driver; void *driver_data; struct ofono_atom *atom; + struct provision_request *provision; }; struct ofono_gprs_context { @@ -123,6 +125,10 @@ struct pri_context { struct ofono_gprs *gprs; }; +struct provision_request { + struct ofono_gprs *gprs; +}; + static void gprs_netreg_update(struct ofono_gprs *gprs); static void gprs_deactivate_next(struct ofono_gprs *gprs); @@ -2230,6 +2236,9 @@ static void gprs_remove(struct ofono_atom *atom) if (gprs->driver && gprs->driver->remove) gprs->driver->remove(gprs); + if (gprs->provision != NULL) + gprs->provision->gprs = NULL; + g_free(gprs); } @@ -2483,13 +2492,15 @@ remove: storage_sync(imsi, SETTINGS_STORE, gprs->settings); } -void ofono_gprs_register(struct ofono_gprs *gprs) +static void ofono_gprs_finish_register(struct ofono_gprs *gprs) { DBusConnection *conn = ofono_dbus_get_connection(); struct ofono_modem *modem = __ofono_atom_get_modem(gprs->atom); const char *path = __ofono_atom_get_path(gprs->atom); struct ofono_atom *netreg_atom; - struct ofono_atom *sim_atom; + + if (gprs->contexts == NULL) /* Automatic provisioning failed */ + add_context(gprs, NULL, OFONO_GPRS_CONTEXT_TYPE_INTERNET); if (!g_dbus_register_interface(conn, path, OFONO_CONNECTION_MANAGER_INTERFACE, @@ -2504,18 +2515,6 @@ void ofono_gprs_register(struct ofono_gprs *gprs) ofono_modem_add_interface(modem, OFONO_CONNECTION_MANAGER_INTERFACE); - sim_atom = __ofono_modem_find_atom(modem, OFONO_ATOM_TYPE_SIM); - - if (sim_atom) { - struct ofono_sim *sim = __ofono_atom_get_data(sim_atom); - const char *imsi = ofono_sim_get_imsi(sim); - - gprs_load_settings(gprs, imsi); - } - - if (gprs->contexts == NULL) - add_context(gprs, NULL, OFONO_GPRS_CONTEXT_TYPE_INTERNET); - gprs->netreg_watch = __ofono_modem_add_atom_watch(modem, OFONO_ATOM_TYPE_NETREG, netreg_watch, gprs, NULL); @@ -2529,6 +2528,126 @@ void ofono_gprs_register(struct ofono_gprs *gprs) __ofono_atom_register(gprs->atom, gprs_unregister); } +static void provision_context(const struct ofono_gprs_provision_data *ap, + struct ofono_gprs *gprs) +{ + unsigned int id; + struct pri_context *context = NULL; + + /* Sanity check */ + if (ap == NULL || ap->name == NULL) + return; + + if (gprs->last_context_id) + id = idmap_alloc_next(gprs->pid_map, gprs->last_context_id); + else + id = idmap_alloc(gprs->pid_map); + + if (id > idmap_get_max(gprs->pid_map)) + return; + + context = pri_context_create(gprs, ap->name, ap->type); + DBG("%s context%d '%s' %s", gprs_context_default_name(ap->type), + id, ap->name, context ? "created" : "creation failed"); + + if (context == NULL) + return; + + context->id = id; + + if (ap->username != NULL) + strncpy(context->context.username, ap->username, + OFONO_GPRS_MAX_USERNAME_LENGTH); + + if (ap->password != NULL) + strncpy(context->context.password, ap->password, + OFONO_GPRS_MAX_PASSWORD_LENGTH); + + if (ap->apn != NULL) + strncpy(context->context.apn, ap->apn, + OFONO_GPRS_MAX_APN_LENGTH); + + context->context.proto = ap->proto; + + if (ap->type == OFONO_GPRS_CONTEXT_TYPE_MMS && + ap->message_proxy != NULL) + strncpy(context->message_proxy, ap->message_proxy, + MAX_MESSAGE_PROXY_LENGTH); + + if (ap->type == OFONO_GPRS_CONTEXT_TYPE_MMS && + ap->message_center != NULL) + strncpy(context->message_center, ap->message_center, + MAX_MESSAGE_CENTER_LENGTH); + + if (context_dbus_register(context) == TRUE) { + gprs->last_context_id = id; + gprs->contexts = g_slist_append(gprs->contexts, context); + write_context_settings(gprs, context); + + if (context->type == OFONO_GPRS_CONTEXT_TYPE_MMS) { + g_key_file_set_string(gprs->settings, context->key, + "MessageProxy", + context->message_proxy); + g_key_file_set_string(gprs->settings, context->key, + "MessageCenter", + context->message_center); + } + + storage_sync(gprs->imsi, SETTINGS_STORE, gprs->settings); + } +} + + +static void provision_cb(const struct ofono_gprs_provision_data settings[], + int count, void *user_data) +{ + struct provision_request *req = user_data; + struct ofono_gprs *gprs = req->gprs; + + if (gprs != NULL) { + int i; + gprs->provision = NULL; + + for (i = 0; i < count; i++) + provision_context(&settings[i], gprs); + + ofono_gprs_finish_register(gprs); + } + + g_free(req); +} + +void ofono_gprs_register(struct ofono_gprs *gprs) +{ + struct ofono_modem *modem = __ofono_atom_get_modem(gprs->atom); + struct ofono_atom *sim_atom; + + sim_atom = __ofono_modem_find_atom(modem, OFONO_ATOM_TYPE_SIM); + + if (sim_atom != NULL) { + struct ofono_sim *sim = __ofono_atom_get_data(sim_atom); + const char *imsi = ofono_sim_get_imsi(sim); + + gprs_load_settings(gprs, imsi); + } + + if (gprs->contexts == NULL) { + /* Start settings provisioning */ + struct provision_request *req; + + req = g_try_new0(struct provision_request, 1); + if (req != NULL) { + req->gprs = gprs; + gprs->provision = req; + __ofono_gprs_provision_get_settings(modem, provision_cb, + req); + return; + } + } + + ofono_gprs_finish_register(gprs); +} + void ofono_gprs_remove(struct ofono_gprs *gprs) { __ofono_atom_free(gprs->atom); -- 1.7.1 _______________________________________________ ofono mailing list ofono@ofono.org http://lists.ofono.org/listinfo/ofono