chan_ooh323.c File Reference

#include "chan_ooh323.h"
#include <math.h>

Include dependency graph for chan_ooh323.c:

Go to the source code of this file.

Data Structures
struct	ast_peer_list
struct	ast_user_list
struct	ooh323_config
struct	ooh323_peer
struct	ooh323_pvt
struct	ooh323_user

Macros
#define	DEFAULT_CONTEXT   "default"
#define	DEFAULT_H323ACCNT   "ast_h323"
#define	DEFAULT_H323ID   "Asterisk PBX"
#define	DEFAULT_LOGFILE   "h323_log"
#define	FAXDETECT_CNG   1
#define	FAXDETECT_T38   2
#define	FORMAT   "%-15.15s %-15.15s %-23.23s %-s\n"
#define	FORMAT1   "%-15.15s %-15.15s %-15.15s %-s\n"
#define	FORMAT_STRING_SIZE   512
#define	H323_ALREADYGONE   (1<<5)
#define	H323_DISABLEGK   (1<<7)
#define	H323_FASTSTART   (1<<3)
#define	H323_GKROUTED   (1<<1)
#define	H323_NEEDDESTROY   (1<<6)
#define	H323_NEEDSTART   (1<<8)
#define	H323_OUTGOING   (1<<4)
#define	H323_SILENCESUPPRESSION   (1<<0)
#define	H323_TUNNELING   (1<<2)
#define	IPTOS_MINCOST   0x02
#define	MAXT30   240
#define	T38_DISABLED   0
#define	T38_ENABLED   1
#define	T38_FAXGW   1
#define	T38TOAUDIOTIMEOUT   30

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static struct ooh323_peer *	build_peer (const char *name, struct ast_variable *v, int friend_type)
static struct ooh323_user *	build_user (const char *name, struct ast_variable *v)
void	close_rtp_connection (ooCallData *call)
void	close_udptl_connection (ooCallData *call)
int	configure_local_rtp (struct ooh323_pvt *p, ooCallData *call)
int	delete_peers ()
int	delete_users ()
static void *	do_monitor (void *data)
static struct ooh323_pvt *	find_call (ooCallData *call)
struct ooh323_peer *	find_friend (const char *name, int port)
struct ooh323_peer *	find_peer (const char *name, int port)
struct ooh323_user *	find_user (const char *name, const char *ip)
static int	function_ooh323_read (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
	OOH323 Dialplan function - reads ooh323 settings. More...
static int	function_ooh323_write (struct ast_channel *chan, const char *cmd, char *data, const char *value)
	OOH323 Dialplan function - writes ooh323 settings. More...
char *	handle_cli_ooh323_reload (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_set_debug (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_config (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_gk (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_peer (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_peers (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_user (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_ooh323_show_users (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int	load_module (void)
int	onAlerting (ooCallData *call)
int	onCallCleared (ooCallData *call)
int	onCallEstablished (ooCallData *call)
void	onModeChanged (ooCallData *call, int t38mode)
int	onNewCallCreated (ooCallData *call)
int	onOutgoingCall (ooCallData *call)
int	onProgress (ooCallData *call)
static struct ooh323_pvt *	ooh323_alloc (int callref, char *callToken)
static int	ooh323_answer (struct ast_channel *ast)
static int	ooh323_call (struct ast_channel *ast, const char *dest, int timeout)
int	ooh323_convert_hangupcause_asteriskToH323 (int cause)
int	ooh323_convert_hangupcause_h323ToAsterisk (int cause)
int	ooh323_convertAsteriskCapToH323Cap (struct ast_format *format)
void	ooh323_delete_peer (struct ooh323_peer *peer)
int	ooh323_destroy (struct ooh323_pvt *p)
static int	ooh323_digit_begin (struct ast_channel *ast, char digit)
static int	ooh323_digit_end (struct ast_channel *ast, char digit, unsigned int duration)
static int	ooh323_do_reload (void)
static int	ooh323_fixup (struct ast_channel *oldchan, struct ast_channel *newchan)
static void	ooh323_get_codec (struct ast_channel *chan, struct ast_format_cap *result)
static enum ast_rtp_glue_result	ooh323_get_rtp_peer (struct ast_channel *chan, struct ast_rtp_instance **rtp)
static enum ast_rtp_glue_result	ooh323_get_vrtp_peer (struct ast_channel *chan, struct ast_rtp_instance **rtp)
static int	ooh323_hangup (struct ast_channel *ast)
static int	ooh323_indicate (struct ast_channel *ast, int condition, const void *data, size_t datalen)
static struct ast_channel *	ooh323_new (struct ooh323_pvt *i, int state, const char *host, struct ast_format_cap *cap, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor)
int	ooh323_onReceivedDigit (OOH323CallData *call, const char *digit)
int	ooh323_onReceivedSetup (ooCallData *call, Q931Message *pmsg)
static int	ooh323_queryoption (struct ast_channel *ast, int option, void *data, int *datalen)
static struct ast_frame *	ooh323_read (struct ast_channel *ast)
static struct ast_channel *	ooh323_request (const char *type, struct ast_format_cap *cap, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, const char *data, int *cause)
struct ast_frame *	ooh323_rtp_read (struct ast_channel *ast, struct ooh323_pvt *p)
void	ooh323_set_read_format (ooCallData *call, struct ast_format *fmt)
static int	ooh323_set_rtp_peer (struct ast_channel *chan, struct ast_rtp_instance *rtp, struct ast_rtp_instance *vrtp, struct ast_rtp_instance *trtp, const struct ast_format_cap *codecs, int nat_active)
void	ooh323_set_write_format (ooCallData *call, struct ast_format *fmt, int txframes)
static int	ooh323_write (struct ast_channel *ast, struct ast_frame *f)
int	reload_config (int reload)
static int	reload_module (void)
int	restart_monitor (void)
	Start the channel monitor thread. More...
void	setup_rtp_connection (ooCallData *call, const char *remoteIp, int remotePort)
void	setup_rtp_remote (ooCallData *call, const char *remoteIp, int remotePort)
void	setup_udptl_connection (ooCallData *call, const char *remoteIp, int remotePort)
static int	unload_module (void)
int	update_our_aliases (ooCallData *call, struct ooh323_pvt *p)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Objective Systems H323 Channel" , .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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_CHANNEL_DRIVER, .requires = "udptl", }
static const struct ast_module_info *	ast_module_info = &__mod_info
struct ast_sockaddr	bindaddr
static long	callnumber = 0
static struct ast_cli_entry	cli_ooh323 []
static const char	config [] = "ooh323.conf"
static struct ast_jb_conf	default_jbconf
static int	g729onlyA = 0
static char	gAccountcode [80] = DEFAULT_H323ACCNT
static struct ooAliases *	gAliasList
static int	gAMAFLAGS
static int	gANIasDNI = 0
static int	gBeMaster = 0
static char	gCallerID [AST_MAX_EXTENSION] = ""
static struct ast_format_cap *	gCap
static char	gContext [AST_MAX_EXTENSION] = DEFAULT_CONTEXT
static int	gDirectRTP = 0
static int	gDTMFCodec = 101
static int	gDTMFMode = H323_DTMF_RFC2833
static int	gEarlyDirect = 0
static int	gFastStart = 1
static int	gFAXdetect = FAXDETECT_CNG
static char	gGatekeeper [100]
OOBOOL	gH323Debug = FALSE
OOH323EndPoint	gH323ep
static int	gIncomingLimit = 1024
static char	gInitError [256] = ""
static char	gIP [2+8 *4+7]
static int	gIsGateway = 0
static struct ast_jb_conf	global_jbconf
static char	gLogFile [PATH_MAX] = DEFAULT_LOGFILE
static int	gMediaWaitForConnect = 0
static int	gNat = FALSE
static int	gOutgoingLimit = 1024
static int	gPort = 1720
static enum RasGatekeeperMode	gRasGkMode = RasNoGatekeeper
static char	gRASIP [2+8 *4+7]
static int	gRTDRCount = 0
static int	gRTDRInterval = 0
static int	gRTPTimeout = 60
static int	gT38Support = T38_FAXGW
static int	gTOS = 0
static int	gTRCLVL = OOTRCLVLERR
static int	gTunneling = 1
static ast_mutex_t	h323_reload_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static int	h323_reloading = 0
static struct ooh323_pvt *	iflist = NULL
static ast_mutex_t	iflock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static struct io_context *	io
static int	manufacturer = 0
static pthread_t	monitor_thread = AST_PTHREADT_NULL
static ast_mutex_t	monlock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
struct ast_module *	myself
static struct ooh323_config	ooconfig
static struct ast_rtp_glue	ooh323_rtp
static struct ast_channel_tech	ooh323_tech
static ast_mutex_t	ooh323c_cn_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static struct ast_peer_list	peerl
static struct ast_sched_context *	sched
static int	t35countrycode = 0
static int	t35extensions = 0
static const char	tdesc [] = "Objective Systems H323 Channel Driver"
static const char	type [] = "OOH323"
static int	usecnt = 0
static ast_mutex_t	usecnt_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static struct ast_user_list	userl
int	v6mode = 0
static char	vendor [AST_MAX_EXTENSION] = ""
static char	version [AST_MAX_EXTENSION] = ""

Macro Definition Documentation

DEFAULT_CONTEXT

#define DEFAULT_CONTEXT   "default"

Definition at line 83 of file chan_ooh323.c.

Referenced by reload_config().

DEFAULT_H323ACCNT

#define DEFAULT_H323ACCNT   "ast_h323"

Definition at line 86 of file chan_ooh323.c.

Referenced by reload_config().

DEFAULT_H323ID

#define DEFAULT_H323ID   "Asterisk PBX"

Definition at line 84 of file chan_ooh323.c.

Referenced by reload_config().

DEFAULT_LOGFILE

#define DEFAULT_LOGFILE   "h323_log"

Definition at line 85 of file chan_ooh323.c.

Referenced by reload_config().

FAXDETECT_CNG

#define FAXDETECT_CNG   1

Definition at line 105 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), function_ooh323_write(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_peer(), handle_cli_ooh323_show_user(), ooh323_new(), ooh323_rtp_read(), and reload_config().

FAXDETECT_T38

#define FAXDETECT_T38   2

Definition at line 106 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), function_ooh323_write(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_peer(), handle_cli_ooh323_show_user(), onModeChanged(), and reload_config().

FORMAT

#define FORMAT   "%-15.15s %-15.15s %-23.23s %-s\n"

Referenced by handle_cli_ooh323_show_peers(), hash_ao2_destroy(), and rb_ao2_destroy().

FORMAT1

#define FORMAT1   "%-15.15s %-15.15s %-15.15s %-s\n"

Referenced by handle_cli_ooh323_show_users().

FORMAT_STRING_SIZE

#define FORMAT_STRING_SIZE   512

Definition at line 80 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), and handle_cli_ooh323_show_gk().

H323_ALREADYGONE

#define H323_ALREADYGONE   (1<<5)

Definition at line 94 of file chan_ooh323.c.

Referenced by onCallCleared(), ooh323_hangup(), and ooh323_indicate().

H323_DISABLEGK

#define H323_DISABLEGK   (1<<7)

Definition at line 96 of file chan_ooh323.c.

Referenced by ooh323_alloc(), ooh323_call(), and ooh323_onReceivedSetup().

H323_FASTSTART

#define H323_FASTSTART   (1<<3)

Definition at line 92 of file chan_ooh323.c.

H323_GKROUTED

#define H323_GKROUTED   (1<<1)

Definition at line 90 of file chan_ooh323.c.

H323_NEEDDESTROY

#define H323_NEEDDESTROY   (1<<6)

Definition at line 95 of file chan_ooh323.c.

Referenced by do_monitor(), onCallCleared(), ooh323_hangup(), and ooh323_onReceivedSetup().

H323_NEEDSTART

#define H323_NEEDSTART   (1<<8)

Definition at line 97 of file chan_ooh323.c.

H323_OUTGOING

#define H323_OUTGOING   (1<<4)

Definition at line 93 of file chan_ooh323.c.

Referenced by onCallEstablished(), ooh323_call(), ooh323_destroy(), ooh323_new(), ooh323_onReceivedSetup(), ooh323_request(), and ooh323_write().

H323_SILENCESUPPRESSION

#define H323_SILENCESUPPRESSION   (1<<0)

Definition at line 89 of file chan_ooh323.c.

H323_TUNNELING

#define H323_TUNNELING   (1<<2)

Definition at line 91 of file chan_ooh323.c.

IPTOS_MINCOST

#define IPTOS_MINCOST   0x02

Definition at line 77 of file chan_ooh323.c.

Referenced by reload_config().

MAXT30

#define MAXT30   240

Definition at line 99 of file chan_ooh323.c.

T38_DISABLED

#define T38_DISABLED   0

Definition at line 101 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), change_t38_state(), defer_incoming_sdp_stream(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_peer(), handle_cli_ooh323_show_user(), handle_request_invite(), handle_response_invite(), interpret_t38_parameters(), negotiate_incoming_sdp_stream(), ooh323_queryoption(), ooh323_rtp_read(), process_sdp(), reload_config(), sip_acf_channel_read(), t38_change_state(), t38_interpret_parameters(), and t38_reinvite_response_cb().

T38_ENABLED

#define T38_ENABLED   1

Definition at line 102 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), chan_pjsip_queryoption(), change_t38_state(), check_rtp_timeout(), close_udptl_connection(), create_outgoing_sdp_stream(), handle_request_invite(), interpret_t38_parameters(), onModeChanged(), ooh323_indicate(), proc_session_timer(), process_sdp(), reload_config(), setup_udptl_connection(), sip_get_rtp_peer(), sip_queryoption(), sip_write(), t38_change_state(), t38_interpret_parameters(), t38_reinvite_response_cb(), and transmit_response_with_sdp().

T38_FAXGW

#define T38_FAXGW   1

Definition at line 103 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_peer(), handle_cli_ooh323_show_user(), and reload_config().

T38TOAUDIOTIMEOUT

#define T38TOAUDIOTIMEOUT   30

Definition at line 100 of file chan_ooh323.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 5250 of file chan_ooh323.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 5250 of file chan_ooh323.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 5250 of file chan_ooh323.c.

build_peer()

static struct ooh323_peer* build_peer ( const char *  name, struct ast_variable *  v, int  friend_type  )

static

Definition at line 2515 of file chan_ooh323.c.

References ooh323_peer::accountcode, ooh323_peer::amaflags, ast_calloc, ast_channel_string2amaflag(), ast_copy_string(), ast_false(), ast_format_cap_alloc, ast_format_cap_append_from_cap(), ast_format_cap_update_by_allow_disallow(), ast_free, ast_log, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_init, ast_parse_arg(), ast_sockaddr_stringify_host(), ast_strdup, ast_strdupa, ast_true(), ast_verb, buf, ooh323_peer::cap, ooh323_peer::directrtp, ooh323_peer::dtmfcodec, ooh323_peer::dtmfmode, ooh323_peer::e164, ooh323_peer::earlydirect, ooh323_peer::email, ooh323_peer::faststart, ooh323_peer::faxdetect, FAXDETECT_CNG, FAXDETECT_T38, ooh323_pvt::g729onlyA, ooh323_peer::g729onlyA, gAccountcode, gAMAFLAGS, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gH323Debug, gNat, gRTPTimeout, gT38Support, gTunneling, ooh323_peer::h245tunneling, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_peer::h323id, ooh323_peer::ip, ast_variable::lineno, ooh323_peer::lock, LOG_ERROR, LOG_WARNING, ooh323_peer::mFriend, ast_variable::name, ooh323_peer::name, ooh323_peer::nat, ast_variable::next, ooh323_pvt::next, NULL, ooh323_delete_peer(), ooh323_peer::outgoinglimit, PARSE_ADDR, ooh323_pvt::peer, ooh323_peer::port, ooh323_peer::rtdrcount, ooh323_peer::rtdrinterval, ooh323_peer::rtpmask, ooh323_peer::rtpmaskstr, ooh323_peer::rtptimeout, strsep(), T38_DISABLED, T38_ENABLED, T38_FAXGW, ooh323_peer::t38support, tmp(), ooh323_peer::url, and ast_variable::value.

Referenced by reload_config().

{
 struct ooh323_peer *peer = NULL;

 if (gH323Debug)
 ast_verb(0, "--- build_peer\n");

 peer = ast_calloc(1, sizeof(*peer));
 if (peer) {
 memset(peer, 0, sizeof(struct ooh323_peer));
 if (!(peer->cap = ast_format_cap_alloc(0))) {
 ast_free(peer);
 return NULL;
 }
 ast_mutex_init(&peer->lock);
 ast_copy_string(peer->name, name, sizeof(peer->name));
 ast_format_cap_append_from_cap(peer->cap, gCap, AST_MEDIA_TYPE_UNKNOWN);
 peer->rtptimeout = gRTPTimeout;
 peer->nat = gNat;
 ast_copy_string(peer->accountcode, gAccountcode, sizeof(peer->accountcode));
 peer->amaflags = gAMAFLAGS;
 peer->dtmfmode = gDTMFMode;
 peer->dtmfcodec = gDTMFCodec;
 peer->faxdetect = gFAXdetect;
 peer->t38support = gT38Support;
 peer->faststart = gFastStart;
 peer->h245tunneling = gTunneling;
 peer->directrtp = gDirectRTP;
 peer->earlydirect = gEarlyDirect;
 peer->g729onlyA = g729onlyA;
 peer->port = 1720;
 if (0 == friend_type) {
 peer->mFriend = 1;
 }

 while (v) {
 if (!strcasecmp(v->name, "h323id")) {
 if (!(peer->h323id = ast_strdup(v->value))) {
 ast_log(LOG_ERROR, "Could not allocate memory for h323id of "
 "peer %s\n", name);
 ooh323_delete_peer(peer);
 return NULL;
 }
 } else if (!strcasecmp(v->name, "e164")) {
 int valid = 1;
 const char *tmp;
 for(tmp = v->value; *tmp; tmp++) {
 if (!isdigit(*tmp)) {
 valid = 0;
 break;
 }
 }
 if (valid) {
 if (!(peer->e164 = ast_strdup(v->value))) {
 ast_log(LOG_ERROR, "Could not allocate memory for e164 of "
 "peer %s\n", name);
 ooh323_delete_peer(peer);
 return NULL;
 }
 } else {
 ast_log(LOG_ERROR, "Invalid e164: %s for peer %s\n", v->value, name);
 }
 } else if (!strcasecmp(v->name, "email")) {
 if (!(peer->email = ast_strdup(v->value))) {
 ast_log(LOG_ERROR, "Could not allocate memory for email of "
 "peer %s\n", name);
 ooh323_delete_peer(peer);
 return NULL;
 }
 } else if (!strcasecmp(v->name, "url")) {
 if (!(peer->url = ast_strdup(v->value))) {
 ast_log(LOG_ERROR, "Could not allocate memory for h323id of "
 "peer %s\n", name);
 ooh323_delete_peer(peer);
 return NULL;
 }
 } else if (!strcasecmp(v->name, "port")) {
 peer->port = atoi(v->value);
 } else if (!strcasecmp(v->name, "host") || !strcasecmp(v->name, "ip")) {
 struct ast_sockaddr p;
 if (!ast_parse_arg(v->value, PARSE_ADDR, &p)) {
 ast_copy_string(peer->ip, ast_sockaddr_stringify_host(&p), sizeof(peer->ip));
 } else {
 ast_copy_string(peer->ip, v->value, sizeof(peer->ip));
 }

 } else if (!strcasecmp(v->name, "outgoinglimit")) {
 int val = atoi(v->value);
 if (val < 0) {
 peer->outgoinglimit = 0;
 } else {
 peer->outgoinglimit = val;
 }
 } else if (!strcasecmp(v->name, "accountcode")) {
 ast_copy_string(peer->accountcode, v->value, sizeof(peer->accountcode));
 } else if (!strcasecmp(v->name, "faststart")) {
 peer->faststart = ast_true(v->value);
 } else if (!strcasecmp(v->name, "h245tunneling")) {
 peer->h245tunneling = ast_true(v->value);
 } else if (!strcasecmp(v->name, "directrtp") || !strcasecmp(v->name, "directmedia")) {
 peer->directrtp = ast_true(v->value);
 peer->earlydirect = ast_true(v->value);
 } else if (!strcasecmp(v->name, "earlydirect") || !strcasecmp(v->name, "directrtpsetup")) {
 peer->earlydirect = ast_true(v->value);
 } else if (!strcasecmp(v->name, "g729onlyA")) {
 peer->g729onlyA = ast_true(v->value);
 } else if (!strcasecmp(v->name, "nat")) {
 peer->nat = ast_true(v->value);
 } else if (!strcasecmp(v->name, "rtptimeout")) {
 peer->rtptimeout = atoi(v->value);
 if(peer->rtptimeout < 0)
 peer->rtptimeout = gRTPTimeout;
 } else if (!strcasecmp(v->name, "rtpmask")) {
 if ((peer->rtpmask = ast_calloc(1, sizeof(struct OOH323Regex))) &&
 (regcomp(&peer->rtpmask->regex, v->value, REG_EXTENDED)
 == 0)) {
 ast_mutex_init(&peer->rtpmask->lock);
 peer->rtpmask->inuse = 1;
 ast_copy_string(peer->rtpmaskstr, v->value,
 sizeof(peer->rtpmaskstr));
 } else peer->rtpmask = NULL;
 } else if (!strcasecmp(v->name, "disallow")) {
 ast_format_cap_update_by_allow_disallow(peer->cap, v->value, 0);
 } else if (!strcasecmp(v->name, "allow")) {
 const char* tcodecs = v->value;
 if (!strcasecmp(v->value, "all")) {
 tcodecs = "ulaw,alaw,g729,g723,gsm";
 }
 ast_format_cap_update_by_allow_disallow(peer->cap, tcodecs, 1);
 } else if (!strcasecmp(v->name, "amaflags")) {
 peer->amaflags = ast_channel_string2amaflag(v->value);
 } else if (!strcasecmp(v->name, "roundtrip")) {
 sscanf(v->value, "%d,%d", &peer->rtdrcount, &peer->rtdrinterval);
 } else if (!strcasecmp(v->name, "dtmfmode")) {
 if (!strcasecmp(v->value, "rfc2833"))
 peer->dtmfmode = H323_DTMF_RFC2833;
 if (!strcasecmp(v->value, "cisco"))
 peer->dtmfmode = H323_DTMF_CISCO;
 else if (!strcasecmp(v->value, "q931keypad"))
 peer->dtmfmode = H323_DTMF_Q931;
 else if (!strcasecmp(v->value, "h245alphanumeric"))
 peer->dtmfmode = H323_DTMF_H245ALPHANUMERIC;
 else if (!strcasecmp(v->value, "h245signal"))
 peer->dtmfmode = H323_DTMF_H245SIGNAL;
 else if (!strcasecmp(v->value, "inband"))
 peer->dtmfmode = H323_DTMF_INBAND;
 } else if (!strcasecmp(v->name, "relaxdtmf")) {
 peer->dtmfmode |= ast_true(v->value) ? H323_DTMF_INBANDRELAX : 0;
 } else if (!strcasecmp(v->name, "dtmfcodec") && atoi(v->value)) {
 peer->dtmfcodec = atoi(v->value);
 } else if (!strcasecmp(v->name, "faxdetect")) {
 if (ast_true(v->value)) {
 peer->faxdetect = FAXDETECT_CNG | FAXDETECT_T38;
 } else if (ast_false(v->value)) {
 peer->faxdetect = 0;
 } else {
 char *buf = ast_strdupa(v->value);
 char *word, *next = buf;
 peer->faxdetect = 0;
 while ((word = strsep(&next, ","))) {
 if (!strcasecmp(word, "cng")) {
 peer->faxdetect |= FAXDETECT_CNG;
 } else if (!strcasecmp(word, "t38")) {
 peer->faxdetect |= FAXDETECT_T38;
 } else {
 ast_log(LOG_WARNING, "Unknown faxdetect mode '%s' on line %d.\n", word, v->lineno);
 }
 }

 }
 } else if (!strcasecmp(v->name, "t38support")) {
 if (!strcasecmp(v->value, "disabled"))
 peer->t38support = T38_DISABLED;
 if (!strcasecmp(v->value, "no"))
 peer->t38support = T38_DISABLED;
 else if (!strcasecmp(v->value, "faxgw"))
 peer->t38support = T38_FAXGW;
 else if (!strcasecmp(v->value, "yes"))
 peer->t38support = T38_ENABLED;
 }
 v = v->next;
 }
 }

 if (gH323Debug)
 ast_verb(0, "+++ build_peer\n");

 return peer;
}

build_user()

static struct ooh323_user* build_user ( const char *  name, struct ast_variable *  v  )

static

Definition at line 2368 of file chan_ooh323.c.

References ooh323_user::accountcode, ooh323_user::amaflags, ooh323_user::aniasdni, ast_calloc, ast_channel_string2amaflag(), ast_copy_string(), ast_false(), ast_format_cap_alloc, ast_format_cap_append_from_cap(), ast_format_cap_update_by_allow_disallow(), ast_free, ast_log, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_init, ast_parse_arg(), ast_sockaddr_stringify_addr(), ast_strdupa, ast_true(), ast_verb, buf, ooh323_user::cap, ooh323_user::context, ooh323_user::directrtp, ooh323_user::dtmfcodec, ooh323_user::dtmfmode, ooh323_user::earlydirect, ooh323_user::faststart, ooh323_user::faxdetect, FAXDETECT_CNG, FAXDETECT_T38, ooh323_pvt::g729onlyA, ooh323_user::g729onlyA, gAccountcode, gAMAFLAGS, gContext, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gH323Debug, gNat, gRTPTimeout, gT38Support, gTunneling, ooh323_user::h245tunneling, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_user::incominglimit, ast_variable::lineno, ooh323_user::lock, LOG_WARNING, ooh323_user::mIP, ooh323_user::mUseIP, ast_variable::name, ooh323_user::name, ooh323_user::nat, ast_variable::next, ooh323_pvt::next, NULL, PARSE_ADDR, ooh323_user::rtdrcount, ooh323_user::rtdrinterval, ooh323_user::rtpmask, ooh323_user::rtpmaskstr, ooh323_user::rtptimeout, strsep(), T38_DISABLED, T38_ENABLED, T38_FAXGW, ooh323_user::t38support, ooh323_pvt::user, and ast_variable::value.

Referenced by reload_config().

{
 struct ooh323_user *user = NULL;

 if (gH323Debug)
 ast_verb(0, "--- build_user\n");

 user = ast_calloc(1,sizeof(struct ooh323_user));
 if (user) {
 memset(user, 0, sizeof(struct ooh323_user));
 if (!(user->cap = ast_format_cap_alloc(0))) {
 ast_free(user);
 return NULL;
 }
 ast_mutex_init(&user->lock);
 ast_copy_string(user->name, name, sizeof(user->name));
 ast_format_cap_append_from_cap(user->cap, gCap, AST_MEDIA_TYPE_UNKNOWN);
 user->rtptimeout = gRTPTimeout;
 user->nat = gNat;
 user->dtmfmode = gDTMFMode;
 user->dtmfcodec = gDTMFCodec;
 user->faxdetect = gFAXdetect;
 user->t38support = gT38Support;
 user->faststart = gFastStart;
 user->h245tunneling = gTunneling;
 user->directrtp = gDirectRTP;
 user->earlydirect = gEarlyDirect;
 user->g729onlyA = g729onlyA;
 /* set default context */
 ast_copy_string(user->context, gContext, sizeof(user->context));
 ast_copy_string(user->accountcode, gAccountcode, sizeof(user->accountcode));
 user->amaflags = gAMAFLAGS;

 while (v) {
 if (!strcasecmp(v->name, "context")) {
 ast_copy_string(user->context, v->value, sizeof(user->context));
 } else if (!strcasecmp(v->name, "incominglimit")) {
 user->incominglimit = atoi(v->value);
 if (user->incominglimit < 0)
 user->incominglimit = 0;
 } else if (!strcasecmp(v->name, "accountcode")) {
 ast_copy_string(user->accountcode, v->value, sizeof(user->accountcode));
 } else if (!strcasecmp(v->name, "roundtrip")) {
 sscanf(v->value, "%d,%d", &user->rtdrcount, &user->rtdrinterval);
 } else if (!strcasecmp(v->name, "faststart")) {
 user->faststart = ast_true(v->value);
 } else if (!strcasecmp(v->name, "h245tunneling")) {
 user->h245tunneling = ast_true(v->value);
 } else if (!strcasecmp(v->name, "directrtp") || !strcasecmp(v->name, "directmedia")) {
 user->directrtp = ast_true(v->value);
 user->earlydirect = ast_true(v->value);
 } else if (!strcasecmp(v->name, "earlydirect") || !strcasecmp(v->name, "directrtpsetup")) {
 user->earlydirect = ast_true(v->value);
 } else if (!strcasecmp(v->name, "g729onlyA")) {
 user->g729onlyA = ast_true(v->value);
 } else if (!strcasecmp(v->name, "nat")) {
 user->nat = ast_true(v->value);
 } else if (!strcasecmp(v->name, "rtptimeout")) {
 user->rtptimeout = atoi(v->value);
 if (user->rtptimeout < 0)
 user->rtptimeout = gRTPTimeout;
 } else if (!strcasecmp(v->name, "rtpmask")) {
 if ((user->rtpmask = ast_calloc(1, sizeof(struct OOH323Regex))) &&
 (regcomp(&user->rtpmask->regex, v->value, REG_EXTENDED)
 == 0)) {
 ast_mutex_init(&user->rtpmask->lock);
 user->rtpmask->inuse = 1;
 ast_copy_string(user->rtpmaskstr, v->value,
 sizeof(user->rtpmaskstr));
 } else user->rtpmask = NULL;
 } else if (!strcasecmp(v->name, "disallow")) {
 ast_format_cap_update_by_allow_disallow(user->cap, v->value, 0);
 } else if (!strcasecmp(v->name, "allow")) {
 const char* tcodecs = v->value;
 if (!strcasecmp(v->value, "all")) {
 tcodecs = "ulaw,alaw,g729,g723,gsm";
 }
 ast_format_cap_update_by_allow_disallow(user->cap, tcodecs, 1);
 } else if (!strcasecmp(v->name, "amaflags")) {
 user->amaflags = ast_channel_string2amaflag(v->value);
 } else if (!strcasecmp(v->name, "ip") || !strcasecmp(v->name, "host")) {
 struct ast_sockaddr p;
 if (!ast_parse_arg(v->value, PARSE_ADDR, &p)) {
 ast_copy_string(user->mIP, ast_sockaddr_stringify_addr(&p), sizeof(user->mIP)-1);
 } else {
 ast_copy_string(user->mIP, v->value, sizeof(user->mIP)-1);
 }
 user->mUseIP = 1;
 } else if (!strcasecmp(v->name, "dtmfmode")) {
 if (!strcasecmp(v->value, "rfc2833"))
 user->dtmfmode = H323_DTMF_RFC2833;
 if (!strcasecmp(v->value, "cisco"))
 user->dtmfmode = H323_DTMF_CISCO;
 else if (!strcasecmp(v->value, "q931keypad"))
 user->dtmfmode = H323_DTMF_Q931;
 else if (!strcasecmp(v->value, "h245alphanumeric"))
 user->dtmfmode = H323_DTMF_H245ALPHANUMERIC;
 else if (!strcasecmp(v->value, "h245signal"))
 user->dtmfmode = H323_DTMF_H245SIGNAL;
 else if (!strcasecmp(v->value, "inband"))
 user->dtmfmode = H323_DTMF_INBAND;
 } else if (!strcasecmp(v->name, "relaxdtmf")) {
 user->dtmfmode |= ast_true(v->value) ? H323_DTMF_INBANDRELAX : 0;
 } else if (!strcasecmp(v->name, "dtmfcodec") && atoi(v->value)) {
 user->dtmfcodec = atoi(v->value);
 } else if (!strcasecmp(v->name, "faxdetect")) {
 if (ast_true(v->value)) {
 user->faxdetect = FAXDETECT_CNG | FAXDETECT_T38;
 } else if (ast_false(v->value)) {
 user->faxdetect = 0;
 } else {
 char *buf = ast_strdupa(v->value);
 char *word, *next = buf;
 user->faxdetect = 0;
 while ((word = strsep(&next, ","))) {
 if (!strcasecmp(word, "cng")) {
 user->faxdetect |= FAXDETECT_CNG;
 } else if (!strcasecmp(word, "t38")) {
 user->faxdetect |= FAXDETECT_T38;
 } else {
 ast_log(LOG_WARNING, "Unknown faxdetect mode '%s' on line %d.\n", word, v->lineno);
 }
 }

 }
 } else if (!strcasecmp(v->name, "t38support")) {
 if (!strcasecmp(v->value, "disabled"))
 user->t38support = T38_DISABLED;
 if (!strcasecmp(v->value, "no"))
 user->t38support = T38_DISABLED;
 else if (!strcasecmp(v->value, "faxgw"))
 user->t38support = T38_FAXGW;
 else if (!strcasecmp(v->value, "yes"))
 user->t38support = T38_ENABLED;
 } else if (!strcasecmp(v->name, "aniasdni")) {
 user->aniasdni = ast_true(v->value);
 }
 v = v->next;
 }
 }

 if (gH323Debug)
 ast_verb(0, "+++ build_user\n");

 return user;
}

close_rtp_connection()

void close_rtp_connection

(

ooCallData *

call

)

Definition at line 4810 of file chan_ooh323.c.

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_stop(), ast_verb, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, and ooh323_pvt::rtp.

Referenced by ooh323c_stop_transmit_channel().

{
 struct ooh323_pvt *p = NULL;

 if(gH323Debug)
 ast_verb(0, "--- close_rtp_connection\n");

 p = find_call(call);
 if (!p) {
 ast_log(LOG_ERROR, "Couldn't find matching call to close rtp "
 "connection\n");
 return;
 }
 ast_mutex_lock(&p->lock);
 if (p->rtp) {
 ast_rtp_instance_stop(p->rtp);
 }
 ast_mutex_unlock(&p->lock);

 if(gH323Debug)
 ast_verb(0, "+++ close_rtp_connection\n");

 return;
}

close_udptl_connection()

void close_udptl_connection

(

ooCallData *

call

)

Definition at line 4901 of file chan_ooh323.c.

References ast_channel_trylock, ast_channel_unlock, AST_CONTROL_T38_PARAMETERS, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_queue_control_data(), AST_T38_TERMINATED, ast_verb, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323_pvt::owner, ast_control_t38_parameters::request_response, T38_ENABLED, ooh323_pvt::t38_tx_enable, and ooh323_pvt::t38support.

Referenced by ooh323c_stop_transmit_datachannel().

{
 struct ooh323_pvt *p = NULL;

 if(gH323Debug)
 ast_verb(0, "--- close_udptl_connection\n");

 p = find_call(call);
 if (!p) {
 ast_log(LOG_ERROR, "Couldn't find matching call to close udptl "
 "connection\n");
 return;
 }
 ast_mutex_lock(&p->lock);
 if (p->owner) {
 while (p->owner && ast_channel_trylock(p->owner)) {
 ast_debug(1, "Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 }
 if (!p->owner) {
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return;
 }
 } else {
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return;
 }

 p->t38_tx_enable = 0;
 if (p->t38support == T38_ENABLED) {
 struct ast_control_t38_parameters parameters = { .request_response = 0 };
 parameters.request_response = AST_T38_TERMINATED;
 ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS, &parameters, sizeof(parameters));
 }

 ast_channel_unlock(p->owner);
 ast_mutex_unlock(&p->lock);

 if(gH323Debug)
 ast_verb(0, "+++ close_udptl_connection\n");

 return;
}

configure_local_rtp()

int configure_local_rtp	(	struct ooh323_pvt *	p,
		ooCallData *	call
	)

Definition at line 4599 of file chan_ooh323.c.

References ao2_ref, ast_channel_set_fd(), ast_channel_trylock, ast_channel_unlock, ast_copy_string(), ast_debug, ast_format_cap_count(), ast_format_cap_get_format(), ast_format_cap_get_framing(), ast_log, ast_mutex_unlock, ast_parse_arg(), ast_rtp_codecs_payloads_set_rtpmap_type(), ast_rtp_codecs_set_framing(), ast_rtp_instance_fd(), ast_rtp_instance_get_codecs(), ast_rtp_instance_get_local_address(), ast_rtp_instance_new(), ast_rtp_instance_set_prop(), ast_rtp_instance_set_qos(), ast_rtp_instance_set_timeout(), AST_RTP_PROPERTY_DTMF, AST_RTP_PROPERTY_NAT, AST_RTP_PROPERTY_RTCP, ast_sockaddr_copy(), ast_sockaddr_port, ast_sockaddr_stringify_addr(), ast_udptl_fd(), ast_udptl_get_us(), ast_udptl_new_with_bindaddr(), ast_udptl_set_far_max_datagram(), ast_verb, bindaddr, ooh323_pvt::cap, DEADLOCK_AVOIDANCE, ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, errno, format, gH323Debug, gTOS, H323_DTMF_CISCO, H323_DTMF_RFC2833, ooh323_pvt::lock, LOG_ERROR, LOG_WARNING, ooh323_pvt::nat, NULL, ooh323_convertAsteriskCapToH323Cap(), ooh323_pvt::owner, PARSE_ADDR, ooh323_pvt::rtdrcount, ooh323_pvt::rtdrinterval, ooh323_pvt::rtp, ooh323_pvt::rtptimeout, and ooh323_pvt::udptl.

Referenced by onNewCallCreated(), onOutgoingCall(), and ooh323_onReceivedSetup().

{
 char lhost[INET6_ADDRSTRLEN];
 unsigned lport = 0;
 struct ast_sockaddr tmp;
 ooMediaInfo mediaInfo;
 int x;

 if (gH323Debug)
 ast_verb(0, "--- configure_local_rtp\n");

 memset(&mediaInfo, 0, sizeof(mediaInfo));
 if (ast_parse_arg(call->localIP, PARSE_ADDR, &tmp)) {
 ast_sockaddr_copy(&tmp, &bindaddr);
 }
 if (!(p->rtp = ast_rtp_instance_new("asterisk", sched, &tmp, NULL))) {
 ast_log(LOG_WARNING, "Unable to create RTP session: %s\n",
 strerror(errno));
 return 0;
 }

 ast_rtp_instance_set_qos(p->rtp, gTOS, 0, "ooh323-rtp");

 if (!(p->udptl = ast_udptl_new_with_bindaddr(sched, io, 0, &tmp))) {
 ast_log(LOG_WARNING, "Unable to create UDPTL session: %s\n",
 strerror(errno));
 return 0;
 }
 ast_udptl_set_far_max_datagram(p->udptl, 144);

 if (p->owner) {
 while (p->owner && ast_channel_trylock(p->owner)) {
 ast_debug(1,"Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 }
 if (!p->owner) {
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return 0;
 }
 } else {
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return 0;
 }

 ast_channel_set_fd(p->owner, 0, ast_rtp_instance_fd(p->rtp, 0));
 ast_channel_set_fd(p->owner, 1, ast_rtp_instance_fd(p->rtp, 1));
 ast_channel_set_fd(p->owner, 5, ast_udptl_fd(p->udptl));

 ast_channel_unlock(p->owner);

 if (p->rtp) {
 if (p->cap) {
 ast_rtp_codecs_set_framing(ast_rtp_instance_get_codecs(p->rtp),
 ast_format_cap_get_framing(p->cap));
 }
 if (p->nat) {
 ast_rtp_instance_set_prop(p->rtp, AST_RTP_PROPERTY_NAT, 1);
 }
 if (p->dtmfmode & H323_DTMF_RFC2833 && p->dtmfcodec) {
 ast_rtp_instance_set_prop(p->rtp, AST_RTP_PROPERTY_DTMF, 1);
 ast_rtp_codecs_payloads_set_rtpmap_type(ast_rtp_instance_get_codecs(p->rtp),
 p->rtp, p->dtmfcodec, "audio", "telephone-event", 0);
 }
 if (p->dtmfmode & H323_DTMF_CISCO && p->dtmfcodec) {
 ast_rtp_instance_set_prop(p->rtp, AST_RTP_PROPERTY_DTMF, 1);
 ast_rtp_codecs_payloads_set_rtpmap_type(ast_rtp_instance_get_codecs(p->rtp),
 p->rtp, p->dtmfcodec, "audio", "cisco-telephone-event", 0);
 }
 /* figure out our local RTP port and tell the H.323 stack about it*/
 ast_rtp_instance_get_local_address(p->rtp, &tmp);
 ast_copy_string(lhost, ast_sockaddr_stringify_addr(&tmp), sizeof(lhost));
 lport = ast_sockaddr_port(&tmp);

 if (p->rtptimeout) {
 ast_rtp_instance_set_timeout(p->rtp, p->rtptimeout);
 }
 ast_rtp_instance_set_prop(p->rtp, AST_RTP_PROPERTY_RTCP, 1);

 }

 if (p->rtdrcount) {
 if (gH323Debug)
 ast_verb(0, "Setup RTDR info: %d, %d\n", p->rtdrinterval, p->rtdrcount);
 call->rtdrInterval = p->rtdrinterval;
 call->rtdrCount = p->rtdrcount;
 }


 ast_copy_string(mediaInfo.lMediaIP, lhost, sizeof(mediaInfo.lMediaIP));
 mediaInfo.lMediaPort = lport;
 mediaInfo.lMediaCntrlPort = mediaInfo.lMediaPort + 1;
 for (x = 0; x < ast_format_cap_count(p->cap); x++) {
 struct ast_format *format = ast_format_cap_get_format(p->cap, x);

 strcpy(mediaInfo.dir, "transmit");
 mediaInfo.cap = ooh323_convertAsteriskCapToH323Cap(format);
 ooAddMediaInfo(call, mediaInfo);
 strcpy(mediaInfo.dir, "receive");
 ooAddMediaInfo(call, mediaInfo);
 if (mediaInfo.cap == OO_G729A) {
 strcpy(mediaInfo.dir, "transmit");
 mediaInfo.cap = OO_G729;
 ooAddMediaInfo(call, mediaInfo);
 strcpy(mediaInfo.dir, "receive");
 ooAddMediaInfo(call, mediaInfo);

 strcpy(mediaInfo.dir, "transmit");
 mediaInfo.cap = OO_G729B;
 ooAddMediaInfo(call, mediaInfo);
 strcpy(mediaInfo.dir, "receive");
 ooAddMediaInfo(call, mediaInfo);
 }

 ao2_ref(format, -1);
 }

 if (p->udptl) {
 ast_udptl_get_us(p->udptl, &tmp);
 ast_copy_string(lhost, ast_sockaddr_stringify_addr(&tmp), sizeof(lhost));
 lport = ast_sockaddr_port(&tmp);
 ast_copy_string(mediaInfo.lMediaIP, lhost, sizeof(mediaInfo.lMediaIP));
 mediaInfo.lMediaPort = lport;
 mediaInfo.lMediaCntrlPort = mediaInfo.lMediaPort +1;
 mediaInfo.cap = OO_T38;
 strcpy(mediaInfo.dir, "transmit");
 ooAddMediaInfo(call, mediaInfo);
 strcpy(mediaInfo.dir, "receive");
 ooAddMediaInfo(call, mediaInfo);
 }

 if (gH323Debug)
 ast_verb(0, "+++ configure_local_rtp\n");

 return 1;
}

delete_peers()

int delete_peers

(

void

)

Definition at line 4230 of file chan_ooh323.c.

References ast_free, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_peer_list::lock, ooh323_peer::next, NULL, peerl, and ast_peer_list::peers.

Referenced by reload_config(), and unload_module().

{
 struct ooh323_peer *cur = NULL, *prev = NULL;
 ast_mutex_lock(&peerl.lock);
 cur = peerl.peers;
 while (cur) {
 prev = cur;
 cur = cur->next;

 ast_mutex_destroy(&prev->lock);
 ast_free(prev->h323id);
 ast_free(prev->email);
 ast_free(prev->url);
 ast_free(prev->e164);
 if(prev->rtpmask) {
 ast_mutex_lock(&prev->rtpmask->lock);
 prev->rtpmask->inuse--;
 ast_mutex_unlock(&prev->rtpmask->lock);
 if (prev->rtpmask->inuse == 0) {
 regfree(&prev->rtpmask->regex);
 ast_mutex_destroy(&prev->rtpmask->lock);
 ast_free(prev->rtpmask);
 }
 }
 ast_free(prev);

 if (cur == peerl.peers) {
 break;
 }
 }
 peerl.peers = NULL;
 ast_mutex_unlock(&peerl.lock);
 return 0;
}

delete_users()

int delete_users

(

void

)

Definition at line 4265 of file chan_ooh323.c.

References ao2_cleanup, ast_free, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_user_list::lock, ooh323_user::next, NULL, userl, and ast_user_list::users.

Referenced by reload_config(), and unload_module().

{
 struct ooh323_user *cur = NULL, *prev = NULL;
 ast_mutex_lock(&userl.lock);
 cur = userl.users;
 while (cur) {
 prev = cur;
 cur = cur->next;
 ast_mutex_destroy(&prev->lock);

 if(prev->rtpmask) {
 ast_mutex_lock(&prev->rtpmask->lock);
 prev->rtpmask->inuse--;
 ast_mutex_unlock(&prev->rtpmask->lock);
 if (prev->rtpmask->inuse == 0) {
 regfree(&prev->rtpmask->regex);
 ast_mutex_destroy(&prev->rtpmask->lock);
 ast_free(prev->rtpmask);
 }
 }
 ao2_cleanup(prev->cap);
 ast_free(prev);
 if (cur == userl.users) {
 break;
 }
 }
 userl.users = NULL;
 ast_mutex_unlock(&userl.lock);
 return 0;
}

do_monitor()

static void* do_monitor ( void *  data )

static

Definition at line 3998 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_trylock, ast_channel_unlock, ast_io_wait(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_sendcng(), ast_sched_runq(), ast_sched_wait(), ast_sockaddr_isnull(), AST_SOFTHANGUP_DEV, ast_softhangup_nolock(), ast_test_flag, ast_verb, gGatekeeper, gH323ep, gRasGkMode, gRASIP, H323_NEEDDESTROY, h323_reload_lock, h323_reloading, iflist, iflock, ooh323_pvt::lastrtprx, ooh323_pvt::lastrtptx, LOG_NOTICE, monlock, ooh323_pvt::next, NULL, ooh323_destroy(), ooh323_do_reload(), ooh323_pvt::owner, ooh323_pvt::redirip, ooh323_pvt::rtp, and ooh323_pvt::rtptimeout.

Referenced by restart_monitor().

{
 int res;
 int reloading;
 struct ooh323_pvt *h323 = NULL;
 time_t t;

 for (;;) {
 struct ooh323_pvt *h323_next;
 /* Check for a reload request */
 ast_mutex_lock(&h323_reload_lock);
 reloading = h323_reloading;
 h323_reloading = 0;
 ast_mutex_unlock(&h323_reload_lock);
 if (reloading) {
 ast_verb(1, "Reloading H.323\n");
 ooh323_do_reload();
 }
 if (gH323ep.gkClient && gH323ep.gkClient->state == GkClientStopped) {
 ooGkClientDestroy();
 ast_verb(0, "Restart stopped gatekeeper client\n");
 ooGkClientInit(gRasGkMode, (gRasGkMode == RasUseSpecificGatekeeper) ?
 gGatekeeper : 0, gRASIP, 0);
 ooGkClientStart(gH323ep.gkClient);
 }

 /* Check for interfaces needing to be killed */
 ast_mutex_lock(&iflock);
 time(&t);
 h323 = iflist;
 while (h323) {
 h323_next = h323->next;

 if (h323->rtp && h323->rtptimeout && h323->lastrtptx &&
 h323->lastrtptx + h323->rtptimeout < t) {
 ast_rtp_instance_sendcng(h323->rtp, 0);
 h323->lastrtptx = time(NULL);
 }

 if (h323->rtp && h323->owner && h323->rtptimeout &&
 h323->lastrtprx && ast_sockaddr_isnull(&h323->redirip) &&
 h323->lastrtprx + h323->rtptimeout < t) {
 if (!ast_channel_trylock(h323->owner)) {
 ast_softhangup_nolock(h323->owner, AST_SOFTHANGUP_DEV);
 ast_log(LOG_NOTICE, "Disconnecting call '%s' for lack of RTP activity in %ld seconds\n", ast_channel_name(h323->owner), (long) (t - h323->lastrtprx));
 ast_channel_unlock(h323->owner);
 }

 }

 if (ast_test_flag(h323, H323_NEEDDESTROY)) {
 ooh323_destroy (h323);
 } /* else if (ast_test_flag(h323, H323_NEEDSTART) && h323->owner) {
 ast_channel_lock(h323->owner);
 if (ast_pbx_start(h323->owner)) {
 ast_log(LOG_WARNING, "Unable to start PBX on %s\n", h323->owner->name);
 ast_channel_unlock(h323->owner);
 ast_hangup(h323->owner);
 }
 ast_channel_unlock(h323->owner);
 ast_clear_flag(h323, H323_NEEDSTART);
 } */
 h323 = h323_next;
 }
 ast_mutex_unlock(&iflock);
 pthread_testcancel();

 /* Wait for sched or io */
 res = ast_sched_wait(sched);
 if ((res < 0) || (res > 1000)) {
 res = 1000;
 }
 res = ast_io_wait(io, res);
 pthread_testcancel();
 ast_mutex_lock(&monlock);
 if (res >= 0) {
 ast_sched_runq(sched);
 }
 ast_mutex_unlock(&monlock);
 }
 /* Never reached */
 return NULL;
}

find_call()

static struct ooh323_pvt* find_call ( ooCallData *  call )

static

Definition at line 810 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, ooh323_pvt::callToken, gH323Debug, iflist, iflock, and ooh323_pvt::next.

Referenced by close_rtp_connection(), close_udptl_connection(), onAlerting(), onCallCleared(), onCallEstablished(), onModeChanged(), onNewCallCreated(), onOutgoingCall(), onProgress(), ooh323_onReceivedDigit(), ooh323_set_read_format(), ooh323_set_write_format(), setup_rtp_connection(), setup_rtp_remote(), and setup_udptl_connection().

{
 struct ooh323_pvt *p;

 if (gH323Debug)
 ast_verb(0, "--- find_call\n");

 ast_mutex_lock(&iflock);

 for (p = iflist; p; p = p->next) {
 if (p->callToken && !strcmp(p->callToken, call->callToken)) {
 break;
 }
 }
 ast_mutex_unlock(&iflock);

 if (gH323Debug)
 ast_verb(0, "+++ find_call\n");

 return p;
}

find_friend()

struct ooh323_peer * find_friend	(	const char *	name,
		int	port
	)

Definition at line 858 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, gH323Debug, ooh323_peer::ip, ast_peer_list::lock, ooh323_peer::next, ooh323_pvt::peer, peerl, ast_peer_list::peers, and ooh323_peer::port.

{
 struct ooh323_peer *peer;

 if (gH323Debug)
 ast_verb(0, "--- find_friend \"%s\"\n", name);


 ast_mutex_lock(&peerl.lock);
 for (peer = peerl.peers; peer; peer = peer->next) {
 if (gH323Debug) {
 ast_verb(0, " comparing with \"%s\"\n", peer->ip);
 }
 if (!strcmp(peer->ip, name)) {
 if (port <= 0 || (port > 0 && peer->port == port)) {
 break;
 }
 }
 }
 ast_mutex_unlock(&peerl.lock);

 if (gH323Debug) {
 if (peer) {
 ast_verb(0, " found matching friend\n");
 }
 ast_verb(0, "+++ find_friend \"%s\"\n", name);
 }

 return peer;
}

find_peer()

struct ooh323_peer* find_peer	(	const char *	name,
		int	port
	)

Definition at line 890 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, ooh323_peer::e164, gH323Debug, ooh323_peer::h323id, ooh323_peer::ip, ast_peer_list::lock, ooh323_peer::name, ooh323_peer::next, ooh323_pvt::peer, peerl, and ast_peer_list::peers.

Referenced by ooh323_request().

{
 struct ooh323_peer *peer;

 if (gH323Debug)
 ast_verb(0, "--- find_peer \"%s\"\n", name);


 ast_mutex_lock(&peerl.lock);
 for (peer = peerl.peers; peer; peer = peer->next) {
 if (gH323Debug) {
 ast_verb(0, " comparing with \"%s\"\n", peer->ip);
 }
 if (!strcasecmp(peer->name, name))
 break;
 if (peer->h323id && !strcasecmp(peer->h323id, name))
 break;
 if (peer->e164 && !strcasecmp(peer->e164, name))
 break;
 /*
 if (!strcmp(peer->ip, name)) {
 if (port > 0 && peer->port == port) { break; }
 else if (port <= 0) { break; }
 }
 */
 }
 ast_mutex_unlock(&peerl.lock);

 if (gH323Debug) {
 if (peer) {
 ast_verb(0, " found matching peer\n");
 }
 ast_verb(0, "+++ find_peer \"%s\"\n", name);
 }

 return peer;
}

find_user()

struct ooh323_user* find_user	(	const char *	name,
		const char *	ip
	)

Definition at line 832 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, gH323Debug, ast_user_list::lock, ooh323_user::mIP, ooh323_user::mUseIP, ooh323_user::name, ooh323_user::next, ooh323_pvt::user, userl, and ast_user_list::users.

Referenced by ooh323_destroy(), and ooh323_onReceivedSetup().

{
 struct ooh323_user *user;

 if (gH323Debug)
 ast_verb(0, "--- find_user: %s, %s\n",name,ip);

 ast_mutex_lock(&userl.lock);

 for (user = userl.users; user; user = user->next) {
 if (ip && user->mUseIP && !strcmp(user->mIP, ip)) {
 break;
 }
 if (name && !strcmp(user->name, name)) {
 break;
 }
 }

 ast_mutex_unlock(&userl.lock);

 if (gH323Debug)
 ast_verb(0, "+++ find_user\n");

 return user;
}

function_ooh323_read()

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

static

OOH323 Dialplan function - reads ooh323 settings.

Definition at line 3685 of file chan_ooh323.c.

References ast_channel_lock, ast_channel_tech(), ast_channel_tech_pvt(), ast_channel_unlock, ast_copy_string(), ast_log, ast_mutex_lock, ast_mutex_unlock, ooh323_pvt::callee_dialedDigits, ooh323_pvt::callee_email, ooh323_pvt::callee_h323id, ooh323_pvt::callee_url, ooh323_pvt::caller_dialedDigits, ooh323_pvt::caller_email, ooh323_pvt::caller_h323id, ooh323_pvt::caller_url, ooh323_pvt::faxdetect, ooh323_pvt::lock, LOG_ERROR, ooh323_pvt::t38support, and type.

{
 struct ooh323_pvt *p = ast_channel_tech_pvt(chan);

 ast_channel_lock(chan);
 if (!p) {
 ast_channel_unlock(chan);
 return -1;
 }

 if (strcmp(ast_channel_tech(chan)->type, "OOH323")) {
 ast_log(LOG_ERROR, "This function is only supported on OOH323 channels, Channel is %s\n", ast_channel_tech(chan)->type);
 ast_channel_unlock(chan);
 return -1;
 }

 ast_mutex_lock(&p->lock);
 if (!strcasecmp(data, "faxdetect")) {
 ast_copy_string(buf, p->faxdetect ? "1" : "0", len);
 } else if (!strcasecmp(data, "t38support")) {
 ast_copy_string(buf, p->t38support ? "1" : "0", len);
 } else if (!strcasecmp(data, "caller_h323id")) {
 ast_copy_string(buf, p->caller_h323id, len);
 } else if (!strcasecmp(data, "caller_dialeddigits")) {
 ast_copy_string(buf, p->caller_dialedDigits, len);
 } else if (!strcasecmp(data, "caller_email")) {
 ast_copy_string(buf, p->caller_email, len);
 } else if (!strcasecmp(data, "h323id_url")) {
 ast_copy_string(buf, p->caller_url, len);
 } else if (!strcasecmp(data, "callee_h323id")) {
 ast_copy_string(buf, p->callee_h323id, len);
 } else if (!strcasecmp(data, "callee_dialeddigits")) {
 ast_copy_string(buf, p->callee_dialedDigits, len);
 } else if (!strcasecmp(data, "callee_email")) {
 ast_copy_string(buf, p->callee_email, len);
 } else if (!strcasecmp(data, "callee_url")) {
 ast_copy_string(buf, p->callee_url, len);
 }
 ast_mutex_unlock(&p->lock);

 ast_channel_unlock(chan);
 return 0;
}

function_ooh323_write()

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

static

OOH323 Dialplan function - writes ooh323 settings.

Definition at line 3730 of file chan_ooh323.c.

References ast_channel_lock, ast_channel_tech(), ast_channel_tech_pvt(), ast_channel_unlock, ast_false(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strdupa, ast_true(), buf, ooh323_pvt::faxdetect, FAXDETECT_CNG, FAXDETECT_T38, ooh323_pvt::lock, LOG_ERROR, LOG_WARNING, ooh323_pvt::next, strsep(), ooh323_pvt::t38support, and type.

{
 struct ooh323_pvt *p = ast_channel_tech_pvt(chan);
 int res = -1;

 ast_channel_lock(chan);
 if (!p) {
 ast_channel_unlock(chan);
 return -1;
 }

 if (strcmp(ast_channel_tech(chan)->type, "OOH323")) {
 ast_log(LOG_ERROR, "This function is only supported on OOH323 channels, Channel is %s\n", ast_channel_tech(chan)->type);
 ast_channel_unlock(chan);
 return -1;
 }

 ast_mutex_lock(&p->lock);
 if (!strcasecmp(data, "faxdetect")) {
 if (ast_true(value)) {
 p->faxdetect = 1;
 res = 0;
 } else if (ast_false(value)) {
 p->faxdetect = 0;
 res = 0;
 } else {
 char *buf = ast_strdupa(value);
 char *word, *next = buf;
 p->faxdetect = 0;
 res = 0;
 while ((word = strsep(&next, ","))) {
 if (!strcasecmp(word, "cng")) {
 p->faxdetect |= FAXDETECT_CNG;
 } else if (!strcasecmp(word, "t38")) {
 p->faxdetect |= FAXDETECT_T38;
 } else {
 ast_log(LOG_WARNING, "Unknown faxdetect mode '%s'.\n", word);
 res = -1;
 }
 }

 }
 } else if (!strcasecmp(data, "t38support")) {
 if (ast_true(value)) {
 p->t38support = 1;
 res = 0;
 } else {
 p->t38support = 0;
 res = 0;
 }
 }
 ast_mutex_unlock(&p->lock);
 ast_channel_unlock(chan);

 return res;
}

handle_cli_ooh323_reload()

char* handle_cli_ooh323_reload	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)

Definition at line 2778 of file chan_ooh323.c.

References ast_cli_args::argc, ast_mutex_lock, ast_mutex_unlock, ast_verb, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, ast_cli_entry::command, gH323Debug, h323_reload_lock, h323_reloading, NULL, restart_monitor(), and ast_cli_entry::usage.

{

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 reload";
 e->usage =
 "Usage: ooh323 reload\n"
 " Reload OOH323 config.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 2)
 return CLI_SHOWUSAGE;

 if (gH323Debug)
 ast_verb(0, "--- ooh323_reload\n");

 ast_mutex_lock(&h323_reload_lock);
 if (h323_reloading) {
 ast_verb(0, "Previous OOH323 reload not yet done\n");
 } else {
 h323_reloading = 1;
 }
 ast_mutex_unlock(&h323_reload_lock);
 restart_monitor();

 if (gH323Debug)
 ast_verb(0, "+++ ooh323_reload\n");

 return 0;
}

handle_cli_ooh323_set_debug()

static char* handle_cli_ooh323_set_debug ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3466 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, FALSE, ast_cli_args::fd, gH323Debug, NULL, RESULT_SUCCESS, TRUE, and ast_cli_entry::usage.

{
 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 set debug [off]";
 e->usage =
 "Usage: ooh323 set debug [off]\n"
 " Enables/Disables debugging of OOH323 channel driver\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc < 3 || a->argc > 4)
 return CLI_SHOWUSAGE;
 if (a->argc == 4 && strcasecmp(a->argv[3], "off"))
 return CLI_SHOWUSAGE;

 gH323Debug = (a->argc == 4) ? FALSE : TRUE;
 ast_cli(a->fd, "OOH323 Debugging %s\n", gH323Debug ? "Enabled" : "Disabled");

 return CLI_SUCCESS;
}

handle_cli_ooh323_show_config()

static char* handle_cli_ooh323_show_config ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3558 of file chan_ooh323.c.

References ast_cli_args::argc, ast_channel_amaflags2string(), ast_cli(), ast_format_cap_get_names(), AST_FORMAT_CAP_NAMES_LEN, ast_str_alloca, callnumber, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, FAXDETECT_CNG, FAXDETECT_T38, ast_cli_args::fd, FORMAT_STRING_SIZE, gAccountcode, gAliasList, gAMAFLAGS, gCallerID, gContext, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gGatekeeper, gH323ep, gIP, gLogFile, gMediaWaitForConnect, gPort, gRasGkMode, gRTDRCount, gRTDRInterval, gT38Support, gTunneling, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_config::mTCPPortEnd, ooh323_config::mTCPPortStart, NULL, ooconfig, T38_DISABLED, T38_FAXGW, ast_cli_entry::usage, and value.

{
 char value[FORMAT_STRING_SIZE];
 struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
 ooAliases *pAlias = NULL, *pAliasNext = NULL;;

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show config";
 e->usage =
 "Usage: ooh323 show config\n"
 " Shows global configuration of H.323 channel driver\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 3)
 return CLI_SHOWUSAGE;

 ast_cli(a->fd, "\nObjective Open H.323 Channel Driver's Config:\n");
 snprintf(value, sizeof(value), "%s:%d", gIP, gPort);
 ast_cli(a->fd, "%-20s%s\n", "IP:Port: ", value);
 ast_cli(a->fd, "%-20s%d-%d\n", "H.225 port range: ", ooconfig.mTCPPortStart, ooconfig.mTCPPortEnd);
 ast_cli(a->fd, "%-20s%s\n", "FastStart", gFastStart?"yes":"no");
 ast_cli(a->fd, "%-20s%s\n", "Tunneling", gTunneling?"yes":"no");
 ast_cli(a->fd, "%-20s%s\n", "CallerId", gCallerID);
 ast_cli(a->fd, "%-20s%s\n", "MediaWaitForConnect", gMediaWaitForConnect?"yes":"no");
 ast_cli(a->fd, "%-20s%s\n", "DirectRTP", gDirectRTP ? "yes" : "no");
 ast_cli(a->fd, "%-20s%s\n", "EarlyDirectRTP", gEarlyDirect ? "yes" : "no");

#if (0)
 extern OOH323EndPoint gH323ep;
 ast_cli(a->fd, "%-20s%s\n", "FASTSTART",
 (OO_TESTFLAG(gH323ep.flags, OO_M_FASTSTART) != 0) ? "yes" : "no");
 ast_cli(a->fd, "%-20s%s\n", "TUNNELING",
 (OO_TESTFLAG(gH323ep.flags, OO_M_TUNNELING) != 0) ? "yes" : "no");
 ast_cli(a->fd, "%-20s%s\n", "MEDIAWAITFORCONN",
 (OO_TESTFLAG(gH323ep.flags, OO_M_MEDIAWAITFORCONN) != 0) ? "yes" : "no");
#endif

 if (gRasGkMode == RasNoGatekeeper) {
 snprintf(value, sizeof(value), "%s", "No Gatekeeper");
 } else if (gRasGkMode == RasDiscoverGatekeeper) {
 snprintf(value, sizeof(value), "%s", "Discover");
 } else {
 snprintf(value, sizeof(value), "%s", gGatekeeper);
 }
 ast_cli(a->fd, "%-20s%s\n", "Gatekeeper:", value);
 ast_cli(a->fd, "%-20s%s\n", "H.323 LogFile:", gLogFile);
 ast_cli(a->fd, "%-20s%s\n", "Context:", gContext);
 ast_cli(a->fd, "%-20s%s\n", "Capability:",
 ast_format_cap_get_names(gCap, &codec_buf));
 ast_cli(a->fd, "%-20s", "DTMF Mode: ");
 if (gDTMFMode & H323_DTMF_CISCO) {
 ast_cli(a->fd, "%s\n", "cisco");
 ast_cli(a->fd, "%-20.15s%d\n", "DTMF Codec: ", gDTMFCodec);
 } else if (gDTMFMode & H323_DTMF_RFC2833) {
 ast_cli(a->fd, "%s\n", "rfc2833");
 ast_cli(a->fd, "%-20.15s%d\n", "DTMF Codec: ", gDTMFCodec);
 } else if (gDTMFMode & H323_DTMF_Q931) {
 ast_cli(a->fd, "%s\n", "q931keypad");
 } else if (gDTMFMode & H323_DTMF_H245ALPHANUMERIC) {
 ast_cli(a->fd, "%s\n", "h245alphanumeric");
 } else if (gDTMFMode & H323_DTMF_H245SIGNAL) {
 ast_cli(a->fd, "%s\n", "h245signal");
 } else if (gDTMFMode & H323_DTMF_INBAND && gDTMFMode & H323_DTMF_INBANDRELAX) {
 ast_cli(a->fd, "%s\n", "inband-relaxed");
 } else if (gDTMFMode & H323_DTMF_INBAND) {
 ast_cli(a->fd, "%s\n", "inband");
 } else {
 ast_cli(a->fd, "%s\n", "unknown");
 }

 ast_cli(a->fd,"%-20s", "T.38 Mode: ");
 if (gT38Support == T38_DISABLED) {
 ast_cli(a->fd, "%s\n", "disabled");
 } else if (gT38Support == T38_FAXGW) {
 ast_cli(a->fd, "%s\n", "faxgw/chan_sip compatible");
 }
 if (gFAXdetect == (FAXDETECT_CNG | FAXDETECT_T38)) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Yes");
 } else if (gFAXdetect & FAXDETECT_CNG) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Cng");
 } else if (gFAXdetect & FAXDETECT_T38) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "T.38");
 } else {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "No");
 }

 if (gRTDRCount && gRTDRInterval) {
 ast_cli(a->fd, "%-20.15s%d,%d\n", "RoundTrip: ", gRTDRCount, gRTDRInterval);
 }

 ast_cli(a->fd, "%-20s%ld\n", "Call counter: ", callnumber);
 ast_cli(a->fd, "%-20s%s\n", "AccountCode: ", gAccountcode);
 ast_cli(a->fd, "%-20s%s\n", "AMA flags: ", ast_channel_amaflags2string(gAMAFLAGS));

 pAlias = gAliasList;
 if(pAlias) {
 ast_cli(a->fd, "%-20s\n", "Aliases: ");
 }
 while (pAlias) {
 pAliasNext = pAlias->next;
 if (pAliasNext) {
 ast_cli(a->fd,"\t%-30s\t%-30s\n",pAlias->value, pAliasNext->value);
 pAlias = pAliasNext->next;
 } else {
 ast_cli(a->fd,"\t%-30s\n",pAlias->value);
 pAlias = pAlias->next;
 }
 }
 return CLI_SUCCESS;
}

handle_cli_ooh323_show_gk()

static char* handle_cli_ooh323_show_gk ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3497 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, FORMAT_STRING_SIZE, gGatekeeper, gH323ep, gRasGkMode, NULL, ast_cli_entry::usage, and value.

{
 char value[FORMAT_STRING_SIZE];

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show gk";
 e->usage =
 "Usage: ooh323 show gk\n"
 " Shows Gatekeeper connection state\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 3)
 return CLI_SHOWUSAGE;

 ast_cli(a->fd, "\nGateKeeper connection state:\n");
 if (!gH323ep.gkClient) {
 ast_cli(a->fd, "No Gatekeeper is configured\n");
 return CLI_SUCCESS;
 }

 if (gRasGkMode == RasNoGatekeeper) {
 snprintf(value, sizeof(value), "%s", "No Gatekeeper");
 } else if (gRasGkMode == RasDiscoverGatekeeper) {
 snprintf(value, sizeof(value), "%s", "Discover");
 } else {
 snprintf(value, sizeof(value), "%s", gGatekeeper);
 }
 ast_cli(a->fd, "%-20s%s\n", "Gatekeeper:", value);
 switch(gH323ep.gkClient->state) {
 case GkClientIdle:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Idle");
 break;
 case GkClientDiscovered:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Discovered");
 break;
 case GkClientRegistered:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Registered");
 break;
 case GkClientUnregistered:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Unregistered");
 break;
 case GkClientGkErr:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Error");
 break;
 case GkClientFailed:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Failed");
 break;
 case GkClientStopped:
 ast_cli(a->fd, "%-20s%s\n", "GK state:", "Shutdown");
 break;
 default:
 break;
 }

 return CLI_SUCCESS;
}

handle_cli_ooh323_show_peer()

static char* handle_cli_ooh323_show_peer ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3188 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_channel_amaflags2string(), ast_cli(), ast_mutex_lock, ast_mutex_unlock, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, FAXDETECT_CNG, FAXDETECT_T38, ast_cli_args::fd, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_peer::lock, ast_peer_list::lock, NULL, ooh323_pvt::peer, peerl, ast_peer_list::peers, T38_DISABLED, T38_FAXGW, and ast_cli_entry::usage.

{
 char ip_port[64];
 struct ooh323_peer *prev = NULL, *peer = NULL;

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show peer";
 e->usage =
 "Usage: ooh323 show peer <name>\n"
 " List details of specific OOH323 peer.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 4)
 return CLI_SHOWUSAGE;

 ast_mutex_lock(&peerl.lock);
 peer = peerl.peers;
 while (peer) {
 ast_mutex_lock(&peer->lock);
 if (!strcmp(peer->name, a->argv[3])) {
 break;
 } else {
 prev = peer;
 peer = peer->next;
 ast_mutex_unlock(&prev->lock);
 }
 }

 if (peer) {
 sprintf(ip_port, "%s:%d", peer->ip, peer->port);
 ast_cli(a->fd, "%-15.15s%s\n", "Name: ", peer->name);
 ast_cli(a->fd, "%s:%s,%s\n", "FastStart/H.245 Tunneling", peer->faststart?"yes":"no",
 peer->h245tunneling?"yes":"no");
 ast_cli(a->fd, "%-15s%s\n", "DirectRTP", peer->directrtp ? "yes" : "no");
 ast_cli(a->fd, "%-15s%s\n", "EarlyDirectRTP", peer->earlydirect ? "yes" : "no");
 ast_cli(a->fd, "%-15.15s", "DTMF Mode: ");
 if (peer->dtmfmode & H323_DTMF_CISCO) {
 ast_cli(a->fd, "%s\n", "cisco");
 ast_cli(a->fd, "%-15.15s%d\n", "DTMF Codec: ", peer->dtmfcodec);
 } else if (peer->dtmfmode & H323_DTMF_RFC2833) {
 ast_cli(a->fd, "%s\n", "rfc2833");
 ast_cli(a->fd, "%-15.15s%d\n", "DTMF Codec: ", peer->dtmfcodec);
 } else if (peer->dtmfmode & H323_DTMF_Q931) {
 ast_cli(a->fd, "%s\n", "q931keypad");
 } else if (peer->dtmfmode & H323_DTMF_H245ALPHANUMERIC) {
 ast_cli(a->fd, "%s\n", "h245alphanumeric");
 } else if (peer->dtmfmode & H323_DTMF_H245SIGNAL) {
 ast_cli(a->fd, "%s\n", "h245signal");
 } else if (peer->dtmfmode & H323_DTMF_INBAND && peer->dtmfmode & H323_DTMF_INBANDRELAX) {
 ast_cli(a->fd, "%s\n", "inband-relaxed");
 } else if (peer->dtmfmode & H323_DTMF_INBAND) {
 ast_cli(a->fd, "%s\n", "inband");
 } else {
 ast_cli(a->fd, "%s\n", "unknown");
 }
 ast_cli(a->fd,"%-15s", "T.38 Mode: ");
 if (peer->t38support == T38_DISABLED) {
 ast_cli(a->fd, "%s\n", "disabled");
 } else if (peer->t38support == T38_FAXGW) {
 ast_cli(a->fd, "%s\n", "faxgw/chan_sip compatible");
 }
 if (peer->faxdetect == (FAXDETECT_CNG | FAXDETECT_T38)) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Yes");
 } else if (peer->faxdetect & FAXDETECT_CNG) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Cng");
 } else if (peer->faxdetect & FAXDETECT_T38) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "T.38");
 } else {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "No");
 }

 ast_cli(a->fd, "%-15.15s%s\n", "AccountCode: ", peer->accountcode);
 ast_cli(a->fd, "%-15.15s%s\n", "AMA flags: ", ast_channel_amaflags2string(peer->amaflags));
 ast_cli(a->fd, "%-15.15s%s\n", "IP:Port: ", ip_port);
 ast_cli(a->fd, "%-15.15s%u\n", "OutgoingLimit: ", peer->outgoinglimit);
 ast_cli(a->fd, "%-15.15s%d\n", "rtptimeout: ", peer->rtptimeout);
 ast_cli(a->fd, "%-15.15s%s\n", "nat: ", peer->nat?"yes":"no");
 if (peer->rtpmaskstr[0]) {
 ast_cli(a->fd, "%-15.15s%s\n", "rtpmask: ", peer->rtpmaskstr);
 }
 if (peer->rtdrcount && peer->rtdrinterval) {
 ast_cli(a->fd, "%-15.15s%d,%d\n", "RoundTrip: ", peer->rtdrcount, peer->rtdrinterval);
 }
 ast_mutex_unlock(&peer->lock);
 } else {
 ast_cli(a->fd, "Peer %s not found\n", a->argv[3]);
 ast_cli(a->fd, "\n");
 }
 ast_mutex_unlock(&peerl.lock);

 return CLI_SUCCESS;
}

handle_cli_ooh323_show_peers()

static char* handle_cli_ooh323_show_peers ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3285 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli(), ast_format_cap_get_names(), AST_FORMAT_CAP_NAMES_LEN, ast_mutex_lock, ast_mutex_unlock, ast_str_alloca, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, FORMAT, ooh323_peer::lock, ast_peer_list::lock, NULL, ooh323_pvt::peer, peerl, ast_peer_list::peers, and ast_cli_entry::usage.

{
 struct ooh323_peer *prev = NULL, *peer = NULL;
 struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
 char ip_port[64];
#define FORMAT "%-15.15s %-15.15s %-23.23s %-s\n"

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show peers";
 e->usage =
 "Usage: ooh323 show peers\n"
 " Lists all known OOH323 peers.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 3)
 return CLI_SHOWUSAGE;

 ast_cli(a->fd, FORMAT, "Name", "Accountcode", "ip:port", "Formats");

 ast_mutex_lock(&peerl.lock);
 peer = peerl.peers;
 while (peer) {
 ast_mutex_lock(&peer->lock);
 snprintf(ip_port, sizeof(ip_port), "%s:%d", peer->ip, peer->port);
 ast_cli(a->fd, FORMAT, peer->name,
 peer->accountcode,
 ip_port,
 ast_format_cap_get_names(peer->cap, &codec_buf));
 prev = peer;
 peer = peer->next;
 ast_mutex_unlock(&prev->lock);

 }
 ast_mutex_unlock(&peerl.lock);
#undef FORMAT
 return CLI_SUCCESS;
}

handle_cli_ooh323_show_user()

static char* handle_cli_ooh323_show_user ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3327 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_channel_amaflags2string(), ast_cli(), ast_mutex_lock, ast_mutex_unlock, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, FAXDETECT_CNG, FAXDETECT_T38, ast_cli_args::fd, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_user::lock, ast_user_list::lock, NULL, T38_DISABLED, T38_FAXGW, ast_cli_entry::usage, ooh323_pvt::user, userl, and ast_user_list::users.

{
 struct ooh323_user *prev = NULL, *user = NULL;

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show user";
 e->usage =
 "Usage: ooh323 show user <name>\n"
 " List details of specific OOH323 user.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 4)
 return CLI_SHOWUSAGE;


 ast_mutex_lock(&userl.lock);
 user = userl.users;
 while (user) {
 ast_mutex_lock(&user->lock);
 if (!strcmp(user->name, a->argv[3])) {
 break;
 } else {
 prev = user;
 user = user->next;
 ast_mutex_unlock(&prev->lock);
 }
 }

 if (user) {
 ast_cli(a->fd, "%-15.15s%s\n", "Name: ", user->name);
 ast_cli(a->fd, "%s:%s,%s\n", "FastStart/H.245 Tunneling", user->faststart?"yes":"no",
 user->h245tunneling?"yes":"no");
 ast_cli(a->fd, "%-15s%s\n", "DirectRTP", user->directrtp ? "yes" : "no");
 ast_cli(a->fd, "%-15s%s\n", "EarlyDirectRTP", user->earlydirect ? "yes" : "no");
 ast_cli(a->fd, "%-15.15s", "DTMF Mode: ");
 if (user->dtmfmode & H323_DTMF_CISCO) {
 ast_cli(a->fd, "%s\n", "cisco");
 ast_cli(a->fd, "%-15.15s%d\n", "DTMF Codec: ", user->dtmfcodec);
 } else if (user->dtmfmode & H323_DTMF_RFC2833) {
 ast_cli(a->fd, "%s\n", "rfc2833");
 ast_cli(a->fd, "%-15.15s%d\n", "DTMF Codec: ", user->dtmfcodec);
 } else if (user->dtmfmode & H323_DTMF_Q931) {
 ast_cli(a->fd, "%s\n", "q931keypad");
 } else if (user->dtmfmode & H323_DTMF_H245ALPHANUMERIC) {
 ast_cli(a->fd, "%s\n", "h245alphanumeric");
 } else if (user->dtmfmode & H323_DTMF_H245SIGNAL) {
 ast_cli(a->fd, "%s\n", "h245signal");
 } else if (user->dtmfmode & H323_DTMF_INBAND && user->dtmfmode & H323_DTMF_INBANDRELAX) {
 ast_cli(a->fd, "%s\n", "inband-relaxed");
 } else if (user->dtmfmode & H323_DTMF_INBAND) {
 ast_cli(a->fd, "%s\n", "inband");
 } else {
 ast_cli(a->fd, "%s\n", "unknown");
 }
 ast_cli(a->fd,"%-15s", "T.38 Mode: ");
 if (user->t38support == T38_DISABLED) {
 ast_cli(a->fd, "%s\n", "disabled");
 } else if (user->t38support == T38_FAXGW) {
 ast_cli(a->fd, "%s\n", "faxgw/chan_sip compatible");
 }
 if (user->faxdetect == (FAXDETECT_CNG | FAXDETECT_T38)) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Yes");
 } else if (user->faxdetect & FAXDETECT_CNG) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "Cng");
 } else if (user->faxdetect & FAXDETECT_T38) {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "T.38");
 } else {
 ast_cli(a->fd,"%-20s%s\n", "FAX Detect:", "No");
 }

 ast_cli(a->fd, "%-15.15s%s\n", "AccountCode: ", user->accountcode);
 ast_cli(a->fd, "%-15.15s%s\n", "AMA flags: ", ast_channel_amaflags2string(user->amaflags));
 ast_cli(a->fd, "%-15.15s%s\n", "Context: ", user->context);
 ast_cli(a->fd, "%-15.15s%d\n", "IncomingLimit: ", user->incominglimit);
 ast_cli(a->fd, "%-15.15s%u\n", "InUse: ", user->inUse);
 ast_cli(a->fd, "%-15.15s%d\n", "rtptimeout: ", user->rtptimeout);
 ast_cli(a->fd, "%-15.15s%s\n", "nat: ", user->nat?"yes":"no");
 if (user->rtpmaskstr[0]) {
 ast_cli(a->fd, "%-15.15s%s\n", "rtpmask: ", user->rtpmaskstr);
 }
 ast_mutex_unlock(&user->lock);
 if (user->rtdrcount && user->rtdrinterval) {
 ast_cli(a->fd, "%-15.15s%d,%d\n", "RoundTrip: ", user->rtdrcount, user->rtdrinterval);
 }
 } else {
 ast_cli(a->fd, "User %s not found\n", a->argv[3]);
 ast_cli(a->fd, "\n");
 }
 ast_mutex_unlock(&userl.lock);

 return CLI_SUCCESS;
}

handle_cli_ooh323_show_users()

static char* handle_cli_ooh323_show_users ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 3424 of file chan_ooh323.c.

References ast_cli_args::argc, ast_cli(), ast_format_cap_get_names(), AST_FORMAT_CAP_NAMES_LEN, ast_mutex_lock, ast_mutex_unlock, ast_str_alloca, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, ast_cli_entry::command, ast_cli_args::fd, FORMAT1, ooh323_user::lock, ast_user_list::lock, NULL, RESULT_SUCCESS, ast_cli_entry::usage, ooh323_pvt::user, userl, and ast_user_list::users.

{
 struct ooh323_user *prev = NULL, *user = NULL;
 struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
#define FORMAT1 "%-15.15s %-15.15s %-15.15s %-s\n"

 switch (cmd) {
 case CLI_INIT:
 e->command = "ooh323 show users";
 e->usage =
 "Usage: ooh323 show users \n"
 " Lists all known OOH323 users.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

 if (a->argc != 3)
 return CLI_SHOWUSAGE;


 ast_cli(a->fd, FORMAT1, "Username", "Accountcode", "Context", "Formats");

 ast_mutex_lock(&userl.lock);
 user = userl.users;
 while(user)
 {
 ast_mutex_lock(&user->lock);
 ast_cli(a->fd, FORMAT1, user->name,
 user->accountcode, user->context,
 ast_format_cap_get_names(user->cap, &codec_buf));
 prev = user;
 user = user->next;
 ast_mutex_unlock(&prev->lock);

 }
 ast_mutex_unlock(&userl.lock);
#undef FORMAT1
 return RESULT_SUCCESS;

}

load_module()

static int load_module ( void  )

static

Definition at line 3787 of file chan_ooh323.c.

References ao2_ref, ast_channel_register(), ast_cli_register_multiple, ast_debug, ast_format_cap_alloc, ast_format_cap_append, ast_format_cap_append_by_type(), AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_ulaw, ast_log, AST_MEDIA_TYPE_UNKNOWN, AST_MODULE_LOAD_DECLINE, ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, ast_register_atexit(), ast_rtp_glue_register, ast_sched_context_create(), ast_channel_tech::capabilities, ooh323_peer::e164, ooh323_peer::email, gAliasList, gBeMaster, gCallerID, gDTMFCodec, gDTMFMode, gFastStart, gGatekeeper, gInitError, gIP, gIsGateway, gLogFile, gMediaWaitForConnect, gPort, gRasGkMode, gRASIP, gTRCLVL, gTunneling, ooh323_peer::h323id, io_context_create(), ast_user_list::lock, ast_peer_list::lock, LOG_ERROR, LOG_WARNING, manufacturer, ooh323_config::mTCPPortEnd, ooh323_config::mTCPPortStart, ooh323_peer::next, NULL, onAlerting(), onCallCleared(), onCallEstablished(), onModeChanged(), onNewCallCreated(), onOutgoingCall(), onProgress(), ooconfig, ooh323_onReceivedDigit(), ooh323_onReceivedSetup(), ooh323c_set_capability(), ooh323c_start_stack_thread(), ooh323_pvt::peer, peerl, ast_peer_list::peers, reload_config(), restart_monitor(), ast_module_info::self, setup_rtp_remote(), t35countrycode, t35extensions, type, ooh323_peer::url, userl, ast_user_list::users, v6mode, vendor, and version.

Referenced by ooh323_convert_hangupcause_h323ToAsterisk().

{
 struct ooAliases * pNewAlias = NULL;
 struct ooh323_peer *peer = NULL;
 OOH225MsgCallbacks h225Callbacks = {0, 0, 0, 0};

 OOH323CALLBACKS h323Callbacks = {
 .onNewCallCreated = onNewCallCreated,
 .onAlerting = onAlerting,
 .onProgress = onProgress,
 .onIncomingCall = NULL,
 .onOutgoingCall = onOutgoingCall,
 .onCallEstablished = onCallEstablished,
 .onCallCleared = onCallCleared,
 .openLogicalChannels = NULL,
 .onReceivedDTMF = ooh323_onReceivedDigit,
 .onModeChanged = onModeChanged,
 .onMediaChanged = (cb_OnMediaChanged) setup_rtp_remote,
 };
 if (!(gCap = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT))) {
 return AST_MODULE_LOAD_DECLINE;
 }
 if (!(ooh323_tech.capabilities = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT))) {
 ao2_ref(gCap, -1);
 gCap = NULL;
 return AST_MODULE_LOAD_DECLINE;
 }
 ast_format_cap_append(gCap, ast_format_ulaw, 0);
 ast_format_cap_append_by_type(ooh323_tech.capabilities, AST_MEDIA_TYPE_UNKNOWN);

 myself = ast_module_info->self;

 h225Callbacks.onReceivedSetup = &ooh323_onReceivedSetup;

 userl.users = NULL;
 ast_mutex_init(&userl.lock);
 peerl.peers = NULL;
 ast_mutex_init(&peerl.lock);

#if 0
 ast_register_atexit(&ast_ooh323c_exit);
#endif

 if (!(sched = ast_sched_context_create())) {
 ast_log(LOG_WARNING, "Unable to create schedule context\n");
 }
 if (!(io = io_context_create())) {
 ast_log(LOG_WARNING, "Unable to create I/O context\n");
 }


 if (!reload_config(0)) {

 /* fire up the H.323 Endpoint */
 if (OO_OK != ooH323EpInitialize(OO_CALLMODE_AUDIOCALL, gLogFile, gInitError, sizeof(gInitError))) {
 ast_log(LOG_ERROR, "Failed to initialize OOH323 endpoint: %s"
 "OOH323 Disabled\n", gInitError);
 ao2_ref(gCap, -1);
 gCap = NULL;
 ao2_ref(ooh323_tech.capabilities, -1);
 ooh323_tech.capabilities = NULL;
 return AST_MODULE_LOAD_DECLINE;
 }

 /* Make sure we can register our OOH323 channel type */
 if (ast_channel_register(&ooh323_tech)) {
 ast_log(LOG_ERROR, "Unable to register channel class %s\n", type);
 ao2_ref(gCap, -1);
 gCap = NULL;
 ao2_ref(ooh323_tech.capabilities, -1);
 ooh323_tech.capabilities = NULL;
 return AST_MODULE_LOAD_DECLINE;
 }
 ast_rtp_glue_register(&ooh323_rtp);
 ast_cli_register_multiple(cli_ooh323, sizeof(cli_ooh323) / sizeof(struct ast_cli_entry));

 if (gIsGateway)
 ooH323EpSetAsGateway();

 ooH323EpSetVersionInfo(t35countrycode, t35extensions, manufacturer,
 vendor, version);
 ooH323EpDisableAutoAnswer();
 ooH323EpSetH225MsgCallbacks(h225Callbacks);
 ooH323EpSetTraceLevel(gTRCLVL);
 ooH323EpSetLocalAddress(gIP, gPort);
 if (v6mode) {
 ast_debug(1, "OOH323 channel is in IP6 mode\n");
 }
 ooH323EpSetCallerID(gCallerID);

 if(ooH323EpSetTCPPortRange(ooconfig.mTCPPortStart, ooconfig.mTCPPortEnd) == OO_FAILED) {
 ast_log(LOG_ERROR, "h225portrange: Failed to set range\n");
 }

 /* Set aliases if any */
 for (pNewAlias = gAliasList; pNewAlias; pNewAlias = pNewAlias->next) {
 switch (pNewAlias->type) {
 case T_H225AliasAddress_h323_ID:
 ooH323EpAddAliasH323ID(pNewAlias->value);
 break;
 case T_H225AliasAddress_dialedDigits:
 ooH323EpAddAliasDialedDigits(pNewAlias->value);
 break;
 case T_H225AliasAddress_email_ID:
 ooH323EpAddAliasEmailID(pNewAlias->value);
 break;
 default:
 ;
 }
 }

 ast_mutex_lock(&peerl.lock);
 peer = peerl.peers;
 while (peer) {
 if(peer->h323id) ooH323EpAddAliasH323ID(peer->h323id);
 if(peer->email) ooH323EpAddAliasEmailID(peer->email);
 if(peer->e164) ooH323EpAddAliasDialedDigits(peer->e164);
 if(peer->url) ooH323EpAddAliasURLID(peer->url);
 peer = peer->next;
 }
 ast_mutex_unlock(&peerl.lock);


 if (gMediaWaitForConnect)
 ooH323EpEnableMediaWaitForConnect();
 else
 ooH323EpDisableMediaWaitForConnect();

 /* Fast start and tunneling options */
 if (gFastStart)
 ooH323EpEnableFastStart();
 else
 ooH323EpDisableFastStart();

 if (!gTunneling)
 ooH323EpDisableH245Tunneling();

 if (gBeMaster)
 ooH323EpTryBeMaster(1);

 ooH323EpEnableManualRingback();

 /* Gatekeeper */
 if (gRasGkMode == RasUseSpecificGatekeeper)
 ooGkClientInit(gRasGkMode, gGatekeeper, gRASIP, 0);
 else if (gRasGkMode == RasDiscoverGatekeeper)
 ooGkClientInit(gRasGkMode, 0, gRASIP, 0);

 /* Register callbacks */
 ooH323EpSetH323Callbacks(h323Callbacks);

 /* Add endpoint capabilities */
 if (ooh323c_set_capability(gCap, gDTMFMode, gDTMFCodec) < 0) {
 ast_log(LOG_ERROR, "Capabilities failure for OOH323. OOH323 Disabled.\n");
 ao2_ref(gCap, -1);
 gCap = NULL;
 ao2_ref(ooh323_tech.capabilities, -1);
 ooh323_tech.capabilities = NULL;
 return 1;
 }

 /* Create H.323 listener */
 if (ooCreateH323Listener() != OO_OK) {
 ast_log(LOG_ERROR, "OOH323 Listener Creation failure. "
 "OOH323 DISABLED\n");

 ooH323EpDestroy();
 ao2_ref(gCap, -1);
 gCap = NULL;
 ao2_ref(ooh323_tech.capabilities, -1);
 ooh323_tech.capabilities = NULL;
 return 1;
 }

 if (ooh323c_start_stack_thread() < 0) {
 ast_log(LOG_ERROR, "Failed to start OOH323 stack thread. "
 "OOH323 DISABLED\n");
 ooH323EpDestroy();
 ao2_ref(gCap, -1);
 gCap = NULL;
 ao2_ref(ooh323_tech.capabilities, -1);
 ooh323_tech.capabilities = NULL;
 return 1;
 }
 /* And start the monitor for the first time */
 restart_monitor();
 } else {
 ast_log(LOG_ERROR, "Can't load ooh323 config file, OOH323 Disabled\n");
 return AST_MODULE_LOAD_DECLINE;
 }

 return 0;
}

onAlerting()

int onAlerting

(

ooCallData *

call

)

Definition at line 1682 of file chan_ooh323.c.

References ast_channel_queue_connected_line_update(), ast_channel_trylock, ast_channel_unlock, AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER, AST_CONTROL_RINGING, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_party_connected_line_init(), ast_queue_control(), ast_setstate(), AST_STATE_RINGING, AST_STATE_UP, ast_verb, c, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ast_party_connected_line::id, ast_set_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, ast_party_id::name, ast_set_party_id::name, NULL, ooh323_pvt::owner, ast_party_connected_line::source, ast_party_name::str, and ast_party_name::valid.

Referenced by load_module().

{
 struct ooh323_pvt *p = NULL;
 struct ast_channel *c = NULL;

 if (gH323Debug)
 ast_verb(0, "--- onAlerting %s\n", call->callToken);

 p = find_call(call);

 if(!p) {
 ast_log(LOG_ERROR, "No matching call found\n");
 return -1;
 }
 ast_mutex_lock(&p->lock);
 if (!p->owner) {
 ast_mutex_unlock(&p->lock);
 ast_debug(1, "Channel has no owner\n");
 return 0;
 }
 while (p->owner && ast_channel_trylock(p->owner)) {
 ast_debug(1, "Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 }
 if (!p->owner) {
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return 0;
 }
 c = p->owner;

 if (call->remoteDisplayName) {
 struct ast_party_connected_line connected;
 struct ast_set_party_connected_line update_connected;

 memset(&update_connected, 0, sizeof(update_connected));
 update_connected.id.name = 1;
 ast_party_connected_line_init(&connected);
 connected.id.name.valid = 1;
 connected.id.name.str = (char *) call->remoteDisplayName;
 connected.source = AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER;
 ast_channel_queue_connected_line_update(c, &connected, &update_connected);
 }
 if (ast_channel_state(c) != AST_STATE_UP)
 ast_setstate(c, AST_STATE_RINGING);

 ast_queue_control(c, AST_CONTROL_RINGING);
 ast_channel_unlock(c);
 ast_mutex_unlock(&p->lock);

 if (gH323Debug)
 ast_verb(0, "+++ onAlerting %s\n", call->callToken);

 return OO_OK;
}

onCallCleared()

int onCallCleared

(

ooCallData *

call

)

Definition at line 2236 of file chan_ooh323.c.

References ast_channel_hangupcause_set(), ast_channel_softhangup_internal_flag_add(), ast_channel_tech_pvt_set(), ast_channel_trylock, ast_channel_unlock, ast_cond_signal, ast_debug, ast_module_unref, ast_mutex_lock, ast_mutex_unlock, ast_queue_hangup_with_cause(), ast_set_flag, AST_SOFTHANGUP_DEV, ast_test_flag, ast_verb, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, H323_ALREADYGONE, H323_NEEDDESTROY, ooh323_pvt::lock, NULL, ooh323c_stop_call_thread(), ooh323_pvt::owner, ooh323_pvt::rtp, ooh323_pvt::rtpcond, usecnt, and usecnt_lock.

Referenced by load_module().

{
 struct ooh323_pvt *p = NULL;
 int ownerLock = 0;

 if (gH323Debug)
 ast_verb(0, "--- onCallCleared %s \n", call->callToken);


 if ((p = find_call(call))) {
 ast_mutex_lock(&p->lock);

 while (p->owner) {
 if (ast_channel_trylock(p->owner)) {
 ooTrace(OOTRCLVLINFO, "Failed to grab lock, trying again\n");
 ast_debug(1, "Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 } else {
 ownerLock = 1; break;
 }
 }

 if (ownerLock) {
 if (!ast_test_flag(p, H323_ALREADYGONE)) {

 ast_set_flag(p, H323_ALREADYGONE);
 ast_channel_hangupcause_set(p->owner, call->q931cause);
 ast_channel_softhangup_internal_flag_add(p->owner, AST_SOFTHANGUP_DEV);
 ast_queue_hangup_with_cause(p->owner,call->q931cause);
 }
 }

 if(p->owner) {
 ast_channel_tech_pvt_set(p->owner, NULL);
 ast_channel_unlock(p->owner);
 p->owner = NULL;
 ast_module_unref(myself);
 }

 if (!p->rtp) {
 ast_cond_signal(&p->rtpcond);
 }

 ast_set_flag(p, H323_NEEDDESTROY);

 ooh323c_stop_call_thread(call);

 ast_mutex_unlock(&p->lock);
 ast_mutex_lock(&usecnt_lock);
 usecnt--;
 ast_mutex_unlock(&usecnt_lock);

 }

 if (gH323Debug)
 ast_verb(0, "+++ onCallCleared\n");

 return OO_OK;
}

onCallEstablished()

int onCallEstablished

(

ooCallData *

call

)

Definition at line 2181 of file chan_ooh323.c.

References ast_channel_publish_snapshot(), ast_channel_queue_connected_line_update(), ast_channel_trylock, ast_channel_unlock, AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER, AST_CONTROL_ANSWER, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_party_connected_line_init(), ast_queue_control(), ast_test_flag, ast_verb, c, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, H323_OUTGOING, ast_party_connected_line::id, ast_set_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, ast_party_id::name, ast_set_party_id::name, NULL, ooh323_pvt::owner, ast_party_connected_line::source, ast_party_name::str, and ast_party_name::valid.

Referenced by load_module().

{
 struct ooh323_pvt *p = NULL;

 if (gH323Debug)
 ast_verb(0, "--- onCallEstablished %s\n", call->callToken);


 if (!(p = find_call(call))) {
 ast_log(LOG_ERROR, "Failed to find a matching call.\n");
 return -1;
 }

 if(ast_test_flag(p, H323_OUTGOING)) {
 ast_mutex_lock(&p->lock);
 if (!p->owner) {
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return -1;
 }

 while (p->owner && ast_channel_trylock(p->owner)) {
 ast_debug(1, "Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 }
 if (p->owner) {
 struct ast_channel* c = p->owner;

 if (call->remoteDisplayName) {
 struct ast_party_connected_line connected;
 struct ast_set_party_connected_line update_connected;

 memset(&update_connected, 0, sizeof(update_connected));
 update_connected.id.name = 1;
 ast_party_connected_line_init(&connected);
 connected.id.name.valid = 1;
 connected.id.name.str = (char *) call->remoteDisplayName;
 connected.source = AST_CONNECTED_LINE_UPDATE_SOURCE_ANSWER;
 ast_channel_queue_connected_line_update(c, &connected, &update_connected);
 }

 ast_queue_control(c, AST_CONTROL_ANSWER);
 ast_channel_publish_snapshot(c);
 ast_channel_unlock(p->owner);
 }
 ast_mutex_unlock(&p->lock);

 }

 if (gH323Debug)
 ast_verb(0, "+++ onCallEstablished %s\n", call->callToken);

 return OO_OK;
}

onModeChanged()

void onModeChanged	(	ooCallData *	call,
		int	t38mode
	)

Definition at line 5076 of file chan_ooh323.c.

References ast_async_goto(), ast_channel_caller(), ast_channel_context(), ast_channel_exten(), ast_channel_macrocontext(), ast_channel_name(), ast_channel_trylock, ast_channel_unlock, AST_CONTROL_T38_PARAMETERS, ast_debug, ast_exists_extension(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_queue_control_data(), AST_T38_RATE_14400, AST_T38_REQUEST_NEGOTIATE, AST_T38_REQUEST_TERMINATE, ast_udptl_get_far_max_ifp(), ast_udptl_set_far_max_datagram(), ast_verb, ooh323_pvt::chmodepend, DEADLOCK_AVOIDANCE, ooh323_pvt::faxdetect, FAXDETECT_T38, ooh323_pvt::faxdetected, ooh323_pvt::faxmode, find_call(), gH323Debug, ast_party_caller::id, ooh323_pvt::lock, LOG_ERROR, LOG_NOTICE, ast_control_t38_parameters::max_ifp, NULL, ast_party_id::number, ooh323_pvt::owner, pbx_builtin_setvar_helper(), ast_control_t38_parameters::rate, ast_control_t38_parameters::request_response, S_COR, S_OR, ast_party_number::str, T38_ENABLED, ooh323_pvt::t38_init, ooh323_pvt::t38support, ooh323_pvt::udptl, ast_party_number::valid, and ast_control_t38_parameters::version.

Referenced by load_module().

 {
 struct ooh323_pvt *p;

 p = find_call(call);
 if (!p) {
 ast_log(LOG_ERROR, "No matching call found for %s\n", call->callToken);
 return;
 }

 ast_mutex_lock(&p->lock);

 if (gH323Debug)
 ast_debug(1, "change mode to %d for %s\n", t38mode, call->callToken);

 if (t38mode == p->faxmode) {
 if (gH323Debug)
 ast_debug(1, "mode for %s is already %d\n", call->callToken,
 t38mode);
 p->chmodepend = 0;
 ast_mutex_unlock(&p->lock);
 return;
 }

 if (p->owner) {
 while (p->owner && ast_channel_trylock(p->owner)) {
 ast_debug(1,"Failed to grab lock, trying again\n");
 DEADLOCK_AVOIDANCE(&p->lock);
 }
 if (!p->owner) {
 p->chmodepend = 0;
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return;
 }
 } else {
 p->chmodepend = 0;
 ast_mutex_unlock(&p->lock);
 ast_log(LOG_ERROR, "Channel has no owner\n");
 return;
 }

 if (t38mode) {


 if (p->t38support == T38_ENABLED) {
 struct ast_control_t38_parameters parameters = { .request_response = 0 };

 if ((p->faxdetect & FAXDETECT_T38) && !p->faxdetected) {
 const char *target_context;
 ast_debug(1, "* Detected T.38 Request\n");
 target_context = S_OR(ast_channel_macrocontext(p->owner), ast_channel_context(p->owner));
 if ((strcmp(ast_channel_exten(p->owner), "fax")) &&
 (ast_exists_extension(p->owner, target_context, "fax", 1,
 S_COR(ast_channel_caller(p->owner)->id.number.valid, ast_channel_caller(p->owner)->id.number.str, NULL)))) {
 ast_verb(2, "Redirecting '%s' to fax extension due to CNG detection\n", ast_channel_name(p->owner));
 pbx_builtin_setvar_helper(p->owner, "FAXEXTEN", ast_channel_exten(p->owner));
 if (ast_async_goto(p->owner, target_context, "fax", 1)) {
 ast_log(LOG_NOTICE, "Failed to async goto '%s' into fax of '%s'\n", ast_channel_name(p->owner),target_context);
 }
 }
 p->faxdetected = 1;
 }

/* AST_T38_CONTROL mode */

 parameters.request_response = AST_T38_REQUEST_NEGOTIATE;
 if (call->T38FarMaxDatagram) {
 ast_udptl_set_far_max_datagram(p->udptl, call->T38FarMaxDatagram);
 } else {
 ast_udptl_set_far_max_datagram(p->udptl, 144);
 }
 if (call->T38Version) {
 parameters.version = call->T38Version;
 }
 parameters.max_ifp = ast_udptl_get_far_max_ifp(p->udptl);
 parameters.rate = AST_T38_RATE_14400;
 ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS,
 &parameters, sizeof(parameters));
 p->faxmode = 1;


 }
 } else {
 if (p->t38support == T38_ENABLED) {
 struct ast_control_t38_parameters parameters = { .request_response = 0 };
 parameters.request_response = AST_T38_REQUEST_TERMINATE;
 parameters.max_ifp = ast_udptl_get_far_max_ifp(p->udptl);
 parameters.rate = AST_T38_RATE_14400;
 ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS,
 &parameters, sizeof(parameters));
 }
 p->faxmode = 0;
 p->faxdetected = 0;
 p->t38_init = 0;
 }

 p->chmodepend = 0;
 ast_channel_unlock(p->owner);
 ast_mutex_unlock(&p->lock);
}

onNewCallCreated()

int onNewCallCreated

(

ooCallData *

call

)

Definition at line 2089 of file chan_ooh323.c.

References ast_cond_signal, ast_format_cap_get_names(), AST_FORMAT_CAP_NAMES_LEN, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_str_alloca, ast_strlen_zero, ast_verb, ooh323_pvt::caller_dialedDigits, ooh323_pvt::caller_h323id, ooh323_pvt::callerid_name, ooh323_pvt::callerid_num, ooh323_pvt::cap, configure_local_rtp(), ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, ooh323_pvt::exten, find_call(), ooh323_pvt::g729onlyA, gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323c_set_capability_for_call(), ooh323c_start_call_thread(), ooh323_pvt::rtpcond, ooh323_pvt::t38support, and ooh323_pvt::username.

Referenced by load_module().

{
 struct ooh323_pvt *p = NULL;
 int i = 0;

 if (gH323Debug)
 ast_verb(0, "--- onNewCallCreated %lx: %s\n", (long unsigned int) call, call->callToken);

 ast_mutex_lock(&call->Lock);
 if (ooh323c_start_call_thread(call)) {
 ast_log(LOG_ERROR,"Failed to create call thread.\n");
 ast_mutex_unlock(&call->Lock);
 return -1;
 }

 if (!strcmp(call->callType, "outgoing")) {
 p = find_call(call);
 if (!p) {
 ast_log(LOG_ERROR, "Failed to find a matching call.\n");
 ast_mutex_unlock(&call->Lock);
 return -1;
 }
 ast_mutex_lock(&p->lock);

 if (!ast_strlen_zero(p->callerid_name)) {
 ooCallSetCallerId(call, p->callerid_name);
 }
 if (!ast_strlen_zero(p->callerid_num)) {
 i = 0;
 while (*(p->callerid_num + i) != '\0') {
 if(!isdigit(*(p->callerid_num+i))) { break; }
 i++;
 }
 if(*(p->callerid_num+i) == '\0')
 ooCallSetCallingPartyNumber(call, p->callerid_num);
 else {
 if(ast_strlen_zero(p->callerid_name))
 ooCallSetCallerId(call, p->callerid_num);
 }
 }

 if (!ast_strlen_zero(p->caller_h323id))
 ooCallAddAliasH323ID(call, p->caller_h323id);

 if (!ast_strlen_zero(p->caller_dialedDigits)) {
 if (gH323Debug) {
 ast_verb(0, "Setting dialed digits %s\n", p->caller_dialedDigits);
 }
 ooCallAddAliasDialedDigits(call, p->caller_dialedDigits);
 } else if (!ast_strlen_zero(p->callerid_num)) {
 if (ooIsDailedDigit(p->callerid_num)) {
 if (gH323Debug) {
 ast_verb(0, "setting callid number %s\n", p->callerid_num);
 }
 ooCallAddAliasDialedDigits(call, p->callerid_num);
 } else if (ast_strlen_zero(p->caller_h323id)) {
 ooCallAddAliasH323ID(call, p->callerid_num);
 }
 }


 if (!ast_strlen_zero(p->exten)) {
 if (ooIsDailedDigit(p->exten)) {
 ooCallSetCalledPartyNumber(call, p->exten);
 ooCallAddRemoteAliasDialedDigits(call, p->exten);
 } else {
 ooCallAddRemoteAliasH323ID(call, p->exten);
 }
 }

 if (gH323Debug) {
 struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);

 ast_verb(0, " Outgoing call %s(%s) - Codec prefs - %s\n",
 p->username?p->username:"NULL", call->callToken,
 ast_format_cap_get_names(p->cap, &codec_buf));
 }

 ooh323c_set_capability_for_call(call, p->cap,
 p->dtmfmode, p->dtmfcodec, p->t38support, p->g729onlyA);

 configure_local_rtp(p, call);
 ast_cond_signal(&p->rtpcond);
 ast_mutex_unlock(&p->lock);
 }

 ast_mutex_unlock(&call->Lock);
 if (gH323Debug)
 ast_verb(0, "+++ onNewCallCreated %s\n", call->callToken);
 return OO_OK;
}

onOutgoingCall()

int onOutgoingCall

(

ooCallData *

call

)

Definition at line 2016 of file chan_ooh323.c.

References ast_copy_string(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero, ast_verb, ooh323_pvt::caller_dialedDigits, ooh323_pvt::caller_h323id, ooh323_pvt::callerid_name, ooh323_pvt::callerid_num, configure_local_rtp(), find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323_pvt::rtp, ooh323_pvt::rtpmask, and ooh323_pvt::rtpmaskstr.

Referenced by load_module().

{
 struct ooh323_pvt *p = NULL;
 int i = 0;

 if (gH323Debug)
 ast_verb(0, "--- onOutgoingCall %lx: %s\n", (long unsigned int) call, call->callToken);

 if (!strcmp(call->callType, "outgoing")) {
 p = find_call(call);
 if (!p) {
 ast_log(LOG_ERROR, "Failed to find a matching call.\n");
 return -1;
 }
 ast_mutex_lock(&p->lock);

 if (!ast_strlen_zero(p->callerid_name)) {
 ooCallSetCallerId(call, p->callerid_name);
 }
 if (!ast_strlen_zero(p->callerid_num)) {
 i = 0;
 while (*(p->callerid_num + i) != '\0') {
 if(!isdigit(*(p->callerid_num+i))) { break; }
 i++;
 }
 if(*(p->callerid_num+i) == '\0')
 ooCallSetCallingPartyNumber(call, p->callerid_num);
 else {
 if(!p->callerid_name)
 ooCallSetCallerId(call, p->callerid_num);
 }
 }

 if (!ast_strlen_zero(p->caller_h323id))
 ooCallAddAliasH323ID(call, p->caller_h323id);

 if (!ast_strlen_zero(p->caller_dialedDigits)) {
 if (gH323Debug) {
 ast_verb(0, "Setting dialed digits %s\n", p->caller_dialedDigits);
 }
 ooCallAddAliasDialedDigits(call, p->caller_dialedDigits);
 } else if (!ast_strlen_zero(p->