#define MUSE_WATCHDOG_CHECK_COUNT 3
#define MUSE_WATCHDOG_TIMER_PERIOD 5
+const char *msg_type[] = { "normal type", "fds type" };
+
static GMutex msg_lock;
static GMutex msg_ipc_lock;
if (shutdown(sock_fd, SHUT_RDWR) == MUSE_ERR) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[%d] failed to shutdown %s", sock_fd, err_msg);
+ LOGE("[%d] failed to shutdown [error %s %d]", sock_fd, err_msg, errno);
}
if (close(sock_fd) == MUSE_ERR) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[%d] failed to close %s", sock_fd, err_msg);
+ LOGE("[%d] failed to close [error %s %d]", sock_fd, err_msg, errno);
}
LOGI("[%d] connection close", sock_fd);
flags = value ? (flags | O_NONBLOCK) : (flags & ~O_NONBLOCK);
if (fcntl(fd, F_SETFL, flags) == -1) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("fcntl (%d, F_SETFL, %d) %s", fd, flags, err_msg);
+ LOGE("fcntl (%d, F_SETFL, %d) [error %s %d]", fd, flags, err_msg, errno);
return MM_ERROR_FILE_INTERNAL;
} else {
LOGD("fcntl (%d, F_SETFL)", fd);
if (setsockopt(sock_fd, SOL_SOCKET, SO_SNDTIMEO, (void *)&tv, (socklen_t)sizeof(tv)) == MUSE_ERR) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[%d] Failed to set socket send timeout option (%s) %d", sock_fd, err_msg, errno);
+ LOGE("[%d] Failed to set socket send timeout option [error %s %d]", sock_fd, err_msg, errno);
return MM_ERROR_UNKNOWN;
}
if (setsockopt(sock_fd, SOL_SOCKET, SO_RCVTIMEO, (void *)&tv, (socklen_t)sizeof(tv)) == MUSE_ERR) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[%d] Failed to set socket recv timeout option (%s) %d", sock_fd, err_msg, errno);
+ LOGE("[%d] Failed to set socket recv timeout option [error %s %d]", sock_fd, err_msg, errno);
return MM_ERROR_UNKNOWN;
}
msg_info.marker = MUSE_MSG_HEAD;
msg_info.size = strlen(buf);
- /*LOGD("send [t:%d,s:%d] [%s]", msg_info.type, msg_info.size, buf);*/
-
g_mutex_lock(&msg_ipc_lock);
ret = send(sock_fd, &msg_info, sizeof(muse_msg_info_t), 0);
if (ret != sizeof(muse_msg_info_t)) {
- LOGE("msg info [t:%d,s:%d] send failed : %d, errno %d",
- msg_info.type, msg_info.size, ret, errno);
+ strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
+ LOGE("msg info [type : %s size : %d] send failed : %d [error %s %d]", msg_type[msg_info.type], msg_info.size, ret, err_msg, errno);
goto _MSG_SEND_DONE;
}
if (msg_info.type == MUSE_MSG_TYPE_NORMAL) {
ret = send(sock_fd, buf, msg_info.size, 0);
- if (ret != (int)msg_info.size)
- LOGE("send failed : %d, [%s], errno %d", ret, buf, errno);
+ if (ret != (int)msg_info.size) {
+ strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
+ LOGE("[%s] send failed : %d [error %s %d]", buf, ret, err_msg, errno);
+ }
goto _MSG_SEND_DONE;
}
msg.msg_controllen = cptr->cmsg_len;
}
- if ((ret = sendmsg(sock_fd, &msg, 0)) == MUSE_ERR) {
+ if ((ret = sendmsg(sock_fd, &msg, 0)) == SEND_FAIL) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
LOGE("[%d] fail to send msg - [error %s %d]", sock_fd, err_msg, errno);
}
g_return_val_if_fail(buf, MM_ERROR_INVALID_ARGUMENT);
- /* get msg type and length */
+ /* get the msg type and length */
if (!muse_core_msg_recv_len(sock_fd, (char *)&msg_info, sizeof(muse_msg_info_t))) {
LOGE("msg info receive failed");
- return -1;
+ return RECV_FAIL;
}
if (msg_info.marker != MUSE_MSG_HEAD) {
LOGE("invalid marker 0x%x", msg_info.marker);
- return -1;
+ return RECV_FAIL;
}
if (msg_info.type == MUSE_MSG_TYPE_NORMAL) {
if (!muse_core_msg_recv_len(sock_fd, buf, msg_info.size)) {
LOGE("msg receive failed");
- return -1;
+ return RECV_FAIL;
}
ret = msg_info.size;
msg.msg_control = data;
msg.msg_controllen = sizeof(data);
- if ((ret = recvmsg(sock_fd, &msg, 0)) == MUSE_ERR) {
+ if ((ret = recvmsg(sock_fd, &msg, 0)) == RECV_FAIL) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("fail to receive msg (%s)", err_msg);
+ LOGE("fail to receive msg [error %s %d]", err_msg, errno);
return ret;
}
buf[ret] = '\0';
- /*LOGD("recv [t:%d,s:%d] [%s]", msg_info.type, msg_info.size, buf);*/
-
return ret;
}
recv_len = recv(fd, buf + offset, msg_len - offset, 0);
if (recv_len < 0) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[fd %d] recv : %s (%d)", fd, err_msg, errno);
+ LOGE("[fd %d] recv failed [error %s %d]", fd, err_msg, errno);
return false;
} else if (recv_len == 0) {
LOGD("EOF");
if (fstat(fd, &sb) < 0) {
strerror_r(errno, err_msg, MUSE_MSG_LEN_MAX);
- LOGE("[%d] failed to get file status %d %s", fd, errno, err_msg);
+ LOGE("[%d] failed to get file status [error %s %d]", fd, err_msg, errno);
return;
}