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);
int ms_ipc_receive_message_tcp(int client_sock, ms_comm_msg_s *recv_msg);
int ms_ipc_accept_client_tcp(int serv_sock, int* client_sock);
MSAPI_DBG_SLOG("receive msg from P[%d] T[%d] M[%.*s] S[%.*s]", recv_msg->pid, recv_msg->msg_type, MAX_MSG_SIZE, recv_msg->msg, MS_UUID_SIZE, recv_msg->storage_id);
if (strlen(recv_msg->msg) == 0 || strlen(recv_msg->msg) >= MAX_MSG_SIZE) {
- MSAPI_DBG_ERR("IPC message is wrong. message size is %d", strlen(recv_msg->msg));
+ MSAPI_DBG_ERR("IPC message is wrong. message size is over MAX_MSG_SIZE");
return MS_MEDIA_ERR_INVALID_IPC_MESSAGE;
}
if (strlen(recv_msg->storage_id) >= MS_UUID_SIZE) {
- MSAPI_DBG_ERR("IPC message is wrong. storage_id size is %d", strlen(recv_msg->storage_id));
+ MSAPI_DBG_ERR("IPC message is wrong. storage_id size is over MS_UUID_SIZE");
return MS_MEDIA_ERR_INVALID_IPC_MESSAGE;
}
}
if (strlen(recv_msg.msg) == 0 || strlen(recv_msg.msg) >= MAX_FILEPATH_LEN) {
- MSAPI_DBG_ERR("msg size is invlid[%d]", strlen(recv_msg.msg));
+ MSAPI_DBG_ERR("msg size is invlid");
return FALSE;
}
int ms_ipc_send_msg_to_client_tcp(int sockfd, ms_comm_msg_s *send_msg, struct sockaddr_un *client_addr)
{
if (write(sockfd, send_msg, sizeof(*(send_msg))) != sizeof(*(send_msg))) {
- MSAPI_DBG_STRERROR("sendto failed");
+ MSAPI_DBG_STRERROR("write failed");
return MS_MEDIA_ERR_SOCKET_SEND;
}
return MS_MEDIA_ERR_NONE;
}
-int ms_ipc_receive_message(int sockfd, void *recv_msg)
-{
- int recv_msg_size;
-
- MSAPI_RETV_IF(recv_msg == NULL, MS_MEDIA_ERR_INVALID_PARAMETER);
-
- if ((recv_msg_size = read(sockfd, recv_msg, sizeof(ms_comm_msg_s))) < 0) {
- if (errno == EWOULDBLOCK) {
- MSAPI_DBG_ERR("Timeout. Can't try any more");
- return MS_MEDIA_ERR_SOCKET_RECEIVE_TIMEOUT;
- } else {
- MSAPI_DBG_STRERROR("recv failed");
- return MS_MEDIA_ERR_SOCKET_RECEIVE;
- }
- }
-
- return MS_MEDIA_ERR_NONE;
-}
-
int ms_ipc_accept_client_tcp(int serv_sock, int* client_sock)
{
int sockfd = -1;
MSAPI_DBG_SLOG("receive msg from P[%d] T[%d] M[%.*s]", recv_msg->pid, recv_msg->msg_type, MAX_MSG_SIZE, recv_msg->msg);
if (strlen(recv_msg->msg) == 0 || strlen(recv_msg->msg) >= MAX_MSG_SIZE) {
- MSAPI_DBG_ERR("IPC message is wrong. message size is %d", strlen(recv_msg->msg));
+ MSAPI_DBG_ERR("IPC message is wrong. message size is over MAX_MSG_SIZE");
return MS_MEDIA_ERR_INVALID_IPC_MESSAGE;
}
}
if (strlen(recv_msg->msg) == 0 || strlen(recv_msg->msg) >= MAX_MSG_SIZE) {
- MS_DBG_ERR("msg size is invlid[%d]", strlen(recv_msg->msg));
+ MS_DBG_ERR("msg size is invlid");
+ MS_SAFE_FREE(recv_msg);
return TRUE;
}
if (strlen(recv_msg->storage_id) >= MS_UUID_SIZE) {
- MS_DBG_ERR("storage_id size is invlid[%d]", strlen(recv_msg->storage_id));
+ MS_DBG_ERR("storage_id size is invlid");
+ MS_SAFE_FREE(recv_msg);
return TRUE;
}
}
if (strlen(recv_msg->msg) == 0 || strlen(recv_msg->msg) >= MAX_MSG_SIZE) {
- MS_DBG_ERR("msg size is invlid[%d]", strlen(recv_msg->msg));
+ MS_DBG_ERR("msg size is invlid");
+ MS_SAFE_FREE(recv_msg);
return TRUE;
}
if (strlen(recv_msg->storage_id) >= MS_UUID_SIZE) {
- MS_DBG_ERR("storage_id size is invlid[%d]", strlen(recv_msg->storage_id));
+ MS_DBG_ERR("storage_id size is invlid");
+ MS_SAFE_FREE(recv_msg);
return TRUE;
}
if (strlen(msg->msg) >= MAX_FILEPATH_LEN) {
MS_DBG_ERR("msg size is invlid[%d]", strlen(msg->msg));
+ MS_SAFE_FREE(buf);
return MS_MEDIA_ERR_INVALID_IPC_MESSAGE;
}
}
}
+ if (ret != MS_MEDIA_ERR_NONE)
+ MS_DBG_ERR("error : ms_update_storage or ms_insert_storage failed");
+
/* request to update media db */
ret = ms_insert_folder(handle, storage_id, mounted_path, uid);
if (ret != MS_MEDIA_ERR_NONE)
MS_DBG("Set language change cb [%s]", lang);
priv_lang = strdup(lang);
- MS_SAFE_FREE(lang);
err = vconf_notify_key_changed(VCONFKEY_LANGSET, (vconf_callback_fn) _ms_change_lang_vconf_cb, NULL);
if (err == -1)
MS_DBG_ERR("add call back function for event %s fails", VCONFKEY_LANGSET);
}
+
+ MS_SAFE_FREE(lang);
+
#endif
#ifdef _USE_SENIOR_MODE
/*add noti receiver for smart hub reset */
}
if (strlen(recv_msg.msg) == 0 || strlen(recv_msg.msg) >= MAX_MSG_SIZE) {
- MS_DBG_ERR("msg size is invlid[%d]", strlen(recv_msg.msg));
+ MS_DBG_ERR("msg size is invlid");
return TRUE;
}
if (strlen(recv_msg.storage_id) >= MS_UUID_SIZE) {
- MS_DBG_ERR("storage_id size is invlid[%d]", strlen(recv_msg.storage_id));
+ MS_DBG_ERR("storage_id size is invlid");
return TRUE;
}
{
struct sockaddr_un serv_addr;
unsigned int serv_addr_len;
-
+ ms_thumb_server_msg recv_msg;
+ int len = 0;
int sockfd = -1;
if (g_communicate_sock <= 0)
return FALSE;
}
- ms_thumb_server_msg recv_msg;
- int recv_msg_size = 0;
-
- recv_msg_size = ms_ipc_receive_message(sockfd, &recv_msg);
- if (recv_msg_size != MS_MEDIA_ERR_NONE) {
- MS_DBG_STRERROR("ms_ipc_receive_message failed");
+ if ((len = read(sockfd, &recv_msg, sizeof(ms_thumb_server_msg))) < 0) {
+ MS_DBG_STRERROR("read failed");
close(sockfd);
return FALSE;
}
- //MS_DBG("Receive : %d(%d)", recv_msg.msg_type, recv_msg_size);
if (recv_msg.msg_type == MS_MSG_THUMB_SERVER_READY)
MS_DBG("Thumbnail server is ready");
_ms_thumb_set_buffer(&res_msg, &buf, &buf_size);
if (send(client_sock, buf, buf_size, 0) < 0)
- MS_DBG_STRERROR("sendto failed");
+ MS_DBG_STRERROR("send failed");
else
MS_DBG("Sent Refuse msg from %s", recv_msg->org_path);