--- /dev/null
+/*
+ * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ * Licensed under the Apache License, Version 2.0 (the License);
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef __TIZEN_WEB_DOWNLOAD_H__
+#define __TIZEN_WEB_DOWNLOAD_H__
+
+#include <tizen.h>
+#include <app.h>
+
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+ /**
+ * @addtogroup CAPI_WEB_DOWNLOAD_MODULE
+ * @{
+ */
+
+/**
+ * @brief Name for download service operation. Download Manager application is launched.
+ */
+#define SERVICE_OPERATION_DOWNLOAD "http://tizen.org/appcontrol/operation/download"
+
+/**
+ * @brief Enumeration of error code for URL download
+ */
+typedef enum
+{
+ DOWNLOAD_ERROR_NONE = TIZEN_ERROR_NONE, /**< Successful */
+ DOWNLOAD_ERROR_INVALID_PARAMETER = TIZEN_ERROR_INVALID_PARAMETER, /**< Invalid parameter */
+ DOWNLOAD_ERROR_OUT_OF_MEMORY = TIZEN_ERROR_OUT_OF_MEMORY, /**< Out of memory */
+ DOWNLOAD_ERROR_NETWORK_UNREACHABLE = TIZEN_ERROR_NETWORK_UNREACHABLE, /**< Network is unreachable */
+ DOWNLOAD_ERROR_CONNECTION_TIMED_OUT = TIZEN_ERROR_CONNECTION_TIME_OUT, /**< Http session time-out */
+ DOWNLOAD_ERROR_NO_SPACE = TIZEN_ERROR_FILE_NO_SPACE_ON_DEVICE, /**< No space left on device */
+ DOWNLOAD_ERROR_FIELD_NOT_FOUND = TIZEN_ERROR_KEY_NOT_AVAILABLE, /**< Specified field not found */
+ DOWNLOAD_ERROR_INVALID_STATE = TIZEN_ERROR_WEB_CLASS | 0x21, /**< Invalid state */
+ DOWNLOAD_ERROR_CONNECTION_FAILED = TIZEN_ERROR_WEB_CLASS | 0x22, /**< Connection failed */
+ DOWNLOAD_ERROR_INVALID_URL = TIZEN_ERROR_WEB_CLASS | 0x24, /**< Invalid URL */
+ DOWNLOAD_ERROR_INVALID_DESTINATION = TIZEN_ERROR_WEB_CLASS | 0x25, /**< Invalid destination */
+ DOWNLOAD_ERROR_TOO_MANY_DOWNLOADS = TIZEN_ERROR_WEB_CLASS | 0x26, /**< Full of available simultaneous downloads */
+ DOWNLOAD_ERROR_QUEUE_FULL = TIZEN_ERROR_WEB_CLASS | 0x27, /**< Full of available downloading items from server*/
+ DOWNLOAD_ERROR_ALREADY_COMPLETED = TIZEN_ERROR_WEB_CLASS | 0x28, /**< The download is already completed */
+ DOWNLOAD_ERROR_FILE_ALREADY_EXISTS = TIZEN_ERROR_WEB_CLASS | 0x29, /**< It is failed to rename the downloaded file */
+ DOWNLOAD_ERROR_CANNOT_RESUME = TIZEN_ERROR_WEB_CLASS | 0x2a, /**< It cannot resume */
+ DOWNLOAD_ERROR_TOO_MANY_REDIRECTS = TIZEN_ERROR_WEB_CLASS | 0x30, /**< In case of too may redirects from http response header*/
+ DOWNLOAD_ERROR_UNHANDLED_HTTP_CODE = TIZEN_ERROR_WEB_CLASS | 0x31, /**< The download cannot handle the http status value */
+ DOWNLOAD_ERROR_REQUEST_TIMEOUT = TIZEN_ERROR_WEB_CLASS | 0x32, /**< There are no action after client create a download id*/
+ DOWNLOAD_ERROR_RESPONSE_TIMEOUT = TIZEN_ERROR_WEB_CLASS | 0x33, /**< It does not call start API in some time although the download is created*/
+ DOWNLOAD_ERROR_SYSTEM_DOWN = TIZEN_ERROR_WEB_CLASS | 0x34, /**< There are no response from client after rebooting download daemon*/
+ DOWNLOAD_ERROR_ID_NOT_FOUND = TIZEN_ERROR_WEB_CLASS | 0x35, /**< The download id is not existed in download service module*/
+ DOWNLOAD_ERROR_NO_DATA = TIZEN_ERROR_NO_DATA, /**< No data because the set API is not called */
+ DOWNLOAD_ERROR_IO_ERROR = TIZEN_ERROR_IO_ERROR , /**< Internal I/O error */
+} download_error_e;
+
+
+/**
+ * @brief Enumerations of state of download
+ */
+typedef enum
+{
+ DOWNLOAD_STATE_NONE, /**< It is ready to download */
+ DOWNLOAD_STATE_READY, /**< It is ready to download */
+ DOWNLOAD_STATE_QUEUED, /**< It is queued to start downloading */
+ DOWNLOAD_STATE_DOWNLOADING, /**< The download is currently running */
+ DOWNLOAD_STATE_PAUSED, /**< The download is waiting to resume */
+ DOWNLOAD_STATE_COMPLETED, /**< The download is completed. */
+ DOWNLOAD_STATE_FAILED, /**< The download failed. */
+ DOWNLOAD_STATE_CANCELED, /**< User cancel the download item. */
+} download_state_e;
+
+/**
+ * @brief Enumerations of network type for download
+ */
+typedef enum
+{
+ DOWNLOAD_NETWORK_DATA_NETWORK, /**< Download is available through data network */
+ DOWNLOAD_NETWORK_WIFI, /**< Download is available through Wi-Fi */
+ DOWNLOAD_NETWORK_ALL /**< Download is available through either data network or Wi-Fi */
+} download_network_type_e ;
+
+
+/**
+ * @brief Called when the download status is changed.
+ *
+ * @param [in] download The download id
+ * @param [in] state The state of download
+ * @param [in] user_data The user data passed from download_set_state_changed_cb()
+ * @pre download_start() will cause this callback if you register this callback using download_set_state_changed_cb()
+ * @see download_set_state_changed_cb()
+ * @see download_unset_state_changed_cb()
+ */
+typedef void (*download_state_changed_cb) (int download_id,
+ download_state_e state, void *user_data);
+
+/**
+ * @brief Called when the progress of download changes.
+ *
+ * @remarks This callback function is only invoked in the downloading state.
+ * @param [in] download The download id
+ * @param [in] received The size of the data received in bytes
+ * @param [in] user_data The user data passed from download_set_progress_cb()
+ * @pre This callback function is invoked if you register this callback using download_set_progress_cb().
+ * @see download_cancel()
+ * @see download_set_progress_cb()
+ * @see download_unset_progress_cb()
+ */
+typedef void (*download_progress_cb) (int download_id, unsigned long long received, void *user_data);
+
+/**
+ * @brief Creates a download id.
+ *
+ * @remarks The @a download must be released with download_destroy() by you.\n
+ * The g_type_init() should be called when creating a main loop by user side. \n
+ * Because the libsoup, which is http stack library of download module, use gobject internally.
+ * @param [out] download A download id to be newly created on success
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @post The download state will be #DOWNLOAD_STATE_READY
+ * @see download_destroy()
+ */
+int download_create(int *download_id);
+
+
+/**
+ * @brief Unload all data concerning a download id from memory.
+ *
+ * @detail After calling this API, a download ID is existed at DB in certain time.\n
+ * Within that time, it is able to use the other API with the download ID.
+ * @remark If #DOWNLOAD_ERROR_ID_NOT_FOUND is returned, it means that the download ID is completely removed from DB.
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_create()
+ */
+int download_destroy(int download_id);
+
+
+/**
+ * @brief Sets the URL to download.
+ *
+ * @remarks This function should be called before downloading (See download_start())
+ * @param [in] download The download id
+ * @param [in] url The URL to download \n
+ * If the @a url is NULL, it clears the previous value.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_url()
+ */
+int download_set_url(int download_id, const char *url);
+
+
+/**
+ * @brief Gets the URL to download.
+ *
+ * @remarks The @a url must be released with free() by you.
+ * @param [in] download The download id
+ * @param [out] url The URL to download
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_url()
+ */
+int download_get_url(int download_id, char **url);
+
+
+/**
+ * @brief Sets the allowed network type for the downloaded file
+ *
+ * @details The file can be downloaded only under the allowed network.
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @param [in] net_type The network type which the client prefer
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_network_type()
+ * @see #download_network_type_e
+ */
+int download_set_network_type(int download_id, download_network_type_e net_type);
+
+
+/**
+ * @brief Gets the netowork type for the downloaded file
+ *
+ * @param [in] download The download id
+ * @param [out] net_type The network type which is defined by client.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_network_type()
+ * @see #download_network_type_e
+ */
+int download_get_network_type(int download_id, download_network_type_e *net_type);
+
+
+/**
+ * @brief Sets the destination for the downloaded file.
+ *
+ * @details The file will be downloaded to the specified destination.
+ * The downloaded file is saved to an auto-generated file name in the destination.
+ * If the destination is not specified, the file will be downloaded to default storage. (See the @ref CAPI_STORAGE_MODULE API)
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @param [in] path The absolute path to the downloaded file
+ * If the @a path is NULL, it clears the previous value.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_destination()
+ */
+int download_set_destination(int download_id, const char *path);
+
+
+/**
+ * @brief Gets the destination for the downloaded file.
+ *
+ * @remarks The @a path must be released with free() by you.
+ * @param [in] download The download id
+ * @param [out] path The absolute path to the downloaded file
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_destination()
+ */
+int download_get_destination(int download_id, char **path);
+
+
+/**
+ * @brief Sets the name for the downloaded file.
+ *
+ * @details The file will be downloaded to the specified destination as the given file name.
+ * If the file name is not specified, the downloaded file is saved to an auto-generated file name in the destination.
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @param [in] file_name The file name for the downloaded file
+ * If the @a name is NULL, it clears the previous value.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_file_name()
+ */
+int download_set_file_name(int download_id, const char *file_name);
+
+
+/**
+ * @brief Gets the name which is set by user.
+ *
+ * @details If user do not set any name, it retruns NULL.
+ *
+ * @remarks The @a file_name must be released with free() by you.
+ * @param [in] download The download id
+ * @param [out] file_name The file name which is set by user.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_file_name()
+ */
+int download_get_file_name(int download_id, char **file_name);
+
+
+/**
+ * @brief Sets the option value to register notification messages by download service module.
+ * @details The tree types of notification message can be posted. Those are completion, failed and ongoing type.
+ * When the notification message of failed and ongoing types from the notification tray, \n
+ * the client application which call this API will be launched. \n
+ *
+ * @remarks The extra param should be set together (See download_set_notification_extra_param()). \n
+ * The downloading and failed notification can be registerd only if the extra param for noticiation message is set. \n
+ * If it is not, the client application can not know who request to launch itself. \n
+ * It should be necessary to understand the action operation of notification click event.
+ * @remarks If the competition notification message is selected from the notification tray,\n
+ * the proper player application is launched automatically.
+ * @remarks The default value is false. So if the client don't enable it, any notification messages are not registered.
+ * @remarks This function should be called before downloading (See download_start())
+ * @param[in] download The download id
+ * @param[in] enable The boolean type. The true or false value is available.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_notification()
+ * @see service_get_operation()
+ */
+int download_set_notification(int download_id, bool enable);
+
+/**
+ * @brief Gets the option value to register notification messages by download service module.
+ * @param[in] download The download id
+ * @param[out] enable The boolean type. The true or false value is retruned
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_notification()
+ */
+int download_get_notification(int download_id, bool *enable);
+
+/**
+ * @brief Sets the extra param data which pass by application service data when notification message is clicked
+ * @details When client set the extra param data for ongoing notificaiton action, \n
+ * it can get the data through service_get_extra_data() when client application is launched by notification action.
+ *
+ * @remarks This function should be called before downloading (See download_start())
+ *
+ * @param[in] download The download id
+ * @param[in] key The character pointer type. The extra param has a pair of key and value
+ * @param[in] value The character pointer type. The extra param has a pair of key and value
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_get_notification_extra_param()
+ * @see download_service_get_extra_data()
+ * @see service_get_operation()
+ */
+int download_set_notification_extra_param(int download_id, char *key, char *value);
+
+
+/**
+ * @brief Gets the extra param value to set by download_set_notification_extra_param
+ * @param[in] download The download id
+ * @param[out] key The character pointer type. The extra param has a pair of key and value
+ * @param[out] value param The character pointer type. The extra param has a pair of key and value
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_notification_extra_param()
+ */
+int download_get_notification_extra_param(int download_id, char **key, char **value);
+
+
+/**
+ * @brief Gets the absolute path to save the downloaded file
+ *
+ * @remarks This function returns #DOWNLOAD_ERROR_INVALID_STATE if the download is not completed. \n
+ * The @a path must be released with free() by you.
+ * @param [in] download The download id
+ * @param [out] path The absolute path to the downloaded file
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_COMPLETED.
+ * @see download_set_file_name()
+ * @see download_set_destination()
+ */
+int download_get_downloaded_file_path(int download_id, char **path);
+
+
+/**
+ * @brief Gets the mime type for downloading a content.
+ *
+ * @remarks This function returns #DOWNLOAD_ERROR_INVALID_STATE if the download has not been started. \n
+ * The @a mime_type must be released with free() by you.
+ * @param [in] download The download id
+ * @param [out] mime_type The MIME type of the downloaded file
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_file_name()
+ * @see download_set_destination()
+ * @see download_get_downloaded_file_path()
+ */
+int download_get_mime_type(int download_id, char **mime_type);
+
+
+/**
+ * @brief Sets the option for auto download.
+ * @details If this option is enabled, \n
+ * the previous downloading item is restarted automatically as soon as the download daemon is restarted. \n
+ * And the download progress keep going after the client process is terminated. \n
+ * @remarks The client should call download_set_notification() and download_set_notification_extra_param() after call this API. \n
+ * If it is not, user do not receive the download result in case the client process is not alive.
+ * @remarks The default value is false.
+ * @param[in] download The download id
+ * @param[in] enable The boolean value for auto download which is defined by clinet.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_auto_download()
+ * @see download_set_ongoing_notification()
+ * @see download_set_notification_extra_param()
+ *
+ */
+int download_set_auto_download(int download_id, bool enable);
+
+
+/**
+ * @brief Gets the value of option for auto download.
+ *
+ * @param [in] download The download id
+ * @param [out] enable The boolean value for auto download which is defined by clinet.
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_auto_download()
+ */
+int download_get_auto_download(int download_id, bool *enable);
+
+
+/**
+ * @brief Adds an HTTP header field to the download request
+ *
+ * @details The given HTTP header field will be included with the HTTP request of the download request. \n
+ * Refer to the <a href="http://www.w3.org/Protocols/rfc2616/rfc2616-sec4.html#sec4.2">HTTP/1.1: HTTP Message Headers</a>
+ * @remarks This function should be called before downloading (see download_start()) \n
+ * This function replaces any existing value for the given key. \n
+ * This function returns #DOWNLOAD_ERROR_INVALID_PARAMETER if field or value is zero-length string.
+ * @param [in] download The download id
+ * @param [in] field The name of the HTTP header field
+ * @param [in] value The value associated with given field
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_get_http_header_field()
+ * @see download_remove_http_header_field()
+ */
+int download_add_http_header_field(int download_id, const char *field, const char *value);
+
+
+/**
+ * @brief Gets the value associated with given HTTP header field from the download
+ *
+ * @remarks This function returns #DOWNLOAD_ERROR_INVALID_PARAMETER if field is zero-length string. \n
+ * The @a value must be released with free() by you.
+ * @param [in] download The download id
+ * @param [in] field The name of the HTTP header field
+ * @param [out] value The value associated with given field
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_FIELD_NOT_FOUND Specified field not found
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_add_http_header_field()
+ * @see download_remove_http_header_field()
+ */
+int download_get_http_header_field(int download_id, const char *field, char **value);
+
+
+/**
+ * @brief Removes the given HTTP header field from the download
+ *
+ * @remarks This function should be called before downloading (see download_start()) \n
+ * This function returns #DOWNLOAD_ERROR_INVALID_PARAMETER if field is zero-length string.
+ * @param [in] download The download id
+ * @param [in] field The name of the HTTP header field
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_FIELD_NOT_FOUND Specified field not found
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_FAILED, #DOWNLOAD_STATE_CANCELED
+ * @see download_add_http_header_field()
+ * @see download_get_http_header_field()
+ */
+int download_remove_http_header_field(int download_id, const char *field);
+
+
+/**
+ * @brief Registers a callback function to be invoked when the download state is changed.
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @param [in] callback The callback function to register
+ * @param [in] user_data The user data to be passed to the callback function
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @post download_state_changed_cb() will be invoked.
+ * @see download_unset_state_changed_cb()
+ * @see download_state_changed_cb()
+*/
+int download_set_state_changed_cb(int download_id, download_state_changed_cb callback, void* user_data);
+
+
+/**
+ * @brief Unregisters the callback function.
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_state_changed_cb()
+ * @see download_state_changed_cb()
+*/
+int download_unset_state_changed_cb(int download_id);
+
+
+/**
+ * @brief Registers a callback function to be invoked when progress of the download changes
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @param [in] callback The callback function to register
+ * @param [in] user_data The user data to be passed to the callback function
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @post download_progress_cb() will be invoked.
+ * @see download_unset_progress_cb()
+ * @see download_progress_cb()
+*/
+int download_set_progress_cb(int download_id, download_progress_cb callback, void *user_data);
+
+
+/**
+ * @brief Unregisters the callback function.
+ *
+ * @remarks This function should be called before downloading (see download_start())
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see download_set_progress_cb()
+ * @see download_progress_cb()
+*/
+int download_unset_progress_cb(int download_id);
+
+
+/**
+ * @brief Starts or resumes the download, asynchronously.
+ *
+ * @details This function starts to download the current URL, or resumes the download if paused.
+ *
+ * @remarks The URL is the mandatory information to start the download.
+ * @remarks It should call download_set_progress_cb() and download_set_state_changed_cb() again \n
+ * after the client process is restarted or download_destry() is called
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @retval #DOWNLOAD_ERROR_URL Invalid URL
+ * @retval #DOWNLOAD_ERROR_DESTINATION Invalid destination
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_READY, #DOWNLOAD_STATE_PAUSED, #DOWNLOAD_STATE_CANCELED, #DOWNLOAD_STATE_FAILED.
+ * @post The download state will be #DOWNLOAD_STATE_QUEUED or #DOWNLOAD_STATE_DOWNLOADING
+ * @see download_set_url()
+ * @see download_pause()
+ * @see download_cancel()
+ */
+int download_start(int download_id);
+
+
+/**
+ * @brief Pauses the download, asynchronously.
+ *
+ * @remarks The paused download can be restarted with download_start() or canceled with download_cancel()
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_DOWNLOADING.
+ * @post The download state will be #DOWNLOAD_STATE_PAUSED.
+ * @see download_start()
+ * @see download_cancel()
+ */
+int download_pause(int download_id);
+
+
+/**
+ * @brief Cancel the download, asynchronously.
+ *
+ * @details This function cancels the running download and its state will be #DOWNLOAD_STATE_READY
+ * @remarks The cancelled download can be restarted with download_start().
+ * @param [in] download The download id
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_OUT_OF_MEMORY Out of memory
+ * @retval #DOWNLOAD_ERROR_INVALID_STATE Invalid state
+ * @retval #DOWNLOAD_ERROR_IO_ERROR Internal I/O error
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_QUEUED, #DOWNLOAD_STATE_DOWNLOADING, #DOWNLOAD_STATE_PAUSED.
+ * @post The download state will be #DOWNLOAD_STATE_CANCELED.
+ * @see download_start()
+ */
+int download_cancel(int download_id);
+
+
+/**
+ * @brief Gets the download's current state.
+ *
+ * @param [in] download The download id
+ * @param [out] state The current state of the download
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @see #download_state_e
+ */
+int download_get_state(int download_id, download_state_e *state);
+
+
+/**
+ * @brief Gets the full path of temporary file for downloading a content.
+ *
+ * @param [in] download The download id
+ * @param [out] temp_path The full path of temporary file
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be one of state after #DOWNLOAD_STATE_DOWNLOADING.
+ * @see #download_set_state_changed_cb()
+ * @see #download_unset_state_changed_cb()
+ * @see download_start()
+ */
+int download_get_temp_path(int download_id, char **temp_path);
+
+
+/**
+ * @brief Gets the content name for downloading a file.
+ *
+ * @details This can be defined with referense of HTTP response header data.
+ * The content name can be received when HTTP response header is received.
+ *
+ * @param [in] download The download id
+ * @param [out] content_name The content name for displaying to user
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be one of state after #DOWNLOAD_STATE_DOWNLOADING.
+ * @see #download_set_state_changed_cb()
+ * @see #download_unset_state_changed_cb()
+ * @see download_start()
+ */
+int download_get_content_name(int download_id, char **content_name);
+
+
+/**
+ * @brief Gets the total size for downloading a content.
+ *
+ * @details This data receive from content server. If the content sever don't send total size of the content, the value set as zero.
+ *
+ * @param [in] download The download id
+ * @param [out] content_size The content size for displaying to user
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be one of state after #DOWNLOAD_STATE_DOWNLOADING.
+ * @see #download_set_state_changed_cb()
+ * @see #download_unset_state_changed_cb()
+ * @see download_start()
+ */
+int download_get_content_size(int download_id, unsigned long long *content_size);
+
+
+/**
+ * @brief Gets the error value when the download is failed.
+ *
+ * @param [in] download The download id
+ * @param [out] error The error value
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_FAILED.
+ * @pre The download state must be #DOWNLOAD_STATE_CANCELED.
+ * @see #download_set_state_changed_cb()
+ * @see #download_unset_state_changed_cb()
+ * @see download_start()
+ * @see download_error_e
+ */
+int download_get_error(int download_id, download_error_e *error);
+
+
+/**
+ * @brief Gets the http status code when the download error is happened.
+ *
+ * @param [in] download The download id
+ * @param [out] http_status The http status code which is defined in RFC 2616
+ * @return 0 on success, otherwise a negative error value.
+ * @retval #DOWNLOAD_ERROR_NONE Successful
+ * @retval #DOWNLOAD_ERROR_INVALID_PARAMETER Invalid parameter
+ * @retval #DOWNLOAD_ERROR_ID_NOT_FOUND No Download ID
+ * @pre The download state must be #DOWNLOAD_STATE_FAILED.
+ * @see #download_set_download_status_cb()
+ * @see #download_unset_download_status_cb()
+ * @see download_start()
+ */
+int download_get_http_status(int download_id, int *http_status);
+
+/**
+ * @}
+ */
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* __TIZEN_WEB_DOWNLOAD_H__ */
--- /dev/null
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+#include <fcntl.h>
+#include <errno.h>
+#include <unistd.h>
+
+#include <pthread.h>
+#include <signal.h>
+
+#include <dlog.h>
+#include <download.h>
+#include <download-provider.h>
+
+#ifdef DP_ECHO_TEST
+#define DOWNLOAD_ECHO_SUPPORT
+#endif
+#ifdef DOWNLOAD_ECHO_SUPPORT
+#include <sys/ioctl.h>
+#endif
+
+#ifdef DP_DBUS_ACTIVATION
+#include <dbus/dbus.h>
+#endif
+
+#define MAX_DOWNLOAD_HANDLE 5
+
+#define DEBUG_MSG
+//#define DEBUG_PRINTF
+
+#ifdef DEBUG_MSG
+#ifdef DEBUG_PRINTF
+#include <stdio.h>
+#define TRACE_ERROR(format, ARG...) \
+{ \
+fprintf(stderr,"[URL_DOWNLOAD][%s:%d] "format"\n", __FUNCTION__, __LINE__, ##ARG); \
+}
+#define TRACE_STRERROR(format, ARG...) \
+{ \
+fprintf(stderr,"[URL_DOWNLOAD][%s:%d] "format" [%s]\n", __FUNCTION__, __LINE__, ##ARG, strerror(errno)); \
+}
+#define TRACE_INFO(format, ARG...) \
+{ \
+fprintf(stderr,"[URL_DOWNLOAD][%s:%d] "format"\n", __FUNCTION__, __LINE__, ##ARG); \
+}
+#else
+#include <dlog.h>
+#ifdef LOG_TAG
+#undef LOG_TAG
+#endif
+#define LOG_TAG "TIZEN_N_URL_DOWNLOAD"
+
+#define TRACE_ERROR(format, ARG...) \
+{ \
+LOGE(format, ##ARG); \
+}
+#define TRACE_STRERROR(format, ARG...) \
+{ \
+LOGE(format" [%s]", ##ARG, strerror(errno)); \
+}
+#define TRACE_INFO(format, ARG...) \
+{ \
+LOGI(format, ##ARG); \
+}
+#endif
+#else
+#define TRACE_DEBUG_MSG(format, ARG...) ;
+#endif
+
+// define type
+typedef struct {
+ // send command * get return value.
+ int cmd_socket;
+ // getting event from download-provider
+ int event_socket;
+ pthread_mutex_t mutex; // lock before using, unlock after using
+} download_ipc_info;
+
+typedef struct {
+ download_state_changed_cb state;
+ void *state_user_data;
+ download_progress_cb progress;
+ void *progress_user_data;
+} download_cb_info;
+
+typedef struct {
+ int id;
+ download_cb_info callback;
+} download_slots;
+
+typedef struct {
+ int index;
+ dp_event_info *event;
+} download_event_info;
+
+// declare the variables
+download_ipc_info *g_download_ipc = NULL;
+download_slots g_download_slots[MAX_DOWNLOAD_HANDLE];
+static pthread_mutex_t g_download_mutex = PTHREAD_MUTEX_INITIALIZER;
+static pthread_t g_download_event_thread_pid = 0;
+
+#ifdef DP_DBUS_ACTIVATION
+/* DBUS Activation */
+static int _launch_download_provider_service(void)
+{
+ DBusConnection *connection = NULL;
+ DBusError dbus_error;
+
+ dbus_error_init(&dbus_error);
+
+ connection = dbus_bus_get(DBUS_BUS_SYSTEM, &dbus_error);
+ if (connection == NULL) {
+ TRACE_ERROR("[ERROR] dbus_bus_get");
+ if (dbus_error_is_set(&dbus_error)) {
+ TRACE_ERROR("[DBUS] dbus_bus_get: %s", dbus_error.message);
+ dbus_error_free(&dbus_error);
+ }
+ return -1;
+ }
+
+ dbus_uint32_t result = 0;
+ if (dbus_bus_start_service_by_name
+ (connection,
+ DP_DBUS_SERVICE_DBUS, 0, &result, &dbus_error) == FALSE) {
+ if (dbus_error_is_set(&dbus_error)) {
+ TRACE_ERROR("[DBUS] dbus_bus_start_service_by_name: %s",
+ dbus_error.message);
+ dbus_error_free(&dbus_error);
+ }
+ dbus_connection_unref(connection);
+ return -1;
+ }
+ if (result == DBUS_START_REPLY_ALREADY_RUNNING) {
+ TRACE_INFO("DBUS_START_REPLY_ALREADY_RUNNING [%d]", result);
+ } else if (result == DBUS_START_REPLY_SUCCESS) {
+ TRACE_INFO("DBUS_START_REPLY_SUCCESS [%d]", result);
+ }
+ dbus_connection_unref(connection);
+ return 0;
+}
+#endif
+
+//////////// defines functions /////////////////
+
+int _download_change_dp_errorcode(int errorcode)
+{
+ switch (errorcode)
+ {
+ case DP_ERROR_NONE :
+ return DOWNLOAD_ERROR_NONE;
+ case DP_ERROR_INVALID_PARAMETER :
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ case DP_ERROR_OUT_OF_MEMORY :
+ return DOWNLOAD_ERROR_OUT_OF_MEMORY;
+ case DP_ERROR_IO_ERROR :
+ return DOWNLOAD_ERROR_IO_ERROR;
+ case DP_ERROR_NETWORK_UNREACHABLE :
+ return DOWNLOAD_ERROR_NETWORK_UNREACHABLE;
+ case DP_ERROR_NO_SPACE :
+ return DOWNLOAD_ERROR_NO_SPACE;
+ case DP_ERROR_FIELD_NOT_FOUND :
+ return DOWNLOAD_ERROR_FIELD_NOT_FOUND;
+ case DP_ERROR_INVALID_STATE :
+ return DOWNLOAD_ERROR_INVALID_STATE;
+ case DP_ERROR_CONNECTION_FAILED :
+ return DOWNLOAD_ERROR_CONNECTION_TIMED_OUT;
+ case DP_ERROR_INVALID_URL :
+ return DOWNLOAD_ERROR_INVALID_URL;
+ case DP_ERROR_INVALID_DESTINATION :
+ return DOWNLOAD_ERROR_INVALID_DESTINATION;
+ case DP_ERROR_QUEUE_FULL :
+ return DOWNLOAD_ERROR_QUEUE_FULL;
+ case DP_ERROR_ALREADY_COMPLETED :
+ return DOWNLOAD_ERROR_ALREADY_COMPLETED;
+ case DP_ERROR_FILE_ALREADY_EXISTS :
+ return DOWNLOAD_ERROR_FILE_ALREADY_EXISTS;
+ case DP_ERROR_TOO_MANY_DOWNLOADS :
+ return DOWNLOAD_ERROR_TOO_MANY_DOWNLOADS;
+ case DP_ERROR_NO_DATA :
+ return DOWNLOAD_ERROR_NO_DATA;
+ case DP_ERROR_UNHANDLED_HTTP_CODE :
+ return DOWNLOAD_ERROR_UNHANDLED_HTTP_CODE;
+ case DP_ERROR_CANNOT_RESUME :
+ return DOWNLOAD_ERROR_CANNOT_RESUME;
+ case DP_ERROR_ID_NOT_FOUND :
+ return DOWNLOAD_ERROR_ID_NOT_FOUND;
+ case DP_ERROR_UNKNOWN :
+ return DOWNLOAD_ERROR_INVALID_STATE;
+ default:
+ break;
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int _download_change_dp_state(int state)
+{
+ switch (state)
+ {
+ case DP_STATE_READY:
+ return DOWNLOAD_STATE_READY;
+ case DP_STATE_CONNECTING:
+ return DOWNLOAD_STATE_QUEUED;
+ case DP_STATE_QUEUED :
+ return DOWNLOAD_STATE_QUEUED;
+ case DP_STATE_DOWNLOADING:
+ return DOWNLOAD_STATE_DOWNLOADING;
+ case DP_STATE_PAUSE_REQUESTED :
+ return DOWNLOAD_STATE_DOWNLOADING;
+ case DP_STATE_PAUSED :
+ return DOWNLOAD_STATE_PAUSED;
+ case DP_STATE_COMPLETED :
+ return DOWNLOAD_STATE_COMPLETED;
+ case DP_STATE_CANCELED :
+ return DOWNLOAD_STATE_CANCELED;
+ case DP_STATE_FAILED :
+ return DOWNLOAD_STATE_FAILED;
+ default:
+ break;
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+void _download_print_str_state(int state)
+{
+ switch (state)
+ {
+ case DOWNLOAD_STATE_READY:
+ TRACE_INFO("DOWNLOAD_STATE_READY");
+ break;
+ case DOWNLOAD_STATE_DOWNLOADING:
+ TRACE_INFO("DOWNLOAD_STATE_DOWNLOADING");
+ break;
+ case DOWNLOAD_STATE_QUEUED :
+ TRACE_INFO("DOWNLOAD_STATE_QUEUED");
+ break;
+ case DOWNLOAD_STATE_PAUSED :
+ TRACE_INFO("DOWNLOAD_STATE_PAUSED");
+ break;
+ case DOWNLOAD_STATE_COMPLETED :
+ TRACE_INFO("DOWNLOAD_STATE_COMPLETED");
+ break;
+ case DOWNLOAD_STATE_CANCELED :
+ TRACE_INFO("DOWNLOAD_STATE_CANCELED");
+ break;
+ case DOWNLOAD_STATE_FAILED :
+ TRACE_INFO("DOWNLOAD_STATE_FAILED");
+ break;
+ default:
+ TRACE_INFO("Unknown state (%d)", state);
+ break;
+ }
+}
+
+int _get_my_slot_index(int download_id)
+{
+ int i = 0;
+ // search same info in array.
+ for (; i < MAX_DOWNLOAD_HANDLE; i++)
+ if (g_download_slots[i].id == download_id)
+ return i;
+ return -1;
+}
+
+int _get_empty_slot_index()
+{
+ int i = 0;
+ for (; i < MAX_DOWNLOAD_HANDLE; i++)
+ if (g_download_slots[i].id <= 0)
+ return i;
+ return -1;
+}
+
+int _ipc_read_custom_type(int fd, void *value, size_t type_size)
+{
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK SOCKET]");
+ return -1;
+ }
+
+ if (read(fd, value, type_size) < 0) {
+ TRACE_STRERROR("[CRITICAL] read");
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return -1;
+ }
+ return 0;
+}
+
+int _download_ipc_read_int(int fd)
+{
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK SOCKET]");
+ return -1;
+ }
+
+ int value = -1;
+ if (read(fd, &value, sizeof(int)) < 0) {
+ TRACE_STRERROR("[CRITICAL] read");
+ // for debugging.
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return -1;
+ }
+
+ TRACE_INFO(" %d", value);
+ return value;
+}
+
+// keep the order/ unsigned , str
+char* _ipc_read_string(int fd)
+{
+ unsigned length = 0;
+ char *str = NULL;
+
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK FD]");
+ return NULL;
+ }
+
+ // read flexible URL from client.
+ if (read(fd, &length, sizeof(unsigned)) < 0) {
+ TRACE_STRERROR("failed to read length [%d]", length);
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return NULL;
+ }
+ if (length < 1 || length > DP_MAX_STR_LEN) {
+ TRACE_ERROR("[STRING LEGNTH] [%d]", length);
+ return NULL;
+ }
+ str = (char *)calloc((length + 1), sizeof(char));
+ if (!str) {
+ TRACE_STRERROR("[CRITICAL] allocation");
+ return NULL;
+ }
+ if (read(fd, str, length * sizeof(char)) < 0) {
+ TRACE_STRERROR("failed to read string");
+ free(str);
+ str = NULL;
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return NULL;
+ }
+ str[length] = '\0';
+ return str;
+}
+
+download_error_e _download_ipc_read_return(int fd)
+{
+ download_error_e errorcode = DOWNLOAD_ERROR_NONE;
+ dp_error_type error_info = DP_ERROR_NONE;
+
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK SOCKET]");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (read(fd, &error_info, sizeof(dp_error_type)) < 0) {
+ TRACE_STRERROR("[CRITICAL] read");
+ // maybe, download-provider was crashed.
+ // for debugging.
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ errorcode = _download_change_dp_errorcode(error_info);
+ TRACE_INFO("return : %d", errorcode);
+ return errorcode;
+}
+
+dp_event_info* _download_ipc_read_event(int fd)
+{
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK SOCKET]");
+ return NULL;
+ }
+
+ dp_event_info *event =
+ (dp_event_info *) calloc(1, sizeof(dp_event_info));
+ if (event == NULL) {
+ TRACE_ERROR("[CHECK ALLOCATION]");
+ return NULL;
+ }
+ if (read(fd, event, sizeof(dp_event_info)) < 0) {
+ TRACE_STRERROR("[CRITICAL] read");
+ free(event);
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return NULL;
+ }
+
+ TRACE_INFO("EVENT INFO (ID : %d state : %d error : %d)",
+ event->id, event->state, event->err);
+ return event;
+}
+
+int _ipc_send_int(int fd, int value)
+{
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK FD] [%d]", fd);
+ return -1;
+ }
+
+ if (fd >= 0 && write(fd, &value, sizeof(int)) < 0) {
+ TRACE_STRERROR("send");
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return -1;
+ }
+ return 0;
+}
+
+// keep the order/ unsigned , str
+int _ipc_send_string(int fd, const char *str)
+{
+ unsigned length = 0;
+
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK FD]");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (!str) {
+ TRACE_ERROR("[CHECK STRING]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ length = strlen(str);
+ if (length < 1) {
+ TRACE_ERROR("[CHECK LENGTH]");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (fd >= 0 && write(fd, &length, sizeof(unsigned)) < 0) {
+ TRACE_STRERROR("send");
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (fd >= 0 && write(fd, str, length * sizeof(char)) < 0) {
+ TRACE_STRERROR("send");
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int _download_ipc_send_command(int fd, int id, dp_command_type cmd)
+{
+ if (fd < 0) {
+ TRACE_ERROR("[CHECK SOCKET]");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ dp_command command;
+ command.id = id;
+ command.cmd = cmd;
+ if (fd >= 0 && write(fd, &command, sizeof(dp_command)) < 0) {
+ TRACE_STRERROR("[CRITICAL] send");
+ if (errno == EPIPE) {
+ TRACE_INFO("[EPIPE] Broken Pipe errno [%d]", errno);
+ } else if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] Resource temporarily unavailable errno [%d]", errno);
+ } else {
+ TRACE_INFO("errno [%d]", errno);
+ }
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+download_error_e _send_simple_cmd(int id, dp_command_type cmd )
+{
+ TRACE_INFO("");
+
+ if (cmd <= DP_CMD_NONE) {
+ TRACE_ERROR("[CHECK COMMAND] (%d)", cmd);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, id, cmd) != DOWNLOAD_ERROR_NONE) {
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ return errorcode;
+}
+
+int __create_socket()
+{
+ TRACE_INFO("");
+ int sockfd = -1;
+ struct timeval tv_timeo = { 2, 500000 }; //2.5 second
+
+ struct sockaddr_un clientaddr;
+ if ((sockfd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
+ TRACE_STRERROR("[CRITICAL] socket system error");
+ return -1;
+ }
+
+ if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &tv_timeo,
+ sizeof( tv_timeo ) ) < 0) {
+ TRACE_STRERROR("[CRITICAL] setsockopt SO_SNDTIMEO");
+ close(sockfd);
+ return -1;
+ }
+ if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &tv_timeo,
+ sizeof( tv_timeo ) ) < 0) {
+ TRACE_STRERROR("[CRITICAL] setsockopt SO_SNDTIMEO");
+ close(sockfd);
+ return -1;
+ }
+
+ bzero(&clientaddr, sizeof clientaddr);
+ clientaddr.sun_family = AF_UNIX;
+ memset(clientaddr.sun_path, 0x00, sizeof(clientaddr.sun_path));
+ strncpy(clientaddr.sun_path, DP_IPC, strlen(DP_IPC));
+ clientaddr.sun_path[strlen(DP_IPC)] = '\0';
+ if (connect(sockfd,
+ (struct sockaddr*)&clientaddr, sizeof(clientaddr)) < 0) {
+ close(sockfd);
+ return -1;
+ }
+ TRACE_INFO("sockfd [%d]", sockfd);
+ return sockfd;
+}
+
+int _disconnect_from_provider()
+{
+ TRACE_INFO("");
+ if (g_download_ipc != NULL) {
+ shutdown(g_download_ipc->cmd_socket, 0);
+ close(g_download_ipc->cmd_socket);
+ g_download_ipc->cmd_socket= -1;
+ shutdown(g_download_ipc->event_socket, 0);
+ close(g_download_ipc->event_socket);
+ g_download_ipc->event_socket = -1;
+ pthread_mutex_destroy((&g_download_ipc->mutex));
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+
+ if (g_download_event_thread_pid > 0) {
+ TRACE_INFO("STOP event thread");
+ pthread_cancel(g_download_event_thread_pid);
+ g_download_event_thread_pid = 0;
+ TRACE_INFO("OK terminate event thread");
+ }
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+// clear read buffer. call in head of API before calling IPC_SEND
+void __clear_read_buffer(int fd)
+{
+ long i;
+ long unread_count;
+ char tmp_char;
+
+ // FIONREAD : Returns the number of bytes immediately readable
+ if (ioctl(fd, FIONREAD, &unread_count) >= 0) {
+ if (unread_count > 0) {
+ TRACE_INFO("[CLEAN] garbage packet[%ld]", unread_count);
+ for ( i = 0; i < unread_count; i++) {
+ if (read(fd, &tmp_char, sizeof(char)) < 0) {
+ TRACE_STRERROR("[CHECK] read");
+ break;
+ }
+ }
+ }
+ }
+}
+
+// ask to provider before sending a command.
+// if provider wait in some commnad, can not response immediately
+// capi will wait in read block.
+// after asking, call clear_read_buffer.
+
+
+int _check_ipc_status(int fd)
+{
+ // echo from provider
+ download_error_e errorcode = _send_simple_cmd(-1, DP_CMD_ECHO);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ TRACE_INFO("[ECHO] [%d]", errorcode);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ if (errno == EAGAIN) {
+ TRACE_INFO("[EAGAIN] provider is busy");
+ } else {
+ TRACE_INFO("[CRITICAL] Broken Socket");
+ _disconnect_from_provider();
+ }
+ return -1;
+ }
+ }
+ __clear_read_buffer(fd);
+ return 0;
+}
+#endif
+
+// listen ASYNC state event, no timeout
+void *_download_event_manager(void *arg)
+{
+ int maxfd, index;
+ fd_set rset, read_fdset;
+ dp_event_info *eventinfo = NULL;
+
+ if (g_download_ipc == NULL || g_download_ipc->event_socket < 0) {
+ TRACE_STRERROR("[CRITICAL] IPC NOT ESTABILISH");
+ return 0;
+ }
+
+ // deferred wait to cencal until next function called.
+ // ex) function : select, read in this thread
+ pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);
+
+ TRACE_INFO("FD [%d]", g_download_ipc->event_socket);
+
+ maxfd = g_download_ipc->event_socket;
+ FD_ZERO(&read_fdset);
+ FD_SET(g_download_ipc->event_socket, &read_fdset);
+
+ while(g_download_ipc != NULL
+ && g_download_ipc->event_socket >= 0) {
+ rset = read_fdset;
+ if (select((maxfd + 1), &rset, 0, 0, 0) < 0) {
+ TRACE_STRERROR("[CRITICAL] select");
+ break;
+ }
+
+ if (g_download_event_thread_pid <=0
+ || pthread_self() != g_download_event_thread_pid) {
+ TRACE_ERROR
+ ("[CRITICAL] [CHECK TID] SELF ID [%d] Global ID (%d)",
+ pthread_self(), g_download_event_thread_pid);
+ // another thread may work. just terminate
+ return 0;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ if (g_download_ipc == NULL
+ || g_download_ipc->event_socket < 0) {
+ TRACE_ERROR("[CRITICAL] IPC BROKEN Ending Event Thread");
+ pthread_mutex_unlock(&g_download_mutex);
+ // disconnected by main thread. just terminate
+ return 0;
+ }
+
+ if (FD_ISSET(g_download_ipc->event_socket, &rset) > 0) {
+ // read state info from socket
+ eventinfo =
+ _download_ipc_read_event(g_download_ipc->event_socket);
+ if (!eventinfo || eventinfo->id <= 0) {
+ // failed to read from socket // ignore this status
+ if (eventinfo)
+ free(eventinfo);
+ TRACE_STRERROR("[CRITICAL] Can not read Event packet");
+ pthread_mutex_unlock(&g_download_mutex);
+ if (errno != EAGAIN) // if not timeout. end thread
+ break;
+ continue;
+ }
+ index = _get_my_slot_index(eventinfo->id);
+ if (index < 0) {
+ TRACE_ERROR
+ ("[CRITICAL] not found slot for [%d]",
+ eventinfo->id);
+ free(eventinfo);
+ pthread_mutex_unlock(&g_download_mutex);
+ continue;
+ }
+
+ pthread_mutex_unlock(&g_download_mutex);
+
+ // begin protect callback sections
+ pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
+
+ if (eventinfo->state == DP_STATE_DOWNLOADING
+ && eventinfo->received_size > 0) {
+ if (g_download_slots[index].callback.progress) {
+ // progress event
+ TRACE_INFO("ID %d progress callback %p",
+ eventinfo->id,
+ g_download_slots[index].callback.progress );
+ g_download_slots[index].callback.progress
+ (eventinfo->id, eventinfo->received_size,
+ g_download_slots[index].callback.progress_user_data);
+ }
+ } else {
+ if (g_download_slots[index].callback.state) {
+ // state event
+ TRACE_INFO("ID %d state callback %p",
+ eventinfo->id,
+ g_download_slots[index].callback.state );
+ g_download_slots[index].callback.state
+ (eventinfo->id,
+ _download_change_dp_state(eventinfo->state),
+ g_download_slots[index].callback.state_user_data);
+ }
+ }
+ free(eventinfo);
+
+ // end protect callback sections
+ pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL);
+ continue;
+ }
+ pthread_mutex_unlock(&g_download_mutex);
+ } // while
+
+ FD_ZERO(&read_fdset);
+
+ TRACE_INFO("Terminate Event Thread");
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("Disconnect All Connection");
+ g_download_event_thread_pid = 0; // set 0 to not call pthread_cancel
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return 0;
+}
+
+
+int _connect_to_provider()
+{
+ TRACE_INFO("");
+ if (g_download_ipc == NULL) {
+ #ifdef DP_DBUS_ACTIVATION
+ if (_launch_download_provider_service() < 0) {
+ TRACE_ERROR("[DBUS IO] _launch_download_provider_service");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ #endif
+ g_download_ipc =
+ (download_ipc_info *) calloc(1, sizeof(download_ipc_info));
+ }
+
+ if (g_download_ipc != NULL) {
+
+ int connect_retry = 3;
+ g_download_ipc->cmd_socket = -1;
+ while(g_download_ipc->cmd_socket < 0 && connect_retry-- > 0) {
+ g_download_ipc->cmd_socket = __create_socket();
+ if (g_download_ipc->cmd_socket < 0)
+ usleep(50000);
+ }
+ if (g_download_ipc->cmd_socket < 0) {
+ TRACE_STRERROR("[CRITICAL] connect system error");
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // send a command
+ if (_ipc_send_int(g_download_ipc->cmd_socket,
+ DP_CMD_SET_COMMAND_SOCKET) < 0) {
+ close(g_download_ipc->cmd_socket);
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ #ifndef SO_PEERCRED
+ // send PID. Not support SO_PEERCRED
+ if (_ipc_send_int(g_download_ipc->cmd_socket, get_pid()) < 0) {
+ close(g_download_ipc->cmd_socket);
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ #endif
+ g_download_ipc->event_socket = __create_socket();
+ if (g_download_ipc->event_socket < 0) {
+ TRACE_STRERROR("[CRITICAL] connect system error");
+ close(g_download_ipc->cmd_socket);
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // send a command
+ if (_ipc_send_int(g_download_ipc->event_socket,
+ DP_CMD_SET_EVENT_SOCKET) < 0) {
+ close(g_download_ipc->cmd_socket);
+ close(g_download_ipc->event_socket);
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ #ifndef SO_PEERCRED
+ // send PID. Not support SO_PEERCRED
+ if (_ipc_send_int
+ (g_download_ipc->event_socket, get_pid()) < 0) {
+ close(g_download_ipc->cmd_socket);
+ close(g_download_ipc->event_socket);
+ free(g_download_ipc);
+ g_download_ipc = NULL;
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ #endif
+
+ int ret = pthread_mutex_init((&g_download_ipc->mutex), NULL);
+ if (ret != 0) {
+ TRACE_STRERROR("ERR:pthread_mutex_init FAIL with %d.", ret);
+ _disconnect_from_provider();
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (g_download_event_thread_pid <= 0) {
+ // create thread here ( getting event_socket )
+ pthread_attr_t thread_attr;
+ if (pthread_attr_init(&thread_attr) != 0) {
+ TRACE_STRERROR("[CRITICAL] pthread_attr_init");
+ _disconnect_from_provider();
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (pthread_attr_setdetachstate(&thread_attr,
+ PTHREAD_CREATE_DETACHED) != 0) {
+ TRACE_STRERROR("[CRITICAL] pthread_attr_setdetachstate");
+ _disconnect_from_provider();
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (pthread_create(&g_download_event_thread_pid,
+ &thread_attr,
+ _download_event_manager,
+ g_download_ipc) != 0) {
+ TRACE_STRERROR("[CRITICAL] pthread_create");
+ _disconnect_from_provider();
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ }
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+download_error_e _check_connections()
+{
+ int ret = 0;
+ if (g_download_ipc == NULL)
+ if ((ret = _connect_to_provider()) != DOWNLOAD_ERROR_NONE)
+ return ret;
+ if (g_download_ipc == NULL || g_download_ipc->cmd_socket < 0) {
+ TRACE_ERROR("[CHECK IPC]");
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ return DOWNLOAD_ERROR_NONE;
+}
+
+
+
+/////////////////////// APIs /////////////////////////////////
+
+int download_create(int *download_id)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ int t_download_id = 0;
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ int index = _get_empty_slot_index();
+ if (index < 0) {
+ TRACE_ERROR
+ ("[ERROR] TOO_MANY_DOWNLOADS[%d]", MAX_DOWNLOAD_HANDLE);
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_TOO_MANY_DOWNLOADS;
+ }
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(-1, DP_CMD_CREATE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ // getting state with ID from provider.
+ t_download_id = _download_ipc_read_int(g_download_ipc->cmd_socket);
+ if (t_download_id < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ TRACE_INFO("ID : %d", t_download_id);
+
+ *download_id = t_download_id;
+ g_download_slots[index].id = t_download_id;
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_destroy(int download_id)
+{
+ int index = -1;
+ int errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ index = _get_my_slot_index(download_id);
+ if (index >= 0) {
+ g_download_slots[index].id = 0;
+ g_download_slots[index].callback.state = NULL;
+ g_download_slots[index].callback.state_user_data = NULL;
+ g_download_slots[index].callback.progress = NULL;
+ g_download_slots[index].callback.progress_user_data = NULL;
+ }
+ errorcode = _send_simple_cmd(download_id, DP_CMD_DESTROY);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ // after getting errorcode, send FREE to provider.
+ TRACE_INFO("Request to Free the memory for ID : %d", download_id);
+ // send again DP_CMD_FREE with ID.
+ errorcode = _download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_FREE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_start(int download_id)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_START);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_pause(int download_id)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_PAUSE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_cancel(int download_id)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_CANCEL);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+
+int download_set_url(int download_id, const char *url)
+{
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!url) {
+ TRACE_ERROR("[CHECK url]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ TRACE_INFO("");
+ pthread_mutex_lock(&g_download_mutex);
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_SET_URL)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_string(g_download_ipc->cmd_socket, url)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+
+int download_get_url(int download_id, char **url)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_URL);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting state with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *url = value;
+ TRACE_INFO("ID : %d url : %s", download_id, *url);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_network_type(int download_id,
+ download_network_type_e net_type)
+{
+ int network_type = DP_NETWORK_TYPE_ALL;
+
+ if (net_type == DOWNLOAD_NETWORK_WIFI)
+ network_type = DP_NETWORK_TYPE_WIFI;
+ else if (net_type == DOWNLOAD_NETWORK_DATA_NETWORK)
+ network_type = DP_NETWORK_TYPE_DATA_NETWORK;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_NETWORK_TYPE)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, network_type) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_network_type(int download_id,
+ download_network_type_e *net_type)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ int network_type = DP_NETWORK_TYPE_ALL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_NETWORK_TYPE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ network_type = _download_ipc_read_int(g_download_ipc->cmd_socket);
+ if (network_type < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (network_type == DP_NETWORK_TYPE_WIFI)
+ *net_type = DOWNLOAD_NETWORK_WIFI;
+ else if (network_type == DP_NETWORK_TYPE_DATA_NETWORK)
+ *net_type = DOWNLOAD_NETWORK_DATA_NETWORK;
+ else
+ *net_type = DOWNLOAD_NETWORK_ALL;
+
+ TRACE_INFO("ID : %d network_type : %d", download_id, *net_type);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_destination(int download_id, const char *path)
+{
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!path) {
+ TRACE_ERROR("[CHECK PATH]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_SET_DESTINATION)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_string(g_download_ipc->cmd_socket, path)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+
+int download_get_destination(int download_id, char **path)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode =
+ _send_simple_cmd(download_id, DP_CMD_GET_DESTINATION);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting string with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *path = value;
+ TRACE_INFO("ID : %d path : %s", download_id, *path);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_file_name(int download_id, const char *file_name)
+{
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!file_name) {
+ TRACE_ERROR("[CHECK file_name]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_SET_FILENAME)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_string(g_download_ipc->cmd_socket, file_name)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_file_name(int download_id, char **file_name)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode =
+ _send_simple_cmd(download_id, DP_CMD_GET_FILENAME);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting string with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *file_name = value;
+ TRACE_INFO("ID : %d file_name : %s", download_id, *file_name);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_ongoing_notification(int download_id, bool enable)
+{
+ return download_set_notification(download_id, enable);
+}
+
+int download_set_notification(int download_id, bool enable)
+{
+ int value = enable;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_NOTIFICATION)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, value) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+
+}
+
+int download_get_ongoing_notification(int download_id, bool *enable)
+{
+ return download_get_notification(download_id, enable);
+}
+
+int download_get_notification(int download_id, bool *enable)
+{
+ int value = 0;
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_NOTIFICATION);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ value = _download_ipc_read_int(g_download_ipc->cmd_socket);
+ if (value < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *enable = value;
+ TRACE_INFO("ID : %d auto download : %d", download_id, *enable);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+
+}
+
+int download_get_downloaded_file_path(int download_id, char **path)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode =
+ _send_simple_cmd(download_id, DP_CMD_GET_SAVED_PATH);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting string with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *path = value;
+ TRACE_INFO("ID : %d path : %s", download_id, *path);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_notification_extra_param(int download_id, char *key, char *value)
+{
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!key || !value) {
+ TRACE_ERROR("[CHECK param]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ TRACE_INFO("");
+ pthread_mutex_lock(&g_download_mutex);
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_SET_EXTRA_PARAM)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_string(g_download_ipc->cmd_socket, key)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (_ipc_send_string(g_download_ipc->cmd_socket, value)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_notification_extra_param(int download_id, char **key, char **value)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *key_str = NULL;
+ char *value_str = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_EXTRA_PARAM);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting state with ID from provider.
+ key_str = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (key_str == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ value_str = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value_str == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ free(key_str);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ *key = key_str;
+ *value = value_str;
+ TRACE_INFO("ID : %d key : %s value : %s", download_id, *key, *value);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_add_http_header_field(int download_id, const char *field,
+ const char *value)
+{
+ download_error_e errorcode = DOWNLOAD_ERROR_NONE;
+ TRACE_INFO("");
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!field || !value) {
+ TRACE_ERROR("[CHECK field or value]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_SET_HTTP_HEADER)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (_ipc_send_string(g_download_ipc->cmd_socket, field)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ if (_ipc_send_string(g_download_ipc->cmd_socket, value)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_http_header_field(int download_id,
+ const char *field, char **value)
+{
+ download_error_e errorcode = DOWNLOAD_ERROR_NONE;
+ char *str = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ if (!field || !value) {
+ TRACE_ERROR("[CHECK field or value]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_GET_HTTP_HEADER)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ if (_ipc_send_string(g_download_ipc->cmd_socket, field)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ // getting string with ID from provider.
+ str = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (str == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *value = str;
+ TRACE_INFO("ID : %d field:%s value: %s", download_id, field, *value);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_remove_http_header_field(int download_id,
+ const char *field)
+{
+ download_error_e errorcode = DOWNLOAD_ERROR_NONE;
+
+ TRACE_INFO("");
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (!field) {
+ TRACE_ERROR("[CHECK field]");
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // send commnad with ID
+ if (_download_ipc_send_command
+ (g_download_ipc->cmd_socket, download_id, DP_CMD_DEL_HTTP_HEADER)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_string(g_download_ipc->cmd_socket, field)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+
+ return errorcode;
+}
+
+int download_set_state_changed_cb(int download_id,
+ download_state_changed_cb callback, void* user_data)
+{
+ int index = -1;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (callback == NULL) {
+ download_unset_state_changed_cb(download_id);
+ return DOWNLOAD_ERROR_NONE;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // turn on state_cb flag of provider
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+ // send create command.
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_STATE_CALLBACK)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_state_changed_cb(download_id);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, 1) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_state_changed_cb(download_id);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_state_changed_cb(download_id);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_NONE) {
+ // search same info in array.
+ index = _get_my_slot_index(download_id);
+ if (index < 0) {
+ index = _get_empty_slot_index();
+ if (index < 0) {
+ TRACE_ERROR
+ ("[ERROR] TOO_MANY_DOWNLOADS[%d]", MAX_DOWNLOAD_HANDLE);
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_TOO_MANY_DOWNLOADS;
+ }
+ g_download_slots[index].id = download_id;
+ }
+ g_download_slots[index].callback.state = callback;
+ g_download_slots[index].callback.state_user_data = user_data;
+ }
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_unset_state_changed_cb(int download_id)
+{
+ int index = -1;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ index = _get_my_slot_index(download_id);
+ if (index >= 0) {
+ g_download_slots[index].callback.state = NULL;
+ g_download_slots[index].callback.state_user_data = NULL;
+ }
+ // turn off state_cb flag of provider
+ // send create command.
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_STATE_CALLBACK)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, 0) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_set_progress_cb(int download_id,
+ download_progress_cb callback, void *user_data)
+{
+ int index = -1;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+ if (callback == NULL) {
+ download_unset_progress_cb(download_id);
+ return DOWNLOAD_ERROR_NONE;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ // turn on progress_cb flag of provider
+ // send create command.
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_PROGRESS_CALLBACK)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_progress_cb(download_id);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, 1) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_progress_cb(download_id);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ download_unset_progress_cb(download_id);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_NONE) {
+ // search same info in array.
+ index = _get_my_slot_index(download_id);
+ if (index < 0) {
+ index = _get_empty_slot_index();
+ if (index < 0) {
+ TRACE_ERROR
+ ("[ERROR] TOO_MANY_DOWNLOADS[%d]", MAX_DOWNLOAD_HANDLE);
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_TOO_MANY_DOWNLOADS;
+ }
+ g_download_slots[index].id = download_id;
+ }
+
+ g_download_slots[index].callback.progress = callback;
+ g_download_slots[index].callback.progress_user_data = user_data;
+ }
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_unset_progress_cb(int download_id)
+{
+ int index = -1;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ index = _get_my_slot_index(download_id);
+ if (index >= 0) {
+ g_download_slots[index].callback.progress = NULL;
+ g_download_slots[index].callback.progress_user_data = NULL;
+ }
+ // turn off progress_cb flag of provider
+ // send create command.
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_PROGRESS_CALLBACK)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, 0) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_state(int download_id, download_state_e *state)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ dp_state_type dp_state = DP_STATE_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_STATE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting state with ID from provider.
+ if (_ipc_read_custom_type(g_download_ipc->cmd_socket,
+ &dp_state, sizeof(dp_state_type)) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *state = _download_change_dp_state(dp_state);
+ TRACE_INFO("ID : %d state : %d", download_id, *state);
+ _download_print_str_state(*state);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_temp_path(int download_id, char **temp_path)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode =
+ _send_simple_cmd(download_id, DP_CMD_GET_TEMP_SAVED_PATH);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting string with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *temp_path = value;
+ TRACE_INFO("ID : %d temp_path : %s", download_id, *temp_path);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_content_name(int download_id, char **content_name)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_CONTENT_NAME);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting string with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *content_name = value;
+ TRACE_INFO("ID : %d content_name : %s", download_id, *content_name);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_content_size(int download_id,
+ unsigned long long *content_size)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_TOTAL_FILE_SIZE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ // getting content_size from provider.
+ errorcode = _ipc_read_custom_type(g_download_ipc->cmd_socket,
+ content_size, sizeof(unsigned long long));
+ if (errorcode < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ TRACE_INFO("ID : %d content_size %lld", download_id, *content_size);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_mime_type(int download_id, char **mime_type)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ char *value = NULL;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_MIME_TYPE);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting state with ID from provider.
+ value = _ipc_read_string(g_download_ipc->cmd_socket);
+ if (value == NULL) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *mime_type = value;
+ TRACE_INFO("ID : %d mime_type : %s", download_id, *mime_type);
+ // it need to free
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_set_auto_download(int download_id, bool enable)
+{
+ int value = enable;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ if (_download_ipc_send_command(g_download_ipc->cmd_socket,
+ download_id, DP_CMD_SET_AUTO_DOWNLOAD)
+ != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ if (_ipc_send_int(g_download_ipc->cmd_socket, value) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ // return from provider.
+ download_error_e errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+}
+
+int download_get_auto_download(int download_id, bool *enable)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ int value = 0;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_AUTO_DOWNLOAD);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+
+ value = _download_ipc_read_int(g_download_ipc->cmd_socket);
+ if (value < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *enable = (bool)value;
+ TRACE_INFO("ID : %d auto download : %d", download_id, *enable);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_error(int download_id, download_error_e *error)
+{
+ download_error_e errorcode = DOWNLOAD_ERROR_NONE;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_ERROR);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting errorcode from provider.
+ errorcode =
+ _download_ipc_read_return(g_download_ipc->cmd_socket);
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR) {
+ TRACE_ERROR("[CHECK IO] (%d)", download_id);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ *error = errorcode;
+ TRACE_INFO("ID : %d error : %d", download_id, *error);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
+int download_get_http_status(int download_id, int *http_status)
+{
+ int errorcode = DOWNLOAD_ERROR_NONE;
+ int status = 0;
+
+ if (download_id <= 0) {
+ TRACE_ERROR("[CHECK ID] (%d)", download_id);
+ return DOWNLOAD_ERROR_INVALID_PARAMETER;
+ }
+
+ pthread_mutex_lock(&g_download_mutex);
+ TRACE_INFO("");
+
+ if (_check_connections() != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+
+ pthread_mutex_lock((&g_download_ipc->mutex));
+
+#ifdef DOWNLOAD_ECHO_SUPPORT
+ if (_check_ipc_status(g_download_ipc->cmd_socket) < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+#endif
+
+ errorcode = _send_simple_cmd(download_id, DP_CMD_GET_HTTP_STATUS);
+ if (errorcode != DOWNLOAD_ERROR_NONE) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errorcode == DOWNLOAD_ERROR_IO_ERROR && errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return errorcode;
+ }
+ // getting int from provider.
+ status = _download_ipc_read_int(g_download_ipc->cmd_socket);
+ if (status < 0) {
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ if (errno != EAGAIN)
+ _disconnect_from_provider();
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_IO_ERROR;
+ }
+ *http_status = status;
+ TRACE_INFO("ID : %d http_status : %d", download_id, *http_status);
+ pthread_mutex_unlock((&g_download_ipc->mutex));
+ pthread_mutex_unlock(&g_download_mutex);
+ return DOWNLOAD_ERROR_NONE;
+}
+
projects / platform / core / api / url-download.git / commitdiff