features.c File Reference

Routines implementing call features as call pickup, parking and transfer. More...

#include "asterisk.h"
#include "asterisk/_private.h"
#include <pthread.h>
#include <signal.h>
#include <sys/time.h>
#include <sys/signal.h>
#include <netinet/in.h>
#include "asterisk/lock.h"
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/causes.h"
#include "asterisk/module.h"
#include "asterisk/translate.h"
#include "asterisk/app.h"
#include "asterisk/say.h"
#include "asterisk/features.h"
#include "asterisk/musiconhold.h"
#include "asterisk/config.h"
#include "asterisk/cli.h"
#include "asterisk/manager.h"
#include "asterisk/utils.h"
#include "asterisk/adsi.h"
#include "asterisk/devicestate.h"
#include "asterisk/monitor.h"
#include "asterisk/audiohook.h"
#include "asterisk/global_datastores.h"
#include "asterisk/astobj2.h"
#include "asterisk/cel.h"
#include "asterisk/test.h"

Include dependency graph for features.c:

Go to the source code of this file.

Data Structures
struct	ast_bridge_thread_obj
struct	ast_dial_features
struct	ast_park_call_args
struct	ast_parkinglot
	Structure for parking lots which are put in a container. More...
struct	ast_parkinglot::parkinglot_parklist
struct	feature_ds
struct	feature_exten
struct	feature_group
struct	feature_group_exten
struct	feature_groups
struct	feature_list
struct	park_app_args
struct	parkeduser
	Description of one parked call, added to a list while active, then removed. The list belongs to a parkinglot. More...
struct	parking_dp_context
struct	parking_dp_map
struct	parking_dp_ramp
struct	parking_dp_ramp_map
struct	parking_dp_space_map
struct	parking_dp_spaces
struct	parkinglot_cfg
Defines
#define	AST_MAX_WATCHERS   256
#define	DEFAULT_ATXFER_CALLBACK_RETRIES   2
#define	DEFAULT_ATXFER_DROP_CALL   0
#define	DEFAULT_ATXFER_LOOP_DELAY   10000
#define	DEFAULT_COMEBACK_CONTEXT   "parkedcallstimeout"
#define	DEFAULT_COMEBACK_DIAL_TIME   30
#define	DEFAULT_COMEBACK_TO_ORIGIN   1
#define	DEFAULT_FEATURE_DIGIT_TIMEOUT   1000
#define	DEFAULT_NOANSWER_TIMEOUT_ATTENDED_TRANSFER   15000
#define	DEFAULT_PARK_EXTENSION   "700"
#define	DEFAULT_PARK_TIME   45000
#define	DEFAULT_TRANSFER_DIGIT_TIMEOUT   3000
#define	FEATURES_COUNT   ARRAY_LEN(builtin_features)
#define	HFS_FORMAT   "%-25s %-7s %-7s\n"
#define	MAX_DIAL_FEATURE_OPTIONS   30
Enumerations
enum	{   BRIDGE_OPT_PLAYTONE = (1 << 0), OPT_CALLEE_HANGUP = (1 << 1), OPT_CALLER_HANGUP = (1 << 2), OPT_DURATION_LIMIT = (1 << 3),   OPT_DURATION_STOP = (1 << 4), OPT_CALLEE_TRANSFER = (1 << 5), OPT_CALLER_TRANSFER = (1 << 6), OPT_CALLEE_MONITOR = (1 << 7),   OPT_CALLER_MONITOR = (1 << 8), OPT_CALLEE_PARK = (1 << 9), OPT_CALLER_PARK = (1 << 10), OPT_CALLEE_KILL = (1 << 11),   OPT_CALLEE_GO_ON = (1 << 12) }
enum	{ OPT_ARG_DURATION_LIMIT = 0, OPT_ARG_DURATION_STOP, OPT_ARG_CALLEE_GO_ON, OPT_ARG_ARRAY_SIZE }
enum	ast_park_call_options { AST_PARK_OPT_RINGING = (1 << 0), AST_PARK_OPT_RANDOMIZE = (1 << 1), AST_PARK_OPT_SILENCE = (1 << 2) }
enum	feature_interpret_op { FEATURE_INTERPRET_DETECT, FEATURE_INTERPRET_DO, FEATURE_INTERPRET_CHECK }
Functions
static void	__fini_feature_groups (void)
static void	__fini_feature_list (void)
static void	__init_feature_groups (void)
static void	__init_feature_list (void)
static int	action_bridge (struct mansession *s, const struct message *m)
	Bridge channels together.
static int	add_features_datastore (struct ast_channel *chan, const struct ast_flags *my_features, const struct ast_flags *peer_features)
static void	add_features_datastores (struct ast_channel *caller, struct ast_channel *callee, struct ast_bridge_config *config)
static int	adsi_announce_park (struct ast_channel *chan, char *parkingexten)
	Announce call parking by ADSI.
int	ast_bridge_call (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config)
	bridge the call and set CDR
int	ast_bridge_timelimit (struct ast_channel *chan, struct ast_bridge_config *config, char *parse, struct timeval *calldurationlimit)
	parse L option and read associated channel variables to set warning, warning frequency, and timelimit
int	ast_can_pickup (struct ast_channel *chan)
	Test if a channel can be picked up.
void	ast_channel_log (char *title, struct ast_channel *chan)
int	ast_do_pickup (struct ast_channel *chan, struct ast_channel *target)
	Pickup a call target.
int	ast_feature_detect (struct ast_channel *chan, struct ast_flags *features, const char *code, struct ast_call_feature *feature)
	detect a feature before bridging
int	ast_features_init (void)
int	ast_features_reload (void)
	Reload call features from features.conf.
struct ast_call_feature *	ast_find_call_feature (const char *name)
	look for a call feature entry by its sname
int	ast_masq_park_call (struct ast_channel *rchan, struct ast_channel *peer, int timeout, int *extout)
	Park a call via a masqueraded channel.
int	ast_masq_park_call_exten (struct ast_channel *park_me, struct ast_channel *parker, const char *park_exten, const char *park_context, int timeout, int *extout)
	Park a call via a masqueraded channel.
int	ast_park_call (struct ast_channel *park_me, struct ast_channel *parker, int timeout, const char *park_exten, int *extout)
	Park a call and read back parked location.
int	ast_park_call_exten (struct ast_channel *park_me, struct ast_channel *parker, const char *park_exten, const char *park_context, int timeout, int *extout)
	Park a call and read back parked location.
int	ast_parking_ext_valid (const char *exten_str, struct ast_channel *chan, const char *context)
	Determine if parking extension exists in a given context.
int	ast_pickup_call (struct ast_channel *chan)
	Pickup a call.
const char *	ast_pickup_ext (void)
	Determine system call pickup extension.
struct ast_channel *	ast_pickup_find_by_group (struct ast_channel *chan)
	Find a pickup channel target by group.
void	ast_rdlock_call_features (void)
void	ast_register_feature (struct ast_call_feature *feature)
	register new feature into feature_list
void	ast_unlock_call_features (void)
void	ast_unregister_feature (struct ast_call_feature *feature)
	unregister feature from feature_set
static void	ast_unregister_features (void)
	Remove all features in the list.
static void	ast_unregister_groups (void)
	Remove all feature groups in the list.
static void	atxfer_fail_cleanup (struct ast_channel *transferee, struct ast_channel *transferer, struct ast_party_connected_line *connected_line)
static void *	bridge_call_thread (void *data)
	bridge the call
static void	bridge_call_thread_launch (struct ast_bridge_thread_obj *data)
	create thread for the parked call
static int	bridge_exec (struct ast_channel *chan, const char *data)
	Bridge channels.
static struct parking_dp_context *	build_dialplan_useage_context (struct ast_parkinglot *lot)
static int	build_dialplan_useage_map (struct parking_dp_map *usage_map, int complain)
static struct parking_dp_ramp *	build_dialplan_useage_ramp (const char *exten, int exclusive)
static struct parking_dp_spaces *	build_dialplan_useage_spaces (int start, int stop)
static struct ast_parkinglot *	build_parkinglot (const char *pl_name, struct ast_variable *var)
	Build parkinglot from configuration and chain it in if it doesn't already exist.
static int	builtin_atxfer (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
	Attended transfer.
static int	builtin_automixmonitor (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
static int	builtin_automonitor (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
	Monitor a channel by DTMF.
static int	builtin_blindtransfer (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
	Blind transfer user to another extension.
static int	builtin_disconnect (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
static int	builtin_feature_get_exten (struct ast_channel *chan, const char *feature_name, char *buf, size_t len)
static int	builtin_parkcall (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
	support routing for one touch call parking
static char *	callback_dialoptions (struct ast_flags *features_callee, struct ast_flags *features_caller, char *options, size_t len)
static int	check_compat (struct ast_channel *c, struct ast_channel *newchan)
	make channels compatible
static void	check_goto_on_transfer (struct ast_channel *chan)
	Check goto on transfer.
static void	clear_dialed_interfaces (struct ast_channel *chan)
static struct ast_parkinglot *	copy_parkinglot (const char *name, const struct ast_parkinglot *parkinglot)
	Copy parkinglot and store it with new name.
static struct ast_parkinglot *	create_dynamic_parkinglot (const char *name, struct ast_channel *chan)
static struct ast_parkinglot *	create_parkinglot (const char *name)
	Allocate parking lot structure.
static void	destroy_dialplan_usage_context (struct parking_dp_context *doomed)
static void	destroy_dialplan_usage_map (struct parking_dp_map *doomed)
static void	destroy_space (const char *context, int space)
static void	dial_features_destroy (void *data)
static void *	dial_features_duplicate (void *data)
static int	dialplan_usage_add_parkinglot (struct parking_dp_map *usage_map, struct ast_parkinglot *lot, int complain)
static int	dialplan_usage_add_parkinglot_data (struct parking_dp_context *ctx_node, struct ast_parkinglot *lot, int complain)
static int	do_bridge_masquerade (struct ast_channel *chan, struct ast_channel *tmpchan)
	Actual bridge.
static void *	do_parking_thread (void *ignore)
	Take care of parked calls and unpark them if needed.
static int	feature_check (struct ast_channel *chan, struct ast_flags *features, char *code)
	Check if a feature exists.
static void	feature_ds_destroy (void *data)
static int	feature_exec_app (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, void *data)
	exec an app by feature
static int	feature_exten_cmp (void *obj, void *arg, int flags)
static int	feature_exten_hash (const void *obj, int flags)
static int	feature_interpret (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense)
	Check the dynamic features.
static int	feature_interpret_helper (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config, const char *code, int sense, char *dynamic_features_buf, struct ast_flags *features, feature_interpret_op operation, struct ast_call_feature *feature)
	Helper function for feature_interpret and ast_feature_detect.
static int	feature_read (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
static struct ast_channel *	feature_request_and_dial (struct ast_channel *caller, const char *caller_name, struct ast_channel *requestor, struct ast_channel *transferee, const char *type, struct ast_format_cap *cap, const char *addr, int timeout, int *outstate, const char *language)
static int	feature_write (struct ast_channel *chan, const char *cmd, char *data, const char *value)
static int	featuremap_read (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
static int	featuremap_write (struct ast_channel *chan, const char *cmd, char *data, const char *value)
static void	features_shutdown (void)
static int	find_channel_by_group (void *obj, void *arg, void *data, int flags)
static struct ast_call_feature *	find_dynamic_feature (const char *name)
	find a call feature by name
static struct feature_group *	find_group (const char *name)
	Find a group by name.
static struct ast_parkinglot *	find_parkinglot (const char *name)
	Find parkinglot by name.
static const char *	findparkinglotname (struct ast_channel *chan)
	Find parking lot name from channel.
static int	finishup (struct ast_channel *chan)
static struct feature_ds *	get_feature_ds (struct ast_channel *chan)
static struct ast_exten *	get_parking_exten (const char *exten_str, struct ast_channel *chan, const char *context)
static unsigned int	get_parkingtime (struct ast_channel *chan, struct ast_parkinglot *parkinglot)
static char *	handle_feature_show (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	CLI command to list configured features.
static char *	handle_features_reload (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_parkedcalls (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	CLI command to list parked calls.
static int	load_config (int reload)
static int	manage_parked_call (struct parkeduser *pu, const struct pollfd *pfds, int nfds, struct pollfd **new_pfds, int *new_nfds, int *ms)
static void	manage_parkinglot (struct ast_parkinglot *curlot, const struct pollfd *pfds, int nfds, struct pollfd **new_pfds, int *new_nfds, int *ms)
	Run management on parkinglots, called once per parkinglot.
static int	manager_park (struct mansession *s, const struct message *m)
	Create manager event for parked calls.
static int	manager_parking_status (struct mansession *s, const struct message *m)
	Dump parking lot status.
static int	manager_parkinglot_list (struct mansession *s, const struct message *m)
static int	masq_park_call (struct ast_channel *rchan, struct ast_channel *peer, struct ast_park_call_args *args)
	Park call via masqueraded channel and announce parking spot on peer channel.
static enum ast_device_state	metermaidstate (const char *data)
	metermaids callback from devicestate.c
static void	notify_metermaids (const char *exten, char *context, enum ast_device_state state)
	Notify metermaids that we've changed an extension.
static void	park_add_hints (const char *context, int start, int stop)
	Add parking hints for all defined parking spaces.
static int	park_call_exec (struct ast_channel *chan, const char *data)
	Park a call.
static int	park_call_full (struct ast_channel *chan, struct ast_channel *peer, struct ast_park_call_args *args)
static void	park_space_abort (struct parkeduser *pu)
static struct parkeduser *	park_space_reserve (struct ast_channel *park_me, struct ast_channel *parker, struct ast_park_call_args *args)
static int	parked_call_exec (struct ast_channel *chan, const char *data)
	Pickup parked call.
static int	parkinglot_activate (struct ast_parkinglot *parkinglot)
static int	parkinglot_activate_cb (void *obj, void *arg, int flags)
static struct ast_parkinglot *	parkinglot_addref (struct ast_parkinglot *parkinglot)
static int	parkinglot_cmp_cb (void *obj, void *arg, int flags)
static int	parkinglot_config_read (const char *pl_name, struct parkinglot_cfg *cfg, struct ast_variable *var)
static void	parkinglot_destroy (void *obj)
	Destroy a parking lot.
static void	parkinglot_feature_flag_cfg (const char *pl_name, int *param, struct ast_variable *var)
static int	parkinglot_hash_cb (const void *obj, const int flags)
static int	parkinglot_is_marked_cb (void *obj, void *arg, int flags)
static int	parkinglot_markall_cb (void *obj, void *arg, int flags)
static void	parkinglot_unref (struct ast_parkinglot *parkinglot)
	Unreference parkinglot object.
static struct ast_cdr *	pick_unlocked_cdr (struct ast_cdr *cdr)
	return the first unlocked cdr in a possible chain
static int	play_message_in_bridged_call (struct ast_channel *caller_chan, struct ast_channel *callee_chan, const char *audiofile)
	Play message to both caller and callee in bridged call, plays synchronously, autoservicing the other channel during the message, so please don't use this for very long messages.
static int	play_message_on_chan (struct ast_channel *play_to, struct ast_channel *other, const char *msg, const char *audiofile)
static int	play_message_to_chans (struct ast_channel *left, struct ast_channel *right, int which, const char *msg, const char *audiofile)
static void	post_manager_event (const char *s, struct parkeduser *pu)
	Output parking event to manager.
static void	process_applicationmap_line (struct ast_variable *var)
static int	process_config (struct ast_config *cfg)
static const char *	real_ctx (struct ast_channel *transferer, struct ast_channel *transferee)
	Find the context for the transfer.
static struct feature_group *	register_group (const char *fgname)
	Add new feature group.
static void	register_group_feature (struct feature_group *fg, const char *exten, struct ast_call_feature *feature)
	Add feature to group.
static int	remap_feature (const char *name, const char *value)
static void	remove_dead_context_usage (const char *context, struct parking_dp_context *old_ctx, struct parking_dp_context *new_ctx)
static void	remove_dead_dialplan_useage (struct parking_dp_map *old_map, struct parking_dp_map *new_map)
static void	remove_dead_ramp_usage (const char *context, struct parking_dp_ramp_map *old_ramps, struct parking_dp_ramp_map *new_ramps)
static void	remove_dead_spaces_usage (const char *context, struct parking_dp_space_map *old_spaces, struct parking_dp_space_map *new_spaces, void(*destroy_space)(const char *context, int space))
static void	remove_exten_if_exist (const char *context, const char *exten, int priority)
static void	set_bridge_features_on_config (struct ast_bridge_config *config, const char *features)
static void	set_c_e_p (struct ast_channel *chan, const char *context, const char *ext, int pri)
	store context, extension and priority
static int	set_chan_app_data (struct ast_channel *chan, const char *src_app_data)
static void	set_config_flags (struct ast_channel *chan, struct ast_bridge_config *config)
static void	set_peers (struct ast_channel **caller, struct ast_channel **callee, struct ast_channel *peer, struct ast_channel *chan, int sense)
	set caller and callee according to the direction
static void	unmap_features (void)
static int	usage_context_add_ramp (struct parking_dp_ramp_map *ramp_map, const char *exten, int exclusive, struct ast_parkinglot *lot, int complain)
static int	usage_context_add_spaces (struct parking_dp_space_map *space_map, int start, int stop, struct ast_parkinglot *lot, int complain)
static int	xfer_park_call_helper (struct ast_channel *park_me, struct ast_channel *parker, struct ast_exten *park_exten)
Variables
static int	adsipark
static char *	app_bridge = "Bridge"
static unsigned int	atxfercallbackretries
static unsigned int	atxferdropcall
static unsigned int	atxferloopdelay
static int	atxfernoanswertimeout
static struct ast_app_option	bridge_exec_options [128] = { [ 'p' ] = { .flag = BRIDGE_OPT_PLAYTONE }, [ 'F' ] = { .flag = OPT_CALLEE_GO_ON , .arg_index = OPT_ARG_CALLEE_GO_ON + 1 }, [ 'h' ] = { .flag = OPT_CALLEE_HANGUP }, [ 'H' ] = { .flag = OPT_CALLER_HANGUP }, [ 'k' ] = { .flag = OPT_CALLEE_PARK }, [ 'K' ] = { .flag = OPT_CALLER_PARK }, [ 'L' ] = { .flag = OPT_DURATION_LIMIT , .arg_index = OPT_ARG_DURATION_LIMIT + 1 }, [ 'S' ] = { .flag = OPT_DURATION_STOP , .arg_index = OPT_ARG_DURATION_STOP + 1 }, [ 't' ] = { .flag = OPT_CALLEE_TRANSFER }, [ 'T' ] = { .flag = OPT_CALLER_TRANSFER }, [ 'w' ] = { .flag = OPT_CALLEE_MONITOR }, [ 'W' ] = { .flag = OPT_CALLER_MONITOR }, [ 'x' ] = { .flag = OPT_CALLEE_KILL }, }
static struct ast_call_feature	builtin_features []
static struct ast_datastore_info	channel_app_data_datastore
static struct ast_cli_entry	cli_features []
static char	courtesytone [256]
static struct ast_parkinglot *	default_parkinglot
	Default parking lot.
static struct ast_datastore_info	dial_features_info
static struct ast_datastore_info	feature_ds_info
static struct ast_custom_function	feature_function
static int	featuredigittimeout
static struct ast_custom_function	featuremap_function
static ast_rwlock_t	features_lock = { {0} , NULL, 1 }
static ast_mutex_t	features_reload_lock = { PTHREAD_MUTEX_INITIALIZER , NULL, 1 }
static int	force_reload_load
static struct ast_app *	mixmonitor_app = NULL
static int	mixmonitor_ok = 1
static struct ast_app *	monitor_app = NULL
static int	monitor_ok = 1
static struct ast_app_option	park_call_options [128] = { [ 'r' ] = { .flag = AST_PARK_OPT_RINGING }, [ 'R' ] = { .flag = AST_PARK_OPT_RANDOMIZE }, [ 's' ] = { .flag = AST_PARK_OPT_SILENCE }, }
static const char *	parkcall = "Park"
static const char *	parkedcall = "ParkedCall"
static int	parkeddynamic = 0
static int	parkedplay = 0
static char	parking_con_dial [] = "park-dial"
	Context for parking dialback to parker.
static pthread_t	parking_thread
static struct parkinglot_cfg	parkinglot_cfg_default
static struct parkinglot_cfg	parkinglot_cfg_default_default
static struct ao2_container *	parkinglots
	The configured parking lots container. Always at least one - the default parking lot.
static struct ast_datastore_info	pickup_active
static char	pickup_ext [AST_MAX_EXTENSION]
static char	pickupfailsound [256]
static char	pickupsound [256]
static char *	registrar = "features"
static struct ast_app *	stopmixmonitor_app = NULL
static int	stopmixmonitor_ok = 1
static int	transferdigittimeout
static char	xferfailsound [256]
static char	xfersound [256]

---

Detailed Description

Routines implementing call features as call pickup, parking and transfer.

Author:

Mark Spencer <markster@digium.com>

Definition in file features.c.

---

Define Documentation

#define AST_MAX_WATCHERS   256

Definition at line 528 of file features.c.

#define DEFAULT_ATXFER_CALLBACK_RETRIES   2

Definition at line 523 of file features.c.

Referenced by process_config().

#define DEFAULT_ATXFER_DROP_CALL   0

Do not drop call.

Definition at line 521 of file features.c.

Referenced by process_config().

#define DEFAULT_ATXFER_LOOP_DELAY   10000

ms

Definition at line 522 of file features.c.

Referenced by process_config().

#define DEFAULT_COMEBACK_CONTEXT   "parkedcallstimeout"

Definition at line 524 of file features.c.

#define DEFAULT_COMEBACK_DIAL_TIME   30

Definition at line 526 of file features.c.

Referenced by parkinglot_config_read().

#define DEFAULT_COMEBACK_TO_ORIGIN   1

Definition at line 525 of file features.c.

#define DEFAULT_FEATURE_DIGIT_TIMEOUT   1000

ms

Definition at line 519 of file features.c.

Referenced by process_config().

#define DEFAULT_NOANSWER_TIMEOUT_ATTENDED_TRANSFER   15000

ms

Definition at line 520 of file features.c.

Referenced by process_config().

#define DEFAULT_PARK_EXTENSION   "700"

Definition at line 517 of file features.c.

#define DEFAULT_PARK_TIME   45000

ms

Definition at line 516 of file features.c.

#define DEFAULT_TRANSFER_DIGIT_TIMEOUT   3000

ms

Definition at line 518 of file features.c.

Referenced by process_config().

#define FEATURES_COUNT   ARRAY_LEN(builtin_features)

Definition at line 3124 of file features.c.

Referenced by ast_find_call_feature(), feature_interpret_helper(), feature_request_and_dial(), handle_feature_show(), remap_feature(), set_config_flags(), and unmap_features().

#define HFS_FORMAT   "%-25s %-7s %-7s\n"

Referenced by handle_feature_show().

#define MAX_DIAL_FEATURE_OPTIONS   30

Definition at line 529 of file features.c.

Referenced by manage_parked_call().

---

Enumeration Type Documentation

anonymous enum

Enumerator:

BRIDGE_OPT_PLAYTONE
OPT_CALLEE_HANGUP
OPT_CALLER_HANGUP
OPT_DURATION_LIMIT
OPT_DURATION_STOP
OPT_CALLEE_TRANSFER
OPT_CALLER_TRANSFER
OPT_CALLEE_MONITOR
OPT_CALLER_MONITOR
OPT_CALLEE_PARK
OPT_CALLER_PARK
OPT_CALLEE_KILL
OPT_CALLEE_GO_ON

Definition at line 7940 of file features.c.

     {
   BRIDGE_OPT_PLAYTONE = (1 << 0),
   OPT_CALLEE_HANGUP =  (1 << 1),
   OPT_CALLER_HANGUP =  (1 << 2),
   OPT_DURATION_LIMIT = (1 << 3),
   OPT_DURATION_STOP =  (1 << 4),
   OPT_CALLEE_TRANSFER = (1 << 5),
   OPT_CALLER_TRANSFER = (1 << 6),
   OPT_CALLEE_MONITOR = (1 << 7),
   OPT_CALLER_MONITOR = (1 << 8),
   OPT_CALLEE_PARK = (1 << 9),
   OPT_CALLER_PARK = (1 << 10),
   OPT_CALLEE_KILL = (1 << 11),
   OPT_CALLEE_GO_ON = (1 << 12),
};

anonymous enum

Enumerator:

OPT_ARG_DURATION_LIMIT
OPT_ARG_DURATION_STOP
OPT_ARG_CALLEE_GO_ON
OPT_ARG_ARRAY_SIZE

Definition at line 7956 of file features.c.

     {
   OPT_ARG_DURATION_LIMIT = 0,
   OPT_ARG_DURATION_STOP,
   OPT_ARG_CALLEE_GO_ON,
   /* note: this entry _MUST_ be the last one in the enum */
   OPT_ARG_ARRAY_SIZE,
};

enum ast_park_call_options

Options to pass to park_call_full

Enumerator:

AST_PARK_OPT_RINGING	Provide ringing to the parked caller instead of music on hold
AST_PARK_OPT_RANDOMIZE	Randomly choose a parking spot for the caller instead of choosing the first one that is available.
AST_PARK_OPT_SILENCE	Do not announce the parking number

Definition at line 1275 of file features.c.

                           {
   /*! Provide ringing to the parked caller instead of music on hold */
   AST_PARK_OPT_RINGING =   (1 << 0),
   /*! Randomly choose a parking spot for the caller instead of choosing
    *  the first one that is available. */
   AST_PARK_OPT_RANDOMIZE = (1 << 1),
   /*! Do not announce the parking number */
   AST_PARK_OPT_SILENCE = (1 << 2),
};

enum feature_interpret_op

Enumerator:

FEATURE_INTERPRET_DETECT
FEATURE_INTERPRET_DO
FEATURE_INTERPRET_CHECK

Definition at line 549 of file features.c.

             {
   FEATURE_INTERPRET_DETECT, /* Used by ast_feature_detect */
   FEATURE_INTERPRET_DO,     /* Used by feature_interpret */
   FEATURE_INTERPRET_CHECK,  /* Used by feature_check */
} feature_interpret_op;

---

Function Documentation

static void __fini_feature_groups

(

void

)

[static]

Definition at line 547 of file features.c.

{

static void __fini_feature_list

(

void

)

[static]

Definition at line 3138 of file features.c.

{

static void __init_feature_groups

(

void

)

[static]

Definition at line 547 of file features.c.

{

static void __init_feature_list

(

void

)

[static]

Definition at line 3138 of file features.c.

{

static int action_bridge	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Bridge channels together.

Parameters:

	s
	m	Make sure valid channels were specified, send errors if any of the channels could not be found/locked, answer channels if needed, create the placeholder channels and grab the other channels make the channels compatible, send error if we fail doing so setup the bridge thread object and start the bridge.

Return values:

0

Definition at line 7272 of file features.c.

References ast_answer(), ast_calloc, ast_channel_alloc, ast_channel_get_by_name_prefix(), ast_channel_language(), ast_channel_linkedid(), ast_channel_make_compatible(), ast_channel_name(), ast_channel_unref, ast_hangup(), ast_log(), ast_manager_event_multichan, AST_STATE_DOWN, AST_STATE_UP, ast_streamfile(), ast_strlen_zero(), ast_true(), ast_waitstream(), astman_get_header(), astman_send_ack(), astman_send_error(), bridge_call_thread_launch(), ast_bridge_thread_obj::chan, do_bridge_masquerade(), errno, EVENT_FLAG_CALL, LOG_WARNING, ast_bridge_thread_obj::peer, playtone(), ast_bridge_thread_obj::return_to_pbx, and xfersound.

Referenced by ast_features_init().

{
   const char *channela = astman_get_header(m, "Channel1");
   const char *channelb = astman_get_header(m, "Channel2");
   const char *playtone = astman_get_header(m, "Tone");
   struct ast_channel *chana = NULL, *chanb = NULL, *chans[2];
   struct ast_channel *tmpchana = NULL, *tmpchanb = NULL;
   struct ast_bridge_thread_obj *tobj = NULL;
   char buf[256];

   /* make sure valid channels were specified */
   if (ast_strlen_zero(channela) || ast_strlen_zero(channelb)) {
      astman_send_error(s, m, "Missing channel parameter in request");
      return 0;
   }

   /* Start with chana */
   chana = ast_channel_get_by_name_prefix(channela, strlen(channela));
   if (!chana) {
      snprintf(buf, sizeof(buf), "Channel1 does not exists: %s", channela);
      astman_send_error(s, m, buf);
      return 0;
   }

   /* Answer the channels if needed */
   if (ast_channel_state(chana) != AST_STATE_UP)
      ast_answer(chana);

   /* create the placeholder channels and grab the other channels */
   if (!(tmpchana = ast_channel_alloc(0, AST_STATE_DOWN, NULL, NULL, NULL,
      NULL, NULL, ast_channel_linkedid(chana), 0, "Bridge/%s", ast_channel_name(chana)))) {
      astman_send_error(s, m, "Unable to create temporary channel!");
      chana = ast_channel_unref(chana);
      return 0;
   }

   if (do_bridge_masquerade(chana, tmpchana)) {
      snprintf(buf, sizeof(buf), "Unable to masquerade channel %s!", channela);
      astman_send_error(s, m, buf);
      ast_hangup(tmpchana);
      chana = ast_channel_unref(chana);
      return 0;
   }

   chana = ast_channel_unref(chana);

   /* now do chanb */
   chanb = ast_channel_get_by_name_prefix(channelb, strlen(channelb));
   if (!chanb) {
      snprintf(buf, sizeof(buf), "Channel2 does not exists: %s", channelb);
      astman_send_error(s, m, buf);
      ast_hangup(tmpchana);
      return 0;
   }

   /* Answer the channels if needed */
   if (ast_channel_state(chanb) != AST_STATE_UP)
      ast_answer(chanb);

   /* create the placeholder channels and grab the other channels */
   if (!(tmpchanb = ast_channel_alloc(0, AST_STATE_DOWN, NULL, NULL, NULL,
      NULL, NULL, ast_channel_linkedid(chanb), 0, "Bridge/%s", ast_channel_name(chanb)))) {
      astman_send_error(s, m, "Unable to create temporary channels!");
      ast_hangup(tmpchana);
      chanb = ast_channel_unref(chanb);
      return 0;
   }

   if (do_bridge_masquerade(chanb, tmpchanb)) {
      snprintf(buf, sizeof(buf), "Unable to masquerade channel %s!", channelb);
      astman_send_error(s, m, buf);
      ast_hangup(tmpchana);
      ast_hangup(tmpchanb);
      chanb = ast_channel_unref(chanb);
      return 0;
   }

   chanb = ast_channel_unref(chanb);

   /* make the channels compatible, send error if we fail doing so */
   if (ast_channel_make_compatible(tmpchana, tmpchanb)) {
      ast_log(LOG_WARNING, "Could not make channels %s and %s compatible for manager bridge\n", ast_channel_name(tmpchana), ast_channel_name(tmpchanb));
      astman_send_error(s, m, "Could not make channels compatible for manager bridge");
      ast_hangup(tmpchana);
      ast_hangup(tmpchanb);
      return 0;
   }

   /* setup the bridge thread object and start the bridge */
   if (!(tobj = ast_calloc(1, sizeof(*tobj)))) {
      ast_log(LOG_WARNING, "Unable to spawn a new bridge thread on %s and %s: %s\n", ast_channel_name(tmpchana), ast_channel_name(tmpchanb), strerror(errno));
      astman_send_error(s, m, "Unable to spawn a new bridge thread");
      ast_hangup(tmpchana);
      ast_hangup(tmpchanb);
      return 0;
   }

   tobj->chan = tmpchana;
   tobj->peer = tmpchanb;
   tobj->return_to_pbx = 1;

   if (ast_true(playtone)) {
      if (!ast_strlen_zero(xfersound) && !ast_streamfile(tmpchanb, xfersound, ast_channel_language(tmpchanb))) {
         if (ast_waitstream(tmpchanb, "") < 0)
            ast_log(LOG_WARNING, "Failed to play a courtesy tone on chan %s\n", ast_channel_name(tmpchanb));
      }
   }

   chans[0] = tmpchana;
   chans[1] = tmpchanb;
   /*** DOCUMENTATION
      <managerEventInstance>
         <synopsis>Raised when a bridge is successfully created due to a manager action.</synopsis>
         <syntax>
            <parameter name="Response">
               <enumlist>
                  <enum name="Success"/>
                  <enum name="Failed"/>
               </enumlist>
            </parameter>
         </syntax>
         <see-also>
            <ref type="manager">Bridge</ref>
         </see-also>
      </managerEventInstance>
   ***/
   ast_manager_event_multichan(EVENT_FLAG_CALL, "BridgeAction", 2, chans,
            "Response: Success\r\n"
            "Channel1: %s\r\n"
            "Channel2: %s\r\n", ast_channel_name(tmpchana), ast_channel_name(tmpchanb));

   bridge_call_thread_launch(tobj);

   astman_send_ack(s, m, "Launched bridge thread with success");

   return 0;
}

static int add_features_datastore	(	struct ast_channel *	chan,
		const struct ast_flags *	my_features,
		const struct ast_flags *	peer_features
	)			[static]

Definition at line 905 of file features.c.

References ast_calloc, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_channel_lock, ast_channel_unlock, ast_copy_flags, ast_datastore_alloc, ast_datastore_free(), AST_FLAGS_ALL, ast_log(), ast_datastore::data, DATASTORE_INHERIT_FOREVER, dial_features_info, ast_datastore::inheritance, LOG_WARNING, ast_dial_features::my_features, and ast_dial_features::peer_features.

Referenced by add_features_datastores(), and builtin_atxfer().

{
   struct ast_datastore *datastore;
   struct ast_dial_features *dialfeatures;

   ast_channel_lock(chan);
   datastore = ast_channel_datastore_find(chan, &dial_features_info, NULL);
   ast_channel_unlock(chan);
   if (datastore) {
      /* Already exists. */
      return 1;
   }

   /* Create a new datastore with specified feature flags. */
   datastore = ast_datastore_alloc(&dial_features_info, NULL);
   if (!datastore) {
      ast_log(LOG_WARNING, "Unable to create channel features datastore.\n");
      return 0;
   }
   dialfeatures = ast_calloc(1, sizeof(*dialfeatures));
   if (!dialfeatures) {
      ast_log(LOG_WARNING, "Unable to allocate memory for feature flags.\n");
      ast_datastore_free(datastore);
      return 0;
   }
   ast_copy_flags(&dialfeatures->my_features, my_features, AST_FLAGS_ALL);
   ast_copy_flags(&dialfeatures->peer_features, peer_features, AST_FLAGS_ALL);
   datastore->inheritance = DATASTORE_INHERIT_FOREVER;
   datastore->data = dialfeatures;
   ast_channel_lock(chan);
   ast_channel_datastore_add(chan, datastore);
   ast_channel_unlock(chan);
   return 0;
}

static void add_features_datastores	(	struct ast_channel *	caller,
		struct ast_channel *	callee,
		struct ast_bridge_config *	config
	)			[static]

Definition at line 4208 of file features.c.

References add_features_datastore(), ast_bridge_config::features_callee, and ast_bridge_config::features_caller.

Referenced by ast_bridge_call().

{
   if (add_features_datastore(caller, &config->features_caller, &config->features_callee)) {
      /*
       * If we don't return here, then when we do a builtin_atxfer we
       * will copy the disconnect flags over from the atxfer to the
       * callee (Party C).
       */
      return;
   }

   add_features_datastore(callee, &config->features_callee, &config->features_caller);
}

static int adsi_announce_park	(	struct ast_channel *	chan,
		char *	parkingexten
	)			[static]

Announce call parking by ADSI.

Parameters:

	chan	.
	parkingexten	. Create message to show for ADSI, display message.

Return values:

	0	on success.
	-1	on failure.

Definition at line 1213 of file features.c.

References ADSI_JUST_CENT, ast_adsi_load_session(), ast_adsi_print(), and justify.

Referenced by park_call_full().

{
   int res;
   int justify[5] = {ADSI_JUST_CENT, ADSI_JUST_CENT, ADSI_JUST_CENT, ADSI_JUST_CENT};
   char tmp[256];
   char *message[5] = {NULL, NULL, NULL, NULL, NULL};

   snprintf(tmp, sizeof(tmp), "Parked on %s", parkingexten);
   message[0] = tmp;
   res = ast_adsi_load_session(chan, NULL, 0, 1);
   if (res == -1)
      return res;
   return ast_adsi_print(chan, message, justify, 1);
}

int ast_bridge_call	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config
	)

bridge the call and set CDR

Bridge a call, optionally allowing redirection.

Parameters:

	chan	The bridge considers this channel the caller.
	peer	The bridge considers this channel the callee.
	config	Configuration for this bridge.

Set start time, check for two channels,check if monitor on check for feature activation, create new CDR

Return values:

	res	on success.
	-1	on failure to bridge.

TRUE if h-exten or hangup handlers run.

append the event to featurecode. we rely on the string being zero-filled, and not overflowing it.

Todo:

XXX how do we guarantee the latter ?

Definition at line 4250 of file features.c.

References ast_cdr::accountcode, add_features_datastores(), ast_cdr::amaflags, ast_cdr::answer, ast_autoservice_start(), ast_autoservice_stop(), AST_BRIDGE_RETRY, ast_bridged_channel(), ast_cdr_alloc(), ast_cdr_answer(), AST_CDR_ANSWERED, ast_cdr_appenduserfield(), ast_cdr_copy_vars(), ast_cdr_detach(), ast_cdr_discard(), ast_cdr_dup_unique_swap(), ast_cdr_end(), AST_CDR_FLAG_BRIDGED, AST_CDR_FLAG_DIALED, AST_CDR_FLAG_MAIN, AST_CDR_FLAG_POST_DISABLED, AST_CDR_NULL, ast_cdr_setaccount(), ast_cdr_setanswer(), ast_cdr_setcid(), ast_cdr_setdisposition(), ast_cdr_setuserfield(), ast_cdr_specialized_reset(), ast_cdr_start(), ast_cdr_update(), AST_CEL_BRIDGE_END, AST_CEL_BRIDGE_START, ast_cel_report_event(), ast_channel_accountcode(), ast_channel_amaflags(), ast_channel_appl(), ast_channel_bridge(), ast_channel_caller(), ast_channel_cdr(), ast_channel_cdr_set(), ast_channel_connected_line_macro(), ast_channel_connected_line_sub(), ast_channel_context(), ast_channel_context_set(), ast_channel_data(), ast_channel_exten(), ast_channel_exten_set(), ast_channel_flags(), ast_channel_get_by_name(), ast_channel_lock, ast_channel_lock_both, ast_channel_log(), ast_channel_macrocontext(), ast_channel_name(), AST_CHANNEL_NAME, ast_channel_priority(), ast_channel_priority_set(), ast_channel_redirecting_macro(), ast_channel_redirecting_sub(), ast_channel_set_linkgroup(), ast_channel_setoption(), ast_channel_softhangup_internal_flag(), ast_channel_start_silence_generator(), ast_channel_stop_silence_generator(), ast_channel_uniqueid(), ast_channel_unlock, ast_channel_unref, ast_channel_visible_indication(), ast_check_hangup(), ast_clear_flag, AST_CONTROL_AOC, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_CONNECTED_LINE, AST_CONTROL_FLASH, AST_CONTROL_HANGUP, AST_CONTROL_HOLD, AST_CONTROL_MCID, AST_CONTROL_OPTION, AST_CONTROL_PVT_CAUSE_CODE, AST_CONTROL_REDIRECTING, AST_CONTROL_RINGING, AST_CONTROL_UNHOLD, ast_copy_string(), ast_debug, ast_default_amaflags, ast_dtmf_stream(), ast_exists_extension(), AST_FEATURE_NO_H_EXTEN, AST_FEATURE_RETURN_PASSDIGITS, AST_FEATURE_RETURN_SUCCESS, AST_FEATURE_WARNING_ACTIVE, AST_FLAG_BRIDGE_HANGUP_DONT, AST_FLAG_ZOMBIE, AST_FRAME_CONTROL, AST_FRAME_DTMF_BEGIN, AST_FRAME_DTMF_END, ast_frfree, ast_indicate(), ast_indicate_data(), ast_log(), AST_MAX_CONTEXT, AST_MAX_EXTENSION, ast_opt_transmit_silence, AST_OPTION_AUDIO_MODE, AST_OPTION_DIGIT_DETECT, AST_OPTION_FAX_DETECT, AST_OPTION_FLAG_REQUEST, AST_OPTION_RELAXDTMF, AST_OPTION_TDD, AST_OPTION_TONE_VERIFY, ast_pbx_h_exten_run(), ast_pbx_hangup_handler_run(), ast_raw_answer(), ast_set_flag, AST_SOFTHANGUP_ASYNCGOTO, AST_SOFTHANGUP_UNBRIDGE, AST_STATE_RINGING, AST_STATE_UP, ast_strdupa, ast_strlen_zero(), ast_test_flag, ast_tvcmp(), ast_tvdiff_ms(), ast_tvnow(), ast_tvzero(), ast_write(), ast_cdr::channel, clear_dialed_interfaces(), ast_option_header::data, ast_frame::data, ast_frame::datalen, ast_cdr::dcontext, ast_cdr::disposition, ast_cdr::dst, ast_cdr::dstchannel, ast_bridge_config::end_bridge_callback, ast_bridge_config::end_bridge_callback_data, f, feature_check(), feature_interpret(), FEATURE_MAX_LEN, FEATURE_SENSE_CHAN, FEATURE_SENSE_PEER, ast_bridge_config::feature_start_time, ast_bridge_config::feature_timer, featuredigittimeout, ast_bridge_config::features_callee, ast_bridge_config::features_caller, ast_frame::frametype, ast_frame_subclass::integer, ast_cdr::lastapp, ast_cdr::lastdata, ast_frame::len, LOG_DEBUG, LOG_WARNING, monitor_app, monitor_ok, ast_cdr::next, option_debug, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_exec(), pbx_findapp(), pick_unlocked_cdr(), ast_frame::ptr, S_COR, S_OR, set_bridge_features_on_config(), set_config_flags(), ast_cdr::start, ast_frame::subclass, ast_bridge_config::timelimit, ast_cdr::uniqueid, ast_cdr::userfield, and ast_channel::userfield.

Referenced by app_exec(), bridge_call_thread(), bridge_exec(), builtin_atxfer(), dial_exec_full(), parked_call_exec(), and try_calling().

{
   /* Copy voice back and forth between the two channels.  Give the peer
      the ability to transfer calls with '#<extension' syntax. */
   struct ast_frame *f;
   struct ast_channel *who;
   char chan_featurecode[FEATURE_MAX_LEN + 1]="";
   char peer_featurecode[FEATURE_MAX_LEN + 1]="";
   char orig_channame[AST_CHANNEL_NAME];
   char orig_peername[AST_CHANNEL_NAME];
   int res;
   int diff;
   int hasfeatures=0;
   int hadfeatures=0;
   int sendingdtmfdigit = 0;
   int we_disabled_peer_cdr = 0;
   struct ast_option_header *aoh;
   struct ast_cdr *bridge_cdr = NULL;
   struct ast_cdr *chan_cdr = ast_channel_cdr(chan); /* the proper chan cdr, if there are forked cdrs */
   struct ast_cdr *peer_cdr = ast_channel_cdr(peer); /* the proper chan cdr, if there are forked cdrs */
   struct ast_cdr *new_chan_cdr = NULL; /* the proper chan cdr, if there are forked cdrs */
   struct ast_cdr *new_peer_cdr = NULL; /* the proper chan cdr, if there are forked cdrs */
   struct ast_silence_generator *silgen = NULL;
   /*! TRUE if h-exten or hangup handlers run. */
   int hangup_run = 0;

   pbx_builtin_setvar_helper(chan, "BRIDGEPEER", ast_channel_name(peer));
   pbx_builtin_setvar_helper(peer, "BRIDGEPEER", ast_channel_name(chan));

   /* Clear any BLINDTRANSFER since the transfer has completed. */
   pbx_builtin_setvar_helper(chan, "BLINDTRANSFER", NULL);
   pbx_builtin_setvar_helper(peer, "BLINDTRANSFER", NULL);

   set_bridge_features_on_config(config, pbx_builtin_getvar_helper(chan, "BRIDGE_FEATURES"));
   add_features_datastores(chan, peer, config);

   /* This is an interesting case.  One example is if a ringing channel gets redirected to
    * an extension that picks up a parked call.  This will make sure that the call taken
    * out of parking gets told that the channel it just got bridged to is still ringing. */
   if (ast_channel_state(chan) == AST_STATE_RINGING && ast_channel_visible_indication(peer) != AST_CONTROL_RINGING) {
      ast_indicate(peer, AST_CONTROL_RINGING);
   }

   if (monitor_ok) {
      const char *monitor_exec;
      struct ast_channel *src = NULL;
      if (!monitor_app) {
         if (!(monitor_app = pbx_findapp("Monitor")))
            monitor_ok=0;
      }
      if ((monitor_exec = pbx_builtin_getvar_helper(chan, "AUTO_MONITOR")))
         src = chan;
      else if ((monitor_exec = pbx_builtin_getvar_helper(peer, "AUTO_MONITOR")))
         src = peer;
      if (monitor_app && src) {
         char *tmp = ast_strdupa(monitor_exec);
         pbx_exec(src, monitor_app, tmp);
      }
   }

   set_config_flags(chan, config);

   /* Answer if need be */
   if (ast_channel_state(chan) != AST_STATE_UP) {
      if (ast_raw_answer(chan, 1)) {
         return -1;
      }
   }

#ifdef FOR_DEBUG
   /* show the two channels and cdrs involved in the bridge for debug & devel purposes */
   ast_channel_log("Pre-bridge CHAN Channel info", chan);
   ast_channel_log("Pre-bridge PEER Channel info", peer);
#endif
   /* two channels are being marked as linked here */
   ast_channel_set_linkgroup(chan,peer);

   /* copy the userfield from the B-leg to A-leg if applicable */
   if (ast_channel_cdr(chan) && ast_channel_cdr(peer) && !ast_strlen_zero(ast_channel_cdr(peer)->userfield)) {
      char tmp[256];

      ast_channel_lock(chan);
      if (!ast_strlen_zero(ast_channel_cdr(chan)->userfield)) {
         snprintf(tmp, sizeof(tmp), "%s;%s", ast_channel_cdr(chan)->userfield, ast_channel_cdr(peer)->userfield);
         ast_cdr_appenduserfield(chan, tmp);
      } else {
         ast_cdr_setuserfield(chan, ast_channel_cdr(peer)->userfield);
      }
      ast_channel_unlock(chan);
      /* Don't delete the CDR; just disable it. */
      ast_set_flag(ast_channel_cdr(peer), AST_CDR_FLAG_POST_DISABLED);
      we_disabled_peer_cdr = 1;
   }
   ast_copy_string(orig_channame,ast_channel_name(chan),sizeof(orig_channame));
   ast_copy_string(orig_peername,ast_channel_name(peer),sizeof(orig_peername));

   if (!chan_cdr || (chan_cdr && !ast_test_flag(chan_cdr, AST_CDR_FLAG_POST_DISABLED))) {
      ast_channel_lock_both(chan, peer);
      if (chan_cdr) {
         ast_set_flag(chan_cdr, AST_CDR_FLAG_MAIN);
         ast_cdr_update(chan);
         bridge_cdr = ast_cdr_dup_unique_swap(chan_cdr);
         /* rip any forked CDR's off of the chan_cdr and attach
          * them to the bridge_cdr instead */
         bridge_cdr->next = chan_cdr->next;
         chan_cdr->next = NULL;
         ast_copy_string(bridge_cdr->lastapp, S_OR(ast_channel_appl(chan), ""), sizeof(bridge_cdr->lastapp));
         ast_copy_string(bridge_cdr->lastdata, S_OR(ast_channel_data(chan), ""), sizeof(bridge_cdr->lastdata));
         if (peer_cdr && !ast_strlen_zero(peer_cdr->userfield)) {
            ast_copy_string(bridge_cdr->userfield, peer_cdr->userfield, sizeof(bridge_cdr->userfield));
         }
         ast_cdr_setaccount(peer, ast_channel_accountcode(chan));
      } else {
         /* better yet, in a xfer situation, find out why the chan cdr got zapped (pun unintentional) */
         bridge_cdr = ast_cdr_alloc(); /* this should be really, really rare/impossible? */
         ast_copy_string(bridge_cdr->channel, ast_channel_name(chan), sizeof(bridge_cdr->channel));
         ast_copy_string(bridge_cdr->dstchannel, ast_channel_name(peer), sizeof(bridge_cdr->dstchannel));
         ast_copy_string(bridge_cdr->uniqueid, ast_channel_uniqueid(chan), sizeof(bridge_cdr->uniqueid));
         ast_copy_string(bridge_cdr->lastapp, S_OR(ast_channel_appl(chan), ""), sizeof(bridge_cdr->lastapp));
         ast_copy_string(bridge_cdr->lastdata, S_OR(ast_channel_data(chan), ""), sizeof(bridge_cdr->lastdata));
         ast_cdr_setcid(bridge_cdr, chan);
         bridge_cdr->disposition = (ast_channel_state(chan) == AST_STATE_UP) ?  AST_CDR_ANSWERED : AST_CDR_NULL;
         bridge_cdr->amaflags = ast_channel_amaflags(chan) ? ast_channel_amaflags(chan) :  ast_default_amaflags;
         ast_copy_string(bridge_cdr->accountcode, ast_channel_accountcode(chan), sizeof(bridge_cdr->accountcode));
         /* Destination information */
         ast_copy_string(bridge_cdr->dst, ast_channel_exten(chan), sizeof(bridge_cdr->dst));
         ast_copy_string(bridge_cdr->dcontext, ast_channel_context(chan), sizeof(bridge_cdr->dcontext));
         if (peer_cdr) {
            bridge_cdr->start = peer_cdr->start;
            ast_copy_string(bridge_cdr->userfield, peer_cdr->userfield, sizeof(bridge_cdr->userfield));
         } else {
            ast_cdr_start(bridge_cdr);
         }
      }
      ast_channel_unlock(chan);
      ast_channel_unlock(peer);

      ast_debug(4, "bridge answer set, chan answer set\n");
      /* peer_cdr->answer will be set when a macro runs on the peer;
         in that case, the bridge answer will be delayed while the
         macro plays on the peer channel. The peer answered the call
         before the macro started playing. To the phone system,
         this is billable time for the call, even tho the caller
         hears nothing but ringing while the macro does its thing. */

      /* Another case where the peer cdr's time will be set, is when
         A self-parks by pickup up phone and dialing 700, then B
         picks up A by dialing its parking slot; there may be more
         practical paths that get the same result, tho... in which
         case you get the previous answer time from the Park... which
         is before the bridge's start time, so I added in the
         tvcmp check to the if below */

      if (peer_cdr && !ast_tvzero(peer_cdr->answer) && ast_tvcmp(peer_cdr->answer, bridge_cdr->start) >= 0) {
         ast_cdr_setanswer(bridge_cdr, peer_cdr->answer);
         ast_cdr_setdisposition(bridge_cdr, peer_cdr->disposition);
         if (chan_cdr) {
            ast_cdr_setanswer(chan_cdr, peer_cdr->answer);
            ast_cdr_setdisposition(chan_cdr, peer_cdr->disposition);
         }
      } else {
         ast_cdr_answer(bridge_cdr);
         if (chan_cdr) {
            ast_cdr_answer(chan_cdr); /* for the sake of cli status checks */
         }
      }
      if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_BRIDGE_HANGUP_DONT) && (chan_cdr || peer_cdr)) {
         if (chan_cdr) {
            ast_set_flag(chan_cdr, AST_CDR_FLAG_BRIDGED);
         }
         if (peer_cdr) {
            ast_set_flag(peer_cdr, AST_CDR_FLAG_BRIDGED);
         }
      }
      /* the DIALED flag may be set if a dialed channel is transfered
       * and then bridged to another channel.  In order for the
       * bridge CDR to be written, the DIALED flag must not be
       * present. */
      ast_clear_flag(bridge_cdr, AST_CDR_FLAG_DIALED);
   }
   ast_cel_report_event(chan, AST_CEL_BRIDGE_START, NULL, NULL, peer);

   /* If we are bridging a call, stop worrying about forwarding loops. We presume that if
    * a call is being bridged, that the humans in charge know what they're doing. If they
    * don't, well, what can we do about that? */
   clear_dialed_interfaces(chan);
   clear_dialed_interfaces(peer);

   for (;;) {
      struct ast_channel *other; /* used later */

      res = ast_channel_bridge(chan, peer, config, &f, &who);

      if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_ZOMBIE)
         || ast_test_flag(ast_channel_flags(peer), AST_FLAG_ZOMBIE)) {
         /* Zombies are present time to leave! */
         res = -1;
         if (f) {
            ast_frfree(f);
         }
         goto before_you_go;
      }

      /* When frame is not set, we are probably involved in a situation
         where we've timed out.
         When frame is set, we'll come this code twice; once for DTMF_BEGIN
         and also for DTMF_END. If we flow into the following 'if' for both, then
         our wait times are cut in half, as both will subtract from the
         feature_timer. Not good!
      */
      if (config->feature_timer && (!f || f->frametype == AST_FRAME_DTMF_END)) {
         /* Update feature timer for next pass */
         diff = ast_tvdiff_ms(ast_tvnow(), config->feature_start_time);
         if (res == AST_BRIDGE_RETRY) {
            /* The feature fully timed out but has not been updated. Skip
             * the potential round error from the diff calculation and
             * explicitly set to expired. */
            config->feature_timer = -1;
         } else {
            config->feature_timer -= diff;
         }

         if (hasfeatures) {
            if (config->feature_timer <= 0) {
               /* Not *really* out of time, just out of time for
                  digits to come in for features. */
               ast_debug(1, "Timed out for feature!\n");
               if (!ast_strlen_zero(peer_featurecode)) {
                  ast_dtmf_stream(chan, peer, peer_featurecode, 0, f ? f->len : 0);
                  memset(peer_featurecode, 0, sizeof(peer_featurecode));
               }
               if (!ast_strlen_zero(chan_featurecode)) {
                  ast_dtmf_stream(peer, chan, chan_featurecode, 0, f ? f->len : 0);
                  memset(chan_featurecode, 0, sizeof(chan_featurecode));
               }
               if (f)
                  ast_frfree(f);
               hasfeatures = !ast_strlen_zero(chan_featurecode) || !ast_strlen_zero(peer_featurecode);
               if (!hasfeatures) {
                  /* No more digits expected - reset the timer */
                  config->feature_timer = 0;
               }
               hadfeatures = hasfeatures;
               /* Continue as we were */
               continue;
            } else if (!f) {
               /* The bridge returned without a frame and there is a feature in progress.
                * However, we don't think the feature has quite yet timed out, so just
                * go back into the bridge. */
               continue;
            }
         } else {
            if (config->feature_timer <=0) {
               /* We ran out of time */
               config->feature_timer = 0;
               who = chan;
               if (f)
                  ast_frfree(f);
               f = NULL;
               res = 0;
            }
         }
      }
      if (res < 0) {
         if (!ast_test_flag(ast_channel_flags(chan), AST_FLAG_ZOMBIE) && !ast_test_flag(ast_channel_flags(peer), AST_FLAG_ZOMBIE) && !ast_check_hangup(chan) && !ast_check_hangup(peer)) {
            ast_log(LOG_WARNING, "Bridge failed on channels %s and %s\n", ast_channel_name(chan), ast_channel_name(peer));
         }
         goto before_you_go;
      }

      if (!f || (f->frametype == AST_FRAME_CONTROL &&
            (f->subclass.integer == AST_CONTROL_HANGUP || f->subclass.integer == AST_CONTROL_BUSY ||
               f->subclass.integer == AST_CONTROL_CONGESTION))) {
         /*
          * If the bridge was broken for a hangup that isn't real,
          * then don't run the h extension, because the channel isn't
          * really hung up. This should really only happen with AST_SOFTHANGUP_ASYNCGOTO,
          * but it doesn't hurt to check AST_SOFTHANGUP_UNBRIDGE either.
          */
         ast_channel_lock(chan);
         if (ast_channel_softhangup_internal_flag(chan) & (AST_SOFTHANGUP_ASYNCGOTO | AST_SOFTHANGUP_UNBRIDGE)) {
            ast_set_flag(ast_channel_flags(chan), AST_FLAG_BRIDGE_HANGUP_DONT);
         }
         ast_channel_unlock(chan);
         res = -1;
         break;
      }
      /* many things should be sent to the 'other' channel */
      other = (who == chan) ? peer : chan;
      if (f->frametype == AST_FRAME_CONTROL) {
         switch (f->subclass.integer) {
         case AST_CONTROL_RINGING:
         case AST_CONTROL_FLASH:
         case AST_CONTROL_MCID:
         case -1:
            ast_indicate(other, f->subclass.integer);
            break;
         case AST_CONTROL_CONNECTED_LINE:
            if (ast_channel_connected_line_sub(who, other, f, 1) &&
               ast_channel_connected_line_macro(who, other, f, who != chan, 1)) {
               ast_indicate_data(other, f->subclass.integer, f->data.ptr, f->datalen);
            }
            break;
         case AST_CONTROL_REDIRECTING:
            if (ast_channel_redirecting_sub(who, other, f, 1) &&
               ast_channel_redirecting_macro(who, other, f, who != chan, 1)) {
               ast_indicate_data(other, f->subclass.integer, f->data.ptr, f->datalen);
            }
            break;
         case AST_CONTROL_PVT_CAUSE_CODE:
         case AST_CONTROL_AOC:
         case AST_CONTROL_HOLD:
         case AST_CONTROL_UNHOLD:
            ast_indicate_data(other, f->subclass.integer, f->data.ptr, f->datalen);
            break;
         case AST_CONTROL_OPTION:
            aoh = f->data.ptr;
            /* Forward option Requests, but only ones we know are safe
             * These are ONLY sent by chan_iax2 and I'm not convinced that
             * they are useful. I haven't deleted them entirely because I
             * just am not sure of the ramifications of removing them. */
            if (aoh && aoh->flag == AST_OPTION_FLAG_REQUEST) {
               switch (ntohs(aoh->option)) {
               case AST_OPTION_TONE_VERIFY:
               case AST_OPTION_TDD:
               case AST_OPTION_RELAXDTMF:
               case AST_OPTION_AUDIO_MODE:
               case AST_OPTION_DIGIT_DETECT:
               case AST_OPTION_FAX_DETECT:
                  ast_channel_setoption(other, ntohs(aoh->option), aoh->data,
                     f->datalen - sizeof(struct ast_option_header), 0);
               }
            }
            break;
         }
      } else if (f->frametype == AST_FRAME_DTMF_BEGIN) {
         struct ast_flags *cfg;
         char dtmfcode[2] = { f->subclass.integer, };
         size_t featurelen;

         if (who == chan) {
            featurelen = strlen(chan_featurecode);
            cfg = &(config->features_caller);
         } else {
            featurelen = strlen(peer_featurecode);
            cfg = &(config->features_callee);
         }
         /* Take a peek if this (possibly) matches a feature. If not, just pass this
          * DTMF along untouched. If this is not the first digit of a multi-digit code
          * then we need to fall through and stream the characters if it matches */
         if (featurelen == 0
            && feature_check(chan, cfg, &dtmfcode[0]) == AST_FEATURE_RETURN_PASSDIGITS) {
            if (option_debug > 3) {
               ast_log(LOG_DEBUG, "Passing DTMF through, since it is not a feature code\n");
            }
            ast_write(other, f);
            sendingdtmfdigit = 1;
         } else {
            /* If ast_opt_transmit_silence is set, then we need to make sure we are
             * transmitting something while we hold on to the DTMF waiting for a
             * feature. */
            if (!silgen && ast_opt_transmit_silence) {
               silgen = ast_channel_start_silence_generator(other);
            }
            if (option_debug > 3) {
               ast_log(LOG_DEBUG, "Not passing DTMF through, since it may be a feature code\n");
            }
         }
      } else if (f->frametype == AST_FRAME_DTMF_END) {
         char *featurecode;
         int sense;
         unsigned int dtmfduration = f->len;

         hadfeatures = hasfeatures;
         /* This cannot overrun because the longest feature is one shorter than our buffer */
         if (who == chan) {
            sense = FEATURE_SENSE_CHAN;
            featurecode = chan_featurecode;
         } else  {
            sense = FEATURE_SENSE_PEER;
            featurecode = peer_featurecode;
         }

         if (sendingdtmfdigit == 1) {
            /* We let the BEGIN go through happily, so let's not bother with the END,
             * since we already know it's not something we bother with */
            ast_write(other, f);
            sendingdtmfdigit = 0;
         } else {
            /*! append the event to featurecode. we rely on the string being zero-filled, and
             * not overflowing it.
             * \todo XXX how do we guarantee the latter ?
             */
            featurecode[strlen(featurecode)] = f->subclass.integer;
            /* Get rid of the frame before we start doing "stuff" with the channels */
            ast_frfree(f);
            f = NULL;
            if (silgen) {
               ast_channel_stop_silence_generator(other, silgen);
               silgen = NULL;
            }
            config->feature_timer = 0;
            res = feature_interpret(chan, peer, config, featurecode, sense);
            switch(res) {
            case AST_FEATURE_RETURN_PASSDIGITS:
               ast_dtmf_stream(other, who, featurecode, 0, dtmfduration);
               /* Fall through */
            case AST_FEATURE_RETURN_SUCCESS:
               memset(featurecode, 0, sizeof(chan_featurecode));
               break;
            }
            if (res >= AST_FEATURE_RETURN_PASSDIGITS) {
               res = 0;
            } else {
               break;
            }
            hasfeatures = !ast_strlen_zero(chan_featurecode) || !ast_strlen_zero(peer_featurecode);
            if (hadfeatures && !hasfeatures) {
               /* Feature completed or timed out */
               config->feature_timer = 0;
            } else if (hasfeatures) {
               if (config->timelimit) {
                  /* No warning next time - we are waiting for feature code */
                  ast_set_flag(config, AST_FEATURE_WARNING_ACTIVE);
               }
               config->feature_start_time = ast_tvnow();
               config->feature_timer = featuredigittimeout;
               ast_debug(1, "Set feature timer to %ld ms\n", config->feature_timer);
            }
         }
      }
      if (f)
         ast_frfree(f);
   }
   ast_cel_report_event(chan, AST_CEL_BRIDGE_END, NULL, NULL, peer);

before_you_go:
   /* Just in case something weird happened and we didn't clean up the silence generator... */
   if (silgen) {
      ast_channel_stop_silence_generator(who == chan ? peer : chan, silgen);
      silgen = NULL;
   }

   if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_BRIDGE_HANGUP_DONT)) {
      ast_clear_flag(ast_channel_flags(chan), AST_FLAG_BRIDGE_HANGUP_DONT); /* its job is done */
      if (bridge_cdr) {
         ast_cdr_discard(bridge_cdr);
         /* QUESTION: should we copy bridge_cdr fields to the peer before we throw it away? */
      }
      return res; /* if we shouldn't do the h-exten, we shouldn't do the bridge cdr, either! */
   }

   if (config->end_bridge_callback) {
      config->end_bridge_callback(config->end_bridge_callback_data);
   }

   if (!ast_test_flag(&config->features_caller, AST_FEATURE_NO_H_EXTEN)) {
      struct ast_cdr *swapper = NULL;
      char savelastapp[AST_MAX_EXTENSION];
      char savelastdata[AST_MAX_EXTENSION];
      char save_context[AST_MAX_CONTEXT];
      char save_exten[AST_MAX_EXTENSION];
      int  save_prio;

      ast_channel_lock(chan);
      if (bridge_cdr) {
         /*
          * Swap the bridge_cdr and the chan cdr for a moment, and let
          * the hangup dialplan code operate on it.
          */
         swapper = ast_channel_cdr(chan);
         ast_channel_cdr_set(chan, bridge_cdr);

         /* protect the lastapp/lastdata against the effects of the hangup/dialplan code */
         ast_copy_string(savelastapp, bridge_cdr->lastapp, sizeof(bridge_cdr->lastapp));
         ast_copy_string(savelastdata, bridge_cdr->lastdata, sizeof(bridge_cdr->lastdata));
      }
      ast_copy_string(save_context, ast_channel_context(chan), sizeof(save_context));
      ast_copy_string(save_exten, ast_channel_exten(chan), sizeof(save_exten));
      save_prio = ast_channel_priority(chan);
      ast_channel_unlock(chan);

      ast_autoservice_start(peer);
      if (ast_exists_extension(chan, ast_channel_context(chan), "h", 1,
         S_COR(ast_channel_caller(chan)->id.number.valid,
            ast_channel_caller(chan)->id.number.str, NULL))) {
         ast_pbx_h_exten_run(chan, ast_channel_context(chan));
         hangup_run = 1;
      } else if (!ast_strlen_zero(ast_channel_macrocontext(chan))
         && ast_exists_extension(chan, ast_channel_macrocontext(chan), "h", 1,
            S_COR(ast_channel_caller(chan)->id.number.valid,
               ast_channel_caller(chan)->id.number.str, NULL))) {
         ast_pbx_h_exten_run(chan, ast_channel_macrocontext(chan));
         hangup_run = 1;
      }
      if (ast_pbx_hangup_handler_run(chan)) {
         /* Indicate hangup handlers were run. */
         hangup_run = 1;
      }
      ast_autoservice_stop(peer);

      ast_channel_lock(chan);

      /* swap it back */
      ast_channel_context_set(chan, save_context);
      ast_channel_exten_set(chan, save_exten);
      ast_channel_priority_set(chan, save_prio);
      if (bridge_cdr) {
         if (ast_channel_cdr(chan) == bridge_cdr) {
            ast_channel_cdr_set(chan, swapper);

            /* Restore the lastapp/lastdata */
            ast_copy_string(bridge_cdr->lastapp, savelastapp, sizeof(bridge_cdr->lastapp));
            ast_copy_string(bridge_cdr->lastdata, savelastdata, sizeof(bridge_cdr->lastdata));
         } else {
            bridge_cdr = NULL;
         }
      }
      ast_channel_unlock(chan);
   }

   /* obey the NoCDR() wishes. -- move the DISABLED flag to the bridge CDR if it was set on the channel during the bridge... */
   new_chan_cdr = pick_unlocked_cdr(ast_channel_cdr(chan)); /* the proper chan cdr, if there are forked cdrs */

   /*
    * If the channel CDR has been modified during the call, record
    * the changes in the bridge cdr, BUT, if hangup_run, the CDR
    * got swapped so don't overwrite what was done in the
    * h-extension or hangup handlers.  What a mess.  This is why
    * you never touch CDR code.
    */
   if (new_chan_cdr && bridge_cdr && !hangup_run) {
      ast_cdr_copy_vars(bridge_cdr, new_chan_cdr);
      ast_copy_string(bridge_cdr->userfield, new_chan_cdr->userfield, sizeof(bridge_cdr->userfield));
      bridge_cdr->amaflags = new_chan_cdr->amaflags;
      ast_copy_string(bridge_cdr->accountcode, new_chan_cdr->accountcode, sizeof(bridge_cdr->accountcode));
      if (ast_test_flag(new_chan_cdr, AST_CDR_FLAG_POST_DISABLED)) {
         ast_set_flag(bridge_cdr, AST_CDR_FLAG_POST_DISABLED);
      }
   }

   /* we can post the bridge CDR at this point */
   if (bridge_cdr) {
      ast_cdr_end(bridge_cdr);
      ast_cdr_detach(bridge_cdr);
   }

   /* do a specialized reset on the beginning channel
      CDR's, if they still exist, so as not to mess up
      issues in future bridges;

      Here are the rules of the game:
      1. The chan and peer channel pointers will not change
         during the life of the bridge.
      2. But, in transfers, the channel names will change.
         between the time the bridge is started, and the
         time the channel ends.
         Usually, when a channel changes names, it will
         also change CDR pointers.
      3. Usually, only one of the two channels (chan or peer)
         will change names.
      4. Usually, if a channel changes names during a bridge,
         it is because of a transfer. Usually, in these situations,
         it is normal to see 2 bridges running simultaneously, and
         it is not unusual to see the two channels that change
         swapped between bridges.
      5. After a bridge occurs, we have 2 or 3 channels' CDRs
         to attend to; if the chan or peer changed names,
         we have the before and after attached CDR's.
   */

   if (new_chan_cdr) {
      struct ast_channel *chan_ptr = NULL;

      if (strcasecmp(orig_channame, ast_channel_name(chan)) != 0) {
         /* old channel */
         if ((chan_ptr = ast_channel_get_by_name(orig_channame))) {
            ast_channel_lock(chan_ptr);
            if (!ast_bridged_channel(chan_ptr)) {
               struct ast_cdr *cur;
               for (cur = ast_channel_cdr(chan_ptr); cur; cur = cur->next) {
                  if (cur == chan_cdr) {
                     break;
                  }
               }
               if (cur) {
                  ast_cdr_specialized_reset(chan_cdr, 0);
               }
            }
            ast_channel_unlock(chan_ptr);
            chan_ptr = ast_channel_unref(chan_ptr);
         }
         /* new channel */
         ast_cdr_specialized_reset(new_chan_cdr, 0);
      } else {
         ast_cdr_specialized_reset(ast_channel_cdr(chan), 0); /* nothing changed, reset the chan cdr  */
      }
   }

   {
      struct ast_channel *chan_ptr = NULL;
      new_peer_cdr = pick_unlocked_cdr(ast_channel_cdr(peer)); /* the proper chan cdr, if there are forked cdrs */
      if (new_chan_cdr && ast_test_flag(new_chan_cdr, AST_CDR_FLAG_POST_DISABLED) && new_peer_cdr && !ast_test_flag(new_peer_cdr, AST_CDR_FLAG_POST_DISABLED))
         ast_set_flag(new_peer_cdr, AST_CDR_FLAG_POST_DISABLED); /* DISABLED is viral-- it will propagate across a bridge */
      if (strcasecmp(orig_peername, ast_channel_name(peer)) != 0) {
         /* old channel */
         if ((chan_ptr = ast_channel_get_by_name(orig_peername))) {
            ast_channel_lock(chan_ptr);
            if (!ast_bridged_channel(chan_ptr)) {
               struct ast_cdr *cur;
               for (cur = ast_channel_cdr(chan_ptr); cur; cur = cur->next) {
                  if (cur == peer_cdr) {
                     break;
                  }
               }
               if (cur) {
                  ast_cdr_specialized_reset(peer_cdr, 0);
               }
            }
            ast_channel_unlock(chan_ptr);
            chan_ptr = ast_channel_unref(chan_ptr);
         }
         /* new channel */
         if (new_peer_cdr) {
            ast_cdr_specialized_reset(new_peer_cdr, 0);
         }
      } else {
         if (we_disabled_peer_cdr) {
            ast_clear_flag(ast_channel_cdr(peer), AST_CDR_FLAG_POST_DISABLED);
         }
         ast_cdr_specialized_reset(ast_channel_cdr(peer), 0); /* nothing changed, reset the peer cdr  */
      }
   }

   return res;
}

int ast_bridge_timelimit	(	struct ast_channel *	chan,
		struct ast_bridge_config *	config,
		char *	parse,
		struct timeval *	calldurationlimit
	)

parse L option and read associated channel variables to set warning, warning frequency, and timelimit

Note:

caller must be aware of freeing memory for warning_sound, end_sound, and start_sound

Definition at line 7980 of file features.c.

References ast_channel_lock, ast_channel_unlock, AST_FEATURE_PLAY_WARNING, ast_log(), ast_set_flag, ast_strdup, ast_strdupa, ast_strlen_zero(), ast_true(), ast_verb, ast_bridge_config::end_sound, ast_bridge_config::features_callee, ast_bridge_config::features_caller, LOG_WARNING, pbx_builtin_getvar_helper(), ast_bridge_config::play_warning, S_OR, ast_bridge_config::start_sound, strsep(), ast_bridge_config::timelimit, var, ast_bridge_config::warning_freq, and ast_bridge_config::warning_sound.

Referenced by bridge_exec(), and dial_exec_full().

{
   char *stringp = ast_strdupa(parse);
   char *limit_str, *warning_str, *warnfreq_str;
   const char *var;
   int play_to_caller = 0, play_to_callee = 0;
   int delta;

   limit_str = strsep(&stringp, ":");
   warning_str = strsep(&stringp, ":");
   warnfreq_str = strsep(&stringp, ":");

   config->timelimit = atol(limit_str);
   if (warning_str)
      config->play_warning = atol(warning_str);
   if (warnfreq_str)
      config->warning_freq = atol(warnfreq_str);

   if (!config->timelimit) {
      ast_log(LOG_WARNING, "Bridge does not accept L(%s), hanging up.\n", limit_str);
      config->timelimit = config->play_warning = config->warning_freq = 0;
      config->warning_sound = NULL;
      return -1; /* error */
   } else if ( (delta = config->play_warning - config->timelimit) > 0) {
      int w = config->warning_freq;

      /*
       * If the first warning is requested _after_ the entire call
       * would end, and no warning frequency is requested, then turn
       * off the warning. If a warning frequency is requested, reduce
       * the 'first warning' time by that frequency until it falls
       * within the call's total time limit.
       *
       * Graphically:
       *                timelim->|    delta        |<-playwarning
       *      0__________________|_________________|
       *                       | w  |    |    |    |
       *
       * so the number of intervals to cut is 1+(delta-1)/w
       */
      if (w == 0) {
         config->play_warning = 0;
      } else {
         config->play_warning -= w * ( 1 + (delta-1)/w );
         if (config->play_warning < 1)
            config->play_warning = config->warning_freq = 0;
      }
   }

   ast_channel_lock(chan);

   var = pbx_builtin_getvar_helper(chan, "LIMIT_PLAYAUDIO_CALLER");
   play_to_caller = var ? ast_true(var) : 1;

   var = pbx_builtin_getvar_helper(chan, "LIMIT_PLAYAUDIO_CALLEE");
   play_to_callee = var ? ast_true(var) : 0;

   if (!play_to_caller && !play_to_callee)
      play_to_caller = 1;

   var = pbx_builtin_getvar_helper(chan, "LIMIT_WARNING_FILE");
   config->warning_sound = !ast_strlen_zero(var) ? ast_strdup(var) : ast_strdup("timeleft");

   /* The code looking at config wants a NULL, not just "", to decide
    * that the message should not be played, so we replace "" with NULL.
    * Note, pbx_builtin_getvar_helper _can_ return NULL if the variable is
    * not found.
    */

   var = pbx_builtin_getvar_helper(chan, "LIMIT_TIMEOUT_FILE");
   config->end_sound = !ast_strlen_zero(var) ? ast_strdup(var) : NULL;

   var = pbx_builtin_getvar_helper(chan, "LIMIT_CONNECT_FILE");
   config->start_sound = !ast_strlen_zero(var) ? ast_strdup(var) : NULL;

   ast_channel_unlock(chan);

   /* undo effect of S(x) in case they are both used */
   calldurationlimit->tv_sec = 0;
   calldurationlimit->tv_usec = 0;

   /* more efficient to do it like S(x) does since no advanced opts */
   if (!config->play_warning && !config->start_sound && !config->end_sound && config->timelimit) {
      calldurationlimit->tv_sec = config->timelimit / 1000;
      calldurationlimit->tv_usec = (config->timelimit % 1000) * 1000;
      ast_verb(3, "Setting call duration limit to %.3lf seconds.\n",
         calldurationlimit->tv_sec + calldurationlimit->tv_usec / 1000000.0);
      config->timelimit = play_to_caller = play_to_callee =
      config->play_warning = config->warning_freq = 0;
   } else {
      ast_verb(4, "Limit Data for this call:\n");
      ast_verb(4, "timelimit      = %ld ms (%.3lf s)\n", config->timelimit, config->timelimit / 1000.0);
      ast_verb(4, "play_warning   = %ld ms (%.3lf s)\n", config->play_warning, config->play_warning / 1000.0);
      ast_verb(4, "play_to_caller = %s\n", play_to_caller ? "yes" : "no");
      ast_verb(4, "play_to_callee = %s\n", play_to_callee ? "yes" : "no");
      ast_verb(4, "warning_freq   = %ld ms (%.3lf s)\n", config->warning_freq, config->warning_freq / 1000.0);
      ast_verb(4, "start_sound    = %s\n", S_OR(config->start_sound, ""));
      ast_verb(4, "warning_sound  = %s\n", config->warning_sound);
      ast_verb(4, "end_sound      = %s\n", S_OR(config->end_sound, ""));
   }
   if (play_to_caller)
      ast_set_flag(&(config->features_caller), AST_FEATURE_PLAY_WARNING);
   if (play_to_callee)
      ast_set_flag(&(config->features_callee), AST_FEATURE_PLAY_WARNING);
   return 0;
}

int ast_can_pickup

(

struct ast_channel *

chan

)

Test if a channel can be picked up.

Parameters:

chan

Channel to test if can be picked up.

Note:

This function assumes that chan is locked.

Returns:

TRUE if channel can be picked up.

Definition at line 7688 of file features.c.

References ast_channel_datastore_find(), ast_channel_flags(), ast_channel_masq(), ast_channel_pbx(), AST_FLAG_ZOMBIE, AST_STATE_DOWN, AST_STATE_RING, AST_STATE_RINGING, and ast_test_flag.

Referenced by ast_pickup_find_by_group(), find_by_mark(), find_by_part(), find_channel_by_group(), pickup_by_exten(), and pickup_by_name_cb().

{
   if (!ast_channel_pbx(chan) && !ast_channel_masq(chan) && !ast_test_flag(ast_channel_flags(chan), AST_FLAG_ZOMBIE)
      && (ast_channel_state(chan) == AST_STATE_RINGING
         || ast_channel_state(chan) == AST_STATE_RING
         /*
          * Check the down state as well because some SIP devices do not
          * give 180 ringing when they can just give 183 session progress
          * instead.  Issue 14005.  (Some ISDN switches as well for that
          * matter.)
          */
         || ast_channel_state(chan) == AST_STATE_DOWN)
      && !ast_channel_datastore_find(chan, &pickup_active, NULL)) {
      return 1;
   }
   return 0;
}

void ast_channel_log	(	char *	title,
		struct ast_channel *	chan
	)

Definition at line 4141 of file features.c.

References ast_channel_accountcode(), ast_channel_amaflags(), ast_channel_appl(), ast_channel_cdr(), ast_channel_context(), ast_channel_data(), ast_channel_dialcontext(), ast_channel_exten(), ast_channel_internal_bridged_channel(), ast_channel_linkedid(), ast_channel_macrocontext(), ast_channel_macroexten(), ast_channel_macropriority(), ast_channel_masq(), ast_channel_masqr(), ast_channel_name(), ast_channel_priority(), ast_channel_uniqueid(), ast_log(), and LOG_NOTICE.

Referenced by ast_bridge_call().

{
   ast_log(LOG_NOTICE, "______ %s (%lx)______\n", title, (unsigned long) chan);
   ast_log(LOG_NOTICE, "CHAN: name: %s;  appl: %s; data: %s; contxt: %s;  exten: %s; pri: %d;\n",
      ast_channel_name(chan), ast_channel_appl(chan), ast_channel_data(chan), ast_channel_context(chan), ast_channel_exten(chan), ast_channel_priority(chan));
   ast_log(LOG_NOTICE, "CHAN: acctcode: %s;  dialcontext: %s; amaflags: %x; maccontxt: %s;  macexten: %s; macpri: %d;\n",
      ast_channel_accountcode(chan), ast_channel_dialcontext(chan), ast_channel_amaflags(chan), ast_channel_macrocontext(chan), ast_channel_macroexten(chan), ast_channel_macropriority(chan));
   ast_log(LOG_NOTICE, "CHAN: masq: %p;  masqr: %p; _bridge: %p; uniqueID: %s; linkedID:%s\n",
      ast_channel_masq(chan), ast_channel_masqr(chan),
      ast_channel_internal_bridged_channel(chan), ast_channel_uniqueid(chan), ast_channel_linkedid(chan));
   if (ast_channel_masqr(chan)) {
      ast_log(LOG_NOTICE, "CHAN: masquerading as: %s;  cdr: %p;\n",
         ast_channel_name(ast_channel_masqr(chan)), ast_channel_cdr(ast_channel_masqr(chan)));
   }
   if (ast_channel_internal_bridged_channel(chan)) {
      ast_log(LOG_NOTICE, "CHAN: Bridged to %s\n", ast_channel_name(ast_channel_internal_bridged_channel(chan)));
   }

   ast_log(LOG_NOTICE, "===== done ====\n");
}

int ast_do_pickup	(	struct ast_channel *	chan,
		struct ast_channel *	target
	)

Pickup a call target.

Parameters:

	chan	channel that initiated pickup.
	target	channel to be picked up.

Note:

This function assumes that target is locked.

Return values:

	0	on success.
	-1	on failure.

< A masquerade changes channel names.

< A masquerade changes channel names.

Definition at line 7846 of file features.c.

References ast_answer(), AST_CAUSE_ANSWERED_ELSEWHERE, AST_CEL_PICKUP, ast_cel_report_event(), ast_channel_caller(), ast_channel_connected(), ast_channel_connected_line_macro(), ast_channel_connected_line_sub(), ast_channel_datastore_add(), ast_channel_datastore_remove(), ast_channel_hangupcause_set(), ast_channel_lock, ast_channel_masquerade(), ast_channel_name(), ast_channel_queue_connected_line_update(), ast_channel_unlock, ast_channel_update_connected_line(), ast_connected_line_copy_from_caller(), AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER, AST_CONTROL_ANSWER, ast_datastore_alloc, ast_datastore_free(), ast_debug, ast_do_masquerade(), ast_log(), ast_manager_event_multichan, ast_party_connected_line_copy(), ast_party_connected_line_free(), ast_party_connected_line_init(), ast_party_id_reset(), ast_queue_control(), ast_strdupa, EVENT_FLAG_CALL, LOG_WARNING, ast_party_connected_line::priv, and ast_party_connected_line::source.

Referenced by ast_pickup_call(), pickup_by_channel(), pickup_by_exten(), pickup_by_group(), pickup_by_mark(), and pickup_by_part().

{
   struct ast_party_connected_line connected_caller;
   struct ast_channel *chans[2] = { chan, target };
   struct ast_datastore *ds_pickup;
   const char *chan_name;/*!< A masquerade changes channel names. */
   const char *target_name;/*!< A masquerade changes channel names. */
   int res = -1;

   target_name = ast_strdupa(ast_channel_name(target));
   ast_debug(1, "Call pickup on '%s' by '%s'\n", target_name, ast_channel_name(chan));

   /* Mark the target to block any call pickup race. */
   ds_pickup = ast_datastore_alloc(&pickup_active, NULL);
   if (!ds_pickup) {
      ast_log(LOG_WARNING,
         "Unable to create channel datastore on '%s' for call pickup\n", target_name);
      return -1;
   }
   ast_channel_datastore_add(target, ds_pickup);

   ast_party_connected_line_init(&connected_caller);
   ast_party_connected_line_copy(&connected_caller, ast_channel_connected(target));
   ast_channel_unlock(target);/* The pickup race is avoided so we do not need the lock anymore. */
   /* Reset any earlier private connected id representation */
   ast_party_id_reset(&connected_caller.priv);

   connected_caller.source = AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER;
   if (ast_channel_connected_line_sub(NULL, chan, &connected_caller, 0) &&
      ast_channel_connected_line_macro(NULL, chan, &connected_caller, 0, 0)) {
      ast_channel_update_connected_line(chan, &connected_caller, NULL);
   }
   ast_party_connected_line_free(&connected_caller);

   ast_channel_lock(chan);
   chan_name = ast_strdupa(ast_channel_name(chan));
   ast_connected_line_copy_from_caller(&connected_caller, ast_channel_caller(chan));
   ast_channel_unlock(chan);
   connected_caller.source = AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER;

   ast_cel_report_event(target, AST_CEL_PICKUP, NULL, NULL, chan);

   if (ast_answer(chan)) {
      ast_log(LOG_WARNING, "Unable to answer '%s'\n", chan_name);
      goto pickup_failed;
   }

   if (ast_queue_control(chan, AST_CONTROL_ANSWER)) {
      ast_log(LOG_WARNING, "Unable to queue answer on '%s'\n", chan_name);
      goto pickup_failed;
   }

   ast_channel_queue_connected_line_update(chan, &connected_caller, NULL);

   /* setting the HANGUPCAUSE so the ringing channel knows this call was not a missed call */
   ast_channel_hangupcause_set(chan, AST_CAUSE_ANSWERED_ELSEWHERE);

   if (ast_channel_masquerade(target, chan)) {
      ast_log(LOG_WARNING, "Unable to masquerade '%s' into '%s'\n", chan_name,
         target_name);
      goto pickup_failed;
   }

   /* If you want UniqueIDs, set channelvars in manager.conf to CHANNEL(uniqueid) */
   /*** DOCUMENTATION
      <managerEventInstance>
         <synopsis>Raised when a call pickup occurs.</synopsis>
         <syntax>
            <parameter name="Channel"><para>The name of the channel that initiated the pickup.</para></parameter>
            <parameter name="TargetChannel"><para>The name of the channel that is being picked up.</para></parameter>
         </syntax>
      </managerEventInstance>
   ***/
   ast_manager_event_multichan(EVENT_FLAG_CALL, "Pickup", 2, chans,
      "Channel: %s\r\n"
      "TargetChannel: %s\r\n",
      chan_name, target_name);

   /* Do the masquerade manually to make sure that it is completed. */
   ast_do_masquerade(target);
   res = 0;

pickup_failed:
   ast_channel_lock(target);
   if (!ast_channel_datastore_remove(target, ds_pickup)) {
      ast_datastore_free(ds_pickup);
   }
   ast_party_connected_line_free(&connected_caller);

   return res;
}

int ast_feature_detect	(	struct ast_channel *	chan,
		struct ast_flags *	features,
		const char *	code,
		struct ast_call_feature *	feature
	)

detect a feature before bridging

Parameters:

	chan
	features	an ast_flags ptr
	code	ptr of input code
	feature

Return values:

ast_call_feature

ptr to be set if found

Definition at line 3725 of file features.c.

References FEATURE_INTERPRET_DETECT, and feature_interpret_helper().

Referenced by detect_disconnect().

                                                                                                                                 {

   return feature_interpret_helper(chan, NULL, NULL, code, 0, NULL, features, FEATURE_INTERPRET_DETECT, feature);
}

int ast_features_init

(

void

)

Provided by features.c

Definition at line 8978 of file features.c.

References __ast_custom_function_register(), action_bridge(), ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_devstate_prov_add(), ast_manager_register_xml_core, ast_pthread_create, ast_register_application2(), ast_register_atexit(), AST_TEST_REGISTER, bridge_exec(), do_parking_thread(), EVENT_FLAG_CALL, features_shutdown(), load_config(), manager_park(), manager_parking_status(), manager_parkinglot_list(), metermaidstate(), park_call_exec(), parkcall, parked_call_exec(), parking_thread, parkinglot_cmp_cb(), parkinglot_hash_cb(), and parkinglots.

Referenced by main().

{
   int res;

   parkinglots = ao2_container_alloc(7, parkinglot_hash_cb, parkinglot_cmp_cb);
   if (!parkinglots) {
      return -1;
   }

   res = load_config(0);
   if (res) {
      return res;
   }
   ast_cli_register_multiple(cli_features, ARRAY_LEN(cli_features));
   if (ast_pthread_create(&parking_thread, NULL, do_parking_thread, NULL)) {
      return -1;
   }
   ast_register_application2(app_bridge, bridge_exec, NULL, NULL, NULL);
   res = ast_register_application2(parkedcall, parked_call_exec, NULL, NULL, NULL);
   if (!res)
      res = ast_register_application2(parkcall, park_call_exec, NULL, NULL, NULL);
   if (!res) {
      ast_manager_register_xml_core("ParkedCalls", 0, manager_parking_status);
      ast_manager_register_xml_core("Parkinglots", 0, manager_parkinglot_list);
      ast_manager_register_xml_core("Park", EVENT_FLAG_CALL, manager_park);
      ast_manager_register_xml_core("Bridge", EVENT_FLAG_CALL, action_bridge);
   }
   res |= __ast_custom_function_register(&feature_function, NULL);
   res |= __ast_custom_function_register(&featuremap_function, NULL);

   res |= ast_devstate_prov_add("Park", metermaidstate);
#if defined(TEST_FRAMEWORK)
   res |= AST_TEST_REGISTER(features_test);
#endif   /* defined(TEST_FRAMEWORK) */

   ast_register_atexit(features_shutdown);

   return res;
}

int ast_features_reload

(

void

)

Reload call features from features.conf.

Definition at line 7176 of file features.c.

References ast_context_destroy(), ast_context_find(), ast_mutex_lock, ast_mutex_unlock, features_reload_lock, load_config(), parking_con_dial, and registrar.

Referenced by handle_features_reload().

{
   struct ast_context *con;
   int res;

   ast_mutex_lock(&features_reload_lock);/* Searialize reloading features.conf */

   /*
    * Always destroy the parking_con_dial context to remove buildup
    * of recalled extensions in the context.  At worst, the parked
    * call gets hungup attempting to run an invalid extension when
    * we are trying to callback the parker or the preset return
    * extension.  This is a small window of opportunity on an
    * execution chain that is not expected to happen very often.
    */
   con = ast_context_find(parking_con_dial);
   if (con) {
      ast_context_destroy(con, registrar);
   }

   res = load_config(1);
   ast_mutex_unlock(&features_reload_lock);

   return res;
}

struct ast_call_feature* ast_find_call_feature

(

const char *

name

)

[read]

look for a call feature entry by its sname

Parameters:

name

a string ptr, should match "automon", "blindxfer", "atxfer", etc.

Definition at line 3311 of file features.c.

References FEATURES_COUNT, find_dynamic_feature(), and ast_call_feature::sname.

Referenced by action_atxfer(), builtin_feature_get_exten(), featuremap_write(), handle_request_info(), and process_config().

{
   int x;
   for (x = 0; x < FEATURES_COUNT; x++) {
      if (!strcasecmp(name, builtin_features[x].sname))
         return &builtin_features[x];
   }

   return find_dynamic_feature(name);
}

int ast_masq_park_call	(	struct ast_channel *	park_me,
		struct ast_channel *	parker,
		int	timeout,
		int *	extout
	)

Park a call via a masqueraded channel.

Parameters:

	park_me	Channel to be parked.
	parker	Channel parking the call.
	timeout	is a timeout in milliseconds
	extout	is a parameter to an int that will hold the parked location, or NULL if you want.

Masquerade the park_me channel into a new, empty channel which is then parked.

Note:

Use ast_masq_park_call_exten() instead.

Return values:

	0	on success.
	-1	on failure.

Definition at line 2023 of file features.c.

References ast_channel_name(), ast_strdupa, masq_park_call(), ast_park_call_args::orig_chan_name, and ast_park_call_args::timeout.

Referenced by handle_soft_key_event_message(), handle_stimulus_message(), and parkandannounce_exec().

{
   struct ast_park_call_args args = {
      .timeout = timeout,
      .extout = extout,
   };

   if (peer) {
      args.orig_chan_name = ast_strdupa(ast_channel_name(peer));
   }
   return masq_park_call(rchan, peer, &args);
}

int ast_masq_park_call_exten	(	struct ast_channel *	park_me,
		struct ast_channel *	parker,
		const char *	park_exten,
		const char *	park_context,
		int	timeout,
		int *	extout
	)

Park a call via a masqueraded channel.

Since:

1.8.9

Parameters:

	park_me	Channel to be parked.
	parker	Channel parking the call.
	park_exten	Parking lot access extension
	park_context	Parking lot context
	timeout	is a timeout in milliseconds
	extout	is a parameter to an int that will hold the parked location, or NULL if you want.

Masquerade the park_me channel into a new, empty channel which is then parked.

Return values:

	0	on success.
	-1	on failure.

Definition at line 1969 of file features.c.

References ast_autoservice_start(), ast_autoservice_stop(), ast_channel_name(), ast_get_extension_app_data(), AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), create_dynamic_parkinglot(), find_parkinglot(), get_parking_exten(), masq_park_call(), ast_park_call_args::orig_chan_name, parkeddynamic, ast_park_call_args::parkinglot, parkinglot_unref(), parse(), park_app_args::pl_name, and ast_park_call_args::timeout.

Referenced by __analog_ss_thread(), analog_ss_thread(), and mgcp_ss().

{
   int res;
   char *parse;
   const char *app_data;
   struct ast_exten *exten;
   struct park_app_args app_args;
   struct ast_park_call_args args = {
      .timeout = timeout,
      .extout = extout,
   };

   if (parker) {
      args.orig_chan_name = ast_strdupa(ast_channel_name(parker));
   }
   if (!park_exten || !park_context) {
      return masq_park_call(park_me, parker, &args);
   }

   /*
    * Determiine if the specified park extension has an exclusive
    * parking lot to use.
    */
   if (parker && parker != park_me) {
      ast_autoservice_start(park_me);
   }
   exten = get_parking_exten(park_exten, parker, park_context);
   if (exten) {
      app_data = ast_get_extension_app_data(exten);
      if (!app_data) {
         app_data = "";
      }
      parse = ast_strdupa(app_data);
      AST_STANDARD_APP_ARGS(app_args, parse);

      if (!ast_strlen_zero(app_args.pl_name)) {
         /* Find the specified exclusive parking lot */
         args.parkinglot = find_parkinglot(app_args.pl_name);
         if (!args.parkinglot && parkeddynamic) {
            args.parkinglot = create_dynamic_parkinglot(app_args.pl_name, park_me);
         }
      }
   }
   if (parker && parker != park_me) {
      ast_autoservice_stop(park_me);
   }

   res = masq_park_call(park_me, parker, &args);
   if (args.parkinglot) {
      parkinglot_unref(args.parkinglot);
   }
   return res;
}

int ast_park_call	(	struct ast_channel *	park_me,
		struct ast_channel *	parker,
		int	timeout,
		const char *	park_exten,
		int *	extout
	)

Park a call and read back parked location.

Parameters:

	park_me	Channel to be parked.
	parker	Channel parking the call.
	timeout	is a timeout in milliseconds
	park_exten	Parking lot access extension (Not used)
	extout	is a parameter to an int that will hold the parked location, or NULL if you want.

Park the park_me channel, and read back the parked location to the parker channel. If the call is not picked up within a specified period of time, then the call will return to the last step that it was in (in terms of exten, priority and context).

Note:

Use ast_park_call_exten() instead.

Return values:

	0	on success.
	-1	on failure.

Definition at line 1872 of file features.c.

References park_call_full(), and ast_park_call_args::timeout.

{
   struct ast_park_call_args args = {
      .timeout = timeout,
      .extout = extout,
   };

   return park_call_full(park_me, parker, &args);
}

int ast_park_call_exten	(	struct ast_channel *	park_me,
		struct ast_channel *	parker,
		const char *	park_exten,
		const char *	park_context,
		int	timeout,
		int *	extout
	)

Park a call and read back parked location.

Since:

1.8.9

Parameters:

	park_me	Channel to be parked.
	parker	Channel parking the call.
	park_exten	Parking lot access extension
	park_context	Parking lot context
	timeout	is a timeout in milliseconds
	extout	is a parameter to an int that will hold the parked location, or NULL if you want.

Park the park_me channel, and read back the parked location to the parker channel. If the call is not picked up within a specified period of time, then the call will return to the last step that it was in (in terms of exten, priority and context).

Return values:

	0	on success.
	-1	on failure.

Definition at line 1821 of file features.c.

References ast_autoservice_start(), ast_autoservice_stop(), ast_get_extension_app_data(), AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), create_dynamic_parkinglot(), find_parkinglot(), get_parking_exten(), park_call_full(), parkeddynamic, ast_park_call_args::parkinglot, parkinglot_unref(), parse(), park_app_args::pl_name, and ast_park_call_args::timeout.

Referenced by iax_park_thread(), and sip_park_thread().

{
   int res;
   char *parse;
   const char *app_data;
   struct ast_exten *exten;
   struct park_app_args app_args;
   struct ast_park_call_args args = {
      .timeout = timeout,
      .extout = extout,
   };

   if (!park_exten || !park_context) {
      return park_call_full(park_me, parker, &args);
   }

   /*
    * Determiine if the specified park extension has an exclusive
    * parking lot to use.
    */
   if (parker && parker != park_me) {
      ast_autoservice_start(park_me);
   }
   exten = get_parking_exten(park_exten, parker, park_context);
   if (exten) {
      app_data = ast_get_extension_app_data(exten);
      if (!app_data) {
         app_data = "";
      }
      parse = ast_strdupa(app_data);
      AST_STANDARD_APP_ARGS(app_args, parse);

      if (!ast_strlen_zero(app_args.pl_name)) {
         /* Find the specified exclusive parking lot */
         args.parkinglot = find_parkinglot(app_args.pl_name);
         if (!args.parkinglot && parkeddynamic) {
            args.parkinglot = create_dynamic_parkinglot(app_args.pl_name, park_me);
         }
      }
   }
   if (parker && parker != park_me) {
      ast_autoservice_stop(park_me);
   }

   res = park_call_full(park_me, parker, &args);
   if (args.parkinglot) {
      parkinglot_unref(args.parkinglot);
   }
   return res;
}

int ast_parking_ext_valid	(	const char *	exten_str,
		struct ast_channel *	chan,
		const char *	context
	)

Determine if parking extension exists in a given context.

Return values:

	0	if extension does not exist
	1	if extension does exist

Definition at line 981 of file features.c.

References get_parking_exten().

Referenced by __analog_ss_thread(), analog_ss_thread(), dp_lookup(), handle_request_refer(), mgcp_ss(), and socket_process_helper().

{
   return get_parking_exten(exten_str, chan, context) ? 1 : 0;
}

int ast_pickup_call

(

struct ast_channel *

chan

)

Pickup a call.

Parameters:

chan

channel that initiated pickup.

Walk list of channels, checking it is not itself, channel is pbx one, check that the callgroup for both channels are the same and the channel is ringing. Answer calling channel, flag channel as answered on queue, masq channels together.

< Potential pickup target

Definition at line 7811 of file features.c.

References ast_answer(), ast_channel_name(), ast_channel_unlock, ast_channel_unref, ast_debug, ast_do_pickup(), ast_log(), ast_pickup_find_by_group(), ast_stream_and_wait(), ast_strlen_zero(), LOG_NOTICE, LOG_WARNING, pbx_builtin_setvar_helper(), pickupfailsound, and pickupsound.

Referenced by __analog_ss_thread(), analog_ss_thread(), cb_events(), handle_call_outgoing(), mgcp_ss(), and sip_pickup_thread().

{
   struct ast_channel *target;/*!< Potential pickup target */
   int res = -1;

   ast_debug(1, "pickup attempt by %s\n", ast_channel_name(chan));

   /* The found channel is already locked. */
   target = ast_pickup_find_by_group(chan);
   if (target) {
      ast_log(LOG_NOTICE, "pickup %s attempt by %s\n", ast_channel_name(target), ast_channel_name(chan));

      res = ast_do_pickup(chan, target);
      ast_channel_unlock(target);
      if (!res) {
         if (!ast_strlen_zero(pickupsound)) {
            pbx_builtin_setvar_helper(target, "BRIDGE_PLAY_SOUND", pickupsound);
         }
      } else {
         ast_log(LOG_WARNING, "pickup %s failed by %s\n", ast_channel_name(target), ast_channel_name(chan));
      }
      target = ast_channel_unref(target);
   }

   if (res < 0) {
      ast_debug(1, "No call pickup possible... for %s\n", ast_channel_name(chan));
      if (!ast_strlen_zero(pickupfailsound)) {
         ast_answer(chan);
         ast_stream_and_wait(chan, pickupfailsound, "");
      }
   }

   return res;
}

const char* ast_pickup_ext

(

void

)

Determine system call pickup extension.

Definition at line 986 of file features.c.

Referenced by __analog_ss_thread(), analog_canmatch_featurecode(), analog_ss_thread(), canmatch_featurecode(), cb_events(), get_destination(), handle_call_outgoing(), handle_feature_show(), handle_request_invite(), key_main_page(), and mgcp_ss().

{
   return pickup_ext;
}

struct ast_channel* ast_pickup_find_by_group

(

struct ast_channel *

chan

)

[read]

Find a pickup channel target by group.

Parameters:

chan

channel that initiated pickup.

Return values:

	target	on success. The returned channel is locked and reffed.
	NULL	on error.

< Candidate channels found to pickup.

< Potential pickup target

< Potential new older target

Definition at line 7744 of file features.c.

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_container_alloc_options, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ao2_unlink, ast_can_pickup(), ast_channel_callback(), ast_channel_creationtime(), ast_channel_lock, ast_channel_unlock, ast_channel_unref, ast_tvcmp(), and find_channel_by_group().

Referenced by ast_pickup_call(), and pickup_by_group().

{
   struct ao2_container *candidates;/*!< Candidate channels found to pickup. */
   struct ast_channel *target;/*!< Potential pickup target */

   candidates = ao2_container_alloc_options(AO2_ALLOC_OPT_LOCK_NOLOCK, 1, NULL, NULL);
   if (!candidates) {
      return NULL;
   }

   /* Find all candidate targets by group. */
   ast_channel_callback(find_channel_by_group, chan, candidates, 0);

   /* Find the oldest pickup target candidate */
   target = NULL;
   for (;;) {
      struct ast_channel *candidate;/*!< Potential new older target */
      struct ao2_iterator iter;

      iter = ao2_iterator_init(candidates, 0);
      while ((candidate = ao2_iterator_next(&iter))) {
         if (!target) {
            /* First target. */
            target = candidate;
            continue;
         }
         if (ast_tvcmp(ast_channel_creationtime(candidate), ast_channel_creationtime(target)) < 0) {
            /* We have a new target. */
            ast_channel_unref(target);
            target = candidate;
            continue;
         }
         ast_channel_unref(candidate);
      }
      ao2_iterator_destroy(&iter);
      if (!target) {
         /* No candidates found. */
         break;
      }

      /* The found channel must be locked and ref'd. */
      ast_channel_lock(target);

      /* Recheck pickup ability */
      if (ast_can_pickup(target)) {
         /* This is the channel to pickup. */
         break;
      }

      /* Someone else picked it up or the call went away. */
      ast_channel_unlock(target);
      ao2_unlink(candidates, target);
      target = ast_channel_unref(target);
   }
   ao2_ref(candidates, -1);

   return target;
}

void ast_rdlock_call_features

(

void

)

Definition at line 3297 of file features.c.

References ast_rwlock_rdlock, and features_lock.

Referenced by builtin_feature_get_exten(), featuremap_read(), and handle_request_info().

{
   ast_rwlock_rdlock(&features_lock);
}

void ast_register_feature

(

struct ast_call_feature *

feature

)

register new feature into feature_list

register new feature into feature_set

Definition at line 3141 of file features.c.

References ast_log(), AST_RWLIST_INSERT_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_verb, ast_call_feature::feature_entry, LOG_NOTICE, and ast_call_feature::sname.

Referenced by process_applicationmap_line().

{
   if (!feature) {
      ast_log(LOG_NOTICE,"You didn't pass a feature!\n");
      return;
   }

   AST_RWLIST_WRLOCK(&feature_list);
   AST_RWLIST_INSERT_HEAD(&feature_list,feature,feature_entry);
   AST_RWLIST_UNLOCK(&feature_list);

   ast_verb(2, "Registered Feature '%s'\n",feature->sname);
}

void ast_unlock_call_features

(

void

)

Definition at line 3302 of file features.c.

References ast_rwlock_unlock, and features_lock.

Referenced by builtin_feature_get_exten(), featuremap_read(), and handle_request_info().

{
   ast_rwlock_unlock(&features_lock);
}

void ast_unregister_feature

(

struct ast_call_feature *

feature

)

unregister feature from feature_set

Parameters:

feature

the ast_call_feature object which was registered before

Definition at line 3221 of file features.c.

References ast_free, AST_RWLIST_REMOVE, AST_RWLIST_UNLOCK, and AST_RWLIST_WRLOCK.

{
   if (!feature) {
      return;
   }

   AST_RWLIST_WRLOCK(&feature_list);
   AST_RWLIST_REMOVE(&feature_list, feature, feature_entry);
   AST_RWLIST_UNLOCK(&feature_list);

   ast_free(feature);
}

static void ast_unregister_features

(

void

)

[static]

Remove all features in the list.

Definition at line 3235 of file features.c.

References ast_free, AST_RWLIST_REMOVE_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, and ast_call_feature::feature_entry.

Referenced by process_config().

{
   struct ast_call_feature *feature;

   AST_RWLIST_WRLOCK(&feature_list);
   while ((feature = AST_RWLIST_REMOVE_HEAD(&feature_list, feature_entry))) {
      ast_free(feature);
   }
   AST_RWLIST_UNLOCK(&feature_list);
}

static void ast_unregister_groups

(

void

)

[static]

Remove all feature groups in the list.

Definition at line 3261 of file features.c.

References ast_free, AST_LIST_REMOVE_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_string_field_free_memory, and feature_group::features.

Referenced by process_config().

{
   struct feature_group *fg;
   struct feature_group_exten *fge;

   AST_RWLIST_WRLOCK(&feature_groups);
   while ((fg = AST_LIST_REMOVE_HEAD(&feature_groups, entry))) {
      while ((fge = AST_LIST_REMOVE_HEAD(&fg->features, entry))) {
         ast_string_field_free_memory(fge);
         ast_free(fge);
      }

      ast_string_field_free_memory(fg);
      ast_free(fg);
   }
   AST_RWLIST_UNLOCK(&feature_groups);
}

static void atxfer_fail_cleanup	(	struct ast_channel *	transferee,
		struct ast_channel *	transferer,
		struct ast_party_connected_line *	connected_line
	)			[static]

Definition at line 2640 of file features.c.

References ast_channel_connected_line_macro(), ast_channel_connected_line_sub(), ast_channel_update_connected_line(), ast_party_connected_line_free(), and finishup().

Referenced by builtin_atxfer().

{
   finishup(transferee);

   /*
    * Restore party B connected line info about party A.
    *
    * Party B was the caller to party C and is the last known mode
    * for party B.
    */
   if (ast_channel_connected_line_sub(transferee, transferer, connected_line, 0) &&
      ast_channel_connected_line_macro(transferee, transferer, connected_line, 1, 0)) {
      ast_channel_update_connected_line(transferer, connected_line, NULL);
   }
   ast_party_connected_line_free(connected_line);
}

static void* bridge_call_thread

(

void *

data

)

[static]

bridge the call

Parameters:

data

thread bridge.

Set Last Data for respective channels, reset cdr for channels bridge call, check if we're going back to dialplan if not hangup both legs of the call

Definition at line 1125 of file features.c.

References ast_autoservice_chan_hangup_peer(), ast_bridge_call(), ast_callid_threadassoc_add(), ast_callid_unref, ast_channel_appl_set(), ast_channel_data_set(), ast_channel_name(), ast_check_hangup(), ast_free, ast_hangup(), ast_log(), ast_pbx_start(), ast_bridge_thread_obj::bconfig, ast_bridge_thread_obj::callid, ast_bridge_thread_obj::chan, LOG_VERBOSE, LOG_WARNING, ast_bridge_thread_obj::peer, ast_bridge_thread_obj::return_to_pbx, and set_chan_app_data().

Referenced by bridge_call_thread_launch().

{
   struct ast_bridge_thread_obj *tobj = data;

   if (tobj->callid) {
      ast_callid_threadassoc_add(tobj->callid);
      /* Need to deref and set to null since ast_bridge_thread_obj has no common destructor */
      tobj->callid = ast_callid_unref(tobj->callid);
   }

   ast_channel_appl_set(tobj->chan, !tobj->return_to_pbx ? "Transferred Call" : "ManagerBridge");
   if (set_chan_app_data(tobj->chan, ast_channel_name(tobj->peer))) {
      ast_channel_data_set(tobj->chan, "(Empty)");
   }
   ast_channel_appl_set(tobj->peer, !tobj->return_to_pbx ? "Transferred Call" : "ManagerBridge");
   if (set_chan_app_data(tobj->peer, ast_channel_name(tobj->chan))) {
      ast_channel_data_set(tobj->peer, "(Empty)");
   }

   ast_bridge_call(tobj->peer, tobj->chan, &tobj->bconfig);

   if (tobj->return_to_pbx) {
      if (!ast_check_hangup(tobj->peer)) {
         ast_log(LOG_VERBOSE, "putting peer %s into PBX again\n", ast_channel_name(tobj->peer));
         if (ast_pbx_start(tobj->peer)) {
            ast_log(LOG_WARNING, "FAILED continuing PBX on peer %s\n", ast_channel_name(tobj->peer));
            ast_autoservice_chan_hangup_peer(tobj->chan, tobj->peer);
         }
      } else {
         ast_autoservice_chan_hangup_peer(tobj->chan, tobj->peer);
      }
      if (!ast_check_hangup(tobj->chan)) {
         ast_log(LOG_VERBOSE, "putting chan %s into PBX again\n", ast_channel_name(tobj->chan));
         if (ast_pbx_start(tobj->chan)) {
            ast_log(LOG_WARNING, "FAILED continuing PBX on chan %s\n", ast_channel_name(tobj->chan));
            ast_hangup(tobj->chan);
         }
      } else {
         ast_hangup(tobj->chan);
      }
   } else {
      ast_hangup(tobj->chan);
      ast_hangup(tobj->peer);
   }

   ast_free(tobj);

   return NULL;
}

static void bridge_call_thread_launch

(

struct ast_bridge_thread_obj *

data

)

[static]

create thread for the parked call

Parameters:

data

Create thread and attributes, call bridge_call_thread

Definition at line 1181 of file features.c.

References ast_callid_unref, ast_hangup(), ast_log(), ast_pthread_create, ast_read_threadstorage_callid(), bridge_call_thread(), ast_bridge_thread_obj::callid, ast_bridge_thread_obj::chan, LOG_ERROR, ast_bridge_thread_obj::peer, and thread.

Referenced by action_bridge(), and builtin_atxfer().

{
   pthread_t thread;
   pthread_attr_t attr;
   struct sched_param sched;

   /* This needs to be unreffed once it has been associated with the new thread. */
   data->callid = ast_read_threadstorage_callid();

   pthread_attr_init(&attr);
   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
   if (ast_pthread_create(&thread, &attr, bridge_call_thread, data)) {
      /* Failed to create thread. Ditch the reference to callid. */
      ast_callid_unref(data->callid);
      ast_hangup(data->chan);
      ast_hangup(data->peer);
      ast_log(LOG_ERROR, "Failed to create bridge_call_thread.\n");
      return;
   }
   pthread_attr_destroy(&attr);
   memset(&sched, 0, sizeof(sched));
   pthread_setschedparam(thread, SCHED_RR, &sched);
}

static int bridge_exec	(	struct ast_channel *	chan,
		const char *	data
	)			[static]

Bridge channels.

Parameters:

	chan
	data	channel to bridge with.

Split data, check we aren't bridging with ourself, check valid channel, answer call if not already, check compatible channels, setup bridge config now bridge call, if transfered party hangs up return to PBX extension.

Definition at line 8098 of file features.c.

References args, ast_answer(), AST_APP_ARG, ast_app_parse_options(), ast_autoservice_chan_hangup_peer(), ast_bridge_call(), ast_bridge_timelimit(), ast_channel_alloc, ast_channel_context(), ast_channel_exten(), ast_channel_flags(), ast_channel_get_by_name_prefix(), ast_channel_language(), ast_channel_linkedid(), ast_channel_lock, ast_channel_make_compatible(), ast_channel_name(), ast_channel_priority(), ast_channel_unlock, ast_channel_unref, ast_check_hangup(), ast_debug, AST_DECLARE_APP_ARGS, AST_FEATURE_AUTOMON, AST_FEATURE_DISCONNECT, AST_FEATURE_PARKCALL, AST_FEATURE_REDIRECT, AST_FLAG_BRIDGE_HANGUP_DONT, ast_free, ast_goto_if_exists(), ast_hangup(), ast_log(), ast_manager_event, ast_manager_event_multichan, ast_parseable_goto(), ast_pbx_start(), ast_replace_subargument_delimiter(), ast_set_flag, AST_STANDARD_APP_ARGS, AST_STATE_DOWN, AST_STATE_UP, ast_strdupa, ast_streamfile(), ast_strlen_zero(), ast_test_flag, ast_waitstream(), bridge_exec_options, BRIDGE_OPT_PLAYTONE, do_bridge_masquerade(), ast_bridge_config::end_sound, EVENT_FLAG_CALL, ast_bridge_config::features_callee, ast_bridge_config::features_caller, LOG_WARNING, OPT_ARG_ARRAY_SIZE, OPT_ARG_CALLEE_GO_ON, OPT_ARG_DURATION_LIMIT, OPT_CALLEE_GO_ON, OPT_CALLEE_HANGUP, OPT_CALLEE_KILL, OPT_CALLEE_MONITOR, OPT_CALLEE_PARK, OPT_CALLEE_TRANSFER, OPT_CALLER_HANGUP, OPT_CALLER_MONITOR, OPT_CALLER_PARK, OPT_CALLER_TRANSFER, OPT_DURATION_LIMIT, pbx_builtin_setvar_helper(), ast_bridge_config::start_sound, ast_bridge_config::warning_sound, and xfersound.

Referenced by ast_features_init().

{
   struct ast_channel *current_dest_chan, *final_dest_chan, *chans[2];
   char *tmp_data  = NULL;
   struct ast_flags opts = { 0, };
   struct ast_bridge_config bconfig = { { 0, }, };
   char *opt_args[OPT_ARG_ARRAY_SIZE];
   struct timeval calldurationlimit = { 0, };

   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(dest_chan);
      AST_APP_ARG(options);
   );

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "Bridge require at least 1 argument specifying the other end of the bridge\n");
      return -1;
   }

   tmp_data = ast_strdupa(data);
   AST_STANDARD_APP_ARGS(args, tmp_data);
   if (!ast_strlen_zero(args.options))
      ast_app_parse_options(bridge_exec_options, &opts, opt_args, args.options);

   /* avoid bridge with ourselves */
   if (!strcmp(ast_channel_name(chan), args.dest_chan)) {
      ast_log(LOG_WARNING, "Unable to bridge channel %s with itself\n", ast_channel_name(chan));
      /*** DOCUMENTATION
         <managerEventInstance>
            <synopsis>Raised when an error occurs during bridge creation.</synopsis>
            <see-also>
               <ref type="application">Bridge</ref>
            </see-also>
         </managerEventInstance>
      ***/
      ast_manager_event(chan, EVENT_FLAG_CALL, "BridgeExec",
         "Response: Failed\r\n"
         "Reason: Unable to bridge channel to itself\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n",
         ast_channel_name(chan), args.dest_chan);
      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "LOOP");
      return 0;
   }

   /* make sure we have a valid end point */
   if (!(current_dest_chan = ast_channel_get_by_name_prefix(args.dest_chan,
         strlen(args.dest_chan)))) {
      ast_log(LOG_WARNING, "Bridge failed because channel %s does not exist\n",
         args.dest_chan);
      ast_manager_event(chan, EVENT_FLAG_CALL, "BridgeExec",
         "Response: Failed\r\n"
         "Reason: Channel2 does not exist\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n", ast_channel_name(chan), args.dest_chan);
      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "NONEXISTENT");
      return 0;
   }

   /* try to allocate a place holder where current_dest_chan will be placed */
   if (!(final_dest_chan = ast_channel_alloc(0, AST_STATE_DOWN, NULL, NULL, NULL,
      NULL, NULL, ast_channel_linkedid(current_dest_chan), 0, "Bridge/%s", ast_channel_name(current_dest_chan)))) {
      ast_log(LOG_WARNING, "Cannot create placeholder channel for chan %s\n", args.dest_chan);
      ast_manager_event(chan, EVENT_FLAG_CALL, "BridgeExec",
         "Response: Failed\r\n"
         "Reason: Cannot create placeholder channel\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n", ast_channel_name(chan), args.dest_chan);
      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "FAILURE");
      ast_channel_unref(current_dest_chan);
      return 0;
   }

   if (ast_test_flag(&opts, OPT_DURATION_LIMIT)
      && !ast_strlen_zero(opt_args[OPT_ARG_DURATION_LIMIT])
      && ast_bridge_timelimit(chan, &bconfig, opt_args[OPT_ARG_DURATION_LIMIT], &calldurationlimit)) {
      ast_manager_event(chan, EVENT_FLAG_CALL, "BridgeExec",
         "Response: Failed\r\n"
         "Reason: Cannot setup bridge time limit\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n", ast_channel_name(chan), args.dest_chan);
      ast_hangup(final_dest_chan);
      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "FAILURE");
      current_dest_chan = ast_channel_unref(current_dest_chan);
      goto done;
   }

   if (do_bridge_masquerade(current_dest_chan, final_dest_chan)) {
      ast_manager_event(chan, EVENT_FLAG_CALL, "BridgeExec",
         "Response: Failed\r\n"
         "Reason: Cannot masquerade channels\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n", ast_channel_name(chan), args.dest_chan);
      ast_hangup(final_dest_chan);
      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "FAILURE");
      current_dest_chan = ast_channel_unref(current_dest_chan);
      goto done;
   }

   /* answer the channel if needed */
   if (ast_channel_state(final_dest_chan) != AST_STATE_UP) {
      ast_answer(final_dest_chan);
   }

   chans[0] = current_dest_chan;
   chans[1] = final_dest_chan;

   /* now current_dest_chan is a ZOMBIE and with softhangup set to 1 and final_dest_chan is our end point */
   /* try to make compatible, send error if we fail */
   if (ast_channel_make_compatible(chan, final_dest_chan) < 0) {
      ast_log(LOG_WARNING, "Could not make channels %s and %s compatible for bridge\n", ast_channel_name(chan), ast_channel_name(final_dest_chan));
      ast_manager_event_multichan(EVENT_FLAG_CALL, "BridgeExec", 2, chans,
         "Response: Failed\r\n"
         "Reason: Could not make channels compatible for bridge\r\n"
         "Channel1: %s\r\n"
         "Channel2: %s\r\n", ast_channel_name(chan), ast_channel_name(final_dest_chan));

      /* Maybe we should return this channel to the PBX? */
      ast_autoservice_chan_hangup_peer(chan, final_dest_chan);

      pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "INCOMPATIBLE");
      current_dest_chan = ast_channel_unref(current_dest_chan);
      goto done;
   }

   /* Report that the bridge will be successfull */
   /*** DOCUMENTATION
      <managerEventInstance>
         <synopsis>Raised when the bridge is created successfully.</synopsis>
         <see-also>
            <ref type="application">Bridge</ref>
         </see-also>
      </managerEventInstance>
   ***/
   ast_manager_event_multichan(EVENT_FLAG_CALL, "BridgeExec", 2, chans,
      "Response: Success\r\n"
      "Channel1: %s\r\n"
      "Channel2: %s\r\n", ast_channel_name(chan), ast_channel_name(final_dest_chan));

   current_dest_chan = ast_channel_unref(current_dest_chan);

   /* we have 2 valid channels to bridge, now it is just a matter of setting up the bridge config and starting the bridge */
   if (ast_test_flag(&opts, BRIDGE_OPT_PLAYTONE) && !ast_strlen_zero(xfersound)) {
      if (!ast_streamfile(final_dest_chan, xfersound, ast_channel_language(final_dest_chan))) {
         if (ast_waitstream(final_dest_chan, "") < 0)
            ast_log(LOG_WARNING, "Failed to play courtesy tone on %s\n", ast_channel_name(final_dest_chan));
      }
   }

   if (ast_test_flag(&opts, OPT_CALLEE_TRANSFER))
      ast_set_flag(&(bconfig.features_callee), AST_FEATURE_REDIRECT);
   if (ast_test_flag(&opts, OPT_CALLER_TRANSFER))
      ast_set_flag(&(bconfig.features_caller), AST_FEATURE_REDIRECT);
   if (ast_test_flag(&opts, OPT_CALLEE_HANGUP))
      ast_set_flag(&(bconfig.features_callee), AST_FEATURE_DISCONNECT);
   if (ast_test_flag(&opts, OPT_CALLER_HANGUP))
      ast_set_flag(&(bconfig.features_caller), AST_FEATURE_DISCONNECT);
   if (ast_test_flag(&opts, OPT_CALLEE_MONITOR))
      ast_set_flag(&(bconfig.features_callee), AST_FEATURE_AUTOMON);
   if (ast_test_flag(&opts, OPT_CALLER_MONITOR))
      ast_set_flag(&(bconfig.features_caller), AST_FEATURE_AUTOMON);
   if (ast_test_flag(&opts, OPT_CALLEE_PARK))
      ast_set_flag(&(bconfig.features_callee), AST_FEATURE_PARKCALL);
   if (ast_test_flag(&opts, OPT_CALLER_PARK))
      ast_set_flag(&(bconfig.features_caller), AST_FEATURE_PARKCALL);

   /*
    * Don't let the after-bridge code run the h-exten.  We want to
    * continue in the dialplan.
    */
   ast_set_flag(ast_channel_flags(chan), AST_FLAG_BRIDGE_HANGUP_DONT);
   ast_bridge_call(chan, final_dest_chan, &bconfig);

   /* The bridge has ended, set BRIDGERESULT to SUCCESS. */
   pbx_builtin_setvar_helper(chan, "BRIDGERESULT", "SUCCESS");

   /* If the other channel has not been hung up, return it to the PBX */
   if (!ast_check_hangup(final_dest_chan)) {
      if (ast_test_flag(&opts, OPT_CALLEE_GO_ON)) {
         char *caller_context;
         char *caller_extension;
         int caller_priority;
         int goto_opt;

         ast_channel_lock(chan);
         caller_context = ast_strdupa(ast_channel_context(chan));
         caller_extension = ast_strdupa(ast_channel_exten(chan));
         caller_priority = ast_channel_priority(chan);
         ast_channel_unlock(chan);

         if (!ast_strlen_zero(opt_args[OPT_ARG_CALLEE_GO_ON])) {
            ast_replace_subargument_delimiter(opt_args[OPT_ARG_CALLEE_GO_ON]);
            /* Set current dialplan position to bridger dialplan position */
            goto_opt = ast_goto_if_exists(final_dest_chan, caller_context, caller_extension, caller_priority)
               /* Then perform the goto */
               || ast_parseable_goto(final_dest_chan, opt_args[OPT_ARG_CALLEE_GO_ON]);
         } else { /* F() */
            goto_opt = ast_goto_if_exists(final_dest_chan, caller_context, caller_extension, caller_priority + 1);
         }
         if (goto_opt || ast_pbx_start(final_dest_chan)) {
            ast_autoservice_chan_hangup_peer(chan, final_dest_chan);
         }
      } else if (!ast_test_flag(&opts, OPT_CALLEE_KILL)) {
         ast_debug(1, "starting new PBX in %s,%s,%d for chan %s\n",
            ast_channel_context(final_dest_chan), ast_channel_exten(final_dest_chan),
            ast_channel_priority(final_dest_chan), ast_channel_name(final_dest_chan));

         if (ast_pbx_start(final_dest_chan)) {
            ast_log(LOG_WARNING, "FAILED continuing PBX on dest chan %s\n", ast_channel_name(final_dest_chan));
            ast_autoservice_chan_hangup_peer(chan, final_dest_chan);
         } else {
            ast_debug(1, "SUCCESS continuing PBX on chan %s\n", ast_channel_name(final_dest_chan));
         }
      } else {
         ast_autoservice_chan_hangup_peer(chan, final_dest_chan);
      }
   } else {
      ast_debug(1, "chan %s was hungup\n", ast_channel_name(final_dest_chan));
      ast_autoservice_chan_hangup_peer(chan, final_dest_chan);
   }
done:
   ast_free((char *) bconfig.warning_sound);
   ast_free((char *) bconfig.end_sound);
   ast_free((char *) bconfig.start_sound);

   return 0;
}

static struct parking_dp_context* build_dialplan_useage_context

(

struct ast_parkinglot *

lot

)

[static, read]

Definition at line 6614 of file features.c.

References ast_calloc, ast_parkinglot::cfg, parking_dp_context::context, destroy_dialplan_usage_context(), dialplan_usage_add_parkinglot_data(), and parkinglot_cfg::parking_con.

Referenced by dialplan_usage_add_parkinglot().

{
   struct parking_dp_context *ctx_node;

   ctx_node = ast_calloc(1, sizeof(*ctx_node) + strlen(lot->cfg.parking_con));
   if (!ctx_node) {
      return NULL;
   }
   if (dialplan_usage_add_parkinglot_data(ctx_node, lot, 0)) {
      destroy_dialplan_usage_context(ctx_node);
      return NULL;
   }
   strcpy(ctx_node->context, lot->cfg.parking_con);
   return ctx_node;
}

static int build_dialplan_useage_map	(	struct parking_dp_map *	usage_map,
		int	complain
	)			[static]

Definition at line 6686 of file features.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, dialplan_usage_add_parkinglot(), parkinglots, and status.

Referenced by load_config().

{
   int status = 0;
   struct ao2_iterator iter;
   struct ast_parkinglot *curlot;

   /* For all parking lots */
   iter = ao2_iterator_init(parkinglots, 0);
   for (; (curlot = ao2_iterator_next(&iter)); ao2_ref(curlot, -1)) {
      /* Add the parking lot to the map. */
      if (dialplan_usage_add_parkinglot(usage_map, curlot, complain)) {
         ao2_ref(curlot, -1);
         status = -1;
         break;
      }
   }
   ao2_iterator_destroy(&iter);

   return status;
}

static struct parking_dp_ramp* build_dialplan_useage_ramp	(	const char *	exten,
		int	exclusive
	)			[static, read]

Definition at line 6377 of file features.c.

References ast_calloc, parking_dp_ramp::exclusive, and parking_dp_ramp::exten.

Referenced by usage_context_add_ramp().

{
   struct parking_dp_ramp *ramp_node;

   ramp_node = ast_calloc(1, sizeof(*ramp_node) + strlen(exten));
   if (!ramp_node) {
      return NULL;
   }
   ramp_node->exclusive = exclusive;
   strcpy(ramp_node->exten, exten);
   return ramp_node;
}

static struct parking_dp_spaces* build_dialplan_useage_spaces	(	int	start,
		int	stop
	)			[static, read]

Definition at line 6458 of file features.c.

References ast_calloc, parking_dp_spaces::start, and parking_dp_spaces::stop.

Referenced by usage_context_add_spaces().

{
   struct parking_dp_spaces *spaces_node;

   spaces_node = ast_calloc(1, sizeof(*spaces_node));
   if (!spaces_node) {
      return NULL;
   }
   spaces_node->start = start;
   spaces_node->stop = stop;
   return spaces_node;
}

static struct ast_parkinglot* build_parkinglot	(	const char *	pl_name,
		struct ast_variable *	var
	)			[static, read]

Build parkinglot from configuration and chain it in if it doesn't already exist.

Definition at line 5982 of file features.c.

References ao2_link, ao2_lock, ao2_unlock, ast_debug, AST_LIST_EMPTY, ast_log(), ast_parkinglot::cfg, create_parkinglot(), DEFAULT_PARKINGLOT, find_parkinglot(), force_reload_load, LOG_WARNING, ast_parkinglot::name, parkinglot_config_read(), parkinglot_unref(), parkinglots, ast_parkinglot::parkings, and ast_parkinglot::the_mark.

Referenced by load_config(), and process_config().

{
   struct ast_parkinglot *parkinglot;
   const struct parkinglot_cfg *cfg_defaults;
   struct parkinglot_cfg new_cfg;
   int cfg_error;
   int oldparkinglot = 0;

   parkinglot = find_parkinglot(pl_name);
   if (parkinglot) {
      oldparkinglot = 1;
   } else {
      parkinglot = create_parkinglot(pl_name);
      if (!parkinglot) {
         return NULL;
      }
   }
   if (!strcmp(parkinglot->name, DEFAULT_PARKINGLOT)) {
      cfg_defaults = &parkinglot_cfg_default_default;
   } else {
      cfg_defaults = &parkinglot_cfg_default;
   }
   new_cfg = *cfg_defaults;

   ast_debug(1, "Building parking lot %s\n", parkinglot->name);

   ao2_lock(parkinglot);

   /* Do some config stuff */
   cfg_error = parkinglot_config_read(parkinglot->name, &new_cfg, var);
   if (oldparkinglot) {
      if (cfg_error) {
         /* Bad configuration read.  Keep using the original config. */
         ast_log(LOG_WARNING, "Changes to parking lot %s are discarded.\n",
            parkinglot->name);
         cfg_error = 0;
      } else if (!AST_LIST_EMPTY(&parkinglot->parkings)
         && memcmp(&new_cfg, &parkinglot->cfg, sizeof(parkinglot->cfg))) {
         /* Try reloading later when parking lot is empty. */
         ast_log(LOG_WARNING,
            "Parking lot %s has parked calls.  Parking lot changes discarded.\n",
            parkinglot->name);
         force_reload_load = 1;
      } else {
         /* Accept the new config */
         parkinglot->cfg = new_cfg;
      }
   } else {
      /* Load the initial parking lot config. */
      parkinglot->cfg = new_cfg;
   }
   parkinglot->the_mark = 0;

   ao2_unlock(parkinglot);

   if (cfg_error) {
      /* Only new parking lots could have config errors here. */
      ast_log(LOG_WARNING, "New parking lot %s is discarded.\n", parkinglot->name);
      parkinglot_unref(parkinglot);
      return NULL;
   }

   /* Move it into the list, if it wasn't already there */
   if (!oldparkinglot) {
      ao2_link(parkinglots, parkinglot);
   }
   parkinglot_unref(parkinglot);

   return parkinglot;
}

static int builtin_atxfer	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

Attended transfer.

Parameters:

	chan	transfered user
	peer	person transfering call
	config
	code
	sense	feature options
	data	Get extension to transfer to, if you cannot generate channel (or find extension) return to host channel. After called channel answered wait for hangup of transferer, bridge call between transfer peer (taking them off hold) to attended transfer channel.

Returns:

-1 on failure

Definition at line 2672 of file features.c.

References add_features_datastore(), ast_app_dtget(), ast_autoservice_chan_hangup_peer(), ast_autoservice_start(), ast_autoservice_stop(), ast_bridge_call(), ast_calloc, AST_CEL_ATTENDEDTRANSFER, ast_cel_report_event(), ast_channel_alloc, ast_channel_caller(), ast_channel_connected(), ast_channel_connected_line_macro(), ast_channel_connected_line_sub(), ast_channel_context(), ast_channel_datastore_find(), ast_channel_exten(), ast_channel_flags(), ast_channel_language(), ast_channel_linkedid(), ast_channel_lock, ast_channel_masquerade(), ast_channel_name(), ast_channel_nativeformats(), ast_channel_priority(), ast_channel_readformat(), ast_channel_state_set(), ast_channel_unlock, ast_channel_update_connected_line(), ast_channel_visible_indication_set(), ast_channel_writeformat(), ast_check_hangup(), ast_clear_flag, ast_connected_line_copy_from_caller(), AST_CONNECTED_LINE_UPDATE_SOURCE_TRANSFER, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_HOLD, AST_CONTROL_RINGING, AST_CONTROL_UNHOLD, ast_copy_flags, ast_debug, AST_DIGIT_ANY, ast_do_masquerade(), ast_explicit_goto(), AST_FEATURE_DISCONNECT, AST_FEATURE_RETURN_SUCCESS, AST_FLAG_BRIDGE_HANGUP_DONT, AST_FLAGS_ALL, ast_format_copy(), ast_hangup(), ast_indicate(), ast_log(), ast_party_connected_line_copy(), ast_party_connected_line_free(), ast_party_connected_line_init(), ast_safe_sleep(), ast_set_flag, AST_STATE_DOWN, AST_STATE_UP, ast_strdupa, ast_stream_and_wait(), ast_strlen_zero(), ast_test_flag, ast_waitfordigit(), atxfer_fail_cleanup(), atxfercallbackretries, atxferdropcall, atxferloopdelay, atxfernoanswertimeout, ast_bridge_thread_obj::bconfig, bridge_call_thread_launch(), ast_bridge_thread_obj::chan, check_compat(), ast_datastore::data, dial_features_info, ast_bridge_config::end_bridge_callback_data_fixup, feature_request_and_dial(), ast_bridge_config::features_callee, ast_bridge_config::features_caller, finishup(), get_parking_exten(), LOG_WARNING, ast_dial_features::my_features, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), ast_bridge_thread_obj::peer, ast_dial_features::peer_features, real_ctx(), set_peers(), ast_party_connected_line::source, strsep(), transferdigittimeout, xfer_park_call_helper(), xferfailsound, and xfersound.

{
   struct ast_channel *transferer;/* Party B */
   struct ast_channel *transferee;/* Party A */
   struct ast_exten *park_exten;
   const char *chan1_attended_sound;
   const char *chan2_attended_sound;
   const char *transferer_real_context;
   char xferto[256] = "";
   int res;
   int outstate=0;
   struct ast_channel *newchan;
   struct ast_channel *xferchan;
   struct ast_bridge_thread_obj *tobj;
   struct ast_bridge_config bconfig;
   int l;
   struct ast_party_connected_line connected_line;
   struct ast_datastore *features_datastore;
   struct ast_dial_features *dialfeatures;
   char *transferer_tech;
   char *transferer_name;
   char *transferer_name_orig;
   char *dash;

   ast_debug(1, "Executing Attended Transfer %s, %s (sense=%d) \n", ast_channel_name(chan), ast_channel_name(peer), sense);
   set_peers(&transferer, &transferee, peer, chan, sense);
   transferer_real_context = real_ctx(transferer, transferee);

   /* Start autoservice on transferee while we talk to the transferer */
   ast_autoservice_start(transferee);
   ast_indicate(transferee, AST_CONTROL_HOLD);

   /* Transfer */
   res = ast_stream_and_wait(transferer, "pbx-transfer", AST_DIGIT_ANY);
   if (res < 0) {
      finishup(transferee);
      return -1;
   }
   if (res > 0) { /* If they've typed a digit already, handle it */
      xferto[0] = (char) res;
   }

   /* this is specific of atxfer */
   res = ast_app_dtget(transferer, transferer_real_context, xferto, sizeof(xferto), 100, transferdigittimeout);
   if (res < 0) {  /* hangup or error, (would be 0 for invalid and 1 for valid) */
      finishup(transferee);
      return -1;
   }
   l = strlen(xferto);
   if (res == 0) {
      if (l) {
         ast_log(LOG_WARNING, "Extension '%s' does not exist in context '%s'\n",
            xferto, transferer_real_context);
      } else {
         /* Does anyone care about this case? */
         ast_log(LOG_WARNING, "No digits dialed for atxfer.\n");
      }
      ast_stream_and_wait(transferer, "pbx-invalid", "");
      finishup(transferee);
      return AST_FEATURE_RETURN_SUCCESS;
   }

   park_exten = get_parking_exten(xferto, transferer, transferer_real_context);
   if (park_exten) {
      /* We are transfering the transferee to a parking lot. */
      return xfer_park_call_helper(transferee, transferer, park_exten);
   }

   /*
    * Append context to dialed transfer number.
    *
    * NOTE: The local channel needs the /n flag so party C will use
    * the feature flags set by the dialplan when calling that
    * party.
    */
   snprintf(xferto + l, sizeof(xferto) - l, "@%s/n", transferer_real_context);

   /* If we are performing an attended transfer and we have two channels involved then
      copy sound file information to play upon attended transfer completion */
   chan1_attended_sound = pbx_builtin_getvar_helper(transferer, "ATTENDED_TRANSFER_COMPLETE_SOUND");
   chan2_attended_sound = pbx_builtin_getvar_helper(transferee, "ATTENDED_TRANSFER_COMPLETE_SOUND");
   if (!ast_strlen_zero(chan1_attended_sound)) {
      pbx_builtin_setvar_helper(transferer, "BRIDGE_PLAY_SOUND", chan1_attended_sound);
   }
   if (!ast_strlen_zero(chan2_attended_sound)) {
      pbx_builtin_setvar_helper(transferee, "BRIDGE_PLAY_SOUND", chan2_attended_sound);
   }

   /* Extract redial transferer information from the channel name. */
   transferer_name_orig = ast_strdupa(ast_channel_name(transferer));
   transferer_name = ast_strdupa(transferer_name_orig);
   transferer_tech = strsep(&transferer_name, "/");
   dash = strrchr(transferer_name, '-');
   if (dash) {
      /* Trim off channel name sequence/serial number. */
      *dash = '\0';
   }

   /* Stop autoservice so we can monitor all parties involved in the transfer. */
   if (ast_autoservice_stop(transferee) < 0) {
      ast_indicate(transferee, AST_CONTROL_UNHOLD);
      return -1;
   }

   /* Save connected line info for party B about party A in case transfer fails. */
   ast_party_connected_line_init(&connected_line);
   ast_channel_lock(transferer);
   ast_party_connected_line_copy(&connected_line, ast_channel_connected(transferer));
   ast_channel_unlock(transferer);
   connected_line.source = AST_CONNECTED_LINE_UPDATE_SOURCE_TRANSFER;

   /* Dial party C */
   newchan = feature_request_and_dial(transferer, transferer_name_orig, transferer,
      transferee, "Local", ast_channel_nativeformats(transferer), xferto,
      atxfernoanswertimeout, &outstate, ast_channel_language(transferer));
   ast_debug(2, "Dial party C result: newchan:%d, outstate:%d\n", !!newchan, outstate);

   if (!ast_check_hangup(transferer)) {
      int hangup_dont = 0;

      /* Transferer (party B) is up */
      ast_debug(1, "Actually doing an attended transfer.\n");

      /* Start autoservice on transferee while the transferer deals with party C. */
      ast_autoservice_start(transferee);

      ast_indicate(transferer, -1);
      if (!newchan) {
         /* any reason besides user requested cancel and busy triggers the failed sound */
         switch (outstate) {
         case AST_CONTROL_UNHOLD:/* Caller requested cancel or party C answer timeout. */
         case AST_CONTROL_BUSY:
         case AST_CONTROL_CONGESTION:
            if (ast_stream_and_wait(transferer, xfersound, "")) {
               ast_log(LOG_WARNING, "Failed to play transfer sound!\n");
            }
            break;
         default:
            if (ast_stream_and_wait(transferer, xferfailsound, "")) {
               ast_log(LOG_WARNING, "Failed to play transfer failed sound!\n");
            }
            break;
         }
         atxfer_fail_cleanup(transferee, transferer, &connected_line);
         return AST_FEATURE_RETURN_SUCCESS;
      }

      if (check_compat(transferer, newchan)) {
         if (ast_stream_and_wait(transferer, xferfailsound, "")) {
            ast_log(LOG_WARNING, "Failed to play transfer failed sound!\n");
         }
         atxfer_fail_cleanup(transferee, transferer, &connected_line);
         return AST_FEATURE_RETURN_SUCCESS;
      }
      memset(&bconfig,0,sizeof(struct ast_bridge_config));
      ast_set_flag(&(bconfig.features_caller), AST_FEATURE_DISCONNECT);
      ast_set_flag(&(bconfig.features_callee), AST_FEATURE_DISCONNECT);

      /*
       * ast_bridge_call clears AST_FLAG_BRIDGE_HANGUP_DONT, but we
       * don't want that to happen here because the transferer is in
       * another bridge already.
       */
      if (ast_test_flag(ast_channel_flags(transferer), AST_FLAG_BRIDGE_HANGUP_DONT)) {
         hangup_dont = 1;
      }

      /*
       * Don't let the after-bridge code run the h-exten.  It is the
       * wrong bridge to run the h-exten after.
       */
      ast_set_flag(ast_channel_flags(transferer), AST_FLAG_BRIDGE_HANGUP_DONT);

      /*
       * Let party B and C talk as long as they want while party A
       * languishes in autoservice listening to MOH.
       */
      ast_bridge_call(transferer, newchan, &bconfig);

      if (hangup_dont) {
         /* Restore the AST_FLAG_BRIDGE_HANGUP_DONT flag */
         ast_set_flag(ast_channel_flags(transferer), AST_FLAG_BRIDGE_HANGUP_DONT);
      }

      if (ast_check_hangup(newchan) || !ast_check_hangup(transferer)) {
         ast_autoservice_chan_hangup_peer(transferer, newchan);
         if (ast_stream_and_wait(transferer, xfersound, "")) {
            ast_log(LOG_WARNING, "Failed to play transfer sound!\n");
         }
         atxfer_fail_cleanup(transferee, transferer, &connected_line);
         return AST_FEATURE_RETURN_SUCCESS;
      }

      /* Transferer (party B) is confirmed hung up at this point. */
      if (check_compat(transferee, newchan)) {
         finishup(transferee);
         ast_party_connected_line_free(&connected_line);
         return -1;
      }

      ast_indicate(transferee, AST_CONTROL_UNHOLD);
      if ((ast_autoservice_stop(transferee) < 0)
         || (ast_waitfordigit(transferee, 100) < 0)
         || (ast_waitfordigit(newchan, 100) < 0)
         || ast_check_hangup(transferee)
         || ast_check_hangup(newchan)) {
         ast_hangup(newchan);
         ast_party_connected_line_free(&connected_line);
         return -1;
      }
   } else if (!ast_check_hangup(transferee)) {
      /* Transferer (party B) has hung up at this point.  Doing blonde transfer. */
      ast_debug(1, "Actually doing a blonde transfer.\n");

      if (!newchan && !atxferdropcall) {
         /* Party C is not available, try to call party B back. */
         unsigned int tries = 0;

         if (ast_strlen_zero(transferer_name) || ast_strlen_zero(transferer_tech)) {
            ast_log(LOG_WARNING,
               "Transferer channel name: '%s' cannot be used for callback.\n",
               transferer_name_orig);
            ast_indicate(transferee, AST_CONTROL_UNHOLD);
            ast_party_connected_line_free(&connected_line);
            return -1;
         }

         tries = 0;
         for (;;) {
            /* Try to get party B back. */
            ast_debug(1, "We're trying to callback %s/%s\n",
               transferer_tech, transferer_name);
            newchan = feature_request_and_dial(transferer, transferer_name_orig,
               transferee, transferee, transferer_tech,
               ast_channel_nativeformats(transferee), transferer_name,
               atxfernoanswertimeout, &outstate, ast_channel_language(transferer));
            ast_debug(2, "Dial party B result: newchan:%d, outstate:%d\n",
               !!newchan, outstate);
            if (newchan) {
               /*
                * We have recalled party B (newchan).  We need to give this
                * call leg the same feature flags as the original party B call
                * leg.
                */
               ast_channel_lock(transferer);
               features_datastore = ast_channel_datastore_find(transferer,
                  &dial_features_info, NULL);
               if (features_datastore && (dialfeatures = features_datastore->data)) {
                  struct ast_flags my_features = { 0 };
                  struct ast_flags peer_features = { 0 };

                  ast_copy_flags(&my_features, &dialfeatures->my_features,
                     AST_FLAGS_ALL);
                  ast_copy_flags(&peer_features, &dialfeatures->peer_features,
                     AST_FLAGS_ALL);
                  ast_channel_unlock(transferer);
                  add_features_datastore(newchan, &my_features, &peer_features);
               } else {
                  ast_channel_unlock(transferer);
               }
               break;
            }
            if (ast_check_hangup(transferee)) {
               break;
            }

            ++tries;
            if (atxfercallbackretries <= tries) {
               /* No more callback tries remaining. */
               break;
            }

            if (atxferloopdelay) {
               /* Transfer failed, sleeping */
               ast_debug(1, "Sleeping for %d ms before retrying atxfer.\n",
                  atxferloopdelay);
               ast_safe_sleep(transferee, atxferloopdelay);
               if (ast_check_hangup(transferee)) {
                  ast_party_connected_line_free(&connected_line);
                  return -1;
               }
            }

            /* Retry dialing party C. */
            ast_debug(1, "We're retrying to call %s/%s\n", "Local", xferto);
            newchan = feature_request_and_dial(transferer, transferer_name_orig,
               transferer, transferee, "Local",
               ast_channel_nativeformats(transferee), xferto,
               atxfernoanswertimeout, &outstate, ast_channel_language(transferer));
            ast_debug(2, "Redial party C result: newchan:%d, outstate:%d\n",
               !!newchan, outstate);
            if (newchan || ast_check_hangup(transferee)) {
               break;
            }
         }
      }
      ast_indicate(transferee, AST_CONTROL_UNHOLD);
      if (!newchan) {
         /* No party C or could not callback party B. */
         ast_party_connected_line_free(&connected_line);
         return -1;
      }

      /* newchan is up, we should prepare transferee and bridge them */
      if (ast_check_hangup(newchan)) {
         ast_autoservice_chan_hangup_peer(transferee, newchan);
         ast_party_connected_line_free(&connected_line);
         return -1;
      }
      if (check_compat(transferee, newchan)) {
         ast_party_connected_line_free(&connected_line);
         return -1;
      }
   } else {
      /*
       * Both the transferer and transferee have hungup.  If newchan
       * is up, hang it up as it has no one to talk to.
       */
      ast_debug(1, "Everyone is hungup.\n");
      if (newchan) {
         ast_hangup(newchan);
      }
      ast_party_connected_line_free(&connected_line);
      return -1;
   }

   /* Initiate the channel transfer of party A to party C (or recalled party B). */
   ast_cel_report_event(transferee, AST_CEL_ATTENDEDTRANSFER, NULL, NULL, newchan);

   xferchan = ast_channel_alloc(0, AST_STATE_DOWN, 0, 0, "", "", "", ast_channel_linkedid(transferee), 0, "Transfered/%s", ast_channel_name(transferee));
   if (!xferchan) {
      ast_autoservice_chan_hangup_peer(transferee, newchan);
      ast_party_connected_line_free(&connected_line);
      return -1;
   }

   /* Give party A a momentary ringback tone during transfer. */
   ast_channel_visible_indication_set(xferchan, AST_CONTROL_RINGING);

   /* Make formats okay */
   ast_format_copy(ast_channel_readformat(xferchan), ast_channel_readformat(transferee));
   ast_format_copy(ast_channel_writeformat(xferchan), ast_channel_writeformat(transferee));

   if (ast_channel_masquerade(xferchan, transferee)) {
      ast_hangup(xferchan);
      ast_autoservice_chan_hangup_peer(transferee, newchan);
      ast_party_connected_line_free(&connected_line);
      return -1;
   }
   ast_explicit_goto(xferchan, ast_channel_context(transferee), ast_channel_exten(transferee), ast_channel_priority(transferee));
   ast_channel_state_set(xferchan, AST_STATE_UP);
   ast_clear_flag(ast_channel_flags(xferchan), AST_FLAGS_ALL);

   /* Do the masquerade manually to make sure that is is completed. */
   ast_do_masquerade(xferchan);

   ast_channel_state_set(newchan, AST_STATE_UP);
   ast_clear_flag(ast_channel_flags(newchan), AST_FLAGS_ALL);
   tobj = ast_calloc(1, sizeof(*tobj));
   if (!tobj) {
      ast_hangup(xferchan);
      ast_hangup(newchan);
      ast_party_connected_line_free(&connected_line);
      return -1;
   }

   tobj->chan = newchan;
   tobj->peer = xferchan;
   tobj->bconfig = *config;

   ast_channel_lock(newchan);
   features_datastore = ast_channel_datastore_find(newchan, &dial_features_info, NULL);
   if (features_datastore && (dialfeatures = features_datastore->data)) {
      ast_copy_flags(&tobj->bconfig.features_callee, &dialfeatures->my_features,
         AST_FLAGS_ALL);
   }
   ast_channel_unlock(newchan);

   ast_channel_lock(xferchan);
   features_datastore = ast_channel_datastore_find(xferchan, &dial_features_info, NULL);
   if (features_datastore && (dialfeatures = features_datastore->data)) {
      ast_copy_flags(&tobj->bconfig.features_caller, &dialfeatures->my_features,
         AST_FLAGS_ALL);
   }
   ast_channel_unlock(xferchan);

   if (tobj->bconfig.end_bridge_callback_data_fixup) {
      tobj->bconfig.end_bridge_callback_data_fixup(&tobj->bconfig, tobj->peer, tobj->chan);
   }

   /*
    * xferchan is transferee, and newchan is the transfer target
    * So...in a transfer, who is the caller and who is the callee?
    *
    * When the call is originally made, it is clear who is caller and callee.
    * When a transfer occurs, it is my humble opinion that the transferee becomes
    * the caller, and the transfer target is the callee.
    *
    * The problem is that these macros were set with the intention of the original
    * caller and callee taking those roles.  A transfer can totally mess things up,
    * to be technical.  What sucks even more is that you can't effectively change
    * the macros in the dialplan during the call from the transferer to the transfer
    * target because the transferee is stuck with whatever role he originally had.
    *
    * I think the answer here is just to make sure that it is well documented that
    * during a transfer, the transferee is the "caller" and the transfer target
    * is the "callee."
    *
    * This means that if party B calls party A, and party B transfers party A to
    * party C, then A has switched roles for the call.  Now party A will have the
    * caller macro called on his channel instead of the callee macro.
    *
    * Luckily, the method by which the party B to party C bridge is
    * launched above ensures that the transferee is the "chan" on
    * the bridge and the transfer target is the "peer," so my idea
    * for the roles post-transfer does not require extensive code
    * changes.
    */

   /* Transfer party C connected line to party A */
   ast_channel_lock(transferer);
   /*
    * Due to a limitation regarding when callerID is set on a Local channel,
    * we use the transferer's connected line information here.
    */
   ast_party_connected_line_copy(&connected_line, ast_channel_connected(transferer));
   ast_channel_unlock(transferer);
   connected_line.source = AST_CONNECTED_LINE_UPDATE_SOURCE_TRANSFER;
   if (ast_channel_connected_line_sub(newchan, xferchan, &connected_line, 0) &&
      ast_channel_connected_line_macro(newchan, xferchan, &connected_line, 1, 0)) {
      ast_channel_update_connected_line(xferchan, &connected_line, NULL);
   }

   /* Transfer party A connected line to party C */
   ast_channel_lock(xferchan);
   ast_connected_line_copy_from_caller(&connected_line, ast_channel_caller(xferchan));
   ast_channel_unlock(xferchan);
   connected_line.source = AST_CONNECTED_LINE_UPDATE_SOURCE_TRANSFER;
   if (ast_channel_connected_line_sub(xferchan, newchan, &connected_line, 0) &&
      ast_channel_connected_line_macro(xferchan, newchan, &connected_line, 0, 0)) {
      ast_channel_update_connected_line(newchan, &connected_line, NULL);
   }

   if (ast_stream_and_wait(newchan, xfersound, ""))
      ast_log(LOG_WARNING, "Failed to play transfer sound!\n");
   bridge_call_thread_launch(tobj);

   ast_party_connected_line_free(&connected_line);
   return -1;/* The transferee is masqueraded and the original bridged channels can be hungup. */
}

static int builtin_automixmonitor	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

Definition at line 2357 of file features.c.

References args, ast_alloca, AST_AUDIOHOOK_TYPE_SPY, ast_autoservice_ignore(), ast_autoservice_start(), ast_autoservice_stop(), ast_channel_audiohook_count_by_source(), ast_channel_audiohook_count_by_source_running(), ast_channel_caller(), ast_channel_lock, ast_channel_name(), ast_channel_unlock, AST_FEATURE_RETURN_SUCCESS, AST_FRAME_DTMF_END, ast_log(), ast_strdupa, ast_stream_and_wait(), ast_strlen_zero(), ast_verb, courtesytone, LOG_ERROR, LOG_WARNING, mixmonitor_app, mixmonitor_ok, mixmonitor_spy_type, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_exec(), pbx_findapp(), S_COR, S_OR, set_peers(), stopmixmonitor_app, and stopmixmonitor_ok.

{
   char *caller_chan_id = NULL, *callee_chan_id = NULL, *args = NULL, *touch_filename = NULL;
   int x = 0;
   size_t len;
   struct ast_channel *caller_chan, *callee_chan;
   const char *mixmonitor_spy_type = "MixMonitor";
   const char *touch_format;
   const char *touch_monitor;
   int count = 0;

   if (!mixmonitor_ok) {
      ast_log(LOG_ERROR,"Cannot record the call. The mixmonitor application is disabled.\n");
      return -1;
   }

   if (!(mixmonitor_app = pbx_findapp("MixMonitor"))) {
      mixmonitor_ok = 0;
      ast_log(LOG_ERROR,"Cannot record the call. The mixmonitor application is disabled.\n");
      return -1;
   }

   set_peers(&caller_chan, &callee_chan, peer, chan, sense);

   if (!ast_strlen_zero(courtesytone)) {
      if (ast_autoservice_start(callee_chan))
         return -1;
      ast_autoservice_ignore(callee_chan, AST_FRAME_DTMF_END);
      if (ast_stream_and_wait(caller_chan, courtesytone, "")) {
         ast_log(LOG_WARNING, "Failed to play courtesy tone!\n");
         ast_autoservice_stop(callee_chan);
         return -1;
      }
      if (ast_autoservice_stop(callee_chan))
         return -1;
   }

   ast_channel_lock(callee_chan);
   count = ast_channel_audiohook_count_by_source(callee_chan, mixmonitor_spy_type, AST_AUDIOHOOK_TYPE_SPY);
   ast_channel_unlock(callee_chan);

   /* This means a mixmonitor is attached to the channel, running or not is unknown. */
   if (count > 0) {
      ast_verb(3, "User hit '%s' to stop recording call.\n", code);

      /* Make sure they are running */
      ast_channel_lock(callee_chan);
      count = ast_channel_audiohook_count_by_source_running(callee_chan, mixmonitor_spy_type, AST_AUDIOHOOK_TYPE_SPY);
      ast_channel_unlock(callee_chan);
      if (count > 0) {
         if (!stopmixmonitor_ok) {
            ast_log(LOG_ERROR,"Cannot stop recording the call. The stopmixmonitor application is disabled.\n");
            return -1;
         }
         if (!(stopmixmonitor_app = pbx_findapp("StopMixMonitor"))) {
            stopmixmonitor_ok = 0;
            ast_log(LOG_ERROR,"Cannot stop recording the call. The stopmixmonitor application is disabled.\n");
            return -1;
         } else {
            pbx_exec(callee_chan, stopmixmonitor_app, "");
            return AST_FEATURE_RETURN_SUCCESS;
         }
      }

      ast_log(LOG_WARNING,"Stopped MixMonitors are attached to the channel.\n");
   }

   touch_format = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MIXMONITOR_FORMAT");
   touch_monitor = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MIXMONITOR");

   if (!touch_format)
      touch_format = pbx_builtin_getvar_helper(callee_chan, "TOUCH_MIXMONITOR_FORMAT");

   if (!touch_monitor)
      touch_monitor = pbx_builtin_getvar_helper(callee_chan, "TOUCH_MIXMONITOR");

   if (touch_monitor) {
      len = strlen(touch_monitor) + 50;
      args = ast_alloca(len);
      touch_filename = ast_alloca(len);
      snprintf(touch_filename, len, "auto-%ld-%s", (long)time(NULL), touch_monitor);
      snprintf(args, len, "%s.%s,b", touch_filename, (touch_format) ? touch_format : "wav");
   } else {
      caller_chan_id = ast_strdupa(S_COR(ast_channel_caller(caller_chan)->id.number.valid,
         ast_channel_caller(caller_chan)->id.number.str, ast_channel_name(caller_chan)));
      callee_chan_id = ast_strdupa(S_COR(ast_channel_caller(callee_chan)->id.number.valid,
         ast_channel_caller(callee_chan)->id.number.str, ast_channel_name(callee_chan)));
      len = strlen(caller_chan_id) + strlen(callee_chan_id) + 50;
      args = ast_alloca(len);
      touch_filename = ast_alloca(len);
      snprintf(touch_filename, len, "auto-%ld-%s-%s", (long)time(NULL), caller_chan_id, callee_chan_id);
      snprintf(args, len, "%s.%s,b", touch_filename, S_OR(touch_format, "wav"));
   }

   for( x = 0; x < strlen(args); x++) {
      if (args[x] == '/')
         args[x] = '-';
   }

   ast_verb(3, "User hit '%s' to record call. filename: %s\n", code, touch_filename);

   pbx_exec(callee_chan, mixmonitor_app, args);
   pbx_builtin_setvar_helper(callee_chan, "TOUCH_MIXMONITOR_OUTPUT", touch_filename);
   pbx_builtin_setvar_helper(caller_chan, "TOUCH_MIXMONITOR_OUTPUT", touch_filename);
   return AST_FEATURE_RETURN_SUCCESS;
}

static int builtin_automonitor	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

Monitor a channel by DTMF.

Parameters:

	chan	channel requesting monitor
	peer	channel to be monitored
	config
	code
	sense	feature options
	data	Check monitor app enabled, setup channels, both caller/callee chans not null get TOUCH_MONITOR variable for filename if exists, exec monitor app.

Return values:

	AST_FEATURE_RETURN_SUCCESS	on success.
	-1	on error.

Definition at line 2264 of file features.c.

References args, ast_alloca, ast_channel_caller(), ast_channel_monitor(), ast_channel_name(), AST_FEATURE_RETURN_SUCCESS, ast_log(), ast_strdupa, ast_strlen_zero(), ast_verb, courtesytone, LOG_ERROR, monitor_app, monitor_ok, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_exec(), pbx_findapp(), play_message_in_bridged_call(), S_COR, S_OR, set_peers(), and ast_channel_monitor::stop.

{
   char *caller_chan_id = NULL, *callee_chan_id = NULL, *args = NULL, *touch_filename = NULL;
   int x = 0;
   size_t len;
   struct ast_channel *caller_chan, *callee_chan;
   const char *automon_message_start = NULL;
   const char *automon_message_stop = NULL;
   const char *touch_format = NULL;
   const char *touch_monitor = NULL;
   const char *touch_monitor_prefix = NULL;

   if (!monitor_ok) {
      ast_log(LOG_ERROR,"Cannot record the call. The monitor application is disabled.\n");
      return -1;
   }

   if (!monitor_app && !(monitor_app = pbx_findapp("Monitor"))) {
      monitor_ok = 0;
      ast_log(LOG_ERROR,"Cannot record the call. The monitor application is disabled.\n");
      return -1;
   }

   set_peers(&caller_chan, &callee_chan, peer, chan, sense);

   /* Find extra messages */
   automon_message_start = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MONITOR_MESSAGE_START");
   automon_message_stop = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MONITOR_MESSAGE_STOP");

   if (!ast_strlen_zero(courtesytone)) {  /* Play courtesy tone if configured */
      if(play_message_in_bridged_call(caller_chan, callee_chan, courtesytone) == -1) {
         return -1;
      }
   }

   if (ast_channel_monitor(callee_chan)) {
      ast_verb(4, "User hit '%s' to stop recording call.\n", code);
      if (!ast_strlen_zero(automon_message_stop)) {
         play_message_in_bridged_call(caller_chan, callee_chan, automon_message_stop);
      }
      ast_channel_monitor(callee_chan)->stop(callee_chan, 1);
      return AST_FEATURE_RETURN_SUCCESS;
   }

   touch_format = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MONITOR_FORMAT");
   touch_monitor = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MONITOR");
   touch_monitor_prefix = pbx_builtin_getvar_helper(caller_chan, "TOUCH_MONITOR_PREFIX");

   if (!touch_format)
      touch_format = pbx_builtin_getvar_helper(callee_chan, "TOUCH_MONITOR_FORMAT");

   if (!touch_monitor)
      touch_monitor = pbx_builtin_getvar_helper(callee_chan, "TOUCH_MONITOR");

   if (!touch_monitor_prefix)
      touch_monitor_prefix = pbx_builtin_getvar_helper(callee_chan, "TOUCH_MONITOR_PREFIX");

   if (touch_monitor) {
      len = strlen(touch_monitor) + 50;
      args = ast_alloca(len);
      touch_filename = ast_alloca(len);
      snprintf(touch_filename, len, "%s-%ld-%s", S_OR(touch_monitor_prefix, "auto"), (long)time(NULL), touch_monitor);
      snprintf(args, len, "%s,%s,m", S_OR(touch_format, "wav"), touch_filename);
   } else {
      caller_chan_id = ast_strdupa(S_COR(ast_channel_caller(caller_chan)->id.number.valid,
         ast_channel_caller(caller_chan)->id.number.str, ast_channel_name(caller_chan)));
      callee_chan_id = ast_strdupa(S_COR(ast_channel_caller(callee_chan)->id.number.valid,
         ast_channel_caller(callee_chan)->id.number.str, ast_channel_name(callee_chan)));
      len = strlen(caller_chan_id) + strlen(callee_chan_id) + 50;
      args = ast_alloca(len);
      touch_filename = ast_alloca(len);
      snprintf(touch_filename, len, "%s-%ld-%s-%s", S_OR(touch_monitor_prefix, "auto"), (long)time(NULL), caller_chan_id, callee_chan_id);
      snprintf(args, len, "%s,%s,m", S_OR(touch_format, "wav"), touch_filename);
   }

   for(x = 0; x < strlen(args); x++) {
      if (args[x] == '/')
         args[x] = '-';
   }

   ast_verb(4, "User hit '%s' to record call. filename: %s\n", code, args);

   pbx_exec(callee_chan, monitor_app, args);
   pbx_builtin_setvar_helper(callee_chan, "TOUCH_MONITOR_OUTPUT", touch_filename);
   pbx_builtin_setvar_helper(caller_chan, "TOUCH_MONITOR_OUTPUT", touch_filename);

   if (!ast_strlen_zero(automon_message_start)) {  /* Play start message for both channels */
      play_message_in_bridged_call(caller_chan, callee_chan, automon_message_start);
   }

   return AST_FEATURE_RETURN_SUCCESS;
}

static int builtin_blindtransfer	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

Blind transfer user to another extension.

Parameters:

	chan	channel to be transfered
	peer	channel initiated blind transfer
	config
	code
	data
	sense	feature options

Place chan on hold, check if transferred to parkinglot extension, otherwise check extension exists and transfer caller.

Return values:

	AST_FEATURE_RETURN_SUCCESS.
	-1	on failure.

Definition at line 2507 of file features.c.

References ast_app_dtget(), ast_async_goto(), ast_autoservice_start(), ast_cdr_alloc(), ast_cdr_init(), ast_cdr_start(), AST_CEL_BLINDTRANSFER, ast_cel_report_event(), ast_channel_cdr(), ast_channel_cdr_set(), ast_channel_flags(), ast_channel_lock, ast_channel_name(), ast_channel_pbx(), ast_channel_unlock, AST_CONTROL_HOLD, ast_debug, AST_DIGIT_ANY, AST_FEATURE_RETURN_SUCCESS, AST_FEATURE_RETURN_SUCCESSBREAK, AST_FLAG_BRIDGE_HANGUP_DONT, ast_indicate(), ast_log(), ast_set_flag, ast_strdupa, ast_stream_and_wait(), ast_verb, ast_cdr::channel, check_goto_on_transfer(), ast_cdr::dstchannel, finishup(), get_parking_exten(), ast_cdr::lastapp, ast_cdr::lastdata, LOG_WARNING, pbx_builtin_setvar_helper(), real_ctx(), set_peers(), transferdigittimeout, and xfer_park_call_helper().

{
   struct ast_channel *transferer;
   struct ast_channel *transferee;
   struct ast_exten *park_exten;
   const char *transferer_real_context;
   char xferto[256] = "";
   int res;

   ast_debug(1, "Executing Blind Transfer %s, %s (sense=%d) \n", ast_channel_name(chan), ast_channel_name(peer), sense);
   set_peers(&transferer, &transferee, peer, chan, sense);
   transferer_real_context = ast_strdupa(real_ctx(transferer, transferee));

   /* Start autoservice on transferee while we talk to the transferer */
   ast_autoservice_start(transferee);
   ast_indicate(transferee, AST_CONTROL_HOLD);

   /* Transfer */
   res = ast_stream_and_wait(transferer, "pbx-transfer", AST_DIGIT_ANY);
   if (res < 0) {
      finishup(transferee);
      return -1; /* error ? */
   }
   if (res > 0) { /* If they've typed a digit already, handle it */
      xferto[0] = (char) res;
   }

   res = ast_app_dtget(transferer, transferer_real_context, xferto, sizeof(xferto), 100, transferdigittimeout);
   if (res < 0) {  /* hangup or error, (would be 0 for invalid and 1 for valid) */
      finishup(transferee);
      return -1;
   }
   if (res == 0) {
      if (xferto[0]) {
         ast_log(LOG_WARNING, "Extension '%s' does not exist in context '%s'\n",
            xferto, transferer_real_context);
      } else {
         /* Does anyone care about this case? */
         ast_log(LOG_WARNING, "No digits dialed.\n");
      }
      ast_stream_and_wait(transferer, "pbx-invalid", "");
      finishup(transferee);
      return AST_FEATURE_RETURN_SUCCESS;
   }

   park_exten = get_parking_exten(xferto, transferer, transferer_real_context);
   if (park_exten) {
      /* We are transfering the transferee to a parking lot. */
      return xfer_park_call_helper(transferee, transferer, park_exten);
   }

   /* Do blind transfer. */
   ast_verb(3, "Blind transferring %s to '%s' (context %s) priority 1\n",
      ast_channel_name(transferee), xferto, transferer_real_context);
   ast_cel_report_event(transferer, AST_CEL_BLINDTRANSFER, NULL, xferto, transferee);
   pbx_builtin_setvar_helper(transferer, "BLINDTRANSFER", ast_channel_name(transferee));
   pbx_builtin_setvar_helper(transferee, "BLINDTRANSFER", ast_channel_name(transferer));
   finishup(transferee);
   ast_channel_lock(transferer);
   if (!ast_channel_cdr(transferer)) {
      /* this code should never get called (in a perfect world) */
      ast_channel_cdr_set(transferer, ast_cdr_alloc());
      if (ast_channel_cdr(transferer)) {
         ast_cdr_init(ast_channel_cdr(transferer), transferer); /* initialize our channel's cdr */
         ast_cdr_start(ast_channel_cdr(transferer));
      }
   }
   ast_channel_unlock(transferer);
   if (ast_channel_cdr(transferer)) {
      struct ast_cdr *swap = ast_channel_cdr(transferer);

      ast_debug(1,
         "transferer=%s; transferee=%s; lastapp=%s; lastdata=%s; chan=%s; dstchan=%s\n",
         ast_channel_name(transferer), ast_channel_name(transferee), ast_channel_cdr(transferer)->lastapp,
         ast_channel_cdr(transferer)->lastdata, ast_channel_cdr(transferer)->channel,
         ast_channel_cdr(transferer)->dstchannel);
      ast_debug(1, "TRANSFEREE; lastapp=%s; lastdata=%s, chan=%s; dstchan=%s\n",
         ast_channel_cdr(transferee)->lastapp, ast_channel_cdr(transferee)->lastdata, ast_channel_cdr(transferee)->channel,
         ast_channel_cdr(transferee)->dstchannel);
      ast_debug(1, "transferer_real_context=%s; xferto=%s\n",
         transferer_real_context, xferto);
      /* swap cdrs-- it will save us some time & work */
      ast_channel_cdr_set(transferer, ast_channel_cdr(transferee));
      ast_channel_cdr_set(transferee, swap);
   }

   res = ast_channel_pbx(transferee) ? AST_FEATURE_RETURN_SUCCESSBREAK : -1;

   /* Doh!  Use our handy async_goto functions */
   if (ast_async_goto(transferee, transferer_real_context, xferto, 1)) {
      ast_log(LOG_WARNING, "Async goto failed :-(\n");
      res = -1;
   } else if (res == AST_FEATURE_RETURN_SUCCESSBREAK) {
      /* Don't let the after-bridge code run the h-exten */
      ast_channel_lock(transferee);
      ast_set_flag(ast_channel_flags(transferee), AST_FLAG_BRIDGE_HANGUP_DONT);
      ast_channel_unlock(transferee);
   }
   check_goto_on_transfer(transferer);
   return res;
}

static int builtin_disconnect	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

Definition at line 2464 of file features.c.

References AST_FEATURE_RETURN_HANGUP, and ast_verb.

{
   ast_verb(4, "User hit '%s' to disconnect call.\n", code);
   return AST_FEATURE_RETURN_HANGUP;
}

static int builtin_feature_get_exten	(	struct ast_channel *	chan,
		const char *	feature_name,
		char *	buf,
		size_t	len
	)			[static]

Definition at line 3423 of file features.c.

References ao2_find, ao2_lock, ao2_ref, ao2_unlock, ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_find_call_feature(), ast_rdlock_call_features(), ast_unlock_call_features(), feature_exten::exten, ast_call_feature::exten, feature_ds::feature_map, get_feature_ds(), and OBJ_KEY.

Referenced by feature_interpret_helper(), and featuremap_read().

{
   struct ast_call_feature *feature;
   struct feature_ds *feature_ds;
   struct feature_exten *fe = NULL;

   *buf = '\0';

   if (!(feature = ast_find_call_feature(feature_name))) {
      return -1;
   }

   ast_copy_string(buf, feature->exten, len);

   ast_unlock_call_features();

   ast_channel_lock(chan);
   if ((feature_ds = get_feature_ds(chan))) {
      fe = ao2_find(feature_ds->feature_map, feature_name, OBJ_KEY);
   }
   ast_channel_unlock(chan);

   ast_rdlock_call_features();

   if (fe) {
      ao2_lock(fe);
      ast_copy_string(buf, fe->exten, len);
      ao2_unlock(fe);
      ao2_ref(fe, -1);
      fe = NULL;
   }

   return 0;
}

static int builtin_parkcall	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

support routing for one touch call parking

Parameters:

	chan	channel parking call
	peer	channel to be parked
	config	unsed
	code	unused
	sense	feature options
	data	unused

Return values:

	-1	on successful park.
	-1	on chan hangup.
	AST_FEATURE_RETURN_SUCCESS	on error to keep the bridge connected.

Definition at line 2142 of file features.c.

References ast_answer(), AST_FEATURE_RETURN_SUCCESS, ast_safe_sleep(), AST_STATE_UP, masq_park_call(), and set_peers().

{
   struct ast_channel *parker;
   struct ast_channel *parkee;
   struct ast_park_call_args args = { 0, };

   /*
    * We used to set chan's exten and priority to "s" and 1 here,
    * but this generates (in some cases) an invalid extension, and
    * if "s" exists, could errantly cause execution of extensions
    * you don't expect.  It makes more sense to let nature take its
    * course when chan finishes, and let the pbx do its thing and
    * hang up when the park is over.
    */

   /* Answer if call is not up */
   if (ast_channel_state(chan) != AST_STATE_UP) {
      /*
       * XXX Why are we doing this?  Both of the channels should be up
       * since you cannot do DTMF features unless you are bridged.
       */
      if (ast_answer(chan)) {
         return -1;
      }

      /* Sleep to allow VoIP streams to settle down */
      if (ast_safe_sleep(chan, 1000)) {
         return -1;
      }
   }

   /* one direction used to call park_call.... */
   set_peers(&parker, &parkee, peer, chan, sense);
   return masq_park_call(parkee, parker, &args) ? AST_FEATURE_RETURN_SUCCESS : -1;
}

static char* callback_dialoptions	(	struct ast_flags *	features_callee,
		struct ast_flags *	features_caller,
		char *	options,
		size_t	len
	)			[static]

Definition at line 4910 of file features.c.

References AST_FEATURE_AUTOMON, AST_FEATURE_DISCONNECT, AST_FEATURE_PARKCALL, AST_FEATURE_REDIRECT, ast_test_flag, OPT_CALLEE_AUTOMON, and OPT_CALLER_AUTOMON.

Referenced by manage_parked_call().

{
   int i = 0;
   enum {
      OPT_CALLEE_REDIRECT   = 't',
      OPT_CALLER_REDIRECT   = 'T',
      OPT_CALLEE_AUTOMON    = 'w',
      OPT_CALLER_AUTOMON    = 'W',
      OPT_CALLEE_DISCONNECT = 'h',
      OPT_CALLER_DISCONNECT = 'H',
      OPT_CALLEE_PARKCALL   = 'k',
      OPT_CALLER_PARKCALL   = 'K',
   };

   memset(options, 0, len);
   if (ast_test_flag(features_caller, AST_FEATURE_REDIRECT) && i < len) {
      options[i++] = OPT_CALLER_REDIRECT;
   }
   if (ast_test_flag(features_caller, AST_FEATURE_AUTOMON) && i < len) {
      options[i++] = OPT_CALLER_AUTOMON;
   }
   if (ast_test_flag(features_caller, AST_FEATURE_DISCONNECT) && i < len) {
      options[i++] = OPT_CALLER_DISCONNECT;
   }
   if (ast_test_flag(features_caller, AST_FEATURE_PARKCALL) && i < len) {
      options[i++] = OPT_CALLER_PARKCALL;
   }

   if (ast_test_flag(features_callee, AST_FEATURE_REDIRECT) && i < len) {
      options[i++] = OPT_CALLEE_REDIRECT;
   }
   if (ast_test_flag(features_callee, AST_FEATURE_AUTOMON) && i < len) {
      options[i++] = OPT_CALLEE_AUTOMON;
   }
   if (ast_test_flag(features_callee, AST_FEATURE_DISCONNECT) && i < len) {
      options[i++] = OPT_CALLEE_DISCONNECT;
   }
   if (ast_test_flag(features_callee, AST_FEATURE_PARKCALL) && i < len) {
      options[i++] = OPT_CALLEE_PARKCALL;
   }

   return options;
}

static int check_compat	(	struct ast_channel *	c,
		struct ast_channel *	newchan
	)			[static]

make channels compatible

Parameters:

	c
	newchan

Return values:

	0	on success.
	-1	on failure.

Definition at line 2616 of file features.c.

References ast_autoservice_chan_hangup_peer(), ast_channel_make_compatible(), ast_channel_name(), ast_log(), and LOG_WARNING.

Referenced by builtin_atxfer().

{
   if (ast_channel_make_compatible(c, newchan) < 0) {
      ast_log(LOG_WARNING, "Had to drop call because I couldn't make %s compatible with %s\n",
         ast_channel_name(c), ast_channel_name(newchan));
      ast_autoservice_chan_hangup_peer(c, newchan);
      return -1;
   }
   return 0;
}

static void check_goto_on_transfer

(

struct ast_channel *

chan

)

[static]

Check goto on transfer.

Parameters:

chan

Check if channel has 'GOTO_ON_BLINDXFR' set, if not exit. When found make sure the types are compatible. Check if channel is valid if so start the new channel else hangup the call.

Definition at line 1034 of file features.c.

References ast_channel_alloc, ast_channel_clear_softhangup(), ast_channel_flags(), ast_channel_linkedid(), ast_channel_lock, ast_channel_masquerade(), ast_channel_name(), ast_channel_readformat(), ast_channel_state_set(), ast_channel_unlock, ast_channel_writeformat(), ast_clear_flag, ast_debug, ast_do_masquerade(), AST_FLAGS_ALL, ast_format_copy(), ast_hangup(), ast_parseable_goto(), ast_pbx_start(), AST_SOFTHANGUP_ALL, AST_STATE_DOWN, AST_STATE_UP, ast_strdupa, ast_strlen_zero(), and pbx_builtin_getvar_helper().

Referenced by builtin_blindtransfer().

{
   struct ast_channel *xferchan;
   const char *val;
   char *goto_on_transfer;
   char *x;

   ast_channel_lock(chan);
   val = pbx_builtin_getvar_helper(chan, "GOTO_ON_BLINDXFR");
   if (ast_strlen_zero(val)) {
      ast_channel_unlock(chan);
      return;
   }
   goto_on_transfer = ast_strdupa(val);
   ast_channel_unlock(chan);

   ast_debug(1, "Attempting GOTO_ON_BLINDXFR=%s for %s.\n", val, ast_channel_name(chan));

   xferchan = ast_channel_alloc(0, AST_STATE_DOWN, 0, 0, "", "", "", ast_channel_linkedid(chan), 0,
      "%s", ast_channel_name(chan));
   if (!xferchan) {
      return;
   }

   /* Make formats okay */
   ast_format_copy(ast_channel_readformat(xferchan), ast_channel_readformat(chan));
   ast_format_copy(ast_channel_writeformat(xferchan), ast_channel_writeformat(chan));

   if (ast_channel_masquerade(xferchan, chan)) {
      /* Failed to setup masquerade. */
      ast_hangup(xferchan);
      return;
   }

   for (x = goto_on_transfer; *x; ++x) {
      if (*x == '^') {
         *x = ',';
      }
   }
   ast_parseable_goto(xferchan, goto_on_transfer);
   ast_channel_state_set(xferchan, AST_STATE_UP);
   ast_clear_flag(ast_channel_flags(xferchan), AST_FLAGS_ALL);
   ast_channel_clear_softhangup(xferchan, AST_SOFTHANGUP_ALL);

   ast_do_masquerade(xferchan);
   if (ast_pbx_start(xferchan)) {
      /* Failed to start PBX. */
      ast_hangup(xferchan);
   }
}

static void clear_dialed_interfaces

(

struct ast_channel *

chan

)

[static]

Definition at line 4222 of file features.c.

References ast_channel_datastore_find(), ast_channel_datastore_remove(), ast_channel_lock, ast_channel_name(), ast_channel_unlock, ast_datastore_free(), ast_log(), dialed_interface_info, LOG_DEBUG, and option_debug.

Referenced by ast_bridge_call().

{
   struct ast_datastore *di_datastore;

   ast_channel_lock(chan);
   if ((di_datastore = ast_channel_datastore_find(chan, &dialed_interface_info, NULL))) {
      if (option_debug) {
         ast_log(LOG_DEBUG, "Removing dialed interfaces datastore on %s since we're bridging\n", ast_channel_name(chan));
      }
      if (!ast_channel_datastore_remove(chan, di_datastore)) {
         ast_datastore_free(di_datastore);
      }
   }
   ast_channel_unlock(chan);
}

static struct ast_parkinglot * copy_parkinglot	(	const char *	name,
		const struct ast_parkinglot *	parkinglot
	)			[static, read]

Copy parkinglot and store it with new name.

Definition at line 5285 of file features.c.

References ao2_ref, ast_debug, ast_parkinglot::cfg, create_parkinglot(), and find_parkinglot().

Referenced by create_dynamic_parkinglot().

{
   struct ast_parkinglot *copylot;

   if ((copylot = find_parkinglot(name))) { /* Parkinglot with that name already exists */
      ao2_ref(copylot, -1);
      return NULL;
   }

   copylot = create_parkinglot(name);
   if (!copylot) {
      return NULL;
   }

   ast_debug(1, "Building parking lot %s\n", name);

   /* Copy the source parking lot configuration. */
   copylot->cfg = parkinglot->cfg;

   return copylot;
}

static struct ast_parkinglot* create_dynamic_parkinglot	(	const char *	name,
		struct ast_channel *	chan
	)			[static, read]

Definition at line 1315 of file features.c.

References ao2_link, ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_debug, ast_log(), ast_strdupa, ast_strlen_zero(), ast_parkinglot::cfg, copy_parkinglot(), default_parkinglot, find_parkinglot(), parkinglot_cfg::is_invalid, LOG_ERROR, LOG_WARNING, ast_parkinglot::name, parkinglot_cfg::parkext, parkinglot_cfg::parkext_exclusive, parkinglot_cfg::parking_con, parkinglot_cfg::parking_start, parkinglot_cfg::parking_stop, parkinglot_activate(), parkinglot_addref(), parkinglot_unref(), parkinglots, pbx_builtin_getvar_helper(), and S_OR.

Referenced by ast_masq_park_call_exten(), ast_park_call_exten(), park_call_exec(), park_space_reserve(), and xfer_park_call_helper().

{
   const char *dyn_context;
   const char *dyn_exten;
   const char *dyn_range;
   const char *template_name;
   struct ast_parkinglot *template_parkinglot = NULL;
   struct ast_parkinglot *parkinglot;
   int dyn_start;
   int dyn_end;

   ast_channel_lock(chan);
   template_name = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "PARKINGDYNAMIC"), ""));
   dyn_context = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "PARKINGDYNCONTEXT"), ""));
   dyn_exten = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "PARKINGDYNEXTEN"), ""));
   dyn_range = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "PARKINGDYNPOS"), ""));
   ast_channel_unlock(chan);

   if (!ast_strlen_zero(template_name)) {
      template_parkinglot = find_parkinglot(template_name);
      if (!template_parkinglot) {
         ast_debug(1, "PARKINGDYNAMIC lot %s does not exist.\n",
            template_name);
      } else if (template_parkinglot->cfg.is_invalid) {
         ast_debug(1, "PARKINGDYNAMIC lot %s has invalid config.\n",
            template_name);
         parkinglot_unref(template_parkinglot);
         template_parkinglot = NULL;
      }
   }
   if (!template_parkinglot) {
      template_parkinglot = parkinglot_addref(default_parkinglot);
      ast_debug(1, "Using default parking lot for template\n");
   }

   parkinglot = copy_parkinglot(name, template_parkinglot);
   if (!parkinglot) {
      ast_log(LOG_ERROR, "Could not build dynamic parking lot!\n");
   } else {
      /* Configure the dynamic parking lot. */
      if (!ast_strlen_zero(dyn_context)) {
         ast_copy_string(parkinglot->cfg.parking_con, dyn_context,
            sizeof(parkinglot->cfg.parking_con));
      }
      if (!ast_strlen_zero(dyn_exten)) {
         ast_copy_string(parkinglot->cfg.parkext, dyn_exten,
            sizeof(parkinglot->cfg.parkext));
      }
      if (!ast_strlen_zero(dyn_range)) {
         if (sscanf(dyn_range, "%30d-%30d", &dyn_start, &dyn_end) != 2) {
            ast_log(LOG_WARNING,
               "Format for parking positions is a-b, where a and b are numbers\n");
         } else if (dyn_end < dyn_start || dyn_start <= 0 || dyn_end <= 0) {
            ast_log(LOG_WARNING,
               "Format for parking positions is a-b, where a <= b\n");
         } else {
            parkinglot->cfg.parking_start = dyn_start;
            parkinglot->cfg.parking_stop = dyn_end;
         }
      }

      /*
       * Sanity check for dynamic parking lot configuration.
       *
       * XXX It may be desirable to instead check if the dynamic
       * parking lot overlaps any existing lots like what is done for
       * a reload.
       */
      if (!strcmp(parkinglot->cfg.parking_con, template_parkinglot->cfg.parking_con)) {
         if (!strcmp(parkinglot->cfg.parkext, template_parkinglot->cfg.parkext)
            && parkinglot->cfg.parkext_exclusive) {
            ast_log(LOG_WARNING,
               "Parking lot '%s' conflicts with template parking lot '%s'!\n"
               "Change either PARKINGDYNCONTEXT or PARKINGDYNEXTEN.\n",
               parkinglot->name, template_parkinglot->name);
         }
         if ((template_parkinglot->cfg.parking_start <= parkinglot->cfg.parking_start
               && parkinglot->cfg.parking_start <= template_parkinglot->cfg.parking_stop)
            || (template_parkinglot->cfg.parking_start <= parkinglot->cfg.parking_stop
               && parkinglot->cfg.parking_stop <= template_parkinglot->cfg.parking_stop)
            || (parkinglot->cfg.parking_start < template_parkinglot->cfg.parking_start
               && template_parkinglot->cfg.parking_stop < parkinglot->cfg.parking_stop)) {
            ast_log(LOG_WARNING,
               "Parking lot '%s' parking spaces overlap template parking lot '%s'!\n"
               "Change PARKINGDYNPOS.\n",
               parkinglot->name, template_parkinglot->name);
         }
      }

      parkinglot_activate(parkinglot);
      ao2_link(parkinglots, parkinglot);
   }
   parkinglot_unref(template_parkinglot);

   return parkinglot;
}

static struct ast_parkinglot * create_parkinglot

(

const char *

name

)

[static, read]

Allocate parking lot structure.

Definition at line 5736 of file features.c.

References ao2_alloc, ast_copy_string(), AST_LIST_HEAD_INIT, ast_strlen_zero(), ast_parkinglot::cfg, parkinglot_cfg::is_invalid, ast_parkinglot::name, parkinglot_destroy(), and ast_parkinglot::parkings.

Referenced by build_parkinglot(), and copy_parkinglot().

{
   struct ast_parkinglot *newlot;

   if (ast_strlen_zero(name)) { /* No name specified */
      return NULL;
   }

   newlot = ao2_alloc(sizeof(*newlot), parkinglot_destroy);
   if (!newlot)
      return NULL;

   ast_copy_string(newlot->name, name, sizeof(newlot->name));
   newlot->cfg.is_invalid = 1;/* No config is set yet. */
   AST_LIST_HEAD_INIT(&newlot->parkings);

   return newlot;
}

static void destroy_dialplan_usage_context

(

struct parking_dp_context *

doomed

)

[static]

Definition at line 6333 of file features.c.

References parking_dp_context::access_extens, ast_free, AST_LIST_REMOVE_HEAD, parking_dp_context::hints, and parking_dp_context::spaces.

Referenced by build_dialplan_useage_context(), and destroy_dialplan_usage_map().

{
   struct parking_dp_ramp *ramp;
   struct parking_dp_spaces *spaces;

   while ((ramp = AST_LIST_REMOVE_HEAD(&doomed->access_extens, node))) {
      ast_free(ramp);
   }
   while ((spaces = AST_LIST_REMOVE_HEAD(&doomed->spaces, node))) {
      ast_free(spaces);
   }
   while ((spaces = AST_LIST_REMOVE_HEAD(&doomed->hints, node))) {
      ast_free(spaces);
   }
   ast_free(doomed);
}

static void destroy_dialplan_usage_map

(

struct parking_dp_map *

doomed

)

[static]

Definition at line 6358 of file features.c.

References AST_LIST_REMOVE_HEAD, and destroy_dialplan_usage_context().

Referenced by load_config().

{
   struct parking_dp_context *item;

   while ((item = AST_LIST_REMOVE_HEAD(doomed, node))) {
      destroy_dialplan_usage_context(item);
   }
}

static void destroy_space	(	const char *	context,
		int	space
	)			[static]

Definition at line 6788 of file features.c.

References AST_MAX_EXTENSION, PRIORITY_HINT, and remove_exten_if_exist().

Referenced by remove_dead_context_usage(), and remove_dead_spaces_usage().

{
   char exten[AST_MAX_EXTENSION];

   /* Destroy priorities of the parking space that we registered. */
   snprintf(exten, sizeof(exten), "%d", space);
   remove_exten_if_exist(context, exten, PRIORITY_HINT);
   remove_exten_if_exist(context, exten, 1);
}

static void dial_features_destroy

(

void *

data

)

[static]

Definition at line 881 of file features.c.

References ast_free.

{
   struct ast_dial_features *df = data;
   if (df) {
      ast_free(df);
   }
}

static void* dial_features_duplicate

(

void *

data

)

[static]

Definition at line 868 of file features.c.

References ast_calloc.

{
   struct ast_dial_features *df = data, *df_copy;

   if (!(df_copy = ast_calloc(1, sizeof(*df)))) {
      return NULL;
   }

   memcpy(df_copy, df, sizeof(*df));

   return df_copy;
}

static int dialplan_usage_add_parkinglot	(	struct parking_dp_map *	usage_map,
		struct ast_parkinglot *	lot,
		int	complain
	)			[static]

Definition at line 6641 of file features.c.

References AST_LIST_INSERT_BEFORE_CURRENT, AST_LIST_INSERT_TAIL, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, build_dialplan_useage_context(), ast_parkinglot::cfg, parking_dp_context::context, dialplan_usage_add_parkinglot_data(), and parkinglot_cfg::parking_con.

Referenced by build_dialplan_useage_map().

{
   struct parking_dp_context *cur_ctx;
   struct parking_dp_context *new_ctx;
   int cmp;

   AST_LIST_TRAVERSE_SAFE_BEGIN(usage_map, cur_ctx, node) {
      cmp = strcmp(lot->cfg.parking_con, cur_ctx->context);
      if (cmp > 0) {
         /* The parking lot context goes after this node. */
         continue;
      }
      if (cmp == 0) {
         /* This is the node we will add parking lot spaces to the map. */
         return dialplan_usage_add_parkinglot_data(cur_ctx, lot, complain);
      }
      /* The new parking lot context goes before this node. */
      new_ctx = build_dialplan_useage_context(lot);
      if (!new_ctx) {
         return -1;
      }
      AST_LIST_INSERT_BEFORE_CURRENT(new_ctx, node);
      return 0;
   }
   AST_LIST_TRAVERSE_SAFE_END;

   /* New parking lot context goes on the end. */
   new_ctx = build_dialplan_useage_context(lot);
   if (!new_ctx) {
      return -1;
   }
   AST_LIST_INSERT_TAIL(usage_map, new_ctx, node);
   return 0;
}

static int dialplan_usage_add_parkinglot_data	(	struct parking_dp_context *	ctx_node,
		struct ast_parkinglot *	lot,
		int	complain
	)			[static]

Definition at line 6587 of file features.c.

References parking_dp_context::access_extens, ast_parkinglot::cfg, parking_dp_context::hints, parkinglot_cfg::parkaddhints, parkinglot_cfg::parkext, parkinglot_cfg::parkext_exclusive, parkinglot_cfg::parking_start, parkinglot_cfg::parking_stop, parking_dp_context::spaces, usage_context_add_ramp(), and usage_context_add_spaces().

Referenced by build_dialplan_useage_context(), and dialplan_usage_add_parkinglot().

{
   if (usage_context_add_ramp(&ctx_node->access_extens, lot->cfg.parkext,
      lot->cfg.parkext_exclusive, lot, complain)) {
      return -1;
   }
   if (usage_context_add_spaces(&ctx_node->spaces, lot->cfg.parking_start,
      lot->cfg.parking_stop, lot, complain)) {
      return -1;
   }
   if (lot->cfg.parkaddhints
      && usage_context_add_spaces(&ctx_node->hints, lot->cfg.parking_start,
         lot->cfg.parking_stop, lot, 0)) {
      return -1;
   }
   return 0;
}

static int do_bridge_masquerade	(	struct ast_channel *	chan,
		struct ast_channel *	tmpchan
	)			[static]

Actual bridge.

Parameters:

	chan
	tmpchan	Stop hold music, lock both channels, masq channels, after bridge return channel to next priority.

Return values:

	0	on success.
	-1	on error.

Definition at line 7230 of file features.c.

References ast_channel_context(), ast_channel_exten(), ast_channel_lock_both, ast_channel_masquerade(), ast_channel_priority(), ast_channel_readformat(), ast_channel_unlock, ast_channel_writeformat(), ast_do_masquerade(), ast_explicit_goto(), ast_format_copy(), ast_moh_stop(), ast_setstate(), and ast_strdupa.

Referenced by action_bridge(), and bridge_exec().

{
   const char *context;
   const char *exten;
   int priority;

   ast_moh_stop(chan);
   ast_channel_lock_both(chan, tmpchan);
   context = ast_strdupa(ast_channel_context(chan));
   exten = ast_strdupa(ast_channel_exten(chan));
   priority = ast_channel_priority(chan);
   ast_setstate(tmpchan, ast_channel_state(chan));
   ast_format_copy(ast_channel_readformat(tmpchan), ast_channel_readformat(chan));
   ast_format_copy(ast_channel_writeformat(tmpchan), ast_channel_writeformat(chan));
   ast_channel_unlock(chan);
   ast_channel_unlock(tmpchan);

   /* Masquerade setup and execution must be done without any channel locks held */
   if (ast_channel_masquerade(tmpchan, chan)) {
      return -1;
   }
   ast_do_masquerade(tmpchan);

   /* when returning from bridge, the channel will continue at the next priority */
   ast_explicit_goto(tmpchan, context, exten, priority + 1);

   return 0;
}

static void* do_parking_thread

(

void *

ignore

)

[static]

Take care of parked calls and unpark them if needed.

Parameters:

ignore

unused var.

Start inf loop, lock parking lot, check if any parked channels have gone above timeout if so, remove channel from parking lot and return it to the extension that parked it. Check if parked channel decided to hangup, wait until next FD via select().

Definition at line 5235 of file features.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_free, ast_poll, manage_parkinglot(), and parkinglots.

Referenced by ast_features_init().

{
   struct pollfd *pfds = NULL, *new_pfds = NULL;
   int nfds = 0, new_nfds = 0;

   for (;;) {
      struct ao2_iterator iter;
      struct ast_parkinglot *curlot;
      int ms = -1;   /* poll2 timeout, uninitialized */

      iter = ao2_iterator_init(parkinglots, 0);
      while ((curlot = ao2_iterator_next(&iter))) {
         manage_parkinglot(curlot, pfds, nfds, &new_pfds, &new_nfds, &ms);
         ao2_ref(curlot, -1);
      }
      ao2_iterator_destroy(&iter);

      /* Recycle */
      ast_free(pfds);
      pfds = new_pfds;
      nfds = new_nfds;
      new_pfds = NULL;
      new_nfds = 0;

      /* Wait for something to happen */
      ast_poll(pfds, nfds, ms);
      pthread_testcancel();
   }
   /* If this WERE reached, we'd need to free(pfds) */
   return NULL;   /* Never reached */
}

static int feature_check	(	struct ast_channel *	chan,
		struct ast_flags *	features,
		char *	code
	)			[static]

Check if a feature exists.

Definition at line 3731 of file features.c.

References ast_channel_lock, ast_channel_unlock, ast_strdupa, FEATURE_INTERPRET_CHECK, feature_interpret_helper(), pbx_builtin_getvar_helper(), and S_OR.

Referenced by ast_bridge_call().

                                                                                           {
   char *chan_dynamic_features;
   ast_channel_lock(chan);
   chan_dynamic_features = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "DYNAMIC_FEATURES"),""));
   ast_channel_unlock(chan);

   return feature_interpret_helper(chan, NULL, NULL, code, 0, chan_dynamic_features, features, FEATURE_INTERPRET_CHECK, NULL);
}

static void feature_ds_destroy

(

void *

data

)

[static]

Definition at line 3341 of file features.c.

References ao2_ref, ast_free, and feature_ds::feature_map.

Referenced by get_feature_ds().

{
   struct feature_ds *feature_ds = data;

   if (feature_ds->feature_map) {
      ao2_ref(feature_ds->feature_map, -1);
      feature_ds->feature_map = NULL;
   }

   ast_free(feature_ds);
}

static int feature_exec_app	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		void *	data
	)			[static]

exec an app by feature

Parameters:

chan,peer,config,code,sense,data

Find a feature, determine which channel activated

Return values:

	AST_FEATURE_RETURN_NO_HANGUP_PEER
	-1	error.
	-2	when an application cannot be found.

Todo:

XXX should probably return res

Definition at line 3468 of file features.c.

References ast_call_feature::app, app, ast_call_feature::app_args, ast_autoservice_ignore(), ast_autoservice_start(), ast_autoservice_stop(), ast_channel_name(), AST_FEATURE_FLAG_BYCALLEE, AST_FEATURE_FLAG_BYCALLER, AST_FEATURE_FLAG_ONSELF, AST_FEATURE_RETURN_KEEPTRYING, AST_FEATURE_RETURN_SUCCESS, AST_FEATURE_RETURN_SUCCESSBREAK, AST_FRAME_DTMF_END, ast_log(), ast_moh_start(), ast_moh_stop(), ast_strlen_zero(), ast_test_flag, FEATURE_SENSE_CHAN, LOG_NOTICE, LOG_WARNING, ast_call_feature::moh_class, pbx_builtin_setvar_helper(), pbx_exec(), pbx_findapp(), and ast_call_feature::sname.

Referenced by process_applicationmap_line().

{
   struct ast_app *app;
   struct ast_call_feature *feature = data;
   struct ast_channel *work, *idle;
   int res;

   if (!feature) { /* shouldn't ever happen! */
      ast_log(LOG_NOTICE, "Found feature before, but at execing we've lost it??\n");
      return -1;
   }

   if (sense == FEATURE_SENSE_CHAN) {
      if (!ast_test_flag(feature, AST_FEATURE_FLAG_BYCALLER))
         return AST_FEATURE_RETURN_KEEPTRYING;
      if (ast_test_flag(feature, AST_FEATURE_FLAG_ONSELF)) {
         work = chan;
         idle = peer;
      } else {
         work = peer;
         idle = chan;
      }
   } else {
      if (!ast_test_flag(feature, AST_FEATURE_FLAG_BYCALLEE))
         return AST_FEATURE_RETURN_KEEPTRYING;
      if (ast_test_flag(feature, AST_FEATURE_FLAG_ONSELF)) {
         work = peer;
         idle = chan;
      } else {
         work = chan;
         idle = peer;
      }
   }

   if (!(app = pbx_findapp(feature->app))) {
      ast_log(LOG_WARNING, "Could not find application (%s)\n", feature->app);
      return -2;
   }

   ast_autoservice_start(idle);
   ast_autoservice_ignore(idle, AST_FRAME_DTMF_END);

   pbx_builtin_setvar_helper(work, "DYNAMIC_PEERNAME", ast_channel_name(idle));
   pbx_builtin_setvar_helper(idle, "DYNAMIC_PEERNAME", ast_channel_name(work));
   pbx_builtin_setvar_helper(work, "DYNAMIC_FEATURENAME", feature->sname);
   pbx_builtin_setvar_helper(idle, "DYNAMIC_FEATURENAME", feature->sname);

   if (!ast_strlen_zero(feature->moh_class))
      ast_moh_start(idle, feature->moh_class, NULL);

   res = pbx_exec(work, app, feature->app_args);

   if (!ast_strlen_zero(feature->moh_class))
      ast_moh_stop(idle);

   ast_autoservice_stop(idle);

   if (res) {
      return AST_FEATURE_RETURN_SUCCESSBREAK;
   }
   return AST_FEATURE_RETURN_SUCCESS;  /*! \todo XXX should probably return res */
}

static int feature_exten_cmp	(	void *	obj,
		void *	arg,
		int	flags
	)			[static]

Definition at line 3366 of file features.c.

References CMP_MATCH, CMP_STOP, OBJ_KEY, and feature_exten::sname.

Referenced by get_feature_ds().

{
   const struct feature_exten *fe = obj, *fe2 = arg;
   const char *sname = arg;

   return !strcmp(fe->sname, flags & OBJ_KEY ? sname : fe2->sname) ?
         CMP_MATCH | CMP_STOP : 0;
}

static int feature_exten_hash	(	const void *	obj,
		int	flags
	)			[static]

Definition at line 3358 of file features.c.

References ast_str_hash(), OBJ_KEY, and feature_exten::sname.

Referenced by get_feature_ds().

{
   const struct feature_exten *fe = obj;
   const char *sname = obj;

   return ast_str_hash(flags & OBJ_KEY ? sname : fe->sname);
}

static int feature_interpret	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense
	)			[static]

Check the dynamic features.

Parameters:

chan,peer,config,code,sense

Return values:

	res	on success.
	-1	on failure.

Definition at line 3694 of file features.c.

References ast_channel_lock, ast_channel_name(), ast_channel_unlock, ast_copy_flags, ast_debug, AST_FLAGS_ALL, ast_strdupa, FEATURE_INTERPRET_DO, feature_interpret_helper(), FEATURE_SENSE_CHAN, ast_bridge_config::features_callee, ast_bridge_config::features_caller, ast_flags::flags, pbx_builtin_getvar_helper(), and S_OR.

Referenced by ast_bridge_call().

                                                                                                                                                {

   char dynamic_features_buf[128];
   const char *peer_dynamic_features, *chan_dynamic_features;
   struct ast_flags features;
   struct ast_call_feature feature;
   if (sense == FEATURE_SENSE_CHAN) {
      /* Coverity - This uninit_use should be ignored since this macro initializes the flags */
      ast_copy_flags(&features, &(config->features_caller), AST_FLAGS_ALL);
   }
   else {
      /* Coverity - This uninit_use should be ignored since this macro initializes the flags */
      ast_copy_flags(&features, &(config->features_callee), AST_FLAGS_ALL);
   }

   ast_channel_lock(peer);
   peer_dynamic_features = ast_strdupa(S_OR(pbx_builtin_getvar_helper(peer, "DYNAMIC_FEATURES"),""));
   ast_channel_unlock(peer);

   ast_channel_lock(chan);
   chan_dynamic_features = ast_strdupa(S_OR(pbx_builtin_getvar_helper(chan, "DYNAMIC_FEATURES"),""));
   ast_channel_unlock(chan);

   snprintf(dynamic_features_buf, sizeof(dynamic_features_buf), "%s%s%s", S_OR(chan_dynamic_features, ""), chan_dynamic_features && peer_dynamic_features ? "#" : "", S_OR(peer_dynamic_features,""));

   ast_debug(3, "Feature interpret: chan=%s, peer=%s, code=%s, sense=%d, features=%d, dynamic=%s\n", ast_channel_name(chan), ast_channel_name(peer), code, sense, features.flags, dynamic_features_buf);

   return feature_interpret_helper(chan, peer, config, code, sense, dynamic_features_buf, &features, FEATURE_INTERPRET_DO, &feature);
}

static int feature_interpret_helper	(	struct ast_channel *	chan,
		struct ast_channel *	peer,
		struct ast_bridge_config *	config,
		const char *	code,
		int	sense,
		char *	dynamic_features_buf,
		struct ast_flags *	features,
		feature_interpret_op	operation,
		struct ast_call_feature *	feature
	)			[static]

Helper function for feature_interpret and ast_feature_detect.

Parameters:

chan,peer,config,code,sense,dynamic_features_buf,features,operation,feature

Lock features list, browse for code, unlock list If a feature is found and the operation variable is set, that feature's operation is executed. The first feature found is copied to the feature parameter.

Return values:

	res	on success.
	-1	on failure.

Definition at line 3569 of file features.c.

References ast_debug, AST_FEATURE_RETURN_KEEPTRYING, AST_FEATURE_RETURN_PASSDIGITS, AST_FEATURE_RETURN_STOREDIGITS, AST_FEATURE_RETURN_SUCCESS, AST_LIST_TRAVERSE, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, ast_rwlock_rdlock, ast_rwlock_unlock, ast_strlen_zero(), ast_test_flag, ast_verb, builtin_feature_get_exten(), ast_call_feature::exten, feature_group_exten::exten, feature_group_exten::feature, FEATURE_INTERPRET_CHECK, FEATURE_INTERPRET_DO, ast_call_feature::feature_mask, FEATURE_MAX_LEN, feature_group::features, FEATURES_COUNT, features_lock, find_dynamic_feature(), find_group(), ast_call_feature::fname, ast_call_feature::operation, ast_call_feature::sname, and strsep().

Referenced by ast_feature_detect(), feature_check(), and feature_interpret().

{
   int x;
   struct feature_group *fg = NULL;
   struct feature_group_exten *fge;
   struct ast_call_feature *tmpfeature;
   char *tmp, *tok;
   int res = AST_FEATURE_RETURN_PASSDIGITS;
   int feature_detected = 0;

   if (!(peer && chan && config) && operation == FEATURE_INTERPRET_DO) {
      return -1; /* can not run feature operation */
   }

   ast_rwlock_rdlock(&features_lock);
   for (x = 0; x < FEATURES_COUNT; x++) {
      char feature_exten[FEATURE_MAX_LEN] = "";

      if (!ast_test_flag(features, builtin_features[x].feature_mask)) {
         continue;
      }

      if (builtin_feature_get_exten(chan, builtin_features[x].sname, feature_exten, sizeof(feature_exten))) {
         continue;
      }

      /* Feature is up for consideration */

      if (!strcmp(feature_exten, code)) {
         ast_debug(3, "Feature detected: fname=%s sname=%s exten=%s\n", builtin_features[x].fname, builtin_features[x].sname, feature_exten);
         if (operation == FEATURE_INTERPRET_CHECK) {
            res = AST_FEATURE_RETURN_SUCCESS; /* We found something */
         } else if (operation == FEATURE_INTERPRET_DO) {
            res = builtin_features[x].operation(chan, peer, config, code, sense, NULL);
         }
         if (feature) {
            memcpy(feature, &builtin_features[x], sizeof(*feature));
         }
         feature_detected = 1;
         break;
      } else if (!strncmp(feature_exten, code, strlen(code))) {
         if (res == AST_FEATURE_RETURN_PASSDIGITS) {
            res = AST_FEATURE_RETURN_STOREDIGITS;
         }
      }
   }
   ast_rwlock_unlock(&features_lock);

   if (ast_strlen_zero(dynamic_features_buf) || feature_detected) {
      return res;
   }

   tmp = dynamic_features_buf;

   while ((tok = strsep(&tmp, "#"))) {
      AST_RWLIST_RDLOCK(&feature_groups);

      fg = find_group(tok);

      if (fg) {
         AST_LIST_TRAVERSE(&fg->features, fge, entry) {
            if (!strcmp(fge->exten, code)) {
               if (operation) {
                  res = fge->feature->operation(chan, peer, config, code, sense, fge->feature);
               }
               if (feature) {
                  memcpy(feature, fge->feature, sizeof(*feature));
               }
               if (res != AST_FEATURE_RETURN_KEEPTRYING) {
                  AST_RWLIST_UNLOCK(&feature_groups);
                  break;
               }
               res = AST_FEATURE_RETURN_PASSDIGITS;
            } else if (!strncmp(fge->exten, code, strlen(code))) {
               res = AST_FEATURE_RETURN_STOREDIGITS;
            }
         }
         if (fge) {
            break;
         }
      }

      AST_RWLIST_UNLOCK(&feature_groups);

      AST_RWLIST_RDLOCK(&feature_list);

      if (!(tmpfeature = find_dynamic_feature(tok))) {
         AST_RWLIST_UNLOCK(&feature_list);
         continue;
      }

      /* Feature is up for consideration */
      if (!strcmp(tmpfeature->exten, code)) {
         ast_verb(3, " Feature Found: %s exten: %s\n",tmpfeature->sname, tok);
         if (operation == FEATURE_INTERPRET_CHECK) {
            res = AST_FEATURE_RETURN_SUCCESS; /* We found something */
         } else if (operation == FEATURE_INTERPRET_DO) {
            res = tmpfeature->operation(chan, peer, config, code, sense, tmpfeature);
         }
         if (feature) {
            memcpy(feature, tmpfeature, sizeof(*feature));
         }
         if (res != AST_FEATURE_RETURN_KEEPTRYING) {
            AST_RWLIST_UNLOCK(&feature_list);
            break;
         }
         res = AST_FEATURE_RETURN_PASSDIGITS;
      } else if (!strncmp(tmpfeature->exten, code, strlen(code)))
         res = AST_FEATURE_RETURN_STOREDIGITS;

      AST_RWLIST_UNLOCK(&feature_list);
   }

   return res;
}

static int feature_read	(	struct ast_channel *	chan,
		const char *	cmd,
		char *	data,
		char *	buf,
		size_t	len
	)			[static]

Definition at line 8846 of file features.c.

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

{
   int res = 0;

   if (!strcasecmp(data, "parkingtime")) {
      snprintf(buf, len, "%u", get_parkingtime(chan, NULL) / 1000);
   } else {
      ast_log(LOG_WARNING, "Invalid argument '%s' to FEATURE()\n", data);
      res = -1;
   }

   return res;
}

static struct ast_channel * feature_request_and_dial	(	struct ast_channel *	caller,
		const char *	caller_name,
		struct ast_channel *	requestor,
		struct ast_channel *	transferee,
		const char *	type,
		struct ast_format_cap *	cap,
		const char *	addr,
		int	timeout,
		int *	outstate,
		const char *	language
	)			[static, read]

Definition at line 3835 of file features.c.

References ast_alloca, ast_autoservice_start(), ast_autoservice_stop(), ast_best_codec(), ast_call(), ast_call_forward(), AST_CAUSE_BUSY, AST_CAUSE_CONGESTION, ast_channel_call_forward(), ast_channel_caller(), ast_channel_connected(), ast_channel_connected_line_macro(), ast_channel_connected_line_sub(), ast_channel_exten(), ast_channel_hangupcause(), ast_channel_inherit_variables(), ast_channel_lock, ast_channel_name(), ast_channel_redirecting_macro(), ast_channel_redirecting_sub(), ast_channel_set_connected_line(), ast_channel_unlock, ast_check_hangup(), ast_connected_line_copy_from_caller(), ast_connected_line_parse_data(), AST_CONTROL_ANSWER, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_CONNECTED_LINE, AST_CONTROL_INCOMPLETE, AST_CONTROL_PROCEEDING, AST_CONTROL_PROGRESS, AST_CONTROL_PVT_CAUSE_CODE, AST_CONTROL_REDIRECTING, AST_CONTROL_RINGING, AST_CONTROL_UNHOLD, ast_format_cap_add(), ast_format_cap_alloc_nolock(), ast_format_cap_destroy(), AST_FRAME_CONTROL, AST_FRAME_DTMF, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_frfree, ast_frisolate(), ast_hangup(), ast_indicate(), ast_indicate_data(), ast_is_deferrable_frame(), AST_LIST_HEAD_INIT_NOLOCK, AST_LIST_HEAD_NOLOCK, AST_LIST_INSERT_HEAD, AST_LIST_REMOVE_HEAD, ast_log(), ast_party_connected_line_free(), ast_party_connected_line_set_init(), ast_poll_channel_add(), ast_poll_channel_del(), ast_queue_frame_head(), ast_read(), ast_request(), ast_rwlock_rdlock, ast_rwlock_unlock, AST_STATE_UP, ast_strlen_zero(), ast_tvdiff_ms(), ast_tvnow(), ast_verb, ast_waitfor_n(), ast_write(), cause, ast_frame::data, ast_frame::datalen, ast_call_feature::exten, f, FEATURES_COUNT, features_lock, ast_frame::frametype, ast_frame_subclass::integer, LOG_NOTICE, pbx_builtin_setvar_helper(), ast_frame::ptr, and ast_frame::subclass.

Referenced by builtin_atxfer().

{
   int state = 0;
   int cause = 0;
   int to;
   int caller_hungup;
   int transferee_hungup;
   struct ast_channel *chan;
   struct ast_channel *monitor_chans[3];
   struct ast_channel *active_channel;
   int res;
   int ready = 0;
   struct timeval started;
   int x, len = 0;
   char *disconnect_code = NULL, *dialed_code = NULL;
   struct ast_format_cap *tmp_cap;
   struct ast_format best_audio_fmt;
   struct ast_frame *f;
   AST_LIST_HEAD_NOLOCK(, ast_frame) deferred_frames;

   tmp_cap = ast_format_cap_alloc_nolock();
   if (!tmp_cap) {
      if (outstate) {
         *outstate = 0;
      }
      return NULL;
   }
   ast_best_codec(cap, &best_audio_fmt);
   ast_format_cap_add(tmp_cap, &best_audio_fmt);

   caller_hungup = ast_check_hangup(caller);

   if (!(chan = ast_request(type, tmp_cap, requestor, addr, &cause))) {
      ast_log(LOG_NOTICE, "Unable to request channel %s/%s\n", type, addr);
      switch (cause) {
      case AST_CAUSE_BUSY:
         state = AST_CONTROL_BUSY;
         break;
      case AST_CAUSE_CONGESTION:
         state = AST_CONTROL_CONGESTION;
         break;
      default:
         state = 0;
         break;
      }
      goto done;
   }

   ast_channel_language_set(chan, language);
   ast_channel_inherit_variables(caller, chan);
   pbx_builtin_setvar_helper(chan, "TRANSFERERNAME", caller_name);

   ast_channel_lock(chan);
   ast_connected_line_copy_from_caller(ast_channel_connected(chan), ast_channel_caller(requestor));
   ast_channel_unlock(chan);

   if (ast_call(chan, addr, timeout)) {
      ast_log(LOG_NOTICE, "Unable to call channel %s/%s\n", type, addr);
      switch (ast_channel_hangupcause(chan)) {
      case AST_CAUSE_BUSY:
         state = AST_CONTROL_BUSY;
         break;
      case AST_CAUSE_CONGESTION:
         state = AST_CONTROL_CONGESTION;
         break;
      default:
         state = 0;
         break;
      }
      goto done;
   }

   /* support dialing of the featuremap disconnect code while performing an attended tranfer */
   ast_rwlock_rdlock(&features_lock);
   for (x = 0; x < FEATURES_COUNT; x++) {
      if (strcasecmp(builtin_features[x].sname, "disconnect"))
         continue;

      disconnect_code = builtin_features[x].exten;
      len = strlen(disconnect_code) + 1;
      dialed_code = ast_alloca(len);
      memset(dialed_code, 0, len);
      break;
   }
   ast_rwlock_unlock(&features_lock);
   x = 0;
   started = ast_tvnow();
   to = timeout;
   AST_LIST_HEAD_INIT_NOLOCK(&deferred_frames);

   ast_poll_channel_add(caller, chan);

   transferee_hungup = 0;
   while (!ast_check_hangup(transferee) && (ast_channel_state(chan) != AST_STATE_UP)) {
      int num_chans = 0;

      monitor_chans[num_chans++] = transferee;
      monitor_chans[num_chans++] = chan;
      if (!caller_hungup) {
         if (ast_check_hangup(caller)) {
            caller_hungup = 1;

#if defined(ATXFER_NULL_TECH)
            /* Change caller's name to ensure that it will remain unique. */
            set_new_chan_name(caller);

            /*
             * Get rid of caller's physical technology so it is free for
             * other calls.
             */
            set_kill_chan_tech(caller);
#endif   /* defined(ATXFER_NULL_TECH) */
         } else {
            /* caller is not hungup so monitor it. */
            monitor_chans[num_chans++] = caller;
         }
      }

      /* see if the timeout has been violated */
      if (ast_tvdiff_ms(ast_tvnow(), started) > timeout) {
         state = AST_CONTROL_UNHOLD;
         ast_log(LOG_NOTICE, "We exceeded our AT-timeout for %s\n", ast_channel_name(chan));
         break; /*doh! timeout*/
      }

      active_channel = ast_waitfor_n(monitor_chans, num_chans, &to);
      if (!active_channel)
         continue;

      f = NULL;
      if (transferee == active_channel) {
         struct ast_frame *dup_f;

         f = ast_read(transferee);
         if (f == NULL) { /*doh! where'd he go?*/
            transferee_hungup = 1;
            state = 0;
            break;
         }
         if (ast_is_deferrable_frame(f)) {
            dup_f = ast_frisolate(f);
            if (dup_f) {
               if (dup_f == f) {
                  f = NULL;
               }
               AST_LIST_INSERT_HEAD(&deferred_frames, dup_f, frame_list);
            }
         }
      } else if (chan == active_channel) {
         if (!ast_strlen_zero(ast_channel_call_forward(chan))) {
            state = 0;
            ast_autoservice_start(transferee);
            chan = ast_call_forward(caller, chan, NULL, tmp_cap, NULL, &state);
            ast_autoservice_stop(transferee);
            if (!chan) {
               break;
            }
            continue;
         }
         f = ast_read(chan);
         if (f == NULL) { /*doh! where'd he go?*/
            switch (ast_channel_hangupcause(chan)) {
            case AST_CAUSE_BUSY:
               state = AST_CONTROL_BUSY;
               break;
            case AST_CAUSE_CONGESTION:
               state = AST_CONTROL_CONGESTION;
               break;
            default:
               state = 0;
               break;
            }
            break;
         }

         if (f->frametype == AST_FRAME_CONTROL) {
            if (f->subclass.integer == AST_CONTROL_RINGING) {
               ast_verb(3, "%s is ringing\n", ast_channel_name(chan));
               ast_indicate(caller, AST_CONTROL_RINGING);
            } else if (f->subclass.integer == AST_CONTROL_BUSY) {
               state = f->subclass.integer;
               ast_verb(3, "%s is busy\n", ast_channel_name(chan));
               ast_indicate(caller, AST_CONTROL_BUSY);
               ast_frfree(f);
               break;
            } else if (f->subclass.integer == AST_CONTROL_INCOMPLETE) {
               ast_verb(3, "%s dialed incomplete extension %s; ignoring\n", ast_channel_name(chan), ast_channel_exten(chan));
            } else if (f->subclass.integer == AST_CONTROL_CONGESTION) {
               state = f->subclass.integer;
               ast_verb(3, "%s is congested\n", ast_channel_name(chan));
               ast_indicate(caller, AST_CONTROL_CONGESTION);
               ast_frfree(f);
               break;
            } else if (f->subclass.integer == AST_CONTROL_ANSWER) {
               /* This is what we are hoping for */
               state = f->subclass.integer;
               ast_frfree(f);
               ready=1;
               break;
            } else if (f->subclass.integer == AST_CONTROL_PVT_CAUSE_CODE) {
               ast_indicate_data(caller, AST_CONTROL_PVT_CAUSE_CODE, f->data.ptr, f->datalen);
            } else if (f->subclass.integer == AST_CONTROL_CONNECTED_LINE) {
               if (caller_hungup) {
                  struct ast_party_connected_line connected;

                  /* Just save it for the transfer. */
                  ast_party_connected_line_set_init(&connected, ast_channel_connected(caller));
                  res = ast_connected_line_parse_data(f->data.ptr, f->datalen,
                     &connected);
                  if (!res) {
                     ast_channel_set_connected_line(caller, &connected, NULL);
                  }
                  ast_party_connected_line_free(&connected);
               } else {
                  ast_autoservice_start(transferee);
                  if (ast_channel_connected_line_sub(chan, caller, f, 1) &&
                     ast_channel_connected_line_macro(chan, caller, f, 1, 1)) {
                     ast_indicate_data(caller, AST_CONTROL_CONNECTED_LINE,
                        f->data.ptr, f->datalen);
                  }
                  ast_autoservice_stop(transferee);
               }
            } else if (f->subclass.integer == AST_CONTROL_REDIRECTING) {
               if (!caller_hungup) {
                  ast_autoservice_start(transferee);
                  if (ast_channel_redirecting_sub(chan, caller, f, 1) &&
                     ast_channel_redirecting_macro(chan, caller, f, 1, 1)) {
                     ast_indicate_data(caller, AST_CONTROL_REDIRECTING,
                        f->data.ptr, f->datalen);
                  }
                  ast_autoservice_stop(transferee);
               }
            } else if (f->subclass.integer != -1
               && f->subclass.integer != AST_CONTROL_PROGRESS
               && f->subclass.integer != AST_CONTROL_PROCEEDING) {
               ast_log(LOG_NOTICE, "Don't know what to do about control frame: %d\n", f->subclass.integer);
            }
            /* else who cares */
         } else if (f->frametype == AST_FRAME_VOICE || f->frametype == AST_FRAME_VIDEO) {
            ast_write(caller, f);
         }
      } else if (caller == active_channel) {
         f = ast_read(caller);
         if (f) {
            if (f->frametype == AST_FRAME_DTMF) {
               dialed_code[x++] = f->subclass.integer;
               dialed_code[x] = '\0';
               if (strlen(dialed_code) == len) {
                  x = 0;
               } else if (x && strncmp(dialed_code, disconnect_code, x)) {
                  x = 0;
                  dialed_code[x] = '\0';
               }
               if (*dialed_code && !strcmp(dialed_code, disconnect_code)) {
                  /* Caller Canceled the call */
                  state = AST_CONTROL_UNHOLD;
                  ast_frfree(f);
                  break;
               }
            } else if (f->frametype == AST_FRAME_VOICE || f->frametype == AST_FRAME_VIDEO) {
               ast_write(chan, f);
            }
         }
      }
      if (f)
         ast_frfree(f);
   } /* end while */

   ast_poll_channel_del(caller, chan);

   /*
    * We need to free all the deferred frames, but we only need to
    * queue the deferred frames if no hangup was received.
    */
   ast_channel_lock(transferee);
   transferee_hungup = (transferee_hungup || ast_check_hangup(transferee));
   while ((f = AST_LIST_REMOVE_HEAD(&deferred_frames, frame_list))) {
      if (!transferee_hungup) {
         ast_queue_frame_head(transferee, f);
      }
      ast_frfree(f);
   }
   ast_channel_unlock(transferee);

done:
   ast_indicate(caller, -1);
   if (chan && (ready || ast_channel_state(chan) == AST_STATE_UP)) {
      state = AST_CONTROL_ANSWER;
   } else if (chan) {
      ast_hangup(chan);
      chan = NULL;
   }

   tmp_cap = ast_format_cap_destroy(tmp_cap);

   if (outstate)
      *outstate = state;

   return chan;
}

static int feature_write	(	struct ast_channel *	chan,
		const char *	cmd,
		char *	data,
		const char *	value
	)			[static]

Definition at line 8861 of file features.c.

References ast_channel_lock, ast_channel_unlock, ast_log(), get_feature_ds(), LOG_WARNING, feature_ds::parkingtime, and feature_ds::parkingtime_is_set.

{
   int res = 0;
   struct feature_ds *feature_ds;

   ast_channel_lock(chan);

   if (!(feature_ds = get_feature_ds(chan))) {
      res = -1;
      goto return_cleanup;
   }

   if (!strcasecmp(data, "parkingtime")) {
      feature_ds->parkingtime_is_set = 1;
      if (sscanf(value, "%30u", &feature_ds->parkingtime) == 1) {
         feature_ds->parkingtime *= 1000; /* stored in ms */
      } else {
         ast_log(LOG_WARNING, "'%s' is not a valid parkingtime\n", value);
         feature_ds->parkingtime_is_set = 0;
         res = -1;
      }
   } else {
      ast_log(LOG_WARNING, "Invalid argument '%s' to FEATURE()\n", data);
      res = -1;
   }

return_cleanup:
   ast_channel_unlock(chan);

   return res;
}

static int featuremap_read	(	struct ast_channel *	chan,
		const char *	cmd,
		char *	data,
		char *	buf,
		size_t	len
	)			[static]

Definition at line 8894 of file features.c.

References ast_log(), ast_rdlock_call_features(), ast_unlock_call_features(), builtin_feature_get_exten(), and LOG_WARNING.

{
   int res;

   ast_rdlock_call_features();

   if ((res = builtin_feature_get_exten(chan, data, buf, len))) {
      ast_log(LOG_WARNING, "Invalid argument '%s' to FEATUREMAP()\n", data);
   }

   ast_unlock_call_features();

   return res;
}

static int featuremap_write	(	struct ast_channel *	chan,
		const char *	cmd,
		char *	data,
		const char *	value
	)			[static]

Definition at line 8910 of file features.c.

References ao2_alloc, ao2_find, ao2_link, ao2_lock, ao2_ref, ao2_unlock, ast_channel_lock, ast_channel_unlock, ast_copy_string(), ast_find_call_feature(), ast_log(), feature_exten::exten, feature_ds::feature_map, get_feature_ds(), LOG_WARNING, OBJ_KEY, and feature_exten::sname.

{
   struct feature_ds *feature_ds;
   struct feature_exten *fe;

   if (!ast_find_call_feature(data)) {
      ast_log(LOG_WARNING, "Invalid argument '%s' to FEATUREMAP()\n", data);
      return -1;
   }

   ast_channel_lock(chan);

   if (!(feature_ds = get_feature_ds(chan))) {
      ast_channel_unlock(chan);
      return -1;
   }

   if (!(fe = ao2_find(feature_ds->feature_map, data, OBJ_KEY))) {
      if (!(fe = ao2_alloc(sizeof(*fe), NULL))) {
         ast_channel_unlock(chan);
         return -1;
      }
      ast_copy_string(fe->sname, data, sizeof(fe->sname));
      ao2_link(feature_ds->feature_map, fe);
   }

   ast_channel_unlock(chan);

   ao2_lock(fe);
   ast_copy_string(fe->exten, value, sizeof(fe->exten));
   ao2_unlock(fe);
   ao2_ref(fe, -1);
   fe = NULL;

   return 0;
}

static void features_shutdown

(

void

)

[static]

Definition at line 8961 of file features.c.

References ao2_ref, ast_custom_function_unregister(), ast_devstate_prov_del(), ast_manager_unregister(), ast_unregister_application(), parkcall, parking_thread, and parkinglots.

Referenced by ast_features_init().

{
   ast_devstate_prov_del("Park");
   ast_custom_function_unregister(&featuremap_function);
   ast_custom_function_unregister(&feature_function);
   ast_manager_unregister("Bridge");
   ast_manager_unregister("Park");
   ast_manager_unregister("Parkinglots");
   ast_manager_unregister("ParkedCalls");
   ast_unregister_application(parkcall);
   ast_unregister_application(parkedcall);
   ast_unregister_application(app_bridge);

   pthread_cancel(parking_thread);
   ao2_ref(parkinglots, -1);
}

static int find_channel_by_group	(	void *	obj,
		void *	arg,
		void *	data,
		int	flags
	)			[static]

< Potential pickup target

< Channel wanting to pickup call

< Candidate channels found.

Definition at line 7706 of file features.c.

References ao2_link, ast_can_pickup(), ast_channel_callgroup(), ast_channel_lock, ast_channel_named_callgroups(), ast_channel_named_pickupgroups(), ast_channel_pickupgroup(), ast_channel_trylock, ast_channel_unlock, and ast_namedgroups_intersect().

Referenced by ast_pickup_find_by_group().

{
   struct ast_channel *target = obj;/*!< Potential pickup target */
   struct ast_channel *chan = arg;/*!< Channel wanting to pickup call */

   if (chan == target) {
      return 0;
   }

   ast_channel_lock(target);
   if (ast_can_pickup(target)) {
      /* Lock both channels. */
      while (ast_channel_trylock(chan)) {
         ast_channel_unlock(target);
         sched_yield();
         ast_channel_lock(target);
      }

      /*
       * Both callgroup and namedcallgroup pickup variants are
       * matched independently.  Checking for named group match is
       * done last since it's a more expensive operation.
       */
      if ((ast_channel_pickupgroup(chan) & ast_channel_callgroup(target))
         || (ast_namedgroups_intersect(ast_channel_named_pickupgroups(chan),
            ast_channel_named_callgroups(target)))) {
         struct ao2_container *candidates = data;/*!< Candidate channels found. */

         /* This is a candidate to pickup */
         ao2_link(candidates, target);
      }
      ast_channel_unlock(chan);
   }
   ast_channel_unlock(target);

   return 0;
}

static struct ast_call_feature* find_dynamic_feature

(

const char *

name

)

[static, read]

find a call feature by name

Definition at line 3247 of file features.c.

References AST_RWLIST_TRAVERSE, ast_call_feature::feature_entry, and ast_call_feature::sname.

Referenced by ast_find_call_feature(), feature_interpret_helper(), process_applicationmap_line(), process_config(), and set_config_flags().

{
   struct ast_call_feature *tmp;

   AST_RWLIST_TRAVERSE(&feature_list, tmp, feature_entry) {
      if (!strcasecmp(tmp->sname, name)) {
         break;
      }
   }

   return tmp;
}

static struct feature_group* find_group

(

const char *

name

)

[static, read]

Find a group by name.

Parameters:

name

feature name

Return values:

	feature	group on success.
	NULL	on failure.

Definition at line 3285 of file features.c.

References AST_LIST_TRAVERSE, and feature_group::gname.

Referenced by feature_interpret_helper().

{
   struct feature_group *fg = NULL;

   AST_LIST_TRAVERSE(&feature_groups, fg, entry) {
      if (!strcasecmp(fg->gname, name))
         break;
   }

   return fg;
}

static struct ast_parkinglot * find_parkinglot

(

const char *

name

)

[static, read]

Find parkinglot by name.

Definition at line 5268 of file features.c.

References ao2_find, ast_debug, ast_strlen_zero(), ast_parkinglot::name, and parkinglots.

Referenced by ast_masq_park_call_exten(), ast_park_call_exten(), build_parkinglot(), copy_parkinglot(), create_dynamic_parkinglot(), get_parkingtime(), manager_park(), park_call_exec(), park_space_reserve(), parked_call_exec(), and xfer_park_call_helper().

{
   struct ast_parkinglot *parkinglot;

   if (ast_strlen_zero(name)) {
      return NULL;
   }

   parkinglot = ao2_find(parkinglots, (void *) name, 0);
   if (parkinglot) {
      ast_debug(1, "Found Parking lot: %s\n", parkinglot->name);
   }

   return parkinglot;
}

static const char* findparkinglotname

(

struct ast_channel *

chan

)

[static]

Find parking lot name from channel.

Note:

Channel needs to be locked while the returned string is in use.

Definition at line 1232 of file features.c.

References ast_channel_parkinglot(), ast_strlen_zero(), name, and pbx_builtin_getvar_helper().

Referenced by park_call_exec(), park_space_reserve(), parked_call_exec(), and xfer_park_call_helper().

{
   const char *name;

   /* The channel variable overrides everything */
   name = pbx_builtin_getvar_helper(chan, "PARKINGLOT");
   if (!name && !ast_strlen_zero(ast_channel_parkinglot(chan))) {
      /* Use the channel's parking lot. */
      name = ast_channel_parkinglot(chan);
   }
   return name;
}

static int finishup

(

struct ast_channel *

chan

)

[static]

Definition at line 2036 of file features.c.

References ast_autoservice_stop(), AST_CONTROL_UNHOLD, and ast_indicate().

Referenced by atxfer_fail_cleanup(), builtin_atxfer(), builtin_blindtransfer(), and xfer_park_call_helper().

{
   ast_indicate(chan, AST_CONTROL_UNHOLD);

   return ast_autoservice_stop(chan);
}

static struct feature_ds* get_feature_ds

(

struct ast_channel *

chan

)

[static, read]

Definition at line 3383 of file features.c.

References ao2_container_alloc, ast_calloc, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_datastore_alloc, ast_datastore::data, feature_ds_destroy(), feature_exten_cmp(), feature_exten_hash(), and feature_ds::feature_map.

Referenced by builtin_feature_get_exten(), feature_write(), featuremap_write(), and get_parkingtime().

{
   struct feature_ds *feature_ds;
   struct ast_datastore *ds;

   if ((ds = ast_channel_datastore_find(chan, &feature_ds_info, NULL))) {
      feature_ds = ds->data;
      return feature_ds;
   }

   if (!(feature_ds = ast_calloc(1, sizeof(*feature_ds)))) {
      return NULL;
   }

   if (!(feature_ds->feature_map = ao2_container_alloc(7, feature_exten_hash, feature_exten_cmp))) {
      feature_ds_destroy(feature_ds);
      return NULL;
   }

   if (!(ds = ast_datastore_alloc(&feature_ds_info, NULL))) {
      feature_ds_destroy(feature_ds);
      return NULL;
   }

   ds->data = feature_ds;

   ast_channel_datastore_add(chan, ds);

   return feature_ds;
}

static struct ast_exten* get_parking_exten	(	const char *	exten_str,
		struct ast_channel *	chan,
		const char *	context
	)			[static, read]

Definition at line 960 of file features.c.

References ast_debug, ast_get_extension_app(), E_MATCH, parkcall, pbx_find_extension(), and pbx_find_info::stacklen.

Referenced by ast_masq_park_call_exten(), ast_park_call_exten(), ast_parking_ext_valid(), builtin_atxfer(), and builtin_blindtransfer().

{
   struct ast_exten *exten;
   struct pbx_find_info q = { .stacklen = 0 }; /* the rest is reset in pbx_find_extension */
   const char *app_at_exten;

   ast_debug(4, "Checking if %s@%s is a parking exten\n", exten_str, context);
   exten = pbx_find_extension(chan, NULL, &q, context, exten_str, 1, NULL, NULL,
      E_MATCH);
   if (!exten) {
      return NULL;
   }

   app_at_exten = ast_get_extension_app(exten);
   if (!app_at_exten || strcasecmp(parkcall, app_at_exten)) {
      return NULL;
   }

   return exten;
}

static unsigned int get_parkingtime	(	struct ast_channel *	chan,
		struct ast_parkinglot *	parkinglot
	)			[static]

Definition at line 8807 of file features.c.

References ast_channel_lock, ast_channel_parkinglot(), ast_channel_unlock, ast_strdupa, ast_strlen_zero(), ast_parkinglot::cfg, default_parkinglot, find_parkinglot(), get_feature_ds(), parkinglot_addref(), parkinglot_unref(), parkinglot_cfg::parkingtime, feature_ds::parkingtime, feature_ds::parkingtime_is_set, and S_OR.

Referenced by feature_read(), and park_call_full().

{
   const char *parkinglot_name;
   struct feature_ds *feature_ds;
   unsigned int parkingtime;

   ast_channel_lock(chan);

   feature_ds = get_feature_ds(chan);
   if (feature_ds && feature_ds->parkingtime_is_set) {
      parkingtime = feature_ds->parkingtime;
      ast_channel_unlock(chan);
      return parkingtime;
   }

   parkinglot_name = ast_strdupa(S_OR(ast_channel_parkinglot(chan), ""));

   ast_channel_unlock(chan);

   if (!parkinglot) {
      if (!ast_strlen_zero(parkinglot_name)) {
         parkinglot = find_parkinglot(parkinglot_name);
      }

      if (!parkinglot) {
         parkinglot = parkinglot_addref(default_parkinglot);
      }
   } else {
      /* Just to balance the unref below */
      parkinglot_addref(parkinglot);
   }

   parkingtime = parkinglot->cfg.parkingtime;

   parkinglot_unref(parkinglot);

   return parkingtime;
}

static char* handle_feature_show	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)			[static]

CLI command to list configured features.

Parameters:

	e
	cmd
	a

Return values:

	CLI_SUCCESS	on success.
	NULL	when tab completion is used.

Definition at line 7089 of file features.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli(), AST_CLI_YESNO, AST_LIST_TRAVERSE, ast_pickup_ext(), AST_RWLIST_EMPTY, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_rwlock_rdlock, ast_rwlock_unlock, ast_parkinglot::cfg, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, parkinglot_cfg::comebackcontext, parkinglot_cfg::comebackdialtime, parkinglot_cfg::comebacktoorigin, ast_cli_entry::command, ast_call_feature::default_exten, ast_parkinglot::disabled, feature_group_exten::exten, ast_call_feature::exten, ast_cli_args::fd, feature_group_exten::feature, feature_group::features, FEATURES_COUNT, features_lock, ast_call_feature::fname, feature_group::gname, HFS_FORMAT, parkinglot_cfg::mohclass, ast_parkinglot::name, parkinglot_cfg::parkext, parkinglot_cfg::parking_con, parkinglot_cfg::parking_start, parkinglot_cfg::parking_stop, parkinglots, parkinglot_cfg::parkingtime, ast_call_feature::sname, and ast_cli_entry::usage.

{
   int i;
   struct ast_call_feature *feature;
   struct ao2_iterator iter;
   struct ast_parkinglot *curlot;
#define HFS_FORMAT "%-25s %-7s %-7s\n"

   switch (cmd) {

   case CLI_INIT:
      e->command = "features show";
      e->usage =
         "Usage: features show\n"
         "       Lists configured features\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   ast_cli(a->fd, HFS_FORMAT, "Builtin Feature", "Default", "Current");
   ast_cli(a->fd, HFS_FORMAT, "---------------", "-------", "-------");

   ast_cli(a->fd, HFS_FORMAT, "Pickup", "*8", ast_pickup_ext());          /* default hardcoded above, so we'll hardcode it here */

   ast_rwlock_rdlock(&features_lock);
   for (i = 0; i < FEATURES_COUNT; i++)
      ast_cli(a->fd, HFS_FORMAT, builtin_features[i].fname, builtin_features[i].default_exten, builtin_features[i].exten);
   ast_rwlock_unlock(&features_lock);

   ast_cli(a->fd, "\n");
   ast_cli(a->fd, HFS_FORMAT, "Dynamic Feature", "Default", "Current");
   ast_cli(a->fd, HFS_FORMAT, "---------------", "-------", "-------");
   if (AST_RWLIST_EMPTY(&feature_list)) {
      ast_cli(a->fd, "(none)\n");
   } else {
      AST_RWLIST_RDLOCK(&feature_list);
      AST_RWLIST_TRAVERSE(&feature_list, feature, feature_entry) {
         ast_cli(a->fd, HFS_FORMAT, feature->sname, "no def", feature->exten);
      }
      AST_RWLIST_UNLOCK(&feature_list);
   }

   ast_cli(a->fd, "\nFeature Groups:\n");
   ast_cli(a->fd, "---------------\n");
   if (AST_RWLIST_EMPTY(&feature_groups)) {
      ast_cli(a->fd, "(none)\n");
   } else {
      struct feature_group *fg;
      struct feature_group_exten *fge;

      AST_RWLIST_RDLOCK(&feature_groups);
      AST_RWLIST_TRAVERSE(&feature_groups, fg, entry) {
         ast_cli(a->fd, "===> Group: %s\n", fg->gname);
         AST_LIST_TRAVERSE(&fg->features, fge, entry) {
            ast_cli(a->fd, "===> --> %s (%s)\n", fge->feature->sname, fge->exten);
         }
      }
      AST_RWLIST_UNLOCK(&feature_groups);
   }

   iter = ao2_iterator_init(parkinglots, 0);
   while ((curlot = ao2_iterator_next(&iter))) {
      ast_cli(a->fd, "\nCall parking (Parking lot: %s)\n", curlot->name);
      ast_cli(a->fd, "------------\n");
      ast_cli(a->fd,"%-22s:      %s\n", "Parking extension", curlot->cfg.parkext);
      ast_cli(a->fd,"%-22s:      %s\n", "Parking context", curlot->cfg.parking_con);
      ast_cli(a->fd,"%-22s:      %d-%d\n", "Parked call extensions",
         curlot->cfg.parking_start, curlot->cfg.parking_stop);
      ast_cli(a->fd,"%-22s:      %u ms\n", "Parkingtime", curlot->cfg.parkingtime);
      ast_cli(a->fd,"%-22s:      %s\n", "Comeback to origin",
            (curlot->cfg.comebacktoorigin ? "yes" : "no"));
      ast_cli(a->fd,"%-22s:      %s%s\n", "Comeback context",
            curlot->cfg.comebackcontext, (curlot->cfg.comebacktoorigin ?
               " (comebacktoorigin=yes, not used)" : ""));
      ast_cli(a->fd,"%-22s:      %d\n", "Comeback dial time",
            curlot->cfg.comebackdialtime);
      ast_cli(a->fd,"%-22s:      %s\n", "MusicOnHold class", curlot->cfg.mohclass);
      ast_cli(a->fd,"%-22s:      %s\n", "Enabled", AST_CLI_YESNO(!curlot->disabled));
      ast_cli(a->fd,"\n");
      ao2_ref(curlot, -1);
   }
   ao2_iterator_destroy(&iter);

   return CLI_SUCCESS;
}

static char* handle_features_reload	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)			[static]

Definition at line 7202 of file features.c.

References ast_features_reload(), CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_cli_entry::command, and ast_cli_entry::usage.

{
   switch (cmd) {
   case CLI_INIT:
      e->command = "features reload";
      e->usage =
         "Usage: features reload\n"
         "       Reloads configured call features from features.conf\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }
   ast_features_reload();

   return CLI_SUCCESS;
}

static char* handle_parkedcalls	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)			[static]

CLI command to list parked calls.

Parameters:

	e
	cmd
	a	Check right usage, lock parking lot, display parked calls, unlock parking lot list.

Return values:

	CLI_SUCCESS	on success.
	CLI_SHOWUSAGE	on incorrect number of arguments.
	NULL	when tab completion is used.

Definition at line 7421 of file features.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli_args::argc, ast_cli_entry::args, ast_channel_name(), ast_cli(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, parkeduser::chan, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, parkeduser::context, default_parkinglot, ESS, parkeduser::exten, ast_cli_args::fd, ast_parkinglot::name, parkeduser::parkingexten, parkinglots, ast_parkinglot::parkings, parkeduser::parkingtime, parkeduser::priority, parkeduser::start, and ast_cli_entry::usage.

{
   struct parkeduser *cur;
   int numparked = 0;
   struct ao2_iterator iter;
   struct ast_parkinglot *curlot;

   switch (cmd) {
   case CLI_INIT:
      e->command = "parkedcalls show";
      e->usage =
         "Usage: parkedcalls show\n"
         "       List currently parked calls\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   if (a->argc > e->args)
      return CLI_SHOWUSAGE;

   ast_cli(a->fd, "%-10s %-25s (%-15s %-12s %4s) %s\n", "Num", "Channel",
      "Context", "Extension", "Pri", "Timeout");

   iter = ao2_iterator_init(parkinglots, 0);
   while ((curlot = ao2_iterator_next(&iter))) {
      int lotparked = 0;

      /* subtract ref for iterator and for configured parking lot */
      ast_cli(a->fd, "*** Parking lot: %s (%d)\n", curlot->name,
         ao2_ref(curlot, 0) - 2 - (curlot == default_parkinglot));

      AST_LIST_LOCK(&curlot->parkings);
      AST_LIST_TRAVERSE(&curlot->parkings, cur, list) {
         ast_cli(a->fd, "%-10.10s %-25s (%-15s %-12s %4d) %6lds\n",
            cur->parkingexten, ast_channel_name(cur->chan), cur->context, cur->exten,
            cur->priority,
            (long) (cur->start.tv_sec + (cur->parkingtime / 1000) - time(NULL)));
         ++lotparked;
      }
      AST_LIST_UNLOCK(&curlot->parkings);
      if (lotparked) {
         numparked += lotparked;
         ast_cli(a->fd, "   %d parked call%s in parking lot %s\n", lotparked,
            ESS(lotparked), curlot->name);
      }

      ao2_ref(curlot, -1);
   }
   ao2_iterator_destroy(&iter);

   ast_cli(a->fd, "---\n%d parked call%s in total.\n", numparked, ESS(numparked));

   return CLI_SUCCESS;
}

static int load_config

(

int

reload

)

[static]

Definition at line 7007 of file features.c.

References ao2_t_callback, ast_config_destroy(), ast_config_load2(), ast_debug, AST_LIST_HEAD_NOLOCK_INIT_VALUE, ast_log(), build_dialplan_useage_map(), build_parkinglot(), CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEMISSING, CONFIG_STATUS_FILEUNCHANGED, DEFAULT_PARKINGLOT, default_parkinglot, destroy_dialplan_usage_map(), force_reload_load, LOG_ERROR, LOG_WARNING, OBJ_NODATA, OBJ_UNLINK, parkinglot_activate_cb(), parkinglot_is_marked_cb(), parkinglot_markall_cb(), parkinglots, process_config(), and remove_dead_dialplan_useage().

{
   struct ast_flags config_flags = {
      reload && !force_reload_load ? CONFIG_FLAG_FILEUNCHANGED : 0 };
   struct ast_config *cfg;
   struct parking_dp_map old_usage_map = AST_LIST_HEAD_NOLOCK_INIT_VALUE;
   struct parking_dp_map new_usage_map = AST_LIST_HEAD_NOLOCK_INIT_VALUE;

   /* We are reloading now and have already determined if we will force the reload. */
   force_reload_load = 0;

   if (!default_parkinglot) {
      /* Must create the default default parking lot */
      default_parkinglot = build_parkinglot(DEFAULT_PARKINGLOT, NULL);
      if (!default_parkinglot) {
         ast_log(LOG_ERROR, "Configuration of default default parking lot failed.\n");
         return -1;
      }
      ast_debug(1, "Configuration of default default parking lot done.\n");
   }

   cfg = ast_config_load2("features.conf", "features", config_flags);
   if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
      /* No sense in asking for reload trouble if nothing changed. */
      ast_debug(1, "features.conf did not change.\n");
      return 0;
   }
   if (cfg == CONFIG_STATUS_FILEMISSING
      || cfg == CONFIG_STATUS_FILEINVALID) {
      ast_log(LOG_WARNING, "Could not load features.conf\n");
      return 0;
   }

   /* Save current parking lot dialplan needs. */
   if (build_dialplan_useage_map(&old_usage_map, 0)) {
      destroy_dialplan_usage_map(&old_usage_map);

      /* Allow reloading later to see if conditions have improved. */
      force_reload_load = 1;
      return -1;
   }

   ao2_t_callback(parkinglots, OBJ_NODATA, parkinglot_markall_cb, NULL,
      "callback to mark all parking lots");
   process_config(cfg);
   ast_config_destroy(cfg);
   ao2_t_callback(parkinglots, OBJ_NODATA | OBJ_UNLINK, parkinglot_is_marked_cb, NULL,
      "callback to remove marked parking lots");

   /* Save updated parking lot dialplan needs. */
   if (build_dialplan_useage_map(&new_usage_map, 1)) {
      /*
       * Yuck, if this failure caused any parking lot dialplan items
       * to be lost, they will likely remain lost until Asterisk is
       * restarted.
       */
      destroy_dialplan_usage_map(&old_usage_map);
      destroy_dialplan_usage_map(&new_usage_map);
      return -1;
   }

   /* Remove no longer needed parking lot dialplan usage. */
   remove_dead_dialplan_useage(&old_usage_map, &new_usage_map);

   destroy_dialplan_usage_map(&old_usage_map);
   destroy_dialplan_usage_map(&new_usage_map);

   ao2_t_callback(parkinglots, OBJ_NODATA, parkinglot_activate_cb, NULL,
      "callback to activate all parking lots");

   return 0;
}

static int manage_parked_call	(	struct parkeduser *	pu,
		const struct pollfd *	pfds,
		int	nfds,
		struct pollfd **	new_pfds,
		int *	new_nfds,
		int *	ms
	)			[static]

Definition at line 4962 of file features.c.

References ast_add_extension(), AST_CEL_PARK_END, ast_cel_report_event(), ast_channel_context(), ast_channel_datastore_find(), ast_channel_exten(), ast_channel_fd(), ast_channel_fd_isset(), ast_channel_fdno_set(), ast_channel_flags(), ast_channel_generatordata(), ast_channel_lock, ast_channel_name(), ast_channel_priority(), ast_channel_unlock, ast_clear_flag, ast_context_find_or_create(), AST_CONTROL_HANGUP, AST_CONTROL_HOLD, AST_CONTROL_RINGING, AST_CONTROL_UNHOLD, ast_debug, AST_FLAG_EXCEPTION, AST_FRAME_CONTROL, ast_free_ptr, ast_frfree, ast_hangup(), ast_indicate(), ast_indicate_data(), ast_log(), AST_MAX_EXTENSION, ast_pbx_start(), ast_read(), ast_realloc, ast_set_flag, ast_strdup, ast_strdupa, ast_strlen_zero(), ast_tvdiff_ms(), ast_tvnow(), ast_verb, callback_dialoptions(), ast_parkinglot::cfg, parkeduser::chan, parkinglot_cfg::comebackcontext, parkinglot_cfg::comebackdialtime, parkinglot_cfg::comebacktoorigin, parkeduser::context, ast_datastore::data, dial_features_info, parkeduser::exten, f, ast_frame::frametype, parkeduser::hold_method, ast_frame_subclass::integer, LOG_ERROR, LOG_NOTICE, LOG_WARNING, MAX_DIAL_FEATURE_OPTIONS, parkeduser::moh_trys, parkinglot_cfg::mohclass, ast_dial_features::my_features, ast_parkinglot::name, parkeduser::options_specified, parking_con_dial, parkeduser::parkinglot, parkeduser::parkingnum, parkeduser::parkingtime, pbx_builtin_setvar_helper(), ast_dial_features::peer_features, parkeduser::peername, post_manager_event(), parkeduser::priority, registrar, S_OR, set_c_e_p(), parkeduser::start, and ast_frame::subclass.

Referenced by manage_parkinglot().

{
   struct ast_channel *chan = pu->chan;   /* shorthand */
   int tms;        /* timeout for this item */
   int x;          /* fd index in channel */

   tms = ast_tvdiff_ms(ast_tvnow(), pu->start);
   if (tms > pu->parkingtime) {
      /*
       * Call has been parked too long.
       * Stop entertaining the caller.
       */
      switch (pu->hold_method) {
      case AST_CONTROL_HOLD:
         ast_indicate(pu->chan, AST_CONTROL_UNHOLD);
         break;
      case AST_CONTROL_RINGING:
         ast_indicate(pu->chan, -1);
         break;
      default:
         break;
      }
      pu->hold_method = 0;

      /* Get chan, exten from derived kludge */
      if (pu->peername[0]) {
         char *peername;
         char *dash;
         char *peername_flat; /* using something like DAHDI/52 for an extension name is NOT a good idea */
         int i;

         peername = ast_strdupa(pu->peername);
         dash = strrchr(peername, '-');
         if (dash) {
            *dash = '\0';
         }

         peername_flat = ast_strdupa(peername);
         for (i = 0; peername_flat[i]; i++) {
            if (peername_flat[i] == '/') {
               peername_flat[i] = '_';
            }
         }

         if (!ast_context_find_or_create(NULL, NULL, parking_con_dial, registrar)) {
            ast_log(LOG_ERROR,
               "Parking dial context '%s' does not exist and unable to create\n",
               parking_con_dial);
         } else {
            char returnexten[AST_MAX_EXTENSION];
            char comebackdialtime[AST_MAX_EXTENSION];
            struct ast_datastore *features_datastore;
            struct ast_dial_features *dialfeatures;

            if (!strncmp(peername, "Parked/", 7)) {
               peername += 7;
            }

            ast_channel_lock(chan);
            features_datastore = ast_channel_datastore_find(chan, &dial_features_info,
               NULL);
            if (features_datastore && (dialfeatures = features_datastore->data)) {
               char buf[MAX_DIAL_FEATURE_OPTIONS] = {0,};

               snprintf(returnexten, sizeof(returnexten), "%s,%u,%s", peername,
                  pu->parkinglot->cfg.comebackdialtime,
                  callback_dialoptions(&dialfeatures->peer_features,
                     &dialfeatures->my_features, buf, sizeof(buf)));
            } else { /* Existing default */
               ast_log(LOG_NOTICE, "Dial features not found on %s, using default!\n",
                  ast_channel_name(chan));
               snprintf(returnexten, sizeof(returnexten), "%s,%u,t", peername,
                  pu->parkinglot->cfg.comebackdialtime);
            }
            ast_channel_unlock(chan);

            snprintf(comebackdialtime, sizeof(comebackdialtime), "%u",
                  pu->parkinglot->cfg.comebackdialtime);
            pbx_builtin_setvar_helper(chan, "COMEBACKDIALTIME", comebackdialtime);

            pbx_builtin_setvar_helper(chan, "PARKER", peername);

            if (ast_add_extension(parking_con_dial, 1, peername_flat, 1, NULL, NULL,
               "Dial", ast_strdup(returnexten), ast_free_ptr, registrar)) {
               ast_log(LOG_ERROR,
                  "Could not create parking return dial exten: %s@%s\n",
                  peername_flat, parking_con_dial);
            }
         }
         if (pu->options_specified) {
            /*
             * Park() was called with overriding return arguments, respect
             * those arguments.
             */
            set_c_e_p(chan, pu->context, pu->exten, pu->priority);
         } else if (pu->parkinglot->cfg.comebacktoorigin) {
            set_c_e_p(chan, parking_con_dial, peername_flat, 1);
         } else {
            char parkingslot[AST_MAX_EXTENSION];

            snprintf(parkingslot, sizeof(parkingslot), "%d", pu->parkingnum);
            pbx_builtin_setvar_helper(chan, "PARKINGSLOT", parkingslot);
            pbx_builtin_setvar_helper(chan, "PARKEDLOT", pu->parkinglot->name);
            set_c_e_p(chan, pu->parkinglot->cfg.comebackcontext, peername_flat, 1);
         }
      } else {
         /*
          * They've been waiting too long, send them back to where they
          * came.  Theoretically they should have their original
          * extensions and such, but we copy to be on the safe side.
          */
         set_c_e_p(chan, pu->context, pu->exten, pu->priority);
      }
      post_manager_event("ParkedCallTimeOut", pu);
      ast_cel_report_event(pu->chan, AST_CEL_PARK_END, NULL, "ParkedCallTimeOut", NULL);

      ast_verb(2, "Timeout for %s parked on %d (%s). Returning to %s,%s,%d\n",
         ast_channel_name(pu->chan), pu->parkingnum, pu->parkinglot->name, ast_channel_context(pu->chan),
         ast_channel_exten(pu->chan), ast_channel_priority(pu->chan));

      /* Start up the PBX, or hang them up */
      if (ast_pbx_start(chan))  {
         ast_log(LOG_WARNING,
            "Unable to restart the PBX for user on '%s', hanging them up...\n",
            ast_channel_name(pu->chan));
         ast_hangup(chan);
      }

      /* And take them out of the parking lot */
      return 1;
   }

   /* still within parking time, process descriptors */
   if (pfds) {
      for (x = 0; x < AST_MAX_FDS; x++) {
         struct ast_frame *f;
         int y;

         if (!ast_channel_fd_isset(chan, x)) {
            continue;   /* nothing on this descriptor */
         }

         for (y = 0; y < nfds; y++) {
            if (pfds[y].fd == ast_channel_fd(chan, x)) {
               /* Found poll record! */
               break;
            }
         }
         if (y == nfds) {
            /* Not found */
            continue;
         }

         if (!(pfds[y].revents & (