mirror of https://github.com/odrling/Aegisub
FFMS2: Update Haali's matroska parser
Originally committed to SVN as r2885.
This commit is contained in:
parent
2f7b62d206
commit
fad9a58240
|
@ -1,31 +1,5 @@
|
||||||
/*
|
/*
|
||||||
* Copyright (c) 2004-2006 Mike Matsnev. All Rights Reserved.
|
* Copyright (c) 2004-2009 Mike Matsnev. All Rights Reserved.
|
||||||
*
|
|
||||||
* Redistribution and use in source and binary forms, with or without
|
|
||||||
* modification, are permitted provided that the following conditions
|
|
||||||
* are met:
|
|
||||||
*
|
|
||||||
* 1. Redistributions of source code must retain the above copyright
|
|
||||||
* notice immediately at the beginning of the file, without modification,
|
|
||||||
* this list of conditions, and the following disclaimer.
|
|
||||||
* 2. Redistributions in binary form must reproduce the above copyright
|
|
||||||
* notice, this list of conditions and the following disclaimer in the
|
|
||||||
* documentation and/or other materials provided with the distribution.
|
|
||||||
* 3. Absolutely no warranty of function or purpose is made by the author
|
|
||||||
* Mike Matsnev.
|
|
||||||
*
|
|
||||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
|
||||||
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
|
||||||
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
|
||||||
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
|
||||||
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
|
||||||
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
||||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
||||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
||||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
|
||||||
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
||||||
*
|
|
||||||
* $Id: MatroskaParser.c,v 1.61 2006/10/28 10:39:45 mike Exp $
|
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
@ -50,7 +24,7 @@
|
||||||
#include "MatroskaParser.h"
|
#include "MatroskaParser.h"
|
||||||
|
|
||||||
#ifdef MATROSKA_COMPRESSION_SUPPORT
|
#ifdef MATROSKA_COMPRESSION_SUPPORT
|
||||||
#include "zlib.h"
|
#include <zlib.h>
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#define EBML_VERSION 1
|
#define EBML_VERSION 1
|
||||||
|
@ -67,7 +41,7 @@
|
||||||
#define MAXCLUSTER (64*1048576)
|
#define MAXCLUSTER (64*1048576)
|
||||||
#define MAXFRAME (4*1048576)
|
#define MAXFRAME (4*1048576)
|
||||||
|
|
||||||
#ifdef _WIN32
|
#ifdef WIN32
|
||||||
#define LL(x) x##i64
|
#define LL(x) x##i64
|
||||||
#define ULL(x) x##ui64
|
#define ULL(x) x##ui64
|
||||||
#else
|
#else
|
||||||
|
@ -96,8 +70,7 @@ static char *mystrdup(struct InputStream *is,const char *src) {
|
||||||
return dst;
|
return dst;
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifndef HAVE_STRLCPY
|
static void mystrlcpy(char *dst,const char *src,unsigned size) {
|
||||||
static void strlcpy(char *dst,const char *src,unsigned size) {
|
|
||||||
unsigned i;
|
unsigned i;
|
||||||
|
|
||||||
for (i=0;i+1<size && src[i];++i)
|
for (i=0;i+1<size && src[i];++i)
|
||||||
|
@ -105,7 +78,6 @@ static void strlcpy(char *dst,const char *src,unsigned size) {
|
||||||
if (i<size)
|
if (i<size)
|
||||||
dst[i] = 0;
|
dst[i] = 0;
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
struct Cue {
|
struct Cue {
|
||||||
ulonglong Time;
|
ulonglong Time;
|
||||||
|
@ -240,7 +212,7 @@ static void myvsnprintf_uint_impl(char **pdest,char *de,int width,int zero,
|
||||||
int rem = (int)(val % base);
|
int rem = (int)(val % base);
|
||||||
val = val / base;
|
val = val / base;
|
||||||
|
|
||||||
*--np = rem < 10 ? rem + '0' : rem - 10 + letter;
|
*--np = (char)(rem < 10 ? rem + '0' : rem - 10 + letter);
|
||||||
}
|
}
|
||||||
|
|
||||||
rw = (int)(tmp - np + sizeof(tmp) - 1);
|
rw = (int)(tmp - np + sizeof(tmp) - 1);
|
||||||
|
@ -687,7 +659,7 @@ static ulonglong readVLUIntImp(MatroskaFile *mf,int *mask) {
|
||||||
|
|
||||||
c = readch(mf);
|
c = readch(mf);
|
||||||
if (c == EOF)
|
if (c == EOF)
|
||||||
return EOF;
|
return 0; // XXX should errorjmp()?
|
||||||
|
|
||||||
if (c == 0)
|
if (c == 0)
|
||||||
errorjmp(mf,"Invalid first byte of EBML integer: 0");
|
errorjmp(mf,"Invalid first byte of EBML integer: 0");
|
||||||
|
@ -1078,6 +1050,8 @@ static void parseSegmentInfo(MatroskaFile *mf,ulonglong toplen) {
|
||||||
}
|
}
|
||||||
|
|
||||||
static void parseFirstCluster(MatroskaFile *mf,ulonglong toplen) {
|
static void parseFirstCluster(MatroskaFile *mf,ulonglong toplen) {
|
||||||
|
ulonglong end = filepos(mf) + toplen;
|
||||||
|
|
||||||
mf->seen.Cluster = 1;
|
mf->seen.Cluster = 1;
|
||||||
mf->firstTimecode = 0;
|
mf->firstTimecode = 0;
|
||||||
|
|
||||||
|
@ -1089,7 +1063,7 @@ static void parseFirstCluster(MatroskaFile *mf,ulonglong toplen) {
|
||||||
readVLUInt(mf); // track number
|
readVLUInt(mf); // track number
|
||||||
mf->firstTimecode += readSInt(mf, 2);
|
mf->firstTimecode += readSInt(mf, 2);
|
||||||
|
|
||||||
skipbytes(mf,start + toplen - filepos(mf));
|
skipbytes(mf,end - filepos(mf));
|
||||||
return;
|
return;
|
||||||
case 0xa0: // BlockGroup
|
case 0xa0: // BlockGroup
|
||||||
FOREACH(mf,len)
|
FOREACH(mf,len)
|
||||||
|
@ -1097,7 +1071,7 @@ static void parseFirstCluster(MatroskaFile *mf,ulonglong toplen) {
|
||||||
readVLUInt(mf); // track number
|
readVLUInt(mf); // track number
|
||||||
mf->firstTimecode += readSInt(mf,2);
|
mf->firstTimecode += readSInt(mf,2);
|
||||||
|
|
||||||
skipbytes(mf,start + toplen - filepos(mf));
|
skipbytes(mf,end - filepos(mf));
|
||||||
return;
|
return;
|
||||||
ENDFOR(mf);
|
ENDFOR(mf);
|
||||||
break;
|
break;
|
||||||
|
@ -1424,7 +1398,7 @@ static void parseTrackEntry(MatroskaFile *mf,ulonglong toplen) {
|
||||||
// handle compressed CodecPrivate
|
// handle compressed CodecPrivate
|
||||||
if (t.CompEnabled && t.CompMethod == COMP_ZLIB && (CompScope & 2) && cplen > 0) {
|
if (t.CompEnabled && t.CompMethod == COMP_ZLIB && (CompScope & 2) && cplen > 0) {
|
||||||
z_stream zs;
|
z_stream zs;
|
||||||
char tmp[64], *ncp;
|
Bytef tmp[64], *ncp;
|
||||||
int code;
|
int code;
|
||||||
uLong ncplen;
|
uLong ncplen;
|
||||||
|
|
||||||
|
@ -1432,7 +1406,7 @@ static void parseTrackEntry(MatroskaFile *mf,ulonglong toplen) {
|
||||||
if (inflateInit(&zs) != Z_OK)
|
if (inflateInit(&zs) != Z_OK)
|
||||||
errorjmp(mf, "inflateInit failed");
|
errorjmp(mf, "inflateInit failed");
|
||||||
|
|
||||||
zs.next_in = cp;
|
zs.next_in = (Bytef *)cp;
|
||||||
zs.avail_in = cplen;
|
zs.avail_in = cplen;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
|
@ -1450,7 +1424,7 @@ static void parseTrackEntry(MatroskaFile *mf,ulonglong toplen) {
|
||||||
|
|
||||||
inflateReset(&zs);
|
inflateReset(&zs);
|
||||||
|
|
||||||
zs.next_in = cp;
|
zs.next_in = (Bytef *)cp;
|
||||||
zs.avail_in = cplen;
|
zs.avail_in = cplen;
|
||||||
zs.next_out = ncp;
|
zs.next_out = ncp;
|
||||||
zs.avail_out = ncplen;
|
zs.avail_out = ncplen;
|
||||||
|
@ -1460,7 +1434,7 @@ static void parseTrackEntry(MatroskaFile *mf,ulonglong toplen) {
|
||||||
|
|
||||||
inflateEnd(&zs);
|
inflateEnd(&zs);
|
||||||
|
|
||||||
cp = ncp;
|
cp = (char *)ncp;
|
||||||
cplen = ncplen;
|
cplen = ncplen;
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
@ -1491,7 +1465,7 @@ static void parseTrackEntry(MatroskaFile *mf,ulonglong toplen) {
|
||||||
}
|
}
|
||||||
if (cslen) {
|
if (cslen) {
|
||||||
tp->CompMethodPrivate = (char *)(tp+1) + cplen;
|
tp->CompMethodPrivate = (char *)(tp+1) + cplen;
|
||||||
tp->CompMethodPrivateSize = cslen;
|
tp->CompMethodPrivateSize = (unsigned)cslen;
|
||||||
memcpy(tp->CompMethodPrivate, cs, cslen);
|
memcpy(tp->CompMethodPrivate, cs, cslen);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1982,80 +1956,79 @@ static void parsePointers(MatroskaFile *mf) {
|
||||||
static void parseSegment(MatroskaFile *mf,ulonglong toplen) {
|
static void parseSegment(MatroskaFile *mf,ulonglong toplen) {
|
||||||
ulonglong nextpos;
|
ulonglong nextpos;
|
||||||
unsigned nSeekHeads = 0, dontstop = 0;
|
unsigned nSeekHeads = 0, dontstop = 0;
|
||||||
|
jmp_buf jb;
|
||||||
|
|
||||||
// we want to read data until we find a seekhead or a trackinfo
|
memcpy(&jb,&mf->jb,sizeof(jb));
|
||||||
FOREACH(mf,toplen)
|
|
||||||
case 0x114d9b74: // SeekHead
|
|
||||||
if (mf->flags & MKVF_AVOID_SEEKS) {
|
|
||||||
skipbytes(mf,len);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
nextpos = filepos(mf) + len;
|
if (setjmp(mf->jb))
|
||||||
do {
|
mf->flags &= ~MPF_ERROR;
|
||||||
mf->pSeekHead = 0;
|
else {
|
||||||
parseSeekHead(mf,len);
|
// we want to read data until we find a seekhead or a trackinfo
|
||||||
++nSeekHeads;
|
FOREACH(mf,toplen)
|
||||||
if (mf->pSeekHead) { // this is possibly a chained SeekHead
|
case 0x114d9b74: // SeekHead
|
||||||
seek(mf,mf->pSeekHead);
|
if (mf->flags & MKVF_AVOID_SEEKS) {
|
||||||
id = readID(mf);
|
skipbytes(mf,len);
|
||||||
if (id==EOF) // chained SeekHead points to EOF?
|
break;
|
||||||
break;
|
}
|
||||||
if (id != 0x114d9b74) // chained SeekHead doesnt point to a SeekHead?
|
|
||||||
break;
|
nextpos = filepos(mf) + len;
|
||||||
len = readSize(mf);
|
do {
|
||||||
} else if (mf->pSegmentInfo && mf->pTracks && mf->pCues && mf->pCluster) { // we have pointers to all key elements
|
mf->pSeekHead = 0;
|
||||||
// XXX EVIL HACK
|
parseSeekHead(mf,len);
|
||||||
// Some software doesnt index tags via SeekHead, so we continue
|
++nSeekHeads;
|
||||||
// reading the segment after the second SeekHead
|
if (mf->pSeekHead) { // this is possibly a chained SeekHead
|
||||||
if (mf->pTags || nSeekHeads<2 || filepos(mf)>=start+toplen) {
|
seek(mf,mf->pSeekHead);
|
||||||
parsePointers(mf);
|
id = readID(mf);
|
||||||
return;
|
if (id==EOF) // chained SeekHead points to EOF?
|
||||||
|
break;
|
||||||
|
if (id != 0x114d9b74) // chained SeekHead doesnt point to a SeekHead?
|
||||||
|
break;
|
||||||
|
len = readSize(mf);
|
||||||
}
|
}
|
||||||
// reset nextpos pointer to current position
|
} while (mf->pSeekHead && nSeekHeads < 10);
|
||||||
nextpos = filepos(mf);
|
seek(mf,nextpos); // resume reading segment
|
||||||
dontstop = 1;
|
break;
|
||||||
}
|
case 0x1549a966: // SegmentInfo
|
||||||
} while (mf->pSeekHead);
|
mf->pSegmentInfo = cur;
|
||||||
seek(mf,nextpos); // resume reading segment
|
parseSegmentInfo(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1549a966: // SegmentInfo
|
case 0x1f43b675: // Cluster
|
||||||
mf->pSegmentInfo = cur;
|
if (!mf->pCluster)
|
||||||
parseSegmentInfo(mf,len);
|
mf->pCluster = cur;
|
||||||
break;
|
if (mf->seen.Cluster)
|
||||||
case 0x1f43b675: // Cluster
|
skipbytes(mf,len);
|
||||||
if (!mf->pCluster)
|
else
|
||||||
mf->pCluster = cur;
|
parseFirstCluster(mf,len);
|
||||||
if (mf->seen.Cluster)
|
break;
|
||||||
skipbytes(mf,len);
|
case 0x1654ae6b: // Tracks
|
||||||
else
|
mf->pTracks = cur;
|
||||||
parseFirstCluster(mf,len);
|
parseTracks(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1654ae6b: // Tracks
|
case 0x1c53bb6b: // Cues
|
||||||
mf->pTracks = cur;
|
mf->pCues = cur;
|
||||||
parseTracks(mf,len);
|
parseCues(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1c53bb6b: // Cues
|
case 0x1941a469: // Attachments
|
||||||
mf->pCues = cur;
|
mf->pAttachments = cur;
|
||||||
parseCues(mf,len);
|
parseAttachments(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1941a469: // Attachments
|
case 0x1043a770: // Chapters
|
||||||
mf->pAttachments = cur;
|
mf->pChapters = cur;
|
||||||
parseAttachments(mf,len);
|
parseChapters(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1043a770: // Chapters
|
case 0x1254c367: // Tags
|
||||||
mf->pChapters = cur;
|
mf->pTags = cur;
|
||||||
parseChapters(mf,len);
|
parseTags(mf,len);
|
||||||
break;
|
break;
|
||||||
case 0x1254c367: // Tags
|
ENDFOR1(mf);
|
||||||
mf->pTags = cur;
|
// if we have pointers to all key elements
|
||||||
parseTags(mf,len);
|
if (!dontstop && mf->pSegmentInfo && mf->pTracks && mf->pCluster)
|
||||||
break;
|
break;
|
||||||
ENDFOR1(mf);
|
ENDFOR2();
|
||||||
// if we have pointers to all key elements
|
}
|
||||||
if (!dontstop && mf->pSegmentInfo && mf->pTracks && mf->pCluster)
|
|
||||||
break;
|
memcpy(&mf->jb,&jb,sizeof(jb));
|
||||||
ENDFOR2();
|
|
||||||
parsePointers(mf);
|
parsePointers(mf);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2095,7 +2068,6 @@ static void parseBlockGroup(MatroskaFile *mf,ulonglong toplen,ulonglong timecode
|
||||||
ulonglong v;
|
ulonglong v;
|
||||||
ulonglong duration = 0;
|
ulonglong duration = 0;
|
||||||
ulonglong dpos;
|
ulonglong dpos;
|
||||||
unsigned add_id = 0;
|
|
||||||
struct QueueEntry *qe,*qf = NULL;
|
struct QueueEntry *qe,*qf = NULL;
|
||||||
unsigned char have_duration = 0, have_block = 0;
|
unsigned char have_duration = 0, have_block = 0;
|
||||||
unsigned char gap = 0;
|
unsigned char gap = 0;
|
||||||
|
@ -2152,10 +2124,10 @@ found:
|
||||||
errorjmp(mf,"Unexpected EOF while reading Block flags");
|
errorjmp(mf,"Unexpected EOF while reading Block flags");
|
||||||
|
|
||||||
if (blockex)
|
if (blockex)
|
||||||
ref = !(c & 0x80);
|
ref = (unsigned char)!(c & 0x80);
|
||||||
|
|
||||||
gap = c & 0x1;
|
gap = (unsigned char)(c & 0x1);
|
||||||
lacing = (c >> 1) & 3;
|
lacing = (unsigned char)((c >> 1) & 3);
|
||||||
|
|
||||||
if (lacing) {
|
if (lacing) {
|
||||||
c = readch(mf);
|
c = readch(mf);
|
||||||
|
@ -2762,7 +2734,7 @@ MatroskaFile *mkv_OpenEx(InputStream *io,
|
||||||
{
|
{
|
||||||
MatroskaFile *mf = io->memalloc(io,sizeof(*mf));
|
MatroskaFile *mf = io->memalloc(io,sizeof(*mf));
|
||||||
if (mf == NULL) {
|
if (mf == NULL) {
|
||||||
strlcpy(err_msg,"Out of memory",msgsize);
|
mystrlcpy(err_msg,"Out of memory",msgsize);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2776,7 +2748,7 @@ MatroskaFile *mkv_OpenEx(InputStream *io,
|
||||||
seek(mf,base);
|
seek(mf,base);
|
||||||
parseFile(mf);
|
parseFile(mf);
|
||||||
} else { // parser error
|
} else { // parser error
|
||||||
strlcpy(err_msg,mf->errmsg,msgsize);
|
mystrlcpy(err_msg,mf->errmsg,msgsize);
|
||||||
mkv_Close(mf);
|
mkv_Close(mf);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
@ -2917,7 +2889,7 @@ void mkv_Seek(MatroskaFile *mf,ulonglong timecode,unsigned flags) {
|
||||||
|
|
||||||
mkv_SetTrackMask(mf,mf->trackMask);
|
mkv_SetTrackMask(mf,mf->trackMask);
|
||||||
|
|
||||||
if (flags & MKVF_SEEK_TO_PREV_KEYFRAME) {
|
if (flags & (MKVF_SEEK_TO_PREV_KEYFRAME | MKVF_SEEK_TO_PREV_KEYFRAME_STRICT)) {
|
||||||
// we do this in two stages
|
// we do this in two stages
|
||||||
// a. find the last keyframes before the require position
|
// a. find the last keyframes before the require position
|
||||||
// b. seek to them
|
// b. seek to them
|
||||||
|
@ -2932,7 +2904,7 @@ void mkv_Seek(MatroskaFile *mf,ulonglong timecode,unsigned flags) {
|
||||||
EmptyQueues(mf);
|
EmptyQueues(mf);
|
||||||
|
|
||||||
mf->readPosition = mf->Cues[j].Position + mf->pSegment;
|
mf->readPosition = mf->Cues[j].Position + mf->pSegment;
|
||||||
mf->tcCluster = mf->Cues[j].Time / mf->Seg.TimecodeScale;
|
mf->tcCluster = mf->Cues[j].Time;
|
||||||
|
|
||||||
for (;;) {
|
for (;;) {
|
||||||
if ((ret = fillQueues(mf,0)) < 0 || ret == RBRESYNC)
|
if ((ret = fillQueues(mf,0)) < 0 || ret == RBRESYNC)
|
||||||
|
@ -2940,7 +2912,7 @@ void mkv_Seek(MatroskaFile *mf,ulonglong timecode,unsigned flags) {
|
||||||
|
|
||||||
// drain queues until we get to the required timecode
|
// drain queues until we get to the required timecode
|
||||||
for (n=0;n<mf->nTracks;++n) {
|
for (n=0;n<mf->nTracks;++n) {
|
||||||
if (mf->Queues[n].head && mf->Queues[n].head->Start<timecode) {
|
if (mf->Queues[n].head && (mf->Queues[n].head->Start<timecode || (m_seendf[n] == 0 && m_kftime[n] == MAXU64))) {
|
||||||
if (IS_DELTA(mf->Queues[n].head))
|
if (IS_DELTA(mf->Queues[n].head))
|
||||||
m_seendf[n] = 1;
|
m_seendf[n] = 1;
|
||||||
else
|
else
|
||||||
|
@ -2956,9 +2928,14 @@ void mkv_Seek(MatroskaFile *mf,ulonglong timecode,unsigned flags) {
|
||||||
QFree(mf,QGet(&mf->Queues[n]));
|
QFree(mf,QGet(&mf->Queues[n]));
|
||||||
}
|
}
|
||||||
|
|
||||||
if (mf->Queues[n].head && (mf->Tracks[n]->Type != TT_AUDIO || mf->Queues[n].head->Start<=timecode))
|
// We've drained the queue, so the frame at head is the next one past the requered point.
|
||||||
if (!IS_DELTA(mf->Queues[n].head))
|
// In strict mode we are done, but when seeking is not strict we use the head frame
|
||||||
m_kftime[n] = mf->Queues[n].head->Start;
|
// if it's not an audio track (we accept preroll within a frame for audio), and the head frame
|
||||||
|
// is a keyframe
|
||||||
|
if (!(flags & MKVF_SEEK_TO_PREV_KEYFRAME_STRICT))
|
||||||
|
if (mf->Queues[n].head && (mf->Tracks[n]->Type != TT_AUDIO || mf->Queues[n].head->Start<=timecode))
|
||||||
|
if (!IS_DELTA(mf->Queues[n].head))
|
||||||
|
m_kftime[n] = mf->Queues[n].head->Start;
|
||||||
}
|
}
|
||||||
|
|
||||||
for (n=0;n<mf->nTracks;++n)
|
for (n=0;n<mf->nTracks;++n)
|
||||||
|
@ -2987,7 +2964,7 @@ again:;
|
||||||
EmptyQueues(mf);
|
EmptyQueues(mf);
|
||||||
|
|
||||||
mf->readPosition = mf->Cues[j].Position + mf->pSegment;
|
mf->readPosition = mf->Cues[j].Position + mf->pSegment;
|
||||||
mf->tcCluster = mf->Cues[j].Time / mf->Seg.TimecodeScale;
|
mf->tcCluster = mf->Cues[j].Time;
|
||||||
|
|
||||||
for (mask=0;;) {
|
for (mask=0;;) {
|
||||||
if ((ret = fillQueues(mf,mask)) < 0 || ret == RBRESYNC)
|
if ((ret = fillQueues(mf,mask)) < 0 || ret == RBRESYNC)
|
||||||
|
@ -3182,30 +3159,30 @@ CompressedStream *cs_Create(/* in */ MatroskaFile *mf,
|
||||||
|
|
||||||
ti = mkv_GetTrackInfo(mf, tracknum);
|
ti = mkv_GetTrackInfo(mf, tracknum);
|
||||||
if (ti == NULL) {
|
if (ti == NULL) {
|
||||||
strlcpy(errormsg, "No such track.", msgsize);
|
mystrlcpy(errormsg, "No such track.", msgsize);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!ti->CompEnabled) {
|
if (!ti->CompEnabled) {
|
||||||
strlcpy(errormsg, "Track is not compressed.", msgsize);
|
mystrlcpy(errormsg, "Track is not compressed.", msgsize);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ti->CompMethod != COMP_ZLIB) {
|
if (ti->CompMethod != COMP_ZLIB) {
|
||||||
strlcpy(errormsg, "Unsupported compression method.", msgsize);
|
mystrlcpy(errormsg, "Unsupported compression method.", msgsize);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
cs = mf->cache->memalloc(mf->cache,sizeof(*cs));
|
cs = mf->cache->memalloc(mf->cache,sizeof(*cs));
|
||||||
if (cs == NULL) {
|
if (cs == NULL) {
|
||||||
strlcpy(errormsg, "Ouf of memory.", msgsize);
|
mystrlcpy(errormsg, "Ouf of memory.", msgsize);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
memset(&cs->zs,0,sizeof(cs->zs));
|
memset(&cs->zs,0,sizeof(cs->zs));
|
||||||
code = inflateInit(&cs->zs);
|
code = inflateInit(&cs->zs);
|
||||||
if (code != Z_OK) {
|
if (code != Z_OK) {
|
||||||
strlcpy(errormsg, "ZLib error.", msgsize);
|
mystrlcpy(errormsg, "ZLib error.", msgsize);
|
||||||
mf->cache->memfree(mf->cache,cs);
|
mf->cache->memfree(mf->cache,cs);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
@ -3261,7 +3238,7 @@ int cs_ReadData(CompressedStream *cs,char *buffer,unsigned bufsize)
|
||||||
cs->decoded_ptr += todo;
|
cs->decoded_ptr += todo;
|
||||||
} else {
|
} else {
|
||||||
/* setup output buffer */
|
/* setup output buffer */
|
||||||
cs->zs.next_out = cs->decoded_buffer;
|
cs->zs.next_out = (Bytef *)cs->decoded_buffer;
|
||||||
cs->zs.avail_out = sizeof(cs->decoded_buffer);
|
cs->zs.avail_out = sizeof(cs->decoded_buffer);
|
||||||
|
|
||||||
/* try to read more data */
|
/* try to read more data */
|
||||||
|
@ -3271,11 +3248,11 @@ int cs_ReadData(CompressedStream *cs,char *buffer,unsigned bufsize)
|
||||||
todo = sizeof(cs->frame_buffer);
|
todo = sizeof(cs->frame_buffer);
|
||||||
|
|
||||||
if (cs->mf->cache->read(cs->mf->cache, cs->frame_pos, cs->frame_buffer, todo) != (int)todo) {
|
if (cs->mf->cache->read(cs->mf->cache, cs->frame_pos, cs->frame_buffer, todo) != (int)todo) {
|
||||||
strlcpy(cs->errmsg, "File read failed", sizeof(cs->errmsg));
|
mystrlcpy(cs->errmsg, "File read failed", sizeof(cs->errmsg));
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
cs->zs.next_in = cs->frame_buffer;
|
cs->zs.next_in = (Bytef *)cs->frame_buffer;
|
||||||
cs->zs.avail_in = todo;
|
cs->zs.avail_in = todo;
|
||||||
|
|
||||||
cs->frame_pos += todo;
|
cs->frame_pos += todo;
|
||||||
|
@ -3285,7 +3262,7 @@ int cs_ReadData(CompressedStream *cs,char *buffer,unsigned bufsize)
|
||||||
/* try to decode more data */
|
/* try to decode more data */
|
||||||
code = inflate(&cs->zs,Z_NO_FLUSH);
|
code = inflate(&cs->zs,Z_NO_FLUSH);
|
||||||
if (code != Z_OK && code != Z_STREAM_END) {
|
if (code != Z_OK && code != Z_STREAM_END) {
|
||||||
strlcpy(cs->errmsg, "ZLib error.", sizeof(cs->errmsg));
|
mystrlcpy(cs->errmsg, "ZLib error.", sizeof(cs->errmsg));
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -1,31 +1,5 @@
|
||||||
/*
|
/*
|
||||||
* Copyright (c) 2004-2006 Mike Matsnev. All Rights Reserved.
|
* Copyright (c) 2004-2009 Mike Matsnev. All Rights Reserved.
|
||||||
*
|
|
||||||
* Redistribution and use in source and binary forms, with or without
|
|
||||||
* modification, are permitted provided that the following conditions
|
|
||||||
* are met:
|
|
||||||
*
|
|
||||||
* 1. Redistributions of source code must retain the above copyright
|
|
||||||
* notice immediately at the beginning of the file, without modification,
|
|
||||||
* this list of conditions, and the following disclaimer.
|
|
||||||
* 2. Redistributions in binary form must reproduce the above copyright
|
|
||||||
* notice, this list of conditions and the following disclaimer in the
|
|
||||||
* documentation and/or other materials provided with the distribution.
|
|
||||||
* 3. Absolutely no warranty of function or purpose is made by the author
|
|
||||||
* Mike Matsnev.
|
|
||||||
*
|
|
||||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
|
||||||
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
|
||||||
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
|
||||||
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
|
||||||
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
|
||||||
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
||||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
||||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
||||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
|
||||||
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
||||||
*
|
|
||||||
* $Id: MatroskaParser.h,v 1.19 2006/03/11 10:57:13 mike Exp $
|
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
@ -41,8 +15,6 @@
|
||||||
* system
|
* system
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include <stddef.h>
|
|
||||||
|
|
||||||
#ifdef MPDLLBUILD
|
#ifdef MPDLLBUILD
|
||||||
#define X __declspec(dllexport)
|
#define X __declspec(dllexport)
|
||||||
#else
|
#else
|
||||||
|
@ -130,13 +102,12 @@ struct TrackInfo {
|
||||||
void *CompMethodPrivate;
|
void *CompMethodPrivate;
|
||||||
unsigned CompMethodPrivateSize;
|
unsigned CompMethodPrivateSize;
|
||||||
unsigned MaxBlockAdditionID;
|
unsigned MaxBlockAdditionID;
|
||||||
struct {
|
|
||||||
unsigned int Enabled:1;
|
unsigned int Enabled:1;
|
||||||
unsigned int Default:1;
|
unsigned int Default:1;
|
||||||
unsigned int Lacing:1;
|
unsigned int Lacing:1;
|
||||||
unsigned int DecodeAll:1;
|
unsigned int DecodeAll:1;
|
||||||
unsigned int CompEnabled:1;
|
unsigned int CompEnabled:1;
|
||||||
};
|
|
||||||
|
|
||||||
union {
|
union {
|
||||||
struct {
|
struct {
|
||||||
|
@ -150,9 +121,8 @@ struct TrackInfo {
|
||||||
unsigned int CropL, CropT, CropR, CropB;
|
unsigned int CropL, CropT, CropR, CropB;
|
||||||
unsigned int ColourSpace;
|
unsigned int ColourSpace;
|
||||||
MKFLOAT GammaValue;
|
MKFLOAT GammaValue;
|
||||||
struct {
|
|
||||||
unsigned int Interlaced:1;
|
unsigned int Interlaced:1;
|
||||||
};
|
|
||||||
} Video;
|
} Video;
|
||||||
struct {
|
struct {
|
||||||
MKFLOAT SamplingFreq;
|
MKFLOAT SamplingFreq;
|
||||||
|
@ -235,14 +205,12 @@ struct Chapter {
|
||||||
|
|
||||||
char SegmentUID[16];
|
char SegmentUID[16];
|
||||||
|
|
||||||
struct {
|
unsigned int Hidden:1;
|
||||||
unsigned int Hidden:1;
|
unsigned int Enabled:1;
|
||||||
unsigned int Enabled:1;
|
|
||||||
|
|
||||||
// Editions
|
// Editions
|
||||||
unsigned int Default:1;
|
unsigned int Default:1;
|
||||||
unsigned int Ordered:1;
|
unsigned int Ordered:1;
|
||||||
};
|
|
||||||
};
|
};
|
||||||
|
|
||||||
typedef struct Chapter Chapter;
|
typedef struct Chapter Chapter;
|
||||||
|
@ -321,7 +289,8 @@ X ulonglong mkv_GetSegmentTop(MatroskaFile *mf);
|
||||||
* all tracks are set to return EOF
|
* all tracks are set to return EOF
|
||||||
* on next read
|
* on next read
|
||||||
*/
|
*/
|
||||||
#define MKVF_SEEK_TO_PREV_KEYFRAME 1
|
#define MKVF_SEEK_TO_PREV_KEYFRAME 1
|
||||||
|
#define MKVF_SEEK_TO_PREV_KEYFRAME_STRICT 2
|
||||||
|
|
||||||
X void mkv_Seek(/* in */ MatroskaFile *mf,
|
X void mkv_Seek(/* in */ MatroskaFile *mf,
|
||||||
/* in */ ulonglong timecode /* in ns */,
|
/* in */ ulonglong timecode /* in ns */,
|
||||||
|
|
|
@ -233,6 +233,12 @@ Note that --enable-w32threads is required for multithreaded decoding to work.
|
||||||
|
|
||||||
<h2>Changes</h2>
|
<h2>Changes</h2>
|
||||||
<ul>
|
<ul>
|
||||||
|
<li>2.00 beta 8<ul>
|
||||||
|
<li>Updated Haali's matroska parser code to the latest version</li>
|
||||||
|
<li>Updated FFmpeg to rev X</li>
|
||||||
|
</ul></li>
|
||||||
|
|
||||||
|
|
||||||
<li>2.00 beta 7<ul>
|
<li>2.00 beta 7<ul>
|
||||||
<li>Using ffms2 as a library no longer requires an installed pixfmt.h from libavutil, it is however still required to compile ffms2 and the avisynth plugin part</li>
|
<li>Using ffms2 as a library no longer requires an installed pixfmt.h from libavutil, it is however still required to compile ffms2 and the avisynth plugin part</li>
|
||||||
<li>Fix a crash bug at the end of files with b-frames in beta 6 caused by uninitialized null packets</li>
|
<li>Fix a crash bug at the end of files with b-frames in beta 6 caused by uninitialized null packets</li>
|
||||||
|
|
|
@ -28,7 +28,7 @@ extern "C" {
|
||||||
|
|
||||||
using namespace std;
|
using namespace std;
|
||||||
|
|
||||||
#define VERBOSE
|
//#define VERBOSE
|
||||||
|
|
||||||
static int FFMS_CC UpdateProgress(int State, int64_t Current, int64_t Total, void *Private) {
|
static int FFMS_CC UpdateProgress(int State, int64_t Current, int64_t Total, void *Private) {
|
||||||
|
|
||||||
|
@ -141,6 +141,6 @@ int main(int argc, char *argv[]) {
|
||||||
for (int i = 0; i < sizeof(md5sum); i++)
|
for (int i = 0; i < sizeof(md5sum); i++)
|
||||||
cout << static_cast<unsigned>(md5sum[i]);
|
cout << static_cast<unsigned>(md5sum[i]);
|
||||||
cout << endl;
|
cout << endl;
|
||||||
// cin >> argc;
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
|
@ -563,7 +563,7 @@ AVFrameLite *MatroskaVideoSource::GetFrame(int n, char *ErrorMsg, unsigned MsgSi
|
||||||
bool HasSeeked = false;
|
bool HasSeeked = false;
|
||||||
|
|
||||||
if (n < CurrentFrame || Frames.FindClosestKeyFrame(n) > CurrentFrame) {
|
if (n < CurrentFrame || Frames.FindClosestKeyFrame(n) > CurrentFrame) {
|
||||||
mkv_Seek(MF, Frames[n].DTS, MKVF_SEEK_TO_PREV_KEYFRAME);
|
mkv_Seek(MF, Frames[n].DTS, MKVF_SEEK_TO_PREV_KEYFRAME_STRICT);
|
||||||
avcodec_flush_buffers(CodecContext);
|
avcodec_flush_buffers(CodecContext);
|
||||||
HasSeeked = true;
|
HasSeeked = true;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue