pbx.c File Reference

#include <asterisk/lock.h>
#include <asterisk/cli.h>
#include <asterisk/pbx.h>
#include <asterisk/channel.h>
#include <asterisk/options.h>
#include <asterisk/logger.h>
#include <asterisk/file.h>
#include <asterisk/callerid.h>
#include <asterisk/cdr.h>
#include <asterisk/config.h>
#include <asterisk/term.h>
#include <asterisk/manager.h>
#include <asterisk/ast_expr.h>
#include <asterisk/channel_pvt.h>
#include <asterisk/linkedlists.h>
#include <asterisk/say.h>
#include <asterisk/utils.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <setjmp.h>
#include <ctype.h>
#include <errno.h>
#include <time.h>
#include <sys/time.h>
#include "asterisk.h"

Go to the source code of this file.

Defines
#define	EXT_DATA_SIZE   8192
#define	AST_PBX_MAX_STACK   128
#define	HELPER_EXISTS   0
#define	HELPER_SPAWN   1
#define	HELPER_EXEC   2
#define	HELPER_CANMATCH   3
#define	HELPER_MATCHMORE   4
#define	EXTENSION_MATCH_CORE(data, pattern, match)
#define	STATUS_NO_CONTEXT   1
#define	STATUS_NO_EXTENSION   2
#define	STATUS_NO_PRIORITY   3
#define	STATUS_SUCCESS   4
#define	FIND_NEXT
#define	LOG
Functions
int	pbx_builtin_setvar (struct ast_channel *, void *)
void	pbx_builtin_setvar_helper (struct ast_channel *chan, char *name, char *value)
char *	pbx_builtin_getvar_helper (struct ast_channel *chan, char *name)
	AST_MUTEX_DEFINE_STATIC (applock)
	AST_MUTEX_DEFINE_STATIC (conlock)
	AST_MUTEX_DEFINE_STATIC (switchlock)
	AST_MUTEX_DEFINE_STATIC (hintlock)
int	pbx_exec (struct ast_channel *c, struct ast_app *app, void *data, int newstack)
	executes an application
ast_app *	pbx_findapp (char *app)
	Look up an application.
int	ast_extension_match (char *pattern, char *data)
	Determine if a given extension matches a given pattern (in NXX format).
ast_context *	ast_context_find (char *name)
	Find a context.
void	pbx_substitute_variables_helper (struct ast_channel *c, const char *cp1, char *cp2, int count)
int	ast_extension_state (struct ast_channel *c, char *context, char *exten)
	Uses hint and devicestate callback to get the state of an extension.
int	ast_device_state_changed (const char *fmt,...)
int	ast_extension_state_add (char *context, char *exten, ast_state_cb_type callback, void *data)
	Registers a state change callback.
int	ast_extension_state_del (int id, ast_state_cb_type callback)
	Deletes a registered state change callback by ID.
int	ast_get_hint (char *hint, int hintsize, struct ast_channel *c, char *context, char *exten)
	If an extension exists, return non-zero.
int	ast_exists_extension (struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
	If an extension exists, return non-zero.
int	ast_canmatch_extension (struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
	Looks for a valid matching extension.
int	ast_matchmore_extension (struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
	Looks to see if adding anything to this extension might match something. (exists ^ canmatch).
int	ast_spawn_extension (struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
	Launch a new extension (i.e. new stack).
int	ast_pbx_run (struct ast_channel *c)
	Execute the PBX in the current thread.
int	ast_pbx_start (struct ast_channel *c)
	Create a new thread and start the PBX (or whatever).
int	ast_context_remove_include (char *context, char *include, char *registrar)
	Removes an include.
int	ast_context_remove_include2 (struct ast_context *con, char *include, char *registrar)
	Removes an include by an ast_context structure.
int	ast_context_remove_switch (char *context, char *sw, char *data, char *registrar)
	Remove a switch.
int	ast_context_remove_switch2 (struct ast_context *con, char *sw, char *data, char *registrar)
int	ast_context_remove_extension (char *context, char *extension, int priority, char *registrar)
	Simply remove extension from context.
int	ast_context_remove_extension2 (struct ast_context *con, char *extension, int priority, char *registrar)
int	ast_register_application (char *app, int(*execute)(struct ast_channel *, void *), char *synopsis, char *description)
	Add an application. The function 'execute' should return non-zero if the line needs to be hung up.
int	ast_register_switch (struct ast_switch *sw)
	Register an alternative switch.
void	ast_unregister_switch (struct ast_switch *sw)
	Unregister an alternative switch.
int	ast_unregister_application (char *app)
	Remove an application.
ast_context *	ast_context_create (struct ast_context **extcontexts, char *name, char *registrar)
	Register a new context.
void	__ast_context_destroy (struct ast_context *con, char *registrar)
void	ast_merge_contexts_and_delete (struct ast_context **extcontexts, char *registrar)
	Merge the temporary contexts into a global contexts list and delete from the global list the ones that are being added.
int	ast_context_add_include (char *context, char *include, char *registrar)
	Add an include.
int	ast_context_add_include2 (struct ast_context *con, char *value, char *registrar)
	Add an include.
int	ast_context_add_switch (char *context, char *sw, char *data, char *registrar)
	Add a switch.
int	ast_context_add_switch2 (struct ast_context *con, char *value, char *data, char *registrar)
	Adds a switch (first param is a ast_context).
int	ast_context_remove_ignorepat (char *context, char *ignorepat, char *registrar)
int	ast_context_remove_ignorepat2 (struct ast_context *con, char *ignorepat, char *registrar)
int	ast_context_add_ignorepat (char *con, char *value, char *registrar)
	Add an ignorepat.
int	ast_context_add_ignorepat2 (struct ast_context *con, char *value, char *registrar)
int	ast_ignore_pattern (char *context, char *pattern)
	Checks to see if a number should be ignored.
int	ast_add_extension (char *context, int replace, char *extension, int priority, char *callerid, char *application, void *data, void(*datad)(void *), char *registrar)
int	ast_async_goto (struct ast_channel *chan, char *context, char *exten, int priority)
int	ast_async_goto_by_name (char *channame, char *context, char *exten, int priority)
int	ast_add_extension2 (struct ast_context *con, int replace, char *extension, int priority, char *callerid, char *application, void *data, void(*datad)(void *), char *registrar)
	Add an extension to an extension context, this time with an ast_context *. CallerID is a pattern to match on callerid, or NULL to not care about callerid.
int	ast_pbx_outgoing_exten (char *type, int format, void *data, int timeout, char *context, char *exten, int priority, int *reason, int sync, int callingpres, char *callerid, char *variable, char *account, char *uniqueid)
void *	ast_pbx_run_app (void *data)
int	ast_pbx_outgoing_app (char *type, int format, void *data, int timeout, char *app, char *appdata, int *reason, int sync, char *callerid, char *variable, char *account, char *uniqueid)
void	ast_context_destroy (struct ast_context *con, char *registrar)
	Destroy a context (matches the specified context (or ANY context if NULL).
void	pbx_builtin_clear_globals (void)
int	load_pbx (void)
int	ast_lock_contexts ()
	Locks the contexts.
int	ast_unlock_contexts ()
	Unlocks contexts.
int	ast_lock_context (struct ast_context *con)
	Locks a given context.
int	ast_unlock_context (struct ast_context *con)
	Unlocks the given context.
char *	ast_get_context_name (struct ast_context *con)
char *	ast_get_extension_name (struct ast_exten *exten)
char *	ast_get_include_name (struct ast_include *inc)
char *	ast_get_ignorepat_name (struct ast_ignorepat *ip)
int	ast_get_extension_priority (struct ast_exten *exten)
char *	ast_get_context_registrar (struct ast_context *c)
char *	ast_get_extension_registrar (struct ast_exten *e)
char *	ast_get_include_registrar (struct ast_include *i)
char *	ast_get_ignorepat_registrar (struct ast_ignorepat *ip)
int	ast_get_extension_matchcid (struct ast_exten *e)
char *	ast_get_extension_cidmatch (struct ast_exten *e)
char *	ast_get_extension_app (struct ast_exten *e)
void *	ast_get_extension_app_data (struct ast_exten *e)
char *	ast_get_switch_name (struct ast_sw *sw)
char *	ast_get_switch_data (struct ast_sw *sw)
char *	ast_get_switch_registrar (struct ast_sw *sw)
ast_context *	ast_walk_contexts (struct ast_context *con)
ast_exten *	ast_walk_context_extensions (struct ast_context *con, struct ast_exten *exten)
ast_sw *	ast_walk_context_switches (struct ast_context *con, struct ast_sw *sw)
ast_exten *	ast_walk_extension_priorities (struct ast_exten *exten, struct ast_exten *priority)
ast_include *	ast_walk_context_includes (struct ast_context *con, struct ast_include *inc)
ast_ignorepat *	ast_walk_context_ignorepats (struct ast_context *con, struct ast_ignorepat *ip)
int	ast_context_verify_includes (struct ast_context *con)
	Verifies includes in an ast_contect structure.
Variables
ast_switch *	switches = NULL
ast_hint *	hints = NULL
ast_state_cb *	statecbs = NULL

---

Define Documentation

#define AST_PBX_MAX_STACK   128

Definition at line 485 of file pbx.c.

#define EXT_DATA_SIZE   8192

Definition at line 55 of file pbx.c.

#define EXTENSION_MATCH_CORE (  data, pattern, match   )

Definition at line 573 of file pbx.c. Referenced by ast_extension_match().

#define FIND_NEXT

Value: do { \ c = info; \ while(*c && (*c != '|')) c++; \ if (*c) { *c = '\0'; c++; } else c = NULL; \ } while(0) Definition at line 3075 of file pbx.c.

#define HELPER_CANMATCH   3

Definition at line 490 of file pbx.c. Referenced by ast_canmatch_extension().

#define HELPER_EXEC   2

Definition at line 489 of file pbx.c.

#define HELPER_EXISTS   0

Definition at line 487 of file pbx.c. Referenced by ast_exists_extension().

#define HELPER_MATCHMORE   4

Definition at line 491 of file pbx.c. Referenced by ast_matchmore_extension().

#define HELPER_SPAWN   1

Definition at line 488 of file pbx.c. Referenced by ast_spawn_extension().

#define LOG

Referenced by ast_add_extension2().

#define STATUS_NO_CONTEXT   1

Definition at line 694 of file pbx.c.

#define STATUS_NO_EXTENSION   2

Definition at line 695 of file pbx.c.

#define STATUS_NO_PRIORITY   3

Definition at line 696 of file pbx.c.

#define STATUS_SUCCESS   4

Definition at line 697 of file pbx.c.

---

Function Documentation

void __ast_context_destroy (  struct ast_context *  con, char *  registrar )

Definition at line 4283 of file pbx.c. References ast_context::alts, ast_log(), ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, free, ast_context::ignorepats, ast_context::includes, ast_context::lock, LOG_WARNING, ast_context::name, ast_exten::next, ast_sw::next, ast_ignorepat::next, ast_include::next, ast_context::next, ast_exten::peer, ast_context::registrar, and ast_context::root. Referenced by ast_context_destroy(), and ast_merge_contexts_and_delete(). { struct ast_context *tmp, *tmpl=NULL; struct ast_include *tmpi, *tmpil= NULL; struct ast_sw *sw, *swl= NULL; struct ast_exten *e, *el, *en; struct ast_ignorepat *ipi, *ipl = NULL; ast_mutex_lock(&conlock); tmp = contexts; while(tmp) { if (((tmp->name && con && con->name && !strcasecmp(tmp->name, con->name)) || !con) && (!registrar || !strcasecmp(registrar, tmp->registrar))) { /* Okay, let's lock the structure to be sure nobody else is searching through it. */ if (ast_mutex_lock(&tmp->lock)) { ast_log(LOG_WARNING, "Unable to lock context lock\n"); return; } if (tmpl) tmpl->next = tmp->next; else contexts = tmp->next; /* Okay, now we're safe to let it go -- in a sense, we were ready to let it go as soon as we locked it. */ ast_mutex_unlock(&tmp->lock); for (tmpi = tmp->includes; tmpi; ) { /* Free includes */ tmpil = tmpi; tmpi = tmpi->next; free(tmpil); } for (ipi = tmp->ignorepats; ipi; ) { /* Free ignorepats */ ipl = ipi; ipi = ipi->next; free(ipl); } for (sw = tmp->alts; sw; ) { /* Free switches */ swl = sw; sw = sw->next; free(swl); swl = sw; } for (e = tmp->root; e;) { for (en = e->peer; en;) { el = en; en = en->peer; destroy_exten(el); } el = e; e = e->next; destroy_exten(el); } ast_mutex_destroy(&tmp->lock); free(tmp); if (!con) { /* Might need to get another one -- restart */ tmp = contexts; tmpl = NULL; tmpil = NULL; continue; } ast_mutex_unlock(&conlock); return; } tmpl = tmp; tmp = tmp->next; } ast_mutex_unlock(&conlock); }

int ast_add_extension (  char *  context, int  replace, char *  extension, int  priority, char *  callerid, char *  application, void *  data, void(*)(void *)  datad, char *  registrar )

Parameters: context  context to add the extension to replace  extension  extension to add priority  priority level of extension addition callerid  callerid of extension application  application to run on the extension with that priority level data  data to pass to the application datad  registrar  who registered the extension Add and extension to an extension context. Callerid is a pattern to match CallerID, or NULL to match any callerid Returns 0 on success, -1 on failure Definition at line 3667 of file pbx.c. References ast_add_extension2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) { errno = EBUSY; return -1; } c = ast_walk_contexts(NULL); while (c) { if (!strcmp(context, ast_get_context_name(c))) { int ret = ast_add_extension2(c, replace, extension, priority, callerid, application, data, datad, registrar); ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } ast_unlock_contexts(); errno = ENOENT; return -1; }

int ast_add_extension2 (  struct ast_context *  con, int  replace, char *  extension, int  priority, char *  callerid, char *  application, void *  data, void(*)(void *)  datad, char *  registrar )

Add an extension to an extension context, this time with an ast_context *. CallerID is a pattern to match on callerid, or NULL to not care about callerid. For details about the arguements, check ast_add_extension() Definition at line 3800 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_exten::cidmatch, ast_exten::data, ast_exten::datad, ast_exten::exten, free, ast_context::lock, LOG, LOG_ERROR, LOG_WARNING, malloc, ast_exten::matchcid, ast_context::name, ast_exten::next, ast_exten::peer, ast_exten::priority, PRIORITY_HINT, ast_context::registrar, and ast_context::root. Referenced by ast_add_extension(). { #define LOG do { if (option_debug) {\ if (tmp->matchcid) { \ ast_log(LOG_DEBUG, "Added extension '%s' priority %d (CID match '%s') to %s\n", tmp->exten, tmp->priority, tmp->cidmatch, con->name); \ } else { \ ast_log(LOG_DEBUG, "Added extension '%s' priority %d to %s\n", tmp->exten, tmp->priority, con->name); \ } \ } else if (option_verbose > 2) { \ if (tmp->matchcid) { \ ast_verbose( VERBOSE_PREFIX_3 "Added extension '%s' priority %d (CID match '%s')to %s\n", tmp->exten, tmp->priority, tmp->cidmatch, con->name); \ } else { \ ast_verbose( VERBOSE_PREFIX_3 "Added extension '%s' priority %d to %s\n", tmp->exten, tmp->priority, con->name); \ } \ } } while(0) /* * This is a fairly complex routine. Different extensions are kept * in order by the extension number. Then, extensions of different * priorities (same extension) are kept in a list, according to the * peer pointer. */ struct ast_exten *tmp, *e, *el = NULL, *ep = NULL; int res; /* Be optimistic: Build the extension structure first */ tmp = malloc(sizeof(struct ast_exten)); if (tmp) { memset(tmp, 0, sizeof(struct ast_exten)); ext_strncpy(tmp->exten, extension, sizeof(tmp->exten)); tmp->priority = priority; if (callerid) { ext_strncpy(tmp->cidmatch, callerid, sizeof(tmp->cidmatch)); tmp->matchcid = 1; } else { tmp->cidmatch[0] = '\0'; tmp->matchcid = 0; } strncpy(tmp->app, application, sizeof(tmp->app)-1); tmp->parent = con; tmp->data = data; tmp->datad = datad; tmp->registrar = registrar; tmp->peer = NULL; tmp->next = NULL; } else { ast_log(LOG_ERROR, "Out of memory\n"); errno = ENOMEM; return -1; } if (ast_mutex_lock(&con->lock)) { free(tmp); /* And properly destroy the data */ datad(data); ast_log(LOG_WARNING, "Failed to lock context '%s'\n", con->name); errno = EBUSY; return -1; } e = con->root; while(e) { /* Make sure patterns are always last! */ if ((e->exten[0] != '_') && (extension[0] == '_')) res = -1; else if ((e->exten[0] == '_') && (extension[0] != '_')) res = 1; else res= strcmp(e->exten, extension); if (!res) { if (!e->matchcid && !tmp->matchcid) res = 0; else if (tmp->matchcid && !e->matchcid) res = 1; else if (e->matchcid && !tmp->matchcid) res = -1; else res = strcasecmp(e->cidmatch, tmp->cidmatch); } if (res == 0) { /* We have an exact match, now we find where we are and be sure there's no duplicates */ while(e) { if (e->priority == tmp->priority) { /* Can't have something exactly the same. Is this a replacement? If so, replace, otherwise, bonk. */ if (replace) { if (ep) { /* We're in the peer list, insert ourselves */ ep->peer = tmp; tmp->peer = e->peer; } else if (el) { /* We're the first extension. Take over e's functions */ el->next = tmp; tmp->next = e->next; tmp->peer = e->peer; } else { /* We're the very first extension. */ con->root = tmp; tmp->next = e->next; tmp->peer = e->peer; } if (tmp->priority == PRIORITY_HINT) ast_change_hint(e,tmp); /* Destroy the old one */ e->datad(e->data); free(e); ast_mutex_unlock(&con->lock); if (tmp->priority == PRIORITY_HINT) ast_change_hint(e, tmp); /* And immediately return success. */ LOG; return 0; } else { ast_log(LOG_WARNING, "Unable to register extension '%s', priority %d in '%s', already in use\n", tmp->exten, tmp->priority, con->name); tmp->datad(tmp->data); free(tmp); ast_mutex_unlock(&con->lock); errno = EEXIST; return -1; } } else if (e->priority > tmp->priority) { /* Slip ourselves in just before e */ if (ep) { /* Easy enough, we're just in the peer list */ ep->peer = tmp; tmp->peer = e; } else if (el) { /* We're the first extension in this peer list */ el->next = tmp; tmp->next = e->next; e->next = NULL; tmp->peer = e; } else { /* We're the very first extension altogether */ tmp->next = con->root->next; /* Con->root must always exist or we couldn't get here */ tmp->peer = con->root; con->root = tmp; } ast_mutex_unlock(&con->lock); /* And immediately return success. */ if (tmp->priority == PRIORITY_HINT) ast_add_hint(tmp); LOG; return 0; } ep = e; e = e->peer; } /* If we make it here, then it's time for us to go at the very end. ep *must* be defined or we couldn't have gotten here. */ ep->peer = tmp; ast_mutex_unlock(&con->lock); if (tmp->priority == PRIORITY_HINT) ast_add_hint(tmp); /* And immediately return success. */ LOG; return 0; } else if (res > 0) { /* Insert ourselves just before 'e'. We're the first extension of this kind */ tmp->next = e; if (el) { /* We're in the list somewhere */ el->next = tmp; } else { /* We're at the top of the list */ con->root = tmp; } ast_mutex_unlock(&con->lock); if (tmp->priority == PRIORITY_HINT) ast_add_hint(tmp); /* And immediately return success. */ LOG; return 0; } el = e; e = e->next; } /* If we fall all the way through to here, then we need to be on the end. */ if (el) el->next = tmp; else con->root = tmp; ast_mutex_unlock(&con->lock); if (tmp->priority == PRIORITY_HINT) ast_add_hint(tmp); LOG; return 0; }

int ast_async_goto (  struct ast_channel *  chan, char *  context, char *  exten, int  priority )

Definition at line 3693 of file pbx.c. References ast_channel::_state, ast_channel_alloc(), ast_channel_masquerade(), ast_do_masquerade(), ast_hangup(), ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_pbx_start(), ast_setstate(), AST_SOFTHANGUP_ASYNCGOTO, ast_softhangup_nolock(), ast_channel::context, ast_channel::exten, ast_channel::lock, LOG_WARNING, ast_channel::name, ast_channel::pbx, ast_channel::priority, ast_channel::readformat, and ast_channel::writeformat. Referenced by ast_async_goto_by_name(). { int res = 0; ast_mutex_lock(&chan->lock); if (chan->pbx) { /* This channel is currently in the PBX */ if (context && !ast_strlen_zero(context)) strncpy(chan->context, context, sizeof(chan->context) - 1); if (exten && !ast_strlen_zero(exten)) strncpy(chan->exten, exten, sizeof(chan->context) - 1); if (priority) chan->priority = priority - 1; ast_softhangup_nolock(chan, AST_SOFTHANGUP_ASYNCGOTO); } else { /* In order to do it when the channel doesn't really exist within the PBX, we have to make a new channel, masquerade, and start the PBX at the new location */ struct ast_channel *tmpchan; tmpchan = ast_channel_alloc(0); if (tmpchan) { snprintf(tmpchan->name, sizeof(tmpchan->name), "AsyncGoto/%s", chan->name); ast_setstate(tmpchan, chan->_state); /* Make formats okay */ tmpchan->readformat = chan->readformat; tmpchan->writeformat = chan->writeformat; /* Setup proper location */ if (context && !ast_strlen_zero(context)) strncpy(tmpchan->context, context, sizeof(tmpchan->context) - 1); else strncpy(tmpchan->context, chan->context, sizeof(tmpchan->context) - 1); if (exten && !ast_strlen_zero(exten)) strncpy(tmpchan->exten, exten, sizeof(tmpchan->exten) - 1); else strncpy(tmpchan->exten, chan->exten, sizeof(tmpchan->exten) - 1); if (priority) tmpchan->priority = priority; else tmpchan->priority = chan->priority; /* Masquerade into temp channel */ ast_channel_masquerade(tmpchan, chan); /* Grab the locks and get going */ ast_mutex_lock(&tmpchan->lock); ast_do_masquerade(tmpchan); ast_mutex_unlock(&tmpchan->lock); /* Start the PBX going on our stolen channel */ if (ast_pbx_start(tmpchan)) { ast_log(LOG_WARNING, "Unable to start PBX on %s\n", tmpchan->name); ast_hangup(tmpchan); res = -1; } } else { res = -1; } } ast_mutex_unlock(&chan->lock); return res; }

int ast_async_goto_by_name (  char *  channame, char *  context, char *  exten, int  priority )

Definition at line 3754 of file pbx.c. References ast_async_goto(), ast_channel_walk_locked(), ast_mutex_unlock, ast_channel::lock, and ast_channel::name. { struct ast_channel *chan; int res = -1; chan = ast_channel_walk_locked(NULL); while(chan) { if (!strcasecmp(channame, chan->name)) break; ast_mutex_unlock(&chan->lock); chan = ast_channel_walk_locked(chan); } if (chan) { res = ast_async_goto(chan, context, exten, priority); ast_mutex_unlock(&chan->lock); } return res; }

int ast_canmatch_extension (  struct ast_channel *  c, char *  context, char *  exten, int  priority, char *  callerid )

Looks for a valid matching extension. Parameters: c  not really important context  context to serach within exten  extension to check priority  priority of extension path callerid  callerid of extension being searched for If "exten" *could be* a valid extension in this context with or without some more digits, return non-zero. Basically, when this returns 0, no matter what you add to exten, it's not going to be a valid extension anymore Definition at line 1761 of file pbx.c. References HELPER_CANMATCH. { return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_CANMATCH); }

int ast_context_add_ignorepat (  char *  context, char *  ignorepat, char *  registrar )

Add an ignorepat. Parameters: context  which context to add the ignorpattern to ignorpat  ignorepattern to set up for the extension registrar  registrar of the ignore pattern Adds an ignore pattern to a particular context. Returns 0 on success, -1 on failure Definition at line 3586 of file pbx.c. References ast_context_add_ignorepat2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) { errno = EBUSY; return -1; } c = ast_walk_contexts(NULL); while (c) { if (!strcmp(ast_get_context_name(c), con)) { int ret = ast_context_add_ignorepat2(c, value, registrar); ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } ast_unlock_contexts(); errno = ENOENT; return -1; }

int ast_context_add_ignorepat2 (  struct ast_context *  con, char *  value, char *  registrar )

Definition at line 3610 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_context::ignorepats, ast_context::lock, LOG_ERROR, malloc, ast_ignorepat::next, ast_ignorepat::pattern, and ast_ignorepat::registrar. Referenced by ast_context_add_ignorepat(). { struct ast_ignorepat *ignorepat, *ignorepatc, *ignorepatl = NULL; ignorepat = malloc(sizeof(struct ast_ignorepat)); if (!ignorepat) { ast_log(LOG_ERROR, "Out of memory\n"); errno = ENOMEM; return -1; } memset(ignorepat, 0, sizeof(struct ast_ignorepat)); strncpy(ignorepat->pattern, value, sizeof(ignorepat->pattern)-1); ignorepat->next = NULL; ignorepat->registrar = registrar; ast_mutex_lock(&con->lock); ignorepatc = con->ignorepats; while(ignorepatc) { ignorepatl = ignorepatc; if (!strcasecmp(ignorepatc->pattern, value)) { /* Already there */ ast_mutex_unlock(&con->lock); errno = EEXIST; return -1; } ignorepatc = ignorepatc->next; } if (ignorepatl) ignorepatl->next = ignorepat; else con->ignorepats = ignorepat; ast_mutex_unlock(&con->lock); return 0; }

int ast_context_add_include (  char *  context, char *  include, char *  registrar )

Add an include. Parameters: context  context to add include to include  new include to add registrar  who's registering it Adds an include taking a char * string as the context parameter Returns 0 on success, -1 on error Definition at line 3047 of file pbx.c. References ast_context_add_include2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) { errno = EBUSY; return -1; } /* walk contexts ... */ c = ast_walk_contexts(NULL); while (c) { /* ... search for the right one ... */ if (!strcmp(ast_get_context_name(c), context)) { int ret = ast_context_add_include2(c, include, registrar); /* ... unlock contexts list and return */ ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } /* we can't find the right context */ ast_unlock_contexts(); errno = ENOENT; return -1; }

int ast_context_add_include2 (  struct ast_context *  con, char *  include, char *  registrar )

Add an include. Parameters: con  context to add the include to include  include to add registrar  who registered the context Adds an include taking a struct ast_context as the first parameter Returns 0 on success, -1 on failure Definition at line 3367 of file pbx.c. References ast_get_context_name(), ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), free, ast_context::includes, ast_context::lock, LOG_ERROR, malloc, ast_include::name, ast_include::next, option_verbose, ast_include::registrar, ast_include::rname, and VERBOSE_PREFIX_3. Referenced by ast_context_add_include(). { struct ast_include *new_include; char *c; struct ast_include *i, *il = NULL; /* include, include_last */ /* allocate new include structure ... */ if (!(new_include = malloc(sizeof(struct ast_include)))) { ast_log(LOG_ERROR, "Out of memory\n"); errno = ENOMEM; return -1; } /* ... fill in this structure ... */ memset(new_include, 0, sizeof(struct ast_include)); strncpy(new_include->name, value, sizeof(new_include->name)-1); strncpy(new_include->rname, value, sizeof(new_include->rname)-1); c = new_include->rname; /* Strip off timing info */ while(*c && (*c != '|')) c++; /* Process if it's there */ if (*c) { build_timing(new_include, c+1); *c = '\0'; } new_include->next = NULL; new_include->registrar = registrar; /* ... try to lock this context ... */ if (ast_mutex_lock(&con->lock)) { free(new_include); errno = EBUSY; return -1; } /* ... go to last include and check if context is already included too... */ i = con->includes; while (i) { if (!strcasecmp(i->name, new_include->name)) { free(new_include); ast_mutex_unlock(&con->lock); errno = EEXIST; return -1; } il = i; i = i->next; } /* ... include new context into context list, unlock, return */ if (il) il->next = new_include; else con->includes = new_include; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Including context '%s' in context '%s'\n", new_include->name, ast_get_context_name(con)); ast_mutex_unlock(&con->lock); return 0; }

int ast_context_add_switch (  char *  context, char *  sw, char *  data, char *  registrar )

Add a switch. Parameters: context  context to which to add the switch sw  switch to add data  data to pass to switch registrar  whoever registered the switch This function registers a switch with the asterisk switch architecture It returns 0 on success, -1 on failure Definition at line 3433 of file pbx.c. References ast_context_add_switch2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) { errno = EBUSY; return -1; } /* walk contexts ... */ c = ast_walk_contexts(NULL); while (c) { /* ... search for the right one ... */ if (!strcmp(ast_get_context_name(c), context)) { int ret = ast_context_add_switch2(c, sw, data, registrar); /* ... unlock contexts list and return */ ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } /* we can't find the right context */ ast_unlock_contexts(); errno = ENOENT; return -1; }

int ast_context_add_switch2 (  struct ast_context *  con, char *  sw, char *  data, char *  registrar )

Adds a switch (first param is a ast_context). See ast_context_add_switch() Definition at line 3468 of file pbx.c. References ast_context::alts, ast_get_context_name(), ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), ast_sw::data, free, ast_context::lock, LOG_ERROR, malloc, ast_sw::name, ast_sw::next, option_verbose, ast_sw::registrar, and VERBOSE_PREFIX_3. Referenced by ast_context_add_switch(). { struct ast_sw *new_sw; struct ast_sw *i, *il = NULL; /* sw, sw_last */ /* allocate new sw structure ... */ if (!(new_sw = malloc(sizeof(struct ast_sw)))) { ast_log(LOG_ERROR, "Out of memory\n"); errno = ENOMEM; return -1; } /* ... fill in this structure ... */ memset(new_sw, 0, sizeof(struct ast_sw)); strncpy(new_sw->name, value, sizeof(new_sw->name)-1); if (data) strncpy(new_sw->data, data, sizeof(new_sw->data)-1); else strncpy(new_sw->data, "", sizeof(new_sw->data)-1); new_sw->next = NULL; new_sw->registrar = registrar; /* ... try to lock this context ... */ if (ast_mutex_lock(&con->lock)) { free(new_sw); errno = EBUSY; return -1; } /* ... go to last sw and check if context is already swd too... */ i = con->alts; while (i) { if (!strcasecmp(i->name, new_sw->name) && !strcasecmp(i->data, new_sw->data)) { free(new_sw); ast_mutex_unlock(&con->lock); errno = EEXIST; return -1; } il = i; i = i->next; } /* ... sw new context into context list, unlock, return */ if (il) il->next = new_sw; else con->alts = new_sw; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Including switch '%s/%s' in context '%s'\n", new_sw->name, new_sw->data, ast_get_context_name(con)); ast_mutex_unlock(&con->lock); return 0; }

struct ast_context* ast_context_create (  struct ast_context **  extcontexts, char *  name, char *  registrar )

Register a new context. Parameters: extcontexts  pointer to the ast_context structure pointer name  name of the new context registrar  registrar of the context This will first search for a context with your name. If it exists already, it will not create a new one. If it does not exist, it will create a new one with the given name and registrar. It returns NULL on failure, and an ast_context structure on success Definition at line 2970 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), ast_context::includes, LOG_DEBUG, LOG_ERROR, LOG_WARNING, malloc, ast_context::name, ast_context::next, option_debug, option_verbose, and VERBOSE_PREFIX_3. { struct ast_context *tmp, **local_contexts; if (!extcontexts) { local_contexts = &contexts; ast_mutex_lock(&conlock); } else local_contexts = extcontexts; tmp = *local_contexts; while(tmp) { if (!strcasecmp(tmp->name, name)) { ast_mutex_unlock(&conlock); ast_log(LOG_WARNING, "Tried to register context '%s', already in use\n", name); if (!extcontexts) ast_mutex_unlock(&conlock); return NULL; } tmp = tmp->next; } tmp = malloc(sizeof(struct ast_context)); if (tmp) { memset(tmp, 0, sizeof(struct ast_context)); ast_mutex_init(&tmp->lock); strncpy(tmp->name, name, sizeof(tmp->name)-1); tmp->root = NULL; tmp->registrar = registrar; tmp->next = *local_contexts; tmp->includes = NULL; tmp->ignorepats = NULL; *local_contexts = tmp; if (option_debug) ast_log(LOG_DEBUG, "Registered context '%s'\n", tmp->name); else if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Registered extension context '%s'\n", tmp->name); } else ast_log(LOG_ERROR, "Out of memory\n"); if (!extcontexts) ast_mutex_unlock(&conlock); return tmp; }

void ast_context_destroy (  struct ast_context *  con, char *  registrar )

Destroy a context (matches the specified context (or ANY context if NULL). Parameters: con  context to destroy registrar  who registered it You can optionally leave out either parameter. It will find it based on either the ast_context or the registrar name. Returns nothing Definition at line 4356 of file pbx.c. References __ast_context_destroy(). { __ast_context_destroy(con,registrar); }

struct ast_context* ast_context_find (  char *  name  )

Find a context. Parameters: name  name of the context to find Will search for the context with the given name. Returns the ast_context on success, NULL on failure. Definition at line 677 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_context::name, and ast_context::next. Referenced by ast_context_verify_includes(), and ast_ignore_pattern(). { struct ast_context *tmp; ast_mutex_lock(&conlock); if (name) { tmp = contexts; while(tmp) { if (!strcasecmp(name, tmp->name)) break; tmp = tmp->next; } } else tmp = contexts; ast_mutex_unlock(&conlock); return tmp; }

int ast_context_remove_extension (  char *  context, char *  extension, int  priority, char *  registrar )

Simply remove extension from context. Parameters: context  context to remove extension from extension  which extension to remove priority  priority of extension to remove registrar  registrar of the extension This function removes an extension from a given context. Returns 0 on success, -1 on failure Definition at line 2169 of file pbx.c. References ast_context_remove_extension2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) return -1; /* walk contexts ... */ c = ast_walk_contexts(NULL); while (c) { /* ... search for the right one ... */ if (!strcmp(ast_get_context_name(c), context)) { /* ... remove extension ... */ int ret = ast_context_remove_extension2(c, extension, priority, registrar); /* ... unlock contexts list and return */ ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } /* we can't find the right context */ ast_unlock_contexts(); return -1; }

int ast_context_remove_extension2 (  struct ast_context *  con, char *  extension, int  priority, char *  registrar )

Definition at line 2205 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_exten::exten, free, ast_context::lock, ast_exten::next, ast_exten::peer, ast_exten::priority, PRIORITY_HINT, ast_exten::registrar, and ast_context::root. Referenced by ast_context_remove_extension(). { struct ast_exten *exten, *prev_exten = NULL; if (ast_mutex_lock(&con->lock)) return -1; /* go through all extensions in context and search the right one ... */ exten = con->root; while (exten) { /* look for right extension */ if (!strcmp(exten->exten, extension) && (!registrar || !strcmp(exten->registrar, registrar))) { struct ast_exten *peer; /* should we free all peers in this extension? (priority == 0)? */ if (priority == 0) { /* remove this extension from context list */ if (prev_exten) prev_exten->next = exten->next; else con->root = exten->next; /* fire out all peers */ peer = exten; while (peer) { exten = peer->peer; if (!peer->priority==PRIORITY_HINT) ast_remove_hint(peer); peer->datad(peer->data); free(peer); peer = exten; } ast_mutex_unlock(&con->lock); return 0; } else { /* remove only extension with exten->priority == priority */ struct ast_exten *previous_peer = NULL; peer = exten; while (peer) { /* is this our extension? */ if (peer->priority == priority && (!registrar || !strcmp(peer->registrar, registrar) )) { /* we are first priority extension? */ if (!previous_peer) { /* exists previous extension here? */ if (prev_exten) { /* yes, so we must change next pointer in * previous connection to next peer */ if (peer->peer) { prev_exten->next = peer->peer; peer->peer->next = exten->next; } else prev_exten->next = exten->next; } else { /* no previous extension, we are first * extension, so change con->root ... */ if (peer->peer) con->root = peer->peer; else con->root = exten->next; } } else { /* we are not first priority in extension */ previous_peer->peer = peer->peer; } /* now, free whole priority extension */ if (peer->priority==PRIORITY_HINT) ast_remove_hint(peer); peer->datad(peer->data); free(peer); ast_mutex_unlock(&con->lock); return 0; } else { /* this is not right extension, skip to next peer */ previous_peer = peer; peer = peer->peer; } } ast_mutex_unlock(&con->lock); return -1; } } prev_exten = exten; exten = exten->next; } /* we can't find right extension */ ast_mutex_unlock(&con->lock); return -1; }

int ast_context_remove_ignorepat (  char *  context, char *  ignorepat, char *  registrar )

Parameters: context  context from which to remove the pattern ignorepat  the pattern to remove registrar  the registrar of the ignore pattern This removes the given ignorepattern Returns 0 on success, -1 on failure Definition at line 3527 of file pbx.c. References ast_context_remove_ignorepat2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) { errno = EBUSY; return -1; } c = ast_walk_contexts(NULL); while (c) { if (!strcmp(ast_get_context_name(c), context)) { int ret = ast_context_remove_ignorepat2(c, ignorepat, registrar); ast_unlock_contexts(); return ret; } c = ast_walk_contexts(c); } ast_unlock_contexts(); errno = ENOENT; return -1; }

int ast_context_remove_ignorepat2 (  struct ast_context *  con, char *  ignorepat, char *  registrar )

Definition at line 3551 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, free, ast_context::ignorepats, ast_context::lock, ast_ignorepat::next, ast_ignorepat::pattern, and ast_ignorepat::registrar. Referenced by ast_context_remove_ignorepat(). { struct ast_ignorepat *ip, *ipl = NULL; if (ast_mutex_lock(&con->lock)) { errno = EBUSY; return -1; } ip = con->ignorepats; while (ip) { if (!strcmp(ip->pattern, ignorepat) && (!registrar || (registrar == ip->registrar))) { if (ipl) { ipl->next = ip->next; free(ip); } else { con->ignorepats = ip->next; free(ip); } ast_mutex_unlock(&con->lock); return 0; } ipl = ip; ip = ip->next; } ast_mutex_unlock(&con->lock); errno = EINVAL; return -1; }

int ast_context_remove_include (  char *  context, char *  include, char *  registrar )

Removes an include. See add_include Definition at line 2025 of file pbx.c. References ast_context_remove_include2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) return -1; /* walk contexts and search for the right one ...*/ c = ast_walk_contexts(NULL); while (c) { /* we found one ... */ if (!strcmp(ast_get_context_name(c), context)) { int ret; /* remove include from this context ... */ ret = ast_context_remove_include2(c, include, registrar); ast_unlock_contexts(); /* ... return results */ return ret; } c = ast_walk_contexts(c); } /* we can't find the right one context */ ast_unlock_contexts(); return -1; }

int ast_context_remove_include2 (  struct ast_context *  con, char *  include, char *  registrar )

Removes an include by an ast_context structure. See add_include2 Definition at line 2061 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, free, ast_context::includes, ast_context::lock, ast_include::name, ast_include::next, and ast_include::registrar. Referenced by ast_context_remove_include(). { struct ast_include *i, *pi = NULL; if (ast_mutex_lock(&con->lock)) return -1; /* walk includes */ i = con->includes; while (i) { /* find our include */ if (!strcmp(i->name, include) && (!registrar || !strcmp(i->registrar, registrar))) { /* remove from list */ if (pi) pi->next = i->next; else con->includes = i->next; /* free include and return */ free(i); ast_mutex_unlock(&con->lock); return 0; } pi = i; i = i->next; } /* we can't find the right include */ ast_mutex_unlock(&con->lock); return -1; }

int ast_context_remove_switch (  char *  context, char *  sw, char *  data, char *  registrar )

Remove a switch. Removes a switch with the given parameters Returns 0 on success, -1 on failure Definition at line 2097 of file pbx.c. References ast_context_remove_switch2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts(). { struct ast_context *c; if (ast_lock_contexts()) return -1; /* walk contexts and search for the right one ...*/ c = ast_walk_contexts(NULL); while (c) { /* we found one ... */ if (!strcmp(ast_get_context_name(c), context)) { int ret; /* remove switch from this context ... */ ret = ast_context_remove_switch2(c, sw, data, registrar); ast_unlock_contexts(); /* ... return results */ return ret; } c = ast_walk_contexts(c); } /* we can't find the right one context */ ast_unlock_contexts(); return -1; }

int ast_context_remove_switch2 (  struct ast_context *  con, char *  sw, char *  data, char *  registrar )

Definition at line 2133 of file pbx.c. References ast_context::alts, ast_mutex_lock, ast_mutex_unlock, ast_sw::data, free, ast_context::lock, ast_sw::name, ast_sw::next, and ast_sw::registrar. Referenced by ast_context_remove_switch(). { struct ast_sw *i, *pi = NULL; if (ast_mutex_lock(&con->lock)) return -1; /* walk switchs */ i = con->alts; while (i) { /* find our switch */ if (!strcmp(i->name, sw) && !strcmp(i->data, data) && (!registrar || !strcmp(i->registrar, registrar))) { /* remove from list */ if (pi) pi->next = i->next; else con->alts = i->next; /* free switch and return */ free(i); ast_mutex_unlock(&con->lock); return 0; } pi = i; i = i->next; } /* we can't find the right switch */ ast_mutex_unlock(&con->lock); return -1; }

int ast_context_verify_includes (  struct ast_context *  con  )

Verifies includes in an ast_contect structure. Parameters: con  context in which to verify the includes Returns 0 if no problems found, -1 if there were any missing context Definition at line 5093 of file pbx.c. References ast_context_find(), ast_get_context_name(), ast_log(), ast_walk_context_includes(), LOG_WARNING, and ast_include::rname. { struct ast_include *inc; int res = 0; for (inc = ast_walk_context_includes(con, NULL); inc; inc = ast_walk_context_includes(con, inc)) if (!ast_context_find(inc->rname)) { res = -1; ast_log(LOG_WARNING, "Context '%s' tries includes non-existant context '%s'\n", ast_get_context_name(con), inc->rname); } return res; }

int ast_device_state_changed (  const char *  fmt,   ... )

Definition at line 1441 of file pbx.c. References ast_get_extension_app(), AST_MAX_EXTENSION, ast_mutex_lock, ast_mutex_unlock, ast_state_cb::callback, ast_hint::callbacks, ast_state_cb::data, ast_exten::exten, ast_hint::exten, ast_hint::laststate, ast_context::name, ast_hint::next, ast_state_cb::next, and ast_exten::parent. Referenced by ast_channel_free(), and ast_setstate(). { struct ast_hint *list; struct ast_state_cb *cblist; char hint[AST_MAX_EXTENSION] = ""; char device[AST_MAX_EXTENSION]; char *cur, *rest; int state; va_list ap; va_start(ap, fmt); vsnprintf(device, sizeof(device), fmt, ap); va_end(ap); rest = strchr(device, '-'); if (rest) { *rest = 0; } ast_mutex_lock(&hintlock); list = hints; while (list) { strncpy(hint, ast_get_extension_app(list->exten), sizeof(hint) - 1); cur = hint; do { rest = strchr(cur, '&'); if (rest) { *rest = 0; rest++; } if (!strcmp(cur, device)) { /* Found extension execute callbacks */ state = ast_extension_state2(list->exten); if ((state != -1) && (state != list->laststate)) { /* For general callbacks */ cblist = statecbs; while (cblist) { cblist->callback(list->exten->parent->name, list->exten->exten, state, cblist->data); cblist = cblist->next; } /* For extension callbacks */ cblist = list->callbacks; while (cblist) { cblist->callback(list->exten->parent->name, list->exten->exten, state, cblist->data); cblist = cblist->next; } list->laststate = state; } break; } cur = rest; } while (cur); list = list->next; } ast_mutex_unlock(&hintlock); return 1; }

int ast_exists_extension (  struct ast_channel *  c, char *  context, char *  exten, int  priority, char *  callerid )

If an extension exists, return non-zero. Parameters: c  this is not important context  which context to look in exten  which extension to search for priority  priority of the action within the extension callerid  callerid to search for If an extension within the given context(or callerid) with the given priority is found a non zero value will be returned. Otherwise, 0 is returned. Definition at line 1756 of file pbx.c. References HELPER_EXISTS. Referenced by ast_pbx_outgoing_exten(), and ast_pbx_run(). { return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_EXISTS); }

int ast_extension_match (  char *  pattern, char *  extension )

Determine if a given extension matches a given pattern (in NXX format). Parameters: pattern  pattern to match extension  extension to check against the pattern. Checks whether or not the given extension matches the given pattern. Returns 1 on match, 0 on failure Definition at line 644 of file pbx.c. References EXTENSION_MATCH_CORE. Referenced by ast_ignore_pattern(). { int match; /* If they're the same return */ if (!strcmp(pattern, data)) return 1; EXTENSION_MATCH_CORE(data,pattern,match); /* Must be at the end of both */ if (*data || (*pattern && (*pattern != '/'))) match = 0; return match; }

int ast_extension_state (  struct ast_channel *  c, char *  context, char *  exten )

Uses hint and devicestate callback to get the state of an extension. Parameters: c  this is not important context  which context to look in exten  which extension to get state Returns extension state !! = AST_EXTENSION_??? Definition at line 1430 of file pbx.c. { struct ast_exten *e; e = ast_hint_extension(c, context, exten); if (!e) return -1; return ast_extension_state2(e); }

int ast_extension_state_add (  char *  context, char *  exten, ast_state_cb_type  callback, void *  data )

Registers a state change callback. Parameters: context  which context to look in exten  which extension to get state callback  callback to call if state changed data  to pass to callback The callback is called if the state for extension is changed Return -1 on failure, ID on success Definition at line 1506 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_state_cb::callback, ast_hint::callbacks, ast_state_cb::data, ast_hint::exten, ast_state_cb::id, malloc, ast_state_cb::next, and ast_hint::next. Referenced by init_manager(). { struct ast_hint *list; struct ast_state_cb *cblist; struct ast_exten *e; /* No context and extension add callback to statecbs list */ if (!context && !exten) { ast_mutex_lock(&hintlock); cblist = statecbs; while (cblist) { if (cblist->callback == callback) { cblist->data = data; ast_mutex_unlock(&hintlock); } cblist = cblist->next; } /* Now inserts the callback */ cblist = malloc(sizeof(struct ast_state_cb)); if (!cblist) { ast_mutex_unlock(&hintlock); return -1; } memset(cblist, 0, sizeof(struct ast_state_cb)); cblist->id = 0; cblist->callback = callback; cblist->data = data; cblist->next = statecbs; statecbs = cblist; ast_mutex_unlock(&hintlock); return 0; } if (!context || !exten) return -1; /* This callback type is for only one hint */ e = ast_hint_extension(NULL, context, exten); if (!e) { return -1; } ast_mutex_lock(&hintlock); list = hints; while (list) { if (list->exten == e) break; list = list->next; } if (!list) { ast_mutex_unlock(&hintlock); return -1; } /* Now inserts the callback */ cblist = malloc(sizeof(struct ast_state_cb)); if (!cblist) { ast_mutex_unlock(&hintlock); return -1; } memset(cblist, 0, sizeof(struct ast_state_cb)); cblist->id = stateid++; cblist->callback = callback; cblist->data = data; cblist->next = list->callbacks; list->callbacks = cblist; ast_mutex_unlock(&hintlock); return cblist->id; }

int ast_extension_state_del (  int  id, ast_state_cb_type  callback )

Deletes a registered state change callback by ID. Parameters: id  of the callback to delete Removes the callback from list of callbacks Return 0 on success, -1 on failure Definition at line 1585 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_hint::callbacks, free, ast_state_cb::next, and ast_hint::next. { struct ast_hint *list; struct ast_state_cb *cblist, *cbprev; if (!id && !callback) return -1; ast_mutex_lock(&hintlock); /* id is zero is a callback without extension */ if (!id) { cbprev = NULL; cblist = statecbs; while (cblist) { if (cblist->callback == callback) { if (!cbprev) statecbs = cblist->next; else cbprev->next = cblist->next; free(cblist); ast_mutex_unlock(&hintlock); return 0; } cbprev = cblist; cblist = cblist->next; } ast_mutex_lock(&hintlock); return -1; } /* id greater than zero is a callback with extension */ list = hints; while (list) { cblist = list->callbacks; cbprev = NULL; while (cblist) { if (cblist->id==id) { if (!cbprev) list->callbacks = cblist->next; else cbprev->next = cblist->next; free(cblist); ast_mutex_unlock(&hintlock); return 0; } cbprev = cblist; cblist = cblist->next; } list = list->next; } ast_mutex_unlock(&hintlock); return -1; }

char* ast_get_context_name (  struct ast_context *  con  )

Definition at line 4954 of file pbx.c. References ast_context::name. Referenced by ast_add_extension(), ast_context_add_ignorepat(), ast_context_add_include(), ast_context_add_include2(), ast_context_add_switch(), ast_context_add_switch2(), ast_context_remove_extension(), ast_context_remove_ignorepat(), ast_context_remove_include(), ast_context_remove_switch(), and ast_context_verify_includes(). { return con ? con->name : NULL; }

char* ast_get_context_registrar (  struct ast_context *  c  )

Definition at line 4982 of file pbx.c. References ast_context::registrar. { return c ? c->registrar : NULL; }

char* ast_get_extension_app (  struct ast_exten *  e  )

Definition at line 5012 of file pbx.c. References ast_exten::app. Referenced by ast_device_state_changed(), and ast_get_hint(). { return e ? e->app : NULL; }

void* ast_get_extension_app_data (  struct ast_exten *  e  )

Definition at line 5017 of file pbx.c. References ast_exten::data. { return e ? e->data : NULL; }

char* ast_get_extension_cidmatch (  struct ast_exten *  e  )

Definition at line 5007 of file pbx.c. References ast_exten::cidmatch. { return e ? e->cidmatch : NULL; }

int ast_get_extension_matchcid (  struct ast_exten *  e  )

Definition at line 5002 of file pbx.c. References ast_exten::matchcid. { return e ? e->matchcid : 0; }

char* ast_get_extension_name (  struct ast_exten *  exten  )

Definition at line 4959 of file pbx.c. References ast_exten::exten. { return exten ? exten->exten : NULL; }

int ast_get_extension_priority (  struct ast_exten *  exten  )

Definition at line 4974 of file pbx.c. References ast_exten::priority. { return exten ? exten->priority : -1; }

char* ast_get_extension_registrar (  struct ast_exten *  e  )

Definition at line 4987 of file pbx.c. References ast_exten::registrar. { return e ? e->registrar : NULL; }

int ast_get_hint (  char *  hint, int  maxlen, struct ast_channel *  c, char *  context, char *  exten )

If an extension exists, return non-zero. Parameters: hint  buffer for hint maxlen  size of hint buffer c  this is not important context  which context to look in exten  which extension to search for If an extension within the given context with the priority PRIORITY_HINT is found a non zero value will be returned. Otherwise, 0 is returned. Definition at line 1745 of file pbx.c. References ast_get_extension_app(). { struct ast_exten *e; e = ast_hint_extension(c, context, exten); if (e) { strncpy(hint, ast_get_extension_app(e), hintsize - 1); return -1; } return 0; }

char* ast_get_ignorepat_name (  struct ast_ignorepat *  ip  )

Definition at line 4969 of file pbx.c. References ast_ignorepat::pattern. { return ip ? ip->pattern : NULL; }

char* ast_get_ignorepat_registrar (  struct ast_ignorepat *  ip  )

Definition at line 4997 of file pbx.c. References ast_ignorepat::registrar. { return ip ? ip->registrar : NULL; }

char* ast_get_include_name (  struct ast_include *  inc  )

Definition at line 4964 of file pbx.c. References ast_include::name. { return inc ? inc->name : NULL; }

char* ast_get_include_registrar (  struct ast_include *  i  )

Definition at line 4992 of file pbx.c. References ast_include::registrar. { return i ? i->registrar : NULL; }

char* ast_get_switch_data (  struct ast_sw *  sw  )

Definition at line 5027 of file pbx.c. References ast_sw::data. { return sw ? sw->data : NULL; }

char* ast_get_switch_name (  struct ast_sw *  sw  )

Definition at line 5022 of file pbx.c. References ast_sw::name. { return sw ? sw->name : NULL; }

char* ast_get_switch_registrar (  struct ast_sw *  sw  )

Definition at line 5032 of file pbx.c. References ast_sw::registrar. { return sw ? sw->registrar : NULL; }

int ast_ignore_pattern (  char *  context, char *  pattern )

Checks to see if a number should be ignored. Parameters: context  context to search within extension  to check whether it should be ignored or not Check if a number should be ignored with respect to dialtone cancellation. Returns 0 if the pattern should not be ignored, or non-zero if the pattern should be ignored Definition at line 3645 of file pbx.c. References ast_context_find(), ast_extension_match(), and ast_context::ignorepats. { struct ast_context *con; struct ast_ignorepat *pat; con = ast_context_find(context); if (con) { pat = con->ignorepats; while (pat) { if (ast_extension_match(pat->pattern, pattern)) return 1; pat = pat->next; } } return 0; }

int ast_lock_context (  struct ast_context *  con  )

Locks a given context. Parameters: con  context to lock Locks the context. Returns 0 on success, -1 on failure Definition at line 4941 of file pbx.c. References ast_mutex_lock, and ast_context::lock. { return ast_mutex_lock(&con->lock); }

int ast_lock_contexts (  void   )

Locks the contexts. Locks the context list Returns 0 on success, -1 on error Definition at line 4928 of file pbx.c. References ast_mutex_lock. Referenced by ast_add_extension(), ast_context_add_ignorepat(), ast_context_add_include(), ast_context_add_switch(), ast_context_remove_extension(), ast_context_remove_ignorepat(), ast_context_remove_include(), and ast_context_remove_switch(). { return ast_mutex_lock(&conlock); }

int ast_matchmore_extension (  struct ast_channel *  c, char *  context, char *  exten, int  priority, char *  callerid )

Looks to see if adding anything to this extension might match something. (exists ^ canmatch). Parameters: c  not really important context  context to serach within exten  extension to check priority  priority of extension path callerid  callerid of extension being searched for If "exten" *could match* a valid extension in this context with some more digits, return non-zero. Does NOT return non-zero if this is an exact-match only. Basically, when this returns 0, no matter what you add to exten, it's not going to be a valid extension anymore Definition at line 1766 of file pbx.c. References HELPER_MATCHMORE. Referenced by ast_pbx_run(). { return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_MATCHMORE); }

void ast_merge_contexts_and_delete (  struct ast_context **  extcontexts, char *  registrar )

Merge the temporary contexts into a global contexts list and delete from the global list the ones that are being added. Parameters: extcontexts  pointer to the ast_context structure pointer registar  of the context; if it's set the routine will delete all contexts that belong to that registrar; if NULL only the contexts that are specified in extcontexts Definition at line 3015 of file pbx.c. References __ast_context_destroy(), ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_WARNING, and ast_context::next. { struct ast_context *tmp, *lasttmp = NULL; tmp = *extcontexts; ast_mutex_lock(&conlock); if (registrar) { __ast_context_destroy(NULL,registrar); while (tmp) { lasttmp = tmp; tmp = tmp->next; } } else { while (tmp) { __ast_context_destroy(tmp,tmp->registrar); lasttmp = tmp; tmp = tmp->next; } } if (lasttmp) { lasttmp->next = contexts; contexts = *extcontexts; *extcontexts = NULL; } else ast_log(LOG_WARNING, "Requested contexts didn't get merged\n"); ast_mutex_unlock(&conlock); return; }

AST_MUTEX_DEFINE_STATIC (  hintlock   )

AST_MUTEX_DEFINE_STATIC (  switchlock   )

AST_MUTEX_DEFINE_STATIC (  conlock   )

AST_MUTEX_DEFINE_STATIC (  applock   )

int ast_pbx_outgoing_app (  char *  type, int  format, void *  data, int  timeout, char *  app, char *  appdata, int *  reason, int  sync, char *  callerid, char *  variable, char *  account, char *  uniqueid )

Definition at line 4185 of file pbx.c. References ast_hangup(), ast_log(), ast_pbx_run_app(), ast_pthread_create(), ast_request_and_dial(), AST_STATE_UP, ast_verbose(), free, LOG_ERROR, LOG_WARNING, malloc, option_verbose, pbx_builtin_setvar(), and VERBOSE_PREFIX_4. { struct ast_channel *chan; struct async_stat *as; struct app_tmp *tmp; char *var, *vartmp; int res = -1; pthread_attr_t attr; if (!app || ast_strlen_zero(app)) return -1; if (sync) { chan = ast_request_and_dial(type, format, data, timeout, reason, 0, callerid, uniqueid); if (chan) { pbx_builtin_setaccount(chan, account); if (variable) { vartmp = ast_strdupa(variable); for (var = strtok_r(vartmp, "|", &vartmp); var; var = strtok_r(NULL, "|", &vartmp)) { pbx_builtin_setvar( chan, var ); } } if (chan->_state == AST_STATE_UP) { res = 0; if (option_verbose > 3) ast_verbose(VERBOSE_PREFIX_4 "Channel %s was answered.\n", chan->name); tmp = malloc(sizeof(struct app_tmp)); if (tmp) { memset(tmp, 0, sizeof(struct app_tmp)); strncpy(tmp->app, app, sizeof(tmp->app) - 1); strncpy(tmp->data, appdata, sizeof(tmp->data) - 1); tmp->chan = chan; if (sync > 1) { ast_pbx_run_app(tmp); } else { pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); if (ast_pthread_create(&tmp->t, &attr, ast_pbx_run_app, tmp)) { ast_log(LOG_WARNING, "Unable to spawn execute thread on %s: %s\n", chan->name, strerror(errno)); free(tmp); ast_hangup(chan); res = -1; } } } else { ast_log(LOG_ERROR, "Out of memory :(\n"); res = -1; } } else { if (option_verbose > 3) ast_verbose(VERBOSE_PREFIX_4 "Channel %s was never answered.\n", chan->name); ast_hangup(chan); } } } else { as = malloc(sizeof(struct async_stat)); if (!as) return -1; memset(as, 0, sizeof(struct async_stat)); chan = ast_request_and_dial(type, format, data, timeout, reason, 0, callerid, uniqueid); if (!chan) { free(as); return -1; } pbx_builtin_setaccount(chan, account); as->chan = chan; strncpy(as->app, app, sizeof(as->app) - 1); if (appdata) strncpy(as->appdata, appdata, sizeof(as->appdata) - 1); as->timeout = timeout; if (variable) { vartmp = ast_strdupa(variable); for (var = strtok_r(vartmp, "|", &vartmp); var; var = strtok_r(NULL, "|", &vartmp)) pbx_builtin_setvar( chan, var ); } /* Start a new thread, and get something handling this channel. */ pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); if (ast_pthread_create(&as->p, &attr, async_wait, as)) { ast_log(LOG_WARNING, "Failed to start async wait\n"); free(as); ast_hangup(chan); return -1; } res = 0; } return res; }

int ast_pbx_outgoing_exten (  char *  type, int  format, void *  data, int  timeout, char *  context, char *  exten, int  priority, int *  reason, int  sync, int  callingpres, char *  callerid, char *  variable, char *  account, char *  uniqueid )

Definition at line 4067 of file pbx.c. References __ast_request_and_dial(), ast_channel_alloc(), ast_exists_extension(), ast_hangup(), ast_log(), ast_pbx_run(), ast_pbx_start(), ast_pthread_create(), ast_request_and_dial(), AST_STATE_UP, ast_verbose(), ast_channel::context, ast_channel::exten, free, LOAD_OH, LOG_ERROR, LOG_WARNING, malloc, ast_channel::name, option_verbose, pbx_builtin_setvar(), ast_channel::priority, and VERBOSE_PREFIX_4. { struct ast_channel *chan; struct async_stat *as; int res = -1; char *var, *tmp; struct outgoing_helper oh; pthread_attr_t attr; if (sync) { LOAD_OH(oh); chan = __ast_request_and_dial(type, format, data, timeout, reason, callingpres, callerid, &oh, uniqueid); if (chan) { pbx_builtin_setaccount(chan, account); if (chan->_state == AST_STATE_UP) { res = 0; if (option_verbose > 3) ast_verbose(VERBOSE_PREFIX_4 "Channel %s was answered.\n", chan->name); if (sync > 1) { if (ast_pbx_run(chan)) { ast_log(LOG_ERROR, "Unable to run PBX on %s\n", chan->name); ast_hangup(chan); res = -1; } } else { if (ast_pbx_start(chan)) { ast_log(LOG_ERROR, "Unable to start PBX on %s\n", chan->name); ast_hangup(chan); res = -1; } } } else { if (option_verbose > 3) ast_verbose(VERBOSE_PREFIX_4 "Channel %s was never answered.\n", chan->name); ast_hangup(chan); } } if(res < 0) { /* the call failed for some reason */ /* create a fake channel and execute the "failed" extension (if it exists) within the requested context */ /* check if "failed" exists */ if (ast_exists_extension(chan, context, "failed", 1, NULL)) { chan = ast_channel_alloc(0); if (chan) { strncpy(chan->name, "OutgoingSpoolFailed", sizeof(chan->name) - 1); if (context && !ast_strlen_zero(context)) strncpy(chan->context, context, sizeof(chan->context) - 1); strncpy(chan->exten, "failed", sizeof(chan->exten) - 1); chan->priority = 1; if (variable) { tmp = ast_strdupa(variable); for (var = strtok_r(tmp, "|", &tmp); var; var = strtok_r(NULL, "|", &tmp)) { pbx_builtin_setvar( chan, var ); } } ast_pbx_run(chan); } else ast_log(LOG_WARNING, "Can't allocate the channel structure, skipping execution of extension 'failed'\n"); } } } else { as = malloc(sizeof(struct async_stat)); if (!as) return -1; memset(as, 0, sizeof(struct async_stat)); chan = ast_request_and_dial(type, format, data, timeout, reason, callingpres, callerid, uniqueid); if (!chan) { free(as); return -1; } pbx_builtin_setaccount(chan, account); as->chan = chan; strncpy(as->context, context, sizeof(as->context) - 1); strncpy(as->exten, exten, sizeof(as->exten) - 1); as->priority = priority; as->timeout = timeout; if (variable) { tmp = ast_strdupa(variable); for (var = strtok_r(tmp, "|", &tmp); var; var = strtok_r(NULL, "|", &tmp)) pbx_builtin_setvar( chan, var ); } pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); if (ast_pthread_create(&as->p, &attr, async_wait, as)) { ast_log(LOG_WARNING, "Failed to start async wait\n"); free(as); ast_hangup(chan); return -1; } res = 0; } return res; }

int ast_pbx_run (  struct ast_channel *  c  )

Execute the PBX in the current thread. Parameters: c  channel to run the pbx on This executes the PBX on a given channel. It allocates a new PBX structure for the channel, and provides all PBX functionality. Definition at line 1776 of file pbx.c. References ast_channel::_softhangup, ast_channel::amaflags, ast_cdr_alloc(), ast_cdr_init(), ast_cdr_start(), ast_cdr_update(), ast_exists_extension(), ast_hangup(), ast_log(), ast_matchmore_extension(), AST_PBX_KEEPALIVE, AST_SOFTHANGUP_ASYNCGOTO, AST_SOFTHANGUP_TIMEOUT, ast_spawn_extension(), ast_verbose(), ast_waitfordigit(), ast_channel::callerid, ast_channel::cdr, ast_channel::context, ast_pbx::dtimeout, ast_channel::exten, free, LOG_DEBUG, LOG_ERROR, LOG_WARNING, malloc, ast_channel::name, option_debug, option_verbose, ast_channel::pbx, pbx_builtin_setvar_helper(), ast_channel::priority, ast_pbx::rtimeout, VERBOSE_PREFIX_2, VERBOSE_PREFIX_3, and ast_channel::whentohangup. Referenced by ast_pbx_outgoing_exten(). { int firstpass = 1; char digit; char exten[256]; int pos; int waittime; int res=0; /* A little initial setup here */ if (c->pbx) ast_log(LOG_WARNING, "%s already has PBX structure??\n", c->name); c->pbx = malloc(sizeof(struct ast_pbx)); if (!c->pbx) { ast_log(LOG_ERROR, "Out of memory\n"); return -1; } if (c->amaflags) { if (c->cdr) { ast_log(LOG_WARNING, "%s already has a call record??\n", c->name); } else { c->cdr = ast_cdr_alloc(); if (!c->cdr) { ast_log(LOG_WARNING, "Unable to create Call Detail Record\n"); free(c->pbx); return -1; } ast_cdr_init(c->cdr, c); } } memset(c->pbx, 0, sizeof(struct ast_pbx)); /* Set reasonable defaults */ c->pbx->rtimeout = 10; c->pbx->dtimeout = 5; /* Start by trying whatever the channel is set to */ if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) { /* JK02: If not successfull fall back to 's' */ if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Starting %s at %s,%s,%d failed so falling back to exten 's'\n", c->name, c->context, c->exten, c->priority); strncpy(c->exten, "s", sizeof(c->exten)-1); if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) { /* JK02: And finally back to default if everything else failed */ if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Starting %s at %s,%s,%d still failed so falling back to context 'default'\n", c->name, c->context, c->exten, c->priority); strncpy(c->context, "default", sizeof(c->context)-1); } c->priority = 1; } if (c->cdr) ast_cdr_start(c->cdr); for(;;) { pos = 0; digit = 0; while(ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) { memset(exten, 0, sizeof(exten)); if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->callerid))) { /* Something bad happened, or a hangup has been requested. */ if (((res >= '0') && (res <= '9')) || ((res >= 'A') && (res <= 'F')) || (res == '*') || (res == '#')) { ast_log(LOG_DEBUG, "Oooh, got something to jump out with ('%c')!\n", res); memset(exten, 0, sizeof(exten)); pos = 0; exten[pos++] = digit = res; break; } switch(res) { case AST_PBX_KEEPALIVE: if (option_debug) ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited KEEPALIVE on '%s'\n", c->context, c->exten, c->priority, c->name); else if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited KEEPALIVE on '%s'\n", c->context, c->exten, c->priority, c->name); goto out; break; default: if (option_debug) ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name); else if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name); if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) { c->_softhangup =0; break; } /* atimeout */ if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT) { break; } if (c->cdr) { ast_cdr_update(c); } goto out; } } if ((c->_softhangup == AST_SOFTHANGUP_TIMEOUT) && (ast_exists_extension(c,c->context,"T",1,c->callerid))) { strncpy(c->exten,"T",sizeof(c->exten) - 1); /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */ c->whentohangup = 0; c->priority = 0; c->_softhangup &= ~AST_SOFTHANGUP_TIMEOUT; } else if (c->_softhangup) { ast_log(LOG_DEBUG, "Extension %s, priority %d returned normally even though call was hung up\n", c->exten, c->priority); goto out; } firstpass = 0; c->priority++; } if (!ast_exists_extension(c, c->context, c->exten, 1, c->callerid)) { /* It's not a valid extension anymore */ if (ast_exists_extension(c, c->context, "i", 1, c->callerid)) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Sent into invalid extension '%s' in context '%s' on %s\n", c->exten, c->context, c->name); pbx_builtin_setvar_helper(c, "INVALID_EXTEN", c->exten); strncpy(c->exten, "i", sizeof(c->exten)-1); c->priority = 1; } else { ast_log(LOG_WARNING, "Channel '%s' sent into invalid extension '%s' in context '%s', but no invalid handler\n", c->name, c->exten, c->context); goto out; } } else if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT) { /* If we get this far with AST_SOFTHANGUP_TIMEOUT, then we know that the "T" extension is next. */ c->_softhangup = 0; } else { /* Done, wait for an extension */ if (digit) waittime = c->pbx->dtimeout; else waittime = c->pbx->rtimeout; while (ast_matchmore_extension(c, c->context, exten, 1, c->callerid)) { /* As long as we're willing to wait, and as long as it's not defined, keep reading digits until we can't possibly get a right answer anymore. */ digit = ast_waitfordigit(c, waittime * 1000); if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) { c->_softhangup = 0; } else { if (!digit) /* No entry */ break; if (digit < 0) /* Error, maybe a hangup */ goto out; exten[pos++] = digit; waittime = c->pbx->dtimeout; } } if (ast_exists_extension(c, c->context, exten, 1, c->callerid)) { /* Prepare the next cycle */ strncpy(c->exten, exten, sizeof(c->exten)-1); c->priority = 1; } else { /* No such extension */ if (!ast_strlen_zero(exten)) { /* An invalid extension */ if (ast_exists_extension(c, c->context, "i", 1, c->callerid)) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Invalid extension '%s' in context '%s' on %s\n", exten, c->context, c->name); pbx_builtin_setvar_helper(c, "INVALID_EXTEN", exten); strncpy(c->exten, "i", sizeof(c->exten)-1); c->priority = 1; } else { ast_log(LOG_WARNING, "Invalid extension '%s', but no rule 'i' in context '%s'\n", exten, c->context); goto out; } } else { /* A simple timeout */ if (ast_exists_extension(c, c->context, "t", 1, c->callerid)) { if (option_verbose > 2) ast_verbose( VERBOSE_PREFIX_3 "Timeout on %s\n", c->name); strncpy(c->exten, "t", sizeof(c->exten)-1); c->priority = 1; } else { ast_log(LOG_WARNING, "Timeout, but no rule 't' in context '%s'\n", c->context); goto out; } } } if (c->cdr) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_2 "CDR updated on %s\n",c->name); ast_cdr_update(c); } } } if (firstpass) ast_log(LOG_WARNING, "Don't know what to do with '%s'\n", c->name); out: if ((res != AST_PBX_KEEPALIVE) && ast_exists_extension(c, c->context, "h", 1, c->callerid)) { c->exten[0] = 'h'; c->exten[1] = '\0'; c->priority = 1; while(ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) { if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->callerid))) { /* Something bad happened, or a hangup has been requested. */ if (option_debug) ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name); else if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name); break; } c->priority++; } } pbx_destroy(c->pbx); c->pbx = NULL; if (res != AST_PBX_KEEPALIVE) ast_hangup(c); return 0; }

void* ast_pbx_run_app (  void *  data  )

Definition at line 4169 of file pbx.c. References app_tmp::app, ast_hangup(), ast_log(), ast_verbose(), app_tmp::chan, app_tmp::data, free, LOG_WARNING, ast_channel::name, option_verbose, pbx_exec(), pbx_findapp(), and VERBOSE_PREFIX_4. Referenced by ast_pbx_outgoing_app(). { struct app_tmp *tmp = data; struct ast_app *app; app = pbx_findapp(tmp->app); if (app) { if (option_verbose > 3) ast_verbose(VERBOSE_PREFIX_4 "Lauching %s(%s) on %s\n", tmp->app, tmp->data, tmp->chan->name); pbx_exec(tmp->chan, app, tmp->data, 1); } else ast_log(LOG_WARNING, "No such application '%s'\n", tmp->app); ast_hangup(tmp->chan); free(tmp); return NULL; }

int ast_pbx_start (  struct ast_channel *  c  )

Create a new thread and start the PBX (or whatever). Parameters: c  channel to start the pbx on Starts a pbx thread on a given channel It returns -1 on failure, and 0 on success Definition at line 2001 of file pbx.c. References ast_log(), ast_pthread_create(), and LOG_WARNING. Referenced by ast_async_goto(), and ast_pbx_outgoing_exten(). { pthread_t t; pthread_attr_t attr; if (!c) { ast_log(LOG_WARNING, "Asked to start thread on NULL channel?\n"); return -1; } /* Start a new thread, and get something handling this channel. */ pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); if (ast_pthread_create(&t, &attr, pbx_thread, c)) { ast_log(LOG_WARNING, "Failed to create new channel thread\n"); return -1; } return 0; }

int ast_register_application (  char *  app, int(*)(struct ast_channel *, void *)  execute, char *  synopsis, char *  description )

Add an application. The function 'execute' should return non-zero if the line needs to be hung up. Parameters: app  Short name of the application execute  a function callback to execute the application synopsis  a short description of the application description  long description of the application Include a one-line synopsis (e.g. 'hangs up a channel') and a more lengthy, multiline description with more detail, including under what conditions the application will return 0 or -1. This registers an application with asterisks internal application list. Please note: The individual applications themselves are responsible for registering and unregistering CLI commands. It returns 0 on success, -1 on failure. Definition at line 2309 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), COLOR_BRCYAN, LOG_ERROR, LOG_WARNING, malloc, ast_app::name, ast_app::next, option_verbose, term_color(), and VERBOSE_PREFIX_2. Referenced by load_pbx(). { struct ast_app *tmp, *prev, *cur; char tmps[80]; if (ast_mutex_lock(&applock)) { ast_log(LOG_ERROR, "Unable to lock application list\n"); return -1; } tmp = apps; while(tmp) { if (!strcasecmp(app, tmp->name)) { ast_log(LOG_WARNING, "Already have an application '%s'\n", app); ast_mutex_unlock(&applock); return -1; } tmp = tmp->next; } tmp = malloc(sizeof(struct ast_app)); if (tmp) { memset(tmp, 0, sizeof(struct ast_app)); strncpy(tmp->name, app, sizeof(tmp->name)-1); tmp->execute = execute; tmp->synopsis = synopsis; tmp->description = description; /* Store in alphabetical order */ cur = apps; prev = NULL; while(cur) { if (strcasecmp(tmp->name, cur->name) < 0) break; prev = cur; cur = cur->next; } if (prev) { tmp->next = prev->next; prev->next = tmp; } else { tmp->next = apps; apps = tmp; } } else { ast_log(LOG_ERROR, "Out of memory\n"); ast_mutex_unlock(&applock); return -1; } if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Registered application '%s'\n", term_color(tmps, tmp->name, COLOR_BRCYAN, 0, sizeof(tmps))); ast_mutex_unlock(&applock); return 0; }

int ast_register_switch (  struct ast_switch *  sw  )

Register an alternative switch. Parameters: sw  switch to register This function registers a populated ast_switch structure with the asterisk switching architecture. It returns 0 on success, and other than 0 on failure Definition at line 2360 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_ERROR, LOG_WARNING, ast_switch::name, and ast_switch::next. { struct ast_switch *tmp, *prev=NULL; if (ast_mutex_lock(&switchlock)) { ast_log(LOG_ERROR, "Unable to lock switch lock\n"); return -1; } tmp = switches; while(tmp) { if (!strcasecmp(tmp->name, sw->name)) break; prev = tmp; tmp = tmp->next; } if (tmp) { ast_mutex_unlock(&switchlock); ast_log(LOG_WARNING, "Switch '%s' already found\n", sw->name); return -1; } sw->next = NULL; if (prev) prev->next = sw; else switches = sw; ast_mutex_unlock(&switchlock); return 0; }

int ast_spawn_extension (  struct ast_channel *  c, char *  context, char *  exten, int  priority, char *  callerid )

Launch a new extension (i.e. new stack). Parameters: c  not important context  which context to generate the extension within exten  new extension to add priority  priority of new extension callerid  callerid of extension This adds a new extension to the asterisk extension list. It returns 0 on success, -1 on failure. Definition at line 1771 of file pbx.c. References HELPER_SPAWN. Referenced by ast_pbx_run(). { return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_SPAWN); }

int ast_unlock_context (  struct ast_context *  con  )

Unlocks the given context. Parameters: con  context to unlock Unlocks the given context Returns 0 on success, -1 on failure Definition at line 4946 of file pbx.c. References ast_mutex_unlock, and ast_context::lock. { return ast_mutex_unlock(&con->lock); }

int ast_unlock_contexts (  void   )

Unlocks contexts. Returns 0 on success, -1 on failure Definition at line 4933 of file pbx.c. References ast_mutex_unlock. Referenced by ast_add_extension(), ast_context_add_ignorepat(), ast_context_add_include(), ast_context_add_switch(), ast_context_remove_extension(), ast_context_remove_ignorepat(), ast_context_remove_include(), and ast_context_remove_switch(). { return ast_mutex_unlock(&conlock); }

int ast_unregister_application (  char *  app  )

Remove an application. Parameters: app  name of the application (does not have to be the same string as the one that was registered) This unregisters an application from asterisk's internal registration mechanisms. It returns 0 on success, and -1 on failure. Definition at line 2944 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), free, LOG_ERROR, ast_app::name, ast_app::next, option_verbose, and VERBOSE_PREFIX_2. { struct ast_app *tmp, *tmpl = NULL; if (ast_mutex_lock(&applock)) { ast_log(LOG_ERROR, "Unable to lock application list\n"); return -1; } tmp = apps; while(tmp) { if (!strcasecmp(app, tmp->name)) { if (tmpl) tmpl->next = tmp->next; else apps = tmp->next; if (option_verbose > 1) ast_verbose( VERBOSE_PREFIX_2 "Unregistered application '%s'\n", tmp->name); free(tmp); ast_mutex_unlock(&applock); return 0; } tmpl = tmp; tmp = tmp->next; } ast_mutex_unlock(&applock); return -1; }

void ast_unregister_switch (  struct ast_switch *  sw  )

Unregister an alternative switch. Parameters: sw  switch to unregister Unregisters a switch from asterisk. Returns nothing Definition at line 2388 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_ERROR, and ast_switch::next. { struct ast_switch *tmp, *prev=NULL; if (ast_mutex_lock(&switchlock)) { ast_log(LOG_ERROR, "Unable to lock switch lock\n"); return; } tmp = switches; while(tmp) { if (tmp == sw) { if (prev) prev->next = tmp->next; else switches = tmp->next; tmp->next = NULL; break; } prev = tmp; tmp = tmp->next; } ast_mutex_unlock(&switchlock); }

struct ast_exten* ast_walk_context_extensions (  struct ast_context *  con, struct ast_exten *  exten )

Definition at line 5048 of file pbx.c. References ast_exten::next. { if (!exten) return con ? con->root : NULL; else return exten->next; }

struct ast_ignorepat* ast_walk_context_ignorepats (  struct ast_context *  con, struct ast_ignorepat *  ip )

Definition at line 5084 of file pbx.c. References ast_ignorepat::next. { if (!ip) return con ? con->ignorepats : NULL; else return ip->next; }

struct ast_include* ast_walk_context_includes (  struct ast_context *  con, struct ast_include *  inc )

Definition at line 5075 of file pbx.c. References ast_include::next. Referenced by ast_context_verify_includes(). { if (!inc) return con ? con->includes : NULL; else return inc->next; }

struct ast_sw* ast_walk_context_switches (  struct ast_context *  con, struct ast_sw *  sw )

Definition at line 5057 of file pbx.c. References ast_sw::next. { if (!sw) return con ? con->alts : NULL; else return sw->next; }

struct ast_context* ast_walk_contexts (  struct ast_context *  con  )

Definition at line 5040 of file pbx.c. References ast_context::next. Referenced by ast_add_extension(), ast_context_add_ignorepat(), ast_context_add_include(), ast_context_add_switch(), ast_context_remove_extension(), ast_context_remove_ignorepat(), ast_context_remove_include(), and ast_context_remove_switch(). { if (!con) return contexts; else return con->next; }

struct ast_exten* ast_walk_extension_priorities (  struct ast_exten *  exten, struct ast_exten *  priority )

Definition at line 5066 of file pbx.c. References ast_exten::peer. { if (!priority) return exten; else return priority->peer; }

int load_pbx (  void   )

Definition at line 4898 of file pbx.c. References ast_cli_register(), AST_LIST_HEAD_INIT, ast_log(), ast_register_application(), ast_verbose(), LOG_ERROR, option_verbose, and VERBOSE_PREFIX_1. Referenced by main(). { int x; /* Initialize the PBX */ if (option_verbose) { ast_verbose( "Asterisk PBX Core Initializing\n"); ast_verbose( "Registering builtin applications:\n"); } AST_LIST_HEAD_INIT(&globals); ast_cli_register(&show_applications_cli); ast_cli_register(&show_application_cli); ast_cli_register(&show_dialplan_cli); ast_cli_register(&show_switches_cli); /* Register builtin applications */ for (x=0; x<sizeof(builtins) / sizeof(struct pbx_builtin); x++) { if (option_verbose) ast_verbose( VERBOSE_PREFIX_1 "[%s]\n", builtins[x].name); if (ast_register_application(builtins[x].name, builtins[x].execute, builtins[x].synopsis, builtins[x].description)) { ast_log(LOG_ERROR, "Unable to register builtin application '%s'\n", builtins[x].name); return -1; } } return 0; }

void pbx_builtin_clear_globals (  void   )

Definition at line 4786 of file pbx.c. References AST_LIST_EMPTY, AST_LIST_FIRST, AST_LIST_REMOVE_HEAD, and ast_var_delete(). { struct ast_var_t *vardata; while (!AST_LIST_EMPTY(&globals)) { vardata = AST_LIST_FIRST(&globals); AST_LIST_REMOVE_HEAD(&globals, entries); ast_var_delete(vardata); } }

char * pbx_builtin_getvar_helper (  struct ast_channel *  chan, char *  name )

Definition at line 4686 of file pbx.c. References AST_LIST_TRAVERSE, ast_var_name(), and ast_var_value(). { struct ast_var_t *variables; struct varshead *headp; if (chan) headp=&chan->varshead; else headp=&globals; if (name) { AST_LIST_TRAVERSE(headp,variables,entries) { if (!strcmp(name, ast_var_name(variables))) return ast_var_value(variables); } if (headp != &globals) { /* Check global variables if we haven't already */ headp = &globals; AST_LIST_TRAVERSE(headp,variables,entries) { if (!strcmp(name, ast_var_name(variables))) return ast_var_value(variables); } } } return NULL; }

int pbx_builtin_setvar (  struct ast_channel *  , void *  )

Definition at line 4739 of file pbx.c. References ast_log(), LOG_WARNING, and pbx_builtin_setvar_helper(). Referenced by __ast_request_and_dial(), ast_pbx_outgoing_app(), and ast_pbx_outgoing_exten(). { char *name; char *value; char *stringp=NULL; if (!data || ast_strlen_zero(data)) { ast_log(LOG_WARNING, "Ignoring, since there is no variable to set\n"); return 0; } stringp=data; name=strsep(&stringp,"="); value=strsep(&stringp,"\0"); pbx_builtin_setvar_helper(chan,name,value); return(0); }

void pbx_builtin_setvar_helper (  struct ast_channel *  chan, char *  name, char *  value )

Definition at line 4713 of file pbx.c. References AST_LIST_INSERT_HEAD, AST_LIST_REMOVE, AST_LIST_TRAVERSE, ast_var_assign(), ast_var_delete(), ast_var_name(), ast_verbose(), option_verbose, and VERBOSE_PREFIX_3. Referenced by ast_pbx_run(), and pbx_builtin_setvar(). { struct ast_var_t *newvariable; struct varshead *headp; if (chan) headp=&chan->varshead; else headp=&globals; AST_LIST_TRAVERSE (headp,newvariable,entries) { if (strcasecmp(ast_var_name(newvariable),name)==0) { /* there is already such a variable, delete it */ AST_LIST_REMOVE(headp,newvariable,ast_var_t,entries); ast_var_delete(newvariable); break; } } if (value) { if ((option_verbose > 1) && (headp == &globals)) ast_verbose(VERBOSE_PREFIX_3 "Setting global variable '%s' to '%s'\n",name, value); newvariable=ast_var_assign(name,value); AST_LIST_INSERT_HEAD(headp,newvariable,entries); } }

int pbx_exec (  struct ast_channel *  c, struct ast_app *  app, void *  data, int  newstack )

executes an application Parameters: c  channel to execute on app  which app to execute data  the data passed into the app newstack  stack pointer This application executes an application on a given channel. It saves the stack and executes the given appliation passing in the given data. It returns 0 on success, and -1 on failure Definition at line 426 of file pbx.c. References ast_channel::app, ast_channel::appl, ast_cdr_setapp(), AST_CHANNEL_MAX_STACK, ast_log(), ast_channel::cdr, ast_channel::data, ast_app::execute, ast_channel::jmp, LOG_WARNING, ast_app::name, and ast_channel::stack. Referenced by ast_pbx_run_app(). { /* This function is special. It saves the stack so that no matter how many times it is called, it returns to the same place */ int res; char *saved_c_appl; char *saved_c_data; int stack = c->stack; int (*execute)(struct ast_channel *chan, void *data) = app->execute; if (newstack && stack > AST_CHANNEL_MAX_STACK - 2) { /* Don't allow us to go over the max number of stacks we permit saving. */ ast_log(LOG_WARNING, "Stack overflow, cannot create another stack\n"); return -1; } if (newstack && (res = setjmp(c->jmp[++c->stack]))) { /* Okay, here's where it gets weird. If newstack is non-zero, then we increase the stack increment, but setjmp is not going to return until longjmp is called -- when the application exec'd is finished running. */ if (res == 1) res = 0; if (c->stack != stack + 1) ast_log(LOG_WARNING, "Stack returned to an unexpected place!\n"); else if (c->app[c->stack]) ast_log(LOG_WARNING, "Application may have forgotten to free its memory\n"); c->stack = stack; return res; } else { if (c->cdr) ast_cdr_setapp(c->cdr, app->name, data); /* save channel values */ saved_c_appl= c->appl; saved_c_data= c->data; c->appl = app->name; c->data = data; res = execute(c, data); /* restore channel values */ c->appl= saved_c_appl; c->data= saved_c_data; /* Any application that returns, we longjmp back, just in case. */ if (c->stack != stack + 1) ast_log(LOG_WARNING, "Stack is not at expected value\n"); longjmp(c->jmp[stack+1], res); /* Never returns */ } }

struct ast_app* pbx_findapp (  char *  app  )

Look up an application. Parameters: app  name of the app This function searches for the ast_app structure within the apps that are registered for the one with the name you passed in. Returns the ast_app structure that matches on success, or NULL on failure Definition at line 493 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_WARNING, ast_app::name, and ast_app::next. Referenced by ast_pbx_run_app(). { struct ast_app *tmp; if (ast_mutex_lock(&applock)) { ast_log(LOG_WARNING, "Unable to obtain application lock\n"); return NULL; } tmp = apps; while(tmp) { if (!strcasecmp(tmp->name, app)) break; tmp = tmp->next; } ast_mutex_unlock(&applock); return tmp; }

void pbx_substitute_variables_helper (  struct ast_channel *  c, const char *  cp1, char *  cp2, int  count )

Definition at line 1044 of file pbx.c. References ast_expr(), ast_log(), free, LOG_DEBUG, LOG_NOTICE, and pbx_substitute_variables_helper(). Referenced by pbx_substitute_variables_helper(). { char *cp4; const char *tmp, *whereweare; int length; char workspace[4096]; char ltmp[4096], var[4096]; char *nextvar, *nextexp; char *vars, *vare; int pos, brackets, needsub, len; /* Substitutes variables into cp2, based on string cp1, and assuming cp2 to be zero-filled */ whereweare=tmp=cp1; while(!ast_strlen_zero(whereweare) && count) { /* Assume we're copying the whole remaining string */ pos = strlen(whereweare); /* Look for a variable */ nextvar = strstr(whereweare, "${"); /* Look for an expression */ nextexp = strstr(whereweare, "$["); /* Pick the first one only */ if (nextvar && nextexp) { if (nextvar < nextexp) nextexp = NULL; else nextvar = NULL; } /* If there is one, we only go that far */ if (nextvar) pos = nextvar - whereweare; else if (nextexp) pos = nextexp - whereweare; /* Can't copy more than 'count' bytes */ if (pos > count) pos = count; /* Copy that many bytes */ memcpy(cp2, whereweare, pos); count -= pos; cp2 += pos; whereweare += pos; if (nextvar) { /* We have a variable. Find the start and end, and determine if we are going to have to recursively call ourselves on the contents */ vars = vare = nextvar + 2; brackets = 1; needsub = 0; /* Find the end of it */ while(brackets && *vare) { if ((vare[0] == '$') && (vare[1] == '{')) { needsub++; brackets++; } else if (vare[0] == '}') { brackets--; } else if ((vare[0] == '$') && (vare[1] == '[')) needsub++; vare++; } if (brackets) ast_log(LOG_NOTICE, "Error in extension logic (missing '}')\n"); len = vare - vars - 1; /* Skip totally over variable name */ whereweare += ( len + 3); /* Store variable name (and truncate) */ memset(var, 0, sizeof(var)); strncpy(var, vars, sizeof(var) - 1); var[len] = '\0'; /* Substitute if necessary */ if (needsub) { memset(ltmp, 0, sizeof(ltmp)); pbx_substitute_variables_helper(c, var, ltmp, sizeof(ltmp) - 1); vars = ltmp; } else { vars = var; } /* Retrieve variable value */ workspace[0] = '\0'; pbx_substitute_variables_temp(c,vars,&cp4, workspace, sizeof(workspace)); if (cp4) { length = strlen(cp4); if (length > count) length = count; memcpy(cp2, cp4, length); count -= length; cp2 += length; } } else if (nextexp) { /* We have an expression. Find the start and end, and determine if we are going to have to recursively call ourselves on the contents */ vars = vare = nextexp + 2; brackets = 1; needsub = 0; /* Find the end of it */ while(brackets && *vare) { if ((vare[0] == '$') && (vare[1] == '[')) { needsub++; brackets++; vare++; } else if (vare[0] == '[') { brackets++; } else if (vare[0] == ']') { brackets--; } else if ((vare[0] == '$') && (vare[1] == '{')) { needsub++; vare++; } vare++; } if (brackets) ast_log(LOG_NOTICE, "Error in extension logic (missing ']')\n"); len = vare - vars - 1; /* Skip totally over variable name */ whereweare += ( len + 3); /* Store variable name (and truncate) */ memset(var, 0, sizeof(var)); strncpy(var, vars, sizeof(var) - 1); var[len] = '\0'; /* Substitute if necessary */ if (needsub) { memset(ltmp, 0, sizeof(ltmp)); pbx_substitute_variables_helper(c, var, ltmp, sizeof(ltmp) - 1); vars = ltmp; } else { vars = var; } /* Evaluate expression */ cp4 = ast_expr(vars); ast_log(LOG_DEBUG, "Expression is '%s'\n", cp4); if (cp4) { length = strlen(cp4); if (length > count) length = count; memcpy(cp2, cp4, length); count -= length; cp2 += length; free(cp4); } } else break; } }

---

Variable Documentation

struct ast_hint* hints = NULL

Definition at line 423 of file pbx.c.

struct ast_state_cb* statecbs = NULL

Definition at line 424 of file pbx.c.

struct ast_switch* switches = NULL

Definition at line 419 of file pbx.c.

---