* jb can be configed by misdn_set_opt

* reload does misdn_reload as well



git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@9378 65c4cc65-6c06-0410-ace0-fbb531ad65f3
1.4
Christian Richter 20 years ago
parent 0058f40ed5
commit fd9fe21d2c

@ -159,6 +159,8 @@ struct chan_list {
int ast_dsp; int ast_dsp;
int jb_len;
int jb_upper_threshold;
struct misdn_jb *jb; struct misdn_jb *jb;
struct ast_dsp *dsp; struct ast_dsp *dsp;
@ -596,27 +598,29 @@ static char *misdn_get_ch_state(struct chan_list *p)
return NULL; return NULL;
} }
static int misdn_reload (int fd, int argc, char *argv[])
void reload_config(void)
{ {
int i, cfg_debug; int i, cfg_debug;
ast_cli(fd, "Reloading mISDN Config\n");
chan_misdn_log(-1, 0, "Dynamic Crypting Activation is not support during reload at the moment\n"); chan_misdn_log(-1, 0, "Dynamic Crypting Activation is not support during reload at the moment\n");
free_robin_list(); free_robin_list();
misdn_cfg_reload(); misdn_cfg_reload();
misdn_cfg_update_ptp(); misdn_cfg_update_ptp();
misdn_cfg_get( 0, MISDN_GEN_TRACEFILE, global_tracefile, BUFFERSIZE); misdn_cfg_get( 0, MISDN_GEN_TRACEFILE, global_tracefile, BUFFERSIZE);
misdn_cfg_get( 0, MISDN_GEN_DEBUG, &cfg_debug, sizeof(int)); misdn_cfg_get( 0, MISDN_GEN_DEBUG, &cfg_debug, sizeof(int));
for (i = 0; i <= max_ports; i++) { for (i = 0; i <= max_ports; i++) {
misdn_debug[i] = cfg_debug; misdn_debug[i] = cfg_debug;
misdn_debug_only[i] = 0; misdn_debug_only[i] = 0;
} }
}
static int misdn_reload (int fd, int argc, char *argv[])
{
ast_cli(fd, "Reloading mISDN Config\n");
reload_config();
return 0; return 0;
} }
@ -1139,6 +1143,40 @@ static int update_config (struct chan_list *ch, int orig)
} }
void config_jitterbuffer(struct chan_list *ch)
{
struct misdn_bchannel *bc=ch->bc;
int len=ch->jb_len, threshold=ch->jb_upper_threshold;
chan_misdn_log(1,bc->port, "config_jb: Called\n");
if ( ! len ) {
chan_misdn_log(1,bc->port, "config_jb: Deactivating Jitterbuffer\n");
bc->nojitter=1;
} else {
if (len <=100 || len > 8000) {
chan_misdn_log(-1,bc->port,"config_jb: Jitterbuffer out of Bounds, setting to 1000\n");
len=1000;
}
if ( threshold > len ) {
chan_misdn_log(-1,bc->port,"config_jb: Jitterbuffer Threshold > Jitterbuffer setting to Jitterbuffer -1\n");
}
if ( ch->jb) {
cb_log(0,bc->port,"config_jb: We've got a Jitterbuffer Already on this port.\n");
misdn_jb_destroy(ch->jb);
ch->jb=NULL;
}
ch->jb=misdn_jb_init(len, threshold);
}
}
static int read_config(struct chan_list *ch, int orig) { static int read_config(struct chan_list *ch, int orig) {
if (!ch) { if (!ch) {
@ -1179,33 +1217,10 @@ static int read_config(struct chan_list *ch, int orig) {
/*Initialize new Jitterbuffer*/ /*Initialize new Jitterbuffer*/
{ {
int jb_len,jb_upper_threshold; misdn_cfg_get( port, MISDN_CFG_JITTERBUFFER, &ch->jb_len, sizeof(int));
misdn_cfg_get( port, MISDN_CFG_JITTERBUFFER, &jb_len, sizeof(int)); misdn_cfg_get( port, MISDN_CFG_JITTERBUFFER_UPPER_THRESHOLD, &ch->jb_upper_threshold, sizeof(int));
misdn_cfg_get( port, MISDN_CFG_JITTERBUFFER_UPPER_THRESHOLD, &jb_upper_threshold, sizeof(int));
if ( ! jb_len ) {
chan_misdn_log(1,bc->port, "read_config: Deactivating Jitterbuffer\n");
bc->nojitter=1;
} else {
if (jb_len <=100 || jb_len > 8000) { config_jitterbuffer(ch);
chan_misdn_log(-1,bc->port,"read_config: Jitterbuffer out of Bounds, setting to 1000\n");
jb_len=1000;
}
if ( jb_upper_threshold > jb_len ) {
chan_misdn_log(-1,bc->port,"read_config: Jitterbuffer Threshold > Jitterbuffer setting to Jitterbuffer -1\n");
}
if ( ch->jb) {
cb_log(0,bc->port,"read_config: We've got a Jitterbuffer Already on this port.\n");
misdn_jb_destroy(ch->jb);
ch->jb=NULL;
}
ch->jb=misdn_jb_init(jb_len, jb_upper_threshold);
}
} }
misdn_cfg_get( bc->port, MISDN_CFG_CONTEXT, ch->context, sizeof(ch->context)); misdn_cfg_get( bc->port, MISDN_CFG_CONTEXT, ch->context, sizeof(ch->context));
@ -1761,7 +1776,11 @@ static int misdn_indication(struct ast_channel *ast, int cond)
break; break;
case -1 : case -1 :
chan_misdn_log(1, p->bc->port, " --> * IND :\t-1! (stop indication) pid:%d\n",p->bc?p->bc->pid:-1); chan_misdn_log(1, p->bc->port, " --> * IND :\t-1! (stop indication) pid:%d\n",p->bc?p->bc->pid:-1);
tone_indicate(p, TONE_NONE);
if (p->state == MISDN_CONNECTED)
start_bc_tones(p);
else
tone_indicate(p, TONE_NONE);
break; break;
case AST_CONTROL_HOLD: case AST_CONTROL_HOLD:
@ -3732,6 +3751,13 @@ int unload_module(void)
return 0; return 0;
} }
int reload(void)
{
reload_config();
return 0;
}
int usecount(void) int usecount(void)
{ {
int res; int res;
@ -3805,6 +3831,7 @@ static int misdn_set_opt_exec(struct ast_channel *chan, void *data)
int keyidx=0; int keyidx=0;
int rxgain=0; int rxgain=0;
int txgain=0; int txgain=0;
int change_jitter=0;
if (strcasecmp(chan->tech->type,"mISDN")) { if (strcasecmp(chan->tech->type,"mISDN")) {
ast_log(LOG_WARNING, "misdn_set_opt makes only sense with chan_misdn channels!\n"); ast_log(LOG_WARNING, "misdn_set_opt makes only sense with chan_misdn channels!\n");
@ -3839,8 +3866,32 @@ static int misdn_set_opt_exec(struct ast_channel *chan, void *data)
break; break;
case 'j': case 'j':
chan_misdn_log(1, ch->bc->port, "SETOPT: No jitter\n"); chan_misdn_log(1, ch->bc->port, "SETOPT: jitter\n");
ch->bc->nojitter=1; tok++;
change_jitter=1;
switch ( tok[0] ) {
case 'b' :
ch->jb_len=atoi(++tok);
chan_misdn_log(1, ch->bc->port, " --> buffer_len:%d\n",ch->jb_len);
break;
case 't' :
ch->jb_upper_threshold=atoi(++tok);
chan_misdn_log(1, ch->bc->port, " --> upper_threshold:%d\n",ch->jb_upper_threshold);
break;
case 'n':
ch->bc->nojitter=1;
chan_misdn_log(1, ch->bc->port, " --> nojitter\n");
break;
default:
ch->jb_len=1000;
ch->jb_upper_threshold=0;
chan_misdn_log(1, ch->bc->port, " --> buffer_len:%d (default)\n",ch->jb_len);
chan_misdn_log(1, ch->bc->port, " --> upper_threshold:%d (default)\n",ch->jb_upper_threshold);
}
break; break;
case 'v': case 'v':
@ -3939,6 +3990,10 @@ static int misdn_set_opt_exec(struct ast_channel *chan, void *data)
break; break;
} }
} }
if (change_jitter)
config_jitterbuffer(ch);
if (ch->faxdetect || ch->ast_dsp) { if (ch->faxdetect || ch->ast_dsp) {

Loading…
Cancel
Save