projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Cleanup relayd live comment
[lttng-tools.git]
/
src
/
bin
/
lttng-relayd
/
live.c
diff --git
a/src/bin/lttng-relayd/live.c
b/src/bin/lttng-relayd/live.c
index e6f381df7678b274f28b5924b73d6133839f501e..84057bfb4048bf4ab8f6b4c0c23ec27e55d30da1 100644
(file)
--- a/
src/bin/lttng-relayd/live.c
+++ b/
src/bin/lttng-relayd/live.c
@@
-155,7
+155,7
@@
int create_thread_poll_set(struct lttng_poll_event *events, int size)
}
/* Add quit pipe */
}
/* Add quit pipe */
- ret = lttng_poll_add(events, live_thread_quit_pipe[0], LPOLLIN);
+ ret = lttng_poll_add(events, live_thread_quit_pipe[0], LPOLLIN
| LPOLLERR
);
if (ret < 0) {
goto error;
}
if (ret < 0) {
goto error;
}
@@
-245,9
+245,7
@@
void *thread_listener(void *data)
goto error_sock_control;
}
goto error_sock_control;
}
- /*
- * Pass 3 as size here for the thread quit pipe, control and data socket.
- */
+ /* Pass 2 as size here for the thread quit pipe and control sockets. */
ret = create_thread_poll_set(&events, 2);
if (ret < 0) {
goto error_create_poll;
ret = create_thread_poll_set(&events, 2);
if (ret < 0) {
goto error_create_poll;
@@
-259,6
+257,8
@@
void *thread_listener(void *data)
goto error_poll_add;
}
goto error_poll_add;
}
+ lttng_relay_notify_ready();
+
while (1) {
health_code_update();
while (1) {
health_code_update();
This page took
0.024578 seconds
and
4
git commands to generate.