Fix: rotation state marked as completed before relayd has completed
authorJérémie Galarneau <jeremie.galarneau@efficios.com>
Tue, 3 Apr 2018 14:14:17 +0000 (10:14 -0400)
committerJérémie Galarneau <jeremie.galarneau@efficios.com>
Tue, 3 Apr 2018 16:12:29 +0000 (12:12 -0400)
The session rotation state is updated to COMPLETED before the
relay daemon has signaled that its rotation has been completed.
This causes users using the "rotation get_info" API to receive
this status before the session archive is readable on the
relay daemon's end.

Signed-off-by: Jérémie Galarneau <jeremie.galarneau@efficios.com>
src/bin/lttng-sessiond/rotation-thread.c

index 9f15ed06edacbae130cef7ac9e4c0c7793ecee87..b0869903eaee1dc630370c52b9a1935cb47254a9 100644 (file)
@@ -395,7 +395,6 @@ int handle_channel_rotation_pipe(int fd, uint32_t revents,
                        goto end_unlock_session;
                }
                session->rotate_pending = false;
-               session->rotation_state = LTTNG_ROTATION_STATE_COMPLETED;
                session->last_chunk_start_ts = session->current_chunk_start_ts;
                if (session->rotate_pending_relay) {
                        ret = sessiond_timer_rotate_pending_start(
@@ -406,6 +405,8 @@ int handle_channel_rotation_pipe(int fd, uint32_t revents,
                                ret = -1;
                                goto end_unlock_session;
                        }
+               } else {
+                       session->rotation_state = LTTNG_ROTATION_STATE_COMPLETED;
                }
                DBG("Rotation completed for session %s", session->name);
        }
@@ -445,6 +446,7 @@ int rotate_pending_relay_timer(struct ltt_session *session)
                 * rotations can start now.
                 */
                session->rotate_pending_relay = false;
+               session->rotation_state = LTTNG_ROTATION_STATE_COMPLETED;
        } else if (ret == 1) {
                DBG("[rotation-thread] Rotation still pending on the relay for "
                                "session %" PRIu64, session->id);
This page took 0.026871 seconds and 4 git commands to generate.