diff options
Diffstat (limited to 'provider/download-provider-network.c')
| -rwxr-xr-x | provider/download-provider-network.c | 412 |
1 files changed, 141 insertions, 271 deletions
diff --git a/provider/download-provider-network.c b/provider/download-provider-network.c index ac3fc5b..5fafe2c 100755 --- a/provider/download-provider-network.c +++ b/provider/download-provider-network.c @@ -14,224 +14,130 @@ * limitations under the License. */ +#include "download-provider.h" #include "download-provider-log.h" -#include "download-provider-config.h" #include "download-provider-pthread.h" #include "download-provider-network.h" +#include "download-provider-client-manager.h" + +#include <net_connection.h> #ifdef SUPPORT_WIFI_DIRECT #include <wifi-direct.h> #endif -extern pthread_mutex_t g_dp_queue_mutex; -extern pthread_cond_t g_dp_queue_cond; - -#if 0 -typedef enum -{ - CONNECTION_TYPE_DISCONNECTED = 0, /**< Disconnected */ - CONNECTION_TYPE_WIFI = 1, /**< Wi-Fi type */ - CONNECTION_TYPE_CELLULAR = 2, /**< Cellular type */ - CONNECTION_TYPE_ETHERNET = 3, /**< Ethernet type */ - CONNECTION_TYPE_BT = 4, /**< Bluetooth type */ -} connection_type_e; -typedef enum -{ - CONNECTION_CELLULAR_STATE_OUT_OF_SERVICE = 0, /**< Out of service */ - CONNECTION_CELLULAR_STATE_FLIGHT_MODE = 1, /**< Flight mode */ - CONNECTION_CELLULAR_STATE_ROAMING_OFF = 2, /**< Roaming is turned off */ - CONNECTION_CELLULAR_STATE_CALL_ONLY_AVAILABLE = 3, /**< Call is only available */ - CONNECTION_CELLULAR_STATE_AVAILABLE = 4, /**< Available but not connected yet */ - CONNECTION_CELLULAR_STATE_CONNECTED = 5, /**< Connected */ -} connection_cellular_state_e -typedef enum -{ - CONNECTION_WIFI_STATE_DEACTIVATED = 0, /**< Deactivated state */ - CONNECTION_WIFI_STATE_DISCONNECTED = 1, /**< disconnected state */ - CONNECTION_WIFI_STATE_CONNECTED = 2, /**< Connected state */ -} connection_wifi_state_e; -typedef enum -{ - CONNECTION_ETHERNET_STATE_DEACTIVATED = 0, /**< Deactivated state */ - CONNECTION_ETHERNET_STATE_DISCONNECTED = 1, /**< disconnected state */ - CONNECTION_ETHERNET_STATE_CONNECTED = 2, /**< Connected state */ -} connection_ethernet_state_e; -typedef enum -{ - CONNECTION_ERROR_NONE = TIZEN_ERROR_NONE, /**< Successful */ - CONNECTION_ERROR_INVALID_PARAMETER = TIZEN_ERROR_INVALID_PARAMETER, /**< Invalid parameter */ - CONNECTION_ERROR_OUT_OF_MEMORY = TIZEN_ERROR_OUT_OF_MEMORY, /**< Out of memory error */ - CONNECTION_ERROR_INVALID_OPERATION = TIZEN_ERROR_INVALID_OPERATION, /**< Invalid Operation */ - CONNECTION_ERROR_ADDRESS_FAMILY_NOT_SUPPORTED = TIZEN_ERROR_ADDRESS_FAMILY_NOT_SUPPORTED, /**< Address family not supported */ - CONNECTION_ERROR_OPERATION_FAILED = TIZEN_ERROR_NETWORK_CLASS|0x0401, /**< Operation failed */ - CONNECTION_ERROR_ITERATOR_END = TIZEN_ERROR_NETWORK_CLASS|0x0402, /**< End of iteration */ - CONNECTION_ERROR_NO_CONNECTION = TIZEN_ERROR_NETWORK_CLASS|0x0403, /**< There is no connection */ - CONNECTION_ERROR_NOW_IN_PROGRESS = TIZEN_ERROR_NOW_IN_PROGRESS, /** Now in progress */ - CONNECTION_ERROR_ALREADY_EXISTS = TIZEN_ERROR_NETWORK_CLASS|0x0404, /**< Already exists */ - CONNECTION_ERROR_OPERATION_ABORTED = TIZEN_ERROR_NETWORK_CLASS|0x0405, /**< Operation is aborted */ - CONNECTION_ERROR_DHCP_FAILED = TIZEN_ERROR_NETWORK_CLASS|0x0406, /**< DHCP failed */ - CONNECTION_ERROR_INVALID_KEY = TIZEN_ERROR_NETWORK_CLASS|0x0407, /**< Invalid key */ - CONNECTION_ERROR_NO_REPLY = TIZEN_ERROR_NETWORK_CLASS|0x0408, /**< No reply */ -} connection_error_e; - +pthread_mutex_t g_dp_network_mutex = PTHREAD_MUTEX_INITIALIZER; +int g_network_status = DP_NETWORK_OFF; +connection_h g_network_connection = 0; +int g_network_is_wifi_direct = 0; -static void __print_connection_errorcode_to_string(connection_error_e errorcode) -{ - switch(errorcode) - { - case CONNECTION_ERROR_INVALID_PARAMETER : - TRACE_DEBUG("CONNECTION_ERROR_INVALID_PARAMETER"); - break; - case CONNECTION_ERROR_OUT_OF_MEMORY : - TRACE_DEBUG("CONNECTION_ERROR_OUT_OF_MEMORY"); - break; - case CONNECTION_ERROR_INVALID_OPERATION : - TRACE_DEBUG("CONNECTION_ERROR_INVALID_OPERATION"); - break; - case CONNECTION_ERROR_ADDRESS_FAMILY_NOT_SUPPORTED : - TRACE_DEBUG("CONNECTION_ERROR_ADDRESS_FAMILY_NOT_SUPPORTED"); - break; - case CONNECTION_ERROR_OPERATION_FAILED : - TRACE_DEBUG("CONNECTION_ERROR_OPERATION_FAILED"); - break; - case CONNECTION_ERROR_ITERATOR_END : - TRACE_DEBUG("CONNECTION_ERROR_ITERATOR_END"); - break; - case CONNECTION_ERROR_NO_CONNECTION : - TRACE_DEBUG("CONNECTION_ERROR_NO_CONNECTION"); - break; - case CONNECTION_ERROR_NOW_IN_PROGRESS : - TRACE_DEBUG("CONNECTION_ERROR_NOW_IN_PROGRESS"); - break; - case CONNECTION_ERROR_ALREADY_EXISTS : - TRACE_DEBUG("CONNECTION_ERROR_ALREADY_EXISTS"); - break; - case CONNECTION_ERROR_OPERATION_ABORTED : - TRACE_DEBUG("CONNECTION_ERROR_OPERATION_ABORTED"); - break; - case CONNECTION_ERROR_DHCP_FAILED : - TRACE_DEBUG("CONNECTION_ERROR_DHCP_FAILED"); - break; - case CONNECTION_ERROR_INVALID_KEY : - TRACE_DEBUG("CONNECTION_ERROR_INVALID_KEY"); - break; - case CONNECTION_ERROR_NO_REPLY : - TRACE_DEBUG("CONNECTION_ERROR_NO_REPLY"); - break; - default : - TRACE_DEBUG("CONNECTION_ERROR_NONE"); - break; - } -} +#ifdef SUPPORT_COMPANION_MODE +// support B3 companion mode +#include "vconf.h" +#include "vconf-keys.h" +#include "SAPInterface.h" +#define VCONFKEY_SAP_CONNECTION_NOTIFICATION VCONFKEY_WMS_WMANAGER_CONNECTED +#define VCONFKEY_SAP_CONNECTION_TYPE "memory/private/sap/conn_type" #endif - -#ifdef SUPPORT_WIFI_DIRECT -// support WIFI-Direct -static void __dp_network_wifi_direct_connection_state_changed_cb(wifi_direct_error_e error_code, wifi_direct_connection_state_e connection_state, const char *mac_address, void *data) +static int __dp_network_is_companion_mode() { - dp_privates *privates = (dp_privates*)data; - if (privates == NULL) { - TRACE_ERROR("[CRITICAL] Invalid data"); - return ; - } +#ifdef SUPPORT_COMPANION_MODE + int wms_connected = 0; + int companion_mode = 0; + vconf_get_int(VCONFKEY_SAP_CONNECTION_NOTIFICATION, &wms_connected); + vconf_get_int(VCONFKEY_SAP_CONNECTION_TYPE, &companion_mode); + TRACE_INFO("wms_connected:%d, companion_mode:%d", wms_connected, companion_mode); + if (wms_connected == 1 && (companion_mode & SAP_BT)) + return 1; - if (connection_state == WIFI_DIRECT_CONNECTION_RSP) { - TRACE_DEBUG("WIFI_DIRECT_CONNECTION_RSP"); - privates->is_connected_wifi_direct = 1; - return ; - } - privates->is_connected_wifi_direct = 0; +#endif + return 0; } -//return 0 : connected -int dp_network_wifi_direct_is_connected() +#ifdef SUPPORT_WIFI_DIRECT + +static int __dp_network_wifi_direct_status() { - int is_connected = -1; + int is_connected = 0; wifi_direct_state_e wifi_state = WIFI_DIRECT_STATE_DEACTIVATED; if (wifi_direct_get_state(&wifi_state) == 0) { - switch (wifi_state) - { - case WIFI_DIRECT_STATE_DEACTIVATED : - TRACE_DEBUG("WIFI_DIRECT_STATE_DEACTIVATED"); - break; - case WIFI_DIRECT_STATE_DEACTIVATING : - TRACE_DEBUG("WIFI_DIRECT_STATE_DEACTIVATING"); - break; - case WIFI_DIRECT_STATE_ACTIVATING : - TRACE_DEBUG("WIFI_DIRECT_STATE_ACTIVATING"); - break; - case WIFI_DIRECT_STATE_ACTIVATED : - TRACE_DEBUG("WIFI_DIRECT_STATE_ACTIVATED"); - break; - case WIFI_DIRECT_STATE_DISCOVERING : - TRACE_DEBUG("WIFI_DIRECT_STATE_DISCOVERING"); - break; - case WIFI_DIRECT_STATE_CONNECTING : - TRACE_DEBUG("WIFI_DIRECT_STATE_CONNECTING"); - break; - case WIFI_DIRECT_STATE_DISCONNECTING : - TRACE_DEBUG("WIFI_DIRECT_STATE_DISCONNECTING"); - break; - case WIFI_DIRECT_STATE_CONNECTED : - is_connected = 0; - TRACE_DEBUG("WIFI_DIRECT_STATE_CONNECTED"); - break; - default : - break; + if (wifi_state == WIFI_DIRECT_STATE_CONNECTED) { + TRACE_INFO("WIFI_DIRECT_STATE_CONNECTED"); + is_connected = 1; } } return is_connected; } -#endif +// support WIFI-Direct +static void __dp_network_wifi_direct_changed_cb + (wifi_direct_error_e error_code, + wifi_direct_connection_state_e connection_state, + const char *mac_address, void *data) +{ + pthread_mutex_lock(&g_dp_network_mutex); + if (connection_state == WIFI_DIRECT_CONNECTION_RSP) { + TRACE_INFO("WIFI_DIRECT_CONNECTION_RSP"); + g_network_is_wifi_direct = __dp_network_wifi_direct_status(); + } else { + TRACE_INFO("WIFI_DIRECT_DISCONNECTION"); + g_network_is_wifi_direct = 0; + } + pthread_mutex_unlock(&g_dp_network_mutex); +} +#endif ////////////////////////////////////////////////////////////////////////// /// @brief check the status in more detail by connection type /// @return dp_network_type -static dp_network_type __dp_get_network_connection_status(connection_h connection, connection_type_e type) +static int __dp_get_network_connection_status(connection_h connection, connection_type_e type) { - dp_network_type network_type = DP_NETWORK_TYPE_OFF; - if (type == CONNECTION_TYPE_WIFI) { + int network_type = DP_NETWORK_OFF; + if (__dp_network_is_companion_mode() == 1) { + network_type = DP_NETWORK_ALL; + TRACE_INFO("COMPANION MODE"); + } else if (type == CONNECTION_TYPE_WIFI) { connection_wifi_state_e wifi_state; wifi_state = CONNECTION_WIFI_STATE_DEACTIVATED; - if (connection_get_wifi_state - (connection, &wifi_state) != CONNECTION_ERROR_NONE) + if (connection_get_wifi_state(connection, &wifi_state) != + CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_get_wifi_state"); - if (wifi_state == CONNECTION_WIFI_STATE_CONNECTED) { - TRACE_DEBUG("[CONNECTION_WIFI] CONNECTED"); - network_type = DP_NETWORK_TYPE_WIFI; } else { - TRACE_DEBUG("[CONNECTION_WIFI] [%d]", wifi_state); + if (wifi_state == CONNECTION_WIFI_STATE_CONNECTED) { + TRACE_INFO("WIFI CONNECTED"); + network_type = DP_NETWORK_WIFI; + } } } else if (type == CONNECTION_TYPE_CELLULAR) { connection_cellular_state_e cellular_state; cellular_state = CONNECTION_CELLULAR_STATE_OUT_OF_SERVICE; - if (connection_get_cellular_state - (connection, &cellular_state) != CONNECTION_ERROR_NONE) + if (connection_get_cellular_state(connection, + &cellular_state) != CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_get_cellular_state"); - if (cellular_state == CONNECTION_CELLULAR_STATE_CONNECTED) { - TRACE_DEBUG("[CONNECTION_CELLULAR] DATA NETWORK CONNECTED"); - network_type = DP_NETWORK_TYPE_DATA_NETWORK; } else { - TRACE_DEBUG("[CONNECTION_CELLULAR] [%d]", cellular_state); + if (cellular_state == CONNECTION_CELLULAR_STATE_CONNECTED) { + TRACE_INFO("DATA NETWORK CONNECTED"); + network_type = DP_NETWORK_DATA_NETWORK; + } } } else if (type == CONNECTION_TYPE_ETHERNET) { connection_ethernet_state_e ethernet_state; ethernet_state = CONNECTION_ETHERNET_STATE_DISCONNECTED; - if (connection_get_ethernet_state - (connection, ðernet_state) != CONNECTION_ERROR_NONE) + if (connection_get_ethernet_state(connection, + ðernet_state) != CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_get_ethernet_state"); - if (ethernet_state == CONNECTION_ETHERNET_STATE_CONNECTED) { - TRACE_DEBUG("[CONNECTION_ETHERNET] ETHERNET CONNECTED"); - network_type = DP_NETWORK_TYPE_ETHERNET; } else { - TRACE_DEBUG("[CONNECTION_ETHERNET] [%d]", ethernet_state); + if (ethernet_state == CONNECTION_ETHERNET_STATE_CONNECTED) { + TRACE_INFO("ETHERNET CONNECTED"); + network_type = DP_NETWORK_WIFI; + } } } else { - TRACE_DEBUG("[DISCONNECTED]"); - network_type = DP_NETWORK_TYPE_OFF; + TRACE_INFO("DISCONNECTED"); + network_type = DP_NETWORK_OFF; } + g_network_status = network_type; return network_type; } @@ -240,33 +146,25 @@ static dp_network_type __dp_get_network_connection_status(connection_h connectio /// @todo care requests by network status static void __dp_network_connection_type_changed_cb(connection_type_e type, void *data) { - dp_privates *privates = (dp_privates*)data; - if (privates == NULL) { - TRACE_ERROR("[CRITICAL] Invalid data"); - return ; - } - CLIENT_MUTEX_LOCK(&(g_dp_queue_mutex)); - #if 1 // this callback guarantee that already connectdd - if (type == CONNECTION_TYPE_WIFI) { - TRACE_DEBUG("[CONNECTION_WIFI] CONNECTED"); - privates->network_status = DP_NETWORK_TYPE_WIFI; + pthread_mutex_lock(&g_dp_network_mutex); + // this callback guarantee that already connected + if (__dp_network_is_companion_mode() == 1) { + TRACE_INFO("COMPANION MODE"); + g_network_status = DP_NETWORK_ALL; + } else if (type == CONNECTION_TYPE_WIFI) { + TRACE_INFO("WIFI CONNECTED"); + g_network_status = DP_NETWORK_WIFI; } else if (type == CONNECTION_TYPE_CELLULAR) { - TRACE_DEBUG("[CONNECTION_CELLULAR] DATA NETWORK CONNECTED"); - privates->network_status = DP_NETWORK_TYPE_DATA_NETWORK; + TRACE_INFO("DATA NETWORK CONNECTED"); + g_network_status = DP_NETWORK_DATA_NETWORK; } else if (type == CONNECTION_TYPE_ETHERNET) { - TRACE_DEBUG("[CONNECTION_ETHERNET] ETHERNET CONNECTED"); - privates->network_status = DP_NETWORK_TYPE_ETHERNET; + TRACE_INFO("ETHERNET CONNECTED"); + g_network_status = DP_NETWORK_WIFI; } else { - TRACE_DEBUG("[DISCONNECTED]"); - privates->network_status = DP_NETWORK_TYPE_OFF; + TRACE_INFO("DISCONNECTED"); + g_network_status = DP_NETWORK_OFF; } - if (privates->network_status != DP_NETWORK_TYPE_OFF) - pthread_cond_signal(&g_dp_queue_cond); - #else - privates->network_status = - __dp_get_network_connection_status(privates->connection, type); - #endif - CLIENT_MUTEX_UNLOCK(&(g_dp_queue_mutex)); + pthread_mutex_unlock(&g_dp_network_mutex); } ////////////////////////////////////////////////////////////////////////// @@ -274,124 +172,96 @@ static void __dp_network_connection_type_changed_cb(connection_type_e type, void /// @todo auto resume feature static void __dp_network_connection_ip_changed_cb(const char *ip, const char *ipv6, void *data) { - dp_privates *privates = (dp_privates*)data; - if (privates == NULL) { - TRACE_ERROR("[CRITICAL] Invalid data"); - return ; - } - if (privates->network_status != DP_NETWORK_TYPE_OFF) { - dp_request_slots *requests = privates->requests; - int i = 0; - for (i = 0; i < DP_MAX_REQUEST; i++) { - int locked = pthread_mutex_trylock(&requests[i].mutex); - // locking failure means it used by other thread. - if (locked == 0) { - if (requests[i].request != NULL) { - if (requests[i].request->state == DP_STATE_DOWNLOADING || - (requests[i].request->state == DP_STATE_FAILED && - requests[i].request->error == DP_ERROR_CONNECTION_FAILED)) { - requests[i].request->ip_changed = 1; - } - } - CLIENT_MUTEX_UNLOCK(&requests[i].mutex); - } - } + if (dp_network_get_status() != DP_NETWORK_OFF) { + TRACE_DEBUG("[CONNECTION] IP CHANGED"); + // broadcast to all thread for clients + dp_broadcast_signal(); } } +int dp_network_get_status() +{ + int status = DP_NETWORK_OFF; + pthread_mutex_lock(&g_dp_network_mutex); + status = g_network_status; + pthread_mutex_unlock(&g_dp_network_mutex); + return status; +} + +int dp_network_is_wifi_direct() +{ + pthread_mutex_lock(&g_dp_network_mutex); + int status = g_network_is_wifi_direct; + pthread_mutex_unlock(&g_dp_network_mutex); + return status; +} + ////////////////////////////////////////////////////////////////////////// /// @brief create connection handle & regist callback /// @return 0 : success -1 : failed -int dp_network_connection_init(dp_privates *privates) +int dp_network_connection_init() { int retcode = 0; - if (!privates) { - TRACE_ERROR("[CRITICAL] Invalid data"); - return -1; - } - #ifdef SUPPORT_WIFI_DIRECT if (wifi_direct_initialize() == 0) { wifi_direct_set_connection_state_changed_cb - (__dp_network_wifi_direct_connection_state_changed_cb, privates); - if (dp_network_wifi_direct_is_connected() == 0) - privates->is_connected_wifi_direct = 1; + (__dp_network_wifi_direct_changed_cb, NULL); + g_network_is_wifi_direct = __dp_network_wifi_direct_status(); } #endif - if ((retcode = connection_create(&privates->connection)) != + if ((retcode = connection_create(&g_network_connection)) != CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_create [%d]", retcode); return -1; } - if ((retcode = connection_set_type_changed_cb - (privates->connection, __dp_network_connection_type_changed_cb, - privates)) != CONNECTION_ERROR_NONE) { + if ((retcode = connection_set_type_changed_cb(g_network_connection, + __dp_network_connection_type_changed_cb, NULL)) != + CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_set_type_changed_cb [%d]", retcode); - connection_destroy(privates->connection); + connection_destroy(g_network_connection); + g_network_connection = 0; return -1; } + if ((retcode = connection_set_ip_address_changed_cb - (privates->connection, __dp_network_connection_ip_changed_cb, - privates)) != CONNECTION_ERROR_NONE) { + (g_network_connection, __dp_network_connection_ip_changed_cb, + NULL)) != CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed __dp_network_connection_ip_changed_cb [%d]", retcode); - connection_destroy(privates->connection); + connection_destroy(g_network_connection); + g_network_connection = 0; return -1; } + connection_type_e type = CONNECTION_TYPE_DISCONNECTED; - if ((retcode = connection_get_type(privates->connection, &type)) != + if ((retcode = connection_get_type(g_network_connection, &type)) != CONNECTION_ERROR_NONE) { TRACE_ERROR("Failed connection_get_type [%d]", retcode); - connection_destroy(privates->connection); + connection_destroy(g_network_connection); + g_network_connection = 0; return -1; } - privates->network_status = - __dp_get_network_connection_status(privates->connection, type); + g_network_status = + __dp_get_network_connection_status(g_network_connection, type); return 0; } ////////////////////////////////////////////////////////////////////////// /// @brief destroy connection handle -void dp_network_connection_destroy(connection_h connection) +void dp_network_connection_destroy() { + pthread_mutex_lock(&g_dp_network_mutex); #ifdef SUPPORT_WIFI_DIRECT wifi_direct_unset_connection_state_changed_cb(); wifi_direct_deinitialize(); #endif - connection_unset_type_changed_cb(connection); - connection_unset_ip_address_changed_cb(connection); - connection_destroy(connection); -} - -////////////////////////////////////////////////////////////////////////// -/// @brief check network status using connection API -/// @todo the standard of enabled networking can be changed later -/// @return Network type -dp_network_type dp_get_network_connection_instant_status() -{ - int retcode = 0; - connection_h network_handle = NULL; - dp_network_type network_type = DP_NETWORK_TYPE_OFF; - if ((retcode = connection_create(&network_handle)) != - CONNECTION_ERROR_NONE) { - TRACE_ERROR("Failed connection_create [%d]", retcode); - return DP_NETWORK_TYPE_OFF; + if (g_network_connection != 0) { + connection_unset_type_changed_cb(g_network_connection); + connection_unset_ip_address_changed_cb(g_network_connection); + connection_destroy(g_network_connection); } - - connection_type_e type = CONNECTION_TYPE_DISCONNECTED; - if ((retcode = connection_get_type(network_handle, &type)) != - CONNECTION_ERROR_NONE) { - TRACE_ERROR("Failed connection_get_type [%d]", retcode); - connection_destroy(network_handle); - return DP_NETWORK_TYPE_OFF; - } - network_type = - __dp_get_network_connection_status(network_handle, type); - - if (connection_destroy(network_handle) != CONNECTION_ERROR_NONE) - TRACE_ERROR("Failed connection_destroy"); - - return network_type; + g_network_connection = 0; + pthread_mutex_unlock(&g_dp_network_mutex); } |