/*
- * tel-plugin-packetservice
+ * PacketService Control Module
*
* Copyright (c) 2012 Samsung Electronics Co., Ltd. All rights reserved.
*
* Contact: DongHoo Park <donghoo.park@samsung.com>
+ * Arun Shukla <arun.shukla@samsung.com>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
*
*/
-#include "ps-service.h"
-
#include "ps.h"
-#include "ps-error.h"
+#include "generated-code.h"
#include <core_object.h>
#include <co_ps.h>
+#include <co_context.h>
+#include <storage.h>
#define PROP_DEFAULT FALSE
#define PROP_DEFAULT_STR NULL
#define BOOL2STRING(a) ((a==TRUE) ? ("TRUE"):("FALSE"))
#define TIMEOUT_DEFAULT 5
-#define TIMEOUT_MAX 1280
-
-guint connection_timeout;
-guint timer_src;
-
-/*Properties*/
-
-enum {
- PROP_SERVICE_O,
-
- PROP_SERVICE_PATH,
- PROP_SERVICE_PLUGIN,
- PROP_SERVICE_CONN,
- PROP_SERVICE_P_MODEM,
- PROP_SERVICE_CO_NETWORK,
- PROP_SERVICE_CO_PS
-};
-
-enum {
- SIG_SERVICE_CONTEXT_ADDED,
- SIG_SERVICE_CONTEXT_REMOVED,
- SIG_SERVICE_PROPERTY_CHANGED,
- SIG_SERVICE_LAST
-};
-
-static guint32 signals[SIG_SERVICE_LAST] = {0,};
-
-struct PsServiceClass {
- GObjectClass parent;
-
- //method and signals
- void (*context_added)(PsService *service, gchar *context_path);
- void (*context_removed)(PsService *service, gchar *context_path);
- void (*property_changed)(PsService *service, GHashTable *service_property);
-};
-
-struct PsService {
- GObject parent;
-
- gchar *path;
- TcorePlugin *plg;
- DBusGConnection *conn;
- gpointer p_modem;
- CoreObject *co_network;
- CoreObject *co_ps;
-
- gboolean ps_attached;
- gboolean roaming;
- enum telephony_network_access_technology act;
-
- GHashTable *contexts;
-};
-
-G_DEFINE_TYPE(PsService, ps_service, G_TYPE_OBJECT);
-
-/*Function Declaration*/
-static void __ps_service_get_property(GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
-static void __ps_service_set_property(GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
-
-gboolean ps_iface_service_get_properties(PsService *service, DBusGMethodInvocation *context);
-gboolean ps_iface_service_get_contexts(PsService *service, DBusGMethodInvocation *context);
-
-static void __ps_service_emit_property_changed_signal(PsService *service);
-static void __ps_service_emit_context_added_signal(PsService *service, gpointer context);
-static void __ps_service_emit_context_removed_signal(PsService *service, gpointer context);
-
-static void __remove_context(gpointer data);
-static char *__ps_service_act2string(enum telephony_network_access_technology act);
-static gboolean __ps_service_check_connection_option(gpointer service);
-static gboolean __ps_service_connetion_timeout_handler(gpointer user_data);
-
-#include "ps-iface-service-glue.h"
-
-static void ps_service_init(PsService *service)
-{
- dbg("service initialize");
+#define TIMEOUT_MAX 1800
- service->path = PROP_DEFAULT_STR;
- service->plg = NULL;
- service->conn = NULL;
- service->p_modem = NULL;
- service->co_network = NULL;
- service->co_ps = NULL;
- service->ps_attached = PROP_DEFAULT;
- service->roaming = PROP_DEFAULT;
- service->act = NETWORK_ACT_UNKNOWN;
+static void __ps_service_emit_property_changed_signal(ps_service_t *service);
+static void __ps_service_emit_context_added_signal(ps_service_t *service, gpointer context);
+static void __ps_service_emit_context_removed_signal(ps_service_t *service, gpointer context);
+static void _ps_service_setup_interface(PacketServiceService *service, ps_service_t *service_data);
- service->contexts = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, __remove_context);
- return;
-}
+static char * __ps_service_act2string(enum telephony_network_access_technology act);
+static gboolean __ps_service_check_connection_option(gpointer service, gpointer context);
+static int __ps_service_connetion_timeout_handler(alarm_id_t alarm_id, void *context);
-static void ps_service_class_init(PsServiceClass *klass)
+void __remove_service_handler(gpointer data)
{
- GObjectClass *object_class = G_OBJECT_CLASS(klass);
-
- //class init
- dbg("class init");
-
- object_class->get_property = __ps_service_get_property;
- object_class->set_property = __ps_service_set_property;
-
- //dbus register
- dbus_g_object_type_install_info(PS_TYPE_SERVICE, &dbus_glib_ps_iface_service_object_info);
-
- //add properties
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_PATH,
- g_param_spec_string("path", "PATH", "Technology Path", NULL,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
-
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_P_MODEM,
- g_param_spec_pointer("p_modem", "MODEM", "Parent Modem Object",
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
-
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_PLUGIN,
- g_param_spec_pointer("plg", "PLUGIN", "Plug in Object",
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
-
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_CO_NETWORK,
- g_param_spec_pointer("co_network", "COREOBJECT NETWORK", "CoreObject of Network",
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
-
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_CO_PS,
- g_param_spec_pointer("co_ps", "COREOBJECTPS", "CoreObject of PS",
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
+ ps_service_t *service = data;
- g_object_class_install_property(
- object_class,
- PROP_SERVICE_CONN,
- g_param_spec_boxed("conn", "CONNECTION", "DBus connection", DBUS_TYPE_G_CONNECTION,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
+ dbg("Entered");
+ if(!service){
+ dbg("Service is Null");
+ return;
+ }
- //add signal handler
- signals[SIG_SERVICE_CONTEXT_ADDED] = g_signal_new("context-added", G_OBJECT_CLASS_TYPE(klass),
- G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET(PsServiceClass, context_added), NULL, NULL,
- g_cclosure_marshal_VOID__BOXED, G_TYPE_NONE, 1, DBUS_TYPE_G_STRING_STRING_HASHTABLE);
+ /*Need to remove the compelete hash table*/
+ g_hash_table_remove_all(service->contexts);
- signals[SIG_SERVICE_CONTEXT_REMOVED] = g_signal_new("context-removed",
- G_OBJECT_CLASS_TYPE(klass), G_SIGNAL_RUN_LAST,
- G_STRUCT_OFFSET(PsServiceClass, context_removed), NULL, NULL,
- g_cclosure_marshal_VOID__STRING, G_TYPE_NONE, 1, DBUS_TYPE_G_OBJECT_PATH);
+ /*Need to UNexport and Unref the master Object */
+ if(service->if_obj){
+ g_dbus_interface_skeleton_unexport(G_DBUS_INTERFACE_SKELETON(service->if_obj));
+ g_object_unref(service->if_obj);
+ service->if_obj = NULL;
+ }
- signals[SIG_SERVICE_PROPERTY_CHANGED] = g_signal_new("property-changed",
- G_OBJECT_CLASS_TYPE(klass), G_SIGNAL_RUN_LAST,
- G_STRUCT_OFFSET(PsServiceClass, property_changed), NULL, NULL,
- g_cclosure_marshal_VOID__BOXED, G_TYPE_NONE, 1, DBUS_TYPE_G_STRING_STRING_HASHTABLE);
+ /*Need to free the memory of the internal structure*/
+ g_free(service->path);
+ g_free(service);
+ dbg("Exiting");
return;
}
-static void __ps_service_get_property(GObject *object, guint prop_id, GValue *value,
- GParamSpec *pspec)
+static void __ps_service_emit_property_changed_signal(ps_service_t *service)
{
- return;
-}
+ GVariant *gv = NULL;
+ GVariantBuilder property;
-static void __ps_service_set_property(GObject *object, guint prop_id, const GValue *value,
- GParamSpec *pspec)
-{
- PsService *service = PS_SERVICE(object);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "get service properties");
- switch (prop_id) {
- case PROP_SERVICE_PATH: {
- if (service->path) g_free(service->path);
- service->path = g_value_dup_string(value);
- msg("service(%p) set path(%s)", service, service->path);
- }
- break;
- case PROP_SERVICE_P_MODEM: {
- service->p_modem = g_value_get_pointer(value);
- msg("service(%p) set modem(%p)", service, service->p_modem);
- }
- break;
- case PROP_SERVICE_PLUGIN: {
- service->plg = g_value_get_pointer(value);
- msg("service(%p) set plg(%p)", service, service->plg);
- }
- break;
- case PROP_SERVICE_CO_NETWORK: {
- service->co_network = g_value_get_pointer(value);
- msg("service(%p) set co_network(%p)", service, service->co_network);
- }
- break;
- case PROP_SERVICE_CO_PS: {
- service->co_ps = g_value_get_pointer(value);
- msg("service(%p) set co_ps(%p)", service, service->co_ps);
- }
- break;
- case PROP_SERVICE_CONN: {
- service->conn = g_value_get_boxed(value);
- msg("service(%p) set conn(%p)", service, service->conn);
- }
- break;
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
- break;
- } //swtich end
+ gv = _ps_service_get_properties(service, &property);
+ packet_service_service_emit_property_changed(service->if_obj, gv);
+ dbg("Exiting");
return;
}
-gboolean ps_iface_service_get_properties(PsService *service, DBusGMethodInvocation *context)
+static void __ps_service_emit_context_added_signal(ps_service_t *service, gpointer context)
{
- GError *error = NULL;
- gboolean rv = FALSE;
- GHashTable *properties = NULL;
-
- dbg("get service properties");
-
- properties = g_hash_table_new(g_str_hash, g_str_equal);
- rv = _ps_service_get_properties(service, properties);
- if (rv != TRUE) {
- g_set_error(&error, PS_ERROR, PS_ERR_INTERNAL, "fail to get properties service(%p)",
- service);
- dbus_g_method_return_error(context, error);
- g_hash_table_destroy(properties);
- return FALSE;
- }
+ GVariant *gv = NULL;
+ GVariantBuilder property;
- dbus_g_method_return(context, properties);
- g_hash_table_destroy(properties);
- return TRUE;
-}
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "get service properties");
-gboolean ps_iface_service_get_contexts(PsService *service, DBusGMethodInvocation *context)
-{
- GError *error = NULL;
- GHashTableIter iter;
- gpointer key, value;
- GHashTable *contexts;
-
- dbg("service get contexts interface");
-
- if (service->contexts == NULL) {
- g_set_error(&error, PS_ERROR, PS_ERR_INTERNAL, "service(%p) does not have contexts",
- service);
- dbus_g_method_return_error(context, error);
- return FALSE;
- }
-
- contexts = g_hash_table_new_full(g_direct_hash, g_str_equal, g_free,
- (GDestroyNotify) g_hash_table_destroy);
-
- g_hash_table_iter_init(&iter, service->contexts);
- while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
- gboolean rv = FALSE;
- gchar *path = NULL;
- GHashTable *properties = NULL;
-
- properties = g_hash_table_new(g_str_hash, g_str_equal);
- rv = _ps_context_get_properties(value, properties);
- if (rv != TRUE) {
- g_set_error(&error, PS_ERROR, PS_ERR_INTERNAL, "fail to get properties context(%p)",
- value);
- dbus_g_method_return_error(context, error);
- g_hash_table_destroy(properties);
- g_hash_table_destroy(contexts);
- return FALSE;
- }
-
- path = _ps_context_ref_path(value);
- g_hash_table_insert(contexts, g_strdup(path), properties);
- dbg("service (%p) inserted into hash", value);
- }
-
- dbus_g_method_return(context, contexts);
- g_hash_table_destroy(contexts);
-
- return TRUE;
-}
-
-static void __ps_service_emit_property_changed_signal(PsService *service)
-{
- GHashTable *properties = NULL;
-
- properties = g_hash_table_new(g_str_hash, g_str_equal);
- _ps_service_get_properties(service, properties);
- g_signal_emit(service, signals[SIG_SERVICE_PROPERTY_CHANGED], 0, properties);
- dbg("service (%p) emit property changed signal", service);
- g_hash_table_destroy(properties);
+ gv = _ps_context_get_properties(context, &property);
+ packet_service_service_emit_context_added(service->if_obj, gv);
+ dbg("Exiting");
return;
}
-static void __ps_service_emit_context_added_signal(PsService *service, gpointer context)
+static void __ps_service_emit_context_removed_signal(ps_service_t *service, gpointer context)
{
- GHashTable *properties = NULL;
+ ps_context_t *pscontext = context;
- properties = g_hash_table_new(g_str_hash, g_str_equal);
- _ps_context_get_properties(context, properties);
- g_signal_emit(service, signals[SIG_SERVICE_CONTEXT_ADDED], 0, properties);
- dbg("service (%p) emit the context(%p) added signal", service, context);
- g_hash_table_destroy(properties);
- return;
-}
+ dbg("Entered");
+ packet_service_service_emit_context_removed(service->if_obj, pscontext->path);
-static void __ps_service_emit_context_removed_signal(PsService *service, gpointer context)
-{
- g_signal_emit(service, signals[SIG_SERVICE_CONTEXT_REMOVED], 0, _ps_context_ref_path(context));
- dbg("service (%p) emit the context(%p) removed signal", service, context);
- return;
-}
-
-static void __remove_context(gpointer data)
-{
+ dbg("Exiting");
return;
}
return NULL;
}
-static gboolean __ps_service_check_connection_option(gpointer object)
+static gboolean __ps_service_check_connection_option(gpointer object, gpointer context)
{
gboolean b_connect = TRUE;
- gboolean power, sim, data, flight;
- PsService *service = object;
+ gboolean power = FALSE, sim = FALSE, data = FALSE, flight = FALSE, nw_ops = FALSE;
+ gboolean profile_reset = FALSE;
+
+ enum co_context_role role = CONTEXT_ROLE_UNKNOWN;
+ gint ps_mode;
+ guchar hook_flag;
+ ps_service_t *service = object;
+ ps_modem_t *modem = _ps_service_ref_modem(service);
+ CoreObject *co_context = context;
+ CoreObject *co_network = _ps_service_ref_co_network(service);
+
+ role = tcore_context_get_role(co_context);
if(service->roaming){
- b_connect &=_ps_modem_get_data_roaming_allowed(service->p_modem);
+ b_connect &=_ps_modem_get_data_roaming_allowed(modem);
}
- power = _ps_modem_get_power(service->p_modem);
- sim = _ps_modem_get_sim_init(service->p_modem);
- data = _ps_modem_get_data_allowed(service->p_modem);
- flight = _ps_modem_get_flght_mode(service->p_modem);
+ sim = _ps_modem_get_sim_init(modem);
+ data = _ps_modem_get_data_allowed(modem);
+ flight = _ps_modem_get_flght_mode(modem);
+ hook_flag = _ps_modem_get_hook_flag(modem);
+ profile_reset = _ps_modem_get_reset_profile(modem);
+ if(hook_flag != PS_NO_PENDING_REQUEST)
+ nw_ops = TRUE;
+ if(PS_MODEM_STATE_ONLINE == _ps_modem_get_power(modem))
+ power = TRUE;
+
b_connect &= power;
b_connect &= sim;
- b_connect &= data;
+
+#if defined(TIZEN_SUPPORT_MMS_CONNECT_FORCE)
+ ps_dbg_ex_co(co_network, "csc runtime feature enabled");
+ if(role != CONTEXT_ROLE_MMS && role != CONTEXT_ROLE_PREPAID_MMS){
+ b_connect &= data;
+ } else {
+ char *tmp_apn = NULL;
+ tmp_apn = tcore_context_get_apn(co_context);
+ dbg("csc runtime feature is enabled: apn[%s]", tmp_apn);
+ if(ps_feature_get_bool(PS_FEATURE_OPERATOR_SKT)) {
+ if(data)
+ tcore_context_set_apn(co_context, "web.sktelecom.com");
+ else
+ tcore_context_set_apn(co_context, "mmsonly.sktelecom.com");
+ }
+ }
+#else
+ if (role == CONTEXT_ROLE_IMS || role == CONTEXT_ROLE_IMS_EMERGENCY) {
+ dbg("Do not check data allowed value in case of IMS type");
+ } else {
+ ps_dbg_ex_co(co_network, "csc runtime feature disabled");
+ b_connect &= data;
+ }
+#endif
+
b_connect &= !flight;
- dbg("power(%d), sim init(%d), data allowed(%d), flight mode(%d)", power, sim, data, flight);
+ b_connect &= !nw_ops;
+ b_connect &= !service->restricted;
+ b_connect &= !profile_reset;
+#ifndef TIZEN_PS_FORCE_ATTACH_DETACH
+ b_connect &= service->ps_attached;
+#endif
+ ps_mode = _ps_modem_get_psmode(modem);
+
+
+ if(service->initial_pdp_conn == FALSE) {
+ int wifi_state = PS_WIFI_STATE_OFF;
+ Server *s = NULL;
+ Storage *strg = NULL;
+
+ s = tcore_plugin_ref_server(service->plg);
+ strg = tcore_server_find_storage(s, "vconf");
+ wifi_state = tcore_storage_get_int(strg, KEY_WIFI_STATE);
+ if(wifi_state == PS_WIFI_STATE_CONNECTED) {
+ if (service->wifi_connected_checked == FALSE) {
+ ps_dbg_ex_co(co_network, "DO NOT set PDP retry timer when WiFi connected but PDP never been connected yet.");
+ b_connect &= FALSE;
+ service->wifi_connected_checked = TRUE;
+ } else {
+ ps_dbg_ex_co(co_network, "Wifi connected state was already checked.");
+ }
+ }
+ }
+ ps_dbg_ex_co(co_network, "b_connect(%d), power(%d), sim init(%d), data allowed(%d), flight mode(%d) restricted(%d) ps_attached(%d), ps_mode(%d), fook_flag(%d)",
+ b_connect, power, sim, data, flight, service->restricted, service->ps_attached, ps_mode, hook_flag);
return b_connect;
}
-static gboolean __ps_service_connetion_timeout_handler(gpointer context)
+static int __ps_service_connetion_timeout_handler(alarm_id_t alarm_id, void *context)
{
int rv = 0;
- PsService *service = NULL;
+ ps_service_t *service = _ps_context_ref_service(context);
+ if(service == NULL) {
+ err("service is NULL!!!");
+ return rv;
+ }
- service = _ps_context_ref_service(context);
+ if (service->timer_src > 0) {
+ dbg("remove connection retry timer (%d)", service->timer_src);
+ alarmmgr_remove_alarm(service->timer_src);
+ service->timer_src = 0;
+ }
rv = _ps_service_activate_context(service, context);
- dbg("return rv(%d)", rv);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "return rv(%d)", rv);
+ return rv;
+}
+
+static void __ps_service_set_attach_apn(ps_service_t *service)
+{
+ GHashTableIter iter;
+ gpointer key, ps_context;
+ CoreObject *co_context;
+ gboolean attach_apn = FALSE;
+ enum co_context_role role;
- return FALSE;
+ g_hash_table_iter_init(&iter, service->contexts);
+ while (g_hash_table_iter_next(&iter, &key, &ps_context) == TRUE) {
+ co_context = _ps_context_ref_co_context(ps_context);
+ role = tcore_context_get_role(co_context);
+ attach_apn = tcore_context_get_attach_apn(co_context);
+ if (attach_apn) {
+ dbg("Set 'Attach APN' [%p]", co_context);
+ if (role != CONTEXT_ROLE_INTERNET)
+ _ps_context_set_only_attach(ps_context, TRUE);
+ tcore_ps_define_context(service->co_ps, co_context, NULL);
+ }
+ }
}
-gpointer _ps_service_create_service(DBusGConnection *conn, TcorePlugin *p, gpointer p_modem,
+gpointer _ps_service_create_service(GDBusConnection *conn, TcorePlugin *p, gpointer p_modem,
CoreObject *co_network, CoreObject *co_ps, gchar* path)
{
- guint rv = 0;
- GObject *object;
- DBusGProxy *proxy;
+ PacketServiceService *service;
GError *error = NULL;
+ ps_service_t *new_service;
- dbg("Create SERVICE object - Path: [%s]", path);
+ ps_dbg_ex_co(co_network, "service object create");
g_return_val_if_fail(conn != NULL, NULL);
g_return_val_if_fail(p_modem != NULL, NULL);
- /* Create new Proxy */
- proxy = dbus_g_proxy_new_for_name(conn, "org.freedesktop.DBus", "/org/freedesktop/DBus",
- "org.freedesktop.DBus");
+ /*creating the master object for the interface com.tcore.ps.modem*/
+ service = packet_service_service_skeleton_new();
+
+ /*Initializing the modem list for internal referencing*/
+ new_service = g_try_malloc0(sizeof(ps_service_t));
+ if(NULL == new_service){
+ ps_err_ex_co(co_network, "Unable to allocate memory for master");
+ goto FAILURE;
+ }
- if (!dbus_g_proxy_call(proxy, "RequestName", &error, G_TYPE_STRING, PS_DBUS_SERVICE,
- G_TYPE_UINT, 0, G_TYPE_INVALID, G_TYPE_UINT, &rv, G_TYPE_INVALID)) {
- err("Failed to acquire context(%s) error(%s)", PS_DBUS_SERVICE, error->message);
- return NULL;
+ new_service->conn = conn;
+ new_service->plg = p;
+ new_service->p_modem = p_modem;
+ new_service->co_network = co_network;
+ new_service->co_ps = co_ps;
+ new_service->path = g_strdup(path);
+ new_service->if_obj = service;
+ new_service->contexts = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, NULL);
+
+ /*exporting the interface object to the path mention for master*/
+ if(TRUE != g_dbus_interface_skeleton_export((G_DBUS_INTERFACE_SKELETON(service)), conn, path, &error)) {
+ ps_err_ex_co(co_network, "Failed to export interaface with message [%s] & ID[%d] ", error->message, error->code);
+ goto FAILURE;
}
- dbg("Acquired context: [%s]", PS_DBUS_SERVICE);
- /* Creating new Service object */
- object = g_object_new(PS_TYPE_SERVICE, "conn", conn, "plg", p, "p_modem", p_modem, "co_network",
- co_network, "co_ps", co_ps, "path", path, NULL);
+ _ps_hook_co_network_event(new_service);
+ _ps_get_co_network_values(new_service);
+ _ps_hook_co_ps_event(new_service);
- _ps_hook_co_network_event(object);
- _ps_get_co_network_values(object);
- _ps_hook_co_ps_event(object);
+ /*Setting up the interface for the service */
+ _ps_service_setup_interface(service, new_service);
- dbus_g_connection_register_g_object(conn, path, object);
- msg("service(%p) register dbus path(%s)", object, path);
+ new_service->connection_timeout = TIMEOUT_DEFAULT;
+ ps_dbg_ex_co(co_network, "Successfully Created the service");
+ return new_service;
- return object;
+FAILURE:
+ /*To Do: Handle failure case*/
+ g_free(new_service);
+ g_assert_no_error (error);
+ return NULL;
}
gboolean _ps_service_ref_context(gpointer object, gpointer context)
{
gpointer tmp = NULL;
gchar *s_path = NULL;
- PsService *service = object;
+ ps_service_t *service = object;
+ CoreObject *co_network = NULL;
dbg("service refer to context");
g_return_val_if_fail(service != NULL, FALSE);
+ co_network = _ps_service_ref_co_network(service);
s_path = _ps_context_ref_path(context);
tmp = g_hash_table_lookup(service->contexts, s_path);
if (tmp != NULL) {
- dbg("context(%p) already existed", tmp);
+ ps_dbg_ex_co(co_network, "context(%p) already existed", tmp);
return FALSE;
}
tcore_ps_add_context(service->co_ps, (CoreObject *) _ps_context_ref_co_context(context));
g_hash_table_insert(service->contexts, g_strdup(s_path), context);
- dbg("context(%p) insert to hash", context);
+ ps_dbg_ex_co(co_network, "context(%p) insert to hash", context);
__ps_service_emit_context_added_signal(service, context);
//_ps_service_connect_default_context(service);
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = object;
+ ps_service_t *service = object;
gboolean ret = TRUE;
int rv;
+ CoreObject *co_network = NULL;
- dbg("Service refer to Contexts");
-
+ dbg("service refer to contexts");
g_return_val_if_fail(service != NULL, FALSE);
+ co_network = _ps_service_ref_co_network(service);
g_hash_table_iter_init(&iter, contexts);
while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
gchar *s_path = NULL;
gboolean f_awo = FALSE;
s_path = _ps_context_ref_path(value);
- dbg("Path: [%s]", s_path);
-
- /* Hash lookup */
tmp = g_hash_table_lookup(service->contexts, s_path);
if (tmp != NULL) {
- dbg("context [0x%x] already existed", tmp);
+ ps_dbg_ex_co(co_network, "context(%p) already existed", tmp);
continue;
}
- /* Setting service */
_ps_context_set_service(value, service);
-
- /* Add Context to PS Core object */
- tcore_ps_add_context(service->co_ps, (CoreObject *)_ps_context_ref_co_context(value));
-
- /* Insert conetxt to Hash Table */
+ tcore_ps_add_context(service->co_ps, (CoreObject *) _ps_context_ref_co_context(value));
g_hash_table_insert(service->contexts, g_strdup(s_path), value);
- dbg("Inserted context to Hash table - context [0x%x]", value);
-
- /* Emit Context added signal */
+ ps_dbg_ex_co(co_network, "context(%p) insert to hash", value);
__ps_service_emit_context_added_signal(service, value);
f_awo = _ps_context_get_alwayson_enable(value);
- dbg("Always ON: [%s]", (f_awo ? "YES" : "NO"));
- if(f_awo) {
- dbg("Define Context");
+ if(f_awo){
rv = _ps_service_define_context(service, value);
- dbg("return rv(%d)", rv);
+ ps_dbg_ex_co(co_network, "return rv(%d)", rv);
}
}
- /* Update cellular state key */
_ps_update_cellular_state_key(service);
//_ps_service_connect_default_context(service);
-
return ret;
}
gboolean _ps_service_unref_context(gpointer object, gpointer context)
{
- PsService *service = object;
+ ps_service_t *service = object;
dbg("service unref contexts");
g_return_val_if_fail(service != NULL, FALSE);
g_return_val_if_fail(context != NULL, FALSE);
- dbg("remove context(%p) from service(%p)", context, service);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "remove context(%p) from service(%p)", context, service);
tcore_ps_remove_context(service->co_ps, (CoreObject *) _ps_context_ref_co_context(context));
g_hash_table_remove(service->contexts, _ps_context_ref_path(context));
__ps_service_emit_context_removed_signal(service, context);
return TRUE;
}
-gboolean _ps_service_get_properties(gpointer object, GHashTable *properties)
+gboolean _ps_service_get_properties_handler(gpointer object, GVariantBuilder *properties)
{
- PsService *service = object;
+ ps_service_t *service = object;
dbg("get service properties");
g_return_val_if_fail(service != NULL, FALSE);
g_return_val_if_fail(properties != NULL, FALSE);
- g_hash_table_insert(properties, "path", g_strdup(service->path));
- g_hash_table_insert(properties, "ps_attached", BOOL2STRING(service->ps_attached));
- g_hash_table_insert(properties, "roaming", BOOL2STRING(service->roaming));
- g_hash_table_insert(properties, "act", __ps_service_act2string(service->act));
+ g_variant_builder_open(properties, G_VARIANT_TYPE("a{ss}"));
+ g_variant_builder_add(properties, "{ss}", "path", service->path);
+ g_variant_builder_add(properties, "{ss}", "ps_attached", BOOL2STRING(service->ps_attached));
+ g_variant_builder_add(properties, "{ss}", "roaming", BOOL2STRING(service->roaming));
+ g_variant_builder_add(properties, "{ss}", "act", __ps_service_act2string(service->act));
+ g_variant_builder_close(properties);
+ dbg("Exiting");
return TRUE;
}
+GVariant * _ps_service_get_properties(gpointer object, GVariantBuilder *properties)
+{
+ ps_service_t *service = object;
+
+ dbg("get service properties ");
+ g_return_val_if_fail(service != NULL, FALSE);
+ g_return_val_if_fail(properties != NULL, FALSE);
+
+ g_variant_builder_init(properties, G_VARIANT_TYPE("a{ss}"));
+
+ g_variant_builder_add(properties, "{ss}", "path", service->path);
+ g_variant_builder_add(properties, "{ss}", "ps_attached", BOOL2STRING(service->ps_attached));
+ g_variant_builder_add(properties, "{ss}", "roaming", BOOL2STRING(service->roaming));
+ g_variant_builder_add(properties, "{ss}", "act", __ps_service_act2string(service->act));
+
+ dbg("Exiting");
+ return g_variant_builder_end(properties);
+}
+
gchar* _ps_service_ref_path(gpointer object)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, NULL);
return service->path;
gpointer _ps_service_ref_plugin(gpointer object)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, NULL);
return service->plg;
gpointer _ps_service_ref_co_network(gpointer object)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, NULL);
return service->co_network;
gpointer _ps_service_ref_co_ps(gpointer object)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, NULL);
return service->co_ps;
}
+gpointer _ps_service_ref_modem(gpointer object)
+{
+ ps_service_t *service = object;
+ g_return_val_if_fail(service != NULL, NULL);
+
+ return service->p_modem;
+}
+
gboolean _ps_service_set_context_info(gpointer object, struct tnoti_ps_pdp_ipconfiguration *devinfo)
{
GSList* contexts = NULL;
- PsService *service = object;
-
- dbg("Set context information");
+ ps_service_t *service = object;
+ CoreObject *co_context = NULL;
+ dbg("set context info");
g_return_val_if_fail(service != NULL, FALSE);
- /* Refer context */
- dbg("Context ID: [%d]", devinfo->context_id);
contexts = tcore_ps_ref_context_by_id(service->co_ps, devinfo->context_id);
- if (NULL == contexts) {
- dbg("Failed to refer context");
+ if (!contexts) {
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "fail to ref context by cid.");
return FALSE;
}
- for (; contexts != NULL; contexts = g_slist_next(contexts)) {
- CoreObject *co_context = NULL;
-
+ while (contexts) {
co_context = contexts->data;
- if (NULL == co_context) {
- dbg("Context is NULL");
+ if (!co_context) {
+ contexts = contexts->next;
continue;
}
- /* Set device information */
tcore_context_set_devinfo(co_context, devinfo);
+
+ contexts = contexts->next;
}
return TRUE;
int _ps_service_define_context(gpointer object, gpointer context)
{
- PsService *service = object;
+ ps_service_t *service = object;
CoreObject *co_context = NULL;
gboolean b_connect = TRUE;
co_context = (CoreObject *)_ps_context_ref_co_context(context);
- b_connect = __ps_service_check_connection_option(service);
+ b_connect = __ps_service_check_connection_option(service, co_context);
if(!b_connect)
return TCORE_RETURN_EPERM;
int _ps_service_activate_context(gpointer object, gpointer context)
{
- PsService *service = object;
+ ps_service_t *service = object;
+ ps_modem_t *modem = NULL;
CoreObject *co_context = NULL;
gboolean b_connect = TRUE;
gboolean ps_defined;
int ret = TCORE_RETURN_FAILURE;
+ int default_data_subs = 1;
+ ps_subs_type subs_type = 1;
+ Server *s = NULL;
+ static Storage *strg;
+ CoreObject *co_network = NULL;
- dbg("Activate context [0x%x]", context);
- g_return_val_if_fail(service != NULL, TCORE_RETURN_EINVAL);
+ dbg("activate context(%p)", context);
+ g_return_val_if_fail(service != NULL, FALSE);
- co_context = (CoreObject *)_ps_context_ref_co_context(context);
+ s = tcore_plugin_ref_server(_ps_service_ref_plugin(service));
+ strg = tcore_server_find_storage(s, "vconf");
- /* Check for connection option */
- b_connect = __ps_service_check_connection_option(service);
- dbg("Service option - PS Attached: [%s]", (service->ps_attached ? "YES" : "NO"));
+ co_network = _ps_service_ref_co_network(service);
+ modem = _ps_service_ref_modem(service);
+ if(modem->hook_flag != PS_NO_PENDING_REQUEST){
+ ps_dbg_ex_co(co_network, "Pending request present in queue with flag %x", modem->hook_flag);
+ return TCORE_RETURN_FAILURE;
+ }
- b_connect &= service->ps_attached;
- dbg("Connect: [%s]", (b_connect ? "YES" : "NO"));
+ /* Check for default data subscription value if matchs for modem then only activate */
+ subs_type = _ps_modem_get_subs_type(modem);
+
+ default_data_subs = tcore_storage_get_int(strg, STORAGE_KEY_TELEPHONY_DUALSIM_DEFAULT_DATA_SERVICE_INT);
+ if ((default_data_subs != -1) && ( default_data_subs != (int)subs_type)) {
+ ps_warn_ex_co(co_network, "activation for only [SIM%d] selected by Setting", default_data_subs + 1);
+ return TCORE_RETURN_FAILURE;
+ }
+
+ co_context = (CoreObject *)_ps_context_ref_co_context(context);
+
+ b_connect = __ps_service_check_connection_option(service, co_context);
if(!b_connect)
return TCORE_RETURN_EPERM;
ps_defined = _ps_context_get_ps_defined(context);
if(!ps_defined) {
- dbg("PDP profile is NOT defined!!! Need to define it first...");
+ ps_dbg_ex_co(co_network, "pdp profile is not defined yet, define first. ");
ret = tcore_ps_define_context(service->co_ps, co_context, NULL);
}
else {
- dbg("PDP profile is defined!!! Activate context...");
+ ps_dbg_ex_co(co_network, "pdp profile is defined, activate context. ");
ret = tcore_ps_activate_context(service->co_ps, co_context, NULL);
}
gboolean _ps_service_deactivate_context(gpointer object, gpointer context)
{
- PsService *service = object;
+ ps_service_t *service = object;
CoreObject *co_context = NULL;
- dbg("deactivate context(%p)", context);
g_return_val_if_fail(service != NULL, FALSE);
-
+ dbg("deactivate context(%p)", context);
co_context = (CoreObject *)_ps_context_ref_co_context(context);
return tcore_ps_deactivate_context(service->co_ps, co_context, NULL);
}
+void _ps_service_set_retry_timeout_value(gpointer object, int value)
+{
+ ps_service_t *service = object;
+ g_return_if_fail(service != NULL);
+
+ service->connection_timeout = value;
+ dbg("current timeout (%d)", service->connection_timeout);
+ return;
+}
+
void _ps_service_connection_timer(gpointer object, gpointer context)
{
+ int result = 0;
gboolean f_awo = FALSE;
+ ps_service_t *service = object;
+
+ g_return_if_fail(service != NULL);
f_awo = _ps_context_get_alwayson_enable(context);
if(!f_awo)
return;
- timer_src = g_timeout_add_seconds(connection_timeout, __ps_service_connetion_timeout_handler, context);
+ if (service->timer_src > 0) {
+ warn("remove connection retry timer (%d)", service->timer_src);
+ alarmmgr_remove_alarm(service->timer_src);
+ service->timer_src = 0;
+ }
+ result = alarmmgr_add_alarm_withcb(ALARM_TYPE_VOLATILE, (time_t)(service->connection_timeout),
+ 0, __ps_service_connetion_timeout_handler, context, &(service->timer_src));
+ if (result != ALARMMGR_RESULT_SUCCESS) {
+ err("Failed to add alarm(%d)", result);
+ return;
+ }
- dbg("cellular service timer started timer src(%d), timeout(%d)", timer_src, connection_timeout);
- connection_timeout = connection_timeout*2;
- if(connection_timeout > TIMEOUT_MAX)
- connection_timeout = TIMEOUT_MAX;
+ dbg("cellular service timer started timer src(%d), timeout(%d)", service->timer_src, service->connection_timeout);
+ service->connection_timeout = (service->connection_timeout)*2;
+ if(service->connection_timeout >= TIMEOUT_MAX)
+ service->connection_timeout = TIMEOUT_MAX;
return;
}
void _ps_service_reset_connection_timer(gpointer context)
{
gboolean f_awo = FALSE;
+ ps_service_t *service = NULL;
f_awo = _ps_context_get_alwayson_enable(context);
- dbg("Always ON: [%s]", (f_awo ? "YES" : "NO"));
- if(f_awo == FALSE)
+ if(!f_awo)
return;
- connection_timeout = TIMEOUT_DEFAULT;
-
- if (timer_src != 0) {
- dbg("Remove connection Retry timer [%d]", timer_src);
+ service = _ps_context_ref_service(context);
+ if(service == NULL) {
+ err("service is NULL!!!");
+ return;
+ }
+ service->connection_timeout = TIMEOUT_DEFAULT;
- g_source_remove(timer_src);
- timer_src = 0;
+ if (service->timer_src > 0) {
+ warn("remove connection retry timer (%d)", service->timer_src);
+ alarmmgr_remove_alarm(service->timer_src);
+ service->timer_src = 0;
}
+
+ return;
}
void _ps_service_remove_contexts(gpointer object)
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = object;
+ ps_service_t *service = object;
dbg("service remove all contexts");
g_return_if_fail(service != NULL);
while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
gpointer co_context = NULL;
- dbg("key(%s), value(%p) context", key, value);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "key(%s), value(%p) context", key, value);
co_context = _ps_context_ref_co_context(value);
_ps_service_reset_connection_timer(value);
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = object;
+ ps_service_t *service = object;
dbg("service disconnect all contexts");
g_return_if_fail(service != NULL);
return;
}
-void _ps_service_connect_default_context(gpointer object)
+void _ps_service_disconnect_internet_mms_contexts(gpointer object)
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = object;
+ ps_service_t *service = object;
+ CoreObject *co_context = NULL;
+ enum co_context_role role = CONTEXT_ROLE_UNKNOWN;
- dbg("Connect to 'default' context");
+ dbg("Service disconnect Internet/MMS contexts");
g_return_if_fail(service != NULL);
g_hash_table_iter_init(&iter, service->contexts);
while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
- gboolean f_awo = FALSE;
+ co_context = (CoreObject *)_ps_context_ref_co_context(value);
+ role = tcore_context_get_role(co_context);
+
+ /*
+ * Deactivate following type of contexts -
+ * - INTERNET
+ * - INTERNET_PREPAID
+ * - MMS
+ * - MMS_PREPAID
+ */
+ switch (role) {
+ case CONTEXT_ROLE_INTERNET:
+ case CONTEXT_ROLE_MMS:
+ case CONTEXT_ROLE_PREPAID_INTERNET:
+ case CONTEXT_ROLE_PREPAID_MMS:
+ _ps_service_reset_connection_timer(value);
+ _ps_service_deactivate_context(service, value);
+ break;
+
+ default: {
+ dbg("Need not deactivate for %d PDN type", role);
+ continue;
+ }
+ }
+ }
+}
+
+int _ps_service_connect_default_context(gpointer object)
+{
+ int rv = 0;
+ GHashTableIter iter;
+ gpointer key, value;
+ ps_service_t *service = object;
+ dbg("service connect default context");
+ g_return_val_if_fail(service != NULL, TCORE_RETURN_FAILURE);
+
+ g_hash_table_iter_init(&iter, service->contexts);
+ while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
+ gboolean f_awo = FALSE;
f_awo = _ps_context_get_alwayson_enable(value);
- dbg("Always ON: [%s]", (f_awo ? "YES" : "NO"));
- if(f_awo){
- int rv = 0;
+ if(f_awo){
_ps_service_reset_connection_timer(value);
-
- /* Activate context */
rv = _ps_service_activate_context(service, value);
- dbg("return rv(%d)", rv);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "return rv(%d)", rv);
break;
}
}
- return;
+ return rv;
}
-gpointer _ps_service_return_default_context(gpointer object)
+gpointer _ps_service_return_default_context(gpointer object, int svc_cat_id)
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, NULL);
g_hash_table_iter_init(&iter, service->contexts);
while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
gboolean b_default = FALSE;
- b_default = _ps_context_get_default_internet(value);
+ b_default = _ps_context_get_default_context(value, svc_cat_id);
if(b_default){
return value;
return NULL;
}
+int _ps_service_update_roaming_apn(gpointer object, const char* apn_str)
+{
+ int rv = 0;
+ GHashTableIter iter;
+ gpointer key, value;
+ ps_service_t *service = object;
+
+ g_return_val_if_fail(service != NULL, TCORE_RETURN_FAILURE);
+
+ g_hash_table_iter_init(&iter, service->contexts);
+ while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
+ CoreObject *co_context = NULL;
+ int role = CONTEXT_ROLE_UNKNOWN;
+ char *tmp_apn = NULL, *path = NULL;
+
+ co_context = (CoreObject *)_ps_context_ref_co_context(value);
+ role = tcore_context_get_role(co_context);
+ tmp_apn = tcore_context_get_apn(co_context);
+ path = _ps_context_ref_path(value);
+
+ if(role == CONTEXT_ROLE_INTERNET || role == CONTEXT_ROLE_MMS) {
+ dbg("context[%s]}, role[%d], apn[%s] -> apn[%s]", path, role, tmp_apn, apn_str);
+ tcore_context_set_apn(co_context, apn_str);
+ tcore_ps_deactivate_context(service->co_ps, co_context, NULL);
+ }
+ g_free(tmp_apn);
+ }
+ dbg("rv: %d", rv);
+ return rv;
+}
+
gboolean _ps_service_processing_network_event(gpointer object, gboolean ps_attached, gboolean roaming)
{
- PsService *service = object;
+ ps_service_t *service = object;
+ CoreObject *co_network = NULL;
+ gboolean prev_roaming_status;
g_return_val_if_fail(service != NULL, FALSE);
- _ps_update_cellular_state_key(service);
- if(service->ps_attached == ps_attached && service->roaming == roaming)
- return TRUE;
+ prev_roaming_status = _ps_service_get_roaming(service);
+
+ co_network = _ps_service_ref_co_network(service);
_ps_service_set_ps_attached(service, ps_attached);
_ps_service_set_roaming(service, roaming);
+ _ps_update_cellular_state_key(service);
+ /* Need to set 'Attach APN' for 'ESM Attach' if ps_status is available */
+ if (ps_attached)
+ __ps_service_set_attach_apn(service);
+
+ if(prev_roaming_status != _ps_service_get_roaming(service)) {
+ gboolean roaming_allowed = FALSE;
+ roaming_allowed = _ps_modem_get_data_roaming_allowed(service->p_modem);
+ if(!roaming_allowed && roaming) {
+ ps_dbg_ex_co(co_network, "Roaming allowed (%d), Roaming status (%d)", roaming_allowed, roaming);
+ _ps_service_disconnect_contexts(service);
+ return TRUE;
+ }
+ }
if(service->ps_attached)
_ps_service_connect_default_context(service);
return TRUE;
}
-gboolean _ps_service_set_connected(gpointer object, int context_id, gboolean enabled)
+gboolean _ps_service_set_connected(gpointer object, gpointer cstatus, gboolean enabled)
{
GHashTableIter iter;
gpointer key, value;
- PsService *service = NULL;
- dbg("Set service - Context ID: [%d] State: [%s]",
- context_id, (enabled ? "CONNECTED" : "NOT CONNECTED"));
+ gboolean def_awo = FALSE, b_def_conn = FALSE;
+ gpointer def_conn = NULL;
+ gpointer requested_conn = NULL;
+
+ ps_service_t *service = NULL;
+ struct tnoti_ps_call_status *call_status = NULL;
+ CoreObject * co_network;
+// gpointer pre_def_conn = NULL;
+
+ service = (ps_service_t *) object;
+ co_network = _ps_service_ref_co_network(service);
+ call_status = (struct tnoti_ps_call_status *)cstatus;
+
+ if(enabled && service->initial_pdp_conn == FALSE) {
+ ps_dbg_ex_co(co_network, "Initial PDP connection.");
+ service->initial_pdp_conn = TRUE;
+ }
- service = (PsService *) object;
g_hash_table_iter_init(&iter, service->contexts);
while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
- CoreObject *context = NULL;
int tmp_cid;
+ gboolean b_tmp_def = FALSE;
+ CoreObject *context = NULL;
+ gpointer b_user_data = NULL;
context = _ps_context_ref_co_context(value);
tmp_cid = tcore_context_get_id(context);
- if (tmp_cid != context_id) continue;
+ if (tmp_cid != call_status->context_id) continue;
+
+ //if there is default context in disconnected cid, it has to retry auto connection
+ b_tmp_def = _ps_context_get_default_context(value, CONTEXT_ROLE_INTERNET);
+ if(!b_def_conn){
+ b_def_conn = b_tmp_def;
+ }
+
+ //if disconnected connection has the user data, it is a priority connection.
+ b_user_data = _ps_context_get_user_data(value);
+ if(b_user_data){
+ def_conn = value;
+ requested_conn = b_user_data;
+ }
+
+ if(!enabled){
+ gchar *ipv4 = NULL;
+
+ ps_dbg_ex_co(co_network, "Reset socket connections.");
- if(!enabled) {
- dbg("Clear teh context ID");
tcore_ps_clear_context_id(service->co_ps, context);
+ ipv4 = tcore_context_get_ipv4_addr(context);
+ tcore_util_reset_ipv4_socket(tcore_context_get_ipv4_devname(context), (const char*)ipv4);
}
- /* Set the state */
_ps_context_set_connected(value, enabled);
}
+ //connect to request profile
+ if(!enabled && requested_conn){
+ ps_dbg_ex_co(co_network, "connect to request profile (%p)", requested_conn);
+ _ps_connection_hdlr(requested_conn);
+ _ps_service_reset_connection_timer(def_conn);
+ _ps_context_reset_user_data(def_conn);
+ return TRUE;
+ }
+
+ //default context and always on is true. - request to connect
+ if(!enabled){
+ def_conn = _ps_service_return_default_context(service, CONTEXT_ROLE_INTERNET);
+ def_awo = _ps_context_get_alwayson_enable(def_conn);
+
+ if(!def_awo){
+ ps_dbg_ex_co(co_network, "there is no always on connection");
+ return TRUE;
+ }
+
+ //always on TRUE and default connection - NORMAL RETRY
+ //always on TRUE and no default connection - WAIT 5 Secs for retry from application
+ if(b_def_conn){
+ //retry connection
+ _ps_service_connection_timer(service, def_conn);
+ }
+ else{
+
+ //disconnect from user intention
+#if defined(CONNECT_DEFAULT_CONNECTION_WITHOUT_TIMER)
+ if(call_status->result == 2000) {
+ ps_dbg_ex_co(co_network, "user intended disconnect / connect default connection without timer");
+ __ps_service_connetion_timeout_handler(service->timer_src, def_conn);
+ return TRUE;
+ }
+#endif
+ //with unexpected disconnection from network/me
+ _ps_service_set_retry_timeout_value(service, TIMEOUT_DEFAULT);
+ _ps_service_connection_timer(service, def_conn);
+ }
+
+ }
+
return TRUE;
}
void _ps_service_set_ps_defined(gpointer *object, gboolean value, int cid)
{
- PsService *service = (PsService*)object;
+ ps_service_t *service = (ps_service_t*)object;
GHashTableIter iter;
- gpointer key, out;
-
- dbg("PS Defined - Context ID: [%d] Value: [%d]", cid, value);
+ gpointer key, ps_context;
+ CoreObject *co_network;
+ CoreObject *co_context;
+ unsigned char context_id;
g_return_if_fail(service != NULL);
+ co_network = _ps_service_ref_co_network(service);
g_hash_table_iter_init(&iter, service->contexts);
- while (g_hash_table_iter_next(&iter, &key, &out) == TRUE) {
- gboolean r_activate = 0;
-
- /* Set Context */
- r_activate = _ps_context_set_ps_defined(out, value, cid);
- r_activate &= value;
-
- dbg("Activate context: [%s]", (r_activate ? "YES" : "NO"));
- if(r_activate) {
- int rv;
-
- dbg("Activate context - Context ID: [%d]", cid);
- rv = _ps_service_activate_context(service, out);
- dbg("Activate context request - %s", (rv == TCORE_RETURN_SUCCESS ? "SUCCESS" : "FAIL"));
+ while (g_hash_table_iter_next(&iter, &key, &ps_context) == TRUE) {
+ co_context = _ps_context_ref_co_context(ps_context);
+ context_id = tcore_context_get_id(co_context);
+ if (context_id == cid) {
+ gboolean b_only_attach;
+ /* Set 'ps_defined' */
+ _ps_context_set_ps_defined(ps_context, value);
+
+ b_only_attach = _ps_context_get_only_attach(ps_context);
+ if (b_only_attach) {
+ dbg("Do not activate for only attach apn");
+ _ps_context_set_only_attach(ps_context, FALSE);
+ break;
+ }
+
+ /* Activate if define is completed */
+ if (value) {
+ ps_dbg_ex_co(co_network, "define is complete, activate context for cid(%d)", cid);
+ if (_ps_service_activate_context(service, ps_context)
+ == TCORE_RETURN_SUCCESS) {
+ dbg("Successful activate context");
+ tcore_ps_set_cid_active(service->co_ps, cid, TRUE);
+ }
+ }
break;
}
}
gboolean _ps_service_set_ps_attached(gpointer object, gboolean value)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, FALSE);
service->ps_attached = value;
- dbg("service(%p) ps_attached(%d)", service, service->ps_attached);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "service(%p) ps_attached(%d)", service, service->ps_attached);
+ __ps_service_emit_property_changed_signal(service);
+
+ return TRUE;
+}
+
+gboolean _ps_service_get_restricted(gpointer object)
+{
+ ps_service_t *service = object;
+ g_return_val_if_fail(service != NULL, FALSE);
+
+ return service->restricted;
+}
+gboolean _ps_service_set_restricted(gpointer object, gboolean value)
+{
+ ps_service_t *service = object;
+ g_return_val_if_fail(service != NULL, FALSE);
+
+ service->restricted = value;
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "service(%p) restricted(%d)", service, service->restricted);
+
+ _ps_update_cellular_state_key(service);
+ return TRUE;
+}
+
+gboolean _ps_service_set_number_of_pdn_cnt(gpointer object, gchar *operator)
+{
+ int rv = 0;
+ int num_of_pdn = 0;
+ ps_service_t *service = object;
+ g_return_val_if_fail(service != NULL, FALSE);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "Entered");
+ num_of_pdn = _ps_context_get_number_of_pdn(operator, _ps_modem_ref_cp_name(_ps_service_ref_modem(object)));
+ rv = tcore_ps_set_num_of_pdn(service->co_ps, num_of_pdn);
+
+ if(rv != TCORE_RETURN_SUCCESS){
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "error to get maximum number of pdn");
+ }
+ dbg("Exiting");
return TRUE;
}
gboolean _ps_service_get_roaming(gpointer object)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, FALSE);
return service->roaming;
gboolean _ps_service_set_roaming(gpointer object, gboolean value)
{
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, FALSE);
service->roaming = value;
- dbg("service(%p) roaming(%d)", service, service->roaming);
+ ps_dbg_ex_co(_ps_service_ref_co_network(service), "service(%p) roaming(%d)", service, service->roaming);
__ps_service_emit_property_changed_signal(service);
return TRUE;
}
+static void _indicator_cb_dns_reply(GObject *src, GAsyncResult *res, gpointer user_data)
+{
+ GList *list, *cur;
+ GInetAddress *addr;
+ gchar *str_addr;
+ GError *error = NULL;
+
+ list = g_resolver_lookup_by_name_finish((GResolver *)src, res, &error);
+ if (!list) {
+ dbg("fail to get dns resolving");
+ if (error) {
+ dbg ("error:%d, %s", error->code, error->message);
+ g_error_free (error);
+ }
+ return;
+ }
+
+ for (cur = list; cur; cur = cur->next) {
+ addr = cur->data;
+ str_addr = g_inet_address_to_string(addr);
+ if (!str_addr)
+ continue;
+ dbg("addr(%s)", str_addr);
+
+ g_free(str_addr);
+ g_object_unref(cur->data);
+ break;
+ }
+
+ g_object_unref(src);
+ g_list_free(list);
+ return;
+}
+
gboolean _ps_service_set_access_technology(gpointer object,
enum telephony_network_access_technology value)
{
- PsService *service = object;
+ ps_service_t *service = object;
+ CoreObject *co_network = NULL;
+ enum telephony_network_access_technology p_act = 0;
g_return_val_if_fail(service != NULL, FALSE);
+ co_network = _ps_service_ref_co_network(service);
+ p_act = service->act;
service->act = value;
- dbg("service(%p) Access Technology(%d)", service, service->act);
+ ps_dbg_ex_co(co_network, "service(%p) P ACT(%d) Access Technology(%d)", service, p_act, service->act);
+
+ if(p_act == NETWORK_ACT_LTE && (service->act >= NETWORK_ACT_GSM && service->act < NETWORK_ACT_LTE) ){
+ GResolver *r = NULL;
+
+ ps_dbg_ex_co(co_network, "send the dns pkt for keeping connection");
+
+ r = g_resolver_get_default();
+ g_resolver_lookup_by_name_async(r, "www.google.com", NULL, _indicator_cb_dns_reply, NULL);
+ }
if(service->act > NETWORK_ACT_UNKNOWN && service->act < NETWORK_ACT_NOT_SPECIFIED){
_ps_update_cellular_state_key(service);
enum telephony_ps_state _ps_service_check_cellular_state(gpointer object)
{
gboolean state = FALSE;
- PsService *service = object;
+ ps_service_t *service = object;
g_return_val_if_fail(service != NULL, TELEPHONY_PS_NO_SERVICE);
+ state = _ps_modem_get_flght_mode(service->p_modem);
+ if(state){
+ return TELEPHONY_PS_FLIGHT_MODE;
+ }
+
state = _ps_modem_get_power(service->p_modem);
if(!state){
return TELEPHONY_PS_NO_SERVICE;
return TELEPHONY_PS_NO_SERVICE;
}
+ if(service->restricted){
+ return TELEPHONY_PS_RESTRICTED_SERVICE;
+ }
+
if(!service->ps_attached){
return TELEPHONY_PS_NO_SERVICE;
}
- state = _ps_modem_get_flght_mode(service->p_modem);
- if(state){
- return TELEPHONY_PS_FLIGHT_MODE;
+ state = _ps_modem_get_data_allowed(service->p_modem);
+ if(!state){
+ return TELEPHONY_PS_3G_OFF;
}
state = _ps_modem_get_data_roaming_allowed(service->p_modem);
return TELEPHONY_PS_ROAMING_OFF;
}
- state = _ps_modem_get_data_allowed(service->p_modem);
- if(!state){
- return TELEPHONY_PS_3G_OFF;
+ return TELEPHONY_PS_ON;
+}
+static gboolean on_service_get_properties (PacketServiceService *obj_service,
+ GDBusMethodInvocation *invocation,
+ gpointer user_data)
+{
+ GVariant *gv = NULL;
+ GVariantBuilder property;
+ ps_dbg_ex_co(_ps_service_ref_co_network(user_data), "get service properties");
+
+ gv = _ps_service_get_properties(user_data, &property);
+ packet_service_service_complete_get_properties(obj_service, invocation, gv);
+ return TRUE;
+}
+
+static gboolean
+on_service_get_context (PacketServiceService *obj_service,
+ GDBusMethodInvocation *invocation,
+ gpointer user_data)
+{
+ GVariantBuilder b_context;
+ GVariant *contexts;
+
+ GHashTableIter iter;
+ gpointer key, value;
+ ps_service_t *service = user_data;
+ CoreObject *co_network = _ps_service_ref_co_network(service);
+
+ ps_dbg_ex_co(co_network, "modem get contexts interface");
+
+ if (service->contexts == NULL) {
+ ps_err_ex_co(co_network, "No context present for service");
+ FAIL_RESPONSE(invocation,PS_ERR_INTERNAL);
+ return TRUE;
}
- return TELEPHONY_PS_ON;
+ g_variant_builder_init(&b_context, G_VARIANT_TYPE("a{sa{ss}}"));
+ g_hash_table_iter_init(&iter, service->contexts);
+ while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
+ gchar *path = NULL;
+ g_variant_builder_open(&b_context,G_VARIANT_TYPE("{sa{ss}}"));
+ path = _ps_service_ref_path(value);
+
+ g_variant_builder_add(&b_context, "s",g_strdup(path));
+ if(FALSE == _ps_context_get_properties_handler(value, &b_context)){
+ ps_err_ex_co(co_network, "Failed to get property");
+ g_variant_builder_close(&b_context);
+ FAIL_RESPONSE(invocation,PS_ERR_INTERNAL);
+ return TRUE;
+ }
+ g_variant_builder_close(&b_context);
+
+ }
+
+ contexts = g_variant_builder_end(&b_context);
+ packet_service_service_complete_get_contexts(obj_service, invocation,contexts);
+ return TRUE;
}
+
+static void _ps_service_setup_interface(PacketServiceService *service, ps_service_t *service_data)
+{
+ dbg("Entered");
+ g_signal_connect (service,
+ "handle-get-properties",
+ G_CALLBACK (on_service_get_properties),
+ service_data);
+
+ g_signal_connect (service,
+ "handle-get-contexts",
+ G_CALLBACK (on_service_get_context),
+ service_data);
+
+ dbg("Exiting");
+ return;
+}
+
projects / platform / core / telephony / tel-plugin-packetservice.git / blobdiff