diff --git a/.gitignore b/.gitignore index 6a47caf4ae..2d0effae96 100644 --- a/.gitignore +++ b/.gitignore @@ -151,7 +151,6 @@ Release/ /src/mod/applications/mod_test/test/Makefile.in /src/mod/codecs/mod_com_g729/Makefile /src/mod/codecs/mod_com_g729/Makefile.in -/src/mod/codecs/mod_dahdi_codec/Makefile /src/mod/dialplans/mod_dialplan_directory/Makefile /src/mod/formats/mod_shell_stream/Makefile /src/mod/languages/mod_lua/mod_lua_wrap.cpp.orig diff --git a/build/modules.conf.in b/build/modules.conf.in index 9a4c419f64..34266964dc 100755 --- a/build/modules.conf.in +++ b/build/modules.conf.in @@ -64,7 +64,6 @@ codecs/mod_b64 #codecs/mod_clearmode #codecs/mod_codec2 #codecs/mod_com_g729 -#codecs/mod_dahdi_codec codecs/mod_g723_1 codecs/mod_g729 codecs/mod_h26x diff --git a/build/modules.conf.most b/build/modules.conf.most index 0cc812dba4..c25126f5c8 100755 --- a/build/modules.conf.most +++ b/build/modules.conf.most @@ -62,7 +62,6 @@ codecs/mod_b64 codecs/mod_bv codecs/mod_codec2 #codecs/mod_com_g729 -codecs/mod_dahdi_codec codecs/mod_g723_1 codecs/mod_g729 codecs/mod_h26x diff --git a/configure.ac b/configure.ac index 8866ba7a1b..139ff97358 100755 --- a/configure.ac +++ b/configure.ac @@ -2159,7 +2159,6 @@ AC_CONFIG_FILES([Makefile src/mod/codecs/mod_clearmode/Makefile src/mod/codecs/mod_codec2/Makefile src/mod/codecs/mod_com_g729/Makefile - src/mod/codecs/mod_dahdi_codec/Makefile src/mod/codecs/mod_g723_1/Makefile src/mod/codecs/mod_g729/Makefile src/mod/codecs/mod_h26x/Makefile diff --git a/debian/bootstrap.sh b/debian/bootstrap.sh index 4a87f02570..37cc2fe0c3 100755 --- a/debian/bootstrap.sh +++ b/debian/bootstrap.sh @@ -710,7 +710,6 @@ Depends: \${misc:Depends}, freeswitch (= \${binary:Version}), freeswitch-mod-b64 (= \${binary:Version}), freeswitch-mod-bv (= \${binary:Version}), freeswitch-mod-codec2 (= \${binary:Version}), - freeswitch-mod-dahdi-codec (= \${binary:Version}), freeswitch-mod-g723-1 (= \${binary:Version}), freeswitch-mod-g729 (= \${binary:Version}), freeswitch-mod-h26x (= \${binary:Version}), @@ -737,7 +736,6 @@ Depends: \${misc:Depends}, freeswitch (= \${binary:Version}), freeswitch-mod-b64-dbg (= \${binary:Version}), freeswitch-mod-bv-dbg (= \${binary:Version}), freeswitch-mod-codec2-dbg (= \${binary:Version}), - freeswitch-mod-dahdi-codec-dbg (= \${binary:Version}), freeswitch-mod-g723-1-dbg (= \${binary:Version}), freeswitch-mod-g729-dbg (= \${binary:Version}), freeswitch-mod-h26x-dbg (= \${binary:Version}), diff --git a/debian/control-modules b/debian/control-modules index 8e59f8f3ae..afcf1e23e9 100755 --- a/debian/control-modules +++ b/debian/control-modules @@ -311,10 +311,6 @@ Module: codecs/mod_com_g729 Description: mod_com_g729 Adds mod_com_g729. -Module: codecs/mod_dahdi_codec -Description: mod_dahdi_codec - Adds mod_dahdi_codec. - Module: codecs/mod_g723_1 Description: mod_g723_1 Adds mod_g723_1. diff --git a/src/mod/codecs/mod_dahdi_codec/Makefile.am b/src/mod/codecs/mod_dahdi_codec/Makefile.am deleted file mode 100644 index d4e3287746..0000000000 --- a/src/mod/codecs/mod_dahdi_codec/Makefile.am +++ /dev/null @@ -1,8 +0,0 @@ -include $(top_srcdir)/build/modmake.rulesam -MODNAME=mod_dahdi_codec - -mod_LTLIBRARIES = mod_dahdi_codec.la -mod_dahdi_codec_la_SOURCES = mod_dahdi_codec.c -mod_dahdi_codec_la_CFLAGS = $(AM_CFLAGS) -mod_dahdi_codec_la_LIBADD = $(switch_builddir)/libfreeswitch.la -mod_dahdi_codec_la_LDFLAGS = -avoid-version -module -no-undefined -shared diff --git a/src/mod/codecs/mod_dahdi_codec/mod_dahdi_codec.c b/src/mod/codecs/mod_dahdi_codec/mod_dahdi_codec.c deleted file mode 100644 index 6e7f15428c..0000000000 --- a/src/mod/codecs/mod_dahdi_codec/mod_dahdi_codec.c +++ /dev/null @@ -1,583 +0,0 @@ -/* - * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application - * Copyright (C) 2005-2014, Anthony Minessale II - * - * Version: MPL 1.1 - * - * The contents of this file are subject to the Mozilla Public License Version - * 1.1 (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * http://www.mozilla.org/MPL/ - * - * Software distributed under the License is distributed on an "AS IS" basis, - * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License - * for the specific language governing rights and limitations under the - * License. - * - * The Original Code is FreeSWITCH Modular Media Switching Software Library / DAHDI codec module - * - * The Initial Developer of the Original Code is - * Moises Silva - * Portions created by the Initial Developer are Copyright (C) - * the Initial Developer. All Rights Reserved. - * - * Contributor(s): - * Moises Silva - * - * mod_dahdi_codec -- DAHDI Codecs (G729A 8.0kbit, G723.1 5.3kbit) - * - * Thanks to Voiceway for sponsoring this module and Neocenter for providing the DAHDI hardware to test - * - */ - -#include -#include -#include -#include /* __u32 */ -#include -#include -#include -#include - -/* - * some rules to keep in mind for G729 (the frame size may be different for G723) - * we cannot write more than SFRAME_SIZE (320) - sizeof(struct rtp_packet) which - * seems to be 266 bytes - * if we write less than 160 bytes (1 ulaw frame which is 20 bytes of G729 bytes, a read will block forever) - * TODO: do buffering ourselves to provide just the fixed amount of samples that the card expects - * */ -#define DAHDI_G729_INPUT_FRAME_SIZE 160 -#define DAHDI_G729_OUTPUT_FRAME_SIZE 20 - -/*#define DEBUG_DAHDI_CODEC 1*/ - -#define CODEC_G729_IANA_CODE 18 -#define CODEC_G723_IANA_CODE 4 - -switch_mutex_t *transcoder_counter_mutex; -static uint32_t total_encoders = 0; -static uint32_t total_encoders_usage = 0; -static uint32_t total_decoders = 0; -static uint32_t total_decoders_usage = 0; - -/* - Zaptel/DAHDI definitions to not require the headers installed - Zaptel and DAHDI are binary compatible (at least in the transcoder interface) - */ - -#define DAHDI_TC_CODE 'T' -#define DAHDI_TC_ALLOCATE _IOW(DAHDI_TC_CODE, 1, struct dahdi_transcoder_formats) -#define DAHDI_TC_GETINFO _IOWR(DAHDI_TC_CODE, 2, struct dahdi_transcoder_info) - -#define DAHDI_FORMAT_G723_1 (1 << 0) -#define DAHDI_FORMAT_ULAW (1 << 2) -#define DAHDI_FORMAT_SLINEAR (1 << 6) -#define DAHDI_FORMAT_G729A (1 << 8) - -struct dahdi_transcoder_formats { - __u32 srcfmt; - __u32 dstfmt; -}; - -struct dahdi_transcoder_info { - __u32 tcnum; - char name[80]; - __u32 numchannels; - __u32 dstfmts; - __u32 srcfmts; -}; - -static const char transcoding_device_dahdi[] = "/dev/dahdi/transcode"; -static const char transcoder_name_dahdi[] = "DAHDI"; -static const char transcoding_device_zap[] = "/dev/zap/transcode"; -static const char transcoder_name_zap[] = "Zap"; -static const char *transcoding_device = NULL; -static const char *transcoder_name = NULL; - -SWITCH_MODULE_LOAD_FUNCTION(mod_dahdi_codec_load); -SWITCH_MODULE_DEFINITION(mod_dahdi_codec, mod_dahdi_codec_load, NULL, NULL); - -struct dahdi_context { - int32_t encoding_fd; - int32_t decoding_fd; - uint8_t codec_r; -}; - -static int32_t switch_dahdi_get_transcoder(struct dahdi_transcoder_formats *fmts) -{ - int32_t fdflags; - int32_t fd = open(transcoding_device, O_RDWR); - if (fd < 0) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to open %s transcoder device: %s.\n", transcoder_name, strerror(errno)); - return -1; - } - if (ioctl(fd, DAHDI_TC_ALLOCATE, fmts)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to attach to transcoder: %s.\n", strerror(errno)); - close(fd); - return -1; - } - fdflags = fcntl(fd, F_GETFL); - if (fdflags > -1) { - fdflags |= O_NONBLOCK; - if (fcntl(fd, F_SETFL, fdflags)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Could not set non-block mode in %s transcoder FD: %s\n", - transcoder_name, strerror(errno)); - /* should we abort? this may cause channels to hangup when overruning the device - * see jira dahdi codec issue MODCODEC-8 (Hung Calls and Codec DAHDI G.729A 8.0k decoder error!) - * */ - } - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Could not get flags from %s transcoder FD: %s\n", transcoder_name, strerror(errno)); - } - - if (fmts->srcfmt & DAHDI_FORMAT_ULAW) { - switch_mutex_lock(transcoder_counter_mutex); - total_encoders_usage++; - switch_mutex_unlock(transcoder_counter_mutex); - } else { - switch_mutex_lock(transcoder_counter_mutex); - total_decoders_usage++; - switch_mutex_unlock(transcoder_counter_mutex); - } - - return fd; -} - -static switch_status_t init_encoder(switch_codec_t *codec) -{ - struct dahdi_transcoder_formats fmts; - struct dahdi_context *context = codec->private_info; - - fmts.srcfmt = DAHDI_FORMAT_ULAW; - fmts.dstfmt = (codec->implementation->ianacode == CODEC_G729_IANA_CODE) - ? DAHDI_FORMAT_G729A : DAHDI_FORMAT_G723_1; - context->encoding_fd = switch_dahdi_get_transcoder(&fmts); - if (context->encoding_fd < 0) { -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "encoding requested and denied with %d/%d.\n", fmts.srcfmt, fmts.dstfmt); -#endif - return SWITCH_STATUS_FALSE; - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Encoding requested and granted with %d/%d.\n", fmts.srcfmt, fmts.dstfmt); -#endif - - - return SWITCH_STATUS_SUCCESS; -} - - -static switch_status_t init_decoder(switch_codec_t *codec) -{ - struct dahdi_transcoder_formats fmts; - struct dahdi_context *context = codec->private_info; - - fmts.dstfmt = DAHDI_FORMAT_ULAW; - fmts.srcfmt = (codec->implementation->ianacode == CODEC_G729_IANA_CODE) - ? DAHDI_FORMAT_G729A : DAHDI_FORMAT_G723_1; - context->decoding_fd = switch_dahdi_get_transcoder(&fmts); - if (context->decoding_fd < 0) { -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Decoding requested and denied with %d/%d.\n", fmts.srcfmt, fmts.dstfmt); -#endif - return SWITCH_STATUS_FALSE; - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Decoding requested and granted with %d/%d.\n", fmts.srcfmt, fmts.dstfmt); -#endif - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t switch_dahdi_init(switch_codec_t *codec, switch_codec_flag_t flags, const switch_codec_settings_t *codec_settings) -{ - uint32_t encoding, decoding; - struct dahdi_context *context = NULL; - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Switch DAHDI init called.\n"); - - encoding = (flags & SWITCH_CODEC_FLAG_ENCODE); - decoding = (flags & SWITCH_CODEC_FLAG_DECODE); - - if (!(encoding || decoding)) { -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No encoding or decoding requested for DAHDI transcoder?.\n"); -#endif - return SWITCH_STATUS_FALSE; - } - - if (!(context = switch_core_alloc(codec->memory_pool, sizeof(*context)))) { -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to allocate memory for dahdi codec context.\n"); -#endif - return SWITCH_STATUS_FALSE; - } - - codec->private_info = context; - context->encoding_fd = -1; - context->decoding_fd = -1; - - /* ulaw requires 8 times more storage than g729 and 12 times more than G723, right? - * this can be used to calculate the target buffer when encoding and decoding - * */ - context->codec_r = (codec->implementation->ianacode == CODEC_G729_IANA_CODE) - ? 8 : 12; - - - return SWITCH_STATUS_SUCCESS; -} - -static int wait_for_transcoder(int fd) -{ - /* let's wait a bit for the transcoder, if in 20msthe driver does not notify us that its ready to give us something - then just bail out with 0 bytes encoded/decoded as result, I'd expect the card to hold that buffer and return it later */ - int res = 0; - struct pollfd readpoll; - memset(&readpoll, 0, sizeof(readpoll)); - readpoll.fd = fd; - readpoll.events = POLLIN; - /* my testing shows that it does not take more than 1ms to encode a 160 bytes frame ulaw to g729, - I dont think there is much difference decoding and for g723, waiting 10ms seems more than reasonable */ - res = poll(&readpoll, 1, 10); - return res; -} - -static switch_status_t switch_dahdi_encode(switch_codec_t *codec, - switch_codec_t *other_codec, - void *decoded_data, - uint32_t decoded_data_len, - uint32_t decoded_rate, void *encoded_data, uint32_t *encoded_data_len, uint32_t *encoded_rate, - unsigned int *flag) -{ - int32_t res; - short *dbuf_linear; - unsigned char ebuf_ulaw[decoded_data_len / 2]; - uint32_t i; - struct dahdi_context *context = NULL; - switch_status_t status; - -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Switch DAHDI encode called to encode %d bytes.\n", decoded_data_len); -#endif - context = codec->private_info; - - if (context->encoding_fd == -1) { - if ((status = init_encoder(codec)) != SWITCH_STATUS_SUCCESS) { - return status; - } - } - - dbuf_linear = decoded_data; - for (i = 0; i < decoded_data_len / sizeof(short); i++) { - ebuf_ulaw[i] = linear_to_ulaw(dbuf_linear[i]); - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Writing %d bytes of decoded ulaw data.\n", i); -#endif - res = write(context->encoding_fd, ebuf_ulaw, i); - if (-1 == res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to write to %s encoder device.\n", transcoder_name); - return SWITCH_STATUS_FALSE; - } - if (i != res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Requested to write %d bytes to %s encoder device, but only wrote %d bytes.\n", i, - transcoder_name, res); - return SWITCH_STATUS_FALSE; - } - res = wait_for_transcoder(context->encoding_fd); - if (-1 == res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to poll on %s encoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - if (0 == res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "No output on %s encoder device.\n", transcoder_name); - *encoded_data_len = 0; - return SWITCH_STATUS_SUCCESS; - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Attempting to read %d bytes of encoded data.\n", *encoded_data_len); -#endif - res = read(context->encoding_fd, encoded_data, *encoded_data_len); - if (-1 == res) { - if (EAGAIN == errno || EWOULDBLOCK == errno) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "No output on %s encoder device (%s).\n", transcoder_name, strerror(errno)); - *encoded_data_len = 0; - return SWITCH_STATUS_SUCCESS; - } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to read from %s encoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - *encoded_data_len = res; -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Read %d bytes of encoded data.\n", res); -#endif - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t switch_dahdi_decode(switch_codec_t *codec, - switch_codec_t *other_codec, - void *encoded_data, - uint32_t encoded_data_len, - uint32_t encoded_rate, void *decoded_data, uint32_t *decoded_data_len, uint32_t *decoded_rate, - unsigned int *flag) -{ - int32_t res; - short *dbuf_linear; - // we only can decode up to half ulaw bytes of whatever their destiny linear buffer is - unsigned char dbuf_ulaw[*decoded_data_len / 2]; - unsigned char *ebuf_g729; - uint32_t i; - struct dahdi_context *context; - switch_status_t status; - -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Switch DAHDI decode called to decode %d bytes.\n", encoded_data_len); -#endif - - context = codec->private_info; - dbuf_linear = decoded_data; - ebuf_g729 = encoded_data; - - if (context->decoding_fd == -1) { - if ((status = init_decoder(codec)) != SWITCH_STATUS_SUCCESS) { - return status; - } - } - - if (*flag & SWITCH_CODEC_FLAG_SILENCE) { - memset(dbuf_linear, 0, codec->implementation->decoded_bytes_per_packet); - *decoded_data_len = codec->implementation->decoded_bytes_per_packet; -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Switch DAHDI decode in silence returned %d bytes.\n", *decoded_data_len); -#endif - return SWITCH_STATUS_SUCCESS; - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Writing %d bytes to decode.\n", encoded_data_len); -#endif - res = write(context->decoding_fd, ebuf_g729, encoded_data_len); - if (-1 == res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to write to %s decoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - if (encoded_data_len != res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Requested to write %d bytes to %s decoder device, but only wrote %d bytes.\n", - encoded_data_len, transcoder_name, res); - return SWITCH_STATUS_FALSE; - } -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Attempting to read from device %d bytes of decoded ulaw data.\n", sizeof(dbuf_ulaw)); -#endif - res = wait_for_transcoder(context->decoding_fd); - if (-1 == res) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to poll on %s decoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - if (0 == res) { - memset(dbuf_linear, 0, codec->implementation->decoded_bytes_per_packet); - *decoded_data_len = codec->implementation->decoded_bytes_per_packet; -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "No output on %s decoder device, returning silence frame of %d bytes.\n", transcoder_name, - *decoded_data_len); -#endif - return SWITCH_STATUS_SUCCESS; - } - res = read(context->decoding_fd, dbuf_ulaw, sizeof(dbuf_ulaw)); - if (-1 == res) { - if (EAGAIN == errno || EWOULDBLOCK == errno) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "No output on %s decoder device (%s).\n", transcoder_name, strerror(errno)); - *decoded_data_len = 0; - return SWITCH_STATUS_SUCCESS; - } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to read from %s decoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - for (i = 0; i < res; i++) { - dbuf_linear[i] = ulaw_to_linear(dbuf_ulaw[i]); - } - *decoded_data_len = i * 2; -#ifdef DEBUG_DAHDI_CODEC - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Switch DAHDI decode returned %d bytes.\n", *decoded_data_len); -#endif - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t switch_dahdi_destroy(switch_codec_t *codec) -{ - /* memory pool takes care of the private_info memory */ - struct dahdi_context *context = codec->private_info; - if (context->encoding_fd >= 0) { - switch_mutex_lock(transcoder_counter_mutex); - total_encoders_usage--; - switch_mutex_unlock(transcoder_counter_mutex); - close(context->encoding_fd); - } - if (context->decoding_fd >= 0) { - switch_mutex_lock(transcoder_counter_mutex); - total_decoders_usage--; - switch_mutex_unlock(transcoder_counter_mutex); - close(context->decoding_fd); - } - codec->private_info = NULL; - return SWITCH_STATUS_SUCCESS; -} - -SWITCH_STANDARD_API(dahdi_transcode_usage) -{ - if (!total_encoders && !total_decoders) { - stream->write_function(stream, "No DAHDI transcoding hardware found.\n"); - return SWITCH_STATUS_SUCCESS; - } - switch_mutex_lock(transcoder_counter_mutex); - stream->write_function(stream, "Using %d encoders of a total of %d available.\n", total_encoders_usage, total_encoders); - stream->write_function(stream, "Using %d decoders of a total of %d available.\n", total_decoders_usage, total_decoders); - switch_mutex_unlock(transcoder_counter_mutex); - return SWITCH_STATUS_SUCCESS; -} - -SWITCH_MODULE_LOAD_FUNCTION(mod_dahdi_codec_load) -{ - switch_api_interface_t *api_interface; - switch_codec_interface_t *codec_interface; - struct stat statbuf; - struct dahdi_transcoder_info info = { 0 }; - int32_t fd; - int mpf = 20000; /* Algorithmic delay of 15ms with 5ms of look-ahead delay */ - int spf = 160; - int bpfd = 320; - int bpfc = 20; - int fpnp = 20; - - total_encoders = 0; - total_encoders_usage = 0; - total_decoders = 0; - total_decoders_usage = 0; - - /* Let's check if DAHDI or Zaptel device should be used */ - if (!stat(transcoding_device_dahdi, &statbuf)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "DAHDI transcoding device found.\n"); - transcoding_device = transcoding_device_dahdi; - transcoder_name = transcoder_name_dahdi; - } else if (!stat(transcoding_device_zap, &statbuf)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Zap transcoding device found.\n"); - transcoding_device = transcoding_device_zap; - transcoder_name = transcoder_name_zap; - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No DAHDI or Zap transcoder device was found in /dev/.\n"); - return SWITCH_STATUS_FALSE; - } - - fd = open(transcoding_device, O_RDWR); - if (fd < 0) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to open %s transcoder device: %s.\n", transcoder_name, strerror(errno)); - return SWITCH_STATUS_FALSE; - } - - for (info.tcnum = 0; !ioctl(fd, DAHDI_TC_GETINFO, &info); info.tcnum++) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Found dahdi transcoder name: %s\n", info.name); - if ((info.srcfmts & DAHDI_FORMAT_ULAW) && (info.dstfmts & (DAHDI_FORMAT_G729A | DAHDI_FORMAT_G723_1))) { - total_encoders += info.numchannels; - continue; - } - if ((info.dstfmts & DAHDI_FORMAT_ULAW) && (info.srcfmts & (DAHDI_FORMAT_G729A | DAHDI_FORMAT_G723_1))) { - total_decoders += info.numchannels; - continue; - } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Not using transcoder %s, we just support ULAW and G723.1/G729A", info.name); - } - close(fd); - - if (!total_encoders && !total_decoders) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "No DAHDI transcoders found.\n"); - return SWITCH_STATUS_FALSE; - } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Found %d ULAW to G729A/G723.1 encoders.\n", total_encoders); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Found %d G729A/G723.1 to ULAW decoders.\n", total_decoders); - - switch_mutex_init(&transcoder_counter_mutex, SWITCH_MUTEX_UNNESTED, pool); - - /* connect my internal structure to the blank pointer passed to me */ - *module_interface = switch_loadable_module_create_module_interface(pool, modname); - - SWITCH_ADD_CODEC(codec_interface, "DAHDI G.729A 8.0k"); /* 8.0kbit */ - - switch_core_codec_add_implementation(pool, codec_interface, SWITCH_CODEC_TYPE_AUDIO, /* enumeration defining the type of the codec */ - 18, /* the IANA code number */ - "G729", /* the IANA code name */ - NULL, /* default fmtp to send (can be overridden by the init function) */ - 8000, /* samples transferred per second */ - 8000, /* actual samples transferred per second */ - 8000, /* bits transferred per second */ - mpf, /* number of microseconds per frame */ - spf, /* number of samples per frame */ - bpfd, /* number of bytes per frame decompressed */ - bpfc, /* number of bytes per frame compressed */ - 1, /* number of channels represented */ - fpnp, /* number of frames per network packet */ - switch_dahdi_init, /* function to initialize a codec handle using this implementation */ - switch_dahdi_encode, /* function to encode raw data into encoded data */ - switch_dahdi_decode, /* function to decode encoded data into raw data */ - switch_dahdi_destroy); /* deinitalize a codec handle using this implementation */ - - mpf = 30000; - spf = 240; - bpfd = 480; - bpfc = 30; - fpnp = 30; - switch_core_codec_add_implementation(pool, codec_interface, SWITCH_CODEC_TYPE_AUDIO, /* enumeration defining the type of the codec */ - 18, /* the IANA code number */ - "G729", /* the IANA code name */ - NULL, /* default fmtp to send (can be overridden by the init function) */ - 8000, /* samples transferred per second */ - 8000, /* actual samples transferred per second */ - 8000, /* bits transferred per second */ - mpf, /* number of microseconds per frame */ - spf, /* number of samples per frame */ - bpfd, /* number of bytes per frame decompressed */ - bpfc, /* number of bytes per frame compressed */ - 1, /* number of channels represented */ - fpnp, /* number of frames per network packet */ - switch_dahdi_init, /* function to initialize a codec handle using this implementation */ - switch_dahdi_encode, /* function to encode raw data into encoded data */ - switch_dahdi_decode, /* function to decode encoded data into raw data */ - switch_dahdi_destroy); /* deinitalize a codec handle using this implementation */ - - SWITCH_ADD_CODEC(codec_interface, "DAHDI G.723.1 5.3k"); /* 5.3kbit */ - mpf = 30000; /* Algorithmic delay of 37.5ms with 7.5ms of look-ahead delay */ - spf = 240; - bpfd = 480; - bpfc = 20; - fpnp = 10; - switch_core_codec_add_implementation(pool, codec_interface, SWITCH_CODEC_TYPE_AUDIO, /* enumeration defining the type of the codec */ - 4, /* the IANA code number */ - "G723", /* the IANA code name */ - NULL, /* default fmtp to send (can be overridden by the init function) */ - 8000, /* samples transferred per second */ - 8000, /* actual samples transferred per second */ - 8000, /* bits transferred per second */ - mpf, /* number of microseconds per frame */ - spf, /* number of samples per frame */ - bpfd, /* number of bytes per frame decompressed */ - bpfc, /* number of bytes per frame compressed */ - 1, /* number of channels represented */ - fpnp, /* number of frames per network packet */ - switch_dahdi_init, /* function to initialize a codec handle using this implementation */ - switch_dahdi_encode, /* function to encode raw data into encoded data */ - switch_dahdi_decode, /* function to decode encoded data into raw data */ - switch_dahdi_destroy); /* deinitalize a codec handle using this implementation */ - - SWITCH_ADD_API(api_interface, "dahdi_transcode", "DAHDI Transcode", dahdi_transcode_usage, NULL); - switch_console_set_complete("add dahdi_transcode"); - /* indicate that the module should continue to be loaded */ - return SWITCH_STATUS_SUCCESS; -} - -/* For Emacs: - * Local Variables: - * mode:c - * indent-tabs-mode:t - * tab-width:4 - * c-basic-offset:4 - * End: - * For VIM: - * vim:set softtabstop=4 shiftwidth=4 tabstop=4 noet: - */