projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Deprecate lttng-health-check.3 man page
[lttng-tools.git]
/
src
/
common
/
consumer.c
diff --git
a/src/common/consumer.c
b/src/common/consumer.c
index 2f20ffb5d1d97fb585803d1721bdfeb7e494ffb9..6f3a02d2619eeef095684fc927399fca7a9404dd 100644
(file)
--- a/
src/common/consumer.c
+++ b/
src/common/consumer.c
@@
-94,6
+94,18
@@
static void notify_thread_lttng_pipe(struct lttng_pipe *pipe)
(void) lttng_pipe_write(pipe, &null_stream, sizeof(null_stream));
}
(void) lttng_pipe_write(pipe, &null_stream, sizeof(null_stream));
}
+static void notify_health_quit_pipe(int *pipe)
+{
+ int ret;
+
+ do {
+ ret = write(pipe[1], "4", 1);
+ } while (ret < 0 && errno == EINTR);
+ if (ret < 0 || ret != 1) {
+ PERROR("write consumer health quit");
+ }
+}
+
static void notify_channel_pipe(struct lttng_consumer_local_data *ctx,
struct lttng_consumer_channel *chan,
uint64_t key,
static void notify_channel_pipe(struct lttng_consumer_local_data *ctx,
struct lttng_consumer_channel *chan,
uint64_t key,
@@
-3121,6
+3133,8
@@
end:
notify_channel_pipe(ctx, NULL, -1, CONSUMER_CHANNEL_QUIT);
notify_channel_pipe(ctx, NULL, -1, CONSUMER_CHANNEL_QUIT);
+ notify_health_quit_pipe(health_quit_pipe);
+
/* Cleaning up possibly open sockets. */
if (sock >= 0) {
ret = close(sock);
/* Cleaning up possibly open sockets. */
if (sock >= 0) {
ret = close(sock);
This page took
0.029897 seconds
and
4
git commands to generate.