app_amd.c File Reference

Answering machine detection. More...

#include "asterisk.h"
#include "asterisk/module.h"
#include "asterisk/lock.h"
#include "asterisk/channel.h"
#include "asterisk/dsp.h"
#include "asterisk/pbx.h"
#include "asterisk/config.h"
#include "asterisk/app.h"
#include "asterisk/format_cache.h"

Include dependency graph for app_amd.c:

Go to the source code of this file.

Macros
#define	STATE_IN_SILENCE   2
#define	STATE_IN_WORD   1

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	amd_exec (struct ast_channel *chan, const char *data)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static void	isAnsweringMachine (struct ast_channel *chan, const char *data)
static int	load_config (int reload)
static int	load_module (void)
	Load the module. More...
static int	reload (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Answering Machine Detection Application" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, }
static const char	app [] = "AMD"
static const struct ast_module_info *	ast_module_info = &__mod_info
static ast_mutex_t	config_lock
static int	dfltAfterGreetingSilence = 800
static char *	dfltAudioFile = NULL
static int	dfltBetweenWordsSilence = 50
static int	dfltGreeting = 1500
static int	dfltInitialSilence = 2500
static int	dfltMaximumNumberOfWords = 2
static int	dfltMaximumWordLength = 5000
static int	dfltMaxWaitTimeForFrame = 50
static int	dfltMinimumWordLength = 100
static int	dfltSilenceThreshold = 256
static int	dfltTotalAnalysisTime = 5000

Detailed Description

Answering machine detection.

Author

Claude Klimos (claud.nosp@m.e.kl.nosp@m.imos@.nosp@m.ahee.nosp@m.va.co.nosp@m.m)

Definition in file app_amd.c.

Macro Definition Documentation

STATE_IN_SILENCE

#define STATE_IN_SILENCE   2

Definition at line 152 of file app_amd.c.

STATE_IN_WORD

#define STATE_IN_WORD   1

Definition at line 151 of file app_amd.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 621 of file app_amd.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 621 of file app_amd.c.

amd_exec()

static int amd_exec ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 498 of file app_amd.c.

{
    isAnsweringMachine(chan, data);
 
    return 0;
}

References isAnsweringMachine().

Referenced by load_module().

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 621 of file app_amd.c.

isAnsweringMachine()

static void isAnsweringMachine ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 171 of file app_amd.c.

{
    int res = 0;
    int audioFrameCount = 0;
    struct ast_frame *f = NULL;
    struct ast_dsp *silenceDetector = NULL;
    struct timeval amd_tvstart;
    int dspsilence = 0, framelength = 0;
    RAII_VAR(struct ast_format *, readFormat, NULL, ao2_cleanup);
    int inInitialSilence = 1;
    int inGreeting = 0;
    int voiceDuration = 0;
    int silenceDuration = 0;
    int iTotalTime = 0;
    int iWordsCount = 0;
    int currentState = STATE_IN_WORD;
    int consecutiveVoiceDuration = 0;
    char amdCause[256] = "", amdStatus[256] = "";
    char *parse = ast_strdupa(data);
 
    /* Let's set the initial values of the variables that will control the algorithm.
       The initial values are the default ones. If they are passed as arguments
       when invoking the application, then the default values will be overwritten
       by the ones passed as parameters. */
    int initialSilence       = dfltInitialSilence;
    int greeting             = dfltGreeting;
    int afterGreetingSilence = dfltAfterGreetingSilence;
    int totalAnalysisTime    = dfltTotalAnalysisTime;
    int minimumWordLength    = dfltMinimumWordLength;
    int betweenWordsSilence  = dfltBetweenWordsSilence;
    int maximumNumberOfWords = dfltMaximumNumberOfWords;
    int silenceThreshold     = dfltSilenceThreshold;
    int maximumWordLength    = dfltMaximumWordLength;
    int maxWaitTimeForFrame  = dfltMaxWaitTimeForFrame;
    const char *audioFile = NULL;
 
    AST_DECLARE_APP_ARGS(args,
        AST_APP_ARG(argInitialSilence);
        AST_APP_ARG(argGreeting);
        AST_APP_ARG(argAfterGreetingSilence);
        AST_APP_ARG(argTotalAnalysisTime);
        AST_APP_ARG(argMinimumWordLength);
        AST_APP_ARG(argBetweenWordsSilence);
        AST_APP_ARG(argMaximumNumberOfWords);
        AST_APP_ARG(argSilenceThreshold);
        AST_APP_ARG(argMaximumWordLength);
        AST_APP_ARG(audioFile);
    );
 
    ast_mutex_lock(&config_lock);
    if (!ast_strlen_zero(dfltAudioFile)) {
        audioFile = ast_strdupa(dfltAudioFile);
    }
    ast_mutex_unlock(&config_lock);
 
    ast_verb(3, "AMD: %s %s %s (Fmt: %s)\n", ast_channel_name(chan),
        S_COR(ast_channel_caller(chan)->ani.number.valid, ast_channel_caller(chan)->ani.number.str, "(N/A)"),
        S_COR(ast_channel_redirecting(chan)->from.number.valid, ast_channel_redirecting(chan)->from.number.str, "(N/A)"),
        ast_format_get_name(ast_channel_readformat(chan)));
 
    /* Lets parse the arguments. */
    if (!ast_strlen_zero(parse)) {
        /* Some arguments have been passed. Lets parse them and overwrite the defaults. */
        AST_STANDARD_APP_ARGS(args, parse);
        if (!ast_strlen_zero(args.argInitialSilence))
            initialSilence = atoi(args.argInitialSilence);
        if (!ast_strlen_zero(args.argGreeting))
            greeting = atoi(args.argGreeting);
        if (!ast_strlen_zero(args.argAfterGreetingSilence))
            afterGreetingSilence = atoi(args.argAfterGreetingSilence);
        if (!ast_strlen_zero(args.argTotalAnalysisTime))
            totalAnalysisTime = atoi(args.argTotalAnalysisTime);
        if (!ast_strlen_zero(args.argMinimumWordLength))
            minimumWordLength = atoi(args.argMinimumWordLength);
        if (!ast_strlen_zero(args.argBetweenWordsSilence))
            betweenWordsSilence = atoi(args.argBetweenWordsSilence);
        if (!ast_strlen_zero(args.argMaximumNumberOfWords))
            maximumNumberOfWords = atoi(args.argMaximumNumberOfWords);
        if (!ast_strlen_zero(args.argSilenceThreshold))
            silenceThreshold = atoi(args.argSilenceThreshold);
        if (!ast_strlen_zero(args.argMaximumWordLength))
            maximumWordLength = atoi(args.argMaximumWordLength);
        if (!ast_strlen_zero(args.audioFile)) {
            audioFile = args.audioFile;
        }
    } else {
        ast_debug(1, "AMD using the default parameters.\n");
    }
 
    /* Find lowest ms value, that will be max wait time for a frame */
    if (maxWaitTimeForFrame > initialSilence)
        maxWaitTimeForFrame = initialSilence;
    if (maxWaitTimeForFrame > greeting)
        maxWaitTimeForFrame = greeting;
    if (maxWaitTimeForFrame > afterGreetingSilence)
        maxWaitTimeForFrame = afterGreetingSilence;
    if (maxWaitTimeForFrame > totalAnalysisTime)
        maxWaitTimeForFrame = totalAnalysisTime;
    if (maxWaitTimeForFrame > minimumWordLength)
        maxWaitTimeForFrame = minimumWordLength;
    if (maxWaitTimeForFrame > betweenWordsSilence)
        maxWaitTimeForFrame = betweenWordsSilence;
 
    /* Now we're ready to roll! */
    ast_verb(3, "AMD: initialSilence [%d] greeting [%d] afterGreetingSilence [%d] "
        "totalAnalysisTime [%d] minimumWordLength [%d] betweenWordsSilence [%d] maximumNumberOfWords [%d] silenceThreshold [%d] maximumWordLength [%d] \n",
                initialSilence, greeting, afterGreetingSilence, totalAnalysisTime,
                minimumWordLength, betweenWordsSilence, maximumNumberOfWords, silenceThreshold, maximumWordLength);
 
    /* Set read format to signed linear so we get signed linear frames in */
    readFormat = ao2_bump(ast_channel_readformat(chan));
    if (ast_set_read_format(chan, ast_format_slin) < 0 ) {
        ast_log(LOG_WARNING, "AMD: Channel [%s]. Unable to set to linear mode, giving up\n", ast_channel_name(chan));
        pbx_builtin_setvar_helper(chan , "AMDSTATUS", "");
        pbx_builtin_setvar_helper(chan , "AMDCAUSE", "");
        return;
    }
 
    /* Create a new DSP that will detect the silence */
    if (!(silenceDetector = ast_dsp_new())) {
        ast_log(LOG_WARNING, "AMD: Channel [%s]. Unable to create silence detector :(\n", ast_channel_name(chan));
        pbx_builtin_setvar_helper(chan , "AMDSTATUS", "");
        pbx_builtin_setvar_helper(chan , "AMDCAUSE", "");
        return;
    }
 
    /* Set silence threshold to specified value */
    ast_dsp_set_threshold(silenceDetector, silenceThreshold);
 
    /* Set our start time so we can tie the loop to real world time and not RTP updates */
    amd_tvstart = ast_tvnow();
 
    /* Optional audio file to play to caller while AMD is doing its thing. */
    if (!ast_strlen_zero(audioFile)) {
        ast_streamfile(chan, audioFile, ast_channel_language(chan));
    }
 
    /* Now we go into a loop waiting for frames from the channel */
    while ((res = ast_waitfor(chan, 2 * maxWaitTimeForFrame)) > -1) {
        int ms = 0;
 
        /* Figure out how long we waited */
        if (res >= 0) {
            ms = 2 * maxWaitTimeForFrame - res;
        }
 
        /* If we fail to read in a frame, that means they hung up */
        if (!(f = ast_read(chan))) {
            ast_verb(3, "AMD: Channel [%s]. HANGUP\n", ast_channel_name(chan));
            ast_debug(1, "Got hangup\n");
            strcpy(amdStatus, "HANGUP");
            res = 1;
            break;
        }
 
        /* Check to make sure we haven't gone over our real-world timeout in case frames get stalled for whatever reason */
        if ( (ast_tvdiff_ms(ast_tvnow(), amd_tvstart)) > totalAnalysisTime ) {
            ast_frfree(f);
            strcpy(amdStatus , "NOTSURE");
            if ( audioFrameCount == 0 ) {
                ast_verb(3, "AMD: Channel [%s]. No audio data received in [%d] seconds.\n", ast_channel_name(chan), totalAnalysisTime);
                sprintf(amdCause , "NOAUDIODATA-%d", iTotalTime);
                break;
            }
            ast_verb(3, "AMD: Channel [%s]. Timeout...\n", ast_channel_name(chan));
            sprintf(amdCause , "TOOLONG-%d", iTotalTime);
            break;
        }
 
        if (f->frametype == AST_FRAME_VOICE || f->frametype == AST_FRAME_CNG) {
            /* keep track of the number of audio frames we get */
            audioFrameCount++;
 
            /* Figure out how long the frame is in milliseconds */
            if (f->frametype == AST_FRAME_VOICE) {
                framelength = (ast_codec_samples_count(f) / DEFAULT_SAMPLES_PER_MS);
            } else {
                framelength = ms;
            }
 
            iTotalTime += framelength;
 
            ast_debug(1, "AMD: Channel [%s] frametype [%s] iTotalTime [%d] framelength [%d] totalAnalysisTime [%d]\n",
                      ast_channel_name(chan),
                      f->frametype == AST_FRAME_VOICE ? "AST_FRAME_VOICE" : "AST_FRAME_CNG",
                      iTotalTime, framelength, totalAnalysisTime);
 
            /* If the total time exceeds the analysis time then give up as we are not too sure */
            if (iTotalTime >= totalAnalysisTime) {
                ast_verb(3, "AMD: Channel [%s]. Too long...\n", ast_channel_name(chan));
                ast_frfree(f);
                strcpy(amdStatus , "NOTSURE");
                sprintf(amdCause , "TOOLONG-%d", iTotalTime);
                break;
            }
 
            /* Feed the frame of audio into the silence detector and see if we get a result */
            if (f->frametype != AST_FRAME_VOICE)
                dspsilence += framelength;
            else {
                dspsilence = 0;
                ast_dsp_silence(silenceDetector, f, &dspsilence);
            }
 
            if (dspsilence > 0) {
                silenceDuration = dspsilence;
 
                if (silenceDuration >= betweenWordsSilence) {
                    if (currentState != STATE_IN_SILENCE ) {
                        ast_verb(3, "AMD: Channel [%s]. Changed state to STATE_IN_SILENCE\n", ast_channel_name(chan));
                    }
                    /* Find words less than word duration */
                    if (consecutiveVoiceDuration < minimumWordLength && consecutiveVoiceDuration > 0){
                        ast_verb(3, "AMD: Channel [%s]. Short Word Duration: %d\n", ast_channel_name(chan), consecutiveVoiceDuration);
                    }
                    currentState  = STATE_IN_SILENCE;
                    consecutiveVoiceDuration = 0;
                }
 
                if (inInitialSilence == 1  && silenceDuration >= initialSilence) {
                    ast_verb(3, "AMD: Channel [%s]. ANSWERING MACHINE: silenceDuration:%d initialSilence:%d\n",
                        ast_channel_name(chan), silenceDuration, initialSilence);
                    ast_frfree(f);
                    strcpy(amdStatus , "MACHINE");
                    sprintf(amdCause , "INITIALSILENCE-%d-%d", silenceDuration, initialSilence);
                    res = 1;
                    break;
                }
 
                if (silenceDuration >= afterGreetingSilence  &&  inGreeting == 1) {
                    ast_verb(3, "AMD: Channel [%s]. HUMAN: silenceDuration:%d afterGreetingSilence:%d\n",
                        ast_channel_name(chan), silenceDuration, afterGreetingSilence);
                    ast_frfree(f);
                    strcpy(amdStatus , "HUMAN");
                    sprintf(amdCause , "HUMAN-%d-%d", silenceDuration, afterGreetingSilence);
                    res = 1;
                    break;
                }
 
            } else {
                consecutiveVoiceDuration += framelength;
                voiceDuration += framelength;
 
                /* If I have enough consecutive voice to say that I am in a Word, I can only increment the
                   number of words if my previous state was Silence, which means that I moved into a word. */
                if (consecutiveVoiceDuration >= minimumWordLength && currentState == STATE_IN_SILENCE) {
                    iWordsCount++;
                    ast_verb(3, "AMD: Channel [%s]. Word detected. iWordsCount:%d\n", ast_channel_name(chan), iWordsCount);
                    currentState = STATE_IN_WORD;
                }
                if (consecutiveVoiceDuration >= maximumWordLength){
                    ast_verb(3, "AMD: Channel [%s]. Maximum Word Length detected. [%d]\n", ast_channel_name(chan), consecutiveVoiceDuration);
                    ast_frfree(f);
                    strcpy(amdStatus , "MACHINE");
                    sprintf(amdCause , "MAXWORDLENGTH-%d", consecutiveVoiceDuration);
                    break;
                }
                if (iWordsCount > maximumNumberOfWords) {
                    ast_verb(3, "AMD: Channel [%s]. ANSWERING MACHINE: iWordsCount:%d\n", ast_channel_name(chan), iWordsCount);
                    ast_frfree(f);
                    strcpy(amdStatus , "MACHINE");
                    sprintf(amdCause , "MAXWORDS-%d-%d", iWordsCount, maximumNumberOfWords);
                    res = 1;
                    break;
                }
 
                if (inGreeting == 1 && voiceDuration >= greeting) {
                    ast_verb(3, "AMD: Channel [%s]. ANSWERING MACHINE: voiceDuration:%d greeting:%d\n", ast_channel_name(chan), voiceDuration, greeting);
                    ast_frfree(f);
                    strcpy(amdStatus , "MACHINE");
                    sprintf(amdCause , "LONGGREETING-%d-%d", voiceDuration, greeting);
                    res = 1;
                    break;
                }
 
                if (voiceDuration >= minimumWordLength ) {
                    if (silenceDuration > 0)
                        ast_verb(3, "AMD: Channel [%s]. Detected Talk, previous silence duration: %d\n", ast_channel_name(chan), silenceDuration);
                    silenceDuration = 0;
                }
                if (consecutiveVoiceDuration >= minimumWordLength && inGreeting == 0) {
                    /* Only go in here once to change the greeting flag when we detect the 1st word */
                    if (silenceDuration > 0)
                        ast_verb(3, "AMD: Channel [%s]. Before Greeting Time:  silenceDuration: %d voiceDuration: %d\n", ast_channel_name(chan), silenceDuration, voiceDuration);
                    inInitialSilence = 0;
                    inGreeting = 1;
                }
 
            }
        } else {
            iTotalTime += ms;
            if (iTotalTime >= totalAnalysisTime) {
                ast_frfree(f);
                strcpy(amdStatus , "NOTSURE");
                sprintf(amdCause , "TOOLONG-%d", iTotalTime);
                break;
            }
        }
        ast_frfree(f);
    }
 
    if (!res) {
        /* It took too long to get a frame back. Giving up. */
        ast_verb(3, "AMD: Channel [%s]. Too long...\n", ast_channel_name(chan));
        strcpy(amdStatus , "NOTSURE");
        sprintf(amdCause , "TOOLONG-%d", iTotalTime);
    }
 
    /* Set the status and cause on the channel */
    pbx_builtin_setvar_helper(chan , "AMDSTATUS" , amdStatus);
    pbx_builtin_setvar_helper(chan , "AMDCAUSE" , amdCause);
 
    /* Restore channel read format */
    if (readFormat && ast_set_read_format(chan, readFormat))
        ast_log(LOG_WARNING, "AMD: Unable to restore read format on '%s'\n", ast_channel_name(chan));
 
    /* Free the DSP used to detect silence */
    ast_dsp_free(silenceDetector);
 
    /* If we were playing something to pass the time, stop it now. */
    if (!ast_strlen_zero(audioFile)) {
        ast_stopstream(chan);
    }
 
    return;
}

References ao2_bump, ao2_cleanup, args, AST_APP_ARG, ast_channel_caller(), ast_channel_language(), ast_channel_name(), ast_channel_readformat(), ast_channel_redirecting(), ast_codec_samples_count(), ast_debug, AST_DECLARE_APP_ARGS, ast_dsp_free(), ast_dsp_new(), ast_dsp_set_threshold(), ast_dsp_silence(), ast_format_get_name(), ast_format_slin, AST_FRAME_CNG, AST_FRAME_VOICE, ast_frfree, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_read(), ast_set_read_format(), AST_STANDARD_APP_ARGS, ast_stopstream(), ast_strdupa, ast_streamfile(), ast_strlen_zero(), ast_tvdiff_ms(), ast_tvnow(), ast_verb, ast_waitfor(), config_lock, DEFAULT_SAMPLES_PER_MS, dfltAfterGreetingSilence, dfltAudioFile, dfltBetweenWordsSilence, dfltGreeting, dfltInitialSilence, dfltMaximumNumberOfWords, dfltMaximumWordLength, dfltMaxWaitTimeForFrame, dfltMinimumWordLength, dfltSilenceThreshold, dfltTotalAnalysisTime, ast_frame::frametype, LOG_WARNING, NULL, pbx_builtin_setvar_helper(), RAII_VAR, S_COR, STATE_IN_SILENCE, and STATE_IN_WORD.

Referenced by amd_exec().

load_config()

static int load_config ( int  reload )

static

Definition at line 505 of file app_amd.c.

{
    struct ast_config *cfg = NULL;
    char *cat = NULL;
    struct ast_variable *var = NULL;
    struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
 
    dfltSilenceThreshold = ast_dsp_get_threshold_from_settings(THRESHOLD_SILENCE);
 
    if (!(cfg = ast_config_load("amd.conf", config_flags))) {
        ast_log(LOG_ERROR, "Configuration file amd.conf missing.\n");
        return -1;
    } else if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
        return 0;
    } else if (cfg == CONFIG_STATUS_FILEINVALID) {
        ast_log(LOG_ERROR, "Config file amd.conf is in an invalid format.  Aborting.\n");
        return -1;
    }
 
    cat = ast_category_browse(cfg, NULL);
 
    while (cat) {
        if (!strcasecmp(cat, "general") ) {
            var = ast_variable_browse(cfg, cat);
            while (var) {
                if (!strcasecmp(var->name, "initial_silence")) {
                    dfltInitialSilence = atoi(var->value);
                } else if (!strcasecmp(var->name, "greeting")) {
                    dfltGreeting = atoi(var->value);
                } else if (!strcasecmp(var->name, "after_greeting_silence")) {
                    dfltAfterGreetingSilence = atoi(var->value);
                } else if (!strcasecmp(var->name, "silence_threshold")) {
                    dfltSilenceThreshold = atoi(var->value);
                } else if (!strcasecmp(var->name, "total_analysis_time")) {
                    dfltTotalAnalysisTime = atoi(var->value);
                } else if (!strcasecmp(var->name, "min_word_length")) {
                    dfltMinimumWordLength = atoi(var->value);
                } else if (!strcasecmp(var->name, "between_words_silence")) {
                    dfltBetweenWordsSilence = atoi(var->value);
                } else if (!strcasecmp(var->name, "maximum_number_of_words")) {
                    dfltMaximumNumberOfWords = atoi(var->value);
                } else if (!strcasecmp(var->name, "maximum_word_length")) {
                    dfltMaximumWordLength = atoi(var->value);
                } else if (!strcasecmp(var->name, "playback_file")) {
                    ast_mutex_lock(&config_lock);
                    if (dfltAudioFile) {
                        ast_free(dfltAudioFile);
                        dfltAudioFile = NULL;
                    }
                    if (!ast_strlen_zero(var->value)) {
                        dfltAudioFile = ast_strdup(var->value);
                    }
                    ast_mutex_unlock(&config_lock);
                } else {
                    ast_log(LOG_WARNING, "%s: Cat:%s. Unknown keyword %s at line %d of amd.conf\n",
                        app, cat, var->name, var->lineno);
                }
                var = var->next;
            }
        }
        cat = ast_category_browse(cfg, cat);
    }
 
    ast_config_destroy(cfg);
 
    ast_verb(3, "AMD defaults: initialSilence [%d] greeting [%d] afterGreetingSilence [%d] "
        "totalAnalysisTime [%d] minimumWordLength [%d] betweenWordsSilence [%d] maximumNumberOfWords [%d] silenceThreshold [%d] maximumWordLength [%d]\n",
        dfltInitialSilence, dfltGreeting, dfltAfterGreetingSilence, dfltTotalAnalysisTime,
        dfltMinimumWordLength, dfltBetweenWordsSilence, dfltMaximumNumberOfWords, dfltSilenceThreshold, dfltMaximumWordLength);
 
    return 0;
}

References app, ast_category_browse(), ast_config_destroy(), ast_config_load, ast_dsp_get_threshold_from_settings(), ast_free, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strdup, ast_strlen_zero(), ast_variable_browse(), ast_verb, CONFIG_FLAG_FILEUNCHANGED, config_lock, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, dfltAfterGreetingSilence, dfltAudioFile, dfltBetweenWordsSilence, dfltGreeting, dfltInitialSilence, dfltMaximumNumberOfWords, dfltMaximumWordLength, dfltMinimumWordLength, dfltSilenceThreshold, dfltTotalAnalysisTime, LOG_ERROR, LOG_WARNING, NULL, reload(), THRESHOLD_SILENCE, and var.

Referenced by load_module(), and reload().

load_module()

static int load_module ( void  )

static

Load the module.

Module loading including tests for configuration or dependencies. This function can return AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_DECLINE, or AST_MODULE_LOAD_SUCCESS. If a dependency or environment variable fails tests return AST_MODULE_LOAD_FAILURE. If the module can not load the configuration file or other non-critical problem return AST_MODULE_LOAD_DECLINE. On success return AST_MODULE_LOAD_SUCCESS.

Definition at line 599 of file app_amd.c.

{
    ast_mutex_init(&config_lock);
    if (load_config(0) || ast_register_application_xml(app, amd_exec)) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    return AST_MODULE_LOAD_SUCCESS;
}

References amd_exec(), app, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_mutex_init, ast_register_application_xml, config_lock, and load_config().

reload()

static int reload ( void  )

static

Definition at line 609 of file app_amd.c.

{
    if (load_config(1))
        return AST_MODULE_LOAD_DECLINE;
    return AST_MODULE_LOAD_SUCCESS;
}

References AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, and load_config().

Referenced by load_config().

unload_module()

static int unload_module ( void  )

static

Definition at line 578 of file app_amd.c.

{
    ast_mutex_lock(&config_lock);
    if (dfltAudioFile) {
        ast_free(dfltAudioFile);
    }
    ast_mutex_unlock(&config_lock);
    ast_mutex_destroy(&config_lock);
    return ast_unregister_application(app);
}

References app, ast_free, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_unregister_application(), config_lock, and dfltAudioFile.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Answering Machine Detection Application" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, }

static

Definition at line 621 of file app_amd.c.

app

const char app[] = "AMD"

static

Definition at line 149 of file app_amd.c.

Referenced by load_config(), load_module(), and unload_module().

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 621 of file app_amd.c.

config_lock

ast_mutex_t config_lock

static

Definition at line 166 of file app_amd.c.

Referenced by isAnsweringMachine(), load_config(), load_module(), and unload_module().

dfltAfterGreetingSilence

int dfltAfterGreetingSilence = 800

static

Definition at line 157 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltAudioFile

char* dfltAudioFile = NULL

static

Definition at line 164 of file app_amd.c.

Referenced by isAnsweringMachine(), load_config(), and unload_module().

dfltBetweenWordsSilence

int dfltBetweenWordsSilence = 50

static

Definition at line 160 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltGreeting

int dfltGreeting = 1500

static

Definition at line 156 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltInitialSilence

int dfltInitialSilence = 2500

static

Definition at line 155 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltMaximumNumberOfWords

int dfltMaximumNumberOfWords = 2

static

Definition at line 161 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltMaximumWordLength

int dfltMaximumWordLength = 5000

static

Definition at line 163 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltMaxWaitTimeForFrame

int dfltMaxWaitTimeForFrame = 50

static

Definition at line 169 of file app_amd.c.

Referenced by isAnsweringMachine().

dfltMinimumWordLength

int dfltMinimumWordLength = 100

static

Definition at line 159 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltSilenceThreshold

int dfltSilenceThreshold = 256

static

Definition at line 162 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().

dfltTotalAnalysisTime

int dfltTotalAnalysisTime = 5000

static

Definition at line 158 of file app_amd.c.

Referenced by isAnsweringMachine(), and load_config().