send the rotate pending to the relay

[deliverable/lttng-tools.git] / src / bin / lttng-sessiond / rotation-thread.c

diff --git a/src/bin/lttng-sessiond/rotation-thread.c b/src/bin/lttng-sessiond/rotation-thread.c
index ded83a7a93006dd5c511d5d1d5b6fe9a8d391fe1..24c9715a167e50c11cc0af54f8df51282ca9d7ce 100644 (file)
--- a/src/bin/lttng-sessiond/rotation-thread.c
+++ b/src/bin/lttng-sessiond/rotation-thread.c
@@ -282,7 +282,8 @@ int handle_channel_rotation_pipe(int fd, uint32_t revents,
        if (revents & (LPOLLERR | LPOLLHUP | LPOLLRDHUP)) {
                ret = lttng_poll_del(&state->events, fd);
                if (ret) {
-                       ERR("[rotation-thread] Failed to remove consumer rotation pipe from poll set");
+                       ERR("[rotation-thread] Failed to remove consumer "
+                                       "rotation pipe from poll set");
                }
                goto end;
        }
@@ -312,6 +313,7 @@ int handle_channel_rotation_pipe(int fd, uint32_t revents,
                time_t now = time(NULL);
 
                if (now == (time_t) -1) {
+                       channel_info->session->rotate_status = LTTNG_ROTATE_ERROR;
                        ret = LTTNG_ERR_ROTATE_NOT_AVAILABLE;
                        goto end;
                }
@@ -321,6 +323,7 @@ int handle_channel_rotation_pipe(int fd, uint32_t revents,
                        ERR("Failed to rename completed rotation chunk");
                        goto end;
                }
+               channel_info->session->rotate_pending = false;
        }
 
        channel_rotation_info_destroy(channel_info);