From 969c04670137e9cd0d37cb3a91328b4ccb982a02 Mon Sep 17 00:00:00 2001
From: Cedric Roux <cedric.roux@eurecom.fr>
Date: Tue, 26 Nov 2013 13:30:13 +0000
Subject: [PATCH] - Set priority for dumper thread

git-svn-id: http://svn.eurecom.fr/openair4G/trunk@4525 818b1a75-f10b-46b9-bf7c-635c3b92a50f
---
 common/utils/itti/intertask_interface_dump.c | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/common/utils/itti/intertask_interface_dump.c b/common/utils/itti/intertask_interface_dump.c
index 763b1e0a84..38b51bfad3 100644
--- a/common/utils/itti/intertask_interface_dump.c
+++ b/common/utils/itti/intertask_interface_dump.c
@@ -591,6 +591,9 @@ void itti_dump_thread_use_ring_buffer(void)
 int itti_dump_init(const char * const messages_definition_xml, const char * const dump_file_name)
 {
     int i, ret;
+    struct sched_param scheduler_param;
+
+    scheduler_param.sched_priority = 10;
 
     if (dump_file_name != NULL)
     {
@@ -650,20 +653,25 @@ int itti_dump_init(const char * const messages_definition_xml, const char * cons
     ret = pthread_attr_init(&itti_dump_queue.attr);
     if (ret < 0) {
         ITTI_DUMP_ERROR("pthread_attr_init failed (%d:%s)\n", errno, strerror(errno));
-        return -1;
+        DevAssert(0 == 1);
     }
 
     ret = pthread_attr_setschedpolicy(&itti_dump_queue.attr, SCHED_RR);
     if (ret < 0) {
         ITTI_DUMP_ERROR("pthread_attr_setschedpolicy (SCHED_IDLE) failed (%d:%s)\n", errno, strerror(errno));
-        return -1;
+        DevAssert(0 == 1);
+    }
+    ret = pthread_attr_setschedparam(&itti_dump_queue.attr, &scheduler_param);
+    if (ret < 0) {
+        ITTI_DUMP_ERROR("pthread_attr_setschedparam failed (%d:%s)\n", errno, strerror(errno));
+        DevAssert(0 == 1);
     }
 
     ret = pthread_create(&itti_dump_queue.itti_acceptor_thread, &itti_dump_queue.attr,
                          &itti_dump_socket, (void *)messages_definition_xml);
     if (ret < 0) {
         ITTI_DUMP_ERROR("pthread_create failed (%d:%s)\n", errno, strerror(errno));
-        return -1;
+        DevAssert(0 == 1);
     }
 
     return 0;
-- 
GitLab