#include "media-server-ipc.h"
-typedef enum {
- MS_PROTOCOL_UDP,
- MS_PROTOCOL_TCP
-} ms_protocol_e;
-
-int ms_ipc_create_client_socket(ms_protocol_e protocol, int timeout_sec, ms_sock_info_s* sock_info);
-int ms_ipc_create_server_socket(ms_protocol_e protocol, ms_msg_port_type_e port, int *sock_fd);
+int ms_ipc_create_client_socket(int timeout_sec, ms_sock_info_s* sock_info);
+int ms_ipc_create_server_socket(ms_msg_port_type_e port, int *sock_fd);
int ms_ipc_send_msg_to_server_tcp(int sockfd, ms_msg_port_type_e port, ms_comm_msg_s *send_msg, struct sockaddr_un *serv_addr);
int ms_ipc_send_msg_to_client_tcp(int sockfd, ms_comm_msg_s *send_msg, struct sockaddr_un *client_addr);
int ms_ipc_receive_message(int sockfd, void *recv_msg, unsigned int msg_size);
{
int i = 0;
- for (i = 0; i < g_list_idx; i++) {
+ for (i = 0; i < g_list_idx; i++)
MS_SAFE_FREE(sql_list[i]);
- }
MS_SAFE_FREE(sql_list);
g_list_idx = 0;
}
ret = getgrnam_r("users", &grpinfo, grpbuf, grpbufsize, &grpresult);
- if((ret == 0) && (grpresult != NULL)) {
-// MSAPI_DBG("getgrnam_r users success...\n");
+ if ((ret == 0) && (grpresult != NULL)) {
+ /*MSAPI_DBG("getgrnam_r users success...\n");*/
} else {
MSAPI_DBG_ERR("getgrnam_r users failed ret[%d]", ret);
goto END;
if (uid == getuid()) {
if (MS_STRING_VALID(MEDIA_DB_NAME)) {
-// MSAPI_DBG("MS_STRING_VALID MEDIA_DB_NAME valid...\n");
+ /*MSAPI_DBG("MS_STRING_VALID MEDIA_DB_NAME valid...\n");*/
result_passwd = strdup(MEDIA_DB_NAME);
} else {
MSAPI_DBG_ERR("MS_STRING_VALID MEDIA_DB_NAME invalid...\n");
}
ret = getpwuid_r(uid, &pwdinfo, pwdbuf, pwdbufsize, &pwdresult);
- if((ret == 0) && (pwdresult != NULL)) {
-// MSAPI_DBG("getpwuid uid[%d] success\n", uid);
+ if ((ret == 0) && (pwdresult != NULL)) {
+ /*MSAPI_DBG("getpwuid uid[%d] success\n", uid);*/
} else {
MSAPI_DBG_ERR("getpwuid uid[%d] failed ret[%d]", uid, ret);
MS_SAFE_FREE(pwdbuf);
goto END;
}
-// MSAPI_DBG("grpinfo.gr_gid[%d], pwdinfo.pw_gid[%d]", grpinfo.gr_gid, pwdinfo.pw_gid);
- if(grpinfo.gr_gid != pwdinfo.pw_gid) {
+ if (grpinfo.gr_gid != pwdinfo.pw_gid) {
MSAPI_DBG_ERR("UID [%d] does not belong to 'users' group![%d][%d]", uid, grpinfo.gr_gid, pwdinfo.pw_gid);
MS_SAFE_FREE(pwdbuf);
goto END;
/*In TV case, if the HDD is inserted, so many data can be inserted.
So the size of the journal file is incresed.
We are trucate the journal for reducing the usage rate of the internal storage.*/
-// ret = sqlite3_exec(*db_handle, "PRAGMA journal_mode = TRUNCATE", NULL, NULL, NULL);
+ /*ret = sqlite3_exec(*db_handle, "PRAGMA journal_mode = TRUNCATE", NULL, NULL, NULL);*/
sql = sqlite3_mprintf("%s", "PRAGMA journal_mode = OFF");
ret = sqlite3_exec(*db_handle, sql, NULL, NULL, NULL);
sqlite3_free(sql);
return MS_MEDIA_ERR_INVALID_PARAMETER;
}
-// MSAPI_DBG("querysize[%d] query[%s]", request_msg_size, request_msg);
-
ms_comm_msg_s send_msg;
memset((void *)&send_msg, 0, sizeof(ms_comm_msg_s));
send_msg.uid = uid;
/*Create Socket*/
- ret = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info);
+ ret = ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info);
sockfd = sock_info.sock_fd;
MSAPI_RETV_IF(ret != MS_MEDIA_ERR_NONE, ret);
/*Set server Address*/
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sun_family = AF_UNIX;
-// MSAPI_DBG_SLOG("%s", MEDIA_IPC_PATH[port]);
strncpy(serv_addr.sun_path, tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[sock_info.port]), strlen(tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[sock_info.port])));
/* Connecting to the media db server */
sock_info.port = MS_DB_BATCH_UPDATE_PORT;
/*Create TCP Socket*/
- ret = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info);
+ ret = ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info);
sockfd = sock_info.sock_fd;
MSAPI_RETV_IF(ret != MS_MEDIA_ERR_NONE, ret);
/*Set server Address*/
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sun_family = AF_UNIX;
-// MSAPI_DBG_SLOG("%s", MEDIA_IPC_PATH[port]);
strncpy(serv_addr.sun_path, tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[sock_info.port]), strlen(tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[sock_info.port])));
/* Connecting to the media db server */
strncpy(send_msg.msg, request_msg, request_msg_size);
sockfd = __media_db_get_client_tcp_sock();
- if (sockfd <= 0) {
+ if (sockfd <= 0)
return MS_MEDIA_ERR_SOCKET_CONN;
- }
/* Send request */
if (send(sockfd, &send_msg, sizeof(send_msg), 0) != sizeof(send_msg)) {
char *zErrMsg = NULL;
int retry_count = 0;
-// MSAPI_DBG_SLOG("SQL = [%s]", sql_str);
-
-EXEC_RETRY :
+EXEC_RETRY:
ret = sqlite3_exec(db_handle, sql_str, NULL, NULL, &zErrMsg);
if (SQLITE_OK != ret) {
return ret;
}
}
-
+
*handle = db_handle;
return MS_MEDIA_ERR_NONE;
}
send_msg.uid = uid;
/*Create Socket*/
- ret = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info);
+ ret = ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info);
sockfd = sock_info.sock_fd;
MSAPI_RETV_IF(ret != MS_MEDIA_ERR_NONE, ret);
if (errno == EINTR) {
MSAPI_DBG_STRERROR("catch interrupt");
goto RETRY;
- }
+ }
if (errno == EWOULDBLOCK) {
if (retry_count < MAX_RETRY_COUNT) {
MSAPI_DBG_ERR("TIME OUT[%d]", retry_count);
retry_count++;
goto RETRY;
- }
+ }
close(sockfd);
MSAPI_DBG_ERR("Timeout. Can't try any more");
ret = MS_MEDIA_ERR_INTERNAL;
}
-// MSAPI_DBG("DB PATH[%s]", *db_path);
-
return ret;
}
DCM_REQUEST_CANCEL_FACE,
};
-typedef enum
-{
+typedef enum {
DCM_PHONE, /**< Stored only in phone */
DCM_MMC /**< Stored only in MMC */
} media_dcm_store_type;
MS_SAFE_FREE(req->userData);
MS_SAFE_FREE(req);
- if(g_manage_queue && len == 0) {
+ if (g_manage_queue && len == 0) {
g_queue_free(g_manage_queue);
g_manage_queue = NULL;
}
}
/* Check manage queue */
- if(g_manage_queue) {
+ if (g_manage_queue) {
req_len = g_queue_get_length(g_manage_queue);
- if(req_len > 0)
+ if (req_len > 0)
_media_dcm_send_request();
}
MSAPI_DBG("_media_dcm_send_request start");
- err = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info);
+ err = ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info);
if (err != MS_MEDIA_ERR_NONE) {
MSAPI_DBG_ERR("ms_ipc_create_client_socket failed");
return err;
int pid;
sock_info.port = MS_DCM_CREATOR_PORT;
- err = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info);
+ err = ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info);
if (err != MS_MEDIA_ERR_NONE) {
MSAPI_DBG_ERR("ms_ipc_create_client_socket failed");
return err;
return mkdir(tmp, mode);
}
-int ms_ipc_create_client_socket(ms_protocol_e protocol, int timeout_sec, ms_sock_info_s* sock_info)
+int ms_ipc_create_client_socket(int timeout_sec, ms_sock_info_s* sock_info)
{
int sock = -1;
struct sockaddr_un serv_addr;
return 0;
}
-int ms_ipc_create_server_socket(ms_protocol_e protocol, ms_msg_port_type_e port, int *sock_fd)
+int ms_ipc_create_server_socket(ms_msg_port_type_e port, int *sock_fd)
{
int i;
bool bind_success = false;
}
memset(&serv_addr, 0, sizeof(serv_addr));
-
serv_addr.sun_family = AF_UNIX;
unlink(tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[serv_port]));
strncpy(serv_addr.sun_path, tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[serv_port]), strlen(tzplatform_mkpath(TZ_SYS_RUN, MEDIA_IPC_PATH[serv_port])));
{
bool bSupportSeniorMode = false;
- if(system_info_get_value_bool(SYSTEM_INFO_KEY_GET_SENIOR_MODE_SUPPORTED, &bSupportSeniorMode) != SYSTEM_INFO_ERROR_NONE) {
+ if (system_info_get_value_bool(SYSTEM_INFO_KEY_GET_SENIOR_MODE_SUPPORTED, &bSupportSeniorMode) != SYSTEM_INFO_ERROR_NONE) {
MSAPI_DBG("Get familytv Support failed");
return false;
}
}
ret = getgrnam_r("users", &grpinfo, grpbuf, grpbufsize, &grpresult);
- if((ret == 0) && (grpresult != NULL)) {
-// MSAPI_DBG("getgrnam_r users success...\n");
+ if ((ret == 0) && (grpresult != NULL)) {
+ /*MSAPI_DBG("getgrnam_r users success...\n");*/
} else {
MSAPI_DBG_ERR("getgrnam_r users failed ret[%d]", ret);
goto END;
}
ret = getpwuid_r(uid, &pwdinfo, pwdbuf, pwdbufsize, &pwdresult);
- if((ret == 0) && (pwdresult != NULL)) {
-// MSAPI_DBG("getpwuid uid[%d] success\n", uid);
+ if ((ret == 0) && (pwdresult != NULL)) {
+ /*MSAPI_DBG("getpwuid uid[%d] success\n", uid);*/
} else {
MSAPI_DBG_ERR("getpwuid uid[%d] failed ret[%d]", uid, ret);
MS_SAFE_FREE(pwdbuf);
goto END;
}
- // Compare git_t type and not group name
+ /* Compare git_t type and not group name */
if (grpinfo.gr_gid != pwdinfo.pw_gid) {
MSAPI_DBG_ERR("UID [%d] does not belong to 'users' group!", uid);
MS_SAFE_FREE(pwdbuf);
return false;
#ifdef _USE_SENIOR_MODE
- if(media_util_is_support_senior_mode()) {
- if (strncmp(path, MEDIA_ROOT_PATH_SENIOR_MODE, strlen(MEDIA_ROOT_PATH_SENIOR_MODE)) == 0) {
+ if (media_util_is_support_senior_mode()) {
+ if (strncmp(path, MEDIA_ROOT_PATH_SENIOR_MODE, strlen(MEDIA_ROOT_PATH_SENIOR_MODE)) == 0)
return true;
- }
}
#endif
length_path = strlen(user_path);
- if (strncmp(path, user_path, length_path) == 0) {
+ if (strncmp(path, user_path, length_path) == 0)
ret = true;
- } else if (MS_STRING_VALID(MEDIA_ROOT_PATH_SDCARD) && (strncmp(path, MEDIA_ROOT_PATH_SDCARD, strlen(MEDIA_ROOT_PATH_SDCARD)) == 0)) {
+ else if (MS_STRING_VALID(MEDIA_ROOT_PATH_SDCARD) && (strncmp(path, MEDIA_ROOT_PATH_SDCARD, strlen(MEDIA_ROOT_PATH_SDCARD)) == 0))
ret = true;
- } else if (MS_STRING_VALID(MEDIA_ROOT_PATH_USB) && (strncmp(path, MEDIA_ROOT_PATH_USB, strlen(MEDIA_ROOT_PATH_USB)) == 0)) {
+ else if (MS_STRING_VALID(MEDIA_ROOT_PATH_USB) && (strncmp(path, MEDIA_ROOT_PATH_USB, strlen(MEDIA_ROOT_PATH_USB)) == 0))
ret = true;
- } else if (MS_STRING_VALID(MEDIA_ROOT_PATH_DISC) && (strncmp(path, MEDIA_ROOT_PATH_DISC, strlen(MEDIA_ROOT_PATH_DISC)) == 0)) {
+ else if (MS_STRING_VALID(MEDIA_ROOT_PATH_DISC) && (strncmp(path, MEDIA_ROOT_PATH_DISC, strlen(MEDIA_ROOT_PATH_DISC)) == 0))
ret = true;
- }
#ifdef _USE_SENIOR_MODE
- else if (strncmp(path, MEDIA_ROOT_PATH_SENIOR_MODE, strlen(MEDIA_ROOT_PATH_SENIOR_MODE)) == 0) {
+ else if (strncmp(path, MEDIA_ROOT_PATH_SENIOR_MODE, strlen(MEDIA_ROOT_PATH_SENIOR_MODE)) == 0)
return true;
- }
#endif
- else {
+ else
ret = false;
- }
MS_SAFE_FREE(user_path);
req_result.request_type = MEDIA_REQUEST_EXTRACT_COMPLETE;
} else if (recv_msg.msg_type == MS_MSG_RECEIVE_MSG_FAILED) {
MSAPI_DBG_ERR("in _read_socket MS_MSG_RECEIVE_MSG_FAILED msg_size[%d]", recv_msg.msg_size);
- if((recv_msg.msg_size > 0) && (recv_msg.msg_size < MAX_MSG_SIZE)) {
+ if ((recv_msg.msg_size > 0) && (recv_msg.msg_size < MAX_MSG_SIZE))
req_result.complete_path = strndup(recv_msg.msg, recv_msg.msg_size);
- }
+
req_result.request_type = MEDIA_REQUEST_ERROR_SERVER_RECEIVE_MSG_FAILED;
} else {
MSAPI_DBG("The message is invalid!");
/*NEED MUTEX*/
g_mutex_lock(&scan_req_mutex);
- if (req_list == NULL) {
+ if (req_list == NULL)
req_list = g_array_new(FALSE, FALSE, sizeof(media_scan_data*));
- }
if (req_list == NULL) {
MSAPI_DBG_ERR("g_array_new falied");
send_msg.msg_size = request_msg_size;
send_msg.uid = uid;
strncpy(send_msg.msg, request_msg, request_msg_size);
- if (storage_id != NULL) {
+ if (storage_id != NULL)
strncpy(send_msg.storage_id, storage_id, MS_UUID_SIZE -1);
- }
/*Create Socket*/
- ret = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, 0, &sock_info);
+ ret = ms_ipc_create_client_socket(0, &sock_info);
sockfd = sock_info.sock_fd;
if (sock_info.sock_path != NULL)
sock_path = sock_info.sock_path;
strncpy(send_msg.msg, request_msg, request_msg_size);
/*Create Socket*/
- ret = ms_ipc_create_client_socket(MS_PROTOCOL_TCP, 0, &sock_info);
+ ret = ms_ipc_create_client_socket(0, &sock_info);
sockfd = sock_info.sock_fd;
MSAPI_RETV_IF(ret != MS_MEDIA_ERR_NONE, ret);
MediaDBHandle *db_handle = NULL;
/* Create TCP Socket*/
- ret = ms_ipc_create_server_socket(MS_PROTOCOL_TCP, MS_DB_UPDATE_PORT, &sockfd);
+ ret = ms_ipc_create_server_socket(MS_DB_UPDATE_PORT, &sockfd);
if (ret != MS_MEDIA_ERR_NONE) {
MS_DBG_ERR("Failed to create socket");
return FALSE;
}
/* Create TCP Socket for batch query*/
- ret = ms_ipc_create_server_socket(MS_PROTOCOL_TCP, MS_DB_BATCH_UPDATE_PORT, &tcp_sockfd);
+ ret = ms_ipc_create_server_socket(MS_DB_BATCH_UPDATE_PORT, &tcp_sockfd);
if (ret != MS_MEDIA_ERR_NONE) {
close(sockfd);
MS_DBG_ERR("Failed to create socket");
return FALSE;
}
- if (ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info) < 0) {
+ if (ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info) < 0) {
MS_DBG_ERR("ms_ipc_create_client_socket failed");
return FALSE;
}
{
int sock;
- if (ms_ipc_create_server_socket(MS_PROTOCOL_TCP, serv_port, &sock) < 0) {
+ if (ms_ipc_create_server_socket(serv_port, &sock) < 0) {
MS_DBG_ERR("_ms_dcm_create_socket failed");
return FALSE;
}
_mkdir(tzplatform_mkpath(TZ_SYS_RUN, "media-server"), S_IRWXU | S_IRWXG | S_IRWXO);
/* Create and bind new UDP socket */
- if (ms_ipc_create_server_socket(MS_PROTOCOL_TCP, MS_SCANNER_PORT, &sockfd) != MS_MEDIA_ERR_NONE) {
+ if (ms_ipc_create_server_socket(MS_SCANNER_PORT, &sockfd) != MS_MEDIA_ERR_NONE) {
MS_DBG_ERR("Failed to create socket");
return;
} else {
return FALSE;
}
- if (ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock_info) < 0) {
+ if (ms_ipc_create_client_socket(MS_TIMEOUT_SEC_10, &sock_info) < 0) {
MS_DBG_ERR("ms_ipc_create_client_socket failed");
return FALSE;
}
{
int sock;
- if (ms_ipc_create_server_socket(MS_PROTOCOL_TCP, serv_port, &sock) < 0) {
+ if (ms_ipc_create_server_socket(serv_port, &sock) < 0) {
MS_DBG_ERR("_ms_thumb_create_socket failed");
return FALSE;
}