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

Include dependency graph for chan_ooh323.c:

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

◆ T38_ENABLED

#define T38_ENABLED 1

◆ 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->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 (p->rtpmask && p->rtpmaskstr[0]) {
          call->rtpMask = p->rtpmask;
          ast_mutex_lock(&call->rtpMask->lock);
          call->rtpMask->inuse++;
          ast_mutex_unlock(&call->rtpMask->lock);
          ast_copy_string(call->rtpMaskStr, p->rtpmaskstr, sizeof(call->rtpMaskStr));
       }
 
       if (!p->rtp && !configure_local_rtp(p, call)) {
          ast_mutex_unlock(&p->lock);
          return OO_FAILED;
       }
 
       ast_mutex_unlock(&p->lock);
    }
 
    if (gH323Debug)
       ast_verb(0, "+++   onOutgoingCall %s\n", call->callToken);
    return OO_OK;
 }

◆ onProgress()

int onProgress ( ooCallData * call )

Definition at line 1738 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_PROGRESS, 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, "--- onProgress %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_log(LOG_ERROR, "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_PROGRESS);
          ast_channel_unlock(c);
          ast_mutex_unlock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "+++ onProgress %s\n", call->callToken);
 
    return OO_OK;
 }

◆ ooh323_alloc()

static struct ooh323_pvt* ooh323_alloc	(	int	callref,
		char *	callToken
	)

static

Definition at line 556 of file chan_ooh323.c.

References ooh323_pvt::accountcode, ooh323_pvt::amaflags, ooh323_pvt::aniasdni, ast_calloc, ast_copy_string(), ast_format_cap_alloc, ast_format_cap_append_from_cap(), AST_FORMAT_CAP_FLAG_DEFAULT, ast_free, ast_log, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, ast_strdup, ast_verb, ooh323_pvt::call_reference, ooh323_pvt::callToken, ooh323_pvt::cap, ooh323_pvt::chmodepend, ooh323_pvt::context, ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, ooh323_pvt::faxdetect, ooh323_pvt::faxdetected, ooh323_pvt::faxmode, ooh323_pvt::flags, ooh323_pvt::g729onlyA, gAccountcode, gAMAFLAGS, gANIasDNI, gContext, gDTMFCodec, gDTMFMode, gFAXdetect, gH323Debug, gNat, gRasGkMode, gRTDRCount, gRTDRInterval, gRTPTimeout, gT38Support, H323_DISABLEGK, iflist, iflock, ooh323_pvt::lock, LOG_ERROR, ooh323_pvt::nat, ooh323_pvt::next, NULL, ooh323_pvt::rtdrcount, ooh323_pvt::rtdrinterval, ooh323_pvt::rtptimeout, and ooh323_pvt::t38support.

Referenced by ooh323_onReceivedSetup(), and ooh323_request().

 {
    struct ooh323_pvt *pvt = NULL;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_alloc\n");
    }
 
    if (!(pvt = ast_calloc(1, sizeof(*pvt)))) {
       ast_log(LOG_ERROR, "Couldn't allocate private ooh323 structure\n");
       return NULL;
    }
    if (!(pvt->cap = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT))) {
       ast_free(pvt);
       ast_log(LOG_ERROR, "Couldn't allocate private ooh323 structure\n");
       return NULL;
    }
 
    ast_mutex_init(&pvt->lock);
    ast_mutex_lock(&pvt->lock);
 
    pvt->faxmode = 0;
    pvt->chmodepend = 0;
    pvt->faxdetected = 0;
    pvt->faxdetect = gFAXdetect;
    pvt->t38support = gT38Support;
    pvt->rtptimeout = gRTPTimeout;
    pvt->nat = gNat;
    pvt->rtdrinterval = gRTDRInterval;
    pvt->rtdrcount = gRTDRCount;
    pvt->g729onlyA = g729onlyA;
 
    pvt->call_reference = callref;
    if (callToken)
       pvt->callToken = ast_strdup(callToken);
 
    /* whether to use gk for this call */
    if (gRasGkMode == RasNoGatekeeper)
       OO_SETFLAG(pvt->flags, H323_DISABLEGK);
 
    pvt->dtmfmode = gDTMFMode;
    pvt->dtmfcodec = gDTMFCodec;
    ast_copy_string(pvt->context, gContext, sizeof(pvt->context));
    ast_copy_string(pvt->accountcode, gAccountcode, sizeof(pvt->accountcode));
 
    pvt->amaflags = gAMAFLAGS;
    ast_format_cap_append_from_cap(pvt->cap, gCap, AST_MEDIA_TYPE_UNKNOWN);
 
    pvt->aniasdni = gANIasDNI;
 
    ast_mutex_unlock(&pvt->lock);
    /* Add to interface list */
    ast_mutex_lock(&iflock);
    pvt->next = iflist;
    iflist = pvt;
    ast_mutex_unlock(&iflock);
 
    if (gH323Debug) {
       ast_verb(0, "+++   ooh323_alloc\n");
    }
 
    return pvt;
 }

◆ ooh323_answer()

static int ooh323_answer ( struct ast_channel * ast )

static

Definition at line 1154 of file chan_ooh323.c.

References ooh323_pvt::alertsent, ast_channel_lock, ast_channel_name(), ast_channel_tech_pvt(), ast_channel_unlock, ast_debug, ast_free, ast_mutex_lock, ast_mutex_unlock, ast_setstate(), AST_STATE_UP, ast_strdup, ast_verb, ooh323_pvt::callToken, gH323Debug, ooh323_pvt::lock, and NULL.

 {
    struct ooh323_pvt *p = ast_channel_tech_pvt(ast);
    char *callToken = (char *)NULL;
 
    if (gH323Debug)
       ast_verb(0, "--- ooh323_answer\n");
 
    if (p) {
 
       ast_mutex_lock(&p->lock);
       callToken = (p->callToken ? ast_strdup(p->callToken) : NULL);
       if (ast_channel_state(ast) != AST_STATE_UP) {
          ast_channel_lock(ast);
          if (!p->alertsent) {
                if (gH323Debug) {
                ast_debug(1, "Sending forced ringback for %s, res = %u\n",
                   callToken, ooManualRingback(callToken));
             } else {
                   ooManualRingback(callToken);
             }
             p->alertsent = 1;
          }
          ast_setstate(ast, AST_STATE_UP);
          ast_debug(1, "ooh323_answer(%s)\n", ast_channel_name(ast));
          ast_channel_unlock(ast);
          ooAnswerCall(p->callToken);
       }
       if (callToken) {
          ast_free(callToken);
       }
       ast_mutex_unlock(&p->lock);
    }
 
    if (gH323Debug)
       ast_verb(0, "+++ ooh323_answer\n");
 
   return 0;
 }

◆ ooh323_call()

static int ooh323_call	(	struct ast_channel *	ast,
		const char *	dest,
		int	timeout
	)

static

Definition at line 990 of file chan_ooh323.c.

References ast_channel_connected(), ast_channel_name(), ast_channel_tech_pvt(), ast_channel_transfercapability(), ast_copy_string(), ast_free, ast_log, AST_MAX_EXTENSION, ast_mutex_lock, ast_mutex_unlock, ast_set_flag, AST_STATE_DOWN, AST_STATE_RESERVED, ast_strdup, ast_verb, ooh323_pvt::caller_dialedDigits, ooh323_pvt::caller_email, ooh323_pvt::caller_h323id, ooh323_pvt::caller_url, ooh323_pvt::callerid_name, ooh323_pvt::callerid_num, ooh323_pvt::callToken, ooh323_pvt::faststart, ooh323_pvt::flags, gCallerID, gH323Debug, ooh323_pvt::h245tunneling, H323_DISABLEGK, H323_OUTGOING, ooh323_pvt::host, ast_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, LOG_WARNING, name, ast_party_id::name, NULL, pbx_builtin_getvar_helper(), ooh323_pvt::port, ast_party_name::str, TRUE, and ast_party_name::valid.

 {
    struct ooh323_pvt *p = ast_channel_tech_pvt(ast);
    char destination[256];
       int res=0, i;
    const char *val = NULL;
    ooCallOptions opts = {
       .fastStart = TRUE,
       .tunneling = TRUE,
       .disableGk = TRUE,
             .callMode = OO_CALLMODE_AUDIOCALL,
             .transfercap = 0
    };
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_call- %s\n", dest);
 
 
       if ((ast_channel_state(ast) != AST_STATE_DOWN) && (ast_channel_state(ast) != AST_STATE_RESERVED)) {
       ast_log(LOG_WARNING, "ooh323_call called on %s, neither down nor "
                         "reserved\n", ast_channel_name(ast));
       return -1;
    }
    ast_mutex_lock(&p->lock);
    ast_set_flag(p, H323_OUTGOING);
    if (ast_channel_connected(ast)->id.number.valid && ast_channel_connected(ast)->id.number.str) {
       ast_free(p->callerid_num);
       p->callerid_num = ast_strdup(ast_channel_connected(ast)->id.number.str);
    }
 
    if (ast_channel_connected(ast)->id.name.valid && ast_channel_connected(ast)->id.name.str) {
       ast_free(p->callerid_name);
       p->callerid_name = ast_strdup(ast_channel_connected(ast)->id.name.str);
    } else if (ast_channel_connected(ast)->id.number.valid && ast_channel_connected(ast)->id.number.str) {
       ast_free(p->callerid_name);
       p->callerid_name = ast_strdup(ast_channel_connected(ast)->id.number.str);
    } else {
       ast_channel_connected(ast)->id.name.valid = 1;
       ast_free(ast_channel_connected(ast)->id.name.str);
       ast_channel_connected(ast)->id.name.str = ast_strdup(gCallerID);
       ast_free(p->callerid_name);
       p->callerid_name = ast_strdup(ast_channel_connected(ast)->id.name.str);
    }
 
    /* Retrieve vars */
 
 
    if ((val = pbx_builtin_getvar_helper(ast, "CALLER_H323ID"))) {
       ast_copy_string(p->caller_h323id, val, sizeof(p->caller_h323id));
    }
 
    if ((val = pbx_builtin_getvar_helper(ast, "CALLER_H323DIALEDDIGITS"))) {
       ast_copy_string(p->caller_dialedDigits, val, sizeof(p->caller_dialedDigits));
             if(!p->callerid_num)
          p->callerid_num = ast_strdup(val);
    }
 
    if ((val = pbx_builtin_getvar_helper(ast, "CALLER_H323EMAIL"))) {
       ast_copy_string(p->caller_email, val, sizeof(p->caller_email));
    }
 
    if ((val = pbx_builtin_getvar_helper(ast, "CALLER_H323URL"))) {
       ast_copy_string(p->caller_url, val, sizeof(p->caller_url));
    }
 
    if (p->host && p->port != 0)
       snprintf(destination, sizeof(destination), "%s:%d", p->host, p->port);
    else if (p->host)
       snprintf(destination, sizeof(destination), "%s", p->host);
    else
       ast_copy_string(destination, dest, sizeof(destination));
 
    destination[sizeof(destination)-1]='\0';
 
    opts.transfercap = ast_channel_transfercapability(ast);
    opts.fastStart = p->faststart;
    opts.tunneling = p->h245tunneling;
 
    for (i=0;i<480 && !isRunning(p->callToken);i++) usleep(12000);
 
    if(OO_TESTFLAG(p->flags, H323_DISABLEGK)) {
       res = ooRunCall(destination, p->callToken, AST_MAX_EXTENSION, &opts);
    } else {
       res = ooRunCall(destination, p->callToken, AST_MAX_EXTENSION, NULL);
    }
 
    ast_mutex_unlock(&p->lock);
    if (res != OO_OK) {
       ast_log(LOG_ERROR, "Failed to make call\n");
             return -1; /* ToDO: cleanup */
    }
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_call\n");
 
   return 0;
 }

◆ ooh323_convert_hangupcause_asteriskToH323()

int ooh323_convert_hangupcause_asteriskToH323 ( int cause )

Definition at line 5179 of file chan_ooh323.c.

References AST_CAUSE_BEARERCAPABILITY_NOTAVAIL, AST_CAUSE_BUSY, AST_CAUSE_CALL_REJECTED, AST_CAUSE_CONGESTION, AST_CAUSE_FAILURE, AST_CAUSE_NO_ANSWER, AST_CAUSE_NORMAL, and AST_CAUSE_UNALLOCATED.

Referenced by ooh323_hangup(), and ooh323_onReceivedSetup().

 {
    switch (cause) {
    case AST_CAUSE_CALL_REJECTED:
       return OO_REASON_REMOTE_REJECTED;
    case AST_CAUSE_UNALLOCATED:
       return OO_REASON_NOUSER;
    case AST_CAUSE_BUSY:
       return OO_REASON_REMOTE_BUSY;
    case AST_CAUSE_BEARERCAPABILITY_NOTAVAIL:
       return OO_REASON_NOCOMMON_CAPABILITIES;
    case AST_CAUSE_CONGESTION:
       return OO_REASON_REMOTE_BUSY;
    case AST_CAUSE_NO_ANSWER:
       return OO_REASON_REMOTE_NOANSWER;
    case AST_CAUSE_NORMAL:
       return OO_REASON_REMOTE_CLEARED;
    case AST_CAUSE_FAILURE:
    default:
       return OO_REASON_UNKNOWN;
    }
 
    return 0;
 
 
 }

◆ ooh323_convert_hangupcause_h323ToAsterisk()

int ooh323_convert_hangupcause_h323ToAsterisk ( int cause )

Definition at line 5206 of file chan_ooh323.c.

References AST_CAUSE_BEARERCAPABILITY_NOTAVAIL, AST_CAUSE_BUSY, AST_CAUSE_CALL_REJECTED, AST_CAUSE_CONGESTION, AST_CAUSE_FAILURE, AST_CAUSE_NO_ANSWER, AST_CAUSE_NORMAL, AST_CAUSE_UNALLOCATED, AST_MODFLAG_LOAD_ORDER, AST_MODPRI_CHANNEL_DRIVER, AST_MODULE_INFO(), AST_MODULE_SUPPORT_EXTENDED, ASTERISK_GPL_KEY, load_module(), reload(), reload_module(), and unload_module().

 {
    switch (cause) {
    case OO_REASON_REMOTE_REJECTED:
       return AST_CAUSE_CALL_REJECTED;
    case OO_REASON_NOUSER:
       return AST_CAUSE_UNALLOCATED;
    case OO_REASON_REMOTE_BUSY:
    case OO_REASON_LOCAL_BUSY:
       return AST_CAUSE_BUSY;
    case OO_REASON_NOCOMMON_CAPABILITIES:  /* No codecs approved */
       return AST_CAUSE_BEARERCAPABILITY_NOTAVAIL;
    case OO_REASON_REMOTE_CONGESTED:
    case OO_REASON_LOCAL_CONGESTED:
       return AST_CAUSE_CONGESTION;
    case OO_REASON_REMOTE_NOANSWER:
       return AST_CAUSE_NO_ANSWER;
    case OO_REASON_UNKNOWN:
    case OO_REASON_INVALIDMESSAGE:
    case OO_REASON_TRANSPORTFAILURE:
       return AST_CAUSE_FAILURE;
    case OO_REASON_REMOTE_CLEARED:
       return AST_CAUSE_NORMAL;
    default:
       return AST_CAUSE_NORMAL;
    }
    /* Never reached */
    return 0;
 }

◆ ooh323_convertAsteriskCapToH323Cap()

int ooh323_convertAsteriskCapToH323Cap ( struct ast_format * format )

Definition at line 4506 of file chan_ooh323.c.

References ast_format_alaw, ast_format_cmp(), AST_FORMAT_CMP_EQUAL, ast_format_g723, ast_format_g726, ast_format_g726_aal2, ast_format_g729, ast_format_get_name(), ast_format_gsm, ast_format_h263, ast_format_speex, ast_format_ulaw, ast_log, and LOG_NOTICE.

Referenced by configure_local_rtp(), and ooh323_set_rtp_peer().

 {
    if (ast_format_cmp(format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL) {
       return OO_G711ULAW64K;
    } else if (ast_format_cmp(format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL) {
       return OO_G711ALAW64K;
    } else if (ast_format_cmp(format, ast_format_gsm) == AST_FORMAT_CMP_EQUAL) {
       return OO_GSMFULLRATE;
    } else if (ast_format_cmp(format, ast_format_speex) == AST_FORMAT_CMP_EQUAL) {
       return OO_SPEEX;
    } else if (ast_format_cmp(format, ast_format_g729) == AST_FORMAT_CMP_EQUAL) {
       return OO_G729A;
    } else if (ast_format_cmp(format, ast_format_g726) == AST_FORMAT_CMP_EQUAL) {
       return OO_G726;
    } else if (ast_format_cmp(format, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL) {
       return OO_G726AAL2;
    } else if (ast_format_cmp(format, ast_format_g723) == AST_FORMAT_CMP_EQUAL) {
       return OO_G7231;
    } else if (ast_format_cmp(format, ast_format_h263) == AST_FORMAT_CMP_EQUAL) {
       return OO_H263VIDEO;
    } else {
       ast_log(LOG_NOTICE, "Don't know how to deal with mode %s\n", ast_format_get_name(format));
       return -1;
    }
 }

◆ ooh323_delete_peer()

void ooh323_delete_peer ( struct ooh323_peer * peer )

Definition at line 2328 of file chan_ooh323.c.

References ao2_cleanup, ast_free, ast_mutex_lock, ast_mutex_unlock, ast_verb, ooh323_peer::cap, ooh323_peer::e164, ooh323_peer::email, gH323Debug, ooh323_peer::h323id, ast_peer_list::lock, ooh323_peer::next, NULL, peerl, ast_peer_list::peers, and ooh323_peer::url.

Referenced by build_peer().

 {
    struct ooh323_peer *prev = NULL, *cur = NULL;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_delete_peer\n");
 
    if (peer) {
       cur = peerl.peers;
       ast_mutex_lock(&peerl.lock);
       while(cur) {
          if(cur==peer) break;
          prev = cur;
          cur = cur->next;
       }
 
       if (cur) {
          if(prev)
             prev->next = cur->next;
          else
             peerl.peers = cur->next;
          }
       ast_mutex_unlock(&peerl.lock);
 
       ast_free(peer->h323id);
       ast_free(peer->email);
       ast_free(peer->url);
       ast_free(peer->e164);
 
       ao2_cleanup(peer->cap);
       ast_free(peer);
    }
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_delete_peer\n");
 
 }

◆ ooh323_destroy()

int ooh323_destroy ( struct ooh323_pvt * p )

Definition at line 4117 of file chan_ooh323.c.

References ao2_cleanup, ast_channel_name(), ast_channel_tech_pvt_set(), ast_channel_trylock, ast_channel_unlock, ast_debug, ast_dsp_free(), ast_free, ast_module_unref, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_destroy(), ast_rtp_instance_stop(), ast_test_flag, ast_udptl_destroy(), ast_verb, ooh323_pvt::callerid_name, DEADLOCK_AVOIDANCE, find_user(), gH323Debug, H323_OUTGOING, iflist, ooh323_user::inUse, ooh323_user::lock, ooh323_pvt::next, NULL, and ooh323_pvt::username.

Referenced by do_monitor(), ooh323_request(), and unload_module().

 {
    /* NOTE: Assumes iflock already acquired */
    struct ooh323_pvt *prev = NULL, *cur = NULL;
    struct ooh323_user *user = NULL;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_destroy \n");
 
       if (p)
          ast_verb(0, " Destroying %s\n", p->username);
    }
 
    cur = iflist;
    while (cur) {
       if (cur == p) { break; }
       prev = cur;
       cur = cur->next;
    }
 
    if (cur) {
       ast_mutex_lock(&cur->lock);
       if (prev)
          prev->next = cur->next;
       else
          iflist = cur->next;
 
       if (cur->callToken) {
          if (gH323Debug)
             ast_verb(0, " Destroying %s\n", cur->callToken);
          ast_free(cur->callToken);
          cur->callToken = 0;
       }
 
       if (cur->username) {
          ast_free(cur->username);
          cur->username = 0;
       }
 
       if (cur->host) {
          ast_free(cur->host);
          cur->host = 0;
       }
 
       if (cur->callerid_name) {
          ast_free(cur->callerid_name);
          cur->callerid_name = 0;
       }
 
       if (cur->callerid_num) {
          ast_free(cur->callerid_num);
          cur->callerid_num = 0;
       }
 
       if (cur->rtp) {
          ast_rtp_instance_stop(cur->rtp);
          ast_rtp_instance_destroy(cur->rtp);
          cur->rtp = NULL;
       }
 
       if (cur->udptl) {
          ast_udptl_destroy(cur->udptl);
          cur->udptl = NULL;
       }
 
       /* Unlink us from the owner if we have one */
       if (cur->owner) {
                while(ast_channel_trylock(cur->owner)) {
                      ast_debug(1, "Failed to grab lock, trying again\n");
             DEADLOCK_AVOIDANCE(&cur->lock);
                }
          ast_debug(1, "Detaching from %s\n", ast_channel_name(cur->owner));
          ast_channel_tech_pvt_set(cur->owner, NULL);
          ast_channel_unlock(cur->owner);
          cur->owner = NULL;
          ast_module_unref(myself);
       }
 
       if (cur->vad) {
          ast_dsp_free(cur->vad);
          cur->vad = NULL;
       }
 
 /* decrement user/peer count */
 
       if(!ast_test_flag(cur, H323_OUTGOING)) {
     if (cur->neighbor.user) {
      user = find_user(p->callerid_name, cur->neighbor.user);
      if(user && user->inUse > 0) {
       ast_mutex_lock(&user->lock);
       user->inUse--;
       ast_mutex_unlock(&user->lock);
      }
      ast_free(cur->neighbor.user);
     }
       } else {
 /* outgoing limit decrement here !!! */
       }
 
       ast_mutex_unlock(&cur->lock);
       ast_mutex_destroy(&cur->lock);
       ao2_cleanup(cur->writeformat);
       ao2_cleanup(cur->readformat);
       ao2_cleanup(cur->cap);
       ast_free(cur);
    }
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_destroy\n");
 
    return 0;
 }

◆ ooh323_digit_begin()

static int ooh323_digit_begin	(	struct ast_channel *	ast,
		char	digit
	)

static

Definition at line 928 of file chan_ooh323.c.

References ast_channel_tech_pvt(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_dtmf_begin(), ast_verb, ooh323_pvt::callToken, digit, ooh323_pvt::dtmfmode, gH323Debug, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_Q931, H323_DTMF_RFC2833, ooh323_pvt::lock, LOG_ERROR, and ooh323_pvt::rtp.

 {
    char dtmf[2];
    struct ooh323_pvt *p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan);
    int res = 0;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_digit_begin\n");
 
    if (!p) {
       ast_log(LOG_ERROR, "No private structure for call\n");
       return -1;
    }
    ast_mutex_lock(&p->lock);
 
    if (p->rtp && ((p->dtmfmode & H323_DTMF_RFC2833) || (p->dtmfmode & H323_DTMF_CISCO))) {
       ast_rtp_instance_dtmf_begin(p->rtp, digit);
    } else if (((p->dtmfmode & H323_DTMF_Q931) ||
                    (p->dtmfmode & H323_DTMF_H245ALPHANUMERIC) ||
                    (p->dtmfmode & H323_DTMF_H245SIGNAL))) {
       dtmf[0] = digit;
       dtmf[1] = '\0';
       ooSendDTMFDigit(p->callToken, dtmf);
    } else if (p->dtmfmode & H323_DTMF_INBAND) {
       res = -1; // tell Asterisk to generate inband indications
    }
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug) {
       ast_verb(0, "+++   ooh323_digit_begin, res = %d\n", res);
    }
    return res;
 }

◆ ooh323_digit_end()

static int ooh323_digit_end	(	struct ast_channel *	ast,
		char	digit,
		unsigned int	duration
	)

static

Definition at line 962 of file chan_ooh323.c.

References ast_channel_tech_pvt(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_dtmf_end(), ast_verb, ooh323_pvt::dtmfmode, gH323Debug, H323_DTMF_CISCO, H323_DTMF_INBAND, H323_DTMF_RFC2833, ooh323_pvt::lock, LOG_ERROR, and ooh323_pvt::rtp.

 {
    struct ooh323_pvt *p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan);
    int res = 0;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_digit_end\n");
 
    if (!p) {
       ast_log(LOG_ERROR, "No private structure for call\n");
       return -1;
    }
    ast_mutex_lock(&p->lock);
    if (p->rtp && ((p->dtmfmode & H323_DTMF_RFC2833) || (p->dtmfmode & H323_DTMF_CISCO)) ) {
       ast_rtp_instance_dtmf_end(p->rtp, digit);
    } else if(p->dtmfmode & H323_DTMF_INBAND) {
       res = -1; // tell Asterisk to stop inband indications
    }
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug) {
       ast_verb(0, "+++   ooh323_digit_end, res = %d\n", res);
    }
    return res;
 }

◆ ooh323_do_reload()

static int ooh323_do_reload ( void )

static

Definition at line 2705 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, ooh323_peer::e164, ooh323_peer::email, gAliasList, gGatekeeper, gH323Debug, gH323ep, gRasGkMode, gRASIP, ooh323_peer::h323id, ast_peer_list::lock, ooh323_peer::next, NULL, ooh323_pvt::peer, peerl, ast_peer_list::peers, reload_config(), and ooh323_peer::url.

Referenced by do_monitor().

 {
    struct ooAliases * pNewAlias = NULL;
    struct ooh323_peer *peer = NULL;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_do_reload\n");
    }
 
    /* Gatekeeper */
    if (gH323ep.gkClient) {
       ooGkClientDestroy();
    }
 
       reload_config(1);
 
    /* Gatekeeper */
    if (gRasGkMode == RasUseSpecificGatekeeper ||
       gRasGkMode == RasDiscoverGatekeeper) {
       ooGkClientInit(gRasGkMode, (gRasGkMode == RasUseSpecificGatekeeper) ?
                         gGatekeeper : 0, gRASIP, 0);
       ooGkClientStart(gH323ep.gkClient);
    }
 
    /* Set aliases if any */
    if (gH323Debug) {
       ast_verb(0, "updating local aliases\n");
    }
 
    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 (gH323Debug) {
       ast_verb(0, "+++   ooh323_do_reload\n");
    }
 
    return 0;
 }

◆ ooh323_fixup()

static int ooh323_fixup	(	struct ast_channel *	oldchan,
		struct ast_channel *	newchan
	)

static

Definition at line 1522 of file chan_ooh323.c.

References ast_channel_tech_pvt(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_verb, gH323Debug, ooh323_pvt::lock, LOG_WARNING, and ooh323_pvt::owner.

 {
    struct ooh323_pvt *p = ast_channel_tech_pvt(newchan);
 
    if (!p) return -1;
 
    if (gH323Debug)
       ast_verb(0, "--- ooh323c ooh323_fixup\n");
 
    ast_mutex_lock(&p->lock);
    if (p->owner != oldchan) {
       ast_log(LOG_WARNING, "Old channel wasn't %p but was %p\n", oldchan, p->owner);
       ast_mutex_unlock(&p->lock);
       return -1;
    }
 
    if (p->owner == oldchan) {
       p->owner = newchan;
    } else {
       p->owner = oldchan;
    }
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "+++ ooh323c ooh323_fixup \n");
 
    return 0;
 }

◆ ooh323_get_codec()

static void ooh323_get_codec	(	struct ast_channel *	chan,
		struct ast_format_cap *	result
	)

static

Definition at line 4420 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_nativeformats(), ast_channel_tech_pvt(), ast_format_cap_append_from_cap(), ast_format_cap_count(), AST_MEDIA_TYPE_UNKNOWN, ast_verb, ooh323_pvt::cap, and gH323Debug.

 {
    struct ooh323_pvt *p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan);
    if (gH323Debug) {
       ast_verb(0, "+++ ooh323  get_codec, %s\n", ast_channel_name(chan));
    }
 
    if (p) {
       if (ast_format_cap_count(ast_channel_nativeformats(chan))) {
          ast_format_cap_append_from_cap(result, ast_channel_nativeformats(chan), AST_MEDIA_TYPE_UNKNOWN);
       } else if (ast_format_cap_count(p->cap)) {
          ast_format_cap_append_from_cap(result, p->cap, AST_MEDIA_TYPE_UNKNOWN);
       }
    }
 
    if (gH323Debug) {
       ast_verb(0, "--- ooh323  get_codec, %s\n", ast_channel_name(chan));
    }
 }

◆ ooh323_get_rtp_peer()

static enum ast_rtp_glue_result ooh323_get_rtp_peer	(	struct ast_channel *	chan,
		struct ast_rtp_instance **	rtp
	)

static

Definition at line 4442 of file chan_ooh323.c.

References ao2_ref, ast_channel_name(), ast_channel_tech_pvt(), AST_JB_FORCED, AST_RTP_GLUE_RESULT_FORBID, AST_RTP_GLUE_RESULT_LOCAL, AST_RTP_GLUE_RESULT_REMOTE, ast_rtp_instance_get_remote_address, ast_sockaddr_port, ast_sockaddr_stringify_addr(), AST_STATE_UP, ast_test_flag, ast_verb, ooh323_pvt::directrtp, ooh323_pvt::earlydirect, gH323Debug, global_jbconf, NULL, and ooh323_pvt::rtp.

 {
    struct ooh323_pvt *p = NULL;
    enum ast_rtp_glue_result res = AST_RTP_GLUE_RESULT_LOCAL;
    struct ast_sockaddr tmp;
 
    if (gH323Debug) {
       ast_verb(0, "+++ ooh323  get_rtp_peer \n");
    }
 
    if (!(p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan)))
       return AST_RTP_GLUE_RESULT_FORBID;
 
    if (!(p->rtp)) {
       return AST_RTP_GLUE_RESULT_FORBID;
    }
 
    *rtp = p->rtp ? ao2_ref(p->rtp, +1), p->rtp : NULL;
 
    /* there must be checking of directmedia setting */
 
    if ((ast_channel_state(chan) != AST_STATE_UP && !p->earlydirect) || !p->directrtp) {
       res = AST_RTP_GLUE_RESULT_LOCAL;
    } else {
       res = AST_RTP_GLUE_RESULT_REMOTE;
    }
 
    if (ast_test_flag(&global_jbconf, AST_JB_FORCED)) {
       res = AST_RTP_GLUE_RESULT_FORBID;
    }
 
    ast_rtp_instance_get_remote_address(*rtp, &tmp);
    if (gH323Debug) {
       ast_verb(0, "ooh323_get_rtp_peer  %s -> %s:%d, %u\n", ast_channel_name(chan), ast_sockaddr_stringify_addr(&tmp),
                   ast_sockaddr_port(&tmp), res);
    }
    if (gH323Debug) {
       ast_verb(0, "--- ooh323  get_rtp_peer, res = %d\n", (int) res);
    }
 
    return res;
 }

◆ ooh323_get_vrtp_peer()

static enum ast_rtp_glue_result ooh323_get_vrtp_peer	(	struct ast_channel *	chan,
		struct ast_rtp_instance **	rtp
	)

static

Definition at line 4485 of file chan_ooh323.c.

References ao2_ref, ast_channel_tech_pvt(), AST_RTP_GLUE_RESULT_FORBID, AST_RTP_GLUE_RESULT_LOCAL, NULL, ooh323_pvt::rtp, and ooh323_pvt::vrtp.

 {
    struct ooh323_pvt *p = NULL;
    enum ast_rtp_glue_result res = AST_RTP_GLUE_RESULT_LOCAL;
 
    if (!(p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan)))
       return AST_RTP_GLUE_RESULT_FORBID;
 
    if (!(p->rtp)) {
       return AST_RTP_GLUE_RESULT_FORBID;
    }
 
    *rtp = p->vrtp ? ao2_ref(p->vrtp, +1), p->vrtp : NULL;
 
    /* there must check of supporting video per call */
 
    res = AST_RTP_GLUE_RESULT_FORBID;
 
    return res;
 }

◆ ooh323_hangup()

static int ooh323_hangup ( struct ast_channel * ast )

static

Definition at line 1087 of file chan_ooh323.c.

References AST_CAUSE_CALL_REJECTED, AST_CAUSE_NO_ANSWER, AST_CAUSE_NORMAL_CIRCUIT_CONGESTION, AST_CAUSE_NORMAL_CLEARING, AST_CAUSE_REQUESTED_CHAN_UNAVAIL, AST_CAUSE_USER_BUSY, ast_channel_hangupcause(), ast_channel_tech_pvt(), ast_channel_tech_pvt_set(), ast_debug, ast_module_unref, ast_mutex_lock, ast_mutex_unlock, ast_set_flag, ast_test_flag, ast_update_use_count(), ast_verb, ooh323_pvt::callToken, gH323Debug, H323_ALREADYGONE, H323_NEEDDESTROY, ooh323_pvt::lock, NULL, ooh323_convert_hangupcause_asteriskToH323(), ooh323_pvt::owner, pbx_builtin_getvar_helper(), usecnt, usecnt_lock, and ooh323_pvt::username.

 {
    struct ooh323_pvt *p = ast_channel_tech_pvt(ast);
       int q931cause = AST_CAUSE_NORMAL_CLEARING;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_hangup\n");
 
    if (p) {
       ast_mutex_lock(&p->lock);
 
         if (ast_channel_hangupcause(ast)) {
                 q931cause = ast_channel_hangupcause(ast);
         } else {
                 const char *cause = pbx_builtin_getvar_helper(ast, "DIALSTATUS");
                 if (cause) {
                         if (!strcmp(cause, "CONGESTION")) {
                                 q931cause = AST_CAUSE_NORMAL_CIRCUIT_CONGESTION;
                         } else if (!strcmp(cause, "BUSY")) {
                                 q931cause = AST_CAUSE_USER_BUSY;
                         } else if (!strcmp(cause, "CHANISUNVAIL")) {
                                 q931cause = AST_CAUSE_REQUESTED_CHAN_UNAVAIL;
                         } else if (!strcmp(cause, "NOANSWER")) {
                                 q931cause = AST_CAUSE_NO_ANSWER;
                         } else if (!strcmp(cause, "CANCEL")) {
                                 q931cause = AST_CAUSE_CALL_REJECTED;
                         }
                 }
         }
 
 
 
       if (gH323Debug)
          ast_verb(0, "    hanging %s with cause: %d\n", p->username, q931cause);
       ast_channel_tech_pvt_set(ast, NULL);
       if (!ast_test_flag(p, H323_ALREADYGONE)) {
                ooHangCall(p->callToken,
             ooh323_convert_hangupcause_asteriskToH323(q931cause), q931cause);
          ast_set_flag(p, H323_ALREADYGONE);
          /* ast_mutex_unlock(&p->lock); */
             } else
          ast_set_flag(p, H323_NEEDDESTROY);
       /* detach channel here */
       if (p->owner) {
          ast_channel_tech_pvt_set(p->owner, NULL);
          p->owner = NULL;
          ast_module_unref(myself);
       }
 
       ast_mutex_unlock(&p->lock);
       ast_mutex_lock(&usecnt_lock);
       usecnt--;
       ast_mutex_unlock(&usecnt_lock);
 
       /* Notify the module monitors that use count for resource has changed */
       ast_update_use_count();
 
    } else {
       ast_debug(1, "No call to hangup\n" );
    }
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_hangup\n");
 
   return 0;
 }

◆ ooh323_indicate()

static int ooh323_indicate	(	struct ast_channel *	ast,
		int	condition,
		const void *	data,
		size_t	datalen
	)

static

Definition at line 1280 of file chan_ooh323.c.

References ooh323_pvt::alertsent, AST_CAUSE_SWITCH_CONGESTION, AST_CAUSE_USER_BUSY, ast_channel_connected(), ast_channel_tech_pvt(), AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_CONNECTED_LINE, AST_CONTROL_HOLD, AST_CONTROL_INCOMPLETE, AST_CONTROL_MASQUERADE_NOTIFY, AST_CONTROL_PROCEEDING, AST_CONTROL_PROGRESS, AST_CONTROL_PVT_CAUSE_CODE, AST_CONTROL_RINGING, AST_CONTROL_SRCCHANGE, AST_CONTROL_SRCUPDATE, AST_CONTROL_T38_PARAMETERS, AST_CONTROL_UNHOLD, ast_debug, ast_free, ast_log, ast_moh_start(), ast_moh_stop(), ast_mutex_lock, ast_mutex_unlock, ast_queue_control_data(), ast_rtp_instance_change_source(), ast_rtp_instance_update_source(), ast_sockaddr_isnull(), AST_STATE_RING, AST_STATE_RINGING, AST_STATE_UP, ast_strdup, ast_strlen_zero, AST_T38_NEGOTIATED, AST_T38_RATE_14400, AST_T38_REFUSED, AST_T38_REQUEST_NEGOTIATE, AST_T38_REQUEST_PARMS, AST_T38_REQUEST_TERMINATE, AST_T38_TERMINATED, ast_test_flag, ast_udptl_get_far_max_ifp(), ast_verb, ooh323_pvt::callToken, ooh323_pvt::chmodepend, ooh323_pvt::faxmode, gH323Debug, H323_ALREADYGONE, ooh323_pvt::lock, LOG_ERROR, LOG_WARNING, ast_control_t38_parameters::max_ifp, name, NULL, ooh323_pvt::owner, ooh323_pvt::progsent, ast_control_t38_parameters::rate, ooh323_pvt::redirip, ast_control_t38_parameters::request_response, ooh323_pvt::rtp, T38_ENABLED, ooh323_pvt::t38support, and ooh323_pvt::udptl.

 {
 
    struct ooh323_pvt *p = (struct ooh323_pvt *) ast_channel_tech_pvt(ast);
    char *callToken = (char *)NULL;
    int res = -1, rres;
 
    if (!p) return -1;
 
    ast_mutex_lock(&p->lock);
    callToken = (p->callToken ? ast_strdup(p->callToken) : NULL);
    ast_mutex_unlock(&p->lock);
 
    if (!callToken) {
       if (gH323Debug)
          ast_verb(0, "  ooh323_indicate - No callToken\n");
       return -1;
    }
 
    if (!ast_sockaddr_isnull(&p->redirip)) {
       res = 0;
    }
 
    if (gH323Debug) {
       ast_verb(0, "----- ooh323_indicate %d on call %s\n", condition, callToken);
    }
 
       ast_mutex_lock(&p->lock);
    switch (condition) {
    case AST_CONTROL_INCOMPLETE:
       /* While h323 does support overlapped dialing, this channel driver does not
        * at this time.  Treat a response of Incomplete as if it were congestion.
        */
    case AST_CONTROL_CONGESTION:
       if (!ast_test_flag(p, H323_ALREADYGONE)) {
          ooHangCall(callToken, OO_REASON_LOCAL_CONGESTED, AST_CAUSE_SWITCH_CONGESTION);
       }
       break;
    case AST_CONTROL_BUSY:
       if (!ast_test_flag(p, H323_ALREADYGONE)) {
          ooHangCall(callToken, OO_REASON_LOCAL_BUSY, AST_CAUSE_USER_BUSY);
       }
       break;
    case AST_CONTROL_HOLD:
       ast_moh_start(ast, data, NULL);
       break;
    case AST_CONTROL_UNHOLD:
       ast_moh_stop(ast);
       break;
    case AST_CONTROL_PROGRESS:
       if (ast_channel_state(ast) != AST_STATE_UP) {
             if (!p->progsent) {
             rres = ooManualProgress(callToken);
                if (gH323Debug) {
                ast_debug(1, "Sending manual progress for %s, res = %u\n", callToken, rres);
             }
                p->progsent = 1;
             }
       }
        break;
       case AST_CONTROL_RINGING:
       if (ast_channel_state(ast) == AST_STATE_RING || ast_channel_state(ast) == AST_STATE_RINGING) {
          if (!p->alertsent) {
             rres = ooManualRingback(callToken);
             if (gH323Debug) {
                ast_debug(1, "Sending manual ringback for %s, res = %u\n", callToken, rres);
             }
             p->alertsent = 1;
          }
          p->alertsent = 1;
       }
     break;
    case AST_CONTROL_SRCUPDATE:
       if (p->rtp) {
          ast_rtp_instance_update_source(p->rtp);
       }
       break;
    case AST_CONTROL_SRCCHANGE:
       if (p->rtp) {
          ast_rtp_instance_change_source(p->rtp);
       }
       break;
    case AST_CONTROL_CONNECTED_LINE:
       if (!ast_channel_connected(ast)->id.name.valid
          || ast_strlen_zero(ast_channel_connected(ast)->id.name.str)) {
          break;
       }
       if (gH323Debug) {
          ast_debug(1, "Sending connected line info for %s (%s)\n",
             callToken, ast_channel_connected(ast)->id.name.str);
       }
       ooSetANI(callToken, ast_channel_connected(ast)->id.name.str);
       break;
 
       case AST_CONTROL_T38_PARAMETERS:
       if (p->t38support != T38_ENABLED) {
          struct ast_control_t38_parameters parameters = { .request_response = 0 };
          parameters.request_response = AST_T38_REFUSED;
          ast_queue_control_data(ast, AST_CONTROL_T38_PARAMETERS,
                    &parameters, sizeof(parameters));
          break;
       }
       if (datalen != sizeof(struct ast_control_t38_parameters)) {
          ast_log(LOG_ERROR, "Invalid datalen for AST_CONTROL_T38. "
                   "Expected %d, got %d\n",
             (int)sizeof(enum ast_control_t38), (int)datalen);
       } else {
          const struct ast_control_t38_parameters *parameters = data;
          struct ast_control_t38_parameters our_parameters;
          enum ast_control_t38 message = parameters->request_response;
          switch (message) {
 
          case AST_T38_NEGOTIATED:
             if (p->faxmode) {
                res = 0;
                break;
             }
          case AST_T38_REQUEST_NEGOTIATE:
 
             if (p->faxmode) {
                /* T.38 already negotiated */
                our_parameters.request_response = AST_T38_NEGOTIATED;
                our_parameters.max_ifp = ast_udptl_get_far_max_ifp(p->udptl);
                our_parameters.rate = AST_T38_RATE_14400;
                ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS, &our_parameters, sizeof(our_parameters));
             } else if (!p->chmodepend) {
                p->chmodepend = 1;
                ooRequestChangeMode(p->callToken, 1);
                res = 0;
             }
             break;
 
          case AST_T38_REQUEST_TERMINATE:
 
             if (!p->faxmode) {
                /* T.38 already terminated */
                our_parameters.request_response = AST_T38_TERMINATED;
                ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS, &our_parameters, sizeof(our_parameters));
             } else if (!p->chmodepend) {
                p->chmodepend = 1;
                ooRequestChangeMode(p->callToken, 0);
                res = 0;
             }
             break;
 
          case AST_T38_REQUEST_PARMS:
             our_parameters.request_response = AST_T38_REQUEST_PARMS;
             our_parameters.max_ifp = ast_udptl_get_far_max_ifp(p->udptl);
             our_parameters.rate = AST_T38_RATE_14400;
             ast_queue_control_data(p->owner, AST_CONTROL_T38_PARAMETERS, &our_parameters, sizeof(our_parameters));
             res = AST_T38_REQUEST_PARMS;
             break;
 
          default:
             ;
 
          }
 
       }
       break;
    case AST_CONTROL_PROCEEDING:
    case AST_CONTROL_PVT_CAUSE_CODE:
    case AST_CONTROL_MASQUERADE_NOTIFY:
    case -1:
       break;
    default:
       ast_log(LOG_WARNING, "Don't know how to indicate condition %d on %s\n",
                            condition, callToken);
    }
 
       ast_mutex_unlock(&p->lock);
 
    if (gH323Debug) {
       ast_verb(0, "++++  ooh323_indicate %d on %s is %d\n", condition, callToken, res);
    }
 
       ast_free(callToken);
    return res;
 }

◆ ooh323_new()

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
	)

static

Definition at line 413 of file chan_ooh323.c.

Referenced by ooh323_onReceivedSetup(), and ooh323_request().

 {
    struct ast_format_cap *caps = NULL;
    struct ast_channel *ch = NULL;
    struct ast_format *tmpfmt = NULL;
    int features = 0;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_new - %s\n", host);
    }
 
    caps = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
 
    /* Don't hold a h323 pvt lock while we allocate a channel */
    ast_mutex_unlock(&i->lock);
       ast_mutex_lock(&ooh323c_cn_lock);
       ch = ast_channel_alloc(1, state, i->callerid_num, i->callerid_name,
             i->accountcode, i->exten, i->context, assignedids, requestor, i->amaflags,
             "OOH323/%s-%ld", host, callnumber);
       callnumber++;
       ast_mutex_unlock(&ooh323c_cn_lock);
 
    ast_mutex_lock(&i->lock);
 
    if (ch && caps) {
       ast_channel_tech_set(ch, &ooh323_tech);
 
       if (cap) {
          tmpfmt = ast_format_cap_get_format(cap, 0);
       }
       if (!tmpfmt) {
          tmpfmt = ast_format_cap_get_format(i->cap, 0);
       }
 
       ast_format_cap_append(caps, tmpfmt, 0);
       ast_channel_nativeformats_set(ch, caps);
       ao2_ref(caps, -1);
 
       ast_channel_set_rawwriteformat(ch, tmpfmt);
       ast_channel_set_rawreadformat(ch, tmpfmt);
       ast_set_write_format(ch, tmpfmt);
       ast_set_read_format(ch, tmpfmt);
       ao2_ref(tmpfmt, -1);
 
       ast_jb_configure(ch, &global_jbconf);
 
       if (state == AST_STATE_RING)
          ast_channel_rings_set(ch, 1);
 
       ast_channel_adsicpe_set(ch, AST_ADSI_UNAVAILABLE);
       ast_channel_tech_pvt_set(ch, i);
       i->owner = ch;
       ast_module_ref(myself);
 
       /* Allocate dsp for in-band DTMF support */
       if ((i->dtmfmode & H323_DTMF_INBAND) || (i->faxdetect & FAXDETECT_CNG)) {
          i->vad = ast_dsp_new();
       }
 
       /* inband DTMF*/
       if (i->dtmfmode & H323_DTMF_INBAND) {
          features |= DSP_FEATURE_DIGIT_DETECT;
          if (i->dtmfmode & H323_DTMF_INBANDRELAX) {
             ast_dsp_set_digitmode(i->vad, DSP_DIGITMODE_DTMF | DSP_DIGITMODE_RELAXDTMF);
          }
       }
 
       /* fax detection*/
       if (i->faxdetect & FAXDETECT_CNG) {
          features |= DSP_FEATURE_FAX_DETECT;
          ast_dsp_set_faxmode(i->vad,
                DSP_FAXMODE_DETECT_CNG | DSP_FAXMODE_DETECT_CED);
       }
 
       if (features) {
          ast_dsp_set_features(i->vad, features);
       }
 
       ast_mutex_lock(&usecnt_lock);
       usecnt++;
       ast_mutex_unlock(&usecnt_lock);
 
       /* Notify the module monitors that use count for resource has changed*/
       ast_update_use_count();
 
       ast_channel_context_set(ch, i->context);
       ast_channel_exten_set(ch, i->exten);
 
       ast_channel_priority_set(ch, 1);
 
             if(!ast_test_flag(i, H323_OUTGOING)) {
 
          if (!ast_strlen_zero(i->caller_h323id)) {
             pbx_builtin_setvar_helper(ch, "_CALLER_H323ID", i->caller_h323id);
 
          }
          if (!ast_strlen_zero(i->caller_dialedDigits)) {
             pbx_builtin_setvar_helper(ch, "_CALLER_H323DIALEDDIGITS",
             i->caller_dialedDigits);
          }
          if (!ast_strlen_zero(i->caller_email)) {
             pbx_builtin_setvar_helper(ch, "_CALLER_H323EMAIL",
             i->caller_email);
          }
          if (!ast_strlen_zero(i->caller_url)) {
             pbx_builtin_setvar_helper(ch, "_CALLER_H323URL", i->caller_url);
          }
       }
 
       if (!ast_strlen_zero(i->accountcode))
          ast_channel_accountcode_set(ch, i->accountcode);
 
       if (i->amaflags)
          ast_channel_amaflags_set(ch, i->amaflags);
 
       ast_setstate(ch, state);
       if (state != AST_STATE_DOWN) {
                if (ast_pbx_start(ch)) {
             ast_log(LOG_WARNING, "Unable to start PBX on %s\n", ast_channel_name(ch));
                      ast_channel_unlock(ch);
             ast_hangup(ch);
             ch = NULL;
          }
       }
    } else {
       ao2_cleanup(caps);
       ast_log(LOG_WARNING, "Unable to allocate channel structure\n");
    }
 
 
       if(ch)   ast_channel_unlock(ch);
 
    if (gH323Debug) {
       ast_verb(0, "+++   h323_new\n");
    }
 
    return ch;
 }

◆ ooh323_onReceivedDigit()

int ooh323_onReceivedDigit	(	OOH323CallData *	call,
		const char *	digit
	)

Callback for sending digits from H.323 up to asterisk

Definition at line 1798 of file chan_ooh323.c.

References ast_channel_trylock, ast_channel_unlock, ast_debug, AST_FRAME_DTMF, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_queue_frame(), ast_frame::data, ast_frame::datalen, DEADLOCK_AVOIDANCE, find_call(), ast_frame::frametype, ast_frame_subclass::integer, ooh323_pvt::lock, LOG_ERROR, ast_frame::mallocd, NULL, ast_frame::offset, ooh323_pvt::owner, ast_frame::ptr, ast_frame::samples, ast_frame::src, and ast_frame::subclass.

Referenced by load_module().

 {
    struct ooh323_pvt *p = NULL;
    struct ast_frame f;
    int res;
 
    ast_debug(1, "Received Digit: %c\n", digit[0]);
    p = find_call(call);
    if (!p) {
       ast_log(LOG_ERROR, "Failed to find a matching call.\n");
       return -1;
    }
    if (!p->owner) {
       ast_log(LOG_ERROR, "Channel has no owner\n");
       return -1;
    }
    ast_mutex_lock(&p->lock);
    memset(&f, 0, sizeof(f));
    f.frametype = AST_FRAME_DTMF;
    f.subclass.integer = digit[0];
    f.datalen = 0;
    f.samples = 800;
    f.offset = 0;
    f.data.ptr = NULL;
    f.mallocd = 0;
    f.src = "SEND_DIGIT";
 
    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;
    }
    res = ast_queue_frame(p->owner, &f);
       ast_channel_unlock(p->owner);
       ast_mutex_unlock(&p->lock);
    return res;
 }

◆ ooh323_onReceivedSetup()

int ooh323_onReceivedSetup	(	ooCallData *	call,
		Q931Message *	pmsg
	)

Definition at line 1840 of file chan_ooh323.c.

References ooh323_pvt::accountcode, ooh323_user::accountcode, ooh323_pvt::amaflags, ooh323_user::amaflags, ooh323_pvt::aniasdni, ooh323_user::aniasdni, AST_CAUSE_CALL_REJECTED, AST_CAUSE_NORMAL_CIRCUIT_CONGESTION, ast_clear_flag, ast_copy_string(), ast_format_cap_append_from_cap(), ast_log, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_lock, ast_mutex_unlock, ast_set_flag, AST_STATE_RING, ast_strdup, ast_strlen_zero, ast_verb, c, ooh323_pvt::callee_dialedDigits, ooh323_pvt::callee_email, ooh323_pvt::callee_h323id, ooh323_pvt::caller_dialedDigits, ooh323_pvt::caller_email, ooh323_pvt::caller_h323id, ooh323_pvt::caller_url, ooh323_pvt::callerid_name, ooh323_pvt::callerid_num, ooh323_pvt::cap, ooh323_user::cap, configure_local_rtp(), ooh323_pvt::context, ooh323_user::context, ooh323_pvt::directrtp, ooh323_user::directrtp, ooh323_pvt::dtmfcodec, ooh323_user::dtmfcodec, ooh323_pvt::dtmfmode, ooh323_user::dtmfmode, ooh323_pvt::earlydirect, ooh323_user::earlydirect, ooh323_pvt::exten, ooh323_pvt::faststart, ooh323_user::faststart, ooh323_pvt::faxdetect, ooh323_user::faxdetect, find_user(), ooh323_pvt::flags, ooh323_pvt::g729onlyA, ooh323_user::g729onlyA, gDirectRTP, gEarlyDirect, gH323Debug, ooh323_pvt::h245tunneling, ooh323_user::h245tunneling, H323_DISABLEGK, H323_NEEDDESTROY, H323_OUTGOING, ooh323_user::incominglimit, ooh323_user::inUse, ooh323_pvt::lock, ooh323_user::lock, LOG_ERROR, ooh323_user::mIP, ooh323_user::mUseIP, ooh323_user::name, ooh323_pvt::nat, ooh323_user::nat, ooh323_pvt::neighbor, NULL, ooh323_alloc(), ooh323_convert_hangupcause_asteriskToH323(), ooh323_new(), ooh323c_set_capability_for_call(), ooh323_pvt::rtdrcount, ooh323_user::rtdrcount, ooh323_pvt::rtdrinterval, ooh323_user::rtdrinterval, ooh323_pvt::rtpmask, ooh323_user::rtpmask, ooh323_pvt::rtpmaskstr, ooh323_user::rtpmaskstr, ooh323_pvt::rtptimeout, ooh323_user::rtptimeout, ooh323_pvt::t38support, ooh323_user::t38support, update_our_aliases(), ooh323_pvt::user, and ooh323_pvt::username.

Referenced by load_module().

 {
    struct ooh323_pvt *p = NULL;
    struct ooh323_user *user = NULL;
       struct ast_channel *c = NULL;
    ooAliases *alias = NULL;
    char *at = NULL;
    char number [OO_MAX_NUMBER_LENGTH];
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_onReceivedSetup %s\n", call->callToken);
 
 
    if (!(p = ooh323_alloc(call->callReference, call->callToken))) {
       ast_log(LOG_ERROR, "Failed to create a new call.\n");
       return -1;
    }
    ast_mutex_lock(&p->lock);
    ast_clear_flag(p, H323_OUTGOING);
 
 
    if (call->remoteDisplayName) {
       p->callerid_name = ast_strdup(call->remoteDisplayName);
    }
 
    if (ooCallGetCallingPartyNumber(call, number, OO_MAX_NUMBER_LENGTH) == OO_OK) {
       p->callerid_num = ast_strdup(number);
    }
 
    if (call->remoteAliases) {
       for (alias = call->remoteAliases; alias; alias = alias->next) {
          if (alias->type == T_H225AliasAddress_h323_ID) {
             if (!p->callerid_name) {
                p->callerid_name = ast_strdup(alias->value);
             }
             ast_copy_string(p->caller_h323id, alias->value, sizeof(p->caller_h323id));
             }
          else if(alias->type == T_H225AliasAddress_dialedDigits)
          {
             if(!p->callerid_num)
                p->callerid_num = ast_strdup(alias->value);
             ast_copy_string(p->caller_dialedDigits, alias->value,
                                              sizeof(p->caller_dialedDigits));
          }
          else if(alias->type == T_H225AliasAddress_email_ID)
          {
             ast_copy_string(p->caller_email, alias->value, sizeof(p->caller_email));
          }
          else if(alias->type == T_H225AliasAddress_url_ID)
          {
             ast_copy_string(p->caller_url, alias->value, sizeof(p->caller_url));
          }
       }
    }
 
    number[0] = '\0';
       if(ooCallGetCalledPartyNumber(call, number, OO_MAX_NUMBER_LENGTH)== OO_OK) {
             ast_copy_string(p->exten, number, sizeof(p->exten));
       } else {
       update_our_aliases(call, p);
       if (!ast_strlen_zero(p->callee_dialedDigits)) {
                ast_copy_string(p->exten, p->callee_dialedDigits, sizeof(p->exten));
             } else if(!ast_strlen_zero(p->callee_h323id)) {
          ast_copy_string(p->exten, p->callee_h323id, sizeof(p->exten));
             } else if(!ast_strlen_zero(p->callee_email)) {
          ast_copy_string(p->exten, p->callee_email, sizeof(p->exten));
          if ((at = strchr(p->exten, '@'))) {
             *at = '\0';
          }
       }
    }
 
    /* if no extension found, set to default 's' */
    if (ast_strlen_zero(p->exten)) {
             p->exten[0]='s';
             p->exten[1]='\0';
    }
 
          user = find_user(p->callerid_name, call->remoteIP);
          if(user && (user->incominglimit == 0 || user->inUse < user->incominglimit)) {
       ast_mutex_lock(&user->lock);
       p->username = ast_strdup(user->name);
       p->neighbor.user = user->mUseIP ? ast_strdup(user->mIP) :
                     ast_strdup(user->name);
       ast_copy_string(p->context, user->context, sizeof(p->context));
       ast_copy_string(p->accountcode, user->accountcode, sizeof(p->accountcode));
       p->amaflags = user->amaflags;
       ast_format_cap_append_from_cap(p->cap, user->cap, AST_MEDIA_TYPE_UNKNOWN);
       p->g729onlyA = user->g729onlyA;
       p->dtmfmode |= user->dtmfmode;
       p->dtmfcodec = user->dtmfcodec;
       p->faxdetect = user->faxdetect;
       p->t38support = user->t38support;
       p->rtptimeout = user->rtptimeout;
       p->nat = user->nat;
       p->h245tunneling = user->h245tunneling;
       p->faststart = user->faststart;
       p->directrtp = user->directrtp;
       p->earlydirect = user->earlydirect;
 
       if (p->faststart)
                OO_SETFLAG(call->flags, OO_M_FASTSTART);
       else
          OO_CLRFLAG(call->flags, OO_M_FASTSTART);
       /* if we disable h245tun for this user then we clear flag */
       /* in any other case we don't must touch this */
       /* ie if we receive setup without h245tun but enabled
                      we can't enable it per call */
       if (!p->h245tunneling)
          OO_CLRFLAG(call->flags, OO_M_TUNNELING);
 
       if (user->rtpmask && user->rtpmaskstr[0]) {
          p->rtpmask = user->rtpmask;
          ast_copy_string(p->rtpmaskstr, user->rtpmaskstr,
                       sizeof(p->rtpmaskstr));
       }
       if (user->rtdrcount > 0 && user->rtdrinterval > 0) {
          p->rtdrcount = user->rtdrcount;
          p->rtdrinterval = user->rtdrinterval;
       }
 
       p->aniasdni = user->aniasdni;
 
       if (user->incominglimit) user->inUse++;
       ast_mutex_unlock(&user->lock);
    } else {
     if (!OO_TESTFLAG(p->flags,H323_DISABLEGK)) {
       p->username = ast_strdup(call->remoteIP);
       p->directrtp = gDirectRTP;
       p->earlydirect = gEarlyDirect;
    } else {
      ast_mutex_unlock(&p->lock);
      ast_log(LOG_ERROR, "Unacceptable ip %s\n", call->remoteIP);
      if (!user) {
       ooHangCall(call->callToken, ooh323_convert_hangupcause_asteriskToH323(AST_CAUSE_CALL_REJECTED), AST_CAUSE_CALL_REJECTED);
       call->callEndReason = OO_REASON_REMOTE_REJECTED;
      }
      else {
       ooHangCall(call->callToken, ooh323_convert_hangupcause_asteriskToH323(AST_CAUSE_NORMAL_CIRCUIT_CONGESTION), AST_CAUSE_NORMAL_CIRCUIT_CONGESTION);
       call->callEndReason = OO_REASON_REMOTE_REJECTED;
      }
      ast_set_flag(p, H323_NEEDDESTROY);
      return -1;
     }
    }
 
    ooh323c_set_capability_for_call(call, p->cap, p->dtmfmode, p->dtmfcodec,
                 p->t38support, p->g729onlyA);
 /* Incoming call */
    c = ooh323_new(p, AST_STATE_RING, p->username, 0, NULL, NULL);
    if(!c) {
       ast_mutex_unlock(&p->lock);
       ast_log(LOG_ERROR, "Could not create ast_channel\n");
          return -1;
    }
 
    if (p->aniasdni) {
       ooCallSetCallerId(call, p->exten);
    }
    if (!configure_local_rtp(p, call)) {
       ast_mutex_unlock(&p->lock);
       ast_log(LOG_ERROR, "Couldn't create rtp structure\n");
       return -1;
    }
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_onReceivedSetup - Determined context %s, "
                   "extension %s\n", p->context, p->exten);
 
    return OO_OK;
 }

◆ ooh323_queryoption()

static int ooh323_queryoption	(	struct ast_channel *	ast,
		int	option,
		void *	data,
		int *	datalen
	)

static

Definition at line 1460 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_tech_pvt(), ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, AST_OPTION_DIGIT_DETECT, AST_OPTION_T38_STATE, ast_verb, ooh323_pvt::chmodepend, ooh323_pvt::faxmode, gH323Debug, ooh323_pvt::lock, LOG_ERROR, state, T38_DISABLED, T38_STATE_NEGOTIATED, T38_STATE_NEGOTIATING, T38_STATE_UNAVAILABLE, T38_STATE_UNKNOWN, ooh323_pvt::t38support, and ooh323_pvt::vad.

 {
 
    struct ooh323_pvt *p = (struct ooh323_pvt *) ast_channel_tech_pvt(ast);
    int res = -1;
    enum ast_t38_state state = T38_STATE_UNAVAILABLE;
    char* cp;
 
    if (!p) return -1;
 
    ast_mutex_lock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "----- ooh323_queryoption %d on channel %s\n", option, ast_channel_name(ast));
 
    switch (option) {
 
       case AST_OPTION_T38_STATE:
 
          if (*datalen != sizeof(enum ast_t38_state)) {
             ast_log(LOG_ERROR, "Invalid datalen for AST_OPTION_T38_STATE option."
             " Expected %d, got %d\n", (int)sizeof(enum ast_t38_state), *datalen);
             break;
          }
 
          if (p->t38support != T38_DISABLED) {
             if (p->faxmode) {
                state = (p->chmodepend) ? T38_STATE_NEGOTIATING : T38_STATE_NEGOTIATED;
             } else {
                state = T38_STATE_UNKNOWN;
             }
          }
 
          *((enum ast_t38_state *) data) = state;
          res = 0;
          break;
 
 
       case AST_OPTION_DIGIT_DETECT:
 
          cp = (char *) data;
          *cp = p->vad ? 1 : 0;
          ast_debug(1, "Reporting digit detection %sabled on %s\n",
                       *cp ? "en" : "dis", ast_channel_name(ast));
 
          res = 0;
          break;
 
       default: ;
 
    }
 
    if (gH323Debug)
       ast_verb(0, "+++++ ooh323_queryoption %d on channel %s\n", option, ast_channel_name(ast));
 
       ast_mutex_unlock(&p->lock);
 
    return res;
 }

◆ ooh323_read()

static struct ast_frame * ooh323_read ( struct ast_channel * ast )

static

Definition at line 1194 of file chan_ooh323.c.

References ast_channel_tech_pvt(), AST_FRAME_NULL, ast_mutex_lock, ast_mutex_unlock, ooh323_pvt::lock, ooh323_rtp_read(), and ooh323_pvt::rtp.

 {
    struct ast_frame *fr;
    static struct ast_frame null_frame = { AST_FRAME_NULL, };
    struct ooh323_pvt *p = ast_channel_tech_pvt(ast);
 
    if (!p) return &null_frame;
 
    ast_mutex_lock(&p->lock);
    if (p->rtp)
       fr = ooh323_rtp_read(ast, p);
    else
       fr = &null_frame;
    /* time(&p->lastrtprx); */
    ast_mutex_unlock(&p->lock);
    return fr;
 }

◆ ooh323_request()

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
	)

static

Definition at line 624 of file chan_ooh323.c.

References ooh323_pvt::accountcode, ooh323_peer::accountcode, ooh323_pvt::amaflags, ooh323_peer::amaflags, ast_calloc, AST_CAUSE_INVALID_NUMBER_FORMAT, AST_CAUSE_NORMAL_TEMPORARY_FAILURE, ast_cond_destroy, ast_cond_init, ast_cond_wait, ast_copy_string(), ast_format_cap_append_from_cap(), ast_format_cap_get_names(), ast_format_cap_has_type(), AST_FORMAT_CAP_NAMES_LEN, ast_log, AST_MAX_EXTENSION, AST_MEDIA_TYPE_AUDIO, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_lock, ast_mutex_unlock, ast_set_flag, AST_STATE_DOWN, ast_str_alloca, ast_strdup, ast_verb, ooh323_pvt::callToken, ooh323_pvt::cap, ooh323_peer::cap, ooh323_pvt::directrtp, ooh323_peer::directrtp, ooh323_pvt::dtmfcodec, ooh323_peer::dtmfcodec, ooh323_pvt::dtmfmode, ooh323_peer::dtmfmode, ooh323_pvt::earlydirect, ooh323_peer::earlydirect, ext, ooh323_pvt::exten, ooh323_pvt::faststart, ooh323_peer::faststart, ooh323_pvt::faxdetect, ooh323_peer::faxdetect, find_peer(), ooh323_pvt::g729onlyA, ooh323_peer::g729onlyA, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gH323Debug, gH323ep, gNat, gRasGkMode, gRTDRCount, gRTDRInterval, gRTPTimeout, gT38Support, gTunneling, ooh323_pvt::h245tunneling, ooh323_peer::h245tunneling, H323_OUTGOING, ooh323_pvt::host, iflock, ooh323_peer::ip, ooh323_pvt::lock, LOG_ERROR, LOG_NOTICE, LOG_WARNING, ooh323_peer::name, ooh323_pvt::nat, ooh323_peer::nat, NULL, ooh323_alloc(), ooh323_destroy(), ooh323_new(), ooh323_pvt::peer, ooh323_pvt::port, ooh323_peer::port, restart_monitor(), ooh323_pvt::rtdrcount, ooh323_peer::rtdrcount, ooh323_pvt::rtdrinterval, ooh323_peer::rtdrinterval, ooh323_pvt::rtp, ooh323_pvt::rtpcond, ooh323_pvt::rtpmask, ooh323_peer::rtpmask, ooh323_pvt::rtpmaskstr, ooh323_peer::rtpmaskstr, ooh323_pvt::rtptimeout, ooh323_peer::rtptimeout, ooh323_pvt::t38support, ooh323_peer::t38support, tmp(), and ooh323_pvt::username.

 {
    struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
    struct ast_channel *chan = NULL;
    struct ooh323_pvt *p = NULL;
    struct ooh323_peer *peer = NULL;
    char *dest = NULL;
    char *ext = NULL;
    char tmp[256];
    int port = 0;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_request - data %s format %s\n", data, ast_format_cap_get_names(cap, &codec_buf));
    }
 
    if (!(ast_format_cap_has_type(cap, AST_MEDIA_TYPE_AUDIO))) {
       ast_log(LOG_NOTICE, "Asked to get a channel of unsupported format '%s'\n", ast_format_cap_get_names(cap, &codec_buf));
       return NULL;
    }
 
    p = ooh323_alloc(0,0); /* Initial callRef is zero */
 
    if (!p) {
       ast_log(LOG_WARNING, "Unable to build pvt data for '%s'\n", data);
       return NULL;
    }
    ast_mutex_lock(&p->lock);
 
    /* This is an outgoing call, since ooh323_request is called */
    ast_set_flag(p, H323_OUTGOING);
 
 
       ast_copy_string(tmp, data, sizeof(tmp));
 
    dest = strchr(tmp, '/');
 
    if (dest) {
       *dest = '\0';
       dest++;
       ext = dest;
       dest = tmp;
    } else if ((dest = strchr(tmp, '@'))) {
       *dest = '\0';
       dest++;
       ext = tmp;
    } else {
       dest = tmp;
       ext = NULL;
    }
 
 #if 0
    if ((sport = strchr(dest, ':'))) {
       *sport = '\0';
       sport++;
       port = atoi(sport);
    }
 #endif
 
    if (dest) {
       peer = find_peer(dest, port);
    } else{
       ast_mutex_lock(&iflock);
       ast_mutex_unlock(&p->lock);
       ooh323_destroy(p);
       ast_mutex_unlock(&iflock);
       ast_log(LOG_ERROR, "Destination format is not supported\n");
       *cause = AST_CAUSE_INVALID_NUMBER_FORMAT;
       return NULL;
    }
 
    if (peer) {
       p->username = ast_strdup(peer->name);
       p->host = ast_strdup(peer->ip);
       p->port = peer->port;
       /* Disable gk as we are going to call a known peer*/
       /* OO_SETFLAG(p->flags, H323_DISABLEGK); */
 
       if (ext)
          ast_copy_string(p->exten, ext, sizeof(p->exten));
 
       ast_format_cap_append_from_cap(p->cap, peer->cap, AST_MEDIA_TYPE_UNKNOWN);
       p->g729onlyA = peer->g729onlyA;
       p->dtmfmode |= peer->dtmfmode;
       p->dtmfcodec  = peer->dtmfcodec;
       p->faxdetect = peer->faxdetect;
       p->t38support = peer->t38support;
       p->rtptimeout = peer->rtptimeout;
       p->nat = peer->nat;
       p->faststart = peer->faststart;
       p->h245tunneling = peer->h245tunneling;
       p->directrtp = peer->directrtp;
       p->earlydirect = peer->earlydirect;
       if (peer->rtpmask && peer->rtpmaskstr[0]) {
          p->rtpmask = peer->rtpmask;
          ast_copy_string(p->rtpmaskstr, peer->rtpmaskstr, sizeof(p->rtpmaskstr));
       }
 
       if (peer->rtdrinterval) {
          p->rtdrinterval = peer->rtdrinterval;
          p->rtdrcount = peer->rtdrcount;
       }
 
       ast_copy_string(p->accountcode, peer->accountcode, sizeof(p->accountcode));
       p->amaflags = peer->amaflags;
    } else {
       if (gRasGkMode ==  RasNoGatekeeper) {
          /* no gk and no peer */
          ast_log(LOG_ERROR, "Call to undefined peer %s", dest);
          ast_mutex_lock(&iflock);
          ast_mutex_unlock(&p->lock);
          ooh323_destroy(p);
          ast_mutex_unlock(&iflock);
          return NULL;
       } else if (!gH323ep.gkClient || (gH323ep.gkClient && gH323ep.gkClient->state != GkClientRegistered)) {
          ast_log(LOG_ERROR, "Gatekeeper client is configured but not registered\n");
          *cause = AST_CAUSE_NORMAL_TEMPORARY_FAILURE;
          return NULL;
       }
       p->g729onlyA = g729onlyA;
       p->dtmfmode = gDTMFMode;
       p->dtmfcodec = gDTMFCodec;
       p->faxdetect = gFAXdetect;
       p->t38support = gT38Support;
       p->rtptimeout = gRTPTimeout;
       p->nat = gNat;
       ast_format_cap_append_from_cap(p->cap, gCap, AST_MEDIA_TYPE_UNKNOWN);
       p->rtdrinterval = gRTDRInterval;
       p->rtdrcount = gRTDRCount;
       p->faststart = gFastStart;
       p->h245tunneling = gTunneling;
       p->directrtp = gDirectRTP;
       p->earlydirect = gEarlyDirect;
 
       p->username = ast_strdup(dest);
 
       p->host = ast_strdup(dest);
       if (port > 0) {
          p->port = port;
       }
       if (ext) {
          ast_copy_string(p->exten, ext, sizeof(p->exten));
       }
    }
 
 
    chan = ooh323_new(p, AST_STATE_DOWN, p->username, cap,
              assignedids, requestor);
 
    ast_mutex_unlock(&p->lock);
 
    if (!chan) {
       ast_mutex_lock(&iflock);
       ooh323_destroy(p);
       ast_mutex_unlock(&iflock);
       } else {
             ast_mutex_lock(&p->lock);
             p->callToken = (char*)ast_calloc(1, AST_MAX_EXTENSION);
             if(!p->callToken) {
                ast_mutex_unlock(&p->lock);
                ast_mutex_lock(&iflock);
                ooh323_destroy(p);
                ast_mutex_unlock(&iflock);
                ast_log(LOG_ERROR, "Failed to allocate memory for callToken\n");
                return NULL;
             }
 
       ast_cond_init(&p->rtpcond, NULL);
             ooMakeCall(data, p->callToken, AST_MAX_EXTENSION, NULL);
       if (!p->rtp) {
          ast_cond_wait(&p->rtpcond, &p->lock);
       }
       ast_mutex_unlock(&p->lock);
       ast_cond_destroy(&p->rtpcond);
    }
 
    restart_monitor();
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_request\n");
 
    return chan;
 
 }

◆ ooh323_rtp_read()

struct ast_frame* ooh323_rtp_read	(	struct ast_channel *	ast,
		struct ooh323_pvt *	p
	)

Definition at line 4978 of file chan_ooh323.c.

References ao2_ref, ast_async_goto(), ast_channel_caller(), ast_channel_context(), ast_channel_exten(), ast_channel_fdno(), ast_channel_macrocontext(), ast_channel_name(), ast_channel_nativeformats(), ast_channel_nativeformats_set(), ast_channel_readformat(), ast_channel_writeformat(), ast_debug, ast_dsp_process(), ast_exists_extension(), ast_format_alaw, ast_format_cap_alloc, ast_format_cap_append, AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_cap_iscompatible_format(), ast_format_cmp(), AST_FORMAT_CMP_EQUAL, AST_FORMAT_CMP_NOT_EQUAL, ast_format_get_name(), ast_format_slin, ast_format_ulaw, AST_FRAME_DTMF, AST_FRAME_NULL, AST_FRAME_VOICE, ast_frdup, ast_frfree, ast_log, ast_null_frame, ast_rtp_instance_read(), ast_set_read_format(), ast_set_write_format(), ast_udptl_read(), ast_verb, ooh323_pvt::callToken, ooh323_pvt::chmodepend, ast_frame::datalen, ooh323_pvt::dtmfmode, ooh323_pvt::faxdetect, FAXDETECT_CNG, ooh323_pvt::faxdetected, ooh323_pvt::faxmode, ast_frame_subclass::format, ast_frame::frametype, gH323Debug, H323_DTMF_INBAND, ast_party_caller::id, ast_frame_subclass::integer, ooh323_pvt::lastrtprx, LOG_NOTICE, NULL, ast_party_id::number, ooh323_pvt::owner, pbx_builtin_setvar_helper(), ooh323_pvt::rtp, S_COR, S_OR, ast_party_number::str, ast_frame::subclass, T38_DISABLED, ooh323_pvt::t38support, ooh323_pvt::udptl, ooh323_pvt::vad, ast_party_number::valid, and ooh323_pvt::vrtp.

Referenced by ooh323_read().

 {
    /* Retrieve audio/etc from channel.  Assumes p->lock is already held. */
    struct ast_frame *f;
    struct ast_frame *dfr = NULL;
    static struct ast_frame null_frame = { AST_FRAME_NULL, };
    switch (ast_channel_fdno(ast)) {
    case 0:
       f = ast_rtp_instance_read(p->rtp, 0);  /* RTP Audio */
       p->lastrtprx = time(NULL);
       break;
    case 1:
       f = ast_rtp_instance_read(p->rtp, 1);  /* RTCP Control Channel */
       break;
    case 2:
       f = ast_rtp_instance_read(p->vrtp, 0); /* RTP Video */
       p->lastrtprx = time(NULL);
       break;
    case 3:
       f = ast_rtp_instance_read(p->vrtp, 1); /* RTCP Control Channel for video */
       break;
    case 5:
       f = ast_udptl_read(p->udptl);    /* UDPTL t.38 data */
       if (gH323Debug) {
           ast_debug(1, "Got UDPTL %u/%d len %d for %s\n",
             f->frametype, f->subclass.integer, f->datalen, ast_channel_name(ast));
       }
       p->lastrtprx = time(NULL);
       break;
 
    default:
       f = &null_frame;
    }
 
    if (f && p->owner && !p->faxmode && (f->frametype == AST_FRAME_VOICE)) {
       /* We already hold the channel lock */
       if (ast_format_cap_iscompatible_format(ast_channel_nativeformats(p->owner), f->subclass.format) == AST_FORMAT_CMP_NOT_EQUAL) {
          struct ast_format_cap *caps;
 
          ast_debug(1, "Oooh, voice format changed to %s\n", ast_format_get_name(f->subclass.format));
 
          caps = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
          if (caps) {
             ast_format_cap_append(caps, f->subclass.format, 0);
             ast_channel_nativeformats_set(p->owner, caps);
             ao2_ref(caps, -1);
          }
          ast_set_read_format(p->owner, ast_channel_readformat(p->owner));
          ast_set_write_format(p->owner, ast_channel_writeformat(p->owner));
       }
       if (((p->dtmfmode & H323_DTMF_INBAND) || (p->faxdetect & FAXDETECT_CNG)) && p->vad &&
          ((ast_format_cmp(f->subclass.format, ast_format_slin) == AST_FORMAT_CMP_EQUAL) ||
          (ast_format_cmp(f->subclass.format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL) ||
          (ast_format_cmp(f->subclass.format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL))) {
          dfr = ast_frdup(f);
          dfr = ast_dsp_process(p->owner, p->vad, dfr);
       }
    } else {
       return f;
    }
 
    /* process INBAND DTMF*/
    if (dfr && (dfr->frametype == AST_FRAME_DTMF) && ((dfr->subclass.integer == 'f') || (dfr->subclass.integer == 'e'))) {
       ast_debug(1, "* Detected FAX Tone %s\n", (dfr->subclass.integer == 'e') ? "CED" : "CNG");
       /* Switch to T.38 ON CED*/
       if (!p->faxmode && !p->chmodepend && (dfr->subclass.integer == 'e') && (p->t38support != T38_DISABLED)) {
          if (gH323Debug)
             ast_verb(0, "request to change %s to t.38 because fax ced\n", p->callToken);
          p->chmodepend = 1;
          p->faxdetected = 1;
          ooRequestChangeMode(p->callToken, 1);
       } else if ((dfr->subclass.integer == 'f') && !p->faxdetected) {
          const char *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_frfree(dfr);
             return &ast_null_frame;
          }
       }
    } else if (dfr && dfr->frametype == AST_FRAME_DTMF) {
       ast_debug(1, "* Detected inband DTMF '%c'\n", f->subclass.integer);
       ast_frfree(f);
       return dfr;
    }
 
    if (dfr) {
       ast_frfree(dfr);
    }
    return f;
 }

◆ ooh323_set_read_format()

void ooh323_set_read_format	(	ooCallData *	call,
		struct ast_format *	fmt
	)

Definition at line 1625 of file chan_ooh323.c.

References ao2_ref, ao2_replace, ast_channel_nativeformats_set(), ast_channel_readformat(), ast_channel_trylock, ast_channel_unlock, ast_debug, ast_format_cap_alloc, ast_format_cap_append, AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_get_name(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_set_read_format(), ast_verb, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323_pvt::owner, and ooh323_pvt::readformat.

 {
    struct ooh323_pvt *p = NULL;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_update_readformat %s\n",
             ast_format_get_name(fmt));
 
    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);
 
    ao2_replace(p->readformat, fmt);
 
    if (p->owner) {
       struct ast_format_cap *caps;
 
       caps = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
       if (!caps) {
          ast_log(LOG_ERROR, "Could not allocate capabilities structure\n");
          return;
       }
 
       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");
          ao2_ref(caps, -1);
          return;
       }
 
       if (gH323Debug) {
          ast_verb(0, "Readformat before update %s\n",
            ast_format_get_name(ast_channel_readformat(p->owner)));
       }
       ast_format_cap_append(caps, fmt, 0);
       ast_channel_nativeformats_set(p->owner, caps);
       ao2_ref(caps, -1);
       ast_set_read_format(p->owner, ast_channel_readformat(p->owner));
       ast_channel_unlock(p->owner);
       } else
       ast_log(LOG_ERROR, "No owner found\n");
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_update_readformat\n");
 }

◆ ooh323_set_rtp_peer()

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
	)

static

Definition at line 4532 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_tech_pvt(), ast_channel_writeformat(), ast_free, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_get_and_cmp_remote_address, ast_sockaddr_isnull(), ast_sockaddr_port, ast_sockaddr_stringify_addr(), ast_strdup, ast_verb, ooh323_pvt::callToken, gH323Debug, ooh323_pvt::lock, LOG_ERROR, LOG_WARNING, NULL, ooh323_convertAsteriskCapToH323Cap(), and ooh323_pvt::redirip.

 {
    /* XXX Deal with Video */
    struct ooh323_pvt *p;
    int changed = 0;
    char *callToken = NULL;
 
    if (gH323Debug) {
       ast_verb(0, "---   ooh323_set_peer - %s\n", ast_channel_name(chan));
    }
 
    if (ooh323_convertAsteriskCapToH323Cap(ast_channel_writeformat(chan)) < 0) {
       ast_log(LOG_WARNING, "Unknown format.\n");
       return -1;
    }
    p = (struct ooh323_pvt *) ast_channel_tech_pvt(chan);
    if (!p) {
       ast_log(LOG_ERROR, "No Private Structure, this is bad\n");
       return -1;
    }
 
    ast_mutex_lock(&p->lock);
 
    if (rtp) {
       changed |= ast_rtp_instance_get_and_cmp_remote_address(rtp, &p->redirip);
    } else if (!ast_sockaddr_isnull(&p->redirip)) {
       changed = 1;
       memset(&p->redirip, 0, sizeof(p->redirip));
    }
 
    callToken = (p->callToken ? ast_strdup(p->callToken) : NULL);
 
    if (!callToken) {
       if (gH323Debug) {
          ast_verb(0, "  set_rtp_peer - No callToken\n");
       }
       ast_mutex_unlock(&p->lock);
       return -1;
    }
 
 
    if (changed) {
       if (!ast_sockaddr_isnull(&p->redirip)) {
          if (gH323Debug) {
             ast_verb(0, "ooh323_set_rtp_peer  %s -> %s:%d\n", ast_channel_name(chan), ast_sockaddr_stringify_addr(&p->redirip),
                      ast_sockaddr_port(&p->redirip));
          }
          ooUpdateLogChannels(callToken, ast_sockaddr_stringify_addr(&p->redirip),
                      ast_sockaddr_port(&p->redirip));
       } else {
          if (gH323Debug) {
             ast_verb(0, "ooh323_set_rtp_peer  return back to local\n");
          }
          ooUpdateLogChannels(callToken, "0.0.0.0" , 0);
       }
    }
 
    ast_mutex_unlock(&p->lock);
    ast_free(callToken);
    return 0;
 
 }

◆ ooh323_set_write_format()

void ooh323_set_write_format	(	ooCallData *	call,
		struct ast_format *	fmt,
		int	txframes
	)

Definition at line 1553 of file chan_ooh323.c.

References ao2_ref, ao2_replace, ast_channel_nativeformats(), ast_channel_nativeformats_set(), ast_channel_readformat(), ast_channel_trylock, ast_channel_unlock, ast_channel_writeformat(), ast_debug, ast_format_cap_alloc, ast_format_cap_append, AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_cap_get_names(), AST_FORMAT_CAP_NAMES_LEN, ast_format_cap_set_framing(), ast_format_get_name(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_codecs_payloads_set_rtpmap_type(), ast_rtp_instance_get_codecs(), ast_set_read_format(), ast_set_write_format(), ast_str_alloca, ast_verb, DEADLOCK_AVOIDANCE, ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, find_call(), gH323Debug, H323_DTMF_CISCO, H323_DTMF_RFC2833, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323_pvt::owner, ooh323_pvt::rtp, and ooh323_pvt::writeformat.

Referenced by ooh323c_start_transmit_channel().

 {
    struct ooh323_pvt *p = NULL;
 
    if (gH323Debug)
       ast_verb(0, "---   ooh323_update_writeformat %s/%d\n",
             ast_format_get_name(fmt), txframes);
 
    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);
 
    ao2_replace(p->writeformat, fmt);
 
    if (p->owner) {
       struct ast_format_cap *caps;
 
       caps = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
       if (!caps) {
          ast_log(LOG_ERROR, "Could not allocate capabilities structure\n");
          return;
       }
 
       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");
          ao2_ref(caps, -1);
          return;
       }
       if (gH323Debug) {
          struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
          ast_verb(0, "Writeformat before update %s/%s\n",
            ast_format_get_name(ast_channel_writeformat(p->owner)),
            ast_format_cap_get_names(ast_channel_nativeformats(p->owner), &codec_buf));
       }
 
       if (p->dtmfmode & H323_DTMF_RFC2833 && p->dtmfcodec) {
          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_codecs_payloads_set_rtpmap_type(ast_rtp_instance_get_codecs(p->rtp),
              p->rtp, p->dtmfcodec, "audio", "cisco-telephone-event", 0);
       }
 
       if (txframes) {
          ast_format_cap_set_framing(caps, txframes);
       }
       ast_format_cap_append(caps, fmt, 0);
       ast_channel_nativeformats_set(p->owner, caps);
       ao2_ref(caps, -1);
       ast_set_write_format(p->owner, ast_channel_writeformat(p->owner));
       ast_set_read_format(p->owner, ast_channel_readformat(p->owner));
       ast_channel_unlock(p->owner);
       } else
       ast_log(LOG_ERROR, "No owner found\n");
 
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug)
       ast_verb(0, "+++   ooh323_update_writeformat\n");
 }

◆ ooh323_write()

static int ooh323_write	(	struct ast_channel *	ast,
		struct ast_frame *	f
	)

static

Definition at line 1212 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_nativeformats(), ast_channel_readformat(), ast_channel_tech_pvt(), ast_channel_writeformat(), ast_debug, ast_format_cap_count(), ast_format_cap_get_names(), ast_format_cap_iscompatible_format(), AST_FORMAT_CAP_NAMES_LEN, AST_FORMAT_CMP_NOT_EQUAL, ast_format_get_name(), AST_FRAME_IMAGE, AST_FRAME_MODEM, AST_FRAME_VOICE, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_rtp_instance_write(), ast_set_write_format(), ast_str_alloca, ast_test_flag, ast_udptl_write(), ooh323_pvt::callToken, ast_frame::datalen, ast_frame_subclass::format, ast_frame::frametype, H323_OUTGOING, ast_frame_subclass::integer, ooh323_pvt::lastrtptx, ooh323_pvt::lock, LOG_WARNING, NULL, ooh323_pvt::progsent, ooh323_pvt::rtp, ast_frame::subclass, and ooh323_pvt::udptl.

 {
    struct ooh323_pvt *p = ast_channel_tech_pvt(ast);
    int res = 0;
 
    if (p) {
       ast_mutex_lock(&p->lock);
 
       p->lastrtptx = time(NULL);
 
       if (f->frametype == AST_FRAME_MODEM) {
          ast_debug(1, "Send UDPTL %u/%d len %d for %s\n",
             f->frametype, f->subclass.integer, f->datalen, ast_channel_name(ast));
          if (p->udptl)
             res = ast_udptl_write(p->udptl, f);
          ast_mutex_unlock(&p->lock);
          return res;
       }
 
 
       if (f->frametype == AST_FRAME_VOICE) {
 /* sending progress for first */
          if (!ast_test_flag(p, H323_OUTGOING) && !p->progsent &&
                p->callToken) {
             ooManualProgress(p->callToken);
             p->progsent = 1;
          }
 
 
          if (ast_format_cap_iscompatible_format(ast_channel_nativeformats(ast), f->subclass.format) == AST_FORMAT_CMP_NOT_EQUAL) {
             if (ast_format_cap_count(ast_channel_nativeformats(ast))) {
                struct ast_str *codec_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
                ast_log(LOG_WARNING,
                      "Asked to transmit frame type %s, while native formats is %s (read/write = %s/%s)\n",
                      ast_format_get_name(f->subclass.format),
                      ast_format_cap_get_names(ast_channel_nativeformats(ast), &codec_buf),
                      ast_format_get_name(ast_channel_readformat(ast)),
                      ast_format_get_name(ast_channel_writeformat(ast)));
 
                ast_set_write_format(ast, f->subclass.format);
             } else {
                /* ast_set_write_format(ast, f->subclass);
                ast->nativeformats = f->subclass; */
             }
          ast_mutex_unlock(&p->lock);
          return 0;
          }
 
       if (p->rtp)
          res = ast_rtp_instance_write(p->rtp, f);
 
       ast_mutex_unlock(&p->lock);
 
       } else if (f->frametype == AST_FRAME_IMAGE) {
          ast_mutex_unlock(&p->lock);
          return 0;
       } else {
          ast_log(LOG_WARNING, "Can't send %u type frames with OOH323 write\n",
                             f->frametype);
          ast_mutex_unlock(&p->lock);
          return 0;
       }
 
    }
 
    return res;
 }

◆ reload_config()

static int reload_config ( int reload )

Definition at line 2813 of file chan_ooh323.c.

References ast_calloc, ast_category_browse(), ast_channel_string2amaflag(), ast_config_AST_LOG_DIR, ast_config_destroy(), ast_config_load, ast_copy_string(), ast_false(), ast_format_cap_append, ast_format_cap_remove_by_type(), ast_format_cap_update_by_allow_disallow(), ast_format_ulaw, ast_free, ast_jb_read_conf(), ast_log, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_lock, ast_mutex_unlock, ast_parse_arg(), ast_sockaddr_is_ipv6(), ast_strdup, ast_strdupa, ast_strlen_zero, ast_true(), ast_variable_browse(), ast_variable_retrieve(), ast_verb, bindaddr, buf, build_peer(), build_user(), config, CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEUNCHANGED, DEFAULT_CONTEXT, DEFAULT_H323ACCNT, DEFAULT_H323ID, DEFAULT_LOGFILE, delete_peers(), delete_users(), FALSE, FAXDETECT_CNG, FAXDETECT_T38, format, ooh323_pvt::g729onlyA, gAccountcode, gAliasList, gAMAFLAGS, gANIasDNI, gBeMaster, gCallerID, gContext, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gGatekeeper, gH323Debug, gIncomingLimit, gIP, gIsGateway, global_jbconf, gLogFile, gMediaWaitForConnect, gNat, gOutgoingLimit, gPort, gRasGkMode, gRASIP, gRTDRCount, gRTDRInterval, gRTPTimeout, gT38Support, gTOS, gTRCLVL, gTunneling, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, IPTOS_MINCOST, ast_variable::lineno, ast_user_list::lock, ast_peer_list::lock, LOG_ERROR, LOG_NOTICE, LOG_WARNING, manufacturer, ooh323_config::mTCPPortEnd, ooh323_config::mTCPPortStart, ast_variable::name, ast_variable::next, ooh323_pvt::next, ooh323_user::next, ooh323_peer::next, NULL, ooconfig, PARSE_ADDR, ooh323_pvt::peer, peerl, ast_peer_list::peers, RESULT_SUCCESS, strsep(), t35countrycode, t35extensions, T38_DISABLED, T38_ENABLED, T38_FAXGW, tmp(), ooh323_pvt::user, userl, ast_user_list::users, v6mode, ast_variable::value, vendor, and version.

Referenced by load_module(), and ooh323_do_reload().

 {
    int format;
    struct ooAliases  *pNewAlias = NULL, *cur, *prev;
    struct ast_config *cfg;
    struct ast_variable *v;
    struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
    struct ooh323_user *user = NULL;
    struct ooh323_peer *peer = NULL;
    char *cat;
    const char *utype;
 
    if (gH323Debug)
       ast_verb(0, "---   reload_config\n");
 
    cfg = ast_config_load((char*)config, config_flags);
 
    /* We *must* have a config file otherwise stop immediately */
    if (!cfg) {
       ast_log(LOG_NOTICE, "Unable to load config %s, OOH323 disabled\n", config);
       return 1;
    } else if (cfg == CONFIG_STATUS_FILEUNCHANGED)
       return RESULT_SUCCESS;
 
    if (reload) {
       delete_users();
       delete_peers();
       if (gH323Debug) {
          ast_verb(0, "  reload_config - Freeing up alias list\n");
       }
       cur = gAliasList;
       while (cur) {
          prev = cur;
          cur = cur->next;
          ast_free(prev->value);
          ast_free(prev);
       }
       gAliasList = NULL;
       ooH323EpClearAllAliases();
    }
 
    /* Inintialize everything to default */
    snprintf(gLogFile, sizeof(gLogFile), "%s/%s", ast_config_AST_LOG_DIR, DEFAULT_LOGFILE);
    gPort = 1720;
    gIP[0] = '\0';
    strcpy(gCallerID, DEFAULT_H323ID);
    ast_format_cap_remove_by_type(gCap, AST_MEDIA_TYPE_UNKNOWN);
    ast_format_cap_append(gCap, ast_format_ulaw, 0);
    gDTMFMode = H323_DTMF_RFC2833;
    gDTMFCodec = 101;
    gFAXdetect = FAXDETECT_CNG;
    gT38Support = T38_FAXGW;
    gTRCLVL = OOTRCLVLERR;
    gRasGkMode = RasNoGatekeeper;
    gGatekeeper[0] = '\0';
    gRASIP[0] = '\0';
    gRTPTimeout = 60;
    gNat = FALSE;
    gRTDRInterval = 0;
    gRTDRCount = 0;
    strcpy(gAccountcode, DEFAULT_H323ACCNT);
    gFastStart = 1;
    gTunneling = 1;
    gTOS = 0;
    strcpy(gContext, DEFAULT_CONTEXT);
    gAliasList = NULL;
    gMediaWaitForConnect = 0;
    ooconfig.mTCPPortStart = 12030;
    ooconfig.mTCPPortEnd = 12230;
    memcpy(&global_jbconf, &default_jbconf, sizeof(struct ast_jb_conf));
 
    v = ast_variable_browse(cfg, "general");
    while (v) {
 
       if (!ast_jb_read_conf(&global_jbconf, v->name, v->value)) {
          v = v->next;
          continue;
       }
 
       if (!strcasecmp(v->name, "port")) {
          gPort = (int)strtol(v->value, NULL, 10);
       } else if (!strcasecmp(v->name, "bindaddr")) {
          ast_copy_string(gIP, v->value, sizeof(gIP));
          if (ast_parse_arg(v->value, PARSE_ADDR, &bindaddr)) {
             ast_log(LOG_WARNING, "Invalid address: %s\n", v->value);
             ast_config_destroy(cfg);
             return 1;
          }
          if (ast_sockaddr_is_ipv6(&bindaddr)) {
             v6mode = 1;
          }
       } else if (!strcasecmp(v->name, "h225portrange")) {
          char* endlimit = 0;
                char temp[512];
          ast_copy_string(temp, v->value, sizeof(temp));
          endlimit = strchr(temp, ',');
          if (endlimit) {
             *endlimit = '\0';
             endlimit++;
             ooconfig.mTCPPortStart = atoi(temp);
             ooconfig.mTCPPortEnd = atoi(endlimit);
 
          } else {
             ast_log(LOG_ERROR, "h225portrange: Invalid format, separate port range with \",\"\n");
          }
       } else if (!strcasecmp(v->name, "gateway")) {
          gIsGateway = ast_true(v->value);
             } else if (!strcasecmp(v->name, "faststart")) {
          gFastStart = ast_true(v->value);
          if (gFastStart)
             ooH323EpEnableFastStart();
          else
             ooH323EpDisableFastStart();
       } else if (!strcasecmp(v->name, "mediawaitforconnect")) {
          gMediaWaitForConnect = ast_true(v->value);
          if (gMediaWaitForConnect)
             ooH323EpEnableMediaWaitForConnect();
          else
             ooH323EpDisableMediaWaitForConnect();
       } else if (!strcasecmp(v->name, "h245tunneling")) {
          gTunneling = ast_true(v->value);
          if (gTunneling)
             ooH323EpEnableH245Tunneling();
          else
             ooH323EpDisableH245Tunneling();
       } else if (!strcasecmp(v->name, "directrtp") || !strcasecmp(v->name, "directmedia")) {
          gDirectRTP = ast_true(v->value);
          gEarlyDirect = ast_true(v->value);
       } else if (!strcasecmp(v->name, "earlydirect") || !strcasecmp(v->name, "directrtpsetup")) {
          gEarlyDirect = ast_true(v->value);
       } else if (!strcasecmp(v->name, "g729onlyA")) {
          g729onlyA = ast_true(v->value);
       } else if (!strcasecmp(v->name, "roundtrip")) {
          sscanf(v->value, "%d,%d", &gRTDRCount, &gRTDRInterval);
             } else if (!strcasecmp(v->name, "trybemaster")) {
          gBeMaster = ast_true(v->value);
          if (gBeMaster)
             ooH323EpTryBeMaster(1);
          else
             ooH323EpTryBeMaster(0);
       } else if (!strcasecmp(v->name, "h323id")) {
                pNewAlias = ast_calloc(1, sizeof(struct ooAliases));
          if (!pNewAlias) {
             ast_log(LOG_ERROR, "Failed to allocate memory for h323id alias\n");
             ast_config_destroy(cfg);
             return 1;
          }
          if (gAliasList == NULL) { /* first h323id - set as callerid if callerid is not set */
             ast_copy_string(gCallerID, v->value, sizeof(gCallerID));
          }
          pNewAlias->type =  T_H225AliasAddress_h323_ID;
          pNewAlias->value = ast_strdup(v->value);
          pNewAlias->next = gAliasList;
          gAliasList = pNewAlias;
          pNewAlias = 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) {
                   pNewAlias = ast_calloc(1, sizeof(struct ooAliases));
             if (!pNewAlias) {
                ast_log(LOG_ERROR, "Failed to allocate memory for e164 alias\n");
                ast_config_destroy(cfg);
                return 1;
             }
             pNewAlias->type =  T_H225AliasAddress_dialedDigits;
             pNewAlias->value = ast_strdup(v->value);
             pNewAlias->next = gAliasList;
             gAliasList = pNewAlias;
             pNewAlias = NULL;
          } else {
             ast_log(LOG_ERROR, "Invalid e164: %s\n", v->value);
          }
       } else if (!strcasecmp(v->name, "email")) {
                pNewAlias = ast_calloc(1, sizeof(struct ooAliases));
          if (!pNewAlias) {
             ast_log(LOG_ERROR, "Failed to allocate memory for email alias\n");
             ast_config_destroy(cfg);
             return 1;
          }
          pNewAlias->type =  T_H225AliasAddress_email_ID;
          pNewAlias->value = ast_strdup(v->value);
          pNewAlias->next = gAliasList;
          gAliasList = pNewAlias;
          pNewAlias = NULL;
       } else if (!strcasecmp(v->name, "t35country")) {
          t35countrycode = atoi(v->value);
       } else if (!strcasecmp(v->name, "t35extensions")) {
          t35extensions = atoi(v->value);
       } else if (!strcasecmp(v->name, "manufacturer")) {
          manufacturer = atoi(v->value);
       } else if (!strcasecmp(v->name, "vendorid")) {
          ast_copy_string(vendor, v->value, sizeof(vendor));
       } else if (!strcasecmp(v->name, "versionid")) {
          ast_copy_string(version, v->value, sizeof(version));
       } else if (!strcasecmp(v->name, "callerid")) {
          ast_copy_string(gCallerID, v->value, sizeof(gCallerID));
       } else if (!strcasecmp(v->name, "incominglimit")) {
          gIncomingLimit = atoi(v->value);
       } else if (!strcasecmp(v->name, "outgoinglimit")) {
          gOutgoingLimit = atoi(v->value);
       } else if (!strcasecmp(v->name, "gatekeeper")) {
          if (!strcasecmp(v->value, "DISABLE")) {
             gRasGkMode = RasNoGatekeeper;
          } else if (!strcasecmp(v->value, "DISCOVER")) {
             gRasGkMode = RasDiscoverGatekeeper;
          } else {
             gRasGkMode = RasUseSpecificGatekeeper;
                      ast_copy_string(gGatekeeper, v->value, sizeof(gGatekeeper));
          }
       } else if (!strcasecmp(v->name, "localras")) {
               ast_copy_string(gRASIP, v->value, sizeof(gRASIP));
          ast_verb(3, "  == Setting RAS IP to %s\n", gRASIP);
       } else if (!strcasecmp(v->name, "logfile")) {
          if (v->value[0] == '/') {
             ast_copy_string(gLogFile, v->value, sizeof(gLogFile));
          } else {
             snprintf(gLogFile, sizeof(gLogFile), "%s/%s", ast_config_AST_LOG_DIR, v->value);
          }
       } else if (!strcasecmp(v->name, "context")) {
                ast_copy_string(gContext, v->value, sizeof(gContext));
                ast_verb(3, "  == Setting default context to %s\n", gContext);
       } else if (!strcasecmp(v->name, "nat")) {
          gNat = ast_true(v->value);
       } else if (!strcasecmp(v->name, "rtptimeout")) {
          gRTPTimeout = atoi(v->value);
          if (gRTPTimeout < 0)
             gRTPTimeout = 60;
       } else if (!strcasecmp(v->name, "tos")) {
          if (sscanf(v->value, "%30i", &format) == 1)
             gTOS = format & 0xff;
          else if (!strcasecmp(v->value, "lowdelay"))
             gTOS = IPTOS_LOWDELAY;
          else if (!strcasecmp(v->value, "throughput"))
             gTOS = IPTOS_THROUGHPUT;
          else if (!strcasecmp(v->value, "reliability"))
             gTOS = IPTOS_RELIABILITY;
          else if (!strcasecmp(v->value, "mincost"))
             gTOS = IPTOS_MINCOST;
          else if (!strcasecmp(v->value, "none"))
             gTOS = 0;
          else
             ast_log(LOG_WARNING, "Invalid tos value at line %d, should be "
                                  "'lowdelay', 'throughput', 'reliability', "
                                  "'mincost', or 'none'\n", v->lineno);
       } else if (!strcasecmp(v->name, "amaflags")) {
          gAMAFLAGS = ast_channel_string2amaflag(v->value);
       } else if (!strcasecmp(v->name, "accountcode")) {
          ast_copy_string(gAccountcode, v->value, sizeof(gAccountcode));
       } else if (!strcasecmp(v->name, "disallow")) {
          ast_format_cap_update_by_allow_disallow(gCap, 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(gCap, tcodecs, 1);
       } else if (!strcasecmp(v->name, "dtmfmode")) {
          if (!strcasecmp(v->value, "inband"))
             gDTMFMode = H323_DTMF_INBAND;
          else if (!strcasecmp(v->value, "rfc2833"))
             gDTMFMode = H323_DTMF_RFC2833;
          else if (!strcasecmp(v->value, "cisco"))
             gDTMFMode = H323_DTMF_CISCO;
          else if (!strcasecmp(v->value, "q931keypad"))
             gDTMFMode = H323_DTMF_Q931;
          else if (!strcasecmp(v->value, "h245alphanumeric"))
             gDTMFMode = H323_DTMF_H245ALPHANUMERIC;
          else if (!strcasecmp(v->value, "h245signal"))
             gDTMFMode = H323_DTMF_H245SIGNAL;
          else {
             ast_log(LOG_WARNING, "Unknown dtmf mode '%s', using rfc2833\n",
                                                                     v->value);
             gDTMFMode = H323_DTMF_RFC2833;
          }
       } else if (!strcasecmp(v->name, "relaxdtmf")) {
          gDTMFMode |= ast_true(v->value) ? H323_DTMF_INBANDRELAX : 0;
       } else if (!strcasecmp(v->name, "dtmfcodec") && atoi(v->value)) {
          gDTMFCodec = atoi(v->value);
       } else if (!strcasecmp(v->name, "faxdetect")) {
          if (ast_true(v->value)) {
             gFAXdetect = FAXDETECT_CNG | FAXDETECT_T38;
          } else if (ast_false(v->value)) {
             gFAXdetect = 0;
          } else {
             char *buf = ast_strdupa(v->value);
             char *word, *next = buf;
             gFAXdetect = 0;
             while ((word = strsep(&next, ","))) {
                if (!strcasecmp(word, "cng")) {
                   gFAXdetect |= FAXDETECT_CNG;
                } else if (!strcasecmp(word, "t38")) {
                   gFAXdetect |= 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"))
             gT38Support = T38_DISABLED;
          if (!strcasecmp(v->value, "no"))
             gT38Support = T38_DISABLED;
          else if (!strcasecmp(v->value, "faxgw"))
             gT38Support = T38_FAXGW;
          else if (!strcasecmp(v->value, "yes"))
             gT38Support = T38_ENABLED;
       } else if (!strcasecmp(v->name, "tracelevel")) {
          gTRCLVL = atoi(v->value);
          ooH323EpSetTraceLevel(gTRCLVL);
       } else if (!strcasecmp(v->name, "aniasdni")) {
          gANIasDNI = ast_true(v->value);
       }
       v = v->next;
    }
 
    for (cat = ast_category_browse(cfg, NULL); cat; cat = ast_category_browse(cfg, cat)) {
       if (strcasecmp(cat, "general")) {
          int friend_type = 0;
          utype = ast_variable_retrieve(cfg, cat, "type");
          if (utype) {
             friend_type = strcasecmp(utype, "friend");
             if (!strcmp(utype, "user") || 0 == friend_type) {
                user = build_user(cat, ast_variable_browse(cfg, cat));
                if (user) {
                   ast_mutex_lock(&userl.lock);
                   user->next = userl.users;
                   userl.users = user;
                   ast_mutex_unlock(&userl.lock);
                } else {
                   ast_log(LOG_WARNING, "Failed to build user %s\n", cat);
                }
             }
             if (!strcasecmp(utype, "peer") || 0 == friend_type) {
                peer = build_peer(cat, ast_variable_browse(cfg, cat), friend_type);
                if (peer) {
                   ast_mutex_lock(&peerl.lock);
                   peer->next = peerl.peers;
                   peerl.peers = peer;
                   ast_mutex_unlock(&peerl.lock);
                } else {
                   ast_log(LOG_WARNING, "Failed to build peer %s\n", cat);
                }
             }
          }
       }
    }
    ast_config_destroy(cfg);
 
 
    /* Determine ip address if neccessary */
    if (ast_strlen_zero(gIP)) {
       ooGetLocalIPAddress(gIP);
       if (!strcmp(gIP, "127.0.0.1") || !strcmp(gIP, "::1")) {
          ast_log(LOG_NOTICE, "Failed to determine local ip address. Please "
                             "specify it in ooh323.conf. OOH323 Disabled\n");
          return 1;
       }
    }
 
    if (gH323Debug)
       ast_verb(0, "+++   reload_config\n");
 
    return 0;
 
 }

◆ reload_module()

static int reload_module ( void )

static

Definition at line 3981 of file chan_ooh323.c.

References ast_mutex_lock, ast_mutex_unlock, ast_verb, gH323Debug, h323_reload_lock, h323_reloading, and restart_monitor().

Referenced by ooh323_convert_hangupcause_h323ToAsterisk().

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

◆ restart_monitor()

static int restart_monitor ( void )

Start the channel monitor thread.

Definition at line 4082 of file chan_ooh323.c.

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_pthread_create, AST_PTHREADT_NULL, AST_PTHREADT_STOP, do_monitor(), LOG_ERROR, LOG_WARNING, monitor_thread, monlock, and NULL.

Referenced by handle_cli_ooh323_reload(), load_module(), ooh323_request(), and reload_module().

 {
    pthread_attr_t attr;
 
    /* If we're supposed to be stopped -- stay stopped */
    if (monitor_thread == AST_PTHREADT_STOP)
       return 0;
    if (ast_mutex_lock(&monlock)) {
       ast_log(LOG_WARNING, "Unable to lock monitor\n");
       return -1;
    }
    if (monitor_thread == pthread_self()) {
       ast_mutex_unlock(&monlock);
       ast_log(LOG_WARNING, "Cannot kill myself\n");
       return -1;
    }
    if (monitor_thread != AST_PTHREADT_NULL) {
       /* Wake up the thread */
       pthread_kill(monitor_thread, SIGURG);
    } else {
       pthread_attr_init(&attr);
       pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
       /* Start a new monitor */
       if (ast_pthread_create(&monitor_thread, &attr, do_monitor, NULL) < 0) {
          ast_mutex_unlock(&monlock);
          ast_log(LOG_ERROR, "Unable to start monitor thread.\n");
          return -1;
       }
    }
    ast_mutex_unlock(&monlock);
    return 0;
 }

◆ setup_rtp_connection()

void setup_rtp_connection	(	ooCallData *	call,
		const char *	remoteIp,
		int	remotePort
	)

Definition at line 4775 of file chan_ooh323.c.

References ast_format_cmp(), AST_FORMAT_CMP_EQUAL, ast_format_g726_aal2, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_parse_arg(), ast_rtp_codecs_payloads_set_rtpmap_type(), ast_rtp_instance_get_codecs(), ast_rtp_instance_set_remote_address, AST_RTP_OPT_G726_NONSTANDARD, ast_sockaddr_set_port, ast_verb, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, PARSE_ADDR, ooh323_pvt::rtp, and ooh323_pvt::writeformat.

Referenced by ooh323c_start_transmit_channel().

 {
    struct ooh323_pvt *p = NULL;
    struct ast_sockaddr tmp;
 
    if (gH323Debug)
       ast_verb(0, "---   setup_rtp_connection %s:%d\n", remoteIp, remotePort);
 
    /* Find the call or allocate a private structure if call not found */
    p = find_call(call);
 
    if (!p || !p->rtp) {
       ast_log(LOG_ERROR, "Something is wrong: rtp\n");
       return;
    }
 
    ast_mutex_lock(&p->lock);
 
    ast_parse_arg(remoteIp, PARSE_ADDR, &tmp);
    ast_sockaddr_set_port(&tmp, remotePort);
    ast_rtp_instance_set_remote_address(p->rtp, &tmp);
 
    if (ast_format_cmp(p->writeformat, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL) {
                 ast_rtp_codecs_payloads_set_rtpmap_type(ast_rtp_instance_get_codecs(p->rtp), p->rtp, 2,
                      "audio", "G726-32", AST_RTP_OPT_G726_NONSTANDARD);
    }
 
    ast_mutex_unlock(&p->lock);
 
    if(gH323Debug)
       ast_verb(0, "+++   setup_rtp_connection\n");
 
    return;
 }

◆ setup_rtp_remote()

void setup_rtp_remote	(	ooCallData *	call,
		const char *	remoteIp,
		int	remotePort
	)

Definition at line 4736 of file chan_ooh323.c.

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_parse_arg(), ast_rtp_instance_set_remote_address, ast_sockaddr_set_port, ast_verb, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, PARSE_ADDR, and ooh323_pvt::rtp.

Referenced by load_module().

 {
    struct ooh323_pvt *p = NULL;
    struct ast_sockaddr tmp;
 
    if (gH323Debug) {
       ast_verb(0, "---   setup_rtp_remote %s:%d\n", remoteIp, remotePort);
    }
    if (!remoteIp || !remoteIp[0] || !remotePort) {
       if (gH323Debug) {
          ast_verb(0, "+++ setup_rtp_remote no data\n");
       }
       return;
    }
 
    /* Find the call or allocate a private structure if call not found */
    p = find_call(call);
 
    if (!p || !p->rtp) {
       ast_log(LOG_ERROR, "Something is wrong: rtp\n");
       return;
    }
 
    ast_mutex_lock(&p->lock);
 
    ast_parse_arg(remoteIp, PARSE_ADDR, &tmp);
    ast_sockaddr_set_port(&tmp, remotePort);
    ast_rtp_instance_set_remote_address(p->rtp, &tmp);
 
    ast_mutex_unlock(&p->lock);
 
    if (gH323Debug) {
       ast_verb(0, "+++   setup_rtp_remote\n");
    }
 
    return;
 }

◆ setup_udptl_connection()

void setup_udptl_connection	(	ooCallData *	call,
		const char *	remoteIp,
		int	remotePort
	)

Definition at line 4839 of file chan_ooh323.c.

References ast_channel_name(), ast_channel_trylock, ast_channel_unlock, AST_CONTROL_T38_PARAMETERS, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_parse_arg(), ast_queue_control_data(), ast_sockaddr_port, ast_sockaddr_set_port, ast_sockaddr_stringify_host(), AST_T38_NEGOTIATED, AST_T38_RATE_14400, ast_udptl_get_far_max_ifp(), ast_udptl_set_peer(), ast_udptl_set_tag(), ast_verb, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ooh323_pvt::lastTxT38, ooh323_pvt::lock, LOG_ERROR, ast_control_t38_parameters::max_ifp, NULL, ooh323_pvt::owner, PARSE_ADDR, ast_control_t38_parameters::rate, ast_control_t38_parameters::request_response, T38_ENABLED, ooh323_pvt::t38_tx_enable, ooh323_pvt::t38support, and ooh323_pvt::udptl.

Referenced by ooh323c_start_transmit_datachannel().

 {
    struct ooh323_pvt *p = NULL;
    struct ast_sockaddr them;
 
    if (gH323Debug)
       ast_verb(0, "---   setup_udptl_connection\n");
 
    /* Find the call or allocate a private structure if call not found */
    p = find_call(call);
 
    if (!p) {
       ast_log(LOG_ERROR, "Something is wrong: rtp\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;
    }
 
    ast_parse_arg(remoteIp, PARSE_ADDR, &them);
    ast_sockaddr_set_port(&them, remotePort);
 
    ast_udptl_set_peer(p->udptl, &them);
    ast_udptl_set_tag(p->udptl, "%s", ast_channel_name(p->owner));
    p->t38_tx_enable = 1;
    p->lastTxT38 = time(NULL);
    if (p->t38support == T38_ENABLED) {
       struct ast_control_t38_parameters parameters = { .request_response = 0 };
       parameters.request_response = AST_T38_NEGOTIATED;
       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));
    }
    if (gH323Debug) {
       ast_debug(1, "Receiving UDPTL  %s:%d\n", ast_sockaddr_stringify_host(&them),
                      ast_sockaddr_port(&them));
    }
 
    ast_channel_unlock(p->owner);
    ast_mutex_unlock(&p->lock);
 
    if(gH323Debug)
       ast_verb(0, "+++   setup_udptl_connection\n");
 
    return;
 }

◆ unload_module()

static int unload_module ( void )

static

Definition at line 4296 of file chan_ooh323.c.

References ao2_ref, ast_channel_unregister(), ast_cli_unregister_multiple(), ast_free, ast_log, ast_mutex_lock, ast_mutex_unlock, AST_PTHREADT_NULL, AST_PTHREADT_STOP, ast_rtp_glue_unregister(), ast_softhangup(), AST_SOFTHANGUP_APPUNLOAD, ast_unregister_atexit(), ast_verb, ast_channel_tech::capabilities, delete_peers(), delete_users(), gAliasList, gH323Debug, iflist, iflock, LOG_WARNING, monitor_thread, monlock, ooh323_pvt::next, NULL, ooh323_destroy(), ooh323c_stop_stack_thread(), and ooh323_pvt::owner.

Referenced by ooh323_convert_hangupcause_h323ToAsterisk().

 {
    struct ooh323_pvt *p;
    struct ooAliases *cur = NULL, *prev = NULL;
 
    if (gH323Debug) {
       ast_verb(0, "--- ooh323  unload_module \n");
    }
    /* First, take us out of the channel loop */
    ast_cli_unregister_multiple(cli_ooh323, sizeof(cli_ooh323) / sizeof(struct ast_cli_entry));
    ast_rtp_glue_unregister(&ooh323_rtp);
    ast_channel_unregister(&ooh323_tech);
 #if 0
    ast_unregister_atexit(&ast_ooh323c_exit);
 #endif
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module - hanging up all interfaces\n");
    }
    if (!ast_mutex_lock(&iflock)) {
       /* Hangup all interfaces if they have an owner */
       p = iflist;
       while (p) {
          if (p->owner) {
             ast_softhangup(p->owner, AST_SOFTHANGUP_APPUNLOAD);
          }
          p = p->next;
       }
       iflist = NULL;
       ast_mutex_unlock(&iflock);
    } else {
       ast_log(LOG_WARNING, "Unable to lock the interface list\n");
       return -1;
    }
 
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module - stopping monitor thread\n");
    }
    if (monitor_thread != AST_PTHREADT_NULL) {
       if (!ast_mutex_lock(&monlock)) {
          if (monitor_thread && (monitor_thread != AST_PTHREADT_STOP)) {
             pthread_cancel(monitor_thread);
             pthread_kill(monitor_thread, SIGURG);
             pthread_join(monitor_thread, NULL);
          }
          monitor_thread = AST_PTHREADT_STOP;
          ast_mutex_unlock(&monlock);
       } else {
          ast_log(LOG_WARNING, "Unable to lock the monitor\n");
          return -1;
       }
    }
 
 
    if (gH323Debug) {
       ast_verb(0, "   unload_module - stopping stack thread\n");
    }
    ooh323c_stop_stack_thread();
 
 
    if (gH323Debug) {
       ast_verb(0, "   unload_module - freeing up memory used by interfaces\n");
    }
    if (!ast_mutex_lock(&iflock)) {
       struct ooh323_pvt *pl;
 
       /* Destroy all the interfaces and free their memory */
       p = iflist;
       while (p) {
          pl = p;
          p = p->next;
          /* Free associated memory */
          ooh323_destroy(pl);
       }
       iflist = NULL;
       ast_mutex_unlock(&iflock);
    } else {
       ast_log(LOG_WARNING, "Unable to lock the interface list\n");
       return -1;
    }
 
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module - deleting users\n");
    }
    delete_users();
 
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module - deleting peers\n");
    }
    delete_peers();
 
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module - Freeing up alias list\n");
    }
    cur = gAliasList;
    while (cur) {
      prev = cur;
      cur = cur->next;
      ast_free(prev->value);
      ast_free(prev);
    }
    gAliasList = NULL;
 
 
    if (gH323Debug) {
       ast_verb(0, "  unload_module- destroying OOH323 endpoint \n");
    }
    ooH323EpDestroy();
 
    if (gH323Debug) {
       ast_verb(0, "+++ ooh323  unload_module \n");
    }
 
    ao2_ref(gCap, -1);
    gCap = NULL;
    ao2_ref(ooh323_tech.capabilities, -1);
    ooh323_tech.capabilities = NULL;
    return 0;
 }

◆ update_our_aliases()

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

Definition at line 4949 of file chan_ooh323.c.

References ast_copy_string(), ooh323_pvt::callee_dialedDigits, ooh323_pvt::callee_email, ooh323_pvt::callee_h323id, ooh323_pvt::callee_url, and NULL.

Referenced by ooh323_onReceivedSetup().

 {
    int updated = -1;
    ooAliases *psAlias = NULL;
 
    if (!call->ourAliases)
       return updated;
    for (psAlias = call->ourAliases; psAlias; psAlias = psAlias->next) {
       if (psAlias->type == T_H225AliasAddress_h323_ID) {
          ast_copy_string(p->callee_h323id, psAlias->value, sizeof(p->callee_h323id));
          updated = 1;
       }
       if (psAlias->type == T_H225AliasAddress_dialedDigits) {
          ast_copy_string(p->callee_dialedDigits, psAlias->value,
                                         sizeof(p->callee_dialedDigits));
          updated = 1;
       }
       if (psAlias->type == T_H225AliasAddress_url_ID) {
          ast_copy_string(p->callee_url, psAlias->value, sizeof(p->callee_url));
          updated = 1;
       }
       if (psAlias->type == T_H225AliasAddress_email_ID) {
          ast_copy_string(p->callee_email, psAlias->value, sizeof(p->callee_email));
          updated = 1;
       }
    }
    return updated;
 }

Variable Documentation

◆ __mod_info

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

Definition at line 5250 of file chan_ooh323.c.