RepoMirrors
/
mpv
mirror of https://github.com/mpv-player/mpv
1
0
Fork 0
Code Issues Releases Wiki Activity
mpv/libmpdemux/demux_mkv.cpp

2621 lines
87 KiB
C++
Raw Blame History

extern "C" {
#include "config.h"
}
#ifdef HAVE_MATROSKA
extern "C" {
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include "../mp_msg.h"
#include "../help_mp.h"
#include "stream.h"
#include "demuxer.h"
#include "stheader.h"
#include "../subreader.h"
#include "../libvo/sub.h"
}
#include <iostream>
#include <cassert>
#include <typeinfo>
#include <vector>
#include <ebml/EbmlHead.h>
#include <ebml/EbmlSubHead.h>
#include <ebml/EbmlStream.h>
#include <ebml/EbmlContexts.h>
#include <ebml/EbmlVersion.h>
#include <ebml/StdIOCallback.h>
#include <matroska/KaxAttachments.h>
#include <matroska/KaxBlock.h>
#include <matroska/KaxBlockData.h>
#include <matroska/KaxChapters.h>
#include <matroska/KaxCluster.h>
#include <matroska/KaxClusterData.h>
#include <matroska/KaxContexts.h>
#include <matroska/KaxCues.h>
#include <matroska/KaxCuesData.h>
#include <matroska/KaxInfo.h>
#include <matroska/KaxInfoData.h>
#include <matroska/KaxSeekHead.h>
#include <matroska/KaxSegment.h>
#include <matroska/KaxTracks.h>
#include <matroska/KaxTrackAudio.h>
#include <matroska/KaxTrackVideo.h>
#include <matroska/FileKax.h>
#include "matroska.h"
using namespace LIBMATROSKA_NAMESPACE;
using namespace std;
#ifndef LIBEBML_VERSION
#define LIBEBML_VERSION 000000
#endif // LIBEBML_VERSION
#if LIBEBML_VERSION < 000500
#error libebml version too old - need at least 0.5.0
#endif
// for e.g. "-slang ger"
extern char *dvdsub_lang;
extern char *audio_lang;
// default values for Matroska elements
#define MKVD_TIMECODESCALE 1000000 // 1000000 = 1ms
class mpstream_io_callback: public IOCallback {
private:
stream_t *s;
public:
mpstream_io_callback(stream_t *stream);
virtual uint32 read(void *buffer, size_t size);
virtual void setFilePointer(int64 offset, seek_mode mode = seek_beginning);
virtual size_t write(const void *buffer, size_t size);
virtual uint64 getFilePointer();
virtual void close();
};
mpstream_io_callback::mpstream_io_callback(stream_t *stream) {
s = stream;
}
uint32 mpstream_io_callback::read(void *buffer, size_t size) {
uint32_t result;
result = stream_read(s, (char *)buffer, size);
return result;
}
void mpstream_io_callback::setFilePointer(int64 offset, seek_mode mode) {
int64 new_pos;
if (mode == seek_beginning)
new_pos = offset + s->start_pos;
else if (mode == seek_end)
new_pos = s->end_pos - offset;
else
new_pos = s->pos + offset;
if (new_pos > s->end_pos) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] seek warning: new_pos %lld > end_pos "
"%lld\n", new_pos, s->end_pos);
return;
}
stream_seek(s, new_pos);
}
size_t mpstream_io_callback::write(const void */*buffer*/, size_t /*size*/) {
return 0;
}
uint64 mpstream_io_callback::getFilePointer() {
return s->pos - s->buf_len + s->buf_pos;
}
void mpstream_io_callback::close() {
}
typedef struct mkv_index_entry {
uint64_t timecode, filepos;
int is_key;
} mkv_index_entry_t;
typedef struct mkv_track_index {
uint32_t tnum;
int num_entries;
mkv_index_entry_t *entries;
} mkv_track_index_t;
typedef struct mkv_track {
uint32_t tnum;
char *codec_id;
int ms_compat;
char *language;
char type; // 'v' = video, 'a' = audio, 's' = subs
char v_fourcc[5];
uint32_t v_width, v_height, v_dwidth, v_dheight;
float v_frate;
uint32_t a_formattag;
uint32_t a_channels, a_bps;
float a_sfreq;
int default_track;
void *private_data;
unsigned int private_size;
// For Vorbis audio
unsigned char *headers[3];
uint32_t header_sizes[3];
int ok;
// Stuff for RealMedia
bool realmedia;
demux_packet_t *rm_dp;
int rm_seqnum, rv_kf_base, rv_kf_pts;
float rv_pts; // previous video timestamp
float ra_pts; // previous audio timestamp
} mkv_track_t;
typedef struct mkv_demuxer {
float duration, last_pts;
uint64_t last_filepos;
mkv_track_t **tracks;
int num_tracks;
mkv_track_t *video, *audio, *subs_track;
uint64_t tc_scale, cluster_tc, first_tc;
mpstream_io_callback *in;
uint64_t clear_subs_at;
subtitle subs;
EbmlStream *es;
EbmlElement *saved_l1, *saved_l2;
KaxSegment *segment;
KaxCluster *cluster;
mkv_track_index_t *index;
int num_indexes, cues_found, cues_searched;
int64_t *cluster_positions;
int num_cluster_pos;
int64_t skip_to_timecode;
bool v_skip_to_keyframe, a_skip_to_keyframe;
} mkv_demuxer_t;
typedef struct {
uint32_t chunks; // number of chunks
uint32_t timestamp; // timestamp from packet header
uint32_t len; // length of actual data
uint32_t chunktab; // offset to chunk offset array
} dp_hdr_t;
#if __GNUC__ == 2
#pragma pack(2)
#else
#pragma pack(push,2)
#endif
typedef struct {
uint32_t size;
uint32_t fourcc1;
uint32_t fourcc2;
uint16_t width;
uint16_t height;
uint16_t bpp;
uint32_t unknown1;
uint32_t fps;
uint32_t type1;
uint32_t type2;
} real_video_props_t;
typedef struct {
uint32_t fourcc1; // '.', 'r', 'a', 0xfd
uint16_t version1; // 4 or 5
uint16_t unknown1; // 00 000
uint32_t fourcc2; // .ra4 or .ra5
uint32_t unknown2; // ???
uint16_t version2; // 4 or 5
uint32_t header_size; // == 0x4e
uint16_t flavor; // codec flavor id
uint32_t coded_frame_size; // coded frame size
uint32_t unknown3; // big number
uint32_t unknown4; // bigger number
uint32_t unknown5; // yet another number
uint16_t sub_packet_h;
uint16_t frame_size;
uint16_t sub_packet_size;
uint16_t unknown6; // 00 00
uint16_t sample_rate;
uint16_t unknown8; // 0
uint16_t sample_size;
uint16_t channels;
} real_audio_v4_props_t;
typedef struct {
uint32_t fourcc1; // '.', 'r', 'a', 0xfd
uint16_t version1; // 4 or 5
uint16_t unknown1; // 00 000
uint32_t fourcc2; // .ra4 or .ra5
uint32_t unknown2; // ???
uint16_t version2; // 4 or 5
uint32_t header_size; // == 0x4e
uint16_t flavor; // codec flavor id
uint32_t coded_frame_size; // coded frame size
uint32_t unknown3; // big number
uint32_t unknown4; // bigger number
uint32_t unknown5; // yet another number
uint16_t sub_packet_h;
uint16_t frame_size;
uint16_t sub_packet_size;
uint16_t unknown6; // 00 00
uint8_t unknown7[6]; // 0, srate, 0
uint16_t sample_rate;
uint16_t unknown8; // 0
uint16_t sample_size;
uint16_t channels;
uint32_t genr; // "genr"
uint32_t fourcc3; // fourcc
} real_audio_v5_props_t;
#if __GNUC__ == 2
#pragma pack()
#else
#pragma pack(pop)
#endif
static uint16_t get_uint16(const void *buf) {
uint16_t ret;
unsigned char *tmp;
tmp = (unsigned char *) buf;
ret = tmp[1] & 0xff;
ret = (ret << 8) + (tmp[0] & 0xff);
return ret;
}
static uint32_t get_uint32(const void *buf) {
uint32_t ret;
unsigned char *tmp;
tmp = (unsigned char *) buf;
ret = tmp[3] & 0xff;
ret = (ret << 8) + (tmp[2] & 0xff);
ret = (ret << 8) + (tmp[1] & 0xff);
ret = (ret << 8) + (tmp[0] & 0xff);
return ret;
}
static uint16_t get_uint16_be(const void *buf) {
uint16_t ret;
unsigned char *tmp;
tmp = (unsigned char *) buf;
ret = tmp[0] & 0xff;
ret = (ret << 8) + (tmp[1] & 0xff);
return ret;
}
static uint32_t get_uint32_be(const void *buf) {
uint32_t ret;
unsigned char *tmp;
tmp = (unsigned char *) buf;
ret = tmp[0] & 0xff;
ret = (ret << 8) + (tmp[1] & 0xff);
ret = (ret << 8) + (tmp[2] & 0xff);
ret = (ret << 8) + (tmp[3] & 0xff);
return ret;
}
unsigned char read_char(unsigned char *p, int &pos, int size) {
if ((pos + 1) > size)
throw exception();
pos++;
return p[pos - 1];
}
unsigned short read_word(unsigned char *p, int &pos, int size) {
unsigned short v;
if ((pos + 2) > size)
throw exception();
v = p[pos];
v = (v << 8) | (p[pos + 1] & 0xff);
pos += 2;
return v;
}
unsigned int read_dword(unsigned char *p, int &pos, int size) {
unsigned int v;
if ((pos + 4) > size)
throw exception();
v = p[pos];
v = (v << 8) | (p[pos + 1] & 0xff);
v = (v << 8) | (p[pos + 2] & 0xff);
v = (v << 8) | (p[pos + 3] & 0xff);
pos += 4;
return v;
}
static void handle_subtitles(demuxer_t *d, KaxBlock *block, int64_t duration) {
mkv_demuxer_t *mkv_d = (mkv_demuxer_t *)d->priv;
int len, line, state;
char *s1, *s2, *buffer;
if (duration == -1) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] Warning: No KaxBlockDuration "
"element for subtitle track found.\n");
return;
}
DataBuffer &data = block->GetBuffer(0);
len = data.Size();
buffer = (char *)data.Buffer();
s1 = buffer;
while (((*s1 == '\n') || (*s1 == '\r')) &&
((unsigned int)(s1 - buffer) <= data.Size()))
s1++;
line = 0;
s2 = mkv_d->subs.text[0];
mkv_d->subs.lines = 1;
state = 0;
while ((unsigned int)(s1 - buffer) != data.Size()) {
if ((*s1 == '\n') || (*s1 == '\r')) {
if (state == 0) { // normal char --> newline
if (mkv_d->subs.lines == SUB_MAX_TEXT)
break;
*s2 = 0;
s2 = mkv_d->subs.text[mkv_d->subs.lines];
mkv_d->subs.lines++;
state = 1;
}
} else if (*s1 == '<') // skip HTML tags
state = 2;
else if (*s1 == '>')
state = 0;
else if (state != 2) { // normal character
state = 0;
if ((s2 - mkv_d->subs.text[mkv_d->subs.lines - 1]) < 255) {
*s2 = *s1;
s2++;
}
}
s1++;
}
*s2 = 0;
#ifdef USE_ICONV
subcp_recode1(&mkv_d->subs);
#endif
vo_sub = &mkv_d->subs;
vo_osd_changed(OSDTYPE_SUBTITLE);
mkv_d->clear_subs_at = block->GlobalTimecode() / 1000000 - mkv_d->first_tc +
duration;
}
static mkv_track_t *new_mkv_track(mkv_demuxer_t *d) {
mkv_track_t *t;
t = (mkv_track_t *)malloc(sizeof(mkv_track_t));
if (t != NULL) {
memset(t, 0, sizeof(mkv_track_t));
d->tracks = (mkv_track_t **)realloc(d->tracks, (d->num_tracks + 1) *
sizeof(mkv_track_t *));
if (d->tracks == NULL)
return NULL;
d->tracks[d->num_tracks] = t;
d->num_tracks++;
// Set default values.
t->default_track = 1;
t->a_sfreq = 8000.0;
t->a_channels = 1;
t->language = strdup("eng");
}
return t;
}
static mkv_track_t *find_track_by_num(mkv_demuxer_t *d, uint32_t n,
mkv_track_t *c) {
int i;
for (i = 0; i < d->num_tracks; i++)
if ((d->tracks[i] != NULL) && (d->tracks[i]->tnum == n) &&
(d->tracks[i] != c))
return d->tracks[i];
return NULL;
}
static mkv_track_t *find_track_by_language(mkv_demuxer_t *d, char *language,
mkv_track_t *c, char type = 's') {
int i;
for (i = 0; i < d->num_tracks; i++)
if ((d->tracks[i] != NULL) && (d->tracks[i] != c) &&
(d->tracks[i]->language != NULL) &&
!strcmp(d->tracks[i]->language, language) &&
(d->tracks[i]->type == type))
return d->tracks[i];
return NULL;
}
static int check_track_information(mkv_demuxer_t *d) {
int i, track_num;
unsigned char *c;
uint32_t u, offset, length;
mkv_track_t *t;
BITMAPINFOHEADER *bih;
WAVEFORMATEX *wfe;
for (track_num = 0; track_num < d->num_tracks; track_num++) {
t = d->tracks[track_num];
switch (t->type) {
case 'v': // video track
if (t->codec_id == NULL)
continue;
if (!strcmp(t->codec_id, MKV_V_MSCOMP)) {
if ((t->private_data == NULL) ||
(t->private_size < sizeof(BITMAPINFOHEADER))) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: CodecID for track "
"%u is '" MKV_V_MSCOMP "', but there was no "
"BITMAPINFOHEADER struct present. Therefore we don't have "
"a FourCC to identify the video codec used.\n", t->tnum);
continue;
} else {
t->ms_compat = 1;
bih = (BITMAPINFOHEADER *)t->private_data;
u = get_uint32(&bih->biWidth);
if (t->v_width != u) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: (MS "
"compatibility mode, track %u) "
"Matrosa says video width is %u, but the "
"BITMAPINFOHEADER says %u.\n", t->tnum, t->v_width, u);
if (t->v_width == 0)
t->v_width = u;
}
u = get_uint32(&bih->biHeight);
if (t->v_height != u) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: (MS compatibility "
"mode, track %u) "
"Matrosa video height is %u, but the BITMAPINFOHEADER "
"says %u.\n", t->tnum, t->v_height, u);
if (t->v_height == 0)
t->v_height = u;
}
memcpy(t->v_fourcc, &bih->biCompression, 4);
}
}
if (t->v_width == 0) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] The width for track %u was "
"not set.\n", t->tnum);
continue;
}
if (t->v_height == 0) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] The height for track %u was "
"not set.\n", t->tnum);
continue;
}
if (t->v_dwidth == 0)
t->v_dwidth = t->v_width;
if (t->v_dheight == 0)
t->v_dheight = t->v_height;
// This track seems to be ok.
t->ok = 1;
break;
case 'a': // audio track
if (t->codec_id == NULL)
continue;
if (!strcmp(t->codec_id, MKV_A_ACM)) {
if ((t->private_data == NULL) ||
(t->private_size < sizeof(WAVEFORMATEX))) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: CodecID for track "
"%u is '" MKV_A_ACM "', "
"but there was no WAVEFORMATEX struct present. "
"Therefore we don't have a format ID to identify the audio "
"codec used.\n", t->tnum);
continue;
} else {
t->ms_compat = 1;
wfe = (WAVEFORMATEX *)t->private_data;
u = get_uint32(&wfe->nSamplesPerSec);
if (((uint32_t)t->a_sfreq) != u) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: (MS compatibility "
"mode for track %u) "
"Matroska says that there are %u samples per second, "
"but WAVEFORMATEX says that there are %u.\n", t->tnum,
(uint32_t)t->a_sfreq, u);
if (t->a_sfreq == 0.0)
t->a_sfreq = (float)u;
}
u = get_uint16(&wfe->nChannels);
if (t->a_channels != u) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: (MS "
"compatibility mode for track %u) "
"Matroska says that there are %u channels, but the "
"WAVEFORMATEX says that there are %u.\n", t->tnum,
t->a_channels, u);
if (t->a_channels == 0)
t->a_channels = u;
}
u = get_uint16(&wfe->wBitsPerSample);
if (t->a_bps != u) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: (MS "
"compatibility mode for track %u) "
"Matroska says that there are %u bits per sample, "
"but the WAVEFORMATEX says that there are %u.\n", t->tnum,
t->a_bps, u);
if (t->a_bps == 0)
t->a_bps = u;
}
t->a_formattag = get_uint16(&wfe->wFormatTag);
}
} else {
if (!strcmp(t->codec_id, MKV_A_MP3))
t->a_formattag = 0x0055;
else if (!strcmp(t->codec_id, MKV_A_AC3))
t->a_formattag = 0x2000;
else if (!strcmp(t->codec_id, MKV_A_DTS))
// uses same format tag as AC3, only supported with -hwac3
t->a_formattag = 0x2000;
else if (!strcmp(t->codec_id, MKV_A_PCM))
t->a_formattag = 0x0001;
else if (!strcmp(t->codec_id, MKV_A_AAC_2MAIN) ||
!strcmp(t->codec_id, MKV_A_AAC_2LC) ||
!strcmp(t->codec_id, MKV_A_AAC_2SSR) ||
!strcmp(t->codec_id, MKV_A_AAC_4MAIN) ||
!strcmp(t->codec_id, MKV_A_AAC_4LC) ||
!strcmp(t->codec_id, MKV_A_AAC_4SSR) ||
!strcmp(t->codec_id, MKV_A_AAC_4LTP) ||
!strcmp(t->codec_id, MKV_A_AAC_4SBR))
t->a_formattag = mmioFOURCC('M', 'P', '4', 'A');
else if (!strcmp(t->codec_id, MKV_A_VORBIS)) {
if (t->private_data == NULL) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] WARNING: CodecID for "
"track %u is '" MKV_A_VORBIS
"', but there are no header packets present.", t->tnum);
continue;
}
c = (unsigned char *)t->private_data;
if (c[0] != 2) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] Vorbis track does not "
"contain valid headers.\n");
continue;
}
offset = 1;
for (i = 0; i < 2; i++) {
length = 0;
while ((c[offset] == (unsigned char )255) &&
(length < t->private_size)) {
length += 255;
offset++;
}
if (offset >= (t->private_size - 1)) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] Vorbis track does not "
"contain valid headers.\n");
continue;
}
length += c[offset];
offset++;
t->header_sizes[i] = length;
}
t->headers[0] = &c[offset];
t->headers[1] = &c[offset + t->header_sizes[0]];
t->headers[2] = &c[offset + t->header_sizes[0] +
t->header_sizes[1]];
t->header_sizes[2] = t->private_size - offset -
t->header_sizes[0] - t->header_sizes[1];
t->a_formattag = 0xFFFE;
} else if (t->private_size >= sizeof(real_audio_v4_props_t)) {
if (!strcmp(t->codec_id, MKV_A_REAL28))
t->a_formattag = mmioFOURCC('2', '8', '_', '8');
else if (!strcmp(t->codec_id, MKV_A_REALATRC))
t->a_formattag = mmioFOURCC('a', 't', 'r', 'c');
else if (!strcmp(t->codec_id, MKV_A_REALCOOK))
t->a_formattag = mmioFOURCC('c', 'o', 'o', 'k');
else if (!strcmp(t->codec_id, MKV_A_REALDNET))
t->a_formattag = mmioFOURCC('d', 'n', 'e', 't');
else if (!strcmp(t->codec_id, MKV_A_REALSIPR))
t->a_formattag = mmioFOURCC('s', 'i', 'p', 'r');
} else {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] Unknown/unsupported audio "
"codec ID '%s' for track %u or missing/faulty private "
"codec data.\n", t->codec_id, t->tnum);
continue;
}
}
if (t->a_sfreq == 0.0) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] The sampling frequency was not "
"set for track %u.\n", t->tnum);
continue;
}
if (t->a_channels == 0) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] The number of channels was not "
"set for track %u.\n", t->tnum);
continue;
}
if (t->a_formattag == 0) {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] The audio format tag was not "
"set for track %u.\n", t->tnum);
continue;
}
// This track seems to be ok.
t->ok = 1;
break;
case 's': // Text subtitles do not need any data
t->ok = 1; // except the CodecID.
break;
default: // unknown track type!? error in demuxer...
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] Error in demux_mkv.cpp: unknown "
"demuxer type for track %u: '%c'\n", t->tnum, t->type);
continue;
}
if (t->ok)
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] Track %u seems to be ok.\n", t->tnum);
}
return 1;
}
static void free_mkv_demuxer(mkv_demuxer_t *d) {
int i;
if (d == NULL)
return;
for (i = 0; i < d->num_tracks; i++)
if (d->tracks[i] != NULL) {
if (d->tracks[i]->private_data != NULL)
free(d->tracks[i]->private_data);
if (d->tracks[i]->language != NULL)
free(d->tracks[i]->language);
free(d->tracks[i]);
}
for (i = 0; i < d->num_indexes; i++)
free(d->index[i].entries);
free(d->index);
if (d->es != NULL)
delete d->es;
if (d->saved_l1 != NULL)
delete d->saved_l1;
if (d->in != NULL)
delete d->in;
if (d->segment != NULL)
delete d->segment;
free(d);
}
static void add_index_entry(mkv_demuxer_t *d, uint32_t tnum, uint64_t filepos,
uint64_t timecode, int is_key) {
int i, found;
mkv_index_entry_t *entry;
for (i = 0, found = 0; i < d->num_indexes; i++)
if (d->index[i].tnum == tnum) {
found = 1;
break;
}
if (!found) {
d->index = (mkv_track_index_t *)realloc(d->index, (d->num_indexes + 1) *
sizeof(mkv_track_index_t));
if (d->index == NULL)
return;
i = d->num_indexes;
memset(&d->index[i], 0, sizeof(mkv_track_index_t));
d->index[i].tnum = tnum;
d->num_indexes++;
}
d->index[i].entries =
(mkv_index_entry_t *)realloc(d->index[i].entries,
(d->index[i].num_entries + 1) *
sizeof(mkv_index_entry_t));
if (d->index[i].entries == NULL)
return;
entry = &d->index[i].entries[d->index[i].num_entries];
entry->filepos = filepos;
entry->timecode = timecode;
entry->is_key = is_key;
d->index[i].num_entries++;
}
static void add_cluster_position(mkv_demuxer_t *mkv_d, int64_t position) {
mkv_d->cluster_positions = (int64_t *)realloc(mkv_d->cluster_positions,
(mkv_d->num_cluster_pos + 1) *
sizeof(int64_t));
if (mkv_d->cluster_positions != NULL) {
mkv_d->cluster_positions[mkv_d->num_cluster_pos] = position;
mkv_d->num_cluster_pos++;
} else
mkv_d->num_cluster_pos = 0;
}
#define fits_parent(l, p) (l->GetElementPosition() < \
(p->GetElementPosition() + p->ElementSize()))
static int parse_cues(mkv_demuxer_t *mkv_d) {
EbmlElement *l1 = NULL, *l2 = NULL, *l3 = NULL, *l4 = NULL, *l5 = NULL;
EbmlStream *es;
int upper_lvl_el, elements_found, i, k;
uint64_t tc_scale, filepos = 0, timecode = 0;
uint32_t tnum = 0;
mkv_index_entry_t *entry;
es = mkv_d->es;
tc_scale = mkv_d->tc_scale;
upper_lvl_el = 0;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] /---- [ parsing cues ] -----------\n");
l1 = es->FindNextElement(mkv_d->segment->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
if (l1 == NULL)
return 0;
if (!(EbmlId(*l1) == KaxCues::ClassInfos.GlobalId)) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] No KaxCues element found but but %s.\n"
"[mkv] \\---- [ parsing cues ] -----------\n", typeid(*l1).name());
return 0;
}
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] |+ found cues\n");
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el, 0xFFFFFFFFL,
true, 1);
while (l2 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l2, l1))
break;
if (EbmlId(*l2) == KaxCuePoint::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue point\n");
elements_found = 0;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l3 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l3, l2))
break;
if (EbmlId(*l3) == KaxCueTime::ClassInfos.GlobalId) {
KaxCueTime &cue_time = *static_cast<KaxCueTime *>(l3);
cue_time.ReadData(es->I_O());
timecode = uint64(cue_time) * tc_scale / 1000000 - mkv_d->first_tc;
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue time: %.3fs\n",
(float)timecode / 1000.0);
elements_found |= 1;
} else if (EbmlId(*l3) ==
KaxCueTrackPositions::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue track "
"positions\n");
l4 = es->FindNextElement(l3->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l4 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l4, l3))
break;
if (EbmlId(*l4) == KaxCueTrack::ClassInfos.GlobalId) {
KaxCueTrack &cue_track = *static_cast<KaxCueTrack *>(l4);
cue_track.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue track: "
"%u\n", uint32(cue_track));
tnum = uint32(cue_track);
elements_found |= 2;
} else if (EbmlId(*l4) ==
KaxCueClusterPosition::ClassInfos.GlobalId) {
KaxCueClusterPosition &cue_cp =
*static_cast<KaxCueClusterPosition *>(l4);
cue_cp.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue cluster "
"position: %llu\n", uint64(cue_cp));
filepos = mkv_d->segment->GetGlobalPosition(uint64_t(cue_cp));
elements_found |= 4;
} else if (EbmlId(*l4) ==
KaxCueBlockNumber::ClassInfos.GlobalId) {
KaxCueBlockNumber &cue_bn =
*static_cast<KaxCueBlockNumber *>(l4);
cue_bn.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue block "
"number: %llu\n", uint64(cue_bn));
} else if (EbmlId(*l4) ==
KaxCueCodecState::ClassInfos.GlobalId) {
KaxCueCodecState &cue_cs =
*static_cast<KaxCueCodecState *>(l4);
cue_cs.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue codec "
"state: %llu\n", uint64(cue_cs));
} else if (EbmlId(*l4) ==
KaxCueReference::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue "
"reference\n");
elements_found |= 8;
l5 = es->FindNextElement(l4->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l5 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l5, l4))
break;
if (EbmlId(*l5) == KaxCueRefTime::ClassInfos.GlobalId) {
KaxCueRefTime &cue_rt =
*static_cast<KaxCueRefTime *>(l5);
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue ref "
"time: %.3fs\n", ((float)uint64(cue_rt)) * tc_scale /
1000000000.0);
} else if (EbmlId(*l5) ==
KaxCueRefCluster::ClassInfos.GlobalId) {
KaxCueRefCluster &cue_rc =
*static_cast<KaxCueRefCluster *>(l5);
cue_rc.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue ref "
"cluster: %llu\n", uint64(cue_rc));
} else if (EbmlId(*l5) ==
KaxCueRefNumber::ClassInfos.GlobalId) {
KaxCueRefNumber &cue_rn =
*static_cast<KaxCueRefNumber *>(l5);
cue_rn.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue ref "
"number: %llu\n", uint64(cue_rn));
} else if (EbmlId(*l5) ==
KaxCueRefCodecState::ClassInfos.GlobalId) {
KaxCueRefCodecState &cue_rcs =
*static_cast<KaxCueRefCodecState *>(l5);
cue_rcs.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + found cue ref "
"codec state: %llu\n", uint64(cue_rcs));
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l5->SkipData(static_cast<EbmlStream &>(*es),
l5->Generic().Context);
delete l5;
l5 = es->FindNextElement(l4->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true);
}
} // while (l5 != NULL)
} else
upper_lvl_el = 0;
if (upper_lvl_el > 0) { // we're coming from l5
upper_lvl_el--;
delete l4;
l4 = l5;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l4->SkipData(static_cast<EbmlStream &>(*es),
l4->Generic().Context);
delete l4;
l4 = es->FindNextElement(l3->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l4;
l4 = l5;
}
} // while (l4 != NULL)
} else
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] | + unknown element, level 3: "
"%s\n", typeid(*l3).name());
if (upper_lvl_el > 0) { // we're coming from l4
upper_lvl_el--;
delete l3;
l3 = l4;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l3->SkipData(static_cast<EbmlStream &>(*es),
l3->Generic().Context);
delete l3;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l3;
l3 = l4;
}
} // while (l3 != NULL)
// Three elements must have been found in order for this to be a
// correct entry:
// 1: cue time (timecode)
// 2: cue track (tnum)
// 4: cue cluster position (filepos)
// If 8 is also set, then there was a reference element, and the
// current block is not an I frame. If 8 is not set then this is
// an I frame.
if ((elements_found & 7) == 7)
add_index_entry(mkv_d, tnum, filepos, timecode,
(elements_found & 8) ? 0 : 1);
} else
upper_lvl_el = 0;
if (upper_lvl_el > 0) { // we're coming from l3
upper_lvl_el--;
delete l2;
l2 = l3;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l2->SkipData(static_cast<EbmlStream &>(*es),
l2->Generic().Context);
delete l2;
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l2;
l2 = l3;
}
} // while (l2 != NULL)
// Debug: dump the index
for (i = 0; i < mkv_d->num_indexes; i++) {
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] Index for track %u contains %u "
"entries.\n", mkv_d->index[i].tnum, mkv_d->index[i].num_entries);
for (k = 0; k < mkv_d->index[i].num_entries; k++) {
entry = &mkv_d->index[i].entries[k];
mp_msg(MSGT_DEMUX, MSGL_DBG2, "[mkv] %d: timecode %llu, filepos %llu, "
"is key: %s\n", k, entry->timecode, entry->filepos,
entry->is_key ? "yes" : "no");
}
}
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] \\---- [ parsing cues ] -----------\n");
return 1;
}
extern "C" void print_wave_header(WAVEFORMATEX *h);
extern "C" int demux_mkv_open(demuxer_t *demuxer) {
unsigned char signature[4];
stream_t *s;
demux_packet_t *dp;
mkv_demuxer_t *mkv_d;
int upper_lvl_el, exit_loop, i;
// Elements for different levels
EbmlElement *l0 = NULL, *l1 = NULL, *l2 = NULL, *l3 = NULL, *l4 = NULL;
EbmlStream *es;
mkv_track_t *track;
sh_audio_t *sh_a;
sh_video_t *sh_v;
uint64_t seek_pos, current_pos, cues_pos;
int seek_element_is_cue;
#ifdef USE_ICONV
subcp_open();
#endif
s = demuxer->stream;
stream_seek(s, s->start_pos);
memset(signature, 0, 4);
stream_read(s, (char *)signature, 4);
if ((signature[0] != 0x1A) || (signature[1] != 0x45) ||
(signature[2] != 0xDF) || (signature[3] != 0xA3))
return 0;
stream_seek(s, s->start_pos);
try {
// structure for storing the demuxer's private data
mkv_d = (mkv_demuxer_t *)malloc(sizeof(mkv_demuxer_t));
if (mkv_d == NULL)
return 0;
memset(mkv_d, 0, sizeof(mkv_demuxer_t));
mkv_d->duration = -1.0;
// Create the interface between MPlayer's IO system and
// libmatroska's IO system.
mkv_d->in = new mpstream_io_callback(demuxer->stream);
if (mkv_d->in == NULL) {
free_mkv_demuxer(mkv_d);
return 0;
}
mpstream_io_callback &io = *static_cast<mpstream_io_callback *>(mkv_d->in);
mkv_d->es = new EbmlStream(io);
if (mkv_d->es == NULL) {
free_mkv_demuxer(mkv_d);
return 0;
}
es = mkv_d->es;
// Find the EbmlHead element. Must be the first one.
l0 = es->FindNextID(EbmlHead::ClassInfos, 0xFFFFFFFFL);
if (l0 == NULL) {
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] no head found\n");
free_mkv_demuxer(mkv_d);
return 0;
}
// Don't verify its data for now.
l0->SkipData(static_cast<EbmlStream &>(*es), l0->Generic().Context);
delete l0;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] Found the head...\n");
// Next element must be a segment
l0 = es->FindNextID(KaxSegment::ClassInfos, 0xFFFFFFFFL);
if (l0 == NULL) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] but no segment :(\n");
free_mkv_demuxer(mkv_d);
return 0;
}
if (!(EbmlId(*l0) == KaxSegment::ClassInfos.GlobalId)) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] but no segment :(\n");
free_mkv_demuxer(mkv_d);
return 0;
}
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] + a segment...\n");
mkv_d->segment = (KaxSegment *)l0;
mkv_d->tc_scale = MKVD_TIMECODESCALE;
cues_pos = 0;
upper_lvl_el = 0;
exit_loop = 0;
// We've got our segment, so let's find the tracks
l1 = es->FindNextElement(l0->Generic().Context, upper_lvl_el, 0xFFFFFFFFL,
true, 1);
while (l1 != NULL) {
if ((upper_lvl_el > 0) || exit_loop)
break;
if ((upper_lvl_el < 0) && !fits_parent(l1, l0))
break;
if (EbmlId(*l1) == KaxInfo::ClassInfos.GlobalId) {
// General info about this Matroska file
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] |+ segment information...\n");
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l2 != NULL) {
if ((upper_lvl_el > 0) || exit_loop)
break;
if ((upper_lvl_el < 0) && !fits_parent(l2, l1))
break;
if (EbmlId(*l2) == KaxTimecodeScale::ClassInfos.GlobalId) {
KaxTimecodeScale &tc_scale = *static_cast<KaxTimecodeScale *>(l2);
tc_scale.ReadData(es->I_O());
mkv_d->tc_scale = uint64(tc_scale);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + timecode scale: %llu\n",
mkv_d->tc_scale);
} else if (EbmlId(*l2) == KaxDuration::ClassInfos.GlobalId) {
KaxDuration &duration = *static_cast<KaxDuration *>(l2);
duration.ReadData(es->I_O());
mkv_d->duration = float(duration) * mkv_d->tc_scale / 1000000000.0;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + duration: %.3fs\n",
mkv_d->duration);
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l2->SkipData(static_cast<EbmlStream &>(*es),
l2->Generic().Context);
delete l2;
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
}
}
} else if (EbmlId(*l1) == KaxTracks::ClassInfos.GlobalId) {
// Yep, we've found our KaxTracks element. Now find all tracks
// contained in this segment.
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] |+ segment tracks...\n");
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l2 != NULL) {
if ((upper_lvl_el > 0) || exit_loop)
break;
if ((upper_lvl_el < 0) && !fits_parent(l2, l1))
break;
if (EbmlId(*l2) == KaxTrackEntry::ClassInfos.GlobalId) {
// We actually found a track entry :) We're happy now.
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + a track...\n");
track = new_mkv_track(mkv_d);
if (track == NULL)
return 0;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l3 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l3, l2))
break;
// Now evaluate the data belonging to this track
if (EbmlId(*l3) == KaxTrackNumber::ClassInfos.GlobalId) {
KaxTrackNumber &tnum = *static_cast<KaxTrackNumber *>(l3);
tnum.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Track number: %u\n",
uint32(tnum));
track->tnum = uint32(tnum);
if (find_track_by_num(mkv_d, track->tnum, track) != NULL)
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] | + WARNING: There's "
"more than one track with the number %u.\n",
track->tnum);
} else if (EbmlId(*l3) == KaxTrackUID::ClassInfos.GlobalId) {
KaxTrackUID &tuid = *static_cast<KaxTrackUID *>(l3);
tuid.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Track UID: %u\n",
uint32(tuid));
} else if (EbmlId(*l3) ==
KaxTrackDefaultDuration::ClassInfos.GlobalId) {
KaxTrackDefaultDuration &def_duration =
*static_cast<KaxTrackDefaultDuration *>(l3);
def_duration.ReadData(es->I_O());
if (uint64(def_duration) == 0)
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Default duration: 0");
else {
track->v_frate = 1000000000.0 / (float)uint64(def_duration);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Default duration: "
"%.3fms ( = %.3f fps)\n",
(float)uint64(def_duration) / 1000000.0,
track->v_frate);
}
} else if (EbmlId(*l3) == KaxTrackType::ClassInfos.GlobalId) {
KaxTrackType &ttype = *static_cast<KaxTrackType *>(l3);
ttype.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Track type: ");
switch (uint8(ttype)) {
case track_audio:
mp_msg(MSGT_DEMUX, MSGL_V, "Audio\n");
track->type = 'a';
break;
case track_video:
mp_msg(MSGT_DEMUX, MSGL_V, "Video\n");
track->type = 'v';
break;
case track_subtitle:
mp_msg(MSGT_DEMUX, MSGL_V, "Subtitle\n");
track->type = 's';
break;
default:
mp_msg(MSGT_DEMUX, MSGL_V, "unknown\n");
track->type = '?';
break;
}
} else if (EbmlId(*l3) == KaxTrackAudio::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Audio track\n");
l4 = es->FindNextElement(l3->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l4 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l4, l3))
break;
if (EbmlId(*l4) ==
KaxAudioSamplingFreq::ClassInfos.GlobalId) {
KaxAudioSamplingFreq &freq =
*static_cast<KaxAudioSamplingFreq*>(l4);
freq.ReadData(es->I_O());
track->a_sfreq = float(freq);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Sampling "
"frequency: %f\n", track->a_sfreq);
} else if (EbmlId(*l4) ==
KaxAudioChannels::ClassInfos.GlobalId) {
KaxAudioChannels &channels =
*static_cast<KaxAudioChannels*>(l4);
channels.ReadData(es->I_O());
track->a_channels = uint8(channels);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Channels: %u\n",
track->a_channels);
} else if (EbmlId(*l4) ==
KaxAudioBitDepth::ClassInfos.GlobalId) {
KaxAudioBitDepth &bps =
*static_cast<KaxAudioBitDepth*>(l4);
bps.ReadData(es->I_O());
track->a_bps = uint8(bps);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Bit depth: %u\n",
track->a_bps);
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l4->SkipData(static_cast<EbmlStream &>(*es),
l4->Generic().Context);
delete l4;
l4 = es->FindNextElement(l3->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true);
}
} // while (l4 != NULL)
} else if (EbmlId(*l3) == KaxTrackVideo::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Video track\n");
l4 = es->FindNextElement(l3->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l4 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l4, l3))
break;
if (EbmlId(*l4) == KaxVideoPixelWidth::ClassInfos.GlobalId) {
KaxVideoPixelWidth &width =
*static_cast<KaxVideoPixelWidth *>(l4);
width.ReadData(es->I_O());
track->v_width = uint16(width);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Pixel width: %u\n",
track->v_width);
} else if (EbmlId(*l4) ==
KaxVideoPixelHeight::ClassInfos.GlobalId) {
KaxVideoPixelHeight &height =
*static_cast<KaxVideoPixelHeight *>(l4);
height.ReadData(es->I_O());
track->v_height = uint16(height);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Pixel height: "
"%u\n", track->v_height);
} else if (EbmlId(*l4) ==
KaxVideoDisplayWidth::ClassInfos.GlobalId) {
KaxVideoDisplayWidth &width =
*static_cast<KaxVideoDisplayWidth *>(l4);
width.ReadData(es->I_O());
track->v_dwidth = uint16(width);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Display width: "
"%u\n", track->v_dwidth);
} else if (EbmlId(*l4) ==
KaxVideoDisplayHeight::ClassInfos.GlobalId) {
KaxVideoDisplayHeight &height =
*static_cast<KaxVideoDisplayHeight *>(l4);
height.ReadData(es->I_O());
track->v_dheight = uint16(height);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Display height: "
"%u\n", track->v_dheight);
} else if (EbmlId(*l4) ==
KaxVideoFrameRate::ClassInfos.GlobalId) {
// For older files.
KaxVideoFrameRate &framerate =
*static_cast<KaxVideoFrameRate *>(l4);
framerate.ReadData(es->I_O());
track->v_frate = float(framerate);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Frame rate: %f\n",
float(framerate));
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l4->SkipData(static_cast<EbmlStream &>(*es),
l4->Generic().Context);
delete l4;
l4 = es->FindNextElement(l3->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true);
}
} // while (l4 != NULL)
} else if (EbmlId(*l3) == KaxCodecID::ClassInfos.GlobalId) {
KaxCodecID &codec_id = *static_cast<KaxCodecID*>(l3);
codec_id.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Codec ID: %s\n",
string(codec_id).c_str());
track->codec_id = strdup(string(codec_id).c_str());
} else if (EbmlId(*l3) == KaxCodecPrivate::ClassInfos.GlobalId) {
KaxCodecPrivate &c_priv = *static_cast<KaxCodecPrivate*>(l3);
c_priv.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + CodecPrivate, length "
"%llu\n", c_priv.GetSize());
track->private_size = c_priv.GetSize();
if (track->private_size > 0) {
track->private_data = malloc(track->private_size);
if (track->private_data == NULL)
return 0;
memcpy(track->private_data, c_priv.GetBuffer(),
track->private_size);
}
} else if (EbmlId(*l3) ==
KaxTrackFlagDefault::ClassInfos.GlobalId) {
KaxTrackFlagDefault &f_default =
*static_cast<KaxTrackFlagDefault *>(l3);
f_default.ReadData(es->I_O());
track->default_track = uint32(f_default);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Default flag: %u\n",
track->default_track);
} else if (EbmlId(*l3) ==
KaxTrackLanguage::ClassInfos.GlobalId) {
KaxTrackLanguage &language =
*static_cast<KaxTrackLanguage *>(l3);
language.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + Language: %s\n",
string(language).c_str());
if (track->language != NULL)
free(track->language);
track->language = strdup(string(language).c_str());
} else
upper_lvl_el = 0;
if (upper_lvl_el > 0) { // we're coming from l4
upper_lvl_el--;
delete l3;
l3 = l4;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l3->SkipData(static_cast<EbmlStream &>(*es),
l3->Generic().Context);
delete l3;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l3;
l3 = l4;
}
} // while (l3 != NULL)
} else
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + unknown element@2: %s\n",
typeid(*l2).name());
if (upper_lvl_el > 0) { // we're coming from l3
upper_lvl_el--;
delete l2;
l2 = l3;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l2->SkipData(static_cast<EbmlStream &>(*es),
l2->Generic().Context);
delete l2;
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l2;
l2 = l3;
}
} // while (l2 != NULL)
} else if (EbmlId(*l1) == KaxSeekHead::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] |+ found seek head\n");
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l2 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l2, l1))
break;
if (EbmlId(*l2) == KaxSeek::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + seek entry\n");
seek_pos = 0;
seek_element_is_cue = 0;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l3 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l3, l2))
break;
if (EbmlId(*l3) == KaxSeekID::ClassInfos.GlobalId) {
binary *b;
int s;
KaxSeekID &seek_id = static_cast<KaxSeekID &>(*l3);
seek_id.ReadData(es->I_O());
b = seek_id.GetBuffer();
s = seek_id.GetSize();
EbmlId id(b, s);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + seek ID: ");
for (i = 0; i < s; i++)
mp_msg(MSGT_DEMUX, MSGL_V, "0x%02x ",
((unsigned char *)b)[i]);
mp_msg(MSGT_DEMUX, MSGL_V, "(%s)\n",
(id == KaxInfo::ClassInfos.GlobalId) ?
"KaxInfo" :
(id == KaxCluster::ClassInfos.GlobalId) ?
"KaxCluster" :
(id == KaxTracks::ClassInfos.GlobalId) ?
"KaxTracks" :
(id == KaxCues::ClassInfos.GlobalId) ?
"KaxCues" :
(id == KaxAttachments::ClassInfos.GlobalId) ?
"KaxAttachments" :
(id == KaxChapters::ClassInfos.GlobalId) ?
"KaxChapters" :
"unknown");
if (id == KaxCues::ClassInfos.GlobalId)
seek_element_is_cue = 1;
} else if (EbmlId(*l3) == KaxSeekPosition::ClassInfos.GlobalId) {
KaxSeekPosition &kax_seek_pos =
static_cast<KaxSeekPosition &>(*l3);
kax_seek_pos.ReadData(es->I_O());
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] | + seek position: %llu\n",
uint64(kax_seek_pos));
seek_pos = uint64(kax_seek_pos);
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l3->SkipData(static_cast<EbmlStream &>(*es),
l3->Generic().Context);
delete l3;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
}
} // while (l3 != NULL)
if (!mkv_d->cues_found && (seek_pos > 0) &&
seek_element_is_cue && (s->end_pos != 0))
cues_pos = mkv_d->segment->GetGlobalPosition(seek_pos);
} else
upper_lvl_el = 0;
if (upper_lvl_el > 0) { // we're coming from l3
upper_lvl_el--;
delete l2;
l2 = l3;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l2->SkipData(static_cast<EbmlStream &>(*es),
l2->Generic().Context);
delete l2;
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l2;
l2 = l3;
}
} // while (l2 != NULL)
} else if ((EbmlId(*l1) == KaxCues::ClassInfos.GlobalId) &&
!mkv_d->cues_found) {
// If the cues are up front then by all means read them now!
current_pos = io.getFilePointer();
io.setFilePointer(l1->GetElementPosition());
mkv_d->cues_found = parse_cues(mkv_d);
stream_reset(s);
io.setFilePointer(current_pos);
} else if (EbmlId(*l1) == KaxCluster::ClassInfos.GlobalId) {
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] |+ found cluster, headers are "
"parsed completely :)\n");
add_cluster_position(mkv_d, l1->GetElementPosition());
mkv_d->saved_l1 = l1;
exit_loop = 1;
} else
upper_lvl_el = 0;
if (exit_loop) // we've found the first cluster, so get out
break;
if (upper_lvl_el > 0) { // we're coming from l2
upper_lvl_el--;
delete l1;
l1 = l2;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l1->SkipData(static_cast<EbmlStream &>(*es), l1->Generic().Context);
delete l1;
l1 = es->FindNextElement(l0->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true);
} else {
delete l1;
l1 = l2;
}
} // while (l1 != NULL)
if (!exit_loop) {
free_mkv_demuxer(mkv_d);
return 0;
}
// Try to find the very first timecode (cluster timecode).
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
if ((l2 != NULL) && !upper_lvl_el &&
(EbmlId(*l2) == KaxClusterTimecode::ClassInfos.GlobalId)) {
KaxClusterTimecode &ctc = *static_cast<KaxClusterTimecode *>(l2);
ctc.ReadData(es->I_O());
mkv_d->first_tc = uint64(ctc) * mkv_d->tc_scale / 1000000;
delete l2;
} else
mkv_d->first_tc = 0;
stream_seek(s, l1->GetElementPosition());
// If we have found an entry for the cues in the meta seek data but no
// cues at the front of the file then read them now. This way the
// timecode scale will have been initialized correctly.
if (cues_pos && !mkv_d->cues_found) {
current_pos = io.getFilePointer();
io.setFilePointer(cues_pos);
mkv_d->cues_found = parse_cues(mkv_d);
if (s->eof)
stream_reset(s);
io.setFilePointer(current_pos);
}
} catch (exception &ex) {
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] caught exception\n");
return 0;
}
if (!check_track_information(mkv_d)) {
free_mkv_demuxer(mkv_d);
return 0;
}
track = NULL;
if (demuxer->video->id == -1) { // Automatically select a video track.
// Search for a video track that has the 'default' flag set.
for (i = 0; i < mkv_d->num_tracks; i++)
if ((mkv_d->tracks[i]->type == 'v') && mkv_d->tracks[i]->ok &&
mkv_d->tracks[i]->default_track) {
track = mkv_d->tracks[i];
break;
}
if (track == NULL)
// No track has the 'default' flag set - let's take the first video
// track.
for (i = 0; i < mkv_d->num_tracks; i++)
if ((mkv_d->tracks[i]->type == 'v') && mkv_d->tracks[i]->ok) {
track = mkv_d->tracks[i];
break;
}
} else if (demuxer->video->id != -2) // -2 = no video at all
track = find_track_by_num(mkv_d, demuxer->video->id, NULL);
if (track) {
BITMAPINFOHEADER *bih;
bih = (BITMAPINFOHEADER *)calloc(1, track->private_size);
if (bih == NULL) {
free_mkv_demuxer(mkv_d);
return 0;
}
if (track->ms_compat) { // MS compatibility mode
BITMAPINFOHEADER *src;
src = (BITMAPINFOHEADER *)track->private_data;
bih->biSize = get_uint32(&src->biSize);
bih->biWidth = get_uint32(&src->biWidth);
bih->biHeight = get_uint32(&src->biHeight);
bih->biPlanes = get_uint16(&src->biPlanes);
bih->biBitCount = get_uint16(&src->biBitCount);
bih->biCompression = get_uint32(&src->biCompression);
bih->biSizeImage = get_uint32(&src->biSizeImage);
bih->biXPelsPerMeter = get_uint32(&src->biXPelsPerMeter);
bih->biYPelsPerMeter = get_uint32(&src->biYPelsPerMeter);
bih->biClrUsed = get_uint32(&src->biClrUsed);
bih->biClrImportant = get_uint32(&src->biClrImportant);
memcpy((char *)bih + sizeof(BITMAPINFOHEADER),
(char *)src + sizeof(BITMAPINFOHEADER),
track->private_size - sizeof(BITMAPINFOHEADER));
} else {
bih->biSize = sizeof(BITMAPINFOHEADER);
bih->biWidth = track->v_width;
bih->biHeight = track->v_height;
bih->biBitCount = 24;
bih->biSizeImage = bih->biWidth * bih->biHeight * bih->biBitCount / 8;
if ((track->private_size >= sizeof(real_video_props_t)) &&
(!strcmp(track->codec_id, MKV_V_REALV10) ||
!strcmp(track->codec_id, MKV_V_REALV20) ||
!strcmp(track->codec_id, MKV_V_REALV30) ||
!strcmp(track->codec_id, MKV_V_REALV40))) {
unsigned char *dst, *src;
real_video_props_t *rvp;
uint32_t type2;
rvp = (real_video_props_t *)track->private_data;
src = (unsigned char *)(rvp + 1);
bih = (BITMAPINFOHEADER *)realloc(bih, sizeof(BITMAPINFOHEADER) + 12);
bih->biSize = 48;
bih->biPlanes = 1;
type2 = get_uint32_be(&rvp->type2);
if ((type2 == 0x10003000) || (type2 == 0x10003001))
bih->biCompression = mmioFOURCC('R', 'V', '1', '3');
else
bih->biCompression = mmioFOURCC('R', 'V', track->codec_id[9], '0');
dst = (unsigned char *)(bih + 1);
((unsigned int *)dst)[0] = get_uint32_be(&rvp->type1);
((unsigned int *)dst)[1] = type2;
if ((bih->biCompression <= 0x30335652) &&
(type2 >= 0x20200002)) {
// read secondary WxH for the cmsg24[] (see vd_realvid.c)
((unsigned short *)(bih + 1))[4] = 4 * (unsigned short)src[0];
((unsigned short *)(bih + 1))[5] = 4 * (unsigned short)src[1];
} else
memset(&dst[8], 0, 4);
track->realmedia = true;
} else {
mp_msg(MSGT_DEMUX, MSGL_WARN, "[mkv] Unknown/unsupported CodecID "
"(%s) or missing/bad CodecPrivate data (track %u).\n",
track->codec_id, track->tnum);
demuxer->video->id = -2;
}
}
if (demuxer->video->id != -2) {
mp_msg(MSGT_DEMUX, MSGL_INFO, "[mkv] Will play video track %u\n",
track->tnum);
sh_v = new_sh_video(demuxer, track->tnum);
sh_v->bih = bih;
sh_v->format = sh_v->bih->biCompression;
if (track->v_frate == 0.0)
track->v_frate = 25.0;
sh_v->fps = track->v_frate;
sh_v->frametime = 1 / track->v_frate;
sh_v->disp_w = track->v_width;
sh_v->disp_h = track->v_height;
sh_v->aspect = (float)track->v_dwidth / (float)track->v_dheight;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] Aspect: %f\n", sh_v->aspect);
demuxer->video->id = track->tnum;
demuxer->video->sh = sh_v;
sh_v->ds = demuxer->video;
mkv_d->video = track;
} else
free(bih);
} else {
mp_msg(MSGT_DEMUX, MSGL_INFO, "[mkv] No video track found/wanted.\n");
demuxer->video->id = -2;
}
track = NULL;
if (demuxer->audio->id == -1) { // Automatically select an audio track.
// check if the user specified an audio language
if (audio_lang != NULL) {
track = find_track_by_language(mkv_d, audio_lang, NULL, 'a');
}
if (track == NULL)
// no audio language specified, or language not found
// Search for an audio track that has the 'default' flag set.
for (i = 0; i < mkv_d->num_tracks; i++)
if ((mkv_d->tracks[i]->type == 'a') && mkv_d->tracks[i]->ok &&
mkv_d->tracks[i]->default_track) {
track = mkv_d->tracks[i];
break;
}
if (track == NULL)
// No track has the 'default' flag set - let's take the first audio
// track.
for (i = 0; i < mkv_d->num_tracks; i++)
if ((mkv_d->tracks[i]->type == 'a') && mkv_d->tracks[i]->ok) {
track = mkv_d->tracks[i];
break;
}
} else if (demuxer->audio->id != -2) // -2 = no audio at all
track = find_track_by_num(mkv_d, demuxer->audio->id, NULL);
if (track) {
mp_msg(MSGT_DEMUX, MSGL_INFO, "[mkv] Will play audio track %u\n",
track->tnum);
sh_a = new_sh_audio(demuxer, track->tnum);
demuxer->audio->id = track->tnum;
demuxer->audio->sh = sh_a;
sh_a->ds = demuxer->audio;
mkv_d->audio = track;
if (track->ms_compat) {
sh_a->wf = (WAVEFORMATEX *)calloc(1, track->private_size);
if (sh_a->wf == NULL) {
free_mkv_demuxer(mkv_d);
return 0;
}
memcpy(sh_a->wf, track->private_data, track->private_size);
} else {
sh_a->wf = (WAVEFORMATEX *)calloc(1, sizeof(WAVEFORMATEX));
if (sh_a->wf == NULL) {
free_mkv_demuxer(mkv_d);
return 0;
}
}
sh_a->format = track->a_formattag;
sh_a->wf->wFormatTag = track->a_formattag;
sh_a->channels = track->a_channels;
sh_a->wf->nChannels = track->a_channels;
sh_a->samplerate = (uint32_t)track->a_sfreq;
sh_a->wf->nSamplesPerSec = (uint32_t)track->a_sfreq;
sh_a->samplesize = track->a_bps / 8;
if (!strcmp(track->codec_id, MKV_A_MP3)) {
sh_a->wf->nAvgBytesPerSec = 16000;
sh_a->wf->nBlockAlign = 1152;
sh_a->wf->wBitsPerSample = 0;
sh_a->samplesize = 0;
} else if (!strcmp(track->codec_id, MKV_A_AC3)) {
sh_a->wf->nAvgBytesPerSec = 16000;
sh_a->wf->nBlockAlign = 1536;
sh_a->wf->wBitsPerSample = 0;
sh_a->samplesize = 0;
} else if (!strcmp(track->codec_id, MKV_A_PCM)) {
sh_a->wf->nAvgBytesPerSec = sh_a->channels * sh_a->samplerate * 2;
sh_a->wf->nBlockAlign = sh_a->wf->nAvgBytesPerSec;
sh_a->wf->wBitsPerSample = track->a_bps;
} else if (track->a_formattag == mmioFOURCC('M', 'P', '4', 'A')) {
int profile, srate_idx;
sh_a->wf->nAvgBytesPerSec = 16000;
sh_a->wf->nBlockAlign = 1024;
sh_a->wf->wBitsPerSample = 0;
sh_a->samplesize = 0;
// Recreate the 'private data' which faad2 uses in its initialization.
// A_AAC/MPEG2/MAIN
// 0123456789012345
if (!strcmp(&track->codec_id[12], "MAIN"))
profile = 0;
else if (!strcmp(&track->codec_id[12], "LC"))
profile = 1;
else if (!strcmp(&track->codec_id[12], "SSR"))
profile = 2;
else
profile = 3;
if (92017 <= sh_a->samplerate)
srate_idx = 0;
else if (75132 <= sh_a->samplerate)
srate_idx = 1;
else if (55426 <= sh_a->samplerate)
srate_idx = 2;
else if (46009 <= sh_a->samplerate)
srate_idx = 3;
else if (37566 <= sh_a->samplerate)
srate_idx = 4;
else if (27713 <= sh_a->samplerate)
srate_idx = 5;
else if (23004 <= sh_a->samplerate)
srate_idx = 6;
else if (18783 <= sh_a->samplerate)
srate_idx = 7;
else if (13856 <= sh_a->samplerate)
srate_idx = 8;
else if (11502 <= sh_a->samplerate)
srate_idx = 9;
else if (9391 <= sh_a->samplerate)
srate_idx = 10;
else
srate_idx = 11;
sh_a->codecdata = (unsigned char *)calloc(1, 2);
sh_a->codecdata_len = 2;
sh_a->codecdata[0] = ((profile + 1) << 3) | ((srate_idx & 0xe) >> 1);
sh_a->codecdata[1] = ((srate_idx & 0x1) << 7) | (track->a_channels << 3);
} else if (!strcmp(track->codec_id, MKV_A_VORBIS)) {
for (i = 0; i < 3; i++) {
dp = new_demux_packet(track->header_sizes[i]);
memcpy(dp->buffer, track->headers[i], track->header_sizes[i]);
dp->pts = 0;
dp->flags = 0;
ds_add_packet(demuxer->audio, dp);
}
} else if ((track->private_size >= sizeof(real_audio_v4_props_t)) &&
!strncmp(track->codec_id, MKV_A_REALATRC, 7)) {
// Common initialization for all RealAudio codecs
real_audio_v4_props_t *ra4p;
real_audio_v5_props_t *ra5p;
unsigned char *src;
int codecdata_length, version;
ra4p = (real_audio_v4_props_t *)track->private_data;
ra5p = (real_audio_v5_props_t *)track->private_data;
sh_a->wf->wBitsPerSample = sh_a->samplesize * 8;
sh_a->wf->nAvgBytesPerSec = 0; // FIXME !?
sh_a->wf->nBlockAlign = get_uint16_be(&ra4p->frame_size);
version = get_uint16_be(&ra4p->version1);
if (version == 4) {
src = (unsigned char *)(ra4p + 1);
src += src[0] + 1;
src += src[0] + 1;
} else
src = (unsigned char *)(ra5p + 1);
src += 3;
if (version == 5)
src++;
codecdata_length = get_uint32_be(src);
src += 4;
sh_a->wf->cbSize = 10 + codecdata_length;
sh_a->wf = (WAVEFORMATEX *)realloc(sh_a->wf, sizeof(WAVEFORMATEX) +
sh_a->wf->cbSize);
((short *)(sh_a->wf + 1))[0] = get_uint16_be(&ra4p->sub_packet_size);
((short *)(sh_a->wf + 1))[1] = get_uint16_be(&ra4p->sub_packet_h);
((short *)(sh_a->wf + 1))[2] = get_uint16_be(&ra4p->flavor);
((short *)(sh_a->wf + 1))[3] = get_uint32_be(&ra4p->coded_frame_size);
((short *)(sh_a->wf + 1))[4] = codecdata_length;
memcpy(((char *)(sh_a->wf + 1)) + 10, src, codecdata_length);
track->realmedia = true;
}
} else {
mp_msg(MSGT_DEMUX, MSGL_INFO, "[mkv] No audio track found/wanted.\n");
demuxer->audio->id = -2;
}
// DO NOT automatically select a subtitle track and behave like DVD
// playback: only show subtitles if the user explicitely wants them.
track = NULL;
if (demuxer->sub->id >= 0)
track = find_track_by_num(mkv_d, demuxer->sub->id, NULL);
else if (dvdsub_lang != NULL)
track = find_track_by_language(mkv_d, dvdsub_lang, NULL);
if (track) {
if (strcmp(track->codec_id, MKV_S_TEXTASCII) &&
strcmp(track->codec_id, MKV_S_TEXTUTF8))
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] Subtitle type '%s' is not "
"supported. Track will not be displayed.\n", track->codec_id);
else {
mp_msg(MSGT_DEMUX, MSGL_INFO, "[mkv] Will display subtitle track %u\n",
track->tnum);
mkv_d->subs_track = track;
if (!mkv_d->subs.text[0]) {
for (i = 0; i < SUB_MAX_TEXT; i++)
mkv_d->subs.text[i] = (char *)malloc(256);
if (!strcmp(track->codec_id, MKV_S_TEXTUTF8))
sub_utf8 = 1; // Force UTF-8 conversion.
} else
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] File does not contain a "
"subtitle track with the id %u.\n", demuxer->sub->id);
}
}
if (s->end_pos == 0)
demuxer->seekable = 0;
else {
demuxer->movi_start = s->start_pos;
demuxer->movi_end = s->end_pos;
demuxer->seekable = 1;
}
demuxer->priv = mkv_d;
return 1;
}
// Taken from demux_real.c. Thanks to the original developpers :)
#define SKIP_BITS(n) buffer <<= n
#define SHOW_BITS(n) ((buffer) >> (32 - (n)))
static float real_fix_timestamp(mkv_track_t *track, unsigned char *s,
int timestamp) {
float v_pts;
uint32_t buffer = (s[0] << 24) + (s[1] << 16) + (s[2] << 8) + s[3];
int kf = timestamp;
int pict_type;
int orig_kf;
if (!strcmp(track->codec_id, MKV_V_REALV30) ||
!strcmp(track->codec_id, MKV_V_REALV40)) {
if (!strcmp(track->codec_id, MKV_V_REALV30)) {
SKIP_BITS(3);
pict_type = SHOW_BITS(2);
SKIP_BITS(2 + 7);
}else{
SKIP_BITS(1);
pict_type = SHOW_BITS(2);
SKIP_BITS(2 + 7 + 3);
}
kf = SHOW_BITS(13); // kf= 2*SHOW_BITS(12);
orig_kf = kf;
if (pict_type <= 1) {
// I frame, sync timestamps:
track->rv_kf_base = timestamp - kf;
mp_msg(MSGT_DEMUX, MSGL_V, "\nTS: base=%08X\n", track->rv_kf_base);
kf = timestamp;
} else {
// P/B frame, merge timestamps:
int tmp = timestamp - track->rv_kf_base;
kf |= tmp & (~0x1fff); // combine with packet timestamp
if (kf < (tmp - 4096)) // workaround wrap-around problems
kf += 8192;
else if (kf > (tmp + 4096))
kf -= 8192;
kf += track->rv_kf_base;
}
if (pict_type != 3) { // P || I frame -> swap timestamps
int tmp = kf;
kf = track->rv_kf_pts;
track->rv_kf_pts = tmp;
}
mp_msg(MSGT_DEMUX, MSGL_V, "\nTS: %08X -> %08X (%04X) %d %02X %02X %02X "
"%02X %5d\n", timestamp, kf, orig_kf, pict_type, s[0], s[1], s[2],
s[3], kf - (int)(1000.0 * track->rv_pts));
}
v_pts = kf * 0.001f;
track->rv_pts = v_pts;
return v_pts;
}
static void handle_realvideo(demuxer_t *demuxer, DataBuffer &data,
bool keyframe, int &found_data) {
unsigned char *p;
dp_hdr_t *hdr;
int chunks, isize;
mkv_demuxer_t *mkv_d;
demux_stream_t *ds;
demux_packet_t *dp;
mkv_d = (mkv_demuxer_t *)demuxer->priv;
ds = demuxer->video;
p = (unsigned char *)data.Buffer();
chunks = p[0];
isize = data.Size() - 1 - (chunks + 1) * 8;
dp = new_demux_packet(sizeof(dp_hdr_t) + isize + 8 * (chunks + 1));
memcpy(&dp->buffer[sizeof(dp_hdr_t)], &p[1 + (chunks + 1) * 8], isize);
memcpy(&dp->buffer[sizeof(dp_hdr_t) + isize], &p[1], (chunks + 1) * 8);
hdr = (dp_hdr_t *)dp->buffer;
hdr->len = isize;
hdr->chunks = chunks;
hdr->timestamp = (int)(mkv_d->last_pts * 1000);
hdr->chunktab = sizeof(dp_hdr_t) + isize;
dp->len = sizeof(dp_hdr_t) + isize + 8 * (chunks + 1);
if (mkv_d->v_skip_to_keyframe) {
dp->pts = mkv_d->last_pts;
mkv_d->video->rv_kf_base = 0;
mkv_d->video->rv_kf_pts = hdr->timestamp;
} else
dp->pts = real_fix_timestamp(mkv_d->video, &dp->buffer[sizeof(dp_hdr_t)],
hdr->timestamp);
dp->pos = demuxer->filepos;
dp->flags = keyframe ? 0x10 : 0;
ds_add_packet(ds, dp);
found_data++;
}
static void handle_realaudio(demuxer_t *demuxer, DataBuffer &data,
bool keyframe, int &found_data) {
mkv_demuxer_t *mkv_d;
demux_packet_t *dp;
mkv_d = (mkv_demuxer_t *)demuxer->priv;
dp = new_demux_packet(data.Size());
memcpy(dp->buffer, data.Buffer(), data.Size());
if ((mkv_d->audio->ra_pts == mkv_d->last_pts) &&
!mkv_d->a_skip_to_keyframe)
dp->pts = 0;
else
dp->pts = mkv_d->last_pts;
mkv_d->audio->ra_pts = mkv_d->last_pts;
dp->pos = demuxer->filepos;
dp->flags = keyframe ? 0x10 : 0;
ds_add_packet(demuxer->audio, dp);
found_data++;
}
extern "C" int demux_mkv_fill_buffer(demuxer_t *d) {
demux_packet_t *dp;
demux_stream_t *ds;
mkv_demuxer_t *mkv_d;
int upper_lvl_el, exit_loop, found_data, i, delete_element, elements_found;
// Elements for different levels
EbmlElement *l0 = NULL, *l1 = NULL, *l2 = NULL, *l3 = NULL;
EbmlStream *es;
KaxBlock *block;
int64_t block_duration, block_ref1, block_ref2;
bool use_this_block;
float current_pts;
mkv_d = (mkv_demuxer_t *)d->priv;
es = mkv_d->es;
l0 = mkv_d->segment;
// End of stream
if (mkv_d->saved_l1 == NULL)
return 0;
exit_loop = 0;
upper_lvl_el = 0;
l1 = mkv_d->saved_l1;
mkv_d->saved_l1 = NULL;
found_data = 0;
try {
// The idea is not to handle a complete KaxCluster with each call to
// demux_mkv_fill_buffer because those might be rather big.
while (l1 != NULL) {
if ((upper_lvl_el > 0) || exit_loop)
break;
if ((upper_lvl_el < 0) && !fits_parent(l1, l0))
break;
if (EbmlId(*l1) == KaxCluster::ClassInfos.GlobalId) {
mkv_d->cluster = (KaxCluster *)l1;
if (found_data) {
mkv_d->saved_l1 = l1;
break;
}
if (mkv_d->saved_l2 != NULL) {
l2 = mkv_d->saved_l2;
mkv_d->saved_l2 = NULL;
} else
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l2 != NULL) {
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l2, l1))
break;
// Handle at least one data packets in one call to
// demux_mkv_fill_buffer - but abort if we have found that.
if (found_data >= 1) {
mkv_d->saved_l2 = l2;
mkv_d->saved_l1 = l1;
exit_loop = 1;
break;
}
if (EbmlId(*l2) == KaxClusterTimecode::ClassInfos.GlobalId) {
KaxClusterTimecode &ctc = *static_cast<KaxClusterTimecode *>(l2);
ctc.ReadData(es->I_O());
mkv_d->cluster_tc = uint64(ctc);
#if LIBEBML_VERSION >= 000404
mkv_d->cluster->InitTimecode(mkv_d->cluster_tc, mkv_d->tc_scale);
#else
mkv_d->cluster->InitTimecode(mkv_d->cluster_tc);
#endif // LIBEBML_VERSION
} else if (EbmlId(*l2) == KaxBlockGroup::ClassInfos.GlobalId) {
block = NULL;
block_duration = -1;
block_ref1 = 0;
block_ref2 = 0;
elements_found = 0;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
while (l3 != NULL) {
delete_element = 1;
if (upper_lvl_el > 0)
break;
if ((upper_lvl_el < 0) && !fits_parent(l3, l2))
break;
if (EbmlId(*l3) == KaxBlock::ClassInfos.GlobalId) {
block = static_cast<KaxBlock *>(l3);
block->ReadData(es->I_O());
block->SetParent(*mkv_d->cluster);
delete_element = 0;
elements_found |= 1;
} else if (EbmlId(*l3) ==
KaxBlockDuration::ClassInfos.GlobalId) {
KaxBlockDuration &duration =
*static_cast<KaxBlockDuration *>(l3);
duration.ReadData(es->I_O());
block_duration = (int64_t)uint64(duration);
elements_found |= 2;
} else if (EbmlId(*l3) ==
KaxReferenceBlock::ClassInfos.GlobalId) {
KaxReferenceBlock &ref =
*static_cast<KaxReferenceBlock *>(l3);
ref.ReadData(es->I_O());
if ((elements_found & 4) == 0) {
block_ref1 = int64(ref);
elements_found |= 4;
} else {
block_ref2 = int64(ref);
elements_found |= 8;
}
} else
upper_lvl_el = 0;
if (upper_lvl_el == 0) {
l3->SkipData(static_cast<EbmlStream &>(*es),
l3->Generic().Context);
if (delete_element)
delete l3;
l3 = es->FindNextElement(l2->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
}
} // while (l3 != NULL)
if (block != NULL) {
// Clear the subtitles if they're obsolete now.
if ((mkv_d->clear_subs_at > 0) &&
(mkv_d->clear_subs_at <=
(block->GlobalTimecode() / 1000000 - mkv_d->first_tc))) {
mkv_d->subs.lines = 0;
vo_sub = &mkv_d->subs;
vo_osd_changed(OSDTYPE_SUBTITLE);
mkv_d->clear_subs_at = 0;
}
ds = NULL;
if ((mkv_d->video != NULL) &&
(mkv_d->video->tnum == block->TrackNum()))
ds = d->video;
else if ((mkv_d->audio != NULL) &&
(mkv_d->audio->tnum == block->TrackNum()))
ds = d->audio;
use_this_block = true;
current_pts = (float)(block->GlobalTimecode() / 1000000.0 -
mkv_d->first_tc) / 1000.0;
if (ds == d->audio) {
if (mkv_d->a_skip_to_keyframe &&
((elements_found & 4) == 4))
use_this_block = false;
else if (mkv_d->v_skip_to_keyframe)
use_this_block = false;
} else if ((current_pts * 1000) < mkv_d->skip_to_timecode)
use_this_block = false;
else if (ds == d->video) {
if (mkv_d->v_skip_to_keyframe &&
((elements_found & 4) == 4))
use_this_block = false;
} else if ((mkv_d->subs_track != NULL) &&
(mkv_d->subs_track->tnum == block->TrackNum())) {
if (!mkv_d->v_skip_to_keyframe)
handle_subtitles(d, block, block_duration);
use_this_block = false;
} else
use_this_block = false;
if (use_this_block) {
mkv_d->last_pts = current_pts;
d->filepos = mkv_d->in->getFilePointer();
mkv_d->last_filepos = d->filepos;
for (i = 0; i < (int)block->NumberFrames(); i++) {
DataBuffer &data = block->GetBuffer(i);
if ((ds == d->video) && mkv_d->video->realmedia)
handle_realvideo(d, data, (elements_found & 4) == 0,
found_data);
else if ((ds == d->audio) && mkv_d->audio->realmedia)
handle_realaudio(d, data, (elements_found & 4) == 0,
found_data);
else {
dp = new_demux_packet(data.Size());
memcpy(dp->buffer, data.Buffer(), data.Size());
dp->flags = (elements_found & 4) == 0 ? 1 : 0;
dp->pts = mkv_d->last_pts;
ds_add_packet(ds, dp);
found_data++;
}
}
if (ds == d->video) {
mkv_d->v_skip_to_keyframe = false;
mkv_d->skip_to_timecode = 0;
}
if (ds == d->audio)
mkv_d->a_skip_to_keyframe = false;
}
delete block;
} // block != NULL
} else
upper_lvl_el = 0;
if (upper_lvl_el > 0) { // we're coming from l3
upper_lvl_el--;
delete l2;
l2 = l3;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l2->SkipData(static_cast<EbmlStream &>(*es),
l2->Generic().Context);
delete l2;
l2 = es->FindNextElement(l1->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
} else {
delete l2;
l2 = l3;
}
} // while (l2 != NULL)
} else if (EbmlId(*l1) == KaxCues::ClassInfos.GlobalId)
return 0;
else
upper_lvl_el = 0;
if (exit_loop)
break;
if (upper_lvl_el > 0) { // we're coming from l2
upper_lvl_el--;
delete l1;
l1 = l2;
if (upper_lvl_el > 0)
break;
} else if (upper_lvl_el == 0) {
l1->SkipData(static_cast<EbmlStream &>(*es), l1->Generic().Context);
delete l1;
l1 = es->FindNextElement(l0->Generic().Context, upper_lvl_el,
0xFFFFFFFFL, true, 1);
if ((l1 != NULL) && (EbmlId(*l1) == KaxCluster::ClassInfos.GlobalId))
add_cluster_position(mkv_d, l1->GetElementPosition());
} else {
delete l1;
l1 = l2;
}
} // while (l1 != NULL)
} catch (exception ex) {
mp_msg(MSGT_DEMUX, MSGL_ERR, "[mkv] exception caught\n");
return 0;
}
if (found_data)
return 1;
return 0;
}
extern "C" void resync_audio_stream(sh_audio_t *sh_audio);
extern "C" void demux_mkv_seek(demuxer_t *demuxer, float rel_seek_secs,
int flags) {
int i, k, upper_lvl_el;
mkv_demuxer_t *mkv_d = (mkv_demuxer_t *)demuxer->priv;
int64_t target_timecode, target_filepos = 0, min_diff, diff, current_pos;
int64_t cluster_pos;
mkv_track_index_t *index;
mkv_index_entry_t *entry;
EbmlElement *l1;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] SEEK, relss: %.3f, flags: %d\n",
rel_seek_secs, flags);
if (!mkv_d->cues_found && !mkv_d->cues_searched) {
// We've not found an index so far. So let's skip over all level 1
// elements until we either hit another segment, the end of the file
// or - suprise - some cues.
current_pos = mkv_d->in->getFilePointer();
// Skip the data but do not delete the element! This is our current
// cluster, and we need it later on in demux_mkv_fill_buffer.
l1 = mkv_d->saved_l1;
l1->SkipData(static_cast<EbmlStream &>(*mkv_d->es), l1->Generic().Context);
l1 = mkv_d->es->FindNextElement(mkv_d->segment->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true, 1);
while (l1 != NULL) {
if (upper_lvl_el)
break;
if (EbmlId(*l1) == KaxCues::ClassInfos.GlobalId) {
mkv_d->in->setFilePointer(l1->GetElementPosition());
delete l1;
mkv_d->cues_found = parse_cues(mkv_d);
break;
} else {
if (EbmlId(*l1) == KaxCluster::ClassInfos.GlobalId)
add_cluster_position(mkv_d, l1->GetElementPosition());
l1->SkipData(static_cast<EbmlStream &>(*mkv_d->es),
l1->Generic().Context);
delete l1;
l1 = mkv_d->es->FindNextElement(mkv_d->segment->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true, 1);
}
}
if (demuxer->stream->eof)
stream_reset(demuxer->stream);
mkv_d->in->setFilePointer(current_pos);
mkv_d->cues_searched = 1;
}
if (!(flags & 2)) { // Time in secs
if (flags & 1) // Absolute seek
target_timecode = 0;
else // Relative seek
target_timecode = (int64_t)(mkv_d->last_pts * 1000.0);
target_timecode += (int64_t)(rel_seek_secs * 1000.0);
if (target_timecode < 0)
target_timecode = 0;
min_diff = 0xFFFFFFFL;
// Let's find the entry in the index with the smallest difference
// to the wanted timecode.
entry = NULL;
for (i = 0; i < mkv_d->num_indexes; i++)
if (mkv_d->index[i].tnum == mkv_d->video->tnum) {
index = &mkv_d->index[i];
for (k = 0; k < index->num_entries; k++) {
if (!index->entries[k].is_key)
continue;
diff = target_timecode - (int64_t)index->entries[k].timecode;
if (diff < 0)
diff *= -1;
if (diff < min_diff) {
min_diff = diff;
entry = & index->entries[k];
}
}
break;
}
if (mkv_d->saved_l1 != NULL)
delete mkv_d->saved_l1;
if (mkv_d->saved_l2 != NULL) {
delete mkv_d->saved_l2;
mkv_d->saved_l2 = NULL;
}
if (entry != NULL) { // We've found an entry.
mkv_d->in->setFilePointer(entry->filepos);
upper_lvl_el = 0;
mkv_d->saved_l1 =
mkv_d->es->FindNextElement(mkv_d->segment->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true, 1);
} else { // We've not found an entry --> no index?
target_filepos = (int64_t)(target_timecode * mkv_d->last_filepos /
(mkv_d->last_pts * 1000.0));
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] No index entry found. Calculated "
"filepos %lld. Old timecode %lld.\n", target_filepos,
(int64_t)(mkv_d->last_pts * 1000.0));
// Let's find the nearest cluster so that libebml does not have to
// do so much work.
cluster_pos = 0;
min_diff = 0x0FFFFFFFL;
for (i = 0; i < mkv_d->num_cluster_pos; i++) {
diff = mkv_d->cluster_positions[i] - target_filepos;
if (rel_seek_secs < 0) {
if ((diff > 0) && (diff < min_diff)) {
cluster_pos = mkv_d->cluster_positions[i];
min_diff = diff;
}
} else if ((diff < 0 ? -1 * diff : diff) < min_diff) {
cluster_pos = mkv_d->cluster_positions[i];
min_diff = diff < 0 ? -1 * diff : diff;
}
}
if (min_diff != 0x0FFFFFFFL) {
target_filepos = cluster_pos;
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] New target_filepos because of "
"cluster: %lld.\n", target_filepos);
}
if (target_filepos >= demuxer->movi_end)
return;
mkv_d->in->setFilePointer(target_filepos);
upper_lvl_el = 0;
mkv_d->saved_l1 =
mkv_d->es->FindNextElement(mkv_d->segment->Generic().Context,
upper_lvl_el, 0xFFFFFFFFL, true, 1);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] seek result: target_timecode %lld, "
"did not find an entry. Calculated target_filspos: %lld\n",
target_timecode, target_filepos);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] seek found %p (%s).\n",
mkv_d->saved_l1, mkv_d->saved_l1 == NULL ? "null" :
typeid(*mkv_d->saved_l1).name());
}
if (mkv_d->video != NULL)
mkv_d->v_skip_to_keyframe = true;
if (rel_seek_secs > 0.0)
mkv_d->skip_to_timecode = target_timecode;
mkv_d->a_skip_to_keyframe = true;
demux_mkv_fill_buffer(demuxer);
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] New timecode: %lld\n",
(int64_t)(mkv_d->last_pts * 1000.0));
mkv_d->subs.lines = 0;
vo_sub = &mkv_d->subs;
vo_osd_changed(OSDTYPE_SUBTITLE);
mkv_d->clear_subs_at = 0;
if(demuxer->audio->sh != NULL)
resync_audio_stream((sh_audio_t *)demuxer->audio->sh);
} else
mp_msg(MSGT_DEMUX, MSGL_V, "[mkv] seek unsupported flags\n");
}
extern "C" void demux_close_mkv(demuxer_t *demuxer) {
mkv_demuxer_t *mkv_d = (mkv_demuxer_t *)demuxer->priv;
free_mkv_demuxer(mkv_d);
#ifdef USE_ICONV
subcp_close();
#endif
}
extern "C" int demux_mkv_control(demuxer_t *demuxer, int cmd, void *arg) {
mkv_demuxer_t *mkv_d = (mkv_demuxer_t *)demuxer->priv;
switch (cmd) {
case DEMUXER_CTRL_GET_TIME_LENGTH:
if (mkv_d->duration == -1.0)
return DEMUXER_CTRL_DONTKNOW;
*((unsigned long *)arg) = (unsigned long)mkv_d->duration;
return DEMUXER_CTRL_OK;
case DEMUXER_CTRL_GET_PERCENT_POS:
if (mkv_d->duration == -1.0) {
if (demuxer->movi_start == demuxer->movi_end)
return DEMUXER_CTRL_DONTKNOW;
*((int *)arg) =
(int)((demuxer->filepos - demuxer->movi_start) /
((demuxer->movi_end - demuxer->movi_start) / 100));
return DEMUXER_CTRL_OK;
}
*((int *)arg) = (int)(100 * mkv_d->last_pts / mkv_d->duration);
return DEMUXER_CTRL_OK;
default:
return DEMUXER_CTRL_NOTIMPL;
}
}
#endif /* HAVE_MATROSKA */
Reference in New Issue View Git Blame Copy Permalink