dfca23e3 |
/*
* NuppelVideo demuxer. |
406792e7 |
* Copyright (c) 2006 Reimar Doeffinger |
dfca23e3 |
* |
b78e7197 |
* This file is part of FFmpeg.
*
* FFmpeg is free software; you can redistribute it and/or |
dfca23e3 |
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either |
b78e7197 |
* version 2.1 of the License, or (at your option) any later version. |
dfca23e3 |
* |
b78e7197 |
* FFmpeg is distributed in the hope that it will be useful, |
dfca23e3 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public |
b78e7197 |
* License along with FFmpeg; if not, write to the Free Software |
dfca23e3 |
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/ |
6a5d31ac |
#include "libavutil/intreadwrite.h" |
3383a53e |
#include "libavutil/intfloat.h" |
dfca23e3 |
#include "avformat.h" |
c3f9ebf7 |
#include "internal.h" |
9d9f4119 |
#include "riff.h" |
dfca23e3 |
typedef struct {
int v_id;
int a_id; |
dd6ca721 |
int rtjpg_video; |
dfca23e3 |
} NUVContext;
typedef enum {
NUV_VIDEO = 'V',
NUV_EXTRADATA = 'D',
NUV_AUDIO = 'A',
NUV_SEEKP = 'R',
NUV_MYTHEXT = 'X' |
b4be9321 |
} nuv_frametype; |
dfca23e3 |
static int nuv_probe(AVProbeData *p) {
if (!memcmp(p->buf, "NuppelVideo", 12))
return AVPROBE_SCORE_MAX;
if (!memcmp(p->buf, "MythTVVideo", 12))
return AVPROBE_SCORE_MAX;
return 0;
}
|
c68fafe0 |
/// little macro to sanitize packet size |
dfca23e3 |
#define PKTSIZE(s) (s & 0xffffff)
/** |
adbfc605 |
* @brief read until we found all data needed for decoding
* @param vst video stream of which to change parameters
* @param ast video stream of which to change parameters
* @param myth set if this is a MythTVVideo format file
* @return 1 if all required codec data was found |
dfca23e3 |
*/ |
471fe57e |
static int get_codec_data(AVIOContext *pb, AVStream *vst, |
dfca23e3 |
AVStream *ast, int myth) { |
b4be9321 |
nuv_frametype frametype; |
dfca23e3 |
if (!vst && !myth)
return 1; // no codec data needed
while (!url_feof(pb)) {
int size, subtype; |
e63a3628 |
frametype = avio_r8(pb); |
dfca23e3 |
switch (frametype) {
case NUV_EXTRADATA: |
e63a3628 |
subtype = avio_r8(pb); |
45a8a02a |
avio_skip(pb, 6); |
e63a3628 |
size = PKTSIZE(avio_rl32(pb)); |
50a6c318 |
if (vst && subtype == 'R') { |
dfca23e3 |
vst->codec->extradata_size = size;
vst->codec->extradata = av_malloc(size); |
e63a3628 |
avio_read(pb, vst->codec->extradata, size); |
dfca23e3 |
size = 0;
if (!myth)
return 1;
}
break;
case NUV_MYTHEXT: |
45a8a02a |
avio_skip(pb, 7); |
e63a3628 |
size = PKTSIZE(avio_rl32(pb)); |
dfca23e3 |
if (size != 128 * 4)
break; |
e63a3628 |
avio_rl32(pb); // version |
dfca23e3 |
if (vst) { |
e63a3628 |
vst->codec->codec_tag = avio_rl32(pb); |
dfca23e3 |
vst->codec->codec_id = |
1a40491e |
ff_codec_get_id(ff_codec_bmp_tags, vst->codec->codec_tag); |
efd74286 |
if (vst->codec->codec_tag == MKTAG('R', 'J', 'P', 'G'))
vst->codec->codec_id = CODEC_ID_NUV; |
dfca23e3 |
} else |
45a8a02a |
avio_skip(pb, 4); |
dfca23e3 |
if (ast) { |
e63a3628 |
ast->codec->codec_tag = avio_rl32(pb);
ast->codec->sample_rate = avio_rl32(pb);
ast->codec->bits_per_coded_sample = avio_rl32(pb);
ast->codec->channels = avio_rl32(pb); |
dfca23e3 |
ast->codec->codec_id = |
1a40491e |
ff_wav_codec_get_id(ast->codec->codec_tag, |
dd1c8f3e |
ast->codec->bits_per_coded_sample); |
8a59d9a3 |
ast->need_parsing = AVSTREAM_PARSE_FULL; |
dfca23e3 |
} else |
45a8a02a |
avio_skip(pb, 4 * 4); |
dfca23e3 |
size -= 6 * 4; |
45a8a02a |
avio_skip(pb, size); |
dfca23e3 |
return 1;
case NUV_SEEKP:
size = 11;
break;
default: |
45a8a02a |
avio_skip(pb, 7); |
e63a3628 |
size = PKTSIZE(avio_rl32(pb)); |
dfca23e3 |
break;
} |
45a8a02a |
avio_skip(pb, size); |
dfca23e3 |
}
return 0;
}
|
6e9651d1 |
static int nuv_header(AVFormatContext *s) { |
e4141433 |
NUVContext *ctx = s->priv_data; |
471fe57e |
AVIOContext *pb = s->pb; |
ac2b2226 |
char id_string[12]; |
dfca23e3 |
double aspect, fps;
int is_mythtv, width, height, v_packs, a_packs;
int stream_nr = 0;
AVStream *vst = NULL, *ast = NULL; |
e63a3628 |
avio_read(pb, id_string, 12); |
dfca23e3 |
is_mythtv = !memcmp(id_string, "MythTVVideo", 12); |
45a8a02a |
avio_skip(pb, 5); // version string
avio_skip(pb, 3); // padding |
e63a3628 |
width = avio_rl32(pb);
height = avio_rl32(pb);
avio_rl32(pb); // unused, "desiredwidth"
avio_rl32(pb); // unused, "desiredheight"
avio_r8(pb); // 'P' == progressive, 'I' == interlaced |
45a8a02a |
avio_skip(pb, 3); // padding |
3383a53e |
aspect = av_int2double(avio_rl64(pb)); |
4c8e5dfc |
if (aspect > 0.9999 && aspect < 1.0001)
aspect = 4.0 / 3.0; |
3383a53e |
fps = av_int2double(avio_rl64(pb)); |
dfca23e3 |
// number of packets per stream type, -1 means unknown, e.g. streaming |
e63a3628 |
v_packs = avio_rl32(pb);
a_packs = avio_rl32(pb);
avio_rl32(pb); // text |
dfca23e3 |
|
e63a3628 |
avio_rl32(pb); // keyframe distance (?) |
dfca23e3 |
if (v_packs) {
ctx->v_id = stream_nr++; |
84ad31ff |
vst = avformat_new_stream(s, NULL); |
60583fb6 |
if (!vst)
return AVERROR(ENOMEM); |
72415b2a |
vst->codec->codec_type = AVMEDIA_TYPE_VIDEO; |
dfca23e3 |
vst->codec->codec_id = CODEC_ID_NUV;
vst->codec->width = width;
vst->codec->height = height; |
dd1c8f3e |
vst->codec->bits_per_coded_sample = 10; |
59729451 |
vst->sample_aspect_ratio = av_d2q(aspect * height / width, 10000); |
8643594c |
vst->r_frame_rate = av_d2q(fps, 60000); |
c3f9ebf7 |
avpriv_set_pts_info(vst, 32, 1, 1000); |
dfca23e3 |
} else
ctx->v_id = -1;
if (a_packs) {
ctx->a_id = stream_nr++; |
84ad31ff |
ast = avformat_new_stream(s, NULL); |
60583fb6 |
if (!ast)
return AVERROR(ENOMEM); |
72415b2a |
ast->codec->codec_type = AVMEDIA_TYPE_AUDIO; |
dfca23e3 |
ast->codec->codec_id = CODEC_ID_PCM_S16LE;
ast->codec->channels = 2;
ast->codec->sample_rate = 44100;
ast->codec->bit_rate = 2 * 2 * 44100 * 8;
ast->codec->block_align = 2 * 2; |
dd1c8f3e |
ast->codec->bits_per_coded_sample = 16; |
c3f9ebf7 |
avpriv_set_pts_info(ast, 32, 1, 1000); |
dfca23e3 |
} else
ctx->a_id = -1;
get_codec_data(pb, vst, ast, is_mythtv); |
00496302 |
ctx->rtjpg_video = vst && vst->codec->codec_id == CODEC_ID_NUV; |
dfca23e3 |
return 0;
}
#define HDRSIZE 12
static int nuv_packet(AVFormatContext *s, AVPacket *pkt) { |
e4141433 |
NUVContext *ctx = s->priv_data; |
471fe57e |
AVIOContext *pb = s->pb; |
dfca23e3 |
uint8_t hdr[HDRSIZE]; |
b4be9321 |
nuv_frametype frametype; |
dfca23e3 |
int ret, size;
while (!url_feof(pb)) { |
dd6ca721 |
int copyhdrsize = ctx->rtjpg_video ? HDRSIZE : 0; |
384c9c2f |
uint64_t pos = avio_tell(pb); |
e63a3628 |
ret = avio_read(pb, hdr, HDRSIZE); |
4e5735f7 |
if (ret < HDRSIZE)
return ret < 0 ? ret : AVERROR(EIO); |
dfca23e3 |
frametype = hdr[0]; |
fead30d4 |
size = PKTSIZE(AV_RL32(&hdr[8])); |
dfca23e3 |
switch (frametype) {
case NUV_EXTRADATA: |
dd6ca721 |
if (!ctx->rtjpg_video) { |
45a8a02a |
avio_skip(pb, size); |
dd6ca721 |
break;
}
case NUV_VIDEO: |
dfca23e3 |
if (ctx->v_id < 0) {
av_log(s, AV_LOG_ERROR, "Video packet in file without video stream!\n"); |
45a8a02a |
avio_skip(pb, size); |
dfca23e3 |
break;
} |
dd6ca721 |
ret = av_new_packet(pkt, copyhdrsize + size); |
dfca23e3 |
if (ret < 0)
return ret; |
8e4c1000 |
|
fb2e95c9 |
pkt->pos = pos; |
8e4c1000 |
pkt->flags |= hdr[2] == 0 ? AV_PKT_FLAG_KEY : 0; |
fead30d4 |
pkt->pts = AV_RL32(&hdr[4]); |
dfca23e3 |
pkt->stream_index = ctx->v_id; |
dd6ca721 |
memcpy(pkt->data, hdr, copyhdrsize); |
e63a3628 |
ret = avio_read(pb, pkt->data + copyhdrsize, size); |
ef12ec23 |
if (ret < 0) {
av_free_packet(pkt);
return ret;
} |
94705111 |
if (ret < size)
av_shrink_packet(pkt, copyhdrsize + ret); |
b0723c8a |
return 0; |
dfca23e3 |
case NUV_AUDIO:
if (ctx->a_id < 0) {
av_log(s, AV_LOG_ERROR, "Audio packet in file without audio stream!\n"); |
45a8a02a |
avio_skip(pb, size); |
dfca23e3 |
break;
}
ret = av_get_packet(pb, pkt, size); |
cc947f04 |
pkt->flags |= AV_PKT_FLAG_KEY; |
fb2e95c9 |
pkt->pos = pos; |
fead30d4 |
pkt->pts = AV_RL32(&hdr[4]); |
dfca23e3 |
pkt->stream_index = ctx->a_id; |
b0723c8a |
if (ret < 0) return ret;
return 0; |
dfca23e3 |
case NUV_SEEKP:
// contains no data, size value is invalid
break;
default: |
45a8a02a |
avio_skip(pb, size); |
dfca23e3 |
break;
}
} |
6f3e0b21 |
return AVERROR(EIO); |
dfca23e3 |
}
|
7768f6b1 |
/**
* \brief looks for the string RTjjjjjjjjjj in the stream too resync reading
* \return 1 if the syncword is found 0 otherwise.
*/
static int nuv_resync(AVFormatContext *s, int64_t pos_limit) {
AVIOContext *pb = s->pb;
uint32_t tag = 0;
while(!url_feof(pb) && avio_tell(pb) < pos_limit) {
tag = (tag << 8) | avio_r8(pb);
if (tag == MKBETAG('R','T','j','j') &&
(tag = avio_rb32(pb)) == MKBETAG('j','j','j','j') &&
(tag = avio_rb32(pb)) == MKBETAG('j','j','j','j'))
return 1;
}
return 0;
}
/**
* \brief attempts to read a timestamp from stream at the given stream position |
2d38081b |
* \return timestamp if successful and AV_NOPTS_VALUE if failure |
7768f6b1 |
*/
static int64_t nuv_read_dts(AVFormatContext *s, int stream_index,
int64_t *ppos, int64_t pos_limit)
{
NUVContext *ctx = s->priv_data;
AVIOContext *pb = s->pb;
uint8_t hdr[HDRSIZE];
nuv_frametype frametype;
int size, key, idx;
int64_t pos, dts;
if (avio_seek(pb, *ppos, SEEK_SET) < 0)
return AV_NOPTS_VALUE;
if (!nuv_resync(s, pos_limit))
return AV_NOPTS_VALUE;
while (!url_feof(pb) && avio_tell(pb) < pos_limit) {
if (avio_read(pb, hdr, HDRSIZE) < HDRSIZE)
return AV_NOPTS_VALUE;
frametype = hdr[0];
size = PKTSIZE(AV_RL32(&hdr[8]));
switch (frametype) {
case NUV_SEEKP:
break;
case NUV_AUDIO:
case NUV_VIDEO:
if (frametype == NUV_VIDEO) {
idx = ctx->v_id;
key = hdr[2] == 0;
} else {
idx = ctx->a_id;
key = 1;
}
if (stream_index == idx) {
pos = avio_tell(s->pb) - HDRSIZE;
dts = AV_RL32(&hdr[4]);
// TODO - add general support in av_gen_search, so it adds positions after reading timestamps
av_add_index_entry(s->streams[stream_index], pos, dts, size + HDRSIZE, 0,
key ? AVINDEX_KEYFRAME : 0);
*ppos = pos;
return dts;
}
default:
avio_skip(pb, size);
break;
}
}
return AV_NOPTS_VALUE;
}
|
66355be3 |
AVInputFormat ff_nuv_demuxer = { |
dfc2c4d9 |
.name = "nuv",
.long_name = NULL_IF_CONFIG_SMALL("NuppelVideo format"),
.priv_data_size = sizeof(NUVContext),
.read_probe = nuv_probe,
.read_header = nuv_header,
.read_packet = nuv_packet, |
7768f6b1 |
.read_timestamp = nuv_read_dts, |
20234a4b |
.flags = AVFMT_GENERIC_INDEX, |
dfca23e3 |
}; |