|
|
@ -45,6 +45,17 @@ void bsr_proc::init(sr_proc* sr_,
|
|
|
|
|
|
|
|
|
|
|
|
// Print periodically the LCID queue status
|
|
|
|
// Print periodically the LCID queue status
|
|
|
|
auto queue_status_print_task = [this](uint32_t tid) {
|
|
|
|
auto queue_status_print_task = [this](uint32_t tid) {
|
|
|
|
|
|
|
|
print_state();
|
|
|
|
|
|
|
|
timer_queue_status_print.run();
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
timer_queue_status_print.set(QUEUE_STATUS_PERIOD_MS, queue_status_print_task);
|
|
|
|
|
|
|
|
timer_queue_status_print.run();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
initiated = true;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void bsr_proc::print_state()
|
|
|
|
|
|
|
|
{
|
|
|
|
char str[128];
|
|
|
|
char str[128];
|
|
|
|
str[0] = '\0';
|
|
|
|
str[0] = '\0';
|
|
|
|
int n = 0;
|
|
|
|
int n = 0;
|
|
|
@ -54,12 +65,6 @@ void bsr_proc::init(sr_proc* sr_,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Info("BSR: triggered_bsr_type=%s, LCID QUEUE status: %s\n", bsr_type_tostring(triggered_bsr_type), str);
|
|
|
|
Info("BSR: triggered_bsr_type=%s, LCID QUEUE status: %s\n", bsr_type_tostring(triggered_bsr_type), str);
|
|
|
|
timer_queue_status_print.run();
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
timer_queue_status_print.set(QUEUE_STATUS_PERIOD_MS, queue_status_print_task);
|
|
|
|
|
|
|
|
timer_queue_status_print.run();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
initiated = true;
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
void bsr_proc::set_trigger(srsue::bsr_proc::triggered_bsr_type_t new_trigger)
|
|
|
|
void bsr_proc::set_trigger(srsue::bsr_proc::triggered_bsr_type_t new_trigger)
|
|
|
|