Asterisk - The Open Source Telephony Project GIT-master-7e7a603
Macros | Functions
ooh323cDriver.h File Reference
#include "chan_ooh323.h"
#include "ootypes.h"
#include "ooh323ep.h"
#include "oochannels.h"
#include "ooCalls.h"
#include "ooCapability.h"
#include "ooStackCmds.h"
#include "asterisk/format.h"
Include dependency graph for ooh323cDriver.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros

#define H323_DTMF_CISCO   (1 << 5)
 
#define H323_DTMF_H245ALPHANUMERIC   (1 << 2)
 
#define H323_DTMF_H245SIGNAL   (1 << 3)
 
#define H323_DTMF_INBAND   (1 << 4)
 
#define H323_DTMF_INBANDRELAX   (1 << 8)
 
#define H323_DTMF_Q931   (1 << 1)
 
#define H323_DTMF_RFC2833   (1 << 0)
 

Functions

struct ast_format * convertH323CapToAsteriskCap (int cap)
 
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)
 
int ooh323c_start_call_thread (ooCallData *call)
 
int ooh323c_start_stack_thread (void)
 
int ooh323c_stop_call_thread (ooCallData *call)
 
int ooh323c_stop_stack_thread (void)
 

Macro Definition Documentation

◆ H323_DTMF_CISCO

#define H323_DTMF_CISCO   (1 << 5)

Definition at line 31 of file ooh323cDriver.h.

◆ H323_DTMF_H245ALPHANUMERIC

#define H323_DTMF_H245ALPHANUMERIC   (1 << 2)

Definition at line 28 of file ooh323cDriver.h.

◆ H323_DTMF_H245SIGNAL

#define H323_DTMF_H245SIGNAL   (1 << 3)

Definition at line 29 of file ooh323cDriver.h.

◆ H323_DTMF_INBAND

#define H323_DTMF_INBAND   (1 << 4)

Definition at line 30 of file ooh323cDriver.h.

◆ H323_DTMF_INBANDRELAX

#define H323_DTMF_INBANDRELAX   (1 << 8)

Definition at line 32 of file ooh323cDriver.h.

◆ H323_DTMF_Q931

#define H323_DTMF_Q931   (1 << 1)

Definition at line 27 of file ooh323cDriver.h.

◆ H323_DTMF_RFC2833

#define H323_DTMF_RFC2833   (1 << 0)

Definition at line 26 of file ooh323cDriver.h.

Function Documentation

◆ convertH323CapToAsteriskCap()

struct ast_format * convertH323CapToAsteriskCap ( int  cap)

Definition at line 664 of file ooh323cDriver.c.

665{
666 switch(cap)
667 {
668 case OO_G711ULAW64K:
669 return ast_format_ulaw;
670 case OO_G711ALAW64K:
671 return ast_format_alaw;
672 case OO_GSMFULLRATE:
673 return ast_format_gsm;
674 case OO_SPEEX:
675 return ast_format_speex;
676 case OO_G729:
677 return ast_format_g729;
678 case OO_G729A:
679 return ast_format_g729;
680 case OO_G729B:
681 return ast_format_g729;
682 case OO_G7231:
683 return ast_format_g723;
684 case OO_G726:
685 return ast_format_g726;
686 case OO_G726AAL2:
687 return ast_format_g726_aal2;
688 case OO_H263VIDEO:
689 return ast_format_h263;
690 default:
691 ast_debug(1, "Cap %d is not supported by driver yet\n", cap);
692 return NULL;
693 }
694
695 return NULL;
696}
ast_format_gsm
struct ast_format * ast_format_gsm
Built-in cached gsm format.
Definition: format_cache.c:96
ast_format_speex
struct ast_format * ast_format_speex
Built-in cached speex format.
Definition: format_cache.c:131
ast_format_h263
struct ast_format * ast_format_h263
Built-in cached h263 format.
Definition: format_cache.c:166
ast_format_g726
struct ast_format * ast_format_g726
Built-in cached g726 format.
Definition: format_cache.c:111
ast_format_ulaw
struct ast_format * ast_format_ulaw
Built-in cached ulaw format.
Definition: format_cache.c:86
ast_format_g723
struct ast_format * ast_format_g723
Built-in cached g723.1 format.
Definition: format_cache.c:146
ast_format_alaw
struct ast_format * ast_format_alaw
Built-in cached alaw format.
Definition: format_cache.c:91
ast_format_g726_aal2
struct ast_format * ast_format_g726_aal2
Built-in cached g726 aal2 format.
Definition: format_cache.c:116
ast_format_g729
struct ast_format * ast_format_g729
Built-in cached g729 format.
Definition: format_cache.c:151
ast_debug
#define ast_debug(level,...)
Log a DEBUG message.
Definition: include/asterisk/logger.h:451
NULL
#define NULL
Definition: resample.c:96

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

◆ ooh323c_set_capability()

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

Definition at line 227 of file ooh323cDriver.c.

229{
230 int ret = 0, x;
231 if (gH323Debug) {
232 ast_verb(0, "\tAdding capabilities to H323 endpoint\n");
233 }
234
235 for(x=0; x<ast_format_cap_count(cap); x++)
236 {
237 struct ast_format *format = ast_format_cap_get_format(cap, x);
238 if(ast_format_cmp(format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL)
239 {
240 if (gH323Debug) {
241 ast_verb(0, "\tAdding g711 ulaw capability to H323 endpoint\n");
242 }
243 ret= ooH323EpAddG711Capability(OO_G711ULAW64K, gtxframes, grxframes,
244 OORXANDTX, &ooh323c_start_receive_channel,
245 &ooh323c_start_transmit_channel,
246 &ooh323c_stop_receive_channel,
247 &ooh323c_stop_transmit_channel);
248 }
249 if(ast_format_cmp(format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL)
250 {
251 if (gH323Debug) {
252 ast_verb(0, "\tAdding g711 alaw capability to H323 endpoint\n");
253 }
254 ret= ooH323EpAddG711Capability(OO_G711ALAW64K, gtxframes, grxframes,
255 OORXANDTX, &ooh323c_start_receive_channel,
256 &ooh323c_start_transmit_channel,
257 &ooh323c_stop_receive_channel,
258 &ooh323c_stop_transmit_channel);
259 }
260
261 if(ast_format_cmp(format, ast_format_g729) == AST_FORMAT_CMP_EQUAL)
262 {
263 if (gH323Debug) {
264 ast_verb(0, "\tAdding g729A capability to H323 endpoint\n");
265 }
266 ret = ooH323EpAddG729Capability(OO_G729A, 2, 24,
267 OORXANDTX, &ooh323c_start_receive_channel,
268 &ooh323c_start_transmit_channel,
269 &ooh323c_stop_receive_channel,
270 &ooh323c_stop_transmit_channel);
271
272 if (gH323Debug) {
273 ast_verb(0, "\tAdding g729 capability to H323 endpoint\n");
274 }
275 ret |= ooH323EpAddG729Capability(OO_G729, 2, 24,
276 OORXANDTX, &ooh323c_start_receive_channel,
277 &ooh323c_start_transmit_channel,
278 &ooh323c_stop_receive_channel,
279 &ooh323c_stop_transmit_channel);
280 if (gH323Debug) {
281 ast_verb(0, "\tAdding g729b capability to H323 endpoint\n");
282 }
283 ret |= ooH323EpAddG729Capability(OO_G729B, 2, 24,
284 OORXANDTX, &ooh323c_start_receive_channel,
285 &ooh323c_start_transmit_channel,
286 &ooh323c_stop_receive_channel,
287 &ooh323c_stop_transmit_channel);
288 }
289
290 if(ast_format_cmp(format, ast_format_g723) == AST_FORMAT_CMP_EQUAL)
291 {
292 if (gH323Debug) {
293 ast_verb(0, "\tAdding g7231 capability to H323 endpoint\n");
294 }
295 ret = ooH323EpAddG7231Capability(OO_G7231, 1, 1, FALSE,
296 OORXANDTX, &ooh323c_start_receive_channel,
297 &ooh323c_start_transmit_channel,
298 &ooh323c_stop_receive_channel,
299 &ooh323c_stop_transmit_channel);
300
301 }
302
303 if(ast_format_cmp(format, ast_format_g726) == AST_FORMAT_CMP_EQUAL)
304 {
305 if (gH323Debug) {
306 ast_verb(0, "\tAdding g726 capability to H323 endpoint\n");
307 }
308 ret = ooH323EpAddG726Capability(OO_G726, gtxframes, grxframes, FALSE,
309 OORXANDTX, &ooh323c_start_receive_channel,
310 &ooh323c_start_transmit_channel,
311 &ooh323c_stop_receive_channel,
312 &ooh323c_stop_transmit_channel);
313
314 }
315
316 if(ast_format_cmp(format, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL)
317 {
318 if (gH323Debug) {
319 ast_verb(0, "\tAdding g726aal2 capability to H323 endpoint\n");
320 }
321 ret = ooH323EpAddG726Capability(OO_G726AAL2, gtxframes, grxframes, FALSE,
322 OORXANDTX, &ooh323c_start_receive_channel,
323 &ooh323c_start_transmit_channel,
324 &ooh323c_stop_receive_channel,
325 &ooh323c_stop_transmit_channel);
326
327 }
328
329 if(ast_format_cmp(format, ast_format_h263) == AST_FORMAT_CMP_EQUAL)
330 {
331 if (gH323Debug) {
332 ast_verb(0, "\tAdding h263 capability to H323 endpoint\n");
333 }
334 ret = ooH323EpAddH263VideoCapability(OO_H263VIDEO, 1, 0, 0, 0, 0, 320*1024,
335 OORXANDTX, &ooh323c_start_receive_channel,
336 &ooh323c_start_transmit_channel,
337 &ooh323c_stop_receive_channel,
338 &ooh323c_stop_transmit_channel);
339
340 }
341
342 if(ast_format_cmp(format, ast_format_gsm) == AST_FORMAT_CMP_EQUAL)
343 {
344 if (gH323Debug) {
345 ast_verb(0, "\tAdding gsm capability to H323 endpoint\n");
346 }
347 ret = ooH323EpAddGSMCapability(OO_GSMFULLRATE, 4, FALSE, FALSE,
348 OORXANDTX, &ooh323c_start_receive_channel,
349 &ooh323c_start_transmit_channel,
350 &ooh323c_stop_receive_channel,
351 &ooh323c_stop_transmit_channel);
352
353 }
354
355 if(ast_format_cmp(format, ast_format_speex) == AST_FORMAT_CMP_EQUAL)
356 {
357 if (gH323Debug) {
358 ast_verb(0, "\tAdding speex capability to H323 endpoint\n");
359 }
360 ret = ooH323EpAddSpeexCapability(OO_SPEEX, 4, 4, FALSE,
361 OORXANDTX, &ooh323c_start_receive_channel,
362 &ooh323c_start_transmit_channel,
363 &ooh323c_stop_receive_channel,
364 &ooh323c_stop_transmit_channel);
365
366 }
367
368 ao2_ref(format, -1);
369 }
370
371 if(dtmf & H323_DTMF_CISCO)
372 ret |= ooH323EpEnableDTMFCISCO(0);
373 if(dtmf & H323_DTMF_RFC2833)
374 ret |= ooH323EpEnableDTMFRFC2833(0);
375 else if(dtmf & H323_DTMF_H245ALPHANUMERIC)
376 ret |= ooH323EpEnableDTMFH245Alphanumeric();
377 else if(dtmf & H323_DTMF_H245SIGNAL)
378 ret |= ooH323EpEnableDTMFH245Signal();
379
380 return ret;
381}
FALSE
#define FALSE
Definition: app_minivm.c:527
ao2_ref
#define ao2_ref(o, delta)
Reference/unreference an object and return the old refcount.
Definition: astobj2.h:459
ast_format_cmp
enum ast_format_cmp_res ast_format_cmp(const struct ast_format *format1, const struct ast_format *format2)
Compare two formats.
Definition: format.c:201
AST_FORMAT_CMP_EQUAL
@ AST_FORMAT_CMP_EQUAL
Definition: format.h:36
ast_format_cap_get_format
struct ast_format * ast_format_cap_get_format(const struct ast_format_cap *cap, int position)
Get the format at a specific index.
Definition: format_cap.c:400
ast_format_cap_count
size_t ast_format_cap_count(const struct ast_format_cap *cap)
Get the number of formats present within the capabilities structure.
Definition: format_cap.c:395
ast_verb
#define ast_verb(level,...)
Definition: include/asterisk/logger.h:462
gH323Debug
OOBOOL gH323Debug
Definition: chan_ooh323.c:381
ooh323c_start_receive_channel
int ooh323c_start_receive_channel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:593
ooh323c_stop_receive_channel
int ooh323c_stop_receive_channel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:630
grxframes
static int grxframes
Definition: ooh323cDriver.c:36
ooh323c_start_transmit_channel
int ooh323c_start_transmit_channel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:607
gtxframes
static int gtxframes
Definition: ooh323cDriver.c:38
ooh323c_stop_transmit_channel
int ooh323c_stop_transmit_channel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:635
H323_DTMF_H245ALPHANUMERIC
#define H323_DTMF_H245ALPHANUMERIC
Definition: ooh323cDriver.h:28
H323_DTMF_RFC2833
#define H323_DTMF_RFC2833
Definition: ooh323cDriver.h:26
H323_DTMF_H245SIGNAL
#define H323_DTMF_H245SIGNAL
Definition: ooh323cDriver.h:29
H323_DTMF_CISCO
#define H323_DTMF_CISCO
Definition: ooh323cDriver.h:31
ast_format
Definition of a media format.
Definition: format.c:43

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, gH323Debug, grxframes, gtxframes, H323_DTMF_CISCO, H323_DTMF_H245ALPHANUMERIC, H323_DTMF_H245SIGNAL, H323_DTMF_RFC2833, ooh323c_start_receive_channel(), ooh323c_start_transmit_channel(), ooh323c_stop_receive_channel(), and ooh323c_stop_transmit_channel().

Referenced by load_module().

◆ 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 383 of file ooh323cDriver.c.

386{
387 int ret = 0, x, txframes;
388 if (gH323Debug) {
389 ast_verb(0, "\tAdding capabilities to call(%s, %s)\n", call->callType,
390 call->callToken);
391 }
392 if(dtmf & H323_DTMF_CISCO || 1)
393 ret |= ooCallEnableDTMFCISCO(call,dtmfcodec);
394 if(dtmf & H323_DTMF_RFC2833 || 1)
395 ret |= ooCallEnableDTMFRFC2833(call,dtmfcodec);
396 if(dtmf & H323_DTMF_H245ALPHANUMERIC || 1)
397 ret |= ooCallEnableDTMFH245Alphanumeric(call);
398 if(dtmf & H323_DTMF_H245SIGNAL || 1)
399 ret |= ooCallEnableDTMFH245Signal(call);
400
401 if (t38support)
402 ooCapabilityAddT38Capability(call, OO_T38, OORXANDTX,
403 &ooh323c_start_receive_datachannel,
404 &ooh323c_start_transmit_datachannel,
405 &ooh323c_stop_receive_datachannel,
406 &ooh323c_stop_transmit_datachannel,
407 0);
408
409 for(x=0; x<ast_format_cap_count(cap); x++)
410 {
411 struct ast_format *format = ast_format_cap_get_format(cap, x);
412 if(ast_format_cmp(format, ast_format_ulaw) == AST_FORMAT_CMP_EQUAL)
413 {
414 if (gH323Debug) {
415 ast_verb(0, "\tAdding g711 ulaw capability to call(%s, %s)\n",
416 call->callType, call->callToken);
417 }
418 txframes = ast_format_cap_get_format_framing(cap, format);
419 ret= ooCallAddG711Capability(call, OO_G711ULAW64K, txframes,
420 txframes, OORXANDTX,
421 &ooh323c_start_receive_channel,
422 &ooh323c_start_transmit_channel,
423 &ooh323c_stop_receive_channel,
424 &ooh323c_stop_transmit_channel);
425 }
426 if(ast_format_cmp(format, ast_format_alaw) == AST_FORMAT_CMP_EQUAL)
427 {
428 if (gH323Debug) {
429 ast_verb(0, "\tAdding g711 alaw capability to call(%s, %s)\n",
430 call->callType, call->callToken);
431 }
432 txframes = ast_format_cap_get_format_framing(cap, format);
433 ret= ooCallAddG711Capability(call, OO_G711ALAW64K, txframes,
434 txframes, OORXANDTX,
435 &ooh323c_start_receive_channel,
436 &ooh323c_start_transmit_channel,
437 &ooh323c_stop_receive_channel,
438 &ooh323c_stop_transmit_channel);
439 }
440
441 if(ast_format_cmp(format, ast_format_g726) == AST_FORMAT_CMP_EQUAL)
442 {
443 if (gH323Debug) {
444 ast_verb(0, "\tAdding g726 capability to call (%s, %s)\n",
445 call->callType, call->callToken);
446 }
447 txframes = ast_format_cap_get_format_framing(cap, format);
448 ret = ooCallAddG726Capability(call, OO_G726, txframes, grxframes, FALSE,
449 OORXANDTX, &ooh323c_start_receive_channel,
450 &ooh323c_start_transmit_channel,
451 &ooh323c_stop_receive_channel,
452 &ooh323c_stop_transmit_channel);
453
454 }
455
456 if(ast_format_cmp(format, ast_format_g726_aal2) == AST_FORMAT_CMP_EQUAL)
457 {
458 if (gH323Debug) {
459 ast_verb(0, "\tAdding g726aal2 capability to call (%s, %s)\n",
460 call->callType, call->callToken);
461 }
462 txframes = ast_format_cap_get_format_framing(cap, format);
463 ret = ooCallAddG726Capability(call, OO_G726AAL2, txframes, grxframes, FALSE,
464 OORXANDTX, &ooh323c_start_receive_channel,
465 &ooh323c_start_transmit_channel,
466 &ooh323c_stop_receive_channel,
467 &ooh323c_stop_transmit_channel);
468
469 }
470
471 if(ast_format_cmp(format, ast_format_g729) == AST_FORMAT_CMP_EQUAL)
472 {
473
474 txframes = (ast_format_cap_get_format_framing(cap, format))/10;
475 if (gH323Debug) {
476 ast_verb(0, "\tAdding g729A capability to call(%s, %s)\n",
477 call->callType, call->callToken);
478 }
479 ret= ooCallAddG729Capability(call, OO_G729A, txframes, txframes,
480 OORXANDTX, &ooh323c_start_receive_channel,
481 &ooh323c_start_transmit_channel,
482 &ooh323c_stop_receive_channel,
483 &ooh323c_stop_transmit_channel);
484 if (g729onlyA)
485 continue;
486 if (gH323Debug) {
487 ast_verb(0, "\tAdding g729 capability to call(%s, %s)\n",
488 call->callType, call->callToken);
489 }
490 ret|= ooCallAddG729Capability(call, OO_G729, txframes, txframes,
491 OORXANDTX, &ooh323c_start_receive_channel,
492 &ooh323c_start_transmit_channel,
493 &ooh323c_stop_receive_channel,
494 &ooh323c_stop_transmit_channel);
495 if (gH323Debug) {
496 ast_verb(0, "\tAdding g729B capability to call(%s, %s)\n",
497 call->callType, call->callToken);
498 }
499 ret|= ooCallAddG729Capability(call, OO_G729B, txframes, txframes,
500 OORXANDTX, &ooh323c_start_receive_channel,
501 &ooh323c_start_transmit_channel,
502 &ooh323c_stop_receive_channel,
503 &ooh323c_stop_transmit_channel);
504
505 }
506
507 if(ast_format_cmp(format, ast_format_g723) == AST_FORMAT_CMP_EQUAL)
508 {
509 if (gH323Debug) {
510 ast_verb(0, "\tAdding g7231 capability to call (%s, %s)\n",
511 call->callType, call->callToken);
512 }
513 ret = ooCallAddG7231Capability(call, OO_G7231, 1, 1, FALSE,
514 OORXANDTX, &ooh323c_start_receive_channel,
515 &ooh323c_start_transmit_channel,
516 &ooh323c_stop_receive_channel,
517 &ooh323c_stop_transmit_channel);
518
519 }
520
521 if(ast_format_cmp(format, ast_format_h263) == AST_FORMAT_CMP_EQUAL)
522 {
523 if (gH323Debug) {
524 ast_verb(0, "\tAdding h263 capability to call (%s, %s)\n",
525 call->callType, call->callToken);
526 }
527 ret = ooCallAddH263VideoCapability(call, OO_H263VIDEO, 1, 0, 0, 0, 0, 320*1024,
528 OORXANDTX, &ooh323c_start_receive_channel,
529 &ooh323c_start_transmit_channel,
530 &ooh323c_stop_receive_channel,
531 &ooh323c_stop_transmit_channel);
532
533 }
534
535 if(ast_format_cmp(format, ast_format_gsm) == AST_FORMAT_CMP_EQUAL)
536 {
537 if (gH323Debug) {
538 ast_verb(0, "\tAdding gsm capability to call(%s, %s)\n",
539 call->callType, call->callToken);
540 }
541 ret = ooCallAddGSMCapability(call, OO_GSMFULLRATE, 4, FALSE, FALSE,
542 OORXANDTX, &ooh323c_start_receive_channel,
543 &ooh323c_start_transmit_channel,
544 &ooh323c_stop_receive_channel,
545 &ooh323c_stop_transmit_channel);
546 }
547
548 if(ast_format_cmp(format, ast_format_speex) == AST_FORMAT_CMP_EQUAL)
549 {
550 if (gH323Debug) {
551 ast_verb(0, "\tAdding Speex capability to call(%s, %s)\n",
552 call->callType, call->callToken);
553 }
554 ret = ooCallAddSpeexCapability(call, OO_SPEEX, 4, 4, FALSE,
555 OORXANDTX, &ooh323c_start_receive_channel,
556 &ooh323c_start_transmit_channel,
557 &ooh323c_stop_receive_channel,
558 &ooh323c_stop_transmit_channel);
559 }
560
561 ao2_ref(format, -1);
562 }
563 return ret;
564}
g729onlyA
static int g729onlyA
Definition: chan_ooh323.c:375
call
static int call(void *data)
Definition: chan_pjsip.c:2391
ast_format_cap_get_format_framing
unsigned int ast_format_cap_get_format_framing(const struct ast_format_cap *cap, const struct ast_format *format)
Get the framing for a format.
Definition: format_cap.c:443
ooh323c_stop_receive_datachannel
int ooh323c_stop_receive_datachannel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:653
ooh323c_start_receive_datachannel
int ooh323c_start_receive_datachannel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:642
ooh323c_start_transmit_datachannel
int ooh323c_start_transmit_datachannel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:647
ooh323c_stop_transmit_datachannel
int ooh323c_stop_transmit_datachannel(ooCallData *call, ooLogicalChannel *pChannel)
Definition: ooh323cDriver.c:658

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, call(), FALSE, g729onlyA, 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(), and ooh323_onReceivedSetup().

◆ ooh323c_start_call_thread()

int ooh323c_start_call_thread ( ooCallData *  call)

Definition at line 130 of file ooh323cDriver.c.

130 {
131 char c = 'c';
132 struct callthread *cur = callThreads;
133
134 ast_mutex_lock(&callThreadsLock);
135 while (cur != NULL && (cur->inUse || ast_mutex_trylock(&cur->lock))) {
136 cur = cur->next;
137 }
138 ast_mutex_unlock(&callThreadsLock);
139
140 if (cur != NULL) {
141 if (cur->inUse || write(cur->thePipe[1], &c, 1) < 0) {
142 ast_mutex_unlock(&cur->lock);
143 cur = NULL;
144 }
145 }
146
147/* make new thread */
148 if (cur == NULL) {
149 if (!(cur = ast_calloc(1, sizeof(struct callthread)))) {
150 ast_log(LOG_ERROR, "Unable to allocate thread structure for call %s\n",
151 call->callToken);
152 return -1;
153 }
154
155 ast_module_ref(myself);
156 if ((socketpair(PF_LOCAL, SOCK_STREAM, 0, cur->thePipe)) == -1) {
157 ast_log(LOG_ERROR, "Can't create thread pipe for call %s\n", call->callToken);
158 ast_free(cur);
159 return -1;
160 }
161 cur->inUse = TRUE;
162 cur->call = call;
163
164 ast_mutex_init(&cur->lock);
165
166 if (gH323Debug)
167 ast_debug(1,"new call thread created for call %s\n", call->callToken);
168
169 if(ast_pthread_create_detached_background(&call->callThread, NULL, ooh323c_call_thread, cur) < 0)
170 {
171 ast_log(LOG_ERROR, "Unable to start ooh323c call thread for call %s\n",
172 call->callToken);
173 ast_mutex_destroy(&cur->lock);
174 close(cur->thePipe[0]);
175 close(cur->thePipe[1]);
176 ast_free(cur);
177 return -1;
178 }
179
180 } else {
181 if (gH323Debug)
182 ast_debug(1,"using existing call thread for call %s\n", call->callToken);
183 cur->inUse = TRUE;
184 cur->call = call;
185 ast_mutex_unlock(&cur->lock);
186
187 }
188 return 0;
189}
TRUE
#define TRUE
Definition: app_minivm.c:524
PF_LOCAL
#define PF_LOCAL
Definition: asterisk.c:293
ast_free
#define ast_free(a)
Definition: astmm.h:180
ast_calloc
#define ast_calloc(num, len)
A wrapper for calloc()
Definition: astmm.h:202
ast_log
#define ast_log
Definition: astobj2.c:42
LOG_ERROR
#define LOG_ERROR
Definition: include/asterisk/logger.h:286
ast_mutex_init
#define ast_mutex_init(pmutex)
Definition: lock.h:186
ast_mutex_unlock
#define ast_mutex_unlock(a)
Definition: lock.h:190
ast_mutex_trylock
#define ast_mutex_trylock(a)
Definition: lock.h:191
ast_mutex_destroy
#define ast_mutex_destroy(a)
Definition: lock.h:188
ast_mutex_lock
#define ast_mutex_lock(a)
Definition: lock.h:189
ast_module_ref
#define ast_module_ref(mod)
Hold a reference to the module.
Definition: module.h:443
callThreadsLock
static ast_mutex_t callThreadsLock
Definition: ooh323cDriver.c:48
ooh323c_call_thread
void * ooh323c_call_thread(void *dummy)
Definition: ooh323cDriver.c:80
myself
struct ast_module * myself
Definition: chan_ooh323.c:113
callThreads
static struct callthread * callThreads
callthread::thePipe
int thePipe[2]
Definition: ooh323cDriver.c:42
callthread::next
struct callthread * next
Definition: ooh323cDriver.c:45
callthread::inUse
OOBOOL inUse
Definition: ooh323cDriver.c:43
callthread::call
ooCallData * call
Definition: ooh323cDriver.c:44
callthread::lock
ast_mutex_t lock
Definition: ooh323cDriver.c:41
c
static struct test_val c
Definition: test_linkedlists.c:48
ast_pthread_create_detached_background
#define ast_pthread_create_detached_background(a, b, c, d)
Definition: utils.h:597

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, call(), callThreads, callThreadsLock, gH323Debug, callthread::inUse, callthread::lock, LOG_ERROR, myself, callthread::next, NULL, ooh323c_call_thread(), PF_LOCAL, callthread::thePipe, and TRUE.

Referenced by onNewCallCreated().

◆ ooh323c_start_stack_thread()

int ooh323c_start_stack_thread ( void  )

Definition at line 199 of file ooh323cDriver.c.

200{
201 if(ast_pthread_create_background(&ooh323c_thread, NULL, ooh323c_stack_thread, NULL) < 0)
202 {
203 ast_log(LOG_ERROR, "Unable to start ooh323c thread.\n");
204 return -1;
205 }
206 if(ast_pthread_create_background(&ooh323cmd_thread, NULL, ooh323c_cmd_thread, NULL) < 0)
207 {
208 ast_log(LOG_ERROR, "Unable to start ooh323cmd thread.\n");
209 return -1;
210 }
211 return 0;
212}
ooh323cmd_thread
static pthread_t ooh323cmd_thread
Definition: ooh323cDriver.c:35
ooh323c_stack_thread
void * ooh323c_stack_thread(void *dummy)
Definition: ooh323cDriver.c:66
ooh323c_cmd_thread
void * ooh323c_cmd_thread(void *dummy)
Definition: ooh323cDriver.c:73
ooh323c_thread
static pthread_t ooh323c_thread
Definition: ooh323cDriver.c:34
ast_pthread_create_background
#define ast_pthread_create_background(a, b, c, d)
Definition: utils.h:592

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

◆ ooh323c_stop_call_thread()

int ooh323c_stop_call_thread ( ooCallData *  call)

Definition at line 192 of file ooh323cDriver.c.

192 {
193 if (call->callThread != AST_PTHREADT_NULL) {
194 ooStopMonitorCallChannels(call);
195 }
196 return 0;
197}
AST_PTHREADT_NULL
#define AST_PTHREADT_NULL
Definition: lock.h:66

References AST_PTHREADT_NULL, and call().

Referenced by onCallCleared().

◆ ooh323c_stop_stack_thread()

int ooh323c_stop_stack_thread ( void  )

Definition at line 214 of file ooh323cDriver.c.

215{
216 if(ooh323c_thread != AST_PTHREADT_NULL)
217 {
218 ooStopMonitor();
219 pthread_join(ooh323c_thread, NULL);
220 ooh323c_thread = AST_PTHREADT_NULL;
221 pthread_join(ooh323cmd_thread, NULL);
222 ooh323cmd_thread = AST_PTHREADT_NULL;
223 }
224 return 0;
225}

References AST_PTHREADT_NULL, NULL, ooh323c_thread, and ooh323cmd_thread.

Referenced by unload_module().

Generated on Wed Apr 24 2024 20:04:34 for Asterisk - The Open Source Telephony Project by doxygen 1.9.4