ooh323cDriver.c File Reference

#include "ooh323cDriver.h"
#include "asterisk.h"
#include "asterisk/lock.h"
#include "asterisk/pbx.h"
#include "asterisk/logger.h"

Include dependency graph for ooh323cDriver.c:

Go to the source code of this file.

Data Structures
struct	callthread

Macros
#define	AST_BACKGROUND_STACKSIZE   768 * 1024
#define	SEC_TO_HOLD_THREAD   24

Functions
struct ast_format *	convertH323CapToAsteriskCap (int cap)
void *	ooh323c_call_thread (void *dummy)
void *	ooh323c_cmd_thread (void *dummy)
int	ooh323c_set_aliases (ooAliases *aliases)
int	ooh323c_set_capability (struct ast_format_cap *cap, int dtmf, int dtmfcodec)
int	ooh323c_set_capability_for_call (ooCallData *call, struct ast_format_cap *cap, int dtmf, int dtmfcodec, int t38support, int g729onlyA)
void *	ooh323c_stack_thread (void *dummy)
int	ooh323c_start_call_thread (ooCallData *call)
int	ooh323c_start_receive_channel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_start_receive_datachannel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_start_stack_thread ()
int	ooh323c_start_transmit_channel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_start_transmit_datachannel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_stop_call_thread (ooCallData *call)
int	ooh323c_stop_receive_channel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_stop_receive_datachannel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_stop_stack_thread (void)
int	ooh323c_stop_transmit_channel (ooCallData *call, ooLogicalChannel *pChannel)
int	ooh323c_stop_transmit_datachannel (ooCallData *call, ooLogicalChannel *pChannel)

Variables
static struct callthread *	callThreads = NULL
static ast_mutex_t	callThreadsLock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
OOBOOL	gH323Debug
OOH323EndPoint	gH323ep
static int	grxframes = 240
static int	gtxframes = 20
struct ast_module *	myself
static pthread_t	ooh323c_thread = AST_PTHREADT_NULL
static pthread_t	ooh323cmd_thread = AST_PTHREADT_NULL

Macro Definition Documentation

AST_BACKGROUND_STACKSIZE

#define AST_BACKGROUND_STACKSIZE   768 * 1024

Definition at line 26 of file ooh323cDriver.c.

SEC_TO_HOLD_THREAD

#define SEC_TO_HOLD_THREAD   24

Definition at line 28 of file ooh323cDriver.c.

Referenced by ooh323c_call_thread().

Function Documentation

convertH323CapToAsteriskCap()

struct ast_format* convertH323CapToAsteriskCap

(

int

cap

)

Definition at line 664 of file ooh323cDriver.c.

References ast_debug, ast_format_alaw, ast_format_g723, ast_format_g726, ast_format_g726_aal2, ast_format_g729, ast_format_gsm, ast_format_h263, ast_format_speex, ast_format_ulaw, and NULL.

Referenced by ooh323c_start_receive_channel(), and ooh323c_start_transmit_channel().

{
 switch(cap)
 {
 case OO_G711ULAW64K:
 return ast_format_ulaw;
 case OO_G711ALAW64K:
 return ast_format_alaw;
 case OO_GSMFULLRATE:
 return ast_format_gsm;
 case OO_SPEEX:
 return ast_format_speex;
 case OO_G729:
 return ast_format_g729;
 case OO_G729A:
 return ast_format_g729;
 case OO_G729B:
 return ast_format_g729;
 case OO_G7231:
 return ast_format_g723;
 case OO_G726:
 return ast_format_g726;
 case OO_G726AAL2:
 return ast_format_g726_aal2;
 case OO_H263VIDEO:
 return ast_format_h263;
 default:
 ast_debug(1, "Cap %d is not supported by driver yet\n", cap);
 return NULL;
 }

 return NULL;
}

ooh323c_call_thread()

void * ooh323c_call_thread

(

void *

dummy

)

Definition at line 80 of file ooh323cDriver.c.

References ast_free, ast_module_unref, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_update_use_count(), c, callthread::call, callThreads, callThreadsLock, FALSE, callthread::inUse, callthread::lock, callthread::next, NULL, callthread::prev, SEC_TO_HOLD_THREAD, and callthread::thePipe.

Referenced by ooh323c_start_call_thread().

{
 struct callthread* mycthread = (struct callthread *)dummy;
 struct pollfd pfds[1];
 char c;
 int res = 0;

 do {

 ooMonitorCallChannels((ooCallData*)mycthread->call);
 mycthread->call = NULL;
 mycthread->prev = NULL;
 mycthread->inUse = FALSE;

 ast_mutex_lock(&callThreadsLock);
 mycthread->next = callThreads;
 callThreads = mycthread;
 if (mycthread->next) mycthread->next->prev = mycthread;
 ast_mutex_unlock(&callThreadsLock);

 pfds[0].fd = mycthread->thePipe[0];
 pfds[0].events = POLLIN;
 ooSocketPoll(pfds, 1, SEC_TO_HOLD_THREAD * 1000);
 if (ooPDRead(pfds, 1, mycthread->thePipe[0]))
 res = read(mycthread->thePipe[0], &c, 1);

 ast_mutex_lock(&callThreadsLock);
 ast_mutex_lock(&mycthread->lock);
 if (mycthread->prev)
 mycthread->prev->next = mycthread->next;
 else
 callThreads = mycthread->next;
 if (mycthread->next)
 mycthread->next->prev = mycthread->prev;
 ast_mutex_unlock(&mycthread->lock);
 ast_mutex_unlock(&callThreadsLock);

 } while (mycthread->call != NULL && res >= 0);


 ast_mutex_destroy(&mycthread->lock);

 close(mycthread->thePipe[0]);
 close(mycthread->thePipe[1]);
 ast_free(mycthread);
 ast_module_unref(myself);
 ast_update_use_count();
 return NULL;
}

ooh323c_cmd_thread()

void * ooh323c_cmd_thread

(

void *

dummy

)

Definition at line 73 of file ooh323cDriver.c.

References dummy().

Referenced by ooh323c_start_stack_thread().

{

 ooMonitorCmdChannels();
 return dummy;
}

ooh323c_set_aliases()

int ooh323c_set_aliases

(

ooAliases *

aliases

)

Definition at line 566 of file ooh323cDriver.c.

References aliases, and ast_debug.

{
 ooAliases *cur = aliases;
 while(cur)
 {
 switch(cur->type)
 {
 case T_H225AliasAddress_dialedDigits:
 ooH323EpAddAliasDialedDigits(cur->value);
 break;
 case T_H225AliasAddress_h323_ID:
 ooH323EpAddAliasH323ID(cur->value);
 break;
 case T_H225AliasAddress_url_ID:
 ooH323EpAddAliasURLID(cur->value);
 break;
 case T_H225AliasAddress_email_ID:
 ooH323EpAddAliasEmailID(cur->value);
 break;
 default:
 ast_debug(1, "Ignoring unknown alias type\n");
 }
 cur = cur->next;
 }
 return 1;
}

ooh323c_set_capability()

int ooh323c_set_capability	(	struct ast_format_cap *	cap,
		int	dtmf,
		int	dtmfcodec
	)

Definition at line 228 of file ooh323cDriver.c.

References ao2_ref, ast_format_alaw, ast_format_cap_count(), ast_format_cap_get_format(), ast_format_cmp(), AST_FORMAT_CMP_EQUAL, ast_format_g723, ast_format_g726, ast_format_g726_aal2, ast_format_g729, ast_format_gsm, ast_format_h263, ast_format_speex, ast_format_ulaw, ast_verb, FALSE, format, gH323Debug, grxframes, gtxframes, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_RFC2833, ooh323c_set_capability_for_call(), ooh323c_start_receive_channel(), ooh323c_start_transmit_channel(), ooh323c_stop_receive_channel(), and ooh323c_stop_transmit_channel().

Referenced by load_module(), and ooh323c_stop_stack_thread().

{
 int ret = 0, x;
 if (gH323Debug) {
 ast_verb(0, "\tAdding capabilities to H323 endpoint\n");
 }

 for(x=0; x<ast_format_cap_count(cap); x++)
 {
 struct ast_format *format = ast_format_cap_get_format(cap, x);
 if(ast_format_cmp(format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g711 ulaw capability to H323 endpoint\n");
 }
 ret= ooH323EpAddG711Capability(OO_G711ULAW64K, gtxframes, grxframes,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }
 if(ast_format_cmp(format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g711 alaw capability to H323 endpoint\n");
 }
 ret= ooH323EpAddG711Capability(OO_G711ALAW64K, gtxframes, grxframes,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }

 if(ast_format_cmp(format, ast_format_g729) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g729A capability to H323 endpoint\n");
 }
 ret = ooH323EpAddG729Capability(OO_G729A, 2, 24,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 if (gH323Debug) {
 ast_verb(0, "\tAdding g729 capability to H323 endpoint\n");
 }
 ret |= ooH323EpAddG729Capability(OO_G729, 2, 24,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 if (gH323Debug) {
 ast_verb(0, "\tAdding g729b capability to H323 endpoint\n");
 }
 ret |= ooH323EpAddG729Capability(OO_G729B, 2, 24,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }

 if(ast_format_cmp(format, ast_format_g723) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g7231 capability to H323 endpoint\n");
 }
 ret = ooH323EpAddG7231Capability(OO_G7231, 1, 1, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_g726) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g726 capability to H323 endpoint\n");
 }
 ret = ooH323EpAddG726Capability(OO_G726, gtxframes, grxframes, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g726aal2 capability to H323 endpoint\n");
 }
 ret = ooH323EpAddG726Capability(OO_G726AAL2, gtxframes, grxframes, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_h263) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding h263 capability to H323 endpoint\n");
 }
 ret = ooH323EpAddH263VideoCapability(OO_H263VIDEO, 1, 0, 0, 0, 0, 320*1024,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_gsm) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding gsm capability to H323 endpoint\n");
 }
 ret = ooH323EpAddGSMCapability(OO_GSMFULLRATE, 4, FALSE, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_speex) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding speex capability to H323 endpoint\n");
 }
 ret = ooH323EpAddSpeexCapability(OO_SPEEX, 4, 4, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 ao2_ref(format, -1);
 }

 if(dtmf & H323_DTMF_CISCO)
 ret |= ooH323EpEnableDTMFCISCO(0);
 if(dtmf & H323_DTMF_RFC2833)
 ret |= ooH323EpEnableDTMFRFC2833(0);
 else if(dtmf & H323_DTMF_H245ALPHANUMERIC)
 ret |= ooH323EpEnableDTMFH245Alphanumeric();
 else if(dtmf & H323_DTMF_H245SIGNAL)
 ret |= ooH323EpEnableDTMFH245Signal();

 return ret;
}

ooh323c_set_capability_for_call()

int ooh323c_set_capability_for_call	(	ooCallData *	call,
		struct ast_format_cap *	cap,
		int	dtmf,
		int	dtmfcodec,
		int	t38support,
		int	g729onlyA
	)

Definition at line 384 of file ooh323cDriver.c.

References ao2_ref, ast_format_alaw, ast_format_cap_count(), ast_format_cap_get_format(), ast_format_cap_get_format_framing(), ast_format_cmp(), AST_FORMAT_CMP_EQUAL, ast_format_g723, ast_format_g726, ast_format_g726_aal2, ast_format_g729, ast_format_gsm, ast_format_h263, ast_format_speex, ast_format_ulaw, ast_verb, FALSE, format, gH323Debug, grxframes, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_RFC2833, ooh323c_start_receive_channel(), ooh323c_start_receive_datachannel(), ooh323c_start_transmit_channel(), ooh323c_start_transmit_datachannel(), ooh323c_stop_receive_channel(), ooh323c_stop_receive_datachannel(), ooh323c_stop_transmit_channel(), and ooh323c_stop_transmit_datachannel().

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

{
 int ret = 0, x, txframes;
 if (gH323Debug) {
 ast_verb(0, "\tAdding capabilities to call(%s, %s)\n", call->callType,
 call->callToken);
 }
 if(dtmf & H323_DTMF_CISCO || 1)
 ret |= ooCallEnableDTMFCISCO(call,dtmfcodec);
 if(dtmf & H323_DTMF_RFC2833 || 1)
 ret |= ooCallEnableDTMFRFC2833(call,dtmfcodec);
 if(dtmf & H323_DTMF_H245ALPHANUMERIC || 1)
 ret |= ooCallEnableDTMFH245Alphanumeric(call);
 if(dtmf & H323_DTMF_H245SIGNAL || 1)
 ret |= ooCallEnableDTMFH245Signal(call);

 if (t38support)
 ooCapabilityAddT38Capability(call, OO_T38, OORXANDTX,
 &ooh323c_start_receive_datachannel,
 &ooh323c_start_transmit_datachannel,
 &ooh323c_stop_receive_datachannel,
 &ooh323c_stop_transmit_datachannel,
 0);

 for(x=0; x<ast_format_cap_count(cap); x++)
 {
 struct ast_format *format = ast_format_cap_get_format(cap, x);
 if(ast_format_cmp(format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g711 ulaw capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 txframes = ast_format_cap_get_format_framing(cap, format);
 ret= ooCallAddG711Capability(call, OO_G711ULAW64K, txframes,
 txframes, OORXANDTX,
 &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }
 if(ast_format_cmp(format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g711 alaw capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 txframes = ast_format_cap_get_format_framing(cap, format);
 ret= ooCallAddG711Capability(call, OO_G711ALAW64K, txframes,
 txframes, OORXANDTX,
 &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }

 if(ast_format_cmp(format, ast_format_g726) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g726 capability to call (%s, %s)\n",
 call->callType, call->callToken);
 }
 txframes = ast_format_cap_get_format_framing(cap, format);
 ret = ooCallAddG726Capability(call, OO_G726, txframes, grxframes, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g726aal2 capability to call (%s, %s)\n",
 call->callType, call->callToken);
 }
 txframes = ast_format_cap_get_format_framing(cap, format);
 ret = ooCallAddG726Capability(call, OO_G726AAL2, txframes, grxframes, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_g729) == AST_FORMAT_CMP_EQUAL)
 {

 txframes = (ast_format_cap_get_format_framing(cap, format))/10;
 if (gH323Debug) {
 ast_verb(0, "\tAdding g729A capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 ret= ooCallAddG729Capability(call, OO_G729A, txframes, txframes,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 if (g729onlyA)
 continue;
 if (gH323Debug) {
 ast_verb(0, "\tAdding g729 capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 ret|= ooCallAddG729Capability(call, OO_G729, txframes, txframes,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 if (gH323Debug) {
 ast_verb(0, "\tAdding g729B capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 ret|= ooCallAddG729Capability(call, OO_G729B, txframes, txframes,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_g723) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding g7231 capability to call (%s, %s)\n",
 call->callType, call->callToken);
 }
 ret = ooCallAddG7231Capability(call, OO_G7231, 1, 1, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_h263) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding h263 capability to call (%s, %s)\n",
 call->callType, call->callToken);
 }
 ret = ooCallAddH263VideoCapability(call, OO_H263VIDEO, 1, 0, 0, 0, 0, 320*1024,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);

 }

 if(ast_format_cmp(format, ast_format_gsm) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding gsm capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 ret = ooCallAddGSMCapability(call, OO_GSMFULLRATE, 4, FALSE, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }

 if(ast_format_cmp(format, ast_format_speex) == AST_FORMAT_CMP_EQUAL)
 {
 if (gH323Debug) {
 ast_verb(0, "\tAdding Speex capability to call(%s, %s)\n",
 call->callType, call->callToken);
 }
 ret = ooCallAddSpeexCapability(call, OO_SPEEX, 4, 4, FALSE,
 OORXANDTX, &ooh323c_start_receive_channel,
 &ooh323c_start_transmit_channel,
 &ooh323c_stop_receive_channel,
 &ooh323c_stop_transmit_channel);
 }

 ao2_ref(format, -1);
 }
 return ret;
}

ooh323c_stack_thread()

void * ooh323c_stack_thread

(

void *

dummy

)

Definition at line 66 of file ooh323cDriver.c.

References dummy().

Referenced by ooh323c_start_stack_thread().

{

 ooMonitorChannels();
 return dummy;
}

ooh323c_start_call_thread()

int ooh323c_start_call_thread

(

ooCallData *

call

)

Definition at line 130 of file ooh323cDriver.c.

References ast_calloc, ast_debug, ast_free, ast_log, ast_module_ref, ast_mutex_destroy, ast_mutex_init, ast_mutex_lock, ast_mutex_trylock, ast_mutex_unlock, ast_pthread_create_detached_background, c, callthread::call, callThreads, callThreadsLock, gH323Debug, callthread::inUse, callthread::lock, LOG_ERROR, callthread::next, NULL, ooh323c_call_thread(), PF_LOCAL, callthread::thePipe, and TRUE.

Referenced by onNewCallCreated().

 {
 char c = 'c';
 struct callthread *cur = callThreads;

 ast_mutex_lock(&callThreadsLock);
 while (cur != NULL && (cur->inUse || ast_mutex_trylock(&cur->lock))) {
 cur = cur->next;
 }
 ast_mutex_unlock(&callThreadsLock);

 if (cur != NULL) {
 if (cur->inUse || write(cur->thePipe[1], &c, 1) < 0) {
 ast_mutex_unlock(&cur->lock);
 cur = NULL;
 }
 }

/* make new thread */
 if (cur == NULL) {
 if (!(cur = ast_calloc(1, sizeof(struct callthread)))) {
 ast_log(LOG_ERROR, "Unable to allocate thread structure for call %s\n",
 call->callToken);
 return -1;
 }

 ast_module_ref(myself);
 if ((socketpair(PF_LOCAL, SOCK_STREAM, 0, cur->thePipe)) == -1) {
 ast_log(LOG_ERROR, "Can't create thread pipe for call %s\n", call->callToken);
 ast_free(cur);
 return -1;
 }
 cur->inUse = TRUE;
 cur->call = call;

 ast_mutex_init(&cur->lock);

 if (gH323Debug)
 ast_debug(1,"new call thread created for call %s\n", call->callToken);

 if(ast_pthread_create_detached_background(&call->callThread, NULL, ooh323c_call_thread, cur) < 0)
 {
 ast_log(LOG_ERROR, "Unable to start ooh323c call thread for call %s\n",
 call->callToken);
 ast_mutex_destroy(&cur->lock);
 close(cur->thePipe[0]);
 close(cur->thePipe[1]);
 ast_free(cur);
 return -1;
 }

 } else {
 if (gH323Debug)
 ast_debug(1,"using existing call thread for call %s\n", call->callToken);
 cur->inUse = TRUE;
 cur->call = call;
 ast_mutex_unlock(&cur->lock);

 }
 return 0;
}

ooh323c_start_receive_channel()

int ooh323c_start_receive_channel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 593 of file ooh323cDriver.c.

References ast_log, convertH323CapToAsteriskCap(), LOG_ERROR, and NULL.

Referenced by ooh323c_set_capability(), and ooh323c_set_capability_for_call().

{
 struct ast_format *tmpfmt = NULL;
 tmpfmt = convertH323CapToAsteriskCap(pChannel->chanCap->cap);
 if(tmpfmt) {
 /* ooh323_set_read_format(call, fmt); */
 }else{
 ast_log(LOG_ERROR, "Invalid capability type for receive channel %s\n",
 call->callToken);
 return -1;
 }
 return 1;
}

ooh323c_start_receive_datachannel()

int ooh323c_start_receive_datachannel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 642 of file ooh323cDriver.c.

Referenced by ooh323c_set_capability_for_call().

{
 return 1;
}

ooh323c_start_stack_thread()

int ooh323c_start_stack_thread

(

void

)

Definition at line 199 of file ooh323cDriver.c.

References ast_log, ast_pthread_create_background, LOG_ERROR, NULL, ooh323c_cmd_thread(), ooh323c_stack_thread(), ooh323c_thread, and ooh323cmd_thread.

Referenced by load_module().

{
 if(ast_pthread_create_background(&ooh323c_thread, NULL, ooh323c_stack_thread, NULL) < 0)
 {
 ast_log(LOG_ERROR, "Unable to start ooh323c thread.\n");
 return -1;
 }
 if(ast_pthread_create_background(&ooh323cmd_thread, NULL, ooh323c_cmd_thread, NULL) < 0)
 {
 ast_log(LOG_ERROR, "Unable to start ooh323cmd thread.\n");
 return -1;
 }
 return 0;
}

ooh323c_start_transmit_channel()

int ooh323c_start_transmit_channel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 607 of file ooh323cDriver.c.

References ast_format_alaw, ast_format_cmp(), AST_FORMAT_CMP_EQUAL, ast_format_g729, ast_format_ulaw, ast_log, convertH323CapToAsteriskCap(), LOG_ERROR, NULL, ooh323_set_write_format(), and setup_rtp_connection().

Referenced by ooh323c_set_capability(), and ooh323c_set_capability_for_call().

{
 struct ast_format *tmpfmt = NULL;
 tmpfmt = convertH323CapToAsteriskCap(pChannel->chanCap->cap);

 if (tmpfmt) {
 if ((ast_format_cmp(tmpfmt, ast_format_alaw) == AST_FORMAT_CMP_EQUAL) ||
 (ast_format_cmp(tmpfmt, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL)) {
 ooh323_set_write_format(call, tmpfmt, ((OOCapParams *)(pChannel->chanCap->params))->txframes);
 } else if (ast_format_cmp(tmpfmt, ast_format_g729) == AST_FORMAT_CMP_EQUAL) {
 ooh323_set_write_format(call, tmpfmt, ((OOCapParams *)(pChannel->chanCap->params))->txframes*10);
 } else {
 ooh323_set_write_format(call, tmpfmt, 0);
 }
 }else{
 ast_log(LOG_ERROR, "Invalid capability type for receive channel %s\n",
 call->callToken);
 return -1;
 }
 setup_rtp_connection(call, pChannel->remoteIP, pChannel->remoteMediaPort);
 return 1;
}

ooh323c_start_transmit_datachannel()

int ooh323c_start_transmit_datachannel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 647 of file ooh323cDriver.c.

References setup_udptl_connection().

Referenced by ooh323c_set_capability_for_call().

{
 setup_udptl_connection(call, pChannel->remoteIP, pChannel->remoteMediaPort);
 return 1;
}

ooh323c_stop_call_thread()

int ooh323c_stop_call_thread

(

ooCallData *

call

)

Definition at line 192 of file ooh323cDriver.c.

References AST_PTHREADT_NULL.

Referenced by onCallCleared().

 {
 if (call->callThread != AST_PTHREADT_NULL) {
 ooStopMonitorCallChannels(call);
 }
 return 0;
}

ooh323c_stop_receive_channel()

int ooh323c_stop_receive_channel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 630 of file ooh323cDriver.c.

Referenced by ooh323c_set_capability(), and ooh323c_set_capability_for_call().

{
 return 1;
}

ooh323c_stop_receive_datachannel()

int ooh323c_stop_receive_datachannel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 653 of file ooh323cDriver.c.

Referenced by ooh323c_set_capability_for_call().

{
 return 1;
}

ooh323c_stop_stack_thread()

int ooh323c_stop_stack_thread

(

void

)

Definition at line 214 of file ooh323cDriver.c.

References AST_PTHREADT_NULL, NULL, ooh323c_set_capability(), ooh323c_thread, and ooh323cmd_thread.

Referenced by unload_module().

{
 if(ooh323c_thread != AST_PTHREADT_NULL)
 {
 ooStopMonitor();
 pthread_join(ooh323c_thread, NULL);
 ooh323c_thread = AST_PTHREADT_NULL;
 pthread_join(ooh323cmd_thread, NULL);
 ooh323cmd_thread = AST_PTHREADT_NULL;
 }
 return 0;
}

ooh323c_stop_transmit_channel()

int ooh323c_stop_transmit_channel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 635 of file ooh323cDriver.c.

References close_rtp_connection().

Referenced by ooh323c_set_capability(), and ooh323c_set_capability_for_call().

{
 close_rtp_connection(call);
 return 1;
}

ooh323c_stop_transmit_datachannel()

int ooh323c_stop_transmit_datachannel	(	ooCallData *	call,
		ooLogicalChannel *	pChannel
	)

Definition at line 658 of file ooh323cDriver.c.

References close_udptl_connection().

Referenced by ooh323c_set_capability_for_call().

{
 close_udptl_connection(call);
 return 1;
}

Variable Documentation

callThreads

struct callthread * callThreads = NULL

static

Referenced by ooh323c_call_thread(), and ooh323c_start_call_thread().

callThreadsLock

ast_mutex_t callThreadsLock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 48 of file ooh323cDriver.c.

Referenced by ooh323c_call_thread(), and ooh323c_start_call_thread().

gH323Debug

OOBOOL gH323Debug

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

grxframes

int grxframes = 240

static

Definition at line 36 of file ooh323cDriver.c.

Referenced by ooh323c_set_capability(), and ooh323c_set_capability_for_call().

gtxframes

int gtxframes = 20

static

Definition at line 38 of file ooh323cDriver.c.

Referenced by ooh323c_set_capability().

myself

struct ast_module* myself

Definition at line 113 of file chan_ooh323.c.

ooh323c_thread

pthread_t ooh323c_thread = AST_PTHREADT_NULL

static

Definition at line 34 of file ooh323cDriver.c.

Referenced by ooh323c_start_stack_thread(), and ooh323c_stop_stack_thread().

ooh323cmd_thread

pthread_t ooh323cmd_thread = AST_PTHREADT_NULL

static

Definition at line 35 of file ooh323cDriver.c.

Referenced by ooh323c_start_stack_thread(), and ooh323c_stop_stack_thread().