codec_zap.c File Reference

Translate between various formats natively through Zaptel transcoding. More...

#include "asterisk.h"
#include <fcntl.h>
#include <stdlib.h>
#include <unistd.h>
#include <netinet/in.h>
#include <string.h>
#include <stdio.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <sys/mman.h>
#include <linux/zaptel.h>
#include "asterisk/lock.h"
#include "asterisk/translate.h"
#include "asterisk/config.h"
#include "asterisk/options.h"
#include "asterisk/module.h"
#include "asterisk/cli.h"
#include "asterisk/logger.h"
#include "asterisk/channel.h"
#include "asterisk/utils.h"
#include "asterisk/linkedlists.h"

Include dependency graph for codec_zap.c:

Go to the source code of this file.

Data Structures
struct	ast_translator_pvt
struct	format_map
struct	translator
Defines
#define	BUFFER_SAMPLES   8000
Functions
static	AST_LIST_HEAD_STATIC (zap_translators, translator)
	AST_MUTEX_DEFINE_STATIC (channelcount)
static int	build_translators (struct format_map *map, unsigned int dstfmts, unsigned int srcfmts)
char *	description (void)
	Provides a description of the module.
static void	drop_translator (int dst, int src)
static struct ast_frame *	fakesrc_sample (void)
static int	find_transcoders (void)
char *	key ()
	Returns the ASTERISK_GPL_KEY.
int	load_module (void)
	Initialize the module.
static void	parse_config (void)
static int	register_translator (int dst, int src)
int	reload (void)
	Reload stuff.
static int	show_transcoder (int fd, int argc, char **argv)
int	unload_module (void)
	Cleanup all module structures, sockets, etc.
static void	unregister_translators (void)
int	usecount (void)
	Provides a usecount.
static void	zap_destroy (struct ast_translator_pvt *ztp)
static int	zap_framein (struct ast_translator_pvt *ztp, struct ast_frame *f)
static struct ast_frame *	zap_frameout (struct ast_translator_pvt *ztp)
static struct ast_translator_pvt *	zap_new_alawtog723 (void)
static struct ast_translator_pvt *	zap_new_alawtog729 (void)
static struct ast_translator_pvt *	zap_new_g723toalaw (void)
static struct ast_translator_pvt *	zap_new_g723toulaw (void)
static struct ast_translator_pvt *	zap_new_g729toalaw (void)
static struct ast_translator_pvt *	zap_new_g729toulaw (void)
static struct ast_translator_pvt *	zap_new_ulawtog723 (void)
static struct ast_translator_pvt *	zap_new_ulawtog729 (void)
Variables
static int	complexinuse = 0
static struct format_map	global_format_map = { { { 0 } } }
static unsigned int	global_useplc = 0
static int	localusecnt = 0
static char	show_transcoder_usage []
static int	simpleinuse = 0
static char *	tdesc = "Generic Zaptel Transcoder Codec Translator"
static int	totalchannels = 0
static struct ast_cli_entry	transcoder_cli []

---

Detailed Description

Translate between various formats natively through Zaptel transcoding.

Definition in file codec_zap.c.

---

Define Documentation

#define BUFFER_SAMPLES   8000

Definition at line 55 of file codec_zap.c.

---

Function Documentation

static AST_LIST_HEAD_STATIC	(	zap_translators	,
		translator
	)			[static]

AST_MUTEX_DEFINE_STATIC

(

channelcount

)

static int build_translators	(	struct format_map *	map,
		unsigned int	dstfmts,
		unsigned int	srcfmts
	)			[static]

Definition at line 807 of file codec_zap.c.

References format_map::map, and register_translator().

Referenced by find_transcoders().

{
   unsigned int src, dst;

   for (src = 0; src < 32; src++) {
      for (dst = 0; dst < 32; dst++) {
         if (!(srcfmts & (1<< src)))
            continue;

         if (!(dstfmts & (1 << dst)))
            continue;

         if (global_format_map.map[dst][src])
            continue;

         if (!register_translator(dst, src))
            map->map[dst][src] = 1;
         else
            return 0;
      }
   }
   return 1;
}

char* description

(

void

)

Provides a description of the module.

Returns:

a short description of your module

Definition at line 901 of file codec_zap.c.

{
   return tdesc;
}

static void drop_translator	(	int	dst,
		int	src
	)			[static]

Definition at line 754 of file codec_zap.c.

References AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_unregister_translator(), ast_translator::dstfmt, free, format_map::map, ast_translator::srcfmt, and translator::t.

Referenced by find_transcoders().

{
   struct translator *cur;

   AST_LIST_LOCK(&zap_translators);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&zap_translators, cur, entry) {
      if (cur->t.srcfmt != src)
         continue;

      if (cur->t.dstfmt != dst)
         continue;

      AST_LIST_REMOVE_CURRENT(&zap_translators, entry);
      ast_unregister_translator(&cur->t);
      free(cur);
      global_format_map.map[dst][src] = 0;
      break;
   }
   AST_LIST_TRAVERSE_SAFE_END;
   AST_LIST_UNLOCK(&zap_translators);
}

static struct ast_frame* fakesrc_sample

(

void

)

[static, read]

Definition at line 692 of file codec_zap.c.

References AST_FRAME_VOICE, and ast_frame::frametype.

Referenced by register_translator().

{
   /* Don't bother really trying to test hardware ones. */
   static struct ast_frame f = {
      .frametype = AST_FRAME_VOICE,
      .samples = 240,
      .src = __PRETTY_FUNCTION__
   };

   return &f;
}

static int find_transcoders

(

void

)

[static]

Definition at line 831 of file codec_zap.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), build_translators(), drop_translator(), LOG_DEBUG, format_map::map, option_verbose, and VERBOSE_PREFIX_2.

Referenced by load_module().

{
   struct zt_transcode_info info = { 0, };
   struct format_map map = { { { 0 } } };
   int fd, res;
   unsigned int x, y;

   info.op = ZT_TCOP_GETINFO;
   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0) {
      ast_log(LOG_DEBUG, "No Zaptel transcoder support!\n");
      return 0;
   }

   ast_mutex_lock(&channelcount);
   totalchannels = 0;
   ast_mutex_unlock(&channelcount);

   for (info.tcnum = 0; !(res = ioctl(fd, ZT_TRANSCODE_OP, &info)); info.tcnum++) {
      if (option_verbose > 1)
         ast_verbose(VERBOSE_PREFIX_2 "Found transcoder '%s'.\n", info.name);

      if(build_translators(&map, info.dstfmts, info.srcfmts)) {
         ast_mutex_lock(&channelcount);
         totalchannels += info.numchannels;
         ast_mutex_unlock(&channelcount);
      }
   }
   close(fd);

   if (!info.tcnum && (option_verbose > 1))
      ast_verbose(VERBOSE_PREFIX_2 "No hardware transcoders found.\n");

   for (x = 0; x < 32; x++) {
      for (y = 0; y < 32; y++) {
         if (!map.map[x][y] && global_format_map.map[x][y])
            drop_translator(x, y);
      }
   }
   ast_mutex_lock(&channelcount);
   totalchannels = totalchannels/2;
   ast_mutex_unlock(&channelcount);
   return 0;
}

char* key

(

void

)

Returns the ASTERISK_GPL_KEY.

This returns the ASTERISK_GPL_KEY, signifiying that you agree to the terms of the GPL stated in the ASTERISK_GPL_KEY. Your module will not load if it does not return the EXACT message:

 char *key(void) {
         return ASTERISK_GPL_KEY;
 }

Returns:

ASTERISK_GPL_KEY

Definition at line 913 of file codec_zap.c.

References ASTERISK_GPL_KEY.

{
   return ASTERISK_GPL_KEY;
}

int load_module

(

void

)

Initialize the module.

This function is called at module load time. Put all code in here that needs to set up your module's hardware, software, registrations, etc.

Returns:

This function should return 0 on success and non-zero on failure. If the module is not loaded successfully, Asterisk will call its unload_module() function.

Initialize the Agents module. This function is being called by Asterisk when loading the module. Among other thing it registers applications, cli commands and reads the cofiguration file.

Returns:

int Always 0.

TE STUFF END

Definition at line 891 of file codec_zap.c.

References ast_cli_register_multiple(), ast_mutex_init(), find_transcoders(), and parse_config().

{
   ast_mutex_init(&channelcount);
   parse_config();

   find_transcoders();
   ast_cli_register_multiple(transcoder_cli, sizeof(transcoder_cli) / sizeof(struct ast_cli_entry));
   return 0;
}

static void parse_config

(

void

)

[static]

Definition at line 788 of file codec_zap.c.

References ast_config_destroy(), ast_config_load(), ast_true(), ast_variable_browse(), ast_verbose(), cfg, ast_variable::name, ast_variable::next, option_verbose, ast_variable::value, var, and VERBOSE_PREFIX_3.

{
   struct ast_variable *var;
   struct ast_config *cfg = ast_config_load("codecs.conf");

   if (!cfg)
      return;

   for (var = ast_variable_browse(cfg, "plc"); var; var = var->next) {
      if (!strcasecmp(var->name, "genericplc")) {
         global_useplc = ast_true(var->value);
         if (option_verbose > 2)
            ast_verbose(VERBOSE_PREFIX_3 "codec_zap: %susing generic PLC\n", global_useplc ? "" : "not ");
      }
   }

   ast_config_destroy(cfg);
}

static int register_translator	(	int	dst,
		int	src
	)			[static]

Definition at line 704 of file codec_zap.c.

References ast_getformatname(), AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, ast_log(), ast_register_translator(), calloc, ast_translator::destroy, ast_translator::dstfmt, fakesrc_sample(), ast_translator::framein, ast_translator::frameout, free, LOG_ERROR, format_map::map, ast_translator::name, ast_translator::newpvt, ast_translator::sample, ast_translator::srcfmt, translator::t, zap_destroy(), zap_framein(), zap_frameout(), zap_new_alawtog723(), zap_new_alawtog729(), zap_new_g723toalaw(), zap_new_g723toulaw(), zap_new_g729toalaw(), zap_new_g729toulaw(), zap_new_ulawtog723(), and zap_new_ulawtog729().

Referenced by build_translators().

{
   struct translator *zt;
   int res;

   if (!(zt = calloc(1, sizeof(*zt)))) {
      ast_log(LOG_ERROR, "Could not allocate translator\n");
      return -1;
   }

   snprintf((char *) (zt->t.name), sizeof(zt->t.name), "zap%sto%s", 
       ast_getformatname((1 << src)), ast_getformatname((1 << dst)));

   if(src == 8 && dst == 2) /* G.729 to Ulaw */
      zt->t.newpvt = zap_new_g729toulaw;
   else if(src == 8 && dst == 3) /* G.729 to Alaw */
      zt->t.newpvt = zap_new_g729toalaw;
   else if(src == 2 && dst == 8) /* Ulaw to G.729 */
      zt->t.newpvt = zap_new_ulawtog729;
   else if(src == 3 && dst == 8) /* Alaw to G.729 */
      zt->t.newpvt = zap_new_alawtog729;
   else if(src == 0 && dst == 2) /* G.723 to Ulaw */
      zt->t.newpvt = zap_new_g723toulaw;
   else if(src == 0 && dst == 3) /* G.723 to Alaw */
      zt->t.newpvt = zap_new_g723toalaw;
   else if(src == 2 && dst == 0) /* Ulaw to G.723 */
      zt->t.newpvt = zap_new_ulawtog723;
   else if(src == 3 && dst == 0) /* Alaw to G.723 */
      zt->t.newpvt = zap_new_alawtog723;

   zt->t.frameout = zap_frameout;
   zt->t.destroy = zap_destroy;
   zt->t.sample = fakesrc_sample;
   zt->t.framein = zap_framein;
   zt->t.srcfmt = (1 << src);
   zt->t.dstfmt = (1 << dst);
   if ((res = ast_register_translator(&zt->t))) {
      free(zt);
      return -1;
   }

   AST_LIST_LOCK(&zap_translators);
   AST_LIST_INSERT_HEAD(&zap_translators, zt, entry);
   AST_LIST_UNLOCK(&zap_translators);

   global_format_map.map[dst][src] = 1;

   return res;
}

int reload

(

void

)

Reload stuff.

This function is where any reload routines take place. Re-read config files, change signalling, whatever is appropriate on a reload.

Returns:

The return value is not used.

Definition at line 875 of file codec_zap.c.

References parse_config().

{
   parse_config();

   return 0;
}

static int show_transcoder	(	int	fd,
		int	argc,
		char **	argv
	)			[static]

Definition at line 108 of file codec_zap.c.

References ast_cli(), ast_mutex_lock(), ast_mutex_unlock(), and RESULT_SUCCESS.

{
   ast_mutex_lock(&channelcount);

   if (!totalchannels) { 
      ast_cli(fd, "No transcoder card registered\n");
      ast_mutex_unlock(&channelcount);
      return RESULT_SUCCESS;
   }

   ast_cli(fd, "%d/%d encoders/decoders of %d channels are in use.\n", complexinuse, simpleinuse, totalchannels);

   ast_mutex_unlock(&channelcount);
   return RESULT_SUCCESS;
}

int unload_module

(

void

)

Cleanup all module structures, sockets, etc.

This is called at exit. Any registrations and memory allocations need to be unregistered and free'd here. Nothing else will do these for you (until exit).

Returns:

Zero on success, or non-zero on error.

Definition at line 882 of file codec_zap.c.

References ast_cli_unregister_multiple(), and unregister_translators().

{
   if(!localusecnt)
      return -1;
   unregister_translators();
   ast_cli_unregister_multiple(transcoder_cli, sizeof(transcoder_cli) / sizeof(struct ast_cli_entry));
   return 0;
}

static void unregister_translators

(

void

)

[static]

Definition at line 776 of file codec_zap.c.

References AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_unregister_translator(), free, and translator::t.

Referenced by unload_module().

{
   struct translator *cur;

   AST_LIST_LOCK(&zap_translators);
   while ((cur = AST_LIST_REMOVE_HEAD(&zap_translators, entry))) {
      ast_unregister_translator(&cur->t);
      free(cur);
   }
   AST_LIST_UNLOCK(&zap_translators);
}

int usecount

(

void

)

Provides a usecount.

This function will be called by various parts of asterisk. Basically, all it has to do is to return a usecount when called. You will need to maintain your usecount within the module somewhere. The usecount should be how many channels provided by this module are in use.

Returns:

The module's usecount.

Definition at line 906 of file codec_zap.c.

References STANDARD_USECOUNT.

{
   int res;
   STANDARD_USECOUNT(res);
   return res;
}

static void zap_destroy

(

struct ast_translator_pvt *

ztp

)

[static]

Definition at line 215 of file codec_zap.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, ast_translator_pvt::inuse, and LOG_WARNING.

Referenced by register_translator().

{
   unsigned int x;

   x = ZT_TCOP_RELEASE;
   if (ioctl(ztp->fd, ZT_TRANSCODE_OP, &x))
      ast_log(LOG_WARNING, "Failed to release transcoder channel: %s\n", strerror(errno));
            
   munmap(ztp->hdr, sizeof(*ztp->hdr));
   if(ztp->inuse) {
      ast_mutex_lock(&channelcount);
      localusecnt--;
      if(ztp->dstfmt == 8 || ztp->dstfmt == 0)
         complexinuse--;
      else
         simpleinuse--;
      ast_mutex_unlock(&channelcount);
   }
   close(ztp->fd);
}

static int zap_framein	(	struct ast_translator_pvt *	ztp,
		struct ast_frame *	f
	)			[static]

Definition at line 124 of file codec_zap.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_frame::data, ast_frame::datalen, ast_translator_pvt::dstfmt, ast_translator_pvt::fake, ast_translator_pvt::hdr, ast_translator_pvt::inuse, LOG_WARNING, ast_frame::samples, ast_translator_pvt::samples, and ast_frame::subclass.

Referenced by register_translator().

{
   struct zt_transcode_header *hdr = ztp->hdr;
   if (!f->subclass) {
      /* Fake a return frame for calculation purposes */
      ztp->fake = 2;
      ztp->samples = f->samples;
      return 0;
   }
   if(!ztp->inuse) {
      ast_mutex_lock(&channelcount);
      localusecnt++;
      if(ztp->dstfmt == 8 || ztp->dstfmt == 0 ) 
         complexinuse++;
      else 
         simpleinuse++;
      ast_mutex_unlock(&channelcount);
      ztp->inuse = 1;
   }
   if (!hdr->srclen)
      /* Copy at front of buffer */
      hdr->srcoffset = 0;

   if (hdr->srclen + f->datalen > sizeof(hdr->srcdata)) {
      ast_log(LOG_WARNING, "Out of space for codec translation!\n");
      return -1;
   }

   if (hdr->srclen + f->datalen + hdr->srcoffset > sizeof(hdr->srcdata)) {
      /* Very unlikely */
      memmove(hdr->srcdata, hdr->srcdata + hdr->srcoffset, hdr->srclen);
      hdr->srcoffset = 0;
   }

   memcpy(hdr->srcdata + hdr->srcoffset + hdr->srclen, f->data, f->datalen);
   hdr->srclen += f->datalen;
   ztp->samples += f->samples;

   return -1;
}

static struct ast_frame* zap_frameout

(

struct ast_translator_pvt *

ztp

)

[static, read]

Definition at line 165 of file codec_zap.c.

References AST_FRAME_VOICE, AST_FRIENDLY_OFFSET, ast_log(), ast_verbose(), ast_frame::data, ast_frame::datalen, ast_translator_pvt::f, ast_translator_pvt::fake, ast_translator_pvt::fd, ast_frame::frametype, ast_translator_pvt::hdr, LOG_WARNING, ast_frame::mallocd, ast_frame::offset, ast_translator_pvt::samples, ast_frame::samples, and ast_frame::subclass.

Referenced by register_translator().

{
   struct zt_transcode_header *hdr = ztp->hdr;
   unsigned int x;

   if (ztp->fake == 2) {
      ztp->fake = 1;
      ztp->f.frametype = AST_FRAME_VOICE;
      ztp->f.subclass = 0;
      ztp->f.samples = 240;
      ztp->f.data = NULL;
      ztp->f.offset = 0;
      ztp->f.datalen = 0;
      ztp->f.mallocd = 0;
      ztp->samples = 0;
   } else if (ztp->fake == 1) {
      return NULL;
   } else {
      if (hdr->dstlen) {
#ifdef DEBUG_TRANSCODE
         ztp->totalms += hdr->dstsamples;
         if ((ztp->totalms - ztp->lasttotalms) > 8000) {
            ast_verbose("Whee %p, %d (%d to %d)\n", ztp, hdr->dstlen, ztp->lasttotalms, ztp->totalms);
            ztp->lasttotalms = ztp->totalms;
         }
#endif
         ztp->f.frametype = AST_FRAME_VOICE;
         ztp->f.subclass = hdr->dstfmt;
         ztp->f.samples = hdr->dstsamples;
         ztp->f.data = hdr->dstdata + hdr->dstoffset;
         ztp->f.offset = hdr->dstoffset;
         ztp->f.datalen = hdr->dstlen;
         ztp->f.mallocd = 0;
         ztp->samples -= ztp->f.samples;
         hdr->dstlen = 0;
         
      } else {
         if (hdr->srclen) {
            hdr->dstoffset = AST_FRIENDLY_OFFSET;
            x = ZT_TCOP_TRANSCODE;
            if (ioctl(ztp->fd, ZT_TRANSCODE_OP, &x))
               ast_log(LOG_WARNING, "Failed to transcode: %s\n", strerror(errno));
         }
         return NULL;
      }
   }

   return &ztp->f;
}

static struct ast_translator_pvt* zap_new_alawtog723

(

void

)

[static, read]

Definition at line 236 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 0;
   ztp->srcfmt = 3;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_alawtog729

(

void

)

[static, read]

Definition at line 464 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 8;
   ztp->srcfmt = 3;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_g723toalaw

(

void

)

[static, read]

Definition at line 350 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 3;
   ztp->srcfmt = 0;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_g723toulaw

(

void

)

[static, read]

Definition at line 407 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 2;
   ztp->srcfmt = 0;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_g729toalaw

(

void

)

[static, read]

Definition at line 578 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 3;
   ztp->srcfmt = 8;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_g729toulaw

(

void

)

[static, read]

Definition at line 635 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 2;
   ztp->srcfmt = 8;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_ulawtog723

(

void

)

[static, read]

Definition at line 293 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 0;
   ztp->srcfmt = 2;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

static struct ast_translator_pvt* zap_new_ulawtog729

(

void

)

[static, read]

Definition at line 521 of file codec_zap.c.

References ast_log(), calloc, ast_translator_pvt::dstfmt, ast_translator_pvt::fd, ast_translator_pvt::hdr, LOG_ERROR, LOG_WARNING, and ast_translator_pvt::srcfmt.

Referenced by register_translator().

{
   /* Request translation through zap if possible */
   int fd;
   unsigned int x = ZT_TCOP_ALLOCATE;
   struct ast_translator_pvt *ztp;
   struct zt_transcode_header *hdr;
   int flags;
   
   ztp = calloc(1,sizeof(struct ast_translator_pvt));
   if(!ztp) {
      ast_log(LOG_ERROR, "Could not allocate ztp structure.\n");
      return NULL;
   }
   ztp->dstfmt = 8;
   ztp->srcfmt = 2;

   if ((fd = open("/dev/zap/transcode", O_RDWR)) < 0)
      return NULL;
   flags = fcntl(fd, F_GETFL);
   if (flags > - 1) {
      if (fcntl(fd, F_SETFL, flags | O_NONBLOCK))
         ast_log(LOG_WARNING, "Could not set non-block mode!\n");
   }
   

   if ((hdr = mmap(NULL, sizeof(*hdr), PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)) == MAP_FAILED) {
      ast_log(LOG_ERROR, "Memory Map failed for transcoding (%s)\n", strerror(errno));
      close(fd);

      return NULL;
   }

   if (hdr->magic != ZT_TRANSCODE_MAGIC) {
      ast_log(LOG_ERROR, "Transcoder header (%08x) wasn't magic.  Abandoning\n", hdr->magic);
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }
   
   hdr->srcfmt = (1 << ztp->srcfmt);
   hdr->dstfmt = (1 << ztp->dstfmt);
   if (ioctl(fd, ZT_TRANSCODE_OP, &x)) {
      ast_log(LOG_ERROR, "Unable to attach transcoder: %s\n", strerror(errno));
      munmap(hdr, sizeof(*hdr));
      close(fd);

      return NULL;
   }

   ztp->fd = fd;
   ztp->hdr = hdr;

   return (struct ast_translator_pvt *) ztp;
}

---

Variable Documentation

int complexinuse = 0 [static]

Definition at line 60 of file codec_zap.c.

struct format_map global_format_map = { { { 0 } } } [static]

Definition at line 83 of file codec_zap.c.

unsigned int global_useplc = 0 [static]

Definition at line 57 of file codec_zap.c.

int localusecnt = 0 [static]

Definition at line 62 of file codec_zap.c.

char show_transcoder_usage[] [static]

Initial value:

"Usage: show transcoder\n"
"       Displays transcoder utilization.\n"

Definition at line 67 of file codec_zap.c.

int simpleinuse = 0 [static]

Definition at line 61 of file codec_zap.c.

char* tdesc = "Generic Zaptel Transcoder Codec Translator" [static]

Definition at line 65 of file codec_zap.c.

int totalchannels = 0 [static]

Definition at line 59 of file codec_zap.c.

struct ast_cli_entry transcoder_cli[] [static]

Initial value:

 {
   { { "show", "transcoder", NULL},
   show_transcoder, "Displays transcoder utilization.",
   show_transcoder_usage}
}

Definition at line 73 of file codec_zap.c.