/* * * oFono - Open Source Telephony * * Copyright (C) 2008-2011 Intel Corporation. All rights reserved. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License version 2 as * published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA * */ #ifdef HAVE_CONFIG_H #include #endif #define _GNU_SOURCE #include #include #include #include #include #include #include #include "gatchat.h" #include "gatresult.h" #include "hsomodem.h" #define HSO_DISCONNECTED 0 #define HSO_CONNECTED 1 #define HSO_CONNECTING 2 #define HSO_FAILED 3 #define AUTH_BUF_LENGTH OFONO_GPRS_MAX_USERNAME_LENGTH + \ OFONO_GPRS_MAX_PASSWORD_LENGTH + 128 #define STATIC_IP_NETMASK "255.255.255.255" static const char *none_prefix[] = { NULL }; static const char *owandata_prefix[] = { "_OWANDATA:", NULL }; enum hso_state { HSO_NONE = 0, HSO_ENABLING = 1, HSO_DISABLING = 2, }; struct gprs_context_data { GAtChat *chat; unsigned int active_context; /* Currently active */ enum hso_state hso_state; /* Are we in req ? */ ofono_gprs_context_cb_t cb; void *cb_data; /* Callback data */ int owancall; /* State of the call */ }; static void at_owancall_down_cb(gboolean ok, GAtResult *result, gpointer user_data) { struct cb_data *cbd = user_data; ofono_gprs_context_cb_t cb = cbd->cb; struct ofono_gprs_context *gc = cbd->user; struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); struct ofono_error error; /* Now we have to wait for the unsolicited notification to arrive */ if (ok && gcd->owancall != 0) { gcd->hso_state = HSO_DISABLING; gcd->cb = cb; gcd->cb_data = cbd->data; return; } decode_at_error(&error, g_at_result_final_response(result)); cb(&error, cbd->data); } static void at_owancall_up_cb(gboolean ok, GAtResult *result, gpointer user_data) { struct cb_data *cbd = user_data; ofono_gprs_context_cb_t cb = cbd->cb; struct ofono_gprs_context *gc = cbd->user; struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); struct ofono_error error; if (ok) { gcd->hso_state = HSO_ENABLING; gcd->cb = cb; gcd->cb_data = cbd->data; return; } gcd->active_context = 0; decode_at_error(&error, g_at_result_final_response(result)); cb(&error, cbd->data); } static void hso_cgdcont_cb(gboolean ok, GAtResult *result, gpointer user_data) { struct cb_data *cbd = user_data; ofono_gprs_context_cb_t cb = cbd->cb; struct ofono_gprs_context *gc = cbd->user; struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); struct cb_data *ncbd; char buf[64]; if (!ok) { struct ofono_error error; gcd->active_context = 0; decode_at_error(&error, g_at_result_final_response(result)); cb(&error, cbd->data); return; } ncbd = g_memdup(cbd, sizeof(struct cb_data)); snprintf(buf, sizeof(buf), "AT_OWANCALL=%u,1,1", gcd->active_context); if (g_at_chat_send(gcd->chat, buf, none_prefix, at_owancall_up_cb, ncbd, g_free) > 0) return; g_free(ncbd); gcd->active_context = 0; CALLBACK_WITH_FAILURE(cb, cbd->data); } static void hso_gprs_activate_primary(struct ofono_gprs_context *gc, const struct ofono_gprs_primary_context *ctx, ofono_gprs_context_cb_t cb, void *data) { struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); struct cb_data *cbd = cb_data_new(cb, data); char buf[AUTH_BUF_LENGTH]; int len; /* IPv6 support not implemented */ if (ctx->proto != OFONO_GPRS_PROTO_IP) goto error; gcd->active_context = ctx->cid; cbd->user = gc; if (ctx->username[0] && ctx->password[0]) snprintf(buf, sizeof(buf), "AT$QCPDPP=%u,1,\"%s\",\"%s\"", ctx->cid, ctx->password, ctx->username); else if (ctx->password[0]) snprintf(buf, sizeof(buf), "AT$QCPDPP=%u,2,,\"%s\"", ctx->cid, ctx->password); else snprintf(buf, sizeof(buf), "AT$QCPDPP=%u,0", ctx->cid); if (g_at_chat_send(gcd->chat, buf, none_prefix, NULL, NULL, NULL) == 0) goto error; len = snprintf(buf, sizeof(buf), "AT+CGDCONT=%u,\"IP\"", ctx->cid); if (ctx->apn) snprintf(buf + len, sizeof(buf) - len - 3, ",\"%s\"", ctx->apn); if (g_at_chat_send(gcd->chat, buf, none_prefix, hso_cgdcont_cb, cbd, g_free) > 0) return; error: g_free(cbd); CALLBACK_WITH_FAILURE(cb, data); } static void hso_gprs_deactivate_primary(struct ofono_gprs_context *gc, unsigned int cid, ofono_gprs_context_cb_t cb, void *data) { struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); struct cb_data *cbd = cb_data_new(cb, data); char buf[128]; cbd->user = gc; snprintf(buf, sizeof(buf), "AT_OWANCALL=%u,0,1", cid); if (g_at_chat_send(gcd->chat, buf, none_prefix, at_owancall_down_cb, cbd, g_free) > 0) return; g_free(cbd); CALLBACK_WITH_FAILURE(cb, data); } static void owandata_cb(gboolean ok, GAtResult *result, gpointer user_data) { struct ofono_gprs_context *gc = user_data; struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); GAtResultIter iter; int cid; const char *ip = NULL; const char *gateway = NULL; const char *dns1 = NULL; const char *dns2 = NULL; const char *dns[3]; struct ofono_modem *modem; const char *interface; if (!ok) return; g_at_result_iter_init(&iter, result); if (g_at_result_iter_next(&iter, "_OWANDATA:") == FALSE) return; g_at_result_iter_next_number(&iter, &cid); g_at_result_iter_next_unquoted_string(&iter, &ip); g_at_result_iter_next_unquoted_string(&iter, &gateway); g_at_result_iter_next_unquoted_string(&iter, &dns1); g_at_result_iter_next_unquoted_string(&iter, &dns2); if (ip && ip[0] == ' ') ip += 1; if (gateway && gateway[0] == ' ') gateway += 1; if (dns1 && dns1[0] == ' ') dns1 += 1; if (dns2 && dns2[0] == ' ') dns2 += 1; /* Don't bother reporting the same DNS twice */ if (g_str_equal(dns1, dns2)) dns2 = NULL; dns[0] = dns1; dns[1] = dns2; dns[2] = 0; modem = ofono_gprs_context_get_modem(gc); interface = ofono_modem_get_string(modem, "NetworkInterface"); ofono_info("Got the following parameters for context: %d", cid); ofono_info("IP: %s, Gateway: %s", ip, gateway); ofono_info("DNS: %s, %s", dns1, dns2); ofono_gprs_context_set_interface(gc, interface); ofono_gprs_context_set_ipv4_address(gc, ip, TRUE); ofono_gprs_context_set_ipv4_netmask(gc, STATIC_IP_NETMASK); ofono_gprs_context_set_ipv4_gateway(gc, gateway); ofono_gprs_context_set_ipv4_dns_servers(gc, dns); CALLBACK_WITH_SUCCESS(gcd->cb, gcd->cb_data); gcd->hso_state = HSO_NONE; gcd->cb = NULL; gcd->cb_data = NULL; } static void owancall_notifier(GAtResult *result, gpointer user_data) { struct ofono_gprs_context *gc = user_data; struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); GAtResultIter iter; int state; int cid; if (gcd->active_context == 0) return; g_at_result_iter_init(&iter, result); if (g_at_result_iter_next(&iter, "_OWANCALL:") == FALSE) return; g_at_result_iter_next_number(&iter, &cid); g_at_result_iter_next_number(&iter, &state); if (gcd->active_context != (unsigned int) cid) return; switch (state) { case HSO_DISCONNECTED: DBG("HSO Context: disconnected"); if (gcd->hso_state == HSO_DISABLING) { CALLBACK_WITH_SUCCESS(gcd->cb, gcd->cb_data); gcd->hso_state = HSO_NONE; gcd->cb = NULL; gcd->cb_data = NULL; } else { ofono_gprs_context_deactivated(gc, gcd->active_context); } gcd->active_context = 0; break; case HSO_CONNECTED: DBG("HSO Context: connected"); if (gcd->hso_state == HSO_ENABLING) { char buf[128]; snprintf(buf, sizeof(buf), "AT_OWANDATA=%u", gcd->active_context); g_at_chat_send(gcd->chat, buf, owandata_prefix, owandata_cb, gc, NULL); } break; case HSO_FAILED: DBG("HSO Context: failed"); if (gcd->hso_state == HSO_ENABLING) { CALLBACK_WITH_FAILURE(gcd->cb, gcd->cb_data); gcd->hso_state = HSO_NONE; gcd->cb = NULL; gcd->cb_data = NULL; } gcd->active_context = 0; break; default: break; }; gcd->owancall = state; } static int hso_gprs_context_probe(struct ofono_gprs_context *gc, unsigned int vendor, void *data) { GAtChat *chat = data; struct gprs_context_data *gcd; gcd = g_new0(struct gprs_context_data, 1); gcd->chat = g_at_chat_clone(chat); g_at_chat_register(gcd->chat, "_OWANCALL:", owancall_notifier, FALSE, gc, NULL); ofono_gprs_context_set_data(gc, gcd); return 0; } static void hso_gprs_context_remove(struct ofono_gprs_context *gc) { struct gprs_context_data *gcd = ofono_gprs_context_get_data(gc); ofono_gprs_context_set_data(gc, NULL); g_at_chat_unref(gcd->chat); g_free(gcd); } static struct ofono_gprs_context_driver driver = { .name = "hsomodem", .probe = hso_gprs_context_probe, .remove = hso_gprs_context_remove, .activate_primary = hso_gprs_activate_primary, .deactivate_primary = hso_gprs_deactivate_primary, }; void hso_gprs_context_init(void) { ofono_gprs_context_driver_register(&driver); } void hso_gprs_context_exit(void) { ofono_gprs_context_driver_unregister(&driver); }