ls::rotation_thread::rotation_thread(rotation_thread_timer_queue& rotation_timer_queue,
notification_thread_handle& notification_thread_handle) :
ls::rotation_thread::rotation_thread(rotation_thread_timer_queue& rotation_timer_queue,
notification_thread_handle& notification_thread_handle) :
- _rotation_timer_queue{ rotation_timer_queue },
- _notification_thread_handle{ notification_thread_handle }
+ _rotation_timer_queue(rotation_timer_queue),
+ _notification_thread_handle(notification_thread_handle)
DBG_FMT("Handling descriptor activity: fd={}, events={:b}", fd, revents);
if (revents & LPOLLERR) {
DBG_FMT("Handling descriptor activity: fd={}, events={:b}", fd, revents);
if (revents & LPOLLERR) {
auto condition_status =
lttng_condition_session_consumed_size_set_threshold(rotate_condition.get(), size);
if (condition_status != LTTNG_CONDITION_STATUS_OK) {
auto condition_status =
lttng_condition_session_consumed_size_set_threshold(rotate_condition.get(), size);
if (condition_status != LTTNG_CONDITION_STATUS_OK) {
"Could not set session consumed size condition threshold: size={}", size));
}
condition_status = lttng_condition_session_consumed_size_set_session_name(
rotate_condition.get(), session.name);
if (condition_status != LTTNG_CONDITION_STATUS_OK) {
"Could not set session consumed size condition threshold: size={}", size));
}
condition_status = lttng_condition_session_consumed_size_set_session_name(
rotate_condition.get(), session.name);
if (condition_status != LTTNG_CONDITION_STATUS_OK) {
&_notification_thread_handle, trigger.get(), true);
if (register_ret != LTTNG_OK) {
LTTNG_THROW_CTL(
&_notification_thread_handle, trigger.get(), true);
if (register_ret != LTTNG_OK) {
LTTNG_THROW_CTL(
_notification_channel.get(),
lttng_trigger_get_const_condition(session.rotate_trigger));
if (unsubscribe_status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) {
_notification_channel.get(),
lttng_trigger_get_const_condition(session.rotate_trigger));
if (unsubscribe_status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) {
"Failed to unsubscribe from consumed size condition used to control automatic size-based rotations: session_name=`{}` return_code={}",
session.name,
static_cast<int>(unsubscribe_status)));
"Failed to unsubscribe from consumed size condition used to control automatic size-based rotations: session_name=`{}` return_code={}",
session.name,
static_cast<int>(unsubscribe_status)));
&_notification_thread_handle, session.rotate_trigger);
if (unregister_status != LTTNG_OK) {
LTTNG_THROW_CTL(
&_notification_thread_handle, session.rotate_trigger);
if (unregister_status != LTTNG_OK) {
LTTNG_THROW_CTL(