rename mp3.c to mp3_afh.c and ogg.c to ogg_afh.c
authorAndre <maan@p133.(none)>
Wed, 17 May 2006 19:47:27 +0000 (21:47 +0200)
committerAndre <maan@p133.(none)>
Wed, 17 May 2006 19:47:27 +0000 (21:47 +0200)
configure.ac
error.h
mp3.c [deleted file]
mp3_afh.c [new file with mode: 0644]
ogg.c [deleted file]
ogg_afh.c [new file with mode: 0644]

index 8972090..18d6e9c 100644 (file)
@@ -71,7 +71,7 @@ audiod_errlist_objs="audiod exec close_on_fork signal string daemon stat net
 audiod_ldflags=""
 
 server_cmdline_objs="server.cmdline"
-server_errlist_objs="server mp3 afs command net string signal random_selector
+server_errlist_objs="server mp3_afh afs command net string signal random_selector
        time daemon stat crypt http_send db close_on_fork playlist_selector
        ipc dccp dccp_send fd"
 server_ldflags=""
@@ -209,7 +209,7 @@ if test "$have_ogg" = "yes"; then
        filter_cmdline_objs="$filter_cmdline_objs oggdec_filter.cmdline"
        audiod_cmdline_objs="$audiod_cmdline_objs oggdec_filter.cmdline"
 
-       server_errlist_objs="$server_errlist_objs ogg"
+       server_errlist_objs="$server_errlist_objs ogg_afh"
        filter_errlist_objs="$filter_errlist_objs oggdec"
        audiod_errlist_objs="$audiod_errlist_objs oggdec"
 else
diff --git a/error.h b/error.h
index dabe82b..924f960 100644 (file)
--- a/error.h
+++ b/error.h
@@ -46,8 +46,8 @@ enum para_subsystem {
        SS_HTTP_SEND,
        SS_ORTP_SEND,
        SS_DB,
-       SS_OGG,
-       SS_MP3,
+       SS_OGG_AFH,
+       SS_MP3_AFH,
        SS_AAC_AFH,
        SS_MP3DEC,
        SS_AACDEC,
@@ -178,7 +178,7 @@ extern const char **para_errlist[];
        PARA_ERROR(NULL_OPEN, "can not open /dev/null"), \
 
 
-#define MP3_ERRORS \
+#define MP3_AFH_ERRORS \
        PARA_ERROR(FREAD, "fread error"), \
        PARA_ERROR(FSEEK, "fseek error"), \
        PARA_ERROR(FRAME, "invalid mp3 frame"), \
@@ -203,7 +203,7 @@ extern const char **para_errlist[];
        PARA_ERROR(STCO, "did not find stco atom"), \
 
 
-#define OGG_ERRORS \
+#define OGG_AFH_ERRORS \
        PARA_ERROR(OGG_READ, "ogg read error"), \
        PARA_ERROR(SYNC_PAGEOUT, "ogg sync page-out error (no ogg file?)"), \
        PARA_ERROR(STREAM_PAGEIN, "ogg stream page-in error (first page)"), \
@@ -458,8 +458,8 @@ SS_ENUM(OGGDEC);
 SS_ENUM(MP3DEC);
 SS_ENUM(AACDEC);
 SS_ENUM(FILTER);
-SS_ENUM(MP3);
-SS_ENUM(OGG);
+SS_ENUM(MP3_AFH);
+SS_ENUM(OGG_AFH);
 SS_ENUM(AAC_AFH);
 SS_ENUM(AAC_COMMON);
 SS_ENUM(SERVER);
diff --git a/mp3.c b/mp3.c
deleted file mode 100644 (file)
index 4bd8888..0000000
--- a/mp3.c
+++ /dev/null
@@ -1,498 +0,0 @@
-/*
- * Copyright (C) 2003-2006 Andre Noll <maan@systemlinux.org>
- *
- *     This program is free software; you can redistribute it and/or modify
- *     it under the terms of the GNU General Public License as published by
- *     the Free Software Foundation; either version 2 of the License, or
- *     (at your option) any later version.
- *
- *     This program is distributed in the hope that it will be useful,
- *     but WITHOUT ANY WARRANTY; without even the implied warranty of
- *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- *     GNU General Public License for more details.
- *
- *     You should have received a copy of the GNU General Public License
- *     along with this program; if not, write to the Free Software
- *     Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
- */
-
-/** \file mp3.c para_server's mp3 audio format handler */
-
-/*
- * This file is based in part on mp3tech.c and mp3tech.h, Copyright (C)
- * 2000-2001 Cedric Tefft <cedric@earthling.net>, which in turn is based
- * in part on
- *
- *     * MP3Info 0.5 by Ricardo Cerqueira <rmc@rccn.net>
- *     * MP3Stat 0.9 by Ed Sweetman <safemode@voicenet.com> and
- *                      Johannes Overmann <overmann@iname.com>
- */
-
-#include "server.cmdline.h"
-#include "server.h"
-#include "afs.h"
-#include "afh.h"
-#include "error.h"
-#include "fd.h"
-
-/** \cond some defines and structs which are only used in this file */
-
-/*
- * MIN_CONSEC_GOOD_FRAMES defines how many consecutive valid MP3 frames we need
- * to see before we decide we are looking at a real MP3 file
- */
-#define MIN_CONSEC_GOOD_FRAMES 3
-
-#define FRAME_HEADER_SIZE 4
-#define MIN_FRAME_SIZE 21
-
-struct mp3header {
-       unsigned long sync;
-       unsigned int version;
-       unsigned int layer;
-       unsigned int crc;
-       unsigned int bitrate;
-       unsigned int freq;
-       unsigned int padding;
-       unsigned int mode;
-       unsigned int copyright;
-       unsigned int original;
-       unsigned int emphasis;
-};
-
-struct id3tag {
-       char title[31];
-       char artist[31];
-       char album[31];
-       char year[5];
-       char comment[31];
-};
-
-struct mp3info {
-       char *filename;
-       FILE *file;
-       struct mp3header header;
-       int id3_isvalid;
-       struct id3tag id3;
-       int vbr;
-       long unsigned br_average;
-       long unsigned seconds;
-       int frames;
-       int freq;
-};
-
-/** \endcond */
-static int frequencies[3][4] = {
-       {22050,24000,16000,50000}, /* MPEG 2.0 */
-       {44100,48000,32000,50000}, /* MPEG 1.0 */
-       {11025,12000,8000,50000} /* MPEG 2.5 */
-};
-
-static int mp3info_bitrate[2][3][14] = {
-{ /* MPEG 2.0 */
-       {32,48,56,64,80,96,112,128,144,160,176,192,224,256}, /* layer 1 */
-       {8,16,24,32,40,48,56,64,80,96,112,128,144,160}, /* layer 2 */
-       {8,16,24,32,40,48,56,64,80,96,112,128,144,160} /* layer 3 */
-},
-
-{ /* MPEG 1.0 */
-       {32,64,96,128,160,192,224,256,288,320,352,384,416,448}, /* layer 1 */
-       {32,48,56,64,80,96,112,128,160,192,224,256,320,384}, /* layer 2 */
-       {32,40,48,56,64,80,96,112,128,160,192,224,256,320} /* layer 3 */
-}
-};
-
-static int frame_size_index[] = {24000, 72000, 72000};
-static const char *mode_text[] = {"stereo", "joint stereo", "dual channel", "mono", "invalid"};
-
-static struct mp3info mp3;
-static char mp3buf[8192];
-static int chunk_size;
-static struct audio_format_handler *af;
-
-static int header_frequency(struct mp3header *h)
-{
-       if (h->version > 2 || h->freq > 3)
-               return -E_HEADER_FREQ;
-       return frequencies[h->version][h->freq];
-}
-
-static const char *header_mode(struct mp3header *h)
-{
-       if (h->mode > 4)
-               h->mode = 4; /* invalid */
-       return mode_text[h->mode];
-}
-static int header_bitrate(struct mp3header *h)
-{
-       if (h->layer > 3 || h->bitrate > 14)
-               return -E_HEADER_BITRATE;
-       return mp3info_bitrate[h->version & 1][3 - h->layer][h->bitrate - 1];
-}
-
-static int frame_length(struct mp3header *header)
-{
-       int hb, hf = header_frequency(header);
-
-       if (hf < 0)
-               return hf;
-       hb = header_bitrate(header);
-       if (hb < 0)
-               return hb;
-       if (header->sync != 0xFFE || header->layer > 3)
-               return -E_FRAME;
-       return frame_size_index[3 - header->layer] *
-               ((header->version & 1) + 1) * hb / hf
-               + header->padding;
-}
-
-static void write_info_str(char *info_str)
-{
-       int v = mp3.id3_isvalid;
-
-       snprintf(info_str, MMD_INFO_SIZE,
-               "audio_file_info1:%d x %lums, %lu kbit/s (%cbr) %i KHz %s\n"
-               "audio_file_info2:%s, by %s\n"
-               "audio_file_info3:A: %s, Y: %s, C: %s\n",
-               mp3.frames,
-               tv2ms(&af->chunk_tv),
-               mp3.br_average,
-               mp3.vbr? 'v' : 'c',
-               mp3.freq / 1000,
-               header_mode(&mp3.header),
-               v && *mp3.id3.title? mp3.id3.title : "(title tag not set)",
-               v && *mp3.id3.artist? mp3.id3.artist : "(artist tag not set)",
-               v && *mp3.id3.album? mp3.id3.album : "(album tag not set)",
-               v && *mp3.id3.year? mp3.id3.year : "????",
-               v && *mp3.id3.comment? mp3.id3.comment : "(comment tag not set)"
-       );
-}
-
-/*
- * Remove trailing whitespace from the end of a string
- */
-static char *unpad(char *string)
-{
-       char *pos = string + strlen(string) - 1;
-       while (isspace(pos[0]))
-               (pos--)[0] = 0;
-       return string;
-}
-
-static int compare_headers(struct mp3header *h1,struct mp3header *h2)
-{
-       if ((*(uint*)h1) == (*(uint*)h2))
-               return 1;
-       if ((h1->version == h2->version) &&
-                       (h1->layer == h2->layer) &&
-                       (h1->crc == h2->crc) &&
-                       (h1->freq == h2->freq) &&
-                       (h1->mode == h2->mode) &&
-                       (h1->copyright == h2->copyright) &&
-                       (h1->original == h2->original) &&
-                       (h1->emphasis == h2->emphasis))
-               return 1;
-       else
-               return 0;
-}
-
-/**
- * get next MP3 frame header.
- *
- * \param stream to read the header from
- * \param header structure that gets filled in by get_header()
- *
- * \return On success, the header frame length is returned.  A return value of
- * zero means that we did not retrieve a valid frame header, and a negative
- * return value indicates an error.
- */
-static int get_header(FILE *file, struct mp3header *header)
-{
-       unsigned char buffer[FRAME_HEADER_SIZE];
-       int fl, ret;
-
-       if (!file || !header)
-               return -E_MP3_NO_FILE;
-       ret = para_fread(buffer, FRAME_HEADER_SIZE, 1, file);
-       if (ret < FRAME_HEADER_SIZE) {
-               header->sync = 0;
-               return ret < 0? ret : 0;
-       }
-       header->layer = (buffer[1] >> 1) & 3;
-       header->sync = (((int)buffer[0]<<4) | ((int)(buffer[1]&0xE0)>>4));
-       if (buffer[1] & 0x10)
-               header->version = (buffer[1] >> 3) & 1;
-       else
-               header->version = 2;
-       if ((header->sync != 0xFFE) || (header->layer != 1)) {
-               header->sync = 0;
-//             PARA_DEBUG_LOG("%s: header not found\n", __func__);
-               return 0;
-       }
-       header->crc = buffer[1] & 1;
-       header->bitrate = (buffer[2] >> 4) & 0x0F;
-//     PARA_DEBUG_LOG("%s: found header, bitrate: %u\n", __func__,
-//             header->bitrate);
-       header->freq = (buffer[2] >> 2) & 0x3;
-       header->padding = (buffer[2] >>1) & 0x1;
-       header->mode = (buffer[3] >> 6) & 0x3;
-       fl = frame_length(header);
-       return (fl >= MIN_FRAME_SIZE)? fl : -E_FRAME_LENGTH;
-}
-
-/**
- * find the next mp3 header
- *
- * \return On success, the length of the next frame header. If the end of the
- * file was reached, the function returns zero. On errors, a negative value is
- * returned.
- *
- */
-static int mp3_seek_next_header(void)
-{
-       int k, l = 0, c, first_len;
-       struct mp3header h, h2;
-       long valid_start = 0;
-
-       while (1) {
-               while ((c = fgetc(mp3.file)) != 255 && (c != EOF))
-                       ; /* nothing */
-               if (c != 255)
-                       return 0;
-               ungetc(c, mp3.file);
-               valid_start = ftell(mp3.file);
-               first_len = get_header(mp3.file, &h);
-               if (first_len <= 0)
-                       continue;
-               if (fseek(mp3.file, first_len - FRAME_HEADER_SIZE, SEEK_CUR) < 0)
-                       return -E_FSEEK;
-               for (k = 1; k < MIN_CONSEC_GOOD_FRAMES; k++) {
-                       if ((l = get_header(mp3.file, &h2)) <= 0)
-                               break;
-                       if (!compare_headers(&h, &h2))
-                               break;
-                       fseek(mp3.file, l - FRAME_HEADER_SIZE, SEEK_CUR);
-               }
-               if (k == MIN_CONSEC_GOOD_FRAMES) {
-                       fseek(mp3.file, valid_start, SEEK_SET);
-                       memcpy(&(mp3.header), &h2, sizeof(struct mp3header));
-                       return first_len;
-               }
-       }
-}
-
-static int mp3_get_id3(void)
-{
-       char fbuf[4];
-
-       mp3.id3_isvalid = 0;
-       mp3.id3.title[0] = '\0';
-       mp3.id3.artist[0] = '\0';
-       mp3.id3.album[0] = '\0';
-       mp3.id3.comment[0] = '\0';
-       mp3.id3.year[0] = '\0';
-       if (fseek(mp3.file, -128, SEEK_END))
-               return -E_FSEEK;
-       if (para_fread(fbuf, 1, 3, mp3.file) < 0)
-               return -E_FREAD;
-       fbuf[3] = '\0';
-       if (strcmp("TAG", fbuf)) {
-               PARA_INFO_LOG("%s", "no id3 tag\n");
-               return 0;
-       }
-       if (fseek(mp3.file, -125, SEEK_END) < 0)
-               return -E_FSEEK;
-       if (para_fread(mp3.id3.title, 1, 30, mp3.file) != 30)
-               return -E_FREAD;
-       mp3.id3.title[30] = '\0';
-       if (para_fread(mp3.id3.artist, 1, 30, mp3.file) != 30)
-               return -E_FREAD;
-       mp3.id3.artist[30] = '\0';
-       if (para_fread(mp3.id3.album, 1, 30, mp3.file) != 30)
-               return -E_FREAD;
-       mp3.id3.album[30] = '\0';
-       if (para_fread(mp3.id3.year, 1, 4, mp3.file) != 4)
-               return -E_FREAD;
-       mp3.id3.year[4] = '\0';
-       if (para_fread(mp3.id3.comment, 1, 30, mp3.file) != 30)
-               return -E_FREAD;
-       mp3.id3.comment[30] = '\0';
-       mp3.id3_isvalid = 1;
-       unpad(mp3.id3.title);
-       unpad(mp3.id3.artist);
-       unpad(mp3.id3.album);
-       unpad(mp3.id3.year);
-       unpad(mp3.id3.comment);
-       return 1;
-}
-
-static int find_valid_start(void)
-{
-       int frame_len;
-
-       if (!mp3.file)
-               return -E_MP3_NO_FILE;
-       frame_len = get_header(mp3.file, &mp3.header);
-       if (frame_len < 0)
-               return frame_len;
-       if (!frame_len) {
-               frame_len = mp3_seek_next_header();
-               if (frame_len <= 0)
-                       return frame_len;
-       } else
-               if (fseek(mp3.file, -FRAME_HEADER_SIZE, SEEK_CUR) < 0)
-                       return -E_FSEEK;
-       if (frame_len <= 1) /* FRAME_HEADER_SIZE? */
-               return -E_FRAME_LENGTH;
-       return frame_len;
-}
-
-static int mp3_read_info(void)
-{
-       long fl_avg = 0, freq_avg = 0, br_avg = 0, fcount = 0;
-       int ret, len = 0, old_br = -1;
-       struct timeval total_time = {0, 0};
-
-       ret = mp3_get_id3();
-       if (ret < 0)
-               return ret;
-       rewind(mp3.file);
-       mp3.vbr = 0;
-       mp3.freq = 0;
-       while (1) {
-               int freq, br, fl;
-               struct timeval tmp, cct; /* current chunk time */
-               if (len > 0)
-                       if (fseek(mp3.file, len, SEEK_CUR) < 0)
-                               return -E_FSEEK;
-               len = find_valid_start();
-               if (len <= 0)
-                       break;
-               freq = header_frequency(&mp3.header);
-               br = header_bitrate(&mp3.header);
-               fl = frame_length(&mp3.header);
-               if (freq < 0 || br < 0 || fl < 0)
-                       continue;
-               tmp.tv_sec = fl;
-               tmp.tv_usec = 0;
-               tv_divide(br * 125, &tmp, &cct);
-               tv_add(&cct, &total_time, &tmp);
-               total_time = tmp;
-//             PARA_DEBUG_LOG("%s: br: %d, freq: %d, fl: %d, cct: %lu\n", __func__, br, freq, fl, cct.tv_usec);
-               fcount++;
-               if (fcount == 1) {
-                       freq_avg = freq;
-                       br_avg = br;
-                       old_br = br;
-                       fl_avg = fl;
-                       continue;
-               }
-               freq_avg += (freq - freq_avg) / (fcount + 1);
-               fl_avg += (fl - fl_avg) / (fcount + 1);
-               br_avg += (br - br_avg) / (fcount + 1);
-               if (old_br != br)
-                       mp3.vbr = 1;
-               old_br = br;
-       }
-       if (!fcount || !freq_avg || !br_avg)
-               return -E_MP3_INFO;
-       mp3.br_average = br_avg;
-       mp3.freq = freq_avg;
-       mp3.frames = fcount;
-       mp3.seconds = (tv2ms(&total_time) + 500) / 1000;
-       tv_divide(fcount, &total_time, &af->chunk_tv);
-       rewind(mp3.file);
-       PARA_DEBUG_LOG("chunk_time: %lums\n", tv2ms(&af->chunk_tv));
-       tv_scale(30, &af->chunk_tv, &af->eof_tv);
-       PARA_DEBUG_LOG("eof timeout: %lu\n", tv2ms(&af->eof_tv));
-       return 1;
-}
-
-/*
- * Read mp3 information from audio file
- */
-static int mp3_get_file_info(FILE *audio_file, char *info_str,
-       long unsigned *frames, int *seconds)
-{
-       int ret;
-
-       if (!audio_file)
-               return -E_MP3_NO_FILE;
-       mp3.file = audio_file;
-       ret = mp3_read_info();
-       if (ret < 0) {
-               mp3.file = NULL;
-               return ret;
-       }
-       write_info_str(info_str);
-       *frames = mp3.frames;
-       *seconds = mp3.seconds;
-       if (*seconds < 2 || !*frames)
-               return -E_MP3_INFO;
-       return 1;
-}
-
-static int mp3_reposition_stream(long unsigned new_frame)
-{
-       int count = 0, len;
-
-       PARA_DEBUG_LOG("jmp to frame %lu/%i\n", new_frame, mp3.frames);
-       rewind(mp3.file);
-       while (count < new_frame && (len = find_valid_start()) > 0) {
-//             PARA_DEBUG_LOG("%s: jmp to frame %d\n", __func__, count);
-               if (fseek(mp3.file, len, SEEK_CUR) < 0)
-                       return -E_FSEEK;
-               count++;
-       }
-       if (count != new_frame) {
-               rewind(mp3.file);
-               return -E_MP3_REPOS;
-       }
-       return 1;
-}
-
-static int mp3_read_next_chunk(void)
-{
-       int len = find_valid_start();
-
-       if (len <= 0) {
-               if (len < 0)
-                       PARA_ERROR_LOG("invalid frame len (%d)\n", len);
-               return len;
-       }
-       chunk_size = para_fread(mp3buf, len, 1, mp3.file);
-       if (len != chunk_size)
-               PARA_DEBUG_LOG("short read (%d/%d)\n", chunk_size, len);
-       return chunk_size;
-}
-
-static char *mp3_read_chunk(__a_unused long unsigned chunk_num, ssize_t *len)
-{
-       *len = mp3_read_next_chunk();
-       if (*len <= 0)
-               return NULL;
-       return mp3buf;
-}
-
-static void mp3_close_audio_file(void)
-{
-       if (!mp3.file)
-               return;
-       fclose(mp3.file);
-       mp3.file = NULL;
-}
-
-static const char* mp3_suffixes[] = {"mp3", NULL};
-void mp3_init(struct audio_format_handler *p)
-{
-       af = p;
-       af->get_file_info = mp3_get_file_info;
-       af->reposition_stream = mp3_reposition_stream;
-       af->read_chunk = mp3_read_chunk;
-       af->close_audio_file = mp3_close_audio_file;
-       af->get_header_info = NULL;
-       /* eof_tv gets overwritten in mp3_get_file_info() */
-       af->eof_tv.tv_sec = 0;
-       af->eof_tv.tv_usec = 100 * 1000;
-       af->suffixes = mp3_suffixes;
-}
diff --git a/mp3_afh.c b/mp3_afh.c
new file mode 100644 (file)
index 0000000..4bd8888
--- /dev/null
+++ b/mp3_afh.c
@@ -0,0 +1,498 @@
+/*
+ * Copyright (C) 2003-2006 Andre Noll <maan@systemlinux.org>
+ *
+ *     This program is free software; you can redistribute it and/or modify
+ *     it under the terms of the GNU General Public License as published by
+ *     the Free Software Foundation; either version 2 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU General Public License for more details.
+ *
+ *     You should have received a copy of the GNU General Public License
+ *     along with this program; if not, write to the Free Software
+ *     Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
+ */
+
+/** \file mp3.c para_server's mp3 audio format handler */
+
+/*
+ * This file is based in part on mp3tech.c and mp3tech.h, Copyright (C)
+ * 2000-2001 Cedric Tefft <cedric@earthling.net>, which in turn is based
+ * in part on
+ *
+ *     * MP3Info 0.5 by Ricardo Cerqueira <rmc@rccn.net>
+ *     * MP3Stat 0.9 by Ed Sweetman <safemode@voicenet.com> and
+ *                      Johannes Overmann <overmann@iname.com>
+ */
+
+#include "server.cmdline.h"
+#include "server.h"
+#include "afs.h"
+#include "afh.h"
+#include "error.h"
+#include "fd.h"
+
+/** \cond some defines and structs which are only used in this file */
+
+/*
+ * MIN_CONSEC_GOOD_FRAMES defines how many consecutive valid MP3 frames we need
+ * to see before we decide we are looking at a real MP3 file
+ */
+#define MIN_CONSEC_GOOD_FRAMES 3
+
+#define FRAME_HEADER_SIZE 4
+#define MIN_FRAME_SIZE 21
+
+struct mp3header {
+       unsigned long sync;
+       unsigned int version;
+       unsigned int layer;
+       unsigned int crc;
+       unsigned int bitrate;
+       unsigned int freq;
+       unsigned int padding;
+       unsigned int mode;
+       unsigned int copyright;
+       unsigned int original;
+       unsigned int emphasis;
+};
+
+struct id3tag {
+       char title[31];
+       char artist[31];
+       char album[31];
+       char year[5];
+       char comment[31];
+};
+
+struct mp3info {
+       char *filename;
+       FILE *file;
+       struct mp3header header;
+       int id3_isvalid;
+       struct id3tag id3;
+       int vbr;
+       long unsigned br_average;
+       long unsigned seconds;
+       int frames;
+       int freq;
+};
+
+/** \endcond */
+static int frequencies[3][4] = {
+       {22050,24000,16000,50000}, /* MPEG 2.0 */
+       {44100,48000,32000,50000}, /* MPEG 1.0 */
+       {11025,12000,8000,50000} /* MPEG 2.5 */
+};
+
+static int mp3info_bitrate[2][3][14] = {
+{ /* MPEG 2.0 */
+       {32,48,56,64,80,96,112,128,144,160,176,192,224,256}, /* layer 1 */
+       {8,16,24,32,40,48,56,64,80,96,112,128,144,160}, /* layer 2 */
+       {8,16,24,32,40,48,56,64,80,96,112,128,144,160} /* layer 3 */
+},
+
+{ /* MPEG 1.0 */
+       {32,64,96,128,160,192,224,256,288,320,352,384,416,448}, /* layer 1 */
+       {32,48,56,64,80,96,112,128,160,192,224,256,320,384}, /* layer 2 */
+       {32,40,48,56,64,80,96,112,128,160,192,224,256,320} /* layer 3 */
+}
+};
+
+static int frame_size_index[] = {24000, 72000, 72000};
+static const char *mode_text[] = {"stereo", "joint stereo", "dual channel", "mono", "invalid"};
+
+static struct mp3info mp3;
+static char mp3buf[8192];
+static int chunk_size;
+static struct audio_format_handler *af;
+
+static int header_frequency(struct mp3header *h)
+{
+       if (h->version > 2 || h->freq > 3)
+               return -E_HEADER_FREQ;
+       return frequencies[h->version][h->freq];
+}
+
+static const char *header_mode(struct mp3header *h)
+{
+       if (h->mode > 4)
+               h->mode = 4; /* invalid */
+       return mode_text[h->mode];
+}
+static int header_bitrate(struct mp3header *h)
+{
+       if (h->layer > 3 || h->bitrate > 14)
+               return -E_HEADER_BITRATE;
+       return mp3info_bitrate[h->version & 1][3 - h->layer][h->bitrate - 1];
+}
+
+static int frame_length(struct mp3header *header)
+{
+       int hb, hf = header_frequency(header);
+
+       if (hf < 0)
+               return hf;
+       hb = header_bitrate(header);
+       if (hb < 0)
+               return hb;
+       if (header->sync != 0xFFE || header->layer > 3)
+               return -E_FRAME;
+       return frame_size_index[3 - header->layer] *
+               ((header->version & 1) + 1) * hb / hf
+               + header->padding;
+}
+
+static void write_info_str(char *info_str)
+{
+       int v = mp3.id3_isvalid;
+
+       snprintf(info_str, MMD_INFO_SIZE,
+               "audio_file_info1:%d x %lums, %lu kbit/s (%cbr) %i KHz %s\n"
+               "audio_file_info2:%s, by %s\n"
+               "audio_file_info3:A: %s, Y: %s, C: %s\n",
+               mp3.frames,
+               tv2ms(&af->chunk_tv),
+               mp3.br_average,
+               mp3.vbr? 'v' : 'c',
+               mp3.freq / 1000,
+               header_mode(&mp3.header),
+               v && *mp3.id3.title? mp3.id3.title : "(title tag not set)",
+               v && *mp3.id3.artist? mp3.id3.artist : "(artist tag not set)",
+               v && *mp3.id3.album? mp3.id3.album : "(album tag not set)",
+               v && *mp3.id3.year? mp3.id3.year : "????",
+               v && *mp3.id3.comment? mp3.id3.comment : "(comment tag not set)"
+       );
+}
+
+/*
+ * Remove trailing whitespace from the end of a string
+ */
+static char *unpad(char *string)
+{
+       char *pos = string + strlen(string) - 1;
+       while (isspace(pos[0]))
+               (pos--)[0] = 0;
+       return string;
+}
+
+static int compare_headers(struct mp3header *h1,struct mp3header *h2)
+{
+       if ((*(uint*)h1) == (*(uint*)h2))
+               return 1;
+       if ((h1->version == h2->version) &&
+                       (h1->layer == h2->layer) &&
+                       (h1->crc == h2->crc) &&
+                       (h1->freq == h2->freq) &&
+                       (h1->mode == h2->mode) &&
+                       (h1->copyright == h2->copyright) &&
+                       (h1->original == h2->original) &&
+                       (h1->emphasis == h2->emphasis))
+               return 1;
+       else
+               return 0;
+}
+
+/**
+ * get next MP3 frame header.
+ *
+ * \param stream to read the header from
+ * \param header structure that gets filled in by get_header()
+ *
+ * \return On success, the header frame length is returned.  A return value of
+ * zero means that we did not retrieve a valid frame header, and a negative
+ * return value indicates an error.
+ */
+static int get_header(FILE *file, struct mp3header *header)
+{
+       unsigned char buffer[FRAME_HEADER_SIZE];
+       int fl, ret;
+
+       if (!file || !header)
+               return -E_MP3_NO_FILE;
+       ret = para_fread(buffer, FRAME_HEADER_SIZE, 1, file);
+       if (ret < FRAME_HEADER_SIZE) {
+               header->sync = 0;
+               return ret < 0? ret : 0;
+       }
+       header->layer = (buffer[1] >> 1) & 3;
+       header->sync = (((int)buffer[0]<<4) | ((int)(buffer[1]&0xE0)>>4));
+       if (buffer[1] & 0x10)
+               header->version = (buffer[1] >> 3) & 1;
+       else
+               header->version = 2;
+       if ((header->sync != 0xFFE) || (header->layer != 1)) {
+               header->sync = 0;
+//             PARA_DEBUG_LOG("%s: header not found\n", __func__);
+               return 0;
+       }
+       header->crc = buffer[1] & 1;
+       header->bitrate = (buffer[2] >> 4) & 0x0F;
+//     PARA_DEBUG_LOG("%s: found header, bitrate: %u\n", __func__,
+//             header->bitrate);
+       header->freq = (buffer[2] >> 2) & 0x3;
+       header->padding = (buffer[2] >>1) & 0x1;
+       header->mode = (buffer[3] >> 6) & 0x3;
+       fl = frame_length(header);
+       return (fl >= MIN_FRAME_SIZE)? fl : -E_FRAME_LENGTH;
+}
+
+/**
+ * find the next mp3 header
+ *
+ * \return On success, the length of the next frame header. If the end of the
+ * file was reached, the function returns zero. On errors, a negative value is
+ * returned.
+ *
+ */
+static int mp3_seek_next_header(void)
+{
+       int k, l = 0, c, first_len;
+       struct mp3header h, h2;
+       long valid_start = 0;
+
+       while (1) {
+               while ((c = fgetc(mp3.file)) != 255 && (c != EOF))
+                       ; /* nothing */
+               if (c != 255)
+                       return 0;
+               ungetc(c, mp3.file);
+               valid_start = ftell(mp3.file);
+               first_len = get_header(mp3.file, &h);
+               if (first_len <= 0)
+                       continue;
+               if (fseek(mp3.file, first_len - FRAME_HEADER_SIZE, SEEK_CUR) < 0)
+                       return -E_FSEEK;
+               for (k = 1; k < MIN_CONSEC_GOOD_FRAMES; k++) {
+                       if ((l = get_header(mp3.file, &h2)) <= 0)
+                               break;
+                       if (!compare_headers(&h, &h2))
+                               break;
+                       fseek(mp3.file, l - FRAME_HEADER_SIZE, SEEK_CUR);
+               }
+               if (k == MIN_CONSEC_GOOD_FRAMES) {
+                       fseek(mp3.file, valid_start, SEEK_SET);
+                       memcpy(&(mp3.header), &h2, sizeof(struct mp3header));
+                       return first_len;
+               }
+       }
+}
+
+static int mp3_get_id3(void)
+{
+       char fbuf[4];
+
+       mp3.id3_isvalid = 0;
+       mp3.id3.title[0] = '\0';
+       mp3.id3.artist[0] = '\0';
+       mp3.id3.album[0] = '\0';
+       mp3.id3.comment[0] = '\0';
+       mp3.id3.year[0] = '\0';
+       if (fseek(mp3.file, -128, SEEK_END))
+               return -E_FSEEK;
+       if (para_fread(fbuf, 1, 3, mp3.file) < 0)
+               return -E_FREAD;
+       fbuf[3] = '\0';
+       if (strcmp("TAG", fbuf)) {
+               PARA_INFO_LOG("%s", "no id3 tag\n");
+               return 0;
+       }
+       if (fseek(mp3.file, -125, SEEK_END) < 0)
+               return -E_FSEEK;
+       if (para_fread(mp3.id3.title, 1, 30, mp3.file) != 30)
+               return -E_FREAD;
+       mp3.id3.title[30] = '\0';
+       if (para_fread(mp3.id3.artist, 1, 30, mp3.file) != 30)
+               return -E_FREAD;
+       mp3.id3.artist[30] = '\0';
+       if (para_fread(mp3.id3.album, 1, 30, mp3.file) != 30)
+               return -E_FREAD;
+       mp3.id3.album[30] = '\0';
+       if (para_fread(mp3.id3.year, 1, 4, mp3.file) != 4)
+               return -E_FREAD;
+       mp3.id3.year[4] = '\0';
+       if (para_fread(mp3.id3.comment, 1, 30, mp3.file) != 30)
+               return -E_FREAD;
+       mp3.id3.comment[30] = '\0';
+       mp3.id3_isvalid = 1;
+       unpad(mp3.id3.title);
+       unpad(mp3.id3.artist);
+       unpad(mp3.id3.album);
+       unpad(mp3.id3.year);
+       unpad(mp3.id3.comment);
+       return 1;
+}
+
+static int find_valid_start(void)
+{
+       int frame_len;
+
+       if (!mp3.file)
+               return -E_MP3_NO_FILE;
+       frame_len = get_header(mp3.file, &mp3.header);
+       if (frame_len < 0)
+               return frame_len;
+       if (!frame_len) {
+               frame_len = mp3_seek_next_header();
+               if (frame_len <= 0)
+                       return frame_len;
+       } else
+               if (fseek(mp3.file, -FRAME_HEADER_SIZE, SEEK_CUR) < 0)
+                       return -E_FSEEK;
+       if (frame_len <= 1) /* FRAME_HEADER_SIZE? */
+               return -E_FRAME_LENGTH;
+       return frame_len;
+}
+
+static int mp3_read_info(void)
+{
+       long fl_avg = 0, freq_avg = 0, br_avg = 0, fcount = 0;
+       int ret, len = 0, old_br = -1;
+       struct timeval total_time = {0, 0};
+
+       ret = mp3_get_id3();
+       if (ret < 0)
+               return ret;
+       rewind(mp3.file);
+       mp3.vbr = 0;
+       mp3.freq = 0;
+       while (1) {
+               int freq, br, fl;
+               struct timeval tmp, cct; /* current chunk time */
+               if (len > 0)
+                       if (fseek(mp3.file, len, SEEK_CUR) < 0)
+                               return -E_FSEEK;
+               len = find_valid_start();
+               if (len <= 0)
+                       break;
+               freq = header_frequency(&mp3.header);
+               br = header_bitrate(&mp3.header);
+               fl = frame_length(&mp3.header);
+               if (freq < 0 || br < 0 || fl < 0)
+                       continue;
+               tmp.tv_sec = fl;
+               tmp.tv_usec = 0;
+               tv_divide(br * 125, &tmp, &cct);
+               tv_add(&cct, &total_time, &tmp);
+               total_time = tmp;
+//             PARA_DEBUG_LOG("%s: br: %d, freq: %d, fl: %d, cct: %lu\n", __func__, br, freq, fl, cct.tv_usec);
+               fcount++;
+               if (fcount == 1) {
+                       freq_avg = freq;
+                       br_avg = br;
+                       old_br = br;
+                       fl_avg = fl;
+                       continue;
+               }
+               freq_avg += (freq - freq_avg) / (fcount + 1);
+               fl_avg += (fl - fl_avg) / (fcount + 1);
+               br_avg += (br - br_avg) / (fcount + 1);
+               if (old_br != br)
+                       mp3.vbr = 1;
+               old_br = br;
+       }
+       if (!fcount || !freq_avg || !br_avg)
+               return -E_MP3_INFO;
+       mp3.br_average = br_avg;
+       mp3.freq = freq_avg;
+       mp3.frames = fcount;
+       mp3.seconds = (tv2ms(&total_time) + 500) / 1000;
+       tv_divide(fcount, &total_time, &af->chunk_tv);
+       rewind(mp3.file);
+       PARA_DEBUG_LOG("chunk_time: %lums\n", tv2ms(&af->chunk_tv));
+       tv_scale(30, &af->chunk_tv, &af->eof_tv);
+       PARA_DEBUG_LOG("eof timeout: %lu\n", tv2ms(&af->eof_tv));
+       return 1;
+}
+
+/*
+ * Read mp3 information from audio file
+ */
+static int mp3_get_file_info(FILE *audio_file, char *info_str,
+       long unsigned *frames, int *seconds)
+{
+       int ret;
+
+       if (!audio_file)
+               return -E_MP3_NO_FILE;
+       mp3.file = audio_file;
+       ret = mp3_read_info();
+       if (ret < 0) {
+               mp3.file = NULL;
+               return ret;
+       }
+       write_info_str(info_str);
+       *frames = mp3.frames;
+       *seconds = mp3.seconds;
+       if (*seconds < 2 || !*frames)
+               return -E_MP3_INFO;
+       return 1;
+}
+
+static int mp3_reposition_stream(long unsigned new_frame)
+{
+       int count = 0, len;
+
+       PARA_DEBUG_LOG("jmp to frame %lu/%i\n", new_frame, mp3.frames);
+       rewind(mp3.file);
+       while (count < new_frame && (len = find_valid_start()) > 0) {
+//             PARA_DEBUG_LOG("%s: jmp to frame %d\n", __func__, count);
+               if (fseek(mp3.file, len, SEEK_CUR) < 0)
+                       return -E_FSEEK;
+               count++;
+       }
+       if (count != new_frame) {
+               rewind(mp3.file);
+               return -E_MP3_REPOS;
+       }
+       return 1;
+}
+
+static int mp3_read_next_chunk(void)
+{
+       int len = find_valid_start();
+
+       if (len <= 0) {
+               if (len < 0)
+                       PARA_ERROR_LOG("invalid frame len (%d)\n", len);
+               return len;
+       }
+       chunk_size = para_fread(mp3buf, len, 1, mp3.file);
+       if (len != chunk_size)
+               PARA_DEBUG_LOG("short read (%d/%d)\n", chunk_size, len);
+       return chunk_size;
+}
+
+static char *mp3_read_chunk(__a_unused long unsigned chunk_num, ssize_t *len)
+{
+       *len = mp3_read_next_chunk();
+       if (*len <= 0)
+               return NULL;
+       return mp3buf;
+}
+
+static void mp3_close_audio_file(void)
+{
+       if (!mp3.file)
+               return;
+       fclose(mp3.file);
+       mp3.file = NULL;
+}
+
+static const char* mp3_suffixes[] = {"mp3", NULL};
+void mp3_init(struct audio_format_handler *p)
+{
+       af = p;
+       af->get_file_info = mp3_get_file_info;
+       af->reposition_stream = mp3_reposition_stream;
+       af->read_chunk = mp3_read_chunk;
+       af->close_audio_file = mp3_close_audio_file;
+       af->get_header_info = NULL;
+       /* eof_tv gets overwritten in mp3_get_file_info() */
+       af->eof_tv.tv_sec = 0;
+       af->eof_tv.tv_usec = 100 * 1000;
+       af->suffixes = mp3_suffixes;
+}
diff --git a/ogg.c b/ogg.c
deleted file mode 100644 (file)
index 3445970..0000000
--- a/ogg.c
+++ /dev/null
@@ -1,362 +0,0 @@
-/*
- * Copyright (C) 2004-2006 Andre Noll <maan@systemlinux.org>
- *
- *     This program is free software; you can redistribute it and/or modify
- *     it under the terms of the GNU General Public License as published by
- *     the Free Software Foundation; either version 2 of the License, or
- *     (at your option) any later version.
- *
- *     This program is distributed in the hope that it will be useful,
- *     but WITHOUT ANY WARRANTY; without even the implied warranty of
- *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- *     GNU General Public License for more details.
- *
- *     You should have received a copy of the GNU General Public License
- *     along with this program; if not, write to the Free Software
- *     Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
- */
-/** \file ogg.c para_server's ogg vorbis audio format handler */
-
-#include <ogg/ogg.h>
-#include <vorbis/codec.h>
-#include <vorbis/vorbisfile.h>
-
-#include "server.cmdline.h"
-#include "server.h"
-#include "afs.h"
-#include "afh.h"
-#include "error.h"
-#include "string.h"
-
-/* must be big enough to hold header */
-#define CHUNK_SIZE 32768
-static double chunk_time = 0.25;
-
-static OggVorbis_File *oggvorbis_file;
-static FILE *infile;
-static int header_len, oggbuf_len, vi_channels;
-static char *header, *oggbuf;
-static ssize_t *chunk_table, max_chunk_len;
-struct audio_format_handler *af;
-static long vi_sampling_rate, vi_bitrate, vi_bitrate_nominal,
-       num_chunks;
-
-static int ogg_compute_header_len(void)
-{
-       int ret, len, in = fileno(infile);
-       unsigned int serial;
-       char *buf;
-       ogg_page page;
-       ogg_packet packet;
-       vorbis_comment vc;
-       vorbis_info vi;
-       ogg_stream_state *stream_in = para_malloc(sizeof(ogg_stream_state));
-       ogg_stream_state *stream_out = para_malloc(sizeof(ogg_stream_state));
-       ogg_sync_state *sync_in = para_malloc(sizeof(ogg_sync_state));
-
-       ogg_sync_init(sync_in);
-       vorbis_info_init(&vi);
-       vorbis_comment_init(&vc);
-       buf = ogg_sync_buffer(sync_in, CHUNK_SIZE);
-       len = read(in, buf, CHUNK_SIZE);
-       ret = -E_OGG_READ;
-       if (len <= 0)
-               goto err1;
-       ogg_sync_wrote(sync_in, len);
-       ret = -E_SYNC_PAGEOUT;
-       if (ogg_sync_pageout(sync_in, &page) <= 0)
-               goto err1;
-       serial = ogg_page_serialno(&page);
-       ogg_stream_init(stream_in, serial);
-       ogg_stream_init(stream_out, serial);
-       ret = ogg_stream_pagein(stream_in, &page);
-       if (ret < 0) {
-               ret = E_STREAM_PAGEIN;
-               goto err2;
-       }
-       ret = ogg_stream_packetout(stream_in, &packet);
-       if (ret != 1) {
-               ret = -E_STREAM_PACKETOUT;
-               goto err2;
-       }
-       ret = -E_VORBIS;
-       if (vorbis_synthesis_headerin(&vi, &vc, &packet) < 0) {
-               goto err2;
-       } else
-               PARA_INFO_LOG("channels: %i, rate: %li\n", vi.channels,
-                       vi.rate);
-       ogg_stream_packetin(stream_out, &packet);
-
-       ret = ogg_sync_pageout(sync_in, &page);
-       if (ret <= 0) {
-               ret = -E_SYNC_PAGEOUT;
-               goto err2;
-       }
-       ogg_stream_pagein(stream_in, &page);
-       ogg_stream_packetout(stream_in, &packet);
-       ogg_stream_packetin(stream_out, &packet);
-
-       ret = ogg_sync_pageout(sync_in, &page);
-       if (ret <= 0) {
-               ret = -E_SYNC_PAGEOUT;
-               goto err2;
-       }
-       ogg_stream_pagein(stream_in, &page);
-       ogg_stream_packetout(stream_in, &packet);
-       ogg_stream_packetin(stream_out, &packet);
-
-       header_len = 0;
-       while (ogg_stream_flush(stream_out, &page))
-               header_len += page.body_len + page.header_len;
-       ret = len;
-       PARA_INFO_LOG("header_len = %d\n", header_len);
-err2:
-       ogg_stream_destroy(stream_in);
-       ogg_stream_destroy(stream_out);
-err1:
-       ogg_sync_destroy(sync_in);
-       vorbis_info_clear(&vi);
-        vorbis_comment_clear(&vc);
-       return ret;
-}
-
-static void tunetable(void)
-{
-       int i = 1, j = -1, lp = 1;
-       while (i < num_chunks) {
-               if (chunk_table[i] == chunk_table[lp]) {
-                       i++;
-                       continue;
-               }
-               if (j < 0)
-                       tv_scale(i + 2, &af->chunk_tv, &af->eof_tv);
-               for (j = lp; j < i; j++)
-                       chunk_table[j] = chunk_table[i];
-               lp = i;
-       }
-#if 1
-       for (i = 2; i < num_chunks; i++)
-               if (chunk_table[i] != chunk_table[1])
-                       break;
-       lp = i;
-       for (i = 2; i < num_chunks - lp; i++)
-               chunk_table[i] = chunk_table[i + lp];
-#endif 
-}
-
-
-/*
- * Alloc and fill array table of byte offsets. chunk_table[i] is the
- * offset in the current infile at which the sample containing time i *
- * CHUNK_TIME begins.
- */
-static void ogg_compute_chunk_table(double time_total)
-{
-       int i, ret, num;
-       ssize_t pos = 0, min = 0, old_pos;
-
-       old_pos = 0;
-       ret = 0;
-       num = time_total / chunk_time + 3;
-       PARA_DEBUG_LOG("chunk time: %g allocating %d chunk pointers\n",
-               chunk_time, num);
-       chunk_table = para_malloc(num * sizeof(ogg_int64_t));
-       chunk_table[0] = 0;
-       max_chunk_len = 0;
-       rewind(infile);
-       for (i = 1; ret == 0; i++) {
-               ogg_int64_t diff;
-               ret = ov_time_seek(oggvorbis_file, i * chunk_time);
-               if (ret)
-                       break;
-               pos = ov_raw_tell(oggvorbis_file);
-               diff = pos - old_pos;
-               max_chunk_len = PARA_MAX(max_chunk_len, diff);
-               min = (i == 1)? diff : PARA_MIN(min, diff);
-               chunk_table[i] = pos;
-               if (i < 11 || !((i - 1) % 1000)|| i > num - 11)
-                       PARA_DEBUG_LOG("chunk #%d: %g secs, pos: %zd, "
-                               "size: %zd\n", i - 1,
-                               i * chunk_time, pos, pos - old_pos);
-               old_pos = pos;
-       }
-       num_chunks = i - 1;
-       chunk_table[i] = pos;
-       tunetable();
-       PARA_INFO_LOG("%li chunks (%fs), max chunk: %zd, min chunk: %zd\n",
-               num_chunks, chunk_time, max_chunk_len, min);
-       rewind(infile);
-}
-
-static void ogg_close_audio_file(void)
-{
-       if (oggvorbis_file) {
-               PARA_DEBUG_LOG("%s", "ov_clear\n");
-               ov_clear(oggvorbis_file);
-               free(oggvorbis_file);
-               oggvorbis_file = NULL;
-       }
-       free(header);
-       header = NULL;
-       header_len = 0;
-       free(chunk_table);
-       chunk_table = NULL;
-       num_chunks = 0;
-       free(oggbuf);
-       oggbuf = NULL;
-       oggbuf_len = 0;
-}
-
-static int ogg_save_header(FILE *file, int header_len)
-{
-       int ret;
-
-       header = para_malloc(header_len);
-       rewind(file);
-       ret = read(fileno(file), header, header_len);
-       if (ret != header_len)
-               return -E_OGG_READ;
-       return 1;
-}
-
-/*
- * Init oggvorbis file and write some tech data to given pointers.
- */
-static int ogg_get_file_info(FILE *file, char *info_str, long unsigned *frames,
-       int *seconds)
-{
-       int ret;
-       double time_total;
-       vorbis_info *vi;
-       ogg_int64_t raw_total;
-
-       infile = file;
-       if (!file)
-               return -E_OGG_NO_FILE;
-       ret = ogg_compute_header_len();
-       if (ret < 0)
-               return ret;
-       ret = ogg_save_header(file, header_len);
-       if (ret < 0)
-               return ret;
-       rewind(file);
-       oggvorbis_file = para_malloc(sizeof(OggVorbis_File));
-       ret = ov_open(file, oggvorbis_file, NULL, 0);
-       if (ret < 0) {
-               free(oggvorbis_file);
-               free(header);
-               return -E_OGG_OPEN;
-       }
-       ret = -E_OGG_INFO;
-       vi = ov_info(oggvorbis_file, 0);
-       if (!vi)
-               goto err;
-       time_total = ov_time_total(oggvorbis_file, -1);
-       raw_total = ov_raw_total(oggvorbis_file, -1);
-       *seconds = time_total;
-       vi_sampling_rate = vi->rate;
-       vi_bitrate = ov_bitrate(oggvorbis_file, 0);
-       vi_bitrate_nominal = vi->bitrate_nominal;
-       vi_channels = vi->channels;
-       ogg_compute_chunk_table(time_total);
-       *frames = num_chunks;
-       sprintf(info_str, "audio_file_info1:%lu x %lu, %ldkHz, %d channels, %ldkbps\n"
-               "audio_file_info2: \n"
-               "audio_file_info3: \n",
-               num_chunks, (long unsigned) (chunk_time * 1000 * 1000),
-               vi_sampling_rate / 1000, vi_channels, vi_bitrate / 1000
-               );
-       rewind(file);
-       return 1;
-err:
-       ogg_close_audio_file();
-       return ret;
-}
-
-/*
- * Simple stream reposition routine
- */
-static int ogg_reposition_stream(long unsigned request)
-{
-       int ret;
-       long seek;
-
-       seek = chunk_table[request];
-       ret = fseek(infile, seek, SEEK_SET);
-       PARA_DEBUG_LOG("seek to %li returned %d. offset:%li\n", seek,
-               ret, ftell(infile));
-       return ret < 0? -E_OGG_REPOS : 1;
-}
-
-static ogg_int64_t get_chunk_size(long unsigned chunk_num)
-{
-       ogg_int64_t ret;
-       if (chunk_num >= num_chunks)
-               return -1;
-       ret = chunk_table[chunk_num + 1] - chunk_table[chunk_num];
-       if (!ret)
-               return ret;
-#if 0
-       PARA_DEBUG_LOG("chunk %d: %lli-%lli (%lli bytes)\n",
-               chunk_num,
-               chunk_table[chunk_num],
-               chunk_table[chunk_num + 1] - 1,
-               ret);
-#endif
-       return ret;
-}
-
-char *ogg_read_chunk(long unsigned current_chunk, ssize_t *len)
-{
-       int ret;
-       ogg_int64_t cs = get_chunk_size(current_chunk);
-       if (!cs) { /* nothing to send for this run */
-               *len = 0;
-               return oggbuf;
-       }
-       if (cs < 0) { /* eof */
-               *len = 0;
-               return NULL;
-       }
-       *len = cs;
-       if (!oggbuf || oggbuf_len < *len) {
-               PARA_INFO_LOG("increasing ogg buffer size (%d -> %zu)\n",
-                       oggbuf_len, *len);
-               oggbuf = para_realloc(oggbuf, *len);
-               oggbuf_len = *len;
-       }
-       ret = read(fileno(infile), oggbuf, *len);
-       if (!ret) {
-               *len = 0;
-               return NULL;
-       }
-       if (ret < 0) {
-               *len = -E_OGG_READ;
-               return NULL;
-       }
-       if (ret != *len)
-               PARA_WARNING_LOG("short read (%d/%zd)\n", ret, *len);
-       *len = ret;
-       return oggbuf;
-}
-
-static char *ogg_get_header_info(int *len)
-{
-       *len = header_len;
-       return header;
-}
-
-static const char* ogg_suffixes[] = {"ogg", NULL};
-void ogg_init(struct audio_format_handler *p)
-{
-       af = p;
-       af->reposition_stream = ogg_reposition_stream;
-       af->get_file_info = ogg_get_file_info,
-       af->read_chunk = ogg_read_chunk;
-       af->close_audio_file = ogg_close_audio_file;
-       af->get_header_info = ogg_get_header_info;
-       af->chunk_tv.tv_sec = 0;
-       af->chunk_tv.tv_usec = 250 * 1000;
-       tv_scale(3, &af->chunk_tv, &af->eof_tv);
-       af->suffixes = ogg_suffixes;
-}
diff --git a/ogg_afh.c b/ogg_afh.c
new file mode 100644 (file)
index 0000000..3445970
--- /dev/null
+++ b/ogg_afh.c
@@ -0,0 +1,362 @@
+/*
+ * Copyright (C) 2004-2006 Andre Noll <maan@systemlinux.org>
+ *
+ *     This program is free software; you can redistribute it and/or modify
+ *     it under the terms of the GNU General Public License as published by
+ *     the Free Software Foundation; either version 2 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU General Public License for more details.
+ *
+ *     You should have received a copy of the GNU General Public License
+ *     along with this program; if not, write to the Free Software
+ *     Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
+ */
+/** \file ogg.c para_server's ogg vorbis audio format handler */
+
+#include <ogg/ogg.h>
+#include <vorbis/codec.h>
+#include <vorbis/vorbisfile.h>
+
+#include "server.cmdline.h"
+#include "server.h"
+#include "afs.h"
+#include "afh.h"
+#include "error.h"
+#include "string.h"
+
+/* must be big enough to hold header */
+#define CHUNK_SIZE 32768
+static double chunk_time = 0.25;
+
+static OggVorbis_File *oggvorbis_file;
+static FILE *infile;
+static int header_len, oggbuf_len, vi_channels;
+static char *header, *oggbuf;
+static ssize_t *chunk_table, max_chunk_len;
+struct audio_format_handler *af;
+static long vi_sampling_rate, vi_bitrate, vi_bitrate_nominal,
+       num_chunks;
+
+static int ogg_compute_header_len(void)
+{
+       int ret, len, in = fileno(infile);
+       unsigned int serial;
+       char *buf;
+       ogg_page page;
+       ogg_packet packet;
+       vorbis_comment vc;
+       vorbis_info vi;
+       ogg_stream_state *stream_in = para_malloc(sizeof(ogg_stream_state));
+       ogg_stream_state *stream_out = para_malloc(sizeof(ogg_stream_state));
+       ogg_sync_state *sync_in = para_malloc(sizeof(ogg_sync_state));
+
+       ogg_sync_init(sync_in);
+       vorbis_info_init(&vi);
+       vorbis_comment_init(&vc);
+       buf = ogg_sync_buffer(sync_in, CHUNK_SIZE);
+       len = read(in, buf, CHUNK_SIZE);
+       ret = -E_OGG_READ;
+       if (len <= 0)
+               goto err1;
+       ogg_sync_wrote(sync_in, len);
+       ret = -E_SYNC_PAGEOUT;
+       if (ogg_sync_pageout(sync_in, &page) <= 0)
+               goto err1;
+       serial = ogg_page_serialno(&page);
+       ogg_stream_init(stream_in, serial);
+       ogg_stream_init(stream_out, serial);
+       ret = ogg_stream_pagein(stream_in, &page);
+       if (ret < 0) {
+               ret = E_STREAM_PAGEIN;
+               goto err2;
+       }
+       ret = ogg_stream_packetout(stream_in, &packet);
+       if (ret != 1) {
+               ret = -E_STREAM_PACKETOUT;
+               goto err2;
+       }
+       ret = -E_VORBIS;
+       if (vorbis_synthesis_headerin(&vi, &vc, &packet) < 0) {
+               goto err2;
+       } else
+               PARA_INFO_LOG("channels: %i, rate: %li\n", vi.channels,
+                       vi.rate);
+       ogg_stream_packetin(stream_out, &packet);
+
+       ret = ogg_sync_pageout(sync_in, &page);
+       if (ret <= 0) {
+               ret = -E_SYNC_PAGEOUT;
+               goto err2;
+       }
+       ogg_stream_pagein(stream_in, &page);
+       ogg_stream_packetout(stream_in, &packet);
+       ogg_stream_packetin(stream_out, &packet);
+
+       ret = ogg_sync_pageout(sync_in, &page);
+       if (ret <= 0) {
+               ret = -E_SYNC_PAGEOUT;
+               goto err2;
+       }
+       ogg_stream_pagein(stream_in, &page);
+       ogg_stream_packetout(stream_in, &packet);
+       ogg_stream_packetin(stream_out, &packet);
+
+       header_len = 0;
+       while (ogg_stream_flush(stream_out, &page))
+               header_len += page.body_len + page.header_len;
+       ret = len;
+       PARA_INFO_LOG("header_len = %d\n", header_len);
+err2:
+       ogg_stream_destroy(stream_in);
+       ogg_stream_destroy(stream_out);
+err1:
+       ogg_sync_destroy(sync_in);
+       vorbis_info_clear(&vi);
+        vorbis_comment_clear(&vc);
+       return ret;
+}
+
+static void tunetable(void)
+{
+       int i = 1, j = -1, lp = 1;
+       while (i < num_chunks) {
+               if (chunk_table[i] == chunk_table[lp]) {
+                       i++;
+                       continue;
+               }
+               if (j < 0)
+                       tv_scale(i + 2, &af->chunk_tv, &af->eof_tv);
+               for (j = lp; j < i; j++)
+                       chunk_table[j] = chunk_table[i];
+               lp = i;
+       }
+#if 1
+       for (i = 2; i < num_chunks; i++)
+               if (chunk_table[i] != chunk_table[1])
+                       break;
+       lp = i;
+       for (i = 2; i < num_chunks - lp; i++)
+               chunk_table[i] = chunk_table[i + lp];
+#endif 
+}
+
+
+/*
+ * Alloc and fill array table of byte offsets. chunk_table[i] is the
+ * offset in the current infile at which the sample containing time i *
+ * CHUNK_TIME begins.
+ */
+static void ogg_compute_chunk_table(double time_total)
+{
+       int i, ret, num;
+       ssize_t pos = 0, min = 0, old_pos;
+
+       old_pos = 0;
+       ret = 0;
+       num = time_total / chunk_time + 3;
+       PARA_DEBUG_LOG("chunk time: %g allocating %d chunk pointers\n",
+               chunk_time, num);
+       chunk_table = para_malloc(num * sizeof(ogg_int64_t));
+       chunk_table[0] = 0;
+       max_chunk_len = 0;
+       rewind(infile);
+       for (i = 1; ret == 0; i++) {
+               ogg_int64_t diff;
+               ret = ov_time_seek(oggvorbis_file, i * chunk_time);
+               if (ret)
+                       break;
+               pos = ov_raw_tell(oggvorbis_file);
+               diff = pos - old_pos;
+               max_chunk_len = PARA_MAX(max_chunk_len, diff);
+               min = (i == 1)? diff : PARA_MIN(min, diff);
+               chunk_table[i] = pos;
+               if (i < 11 || !((i - 1) % 1000)|| i > num - 11)
+                       PARA_DEBUG_LOG("chunk #%d: %g secs, pos: %zd, "
+                               "size: %zd\n", i - 1,
+                               i * chunk_time, pos, pos - old_pos);
+               old_pos = pos;
+       }
+       num_chunks = i - 1;
+       chunk_table[i] = pos;
+       tunetable();
+       PARA_INFO_LOG("%li chunks (%fs), max chunk: %zd, min chunk: %zd\n",
+               num_chunks, chunk_time, max_chunk_len, min);
+       rewind(infile);
+}
+
+static void ogg_close_audio_file(void)
+{
+       if (oggvorbis_file) {
+               PARA_DEBUG_LOG("%s", "ov_clear\n");
+               ov_clear(oggvorbis_file);
+               free(oggvorbis_file);
+               oggvorbis_file = NULL;
+       }
+       free(header);
+       header = NULL;
+       header_len = 0;
+       free(chunk_table);
+       chunk_table = NULL;
+       num_chunks = 0;
+       free(oggbuf);
+       oggbuf = NULL;
+       oggbuf_len = 0;
+}
+
+static int ogg_save_header(FILE *file, int header_len)
+{
+       int ret;
+
+       header = para_malloc(header_len);
+       rewind(file);
+       ret = read(fileno(file), header, header_len);
+       if (ret != header_len)
+               return -E_OGG_READ;
+       return 1;
+}
+
+/*
+ * Init oggvorbis file and write some tech data to given pointers.
+ */
+static int ogg_get_file_info(FILE *file, char *info_str, long unsigned *frames,
+       int *seconds)
+{
+       int ret;
+       double time_total;
+       vorbis_info *vi;
+       ogg_int64_t raw_total;
+
+       infile = file;
+       if (!file)
+               return -E_OGG_NO_FILE;
+       ret = ogg_compute_header_len();
+       if (ret < 0)
+               return ret;
+       ret = ogg_save_header(file, header_len);
+       if (ret < 0)
+               return ret;
+       rewind(file);
+       oggvorbis_file = para_malloc(sizeof(OggVorbis_File));
+       ret = ov_open(file, oggvorbis_file, NULL, 0);
+       if (ret < 0) {
+               free(oggvorbis_file);
+               free(header);
+               return -E_OGG_OPEN;
+       }
+       ret = -E_OGG_INFO;
+       vi = ov_info(oggvorbis_file, 0);
+       if (!vi)
+               goto err;
+       time_total = ov_time_total(oggvorbis_file, -1);
+       raw_total = ov_raw_total(oggvorbis_file, -1);
+       *seconds = time_total;
+       vi_sampling_rate = vi->rate;
+       vi_bitrate = ov_bitrate(oggvorbis_file, 0);
+       vi_bitrate_nominal = vi->bitrate_nominal;
+       vi_channels = vi->channels;
+       ogg_compute_chunk_table(time_total);
+       *frames = num_chunks;
+       sprintf(info_str, "audio_file_info1:%lu x %lu, %ldkHz, %d channels, %ldkbps\n"
+               "audio_file_info2: \n"
+               "audio_file_info3: \n",
+               num_chunks, (long unsigned) (chunk_time * 1000 * 1000),
+               vi_sampling_rate / 1000, vi_channels, vi_bitrate / 1000
+               );
+       rewind(file);
+       return 1;
+err:
+       ogg_close_audio_file();
+       return ret;
+}
+
+/*
+ * Simple stream reposition routine
+ */
+static int ogg_reposition_stream(long unsigned request)
+{
+       int ret;
+       long seek;
+
+       seek = chunk_table[request];
+       ret = fseek(infile, seek, SEEK_SET);
+       PARA_DEBUG_LOG("seek to %li returned %d. offset:%li\n", seek,
+               ret, ftell(infile));
+       return ret < 0? -E_OGG_REPOS : 1;
+}
+
+static ogg_int64_t get_chunk_size(long unsigned chunk_num)
+{
+       ogg_int64_t ret;
+       if (chunk_num >= num_chunks)
+               return -1;
+       ret = chunk_table[chunk_num + 1] - chunk_table[chunk_num];
+       if (!ret)
+               return ret;
+#if 0
+       PARA_DEBUG_LOG("chunk %d: %lli-%lli (%lli bytes)\n",
+               chunk_num,
+               chunk_table[chunk_num],
+               chunk_table[chunk_num + 1] - 1,
+               ret);
+#endif
+       return ret;
+}
+
+char *ogg_read_chunk(long unsigned current_chunk, ssize_t *len)
+{
+       int ret;
+       ogg_int64_t cs = get_chunk_size(current_chunk);
+       if (!cs) { /* nothing to send for this run */
+               *len = 0;
+               return oggbuf;
+       }
+       if (cs < 0) { /* eof */
+               *len = 0;
+               return NULL;
+       }
+       *len = cs;
+       if (!oggbuf || oggbuf_len < *len) {
+               PARA_INFO_LOG("increasing ogg buffer size (%d -> %zu)\n",
+                       oggbuf_len, *len);
+               oggbuf = para_realloc(oggbuf, *len);
+               oggbuf_len = *len;
+       }
+       ret = read(fileno(infile), oggbuf, *len);
+       if (!ret) {
+               *len = 0;
+               return NULL;
+       }
+       if (ret < 0) {
+               *len = -E_OGG_READ;
+               return NULL;
+       }
+       if (ret != *len)
+               PARA_WARNING_LOG("short read (%d/%zd)\n", ret, *len);
+       *len = ret;
+       return oggbuf;
+}
+
+static char *ogg_get_header_info(int *len)
+{
+       *len = header_len;
+       return header;
+}
+
+static const char* ogg_suffixes[] = {"ogg", NULL};
+void ogg_init(struct audio_format_handler *p)
+{
+       af = p;
+       af->reposition_stream = ogg_reposition_stream;
+       af->get_file_info = ogg_get_file_info,
+       af->read_chunk = ogg_read_chunk;
+       af->close_audio_file = ogg_close_audio_file;
+       af->get_header_info = ogg_get_header_info;
+       af->chunk_tv.tv_sec = 0;
+       af->chunk_tv.tv_usec = 250 * 1000;
+       tv_scale(3, &af->chunk_tv, &af->eof_tv);
+       af->suffixes = ogg_suffixes;
+}