tweak

diff --git a/src/mod/endpoints/mod_sofia/mod_sofia.h b/src/mod/endpoints/mod_sofia/mod_sofia.h
index a7bd1e6843ecfcd6118634ffacc17ef262e3feb1..190212a22b62ff74dd3947f070b38fbc3173125c 100644 (file)
--- a/src/mod/endpoints/mod_sofia/mod_sofia.h
+++ b/src/mod/endpoints/mod_sofia/mod_sofia.h
@@ -321,7 +321,7 @@ typedef enum {
        TFLAG_MAX
 } TFLAGS;
 
-#define SOFIA_MAX_MSG_QUEUE 51
+#define SOFIA_MAX_MSG_QUEUE 101
 #define SOFIA_MSG_QUEUE_SIZE 5000
 
 struct mod_sofia_globals {

diff --git a/src/mod/endpoints/mod_sofia/sofia.c b/src/mod/endpoints/mod_sofia/sofia.c
index 318ca29b7b78d73f0e48c001597a9d5d0d14eb11..c225b2bf35d4162df882a8691ffdc445fdb3c6d6 100644 (file)
--- a/src/mod/endpoints/mod_sofia/sofia.c
+++ b/src/mod/endpoints/mod_sofia/sofia.c
@@ -1145,6 +1145,7 @@ void *SWITCH_THREAD_FUNC sofia_msg_thread_run(switch_thread_t *thread, void *obj
        while(switch_queue_pop(q, &pop) == SWITCH_STATUS_SUCCESS && pop) {
                sofia_dispatch_event_t *de = (sofia_dispatch_event_t *) pop;
                sofia_process_dispatch_event(&de);
+               switch_cond_next();
        }
 
        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "MSG Thread Ended\n");
@@ -1175,7 +1176,7 @@ static void sofia_msg_thread_start(int idx)
 
                                switch_threadattr_create(&thd_attr, mod_sofia_globals.pool);
                                switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
-                               switch_threadattr_priority_increase(thd_attr);
+                               //switch_threadattr_priority_increase(thd_attr);
                                switch_thread_create(&mod_sofia_globals.msg_queue_thread[i], 
                                                                         thd_attr, 
                                                                         sofia_msg_thread_run,