summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xserver/thumb-server-internal.c11
-rwxr-xr-xsrc/ipc/media-thumb-ipc.c3
2 files changed, 11 insertions, 3 deletions
diff --git a/server/thumb-server-internal.c b/server/thumb-server-internal.c
index 6de74ad..860bc6a 100755
--- a/server/thumb-server-internal.c
+++ b/server/thumb-server-internal.c
@@ -421,7 +421,7 @@ gboolean _thumb_server_send_msg_to_agent(int msg_type)
ms_thumb_server_msg send_msg;
#ifdef _USE_UDS_SOCKET_
- if (ms_ipc_create_client_socket(MS_PROTOCOL_UDP, MS_TIMEOUT_SEC_10, &sock, MS_THUMB_COMM_PORT) < 0) {
+ if (ms_ipc_create_client_socket(MS_PROTOCOL_TCP, MS_TIMEOUT_SEC_10, &sock, MS_THUMB_COMM_PORT) < 0) {
#else
if (ms_ipc_create_client_socket(MS_PROTOCOL_UDP, MS_TIMEOUT_SEC_10, &sock) < 0) {
#endif
@@ -441,7 +441,14 @@ gboolean _thumb_server_send_msg_to_agent(int msg_type)
send_msg.msg_type = msg_type;
- if (sendto(sock, &send_msg, sizeof(ms_thumb_server_msg), 0, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) != sizeof(ms_thumb_server_msg)) {
+
+ if (connect(sock, &serv_addr, sizeof(serv_addr)) < 0) {
+ thumb_err("connect failed [%s]",strerror(errno));
+ close(sock);
+ return FALSE;
+ }
+
+ if (send(sock, &send_msg, sizeof(ms_thumb_server_msg), 0) != sizeof(ms_thumb_server_msg)) {
thumb_err("sendto failed: %s\n", strerror(errno));
close(sock);
return FALSE;
diff --git a/src/ipc/media-thumb-ipc.c b/src/ipc/media-thumb-ipc.c
index b8ec1a5..080a817 100755
--- a/src/ipc/media-thumb-ipc.c
+++ b/src/ipc/media-thumb-ipc.c
@@ -164,6 +164,7 @@ int __media_thumb_check_req_queue(const char *path)
{
int req_len = 0, i;
+ if (g_request_queue == NULL) return MEDIA_THUMB_ERROR_NONE;
req_len = g_queue_get_length(g_request_queue);
// thumb_dbg("Queue length : %d", req_len);
@@ -776,7 +777,7 @@ _media_thumb_request_async(int msg_type, media_thumb_type thumb_type, const char
#ifdef _USE_MEDIA_UTIL_
#ifdef _USE_UDS_SOCKET_
- strcpy(serv_addr.sun_path, "/tmp/media_ipc_thumbcreator.dat");
+ strcpy(serv_addr.sun_path, "/var/run/media-server/media_ipc_thumbcreator.socket");
#elif defined(_USE_UDS_SOCKET_TCP_)
strcpy(serv_addr.sun_path, "/tmp/media_ipc_thumbcreator.dat");
#else