Sun Aug 6 15:02:54 2006

Asterisk developer's documentation

---

app.c File Reference

Convenient Application Routines. More...

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#include <errno.h>
#include <unistd.h>
#include <dirent.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <regex.h>
#include "asterisk.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/file.h"
#include "asterisk/app.h"
#include "asterisk/dsp.h"
#include "asterisk/logger.h"
#include "asterisk/options.h"
#include "asterisk/utils.h"
#include "asterisk/lock.h"
#include "asterisk/indications.h"

Include dependency graph for app.c:

Go to the source code of this file.

Defines
#define	MAX_OTHER_FORMATS   10
#define	RES_EXIT   (1 << 17)
#define	RES_REPEAT   (1 << 18)
#define	RES_RESTART   ((1 << 19) | RES_REPEAT)
#define	RES_UPONE   (1 << 16)
Functions
int	ast_app_dtget (struct ast_channel *chan, const char *context, char *collect, size_t size, int maxlen, int timeout)
	Present a dialtone and collect a certain length extension.
int	ast_app_getdata (struct ast_channel *c, char *prompt, char *s, int maxlen, int timeout)
	Plays a stream and gets DTMF data from a channel.
int	ast_app_getdata_full (struct ast_channel *c, char *prompt, char *s, int maxlen, int timeout, int audiofd, int ctrlfd)
	Full version with audiofd and controlfd. NOTE: returns '2' on ctrlfd available, not '1' like other full functions.
int	ast_app_getvoice (struct ast_channel *c, char *dest, char *dstfmt, char *prompt, int silence, int maxsec)
int	ast_app_group_get_count (char *group, char *category)
int	ast_app_group_match_get_count (char *groupmatch, char *category)
int	ast_app_group_set_channel (struct ast_channel *chan, char *data)
int	ast_app_group_split_group (char *data, char *group, int group_max, char *category, int category_max)
int	ast_app_has_voicemail (const char *mailbox, const char *folder)
int	ast_app_messagecount (const char *mailbox, int *newmsgs, int *oldmsgs)
int	ast_app_parse_options (const struct ast_app_option *options, struct ast_flags *flags, char **args, char *optstr)
	Parses a string containing application options and sets flags/arguments.
unsigned int	ast_app_separate_args (char *buf, char delim, char **array, int arraylen)
	Separate a string into arguments in an array.
int	ast_control_streamfile (struct ast_channel *chan, const char *file, const char *fwd, const char *rev, const char *stop, const char *pause, const char *restart, int skipms)
int	ast_dtmf_stream (struct ast_channel *chan, struct ast_channel *peer, char *digits, int between)
void	ast_install_vm_functions (int(*has_voicemail_func)(const char *mailbox, const char *folder), int(*messagecount_func)(const char *mailbox, int *newmsgs, int *oldmsgs))
int	ast_ivr_menu_run (struct ast_channel *chan, struct ast_ivr_menu *menu, void *cbdata)
	Runs an IVR menu.
static int	ast_ivr_menu_run_internal (struct ast_channel *chan, struct ast_ivr_menu *menu, void *cbdata)
int	ast_linear_stream (struct ast_channel *chan, const char *filename, int fd, int allowoverride)
enum AST_LOCK_RESULT	ast_lock_path (const char *path)
	Lock a filesystem path.
int	ast_play_and_prepend (struct ast_channel *chan, char *playfile, char *recordfile, int maxtime, char *fmt, int *duration, int beep, int silencethreshold, int maxsilence)
int	ast_play_and_record (struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, int silencethreshold, int maxsilence, const char *path)
int	ast_play_and_record_full (struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, int silencethreshold, int maxsilence, const char *path, const char *acceptdtmf, const char *canceldtmf)
int	ast_play_and_wait (struct ast_channel *chan, const char *fn)
char *	ast_read_textfile (const char *filename)
int	ast_record_review (struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, const char *path)
void	ast_uninstall_vm_functions (void)
int	ast_unlock_path (const char *path)
static int	ivr_dispatch (struct ast_channel *chan, struct ast_ivr_option *option, char *exten, void *cbdata)
static void *	linear_alloc (struct ast_channel *chan, void *params)
static int	linear_generator (struct ast_channel *chan, void *data, int len, int samples)
static void	linear_release (struct ast_channel *chan, void *params)
static int	option_exists (struct ast_ivr_menu *menu, char *option)
static int	option_matchmore (struct ast_ivr_menu *menu, char *option)
static int	read_newoption (struct ast_channel *chan, struct ast_ivr_menu *menu, char *exten, int maxexten)
Variables
static int(*	ast_has_voicemail_func )(const char *mailbox, const char *folder) = NULL
static int(*	ast_messagecount_func )(const char *mailbox, int *newmsgs, int *oldmsgs) = NULL
static char	default_acceptdtmf [] = "#"
static char	default_canceldtmf [] = "0"
static int	global_maxsilence = 0
static int	global_silence_threshold = 128
static struct ast_generator	linearstream

---

Detailed Description

Convenient Application Routines.

Definition in file app.c.

---

Define Documentation

#define MAX_OTHER_FORMATS   10

Definition at line 52 of file app.c. Referenced by ast_play_and_prepend(), and ast_play_and_record_full().

#define RES_EXIT   (1 << 17)

Definition at line 1302 of file app.c. Referenced by ast_ivr_menu_run_internal(), and ivr_dispatch().

#define RES_REPEAT   (1 << 18)

Definition at line 1303 of file app.c. Referenced by ast_ivr_menu_run_internal(), and ivr_dispatch().

#define RES_RESTART   ((1 << 19) | RES_REPEAT)

Definition at line 1304 of file app.c. Referenced by ast_ivr_menu_run_internal(), and ivr_dispatch().

#define RES_UPONE   (1 << 16)

Definition at line 1301 of file app.c. Referenced by ast_ivr_menu_run_internal(), and ivr_dispatch().

---

Function Documentation

int ast_app_dtget (  struct ast_channel *  chan, const char *  context, char *  collect, size_t  size, int  maxlen, int  timeout )

Present a dialtone and collect a certain length extension. Returns: Returns 1 on valid extension entered, -1 on hangup, or 0 on invalid extension. Note: Note that if 'collect' holds digits already, new digits will be appended, so be sure it's initialized properly Definition at line 62 of file app.c. References ast_exists_extension(), ast_get_indication_tone(), ast_ignore_pattern(), ast_log(), ast_matchmore_extension(), ast_playtones_start(), ast_playtones_stop(), ast_waitfordigit(), ast_channel::cid, ast_callerid::cid_num, tone_zone_sound::data, ast_pbx::dtimeout, LOG_NOTICE, ast_channel::pbx, and ast_channel::zone. Referenced by builtin_atxfer(), and builtin_blindtransfer(). { struct tone_zone_sound *ts; int res=0, x=0; if(maxlen > size) maxlen = size; if(!timeout && chan->pbx) timeout = chan->pbx->dtimeout; else if(!timeout) timeout = 5; ts = ast_get_indication_tone(chan->zone,"dial"); if (ts && ts->data[0]) res = ast_playtones_start(chan, 0, ts->data, 0); else ast_log(LOG_NOTICE,"Huh....? no dial for indications?\n"); for (x = strlen(collect); strlen(collect) < maxlen; ) { res = ast_waitfordigit(chan, timeout); if (!ast_ignore_pattern(context, collect)) ast_playtones_stop(chan); if (res < 1) break; collect[x++] = res; if (!ast_matchmore_extension(chan, context, collect, 1, chan->cid.cid_num)) { if (collect[x-1] == '#') { /* Not a valid extension, ending in #, assume the # was to finish dialing */ collect[x-1] = '\0'; } break; } } if (res >= 0) { if (ast_exists_extension(chan, context, collect, 1, chan->cid.cid_num)) res = 1; else res = 0; } return res; }

int ast_app_getdata (  struct ast_channel *  c, char *  prompt, char *  s, int  maxlen, int  timeout )

Plays a stream and gets DTMF data from a channel. Parameters: timeout  set timeout to 0 for "standard" timeouts. Set timeout to -1 for "ludicrous time" (essentially never times out) Definition at line 109 of file app.c. References ast_readstring(), ast_streamfile(), ast_pbx::dtimeout, ast_channel::language, ast_channel::pbx, and ast_pbx::rtimeout. Referenced by __login_exec(), auth_exec(), conf_exec(), dictate_exec(), find_conf(), read_exec(), testclient_exec(), testserver_exec(), and vm_exec(). { int res,to,fto; /* XXX Merge with full version? XXX */ if (maxlen) s[0] = '\0'; if (prompt) { res = ast_streamfile(c, prompt, c->language); if (res < 0) return res; } fto = c->pbx ? c->pbx->rtimeout * 1000 : 6000; to = c->pbx ? c->pbx->dtimeout * 1000 : 2000; if (timeout > 0) fto = to = timeout; if (timeout < 0) fto = to = 1000000000; res = ast_readstring(c, s, maxlen, to, fto, "#"); return res; }

int ast_app_getdata_full (  struct ast_channel *  c, char *  prompt, char *  s, int  maxlen, int  timeout, int  audiofd, int  ctrlfd )

Full version with audiofd and controlfd. NOTE: returns '2' on ctrlfd available, not '1' like other full functions. Definition at line 132 of file app.c. References ast_readstring_full(), ast_streamfile(), and ast_channel::language. Referenced by handle_getdata(). { int res,to,fto; if (prompt) { res = ast_streamfile(c, prompt, c->language); if (res < 0) return res; } fto = 6000; to = 2000; if (timeout > 0) fto = to = timeout; if (timeout < 0) fto = to = 1000000000; res = ast_readstring_full(c, s, maxlen, to, fto, "#", audiofd, ctrlfd); return res; }

int ast_app_getvoice (  struct ast_channel *  c, char *  dest, char *  dstfmt, char *  prompt, int  silence, int  maxsec )

Record voice (after playing prompt if specified), waiting for silence (in ms) up to a given timeout (in s) or '#' Definition at line 150 of file app.c. References ast_closestream(), ast_dsp_free(), ast_dsp_new(), ast_dsp_silence(), AST_FORMAT_SLINEAR, AST_FRAME_DTMF, AST_FRAME_VOICE, ast_frfree(), ast_log(), ast_read(), ast_set_read_format(), ast_streamfile(), ast_waitfor(), ast_waitstream(), ast_writefile(), ast_writestream(), ast_frame::frametype, ast_channel::language, LOG_NOTICE, LOG_WARNING, ast_channel::name, ast_channel::readformat, ast_frame::samples, ast_frame::subclass, and total. { int res; struct ast_filestream *writer; int rfmt; int totalms=0, total; struct ast_frame *f; struct ast_dsp *sildet; /* Play prompt if requested */ if (prompt) { res = ast_streamfile(c, prompt, c->language); if (res < 0) return res; res = ast_waitstream(c,""); if (res < 0) return res; } rfmt = c->readformat; res = ast_set_read_format(c, AST_FORMAT_SLINEAR); if (res < 0) { ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n"); return -1; } sildet = ast_dsp_new(); if (!sildet) { ast_log(LOG_WARNING, "Unable to create silence detector :(\n"); return -1; } writer = ast_writefile(dest, dstfmt, "Voice file", 0, 0, 0666); if (!writer) { ast_log(LOG_WARNING, "Unable to open file '%s' in format '%s' for writing\n", dest, dstfmt); ast_dsp_free(sildet); return -1; } for(;;) { if ((res = ast_waitfor(c, 2000)) < 0) { ast_log(LOG_NOTICE, "Waitfor failed while recording file '%s' format '%s'\n", dest, dstfmt); break; } if (res) { f = ast_read(c); if (!f) { ast_log(LOG_NOTICE, "Hungup while recording file '%s' format '%s'\n", dest, dstfmt); break; } if ((f->frametype == AST_FRAME_DTMF) && (f->subclass == '#')) { /* Ended happily with DTMF */ ast_frfree(f); break; } else if (f->frametype == AST_FRAME_VOICE) { ast_dsp_silence(sildet, f, &total); if (total > silence) { /* Ended happily with silence */ ast_frfree(f); break; } totalms += f->samples / 8; if (totalms > maxsec * 1000) { /* Ended happily with too much stuff */ ast_log(LOG_NOTICE, "Constraining voice on '%s' to %d seconds\n", c->name, maxsec); ast_frfree(f); break; } res = ast_writestream(writer, f); if (res < 0) { ast_log(LOG_WARNING, "Failed to write to stream at %s!\n", dest); ast_frfree(f); break; } } ast_frfree(f); } } res = ast_set_read_format(c, rfmt); if (res) ast_log(LOG_WARNING, "Unable to restore read format on '%s'\n", c->name); ast_dsp_free(sildet); ast_closestream(writer); return 0; }

int ast_app_group_get_count (  char *  group, char *  category )

Get the current channel count of the specified group and category. Definition at line 1051 of file app.c. References ast_channel_walk_locked(), ast_mutex_unlock(), ast_strlen_zero(), GROUP_CATEGORY_PREFIX, pbx_builtin_getvar_helper(), and s. Referenced by group_check_exec(), group_count_exec(), and group_count_function_read(). { struct ast_channel *chan; int count = 0; char *test; char cat[80]; char *s; if (ast_strlen_zero(group)) return 0; s = (!ast_strlen_zero(category)) ? category : GROUP_CATEGORY_PREFIX; ast_copy_string(cat, s, sizeof(cat)); chan = NULL; while ((chan = ast_channel_walk_locked(chan)) != NULL) { test = pbx_builtin_getvar_helper(chan, cat); if (test && !strcasecmp(test, group)) count++; ast_mutex_unlock(&chan->lock); } return count; }

int ast_app_group_match_get_count (  char *  groupmatch, char *  category )

Get the current channel count of all groups that match the specified pattern and category. Definition at line 1076 of file app.c. References ast_channel_walk_locked(), ast_mutex_unlock(), ast_strlen_zero(), GROUP_CATEGORY_PREFIX, pbx_builtin_getvar_helper(), and s. Referenced by group_match_count_exec(), and group_match_count_function_read(). { regex_t regexbuf; struct ast_channel *chan; int count = 0; char *test; char cat[80]; char *s; if (ast_strlen_zero(groupmatch)) return 0; /* if regex compilation fails, return zero matches */ if (regcomp(&regexbuf, groupmatch, REG_EXTENDED | REG_NOSUB)) return 0; s = (!ast_strlen_zero(category)) ? category : GROUP_CATEGORY_PREFIX; ast_copy_string(cat, s, sizeof(cat)); chan = NULL; while ((chan = ast_channel_walk_locked(chan)) != NULL) { test = pbx_builtin_getvar_helper(chan, cat); if (test && !regexec(&regexbuf, test, 0, NULL, 0)) count++; ast_mutex_unlock(&chan->lock); } regfree(&regexbuf); return count; }

int ast_app_group_set_channel (  struct ast_channel *  chan, char *  data )

Set the group for a channel, splitting the provided data into group and category, if specified. Definition at line 1037 of file app.c. References ast_app_group_split_group(), group, and pbx_builtin_setvar_helper(). Referenced by dial_exec_full(), group_function_write(), and group_set_exec(). { int res=0; char group[80] = ""; char category[80] = ""; if (!ast_app_group_split_group(data, group, sizeof(group), category, sizeof(category))) { pbx_builtin_setvar_helper(chan, category, group); } else res = -1; return res; }

int ast_app_group_split_group (  char *  data, char *  group, int  group_max, char *  category, int  category_max )

Split a group string into group and category, returning a default category if none is provided. Definition at line 1008 of file app.c. References ast_strlen_zero(), and GROUP_CATEGORY_PREFIX. Referenced by ast_app_group_set_channel(), group_check_exec(), group_count_exec(), group_count_function_read(), group_match_count_exec(), and group_match_count_function_read(). { int res=0; char tmp[256]; char *grp=NULL, *cat=NULL; if (!ast_strlen_zero(data)) { ast_copy_string(tmp, data, sizeof(tmp)); grp = tmp; cat = strchr(tmp, '@'); if (cat) { *cat = '\0'; cat++; } } if (!ast_strlen_zero(grp)) ast_copy_string(group, grp, group_max); else res = -1; if (cat) snprintf(category, category_max, "%s_%s", GROUP_CATEGORY_PREFIX, cat); else ast_copy_string(category, GROUP_CATEGORY_PREFIX, category_max); return res; }

int ast_app_has_voicemail (  const char *  mailbox, const char *  folder )

Determine if a given mailbox has any voicemail Definition at line 249 of file app.c. References ast_has_voicemail_func, ast_verbose(), option_verbose, and VERBOSE_PREFIX_3. Referenced by action_mailboxstatus(), do_monitor(), has_voicemail(), notify_new_message(), play_dialtone(), and update_registry(). { static int warned = 0; if (ast_has_voicemail_func) return ast_has_voicemail_func(mailbox, folder); if ((option_verbose > 2) && !warned) { ast_verbose(VERBOSE_PREFIX_3 "Message check requested for mailbox %s/folder %s but voicemail not loaded.\n", mailbox, folder ? folder : "INBOX"); warned++; } return 0; }

int ast_app_messagecount (  const char *  mailbox, int *  newmsgs, int *  oldmsgs )

Determine number of new/old messages in a mailbox Definition at line 263 of file app.c. References ast_messagecount_func, ast_verbose(), option_verbose, and VERBOSE_PREFIX_3. Referenced by action_mailboxcount(), do_housekeeping(), notify_new_message(), sip_send_mwi_to_peer(), and update_registry(). { static int warned = 0; if (newmsgs) *newmsgs = 0; if (oldmsgs) *oldmsgs = 0; if (ast_messagecount_func) return ast_messagecount_func(mailbox, newmsgs, oldmsgs); if (!warned && (option_verbose > 2)) { warned++; ast_verbose(VERBOSE_PREFIX_3 "Message count requested for mailbox %s but voicemail not loaded.\n", mailbox); } return 0; }

int ast_app_parse_options (  const struct ast_app_option *  options, struct ast_flags *  flags, char **  args, char *  optstr )

Parses a string containing application options and sets flags/arguments. Parameters: options  The array of possible options declared with AST_APP_OPTIONS flags  The flag structure to have option flags set args  The array of argument pointers to hold arguments found optstr  The string containing the options to be parsed Returns: zero for success, non-zero if an error occurs See also: AST_APP_OPTIONS Definition at line 1538 of file app.c. References ast_app_option::arg_index, ast_clear_flag, AST_FLAGS_ALL, ast_log(), ast_set_flag, LOG_WARNING, and s. Referenced by app_exec(), chanspy_exec(), conf_exec(), dial_exec_full(), mixmonitor_exec(), page_exec(), pbx_builtin_background(), pbx_builtin_resetcdr(), pbx_builtin_waitexten(), vm_exec(), and vm_execmain(). { char *s; int curarg; unsigned int argloc; char *arg; int res = 0; ast_clear_flag(flags, AST_FLAGS_ALL); if (!optstr) return 0; s = optstr; while (*s) { curarg = *s++ & 0x7f; ast_set_flag(flags, options[curarg].flag); argloc = options[curarg].arg_index; if (*s == '(') { /* Has argument */ arg = ++s; while (*s && (*s != ')')) s++; if (*s) { if (argloc) args[argloc - 1] = arg; *s++ = '\0'; } else { ast_log(LOG_WARNING, "Missing closing parenthesis for argument '%c' in string '%s'\n", curarg, arg); res = -1; } } else if (argloc) { args[argloc - 1] = NULL; } } return res; }

unsigned int ast_app_separate_args (  char *  buf, char  delim, char **  array, int  arraylen )

Separate a string into arguments in an array. Parameters: buf  The string to be parsed (this must be a writable copy, as it will be modified) delim  The character to be used to delimit arguments array  An array of 'char *' to be filled in with pointers to the found arguments arraylen  The number of elements in the array (i.e. the number of arguments you will accept) Note: if there are more arguments in the string than the array will hold, the last element of the array will contain the remaining arguments, not separated. The array will be completely zeroed by this function before it populates any entries. Returns: The number of arguments found, or zero if the function arguments are not valid. Definition at line 1108 of file app.c. Referenced by add_agent(), app_exec(), astman_get_variables(), builtin_function_cdr_read(), builtin_function_cdr_write(), builtin_function_checkmd5(), builtin_function_math(), chanspy_exec(), controlplayback_exec(), cut_internal(), dictate_exec(), function_db_exists(), function_db_read(), function_db_write(), pbx_builtin_background(), pbx_builtin_setvar(), pbx_builtin_waitexten(), read_exec(), vm_exec(), and vm_execmain(). { int argc; char *scan; int paren = 0; if (!buf || !array || !arraylen) return 0; memset(array, 0, arraylen * sizeof(*array)); scan = buf; for (argc = 0; *scan && (argc < arraylen - 1); argc++) { array[argc] = scan; for (; *scan; scan++) { if (*scan == '(') paren++; else if (*scan == ')') { if (paren) paren--; } else if ((*scan == delim) && !paren) { *scan++ = '\0'; break; } } } if (*scan) array[argc++] = scan; return argc; }

int ast_control_streamfile (  struct ast_channel *  chan, const char *  file, const char *  fwd, const char *  rev, const char *  stop, const char *  pause, const char *  restart, int  skipms )

Stream a file with fast forward, pause, reverse, restart. Definition at line 432 of file app.c. References ast_channel::_state, ast_answer(), ast_log(), ast_seekstream(), AST_STATE_UP, ast_stopstream(), ast_streamfile(), ast_tellstream(), ast_waitfordigit(), ast_waitstream_fr(), and LOG_DEBUG. Referenced by controlplayback_exec(), handle_controlstreamfile(), and wait_file(). { char *breaks = NULL; char *end = NULL; int blen = 2; int res; long pause_restart_point = 0; if (stop) blen += strlen(stop); if (pause) blen += strlen(pause); if (restart) blen += strlen(restart); if (blen > 2) { breaks = alloca(blen + 1); breaks[0] = '\0'; if (stop) strcat(breaks, stop); if (pause) strcat(breaks, pause); if (restart) strcat(breaks, restart); } if (chan->_state != AST_STATE_UP) res = ast_answer(chan); if (file) { if ((end = strchr(file,':'))) { if (!strcasecmp(end, ":end")) { *end = '\0'; end++; } } } for (;;) { ast_stopstream(chan); res = ast_streamfile(chan, file, chan->language); if (!res) { if (pause_restart_point) { ast_seekstream(chan->stream, pause_restart_point, SEEK_SET); pause_restart_point = 0; } else if (end) { ast_seekstream(chan->stream, 0, SEEK_END); end = NULL; }; res = ast_waitstream_fr(chan, breaks, fwd, rev, skipms); } if (res < 1) break; /* We go at next loop if we got the restart char */ if (restart && strchr(restart, res)) { ast_log(LOG_DEBUG, "we'll restart the stream here at next loop\n"); pause_restart_point = 0; continue; } if (pause && strchr(pause, res)) { pause_restart_point = ast_tellstream(chan->stream); for (;;) { ast_stopstream(chan); res = ast_waitfordigit(chan, 1000); if (!res) continue; else if (res == -1 || strchr(pause, res) || (stop && strchr(stop, res))) break; } if (res == *pause) { res = 0; continue; } } if (res == -1) break; /* if we get one of our stop chars, return it to the calling function */ if (stop && strchr(stop, res)) break; } ast_stopstream(chan); return res; }

int ast_dtmf_stream (  struct ast_channel *  chan, struct ast_channel *  peer, char *  digits, int  between )

Send DTMF to chan (optionally entertain peer) Definition at line 281 of file app.c. References ast_autoservice_start(), ast_autoservice_stop(), AST_FRAME_DTMF, ast_log(), ast_safe_sleep(), ast_waitfor(), ast_write(), and LOG_WARNING. Referenced by ast_bridge_call(), dial_exec_full(), misdn_send_digit(), senddtmf_exec(), testclient_exec(), and testserver_exec(). { char *ptr; int res = 0; struct ast_frame f; if (!between) between = 100; if (peer) res = ast_autoservice_start(peer); if (!res) { res = ast_waitfor(chan,100); if (res > -1) { for (ptr=digits; *ptr; ptr++) { if (*ptr == 'w') { res = ast_safe_sleep(chan, 500); if (res) break; continue; } memset(&f, 0, sizeof(f)); f.frametype = AST_FRAME_DTMF; f.subclass = *ptr; f.src = "ast_dtmf_stream"; if (strchr("0123456789*#abcdABCD",*ptr)==NULL) { ast_log(LOG_WARNING, "Illegal DTMF character '%c' in string. (0-9*#aAbBcCdD allowed)\n",*ptr); } else { res = ast_write(chan, &f); if (res) break; /* pause between digits */ res = ast_safe_sleep(chan,between); if (res) break; } } } if (peer) { /* Stop autoservice on the peer channel, but don't overwrite any error condition that has occurred previously while acting on the primary channel */ if (ast_autoservice_stop(peer) && !res) res = -1; } } return res; }

void ast_install_vm_functions (  int(*)(const char *mailbox, const char *folder)  has_voicemail_func, int(*)(const char *mailbox, int *newmsgs, int *oldmsgs)  messagecount_func )

Definition at line 236 of file app.c. References ast_has_voicemail_func, and ast_messagecount_func. Referenced by load_module(). { ast_has_voicemail_func = has_voicemail_func; ast_messagecount_func = messagecount_func; }

int ast_ivr_menu_run (  struct ast_channel *  c, struct ast_ivr_menu *  menu, void *  cbdata )

Runs an IVR menu. Returns: returns 0 on successful completion, -1 on hangup, or -2 on user error in menu Definition at line 1495 of file app.c. References ast_ivr_menu_run_internal(). Referenced by skel_exec(). { int res; res = ast_ivr_menu_run_internal(chan, menu, cbdata); /* Hide internal coding */ if (res > 0) res = 0; return res; }

static int ast_ivr_menu_run_internal (  struct ast_channel *  chan, struct ast_ivr_menu *  menu, void *  cbdata )  [static]

Definition at line 1415 of file app.c. References AST_DIGIT_ANY, ast_log(), AST_MAX_EXTENSION, exten, ivr_dispatch(), LOG_DEBUG, LOG_WARNING, maxretries, ast_ivr_option::option, option_exists(), ast_ivr_menu::options, read_newoption(), RES_EXIT, RES_REPEAT, RES_RESTART, RES_UPONE, and ast_ivr_menu::title. Referenced by ast_ivr_menu_run(), and ivr_dispatch(). { /* Execute an IVR menu structure */ int res=0; int pos = 0; int retries = 0; char exten[AST_MAX_EXTENSION] = "s"; if (option_exists(menu, "s") < 0) { strcpy(exten, "g"); if (option_exists(menu, "g") < 0) { ast_log(LOG_WARNING, "No 's' nor 'g' extension in menu '%s'!\n", menu->title); return -1; } } while(!res) { while(menu->options[pos].option) { if (!strcasecmp(menu->options[pos].option, exten)) { res = ivr_dispatch(chan, menu->options + pos, exten, cbdata); ast_log(LOG_DEBUG, "IVR Dispatch of '%s' (pos %d) yields %d\n", exten, pos, res); if (res < 0) break; else if (res & RES_UPONE) return 0; else if (res & RES_EXIT) return res; else if (res & RES_REPEAT) { int maxretries = res & 0xffff; if ((res & RES_RESTART) == RES_RESTART) { retries = 0; } else retries++; if (!maxretries) maxretries = 3; if ((maxretries > 0) && (retries >= maxretries)) { ast_log(LOG_DEBUG, "Max retries %d exceeded\n", maxretries); return -2; } else { if (option_exists(menu, "g") > -1) strcpy(exten, "g"); else if (option_exists(menu, "s") > -1) strcpy(exten, "s"); } pos=0; continue; } else if (res && strchr(AST_DIGIT_ANY, res)) { ast_log(LOG_DEBUG, "Got start of extension, %c\n", res); exten[1] = '\0'; exten[0] = res; if ((res = read_newoption(chan, menu, exten, sizeof(exten)))) break; if (option_exists(menu, exten) < 0) { if (option_exists(menu, "i")) { ast_log(LOG_DEBUG, "Invalid extension entered, going to 'i'!\n"); strcpy(exten, "i"); pos = 0; continue; } else { ast_log(LOG_DEBUG, "Aborting on invalid entry, with no 'i' option!\n"); res = -2; break; } } else { ast_log(LOG_DEBUG, "New existing extension: %s\n", exten); pos = 0; continue; } } } pos++; } ast_log(LOG_DEBUG, "Stopping option '%s', res is %d\n", exten, res); pos = 0; if (!strcasecmp(exten, "s")) strcpy(exten, "g"); else break; } return res; }

int ast_linear_stream (  struct ast_channel *  chan, const char *  filename, int  fd, int  allowoverride )

Stream a filename (or file descriptor) as a generator. Definition at line 401 of file app.c. References ast_activate_generator(), ast_config_AST_VAR_DIR, ast_log(), ast_strlen_zero(), linear_state::autoclose, LOG_WARNING, and malloc. { struct linear_state *lin; char tmpf[256]; int res = -1; int autoclose = 0; if (fd < 0) { if (ast_strlen_zero(filename)) return -1; autoclose = 1; if (filename[0] == '/') ast_copy_string(tmpf, filename, sizeof(tmpf)); else snprintf(tmpf, sizeof(tmpf), "%s/%s/%s", (char *)ast_config_AST_VAR_DIR, "sounds", filename); fd = open(tmpf, O_RDONLY); if (fd < 0){ ast_log(LOG_WARNING, "Unable to open file '%s': %s\n", tmpf, strerror(errno)); return -1; } } lin = malloc(sizeof(struct linear_state)); if (lin) { memset(lin, 0, sizeof(lin)); lin->fd = fd; lin->allowoverride = allowoverride; lin->autoclose = autoclose; res = ast_activate_generator(chan, &linearstream, lin); } return res; }

enum AST_LOCK_RESULT ast_lock_path (  const char *  path  )

Lock a filesystem path. Parameters: path  the path to be locked Returns: one of AST_LOCK_RESULT values Definition at line 1142 of file app.c. References AST_LOCK_FAILURE, AST_LOCK_PATH_NOT_FOUND, AST_LOCK_SUCCESS, AST_LOCK_TIMEOUT, ast_log(), LOG_DEBUG, LOG_ERROR, LOG_WARNING, and s. Referenced by vm_lock_path(). { char *s; char *fs; int res; int fd; time_t start; s = alloca(strlen(path) + 10); fs = alloca(strlen(path) + 20); if (!fs || !s) { ast_log(LOG_WARNING, "Out of memory!\n"); return AST_LOCK_FAILURE; } snprintf(fs, strlen(path) + 19, "%s/.lock-%08x", path, rand()); fd = open(fs, O_WRONLY | O_CREAT | O_EXCL, 0600); if (fd < 0) { ast_log(LOG_ERROR, "Unable to create lock file '%s': %s\n", path, strerror(errno)); return AST_LOCK_PATH_NOT_FOUND; } close(fd); snprintf(s, strlen(path) + 9, "%s/.lock", path); time(&start); while (((res = link(fs, s)) < 0) && (errno == EEXIST) && (time(NULL) - start < 5)) usleep(1); unlink(fs); if (res) { ast_log(LOG_WARNING, "Failed to lock path '%s': %s\n", path, strerror(errno)); return AST_LOCK_TIMEOUT; } else { ast_log(LOG_DEBUG, "Locked path '%s'\n", path); return AST_LOCK_SUCCESS; } }

int ast_play_and_prepend (  struct ast_channel *  chan, char *  playfile, char *  recordfile, int  maxtime_sec, char *  fmt, int *  duration, int  beep, int  silencethreshold, int  maxsilence_ms )

Record a message and prepend the message to the given record file after playing the optional playfile (or a beep), storing the duration in 'duration' and with a maximum permitted silence time in milliseconds of 'maxsilence' under 'silencethreshold' or use '-1' for either or both parameters for defaults. Definition at line 772 of file app.c. References ast_closestream(), ast_dsp_free(), ast_dsp_new(), ast_dsp_set_threshold(), ast_dsp_silence(), ast_filedelete(), ast_filerename(), AST_FORMAT_SLINEAR, AST_FRAME_DTMF, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_frfree(), ast_getformatname(), ast_log(), ast_play_and_wait(), ast_read(), ast_readfile(), ast_readframe(), ast_set_read_format(), ast_strdupa, ast_stream_rewind(), ast_streamfile(), ast_truncstream(), ast_verbose(), ast_waitfor(), ast_waitstream(), ast_writefile(), ast_writestream(), ast_frame::frametype, ast_channel::language, LOG_DEBUG, LOG_WARNING, MAX_OTHER_FORMATS, ast_channel::name, option_verbose, ast_channel::readformat, strsep(), ast_frame::subclass, ast_dsp::totalsilence, and VERBOSE_PREFIX_3. Referenced by vm_forwardoptions(). { int d = 0; char *fmts; char comment[256]; int x, fmtcnt=1, res=-1,outmsg=0; struct ast_frame *f; struct ast_filestream *others[MAX_OTHER_FORMATS]; struct ast_filestream *realfiles[MAX_OTHER_FORMATS]; char *sfmt[MAX_OTHER_FORMATS]; char *stringp=NULL; time_t start, end; struct ast_dsp *sildet; /* silence detector dsp */ int totalsilence = 0; int dspsilence = 0; int rfmt=0; char prependfile[80]; if (silencethreshold < 0) silencethreshold = global_silence_threshold; if (maxsilence < 0) maxsilence = global_maxsilence; /* barf if no pointer passed to store duration in */ if (duration == NULL) { ast_log(LOG_WARNING, "Error play_and_prepend called without duration pointer\n"); return -1; } ast_log(LOG_DEBUG,"play_and_prepend: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt); snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name); if (playfile || beep) { if (!beep) d = ast_play_and_wait(chan, playfile); if (d > -1) d = ast_streamfile(chan, "beep",chan->language); if (!d) d = ast_waitstream(chan,""); if (d < 0) return -1; } ast_copy_string(prependfile, recordfile, sizeof(prependfile)); strncat(prependfile, "-prepend", sizeof(prependfile) - strlen(prependfile) - 1); fmts = ast_strdupa(fmt); stringp=fmts; strsep(&stringp, "|"); ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts); sfmt[0] = ast_strdupa(fmts); while((fmt = strsep(&stringp, "|"))) { if (fmtcnt > MAX_OTHER_FORMATS - 1) { ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app.c\n"); break; } sfmt[fmtcnt++] = ast_strdupa(fmt); } time(&start); end=start; /* pre-initialize end to be same as start in case we never get into loop */ for (x=0;x<fmtcnt;x++) { others[x] = ast_writefile(prependfile, sfmt[x], comment, O_TRUNC, 0, 0700); ast_verbose( VERBOSE_PREFIX_3 "x=%d, open writing: %s format: %s, %p\n", x, prependfile, sfmt[x], others[x]); if (!others[x]) { break; } } sildet = ast_dsp_new(); /* Create the silence detector */ if (!sildet) { ast_log(LOG_WARNING, "Unable to create silence detector :(\n"); return -1; } ast_dsp_set_threshold(sildet, silencethreshold); if (maxsilence > 0) { rfmt = chan->readformat; res = ast_set_read_format(chan, AST_FORMAT_SLINEAR); if (res < 0) { ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n"); ast_dsp_free(sildet); return -1; } } if (x == fmtcnt) { /* Loop forever, writing the packets we read to the writer(s), until we read a # or get a hangup */ f = NULL; for(;;) { res = ast_waitfor(chan, 2000); if (!res) { ast_log(LOG_DEBUG, "One waitfor failed, trying another\n"); /* Try one more time in case of masq */ res = ast_waitfor(chan, 2000); if (!res) { ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name); res = -1; } } if (res < 0) { f = NULL; break; } f = ast_read(chan); if (!f) break; if (f->frametype == AST_FRAME_VOICE) { /* write each format */ for (x=0;x<fmtcnt;x++) { if (!others[x]) break; res = ast_writestream(others[x], f); } /* Silence Detection */ if (maxsilence > 0) { dspsilence = 0; ast_dsp_silence(sildet, f, &dspsilence); if (dspsilence) totalsilence = dspsilence; else totalsilence = 0; if (totalsilence > maxsilence) { /* Ended happily with silence */ if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000); ast_frfree(f); res = 'S'; outmsg=2; break; } } /* Exit on any error */ if (res) { ast_log(LOG_WARNING, "Error writing frame\n"); ast_frfree(f); break; } } else if (f->frametype == AST_FRAME_VIDEO) { /* Write only once */ ast_writestream(others[0], f); } else if (f->frametype == AST_FRAME_DTMF) { /* stop recording with any digit */ if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass); res = 't'; outmsg = 2; ast_frfree(f); break; } if (maxtime) { time(&end); if (maxtime < (end - start)) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Took too long, cutting it short...\n"); res = 't'; outmsg=2; ast_frfree(f); break; } } ast_frfree(f); } if (end == start) time(&end); if (!f) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "User hung up\n"); res = -1; outmsg=1; #if 0 /* delete all the prepend files */ for (x=0;x<fmtcnt;x++) { if (!others[x]) break; ast_closestream(others[x]); ast_filedelete(prependfile, sfmt[x]); } #endif } } else { ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", prependfile, sfmt[x]); } ast_dsp_free(sildet); *duration = end - start; #if 0 if (outmsg > 1) { #else if (outmsg) { #endif struct ast_frame *fr; for (x=0;x<fmtcnt;x++) { snprintf(comment, sizeof(comment), "Opening the real file %s.%s\n", recordfile, sfmt[x]); realfiles[x] = ast_readfile(recordfile, sfmt[x], comment, O_RDONLY, 0, 0); if (!others[x] || !realfiles[x]) break; if (totalsilence) ast_stream_rewind(others[x], totalsilence-200); else ast_stream_rewind(others[x], 200); ast_truncstream(others[x]); /* add the original file too */ while ((fr = ast_readframe(realfiles[x]))) { ast_writestream(others[x],fr); } ast_closestream(others[x]); ast_closestream(realfiles[x]); ast_filerename(prependfile, recordfile, sfmt[x]); #if 0 ast_verbose("Recording Format: sfmts=%s, prependfile %s, recordfile %s\n", sfmt[x],prependfile,recordfile); #endif ast_filedelete(prependfile, sfmt[x]); } } if (rfmt) { if (ast_set_read_format(chan, rfmt)) { ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name); } } if (outmsg) { if (outmsg > 1) { /* Let them know it worked */ ast_streamfile(chan, "auth-thankyou", chan->language); ast_waitstream(chan, ""); } } return res; }

int ast_play_and_record (  struct ast_channel *  chan, const char *  playfile, const char *  recordfile, int  maxtime_sec, const char *  fmt, int *  duration, int  silencethreshold, int  maxsilence_ms, const char *  path )

Record a file for a max amount of time (in seconds), in a given list of formats separated by '|', outputting the duration of the recording, and with a maximum permitted silence time in milliseconds of 'maxsilence' under 'silencethreshold' or use '-1' for either or both parameters for defaults. calls ast_unlock_path() on 'path' if passed Definition at line 767 of file app.c. References ast_play_and_record_full(). Referenced by ast_record_review(), and dial_exec_full(). { return ast_play_and_record_full(chan, playfile, recordfile, maxtime, fmt, duration, silencethreshold, maxsilence, path, default_acceptdtmf, default_canceldtmf); }

int ast_play_and_record_full (  struct ast_channel *  chan, const char *  playfile, const char *  recordfile, int  maxtime, const char *  fmt, int *  duration, int  silencethreshold, int  maxsilence, const char *  path, const char *  acceptdtmf, const char *  canceldtmf )

Definition at line 540 of file app.c. References ast_channel_start_silence_generator(), ast_channel_stop_silence_generator(), ast_closestream(), AST_CONTROL_VIDUPDATE, ast_dsp_free(), ast_dsp_new(), ast_dsp_set_threshold(), ast_dsp_silence(), AST_FORMAT_SLINEAR, AST_FRAME_DTMF, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_frfree(), ast_getformatname(), ast_indicate(), ast_log(), ast_play_and_wait(), ast_read(), ast_set_read_format(), ast_strdupa, ast_stream_rewind(), ast_streamfile(), ast_truncstream(), ast_unlock_path(), ast_verbose(), ast_waitfor(), ast_waitstream(), ast_writefile(), ast_writestream(), ast_frame::frametype, LOG_DEBUG, LOG_WARNING, MAX_OTHER_FORMATS, ast_channel::name, option_transmit_silence_during_record, option_verbose, ast_channel::readformat, strsep(), ast_frame::subclass, ast_dsp::totalsilence, and VERBOSE_PREFIX_3. Referenced by ast_play_and_record(), and play_record_review(). { int d; char *fmts; char comment[256]; int x, fmtcnt=1, res=-1,outmsg=0; struct ast_frame *f; struct ast_filestream *others[MAX_OTHER_FORMATS]; char *sfmt[MAX_OTHER_FORMATS]; char *stringp=NULL; time_t start, end; struct ast_dsp *sildet=NULL; /* silence detector dsp */ int totalsilence = 0; int dspsilence = 0; int rfmt=0; struct ast_silence_generator *silgen = NULL; if (silencethreshold < 0) silencethreshold = global_silence_threshold; if (maxsilence < 0) maxsilence = global_maxsilence; /* barf if no pointer passed to store duration in */ if (duration == NULL) { ast_log(LOG_WARNING, "Error play_and_record called without duration pointer\n"); return -1; } ast_log(LOG_DEBUG,"play_and_record: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt); snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name); if (playfile) { d = ast_play_and_wait(chan, playfile); if (d > -1) d = ast_streamfile(chan, "beep",chan->language); if (!d) d = ast_waitstream(chan,""); if (d < 0) return -1; } fmts = ast_strdupa(fmt); stringp=fmts; strsep(&stringp, "|"); ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts); sfmt[0] = ast_strdupa(fmts); while((fmt = strsep(&stringp, "|"))) { if (fmtcnt > MAX_OTHER_FORMATS - 1) { ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app.c\n"); break; } sfmt[fmtcnt++] = ast_strdupa(fmt); } time(&start); end=start; /* pre-initialize end to be same as start in case we never get into loop */ for (x=0;x<fmtcnt;x++) { others[x] = ast_writefile(recordfile, sfmt[x], comment, O_TRUNC, 0, 0700); ast_verbose( VERBOSE_PREFIX_3 "x=%d, open writing: %s format: %s, %p\n", x, recordfile, sfmt[x], others[x]); if (!others[x]) { break; } } if (path) ast_unlock_path(path); if (maxsilence > 0) { sildet = ast_dsp_new(); /* Create the silence detector */ if (!sildet) { ast_log(LOG_WARNING, "Unable to create silence detector :(\n"); return -1; } ast_dsp_set_threshold(sildet, silencethreshold); rfmt = chan->readformat; res = ast_set_read_format(chan, AST_FORMAT_SLINEAR); if (res < 0) { ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n"); ast_dsp_free(sildet); return -1; } } /* Request a video update */ ast_indicate(chan, AST_CONTROL_VIDUPDATE); if (option_transmit_silence_during_record) silgen = ast_channel_start_silence_generator(chan); if (x == fmtcnt) { /* Loop forever, writing the packets we read to the writer(s), until we read a # or get a hangup */ f = NULL; for(;;) { res = ast_waitfor(chan, 2000); if (!res) { ast_log(LOG_DEBUG, "One waitfor failed, trying another\n"); /* Try one more time in case of masq */ res = ast_waitfor(chan, 2000); if (!res) { ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name); res = -1; } } if (res < 0) { f = NULL; break; } f = ast_read(chan); if (!f) break; if (f->frametype == AST_FRAME_VOICE) { /* write each format */ for (x=0;x<fmtcnt;x++) { res = ast_writestream(others[x], f); } /* Silence Detection */ if (maxsilence > 0) { dspsilence = 0; ast_dsp_silence(sildet, f, &dspsilence); if (dspsilence) totalsilence = dspsilence; else totalsilence = 0; if (totalsilence > maxsilence) { /* Ended happily with silence */ if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000); ast_frfree(f); res = 'S'; outmsg=2; break; } } /* Exit on any error */ if (res) { ast_log(LOG_WARNING, "Error writing frame\n"); ast_frfree(f); break; } } else if (f->frametype == AST_FRAME_VIDEO) { /* Write only once */ ast_writestream(others[0], f); } else if (f->frametype == AST_FRAME_DTMF) { if (strchr(acceptdtmf, f->subclass)) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass); res = f->subclass; outmsg = 2; ast_frfree(f); break; } if (strchr(canceldtmf, f->subclass)) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "User cancelled message by pressing %c\n", f->subclass); res = f->subclass; outmsg = 0; ast_frfree(f); break; } } if (maxtime) { time(&end); if (maxtime < (end - start)) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Took too long, cutting it short...\n"); outmsg = 2; res = 't'; ast_frfree(f); break; } } ast_frfree(f); } if (end == start) time(&end); if (!f) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "User hung up\n"); res = -1; outmsg=1; } } else { ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", recordfile, sfmt[x]); } if (silgen) ast_channel_stop_silence_generator(chan, silgen); *duration = end - start; for (x=0;x<fmtcnt;x++) { if (!others[x]) break; if (res > 0) { if (totalsilence) ast_stream_rewind(others[x], totalsilence-200); else ast_stream_rewind(others[x], 200); } ast_truncstream(others[x]); ast_closestream(others[x]); } if (rfmt) { if (ast_set_read_format(chan, rfmt)) { ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name); } } if (outmsg > 1) { /* Let them know recording is stopped */ if(!ast_streamfile(chan, "auth-thankyou", chan->language)) ast_waitstream(chan, ""); } if (sildet) ast_dsp_free(sildet); return res; }

int ast_play_and_wait (  struct ast_channel *  chan, const char *  fn )

Play a stream and wait for a digit, returning the digit that was pressed Definition at line 526 of file app.c. References AST_DIGIT_ANY, ast_stopstream(), ast_streamfile(), ast_waitstream(), and ast_channel::language. Referenced by advanced_options(), ast_play_and_prepend(), ast_play_and_record_full(), ast_record_review(), dial_exec_full(), dialout(), forward_message(), get_folder(), get_folder2(), leave_voicemail(), play_message_category(), play_record_review(), vm_authenticate(), vm_browse_messages_en(), vm_browse_messages_es(), vm_browse_messages_gr(), vm_browse_messages_it(), vm_browse_messages_pt(), vm_execmain(), vm_forwardoptions(), vm_instructions(), vm_intro_cz(), vm_intro_de(), vm_intro_en(), vm_intro_es(), vm_intro_fr(), vm_intro_gr(), vm_intro_it(), vm_intro_nl(), vm_intro_no(), vm_intro_pt(), vm_intro_pt_BR(), vm_intro_se(), vm_newuser(), vm_options(), vm_play_folder_name(), vm_play_folder_name_gr(), vm_tempgreeting(), and vmauthenticate(). { int d; d = ast_streamfile(chan, fn, chan->language); if (d) return d; d = ast_waitstream(chan, AST_DIGIT_ANY); ast_stopstream(chan); return d; }

char* ast_read_textfile (  const char *  file  )

Read a file into asterisk Definition at line 1505 of file app.c. References ast_log(), free, LOG_WARNING, and malloc. Referenced by readfile_exec(). { int fd; char *output=NULL; struct stat filesize; int count=0; int res; if(stat(filename,&filesize)== -1){ ast_log(LOG_WARNING,"Error can't stat %s\n", filename); return NULL; } count=filesize.st_size + 1; fd = open(filename, O_RDONLY); if (fd < 0) { ast_log(LOG_WARNING, "Cannot open file '%s' for reading: %s\n", filename, strerror(errno)); return NULL; } output=(char *)malloc(count); if (output) { res = read(fd, output, count - 1); if (res == count - 1) { output[res] = '\0'; } else { ast_log(LOG_WARNING, "Short read of %s (%d of %d): %s\n", filename, res, count - 1, strerror(errno)); free(output); output = NULL; } } else ast_log(LOG_WARNING, "Out of memory!\n"); close(fd); return output; }

int ast_record_review (  struct ast_channel *  chan, const char *  playfile, const char *  recordfile, int  maxtime, const char *  fmt, int *  duration, const char *  path )

Allow to record message and have a review option Definition at line 1203 of file app.c. References AST_DIGIT_ANY, ast_log(), ast_play_and_record(), ast_play_and_wait(), ast_streamfile(), ast_verbose(), ast_waitfordigit(), ast_waitstream(), ast_channel::language, LOG_WARNING, and VERBOSE_PREFIX_3. Referenced by conf_run(). { int silencethreshold = 128; int maxsilence=0; int res = 0; int cmd = 0; int max_attempts = 3; int attempts = 0; int recorded = 0; int message_exists = 0; /* Note that urgent and private are for flagging messages as such in the future */ /* barf if no pointer passed to store duration in */ if (duration == NULL) { ast_log(LOG_WARNING, "Error ast_record_review called without duration pointer\n"); return -1; } cmd = '3'; /* Want to start by recording */ while ((cmd >= 0) && (cmd != 't')) { switch (cmd) { case '1': if (!message_exists) { /* In this case, 1 is to record a message */ cmd = '3'; break; } else { ast_streamfile(chan, "vm-msgsaved", chan->language); ast_waitstream(chan, ""); cmd = 't'; return res; } case '2': /* Review */ ast_verbose(VERBOSE_PREFIX_3 "Reviewing the recording\n"); ast_streamfile(chan, recordfile, chan->language); cmd = ast_waitstream(chan, AST_DIGIT_ANY); break; case '3': message_exists = 0; /* Record */ if (recorded == 1) ast_verbose(VERBOSE_PREFIX_3 "Re-recording\n"); else ast_verbose(VERBOSE_PREFIX_3 "Recording\n"); recorded = 1; cmd = ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, silencethreshold, maxsilence, path); if (cmd == -1) { /* User has hung up, no options to give */ return cmd; } if (cmd == '0') { break; } else if (cmd == '*') { break; } else { /* If all is well, a message exists */ message_exists = 1; cmd = 0; } break; case '4': case '5': case '6': case '7': case '8': case '9': case '*': case '#': cmd = ast_play_and_wait(chan, "vm-sorry"); break; default: if (message_exists) { cmd = ast_play_and_wait(chan, "vm-review"); } else { cmd = ast_play_and_wait(chan, "vm-torerecord"); if (!cmd) cmd = ast_waitfordigit(chan, 600); } if (!cmd) cmd = ast_waitfordigit(chan, 6000); if (!cmd) { attempts++; } if (attempts > max_attempts) { cmd = 't'; } } } if (cmd == 't') cmd = 0; return cmd; }

void ast_uninstall_vm_functions (  void   )

Definition at line 243 of file app.c. References ast_has_voicemail_func, and ast_messagecount_func. Referenced by unload_module(). { ast_has_voicemail_func = NULL; ast_messagecount_func = NULL; }

int ast_unlock_path (  const char *  path  )

Unlock a path Definition at line 1182 of file app.c. References ast_log(), LOG_DEBUG, LOG_ERROR, LOG_WARNING, and s. Referenced by ast_play_and_record_full(), close_mailbox(), copy_message(), count_messages(), last_message_index(), leave_voicemail(), resequence_mailbox(), and save_to_folder(). { char *s; int res; s = alloca(strlen(path) + 10); if (!s) { ast_log(LOG_WARNING, "Out of memory!\n"); return -1; } snprintf(s, strlen(path) + 9, "%s/%s", path, ".lock"); if ((res = unlink(s))) ast_log(LOG_ERROR, "Could not unlock path '%s': %s\n", path, strerror(errno)); else ast_log(LOG_DEBUG, "Unlocked path '%s'\n", path); return res; }

static int ivr_dispatch (  struct ast_channel *  chan, struct ast_ivr_option *  option, char *  exten, void *  cbdata )  [static]

Definition at line 1307 of file app.c. References ast_ivr_option::action, ast_ivr_option::adata, AST_ACTION_BACKGROUND, AST_ACTION_BACKLIST, AST_ACTION_CALLBACK, AST_ACTION_EXIT, AST_ACTION_MENU, AST_ACTION_NOOP, AST_ACTION_PLAYBACK, AST_ACTION_PLAYLIST, AST_ACTION_REPEAT, AST_ACTION_RESTART, AST_ACTION_TRANSFER, AST_ACTION_UPONE, AST_ACTION_WAITOPTION, AST_DIGIT_ANY, ast_ivr_menu_run_internal(), ast_log(), ast_parseable_goto(), ast_stopstream(), ast_strdupa, ast_streamfile(), ast_waitfordigit(), ast_waitstream(), ast_channel::language, LOG_NOTICE, n, ast_channel::pbx, RES_EXIT, RES_REPEAT, RES_RESTART, RES_UPONE, ast_pbx::rtimeout, and strsep(). Referenced by ast_ivr_menu_run_internal(). { int res; int (*ivr_func)(struct ast_channel *, void *); char *c; char *n; switch(option->action) { case AST_ACTION_UPONE: return RES_UPONE; case AST_ACTION_EXIT: return RES_EXIT | (((unsigned long)(option->adata)) & 0xffff); case AST_ACTION_REPEAT: return RES_REPEAT | (((unsigned long)(option->adata)) & 0xffff); case AST_ACTION_RESTART: return RES_RESTART ; case AST_ACTION_NOOP: return 0; case AST_ACTION_BACKGROUND: res = ast_streamfile(chan, (char *)option->adata, chan->language); if (!res) { res = ast_waitstream(chan, AST_DIGIT_ANY); } else { ast_log(LOG_NOTICE, "Unable to find file '%s'!\n", (char *)option->adata); res = 0; } return res; case AST_ACTION_PLAYBACK: res = ast_streamfile(chan, (char *)option->adata, chan->language); if (!res) { res = ast_waitstream(chan, ""); } else { ast_log(LOG_NOTICE, "Unable to find file '%s'!\n", (char *)option->adata); res = 0; } return res; case AST_ACTION_MENU: res = ast_ivr_menu_run_internal(chan, (struct ast_ivr_menu *)option->adata, cbdata); /* Do not pass entry errors back up, treaat ast though ti was an "UPONE" */ if (res == -2) res = 0; return res; case AST_ACTION_WAITOPTION: res = ast_waitfordigit(chan, 1000 * (chan->pbx ? chan->pbx->rtimeout : 10)); if (!res) return 't'; return res; case AST_ACTION_CALLBACK: ivr_func = option->adata; res = ivr_func(chan, cbdata); return res; case AST_ACTION_TRANSFER: res = ast_parseable_goto(chan, option->adata); return 0; case AST_ACTION_PLAYLIST: case AST_ACTION_BACKLIST: res = 0; c = ast_strdupa(option->adata); if (c) { while((n = strsep(&c, ";"))) if ((res = ast_streamfile(chan, n, chan->language)) || (res = ast_waitstream(chan, (option->action == AST_ACTION_BACKLIST) ? AST_DIGIT_ANY : ""))) break; ast_stopstream(chan); } return res; default: ast_log(LOG_NOTICE, "Unknown dispatch function %d, ignoring!\n", option->action); return 0; }; return -1; }

static void* linear_alloc (  struct ast_channel *  chan, void *  params )  [static]

Definition at line 374 of file app.c. References linear_state::allowoverride, ast_clear_flag, AST_FLAG_WRITE_INT, AST_FORMAT_SLINEAR, ast_log(), ast_set_flag, ast_set_write_format(), free, LOG_WARNING, and linear_state::origwfmt. { struct linear_state *ls; /* In this case, params is already malloc'd */ if (params) { ls = params; if (ls->allowoverride) ast_set_flag(chan, AST_FLAG_WRITE_INT); else ast_clear_flag(chan, AST_FLAG_WRITE_INT); ls->origwfmt = chan->writeformat; if (ast_set_write_format(chan, AST_FORMAT_SLINEAR)) { ast_log(LOG_WARNING, "Unable to set '%s' to linear format (write)\n", chan->name); free(ls); ls = params = NULL; } } return params; }

static int linear_generator (  struct ast_channel *  chan, void *  data, int  len, int  samples )  [static]

Definition at line 347 of file app.c. References AST_FORMAT_SLINEAR, AST_FRAME_VOICE, AST_FRIENDLY_OFFSET, ast_log(), ast_write(), linear_state::fd, and LOG_WARNING. { struct ast_frame f; short buf[2048 + AST_FRIENDLY_OFFSET / 2]; struct linear_state *ls = data; int res; len = samples * 2; if (len > sizeof(buf) - AST_FRIENDLY_OFFSET) { ast_log(LOG_WARNING, "Can't generate %d bytes of data!\n" ,len); len = sizeof(buf) - AST_FRIENDLY_OFFSET; } memset(&f, 0, sizeof(f)); res = read(ls->fd, buf + AST_FRIENDLY_OFFSET/2, len); if (res > 0) { f.frametype = AST_FRAME_VOICE; f.subclass = AST_FORMAT_SLINEAR; f.data = buf + AST_FRIENDLY_OFFSET/2; f.datalen = res; f.samples = res / 2; f.offset = AST_FRIENDLY_OFFSET; ast_write(chan, &f); if (res == len) return 0; } return -1; }

static void linear_release (  struct ast_channel *  chan, void *  params )  [static]

Definition at line 336 of file app.c. References ast_log(), ast_set_write_format(), linear_state::autoclose, linear_state::fd, free, LOG_WARNING, and linear_state::origwfmt. { struct linear_state *ls = params; if (ls->origwfmt && ast_set_write_format(chan, ls->origwfmt)) { ast_log(LOG_WARNING, "Unable to restore channel '%s' to format '%d'\n", chan->name, ls->origwfmt); } if (ls->autoclose) close(ls->fd); free(params); }

static int option_exists (  struct ast_ivr_menu *  menu, char *  option )  [static]

Definition at line 1379 of file app.c. References ast_ivr_option::option, and ast_ivr_menu::options. Referenced by ast_ivr_menu_run_internal(). { int x; for (x=0;menu->options[x].option;x++) if (!strcasecmp(menu->options[x].option, option)) return x; return -1; }

static int option_matchmore (  struct ast_ivr_menu *  menu, char *  option )  [static]

Definition at line 1388 of file app.c. Referenced by read_newoption(). { int x; for (x=0;menu->options[x].option;x++) if ((!strncasecmp(menu->options[x].option, option, strlen(option))) && (menu->options[x].option[strlen(option)])) return x; return -1; }

static int read_newoption (  struct ast_channel *  chan, struct ast_ivr_menu *  menu, char *  exten, int  maxexten )  [static]

Definition at line 1398 of file app.c. References ast_waitfordigit(), and option_matchmore(). Referenced by ast_ivr_menu_run_internal(). { int res=0; int ms; while(option_matchmore(menu, exten)) { ms = chan->pbx ? chan->pbx->dtimeout : 5000; if (strlen(exten) >= maxexten - 1) break; res = ast_waitfordigit(chan, ms); if (res < 1) break; exten[strlen(exten) + 1] = '\0'; exten[strlen(exten)] = res; } return res > 0 ? 0 : res; }

---

Variable Documentation

int(* ast_has_voicemail_func)(const char *mailbox, const char *folder) = NULL [static]

Definition at line 233 of file app.c. Referenced by ast_app_has_voicemail(), ast_install_vm_functions(), and ast_uninstall_vm_functions().

int(* ast_messagecount_func)(const char *mailbox, int *newmsgs, int *oldmsgs) = NULL [static]

Definition at line 234 of file app.c. Referenced by ast_app_messagecount(), ast_install_vm_functions(), and ast_uninstall_vm_functions().

char default_acceptdtmf[] = "#" [static]

Definition at line 764 of file app.c.

char default_canceldtmf[] = "0" [static]

Definition at line 765 of file app.c.

int global_maxsilence = 0 [static]

Definition at line 538 of file app.c.

int global_silence_threshold = 128 [static]

Definition at line 537 of file app.c.

struct ast_generator linearstream [static]

Definition at line 394 of file app.c.

---