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 <sys/sysinfo.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/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/presencestate.h"
#include "asterisk/hashtab.h"
#include "asterisk/module.h"
#include "asterisk/indications.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/xmldoc.h"
#include "asterisk/astobj2.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/dial.h"
#include "asterisk/vector.h"
#include "pbx_private.h"

Include dependency graph for pbx.c:

Go to the source code of this file.

Data Structures
struct	ast_autohint
	Structure for dial plan autohints. More...
struct	ast_context
	ast_context: An extension context - must remain in sync with fake_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_hintdevice
	Structure for dial plan hint devices. More...
struct	ast_state_cb
	ast_state_cb: An extension state notify register item More...
struct	cfextension_states
struct	dialplan_counters
	Counters for the show dialplan manager command. More...
struct	fake_context
struct	match_char
	match_char: forms a syntax tree for quick matching of extension patterns More...
struct	pattern_node
struct	pbx_exception
struct	pbx_outgoing
	Structure which contains information about an outgoing dial. More...
struct	scoreboard
struct	store_hint
struct	store_hints

Macros
#define	ADVANCE(s)   candidate_exten_advance(s)
#define	BITS_PER   8 /* Number of bits per unit (byte). */
#define	EXT_DATA_SIZE   8192
#define	HASH_EXTENHINT_SIZE   563
#define	HINTDEVICE_DATA_LENGTH   16
#define	INC_DST_OVERFLOW_CHECK
#define	MORE(s)   (*candidate_exten_advance(s))
#define	NEW_MATCHER_CHK_MATCH
#define	NEW_MATCHER_RECURSE
#define	SAY_STUBS   /* generate declarations and stubs for say methods */
#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_HARDTRAN   3
#define	VAR_NORMAL   1
#define	VAR_SOFTTRAN   2

Functions
void	__ast_context_destroy (struct ast_context *list, struct ast_hashtab *contexttab, struct ast_context *con, const char *registrar)
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	__init_extensionstate_buf (void)
static void	__init_hintdevice_data (void)
static void	__init_switch_data (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	action_extensionstatelist (struct mansession *s, const struct message *m)
static struct match_char *	add_exten_to_pattern_tree (struct ast_context *con, struct ast_exten *e1, int findonly)
static int	add_hintdevice (struct ast_hint *hint, const char *devicelist)
	add hintdevice structure and link it into the container. More...
static struct match_char *	add_pattern_node (struct ast_context *con, struct match_char *current, const struct pattern_node *pattern, int is_pattern, int already, struct match_char **nextcharptr)
static int	add_priority (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. More...
static struct ao2_container *	alloc_device_state_info (void)
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. More...
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. More...
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, const char *registrar_file, int registrar_line)
	Main interface to add extensions to the list for out context. More...
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, const char *registrar_file, int registrar_line, int lock_context)
	Same as ast_add_extension2() but controls the context locking. More...
int	ast_add_extension2_nolock (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, const char *registrar_file, int registrar_line)
	Same as ast_add_extension2, but assumes you have already locked context. More...
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. More...
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. More...
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. More...
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_canmatch_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
	Looks for a valid matching extension. More...
static int	ast_change_hint (struct ast_exten *oe, struct ast_exten *ne)
	Change hint for an extension. More...
int	ast_context_add_ignorepat (const char *context, const char *value, const char *registrar)
	Add an ignorepat. More...
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. More...
int	ast_context_add_include2 (struct ast_context *con, const char *value, const char *registrar)
	Add a context include. More...
int	ast_context_add_switch (const char *context, const char *sw, const char *data, int eval, const char *registrar)
	Add a switch. More...
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) More...
void	ast_context_destroy (struct ast_context *con, const char *registrar)
	Destroy a context (matches the specified context or ANY context if NULL) More...
int	ast_context_destroy_by_name (const char *context, const char *registrar)
	Destroy a context by name. More...
struct ast_context *	ast_context_find (const char *name)
	Find a context. More...
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. More...
int	ast_context_ignorepats_count (const struct ast_context *con)
const struct ast_ignorepat *	ast_context_ignorepats_get (const struct ast_context *con, int idx)
int	ast_context_includes_count (const struct ast_context *con)
const struct ast_include *	ast_context_includes_get (const struct ast_context *con, int idx)
int	ast_context_lockmacro (const char *context)
	locks the macrolock in the given context More...
int	ast_context_remove_extension (const char *context, const char *extension, int priority, const char *registrar)
	Simply remove extension from context. More...
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. More...
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 ... More...
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. More...
int	ast_context_remove_switch (const char *context, const char *sw, const char *data, const char *registrar)
	Remove a switch. More...
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. More...
void	ast_context_set_autohints (struct ast_context *con, int enabled)
	Enable or disable autohints support on a context. More...
int	ast_context_switches_count (const struct ast_context *con)
const struct ast_sw *	ast_context_switches_get (const struct ast_context *con, int idx)
int	ast_context_unlockmacro (const char *context)
	Unlocks the macrolock in the given context. More...
int	ast_context_verify_includes (struct ast_context *con)
	Verifies includes in an ast_contect structure. More...
enum ast_extension_states	ast_devstate_to_extenstate (enum ast_device_state devstate)
	Map devstate to an extension state. More...
int	ast_exists_extension (struct ast_channel *c, const char *context, const char *exten, int priority, const char *callerid)
	Determine whether an extension exists. More...
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. More...
int	ast_extension_match (const char *pattern, const char *data)
	Determine if a given extension matches a given pattern (in NXX format) More...
int	ast_extension_state (struct ast_channel *c, const char *context, const char *exten)
	Check extension state for an extension by using hint. More...
static int	ast_extension_state2 (struct ast_exten *e, struct ao2_container *device_state_info)
	Check state of extension by using hints. More...
const char *	ast_extension_state2str (int extension_state)
	Return extension_state as string. More...
static int	ast_extension_state3 (struct ast_str *hint_app, struct ao2_container *device_state_info)
int	ast_extension_state_add (const char *context, const char *exten, ast_state_cb_type change_cb, void *data)
	Add watcher for extension states. More...
int	ast_extension_state_add_destroy (const char *context, const char *exten, ast_state_cb_type change_cb, ast_state_cb_destroy_type destroy_cb, void *data)
	Add watcher for extension states with destructor. More...
int	ast_extension_state_add_destroy_extended (const char *context, const char *exten, ast_state_cb_type change_cb, ast_state_cb_destroy_type destroy_cb, void *data)
	Add watcher for extended extension states with destructor. More...
int	ast_extension_state_add_extended (const char *context, const char *exten, ast_state_cb_type change_cb, void *data)
	Add watcher for extended extension states. More...
int	ast_extension_state_del (int id, ast_state_cb_type change_cb)
	Deletes a state change watcher by ID. More...
int	ast_extension_state_extended (struct ast_channel *c, const char *context, const char *exten, struct ao2_container **device_state_info)
	Check extended extension state for an extension by using hint. More...
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. More...
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. More...
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)
const char *	ast_get_extension_registrar_file (struct ast_exten *e)
	Get name of configuration file used by registrar to register this extension. More...
int	ast_get_extension_registrar_line (struct ast_exten *e)
	Get line number of configuration file used by registrar to register this extension. More...
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. More...
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 More...
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. More...
int	ast_hint_presence_state (struct ast_channel *c, const char *context, const char *exten, char **subtype, char **message)
	Uses hint and presence state callback to get the presence state of an extension. More...
int	ast_ignore_pattern (const char *context, const char *pattern)
	Checks to see if a number should be ignored. More...
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) More...
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. More...
int	ast_parseable_goto (struct ast_channel *chan, const char *goto_string)
void	ast_pbx_h_exten_run (struct ast_channel *chan, const char *context)
	Run the h exten from the given context. More...
int	ast_pbx_init (void)
int	ast_pbx_outgoing_app (const char *type, struct ast_format_cap *cap, const char *addr, 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, const struct ast_assigned_ids *assignedids)
	Synchronously or asynchronously make an outbound call and execute an application on the channel. More...
int	ast_pbx_outgoing_app_predial (const char *type, struct ast_format_cap *cap, const char *addr, 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, const struct ast_assigned_ids *assignedids, const char *predial_callee)
int	ast_pbx_outgoing_exten (const char *type, struct ast_format_cap *cap, const char *addr, 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 **locked_channel, int early_media, const struct ast_assigned_ids *assignedids)
	Synchronously or asynchronously make an outbound call and send it to a particular extension. More...
int	ast_pbx_outgoing_exten_predial (const char *type, struct ast_format_cap *cap, const char *addr, 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 **locked_channel, int early_media, const struct ast_assigned_ids *assignedids, const char *predial_callee)
enum ast_pbx_result	ast_pbx_run (struct ast_channel *c)
	Execute the PBX in the current thread. More...
enum ast_pbx_result	ast_pbx_run_args (struct ast_channel *c, struct ast_pbx_args *args)
	Execute the PBX in the current thread. More...
enum ast_pbx_result	ast_pbx_start (struct ast_channel *c)
	Create a new thread and start the PBX. More...
int	ast_processed_calls (void)
	Retrieve the total number of calls processed through the PBX since last restart. More...
int	ast_rdlock_context (struct ast_context *con)
	Read locks a given context. More...
int	ast_rdlock_contexts (void)
	Read locks the context list. More...
static int	ast_remove_hint (struct ast_exten *e)
	Remove hint from extension. More...
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) More...
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. More...
int	ast_unlock_context (struct ast_context *con)
int	ast_unlock_contexts (void)
	Unlocks contexts. More...
struct ast_exten *	ast_walk_context_extensions (struct ast_context *con, struct ast_exten *exten)
const struct ast_ignorepat *	ast_walk_context_ignorepats (const struct ast_context *con, const struct ast_ignorepat *ip)
const struct ast_include *	ast_walk_context_includes (const struct ast_context *con, const struct ast_include *inc)
const struct ast_sw *	ast_walk_context_switches (const struct ast_context *con, const 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. More...
int	ast_wrlock_contexts (void)
	Write locks the context list. More...
static int	autohint_cmp (void *obj, void *arg, int flags)
static int	autohint_hash_cb (const void *obj, const int flags)
static const char *	candidate_exten_advance (const char *str)
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. More...
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' More...
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	context_table_create_autohints (struct ast_hashtab *table)
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_hint (void *obj)
static void	destroy_pattern_tree (struct match_char *pattern_tree)
static void	destroy_state_cb (void *doomed)
static void	device_state_cb (void *unused, struct stasis_subscription *sub, struct stasis_message *msg)
static void	device_state_info_dt (void *obj)
static void	device_state_notify_callbacks (struct ast_hint *hint, struct ast_str **hint_app)
static void	exception_store_free (void *data)
static int	execute_state_callback (ast_state_cb_type cb, const char *context, const char *exten, void *data, enum ast_state_cb_update_reason reason, struct ast_hint *hint, struct ao2_container *device_state_info)
static int	ext_cmp (const char *left, const char *right)
static int	ext_cmp_exten (const char *left, const char *right)
static int	ext_cmp_exten_partial (const char *left, const char *right)
static int	ext_cmp_exten_strlen (const char *str)
static int	ext_cmp_pattern (const char *left, const char *right)
static int	ext_cmp_pattern_pos (const char **p, unsigned char *bitwise)
	helper functions to sort extension patterns in the desired way, so that more specific patterns appear first. More...
static int	ext_fluff_count (const char *exten)
static unsigned int	ext_strncpy (char *dst, const char *src, size_t dst_size, int nofluff)
static int	extension_match_core (const char *pattern, const char *data, enum ext_match_t mode)
static int	extension_presence_state_helper (struct ast_exten *e, char **subtype, char **message)
static int	extension_state_add_destroy (const char *context, const char *exten, ast_state_cb_type change_cb, ast_state_cb_destroy_type destroy_cb, void *data, int extended)
static struct ast_context *	find_context (const char *context)
	lookup for a context with a given name, More...
static struct ast_context *	find_context_locked (const char *context)
	lookup for a context with a given name, More...
static int	find_hint_by_cb_id (void *obj, void *arg, int flags)
	Find Hint by callback id. More...
static struct ast_exten *	get_canmatch_exten (struct match_char *node)
static void	get_device_state_causing_channels (struct ao2_container *c)
static const char *	get_pattern_node (struct pattern_node *node, const char *src, int pattern, const char *extenbuf)
static char *	handle_debug_dialplan (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Send ack once. More...
static int	handle_hint_change_message_type (struct stasis_message *msg, enum ast_state_cb_update_reason reason)
static char *	handle_set_extenpatternmatchnew (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_device2extenstate (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_show_dialplan (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
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 More...
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 More...
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	hint_cmp (void *obj, void *arg, int flags)
static int	hint_hash (const void *obj, const int flags)
static int	hint_id_cmp (void *obj, void *arg, int flags)
static int	hintdevice_cmp_multiple (void *obj, void *arg, int flags)
static void	hintdevice_destroy (void *obj)
static int	hintdevice_hash_cb (const void *obj, const int flags)
static int	hintdevice_remove_cb (void *obj, void *arg, void *data, int flags)
static int	increase_call_count (const struct ast_channel *c)
	Increase call count for channel. More...
static void	insert_in_next_chars_alt_char_list (struct match_char **parent_ptr, struct match_char *node)
static int	internal_extension_state_extended (struct ast_channel *c, const char *context, const char *exten, struct ao2_container *device_state_info)
int	load_pbx (void)
static void	manager_dpsendack (struct mansession *s, const struct message *m)
	Send ack once. More...
static int	manager_show_dialplan (struct mansession *s, const struct message *m)
	Manager listing of dial plan. More...
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, const struct ast_include *rinclude, int includecount, const char *includes[])
	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. More...
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 char *	parse_hint_device (struct ast_str *hint_args)
static char *	parse_hint_presence (struct ast_str *hint_args)
int	pbx_checkcondition (const char *condition)
	Evaluate a condition. More...
static void	pbx_destroy (struct ast_pbx *p)
static enum ast_control_frame_type	pbx_dial_reason (enum ast_dial_result dial_result, int cause)
	Attempt to convert disconnect cause to old originate reason. More...
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: More...
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)
static int	pbx_outgoing_attempt (const char *type, struct ast_format_cap *cap, const char *addr, int timeout, const char *context, const char *exten, int priority, 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, int early_media, const struct ast_assigned_ids *assignedids, const char *predial_callee)
static void	pbx_outgoing_destroy (void *obj)
	Destructor for outgoing structure. More...
static void *	pbx_outgoing_exec (void *data)
	Internal function which dials an outgoing leg and sends it to a provided extension or application. More...
static void	pbx_outgoing_state_callback (struct ast_dial *dial)
	Internal dialing state callback which causes early media to trigger an answer. More...
static int	pbx_parseable_goto (struct ast_channel *chan, const char *goto_string, int async)
int	pbx_set_autofallthrough (int newval)
int	pbx_set_extenpatternmatchnew (int newval)
void	pbx_set_overrideswitch (const char *newval)
static void	pbx_shutdown (void)
static void *	pbx_thread (void *data)
static void	presence_state_cb (void *unused, struct stasis_subscription *sub, struct stasis_message *msg)
static void	presence_state_notify_callbacks (struct ast_hint *hint, struct ast_str **hint_app, struct ast_presence_state_message *presence_state)
static void	print_autohint_key (void *v_obj, void *where, ao2_prnt_fn *prnt)
static void	print_ext (struct ast_exten *e, char *buf, int buflen)
	helper function to print an extension More...
static void	print_hintdevices_key (void *v_obj, void *where, ao2_prnt_fn *prnt)
static void	print_hints_key (void *v_obj, void *where, ao2_prnt_fn *prnt)
static void	print_statecbs_key (void *v_obj, void *where, ao2_prnt_fn *prnt)
static int	publish_hint_change (struct ast_hint *hint, struct ast_exten *ne)
	Publish a hint changed event. More...
static int	publish_hint_remove (struct ast_hint *hint)
	Publish a hint removed event. More...
int	raise_exception (struct ast_channel *chan, const char *reason, int priority)
static int	remove_hintdevice (struct ast_hint *hint)
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, const struct ast_include *rinclude, int includecount, const char *includes[])
static void	show_dialplan_helper_extension_output (int fd, char *buf1, char *buf2, struct ast_exten *exten)
	Writes CLI output of a single extension for show dialplan. More...
	STASIS_MESSAGE_TYPE_DEFN_LOCAL (hint_change_message_type)
	STASIS_MESSAGE_TYPE_DEFN_LOCAL (hint_remove_message_type)
static int	statecbs_cmp (void *obj, void *arg, int flags)
static int	testtime_write (struct ast_channel *chan, const char *cmd, char *var, const char *value)
static struct ast_exten *	trie_find_next_match (struct match_char *node)
static void	unload_pbx (void)
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)
void	wait_for_hangup (struct ast_channel *chan, const void *data)

Variables
static int	autofallthrough = 1
static struct ao2_container *	autohints
	Container for autohint contexts. More...
static ast_mutex_t	conlock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
	Lock for the ast_context list. More...
static ast_mutex_t	context_merge_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
	Lock to hold off restructuring of hints by ast_merge_contexts_and_delete. More...
static struct ast_context *	contexts
static struct ast_hashtab *	contexts_table = NULL
static int	countcalls
static struct stasis_subscription *	device_state_sub
	Subscription for device state change events. More...
static struct ast_custom_function	exception_function
static const struct ast_datastore_info	exception_store_info
static int	extenpatternmatchnew = 0
static const 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 ast_threadstorage	hintdevice_data = { .once = PTHREAD_ONCE_INIT , .key_init = __init_hintdevice_data , .custom_init = NULL , }
static struct ao2_container *	hintdevices
	Container for hint devices. More...
static struct ao2_container *	hints
static ast_mutex_t	maxcalllock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static char *	overrideswitch = NULL
static struct ast_cli_entry	pbx_cli []
static struct stasis_subscription *	presence_state_sub
	Subscription for presence state change events. More...
static struct ao2_container *	statecbs
static int	stateid = 1
static struct ast_threadstorage	switch_data = { .once = PTHREAD_ONCE_INIT , .key_init = __init_switch_data , .custom_init = NULL , }
static struct ast_custom_function	testtime_function
static int	totalcalls

Detailed Description

Core PBX routines.

Author

Mark Spencer marks.nosp@m.ter@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

Definition in file pbx.c.

Macro Definition Documentation

ADVANCE

#define ADVANCE

(

s

)

candidate_exten_advance(s)

Definition at line 1229 of file pbx.c.

BITS_PER

#define BITS_PER   8 /* Number of bits per unit (byte). */

Referenced by ext_cmp_pattern_pos().

EXT_DATA_SIZE

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

Referenced by pbx_extension_helper().

HASH_EXTENHINT_SIZE

#define HASH_EXTENHINT_SIZE   563

Definition at line 358 of file pbx.c.

Referenced by ast_pbx_init().

HINTDEVICE_DATA_LENGTH

#define HINTDEVICE_DATA_LENGTH   16

Definition at line 351 of file pbx.c.

INC_DST_OVERFLOW_CHECK

#define INC_DST_OVERFLOW_CHECK

Referenced by get_pattern_node().

MORE

#define MORE

(

s

)

(*candidate_exten_advance(s))

Definition at line 1228 of file pbx.c.

NEW_MATCHER_CHK_MATCH

#define NEW_MATCHER_CHK_MATCH

Referenced by new_find_extension().

NEW_MATCHER_RECURSE

#define NEW_MATCHER_RECURSE

Referenced by new_find_extension().

SAY_STUBS

#define SAY_STUBS   /* generate declarations and stubs for say methods */

Definition at line 57 of file pbx.c.

STATUS_NO_CONTEXT

#define STATUS_NO_CONTEXT   1

Definition at line 2467 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

STATUS_NO_EXTENSION

#define STATUS_NO_EXTENSION   2

Definition at line 2468 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

STATUS_NO_LABEL

#define STATUS_NO_LABEL   4

Definition at line 2470 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

STATUS_NO_PRIORITY

#define STATUS_NO_PRIORITY   3

Definition at line 2469 of file pbx.c.

Referenced by pbx_extension_helper(), and pbx_find_extension().

STATUS_SUCCESS

#define STATUS_SUCCESS   5

Definition at line 2471 of file pbx.c.

Referenced by pbx_find_extension().

SWITCH_DATA_LENGTH

#define SWITCH_DATA_LENGTH   256

Definition at line 219 of file pbx.c.

VAR_HARDTRAN

#define VAR_HARDTRAN   3

Definition at line 223 of file pbx.c.

VAR_NORMAL

#define VAR_NORMAL   1

Definition at line 221 of file pbx.c.

VAR_SOFTTRAN

#define VAR_SOFTTRAN   2

Definition at line 222 of file pbx.c.

Function Documentation

__ast_context_destroy()

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

Definition at line 8095 of file pbx.c.

References __ast_internal_context_destroy(), ast_context::alts, ast_context_ignorepats_count(), ast_context_includes_count(), ast_context_remove_extension_callerid2(), ast_context_switches_count(), ast_copy_string(), ast_debug, ast_free, ast_get_ignorepat_registrar(), ast_get_include_registrar(), ast_get_switch_registrar(), ast_hashtab_end_traversal(), ast_hashtab_next(), ast_hashtab_remove_this_object(), ast_hashtab_start_traversal, AST_MAX_EXTENSION, ast_unlock_context(), AST_VECTOR_GET, AST_VECTOR_REMOVE_ORDERED, ast_verb, ast_wrlock_context(), ast_exten::cidmatch, ast_exten::exten, ignorepat_free(), ast_context::ignorepats, include_free(), ast_context::includes, ast_exten::matchcid, ast_exten::name, ast_context::name, ast_exten::next, ast_context::next, NULL, ast_exten::peer_table, ast_exten::priority, ast_context::refcount, ast_exten::registrar, ast_context::registrar, ast_context::root, ast_context::root_table, sw_free(), and tmp().

Referenced by ast_context_destroy(), and ast_context_set_autohints().

{
 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;
 int idx;

 /* remove any ignorepats whose registrar matches */
 for (idx = ast_context_ignorepats_count(tmp) - 1; idx >= 0; idx--) {
 struct ast_ignorepat *ip = AST_VECTOR_GET(&tmp->ignorepats, idx);

 if (!strcmp(ast_get_ignorepat_registrar(ip), registrar)) {
 AST_VECTOR_REMOVE_ORDERED(&tmp->ignorepats, idx);
 ignorepat_free(ip);
 }
 }
 /* remove any includes whose registrar matches */
 for (idx = ast_context_includes_count(tmp) - 1; idx >= 0; idx--) {
 struct ast_include *i = AST_VECTOR_GET(&tmp->includes, idx);

 if (!strcmp(ast_get_include_registrar(i), registrar)) {
 AST_VECTOR_REMOVE_ORDERED(&tmp->includes, idx);
 include_free(i);
 }
 }
 /* remove any switches whose registrar matches */
 for (idx = ast_context_switches_count(tmp) - 1; idx >= 0; idx--) {
 struct ast_sw *sw = AST_VECTOR_GET(&tmp->alts, idx);

 if (!strcmp(ast_get_switch_registrar(sw), registrar)) {
 AST_VECTOR_REMOVE_ORDERED(&tmp->alts, idx);
 sw_free(sw);
 }
 }

 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))) {
 int end_traversal = 1;

 /*
 * If the extension could not be removed from the root_table due to
 * a loaded PBX app, it can exist here but have its peer_table be
 * destroyed due to a previous pass through this function.
 */
 if (!exten_item->peer_table) {
 continue;
 }

 prio_iter = ast_hashtab_start_traversal(exten_item->peer_table);
 while ((prio_item=ast_hashtab_next(prio_iter))) {
 char extension[AST_MAX_EXTENSION];
 char cidmatch[AST_MAX_EXTENSION];
 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->name, prio_item->priority, registrar, con? con->name : "<nil>", con, con? con->root_table: NULL);
 ast_copy_string(extension, prio_item->exten, sizeof(extension));
 if (prio_item->cidmatch) {
 ast_copy_string(cidmatch, prio_item->cidmatch, sizeof(cidmatch));
 }
 end_traversal &= ast_context_remove_extension_callerid2(tmp, extension, prio_item->priority, cidmatch, prio_item->matchcid, NULL, 1);
 }
 /* Explanation:
 * ast_context_remove_extension_callerid2 will destroy the extension that it comes across. This
 * destruction includes destroying the exten's peer_table, which we are currently traversing. If
 * ast_context_remove_extension_callerid2 ever should return '0' then this means we have destroyed
 * the hashtable which we are traversing, and thus calling ast_hashtab_end_traversal will result
 * in reading invalid memory. Thus, if we detect that we destroyed the hashtable, then we will simply
 * free the iterator
 */
 if (end_traversal) {
 ast_hashtab_end_traversal(prio_iter);
 } else {
 ast_free(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 && !ast_context_ignorepats_count(tmp) && !ast_context_includes_count(tmp) && !ast_context_switches_count(tmp)) {
 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;
 }
}

__ast_goto_if_exists()

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

static

Definition at line 8772 of file pbx.c.

References ast_async_goto(), ast_channel_caller(), ast_channel_context(), ast_channel_exten(), ast_exists_extension(), ast_explicit_goto(), AST_PBX_GOTO_FAILED, context, ast_exten::exten, NULL, ast_exten::priority, and S_COR.

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 = ast_channel_context(chan);
 if (exten == NULL)
 exten = ast_channel_exten(chan);

 goto_func = (async) ? ast_async_goto : ast_explicit_goto;
 if (ast_exists_extension(chan, context, exten, priority,
 S_COR(ast_channel_caller(chan)->id.number.valid, ast_channel_caller(chan)->id.number.str, NULL)))
 return goto_func(chan, context, exten, priority);
 else {
 return AST_PBX_GOTO_FAILED;
 }
}

__ast_internal_context_destroy()

static void __ast_internal_context_destroy ( struct ast_context *  con )

static

Definition at line 8050 of file pbx.c.

References ast_context::alts, ast_free, ast_hashtab_destroy(), ast_mutex_destroy, ast_rwlock_destroy, AST_VECTOR_CALLBACK_VOID, AST_VECTOR_FREE, destroy_exten(), destroy_pattern_tree(), el, ignorepat_free(), ast_context::ignorepats, include_free(), ast_context::includes, ast_context::lock, ast_context::macrolock, ast_exten::next, NULL, ast_context::pattern_tree, ast_exten::peer, ast_context::registrar, ast_context::root, ast_context::root_table, sw_free(), and tmp().

Referenced by __ast_context_destroy(), and ast_merge_contexts_and_delete().

{
 struct ast_exten *e, *el, *en;
 struct ast_context *tmp = con;

 /* Free includes */
 AST_VECTOR_CALLBACK_VOID(&tmp->includes, include_free);
 AST_VECTOR_FREE(&tmp->includes);

 /* Free ignorepats */
 AST_VECTOR_CALLBACK_VOID(&tmp->ignorepats, ignorepat_free);
 AST_VECTOR_FREE(&tmp->ignorepats);

 /* Free switches */
 AST_VECTOR_CALLBACK_VOID(&tmp->alts, sw_free);
 AST_VECTOR_FREE(&tmp->alts);

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

 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_mutex_destroy(&tmp->macrolock);
 ast_free(tmp);
}

__ast_pbx_run()

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

References ast_callid_threadassoc_add(), ast_calloc, ast_channel_caller(), ast_channel_callid(), ast_channel_callid_set(), ast_channel_clear_softhangup(), ast_channel_context(), ast_channel_exten(), ast_channel_flags(), ast_channel_lock, ast_channel_name(), ast_channel_pbx(), ast_channel_pbx_set(), ast_channel_priority(), ast_channel_priority_set(), ast_channel_softhangup_internal_flag(), ast_channel_unlock, ast_channel_whentohangup(), ast_check_hangup(), ast_clear_flag, ast_copy_string(), ast_create_callid(), ast_debug, ast_exists_extension(), AST_FLAG_BRIDGE_HANGUP_RUN, AST_FLAG_IN_AUTOLOOP, ast_free, ast_hangup(), ast_log, ast_matchmore_extension(), AST_PBX_ERROR, AST_PBX_FAILED, ast_pbx_h_exten_run(), ast_pbx_hangup_handler_run(), AST_PBX_INCOMPLETE, AST_PBX_SUCCESS, ast_read_threadstorage_callid(), 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, collect_digits(), digit, ast_pbx::dtimeoutms, error(), indicate_busy(), indicate_congestion(), LOG_WARNING, ast_pbx_args::no_hangup_chan, NULL, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_destroy(), raise_exception(), ast_pbx::rtimeoutms, S_COR, set_ext_pri(), status, and timeout.

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 */
 struct ast_pbx *pbx;
 ast_callid callid;

 /* A little initial setup here */
 if (ast_channel_pbx(c)) {
 ast_log(LOG_WARNING, "%s already has PBX structure??\n", ast_channel_name(c));
 /* XXX and now what ? */
 ast_free(ast_channel_pbx(c));
 }
 if (!(pbx = ast_calloc(1, sizeof(*pbx)))) {
 return AST_PBX_FAILED;
 }

 callid = ast_read_threadstorage_callid();
 /* If the thread isn't already associated with a callid, we should create that association. */
 if (!callid) {
 /* Associate new PBX thread with the channel call id if it is availble.
 * If not, create a new one instead.
 */
 callid = ast_channel_callid(c);
 if (!callid) {
 callid = ast_create_callid();
 if (callid) {
 ast_channel_lock(c);
 ast_channel_callid_set(c, callid);
 ast_channel_unlock(c);
 }
 }
 ast_callid_threadassoc_add(callid);
 callid = 0;
 }

 ast_channel_pbx_set(c, pbx);
 /* Set reasonable defaults */
 ast_channel_pbx(c)->rtimeoutms = 10000;
 ast_channel_pbx(c)->dtimeoutms = 5000;

 ast_channel_lock(c);
 autoloopflag = ast_test_flag(ast_channel_flags(c), AST_FLAG_IN_AUTOLOOP); /* save value to restore at the end */
 ast_set_flag(ast_channel_flags(c), AST_FLAG_IN_AUTOLOOP);
 ast_channel_unlock(c);

 if (ast_strlen_zero(ast_channel_exten(c))) {
 /* If not successful fall back to 's' - but only if there is no given exten */
 ast_verb(2, "Starting %s at %s,%s,%d failed so falling back to exten 's'\n", ast_channel_name(c), ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c));
 /* 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);
 }

 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;

 /* No digits pressed yet */
 dst_exten[pos] = '\0';

 /* loop on priorities in this context/exten */
 while (!(res = ast_spawn_extension(c, ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c),
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL),
 &found, 1))) {

 if (!ast_check_hangup(c)) {
 ast_channel_priority_set(c, ast_channel_priority(c) + 1);
 continue;
 }

 /* Check softhangup flags. */
 if (ast_channel_softhangup_internal_flag(c) & AST_SOFTHANGUP_ASYNCGOTO) {
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_ASYNCGOTO);
 continue;
 }
 if (ast_channel_softhangup_internal_flag(c) & AST_SOFTHANGUP_TIMEOUT) {
 if (ast_exists_extension(c, ast_channel_context(c), "T", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 set_ext_pri(c, "T", 1);
 /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
 memset(ast_channel_whentohangup(c), 0, sizeof(*ast_channel_whentohangup(c)));
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_TIMEOUT);
 continue;
 } else if (ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 raise_exception(c, "ABSOLUTETIMEOUT", 1);
 /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
 memset(ast_channel_whentohangup(c), 0, sizeof(*ast_channel_whentohangup(c)));
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_TIMEOUT);
 continue;
 }

 /* Call timed out with no special extension to jump to. */
 error = 1;
 break;
 }
 ast_debug(1, "Extension %s, priority %d returned normally even though call was hung up\n",
 ast_channel_exten(c), ast_channel_priority(c));
 error = 1;
 break;
 } /* 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", ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c), ast_channel_name(c));
 ast_verb(2, "Spawn extension (%s, %s, %d) exited INCOMPLETE on '%s'\n", ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c), ast_channel_name(c));

 /* Don't cycle on incomplete - this will happen if the only extension that matches is our "incomplete" extension */
 if (!ast_matchmore_extension(c, ast_channel_context(c), ast_channel_exten(c), 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 invalid = 1;
 } else {
 ast_copy_string(dst_exten, ast_channel_exten(c), sizeof(dst_exten));
 digit = 1;
 pos = strlen(dst_exten);
 }
 } else {
 ast_debug(1, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c), ast_channel_name(c));
 ast_verb(2, "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c), ast_channel_name(c));

 if ((res == AST_PBX_ERROR)
 && ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 /* if we are already on the 'e' exten, don't jump to it again */
 if (!strcmp(ast_channel_exten(c), "e")) {
 ast_verb(2, "Spawn extension (%s, %s, %d) exited ERROR while already on 'e' exten on '%s'\n", ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c), ast_channel_name(c));
 error = 1;
 } else {
 raise_exception(c, "ERROR", 1);
 continue;
 }
 }

 if (ast_channel_softhangup_internal_flag(c) & AST_SOFTHANGUP_ASYNCGOTO) {
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_ASYNCGOTO);
 continue;
 }
 if (ast_channel_softhangup_internal_flag(c) & AST_SOFTHANGUP_TIMEOUT) {
 if (ast_exists_extension(c, ast_channel_context(c), "T", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 set_ext_pri(c, "T", 1);
 /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
 memset(ast_channel_whentohangup(c), 0, sizeof(*ast_channel_whentohangup(c)));
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_TIMEOUT);
 continue;
 } else if (ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 raise_exception(c, "ABSOLUTETIMEOUT", 1);
 /* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
 memset(ast_channel_whentohangup(c), 0, sizeof(*ast_channel_whentohangup(c)));
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_TIMEOUT);
 continue;
 }
 /* Call timed out with no special extension to jump to. */
 }
 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_strlen_zero(dst_exten) &&
 !ast_exists_extension(c, ast_channel_context(c), ast_channel_exten(c), 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL)))) {
 /*!\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, ast_channel_context(c), "i", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 ast_verb(3, "Channel '%s' sent to invalid extension: context,exten,priority=%s,%s,%d\n",
 ast_channel_name(c), ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c));
 pbx_builtin_setvar_helper(c, "INVALID_EXTEN", ast_channel_exten(c));
 set_ext_pri(c, "i", 1);
 } else if (ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 raise_exception(c, "INVALID", 1);
 } else {
 ast_log(LOG_WARNING, "Channel '%s' sent to invalid extension but no invalid handler: context,exten,priority=%s,%s,%d\n",
 ast_channel_name(c), ast_channel_context(c), ast_channel_exten(c), ast_channel_priority(c));
 error = 1; /* we know what to do with it */
 break;
 }
 } else if (ast_channel_softhangup_internal_flag(c) & AST_SOFTHANGUP_TIMEOUT) {
 /* If we get this far with AST_SOFTHANGUP_TIMEOUT, then we know that the "T" extension is next. */
 ast_channel_clear_softhangup(c, AST_SOFTHANGUP_TIMEOUT);
 } else { /* keypress received, get more digits for a full extension */
 int waittime = 0;
 if (digit)
 waittime = ast_channel_pbx(c)->dtimeoutms;
 else if (!autofallthrough)
 waittime = ast_channel_pbx(c)->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", ast_channel_name(c), status);
 if (!strcasecmp(status, "CONGESTION"))
 res = indicate_congestion(c, "10");
 else if (!strcasecmp(status, "CHANUNAVAIL"))
 res = indicate_congestion(c, "10");
 else if (!strcasecmp(status, "BUSY"))
 res = indicate_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, ast_channel_context(c), dst_exten, 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) { /* 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, ast_channel_context(c), "i", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 ast_verb(3, "Invalid extension '%s' in context '%s' on %s\n", dst_exten, ast_channel_context(c), ast_channel_name(c));
 pbx_builtin_setvar_helper(c, "INVALID_EXTEN", dst_exten);
 set_ext_pri(c, "i", 1);
 } else if (ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 raise_exception(c, "INVALID", 1);
 } else {
 ast_log(LOG_WARNING,
 "Invalid extension '%s', but no rule 'i' or 'e' in context '%s'\n",
 dst_exten, ast_channel_context(c));
 found = 1; /* XXX disable message */
 break;
 }
 } else {
 /* A simple timeout */
 if (ast_exists_extension(c, ast_channel_context(c), "t", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 ast_verb(3, "Timeout on %s\n", ast_channel_name(c));
 set_ext_pri(c, "t", 1);
 } else if (ast_exists_extension(c, ast_channel_context(c), "e", 1,
 S_COR(ast_channel_caller(c)->id.number.valid, ast_channel_caller(c)->id.number.str, NULL))) {
 raise_exception(c, "RESPONSETIMEOUT", 1);
 } else {
 ast_log(LOG_WARNING,
 "Timeout, but no rule 't' or 'e' in context '%s'\n",
 ast_channel_context(c));
 found = 1; /* XXX disable message */
 break;
 }
 }
 }
 }
 }

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

 if (!args || !args->no_hangup_chan) {
 ast_softhangup(c, AST_SOFTHANGUP_APPUNLOAD);
 if (!ast_test_flag(ast_channel_flags(c), AST_FLAG_BRIDGE_HANGUP_RUN)
 && ast_exists_extension(c, ast_channel_context(c), "h", 1,
 S_COR(ast_channel_caller(c)->id.number.valid,
 ast_channel_caller(c)->id.number.str, NULL))) {
 ast_pbx_h_exten_run(c, ast_channel_context(c));
 }
 ast_pbx_hangup_handler_run(c);
 }

 ast_channel_lock(c);
 ast_set2_flag(ast_channel_flags(c), autoloopflag, AST_FLAG_IN_AUTOLOOP);
 ast_clear_flag(ast_channel_flags(c), AST_FLAG_BRIDGE_HANGUP_RUN); /* from one round to the next, make sure this gets cleared */
 ast_channel_unlock(c);
 pbx_destroy(ast_channel_pbx(c));
 ast_channel_pbx_set(c, NULL);

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

 return AST_PBX_SUCCESS;
}

__init_extensionstate_buf()

static void __init_extensionstate_buf ( void  )

static

Definition at line 229 of file pbx.c.

{

__init_hintdevice_data()

static void __init_hintdevice_data ( void  )

static

Definition at line 352 of file pbx.c.

{

__init_switch_data()

static void __init_switch_data ( void  )

static

Definition at line 228 of file pbx.c.

{

_extension_match_core()

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

static

Definition at line 2209 of file pbx.c.

References ast_log, ast_exten::data, E_MATCH, E_MATCH_MASK, E_MATCHMORE, end, ext_cmp_exten(), ext_cmp_exten_partial(), ext_cmp_exten_strlen(), ext_cmp_pattern(), 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 (pattern[0] != '_') { /* not a pattern, try exact or partial match */
 int lp = ext_cmp_exten_strlen(pattern);
 int ld = ext_cmp_exten_strlen(data);

 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 (!ext_cmp_exten(%s,%s) when mode== E_MATCH)\n", pattern, data);
#endif
 return !ext_cmp_exten(pattern, data); /* 1 on match, 0 on fail */
 }
 if (ld == 0 || !ext_cmp_exten_partial(pattern, data)) { /* 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;
 }
 }
 if (mode == E_MATCH && data[0] == '_') {
 /*
 * XXX It is bad design that we don't know if we should be
 * comparing data and pattern as patterns or comparing data if
 * it conforms to pattern when the function is called. First,
 * assume they are both patterns. If they don't match then try
 * to see if data conforms to the given pattern.
 *
 * note: if this test is left out, then _x. will not match _x. !!!
 */
#ifdef NEED_DEBUG_HERE
 ast_log(LOG_NOTICE, "Comparing as patterns first. pattern:%s data:%s\n", pattern, data);
#endif
 if (!ext_cmp_pattern(pattern + 1, data + 1)) {
#ifdef NEED_DEBUG_HERE
 ast_log(LOG_NOTICE,"return (1) - pattern matches pattern\n");
#endif
 return 1;
 }
 }

 ++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.
 */
 for (;;) {
 const char *end;

 /* Ignore '-' chars as eye candy fluff. */
 while (*data == '-') {
 ++data;
 }
 while (*pattern == '-') {
 ++pattern;
 }
 if (!*data || !*pattern || *pattern == '/') {
 break;
 }

 switch (*pattern) {
 case '[': /* a range */
 ++pattern;
 end = strchr(pattern, ']'); /* XXX should deal with escapes ? */
 if (!end) {
 ast_log(LOG_WARNING, "Wrong usage of [] in the extension\n");
 return 0; /* unconditional failure */
 }
 if (pattern == end) {
 /* Ignore empty character sets. */
 ++pattern;
 continue;
 }
 for (; 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':
 case 'N':
 if (*data < '2' || *data > '9') {
#ifdef NEED_DEBUG_HERE
 ast_log(LOG_NOTICE,"return (0) N is not matched\n");
#endif
 return 0;
 }
 break;
 case 'x':
 case 'X':
 if (*data < '0' || *data > '9') {
#ifdef NEED_DEBUG_HERE
 ast_log(LOG_NOTICE,"return (0) X is not matched\n");
#endif
 return 0;
 }
 break;
 case 'z':
 case 'Z':
 if (*data < '1' || *data > '9') {
#ifdef NEED_DEBUG_HERE
 ast_log(LOG_NOTICE,"return (0) Z is not 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;
 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;
 }
 break;
 }
 ++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 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 */
 }
}

acf_exception_read()

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

static

Definition at line 2832 of file pbx.c.

References ast_channel_datastore_find(), ast_copy_string(), pbx_exception::context, ast_datastore::data, pbx_exception::exten, NULL, 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;
}

action_extensionstatelist()

static int action_extensionstatelist ( struct mansession *  s, const struct message *  m  )

static

Definition at line 8383 of file pbx.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_lock, ao2_ref, ao2_unlock, ast_exten::app, ast_extension_state2str(), ast_strlen_zero, astman_append(), astman_get_header(), astman_send_error(), astman_send_list_complete_end(), astman_send_list_complete_start(), astman_send_listack(), ast_exten::exten, ast_hint::exten, ast_hint::laststate, ast_context::name, and ast_exten::parent.

Referenced by load_pbx().

{
 const char *action_id = astman_get_header(m, "ActionID");
 struct ast_hint *hint;
 struct ao2_iterator it_hints;
 int hint_count = 0;

 if (!hints) {
 astman_send_error(s, m, "No dialplan hints are available");
 return 0;
 }

 astman_send_listack(s, m, "Extension Statuses will follow", "start");

 ao2_lock(hints);
 it_hints = ao2_iterator_init(hints, 0);
 for (; (hint = ao2_iterator_next(&it_hints)); ao2_ref(hint, -1)) {

 ao2_lock(hint);

 /* Ignore pattern matching hints; they are stored in the
 * hints container but aren't real from the perspective of
 * an AMI user
 */
 if (hint->exten->exten[0] == '_') {
 ao2_unlock(hint);
 continue;
 }

 ++hint_count;

 astman_append(s, "Event: ExtensionStatus\r\n");
 if (!ast_strlen_zero(action_id)) {
 astman_append(s, "ActionID: %s\r\n", action_id);
 }
 astman_append(s,
 "Exten: %s\r\n"
 "Context: %s\r\n"
 "Hint: %s\r\n"
 "Status: %d\r\n"
 "StatusText: %s\r\n\r\n",
 hint->exten->exten,
 hint->exten->parent->name,
 hint->exten->app,
 hint->laststate,
 ast_extension_state2str(hint->laststate));
 ao2_unlock(hint);
 }

 ao2_iterator_destroy(&it_hints);
 ao2_unlock(hints);

 astman_send_list_complete_start(s, m, "ExtensionStateListComplete", hint_count);
 astman_send_list_complete_end(s);

 return 0;
}

add_exten_to_pattern_tree()

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

static

Definition at line 1657 of file pbx.c.

References add_pattern_node(), already_in_tree(), ARRAY_LEN, ast_copy_string(), ast_debug, ast_log, buf, pattern_node::buf, ast_exten::cidmatch, match_char::deleted, ast_exten::exten, match_char::exten, get_pattern_node(), LOG_ERROR, LOG_WARNING, ast_exten::matchcid, ast_exten::name, match_char::next_char, NULL, and ast_context::pattern_tree.

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

{
 struct match_char *m1 = NULL;
 struct match_char *m2 = NULL;
 struct match_char **m0;
 const char *pos;
 int already;
 int pattern = 0;
 int idx_cur;
 int idx_next;
 char extenbuf[512];
 struct pattern_node pat_node[2];

 if (e1->matchcid) {
 if (sizeof(extenbuf) < strlen(e1->exten) + strlen(e1->cidmatch) + 2) {
 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 NULL;
 }
 sprintf(extenbuf, "%s/%s", e1->exten, e1->cidmatch);/* Safe. We just checked. */
 } else {
 ast_copy_string(extenbuf, e1->exten, sizeof(extenbuf));
 }

#ifdef NEED_DEBUG
 ast_debug(1, "Adding exten %s to tree\n", extenbuf);
#endif
 m1 = con->pattern_tree; /* each pattern starts over at the root of the pattern tree */
 m0 = &con->pattern_tree;
 already = 1;

 pos = extenbuf;
 if (*pos == '_') {
 pattern = 1;
 ++pos;
 }
 idx_cur = 0;
 pos = get_pattern_node(&pat_node[idx_cur], pos, pattern, extenbuf);
 for (; pat_node[idx_cur].buf[0]; idx_cur = idx_next) {
 idx_next = (idx_cur + 1) % ARRAY_LEN(pat_node);
 pos = get_pattern_node(&pat_node[idx_next], pos, pattern, extenbuf);

 /* See about adding node to tree. */
 m2 = NULL;
 if (already && (m2 = already_in_tree(m1, pat_node[idx_cur].buf, pattern))
 && m2->next_char) {
 if (!pat_node[idx_next].buf[0]) {
 /*
 * This is the end of the pattern, but not the end of the tree.
 * Mark this node with the exten... a shorter pattern might win
 * if the longer one doesn't match.
 */
 if (findonly) {
 return m2;
 }
 if (m2->exten) {
 ast_log(LOG_WARNING, "Found duplicate exten. Had %s found %s\n",
 m2->deleted ? "(deleted/invalid)" : m2->exten->name, e1->name);
 }
 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;
 }
 m1 = add_pattern_node(con, m1, &pat_node[idx_cur], pattern, already, m0);
 if (!m1) { /* m1 is the node just added */
 return NULL;
 }
 m0 = &m1->next_char;
 }
 if (!pat_node[idx_next].buf[0]) {
 if (m2 && m2->exten) {
 ast_log(LOG_WARNING, "Found duplicate exten. Had %s found %s\n",
 m2->deleted ? "(deleted/invalid)" : m2->exten->name, e1->name);
 }
 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;
 }
 }
 return m1;
}

add_hintdevice()

static int add_hintdevice ( struct ast_hint *  hint, const char *  devicelist  )

static

add hintdevice structure and link it into the container.

Definition at line 552 of file pbx.c.

References ao2_ref, ao2_t_alloc, ao2_t_link, ao2_t_ref, ast_free, ast_str_buffer(), ast_str_set(), ast_str_thread_get(), ast_strdup, AST_VECTOR_APPEND, ast_hintdevice::hint, ast_hintdevice::hintdevice, hintdevice_data, hintdevice_destroy(), parse(), str, and strsep().

Referenced by ast_add_hint(), and ast_change_hint().

{
 struct ast_str *str;
 char *parse;
 char *cur;
 struct ast_hintdevice *device;
 int devicelength;

 if (!hint || !devicelist) {
 /* Trying to add garbage? Don't bother. */
 return 0;
 }
 if (!(str = ast_str_thread_get(&hintdevice_data, 16))) {
 return -1;
 }
 ast_str_set(&str, 0, "%s", devicelist);
 parse = ast_str_buffer(str);

 /* Spit on '&' and ',' to handle presence hints as well */
 while ((cur = strsep(&parse, "&,"))) {
 char *device_name;

 devicelength = strlen(cur);
 if (!devicelength) {
 continue;
 }

 device_name = ast_strdup(cur);
 if (!device_name) {
 return -1;
 }

 device = ao2_t_alloc(sizeof(*device) + devicelength, hintdevice_destroy,
 "allocating a hintdevice structure");
 if (!device) {
 ast_free(device_name);
 return -1;
 }
 strcpy(device->hintdevice, cur);
 ao2_ref(hint, +1);
 device->hint = hint;
 if (AST_VECTOR_APPEND(&hint->devices, device_name)) {
 ast_free(device_name);
 ao2_ref(device, -1);
 return -1;
 }
 ao2_t_link(hintdevices, device, "Linking device into hintdevice container.");
 ao2_t_ref(device, -1, "hintdevice is linked so we can unref");
 }

 return 0;
}

add_pattern_node()

static struct match_char* add_pattern_node ( struct ast_context *  con, struct match_char *  current, const struct pattern_node *  pattern, int  is_pattern, int  already, struct match_char **  nextcharptr  )

static

Definition at line 1459 of file pbx.c.

References ast_calloc, pattern_node::buf, insert_in_next_chars_alt_char_list(), match_char::is_pattern, match_char::next_char, NULL, ast_context::pattern_tree, pattern_node::specif, 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->buf)))) {
 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->buf);

 /* the specificity scores are the same as used in the old
 pattern matcher. */
 m->is_pattern = is_pattern;
 if (pattern->specif == 1 && is_pattern && pattern->buf[0] == 'N') {
 m->specificity = 0x0832;
 } else if (pattern->specif == 1 && is_pattern && pattern->buf[0] == 'Z') {
 m->specificity = 0x0931;
 } else if (pattern->specif == 1 && is_pattern && pattern->buf[0] == 'X') {
 m->specificity = 0x0a30;
 } else if (pattern->specif == 1 && is_pattern && pattern->buf[0] == '.') {
 m->specificity = 0x18000;
 } else if (pattern->specif == 1 && is_pattern && pattern->buf[0] == '!') {
 m->specificity = 0x28000;
 } else {
 m->specificity = pattern->specif;
 }

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

add_priority()

static int add_priority ( 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 7109 of file pbx.c.

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

Referenced by ast_add_extension2_lockopt().

{
 struct ast_exten *ep;
 struct ast_exten *eh=e;
 int repeated_label = 0; /* Track if this label is a repeat, assume no. */

 for (ep = NULL; e ; ep = e, e = e->peer) {
 if (e->label && tmp->label && e->priority != tmp->priority && !strcmp(e->label, tmp->label)) {
 if (strcmp(e->name, tmp->name)) {
 ast_log(LOG_WARNING,
 "Extension '%s' priority %d in '%s', label '%s' already in use at aliased extension '%s' priority %d\n",
 tmp->name, tmp->priority, con->name, tmp->label, e->name, e->priority);
 } else {
 ast_log(LOG_WARNING,
 "Extension '%s' priority %d in '%s', label '%s' already in use at priority %d\n",
 tmp->name, tmp->priority, con->name, tmp->label, e->priority);
 }
 repeated_label = 1;
 }
 if (e->priority >= tmp->priority) {
 break;
 }
 }

 if (repeated_label) { /* Discard the label since it's a repeat. */
 tmp->label = NULL;
 }

 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) {
 if (strcmp(e->name, tmp->name)) {
 ast_log(LOG_WARNING,
 "Unable to register extension '%s' priority %d in '%s', already in use by aliased extension '%s'\n",
 tmp->name, tmp->priority, con->name, e->name);
 } else {
 ast_log(LOG_WARNING,
 "Unable to register extension '%s' priority %d in '%s', already in use\n",
 tmp->name, tmp->priority, con->name);
 }

 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) {
 ast_add_hint(tmp);
 }
 }
 return 0;
}

alloc_device_state_info()

static struct ao2_container* alloc_device_state_info ( void  )

static

Definition at line 3076 of file pbx.c.

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_container_alloc_list, and NULL.

Referenced by ast_extension_state_extended(), and device_state_notify_callbacks().

{
 return ao2_container_alloc_list(AO2_ALLOC_OPT_LOCK_NOLOCK, 0, NULL, NULL);
}

already_in_tree()

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

static

Definition at line 1397 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;
}

ast_active_calls()

int ast_active_calls

(

void

)

Retrieve the number of active calls.

Definition at line 4764 of file pbx.c.

References countcalls.

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

{
 return countcalls;
}

ast_add_extension()

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	a pointer to a function that will deallocate data when needed or NULL if data does not need to be freed.
registrar	who registered the extension

Note

On any failure, the function pointed to by datap will be called and passed the data pointer.

Return values

0	success
-1	failure

Definition at line 6970 of file pbx.c.

References ast_add_extension2(), ast_unlock_contexts(), c, ast_exten::datad, find_context_locked(), and NULL.

Referenced by add_to_regcontext(), app_create(), ast_hint_presence_state(), ast_sip_persistent_endpoint_update_state(), AST_TEST_DEFINE(), create_test_dialplan(), device_state_cb(), extension_state_add_destroy(), handle_cli_dialplan_add_extension(), internal_extension_state_extended(), join_conference_bridge(), load_module(), register_exten(), register_extension(), register_peer_exten(), sla_build_station(), and sla_build_trunk().

{
 int ret = -1;
 struct ast_context *c;

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

 return ret;
}

ast_add_extension2()

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,
		const char *	registrar_file,
		int	registrar_line
	)

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

References ast_add_extension2_lockopt(), and ast_exten::datad.

Referenced by ast_add_extension(), and context_merge().

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

ast_add_extension2_lockopt()

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, const char *  registrar_file, int  registrar_line, int  lock_context  )

static

Same as ast_add_extension2() but controls the context locking.

Does all the work of ast_add_extension2, but adds an arg to determine if context locking should be done.

Definition at line 7325 of file pbx.c.

References add_exten_to_pattern_tree(), add_priority(), ast_exten::app, ast_add_hint(), ast_calloc, ast_channel_context_set(), ast_channel_exten_set(), ast_channel_unref, ast_dummy_channel_alloc, AST_EXT_MATCHCID_OFF, AST_EXT_MATCHCID_ON, ast_free, ast_hashtab_create, ast_hashtab_insert_safe, ast_hashtab_lookup(), ast_hashtab_newsize_java(), ast_hashtab_remove_this_object(), ast_hashtab_resize_java(), ast_log, ast_strlen_zero, ast_thread_inhibit_escalations(), ast_thread_inhibit_escalations_swap(), ast_unlock_context(), ast_wrlock_context(), c, ast_exten::cidmatch, ast_exten::cidmatch_display, ast_exten::data, ast_exten::datad, DEBUG_ATLEAST, match_char::deleted, el, errno, ext_cmp(), ext_fluff_count(), ext_strncpy(), ast_exten::exten, match_char::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_DEBUG, LOG_ERROR, ast_exten::matchcid, ast_exten::name, ast_context::name, ast_exten::next, NULL, 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_exten::registrar_file, ast_exten::registrar_line, ast_context::root, ast_context::root_table, ast_exten::stuff, tmp(), VAR_BUF_SIZE, and match_char::x.

Referenced by ast_add_extension2(), ast_add_extension2_nolock(), 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];
 int exten_fluff;
 int callerid_fluff;

 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);
 /* We always need to deallocate 'data' on failure */
 if (datad) {
 datad(data);
 }
 return -1;
 }

 /* If we are adding a hint evalulate in variables and global variables */
 if (priority == PRIORITY_HINT && strstr(application, "${") && extension[0] != '_') {
 int inhibited;
 struct ast_channel *c = ast_dummy_channel_alloc();

 if (c) {
 ast_channel_exten_set(c, extension);
 ast_channel_context_set(c, con->name);
 }

 /*
 * We can allow dangerous functions when adding a hint since
 * altering dialplan is itself a privileged activity. Otherwise,
 * we could never execute dangerous functions.
 */
 inhibited = ast_thread_inhibit_escalations_swap(0);
 pbx_substitute_variables_helper(c, application, expand_buf, sizeof(expand_buf));
 if (0 < inhibited) {
 ast_thread_inhibit_escalations();
 }

 application = expand_buf;
 if (c) {
 ast_channel_unref(c);
 }
 }

 exten_fluff = ext_fluff_count(extension);
 callerid_fluff = callerid ? ext_fluff_count(callerid) : 0;

 length = sizeof(struct ast_exten);
 length += strlen(extension) + 1;
 if (exten_fluff) {
 length += strlen(extension) + 1 - exten_fluff;
 }
 length += strlen(application) + 1;
 if (label) {
 length += strlen(label) + 1;
 }
 if (callerid) {
 length += strlen(callerid) + 1;
 if (callerid_fluff) {
 length += strlen(callerid) + 1 - callerid_fluff;
 }
 } else {
 length ++; /* just the '\0' */
 }
 if (registrar_file) {
 length += strlen(registrar_file) + 1;
 }

 /* Be optimistic: Build the extension structure first */
 tmp = ast_calloc(1, length);
 if (!tmp) {
 /* We always need to deallocate 'data' on failure */
 if (datad) {
 datad(data);
 }
 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->name = p;
 p += ext_strncpy(p, extension, strlen(extension) + 1, 0);
 if (exten_fluff) {
 tmp->exten = p;
 p += ext_strncpy(p, extension, strlen(extension) + 1 - exten_fluff, 1);
 } else {
 /* no fluff, we don't need a copy. */
 tmp->exten = tmp->name;
 }
 tmp->priority = priority;
 tmp->cidmatch_display = tmp->cidmatch = p; /* but use p for assignments below */

 /* Blank callerid and NULL callerid are two SEPARATE things. Do NOT confuse the two!!! */
 if (callerid) {
 p += ext_strncpy(p, callerid, strlen(callerid) + 1, 0);
 if (callerid_fluff) {
 tmp->cidmatch = p;
 p += ext_strncpy(p, callerid, strlen(callerid) + 1 - callerid_fluff, 1);
 }
 tmp->matchcid = AST_EXT_MATCHCID_ON;
 } else {
 *p++ = '\0';
 tmp->matchcid = AST_EXT_MATCHCID_OFF;
 }

 if (registrar_file) {
 tmp->registrar_file = p;
 strcpy(p, registrar_file);
 p += strlen(registrar_file) + 1;
 } else {
 tmp->registrar_file = NULL;
 }

 tmp->app = p;
 strcpy(p, application);
 tmp->parent = con;
 tmp->data = data;
 tmp->datad = datad;
 tmp->registrar = registrar;
 tmp->registrar_line = registrar_line;

 if (lock_context) {
 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. */
 ext_strncpy(dummy_name, tmp->exten, sizeof(dummy_name), 1);
 dummy_exten.exten = dummy_name;
 dummy_exten.matchcid = AST_EXT_MATCHCID_OFF;
 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 == AST_EXT_MATCHCID_OFF && tmp->matchcid == AST_EXT_MATCHCID_OFF)
 res = 0;
 else if (tmp->matchcid == AST_EXT_MATCHCID_ON && e->matchcid == AST_EXT_MATCHCID_OFF)
 res = 1;
 else if (e->matchcid == AST_EXT_MATCHCID_ON && tmp->matchcid == AST_EXT_MATCHCID_OFF)
 res = -1;
 else
 res = ext_cmp(e->cidmatch, tmp->cidmatch);
 }
 if (res >= 0)
 break;
 }
 if (e && res == 0) { /* exact match, insert in the priority chain */
 res = add_priority(con, tmp, el, e, replace);
 if (res < 0) {
 if (con->pattern_tree) {
 struct match_char *x = add_exten_to_pattern_tree(con, tmp, 1);

 if (x->exten) {
 x->deleted = 1;
 x->exten = 0;
 }

 ast_hashtab_remove_this_object(con->root_table, tmp);
 }

 if (tmp->datad) {
 tmp->datad(tmp->data);
 /* if you free this, null it out */
 tmp->data = NULL;
 }

 ast_free(tmp);
 }
 if (lock_context) {
 ast_unlock_context(con);
 }
 if (res < 0) {
 errno = EEXIST;
 return -1;
 }
 } 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;
 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 (el) { /* there is another exten already in this context */
 el->next = 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;
 }
 if (label) {
 ast_hashtab_insert_safe(tmp->peer_label_table, tmp);
 }
 ast_hashtab_insert_safe(tmp->peer_table, tmp);
 ast_hashtab_insert_safe(con->root_table, tmp);

 if (lock_context) {
 ast_unlock_context(con);
 }
 if (tmp->priority == PRIORITY_HINT) {
 ast_add_hint(tmp);
 }
 }
 if (DEBUG_ATLEAST(1)) {
 if (tmp->matchcid == AST_EXT_MATCHCID_ON) {
 ast_log(LOG_DEBUG, "Added extension '%s' priority %d (CID match '%s') to %s (%p)\n",
 tmp->name, tmp->priority, tmp->cidmatch_display, con->name, con);
 } else {
 ast_log(LOG_DEBUG, "Added extension '%s' priority %d to %s (%p)\n",
 tmp->name, tmp->priority, con->name, con);
 }
 }

 return 0;
}

ast_add_extension2_nolock()

int ast_add_extension2_nolock	(	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,
		const char *	registrar_file,
		int	registrar_line
	)

Same as ast_add_extension2, but assumes you have already locked context.

Since

12.0.0

Note

con must be write locked prior to calling. For details about the arguments, check ast_add_extension()

Definition at line 7308 of file pbx.c.

References ast_add_extension2_lockopt(), and ast_exten::datad.

Referenced by add_extension(), parking_add_extension(), and parking_duration_callback().

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

ast_add_extension_nolock()

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

References ast_add_extension2_lockopt(), c, ast_exten::datad, find_context(), and NULL.

Referenced by ast_merge_contexts_and_delete().

{
 int ret = -1;
 struct ast_context *c;

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

 return ret;
}

ast_add_hint()

static int ast_add_hint ( struct ast_exten *  e )

static

Add hint to hint list, check initial extension state.

Definition at line 3982 of file pbx.c.

References add_hintdevice(), ao2_alloc, AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_list, ao2_find, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_link, ao2_lock, ao2_ref, ao2_unlock, ast_exten::app, ast_debug, AST_DEVICE_INVALID, ast_extension_state2(), ast_get_context_name(), ast_get_extension_app(), ast_get_extension_context(), ast_get_extension_name(), AST_HINT_UPDATE_DEVICE, ast_log, AST_PRESENCE_INVALID, AST_VECTOR_INIT, ast_hint::callbacks, ast_state_cb::change_cb, ast_state_cb::data, destroy_hint(), execute_state_callback(), ast_exten::exten, ast_hint::exten, extension_presence_state_helper(), hint_id_cmp(), ast_hint::last_presence_message, ast_hint::last_presence_state, ast_hint::last_presence_subtype, ast_hint::laststate, LOG_WARNING, and NULL.

Referenced by add_priority(), and ast_add_extension2_lockopt().

{
 struct ast_hint *hint_new;
 struct ast_hint *hint_found;
 char *message = NULL;
 char *subtype = NULL;
 int presence_state;

 if (!e) {
 return -1;
 }

 /*
 * We must create the hint we wish to add before determining if
 * it is already in the hints container to avoid possible
 * deadlock when getting the current extension state.
 */
 hint_new = ao2_alloc(sizeof(*hint_new), destroy_hint);
 if (!hint_new) {
 return -1;
 }
 AST_VECTOR_INIT(&hint_new->devices, 8);

 /* Initialize new hint. */
 hint_new->callbacks = ao2_container_alloc_list(AO2_ALLOC_OPT_LOCK_MUTEX, 0, NULL, hint_id_cmp);
 if (!hint_new->callbacks) {
 ao2_ref(hint_new, -1);
 return -1;
 }
 hint_new->exten = e;
 if (strstr(e->app, "${") && e->exten[0] == '_') {
 /* The hint is dynamic and hasn't been evaluted yet */
 hint_new->laststate = AST_DEVICE_INVALID;
 hint_new->last_presence_state = AST_PRESENCE_INVALID;
 } else {
 hint_new->laststate = ast_extension_state2(e, NULL);
 if ((presence_state = extension_presence_state_helper(e, &subtype, &message)) > 0) {
 hint_new->last_presence_state = presence_state;
 hint_new->last_presence_subtype = subtype;
 hint_new->last_presence_message = message;
 }
 }

 /* Prevent multiple add hints from adding the same hint at the same time. */
 ao2_lock(hints);

 /* Search if hint exists, do nothing */
 hint_found = ao2_find(hints, e, 0);
 if (hint_found) {
 ao2_ref(hint_found, -1);
 ao2_unlock(hints);
 ao2_ref(hint_new, -1);
 ast_debug(2, "HINTS: Not re-adding existing hint %s: %s\n",
 ast_get_extension_name(e), ast_get_extension_app(e));
 return -1;
 }

 /* Add new hint to the hints container */
 ast_debug(2, "HINTS: Adding hint %s: %s\n",
 ast_get_extension_name(e), ast_get_extension_app(e));
 ao2_link(hints, hint_new);
 if (add_hintdevice(hint_new, ast_get_extension_app(e))) {
 ast_log(LOG_WARNING, "Could not add devices for hint: %s@%s.\n",
 ast_get_extension_name(e),
 ast_get_context_name(ast_get_extension_context(e)));
 }

 /* if not dynamic */
 if (!(strstr(e->app, "${") && e->exten[0] == '_')) {
 struct ast_state_cb *state_cb;
 struct ao2_iterator cb_iter;

 /* For general callbacks */
 cb_iter = ao2_iterator_init(statecbs, 0);
 for (; (state_cb = ao2_iterator_next(&cb_iter)); ao2_ref(state_cb, -1)) {
 execute_state_callback(state_cb->change_cb,
 ast_get_context_name(ast_get_extension_context(e)),
 ast_get_extension_name(e),
 state_cb->data,
 AST_HINT_UPDATE_DEVICE,
 hint_new,
 NULL);
 }
 ao2_iterator_destroy(&cb_iter);
 }
 ao2_unlock(hints);
 ao2_ref(hint_new, -1);

 return 0;
}

ast_async_goto()

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

Note

Do NOT hold any channel locks when calling this function.

Definition at line 7011 of file pbx.c.

References ast_channel_flags(), ast_channel_is_bridged(), ast_channel_lock, ast_channel_name(), ast_channel_pbx(), ast_channel_unlock, ast_channel_yank(), ast_explicit_goto(), AST_FLAG_IN_AUTOLOOP, ast_hangup(), ast_log, ast_pbx_start(), AST_SOFTHANGUP_ASYNCGOTO, ast_softhangup_nolock(), ast_test_flag, and LOG_WARNING.

Referenced by __ast_goto_if_exists(), action_redirect(), ast_async_goto_by_name(), bridge_channel_blind_transfer(), chan_pjsip_cng_tone_detected(), comeback_goto(), dahdi_handle_dtmf(), fax_detect_framehook(), handle_request_bye(), my_handle_dtmf(), onModeChanged(), ooh323_rtp_read(), pbx_parseable_goto(), process_ast_dsp(), process_sdp(), and sip_read().

{
 struct ast_channel *newchan;

 ast_channel_lock(chan);
 /* Channels in a bridge or running a PBX can be sent directly to the specified destination */
 if (ast_channel_is_bridged(chan) || ast_channel_pbx(chan)) {
 if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_IN_AUTOLOOP)) {
 priority += 1;
 }
 ast_explicit_goto(chan, context, exten, priority);
 ast_softhangup_nolock(chan, AST_SOFTHANGUP_ASYNCGOTO);
 ast_channel_unlock(chan);
 return 0;
 }
 ast_channel_unlock(chan);

 /* Otherwise, we need to gain control of the channel first */
 newchan = ast_channel_yank(chan);
 if (!newchan) {
 ast_log(LOG_WARNING, "Unable to gain control of channel %s\n", ast_channel_name(chan));
 return -1;
 }
 ast_explicit_goto(newchan, context, exten, priority);
 if (ast_pbx_start(newchan)) {
 ast_hangup(newchan);
 ast_log(LOG_WARNING, "Unable to start PBX on %s\n", ast_channel_name(newchan));
 return -1;
 }

 return 0;
}

ast_async_goto_by_name()

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

ast_async_goto_if_exists()

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

References __ast_goto_if_exists().

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

ast_async_parseable_goto()

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

References pbx_parseable_goto().

Referenced by asyncgoto_exec(), detect_callback(), handle_redirect(), and parking_duration_callback().

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

ast_canmatch_extension()

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

References E_CANMATCH, NULL, 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(), leave_voicemail(), loopback_canmatch(), mgcp_ss(), pbx_builtin_background(), phone_check_exception(), test_exten(), and valid_exit().

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

ast_change_hint()

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

static

Change hint for an extension.

Definition at line 4096 of file pbx.c.

References add_hintdevice(), ao2_find, ao2_link, ao2_lock, ao2_ref, ao2_unlock, ast_get_context_name(), ast_get_extension_app(), ast_get_extension_context(), ast_get_extension_name(), ast_log, ast_mutex_unlock, context_merge_lock, ast_hint::exten, LOG_WARNING, OBJ_UNLINK, publish_hint_change(), and remove_hintdevice().

Referenced by add_priority().

{
 struct ast_hint *hint;

 if (!oe || !ne) {
 return -1;
 }

 ao2_lock(hints);/* Locked to hold off others while we move the hint around. */

 /*
 * Unlink the hint from the hints container as the extension
 * name (which is the hash value) could change.
 */
 hint = ao2_find(hints, oe, OBJ_UNLINK);
 if (!hint) {
 ao2_unlock(hints);
 ast_mutex_unlock(&context_merge_lock);
 return -1;
 }

 remove_hintdevice(hint);

 /* Update the hint and put it back in the hints container. */
 ao2_lock(hint);
 hint->exten = ne;

 ao2_unlock(hint);

 ao2_link(hints, hint);
 if (add_hintdevice(hint, ast_get_extension_app(ne))) {
 ast_log(LOG_WARNING, "Could not add devices for hint: %s@%s.\n",
 ast_get_extension_name(ne),
 ast_get_context_name(ast_get_extension_context(ne)));
 }
 ao2_unlock(hints);

 publish_hint_change(hint, ne);

 ao2_ref(hint, -1);

 return 0;
}

ast_context_add_ignorepat()

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

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

Referenced by handle_cli_dialplan_add_ignorepat().

{
 int ret = -1;
 struct ast_context *c;

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

ast_context_add_ignorepat2()

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

Definition at line 6890 of file pbx.c.

References ast_context_ignorepats_count(), ast_context_ignorepats_get(), ast_get_ignorepat_name(), ast_unlock_context(), AST_VECTOR_APPEND, ast_wrlock_context(), errno, ignorepat_alloc(), ignorepat_free(), and ast_context::ignorepats.

Referenced by ast_context_add_ignorepat(), and context_merge_incls_swits_igps_other_registrars().

{
 struct ast_ignorepat *ignorepat = ignorepat_alloc(value, registrar);
 int idx;

 if (!ignorepat) {
 return -1;
 }

 ast_wrlock_context(con);
 for (idx = 0; idx < ast_context_ignorepats_count(con); idx++) {
 const struct ast_ignorepat *i = ast_context_ignorepats_get(con, idx);

 if (!strcasecmp(ast_get_ignorepat_name(i), value)) {
 /* Already there */
 ast_unlock_context(con);
 ignorepat_free(ignorepat);
 errno = EEXIST;
 return -1;
 }
 }
 if (AST_VECTOR_APPEND(&con->ignorepats, ignorepat)) {
 ignorepat_free(ignorepat);
 ast_unlock_context(con);
 return -1;
 }
 ast_unlock_context(con);

 return 0;
}

ast_context_add_include()

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

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

Referenced by AST_TEST_DEFINE(), and handle_cli_dialplan_add_include().

{
 int ret = -1;
 struct ast_context *c;

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

ast_context_add_include2()

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

Add a context include.

Parameters

con	context to add the include to
value	include value 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 6726 of file pbx.c.

References ast_context_includes_count(), ast_context_includes_get(), ast_debug, ast_get_context_name(), ast_get_include_name(), ast_unlock_context(), AST_VECTOR_APPEND, ast_wrlock_context(), errno, include_alloc(), include_free(), and ast_context::includes.

Referenced by ast_context_add_include(), and context_merge_incls_swits_igps_other_registrars().

{
 struct ast_include *new_include;
 int idx;

 /* allocate new include structure ... */
 new_include = include_alloc(value, registrar);
 if (!new_include) {
 return -1;
 }

 ast_wrlock_context(con);

 /* ... go to last include and check if context is already included too... */
 for (idx = 0; idx < ast_context_includes_count(con); idx++) {
 const struct ast_include *i = ast_context_includes_get(con, idx);

 if (!strcasecmp(ast_get_include_name(i), ast_get_include_name(new_include))) {
 include_free(new_include);
 ast_unlock_context(con);
 errno = EEXIST;
 return -1;
 }
 }

 /* ... include new context into context list, unlock, return */
 if (AST_VECTOR_APPEND(&con->includes, new_include)) {
 include_free(new_include);
 ast_unlock_context(con);
 return -1;
 }
 ast_debug(1, "Including context '%s' in context '%s'\n",
 ast_get_include_name(new_include), ast_get_context_name(con));

 ast_unlock_context(con);

 return 0;
}

ast_context_add_switch()

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

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

{
 int ret = -1;
 struct ast_context *c;

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

ast_context_add_switch2()

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)

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

References ast_context::alts, ast_context_switches_count(), ast_context_switches_get(), ast_get_context_name(), ast_get_switch_data(), ast_get_switch_name(), ast_unlock_context(), AST_VECTOR_APPEND, ast_verb, ast_wrlock_context(), errno, sw_alloc(), and sw_free().

Referenced by ast_context_add_switch(), and context_merge_incls_swits_igps_other_registrars().

{
 int idx;
 struct ast_sw *new_sw;

 /* allocate new sw structure ... */
 if (!(new_sw = sw_alloc(value, data, eval, registrar))) {
 return -1;
 }

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

 /* ... go to last sw and check if context is already swd too... */
 for (idx = 0; idx < ast_context_switches_count(con); idx++) {
 const struct ast_sw *i = ast_context_switches_get(con, idx);

 if (!strcasecmp(ast_get_switch_name(i), ast_get_switch_name(new_sw)) &&
 !strcasecmp(ast_get_switch_data(i), ast_get_switch_data(new_sw))) {
 sw_free(new_sw);
 ast_unlock_context(con);
 errno = EEXIST;
 return -1;
 }
 }

 /* ... sw new context into context list, unlock, return */
 if (AST_VECTOR_APPEND(&con->alts, new_sw)) {
 sw_free(new_sw);
 ast_unlock_context(con);
 return -1;
 }

 ast_verb(3, "Including switch '%s/%s' in context '%s'\n",
 ast_get_switch_name(new_sw), ast_get_switch_data(new_sw), ast_get_context_name(con));

 ast_unlock_context(con);

 return 0;
}

ast_context_destroy()

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

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

Referenced by ast_context_destroy_by_name().

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

ast_context_destroy_by_name()

int ast_context_destroy_by_name	(	const char *	context,
		const char *	registrar
	)

Destroy a context by name.

Parameters

context	Name of the context to destroy
registrar	who registered it

You can optionally leave out the registrar parameter. It will find it based on the context name.

Return values

-1	context not found
0	Success

Definition at line 8244 of file pbx.c.

References ast_context_destroy(), ast_context_find(), ast_unlock_contexts(), and ast_wrlock_contexts().

Referenced by __unload_module(), app_dtor(), ast_sip_destroy_sorcery_global(), check_regcontext(), cleanup_stale_contexts(), handle_cli_dialplan_remove_context(), and unload_module().

{
 struct ast_context *con;
 int ret = -1;

 ast_wrlock_contexts();
 con = ast_context_find(context);
 if (con) {
 ast_context_destroy(con, registrar);
 ret = 0;
 }
 ast_unlock_contexts();

 return ret;
}

ast_context_find()

struct ast_context* ast_context_find

(

const char *

name

)

Find a context.

Parameters

name	name of the context to find

Will search for the context with the given name.

Returns

the ast_context on success, NULL on failure.

Definition at line 2443 of file pbx.c.

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

Referenced by _macro_exec(), app_create(), ast_context_destroy_by_name(), ast_context_verify_includes(), ast_ignore_pattern(), handle_cli_dialplan_add_extension(), handle_cli_dialplan_add_include(), isexten_function_read(), register_exten(), register_peer_exten(), and unregister_exten().

{
 struct ast_context *tmp;
 struct fake_context item;

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

ast_context_find_or_create()

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.

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

References ast_context::alts, 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_VECTOR_INIT, ast_wrlock_contexts(), contexts, 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, NULL, ast_context::refcount, ast_context::registrar, ast_context::root, ast_context::root_table, and tmp().

Referenced by context_merge().

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

 if (!contexts_table) {
 /* Protect creation of contexts_table from reentrancy. */
 ast_wrlock_contexts();
 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_unlock_contexts();
 }

 ast_copy_string(search.name, name, sizeof(search.name));
 if (!extcontexts) {
 ast_rdlock_contexts();
 local_contexts = &contexts;
 tmp = ast_hashtab_lookup(contexts_table, &search);
 if (tmp) {
 tmp->refcount++;
 ast_unlock_contexts();
 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);
 AST_VECTOR_INIT(&tmp->includes, 0);
 AST_VECTOR_INIT(&tmp->ignorepats, 0);
 AST_VECTOR_INIT(&tmp->alts, 0);
 tmp->refcount = 1;
 } else {
 ast_log(LOG_ERROR, "Danger! We failed to allocate a context for %s!\n", name);
 if (!extcontexts) {
 ast_unlock_contexts();
 }
 return NULL;
 }

 if (!extcontexts) {
 tmp->next = *local_contexts;
 *local_contexts = tmp;
 ast_hashtab_insert_safe(contexts_table, tmp); /*put this context into the tree */
 ast_unlock_contexts();
 } 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 extension context '%s'; registrar: %s\n", tmp->name, registrar);
 return tmp;
}

ast_context_ignorepats_count()

int ast_context_ignorepats_count

(

const struct ast_context *

con

)

Definition at line 8740 of file pbx.c.

References AST_VECTOR_SIZE, and ast_context::ignorepats.

Referenced by __ast_context_destroy(), ast_context_add_ignorepat2(), ast_context_remove_ignorepat2(), ast_ignore_pattern(), ast_walk_context_ignorepats(), complete_dialplan_remove_ignorepat(), context_merge_incls_swits_igps_other_registrars(), context_used(), handle_cli_dialplan_save(), lookup_c_ip(), manager_show_dialplan_helper(), and show_dialplan_helper().

{
 return AST_VECTOR_SIZE(&con->ignorepats);
}

ast_context_ignorepats_get()

const struct ast_ignorepat* ast_context_ignorepats_get	(	const struct ast_context *	con,
		int	idx
	)

Definition at line 8745 of file pbx.c.

References AST_VECTOR_GET, and ast_context::ignorepats.

Referenced by ast_context_add_ignorepat2(), ast_ignore_pattern(), ast_walk_context_ignorepats(), 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 AST_VECTOR_GET(&con->ignorepats, idx);
}

ast_context_includes_count()

int ast_context_includes_count

(

const struct ast_context *

con

)

Definition at line 8697 of file pbx.c.

References AST_VECTOR_SIZE, and ast_context::includes.

Referenced by __ast_context_destroy(), ast_context_add_include2(), ast_context_remove_include2(), ast_context_verify_includes(), ast_walk_context_includes(), complete_dialplan_remove_include(), context_merge_incls_swits_igps_other_registrars(), context_used(), find_matching_priority(), handle_cli_dialplan_save(), lookup_ci(), manager_show_dialplan_helper(), pbx_find_extension(), and show_dialplan_helper().

{
 return AST_VECTOR_SIZE(&con->includes);
}

ast_context_includes_get()

const struct ast_include* ast_context_includes_get	(	const struct ast_context *	con,
		int	idx
	)

Definition at line 8702 of file pbx.c.

References AST_VECTOR_GET, and ast_context::includes.

Referenced by ast_context_add_include2(), ast_context_verify_includes(), ast_walk_context_includes(), complete_dialplan_remove_include(), context_merge_incls_swits_igps_other_registrars(), find_matching_priority(), handle_cli_dialplan_save(), lookup_ci(), manager_show_dialplan_helper(), pbx_find_extension(), and show_dialplan_helper().

{
 return AST_VECTOR_GET(&con->includes, idx);
}

ast_context_lockmacro()

int ast_context_lockmacro

(

const char *

context

)

locks the macrolock in the 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.

Parameters

context

The context

Definition at line 5162 of file pbx.c.

References ast_mutex_lock, ast_unlock_contexts(), c, find_context_locked(), and ast_context::macrolock.

Referenced by _macro_exec().

{
 struct ast_context *c;
 int ret = -1;

 c = find_context_locked(context);
 if (c) {
 ast_unlock_contexts();

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

 return ret;
}

ast_context_remove_extension()

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

Simply remove extension from context.

Note

This function will lock conlock.

Definition at line 4952 of file pbx.c.

References ast_context_remove_extension_callerid(), AST_EXT_MATCHCID_ANY, and NULL.

Referenced by ast_sip_persistent_endpoint_update_state(), AST_TEST_DEFINE(), conf_ended(), delete_extens(), register_peer_exten(), sla_station_destructor(), sla_trunk_destructor(), unregister_exten(), and unregister_extension().

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

ast_context_remove_extension2()

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

References ast_context_remove_extension_callerid2(), AST_EXT_MATCHCID_ANY, and NULL.

Referenced by add_extension(), and add_hints().

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

ast_context_remove_extension_callerid()

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

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

Referenced by ast_context_remove_extension(), handle_cli_dialplan_remove_extension(), and manager_dialplan_extension_remove().

{
 int ret = -1; /* default error return */
 struct ast_context *c;

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

 return ret;
}

ast_context_remove_extension_callerid2()

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

References add_exten_to_pattern_tree(), 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(), ext_strncpy(), ast_exten::exten, match_char::exten, ast_exten::label, LOG_ERROR, LOG_NOTICE, LOG_WARNING, ast_exten::matchcid, ast_exten::name, ast_context::name, ast_exten::next, NULL, 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];
 char dummy_cid[1024];
 struct ast_exten *previous_peer = NULL;
 struct ast_exten *next_peer = NULL;
 int found = 0;

 if (!already_locked)
 ast_wrlock_context(con);

#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;
 ext_strncpy(dummy_name, extension, sizeof(dummy_name), 1);
 ex.matchcid = matchcallerid;
 if (callerid) {
 ex.cidmatch = dummy_cid;
 ext_strncpy(dummy_cid, callerid, sizeof(dummy_cid), 1);
 } else {
 ex.cidmatch = NULL;
 }
 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->name);
 }
 }

 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->name);
 }
 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->name, 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->name, 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, ex.exten) &&
 (!matchcallerid ||
 (!ast_strlen_zero(ex.cidmatch) && !ast_strlen_zero(exten->cidmatch) && !strcmp(exten->cidmatch, ex.cidmatch)) ||
 (ast_strlen_zero(ex.cidmatch) && 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->