app_externalivr.c File Reference

External IVR application interface. More...

#include "asterisk.h"
#include <signal.h>
#include "asterisk/lock.h"
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/linkedlists.h"
#include "asterisk/app.h"
#include "asterisk/utils.h"
#include "asterisk/tcptls.h"
#include "asterisk/astobj2.h"

Include dependency graph for app_externalivr.c:

Go to the source code of this file.

Data Structures
struct	ivr_localuser::finishlist
struct	gen_state
struct	ivr_localuser
struct	ivr_localuser::playlist
struct	playlist_entry

Macros
#define	ast_chan_log(level, channel, format, ...)   ast_log(level, "%s: " format, ast_channel_name(channel) , ## __VA_ARGS__)
#define	EIVR_CMD_ANS   'T' /* answer channel */
#define	EIVR_CMD_APND   'A' /* append to prompt queue */
#define	EIVR_CMD_DTMF   'D' /* send DTMF */
#define	EIVR_CMD_EXIT   'E' /* exit */
#define	EIVR_CMD_GET   'G' /* get channel varable(s) */
#define	EIVR_CMD_HGUP   'H' /* hangup */
#define	EIVR_CMD_IRPT   'I' /* interrupt */
#define	EIVR_CMD_LOG   'L' /* log message */
#define	EIVR_CMD_OPT   'O' /* option */
#define	EIVR_CMD_PARM   'P' /* return supplied params */
#define	EIVR_CMD_SQUE   'S' /* (re)set prompt queue */
#define	EIVR_CMD_SVAR   'V' /* set channel varable(s) */
#define	EIVR_CMD_XIT   'X' /* exit **depricated** */
#define	EXTERNALIVR_PORT   2949

Enumerations
enum	options_flags { noanswer = (1 << 0), ignore_hangup = (1 << 1), run_dead = (1 << 2) }

Functions
static int	app_exec (struct ast_channel *chan, const char *data)
static void	ast_eivr_getvariable (struct ast_channel *chan, char *data, char *outbuf, int outbuflen)
static void	ast_eivr_senddtmf (struct ast_channel *chan, char *vdata)
static void	ast_eivr_setvariable (struct ast_channel *chan, char *data)
	AST_MODULE_INFO_STANDARD_EXTENDED (ASTERISK_GPL_KEY, "External IVR Interface Application")
static int	eivr_comm (struct ast_channel *chan, struct ivr_localuser *u, struct ast_iostream *eivr_events, struct ast_iostream *eivr_commands, struct ast_iostream *eivr_errors, const struct ast_str *args, const struct ast_flags flags)
static void *	gen_alloc (struct ast_channel *chan, void *params)
static void	gen_closestream (struct gen_state *state)
static int	gen_generate (struct ast_channel *chan, void *data, int len, int samples)
static int	gen_nextfile (struct gen_state *state)
static struct ast_frame *	gen_readframe (struct gen_state *state)
static void	gen_release (struct ast_channel *chan, void *data)
static int	load_module (void)
static struct playlist_entry *	make_entry (const char *filename)
static void	send_eivr_event (struct ast_iostream *stream, const char event, const char *data, const struct ast_channel *chan)
static int	unload_module (void)

Variables
static const char	app [] = "ExternalIVR"
static const struct ast_app_option	app_opts [128] = { [ 'n' ] = { .flag = noanswer }, [ 'i' ] = { .flag = ignore_hangup }, [ 'd' ] = { .flag = run_dead }, }
static struct ast_generator	gen

Detailed Description

External IVR application interface.

Author

Kevin P. Fleming kpfle.nosp@m.ming.nosp@m.@digi.nosp@m.um.c.nosp@m.om

Note

Portions taken from the file-based music-on-hold work created by Anthony Minessale II in res_musiconhold.c

Definition in file app_externalivr.c.

Macro Definition Documentation

ast_chan_log

#define ast_chan_log	(		level,
			channel,
			format,
			...
	)		ast_log(level, "%s: " format, ast_channel_name(channel) , ## __VA_ARGS__)

Definition at line 98 of file app_externalivr.c.

Referenced by app_exec(), eivr_comm(), gen_generate(), and gen_nextfile().

EIVR_CMD_ANS

#define EIVR_CMD_ANS   'T' /* answer channel */

Definition at line 111 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_APND

#define EIVR_CMD_APND   'A' /* append to prompt queue */

Definition at line 101 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_DTMF

#define EIVR_CMD_DTMF   'D' /* send DTMF */

Definition at line 102 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_EXIT

#define EIVR_CMD_EXIT   'E' /* exit */

Definition at line 103 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_GET

#define EIVR_CMD_GET   'G' /* get channel varable(s) */

Definition at line 104 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_HGUP

#define EIVR_CMD_HGUP   'H' /* hangup */

Definition at line 105 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_IRPT

#define EIVR_CMD_IRPT   'I' /* interrupt */

Definition at line 106 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_LOG

#define EIVR_CMD_LOG   'L' /* log message */

Definition at line 107 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_OPT

#define EIVR_CMD_OPT   'O' /* option */

Definition at line 108 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_PARM

#define EIVR_CMD_PARM   'P' /* return supplied params */

Definition at line 109 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_SQUE

#define EIVR_CMD_SQUE   'S' /* (re)set prompt queue */

Definition at line 110 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_SVAR

#define EIVR_CMD_SVAR   'V' /* set channel varable(s) */

Definition at line 112 of file app_externalivr.c.

Referenced by eivr_comm().

EIVR_CMD_XIT

#define EIVR_CMD_XIT   'X' /* exit **depricated** */

Definition at line 113 of file app_externalivr.c.

Referenced by eivr_comm().

EXTERNALIVR_PORT

#define EXTERNALIVR_PORT   2949

Definition at line 115 of file app_externalivr.c.

Referenced by app_exec().

Enumeration Type Documentation

options_flags

enum options_flags

Enumerator
noanswer
ignore_hangup
run_dead

Definition at line 117 of file app_externalivr.c.

 {
 noanswer = (1 << 0),
 ignore_hangup = (1 << 1),
 run_dead = (1 << 2),
};

Function Documentation

app_exec()

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

static

Definition at line 392 of file app_externalivr.c.

References ivr_localuser::abort_current_sound, ast_tcptls_session_args::accept_fd, ao2_ref, app_opts, ast_activate_generator(), AST_AF_UNSPEC, ast_answer(), AST_APP_ARG, ast_app_parse_options(), ast_chan_log, ast_close_fds_above_n(), ast_deactivate_generator(), ast_debug, AST_DECLARE_APP_ARGS, ast_free, ast_iostream_close(), ast_iostream_from_fd(), AST_LIST_HEAD_INIT_VALUE, AST_LIST_REMOVE_HEAD, ast_log, ast_opt_high_priority, ast_safe_fork(), ast_set_priority(), ast_sockaddr_copy(), ast_sockaddr_port, ast_sockaddr_resolve(), ast_sockaddr_set_port, AST_STANDARD_APP_ARGS, AST_STATE_UP, ast_str_alloca, ast_str_append(), ast_str_reset(), ast_strdupa, ast_strlen_zero, ast_tcptls_client_create(), ast_tcptls_client_start(), ast_test_flag, ast_verb, buf, ivr_localuser::chan, eivr_comm(), errno, EXTERNALIVR_PORT, ivr_localuser::gen_active, host, ignore_hangup, playlist_entry::list, LOG_ERROR, noanswer, NULL, options, ivr_localuser::playlist, ast_tcptls_session_args::remote_address, run_dead, and ast_tcptls_session_instance::stream.

Referenced by load_module().

{
 struct ast_flags flags = { 0, };
 char *opts[0];
 struct playlist_entry *entry;
 int child_stdin[2] = { -1, -1 };
 int child_stdout[2] = { -1, -1 };
 int child_stderr[2] = { -1, -1 };
 struct ast_iostream *stream_stdin = NULL, *stream_stdout = NULL,
 *stream_stderr = NULL;
 int res = -1;
 int pid;

 struct ast_tcptls_session_instance *ser = NULL;

 struct ivr_localuser foo = {
 .playlist = AST_LIST_HEAD_INIT_VALUE,
 .finishlist = AST_LIST_HEAD_INIT_VALUE,
 .gen_active = 0,
 .playing_silence = 1,
 };
 struct ivr_localuser *u = &foo;

 char *buf;
 int j;
 char *s, **app_args, *e;
 struct ast_str *comma_delim_args = ast_str_alloca(100);

 AST_DECLARE_APP_ARGS(eivr_args,
 AST_APP_ARG(application);
 AST_APP_ARG(options);
 );
 AST_DECLARE_APP_ARGS(application_args,
 AST_APP_ARG(cmd)[32];
 );

 u->abort_current_sound = 0;
 u->chan = chan;

 if (ast_strlen_zero(data)) {
 ast_log(LOG_ERROR, "ExternalIVR requires a command to execute\n");
 goto exit;
 }

 buf = ast_strdupa(data);
 AST_STANDARD_APP_ARGS(eivr_args, buf);

 ast_verb(4, "ExternalIVR received application and arguments: %s\n", eivr_args.application);
 ast_verb(4, "ExternalIVR received options: %s\n", eivr_args.options);

 /* Parse out any application arguments */
 if ((s = strchr(eivr_args.application, '('))) {
 s[0] = ',';
 if ((e = strrchr(s, ')'))) {
 *e = '\0';
 } else {
 ast_log(LOG_ERROR, "Parse error, missing closing parenthesis\n");
 goto exit;
 }
 }

 AST_STANDARD_APP_ARGS(application_args, eivr_args.application);
 app_args = application_args.argv;

 /* Put the application + the arguments in a , delimited list */
 ast_str_reset(comma_delim_args);
 for (j = 0; application_args.cmd[j] != NULL; j++) {
 ast_str_append(&comma_delim_args, 0, "%s%s", j == 0 ? "" : ",", application_args.cmd[j]);
 }

 /* Get rid of any extraneous arguments */
 if (eivr_args.options && (s = strchr(eivr_args.options, ','))) {
 *s = '\0';
 }

 /* Parse the ExternalIVR() arguments */
 ast_verb(4, "Parsing options from: [%s]\n", eivr_args.options);
 ast_app_parse_options(app_opts, &flags, opts, eivr_args.options);
 if (ast_test_flag(&flags, noanswer)) {
 ast_verb(4, "noanswer is set\n");
 }
 if (ast_test_flag(&flags, ignore_hangup)) {
 ast_verb(4, "ignore_hangup is set\n");
 }
 if (ast_test_flag(&flags, run_dead)) {
 ast_verb(4, "run_dead is set\n");
 }

 if (!(ast_test_flag(&flags, noanswer))) {
 ast_verb(3, "Answering channel and starting generator\n");
 if (ast_channel_state(chan) != AST_STATE_UP) {
 if (ast_test_flag(&flags, run_dead)) {
 ast_chan_log(LOG_ERROR, chan, "Running ExternalIVR with 'd'ead flag on non-hungup channel isn't supported\n");
 goto exit;
 }
 ast_answer(chan);
 }
 if (ast_activate_generator(chan, &gen, u) < 0) {
 ast_chan_log(LOG_ERROR, chan, "Failed to activate generator\n");
 goto exit;
 } else {
 u->gen_active = 1;
 }
 }

 if (!strncmp(app_args[0], "ivr://", sizeof("ivr://") - 1)) {
 struct ast_tcptls_session_args ivr_desc = {
 .accept_fd = -1,
 .name = "IVR",
 };
 struct ast_sockaddr *addrs;
 int num_addrs = 0, i = 0;
 char *host = app_args[0] + sizeof("ivr://") - 1;

 /* Communicate through socket to server */
 ast_debug(1, "Parsing hostname/port for socket connect from \"%s\"\n", host);

 if (!(num_addrs = ast_sockaddr_resolve(&addrs, host, 0, AST_AF_UNSPEC))) {
 ast_chan_log(LOG_ERROR, chan, "Unable to locate host '%s'\n", host);
 goto exit;
 }

 for (i = 0; i < num_addrs; i++) {
 if (!ast_sockaddr_port(&addrs[i])) {
 /* Default port if not specified */
 ast_sockaddr_set_port(&addrs[i], EXTERNALIVR_PORT);
 }
 ast_sockaddr_copy(&ivr_desc.remote_address, &addrs[i]);
 if (!(ser = ast_tcptls_client_create(&ivr_desc)) || !(ser = ast_tcptls_client_start(ser))) {
 continue;
 }
 break;
 }

 ast_free(addrs);

 if (i == num_addrs) {
 ast_chan_log(LOG_ERROR, chan, "Could not connect to any host. ExternalIVR failed.\n");
 goto exit;
 }

 res = eivr_comm(chan, u, ser->stream, ser->stream, NULL, comma_delim_args, flags);

 } else {
 if (pipe(child_stdin)) {
 ast_chan_log(LOG_ERROR, chan, "Could not create pipe for child input: %s\n", strerror(errno));
 goto exit;
 }
 if (pipe(child_stdout)) {
 ast_chan_log(LOG_ERROR, chan, "Could not create pipe for child output: %s\n", strerror(errno));
 goto exit;
 }
 if (pipe(child_stderr)) {
 ast_chan_log(LOG_ERROR, chan, "Could not create pipe for child errors: %s\n", strerror(errno));
 goto exit;
 }

 pid = ast_safe_fork(0);
 if (pid < 0) {
 ast_log(LOG_ERROR, "Failed to fork(): %s\n", strerror(errno));
 goto exit;
 }

 if (!pid) {
 /* child process */
 if (ast_opt_high_priority)
 ast_set_priority(0);

 dup2(child_stdin[0], STDIN_FILENO);
 dup2(child_stdout[1], STDOUT_FILENO);
 dup2(child_stderr[1], STDERR_FILENO);
 ast_close_fds_above_n(STDERR_FILENO);
 execv(app_args[0], app_args);
 fprintf(stderr, "Failed to execute '%s': %s\n", app_args[0], strerror(errno));
 _exit(1);
 } else {
 /* parent process */
 close(child_stdin[0]);
 child_stdin[0] = -1;
 close(child_stdout[1]);
 child_stdout[1] = -1;
 close(child_stderr[1]);
 child_stderr[1] = -1;

 stream_stdin = ast_iostream_from_fd(&child_stdin[1]);
 stream_stdout = ast_iostream_from_fd(&child_stdout[0]);
 stream_stderr = ast_iostream_from_fd(&child_stderr[0]);

 res = eivr_comm(chan, u, stream_stdin, stream_stdout, stream_stderr, comma_delim_args, flags);
 }
 }

 exit:
 if (u->gen_active) {
 ast_deactivate_generator(chan);
 }
 if (stream_stdin) {
 ast_iostream_close(stream_stdin);
 }
 if (stream_stdout) {
 ast_iostream_close(stream_stdout);
 }
 if (stream_stderr) {
 ast_iostream_close(stream_stderr);
 }
 if (child_stdin[0] > -1) {
 close(child_stdin[0]);
 }
 if (child_stdin[1] > -1) {
 close(child_stdin[1]);
 }
 if (child_stdout[0] > -1) {
 close(child_stdout[0]);
 }
 if (child_stdout[1] > -1) {
 close(child_stdout[1]);
 }
 if (child_stderr[0] > -1) {
 close(child_stderr[0]);
 }
 if (child_stderr[1] > -1) {
 close(child_stderr[1]);
 }
 if (ser) {
 ao2_ref(ser, -1);
 }
 while ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 ast_free(entry);
 }
 return res;
}

ast_eivr_getvariable()

static void ast_eivr_getvariable ( struct ast_channel *  chan, char *  data, char *  outbuf, int  outbuflen  )

static

Definition at line 304 of file app_externalivr.c.

References ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_str_alloca, ast_str_append(), ast_str_buffer(), inbuf(), NULL, pbx_builtin_getvar_helper(), strsep(), and value.

Referenced by eivr_comm().

{
 /* original input data: "G,var1,var2," */
 /* data passed as "data": "var1,var2" */

 char *inbuf, *variable;
 const char *value;
 int j;
 struct ast_str *newstring = ast_str_alloca(outbuflen);

 outbuf[0] = '\0';

 for (j = 1, inbuf = data; ; j++) {
 variable = strsep(&inbuf, ",");
 if (variable == NULL) {
 int outstrlen = strlen(outbuf);
 if (outstrlen && outbuf[outstrlen - 1] == ',') {
 outbuf[outstrlen - 1] = 0;
 }
 break;
 }

 ast_channel_lock(chan);
 if (!(value = pbx_builtin_getvar_helper(chan, variable))) {
 value = "";
 }

 ast_str_append(&newstring, 0, "%s=%s,", variable, value);
 ast_channel_unlock(chan);
 ast_copy_string(outbuf, ast_str_buffer(newstring), outbuflen);
 }
}

ast_eivr_senddtmf()

static void ast_eivr_senddtmf ( struct ast_channel *  chan, char *  vdata  )

static

Definition at line 356 of file app_externalivr.c.

References args, AST_APP_ARG, ast_app_parse_timelen(), AST_DECLARE_APP_ARGS, ast_dtmf_stream(), AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero, ast_verb, NULL, and TIMELEN_MILLISECONDS.

Referenced by eivr_comm().

{

 char *data;
 int dinterval = 0, duration = 0;
 AST_DECLARE_APP_ARGS(args,
 AST_APP_ARG(digits);
 AST_APP_ARG(dinterval);
 AST_APP_ARG(duration);
 );

 data = ast_strdupa(vdata);
 AST_STANDARD_APP_ARGS(args, data);

 if (!ast_strlen_zero(args.dinterval)) {
 ast_app_parse_timelen(args.dinterval, &dinterval, TIMELEN_MILLISECONDS);
 }
 if (!ast_strlen_zero(args.duration)) {
 ast_app_parse_timelen(args.duration, &duration, TIMELEN_MILLISECONDS);
 }
 ast_verb(4, "Sending DTMF: %s %d %d\n", args.digits, dinterval <= 0 ? 250 : dinterval, duration);
 ast_dtmf_stream(chan, NULL, args.digits, dinterval <= 0 ? 250 : dinterval, duration);
}

ast_eivr_setvariable()

static void ast_eivr_setvariable ( struct ast_channel *  chan, char *  data  )

static

Definition at line 337 of file app_externalivr.c.

References ast_debug, ast_strdupa, inbuf(), pbx_builtin_setvar_helper(), strsep(), and value.

Referenced by eivr_comm().

{
 char *value;

 char *inbuf = ast_strdupa(data), *variable;

 for (variable = strsep(&inbuf, ","); variable; variable = strsep(&inbuf, ",")) {
 ast_debug(1, "Setting up a variable: %s\n", variable);
 /* variable contains "varname=value" */
 value = strchr(variable, '=');
 if (!value) {
 value = "";
 } else {
 *value++ = '\0';
 }
 pbx_builtin_setvar_helper(chan, variable, value);
 }
}

AST_MODULE_INFO_STANDARD_EXTENDED()

AST_MODULE_INFO_STANDARD_EXTENDED	(	ASTERISK_GPL_KEY	,
		"External IVR Interface Application"
	)

Referenced by load_module().

eivr_comm()

static int eivr_comm ( struct ast_channel *  chan, struct ivr_localuser *  u, struct ast_iostream *  eivr_events, struct ast_iostream *  eivr_commands, struct ast_iostream *  eivr_errors, const struct ast_str *  args, const struct ast_flags  flags  )

static

Definition at line 624 of file app_externalivr.c.

References ivr_localuser::abort_current_sound, ast_activate_generator(), ast_answer(), ast_chan_log, ast_channel_flags(), ast_channel_hangupcause_set(), ast_channel_language(), ast_check_hangup(), AST_CONTROL_HANGUP, ast_eivr_getvariable(), ast_eivr_senddtmf(), ast_eivr_setvariable(), ast_fileexists(), AST_FLAG_ZOMBIE, AST_FRAME_CONTROL, AST_FRAME_DTMF, ast_free, ast_frfree, ast_iostream_get_fd(), ast_iostream_gets(), AST_LIST_EMPTY, AST_LIST_INSERT_TAIL, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_read(), AST_STATE_UP, ast_str_buffer(), ast_strip(), ast_test_flag, ast_verb, ast_waitfor_nandfds(), ivr_localuser::chan, ast_frame::data, EIVR_CMD_ANS, EIVR_CMD_APND, EIVR_CMD_DTMF, EIVR_CMD_EXIT, EIVR_CMD_GET, EIVR_CMD_HGUP, EIVR_CMD_IRPT, EIVR_CMD_LOG, EIVR_CMD_OPT, EIVR_CMD_PARM, EIVR_CMD_SQUE, EIVR_CMD_SVAR, EIVR_CMD_XIT, errno, playlist_entry::filename, ivr_localuser::finishlist, ast_frame::frametype, ivr_localuser::gen_active, ignore_hangup, input(), ast_frame_subclass::integer, playlist_entry::list, LOG_ERROR, LOG_NOTICE, LOG_WARNING, make_entry(), NULL, ivr_localuser::option_autoclear, ivr_localuser::playing_silence, ivr_localuser::playlist, run_dead, send_eivr_event(), ast_frame::subclass, tmp(), and ast_frame::uint32.

Referenced by app_exec().

{
 char input[1024];
 struct playlist_entry *entry;
 struct ast_frame *f;
 int ms;
 int exception;
 int ready_fd;
 int waitfds[2];
 int r;
 struct ast_channel *rchan;
 int res = -1;
 int hangup_info_sent = 0;

 waitfds[0] = ast_iostream_get_fd(eivr_commands);
 waitfds[1] = eivr_errors ? ast_iostream_get_fd(eivr_errors) : -1;

 while (1) {
 if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_ZOMBIE)) {
 ast_chan_log(LOG_ERROR, chan, "Is a zombie\n");
 break;
 }
 if (!hangup_info_sent && !(ast_test_flag(&flags, run_dead)) && ast_check_hangup(chan)) {
 if (ast_test_flag(&flags, ignore_hangup)) {
 ast_verb(3, "Got check_hangup, but ignore_hangup set so sending 'I' command\n");
 send_eivr_event(eivr_events, 'I', "HANGUP", chan);
 hangup_info_sent = 1;
 } else {
 ast_verb(3, "Got check_hangup\n");
 send_eivr_event(eivr_events, 'H', NULL, chan);
 break;
 }
 }

 ready_fd = 0;
 ms = 100;
 errno = 0;
 exception = 0;

 rchan = ast_waitfor_nandfds(&chan, 1, waitfds, (eivr_errors) ? 2 : 1, &exception, &ready_fd, &ms);

 if (ast_channel_state(chan) == AST_STATE_UP && !AST_LIST_EMPTY(&u->finishlist)) {
 AST_LIST_LOCK(&u->finishlist);
 while ((entry = AST_LIST_REMOVE_HEAD(&u->finishlist, list))) {
 send_eivr_event(eivr_events, 'F', entry->filename, chan);
 ast_free(entry);
 }
 AST_LIST_UNLOCK(&u->finishlist);
 }

 if (ast_channel_state(chan) == AST_STATE_UP && !(ast_check_hangup(chan)) && rchan) {
 /* the channel has something */
 f = ast_read(chan);
 if (!f) {
 ast_verb(3, "Returned no frame\n");
 send_eivr_event(eivr_events, 'H', NULL, chan);
 break;
 }
 if (f->frametype == AST_FRAME_DTMF) {
 send_eivr_event(eivr_events, f->subclass.integer, NULL, chan);
 if (u->option_autoclear) {
 AST_LIST_LOCK(&u->playlist);
 if (!u->abort_current_sound && !u->playing_silence) {
 /* send interrupted file as T data */
 if ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'T', entry->filename, chan);
 ast_free(entry);
 }
 }
 while ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'D', entry->filename, chan);
 ast_free(entry);
 }
 if (!u->playing_silence)
 u->abort_current_sound = 1;
 AST_LIST_UNLOCK(&u->playlist);
 }
 } else if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass.integer == AST_CONTROL_HANGUP)) {
 ast_verb(3, "Got AST_CONTROL_HANGUP\n");
 send_eivr_event(eivr_events, 'H', NULL, chan);
 if (f->data.uint32) {
 ast_channel_hangupcause_set(chan, f->data.uint32);
 }
 ast_frfree(f);
 break;
 }
 ast_frfree(f);
 } else if (ready_fd == waitfds[0]) {
 if (exception) {
 ast_chan_log(LOG_ERROR, chan, "Child process went away\n");
 break;
 }

 r = ast_iostream_gets(eivr_commands, input, sizeof(input));
 if (r <= 0) {
 if (r == 0) {
 ast_chan_log(LOG_ERROR, chan, "Child process went away\n");
 break;
 }
 continue;
 }

 ast_strip(input);
 ast_verb(4, "got command '%s'\n", input);

 if (strlen(input) < 3) {
 continue;
 }

 if (input[0] == EIVR_CMD_PARM) {
 struct ast_str *tmp = (struct ast_str *) args;
 send_eivr_event(eivr_events, 'P', ast_str_buffer(tmp), chan);
 } else if (input[0] == EIVR_CMD_DTMF) {
 ast_verb(4, "Sending DTMF: %s\n", &input[2]);
 ast_eivr_senddtmf(chan, &input[2]);
 } else if (input[0] == EIVR_CMD_ANS) {
 ast_verb(3, "Answering channel if needed and starting generator\n");
 if (ast_channel_state(chan) != AST_STATE_UP) {
 if (ast_test_flag(&flags, run_dead)) {
 ast_chan_log(LOG_WARNING, chan, "Running ExternalIVR with 'd'ead flag on non-hungup channel isn't supported\n");
 send_eivr_event(eivr_events, 'Z', "ANSWER_FAILURE", chan);
 continue;
 }
 if (ast_answer(chan)) {
 ast_chan_log(LOG_WARNING, chan, "Failed to answer channel\n");
 send_eivr_event(eivr_events, 'Z', "ANSWER_FAILURE", chan);
 continue;
 }
 }
 if (!(u->gen_active)) {
 if (ast_activate_generator(chan, &gen, u) < 0) {
 ast_chan_log(LOG_WARNING, chan, "Failed to activate generator\n");
 send_eivr_event(eivr_events, 'Z', "GENERATOR_FAILURE", chan);
 } else {
 u->gen_active = 1;
 }
 }
 } else if (input[0] == EIVR_CMD_IRPT) {
 if (ast_channel_state(chan) != AST_STATE_UP || ast_check_hangup(chan)) {
 ast_chan_log(LOG_WARNING, chan, "Queue 'I'nterrupt called on unanswered channel\n");
 send_eivr_event(eivr_events, 'Z', NULL, chan);
 continue;
 }
 AST_LIST_LOCK(&u->playlist);
 if (!u->abort_current_sound && !u->playing_silence) {
 /* send interrupted file as T data */
 if ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'T', entry->filename, chan);
 ast_free(entry);
 }
 }
 while ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'D', entry->filename, chan);
 ast_free(entry);
 }
 if (!u->playing_silence) {
 u->abort_current_sound = 1;
 }
 AST_LIST_UNLOCK(&u->playlist);
 } else if (input[0] == EIVR_CMD_SQUE) {
 if (ast_channel_state(chan) != AST_STATE_UP || ast_check_hangup(chan)) {
 ast_chan_log(LOG_WARNING, chan, "Queue re'S'et called on unanswered channel\n");
 send_eivr_event(eivr_events, 'Z', NULL, chan);
 continue;
 }
 if (!ast_fileexists(&input[2], NULL, ast_channel_language(u->chan))) {
 ast_chan_log(LOG_WARNING, chan, "Unknown file requested '%s'\n", &input[2]);
 send_eivr_event(eivr_events, 'Z', &input[2], chan);
 } else {
 AST_LIST_LOCK(&u->playlist);
 if (!u->abort_current_sound && !u->playing_silence) {
 /* send interrupted file as T data */
 if ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'T', entry->filename, chan);
 ast_free(entry);
 }
 }
 while ((entry = AST_LIST_REMOVE_HEAD(&u->playlist, list))) {
 send_eivr_event(eivr_events, 'D', entry->filename, chan);
 ast_free(entry);
 }
 if (!u->playing_silence) {
 u->abort_current_sound = 1;
 }
 entry = make_entry(&input[2]);
 if (entry) {
 AST_LIST_INSERT_TAIL(&u->playlist, entry, list);
 }
 AST_LIST_UNLOCK(&u->playlist);
 }
 } else if (input[0] == EIVR_CMD_APND) {
 if (ast_channel_state(chan) != AST_STATE_UP || ast_check_hangup(chan)) {
 ast_chan_log(LOG_WARNING, chan, "Queue 'A'ppend called on unanswered channel\n");
 send_eivr_event(eivr_events, 'Z', NULL, chan);
 continue;
 }
 if (!ast_fileexists(&input[2], NULL, ast_channel_language(u->chan))) {
 ast_chan_log(LOG_WARNING, chan, "Unknown file requested '%s'\n", &input[2]);
 send_eivr_event(eivr_events, 'Z', &input[2], chan);
 } else {
 entry = make_entry(&input[2]);
 if (entry) {
 AST_LIST_LOCK(&u->playlist);
 AST_LIST_INSERT_TAIL(&u->playlist, entry, list);
 AST_LIST_UNLOCK(&u->playlist);
 }
 }
 } else if (input[0] == EIVR_CMD_GET) {
 char response[2048];
 ast_verb(4, "Retriving Variables from channel: %s\n", &input[2]);
 ast_eivr_getvariable(chan, &input[2], response, sizeof(response));
 send_eivr_event(eivr_events, 'G', response, chan);
 } else if (input[0] == EIVR_CMD_SVAR) {
 ast_verb(4, "Setting Variables in channel: %s\n", &input[2]);
 ast_eivr_setvariable(chan, &input[2]);
 } else if (input[0] == EIVR_CMD_LOG) {
 ast_chan_log(LOG_NOTICE, chan, "Log message from EIVR: %s\n", &input[2]);
 } else if (input[0] == EIVR_CMD_XIT) {
 ast_chan_log(LOG_NOTICE, chan, "Exiting: %s\n", &input[2]);
 ast_chan_log(LOG_WARNING, chan, "e'X'it command is depricated, use 'E'xit instead\n");
 res = 0;
 break;
 } else if (input[0] == EIVR_CMD_EXIT) {
 ast_chan_log(LOG_NOTICE, chan, "Exiting: %s\n", &input[2]);
 send_eivr_event(eivr_events, 'E', NULL, chan);
 res = 0;
 break;
 } else if (input[0] == EIVR_CMD_HGUP) {
 ast_chan_log(LOG_NOTICE, chan, "Hanging up: %s\n", &input[2]);
 send_eivr_event(eivr_events, 'H', NULL, chan);
 break;
 } else if (input[0] == EIVR_CMD_OPT) {
 if (ast_channel_state(chan) != AST_STATE_UP || ast_check_hangup(chan)) {
 ast_chan_log(LOG_WARNING, chan, "Option called on unanswered channel\n");
 send_eivr_event(eivr_events, 'Z', NULL, chan);
 continue;
 }
 if (!strcasecmp(&input[2], "autoclear"))
 u->option_autoclear = 1;
 else if (!strcasecmp(&input[2], "noautoclear"))
 u->option_autoclear = 0;
 else
 ast_chan_log(LOG_WARNING, chan, "Unknown option requested: %s\n", &input[2]);
 }
 } else if (ready_fd == waitfds[1]) {
 if (exception) {
 ast_chan_log(LOG_ERROR, chan, "Child process went away\n");
 break;
 }

 r = ast_iostream_gets(eivr_errors, input, sizeof(input));
 if (r > 0) {
 ast_chan_log(LOG_NOTICE, chan, "stderr: %s\n", ast_strip(input));
 } else if (r == 0) {
 ast_chan_log(LOG_ERROR, chan, "Child process went away\n");
 break;
 }
 } else if ((ready_fd < 0) && ms) {
 if (errno == 0 || errno == EINTR)
 continue;

 ast_chan_log(LOG_ERROR, chan, "Wait failed (%s)\n", strerror(errno));
 break;
 }
 }

 return res;
}

gen_alloc()

static void* gen_alloc ( struct ast_channel *  chan, void *  params  )

static

Definition at line 175 of file app_externalivr.c.

References ast_calloc, NULL, state, and gen_state::u.

{
 struct ivr_localuser *u = params;
 struct gen_state *state;

 if (!(state = ast_calloc(1, sizeof(*state))))
 return NULL;

 state->u = u;

 return state;
}

gen_closestream()

static void gen_closestream ( struct gen_state *  state )

static

Definition at line 188 of file app_externalivr.c.

References ast_channel_stream_set(), ast_closestream(), ivr_localuser::chan, NULL, gen_state::stream, and gen_state::u.

Referenced by gen_nextfile(), gen_readframe(), and gen_release().

{
 if (!state->stream)
 return;

 ast_closestream(state->stream);
 ast_channel_stream_set(state->u->chan, NULL);
 state->stream = NULL;
}

gen_generate()

static int gen_generate ( struct ast_channel *  chan, void *  data, int  len, int  samples  )

static

Definition at line 273 of file app_externalivr.c.

References ast_chan_log, ast_frfree, ast_write(), errno, gen_readframe(), LOG_WARNING, NULL, gen_state::sample_queue, and ast_frame::samples.

{
 struct gen_state *state = data;
 struct ast_frame *f = NULL;
 int res = 0;

 state->sample_queue += samples;

 while (state->sample_queue > 0) {
 if (!(f = gen_readframe(state)))
 return -1;

 res = ast_write(chan, f);
 ast_frfree(f);
 if (res < 0) {
 ast_chan_log(LOG_WARNING, chan, "Failed to write frame: %s\n", strerror(errno));
 return -1;
 }
 state->sample_queue -= f->samples;
 }

 return res;
}

gen_nextfile()

static int gen_nextfile ( struct gen_state *  state )

static

Definition at line 207 of file app_externalivr.c.

References ivr_localuser::abort_current_sound, ast_chan_log, ast_channel_language(), AST_LIST_FIRST, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_openstream_full(), ivr_localuser::chan, gen_state::current, errno, playlist_entry::filename, gen_closestream(), playlist_entry::list, LOG_WARNING, ivr_localuser::playing_silence, ivr_localuser::playlist, gen_state::stream, and gen_state::u.

Referenced by gen_readframe().

{
 struct ivr_localuser *u = state->u;
 char *file_to_stream;

 u->abort_current_sound = 0;
 u->playing_silence = 0;
 gen_closestream(state);

 while (!state->stream) {
 state->current = AST_LIST_FIRST(&u->playlist);
 if (state->current) {
 file_to_stream = state->current->filename;
 } else {
 file_to_stream = "silence/10";
 u->playing_silence = 1;
 }

 if (!(state->stream = ast_openstream_full(u->chan, file_to_stream, ast_channel_language(u->chan), 1))) {
 ast_chan_log(LOG_WARNING, u->chan, "File '%s' could not be opened: %s\n", file_to_stream, strerror(errno));
 AST_LIST_LOCK(&u->playlist);
 AST_LIST_REMOVE_HEAD(&u->playlist, list);
 AST_LIST_UNLOCK(&u->playlist);
 if (!u->playing_silence) {
 continue;
 } else {
 break;
 }
 }
 }

 return (!state->stream);
}

gen_readframe()

static struct ast_frame* gen_readframe ( struct gen_state *  state )

static

Definition at line 241 of file app_externalivr.c.

References ivr_localuser::abort_current_sound, AST_LIST_FIRST, AST_LIST_INSERT_TAIL, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_readframe(), gen_state::current, ivr_localuser::finishlist, gen_closestream(), gen_nextfile(), playlist_entry::list, NULL, ivr_localuser::playing_silence, ivr_localuser::playlist, gen_state::stream, and gen_state::u.

Referenced by gen_generate().

{
 struct ast_frame *f = NULL;
 struct ivr_localuser *u = state->u;

 if (u->abort_current_sound ||
 (u->playing_silence && AST_LIST_FIRST(&u->playlist))) {
 gen_closestream(state);
 AST_LIST_LOCK(&u->playlist);
 gen_nextfile(state);
 AST_LIST_UNLOCK(&u->playlist);
 }

 if (!(state->stream && (f = ast_readframe(state->stream)))) {
 if (state->current) {
 /* remove finished file from playlist */
 AST_LIST_LOCK(&u->playlist);
 AST_LIST_REMOVE_HEAD(&u->playlist, list);
 AST_LIST_UNLOCK(&u->playlist);
 /* add finished file to finishlist */
 AST_LIST_LOCK(&u->finishlist);
 AST_LIST_INSERT_TAIL(&u->finishlist, state->current, list);
 AST_LIST_UNLOCK(&u->finishlist);
 state->current = NULL;
 }
 if (!gen_nextfile(state))
 f = ast_readframe(state->stream);
 }

 return f;
}

gen_release()

static void gen_release ( struct ast_channel *  chan, void *  data  )

static

Definition at line 198 of file app_externalivr.c.

References ast_free, and gen_closestream().

{
 struct gen_state *state = data;

 gen_closestream(state);
 ast_free(data);
}

load_module()

static int load_module ( void  )

static

Definition at line 902 of file app_externalivr.c.

References app, app_exec(), AST_MODULE_INFO_STANDARD_EXTENDED(), ast_register_application_xml, and ASTERISK_GPL_KEY.

{
 return ast_register_application_xml(app, app_exec);
}

make_entry()

static struct playlist_entry* make_entry ( const char *  filename )

static

Definition at line 380 of file app_externalivr.c.

References ast_calloc, playlist_entry::filename, and NULL.

Referenced by eivr_comm().

{
 struct playlist_entry *entry;

 if (!(entry = ast_calloc(1, sizeof(*entry) + strlen(filename) + 10))) /* XXX why 10 ? */
 return NULL;

 strcpy(entry->filename, filename);

 return entry;
}

send_eivr_event()

static void send_eivr_event ( struct ast_iostream *  stream, const char  event, const char *  data, const struct ast_channel *  chan  )

static

Definition at line 158 of file app_externalivr.c.

References ast_debug, ast_free, ast_iostream_write(), ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_truncate(), NULL, and tmp().

Referenced by eivr_comm().

{
 struct ast_str *tmp = ast_str_create(12);

 ast_str_append(&tmp, 0, "%c,%10d", event, (int)time(NULL));
 if (data) {
 ast_str_append(&tmp, 0, ",%s", data);
 }
 ast_str_append(&tmp, 0, "\n");
 ast_iostream_write(stream, ast_str_buffer(tmp), strlen(ast_str_buffer(tmp)));
 ast_str_truncate(tmp, -1);

 ast_debug(1, "sent '%s'", ast_str_buffer(tmp));
 ast_free(tmp);
}

unload_module()

static int unload_module ( void  )

static

Definition at line 897 of file app_externalivr.c.

References app, and ast_unregister_application().

{
 return ast_unregister_application(app);
}

Variable Documentation

app

const char app[] = "ExternalIVR"

static

Definition at line 95 of file app_externalivr.c.

Referenced by load_module(), and unload_module().

app_opts

const struct ast_app_option app_opts[128] = { [ 'n' ] = { .flag = noanswer }, [ 'i' ] = { .flag = ignore_hangup }, [ 'd' ] = { .flag = run_dead }, }

static

Definition at line 127 of file app_externalivr.c.

Referenced by app_exec().

gen

struct ast_generator gen

static

Definition at line 297 of file app_externalivr.c.

Referenced by find_body_generator_type_subtype(), find_body_generator_type_subtype_nolock(), reload_config(), and set_config().