diff options
-rw-r--r-- | apps/app_externalivr.c | 4 | ||||
-rw-r--r-- | apps/app_festival.c | 4 | ||||
-rw-r--r-- | apps/app_ices.c | 3 | ||||
-rw-r--r-- | apps/app_mp3.c | 3 | ||||
-rw-r--r-- | apps/app_nbscat.c | 4 | ||||
-rw-r--r-- | apps/app_zapras.c | 4 | ||||
-rw-r--r-- | asterisk.c | 2 | ||||
-rw-r--r-- | include/asterisk/options.h | 1 | ||||
-rw-r--r-- | res/res_musiconhold.c | 4 |
9 files changed, 29 insertions, 0 deletions
diff --git a/apps/app_externalivr.c b/apps/app_externalivr.c index a53a59532..b61ddd99a 100644 --- a/apps/app_externalivr.c +++ b/apps/app_externalivr.c @@ -44,6 +44,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include "asterisk/module.h" #include "asterisk/linkedlists.h" #include "asterisk/app.h" +#include "asterisk/options.h" static const char *tdesc = "External IVR Interface Application"; @@ -313,6 +314,9 @@ static int app_exec(struct ast_channel *chan, void *data) /* child process */ int i; + if (option_highpriority) + ast_set_priority(0); + dup2(child_stdin[0], STDIN_FILENO); dup2(child_stdout[1], STDOUT_FILENO); dup2(child_stderr[1], STDERR_FILENO); diff --git a/apps/app_festival.c b/apps/app_festival.c index d3bd1e9b9..de1830fd2 100644 --- a/apps/app_festival.c +++ b/apps/app_festival.c @@ -53,6 +53,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include "asterisk/config.h" #include "asterisk/utils.h" #include "asterisk/lock.h" +#include "asterisk/options.h" #define FESTIVAL_CONFIG "festival.conf" @@ -136,6 +137,9 @@ static int send_waveform_to_fd(char *waveform, int length, int fd) { if (x != fd) close(x); } + if (option_highpriority) + ast_set_priority(0); + /*IAS */ #ifdef __PPC__ for( x=0; x<length; x+=2) diff --git a/apps/app_ices.c b/apps/app_ices.c index 4c1505584..85f4159ec 100644 --- a/apps/app_ices.c +++ b/apps/app_ices.c @@ -44,6 +44,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include "asterisk/pbx.h" #include "asterisk/module.h" #include "asterisk/translate.h" +#include "asterisk/options.h" #define ICES "/usr/bin/ices" #define LOCAL_ICES "/usr/local/bin/ices" @@ -72,6 +73,8 @@ static int icesencode(char *filename, int fd) ast_log(LOG_WARNING, "Fork failed\n"); if (res) return res; + if (option_highpriority) + ast_set_priority(0); dup2(fd, STDIN_FILENO); for (x=STDERR_FILENO + 1;x<256;x++) { if ((x != STDIN_FILENO) && (x != STDOUT_FILENO)) diff --git a/apps/app_mp3.c b/apps/app_mp3.c index ee78840ec..31fc32096 100644 --- a/apps/app_mp3.c +++ b/apps/app_mp3.c @@ -43,6 +43,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include "asterisk/pbx.h" #include "asterisk/module.h" #include "asterisk/translate.h" +#include "asterisk/options.h" #define LOCAL_MPG_123 "/usr/local/bin/mpg123" #define MPG_123 "/usr/bin/mpg123" @@ -71,6 +72,8 @@ static int mp3play(char *filename, int fd) ast_log(LOG_WARNING, "Fork failed\n"); if (res) return res; + if (option_highpriority) + ast_set_priority(0); dup2(fd, STDOUT_FILENO); for (x=0;x<256;x++) { if (x != STDOUT_FILENO) diff --git a/apps/app_nbscat.c b/apps/app_nbscat.c index e1fb921c4..adc232373 100644 --- a/apps/app_nbscat.c +++ b/apps/app_nbscat.c @@ -44,6 +44,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include "asterisk/pbx.h" #include "asterisk/module.h" #include "asterisk/translate.h" +#include "asterisk/options.h" #define LOCAL_NBSCAT "/usr/local/bin/nbscat8k" #define NBSCAT "/usr/bin/nbscat8k" @@ -75,6 +76,9 @@ static int NBScatplay(int fd) ast_log(LOG_WARNING, "Fork failed\n"); if (res) return res; + if (option_highpriority) + ast_set_priority(0); + dup2(fd, STDOUT_FILENO); for (x=0;x<256;x++) { if (x != STDOUT_FILENO) diff --git a/apps/app_zapras.c b/apps/app_zapras.c index 4a94f34ba..904badcb0 100644 --- a/apps/app_zapras.c +++ b/apps/app_zapras.c @@ -96,6 +96,10 @@ static pid_t spawn_ras(struct ast_channel *chan, char *args) /* Execute RAS on File handles */ dup2(chan->fds[0], STDIN_FILENO); + /* Drop high priority */ + if (option_highpriority) + ast_set_priority(0); + /* Close other file descriptors */ for (x=STDERR_FILENO + 1;x<1024;x++) close(x); diff --git a/asterisk.c b/asterisk.c index 5e1423e86..c62442d09 100644 --- a/asterisk.c +++ b/asterisk.c @@ -443,6 +443,8 @@ int ast_safe_system(const char *s) pid = fork(); if (pid == 0) { + if (option_highpriority) + ast_set_priority(0); /* Close file descriptors and launch system command */ for (x = STDERR_FILENO + 1; x < 4096; x++) close(x); diff --git a/include/asterisk/options.h b/include/asterisk/options.h index fd8f3aadb..7a71cdcb0 100644 --- a/include/asterisk/options.h +++ b/include/asterisk/options.h @@ -44,6 +44,7 @@ extern int option_timestamp; extern int option_transcode_slin; extern int option_transmit_silence_during_record; extern int option_maxcalls; +extern int option_highpriority; extern double option_maxload; extern int option_dontwarn; extern int option_priority_jumping; diff --git a/res/res_musiconhold.c b/res/res_musiconhold.c index d31bf08ac..a90585b21 100644 --- a/res/res_musiconhold.c +++ b/res/res_musiconhold.c @@ -440,6 +440,10 @@ static int spawn_mp3(struct mohclass *class) } if (!class->pid) { int x; + + if (option_highpriority) + ast_set_priority(0); + close(fds[0]); /* Stdout goes to pipe */ dup2(fds[1], STDOUT_FILENO); |