|
|
|
@ -14,7 +14,7 @@
|
|
|
|
|
namespace srsue {
|
|
|
|
|
namespace nr {
|
|
|
|
|
|
|
|
|
|
worker_pool::worker_pool(uint32_t max_workers) : pool(max_workers), logger(srslog::fetch_basic_logger("NR-PHY")) {}
|
|
|
|
|
worker_pool::worker_pool(uint32_t max_workers) : pool(max_workers), logger(srslog::fetch_basic_logger("PHY-NR")) {}
|
|
|
|
|
|
|
|
|
|
bool worker_pool::init(const phy_args_nr_t& args, phy_common* common, stack_interface_phy_nr* stack_, int prio)
|
|
|
|
|
{
|
|
|
|
@ -36,7 +36,7 @@ bool worker_pool::init(const phy_args_nr_t& args, phy_common* common, stack_inte
|
|
|
|
|
|
|
|
|
|
// Add workers to workers pool and start threads
|
|
|
|
|
for (uint32_t i = 0; i < args.nof_phy_threads; i++) {
|
|
|
|
|
auto& log = srslog::fetch_basic_logger(fmt::format("PHY{}", i));
|
|
|
|
|
auto& log = srslog::fetch_basic_logger(fmt::format("PHY{}-NR", i));
|
|
|
|
|
log.set_level(srslog::str_to_basic_level(args.log.phy_level));
|
|
|
|
|
log.set_hex_dump_max_size(args.log.phy_hex_limit);
|
|
|
|
|
|
|
|
|
@ -50,7 +50,7 @@ bool worker_pool::init(const phy_args_nr_t& args, phy_common* common, stack_inte
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Initialise PRACH
|
|
|
|
|
auto& prach_log = srslog::fetch_basic_logger("PRACH");
|
|
|
|
|
auto& prach_log = srslog::fetch_basic_logger("PRACH-NR");
|
|
|
|
|
prach_log.set_level(srslog::str_to_basic_level(args.log.phy_level));
|
|
|
|
|
prach_buffer = std::unique_ptr<prach>(new prach(prach_log));
|
|
|
|
|
prach_buffer->init(phy_state.args.dl.nof_max_prb);
|
|
|
|
|