libavformat/mmf.c

   1 /*
   2  * Yamaha SMAF format
   3  * Copyright (c) 2005 Vidar Madsen
   4  *
   5  * This file is part of Libav.
   6  *
   7  * Libav is free software; you can redistribute it and/or
   8  * modify it under the terms of the GNU Lesser General Public
   9  * License as published by the Free Software Foundation; either
  10  * version 2.1 of the License, or (at your option) any later version.
  11  *
  12  * Libav is distributed in the hope that it will be useful,
  13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * Lesser General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU Lesser General Public
  18  * License along with Libav; if not, write to the Free Software
  19  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  20  */
  21 #include "avformat.h"
  22 #include "avio_internal.h"
  23 #include "pcm.h"
  24 #include "riff.h"
  25
  26 typedef struct {
  27     int64_t atrpos, atsqpos, awapos;
  28     int64_t data_size;
  29 } MMFContext;
  30
  31 static const int mmf_rates[] = { 4000, 8000, 11025, 22050, 44100 };
  32
  33 static int mmf_rate(int code)
  34 {
  35     if((code < 0) || (code > 4))
  36         return -1;
  37     return mmf_rates[code];
  38 }
  39
  40 #if CONFIG_MMF_MUXER
  41 static int mmf_rate_code(int rate)
  42 {
  43     int i;
  44     for(i = 0; i < 5; i++)
  45         if(mmf_rates[i] == rate)
  46             return i;
  47     return -1;
  48 }
  49
  50 /* Copy of end_tag() from avienc.c, but for big-endian chunk size */
  51 static void end_tag_be(AVIOContext *pb, int64_t start)
  52 {
  53     int64_t pos;
  54
  55     pos = avio_tell(pb);
  56     avio_seek(pb, start - 4, SEEK_SET);
  57     avio_wb32(pb, (uint32_t)(pos - start));
  58     avio_seek(pb, pos, SEEK_SET);
  59 }
  60
  61 static int mmf_write_header(AVFormatContext *s)
  62 {
  63     MMFContext *mmf = s->priv_data;
  64     AVIOContext *pb = s->pb;
  65     int64_t pos;
  66     int rate;
  67
  68     rate = mmf_rate_code(s->streams[0]->codec->sample_rate);
  69     if(rate < 0) {
  70         av_log(s, AV_LOG_ERROR, "Unsupported sample rate %d\n", s->streams[0]->codec->sample_rate);
  71         return -1;
  72     }
  73
  74     ffio_wfourcc(pb, "MMMD");
  75     avio_wb32(pb, 0);
  76     pos = ff_start_tag(pb, "CNTI");
  77     avio_w8(pb, 0); /* class */
  78     avio_w8(pb, 0); /* type */
  79     avio_w8(pb, 0); /* code type */
  80     avio_w8(pb, 0); /* status */
  81     avio_w8(pb, 0); /* counts */
  82     avio_write(pb, "VN:libavcodec,", sizeof("VN:libavcodec,") -1); /* metadata ("ST:songtitle,VN:version,...") */
  83     end_tag_be(pb, pos);
  84
  85     avio_write(pb, "ATR\x00", 4);
  86     avio_wb32(pb, 0);
  87     mmf->atrpos = avio_tell(pb);
  88     avio_w8(pb, 0); /* format type */
  89     avio_w8(pb, 0); /* sequence type */
  90     avio_w8(pb, (0 << 7) | (1 << 4) | rate); /* (channel << 7) | (format << 4) | rate */
  91     avio_w8(pb, 0); /* wave base bit */
  92     avio_w8(pb, 2); /* time base d */
  93     avio_w8(pb, 2); /* time base g */
  94
  95     ffio_wfourcc(pb, "Atsq");
  96     avio_wb32(pb, 16);
  97     mmf->atsqpos = avio_tell(pb);
  98     /* Will be filled on close */
  99     avio_write(pb, "\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00", 16);
 100
 101     mmf->awapos = ff_start_tag(pb, "Awa\x01");
 102
 103     av_set_pts_info(s->streams[0], 64, 1, s->streams[0]->codec->sample_rate);
 104
 105     avio_flush(pb);
 106
 107     return 0;
 108 }
 109
 110 static int mmf_write_packet(AVFormatContext *s, AVPacket *pkt)
 111 {
 112     AVIOContext *pb = s->pb;
 113     avio_write(pb, pkt->data, pkt->size);
 114     return 0;
 115 }
 116
 117 /* Write a variable-length symbol */
 118 static void put_varlength(AVIOContext *pb, int val)
 119 {
 120     if(val < 128)
 121         avio_w8(pb, val);
 122     else {
 123         val -= 128;
 124         avio_w8(pb, 0x80 | val >> 7);
 125         avio_w8(pb, 0x7f & val);
 126     }
 127 }
 128
 129 static int mmf_write_trailer(AVFormatContext *s)
 130 {
 131     AVIOContext *pb = s->pb;
 132     MMFContext *mmf = s->priv_data;
 133     int64_t pos, size;
 134     int gatetime;
 135
 136     if (s->pb->seekable) {
 137         /* Fill in length fields */
 138         end_tag_be(pb, mmf->awapos);
 139         end_tag_be(pb, mmf->atrpos);
 140         end_tag_be(pb, 8);
 141
 142         pos = avio_tell(pb);
 143         size = pos - mmf->awapos;
 144
 145         /* Fill Atsq chunk */
 146         avio_seek(pb, mmf->atsqpos, SEEK_SET);
 147
 148         /* "play wav" */
 149         avio_w8(pb, 0); /* start time */
 150         avio_w8(pb, 1); /* (channel << 6) | wavenum */
 151         gatetime = size * 500 / s->streams[0]->codec->sample_rate;
 152         put_varlength(pb, gatetime); /* duration */
 153
 154         /* "nop" */
 155         put_varlength(pb, gatetime); /* start time */
 156         avio_write(pb, "\xff\x00", 2); /* nop */
 157
 158         /* "end of sequence" */
 159         avio_write(pb, "\x00\x00\x00\x00", 4);
 160
 161         avio_seek(pb, pos, SEEK_SET);
 162
 163         avio_flush(pb);
 164     }
 165     return 0;
 166 }
 167 #endif /* CONFIG_MMF_MUXER */
 168
 169 static int mmf_probe(AVProbeData *p)
 170 {
 171     /* check file header */
 172     if (p->buf[0] == 'M' && p->buf[1] == 'M' &&
 173         p->buf[2] == 'M' && p->buf[3] == 'D' &&
 174         p->buf[8] == 'C' && p->buf[9] == 'N' &&
 175         p->buf[10] == 'T' && p->buf[11] == 'I')
 176         return AVPROBE_SCORE_MAX;
 177     else
 178         return 0;
 179 }
 180
 181 /* mmf input */
 182 static int mmf_read_header(AVFormatContext *s,
 183                            AVFormatParameters *ap)
 184 {
 185     MMFContext *mmf = s->priv_data;
 186     unsigned int tag;
 187     AVIOContext *pb = s->pb;
 188     AVStream *st;
 189     int64_t size;
 190     int rate, params;
 191
 192     tag = avio_rl32(pb);
 193     if (tag != MKTAG('M', 'M', 'M', 'D'))
 194         return -1;
 195     avio_skip(pb, 4); /* file_size */
 196
 197     /* Skip some unused chunks that may or may not be present */
 198     for(;; avio_skip(pb, size)) {
 199         tag = avio_rl32(pb);
 200         size = avio_rb32(pb);
 201         if(tag == MKTAG('C','N','T','I')) continue;
 202         if(tag == MKTAG('O','P','D','A')) continue;
 203         break;
 204     }
 205
 206     /* Tag = "ATRx", where "x" = track number */
 207     if ((tag & 0xffffff) == MKTAG('M', 'T', 'R', 0)) {
 208         av_log(s, AV_LOG_ERROR, "MIDI like format found, unsupported\n");
 209         return -1;
 210     }
 211     if ((tag & 0xffffff) != MKTAG('A', 'T', 'R', 0)) {
 212         av_log(s, AV_LOG_ERROR, "Unsupported SMAF chunk %08x\n", tag);
 213         return -1;
 214     }
 215
 216     avio_r8(pb); /* format type */
 217     avio_r8(pb); /* sequence type */
 218     params = avio_r8(pb); /* (channel << 7) | (format << 4) | rate */
 219     rate = mmf_rate(params & 0x0f);
 220     if(rate  < 0) {
 221         av_log(s, AV_LOG_ERROR, "Invalid sample rate\n");
 222         return -1;
 223     }
 224     avio_r8(pb); /* wave base bit */
 225     avio_r8(pb); /* time base d */
 226     avio_r8(pb); /* time base g */
 227
 228     /* Skip some unused chunks that may or may not be present */
 229     for(;; avio_skip(pb, size)) {
 230         tag = avio_rl32(pb);
 231         size = avio_rb32(pb);
 232         if(tag == MKTAG('A','t','s','q')) continue;
 233         if(tag == MKTAG('A','s','p','I')) continue;
 234         break;
 235     }
 236
 237     /* Make sure it's followed by an Awa chunk, aka wave data */
 238     if ((tag & 0xffffff) != MKTAG('A', 'w', 'a', 0)) {
 239         av_log(s, AV_LOG_ERROR, "Unexpected SMAF chunk %08x\n", tag);
 240         return -1;
 241     }
 242     mmf->data_size = size;
 243
 244     st = av_new_stream(s, 0);
 245     if (!st)
 246         return AVERROR(ENOMEM);
 247
 248     st->codec->codec_type = AVMEDIA_TYPE_AUDIO;
 249     st->codec->codec_id = CODEC_ID_ADPCM_YAMAHA;
 250     st->codec->sample_rate = rate;
 251     st->codec->channels = 1;
 252     st->codec->bits_per_coded_sample = 4;
 253     st->codec->bit_rate = st->codec->sample_rate * st->codec->bits_per_coded_sample;
 254
 255     av_set_pts_info(st, 64, 1, st->codec->sample_rate);
 256
 257     return 0;
 258 }
 259
 260 #define MAX_SIZE 4096
 261
 262 static int mmf_read_packet(AVFormatContext *s,
 263                            AVPacket *pkt)
 264 {
 265     MMFContext *mmf = s->priv_data;
 266     int ret, size;
 267
 268     if (s->pb->eof_reached)
 269         return AVERROR(EIO);
 270
 271     size = MAX_SIZE;
 272     if(size > mmf->data_size)
 273         size = mmf->data_size;
 274
 275     if(!size)
 276         return AVERROR(EIO);
 277
 278     if (av_new_packet(pkt, size))
 279         return AVERROR(EIO);
 280     pkt->stream_index = 0;
 281
 282     ret = avio_read(s->pb, pkt->data, pkt->size);
 283     if (ret < 0)
 284         av_free_packet(pkt);
 285
 286     mmf->data_size -= ret;
 287
 288     pkt->size = ret;
 289     return ret;
 290 }
 291
 292 #if CONFIG_MMF_DEMUXER
 293 AVInputFormat ff_mmf_demuxer = {
 294     .name           = "mmf",
 295     .long_name      = NULL_IF_CONFIG_SMALL("Yamaha SMAF"),
 296     .priv_data_size = sizeof(MMFContext),
 297     .read_probe     = mmf_probe,
 298     .read_header    = mmf_read_header,
 299     .read_packet    = mmf_read_packet,
 300     .read_seek      = pcm_read_seek,
 301 };
 302 #endif
 303 #if CONFIG_MMF_MUXER
 304 AVOutputFormat ff_mmf_muxer = {
 305     .name              = "mmf",
 306     .long_name         = NULL_IF_CONFIG_SMALL("Yamaha SMAF"),
 307     .mime_type         = "application/vnd.smaf",
 308     .extensions        = "mmf",
 309     .priv_data_size    = sizeof(MMFContext),
 310     .audio_codec       = CODEC_ID_ADPCM_YAMAHA,
 311     .video_codec       = CODEC_ID_NONE,
 312     .write_header      = mmf_write_header,
 313     .write_packet      = mmf_write_packet,
 314     .write_trailer     = mmf_write_trailer,
 315 };
 316 #endif