From: Bang Kwang min <justine.bang@samsung.com>
Date: Tue, 28 Aug 2012 07:27:57 +0000 (+0900)
Subject: pause/resume the download even if no socket or callback
X-Git-Tag: 2.0_alpha~14
X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=19d91820521bc53021c79f40eea64a921b87b6c7;p=platform%2Fcore%2Fapi%2Furl-download.git

pause/resume the download even if no socket or callback

[Title] pause/resume the download even if no socket or callback
[Issue#] N/A
[Problem] N/A
[Cause] N/A
[Solution] N/A
[SCMRequest] N/A

Change-Id: Ie51f17a144cd8c7bdd77506197383ea5d31f75c8
---

diff --git a/src/url_download_provider.c b/src/url_download_provider.c
index eacd84f..ab56d40 100644
--- a/src/url_download_provider.c
+++ b/src/url_download_provider.c
@@ -843,27 +843,105 @@ int url_download_start(url_download_h download, int *id)
 // send pause message
 int url_download_pause(url_download_h download)
 {
-	if (download == NULL || download->sockfd <= 0)
+	if (download == NULL)
 		return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_INVALID_PARAMETER, NULL);
 
 	if (download->state != URL_DOWNLOAD_STATE_DOWNLOADING)
 		return url_download_error_invalid_state(__FUNCTION__, download);
 
-	ipc_send_download_control(download->sockfd, DOWNLOAD_CONTROL_PAUSE);
-
+	if (download->sockfd > 0) {
+		ipc_send_download_control(download->sockfd, DOWNLOAD_CONTROL_PAUSE);
+		if (!(download->callback.completed
+			|| download->callback.stopped
+			|| download->callback.progress
+			|| download->callback.paused)) {  // if no callback
+			// Sync style
+			if (ipc_receive_header(download->sockfd) == DOWNLOAD_CONTROL_GET_STATE_INFO) {
+				download_state_info stateinfo;
+				if (read(download->sockfd, &stateinfo, sizeof(download_state_info)) < 0)
+					return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+				download->state = url_download_provider_state(stateinfo.state);
+			} else
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+		}
+	} else { // if no socket
+		int sockfd = _connect_download_provider();
+		if (sockfd > 0) {
+			ipc_send_download_control(sockfd, DOWNLOAD_CONTROL_PAUSE);
+			download_request_info requestMsg;
+			memset(&requestMsg, 0x00, sizeof(download_request_info));
+			if (download->requestid > 0)
+				requestMsg.requestid = download->requestid;
+			if (ipc_send_request_stateinfo(sockfd, &requestMsg)
+				!= URL_DOWNLOAD_ERROR_NONE) {
+				LOGE("[%s]request send system error : %s",
+					__FUNCTION__, strerror(errno));
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+			}
+			// Sync style
+			if (ipc_receive_header(sockfd) == DOWNLOAD_CONTROL_GET_STATE_INFO) {
+				download_state_info stateinfo;
+				if (read(sockfd, &stateinfo, sizeof(download_state_info)) < 0)
+					return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+				download->state = url_download_provider_state(stateinfo.state);
+			} else
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+			// close socket.
+			_clear_socket(sockfd);
+		}
+	}
 	return URL_DOWNLOAD_ERROR_NONE;
 }
 
 int url_download_resume(url_download_h download)
 {
-	if (download == NULL || download->sockfd <= 0)
+	if (download == NULL)
 		return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_INVALID_PARAMETER, NULL);
 
 	if (download->state != URL_DOWNLOAD_STATE_PAUSED)
 		return url_download_error_invalid_state(__FUNCTION__, download);
 
-	ipc_send_download_control(download->sockfd, DOWNLOAD_CONTROL_RESUME);
-
+	if (download->sockfd > 0) {
+		ipc_send_download_control(download->sockfd, DOWNLOAD_CONTROL_RESUME);
+		if (!(download->callback.completed
+			|| download->callback.stopped
+			|| download->callback.progress
+			|| download->callback.paused)) {  // if no callback
+			// Sync style
+			if (ipc_receive_header(download->sockfd) == DOWNLOAD_CONTROL_GET_STATE_INFO) {
+				download_state_info stateinfo;
+				if (read(download->sockfd, &stateinfo, sizeof(download_state_info)) < 0)
+					return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+				download->state = url_download_provider_state(stateinfo.state);
+			} else
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+		}
+	} else { // if no socket
+		int sockfd = _connect_download_provider();
+		if (sockfd > 0) {
+			ipc_send_download_control(sockfd, DOWNLOAD_CONTROL_RESUME);
+			download_request_info requestMsg;
+			memset(&requestMsg, 0x00, sizeof(download_request_info));
+			if (download->requestid > 0)
+				requestMsg.requestid = download->requestid;
+			if (ipc_send_request_stateinfo(sockfd, &requestMsg)
+				!= URL_DOWNLOAD_ERROR_NONE) {
+				LOGE("[%s]request send system error : %s",
+					__FUNCTION__, strerror(errno));
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+			}
+			// Sync style
+			if (ipc_receive_header(sockfd) == DOWNLOAD_CONTROL_GET_STATE_INFO) {
+				download_state_info stateinfo;
+				if (read(sockfd, &stateinfo, sizeof(download_state_info)) < 0)
+					return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+				download->state = url_download_provider_state(stateinfo.state);
+			} else
+				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
+			// close socket.
+			_clear_socket(sockfd);
+		}
+	}
 	return URL_DOWNLOAD_ERROR_NONE;
 }
 
@@ -893,7 +971,7 @@ int url_download_stop(url_download_h download)
 			} else
 				return url_download_error(__FUNCTION__, URL_DOWNLOAD_ERROR_IO_ERROR, NULL);
 		}
-	} else {
+	} else { // if no socket
 		int sockfd = _connect_download_provider();
 		if (sockfd > 0) {
 			ipc_send_download_control(sockfd, DOWNLOAD_CONTROL_STOP);