Merge "resource_channels.c: add hangup reason "answered_elsewhere"."
[asterisk/asterisk.git] / codecs / codec_gsm.c
index 99b5322..f80c955 100644 (file)
 
 /*** MODULEINFO
        <depend>gsm</depend>
+       <support_level>core</support_level>
  ***/
 
 #include "asterisk.h"
 
-ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
+ASTERISK_REGISTER_FILE()
 
-#include <fcntl.h>
-#include <netinet/in.h>
-
-#include "asterisk/lock.h"
 #include "asterisk/translate.h"
 #include "asterisk/config.h"
-#include "asterisk/options.h"
 #include "asterisk/module.h"
-#include "asterisk/logger.h"
-#include "asterisk/channel.h"
 #include "asterisk/utils.h"
+#include "asterisk/linkedlists.h"
 
 #ifdef HAVE_GSM_HEADER
 #include "gsm.h"
@@ -54,15 +49,15 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 
 #include "../formats/msgsm.h"
 
-/* Sample frame data */
-#include "slin_gsm_ex.h"
-#include "gsm_slin_ex.h"
-
 #define BUFFER_SAMPLES 8000
 #define GSM_SAMPLES    160
 #define        GSM_FRAME_LEN   33
 #define        MSGSM_FRAME_LEN 65
 
+/* Sample frame data */
+#include "asterisk/slin.h"
+#include "ex_gsm.h"
+
 struct gsm_translator_pvt {    /* both gsm2lin and lin2gsm */
        gsm gsm;
        int16_t buf[BUFFER_SAMPLES];    /* lin2gsm, temporary storage */
@@ -75,42 +70,12 @@ static int gsm_new(struct ast_trans_pvt *pvt)
        return (tmp->gsm = gsm_create()) ? 0 : -1;
 }
 
-static struct ast_frame *lintogsm_sample(void)
-{
-       static struct ast_frame f;
-       f.frametype = AST_FRAME_VOICE;
-       f.subclass = AST_FORMAT_SLINEAR;
-       f.datalen = sizeof(slin_gsm_ex);
-       /* Assume 8000 Hz */
-       f.samples = sizeof(slin_gsm_ex)/2;
-       f.mallocd = 0;
-       f.offset = 0;
-       f.src = __PRETTY_FUNCTION__;
-       f.data = slin_gsm_ex;
-       return &f;
-}
-
-static struct ast_frame *gsmtolin_sample(void)
-{
-       static struct ast_frame f;
-       f.frametype = AST_FRAME_VOICE;
-       f.subclass = AST_FORMAT_GSM;
-       f.datalen = sizeof(gsm_slin_ex);
-       /* All frames are 20 ms long */
-       f.samples = GSM_SAMPLES;
-       f.mallocd = 0;
-       f.offset = 0;
-       f.src = __PRETTY_FUNCTION__;
-       f.data = gsm_slin_ex;
-       return &f;
-}
-
 /*! \brief decode and store in outbuf. */
 static int gsmtolin_framein(struct ast_trans_pvt *pvt, struct ast_frame *f)
 {
        struct gsm_translator_pvt *tmp = pvt->pvt;
        int x;
-       int16_t *dst = (int16_t *)pvt->outbuf;
+       int16_t *dst = pvt->outbuf.i16;
        /* guess format from frame len. 65 for MSGSM, 33 for regular GSM */
        int flen = (f->datalen % MSGSM_FRAME_LEN == 0) ?
                MSGSM_FRAME_LEN : GSM_FRAME_LEN;
@@ -126,10 +91,10 @@ static int gsmtolin_framein(struct ast_trans_pvt *pvt, struct ast_frame *f)
                        /* XXX what's the point here! we should just work
                         * on the full format.
                         */
-                       conv65(f->data + x, data);
+                       conv65(f->data.ptr + x, data);
                } else {
                        len = GSM_SAMPLES;
-                       src = f->data + x;
+                       src = f->data.ptr + x;
                }
                /* XXX maybe we don't need to check */
                if (pvt->samples + len > BUFFER_SAMPLES) {      
@@ -166,7 +131,7 @@ static int lintogsm_framein(struct ast_trans_pvt *pvt, struct ast_frame *f)
                ast_log(LOG_WARNING, "Out of buffer space\n");
                return -1;
        }
-       memcpy(tmp->buf + pvt->samples, f->data, f->datalen);
+       memcpy(tmp->buf + pvt->samples, f->data.ptr, f->datalen);
        pvt->samples += f->samples;
        return 0;
 }
@@ -175,25 +140,35 @@ static int lintogsm_framein(struct ast_trans_pvt *pvt, struct ast_frame *f)
 static struct ast_frame *lintogsm_frameout(struct ast_trans_pvt *pvt)
 {
        struct gsm_translator_pvt *tmp = pvt->pvt;
-       int datalen = 0;
-       int samples = 0;
+       struct ast_frame *result = NULL;
+       struct ast_frame *last = NULL;
+       int samples = 0; /* output samples */
 
-       /* We can't work on anything less than a frame in size */
-       if (pvt->samples < GSM_SAMPLES)
-               return NULL;
        while (pvt->samples >= GSM_SAMPLES) {
+               struct ast_frame *current;
+
                /* Encode a frame of data */
-               gsm_encode(tmp->gsm, tmp->buf + samples, (gsm_byte *) pvt->outbuf + datalen);
-               datalen += GSM_FRAME_LEN;
+               gsm_encode(tmp->gsm, tmp->buf + samples, (gsm_byte *) pvt->outbuf.c);
                samples += GSM_SAMPLES;
                pvt->samples -= GSM_SAMPLES;
+
+               current = ast_trans_frameout(pvt, GSM_FRAME_LEN, GSM_SAMPLES);
+               if (!current) {
+                       continue;
+               } else if (last) {
+                       AST_LIST_NEXT(last, frame_list) = current;
+               } else {
+                       result = current;
+               }
+               last = current;
        }
 
        /* Move the data at the end of the buffer to the front */
-       if (pvt->samples)
+       if (samples) {
                memmove(tmp->buf, tmp->buf + samples, pvt->samples * 2);
+       }
 
-       return ast_trans_frameout(pvt, datalen, samples);
+       return result;
 }
 
 static void gsm_destroy_stuff(struct ast_trans_pvt *pvt)
@@ -204,68 +179,55 @@ static void gsm_destroy_stuff(struct ast_trans_pvt *pvt)
 }
 
 static struct ast_translator gsmtolin = {
-       .name = "gsmtolin", 
-       .srcfmt = AST_FORMAT_GSM,
-       .dstfmt = AST_FORMAT_SLINEAR,
+       .name = "gsmtolin",
+       .src_codec = {
+               .name = "gsm",
+               .type = AST_MEDIA_TYPE_AUDIO,
+               .sample_rate = 8000,
+       },
+       .dst_codec = {
+               .name = "slin",
+               .type = AST_MEDIA_TYPE_AUDIO,
+               .sample_rate = 8000,
+       },
+       .format = "slin",
        .newpvt = gsm_new,
        .framein = gsmtolin_framein,
        .destroy = gsm_destroy_stuff,
-       .sample = gsmtolin_sample,
+       .sample = gsm_sample,
        .buffer_samples = BUFFER_SAMPLES,
        .buf_size = BUFFER_SAMPLES * 2,
        .desc_size = sizeof (struct gsm_translator_pvt ),
-       .plc_samples = GSM_SAMPLES,
 };
 
 static struct ast_translator lintogsm = {
-       .name = "lintogsm", 
-       .srcfmt = AST_FORMAT_SLINEAR,
-       .dstfmt = AST_FORMAT_GSM,
+       .name = "lintogsm",
+       .src_codec = {
+               .name = "slin",
+               .type = AST_MEDIA_TYPE_AUDIO,
+               .sample_rate = 8000,
+       },
+       .dst_codec = {
+               .name = "gsm",
+               .type = AST_MEDIA_TYPE_AUDIO,
+               .sample_rate = 8000,
+       },
+       .format = "gsm",
        .newpvt = gsm_new,
        .framein = lintogsm_framein,
        .frameout = lintogsm_frameout,
        .destroy = gsm_destroy_stuff,
-       .sample = lintogsm_sample,
+       .sample = slin8_sample,
        .desc_size = sizeof (struct gsm_translator_pvt ),
        .buf_size = (BUFFER_SAMPLES * GSM_FRAME_LEN + GSM_SAMPLES - 1)/GSM_SAMPLES,
 };
 
-
-static int parse_config(int reload)
-{
-       struct ast_variable *var;
-       struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
-       struct ast_config *cfg = ast_config_load("codecs.conf", config_flags);
-       if (!cfg)
-               return -1;
-       if (cfg == CONFIG_STATUS_FILEUNCHANGED) 
-               return 0;
-       for (var = ast_variable_browse(cfg, "plc"); var; var = var->next) {
-              if (!strcasecmp(var->name, "genericplc")) {
-                      gsmtolin.useplc = ast_true(var->value) ? 1 : 0;
-                          ast_verb(3, "codec_gsm: %susing generic PLC\n", gsmtolin.useplc ? "" : "not ");
-              }
-       }
-       ast_config_destroy(cfg);
-       return 0;
-}
-
-/*! \brief standard module glue */
-static int reload(void)
-{
-       if (parse_config(1)) {
-               return AST_MODULE_LOAD_DECLINE;
-       }
-       return AST_MODULE_LOAD_SUCCESS;
-}
-
 static int unload_module(void)
 {
        int res;
 
        res = ast_unregister_translator(&lintogsm);
-       if (!res)
-               res = ast_unregister_translator(&gsmtolin);
+       res |= ast_unregister_translator(&gsmtolin);
 
        return res;
 }
@@ -274,20 +236,19 @@ static int load_module(void)
 {
        int res;
 
-       if (parse_config(0))
-               return AST_MODULE_LOAD_DECLINE;
        res = ast_register_translator(&gsmtolin);
-       if (!res) 
-               res=ast_register_translator(&lintogsm);
-       else
-               ast_unregister_translator(&gsmtolin);
-       if (res) 
+       res |= ast_register_translator(&lintogsm);
+
+       if (res) {
+               unload_module();
                return AST_MODULE_LOAD_FAILURE;
+       }
+
        return AST_MODULE_LOAD_SUCCESS;
 }
 
 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "GSM Coder/Decoder",
-               .load = load_module,
-               .unload = unload_module,
-               .reload = reload,
-              );
+       .support_level = AST_MODULE_SUPPORT_CORE,
+       .load = load_module,
+       .unload = unload_module,
+);