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 <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.

Data Structures
struct	ast_exten
struct	ast_include
struct	ast_sw
struct	ast_ignorepat
struct	ast_context
struct	ast_app
struct	ast_state_cb
struct	ast_hint
struct	pbx_builtin
struct	async_stat
struct	app_tmp
Defines
#define	AST_PBX_MAX_STACK   64
#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)
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 maxlen, 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, int lock)
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 needlock)
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, char *callerid, char *variable, char *account)
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)
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)
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   64

Definition at line 409 of file pbx.c.

#define EXTENSION_MATCH_CORE (  data, pattern, match   )

Definition at line 494 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 2885 of file pbx.c.

#define HELPER_CANMATCH   3

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

#define HELPER_EXEC   2

Definition at line 413 of file pbx.c.

#define HELPER_EXISTS   0

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

#define HELPER_MATCHMORE   4

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

#define HELPER_SPAWN   1

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

#define LOG

#define STATUS_NO_CONTEXT   1

Definition at line 614 of file pbx.c.

#define STATUS_NO_EXTENSION   2

Definition at line 615 of file pbx.c.

#define STATUS_NO_PRIORITY   3

Definition at line 616 of file pbx.c.

#define STATUS_SUCCESS   4

Definition at line 617 of file pbx.c.

---

Function Documentation

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

Definition at line 4066 of file pbx.c. { 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; if (lock) 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); } free(tmp); if (!con) { /* Might need to get another one -- restart */ tmp = contexts; tmpl = NULL; tmpil = NULL; continue; } if (lock) ast_mutex_unlock(&conlock); return; } tmpl = tmp; tmp = tmp->next; } if (lock) ast_mutex_unlock(&conlock); }

int ast_add_extension (  char *  context, int  replace, char *  extension, int  priority, char *  callerid, char *  application, void *  data, void(*  datad)(void *), 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 3472 of file pbx.c. { 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(*  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. For details about the arguements, check ast_add_extension() Definition at line 3605 of file pbx.c. Referenced by ast_ignore_pattern(). { #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 { strcpy(tmp->cidmatch, ""); 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) { res= strcasecmp(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, int  needlock )

Definition at line 3498 of file pbx.c. { int res = 0; if (needlock) ast_mutex_lock(&chan->lock); if (chan->pbx) { /* This channel is currently in the PBX */ if (context && strlen(context)) strncpy(chan->context, context, sizeof(chan->context) - 1); if (exten && strlen(exten)) strncpy(chan->exten, exten, sizeof(chan->context) - 1); if (priority) chan->priority = priority - 1; ast_softhangup_nolock(chan, AST_SOFTHANGUP_ASYNCGOTO); if (needlock) ast_mutex_unlock(&chan->lock); } 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; struct ast_frame *f; 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 && strlen(context)) strncpy(tmpchan->context, context, sizeof(tmpchan->context) - 1); else strncpy(tmpchan->context, chan->context, sizeof(tmpchan->context) - 1); if (exten && strlen(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); if (needlock) ast_mutex_unlock(&chan->lock); /* Make the masquerade happen by reading a frame from the tmp channel */ f = ast_read(tmpchan); if (f) ast_frfree(f); /* 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; if (needlock) ast_mutex_unlock(&chan->lock); } } return res; }

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

Definition at line 3566 of file pbx.c. { struct ast_channel *chan; chan = ast_channel_walk(NULL); while(chan) { if (!strcasecmp(channame, chan->name)) break; chan = ast_channel_walk(chan); } if (chan) return ast_async_goto(chan, context, exten, priority, 1); return -1; }

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 1645 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 3393 of file pbx.c. { 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 3417 of file pbx.c. References ast_mutex_unlock, and ast_context::lock. { 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 2857 of file pbx.c. { 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 3174 of file pbx.c. { 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 3240 of file pbx.c. { 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 3275 of file pbx.c. { 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 2780 of file pbx.c. { 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 4140 of file pbx.c. { __ast_context_destroy(con,registrar,1); }

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 597 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, and ast_context::next. { 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 2055 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 2091 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, free, ast_context::lock, ast_exten::next, ast_exten::peer, PRIORITY_HINT, 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) && (!strcmp(exten->registrar, 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 && (!strcmp(peer->registrar, 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 3334 of file pbx.c. { 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 3358 of file pbx.c. { 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 == ip->registrar || !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 1911 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 1947 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, free, ast_context::includes, ast_context::lock, and ast_include::next. 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) && (!strcmp(i->registrar, 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 1983 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 2019 of file pbx.c. References ast_context::alts, ast_mutex_lock, ast_mutex_unlock, free, ast_context::lock, and ast_sw::next. 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) && (!strcmp(i->registrar, 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 4741 of file pbx.c. { 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 1321 of file pbx.c. References ast_get_extension_app(), AST_MAX_EXTENSION, ast_mutex_lock, ast_mutex_unlock, ast_state_cb::callback, hints, and statecbs. { 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)-1, fmt, ap); va_end(ap); rest = strchr(device, '-'); if (rest) { *rest = 0; } ast_mutex_lock(&hintlock); list = hints; while (list) { strcpy(hint, ast_get_extension_app(list->exten)); 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 1640 of file pbx.c. References HELPER_EXISTS. Referenced by 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 564 of file pbx.c. References EXTENSION_MATCH_CORE. { 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 1310 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 1388 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_state_cb_type, ast_state_cb::data, hints, malloc, ast_hint::next, and statecbs. 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 1468 of file pbx.c. References ast_mutex_lock, ast_mutex_unlock, ast_state_cb_type, ast_hint::callbacks, free, hints, ast_state_cb::next, and statecbs. { 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 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 4612 of file pbx.c. References ast_ignorepat::pattern. Referenced by ast_context_remove_extension(), ast_context_remove_include(), ast_context_remove_switch(), and ast_ignore_pattern(). { return con ? con->name : NULL; }

char* ast_get_context_registrar (  struct ast_context *  c  )

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

char* ast_get_extension_app (  struct ast_exten *  e  )

Definition at line 4660 of file pbx.c. References ast_sw::data. 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 4665 of file pbx.c. References ast_sw::registrar. { return e ? e->data : NULL; }

char* ast_get_extension_name (  struct ast_exten *  exten  )

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

int ast_get_extension_priority (  struct ast_exten *  exten  )

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

char* ast_get_extension_registrar (  struct ast_exten *  e  )

Definition at line 4645 of file pbx.c. References ast_exten::app. { 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 1629 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), maxlen); return -1; } return 0; }

char* ast_get_ignorepat_name (  struct ast_ignorepat *  ip  )

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

char* ast_get_ignorepat_registrar (  struct ast_ignorepat *  ip  )

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

char* ast_get_include_name (  struct ast_include *  inc  )

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

char* ast_get_include_registrar (  struct ast_include *  i  )

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

char* ast_get_switch_data (  struct ast_sw *  sw  )

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

char* ast_get_switch_name (  struct ast_sw *  sw  )

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

char* ast_get_switch_registrar (  struct ast_sw *  sw  )

Definition at line 4680 of file pbx.c. References ast_exten::next, and ast_context::root. { 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 3451 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 *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 4599 of file pbx.c. { 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 4586 of file pbx.c. Referenced by ast_context_remove_extension(), ast_context_remove_include(), ast_context_remove_switch(), and ast_ignore_pattern(). { 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 1650 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 2825 of file pbx.c. { struct ast_context *tmp, *lasttmp = NULL; tmp = *extcontexts; ast_mutex_lock(&conlock); if (registrar) { __ast_context_destroy(NULL,registrar,0); while (tmp) { lasttmp = tmp; tmp = tmp->next; } } else { while (tmp) { __ast_context_destroy(tmp,tmp->registrar,0); 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; }

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 )

Definition at line 3976 of file pbx.c. { struct ast_channel *chan; struct async_stat *as; struct app_tmp *tmp; char *var, *vartmp; int res = -1; pthread_attr_t attr; if (!app || !strlen(app)) return -1; if (sync) { chan = ast_request_and_dial(type, format, data, timeout, reason, callerid); 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 (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, callerid); 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 (pthread_create(&as->p, NULL, 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, char *  callerid, char *  variable, char *  account )

Definition at line 3865 of file pbx.c. References option_verbose. { 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, callerid, &oh); 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); } } else { /* 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 && strlen(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, callerid); 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; pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); if (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 1660 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, EVENT_FLAG_CALL, ast_channel::exten, free, LOG_DEBUG, LOG_ERROR, LOG_WARNING, malloc, manager_event(), ast_channel::name, option_debug, option_verbose, ast_channel::pbx, pbx_builtin_setvar_helper(), ast_channel::priority, ast_pbx::rtimeout, ast_channel::uniqueid, VERBOSE_PREFIX_2, VERBOSE_PREFIX_3, and ast_channel::whentohangup. { 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' */ 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 */ 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)); manager_event(EVENT_FLAG_CALL, "Newexten", "Channel: %s\r\n" "Context: %s\r\n" "Extension: %s\r\n" "Priority: %d\r\n" "Uniqueid: %s\r\n", c->name, c->context, c->exten, c->priority, c->uniqueid); 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 (strlen(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, but no rule 'i' in context '%s'\n", 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)) { strcpy(c->exten, "h"); 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; }

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 1887 of file pbx.c. References ast_log(), and LOG_WARNING. { 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 (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(*  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. 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 2195 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_verbose(), COLOR_BRCYAN, LOG_ERROR, LOG_WARNING, malloc, ast_app::next, option_verbose, term_color(), and VERBOSE_PREFIX_2. { 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 2246 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_ERROR, LOG_WARNING, ast_switch::name, ast_switch::next, and switches. { 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 1655 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 4604 of file pbx.c. { return ast_mutex_unlock(&con->lock); }

int ast_unlock_contexts (  void   )

Unlocks contexts. Returns 0 on success, -1 on failure Definition at line 4591 of file pbx.c. Referenced by ast_context_remove_extension(), ast_context_remove_include(), ast_context_remove_switch(), and ast_ignore_pattern(). { 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 2755 of file pbx.c. { 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); 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 2274 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_ERROR, ast_switch::next, and switches. { 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 4696 of file pbx.c. { 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 4732 of file pbx.c. { 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 4723 of file pbx.c. { 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 4705 of file pbx.c. { if (!sw) return con ? con->alts : NULL; else return sw->next; }

struct ast_context* ast_walk_contexts (  struct ast_context *  con  )

Definition at line 4688 of file pbx.c. References ast_context::alts, and ast_sw::next. Referenced by ast_context_remove_extension(), ast_context_remove_include(), ast_context_remove_switch(), and ast_ignore_pattern(). { 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 4714 of file pbx.c. { if (!priority) return exten; else return priority->peer; }

int load_pbx (  void   )

Definition at line 4560 of file pbx.c. 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_cli_register(&show_applications_cli); ast_cli_register(&show_application_cli); ast_cli_register(&show_dialplan_cli); ast_cli_register(&show_switches_cli); 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 4484 of file pbx.c. { 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 4386 of file pbx.c. References 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 4437 of file pbx.c. { char *name; char *value; char *stringp=NULL; if (!data || !strlen(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 4412 of file pbx.c. References AST_LIST_INSERT_HEAD, ast_var_assign(), ast_verbose(), option_verbose, and VERBOSE_PREFIX_3. { 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 362 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. { /* 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; 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); c->appl = app->name; c->data = data; res = execute(c, data); c->appl = NULL; c->data = NULL; /* 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 417 of file pbx.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, LOG_WARNING, and ast_app::next. { 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 945 of file pbx.c. References ast_expr(), ast_log(), free, LOG_DEBUG, and LOG_NOTICE. { char *cp4; const char *tmp, *whereweare; int length; char workspace[256]; char ltmp[256], var[256]; 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(strlen(whereweare) && count) { /* Assume we're copying the whole remaining string */ pos = strlen(whereweare); /* Look for a variable */ nextvar = strstr(whereweare, "${"); nextexp = strstr(whereweare, "$["); 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 */ strcpy(workspace, ""); 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++; } 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; } /* 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 359 of file pbx.c. Referenced by ast_device_state_changed(), ast_extension_state_add(), and ast_extension_state_del().

struct ast_state_cb* statecbs = NULL

Definition at line 360 of file pbx.c. Referenced by ast_device_state_changed(), ast_extension_state_add(), and ast_extension_state_del().

struct ast_switch* switches = NULL

Definition at line 354 of file pbx.c. Referenced by ast_register_switch(), and ast_unregister_switch().

---