pbx.c File Reference

Core PBX routines. More...

#include "asterisk.h"
#include "asterisk/_private.h"
#include "asterisk/paths.h"
#include <ctype.h>
#include <time.h>
#include <sys/time.h>
#include "asterisk/lock.h"
#include "asterisk/cli.h"
#include "asterisk/pbx.h"
#include "asterisk/channel.h"
#include "asterisk/file.h"
#include "asterisk/callerid.h"
#include "asterisk/cdr.h"
#include "asterisk/cel.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/event.h"
#include "asterisk/hashtab.h"
#include "asterisk/module.h"
#include "asterisk/indications.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/xmldoc.h"

Include dependency graph for pbx.c:

Go to the source code of this file.

Data Structures
struct	acf_root
struct	app_tmp
struct	apps
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	cfextension_states
struct	dialplan_counters
	Counters for the show dialplan manager command. More...
struct	fake_context
struct	hints
struct	match_char
	match_char: forms a syntax tree for quick matching of extension patterns More...
struct	pbx_builtin
	Declaration of builtin applications. More...
struct	pbx_exception
struct	scoreboard
struct	statecbs
struct	statechange
struct	store_hint
struct	store_hints
struct	switches
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	EXT_DATA_SIZE   8192
#define	NEW_MATCHER_CHK_MATCH
#define	NEW_MATCHER_RECURSE
#define	SAY_STUBS
#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_DIALTONE   (1 << 1)
#define	WAITEXTEN_MOH   (1 << 0)
Functions
void	__ast_context_destroy (struct ast_context *list, struct ast_hashtab *contexttab, struct ast_context *con, const char *registrar)
int	__ast_custom_function_register (struct ast_custom_function *acf, struct ast_module *mod)
	Register a custom function.
static int	__ast_goto_if_exists (struct ast_channel *chan, const char *context, const char *exten, int priority, int async)
static void	__ast_internal_context_destroy (struct ast_context *con)
static enum ast_pbx_result	__ast_pbx_run (struct ast_channel *c, struct ast_pbx_args *args)
static void	__fini_acf_root (void)
static void	__fini_apps (void)
static void	__fini_hints (void)
static void	__fini_switches (void)
static void	__init_acf_root (void)
static void	__init_apps (void)
static void	__init_extensionstate_buf (void)
static void	__init_hints (void)
static void	__init_switch_data (void)
static void	__init_switches (void)
static int	_extension_match_core (const char *pattern, const char *data, enum ext_match_t mode)
static int	acf_exception_read (struct ast_channel *chan, const char *name, char *data, char *buf, size_t buflen)
static int	acf_retrieve_docs (struct ast_custom_function *acf)
static struct match_char *	add_exten_to_pattern_tree (struct ast_context *con, struct ast_exten *e1, int findonly)
static struct match_char *	add_pattern_node (struct ast_context *con, struct match_char *current, char *pattern, int is_pattern, int already, int specificity, struct match_char **parent)
static int	add_pri (struct ast_context *con, struct ast_exten *tmp, struct ast_exten *el, struct ast_exten *e, int replace)
	add the extension in the priority chain.
static int	add_pri_lockopt (struct ast_context *con, struct ast_exten *tmp, struct ast_exten *el, struct ast_exten *e, int replace, int lockhints)
	add the extension in the priority chain.
static struct match_char *	already_in_tree (struct match_char *current, char *pat, int is_pattern)
int	ast_active_calls (void)
	Retrieve the number of active calls.
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)
	Add and extension to an extension context.
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)
	Main interface to add extensions to the list for out context.
static int	ast_add_extension2_lockopt (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, int lockconts, int lockhints)
	Does all the work of ast_add_extension2, but adds two args, to determine if context and hint locking should be done. In merge_and_delete, we need to do this without locking, as the locks are already held.
static int	ast_add_extension_nolock (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)
static int	ast_add_hint (struct ast_exten *e)
	Add hint to hint list, check initial extension state.
static int	ast_add_hint_nolock (struct ast_exten *e)
	Add hint to hint list, check initial extension state; the hints had better be WRLOCKED already!
int	ast_async_goto (struct ast_channel *chan, const char *context, const char *exten, int priority)
	Set the channel to next execute the specified dialplan location.
int	ast_async_goto_by_name (const char *channame, const char *context, const char *exten, int priority)
	Set the channel to next execute the specified dialplan location.
int	ast_async_goto_if_exists (struct ast_channel *chan, const char *context, const char *exten, int priority)
int	ast_async_parseable_goto (struct ast_channel *chan, const char *goto_string)
int	ast_build_timing (struct ast_timing *i, const char *info_in)
	Construct a timing bitmap, for use in time-based conditionals.
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.
static int	ast_change_hint (struct ast_exten *oe, struct ast_exten *ne)
	Change hint for an extension.
int	ast_check_timing (const struct ast_timing *i)
	Evaluate a pre-constructed bitmap as to whether the current time falls within the range specified.
char *	ast_complete_applications (const char *line, const char *word, int state)
	Command completion for the list of installed applications.
int	ast_context_add_ignorepat (const char *context, const char *value, const char *registrar)
	Add an ignorepat.
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)
	Add a context include.
int	ast_context_add_include2 (struct ast_context *con, const char *value, const char *registrar)
	Add a context include.
int	ast_context_add_switch (const char *context, const char *sw, const char *data, int eval, const char *registrar)
	Add a switch.
int	ast_context_add_switch2 (struct ast_context *con, const char *value, const char *data, int eval, const char *registrar)
	Adds a switch (first param is a ast_context).
void	ast_context_destroy (struct ast_context *con, const char *registrar)
	Destroy a context (matches the specified context (or ANY context if NULL).
struct ast_context *	ast_context_find (const char *name)
	Find a context.
struct ast_context *	ast_context_find_or_create (struct ast_context **extcontexts, struct ast_hashtab *exttable, const char *name, const char *registrar)
	Register a new context or find an existing one.
int	ast_context_lockmacro (const char *context)
	locks the macrolock in the given given context
int	ast_context_remove_extension (const char *context, const char *extension, int priority, const char *registrar)
	Simply remove extension from context.
int	ast_context_remove_extension2 (struct ast_context *con, const char *extension, int priority, const char *registrar, int already_locked)
	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_extension_callerid (const char *context, const char *extension, int priority, const char *callerid, int matchcallerid, const char *registrar)
int	ast_context_remove_extension_callerid2 (struct ast_context *con, const char *extension, int priority, const char *callerid, int matchcallerid, const char *registrar, int already_locked)
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)
	Remove included contexts. This function locks contexts list by &conlist, search for the right context structure, leave context list locked and call ast_context_remove_include2 which removes include, unlock contexts list and return ...
int	ast_context_remove_include2 (struct ast_context *con, const char *include, const char *registrar)
	Locks context, remove included contexts, unlocks context. 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.
int	ast_context_remove_switch (const char *context, const char *sw, const char *data, const char *registrar)
	Remove a switch.
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_unlockmacro (const char *context)
	Unlocks the macrolock in the given context.
int	ast_context_verify_includes (struct ast_context *con)
	Verifies includes in an ast_contect structure.
struct ast_custom_function *	ast_custom_function_find (const char *name)
int	ast_custom_function_unregister (struct ast_custom_function *acf)
	Unregister a custom function.
int	ast_destroy_timing (struct ast_timing *i)
	Deallocates memory structures associated with a timing bitmap.
enum ast_extension_states	ast_devstate_to_extenstate (enum ast_device_state devstate)
	Map devstate to an extension state.
int	ast_exists_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
	Determine whether an extension exists.
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_cmp (const char *a, const char *b)
	Determine if one extension should match before another.
int	ast_extension_match (const char *pattern, const char *data)
	Determine if a given extension matches a given pattern (in NXX format).
int	ast_extension_state (struct ast_channel *c, const char *context, const char *exten)
	Check extension state for an extension by using hint.
static int	ast_extension_state2 (struct ast_exten *e)
	Check state of extension by using hints.
const char *	ast_extension_state2str (int extension_state)
	Return extension_state as string.
int	ast_extension_state_add (const char *context, const char *exten, ast_state_cb_type callback, void *data)
	Add watcher for extension states.
int	ast_extension_state_del (int id, ast_state_cb_type callback)
	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)
	Find the priority of an extension that has the specified label.
int	ast_findlabel_extension2 (struct ast_channel *c, struct ast_context *con, const char *exten, const char *label, const char *callerid)
	Find the priority of an extension that has the specified label.
int	ast_func_read (struct ast_channel *chan, const char *function, char *workspace, size_t len)
	executes a read operation on a function
int	ast_func_read2 (struct ast_channel *chan, const char *function, struct ast_str **str, ssize_t maxlen)
	executes a read operation on a function
int	ast_func_write (struct ast_channel *chan, const char *function, const char *value)
	executes a write operation on a function
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)
struct ast_context *	ast_get_extension_context (struct ast_exten *exten)
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)
	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)
int	ast_get_switch_eval (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, const char *context, const char *exten, int priority)
int	ast_hashtab_compare_contexts (const void *ah_a, const void *ah_b)
	hashtable functions for contexts
unsigned int	ast_hashtab_hash_contexts (const void *obj)
static struct ast_exten *	ast_hint_extension (struct ast_channel *c, const char *context, const char *exten)
static struct ast_exten *	ast_hint_extension_nolock (struct ast_channel *c, const char *context, const char *exten)
	Find hint for given extension in context.
int	ast_ignore_pattern (const char *context, const char *pattern)
	Checks to see if a number should be ignored.
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).
void	ast_merge_contexts_and_delete (struct ast_context **extcontexts, struct ast_hashtab *exttable, const char *registrar)
	Merge the temporary contexts into a global contexts list and delete from the global list the ones that are being added.
int	ast_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 synchronous, const char *cid_num, const char *cid_name, struct ast_variable *vars, const char *account, struct ast_channel **locked_channel)
static int	ast_pbx_outgoing_cdr_failed (void)
	Function to post an empty cdr after a spool call fails.
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 synchronous, 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)
	Execute the PBX in the current thread.
static void *	ast_pbx_run_app (void *data)
	run the application and free the descriptor once done
enum ast_pbx_result	ast_pbx_run_args (struct ast_channel *c, struct ast_pbx_args *args)
	Execute the PBX in the current thread.
enum ast_pbx_result	ast_pbx_start (struct ast_channel *c)
	Create a new thread and start the PBX.
int	ast_processed_calls (void)
	Retrieve the total number of calls processed through the PBX since last restart.
int	ast_rdlock_context (struct ast_context *con)
	Read locks a given context.
int	ast_rdlock_contexts ()
	Read locks the context list.
int	ast_register_application2 (const char *app, int(*execute)(struct ast_channel *, const char *), const char *synopsis, const char *description, void *mod)
	Dynamically register a new dial plan application.
int	ast_register_switch (struct ast_switch *sw)
	Register an alternative dialplan switch.
static int	ast_remove_hint (struct ast_exten *e)
	Remove hint from extension.
int	ast_spawn_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid, int *found, int combined_find_spawn)
	Launch a new extension (i.e. new stack).
int	ast_str_get_hint (struct ast_str **hint, ssize_t hintsize, struct ast_str **name, ssize_t namesize, struct ast_channel *c, const char *context, const char *exten)
	Get hint for channel.
const char *	ast_str_retrieve_variable (struct ast_str **str, ssize_t maxlen, struct ast_channel *c, struct varshead *headp, const char *var)
void	ast_str_substitute_variables (struct ast_str **buf, ssize_t maxlen, struct ast_channel *chan, const char *templ)
void	ast_str_substitute_variables_full (struct ast_str **buf, ssize_t maxlen, struct ast_channel *c, struct varshead *headp, const char *templ, size_t *used)
void	ast_str_substitute_variables_varshead (struct ast_str **buf, ssize_t maxlen, struct varshead *headp, const char *templ)
static const char *	ast_str_substring (struct ast_str *value, int offset, int length)
int	ast_unlock_context (struct ast_context *con)
int	ast_unlock_contexts ()
	Unlocks contexts.
int	ast_unregister_application (const char *app)
	Unregister an application.
void	ast_unregister_switch (struct ast_switch *sw)
	Unregister an alternative switch.
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)
int	ast_wrlock_context (struct ast_context *con)
	Write locks a given context.
int	ast_wrlock_contexts ()
	Write locks the context list.
int	ast_wrlock_contexts_version (void)
static void *	async_wait (void *data)
static void	cli_match_char_tree (struct match_char *node, char *prefix, int fd)
static int	collect_digits (struct ast_channel *c, int waittime, char *buf, int buflen, int pos)
	collect digits from the channel into the buffer.
static int	compare_char (const void *a, const void *b)
static char *	complete_core_show_hint (const char *line, const char *word, int pos, int state)
	autocomplete for CLI command 'core show hint'
static char *	complete_show_dialplan_context (const char *line, const char *word, int pos, int state)
static void	context_merge (struct ast_context **extcontexts, struct ast_hashtab *exttable, struct ast_context *context, const char *registrar)
static void	context_merge_incls_swits_igps_other_registrars (struct ast_context *new, struct ast_context *old, const char *registrar)
static void	create_match_char_tree (struct ast_context *con)
static void	decrease_call_count (void)
static void	destroy_exten (struct ast_exten *e)
static void	destroy_pattern_tree (struct match_char *pattern_tree)
static void	device_state_cb (const struct ast_event *event, void *unused)
static void	exception_store_free (void *data)
static int	ext_cmp (const char *a, const char *b)
	the full routine to compare extensions in rules.
static int	ext_cmp1 (const char **p)
	helper functions to sort extensions and patterns in the desired way, so that more specific patterns appear first.
static int	ext_strncpy (char *dst, const char *src, int len)
	copy a string skipping whitespace
static int	extension_match_core (const char *pattern, const char *data, enum ext_match_t mode)
static struct ast_context *	find_context (const char *context)
	lookup for a context with a given name,
static struct ast_context *	find_context_locked (const char *context)
	lookup for a context with a given name,
static char *	func_args (char *function)
	return a pointer to the arguments of the function, and terminates the function name with '\0'
static struct ast_exten *	get_canmatch_exten (struct match_char *node)
static unsigned	get_range (char *src, int max, const char *const names[], const char *msg)
	helper function to return a range up to max (7, 12, 31 respectively). names, if supplied, is an array of names that should be mapped to numbers.
static void	get_timerange (struct ast_timing *i, char *times)
	store a bitmask of valid times, one bit each 1 minute
static char *	handle_debug_dialplan (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Send ack once.
static char *	handle_set_chanvar (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_set_extenpatternmatchnew (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_set_global (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_application (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_applications (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_chanvar (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	CLI support for listing chanvar's variables in a parseable way.
static char *	handle_show_dialplan (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_function (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_functions (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_globals (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	CLI support for listing global variables in a parseable way.
static char *	handle_show_hint (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	handle_show_hint: CLI support for listing registered dial plan hint
static char *	handle_show_hints (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	handle_show_hints: CLI support for listing registered dial plan hints
static char *	handle_show_switches (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	handle_show_switches: CLI support for listing registered dial plan switches
static int	handle_statechange (void *datap)
static char *	handle_unset_extenpatternmatchnew (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int	hashtab_compare_exten_labels (const void *ah_a, const void *ah_b)
static int	hashtab_compare_exten_numbers (const void *ah_a, const void *ah_b)
static int	hashtab_compare_extens (const void *ha_a, const void *ah_b)
static unsigned int	hashtab_hash_extens (const void *obj)
static unsigned int	hashtab_hash_labels (const void *obj)
static unsigned int	hashtab_hash_priority (const void *obj)
static int	include_valid (struct ast_include *i)
static int	increase_call_count (const struct ast_channel *c)
	Increase call count for channel.
static void	insert_in_next_chars_alt_char_list (struct match_char **parent_ptr, struct match_char *node)
int	load_pbx (void)
static int	lookup_name (const char *s, const char *const names[], int max)
	Helper for get_range. return the index of the matching entry, starting from 1. If names is not supplied, try numeric values.
static void	manager_dpsendack (struct mansession *s, const struct message *m)
	Send ack once.
static int	manager_show_dialplan (struct mansession *s, const struct message *m)
	Manager listing of dial plan.
static int	manager_show_dialplan_helper (struct mansession *s, const struct message *m, const char *actionidtext, const char *context, const char *exten, struct dialplan_counters *dpc, struct ast_include *rinclude)
	Show dialplan extensions XXX this function is similar but not exactly the same as the CLI's show dialplan. Must check whether the difference is intentional or not.
static int	matchcid (const char *cidpattern, const char *callerid)
static void	new_find_extension (const char *str, struct scoreboard *score, struct match_char *tree, int length, int spec, const char *callerid, const char *label, enum ext_match_t action)
static int	parse_variable_name (char *var, int *offset, int *length, int *isfunc)
	extract offset:length from variable name.
static int	pbx_builtin_answer (struct ast_channel *, const char *)
static int	pbx_builtin_background (struct ast_channel *, const char *)
static int	pbx_builtin_busy (struct ast_channel *, const char *)
void	pbx_builtin_clear_globals (void)
static int	pbx_builtin_congestion (struct ast_channel *, const char *)
static int	pbx_builtin_execiftime (struct ast_channel *, const char *)
const char *	pbx_builtin_getvar_helper (struct ast_channel *chan, const char *name)
	Return a pointer to the value of the corresponding channel variable.
static int	pbx_builtin_goto (struct ast_channel *, const char *)
static int	pbx_builtin_gotoif (struct ast_channel *, const char *)
static int	pbx_builtin_gotoiftime (struct ast_channel *, const char *)
static int	pbx_builtin_hangup (struct ast_channel *, const char *)
static int	pbx_builtin_importvar (struct ast_channel *, const char *)
static int	pbx_builtin_incomplete (struct ast_channel *, const char *)
static int	pbx_builtin_noop (struct ast_channel *, const char *)
static int	pbx_builtin_proceeding (struct ast_channel *, const char *)
static int	pbx_builtin_progress (struct ast_channel *, const char *)
void	pbx_builtin_pushvar_helper (struct ast_channel *chan, const char *name, const char *value)
	Add a variable to the channel variable stack, without removing any previously set value.
int	pbx_builtin_raise_exception (struct ast_channel *chan, const char *reason)
static int	pbx_builtin_resetcdr (struct ast_channel *, const char *)
static int	pbx_builtin_ringing (struct ast_channel *, const char *)
static int	pbx_builtin_saycharacters (struct ast_channel *, const char *)
static int	pbx_builtin_saydigits (struct ast_channel *, const char *)
static int	pbx_builtin_saynumber (struct ast_channel *, const char *)
static int	pbx_builtin_sayphonetic (struct ast_channel *, const char *)
int	pbx_builtin_serialize_variables (struct ast_channel *chan, struct ast_str **buf)
	Create a human-readable string, specifying all variables and their corresponding values.
static int	pbx_builtin_setamaflags (struct ast_channel *, const char *)
int	pbx_builtin_setvar (struct ast_channel *chan, const char *data)
	Parse and set a single channel variable, where the name and value are separated with an '=' character.
void	pbx_builtin_setvar_helper (struct ast_channel *chan, const char *name, const char *value)
	Add a variable to the channel variable stack, removing the most recently set value for the same name.
int	pbx_builtin_setvar_multiple (struct ast_channel *chan, const char *vdata)
	Parse and set multiple channel variables, where the pairs are separated by the ',' character, and name and value are separated with an '=' character.
static int	pbx_builtin_wait (struct ast_channel *, const char *)
static int	pbx_builtin_waitexten (struct ast_channel *, const char *)
int	pbx_checkcondition (const char *condition)
	Evaluate a condition.
static void	pbx_destroy (struct ast_pbx *p)
int	pbx_exec (struct ast_channel *c, struct ast_app *app, const char *data)
	Execute an application.
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, enum ext_match_t action, int *found, int combined_find_spawn)
	The return value depends on the action:.
struct ast_exten *	pbx_find_extension (struct ast_channel *chan, struct ast_context *bypass, struct pbx_find_info *q, const char *context, const char *exten, int priority, const char *label, const char *callerid, enum ext_match_t action)
struct ast_app *	pbx_findapp (const char *app)
	Find application handle in linked list.
static struct ast_switch *	pbx_findswitch (const char *sw)
static int	pbx_parseable_goto (struct ast_channel *chan, const char *goto_string, int async)
void	pbx_retrieve_variable (struct ast_channel *c, const char *var, char **ret, char *workspace, int workspacelen, struct varshead *headp)
	Support for Asterisk built-in variables in the dialplan.
int	pbx_set_autofallthrough (int newval)
int	pbx_set_extenpatternmatchnew (int newval)
void	pbx_set_overrideswitch (const char *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)
void	pbx_substitute_variables_helper_full (struct ast_channel *c, struct varshead *headp, const char *cp1, char *cp2, int count, size_t *used)
void	pbx_substitute_variables_varshead (struct varshead *headp, const char *cp1, char *cp2, int count)
static void *	pbx_thread (void *data)
static void	print_app_docs (struct ast_app *aa, int fd)
static void	print_ext (struct ast_exten *e, char *buf, int buflen)
	helper function to print an extension
static void	set_ext_pri (struct ast_channel *c, const char *exten, int pri)
static int	show_debug_helper (int fd, const char *context, const char *exten, struct dialplan_counters *dpc, struct ast_include *rinclude, int includecount, const char *includes[])
static int	show_dialplan_helper (int fd, const char *context, const char *exten, struct dialplan_counters *dpc, struct ast_include *rinclude, int includecount, const 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 struct ast_exten *	trie_find_next_match (struct match_char *node)
static void	unreference_cached_app (struct ast_app *app)
static void	update_scoreboard (struct scoreboard *board, int length, int spec, struct ast_exten *exten, char last, const char *callerid, int deleted, struct match_char *node)
static void	wait_for_hangup (struct ast_channel *chan, const void *data)
Variables
static int	autofallthrough = 1
static struct ast_app_option	background_opts [128] = { [ 's' ] = { .flag = (1 << 0) }, [ 'n' ] = { .flag = (1 << 1) }, [ 'm' ] = { .flag = (1 << 2) }, [ 'p' ] = { .flag = (1 << 3) },}
static struct pbx_builtin	builtins []
	Declaration of builtin applications.
static ast_rwlock_t	conlock = { 0 }
static int	conlock_wrlock_version = 0
static struct ast_context *	contexts
static struct ast_hashtab *	contexts_table = NULL
static int	countcalls
static const char *const	days []
static struct ast_event_sub *	device_state_sub
	Subscription for device state change events.
static struct ast_taskprocessor *	device_state_tps
static struct ast_custom_function	exception_function
static struct ast_datastore_info	exception_store_info
static int	extenpatternmatchnew = 0
static struct cfextension_states	extension_states []
static struct ast_threadstorage	extensionstate_buf = { .once = PTHREAD_ONCE_INIT, .key_init = __init_extensionstate_buf , .custom_init = NULL , }
static struct varshead	globals = AST_LIST_HEAD_NOLOCK_INIT_VALUE
static ast_rwlock_t	globalslock = { 0 }
static ast_mutex_t	maxcalllock = ((ast_mutex_t) PTHREAD_MUTEX_INITIALIZER )
static const char *const	months []
static char *	overrideswitch = NULL
static struct ast_cli_entry	pbx_cli []
static struct ast_app_option	resetcdr_opts [128] = { [ 'w' ] = { .flag = (1 << 1) }, [ 'a' ] = { .flag = (1 << 2) }, [ 'v' ] = { .flag = (1 << 0) }, [ 'e' ] = { .flag = (1 << 10) },}
static int	stateid = 1
static struct ast_threadstorage	switch_data = { .once = PTHREAD_ONCE_INIT, .key_init = __init_switch_data , .custom_init = NULL , }
static int	totalcalls
static struct ast_app_option	waitexten_opts [128] = { [ 'm' ] = { .flag = (1 << 0) , .arg_index = 0 + 1 }, [ 'd' ] = { .flag = (1 << 1) , .arg_index = 0 + 1 },}

---

Detailed Description

Core PBX routines.

Author:

Mark Spencer <markster@digium.com>

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

#define BACKGROUND_MATCHEXTEN   (1 << 2)

Definition at line 756 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_NOANSWER   (1 << 1)

Definition at line 755 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_PLAYBACK   (1 << 3)

Definition at line 757 of file pbx.c.

Referenced by pbx_builtin_background().

#define BACKGROUND_SKIP   (1 << 0)

Definition at line 754 of file pbx.c.

Referenced by pbx_builtin_background().

#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 ;-)

A new algorithm to do searching based on a 'compiled' pattern tree is introduced here, and shows a fairly flat (constant) search time, even for over 10000 patterns.

Also, using a hash table for context/priority name lookup can help prevent the find_extension routines from absorbing exponential cpu cycles as the number of contexts/priorities grow. I've previously tested find_extension with red-black trees, which have O(log2(n)) speed. Right now, I'm using hash tables, which do searches (ideally) in O(1) time. While these techniques do not yield much speed in small dialplans, they are worth the trouble in large dialplans.

Definition at line 743 of file pbx.c.

Referenced by pbx_extension_helper(), and realtime_exec().

#define NEW_MATCHER_CHK_MATCH

Referenced by new_find_extension().

#define NEW_MATCHER_RECURSE

Referenced by new_find_extension().

#define SAY_STUBS

Definition at line 55 of file pbx.c.

#define STATUS_NO_CONTEXT   1

Definition at line 2475 of file pbx.c.

#define STATUS_NO_EXTENSION   2

Definition at line 2476 of file pbx.c.

#define STATUS_NO_LABEL   4

Definition at line 2478 of file pbx.c.

#define STATUS_NO_PRIORITY   3

Definition at line 2477 of file pbx.c.

#define STATUS_SUCCESS   5

Definition at line 2479 of file pbx.c.

#define SWITCH_DATA_LENGTH   256

Definition at line 746 of file pbx.c.

#define VAR_BUF_SIZE   4096

Definition at line 748 of file pbx.c.

Referenced by ast_add_extension2_lockopt(), ast_func_read2(), pbx_builtin_importvar(), and pbx_substitute_variables_helper_full().

#define VAR_HARDTRAN   3

Definition at line 752 of file pbx.c.

#define VAR_NORMAL   1

Definition at line 750 of file pbx.c.

#define VAR_SOFTTRAN   2

Definition at line 751 of file pbx.c.

#define WAITEXTEN_DIALTONE   (1 << 1)

Definition at line 767 of file pbx.c.

Referenced by pbx_builtin_waitexten().

#define WAITEXTEN_MOH   (1 << 0)

Definition at line 766 of file pbx.c.

Referenced by pbx_builtin_waitexten().

---

Function Documentation

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

Definition at line 8563 of file pbx.c.

References __ast_internal_context_destroy(), ast_context::alts, ast_context_remove_extension_callerid2(), ast_debug, ast_free, ast_hashtab_end_traversal(), ast_hashtab_next(), ast_hashtab_remove_this_object(), ast_hashtab_start_traversal(), AST_LIST_EMPTY, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_exten::cidmatch, contexts, ast_exten::exten, ast_context::ignorepats, ast_context::includes, ast_context::name, ast_include::next, ast_ignorepat::next, ast_context::next, ast_sw::next, ast_exten::peer_table, ast_exten::priority, ast_context::refcount, ast_exten::registrar, ast_sw::registrar, ast_include::registrar, ast_ignorepat::registrar, ast_context::registrar, ast_context::root, and ast_context::root_table.

Referenced by ast_context_destroy().

{
   struct ast_context *tmp, *tmpl=NULL;
   struct ast_exten *exten_item, *prio_item;

   for (tmp = list; tmp; ) {
      struct ast_context *next = NULL; /* next starting point */
         /* The following code used to skip forward to the next
            context with matching registrar, but this didn't
            make sense; individual priorities registrar'd to
            the matching registrar could occur in any context! */
      ast_debug(1, "Investigate ctx %s %s\n", tmp->name, tmp->registrar);
      if (con) {
         for (; tmp; tmpl = tmp, tmp = tmp->next) { /* skip to the matching context */
            ast_debug(1, "check ctx %s %s\n", tmp->name, tmp->registrar);
            if ( !strcasecmp(tmp->name, con->name) ) {
               break;   /* found it */
            }
         }
      }

      if (!tmp)   /* not found, we are done */
         break;
      ast_wrlock_context(tmp);

      if (registrar) {
         /* then search thru and remove any extens that match registrar. */
         struct ast_hashtab_iter *exten_iter;
         struct ast_hashtab_iter *prio_iter;
         struct ast_ignorepat *ip, *ipl = NULL, *ipn = NULL;
         struct ast_include *i, *pi = NULL, *ni = NULL;
         struct ast_sw *sw = NULL;

         /* remove any ignorepats whose registrar matches */
         for (ip = tmp->ignorepats; ip; ip = ipn) {
            ipn = ip->next;
            if (!strcmp(ip->registrar, registrar)) {
               if (ipl) {
                  ipl->next = ip->next;
                  ast_free(ip);
                  continue; /* don't change ipl */
               } else {
                  tmp->ignorepats = ip->next;
                  ast_free(ip);
                  continue; /* don't change ipl */
               }
            }
            ipl = ip;
         }
         /* remove any includes whose registrar matches */
         for (i = tmp->includes; i; i = ni) {
            ni = i->next;
            if (strcmp(i->registrar, registrar) == 0) {
               /* remove from list */
               if (pi) {
                  pi->next = i->next;
                  /* free include */
                  ast_free(i);
                  continue; /* don't change pi */
               } else {
                  tmp->includes = i->next;
                  /* free include */
                  ast_free(i);
                  continue; /* don't change pi */
               }
            }
            pi = i;
         }
         /* remove any switches whose registrar matches */
         AST_LIST_TRAVERSE_SAFE_BEGIN(&tmp->alts, sw, list) {
            if (strcmp(sw->registrar,registrar) == 0) {
               AST_LIST_REMOVE_CURRENT(list);
               ast_free(sw);
            }
         }
         AST_LIST_TRAVERSE_SAFE_END;

         if (tmp->root_table) { /* it is entirely possible that the context is EMPTY */
            exten_iter = ast_hashtab_start_traversal(tmp->root_table);
            while ((exten_item=ast_hashtab_next(exten_iter))) {
               prio_iter = ast_hashtab_start_traversal(exten_item->peer_table);
               while ((prio_item=ast_hashtab_next(prio_iter))) {
                  if (!prio_item->registrar || strcmp(prio_item->registrar, registrar) != 0) {
                     continue;
                  }
                  ast_verb(3, "Remove %s/%s/%d, registrar=%s; con=%s(%p); con->root=%p\n",
                         tmp->name, prio_item->exten, prio_item->priority, registrar, con? con->name : "<nil>", con, con? con->root_table: NULL);
                  /* set matchcid to 1 to insure we get a direct match, and NULL registrar to make sure no wildcarding is done */
                  ast_context_remove_extension_callerid2(tmp, prio_item->exten, prio_item->priority, prio_item->cidmatch, 1, NULL, 1);
               }
               ast_hashtab_end_traversal(prio_iter);
            }
            ast_hashtab_end_traversal(exten_iter);
         }

         /* delete the context if it's registrar matches, is empty, has refcount of 1, */
         /* it's not empty, if it has includes, ignorepats, or switches that are registered from
            another registrar. It's not empty if there are any extensions */
         if (strcmp(tmp->registrar, registrar) == 0 && tmp->refcount < 2 && !tmp->root && !tmp->ignorepats && !tmp->includes && AST_LIST_EMPTY(&tmp->alts)) {
            ast_debug(1, "delete ctx %s %s\n", tmp->name, tmp->registrar);
            ast_hashtab_remove_this_object(contexttab, tmp);

            next = tmp->next;
            if (tmpl)
               tmpl->next = next;
            else
               contexts = 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_unlock_context(tmp);
            __ast_internal_context_destroy(tmp);
         } else {
            ast_debug(1,"Couldn't delete ctx %s/%s; refc=%d; tmp.root=%p\n", tmp->name, tmp->registrar,
                    tmp->refcount, tmp->root);
            ast_unlock_context(tmp);
            next = tmp->next;
            tmpl = tmp;
         }
      } else if (con) {
         ast_verb(3, "Deleting context %s registrar=%s\n", tmp->name, tmp->registrar);
         ast_debug(1, "delete ctx %s %s\n", tmp->name, tmp->registrar);
         ast_hashtab_remove_this_object(contexttab, tmp);

         next = tmp->next;
         if (tmpl)
            tmpl->next = next;
         else
            contexts = 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_unlock_context(tmp);
         __ast_internal_context_destroy(tmp);
      }

      /* if we have a specific match, we are done, otherwise continue */
      tmp = con ? NULL : next;
   }
}

int __ast_custom_function_register	(	struct ast_custom_function *	acf,
		struct ast_module *	mod
	)

Register a custom function.

Definition at line 3358 of file pbx.c.

References acf_retrieve_docs(), ast_custom_function::acflist, ast_log(), AST_RWLIST_INSERT_BEFORE_CURRENT, AST_RWLIST_INSERT_TAIL, AST_RWLIST_TRAVERSE, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, AST_STATIC_DOC, ast_verb, COLOR_BRCYAN, ast_custom_function::docsrc, LOG_ERROR, ast_custom_function::mod, ast_custom_function::name, and term_color().

Referenced by load_pbx().

{
   struct ast_custom_function *cur;
   char tmps[80];

   if (!acf) {
      return -1;
   }

   acf->mod = mod;
#ifdef AST_XML_DOCS
   acf->docsrc = AST_STATIC_DOC;
#endif

   if (acf_retrieve_docs(acf)) {
      return -1;
   }

   AST_RWLIST_WRLOCK(&acf_root);

   AST_RWLIST_TRAVERSE(&acf_root, cur, acflist) {
      if (!strcmp(acf->name, cur->name)) {
         ast_log(LOG_ERROR, "Function %s already registered.\n", acf->name);
         AST_RWLIST_UNLOCK(&acf_root);
         return -1;
      }
   }

   /* Store in alphabetical order */
   AST_RWLIST_TRAVERSE_SAFE_BEGIN(&acf_root, cur, acflist) {
      if (strcasecmp(acf->name, cur->name) < 0) {
         AST_RWLIST_INSERT_BEFORE_CURRENT(acf, acflist);
         break;
      }
   }
   AST_RWLIST_TRAVERSE_SAFE_END;

   if (!cur) {
      AST_RWLIST_INSERT_TAIL(&acf_root, acf, acflist);
   }

   AST_RWLIST_UNLOCK(&acf_root);

   ast_verb(2, "Registered custom function '%s'\n", term_color(tmps, acf->name, COLOR_BRCYAN, 0, sizeof(tmps)));

   return 0;
}

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

Definition at line 9822 of file pbx.c.

References ast_async_goto(), ast_exists_extension(), ast_explicit_goto(), AST_PBX_GOTO_FAILED, 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;

   if (context == NULL)
      context = chan->context;
   if (exten == NULL)
      exten = chan->exten;

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

static void __ast_internal_context_destroy

(

struct ast_context *

con

)

[static]

Definition at line 8516 of file pbx.c.

References ast_context::alts, ast_free, ast_hashtab_destroy(), AST_LIST_REMOVE_HEAD, ast_rwlock_destroy(), destroy_exten(), destroy_pattern_tree(), el, ast_context::ignorepats, ast_context::includes, ast_context::lock, ast_exten::next, ast_ignorepat::next, ast_include::next, ast_context::pattern_tree, ast_exten::peer, ast_context::registrar, ast_context::root, and ast_context::root_table.

Referenced by __ast_context_destroy(), and ast_merge_contexts_and_delete().

{
   struct ast_include *tmpi;
   struct ast_sw *sw;
   struct ast_exten *e, *el, *en;
   struct ast_ignorepat *ipi;
   struct ast_context *tmp = con;

   for (tmpi = tmp->includes; tmpi; ) { /* Free includes */
      struct ast_include *tmpil = tmpi;
      tmpi = tmpi->next;
      ast_free(tmpil);
   }
   for (ipi = tmp->ignorepats; ipi; ) { /* Free ignorepats */
      struct ast_ignorepat *ipl = ipi;
      ipi = ipi->next;
      ast_free(ipl);
   }
   if (tmp->registrar)
      ast_free(tmp->registrar);

   /* destroy the hash tabs */
   if (tmp->root_table) {
      ast_hashtab_destroy(tmp->root_table, 0);
   }
   /* and destroy the pattern tree */
   if (tmp->pattern_tree)
      destroy_pattern_tree(tmp->pattern_tree);

   while ((sw = AST_LIST_REMOVE_HEAD(&tmp->alts, list)))
      ast_free(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);
   }
   tmp->root = NULL;
   ast_rwlock_destroy(&tmp->lock);
   ast_free(tmp);
}

static enum ast_pbx_result __ast_pbx_run	(	struct ast_channel *	c,
		struct ast_pbx_args *	args
	)			[static]

Note:

We get here on a failure of some kind: non-existing extension or hangup. We have options, here. We can either catch the failure and continue, or we can drop out entirely.

If there is no match at priority 1, it is not a valid extension anymore. Try to continue at "i" (for invalid) or "e" (for exception) or exit if neither exist.

Definition at line 4551 of file pbx.c.

References ast_channel::_softhangup, ast_calloc, ast_cdr_end(), ast_cdr_update(), ast_check_hangup(), ast_clear_flag, ast_copy_string(), ast_debug, ast_exists_extension(), AST_FLAG_BRIDGE_HANGUP_RUN, AST_FLAG_IN_AUTOLOOP, ast_free, ast_hangup(), ast_log(), ast_matchmore_extension(), ast_opt_end_cdr_before_h_exten, AST_PBX_ERROR, AST_PBX_INCOMPLETE, ast_set2_flag, ast_set_flag, ast_softhangup(), AST_SOFTHANGUP_APPUNLOAD, AST_SOFTHANGUP_ASYNCGOTO, AST_SOFTHANGUP_TIMEOUT, ast_spawn_extension(), ast_strlen_zero(), ast_test_flag, ast_verb, autofallthrough, ast_channel::cdr, ast_channel::cid, ast_callerid::cid_num, collect_digits(), ast_channel::context, ast_pbx::dtimeoutms, ast_channel::exten, LOG_WARNING, ast_channel::name, ast_pbx_args::no_hangup_chan, ast_channel::pbx, pbx_builtin_busy(), pbx_builtin_congestion(), pbx_builtin_getvar_helper(), pbx_builtin_raise_exception(), pbx_builtin_setvar_helper(), pbx_destroy(), ast_channel::priority, ast_pbx::rtimeoutms, set_ext_pri(), status, and ast_channel::whentohangup.

Referenced by ast_pbx_run_args(), and pbx_thread().

{
   int found = 0; /* set if we find at least one match */
   int res = 0;
   int autoloopflag;
   int error = 0;    /* set an error conditions */

   /* A little initial setup here */
   if (c->pbx) {
      ast_log(LOG_WARNING, "%s already has PBX structure??\n", c->name);
      /* XXX and now what ? */
      ast_free(c->pbx);
   }
   if (!(c->pbx = ast_calloc(1, sizeof(*c->pbx))))
      return -1;
   /* Set reasonable defaults */
   c->pbx->rtimeoutms = 10000;
   c->pbx->dtimeoutms = 5000;

   autoloopflag = ast_test_flag(c, AST_FLAG_IN_AUTOLOOP);   /* save value to restore at the end */
   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' */
      ast_verb(2, "Starting %s at %s,%s,%d failed so falling back to exten 's'\n", c->name, c->context, c->exten, c->priority);
      /* XXX the original code used the existing priority in the call to
       * ast_exists_extension(), and reset it to 1 afterwards.
       * I believe the correct thing is to set it to 1 immediately.
       */
      set_ext_pri(c, "s", 1);
      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 */
         ast_verb(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));
      }
   }
   for (;;) {
      char dst_exten[256]; /* buffer to accumulate digits */
      int pos = 0;      /* XXX should check bounds */
      int digit = 0;
      int invalid = 0;
      int timeout = 0;

      /* loop on priorities in this context/exten */
      while ( !(res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->cid.cid_num, &found,1))) {
         if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT && ast_exists_extension(c, c->context, "T", 1, c->cid.cid_num)) {
            set_ext_pri(c, "T", 0); /* 0 will become 1 with the c->priority++; at the end */
            /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
            memset(&c->whentohangup, 0, sizeof(c->whentohangup));
            c->_softhangup &= ~AST_SOFTHANGUP_TIMEOUT;
         } else if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT && ast_exists_extension(c, c->context, "e", 1, c->cid.cid_num)) {
            pbx_builtin_raise_exception(c, "ABSOLUTETIMEOUT");
            /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
            memset(&c->whentohangup, 0, sizeof(c->whentohangup));
            c->_softhangup &= ~AST_SOFTHANGUP_TIMEOUT;
         } else if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) {
            c->_softhangup = 0;
            continue;
         } else if (ast_check_hangup(c)) {
            ast_debug(1, "Extension %s, priority %d returned normally even though call was hung up\n",
               c->exten, c->priority);
            error = 1;
            break;
         }
         c->priority++;
      } /* end while  - from here on we can use 'break' to go out */
      if (found && res) {
         /* Something bad happened, or a hangup has been requested. */
         if (strchr("0123456789ABCDEF*#", res)) {
            ast_debug(1, "Oooh, got something to jump out with ('%c')!\n", res);
            pos = 0;
            dst_exten[pos++] = digit = res;
            dst_exten[pos] = '\0';
         } else if (res == AST_PBX_INCOMPLETE) {
            ast_debug(1, "Spawn extension (%s,%s,%d) exited INCOMPLETE on '%s'\n", c->context, c->exten, c->priority, c->name);
            ast_verb(2, "Spawn extension (%s, %s, %d) exited INCOMPLETE on '%s'\n", c->context, c->exten, c->priority, c->name);

            /* Don't cycle on incomplete - this will happen if the only extension that matches is our "incomplete" extension */
            if (!ast_matchmore_extension(c, c->context, c->exten, 1, c->cid.cid_num)) {
               invalid = 1;
            } else {
               ast_copy_string(dst_exten, c->exten, sizeof(dst_exten));
               digit = 1;
               pos = strlen(dst_exten);
            }
         } else {
            ast_debug(1, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
            ast_verb(2, "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);

            if ((res == AST_PBX_ERROR) && ast_exists_extension(c, c->context, "e", 1, c->cid.cid_num)) {
               /* if we are already on the 'e' exten, don't jump to it again */
               if (!strcmp(c->exten, "e")) {
                  ast_verb(2, "Spawn extension (%s, %s, %d) exited ERROR while already on 'e' exten on '%s'\n", c->context, c->exten, c->priority, c->name);
                  error = 1;
               } else {
                  pbx_builtin_raise_exception(c, "ERROR");
                  continue;
               }
            }

            if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) {
               c->_softhangup = 0;
               continue;
            } else if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT && ast_exists_extension(c, c->context, "T", 1, c->cid.cid_num)) {
               set_ext_pri(c, "T", 1);
               /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
               memset(&c->whentohangup, 0, sizeof(c->whentohangup));
               c->_softhangup &= ~AST_SOFTHANGUP_TIMEOUT;
               continue;
            } else {
               if (c->cdr)
                  ast_cdr_update(c);
               error = 1;
               break;
            }
         }
      }
      if (error)
         break;

      /*!\note
       * We get here on a failure of some kind:  non-existing extension or
       * hangup.  We have options, here.  We can either catch the failure
       * and continue, or we can drop out entirely. */

      if (invalid || !ast_exists_extension(c, c->context, c->exten, 1, c->cid.cid_num)) {
         /*!\note
          * If there is no match at priority 1, it is not a valid extension anymore.
          * Try to continue at "i" (for invalid) or "e" (for exception) or exit if
          * neither exist.
          */
         if (ast_exists_extension(c, c->context, "i", 1, c->cid.cid_num)) {
            ast_verb(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);
            set_ext_pri(c, "i", 1);
         } else if (ast_exists_extension(c, c->context, "e", 1, c->cid.cid_num)) {
            pbx_builtin_raise_exception(c, "INVALID");
         } 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);
            error = 1; /* we know what to do with it */
            break;
         }
      } 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 { /* keypress received, get more digits for a full extension */
         int waittime = 0;
         if (digit)
            waittime = c->pbx->dtimeoutms;
         else if (!autofallthrough)
            waittime = c->pbx->rtimeoutms;
         if (!waittime) {
            const char *status = pbx_builtin_getvar_helper(c, "DIALSTATUS");
            if (!status)
               status = "UNKNOWN";
            ast_verb(3, "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");
            error = 1; /* XXX disable message */
            break;   /* exit from the 'for' loop */
         }

         if (collect_digits(c, waittime, dst_exten, sizeof(dst_exten), pos))
            break;
         if (res == AST_PBX_INCOMPLETE && ast_strlen_zero(&dst_exten[pos]))
            timeout = 1;
         if (!timeout && ast_exists_extension(c, c->context, dst_exten, 1, c->cid.cid_num)) /* Prepare the next cycle */
            set_ext_pri(c, dst_exten, 1);
         else {
            /* No such extension */
            if (!timeout && !ast_strlen_zero(dst_exten)) {
               /* An invalid extension */
               if (ast_exists_extension(c, c->context, "i", 1, c->cid.cid_num)) {
                  ast_verb(3, "Invalid extension '%s' in context '%s' on %s\n", dst_exten, c->context, c->name);
                  pbx_builtin_setvar_helper(c, "INVALID_EXTEN", dst_exten);
                  set_ext_pri(c, "i", 1);
               } else if (ast_exists_extension(c, c->context, "e", 1, c->cid.cid_num)) {
                  pbx_builtin_raise_exception(c, "INVALID");
               } else {
                  ast_log(LOG_WARNING, "Invalid extension '%s', but no rule 'i' in context '%s'\n", dst_exten, c->context);
                  found = 1; /* XXX disable message */
                  break;
               }
            } else {
               /* A simple timeout */
               if (ast_exists_extension(c, c->context, "t", 1, c->cid.cid_num)) {
                  ast_verb(3, "Timeout on %s\n", c->name);
                  set_ext_pri(c, "t", 1);
               } else if (ast_exists_extension(c, c->context, "e", 1, c->cid.cid_num)) {
                  pbx_builtin_raise_exception(c, "RESPONSETIMEOUT");
               } else {
                  ast_log(LOG_WARNING, "Timeout, but no rule 't' in context '%s'\n", c->context);
                  found = 1; /* XXX disable message */
                  break;
               }
            }
         }
         if (c->cdr) {
            ast_verb(2, "CDR updated on %s\n",c->name);
            ast_cdr_update(c);
         }
      }
   }

   if (!found && !error) {
      ast_log(LOG_WARNING, "Don't know what to do with '%s'\n", c->name);
   }

   if (!args || !args->no_hangup_chan) {
      ast_softhangup(c, AST_SOFTHANGUP_APPUNLOAD);
   }

   if ((!args || !args->no_hangup_chan) &&
         !ast_test_flag(c, AST_FLAG_BRIDGE_HANGUP_RUN) &&
         ast_exists_extension(c, c->context, "h", 1, c->cid.cid_num)) {
      set_ext_pri(c, "h", 1);
      if (c->cdr && ast_opt_end_cdr_before_h_exten) {
         ast_cdr_end(c->cdr);
      }
      while ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->cid.cid_num, &found, 1)) == 0) {
         c->priority++;
      }
      if (found && res) {
         /* Something bad happened, or a hangup has been requested. */
         ast_debug(1, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
         ast_verb(2, "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
      }
   }
   ast_set2_flag(c, autoloopflag, AST_FLAG_IN_AUTOLOOP);
   ast_clear_flag(c, AST_FLAG_BRIDGE_HANGUP_RUN); /* from one round to the next, make sure this gets cleared */
   pbx_destroy(c->pbx);
   c->pbx = NULL;

   if (!args || !args->no_hangup_chan) {
      ast_hangup(c);
   }

   return 0;
}

static void __fini_acf_root

(

void

)

[static]

Definition at line 1099 of file pbx.c.

{

static void __fini_apps

(

void

)

[static]

Definition at line 1143 of file pbx.c.

01148 :
   When holding this list's lock, do _not_ do anything that will cause conlock

static void __fini_hints

(

void

)

[static]

Definition at line 1154 of file pbx.c.

{

static void __fini_switches

(

void

)

[static]

Definition at line 1145 of file pbx.c.

01148 :
   When holding this list's lock, do _not_ do anything that will cause conlock

static void __init_acf_root

(

void

)

[static]

Definition at line 1099 of file pbx.c.

{

static void __init_apps

(

void

)

[static]

Definition at line 1143 of file pbx.c.

01148 :
   When holding this list's lock, do _not_ do anything that will cause conlock

static void __init_extensionstate_buf

(

void

)

[static]

Definition at line 780 of file pbx.c.

: An extension

static void __init_hints

(

void

)

[static]

Definition at line 1154 of file pbx.c.

{

static void __init_switch_data

(

void

)

[static]

Definition at line 779 of file pbx.c.

: An extension

static void __init_switches

(

void

)

[static]

Definition at line 1145 of file pbx.c.

01148 :
   When holding this list's lock, do _not_ do anything that will cause conlock

static int _extension_match_core	(	const char *	pattern,
		const char *	data,
		enum ext_match_t	mode
	)			[static]

Definition at line 2250 of file pbx.c.

References ast_log(), E_MATCH, E_MATCH_MASK, E_MATCHMORE, LOG_NOTICE, and LOG_WARNING.

Referenced by extension_match_core().

{
   mode &= E_MATCH_MASK;   /* only consider the relevant bits */

#ifdef NEED_DEBUG_HERE
   ast_log(LOG_NOTICE,"match core: pat: '%s', dat: '%s', mode=%d\n", pattern, data, (int)mode);
#endif

   if ( (mode == E_MATCH) && (pattern[0] == '_') && (!strcasecmp(pattern,data)) ) { /* note: if this test is left out, then _x. will not match _x. !!! */
#ifdef NEED_DEBUG_HERE
      ast_log(LOG_NOTICE,"return (1) - pattern matches pattern\n");
#endif
      return 1;
   }

   if (pattern[0] != '_') { /* not a pattern, try exact or partial match */
      int ld = strlen(data), lp = strlen(pattern);

      if (lp < ld) {    /* pattern too short, cannot match */
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE,"return (0) - pattern too short, cannot match\n");
#endif
         return 0;
      }
      /* depending on the mode, accept full or partial match or both */
      if (mode == E_MATCH) {
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE,"return (!strcmp(%s,%s) when mode== E_MATCH)\n", pattern, data);
#endif
         return !strcmp(pattern, data); /* 1 on match, 0 on fail */
      }
      if (ld == 0 || !strncasecmp(pattern, data, ld)) { /* partial or full match */
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE,"return (mode(%d) == E_MATCHMORE ? lp(%d) > ld(%d) : 1)\n", mode, lp, ld);
#endif
         return (mode == E_MATCHMORE) ? lp > ld : 1; /* XXX should consider '!' and '/' ? */
      } else {
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE,"return (0) when ld(%d) > 0 && pattern(%s) != data(%s)\n", ld, pattern, data);
#endif
         return 0;
      }
   }
   pattern++; /* skip leading _ */
   /*
    * XXX below we stop at '/' which is a separator for the CID info. However we should
    * not store '/' in the pattern at all. When we insure it, we can remove the checks.
    */
   while (*data && *pattern && *pattern != '/') {
      const char *end;

      if (*data == '-') { /* skip '-' in data (just a separator) */
         data++;
         continue;
      }
      switch (toupper(*pattern)) {
      case '[':   /* a range */
         end = strchr(pattern+1, ']'); /* XXX should deal with escapes ? */
         if (end == NULL) {
            ast_log(LOG_WARNING, "Wrong usage of [] in the extension\n");
            return 0;   /* unconditional failure */
         }
         for (pattern++; pattern != end; pattern++) {
            if (pattern+2 < end && pattern[1] == '-') { /* this is a range */
               if (*data >= pattern[0] && *data <= pattern[2])
                  break;   /* match found */
               else {
                  pattern += 2; /* skip a total of 3 chars */
                  continue;
               }
            } else if (*data == pattern[0])
               break;   /* match found */
         }
         if (pattern == end) {
#ifdef NEED_DEBUG_HERE
            ast_log(LOG_NOTICE,"return (0) when pattern==end\n");
#endif
            return 0;
         }
         pattern = end; /* skip and continue */
         break;
      case 'N':
         if (*data < '2' || *data > '9') {
#ifdef NEED_DEBUG_HERE
            ast_log(LOG_NOTICE,"return (0) N is matched\n");
#endif
            return 0;
         }
         break;
      case 'X':
         if (*data < '0' || *data > '9') {
#ifdef NEED_DEBUG_HERE
            ast_log(LOG_NOTICE,"return (0) X is matched\n");
#endif
            return 0;
         }
         break;
      case 'Z':
         if (*data < '1' || *data > '9') {
#ifdef NEED_DEBUG_HERE
            ast_log(LOG_NOTICE,"return (0) Z is matched\n");
#endif
            return 0;
         }
         break;
      case '.':   /* Must match, even with more digits */
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE, "return (1) when '.' is matched\n");
#endif
         return 1;
      case '!':   /* Early match */
#ifdef NEED_DEBUG_HERE
         ast_log(LOG_NOTICE, "return (2) when '!' is matched\n");
#endif
         return 2;
      case ' ':
      case '-':   /* Ignore these in patterns */
         data--; /* compensate the final data++ */
         break;
      default:
         if (*data != *pattern) {
#ifdef NEED_DEBUG_HERE
            ast_log(LOG_NOTICE, "return (0) when *data(%c) != *pattern(%c)\n", *data, *pattern);
#endif
            return 0;
         }
      }
      data++;
      pattern++;
   }
   if (*data)        /* data longer than pattern, no match */ {
#ifdef NEED_DEBUG_HERE
      ast_log(LOG_NOTICE, "return (0) when data longer than pattern\n");
#endif
      return 0;
   }

   /*
    * match so far, but ran off the end of the data.
    * Depending on what is next, determine match or not.
    */
   if (*pattern == '\0' || *pattern == '/') {   /* exact match */
#ifdef NEED_DEBUG_HERE
      ast_log(LOG_NOTICE, "at end, return (%d) in 'exact match'\n", (mode==E_MATCHMORE) ? 0 : 1);
#endif
      return (mode == E_MATCHMORE) ? 0 : 1;  /* this is a failure for E_MATCHMORE */
   } else if (*pattern == '!')   {     /* early match */
#ifdef NEED_DEBUG_HERE
      ast_log(LOG_NOTICE, "at end, return (2) when '!' is matched\n");
#endif
      return 2;
   } else {                /* partial match */
#ifdef NEED_DEBUG_HERE
      ast_log(LOG_NOTICE, "at end, return (%d) which deps on E_MATCH\n", (mode == E_MATCH) ? 0 : 1);
#endif
      return (mode == E_MATCH) ? 0 : 1;   /* this is a failure for E_MATCH */
   }
}

static int acf_exception_read	(	struct ast_channel *	chan,
		const char *	name,
		char *	data,
		char *	buf,
		size_t	buflen
	)			[static]

Definition at line 3098 of file pbx.c.

References ast_channel_datastore_find(), ast_copy_string(), pbx_exception::context, ast_datastore::data, exception_store_info, pbx_exception::exten, pbx_exception::priority, and pbx_exception::reason.

{
   struct ast_datastore *ds = ast_channel_datastore_find(chan, &exception_store_info, NULL);
   struct pbx_exception *exception = NULL;
   if (!ds || !ds->data)
      return -1;
   exception = ds->data;
   if (!strcasecmp(data, "REASON"))
      ast_copy_string(buf, exception->reason, buflen);
   else if (!strcasecmp(data, "CONTEXT"))
      ast_copy_string(buf, exception->context, buflen);
   else if (!strncasecmp(data, "EXTEN", 5))
      ast_copy_string(buf, exception->exten, buflen);
   else if (!strcasecmp(data, "PRIORITY"))
      snprintf(buf, buflen, "%d", exception->priority);
   else
      return -1;
   return 0;
}

static int acf_retrieve_docs

(

struct ast_custom_function *

acf

)

[static]

Definition at line 3313 of file pbx.c.

References ast_custom_function::arguments, ast_free, ast_string_field_init, ast_string_field_set, ast_strlen_zero(), AST_XML_DOC, desc, ast_custom_function::desc, ast_custom_function::docsrc, ast_custom_function::name, ast_custom_function::seealso, synopsis, ast_custom_function::synopsis, and ast_custom_function::syntax.

Referenced by __ast_custom_function_register().

{
#ifdef AST_XML_DOCS
   char *tmpxml;

   /* Let's try to find it in the Documentation XML */
   if (!ast_strlen_zero(acf->desc) || !ast_strlen_zero(acf->synopsis)) {
      return 0;
   }

   if (ast_string_field_init(acf, 128)) {
      return -1;
   }

   /* load synopsis */
   tmpxml = ast_xmldoc_build_synopsis("function", acf->name);
   ast_string_field_set(acf, synopsis, tmpxml);
   ast_free(tmpxml);

   /* load description */
   tmpxml = ast_xmldoc_build_description("function", acf->name);
   ast_string_field_set(acf, desc, tmpxml);
   ast_free(tmpxml);

   /* load syntax */
   tmpxml = ast_xmldoc_build_syntax("function", acf->name);
   ast_string_field_set(acf, syntax, tmpxml);
   ast_free(tmpxml);

   /* load arguments */
   tmpxml = ast_xmldoc_build_arguments("function", acf->name);
   ast_string_field_set(acf, arguments, tmpxml);
   ast_free(tmpxml);

   /* load seealso */
   tmpxml = ast_xmldoc_build_seealso("function", acf->name);
   ast_string_field_set(acf, seealso, tmpxml);
   ast_free(tmpxml);

   acf->docsrc = AST_XML_DOC;
#endif

   return 0;
}

static struct match_char * add_exten_to_pattern_tree	(	struct ast_context *	con,
		struct ast_exten *	e1,
		int	findonly
	)			[static, read]

Definition at line 1906 of file pbx.c.

References add_pattern_node(), already_in_tree(), ast_copy_string(), ast_log(), buf, ast_exten::cidmatch, compare_char(), match_char::deleted, match_char::exten, ast_exten::exten, LOG_DEBUG, LOG_ERROR, LOG_WARNING, m1, m2, ast_exten::matchcid, match_char::next_char, and ast_context::pattern_tree.

Referenced by add_pri_lockopt(), ast_add_extension2_lockopt(), ast_context_remove_extension_callerid2(), and create_match_char_tree().

{
   struct match_char *m1 = NULL, *m2 = NULL, **m0;
   int specif;
   int already;
   int pattern = 0;
   char buf[256];
   char extenbuf[512];
   char *s1 = extenbuf;
   int l1 = strlen(e1->exten) + strlen(e1->cidmatch) + 2;


   ast_copy_string(extenbuf, e1->exten, sizeof(extenbuf));

   if (e1->matchcid &&  l1 <= sizeof(extenbuf)) {
      strcat(extenbuf, "/");
      strcat(extenbuf, e1->cidmatch);
   } else if (l1 > sizeof(extenbuf)) {
      ast_log(LOG_ERROR, "The pattern %s/%s is too big to deal with: it will be ignored! Disaster!\n", e1->exten, e1->cidmatch);
      return 0;
   }
#ifdef NEED_DEBUG
   ast_log(LOG_DEBUG, "Adding exten %s%c%s to tree\n", s1, e1->matchcid ? '/' : ' ', e1->matchcid ? e1->cidmatch : "");
#endif
   m1 = con->pattern_tree; /* each pattern starts over at the root of the pattern tree */
   m0 = &con->pattern_tree;
   already = 1;

   if ( *s1 == '_') {
      pattern = 1;
      s1++;
   }
   while (*s1) {
      if (pattern && *s1 == '[' && *(s1 - 1) != '\\') {
         char *s2 = buf;
         buf[0] = 0;
         s1++; /* get past the '[' */
         while (*s1 != ']' && *(s1 - 1) != '\\') {
            if (*s1 == '\\') {
               if (*(s1 + 1) == ']') {
                  *s2++ = ']';
                  s1 += 2;
               } else if (*(s1 + 1) == '\\') {
                  *s2++ = '\\';
                  s1 += 2;
               } else if (*(s1 + 1) == '-') {
                  *s2++ = '-';
                  s1 += 2;
               } else if (*(s1 + 1) == '[') {
                  *s2++ = '[';
                  s1 += 2;
               }
            } else if (*s1 == '-') { /* remember to add some error checking to all this! */
               char s3 = *(s1 - 1);
               char s4 = *(s1 + 1);
               for (s3++; s3 <= s4; s3++) {
                  *s2++ = s3;
               }
               s1 += 2;
            } else if (*s1 == '\0') {
               ast_log(LOG_WARNING, "A matching ']' was not found for '[' in pattern string '%s'\n", extenbuf);
               break;
            } else {
               *s2++ = *s1++;
            }
         }
         *s2 = 0; /* null terminate the exploded range */
         /* sort the characters */

         specif = strlen(buf);
         qsort(buf, specif, 1, compare_char);
         specif <<= 8;
         specif += buf[0];
      } else {
         if (*s1 == '\\') {
            s1++;
            buf[0] = *s1;
         } else {
            if (pattern) {
               if (*s1 == 'n') { /* make sure n,x,z patterns are canonicalized to N,X,Z */
                  *s1 = 'N';
               } else if (*s1 == 'x') {
                  *s1 = 'X';
               } else if (*s1 == 'z') {
                  *s1 = 'Z';
               }
            }
            buf[0] = *s1;
         }
         buf[1] = 0;
         specif = 1;
      }
      m2 = 0;
      if (already && (m2 = already_in_tree(m1, buf, pattern)) && m2->next_char) {
         if (!(*(s1 + 1))) {  /* if this is the end of the pattern, but not the end of the tree, then mark this node with the exten...
                        a shorter pattern might win if the longer one doesn't match */
            if (m2->exten) {
               ast_log(LOG_WARNING, "Found duplicate exten. Had %s found %s\n", m2->exten->exten, e1->exten);
            }
            m2->exten = e1;
            m2->deleted = 0;
         }
         m1 = m2->next_char; /* m1 points to the node to compare against */
         m0 = &m2->next_char; /* m0 points to the ptr that points to m1 */
      } else { /* not already OR not m2 OR nor m2->next_char */
         if (m2) {
            if (findonly) {
               return m2;
            }
            m1 = m2; /* while m0 stays the same */
         } else {
            if (findonly) {
               return m1;
            }
            if (!(m1 = add_pattern_node(con, m1, buf, pattern, already,specif, m0))) { /* m1 is the node just added */
               return NULL;
            }
            m0 = &m1->next_char;
         }
         if (!(*(s1 + 1))) {
            if (m2 && m2->exten) {
               ast_log(LOG_WARNING, "Found duplicate exten. Had %s found %s\n", m2->exten->exten, e1->exten);
            }
            m1->deleted = 0;
            m1->exten = e1;
         }

         /* The 'already' variable is a mini-optimization designed to make it so that we
          * don't have to call already_in_tree when we know it will return false.
          */
         already = 0;
      }
      s1++; /* advance to next char */
   }
   return m1;
}

static struct match_char * add_pattern_node	(	struct ast_context *	con,
		struct match_char *	current,
		char *	pattern,
		int	is_pattern,
		int	already,
		int	specificity,
		struct match_char **	parent
	)			[static, read]

Definition at line 1864 of file pbx.c.

References ast_calloc, insert_in_next_chars_alt_char_list(), match_char::is_pattern, match_char::next_char, ast_context::pattern_tree, match_char::specificity, and match_char::x.

Referenced by add_exten_to_pattern_tree().

{
   struct match_char *m;
   
   if (!(m = ast_calloc(1, sizeof(*m) + strlen(pattern)))) {
      return NULL;
   }

   /* strcpy is safe here since we know its size and have allocated
    * just enough space for when we allocated m
    */
   strcpy(m->x, pattern);

   /* the specificity scores are the same as used in the old
      pattern matcher. */
   m->is_pattern = is_pattern;
   if (specificity == 1 && is_pattern && pattern[0] == 'N')
      m->specificity = 0x0802;
   else if (specificity == 1 && is_pattern && pattern[0] == 'Z')
      m->specificity = 0x0901;
   else if (specificity == 1 && is_pattern && pattern[0] == 'X')
      m->specificity = 0x0a00;
   else if (specificity == 1 && is_pattern && pattern[0] == '.')
      m->specificity = 0x10000;
   else if (specificity == 1 && is_pattern && pattern[0] == '!')
      m->specificity = 0x20000;
   else
      m->specificity = specificity;

   if (!con->pattern_tree) {
      insert_in_next_chars_alt_char_list(&con->pattern_tree, m);
   } else {
      if (already) { /* switch to the new regime (traversing vs appending)*/
         insert_in_next_chars_alt_char_list(nextcharptr, m);
      } else {
         insert_in_next_chars_alt_char_list(&current->next_char, m);
      }
   }

   return m;
}

static int add_pri	(	struct ast_context *	con,
		struct ast_exten *	tmp,
		struct ast_exten *	el,
		struct ast_exten *	e,
		int	replace
	)			[static]

add the extension in the priority chain.

Return values:

	0	on success.
	-1	on failure.

Definition at line 7727 of file pbx.c.

References add_pri_lockopt().

Referenced by ast_add_extension2_lockopt().

{
   return add_pri_lockopt(con, tmp, el, e, replace, 1);
}

static int add_pri_lockopt	(	struct ast_context *	con,
		struct ast_exten *	tmp,
		struct ast_exten *	el,
		struct ast_exten *	e,
		int	replace,
		int	lockhints
	)			[static]

add the extension in the priority chain.

Return values:

	0	on success.
	-1	on failure.

Definition at line 7738 of file pbx.c.

References add_exten_to_pattern_tree(), ast_add_hint(), ast_add_hint_nolock(), ast_change_hint(), ast_free, ast_hashtab_insert_safe(), ast_hashtab_remove_object_via_lookup(), ast_log(), ast_exten::data, ast_exten::datad, match_char::exten, ast_exten::exten, ast_exten::label, LOG_ERROR, LOG_WARNING, ast_context::name, ast_exten::next, ast_exten::peer, ast_exten::peer_label_table, ast_exten::peer_table, ast_exten::priority, PRIORITY_HINT, ast_context::root, ast_context::root_table, and match_char::x.

Referenced by add_pri().

{
   struct ast_exten *ep;
   struct ast_exten *eh=e;

   for (ep = NULL; e ; ep = e, e = e->peer) {
      if (e->priority >= tmp->priority)
         break;
   }
   if (!e) {   /* go at the end, and ep is surely set because the list is not empty */
      ast_hashtab_insert_safe(eh->peer_table, tmp);

      if (tmp->label) {
         ast_hashtab_insert_safe(eh->peer_label_table, tmp);
      }
      ep->peer = tmp;
      return 0;   /* success */
   }
   if (e->priority == tmp->priority) {
      /* Can't have something exactly the same.  Is this a
         replacement?  If so, replace, otherwise, bonk. */
      if (!replace) {
         ast_log(LOG_WARNING, "Unable to register extension '%s', priority %d in '%s', already in use\n", tmp->exten, tmp->priority, con->name);
         if (tmp->datad) {
            tmp->datad(tmp->data);
            /* if you free this, null it out */
            tmp->data = NULL;
         }

         ast_free(tmp);
         return -1;
      }
      /* we are replacing e, so copy the link fields and then update
       * whoever pointed to e to point to us
       */
      tmp->next = e->next; /* not meaningful if we are not first in the peer list */
      tmp->peer = e->peer; /* always meaningful */
      if (ep)  {     /* We're in the peer list, just insert ourselves */
         ast_hashtab_remove_object_via_lookup(eh->peer_table,e);

         if (e->label) {
            ast_hashtab_remove_object_via_lookup(eh->peer_label_table,e);
         }

         ast_hashtab_insert_safe(eh->peer_table,tmp);
         if (tmp->label) {
            ast_hashtab_insert_safe(eh->peer_label_table,tmp);
         }

         ep->peer = tmp;
      } else if (el) {     /* We're the first extension. Take over e's functions */
         struct match_char *x = add_exten_to_pattern_tree(con, e, 1);
         tmp->peer_table = e->peer_table;
         tmp->peer_label_table = e->peer_label_table;
         ast_hashtab_remove_object_via_lookup(tmp->peer_table,e);
         ast_hashtab_insert_safe(tmp->peer_table,tmp);
         if (e->label) {
            ast_hashtab_remove_object_via_lookup(tmp->peer_label_table, e);
         }
         if (tmp->label) {
            ast_hashtab_insert_safe(tmp->peer_label_table, tmp);
         }

         ast_hashtab_remove_object_via_lookup(con->root_table, e);
         ast_hashtab_insert_safe(con->root_table, tmp);
         el->next = tmp;
         /* The pattern trie points to this exten; replace the pointer,
            and all will be well */
         if (x) { /* if the trie isn't formed yet, don't sweat this */
            if (x->exten) { /* this test for safety purposes */
               x->exten = tmp; /* replace what would become a bad pointer */
            } else {
               ast_log(LOG_ERROR,"Trying to delete an exten from a context, but the pattern tree node returned isn't an extension\n");
            }
         }
      } else {       /* We're the very first extension.  */
         struct match_char *x = add_exten_to_pattern_tree(con, e, 1);
         ast_hashtab_remove_object_via_lookup(con->root_table, e);
         ast_hashtab_insert_safe(con->root_table, tmp);
         tmp->peer_table = e->peer_table;
         tmp->peer_label_table = e->peer_label_table;
         ast_hashtab_remove_object_via_lookup(tmp->peer_table, e);
         ast_hashtab_insert_safe(tmp->peer_table, tmp);
         if (e->label) {
            ast_hashtab_remove_object_via_lookup(tmp->peer_label_table, e);
         }
         if (tmp->label) {
            ast_hashtab_insert_safe(tmp->peer_label_table, tmp);
         }

         ast_hashtab_remove_object_via_lookup(con->root_table, e);
         ast_hashtab_insert_safe(con->root_table, tmp);
         con->root = tmp;
         /* The pattern trie points to this exten; replace the pointer,
            and all will be well */
         if (x) { /* if the trie isn't formed yet; no problem */
            if (x->exten) { /* this test for safety purposes */
               x->exten = tmp; /* replace what would become a bad pointer */
            } else {
               ast_log(LOG_ERROR,"Trying to delete an exten from a context, but the pattern tree node returned isn't an extension\n");
            }
         }
      }
      if (tmp->priority == PRIORITY_HINT)
         ast_change_hint(e,tmp);
      /* Destroy the old one */
      if (e->datad)
         e->datad(e->data);
      ast_free(e);
   } else { /* Slip ourselves in just before e */
      tmp->peer = e;
      tmp->next = e->next; /* extension chain, or NULL if e is not the first extension */
      if (ep) {         /* Easy enough, we're just in the peer list */
         if (tmp->label) {
            ast_hashtab_insert_safe(eh->peer_label_table, tmp);
         }
         ast_hashtab_insert_safe(eh->peer_table, tmp);
         ep->peer = tmp;
      } else {       /* we are the first in some peer list, so link in the ext list */
         tmp->peer_table = e->peer_table;
         tmp->peer_label_table = e->peer_label_table;
         e->peer_table = 0;
         e->peer_label_table = 0;
         ast_hashtab_insert_safe(tmp->peer_table, tmp);
         if (tmp->label) {
            ast_hashtab_insert_safe(tmp->peer_label_table, tmp);
         }
         ast_hashtab_remove_object_via_lookup(con->root_table, e);
         ast_hashtab_insert_safe(con->root_table, tmp);
         if (el)
            el->next = tmp;   /* in the middle... */
         else
            con->root = tmp; /* ... or at the head */
         e->next = NULL;   /* e is no more at the head, so e->next must be reset */
      }
      /* And immediately return success. */
      if (tmp->priority == PRIORITY_HINT) {
         if (lockhints) {
            ast_add_hint(tmp);
         } else {
            ast_add_hint_nolock(tmp);
         }
      }
   }
   return 0;
}

static struct match_char * already_in_tree	(	struct match_char *	current,
		char *	pat,
		int	is_pattern
	)			[static, read]

Definition at line 1809 of file pbx.c.

References match_char::alt_char, match_char::is_pattern, and match_char::x.

Referenced by add_exten_to_pattern_tree().

{
   struct match_char *t;

   if (!current) {
      return 0;
   }

   for (t = current; t; t = t->alt_char) {
      if (is_pattern == t->is_pattern && !strcmp(pat, t->x)) {/* uh, we may want to sort exploded [] contents to make matching easy */
         return t;
      }
   }

   return 0;
}

int ast_active_calls

(

void

)

Retrieve the number of active calls.

Definition at line 4934 of file pbx.c.

References countcalls.

Referenced by ast_var_Config(), handle_chanlist(), handle_showcalls(), and sysinfo_helper().

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

Add and extension to an extension context.

Parameters:

	context	context to add the extension to
	replace
	extension	extension to add
	priority	priority level of extension addition
	label	extension label
	callerid	pattern to match CallerID, or NULL to match any CallerID
	application	application to run on the extension with that priority level
	data	data to pass to the application
	datad
	registrar	who registered the extension

Return values:

	0	success
	-1	failure

Definition at line 7590 of file pbx.c.

References ast_add_extension2(), ast_unlock_contexts(), and find_context_locked().

Referenced by ast_extension_state_add(), handle_cli_dialplan_add_extension(), park_add_hints(), register_exten(), register_peer_exten(), and RegisterExtension().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) {
      ret = ast_add_extension2(c, replace, extension, priority, label, callerid,
         application, data, datad, registrar);
      ast_unlock_contexts();
   }

   return ret;
}

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
	)

Main interface to add extensions to the list for out context.

Add an extension to an extension context, this time with an ast_context *.

We sort extensions in order of matching preference, so that we can stop the search as soon as we find a suitable match. This ordering also takes care of wildcards such as '.' (meaning "one or more of any character") and '!' (which is 'earlymatch', meaning "zero or more of any character" but also impacts the return value from CANMATCH and EARLYMATCH.

The extension match rules defined in the devmeeting 2006.05.05 are quite simple: WE SELECT THE LONGEST MATCH. In detail, "longest" means the number of matched characters in the extension. In case of ties (e.g. _XXX and 333) in the length of a pattern, we give priority to entries with the smallest cardinality (e.g, [5-9] comes before [2-8] before the former has only 5 elements, while the latter has 7, etc. In case of same cardinality, the first element in the range counts. If we still have a tie, any final '!' will make this as a possibly less specific pattern.

EBUSY - can't lock EEXIST - extension with the same priority exist and no replace is set

Definition at line 7911 of file pbx.c.

References ast_add_extension2_lockopt().

Referenced by add_extensions(), ast_add_extension(), build_parkinglot(), context_merge(), load_config(), load_module(), manage_parkinglot(), park_call_full(), pbx_load_config(), pbx_load_users(), sla_build_station(), and sla_build_trunk().

{
   return ast_add_extension2_lockopt(con, replace, extension, priority, label, callerid, application, data, datad, registrar, 1, 1);
}

static int ast_add_extension2_lockopt	(	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,
		int	lockconts,
		int	lockhints
	)			[static]

Does all the work of ast_add_extension2, but adds two args, to determine if context and hint locking should be done. In merge_and_delete, we need to do this without locking, as the locks are already held.

Definition at line 7924 of file pbx.c.

References add_exten_to_pattern_tree(), add_pri(), ast_exten::app, ast_add_hint(), ast_add_hint_nolock(), ast_calloc, ast_channel_release(), ast_copy_string(), ast_debug, ast_dummy_channel_alloc(), ast_hashtab_create(), ast_hashtab_insert_safe(), ast_hashtab_lookup(), ast_hashtab_newsize_java(), ast_hashtab_resize_java(), ast_log(), ast_strlen_zero(), ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_exten::cidmatch, ast_channel::context, ast_exten::data, ast_exten::datad, el, errno, ext_cmp(), ext_strncpy(), ast_exten::exten, ast_channel::exten, hashtab_compare_exten_labels(), hashtab_compare_exten_numbers(), hashtab_compare_extens(), hashtab_hash_extens(), hashtab_hash_labels(), hashtab_hash_priority(), ast_exten::label, LOG_ERROR, ast_exten::matchcid, ast_context::name, ast_exten::next, option_debug, ast_exten::parent, ast_context::pattern_tree, pbx_substitute_variables_helper(), ast_exten::peer_label_table, ast_exten::peer_table, ast_exten::priority, PRIORITY_HINT, ast_exten::registrar, ast_context::root, ast_context::root_table, ast_exten::stuff, and VAR_BUF_SIZE.

Referenced by ast_add_extension2(), and ast_add_extension_nolock().

{
   /*
    * Sort extensions (or patterns) according to the rules indicated above.
    * These are implemented by the function ext_cmp()).
    * All priorities for the same ext/pattern/cid are kept in a list,
    * using the 'peer' field  as a link field..
    */
   struct ast_exten *tmp, *tmp2, *e, *el = NULL;
   int res;
   int length;
   char *p;
   char expand_buf[VAR_BUF_SIZE];
   struct ast_exten dummy_exten = {0};
   char dummy_name[1024];

   if (ast_strlen_zero(extension)) {
      ast_log(LOG_ERROR,"You have to be kidding-- add exten '' to context %s? Figure out a name and call me back. Action ignored.\n",
            con->name);
      return -1;
   }

   /* If we are adding a hint evalulate in variables and global variables */
   if (priority == PRIORITY_HINT && strstr(application, "${") && !strstr(extension, "_")) {
      struct ast_channel *c = ast_dummy_channel_alloc();
      ast_copy_string(c->exten, extension, sizeof(c->exten));
      ast_copy_string(c->context, con->name, sizeof(c->context));

      pbx_substitute_variables_helper(c, application, expand_buf, sizeof(expand_buf));
      application = expand_buf;
      ast_channel_release(c);
   }

   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 ++;  /* just the '\0' */

   /* Be optimistic:  Build the extension structure first */
   if (!(tmp = ast_calloc(1, length)))
      return -1;

   if (ast_strlen_zero(label)) /* let's turn empty labels to a null ptr */
      label = 0;

   /* use p as dst in assignments, as the fields are const char * */
   p = tmp->stuff;
   if (label) {
      tmp->label = p;
      strcpy(p, label);
      p += strlen(label) + 1;
   }
   tmp->exten = p;
   p += ext_strncpy(p, extension, strlen(extension) + 1) + 1;
   tmp->priority = priority;
   tmp->cidmatch = p;   /* but use p for assignments below */
   if (!ast_strlen_zero(callerid)) {
      p += ext_strncpy(p, callerid, strlen(callerid) + 1) + 1;
      tmp->matchcid = 1;
   } else {
      *p++ = '\0';
      tmp->matchcid = 0;
   }
   tmp->app = p;
   strcpy(p, application);
   tmp->parent = con;
   tmp->data = data;
   tmp->datad = datad;
   tmp->registrar = registrar;

   if (lockconts) {
      ast_wrlock_context(con);
   }

   if (con->pattern_tree) { /* usually, on initial load, the pattern_tree isn't formed until the first find_exten; so if we are adding
                        an extension, and the trie exists, then we need to incrementally add this pattern to it. */
      ast_copy_string(dummy_name, extension, sizeof(dummy_name));
      dummy_exten.exten = dummy_name;
      dummy_exten.matchcid = 0;
      dummy_exten.cidmatch = 0;
      tmp2 = ast_hashtab_lookup(con->root_table, &dummy_exten);
      if (!tmp2) {
         /* hmmm, not in the trie; */
         add_exten_to_pattern_tree(con, tmp, 0);
         ast_hashtab_insert_safe(con->root_table, tmp); /* for the sake of completeness */
      }
   }
   res = 0; /* some compilers will think it is uninitialized otherwise */
   for (e = con->root; e; el = e, e = e->next) {   /* scan the extension list */
      res = ext_cmp(e->exten, tmp->exten);
      if (res == 0) { /* extension match, now look at cidmatch */
         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 = ext_cmp(e->cidmatch, tmp->cidmatch);
      }
      if (res >= 0)
         break;
   }
   if (e && res == 0) { /* exact match, insert in the pri chain */
      res = add_pri(con, tmp, el, e, replace);
      if (lockconts) {
         ast_unlock_context(con);
      }
      if (res < 0) {
         errno = EEXIST;   /* XXX do we care ? */
         return 0; /* XXX should we return -1 maybe ? */
      }
   } else {
      /*
       * not an exact match, this is the first entry with this pattern,
       * so insert in the main list right before 'e' (if any)
       */
      tmp->next = e;
      if (el) {  /* there is another exten already in this context */
         el->next = tmp;
         tmp->peer_table = ast_hashtab_create(13,
                     hashtab_compare_exten_numbers,
                     ast_hashtab_resize_java,
                     ast_hashtab_newsize_java,
                     hashtab_hash_priority,
                     0);
         tmp->peer_label_table = ast_hashtab_create(7,
                        hashtab_compare_exten_labels,
                        ast_hashtab_resize_java,
                        ast_hashtab_newsize_java,
                        hashtab_hash_labels,
                        0);
         if (label) {
            ast_hashtab_insert_safe(tmp->peer_label_table, tmp);
         }
         ast_hashtab_insert_safe(tmp->peer_table, tmp);
      } else {  /* this is the first exten in this context */
         if (!con->root_table)
            con->root_table = ast_hashtab_create(27,
                                       hashtab_compare_extens,
                                       ast_hashtab_resize_java,
                                       ast_hashtab_newsize_java,
                                       hashtab_hash_extens,
                                       0);
         con->root = tmp;
         con->root->peer_table = ast_hashtab_create(13,
                        hashtab_compare_exten_numbers,
                        ast_hashtab_resize_java,
                        ast_hashtab_newsize_java,
                        hashtab_hash_priority,
                        0);
         con->root->peer_label_table = ast_hashtab_create(7,
                           hashtab_compare_exten_labels,
                           ast_hashtab_resize_java,
                           ast_hashtab_newsize_java,
                           hashtab_hash_labels,
                           0);
         if (label) {
            ast_hashtab_insert_safe(con->root->peer_label_table, tmp);
         }
         ast_hashtab_insert_safe(con->root->peer_table, tmp);

      }
      ast_hashtab_insert_safe(con->root_table, tmp);
      if (lockconts) {
         ast_unlock_context(con);
      }
      if (tmp->priority == PRIORITY_HINT) {
         if (lockhints) {
            ast_add_hint(tmp);
         } else {
            ast_add_hint_nolock(tmp);
         }
      }
   }
   if (option_debug) {
      if (tmp->matchcid) {
         ast_debug(1, "Added extension '%s' priority %d (CID match '%s') to %s (%p)\n",
                 tmp->exten, tmp->priority, tmp->cidmatch, con->name, con);
      } else {
         ast_debug(1, "Added extension '%s' priority %d to %s (%p)\n",
                 tmp->exten, tmp->priority, con->name, con);
      }
   }

   if (tmp->matchcid) {
      ast_verb(3, "Added extension '%s' priority %d (CID match '%s') to %s (%p)\n",
             tmp->exten, tmp->priority, tmp->cidmatch, con->name, con);
   } else {
      ast_verb(3, "Added extension '%s' priority %d to %s (%p)\n",
             tmp->exten, tmp->priority, con->name, con);
   }

   return 0;
}

static int ast_add_extension_nolock	(	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
	)			[static]

Definition at line 7571 of file pbx.c.

References ast_add_extension2_lockopt(), and find_context().

Referenced by ast_merge_contexts_and_delete().

{
   int ret = -1;
   struct ast_context *c = find_context(context);

   if (c) {
      ret = ast_add_extension2_lockopt(c, replace, extension, priority, label, callerid,
         application, data, datad, registrar, 0, 0);
   }

   return ret;
}

static int ast_add_hint

(

struct ast_exten *

e

)

[static]

Add hint to hint list, check initial extension state.

Definition at line 4376 of file pbx.c.

References ast_add_hint_nolock(), AST_RWLIST_UNLOCK, and AST_RWLIST_WRLOCK.

Referenced by add_pri_lockopt(), and ast_add_extension2_lockopt().

{
   int ret;

   AST_RWLIST_WRLOCK(&hints);
   ret = ast_add_hint_nolock(e);
   AST_RWLIST_UNLOCK(&hints);

   return ret;
}

static int ast_add_hint_nolock

(

struct ast_exten *

e

)

[static]

Add hint to hint list, check initial extension state; the hints had better be WRLOCKED already!

Definition at line 4347 of file pbx.c.

References ast_calloc, ast_debug, ast_extension_state2(), ast_get_extension_app(), ast_get_extension_name(), AST_RWLIST_INSERT_HEAD, AST_RWLIST_TRAVERSE, ast_hint::exten, and ast_hint::laststate.

Referenced by add_pri_lockopt(), ast_add_extension2_lockopt(), and ast_add_hint().

{
   struct ast_hint *hint;

   if (!e)
      return -1;

   /* Search if hint exists, do nothing */
   AST_RWLIST_TRAVERSE(&hints, hint, list) {
      if (hint->exten == e) {
         ast_debug(2, "HINTS: Not re-adding existing hint %s: %s\n", ast_get_extension_name(e), ast_get_extension_app(e));
         return -1;
      }
   }

   ast_debug(2, "HINTS: Adding hint %s: %s\n", ast_get_extension_name(e), ast_get_extension_app(e));

   if (!(hint = ast_calloc(1, sizeof(*hint)))) {
      return -1;
   }
   /* Initialize and insert new item at the top */
   hint->exten = e;
   hint->laststate = ast_extension_state2(e);
   AST_RWLIST_INSERT_HEAD(&hints, hint, list);

   return 0;
}

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

Set the channel to next execute the specified dialplan location.

See also:

ast_async_parseable_goto, ast_async_goto_if_exists

Definition at line 7629 of file pbx.c.

References ast_channel::_state, ast_channel::accountcode, ast_channel::amaflags, ast_cdr_discard(), ast_cdr_dup(), ast_channel_alloc, ast_channel_lock, ast_channel_masquerade(), ast_channel_unlock, ast_do_masquerade(), ast_explicit_goto(), ast_hangup(), ast_log(), ast_pbx_start(), AST_SOFTHANGUP_ASYNCGOTO, ast_softhangup_nolock(), ast_channel::cdr, ast_channel::context, ast_channel::exten, ast_channel::linkedid, LOG_WARNING, ast_channel::name, ast_channel::pbx, ast_channel::readformat, S_OR, and ast_channel::writeformat.

Referenced by __ast_goto_if_exists(), action_redirect(), ast_async_goto_by_name(), builtin_blindtransfer(), change_t38_state(), console_transfer(), dahdi_handle_dtmfup(), handle_request_bye(), handle_request_refer(), my_handle_dtmfup(), pbx_parseable_goto(), process_ast_dsp(), and socket_process().

{
   int res = 0;

   ast_channel_lock(chan);

   if (chan->pbx) { /* This channel is currently in the PBX */
      ast_explicit_goto(chan, context, exten, priority + 1);
      ast_softhangup_nolock(chan, AST_SOFTHANGUP_ASYNCGOTO);
   } else {
      /* In order to do it when the channel doesn't really exist within
         the PBX, we have to make a new channel, masquerade, and start the PBX
         at the new location */
      struct ast_channel *tmpchan = ast_channel_alloc(0, chan->_state, 0, 0, chan->accountcode, chan->exten, chan->context, chan->linkedid, chan->amaflags, "AsyncGoto/%s", chan->name);
      if (!tmpchan) {
         res = -1;
      } else {
         if (chan->cdr) {
            ast_cdr_discard(tmpchan->cdr);
            tmpchan->cdr = ast_cdr_dup(chan->cdr);  /* share the love */
         }
         /* Make formats okay */
         tmpchan->readformat = chan->readformat;
         tmpchan->writeformat = chan->writeformat;
         /* Setup proper location */
         ast_explicit_goto(tmpchan,
            S_OR(context, chan->context), S_OR(exten, chan->exten), priority);

         /* Masquerade into temp channel */
         if (ast_channel_masquerade(tmpchan, chan)) {
            /* Failed to set up the masquerade.  It's probably chan_local
             * in the middle of optimizing itself out.  Sad. :( */
            ast_hangup(tmpchan);
            tmpchan = NULL;
            res = -1;
         } else {
            /* it may appear odd to unlock chan here since the masquerade is on
             * tmpchan, but no channel locks should be held when doing a masquerade
             * since a masquerade requires a lock on the channels ao2 container. */
            ast_channel_unlock(chan);
            ast_do_masquerade(tmpchan);
            ast_channel_lock(chan);
            /* 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;
            }
         }
      }
   }
   ast_channel_unlock(chan);
   return res;
}

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

Set the channel to next execute the specified dialplan location.

Definition at line 7684 of file pbx.c.

References ast_async_goto(), ast_channel_get_by_name(), and ast_channel_unref.

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

   if ((chan = ast_channel_get_by_name(channame))) {
      res = ast_async_goto(chan, context, exten, priority);
      chan = ast_channel_unref(chan);
   }

   return res;
}

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

Note:

This function will handle locking the channel as needed.

Definition at line 9847 of file pbx.c.

References __ast_goto_if_exists().

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

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

Note:

This function will handle locking the channel as needed.

Definition at line 9910 of file pbx.c.

References pbx_parseable_goto().

Referenced by asyncgoto_exec(), and handle_redirect().

{
   return pbx_parseable_goto(chan, goto_string, 1);
}

int ast_build_timing	(	struct ast_timing *	i,
		const char *	info
	)

Construct a timing bitmap, for use in time-based conditionals.

Parameters:

	i	Pointer to an ast_timing structure.
	info	Standard string containing a timerange, weekday range, monthday range, and month range, as well as an optional timezone.

Return values:

Returns

1 on success or 0 on failure.

Definition at line 7224 of file pbx.c.

References ast_strdup, ast_strdupa, ast_strlen_zero(), ast_timing::daymask, days, ast_timing::dowmask, get_range(), get_timerange(), ast_timing::monthmask, months, strsep(), and ast_timing::timezone.

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

{
   char *info_save, *info;
   int j, num_fields, last_sep = -1;

   /* 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 */
   info_save = info = ast_strdupa(info_in);

   /* count the number of fields in the timespec */
   for (j = 0, num_fields = 1; info[j] != '\0'; j++) {
      if (info[j] == ',') {
         last_sep = j;
         num_fields++;
      }
   }

   /* save the timezone, if it is specified */
   if (num_fields == 5) {
      i->timezone = ast_strdup(info + last_sep + 1);
   } else {
      i->timezone = NULL;
   }

   /* Assume everything except time */
   i->monthmask = 0xfff;   /* 12 bits */
   i->daymask = 0x7fffffffU; /* 31 bits */
   i->dowmask = 0x7f; /* 7 bits */
   /* on each call, use strsep() to move info to the next argument */
   get_timerange(i, strsep(&info, "|,"));
   if (info)
      i->dowmask = get_range(strsep(&info, "|,"), 7, days, "day of week");
   if (info)
      i->daymask = get_range(strsep(&info, "|,"), 31, NULL, "day");
   if (info)
      i->monthmask = get_range(strsep(&info, "|,"), 12, months, "month");
   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

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

Returns:

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

References E_CANMATCH, and pbx_extension_helper().

Referenced by __analog_ss_thread(), analog_ss_thread(), background_detect_exec(), cb_events(), do_immediate_setup(), dp_lookup(), dundi_lookup_local(), get_also_info(), get_destination(), handle_link_data(), handle_link_phone_dtmf(), leave_voicemail(), local_dtmf_helper(), loopback_canmatch(), mgcp_ss(), phone_check_exception(), skinny_ss(), and valid_exit().

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

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

Change hint for an extension.

Definition at line 4388 of file pbx.c.

References AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, and ast_hint::exten.

Referenced by add_pri_lockopt().

{
   struct ast_hint *hint;
   int res = -1;

   AST_RWLIST_WRLOCK(&hints);
   AST_RWLIST_TRAVERSE(&hints, hint, list) {
      if (hint->exten == oe) {
         hint->exten = ne;
         res = 0;
         break;
      }
   }
   AST_RWLIST_UNLOCK(&hints);

   return res;
}

int ast_check_timing

(

const struct ast_timing *

i

)

Evaluate a pre-constructed bitmap as to whether the current time falls within the range specified.

Parameters:

i

Pointer to an ast_timing structure.

Return values:

Returns

1, if the time matches or 0, if the current time falls outside of the specified range.

Definition at line 7267 of file pbx.c.

References ast_localtime(), ast_log(), ast_tvnow(), ast_timing::daymask, ast_timing::dowmask, LOG_WARNING, ast_timing::minmask, ast_timing::monthmask, ast_timing::timezone, ast_tm::tm_hour, ast_tm::tm_mday, ast_tm::tm_min, ast_tm::tm_mon, and ast_tm::tm_wday.

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

{
   struct ast_tm tm;
   struct timeval now = ast_tvnow();

   ast_localtime(&now, &tm, i->timezone);

   /* 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 * 2 + (tm.tm_min >= 30 ? 1 : 0)] & (1 << (tm.tm_min >= 30 ? tm.tm_min - 30 : tm.tm_min))))
      return 0;

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

char* ast_complete_applications	(	const char *	line,
		const char *	word,
		int	state
	)

Command completion for the list of installed applications.

This can be called from a CLI command completion function that wants to complete from the list of available applications.

Definition at line 9915 of file pbx.c.

References AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_strdup, and ast_app::name.

Referenced by handle_orig(), and handle_show_application().

{
   struct ast_app *app = NULL;
   int which = 0;
   char *ret = NULL;
   size_t wordlen = strlen(word);

   AST_RWLIST_RDLOCK(&apps);
   AST_RWLIST_TRAVERSE(&apps, app, list) {
      if (!strncasecmp(word, app->name, wordlen) && ++which > state) {
         ret = ast_strdup(app->name);
         break;
      }
   }
   AST_RWLIST_UNLOCK(&apps);

   return ret;
}

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.

Return values:

	0	on success
	-1	on failure

Definition at line 7502 of file pbx.c.

References ast_context_add_ignorepat2(), ast_unlock_contexts(), and find_context_locked().

Referenced by handle_cli_dialplan_add_ignorepat().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) {
      ret = ast_context_add_ignorepat2(c, value, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

Definition at line 7514 of file pbx.c.

References ast_calloc, ast_unlock_context(), ast_wrlock_context(), errno, ast_context::ignorepats, ast_ignorepat::next, ast_ignorepat::pattern, and ast_ignorepat::registrar.

Referenced by ast_compile_ael2(), ast_context_add_ignorepat(), context_merge_incls_swits_igps_other_registrars(), and pbx_load_config().

{
   struct ast_ignorepat *ignorepat, *ignorepatc, *ignorepatl = NULL;
   int length;
   char *pattern;
   length = sizeof(struct ast_ignorepat);
   length += strlen(value) + 1;
   if (!(ignorepat = ast_calloc(1, length)))
      return -1;
   /* The cast to char * is because we need to write the initial value.
    * The field is not supposed to be modified otherwise.  Also, gcc 4.2
    * sees the cast as dereferencing a type-punned pointer and warns about
    * it.  This is the workaround (we're telling gcc, yes, that's really
    * what we wanted to do).
    */
   pattern = (char *) ignorepat->pattern;
   strcpy(pattern, value);
   ignorepat->next = NULL;
   ignorepat->registrar = registrar;
   ast_wrlock_context(con);
   for (ignorepatc = con->ignorepats; ignorepatc; ignorepatc = ignorepatc->next) {
      ignorepatl = ignorepatc;
      if (!strcasecmp(ignorepatc->pattern, value)) {
         /* Already there */
         ast_unlock_context(con);
         errno = EEXIST;
         return -1;
      }
   }
   if (ignorepatl)
      ignorepatl->next = ignorepat;
   else
      con->ignorepats = ignorepat;
   ast_unlock_context(con);
   return 0;

}

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

Add a context 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

Return values:

	0	on success
	-1	on error

Definition at line 7053 of file pbx.c.

References ast_context_add_include2(), ast_unlock_contexts(), and find_context_locked().

Referenced by handle_cli_dialplan_add_include().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) {
      ret = ast_context_add_include2(c, include, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

Add a context 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

Return values:

	0	on success
	-1	on failure

Definition at line 7317 of file pbx.c.

References ast_build_timing(), ast_calloc, ast_destroy_timing(), ast_free, ast_get_context_name(), ast_unlock_context(), ast_verb, ast_wrlock_context(), errno, ast_include::hastime, ast_context::includes, ast_include::name, ast_include::next, ast_include::registrar, ast_include::rname, ast_include::stuff, and ast_include::timing.

Referenced by ast_compile_ael2(), ast_context_add_include(), context_merge_incls_swits_igps_other_registrars(), and pbx_load_config().

{
   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 = ast_calloc(1, length)))
      return -1;
   /* Fill in this structure. Use 'p' for assignments, as the fields
    * in the structure are 'const char *'
    */
   p = new_include->stuff;
   new_include->name = p;
   strcpy(p, value);
   p += strlen(value) + 1;
   new_include->rname = p;
   strcpy(p, value);
   /* Strip off timing info, and process if it is there */
   if ( (c = strchr(p, ',')) ) {
      *c++ = '\0';
      new_include->hastime = ast_build_timing(&(new_include->timing), c);
   }
   new_include->next      = NULL;
   new_include->registrar = registrar;

   ast_wrlock_context(con);

   /* ... go to last include and check if context is already included too... */
   for (i = con->includes; i; i = i->next) {
      if (!strcasecmp(i->name, new_include->name)) {
         ast_destroy_timing(&(new_include->timing));
         ast_free(new_include);
         ast_unlock_context(con);
         errno = EEXIST;
         return -1;
      }
      il = i;
   }

   /* ... include new context into context list, unlock, return */
   if (il)
      il->next = new_include;
   else
      con->includes = new_include;
   ast_verb(3, "Including context '%s' in context '%s'\n", new_include->name, ast_get_context_name(con));

   ast_unlock_context(con);

   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

Return values:

	0	on success
	-1	on failure

Definition at line 7380 of file pbx.c.

References ast_context_add_switch2(), ast_unlock_contexts(), and find_context_locked().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) { /* found, add switch to this context */
      ret = ast_context_add_switch2(c, sw, data, eval, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

Note:

See ast_context_add_switch() for argument information, with the exception of the first argument. In this case, it's a pointer to an ast_context structure as opposed to the name.

Definition at line 7399 of file pbx.c.

References ast_context::alts, ast_calloc, ast_free, ast_get_context_name(), AST_LIST_INSERT_TAIL, AST_LIST_TRAVERSE, ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_sw::data, errno, ast_sw::eval, ast_sw::name, ast_sw::registrar, and ast_sw::stuff.

Referenced by ast_compile_ael2(), ast_context_add_switch(), context_merge_incls_swits_igps_other_registrars(), lua_register_switches(), and pbx_load_config().

{
   struct ast_sw *new_sw;
   struct ast_sw *i;
   int length;
   char *p;

   length = sizeof(struct ast_sw);
   length += strlen(value) + 1;
   if (data)
      length += strlen(data);
   length++;

   /* allocate new sw structure ... */
   if (!(new_sw = ast_calloc(1, length)))
      return -1;
   /* ... fill in this structure ... */
   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++;
   }
   new_sw->eval     = eval;
   new_sw->registrar = registrar;

   /* ... try to lock this context ... */
   ast_wrlock_context(con);

   /* ... go to last sw and check if context is already swd too... */
   AST_LIST_TRAVERSE(&con->alts, i, list) {
      if (!strcasecmp(i->name, new_sw->name) && !strcasecmp(i->data, new_sw->data)) {
         ast_free(new_sw);
         ast_unlock_context(con);
         errno = EEXIST;
         return -1;
      }
   }

   /* ... sw new context into context list, unlock, return */
   AST_LIST_INSERT_TAIL(&con->alts, new_sw, list);

   ast_verb(3, "Including switch '%s/%s' in context '%s'\n", new_sw->name, new_sw->data, ast_get_context_name(con));

   ast_unlock_context(con);

   return 0;
}

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

References __ast_context_destroy(), ast_unlock_contexts(), ast_wrlock_contexts(), contexts, and contexts_table.

Referenced by __unload_module(), cleanup_stale_contexts(), parkinglot_destroy(), sla_destroy(), and unload_module().

{
   ast_wrlock_contexts();
   __ast_context_destroy(contexts, contexts_table, con,registrar);
   ast_unlock_contexts();
}

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

References ast_copy_string(), ast_hashtab_lookup(), ast_rdlock_contexts(), ast_unlock_contexts(), ast_walk_contexts(), contexts_table, ast_context::name, and fake_context::name.

Referenced by __unload_module(), _macro_exec(), ast_context_verify_includes(), ast_ignore_pattern(), cleanup_stale_contexts(), isexten_function_read(), load_config(), manage_parkinglot(), park_exec_full(), parkinglot_destroy(), register_exten(), register_peer_exten(), unload_module(), and unregister_exten().

{
   struct ast_context *tmp = NULL;
   struct fake_context item;

   ast_copy_string(item.name, name, sizeof(item.name));

   ast_rdlock_contexts();
   if( contexts_table ) {
      tmp = ast_hashtab_lookup(contexts_table,&item);
   } else {
      while ( (tmp = ast_walk_contexts(tmp)) ) {
         if (!name || !strcasecmp(name, tmp->name)) {
            break;
         }
      }
   }
   ast_unlock_contexts();
   return tmp;
}

struct ast_context* ast_context_find_or_create	(	struct ast_context **	extcontexts,
		struct ast_hashtab *	exttable,
		const char *	name,
		const char *	registrar
	)			[read]

Register a new context or find an existing one.

Parameters:

	extcontexts	pointer to the ast_context structure pointer
	exttable	pointer to the hashtable that contains all the elements in extcontexts
	name	name of the new context
	registrar	registrar of the context

This function allows you to play in two environments: the global contexts (active dialplan) or an external context set of your choosing. To act on the external set, make sure extcontexts and exttable are set; for the globals, make sure both extcontexts and exttable are NULL.

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.

Returns:

NULL on failure, and an ast_context structure on success

Definition at line 6710 of file pbx.c.

References ast_calloc, ast_copy_string(), ast_debug, ast_hashtab_compare_contexts(), ast_hashtab_create(), ast_hashtab_hash_contexts(), ast_hashtab_insert_immediate(), ast_hashtab_insert_safe(), ast_hashtab_lookup(), ast_hashtab_newsize_java(), ast_hashtab_resize_java(), ast_log(), ast_mutex_init(), ast_rdlock_contexts(), ast_rwlock_init(), ast_strdup, ast_unlock_contexts(), ast_verb, ast_wrlock_contexts(), contexts, contexts_table, ast_context::ignorepats, ast_context::includes, local_contexts, ast_context::lock, LOG_ERROR, ast_context::macrolock, ast_context::name, fake_context::name, ast_context::next, ast_context::refcount, ast_context::registrar, ast_context::root, and ast_context::root_table.

Referenced by ast_compile_ael2(), build_parkinglot(), config_parse_variables(), context_merge(), load_config(), load_module(), lua_register_switches(), manage_parkinglot(), park_call_full(), pbx_load_config(), pbx_load_users(), reload_config(), set_config(), sla_build_station(), and sla_build_trunk().

{
   struct ast_context *tmp, **local_contexts;
   struct fake_context search;
   int length = sizeof(struct ast_context) + strlen(name) + 1;

   if (!contexts_table) {
      contexts_table = ast_hashtab_create(17,
                                 ast_hashtab_compare_contexts,
                                 ast_hashtab_resize_java,
                                 ast_hashtab_newsize_java,
                                 ast_hashtab_hash_contexts,
                                 0);
   }

   ast_copy_string(search.name, name, sizeof(search.name));
   if (!extcontexts) {
      ast_rdlock_contexts();
      local_contexts = &contexts;
      tmp = ast_hashtab_lookup(contexts_table, &search);
      ast_unlock_contexts();
      if (tmp) {
         tmp->refcount++;
         return tmp;
      }
   } else { /* local contexts just in a linked list; search there for the new context; slow, linear search, but not frequent */
      local_contexts = extcontexts;
      tmp = ast_hashtab_lookup(exttable, &search);
      if (tmp) {
         tmp->refcount++;
         return tmp;
      }
   }

   if ((tmp = ast_calloc(1, length))) {
      ast_rwlock_init(&tmp->lock);
      ast_mutex_init(&tmp->macrolock);
      strcpy(tmp->name, name);
      tmp->root = NULL;
      tmp->root_table = NULL;
      tmp->registrar = ast_strdup(registrar);
      tmp->includes = NULL;
      tmp->ignorepats = NULL;
      tmp->refcount = 1;
   } else {
      ast_log(LOG_ERROR, "Danger! We failed to allocate a context for %s!\n", name);
      return NULL;
   }

   if (!extcontexts) {
      ast_wrlock_contexts();
      tmp->next = *local_contexts;
      *local_contexts = tmp;
      ast_hashtab_insert_safe(contexts_table, tmp); /*put this context into the tree */
      ast_unlock_contexts();
      ast_debug(1, "Registered context '%s'(%p) in table %p registrar: %s\n", tmp->name, tmp, contexts_table, registrar);
      ast_verb(3, "Registered extension context '%s' (%p) in table %p; registrar: %s\n", tmp->name, tmp, contexts_table, registrar);
   } else {
      tmp->next = *local_contexts;
      if (exttable)
         ast_hashtab_insert_immediate(exttable, tmp); /*put this context into the tree */

      *local_contexts = tmp;
      ast_debug(1, "Registered context '%s'(%p) in local table %p; registrar: %s\n", tmp->name, tmp, exttable, registrar);
      ast_verb(3, "Registered extension context '%s' (%p) in local table %p; registrar: %s\n", tmp->name, tmp, exttable, registrar);
   }
   return tmp;
}

int ast_context_lockmacro

(

const char *

context

)

locks the macrolock in the given given context

Note:

This function locks contexts list by &conlist, searches for the right context structure, and locks the macrolock mutex in that context. macrolock is used to limit a macro to be executed by one call at a time.

Definition at line 5314 of file pbx.c.

References ast_copy_string(), ast_hashtab_lookup(), ast_mutex_lock(), ast_rdlock_contexts(), ast_unlock_contexts(), contexts_table, ast_context::macrolock, and fake_context::name.

Referenced by _macro_exec().

{
   struct ast_context *c = NULL;
   int ret = -1;
   struct fake_context item;

   ast_rdlock_contexts();

   ast_copy_string(item.name, context, sizeof(item.name));

   c = ast_hashtab_lookup(contexts_table,&item);
   if (c)
      ret = 0;
   ast_unlock_contexts();

   /* if we found context, lock macrolock */
   if (ret == 0) {
      ret = ast_mutex_lock(&c->macrolock);
   }

   return ret;
}

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 (0 to remove all)
	callerid	NULL to remove all; non-NULL to match a single record per priority
	matchcid	non-zero to match callerid element (if non-NULL); 0 to match default case
	registrar	registrar of the extension

This function removes an extension from a given context.

Return values:

	0	on success
	-1	on failure

Definition at line 5122 of file pbx.c.

References ast_context_remove_extension_callerid().

Referenced by destroy_station(), destroy_trunk(), register_peer_exten(), unregister_exten(), and UnregisterExtension().

{
   return ast_context_remove_extension_callerid(context, extension, priority, NULL, 0, registrar);
}

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

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

References ast_context_remove_extension_callerid2().

Referenced by load_config(), manage_parkinglot(), park_exec_full(), and unload_module().

{
   return ast_context_remove_extension_callerid2(con, extension, priority, NULL, 0, registrar, already_locked);
}

int ast_context_remove_extension_callerid	(	const char *	context,
		const char *	extension,
		int	priority,
		const char *	callerid,
		int	matchcallerid,
		const char *	registrar
	)

Definition at line 5127 of file pbx.c.

References ast_context_remove_extension_callerid2(), ast_unlock_contexts(), and find_context_locked().

Referenced by ast_context_remove_extension(), and handle_cli_dialplan_remove_extension().

{
   int ret = -1; /* default error return */
   struct ast_context *c = find_context_locked(context);

   if (c) { /* ... remove extension ... */
      ret = ast_context_remove_extension_callerid2(c, extension, priority, callerid, matchcallerid, registrar, 1);
      ast_unlock_contexts();
   }
   return ret;
}

int ast_context_remove_extension_callerid2	(	struct ast_context *	con,
		const char *	extension,
		int	priority,
		const char *	callerid,
		int	matchcallerid,
		const char *	registrar,
		int	already_locked
	)

Definition at line 5154 of file pbx.c.

References add_exten_to_pattern_tree(), ast_copy_string(), ast_hashtab_insert_immediate(), ast_hashtab_lookup(), ast_hashtab_remove_this_object(), ast_hashtab_size(), ast_log(), ast_strlen_zero(), ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_exten::cidmatch, match_char::deleted, destroy_exten(), match_char::exten, ast_exten::exten, ast_exten::label, LOG_ERROR, LOG_NOTICE, LOG_WARNING, ast_exten::matchcid, ast_context::name, ast_exten::next, ast_context::pattern_tree, ast_exten::peer, ast_exten::peer_label_table, ast_exten::peer_table, ast_exten::priority, ast_exten::registrar, ast_context::root, ast_context::root_table, and match_char::x.

Referenced by __ast_context_destroy(), ast_context_remove_extension2(), and ast_context_remove_extension_callerid().

{
   struct ast_exten *exten, *prev_exten = NULL;
   struct ast_exten *peer;
   struct ast_exten ex, *exten2, *exten3;
   char dummy_name[1024];
   struct ast_exten *previous_peer = NULL;
   struct ast_exten *next_peer = NULL;
   int found = 0;

   if (!already_locked)
      ast_wrlock_context(con);

   /* Handle this is in the new world */

   /* FIXME For backwards compatibility, if callerid==NULL, then remove ALL
    * peers, not just those matching the callerid. */
#ifdef NEED_DEBUG
   ast_verb(3,"Removing %s/%s/%d%s%s from trees, registrar=%s\n", con->name, extension, priority, matchcallerid ? "/" : "", matchcallerid ? callerid : "", registrar);
#endif
#ifdef CONTEXT_DEBUG
   check_contexts(__FILE__, __LINE__);
#endif
   /* find this particular extension */
   ex.exten = dummy_name;
   ex.matchcid = matchcallerid && !ast_strlen_zero(callerid); /* don't say match if there's no callerid */
   ex.cidmatch = callerid;
   ast_copy_string(dummy_name, extension, sizeof(dummy_name));
   exten = ast_hashtab_lookup(con->root_table, &ex);
   if (exten) {
      if (priority == 0) {
         exten2 = ast_hashtab_remove_this_object(con->root_table, exten);
         if (!exten2)
            ast_log(LOG_ERROR,"Trying to delete the exten %s from context %s, but could not remove from the root_table\n", extension, con->name);
         if (con->pattern_tree) {
            struct match_char *x = add_exten_to_pattern_tree(con, exten, 1);

            if (x->exten) { /* this test for safety purposes */
               x->deleted = 1; /* with this marked as deleted, it will never show up in the scoreboard, and therefore never be found */
               x->exten = 0; /* get rid of what will become a bad pointer */
            } else {
               ast_log(LOG_WARNING,"Trying to delete an exten from a context, but the pattern tree node returned isn't a full extension\n");
            }
         }
      } else {
         ex.priority = priority;
         exten2 = ast_hashtab_lookup(exten->peer_table, &ex);
         if (exten2) {

            if (exten2->label) { /* if this exten has a label, remove that, too */
               exten3 = ast_hashtab_remove_this_object(exten->peer_label_table,exten2);
               if (!exten3)
                  ast_log(LOG_ERROR,"Did not remove this priority label (%d/%s) from the peer_label_table of context %s, extension %s!\n", priority, exten2->label, con->name, exten2->exten);
            }

            exten3 = ast_hashtab_remove_this_object(exten->peer_table, exten2);
            if (!exten3)
               ast_log(LOG_ERROR,"Did not remove this priority (%d) from the peer_table of context %s, extension %s!\n", priority, con->name, exten2->exten);
            if (exten2 == exten && exten2->peer) {
               exten2 = ast_hashtab_remove_this_object(con->root_table, exten);
               ast_hashtab_insert_immediate(con->root_table, exten2->peer);
            }
            if (ast_hashtab_size(exten->peer_table) == 0) {
               /* well, if the last priority of an exten is to be removed,
                  then, the extension is removed, too! */
               exten3 = ast_hashtab_remove_this_object(con->root_table, exten);
               if (!exten3)
                  ast_log(LOG_ERROR,"Did not remove this exten (%s) from the context root_table (%s) (priority %d)\n", exten->exten, con->name, priority);
               if (con->pattern_tree) {
                  struct match_char *x = add_exten_to_pattern_tree(con, exten, 1);
                  if (x->exten) { /* this test for safety purposes */
                     x->deleted = 1; /* with this marked as deleted, it will never show up in the scoreboard, and therefore never be found */
                     x->exten = 0; /* get rid of what will become a bad pointer */
                  }
               }
            }
         } else {
            ast_log(LOG_ERROR,"Could not find priority %d of exten %s in context %s!\n",
                  priority, exten->exten, con->name);
         }
      }
   } else {
      /* hmmm? this exten is not in this pattern tree? */
      ast_log(LOG_WARNING,"Cannot find extension %s in root_table in context %s\n",
            extension, con->name);
   }
#ifdef NEED_DEBUG
   if (con->pattern_tree) {
      ast_log(LOG_NOTICE,"match char tree after exten removal:\n");
      log_match_char_tree(con->pattern_tree, " ");
   }
#endif

   /* scan the extension list to find first matching extension-registrar */
   for (exten = con->root; exten; prev_exten = exten, exten = exten->next) {
      if (!strcmp(exten->exten, extension) &&
         (!registrar || !strcmp(exten->registrar, registrar)) &&
         (!matchcallerid || (!ast_strlen_zero(callerid) && !ast_strlen_zero(exten->cidmatch) && !strcmp(exten->cidmatch, callerid)) || (ast_strlen_zero(callerid) && ast_strlen_zero(exten->cidmatch))))
         break;
   }
   if (!exten) {
      /* we can't find right extension */
      if (!already_locked)
         ast_unlock_context(con);
      return -1;
   }

   /* scan the priority list to remove extension with exten->priority == priority */
   for (peer = exten, next_peer = exten->peer ? exten->peer : exten->next;
       peer && !strcmp(peer->exten, extension) && (!matchcallerid || (!ast_strlen_zero(callerid) && !ast_strlen_zero(peer->cidmatch) && !strcmp(peer->cidmatch,callerid)) || (ast_strlen_zero(callerid) && ast_strlen_zero(peer->cidmatch)));
         peer = next_peer, next_peer = next_peer ? (next_peer->peer ? next_peer->peer : next_peer->next) : NULL) {
      if ((priority == 0 || peer->priority == priority) &&
            (!callerid || !matchcallerid || (matchcallerid && !strcmp(peer->cidmatch, callerid))) &&
            (!registrar || !strcmp(peer->registrar, registrar) )) {
         found = 1;

         /* we are first priority extension? */
         if (!previous_peer) {
            /*
             * We are first in the priority chain, so must update the extension chain.
             * The next node is either the next priority or the next extension
             */
            struct ast_exten *next_node = peer->peer ? peer->peer : peer->next;
            if (peer->peer) {
               /* move the peer_table and peer_label_table down to the next peer, if
                  it is there */
               peer->peer->peer_table = peer->peer_table;
               peer->peer->peer_label_table = peer->peer_label_table;
               peer->peer_table = NULL;
               peer->peer_label_table = NULL;
            }
            if (!prev_exten) {   /* change the root... */
               con->root = next_node;
            } else {
               prev_exten->next = next_node; /* unlink */
            }
            if (peer->peer)   { /* update the new head of the pri list */
               peer->peer->next = peer->next;
            }
         } else { /* easy, we are not first priority in extension */
            previous_peer->peer = peer->peer;
         }

         /* now, free whole priority extension */
         destroy_exten(peer);
      } else {
         previous_peer = peer;
      }
   }
   if (!already_locked)
      ast_unlock_context(con);
   return found ? 0 : -1;
}

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

Definition at line 7459 of file pbx.c.

References ast_context_remove_ignorepat2(), ast_unlock_contexts(), and find_context_locked().

Referenced by handle_cli_dialplan_remove_ignorepat().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) {
      ret = ast_context_remove_ignorepat2(c, ignorepat, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

Definition at line 7471 of file pbx.c.

References ast_free, ast_unlock_context(), ast_wrlock_context(), errno, ast_context::ignorepats, ast_ignorepat::next, ast_ignorepat::pattern, and ast_ignorepat::registrar.

Referenced by ast_context_remove_ignorepat().

{
   struct ast_ignorepat *ip, *ipl = NULL;

   ast_wrlock_context(con);

   for (ip = con->ignorepats; ip; ip = ip->next) {
      if (!strcmp(ip->pattern, ignorepat) &&
         (!registrar || (registrar == ip->registrar))) {
         if (ipl) {
            ipl->next = ip->next;
            ast_free(ip);
         } else {
            con->ignorepats = ip->next;
            ast_free(ip);
         }
         ast_unlock_context(con);
         return 0;
      }
      ipl = ip;
   }

   ast_unlock_context(con);
   errno = EINVAL;
   return -1;
}

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

Remove included contexts. This function locks contexts list by &conlist, search for the right context structure, leave context list locked and call ast_context_remove_include2 which removes include, unlock contexts list and return ...

Remove a context include.

Definition at line 5013 of file pbx.c.

References ast_context_remove_include2(), ast_unlock_contexts(), and find_context_locked().

Referenced by handle_cli_dialplan_remove_include().

{
   int ret = -1;
   struct ast_context *c = find_context_locked(context);

   if (c) {
      /* found, remove include from this context ... */
      ret = ast_context_remove_include2(c, include, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

Locks context, remove included contexts, unlocks context. 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.

Removes an include by an ast_context structure.

Return values:

	0	on success.
	-1	on failure.

Definition at line 5035 of file pbx.c.

References ast_destroy_timing(), ast_free, ast_get_context_name(), ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_context::includes, ast_include::name, ast_include::next, ast_include::registrar, and ast_include::timing.

Referenced by ast_context_remove_include().

{
   struct ast_include *i, *pi = NULL;
   int ret = -1;

   ast_wrlock_context(con);

   /* find our include */
   for (i = con->includes; i; pi = i, i = i->next) {
      if (!strcmp(i->name, include) &&
            (!registrar || !strcmp(i->registrar, registrar))) {
         /* remove from list */
         ast_verb(3, "Removing inclusion of context '%s' in context '%s; registrar=%s'\n", include, ast_get_context_name(con), registrar);
         if (pi)
            pi->next = i->next;
         else
            con->includes = i->next;
         /* free include and return */
         ast_destroy_timing(&(i->timing));
         ast_free(i);
         ret = 0;
         break;
      }
   }

   ast_unlock_context(con);

   return ret;
}

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

Remove a switch.

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

References ast_context_remove_switch2(), ast_unlock_contexts(), and find_context_locked().

{
   int ret = -1; /* default error return */
   struct ast_context *c = find_context_locked(context);

   if (c) {
      /* remove switch from this context ... */
      ret = ast_context_remove_switch2(c, sw, data, registrar);
      ast_unlock_contexts();
   }
   return ret;
}

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

References ast_context::alts, ast_free, ast_get_context_name(), AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, ast_unlock_context(), ast_verb, ast_wrlock_context(), ast_sw::data, ast_sw::name, and ast_sw::registrar.

Referenced by ast_context_remove_switch().

{
   struct ast_sw *i;
   int ret = -1;

   ast_wrlock_context(con);

   /* walk switches */
   AST_LIST_TRAVERSE_SAFE_BEGIN(&con->alts, i, list) {
      if (!strcmp(i->name, sw) && !strcmp(i->data, data) &&
         (!registrar || !strcmp(i->registrar, registrar))) {
         /* found, remove from list */
         ast_verb(3, "Removing switch '%s' from context '%s; registrar=%s'\n", sw, ast_get_context_name(con), registrar);
         AST_LIST_REMOVE_CURRENT(list);
         ast_free(i); /* free switch and return */
         ret = 0;
         break;
      }
   }
   AST_LIST_TRAVERSE_SAFE_END;

   ast_unlock_context(con);

   return ret;
}

int ast_context_unlockmacro

(

const char *

context

)

Unlocks the macrolock in the given context.

Note:

This function locks contexts list by &conlist, searches for the right context structure, and unlocks the macrolock mutex in that context. macrolock is used to limit a macro to be executed by one call at a time.

Definition at line 5342 of file pbx.c.

References ast_copy_string(), ast_hashtab_lookup(), ast_mutex_unlock(), ast_rdlock_contexts(), ast_unlock_contexts(), contexts_table, ast_context::macrolock, and fake_context::name.

Referenced by _macro_exec().

{
   struct ast_context *c = NULL;
   int ret = -1;
   struct fake_context item;

   ast_rdlock_contexts();

   ast_copy_string(item.name, context, sizeof(item.name));

   c = ast_hashtab_lookup(contexts_table,&item);
   if (c)
      ret = 0;
   ast_unlock_contexts();

   /* if we found context, unlock macrolock */
   if (ret == 0) {
      ret = ast_mutex_unlock(&c->macrolock);
   }

   return ret;
}

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

Return values:

	0	if no problems found
	-1	if there were any missing context

Definition at line 9803 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 = NULL;
   int res = 0;

   while ( (inc = ast_walk_context_includes(con, inc)) ) {
      if (ast_context_find(inc->rname))
         continue;

      res = -1;
      ast_log(LOG_WARNING, "Context '%s' tries to include nonexistent context '%s'\n",
         ast_get_context_name(con), inc->rname);
      break;
   }

   return res;
}

struct ast_custom_function* ast_custom_function_find

(

const char *

name

)

[read]

Definition at line 3269 of file pbx.c.

References ast_custom_function::acflist, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, and ast_custom_function::name.

Referenced by ast_func_read(), ast_func_read2(), ast_func_write(), config_curl(), destroy_curl(), handle_show_function(), op_func(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update2_curl(), and update_curl().

{
   struct ast_custom_function *acf = NULL;

   AST_RWLIST_RDLOCK(&acf_root);
   AST_RWLIST_TRAVERSE(&acf_root, acf, acflist) {
      if (!strcmp(name, acf->name))
         break;
   }
   AST_RWLIST_UNLOCK(&acf_root);

   return acf;
}

int ast_custom_function_unregister

(

struct ast_custom_function *

acf

)

Unregister a custom function.

Definition at line 3283 of file pbx.c.

References ast_custom_function::acflist, AST_RWLIST_REMOVE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_string_field_free_memory, ast_verb, AST_XML_DOC, ast_custom_function::docsrc, and ast_custom_function::name.

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

{
   struct ast_custom_function *cur;

   if (!acf) {
      return -1;
   }

   AST_RWLIST_WRLOCK(&acf_root);
   if ((cur = AST_RWLIST_REMOVE(&acf_root, acf, acflist))) {
#ifdef AST_XML_DOCS
      if (cur->docsrc == AST_XML_DOC) {
         ast_string_field_free_memory(acf);
      }
#endif
      ast_verb(2, "Unregistered custom function %s\n", cur->name);
   }
   AST_RWLIST_UNLOCK(&acf_root);

   return cur ? 0 : -1;
}

int ast_destroy_timing

(

struct ast_timing *

i

)

Deallocates memory structures associated with a timing bitmap.

Parameters:

i

Pointer to an ast_timing structure.

Return values:

	0	success
	non-zero	failure (number suitable to pass to

See also:

strerror)

Definition at line 7302 of file pbx.c.

References ast_free, and ast_timing::timezone.

Referenced by ast_context_add_include2(), ast_context_remove_include2(), iftime(), pbx_builtin_execiftime(), and pbx_builtin_gotoiftime().

{
   if (i->timezone) {
      ast_free(i->timezone);
      i->timezone = NULL;
   }
   return 0;
}

enum ast_extension_states ast_devstate_to_extenstate

(

enum ast_device_state

devstate

)

Map devstate to an extension state.

Parameters:

[in]

device

state

Returns:

the extension state mapping.

Definition at line 4086 of file pbx.c.

References AST_DEVICE_BUSY, AST_DEVICE_INUSE, AST_DEVICE_INVALID, AST_DEVICE_NOT_INUSE, AST_DEVICE_ONHOLD, AST_DEVICE_RINGING, AST_DEVICE_RINGINUSE, AST_DEVICE_TOTAL, AST_DEVICE_UNAVAILABLE, AST_DEVICE_UNKNOWN, AST_EXTENSION_BUSY, AST_EXTENSION_INUSE, AST_EXTENSION_NOT_INUSE, AST_EXTENSION_ONHOLD, AST_EXTENSION_RINGING, and AST_EXTENSION_UNAVAILABLE.

Referenced by ast_extension_state2().

{
   switch (devstate) {
   case AST_DEVICE_ONHOLD:
      return AST_EXTENSION_ONHOLD;
   case AST_DEVICE_BUSY:
      return AST_EXTENSION_BUSY;
   case AST_DEVICE_UNAVAILABLE:
   case AST_DEVICE_UNKNOWN:
   case AST_DEVICE_INVALID:
      return AST_EXTENSION_UNAVAILABLE;
   case AST_DEVICE_RINGINUSE:
      return (AST_EXTENSION_INUSE | AST_EXTENSION_RINGING);
   case AST_DEVICE_RINGING:
      return AST_EXTENSION_RINGING;
   case AST_DEVICE_INUSE:
      return AST_EXTENSION_INUSE;
   case AST_DEVICE_NOT_INUSE:
      return AST_EXTENSION_NOT_INUSE;
   case AST_DEVICE_TOTAL: /* not a device state, included for completeness */
      break;
   }

   return AST_EXTENSION_NOT_INUSE;
}

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

Determine whether an extension exists.

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

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

Returns:

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

References E_MATCH, and pbx_extension_helper().

Referenced by __analog_ss_thread(), __ast_goto_if_exists(), __ast_pbx_run(), _macro_exec(), acf_isexten_exec(), analog_ss_thread(), answer_call(), ast_app_dtget(), ast_bridge_call(), ast_pbx_outgoing_exten(), builtin_atxfer(), builtin_blindtransfer(), cb_events(), change_t38_state(), cli_console_dial(), conf_run(), console_dial(), console_transfer(), dahdi_handle_dtmfup(), dial_exec_full(), disa_exec(), dp_lookup(), dundi_lookup_local(), get_also_info(), get_destination(), get_refer_info(), gosub_exec(), handle_gosub(), handle_link_data(), handle_link_phone_dtmf(), handle_stimulus_message(), isexten_function_read(), leave_voicemail(), local_alloc(), local_call(), local_devicestate(), local_dtmf_helper(), loopback_exists(), metermaidstate(), mgcp_ss(), minivm_greet_exec(), misdn_overlap_dial_task(), my_handle_dtmfup(), park_space_reserve(), parkandannounce_exec(), pbx_builtin_waitexten(), phone_check_exception(), privacy_exec(), process_ast_dsp(), readexten_exec(), register_peer_exten(), rpt_exec(), show_debug_helper(), skinny_ss(), socket_process(), and waitstream_core().

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

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

Note:

This function will handle locking the channel as needed.

Definition at line 7606 of file pbx.c.

References ast_channel_lock, ast_channel_unlock, ast_copy_string(), 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(), builtin_atxfer(), disa_exec(), do_bridge_masquerade(), handle_setpriority(), pbx_parseable_goto(), and return_exec().

{
   if (!chan)
      return -1;

   ast_channel_lock(chan);

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

   ast_channel_unlock(chan);

   return 0;
}

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

Definition at line 2431 of file pbx.c.

References ast_log(), E_CANMATCH, E_MATCHMORE, extension_match_core(), and LOG_WARNING.

Referenced by lua_find_extension(), and realtime_switch_common().

{
   if (needmore != E_MATCHMORE && needmore != E_CANMATCH)
      ast_log(LOG_WARNING, "invalid argument %d\n", needmore);
   return extension_match_core(pattern, data, needmore);
}

int ast_extension_cmp	(	const char *	a,
		const char *	b
	)

Determine if one extension should match before another.

Parameters:

	a	extension to compare with b
	b	extension to compare with a

Checks whether or extension a should match before extension b

Return values:

	0	if the two extensions have equal matching priority
	1	on a > b
	-1	on a < b

Definition at line 2233 of file pbx.c.

References ext_cmp().

Referenced by lua_extension_cmp().

{
   return ext_cmp(a, b);
}

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.

Return values:

	1	on match
	0	on failure

Definition at line 2426 of file pbx.c.

References E_MATCH, and extension_match_core().

Referenced by ast_ignore_pattern(), do_say(), find_matching_priority(), load_module(), loopback_canmatch(), loopback_exists(), loopback_matchmore(), lua_find_extension(), manager_show_dialplan_helper(), matchcid(), misdn_cfg_is_msn_valid(), realtime_switch_common(), reload(), and show_dialplan_helper().

{
   return extension_match_core(pattern, data, E_MATCH);
}

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

Check extension state for an extension by using hint.

Uses hint and devicestate callback to get the state of an extension.

Definition at line 4148 of file pbx.c.

References ast_extension_state2(), and ast_hint_extension().

Referenced by action_extensionstate(), extstate_read(), and handle_request_subscribe().

{
   struct ast_exten *e;

   if (!(e = ast_hint_extension(c, context, exten))) {  /* Do we have a hint for this extension ? */
      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]

Check state of extension by using hints.

Definition at line 4113 of file pbx.c.

References ast_devstate_aggregate_add(), ast_devstate_aggregate_init(), ast_devstate_aggregate_result(), ast_devstate_to_extenstate(), ast_get_extension_app(), ast_str_buffer(), ast_str_set(), ast_str_thread_get(), extensionstate_buf, and strsep().

Referenced by ast_add_hint_nolock(), ast_extension_state(), and handle_statechange().

{
   struct ast_str *hint = ast_str_thread_get(&extensionstate_buf, 16);
   char *cur, *rest;
   struct ast_devstate_aggregate agg;

   if (!e)
      return -1;

   ast_devstate_aggregate_init(&agg);

   ast_str_set(&hint, 0, "%s", ast_get_extension_app(e));

   rest = ast_str_buffer(hint);  /* One or more devices separated with a & character */

   while ( (cur = strsep(&rest, "&")) ) {
      ast_devstate_aggregate_add(&agg, ast_device_state(cur));
   }

   return ast_devstate_to_extenstate(ast_devstate_aggregate_result(&agg));
}

const char* ast_extension_state2str

(

int

extension_state

)

Return extension_state as string.

Return string representation of the state of an extension.

Definition at line 4136 of file pbx.c.

References ARRAY_LEN, extension_states, and cfextension_states::text.

Referenced by cb_extensionstate(), handle_request_subscribe(), handle_show_hint(), handle_show_hints(), and show_channels_cb().

{
   int i;

   for (i = 0; (i < ARRAY_LEN(extension_states)); 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
	)

Add watcher for extension states.

Registers a state change callback.

Definition at line 4212 of file pbx.c.

References ast_exten::app, ast_add_extension(), ast_calloc, ast_free_ptr, ast_hint_extension(), AST_LIST_INSERT_HEAD, AST_LIST_TRAVERSE, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_strdup, ast_state_cb::callback, ast_hint::callbacks, ast_exten::cidmatch, ast_exten::data, ast_state_cb::data, ast_hint::exten, ast_exten::exten, ast_state_cb::id, ast_exten::label, ast_context::name, ast_exten::parent, ast_exten::priority, ast_exten::registrar, and stateid.

Referenced by __init_manager(), handle_request_subscribe(), and skinny_register().

{
   struct ast_hint *hint;
   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_RWLIST_WRLOCK(&hints);

      AST_LIST_TRAVERSE(&statecbs, cblist, entry) {
         if (cblist->callback == callback) {
            cblist->data = data;
            AST_RWLIST_UNLOCK(&hints);
            return 0;
         }
      }

      /* Now insert the callback */
      if (!(cblist = ast_calloc(1, sizeof(*cblist)))) {
         AST_RWLIST_UNLOCK(&hints);
         return -1;
      }
      cblist->id = 0;
      cblist->callback = callback;
      cblist->data = data;

      AST_LIST_INSERT_HEAD(&statecbs, cblist, entry);

      AST_RWLIST_UNLOCK(&hints);

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

   /* If this is a pattern, dynamically create a new extension for this
    * particular match.  Note that this will only happen once for each
    * individual extension, because the pattern will no longer match first.
    */
   if (e->exten[0] == '_') {
      ast_add_extension(e->parent->name, 0, exten, e->priority, e->label,
         e->cidmatch, e->app, ast_strdup(e->data), ast_free_ptr,
         e->registrar);
      e = ast_hint_extension(NULL, context, exten);
      if (!e || e->exten[0] == '_') {
         return -1;
      }
   }

   /* Find the hint in the list of hints */
   AST_RWLIST_WRLOCK(&hints);

   AST_RWLIST_TRAVERSE(&hints, hint, list) {
      if (hint->exten == e)
         break;
   }

   if (!hint) {
      /* We have no hint, sorry */
      AST_RWLIST_UNLOCK(&hints);
      return -1;
   }

   /* Now insert the callback in the callback list  */
   if (!(cblist = ast_calloc(1, sizeof(*cblist)))) {
      AST_RWLIST_UNLOCK(&hints);
      return -1;
   }

   cblist->id = stateid++;    /* Unique ID for this callback */
   cblist->callback = callback;  /* Pointer to callback routine */
   cblist->data = data;    /* Data for the callback */

   AST_LIST_INSERT_HEAD(&hint->callbacks, cblist, entry);

   AST_RWLIST_UNLOCK(&hints);

   return cblist->id;
}

int ast_extension_state_del	(	int	id,
		ast_state_cb_type	callback
	)

Remove a watcher from the callback list.

Deletes a registered state change callback by ID.

Definition at line 4302 of file pbx.c.

References ast_free, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_state_cb::callback, ast_hint::callbacks, and ast_state_cb::id.

Referenced by dialog_unlink_all(), handle_request_subscribe(), and skinny_unregister().

{
   struct ast_state_cb *p_cur = NULL;
   int ret = -1;

   if (!id && !callback)
      return -1;

   AST_RWLIST_WRLOCK(&hints);

   if (!id) {  /* id == 0 is a callback without extension */
      AST_LIST_TRAVERSE_SAFE_BEGIN(&statecbs, p_cur, entry) {
         if (p_cur->callback == callback) {
            AST_LIST_REMOVE_CURRENT(entry);
            break;
         }
      }
      AST_LIST_TRAVERSE_SAFE_END;
   } else { /* callback with extension, find the callback based on ID */
      struct ast_hint *hint;
      AST_RWLIST_TRAVERSE(&hints, hint, list) {
         AST_LIST_TRAVERSE_SAFE_BEGIN(&hint->callbacks, p_cur, entry) {
            if (p_cur->id == id) {
               AST_LIST_REMOVE_CURRENT(entry);
               break;
            }
         }
         AST_LIST_TRAVERSE_SAFE_END;

         if (p_cur)
            break;
      }
   }

   if (p_cur) {
      ast_free(p_cur);
   }

   AST_RWLIST_UNLOCK(&hints);

   return ret;
}

int ast_findlabel_extension	(	struct ast_channel *	c,
		const char *	context,
		const char *	exten,
		const char *	label,
		const char *	callerid
	)

Find the priority of an extension that has the specified label.

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

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

Return values:

	the	priority which matches the given label in the extension
	-1	if not found.

Definition at line 4485 of file pbx.c.

References E_FINDLABEL, and pbx_extension_helper().

Referenced by action_originate(), action_redirect(), handle_gosub(), handle_setpriority(), isexten_function_read(), and pbx_parseable_goto().

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

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

Find the priority of an extension that has the specified label.

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

This function is the same as ast_findlabel_extension, except that it accepts a pointer to an ast_context structure to specify the context instead of the name of the context. Otherwise, the functions behave the same.

Definition at line 4490 of file pbx.c.

References E_FINDLABEL, and pbx_extension_helper().

Referenced by pbx_load_config().

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

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

executes a read operation on a function

Parameters:

	chan	Channel to execute on
	function	Data containing the function call string (will be modified)
	workspace	A pointer to safe memory to use for a return value
	len	the number of bytes in workspace

This application executes a function in read mode on a given channel.

Return values:

	0	success
	non-zero	failure

Definition at line 3427 of file pbx.c.

References __ast_module_user_add(), __ast_module_user_remove(), ast_copy_string(), ast_custom_function_find(), ast_free, ast_log(), ast_str_buffer(), ast_str_create(), ast_str_size(), ast_strdupa, copy(), func_args(), LOG_ERROR, ast_custom_function::mod, ast_custom_function::read, ast_custom_function::read2, and str.

Referenced by action_getvar(), action_status(), handle_getvariable(), lua_get_variable_value(), and pbx_substitute_variables_helper_full().

{
   char *copy = ast_strdupa(function);
   char *args = func_args(copy);
   struct ast_custom_function *acfptr = ast_custom_function_find(copy);
   int res;
   struct ast_module_user *u = NULL;

   if (acfptr == NULL) {
      ast_log(LOG_ERROR, "Function %s not registered\n", copy);
   } else if (!acfptr->read && !acfptr->read2) {
      ast_log(LOG_ERROR, "Function %s cannot be read\n", copy);
   } else if (acfptr->read) {
      if (acfptr->mod) {
         u = __ast_module_user_add(acfptr->mod, chan);
      }
      res = acfptr->read(chan, copy, args, workspace, len);
      if (acfptr->mod && u) {
         __ast_module_user_remove(acfptr->mod, u);
      }
      return res;
   } else {
      struct ast_str *str = ast_str_create(16);
      if (acfptr->mod) {
         u = __ast_module_user_add(acfptr->mod, chan);
      }
      res = acfptr->read2(chan, copy, args, &str, 0);
      if (acfptr->mod && u) {
         __ast_module_user_remove(acfptr->mod, u);
      }
      ast_copy_string(workspace, ast_str_buffer(str), len > ast_str_size(str) ? ast_str_size(str) : len);
      ast_free(str);
      return res;
   }
   return -1;
}

int ast_func_read2	(	struct ast_channel *	chan,
		const char *	function,
		struct ast_str **	str,
		ssize_t	maxlen
	)

executes a read operation on a function

Parameters:

	chan	Channel to execute on
	function	Data containing the function call string (will be modified)
	str	A dynamic string buffer into which to place the result.
	maxlen	<0 if the dynamic buffer should not grow; >0 if the dynamic buffer should be limited to that number of bytes; 0 if the dynamic buffer has no upper limit

This application executes a function in read mode on a given channel.

Return values:

	0	success
	non-zero	failure

Definition at line 3464 of file pbx.c.

References __ast_module_user_add(), __ast_module_user_remove(), ast_custom_function_find(), ast_log(), ast_str_buffer(), ast_str_make_space(), ast_str_reset(), ast_str_size(), ast_strdupa, copy(), func_args(), LOG_ERROR, maxsize, ast_custom_function::mod, ast_custom_function::read, ast_custom_function::read2, ast_custom_function::read_max, and VAR_BUF_SIZE.

Referenced by ast_str_substitute_variables_full().

{
   char *copy = ast_strdupa(function);
   char *args = func_args(copy);
   struct ast_custom_function *acfptr = ast_custom_function_find(copy);
   int res;
   struct ast_module_user *u = NULL;

   if (acfptr == NULL) {
      ast_log(LOG_ERROR, "Function %s not registered\n", copy);
   } else if (!acfptr->read && !acfptr->read2) {
      ast_log(LOG_ERROR, "Function %s cannot be read\n", copy);
   } else {
      if (acfptr->mod) {
         u = __ast_module_user_add(acfptr->mod, chan);
      }
      if (acfptr->read2) {
         /* ast_str enabled */
         ast_str_reset(*str);
         res = acfptr->read2(chan, copy, args, str, maxlen);
      } else {
         /* Legacy function pointer, allocate buffer for result */
         int maxsize = ast_str_size(*str);
         if (maxlen > -1) {
            if (maxlen == 0) {
               if (acfptr->read_max) {
                  maxsize = acfptr->read_max;
               } else {
                  maxsize = VAR_BUF_SIZE;
               }
            } else {
               maxsize = maxlen;
            }
            ast_str_make_space(str, maxsize);
         }
         res = acfptr->read(chan, copy, args, ast_str_buffer(*str), maxsize);
      }
      if (acfptr->mod && u) {
         __ast_module_user_remove(acfptr->mod, u);
      }
      return res;
   }
   return -1;
}

int ast_func_write	(	struct ast_channel *	chan,
		const char *	function,
		const char *	value
	)

executes a write operation on a function

Parameters:

	chan	Channel to execute on
	function	Data containing the function call string (will be modified)
	value	A value parameter to pass for writing

This application executes a function in write mode on a given channel.

Return values:

	0	success
	non-zero	failure

Definition at line 3509 of file pbx.c.

References __ast_module_user_add(), __ast_module_user_remove(), ast_custom_function_find(), ast_log(), ast_strdupa, copy(), func_args(), LOG_ERROR, ast_custom_function::mod, and ast_custom_function::write.

Referenced by conf_run(), pbx_builtin_pushvar_helper(), and pbx_builtin_setvar_helper().

{
   char *copy = ast_strdupa(function);
   char *args = func_args(copy);
   struct ast_custom_function *acfptr = ast_custom_function_find(copy);

   if (acfptr == NULL)
      ast_log(LOG_ERROR, "Function %s not registered\n", copy);
   else if (!acfptr->write)
      ast_log(LOG_ERROR, "Function %s cannot be written to\n", copy);
   else {
      int res;
      struct ast_module_user *u = NULL;
      if (acfptr->mod)
         u = __ast_module_user_add(acfptr->mod, chan);
      res = acfptr->write(chan, copy, args, value);
      if (acfptr->mod && u)
         __ast_module_user_remove(acfptr->mod, u);
      return res;
   }

   return -1;
}

const char* ast_get_context_name

(

struct ast_context *

con

)

Definition at line 9655 of file pbx.c.

References ast_context::name.

Referenced by _macro_exec(), ast_context_add_include2(), ast_context_add_switch2(), ast_context_remove_include2(), ast_context_remove_switch2(), ast_context_verify_includes(), complete_dialplan_add_extension(), complete_dialplan_add_ignorepat(), complete_dialplan_add_include(), complete_dialplan_remove_extension(), complete_dialplan_remove_ignorepat(), complete_dialplan_remove_include(), complete_show_dialplan_context(), context_merge_incls_swits_igps_other_registrars(), dundi_precache_full(), find_matching_endwhile(), find_matching_priority(), handle_cli_dialplan_save(), handle_show_hint(), handle_show_hints(), manager_show_dialplan_helper(), show_debug_helper(), and show_dialplan_helper().

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

const char* ast_get_context_registrar

(

struct ast_context *

c

)

Definition at line 9693 of file pbx.c.

References ast_context::registrar.

Referenced by handle_cli_dialplan_save(), show_debug_helper(), and show_dialplan_helper().

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

const char* ast_get_extension_app

(

struct ast_exten *

e

)

Definition at line 9723 of file pbx.c.

References ast_exten::app.

Referenced by _macro_exec(), ast_add_hint_nolock(), ast_extension_state2(), ast_get_hint(), ast_str_get_hint(), find_matching_endwhile(), handle_cli_dialplan_save(), handle_show_hint(), handle_show_hints(), handle_statechange(), manager_show_dialplan_helper(), and print_ext().

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

void* ast_get_extension_app_data

(

struct ast_exten *

e

)

Definition at line 9728 of file pbx.c.

References ast_exten::data.

Referenced by _macro_exec(), ast_get_hint(), ast_str_get_hint(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and print_ext().

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

const char* ast_get_extension_cidmatch

(

struct ast_exten *

e

)

Definition at line 9718 of file pbx.c.

References ast_exten::cidmatch.

Referenced by complete_dialplan_remove_extension(), find_matching_priority(), and handle_cli_dialplan_save().

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

struct ast_context* ast_get_extension_context

(

struct ast_exten *

exten

)

[read]

Definition at line 9660 of file pbx.c.

References ast_exten::parent.

Referenced by handle_show_hint(), and handle_show_hints().

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

const char* ast_get_extension_label

(

struct ast_exten *

exten

)

Definition at line 9670 of file pbx.c.

References ast_exten::label.

Referenced by handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

int ast_get_extension_matchcid

(

struct ast_exten *

e

)

Definition at line 9713 of file pbx.c.

References ast_exten::matchcid.

Referenced by complete_dialplan_remove_extension(), find_matching_priority(), and handle_cli_dialplan_save().

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

const char* ast_get_extension_name

(

struct ast_exten *

exten

)

Definition at line 9665 of file pbx.c.

References ast_exten::exten.

Referenced by ast_add_hint_nolock(), complete_core_show_hint(), complete_dialplan_remove_extension(), dundi_precache_full(), find_matching_priority(), handle_cli_dialplan_save(), handle_show_hint(), handle_show_hints(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

int ast_get_extension_priority

(

struct ast_exten *

exten

)

Definition at line 9685 of file pbx.c.

References ast_exten::priority.

Referenced by complete_dialplan_remove_extension(), find_matching_priority(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and print_ext().

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

const char* ast_get_extension_registrar

(

struct ast_exten *

e

)

Definition at line 9698 of file pbx.c.

References ast_exten::registrar.

Referenced by handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

int ast_get_hint	(	char *	hint,
		int	hintsize,
		char *	name,
		int	namesize,
		struct ast_channel *	c,
		const char *	context,
		const char *	exten
	)

Get hint for channel.

If an extension hint exists, return non-zero.

Definition at line 4442 of file pbx.c.

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

Referenced by action_extensionstate(), get_cid_name(), get_destination(), hint_read(), manager_state_cb(), skinny_extensionstate_cb(), and state_notify_build_xml().

{
   struct ast_exten *e = ast_hint_extension(c, context, exten);

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

const char* ast_get_ignorepat_name

(

struct ast_ignorepat *

ip

)

Definition at line 9680 of file pbx.c.

References ast_ignorepat::pattern.

Referenced by complete_dialplan_remove_ignorepat(), context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), lookup_c_ip(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

const char* ast_get_ignorepat_registrar

(

struct ast_ignorepat *

ip

)

Definition at line 9708 of file pbx.c.

References ast_ignorepat::registrar.

Referenced by context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

const char* ast_get_include_name

(

struct ast_include *

inc

)

Definition at line 9675 of file pbx.c.

References ast_include::name.

Referenced by complete_dialplan_remove_include(), context_merge_incls_swits_igps_other_registrars(), find_matching_priority(), handle_cli_dialplan_save(), lookup_ci(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

const char* ast_get_include_registrar

(

struct ast_include *

i

)

Definition at line 9703 of file pbx.c.

References ast_include::registrar.

Referenced by context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

const char* ast_get_switch_data

(

struct ast_sw *

sw

)

Definition at line 9738 of file pbx.c.

References ast_sw::data.

Referenced by context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

int ast_get_switch_eval

(

struct ast_sw *

sw

)

Definition at line 9743 of file pbx.c.

References ast_sw::eval.

Referenced by context_merge_incls_swits_igps_other_registrars().

{
   return sw->eval;
}

const char* ast_get_switch_name

(

struct ast_sw *

sw

)

Definition at line 9733 of file pbx.c.

References ast_sw::name.

Referenced by context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

const char* ast_get_switch_registrar

(

struct ast_sw *

sw

)

Definition at line 9748 of file pbx.c.

References ast_sw::registrar.

Referenced by context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), and show_dialplan_helper().

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

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

Note:

This function will handle locking the channel as needed.

Definition at line 9842 of file pbx.c.

References __ast_goto_if_exists().

Referenced by background_detect_exec(), channel_spy(), common_exec(), conf_run(), dial_exec_full(), goto_exten(), onedigit_goto(), priority_jump(), select_entry(), and valid_exit().

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

int ast_hashtab_compare_contexts	(	const void *	ah_a,
		const void *	ah_b
	)

hashtable functions for contexts

Definition at line 1013 of file pbx.c.

References ast_context::name.

Referenced by ast_context_find_or_create(), lua_register_switches(), and pbx_load_module().

{
   const struct ast_context *ac = ah_a;
   const struct ast_context *bc = ah_b;
   if (!ac || !bc) /* safety valve, but it might prevent a crash you'd rather have happen */
      return 1;
   /* assume context names are registered in a string table! */
   return strcmp(ac->name, bc->name);
}

unsigned int ast_hashtab_hash_contexts

(

const void *

obj

)

Definition at line 1056 of file pbx.c.

References ast_hashtab_hash_string(), and ast_context::name.

Referenced by ast_context_find_or_create(), lua_register_switches(), and pbx_load_module().

{
   const struct ast_context *ac = obj;
   return ast_hashtab_hash_string(ac->name);
}

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

Definition at line 4077 of file pbx.c.

References ast_hint_extension_nolock(), ast_rdlock_contexts(), and ast_unlock_contexts().

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

{
   struct ast_exten *e;
   ast_rdlock_contexts();
   e = ast_hint_extension_nolock(c, context, exten);
   ast_unlock_contexts();
   return e;
}

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

Find hint for given extension in context.

Definition at line 4071 of file pbx.c.

References E_MATCH, pbx_find_extension(), PRIORITY_HINT, and pbx_find_info::stacklen.

Referenced by ast_hint_extension(), and ast_merge_contexts_and_delete().

{
   struct pbx_find_info q = { .stacklen = 0 }; /* the rest is set in pbx_find_context */
   return pbx_find_extension(c, NULL, &q, context, exten, PRIORITY_HINT, NULL, "", E_MATCH);
}

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.

Return values:

	0	if the pattern should not be ignored
	non-zero	if the pattern should be ignored

Definition at line 7552 of file pbx.c.

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

Referenced by __analog_ss_thread(), analog_ss_thread(), ast_app_dtget(), disa_exec(), dp_lookup(), dundi_lookup_local(), handle_enbloc_call_message(), handle_soft_key_event_message(), handle_stimulus_message(), mgcp_ss(), and skinny_ss().

{
   struct ast_context *con = ast_context_find(context);
   if (con) {
      struct ast_ignorepat *pat;
      for (pat = con->ignorepats; pat; pat = pat->next) {
         if (ast_extension_match(pat->pattern, pattern))
            return 1;
      }
   }

   return 0;
}

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 XXX
	context	context to serach within
	exten	extension to check
	priority	priority of extension path
	callerid	callerid of extension being searched for

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

Returns:

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

References E_MATCHMORE, and pbx_extension_helper().

Referenced by __analog_ss_thread(), __ast_pbx_run(), analog_ss_thread(), ast_app_dtget(), collect_digits(), disa_exec(), dp_lookup(), dundi_lookup_local(), handle_link_data(), handle_link_phone_dtmf(), local_dtmf_helper(), loopback_matchmore(), mgcp_ss(), pbx_builtin_background(), readexten_exec(), and skinny_ss().

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

void ast_merge_contexts_and_delete	(	struct ast_context **	extcontexts,
		struct ast_hashtab *	exttable,
		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
	exttable	pointer to the ast_hashtab structure that contains all the elements in extcontexts
	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 6909 of file pbx.c.

References __ast_internal_context_destroy(), ast_exten::app, ast_add_extension_nolock(), ast_calloc, AST_EXTENSION_REMOVED, ast_free, ast_free_ptr, ast_hashtab_destroy(), ast_hashtab_end_traversal(), ast_hashtab_next(), ast_hashtab_start_traversal(), ast_hint_extension_nolock(), AST_LIST_APPEND_LIST, AST_LIST_EMPTY, AST_LIST_HEAD_INIT_VALUE, AST_LIST_INSERT_HEAD, AST_LIST_REMOVE_HEAD, ast_log(), ast_rdlock_contexts(), AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_strdup, ast_tvdiff_us(), ast_tvnow(), ast_unlock_contexts(), ast_verb, ast_wrlock_contexts(), ast_wrlock_contexts_version(), ast_state_cb::callback, ast_hint::callbacks, context_merge(), contexts, contexts_table, ast_state_cb::data, ast_exten::data, E_MATCH, ast_exten::exten, ast_hint::exten, ast_hint::laststate, LOG_WARNING, ast_context::name, ast_context::next, ast_sw::next, ast_exten::parent, pbx_find_extension(), PRIORITY_HINT, ast_context::registrar, and pbx_find_info::stacklen.

Referenced by lua_reload_extensions(), and pbx_load_module().

{
   double ft;
   struct ast_context *tmp, *oldcontextslist;
   struct ast_hashtab *oldtable;
   struct store_hints store = AST_LIST_HEAD_INIT_VALUE;
   struct store_hint *this;
   struct ast_hint *hint;
   struct ast_exten *exten;
   int length;
   struct ast_state_cb *thiscb;
   struct ast_hashtab_iter *iter;

   /* it is very important that this function hold the hint list lock _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
   */

   struct timeval begintime, writelocktime, endlocktime, enddeltime;
   int wrlock_ver;

   begintime = ast_tvnow();
   ast_rdlock_contexts();
   iter = ast_hashtab_start_traversal(contexts_table);
   while ((tmp = ast_hashtab_next(iter))) {
      context_merge(extcontexts, exttable, tmp, registrar);
   }
   ast_hashtab_end_traversal(iter);
   wrlock_ver = ast_wrlock_contexts_version();

   ast_unlock_contexts(); /* this feels real retarded, but you must do
                       what you must do If this isn't done, the following 
                        wrlock is a guraranteed deadlock */
   ast_wrlock_contexts();
   if (ast_wrlock_contexts_version() > wrlock_ver+1) {
      ast_log(LOG_WARNING,"==================!!!!!!!!!!!!!!!Something changed the contexts in the middle of merging contexts!\n");
   }

   AST_RWLIST_WRLOCK(&hints);
   writelocktime = ast_tvnow();

   /* preserve all watchers for hints associated with this registrar */
   AST_RWLIST_TRAVERSE(&hints, hint, list) {
      if (!AST_LIST_EMPTY(&hint->callbacks) && !strcmp(registrar, hint->exten->parent->registrar)) {
         length = strlen(hint->exten->exten) + strlen(hint->exten->parent->name) + 2 + sizeof(*this);
         if (!(this = ast_calloc(1, length)))
            continue;
         AST_LIST_APPEND_LIST(&this->callbacks, &hint->callbacks, entry);
         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);
      }
   }

   /* save the old table and list */
   oldtable = contexts_table;
   oldcontextslist = contexts;

   /* move in the new table and list */
   contexts_table = exttable;
   contexts = *extcontexts;

   /* restore the watchers for hints that can be found; notify those that
      cannot be restored
   */
   while ((this = AST_LIST_REMOVE_HEAD(&store, list))) {
      struct pbx_find_info q = { .stacklen = 0 };
      exten = pbx_find_extension(NULL, NULL, &q, this->context, this->exten, PRIORITY_HINT, NULL, "", E_MATCH);
      /* If this is a pattern, dynamically create a new extension for this
       * particular match.  Note that this will only happen once for each
       * individual extension, because the pattern will no longer match first.
       */
      if (exten && exten->exten[0] == '_') {
         ast_add_extension_nolock(exten->parent->name, 0, this->exten, PRIORITY_HINT, NULL,
            0, exten->app, ast_strdup(exten->data), ast_free_ptr, registrar);
         /* rwlocks are not recursive locks */
         exten = ast_hint_extension_nolock(NULL, this->context, this->exten);
      }

      /* Find the hint in the list of hints */
      AST_RWLIST_TRAVERSE(&hints, hint, list) {
         if (hint->exten == exten)
            break;
      }
      if (!exten || !hint) {
         /* this hint has been removed, notify the watchers */
         while ((thiscb = AST_LIST_REMOVE_HEAD(&this->callbacks, entry))) {
            thiscb->callback(this->context, this->exten, AST_EXTENSION_REMOVED, thiscb->data);
            ast_free(thiscb);
         }
      } else {
         AST_LIST_APPEND_LIST(&hint->callbacks, &this->callbacks, entry);
         hint->laststate = this->laststate;
      }
      ast_free(this);
   }

   AST_RWLIST_UNLOCK(&hints);
   ast_unlock_contexts();
   endlocktime = ast_tvnow();

   /* the old list and hashtab no longer are relevant, delete them while the rest of asterisk
      is now freely using the new stuff instead */

   ast_hashtab_destroy(oldtable, NULL);

   for (tmp = oldcontextslist; tmp; ) {
      struct ast_context *next;  /* next starting point */
      next = tmp->next;
      __ast_internal_context_destroy(tmp);
      tmp = next;
   }
   enddeltime = ast_tvnow();

   ft = ast_tvdiff_us(writelocktime, begintime);
   ft /= 1000000.0;
   ast_verb(3,"Time to scan old dialplan and merge leftovers back into the new: %8.6f sec\n", ft);

   ft = ast_tvdiff_us(endlocktime, writelocktime);
   ft /= 1000000.0;
   ast_verb(3,"Time to restore hints and swap in new dialplan: %8.6f sec\n", ft);

   ft = ast_tvdiff_us(enddeltime, endlocktime);
   ft /= 1000000.0;
   ast_verb(3,"Time to delete the old dialplan: %8.6f sec\n", ft);

   ft = ast_tvdiff_us(enddeltime, begintime);
   ft /= 1000000.0;
   ast_verb(3,"Total time merge_contexts_delete: %8.6f sec\n", ft);
   return;
}

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

Note:

This function will handle locking the channel as needed.

Definition at line 9905 of file pbx.c.

References pbx_parseable_goto().

Referenced by _while_exec(), check_goto_on_transfer(), dial_exec_full(), gosub_exec(), ivr_dispatch(), parkandannounce_exec(), pbx_builtin_goto(), and while_continue_exec().

{
   return pbx_parseable_goto(chan, goto_string, 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
	)

Synchronously or asynchronously make an outbound call and send it to a particular application with given extension

Definition at line 8393 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_calloc, ast_cdr_disposition(), ast_cdr_failed(), ast_cdr_setaccount(), ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_free, ast_hangup(), ast_log(), ast_pbx_outgoing_cdr_failed(), ast_pbx_run_app(), ast_pthread_create_detached, ast_set_variables(), AST_STATE_UP, ast_strlen_zero(), ast_variables_destroy(), ast_verb, async_wait(), ast_channel::cdr, async_stat::chan, app_tmp::chan, app_tmp::data, errno, ast_channel::hangupcause, LOG_WARNING, ast_channel::name, async_stat::p, app_tmp::t, async_stat::timeout, and outgoing_helper::vars.

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

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

   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 (synchronous) {
      chan = __ast_request_and_dial(type, format, NULL, data, timeout, reason, cid_num, cid_name, &oh);
      if (chan) {
         ast_set_variables(chan, vars);
         if (account)
            ast_cdr_setaccount(chan, account);
         if (chan->_state == AST_STATE_UP) {
            res = 0;
            ast_verb(4, "Channel %s was answered.\n", chan->name);
            tmp = ast_calloc(1, sizeof(*tmp));
            if (!tmp)
               res = -1;
            else {
               ast_copy_string(tmp->app, app, sizeof(tmp->app));
               if (appdata)
                  ast_copy_string(tmp->data, appdata, sizeof(tmp->data));
               tmp->chan = chan;
               if (synchronous > 1) {
                  if (locked_channel)
                     ast_channel_unlock(chan);
                  ast_pbx_run_app(tmp);
               } else {
                  if (locked_channel)
                     ast_channel_lock(chan);
                  if (ast_pthread_create_detached(&tmp->t, NULL, ast_pbx_run_app, tmp)) {
                     ast_log(LOG_WARNING, "Unable to spawn execute thread on %s: %s\n", chan->name, strerror(errno));
                     ast_free(tmp);
                     if (locked_channel)
                        ast_channel_unlock(chan);
                     ast_hangup(chan);
                     res = -1;
                  } else {
                     if (locked_channel)
                        *locked_channel = chan;
                  }
               }
            }
         } else {
            ast_verb(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 {
      struct async_stat *as;
      if (!(as = ast_calloc(1, sizeof(*as)))) {
         res = -1;
         goto outgoing_app_cleanup;
      }
      chan = __ast_request_and_dial(type, format, NULL, data, timeout, reason, cid_num, cid_name, &oh);
      if (!chan) {
         ast_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. */
      if (locked_channel)
         ast_channel_lock(chan);
      if (ast_pthread_create_detached(&as->p, NULL, async_wait, as)) {
         ast_log(LOG_WARNING, "Failed to start async wait\n");
         ast_free(as);
         if (locked_channel)
            ast_channel_unlock(chan);
         ast_hangup(chan);
         res = -1;
         goto outgoing_app_cleanup;
      } else {
         if (locked_channel)
            *locked_channel = chan;
      }
      res = 0;
   }
outgoing_app_cleanup:
   ast_variables_destroy(vars);
   return res;
}

static int ast_pbx_outgoing_cdr_failed

(

void

)

[static]

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

Note:

This function posts an empty cdr for a failed spool call

Definition at line 8200 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_release(), ast_dummy_channel_alloc(), and ast_channel::cdr.

Referenced by ast_pbx_outgoing_app(), and ast_pbx_outgoing_exten().

{
   /* allocate a channel */
   struct ast_channel *chan = ast_dummy_channel_alloc();

   if (!chan)
      return -1;  /* failure */

   chan->cdr = ast_cdr_alloc();
   if (!chan->cdr) {
      /* allocation of the cdr failed */
      chan = ast_channel_release(chan);   /* free the channel */
      return -1;                /* return failure */
   }

   /* allocation of the cdr was successful */
   ast_cdr_init(chan->cdr, chan);  /* initialize 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 */
   chan->cdr = NULL;
   chan = ast_channel_release(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 **	locked_channel
	)

Synchronously or asynchronously make an outbound call and send it to a particular extension

Definition at line 8227 of file pbx.c.

References __ast_request_and_dial(), ast_channel::_state, outgoing_helper::account, ast_calloc, ast_cdr_disposition(), ast_cdr_failed(), ast_cdr_setaccount(), ast_channel_alloc, ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_exists_extension(), ast_free, ast_hangup(), ast_log(), ast_pbx_outgoing_cdr_failed(), ast_pbx_run(), ast_pbx_start(), ast_pthread_create_detached, ast_request_and_dial(), ast_set_variables(), AST_STATE_DOWN, AST_STATE_UP, ast_strlen_zero(), ast_variables_destroy(), ast_verb, async_wait(), ast_channel::cdr, async_stat::chan, outgoing_helper::cid_name, outgoing_helper::cid_num, async_stat::context, ast_channel::context, outgoing_helper::context, outgoing_helper::exten, ast_channel::hangupcause, LOG_ERROR, LOG_WARNING, ast_channel::name, async_stat::p, outgoing_helper::parent_channel, pbx_builtin_setvar_helper(), outgoing_helper::priority, set_ext_pri(), async_stat::timeout, and outgoing_helper::vars.

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

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

   if (synchronous) {
      oh.context = context;
      oh.exten = exten;
      oh.priority = priority;
      oh.cid_num = cid_num;
      oh.cid_name = cid_name;
      oh.account = account;
      oh.vars = vars;
      oh.parent_channel = NULL;

      chan = __ast_request_and_dial(type, format, NULL, data, timeout, reason, cid_num, cid_name, &oh);
      if (channel) {
         *channel = chan;
         if (chan)
            ast_channel_lock(chan);
      }
      if (chan) {
         if (chan->_state == AST_STATE_UP) {
               res = 0;
            ast_verb(4, "Channel %s was answered.\n", chan->name);

            if (synchronous > 1) {
               if (channel)
                  ast_channel_unlock(chan);
               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);
                  chan = NULL;
                  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_channel_unlock(chan);
                  }
                  ast_hangup(chan);
                  res = -1;
               }
               chan = NULL;
            }
         } else {
            ast_verb(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_channel_unlock(chan);
            }
            ast_hangup(chan);
            chan = NULL;
         }
      }

      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, AST_STATE_DOWN, 0, 0, "", "", "", NULL, 0, "OutgoingSpoolFailed");
            if (chan) {
               char failed_reason[4] = "";
               if (!ast_strlen_zero(context))
                  ast_copy_string(chan->context, context, sizeof(chan->context));
               set_ext_pri(chan, "failed", 1);
               ast_set_variables(chan, vars);
               snprintf(failed_reason, sizeof(failed_reason), "%d", *reason);
               pbx_builtin_setvar_helper(chan, "REASON", failed_reason);
               if (account)
                  ast_cdr_setaccount(chan, account);
               if (ast_pbx_run(chan)) {
                  ast_log(LOG_ERROR, "Unable to run PBX on %s\n", chan->name);
                  ast_hangup(chan);
               }
               chan = NULL;
            }
         }
      }
   } else {
      if (!(as = ast_calloc(1, sizeof(*as)))) {
         res = -1;
         goto outgoing_exten_cleanup;
      }
      chan = ast_request_and_dial(type, format, NULL, data, timeout, reason, cid_num, cid_name);
      if (channel) {
         *channel = chan;
         if (chan)
            ast_channel_lock(chan);
      }
      if (!chan) {
         ast_free(as);
         res = -1;
         goto outgoing_exten_cleanup;
      }
      as->chan = chan;
      ast_copy_string(as->context, context, sizeof(as->context));
      set_ext_pri(as->chan,  exten, priority);
      as->timeout = timeout;
      ast_set_variables(chan, vars);
      if (account)
         ast_cdr_setaccount(chan, account);
      if (ast_pthread_create_detached(&as->p, NULL, async_wait, as)) {
         ast_log(LOG_WARNING, "Failed to start async wait\n");
         ast_free(as);
         if (channel) {
            *channel = NULL;
            ast_channel_unlock(chan);
         }
         ast_hangup(chan);
         res = -1;
         goto outgoing_exten_cleanup;
      }
      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

This executes the PBX on a given channel. It allocates a new PBX structure for the channel, and provides all PBX functionality. See ast_pbx_start for an asynchronous function to run the PBX in a new thread as opposed to the current one.

Return values:

	Zero	on success
	non-zero	on failure

Definition at line 4929 of file pbx.c.

References ast_pbx_run_args().

Referenced by __analog_ss_thread(), analog_ss_thread(), ast_pbx_outgoing_exten(), async_wait(), do_notify(), mgcp_ss(), skinny_newcall(), and unistim_ss().

{
   return ast_pbx_run_args(c, NULL);
}

static void* ast_pbx_run_app

(

void *

data

)

[static]

run the application and free the descriptor once done

Definition at line 8378 of file pbx.c.

References app_tmp::app, ast_free, ast_hangup(), ast_log(), ast_verb, app_tmp::chan, app_tmp::data, LOG_WARNING, ast_channel::name, pbx_exec(), and pbx_findapp().

Referenced by ast_pbx_outgoing_app().

{
   struct app_tmp *tmp = data;
   struct ast_app *app;
   app = pbx_findapp(tmp->app);
   if (app) {
      ast_verb(4, "Launching %s(%s) on %s\n", tmp->app, tmp->data, tmp->chan->name);
      pbx_exec(tmp->chan, app, tmp->data);
   } else
      ast_log(LOG_WARNING, "No such application '%s'\n", tmp->app);
   ast_hangup(tmp->chan);
   ast_free(tmp);
   return NULL;
}

enum ast_pbx_result ast_pbx_run_args	(	struct ast_channel *	c,
		struct ast_pbx_args *	args
	)

Execute the PBX in the current thread.

Parameters:

	c	channel to run the pbx on
	args	options for the pbx

This executes the PBX on a given channel. It allocates a new PBX structure for the channel, and provides all PBX functionality. See ast_pbx_start for an asynchronous function to run the PBX in a new thread as opposed to the current one.

Return values:

	Zero	on success
	non-zero	on failure

Definition at line 4914 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_run(), dial_exec_full(), handle_gosub(), and try_calling().

{
   enum ast_pbx_result res = AST_PBX_SUCCESS;

   if (increase_call_count(c)) {
      return AST_PBX_CALL_LIMIT;
   }

   res = __ast_pbx_run(c, args);

   decrease_call_count();

   return res;
}

enum ast_pbx_result ast_pbx_start

(

struct ast_channel *

c

)

Create a new thread and start the PBX.

Parameters:

c

channel to start the pbx on

See also:

ast_pbx_run for a synchronous function to run the PBX in the current thread, as opposed to starting a new one.

Return values:

	Zero	on success
	non-zero	on failure

Definition at line 4892 of file pbx.c.

References ast_log(), AST_PBX_CALL_LIMIT, AST_PBX_FAILED, AST_PBX_SUCCESS, ast_pthread_create_detached, decrease_call_count(), increase_call_count(), LOG_WARNING, and pbx_thread().

Referenced by __oh323_new(), alsa_new(), ast_async_goto(), ast_iax2_new(), ast_pbx_outgoing_exten(), bridge_call_thread(), bridge_exec(), check_goto_on_transfer(), console_new(), dahdi_new(), dial_exec_full(), gtalk_new(), gtalk_newcall(), handle_request_invite(), jingle_new(), jingle_newcall(), local_call(), manage_parkinglot(), mgcp_new(), nbs_new(), oss_new(), pbx_start_chan(), phone_new(), rpt_call(), sip_new(), skinny_new(), unistim_new(), and usbradio_new().

{
   pthread_t t;

   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. */
   if (ast_pthread_create_detached(&t, NULL, pbx_thread, c)) {
      ast_log(LOG_WARNING, "Failed to create new channel thread\n");
      decrease_call_count();
      return AST_PBX_FAILED;
   }

   return AST_PBX_SUCCESS;
}

int ast_processed_calls

(

void

)

Retrieve the total number of calls processed through the PBX since last restart.

Definition at line 4939 of file pbx.c.

References totalcalls.

Referenced by ast_var_Config(), handle_chanlist(), and handle_showcalls().

{
   return totalcalls;
}

int ast_rdlock_context

(

struct ast_context *

con

)

Read locks a given context.

Parameters:

con

context to lock

Return values:

	0	on success
	-1	on failure

Definition at line 9642 of file pbx.c.

References ast_rwlock_rdlock(), and ast_context::lock.

Referenced by _macro_exec(), complete_dialplan_remove_ignorepat(), complete_dialplan_remove_include(), dundi_precache_full(), find_matching_endwhile(), handle_cli_dialplan_save(), lookup_c_ip(), lookup_ci(), manager_show_dialplan_helper(), show_debug_helper(), and show_dialplan_helper().

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

int ast_rdlock_contexts

(

void

)

Read locks the context list.

Return values:

	0	on success
	-1	on error

Definition at line 9624 of file pbx.c.

References ast_rwlock_rdlock(), and conlock.

Referenced by _macro_exec(), ast_context_find(), ast_context_find_or_create(), ast_context_lockmacro(), ast_context_unlockmacro(), ast_hint_extension(), ast_merge_contexts_and_delete(), complete_dialplan_add_extension(), complete_dialplan_add_ignorepat(), complete_dialplan_add_include(), complete_dialplan_remove_extension(), complete_dialplan_remove_ignorepat(), complete_dialplan_remove_include(), complete_show_dialplan_context(), dundi_precache_full(), find_context_locked(), find_matching_endwhile(), handle_cli_dialplan_save(), handle_statechange(), manager_show_dialplan_helper(), pbx_extension_helper(), show_debug_helper(), show_dialplan_helper(), and unreference_cached_app().

{
   return ast_rwlock_rdlock(&conlock);
}

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

Dynamically register a new dial plan application.

Register an application.

Definition at line 5366 of file pbx.c.

References ast_app::arguments, ast_calloc, ast_free, ast_log(), AST_RWLIST_INSERT_BEFORE_CURRENT, AST_RWLIST_INSERT_TAIL, AST_RWLIST_TRAVERSE, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, AST_STATIC_DOC, ast_string_field_init, ast_string_field_set, ast_strlen_zero(), ast_verb, AST_XML_DOC, COLOR_BRCYAN, ast_app::execute, LOG_WARNING, ast_app::module, ast_app::name, ast_app::seealso, ast_app::syntax, and term_color().

Referenced by ast_features_init(), and load_pbx().

{
   struct ast_app *tmp, *cur = NULL;
   char tmps[80];
   int length, res;
#ifdef AST_XML_DOCS
   char *tmpxml;
#endif

   AST_RWLIST_WRLOCK(&apps);
   AST_RWLIST_TRAVERSE(&apps, tmp, list) {
      if (!(res = strcasecmp(app, tmp->name))) {
         ast_log(LOG_WARNING, "Already have an application '%s'\n", app);
         AST_RWLIST_UNLOCK(&apps);
         return -1;
      } else if (res < 0)
         break;
   }

   length = sizeof(*tmp) + strlen(app) + 1;

   if (!(tmp = ast_calloc(1, length))) {
      AST_RWLIST_UNLOCK(&apps);
      return -1;
   }

   if (ast_string_field_init(tmp, 128)) {
      AST_RWLIST_UNLOCK(&apps);
      ast_free(tmp);
      return -1;
   }

#ifdef AST_XML_DOCS
   /* Try to lookup the docs in our XML documentation database */
   if (ast_strlen_zero(synopsis) && ast_strlen_zero(description)) {
      /* load synopsis */
      tmpxml = ast_xmldoc_build_synopsis("application", app);
      ast_string_field_set(tmp, synopsis, tmpxml);
      ast_free(tmpxml);

      /* load description */
      tmpxml = ast_xmldoc_build_description("application", app);
      ast_string_field_set(tmp, description, tmpxml);
      ast_free(tmpxml);

      /* load syntax */
      tmpxml = ast_xmldoc_build_syntax("application", app);
      ast_string_field_set(tmp, syntax, tmpxml);
      ast_free(tmpxml);

      /* load arguments */
      tmpxml = ast_xmldoc_build_arguments("application", app);
      ast_string_field_set(tmp, arguments, tmpxml);
      ast_free(tmpxml);

      /* load seealso */
      tmpxml = ast_xmldoc_build_seealso("application", app);
      ast_string_field_set(tmp, seealso, tmpxml);
      ast_free(tmpxml);
      tmp->docsrc = AST_XML_DOC;
   } else {
#endif
      ast_string_field_set(tmp, synopsis, synopsis);
      ast_string_field_set(tmp, description, description);
#ifdef AST_XML_DOCS
      tmp->docsrc = AST_STATIC_DOC;
   }
#endif

   strcpy(tmp->name, app);
   tmp->execute = execute;
   tmp->module = mod;

   /* Store in alphabetical order */
   AST_RWLIST_TRAVERSE_SAFE_BEGIN(&apps, cur, list) {
      if (strcasecmp(tmp->name, cur->name) < 0) {
         AST_RWLIST_INSERT_BEFORE_CURRENT(tmp, list);
         break;
      }
   }
   AST_RWLIST_TRAVERSE_SAFE_END;
   if (!cur)
      AST_RWLIST_INSERT_TAIL(&apps, tmp, list);

   ast_verb(2, "Registered application '%s'\n", term_color(tmps, tmp->name, COLOR_BRCYAN, 0, sizeof(tmps)));

   AST_RWLIST_UNLOCK(&apps);

   return 0;
}

int ast_register_switch

(

struct ast_switch *

sw

)

Register an alternative dialplan switch.

Parameters:

sw

switch to register

This function registers a populated ast_switch structure with the asterisk switching architecture.

Return values:

	0	success
	non-zero	failure

Definition at line 5461 of file pbx.c.

References ast_log(), AST_RWLIST_INSERT_TAIL, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, LOG_WARNING, and ast_switch::name.

Referenced by load_module().

{
   struct ast_switch *tmp;

   AST_RWLIST_WRLOCK(&switches);
   AST_RWLIST_TRAVERSE(&switches, tmp, list) {
      if (!strcasecmp(tmp->name, sw->name)) {
         AST_RWLIST_UNLOCK(&switches);
         ast_log(LOG_WARNING, "Switch '%s' already found\n", sw->name);
         return -1;
      }
   }
   AST_RWLIST_INSERT_TAIL(&switches, sw, list);
   AST_RWLIST_UNLOCK(&switches);

   return 0;
}

static int ast_remove_hint

(

struct ast_exten *

e

)

[static]

Remove hint from extension.

Definition at line 4407 of file pbx.c.

References AST_EXTENSION_DEACTIVATED, ast_free, AST_LIST_REMOVE_HEAD, AST_RWLIST_REMOVE_CURRENT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, ast_state_cb::callback, ast_hint::callbacks, ast_state_cb::data, ast_exten::exten, ast_hint::exten, ast_context::name, and ast_exten::parent.

Referenced by destroy_exten().

{
   /* Cleanup the Notifys if hint is removed */
   struct ast_hint *hint;
   struct ast_state_cb *cblist;
   int res = -1;

   if (!e)
      return -1;

   AST_RWLIST_TRAVERSE_SAFE_BEGIN(&hints, hint, list) {
      if (hint->exten != e)
         continue;

      while ((cblist = AST_LIST_REMOVE_HEAD(&hint->callbacks, entry))) {
         /* Notify with -1 and remove all callbacks */
         cblist->callback(hint->exten->parent->name, hint->exten->exten,
            AST_EXTENSION_DEACTIVATED, cblist->data);
         ast_free(cblist);
      }

      AST_RWLIST_REMOVE_CURRENT(list);
      ast_free(hint);

      res = 0;

      break;
   }
   AST_RWLIST_TRAVERSE_SAFE_END;

   return res;
}

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

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
	found
	combined_find_spawn	This adds a new extension to the asterisk extension list.

Note:

It is possible for autoservice to be started and stopped on c during this function call, it is important that c is not locked prior to calling this. Otherwise a deadlock may occur

Return values:

	0	on success
	-1	on failure.

Definition at line 4505 of file pbx.c.

References E_SPAWN, and pbx_extension_helper().

Referenced by __ast_pbx_run(), _macro_exec(), ast_bridge_call(), dial_exec_full(), and loopback_exec().

{
   return pbx_extension_helper(c, NULL, context, exten, priority, NULL, callerid, E_SPAWN, found, combined_find_spawn);
}

int ast_str_get_hint	(	struct ast_str **	hint,
		ssize_t	hintsize,
		struct ast_str **	name,
		ssize_t	namesize,
		struct ast_channel *	c,
		const char *	context,
		const char *	exten
	)

Get hint for channel.

If an extension hint exists, return non-zero.

Definition at line 4460 of file pbx.c.

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

Referenced by ast_str_retrieve_variable().

{
   struct ast_exten *e = ast_hint_extension(c, context, exten);

   if (!e) {
      return 0;
   }

   if (hint) {
      ast_str_set(hint, hintsize, "%s", ast_get_extension_app(e));
   }
   if (name) {
      const char *tmp = ast_get_extension_app_data(e);
      if (tmp) {
         ast_str_set(name, namesize, "%s", tmp);
      }
   }
   return -1;
}

const char* ast_str_retrieve_variable	(	struct ast_str **	buf,
		ssize_t	maxlen,
		struct ast_channel *	chan,
		struct varshead *	headp,
		const char *	var
	)

Parameters:

	buf	Result will be placed in this buffer.
	maxlen	-1 if the buffer should not grow, 0 if the buffer may grow to any size, and >0 if the buffer should grow only to that number of bytes.
	chan	Channel variables from which to extract values, and channel to pass to any dialplan functions.
	headp	If no channel is specified, a channel list from which to extract variable values
	var	Variable name to retrieve.

Definition at line 2929 of file pbx.c.

References ARRAY_LEN, ast_channel_lock, ast_channel_unlock, ast_config_AST_SYSTEM_NAME, ast_debug, ast_eid_default, ast_eid_to_str(), AST_LIST_TRAVERSE, ast_rwlock_rdlock(), ast_rwlock_unlock(), ast_str_buffer(), ast_str_get_hint(), ast_str_set(), ast_str_substring(), ast_strdupa, ast_var_name(), ast_var_value(), ast_channel::cid, ast_callerid::cid_ani2, ast_callerid::cid_pres, ast_callerid::cid_tns, ast_callerid::cid_ton, ast_channel::context, ast_var_t::entries, ast_channel::exten, globals, globalslock, ast_channel::hangupcause, ast_channel::name, parse_variable_name(), ast_channel::priority, s, ast_channel::uniqueid, and ast_channel::varshead.

Referenced by ast_str_substitute_variables_full(), and pbx_retrieve_variable().

{
   const char not_found = '\0';
   char *tmpvar;
   const char *ret;
   const char *s; /* the result */
   int offset, length;
   int i, need_substring;
   struct varshead *places[2] = { headp, &globals };  /* list of places where we may look */

   if (c) {
      ast_channel_lock(c);
      places[0] = &c->varshead;
   }
   /*
    * Make a copy of var because parse_variable_name() modifies the string.
    * Then if called directly, we might need to run substring() on the result;
    * remember this for later in 'need_substring', 'offset' and 'length'
    */
   tmpvar = ast_strdupa(var); /* parse_variable_name modifies the string */
   need_substring = parse_variable_name(tmpvar, &offset, &length, &i /* ignored */);

   /*
    * Look first into predefined variables, then into variable lists.
    * Variable 's' points to the result, according to the following rules:
    * s == &not_found (set at the beginning) means that we did not find a
    * matching variable and need to look into more places.
    * If s != &not_found, s is a valid result string as follows:
    * s = NULL if the variable does not have a value;
    * you typically do this when looking for an unset predefined variable.
    * s = workspace if the result has been assembled there;
    * typically done when the result is built e.g. with an snprintf(),
    * so we don't need to do an additional copy.
    * s != workspace in case we have a string, that needs to be copied
    * (the ast_copy_string is done once for all at the end).
    * Typically done when the result is already available in some string.
    */
   s = &not_found;   /* default value */
   if (c) { /* This group requires a valid channel */
      /* Names with common parts are looked up a piece at a time using strncmp. */
      if (!strncmp(var, "CALL", 4)) {
         if (!strncmp(var + 4, "ING", 3)) {
            if (!strcmp(var + 7, "PRES")) {        /* CALLINGPRES */
               ast_str_set(str, maxlen, "%d", c->cid.cid_pres);
               s = ast_str_buffer(*str);
            } else if (!strcmp(var + 7, "ANI2")) {    /* CALLINGANI2 */
               ast_str_set(str, maxlen, "%d", c->cid.cid_ani2);
               s = ast_str_buffer(*str);
            } else if (!strcmp(var + 7, "TON")) {     /* CALLINGTON */
               ast_str_set(str, maxlen, "%d", c->cid.cid_ton);
               s = ast_str_buffer(*str);
            } else if (!strcmp(var + 7, "TNS")) {     /* CALLINGTNS */
               ast_str_set(str, maxlen, "%d", c->cid.cid_tns);
               s = ast_str_buffer(*str);
            }
         }
      } else if (!strcmp(var, "HINT")) {
         s = ast_str_get_hint(str, maxlen, NULL, 0, c, c->context, c->exten) ? ast_str_buffer(*str) : NULL;
      } else if (!strcmp(var, "HINTNAME")) {
         s = ast_str_get_hint(NULL, 0, str, maxlen, c, c->context, c->exten) ? ast_str_buffer(*str) : NULL;
      } else if (!strcmp(var, "EXTEN")) {
         s = c->exten;
      } else if (!strcmp(var, "CONTEXT")) {
         s = c->context;
      } else if (!strcmp(var, "PRIORITY")) {
         ast_str_set(str, maxlen, "%d", c->priority);
         s = ast_str_buffer(*str);
      } else if (!strcmp(var, "CHANNEL")) {
         s = c->name;
      } else if (!strcmp(var, "UNIQUEID")) {
         s = c->uniqueid;
      } else if (!strcmp(var, "HANGUPCAUSE")) {
         ast_str_set(str, maxlen, "%d", c->hangupcause);
         s = ast_str_buffer(*str);
      }
   }
   if (s == &not_found) { /* look for more */
      if (!strcmp(var, "EPOCH")) {
         ast_str_set(str, maxlen, "%u", (int) time(NULL));
         s = ast_str_buffer(*str);
      } else if (!strcmp(var, "SYSTEMNAME")) {
         s = ast_config_AST_SYSTEM_NAME;
      } else if (!strcmp(var, "ENTITYID")) {
         char workspace[20];
         ast_eid_to_str(workspace, sizeof(workspace), &ast_eid_default);
         s = workspace;
      }
   }
   /* if not found, look into chanvars or global vars */
   for (i = 0; s == &not_found && i < ARRAY_LEN(places); i++) {
      struct ast_var_t *variables;
      if (!places[i])
         continue;
      if (places[i] == &globals)
         ast_rwlock_rdlock(&globalslock);
      AST_LIST_TRAVERSE(places[i], variables, entries) {
         if (!strcasecmp(ast_var_name(variables), var)) {
            s = ast_var_value(variables);
            break;
         }
      }
      if (places[i] == &globals)
         ast_rwlock_unlock(&globalslock);
   }
   if (s == &not_found || s == NULL) {
      ast_debug(5, "Result of '%s' is NULL\n", var);
      ret = NULL;
   } else {
      ast_debug(5, "Result of '%s' is '%s'\n", var, s);
      if (s != ast_str_buffer(*str)) {
         ast_str_set(str, maxlen, "%s", s);
      }
      ret = ast_str_buffer(*str);
      if (need_substring) {
         ret = ast_str_substring(*str, offset, length);
         ast_debug(2, "Final result of '%s' is '%s'\n", var, ret);
      }
   }

   if (c) {
      ast_channel_unlock(c);
   }
   return ret;
}

void ast_str_substitute_variables	(	struct ast_str **	buf,
		ssize_t	maxlen,
		struct ast_channel *	chan,
		const char *	templ
	)

Parameters:

	buf	Result will be placed in this buffer.
	maxlen	-1 if the buffer should not grow, 0 if the buffer may grow to any size, and >0 if the buffer should grow only to that number of bytes.
	chan	Channel variables from which to extract values, and channel to pass to any dialplan functions.
	templ	Variable template to expand.

Definition at line 3709 of file pbx.c.

References ast_str_substitute_variables_full().

Referenced by _macro_exec(), acf_odbc_read(), acf_odbc_write(), cli_odbc_read(), cli_odbc_write(), config_curl(), custom_log(), cut_internal(), destroy_curl(), exec_exec(), func_mchan_read(), function_eval2(), function_fieldqty_helper(), handle_getvariablefull(), import_helper(), make_email_file(), realtime_curl(), realtime_multi_curl(), require_curl(), sendmail(), sendpage(), store_curl(), syslog_log(), tryexec_exec(), update2_curl(), and update_curl().

{
   size_t used;
   ast_str_substitute_variables_full(buf, maxlen, chan, NULL, templ, &used);
}

void ast_str_substitute_variables_full	(	struct ast_str **	buf,
		ssize_t	maxlen,
		struct ast_channel *	c,
		struct varshead *	headp,
		const char *	templ,
		size_t *	used
	)

Parameters:

	buf	Result will be placed in this buffer.
	maxlen	-1 if the buffer should not grow, 0 if the buffer may grow to any size, and >0 if the buffer should grow only to that number of bytes.
	c	Channel variables from which to extract values, and channel to pass to any dialplan functions.
	headp	If no channel is specified, a channel list from which to extract variable values
	templ	Variable template to expand.
	used	Number of bytes read from the template.

Definition at line 3533 of file pbx.c.

References ast_channel_release(), ast_debug, ast_dummy_channel_alloc(), ast_free, ast_func_read2(), ast_log(), ast_str_append(), ast_str_append_substr(), ast_str_buffer(), ast_str_create(), ast_str_expr(), ast_str_reset(), ast_str_retrieve_variable(), ast_str_set_substr(), ast_str_strlen(), ast_str_substitute_variables_full(), ast_str_substring(), ast_strlen_zero(), len(), LOG_ERROR, LOG_WARNING, parse_variable_name(), and ast_channel::varshead.

Referenced by ast_str_substitute_variables(), ast_str_substitute_variables_full(), and ast_str_substitute_variables_varshead().

{
   /* Substitutes variables into buf, based on string templ */
   char *cp4 = NULL;
   const char *tmp, *whereweare;
   int orig_size = 0;
   int offset, offset2, isfunction;
   const char *nextvar, *nextexp, *nextthing;
   const char *vars, *vare;
   char *finalvars;
   int pos, brackets, needsub, len;
   struct ast_str *substr1 = ast_str_create(16), *substr2 = NULL, *substr3 = ast_str_create(16);

   ast_str_reset(*buf);
   whereweare = tmp = templ;
   while (!ast_strlen_zero(whereweare)) {
      /* 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;
         default:
            pos = 1;
         }
      }

      if (pos) {
         /* Copy that many bytes */
         ast_str_append_substr(buf, maxlen, whereweare, pos);

         templ += 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_WARNING, "Error in extension logic (missing '}')\n");
         len = vare - vars - 1;

         /* Skip totally over variable string */
         whereweare += (len + 3);

         /* Store variable name (and truncate) */
         ast_str_set_substr(&substr1, 0, vars, len);
         ast_debug(5, "Evaluating '%s' (from '%s' len %d)\n", ast_str_buffer(substr1), vars, len);

         /* Substitute if necessary */
         if (needsub) {
            size_t used;
            if (!substr2) {
               substr2 = ast_str_create(16);
            }

            ast_str_substitute_variables_full(&substr2, 0, c, headp, ast_str_buffer(substr1), &used);
            finalvars = ast_str_buffer(substr2);
         } else {
            finalvars = ast_str_buffer(substr1);
         }

         parse_variable_name(finalvars, &offset, &offset2, &isfunction);
         if (isfunction) {
            /* Evaluate function */
            if (c || !headp) {
               cp4 = ast_func_read2(c, finalvars, &substr3, 0) ? NULL : ast_str_buffer(substr3);
            } else {
               struct varshead old;
               struct ast_channel *bogus = ast_dummy_channel_alloc();
               if (bogus) {
                  memcpy(&old, &bogus->varshead, sizeof(old));
                  memcpy(&bogus->varshead, headp, sizeof(bogus->varshead));
                  cp4 = ast_func_read2(c, finalvars, &substr3, 0) ? NULL : ast_str_buffer(substr3);
                  /* Don't deallocate the varshead that was passed in */
                  memcpy(&bogus->varshead, &old, sizeof(bogus->varshead));
                  ast_channel_release(bogus);
               } else {
                  ast_log(LOG_ERROR, "Unable to allocate bogus channel for variable substitution.  Function results may be blank.\n");
               }
            }
            ast_debug(2, "Function result is '%s'\n", cp4 ? cp4 : "(null)");
         } else {
            /* Retrieve variable value */
            ast_str_retrieve_variable(&substr3, 0, c, headp, finalvars);
            cp4 = ast_str_buffer(substr3);
         }
         if (cp4) {
            ast_str_substring(substr3, offset, offset2);
            ast_str_append(buf, maxlen, "%s", ast_str_buffer(substr3));
         }
      } else if (nextexp) {
         /* We have an expression.  Find the start and end, and determine
            if we are going to have to recursively call ourselves on the
            contents */
         vars = vare = nextexp + 2;
         brackets = 1;
         needsub = 0;

         /* Find the end of it */
         while (brackets && *vare) {
            if ((vare[0] == '$') && (vare[1] == '[')) {
               needsub++;
               brackets++;
               vare++;
            } else if (vare[0] == '[') {
               brackets++;
            } else if (vare[0] == ']') {
               brackets--;
            } else if ((vare[0] == '$') && (vare[1] == '{')) {
               needsub++;
               vare++;
            }
            vare++;
         }
         if (brackets)
            ast_log(LOG_WARNING, "Error in extension logic (missing ']')\n");
         len = vare - vars - 1;

         /* Skip totally over expression */
         whereweare += (len + 3);

         /* Store variable name (and truncate) */
         ast_str_set_substr(&substr1, 0, vars, len);

         /* Substitute if necessary */
         if (needsub) {
            size_t used;
            if (!substr2) {
               substr2 = ast_str_create(16);
            }

            ast_str_substitute_variables_full(&substr2, 0, c, headp, ast_str_buffer(substr1), &used);
            finalvars = ast_str_buffer(substr2);
         } else {
            finalvars = ast_str_buffer(substr1);
         }

         if (ast_str_expr(&substr3, 0, c, finalvars)) {
            ast_debug(2, "Expression result is '%s'\n", ast_str_buffer(substr3));
         }
         ast_str_append(buf, maxlen, "%s", ast_str_buffer(substr3));
      }
   }
   *used = ast_str_strlen(*buf) - orig_size;
   ast_free(substr1);
   ast_free(substr2);
   ast_free(substr3);
}

void ast_str_substitute_variables_varshead	(	struct ast_str **	buf,
		ssize_t	maxlen,
		struct varshead *	headp,
		const char *	templ
	)

Parameters:

	buf	Result will be placed in this buffer.
	maxlen	-1 if the buffer should not grow, 0 if the buffer may grow to any size, and >0 if the buffer should grow only to that number of bytes.
	headp	If no channel is specified, a channel list from which to extract variable values
	templ	Variable template to expand.

Definition at line 3715 of file pbx.c.

References ast_str_substitute_variables_full().

Referenced by add_user_extension(), build_user_routes(), phoneprov_callback(), pp_each_extension_helper(), and pp_each_user_helper().

{
   size_t used;
   ast_str_substitute_variables_full(buf, maxlen, NULL, headp, templ, &used);
}

static const char* ast_str_substring	(	struct ast_str *	value,
		int	offset,
		int	length
	)			[static]

Definition at line 2864 of file pbx.c.

References ast_str_buffer(), ast_str_reset(), ast_str_strlen(), and ast_str_update().

Referenced by ast_str_retrieve_variable(), and ast_str_substitute_variables_full().

{
   int lr;  /* length of the input string after the copy */

   lr = ast_str_strlen(value); /* compute length after copy, so we never go out of the workspace */

   /* Quick check if no need to do anything */
   if (offset == 0 && length >= lr) /* take the whole string */
      return ast_str_buffer(value);

   if (offset < 0)   {  /* translate negative offset into positive ones */
      offset = lr + offset;
      if (offset < 0) /* If the negative offset was greater than the length of the string, just start at the beginning */
         offset = 0;
   }

   /* too large offset result in empty string so we know what to return */
   if (offset >= lr) {
      ast_str_reset(value);
      return ast_str_buffer(value);
   }

   if (offset > 0) {
      /* Go ahead and chop off the beginning */
      memcpy(ast_str_buffer(value), ast_str_buffer(value) + offset, ast_str_strlen(value) - offset + 1);
      lr -= offset;
   }

   if (length >= 0 && length < lr) {   /* truncate if necessary */
      char *tmp = ast_str_buffer(value);
      tmp[length] = '\0';
      ast_str_update(value);
   } else if (length < 0) {
      if (lr > -length) { /* After we remove from the front and from the rear, is there anything left? */
         char *tmp = ast_str_buffer(value);
         tmp[lr + length] = '\0';
         ast_str_update(value);
      } else {
         ast_str_reset(value);
      }
   } else {
      /* Nothing to do, but update the buffer length */
      ast_str_update(value);
   }

   return ast_str_buffer(value);
}

int ast_unlock_context

(

struct ast_context *

con

)

Return values:

Unlocks

the given context

Parameters:

con

context to unlock

Return values:

	0	on success
	-1	on failure

Definition at line 9647 of file pbx.c.

References ast_rwlock_unlock(), and ast_context::lock.

Referenced by __ast_context_destroy(), _macro_exec(), ast_add_extension2_lockopt(), ast_context_add_ignorepat2(), ast_context_add_include2(), ast_context_add_switch2(), ast_context_remove_extension_callerid2(), ast_context_remove_ignorepat2(), ast_context_remove_include2(), ast_context_remove_switch2(), complete_dialplan_remove_ignorepat(), complete_dialplan_remove_include(), dundi_precache_full(), find_matching_endwhile(), handle_cli_dialplan_save(), lookup_c_ip(), lookup_ci(), manager_show_dialplan_helper(), show_debug_helper(), and show_dialplan_helper().

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

int ast_unlock_contexts

(

void

)

Unlocks contexts.

Return values:

	0	on success
	-1	on failure

Definition at line 9629 of file pbx.c.

References ast_rwlock_unlock(), and conlock.

Referenced by _macro_exec(), ast_add_extension(), ast_context_add_ignorepat(), ast_context_add_include(), ast_context_add_switch(), ast_context_destroy(), ast_context_find(), ast_context_find_or_create(), ast_context_lockmacro(), ast_context_remove_extension_callerid(), ast_context_remove_ignorepat(), ast_context_remove_include(), ast_context_remove_switch(), ast_context_unlockmacro(), ast_hint_extension(), ast_merge_contexts_and_delete(), complete_dialplan_add_extension(), complete_dialplan_add_ignorepat(), complete_dialplan_add_include(), complete_dialplan_remove_extension(), complete_dialplan_remove_ignorepat(), complete_dialplan_remove_include(), complete_show_dialplan_context(), dundi_precache_full(), find_context_locked(), find_matching_endwhile(), handle_cli_dialplan_save(), handle_statechange(), manager_show_dialplan_helper(), pbx_extension_helper(), show_debug_helper(), show_dialplan_helper(), and unreference_cached_app().

{
   return ast_rwlock_unlock(&conlock);
}

</