abstract_jb.h File Reference

Common implementation-independent jitterbuffer stuff. More...

#include <sys/time.h>
#include "asterisk/format.h"

Include dependency graph for abstract_jb.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct ast_jb

General jitterbuffer state. More...

struct ast_jb_conf

General jitterbuffer configuration. More...

struct ast_jb_impl

Jitterbuffer implementation struct. More...

Defines

#define AST_JB_CONF_ENABLE   "enable"

#define AST_JB_CONF_FORCE   "force"

#define AST_JB_CONF_IMPL   "impl"

#define AST_JB_CONF_LOG   "log"

#define AST_JB_CONF_MAX_SIZE   "maxsize"

#define AST_JB_CONF_PREFIX   "jb"

#define AST_JB_CONF_RESYNCH_THRESHOLD   "resyncthreshold"

#define AST_JB_CONF_TARGET_EXTRA   "targetextra"

#define AST_JB_IMPL_NAME_SIZE   12

Typedefs

typedef void *(* jb_create_impl )(struct ast_jb_conf *general_config, long resynch_threshold)

Create.

typedef void(* jb_destroy_impl )(void *jb)

Destroy.

typedef void(* jb_empty_and_reset_impl )(void *jb)

Empty and reset jb.

typedef void(* jb_force_resynch_impl )(void *jb)

Force resynch.

typedef int(* jb_get_impl )(void *jb, struct ast_frame **fout, long now, long interpl)

Get frame for now.

typedef long(* jb_next_impl )(void *jb)

Get next.

typedef int(* jb_put_first_impl )(void *jb, struct ast_frame *fin, long now)

Put first frame.

typedef int(* jb_put_impl )(void *jb, struct ast_frame *fin, long now)

Put frame.

typedef int(* jb_remove_impl )(void *jb, struct ast_frame **fout)

Remove first frame.

Enumerations

enum { AST_JB_ENABLED = (1 << 0), AST_JB_FORCED = (1 << 1), AST_JB_LOG = (1 << 2) }

enum { AST_JB_IMPL_OK, AST_JB_IMPL_DROP, AST_JB_IMPL_INTERP, AST_JB_IMPL_NOFRAME }

enum ast_jb_type { AST_JB_FIXED, AST_JB_ADAPTIVE }

Functions

void ast_jb_configure (struct ast_channel *chan, const struct ast_jb_conf *conf)

Configures a jitterbuffer on a channel.

void ast_jb_destroy (struct ast_channel *chan)

Destroys jitterbuffer on a channel.

int ast_jb_do_usecheck (struct ast_channel *c0, struct ast_channel *c1)

Checks the need of a jb use in a generic bridge.

void ast_jb_empty_and_reset (struct ast_channel *c0, struct ast_channel *c1)

drops all frames from a jitterbuffer and resets it

void ast_jb_get_and_deliver (struct ast_channel *c0, struct ast_channel *c1)

Deliver the queued frames that should be delivered now for both channels.

void ast_jb_get_config (const struct ast_channel *chan, struct ast_jb_conf *conf)

Copies a channel's jitterbuffer configuration.

struct ast_jb_impl * ast_jb_get_impl (enum ast_jb_type type)

int ast_jb_get_when_to_wakeup (struct ast_channel *c0, struct ast_channel *c1, int time_left)

Calculates the time, left to the closest delivery moment in a bridge.

int ast_jb_put (struct ast_channel *chan, struct ast_frame *f)

Puts a frame into a channel jitterbuffer.

int ast_jb_read_conf (struct ast_jb_conf *conf, const char *varname, const char *value)

Sets jitterbuffer configuration property.

Detailed Description

Common implementation-independent jitterbuffer stuff.

Author:: Slav Klenov <slav@securax.org>

Definition in file abstract_jb.h.

Define Documentation

#define AST_JB_CONF_ENABLE "enable"

Definition at line 85 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_FORCE "force"

Definition at line 86 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_IMPL "impl"

Definition at line 90 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_LOG "log"

Definition at line 91 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_MAX_SIZE "maxsize"

Definition at line 87 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_PREFIX "jb"

Definition at line 84 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_RESYNCH_THRESHOLD "resyncthreshold"

Definition at line 88 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_CONF_TARGET_EXTRA "targetextra"

Definition at line 89 of file abstract_jb.h.

Referenced by ast_jb_read_conf().

#define AST_JB_IMPL_NAME_SIZE 12

Definition at line 63 of file abstract_jb.h.

Referenced by create_jb().

Typedef Documentation

typedef void*(* jb_create_impl)(struct ast_jb_conf *general_config, long resynch_threshold)

Create.

Definition at line 95 of file abstract_jb.h.

typedef void(* jb_destroy_impl)(void *jb)

Destroy.

Definition at line 97 of file abstract_jb.h.

typedef void(* jb_empty_and_reset_impl)(void *jb)

Empty and reset jb.

Definition at line 111 of file abstract_jb.h.

typedef void(* jb_force_resynch_impl)(void *jb)

Force resynch.

Definition at line 109 of file abstract_jb.h.

typedef int(* jb_get_impl)(void *jb, struct ast_frame **fout, long now, long interpl)

Get frame for now.

Definition at line 103 of file abstract_jb.h.

typedef long(* jb_next_impl)(void *jb)

Get next.

Definition at line 105 of file abstract_jb.h.

typedef int(* jb_put_first_impl)(void *jb, struct ast_frame *fin, long now)

Put first frame.

Definition at line 99 of file abstract_jb.h.

typedef int(* jb_put_impl)(void *jb, struct ast_frame *fin, long now)

Put frame.

Definition at line 101 of file abstract_jb.h.

typedef int(* jb_remove_impl)(void *jb, struct ast_frame **fout)

Remove first frame.

Definition at line 107 of file abstract_jb.h.

Enumeration Type Documentation

anonymous enum

Enumerator:

AST_JB_ENABLED
AST_JB_FORCED
AST_JB_LOG

Definition at line 44 of file abstract_jb.h.

00044      {
00045    AST_JB_ENABLED = (1 << 0),
00046    AST_JB_FORCED =  (1 << 1),
00047    AST_JB_LOG =     (1 << 2)
00048 };

anonymous enum

Abstract return codes

Enumerator:

AST_JB_IMPL_OK
AST_JB_IMPL_DROP
AST_JB_IMPL_INTERP
AST_JB_IMPL_NOFRAME

Definition at line 56 of file abstract_jb.h.

00056      {
00057    AST_JB_IMPL_OK,
00058    AST_JB_IMPL_DROP,
00059    AST_JB_IMPL_INTERP,
00060    AST_JB_IMPL_NOFRAME
00061 };

enum ast_jb_type

Enumerator:

AST_JB_FIXED
AST_JB_ADAPTIVE

Definition at line 50 of file abstract_jb.h.

00050                  {
00051    AST_JB_FIXED,
00052    AST_JB_ADAPTIVE,
00053 };

Function Documentation

void ast_jb_configure	(	struct ast_channel *	chan,
		const struct ast_jb_conf *	conf
	)

Configures a jitterbuffer on a channel.

Parameters:

	chan	channel to configure.
	conf	configuration to apply.

Called from a channel driver when a channel is created and its jitterbuffer needs to be configured.

Definition at line 567 of file abstract_jb.c.

References ast_jb::conf, and ast_channel::jb.

Referenced by __oh323_rtp_create(), __oh323_update_info(), alsa_new(), console_new(), dahdi_new(), gtalk_new(), jingle_new(), local_new(), mgcp_new(), misdn_new(), oss_new(), sip_new(), skinny_new(), unistim_new(), and usbradio_new().

00568 {
00569    memcpy(&chan->jb.conf, conf, sizeof(*conf));
00570 }

void ast_jb_destroy ( struct ast_channel * chan )

Destroys jitterbuffer on a channel.

Parameters:

chan

channel.

Called from ast_channel_free() when a channel is destroyed.

Definition at line 487 of file abstract_jb.c.

References ast_channel_name(), ast_clear_flag, ast_frfree, AST_JB_IMPL_OK, ast_test_flag, ast_verb, ast_jb_impl::destroy, f, ast_jb::impl, ast_channel::jb, JB_CREATED, ast_jb::jbobj, ast_jb::logfile, ast_jb_impl::name, and ast_jb_impl::remove.

Referenced by ast_channel_destructor().

00488 {
00489    struct ast_jb *jb = &chan->jb;
00490    const struct ast_jb_impl *jbimpl = jb->impl;
00491    void *jbobj = jb->jbobj;
00492    struct ast_frame *f;
00493 
00494    if (jb->logfile) {
00495       fclose(jb->logfile);
00496       jb->logfile = NULL;
00497    }
00498 
00499    if (ast_test_flag(jb, JB_CREATED)) {
00500       /* Remove and free all frames still queued in jb */
00501       while (jbimpl->remove(jbobj, &f) == AST_JB_IMPL_OK) {
00502          ast_frfree(f);
00503       }
00504 
00505       jbimpl->destroy(jbobj);
00506       jb->jbobj = NULL;
00507 
00508       ast_clear_flag(jb, JB_CREATED);
00509 
00510       ast_verb(3, "%s jitterbuffer destroyed on channel %s\n", jbimpl->name, ast_channel_name(chan));
00511    }
00512 }

int ast_jb_do_usecheck	(	struct ast_channel *	c0,
		struct ast_channel *	c1
	)

Checks the need of a jb use in a generic bridge.

Parameters:

	c0	first bridged channel.
	c1	second bridged channel.

Called from ast_generic_bridge() when two channels are entering in a bridge. The function checks the need of a jitterbuffer, depending on both channel's configuration and technology properties. As a result, this function sets appropriate internal jb flags to the channels, determining further behaviour of the bridged jitterbuffers.

Return values:

	zero	if there are no jitter buffers in use
	non-zero	if there are

Definition at line 157 of file abstract_jb.c.

References AST_CHAN_TP_CREATESJITTER, AST_CHAN_TP_WANTSJITTER, AST_JB_ENABLED, AST_JB_FORCED, ast_set_flag, ast_test_flag, ast_jb::conf, ast_channel::jb, jb_choose_impl(), JB_CREATED, JB_TIMEBASE_INITIALIZED, JB_USE, ast_channel_tech::properties, ast_channel::tech, and ast_jb::timebase.

Referenced by ast_generic_bridge().

00158 {
00159    struct ast_jb *jb0 = &c0->jb;
00160    struct ast_jb *jb1 = &c1->jb;
00161    struct ast_jb_conf *conf0 = &jb0->conf;
00162    struct ast_jb_conf *conf1 = &jb1->conf;
00163    int c0_wants_jitter = c0->tech->properties & AST_CHAN_TP_WANTSJITTER;
00164    int c0_creates_jitter = c0->tech->properties & AST_CHAN_TP_CREATESJITTER;
00165    int c0_jb_enabled = ast_test_flag(conf0, AST_JB_ENABLED);
00166    int c0_force_jb = ast_test_flag(conf0, AST_JB_FORCED);
00167    int c0_jb_timebase_initialized = ast_test_flag(jb0, JB_TIMEBASE_INITIALIZED);
00168    int c0_jb_created = ast_test_flag(jb0, JB_CREATED);
00169    int c1_wants_jitter = c1->tech->properties & AST_CHAN_TP_WANTSJITTER;
00170    int c1_creates_jitter = c1->tech->properties & AST_CHAN_TP_CREATESJITTER;
00171    int c1_jb_enabled = ast_test_flag(conf1, AST_JB_ENABLED);
00172    int c1_force_jb = ast_test_flag(conf1, AST_JB_FORCED);
00173    int c1_jb_timebase_initialized = ast_test_flag(jb1, JB_TIMEBASE_INITIALIZED);
00174    int c1_jb_created = ast_test_flag(jb1, JB_CREATED);
00175    int inuse = 0;
00176 
00177    /* Determine whether audio going to c0 needs a jitter buffer */
00178    if (((!c0_wants_jitter && c1_creates_jitter) || (c0_force_jb && c1_creates_jitter)) && c0_jb_enabled) {
00179       ast_set_flag(jb0, JB_USE);
00180       if (!c0_jb_timebase_initialized) {
00181          if (c1_jb_timebase_initialized) {
00182             memcpy(&jb0->timebase, &jb1->timebase, sizeof(struct timeval));
00183          } else {
00184             gettimeofday(&jb0->timebase, NULL);
00185          }
00186          ast_set_flag(jb0, JB_TIMEBASE_INITIALIZED);
00187       }
00188 
00189       if (!c0_jb_created) {
00190          jb_choose_impl(c0);
00191       }
00192 
00193       inuse = 1;
00194    }
00195 
00196    /* Determine whether audio going to c1 needs a jitter buffer */
00197    if (((!c1_wants_jitter && c0_creates_jitter) || (c1_force_jb && c0_creates_jitter)) && c1_jb_enabled) {
00198       ast_set_flag(jb1, JB_USE);
00199       if (!c1_jb_timebase_initialized) {
00200          if (c0_jb_timebase_initialized) {
00201             memcpy(&jb1->timebase, &jb0->timebase, sizeof(struct timeval));
00202          } else {
00203             gettimeofday(&jb1->timebase, NULL);
00204          }
00205          ast_set_flag(jb1, JB_TIMEBASE_INITIALIZED);
00206       }
00207 
00208       if (!c1_jb_created) {
00209          jb_choose_impl(c1);
00210       }
00211 
00212       inuse = 1;
00213    }
00214 
00215    return inuse;
00216 }

void ast_jb_empty_and_reset	(	struct ast_channel *	c0,
		struct ast_channel *	c1
	)

drops all frames from a jitterbuffer and resets it

Parameters:

	c0	one channel of a bridge
	c1	the other channel of the bridge

Definition at line 578 of file abstract_jb.c.

References ast_test_flag, ast_jb_impl::empty_and_reset, ast_jb::impl, ast_channel::jb, JB_CREATED, JB_USE, and ast_jb::jbobj.

Referenced by ast_generic_bridge().

00579 {
00580    struct ast_jb *jb0 = &c0->jb;
00581    struct ast_jb *jb1 = &c1->jb;
00582    int c0_use_jb = ast_test_flag(jb0, JB_USE);
00583    int c0_jb_is_created = ast_test_flag(jb0, JB_CREATED);
00584    int c1_use_jb = ast_test_flag(jb1, JB_USE);
00585    int c1_jb_is_created = ast_test_flag(jb1, JB_CREATED);
00586 
00587    if (c0_use_jb && c0_jb_is_created && jb0->impl->empty_and_reset) {
00588       jb0->impl->empty_and_reset(jb0->jbobj);
00589    }
00590 
00591    if (c1_use_jb && c1_jb_is_created && jb1->impl->empty_and_reset) {
00592       jb1->impl->empty_and_reset(jb1->jbobj);
00593    }
00594 }

void ast_jb_get_and_deliver	(	struct ast_channel *	c0,
		struct ast_channel *	c1
	)

Deliver the queued frames that should be delivered now for both channels.

Parameters:

	c0	first bridged channel.
	c1	second bridged channel.

Called from ast_generic_bridge() to deliver any frames, that should be delivered for the moment of invocation. Does nothing if neihter of the channels is using jb or has any frames currently queued in. The function delivers frames usig ast_write() each of the channels.

Definition at line 323 of file abstract_jb.c.

References ast_test_flag, ast_channel::jb, JB_CREATED, jb_get_and_deliver(), and JB_USE.

Referenced by ast_generic_bridge().

00324 {
00325    struct ast_jb *jb0 = &c0->jb;
00326    struct ast_jb *jb1 = &c1->jb;
00327    int c0_use_jb = ast_test_flag(jb0, JB_USE);
00328    int c0_jb_is_created = ast_test_flag(jb0, JB_CREATED);
00329    int c1_use_jb = ast_test_flag(jb1, JB_USE);
00330    int c1_jb_is_created = ast_test_flag(jb1, JB_CREATED);
00331 
00332    if (c0_use_jb && c0_jb_is_created)
00333       jb_get_and_deliver(c0);
00334 
00335    if (c1_use_jb && c1_jb_is_created)
00336       jb_get_and_deliver(c1);
00337 }

void ast_jb_get_config	(	const struct ast_channel *	chan,
		struct ast_jb_conf *	conf
	)

Copies a channel's jitterbuffer configuration.

Parameters:

	chan	channel.
	conf	destination.

Definition at line 573 of file abstract_jb.c.

References ast_jb::conf, and ast_channel::jb.

00574 {
00575    memcpy(conf, &chan->jb.conf, sizeof(*conf));
00576 }

struct ast_jb_impl* ast_jb_get_impl ( enum ast_jb_type type ) [read]

Definition at line 791 of file abstract_jb.c.

References ARRAY_LEN.

Referenced by jb_framedata_init().

00792 {
00793    int i;
00794    for (i = 0; i < ARRAY_LEN(avail_impl); i++) {
00795       if (avail_impl[i].type == type) {
00796          return &avail_impl[i];
00797       }
00798    }
00799    return NULL;
00800 }

int ast_jb_get_when_to_wakeup	(	struct ast_channel *	c0,
		struct ast_channel *	c1,
		int	time_left
	)

Calculates the time, left to the closest delivery moment in a bridge.

Parameters:

	c0	first bridged channel.
	c1	second bridged channel.
	time_left	bridge time limit, or -1 if not set.

Called from ast_generic_bridge() to determine the maximum time to wait for activity in ast_waitfor_n() call. If neihter of the channels is using jb, this function returns the time limit passed.

Returns:: maximum time to wait.

Definition at line 218 of file abstract_jb.c.

References ast_test_flag, get_now(), ast_channel::jb, JB_CREATED, JB_USE, and ast_jb::next.

Referenced by ast_generic_bridge().

00219 {
00220    struct ast_jb *jb0 = &c0->jb;
00221    struct ast_jb *jb1 = &c1->jb;
00222    int c0_use_jb = ast_test_flag(jb0, JB_USE);
00223    int c0_jb_is_created = ast_test_flag(jb0, JB_CREATED);
00224    int c1_use_jb = ast_test_flag(jb1, JB_USE);
00225    int c1_jb_is_created = ast_test_flag(jb1, JB_CREATED);
00226    int wait, wait0, wait1;
00227    struct timeval tv_now;
00228 
00229    if (time_left == 0) {
00230       /* No time left - the bridge will be retried */
00231       /* TODO: Test disable this */
00232       /*return 0;*/
00233    }
00234 
00235    if (time_left < 0) {
00236       time_left = INT_MAX;
00237    }
00238 
00239    gettimeofday(&tv_now, NULL);
00240 
00241    wait0 = (c0_use_jb && c0_jb_is_created) ? jb0->next - get_now(jb0, &tv_now) : time_left;
00242    wait1 = (c1_use_jb && c1_jb_is_created) ? jb1->next - get_now(jb1, &tv_now) : time_left;
00243 
00244    wait = wait0 < wait1 ? wait0 : wait1;
00245    wait = wait < time_left ? wait : time_left;
00246 
00247    if (wait == INT_MAX) {
00248       wait = -1;
00249    } else if (wait < 1) {
00250       /* don't let wait=0, because this can cause the pbx thread to loop without any sleeping at all */
00251       wait = 1;
00252    }
00253 
00254    return wait;
00255 }

int ast_jb_put	(	struct ast_channel *	chan,
		struct ast_frame *	f
	)

Puts a frame into a channel jitterbuffer.

Parameters:

	chan	channel.
	f	frame.

Called from ast_generic_bridge() to put a frame into a channel's jitterbuffer. The function will successfuly enqueue a frame if and only if: 1. the channel is using a jitterbuffer (as determined by ast_jb_do_usecheck()), 2. the frame's type is AST_FRAME_VOICE, 3. the frame has timing info set and has length >= 2 ms, 4. there is no some internal error happened (like failed memory allocation). Frames, successfuly queued, should be delivered by the channel's jitterbuffer, when their delivery time has came. Frames, not successfuly queued, should be delivered immediately. Dropped by the jb implementation frames are considered successfuly enqueued as far as they should not be delivered at all.

Return values:

	0	if the frame was queued
	-1	if not

Definition at line 258 of file abstract_jb.c.

References ast_channel_name(), ast_clear_flag, AST_FRAME_DTMF, AST_FRAME_VOICE, ast_frdup(), AST_FRFLAG_HAS_TIMING_INFO, ast_frfree, AST_JB_IMPL_OK, ast_log(), ast_set_flag, ast_test_flag, create_jb(), ast_jb_impl::force_resync, ast_frame::frametype, get_now(), ast_jb::impl, ast_channel::jb, JB_CREATED, jb_framelog, JB_USE, ast_jb::jbobj, ast_frame::len, LOG_ERROR, LOG_WARNING, ast_jb_impl::next, ast_jb::next, ast_jb_impl::put, ast_frame::src, and ast_frame::ts.

Referenced by ast_generic_bridge().

00259 {
00260    struct ast_jb *jb = &chan->jb;
00261    const struct ast_jb_impl *jbimpl = jb->impl;
00262    void *jbobj = jb->jbobj;
00263    struct ast_frame *frr;
00264    long now = 0;
00265 
00266    if (!ast_test_flag(jb, JB_USE))
00267       return -1;
00268 
00269    if (f->frametype != AST_FRAME_VOICE) {
00270       if (f->frametype == AST_FRAME_DTMF && ast_test_flag(jb, JB_CREATED)) {
00271          jb_framelog("JB_PUT {now=%ld}: Received DTMF frame. Force resynching jb...\n", now);
00272          jbimpl->force_resync(jbobj);
00273       }
00274 
00275       return -1;
00276    }
00277 
00278    /* We consider an enabled jitterbuffer should receive frames with valid timing info. */
00279    if (!ast_test_flag(f, AST_FRFLAG_HAS_TIMING_INFO) || f->len < 2 || f->ts < 0) {
00280       ast_log(LOG_WARNING, "%s received frame with invalid timing info: "
00281          "has_timing_info=%d, len=%ld, ts=%ld, src=%s\n",
00282          ast_channel_name(chan), ast_test_flag(f, AST_FRFLAG_HAS_TIMING_INFO), f->len, f->ts, f->src);
00283       return -1;
00284    }
00285 
00286    frr = ast_frdup(f);
00287 
00288    if (!frr) {
00289       ast_log(LOG_ERROR, "Failed to isolate frame for the jitterbuffer on channel '%s'\n", ast_channel_name(chan));
00290       return -1;
00291    }
00292 
00293    if (!ast_test_flag(jb, JB_CREATED)) {
00294       if (create_jb(chan, frr)) {
00295          ast_frfree(frr);
00296          /* Disable the jitterbuffer */
00297          ast_clear_flag(jb, JB_USE);
00298          return -1;
00299       }
00300 
00301       ast_set_flag(jb, JB_CREATED);
00302       return 0;
00303    } else {
00304       now = get_now(jb, NULL);
00305       if (jbimpl->put(jbobj, frr, now) != AST_JB_IMPL_OK) {
00306          jb_framelog("JB_PUT {now=%ld}: Dropped frame with ts=%ld and len=%ld\n", now, frr->ts, frr->len);
00307          ast_frfree(frr);
00308          /*return -1;*/
00309          /* TODO: Check this fix - should return 0 here, because the dropped frame shouldn't
00310             be delivered at all */
00311          return 0;
00312       }
00313 
00314       jb->next = jbimpl->next(jbobj);
00315 
00316       jb_framelog("JB_PUT {now=%ld}: Queued frame with ts=%ld and len=%ld\n", now, frr->ts, frr->len);
00317 
00318       return 0;
00319    }
00320 }

int ast_jb_read_conf	(	struct ast_jb_conf *	conf,
		const char *	varname,
		const char *	value
	)

Sets jitterbuffer configuration property.

Parameters:

	conf	configuration to store the property in.
	varname	property name.
	value	property value.

Called from a channel driver to build a jitterbuffer configuration typically when reading a configuration file. It is not necessary for a channel driver to know each of the jb configuration property names. The jitterbuffer itself knows them. The channel driver can pass each config var it reads through this function. It will return 0 if the variable was consumed from the jb conf.

Returns:: zero if the property was set to the configuration, -1 if not.

Definition at line 528 of file abstract_jb.c.

References AST_JB_CONF_ENABLE, AST_JB_CONF_FORCE, AST_JB_CONF_IMPL, AST_JB_CONF_LOG, AST_JB_CONF_MAX_SIZE, AST_JB_CONF_PREFIX, AST_JB_CONF_RESYNCH_THRESHOLD, AST_JB_CONF_TARGET_EXTRA, AST_JB_ENABLED, AST_JB_FORCED, AST_JB_LOG, ast_set2_flag, ast_strlen_zero(), ast_true(), ast_jb_conf::impl, ast_jb_conf::max_size, name, ast_jb_conf::resync_threshold, and ast_jb_conf::target_extra.

Referenced by _build_general_config(), config_parse_variables(), gtalk_load_config(), jb_framedata_init(), jingle_load_config(), load_module(), process_dahdi(), reload_config(), store_config(), and store_config_core().

00529 {
00530    int prefixlen = sizeof(AST_JB_CONF_PREFIX) - 1;
00531    const char *name;
00532    int tmp;
00533 
00534    if (strncasecmp(AST_JB_CONF_PREFIX, varname, prefixlen)) {
00535       return -1;
00536    }
00537 
00538    name = varname + prefixlen;
00539 
00540    if (!strcasecmp(name, AST_JB_CONF_ENABLE)) {
00541       ast_set2_flag(conf, ast_true(value), AST_JB_ENABLED);
00542    } else if (!strcasecmp(name, AST_JB_CONF_FORCE)) {
00543       ast_set2_flag(conf, ast_true(value), AST_JB_FORCED);
00544    } else if (!strcasecmp(name, AST_JB_CONF_MAX_SIZE)) {
00545       if ((tmp = atoi(value)) > 0)
00546          conf->max_size = tmp;
00547    } else if (!strcasecmp(name, AST_JB_CONF_RESYNCH_THRESHOLD)) {
00548       if ((tmp = atoi(value)) > 0)
00549          conf->resync_threshold = tmp;
00550    } else if (!strcasecmp(name, AST_JB_CONF_IMPL)) {
00551       if (!ast_strlen_zero(value))
00552          snprintf(conf->impl, sizeof(conf->impl), "%s", value);
00553    } else if (!strcasecmp(name, AST_JB_CONF_TARGET_EXTRA)) {
00554       if (sscanf(value, "%30d", &tmp) == 1) {
00555          conf->target_extra = tmp;
00556       }
00557    } else if (!strcasecmp(name, AST_JB_CONF_LOG)) {
00558       ast_set2_flag(conf, ast_true(value), AST_JB_LOG);
00559    } else {
00560       return -1;
00561    }
00562 
00563    return 0;
00564 }


Data Structures
struct	ast_jb
	General jitterbuffer state. More...
struct	ast_jb_conf
	General jitterbuffer configuration. More...
struct	ast_jb_impl
	Jitterbuffer implementation struct. More...
Defines
#define	AST_JB_CONF_ENABLE "enable"
#define	AST_JB_CONF_FORCE "force"
#define	AST_JB_CONF_IMPL "impl"
#define	AST_JB_CONF_LOG "log"
#define	AST_JB_CONF_MAX_SIZE "maxsize"
#define	AST_JB_CONF_PREFIX "jb"
#define	AST_JB_CONF_RESYNCH_THRESHOLD "resyncthreshold"
#define	AST_JB_CONF_TARGET_EXTRA "targetextra"
#define	AST_JB_IMPL_NAME_SIZE 12
Typedefs
typedef void (	jb_create_impl )(struct ast_jb_conf *general_config, long resynch_threshold)
	Create.
typedef void(*	jb_destroy_impl )(void *jb)
	Destroy.
typedef void(*	jb_empty_and_reset_impl )(void *jb)
	Empty and reset jb.
typedef void(*	jb_force_resynch_impl )(void *jb)
	Force resynch.
typedef int(*	jb_get_impl )(void jb, struct ast_frame *fout, long now, long interpl)
	Get frame for now.
typedef long(*	jb_next_impl )(void *jb)
	Get next.
typedef int(*	jb_put_first_impl )(void jb, struct ast_frame fin, long now)
	Put first frame.
typedef int(*	jb_put_impl )(void jb, struct ast_frame fin, long now)
	Put frame.
typedef int(*	jb_remove_impl )(void jb, struct ast_frame *fout)
	Remove first frame.
Enumerations
enum	{ AST_JB_ENABLED = (1 << 0), AST_JB_FORCED = (1 << 1), AST_JB_LOG = (1 << 2) }
enum	{ AST_JB_IMPL_OK, AST_JB_IMPL_DROP, AST_JB_IMPL_INTERP, AST_JB_IMPL_NOFRAME }
enum	ast_jb_type { AST_JB_FIXED, AST_JB_ADAPTIVE }
Functions
void	ast_jb_configure (struct ast_channel chan, const struct ast_jb_conf conf)
	Configures a jitterbuffer on a channel.
void	ast_jb_destroy (struct ast_channel *chan)
	Destroys jitterbuffer on a channel.
int	ast_jb_do_usecheck (struct ast_channel c0, struct ast_channel c1)
	Checks the need of a jb use in a generic bridge.
void	ast_jb_empty_and_reset (struct ast_channel c0, struct ast_channel c1)
	drops all frames from a jitterbuffer and resets it
void	ast_jb_get_and_deliver (struct ast_channel c0, struct ast_channel c1)
	Deliver the queued frames that should be delivered now for both channels.
void	ast_jb_get_config (const struct ast_channel chan, struct ast_jb_conf conf)
	Copies a channel's jitterbuffer configuration.
struct ast_jb_impl *	ast_jb_get_impl (enum ast_jb_type type)
int	ast_jb_get_when_to_wakeup (struct ast_channel c0, struct ast_channel c1, int time_left)
	Calculates the time, left to the closest delivery moment in a bridge.
int	ast_jb_put (struct ast_channel chan, struct ast_frame f)
	Puts a frame into a channel jitterbuffer.
int	ast_jb_read_conf (struct ast_jb_conf conf, const char varname, const char *value)
	Sets jitterbuffer configuration property.

Asterisk developer's documentation

abstract_jb.h File Reference

Data Structures

Defines

Typedefs

Enumerations

Functions

Detailed Description

Define Documentation

Typedef Documentation

Enumeration Type Documentation

Function Documentation