skypopen: let's bump the thread priorities, refined

diff --git a/src/mod/endpoints/mod_skypopen/mod_skypopen.c b/src/mod/endpoints/mod_skypopen/mod_skypopen.c
index 8841ee246b8379eef78388c33612f20feb5dab76..133c8b7ff063d6682d011ce1327eb7183b754f9b 100644 (file)
--- a/src/mod/endpoints/mod_skypopen/mod_skypopen.c
+++ b/src/mod/endpoints/mod_skypopen/mod_skypopen.c
@@ -1733,7 +1733,7 @@ static switch_status_t load_config(int reload_type)
                                switch_threadattr_create(&skypopen_api_thread_attr, skypopen_module_pool);
                                switch_threadattr_detach_set(skypopen_api_thread_attr, 0);
                                switch_threadattr_stacksize_set(skypopen_api_thread_attr, SWITCH_THREAD_STACKSIZE);
-                               switch_threadattr_priority_increase(skypopen_api_thread_attr);
+                               //switch_threadattr_priority_increase(skypopen_api_thread_attr);
                                switch_thread_create(&globals.SKYPOPEN_INTERFACES[interface_id].skypopen_api_thread,
                                                                         skypopen_api_thread_attr, skypopen_do_skypeapi_thread, &globals.SKYPOPEN_INTERFACES[interface_id],
                                                                         skypopen_module_pool);
@@ -1743,7 +1743,7 @@ static switch_status_t load_config(int reload_type)
                                switch_threadattr_create(&skypopen_signaling_thread_attr, skypopen_module_pool);
                                switch_threadattr_detach_set(skypopen_signaling_thread_attr, 0);
                                switch_threadattr_stacksize_set(skypopen_signaling_thread_attr, SWITCH_THREAD_STACKSIZE);
-                               switch_threadattr_priority_increase(skypopen_signaling_thread_attr);
+                               //switch_threadattr_priority_increase(skypopen_signaling_thread_attr);
                                switch_thread_create(&globals.SKYPOPEN_INTERFACES[interface_id].
                                                                         skypopen_signaling_thread, skypopen_signaling_thread_attr,
                                                                         skypopen_signaling_thread_func, &globals.SKYPOPEN_INTERFACES[interface_id], skypopen_module_pool);
@@ -2170,7 +2170,8 @@ int dtmf_received(private_t *tech_pvt, char *value)
 
 int start_audio_threads(private_t *tech_pvt)
 {
-       switch_threadattr_t *thd_attr = NULL;
+       switch_threadattr_t *tcp_srv_thread_thd_attr = NULL;
+       switch_threadattr_t *tcp_cli_thread_thd_attr = NULL;
 
        tech_pvt->begin_to_write = 0;
        tech_pvt->begin_to_read = 0;
@@ -2196,13 +2197,13 @@ int start_audio_threads(private_t *tech_pvt)
 
        switch_core_timer_sync(&tech_pvt->timer_write);
 
-       switch_threadattr_create(&thd_attr, skypopen_module_pool);
-       switch_threadattr_detach_set(thd_attr, 0);
-       switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
-       switch_threadattr_priority_increase(thd_attr);
+       switch_threadattr_create(&tcp_srv_thread_thd_attr, skypopen_module_pool);
+       switch_threadattr_detach_set(tcp_srv_thread_thd_attr, 0);
+       switch_threadattr_stacksize_set(tcp_srv_thread_thd_attr, SWITCH_THREAD_STACKSIZE);
+       switch_threadattr_priority_increase(tcp_srv_thread_thd_attr);
        switch_mutex_lock(tech_pvt->mutex_thread_audio_srv);
        //DEBUGA_SKYPE("debugging_hangup srv lock\n", SKYPOPEN_P_LOG);
-       if (switch_thread_create(&tech_pvt->tcp_srv_thread, thd_attr, skypopen_do_tcp_srv_thread, tech_pvt, skypopen_module_pool) == SWITCH_STATUS_SUCCESS) {
+       if (switch_thread_create(&tech_pvt->tcp_srv_thread, tcp_srv_thread_thd_attr, skypopen_do_tcp_srv_thread, tech_pvt, skypopen_module_pool) == SWITCH_STATUS_SUCCESS) {
                DEBUGA_SKYPE("started tcp_srv_thread thread.\n", SKYPOPEN_P_LOG);
        } else {
                ERRORA("failed to start tcp_srv_thread thread.\n", SKYPOPEN_P_LOG);
@@ -2213,13 +2214,13 @@ int start_audio_threads(private_t *tech_pvt)
        switch_mutex_unlock(tech_pvt->mutex_thread_audio_srv);
        //DEBUGA_SKYPE("debugging_hangup srv unlock\n", SKYPOPEN_P_LOG);
 
-       switch_threadattr_create(&thd_attr, skypopen_module_pool);
-       switch_threadattr_detach_set(thd_attr, 0);
-       switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
-       switch_threadattr_priority_increase(thd_attr);
+       switch_threadattr_create(&tcp_cli_thread_thd_attr, skypopen_module_pool);
+       switch_threadattr_detach_set(tcp_cli_thread_thd_attr, 0);
+       switch_threadattr_stacksize_set(tcp_cli_thread_thd_attr, SWITCH_THREAD_STACKSIZE);
+       switch_threadattr_priority_increase(tcp_cli_thread_thd_attr);
        switch_mutex_lock(tech_pvt->mutex_thread_audio_cli);
        //DEBUGA_SKYPE("debugging_hangup cli lock\n", SKYPOPEN_P_LOG);
-       if (switch_thread_create(&tech_pvt->tcp_cli_thread, thd_attr, skypopen_do_tcp_cli_thread, tech_pvt, skypopen_module_pool) == SWITCH_STATUS_SUCCESS) {
+       if (switch_thread_create(&tech_pvt->tcp_cli_thread, tcp_cli_thread_thd_attr, skypopen_do_tcp_cli_thread, tech_pvt, skypopen_module_pool) == SWITCH_STATUS_SUCCESS) {
                DEBUGA_SKYPE("started tcp_cli_thread thread.\n", SKYPOPEN_P_LOG);
        } else {
                ERRORA("failed to start tcp_cli_thread thread.\n", SKYPOPEN_P_LOG);