From de03d58545ced64606947dccd877341a127a4a69 Mon Sep 17 00:00:00 2001 From: aurel Date: Mon, 9 Feb 2009 22:00:57 +0000 Subject: change internal real video packetizing format to the more straight forward one see [MPlayer-dev-eng] [PATCH] cleanup/uniformize real video packetizing patch blessed by Roberto git-svn-id: svn://svn.mplayerhq.hu/mplayer/trunk@28503 b3059339-0415-0410-9bf9-f77b7e298cf2 --- libmpdemux/demux_real.c | 91 ++++++++++++++++++++++--------------------------- 1 file changed, 41 insertions(+), 50 deletions(-) (limited to 'libmpdemux/demux_real.c') diff --git a/libmpdemux/demux_real.c b/libmpdemux/demux_real.c index b6b54f7c03..32b7acc11d 100644 --- a/libmpdemux/demux_real.c +++ b/libmpdemux/demux_real.c @@ -28,6 +28,7 @@ Video codecs: (supported by RealPlayer8 for Linux) #include "config.h" #include "mp_msg.h" #include "help_mp.h" +#include "mpbswap.h" #include "stream/stream.h" #include "demuxer.h" @@ -474,8 +475,9 @@ void hexdump(char *, unsigned long); #define SKIP_BITS(n) buffer<<=n #define SHOW_BITS(n) ((buffer)>>(32-(n))) -static double real_fix_timestamp(real_priv_t* priv, unsigned char* s, unsigned int timestamp, double frametime, unsigned int format){ +double real_fix_timestamp(unsigned char *buf, unsigned int timestamp, unsigned int format, int64_t *kf_base, int *kf_pts, double *pts){ double v_pts; + unsigned char *s = buf + 1 + (*buf+1)*8; uint32_t buffer= (s[0]<<24) + (s[1]<<16) + (s[2]<<8) + s[3]; unsigned int kf=timestamp; int pict_type; @@ -497,29 +499,29 @@ static double real_fix_timestamp(real_priv_t* priv, unsigned char* s, unsigned i // if(pict_type==0) if(pict_type<=1){ // I frame, sync timestamps: - priv->kf_base=(int64_t)timestamp-kf; - mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: base=%08"PRIX64"\n",priv->kf_base); + *kf_base=(int64_t)timestamp-kf; + mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: base=%08"PRIX64"\n",*kf_base); kf=timestamp; } else { // P/B frame, merge timestamps: - int64_t tmp=(int64_t)timestamp-priv->kf_base; + int64_t tmp=(int64_t)timestamp-*kf_base; kf|=tmp&(~0x1fff); // combine with packet timestamp if(kftmp+4096) kf-=8192; - kf+=priv->kf_base; + kf+=*kf_base; } if(pict_type != 3){ // P || I frame -> swap timestamps unsigned int tmp=kf; - kf=priv->kf_pts; - priv->kf_pts=tmp; + kf=*kf_pts; + *kf_pts=tmp; // if(kf<=tmp) kf=0; } - mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: %08X -> %08X (%04X) %d %02X %02X %02X %02X %5u\n",timestamp,kf,orig_kf,pict_type,s[0],s[1],s[2],s[3],kf-(unsigned int)(1000.0*priv->v_pts)); + mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: %08X -> %08X (%04X) %d %02X %02X %02X %02X %5u\n",timestamp,kf,orig_kf,pict_type,s[0],s[1],s[2],s[3],pts?kf-(unsigned int)(*pts*1000.0):0); } #endif v_pts=kf*0.001f; -// if(v_ptsv_pts || !kf) v_pts=priv->v_pts+frametime; - priv->v_pts=v_pts; +// if(pts && (v_pts<*pts || !kf)) v_pts=*pts+frametime; + if(pts) *pts=v_pts; return v_pts; } @@ -530,6 +532,29 @@ typedef struct dp_hdr_s { uint32_t chunktab; // offset to chunk offset array } dp_hdr_t; +static void queue_video_packet(real_priv_t *priv, demux_stream_t *ds, demux_packet_t *dp) +{ + dp_hdr_t hdr = *(dp_hdr_t*)dp->buffer; + unsigned char *tmp = malloc(8*(1+hdr.chunks)); + memcpy(tmp, dp->buffer+hdr.chunktab, 8*(1+hdr.chunks)); + memmove(dp->buffer+1+8*(1+hdr.chunks), dp->buffer+sizeof(dp_hdr_t), hdr.len); + memcpy(dp->buffer+1, tmp, 8*(1+hdr.chunks)); + *dp->buffer = (uint8_t)hdr.chunks; + free(tmp); + + if(priv->video_after_seek){ + priv->kf_base = 0; + priv->kf_pts = hdr.timestamp; + priv->video_after_seek = 0; + } + if(hdr.len >= 3) /* this check may be useless */ + dp->pts = real_fix_timestamp(dp->buffer, hdr.timestamp, + ((sh_video_t *)ds->sh)->format, + &priv->kf_base, &priv->kf_pts, + &priv->v_pts); + ds_add_packet(ds, dp); +} + // return value: // 0 = EOF or no stream found // 1 = successfully read a packet @@ -915,16 +940,7 @@ got_video: if(ds->asf_seq!=vpkg_seqnum){ // this fragment is for new packet, close the old one mp_msg(MSGT_DEMUX,MSGL_DBG2, "closing probably incomplete packet, len: %d \n",dp->len); - if(priv->video_after_seek){ - priv->kf_base = 0; - priv->kf_pts = dp_hdr->timestamp; - dp->pts= - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - priv->video_after_seek = 0; - } else if (dp_hdr->len >= 3) - dp->pts = - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - ds_add_packet(ds,dp); + queue_video_packet(priv, ds, dp); ds->asf_packet=NULL; } else { // append data to it! @@ -941,8 +957,8 @@ got_video: dp_data=dp->buffer+sizeof(dp_hdr_t); extra=(uint32_t*)(dp->buffer+dp_hdr->chunktab); } - extra[2*dp_hdr->chunks+0]=1; - extra[2*dp_hdr->chunks+1]=dp_hdr->len; + extra[2*dp_hdr->chunks+0]=le2me_32(1); + extra[2*dp_hdr->chunks+1]=le2me_32(dp_hdr->len); if(0x80==(vpkg_header&0xc0)){ // last fragment! if(dp_hdr->len!=vpkg_length-vpkg_offset) @@ -954,16 +970,7 @@ got_video: len-=vpkg_offset; mp_dbg(MSGT_DEMUX,MSGL_DBG2, "fragment (%d bytes) appended, %d bytes left\n",vpkg_offset,len); // we know that this is the last fragment -> we can close the packet! - if(priv->video_after_seek){ - priv->kf_base = 0; - priv->kf_pts = dp_hdr->timestamp; - dp->pts= - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - priv->video_after_seek = 0; - } else if (dp_hdr->len >= 3) - dp->pts = - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - ds_add_packet(ds,dp); + queue_video_packet(priv, ds, dp); ds->asf_packet=NULL; // continue parsing continue; @@ -991,7 +998,7 @@ got_video: dp_hdr->chunktab=sizeof(dp_hdr_t)+vpkg_length; dp_data=dp->buffer+sizeof(dp_hdr_t); extra=(uint32_t*)(dp->buffer+dp_hdr->chunktab); - extra[0]=1; extra[1]=0; // offset of the first chunk + extra[0]=le2me_32(1); extra[1]=0; // offset of the first chunk if(0x00==(vpkg_header&0xc0)){ // first fragment: if (len > dp->len - sizeof(dp_hdr_t)) len = dp->len - sizeof(dp_hdr_t); @@ -999,13 +1006,6 @@ got_video: stream_read(demuxer->stream, dp_data, len); ds->asf_packet=dp; len=0; - if(priv->video_after_seek){ - priv->kf_base = 0; - priv->kf_pts = dp_hdr->timestamp; - dp->pts= - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - priv->video_after_seek = 0; - } break; } // whole packet (not fragmented): @@ -1020,16 +1020,7 @@ got_video: } dp_hdr->len=vpkg_length; len-=vpkg_length; stream_read(demuxer->stream, dp_data, vpkg_length); - if(priv->video_after_seek){ - priv->kf_base = 0; - priv->kf_pts = dp_hdr->timestamp; - dp->pts= - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - priv->video_after_seek = 0; - } else if (dp_hdr->len >= 3) - dp->pts = - real_fix_timestamp(priv,dp_data,dp_hdr->timestamp,sh_video->frametime,sh_video->format); - ds_add_packet(ds,dp); + queue_video_packet(priv, ds, dp); } // while(len>0) -- cgit v1.2.3