pbx.c File Reference

Core PBX routines. More...

#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <ctype.h>
#include <errno.h>
#include <time.h>
#include <sys/time.h>
#include "asterisk.h"
#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/linkedlists.h"
#include "asterisk/say.h"
#include "asterisk/utils.h"
#include "asterisk/causes.h"
#include "asterisk/musiconhold.h"
#include "asterisk/app.h"
#include "asterisk/devicestate.h"
#include "asterisk/compat.h"

Include dependency graph for pbx.c:

Go to the source code of this file.

Data Structures
struct	app_tmp
struct	ast_app
	ast_app: A registered application More...
struct	ast_context
	ast_context: An extension context More...
struct	ast_exten
	ast_exten: An extension The dialplan is saved as a linked list with each context having it's own linked list of extensions - one item per priority. More...
struct	ast_hint
	Structure for dial plan hints. More...
struct	ast_ignorepat
	ast_ignorepat: Ignore patterns in dial plan More...
struct	ast_include
	ast_include: include= support in extensions.conf More...
struct	ast_state_cb
	ast_state_cb: An extension state notify register item More...
struct	ast_sw
	ast_sw: Switch statement in extensions.conf More...
struct	async_stat
struct	dialplan_counters
struct	pbx_builtin
	Declaration of builtin applications. More...
struct	store_hint
Defines
#define	AST_PBX_MAX_STACK   128
#define	BACKGROUND_MATCHEXTEN   (1 << 2)
#define	BACKGROUND_NOANSWER   (1 << 1)
#define	BACKGROUND_PLAYBACK   (1 << 3)
#define	BACKGROUND_SKIP   (1 << 0)
#define	DONT_HAVE_LENGTH   0x80000000
#define	EXT_DATA_SIZE   8192
#define	EXTENSION_MATCH_CORE(data, pattern, match)
#define	FIND_NEXT
#define	HELPER_CANMATCH   3
#define	HELPER_EXEC   2
#define	HELPER_EXISTS   0
#define	HELPER_FINDLABEL   5
#define	HELPER_MATCHMORE   4
#define	HELPER_SPAWN   1
#define	LOG
#define	STATUS_NO_CONTEXT   1
#define	STATUS_NO_EXTENSION   2
#define	STATUS_NO_LABEL   4
#define	STATUS_NO_PRIORITY   3
#define	STATUS_SUCCESS   5
#define	SWITCH_DATA_LENGTH   256
#define	VAR_BUF_SIZE   4096
#define	VAR_HARDTRAN   3
#define	VAR_NORMAL   1
#define	VAR_SOFTTRAN   2
#define	WAITEXTEN_MOH   (1 << 0)
Functions
void	__ast_context_destroy (struct ast_context *con, const char *registrar)
static int	__ast_goto_if_exists (struct ast_channel *chan, char *context, char *exten, int priority, int async)
static int	__ast_pbx_run (struct ast_channel *c)
int	ast_active_calls (void)
int	ast_add_extension (const char *context, int replace, const char *extension, int priority, const char *label, const char *callerid, const char *application, void *data, void(*datad)(void *), const char *registrar)
int	ast_add_extension2 (struct ast_context *con, int replace, const char *extension, int priority, const char *label, const char *callerid, const char *application, void *data, void(*datad)(void *), const char *registrar)
static int	ast_add_hint (struct ast_exten *e)
	ast_add_hint: Add hint to hint list, check initial extension state
	AST_APP_OPTIONS (resetcdr_opts,{AST_APP_OPTION('w', AST_CDR_FLAG_POSTED), AST_APP_OPTION('a', AST_CDR_FLAG_LOCKED), AST_APP_OPTION('v', AST_CDR_FLAG_KEEP_VARS),})
	AST_APP_OPTIONS (waitexten_opts,{AST_APP_OPTION_ARG('m', WAITEXTEN_MOH, 1),})
	AST_APP_OPTIONS (background_opts,{AST_APP_OPTION('s', BACKGROUND_SKIP), AST_APP_OPTION('n', BACKGROUND_NOANSWER), AST_APP_OPTION('m', BACKGROUND_MATCHEXTEN), AST_APP_OPTION('p', BACKGROUND_PLAYBACK),})
int	ast_async_goto (struct ast_channel *chan, const char *context, const char *exten, int priority)
int	ast_async_goto_by_name (const char *channame, const char *context, const char *exten, int priority)
int	ast_async_goto_if_exists (struct ast_channel *chan, char *context, char *exten, int priority)
int	ast_build_timing (struct ast_timing *i, char *info_in)
int	ast_canmatch_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
static int	ast_change_hint (struct ast_exten *oe, struct ast_exten *ne)
	ast_change_hint: Change hint for an extension
int	ast_check_timing (struct ast_timing *i)
int	ast_context_add_ignorepat (const char *con, const char *value, const char *registrar)
int	ast_context_add_ignorepat2 (struct ast_context *con, const char *value, const char *registrar)
int	ast_context_add_include (const char *context, const char *include, const char *registrar)
int	ast_context_add_include2 (struct ast_context *con, const char *value, const char *registrar)
int	ast_context_add_switch (const char *context, const char *sw, const char *data, int eval, const char *registrar)
int	ast_context_add_switch2 (struct ast_context *con, const char *value, const char *data, int eval, const char *registrar)
struct ast_context *	ast_context_create (struct ast_context **extcontexts, const char *name, const char *registrar)
void	ast_context_destroy (struct ast_context *con, const char *registrar)
struct ast_context *	ast_context_find (const char *name)
int	ast_context_remove_extension (const char *context, const char *extension, int priority, const char *registrar)
int	ast_context_remove_extension2 (struct ast_context *con, const char *extension, int priority, const char *registrar)
	This functionc locks given context, search for the right extension and fires out all peer in this extensions with given priority. If priority is set to 0, all peers are removed. After that, unlock context and return.
int	ast_context_remove_ignorepat (const char *context, const char *ignorepat, const char *registrar)
int	ast_context_remove_ignorepat2 (struct ast_context *con, const char *ignorepat, const char *registrar)
int	ast_context_remove_include (const char *context, const char *include, const char *registrar)
int	ast_context_remove_include2 (struct ast_context *con, const char *include, const char *registrar)
int	ast_context_remove_switch (const char *context, const char *sw, const char *data, const char *registrar)
int	ast_context_remove_switch2 (struct ast_context *con, const char *sw, const char *data, const char *registrar)
	This function locks given context, removes switch, unlock context and return.
int	ast_context_verify_includes (struct ast_context *con)
struct ast_custom_function *	ast_custom_function_find (char *name)
int	ast_custom_function_register (struct ast_custom_function *acf)
int	ast_custom_function_unregister (struct ast_custom_function *acf)
int	ast_exec_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
int	ast_exists_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
int	ast_explicit_goto (struct ast_channel *chan, const char *context, const char *exten, int priority)
int	ast_extension_close (const char *pattern, const char *data, int needmore)
int	ast_extension_match (const char *pattern, const char *data)
int	ast_extension_state (struct ast_channel *c, char *context, char *exten)
	ast_extension_state: Check extension state for an extension by using hint
static int	ast_extension_state2 (struct ast_exten *e)
	ast_extensions_state2: Check state of extension by using hints
const char *	ast_extension_state2str (int extension_state)
	ast_extension_state2str: Return extension_state as string
int	ast_extension_state_add (const char *context, const char *exten, ast_state_cb_type callback, void *data)
	ast_extension_state_add: Add watcher for extension states
int	ast_extension_state_del (int id, ast_state_cb_type callback)
	ast_extension_state_del: Remove a watcher from the callback list
int	ast_findlabel_extension (struct ast_channel *c, const char *context, const char *exten, const char *label, const char *callerid)
int	ast_findlabel_extension2 (struct ast_channel *c, struct ast_context *con, const char *exten, const char *label, const char *callerid)
char *	ast_func_read (struct ast_channel *chan, const char *in, char *workspace, size_t len)
void	ast_func_write (struct ast_channel *chan, const char *in, const char *value)
const char *	ast_get_context_name (struct ast_context *con)
const char *	ast_get_context_registrar (struct ast_context *c)
const char *	ast_get_extension_app (struct ast_exten *e)
void *	ast_get_extension_app_data (struct ast_exten *e)
const char *	ast_get_extension_cidmatch (struct ast_exten *e)
const char *	ast_get_extension_label (struct ast_exten *exten)
int	ast_get_extension_matchcid (struct ast_exten *e)
const char *	ast_get_extension_name (struct ast_exten *exten)
int	ast_get_extension_priority (struct ast_exten *exten)
const char *	ast_get_extension_registrar (struct ast_exten *e)
int	ast_get_hint (char *hint, int hintsize, char *name, int namesize, struct ast_channel *c, const char *context, const char *exten)
	ast_get_hint: Get hint for channel
const char *	ast_get_ignorepat_name (struct ast_ignorepat *ip)
const char *	ast_get_ignorepat_registrar (struct ast_ignorepat *ip)
const char *	ast_get_include_name (struct ast_include *inc)
const char *	ast_get_include_registrar (struct ast_include *i)
const char *	ast_get_switch_data (struct ast_sw *sw)
const char *	ast_get_switch_name (struct ast_sw *sw)
const char *	ast_get_switch_registrar (struct ast_sw *sw)
int	ast_goto_if_exists (struct ast_channel *chan, char *context, char *exten, int priority)
static struct ast_exten *	ast_hint_extension (struct ast_channel *c, const char *context, const char *exten)
	ast_hint_extension: Find hint for given extension in context
void	ast_hint_state_changed (const char *device)
int	ast_ignore_pattern (const char *context, const char *pattern)
	AST_LIST_HEAD (store_hints, store_hint)
int	ast_lock_context (struct ast_context *con)
int	ast_lock_contexts ()
int	ast_matchmore_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
void	ast_merge_contexts_and_delete (struct ast_context **extcontexts, const char *registrar)
	AST_MUTEX_DEFINE_STATIC (hintlock)
	AST_MUTEX_DEFINE_STATIC (switchlock)
	AST_MUTEX_DEFINE_STATIC (applock)
	AST_MUTEX_DEFINE_STATIC (conlock)
	AST_MUTEX_DEFINE_STATIC (acflock)
	AST_MUTEX_DEFINE_STATIC (maxcalllock)
	AST_MUTEX_DEFINE_STATIC (globalslock)
int	ast_parseable_goto (struct ast_channel *chan, const char *goto_string)
int	ast_pbx_outgoing_app (const char *type, int format, void *data, int timeout, const char *app, const char *appdata, int *reason, int sync, const char *cid_num, const char *cid_name, struct ast_variable *vars, const char *account, struct ast_channel **locked_channel)
int	ast_pbx_outgoing_cdr_failed (void)
int	ast_pbx_outgoing_exten (const char *type, int format, void *data, int timeout, const char *context, const char *exten, int priority, int *reason, int sync, const char *cid_num, const char *cid_name, struct ast_variable *vars, const char *account, struct ast_channel **channel)
enum ast_pbx_result	ast_pbx_run (struct ast_channel *c)
static void *	ast_pbx_run_app (void *data)
enum ast_pbx_result	ast_pbx_start (struct ast_channel *c)
int	ast_register_application (const char *app, int(*execute)(struct ast_channel *, void *), const char *synopsis, const char *description)
	Dynamically register a new dial plan application.
int	ast_register_switch (struct ast_switch *sw)
static int	ast_remove_hint (struct ast_exten *e)
	ast_remove_hint: Remove hint from extension
int	ast_spawn_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
int	ast_unlock_context (struct ast_context *con)
int	ast_unlock_contexts ()
int	ast_unregister_application (const char *app)
void	ast_unregister_switch (struct ast_switch *sw)
struct ast_exten *	ast_walk_context_extensions (struct ast_context *con, struct ast_exten *exten)
struct ast_ignorepat *	ast_walk_context_ignorepats (struct ast_context *con, struct ast_ignorepat *ip)
struct ast_include *	ast_walk_context_includes (struct ast_context *con, struct ast_include *inc)
struct ast_sw *	ast_walk_context_switches (struct ast_context *con, struct ast_sw *sw)
struct ast_context *	ast_walk_contexts (struct ast_context *con)
struct ast_exten *	ast_walk_extension_priorities (struct ast_exten *exten, struct ast_exten *priority)
static void *	async_wait (void *data)
static char *	complete_show_application (char *line, char *word, int pos, int state)
static char *	complete_show_applications (char *line, char *word, int pos, int state)
static char *	complete_show_dialplan_context (char *line, char *word, int pos, int state)
static char *	complete_show_function (char *line, char *word, int pos, int state)
static void	decrease_call_count (void)
static void	destroy_exten (struct ast_exten *e)
static int	ext_strncpy (char *dst, const char *src, int len)
static unsigned int	get_day (char *day)
static unsigned int	get_dow (char *dow)
	get_dow: Get day of week
static unsigned int	get_month (char *mon)
static void	get_timerange (struct ast_timing *i, char *times)
static int	handle_show_application (int fd, int argc, char *argv[])
static int	handle_show_applications (int fd, int argc, char *argv[])
static int	handle_show_dialplan (int fd, int argc, char *argv[])
static int	handle_show_function (int fd, int argc, char *argv[])
static int	handle_show_functions (int fd, int argc, char *argv[])
static int	handle_show_hints (int fd, int argc, char *argv[])
	handle_show_hints: CLI support for listing registred dial plan hints
static int	handle_show_switches (int fd, int argc, char *argv[])
	handle_show_switches: CLI support for listing registred dial plan switches
static int	include_valid (struct ast_include *i)
static int	increase_call_count (const struct ast_channel *c)
int	load_pbx (void)
static int	matchcid (const char *cidpattern, const char *callerid)
static void	null_datad (void *foo)
static int	parse_variable_name (char *var, int *offset, int *length, int *isfunc)
static int	pbx_builtin_answer (struct ast_channel *, void *)
static int	pbx_builtin_atimeout (struct ast_channel *, void *)
static int	pbx_builtin_background (struct ast_channel *, void *)
static int	pbx_builtin_busy (struct ast_channel *, void *)
void	pbx_builtin_clear_globals (void)
static int	pbx_builtin_congestion (struct ast_channel *, void *)
static int	pbx_builtin_dtimeout (struct ast_channel *, void *)
static int	pbx_builtin_execiftime (struct ast_channel *, void *)
char *	pbx_builtin_getvar_helper (struct ast_channel *chan, const char *name)
static int	pbx_builtin_goto (struct ast_channel *, void *)
static int	pbx_builtin_gotoif (struct ast_channel *, void *)
static int	pbx_builtin_gotoiftime (struct ast_channel *, void *)
static int	pbx_builtin_hangup (struct ast_channel *, void *)
static int	pbx_builtin_importvar (struct ast_channel *, void *)
static int	pbx_builtin_noop (struct ast_channel *, void *)
static int	pbx_builtin_progress (struct ast_channel *, void *)
void	pbx_builtin_pushvar_helper (struct ast_channel *chan, const char *name, const char *value)
static int	pbx_builtin_resetcdr (struct ast_channel *, void *)
static int	pbx_builtin_ringing (struct ast_channel *, void *)
static int	pbx_builtin_rtimeout (struct ast_channel *, void *)
static int	pbx_builtin_saycharacters (struct ast_channel *, void *)
static int	pbx_builtin_saydigits (struct ast_channel *, void *)
static int	pbx_builtin_saynumber (struct ast_channel *, void *)
static int	pbx_builtin_sayphonetic (struct ast_channel *, void *)
int	pbx_builtin_serialize_variables (struct ast_channel *chan, char *buf, size_t size)
static int	pbx_builtin_setaccount (struct ast_channel *, void *)
static int	pbx_builtin_setamaflags (struct ast_channel *, void *)
static int	pbx_builtin_setglobalvar (struct ast_channel *, void *)
static int	pbx_builtin_setlanguage (struct ast_channel *, void *)
int	pbx_builtin_setvar (struct ast_channel *, void *)
void	pbx_builtin_setvar_helper (struct ast_channel *chan, const char *name, const char *value)
static int	pbx_builtin_setvar_old (struct ast_channel *, void *)
static int	pbx_builtin_wait (struct ast_channel *, void *)
static int	pbx_builtin_waitexten (struct ast_channel *, void *)
int	pbx_checkcondition (char *condition)
static void	pbx_destroy (struct ast_pbx *p)
int	pbx_exec (struct ast_channel *c, struct ast_app *app, void *data, int newstack)
static int	pbx_extension_helper (struct ast_channel *c, struct ast_context *con, const char *context, const char *exten, int priority, const char *label, const char *callerid, int action)
static struct ast_exten *	pbx_find_extension (struct ast_channel *chan, struct ast_context *bypass, const char *context, const char *exten, int priority, const char *label, const char *callerid, int action, char *incstack[], int *stacklen, int *status, struct ast_switch **swo, char **data, const char **foundcontext)
struct ast_app *	pbx_findapp (const char *app)
	Find application handle in linked list.
static struct ast_switch *	pbx_findswitch (const char *sw)
void	pbx_retrieve_variable (struct ast_channel *c, const char *var, char **ret, char *workspace, int workspacelen, struct varshead *headp)
	pbx_retrieve_variable: Support for Asterisk built-in variables ---
int	pbx_set_autofallthrough (int newval)
static void	pbx_substitute_variables (char *passdata, int datalen, struct ast_channel *c, struct ast_exten *e)
void	pbx_substitute_variables_helper (struct ast_channel *c, const char *cp1, char *cp2, int count)
static void	pbx_substitute_variables_helper_full (struct ast_channel *c, struct varshead *headp, const char *cp1, char *cp2, int count)
void	pbx_substitute_variables_varshead (struct varshead *headp, const char *cp1, char *cp2, int count)
static void *	pbx_thread (void *data)
static int	show_dialplan_helper (int fd, char *context, char *exten, struct dialplan_counters *dpc, struct ast_include *rinclude, int includecount, char *includes[])
static char *	substring (const char *value, int offset, int length, char *workspace, size_t workspace_len)
	takes a substring. It is ok to call with value == workspace.
static void	wait_for_hangup (struct ast_channel *chan, void *data)
Variables
static struct ast_custom_function *	acf_root = NULL
static struct ast_app *	apps = NULL
static int	autofallthrough = 0
static struct pbx_builtin	builtins []
	Declaration of builtin applications.
static struct ast_context *	contexts = NULL
static int	countcalls = 0
static char *	days []
static struct varshead	globals
struct ast_hint *	hints = NULL
static char *	months []
static struct ast_cli_entry	pbx_cli []
static char	show_application_help []
static char	show_applications_help []
static char	show_dialplan_help []
static char	show_function_help []
static char	show_functions_help []
static char	show_hints_help []
static char	show_switches_help []
struct ast_state_cb *	statecbs = NULL
static int	stateid = 1
struct ast_switch *	switches = NULL

---

Detailed Description

Core PBX routines.

Definition in file pbx.c.

---

Define Documentation

#define AST_PBX_MAX_STACK   128

Go no deeper than this through includes (not counting loops)

Definition at line 586 of file pbx.c.

Referenced by ast_hint_extension(), handle_show_dialplan(), pbx_extension_helper(), pbx_find_extension(), and show_dialplan_helper().

#define BACKGROUND_MATCHEXTEN   (1 << 2)

Definition at line 87 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_NOANSWER   (1 << 1)

Definition at line 86 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_PLAYBACK   (1 << 3)

Definition at line 88 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_SKIP   (1 << 0)

Definition at line 85 of file pbx.c.

Referenced by pbx_builtin_background().

#define DONT_HAVE_LENGTH   0x80000000

Definition at line 924 of file pbx.c.

Referenced by parse_variable_name().

#define EXT_DATA_SIZE   8192

Note:

I M P O R T A N T :

The speed of extension handling will likely be among the most important aspects of this PBX. The switching scheme as it exists right now isn't terribly bad (it's O(N+M), where N is the # of extensions and M is the avg # of priorities, but a constant search time here would be great ;-)

Definition at line 74 of file pbx.c.

Referenced by pbx_extension_helper(), and realtime_exec().

#define EXTENSION_MATCH_CORE	(	data,
		pattern,
		match		)

Definition at line 646 of file pbx.c.

Referenced by ast_extension_close(), and 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 3855 of file pbx.c.

Referenced by ast_build_timing().

#define HELPER_CANMATCH   3

Definition at line 591 of file pbx.c.

Referenced by ast_canmatch_extension(), pbx_extension_helper(), and pbx_find_extension().

#define HELPER_EXEC   2

Definition at line 590 of file pbx.c.

Referenced by ast_exec_extension(), and pbx_extension_helper().

#define HELPER_EXISTS   0

Definition at line 588 of file pbx.c.

Referenced by ast_exists_extension(), ast_hint_extension(), and pbx_extension_helper().

#define HELPER_FINDLABEL   5

Definition at line 593 of file pbx.c.

Referenced by ast_findlabel_extension(), ast_findlabel_extension2(), pbx_extension_helper(), and pbx_find_extension().

#define HELPER_MATCHMORE   4

Definition at line 592 of file pbx.c.

Referenced by ast_matchmore_extension(), pbx_extension_helper(), and pbx_find_extension().

#define HELPER_SPAWN   1

Definition at line 589 of file pbx.c.

Referenced by ast_spawn_extension(), and pbx_extension_helper().

#define LOG

Referenced by ast_add_extension2().

#define STATUS_NO_CONTEXT   1

Definition at line 774 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

#define STATUS_NO_EXTENSION   2

Definition at line 775 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

#define STATUS_NO_LABEL   4

Definition at line 777 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

#define STATUS_NO_PRIORITY   3

Definition at line 776 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

#define STATUS_SUCCESS   5

Definition at line 778 of file pbx.c.

Referenced by pbx_find_extension().

#define SWITCH_DATA_LENGTH   256

Definition at line 77 of file pbx.c.

Referenced by ast_context_add_switch2(), and pbx_find_extension().

#define VAR_BUF_SIZE   4096

Definition at line 79 of file pbx.c.

Referenced by ast_add_extension2(), pbx_builtin_importvar(), and pbx_substitute_variables_helper_full().

#define VAR_HARDTRAN   3

Definition at line 83 of file pbx.c.

#define VAR_NORMAL   1

Definition at line 81 of file pbx.c.

#define VAR_SOFTTRAN   2

Definition at line 82 of file pbx.c.

#define WAITEXTEN_MOH   (1 << 0)

Definition at line 97 of file pbx.c.

Referenced by pbx_builtin_waitexten().

---

Function Documentation

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

Definition at line 5341 of file pbx.c.

References ast_context::alts, ast_log(), ast_mutex_destroy(), ast_mutex_lock(), ast_mutex_unlock(), destroy_exten(), el, 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);
}

static int __ast_goto_if_exists	(	struct ast_channel *	chan,
		char *	context,
		char *	exten,
		int	priority,
		int	async
	)			[static]

Definition at line 6478 of file pbx.c.

References ast_async_goto(), ast_exists_extension(), ast_explicit_goto(), ast_channel::cid, ast_callerid::cid_num, ast_channel::context, and ast_channel::exten.

Referenced by ast_async_goto_if_exists(), and ast_goto_if_exists().

{
   int (*goto_func)(struct ast_channel *chan, const char *context, const char *exten, int priority);

   if (!chan)
      return -2;

   goto_func = (async) ? ast_async_goto : ast_explicit_goto;
   if (ast_exists_extension(chan, context ? context : chan->context,
             exten ? exten : chan->exten, priority,
             chan->cid.cid_num))
      return goto_func(chan, context ? context : chan->context,
             exten ? exten : chan->exten, priority);
   else 
      return -3;
}

static int __ast_pbx_run

(

struct ast_channel *

c

)

[static]

Definition at line 2258 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_FLAG_IN_AUTOLOOP, ast_hangup(), ast_log(), ast_matchmore_extension(), AST_PBX_KEEPALIVE, ast_set2_flag, ast_set_flag, AST_SOFTHANGUP_ASYNCGOTO, AST_SOFTHANGUP_TIMEOUT, ast_spawn_extension(), ast_strlen_zero(), ast_test_flag, ast_verbose(), ast_waitfordigit(), ast_channel::cdr, ast_channel::cid, ast_callerid::cid_num, ast_channel::context, ast_pbx::dtimeout, ast_channel::exten, exten, free, LOG_DEBUG, LOG_ERROR, LOG_WARNING, malloc, ast_channel::name, option_debug, option_verbose, ast_channel::pbx, pbx_builtin_busy(), pbx_builtin_congestion(), pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_destroy(), ast_channel::priority, ast_pbx::rtimeout, ast_cdr::start, VERBOSE_PREFIX_2, VERBOSE_PREFIX_3, and ast_channel::whentohangup.

Referenced by ast_pbx_run(), and pbx_thread().

{
   int firstpass = 1;
   int digit;
   char exten[256];
   int pos;
   int waittime;
   int res=0;
   int autoloopflag;

   /* 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) {
         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;

   autoloopflag = ast_test_flag(c, AST_FLAG_IN_AUTOLOOP);
   ast_set_flag(c, AST_FLAG_IN_AUTOLOOP);

   /* Start by trying whatever the channel is set to */
   if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
      /* If not successful 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);
      ast_copy_string(c->exten, "s", sizeof(c->exten));
      if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
         /* 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);
         ast_copy_string(c->context, "default", sizeof(c->context));
      }
      c->priority = 1;
   }
   if (c->cdr && !c->cdr->start.tv_sec && !c->cdr->start.tv_usec)
      ast_cdr_start(c->cdr);
   for(;;) {
      pos = 0;
      digit = 0;
      while(ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
         memset(exten, 0, sizeof(exten));
         if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->cid.cid_num))) {
            /* 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);
               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);
               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->cid.cid_num))) {
            ast_copy_string(c->exten, "T", sizeof(c->exten));
            /* 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->cid.cid_num)) {
         /* It's not a valid extension anymore */
         if (ast_exists_extension(c, c->context, "i", 1, c->cid.cid_num)) {
            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);
            ast_copy_string(c->exten, "i", sizeof(c->exten));
            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 */
         waittime = 0;
         if (digit)
            waittime = c->pbx->dtimeout;
         else if (!autofallthrough)
            waittime = c->pbx->rtimeout;
         if (waittime) {
            while (ast_matchmore_extension(c, c->context, exten, 1, c->cid.cid_num)) {
               /* 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->cid.cid_num)) {
               /* Prepare the next cycle */
               ast_copy_string(c->exten, exten, sizeof(c->exten));
               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->cid.cid_num)) {
                     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);
                     ast_copy_string(c->exten, "i", sizeof(c->exten));
                     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->cid.cid_num)) {
                     if (option_verbose > 2)
                        ast_verbose( VERBOSE_PREFIX_3 "Timeout on %s\n", c->name);
                     ast_copy_string(c->exten, "t", sizeof(c->exten));
                     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);
             }
         } else {
            char *status;

            status = pbx_builtin_getvar_helper(c, "DIALSTATUS");
            if (!status)
               status = "UNKNOWN";
            if (option_verbose > 2)
               ast_verbose(VERBOSE_PREFIX_2 "Auto fallthrough, channel '%s' status is '%s'\n", c->name, status);
            if (!strcasecmp(status, "CONGESTION"))
               res = pbx_builtin_congestion(c, "10");
            else if (!strcasecmp(status, "CHANUNAVAIL"))
               res = pbx_builtin_congestion(c, "10");
            else if (!strcasecmp(status, "BUSY"))
               res = pbx_builtin_busy(c, "10");
            goto out;
         }
      }
   }
   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->cid.cid_num)) {
      c->exten[0] = 'h';
      c->exten[1] = '\0';
      c->priority = 1;
      while(ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
         if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->cid.cid_num))) {
            /* 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);
            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++;
      }
   }
   ast_set2_flag(c, autoloopflag, AST_FLAG_IN_AUTOLOOP);

   pbx_destroy(c->pbx);
   c->pbx = NULL;
   if (res != AST_PBX_KEEPALIVE)
      ast_hangup(c);
   return 0;
}

int ast_active_calls

(

void

)

Definition at line 2584 of file pbx.c.

Referenced by handle_chanlist().

{
   return countcalls;
}

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

Parameters:

	context	context to add the extension to
	replace
	extension	extension to add
	priority	priority level of extension addition
	label	extension label
	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 4527 of file pbx.c.

References ast_add_extension2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_add_extension(), and register_peer_exten().

{
   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, label, 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,
		const char *	extension,
		int	priority,
		const char *	label,
		const char *	callerid,
		const char *	application,
		void *	data,
		void(*)(void *)	datad,
		const 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 4666 of file pbx.c.

References ast_exten::app, ast_add_hint(), ast_change_hint(), AST_LIST_FIRST, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_exten::cidmatch, ast_exten::data, ast_exten::datad, el, ext_strncpy(), ast_exten::exten, free, globals, ast_exten::label, ast_context::lock, LOG, LOG_ERROR, LOG_WARNING, malloc, ast_exten::matchcid, ast_context::name, ast_exten::next, null_datad(), ast_exten::parent, pbx_substitute_variables_varshead(), ast_exten::peer, ast_exten::priority, PRIORITY_HINT, ast_exten::registrar, ast_context::root, ast_exten::stuff, and VAR_BUF_SIZE.

Referenced by __build_step(), ast_add_extension(), ast_park_call(), do_parking_thread(), fillin_process(), handle_macro(), load_config(), and pbx_load_module().

{

#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); \
      } \
   } \
   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;
   int length;
   char *p;
   char expand_buf[VAR_BUF_SIZE] = { 0, };

   /* if we are adding a hint, and there are global variables, and the hint
      contains variable references, then expand them
   */
   ast_mutex_lock(&globalslock);
   if ((priority == PRIORITY_HINT) && AST_LIST_FIRST(&globals) && strstr(application, "${")) {
      pbx_substitute_variables_varshead(&globals, application, expand_buf, sizeof(expand_buf));
      application = expand_buf;
   }
   ast_mutex_unlock(&globalslock);

   length = sizeof(struct ast_exten);
   length += strlen(extension) + 1;
   length += strlen(application) + 1;
   if (label)
      length += strlen(label) + 1;
   if (callerid)
      length += strlen(callerid) + 1;
   else
      length ++;

   /* Be optimistic:  Build the extension structure first */
   if (datad == NULL)
      datad = null_datad;
   tmp = malloc(length);
   if (tmp) {
      memset(tmp, 0, length);
      p = tmp->stuff;
      if (label) {
         tmp->label = p;
         strcpy(tmp->label, label);
         p += strlen(label) + 1;
      }
      tmp->exten = p;
      p += ext_strncpy(tmp->exten, extension, strlen(extension) + 1) + 1;
      tmp->priority = priority;
      tmp->cidmatch = p;
      if (callerid) {
         p += ext_strncpy(tmp->cidmatch, callerid, strlen(callerid) + 1) + 1;
         tmp->matchcid = 1;
      } else {
         tmp->cidmatch[0] = '\0';
         tmp->matchcid = 0;
         p++;
      }
      tmp->app = p;
      strcpy(tmp->app, application);
      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;   
}

static int ast_add_hint

(

struct ast_exten *

e

)

[static]

ast_add_hint: Add hint to hint list, check initial extension state

Definition at line 2095 of file pbx.c.

References ast_extension_state2(), ast_get_extension_app(), ast_get_extension_name(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_hint::exten, ast_hint::laststate, list, LOG_DEBUG, malloc, ast_hint::next, and option_debug.

Referenced by ast_add_extension2().

{
   struct ast_hint *list;

   if (!e) 
      return -1;

   ast_mutex_lock(&hintlock);
   list = hints;        

   /* Search if hint exists, do nothing */
   while (list) {
      if (list->exten == e) {
         ast_mutex_unlock(&hintlock);
         if (option_debug > 1)
            ast_log(LOG_DEBUG, "HINTS: Not re-adding existing hint %s: %s\n", ast_get_extension_name(e), ast_get_extension_app(e));
         return -1;
      }
      list = list->next;    
   }

   if (option_debug > 1)
      ast_log(LOG_DEBUG, "HINTS: Adding hint %s: %s\n", ast_get_extension_name(e), ast_get_extension_app(e));

   list = malloc(sizeof(struct ast_hint));
   if (!list) {
      ast_mutex_unlock(&hintlock);
      if (option_debug > 1)
         ast_log(LOG_DEBUG, "HINTS: Out of memory...\n");
      return -1;
   }
   /* Initialize and insert new item at the top */
   memset(list, 0, sizeof(struct ast_hint));
   list->exten = e;
   list->laststate = ast_extension_state2(e);
   list->next = hints;
   hints = list;

   ast_mutex_unlock(&hintlock);
   return 0;
}

AST_APP_OPTIONS

(

resetcdr_opts

)

AST_APP_OPTIONS

(

waitexten_opts

)

AST_APP_OPTIONS

(

background_opts

)

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

Definition at line 4572 of file pbx.c.

References ast_channel::_state, ast_channel_alloc(), ast_channel_masquerade(), ast_do_masquerade(), ast_explicit_goto(), ast_hangup(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pbx_start(), ast_setstate(), AST_SOFTHANGUP_ASYNCGOTO, ast_softhangup_nolock(), ast_strlen_zero(), ast_channel::context, ast_channel::exten, ast_channel::lock, LOG_WARNING, ast_channel::name, ast_channel::pbx, ast_channel::readformat, and ast_channel::writeformat.

Referenced by __ast_goto_if_exists(), action_redirect(), ast_async_goto_by_name(), builtin_blindtransfer(), console_transfer(), handle_request_bye(), handle_request_refer(), i4l_read(), monitor_handle_owned(), process_ast_dsp(), socket_read(), and zt_handle_dtmfup().

{
   int res = 0;

   ast_mutex_lock(&chan->lock);

   if (chan->pbx) {
      /* This channel is currently in the PBX */
      ast_explicit_goto(chan, context, exten, priority);
      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 */
         ast_explicit_goto(tmpchan,
                 (!ast_strlen_zero(context)) ? context : chan->context,
                 (!ast_strlen_zero(exten)) ? exten : chan->exten,
                 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	(	const char *	channame,
		const char *	context,
		const char *	exten,
		int	priority
	)

Definition at line 4621 of file pbx.c.

References ast_async_goto(), ast_get_channel_by_name_locked(), ast_mutex_unlock(), and ast_channel::lock.

{
   struct ast_channel *chan;
   int res = -1;

   chan = ast_get_channel_by_name_locked(channame);
   if (chan) {
      res = ast_async_goto(chan, context, exten, priority);
      ast_mutex_unlock(&chan->lock);
   }
   return res;
}

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

Definition at line 6499 of file pbx.c.

References __ast_goto_if_exists().

                                                                                                 {
   return __ast_goto_if_exists(chan, context, exten, priority, 1);
}

int ast_build_timing	(	struct ast_timing *	i,
		char *	info_in
	)

Definition at line 4105 of file pbx.c.

References ast_strlen_zero(), ast_timing::daymask, ast_timing::dowmask, FIND_NEXT, get_day(), get_dow(), get_month(), get_timerange(), and ast_timing::monthmask.

Referenced by ast_context_add_include2(), builtin_function_iftime(), pbx_builtin_execiftime(), and pbx_builtin_gotoiftime().

{
   char info_save[256];
   char *info;
   char *c;

   /* Check for empty just in case */
   if (ast_strlen_zero(info_in))
      return 0;
   /* make a copy just in case we were passed a static string */
   ast_copy_string(info_save, info_in, sizeof(info_save));
   info = info_save;
   /* Assume everything except time */
   i->monthmask = (1 << 12) - 1;
   i->daymask = (1 << 30) - 1 + (1 << 30);
   i->dowmask = (1 << 7) - 1;
   /* Avoid using str tok */
   FIND_NEXT;
   /* Info has the time range, start with that */
   get_timerange(i, info);
   info = c;
   if (!info)
      return 1;
   FIND_NEXT;
   /* Now check for day of week */
   i->dowmask = get_dow(info);

   info = c;
   if (!info)
      return 1;
   FIND_NEXT;
   /* Now check for the day of the month */
   i->daymask = get_day(info);
   info = c;
   if (!info)
      return 1;
   FIND_NEXT;
   /* And finally go for the month */
   i->monthmask = get_month(info);

   return 1;
}

int ast_canmatch_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		int	priority,
		const 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 2238 of file pbx.c.

References HELPER_CANMATCH, and pbx_extension_helper().

Referenced by background_detect_exec(), cb_events(), dp_lookup(), dundi_lookup_local(), get_also_info(), get_destination(), get_refer_info(), handle_link_data(), handle_link_phone_dtmf(), loopback_canmatch(), mgcp_ss(), monitor_handle_notowned(), phone_check_exception(), rpt(), skinny_ss(), ss_thread(), and valid_exit().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, callerid, HELPER_CANMATCH);
}

static int ast_change_hint	(	struct ast_exten *	oe,
		struct ast_exten *	ne
	)			[static]

ast_change_hint: Change hint for an extension

Definition at line 2138 of file pbx.c.

References ast_mutex_lock(), ast_mutex_unlock(), ast_hint::exten, list, and ast_hint::next.

Referenced by ast_add_extension2().

{ 
   struct ast_hint *list;

   ast_mutex_lock(&hintlock);
   list = hints;

   while(list) {
      if (list->exten == oe) {
            list->exten = ne;
         ast_mutex_unlock(&hintlock);  
         return 0;
      }
      list = list->next;
   }
   ast_mutex_unlock(&hintlock);

   return -1;
}

int ast_check_timing

(

struct ast_timing *

i

)

Definition at line 4148 of file pbx.c.

References ast_log(), ast_timing::daymask, ast_timing::dowmask, LOG_WARNING, ast_timing::minmask, ast_timing::monthmask, and t.

Referenced by builtin_function_iftime(), include_valid(), pbx_builtin_execiftime(), and pbx_builtin_gotoiftime().

{
   struct tm tm;
   time_t t;

   time(&t);
   localtime_r(&t,&tm);

   /* If it's not the right month, return */
   if (!(i->monthmask & (1 << tm.tm_mon))) {
      return 0;
   }

   /* If it's not that time of the month.... */
   /* Warning, tm_mday has range 1..31! */
   if (!(i->daymask & (1 << (tm.tm_mday-1))))
      return 0;

   /* If it's not the right day of the week */
   if (!(i->dowmask & (1 << tm.tm_wday)))
      return 0;

   /* Sanity check the hour just to be safe */
   if ((tm.tm_hour < 0) || (tm.tm_hour > 23)) {
      ast_log(LOG_WARNING, "Insane time...\n");
      return 0;
   }

   /* Now the tough part, we calculate if it fits
      in the right time based on min/hour */
   if (!(i->minmask[tm.tm_hour] & (1 << (tm.tm_min / 2))))
      return 0;

   /* If we got this far, then we're good */
   return 1;
}

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

Add an ignorepat

Parameters:

	context	which context to add the ignorpattern to
	ignorepat	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 4444 of file pbx.c.

References ast_context_add_ignorepat2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_add_ignorepat().

{
   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,
		const char *	value,
		const char *	registrar
	)

Definition at line 4468 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(), handle_context(), and pbx_load_module().

{
   struct ast_ignorepat *ignorepat, *ignorepatc, *ignorepatl = NULL;
   int length;
   length = sizeof(struct ast_ignorepat);
   length += strlen(value) + 1;
   ignorepat = malloc(length);
   if (!ignorepat) {
      ast_log(LOG_ERROR, "Out of memory\n");
      errno = ENOMEM;
      return -1;
   }
   memset(ignorepat, 0, length);
   strcpy(ignorepat->pattern, value);
   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	(	const char *	context,
		const char *	include,
		const 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 3827 of file pbx.c.

References ast_context_add_include2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_add_include().

{
   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,
		const char *	include,
		const 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 4192 of file pbx.c.

References ast_build_timing(), ast_get_context_name(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), free, ast_include::hastime, ast_context::includes, ast_context::lock, LOG_ERROR, malloc, ast_include::name, ast_include::next, option_verbose, ast_include::registrar, ast_include::rname, ast_include::stuff, ast_include::timing, and VERBOSE_PREFIX_3.

Referenced by ast_context_add_include(), handle_context(), and pbx_load_module().

{
   struct ast_include *new_include;
   char *c;
   struct ast_include *i, *il = NULL; /* include, include_last */
   int length;
   char *p;
   
   length = sizeof(struct ast_include);
   length += 2 * (strlen(value) + 1);

   /* allocate new include structure ... */
   if (!(new_include = malloc(length))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      errno = ENOMEM;
      return -1;
   }
   
   /* ... fill in this structure ... */
   memset(new_include, 0, length);
   p = new_include->stuff;
   new_include->name = p;
   strcpy(new_include->name, value);
   p += strlen(value) + 1;
   new_include->rname = p;
   strcpy(new_include->rname, value);
   c = new_include->rname;
   /* Strip off timing info */
   while(*c && (*c != '|')) 
      c++; 
   /* Process if it's there */
   if (*c) {
           new_include->hastime = ast_build_timing(&(new_include->timing), 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	(	const char *	context,
		const char *	sw,
		const char *	data,
		int	eval,
		const char *	registrar
	)

Add a switch

Parameters:

	context	context to which to add the switch
	sw	switch to add
	data	data to pass to switch
	eval	whether to evaluate variables when running 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 4268 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, eval, 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,
		const char *	sw,
		const char *	data,
		int	eval,
		const char *	registrar
	)

Adds a switch (first param is a ast_context)

See ast_context_add_switch()

Definition at line 4303 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, ast_sw::eval, free, ast_context::lock, LOG_ERROR, malloc, ast_sw::name, ast_sw::next, option_verbose, ast_sw::registrar, ast_sw::stuff, SWITCH_DATA_LENGTH, ast_sw::tmpdata, and VERBOSE_PREFIX_3.

Referenced by ast_context_add_switch(), handle_context(), and pbx_load_module().

{
   struct ast_sw *new_sw;
   struct ast_sw *i, *il = NULL; /* sw, sw_last */
   int length;
   char *p;
   
   length = sizeof(struct ast_sw);
   length += strlen(value) + 1;
   if (data)
      length += strlen(data);
   length++;
   if (eval) {
      /* Create buffer for evaluation of variables */
      length += SWITCH_DATA_LENGTH;
      length++;
   }

   /* allocate new sw structure ... */
   if (!(new_sw = malloc(length))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      errno = ENOMEM;
      return -1;
   }
   
   /* ... fill in this structure ... */
   memset(new_sw, 0, length);
   p = new_sw->stuff;
   new_sw->name = p;
   strcpy(new_sw->name, value);
   p += strlen(value) + 1;
   new_sw->data = p;
   if (data) {
      strcpy(new_sw->data, data);
      p += strlen(data) + 1;
   } else {
      strcpy(new_sw->data, "");
      p++;
   }
   if (eval) 
      new_sw->tmpdata = p;
   new_sw->next      = NULL;
   new_sw->eval     = eval;
   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,
		const char *	name,
		const char *	registrar
	)			[read]

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 3662 of file pbx.c.

References ast_log(), ast_mutex_init(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), ast_context::ignorepats, ast_context::includes, local_contexts, ast_context::lock, LOG_DEBUG, LOG_ERROR, LOG_WARNING, malloc, ast_context::name, ast_context::next, option_debug, option_verbose, ast_context::registrar, ast_context::root, and VERBOSE_PREFIX_3.

Referenced by ast_park_call(), do_parking_thread(), handle_context(), handle_macro(), load_config(), pbx_load_module(), reload_config(), and set_config().

{
   struct ast_context *tmp, **local_contexts;
   int length;
   length = sizeof(struct ast_context);
   length += strlen(name) + 1;
   if (!extcontexts) {
      local_contexts = &contexts;
      ast_mutex_lock(&conlock);
   } else
      local_contexts = extcontexts;

   tmp = *local_contexts;
   while(tmp) {
      if (!strcasecmp(tmp->name, name)) {
         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(length);
   if (tmp) {
      memset(tmp, 0, length);
      ast_mutex_init(&tmp->lock);
      strcpy(tmp->name, name);
      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);
      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,
		const 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 5414 of file pbx.c.

References __ast_context_destroy().

Referenced by ael_reload(), reload(), and unload_module().

{
   __ast_context_destroy(con,registrar);
}

struct ast_context* ast_context_find

(

const char *

name

)

[read]

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 757 of file pbx.c.

References ast_mutex_lock(), ast_mutex_unlock(), ast_context::name, and ast_context::next.

Referenced by ast_context_verify_includes(), ast_ignore_pattern(), ast_park_call(), do_parking_thread(), load_config(), macro_exec(), park_exec(), reload_config(), and set_config().

{
   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	(	const char *	context,
		const char *	extension,
		int	priority,
		const 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 2747 of file pbx.c.

References ast_context_remove_extension2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_remove_extension(), and register_peer_exten().

{
   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,
		const char *	extension,
		int	priority,
		const char *	registrar
	)

This functionc locks given context, search for the right extension and fires out all peer in this extensions with given priority. If priority is set to 0, all peers are removed. After that, unlock context and return.

Note:

When do you want to call this function, make sure that &conlock is locked, because some process can handle with your *con context before you lock it.

Definition at line 2783 of file pbx.c.

References ast_mutex_lock(), ast_mutex_unlock(), ast_remove_hint(), ast_exten::data, ast_exten::datad, ast_exten::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(), do_parking_thread(), load_config(), and park_exec().

{
   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	(	const char *	context,
		const char *	ignorepat,
		const 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 4385 of file pbx.c.

References ast_context_remove_ignorepat2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_remove_ignorepat().

{
   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,
		const char *	ignorepat,
		const char *	registrar
	)

Definition at line 4409 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	(	const char *	context,
		const char *	include,
		const char *	registrar
	)

Removes an include

See add_include

Definition at line 2603 of file pbx.c.

References ast_context_remove_include2(), ast_get_context_name(), ast_lock_contexts(), ast_unlock_contexts(), and ast_walk_contexts().

Referenced by handle_context_dont_include().

{
   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,
		const char *	include,
		const char *	registrar
	)

Removes an include by an ast_context structure

See add_include2

Definition at line 2639 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	(	const char *	context,
		const char *	sw,
		const char *	data,
		const char *	registrar
	)

Note:

This function locks contexts list by &conlist, search for the rigt context structure, leave context list locked and call ast_context_remove_switch2 which removes switch, unlock contexts list and return ...

Definition at line 2675 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,
		const char *	sw,
		const char *	data,
		const char *	registrar
	)

This function locks given context, removes switch, unlock context and return.

Note:

When we call this function, &conlock lock must be locked, because when we giving *con argument, some process can remove/change this context and after that there can be segfault.

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

References ast_context_find(), ast_get_context_name(), ast_log(), ast_walk_context_includes(), LOG_WARNING, and ast_include::rname.

Referenced by pbx_load_module().

{
   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 nonexistent context '%s'\n",
               ast_get_context_name(con), inc->rname);
      }
   return res;
}

struct ast_custom_function* ast_custom_function_find

(

char *

name

)

[read]

Definition at line 1287 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_ERROR, ast_custom_function::name, and ast_custom_function::next.

Referenced by ast_custom_function_register(), ast_func_read(), ast_func_write(), and handle_show_function().

{
   struct ast_custom_function *acfptr;

   /* try to lock functions list ... */
   if (ast_mutex_lock(&acflock)) {
      ast_log(LOG_ERROR, "Unable to lock function list\n");
      return NULL;
   }

   for (acfptr = acf_root; acfptr; acfptr = acfptr->next) {
      if (!strcmp(name, acfptr->name)) {
         break;
      }
   }

   ast_mutex_unlock(&acflock);
   
   return acfptr;
}

int ast_custom_function_register

(

struct ast_custom_function *

acf

)

Definition at line 1343 of file pbx.c.

References ast_custom_function_find(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), LOG_ERROR, ast_custom_function::name, ast_custom_function::next, option_verbose, and VERBOSE_PREFIX_2.

Referenced by load_module().

{
   if (!acf)
      return -1;

   /* try to lock functions list ... */
   if (ast_mutex_lock(&acflock)) {
      ast_log(LOG_ERROR, "Unable to lock function list. Failed registering function %s\n", acf->name);
      return -1;
   }

   if (ast_custom_function_find(acf->name)) {
      ast_log(LOG_ERROR, "Function %s already registered.\n", acf->name);
      ast_mutex_unlock(&acflock);
      return -1;
   }

   acf->next = acf_root;
   acf_root = acf;

   ast_mutex_unlock(&acflock);

   if (option_verbose > 1)
      ast_verbose(VERBOSE_PREFIX_2 "Registered custom function %s\n", acf->name);

   return 0;
}

int ast_custom_function_unregister

(

struct ast_custom_function *

acf

)

Definition at line 1308 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), LOG_ERROR, ast_custom_function::name, ast_custom_function::next, option_verbose, and VERBOSE_PREFIX_2.

Referenced by unload_module().

{
   struct ast_custom_function *acfptr, *lastacf = NULL;
   int res = -1;

   if (!acf)
      return -1;

   /* try to lock functions list ... */
   if (ast_mutex_lock(&acflock)) {
      ast_log(LOG_ERROR, "Unable to lock function list\n");
      return -1;
   }

   for (acfptr = acf_root; acfptr; acfptr = acfptr->next) {
      if (acfptr == acf) {
         if (lastacf) {
            lastacf->next = acf->next;
         } else {
            acf_root = acf->next;
         }
         res = 0;
         break;
      }
      lastacf = acfptr;
   }

   ast_mutex_unlock(&acflock);

   if (!res && (option_verbose > 1))
      ast_verbose(VERBOSE_PREFIX_2 "Unregistered custom function %s\n", acf->name);

   return res;
}

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

Execute an extension.

Parameters:

	c	channel to execute upon
	context	which context extension is in
	exten	extension to execute
	priority	priority to execute within the given extension
	callerid	Caller-ID If it's not available, do whatever you should do for default extensions and halt the thread if necessary. This function does not return, except on error.

Definition at line 2253 of file pbx.c.

References HELPER_EXEC, and pbx_extension_helper().

Referenced by loopback_exec().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, callerid, HELPER_EXEC);
}

int ast_exists_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		int	priority,
		const 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 2223 of file pbx.c.

References HELPER_EXISTS, and pbx_extension_helper().

Referenced by __ast_goto_if_exists(), __ast_pbx_run(), __login_exec(), agentmonitoroutgoing_exec(), ast_app_dtget(), ast_pbx_outgoing_exten(), ast_waitstream_exten(), builtin_atxfer(), builtin_blindtransfer(), cb_events(), console_dial(), console_transfer(), disa_exec(), dp_lookup(), dundi_lookup_local(), get_also_info(), get_destination(), get_refer_info(), handle_link_data(), handle_link_phone_dtmf(), i4l_read(), leave_voicemail(), local_alloc(), loopback_exists(), macro_exec(), mgcp_ss(), misdn_overlap_dial_task(), monitor_handle_notowned(), monitor_handle_owned(), parkandannounce_exec(), pbx_builtin_waitexten(), phone_check_exception(), process_ast_dsp(), register_peer_exten(), rpt(), rpt_exec(), skinny_ss(), socket_read(), ss_thread(), and zt_handle_dtmfup().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, callerid, HELPER_EXISTS);
}

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

Definition at line 4553 of file pbx.c.

References AST_FLAG_IN_AUTOLOOP, ast_strlen_zero(), ast_test_flag, ast_channel::context, ast_channel::exten, and ast_channel::priority.

Referenced by __ast_goto_if_exists(), ast_async_goto(), ast_parseable_goto(), builtin_atxfer(), disa_exec(), and handle_setpriority().

{
   if (!chan)
      return -1;

   if (!ast_strlen_zero(context))
      ast_copy_string(chan->context, context, sizeof(chan->context));
   if (!ast_strlen_zero(exten))
      ast_copy_string(chan->exten, exten, sizeof(chan->exten));
   if (priority > -1) {
      chan->priority = priority;
      /* see flag description in channel.h for explanation */
      if (ast_test_flag(chan, AST_FLAG_IN_AUTOLOOP))
         chan->priority--;
   }
   
   return 0;
}

int ast_extension_close	(	const char *	pattern,
		const char *	data,
		int	needmore
	)

Definition at line 736 of file pbx.c.

References ast_strlen_zero(), EXTENSION_MATCH_CORE, and match().

Referenced by pbx_find_extension(), and realtime_switch_common().

{
   int match;
   /* If "data" is longer, it can'be a subset of pattern unless
      pattern is a pattern match */
   if ((strlen(pattern) < strlen(data)) && (pattern[0] != '_'))
      return 0;
   
   if ((ast_strlen_zero((char *)data) || !strncasecmp(pattern, data, strlen(data))) && 
      (!needmore || (strlen(pattern) > strlen(data)))) {
      return 1;
   }
   EXTENSION_MATCH_CORE(data,pattern,match);
   /* If there's more or we don't care about more, or if it's a possible early match, 
      return non-zero; otherwise it's a miss */
   if (!needmore || *pattern || match == 2) {
      return match;
   } else
      return 0;
}

int ast_extension_match	(	const char *	pattern,
		const 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 723 of file pbx.c.

References EXTENSION_MATCH_CORE, and match().

Referenced by ast_ignore_pattern(), find_matching_priority(), loopback_canmatch(), loopback_exec(), loopback_exists(), loopback_matchmore(), matchcid(), misdn_cfg_is_msn_valid(), pbx_find_extension(), realtime_switch_common(), and show_dialplan_helper().

{
   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
	)

ast_extension_state: Check extension state for an extension by using hint

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 1895 of file pbx.c.

References ast_extension_state2(), and ast_hint_extension().

Referenced by action_extensionstate(), and handle_request_subscribe().

{
   struct ast_exten *e;

   e = ast_hint_extension(c, context, exten);   /* Do we have a hint for this extension ? */ 
   if (!e) 
      return -1;           /* No hint, return -1 */

   return ast_extension_state2(e);        /* Check all devices in the hint */
}

static int ast_extension_state2

(

struct ast_exten *

e

)

[static]

ast_extensions_state2: Check state of extension by using hints

Definition at line 1808 of file pbx.c.

References AST_DEVICE_BUSY, AST_DEVICE_INUSE, AST_DEVICE_INVALID, AST_DEVICE_NOT_INUSE, AST_DEVICE_RINGING, ast_device_state(), AST_DEVICE_UNAVAILABLE, AST_EXTENSION_BUSY, AST_EXTENSION_INUSE, AST_EXTENSION_NOT_INUSE, AST_EXTENSION_RINGING, AST_EXTENSION_UNAVAILABLE, ast_get_extension_app(), AST_MAX_EXTENSION, inuse, and ring().

Referenced by ast_add_hint(), ast_extension_state(), and ast_hint_state_changed().

{
   char hint[AST_MAX_EXTENSION] = "";    
   char *cur, *rest;
   int res = -1;
   int allunavailable = 1, allbusy = 1, allfree = 1;
   int busy = 0, inuse = 0, ring = 0;

   if (!e)
      return -1;

   ast_copy_string(hint, ast_get_extension_app(e), sizeof(hint));

   cur = hint;       /* On or more devices separated with a & character */
   do {
      rest = strchr(cur, '&');
      if (rest) {
         *rest = 0;
         rest++;
      }
   
      res = ast_device_state(cur);
      switch (res) {
      case AST_DEVICE_NOT_INUSE:
         allunavailable = 0;
         allbusy = 0;
         break;
      case AST_DEVICE_INUSE:
         inuse = 1;
         allunavailable = 0;
         allfree = 0;
         break;
      case AST_DEVICE_RINGING:
         ring = 1;
         allunavailable = 0;
         allfree = 0;
         break;
      case AST_DEVICE_BUSY:
         allunavailable = 0;
         allfree = 0;
         busy = 1;
         break;
      case AST_DEVICE_UNAVAILABLE:
      case AST_DEVICE_INVALID:
         allbusy = 0;
         allfree = 0;
         break;
      default:
         allunavailable = 0;
         allbusy = 0;
         allfree = 0;
      }
      cur = rest;
   } while (cur);

   if (!inuse && ring)
      return AST_EXTENSION_RINGING;
   if (inuse && ring)
      return (AST_EXTENSION_INUSE | AST_EXTENSION_RINGING);
   if (inuse)
      return AST_EXTENSION_INUSE;
   if (allfree)
      return AST_EXTENSION_NOT_INUSE;
   if (allbusy)      
      return AST_EXTENSION_BUSY;
   if (allunavailable)
      return AST_EXTENSION_UNAVAILABLE;
   if (busy) 
      return AST_EXTENSION_INUSE;
   
   return AST_EXTENSION_NOT_INUSE;
}

const char* ast_extension_state2str

(

int

extension_state

)

ast_extension_state2str: Return extension_state as string

Return string of the state of an extension

Parameters:

extension_state

is the numerical state delivered by ast_extension_state Returns the state of an extension as string

Definition at line 1882 of file pbx.c.

References extension_states, and cfextension_states::text.

Referenced by __sip_show_channels(), cb_extensionstate(), handle_request_subscribe(), and handle_show_hints().

{
   int i;

   for (i = 0; (i < (sizeof(extension_states) / sizeof(extension_states[0]))); i++) {
      if (extension_states[i].extension_state == extension_state) {
         return extension_states[i].text;
      }
   }
   return "Unknown"; 
}

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

ast_extension_state_add: Add watcher for extension states

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 1949 of file pbx.c.

References ast_hint_extension(), ast_mutex_lock(), ast_mutex_unlock(), ast_state_cb::callback, ast_hint::callbacks, ast_state_cb::data, ast_hint::exten, ast_state_cb::id, list, malloc, ast_hint::next, and ast_state_cb::next.

Referenced by handle_request_subscribe(), and init_manager().

{
   struct ast_hint *list;
   struct ast_state_cb *cblist;
   struct ast_exten *e;

   /* If there's 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);
            return 0;
         }
         cblist = cblist->next;
      }
   
      /* Now insert 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, so get the hint */
   e = ast_hint_extension(NULL, context, exten);    
   if (!e) {
      return -1;
   }

   /* Find the hint in the list of hints */
   ast_mutex_lock(&hintlock);
   list = hints;        

   while (list) {
      if (list->exten == e)
         break;       
      list = list->next;    
   }

   if (!list) {
      /* We have no hint, sorry */
      ast_mutex_unlock(&hintlock);
      return -1;
   }

   /* Now insert the callback in the callback list  */
   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++;    /* Unique ID for this callback */
   cblist->callback = callback;  /* Pointer to callback routine */
   cblist->data = data;    /* Data for the callback */

   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
	)

ast_extension_state_del: Remove a watcher from the callback list

Deletes a registered state change callback by ID

Parameters:

	id	of the callback to delete
	callback	callback Removes the callback from list of callbacks Return 0 on success, -1 on failure

Definition at line 2032 of file pbx.c.

References ast_mutex_lock(), ast_mutex_unlock(), ast_state_cb::callback, ast_hint::callbacks, free, ast_state_cb::id, list, ast_hint::next, and ast_state_cb::next.

Referenced by __sip_destroy(), and handle_request_subscribe().

{
   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_unlock(&hintlock);
      return -1;
   }

   /* id greater than zero is a callback with extension */
   /* Find the callback based on ID */
   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;
}

int ast_findlabel_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		const char *	label,
		const 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
	label	label of the action within the extension to match to priority
	callerid	callerid to search for If an priority which matches given label in extension or -1 if not found. \

Definition at line 2228 of file pbx.c.

References HELPER_FINDLABEL, and pbx_extension_helper().

Referenced by ast_parseable_goto(), and handle_setpriority().

{
   return pbx_extension_helper(c, NULL, context, exten, 0, label, callerid, HELPER_FINDLABEL);
}

int ast_findlabel_extension2	(	struct ast_channel *	c,
		struct ast_context *	con,
		const char *	exten,
		const char *	label,
		const char *	callerid
	)

Definition at line 2233 of file pbx.c.

References HELPER_FINDLABEL, and pbx_extension_helper().

Referenced by pbx_load_module().

{
   return pbx_extension_helper(c, con, NULL, exten, 0, label, callerid, HELPER_FINDLABEL);
}

char* ast_func_read	(	struct ast_channel *	chan,
		const char *	in,
		char *	workspace,
		size_t	len
	)

executes a read operation on a function

Parameters:

	chan	Channel to execute on
	in	Data containing the function call string
	workspace	A pointer to safe memory to use for a return value
	len	the number of bytes in workspace This application executes an function in read mode on a given channel. It returns a pointer to workspace if the buffer contains any new data or NULL if there was a problem.

Definition at line 1371 of file pbx.c.

References ast_custom_function_find(), ast_log(), ast_strdupa, LOG_ERROR, LOG_WARNING, and ast_custom_function::read.

Referenced by handle_getvariable(), and pbx_substitute_variables_helper_full().

{
   char *args = NULL, *function, *p;
   char *ret = "0";
   struct ast_custom_function *acfptr;

   function = ast_strdupa(in);
   if (!function) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return ret;
   }
   if ((args = strchr(function, '('))) {
      *args = '\0';
      args++;
      if ((p = strrchr(args, ')'))) {
         *p = '\0';
      } else {
         ast_log(LOG_WARNING, "Can't find trailing parenthesis?\n");
      }
   } else {
      ast_log(LOG_WARNING, "Function doesn't contain parentheses.  Assuming null argument.\n");
   }

   if ((acfptr = ast_custom_function_find(function))) {
      /* run the custom function */
      if (acfptr->read) {
         return acfptr->read(chan, function, args, workspace, len);
      } else {
         ast_log(LOG_ERROR, "Function %s cannot be read\n", function);
      }
   } else {
      ast_log(LOG_ERROR, "Function %s not registered\n", function);
   }
   return ret;
}

void ast_func_write	(	struct ast_channel *	chan,
		const char *	in,
		const char *	value
	)

executes a write operation on a function

Parameters:

	chan	Channel to execute on
	in	Data containing the function call string
	value	A value parameter to pass for writing This application executes an function in write mode on a given channel. It has no return value.

Definition at line 1407 of file pbx.c.

References ast_custom_function_find(), ast_log(), ast_strdupa, LOG_ERROR, LOG_WARNING, and ast_custom_function::write.

Referenced by pbx_builtin_pushvar_helper(), and pbx_builtin_setvar_helper().

{
   char *args = NULL, *function, *p;
   struct ast_custom_function *acfptr;

   function = ast_strdupa(in);
   if (!function) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return;
   }
   if ((args = strchr(function, '('))) {
      *args = '\0';
      args++;
      if ((p = strrchr(args, ')'))) {
         *p = '\0';
      } else {
         ast_log(LOG_WARNING, "Can't find trailing parenthesis?\n");
      }
   } else {
      ast_log(LOG_WARNING, "Function doesn't contain parentheses.  Assuming null argument.\n");
   }

   if ((acfptr = ast_custom_function_find(function))) {
      /* run the custom function */
      if (acfptr->write) {
         acfptr->write(chan, function, args, value);
      } else {
         ast_log(LOG_ERROR, "Function %s is read-only, it cannot be written to\n", function);
      }
   } else {
      ast_log(LOG_ERROR, "Function %s not registered\n", function);
   }
}

const char* ast_get_context_name

(

struct ast_context *

con

)

Definition at line 6319 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(), ast_context_verify_includes(), complete_context_add_extension(), complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_extension(), complete_context_remove_ignorepat(), complete_show_dialplan_context(), dundi_precache_full(), find_matching_endwhile(), find_matching_priority(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   return con ? con->name : NULL;
}

const char* ast_get_context_registrar

(

struct ast_context *

c

)

Definition at line 6352 of file pbx.c.

References ast_context::registrar.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return c ? c->registrar : NULL;
}

const char* ast_get_extension_app

(

struct ast_exten *

e

)

Definition at line 6382 of file pbx.c.

References ast_exten::app.

Referenced by ast_add_hint(), ast_extension_state2(), ast_get_hint(), ast_hint_state_changed(), find_matching_endwhile(), handle_save_dialplan(), handle_show_hints(), macro_exec(), and show_dialplan_helper().

{
   return e ? e->app : NULL;
}

void* ast_get_extension_app_data

(

struct ast_exten *

e

)

Definition at line 6387 of file pbx.c.

References ast_exten::data.

Referenced by ast_get_hint(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   return e ? e->data : NULL;
}

const char* ast_get_extension_cidmatch

(

struct ast_exten *

e

)

Definition at line 6377 of file pbx.c.

References ast_exten::cidmatch.

Referenced by find_matching_priority(), and handle_save_dialplan().

{
   return e ? e->cidmatch : NULL;
}

const char* ast_get_extension_label

(

struct ast_exten *

exten

)

Definition at line 6329 of file pbx.c.

References ast_exten::label.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return exten ? exten->label : NULL;
}

int ast_get_extension_matchcid

(

struct ast_exten *

e

)

Definition at line 6372 of file pbx.c.

References ast_exten::matchcid.

Referenced by find_matching_priority(), and handle_save_dialplan().

{
   return e ? e->matchcid : 0;
}

const char* ast_get_extension_name

(

struct ast_exten *

exten

)

Definition at line 6324 of file pbx.c.

References ast_exten::exten.

Referenced by ast_add_hint(), complete_context_remove_extension(), dundi_precache_full(), find_matching_priority(), handle_save_dialplan(), handle_show_hints(), and show_dialplan_helper().

{
   return exten ? exten->exten : NULL;
}

int ast_get_extension_priority

(

struct ast_exten *

exten

)

Definition at line 6344 of file pbx.c.

References ast_exten::priority.

Referenced by complete_context_remove_extension(), find_matching_priority(), handle_save_dialplan(), and show_dialplan_helper().

{
   return exten ? exten->priority : -1;
}

const char* ast_get_extension_registrar

(

struct ast_exten *

e

)

Definition at line 6357 of file pbx.c.

References ast_exten::registrar.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return e ? e->registrar : NULL;
}

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

ast_get_hint: Get hint for channel

If an extension exists, return non-zero

Parameters:

	hint	buffer for hint
	maxlen	size of hint buffer
	name	buffer for name portion of hint
	maxnamelen	size of name 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 2204 of file pbx.c.

References ast_get_extension_app(), ast_get_extension_app_data(), and ast_hint_extension().

Referenced by action_extensionstate(), get_cid_name(), pbx_retrieve_variable(), and transmit_state_notify().

{
   struct ast_exten *e;
   void *tmp;

   e = ast_hint_extension(c, context, exten);
   if (e) {
      if (hint) 
          ast_copy_string(hint, ast_get_extension_app(e), hintsize);
      if (name) {
         tmp = ast_get_extension_app_data(e);
         if (tmp)
            ast_copy_string(name, (char *) tmp, namesize);
      }
       return -1;
   }
   return 0;   
}

const char* ast_get_ignorepat_name

(

struct ast_ignorepat *

ip

)

Definition at line 6339 of file pbx.c.

References ast_ignorepat::pattern.

Referenced by complete_context_add_ignorepat(), complete_context_remove_ignorepat(), handle_save_dialplan(), and show_dialplan_helper().

{
   return ip ? ip->pattern : NULL;
}

const char* ast_get_ignorepat_registrar

(

struct ast_ignorepat *

ip

)

Definition at line 6367 of file pbx.c.

References ast_ignorepat::registrar.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return ip ? ip->registrar : NULL;
}

const char* ast_get_include_name

(

struct ast_include *

inc

)

Definition at line 6334 of file pbx.c.

References ast_include::name.

Referenced by complete_context_add_include(), complete_context_dont_include(), find_matching_priority(), handle_save_dialplan(), and show_dialplan_helper().

{
   return inc ? inc->name : NULL;
}

const char* ast_get_include_registrar

(

struct ast_include *

i

)

Definition at line 6362 of file pbx.c.

References ast_include::registrar.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return i ? i->registrar : NULL;
}

const char* ast_get_switch_data

(

struct ast_sw *

sw

)

Definition at line 6397 of file pbx.c.

References ast_sw::data.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return sw ? sw->data : NULL;
}

const char* ast_get_switch_name

(

struct ast_sw *

sw

)

Definition at line 6392 of file pbx.c.

References ast_sw::name.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return sw ? sw->name : NULL;
}

const char* ast_get_switch_registrar

(

struct ast_sw *

sw

)

Definition at line 6402 of file pbx.c.

References ast_sw::registrar.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   return sw ? sw->registrar : NULL;
}

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

Definition at line 6495 of file pbx.c.

References __ast_goto_if_exists().

Referenced by aqm_exec(), auth_exec(), background_detect_exec(), chanavail_exec(), conf_run(), controlplayback_exec(), dial_exec_full(), do_directory(), dundi_lookup_exec(), enumlookup_exec(), get_exec(), group_check_exec(), hasvoicemail_exec(), leave_voicemail(), lookupblacklist_exec(), md5check_exec(), onedigit_goto(), ospfinished_exec(), osplookup_exec(), ospnext_exec(), play_mailbox_owner(), playback_exec(), pqm_exec(), privacy_exec(), rqm_exec(), sendimage_exec(), sendtext_exec(), sendurl_exec(), sip_getheader(), system_exec_helper(), transfer_exec(), txtcidname_exec(), upqm_exec(), valid_exit(), vm_box_exists(), vm_exec(), and wait_for_answer().

                                                                                           {
   return __ast_goto_if_exists(chan, context, exten, priority, 0);
}

static struct ast_exten* ast_hint_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten
	)			[static, read]

ast_hint_extension: Find hint for given extension in context

Definition at line 1788 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), AST_PBX_MAX_STACK, HELPER_EXISTS, LOG_WARNING, pbx_find_extension(), and PRIORITY_HINT.

Referenced by ast_extension_state(), ast_extension_state_add(), ast_get_hint(), and ast_merge_contexts_and_delete().

{
   struct ast_exten *e;
   struct ast_switch *sw;
   char *data;
   const char *foundcontext = NULL;
   int status = 0;
   char *incstack[AST_PBX_MAX_STACK];
   int stacklen = 0;

   if (ast_mutex_lock(&conlock)) {
      ast_log(LOG_WARNING, "Unable to obtain lock\n");
      return NULL;
   }
   e = pbx_find_extension(c, NULL, context, exten, PRIORITY_HINT, NULL, "", HELPER_EXISTS, incstack, &stacklen, &status, &sw, &data, &foundcontext);
   ast_mutex_unlock(&conlock);   
   return e;
}

void ast_hint_state_changed

(

const char *

device

)

Definition at line 1906 of file pbx.c.

References ast_extension_state2(), 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_state_cb::next, ast_hint::next, ast_exten::parent, parse(), and strsep().

Referenced by do_state_change().

{
   struct ast_hint *hint;
   struct ast_state_cb *cblist;
   char buf[AST_MAX_EXTENSION];
   char *parse;
   char *cur;
   int state;

   ast_mutex_lock(&hintlock);

   for (hint = hints; hint; hint = hint->next) {
      ast_copy_string(buf, ast_get_extension_app(hint->exten), sizeof(buf));
      parse = buf;
      for (cur = strsep(&parse, "&"); cur; cur = strsep(&parse, "&")) {
         if (strcasecmp(cur, device))
            continue;

         /* Get device state for this hint */
         state = ast_extension_state2(hint->exten);
         
         if ((state == -1) || (state == hint->laststate))
            continue;

         /* Device state changed since last check - notify the watchers */
         
         /* For general callbacks */
         for (cblist = statecbs; cblist; cblist = cblist->next)
            cblist->callback(hint->exten->parent->name, hint->exten->exten, state, cblist->data);
         
         /* For extension callbacks */
         for (cblist = hint->callbacks; cblist; cblist = cblist->next)
            cblist->callback(hint->exten->parent->name, hint->exten->exten, state, cblist->data);
         
         hint->laststate = state;
         break;
      }
   }

   ast_mutex_unlock(&hintlock);
}

int ast_ignore_pattern	(	const char *	context,
		const char *	pattern
	)

Checks to see if a number should be ignored

Parameters:

	context	context to search within
	pattern	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 4505 of file pbx.c.

References ast_context_find(), ast_extension_match(), ast_context::ignorepats, ast_ignorepat::next, and ast_ignorepat::pattern.

Referenced by ast_app_dtget(), disa_exec(), dp_lookup(), dundi_lookup_local(), mgcp_ss(), skinny_ss(), and ss_thread().

{
   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;
}

AST_LIST_HEAD	(	store_hints	,
		store_hint
	)

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 6306 of file pbx.c.

References ast_mutex_lock(), and ast_context::lock.

Referenced by complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_ignorepat(), dundi_precache_full(), find_matching_endwhile(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   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 6293 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(), ast_context_remove_switch(), complete_context_add_extension(), complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_extension(), complete_context_remove_ignorepat(), complete_show_dialplan_context(), dundi_precache_full(), find_matching_endwhile(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   return ast_mutex_lock(&conlock);
}

int ast_matchmore_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		int	priority,
		const 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 2243 of file pbx.c.

References HELPER_MATCHMORE, and pbx_extension_helper().

Referenced by __ast_pbx_run(), ast_app_dtget(), disa_exec(), dp_lookup(), dundi_lookup_local(), loopback_matchmore(), mgcp_ss(), skinny_ss(), and ss_thread().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, callerid, HELPER_MATCHMORE);
}

void ast_merge_contexts_and_delete	(	struct ast_context **	extcontexts,
		const 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
	registrar	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 3720 of file pbx.c.

References __ast_context_destroy(), AST_EXTENSION_REMOVED, ast_hint_extension(), AST_LIST_HEAD_INIT, AST_LIST_INSERT_HEAD, AST_LIST_REMOVE_HEAD, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_state_cb::callback, store_hint::callbacks, ast_hint::callbacks, calloc, store_hint::context, ast_state_cb::data, ast_exten::exten, ast_hint::exten, store_hint::exten, free, ast_hint::laststate, store_hint::laststate, LOG_WARNING, ast_context::name, ast_state_cb::next, ast_context::next, ast_hint::next, ast_exten::parent, and ast_context::registrar.

Referenced by pbx_load_module().

{
   struct ast_context *tmp, *lasttmp = NULL;
   struct store_hints store;
   struct store_hint *this;
   struct ast_hint *hint;
   struct ast_exten *exten;
   int length;
   struct ast_state_cb *thiscb, *prevcb;

   memset(&store, 0, sizeof(store));
   AST_LIST_HEAD_INIT(&store);

   /* it is very important that this function hold the hintlock _and_ the conlock
      during its operation; not only do we need to ensure that the list of contexts
      and extensions does not change, but also that no hint callbacks (watchers) are
      added or removed during the merge/delete process

      in addition, the locks _must_ be taken in this order, because there are already
      other code paths that use this order
   */
   ast_mutex_lock(&conlock);
   ast_mutex_lock(&hintlock);

   /* preserve all watchers for hints associated with this registrar */
   for (hint = hints; hint; hint = hint->next) {
      if (hint->callbacks && !strcmp(registrar, hint->exten->parent->registrar)) {
         length = strlen(hint->exten->exten) + strlen(hint->exten->parent->name) + 2 + sizeof(*this);
         this = calloc(1, length);
         if (!this) {
            ast_log(LOG_WARNING, "Could not allocate memory to preserve hint\n");
            continue;
         }
         this->callbacks = hint->callbacks;
         hint->callbacks = NULL;
         this->laststate = hint->laststate;
         this->context = this->data;
         strcpy(this->data, hint->exten->parent->name);
         this->exten = this->data + strlen(this->context) + 1;
         strcpy(this->exten, hint->exten->exten);
         AST_LIST_INSERT_HEAD(&store, this, list);
      }
   }

   tmp = *extcontexts;
   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");

   /* restore the watchers for hints that can be found; notify those that
      cannot be restored
   */
   while ((this = AST_LIST_REMOVE_HEAD(&store, list))) {
      exten = ast_hint_extension(NULL, this->context, this->exten);
      /* Find the hint in the list of hints */
      for (hint = hints; hint; hint = hint->next) {
         if (hint->exten == exten)
            break;
      }
      if (!exten || !hint) {
         /* this hint has been removed, notify the watchers */
         prevcb = NULL;
         thiscb = this->callbacks;
         while (thiscb) {
            prevcb = thiscb;      
            thiscb = thiscb->next;
            prevcb->callback(this->context, this->exten, AST_EXTENSION_REMOVED, prevcb->data);
            free(prevcb);
            }
      } else {
         thiscb = this->callbacks;
         while (thiscb->next)
            thiscb = thiscb->next;
         thiscb->next = hint->callbacks;
         hint->callbacks = this->callbacks;
         hint->laststate = this->laststate;
      }
      free(this);
   }

   ast_mutex_unlock(&hintlock);
   ast_mutex_unlock(&conlock);

   return;  
}

AST_MUTEX_DEFINE_STATIC

(

hintlock

)

AST_MUTEX_DEFINE_STATIC

(

switchlock

)

AST_MUTEX_DEFINE_STATIC

(

applock

)

AST_MUTEX_DEFINE_STATIC

(

conlock

)

AST_MUTEX_DEFINE_STATIC

(

acflock

)

Lock for the custom function list

AST_MUTEX_DEFINE_STATIC

(

maxcalllock

)

AST_MUTEX_DEFINE_STATIC

(

globalslock

)

int ast_parseable_goto	(	struct ast_channel *	chan,
		const char *	goto_string
	)

Definition at line 6503 of file pbx.c.

References ast_cdr_update(), ast_explicit_goto(), ast_findlabel_extension(), ast_log(), ast_strdupa, ast_strlen_zero(), ast_channel::cid, ast_callerid::cid_num, ast_channel::context, ast_channel::exten, store_hint::exten, LOG_WARNING, ast_channel::priority, s, and strsep().

Referenced by _while_exec(), check_goto_on_transfer(), dial_exec_full(), gosub_exec(), ivr_dispatch(), pbx_builtin_goto(), random_exec(), and return_exec().

{
   char *s;
   char *exten, *pri, *context;
   char *stringp=NULL;
   int ipri;
   int mode = 0;

   if (ast_strlen_zero(goto_string)) {
      ast_log(LOG_WARNING, "Goto requires an argument (optional context|optional extension|priority)\n");
      return -1;
   }
   s = ast_strdupa(goto_string);
   stringp=s;
   context = strsep(&stringp, "|");
   exten = strsep(&stringp, "|");
   if (!exten) {
      /* Only a priority in this one */
      pri = context;
      exten = NULL;
      context = NULL;
   } else {
      pri = strsep(&stringp, "|");
      if (!pri) {
         /* Only an extension and priority in this one */
         pri = exten;
         exten = context;
         context = NULL;
      }
   }
   if (*pri == '+') {
      mode = 1;
      pri++;
   } else if (*pri == '-') {
      mode = -1;
      pri++;
   }
   if (sscanf(pri, "%30d", &ipri) != 1) {
      if ((ipri = ast_findlabel_extension(chan, context ? context : chan->context, (exten && strcasecmp(exten, "BYEXTENSION")) ? exten : chan->exten, 
         pri, chan->cid.cid_num)) < 1) {
         ast_log(LOG_WARNING, "Priority '%s' must be a number > 0, or valid label\n", pri);
         return -1;
      } else
         mode = 0;
   } 
   /* At this point we have a priority and maybe an extension and a context */

   if (exten && !strcasecmp(exten, "BYEXTENSION"))
      exten = NULL;

   if (mode) 
      ipri = chan->priority + (ipri * mode);

   ast_explicit_goto(chan, context, exten, ipri);
   ast_cdr_update(chan);
   return 0;

}

int ast_pbx_outgoing_app	(	const char *	type,
		int	format,
		void *	data,
		int	timeout,
		const char *	app,
		const char *	appdata,
		int *	reason,
		int	sync,
		const char *	cid_num,
		const char *	cid_name,
		struct ast_variable *	vars,
		const char *	account,
		struct ast_channel **	locked_channel
	)

Definition at line 5183 of file pbx.c.

References __ast_request_and_dial(), ast_channel::_state, outgoing_helper::account, async_stat::app, app_tmp::app, async_stat::appdata, ast_cdr_alloc(), ast_cdr_disposition(), ast_cdr_failed(), ast_cdr_init(), ast_cdr_setaccount(), ast_cdr_start(), ast_hangup(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pbx_outgoing_cdr_failed(), ast_pbx_run_app(), ast_pthread_create, ast_set_variables(), AST_STATE_UP, ast_strlen_zero(), ast_variables_destroy(), ast_verbose(), async_wait(), ast_channel::cdr, async_stat::chan, app_tmp::chan, app_tmp::data, free, ast_channel::hangupcause, ast_channel::lock, LOG_ERROR, LOG_WARNING, malloc, ast_channel::name, option_verbose, async_stat::p, ast_channel::pbx, app_tmp::t, async_stat::timeout, outgoing_helper::vars, and VERBOSE_PREFIX_4.

Referenced by action_originate(), attempt_thread(), fast_originate(), and page_thread().

{
   struct ast_channel *chan;
   struct async_stat *as;
   struct app_tmp *tmp;
   int res = -1, cdr_res = -1;
   struct outgoing_helper oh;
   pthread_attr_t attr;

   memset(&oh, 0, sizeof(oh));
   oh.vars = vars;
   oh.account = account;   

   if (locked_channel) 
      *locked_channel = NULL;
   if (ast_strlen_zero(app)) {
      res = -1;
      goto outgoing_app_cleanup; 
   }
   if (sync) {
      chan = __ast_request_and_dial(type, format, data, timeout, reason, cid_num, cid_name, &oh);
      if (chan) {
         if (chan->cdr) { /* check if the channel already has a cdr record, if not give it one */
            ast_log(LOG_WARNING, "%s already has a call record??\n", chan->name);
         } else {
            chan->cdr = ast_cdr_alloc();   /* allocate a cdr for the channel */
            if(!chan->cdr) {
               /* allocation of the cdr failed */
               ast_log(LOG_WARNING, "Unable to create Call Detail Record\n");
               free(chan->pbx);
               res = -1;
               goto outgoing_app_cleanup;
            }
            /* allocation of the cdr was successful */
            ast_cdr_init(chan->cdr, chan);  /* initilize our channel's cdr */
            ast_cdr_start(chan->cdr);
         }
         ast_set_variables(chan, vars);
         if (account)
            ast_cdr_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);
            tmp = malloc(sizeof(struct app_tmp));
            if (tmp) {
               memset(tmp, 0, sizeof(struct app_tmp));
               ast_copy_string(tmp->app, app, sizeof(tmp->app));
               if (appdata)
                  ast_copy_string(tmp->data, appdata, sizeof(tmp->data));
               tmp->chan = chan;
               if (sync > 1) {
                  if (locked_channel)
                     ast_mutex_unlock(&chan->lock);
                  ast_pbx_run_app(tmp);
               } else {
                  pthread_attr_init(&attr);
                  pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
                  if (locked_channel) 
                     ast_mutex_lock(&chan->lock);
                  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);
                     if (locked_channel) 
                        ast_mutex_unlock(&chan->lock);
                     ast_hangup(chan);
                     res = -1;
                  } else {
                     if (locked_channel) 
                        *locked_channel = chan;
                  }
                  pthread_attr_destroy(&attr);
               }
            } 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);
            if (chan->cdr) { /* update the cdr */
               /* here we update the status of the call, which sould be busy.
                * if that fails then we set the status to failed */
               if (ast_cdr_disposition(chan->cdr, chan->hangupcause))
                  ast_cdr_failed(chan->cdr);
            }
            ast_hangup(chan);
         }
      }
      
      if (res < 0) { /* the call failed for some reason */
         if (*reason == 0) { /* if the call failed (not busy or no answer)
                        * update the cdr with the failed message */
            cdr_res = ast_pbx_outgoing_cdr_failed();
            if (cdr_res != 0) {
               res = cdr_res;
               goto outgoing_app_cleanup;
            }
         }
      }

   } else {
      as = malloc(sizeof(struct async_stat));
      if (!as) {
         res = -1;
         goto outgoing_app_cleanup;
      }
      memset(as, 0, sizeof(struct async_stat));
      chan = __ast_request_and_dial(type, format, data, timeout, reason, cid_num, cid_name, &oh);
      if (!chan) {
         free(as);
         res = -1;
         goto outgoing_app_cleanup;
      }
      as->chan = chan;
      ast_copy_string(as->app, app, sizeof(as->app));
      if (appdata)
         ast_copy_string(as->appdata,  appdata, sizeof(as->appdata));
      as->timeout = timeout;
      ast_set_variables(chan, vars);
      if (account)
         ast_cdr_setaccount(chan, account);
      /* Start a new thread, and get something handling this channel. */
      pthread_attr_init(&attr);
      pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
      if (locked_channel) 
         ast_mutex_lock(&chan->lock);
      if (ast_pthread_create(&as->p, &attr, async_wait, as)) {
         ast_log(LOG_WARNING, "Failed to start async wait\n");
         free(as);
         if (locked_channel) 
            ast_mutex_unlock(&chan->lock);
         ast_hangup(chan);
         res = -1;
         pthread_attr_destroy(&attr);
         goto outgoing_app_cleanup;
      } else {
         if (locked_channel)
            *locked_channel = chan;
      }
      pthread_attr_destroy(&attr);
      res = 0;
   }
outgoing_app_cleanup:
   ast_variables_destroy(vars);
   return res;
}

int ast_pbx_outgoing_cdr_failed

(

void

)

Function to post an empty cdr after a spool call fails.

This function posts an empty cdr for a failed spool call

Definition at line 4977 of file pbx.c.

References ast_cdr_alloc(), ast_cdr_detach(), ast_cdr_end(), ast_cdr_failed(), ast_cdr_init(), ast_cdr_start(), ast_channel_alloc(), ast_channel_free(), ast_log(), ast_channel::cdr, and LOG_WARNING.

Referenced by ast_pbx_outgoing_app(), and ast_pbx_outgoing_exten().

{
   /* allocate a channel */
   struct ast_channel *chan = ast_channel_alloc(0);
   if(!chan) {
      /* allocation of the channel failed, let some peeps know */
      ast_log(LOG_WARNING, "Unable to allocate channel structure for CDR record\n");
      return -1;  /* failure */
   }

   chan->cdr = ast_cdr_alloc();   /* allocate a cdr for the channel */

   if(!chan->cdr) {
      /* allocation of the cdr failed */
      ast_log(LOG_WARNING, "Unable to create Call Detail Record\n");
      ast_channel_free(chan);   /* free the channel */
      return -1;                /* return failure */
   }
   
   /* allocation of the cdr was successful */
   ast_cdr_init(chan->cdr, chan);  /* initilize our channel's cdr */
   ast_cdr_start(chan->cdr);       /* record the start and stop time */
   ast_cdr_end(chan->cdr);
   ast_cdr_failed(chan->cdr);      /* set the status to failed */
   ast_cdr_detach(chan->cdr);      /* post and free the record */
   ast_channel_free(chan);         /* free the channel */
   
   return 0;  /* success */
}

int ast_pbx_outgoing_exten	(	const char *	type,
		int	format,
		void *	data,
		int	timeout,
		const char *	context,
		const char *	exten,
		int	priority,
		int *	reason,
		int	sync,
		const char *	cid_num,
		const char *	cid_name,
		struct ast_variable *	vars,
		const char *	account,
		struct ast_channel **	channel
	)

Definition at line 5007 of file pbx.c.

References __ast_request_and_dial(), ast_channel::_state, ast_cdr_alloc(), ast_cdr_disposition(), ast_cdr_failed(), ast_cdr_init(), ast_cdr_setaccount(), ast_cdr_start(), ast_channel_alloc(), ast_exists_extension(), ast_hangup(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pbx_outgoing_cdr_failed(), ast_pbx_run(), ast_pbx_start(), ast_pthread_create, ast_request_and_dial(), ast_set_variables(), AST_STATE_UP, ast_strlen_zero(), ast_variables_destroy(), ast_verbose(), async_wait(), ast_channel::cdr, async_stat::chan, async_stat::context, ast_channel::context, async_stat::exten, ast_channel::exten, free, ast_channel::hangupcause, LOAD_OH, ast_channel::lock, LOG_ERROR, LOG_WARNING, malloc, ast_channel::name, option_verbose, async_stat::p, ast_channel::pbx, async_stat::priority, ast_channel::priority, async_stat::timeout, and VERBOSE_PREFIX_4.

Referenced by action_originate(), attempt_thread(), and fast_originate().

{
   struct ast_channel *chan;
   struct async_stat *as;
   int res = -1, cdr_res = -1;
   struct outgoing_helper oh;
   pthread_attr_t attr;

   if (sync) {
      LOAD_OH(oh);
      chan = __ast_request_and_dial(type, format, data, timeout, reason, cid_num, cid_name, &oh);
      if (channel) {
         *channel = chan;
         if (chan)
            ast_mutex_lock(&chan->lock);
      }
      if (chan) {
         if (chan->cdr) { /* check if the channel already has a cdr record, if not give it one */
            ast_log(LOG_WARNING, "%s already has a call record??\n", chan->name);
         } else {
            chan->cdr = ast_cdr_alloc();   /* allocate a cdr for the channel */
            if (!chan->cdr) {
               /* allocation of the cdr failed */
               ast_log(LOG_WARNING, "Unable to create Call Detail Record\n");
               free(chan->pbx);
               res = -1;
               goto outgoing_exten_cleanup;
            }
            /* allocation of the cdr was successful */
            ast_cdr_init(chan->cdr, chan);  /* initilize our channel's cdr */
            ast_cdr_start(chan->cdr);
         }
         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 (channel)
                  ast_mutex_unlock(&chan->lock);
               if (ast_pbx_run(chan)) {
                  ast_log(LOG_ERROR, "Unable to run PBX on %s\n", chan->name);
                  if (channel)
                     *channel = NULL;
                  ast_hangup(chan);
                  res = -1;
               }
            } else {
               if (ast_pbx_start(chan)) {
                  ast_log(LOG_ERROR, "Unable to start PBX on %s\n", chan->name);
                  if (channel) {
                     *channel = NULL;
                     ast_mutex_unlock(&chan->lock);
                  }
                  ast_hangup(chan);
                  res = -1;
               } 
            }
         } else {
            if (option_verbose > 3)
               ast_verbose(VERBOSE_PREFIX_4 "Channel %s was never answered.\n", chan->name);

            if(chan->cdr) { /* update the cdr */
               /* here we update the status of the call, which sould be busy.
                * if that fails then we set the status to failed */
               if (ast_cdr_disposition(chan->cdr, chan->hangupcause))
                  ast_cdr_failed(chan->cdr);
            }
         
            if (channel) {
               *channel = NULL;
               ast_mutex_unlock(&chan->lock);
            }
            ast_hangup(chan);
         }
      }

      if (res < 0) { /* the call failed for some reason */
         if (*reason == 0) { /* if the call failed (not busy or no answer)
                        * update the cdr with the failed message */
            cdr_res = ast_pbx_outgoing_cdr_failed();
            if (cdr_res != 0) {
               res = cdr_res;
               goto outgoing_exten_cleanup;
            }
         }
         
         /* 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) {
               ast_copy_string(chan->name, "OutgoingSpoolFailed", sizeof(chan->name));
               if (!ast_strlen_zero(context))
                  ast_copy_string(chan->context, context, sizeof(chan->context));
               ast_copy_string(chan->exten, "failed", sizeof(chan->exten));
               chan->priority = 1;
               ast_set_variables(chan, vars);
               if (account)
                  ast_cdr_setaccount(chan, account);
               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) {
         res = -1;
         goto outgoing_exten_cleanup;
      }  
      memset(as, 0, sizeof(struct async_stat));
      chan = ast_request_and_dial(type, format, data, timeout, reason, cid_num, cid_name);
      if (channel) {
         *channel = chan;
         if (chan)
            ast_mutex_lock(&chan->lock);
      }
      if (!chan) {
         free(as);
         res = -1;
         goto outgoing_exten_cleanup;
      }
      as->chan = chan;
      ast_copy_string(as->context, context, sizeof(as->context));
      ast_copy_string(as->exten,  exten, sizeof(as->exten));
      as->priority = priority;
      as->timeout = timeout;
      ast_set_variables(chan, vars);
      if (account)
         ast_cdr_setaccount(chan, account);
      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);
         if (channel) {
            *channel = NULL;
            ast_mutex_unlock(&chan->lock);
         }
         ast_hangup(chan);
         res = -1;
         pthread_attr_destroy(&attr);
         goto outgoing_exten_cleanup;
      }
      pthread_attr_destroy(&attr);
      res = 0;
   }
outgoing_exten_cleanup:
   ast_variables_destroy(vars);
   return res;
}

enum ast_pbx_result ast_pbx_run

(

struct ast_channel *

c

)

Execute the PBX in the current thread

Parameters:

c

channel to run the pbx on

Returns:

Zero on success, non-zero on failure 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 2571 of file pbx.c.

References __ast_pbx_run(), AST_PBX_CALL_LIMIT, AST_PBX_SUCCESS, decrease_call_count(), and increase_call_count().

Referenced by ast_pbx_outgoing_exten(), async_wait(), mgcp_ss(), skinny_ss(), and ss_thread().

{
   enum ast_pbx_result res = AST_PBX_SUCCESS;

   if (increase_call_count(c))
      return AST_PBX_CALL_LIMIT;

   res = __ast_pbx_run(c);
   decrease_call_count();

   return res;
}

static void* ast_pbx_run_app

(

void *

data

)

[static]

Definition at line 5167 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 "Launching %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;
}

enum ast_pbx_result 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

Returns:

Zero on success, non-zero on failure

Definition at line 2545 of file pbx.c.

References ast_log(), AST_PBX_CALL_LIMIT, AST_PBX_FAILED, AST_PBX_SUCCESS, ast_pthread_create, increase_call_count(), LOG_WARNING, pbx_thread(), and t.

Referenced by __oh323_new(), alsa_new(), ast_async_goto(), ast_iax2_new(), ast_modem_new(), ast_pbx_outgoing_exten(), check_goto_on_transfer(), dial_exec_full(), do_parking_thread(), handle_request_invite(), local_call(), mgcp_new(), nbs_new(), oss_new(), pbx_start_chan(), phone_new(), rpt_call(), sip_new(), skinny_new(), vpb_new(), and zt_new().

{
   pthread_t t;
   pthread_attr_t attr;

   if (!c) {
      ast_log(LOG_WARNING, "Asked to start thread on NULL channel?\n");
      return AST_PBX_FAILED;
   }
      
   if (increase_call_count(c))
      return AST_PBX_CALL_LIMIT;

   /* 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");
      pthread_attr_destroy(&attr);
      return AST_PBX_FAILED;
   }
   pthread_attr_destroy(&attr);

   return AST_PBX_SUCCESS;
}

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

Dynamically register a new dial plan application.

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 2888 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), COLOR_BRCYAN, ast_app::description, ast_app::execute, LOG_ERROR, LOG_WARNING, malloc, ast_app::name, ast_app::next, option_verbose, ast_app::synopsis, term_color(), and VERBOSE_PREFIX_2.

Referenced by load_module(), and load_pbx().

{
   struct ast_app *tmp, *prev, *cur;
   char tmps[80];
   int length;
   length = sizeof(struct ast_app);
   length += strlen(app) + 1;
   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(length);
   if (tmp) {
      memset(tmp, 0, length);
      strcpy(tmp->name, app);
      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 2942 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_ERROR, LOG_WARNING, ast_switch::name, and ast_switch::next.

Referenced by load_module().

{
   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;
}

static int ast_remove_hint

(

struct ast_exten *

e

)

[static]

ast_remove_hint: Remove hint from extension

Definition at line 2159 of file pbx.c.

References AST_EXTENSION_DEACTIVATED, ast_mutex_lock(), ast_mutex_unlock(), ast_state_cb::callback, ast_hint::callbacks, ast_state_cb::data, ast_exten::exten, ast_hint::exten, free, list, ast_context::name, ast_hint::next, ast_state_cb::next, and ast_exten::parent.

Referenced by ast_context_remove_extension2(), and destroy_exten().

{
   /* Cleanup the Notifys if hint is removed */
   struct ast_hint *list, *prev = NULL;
   struct ast_state_cb *cblist, *cbprev;

   if (!e) 
      return -1;

   ast_mutex_lock(&hintlock);

   list = hints;    
   while(list) {
      if (list->exten==e) {
         cbprev = NULL;
         cblist = list->callbacks;
         while (cblist) {
            /* Notify with -1 and remove all callbacks */
            cbprev = cblist;      
            cblist = cblist->next;
            cbprev->callback(list->exten->parent->name, list->exten->exten, AST_EXTENSION_DEACTIVATED, cbprev->data);
            free(cbprev);
            }
            list->callbacks = NULL;

            if (!prev)
            hints = list->next;
            else
            prev->next = list->next;
            free(list);
       
         ast_mutex_unlock(&hintlock);
         return 0;
      } else {
         prev = list;
         list = list->next;    
      }
   }

   ast_mutex_unlock(&hintlock);
   return -1;
}

int ast_spawn_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		int	priority,
		const 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 2248 of file pbx.c.

References HELPER_SPAWN, and pbx_extension_helper().

Referenced by __ast_pbx_run(), loopback_exec(), and macro_exec().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, 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 6311 of file pbx.c.

References ast_mutex_unlock(), and ast_context::lock.

Referenced by complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_ignorepat(), dundi_precache_full(), find_matching_endwhile(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   return ast_mutex_unlock(&con->lock);
}

int ast_unlock_contexts

(

void

)

Unlocks contexts

Returns 0 on success, -1 on failure

Definition at line 6298 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(), ast_context_remove_switch(), complete_context_add_extension(), complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_extension(), complete_context_remove_ignorepat(), complete_show_dialplan_context(), dundi_precache_full(), find_matching_endwhile(), handle_save_dialplan(), macro_exec(), and show_dialplan_helper().

{
   return ast_mutex_unlock(&conlock);
}

int ast_unregister_application

(

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

Referenced by __unload_module(), and unload_module().

{
   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 2970 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_ERROR, and ast_switch::next.

Referenced by __unload_module(), and unload_module().

{
   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
	)			[read]

Definition at line 6418 of file pbx.c.

References ast_exten::next, and ast_context::root.

Referenced by complete_context_remove_extension(), dundi_precache_full(), find_matching_priority(), handle_save_dialplan(), and show_dialplan_helper().

{
   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
	)			[read]

Definition at line 6454 of file pbx.c.

References ast_context::ignorepats, and ast_ignorepat::next.

Referenced by complete_context_add_ignorepat(), complete_context_remove_ignorepat(), handle_save_dialplan(), and show_dialplan_helper().

{
   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
	)			[read]

Definition at line 6445 of file pbx.c.

References ast_context::includes, and ast_include::next.

Referenced by ast_context_verify_includes(), complete_context_add_include(), complete_context_dont_include(), find_matching_priority(), handle_save_dialplan(), and show_dialplan_helper().

{
   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
	)			[read]

Definition at line 6427 of file pbx.c.

References ast_context::alts, and ast_sw::next.

Referenced by handle_save_dialplan(), and show_dialplan_helper().

{
   if (!sw)
      return con ? con->alts : NULL;
   else
      return sw->next;
}

struct ast_context* ast_walk_contexts

(

struct ast_context *

con

)

[read]

Definition at line 6410 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(), ast_context_remove_switch(), complete_context_add_extension(), complete_context_add_ignorepat(), complete_context_add_include(), complete_context_dont_include(), complete_context_remove_extension(), complete_context_remove_ignorepat(), complete_show_dialplan_context(), dundi_precache_full(), find_matching_endwhile(), find_matching_priority(), handle_save_dialplan(), macro_exec(), pbx_load_module(), and show_dialplan_helper().

{
   if (!con)
      return contexts;
   else
      return con->next;
}

struct ast_exten* ast_walk_extension_priorities	(	struct ast_exten *	exten,
		struct ast_exten *	priority
	)			[read]

Definition at line 6436 of file pbx.c.

References ast_exten::peer.

Referenced by complete_context_remove_extension(), find_matching_priority(), handle_save_dialplan(), and show_dialplan_helper().

{
   if (!priority)
      return exten;
   else
      return priority->peer;
}

static void* async_wait

(

void *

data

)

[static]

Definition at line 4913 of file pbx.c.

References ast_channel::_state, async_stat::app, async_stat::appdata, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_FRAME_CONTROL, ast_frfree(), ast_hangup(), ast_log(), ast_pbx_run(), ast_read(), AST_STATE_UP, ast_strlen_zero(), ast_verbose(), ast_waitfor(), async_stat::chan, ast_channel::context, async_stat::context, ast_channel::exten, async_stat::exten, ast_frame::frametype, free, LOG_ERROR, LOG_WARNING, ast_channel::name, option_verbose, pbx_exec(), pbx_findapp(), ast_channel::priority, async_stat::priority, ast_frame::subclass, async_stat::timeout, and VERBOSE_PREFIX_3.

Referenced by ast_pbx_outgoing_app(), and ast_pbx_outgoing_exten().

{
   struct async_stat *as = data;
   struct ast_channel *chan = as->chan;
   int timeout = as->timeout;
   int res;
   struct ast_frame *f;
   struct ast_app *app;
   
   while(timeout && (chan->_state != AST_STATE_UP)) {
      res = ast_waitfor(chan, timeout);
      if (res < 1) 
         break;
      if (timeout > -1)
         timeout = res;
      f = ast_read(chan);
      if (!f)
         break;
      if (f->frametype == AST_FRAME_CONTROL) {
         if ((f->subclass == AST_CONTROL_BUSY)  ||
             (f->subclass == AST_CONTROL_CONGESTION) ) {
            ast_frfree(f);
            break;
         }
      }
      ast_frfree(f);
   }
   if (chan->_state == AST_STATE_UP) {
      if (!ast_strlen_zero(as->app)) {
         app = pbx_findapp(as->app);
         if (app) {
            if (option_verbose > 2)
               ast_verbose(VERBOSE_PREFIX_3 "Launching %s(%s) on %s\n", as->app, as->appdata, chan->name);
            pbx_exec(chan, app, as->appdata, 1);
         } else
            ast_log(LOG_WARNING, "No such application '%s'\n", as->app);
      } else {
         if (!ast_strlen_zero(as->context))
            ast_copy_string(chan->context, as->context, sizeof(chan->context));
         if (!ast_strlen_zero(as->exten))
            ast_copy_string(chan->exten, as->exten, sizeof(chan->exten));
         if (as->priority > 0)
            chan->priority = as->priority;
         /* Run the PBX */
         if (ast_pbx_run(chan)) {
            ast_log(LOG_ERROR, "Failed to start PBX on %s\n", chan->name);
         } else {
            /* PBX will have taken care of this */
            chan = NULL;
         }
      }
         
   }
   free(as);
   if (chan)
      ast_hangup(chan);
   return NULL;
}

static char* complete_show_application	(	char *	line,
		char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 3041 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_ERROR, ast_app::name, ast_app::next, and strdup.

{
   struct ast_app *a;
   int which = 0;

   /* try to lock applications list ... */
   if (ast_mutex_lock(&applock)) {
      ast_log(LOG_ERROR, "Unable to lock application list\n");
      return NULL;
   }

   /* ... walk all applications ... */
   a = apps; 
   while (a) {
      /* ... check if word matches this application ... */
      if (!strncasecmp(word, a->name, strlen(word))) {
         /* ... if this is right app serve it ... */
         if (++which > state) {
            char *ret = strdup(a->name);
            ast_mutex_unlock(&applock);
            return ret;
         }
      }
      a = a->next; 
   }

   /* no application match */
   ast_mutex_unlock(&applock);
   return NULL; 
}

static char* complete_show_applications	(	char *	line,
		char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 3288 of file pbx.c.

References ast_strlen_zero(), and strdup.

{
   if (pos == 2) {
      if (ast_strlen_zero(word)) {
         switch (state) {
         case 0:
            return strdup("like");
         case 1:
            return strdup("describing");
         default:
            return NULL;
         }
      } else if (! strncasecmp(word, "like", strlen(word))) {
         if (state == 0) {
            return strdup("like");
         } else {
            return NULL;
         }
      } else if (! strncasecmp(word, "describing", strlen(word))) {
         if (state == 0) {
            return strdup("describing");
         } else {
            return NULL;
         }
      }
   }
   return NULL;
}

static char* complete_show_dialplan_context	(	char *	line,
		char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 3320 of file pbx.c.

References ast_get_context_name(), ast_lock_contexts(), ast_log(), ast_unlock_contexts(), ast_walk_contexts(), LOG_ERROR, and strdup.

{
   struct ast_context *c;
   int which = 0;

   /* we are do completion of [exten@]context on second position only */
   if (pos != 2) return NULL;

   /* try to lock contexts list ... */
   if (ast_lock_contexts()) {
      ast_log(LOG_ERROR, "Unable to lock context list\n");
      return NULL;
   }

   /* ... walk through all contexts ... */
   c = ast_walk_contexts(NULL);
   while(c) {
      /* ... word matches context name? yes? ... */
      if (!strncasecmp(word, ast_get_context_name(c), strlen(word))) {
         /* ... for serve? ... */
         if (++which > state) {
            /* ... yes, serve this context name ... */
            char *ret = strdup(ast_get_context_name(c));
            ast_unlock_contexts();
            return ret;
         }
      }
      c = ast_walk_contexts(c);
   }

   /* ... unlock and return */
   ast_unlock_contexts();
   return NULL;
}

static char* complete_show_function	(	char *	line,
		char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 1260 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_ERROR, ast_custom_function::name, ast_custom_function::next, and strdup.

{
   struct ast_custom_function *acf;
   int which = 0;

   /* try to lock functions list ... */
   if (ast_mutex_lock(&acflock)) {
      ast_log(LOG_ERROR, "Unable to lock function list\n");
      return NULL;
   }

   acf = acf_root;
   while (acf) {
      if (!strncasecmp(word, acf->name, strlen(word))) {
         if (++which > state) {
            char *ret = strdup(acf->name);
            ast_mutex_unlock(&acflock);
            return ret;
         }
      }
      acf = acf->next; 
   }

   ast_mutex_unlock(&acflock);
   return NULL; 
}

static void decrease_call_count

(

void

)

[static]

Definition at line 2517 of file pbx.c.

References ast_mutex_lock(), and ast_mutex_unlock().

Referenced by ast_pbx_run(), and pbx_thread().

{
   ast_mutex_lock(&maxcalllock);
   if (countcalls > 0)
      countcalls--;
   ast_mutex_unlock(&maxcalllock);
}

static void destroy_exten

(

struct ast_exten *

e

)

[static]

Definition at line 5331 of file pbx.c.

References ast_remove_hint(), ast_exten::data, ast_exten::datad, free, ast_exten::priority, and PRIORITY_HINT.

Referenced by __ast_context_destroy().

{
   if (e->priority == PRIORITY_HINT)
      ast_remove_hint(e);

   if (e->datad)
      e->datad(e->data);
   free(e);
}

static int ext_strncpy	(	char *	dst,
		const char *	src,
		int	len
	)			[static]

Definition at line 4634 of file pbx.c.

Referenced by ast_add_extension2().

{
   int count=0;

   while(*src && (count < len - 1)) {
      switch(*src) {
      case ' ':
         /* otherwise exten => [a-b],1,... doesn't work */
         /*    case '-': */
         /* Ignore */
         break;
      default:
         *dst = *src;
         dst++;
      }
      src++;
      count++;
   }
   *dst = '\0';

   return count;
}

static unsigned int get_day

(

char *

day

)

[static]

Definition at line 4000 of file pbx.c.

References ast_log(), ast_strlen_zero(), LOG_WARNING, and s.

Referenced by ast_build_timing().

{
   char *c;
   /* The following line is coincidence, really! */
   int s, e, x;
   unsigned int mask;

   /* Check for all days */
   if (ast_strlen_zero(day) || !strcmp(day, "*")) {
      mask = (1 << 30)  + ((1 << 30) - 1);
      return mask;
   }
   /* Get start and ending days */
   c = strchr(day, '-');
   if (c) {
      *c = '\0';
      c++;
   }
   /* Find the start */
   if (sscanf(day, "%2d", &s) != 1) {
      ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", day);
      return 0;
   }
   if ((s < 1) || (s > 31)) {
      ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", day);
      return 0;
   }
   s--;
   if (c) {
      if (sscanf(c, "%2d", &e) != 1) {
         ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", c);
         return 0;
      }
      if ((e < 1) || (e > 31)) {
         ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", c);
         return 0;
      }
      e--;
   } else
      e = s;
   mask = 0;
   for (x=s; x!=e; x = (x + 1) % 31) {
      mask |= (1 << x);
   }
   mask |= (1 << x);
   return mask;
}

static unsigned int get_dow

(

char *

dow

)

[static]

get_dow: Get day of week

Definition at line 3958 of file pbx.c.

References ast_log(), ast_strlen_zero(), days, LOG_WARNING, and s.

Referenced by ast_build_timing().

{
   char *c;
   /* The following line is coincidence, really! */
   int s, e, x;
   unsigned int mask;

   /* Check for all days */
   if (ast_strlen_zero(dow) || !strcmp(dow, "*"))
      return (1 << 7) - 1;
   /* Get start and ending days */
   c = strchr(dow, '-');
   if (c) {
      *c = '\0';
      c++;
   } else
      c = NULL;
   /* Find the start */
   s = 0;
   while((s < 7) && strcasecmp(dow, days[s])) s++;
   if (s >= 7) {
      ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", dow);
      return 0;
   }
   if (c) {
      e = 0;
      while((e < 7) && strcasecmp(c, days[e])) e++;
      if (e >= 7) {
         ast_log(LOG_WARNING, "Invalid day '%s', assuming none\n", c);
         return 0;
      }
   } else
      e = s;
   mask = 0;
   for (x=s; x != e; x = (x + 1) % 7) {
      mask |= (1 << x);
   }
   /* One last one */
   mask |= (1 << x);
   return mask;
}

static unsigned int get_month

(

char *

mon

)

[static]

Definition at line 4064 of file pbx.c.

References ast_log(), ast_strlen_zero(), LOG_WARNING, months, and s.

Referenced by ast_build_timing().

{
   char *c;
   /* The following line is coincidence, really! */
   int s, e, x;
   unsigned int mask;

   /* Check for all days */
   if (ast_strlen_zero(mon) || !strcmp(mon, "*")) 
      return (1 << 12) - 1;
   /* Get start and ending days */
   c = strchr(mon, '-');
   if (c) {
      *c = '\0';
      c++;
   }
   /* Find the start */
   s = 0;
   while((s < 12) && strcasecmp(mon, months[s])) s++;
   if (s >= 12) {
      ast_log(LOG_WARNING, "Invalid month '%s', assuming none\n", mon);
      return 0;
   }
   if (c) {
      e = 0;
      while((e < 12) && strcasecmp(c, months[e])) e++;
      if (e >= 12) {
         ast_log(LOG_WARNING, "Invalid month '%s', assuming none\n", c);
         return 0;
      }
   } else
      e = s;
   mask = 0;
   for (x=s; x!=e; x = (x + 1) % 12) {
      mask |= (1 << x);
   }
   /* One last one */
   mask |= (1 << x);
   return mask;
}

static void get_timerange	(	struct ast_timing *	i,
		char *	times
	)			[static]

Definition at line 3862 of file pbx.c.

References ast_log(), ast_strlen_zero(), LOG_WARNING, and ast_timing::minmask.

Referenced by ast_build_timing().

{
   char *e;
   int x;
   int s1, s2;
   int e1, e2;
   /* int cth, ctm; */

   /* start disabling all times, fill the fields with 0's, as they may contain garbage */
   memset(i->minmask, 0, sizeof(i->minmask));
   
   /* Star is all times */
   if (ast_strlen_zero(times) || !strcmp(times, "*")) {
      for (x=0; x<24; x++)
         i->minmask[x] = (1 << 30) - 1;
      return;
   }
   /* Otherwise expect a range */
   e = strchr(times, '-');
   if (!e) {
      ast_log(LOG_WARNING, "Time range is not valid. Assuming no restrictions based on time.\n");
      return;
   }
   *e = '\0';
   e++;
   while(*e && !isdigit(*e)) 
      e++;
   if (!*e) {
      ast_log(LOG_WARNING, "Invalid time range.  Assuming no restrictions based on time.\n");
      return;
   }
   if (sscanf(times, "%2d:%2d", &s1, &s2) != 2) {
      ast_log(LOG_WARNING, "%s isn't a time.  Assuming no restrictions based on time.\n", times);
      return;
   }
   if (sscanf(e, "%2d:%2d", &e1, &e2) != 2) {
      ast_log(LOG_WARNING, "%s isn't a time.  Assuming no restrictions based on time.\n", e);
      return;
   }

#if 1
   s1 = s1 * 30 + s2/2;
   if ((s1 < 0) || (s1 >= 24*30)) {
      ast_log(LOG_WARNING, "%s isn't a valid start time. Assuming no time.\n", times);
      return;
   }
   e1 = e1 * 30 + e2/2;
   if ((e1 < 0) || (e1 >= 24*30)) {
      ast_log(LOG_WARNING, "%s isn't a valid end time. Assuming no time.\n", e);
      return;
   }
   /* Go through the time and enable each appropriate bit */
   for (x=s1;x != e1;x = (x + 1) % (24 * 30)) {
      i->minmask[x/30] |= (1 << (x % 30));
   }
   /* Do the last one */
   i->minmask[x/30] |= (1 << (x % 30));
#else
   for (cth=0; cth<24; cth++) {
      /* Initialize masks to blank */
      i->minmask[cth] = 0;
      for (ctm=0; ctm<30; ctm++) {
         if (
         /* First hour with more than one hour */
               (((cth == s1) && (ctm >= s2)) &&
                ((cth < e1)))
         /* Only one hour */
         ||    (((cth == s1) && (ctm >= s2)) &&
                ((cth == e1) && (ctm <= e2)))
         /* In between first and last hours (more than 2 hours) */
         ||    ((cth > s1) &&
                (cth < e1))
         /* Last hour with more than one hour */
         ||    ((cth > s1) &&
                ((cth == e1) && (ctm <= e2)))
         )
            i->minmask[cth] |= (1 << (ctm / 2));
      }
   }
#endif
   /* All done */
   return;
}

static int handle_show_application	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 3073 of file pbx.c.

References ast_cli(), ast_log(), AST_MAX_APP, ast_mutex_lock(), ast_mutex_unlock(), COLOR_CYAN, COLOR_MAGENTA, ast_app::description, description, LOG_ERROR, ast_app::name, ast_app::next, RESULT_FAILURE, RESULT_SHOWUSAGE, RESULT_SUCCESS, ast_app::synopsis, synopsis, and term_color().

{
   struct ast_app *a;
   int app, no_registered_app = 1;

   if (argc < 3) return RESULT_SHOWUSAGE;

   /* try to lock applications list ... */
   if (ast_mutex_lock(&applock)) {
      ast_log(LOG_ERROR, "Unable to lock application list\n");
      return -1;
   }

   /* ... go through all applications ... */
   a = apps; 
   while (a) {
      /* ... compare this application name with all arguments given
       * to 'show application' command ... */
      for (app = 2; app < argc; app++) {
         if (!strcasecmp(a->name, argv[app])) {
            /* Maximum number of characters added by terminal coloring is 22 */
            char infotitle[64 + AST_MAX_APP + 22], syntitle[40], destitle[40];
            char info[64 + AST_MAX_APP], *synopsis = NULL, *description = NULL;
            int synopsis_size, description_size;

            no_registered_app = 0;

            if (a->synopsis)
               synopsis_size = strlen(a->synopsis) + 23;
            else
               synopsis_size = strlen("Not available") + 23;
            synopsis = alloca(synopsis_size);

            if (a->description)
               description_size = strlen(a->description) + 23;
            else
               description_size = strlen("Not available") + 23;
            description = alloca(description_size);

            if (synopsis && description) {
               snprintf(info, 64 + AST_MAX_APP, "\n  -= Info about application '%s' =- \n\n", a->name);
               term_color(infotitle, info, COLOR_MAGENTA, 0, 64 + AST_MAX_APP + 22);
               term_color(syntitle, "[Synopsis]\n", COLOR_MAGENTA, 0, 40);
               term_color(destitle, "[Description]\n", COLOR_MAGENTA, 0, 40);
               term_color(synopsis,
                           a->synopsis ? a->synopsis : "Not available",
                           COLOR_CYAN, 0, synopsis_size);
               term_color(description,
                           a->description ? a->description : "Not available",
                           COLOR_CYAN, 0, description_size);

               ast_cli(fd,"%s%s%s\n\n%s%s\n", infotitle, syntitle, synopsis, destitle, description);
            } else {
               /* ... one of our applications, show info ...*/
               ast_cli(fd,"\n  -= Info about application '%s' =- \n\n"
                  "[Synopsis]\n  %s\n\n"
                  "[Description]\n%s\n",
                  a->name,
                  a->synopsis ? a->synopsis : "Not available",
                  a->description ? a->description : "Not available");
            }
         }
      }
      a = a->next; 
   }

   ast_mutex_unlock(&applock);

   /* we found at least one app? no? */
   if (no_registered_app) {
      ast_cli(fd, "Your application(s) is (are) not registered\n");
      return RESULT_FAILURE;
   }

   return RESULT_SUCCESS;
}

static int handle_show_applications	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 3211 of file pbx.c.

References ast_cli(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_app::description, LOG_ERROR, ast_app::name, ast_app::next, RESULT_SUCCESS, strcasestr(), and ast_app::synopsis.

{
   struct ast_app *a;
   int like=0, describing=0;
   int total_match = 0;    /* Number of matches in like clause */
   int total_apps = 0;  /* Number of apps registered */
   
   /* try to lock applications list ... */
   if (ast_mutex_lock(&applock)) {
      ast_log(LOG_ERROR, "Unable to lock application list\n");
      return -1;
   }

   /* ... have we got at least one application (first)? no? */
   if (!apps) {
      ast_cli(fd, "There are no registered applications\n");
      ast_mutex_unlock(&applock);
      return -1;
   }

   /* show applications like <keyword> */
   if ((argc == 4) && (!strcmp(argv[2], "like"))) {
      like = 1;
   } else if ((argc > 3) && (!strcmp(argv[2], "describing"))) {
      describing = 1;
   }

   /* show applications describing <keyword1> [<keyword2>] [...] */
   if ((!like) && (!describing)) {
      ast_cli(fd, "    -= Registered Asterisk Applications =-\n");
   } else {
      ast_cli(fd, "    -= Matching Asterisk Applications =-\n");
   }

   /* ... go through all applications ... */
   for (a = apps; a; a = a->next) {
      /* ... show informations about applications ... */
      int printapp=0;
      total_apps++;
      if (like) {
         if (strcasestr(a->name, argv[3])) {
            printapp = 1;
            total_match++;
         }
      } else if (describing) {
         if (a->description) {
            /* Match all words on command line */
            int i;
            printapp = 1;
            for (i=3; i<argc; i++) {
               if (!strcasestr(a->description, argv[i])) {
                  printapp = 0;
               } else {
                  total_match++;
               }
            }
         }
      } else {
         printapp = 1;
      }

      if (printapp) {
         ast_cli(fd,"  %20s: %s\n", a->name, a->synopsis ? a->synopsis : "<Synopsis not available>");
      }
   }
   if ((!like) && (!describing)) {
      ast_cli(fd, "    -= %d Applications Registered =-\n",total_apps);
   } else {
      ast_cli(fd, "    -= %d Applications Matching =-\n",total_match);
   }
   
   /* ... unlock and return */
   ast_mutex_unlock(&applock);

   return RESULT_SUCCESS;
}

static int handle_show_dialplan	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 3551 of file pbx.c.

References ast_cli(), AST_PBX_MAX_STACK, ast_strdupa, ast_strlen_zero(), context, dialplan_counters::context_existence, exten, dialplan_counters::extension_existence, RESULT_FAILURE, RESULT_SHOWUSAGE, RESULT_SUCCESS, show_dialplan_helper(), strsep(), dialplan_counters::total_context, dialplan_counters::total_exten, and dialplan_counters::total_prio.

{
   char *exten = NULL, *context = NULL;
   /* Variables used for different counters */
   struct dialplan_counters counters;
   char *incstack[AST_PBX_MAX_STACK];
   memset(&counters, 0, sizeof(counters));

   if (argc != 2 && argc != 3) 
      return RESULT_SHOWUSAGE;

   /* we obtain [exten@]context? if yes, split them ... */
   if (argc == 3) {
      char *splitter = ast_strdupa(argv[2]);
      /* is there a '@' character? */
      if (splitter && strchr(argv[2], '@')) {
         /* yes, split into exten & context ... */
         exten   = strsep(&splitter, "@");
         context = splitter;

         /* check for length and change to NULL if ast_strlen_zero() */
         if (ast_strlen_zero(exten))
            exten = NULL;
         if (ast_strlen_zero(context))
            context = NULL;
         show_dialplan_helper(fd, context, exten, &counters, NULL, 0, incstack);
      } else {
         /* no '@' char, only context given */
         context = argv[2];
         if (ast_strlen_zero(context))
            context = NULL;
         show_dialplan_helper(fd, context, exten, &counters, NULL, 0, incstack);
      }
   } else {
      /* Show complete dial plan */
      show_dialplan_helper(fd, NULL, NULL, &counters, NULL, 0, incstack);
   }

   /* check for input failure and throw some error messages */
   if (context && !counters.context_existence) {
      ast_cli(fd, "There is no existence of '%s' context\n", context);
      return RESULT_FAILURE;
   }

   if (exten && !counters.extension_existence) {
      if (context)
         ast_cli(fd, "There is no existence of %s@%s extension\n",
            exten, context);
      else
         ast_cli(fd,
            "There is no existence of '%s' extension in all contexts\n",
            exten);
      return RESULT_FAILURE;
   }

   ast_cli(fd,"-= %d %s (%d %s) in %d %s. =-\n",
            counters.total_exten, counters.total_exten == 1 ? "extension" : "extensions",
            counters.total_prio, counters.total_prio == 1 ? "priority" : "priorities",
            counters.total_context, counters.total_context == 1 ? "context" : "contexts");

   /* everything ok */
   return RESULT_SUCCESS;
}

static int handle_show_function	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 1205 of file pbx.c.

References ast_cli(), ast_custom_function_find(), AST_MAX_APP, COLOR_CYAN, COLOR_MAGENTA, ast_custom_function::desc, description, ast_custom_function::name, RESULT_FAILURE, RESULT_SHOWUSAGE, RESULT_SUCCESS, ast_custom_function::synopsis, synopsis, ast_custom_function::syntax, and term_color().

{
   struct ast_custom_function *acf;
   /* Maximum number of characters added by terminal coloring is 22 */
   char infotitle[64 + AST_MAX_APP + 22], syntitle[40], destitle[40];
   char info[64 + AST_MAX_APP], *synopsis = NULL, *description = NULL;
   char stxtitle[40], *syntax = NULL;
   int synopsis_size, description_size, syntax_size;

   if (argc < 3) return RESULT_SHOWUSAGE;

   if (!(acf = ast_custom_function_find(argv[2]))) {
      ast_cli(fd, "No function by that name registered.\n");
      return RESULT_FAILURE;

   }

   if (acf->synopsis)
      synopsis_size = strlen(acf->synopsis) + 23;
   else
      synopsis_size = strlen("Not available") + 23;
   synopsis = alloca(synopsis_size);
   
   if (acf->desc)
      description_size = strlen(acf->desc) + 23;
   else
      description_size = strlen("Not available") + 23;
   description = alloca(description_size);

   if (acf->syntax)
      syntax_size = strlen(acf->syntax) + 23;
   else
      syntax_size = strlen("Not available") + 23;
   syntax = alloca(syntax_size);

   snprintf(info, 64 + AST_MAX_APP, "\n  -= Info about function '%s' =- \n\n", acf->name);
   term_color(infotitle, info, COLOR_MAGENTA, 0, 64 + AST_MAX_APP + 22);
   term_color(stxtitle, "[Syntax]\n", COLOR_MAGENTA, 0, 40);
   term_color(syntitle, "[Synopsis]\n", COLOR_MAGENTA, 0, 40);
   term_color(destitle, "[Description]\n", COLOR_MAGENTA, 0, 40);
   term_color(syntax,
         acf->syntax ? acf->syntax : "Not available",
         COLOR_CYAN, 0, syntax_size);
   term_color(synopsis,
         acf->synopsis ? acf->synopsis : "Not available",
         COLOR_CYAN, 0, synopsis_size);
   term_color(description,
         acf->desc ? acf->desc : "Not available",
         COLOR_CYAN, 0, description_size);
   
   ast_cli(fd,"%s%s%s\n\n%s%s\n\n%s%s\n", infotitle, stxtitle, syntax, syntitle, synopsis, destitle, description);

   return RESULT_SUCCESS;
}

static int handle_show_functions	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 1189 of file pbx.c.

References ast_cli(), ast_mutex_lock(), ast_mutex_unlock(), ast_custom_function::name, ast_custom_function::next, ast_custom_function::synopsis, and ast_custom_function::syntax.

{
   struct ast_custom_function *acf;
   int count_acf = 0;

   ast_cli(fd, "Installed Custom Functions:\n--------------------------------------------------------------------------------\n");
   ast_mutex_lock(&acflock);
   for (acf = acf_root ; acf; acf = acf->next) {
      ast_cli(fd, "%-20.20s  %-35.35s  %s\n", acf->name, acf->syntax, acf->synopsis);
      count_acf++;
   }
   ast_mutex_unlock(&acflock);
   ast_cli(fd, "%d custom functions installed.\n", count_acf);
   return 0;
}

static int handle_show_hints	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

handle_show_hints: CLI support for listing registred dial plan hints

Definition at line 3151 of file pbx.c.

References ast_cli(), ast_extension_state2str(), ast_get_extension_app(), ast_get_extension_name(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_hint::callbacks, ast_hint::exten, ast_hint::laststate, LOG_ERROR, ast_hint::next, ast_state_cb::next, and RESULT_SUCCESS.

{
   struct ast_hint *hint;
   int num = 0;
   int watchers;
   struct ast_state_cb *watcher;

   if (!hints) {
      ast_cli(fd, "There are no registered dialplan hints\n");
      return RESULT_SUCCESS;
   }
   /* ... we have hints ... */
   ast_cli(fd, "\n    -= Registered Asterisk Dial Plan Hints =-\n");
   if (ast_mutex_lock(&hintlock)) {
      ast_log(LOG_ERROR, "Unable to lock hints\n");
      return -1;
   }
   hint = hints;
   while (hint) {
      watchers = 0;
      for (watcher = hint->callbacks; watcher; watcher = watcher->next)
         watchers++;
      ast_cli(fd, "   %-20.20s: %-20.20s  State:%-15.15s Watchers %2d\n",
         ast_get_extension_name(hint->exten), ast_get_extension_app(hint->exten),
         ast_extension_state2str(hint->laststate), watchers);
      num++;
      hint = hint->next;
   }
   ast_cli(fd, "----------------\n");
   ast_cli(fd, "- %d hints registered\n", num);
   ast_mutex_unlock(&hintlock);
   return RESULT_SUCCESS;
}

static int handle_show_switches	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

handle_show_switches: CLI support for listing registred dial plan switches

Definition at line 3186 of file pbx.c.

References ast_cli(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_switch::description, LOG_ERROR, ast_switch::name, ast_switch::next, and RESULT_SUCCESS.

{
   struct ast_switch *sw;
   if (!switches) {
      ast_cli(fd, "There are no registered alternative switches\n");
      return RESULT_SUCCESS;
   }
   /* ... we have applications ... */
   ast_cli(fd, "\n    -= Registered Asterisk Alternative Switches =-\n");
   if (ast_mutex_lock(&switchlock)) {
      ast_log(LOG_ERROR, "Unable to lock switches\n");
      return -1;
   }
   sw = switches;
   while (sw) {
      ast_cli(fd, "%s: %s\n", sw->name, sw->description);
      sw = sw->next;
   }
   ast_mutex_unlock(&switchlock);
   return RESULT_SUCCESS;
}

static int include_valid

(

struct ast_include *

i

)

[inline, static]

Definition at line 633 of file pbx.c.

References ast_check_timing(), ast_include::hastime, and ast_include::timing.

Referenced by pbx_find_extension().

{
   if (!i->hastime)
      return 1;

   return ast_check_timing(&(i->timing));
}

static int increase_call_count

(

const struct ast_channel *

c

)

[static]

Definition at line 2492 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), getloadavg(), LOG_NOTICE, ast_channel::name, option_maxcalls, and option_maxload.

Referenced by ast_pbx_run(), and ast_pbx_start().

{
   int failed = 0;
   double curloadavg;
   ast_mutex_lock(&maxcalllock);
   if (option_maxcalls) {
      if (countcalls >= option_maxcalls) {
         ast_log(LOG_NOTICE, "Maximum call limit of %d calls exceeded by '%s'!\n", option_maxcalls, c->name);
         failed = -1;
      }
   }
   if (option_maxload) {
      getloadavg(&curloadavg, 1);
      if (curloadavg >= option_maxload) {
         ast_log(LOG_NOTICE, "Maximum loadavg limit of %lf load exceeded by '%s' (currently %f)!\n", option_maxload, c->name, curloadavg);
         failed = -1;
      }
   }
   if (!failed)
      countcalls++;  
   ast_mutex_unlock(&maxcalllock);

   return failed;
}

int load_pbx

(

void

)

Definition at line 6266 of file pbx.c.

References ast_cli_register_multiple(), AST_LIST_HEAD_INIT_NOLOCK, ast_log(), ast_register_application(), ast_verbose(), builtins, description, globals, LOG_ERROR, name, option_verbose, synopsis, 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_NOLOCK(&globals);
   ast_cli_register_multiple(pbx_cli, sizeof(pbx_cli) / sizeof(pbx_cli[0]));

   /* 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;
}

static int matchcid	(	const char *	cidpattern,
		const char *	callerid
	)			[static]

Definition at line 780 of file pbx.c.

References ast_extension_match(), and ast_strlen_zero().

Referenced by pbx_find_extension().

{
   int failresult;
   
   /* If the Caller*ID pattern is empty, then we're matching NO Caller*ID, so
      failing to get a number should count as a match, otherwise not */

   if (!ast_strlen_zero(cidpattern))
      failresult = 0;
   else
      failresult = 1;

   if (!callerid)
      return failresult;

   return ast_extension_match(cidpattern, callerid);
}

static void null_datad

(

void *

foo

)

[static]

Definition at line 4657 of file pbx.c.

Referenced by ast_add_extension2().

{
}

static int parse_variable_name	(	char *	var,
		int *	offset,
		int *	length,
		int *	isfunc
	)			[static]

Definition at line 926 of file pbx.c.

References DONT_HAVE_LENGTH.

Referenced by pbx_retrieve_variable(), and pbx_substitute_variables_helper_full().

{
   char *varchar, *offsetchar = NULL;
   int parens=0;

   *offset = 0;
   *length = DONT_HAVE_LENGTH;
   *isfunc = 0;
   for (varchar=var; *varchar; varchar++) {
      switch (*varchar) {
      case '(':
         (*isfunc)++;
         parens++;
         break;
      case ')':
         parens--;
         break;
      case ':':
         if (parens == 0) {
            offsetchar = varchar + 1;
            *varchar = '\0';
            goto pvn_endfor;
         }
      }
   }
pvn_endfor:
   if (offsetchar) {
      sscanf(offsetchar, "%30d:%30d", offset, length);
      return 1;
   } else {
      return 0;
   }
}

void pbx_builtin_clear_globals

(

void

)

Definition at line 6155 of file pbx.c.

References AST_LIST_REMOVE_HEAD, ast_mutex_lock(), ast_mutex_unlock(), ast_var_delete(), and globals.

Referenced by handle_reload_extensions(), and reload().

{
   struct ast_var_t *vardata;

   ast_mutex_lock(&globalslock);
   while ((vardata = AST_LIST_REMOVE_HEAD(&globals, entries)))
      ast_var_delete(vardata);
   ast_mutex_unlock(&globalslock);
}

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

Definition at line 5950 of file pbx.c.

References AST_LIST_TRAVERSE, ast_mutex_lock(), ast_mutex_unlock(), ast_var_name(), ast_var_value(), globals, and ast_channel::varshead.

Referenced by __ast_pbx_run(), __login_exec(), _while_exec(), action_getvar(), agentmonitoroutgoing_exec(), ast_bridge_call(), ast_channel_bridge(), ast_feature_interpret(), ast_monitor_stop(), ast_osp_lookup(), builtin_atxfer(), builtin_automonitor(), builtin_blindtransfer(), chanspy_exec(), check_goto_on_transfer(), conf_exec(), conf_run(), dial_exec_full(), do_chanreads(), dundi_exec(), dundi_helper(), get_index(), get_refer_info(), group_check_exec(), group_count_exec(), iax2_exec(), import_ch(), leave_voicemail(), macro_exec(), misdn_answer(), misdn_hangup(), oh323_hangup(), ospfinished_exec(), ospnext_exec(), queue_exec(), retrydial_exec(), return_exec(), set_config_flags(), sip_addheader(), try_calling(), try_suggested_sip_codec(), wait_for_answer(), zt_call(), and zt_hangup().

{
        struct ast_var_t *variables;
        char *ret = NULL;
        int i;
        struct varshead *places[2] = { NULL, &globals };
        
        if (!name)
                return NULL;
        if (chan)
                places[0] = &chan->varshead;

        for (i = 0; i < 2; i++) {
                if (!places[i])
                        continue;
                if (places[i] == &globals)
                        ast_mutex_lock(&globalslock);
                AST_LIST_TRAVERSE(places[i], variables, entries) {
                        if (!strcmp(name, ast_var_name(variables))) {
                                ret = ast_var_value(variables);
                                break;
                        }
                }
                if (places[i] == &globals)
                        ast_mutex_unlock(&globalslock);
                if (ret)
                        break;
        }

        return ret;                
}

static int pbx_builtin_gotoif	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6184 of file pbx.c.

References ast_log(), ast_strdupa, ast_strlen_zero(), LOG_DEBUG, LOG_WARNING, pbx_builtin_goto(), pbx_checkcondition(), s, and strsep().

{
   char *condition, *branch1, *branch2, *branch;
   char *s;
   int rc;
   char *stringp=NULL;

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "Ignoring, since there is no variable to check\n");
      return 0;
   }
   
   s = ast_strdupa(data);
   stringp = s;
   condition = strsep(&stringp,"?");
   branch1 = strsep(&stringp,":");
   branch2 = strsep(&stringp,"");
   branch = pbx_checkcondition(condition) ? branch1 : branch2;
   
   if (ast_strlen_zero(branch)) {
      ast_log(LOG_DEBUG, "Not taking any branch\n");
      return 0;
   }
   
   rc = pbx_builtin_goto(chan, branch);

   return rc;
}           

int pbx_builtin_importvar	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6094 of file pbx.c.

References ast_get_channel_by_name_locked(), ast_log(), ast_mutex_unlock(), ast_strdupa, ast_strlen_zero(), ast_channel::lock, LOG_WARNING, name, pbx_builtin_setvar_helper(), pbx_substitute_variables_helper(), s, strsep(), and VAR_BUF_SIZE.

{
   char *name;
   char *value;
   char *stringp=NULL;
   char *channel;
   struct ast_channel *chan2;
   char tmp[VAR_BUF_SIZE]="";
   char *s;

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "Ignoring, since there is no variable to set\n");
      return 0;
   }

   stringp = ast_strdupa(data);
   name = strsep(&stringp,"=");
   channel = strsep(&stringp,"|"); 
   value = strsep(&stringp,"\0");
   if (channel && value && name) {
      chan2 = ast_get_channel_by_name_locked(channel);
      if (chan2) {
         s = alloca(strlen(value) + 4);
         if (s) {
            sprintf(s, "${%s}", value);
            pbx_substitute_variables_helper(chan2, s, tmp, sizeof(tmp) - 1);
         }
         ast_mutex_unlock(&chan2->lock);
      }
      pbx_builtin_setvar_helper(chan, name, tmp);
   }

   return(0);
}

static int pbx_builtin_noop	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6149 of file pbx.c.

{
   return 0;
}

void pbx_builtin_pushvar_helper	(	struct ast_channel *	chan,
		const char *	name,
		const char *	value
	)

Definition at line 5982 of file pbx.c.

References ast_func_write(), AST_LIST_INSERT_HEAD, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_var_assign(), ast_verbose(), globals, LOG_WARNING, option_verbose, ast_channel::varshead, and VERBOSE_PREFIX_2.

Referenced by gosub_exec().

{
   struct ast_var_t *newvariable;
   struct varshead *headp;

   if (name[strlen(name)-1] == ')') {
      ast_log(LOG_WARNING, "Cannot push a value onto a function\n");
      return ast_func_write(chan, name, value);
   }

   headp = (chan) ? &chan->varshead : &globals;

   if (value) {
      if ((option_verbose > 1) && (headp == &globals))
         ast_verbose(VERBOSE_PREFIX_2 "Setting global variable '%s' to '%s'\n", name, value);
      newvariable = ast_var_assign(name, value);
      if (headp == &globals)
         ast_mutex_lock(&globalslock);
      AST_LIST_INSERT_HEAD(headp, newvariable, entries);
      if (headp == &globals)
         ast_mutex_unlock(&globalslock);
   }
}

static int pbx_builtin_saycharacters	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6248 of file pbx.c.

References ast_say_character_str(), and ast_channel::language.

{
   int res = 0;

   if (data)
      res = ast_say_character_str(chan, (char *)data, "", chan->language);
   return res;
}

static int pbx_builtin_saydigits	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6239 of file pbx.c.

References ast_say_digit_str(), and ast_channel::language.

{
   int res = 0;

   if (data)
      res = ast_say_digit_str(chan, (char *)data, "", chan->language);
   return res;
}

static int pbx_builtin_saynumber	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6213 of file pbx.c.

References ast_log(), ast_say_number(), ast_strlen_zero(), ast_channel::language, LOG_WARNING, and strsep().

{
   int res = 0;
   char tmp[256];
   char *number = (char *) NULL;
   char *options = (char *) NULL;

   
   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "SayNumber requires an argument (number)\n");
      return -1;
   }
   ast_copy_string(tmp, (char *) data, sizeof(tmp));
   number=tmp;
   strsep(&number, "|");
   options = strsep(&number, "|");
   if (options) { 
      if ( strcasecmp(options, "f") && strcasecmp(options,"m") && 
         strcasecmp(options, "c") && strcasecmp(options, "n") ) {
         ast_log(LOG_WARNING, "SayNumber gender option is either 'f', 'm', 'c' or 'n'\n");
         return -1;
      }
   }
   return res = ast_say_number(chan, atoi((char *) tmp), "", chan->language, options);
}

static int pbx_builtin_sayphonetic	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6257 of file pbx.c.

References ast_say_phonetic_str(), and ast_channel::language.

{
   int res = 0;

   if (data)
      res = ast_say_phonetic_str(chan, (char *)data, "", chan->language);
   return res;
}

int pbx_builtin_serialize_variables	(	struct ast_channel *	chan,
		char *	buf,
		size_t	size
	)

Definition at line 5925 of file pbx.c.

References ast_build_string(), AST_LIST_TRAVERSE, ast_log(), ast_var_name(), ast_var_value(), LOG_ERROR, total, var, and ast_channel::varshead.

Referenced by dumpchan_exec(), and handle_showchan().

{
   struct ast_var_t *variables;
   char *var, *val;
   int total = 0;

   if (!chan)
      return 0;

   memset(buf, 0, size);

   AST_LIST_TRAVERSE(&chan->varshead, variables, entries) {
      if ((var = ast_var_name(variables)) && (val = ast_var_value(variables))) {
         if (ast_build_string(&buf, &size, "%s=%s\n", var, val)) {
            ast_log(LOG_ERROR, "Data Buffer Size Exceeded!\n");
            break;
         } else
            total++;
      } else 
         break;
   }
   
   return total;
}

static int pbx_builtin_setglobalvar	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6129 of file pbx.c.

References ast_log(), ast_strlen_zero(), LOG_WARNING, name, pbx_builtin_setvar_helper(), and strsep().

{
   char *name;
   char *value;
   char *stringp = NULL;

   if (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(NULL, name, value);

   return(0);
}

int pbx_builtin_setvar	(	struct ast_channel *	chan,
		void *	data
	)

Definition at line 6058 of file pbx.c.

References ast_app_separate_args(), ast_log(), ast_strdupa, ast_strlen_zero(), LOG_WARNING, name, and pbx_builtin_setvar_helper().

Referenced by handle_globals(), and pbx_builtin_setvar_old().

{
   char *name, *value, *mydata;
   int argc;
   char *argv[24];      /* this will only support a maximum of 24 variables being set in a single operation */
   int global = 0;
   int x;

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "Set requires at least one variable name/value pair.\n");
      return 0;
   }

   mydata = ast_strdupa(data);
   argc = ast_app_separate_args(mydata, '|', argv, sizeof(argv) / sizeof(argv[0]));

   /* check for a trailing flags argument */
   if ((argc > 1) && !strchr(argv[argc-1], '=')) {
      argc--;
      if (strchr(argv[argc], 'g'))
         global = 1;
   }

   for (x = 0; x < argc; x++) {
      name = argv[x];
      if ((value = strchr(name, '='))) {
         *value = '\0';
         value++;
         pbx_builtin_setvar_helper((global) ? NULL : chan, name, value);
      } else
         ast_log(LOG_WARNING, "Ignoring entry '%s' with no = (and not last 'options' entry)\n", name);
   }

   return(0);
}

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

Definition at line 6006 of file pbx.c.

References ast_func_write(), AST_LIST_INSERT_HEAD, AST_LIST_REMOVE, AST_LIST_TRAVERSE, ast_mutex_lock(), ast_mutex_unlock(), ast_var_assign(), ast_var_delete(), ast_var_name(), ast_verbose(), globals, option_verbose, ast_channel::varshead, and VERBOSE_PREFIX_2.

Referenced by __ast_pbx_run(), __login_exec(), _while_exec(), action_setvar(), aPGSQL_connect(), aPGSQL_fetch(), aPGSQL_query(), aqm_exec(), ast_bridge_call(), ast_channel_bridge(), ast_iax2_new(), ast_monitor_start(), ast_set_variables(), background_detect_exec(), builtin_blindtransfer(), builtin_function_set(), cb_events(), chanavail_exec(), conf_run(), controlplayback_exec(), count_exec(), curl_exec(), cut_exec(), dial_exec_full(), disa_exec(), do_waiting(), dundi_lookup_exec(), enumlookup_exec(), eval_exec(), export_ch(), function_db_exists(), function_db_read(), get_exec(), get_refer_info(), group_check_exec(), group_count_exec(), group_match_count_exec(), handle_setvariable(), hasvoicemail_exec(), i4l_read(), leave_voicemail(), lookupblacklist_exec(), macro_exec(), math_exec(), md5_exec(), md5check_exec(), misdn_call(), mixmonitor_exec(), monitor_handle_owned(), ospfinished_exec(), osplookup_exec(), ospnext_exec(), pbx_builtin_importvar(), pbx_builtin_setglobalvar(), pbx_builtin_setvar(), pbx_extension_helper(), pbx_load_module(), play_message_datetime(), playback_exec(), pop_exec(), pqm_exec(), prep_email_sub_vars(), privacy_exec(), process_ast_dsp(), read_exec(), readfile_exec(), realtime_exec(), record_exec(), return_exec(), rqm_exec(), sendimage_exec(), sendtext_exec(), sendurl_exec(), set_agentbycallerid(), set_queue_result(), sip_addheader(), sip_getheader(), sip_new(), sort_exec(), start_monitor_exec(), system_exec_helper(), transfer_exec(), txtcidname_exec(), upqm_exec(), vm_box_exists(), vm_exec(), vmauthenticate(), zt_handle_dtmfup(), and zt_new().

{
   struct ast_var_t *newvariable;
   struct varshead *headp;
   const char *nametail = name;

   if (name[strlen(name)-1] == ')')
      return ast_func_write(chan, name, value);

   headp = (chan) ? &chan->varshead : &globals;

   /* For comparison purposes, we have to strip leading underscores */
   if (*nametail == '_') {
      nametail++;
      if (*nametail == '_') 
         nametail++;
   }

   if (headp == &globals)
      ast_mutex_lock(&globalslock);
   AST_LIST_TRAVERSE (headp, newvariable, entries) {
      if (strcasecmp(ast_var_name(newvariable), nametail) == 0) {
         /* there is already such a variable, delete it */
         AST_LIST_REMOVE(headp, newvariable, entries);
         ast_var_delete(newvariable);
         break;
      }
   }
   
   if (value) {
      if ((option_verbose > 1) && (headp == &globals))
         ast_verbose(VERBOSE_PREFIX_2 "Setting global variable '%s' to '%s'\n", name, value);
      newvariable = ast_var_assign(name, value);   
      AST_LIST_INSERT_HEAD(headp, newvariable, entries);
   }
   
   if (headp == &globals)
      ast_mutex_unlock(&globalslock);
}

int pbx_builtin_setvar_old	(	struct ast_channel *	chan,
		void *	data
	)			[static]

Definition at line 6046 of file pbx.c.

References ast_log(), LOG_WARNING, and pbx_builtin_setvar().

{
   static int deprecation_warning = 0;

   if (!deprecation_warning) {
      ast_log(LOG_WARNING, "SetVar is deprecated, please use Set instead.\n");
      deprecation_warning = 1;
   }

   return pbx_builtin_setvar(chan, data);
}

int pbx_checkcondition

(

char *

condition

)

Definition at line 6165 of file pbx.c.

Referenced by _while_exec(), builtin_function_if(), execif_exec(), gosubif_exec(), macro_exec(), macroif_exec(), and pbx_builtin_gotoif().

{
   if (condition) {
      if (*condition == '\0') {
         /* Empty strings are false */
         return 0;
      } else if (*condition >= '0' && *condition <= '9') {
         /* Numbers are evaluated for truth */
         return atoi(condition);
      } else {
         /* Strings are true */
         return 1;
      }
   } else {
      /* NULL is also false */
      return 0;
   }
}

static void pbx_destroy

(

struct ast_pbx *

p

)

[static]

Definition at line 641 of file pbx.c.

References free.

Referenced by __ast_pbx_run().

{
   free(p);
}

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

Parameters:

c	Channel
app	Application
data	Data for execution
newstack	Force stack increment

Definition at line 552 of file pbx.c.

References ast_channel::appl, ast_cdr_setapp(), ast_check_hangup(), ast_log(), ast_channel::cdr, ast_channel::data, ast_app::execute, LOG_WARNING, and ast_app::name.

Referenced by ast_bridge_call(), ast_pbx_run_app(), async_wait(), builtin_automonitor(), conf_run(), dial_exec_full(), dundi_exec(), exec_exec(), execif_exec(), feature_exec_app(), forward_message(), handle_exec(), iax2_exec(), page_exec(), pbx_builtin_execiftime(), pbx_extension_helper(), and realtime_exec().

{
   int res;
   
   char *saved_c_appl;
   char *saved_c_data;
   
   int (*execute)(struct ast_channel *chan, void *data) = app->execute; 

   if (newstack) {
      if (c->cdr && !ast_check_hangup(c))
         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;
      return res;
   } else
      ast_log(LOG_WARNING, "You really didn't want to call this function with newstack set to 0\n");
   return -1;
}

static int pbx_extension_helper	(	struct ast_channel *	c,
		struct ast_context *	con,
		const char *	context,
		const char *	exten,
		int	priority,
		const char *	label,
		const char *	callerid,
		int	action
	)			[static]

Definition at line 1641 of file pbx.c.

References ast_exten::app, app, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), AST_PBX_MAX_STACK, ast_strlen_zero(), ast_verbose(), COLOR_BRCYAN, COLOR_BRMAGENTA, ast_channel::context, EVENT_FLAG_CALL, ast_switch::exec, EXT_DATA_SIZE, ast_channel::exten, HELPER_CANMATCH, HELPER_EXEC, HELPER_EXISTS, HELPER_FINDLABEL, HELPER_MATCHMORE, HELPER_SPAWN, LOG_DEBUG, LOG_NOTICE, LOG_WARNING, manager_event(), ast_switch::name, ast_channel::name, ast_app::name, option_debug, option_verbose, pbx_builtin_setvar_helper(), pbx_exec(), pbx_find_extension(), pbx_findapp(), pbx_substitute_variables(), ast_channel::priority, ast_exten::priority, STATUS_NO_CONTEXT, STATUS_NO_EXTENSION, STATUS_NO_LABEL, STATUS_NO_PRIORITY, term_color(), ast_channel::uniqueid, and VERBOSE_PREFIX_3.

Referenced by ast_canmatch_extension(), ast_exec_extension(), ast_exists_extension(), ast_findlabel_extension(), ast_findlabel_extension2(), ast_matchmore_extension(), and ast_spawn_extension().

{
   struct ast_exten *e;
   struct ast_app *app;
   struct ast_switch *sw;
   char *data;
   const char *foundcontext=NULL;
   int newstack = 0;
   int res;
   int status = 0;
   char *incstack[AST_PBX_MAX_STACK];
   char passdata[EXT_DATA_SIZE];
   int stacklen = 0;
   char tmp[80];
   char tmp2[80];
   char tmp3[EXT_DATA_SIZE];
   char atmp[80];
   char atmp2[EXT_DATA_SIZE+100];

   if (ast_mutex_lock(&conlock)) {
      ast_log(LOG_WARNING, "Unable to obtain lock\n");
      if ((action == HELPER_EXISTS) || (action == HELPER_CANMATCH) || (action == HELPER_MATCHMORE))
         return 0;
      else
         return -1;
   }
   e = pbx_find_extension(c, con, context, exten, priority, label, callerid, action, incstack, &stacklen, &status, &sw, &data, &foundcontext);
   if (e) {
      switch(action) {
      case HELPER_CANMATCH:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_EXISTS:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_FINDLABEL:
         res = e->priority;
         ast_mutex_unlock(&conlock);
         return res;
      case HELPER_MATCHMORE:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_SPAWN:
         newstack++;
         /* Fall through */
      case HELPER_EXEC:
         app = pbx_findapp(e->app);
         ast_mutex_unlock(&conlock);
         if (app) {
            if (c->context != context)
               ast_copy_string(c->context, context, sizeof(c->context));
            if (c->exten != exten)
               ast_copy_string(c->exten, exten, sizeof(c->exten));
            c->priority = priority;
            pbx_substitute_variables(passdata, sizeof(passdata), c, e);
            if (option_debug) {
                  ast_log(LOG_DEBUG, "Launching '%s'\n", app->name);
                  snprintf(atmp, 80, "STACK-%s-%s-%d", context, exten, priority);
                  snprintf(atmp2, EXT_DATA_SIZE+100, "%s(\"%s\", \"%s\") %s", app->name, c->name, (!ast_strlen_zero(passdata) ? (char *)passdata : ""), (newstack ? "in new stack" : "in same stack"));
                  pbx_builtin_setvar_helper(c, atmp, atmp2);
            }
            if (option_verbose > 2)
                  ast_verbose( VERBOSE_PREFIX_3 "Executing %s(\"%s\", \"%s\") %s\n", 
                        term_color(tmp, app->name, COLOR_BRCYAN, 0, sizeof(tmp)),
                        term_color(tmp2, c->name, COLOR_BRMAGENTA, 0, sizeof(tmp2)),
                        term_color(tmp3, (!ast_strlen_zero(passdata) ? (char *)passdata : ""), COLOR_BRMAGENTA, 0, sizeof(tmp3)),
                        (newstack ? "in new stack" : "in same stack"));
            manager_event(EVENT_FLAG_CALL, "Newexten", 
               "Channel: %s\r\n"
               "Context: %s\r\n"
               "Extension: %s\r\n"
               "Priority: %d\r\n"
               "Application: %s\r\n"
               "AppData: %s\r\n"
               "Uniqueid: %s\r\n",
               c->name, c->context, c->exten, c->priority, app->name, passdata ? passdata : "(NULL)", c->uniqueid);
            res = pbx_exec(c, app, passdata, newstack);
            return res;
         } else {
            ast_log(LOG_WARNING, "No application '%s' for extension (%s, %s, %d)\n", e->app, context, exten, priority);
            return -1;
         }
      default:
         ast_log(LOG_WARNING, "Huh (%d)?\n", action);       return -1;
      }
   } else if (sw) {
      switch(action) {
      case HELPER_CANMATCH:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_EXISTS:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_MATCHMORE:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_FINDLABEL:
         ast_mutex_unlock(&conlock);
         return -1;
      case HELPER_SPAWN:
         newstack++;
         /* Fall through */
      case HELPER_EXEC:
         ast_mutex_unlock(&conlock);
         if (sw->exec)
            res = sw->exec(c, foundcontext ? foundcontext : context, exten, priority, callerid, newstack, data);
         else {
            ast_log(LOG_WARNING, "No execution engine for switch %s\n", sw->name);
            res = -1;
         }
         return res;
      default:
         ast_log(LOG_WARNING, "Huh (%d)?\n", action);
         return -1;
      }
   } else {
      ast_mutex_unlock(&conlock);
      switch(status) {
      case STATUS_NO_CONTEXT:
         if ((action != HELPER_EXISTS) && (action != HELPER_MATCHMORE))
            ast_log(LOG_NOTICE, "Cannot find extension context '%s'\n", context);
         break;
      case STATUS_NO_EXTENSION:
         if ((action != HELPER_EXISTS) && (action !=  HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
            ast_log(LOG_NOTICE, "Cannot find extension '%s' in context '%s'\n", exten, context);
         break;
      case STATUS_NO_PRIORITY:
         if ((action != HELPER_EXISTS) && (action !=  HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
            ast_log(LOG_NOTICE, "No such priority %d in extension '%s' in context '%s'\n", priority, exten, context);
         break;
      case STATUS_NO_LABEL:
         if (context)
            ast_log(LOG_NOTICE, "No such label '%s' in extension '%s' in context '%s'\n", label, exten, context);
         break;
      default:
         ast_log(LOG_DEBUG, "Shouldn't happen!\n");
      }
      
      if ((action != HELPER_EXISTS) && (action != HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
         return -1;
      else
         return 0;
   }

}

static struct ast_exten* pbx_find_extension	(	struct ast_channel *	chan,
		struct ast_context *	bypass,
		const char *	context,
		const char *	exten,
		int	priority,
		const char *	label,
		const char *	callerid,
		int	action,
		char *	incstack[],
		int *	stacklen,
		int *	status,
		struct ast_switch **	swo,
		char **	data,
		const char **	foundcontext
	)			[static, read]

Definition at line 798 of file pbx.c.

References ast_context::alts, ast_extension_close(), ast_extension_match(), ast_log(), AST_PBX_MAX_STACK, ast_switch::canmatch, ast_exten::cidmatch, ast_sw::data, ast_sw::eval, ast_switch::exists, ast_exten::exten, HELPER_CANMATCH, HELPER_FINDLABEL, HELPER_MATCHMORE, include_valid(), ast_context::includes, ast_exten::label, LOG_WARNING, match(), matchcid(), ast_exten::matchcid, ast_switch::matchmore, ast_sw::name, ast_context::name, ast_context::next, ast_include::next, ast_sw::next, ast_exten::next, pbx_findswitch(), pbx_substitute_variables_helper(), ast_exten::peer, ast_exten::priority, ast_include::rname, ast_context::root, STATUS_NO_CONTEXT, STATUS_NO_EXTENSION, STATUS_NO_LABEL, STATUS_NO_PRIORITY, STATUS_SUCCESS, SWITCH_DATA_LENGTH, and ast_sw::tmpdata.

Referenced by ast_hint_extension(), and pbx_extension_helper().

{
   int x, res;
   struct ast_context *tmp;
   struct ast_exten *e, *eroot;
   struct ast_include *i;
   struct ast_sw *sw;
   struct ast_switch *asw;

   /* Initialize status if appropriate */
   if (!*stacklen) {
      *status = STATUS_NO_CONTEXT;
      *swo = NULL;
      *data = NULL;
   }
   /* Check for stack overflow */
   if (*stacklen >= AST_PBX_MAX_STACK) {
      ast_log(LOG_WARNING, "Maximum PBX stack exceeded\n");
      return NULL;
   }
   /* Check first to see if we've already been checked */
   for (x=0; x<*stacklen; x++) {
      if (!strcasecmp(incstack[x], context))
         return NULL;
   }
   if (bypass)
      tmp = bypass;
   else
      tmp = contexts;
   while(tmp) {
      /* Match context */
      if (bypass || !strcmp(tmp->name, context)) {
         struct ast_exten *earlymatch = NULL;

         if (*status < STATUS_NO_EXTENSION)
            *status = STATUS_NO_EXTENSION;
         for (eroot = tmp->root; eroot; eroot=eroot->next) {
            int match = 0;
            /* Match extension */
            if ((((action != HELPER_MATCHMORE) && ast_extension_match(eroot->exten, exten)) ||
                 ((action == HELPER_CANMATCH) && (ast_extension_close(eroot->exten, exten, 0))) ||
                 ((action == HELPER_MATCHMORE) && (match = ast_extension_close(eroot->exten, exten, 1)))) &&
                (!eroot->matchcid || matchcid(eroot->cidmatch, callerid))) {

               if (action == HELPER_MATCHMORE && match == 2 && !earlymatch) {
                  /* It matched an extension ending in a '!' wildcard
                     So ignore it for now, unless there's a better match */
                  earlymatch = eroot;
               } else {
                  e = eroot;
                  if (*status < STATUS_NO_PRIORITY)
                     *status = STATUS_NO_PRIORITY;
                  while(e) {
                     /* Match priority */
                     if (action == HELPER_FINDLABEL) {
                        if (*status < STATUS_NO_LABEL)
                           *status = STATUS_NO_LABEL;
                        if (label && e->label && !strcmp(label, e->label)) {
                           *status = STATUS_SUCCESS;
                           *foundcontext = context;
                           return e;
                        }
                     } else if (e->priority == priority) {
                        *status = STATUS_SUCCESS;
                        *foundcontext = context;
                        return e;
                     }
                     e = e->peer;
                  }
               }
            }
         }
         if (earlymatch) {
            /* Bizarre logic for HELPER_MATCHMORE. We return zero to break out 
               of the loop waiting for more digits, and _then_ match (normally)
               the extension we ended up with. We got an early-matching wildcard
               pattern, so return NULL to break out of the loop. */
            return NULL;
         }
         /* Check alternative switches */
         sw = tmp->alts;
         while(sw) {
            if ((asw = pbx_findswitch(sw->name))) {
               /* Substitute variables now */
               if (sw->eval) 
                  pbx_substitute_variables_helper(chan, sw->data, sw->tmpdata, SWITCH_DATA_LENGTH - 1);
               if (action == HELPER_CANMATCH)
                  res = asw->canmatch ? asw->canmatch(chan, context, exten, priority, callerid, sw->eval ? sw->tmpdata : sw->data) : 0;
               else if (action == HELPER_MATCHMORE)
                  res = asw->matchmore ? asw->matchmore(chan, context, exten, priority, callerid, sw->eval ? sw->tmpdata : sw->data) : 0;
               else
                  res = asw->exists ? asw->exists(chan, context, exten, priority, callerid, sw->eval ? sw->tmpdata : sw->data) : 0;
               if (res) {
                  /* Got a match */
                  *swo = asw;
                  *data = sw->eval ? sw->tmpdata : sw->data;
                  *foundcontext = context;
                  return NULL;
               }
            } else {
               ast_log(LOG_WARNING, "No such switch '%s'\n", sw->name);
            }
            sw = sw->next;
         }
         /* Setup the stack */
         incstack[*stacklen] = tmp->name;
         (*stacklen)++;
         /* Now try any includes we have in this context */
         i = tmp->includes;
         while(i) {
            if (include_valid(i)) {
               if ((e = pbx_find_extension(chan, bypass, i->rname, exten, priority, label, callerid, action, incstack, stacklen, status, swo, data, foundcontext))) 
                  return e;
               if (*swo) 
                  return NULL;
            }
            i = i->next;
         }
         break;
      }
      tmp = tmp->next;
   }
   return NULL;
}

struct ast_app* pbx_findapp

(

const char *

app

)

[read]

Find application handle in linked list.

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 597 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_bridge_call(), ast_pbx_run_app(), async_wait(), builtin_automonitor(), conf_run(), dial_exec_full(), dundi_exec(), exec_exec(), execif_exec(), feature_exec_app(), forward_message(), handle_exec(), iax2_exec(), page_exec(), pbx_builtin_execiftime(), pbx_extension_helper(), and realtime_exec().

{
   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;
}

static struct ast_switch* pbx_findswitch

(

const char *

sw

)

[static, read]

Definition at line 615 of file pbx.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), LOG_WARNING, ast_switch::name, and ast_switch::next.

Referenced by pbx_find_extension().

{
   struct ast_switch *asw;

   if (ast_mutex_lock(&switchlock)) {
      ast_log(LOG_WARNING, "Unable to obtain application lock\n");
      return NULL;
   }
   asw = switches;
   while(asw) {
      if (!strcasecmp(asw->name, sw))
         break;
      asw = asw->next;
   }
   ast_mutex_unlock(&switchlock);
   return asw;
}

void pbx_retrieve_variable	(	struct ast_channel *	c,
		const char *	var,
		char **	ret,
		char *	workspace,
		int	workspacelen,
		struct varshead *	headp
	)

pbx_retrieve_variable: Support for Asterisk built-in variables ---

Definition at line 999 of file pbx.c.

References ast_channel::accountcode, ast_get_hint(), AST_LIST_TRAVERSE, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_var_name(), ast_var_value(), ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_ani2, ast_callerid::cid_dnid, ast_callerid::cid_name, ast_callerid::cid_num, ast_callerid::cid_pres, ast_callerid::cid_rdnis, ast_callerid::cid_tns, ast_callerid::cid_ton, ast_channel::context, ast_channel::exten, globals, ast_channel::hangupcause, ast_channel::language, LOG_WARNING, ast_channel::name, offset, parse_variable_name(), pbx_retrieve_variable(), ast_channel::priority, substring(), ast_channel::uniqueid, and ast_channel::varshead.

Referenced by handle_getvariable(), pbx_retrieve_variable(), and pbx_substitute_variables_helper_full().

{
   char tmpvar[80];
   time_t thistime;
   struct tm brokentime;
   int offset, offset2, isfunc;
   struct ast_var_t *variables;

   if (c) 
      headp=&c->varshead;
   *ret=NULL;
   ast_copy_string(tmpvar, var, sizeof(tmpvar));
   if (parse_variable_name(tmpvar, &offset, &offset2, &isfunc)) {
      pbx_retrieve_variable(c, tmpvar, ret, workspace, workspacelen, headp);
      if (!(*ret)) 
         return;
      *ret = substring(*ret, offset, offset2, workspace, workspacelen);
   } else if (c && !strncmp(var, "CALL", 4)) {
      if (!strncmp(var + 4, "ER", 2)) {
         if (!strncmp(var + 6, "ID", 2)) {
            if (!var[8]) {          /* CALLERID */
               if (c->cid.cid_num) {
                  if (c->cid.cid_name) {
                     snprintf(workspace, workspacelen, "\"%s\" <%s>", c->cid.cid_name, c->cid.cid_num);
                  } else {
                     ast_copy_string(workspace, c->cid.cid_num, workspacelen);
                  }
                  *ret = workspace;
               } else if (c->cid.cid_name) {
                  ast_copy_string(workspace, c->cid.cid_name, workspacelen);
                  *ret = workspace;
               } else
                  *ret = NULL;
            } else if (!strcmp(var + 8, "NUM")) {
               /* CALLERIDNUM */
               if (c->cid.cid_num) {
                  ast_copy_string(workspace, c->cid.cid_num, workspacelen);
                  *ret = workspace;
               } else
                  *ret = NULL;
            } else if (!strcmp(var + 8, "NAME")) {
               /* CALLERIDNAME */
               if (c->cid.cid_name) {
                  ast_copy_string(workspace, c->cid.cid_name, workspacelen);
                  *ret = workspace;
               } else
                  *ret = NULL;
            } else
               goto icky;
         } else if (!strcmp(var + 6, "ANI")) {
            /* CALLERANI */
            if (c->cid.cid_ani) {
               ast_copy_string(workspace, c->cid.cid_ani, workspacelen);
               *ret = workspace;
            } else
               *ret = NULL;
         } else
            goto icky;
      } else if (!strncmp(var + 4, "ING", 3)) {
         if (!strcmp(var + 7, "PRES")) {
            /* CALLINGPRES */
            snprintf(workspace, workspacelen, "%d", c->cid.cid_pres);
            *ret = workspace;
         } else if (!strcmp(var + 7, "ANI2")) {
            /* CALLINGANI2 */
            snprintf(workspace, workspacelen, "%d", c->cid.cid_ani2);
            *ret = workspace;
         } else if (!strcmp(var + 7, "TON")) {
            /* CALLINGTON */
            snprintf(workspace, workspacelen, "%d", c->cid.cid_ton);
            *ret = workspace;
         } else if (!strcmp(var + 7, "TNS")) {
            /* CALLINGTNS */
            snprintf(workspace, workspacelen, "%d", c->cid.cid_tns);
            *ret = workspace;
         } else
            goto icky;
      } else
         goto icky;
   } else if (c && !strcmp(var, "DNID")) {
      if (c->cid.cid_dnid) {
         ast_copy_string(workspace, c->cid.cid_dnid, workspacelen);
         *ret = workspace;
      } else
         *ret = NULL;
   } else if (c && !strcmp(var, "HINT")) {
      if (!ast_get_hint(workspace, workspacelen, NULL, 0, c, c->context, c->exten))
         *ret = NULL;
      else
         *ret = workspace;
   } else if (c && !strcmp(var, "HINTNAME")) {
      if (!ast_get_hint(NULL, 0, workspace, workspacelen, c, c->context, c->exten))
         *ret = NULL;
      else
         *ret = workspace;
   } else if (c && !strcmp(var, "EXTEN")) {
      ast_copy_string(workspace, c->exten, workspacelen);
      *ret = workspace;
   } else if (c && !strcmp(var, "RDNIS")) {
      if (c->cid.cid_rdnis) {
         ast_copy_string(workspace, c->cid.cid_rdnis, workspacelen);
         *ret = workspace;
      } else
         *ret = NULL;
   } else if (c && !strcmp(var, "CONTEXT")) {
      ast_copy_string(workspace, c->context, workspacelen);
      *ret = workspace;
   } else if (c && !strcmp(var, "PRIORITY")) {
      snprintf(workspace, workspacelen, "%d", c->priority);
      *ret = workspace;
   } else if (c && !strcmp(var, "CHANNEL")) {
      ast_copy_string(workspace, c->name, workspacelen);
      *ret = workspace;
   } else if (!strcmp(var, "EPOCH")) {
      snprintf(workspace, workspacelen, "%u",(int)time(NULL));
      *ret = workspace;
   } else if (!strcmp(var, "DATETIME")) {
      thistime=time(NULL);
      localtime_r(&thistime, &brokentime);
      snprintf(workspace, workspacelen, "%02d%02d%04d-%02d:%02d:%02d",
         brokentime.tm_mday,
         brokentime.tm_mon+1,
         brokentime.tm_year+1900,
         brokentime.tm_hour,
         brokentime.tm_min,
         brokentime.tm_sec
      );
      *ret = workspace;
   } else if (!strcmp(var, "TIMESTAMP")) {
      thistime=time(NULL);
      localtime_r(&thistime, &brokentime);
      /* 20031130-150612 */
      snprintf(workspace, workspacelen, "%04d%02d%02d-%02d%02d%02d",
         brokentime.tm_year+1900,
         brokentime.tm_mon+1,
         brokentime.tm_mday,
         brokentime.tm_hour,
         brokentime.tm_min,
         brokentime.tm_sec
      );
      *ret = workspace;
   } else if (c && !strcmp(var, "UNIQUEID")) {
      snprintf(workspace, workspacelen, "%s", c->uniqueid);
      *ret = workspace;
   } else if (c && !strcmp(var, "HANGUPCAUSE")) {
      snprintf(workspace, workspacelen, "%d", c->hangupcause);
      *ret = workspace;
   } else if (c && !strcmp(var, "ACCOUNTCODE")) {
      ast_copy_string(workspace, c->accountcode, workspacelen);
      *ret = workspace;
   } else if (c && !strcmp(var, "LANGUAGE")) {
      ast_copy_string(workspace, c->language, workspacelen);
      *ret = workspace;
   } else {
icky:
      if (headp) {
         AST_LIST_TRAVERSE(headp,variables,entries) {
#if 0
            ast_log(LOG_WARNING,"Comparing variable '%s' with '%s'\n",var,ast_var_name(variables));
#endif
            if (strcasecmp(ast_var_name(variables),var)==0) {
               *ret=ast_var_value(variables);
               if (*ret) {
                  ast_copy_string(workspace, *ret, workspacelen);
                  *ret = workspace;
               }
               break;
            }
         }
      }
      if (!(*ret)) {
         /* Try globals */
         ast_mutex_lock(&globalslock);
         AST_LIST_TRAVERSE(&globals,variables,entries) {
            if (strcasecmp(ast_var_name(variables),var)==0) {
               *ret = ast_var_value(variables);
               if (*ret) {
                  ast_copy_string(workspace, *ret, workspacelen);
                  *ret = workspace;
               }
            }
         }
         ast_mutex_unlock(&globalslock);
      }
   }
}

int pbx_set_autofallthrough

(

int

newval

)

Definition at line 2589 of file pbx.c.

Referenced by pbx_load_module().

{
   int oldval;
   oldval = autofallthrough;
   if (oldval != newval)
      autofallthrough = newval;
   return oldval;
}

static void pbx_substitute_variables	(	char *	passdata,
		int	datalen,
		struct ast_channel *	c,
		struct ast_exten *	e
	)			[static]

Definition at line 1628 of file pbx.c.

References ast_exten::data, and pbx_substitute_variables_helper().

Referenced by pbx_extension_helper().

{
   memset(passdata, 0, datalen);
      
   /* No variables or expressions in e->data, so why scan it? */
   if (!strchr(e->data, '$') && !strstr(e->data,"${") && !strstr(e->data,"$[") && !strstr(e->data,"$(")) {
      ast_copy_string(passdata, e->data, datalen);
      return;
   }
   
   pbx_substitute_variables_helper(c, e->data, passdata, datalen - 1);
}                                                     

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

Definition at line 1618 of file pbx.c.

References pbx_substitute_variables_helper_full(), and ast_channel::varshead.

Referenced by custom_log(), cut_internal(), eval_exec(), exec_exec(), function_eval(), function_fieldqty(), handle_getvariablefull(), launch_monitor_thread(), macro_exec(), pbx_builtin_importvar(), pbx_find_extension(), pbx_load_module(), pbx_substitute_variables(), realtime_exec(), rpt_exec(), sendmail(), and sendpage().

{
   pbx_substitute_variables_helper_full(c, (c) ? &c->varshead : NULL, cp1, cp2, count);
}

static void pbx_substitute_variables_helper_full	(	struct ast_channel *	c,
		struct varshead *	headp,
		const char *	cp1,
		char *	cp2,
		int	count
	)			[static]

Definition at line 1441 of file pbx.c.

References ast_expr(), ast_func_read(), ast_log(), ast_strlen_zero(), LOG_DEBUG, LOG_NOTICE, offset, parse_variable_name(), pbx_retrieve_variable(), substring(), var, and VAR_BUF_SIZE.

Referenced by pbx_substitute_variables_helper(), and pbx_substitute_variables_varshead().

{
   char *cp4;
   const char *tmp, *whereweare;
   int length, offset, offset2, isfunction;
   char *workspace = NULL;
   char *ltmp = NULL, *var = NULL;
   char *nextvar, *nextexp, *nextthing;
   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);
      nextvar = NULL;
      nextexp = NULL;
      nextthing = strchr(whereweare, '$');
      if (nextthing) {
         switch(nextthing[1]) {
         case '{':
            nextvar = nextthing;
            pos = nextvar - whereweare;
            break;
         case '[':
            nextexp = nextthing;
            pos = nextexp - whereweare;
            break;
         }
      }

      if (pos) {
         /* 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++;
            } else if (vare[0] == '{') {
               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 string */
         whereweare += (len + 3);

         if (!var)
            var = alloca(VAR_BUF_SIZE);

         /* Store variable name (and truncate) */
         ast_copy_string(var, vars, len + 1);

         /* Substitute if necessary */
         if (needsub) {
            if (!ltmp)
               ltmp = alloca(VAR_BUF_SIZE);

            memset(ltmp, 0, VAR_BUF_SIZE);
            pbx_substitute_variables_helper_full(c, headp, var, ltmp, VAR_BUF_SIZE - 1);
            vars = ltmp;
         } else {
            vars = var;
         }

         if (!workspace)
            workspace = alloca(VAR_BUF_SIZE);

         workspace[0] = '\0';

         parse_variable_name(vars, &offset, &offset2, &isfunction);
         if (isfunction) {
            /* Evaluate function */
            cp4 = ast_func_read(c, vars, workspace, VAR_BUF_SIZE);

            ast_log(LOG_DEBUG, "Function result is '%s'\n", cp4 ? cp4 : "(null)");
         } else {
            /* Retrieve variable value */
            pbx_retrieve_variable(c, vars, &cp4, workspace, VAR_BUF_SIZE, headp);