X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=liblttkconsumerd%2Fliblttkconsumerd.c;h=99bf30eb4c0d6a2f430087ecd52b309bfb3fc388;hb=f40799e8d49a5e8161084fa98023f3e571b51962;hp=e11229abd5dca98661aa653be113c6b74a6e088c;hpb=223be86b3f1e2750e9d0bf6e022f2696e84c07d7;p=lttng-tools.git

diff --git a/liblttkconsumerd/liblttkconsumerd.c b/liblttkconsumerd/liblttkconsumerd.c
index e11229abd..99bf30eb4 100644
--- a/liblttkconsumerd/liblttkconsumerd.c
+++ b/liblttkconsumerd/liblttkconsumerd.c
@@ -651,6 +651,9 @@ static int kconsumerd_consumerd_recv_fd(int sfd,
 			}
 			/* signal the poll thread */
 			tmp2 = write(kconsumerd_poll_pipe[1], "4", 1);
+			if (tmp2 < 0) {
+				perror("write kconsumerd poll");
+			}
 		} else {
 			ERR("Didn't received any fd");
 			kconsumerd_send_error(KCONSUMERD_ERROR_RECV_FD);
@@ -762,6 +765,9 @@ void *kconsumerd_thread_poll_fds(void *data)
 		if (pollfd[nb_fd].revents == POLLIN) {
 			DBG("kconsumerd_poll_pipe wake up");
 			tmp2 = read(kconsumerd_poll_pipe[0], &tmp, 1);
+			if (tmp2 < 0) {
+				perror("read kconsumerd poll");
+			}
 			continue;
 		}
 
@@ -1020,6 +1026,9 @@ void kconsumerd_should_exit(void)
 	int ret;
 	kconsumerd_quit = 1;
 	ret = write(kconsumerd_should_quit[1], "4", 1);
+	if (ret < 0) {
+		perror("write kconsumerd quit");
+	}
 }
 
 /*