send the rotate pending to the relay

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

diff --git a/src/bin/lttng-sessiond/kernel.c b/src/bin/lttng-sessiond/kernel.c
index 43fc935536612bf5af9287cc32bac4c45d4010b7..10ddabdbc641aa28d5f45646d811b3fdb40d4c58 100644 (file)
--- a/src/bin/lttng-sessiond/kernel.c
+++ b/src/bin/lttng-sessiond/kernel.c
@@ -1179,8 +1179,8 @@ int kernel_rotate_session(struct ltt_session *session)
 
                        ret = consumer_rotate_channel(socket, chan->fd,
                                        ksess->uid, ksess->gid, ksess->consumer,
-                                       "", 0,
-                                       session->rotate_count);
+                                       "", 0, session->rotate_count,
+                                       &session->rotate_pending_relay);
                        if (ret < 0) {
                                ret = LTTNG_ERR_KERN_CONSUMER_FAIL;
                                pthread_mutex_unlock(socket->lock);
@@ -1196,7 +1196,8 @@ int kernel_rotate_session(struct ltt_session *session)
                pthread_mutex_lock(socket->lock);
                ret = consumer_rotate_channel(socket, ksess->metadata->fd,
                                ksess->uid, ksess->gid, ksess->consumer, "", 1,
-                               session->rotate_count);
+                               session->rotate_count,
+                               &session->rotate_pending_relay);
                if (ret < 0) {
                        ret = LTTNG_ERR_KERN_CONSUMER_FAIL;
                        pthread_mutex_unlock(socket->lock);