X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Frotate.c;h=ec0aa666837d6b6346e14047d11800584f5bc25a;hb=30f1659b7319f08fa5422db5fa8493905cb4b9c6;hp=e2a3ef9eaac221ef97cc611004db602d7af347f0;hpb=ab5be9fa2eb5ba9600a82cd18fd3cfcbac69169a;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/rotate.c b/src/bin/lttng-sessiond/rotate.c index e2a3ef9ea..ec0aa6668 100644 --- a/src/bin/lttng-sessiond/rotate.c +++ b/src/bin/lttng-sessiond/rotate.c @@ -17,7 +17,7 @@ #include #include #include -#include +#include #include #include #include @@ -46,6 +46,10 @@ int subscribe_session_consumed_size_rotation(struct ltt_session *session, uint64 enum lttng_condition_status condition_status; enum lttng_notification_channel_status nc_status; struct lttng_action *action; + const struct lttng_credentials session_creds = { + .uid = LTTNG_OPTIONAL_INIT_VALUE(session->uid), + .gid = LTTNG_OPTIONAL_INIT_VALUE(session->gid), + }; session->rotate_condition = lttng_condition_session_consumed_size_create(); if (!session->rotate_condition) { @@ -88,6 +92,9 @@ int subscribe_session_consumed_size_rotation(struct ltt_session *session, uint64 goto end; } + lttng_trigger_set_credentials( + session->rotate_trigger, &session_creds); + nc_status = lttng_notification_channel_subscribe( rotate_notification_channel, session->rotate_condition); if (nc_status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) { @@ -97,7 +104,8 @@ int subscribe_session_consumed_size_rotation(struct ltt_session *session, uint64 } ret = notification_thread_command_register_trigger( - notification_thread_handle, session->rotate_trigger); + notification_thread_handle, session->rotate_trigger, + true); if (ret < 0 && ret != -LTTNG_ERR_TRIGGER_EXISTS) { ERR("Register trigger, %s", lttng_strerror(ret)); ret = -1;