apps/codecs/vox.c

   1 /***************************************************************************
   2  *             __________               __   ___.
   3  *   Open      \______   \ ____   ____ |  | _\_ |__   _______  ___
   4  *   Source     |       _//  _ \_/ ___\|  |/ /| __ \ /  _ \  \/  /
   5  *   Jukebox    |    |   (  <_> )  \___|    < | \_\ (  <_> > <  <
   6  *   Firmware   |____|_  /\____/ \___  >__|_ \|___  /\____/__/\_ \
   7  *                     \/            \/     \/    \/            \/
   8  * $Id$
   9  *
  10  * Copyright (C) 2010 Yoshihisa Uchida
  11  *
  12  * This program is free software; you can redistribute it and/or
  13  * modify it under the terms of the GNU General Public License
  14  * as published by the Free Software Foundation; either version 2
  15  * of the License, or (at your option) any later version.
  16  *
  17  * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
  18  * KIND, either express or implied.
  19  *
  20  ****************************************************************************/
  21
  22 #include "codeclib.h"
  23 #include "codecs/libpcm/support_formats.h"
  24
  25 CODEC_HEADER
  26
  27 /* vox codec (Dialogic telephony file formats) */
  28
  29 #define PCM_SAMPLE_SIZE (2048)
  30
  31 static int32_t samples[PCM_SAMPLE_SIZE] IBSS_ATTR;
  32
  33 static struct pcm_format format;
  34 static uint32_t bytesdone;
  35
  36 static uint8_t *read_buffer(size_t *realsize)
  37 {
  38     uint8_t *buffer = (uint8_t *)ci->request_buffer(realsize, format.chunksize);
  39     if (bytesdone + (*realsize) > format.numbytes)
  40         *realsize = format.numbytes - bytesdone;
  41     bytesdone += *realsize;
  42     ci->advance_buffer(*realsize);
  43     return buffer;
  44 }
  45
  46 /* this is the codec entry point */
  47 enum codec_status codec_main(void)
  48 {
  49     int status = CODEC_OK;
  50     uint32_t decodedsamples;
  51     size_t n;
  52     int bufcount;
  53     int endofstream;
  54     uint8_t *voxbuf;
  55     off_t firstblockposn = 0;     /* position of the first block in file */
  56     const struct pcm_codec *codec;
  57
  58     /* Generic codec initialisation */
  59     ci->configure(DSP_SET_SAMPLE_DEPTH, PCM_OUTPUT_DEPTH-1);
  60
  61 next_track:
  62     if (codec_init()) {
  63         DEBUGF("codec_init() error\n");
  64         status = CODEC_ERROR;
  65         goto exit;
  66     }
  67
  68     while (!*ci->taginfo_ready && !ci->stop_codec)
  69         ci->sleep(1);
  70
  71     codec_set_replaygain(ci->id3);
  72
  73     /* Need to save offset for later use (cleared indirectly by advance_buffer) */
  74     bytesdone = ci->id3->offset;
  75
  76     ci->memset(&format, 0, sizeof(struct pcm_format));
  77
  78     /* set format */
  79     format.channels      = 1;
  80     format.bitspersample = 4;
  81     format.numbytes      = ci->id3->filesize;
  82     format.blockalign    = 1;
  83
  84     /* advance to first WAVE chunk */
  85     firstblockposn = 0;
  86     decodedsamples = 0;
  87     ci->advance_buffer(firstblockposn);
  88
  89     /*
  90      * get codec
  91      * supports dialogic oki adpcm only
  92      */
  93     codec = get_dialogic_oki_adpcm_codec();
  94     if (!codec)
  95     {
  96         DEBUGF("CODEC_ERROR: dialogic oki adpcm codec does not load.\n");
  97         status = CODEC_ERROR;
  98         goto done;
  99     }
 100
 101     if (!codec->set_format(&format))
 102     {
 103         status = CODEC_ERROR;
 104         goto done;
 105     }
 106
 107     if (format.numbytes == 0) {
 108         DEBUGF("CODEC_ERROR: data size is 0\n");
 109         status = CODEC_ERROR;
 110         goto done;
 111     }
 112
 113     /* check chunksize */
 114     if (format.chunksize * 2 > PCM_SAMPLE_SIZE)
 115         format.chunksize = PCM_SAMPLE_SIZE / 2;
 116     if (format.chunksize == 0)
 117     {
 118         DEBUGF("CODEC_ERROR: chunksize is 0\n");
 119         status = CODEC_ERROR;
 120         goto done;
 121     }
 122
 123     ci->configure(DSP_SWITCH_FREQUENCY, ci->id3->frequency);
 124     ci->configure(DSP_SET_STEREO_MODE, STEREO_MONO);
 125
 126     /* make sure we're at the correct offset */
 127     if (bytesdone > (uint32_t) firstblockposn) {
 128         /* Round down to previous block */
 129         struct pcm_pos *newpos = codec->get_seek_pos(bytesdone - firstblockposn,
 130                                                      PCM_SEEK_POS, &read_buffer);
 131
 132         if (newpos->pos > format.numbytes)
 133             goto done;
 134         if (ci->seek_buffer(firstblockposn + newpos->pos))
 135         {
 136             bytesdone      = newpos->pos;
 137             decodedsamples = newpos->samples;
 138         }
 139         ci->seek_complete();
 140     } else {
 141         /* already where we need to be */
 142         bytesdone = 0;
 143     }
 144
 145     /* The main decoder loop */
 146     endofstream = 0;
 147
 148     while (!endofstream) {
 149         ci->yield();
 150         if (ci->stop_codec || ci->new_track) {
 151             break;
 152         }
 153
 154         if (ci->seek_time) {
 155             struct pcm_pos *newpos = codec->get_seek_pos(ci->seek_time, PCM_SEEK_TIME,
 156                                                          &read_buffer);
 157
 158             if (newpos->pos > format.numbytes)
 159                 break;
 160             if (ci->seek_buffer(firstblockposn + newpos->pos))
 161             {
 162                 bytesdone      = newpos->pos;
 163                 decodedsamples = newpos->samples;
 164             }
 165             ci->seek_complete();
 166         }
 167
 168         voxbuf = (uint8_t *)ci->request_buffer(&n, format.chunksize);
 169         if (n == 0)
 170             break; /* End of stream */
 171         if (bytesdone + n > format.numbytes) {
 172             n = format.numbytes - bytesdone;
 173             endofstream = 1;
 174         }
 175
 176         status = codec->decode(voxbuf, n, samples, &bufcount);
 177         if (status == CODEC_ERROR)
 178         {
 179             DEBUGF("codec error\n");
 180             goto done;
 181         }
 182
 183         ci->pcmbuf_insert(samples, NULL, bufcount);
 184         ci->advance_buffer(n);
 185         bytesdone += n;
 186         decodedsamples += bufcount;
 187
 188         if (bytesdone >= format.numbytes)
 189             endofstream = 1;
 190         ci->set_elapsed(decodedsamples*1000LL/ci->id3->frequency);
 191     }
 192     status = CODEC_OK;
 193
 194 done:
 195     if (ci->request_next_track())
 196         goto next_track;
 197
 198 exit:
 199     return status;
 200 }