#include "media-server-ipc.h"
+/* IPC message type between media-server & thumbnail-server */
+enum {
+ THUMB_REQUEST_DB_INSERT,
+ THUMB_REQUEST_ALL_MEDIA,
+ THUMB_REQUEST_CANCEL_MEDIA,
+ THUMB_REQUEST_CANCEL_ALL,
+ THUMB_REQUEST_KILL_SERVER,
+ THUMB_RESPONSE,
+ THUMB_REQUEST_RAW_DATA,
+ THUMB_REQUEST_CANCEL_RAW_DATA,
+ THUMB_REQUEST_CANCEL_ALL_RAW_DATA,
+ THUMB_RESPONSE_RAW_DATA,
+};
+
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);
}
memcpy(msg, buf, header_size);
- MS_DBG("origin_path_size : %d, dest_path_size : %d, thumb_size : %d", msg->origin_path_size, msg->dest_path_size, msg->thumb_size);
+ MS_DBG("origin_path_size : %d, dest_path_size : %d, thumb_size : %d, status : %d", msg->origin_path_size, msg->dest_path_size, msg->thumb_size, msg->status);
MS_SAFE_FREE(buf);
- if (msg->msg_type == MS_MSG_THUMB_EXTRACT_ALL_DONE || msg->msg_type == 5) {
+ if (msg->msg_type == MS_MSG_THUMB_EXTRACT_ALL_DONE || msg->msg_type == THUMB_REQUEST_KILL_SERVER) {
MS_DBG("msg_type only cases [%d]", msg->msg_type);
return MS_MEDIA_ERR_NONE;
}
return FALSE;
}
- MS_DBG_SLOG("recv %s from thumb daemon is successful", res_msg->dst_path);
+ if (res_msg->status == MS_MEDIA_ERR_NONE)
+ MS_DBG_SLOG("recv %s from thumb daemon is successful", res_msg->dst_path);
+ else
+ MS_DBG_SLOG("recv %s from thumb daemon is failed (%d)", res_msg->dst_path, res_msg->status);
+
ms_ipc_delete_client_socket(&sock_info);
- if (res_msg->msg_type == 2 && g_communicate_sock > 0) { // THUMB_REQUEST_ALL_MEDIA
+ if (res_msg->msg_type == THUMB_REQUEST_ALL_MEDIA && g_communicate_sock > 0) {
GSource *source = NULL;
if (g_tcp_channel == NULL)
g_tcp_channel = g_io_channel_unix_new(g_communicate_sock);
memset((void *)&msg, 0, sizeof(msg));
memset((void *)&recv_msg, 0, sizeof(recv_msg));
- msg.msg_type = 2; // THUMB_REQUEST_ALL_MEDIA
+ msg.msg_type = THUMB_REQUEST_ALL_MEDIA;
msg.org_path[0] = '\0';
msg.origin_path_size = 1;
msg.dst_path[0] = '\0';
memset((void *)&msg, 0, sizeof(msg));
memset((void *)&recv_msg, 0, sizeof(recv_msg));
- msg.msg_type = 5; // THUMB_REQUEST_KILL_SERVER
+ msg.msg_type = THUMB_REQUEST_KILL_SERVER;
msg.org_path[0] = '\0';
msg.origin_path_size = 1;
msg.dst_path[0] = '\0';
}
if (recv_msg) {
- if (recv_msg->msg_type == 2 && g_thumb_server_extracting) { // THUMB_REQUEST_ALL_MEDIA
+ if (recv_msg->msg_type == THUMB_REQUEST_ALL_MEDIA && g_thumb_server_extracting) {
MS_DBG_WARN("Thumbnail server is already extracting..This request is queued.");
g_thumb_server_queued_all_extracting_request = TRUE;
} else {
thumbMsg res_msg;
memset((void *)&res_msg, 0, sizeof(res_msg));
- res_msg.msg_type = 6; // THUMB_RESPONSE
- res_msg.status = 1; //THUMB_FAIL
+ res_msg.msg_type = THUMB_RESPONSE;
+ res_msg.status = MS_MEDIA_ERR_INTERNAL;
res_msg.origin_path_size = strlen(recv_msg->org_path);
strncpy(res_msg.org_path, recv_msg->org_path, res_msg.origin_path_size);
res_msg.dst_path[0] = '\0';
thumbMsg res_msg;
memset((void *)&res_msg, 0, sizeof(res_msg));
- res_msg.msg_type = 6; // THUMB_RESPONSE
- res_msg.status = 1; //THUMB_FAIL
+ res_msg.msg_type = THUMB_RESPONSE;
+ res_msg.status = MS_MEDIA_ERR_INTERNAL;
res_msg.origin_path_size = recv_msg->origin_path_size;
strncpy(res_msg.org_path, recv_msg->org_path, res_msg.origin_path_size);
res_msg.dst_path[0] = '\0';