adt: fix report on failure for priority_task_workers

Author: alvasMan

include/srsran/support/executors/priority_task_worker.h

@@ -147,9 +147,9 @@ class priority_task_worker_executor : public task_executor
 /// \brief Create task executor with \c Priority for \c priority_multiqueue_task_worker.
 template <task_priority Priority, concurrent_queue_policy... QueuePolicies>
 priority_task_worker_executor<Priority, QueuePolicies...>
-make_priority_task_worker_executor(priority_task_worker<QueuePolicies...>& worker)
+make_priority_task_worker_executor(priority_task_worker<QueuePolicies...>& worker, bool report_on_failure)
 {
-  return priority_task_worker_executor<Priority, QueuePolicies...>(worker);
+  return priority_task_worker_executor<Priority, QueuePolicies...>(worker, report_on_failure);
 }
 
 /// \brief Create general task executor pointer with \c Priority for \c priority_multiqueue_task_worker.
@@ -164,14 +164,15 @@ namespace detail {
 template <typename Func, concurrent_queue_policy... QueuePolicies, size_t... Is>
 void visit_executor(priority_task_worker<QueuePolicies...>& w,
                     task_priority                           priority,
+                    bool                                    report_on_failure,
                     const Func&                             func,
                     std::index_sequence<Is...> /*unused*/)
 {
   const size_t idx = detail::enqueue_priority_to_queue_index(priority, sizeof...(QueuePolicies));
-  (void)std::initializer_list<int>{[idx, &w, &func]() {
+  (void)std::initializer_list<int>{[idx, &w, &func, report_on_failure]() {
     if (idx == Is) {
-      func(
-          make_priority_task_worker_executor<detail::queue_index_to_enqueue_priority(Is, sizeof...(QueuePolicies))>(w));
+      func(make_priority_task_worker_executor<detail::queue_index_to_enqueue_priority(Is, sizeof...(QueuePolicies))>(
+          w, report_on_failure));
     }
     return 0;
   }()...};
@@ -181,9 +182,13 @@ void visit_executor(priority_task_worker<QueuePolicies...>& w,
 
 /// \brief Create general task executor pointer with \c Priority for \c priority_multiqueue_task_worker.
 template <typename Func, concurrent_queue_policy... QueuePolicies>
-void visit_executor(priority_task_worker<QueuePolicies...>& worker, task_priority priority, const Func& func)
+void visit_executor(priority_task_worker<QueuePolicies...>& worker,
+                    task_priority                           priority,
+                    bool                                    report_on_failure,
+                    const Func&                             func)
 {
-  detail::visit_executor(worker, priority, func, std::make_index_sequence<sizeof...(QueuePolicies)>{});
+  detail::visit_executor(
+      worker, priority, report_on_failure, func, std::make_index_sequence<sizeof...(QueuePolicies)>{});
 }
 
 /// \brief Create general task executor pointer with \c Priority for \c priority_multiqueue_task_worker.

lib/support/executors/task_execution_manager.cpp

@@ -307,7 +307,7 @@ struct priority_multiqueue_worker_context
   create_executor(const execution_config_helper::priority_multiqueue_worker::executor& desc) override
   {
     std::unique_ptr<task_executor> exec;
-    visit_executor(this->worker, desc.priority, [this, &exec, &desc](auto&& prio_exec) {
+    visit_executor(this->worker, desc.priority, desc.report_on_failure, [this, &exec, &desc](auto&& prio_exec) {
       exec = this->task_tracer == nullptr
                  ? decorate_executor(desc, std::move(prio_exec))
                  : decorate_executor(desc, make_trace_executor(desc.name, std::move(prio_exec), *this->task_tracer));