[ LTTCOMM_ERR_INDEX(CONSUMERD_SPLICE_ENOMEM) ] = "consumerd splice ENOMEM",
[ LTTCOMM_ERR_INDEX(CONSUMERD_SPLICE_ESPIPE) ] = "consumerd splice ESPIPE",
[ LTTCOMM_ERR_INDEX(LTTCOMM_NO_EVENT) ] = "Event not found",
+ [ LTTCOMM_ERR_INDEX(LTTCOMM_INVALID) ] = "Invalid parameter",
};
/*
msg.msg_iov = iov;
msg.msg_iovlen = 1;
- ret = recvmsg(sock, &msg, MSG_WAITALL);
+ do {
+ ret = recvmsg(sock, &msg, MSG_WAITALL);
+ } while (ret < 0 && errno == EINTR);
if (ret < 0) {
PERROR("recvmsg");
}
* Only warn about EPIPE when quiet mode is deactivated.
* We consider EPIPE as expected.
*/
- if (errno != EPIPE || !opt_quiet) {
+ if (errno != EPIPE || !lttng_opt_quiet) {
PERROR("sendmsg");
}
}
* Only warn about EPIPE when quiet mode is deactivated.
* We consider EPIPE as expected.
*/
- if (errno != EPIPE || !opt_quiet) {
+ if (errno != EPIPE || !lttng_opt_quiet) {
PERROR("sendmsg");
}
}
msg.msg_control = recv_fd;
msg.msg_controllen = sizeof(recv_fd);
- ret = recvmsg(sock, &msg, 0);
+ do {
+ ret = recvmsg(sock, &msg, 0);
+ } while (ret < 0 && errno == EINTR);
if (ret < 0) {
PERROR("recvmsg fds");
goto end;
* Only warn about EPIPE when quiet mode is deactivated.
* We consider EPIPE as expected.
*/
- if (errno != EPIPE || !opt_quiet) {
+ if (errno != EPIPE || !lttng_opt_quiet) {
PERROR("sendmsg");
}
}
msg.msg_controllen = sizeof(anc_buf);
#endif /* __linux__ */
- ret = recvmsg(sock, &msg, 0);
+ do {
+ ret = recvmsg(sock, &msg, 0);
+ } while (ret < 0 && errno == EINTR);
if (ret < 0) {
PERROR("recvmsg fds");
goto end;