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 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	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	MAX_EXTENBUF_SIZE   512
#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_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)
	Remove an ignorepat. More...
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_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 *extension)
	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)
int	ast_get_extension_data (char *buf, int bufsize, struct ast_channel *c, const char *context, const char *exten, int priority)
	Fill a string buffer with the data at a dialplan extension. More...
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_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...
int	pbx_parse_location (struct ast_channel *chan, char **contextp, char **extenp, char **prip, int *ipri, int *mode, char *rest)
	Parses a dialplan location into context, extension, priority. 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 1234 of file pbx.c.

BITS_PER

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

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.

HASH_EXTENHINT_SIZE

#define HASH_EXTENHINT_SIZE   563

Definition at line 365 of file pbx.c.

HINTDEVICE_DATA_LENGTH

#define HINTDEVICE_DATA_LENGTH   16

Definition at line 358 of file pbx.c.

INC_DST_OVERFLOW_CHECK

#define INC_DST_OVERFLOW_CHECK

MAX_EXTENBUF_SIZE

#define MAX_EXTENBUF_SIZE   512

Definition at line 1662 of file pbx.c.

MORE

#define MORE

(

s

)

(*candidate_exten_advance(s))

Definition at line 1233 of file pbx.c.

NEW_MATCHER_CHK_MATCH

#define NEW_MATCHER_CHK_MATCH

NEW_MATCHER_RECURSE

#define NEW_MATCHER_RECURSE

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

STATUS_NO_EXTENSION

#define STATUS_NO_EXTENSION   2

Definition at line 2465 of file pbx.c.

STATUS_NO_LABEL

#define STATUS_NO_LABEL   4

Definition at line 2467 of file pbx.c.

STATUS_NO_PRIORITY

#define STATUS_NO_PRIORITY   3

Definition at line 2466 of file pbx.c.

STATUS_SUCCESS

#define STATUS_SUCCESS   5

Definition at line 2468 of file pbx.c.

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

{
    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(5, "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;
    }
}

References __ast_internal_context_destroy(), 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, contexts, ast_exten::exten, ignorepat_free(), include_free(), ast_exten::matchcid, ast_exten::name, ast_context::name, ast_context::next, ast_sw::next, NULL, ast_exten::peer_table, ast_exten::priority, ast_exten::registrar, registrar, ast_context::root_table, sw_free(), and tmp().

Referenced by ast_context_destroy().

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

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

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

Referenced by ast_async_goto_if_exists(), and ast_goto_if_exists().

__ast_internal_context_destroy()

static void __ast_internal_context_destroy ( struct ast_context *  con )

static

Definition at line 8015 of file pbx.c.

{
    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);
 
    /* 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_free(tmp);
}

References ast_free, ast_hashtab_destroy(), ast_rwlock_destroy, AST_VECTOR_CALLBACK_VOID, AST_VECTOR_FREE, destroy_exten(), destroy_pattern_tree(), el, ignorepat_free(), include_free(), ast_exten::next, NULL, ast_exten::peer, sw_free(), and tmp().

Referenced by __ast_context_destroy(), and ast_merge_contexts_and_delete().

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

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

References args, 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, autofallthrough, c, collect_digits(), digit, ast_pbx::dtimeoutms, error(), indicate_busy(), indicate_congestion(), LOG_WARNING, NULL, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_destroy(), raise_exception(), ast_pbx::rtimeoutms, S_COR, set_ext_pri(), and status.

Referenced by ast_pbx_run_args(), and pbx_thread().

__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 359 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 2223 of file pbx.c.

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

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

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.

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

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

action_extensionstatelist()

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

static

Definition at line 8344 of file pbx.c.

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

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

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

{
    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[MAX_EXTENBUF_SIZE];
    volatile size_t required_space = strlen(e1->exten) + 1;
    struct pattern_node pat_node[2];
 
    if (e1->matchcid) {
        required_space += (strlen(e1->cidmatch) + 2 /* '/' + NULL */);
        if (required_space > MAX_EXTENBUF_SIZE) {
            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 {
        if (required_space > MAX_EXTENBUF_SIZE) {
            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;
        }
        ast_copy_string(extenbuf, e1->exten, required_space);
    }
 
#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;
}

References add_pattern_node(), already_in_tree(), ARRAY_LEN, ast_copy_string(), ast_debug, ast_log, pattern_node::buf, buf, ast_exten::cidmatch, match_char::deleted, ast_exten::exten, match_char::exten, get_pattern_node(), LOG_ERROR, LOG_WARNING, ast_exten::matchcid, MAX_EXTENBUF_SIZE, 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().

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

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

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_hint::devices, ast_hintdevice::hint, ast_hintdevice::hintdevice, hintdevice_data, hintdevice_destroy(), hintdevices, str, and strsep().

Referenced by ast_add_hint(), and ast_change_hint().

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

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

References ast_calloc, pattern_node::buf, current, insert_in_next_chars_alt_char_list(), match_char::is_pattern, NULL, ast_context::pattern_tree, pattern_node::specif, match_char::specificity, and match_char::x.

Referenced by add_exten_to_pattern_tree().

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

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

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, ast_exten::data, ast_exten::datad, el, 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, replace(), ast_context::root, ast_context::root_table, tmp(), and match_char::x.

Referenced by ast_add_extension2_lockopt().

alloc_device_state_info()

static struct ao2_container * alloc_device_state_info ( void  )

static

Definition at line 3076 of file pbx.c.

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

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_container_alloc_list, and NULL.

Referenced by ast_extension_state_extended(), and device_state_notify_callbacks().

already_in_tree()

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

static

Definition at line 1402 of file pbx.c.

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

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

Referenced by add_exten_to_pattern_tree().

ast_active_calls()

int ast_active_calls

(

void

)

Retrieve the number of active calls.

Definition at line 4760 of file pbx.c.

{
    return countcalls;
}

References countcalls.

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

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

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

References ast_add_extension2(), ast_unlock_contexts(), c, voicemailpwcheck::context, ast_context::data, find_context_locked(), NULL, priority, registrar, and replace().

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_extension(), register_peer_exten(), sla_build_station(), and sla_build_trunk().

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

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

References ast_add_extension2_lockopt(), priority, registrar, and replace().

Referenced by add_extensions(), ast_add_extension(), context_merge(), lua_register_hints(), manager_dialplan_extension_add(), pbx_load_config(), and pbx_load_users().

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

{
    /*
     * 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 evaluate 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);
        }
    }
 
    if (priority == PRIORITY_HINT) {
        /* Fluff in a hint is fine. This prevents the removal of dashes from dynamically
         * created hints during a reload. */
        exten_fluff = 0;
    } else {
        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;
}

References add_exten_to_pattern_tree(), add_priority(), 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::data, ast_exten::datad, DEBUG_ATLEAST, el, errno, ext_cmp(), ext_fluff_count(), ext_strncpy(), ast_exten::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_context::name, ast_exten::next, NULL, ast_context::pattern_tree, pbx_substitute_variables_helper(), priority, PRIORITY_HINT, registrar, ast_exten::registrar_file, ast_exten::registrar_line, replace(), ast_context::root, ast_context::root_table, tmp(), VAR_BUF_SIZE, and match_char::x.

Referenced by ast_add_extension2(), ast_add_extension2_nolock(), and ast_add_extension_nolock().

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

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

References ast_add_extension2_lockopt(), priority, registrar, and replace().

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

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

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

References ast_add_extension2_lockopt(), c, voicemailpwcheck::context, ast_context::data, find_context(), NULL, priority, registrar, and replace().

Referenced by ast_merge_contexts_and_delete().

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

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

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(), ast_hint::devices, 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, NULL, and statecbs.

Referenced by add_priority(), and ast_add_extension2_lockopt().

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

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

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, voicemailpwcheck::context, ast_channel::exten, LOG_WARNING, and priority.

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(), my_handle_dtmf(), onModeChanged(), ooh323_rtp_read(), and pbx_parseable_goto().

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

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

References ast_async_goto(), ast_channel_get_by_name(), ast_channel_unref, voicemailpwcheck::context, ast_channel::exten, and priority.

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

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

References __ast_goto_if_exists(), voicemailpwcheck::context, ast_channel::exten, and priority.

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

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

References pbx_parseable_goto().

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

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

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

References c, voicemailpwcheck::context, E_CANMATCH, ast_exten::exten, NULL, pbx_extension_helper(), and priority.

Referenced by __analog_ss_thread(), analog_ss_thread(), background_detect_exec(), dp_lookup(), dundi_lookup_local(), get_destination(), leave_voicemail(), loopback_canmatch(), pbx_builtin_background(), test_exten(), and valid_exit().

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

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

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

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

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

References ast_context_add_ignorepat2(), ast_unlock_contexts(), c, voicemailpwcheck::context, find_context_locked(), registrar, and value.

Referenced by handle_cli_dialplan_add_ignorepat().

ast_context_add_ignorepat2()

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

Definition at line 6848 of file pbx.c.

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

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(), ast_context::ignorepats, registrar, and value.

Referenced by ast_context_add_ignorepat(), and context_merge_incls_swits_igps_other_registrars().

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

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

References ast_context_add_include2(), ast_unlock_contexts(), c, voicemailpwcheck::context, find_context_locked(), and registrar.

Referenced by AST_TEST_DEFINE(), and handle_cli_dialplan_add_include().

ast_context_add_include2()

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

Add a context include.

Adds an include taking a struct ast_context as the first parameter

Note

See ast_context_add_include for information on arguments

Definition at line 6684 of file pbx.c.

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

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(), ast_context::includes, registrar, and value.

Referenced by ast_context_add_include(), and context_merge_incls_swits_igps_other_registrars().

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

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

References ast_context_add_switch2(), ast_unlock_contexts(), c, voicemailpwcheck::context, ast_context::data, find_context_locked(), and registrar.

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

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

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(), ast_sw::data, errno, ast_sw::eval, registrar, sw_alloc(), sw_free(), and value.

Referenced by ast_context_add_switch(), and context_merge_incls_swits_igps_other_registrars().

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.

Definition at line 8221 of file pbx.c.

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

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

Referenced by ast_context_destroy_by_name(), AST_TEST_DEFINE(), parking_lot_cfg_remove_extensions(), remove_all_configured_parking_lot_extensions(), remove_pending_parking_lot_extensions(), sla_destroy(), and unload_module().

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

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

References ast_context_destroy(), ast_context_find(), ast_unlock_contexts(), ast_wrlock_contexts(), voicemailpwcheck::context, and registrar.

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

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

{
    struct ast_context *tmp;
    struct ast_context item = {
        .name = name,
    };
 
    if (!name) {
        return NULL;
    }
    ast_rdlock_contexts();
    if (contexts_table) {
        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;
}

References ast_hashtab_lookup(), ast_rdlock_contexts(), ast_unlock_contexts(), ast_walk_contexts(), contexts_table, item, name, aco_type::name, NULL, and tmp().

Referenced by app_create(), ast_context_destroy_by_name(), ast_context_verify_includes(), ast_ignore_pattern(), context_included(), handle_cli_dialplan_add_extension(), handle_cli_dialplan_add_include(), and isexten_function_read().

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

{
    struct ast_context *tmp, **local_contexts;
    struct ast_context search = {
        .name = name,
    };
    size_t name_bytes = strlen(name);
    size_t registrar_bytes = strlen(registrar);
    int length = sizeof(struct ast_context) + name_bytes + registrar_bytes + 2;
 
    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();
    }
 
    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);
        tmp->name = memcpy(&tmp->data[0], name, name_bytes);
        tmp->registrar = memcpy(&tmp->data[name_bytes + 1], registrar, registrar_bytes);
        tmp->root = NULL;
        tmp->root_table = NULL;
        AST_VECTOR_INIT(&tmp->includes, 0);
        AST_VECTOR_INIT(&tmp->ignorepats, 0);
        AST_VECTOR_INIT(&tmp->alts, 0);
        tmp->refcount = 1;
 
        /* The context 'name' must be stored at the beginning of 'data.' The
         * order of subsequent strings (currently only 'registrar') is not
         * relevant. */
        ast_assert(tmp->name == &tmp->data[0]);
    } 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;
}

References ast_assert, ast_calloc, 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_rdlock_contexts(), ast_rwlock_init, ast_unlock_contexts(), AST_VECTOR_INIT, ast_wrlock_contexts(), contexts, contexts_table, local_contexts, LOG_ERROR, name, ast_context::name, NULL, registrar, and tmp().

Referenced by add_hints(), app_create(), ast_compile_ael2(), ast_sip_persistent_endpoint_add_to_regcontext(), AST_TEST_DEFINE(), context_merge(), create_test_dialplan(), handle_cli_dialplan_add_extension(), handle_cli_dialplan_add_include(), load_module(), lua_register_hints(), lua_register_switches(), manager_dialplan_extension_add(), parking_duration_callback(), parking_lot_cfg_create_extensions(), pbx_load_config(), pbx_load_users(), set_config(), sla_build_station(), and sla_build_trunk().

ast_context_ignorepats_count()

int ast_context_ignorepats_count

(

const struct ast_context *

con

)

Definition at line 8722 of file pbx.c.

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

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

ast_context_ignorepats_get()

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

Definition at line 8727 of file pbx.c.

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

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

ast_context_includes_count()

int ast_context_includes_count

(

const struct ast_context *

con

)

Definition at line 8679 of file pbx.c.

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

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

ast_context_includes_get()

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

Definition at line 8684 of file pbx.c.

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

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

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

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

References ast_context_remove_extension_callerid(), AST_EXT_MATCHCID_ANY, voicemailpwcheck::context, NULL, priority, and registrar.

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

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

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

References ast_context_remove_extension_callerid2(), AST_EXT_MATCHCID_ANY, NULL, priority, and registrar.

Referenced by add_extension(), and add_hints().

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

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

References ast_context_remove_extension_callerid2(), ast_unlock_contexts(), c, voicemailpwcheck::context, find_context_locked(), priority, and registrar.

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

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

{
    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_debug(3,"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->peer ? exten->peer : exten->next;
         peer && !strcmp(peer->exten, ex.exten) &&
            (!callerid || (!matchcallerid && !peer->matchcid) || (matchcallerid && peer->matchcid && !strcmp(peer->cidmatch, ex.cidmatch))) ;
            peer = next_peer, next_peer = next_peer ? (next_peer->peer ? next_peer->peer : next_peer->next) : NULL) {
 
        if ((priority == 0 || peer->priority == priority) &&
                (!registrar || !strcmp(peer->registrar, registrar) )) {
            found = 1;
 
            /* we are first priority extension? */
            if (!previous_peer) {
                /*
                 * We are first in the priority chain, so must update the extension chain.
                 * The next node is either the next priority or the next extension
                 */
                struct ast_exten *next_node = peer->peer ? peer->peer : peer->next;
                if (peer->peer) {
                    /* move the peer_table and peer_label_table down to the next peer, if
                       it is there */
                    peer->peer->peer_table = peer->peer_table;
                    peer->peer->peer_label_table = peer->peer_label_table;
                    peer->peer_table = NULL;
                    peer->peer_label_table = NULL;
                }
                if (!prev_exten) {  /* change the root... */
                    con->root = next_node;
                } else {
                    prev_exten->next = next_node; /* unlink */
                }
                if (peer->peer) { /* update the new head of the pri list */
                    peer->peer->next = peer->next;
                }
            } else { /* easy, we are not first priority in extension */
                previous_peer->peer = peer->peer;
            }
 
 
            /* now, free whole priority extension */
            destroy_exten(peer);
        } else {
            previous_peer = peer;
        }
    }
    if (!already_locked)
        ast_unlock_context(con);
    return found ? 0 : -1;
}

References add_exten_to_pattern_tree(), ast_debug, 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, 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, priority, ast_exten::priority, ast_exten::registrar, 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().

ast_context_remove_ignorepat()

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

Remove an ignorepat.

Parameters

context	context from which to remove the pattern
ignorepat	the pattern to remove
registrar	the registrar of the ignore pattern

This removes the given ignorepattern

Return values

0	on success
-1	on failure

Definition at line 6795 of file pbx.c.

{
    int ret = -1;
    struct ast_context *c;
 
    c = find_context_locked(context);
    if (c) {
        ret = ast_context_remove_ignorepat2(c, ignorepat, registrar);
        ast_unlock_contexts();
    }
    return ret;
}

References ast_context_remove_ignorepat2(), ast_unlock_contexts(), c, voicemailpwcheck::context, find_context_locked(), and registrar.

Referenced by handle_cli_dialplan_remove_ignorepat().

ast_context_remove_ignorepat2()

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

Definition at line 6808 of file pbx.c.

{
    int idx;
 
    ast_wrlock_context(con);
 
    for (idx = 0; idx < ast_context_ignorepats_count(con); idx++) {
        struct ast_ignorepat *ip = AST_VECTOR_GET(&con->ignorepats, idx);
 
        if (!strcmp(ast_get_ignorepat_name(ip), ignorepat) &&
            (!registrar || (registrar == ast_get_ignorepat_registrar(ip)))) {
            AST_VECTOR_REMOVE_ORDERED(&con->ignorepats, idx);
            ignorepat_free(ip);
            ast_unlock_context(con);
            return 0;
        }
    }
 
    ast_unlock_context(con);
    errno = EINVAL;
    return -1;
}

References ast_context_ignorepats_count(), ast_get_ignorepat_name(), ast_get_ignorepat_registrar(), ast_unlock_context(), AST_VECTOR_GET, AST_VECTOR_REMOVE_ORDERED, ast_wrlock_context(), errno, ignorepat_free(), ast_context::ignorepats, and registrar.

Referenced by ast_context_remove_ignorepat().

ast_context_remove_include()

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

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

Remove a context include.

Definition at line 4836 of file pbx.c.

{
    int ret = -1;
    struct ast_context *c;
 
    c = find_context_locked(context);
    if (c) {
        /* found, remove include from this context ... */
        ret = ast_context_remove_include2(c, include, registrar);
        ast_unlock_contexts();
    }
    return ret;
}

References ast_context_remove_include2(), ast_unlock_contexts(), c, voicemailpwcheck::context, find_context_locked(), and registrar.

Referenced by handle_cli_dialplan_remove_include().

ast_context_remove_include2()

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

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

Removes an include by an ast_context structure.

Return values

0	on success.
-1	on failure.

Definition at line 4859 of file pbx.c.

{
    int ret = -1;
    int idx;
 
    ast_wrlock_context(con);
 
    /* find our include */
    for (idx = 0; idx < ast_context_includes_count(con); idx++) {
        struct ast_include *i = AST_VECTOR_GET(&con->includes, idx);
 
        if (!strcmp(ast_get_include_name(i), include) &&
                (!registrar || !strcmp(ast_get_include_registrar(i), registrar))) {
 
            /* remove from list */
            ast_verb(3, "Removing inclusion of context '%s' in context '%s; registrar=%s'\n", include, ast_get_context_name(con), registrar);
            AST_VECTOR_REMOVE_ORDERED(&con->includes, idx);
 
            /* free include and return */
            include_free(i);
            ret = 0;
            break;
        }
    }
 
    ast_unlock_context(con);
 
    return ret;
}

References ast_context_includes_count(), ast_get_context_name(), ast_get_include_name(), ast_get_include_registrar(), ast_unlock_context(), AST_VECTOR_GET, AST_VECTOR_REMOVE_ORDERED, ast_verb, ast_wrlock_context(), include_free(), ast_context::includes, and registrar.

Referenced by ast_context_remove_include().

ast_context_remove_switch()

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

Remove a switch.

Note

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

Definition at line 4894 of file pbx.c.

{
    int ret = -1; /* default error return */
    struct ast_context *c;
 
    c = find_context_locked(context);
    if (c) {
        /* remove switch from this context ... */
        ret = ast_context_remove_switch2(c, sw, data, registrar);
        ast_unlock_contexts();
    }
    return ret;
}

References ast_context_remove_switch2(), ast_unlock_contexts(), c, voicemailpwcheck::context, ast_context::data, find_context_locked(), and registrar.

ast_context_remove_switch2()

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

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

Note

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

Definition at line 4916 of file pbx.c.

{
    int idx;
    int ret = -1;
 
    ast_wrlock_context(con);
 
    /* walk switches */
    for (idx = 0; idx < ast_context_switches_count(con); idx++) {
        struct ast_sw *i = AST_VECTOR_GET(&con->alts, idx);
 
        if (!strcmp(ast_get_switch_name(i), sw) &&
            !strcmp(ast_get_switch_data(i), data) &&
            (!registrar || !strcmp(ast_get_switch_registrar(i), registrar))) {
 
            /* found, remove from list */
            ast_verb(3, "Removing switch '%s' from context '%s; registrar=%s'\n", sw, ast_get_context_name(con), registrar);
            AST_VECTOR_REMOVE_ORDERED(&con->alts, idx);
 
            /* free switch and return */
            sw_free(i);
            ret = 0;
            break;
        }
    }
 
    ast_unlock_context(con);
 
    return ret;
}

References ast_context::alts, ast_context_switches_count(), ast_get_context_name(), ast_get_switch_data(), ast_get_switch_name(), ast_get_switch_registrar(), ast_unlock_context(), AST_VECTOR_GET, AST_VECTOR_REMOVE_ORDERED, ast_verb, ast_wrlock_context(), ast_sw::data, registrar, and sw_free().

Referenced by ast_context_remove_switch().

ast_context_set_autohints()

void ast_context_set_autohints	(	struct ast_context *	con,
		int	enabled
	)

Enable or disable autohints support on a context.

Parameters

con	pointer to the context
enabled	whether autohints are enabled

Definition at line 6230 of file pbx.c.

{
    con->autohints = enabled;
}

References ast_context::autohints, and enabled.

Referenced by pbx_load_config().

ast_context_switches_count()

int ast_context_switches_count

(

const struct ast_context *

con

)

Definition at line 8634 of file pbx.c.

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

References ast_context::alts, and AST_VECTOR_SIZE.

Referenced by __ast_context_destroy(), ast_context_add_switch2(), ast_context_remove_switch2(), ast_walk_context_switches(), context_merge_incls_swits_igps_other_registrars(), context_used(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), pbx_find_extension(), and show_dialplan_helper().

ast_context_switches_get()

const struct ast_sw * ast_context_switches_get	(	const struct ast_context *	con,
		int	idx
	)

Definition at line 8639 of file pbx.c.

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

References ast_context::alts, and AST_VECTOR_GET.

Referenced by ast_context_add_switch2(), ast_walk_context_switches(), context_merge_incls_swits_igps_other_registrars(), handle_cli_dialplan_save(), manager_show_dialplan_helper(), pbx_find_extension(), and show_dialplan_helper().

ast_context_verify_includes()

int ast_context_verify_includes

(

struct ast_context *

con

)

Verifies includes in an ast_contect structure.

Parameters

con	context in which to verify the includes

Return values

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

Definition at line 8732 of file pbx.c.

{
    int idx;
    int res = 0;
    int includecount = ast_context_includes_count(con);
 
    if (includecount >= AST_PBX_MAX_STACK) {
        ast_log(LOG_WARNING, "Context %s contains too many includes (%d). Maximum is %d.\n",
            ast_get_context_name(con), includecount, AST_PBX_MAX_STACK);
    }
 
    for (idx = 0; idx < includecount; idx++) {
        const struct ast_include *inc = ast_context_includes_get(con, idx);
 
        if (ast_context_find(include_rname(inc))) {
            continue;
        }
 
        res = -1;
        ast_log(LOG_WARNING, "Context '%s' tries to include nonexistent context '%s'\n",
            ast_get_context_name(con), include_rname(inc));
        break;
    }
 
    return res;
}

References ast_context_find(), ast_context_includes_count(), ast_context_includes_get(), ast_get_context_name(), ast_log, AST_PBX_MAX_STACK, include_rname(), and LOG_WARNING.

Referenced by pbx_load_module().

ast_devstate_to_extenstate()

enum ast_extension_states ast_devstate_to_extenstate

(

enum ast_device_state

devstate

)

Map devstate to an extension state.

Parameters

[in]

devstate

device state

Returns

the extension state mapping.

Definition at line 3006 of file pbx.c.

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

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

Referenced by ast_extension_state3(), and AST_TEST_DEFINE().

ast_exists_extension()

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

Determine whether an extension exists.

Parameters

c	this is not important
context	which context to look in
exten	which extension to search for
priority	priority of the action within the extension
callerid	callerid to search for

Note

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

Returns

If an extension within the given context(or callerid) with the given priority is found a non zero value will be returned. Otherwise, 0 is returned.

Definition at line 4175 of file pbx.c.

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

References c, voicemailpwcheck::context, E_MATCH, ast_exten::exten, NULL, pbx_extension_helper(), and priority.

Referenced by __analog_ss_thread(), __ast_goto_if_exists(), __ast_pbx_run(), acf_isexten_exec(), action_originate(), add_to_regcontext(), analog_ss_thread(), ast_app_dtget(), ast_bridge_setup_after_goto(), ast_pbx_outgoing_exten_predial(), ast_sip_persistent_endpoint_update_state(), chan_pjsip_cng_tone_detected(), cli_console_dial(), comeback_goto(), conf_run(), dahdi_handle_dtmf(), dial_exec_full(), dialplan_has_destination_cb(), disa_exec(), dp_lookup(), dundi_lookup_local(), fax_detect_framehook(), findmeexec(), get_destination(), gosub_exec(), grab_transfer(), handle_gosub(), isexten_function_read(), jingle_new(),