chan_ooh323.c File Reference

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

Include dependency graph for chan_ooh323.c:

Go to the source code of this file.

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

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

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static struct ooh323_peer *	build_peer (const char *name, struct ast_variable *v, int friend_type)
static struct ooh323_user *	build_user (const char *name, struct ast_variable *v)
void	close_rtp_connection (ooCallData *call)
void	close_udptl_connection (ooCallData *call)
int	configure_local_rtp (struct ooh323_pvt *p, ooCallData *call)
int	delete_peers ()
int	delete_users ()
static void *	do_monitor (void *data)
static struct ooh323_pvt *	find_call (ooCallData *call)
struct ooh323_peer *	find_friend (const char *name, int port)
struct ooh323_peer *	find_peer (const char *name, int port)
struct ooh323_user *	find_user (const char *name, const char *ip)
static int	function_ooh323_read (struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
	OOH323 Dialplan function - reads ooh323 settings.
static int	function_ooh323_write (struct ast_channel *chan, const char *cmd, char *data, const char *value)
	OOH323 Dialplan function - writes ooh323 settings.
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)
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 = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .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 = AST_MUTEX_INIT_VALUE
static int	h323_reloading = 0
static struct ooh323_pvt *	iflist = NULL
static ast_mutex_t	iflock = AST_MUTEX_INIT_VALUE
static struct io_context *	io
static int	manufacturer = 0
static pthread_t	monitor_thread = AST_PTHREADT_NULL
static ast_mutex_t	monlock = AST_MUTEX_INIT_VALUE
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 = AST_MUTEX_INIT_VALUE
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 = AST_MUTEX_INIT_VALUE
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.

DEFAULT_H323ACCNT

#define DEFAULT_H323ACCNT   "ast_h323"

Definition at line 86 of file chan_ooh323.c.

DEFAULT_H323ID

#define DEFAULT_H323ID   "Asterisk PBX"

Definition at line 84 of file chan_ooh323.c.

DEFAULT_LOGFILE

#define DEFAULT_LOGFILE   "h323_log"

Definition at line 85 of file chan_ooh323.c.

FAXDETECT_CNG

#define FAXDETECT_CNG   1

Definition at line 105 of file chan_ooh323.c.

FAXDETECT_T38

#define FAXDETECT_T38   2

Definition at line 106 of file chan_ooh323.c.

FORMAT

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

FORMAT1

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

FORMAT_STRING_SIZE

#define FORMAT_STRING_SIZE   512

Definition at line 80 of file chan_ooh323.c.

H323_ALREADYGONE

#define H323_ALREADYGONE   (1<<5)

Definition at line 94 of file chan_ooh323.c.

H323_DISABLEGK

#define H323_DISABLEGK   (1<<7)

Definition at line 96 of file chan_ooh323.c.

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.

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.

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.

MAXT30

#define MAXT30   240

Definition at line 99 of file chan_ooh323.c.

T38_DISABLED

#define T38_DISABLED   0

Definition at line 101 of file chan_ooh323.c.

T38_ENABLED

#define T38_ENABLED   1

Definition at line 102 of file chan_ooh323.c.

T38_FAXGW

#define T38_FAXGW   1

Definition at line 103 of file chan_ooh323.c.

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.

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

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_peer::g729onlyA, g729onlyA, gAccountcode, gAMAFLAGS, gCap, 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, ooh323_peer::name, name, ast_variable::name, ooh323_peer::nat, ast_variable::next, NULL, ooh323_delete_peer(), ooh323_peer::outgoinglimit, PARSE_ADDR, 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, ooh323_peer::url, and ast_variable::value.

Referenced by reload_config().

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.

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

References 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, FAXDETECT_CNG, FAXDETECT_T38, g729onlyA, gAccountcode, gAMAFLAGS, gCap, gContext, gDirectRTP, gDTMFCodec, gDTMFMode, gEarlyDirect, gFastStart, gFAXdetect, gH323Debug, gNat, gRTPTimeout, gT38Support, gTunneling, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_DTMF_Q931, H323_DTMF_RFC2833, ast_variable::lineno, LOG_WARNING, name, ast_variable::name, ast_variable::next, NULL, PARSE_ADDR, strsep(), T38_DISABLED, T38_ENABLED, T38_FAXGW, and ast_variable::value.

Referenced by reload_config().

close_rtp_connection()

void close_rtp_connection

(

ooCallData *

call

)

Definition at line 4810 of file chan_ooh323.c.

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

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

Referenced by ooh323c_stop_transmit_channel().

close_udptl_connection()

void close_udptl_connection

(

ooCallData *

call

)

Definition at line 4901 of file chan_ooh323.c.

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

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

configure_local_rtp()

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

Definition at line 4599 of file chan_ooh323.c.

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

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, call(), ooh323_pvt::cap, DEADLOCK_AVOIDANCE, ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, errno, gH323Debug, gTOS, H323_DTMF_CISCO, H323_DTMF_RFC2833, io, 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().

delete_peers()

int delete_peers

(

void

)

Definition at line 4230 of file chan_ooh323.c.

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

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

delete_users()

int delete_users

(

void

)

Definition at line 4265 of file chan_ooh323.c.

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

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

do_monitor()

static void * do_monitor ( void *  data )

static

Definition at line 3998 of file chan_ooh323.c.

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

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

find_call()

static struct ooh323_pvt * find_call ( ooCallData *  call )

static

Definition at line 810 of file chan_ooh323.c.

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

References ast_mutex_lock, ast_mutex_unlock, ast_verb, call(), 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().

find_friend()

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

Definition at line 858 of file chan_ooh323.c.

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

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

find_peer()

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

Definition at line 890 of file chan_ooh323.c.

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

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, name, ooh323_peer::next, peerl, and ast_peer_list::peers.

Referenced by ooh323_request().

find_user()

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

Definition at line 832 of file chan_ooh323.c.

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

References ast_mutex_lock, ast_mutex_unlock, ast_verb, gH323Debug, ast_user_list::lock, name, userl, and ast_user_list::users.

Referenced by ooh323_destroy(), and ooh323_onReceivedSetup().

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.

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

References ast_channel_lock, ast_channel_tech_pvt(), ast_channel_unlock, ast_copy_string(), ast_log, ast_mutex_lock, ast_mutex_unlock, buf, 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, len(), ooh323_pvt::lock, LOG_ERROR, ooh323_pvt::t38support, and type.

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.

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

References ast_channel_lock, 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, type, and value.

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.

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

References a, 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.

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.

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

References a, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, FALSE, gH323Debug, NULL, TRUE, and ast_cli_entry::usage.

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.

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

References a, 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, FORMAT_STRING_SIZE, gAccountcode, gAliasList, gAMAFLAGS, gCallerID, gCap, 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.

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.

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

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

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.

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

References a, 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, 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, test_val::name, ooh323_peer::next, NULL, peerl, ast_peer_list::peers, T38_DISABLED, T38_FAXGW, and ast_cli_entry::usage.

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.

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

References a, 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, FORMAT, ooh323_peer::lock, ast_peer_list::lock, test_val::name, ooh323_peer::next, NULL, peerl, ast_peer_list::peers, and ast_cli_entry::usage.

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.

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

References a, 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, 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, userl, and ast_user_list::users.

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.

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

References a, 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, FORMAT1, ooh323_user::lock, ast_user_list::lock, NULL, RESULT_SUCCESS, ast_cli_entry::usage, userl, and ast_user_list::users.

load_module()

static int load_module ( void  )

static

Definition at line 3787 of file chan_ooh323.c.

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

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, cli_ooh323, ooh323_peer::e164, ooh323_peer::email, gAliasList, gBeMaster, gCallerID, gCap, gDTMFCodec, gDTMFMode, gFastStart, gGatekeeper, gInitError, gIP, gIsGateway, gLogFile, gMediaWaitForConnect, gPort, gRasGkMode, gRASIP, gTRCLVL, gTunneling, ooh323_peer::h323id, io, io_context_create(), ast_user_list::lock, ast_peer_list::lock, LOG_ERROR, LOG_WARNING, manufacturer, ooh323_config::mTCPPortEnd, ooh323_config::mTCPPortStart, myself, ooh323_peer::next, NULL, onAlerting(), onCallCleared(), onCallEstablished(), onModeChanged(), onNewCallCreated(), onOutgoingCall(), onProgress(), ooconfig, ooh323_onReceivedDigit(), ooh323_onReceivedSetup(), ooh323_rtp, ooh323_tech, ooh323c_set_capability(), ooh323c_start_stack_thread(), 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.

onAlerting()

int onAlerting

(

ooCallData *

call

)

Definition at line 1682 of file chan_ooh323.c.

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

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, call(), connected, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ast_set_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, ast_set_party_id::name, NULL, and ooh323_pvt::owner.

Referenced by load_module().

onCallCleared()

int onCallCleared

(

ooCallData *

call

)

Definition at line 2236 of file chan_ooh323.c.

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

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, call(), DEADLOCK_AVOIDANCE, find_call(), gH323Debug, H323_ALREADYGONE, H323_NEEDDESTROY, ooh323_pvt::lock, myself, NULL, ooh323c_stop_call_thread(), ooh323_pvt::owner, ooh323_pvt::rtp, ooh323_pvt::rtpcond, usecnt, and usecnt_lock.

Referenced by load_module().

onCallEstablished()

int onCallEstablished

(

ooCallData *

call

)

Definition at line 2181 of file chan_ooh323.c.

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

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, call(), connected, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, H323_OUTGOING, ast_set_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, ast_set_party_id::name, NULL, and ooh323_pvt::owner.

Referenced by load_module().

onModeChanged()

void onModeChanged	(	ooCallData *	call,
		int	t38mode
	)

Definition at line 5076 of file chan_ooh323.c.

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

References ast_async_goto(), ast_channel_caller(), ast_channel_context(), ast_channel_exten(), 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, call(), 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, 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().

onNewCallCreated()

int onNewCallCreated

(

ooCallData *

call

)

Definition at line 2089 of file chan_ooh323.c.

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

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

onOutgoingCall()

int onOutgoingCall

(

ooCallData *

call

)

Definition at line 2016 of file chan_ooh323.c.

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

References ast_copy_string(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), ast_verb, call(), 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().

onProgress()

int onProgress

(

ooCallData *

call

)

Definition at line 1738 of file chan_ooh323.c.

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

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, call(), connected, DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ast_set_party_connected_line::id, ooh323_pvt::lock, LOG_ERROR, ast_set_party_id::name, NULL, and ooh323_pvt::owner.

Referenced by load_module().

ooh323_alloc()

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

static

Definition at line 556 of file chan_ooh323.c.

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

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, g729onlyA, gAccountcode, gAMAFLAGS, gANIasDNI, gCap, 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().

ooh323_answer()

static int ooh323_answer ( struct ast_channel *  ast )

static

Definition at line 1154 of file chan_ooh323.c.

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

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.

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.

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

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.

ooh323_convert_hangupcause_asteriskToH323()

int ooh323_convert_hangupcause_asteriskToH323

(

int

cause

)

Definition at line 5179 of file chan_ooh323.c.

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

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

ooh323_convert_hangupcause_h323ToAsterisk()

int ooh323_convert_hangupcause_h323ToAsterisk

(

int

cause

)

Definition at line 5206 of file chan_ooh323.c.

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

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.

ooh323_convertAsteriskCapToH323Cap()

int ooh323_convertAsteriskCapToH323Cap

(

struct ast_format *

format

)

Definition at line 4506 of file chan_ooh323.c.

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

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

ooh323_delete_peer()

void ooh323_delete_peer

(

struct ooh323_peer *

peer

)

Definition at line 2328 of file chan_ooh323.c.

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

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

ooh323_destroy()

int ooh323_destroy

(

struct ooh323_pvt *

p

)

Definition at line 4117 of file chan_ooh323.c.

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

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, myself, ooh323_pvt::next, NULL, and ooh323_pvt::username.

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

ooh323_digit_begin()

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

static

Definition at line 928 of file chan_ooh323.c.

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

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.

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.

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

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

ooh323_do_reload()

static int ooh323_do_reload ( void  )

static

Definition at line 2705 of file chan_ooh323.c.

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

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, peerl, ast_peer_list::peers, reload_config(), and ooh323_peer::url.

Referenced by do_monitor().

ooh323_fixup()

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

static

Definition at line 1522 of file chan_ooh323.c.

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

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.

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.

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

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, gH323Debug, and result.

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.

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

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.

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.

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

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.

ooh323_hangup()

static int ooh323_hangup ( struct ast_channel *  ast )

static

Definition at line 1087 of file chan_ooh323.c.

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

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, myself, NULL, ooh323_convert_hangupcause_asteriskToH323(), ooh323_pvt::owner, pbx_builtin_getvar_helper(), usecnt, usecnt_lock, and ooh323_pvt::username.

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.

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

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.

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.

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

References ooh323_pvt::accountcode, ooh323_pvt::amaflags, ao2_cleanup, ao2_ref, AST_ADSI_UNAVAILABLE, ast_channel_adsicpe_set(), ast_channel_alloc, ast_channel_amaflags_set(), ast_channel_context_set(), ast_channel_exten_set(), ast_channel_name(), ast_channel_nativeformats_set(), ast_channel_priority_set(), ast_channel_rings_set(), ast_channel_set_rawreadformat(), ast_channel_set_rawwriteformat(), ast_channel_tech_pvt_set(), ast_channel_tech_set(), ast_channel_unlock, ast_dsp_new(), ast_dsp_set_digitmode(), ast_dsp_set_faxmode(), ast_dsp_set_features(), ast_format_cap_alloc, ast_format_cap_append, AST_FORMAT_CAP_FLAG_DEFAULT, ast_format_cap_get_format(), ast_hangup(), ast_jb_configure(), ast_log, ast_module_ref, ast_mutex_lock, ast_mutex_unlock, ast_pbx_start(), ast_set_read_format(), ast_set_write_format(), ast_setstate(), AST_STATE_DOWN, AST_STATE_RING, ast_strlen_zero(), ast_test_flag, ast_update_use_count(), 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, callnumber, ooh323_pvt::cap, ooh323_pvt::context, DSP_DIGITMODE_DTMF, DSP_DIGITMODE_RELAXDTMF, DSP_FAXMODE_DETECT_CED, DSP_FAXMODE_DETECT_CNG, DSP_FEATURE_DIGIT_DETECT, DSP_FEATURE_FAX_DETECT, ooh323_pvt::dtmfmode, ooh323_pvt::exten, ooh323_pvt::faxdetect, FAXDETECT_CNG, gH323Debug, global_jbconf, H323_DTMF_INBAND, H323_DTMF_INBANDRELAX, H323_OUTGOING, ooh323_pvt::lock, LOG_WARNING, myself, NULL, ooh323_tech, ooh323c_cn_lock, ooh323_pvt::owner, pbx_builtin_setvar_helper(), usecnt, usecnt_lock, and ooh323_pvt::vad.

Referenced by ooh323_onReceivedSetup(), and ooh323_request().

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.

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

References ast_channel_trylock, ast_channel_unlock, ast_debug, AST_FRAME_DTMF, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_queue_frame(), call(), ast_frame::data, ast_frame::datalen, DEADLOCK_AVOIDANCE, digit, 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().

ooh323_onReceivedSetup()

int ooh323_onReceivedSetup	(	ooCallData *	call,
		Q931Message *	pmsg
	)

Definition at line 1840 of file chan_ooh323.c.

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

References ooh323_pvt::accountcode, ooh323_pvt::amaflags, ooh323_pvt::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, call(), 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, configure_local_rtp(), ooh323_pvt::context, ooh323_pvt::directrtp, ooh323_pvt::dtmfcodec, ooh323_pvt::dtmfmode, ooh323_pvt::earlydirect, ooh323_pvt::exten, ooh323_pvt::faststart, ooh323_pvt::faxdetect, find_user(), ooh323_pvt::flags, ooh323_pvt::g729onlyA, gDirectRTP, gEarlyDirect, gH323Debug, ooh323_pvt::h245tunneling, H323_DISABLEGK, H323_NEEDDESTROY, H323_OUTGOING, ooh323_pvt::lock, LOG_ERROR, ooh323_pvt::nat, ooh323_pvt::neighbor, NULL, ooh323_alloc(), ooh323_convert_hangupcause_asteriskToH323(), ooh323_new(), ooh323c_set_capability_for_call(), ooh323_pvt::rtdrcount, ooh323_pvt::rtdrinterval, ooh323_pvt::rtpmask, ooh323_pvt::rtpmaskstr, ooh323_pvt::rtptimeout, ooh323_pvt::t38support, update_our_aliases(), ooh323_pvt::user, and ooh323_pvt::username.

Referenced by load_module().

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.

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

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, T38_DISABLED, T38_STATE_NEGOTIATED, T38_STATE_NEGOTIATING, T38_STATE_UNAVAILABLE, T38_STATE_UNKNOWN, ooh323_pvt::t38support, and ooh323_pvt::vad.

ooh323_read()

static struct ast_frame * ooh323_read ( struct ast_channel *  ast )

static

Definition at line 1194 of file chan_ooh323.c.

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

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

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.

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

References ooh323_peer::accountcode, ooh323_pvt::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, g729onlyA, gCap, 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::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, and ooh323_pvt::username.

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.

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

References ao2_ref, ast_async_goto(), ast_channel_caller(), ast_channel_context(), ast_channel_exten(), ast_channel_fdno(), 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, 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().

ooh323_set_read_format()

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

Definition at line 1625 of file chan_ooh323.c.

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

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, call(), DEADLOCK_AVOIDANCE, find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, ooh323_pvt::owner, and ooh323_pvt::readformat.

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.

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

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(), ooh323_pvt::redirip, and ooh323_pvt::rtp.

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.

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

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

ooh323_write()

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

static

Definition at line 1212 of file chan_ooh323.c.

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

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.

reload_config()

static int reload_config

(

int

reload

)

Definition at line 2813 of file chan_ooh323.c.

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

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_jbconf, DEFAULT_LOGFILE, delete_peers(), delete_users(), FALSE, FAXDETECT_CNG, FAXDETECT_T38, g729onlyA, gAccountcode, gAliasList, gAMAFLAGS, gANIasDNI, gBeMaster, gCallerID, gCap, 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, ooh323_peer::next, ast_variable::next, NULL, ooconfig, PARSE_ADDR, peerl, ast_peer_list::peers, reload(), RESULT_SUCCESS, strsep(), t35countrycode, t35extensions, T38_DISABLED, T38_ENABLED, T38_FAXGW, userl, ast_user_list::users, v6mode, ast_variable::value, vendor, and version.

reload_module()

static int reload_module ( void  )

static

Examples

app_skel.c.

Definition at line 3981 of file chan_ooh323.c.

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

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

restart_monitor()

static int restart_monitor

(

void

)

Definition at line 4082 of file chan_ooh323.c.

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

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

setup_rtp_connection()

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

Definition at line 4775 of file chan_ooh323.c.

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

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, call(), find_call(), gH323Debug, ooh323_pvt::lock, LOG_ERROR, NULL, PARSE_ADDR, ooh323_pvt::rtp, and ooh323_pvt::writeformat.

Referenced by ooh323c_start_transmit_channel().

setup_rtp_remote()

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

Definition at line 4736 of file chan_ooh323.c.

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

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

Referenced by load_module().

setup_udptl_connection()

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

Definition at line 4839 of file chan_ooh323.c.

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

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

unload_module()

static int unload_module ( void  )

static

Definition at line 4296 of file chan_ooh323.c.

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

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, cli_ooh323, delete_peers(), delete_users(), gAliasList, gCap, gH323Debug, iflist, iflock, LOG_WARNING, monitor_thread, monlock, ooh323_pvt::next, NULL, ooh323_destroy(), ooh323_rtp, ooh323_tech, ooh323c_stop_stack_thread(), and ooh323_pvt::owner.

update_our_aliases()

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

Definition at line 4949 of file chan_ooh323.c.

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

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

Referenced by ooh323_onReceivedSetup().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Objective Systems H323 Channel" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .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.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 5250 of file chan_ooh323.c.

bindaddr

struct ast_sockaddr bindaddr

Definition at line 353 of file chan_ooh323.c.

Referenced by __ast_http_load(), ast_find_ourip(), ast_netsock_bindaddr(), configure_local_rtp(), process_config(), process_config(), reload_config(), reload_config(), and set_config().

callnumber

long callnumber = 0

static

Definition at line 335 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), and ooh323_new().

cli_ooh323

struct ast_cli_entry cli_ooh323[]

static

Definition at line 3673 of file chan_ooh323.c.

                                           {
    AST_CLI_DEFINE(handle_cli_ooh323_set_debug, "Enable/Disable OOH323 debugging"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_config, "Show details on global configuration of H.323 channel driver"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_gk, "Show OOH323 Gatekeeper connection status"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_peer, "Show details on specific OOH323 peer"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_peers,  "Show defined OOH323 peers"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_user, "Show details on specific OOH323 user"),
    AST_CLI_DEFINE(handle_cli_ooh323_show_users,  "Show defined OOH323 users"),
        AST_CLI_DEFINE(handle_cli_ooh323_reload, "reload ooh323 config")
};

Referenced by load_module(), and unload_module().

config

const char config[] = "ooh323.conf"

static

Definition at line 111 of file chan_ooh323.c.

Referenced by __ast_sorcery_apply_config(), add_features_datastores(), app_exec(), ast_ari_asterisk_get_info(), ast_bridge_call(), ast_bridge_call_with_flags(), ast_bridge_features_enable(), ast_bridge_timelimit(), ast_category_append(), ast_category_browse(), ast_category_browse_filtered(), ast_category_delete(), ast_category_exist(), ast_category_get(), ast_category_get(), ast_category_insert(), ast_category_root(), ast_cdr_set_config(), ast_cel_set_config(), ast_config_new(), ast_config_sort_categories(), ast_get_cc_agent_dialstring(), ast_get_cc_agent_policy(), ast_get_cc_callback_sub(), ast_get_cc_max_agents(), ast_get_cc_max_monitors(), ast_get_cc_monitor_policy(), ast_get_cc_offer_timer(), ast_get_cc_recall_timer(), ast_get_ccbs_available_timer(), ast_get_ccnr_available_timer(), ast_set_cc_agent_dialstring(), ast_set_cc_agent_policy(), ast_set_cc_callback_sub(), ast_set_cc_max_agents(), ast_set_cc_max_monitors(), ast_set_cc_monitor_policy(), ast_set_cc_offer_timer(), ast_set_cc_recall_timer(), ast_set_ccbs_available_timer(), ast_set_ccnr_available_timer(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), ast_variable_browse(), ast_variable_browse(), ast_variable_retrieve(), ast_variable_retrieve(), ast_variable_retrieve_filtered(), asterisk_publication_config_alloc(), asterisk_publication_config_destroy(), asterisk_publication_devicestate(), asterisk_publication_devicestate_refresh(), asterisk_publication_devicestate_state_change(), asterisk_publication_mailboxstate(), asterisk_publication_mwi_refresh(), asterisk_publication_mwi_state_change(), asterisk_publication_new(), bridge_config_set_limits(), bridge_config_set_limits_warning_values(), category_get(), category_get_sep(), cdr_enable_batch_mode(), config_alloc(), config_can_be_inherited(), create_lookup_filter(), custom_log(), custom_log(), dial_exec_full(), do_reload(), hep_queue_cb(), hepv3_config_alloc(), hepv3_config_dtor(), hepv3_config_pre_apply(), hepv3_data_alloc(), hepv3_get_uuid_type(), hepv3_is_loaded(), hepv3_send_packet(), load_config(), load_module(), load_mysql_config(), load_odbc_config(), localized_category_get(), module_config_alloc(), module_config_alloc(), module_config_dtor(), module_config_dtor(), new_realtime_sqlite3_db(), parse_config(), parse_config(), parse_config(), parse_config(), pre_bridge_setup(), process_config(), process_config(), prometheus_config_pre_apply(), prometheus_general_config_alloc(), prometheus_general_config_dtor(), prometheus_general_config_set(), prometheus_show_status(), realtime_sqlite3_load(), regex_filter_handler(), reload_config(), reload_config(), reload_config(), reload_module(), send_refresh_cb(), set_bridge_features_on_config(), set_config_flags(), sorcery_config_close(), sorcery_config_destructor(), sorcery_config_internal_load(), sorcery_config_open(), sorcery_config_retrieve_fields(), sorcery_config_retrieve_id(), sorcery_config_retrieve_multiple(), sorcery_config_retrieve_prefix(), sorcery_config_retrieve_regex(), sorcery_is_configuration_met(), sorcery_is_criteria_met(), sorcery_is_explicit_name_met(), sorcery_realtime_create(), sorcery_realtime_delete(), sorcery_realtime_open(), sorcery_realtime_retrieve_fields(), sorcery_realtime_retrieve_multiple(), sorcery_realtime_update(), timezone_add(), update_realtime_sqlite3_db(), and wait_for_answer().

default_jbconf

struct ast_jb_conf default_jbconf

static

Definition at line 115 of file chan_ooh323.c.

{
    .flags = 0,
    .max_size = -1,
    .resync_threshold = -1,
    .impl = ""
};

Referenced by reload_config().

g729onlyA

int g729onlyA = 0

static

Definition at line 375 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), ooh323_alloc(), ooh323_request(), ooh323c_set_capability_for_call(), and reload_config().

gAccountcode

char gAccountcode[80] = DEFAULT_H323ACCNT

static

Definition at line 376 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_alloc(), and reload_config().

gAliasList

struct ooAliases* gAliasList

static

Definition at line 356 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), ooh323_do_reload(), reload_config(), and unload_module().

gAMAFLAGS

int gAMAFLAGS

static

Definition at line 377 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_alloc(), and reload_config().

gANIasDNI

int gANIasDNI = 0

static

Definition at line 385 of file chan_ooh323.c.

Referenced by ooh323_alloc(), and reload_config().

gBeMaster

int gBeMaster = 0

static

Definition at line 369 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

gCallerID

char gCallerID[AST_MAX_EXTENSION] = ""

static

Definition at line 355 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), ooh323_call(), and reload_config().

gCap

struct ast_format_cap* gCap

static

Definition at line 357 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), load_module(), ooh323_alloc(), ooh323_request(), reload_config(), and unload_module().

gContext

char gContext[AST_MAX_EXTENSION] = DEFAULT_CONTEXT

static

Definition at line 378 of file chan_ooh323.c.

Referenced by build_user(), handle_cli_ooh323_show_config(), ooh323_alloc(), and reload_config().

gDirectRTP

int gDirectRTP = 0

static

Definition at line 371 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_onReceivedSetup(), ooh323_request(), and reload_config().

gDTMFCodec

int gDTMFCodec = 101

static

Definition at line 359 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), load_module(), ooh323_alloc(), ooh323_request(), and reload_config().

gDTMFMode

int gDTMFMode = H323_DTMF_RFC2833

static

Definition at line 358 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), load_module(), ooh323_alloc(), ooh323_request(), and reload_config().

gEarlyDirect

int gEarlyDirect = 0

static

Definition at line 372 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_onReceivedSetup(), ooh323_request(), and reload_config().

gFastStart

int gFastStart = 1

static

Definition at line 367 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), load_module(), ooh323_request(), and reload_config().

gFAXdetect

int gFAXdetect = FAXDETECT_CNG

static

Definition at line 360 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_alloc(), ooh323_request(), and reload_config().

gGatekeeper

char gGatekeeper[100]

static

Definition at line 362 of file chan_ooh323.c.

Referenced by do_monitor(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_gk(), load_module(), ooh323_do_reload(), and reload_config().

gH323Debug

OOBOOL gH323Debug = FALSE

Definition at line 381 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), close_rtp_connection(), close_udptl_connection(), configure_local_rtp(), find_call(), find_friend(), find_peer(), find_user(), handle_cli_ooh323_reload(), handle_cli_ooh323_set_debug(), onAlerting(), onCallCleared(), onCallEstablished(), onModeChanged(), onNewCallCreated(), onOutgoingCall(), onProgress(), ooh323_alloc(), ooh323_answer(), ooh323_call(), ooh323_delete_peer(), ooh323_destroy(), ooh323_digit_begin(), ooh323_digit_end(), ooh323_do_reload(), ooh323_fixup(), ooh323_get_codec(), ooh323_get_rtp_peer(), ooh323_hangup(), ooh323_indicate(), ooh323_new(), ooh323_onReceivedSetup(), ooh323_queryoption(), ooh323_request(), ooh323_rtp_read(), ooh323_set_read_format(), ooh323_set_rtp_peer(), ooh323_set_write_format(), ooh323c_set_capability(), ooh323c_set_capability_for_call(), ooh323c_start_call_thread(), reload_config(), reload_module(), setup_rtp_connection(), setup_rtp_remote(), setup_udptl_connection(), and unload_module().

gH323ep

OOH323EndPoint gH323ep

extern

Referenced by do_monitor(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_gk(), ooh323_do_reload(), and ooh323_request().

gIncomingLimit

int gIncomingLimit = 1024

static

Definition at line 379 of file chan_ooh323.c.

Referenced by reload_config().

gInitError

char gInitError[256] = ""

static

Definition at line 350 of file chan_ooh323.c.

Referenced by load_module().

gIP

char gIP[2+8 *4+7]

static

Definition at line 352 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), and reload_config().

gIsGateway

int gIsGateway = 0

static

Definition at line 366 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

global_jbconf

struct ast_jb_conf global_jbconf

static

Definition at line 122 of file chan_ooh323.c.

Referenced by ooh323_get_rtp_peer(), ooh323_new(), and reload_config().

gLogFile

char gLogFile[PATH_MAX] = DEFAULT_LOGFILE

static

Definition at line 349 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), and reload_config().

gMediaWaitForConnect

int gMediaWaitForConnect = 0

static

Definition at line 370 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), and reload_config().

gNat

int gNat = FALSE

static

Definition at line 384 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), ooh323_alloc(), ooh323_request(), and reload_config().

gOutgoingLimit

int gOutgoingLimit = 1024

static

Definition at line 380 of file chan_ooh323.c.

Referenced by reload_config().

gPort

int gPort = 1720

static

Definition at line 351 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), load_module(), and reload_config().

gRasGkMode

enum RasGatekeeperMode gRasGkMode = RasNoGatekeeper

static

Definition at line 364 of file chan_ooh323.c.

Referenced by do_monitor(), handle_cli_ooh323_show_config(), handle_cli_ooh323_show_gk(), load_module(), ooh323_alloc(), ooh323_do_reload(), ooh323_request(), and reload_config().

gRASIP

char gRASIP[2+8 *4+7]

static

Definition at line 363 of file chan_ooh323.c.

Referenced by do_monitor(), load_module(), ooh323_do_reload(), and reload_config().

gRTDRCount

int gRTDRCount = 0

static

Definition at line 383 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), ooh323_alloc(), ooh323_request(), and reload_config().

gRTDRInterval

int gRTDRInterval = 0

static

Definition at line 383 of file chan_ooh323.c.

Referenced by handle_cli_ooh323_show_config(), ooh323_alloc(), ooh323_request(), and reload_config().

gRTPTimeout

int gRTPTimeout = 60

static

Definition at line 374 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), ooh323_alloc(), ooh323_request(), and reload_config().

gT38Support

int gT38Support = T38_FAXGW

static

Definition at line 361 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), ooh323_alloc(), ooh323_request(), and reload_config().

gTOS

int gTOS = 0

static

Definition at line 373 of file chan_ooh323.c.

Referenced by configure_local_rtp(), and reload_config().

gTRCLVL

int gTRCLVL = OOTRCLVLERR

static

Definition at line 382 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

gTunneling

int gTunneling = 1

static

Definition at line 368 of file chan_ooh323.c.

Referenced by build_peer(), build_user(), handle_cli_ooh323_show_config(), load_module(), ooh323_request(), and reload_config().

h323_reload_lock

ast_mutex_t h323_reload_lock = AST_MUTEX_INIT_VALUE

static

Definition at line 329 of file chan_ooh323.c.

Referenced by do_monitor(), handle_cli_ooh323_reload(), and reload_module().

h323_reloading

int h323_reloading = 0

static

Definition at line 328 of file chan_ooh323.c.

Referenced by do_monitor(), handle_cli_ooh323_reload(), and reload_module().

iflist

struct ooh323_pvt * iflist = NULL

static

Referenced by do_monitor(), find_call(), ooh323_alloc(), ooh323_destroy(), and unload_module().

iflock

ast_mutex_t iflock = AST_MUTEX_INIT_VALUE

static

Definition at line 252 of file chan_ooh323.c.

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

io

struct io_context* io

static

Definition at line 401 of file chan_ooh323.c.

Referenced by ael2_parse(), ast_expr(), ast_str_expr(), ast_udptl_new_with_bindaddr(), configure_local_rtp(), do_monitor(), and load_module().

manufacturer

int manufacturer = 0

static

Definition at line 389 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

monitor_thread

pthread_t monitor_thread = AST_PTHREADT_NULL

static

Definition at line 410 of file chan_ooh323.c.

Referenced by restart_monitor(), and unload_module().

monlock

ast_mutex_t monlock = AST_MUTEX_INIT_VALUE

static

Definition at line 405 of file chan_ooh323.c.

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

myself

struct ast_module* myself

Definition at line 113 of file chan_ooh323.c.

Referenced by load_module(), onCallCleared(), ooh323_destroy(), ooh323_hangup(), ooh323_new(), ooh323c_call_thread(), and ooh323c_start_call_thread().

ooconfig

struct ooh323_config ooconfig

static

Referenced by handle_cli_ooh323_show_config(), load_module(), and reload_config().

ooh323_rtp

struct ast_rtp_glue ooh323_rtp

static

Definition at line 172 of file chan_ooh323.c.

                                        {
    .type = type,
    .get_rtp_info = ooh323_get_rtp_peer,
    .get_vrtp_info = ooh323_get_vrtp_peer,
    .update_peer = ooh323_set_rtp_peer,
    .get_codec = ooh323_get_codec,
};

Referenced by load_module(), and unload_module().

ooh323_tech

struct ast_channel_tech ooh323_tech

static

Definition at line 150 of file chan_ooh323.c.

                                             {
    .type = type,
    .description = tdesc,
    .properties = AST_CHAN_TP_WANTSJITTER | AST_CHAN_TP_CREATESJITTER,
    .requester = ooh323_request,
    .send_digit_begin = ooh323_digit_begin,
    .send_digit_end = ooh323_digit_end,
    .call = ooh323_call,
    .hangup = ooh323_hangup,
    .answer = ooh323_answer,
    .read = ooh323_read,
    .write = ooh323_write,
    .exception = ooh323_read,
    .indicate = ooh323_indicate,
    .fixup = ooh323_fixup,
    .send_html = 0,
    .queryoption = ooh323_queryoption,
    .early_bridge = ast_rtp_instance_early_bridge,
    .func_channel_read = function_ooh323_read,
    .func_channel_write = function_ooh323_write,
};

Referenced by load_module(), ooh323_new(), and unload_module().

ooh323c_cn_lock

ast_mutex_t ooh323c_cn_lock = AST_MUTEX_INIT_VALUE

static

Definition at line 336 of file chan_ooh323.c.

Referenced by ooh323_new().

peerl

struct ast_peer_list peerl

static

Referenced by delete_peers(), find_friend(), find_peer(), handle_cli_ooh323_show_peer(), handle_cli_ooh323_show_peers(), load_module(), ooh323_delete_peer(), ooh323_do_reload(), and reload_config().

sched

struct ast_sched_context* sched

static

Asterisk RTP stuff

Definition at line 400 of file chan_ooh323.c.

t35countrycode

int t35countrycode = 0

static

Definition at line 387 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

t35extensions

int t35extensions = 0

static

Definition at line 388 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

tdesc

const char tdesc[] = "Objective Systems H323 Channel Driver"

static

Definition at line 110 of file chan_ooh323.c.

type

const char type[] = "OOH323"

static

Definition at line 109 of file chan_ooh323.c.

Referenced by __ast_request_and_dial(), __ast_sorcery_apply_config(), __ast_sorcery_apply_default(), __ast_sorcery_apply_wizard_mapping(), __ast_sorcery_insert_wizard_mapping(), __ast_sorcery_object_field_register(), __ast_sorcery_object_register(), __ast_sorcery_remove_wizard_mapping(), __send_command(), _ast_xmldoc_build_syntax(), aco_info_init(), aco_option_find(), aco_process_category_options(), aco_process_var(), aco_set_defaults(), add_static_payload(), aeap_send(), aeap_transport_create(), aeap_transport_create_and_connect(), agi_channel_to_ami(), aoc_consume(), aoc_invite_outgoing_response(), append_expected_event(), append_expected_event_snapshot(), ari_conf_load(), ari_websocket_type_to_str(), ast_aeap_create_and_connect(), ast_aeap_message_create1(), ast_aeap_message_create2(), ast_aeap_message_create_error(), ast_aeap_message_create_request(), ast_aeap_message_create_response(), ast_aeap_message_deserialize(), ast_aeap_message_serial_type(), ast_aoc_add_unit_entry(), ast_aoc_set_total_type(), ast_audiohook_init(), ast_body_to_pjsip_body(), ast_call_forward(), ast_callerid_vmwi_generate(), ast_cc_agent_callback(), ast_cc_monitor_count(), ast_cel_get_type_name(), ast_channel_audiohook_count_by_source(), ast_channel_audiohook_count_by_source_running(), ast_channel_blob_create(), ast_channel_blob_create_from_cache(), ast_channel_get_default_stream(), ast_channel_publish_blob(), ast_channel_publish_cached_blob(), ast_codec_get(), ast_codec_media_type2str(), ast_config_option_default_handler(), ast_endpoint_blob_create(), ast_endpoint_blob_publish(), ast_event_get_type_name(), ast_event_new(), ast_format_cap_append_by_type(), ast_format_cap_append_from_cap(), ast_format_cap_get_best_by_type(), ast_format_cap_has_type(), ast_format_cap_remove_by_type(), ast_format_cap_replace_from_cap(), ast_format_str_reduce(), ast_framehook_list_contains_no_active_of_type(), ast_http_get_json(), ast_http_get_post_vars(), ast_jb_get_impl(), ast_json_typename(), ast_manager_publish_event(), ast_module_helper(), ast_multi_object_blob_add(), ast_multi_object_blob_create(), ast_multi_object_blob_single_channel_publish(), ast_multicast_rtp_create_options(), ast_pbx_outgoing_app(), ast_pbx_outgoing_app_predial(), ast_pbx_outgoing_exten(), ast_pbx_outgoing_exten_predial(), ast_readfile(), ast_request(), ast_request_and_dial(), ast_request_with_stream_topology(), ast_rtp_codecs_find_payload_code(), ast_rtp_codecs_get_payload(), ast_rtp_codecs_get_payload_format(), ast_rtp_codecs_get_stream_type(), ast_rtp_codecs_payload_code_sample_rate(), ast_rtp_codecs_payload_code_tx_sample_rate(), ast_rtp_codecs_payload_formats(), ast_rtp_codecs_payload_replace_format(), ast_rtp_codecs_payloads_copy(), ast_rtp_codecs_payloads_destroy(), ast_rtp_codecs_payloads_unset(), ast_rtp_codecs_payloads_xover(), ast_rtp_instance_early_bridge(), ast_rtp_instance_early_bridge_make_compatible(), ast_rtp_instance_get_glue(), ast_rtp_instance_make_compatible(), ast_sd_get_fd(), ast_sd_get_fd_un(), ast_search_dns(), ast_set_lock_type(), ast_sip_auth_type_to_str(), ast_sip_is_content_type(), ast_sip_pubsub_generate_body_content(), ast_sip_pubsub_is_body_generator_registered(), ast_sip_session_media_state_add(), ast_sip_session_media_state_clone(), ast_sip_str_to_security_mechanism(), ast_sorcery_alloc(), ast_sorcery_force_reload_object(), ast_sorcery_get_object_type(), ast_sorcery_get_wizard_mapping(), ast_sorcery_get_wizard_mapping_count(), ast_sorcery_load_object(), ast_sorcery_object_fields_register(), ast_sorcery_object_set_congestion_levels(), ast_sorcery_object_set_copy_handler(), ast_sorcery_object_set_diff_handler(), ast_sorcery_object_unregister(), ast_sorcery_observer_add(), ast_sorcery_observer_remove(), ast_sorcery_reload_object(), ast_sorcery_retrieve_by_fields(), ast_sorcery_retrieve_by_id(), ast_sorcery_retrieve_by_prefix(), ast_sorcery_retrieve_by_regex(), ast_speech_results_type_to_string(), ast_stream_alloc(), ast_stream_set_type(), ast_stream_topology_create_from_format_cap(), ast_stream_topology_get_first_stream_by_type(), ast_stream_topology_get_formats_by_type(), ast_stream_topology_map(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), ast_var_channels_table(), ast_websocket_type_to_str(), ast_write_stream(), ast_writefile(), ast_writestream(), ast_xml_doc_item_alloc(), ast_xmldoc_build_arguments(), ast_xmldoc_build_description(), ast_xmldoc_build_documentation(), ast_xmldoc_build_final_response(), ast_xmldoc_build_list_responses(), ast_xmldoc_build_seealso(), ast_xmldoc_build_since(), ast_xmldoc_build_synopsis(), ast_xmldoc_build_syntax(), asterisk_publication_devicestate_state_change(), asterisk_publication_mwi_state_change(), astobj2_test_1_helper(), bridge_basic_change_personality(), bridge_channel_event_join_leave(), bridge_create_common(), bridge_other_hook(), bucket_file_wizard_retrieve(), bucket_http_test_wizard_retrieve_id(), bucket_http_wizard_retrieve_id(), bucket_test_wizard_retrieve_id(), bucket_wizard_retrieve(), cache_entry_create(), cache_find(), cache_put(), cache_test_aggregate_calc_fn(), cache_test_message_create(), cache_test_message_create_full(), chan_pjsip_request(), change_callerid(), channel_blob_to_json(), channel_do_masquerade(), channel_fax_cb(), channel_read_pjsip(), channel_read_rtcp(), channel_read_rtp(), channel_set_default_streams(), channel_snapshot_base_create(), check_event(), check_header(), check_header(), check_resync(), check_stream_positions(), check_translation_path(), cli_endpoint_print_child_body(), cli_endpoint_print_child_header(), conf_run(), create_channel_blob_message(), create_dialog_uas(), create_dtmf_frame(), create_new_socket(), create_object(), dahdi_setoption(), dahdichan_helper(), decode(), device_state_cb(), dns_parse_answer(), evaluate_and(), evaluate_equal(), evaluate_greater_than(), evaluate_greater_than_or_equal(), evaluate_history_entry(), evaluate_less_than(), evaluate_less_than_or_equal(), evaluate_like(), evaluate_not(), evaluate_not_equal(), evaluate_or(), find_agent_callbacks(), find_body_generator_accept(), find_body_generator_type_subtype(), find_body_generator_type_subtype_nolock(), find_monitor_callbacks(), find_route(), find_unused_payload_in_range(), flash_exec(), func_confbridge_channels(), func_confbridge_helper(), func_confbridge_info(), function_ooh323_read(), function_ooh323_write(), g723_len(), generate_notify_body(), generate_status(), get_announce_filename(), get_sqlite_column_type(), get_sub(), get_sub_holding(), get_unused_callno(), h264_decap(), handle_bridge_technology_show(), handle_cli_iax2_show_threads(), handle_cli_realtime_mysql_status(), handle_incoming_sdp(), handle_missing_column(), handle_missing_table(), handle_showchan(), hangupcause_read(), hold_intercept_framehook_consume(), iax_showframe(), init_details(), internal_ao2_traverse(), internal_type_destroy(), internal_type_init(), is_stream_limitation_reached(), jb_put(), jingle_add_content(), jingle_add_payloads_to_description(), jingle_interpret_ice_udp_transport(), jingle_send_error_response(), ldap_mod_create(), ldap_mod_duplicate(), link_option_to_types(), load_module(), local_request(), local_request_with_stream_topology(), lock_msg_q(), manager_bridge_tech_list(), manager_generic_msg_cb(), manager_send_response(), match_ie_val(), memory_cache_full_update(), memory_cache_populate(), memory_cache_stale_update_full(), message_create(), message_type_dtor(), mock_retrieve_id(), module_matches_helper_type(), msg_timestamp(), multi_object_blob_dtor(), multi_object_blob_to_ami(), multi_user_event_to_json(), multicast_rtp_request(), mwi_startup_event_cb(), native_rtp_framehook_consume(), npval(), npval2(), originate_exec(), parse_tag(), pbx_outgoing_attempt(), pjsip_acf_channel_read(), pjsip_acf_dtmf_mode_read(), pjsip_acf_dtmf_mode_write(), pjsip_acf_media_offer_read(), pjsip_acf_media_offer_write(), pjsip_acf_moh_passthrough_read(), pjsip_acf_moh_passthrough_write(), pjsip_acf_parse_uri_read(), pjsip_acf_session_refresh_write(), pjsip_app_hangup_handler(), pjsip_transfer_handling_write(), playback_to_json(), polarity_read(), polarity_write(), prepare_bridge_media_channel(), print_escaped_uri(), process_category(), process_log_list(), process_request(), prometheus_metric_type_to_string(), ptestate_tostr(), publish_chanspy_message(), publish_chanspy_message(), publish_format_update(), publish_load_message_type(), purge_old_messages(), push_notify_channel(), pvalCheckType(), pvalCreateNode(), queue_channel_to_ami(), queue_member_to_ami(), queue_multi_channel_to_ami(), queue_publish_member_blob(), queue_publish_multi_channel_blob(), queue_publish_multi_channel_snapshot_blob(), queue_put(), realtime_sqlite3_require(), recording_to_json(), registrar_contact_delete(), request_channel(), require_curl(), require_mysql(), require_odbc(), require_pgsql(), rtcp_report_to_ami(), rtp_codecs_find_non_primary_dynamic_rx(), rtp_codecs_payloads_copy_rx(), rtp_codecs_payloads_copy_tx(), rtp_glue_data_get(), rtp_payload_type_alloc(), s_to_json(), sayfile_exec(), schedule_delivery(), sdp_requires_deferral(), send_command(), send_command_final(), send_command_immediate(), send_command_locked(), send_command_transfer(), send_conf_stasis(), send_conf_stasis_snapshots(), sendmail(), serialize_showchan(), session_inv_on_state_changed(), set_next_mime_type(), set_outbound_initial_authentication_credentials(), set_target_uri(), set_type(), setup_env(), simple_bridge_channel_event(), simple_bridge_event(), simple_channel_event(), simple_endpoint_event(), sip_dialog_create_contact(), sip_dialog_create_from(), sla_framehook_consume(), sla_load_config(), sla_queue_event(), sla_queue_event_conf(), sla_queue_event_full(), sla_queue_event_nolock(), smdi_message_wait(), smdi_msg_find(), smdi_msg_pop(), snoop_setup_audiohook(), softhangup_exec(), softmix_bridge_stream_topology_changed(), sorcery_astdb_filter_objectset(), sorcery_astdb_retrieve_fields(), sorcery_astdb_retrieve_fields_common(), sorcery_astdb_retrieve_id(), sorcery_astdb_retrieve_multiple(), sorcery_astdb_retrieve_prefix(), sorcery_astdb_retrieve_regex(), sorcery_config_internal_load(), sorcery_config_load(), sorcery_config_reload(), sorcery_field_default_handler(), sorcery_is_configuration_met(), sorcery_is_explicit_name_met(), sorcery_memory_cache_load(), sorcery_memory_cache_retrieve_id(), sorcery_memory_cache_retrieve_multiple(), sorcery_memory_cache_retrieve_prefix(), sorcery_memory_cache_retrieve_regex(), sorcery_object_load(), sorcery_object_type_alloc(), sorcery_realtime_filter_objectset(), sorcery_realtime_retrieve_fields(), sorcery_realtime_retrieve_id(), sorcery_realtime_retrieve_multiple(), sorcery_realtime_retrieve_prefix(), sorcery_realtime_retrieve_regex(), sorcery_reloadable(), sorcery_test_retrieve_id(), sorcery_wizard_load(), stale_cache_update_task_data_alloc(), stasis_app_bridge_create(), stasis_app_bridge_create_invisible(), stasis_app_user_event(), stasis_cache_dump(), stasis_cache_dump_all(), stasis_cache_dump_by_eid(), stasis_cache_get(), stasis_cache_get_all(), stasis_cache_get_by_eid(), stasis_caching_accept_message_type(), stasis_cp_single_accept_message_type(), stasis_message_create(), stasis_message_create_full(), stasis_message_type_available_formatters(), stasis_message_type_create(), stasis_message_type_hash(), stasis_message_type_id(), stasis_message_type_name(), stasis_subscription_accept_message_type(), stasis_subscription_decline_message_type(), stream_echo_exec(), stream_echo_perform(), stream_echo_topology_alloc(), stream_echo_write(), subscription_persistence_event_cb(), subscription_persistence_update(), subtype_tostr(), t38_consume(), taskpool_taskprocessor_alloc(), tech_capability2str(), test_container2str(), test_init_rtp_instances(), test_make_nonsorted(), test_make_sorted(), test_performance(), test_traversal_nonsorted(), test_traversal_sorted(), testloop(), transfer_exec(), transfer_target_framehook_consume(), try_calling(), type_in_list(), unlink_from_msg_q(), unlock_msg_q(), update_content_type(), waitstream_control(), websocket_on_rx_msg(), xmldoc_build_documentation_item(), xmldoc_build_field(), xmldoc_get_node(), xmldoc_get_syntax_config_option(), xmldoc_get_syntax_type(), xmldoc_update_config_option(), xmldoc_update_config_type(), xmpp_action_hook(), xmpp_client_authenticate(), xmpp_pak_presence(), xmpp_pubsub_iq_create(), and yyparse().

usecnt

int usecnt = 0

static

Definition at line 332 of file chan_ooh323.c.

Referenced by identify_module(), modlist_modentry(), onCallCleared(), ooh323_hangup(), ooh323_new(), and process_module_list().

usecnt_lock

ast_mutex_t usecnt_lock = AST_MUTEX_INIT_VALUE

static

Definition at line 333 of file chan_ooh323.c.

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

userl

struct ast_user_list userl

static

Referenced by delete_users(), find_user(), handle_cli_ooh323_show_user(), handle_cli_ooh323_show_users(), load_module(), and reload_config().

v6mode

int v6mode = 0

Definition at line 354 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

vendor

char vendor[AST_MAX_EXTENSION] = ""

static

Definition at line 390 of file chan_ooh323.c.

Referenced by load_module(), and reload_config().

version

char version[AST_MAX_EXTENSION] = ""

static

Definition at line 391 of file chan_ooh323.c.

Referenced by adsi_begin_download(), ast_adsi_begin_download(), ast_http_response_status_line(), ast_remotecontrol(), ast_rtp_read(), ast_var_Version(), ast_websocket_uri_cb(), check_access(), config_module(), dump_versioned_codec(), iax_firmware_get_version(), iax_ie_append_versioned_uint64(), iax_parse_ies(), iax_provision_version(), load_module(), main(), process_my_load_module(), reload_config(), rtcp_mux(), update_registry(), and xmpp_component_service_discovery_get_hook().