chan_iax2.c File Reference

Implementation of Inter-Asterisk eXchange Version 2. 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 <sys/signal.h>
#include <signal.h>
#include <strings.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/cdr.h"
#include "asterisk/crypto.h"
#include "asterisk/acl.h"
#include "asterisk/manager.h"
#include "asterisk/callerid.h"
#include "asterisk/app.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/aes.h"
#include "asterisk/dnsmgr.h"
#include "asterisk/devicestate.h"
#include "asterisk/netsock.h"
#include "asterisk/stringfields.h"
#include "asterisk/linkedlists.h"
#include "asterisk/event.h"
#include "asterisk/astobj2.h"
#include "asterisk/timing.h"
#include "asterisk/taskprocessor.h"
#include "iax2.h"
#include "iax2-parser.h"
#include "iax2-provision.h"
#include "jitterbuf.h"

Go to the source code of this file.

Data Structures
struct	active_list
struct	addr_range
struct	callno_entry
struct	chan_iax2_pvt
struct	chan_iax2_pvt::signaling_queue
struct	create_addr_info
struct	dpcache
struct	dpreq_data
struct	dynamic_list
struct	firmwares
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_dual
struct	iax_firmware
struct	iax_rr
struct	idle_list
struct	parsed_dial_string
struct	peercnt
struct	registrations
struct	signaling_queue_entry
struct	tpeers
Defines
#define	ACN_FORMAT1   "%-20.25s %4d %4d %4d %5d %3d %5d %4d %6d %4d %4d %5d %3d %5d %4d %6d %s%s %4s%s\n"
#define	ACN_FORMAT2   "%s %d %d %d %d %d %d %d %d %d %d %d %d %d %d %d %s%s %s%s\n"
#define	CALLNO_TO_PTR(a)   ((void *)(unsigned long)(a))
#define	CALLTOKEN_HASH_FORMAT   "%s%d%u%d"
#define	CALLTOKEN_IE_FORMAT   "%u?%s"
#define	DEBUG_SCHED_MULTITHREAD
#define	DEBUG_SUPPORT
#define	DEFAULT_CONTEXT   "default"
#define	DEFAULT_DROP   3
#define	DEFAULT_FREQ_NOTOK   10 * 1000
#define	DEFAULT_FREQ_OK   60 * 1000
#define	DEFAULT_MAX_THREAD_COUNT   100
#define	DEFAULT_MAXMS   2000
#define	DEFAULT_RETRY_TIME   1000
#define	DEFAULT_THREAD_COUNT   10
#define	DEFAULT_TRUNKDATA   640 * 10
#define	FORMAT   "%-20.20s %-15.15s %-10.10s %5.5d/%5.5d %5.5d/%5.5d %-5.5dms %-4.4dms %-4.4dms %-6.6s %s%s %3s%s\n"
#define	FORMAT   "%-20.20s %-6.6s %-10.10s %-20.20s %8d %s\n"
#define	FORMAT   "%-15.15s %-15.15s %s %-15.15s %-5d%s %s %-10s%s"
#define	FORMAT   "%-15.15s %-20.20s %-15.15s %-15.15s %-5.5s %-5.10s\n"
#define	FORMAT2   "%-20.20s %-15.15s %-10.10s %-11.11s %-11.11s %-7.7s %-6.6s %-6.6s %s %s %9s\n"
#define	FORMAT2   "%-20.20s %-6.6s %-10.10s %-20.20s %8.8s %s\n"
#define	FORMAT2   "%-15.15s %-15.15s %s %-15.15s %-8s %s %-10s%s"
#define	FORMAT2   "%-15.15s %-20.20s %-15.15d %-15.15s %-5.5s %-5.10s\n"
#define	FORMATB   "%-20.20s %-15.15s %-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)(1 << 26)
#define	IAX_ALREADYGONE   (uint64_t)(1 << 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)(1 << 16)
#define	IAX_CODEC_NOPREFS   (uint64_t)(1 << 15)
#define	IAX_CODEC_USER_FIRST   (uint64_t)(1 << 14)
#define	IAX_DEBUGDIGEST(msg, key)
#define	IAX_DELAYPBXSTART   (uint64_t)(1 << 25)
#define	IAX_DELME   (uint64_t)(1 << 1)
#define	IAX_DYNAMIC   (uint64_t)(1 << 6)
#define	IAX_ENCRYPTED   (uint64_t)(1 << 12)
#define	IAX_FORCE_ENCRYPT   (uint64_t)(1 << 30)
#define	IAX_FORCEJITTERBUF   (uint64_t)(1 << 20)
#define	IAX_HASCALLERID   (uint64_t)(1 << 0)
#define	IAX_IMMEDIATE   (uint64_t)(1 << 27)
#define	IAX_KEYPOPULATED   (uint64_t)(1 << 13)
#define	IAX_MAXAUTHREQ   (uint64_t)(1 << 24)
#define	IAX_NOTRANSFER   (uint64_t)(1 << 4)
#define	IAX_PROVISION   (uint64_t)(1 << 10)
#define	IAX_QUELCH   (uint64_t)(1 << 11)
#define	IAX_RECVCONNECTEDLINE   (uint64_t)(1 << 29)
#define	IAX_RTAUTOCLEAR   (uint64_t)(1 << 19)
#define	IAX_RTCACHEFRIENDS   (uint64_t)(1 << 17)
#define	IAX_RTIGNOREREGEXPIRE   (uint64_t)(1 << 21)
#define	IAX_RTSAVE_SYSNAME   (uint64_t)(1 << 8)
#define	IAX_RTUPDATE   (uint64_t)(1 << 18)
#define	IAX_SENDANI   (uint64_t)(1 << 7)
#define	IAX_SENDCONNECTEDLINE   (uint64_t)(1 << 28)
#define	IAX_SHRINKCALLERID   (uint64_t)(1 << 31)
#define	IAX_TEMPONLY   (uint64_t)(1 << 2)
#define	IAX_TRANSFERMEDIA   (uint64_t)(1 << 23)
#define	IAX_TRUNK   (uint64_t)(1 << 3)
#define	IAX_TRUNKTIMESTAMPS   (uint64_t)(1 << 22)
#define	IAX_USEJITTERBUF   (uint64_t)(1 << 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.
#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
#define	PTR_TO_CALLNO(a)   ((unsigned short)(unsigned long)(a))
#define	SCHED_MULTITHREADED
#define	schedule_action(func, data)   __schedule_action(func, data, __PRETTY_FUNCTION__)
#define	TRUNK_CALL_START   ARRAY_LEN(iaxs) / 2
#define	TS_GAP_FOR_JB_RESYNC   5000
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	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 sockaddr_in *sin, 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 manager, int fd, 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 int	acf_channel_read (struct ast_channel *chan, const char *funcname, char *preparse, char *buf, size_t buflen)
static int	acf_channel_write (struct ast_channel *chan, const char *function, char *data, const char *value)
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 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, int capability, const char *linkedid)
	Create new call, interface with the PBX core.
static int	attempt_transmit (const void *data)
static int	auth_fail (int callno, int failcode)
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 sockaddr_in *sin, struct chan_iax2_pvt *pvt)
static int	authenticate_reply (struct chan_iax2_pvt *p, struct sockaddr_in *sin, 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.
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.
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	callno_hash (const void *obj, const int flags)
static int	calltoken_required (struct sockaddr_in *sin, const char *name, int subclass)
static int	check_access (int callno, struct sockaddr_in *sin, struct iax_ies *ies)
static int	check_provisioning (struct sockaddr_in *sin, int sockfd, char *si, unsigned int ver)
static int	check_srcaddr (struct sockaddr *sa, socklen_t salen)
	Check if address can be used as packet source.
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 (int 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 sockaddr_in *sin, 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.
static void	delete_users (void)
static void	destroy_firmware (struct iax_firmware *cur)
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 sockaddr_in *sin, int new, int sockfd, int full_frame)
static int	find_callno_locked (unsigned short callno, unsigned short dcallno, struct sockaddr_in *sin, 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 sockaddr_in *sin, int fd)
static struct iax2_user *	find_user (const char *name)
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 struct callno_entry *	get_unused_callno (int trunk, int validated)
static int	handle_call_token (struct ast_iax2_full_hdr *fh, struct iax_ies *ies, struct sockaddr_in *sin, 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.
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.
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.
static int	handle_error (void)
static int	iax2_ack_registry (struct iax_ies *ies, struct sockaddr_in *sin, int callno)
	Acknowledgment received for OUR registration.
static int attribute_pure	iax2_allow_new (int frametype, int subclass, int inbound)
static void	iax2_ami_channelupdate (struct chan_iax2_pvt *pvt)
	Send manager event at call setup to link between Asterisk channel name and IAX2 call identifiers.
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 enum ast_bridge_result	iax2_bridge (struct ast_channel *c0, struct ast_channel *c1, int flags, struct ast_frame **fo, struct ast_channel **rc, int timeoutms)
static int	iax2_call (struct ast_channel *c, 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
static unsigned int	iax2_datetime (const char *tz)
static void	iax2_destroy (int callno)
static void	iax2_destroy_helper (struct chan_iax2_pvt *pvt)
static int	iax2_devicestate (void *data)
	Part of the device state notification system ---.
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.
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.
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 *)
static int	iax2_getpeername (struct sockaddr_in sin, char *host, int len)
static int	iax2_getpeertrunk (struct sockaddr_in sin)
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_key_rotate (const void *vpvt)
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.
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 sockaddr_in *end, int sockfd, const char *dest, const char *template, int force)
static int	iax2_queue_control_data (int callno, enum ast_control_frame_type control, const void *data, size_t datalen)
	Queue a control frame on the ast_channel owner.
static int	iax2_queue_frame (int callno, struct ast_frame *f)
	Queue a frame to a call's owning asterisk channel.
static int	iax2_queue_hangup (int callno)
	Queue a hangup frame on the ast_channel owner.
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, int format, const struct ast_channel *requestor, void *data, int *cause)
static int	iax2_sched_add (struct ast_sched_thread *st, int when, ast_sched_cb callback, const void *data)
static int	iax2_sched_replace (int id, struct ast_sched_thread *st, 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_start_transfer (unsigned short callno0, unsigned short callno1, int mediaonly)
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 int	iax_check_version (char *dev)
static void	iax_debug_output (const char *data)
static void	iax_error_output (const char *data)
static int	iax_firmware_append (struct iax_ie_data *ied, const unsigned char *dev, unsigned int desc)
static void	iax_outputframe (struct iax_frame *f, struct ast_iax2_full_hdr *fhi, int rx, struct sockaddr_in *sin, int datalen)
static int	iax_park (struct ast_channel *chan1, struct ast_channel *chan2)
static void *	iax_park_thread (void *stuff)
static struct iax_frame *	iaxfrdup2 (struct iax_frame *fr)
static void	insert_idle_thread (struct iax2_thread *thread)
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 IAX2 module, load configuraiton ---.
static int	load_objects (void)
static void	lock_both (unsigned short callno0, unsigned short callno1)
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
static int	manager_iax2_show_peers (struct mansession *s, const struct message *m)
	callback to display iax peers in manager
static int	manager_iax2_show_registry (struct mansession *s, const struct message *m)
static int	match (struct sockaddr_in *sin, 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 void	mwi_event_cb (const struct ast_event *event, void *userdata)
static void *	network_thread (void *ignore)
static struct chan_iax2_pvt *	new_iax (struct sockaddr_in *sin, const char *host)
static void	parse_dial_string (char *data, struct parsed_dial_string *pds)
	Parses an IAX dial string into its component parts.
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.
static int	peer_status (struct iax2_peer *peer, char *status, int statuslen)
	peer_status: Report Peer status in character string
static struct iax2_peer *	peer_unref (struct iax2_peer *peer)
static int	peercnt_add (struct sockaddr_in *sin)
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 sockaddr_in *sin)
static void	peercnt_remove (struct peercnt *peercnt)
static int	peercnt_remove_by_addr (struct sockaddr_in *sin)
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.
static int	raw_hangup (struct sockaddr_in *sin, unsigned short src, unsigned short dst, int sockfd)
static struct iax2_peer *	realtime_peer (const char *peername, struct sockaddr_in *sin)
static void	realtime_update_peer (const char *peername, struct sockaddr_in *sin, time_t regtime)
static struct iax2_user *	realtime_user (const char *username, struct sockaddr_in *sin)
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 sockaddr_in *sin, struct iax_ies *ies)
	Verify inbound registration.
static int	registry_authrequest (int callno)
static int	registry_rerequest (struct iax_ies *ies, int callno, struct sockaddr_in *sin)
static char *	regstate2str (int regstate)
static int	reload (void)
static int	reload_config (void)
static void	reload_firmware (int unload)
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 sockaddr_in *sin, struct callno_entry *callno_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 sockaddr_in *sin, 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.
static int	send_trunk (struct iax2_trunk_peer *tpeer, struct timeval *now)
static int	set_config (const char *config_file, int reload)
	Load configuration.
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_meta (int packet_len, struct ast_iax2_meta_hdr *meta, struct sockaddr_in *sin, 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 sockaddr_in *sin, int sockfd)
static int	try_firmware (char *s)
static int	try_transfer (struct chan_iax2_pvt *pvt, struct iax_ies *ies)
static int	uncompress_subclass (unsigned char csub)
static void	unlink_peer (struct iax2_peer *peer)
static int	unload_module (void)
static void	unlock_both (unsigned short callno0, unsigned short callno1)
static void	unwrap_timestamp (struct iax_frame *fr)
static void	update_jbsched (struct chan_iax2_pvt *pvt)
static void	update_max_nontrunk (void)
static void	update_max_trunk (void)
static int	update_packet (struct iax_frame *f)
static int	update_registry (struct sockaddr_in *sin, 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_ref (struct iax2_user *user)
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_DEFAULT , .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, .load = load_module, .unload = unload_module, .reload = reload, }
static char	accountcode [AST_MAX_ACCOUNT_CODE]
static int	adsi = 0
static int	amaflags = 0
static struct ast_module_info *	ast_module_info = &__mod_info
static int	authdebug = 1
static int	autokill = 0
static struct ao2_container *	callno_limits
static struct ao2_container *	callno_pool
static const unsigned int	CALLNO_POOL_BUCKETS = 2699
static struct ao2_container *	callno_pool_trunk
static struct ao2_container *	calltoken_ignores
static struct ast_cli_entry	cli_iax2 []
static struct sockaddr_in	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
struct {
struct iax_frame *   first
struct iax_frame *   last
}	frame_queue [IAX_MAX_CALLS]
	a list of frames that may need to be retransmitted
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_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 struct ast_datastore_info	iax2_variable_datastore_info
static struct ao2_container *	iax_peercallno_pvts
	Another container of iax2_pvt structures.
static struct ao2_container *	iax_transfercallno_pvts
	Another container of iax2_pvt structures.
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
static ast_mutex_t	iaxsl [ARRAY_LEN(iaxs)]
	chan_iax2_pvt structure locks
static int	iaxthreadcount = DEFAULT_THREAD_COUNT
static int	iaxtrunkdebug = 0
static struct ast_custom_function	iaxvar_function
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 const 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	maxnontrunkcall = 1
static int	maxtrunkcall = TRUNK_CALL_START
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 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 ast_codec_pref	prefs
struct {
unsigned int   cos
unsigned int   tos
}	qos
static int	randomcalltokendata
static char	regcontext [AST_MAX_CONTEXT] = ""
static int	resyncthreshold = 1000
static struct ast_sched_thread *	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 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.

Author:

Mark Spencer <markster@digium.com>

See also

• IAX2 configuration

Todo:

Implement musicclass settings for IAX2 devices

Definition in file chan_iax2.c.

---

Define Documentation

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

Referenced by ast_cli_netstats().

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

Referenced by ast_cli_netstats().

#define CALLNO_TO_PTR

(

a

)

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

Definition at line 235 of file chan_iax2.c.

Referenced by ast_iax2_new(), iax2_call(), iax2_hangup(), and update_jbsched().

#define CALLTOKEN_HASH_FORMAT   "%s%d%u%d"

Referenced by handle_call_token().

#define CALLTOKEN_IE_FORMAT   "%u?%s"

Referenced by handle_call_token().

#define DEBUG_SCHED_MULTITHREAD

Definition at line 227 of file chan_iax2.c.

#define DEBUG_SUPPORT

Definition at line 243 of file chan_iax2.c.

#define DEFAULT_CONTEXT   "default"

Definition at line 262 of file chan_iax2.c.

Referenced by check_access(), handle_cli_iax2_show_users(), and reload_config().

#define DEFAULT_DROP   3

Definition at line 241 of file chan_iax2.c.

#define DEFAULT_FREQ_NOTOK   10 * 1000

Definition at line 333 of file chan_iax2.c.

Referenced by build_peer(), handle_response_peerpoke(), and sip_poke_noanswer().

#define DEFAULT_FREQ_OK   60 * 1000

Definition at line 332 of file chan_iax2.c.

Referenced by build_peer().

#define DEFAULT_MAX_THREAD_COUNT   100

Definition at line 238 of file chan_iax2.c.

#define DEFAULT_MAXMS   2000

Definition at line 331 of file chan_iax2.c.

Referenced by build_peer(), iax2_poke_peer(), reload_config(), and set_config().

#define DEFAULT_RETRY_TIME   1000

Definition at line 239 of file chan_iax2.c.

Referenced by __find_callno(), and complete_transfer().

#define DEFAULT_THREAD_COUNT   10

Definition at line 237 of file chan_iax2.c.

#define DEFAULT_TRUNKDATA   640 * 10

40ms, uncompressed linear * 10 channels

Definition at line 610 of file chan_iax2.c.

Referenced by iax2_trunk_queue().

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

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

#define FORMAT   "%-15.15s %-15.15s %s %-15.15s %-5d%s %s %-10s%s"

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

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

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

#define FORMAT2   "%-15.15s %-15.15s %s %-15.15s %-8s %s %-10s%s"

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

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

#define GAMMA   (0.01)

Definition at line 248 of file chan_iax2.c.

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

Definition at line 531 of file chan_iax2.c.

Referenced by iax2_trunk_queue().

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

Allow the FWDOWNL command?

Definition at line 419 of file chan_iax2.c.

Referenced by set_config(), and socket_process().

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

Already disconnected

Definition at line 402 of file chan_iax2.c.

Referenced by __do_deliver(), __get_from_jb(), iax2_hangup(), iax2_predestroy(), iax2_write(), pvt_destructor(), and socket_process().

#define IAX_CALLENCRYPTED

(

pvt

)

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

Definition at line 336 of file chan_iax2.c.

Referenced by iax2_send(), iax2_start_transfer(), and socket_process().

#define IAX_CAPABILITY_FULLBANDWIDTH   0xFFFF

Definition at line 311 of file chan_iax2.c.

Referenced by cache_get_callno_locked(), and set_config().

#define IAX_CAPABILITY_LOWBANDWIDTH

Value:

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

Definition at line 322 of file chan_iax2.c.

Referenced by set_config().

#define IAX_CAPABILITY_LOWFREE

Value:

(IAX_CAPABILITY_LOWBANDWIDTH & \
                     ~AST_FORMAT_G723_1)

Definition at line 327 of file chan_iax2.c.

#define IAX_CAPABILITY_MEDBANDWIDTH

Definition at line 313 of file chan_iax2.c.

Referenced by set_config().

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

only consider requested format and ignore capabilities

Definition at line 409 of file chan_iax2.c.

Referenced by build_user(), check_access(), handle_cli_iax2_show_users(), set_config(), and socket_process().

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

Force old behaviour by turning off prefs

Definition at line 408 of file chan_iax2.c.

Referenced by build_user(), check_access(), handle_cli_iax2_show_users(), set_config(), and socket_process().

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

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

Definition at line 407 of file chan_iax2.c.

Referenced by build_user(), check_access(), handle_cli_iax2_show_users(), set_config(), and socket_process().

#define IAX_DEBUGDIGEST	(	msg,
		key		)

Definition at line 339 of file chan_iax2.c.

Referenced by iax2_key_rotate(), and socket_process().

#define IAX_DELAYPBXSTART   (uint64_t)(1 << 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 418 of file chan_iax2.c.

Referenced by socket_process().

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

Needs to be deleted

Definition at line 394 of file chan_iax2.c.

Referenced by build_peer(), build_user(), peer_delme_cb(), prune_peers(), prune_users(), and user_delme_cb().

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

dynamic peer

Definition at line 399 of file chan_iax2.c.

Referenced by __iax2_show_peers(), build_peer(), function_iaxpeer(), handle_cli_iax2_show_peer(), manager_iax2_show_peer_list(), realtime_peer(), register_verify(), and set_config().

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

Whether we should assume encrypted tx/rx

Definition at line 405 of file chan_iax2.c.

Referenced by authenticate_reply(), authenticate_request(), iax2_send(), and socket_process().

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

Forces call encryption, if encryption not possible hangup

Definition at line 423 of file chan_iax2.c.

Referenced by __find_callno(), authenticate_reply(), authenticate_verify(), build_peer(), build_user(), check_access(), create_addr(), iax2_call(), set_config(), and socket_process().

#define IAX_FORCEJITTERBUF   (uint64_t)(1 << 20)

Force jitterbuffer, even when bridged to a channel that can take jitter

Definition at line 413 of file chan_iax2.c.

Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), iax2_request(), schedule_delivery(), set_config(), and set_config_destroy().

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

CallerID has been specified

Definition at line 393 of file chan_iax2.c.

Referenced by build_peer(), build_user(), check_access(), and update_registry().

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

Allow immediate off-hook to extension s

Definition at line 420 of file chan_iax2.c.

Referenced by build_user(), check_access(), and socket_process().

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

Whether we have a key populated

Definition at line 406 of file chan_iax2.c.

Referenced by authenticate_reply(), decrypt_frame(), and iax2_send().

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

Maximum outstanding AUTHREQ restriction is in place

Definition at line 417 of file chan_iax2.c.

Referenced by authenticate_request(), authenticate_verify(), check_access(), and iax2_destroy_helper().

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

Don't native bridge

Definition at line 397 of file chan_iax2.c.

Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), iax2_bridge(), iax2_request(), iax2_start_transfer(), set_config(), and set_config_destroy().

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

This is a provisioning request

Definition at line 403 of file chan_iax2.c.

Referenced by iax2_provision(), and socket_process().

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

Whether or not we quelch audio

Definition at line 404 of file chan_iax2.c.

Referenced by iax2_write(), and socket_process().

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

Allow receiving of connected line updates

Definition at line 422 of file chan_iax2.c.

Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), iax2_request(), set_config(), set_config_destroy(), and socket_process().

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

erase me on expire

Definition at line 412 of file chan_iax2.c.

Referenced by __expire_registry(), handle_cli_iax2_prune_realtime(), realtime_peer(), and set_config().

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

let realtime stay till your reload

Definition at line 410 of file chan_iax2.c.

Referenced by __expire_registry(), handle_cli_iax2_prune_realtime(), prune_peers(), prune_users(), realtime_peer(), realtime_user(), set_config(), and update_registry().

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

When using realtime, ignore registration expiration

Definition at line 414 of file chan_iax2.c.

Referenced by realtime_peer(), and set_config().

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

Save Systname on Realtime Updates

Definition at line 401 of file chan_iax2.c.

Referenced by realtime_update_peer(), and set_config().

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

Send a realtime update

Definition at line 411 of file chan_iax2.c.

Referenced by __expire_registry(), set_config(), and update_registry().

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

Send ANI along with CallerID

Definition at line 400 of file chan_iax2.c.

Referenced by build_peer(), create_addr(), iax2_call(), and iax2_request().

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

Allow sending of connected line updates

Definition at line 421 of file chan_iax2.c.

Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), iax2_indicate(), iax2_request(), set_config(), and set_config_destroy().

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

Turn on and off caller id shrinking

Definition at line 424 of file chan_iax2.c.

Referenced by check_access(), and set_config().

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

Temporary (realtime)

Definition at line 395 of file chan_iax2.c.

Referenced by __expire_registry(), realtime_peer(), realtime_user(), reg_source_db(), and update_registry().

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

When doing IAX2 transfers, transfer media only

Definition at line 416 of file chan_iax2.c.

Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), iax2_bridge(), iax2_request(), set_config(), and set_config_destroy().

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

Treat as a trunk

Definition at line 396 of file chan_iax2.c.

Referenced by __iax2_show_peers(), build_peer(), build_user(), check_access(), create_addr(), handle_cli_iax2_show_peer(), iax2_getpeertrunk(), iax2_request(), iax2_send(), manager_iax2_show_peer_list(), and socket_process().

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

Send trunk timestamps

Definition at line 415 of file chan_iax2.c.

Referenced by iax2_trunk_queue(), send_trunk(), and set_config().

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

Use jitter buffer

Definition at line 398 of file chan_iax2.c.

Referenced by __find_callno(), ast_cli_netstats(), build_peer(), build_user(), check_access(), create_addr(), handle_cli_iax2_show_channels(), iax2_request(), log_jitterstats(), schedule_delivery(), set_config(), and set_config_destroy().

#define MARK_IAX_SUBCLASS_TX   0x8000

Definition at line 618 of file chan_iax2.c.

Referenced by ast_cli_netstats(), handle_cli_iax2_show_channels(), and iax2_send().

#define MAX_JITTER_BUFFER   50

Definition at line 607 of file chan_iax2.c.

#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 869 of file chan_iax2.c.

Referenced by load_objects().

#define MAX_RETRY_TIME   10000

Definition at line 605 of file chan_iax2.c.

Referenced by __attempt_transmit(), and iax2_send().

#define MAX_TIMESTAMP_SKEW   160

maximum difference between actual and predicted ts for sending

Definition at line 612 of file chan_iax2.c.

Referenced by ast_rtp_raw_write(), calc_timestamp(), and calc_txpeerstamp().

#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 257 of file chan_iax2.c.

Referenced by handle_cli_iax2_set_mtu(), and set_config().

#define MAX_TRUNKDATA   640 * 200

40ms, uncompressed linear * 200 channels

Definition at line 278 of file chan_iax2.c.

Referenced by set_config(), and set_config_destroy().

#define MAX_USER_BUCKETS   MAX_PEER_BUCKETS

Definition at line 873 of file chan_iax2.c.

Referenced by load_module(), and load_objects().

#define MEMORY_SIZE   100

Definition at line 240 of file chan_iax2.c.

#define MIN_JITTER_BUFFER   10

Definition at line 608 of file chan_iax2.c.

#define MIN_RETRY_TIME   100

Definition at line 604 of file chan_iax2.c.

Referenced by iax2_send().

#define MIN_REUSE_TIME   60

Definition at line 245 of file chan_iax2.c.

Referenced by make_trunk(), and sched_delay_remove().

#define PTR_TO_CALLNO

(

a

)

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

Definition at line 234 of file chan_iax2.c.

Referenced by __auto_congest(), __get_from_jb(), acf_channel_read(), acf_channel_write(), function_iaxpeer(), iax2_answer(), iax2_bridge(), iax2_call(), iax2_digit_begin(), iax2_digit_end(), iax2_fixup(), iax2_hangup(), iax2_indicate(), iax2_prov_app(), iax2_sendhtml(), iax2_sendimage(), iax2_sendtext(), iax2_setoption(), iax2_transfer(), iax2_write(), and scheduled_destroy().

#define SCHED_MULTITHREADED

Definition at line 223 of file chan_iax2.c.

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

Definition at line 1398 of file chan_iax2.c.

Referenced by attempt_transmit(), auth_reject(), auto_congest(), auto_hangup(), expire_registry(), get_from_jb(), iax2_do_register_s(), iax2_poke_noanswer(), iax2_poke_peer_s(), send_lagrq(), and send_ping().

#define TRUNK_CALL_START   ARRAY_LEN(iaxs) / 2

Definition at line 1083 of file chan_iax2.c.

Referenced by __find_callno(), create_callno_pools(), make_trunk(), replace_callno(), update_max_nontrunk(), and update_max_trunk().

#define TS_GAP_FOR_JB_RESYNC   5000

Definition at line 615 of file chan_iax2.c.

---

Enumeration Type Documentation

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 929 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

Enumerator:

NEW_PREVENT
NEW_ALLOW
NEW_FORCE
NEW_ALLOW_CALLTOKEN_VALIDATED

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

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

enum iax2_state

Enumerator:

IAX_STATE_STARTED
IAX_STATE_AUTHENTICATED
IAX_STATE_TBD

Definition at line 381 of file chan_iax2.c.

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

enum iax2_thread_iostate

Enumerator:

IAX_IOSTATE_IDLE
IAX_IOSTATE_READY
IAX_IOSTATE_PROCESSING
IAX_IOSTATE_SCHEDREADY

Definition at line 970 of file chan_iax2.c.

                         {
   IAX_IOSTATE_IDLE,
   IAX_IOSTATE_READY,
   IAX_IOSTATE_PROCESSING,
   IAX_IOSTATE_SCHEDREADY,
};

enum iax2_thread_type

Enumerator:

IAX_THREAD_TYPE_POOL
IAX_THREAD_TYPE_DYNAMIC

Definition at line 977 of file chan_iax2.c.

                      {
   IAX_THREAD_TYPE_POOL,
   IAX_THREAD_TYPE_DYNAMIC,
};

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

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 573 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

static void __attempt_transmit

(

const void *

data

)

[static]

Definition at line 3351 of file chan_iax2.c.

References chan_iax2_pvt::addr, iax_frame::af, AST_CAUSE_DESTINATION_OUT_OF_ORDER, AST_CONTROL_HANGUP, AST_FRAME_CONTROL, AST_FRAME_IAX, ast_inet_ntoa(), AST_LIST_REMOVE, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), attempt_transmit(), iax_frame::callno, chan_iax2_pvt::error, f, iax_frame::final, frame_queue, ast_frame::frametype, ast_channel::hangupcause, iax2_destroy(), iax2_frame_free(), iax2_queue_frame(), iax2_sched_add(), IAX_COMMAND_TXREJ, IAX_DEFAULT_REG_EXPIRE, LOG_WARNING, MAX_RETRY_TIME, ast_channel::name, 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().

{
   /* 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 */ ||
          (f->retries >= max_retries) /* Too many attempts */) {
            /* Record an error if we've transmitted too many times */
            if (f->retries >= max_retries) {
               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 = %d, subclass = %d, ts=%d, seqno=%d)\n", ast_inet_ntoa(iaxs[f->callno]->addr.sin_addr),iaxs[f->callno]->owner->name , f->af.frametype, f->af.subclass, 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)
                        iaxs[callno]->owner->hangupcause = 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]);
   }
}

static void __auth_reject

(

const void *

nothing

)

[static]

Definition at line 8679 of file chan_iax2.c.

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, iax_ie_data::pos, and send_command_final().

Referenced by auth_reject().

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

static void __auto_congest

(

const void *

nothing

)

[static]

Definition at line 4498 of file chan_iax2.c.

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

Referenced by auto_congest().

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

static void __auto_hangup

(

const void *

nothing

)

[static]

Definition at line 8728 of file chan_iax2.c.

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, iax_ie_data::pos, and send_command_final().

Referenced by auto_hangup().

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

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 3146 of file chan_iax2.c.

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

Referenced by __get_from_jb(), and schedule_delivery().

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

static void __expire_registry

(

const void *

data

)

[static]

Definition at line 8327 of file chan_iax2.c.

References iax2_peer::addr, ast_db_del(), ast_debug, AST_DEVICE_UNAVAILABLE, ast_devstate_changed(), ast_test_flag64, EVENT_FLAG_SYSTEM, iax2_peer::expire, iax2_peer::expiry, iax2_regfunk, IAX_RTAUTOCLEAR, IAX_RTCACHEFRIENDS, IAX_RTUPDATE, IAX_TEMPONLY, manager_event, iax2_peer::name, peer_unref(), peercnt_modify(), realtime_update_peer(), register_peer_exten(), and unlink_peer().

Referenced by expire_registry().

{
   struct iax2_peer *peer = (struct iax2_peer *) data;

   if (!peer)
      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);
   manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "ChannelType: IAX2\r\nPeer: IAX2/%s\r\nPeerStatus: Unregistered\r\nCause: Expired\r\n", peer->name);
   /* modify entry in peercnts table as _not_ registered */
   peercnt_modify(0, 0, &peer->addr);
   /* Reset the address */
   memset(&peer->addr, 0, sizeof(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, "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);
}

static int __find_callno	(	unsigned short	callno,
		unsigned short	dcallno,
		struct sockaddr_in *	sin,
		int	new,
		int	sockfd,
		int	return_locked,
		int	check_dcallno
	)			[static]

Definition at line 2624 of file chan_iax2.c.

References chan_iax2_pvt::addr, chan_iax2_pvt::amaflags, ao2_find, ao2_ref, ast_copy_flags64, ast_debug, ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_string_field_set, callno_entry::callno, chan_iax2_pvt::callno, chan_iax2_pvt::callno_entry, DEFAULT_RETRY_TIME, chan_iax2_pvt::expiry, get_unused_callno(), iax2_getpeername(), iax2_sched_add(), IAX_FORCE_ENCRYPT, IAX_FORCEJITTERBUF, IAX_NOTRANSFER, IAX_RECVCONNECTEDLINE, IAX_SENDCONNECTEDLINE, IAX_TRANSFERMEDIA, IAX_USEJITTERBUF, chan_iax2_pvt::lagid, LOG_WARNING, match(), NEW_ALLOW, new_iax(), OBJ_POINTER, parkinglot, chan_iax2_pvt::peercallno, peercnt_add(), peercnt_remove_by_addr(), chan_iax2_pvt::pingid, chan_iax2_pvt::pingtime, replace_callno(), send_lagrq(), send_ping(), chan_iax2_pvt::sockfd, store_by_peercallno(), chan_iax2_pvt::transfer, TRUNK_CALL_START, and update_max_nontrunk().

Referenced by find_callno(), and find_callno_locked().

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

         memcpy(&tmp_pvt.addr, sin, sizeof(tmp_pvt.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));
         memcpy(&tmp_pvt.transfer, sin, sizeof(tmp_pvt.transfer));
         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(sin, 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]);
      }
#ifdef IAX_OLD_FIND
      /* If we get here, we SHOULD NOT find a call structure for this
         callno; if we do, it means that there is a call structure that
         has a peer callno but did NOT get entered into the hash table,
         which is bad.

         If we find a call structure using this old, slow method, output a log
         message so we'll know about it. After a few months of leaving this in
         place, if we don't hear about people seeing these messages, we can
         remove this code for good.
      */

      for (x = 1; !res && x < maxnontrunkcall; x++) {
         ast_mutex_lock(&iaxsl[x]);
         if (iaxs[x]) {
            /* Look for an exact match */
            if (match(sin, callno, dcallno, iaxs[x], check_dcallno)) {
               res = x;
            }
         }
         if (!res || !return_locked)
            ast_mutex_unlock(&iaxsl[x]);
      }
      for (x = TRUNK_CALL_START; !res && x < maxtrunkcall; x++) {
         ast_mutex_lock(&iaxsl[x]);
         if (iaxs[x]) {
            /* Look for an exact match */
            if (match(sin, callno, dcallno, iaxs[x], check_dcallno)) {
               res = x;
            }
         }
         if (!res || !return_locked)
            ast_mutex_unlock(&iaxsl[x]);
      }
#endif
   }
   if (!res && (new >= NEW_ALLOW)) {
      struct callno_entry *callno_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(*sin, host, sizeof(host)))
         snprintf(host, sizeof(host), "%s:%d", ast_inet_ntoa(sin->sin_addr), ntohs(sin->sin_port));

      if (peercnt_add(sin)) {
         /* This address has hit its callnumber limit.  When the limit
          * is reached, the connection is not added to the peercnts table.*/
         return 0;
      }

      if (!(callno_entry = get_unused_callno(0, validated))) {
         /* since we ran out of space, remove the peercnt
          * entry we added earlier */
         peercnt_remove_by_addr(sin);
         ast_log(LOG_WARNING, "No more space\n");
         return 0;
      }
      x = callno_entry->callno;
      ast_mutex_lock(&iaxsl[x]);

      iaxs[x] = new_iax(sin, host);
      update_max_nontrunk();
      if (iaxs[x]) {
         if (iaxdebug)
            ast_debug(1, "Creating new call structure %d\n", x);
         iaxs[x]->callno_entry = callno_entry;
         iaxs[x]->sockfd = sockfd;
         iaxs[x]->addr.sin_port = sin->sin_port;
         iaxs[x]->addr.sin_family = sin->sin_family;
         iaxs[x]->addr.sin_addr.s_addr = sin->sin_addr.s_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_FORCEJITTERBUF | 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);
         return 0;
      }
      if (!return_locked)
         ast_mutex_unlock(&iaxsl[x]);
      res = x;
   }
   return res;
}

static void __get_from_jb

(

const void *

p

)

[static]

Definition at line 3924 of file chan_iax2.c.

References __do_deliver(), ast_codec_interp_len(), ast_format_rate(), AST_FRAME_VOICE, AST_FRIENDLY_OFFSET, ast_mutex_lock(), ast_mutex_unlock(), ast_samp2tv(), ast_test_flag64, ast_tvadd(), ast_tvdiff_ms(), ast_tvnow(), jb_frame::data, ast_frame::delivery, ast_frame::frametype, iax2_frame_free(), iax2_queue_frame(), IAX_ALREADYGONE, chan_iax2_pvt::jb, JB_DROP, JB_EMPTY, jb_get(), JB_INTERP, jb_next(), JB_NOFRAME, JB_OK, chan_iax2_pvt::jbid, jb_frame::ms, ast_frame::offset, 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().

{
   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();
   
   /* 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))) {
      ret = jb_get(pvt->jb,&frame,ms,ast_codec_interp_len(pvt->voiceformat));
      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 = pvt->voiceformat;
         af.samples  = frame.ms * (ast_format_rate(pvt->voiceformat) / 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;
      }
   }
   if (pvt)
      update_jbsched(pvt);
   ast_mutex_unlock(&iaxsl[callno]);
}

static void __iax2_do_register_s

(

const void *

data

)

[static]

Definition at line 8009 of file chan_iax2.c.

References iax2_registry::expire, and iax2_do_register().

Referenced by iax2_do_register_s().

{
   struct iax2_registry *reg = (struct iax2_registry *)data;
   reg->expire = -1;
   iax2_do_register(reg);
}

static void __iax2_poke_noanswer

(

const void *

data

)

[static]

Definition at line 11553 of file chan_iax2.c.

References AST_DEVICE_UNAVAILABLE, ast_devstate_changed(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), iax2_peer::callno, EVENT_FLAG_SYSTEM, iax2_destroy(), iax2_poke_peer_s(), iax2_sched_add(), iax2_peer::lastms, LOG_NOTICE, manager_event, iax2_peer::name, peer_ref(), peer_unref(), iax2_peer::pokeexpire, and iax2_peer::pokefreqnotok.

Referenced by iax2_poke_noanswer().

{
   struct iax2_peer *peer = (struct iax2_peer *)data;
   int callno;

   if (peer->lastms > -1) {
      ast_log(LOG_NOTICE, "Peer '%s' is now UNREACHABLE! Time: %d\n", peer->name, peer->lastms);
      manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "ChannelType: IAX2\r\nPeer: IAX2/%s\r\nPeerStatus: Unreachable\r\nTime: %d\r\n", peer->name, peer->lastms);
      ast_devstate_changed(AST_DEVICE_UNAVAILABLE, "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);
}

static void __iax2_poke_peer_s

(

const void *

data

)

[static]

Definition at line 8788 of file chan_iax2.c.

References iax2_poke_peer(), and peer_unref().

Referenced by iax2_poke_peer_s().

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

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

Definition at line 6405 of file chan_iax2.c.

References iax2_peer::addr, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_cli(), ast_copy_string(), ast_inet_ntoa(), ast_str_alloca, ast_str_buffer(), ast_strlen_zero(), ast_test_flag64, astman_append(), iax2_peer::encmethods, encmethods_to_str(), FORMAT, FORMAT2, IAX_DYNAMIC, IAX_TRUNK, iax2_peer::mask, iax2_peer::name, name, peer_status(), peer_unref(), RESULT_SHOWUSAGE, RESULT_SUCCESS, status, and iax2_peer::username.

Referenced by handle_cli_iax2_show_peers(), and manager_iax2_show_peers().

{
   regex_t regexbuf;
   int havepattern = 0;
   int total_peers = 0;
   int online_peers = 0;
   int offline_peers = 0;
   int unmonitored_peers = 0;
   struct ao2_iterator i;

#define FORMAT2 "%-15.15s  %-15.15s %s  %-15.15s  %-8s  %s %-10s%s"
#define FORMAT "%-15.15s  %-15.15s %s  %-15.15s  %-5d%s  %s %-10s%s"

   struct iax2_peer *peer = NULL;
   char name[256];
   struct ast_str *encmethods = ast_str_alloca(256);
   int registeredonly=0;
   char *term = manager ? "\r\n" : "\n";
   char idtext[256] = "";
   switch (argc) {
   case 6:
      if (!strcasecmp(argv[3], "registered"))
         registeredonly = 1;
      else
         return RESULT_SHOWUSAGE;
      if (!strcasecmp(argv[4], "like")) {
         if (regcomp(&regexbuf, argv[5], REG_EXTENDED | REG_NOSUB))
            return RESULT_SHOWUSAGE;
         havepattern = 1;
      } else
         return RESULT_SHOWUSAGE;
      break;
   case 5:
      if (!strcasecmp(argv[3], "like")) {
         if (regcomp(&regexbuf, argv[4], REG_EXTENDED | REG_NOSUB))
            return RESULT_SHOWUSAGE;
         havepattern = 1;
      } else
         return RESULT_SHOWUSAGE;
      break;
   case 4:
      if (!strcasecmp(argv[3], "registered"))
         registeredonly = 1;
      else
         return RESULT_SHOWUSAGE;
      break;
   case 3:
      break;
   default:
      return RESULT_SHOWUSAGE;
   }


   if (!s)
      ast_cli(fd, FORMAT2, "Name/Username", "Host", "   ", "Mask", "Port", "   ", "Status", term);

   i = ao2_iterator_init(peers, 0);
   for (peer = ao2_iterator_next(&i); peer; 
      peer_unref(peer), peer = ao2_iterator_next(&i)) {
      char nm[20];
      char status[20];
      int retstatus;

      if (registeredonly && !peer->addr.sin_addr.s_addr)
         continue;
      if (havepattern && regexec(&regexbuf, peer->name, 0, NULL, 0))
         continue;

      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)
         online_peers++;
      else if (!retstatus)
         offline_peers++;
      else
         unmonitored_peers++;

      ast_copy_string(nm, ast_inet_ntoa(peer->mask), sizeof(nm));

      if (s) {
         astman_append(s,
            "Event: PeerEntry\r\n%s"
            "Channeltype: IAX2\r\n"
            "ChanObjectType: peer\r\n"
            "ObjectName: %s\r\n"
            "IPaddress: %s\r\n"
            "IPport: %d\r\n"
            "Dynamic: %s\r\n"
            "Trunk: %s\r\n"
            "Encryption: %s\r\n"
            "Status: %s\r\n\r\n",
            idtext,
            name,
            peer->addr.sin_addr.s_addr ? ast_inet_ntoa(peer->addr.sin_addr) : "-none-",
            ntohs(peer->addr.sin_port),
            ast_test_flag64(peer, IAX_DYNAMIC) ? "yes" : "no",
            ast_test_flag64(peer, IAX_TRUNK) ? "yes" : "no",
            peer->encmethods ? ast_str_buffer(encmethods) : "no",
            status);
      } else {
         ast_cli(fd, FORMAT, name,
            peer->addr.sin_addr.s_addr ? ast_inet_ntoa(peer->addr.sin_addr) : "(Unspecified)",
            ast_test_flag64(peer, IAX_DYNAMIC) ? "(D)" : "(S)",
            nm,
            ntohs(peer->addr.sin_port),
            ast_test_flag64(peer, IAX_TRUNK) ? "(T)" : "   ",
            peer->encmethods ? "(E)" : "   ",
            status,
            term);
      }
      total_peers++;
   }
   ao2_iterator_destroy(&i);

   if (!s)
      ast_cli(fd,"%d iax2 peers [%d online, %d offline, %d unmonitored]%s", total_peers, online_peers, offline_peers, unmonitored_peers, term);

   if (havepattern)
      regfree(&regexbuf);

   return RESULT_SUCCESS;
#undef FORMAT
#undef FORMAT2
}

static void __reg_module

(

void

)

[static]

Definition at line 14038 of file chan_iax2.c.

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

Definition at line 1373 of file chan_iax2.c.

References ast_copy_string(), ast_debug, iax2_thread::cond, iax2_thread::curfunc, find_idle_thread(), IAX_IOSTATE_SCHEDREADY, iax2_thread::iostate, iax2_thread::lock, iax2_thread::scheddata, iax2_thread::schedfunc, signal_condition(), and thread.

{
   struct iax2_thread *thread = NULL;
   static time_t lasterror;
   static 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) 
      ast_debug(1, "Out of idle IAX2 threads for scheduling!\n");
   lasterror = t;

   return -1;
}

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 7209 of file chan_iax2.c.

References ast_frame::data, ast_frame::datalen, ast_frame::frametype, iax2_send(), ast_frame::ptr, queue_signalling(), ast_frame::src, and ast_frame::subclass.

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

{
   struct ast_frame f = { 0, };
   int res = 0;

   f.frametype = type;
   f.subclass = 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);
}

static void __send_lagrq

(

const void *

data

)

[static]

Definition at line 1478 of file chan_iax2.c.

References ast_debug, AST_FRAME_IAX, ast_mutex_lock(), ast_mutex_unlock(), iax2_thread::callno, iax2_sched_add(), IAX_COMMAND_LAGRQ, chan_iax2_pvt::lagid, send_command(), and send_lagrq().

Referenced by send_lagrq().

{
   int callno = (long) data;

   ast_mutex_lock(&iaxsl[callno]);

   if (iaxs[callno]) {
      if (iaxs[callno]->peercallno) {
         send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_LAGRQ, 0, NULL, 0, -1);
         iaxs[callno]->lagid = iax2_sched_add(sched, lagrq_time * 1000, send_lagrq, data);
      } else {
         /* I am the schedule, so I'm allowed to do this */
         iaxs[callno]->lagid = -1;
      }
   } else {
      ast_debug(1, "I was supposed to send a LAGRQ with callno %d, but no such call exists.\n", callno);
   }

   ast_mutex_unlock(&iaxsl[callno]);
}

static void __send_ping

(

const void *

data

)

[static]

Definition at line 1417 of file chan_iax2.c.

References ast_debug, AST_FRAME_IAX, ast_mutex_lock(), ast_mutex_unlock(), iax2_thread::callno, iax2_sched_add(), IAX_COMMAND_PING, chan_iax2_pvt::pingid, send_command(), and send_ping().

Referenced by send_ping().

{
   int callno = (long) data;

   ast_mutex_lock(&iaxsl[callno]);

   if (iaxs[callno]) {
      if (iaxs[callno]->peercallno) {
         send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_PING, 0, NULL, 0, -1);
         iaxs[callno]->pingid = iax2_sched_add(sched, ping_time * 1000, send_ping, data);
      } else {
         /* I am the schedule, so I'm allowed to do this */
         iaxs[callno]->pingid = -1;
      }
   } else {
      ast_debug(1, "I was supposed to send a PING with callno %d, but no such call exists.\n", callno);
   }

   ast_mutex_unlock(&iaxsl[callno]);
}

static int __unload_module

(

void

)

[static]

Definition at line 13739 of file chan_iax2.c.

References ao2_ref, ARRAY_LEN, ast_channel_unregister(), ast_cli_unregister_multiple(), ast_context_destroy(), ast_context_find(), AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_manager_unregister(), ast_mutex_destroy(), ast_netsock_release(), AST_PTHREADT_NULL, ast_sched_thread_destroy(), ast_taskprocessor_unreference(), ast_timer_close(), ast_unload_realtime(), ast_unregister_application(), ast_unregister_switch(), delete_users(), iax2_destroy(), iax_provision_unload(), iaxactivethreadcount, reload_firmware(), thread, and iax2_thread::threadid.

{
   struct iax2_thread *thread = NULL;
   struct ast_context *con;
   int x;

   if (netthreadid != AST_PTHREADT_NULL) {
      pthread_cancel(netthreadid);
      pthread_kill(netthreadid, SIGURG);
      pthread_join(netthreadid, NULL);
   }

   sched = ast_sched_thread_destroy(sched);

   /* Call for all threads to halt */
   AST_LIST_LOCK(&idle_list);
   while ((thread = AST_LIST_REMOVE_HEAD(&idle_list, list)))
      pthread_cancel(thread->threadid);
   AST_LIST_UNLOCK(&idle_list);

   AST_LIST_LOCK(&active_list);
   while ((thread = AST_LIST_REMOVE_HEAD(&active_list, list)))
      pthread_cancel(thread->threadid);
   AST_LIST_UNLOCK(&active_list);

   AST_LIST_LOCK(&dynamic_list);
   while ((thread = AST_LIST_REMOVE_HEAD(&dynamic_list, list)))
      pthread_cancel(thread->threadid);
   AST_LIST_UNLOCK(&dynamic_list);
   
   /* Wait for threads to exit */
   while(0 < iaxactivethreadcount)
      usleep(10000);
   
   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();
   reload_firmware(1);

   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(peercnts, -1);
   ao2_ref(callno_limits, -1);
   ao2_ref(calltoken_ignores, -1);
   ao2_ref(callno_pool, -1);
   ao2_ref(callno_pool_trunk, -1);
   if (timer) {
      ast_timer_close(timer);
   }
   transmit_processor = ast_taskprocessor_unreference(transmit_processor);

   con = ast_context_find(regcontext);
   if (con)
      ast_context_destroy(con, "IAX2");
   ast_unload_realtime("iaxpeers");
   return 0;
}

static void __unreg_module

(

void

)

[static]

Definition at line 14038 of file chan_iax2.c.

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

Definition at line 13524 of file chan_iax2.c.

References chan_iax2_pvt::addr, ast_copy_string(), ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), chan_iax2_pvt::callno, LOG_ERROR, chan_iax2_pvt::osptoken, PTR_TO_CALLNO, ast_channel::tech, ast_channel::tech_pvt, and chan_iax2_pvt::username.

{
   struct chan_iax2_pvt *pvt;
   unsigned int callno;
   int res = 0;

   if (!chan || chan->tech != &iax2_tech) {
      ast_log(LOG_ERROR, "This function requires a valid IAX2 channel\n");
      return -1;
   }

   callno = PTR_TO_CALLNO(chan->tech_pvt);
   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, pvt->addr.sin_addr.s_addr ? ast_inet_ntoa(pvt->addr.sin_addr) : "", buflen);
   } else if (!strcasecmp(args, "peername")) {
      ast_copy_string(buf, pvt->username, buflen);
   } else {
      res = -1;
   }

   ast_mutex_unlock(&iaxsl[callno]);

   return res;
}

static int acf_channel_write	(	struct ast_channel *	chan,
		const char *	function,
		char *	data,
		const char *	value
	)			[static]

Definition at line 13496 of file chan_iax2.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_string_field_set, chan_iax2_pvt::callno, LOG_ERROR, chan_iax2_pvt::osptoken, PTR_TO_CALLNO, ast_channel::tech, and ast_channel::tech_pvt.

{
   struct chan_iax2_pvt *pvt;
   unsigned int callno;
   int res = 0;

   if (!chan || chan->tech != &iax2_tech) {
      ast_log(LOG_ERROR, "This function requires a valid IAX2 channel\n");
      return -1;
   }

   callno = PTR_TO_CALLNO(chan->tech_pvt);
   ast_mutex_lock(&iaxsl[callno]);
   if (!(pvt = iaxs[callno])) {
      ast_mutex_unlock(&iaxsl[callno]);
      return -1;
   }

   if (!strcasecmp(args, "osptoken"))
      ast_string_field_set(pvt, osptoken, value);
   else
      res = -1;

   ast_mutex_unlock(&iaxsl[callno]);

   return res;
}

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

Definition at line 9453 of file chan_iax2.c.

References ast_channel_datastore_find(), ast_copy_string(), AST_LIST_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_datastore::data, ast_var_t::entries, ast_var_t::name, ast_var_t::value, and var.

{
   struct ast_datastore *variablestore = ast_channel_datastore_find(chan, &iax2_variable_datastore_info, NULL);
   AST_LIST_HEAD(, ast_var_t) *varlist;
   struct ast_var_t *var;

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

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

Definition at line 9476 of file chan_iax2.c.

References ast_calloc, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_datastore_alloc, 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, ast_datastore::inheritance, LOG_ERROR, ast_var_t::name, and var.

{
   struct ast_datastore *variablestore = ast_channel_datastore_find(chan, &iax2_variable_datastore_info, NULL);
   AST_LIST_HEAD(, ast_var_t) *varlist;
   struct ast_var_t *var;

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

static int add_calltoken_ignore

(

const char *

addr

)

[static]

Definition at line 2377 of file chan_iax2.c.

References 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(), addr_range::delme, addr_range::ha, LOG_WARNING, and OBJ_POINTER.

Referenced by set_config().

{
   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 %s\n", addr);
      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;
}

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

Definition at line 4572 of file chan_iax2.c.

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

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

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

Definition at line 2039 of file chan_iax2.c.

References CMP_MATCH, CMP_STOP, addr_range::ha, ast_ha::netaddr, and ast_ha::netmask.

Referenced by load_objects().

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

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

Definition at line 2026 of file chan_iax2.c.

References addr_range::delme.

Referenced by set_config_destroy().

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

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

Definition at line 2033 of file chan_iax2.c.

References addr_range::ha, and ast_ha::netaddr.

Referenced by load_objects().

{
   const struct addr_range *lim = obj;
   return abs((int) lim->ha.netaddr.s_addr);
}

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

Definition at line 2059 of file chan_iax2.c.

References CMP_MATCH, CMP_STOP, addr_range::ha, ast_ha::netaddr, and ast_ha::netmask.

Referenced by calltoken_required(), and set_peercnt_limit().

{
   struct addr_range *addr_range = obj;
   struct sockaddr_in *sin = arg;

   if ((sin->sin_addr.s_addr & addr_range->ha.netmask.s_addr) == addr_range->ha.netaddr.s_addr) {
      return CMP_MATCH | CMP_STOP;
   }
   return 0;
}

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

Definition at line 7267 of file chan_iax2.c.

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

Referenced by check_access().

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

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

Definition at line 6972 of file chan_iax2.c.

References ACN_FORMAT1, ACN_FORMAT2, ARRAY_LEN, 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, chan_iax2_pvt::frames_received, iax_frame_subclass2str(), IAX_USEJITTERBUF, jb_getinfo(), iax_rr::jitter, 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, chan_iax2_pvt::pingtime, and chan_iax2_pvt::remote_rr.

Referenced by handle_cli_iax2_show_netstats(), and manager_iax2_show_netstats().

{
   int x;
   int numchans = 0;
   char first_message[10] = { 0, };
   char last_message[10] = { 0, };
#define ACN_FORMAT1 "%-20.25s %4d %4d %4d %5d %3d %5d %4d %6d %4d %4d %5d %3d %5d %4d %6d %s%s %4s%s\n"
#define ACN_FORMAT2 "%s %d %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 ? iaxs[x]->owner->name : "(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 ? iaxs[x]->owner->name : "(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;
}

static struct ast_channel* ast_iax2_new	(	int	callno,
		int	state,
		int	capability,
		const char *	linkedid
	)			[static, read]

Create new call, interface with the PBX core.

Definition at line 5496 of file chan_iax2.c.

References chan_iax2_pvt::accountcode, chan_iax2_pvt::adsi, ast_channel::adsicpe, ast_channel::amaflags, chan_iax2_pvt::amaflags, chan_iax2_pvt::ani, AST_ADSI_UNAVAILABLE, ast_best_codec(), ast_calloc, ast_channel_alloc, ast_channel_datastore_add(), ast_channel_release(), ast_copy_string(), ast_datastore_alloc, ast_datastore_free(), ast_debug, 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_STATE_DOWN, ast_strdup, ast_string_field_set, ast_strlen_zero(), ast_var_assign(), 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, ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_dnid, chan_iax2_pvt::cid_name, chan_iax2_pvt::cid_num, ast_callerid::cid_pres, ast_callerid::cid_rdnis, ast_callerid::cid_tns, ast_callerid::cid_ton, ast_channel::context, chan_iax2_pvt::context, ast_datastore::data, DATASTORE_INHERIT_FOREVER, chan_iax2_pvt::dnid, ast_var_t::entries, ast_channel::exten, chan_iax2_pvt::exten, chan_iax2_pvt::host, iax2_ami_channelupdate(), chan_iax2_pvt::iaxvars, ast_datastore::inheritance, chan_iax2_pvt::language, LOG_ERROR, LOG_WARNING, ast_channel::name, ast_variable::name, ast_channel::nativeformats, ast_variable::next, chan_iax2_pvt::owner, parkinglot, chan_iax2_pvt::parkinglot, pbx_builtin_setvar_helper(), chan_iax2_pvt::peeradsicpe, ast_channel::rawreadformat, ast_channel::rawwriteformat, chan_iax2_pvt::rdnis, ast_channel::readformat, ast_channel::tech, ast_channel::tech_pvt, ast_variable::value, var, chan_iax2_pvt::vars, and ast_channel::writeformat.

Referenced by iax2_request(), and socket_process().

{
   struct ast_channel *tmp;
   struct chan_iax2_pvt *i;
   struct ast_variable *v = NULL;

   if (!(i = iaxs[callno])) {
      ast_log(LOG_WARNING, "No IAX2 pvt found for callno '%d' !\n", callno);
      return NULL;
   }

   /* Don't hold call lock */
   ast_mutex_unlock(&iaxsl[callno]);
   tmp = ast_channel_alloc(1, state, i->cid_num, i->cid_name, i->accountcode, i->exten, i->context, linkedid, 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]);
         tmp = ast_channel_release(tmp);
         ast_mutex_lock(&iaxsl[callno]);
      }
      return NULL;
   }
   iax2_ami_channelupdate(i);
   if (!tmp)
      return NULL;
   tmp->tech = &iax2_tech;
   /* We can support any format by default, until we get restricted */
   tmp->nativeformats = capability;
   tmp->readformat = tmp->rawreadformat = ast_best_codec(capability);
   tmp->writeformat = tmp->rawwriteformat = ast_best_codec(capability);
   tmp->tech_pvt = CALLNO_TO_PTR(i->callno);

   if (!ast_strlen_zero(i->parkinglot))
      ast_string_field_set(tmp, parkinglot, 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))
      tmp->cid.cid_ani = ast_strdup(i->ani);
   else
      tmp->cid.cid_ani = ast_strdup(i->cid_num);
   tmp->cid.cid_dnid = ast_strdup(i->dnid);
   tmp->cid.cid_rdnis = ast_strdup(i->rdnis);
   tmp->cid.cid_pres = i->calling_pres;
   tmp->cid.cid_ton = i->calling_ton;
   tmp->cid.cid_tns = i->calling_tns;
   if (!ast_strlen_zero(i->language))
      ast_string_field_set(tmp, language, i->language);
   if (!ast_strlen_zero(i->accountcode))
      ast_string_field_set(tmp, accountcode, i->accountcode);
   if (i->amaflags)
      tmp->amaflags = i->amaflags;
   ast_copy_string(tmp->context, i->context, sizeof(tmp->context));
   ast_copy_string(tmp->exten, i->exten, sizeof(tmp->exten));
   if (i->adsi)
      tmp->adsicpe = i->peeradsicpe;
   else
      tmp->adsicpe = AST_ADSI_UNAVAILABLE;
   i->owner = tmp;
   i->capability = capability;

   /* 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);
         }
      }
   }

   if (state != AST_STATE_DOWN) {
      if (ast_pbx_start(tmp)) {
         ast_log(LOG_WARNING, "Unable to start PBX on %s\n", tmp->name);
         ast_hangup(tmp);
         i->owner = NULL;
         return NULL;
      }
   }

   ast_module_ref(ast_module_info->self);
   return tmp;
}

static int attempt_transmit

(

const void *

data

)

[static]

Definition at line 3427 of file chan_iax2.c.

References __attempt_transmit(), and schedule_action.

Referenced by __attempt_transmit(), and transmit_frame().

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

static int auth_fail	(	int	callno,
		int	failcode
	)			[static]

Definition at line 8713 of file chan_iax2.c.

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

Referenced by socket_process().

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

static int auth_reject

(

const void *

data

)

[static]

Definition at line 8699 of file chan_iax2.c.

References __auth_reject(), ast_mutex_lock(), ast_mutex_unlock(), chan_iax2_pvt::authid, and schedule_action.

Referenced by auth_fail().

{
   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
   if (schedule_action(__auth_reject, data))
#endif      
      __auth_reject(data);
   return 0;
}

static int authenticate	(	const char *	challenge,
		const char *	secret,
		const char *	keyn,
		int	authmethods,
		struct iax_ie_data *	ied,
		struct sockaddr_in *	sin,
		struct chan_iax2_pvt *	pvt
	)			[static]

Definition at line 7835 of file chan_iax2.c.

References ast_inet_ntoa(), ast_key_get, AST_KEY_PRIVATE, ast_log(), ast_sign, ast_strlen_zero(), build_encryption_keys(), IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, IAX_AUTH_RSA, iax_ie_append_str(), IAX_IE_MD5_RESULT, IAX_IE_PASSWORD, IAX_IE_RSA_RESULT, LOG_NOTICE, MD5Final(), MD5Init(), and MD5Update().

Referenced by action_login(), authenticate_reply(), and registry_rerequest().

{
   int res = -1;
   int x;
   if (!ast_strlen_zero(keyn)) {
      if (!(authmethods & IAX_AUTH_RSA)) {
         if (ast_strlen_zero(secret)) 
            ast_log(LOG_NOTICE, "Asked to authenticate to %s with an RSA key, but they don't allow RSA authentication\n", ast_inet_ntoa(sin->sin_addr));
      } else if (ast_strlen_zero(challenge)) {
         ast_log(LOG_NOTICE, "No challenge provided for RSA authentication to %s\n", ast_inet_ntoa(sin->sin_addr));
      } else {
         char sig[256];
         struct ast_key *key;
         key = ast_key_get(keyn, AST_KEY_PRIVATE);
         if (!key) {
            ast_log(LOG_NOTICE, "Unable to find private key '%s'\n", keyn);
         } else {
            if (ast_sign(key, (char*)challenge, sig)) {
               ast_log(LOG_NOTICE, "Unable to sign challenge with key\n");
               res = -1;
            } else {
               iax_ie_append_str(ied, IAX_IE_RSA_RESULT, sig);
               res = 0;
            }
         }
      }
   } 
   /* Fall back */
   if (res && !ast_strlen_zero(secret)) {
      if ((authmethods & IAX_AUTH_MD5) && !ast_strlen_zero(challenge)) {
         struct MD5Context md5;
         unsigned char digest[16];
         char digres[128];
         MD5Init(&md5);
         MD5Update(&md5, (unsigned char *)challenge, strlen(challenge));
         MD5Update(&md5, (unsigned char *)secret, strlen(secret));
         MD5Final(digest, &md5);
         /* If they support md5, authenticate with it.  */
         for (x=0;x<16;x++)
            sprintf(digres + (x << 1),  "%2.2x", digest[x]); /* safe */
         if (pvt) {
            build_encryption_keys(digest, pvt);
         }
         iax_ie_append_str(ied, IAX_IE_MD5_RESULT, digres);
         res = 0;
      } else if (authmethods & IAX_AUTH_PLAINTEXT) {
         iax_ie_append_str(ied, IAX_IE_PASSWORD, secret);
         res = 0;
      } else
         ast_log(LOG_NOTICE, "No way to send secret to peer '%s' (their methods: %d)\n", ast_inet_ntoa(sin->sin_addr), authmethods);
   }
   return res;
}

static int authenticate_reply	(	struct chan_iax2_pvt *	p,
		struct sockaddr_in *	sin,
		struct iax_ies *	ies,
		const char *	override,
		const char *	okey
	)			[static]

Note:

This function calls realtime_peer -> reg_source_db -> iax2_poke_peer -> find_callno, so do not call this function with a pvt lock held.

Definition at line 7893 of file chan_iax2.c.

References iax2_peer::addr, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_calloc, ast_channel_datastore_add(), ast_datastore_alloc, ast_datastore_free(), AST_FRAME_IAX, ast_free, AST_LIST_HEAD, AST_LIST_HEAD_INIT, AST_LIST_INSERT_TAIL, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_set_flag64, ast_strdupa, ast_string_field_set, ast_strlen_zero(), ast_test_flag64, ast_var_assign(), authenticate(), iax_ies::authmethods, iax2_peer::authmethods, iax_ie_data::buf, chan_iax2_pvt::callno, chan_iax2_pvt::challenge, iax_ies::challenge, ast_datastore::data, DATASTORE_INHERIT_FOREVER, chan_iax2_pvt::encmethods, iax_ies::encmethods, ast_var_t::entries, IAX_AUTH_MD5, IAX_COMMAND_AUTHREP, IAX_ENCRYPTED, IAX_FORCE_ENCRYPT, IAX_KEYPOPULATED, ast_datastore::inheritance, LOG_ERROR, LOG_NOTICE, iax2_peer::mask, merge_encryption(), ast_variable::name, iax2_peer::name, ast_variable::next, iax2_peer::outkey, chan_iax2_pvt::owner, chan_iax2_pvt::peer, peer_unref(), iax_ie_data::pos, realtime_peer(), iax2_peer::secret, send_command(), chan_iax2_pvt::username, iax2_peer::username, iax_ies::username, ast_variable::value, var, and iax_ies::vars.

Referenced by socket_process().

{
   struct iax2_peer *peer = NULL;
   /* Start pessimistic */
   int res = -1;
   int authmethods = 0;
   struct iax_ie_data ied;
   uint16_t callno = p->callno;

   memset(&ied, 0, sizeof(ied));
   
   if (ies->username)
      ast_string_field_set(p, username, ies->username);
   if (ies->challenge)
      ast_string_field_set(p, challenge, ies->challenge);
   if (ies->authmethods)
      authmethods = ies->authmethods;
   if (authmethods & IAX_AUTH_MD5)
      merge_encryption(p, ies->encmethods);
   else
      p->encmethods = 0;

   /* Check for override RSA authentication first */
   if (!ast_strlen_zero(override) || !ast_strlen_zero(okey)) {
      /* Normal password authentication */
      res = authenticate(p->challenge, override, okey, authmethods, &ied, sin, p);
   } else {
      struct ao2_iterator i = ao2_iterator_init(peers, 0);
      while ((peer = ao2_iterator_next(&i))) {
         if ((ast_strlen_zero(p->peer) || !strcmp(p->peer, peer->name)) 
             /* No peer specified at our end, or this is the peer */
             && (ast_strlen_zero(peer->username) || (!strcmp(peer->username, p->username)))
             /* No username specified in peer rule, or this is the right username */
             && (!peer->addr.sin_addr.s_addr || ((sin->sin_addr.s_addr & peer->mask.s_addr) == (peer->addr.sin_addr.s_addr & peer->mask.s_addr)))
             /* No specified host, or this is our host */
            ) {
            res = authenticate(p->challenge, peer->secret, peer->outkey, authmethods, &ied, sin, p);
            if (!res) {
               peer_unref(peer);
               break;
            }
         }
         peer_unref(peer);
      }
      ao2_iterator_destroy(&i);
      if (!peer) {
         /* We checked our list and didn't find one.  It's unlikely, but possible, 
            that we're trying to authenticate *to* a realtime peer */
         const char *peer_name = ast_strdupa(p->peer);
         ast_mutex_unlock(&iaxsl[callno]);
         if ((peer = realtime_peer(peer_name, NULL))) {
            ast_mutex_lock(&iaxsl[callno]);
            if (!(p = iaxs[callno])) {
               peer_unref(peer);
               return -1;
            }
            res = authenticate(p->challenge, peer->secret,peer->outkey, authmethods, &ied, sin, p);
            peer_unref(peer);
         }
         if (!peer) {
            ast_mutex_lock(&iaxsl[callno]);
            if (!(p = iaxs[callno]))
               return -1;
         }
      }
   }

   if (ies->encmethods) {
      ast_set_flag64(p, IAX_ENCRYPTED | IAX_KEYPOPULATED);
   } else if (ast_test_flag64(iaxs[callno], IAX_FORCE_ENCRYPT)) {
      ast_log(LOG_NOTICE, "Call initiated without encryption while forceencryption=yes option is set");
      return -1;             /* if force encryption is yes, and no encryption methods, then return -1 to hangup */
   }
   if (!res) {
      struct ast_datastore *variablestore;
      struct ast_variable *var, *prev = NULL;
      AST_LIST_HEAD(, ast_var_t) *varlist;
      varlist = ast_calloc(1, sizeof(*varlist));
      variablestore = ast_datastore_alloc(&iax2_variable_datastore_info, NULL);
      if (variablestore && varlist && p->owner) {
         variablestore->data = varlist;
         variablestore->inheritance = DATASTORE_INHERIT_FOREVER;
         AST_LIST_HEAD_INIT(varlist);
         for (var = ies->vars; 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 ies->vars 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);
         ies->vars = NULL;
         ast_channel_datastore_add(p->owner, variablestore);
      } else {
         if (p->owner)
            ast_log(LOG_ERROR, "Memory allocation error while processing IAX2 variables\n");
         if (variablestore)
            ast_datastore_free(variablestore);
         if (varlist)
            ast_free(varlist);
      }
   }

   if (!res)
      res = send_command(p, AST_FRAME_IAX, IAX_COMMAND_AUTHREP, 0, ied.buf, ied.pos, -1);
   return res;
}

static int authenticate_request

(

int

call_num

)

[static]

Precondition:

iaxsl[call_num] is locked

Note:

Since this function calls send_command_final(), the pvt struct for the given call number may disappear while executing this function.

Definition at line 7543 of file chan_iax2.c.

References ao2_find, AST_CAUSE_CALL_REJECTED, AST_FRAME_IAX, ast_random(), ast_set_flag64, ast_string_field_set, ast_test_flag64, chan_iax2_pvt::authmethods, iax_ie_data::buf, chan_iax2_pvt::challenge, iax2_user::curauthreq, chan_iax2_pvt::encmethods, IAX_AUTH_MD5, IAX_AUTH_RSA, IAX_COMMAND_AUTHREQ, IAX_COMMAND_REJECT, IAX_ENCRYPTED, iax_ie_append_byte(), iax_ie_append_short(), iax_ie_append_str(), IAX_IE_AUTHMETHODS, IAX_IE_CAUSE, IAX_IE_CAUSECODE, IAX_IE_CHALLENGE, IAX_IE_ENCRYPTION, IAX_IE_USERNAME, IAX_MAXAUTHREQ, iax2_user::maxauthreq, OBJ_POINTER, iax_ie_data::pos, send_command(), send_command_final(), user_unref(), and chan_iax2_pvt::username.

Referenced by socket_process().

{
   struct iax_ie_data ied;
   int res = -1, authreq_restrict = 0;
   char challenge[10];
   struct chan_iax2_pvt *p = iaxs[call_num];

   memset(&ied, 0, sizeof(ied));

   /* If an AUTHREQ restriction is in place, make sure we can send an AUTHREQ back */
   if (ast_test_flag64(p, IAX_MAXAUTHREQ)) {
      struct iax2_user *user, tmp_user = {
         .name = p->username, 
      };

      user = ao2_find(users, &tmp_user, OBJ_POINTER);
      if (user) {
         if (user->curauthreq == user->maxauthreq)
            authreq_restrict = 1;
         else
            user->curauthreq++;
         user = user_unref(user);
      }
   }

   /* If the AUTHREQ limit test failed, send back an error */
   if (authreq_restrict) {
      iax_ie_append_str(&ied, IAX_IE_CAUSE, "Unauthenticated call limit reached");
      iax_ie_append_byte(&ied, IAX_IE_CAUSECODE, AST_CAUSE_CALL_REJECTED);
      send_command_final(p, AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied.buf, ied.pos, -1);
      return 0;
   }

   iax_ie_append_short(&ied, IAX_IE_AUTHMETHODS, p->authmethods);
   if (p->authmethods & (IAX_AUTH_MD5 | IAX_AUTH_RSA)) {
      snprintf(challenge, sizeof(challenge), "%d", (int)ast_random());
      ast_string_field_set(p, challenge, challenge);
      /* snprintf(p->challenge, sizeof(p->challenge), "%d", (int)ast_random()); */
      iax_ie_append_str(&ied, IAX_IE_CHALLENGE, p->challenge);
   }
   if (p->encmethods)
      iax_ie_append_short(&ied, IAX_IE_ENCRYPTION, p->encmethods);

   iax_ie_append_str(&ied,IAX_IE_USERNAME, p->username);

   res = send_command(p, AST_FRAME_IAX, IAX_COMMAND_AUTHREQ, 0, ied.buf, ied.pos, -1);

   if (p->encmethods)
      ast_set_flag64(p, IAX_ENCRYPTED);

   return res;
}

static int authenticate_verify	(	struct chan_iax2_pvt *	p,
		struct iax_ies *	ies
	)			[static]

Definition at line 7596 of file chan_iax2.c.

References ao2_find, ast_atomic_fetchadd_int(), ast_check_signature, ast_clear_flag64, ast_copy_string(), ast_key_get, AST_KEY_PUBLIC, ast_log(), ast_strdupa, ast_string_field_set, ast_strlen_zero(), ast_test_flag, ast_test_flag64, chan_iax2_pvt::authmethods, chan_iax2_pvt::authrej, chan_iax2_pvt::challenge, iax2_user::curauthreq, chan_iax2_pvt::encmethods, IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, IAX_AUTH_RSA, IAX_FORCE_ENCRYPT, IAX_MAXAUTHREQ, IAX_STATE_AUTHENTICATED, chan_iax2_pvt::inkeys, LOG_NOTICE, LOG_WARNING, iax_ies::md5_result, MD5Final(), MD5Init(), MD5Update(), iax2_user::name, OBJ_POINTER, iax_ies::password, iax_ies::rsa_result, chan_iax2_pvt::secret, secret, chan_iax2_pvt::state, strsep(), user_unref(), and chan_iax2_pvt::username.

Referenced by socket_process().

{
   char requeststr[256];
   char md5secret[256] = "";
   char secret[256] = "";
   char rsasecret[256] = "";
   int res = -1; 
   int x;
   struct iax2_user *user, tmp_user = {
      .name = p->username, 
   };

   if (p->authrej) {
      return res;
   }
   user = ao2_find(users, &tmp_user, OBJ_POINTER);
   if (user) {
      if (ast_test_flag64(p, IAX_MAXAUTHREQ)) {
         ast_atomic_fetchadd_int(&user->curauthreq, -1);
         ast_clear_flag64(p, IAX_MAXAUTHREQ);
      }
      ast_string_field_set(p, host, user->name);
      user = user_unref(user);
   }
   if (ast_test_flag64(p, IAX_FORCE_ENCRYPT) && !p->encmethods) { 
      ast_log(LOG_NOTICE, "Call Terminated, Incomming call is unencrypted while force encrypt is enabled.");
      return res;
   }
   if (!ast_test_flag(&p->state, IAX_STATE_AUTHENTICATED))
      return res;
   if (ies->password)
      ast_copy_string(secret, ies->password, sizeof(secret));
   if (ies->md5_result)
      ast_copy_string(md5secret, ies->md5_result, sizeof(md5secret));
   if (ies->rsa_result)
      ast_copy_string(rsasecret, ies->rsa_result, sizeof(rsasecret));
   if ((p->authmethods & IAX_AUTH_RSA) && !ast_strlen_zero(rsasecret) && !ast_strlen_zero(p->inkeys)) {
      struct ast_key *key;
      char *keyn;
      char tmpkey[256];
      char *stringp=NULL;
      ast_copy_string(tmpkey, p->inkeys, sizeof(tmpkey));
      stringp=tmpkey;
      keyn = strsep(&stringp, ":");
      while(keyn) {
         key = ast_key_get(keyn, AST_KEY_PUBLIC);
         if (key && !ast_check_signature(key, p->challenge, rsasecret)) {
            res = 0;
            break;
         } else if (!key)
            ast_log(LOG_WARNING, "requested inkey '%s' for RSA authentication does not exist\n", keyn);
         keyn = strsep(&stringp, ":");
      }
   } else if (p->authmethods & IAX_AUTH_MD5) {
      struct MD5Context md5;
      unsigned char digest[16];
      char *tmppw, *stringp;
      
      tmppw = ast_strdupa(p->secret);
      stringp = tmppw;
      while((tmppw = strsep(&stringp, ";"))) {
         MD5Init(&md5);
         MD5Update(&md5, (unsigned char *)p->challenge, strlen(p->challenge));
         MD5Update(&md5, (unsigned char *)tmppw, strlen(tmppw));
         MD5Final(digest, &md5);
         /* If they support md5, authenticate with it.  */
         for (x=0;x<16;x++)
            sprintf(requeststr + (x << 1), "%2.2x", digest[x]); /* safe */
         if (!strcasecmp(requeststr, md5secret)) {
            res = 0;
            break;
         }
      }
   } else if (p->authmethods & IAX_AUTH_PLAINTEXT) {
      if (!strcmp(secret, p->secret))
         res = 0;
   }
   return res;
}

static int auto_congest

(

const void *

data

)

[static]

Definition at line 4511 of file chan_iax2.c.

References __auto_congest(), and schedule_action.

Referenced by iax2_call(), sip_call(), and sip_show_sched().

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

static int auto_hangup

(

const void *

data

)

[static]

Definition at line 8743 of file chan_iax2.c.

References __auto_hangup(), ast_mutex_lock(), ast_mutex_unlock(), chan_iax2_pvt::autoid, and schedule_action.

Referenced by iax2_dprequest(), and iax2_provision().

{
   int callno = (int)(long)(data);
   ast_mutex_lock(&iaxsl[callno]);
   if (iaxs[callno]) {
      iaxs[callno]->autoid = -1;
   }
   ast_mutex_unlock(&iaxsl[callno]);
#ifdef SCHED_MULTITHREADED
   if (schedule_action(__auto_hangup, data))
#endif      
      __auto_hangup(data);
   return 0;
}

static void build_callno_limits

(

struct ast_variable *

v

)

[static]

Definition at line 2322 of file chan_iax2.c.

References ao2_alloc, ao2_find, ao2_link, ao2_lock(), ao2_ref, ao2_unlock(), ast_append_ha(), ast_copy_ha(), ast_free_ha(), ast_log(), addr_range::delme, addr_range::ha, addr_range::limit, LOG_ERROR, ast_variable::name, ast_variable::next, OBJ_POINTER, and ast_variable::value.

Referenced by set_config().

{
   struct addr_range *addr_range = NULL;
   struct addr_range tmp;
   struct ast_ha *ha;
   int limit;
   int error;
   int found;

   for (; v; v = v->next) {
      limit = -1;
      error = 0;
      found = 0;
      ha = ast_append_ha("permit", v->name, NULL, &error);

      /* check for valid config information */
      if (error) {
         ast_log(LOG_ERROR, "Call number limit for %s could not be added, Invalid address range\n.", v->name);
         continue;
      } else if ((sscanf(v->value, "%d", &limit) != 1) || (limit < 0)) {
         ast_log(LOG_ERROR, "Call number limit for %s could not be added. Invalid limit %s\n.", v->name, v->value);
         ast_free_ha(ha);
         continue;
      }

      ast_copy_ha(ha, &tmp.ha);
      /* find or create the addr_range */
      if ((addr_range = ao2_find(callno_limits, &tmp, OBJ_POINTER))) {
         ao2_lock(addr_range);
         found = 1;
      } else if (!(addr_range = ao2_alloc(sizeof(*addr_range), NULL))) {
         ast_free_ha(ha);
         return; /* out of memory */
      }

      /* copy over config data into addr_range object */
      ast_copy_ha(ha, &addr_range->ha); /* this is safe because only one ha is possible for each limit */
      ast_free_ha(ha); /* cleanup the tmp ha */
      addr_range->limit = limit;
      addr_range->delme = 0;

      /* cleanup */
      if (found) {
         ao2_unlock(addr_range);
      } else {
         ao2_link(callno_limits, addr_range);
      }
      ao2_ref(addr_range, -1); /* decrement ref from ao2_find and ao2_alloc, only container ref remains */
   }
}

static struct iax2_context* build_context

(

const char *

context

)

[static, read]

Definition at line 11796 of file chan_iax2.c.

References ast_calloc, ast_copy_string(), and iax2_context::context.

Referenced by build_user().

{
   struct iax2_context *con;

   if ((con = ast_calloc(1, sizeof(*con))))
      ast_copy_string(con->context, context, sizeof(con->context));
   
   return con;
}

static void build_ecx_key	(	const unsigned char *	digest,
		struct chan_iax2_pvt *	pvt
	)			[static]

Definition at line 5954 of file chan_iax2.c.

References ast_aes_decrypt_key, ast_aes_encrypt_key, build_rand_pad(), chan_iax2_pvt::ecx, chan_iax2_pvt::mydcx, and chan_iax2_pvt::semirand.

Referenced by build_encryption_keys(), and iax2_key_rotate().

{
   /* it is required to hold the corresponding decrypt key to our encrypt key
    * in the pvt struct because queued frames occasionally need to be decrypted and
    * re-encrypted when updated for a retransmission */
   build_rand_pad(pvt->semirand, sizeof(pvt->semirand));
   ast_aes_encrypt_key(digest, &pvt->ecx);
   ast_aes_decrypt_key(digest, &pvt->mydcx);
}

static void build_encryption_keys	(	const unsigned char *	digest,
		struct chan_iax2_pvt *	pvt
	)			[static]

Definition at line 5948 of file chan_iax2.c.

References ast_aes_decrypt_key, build_ecx_key(), and chan_iax2_pvt::dcx.

Referenced by authenticate(), and decrypt_frame().

{
   build_ecx_key(digest, pvt);
   ast_aes_decrypt_key(digest, &pvt->dcx);
}

static struct iax2_peer * build_peer	(	const char *	name,
		struct ast_variable *	v,
		struct ast_variable *	alt,
		int	temponly
	)			[static, read]

Create peer structure based on configuration.

Definition at line 11944 of file chan_iax2.c.

References iax2_peer::addr, iax2_peer::adsi, ao2_alloc, ao2_find, ast_append_ha(), ast_callerid_split(), ast_clear_flag64, ast_copy_flags64, ast_dnsmgr_lookup(), AST_EVENT_IE_CONTEXT, AST_EVENT_IE_END, AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, AST_EVENT_MWI, ast_event_subscribe(), ast_false(), ast_free_ha(), ast_get_ip(), ast_log(), ast_parse_allow_disallow(), ast_sched_thread_del, ast_set2_flag64, ast_set_flag64, ast_set_flags_to64, ast_strdupa, ast_string_field_init, ast_string_field_set, ast_strlen_zero(), ast_test_flag64, ast_true(), iax2_peer::authmethods, CALLTOKEN_AUTO, CALLTOKEN_DEFAULT, CALLTOKEN_NO, iax2_peer::calltoken_required, CALLTOKEN_YES, iax2_peer::capability, cid_name, cid_num, context, iax2_peer::dbsecret, iax2_peer::defaddr, DEFAULT_FREQ_NOTOK, DEFAULT_FREQ_OK, DEFAULT_MAXMS, iax2_peer::dnsmgr, iax2_peer::encmethods, iax2_peer::expire, iax2_peer::expiry, get_auth_methods(), get_encrypt_methods(), iax2_peer::ha, IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, IAX_DEFAULT_PORTNO, IAX_DELME, IAX_DYNAMIC, IAX_FORCE_ENCRYPT, IAX_FORCEJITTERBUF, IAX_HASCALLERID, IAX_NOTRANSFER, IAX_RECVCONNECTEDLINE, IAX_SENDANI, IAX_SENDCONNECTEDLINE, IAX_TRANSFERMEDIA, IAX_TRUNK, IAX_USEJITTERBUF, inet_aton(), iax2_peer::inkeys, ast_variable::lineno, LOG_WARNING, iax2_peer::mailbox, mailbox, iax2_peer::mask, iax2_peer::maxcallno, iax2_peer::maxms, mwi_event_cb(), iax2_peer::mwi_event_sub, ast_variable::name, iax2_peer::name, ast_variable::next, OBJ_POINTER, iax2_peer::outkey, peer_destructor(), peer_set_srcaddr(), peer_unref(), peercnt_modify(), iax2_peer::peercontext, iax2_peer::pokeexpire, iax2_peer::pokefreqnotok, iax2_peer::pokefreqok, prefs, iax2_peer::prefs, iax2_peer::regexten, S_OR, secret, iax2_peer::smoothing, iax2_peer::sockfd, strsep(), unlink_peer(), ast_variable::value, and zonetag.

{
   struct iax2_peer *peer = NULL;
   struct ast_ha *oldha = NULL;
   int maskfound = 0;
   int found = 0;
   int firstpass = 1;
   struct iax2_peer tmp_peer = {
      .name = name,
   };

   if (!temponly) {
      peer = ao2_find(peers, &tmp_peer, OBJ_POINTER);
      if (peer && !ast_test_flag64(peer, IAX_DELME))
         firstpass = 0;
   }

   if (peer) {
      found++;
      if (firstpass) {
         oldha = peer->ha;
         peer->ha = NULL;
      }
      unlink_peer(peer);
   } else if ((peer = ao2_alloc(sizeof(*peer), peer_destructor))) {
      peer->expire = -1;
      peer->pokeexpire = -1;
      peer->sockfd = defaultsockfd;
      if (ast_string_field_init(peer, 32))
         peer = peer_unref(peer);
   }

   if (peer) {
      if (firstpass) {
         ast_copy_flags64(peer, &globalflags, IAX_USEJITTERBUF | IAX_FORCEJITTERBUF | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE | IAX_FORCE_ENCRYPT);
         peer->encmethods = iax2_encryption;
         peer->adsi = adsi;
         ast_string_field_set(peer,secret,"");
         if (!found) {
            ast_string_field_set(peer, name, name);
            peer->addr.sin_port = htons(IAX_DEFAULT_PORTNO);
            peer->expiry = min_reg_expire;
         }
         peer->prefs = prefs;
         peer->capability = iax2_capability;
         peer->smoothing = 0;
         peer->pokefreqok = DEFAULT_FREQ_OK;
         peer->pokefreqnotok = DEFAULT_FREQ_NOTOK;
         peer->maxcallno = 0;
         peercnt_modify(0, 0, &peer->addr);
         peer->calltoken_required = CALLTOKEN_DEFAULT;
         ast_string_field_set(peer,context,"");
         ast_string_field_set(peer,peercontext,"");
         ast_clear_flag64(peer, IAX_HASCALLERID);
         ast_string_field_set(peer, cid_name, "");
         ast_string_field_set(peer, cid_num, "");
         ast_string_field_set(peer, mohinterpret, mohinterpret);
         ast_string_field_set(peer, mohsuggest, mohsuggest);
      }

      if (!v) {
         v = alt;
         alt = NULL;
      }
      while(v) {
         if (!strcasecmp(v->name, "secret")) {
            ast_string_field_set(peer, secret, v->value);
         } else if (!strcasecmp(v->name, "mailbox")) {
            ast_string_field_set(peer, mailbox, v->value);
         } else if (!strcasecmp(v->name, "hasvoicemail")) {
            if (ast_true(v->value) && ast_strlen_zero(peer->mailbox)) {
               ast_string_field_set(peer, mailbox, name);
            }
         } else if (!strcasecmp(v->name, "mohinterpret")) {
            ast_string_field_set(peer, mohinterpret, v->value);
         } else if (!strcasecmp(v->name, "mohsuggest")) {
            ast_string_field_set(peer, mohsuggest, v->value);
         } else if (!strcasecmp(v->name, "dbsecret")) {
            ast_string_field_set(peer, dbsecret, v->value);
         } else if (!strcasecmp(v->name, "trunk")) {
            ast_set2_flag64(peer, ast_true(v->value), IAX_TRUNK); 
            if (ast_test_flag64(peer, IAX_TRUNK) && !timer) {
               ast_log(LOG_WARNING, "Unable to support trunking on peer '%s' without a timing interface\n", peer->name);
               ast_clear_flag64(peer, IAX_TRUNK);
            }
         } else if (!strcasecmp(v->name, "auth")) {
            peer->authmethods = get_auth_methods(v->value);
         } else if (!strcasecmp(v->name, "encryption")) {
            peer->encmethods |= get_encrypt_methods(v->value);
            if (!peer->encmethods) {
               ast_clear_flag64(peer, IAX_FORCE_ENCRYPT);
            }
         } else if (!strcasecmp(v->name, "forceencryption")) {
            if (ast_false(v->value)) {
               ast_clear_flag64(peer, IAX_FORCE_ENCRYPT);
            } else {
               peer->encmethods |= get_encrypt_methods(v->value);
               if (peer->encmethods) {
                  ast_set_flag64(peer, IAX_FORCE_ENCRYPT);
               }
            }
         } else if (!strcasecmp(v->name, "transfer")) {
            if (!strcasecmp(v->value, "mediaonly")) {
               ast_set_flags_to64(peer, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, IAX_TRANSFERMEDIA);
            } else if (ast_true(v->value)) {
               ast_set_flags_to64(peer, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, 0);
            } else
               ast_set_flags_to64(peer, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, IAX_NOTRANSFER);
         } else if (!strcasecmp(v->name, "jitterbuffer")) {
            ast_set2_flag64(peer, ast_true(v->value), IAX_USEJITTERBUF);
         } else if (!strcasecmp(v->name, "forcejitterbuffer")) {
            ast_set2_flag64(peer, ast_true(v->value), IAX_FORCEJITTERBUF);
         } else if (!strcasecmp(v->name, "host")) {
            if (!strcasecmp(v->value, "dynamic")) {
               /* They'll register with us */
               ast_set_flag64(peer, IAX_DYNAMIC);
               if (!found) {
                  /* Initialize stuff iff we're not found, otherwise
                     we keep going with what we had */
                  memset(&peer->addr.sin_addr, 0, 4);
                  if (peer->addr.sin_port) {
                     /* If we've already got a port, make it the default rather than absolute */
                     peer->defaddr.sin_port = peer->addr.sin_port;
                     peer->addr.sin_port = 0;
                  }
               }
            } else {
               /* Non-dynamic.  Make sure we become that way if we're not */
               ast_sched_thread_del(sched, peer->expire);
               ast_clear_flag64(peer, IAX_DYNAMIC);
               if (ast_dnsmgr_lookup(v->value, &peer->addr, &peer->dnsmgr, srvlookup ? "_iax._udp" : NULL))
                  return peer_unref(peer);
               if (!peer->addr.sin_port)
                  peer->addr.sin_port = htons(IAX_DEFAULT_PORTNO);
            }
            if (!maskfound)
               inet_aton("255.255.255.255", &peer->mask);
         } else if (!strcasecmp(v->name, "defaultip")) {
            if (ast_get_ip(&peer->defaddr, v->value))
               return peer_unref(peer);
         } else if (!strcasecmp(v->name, "sourceaddress")) {
            peer_set_srcaddr(peer, v->value);
         } else if (!strcasecmp(v->name, "permit") ||
                  !strcasecmp(v->name, "deny")) {
            peer->ha = ast_append_ha(v->name, v->value, peer->ha, NULL);
         } else if (!strcasecmp(v->name, "mask")) {
            maskfound++;
            inet_aton(v->value, &peer->mask);
         } else if (!strcasecmp(v->name, "context")) {
            ast_string_field_set(peer, context, v->value);
         } else if (!strcasecmp(v->name, "regexten")) {
            ast_string_field_set(peer, regexten, v->value);
         } else if (!strcasecmp(v->name, "peercontext")) {
            ast_string_field_set(peer, peercontext, v->value);
         } else if (!strcasecmp(v->name, "port")) {
            if (ast_test_flag64(peer, IAX_DYNAMIC))
               peer->defaddr.sin_port = htons(atoi(v->value));
            else
               peer->addr.sin_port = htons(atoi(v->value));
         } else if (!strcasecmp(v->name, "username")) {
            ast_string_field_set(peer, username, v->value);
         } else if (!strcasecmp(v->name, "allow")) {
            ast_parse_allow_disallow(&peer->prefs, &peer->capability, v->value, 1);
         } else if (!strcasecmp(v->name, "disallow")) {
            ast_parse_allow_disallow(&peer->prefs, &peer->capability, v->value, 0);
         } else if (!strcasecmp(v->name, "callerid")) {
            if (!ast_strlen_zero(v->value)) {
               char name2[80];
               char num2[80];
               ast_callerid_split(v->value, name2, sizeof(name2), num2, sizeof(num2));
               ast_string_field_set(peer, cid_name, name2);
               ast_string_field_set(peer, cid_num, num2);
            } else {
               ast_string_field_set(peer, cid_name, "");
               ast_string_field_set(peer, cid_num, "");
            }
            ast_set_flag64(peer, IAX_HASCALLERID);
         } else if (!strcasecmp(v->name, "fullname")) {
            ast_string_field_set(peer, cid_name, S_OR(v->value, ""));
            ast_set_flag64(peer, IAX_HASCALLERID);
         } else if (!strcasecmp(v->name, "cid_number")) {
            ast_string_field_set(peer, cid_num, S_OR(v->value, ""));
            ast_set_flag64(peer, IAX_HASCALLERID);
         } else if (!strcasecmp(v->name, "sendani")) {
            ast_set2_flag64(peer, ast_true(v->value), IAX_SENDANI);
         } else if (!strcasecmp(v->name, "inkeys")) {
            ast_string_field_set(peer, inkeys, v->value);
         } else if (!strcasecmp(v->name, "outkey")) {
            ast_string_field_set(peer, outkey, v->value);
         } else if (!strcasecmp(v->name, "qualify")) {
            if (!strcasecmp(v->value, "no")) {
               peer->maxms = 0;
            } else if (!strcasecmp(v->value, "yes")) {
               peer->maxms = DEFAULT_MAXMS;
            } else if (sscanf(v->value, "%30d", &peer->maxms) != 1) {
               ast_log(LOG_WARNING, "Qualification of peer '%s' should be 'yes', 'no', or a number of milliseconds at line %d of iax.conf\n", peer->name, v->lineno);
               peer->maxms = 0;
            }
         } else if (!strcasecmp(v->name, "qualifysmoothing")) {
            peer->smoothing = ast_true(v->value);
         } else if (!strcasecmp(v->name, "qualifyfreqok")) {
            if (sscanf(v->value, "%30d", &peer->pokefreqok) != 1) {
               ast_log(LOG_WARNING, "Qualification testing frequency of peer '%s' when OK should a number of milliseconds at line %d of iax.conf\n", peer->name, v->lineno);
            }
         } else if (!strcasecmp(v->name, "qualifyfreqnotok")) {
            if (sscanf(v->value, "%30d", &peer->pokefreqnotok) != 1) {
               ast_log(LOG_WARNING, "Qualification testing frequency of peer '%s' when NOT OK should be a number of milliseconds at line %d of iax.conf\n", peer->name, v->lineno);
            } else ast_log(LOG_WARNING, "Set peer->pokefreqnotok to %d\n", peer->pokefreqnotok);
         } else if (!strcasecmp(v->name, "timezone")) {
            ast_string_field_set(peer, zonetag, v->value);
         } else if (!strcasecmp(v->name, "adsi")) {
            peer->adsi = ast_true(v->value);
         } else if (!strcasecmp(v->name, "connectedline")) {
            if (ast_true(v->value)) {
               ast_set_flag64(peer, IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE);
            } else if (!strcasecmp(v->value, "send")) {
               ast_clear_flag64(peer, IAX_RECVCONNECTEDLINE);
               ast_set_flag64(peer, IAX_SENDCONNECTEDLINE);
            } else if (!strcasecmp(v->value, "receive")) {
               ast_clear_flag64(peer, IAX_SENDCONNECTEDLINE);
               ast_set_flag64(peer, IAX_RECVCONNECTEDLINE);
            } else {
               ast_clear_flag64(peer, IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE);
            }
         } else if (!strcasecmp(v->name, "maxcallnumbers")) {
            if (sscanf(v->value, "%10hu", &peer->maxcallno) != 1) {
               ast_log(LOG_WARNING, "maxcallnumbers must be set to a valid number. %s is not valid at line %d.\n", v->value, v->lineno);
            } else {
               peercnt_modify(1, peer->maxcallno, &peer->addr);
            }
         } else if (!strcasecmp(v->name, "requirecalltoken")) {
            /* default is required unless in optional ip list */
            if (ast_false(v->value)) {
               peer->calltoken_required = CALLTOKEN_NO;
            } else if (!strcasecmp(v->value, "auto")) {
               peer->calltoken_required = CALLTOKEN_AUTO;
            } else if (ast_true(v->value)) {
               peer->calltoken_required = CALLTOKEN_YES;
            } else {
               ast_log(LOG_WARNING, "requirecalltoken must be set to a valid value. at line %d\n", v->lineno);
            }
         } /* else if (strcasecmp(v->name,"type")) */
         /* ast_log(LOG_WARNING, "Ignoring %s\n", v->name); */
         v = v->next;
         if (!v) {
            v = alt;
            alt = NULL;
         }
      }
      if (!peer->authmethods)
         peer->authmethods = IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT;
      ast_clear_flag64(peer, IAX_DELME);
      /* Make sure these are IPv4 addresses */
      peer->addr.sin_family = AF_INET;
   }

   if (oldha)
      ast_free_ha(oldha);

   if (!ast_strlen_zero(peer->mailbox)) {
      char *mailbox, *context;
      context = mailbox = ast_strdupa(peer->mailbox);
      strsep(&context, "@");
      if (ast_strlen_zero(context))
         context = "default";
      peer->mwi_event_sub = ast_event_subscribe(AST_EVENT_MWI, mwi_event_cb, "IAX MWI subscription", NULL,
         AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, mailbox,
         AST_EVENT_IE_CONTEXT, AST_EVENT_IE_PLTYPE_STR, context,
         AST_EVENT_IE_END);
   }

   return peer;
}

static void build_rand_pad	(	unsigned char *	buf,
		ssize_t	len
	)			[static]

Definition at line 5938 of file chan_iax2.c.

References ast_random().

Referenced by build_ecx_key(), and update_packet().

{
   long tmp;
   for (tmp = ast_random(); len > 0; tmp = ast_random()) {
      memcpy(buf, (unsigned char *) &tmp, (len > sizeof(tmp)) ? sizeof(tmp) : len);
      buf += sizeof(tmp);
      len -= sizeof(tmp);
   }
}

static struct iax2_user * build_user	(	const char *	name,
		struct ast_variable *	v,
		struct ast_variable *	alt,
		int	temponly
	)			[static, read]

Create in-memory user structure from configuration.

Definition at line 12232 of file chan_iax2.c.

References iax2_user::adsi, iax2_user::amaflags, ao2_alloc, ao2_find, ao2_unlink, ast_append_ha(), ast_callerid_split(), ast_cdr_amaflags2int(), ast_clear_flag64, ast_copy_flags64, ast_false(), ast_free_ha(), ast_log(), ast_parse_allow_disallow(), ast_set2_flag64, ast_set_flag64, ast_set_flags_to64, ast_strdupa, ast_string_field_build, ast_string_field_free_memory, ast_string_field_init, ast_string_field_set, ast_strlen_zero(), ast_test_flag64, ast_true(), ast_variable_new(), iax2_user::authmethods, build_context(), CALLTOKEN_AUTO, CALLTOKEN_DEFAULT, CALLTOKEN_NO, iax2_user::calltoken_required, CALLTOKEN_YES, iax2_user::capability, iax2_user::cid_name, cid_name, iax2_user::cid_num, cid_num, cleanup(), iax2_user::contexts, iax2_user::curauthreq, iax2_user::dbsecret, iax2_user::encmethods, format, free_context(), get_auth_methods(), get_encrypt_methods(), iax2_user::ha, IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, IAX_AUTH_RSA, IAX_CODEC_NOCAP, IAX_CODEC_NOPREFS, IAX_CODEC_USER_FIRST, IAX_DELME, IAX_FORCE_ENCRYPT, IAX_FORCEJITTERBUF, IAX_HASCALLERID, IAX_IMMEDIATE, IAX_NOTRANSFER, IAX_RECVCONNECTEDLINE, IAX_SENDCONNECTEDLINE, IAX_TRANSFERMEDIA, IAX_TRUNK, IAX_USEJITTERBUF, iax2_user::inkeys, ast_variable::lineno, LOG_WARNING, iax2_user::maxauthreq, ast_variable::name, iax2_user::name, ast_variable::next, iax2_context::next, OBJ_POINTER, parkinglot, prefs, iax2_user::prefs, secret, iax2_user::secret, user_destructor(), user_unref(), ast_variable::value, and iax2_user::vars.

{
   struct iax2_user *user = NULL;
   struct iax2_context *con, *conl = NULL;
   struct ast_ha *oldha = NULL;
   struct iax2_context *oldcon = NULL;
   int format;
   int firstpass=1;
   int oldcurauthreq = 0;
   char *varname = NULL, *varval = NULL;
   struct ast_variable *tmpvar = NULL;
   struct iax2_user tmp_user = {
      .name = name,
   };

   if (!temponly) {
      user = ao2_find(users, &tmp_user, OBJ_POINTER);
      if (user && !ast_test_flag64(user, IAX_DELME))
         firstpass = 0;
   }

   if (user) {
      if (firstpass) {
         oldcurauthreq = user->curauthreq;
         oldha = user->ha;
         oldcon = user->contexts;
         user->ha = NULL;
         user->contexts = NULL;
      }
      /* Already in the list, remove it and it will be added back (or FREE'd) */
      ao2_unlink(users, user);
   } else {
      user = ao2_alloc(sizeof(*user), user_destructor);
   }
   
   if (user) {
      if (firstpass) {
         ast_string_field_free_memory(user);
         memset(user, 0, sizeof(struct iax2_user));
         if (ast_string_field_init(user, 32)) {
            user = user_unref(user);
            goto cleanup;
         }
         user->maxauthreq = maxauthreq;
         user->curauthreq = oldcurauthreq;
         user->prefs = prefs;
         user->capability = iax2_capability;
         user->encmethods = iax2_encryption;
         user->adsi = adsi;
         user->calltoken_required = CALLTOKEN_DEFAULT;
         ast_string_field_set(user, name, name);
         ast_string_field_set(user, language, language);
         ast_copy_flags64(user, &globalflags, IAX_USEJITTERBUF | IAX_FORCEJITTERBUF | IAX_CODEC_USER_FIRST | IAX_CODEC_NOPREFS | IAX_CODEC_NOCAP | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE | IAX_FORCE_ENCRYPT);
         ast_clear_flag64(user, IAX_HASCALLERID);
         ast_string_field_set(user, cid_name, "");
         ast_string_field_set(user, cid_num, "");
         ast_string_field_set(user, accountcode, accountcode);
         ast_string_field_set(user, mohinterpret, mohinterpret);
         ast_string_field_set(user, mohsuggest, mohsuggest);
      }
      if (!v) {
         v = alt;
         alt = NULL;
      }
      while(v) {
         if (!strcasecmp(v->name, "context")) {
            con = build_context(v->value);
            if (con) {
               if (conl)
                  conl->next = con;
               else
                  user->contexts = con;
               conl = con;
            }
         } else if (!strcasecmp(v->name, "permit") ||
                  !strcasecmp(v->name, "deny")) {
            user->ha = ast_append_ha(v->name, v->value, user->ha, NULL);
         } else if (!strcasecmp(v->name, "setvar")) {
            varname = ast_strdupa(v->value);
            if (varname && (varval = strchr(varname,'='))) {
               *varval = '\0';
               varval++;
               if((tmpvar = ast_variable_new(varname, varval, ""))) {
                  tmpvar->next = user->vars; 
                  user->vars = tmpvar;
               }
            }
         } else if (!strcasecmp(v->name, "allow")) {
            ast_parse_allow_disallow(&user->prefs, &user->capability, v->value, 1);
         } else if (!strcasecmp(v->name, "disallow")) {
            ast_parse_allow_disallow(&user->prefs, &user->capability,v->value, 0);
         } else if (!strcasecmp(v->name, "trunk")) {
            ast_set2_flag64(user, ast_true(v->value), IAX_TRUNK); 
            if (ast_test_flag64(user, IAX_TRUNK) && !timer) {
               ast_log(LOG_WARNING, "Unable to support trunking on user '%s' without a timing interface\n", user->name);
               ast_clear_flag64(user, IAX_TRUNK);
            }
         } else if (!strcasecmp(v->name, "auth")) {
            user->authmethods = get_auth_methods(v->value);
         } else if (!strcasecmp(v->name, "encryption")) {
            user->encmethods |= get_encrypt_methods(v->value);
            if (!user->encmethods) {
               ast_clear_flag64(user, IAX_FORCE_ENCRYPT);
            }
         } else if (!strcasecmp(v->name, "forceencryption")) {
            if (ast_false(v->value)) {
               ast_clear_flag64(user, IAX_FORCE_ENCRYPT);
            } else {
               user->encmethods |= get_encrypt_methods(v->value);
               if (user->encmethods) {
                  ast_set_flag64(user, IAX_FORCE_ENCRYPT);
               }
            }
         } else if (!strcasecmp(v->name, "transfer")) {
            if (!strcasecmp(v->value, "mediaonly")) {
               ast_set_flags_to64(user, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, IAX_TRANSFERMEDIA);
            } else if (ast_true(v->value)) {
               ast_set_flags_to64(user, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, 0);
            } else
               ast_set_flags_to64(user, IAX_NOTRANSFER|IAX_TRANSFERMEDIA, IAX_NOTRANSFER);
         } else if (!strcasecmp(v->name, "codecpriority")) {
            if(!strcasecmp(v->value, "caller"))
               ast_set_flag64(user, IAX_CODEC_USER_FIRST);
            else if(!strcasecmp(v->value, "disabled"))
               ast_set_flag64(user, IAX_CODEC_NOPREFS);
            else if(!strcasecmp(v->value, "reqonly")) {
               ast_set_flag64(user, IAX_CODEC_NOCAP);
               ast_set_flag64(user, IAX_CODEC_NOPREFS);
            }
         } else if (!strcasecmp(v->name, "immediate")) {
            ast_set2_flag64(user, ast_true(v->value), IAX_IMMEDIATE);
         } else if (!strcasecmp(v->name, "jitterbuffer")) {
            ast_set2_flag64(user, ast_true(v->value), IAX_USEJITTERBUF);
         } else if (!strcasecmp(v->name, "forcejitterbuffer")) {
            ast_set2_flag64(user, ast_true(v->value), IAX_FORCEJITTERBUF);
         } else if (!strcasecmp(v->name, "dbsecret")) {
            ast_string_field_set(user, dbsecret, v->value);
         } else if (!strcasecmp(v->name, "secret")) {
            if (!ast_strlen_zero(user->secret)) {
               char *old = ast_strdupa(user->secret);

               ast_string_field_build(user, secret, "%s;%s", old, v->value);
            } else
               ast_string_field_set(user, secret, v->value);
         } else if (!strcasecmp(v->name, "callerid")) {
            if (!ast_strlen_zero(v->value) && strcasecmp(v->value, "asreceived")) {
               char name2[80];
               char num2[80];
               ast_callerid_split(v->value, name2, sizeof(name2), num2, sizeof(num2));
               ast_string_field_set(user, cid_name, name2);
               ast_string_field_set(user, cid_num, num2);
               ast_set_flag64(user, IAX_HASCALLERID);
            } else {
               ast_clear_flag64(user, IAX_HASCALLERID);
               ast_string_field_set(user, cid_name, "");
               ast_string_field_set(user, cid_num, "");
            }
         } else if (!strcasecmp(v->name, "fullname")) {
            if (!ast_strlen_zero(v->value)) {
               ast_string_field_set(user, cid_name, v->value);
               ast_set_flag64(user, IAX_HASCALLERID);
            } else {
               ast_string_field_set(user, cid_name, "");
               if (ast_strlen_zero(user->cid_num))
                  ast_clear_flag64(user, IAX_HASCALLERID);
            }
         } else if (!strcasecmp(v->name, "cid_number")) {
            if (!ast_strlen_zero(v->value)) {
               ast_string_field_set(user, cid_num, v->value);
               ast_set_flag64(user, IAX_HASCALLERID);
            } else {
               ast_string_field_set(user, cid_num, "");
               if (ast_strlen_zero(user->cid_name))
                  ast_clear_flag64(user, IAX_HASCALLERID);
            }
         } else if (!strcasecmp(v->name, "accountcode")) {
            ast_string_field_set(user, accountcode, v->value);
         } else if (!strcasecmp(v->name, "mohinterpret")) {
            ast_string_field_set(user, mohinterpret, v->value);
         } else if (!strcasecmp(v->name, "mohsuggest")) {
            ast_string_field_set(user, mohsuggest, v->value);
         } else if (!strcasecmp(v->name, "parkinglot")) {
            ast_string_field_set(user, parkinglot, v->value);
         } else if (!strcasecmp(v->name, "language")) {
            ast_string_field_set(user, language, v->value);
         } else if (!strcasecmp(v->name, "amaflags")) {
            format = ast_cdr_amaflags2int(v->value);
            if (format < 0) {
               ast_log(LOG_WARNING, "Invalid AMA Flags: %s at line %d\n", v->value, v->lineno);
            } else {
               user->amaflags = format;
            }
         } else if (!strcasecmp(v->name, "inkeys")) {
            ast_string_field_set(user, inkeys, v->value);
         } else if (!strcasecmp(v->name, "maxauthreq")) {
            user->maxauthreq = atoi(v->value);
            if (user->maxauthreq < 0)
               user->maxauthreq = 0;
         } else if (!strcasecmp(v->name, "adsi")) {
            user->adsi = ast_true(v->value);
         } else if (!strcasecmp(v->name, "connectedline")) {
            if (ast_true(v->value)) {
               ast_set_flag64(user, IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE);
            } else if (!strcasecmp(v->value, "send")) {
               ast_clear_flag64(user, IAX_RECVCONNECTEDLINE);
               ast_set_flag64(user, IAX_SENDCONNECTEDLINE);
            } else if (!strcasecmp(v->value, "receive")) {
               ast_clear_flag64(user, IAX_SENDCONNECTEDLINE);
               ast_set_flag64(user, IAX_RECVCONNECTEDLINE);
            } else {
               ast_clear_flag64(user, IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE);
            }
         } else if (!strcasecmp(v->name, "requirecalltoken")) {
            /* default is required unless in optional ip list */
            if (ast_false(v->value)) {
               user->calltoken_required = CALLTOKEN_NO;
            } else if (!strcasecmp(v->value, "auto")) {
               user->calltoken_required = CALLTOKEN_AUTO;
            } else if (ast_true(v->value)) {
               user->calltoken_required = CALLTOKEN_YES;
            } else {
               ast_log(LOG_WARNING, "requirecalltoken must be set to a valid value. at line %d\n", v->lineno);
            }
         } /* else if (strcasecmp(v->name,"type")) */
         /* ast_log(LOG_WARNING, "Ignoring %s\n", v->name); */
         v = v->next;
         if (!v) {
            v = alt;
            alt = NULL;
         }
      }
      if (!user->authmethods) {
         if (!ast_strlen_zero(user->secret)) {
            user->authmethods = IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT;
            if (!ast_strlen_zero(user->inkeys))
               user->authmethods |= IAX_AUTH_RSA;
         } else if (!ast_strlen_zero(user->inkeys)) {
            user->authmethods = IAX_AUTH_RSA;
         } else {
            user->authmethods = IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT;
         }
      }
      ast_clear_flag64(user, IAX_DELME);
   }
cleanup:
   if (oldha)
      ast_free_ha(oldha);
   if (oldcon)
      free_context(oldcon);
   return user;
}

static int cache_get_callno_locked

(

const char *

data

)

[static]

Definition at line 13101 of file chan_iax2.c.

References add_empty_calltoken_ie(), ARRAY_LEN, ast_debug, AST_FRAME_IAX, ast_log(), ast_mutex_trylock(), ast_mutex_unlock(), ast_strdupa, ast_string_field_set, ast_strlen_zero(), iax_ie_data::buf, chan_iax2_pvt::capability, parsed_dial_string::context, create_addr(), parsed_dial_string::exten, find_callno_locked(), IAX_CAPABILITY_FULLBANDWIDTH, IAX_COMMAND_NEW, iax_ie_append_int(), iax_ie_append_short(), iax_ie_append_str(), IAX_IE_CALLED_CONTEXT, IAX_IE_CALLED_NUMBER, IAX_IE_CAPABILITY, IAX_IE_FORMAT, IAX_IE_USERNAME, IAX_IE_VERSION, IAX_PROTO_VERSION, parsed_dial_string::key, LOG_WARNING, NEW_FORCE, parse_dial_string(), parsed_dial_string::password, parsed_dial_string::peer, iax_ie_data::pos, secret, send_command(), create_addr_info::sockfd, and parsed_dial_string::username.

Referenced by find_cache().

{
   struct sockaddr_in sin;
   int x;
   int callno;
   struct iax_ie_data ied;
   struct create_addr_info cai;
   struct parsed_dial_string pds;
   char *tmpstr;

   for (x = 0; x < ARRAY_LEN(iaxs); x++) {
      /* Look for an *exact match* call.  Once a call is negotiated, it can only
         look up entries for a single context */
      if (!ast_mutex_trylock(&iaxsl[x])) {
         if (iaxs[x] && !strcasecmp(data, iaxs[x]->dproot))
            return x;
         ast_mutex_unlock(&iaxsl[x]);
      }
   }

   /* No match found, we need to create a new one */

   memset(&cai, 0, sizeof(cai));
   memset(&ied, 0, sizeof(ied));
   memset(&pds, 0, sizeof(pds));

   tmpstr = ast_strdupa(data);
   parse_dial_string(tmpstr, &pds);

   if (ast_strlen_zero(pds.peer)) {
      ast_log(LOG_WARNING, "No peer provided in the IAX2 dial string '%s'\n", data);
      return -1;
   }

   /* Populate our address from the given */
   if (create_addr(pds.peer, NULL, &sin, &cai))
      return -1;

   ast_debug(1, "peer: %s, username: %s, password: %s, context: %s\n",
      pds.peer, pds.username, pds.password, pds.context);

   callno = find_callno_locked(0, 0, &sin, NEW_FORCE, cai.sockfd, 0);
   if (callno < 1) {
      ast_log(LOG_WARNING, "Unable to create call\n");
      return -1;
   }

   ast_string_field_set(iaxs[callno], dproot, data);
   iaxs[callno]->capability = IAX_CAPABILITY_FULLBANDWIDTH;

   iax_ie_append_short(&ied, IAX_IE_VERSION, IAX_PROTO_VERSION);
   iax_ie_append_str(&ied, IAX_IE_CALLED_NUMBER, "TBD");
   /* the string format is slightly different from a standard dial string,
      because the context appears in the 'exten' position
   */
   if (pds.exten)
      iax_ie_append_str(&ied, IAX_IE_CALLED_CONTEXT, pds.exten);
   if (pds.username)
      iax_ie_append_str(&ied, IAX_IE_USERNAME, pds.username);
   iax_ie_append_int(&ied, IAX_IE_FORMAT, IAX_CAPABILITY_FULLBANDWIDTH);
   iax_ie_append_int(&ied, IAX_IE_CAPABILITY, IAX_CAPABILITY_FULLBANDWIDTH);
   /* Keep password handy */
   if (pds.password)
      ast_string_field_set(iaxs[callno], secret, pds.password);
   if (pds.key)
      ast_string_field_set(iaxs[callno], outkey, pds.key);
   /* Start the call going */
   add_empty_calltoken_ie(iaxs[callno], &ied); /* this _MUST_ be the last ie added */
   send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_NEW, 0, ied.buf, ied.pos, -1);

   return callno;
}

static unsigned int calc_rxstamp	(	struct chan_iax2_pvt *	p,
		unsigned int	offset
	)			[static]

Definition at line 5790 of file chan_iax2.c.

References ast_debug, ast_random(), ast_samp2tv(), ast_tvdiff_ms(), ast_tvnow(), ast_tvsub(), ast_tvzero(), chan_iax2_pvt::callno, and chan_iax2_pvt::rxcore.

Referenced by ast_rtp_read(), and schedule_delivery().

{
   /* Returns where in "receive time" we are.  That is, how many ms
      since we received (or would have received) the frame with timestamp 0 */
   int ms;
#ifdef IAXTESTS
   int jit;
#endif /* IAXTESTS */
   /* Setup rxcore if necessary */
   if (ast_tvzero(p->rxcore)) {
      p->rxcore = ast_tvnow();
      if (iaxdebug)
         ast_debug(1, "calc_rxstamp: call=%d: rxcore set to %d.%6.6d - %dms\n",
               p->callno, (int)(p->rxcore.tv_sec), (int)(p->rxcore.tv_usec), offset);
      p->rxcore = ast_tvsub(p->rxcore, ast_samp2tv(offset, 1000));
#if 1
      if (iaxdebug)
         ast_debug(1, "calc_rxstamp: call=%d: works out as %d.%6.6d\n",
               p->callno, (int)(p->rxcore.tv_sec),(int)( p->rxcore.tv_usec));
#endif
   }

   ms = ast_tvdiff_ms(ast_tvnow(), p->rxcore);
#ifdef IAXTESTS
   if (test_jit) {
      if (!test_jitpct || ((100.0 * ast_random() / (RAND_MAX + 1.0)) < test_jitpct)) {
         jit = (int)((float)test_jit * ast_random() / (RAND_MAX + 1.0));
         if ((int)(2.0 * ast_random() / (RAND_MAX + 1.0)))
            jit = -jit;
         ms += jit;
      }
   }
   if (test_late) {
      ms += test_late;
      test_late = 0;
   }
#endif /* IAXTESTS */
   return ms;
}

static unsigned int calc_timestamp	(	struct chan_iax2_pvt *	p,
		unsigned int	ts,
		struct ast_frame *	f
	)			[static]

Definition at line 5657 of file chan_iax2.c.

References ast_debug, ast_format_rate(), AST_FRAME_CNG, AST_FRAME_IAX, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_samp2tv(), ast_tvadd(), ast_tvdiff_ms(), ast_tvnow(), ast_tvsub(), ast_tvzero(), chan_iax2_pvt::callno, ast_frame::delivery, ast_frame::frametype, iax2_trunk_peer::lastsent, chan_iax2_pvt::lastsent, MAX_TIMESTAMP_SKEW, chan_iax2_pvt::nextpred, chan_iax2_pvt::notsilenttx, chan_iax2_pvt::offset, chan_iax2_pvt::peercallno, ast_frame::samples, and ast_frame::subclass.

Referenced by iax2_send(), and socket_process().

{
   int ms;
   int voice = 0;
   int genuine = 0;
   int adjust;
   int rate = ast_format_rate(f->subclass) / 1000;
   struct timeval *delivery = NULL;


   /* What sort of frame do we have?: voice is self-explanatory
      "genuine" means an IAX frame - things like LAGRQ/RP, PING/PONG, ACK
      non-genuine frames are CONTROL frames [ringing etc], DTMF
      The "genuine" distinction is needed because genuine frames must get a clock-based timestamp,
      the others need a timestamp slaved to the voice frames so that they go in sequence
   */
   if (f) {
      if (f->frametype == AST_FRAME_VOICE) {
         voice = 1;
         delivery = &f->delivery;
      } else if (f->frametype == AST_FRAME_IAX) {
         genuine = 1;
      } else if (f->frametype == AST_FRAME_CNG) {
         p->notsilenttx = 0;  
      }
   }
   if (ast_tvzero(p->offset)) {
      p->offset = ast_tvnow();
      /* Round to nearest 20ms for nice looking traces */
      p->offset.tv_usec -= p->offset.tv_usec % 20000;
   }
   /* If the timestamp is specified, just send it as is */
   if (ts)
      return ts;
   /* If we have a time that the frame arrived, always use it to make our timestamp */
   if (delivery && !ast_tvzero(*delivery)) {
      ms = ast_tvdiff_ms(*delivery, p->offset);
      if (ms < 0) {
         ms = 0;
      }
      if (iaxdebug)
         ast_debug(3, "calc_timestamp: call %d/%d: Timestamp slaved to delivery time\n", p->callno, iaxs[p->callno]->peercallno);
   } else {
      ms = ast_tvdiff_ms(ast_tvnow(), p->offset);
      if (ms < 0)
         ms = 0;
      if (voice) {
         /* On a voice frame, use predicted values if appropriate */
         if (p->notsilenttx && abs(ms - p->nextpred) <= MAX_TIMESTAMP_SKEW) {
            /* Adjust our txcore, keeping voice and non-voice synchronized */
            /* AN EXPLANATION:
               When we send voice, we usually send "calculated" timestamps worked out
               on the basis of the number of samples sent. When we send other frames,
               we usually send timestamps worked out from the real clock.
               The problem is that they can tend to drift out of step because the 
                  source channel's clock and our clock may not be exactly at the same rate.
               We fix this by continuously "tweaking" p->offset.  p->offset is "time zero"
               for this call.  Moving it adjusts timestamps for non-voice frames.
               We make the adjustment in the style of a moving average.  Each time we
               adjust p->offset by 10% of the difference between our clock-derived
               timestamp and the predicted timestamp.  That's why you see "10000"
               below even though IAX2 timestamps are in milliseconds.
               The use of a moving average avoids offset moving too radically.
               Generally, "adjust" roams back and forth around 0, with offset hardly
               changing at all.  But if a consistent different starts to develop it
               will be eliminated over the course of 10 frames (200-300msecs) 
            */
            adjust = (ms - p->nextpred);
            if (adjust < 0)
               p->offset = ast_tvsub(p->offset, ast_samp2tv(abs(adjust), 10000));
            else if (adjust > 0)
               p->offset = ast_tvadd(p->offset, ast_samp2tv(adjust, 10000));

            if (!p->nextpred) {
               p->nextpred = ms; /*f->samples / rate;*/
               if (p->nextpred <= p->lastsent)
                  p->nextpred = p->lastsent + 3;
            }
            ms = p->nextpred;
         } else {
                /* in this case, just use the actual
            * time, since we're either way off
            * (shouldn't happen), or we're  ending a
            * silent period -- and seed the next
            * predicted time.  Also, round ms to the
            * next multiple of frame size (so our
            * silent periods are multiples of
            * frame size too) */

            if (iaxdebug && abs(ms - p->nextpred) > MAX_TIMESTAMP_SKEW )
               ast_debug(1, "predicted timestamp skew (%u) > max (%u), using real ts instead.\n",
                  abs(ms - p->nextpred), MAX_TIMESTAMP_SKEW);

            if (f->samples >= rate) /* check to make sure we dont core dump */
            {
               int diff = ms % (f->samples / rate);
               if (diff)
                   ms += f->samples/rate - diff;
            }

            p->nextpred = ms;
            p->notsilenttx = 1;
         }
      } else if ( f->frametype == AST_FRAME_VIDEO ) {
         /*
         * IAX2 draft 03 says that timestamps MUST be in order.
         * It does not say anything about several frames having the same timestamp
         * When transporting video, we can have a frame that spans multiple iax packets
         * (so called slices), so it would make sense to use the same timestamp for all of
         * them
         * We do want to make sure that frames don't go backwards though
         */
         if ( (unsigned int)ms < p->lastsent )
            ms = p->lastsent;
      } else {
         /* On a dataframe, use last value + 3 (to accomodate jitter buffer shrinking) if appropriate unless
            it's a genuine frame */
         if (genuine) {
            /* genuine (IAX LAGRQ etc) must keep their clock-based stamps */
            if (ms <= p->lastsent)
               ms = p->lastsent + 3;
         } else if (abs(ms - p->lastsent) <= MAX_TIMESTAMP_SKEW) {
            /* non-genuine frames (!?) (DTMF, CONTROL) should be pulled into the predicted stream stamps */
            ms = p->lastsent + 3;
         }
      }
   }
   p->lastsent = ms;
   if (voice)
      p->nextpred = p->nextpred + f->samples / rate;
   return ms;
}

static unsigned int calc_txpeerstamp	(	struct iax2_trunk_peer *	tpeer,
		int	sampms,
		struct timeval *	now
	)			[static]

Definition at line 5613 of file chan_iax2.c.

References ast_tvdiff_ms(), ast_tvzero(), iax2_trunk_peer::lastsent, iax2_trunk_peer::lasttxtime, MAX_TIMESTAMP_SKEW, iax2_trunk_peer::trunkact, and iax2_trunk_peer::txtrunktime.

Referenced by send_trunk().

{
   unsigned long int mssincetx; /* unsigned to handle overflows */
   long int ms, pred;

   tpeer->trunkact = *now;
   mssincetx = ast_tvdiff_ms(*now, tpeer->lasttxtime);
   if (mssincetx > 5000 || ast_tvzero(tpeer->txtrunktime)) {
      /* If it's been at least 5 seconds since the last time we transmitted on this trunk, reset our timers */
      tpeer->txtrunktime = *now;
      tpeer->lastsent = 999999;
   }
   /* Update last transmit time now */
   tpeer->lasttxtime = *now;
   
   /* Calculate ms offset */
   ms = ast_tvdiff_ms(*now, tpeer->txtrunktime);
   /* Predict from last value */
   pred = tpeer->lastsent + sampms;
   if (abs(ms - pred) < MAX_TIMESTAMP_SKEW)
      ms = pred;
   
   /* We never send the same timestamp twice, so fudge a little if we must */
   if (ms == tpeer->lastsent)
      ms = tpeer->lastsent + 1;
   tpeer->lastsent = ms;
   return ms;
}

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

Definition at line 2527 of file chan_iax2.c.

References ast_random().

Referenced by create_callno_pools().

{
   return abs(ast_random());
}

static int calltoken_required	(	struct sockaddr_in *	sin,
		const char *	name,
		int	subclass
	)			[static]

Definition at line 2075 of file chan_iax2.c.

References addr_range_match_address_cb(), ao2_callback, ao2_ref, ast_debug, ast_inet_ntoa(), CALLTOKEN_AUTO, CALLTOKEN_DEFAULT, CALLTOKEN_NO, iax2_peer::calltoken_required, iax2_user::calltoken_required, find_peer(), find_user(), IAX_COMMAND_NEW, peer_unref(), realtime_peer(), realtime_user(), S_OR, and user_unref().

Referenced by handle_call_token().

{
   struct addr_range *addr_range;
   struct iax2_peer *peer = NULL;
   struct iax2_user *user = NULL;
   /* if no username is given, check for guest accounts */
   const char *find = S_OR(name, "guest");
   int res = 1;  /* required by default */
   int optional = 0;
   enum calltoken_peer_enum calltoken_required = CALLTOKEN_DEFAULT;
   /* There are only two cases in which calltoken validation is not required.
    * Case 1. sin falls within the list of address ranges specified in the calltoken optional table and
    *         the peer definition has not set the requirecalltoken option.
    * Case 2. Username is a valid peer/user, and that peer has requirecalltoken set either auto or no.
    */

   /* ----- Case 1 ----- */
   if ((addr_range = ao2_callback(calltoken_ignores, 0, addr_range_match_address_cb, sin))) {
      ao2_ref(addr_range, -1);
      optional = 1;
   }

   /* ----- Case 2 ----- */
   if ((subclass == IAX_COMMAND_NEW) && (user = find_user(find))) {
      calltoken_required = user->calltoken_required;
   } else if ((subclass == IAX_COMMAND_NEW) && (user = realtime_user(find, sin))) {
      calltoken_required = user->calltoken_required;
   } else if ((subclass != IAX_COMMAND_NEW) && (peer = find_peer(find, 0))) {
      calltoken_required = peer->calltoken_required;
   } else if ((subclass != IAX_COMMAND_NEW) && (peer = realtime_peer(find, sin))) {
      calltoken_required = peer->calltoken_required;
   }

   if (peer) {
      peer_unref(peer);
   }
   if (user) {
      user_unref(user);
   }

   ast_debug(1, "Determining if address %s with username %s requires calltoken validation.  Optional = %d  calltoken_required = %d \n", ast_inet_ntoa(sin->sin_addr), name, optional, calltoken_required);
   if (((calltoken_required == CALLTOKEN_NO) || (calltoken_required == CALLTOKEN_AUTO)) ||
      (optional && (calltoken_required == CALLTOKEN_DEFAULT))) {
      res = 0;
   }

   return res;
}

static int check_access	(	int	callno,
		struct sockaddr_in *	sin,
		struct iax_ies *	ies
	)			[static]

Definition at line 7278 of file chan_iax2.c.

References iax2_user::accountcode, iax2_user::adsi, chan_iax2_pvt::adsi, iax_ies::adsicpe, chan_iax2_pvt::amaflags, iax2_user::amaflags, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, apply_context(), ast_apply_ha(), ast_codec_pref_convert(), ast_copy_flags64, ast_db_get(), ast_inet_ntoa(), ast_log(), AST_PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN, AST_PRES_NUMBER_NOT_AVAILABLE, ast_set2_flag64, ast_set_flag64, ast_shrink_phone_number(), ast_strdupa, ast_string_field_set, ast_strlen_zero(), ast_test_flag64, ast_variable_new(), iax2_user::authmethods, chan_iax2_pvt::authmethods, chan_iax2_pvt::authrej, iax_ies::called_context, iax_ies::called_number, iax_ies::calling_ani, iax_ies::calling_name, iax_ies::calling_number, chan_iax2_pvt::calling_pres, iax_ies::calling_pres, chan_iax2_pvt::calling_tns, iax_ies::calling_tns, chan_iax2_pvt::calling_ton, iax_ies::calling_ton, iax2_user::capability, chan_iax2_pvt::capability, iax_ies::capability, iax2_user::cid_name, cid_name, iax2_user::cid_num, cid_num, iax_ies::codec_prefs, iax2_context::context, chan_iax2_pvt::context, context, iax2_user::contexts, iax2_user::dbsecret, DEFAULT_CONTEXT, iax_ies::dnid, iax2_user::encmethods, chan_iax2_pvt::encmethods, exten, ast_variable::file, iax_ies::format, iax2_user::ha, iax2_getpeertrunk(), IAX_AUTH_MD5, IAX_AUTH_PLAINTEXT, IAX_CODEC_NOCAP, IAX_CODEC_NOPREFS, IAX_CODEC_USER_FIRST, IAX_FORCE_ENCRYPT, IAX_FORCEJITTERBUF, IAX_HASCALLERID, IAX_IMMEDIATE, IAX_MAXAUTHREQ, IAX_NOTRANSFER, IAX_PROTO_VERSION, IAX_RECVCONNECTEDLINE, IAX_SENDCONNECTEDLINE, IAX_SHRINKCALLERID, IAX_TRANSFERMEDIA, IAX_TRUNK, IAX_USEJITTERBUF, iax2_user::inkeys, iax2_user::language, iax_ies::language, LOG_WARNING, iax2_user::maxauthreq, iax2_user::mohinterpret, iax2_user::mohsuggest, ast_variable::name, iax2_user::name, ast_variable::next, parkinglot, iax2_user::parkinglot, chan_iax2_pvt::peeradsicpe, chan_iax2_pvt::peercapability, chan_iax2_pvt::peerformat, iax2_user::prefs, chan_iax2_pvt::prefs, prefs, iax_ies::rdnis, realtime_user(), secret, iax2_user::secret, user_unref(), iax_ies::username, ast_variable::value, chan_iax2_pvt::vars, iax2_user::vars, iax_ies::version, and version.

Referenced by socket_process().

{
   /* Start pessimistic */
   int res = -1;
   int version = 2;
   struct iax2_user *user = NULL, *best = NULL;
   int bestscore = 0;
   int gotcapability = 0;
   struct ast_variable *v = NULL, *tmpvar = NULL;
   struct ao2_iterator i;

   if (!iaxs[callno])
      return res;
   if (ies->called_number)
      ast_string_field_set(iaxs[callno], exten, ies->called_number);
   if (ies->calling_number) {
      if (ast_test_flag64(&globalflags, IAX_SHRINKCALLERID)) { 
         ast_shrink_phone_number(ies->calling_number);
      }
      ast_string_field_set(iaxs[callno], cid_num, ies->calling_number);
   }
   if (ies->calling_name)
      ast_string_field_set(iaxs[callno], cid_name, ies->calling_name);
   if (ies->calling_ani)
      ast_string_field_set(iaxs[callno], ani, ies->calling_ani);
   if (ies->dnid)
      ast_string_field_set(iaxs[callno], dnid, ies->dnid);
   if (ies->rdnis)
      ast_string_field_set(iaxs[callno], rdnis, ies->rdnis);
   if (ies->called_context)
      ast_string_field_set(iaxs[callno], context, ies->called_context);
   if (ies->language)
      ast_string_field_set(iaxs[callno], language, ies->language);
   if (ies->username)
      ast_string_field_set(iaxs[callno], username, ies->username);
   if (ies->calling_ton > -1)
      iaxs[callno]->calling_ton = ies->calling_ton;
   if (ies->calling_tns > -1)
      iaxs[callno]->calling_tns = ies->calling_tns;
   if (ies->calling_pres > -1)
      iaxs[callno]->calling_pres = ies->calling_pres;
   if (ies->format)
      iaxs[callno]->peerformat = ies->format;
   if (ies->adsicpe)
      iaxs[callno]->peeradsicpe = ies->adsicpe;
   if (ies->capability) {
      gotcapability = 1;
      iaxs[callno]->peercapability = ies->capability;
   } 
   if (ies->version)
      version = ies->version;

   /* Use provided preferences until told otherwise for actual preferences */
   if(ies->codec_prefs) {
      ast_codec_pref_convert(&iaxs[callno]->rprefs, ies->codec_prefs, 32, 0);
      ast_codec_pref_convert(&iaxs[callno]->prefs, ies->codec_prefs, 32, 0);
   }

   if (!gotcapability) 
      iaxs[callno]->peercapability = iaxs[callno]->peerformat;
   if (version > IAX_PROTO_VERSION) {
      ast_log(LOG_WARNING, "Peer '%s' has too new a protocol version (%d) for me\n", 
         ast_inet_ntoa(sin->sin_addr), version);
      return res;
   }
   /* Search the userlist for a compatible entry, and fill in the rest */
   i = ao2_iterator_init(users, 0);
   while ((user = ao2_iterator_next(&i))) {
      if ((ast_strlen_zero(iaxs[callno]->username) ||          /* No username specified */
         !strcmp(iaxs[callno]->username, user->name)) /* Or this username specified */
         && ast_apply_ha(user->ha, sin)   /* Access is permitted from this IP */
         && (ast_strlen_zero(iaxs[callno]->context) ||         /* No context specified */
              apply_context(user->contexts, iaxs[callno]->context))) {        /* Context is permitted */
         if (!ast_strlen_zero(iaxs[callno]->username)) {
            /* Exact match, stop right now. */
            if (best)
               user_unref(best);
            best = user;
            break;
         } else if (ast_strlen_zero(user->secret) && ast_strlen_zero(user->dbsecret) && ast_strlen_zero(user->inkeys)) {
            /* No required authentication */
            if (user->ha) {
               /* There was host authentication and we passed, bonus! */
               if (bestscore < 4) {
                  bestscore = 4;
                  if (best)
                     user_unref(best);
                  best = user;
                  continue;
               }
            } else {
               /* No host access, but no secret, either, not bad */
               if (bestscore < 3) {
                  bestscore = 3;
                  if (best)
                     user_unref(best);
                  best = user;
                  continue;
               }
            }
         } else {
            if (user->ha) {
               /* Authentication, but host access too, eh, it's something.. */
               if (bestscore < 2) {
                  bestscore = 2;
                  if (best)
                     user_unref(best);
                  best = user;
                  continue;
               }
            } else {
               /* Authentication and no host access...  This is our baseline */
               if (bestscore < 1) {
                  bestscore = 1;
                  if (best)
                     user_unref(best);
                  best = user;
                  continue;
               }
            }
         }
      }
      user_unref(user);
   }
   ao2_iterator_destroy(&i);
   user = best;
   if (!user && !ast_strlen_zero(iaxs[callno]->username)) {
      user = realtime_user(iaxs[callno]->username, sin);
      if (user && !ast_strlen_zero(iaxs[callno]->context) &&         /* No context specified */
          !apply_context(user->contexts, iaxs[callno]->context)) {      /* Context is permitted */
         user = user_unref(user);
      }
   }
   if (user) {
      /* We found our match (use the first) */
      /* copy vars */
      for (v = user->vars ; v ; v = v->next) {
         if((tmpvar = ast_variable_new(v->name, v->value, v->file))) {
            tmpvar->next = iaxs[callno]->vars; 
            iaxs[callno]->vars = tmpvar;
         }
      }
      /* If a max AUTHREQ restriction is in place, activate it */
      if (user->maxauthreq > 0)
         ast_set_flag64(iaxs[callno], IAX_MAXAUTHREQ);
      iaxs[callno]->prefs = user->prefs;
      ast_copy_flags64(iaxs[callno], user, IAX_CODEC_USER_FIRST | IAX_IMMEDIATE | IAX_CODEC_NOPREFS | IAX_CODEC_NOCAP | IAX_FORCE_ENCRYPT);
      iaxs[callno]->encmethods = user->encmethods;
      /* Store the requested username if not specified */
      if (ast_strlen_zero(iaxs[callno]->username))
         ast_string_field_set(iaxs[callno], username, user->name);
      /* Store whether this is a trunked call, too, of course, and move if appropriate */
      ast_copy_flags64(iaxs[callno], user, IAX_TRUNK);
      iaxs[callno]->capability = user->capability;
      /* And use the default context */
      if (ast_strlen_zero(iaxs[callno]->context)) {
         if (user->contexts)
            ast_string_field_set(iaxs[callno], context, user->contexts->context);
         else
            ast_string_field_set(iaxs[callno], context, DEFAULT_CONTEXT);
      }
      /* And any input keys */
      ast_string_field_set(iaxs[callno], inkeys, user->inkeys);
      /* And the permitted authentication methods */
      iaxs[callno]->authmethods = user->authmethods;
      iaxs[callno]->adsi = user->adsi;
      /* If the user has callerid, override the remote caller id. */
      if (ast_test_flag64(user, IAX_HASCALLERID)) {
         iaxs[callno]->calling_tns = 0;
         iaxs[callno]->calling_ton = 0;
         ast_string_field_set(iaxs[callno], cid_num, user->cid_num);
         ast_string_field_set(iaxs[callno], cid_name, user->cid_name);
         ast_string_field_set(iaxs[callno], ani, user->cid_num);
         iaxs[callno]->calling_pres = AST_PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN;
      } else if (ast_strlen_zero(iaxs[callno]->cid_num) && ast_strlen_zero(iaxs[callno]->cid_name)) {
         iaxs[callno]->calling_pres = AST_PRES_NUMBER_NOT_AVAILABLE;
      } /* else user is allowed to set their own CID settings */
      if (!ast_strlen_zero(user->accountcode))
         ast_string_field_set(iaxs[callno], accountcode, user->accountcode);
      if (!ast_strlen_zero(user->mohinterpret))
         ast_string_field_set(iaxs[callno], mohinterpret, user->mohinterpret);
      if (!ast_strlen_zero(user->mohsuggest))
         ast_string_field_set(iaxs[callno], mohsuggest, user->mohsuggest);
      if (!ast_strlen_zero(user->parkinglot))
         ast_string_field_set(iaxs[callno], parkinglot, user->parkinglot);
      if (user->amaflags)
         iaxs[callno]->amaflags = user->amaflags;
      if (!ast_strlen_zero(user->language))
         ast_string_field_set(iaxs[callno], language, user->language);
      ast_copy_flags64(iaxs[callno], user, IAX_NOTRANSFER | IAX_TRANSFERMEDIA | IAX_USEJITTERBUF | IAX_FORCEJITTERBUF | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE); 
      /* Keep this check last */
      if (!ast_strlen_zero(user->dbsecret)) {
         char *family, *key=NULL;
         char buf[80];
         family = ast_strdupa(user->dbsecret);
         key = strchr(family, '/');
         if (key) {
            *key = '\0';
            key++;
         }
         if (!key || ast_db_get(family, key, buf, sizeof(buf)))
            ast_log(LOG_WARNING, "Unable to retrieve database password for family/key '%s'!\n", user->dbsecret);
         else
            ast_string_field_set(iaxs[callno], secret, buf);
      } else
         ast_string_field_set(iaxs[callno], secret, user->secret);
      res = 0;
      user = user_unref(user);
   } else {
       /* user was not found, but we should still fake an AUTHREQ.
        * Set authmethods to the last known authmethod used by the system
        * Set a fake secret, it's not looked at, just required to attempt authentication.
        * Set authrej so the AUTHREP is rejected without even looking at its contents */
      iaxs[callno]->authmethods = last_authmethod ? last_authmethod : (IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT);
      ast_string_field_set(iaxs[callno], secret, "badsecret");
      iaxs[callno]->authrej = 1;
      if (!ast_strlen_zero(iaxs[callno]->username)) {
         /* only send the AUTHREQ if a username was specified. */
         res = 0;
      }
   }
   ast_set2_flag64(iaxs[callno], iax2_getpeertrunk(*sin), IAX_TRUNK);
   return res;
}

static int check_provisioning	(	struct sockaddr_in *	sin,
		int	sockfd,
		char *	si,
		unsigned int	ver
	)			[static]

Definition at line 9061 of file chan_iax2.c.

References ast_debug, iax2_provision(), and iax_provision_version().

Referenced by socket_process().

{
   unsigned int ourver;
   char rsi[80];
   snprintf(rsi, sizeof(rsi), "si-%s", si);
   if (iax_provision_version(&ourver, rsi, 1))
      return 0;
   ast_debug(1, "Service identifier '%s', we think '%08x', they think '%08x'\n", si, ourver, ver);
   if (ourver != ver) 
      iax2_provision(sin, sockfd, NULL, rsi, 1);
   return 0;
}

static int check_srcaddr	(	struct sockaddr *	sa,
		socklen_t	salen
	)			[static]

Check if address can be used as packet source.

Returns:

0 address available, 1 address unavailable, -1 error

Definition at line 11822 of file chan_iax2.c.

References ast_debug, ast_log(), errno, and LOG_ERROR.

Referenced by peer_set_srcaddr().

{
   int sd;
   int res;
   
   sd = socket(AF_INET, SOCK_DGRAM, 0);
   if (sd < 0) {
      ast_log(LOG_ERROR, "Socket: %s\n", strerror(errno));
      return -1;
   }

   res = bind(sd, sa, salen);
   if (res < 0) {
      ast_debug(1, "Can't bind: %s\n", strerror(errno));
      close(sd);
      return 1;
   }

   close(sd);
   return 0;
}

static int complete_dpreply	(	struct chan_iax2_pvt *	pvt,
		struct iax_ies *	ies
	)			[static]

Definition at line 8055 of file chan_iax2.c.

References ARRAY_LEN, ast_copy_string(), AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, CACHE_FLAG_CANEXIST, CACHE_FLAG_EXISTS, CACHE_FLAG_MATCHMORE, CACHE_FLAG_NONEXISTENT, CACHE_FLAG_PENDING, CACHE_FLAG_UNKNOWN, iax_ies::called_number, iax2_dpcache::callno, iax_ies::dpstatus, iax2_dpcache::expiry, iax2_dpcache::exten, exten, iax2_dpcache::flags, IAX_DPSTATUS_CANEXIST, IAX_DPSTATUS_EXISTS, IAX_DPSTATUS_MATCHMORE, IAX_DPSTATUS_NONEXISTENT, matchmore(), iax2_dpcache::orig, iax2_dpcache::peer_list, iax_ies::refresh, status, and iax2_dpcache::waiters.

Referenced by socket_process().

{
   char exten[256] = "";
   int status = CACHE_FLAG_UNKNOWN, expiry = iaxdefaultdpcache, x, matchmore = 0;
   struct iax2_dpcache *dp = NULL;
   
   if (ies->called_number)
      ast_copy_string(exten, ies->called_number, sizeof(exten));
   
   if (ies->dpstatus & IAX_DPSTATUS_EXISTS)
      status = CACHE_FLAG_EXISTS;
   else if (ies->dpstatus & IAX_DPSTATUS_CANEXIST)
      status = CACHE_FLAG_CANEXIST;
   else if (ies->dpstatus & IAX_DPSTATUS_NONEXISTENT)
      status = CACHE_FLAG_NONEXISTENT;

   if (ies->refresh)
      expiry = ies->refresh;
   if (ies->dpstatus & IAX_DPSTATUS_MATCHMORE)
      matchmore = CACHE_FLAG_MATCHMORE;
   
   AST_LIST_LOCK(&dpcache);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&dpcache, dp, peer_list) {
      if (strcmp(dp->exten, exten))
         continue;
      AST_LIST_REMOVE_CURRENT(peer_list);
      dp->callno = 0;
      dp->expiry.tv_sec = dp->orig.tv_sec + expiry;
      if (dp->flags & CACHE_FLAG_PENDING) {
         dp->flags &= ~CACHE_FLAG_PENDING;
         dp->flags |= status;
         dp->flags |= matchmore;
      }
      /* Wake up waiters */
      for (x = 0; x < ARRAY_LEN(dp->waiters); x++) {
         if (dp->waiters[x] > -1) {
            if (write(dp->waiters[x], "asdf", 4) < 0) {
            }
         }
      }
   }
   AST_LIST_TRAVERSE_SAFE_END;
   AST_LIST_UNLOCK(&dpcache);

   return 0;
}

static char * complete_iax2_peers	(	const char *	line,
		const char *	word,
		int	pos,
		int	state,
		uint64_t	flags
	)			[static]

Definition at line 3690 of file chan_iax2.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_strdup, ast_test_flag64, iax2_peer::name, and peer_unref().

Referenced by handle_cli_iax2_prune_realtime(), handle_cli_iax2_set_debug(), and handle_cli_iax2_show_peer().

{
   int which = 0;
   struct iax2_peer *peer;
   char *res = NULL;
   int wordlen = strlen(word);
   struct ao2_iterator i;

   i = ao2_iterator_init(peers, 0);
   while ((peer = ao2_iterator_next(&i))) {
      if (!strncasecmp(peer->name, word, wordlen) && ++which > state
         && (!flags || ast_test_flag64(peer, flags))) {
         res = ast_strdup(peer->name);
         peer_unref(peer);
         break;
      }
      peer_unref(peer);
   }
   ao2_iterator_destroy(&i);

   return res;
}

static char * complete_iax2_unregister	(	const char *	line,
		const char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 6647 of file chan_iax2.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_strdup, iax2_peer::expire, iax2_peer::name, and peer_unref().

Referenced by handle_cli_iax2_unregister().

{
   int which = 0;
   struct iax2_peer *p = NULL;
   char *res = NULL;
   int wordlen = strlen(word);

   /* 0 - iax2; 1 - unregister; 2 - <peername> */
   if (pos == 2) {
      struct ao2_iterator i = ao2_iterator_init(peers, 0);
      while ((p = ao2_iterator_next(&i))) {
         if (!strncasecmp(p->name, word, wordlen) && 
            ++which > state && p->expire > 0) {
            res = ast_strdup(p->name);
            peer_unref(p);
            break;
         }
         peer_unref(p);
      }
      ao2_iterator_destroy(&i);
   }

   return res;
}

static int complete_transfer	(	int	callno,
		struct iax_ies *	ies
	)			[static]

Definition at line 8102 of file chan_iax2.c.

References chan_iax2_pvt::addr, chan_iax2_pvt::aseqno, AST_LIST_TRAVERSE, ast_log(), iax_ies::callno, jb_frame::data, DEFAULT_RETRY_TIME, frame_queue, iax2_frame_free(), chan_iax2_pvt::iseqno, chan_iax2_pvt::jb, jb_getall(), JB_OK, jb_reset(), chan_iax2_pvt::lag, chan_iax2_pvt::last, chan_iax2_pvt::lastsent, LOG_WARNING, chan_iax2_pvt::nextpred, chan_iax2_pvt::offset, chan_iax2_pvt::oseqno, chan_iax2_pvt::peercallno, peercnt_add(), peercnt_remove_by_addr(), chan_iax2_pvt::pingtime, remove_by_peercallno(), remove_by_transfercallno(), iax_frame::retries, chan_iax2_pvt::rseqno, chan_iax2_pvt::rxcore, store_by_peercallno(), chan_iax2_pvt::svideoformat, chan_iax2_pvt::svoiceformat, chan_iax2_pvt::transfer, TRANSFER_NONE, chan_iax2_pvt::transfercallno, chan_iax2_pvt::transferring, chan_iax2_pvt::videoformat, and chan_iax2_pvt::voiceformat.

Referenced by socket_process().

{
   int peercallno = 0;
   struct chan_iax2_pvt *pvt = iaxs[callno];
   struct iax_frame *cur;
   jb_frame frame;

   if (ies->callno)
      peercallno = ies->callno;

   if (peercallno < 1) {
      ast_log(LOG_WARNING, "Invalid transfer request\n");
      return -1;
   }
   remove_by_transfercallno(pvt);
   /* since a transfer has taken place, the address will change.
    * This must be accounted for in the peercnts table.  Remove
    * the old address and add the new one */
   peercnt_remove_by_addr(&pvt->addr);
   peercnt_add(&pvt->transfer);
   /* now copy over the new address */
   memcpy(&pvt->addr, &pvt->transfer, sizeof(pvt->addr));
   memset(&pvt->transfer, 0, sizeof(pvt->transfer));
   /* Reset sequence numbers */
   pvt->oseqno = 0;
   pvt->rseqno = 0;
   pvt->iseqno = 0;
   pvt->aseqno = 0;

   if (pvt->peercallno) {
      remove_by_peercallno(pvt);
   }
   pvt->peercallno = peercallno;
   /*this is where the transfering call swiches hash tables */
   store_by_peercallno(pvt);
   pvt->transferring = TRANSFER_NONE;
   pvt->svoiceformat = -1;
   pvt->voiceformat = 0;
   pvt->svideoformat = -1;
   pvt->videoformat = 0;
   pvt->transfercallno = -1;
   memset(&pvt->rxcore, 0, sizeof(pvt->rxcore));
   memset(&pvt->offset, 0, sizeof(pvt->offset));
   /* reset jitterbuffer */
   while(jb_getall(pvt->jb,&frame) == JB_OK)
      iax2_frame_free(frame.data);
   jb_reset(pvt->jb);
   pvt->lag = 0;
   pvt->last = 0;
   pvt->lastsent = 0;
   pvt->nextpred = 0;
   pvt->pingtime = DEFAULT_RETRY_TIME;
   AST_LIST_TRAVERSE(&frame_queue[callno], cur, list) {
      /* We must cancel any packets that would have been transmitted
         because now we're talking to someone new.  It's okay, they
         were transmitted to someone that didn't care anyway. */
      cur->retries = -1;
   }
   return 0;
}

static unsigned char compress_subclass

(

int

subclass

)

[static]

Definition at line 1509 of file chan_iax2.c.

References ast_log(), IAX_FLAG_SC_LOG, IAX_MAX_SHIFT, and LOG_WARNING.

Referenced by iax2_send(), raw_hangup(), and send_apathetic_reply().

{
   int x;
   int power=-1;
   /* If it's 128 or smaller, just return it */
   if (subclass < IAX_FLAG_SC_LOG)
      return subclass;
   /* Otherwise find its power */
   for (x = 0; x < IAX_MAX_SHIFT; x++) {
      if (subclass & (1 << x)) {
         if (power > -1) {
            ast_log(LOG_WARNING, "Can't compress subclass %d\n", subclass);
            return 0;
         } else
            power = x;
      }
   }
   return power | IAX_FLAG_SC_LOG;
}

static void construct_rr	(	struct chan_iax2_pvt *	pvt,
		struct iax_ie_data *	iep
	)			[static]

Definition at line 9074 of file chan_iax2.c.

References jb_info::current, jb_info::frames_dropped, jb_info::frames_in, jb_info::frames_lost, jb_info::frames_ooo, iax_ie_append_int(), iax_ie_append_short(), IAX_IE_RR_DELAY, IAX_IE_RR_DROPPED, IAX_IE_RR_JITTER, IAX_IE_RR_LOSS, IAX_IE_RR_OOO, IAX_IE_RR_PKTS, chan_iax2_pvt::jb, jb_getinfo(), jb_info::jitter, jb_info::losspct, and jb_info::min.

Referenced by socket_process().

{
   jb_info stats;
   jb_getinfo(pvt->jb, &stats);
   
   memset(iep, 0, sizeof(*iep));

   iax_ie_append_int(iep,IAX_IE_RR_JITTER, stats.jitter);
   if(stats.frames_in == 0) stats.frames_in = 1;
   iax_ie_append_int(iep,IAX_IE_RR_LOSS, ((0xff & (stats.losspct/1000)) << 24 | (stats.frames_lost & 0x00ffffff)));
   iax_ie_append_int(iep,IAX_IE_RR_PKTS, stats.frames_in);
   iax_ie_append_short(iep,IAX_IE_RR_DELAY, stats.current - stats.min);
   iax_ie_append_int(iep,IAX_IE_RR_DROPPED, stats.frames_dropped);
   iax_ie_append_int(iep,IAX_IE_RR_OOO, stats.frames_ooo);
}

static int create_addr	(	const char *	peername,
		struct ast_channel *	c,
		struct sockaddr_in *	sin,
		struct create_addr_info *	cai
	)			[static]

Definition at line 4407 of file chan_iax2.c.

References iax2_peer::addr, iax2_peer::adsi, create_addr_info::adsi, ast_clear_flag64, ast_codec_pref_convert(), ast_codec_pref_prepend(), ast_copy_flags64, ast_copy_string(), ast_db_get(), ast_debug, ast_get_ip_or_srv(), ast_log(), ast_strdupa, ast_strlen_zero(), iax2_peer::capability, create_addr_info::capability, iax2_peer::cid_name, create_addr_info::cid_name, iax2_peer::cid_num, create_addr_info::cid_num, iax2_peer::context, create_addr_info::context, iax2_peer::dbsecret, iax2_peer::defaddr, iax2_peer::encmethods, create_addr_info::encmethods, find_peer(), create_addr_info::found, IAX_DEFAULT_PORTNO, IAX_FORCE_ENCRYPT, IAX_FORCEJITTERBUF, IAX_NOTRANSFER, IAX_RECVCONNECTEDLINE, IAX_SENDANI, IAX_SENDCONNECTEDLINE, IAX_TRANSFERMEDIA, IAX_TRUNK, IAX_USEJITTERBUF, iax2_peer::lastms, LOG_WARNING, iax2_peer::maxms, create_addr_info::maxtime, iax2_peer::mohinterpret, create_addr_info::mohinterpret, iax2_peer::mohsuggest, create_addr_info::mohsuggest, ast_channel::nativeformats, iax2_peer::outkey, create_addr_info::outkey, peer_unref(), iax2_peer::peercontext, create_addr_info::peercontext, iax2_peer::prefs, create_addr_info::prefs, prefs, iax2_peer::secret, create_addr_info::secret, iax2_peer::sockfd, create_addr_info::sockfd, create_addr_info::timezone, iax2_peer::username, create_addr_info::username, and iax2_peer::zonetag.

{
   struct iax2_peer *peer;
   int res = -1;
   struct ast_codec_pref ourprefs;

   ast_clear_flag64(cai, IAX_SENDANI | IAX_TRUNK);
   cai->sockfd = defaultsockfd;
   cai->maxtime = 0;
   sin->sin_family = AF_INET;

   if (!(peer = find_peer(peername, 1))) {
      cai->found = 0;
      if (ast_get_ip_or_srv(sin, peername, srvlookup ? "_iax._udp" : NULL)) {
         ast_log(LOG_WARNING, "No such host: %s\n", peername);
         return -1;
      }
      sin->sin_port = htons(IAX_DEFAULT_PORTNO);
      /* use global iax prefs for unknown peer/user */
      /* But move the calling channel's native codec to the top of the preference list */
      memcpy(&ourprefs, &prefs, sizeof(ourprefs));
      if (c)
         ast_codec_pref_prepend(&ourprefs, c->nativeformats, 1);
      ast_codec_pref_convert(&ourprefs, cai->prefs, sizeof(cai->prefs), 1);
      return 0;
   }

   cai->found = 1;
   
   /* if the peer has no address (current or default), return failure */
   if (!(peer->addr.sin_addr.s_addr || peer->defaddr.sin_addr.s_addr))
      goto return_unref;

   /* if the peer is being monitored and is currently unreachable, return failure */
   if (peer->maxms && ((peer->lastms > peer->maxms) || (peer->lastms < 0)))
      goto return_unref;

   ast_copy_flags64(cai, peer, IAX_SENDANI | IAX_TRUNK | IAX_NOTRANSFER | IAX_TRANSFERMEDIA | IAX_USEJITTERBUF | IAX_FORCEJITTERBUF | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE | IAX_FORCE_ENCRYPT);
   cai->maxtime = peer->maxms;
   cai->capability = peer->capability;
   cai->encmethods = peer->encmethods;
   cai->sockfd = peer->sockfd;
   cai->adsi = peer->adsi;
   memcpy(&ourprefs, &peer->prefs, sizeof(ourprefs));
   /* Move the calling channel's native codec to the top of the preference list */
   if (c) {
      ast_debug(1, "prepending %x to prefs\n", c->nativeformats);
      ast_codec_pref_prepend(&ourprefs, c->nativeformats, 1);
   }
   ast_codec_pref_convert(&ourprefs, cai->prefs, sizeof(cai->prefs), 1);
   ast_copy_string(cai->context, peer->context, sizeof(cai->context));
   ast_copy_string(cai->peercontext, peer->peercontext, sizeof(cai->peercontext));
   ast_copy_string(cai->username, peer->username, sizeof(cai->username));
   ast_copy_string(cai->timezone, peer->zonetag, sizeof(cai->timezone));
   ast_copy_string(cai->outkey, peer->outkey, sizeof(cai->outkey));
   ast_copy_string(cai->cid_num, peer->cid_num, sizeof(cai->cid_num));
   ast_copy_string(cai->cid_name, peer->cid_name, sizeof(cai->cid_name));
   ast_copy_string(cai->mohinterpret, peer->mohinterpret, sizeof(cai->mohinterpret));
   ast_copy_string(cai->mohsuggest, peer->mohsuggest, sizeof(cai->mohsuggest));
   if (ast_strlen_zero(peer->dbsecret)) {
      ast_copy_string(cai->secret, peer->secret, sizeof(cai->secret));
   } else {
      char *family;
      char *key = NULL;

      family = ast_strdupa(peer->dbsecret);
      key = strchr(family, '/');
      if (key)
         *key++ = '\0';
      if (!key || ast_db_get(family, key, cai->secret, sizeof(cai->secret))) {
         ast_log(LOG_WARNING, "Unable to retrieve database password for family/key '%s'!\n", peer->dbsecret);
         goto return_unref;
      }
   }

   if (peer->addr.sin_addr.s_addr) {
      sin->sin_addr = peer->addr.sin_addr;
      sin->sin_port = peer->addr.sin_port;
   } else {
      sin->sin_addr = peer->defaddr.sin_addr;
      sin->sin_port = peer->defaddr.sin_port;
   }

   res = 0;

return_unref:
   peer_unref(peer);

   return res;
}

static int create_callno_pools

(

void

)

[static]

Definition at line 2532 of file chan_iax2.c.

References ao2_alloc, ao2_container_alloc, ao2_link, ao2_ref, callno_entry::callno, callno_hash(), and TRUNK_CALL_START.

Referenced by load_objects().

{
   uint16_t i;

   if (!(callno_pool = ao2_container_alloc(CALLNO_POOL_BUCKETS, callno_hash, NULL))) {
      return -1;
   }

   if (!(callno_pool_trunk = ao2_container_alloc(CALLNO_POOL_BUCKETS, callno_hash, NULL))) {
      return -1;
   }

   /* start at 2, 0 and 1 are reserved */
   for (i = 2; i <= IAX_MAX_CALLS; i++) {
      struct callno_entry *callno_entry;

      if (!(callno_entry = ao2_alloc(sizeof(*callno_entry), NULL))) {
         return -1;
      }

      callno_entry->callno = i;

      if (i < TRUNK_CALL_START) {
         ao2_link(callno_pool, callno_entry);
      } else {
         ao2_link(callno_pool_trunk, callno_entry);
      }

      ao2_ref(callno_entry, -1);
   }

   return 0;
}

static int decode_frame	(	ast_aes_decrypt_key *	dcx,
		struct ast_iax2_full_hdr *	fh,
		struct ast_frame *	f,
		int *	datalen
	)			[static]

Definition at line 6012 of file chan_iax2.c.

References ast_debug, AST_FRAME_VIDEO, ast_iax2_full_hdr::csub, ast_iax2_mini_enc_hdr::encdata, ast_iax2_full_enc_hdr::encdata, ast_frame::frametype, IAX_FLAG_FULL, memcpy_decrypt(), ast_iax2_full_hdr::scallno, ast_frame::subclass, ast_iax2_full_hdr::type, and uncompress_subclass().

Referenced by decrypt_frame(), and update_packet().

{
   int padding;
   unsigned char *workspace;

   workspace = alloca(*datalen);
   memset(f, 0, sizeof(*f));
   if (ntohs(fh->scallno) & IAX_FLAG_FULL) {
      struct ast_iax2_full_enc_hdr *efh = (struct ast_iax2_full_enc_hdr *)fh;
      if (*datalen < 16 + sizeof(struct ast_iax2_full_hdr))
         return -1;
      /* Decrypt */
      memcpy_decrypt(workspace, efh->encdata, *datalen - sizeof(struct ast_iax2_full_enc_hdr), dcx);

      padding = 16 + (workspace[15] & 0x0f);
      if (iaxdebug)
         ast_debug(1, "Decoding full frame with length %d (padding = %d) (15=%02x)\n", *datalen, padding, workspace[15]);
      if (*datalen < padding + sizeof(struct ast_iax2_full_hdr))
         return -1;

      *datalen -= padding;
      memcpy(efh->encdata, workspace + padding, *datalen - sizeof(struct ast_iax2_full_enc_hdr));
      f->frametype = fh->type;
      if (f->frametype == AST_FRAME_VIDEO) {
         f->subclass = uncompress_subclass(fh->csub & ~0x40) | ((fh->csub >> 6) & 0x1);
      } else {
         f->subclass = uncompress_subclass(fh->csub);
      }
   } else {
      struct ast_iax2_mini_enc_hdr *efh = (struct ast_iax2_mini_enc_hdr *)fh;
      if (iaxdebug)
         ast_debug(1, "Decoding mini with length %d\n", *datalen);
      if (*datalen < 16 + sizeof(struct ast_iax2_mini_hdr))
         return -1;
      /* Decrypt */
      memcpy_decrypt(workspace, efh->encdata, *datalen - sizeof(struct ast_iax2_mini_enc_hdr), dcx);
      padding = 16 + (workspace[15] & 0x0f);
      if (*datalen < padding + sizeof(struct ast_iax2_mini_hdr))
         return -1;
      *datalen -= padding;
      memcpy(efh->encdata, workspace + padding, *datalen - sizeof(struct ast_iax2_mini_enc_hdr));
   }
   return 0;
}

static int decrypt_frame	(	int	callno,
		struct ast_iax2_full_hdr *	fh,
		struct ast_frame *	f,
		int *	datalen
	)			[static]

Definition at line 6098 of file chan_iax2.c.

References ast_set_flag64, ast_strdupa, ast_test_flag64, build_encryption_keys(), decode_frame(), IAX_KEYPOPULATED, MD5Final(), MD5Init(), MD5Update(), secret, and strsep().

Referenced by socket_process().

{
   int res=-1;
   if (!ast_test_flag64(iaxs[callno], IAX_KEYPOPULATED)) {
      /* Search for possible keys, given secrets */
      struct MD5Context md5;
      unsigned char digest[16];
      char *tmppw, *stringp;
      
      tmppw = ast_strdupa(iaxs[callno]->secret);
      stringp = tmppw;
      while ((tmppw = strsep(&stringp, ";"))) {
         MD5Init(&md5);
         MD5Update(&md5, (unsigned char *)iaxs[callno]->challenge, strlen(iaxs[callno]->challenge));
         MD5Update(&md5, (unsigned char *)tmppw, strlen(tmppw));
         MD5Final(digest, &md5);
         build_encryption_keys(digest, iaxs[callno]);
         res = decode_frame(&iaxs[callno]->dcx, fh, f, datalen);
         if (!res) {
            ast_set_flag64(iaxs[callno], IAX_KEYPOPULATED);
            break;
         }
      }
   } else 
      res = decode_frame(&iaxs[callno]->dcx, fh, f, datalen);
   return res;
}

static void defer_full_frame	(	struct iax2_thread *	from_here,
		struct iax2_thread *	to_here
	)			[static]

Queue the last read full frame for processing by a certain thread.

If there are already any full frames queued, they are sorted by sequence number.

Definition at line 9221 of file chan_iax2.c.

References ast_calloc, AST_LIST_INSERT_BEFORE_CURRENT, AST_LIST_INSERT_TAIL, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, ast_mutex_lock(), ast_mutex_unlock(), iax2_thread::buf, iax2_pkt_buf::buf, iax2_thread::buf_len, iax2_thread::full_frames, iax2_pkt_buf::len, iax2_thread::lock, and ast_iax2_full_hdr::oseqno.

Referenced by socket_read().

{
   struct iax2_pkt_buf *pkt_buf, *cur_pkt_buf;
   struct ast_iax2_full_hdr *fh, *cur_fh;

   if (!(pkt_buf = ast_calloc(1, sizeof(*pkt_buf) + from_here->buf_len)))
      return;

   pkt_buf->len = from_here->buf_len;
   memcpy(pkt_buf->buf, from_here->buf, pkt_buf->len);

   fh = (struct ast_iax2_full_hdr *) pkt_buf->buf;
   ast_mutex_lock(&to_here->lock);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&to_here->full_frames, cur_pkt_buf, entry) {
      cur_fh = (struct ast_iax2_full_hdr *) cur_pkt_buf->buf;
      if (fh->oseqno < cur_fh->oseqno) {
         AST_LIST_INSERT_BEFORE_CURRENT(pkt_buf, entry);
         break;
      }
   }
   AST_LIST_TRAVERSE_SAFE_END

   if (!cur_pkt_buf)
      AST_LIST_INSERT_TAIL(&to_here->full_frames, pkt_buf, entry);
   
   ast_mutex_unlock(&to_here->lock);
}

static void delete_users

(

void

)

[static]

Definition at line 12502 of file chan_iax2.c.

References ao2_callback, ast_dnsmgr_release(), ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_mutex_lock(), ast_mutex_unlock(), ast_sched_thread_del, iax2_registry::callno, iax2_registry::dnsmgr, iax2_registry::expire, iax2_destroy(), peer_delme_cb(), chan_iax2_pvt::reg, and user_delme_cb().

{
   struct iax2_registry *reg;

   ao2_callback(users, 0, user_delme_cb, NULL);

   AST_LIST_LOCK(&registrations);
   while ((reg = AST_LIST_REMOVE_HEAD(&registrations, entry))) {
      if (sched) {
         ast_sched_thread_del(sched, reg->expire);
      }
      if (reg->callno) {
         int callno = reg->callno;
         ast_mutex_lock(&iaxsl[callno]);
         if (iaxs[callno]) {
            iaxs[callno]->reg = NULL;
            iax2_destroy(callno);
         }
         ast_mutex_unlock(&iaxsl[callno]);
      }
      if (reg->dnsmgr)
         ast_dnsmgr_release(reg->dnsmgr);
      ast_free(reg);
   }
   AST_LIST_UNLOCK(&registrations);

   ao2_callback(peers, 0, peer_delme_cb, NULL);
}

static void destroy_firmware

(

struct iax_firmware *

cur

)

[static]

Definition at line 2887 of file chan_iax2.c.

References ast_free, ast_iax2_firmware_header::datalen, iax_firmware::fd, and iax_firmware::fwh.

Referenced by reload_firmware().

{
   /* Close firmware */
   if (cur->fwh) {
      munmap((void*)cur->fwh, ntohl(cur->fwh->datalen) + sizeof(*(cur->fwh)));
   }
   close(cur->fd);
   ast_free(cur);
}

static void dp_lookup	(	int	callno,
		const char *	context,
		const char *	callednum,
		const char *	callerid,
		int	skiplock
	)			[static]

Definition at line 8925 of file chan_iax2.c.

References ast_canmatch_extension(), ast_exists_extension(), AST_FRAME_IAX, ast_ignore_pattern(), ast_matchmore_extension(), ast_mutex_lock(), ast_mutex_unlock(), ast_parking_ext(), iax_ie_data::buf, IAX_COMMAND_DPREP, IAX_DPSTATUS_CANEXIST, IAX_DPSTATUS_EXISTS, IAX_DPSTATUS_IGNOREPAT, IAX_DPSTATUS_MATCHMORE, IAX_DPSTATUS_NONEXISTENT, iax_ie_append_short(), iax_ie_append_str(), IAX_IE_CALLED_NUMBER, IAX_IE_DPSTATUS, IAX_IE_REFRESH, iax_ie_data::pos, and send_command().

Referenced by dp_lookup_thread(), and socket_process().

{
   unsigned short dpstatus = 0;
   struct iax_ie_data ied1;
   int mm;

   memset(&ied1, 0, sizeof(ied1));
   mm = ast_matchmore_extension(NULL, context, callednum, 1, callerid);
   /* Must be started */
   if (!strcmp(callednum, ast_parking_ext()) || ast_exists_extension(NULL, context, callednum, 1, callerid)) {
      dpstatus = IAX_DPSTATUS_EXISTS;
   } else if (ast_canmatch_extension(NULL, context, callednum, 1, callerid)) {
      dpstatus = IAX_DPSTATUS_CANEXIST;
   } else {
      dpstatus = IAX_DPSTATUS_NONEXISTENT;
   }
   if (ast_ignore_pattern(context, callednum))
      dpstatus |= IAX_DPSTATUS_IGNOREPAT;
   if (mm)
      dpstatus |= IAX_DPSTATUS_MATCHMORE;
   if (!skiplock)
      ast_mutex_lock(&iaxsl[callno]);
   if (iaxs[callno]) {
      iax_ie_append_str(&ied1, IAX_IE_CALLED_NUMBER, callednum);
      iax_ie_append_short(&ied1, IAX_IE_DPSTATUS, dpstatus);
      iax_ie_append_short(&ied1, IAX_IE_REFRESH, iaxdefaultdpcache);
      send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_DPREP, 0, ied1.buf, ied1.pos, -1);
   }
   if (!skiplock)
      ast_mutex_unlock(&iaxsl[callno]);
}

static void* dp_lookup_thread

(

void *

data

)

[static]

Definition at line 8957 of file chan_iax2.c.

References ast_free, dpreq_data::callednum, dpreq_data::callerid, dpreq_data::callno, dpreq_data::context, and dp_lookup().

Referenced by spawn_dp_lookup().

{
   /* Look up for dpreq */
   struct dpreq_data *dpr = data;
   dp_lookup(dpr->callno, dpr->context, dpr->callednum, dpr->callerid, 0);
   if (dpr->callerid)
      ast_free(dpr->callerid);
   ast_free(dpr);
   return NULL;
}

static void encmethods_to_str	(	int	e,
		struct ast_str *	buf
	)			[static]

Definition at line 1448 of file chan_iax2.c.

References ast_str_append(), ast_str_set(), ast_str_strlen(), IAX_ENCRYPT_AES128, and IAX_ENCRYPT_KEYROTATE.

Referenced by __iax2_show_peers(), handle_cli_iax2_show_peer(), and manager_iax2_show_peer_list().

{
   ast_str_set(&buf, 0, "(");
   if (e & IAX_ENCRYPT_AES128) {
      ast_str_append(&buf, 0, "aes128");
   }
   if (e & IAX_ENCRYPT_KEYROTATE) {
      ast_str_append(&buf, 0, ",keyrotate");
   }
   if (ast_str_strlen(buf) > 1) {
      ast_str_append(&buf, 0, ")");
   } else {
      ast_str_set(&buf, 0, "No");
   }
}

static int encrypt_frame	(	ast_aes_encrypt_key *	ecx,
		struct ast_iax2_full_hdr *	fh,
		unsigned char *	poo,
		int *	datalen
	)			[static]

Definition at line 6057 of file chan_iax2.c.

References ast_debug, ast_iax2_full_hdr::csub, ast_iax2_mini_enc_hdr::encdata, ast_iax2_full_enc_hdr::encdata, IAX_FLAG_FULL, memcpy_encrypt(), ast_iax2_full_hdr::scallno, and ast_iax2_full_hdr::type.

Referenced by iax2_send(), and update_packet().

{
   int padding;
   unsigned char *workspace;
   workspace = alloca(*datalen + 32);
   if (!workspace)
      return -1;
   if (ntohs(fh->scallno) & IAX_FLAG_FULL) {
      struct ast_iax2_full_enc_hdr *efh = (struct ast_iax2_full_enc_hdr *)fh;
      if (iaxdebug)
         ast_debug(1, "Encoding full frame %d/%d with length %d\n", fh->type, fh->csub, *datalen);
      padding = 16 - ((*datalen - sizeof(struct ast_iax2_full_enc_hdr)) % 16);
      padding = 16 + (padding & 0xf);
      memcpy(workspace, poo, padding);
      memcpy(workspace + padding, efh->encdata, *datalen - sizeof(struct ast_iax2_full_enc_hdr));
      workspace[15] &= 0xf0;
      workspace[15] |= (padding & 0xf);
      if (iaxdebug)
         ast_debug(1, "Encoding full frame %d/%d with length %d + %d padding (15=%02x)\n", fh->type, fh->csub, *datalen, padding, workspace[15]);
      *datalen += padding;
      memcpy_encrypt(efh->encdata, workspace, *datalen - sizeof(struct ast_iax2_full_enc_hdr), ecx);
      if (*datalen >= 32 + sizeof(struct ast_iax2_full_enc_hdr))
         memcpy(poo, workspace + *datalen - 32, 32);
   } else {
      struct ast_iax2_mini_enc_hdr *efh = (struct ast_iax2_mini_enc_hdr *)fh;
      if (iaxdebug)
         ast_debug(1, "Encoding mini frame with length %d\n", *datalen);
      padding = 16 - ((*datalen - sizeof(struct ast_iax2_mini_enc_hdr)) % 16);
      padding = 16 + (padding & 0xf);
      memcpy(workspace, poo, padding);
      memcpy(workspace + padding, efh->encdata, *datalen - sizeof(struct ast_iax2_mini_enc_hdr));
      workspace[15] &= 0xf0;
      workspace[15] |= (padding & 0x0f);
      *datalen += padding;
      memcpy_encrypt(efh->encdata, workspace, *datalen - sizeof(struct ast_iax2_mini_enc_hdr), ecx);
      if (*datalen >= 32 + sizeof(struct ast_iax2_mini_enc_hdr))
         memcpy(poo, workspace + *datalen - 32, 32);
   }
   return 0;
}

static int expire_registry

(

const void *

data

)

[static]

Definition at line 8359 of file chan_iax2.c.

References __expire_registry(), and schedule_action.

Referenced by handle_cli_iax2_prune_realtime(), handle_cli_iax2_unregister(), realtime_peer(), reg_source_db(), and update_registry().

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

static struct iax2_dpcache* find_cache	(	struct ast_channel *	chan,
		const char *	data,
		const char *	context,
		const char *	exten,
		int	priority
	)			[static, read]

Definition at line 13174 of file chan_iax2.c.

References ARRAY_LEN, ast_calloc, ast_channel_defer_dtmf(), ast_channel_undefer_dtmf(), ast_copy_string(), ast_free, ast_frfree, 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_mutex_unlock(), ast_read(), ast_test_flag, ast_tvcmp(), ast_tvnow(), ast_waitfor_nandfds(), CACHE_FLAG_PENDING, CACHE_FLAG_TIMEOUT, cache_get_callno_locked(), iax2_dpcache::callno, errno, iax2_dpcache::expiry, iax2_dpcache::exten, f, iax2_dpcache::flags, iax2_dprequest(), IAX_STATE_STARTED, LOG_WARNING,