chan_iax2.c File Reference

Implementation of Inter-Asterisk eXchange Version 2 as specified in RFC 5456. More...

#include "asterisk.h"
#include <sys/mman.h>
#include <dirent.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netinet/in_systm.h>
#include <netinet/ip.h>
#include <sys/time.h>
#include <signal.h>
#include <netdb.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <regex.h>
#include "asterisk/paths.h"
#include "asterisk/lock.h"
#include "asterisk/frame.h"
#include "asterisk/channel.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/sched.h"
#include "asterisk/io.h"
#include "asterisk/config.h"
#include "asterisk/cli.h"
#include "asterisk/translate.h"
#include "asterisk/md5.h"
#include "asterisk/crypto.h"
#include "asterisk/acl.h"
#include "asterisk/manager.h"
#include "asterisk/callerid.h"
#include "asterisk/app.h"
#include "asterisk/mwi.h"
#include "asterisk/astdb.h"
#include "asterisk/musiconhold.h"
#include "asterisk/features.h"
#include "asterisk/utils.h"
#include "asterisk/causes.h"
#include "asterisk/localtime.h"
#include "asterisk/dnsmgr.h"
#include "asterisk/devicestate.h"
#include "asterisk/stringfields.h"
#include "asterisk/linkedlists.h"
#include "asterisk/astobj2.h"
#include "asterisk/timing.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/test.h"
#include "asterisk/security_events.h"
#include "asterisk/stasis_endpoints.h"
#include "asterisk/bridge.h"
#include "asterisk/stasis.h"
#include "asterisk/stasis_system.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/format_cache.h"
#include "asterisk/format_compatibility.h"
#include "asterisk/format_cap.h"
#include "iax2/include/iax2.h"
#include "iax2/include/firmware.h"
#include "iax2/include/parser.h"
#include "iax2/include/provision.h"
#include "iax2/include/codec_pref.h"
#include "iax2/include/format_compatibility.h"
#include "iax2/include/netsock.h"
#include "jitterbuf.h"

Go to the source code of this file.

Data Structures
struct	active_list
struct	addr_range
struct	call_number_pool
struct	chan_iax2_pvt
struct	create_addr_info
struct	dpcache
struct	dpreq_data
struct	dynamic_list
struct	iax2_context
struct	iax2_dpcache
struct	iax2_peer
struct	iax2_pkt_buf
struct	iax2_registry
struct	iax2_thread
struct	iax2_trunk_peer
struct	iax2_user
struct	iax_rr
struct	idle_list
struct	parsed_dial_string
struct	peercnt
struct	registrations
struct	show_peers_context
struct	chan_iax2_pvt::signaling_queue
struct	signaling_queue_entry
struct	tpeers

Macros
#define	ACN_FORMAT1   "%-24.25s %4u %4d %4d %5d %3d %5d %4d %6d %4d %4d %5d %3d %5d %4d %6d %s%s %4s%s\n"
#define	ACN_FORMAT2   "%s %u %d %d %d %d %d %d %d %d %d %d %d %d %d %d %s%s %s%s\n"
#define	AUTH_METHOD_NAMES_BUFSIZE   19
#define	CALLNO_ENTRY_GET_CALLNO(a)   ((a) & 0x7FFF)
#define	CALLNO_ENTRY_IS_VALIDATED(a)   ((a) & 0x8000)
#define	CALLNO_ENTRY_SET_VALIDATED(a)   ((a) |= 0x8000)
#define	CALLNO_ENTRY_TO_PTR(a)   ((void *)(unsigned long)(a))
#define	CALLNO_TO_PTR(a)   ((void *)(unsigned long)(a))
#define	CALLTOKEN_HASH_FORMAT   "%s%u%d" /* address + port + ts + randomcalldata */
#define	CALLTOKEN_IE_FORMAT   "%u?%s" /* time + ? + (40 char hash) */
#define	DEBUG_SCHED_MULTITHREAD
#define	DEBUG_SUPPORT
#define	DEFAULT_CONTEXT   "default"
#define	DEFAULT_DROP   3
#define	DEFAULT_FREQ_NOTOK   10 * 1000 /* How often to check, if the host is down... */
#define	DEFAULT_FREQ_OK   60 * 1000 /* How often to check for the host to be up */
#define	DEFAULT_MAX_THREAD_COUNT   100
#define	DEFAULT_MAXMS   2000 /* Must be faster than 2 seconds by default */
#define	DEFAULT_RETRY_TIME   1000
#define	DEFAULT_THREAD_COUNT   10
#define	DEFAULT_TRUNKDATA   640 * 10
#define	FORMAT   "%-15.15s %-20.20s %-15.15s %-15.15s %-5.5s %-5.10s\n"
#define	FORMAT   "%-45.45s %-6.6s %-10.10s %-45.45s %8d %s\n"
#define	FORMAT   "%-20.20s %-40.40s %-10.10s %5.5d/%5.5d %5.5d/%5.5d %-5.5dms %-4.4dms %-4.4dms %-6.6s %s%s %3s%s\n"
#define	FORMAT2   "%-15.15s %-20.20s %-15.15d %-15.15s %-5.5s %-5.10s\n"
#define	FORMAT2   "%-45.45s %-6.6s %-10.10s %-45.45s %8.8s %s\n"
#define	FORMAT2   "%-20.20s %-40.40s %-10.10s %-11.11s %-11.11s %-7.7s %-6.6s %-6.6s %s %s %9s\n"
#define	FORMATB   "%-20.20s %-40.40s %-10.10s %5.5d/%5.5d %5.5d/%5.5d [Native Bridged to ID=%5.5d]\n"
#define	GAMMA   (0.01)
#define	IAX2_TRUNK_PREFACE   (sizeof(struct iax_frame) + sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr))
#define	IAX_ALLOWFWDOWNLOAD   (uint64_t)(1LLU << 26)
#define	IAX_ALREADYGONE   (uint64_t)(1LLU << 9)
#define	IAX_CALLENCRYPTED(pvt)    (ast_test_flag64(pvt, IAX_ENCRYPTED) && ast_test_flag64(pvt, IAX_KEYPOPULATED))
#define	IAX_CAPABILITY_FULLBANDWIDTH   0xFFFF
#define	IAX_CAPABILITY_LOWBANDWIDTH
#define	IAX_CAPABILITY_LOWFREE
#define	IAX_CAPABILITY_MEDBANDWIDTH
#define	IAX_CODEC_NOCAP   (uint64_t)(1LLU << 16)
#define	IAX_CODEC_NOPREFS   (uint64_t)(1LLU << 15)
#define	IAX_CODEC_USER_FIRST   (uint64_t)(1LLU << 14)
#define	IAX_DEBUGDIGEST(msg, key)
#define	IAX_DELAYPBXSTART   (uint64_t)(1LLU << 25)
#define	IAX_DELME   (uint64_t)(1LLU << 1)
#define	IAX_DYNAMIC   (uint64_t)(1LLU << 6)
#define	IAX_ENCRYPTED   (uint64_t)(1LLU << 12)
#define	IAX_FORCE_ENCRYPT   (uint64_t)(1LLU << 30)
#define	IAX_HASCALLERID   (uint64_t)(1LLU << 0)
#define	IAX_IMMEDIATE   (uint64_t)(1LLU << 27)
#define	IAX_KEYPOPULATED   (uint64_t)(1LLU << 13)
#define	IAX_MAXAUTHREQ   (uint64_t)(1LLU << 24)
#define	IAX_NOTRANSFER   (uint64_t)(1LLU << 4)
#define	IAX_PROVISION   (uint64_t)(1LLU << 10)
#define	IAX_QUELCH   (uint64_t)(1LLU << 11)
#define	IAX_RECVCONNECTEDLINE   (uint64_t)(1LLU << 29)
#define	IAX_RTAUTOCLEAR   (uint64_t)(1LLU << 19)
#define	IAX_RTCACHEFRIENDS   (uint64_t)(1LLU << 17)
#define	IAX_RTIGNOREREGEXPIRE   (uint64_t)(1LLU << 21)
#define	IAX_RTSAVE_SYSNAME   (uint64_t)(1LLU << 8)
#define	IAX_RTUPDATE   (uint64_t)(1LLU << 18)
#define	IAX_SENDANI   (uint64_t)(1LLU << 7)
#define	IAX_SENDCONNECTEDLINE   (uint64_t)(1LLU << 28)
#define	IAX_SHRINKCALLERID   (uint64_t)(1LLU << 31)
#define	IAX_TEMPONLY   (uint64_t)(1LLU << 2)
#define	IAX_TRANSFERMEDIA   (uint64_t)(1LLU << 23)
#define	IAX_TRUNK   (uint64_t)(1LLU << 3)
#define	IAX_TRUNKTIMESTAMPS   (uint64_t)(1LLU << 22)
#define	IAX_USEJITTERBUF   (uint64_t)(1LLU << 5)
#define	MARK_IAX_SUBCLASS_TX   0x8000
#define	MAX_JITTER_BUFFER   50
#define	MAX_PEER_BUCKETS   563
#define	MAX_RETRY_TIME   10000
#define	MAX_TIMESTAMP_SKEW   160
#define	MAX_TRUNK_MTU   1240
	Maximum transmission unit for the UDP packet in the trunk not to be fragmented. This is based on 1516 - ethernet - ip - udp - iax minus one g711 frame = 1240. More...
#define	MAX_TRUNKDATA   640 * 200
#define	MAX_USER_BUCKETS   MAX_PEER_BUCKETS
#define	MEMORY_SIZE   100
#define	MIN_JITTER_BUFFER   10
#define	MIN_RETRY_TIME   100
#define	MIN_REUSE_TIME   60 /* Don't reuse a call number within 60 seconds */
#define	PEERS_FORMAT   "%-15.15s %-40.40s %s %-40.40s %-6s%s %s %-11s %-32.32s\n"
#define	PEERS_FORMAT2   "%-15.15s %-40.40s %s %-40.40s %-9s %s %-11s %-32.32s\n"
#define	PTR_TO_CALLNO(a)   ((unsigned short)(unsigned long)(a))
#define	PTR_TO_CALLNO_ENTRY(a)   ((uint16_t)(unsigned long)(a))
#define	SCHED_MULTITHREADED
#define	schedule_action(func, data)   __schedule_action(func, data, __PRETTY_FUNCTION__)
#define	TRUNK_CALL_START   (IAX_MAX_CALLS / 2)
#define	TS_GAP_FOR_JB_RESYNC   5000

Typedefs
typedef uint16_t	callno_entry

Enumerations
enum	{   CACHE_FLAG_EXISTS = (1 << 0) , CACHE_FLAG_NONEXISTENT = (1 << 1) , CACHE_FLAG_CANEXIST = (1 << 2) , CACHE_FLAG_PENDING = (1 << 3) ,   CACHE_FLAG_TIMEOUT = (1 << 4) , CACHE_FLAG_TRANSMITTED = (1 << 5) , CACHE_FLAG_UNKNOWN = (1 << 6) , CACHE_FLAG_MATCHMORE = (1 << 7) }
enum	{ NEW_PREVENT = 0 , NEW_ALLOW = 1 , NEW_FORCE = 2 , NEW_ALLOW_CALLTOKEN_VALIDATED = 3 }
enum	callno_type { CALLNO_TYPE_NORMAL , CALLNO_TYPE_TRUNK }
enum	calltoken_peer_enum { CALLTOKEN_DEFAULT = 0 , CALLTOKEN_YES = 1 , CALLTOKEN_AUTO = 2 , CALLTOKEN_NO = 3 }
	Call token validation settings. More...
enum	iax2_state { IAX_STATE_STARTED = (1 << 0) , IAX_STATE_AUTHENTICATED = (1 << 1) , IAX_STATE_TBD = (1 << 2) }
enum	iax2_thread_iostate { IAX_IOSTATE_IDLE , IAX_IOSTATE_READY , IAX_IOSTATE_PROCESSING , IAX_IOSTATE_SCHEDREADY }
enum	iax2_thread_type { IAX_THREAD_TYPE_POOL , IAX_THREAD_TYPE_DYNAMIC }
enum	iax_reg_state {   REG_STATE_UNREGISTERED = 0 , REG_STATE_REGSENT , REG_STATE_AUTHSENT , REG_STATE_REGISTERED ,   REG_STATE_REJECTED , REG_STATE_TIMEOUT , REG_STATE_NOAUTH }
enum	iax_transfer_state {   TRANSFER_NONE = 0 , TRANSFER_BEGIN , TRANSFER_READY , TRANSFER_RELEASED ,   TRANSFER_PASSTHROUGH , TRANSFER_MBEGIN , TRANSFER_MREADY , TRANSFER_MRELEASED ,   TRANSFER_MPASSTHROUGH , TRANSFER_MEDIA , TRANSFER_MEDIAPASS }

Functions
static void	__attempt_transmit (const void *data)
static void	__auth_reject (const void *nothing)
static void	__auto_congest (const void *nothing)
static void	__auto_hangup (const void *nothing)
static int	__do_deliver (void *data)
static void	__expire_registry (const void *data)
static int	__find_callno (unsigned short callno, unsigned short dcallno, struct ast_sockaddr *addr, int new, int sockfd, int return_locked, int check_dcallno)
static void	__get_from_jb (const void *p)
static void	__iax2_do_register_s (const void *data)
static void	__iax2_poke_noanswer (const void *data)
static void	__iax2_poke_peer_s (const void *data)
static int	__iax2_show_peers (int fd, int *total, struct mansession *s, const int argc, const char *const argv[])
static void	__reg_module (void)
static int	__schedule_action (void(*func)(const void *data), const void *data, const char *funcname)
static int	__send_command (struct chan_iax2_pvt *i, char type, int command, unsigned int ts, const unsigned char *data, int datalen, int seqno, int now, int transfer, int final)
static void	__send_lagrq (const void *data)
static void	__send_ping (const void *data)
static int	__unload_module (void)
static void	__unreg_module (void)
static void	_iax2_show_peers_one (int fd, struct mansession *s, struct show_peers_context *cont, struct iax2_peer *peer)
static int	acf_channel_read (struct ast_channel *chan, const char *funcname, char *preparse, char *buf, size_t buflen)
static int	acf_iaxvar_read (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
static int	acf_iaxvar_write (struct ast_channel *chan, const char *cmd, char *data, const char *value)
static void	acl_change_stasis_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	acl_change_stasis_subscribe (void)
static void	acl_change_stasis_unsubscribe (void)
static int	add_calltoken_ignore (const char *addr)
static void	add_empty_calltoken_ie (struct chan_iax2_pvt *pvt, struct iax_ie_data *ied)
static int	addr_range_cmp_cb (void *obj, void *arg, int flags)
static int	addr_range_delme_cb (void *obj, void *arg, int flags)
static int	addr_range_hash_cb (const void *obj, const int flags)
static int	addr_range_match_address_cb (void *obj, void *arg, int flags)
static int	apply_context (struct iax2_context *con, const char *context)
static int	ast_cli_netstats (struct mansession *s, int fd, int limit_fmt)
static struct ast_channel *	ast_iax2_new (int callno, int state, iax2_format capability, struct iax2_codec_pref *prefs, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, unsigned int cachable)
	Create new call, interface with the PBX core. More...
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	attempt_transmit (const void *data)
static int	auth_fail (int callno, int failcode)
static char *	auth_method_names (int authmethods, char *restrict buf)
	Get names of all auth methods. More...
static int	auth_reject (const void *data)
static int	authenticate (const char *challenge, const char *secret, const char *keyn, int authmethods, struct iax_ie_data *ied, struct ast_sockaddr *addr, struct chan_iax2_pvt *pvt)
static int	authenticate_reply (struct chan_iax2_pvt *p, struct ast_sockaddr *addr, struct iax_ies *ies, const char *override, const char *okey)
static int	authenticate_request (int call_num)
static int	authenticate_verify (struct chan_iax2_pvt *p, struct iax_ies *ies)
static int	auto_congest (const void *data)
static int	auto_hangup (const void *data)
static void	build_callno_limits (struct ast_variable *v)
static struct iax2_context *	build_context (const char *context)
static void	build_ecx_key (const unsigned char *digest, struct chan_iax2_pvt *pvt)
static void	build_encryption_keys (const unsigned char *digest, struct chan_iax2_pvt *pvt)
static struct iax2_peer *	build_peer (const char *name, struct ast_variable *v, struct ast_variable *alt, int temponly)
	Create peer structure based on configuration. More...
static void	build_rand_pad (unsigned char *buf, ssize_t len)
static struct iax2_user *	build_user (const char *name, struct ast_variable *v, struct ast_variable *alt, int temponly)
	Create in-memory user structure from configuration. More...
static int	cache_get_callno_locked (const char *data)
static unsigned int	calc_rxstamp (struct chan_iax2_pvt *p, unsigned int offset)
static unsigned int	calc_timestamp (struct chan_iax2_pvt *p, unsigned int ts, struct ast_frame *f)
static unsigned int	calc_txpeerstamp (struct iax2_trunk_peer *tpeer, int sampms, struct timeval *now)
static int	calltoken_required (struct ast_sockaddr *addr, const char *name, int subclass)
static int	check_access (int callno, struct ast_sockaddr *addr, struct iax_ies *ies)
static int	check_provisioning (struct ast_sockaddr *addr, int sockfd, char *si, unsigned int ver)
static int	check_srcaddr (struct ast_sockaddr *addr)
	Check if address can be used as packet source. More...
static void	cleanup_thread_list (void *head)
static struct ast_format *	codec_choose_from_prefs (struct iax2_codec_pref *pref, struct ast_format_cap *cap)
static int	complete_dpreply (struct chan_iax2_pvt *pvt, struct iax_ies *ies)
static char *	complete_iax2_peers (const char *line, const char *word, int pos, int state, uint64_t flags)
static char *	complete_iax2_unregister (const char *line, const char *word, int pos, int state)
static int	complete_transfer (int callno, struct iax_ies *ies)
static unsigned char	compress_subclass (iax2_format subclass)
static void	construct_rr (struct chan_iax2_pvt *pvt, struct iax_ie_data *iep)
static int	create_addr (const char *peername, struct ast_channel *c, struct ast_sockaddr *addr, struct create_addr_info *cai)
static int	create_callno_pools (void)
static int	decode_frame (ast_aes_decrypt_key *dcx, struct ast_iax2_full_hdr *fh, struct ast_frame *f, int *datalen)
static int	decrypt_frame (int callno, struct ast_iax2_full_hdr *fh, struct ast_frame *f, int *datalen)
static void	defer_full_frame (struct iax2_thread *from_here, struct iax2_thread *to_here)
	Queue the last read full frame for processing by a certain thread. More...
static void	delete_users (void)
static void	dp_lookup (int callno, const char *context, const char *callednum, const char *callerid, int skiplock)
static void *	dp_lookup_thread (void *data)
static void	encmethods_to_str (int e, struct ast_str **buf)
static int	encrypt_frame (ast_aes_encrypt_key *ecx, struct ast_iax2_full_hdr *fh, unsigned char *poo, int *datalen)
static int	expire_registry (const void *data)
static struct iax2_dpcache *	find_cache (struct ast_channel *chan, const char *data, const char *context, const char *exten, int priority)
static int	find_callno (unsigned short callno, unsigned short dcallno, struct ast_sockaddr *addr, int new, int sockfd, int full_frame)
static int	find_callno_locked (unsigned short callno, unsigned short dcallno, struct ast_sockaddr *addr, int new, int sockfd, int full_frame)
static struct iax2_thread *	find_idle_thread (void)
static struct iax2_peer *	find_peer (const char *name, int realtime)
static struct iax2_trunk_peer *	find_tpeer (struct ast_sockaddr *addr, int fd)
static struct iax2_user *	find_user (const char *name)
static int	firmware_show_callback (struct ast_iax2_firmware_header *header, void *user_data)
static unsigned int	fix_peerts (struct timeval *rxtrunktime, int callno, unsigned int ts)
static void	free_context (struct iax2_context *con)
static void	free_signaling_queue_entry (struct signaling_queue_entry *s)
static int	function_iaxpeer (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
static int	get_auth_methods (const char *value)
static int	get_encrypt_methods (const char *s)
static int	get_from_jb (const void *p)
static int	get_unused_callno (enum callno_type type, int validated, callno_entry *entry)
static int	handle_call_token (struct ast_iax2_full_hdr *fh, struct iax_ies *ies, struct ast_sockaddr *addr, int fd)
static char *	handle_cli_iax2_provision (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_prune_realtime (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_reload (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_set_debug (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_set_debug_jb (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_set_debug_trunk (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_set_mtu (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Set trunk MTU from CLI. More...
static char *	handle_cli_iax2_show_cache (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_callno_limits (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_channels (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_firmware (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_netstats (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_peer (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Show one peer in detail. More...
static char *	handle_cli_iax2_show_peers (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_registry (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_stats (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_threads (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_show_users (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_test_losspct (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_iax2_unregister (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void	handle_deferred_full_frames (struct iax2_thread *thread)
	Handle any deferred full frames for this thread. More...
static int	handle_error (void)
static int	iax2_ack_registry (struct iax_ies *ies, struct ast_sockaddr *addr, int callno)
	Acknowledgment received for OUR registration. More...
static int attribute_pure	iax2_allow_new (int frametype, int subclass, int inbound)
static int	iax2_answer (struct ast_channel *c)
static int	iax2_append_register (const char *hostname, const char *username, const char *secret, const char *porta)
static int	iax2_call (struct ast_channel *c, const char *dest, int timeout)
static int	iax2_canmatch (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
	part of the IAX2 dial plan switch interface More...
static iax2_format	iax2_codec_choose (struct iax2_codec_pref *pref, iax2_format formats)
static unsigned int	iax2_datetime (const char *tz)
static int	iax2_delete_from_sched (const void *data)
static void	iax2_destroy (int callno)
static void	iax2_destroy_helper (struct chan_iax2_pvt *pvt)
static int	iax2_devicestate (const char *data)
	Part of the device state notification system —. More...
static int	iax2_digit_begin (struct ast_channel *c, char digit)
static int	iax2_digit_end (struct ast_channel *c, char digit, unsigned int duration)
static int	iax2_do_register (struct iax2_registry *reg)
static int	iax2_do_register_s (const void *data)
static void	iax2_dprequest (struct iax2_dpcache *dp, int callno)
static void *	iax2_dup_variable_datastore (void *)
static int	iax2_exec (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
	Execute IAX2 dialplan switch. More...
static int	iax2_exists (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
	Part of the IAX2 switch interface. More...
static int	iax2_fixup (struct ast_channel *oldchannel, struct ast_channel *newchan)
static void	iax2_frame_free (struct iax_frame *fr)
static void	iax2_free_variable_datastore (void *)
const char *	iax2_getformatname (iax2_format format)
	iax2 wrapper function for ast_getformatname More...
static const char *	iax2_getformatname_multiple (iax2_format format, struct ast_str **codec_buf)
static int	iax2_getpeername (struct ast_sockaddr addr, char *host, int len)
static int	iax2_getpeertrunk (struct ast_sockaddr addr)
static int	iax2_hangup (struct ast_channel *c)
static int	iax2_indicate (struct ast_channel *c, int condition, const void *data, size_t datalen)
static int	iax2_is_control_frame_allowed (int subtype)
static int	iax2_key_rotate (const void *vpvt)
static int	iax2_lock_callno_unless_destroyed (int callno)
	Acquire the iaxsl[callno] if call exists and not having ongoing hangup. More...
static void	iax2_lock_owner (int callno)
static int	iax2_matchmore (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
	Part of the IAX2 Switch interface. More...
static int	iax2_parse_allow_disallow (struct iax2_codec_pref *pref, iax2_format *formats, const char *list, int allowing)
static int	iax2_poke_noanswer (const void *data)
static int	iax2_poke_peer (struct iax2_peer *peer, int heldcall)
static int	iax2_poke_peer_cb (void *obj, void *arg, int flags)
static int	iax2_poke_peer_s (const void *data)
static int	iax2_predestroy (int callno)
static void *	iax2_process_thread (void *data)
static void	iax2_process_thread_cleanup (void *data)
static int	iax2_prov_app (struct ast_channel *chan, const char *data)
static int	iax2_provision (struct ast_sockaddr *end, int sockfd, const char *dest, const char *template, int force)
static void	iax2_publish_registry (const char *username, const char *domain, const char *status, const char *cause)
static int	iax2_queryoption (struct ast_channel *c, int option, void *data, int *datalen)
static int	iax2_queue_frame (int callno, struct ast_frame *f)
	Queue a frame to a call's owning asterisk channel. More...
static int	iax2_queue_hangup (int callno)
	Queue a hangup frame on the ast_channel owner. More...
static int	iax2_queue_hold (int callno, const char *musicclass)
	Queue a hold frame on the ast_channel owner. More...
static int	iax2_queue_unhold (int callno)
	Queue an unhold frame on the ast_channel owner. More...
static struct ast_frame *	iax2_read (struct ast_channel *c)
static int	iax2_register (const char *value, int lineno)
static struct ast_channel *	iax2_request (const char *type, struct ast_format_cap *cap, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, const char *data, int *cause)
static int	iax2_sched_add (struct ast_sched_context *sched, int when, ast_sched_cb callback, const void *data)
static int	iax2_sched_replace (int id, struct ast_sched_context *con, int when, ast_sched_cb callback, const void *data)
static int	iax2_send (struct chan_iax2_pvt *pvt, struct ast_frame *f, unsigned int ts, int seqno, int now, int transfer, int final)
static int	iax2_sendhtml (struct ast_channel *c, int subclass, const char *data, int datalen)
static int	iax2_sendimage (struct ast_channel *c, struct ast_frame *img)
static int	iax2_sendtext (struct ast_channel *c, const char *text)
static int	iax2_setoption (struct ast_channel *c, int option, void *data, int datalen)
static int	iax2_transfer (struct ast_channel *c, const char *dest)
static int	iax2_transmit (struct iax_frame *fr)
static int	iax2_trunk_expired (struct iax2_trunk_peer *tpeer, struct timeval *now)
static int	iax2_trunk_queue (struct chan_iax2_pvt *pvt, struct iax_frame *fr)
static int	iax2_vnak (int callno)
static int	iax2_write (struct ast_channel *c, struct ast_frame *f)
static void	iax_debug_output (const char *data)
static void	iax_error_output (const char *data)
static void	iax_outputframe (struct iax_frame *f, struct ast_iax2_full_hdr *fhi, int rx, struct ast_sockaddr *addr, int datalen)
static ast_callid	iax_pvt_callid_get (int callno)
static void	iax_pvt_callid_new (int callno)
static void	iax_pvt_callid_set (int callno, ast_callid callid)
static struct iax_frame *	iaxfrdup2 (struct iax_frame *fr)
static void	insert_idle_thread (struct iax2_thread *thread)
static int	invalid_key (ast_aes_decrypt_key *ecx)
static void	jb_debug_output (const char *fmt,...)
static void	jb_error_output (const char *fmt,...)
static void	jb_warning_output (const char *fmt,...)
static int	load_module (void)
	Load the module. More...
static int	load_objects (void)
static void	log_jitterstats (unsigned short callno)
static int	make_trunk (unsigned short callno, int locked)
static int	manager_iax2_show_netstats (struct mansession *s, const struct message *m)
static int	manager_iax2_show_peer_list (struct mansession *s, const struct message *m)
	callback to display iax peers in manager format More...
static int	manager_iax2_show_peers (struct mansession *s, const struct message *m)
	callback to display iax peers in manager More...
static int	manager_iax2_show_registry (struct mansession *s, const struct message *m)
static int	match (struct ast_sockaddr *addr, unsigned short callno, unsigned short dcallno, const struct chan_iax2_pvt *cur, int check_dcallno)
static void	memcpy_decrypt (unsigned char *dst, const unsigned char *src, int len, ast_aes_decrypt_key *dcx)
static void	memcpy_encrypt (unsigned char *dst, const unsigned char *src, int len, ast_aes_encrypt_key *ecx)
static void	merge_encryption (struct chan_iax2_pvt *p, unsigned int enc)
static int	network_change_sched_cb (const void *data)
static void	network_change_stasis_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	network_change_stasis_subscribe (void)
static void	network_change_stasis_unsubscribe (void)
static void *	network_thread (void *ignore)
static struct chan_iax2_pvt *	new_iax (struct ast_sockaddr *addr, const char *host)
static void	parse_dial_string (char *data, struct parsed_dial_string *pds)
	Parses an IAX dial string into its component parts. More...
static int	peer_cmp_cb (void *obj, void *arg, int flags)
static int	peer_delme_cb (void *obj, void *arg, int flags)
static void	peer_destructor (void *obj)
static int	peer_hash_cb (const void *obj, const int flags)
static struct iax2_peer *	peer_ref (struct iax2_peer *peer)
static int	peer_set_sock_cb (void *obj, void *arg, int flags)
static int	peer_set_srcaddr (struct iax2_peer *peer, const char *srcaddr)
	Parse the "sourceaddress" value, lookup in netsock list and set peer's sockfd. Defaults to defaultsockfd if not found. More...
static int	peer_status (struct iax2_peer *peer, char *status, int statuslen)
	peer_status: Report Peer status in character string More...
static struct iax2_peer *	peer_unref (struct iax2_peer *peer)
static int	peercnt_add (struct ast_sockaddr *addr)
static int	peercnt_cmp_cb (void *obj, void *arg, int flags)
static int	peercnt_hash_cb (const void *obj, const int flags)
static void	peercnt_modify (unsigned char reg, uint16_t limit, struct ast_sockaddr *sockaddr)
static void	peercnt_remove (struct peercnt *peercnt)
static int	peercnt_remove_by_addr (struct ast_sockaddr *addr)
static int	peercnt_remove_cb (const void *obj)
static void	poke_all_peers (void)
static int	prune_addr_range_cb (void *obj, void *arg, int flags)
static void	prune_peers (void)
static void	prune_users (void)
static int	pvt_cmp_cb (void *obj, void *arg, int flags)
static void	pvt_destructor (void *obj)
static int	pvt_hash_cb (const void *obj, const int flags)
static int	queue_signalling (struct chan_iax2_pvt *pvt, struct ast_frame *f)
	All frames other than that of type AST_FRAME_IAX must be held until we have received a destination call number. More...
static int	raw_hangup (struct ast_sockaddr *addr, unsigned short src, unsigned short dst, int sockfd)
static struct iax2_peer *	realtime_peer (const char *peername, struct ast_sockaddr *addr)
static void	realtime_update_peer (const char *peername, struct ast_sockaddr *sockaddr, time_t regtime)
static struct iax2_user *	realtime_user (const char *username, struct ast_sockaddr *addr)
static void	reg_source_db (struct iax2_peer *p)
static void	register_peer_exten (struct iax2_peer *peer, int onoff)
static int	register_verify (int callno, struct ast_sockaddr *addr, struct iax_ies *ies)
	Verify inbound registration. More...
static int	registry_authrequest (int callno)
static int	registry_rerequest (struct iax_ies *ies, int callno, struct ast_sockaddr *addr)
static char *	regstate2str (int regstate)
static int	reload (void)
static int	reload_config (int forced_reload)
static void	remove_by_peercallno (struct chan_iax2_pvt *pvt)
static void	remove_by_transfercallno (struct chan_iax2_pvt *pvt)
static int	replace_callno (const void *obj)
static void	requirecalltoken_mark_auto (const char *name, int subclass)
static void	resend_with_token (int callno, struct iax_frame *f, const char *newtoken)
static void	save_osptoken (struct iax_frame *fr, struct iax_ies *ies)
static void	save_rr (struct iax_frame *fr, struct iax_ies *ies)
static void	sched_delay_remove (struct ast_sockaddr *addr, callno_entry entry)
static int	schedule_delivery (struct iax_frame *fr, int updatehistory, int fromtrunk, unsigned int *tsout)
static int	scheduled_destroy (const void *vid)
static int	send_apathetic_reply (unsigned short callno, unsigned short dcallno, struct ast_sockaddr *addr, int command, int ts, unsigned char seqno, int sockfd, struct iax_ie_data *ied)
static int	send_command (struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int)
static int	send_command_final (struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int)
static int	send_command_immediate (struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int)
static int	send_command_locked (unsigned short callno, char, int, unsigned int, const unsigned char *, int, int)
static int	send_command_transfer (struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int)
static int	send_lagrq (const void *data)
static int	send_packet (struct iax_frame *f)
static int	send_ping (const void *data)
static void	send_signaling (struct chan_iax2_pvt *pvt)
	This function must be called once we are sure the other side has given us a call number. All signaling is held here until that point. More...
static int	send_trunk (struct iax2_trunk_peer *tpeer, struct timeval *now)
static int	set_config (const char *config_file, int reload, int forced)
	Load configuration. More...
static void	set_config_destroy (void)
static void	set_hangup_source_and_cause (int callno, unsigned char causecode)
static void	set_peercnt_limit (struct peercnt *peercnt)
static int	set_peercnt_limit_all_cb (void *obj, void *arg, int flags)
static void	signal_condition (ast_mutex_t *lock, ast_cond_t *cond)
static int	socket_process (struct iax2_thread *thread)
static int	socket_process_helper (struct iax2_thread *thread)
static int	socket_process_meta (int packet_len, struct ast_iax2_meta_hdr *meta, struct ast_sockaddr *addr, int sockfd, struct iax_frame *fr)
static int	socket_read (int *id, int fd, short events, void *cbdata)
static void	spawn_dp_lookup (int callno, const char *context, const char *callednum, const char *callerid)
static int	start_network_thread (void)
static void	stop_stuff (int callno)
static void	store_by_peercallno (struct chan_iax2_pvt *pvt)
static void	store_by_transfercallno (struct chan_iax2_pvt *pvt)
static int	timing_read (int *id, int fd, short events, void *cbdata)
static int	transfercallno_pvt_cmp_cb (void *obj, void *arg, int flags)
static int	transfercallno_pvt_hash_cb (const void *obj, const int flags)
static int	transmit_frame (void *data)
static int	transmit_trunk (struct iax_frame *f, struct ast_sockaddr *addr, int sockfd)
static int	try_transfer (struct chan_iax2_pvt *pvt, struct iax_ies *ies)
static iax2_format	uncompress_subclass (unsigned char csub)
static void	unlink_peer (struct iax2_peer *peer)
static int	unload_module (void)
static void	unwrap_timestamp (struct iax_frame *fr)
static void	update_jbsched (struct chan_iax2_pvt *pvt)
static int	update_packet (struct iax_frame *f)
static int	update_registry (struct ast_sockaddr *addr, int callno, char *devtype, int fd, unsigned short refresh)
static int	user_cmp_cb (void *obj, void *arg, int flags)
static int	user_delme_cb (void *obj, void *arg, int flags)
static void	user_destructor (void *obj)
static int	user_hash_cb (const void *obj, const int flags)
static struct iax2_user *	user_unref (struct iax2_user *user)
static void	vnak_retransmit (int callno, int last)
static int	wait_for_peercallno (struct chan_iax2_pvt *pvt)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Inter Asterisk eXchange (Ver 2)" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CHANNEL_DRIVER, .requires = "dnsmgr", .optional_modules = "res_crypto", }
static char	accountcode [AST_MAX_ACCOUNT_CODE]
static struct stasis_subscription *	acl_change_sub
static struct active_list	active_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static int	adsi = 0
static int	amaflags = 0
static const struct ast_module_info *	ast_module_info = &__mod_info
static const char *	auth_method_labels []
	Name of effective auth method. More...
static int	authdebug = 0
static int	autokill = 0
static struct ao2_container *	callno_limits
static struct call_number_pool	callno_pool
static ast_mutex_t	callno_pool_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static struct call_number_pool	callno_pool_trunk
static struct ao2_container *	calltoken_ignores
static struct ast_cli_entry	cli_iax2 []
static struct ast_sockaddr	debugaddr
static uint16_t	DEFAULT_MAXCALLNO_LIMIT = 2048
static uint16_t	DEFAULT_MAXCALLNO_LIMIT_NONVAL = 8192
static char	default_parkinglot [AST_MAX_CONTEXT]
static int	defaultsockfd = -1
static int	delayreject = 0
static struct dpcache	dpcache = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static struct dynamic_list	dynamic_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
struct {
struct iax_frame *   first
struct iax_frame *   last
}	frame_queue [IAX_MAX_CALLS]
	a list of frames that may need to be retransmitted More...
static int	global_max_trunk_mtu
static uint16_t	global_maxcallno
static uint16_t	global_maxcallno_nonval
static int	global_rtautoclear = 120
static struct ast_flags64	globalflags = { 0 }
static int	iax2_authmethods = 0
static iax2_format	iax2_capability = IAX_CAPABILITY_FULLBANDWIDTH
static int	iax2_encryption = 0
static int(*	iax2_regfunk )(const char *username, int onoff) = NULL
static struct ast_switch	iax2_switch
static struct ast_channel_tech	iax2_tech
static const struct ast_datastore_info	iax2_variable_datastore_info
static struct ao2_container *	iax_peercallno_pvts
	Another container of iax2_pvt structures. More...
static struct ao2_container *	iax_transfercallno_pvts
	Another container of iax2_pvt structures. More...
static int	iaxactivethreadcount = 0
static int	iaxcompat = 0
static int	iaxdebug = 0
static int	iaxdefaultdpcache =10 * 60
static int	iaxdefaulttimeout = 5
static int	iaxdynamicthreadcount = 0
static int	iaxdynamicthreadnum = 0
static int	iaxmaxthreadcount = DEFAULT_MAX_THREAD_COUNT
static struct ast_custom_function	iaxpeer_function
static struct chan_iax2_pvt *	iaxs [IAX_MAX_CALLS]
	an array of iax2 pvt structures More...
static ast_mutex_t	iaxsl [ARRAY_LEN(iaxs)]
	chan_iax2_pvt structure locks More...
static int	iaxthreadcount = DEFAULT_THREAD_COUNT
static int	iaxtrunkdebug = 0
static struct ast_custom_function	iaxvar_function
static struct idle_list	idle_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static struct io_context *	io
static int	jittertargetextra = 40
static int	lagrq_time = 10
static char	language [MAX_LANGUAGE] = ""
static int	last_authmethod = 0
static time_t	max_calltoken_delay = 10
static int	max_reg_expire
static int	max_retries = 4
static int	maxauthreq = 3
static int	maxjitterbuffer =1000
static int	maxjitterinterps =10
static int	min_reg_expire
static char	mohinterpret [MAX_MUSICCLASS]
static char	mohsuggest [MAX_MUSICCLASS]
static struct ast_netsock_list *	netsock
static pthread_t	netthreadid = AST_PTHREADT_NULL
static int	network_change_sched_id = -1
static struct stasis_subscription *	network_change_sub
static struct ast_netsock_list *	outsock
static char *	papp = "IAX2Provision"
static struct ao2_container *	peercnts
static struct ao2_container *	peers
static int	ping_time = 21
static struct iax2_codec_pref	prefs_global
struct {
unsigned int   cos
unsigned int   tos
}	qos = { 0, 0 }
static int	randomcalltokendata
static char	regcontext [AST_MAX_CONTEXT] = ""
static struct registrations	registrations = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static int	resyncthreshold =1000
static struct ast_sched_context *	sched
static int	srvlookup = 0
static const char	tdesc [] = "Inter Asterisk eXchange Driver (Ver 2)"
static int	test_losspct = 0
static struct ast_timer *	timer
static uint16_t	total_nonval_callno_used = 0
static struct tpeers	tpeers = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static struct ast_taskprocessor *	transmit_processor
static int	trunk_maxmtu
static int	trunk_nmaxmtu
static int	trunk_timed
static int	trunk_untimed
static int	trunkfreq = 20
static int	trunkmaxsize = MAX_TRUNKDATA
static struct ao2_container *	users

Detailed Description

Implementation of Inter-Asterisk eXchange Version 2 as specified in RFC 5456.

Author

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

Todo:

Implement musicclass settings for IAX2 devices

Definition in file chan_iax2.c.

Macro Definition Documentation

ACN_FORMAT1

#define ACN_FORMAT1   "%-24.25s %4u %4d %4d %5d %3d %5d %4d %6d %4d %4d %5d %3d %5d %4d %6d %s%s %4s%s\n"

ACN_FORMAT2

#define ACN_FORMAT2   "%s %u %d %d %d %d %d %d %d %d %d %d %d %d %d %d %s%s %s%s\n"

AUTH_METHOD_NAMES_BUFSIZE

#define AUTH_METHOD_NAMES_BUFSIZE   19

Definition at line 407 of file chan_iax2.c.

CALLNO_ENTRY_GET_CALLNO

#define CALLNO_ENTRY_GET_CALLNO

(

a

)

((a) & 0x7FFF)

Definition at line 955 of file chan_iax2.c.

CALLNO_ENTRY_IS_VALIDATED

#define CALLNO_ENTRY_IS_VALIDATED

(

a

)

((a) & 0x8000)

Definition at line 954 of file chan_iax2.c.

CALLNO_ENTRY_SET_VALIDATED

#define CALLNO_ENTRY_SET_VALIDATED

(

a

)

((a) |= 0x8000)

Definition at line 953 of file chan_iax2.c.

CALLNO_ENTRY_TO_PTR

#define CALLNO_ENTRY_TO_PTR

(

a

)

((void *)(unsigned long)(a))

Definition at line 951 of file chan_iax2.c.

CALLNO_TO_PTR

#define CALLNO_TO_PTR

(

a

)

((void *)(unsigned long)(a))

Definition at line 293 of file chan_iax2.c.

CALLTOKEN_HASH_FORMAT

#define CALLTOKEN_HASH_FORMAT   "%s%u%d" /* address + port + ts + randomcalldata */

CALLTOKEN_IE_FORMAT

#define CALLTOKEN_IE_FORMAT   "%u?%s" /* time + ? + (40 char hash) */

DEBUG_SCHED_MULTITHREAD

#define DEBUG_SCHED_MULTITHREAD

Definition at line 285 of file chan_iax2.c.

DEBUG_SUPPORT

#define DEBUG_SUPPORT

Definition at line 301 of file chan_iax2.c.

DEFAULT_CONTEXT

#define DEFAULT_CONTEXT   "default"

Definition at line 320 of file chan_iax2.c.

DEFAULT_DROP

#define DEFAULT_DROP   3

Definition at line 299 of file chan_iax2.c.

DEFAULT_FREQ_NOTOK

#define DEFAULT_FREQ_NOTOK   10 * 1000 /* How often to check, if the host is down... */

Definition at line 396 of file chan_iax2.c.

DEFAULT_FREQ_OK

#define DEFAULT_FREQ_OK   60 * 1000 /* How often to check for the host to be up */

Definition at line 395 of file chan_iax2.c.

DEFAULT_MAX_THREAD_COUNT

#define DEFAULT_MAX_THREAD_COUNT   100

Definition at line 296 of file chan_iax2.c.

DEFAULT_MAXMS

#define DEFAULT_MAXMS   2000 /* Must be faster than 2 seconds by default */

Definition at line 394 of file chan_iax2.c.

DEFAULT_RETRY_TIME

#define DEFAULT_RETRY_TIME   1000

Definition at line 297 of file chan_iax2.c.

DEFAULT_THREAD_COUNT

#define DEFAULT_THREAD_COUNT   10

Definition at line 295 of file chan_iax2.c.

DEFAULT_TRUNKDATA

#define DEFAULT_TRUNKDATA   640 * 10

40ms, uncompressed linear * 10 channels

Definition at line 710 of file chan_iax2.c.

FORMAT [1/3]

#define FORMAT   "%-15.15s %-20.20s %-15.15s %-15.15s %-5.5s %-5.10s\n"

FORMAT [2/3]

#define FORMAT   "%-45.45s %-6.6s %-10.10s %-45.45s %8d %s\n"

FORMAT [3/3]

#define FORMAT   "%-20.20s %-40.40s %-10.10s %5.5d/%5.5d %5.5d/%5.5d %-5.5dms %-4.4dms %-4.4dms %-6.6s %s%s %3s%s\n"

FORMAT2 [1/3]

#define FORMAT2   "%-15.15s %-20.20s %-15.15d %-15.15s %-5.5s %-5.10s\n"

FORMAT2 [2/3]

#define FORMAT2   "%-45.45s %-6.6s %-10.10s %-45.45s %8.8s %s\n"

FORMAT2 [3/3]

#define FORMAT2   "%-20.20s %-40.40s %-10.10s %-11.11s %-11.11s %-7.7s %-6.6s %-6.6s %s %s %9s\n"

FORMATB

#define FORMATB   "%-20.20s %-40.40s %-10.10s %5.5d/%5.5d %5.5d/%5.5d [Native Bridged to ID=%5.5d]\n"

GAMMA

#define GAMMA   (0.01)

Definition at line 306 of file chan_iax2.c.

IAX2_TRUNK_PREFACE

#define IAX2_TRUNK_PREFACE   (sizeof(struct iax_frame) + sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr))

Definition at line 638 of file chan_iax2.c.

IAX_ALLOWFWDOWNLOAD

#define IAX_ALLOWFWDOWNLOAD   (uint64_t)(1LLU << 26)

Allow the FWDOWNL command?

Definition at line 523 of file chan_iax2.c.

IAX_ALREADYGONE

#define IAX_ALREADYGONE   (uint64_t)(1LLU << 9)

Already disconnected

Definition at line 507 of file chan_iax2.c.

IAX_CALLENCRYPTED

#define IAX_CALLENCRYPTED

(

pvt

)

(ast_test_flag64(pvt, IAX_ENCRYPTED) && ast_test_flag64(pvt, IAX_KEYPOPULATED))

Definition at line 440 of file chan_iax2.c.

IAX_CAPABILITY_FULLBANDWIDTH

#define IAX_CAPABILITY_FULLBANDWIDTH   0xFFFF

Definition at line 373 of file chan_iax2.c.

IAX_CAPABILITY_LOWBANDWIDTH

#define IAX_CAPABILITY_LOWBANDWIDTH

Value:

                     (IAX_CAPABILITY_MEDBANDWIDTH & \
                     ~AST_FORMAT_G726 &         \
                     ~AST_FORMAT_G726_AAL2 &    \
                     ~AST_FORMAT_ADPCM)

Definition at line 385 of file chan_iax2.c.

IAX_CAPABILITY_LOWFREE

#define IAX_CAPABILITY_LOWFREE

Value:

                     (IAX_CAPABILITY_LOWBANDWIDTH & \
                     ~AST_FORMAT_G723)

Definition at line 390 of file chan_iax2.c.

IAX_CAPABILITY_MEDBANDWIDTH

#define IAX_CAPABILITY_MEDBANDWIDTH

Definition at line 375 of file chan_iax2.c.

IAX_CODEC_NOCAP

#define IAX_CODEC_NOCAP   (uint64_t)(1LLU << 16)

only consider requested format and ignore capabilities

Definition at line 514 of file chan_iax2.c.

IAX_CODEC_NOPREFS

#define IAX_CODEC_NOPREFS   (uint64_t)(1LLU << 15)

Force old behaviour by turning off prefs

Definition at line 513 of file chan_iax2.c.

IAX_CODEC_USER_FIRST

#define IAX_CODEC_USER_FIRST   (uint64_t)(1LLU << 14)

are we willing to let the other guy choose the codec?

Definition at line 512 of file chan_iax2.c.

IAX_DEBUGDIGEST

#define IAX_DEBUGDIGEST	(		msg,
			key
	)

Definition at line 443 of file chan_iax2.c.

IAX_DELAYPBXSTART

#define IAX_DELAYPBXSTART   (uint64_t)(1LLU << 25)

Don't start a PBX on the channel until the peer sends us a response, so that we've achieved a three-way handshake with them before sending voice or anything else

Definition at line 522 of file chan_iax2.c.

IAX_DELME

#define IAX_DELME   (uint64_t)(1LLU << 1)

Needs to be deleted

Definition at line 499 of file chan_iax2.c.

IAX_DYNAMIC

#define IAX_DYNAMIC   (uint64_t)(1LLU << 6)

dynamic peer

Definition at line 504 of file chan_iax2.c.

IAX_ENCRYPTED

#define IAX_ENCRYPTED   (uint64_t)(1LLU << 12)

Whether we should assume encrypted tx/rx

Definition at line 510 of file chan_iax2.c.

IAX_FORCE_ENCRYPT

#define IAX_FORCE_ENCRYPT   (uint64_t)(1LLU << 30)

Forces call encryption, if encryption not possible hangup

Definition at line 527 of file chan_iax2.c.

IAX_HASCALLERID

#define IAX_HASCALLERID   (uint64_t)(1LLU << 0)

CallerID has been specified

Definition at line 498 of file chan_iax2.c.

IAX_IMMEDIATE

#define IAX_IMMEDIATE   (uint64_t)(1LLU << 27)

Allow immediate off-hook to extension s

Definition at line 524 of file chan_iax2.c.

IAX_KEYPOPULATED

#define IAX_KEYPOPULATED   (uint64_t)(1LLU << 13)

Whether we have a key populated

Definition at line 511 of file chan_iax2.c.

IAX_MAXAUTHREQ

#define IAX_MAXAUTHREQ   (uint64_t)(1LLU << 24)

Maximum outstanding AUTHREQ restriction is in place

Definition at line 521 of file chan_iax2.c.

IAX_NOTRANSFER

#define IAX_NOTRANSFER   (uint64_t)(1LLU << 4)

Don't native bridge

Definition at line 502 of file chan_iax2.c.

IAX_PROVISION

#define IAX_PROVISION   (uint64_t)(1LLU << 10)

This is a provisioning request

Definition at line 508 of file chan_iax2.c.

IAX_QUELCH

#define IAX_QUELCH   (uint64_t)(1LLU << 11)

Whether or not we quelch audio

Definition at line 509 of file chan_iax2.c.

IAX_RECVCONNECTEDLINE

#define IAX_RECVCONNECTEDLINE   (uint64_t)(1LLU << 29)

Allow receiving of connected line updates

Definition at line 526 of file chan_iax2.c.

IAX_RTAUTOCLEAR

#define IAX_RTAUTOCLEAR   (uint64_t)(1LLU << 19)

erase me on expire

Definition at line 517 of file chan_iax2.c.

IAX_RTCACHEFRIENDS

#define IAX_RTCACHEFRIENDS   (uint64_t)(1LLU << 17)

let realtime stay till your reload

Definition at line 515 of file chan_iax2.c.

IAX_RTIGNOREREGEXPIRE

#define IAX_RTIGNOREREGEXPIRE   (uint64_t)(1LLU << 21)

When using realtime, ignore registration expiration

Definition at line 518 of file chan_iax2.c.

IAX_RTSAVE_SYSNAME

#define IAX_RTSAVE_SYSNAME   (uint64_t)(1LLU << 8)

Save Systname on Realtime Updates

Definition at line 506 of file chan_iax2.c.

IAX_RTUPDATE

#define IAX_RTUPDATE   (uint64_t)(1LLU << 18)

Send a realtime update

Definition at line 516 of file chan_iax2.c.

IAX_SENDANI

#define IAX_SENDANI   (uint64_t)(1LLU << 7)

Send ANI along with CallerID

Definition at line 505 of file chan_iax2.c.

IAX_SENDCONNECTEDLINE

#define IAX_SENDCONNECTEDLINE   (uint64_t)(1LLU << 28)

Allow sending of connected line updates

Definition at line 525 of file chan_iax2.c.

IAX_SHRINKCALLERID

#define IAX_SHRINKCALLERID   (uint64_t)(1LLU << 31)

Turn on and off caller id shrinking

Definition at line 528 of file chan_iax2.c.

IAX_TEMPONLY

#define IAX_TEMPONLY   (uint64_t)(1LLU << 2)

Temporary (realtime)

Definition at line 500 of file chan_iax2.c.

IAX_TRANSFERMEDIA

#define IAX_TRANSFERMEDIA   (uint64_t)(1LLU << 23)

When doing IAX2 transfers, transfer media only

Definition at line 520 of file chan_iax2.c.

IAX_TRUNK

#define IAX_TRUNK   (uint64_t)(1LLU << 3)

Treat as a trunk

Definition at line 501 of file chan_iax2.c.

IAX_TRUNKTIMESTAMPS

#define IAX_TRUNKTIMESTAMPS   (uint64_t)(1LLU << 22)

Send trunk timestamps

Definition at line 519 of file chan_iax2.c.

IAX_USEJITTERBUF

#define IAX_USEJITTERBUF   (uint64_t)(1LLU << 5)

Use jitter buffer

Definition at line 503 of file chan_iax2.c.

MARK_IAX_SUBCLASS_TX

#define MARK_IAX_SUBCLASS_TX   0x8000

Definition at line 718 of file chan_iax2.c.

MAX_JITTER_BUFFER

#define MAX_JITTER_BUFFER   50

Definition at line 707 of file chan_iax2.c.

MAX_PEER_BUCKETS

#define MAX_PEER_BUCKETS   563

This module will get much higher performance when doing a lot of user and peer lookups if the number of buckets is increased from 1. However, to maintain old behavior for Asterisk 1.4, these are set to 1 by default. When using multiple buckets, search order through these containers is considered random, so you will not be able to depend on the order the entires are specified in iax.conf for matching order.

Definition at line 998 of file chan_iax2.c.

MAX_RETRY_TIME

#define MAX_RETRY_TIME   10000

Definition at line 705 of file chan_iax2.c.

MAX_TIMESTAMP_SKEW

#define MAX_TIMESTAMP_SKEW   160

maximum difference between actual and predicted ts for sending

Definition at line 712 of file chan_iax2.c.

MAX_TRUNK_MTU

#define MAX_TRUNK_MTU   1240

Maximum transmission unit for the UDP packet in the trunk not to be fragmented. This is based on 1516 - ethernet - ip - udp - iax minus one g711 frame = 1240.

Definition at line 315 of file chan_iax2.c.

MAX_TRUNKDATA

#define MAX_TRUNKDATA   640 * 200

40ms, uncompressed linear * 200 channels

Definition at line 340 of file chan_iax2.c.

MAX_USER_BUCKETS

#define MAX_USER_BUCKETS   MAX_PEER_BUCKETS

Definition at line 1002 of file chan_iax2.c.

MEMORY_SIZE

#define MEMORY_SIZE   100

Definition at line 298 of file chan_iax2.c.

MIN_JITTER_BUFFER

#define MIN_JITTER_BUFFER   10

Definition at line 708 of file chan_iax2.c.

MIN_RETRY_TIME

#define MIN_RETRY_TIME   100

Definition at line 704 of file chan_iax2.c.

MIN_REUSE_TIME

#define MIN_REUSE_TIME   60 /* Don't reuse a call number within 60 seconds */

Definition at line 303 of file chan_iax2.c.

PEERS_FORMAT

#define PEERS_FORMAT   "%-15.15s %-40.40s %s %-40.40s %-6s%s %s %-11s %-32.32s\n"

Definition at line 6943 of file chan_iax2.c.

PEERS_FORMAT2

#define PEERS_FORMAT2   "%-15.15s %-40.40s %s %-40.40s %-9s %s %-11s %-32.32s\n"

Definition at line 6942 of file chan_iax2.c.

PTR_TO_CALLNO

#define PTR_TO_CALLNO

(

a

)

((unsigned short)(unsigned long)(a))

Definition at line 292 of file chan_iax2.c.

PTR_TO_CALLNO_ENTRY

#define PTR_TO_CALLNO_ENTRY

(

a

)

((uint16_t)(unsigned long)(a))

Definition at line 950 of file chan_iax2.c.

SCHED_MULTITHREADED

#define SCHED_MULTITHREADED

Todo:

XXX The IAX2 channel driver needs its native bridge code converted to the new bridge technology scheme.

Note

The chan_dahdi native bridge code can be used as an example. It also appears that chan_iax2 also has a native transfer check like chan_dahdi to eliminate tromboned calls.

The existing native bridge code is marked with the IAX2_NATIVE_BRIDGING conditional.

Definition at line 281 of file chan_iax2.c.

schedule_action

#define schedule_action	(		func,
			data
	)		__schedule_action(func, data, __PRETTY_FUNCTION__)

Definition at line 1724 of file chan_iax2.c.

TRUNK_CALL_START

#define TRUNK_CALL_START   (IAX_MAX_CALLS / 2)

Definition at line 1222 of file chan_iax2.c.

TS_GAP_FOR_JB_RESYNC

#define TS_GAP_FOR_JB_RESYNC   5000

Definition at line 715 of file chan_iax2.c.

Typedef Documentation

callno_entry

typedef uint16_t callno_entry

Definition at line 740 of file chan_iax2.c.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
CACHE_FLAG_EXISTS	Extension exists
CACHE_FLAG_NONEXISTENT	Extension is nonexistent
CACHE_FLAG_CANEXIST	Extension can exist
CACHE_FLAG_PENDING	Waiting to hear back response
CACHE_FLAG_TIMEOUT	Timed out
CACHE_FLAG_TRANSMITTED	Request transmitted
CACHE_FLAG_UNKNOWN	Timeout
CACHE_FLAG_MATCHMORE	Matchmore

Definition at line 1049 of file chan_iax2.c.

     {
    /*! Extension exists */
    CACHE_FLAG_EXISTS      = (1 << 0),
    /*! Extension is nonexistent */
    CACHE_FLAG_NONEXISTENT = (1 << 1),
    /*! Extension can exist */
    CACHE_FLAG_CANEXIST    = (1 << 2),
    /*! Waiting to hear back response */
    CACHE_FLAG_PENDING     = (1 << 3),
    /*! Timed out */
    CACHE_FLAG_TIMEOUT     = (1 << 4),
    /*! Request transmitted */
    CACHE_FLAG_TRANSMITTED = (1 << 5),
    /*! Timeout */
    CACHE_FLAG_UNKNOWN     = (1 << 6),
    /*! Matchmore */
    CACHE_FLAG_MATCHMORE   = (1 << 7),
};

anonymous enum

anonymous enum

Enumerator
NEW_PREVENT
NEW_ALLOW
NEW_FORCE
NEW_ALLOW_CALLTOKEN_VALIDATED

Definition at line 2350 of file chan_iax2.c.

     {
    /* do not allow a new call number, only search ones in use for match */
    NEW_PREVENT = 0,
    /* search for match first, then allow a new one to be allocated */
    NEW_ALLOW = 1,
    /* do not search for match, force a new call number */
    NEW_FORCE = 2,
    /* do not search for match, force a new call number.  Signifies call number
     * has been calltoken validated */
    NEW_ALLOW_CALLTOKEN_VALIDATED = 3,
};

callno_type

enum callno_type

Enumerator
CALLNO_TYPE_NORMAL
CALLNO_TYPE_TRUNK

Definition at line 945 of file chan_iax2.c.

                 {
    CALLNO_TYPE_NORMAL,
    CALLNO_TYPE_TRUNK,
};

calltoken_peer_enum

enum calltoken_peer_enum

Call token validation settings.

Enumerator
CALLTOKEN_DEFAULT	Default calltoken required unless the ip is in the ignorelist.
CALLTOKEN_YES	Require call token validation.
CALLTOKEN_AUTO	Require call token validation after a successful registration using call token validation occurs.
CALLTOKEN_NO	Do not require call token validation.

Definition at line 536 of file chan_iax2.c.

                         {
    /*! \brief Default calltoken required unless the ip is in the ignorelist */
    CALLTOKEN_DEFAULT = 0,
    /*! \brief Require call token validation. */
    CALLTOKEN_YES = 1,
    /*! \brief Require call token validation after a successful registration
     *         using call token validation occurs. */
    CALLTOKEN_AUTO = 2,
    /*! \brief Do not require call token validation. */
    CALLTOKEN_NO = 3,
};

iax2_state

enum iax2_state

Enumerator
IAX_STATE_STARTED
IAX_STATE_AUTHENTICATED
IAX_STATE_TBD

Definition at line 486 of file chan_iax2.c.

                {
    IAX_STATE_STARTED =         (1 << 0),
    IAX_STATE_AUTHENTICATED =   (1 << 1),
    IAX_STATE_TBD =             (1 << 2),
};

iax2_thread_iostate

enum iax2_thread_iostate

Enumerator
IAX_IOSTATE_IDLE
IAX_IOSTATE_READY
IAX_IOSTATE_PROCESSING
IAX_IOSTATE_SCHEDREADY

Definition at line 1090 of file chan_iax2.c.

                         {
    IAX_IOSTATE_IDLE,
    IAX_IOSTATE_READY,
    IAX_IOSTATE_PROCESSING,
    IAX_IOSTATE_SCHEDREADY,
};

iax2_thread_type

enum iax2_thread_type

Enumerator
IAX_THREAD_TYPE_POOL
IAX_THREAD_TYPE_DYNAMIC

Definition at line 1097 of file chan_iax2.c.

                      {
    IAX_THREAD_TYPE_POOL,
    IAX_THREAD_TYPE_DYNAMIC,
};

iax_reg_state

enum iax_reg_state

Enumerator
REG_STATE_UNREGISTERED
REG_STATE_REGSENT
REG_STATE_AUTHSENT
REG_STATE_REGISTERED
REG_STATE_REJECTED
REG_STATE_TIMEOUT
REG_STATE_NOAUTH

Definition at line 661 of file chan_iax2.c.

                   {
    REG_STATE_UNREGISTERED = 0,
    REG_STATE_REGSENT,
    REG_STATE_AUTHSENT,
    REG_STATE_REGISTERED,
    REG_STATE_REJECTED,
    REG_STATE_TIMEOUT,
    REG_STATE_NOAUTH
};

iax_transfer_state

enum iax_transfer_state

Enumerator
TRANSFER_NONE
TRANSFER_BEGIN
TRANSFER_READY
TRANSFER_RELEASED
TRANSFER_PASSTHROUGH
TRANSFER_MBEGIN
TRANSFER_MREADY
TRANSFER_MRELEASED
TRANSFER_MPASSTHROUGH
TRANSFER_MEDIA
TRANSFER_MEDIAPASS

Definition at line 671 of file chan_iax2.c.

                        {
    TRANSFER_NONE = 0,
    TRANSFER_BEGIN,
    TRANSFER_READY,
    TRANSFER_RELEASED,
    TRANSFER_PASSTHROUGH,
    TRANSFER_MBEGIN,
    TRANSFER_MREADY,
    TRANSFER_MRELEASED,
    TRANSFER_MPASSTHROUGH,
    TRANSFER_MEDIA,
    TRANSFER_MEDIAPASS
};

Function Documentation

__attempt_transmit()

static void __attempt_transmit ( const void *  data )

static

Definition at line 3595 of file chan_iax2.c.

{
    /* Attempt to transmit the frame to the remote peer...
       Called without iaxsl held. */
    struct iax_frame *f = (struct iax_frame *)data;
    int freeme = 0;
    int callno = f->callno;
 
    /* Make sure this call is still active */
    if (callno)
        ast_mutex_lock(&iaxsl[callno]);
    if (callno && iaxs[callno]) {
        if (f->retries < 0) {
            /* Already ACK'd */
            freeme = 1;
        } else if (f->retries >= max_retries) {
            /* Too many attempts.  Record an error. */
            if (f->transfer) {
                /* Transfer timeout */
                send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_TXREJ, 0, NULL, 0, -1);
            } else if (f->final) {
                iax2_destroy(callno);
            } else {
                if (iaxs[callno]->owner) {
                    ast_log(LOG_WARNING, "Max retries exceeded to host %s on %s (type = %u, subclass = %d, ts=%u, seqno=%d)\n",
                        ast_sockaddr_stringify_addr(&iaxs[f->callno]->addr),
                        ast_channel_name(iaxs[f->callno]->owner),
                        f->af.frametype,
                        f->af.subclass.integer,
                        f->ts,
                        f->oseqno);
                }
                iaxs[callno]->error = ETIMEDOUT;
                if (iaxs[callno]->owner) {
                    struct ast_frame fr = { AST_FRAME_CONTROL, { AST_CONTROL_HANGUP }, .data.uint32 = AST_CAUSE_DESTINATION_OUT_OF_ORDER };
                    /* Hangup the fd */
                    iax2_queue_frame(callno, &fr); /* XXX */
                    /* Remember, owner could disappear */
                    if (iaxs[callno] && iaxs[callno]->owner)
                        ast_channel_hangupcause_set(iaxs[callno]->owner, AST_CAUSE_DESTINATION_OUT_OF_ORDER);
                } else {
                    if (iaxs[callno]->reg) {
                        memset(&iaxs[callno]->reg->us, 0, sizeof(iaxs[callno]->reg->us));
                        iaxs[callno]->reg->regstate = REG_STATE_TIMEOUT;
                        iaxs[callno]->reg->refresh = IAX_DEFAULT_REG_EXPIRE;
                    }
                    iax2_destroy(callno);
                }
            }
            freeme = 1;
        } else {
            /* Update it if it needs it */
            update_packet(f);
            /* Attempt transmission */
            send_packet(f);
            f->retries++;
            /* Try again later after 10 times as long */
            f->retrytime *= 10;
            if (f->retrytime > MAX_RETRY_TIME)
                f->retrytime = MAX_RETRY_TIME;
            /* Transfer messages max out at one second */
            if (f->transfer && (f->retrytime > 1000))
                f->retrytime = 1000;
            f->retrans = iax2_sched_add(sched, f->retrytime, attempt_transmit, f);
        }
    } else {
        /* Make sure it gets freed */
        f->retries = -1;
        freeme = 1;
    }
 
    if (freeme) {
        /* Don't attempt delivery, just remove it from the queue */
        AST_LIST_REMOVE(&frame_queue[callno], f, list);
        ast_mutex_unlock(&iaxsl[callno]);
        f->retrans = -1; /* this is safe because this is the scheduled function */
        /* Free the IAX frame */
        iax2_frame_free(f);
    } else if (callno) {
        ast_mutex_unlock(&iaxsl[callno]);
    }
}

References chan_iax2_pvt::addr, iax_frame::af, AST_CAUSE_DESTINATION_OUT_OF_ORDER, ast_channel_hangupcause_set(), ast_channel_name(), AST_CONTROL_HANGUP, AST_FRAME_CONTROL, AST_FRAME_IAX, AST_LIST_REMOVE, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_sockaddr_stringify_addr(), attempt_transmit(), iax_frame::callno, iax_frame::data, chan_iax2_pvt::error, iax_frame::final, frame_queue, ast_frame::frametype, iax2_destroy(), iax2_frame_free(), iax2_queue_frame(), iax2_sched_add(), IAX_COMMAND_TXREJ, IAX_DEFAULT_REG_EXPIRE, iaxs, iaxsl, ast_frame_subclass::integer, LOG_WARNING, max_retries, MAX_RETRY_TIME, NULL, iax_frame::oseqno, chan_iax2_pvt::owner, iax2_registry::refresh, chan_iax2_pvt::reg, REG_STATE_TIMEOUT, iax2_registry::regstate, iax_frame::retrans, iax_frame::retries, iax_frame::retrytime, send_command(), send_packet(), ast_frame::subclass, iax_frame::transfer, iax_frame::ts, update_packet(), and iax2_registry::us.

Referenced by attempt_transmit().

__auth_reject()

static void __auth_reject ( const void *  nothing )

static

Definition at line 9424 of file chan_iax2.c.

{
    /* Called from IAX thread only, without iaxs lock */
    int callno = (int)(long)(nothing);
    struct iax_ie_data ied;
    ast_mutex_lock(&iaxsl[callno]);
    if (iaxs[callno]) {
        memset(&ied, 0, sizeof(ied));
        if (iaxs[callno]->authfail == IAX_COMMAND_REGREJ) {
            iax_ie_append_str(&ied, IAX_IE_CAUSE, "Registration Refused");
            iax_ie_append_byte(&ied, IAX_IE_CAUSECODE, AST_CAUSE_FACILITY_REJECTED);
        } else if (iaxs[callno]->authfail == IAX_COMMAND_REJECT) {
            iax_ie_append_str(&ied, IAX_IE_CAUSE, "No authority found");
            iax_ie_append_byte(&ied, IAX_IE_CAUSECODE, AST_CAUSE_FACILITY_NOT_SUBSCRIBED);
        }
        send_command_final(iaxs[callno], AST_FRAME_IAX, iaxs[callno]->authfail, 0, ied.buf, ied.pos, -1);
    }
    ast_mutex_unlock(&iaxsl[callno]);
}

References AST_CAUSE_FACILITY_NOT_SUBSCRIBED, AST_CAUSE_FACILITY_REJECTED, AST_FRAME_IAX, ast_mutex_lock, ast_mutex_unlock, iax_ie_data::buf, IAX_COMMAND_REGREJ, IAX_COMMAND_REJECT, iax_ie_append_byte(), iax_ie_append_str(), IAX_IE_CAUSE, IAX_IE_CAUSECODE, iaxs, iaxsl, iax_ie_data::pos, and send_command_final().

Referenced by auth_reject().

__auto_congest()

static void __auto_congest ( const void *  nothing )

static

Definition at line 4782 of file chan_iax2.c.

{
    int callno = PTR_TO_CALLNO(nothing);
    struct ast_frame f = { AST_FRAME_CONTROL, { AST_CONTROL_CONGESTION } };
    ast_mutex_lock(&iaxsl[callno]);
    if (iaxs[callno]) {
        iaxs[callno]->initid = -1;
        iax2_queue_frame(callno, &f);
        ast_log(LOG_NOTICE, "Auto-congesting call due to slow response\n");
    }
    ast_mutex_unlock(&iaxsl[callno]);
}

References AST_CONTROL_CONGESTION, AST_FRAME_CONTROL, ast_log, ast_mutex_lock, ast_mutex_unlock, iax2_queue_frame(), iaxs, iaxsl, chan_iax2_pvt::initid, LOG_NOTICE, and PTR_TO_CALLNO.

Referenced by auto_congest().

__auto_hangup()

static void __auto_hangup ( const void *  nothing )

static

Definition at line 9473 of file chan_iax2.c.

{
    /* Called from IAX thread only, without iaxs lock */
    int callno = (int)(long)(nothing);
    struct iax_ie_data ied;
    ast_mutex_lock(&iaxsl[callno]);
    if (iaxs[callno]) {
        memset(&ied, 0, sizeof(ied));
        iax_ie_append_str(&ied, IAX_IE_CAUSE, "Timeout");
        iax_ie_append_byte(&ied, IAX_IE_CAUSECODE, AST_CAUSE_NO_USER_RESPONSE);
        send_command_final(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_HANGUP, 0, ied.buf, ied.pos, -1);
    }
    ast_mutex_unlock(&iaxsl[callno]);
}

References AST_CAUSE_NO_USER_RESPONSE, AST_FRAME_IAX, ast_mutex_lock, ast_mutex_unlock, iax_ie_data::buf, IAX_COMMAND_HANGUP, iax_ie_append_byte(), iax_ie_append_str(), IAX_IE_CAUSE, IAX_IE_CAUSECODE, iaxs, iaxsl, iax_ie_data::pos, and send_command_final().

Referenced by auto_hangup().

__do_deliver()

static int __do_deliver ( void *  data )

static

Note

This function assumes that iaxsl[callno] is locked when called.

IMPORTANT NOTE!!! Any time this function is used, even if iaxs[callno] was valid before calling it, it may no longer be valid after calling it. This function calls iax2_queue_frame(), which may unlock and lock the mutex associated with this callno, meaning that another thread may grab it and destroy the call.

Definition at line 3387 of file chan_iax2.c.

{
    /* Just deliver the packet by using queueing.  This is called by
      the IAX thread with the iaxsl lock held. */
    struct iax_frame *fr = data;
    fr->retrans = -1;
    ast_clear_flag(&fr->af, AST_FRFLAG_HAS_TIMING_INFO);
    if (iaxs[fr->callno] && !ast_test_flag64(iaxs[fr->callno], IAX_ALREADYGONE))
        iax2_queue_frame(fr->callno, &fr->af);
    /* Free our iax frame */
    iax2_frame_free(fr);
    /* And don't run again */
    return 0;
}

References iax_frame::af, ast_clear_flag, AST_FRFLAG_HAS_TIMING_INFO, ast_test_flag64, iax_frame::callno, iax_frame::data, iax2_frame_free(), iax2_queue_frame(), IAX_ALREADYGONE, iaxs, and iax_frame::retrans.

Referenced by __get_from_jb(), and schedule_delivery().

__expire_registry()

static void __expire_registry ( const void *  data )

static

Definition at line 9040 of file chan_iax2.c.

{
    struct iax2_peer *peer = (struct iax2_peer *) data;
    RAII_VAR(struct ast_json *, blob, NULL, ast_json_unref);
 
    if (!peer)
        return;
    if (peer->expire == -1) {
        /* Removed already (possibly through CLI), ignore */
        return;
    }
 
    peer->expire = -1;
 
    ast_debug(1, "Expiring registration for peer '%s'\n", peer->name);
    if (ast_test_flag64((&globalflags), IAX_RTUPDATE) && (ast_test_flag64(peer, IAX_TEMPONLY|IAX_RTCACHEFRIENDS)))
        realtime_update_peer(peer->name, &peer->addr, 0);
    ast_endpoint_set_state(peer->endpoint, AST_ENDPOINT_OFFLINE);
    blob = ast_json_pack("{s: s, s: s}",
        "peer_status", "Unregistered",
        "cause", "Expired");
    ast_endpoint_blob_publish(peer->endpoint, ast_endpoint_state_type(), blob);
    /* modify entry in peercnts table as _not_ registered */
    peercnt_modify((unsigned char) 0, 0, &peer->addr);
    /* Reset the address */
    ast_sockaddr_setnull(&peer->addr);
    /* Reset expiry value */
    peer->expiry = min_reg_expire;
    if (!ast_test_flag64(peer, IAX_TEMPONLY))
        ast_db_del("IAX/Registry", peer->name);
    register_peer_exten(peer, 0);
    ast_devstate_changed(AST_DEVICE_UNAVAILABLE, AST_DEVSTATE_CACHABLE, "IAX2/%s", peer->name); /* Activate notification */
    if (iax2_regfunk)
        iax2_regfunk(peer->name, 0);
 
    if (ast_test_flag64(peer, IAX_RTAUTOCLEAR))
        unlink_peer(peer);
 
    peer_unref(peer);
}

References iax2_peer::addr, ast_db_del(), ast_debug, AST_DEVICE_UNAVAILABLE, AST_DEVSTATE_CACHABLE, ast_devstate_changed(), ast_endpoint_blob_publish(), AST_ENDPOINT_OFFLINE, ast_endpoint_set_state(), ast_endpoint_state_type(), ast_json_pack(), ast_json_unref(), ast_sockaddr_setnull(), ast_test_flag64, iax2_peer::endpoint, iax2_peer::expire, iax2_peer::expiry, globalflags, iax2_regfunk, IAX_RTAUTOCLEAR, IAX_RTCACHEFRIENDS, IAX_RTUPDATE, IAX_TEMPONLY, min_reg_expire, iax2_peer::name, NULL, peer_unref(), peercnt_modify(), RAII_VAR, realtime_update_peer(), register_peer_exten(), and unlink_peer().

Referenced by expire_registry().

__find_callno()

static int __find_callno ( unsigned short  callno, unsigned short  dcallno, struct ast_sockaddr *  addr, int  new, int  sockfd, int  return_locked, int  check_dcallno  )

static

Note

Calling this function while holding another pvt lock can cause a deadlock.

Definition at line 3155 of file chan_iax2.c.

{
    int res = 0;
    int x;
    /* this call is calltoken validated as long as it is either NEW_FORCE
     * or NEW_ALLOW_CALLTOKEN_VALIDATED */
    int validated = (new > NEW_ALLOW) ? 1 : 0;
    char host[80];
 
    if (new <= NEW_ALLOW) {
        if (callno) {
            struct chan_iax2_pvt *pvt;
            struct chan_iax2_pvt tmp_pvt = {
                .callno = dcallno,
                .peercallno = callno,
                .transfercallno = callno,
                /* hack!! */
                .frames_received = check_dcallno,
            };
 
            ast_sockaddr_copy(&tmp_pvt.addr, addr);
            /* this works for finding normal call numbers not involving transfering */
            if ((pvt = ao2_find(iax_peercallno_pvts, &tmp_pvt, OBJ_POINTER))) {
                if (return_locked) {
                    ast_mutex_lock(&iaxsl[pvt->callno]);
                }
                res = pvt->callno;
                ao2_ref(pvt, -1);
                pvt = NULL;
                return res;
            }
            /* this searches for transfer call numbers that might not get caught otherwise */
            memset(&tmp_pvt.addr, 0, sizeof(tmp_pvt.addr));
            ast_sockaddr_copy(&tmp_pvt.transfer, addr);
            if ((pvt = ao2_find(iax_transfercallno_pvts, &tmp_pvt, OBJ_POINTER))) {
                if (return_locked) {
                    ast_mutex_lock(&iaxsl[pvt->callno]);
                }
                res = pvt->callno;
                ao2_ref(pvt, -1);
                pvt = NULL;
                return res;
            }
        }
            /* This will occur on the first response to a message that we initiated,
         * such as a PING. */
        if (dcallno) {
            ast_mutex_lock(&iaxsl[dcallno]);
        }
        if (callno && dcallno && iaxs[dcallno] && !iaxs[dcallno]->peercallno && match(addr, callno, dcallno, iaxs[dcallno], check_dcallno)) {
            iaxs[dcallno]->peercallno = callno;
            res = dcallno;
            store_by_peercallno(iaxs[dcallno]);
            if (!res || !return_locked) {
                ast_mutex_unlock(&iaxsl[dcallno]);
            }
            return res;
        }
        if (dcallno) {
            ast_mutex_unlock(&iaxsl[dcallno]);
        }
    }
    if (!res && (new >= NEW_ALLOW)) {
        callno_entry entry;
 
        /* It may seem odd that we look through the peer list for a name for
         * this *incoming* call.  Well, it is weird.  However, users don't
         * have an IP address/port number that we can match against.  So,
         * this is just checking for a peer that has that IP/port and
         * assuming that we have a user of the same name.  This isn't always
         * correct, but it will be changed if needed after authentication. */
        if (!iax2_getpeername(*addr, host, sizeof(host)))
            snprintf(host, sizeof(host), "%s", ast_sockaddr_stringify(addr));
 
        if (peercnt_add(addr)) {
            /* This address has hit its callnumber limit.  When the limit
             * is reached, the connection is not added to the peercnts table.*/
            return 0;
        }
 
        if (get_unused_callno(CALLNO_TYPE_NORMAL, validated, &entry)) {
            /* since we ran out of space, remove the peercnt
             * entry we added earlier */
            peercnt_remove_by_addr(addr);
            ast_log(LOG_WARNING, "No more space\n");
            return 0;
        }
        x = CALLNO_ENTRY_GET_CALLNO(entry);
        ast_mutex_lock(&iaxsl[x]);
 
        iaxs[x] = new_iax(addr, host);
        if (iaxs[x]) {
            if (iaxdebug)
                ast_debug(1, "Creating new call structure %d\n", x);
            iaxs[x]->callno_entry = entry;
            iaxs[x]->sockfd = sockfd;
            ast_sockaddr_copy(&iaxs[x]->addr, addr);
            iaxs[x]->peercallno = callno;
            iaxs[x]->callno = x;
            iaxs[x]->pingtime = DEFAULT_RETRY_TIME;
            iaxs[x]->expiry = min_reg_expire;
            iaxs[x]->pingid = iax2_sched_add(sched, ping_time * 1000, send_ping, (void *)(long)x);
            iaxs[x]->lagid = iax2_sched_add(sched, lagrq_time * 1000, send_lagrq, (void *)(long)x);
            iaxs[x]->amaflags = amaflags;
            ast_copy_flags64(iaxs[x], &globalflags, IAX_NOTRANSFER | IAX_TRANSFERMEDIA | IAX_USEJITTERBUF | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE | IAX_FORCE_ENCRYPT);
            ast_string_field_set(iaxs[x], accountcode, accountcode);
            ast_string_field_set(iaxs[x], mohinterpret, mohinterpret);
            ast_string_field_set(iaxs[x], mohsuggest, mohsuggest);
            ast_string_field_set(iaxs[x], parkinglot, default_parkinglot);
 
            if (iaxs[x]->peercallno) {
                store_by_peercallno(iaxs[x]);
            }
        } else {
            ast_log(LOG_WARNING, "Out of resources\n");
            ast_mutex_unlock(&iaxsl[x]);
            replace_callno(CALLNO_ENTRY_TO_PTR(entry));
            return 0;
        }
        if (!return_locked)
            ast_mutex_unlock(&iaxsl[x]);
        res = x;
    }
    return res;
}

References accountcode, chan_iax2_pvt::addr, amaflags, chan_iax2_pvt::amaflags, ao2_find, ao2_ref, ast_copy_flags64, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_sockaddr_copy(), ast_sockaddr_stringify(), ast_string_field_set, chan_iax2_pvt::callno, chan_iax2_pvt::callno_entry, CALLNO_ENTRY_GET_CALLNO, CALLNO_ENTRY_TO_PTR, CALLNO_TYPE_NORMAL, default_parkinglot, DEFAULT_RETRY_TIME, chan_iax2_pvt::expiry, get_unused_callno(), globalflags, chan_iax2_pvt::host, iax2_getpeername(), iax2_sched_add(), IAX_FORCE_ENCRYPT, IAX_NOTRANSFER, iax_peercallno_pvts, IAX_RECVCONNECTEDLINE, IAX_SENDCONNECTEDLINE, iax_transfercallno_pvts, IAX_TRANSFERMEDIA, IAX_USEJITTERBUF, iaxdebug, iaxs, iaxsl, chan_iax2_pvt::lagid, lagrq_time, LOG_WARNING, match(), min_reg_expire, mohinterpret, mohsuggest, NEW_ALLOW, new_iax(), NULL, OBJ_POINTER, chan_iax2_pvt::parkinglot, chan_iax2_pvt::peercallno, peercnt_add(), peercnt_remove_by_addr(), ping_time, chan_iax2_pvt::pingid, chan_iax2_pvt::pingtime, replace_callno(), send_lagrq(), send_ping(), chan_iax2_pvt::sockfd, store_by_peercallno(), and chan_iax2_pvt::transfer.

Referenced by find_callno(), and find_callno_locked().

__get_from_jb()

static void __get_from_jb ( const void *  p )

static

Definition at line 4172 of file chan_iax2.c.

{
    int callno = PTR_TO_CALLNO(p);
    struct chan_iax2_pvt *pvt = NULL;
    struct iax_frame *fr;
    jb_frame frame;
    int ret;
    long ms;
    long next;
    struct timeval now = ast_tvnow();
    struct ast_format *voicefmt;
 
    /* Make sure we have a valid private structure before going on */
    ast_mutex_lock(&iaxsl[callno]);
    pvt = iaxs[callno];
    if (!pvt) {
        /* No go! */
        ast_mutex_unlock(&iaxsl[callno]);
        return;
    }
 
    pvt->jbid = -1;
 
    /* round up a millisecond since ast_sched_runq does; */
    /* prevents us from spinning while waiting for our now */
    /* to catch up with runq's now */
    now.tv_usec += 1000;
 
    ms = ast_tvdiff_ms(now, pvt->rxcore);
    if (ms >= (next = jb_next(pvt->jb))) {
        voicefmt = ast_format_compatibility_bitfield2format(pvt->voiceformat);
        if (!voicefmt) {
            /* pvt->voiceformat won't be set if we haven't received any voice frames yet.
             * In this case, fall back to using the format negotiated during call setup,
             * so we don't stall the jitterbuffer completely. */
            voicefmt = ast_format_compatibility_bitfield2format(pvt->peerformat);
        }
        if (!voicefmt) {
            /* Really shouldn't happen, but if it does, should be looked into */
            ast_log(LOG_WARNING, "No voice format and no peer format available on %s, backlogging frame\n", ast_channel_name(pvt->owner));
            goto cleanup; /* Don't crash if there's no voice format */
        }
        ret = jb_get(pvt->jb, &frame, ms, ast_format_get_default_ms(voicefmt));
        switch(ret) {
        case JB_OK:
            fr = frame.data;
            __do_deliver(fr);
            /* __do_deliver() can cause the call to disappear */
            pvt = iaxs[callno];
            break;
        case JB_INTERP:
        {
            struct ast_frame af = { 0, };
 
            /* create an interpolation frame */
            af.frametype = AST_FRAME_VOICE;
            af.subclass.format = voicefmt;
            af.samples  = frame.ms * (ast_format_get_sample_rate(voicefmt) / 1000);
            af.src  = "IAX2 JB interpolation";
            af.delivery = ast_tvadd(pvt->rxcore, ast_samp2tv(next, 1000));
            af.offset = AST_FRIENDLY_OFFSET;
 
            /* queue the frame:  For consistency, we would call __do_deliver here, but __do_deliver wants an iax_frame,
             * which we'd need to malloc, and then it would free it.  That seems like a drag */
            if (!ast_test_flag64(iaxs[callno], IAX_ALREADYGONE)) {
                iax2_queue_frame(callno, &af);
                /* iax2_queue_frame() could cause the call to disappear */
                pvt = iaxs[callno];
            }
        }
        break;
        case JB_DROP:
            iax2_frame_free(frame.data);
            break;
        case JB_NOFRAME:
        case JB_EMPTY:
            /* do nothing */
            break;
        default:
            /* shouldn't happen */
            break;
        }
    }
cleanup:
    if (pvt)
        update_jbsched(pvt);
    ast_mutex_unlock(&iaxsl[callno]);
}

References __do_deliver(), ast_channel_name(), ast_format_compatibility_bitfield2format(), ast_format_get_default_ms(), ast_format_get_sample_rate(), AST_FRAME_VOICE, AST_FRIENDLY_OFFSET, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_samp2tv(), ast_test_flag64, ast_tvadd(), ast_tvdiff_ms(), ast_tvnow(), cleanup(), jb_frame::data, ast_frame::delivery, ast_frame_subclass::format, ast_frame::frametype, iax2_frame_free(), iax2_queue_frame(), IAX_ALREADYGONE, iaxs, iaxsl, chan_iax2_pvt::jb, JB_DROP, JB_EMPTY, jb_get(), JB_INTERP, jb_next(), JB_NOFRAME, JB_OK, chan_iax2_pvt::jbid, LOG_WARNING, jb_frame::ms, iax_frame::next, ast_frame::next, NULL, ast_frame::offset, chan_iax2_pvt::owner, chan_iax2_pvt::peerformat, PTR_TO_CALLNO, chan_iax2_pvt::rxcore, ast_frame::samples, ast_frame::src, ast_frame::subclass, update_jbsched(), and chan_iax2_pvt::voiceformat.

Referenced by get_from_jb().

__iax2_do_register_s()

static void __iax2_do_register_s ( const void *  data )

static

Definition at line 8683 of file chan_iax2.c.

{
    struct iax2_registry *reg = (struct iax2_registry *)data;
 
    if (ast_sockaddr_isnull(&reg->addr)) {
        reg->addr.ss.ss_family = AST_AF_UNSPEC;
        ast_dnsmgr_lookup(reg->hostname, &reg->addr, &reg->dnsmgr, srvlookup ? "_iax._udp" : NULL);
        if (!ast_sockaddr_port(&reg->addr)) {
            ast_sockaddr_set_port(&reg->addr, reg->port);
        } else {
            reg->port = ast_sockaddr_port(&reg->addr);
        }
    }
 
    reg->expire = -1;
    iax2_do_register(reg);
}

References iax2_registry::addr, AST_AF_UNSPEC, ast_dnsmgr_lookup(), ast_sockaddr_isnull(), ast_sockaddr_port, ast_sockaddr_set_port, iax2_registry::dnsmgr, iax2_registry::expire, iax2_registry::hostname, iax2_do_register(), NULL, iax2_registry::port, srvlookup, and ast_sockaddr::ss.

Referenced by iax2_do_register_s().

__iax2_poke_noanswer()

static void __iax2_poke_noanswer ( const void *  data )

static

Definition at line 12485 of file chan_iax2.c.

{
    struct iax2_peer *peer = (struct iax2_peer *)data;
    int callno;
 
    if (peer->lastms > -1) {
        RAII_VAR(struct ast_json *, blob, NULL, ast_json_unref);
 
        ast_log(LOG_NOTICE, "Peer '%s' is now UNREACHABLE! Time: %d\n", peer->name, peer->lastms);
        ast_endpoint_set_state(peer->endpoint, AST_ENDPOINT_OFFLINE);
        blob = ast_json_pack("{s: s, s: i}",
            "peer_status", "Unreachable",
            "time", peer->lastms);
        ast_endpoint_blob_publish(peer->endpoint, ast_endpoint_state_type(), blob);
        ast_devstate_changed(AST_DEVICE_UNAVAILABLE, AST_DEVSTATE_CACHABLE, "IAX2/%s", peer->name); /* Activate notification */
    }
    if ((callno = peer->callno) > 0) {
        ast_mutex_lock(&iaxsl[callno]);
        iax2_destroy(callno);
        ast_mutex_unlock(&iaxsl[callno]);
    }
    peer->callno = 0;
    peer->lastms = -1;
    /* Try again quickly */
    peer->pokeexpire = iax2_sched_add(sched, peer->pokefreqnotok, iax2_poke_peer_s, peer_ref(peer));
    if (peer->pokeexpire == -1)
        peer_unref(peer);
}

References AST_DEVICE_UNAVAILABLE, AST_DEVSTATE_CACHABLE, ast_devstate_changed(), ast_endpoint_blob_publish(), AST_ENDPOINT_OFFLINE, ast_endpoint_set_state(), ast_endpoint_state_type(), ast_json_pack(), ast_json_unref(), ast_log, ast_mutex_lock, ast_mutex_unlock, iax2_peer::callno, iax2_peer::endpoint, iax2_destroy(), iax2_poke_peer_s(), iax2_sched_add(), iaxsl, iax2_peer::lastms, LOG_NOTICE, iax2_peer::name, NULL, peer_ref(), peer_unref(), iax2_peer::pokeexpire, iax2_peer::pokefreqnotok, and RAII_VAR.

Referenced by iax2_poke_noanswer().

__iax2_poke_peer_s()

static void __iax2_poke_peer_s ( const void *  data )

static

Definition at line 9533 of file chan_iax2.c.

{
    struct iax2_peer *peer = (struct iax2_peer *)data;
    iax2_poke_peer(peer, 0);
    peer_unref(peer);
}

References iax2_poke_peer(), and peer_unref().

Referenced by iax2_poke_peer_s().

__iax2_show_peers()

static int __iax2_show_peers ( int  fd, int *  total, struct mansession *  s, const int  argc, const char *const  argv[]  )

static

Definition at line 7046 of file chan_iax2.c.

{
    struct show_peers_context cont = {
        .havepattern = 0,
        .idtext = "",
        .registeredonly = 0,
 
        .peerlist = 0,
 
        .total_peers = 0,
        .online_peers = 0,
        .offline_peers = 0,
        .unmonitored_peers = 0,
    };
 
    struct ao2_iterator i;
 
    struct iax2_peer *peer = NULL;
 
    switch (argc) {
    case 6:
        if (!strcasecmp(argv[3], "registered"))
            cont.registeredonly = 1;
        else
            return RESULT_SHOWUSAGE;
        if (!strcasecmp(argv[4], "like")) {
            if (regcomp(&cont.regexbuf, argv[5], REG_EXTENDED | REG_NOSUB))
                return RESULT_SHOWUSAGE;
            cont.havepattern = 1;
        } else
            return RESULT_SHOWUSAGE;
        break;
    case 5:
        if (!strcasecmp(argv[3], "like")) {
            if (regcomp(&cont.regexbuf, argv[4], REG_EXTENDED | REG_NOSUB))
                return RESULT_SHOWUSAGE;
            cont.havepattern = 1;
        } else
            return RESULT_SHOWUSAGE;
        break;
    case 4:
        if (!strcasecmp(argv[3], "registered")) {
            cont.registeredonly = 1;
        } else {
            return RESULT_SHOWUSAGE;
        }
        break;
    case 3:
        break;
    default:
        return RESULT_SHOWUSAGE;
    }
 
 
    if (!s) {
        ast_cli(fd, PEERS_FORMAT2, "Name/Username", "Host", "   ", "Mask", "Port", "   ", "Status", "Description");
    }
 
    i = ao2_iterator_init(peers, 0);
    for (; (peer = ao2_iterator_next(&i)); peer_unref(peer)) {
 
        if (cont.registeredonly && ast_sockaddr_isnull(&peer->addr)) {
            continue;
        }
        if (cont.havepattern && regexec(&cont.regexbuf, peer->name, 0, NULL, 0)) {
            continue;
        }
 
        _iax2_show_peers_one(fd, s, &cont, peer);
 
    }
    ao2_iterator_destroy(&i);
 
    if (!s) {
        ast_cli(fd,"%d iax2 peers [%d online, %d offline, %d unmonitored]\n",
            cont.total_peers, cont.online_peers, cont.offline_peers, cont.unmonitored_peers);
    }
 
    if (cont.havepattern) {
        regfree(&cont.regexbuf);
    }
 
    if (total) {
        *total = cont.total_peers;
    }
 
    return RESULT_SUCCESS;
 
}

References _iax2_show_peers_one(), iax2_peer::addr, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_cli(), ast_sockaddr_isnull(), show_peers_context::havepattern, iax2_peer::name, NULL, show_peers_context::offline_peers, show_peers_context::online_peers, peer_unref(), PEERS_FORMAT2, show_peers_context::regexbuf, show_peers_context::registeredonly, RESULT_SHOWUSAGE, RESULT_SUCCESS, total, show_peers_context::total_peers, and show_peers_context::unmonitored_peers.

Referenced by handle_cli_iax2_show_peers(), and manager_iax2_show_peers().

__reg_module()

static void __reg_module ( void  )

static

Definition at line 15136 of file chan_iax2.c.

__schedule_action()

static int __schedule_action ( void(*)(const void *data)  func, const void *  data, const char *  funcname  )

static

Definition at line 1699 of file chan_iax2.c.

{
    struct iax2_thread *thread;
    static time_t lasterror;
    time_t t;
 
    thread = find_idle_thread();
    if (thread != NULL) {
        thread->schedfunc = func;
        thread->scheddata = data;
        thread->iostate = IAX_IOSTATE_SCHEDREADY;
#ifdef DEBUG_SCHED_MULTITHREAD
        ast_copy_string(thread->curfunc, funcname, sizeof(thread->curfunc));
#endif
        signal_condition(&thread->lock, &thread->cond);
        return 0;
    }
    time(&t);
    if (t != lasterror) {
        lasterror = t;
        ast_debug(1, "Out of idle IAX2 threads for scheduling! (%s)\n", funcname);
    }
 
    return -1;
}

References ast_copy_string(), ast_debug, find_idle_thread(), IAX_IOSTATE_SCHEDREADY, NULL, signal_condition(), and thread.

__send_command()

static int __send_command ( struct chan_iax2_pvt *  i, char  type, int  command, unsigned int  ts, const unsigned char *  data, int  datalen, int  seqno, int  now, int  transfer, int  final  )

static

Definition at line 7812 of file chan_iax2.c.

{
    struct ast_frame f = { 0, };
    int res = 0;
 
    f.frametype = type;
    f.subclass.integer = command;
    f.datalen = datalen;
    f.src = __FUNCTION__;
    f.data.ptr = (void *) data;
 
    if ((res = queue_signalling(i, &f)) <= 0) {
        return res;
    }
 
    return iax2_send(i, &f, ts, seqno, now, transfer, final);
}

References ast_frame::data, ast_frame::datalen, ast_frame::frametype, iax2_send(), ast_frame_subclass::integer, ast_frame::ptr, queue_signalling(), ast_frame::seqno, ast_frame::src, ast_frame::subclass, transfer(), ast_frame::ts, and type.

Referenced by send_command(), send_command_final(), send_command_immediate(), and send_command_transfer().

__send_lagrq()

static void __send_lagrq ( const void *  data )

static

Definition at line 1827 of file chan_iax2.c.

{
    int callno = PTR_TO_CALLNO(data);
 
    if (iax2_lock_callno_unless_destroyed(callno) == 0) {
        ast_debug(3, "Hangup initiated on call %d, aborting __send_lagrq\n", callno);
        return;
    }
 
    /* Mark lagid as invalid scheduler id. */
    iaxs[callno]->lagid = -1;
 
    /* callno is now locked. */
    if (iaxs[callno]->peercallno) {
        /* Send LAGRQ packet. */
        send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_LAGRQ, 0, NULL, 0, -1);
 
        /* Schedule sending next lagrq. */
        iaxs[callno]->lagid = iax2_sched_add(sched, lagrq_time * 1000, send_lagrq, data);
    }
 
    ast_mutex_unlock(&iaxsl[callno]);
}

References ast_debug, AST_FRAME_IAX, ast_mutex_unlock, iax2_thread::callno, iax2_lock_callno_unless_destroyed(), iax2_sched_add(), IAX_COMMAND_LAGRQ, iaxs, iaxsl, chan_iax2_pvt::lagid, lagrq_time, NULL, PTR_TO_CALLNO, send_command(), and send_lagrq().

Referenced by send_lagrq().

__send_ping()

static void __send_ping ( const void *  data )

static

Definition at line 1763 of file chan_iax2.c.

{
    int callno = PTR_TO_CALLNO(data);
 
    if (iax2_lock_callno_unless_destroyed(callno) == 0) {
        ast_debug(3, "Hangup initiated on call %d, aborting __send_ping\n", callno);
        return;
    }
 
    /* Mark pingid as invalid scheduler id. */
    iaxs[callno]->pingid = -1;
 
    /* callno is now locked. */
    if (iaxs[callno]->peercallno) {
        /* Send PING packet. */
        send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_PING, 0, NULL, 0, -1);
 
        /* Schedule sending next ping. */
        iaxs[callno]->pingid = iax2_sched_add(sched, ping_time * 1000, send_ping, data);
    }
 
    ast_mutex_unlock(&iaxsl[callno]);
}

References ast_debug, AST_FRAME_IAX, ast_mutex_unlock, iax2_thread::callno, iax2_lock_callno_unless_destroyed(), iax2_sched_add(), IAX_COMMAND_PING, iaxs, iaxsl, NULL, ping_time, chan_iax2_pvt::pingid, PTR_TO_CALLNO, send_command(), and send_ping().

Referenced by send_ping().

__unload_module()

static int __unload_module ( void  )

static

Definition at line 14763 of file chan_iax2.c.

{
    int x;
 
    network_change_stasis_unsubscribe();
    acl_change_stasis_unsubscribe();
 
    ast_manager_unregister("IAXpeers");
    ast_manager_unregister("IAXpeerlist");
    ast_manager_unregister("IAXnetstats");
    ast_manager_unregister("IAXregistry");
    ast_unregister_application(papp);
    ast_cli_unregister_multiple(cli_iax2, ARRAY_LEN(cli_iax2));
    ast_unregister_switch(&iax2_switch);
    ast_channel_unregister(&iax2_tech);
 
    if (netthreadid != AST_PTHREADT_NULL) {
        pthread_cancel(netthreadid);
        pthread_kill(netthreadid, SIGURG);
        pthread_join(netthreadid, NULL);
    }
 
    for (x = 0; x < ARRAY_LEN(iaxs); x++) {
        if (iaxs[x]) {
            iax2_destroy(x);
        }
    }
 
    /* Call for all threads to halt */
    cleanup_thread_list(&active_list);
    cleanup_thread_list(&dynamic_list);
    cleanup_thread_list(&idle_list);
 
    ast_netsock_release(netsock);
    ast_netsock_release(outsock);
    for (x = 0; x < ARRAY_LEN(iaxs); x++) {
        if (iaxs[x]) {
            iax2_destroy(x);
        }
    }
    ast_manager_unregister( "IAXpeers" );
    ast_manager_unregister( "IAXpeerlist" );
    ast_manager_unregister( "IAXnetstats" );
    ast_manager_unregister( "IAXregistry" );
    ast_unregister_application(papp);
    ast_cli_unregister_multiple(cli_iax2, ARRAY_LEN(cli_iax2));
    ast_unregister_switch(&iax2_switch);
    ast_channel_unregister(&iax2_tech);
    delete_users();
    iax_provision_unload();
    iax_firmware_unload();
 
    for (x = 0; x < ARRAY_LEN(iaxsl); x++) {
        ast_mutex_destroy(&iaxsl[x]);
    }
 
    ao2_ref(peers, -1);
    ao2_ref(users, -1);
    ao2_ref(iax_peercallno_pvts, -1);
    ao2_ref(iax_transfercallno_pvts, -1);
    ao2_ref(callno_limits, -1);
    ao2_ref(calltoken_ignores, -1);
    if (timer) {
        ast_timer_close(timer);
        timer = NULL;
    }
    transmit_processor = ast_taskprocessor_unreference(transmit_processor);
 
    ast_sched_clean_by_callback(sched, peercnt_remove_cb, peercnt_remove_cb);
    ast_sched_context_destroy(sched);
    sched = NULL;
    ao2_ref(peercnts, -1);
 
    ast_context_destroy_by_name(regcontext, "IAX2");
    ast_unload_realtime("iaxpeers");
 
    ao2_ref(iax2_tech.capabilities, -1);
    iax2_tech.capabilities = NULL;
    return 0;
}

References acl_change_stasis_unsubscribe(), ao2_ref, ARRAY_LEN, ast_channel_unregister(), ast_cli_unregister_multiple(), ast_context_destroy_by_name(), ast_manager_unregister(), ast_mutex_destroy, ast_netsock_release(), AST_PTHREADT_NULL, ast_sched_clean_by_callback(), ast_sched_context_destroy(), ast_taskprocessor_unreference(), ast_timer_close(), ast_unload_realtime(), ast_unregister_application(), ast_unregister_switch(), callno_limits, calltoken_ignores, ast_channel_tech::capabilities, cleanup_thread_list(), cli_iax2, delete_users(), iax2_destroy(), iax2_switch, iax2_tech, iax_firmware_unload(), iax_peercallno_pvts, iax_provision_unload(), iax_transfercallno_pvts, iaxs, iaxsl, netsock, netthreadid, network_change_stasis_unsubscribe(), NULL, outsock, papp, peercnt_remove_cb(), peercnts, regcontext, timer, and transmit_processor.

Referenced by load_module(), and unload_module().

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 15136 of file chan_iax2.c.

_iax2_show_peers_one()

static void _iax2_show_peers_one ( int  fd, struct mansession *  s, struct show_peers_context *  cont, struct iax2_peer *  peer  )

static

Definition at line 6945 of file chan_iax2.c.

{
    char name[256] = "";
    char status[64];
    int retstatus;
    struct ast_str *encmethods = ast_str_alloca(256);
 
    char *tmp_host, *tmp_mask, *tmp_port;
 
    tmp_host = ast_strdupa(ast_sockaddr_stringify_addr(&peer->addr));
    tmp_mask = ast_strdupa(ast_sockaddr_stringify_addr(&peer->mask));
    tmp_port = ast_strdupa(ast_sockaddr_stringify_port(&peer->addr));
 
    if (!ast_strlen_zero(peer->username)) {
        snprintf(name, sizeof(name), "%s/%s", peer->name, peer->username);
    } else {
        ast_copy_string(name, peer->name, sizeof(name));
    }
 
    encmethods_to_str(peer->encmethods, &encmethods);
    retstatus = peer_status(peer, status, sizeof(status));
    if (retstatus > 0) {
        cont->online_peers++;
    } else if (!retstatus) {
        cont->offline_peers++;
    } else {
        cont->unmonitored_peers++;
    }
 
    if (s) {
        if (cont->peerlist) { /* IAXpeerlist */
            astman_append(s,
                "Event: PeerEntry\r\n%s"
                "Channeltype: IAX\r\n",
                cont->idtext);
            if (!ast_strlen_zero(peer->username)) {
                astman_append(s,
                    "ObjectName: %s\r\n"
                    "ObjectUsername: %s\r\n",
                    peer->name,
                    peer->username);
            } else {
                astman_append(s,
                    "ObjectName: %s\r\n",
                    name);
            }
        } else { /* IAXpeers */
            astman_append(s,
                "Event: PeerEntry\r\n%s"
                "Channeltype: IAX2\r\n"
                "ObjectName: %s\r\n",
                cont->idtext,
                name);
        }
        astman_append(s,
            "ChanObjectType: peer\r\n"
            "IPaddress: %s\r\n",
            tmp_host);
        if (cont->peerlist) { /* IAXpeerlist */
            astman_append(s,
                "Mask: %s\r\n"
                "Port: %s\r\n",
                tmp_mask,
                tmp_port);
        } else { /* IAXpeers */
            astman_append(s,
                "IPport: %s\r\n",
                tmp_port);
        }
        astman_append(s,
            "Dynamic: %s\r\n"
            "Trunk: %s\r\n"
            "Encryption: %s\r\n"
            "Status: %s\r\n",
            ast_test_flag64(peer, IAX_DYNAMIC) ? "yes" : "no",
            ast_test_flag64(peer, IAX_TRUNK) ? "yes" : "no",
            peer->encmethods ? ast_str_buffer(encmethods) : "no",
            status);
        if (cont->peerlist) { /* IAXpeerlist */
            astman_append(s, "\r\n");
        } else { /* IAXpeers */
            astman_append(s,
                "Description: %s\r\n\r\n",
                peer->description);
        }
    } else {
        ast_cli(fd, PEERS_FORMAT,
            name,
            tmp_host,
            ast_test_flag64(peer, IAX_DYNAMIC) ? "(D)" : "(S)",
            tmp_mask,
            tmp_port,
            ast_test_flag64(peer, IAX_TRUNK) ? "(T)" : "   ",
            peer->encmethods ? "(E)" : "   ",
            status,
            peer->description);
    }
 
    cont->total_peers++;
}

References iax2_peer::addr, ast_cli(), ast_copy_string(), ast_sockaddr_stringify_addr(), ast_sockaddr_stringify_port(), ast_str_alloca, ast_str_buffer(), ast_strdupa, ast_strlen_zero(), ast_test_flag64, astman_append(), iax2_peer::description, iax2_peer::encmethods, encmethods_to_str(), IAX_DYNAMIC, IAX_TRUNK, show_peers_context::idtext, iax2_peer::mask, name, iax2_peer::name, show_peers_context::offline_peers, show_peers_context::online_peers, peer_status(), show_peers_context::peerlist, PEERS_FORMAT, status, show_peers_context::total_peers, show_peers_context::unmonitored_peers, and iax2_peer::username.

Referenced by __iax2_show_peers(), and manager_iax2_show_peer_list().

acf_channel_read()

static int acf_channel_read ( struct ast_channel *  chan, const char *  funcname, char *  preparse, char *  buf, size_t  buflen  )

static

Definition at line 14629 of file chan_iax2.c.

{
    struct chan_iax2_pvt *pvt;
    unsigned int callno;
    int res = 0;
 
    if (!chan || ast_channel_tech(chan) != &iax2_tech) {
        ast_log(LOG_ERROR, "This function requires a valid IAX2 channel\n");
        return -1;
    }
 
    callno = PTR_TO_CALLNO(ast_channel_tech_pvt(chan));
    ast_mutex_lock(&iaxsl[callno]);
    if (!(pvt = iaxs[callno])) {
        ast_mutex_unlock(&iaxsl[callno]);
        return -1;
    }
 
    if (!strcasecmp(args, "osptoken")) {
        ast_copy_string(buf, pvt->osptoken, buflen);
    } else if (!strcasecmp(args, "peerip")) {
        ast_copy_string(buf, !ast_sockaddr_isnull(&pvt->addr) ? ast_sockaddr_stringify_addr(&pvt->addr) : "", buflen);
    } else if (!strcasecmp(args, "peername")) {
        ast_copy_string(buf, pvt->username, buflen);
    } else if (!strcasecmp(args, "secure_signaling") || !strcasecmp(args, "secure_media")) {
        snprintf(buf, buflen, "%s", IAX_CALLENCRYPTED(pvt) ? "1" : "");
    } else {
        res = -1;
    }
 
    ast_mutex_unlock(&iaxsl[callno]);
 
    return res;
}

References chan_iax2_pvt::addr, args, ast_channel_tech(), ast_channel_tech_pvt(), ast_copy_string(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_sockaddr_isnull(), ast_sockaddr_stringify_addr(), buf, chan_iax2_pvt::callno, iax2_tech, IAX_CALLENCRYPTED, iaxs, iaxsl, LOG_ERROR, chan_iax2_pvt::osptoken, PTR_TO_CALLNO, and chan_iax2_pvt::username.

acf_iaxvar_read()

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

static

Definition at line 10119 of file chan_iax2.c.

{
    struct ast_datastore *variablestore;
    AST_LIST_HEAD(, ast_var_t) *varlist;
    struct ast_var_t *var;
 
    if (!chan) {
        ast_log(LOG_WARNING, "No channel was provided to %s function.\n", cmd);
        return -1;
    }
 
    variablestore = ast_channel_datastore_find(chan, &iax2_variable_datastore_info, NULL);
    if (!variablestore) {
        *buf = '\0';
        return 0;
    }
    varlist = variablestore->data;
 
    AST_LIST_LOCK(varlist);
    AST_LIST_TRAVERSE(varlist, var, entries) {
        if (strcmp(var->name, data) == 0) {
            ast_copy_string(buf, var->value, len);
            break;
        }
    }
    AST_LIST_UNLOCK(varlist);
    return 0;
}

References ast_channel_datastore_find(), ast_copy_string(), AST_LIST_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, buf, ast_datastore::data, ast_var_t::entries, iax2_variable_datastore_info, len(), LOG_WARNING, NULL, and var.

acf_iaxvar_write()

static int acf_iaxvar_write ( struct ast_channel *  chan, const char *  cmd, char *  data, const char *  value  )

static

Definition at line 10148 of file chan_iax2.c.

{
    struct ast_datastore *variablestore;
    AST_LIST_HEAD(, ast_var_t) *varlist;
    struct ast_var_t *var;
 
    if (!chan) {
        ast_log(LOG_WARNING, "No channel was provided to %s function.\n", cmd);
        return -1;
    }
 
    variablestore = ast_channel_datastore_find(chan, &iax2_variable_datastore_info, NULL);
    if (!variablestore) {
        variablestore = ast_datastore_alloc(&iax2_variable_datastore_info, NULL);
        if (!variablestore) {
            ast_log(LOG_ERROR, "Memory allocation error\n");
            return -1;
        }
        varlist = ast_calloc(1, sizeof(*varlist));
        if (!varlist) {
            ast_datastore_free(variablestore);
            ast_log(LOG_ERROR, "Unable to assign new variable '%s'\n", data);
            return -1;
        }
 
        AST_LIST_HEAD_INIT(varlist);
        variablestore->data = varlist;
        variablestore->inheritance = DATASTORE_INHERIT_FOREVER;
        ast_channel_datastore_add(chan, variablestore);
    } else
        varlist = variablestore->data;
 
    AST_LIST_LOCK(varlist);
    AST_LIST_TRAVERSE_SAFE_BEGIN(varlist, var, entries) {
        if (strcmp(var->name, data) == 0) {
            AST_LIST_REMOVE_CURRENT(entries);
            ast_var_delete(var);
            break;
        }
    }
    AST_LIST_TRAVERSE_SAFE_END;
    var = ast_var_assign(data, value);
    if (var)
        AST_LIST_INSERT_TAIL(varlist, var, entries);
    else
        ast_log(LOG_ERROR, "Unable to assign new variable '%s'\n", data);
    AST_LIST_UNLOCK(varlist);
    return 0;
}

References ast_calloc, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_datastore_alloc, ast_datastore_free(), AST_LIST_HEAD, AST_LIST_HEAD_INIT, AST_LIST_INSERT_TAIL, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, ast_var_assign, ast_var_delete(), ast_datastore::data, DATASTORE_INHERIT_FOREVER, ast_var_t::entries, iax2_variable_datastore_info, ast_datastore::inheritance, LOG_ERROR, LOG_WARNING, NULL, value, and var.

acl_change_stasis_cb()

static void acl_change_stasis_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 1558 of file chan_iax2.c.

{
    if (stasis_message_type(message) != ast_named_acl_change_type()) {
        return;
    }
 
    ast_log(LOG_NOTICE, "Reloading chan_iax2 in response to ACL change event.\n");
    reload_config(1);
}

References ast_log, ast_named_acl_change_type(), LOG_NOTICE, reload_config(), and stasis_message_type().

Referenced by acl_change_stasis_subscribe(), and rtp_reload().

acl_change_stasis_subscribe()

static void acl_change_stasis_subscribe ( void  )

static

Definition at line 1516 of file chan_iax2.c.

{
    if (!acl_change_sub) {
        acl_change_sub = stasis_subscribe(ast_security_topic(),
            acl_change_stasis_cb, NULL);
        stasis_subscription_accept_message_type(acl_change_sub, ast_named_acl_change_type());
        stasis_subscription_set_filter(acl_change_sub, STASIS_SUBSCRIPTION_FILTER_SELECTIVE);
    }
}

References acl_change_stasis_cb(), acl_change_sub, ast_named_acl_change_type(), ast_security_topic(), NULL, stasis_subscribe, stasis_subscription_accept_message_type(), STASIS_SUBSCRIPTION_FILTER_SELECTIVE, and stasis_subscription_set_filter().

Referenced by build_peer(), and build_user().

acl_change_stasis_unsubscribe()

static void acl_change_stasis_unsubscribe ( void  )

static

Definition at line 1526 of file chan_iax2.c.

{
    acl_change_sub = stasis_unsubscribe_and_join(acl_change_sub);
}

References acl_change_sub, and stasis_unsubscribe_and_join().

Referenced by __unload_module().

add_calltoken_ignore()

static int add_calltoken_ignore ( const char *  addr )

static

Definition at line 2842 of file chan_iax2.c.

{
    struct addr_range tmp;
    struct addr_range *addr_range = NULL;
    struct ast_ha *ha = NULL;
    int error = 0;
 
    if (ast_strlen_zero(addr)) {
        ast_log(LOG_WARNING, "invalid calltokenoptional (null)\n");
        return -1;
    }
 
    ha = ast_append_ha("permit", addr, NULL, &error);
 
    /* check for valid config information */
    if (error) {
        ast_log(LOG_WARNING, "Error %d creating calltokenoptional entry %s\n", error, addr);
        return -1;
    }
 
    ast_copy_ha(ha, &tmp.ha);
    /* find or create the addr_range */
    if ((addr_range = ao2_find(calltoken_ignores, &tmp, OBJ_POINTER))) {
        ao2_lock(addr_range);
        addr_range->delme = 0;
        ao2_unlock(addr_range);
    } else if ((addr_range = ao2_alloc(sizeof(*addr_range), NULL))) {
        /* copy over config data into addr_range object */
        ast_copy_ha(ha, &addr_range->ha); /* this is safe because only one ha is possible */
        ao2_link(calltoken_ignores, addr_range);
    } else {
        ast_free_ha(ha);
        return -1;
    }
 
    ast_free_ha(ha);
    ao2_ref(addr_range, -1); /* decrement ref from ao2_find and ao2_alloc, only container ref remains */
 
    return 0;
}

References ast_ha::addr, ao2_alloc, ao2_find, ao2_link, ao2_lock, ao2_ref, ao2_unlock, ast_append_ha(), ast_copy_ha(), ast_free_ha(), ast_log, ast_strlen_zero(), calltoken_ignores, addr_range::delme, error(), addr_range::ha, LOG_WARNING, NULL, OBJ_POINTER, and tmp().

Referenced by set_config().

add_empty_calltoken_ie()

static void add_empty_calltoken_ie ( struct chan_iax2_pvt *  pvt, struct iax_ie_data *  ied  )

static

Definition at line 4858 of file chan_iax2.c.

{
    /* first make sure their are two empty bytes left in ied->buf */
    if (pvt && ied && (2 < ((int) sizeof(ied->buf) - ied->pos))) {
        ied->buf[ied->pos++] = IAX_IE_CALLTOKEN;  /* type */
        ied->buf[ied->pos++] = 0;   /* data size,  ZERO in this case */
        pvt->calltoken_ie_len = 2;
    }
}

References iax_ie_data::buf, chan_iax2_pvt::calltoken_ie_len, IAX_IE_CALLTOKEN, and iax_ie_data::pos.

Referenced by cache_get_callno_locked(), iax2_call(), iax2_do_register(), iax2_poke_peer(), and registry_rerequest().

addr_range_cmp_cb()

static int addr_range_cmp_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 2498 of file chan_iax2.c.

{
    struct addr_range *lim1 = obj, *lim2 = arg;
    return (!(ast_sockaddr_cmp_addr(&lim1->ha.addr, &lim2->ha.addr)) &&
            !(ast_sockaddr_cmp_addr(&lim1->ha.netmask, &lim2->ha.netmask))) ?
            CMP_MATCH | CMP_STOP : 0;
}

References ast_ha::addr, ast_sockaddr_cmp_addr(), CMP_MATCH, CMP_STOP, addr_range::ha, and ast_ha::netmask.

Referenced by load_objects().

addr_range_delme_cb()

static int addr_range_delme_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 2485 of file chan_iax2.c.

{
    struct addr_range *lim = obj;
    lim->delme = 1;
    return 0;
}

References addr_range::delme.

Referenced by set_config_destroy().

addr_range_hash_cb()

static int addr_range_hash_cb ( const void *  obj, const int  flags  )

static

Definition at line 2492 of file chan_iax2.c.

{
    const struct addr_range *lim = obj;
    return abs(ast_sockaddr_hash(&lim->ha.addr));
}

References abs, ast_ha::addr, ast_sockaddr_hash(), and addr_range::ha.

Referenced by load_objects().

addr_range_match_address_cb()

static int addr_range_match_address_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 2522 of file chan_iax2.c.

{
    struct addr_range *addr_range = obj;
    struct ast_sockaddr *addr = arg;
    struct ast_sockaddr tmp_addr;
 
    ast_sockaddr_apply_netmask(addr, &addr_range->ha.netmask, &tmp_addr);
 
    if (!ast_sockaddr_cmp_addr(&tmp_addr, &addr_range->ha.addr)) {
        return CMP_MATCH | CMP_STOP;
    }
    return 0;
}

References ast_ha::addr, ast_sockaddr_apply_netmask(), ast_sockaddr_cmp_addr(), CMP_MATCH, CMP_STOP, addr_range::ha, and ast_ha::netmask.

Referenced by calltoken_required(), and set_peercnt_limit().

apply_context()

static int apply_context ( struct iax2_context *  con, const char *  context  )

static

Definition at line 7876 of file chan_iax2.c.

{
    while(con) {
        if (!strcmp(con->context, context) || !strcmp(con->context, "*"))
            return -1;
        con = con->next;
    }
    return 0;
}

References iax2_context::context, voicemailpwcheck::context, and iax2_context::next.

Referenced by check_access().

ast_cli_netstats()

static int ast_cli_netstats ( struct mansession *  s, int  fd, int  limit_fmt  )

static

Definition at line 7577 of file chan_iax2.c.

{
    int x;
    int numchans = 0;
    char first_message[10] = { 0, };
    char last_message[10] = { 0, };
#define ACN_FORMAT1 "%-24.25s %4u %4d %4d %5d %3d %5d %4d %6d %4d %4d %5d %3d %5d %4d %6d %s%s %4s%s\n"
#define ACN_FORMAT2 "%s %u %d %d %d %d %d %d %d %d %d %d %d %d %d %d %s%s %s%s\n"
    for (x = 0; x < ARRAY_LEN(iaxs); x++) {
        ast_mutex_lock(&iaxsl[x]);
        if (iaxs[x]) {
            int localjitter, localdelay, locallost, locallosspct, localdropped, localooo;
            jb_info jbinfo;
            iax_frame_subclass2str(iaxs[x]->first_iax_message & ~MARK_IAX_SUBCLASS_TX, first_message, sizeof(first_message));
            iax_frame_subclass2str(iaxs[x]->last_iax_message & ~MARK_IAX_SUBCLASS_TX, last_message, sizeof(last_message));
 
            if(ast_test_flag64(iaxs[x], IAX_USEJITTERBUF)) {
                jb_getinfo(iaxs[x]->jb, &jbinfo);
                localjitter = jbinfo.jitter;
                localdelay = jbinfo.current - jbinfo.min;
                locallost = jbinfo.frames_lost;
                locallosspct = jbinfo.losspct/1000;
                localdropped = jbinfo.frames_dropped;
                localooo = jbinfo.frames_ooo;
            } else {
                localjitter = -1;
                localdelay = 0;
                locallost = -1;
                locallosspct = -1;
                localdropped = 0;
                localooo = -1;
            }
            if (s)
                astman_append(s, limit_fmt ? ACN_FORMAT1 : ACN_FORMAT2,
                    iaxs[x]->owner ? ast_channel_name(iaxs[x]->owner) : "(None)",
                    iaxs[x]->pingtime,
                    localjitter,
                    localdelay,
                    locallost,
                    locallosspct,
                    localdropped,
                    localooo,
                    iaxs[x]->frames_received/1000,
                    iaxs[x]->remote_rr.jitter,
                    iaxs[x]->remote_rr.delay,
                    iaxs[x]->remote_rr.losscnt,
                    iaxs[x]->remote_rr.losspct,
                    iaxs[x]->remote_rr.dropped,
                    iaxs[x]->remote_rr.ooo,
                    iaxs[x]->remote_rr.packets/1000,
                    (iaxs[x]->first_iax_message & MARK_IAX_SUBCLASS_TX) ? "Tx:" : "Rx:",
                    first_message,
                    (iaxs[x]->last_iax_message & MARK_IAX_SUBCLASS_TX) ? "Tx:" : "Rx:",
                    last_message);
            else
                ast_cli(fd, limit_fmt ? ACN_FORMAT1 : ACN_FORMAT2,
                    iaxs[x]->owner ? ast_channel_name(iaxs[x]->owner) : "(None)",
                    iaxs[x]->pingtime,
                    localjitter,
                    localdelay,
                    locallost,
                    locallosspct,
                    localdropped,
                    localooo,
                    iaxs[x]->frames_received/1000,
                    iaxs[x]->remote_rr.jitter,
                    iaxs[x]->remote_rr.delay,
                    iaxs[x]->remote_rr.losscnt,
                    iaxs[x]->remote_rr.losspct,
                    iaxs[x]->remote_rr.dropped,
                    iaxs[x]->remote_rr.ooo,
                    iaxs[x]->remote_rr.packets/1000,
                    (iaxs[x]->first_iax_message & MARK_IAX_SUBCLASS_TX) ? "Tx:" : "Rx:",
                    first_message,
                    (iaxs[x]->last_iax_message & MARK_IAX_SUBCLASS_TX) ? "Tx:" : "Rx:",
                    last_message);
            numchans++;
        }
        ast_mutex_unlock(&iaxsl[x]);
    }
 
    return numchans;
}

References ACN_FORMAT1, ACN_FORMAT2, ARRAY_LEN, ast_channel_name(), ast_cli(), ast_mutex_lock, ast_mutex_unlock, ast_test_flag64, astman_append(), jb_info::current, iax_rr::delay, iax_rr::dropped, chan_iax2_pvt::first_iax_message, jb_info::frames_dropped, jb_info::frames_lost, jb_info::frames_ooo, iax_frame_subclass2str(), IAX_USEJITTERBUF, iaxs, iaxsl, jb_getinfo(), jb_info::jitter, chan_iax2_pvt::last_iax_message, iax_rr::losscnt, iax_rr::losspct, jb_info::losspct, MARK_IAX_SUBCLASS_TX, jb_info::min, iax_rr::ooo, iax_rr::packets, and chan_iax2_pvt::remote_rr.

Referenced by handle_cli_iax2_show_netstats(), and manager_iax2_show_netstats().

ast_iax2_new()

static struct ast_channel * ast_iax2_new ( int  callno, int  state, iax2_format  capability, struct iax2_codec_pref *  prefs, const struct ast_assigned_ids *  assignedids, const struct ast_channel *  requestor, unsigned int  cachable  )

static

Create new call, interface with the PBX core.

Definition at line 5906 of file chan_iax2.c.

{
    struct ast_channel *tmp = NULL;
    struct chan_iax2_pvt *i;
    struct iax2_peer *peer;
    struct ast_variable *v = NULL;
    struct ast_format_cap *native;
    struct ast_format *tmpfmt;
    ast_callid callid;
    char *peer_name = NULL;
 
    if (!(i = iaxs[callno])) {
        ast_log(LOG_WARNING, "No IAX2 pvt found for callno '%d' !\n", callno);
        return NULL;
    }
 
    if (!capability) {
        ast_log(LOG_WARNING, "No formats specified for call to: IAX2/%s-%d\n",
            i->host, i->callno);
        return NULL;
    }
    native = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
    if (!native) {
        return NULL;
    }
    if (iax2_codec_pref_best_bitfield2cap(capability, prefs, native)
        || !ast_format_cap_count(native)) {
        ast_log(LOG_WARNING, "No requested formats available for call to: IAX2/%s-%d\n",
            i->host, i->callno);
        ao2_ref(native, -1);
        return NULL;
    }
 
    if (!ast_strlen_zero(i->peer)) {
        peer_name = ast_strdupa(i->peer);
    } else if (!ast_strlen_zero(i->host)) {
        peer_name = ast_strdupa(i->host);
    }
 
    /* Don't hold call lock while making a channel or looking up a peer */
    ast_mutex_unlock(&iaxsl[callno]);
 
    if (!ast_strlen_zero(peer_name)) {
        peer = find_peer(peer_name, 1);
        if (peer && peer->endpoint) {
            tmp = ast_channel_alloc_with_endpoint(1, state, i->cid_num, i->cid_name,
                i->accountcode, i->exten, i->context, assignedids, requestor,
                i->amaflags, peer->endpoint, "IAX2/%s-%d", i->host, i->callno);
        }
        ao2_cleanup(peer);
    }
 
    if (!tmp) {
        tmp = ast_channel_alloc(1, state, i->cid_num, i->cid_name, i->accountcode,
            i->exten, i->context, assignedids, requestor, i->amaflags, "IAX2/%s-%d",
            i->host, i->callno);
    }
 
    ast_mutex_lock(&iaxsl[callno]);
    if (i != iaxs[callno]) {
        if (tmp) {
            /* unlock and relock iaxsl[callno] to preserve locking order */
            ast_mutex_unlock(&iaxsl[callno]);
            ast_channel_unlock(tmp);
            tmp = ast_channel_release(tmp);
            ast_mutex_lock(&iaxsl[callno]);
        }
        ao2_ref(native, -1);
        return NULL;
    }
    if (!tmp) {
        ao2_ref(native, -1);
        return NULL;
    }
 
    ast_channel_stage_snapshot(tmp);
 
    if ((callid = iaxs[callno]->callid)) {
        ast_channel_callid_set(tmp, callid);
    }
 
    ast_channel_tech_set(tmp, &iax2_tech);
 
    /* We can support any format by default, until we get restricted */
    ast_channel_nativeformats_set(tmp, native);
    tmpfmt = ast_format_cap_get_format(native, 0);
 
    ast_channel_set_readformat(tmp, tmpfmt);
    ast_channel_set_rawreadformat(tmp, tmpfmt);
    ast_channel_set_writeformat(tmp, tmpfmt);
    ast_channel_set_rawwriteformat(tmp, tmpfmt);
 
    ao2_ref(tmpfmt, -1);
    ao2_ref(native, -1);
 
    ast_channel_tech_pvt_set(tmp, CALLNO_TO_PTR(i->callno));
 
    if (!ast_strlen_zero(i->parkinglot))
        ast_channel_parkinglot_set(tmp, i->parkinglot);
    /* Don't use ast_set_callerid() here because it will
     * generate a NewCallerID event before the NewChannel event */
    if (!ast_strlen_zero(i->ani)) {
        ast_channel_caller(tmp)->ani.number.valid = 1;
        ast_channel_caller(tmp)->ani.number.str = ast_strdup(i->ani);
    } else if (!ast_strlen_zero(i->cid_num)) {
        ast_channel_caller(tmp)->ani.number.valid = 1;
        ast_channel_caller(tmp)->ani.number.str = ast_strdup(i->cid_num);
    }
    ast_channel_dialed(tmp)->number.str = ast_strdup(i->dnid);
    if (!ast_strlen_zero(i->rdnis)) {
        ast_channel_redirecting(tmp)->from.number.valid = 1;
        ast_channel_redirecting(tmp)->from.number.str = ast_strdup(i->rdnis);
    }
    ast_channel_caller(tmp)->ani2 = i->calling_ani2;
    ast_channel_caller(tmp)->id.name.presentation = i->calling_pres;
    ast_channel_caller(tmp)->id.number.presentation = i->calling_pres;
    ast_channel_caller(tmp)->id.number.plan = i->calling_ton;
    ast_channel_dialed(tmp)->transit_network_select = i->calling_tns;
    if (!ast_strlen_zero(i->language))
        ast_channel_language_set(tmp, i->language);
    if (!ast_strlen_zero(i->accountcode))
        ast_channel_accountcode_set(tmp, i->accountcode);
    if (i->amaflags)
        ast_channel_amaflags_set(tmp, i->amaflags);
    ast_channel_context_set(tmp, i->context);
    ast_channel_exten_set(tmp, i->exten);
    if (i->adsi)
        ast_channel_adsicpe_set(tmp, i->peeradsicpe);
    else
        ast_channel_adsicpe_set(tmp, AST_ADSI_UNAVAILABLE);
    i->owner = tmp;
    i->capability = capability;
 
    if (!cachable) {
        ast_set_flag(ast_channel_flags(tmp), AST_FLAG_DISABLE_DEVSTATE_CACHE);
    }
 
    /* Set inherited variables */
    if (i->vars) {
        for (v = i->vars ; v ; v = v->next)
            pbx_builtin_setvar_helper(tmp, v->name, v->value);
    }
    if (i->iaxvars) {
        struct ast_datastore *variablestore;
        struct ast_variable *var, *prev = NULL;
        AST_LIST_HEAD(, ast_var_t) *varlist;
        ast_debug(1, "Loading up the channel with IAXVARs\n");
        varlist = ast_calloc(1, sizeof(*varlist));
        variablestore = ast_datastore_alloc(&iax2_variable_datastore_info, NULL);
        if (variablestore && varlist) {
            variablestore->data = varlist;
            variablestore->inheritance = DATASTORE_INHERIT_FOREVER;
            AST_LIST_HEAD_INIT(varlist);
            for (var = i->iaxvars; var; var = var->next) {
                struct ast_var_t *newvar = ast_var_assign(var->name, var->value);
                if (prev)
                    ast_free(prev);
                prev = var;
                if (!newvar) {
                    /* Don't abort list traversal, as this would leave i->iaxvars in an inconsistent state. */
                    ast_log(LOG_ERROR, "Memory allocation error while processing IAX2 variables\n");
                } else {
                    AST_LIST_INSERT_TAIL(varlist, newvar, entries);
                }
            }
            if (prev)
                ast_free(prev);
            i->iaxvars = NULL;
            ast_channel_datastore_add(i->owner, variablestore);
        } else {
            if (variablestore) {
                ast_datastore_free(variablestore);
            }
            if (varlist) {
                ast_free(varlist);
            }
        }
    }
 
    ast_channel_stage_snapshot_done(tmp);
    ast_channel_unlock(tmp);
 
    if (state != AST_STATE_DOWN) {
        if (ast_pbx_start(tmp)) {
            ast_log(LOG_WARNING, "Unable to start PBX on %s\n", ast_channel_name(tmp));
            /* unlock and relock iaxsl[callno] to preserve locking order */
            ast_mutex_unlock(&iaxsl[callno]);
            ast_hangup(tmp);
            ast_mutex_lock(&iaxsl[callno]);
            return NULL;
        }
    }
 
    ast_module_ref(ast_module_info->self);
    return tmp;
}

References chan_iax2_pvt::accountcode, chan_iax2_pvt::adsi, chan_iax2_pvt::amaflags, chan_iax2_pvt::ani, ast_party_caller::ani, ast_party_caller::ani2, ao2_cleanup, ao2_ref, AST_ADSI_UNAVAILABLE, ast_calloc, ast_channel_adsicpe_set(), ast_channel_alloc, ast_channel_alloc_with_endpoint, ast_channel_amaflags_set(), ast_channel_caller(), ast_channel_callid_set(), ast_channel_context_set(), ast_channel_datastore_add(), ast_channel_dialed(), ast_channel_exten_set(), ast_channel_flags(), ast_channel_name(), ast_channel_nativeformats_set(), ast_channel_redirecting(), ast_channel_release(), ast_channel_set_rawreadformat(), ast_channel_set_rawwriteformat(), ast_channel_set_readformat(), ast_channel_set_writeformat(), ast_channel_stage_snapshot(), ast_channel_stage_snapshot_done(), ast_channel_tech_pvt_set(), ast_channel_tech_set(), ast_channel_unlock, ast_datastore_alloc, ast_datastore_free(), ast_debug, AST_FLAG_DISABLE_DEVSTATE_CACHE, ast_format_cap_alloc, ast_format_cap_count(), AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_cap_get_format(), ast_free, ast_hangup(), AST_LIST_HEAD, AST_LIST_HEAD_INIT, AST_LIST_INSERT_TAIL, ast_log, ast_module_ref, ast_mutex_lock, ast_mutex_unlock, ast_pbx_start(), ast_set_flag, AST_STATE_DOWN, ast_strdup, ast_strdupa, ast_strlen_zero(), ast_var_assign, chan_iax2_pvt::calling_ani2, chan_iax2_pvt::calling_pres, chan_iax2_pvt::calling_tns, chan_iax2_pvt::calling_ton, chan_iax2_pvt::callno, CALLNO_TO_PTR, chan_iax2_pvt::capability, chan_iax2_pvt::cid_name, chan_iax2_pvt::cid_num, chan_iax2_pvt::context, ast_datastore::data, DATASTORE_INHERIT_FOREVER, chan_iax2_pvt::dnid, iax2_peer::endpoint, ast_var_t::entries, chan_iax2_pvt::exten, find_peer(), ast_party_redirecting::from, chan_iax2_pvt::host, iax2_codec_pref_best_bitfield2cap(), iax2_tech, iax2_variable_datastore_info, iaxs, iaxsl, chan_iax2_pvt::iaxvars, ast_party_caller::id, ast_datastore::inheritance, chan_iax2_pvt::language, LOG_ERROR, LOG_WARNING, ast_party_id::name, ast_variable::name, ast_variable::next, NULL, ast_party_id::number, ast_party_dialed::number, chan_iax2_pvt::owner, chan_iax2_pvt::parkinglot, pbx_builtin_setvar_helper(), chan_iax2_pvt::peer, chan_iax2_pvt::peeradsicpe, ast_party_number::plan, ast_party_name::presentation, ast_party_number::presentation, chan_iax2_pvt::rdnis, ast_module_info::self, ast_party_number::str, ast_party_dialed::str, tmp(), ast_party_dialed::transit_network_select, ast_party_number::valid, ast_variable::value, var, and chan_iax2_pvt::vars.

Referenced by iax2_request(), and socket_process_helper().

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 15136 of file chan_iax2.c.

attempt_transmit()

static int attempt_transmit ( const void *  data )

static

Definition at line 3678 of file chan_iax2.c.

{
#ifdef SCHED_MULTITHREADED
    if (schedule_action(__attempt_transmit, data))
#endif
        __attempt_transmit(data);
    return 0;
}

References __attempt_transmit(), ast_frame::data, and schedule_action.

Referenced by __attempt_transmit(), and transmit_frame().

auth_fail()

static int auth_fail ( int  callno, int  failcode  )

static

Definition at line 9458 of file chan_iax2.c.

{
    /* Schedule sending the authentication failure in one second, to prevent
       guessing */
    if (iaxs[callno]) {
        iaxs[callno]->authfail = failcode;
        if (delayreject) {
            iaxs[callno]->authid = iax2_sched_replace(iaxs[callno]->authid,
                sched, 1000, auth_reject, (void *)(long)callno);
        } else
            auth_reject((void *)(long)callno);
    }
    return 0;
}

References auth_reject(), chan_iax2_pvt::authfail, chan_iax2_pvt::authid, delayreject, iax2_sched_replace(), and iaxs.

Referenced by socket_process_helper().

auth_method_names()

static char * auth_method_names ( int  authmethods, char *restrict  buf  )

static

Get names of all auth methods.

Parameters

	Bit	field of auth methods
[out]	buf	Buffer into which to write the names. Must be of size AUTH_METHOD_NAMES_BUFSIZE.

Returns

Auth methods name

Definition at line 415 of file chan_iax2.c.

{
    char *pos = buf;
 
    *pos = '\0';
 
    if (authmethods & IAX_AUTH_RSA) {
        pos += sprintf(pos, "|RSA");
    }
    if (authmethods & IAX_AUTH_MD5) {
        pos += sprintf(pos, "|MD5");
    }
    if (authmethods & IAX_AUTH_PLAINTEXT) {
        pos += sprintf(pos, "|plaintext");
    }
 
    if (pos == buf) { /* No auth methods */
        strcpy(buf, "none");
        return buf;
    }
 
    return buf + 1; /* Skip leading | */
}

References buf, IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, and IAX_AUTH_RSA.

Referenced by socket_process_helper().

auth_reject()

static int auth_reject ( const void *  data )

static

Definition at line 9444 of file chan_iax2.c.

{
    int callno = (int)(long)(data);
    ast_mutex_lock(&iaxsl[callno]);
    if (iaxs[callno])
        iaxs[callno]->authid = -1;
    ast_mutex_unlock(&iaxsl[callno]);
#ifdef SCHED_MULTITHREADED