projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix set but no use variables warnings
[lttng-tools.git]
/
liblttkconsumerd
/
liblttkconsumerd.c
diff --git
a/liblttkconsumerd/liblttkconsumerd.c
b/liblttkconsumerd/liblttkconsumerd.c
index e11229abd5dca98661aa653be113c6b74a6e088c..99bf30eb4c0d6a2f430087ecd52b309bfb3fc388 100644
(file)
--- 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);
}
/* 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);
} 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 (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;
}
continue;
}
@@
-1020,6
+1026,9
@@
void kconsumerd_should_exit(void)
int ret;
kconsumerd_quit = 1;
ret = write(kconsumerd_should_quit[1], "4", 1);
int ret;
kconsumerd_quit = 1;
ret = write(kconsumerd_should_quit[1], "4", 1);
+ if (ret < 0) {
+ perror("write kconsumerd quit");
+ }
}
/*
}
/*
This page took
0.023006 seconds
and
4
git commands to generate.