interval tweaks

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@7626 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Brian West 2008-02-15 20:11:44 +00:00
parent 10d8b26b89
commit bcc49a1d05
7 changed files with 57 additions and 55 deletions

View File

@ -353,7 +353,7 @@ static inline void switch_core_codec_add_implementation(switch_memory_pool_t *po
/*! deinitalize a codec handle using this implementation */ /*! deinitalize a codec handle using this implementation */
switch_core_codec_destroy_func_t destroy) switch_core_codec_destroy_func_t destroy)
{ {
if (SWITCH_ACCEPTABLE_INTERVAL(microseconds_per_frame / 1000)) {
switch_codec_implementation_t *impl = (switch_codec_implementation_t *) switch_core_alloc(pool, sizeof(*impl)); switch_codec_implementation_t *impl = (switch_codec_implementation_t *) switch_core_alloc(pool, sizeof(*impl));
impl->codec_type = codec_type; impl->codec_type = codec_type;
impl->ianacode = ianacode; impl->ianacode = ianacode;
@ -376,7 +376,7 @@ static inline void switch_core_codec_add_implementation(switch_memory_pool_t *po
impl->next = codec_interface->implementations; impl->next = codec_interface->implementations;
codec_interface->implementations = impl; codec_interface->implementations = impl;
}
} }
///\} ///\}

View File

@ -306,7 +306,7 @@ SWITCH_DECLARE_DATA extern switch_directories SWITCH_GLOBAL_dirs;
#define SWITCH_CORE_QUEUE_LEN 100000 #define SWITCH_CORE_QUEUE_LEN 100000
#define SWITCH_MAX_MANAGEMENT_BUFFER_LEN 1024 * 8 #define SWITCH_MAX_MANAGEMENT_BUFFER_LEN 1024 * 8
#define SWITCH_ACCEPTABLE_INTERVAL(_i) (_i <= SWITCH_MAX_INTERVAL && (_i % 10) == 0) #define SWITCH_ACCEPTABLE_INTERVAL(_i) (_i && _i <= SWITCH_MAX_INTERVAL && (_i % 10) == 0)
typedef enum { typedef enum {
SWITCH_CPF_SCREEN = (1 << 0), SWITCH_CPF_SCREEN = (1 << 0),

View File

@ -4618,8 +4618,6 @@ static conference_obj_t *conference_new(char *name, conf_xml_cfg_t cfg, switch_m
{ {
conference_obj_t *conference; conference_obj_t *conference;
switch_xml_t xml_kvp; switch_xml_t xml_kvp;
char *rate_name = NULL;
char *interval_name = NULL;
char *timer_name = NULL; char *timer_name = NULL;
char *domain = NULL; char *domain = NULL;
char *tts_engine = NULL; char *tts_engine = NULL;
@ -4679,12 +4677,18 @@ static conference_obj_t *conference_new(char *name, conf_xml_cfg_t cfg, switch_m
if (!strcasecmp(var, "rate") && !switch_strlen_zero(val)) { if (!strcasecmp(var, "rate") && !switch_strlen_zero(val)) {
uint32_t tmp = atoi(val); uint32_t tmp = atoi(val);
if (tmp == 8000 || tmp == 16000 || tmp == 32000) { if (tmp == 8000 || tmp == 16000 || tmp == 32000) {
rate_name = val; rate = tmp;
} }
} else if (!strcasecmp(var, "domain") && !switch_strlen_zero(val)) { } else if (!strcasecmp(var, "domain") && !switch_strlen_zero(val)) {
domain = val; domain = val;
} else if (!strcasecmp(var, "interval") && !switch_strlen_zero(val)) { } else if (!strcasecmp(var, "interval") && !switch_strlen_zero(val)) {
interval_name = val; uint32_t tmp = atoi(val);
if (SWITCH_ACCEPTABLE_INTERVAL(tmp)) {
interval = tmp;
} else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING,
"Interval must be multipe of 10 and less than %d, Using default of 20\n", SWITCH_MAX_INTERVAL);
}
} else if (!strcasecmp(var, "timer-name") && !switch_strlen_zero(val)) { } else if (!strcasecmp(var, "timer-name") && !switch_strlen_zero(val)) {
timer_name = val; timer_name = val;
} else if (!strcasecmp(var, "tts-engine") && !switch_strlen_zero(val)) { } else if (!strcasecmp(var, "tts-engine") && !switch_strlen_zero(val)) {
@ -4766,22 +4770,6 @@ static conference_obj_t *conference_new(char *name, conf_xml_cfg_t cfg, switch_m
/* Set defaults and various paramaters */ /* Set defaults and various paramaters */
/* Speed in hertz */
if (!switch_strlen_zero(rate_name)) {
uint32_t r = atoi(rate_name);
if (r) {
rate = r;
}
}
/* Packet Interval in milliseconds */
if (!switch_strlen_zero(interval_name)) {
uint32_t i = atoi(interval_name);
if (i) {
interval = i;
}
}
/* Timer module to use */ /* Timer module to use */
if (switch_strlen_zero(timer_name)) { if (switch_strlen_zero(timer_name)) {
timer_name = "soft"; timer_name = "soft";

View File

@ -684,12 +684,13 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_voipcodecs_load)
switch_gsm_init, switch_gsm_encode, switch_gsm_decode, switch_gsm_destroy); switch_gsm_init, switch_gsm_encode, switch_gsm_decode, switch_gsm_destroy);
} }
/* LPC10 */ /* LPC10 */
if (SWITCH_MAX_INTERVAL >= 90) {
SWITCH_ADD_CODEC(codec_interface, "LPC-10"); SWITCH_ADD_CODEC(codec_interface, "LPC-10");
switch_core_codec_add_implementation(pool, codec_interface, switch_core_codec_add_implementation(pool, codec_interface,
SWITCH_CODEC_TYPE_AUDIO, 7, "LPC", NULL, 8000, 8000, 2400, SWITCH_CODEC_TYPE_AUDIO, 7, "LPC", NULL, 8000, 8000, 2400,
90000, 720, 1440, 28, 1, 1, 1, 90000, 720, 1440, 28, 1, 1, 1,
switch_lpc10_init, switch_lpc10_encode, switch_lpc10_decode, switch_lpc10_destroy); switch_lpc10_init, switch_lpc10_encode, switch_lpc10_decode, switch_lpc10_destroy);
}
/* indicate that the module should continue to be loaded */ /* indicate that the module should continue to be loaded */
return SWITCH_STATUS_SUCCESS; return SWITCH_STATUS_SUCCESS;
} }

View File

@ -905,7 +905,13 @@ static switch_status_t load_config(void)
} else if (!strcmp(var, "sample-rate")) { } else if (!strcmp(var, "sample-rate")) {
globals.sample_rate = atoi(val); globals.sample_rate = atoi(val);
} else if (!strcmp(var, "codec-ms")) { } else if (!strcmp(var, "codec-ms")) {
globals.codec_ms = atoi(val); int tmp = atoi(val);
if (SWITCH_ACCEPTABLE_INTERVAL(tmp)) {
globals.codec_ms = tmp;
} else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING,
"codec-ms must be multipe of 10 and less than %d, Using default of 20\n", SWITCH_MAX_INTERVAL);
}
} else if (!strcmp(var, "dialplan")) { } else if (!strcmp(var, "dialplan")) {
set_global_dialplan(val); set_global_dialplan(val);
} else if (!strcmp(var, "cid-name")) { } else if (!strcmp(var, "cid-name")) {

View File

@ -782,7 +782,13 @@ static switch_status_t load_config(void)
} else if (!strcmp(var, "sample-rate")) { } else if (!strcmp(var, "sample-rate")) {
globals.sample_rate = atoi(val); globals.sample_rate = atoi(val);
} else if (!strcmp(var, "codec-ms")) { } else if (!strcmp(var, "codec-ms")) {
globals.codec_ms = atoi(val); int tmp = atoi(val);
if (SWITCH_ACCEPTABLE_INTERVAL(tmp)) {
globals.codec_ms = tmp;
} else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING,
"codec-ms must be multipe of 10 and less than %d, Using default of 20\n", SWITCH_MAX_INTERVAL);
}
} else if (!strcmp(var, "dialplan")) { } else if (!strcmp(var, "dialplan")) {
set_global_dialplan(val); set_global_dialplan(val);
} else if (!strcmp(var, "cid-name")) { } else if (!strcmp(var, "cid-name")) {

View File

@ -414,10 +414,11 @@ static void launch_threads(void)
} }
} else if (!strcasecmp(var, "interval")) { } else if (!strcasecmp(var, "interval")) {
int tmp = atoi(val); int tmp = atoi(val);
if (tmp >= 10) { if (SWITCH_ACCEPTABLE_INTERVAL(tmp)) {
source->interval = tmp; source->interval = tmp;
} else { } else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Can't set interval to less than 10\n"); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING,
"Interval must be multipe of 10 and less than %d, Using default of 20\n", SWITCH_MAX_INTERVAL);
} }
} else if (!strcasecmp(var, "timer-name")) { } else if (!strcasecmp(var, "timer-name")) {
source->timer_name = switch_core_strdup(source->pool, val); source->timer_name = switch_core_strdup(source->pool, val);