reg_chan->consumer_key,
usess->uid, usess->gid,
usess->consumer, pathname, 0,
- session->rotate_count);
+ session->rotate_count,
+ &session->rotate_pending_relay);
if (ret < 0) {
goto error;
}
reg->registry->reg.ust->metadata_key,
usess->uid, usess->gid,
usess->consumer, pathname, 1,
- session->rotate_count);
+ session->rotate_count,
+ &session->rotate_pending_relay);
if (ret < 0) {
goto error;
}
ret = consumer_rotate_channel(socket, ua_chan->key,
ua_sess->euid, ua_sess->egid,
ua_sess->consumer, pathname, 0,
- session->rotate_count);
+ session->rotate_count,
+ &session->rotate_pending_relay);
if (ret < 0) {
goto error;
}
ret = consumer_rotate_channel(socket, registry->metadata_key,
ua_sess->euid, ua_sess->egid,
ua_sess->consumer, pathname, 1,
- session->rotate_count);
+ session->rotate_count,
+ &session->rotate_pending_relay);
if (ret < 0) {
goto error;
}
}
if (nr_app == 0 && nr_channels == 0) {
- session->rotate_pending = 0;
+ session->rotate_pending = false;
session->rotate_status = LTTNG_ROTATE_EMPTY;
}