PTHREAD_PRIO_INHERIT

Signed-off-by: Robert Schmidt <robert.schmidt@openairinterface.org>

openair2/LAYER2/NR_MAC_gNB/main.c

@@ -297,7 +297,16 @@ void mac_top_init_gNB(ngran_node_t node_type,
       RC.nrmac[i]->ul_next = (fsn_t) {.mu = *scc->ssbSubcarrierSpacing};
       RC.nrmac[i]->print_ue_stats = true;
 
-      pthread_mutex_init(&RC.nrmac[i]->sched_lock, NULL);
+      pthread_mutexattr_t attr;
+      int ret;
+      ret = pthread_mutexattr_init(&attr);
+      DevAssert(ret == 0);
+      ret = pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT);
+      DevAssert(ret == 0);
+      ret = pthread_mutex_init(&RC.nrmac[i]->sched_lock, &attr);
+      DevAssert(ret == 0);
+      ret = pthread_mutexattr_destroy(&attr);
+      DevAssert(ret == 0);
 
       uid_linear_allocator_init(&RC.nrmac[i]->UE_info.uid_allocator);
 

openair2/LAYER2/nr_rlc/nr_rlc_ue_manager.c

@@ -27,8 +27,16 @@ nr_rlc_ue_manager_t *new_nr_rlc_ue_manager(nr_rlc_op_mode_t mode)
     exit(1);
   }
 
-  if (pthread_mutex_init(&ret->lock, NULL)) abort();
+  pthread_mutexattr_t attr;
+  int rc;
+  rc = pthread_mutexattr_init(&attr);
+  DevAssert(rc == 0);
+  rc = pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT);
+  DevAssert(rc == 0);
+  if (pthread_mutex_init(&ret->lock, &attr)) abort();
   ret->mode = mode;
+  rc = pthread_mutexattr_destroy(&attr);
+  DevAssert(rc == 0);
 
   return ret;
 }