mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

Added segment seek

Browse source 
Original commit message from CVS:
Added segment seek
This commit is contained in:
Wim Taymans 2002-11-02 13:47:00 +00:00
parent bb4952c055
commit ea619028c7
2 changed files with 32 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
gst/avi/gstavidemux.c
View file

@ -369,6 +369,7 @@ gst_avi_demux_strh (GstAviDemux *avi_demux)
target->delay = 0LL; target->delay = 0LL;
target->total_bytes = 0LL; target->total_bytes = 0LL;
target->total_frames = 0; target->total_frames = 0;
target->end_pos = -1;
target->skip = 0; target->skip = 0;
@ -1032,6 +1033,7 @@ gst_avi_demux_get_event_mask (GstPad *pad)
{ {
static const GstEventMask masks[] = { static const GstEventMask masks[] = {
{ GST_EVENT_SEEK, GST_SEEK_METHOD_SET | GST_SEEK_FLAG_KEY_UNIT }, { GST_EVENT_SEEK, GST_SEEK_METHOD_SET | GST_SEEK_FLAG_KEY_UNIT },
{ GST_EVENT_SEEK_SEGMENT, GST_SEEK_METHOD_SET | GST_SEEK_FLAG_KEY_UNIT },
{ 0, } { 0, }
}; };
@ -1048,6 +1050,8 @@ gst_avi_demux_handle_src_event (GstPad *pad, GstEvent *event)
stream = gst_pad_get_element_private (pad); stream = gst_pad_get_element_private (pad);
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK_SEGMENT:
stream->end_pos = GST_EVENT_SEEK_ENDOFFSET (event);
case GST_EVENT_SEEK: case GST_EVENT_SEEK:
GST_DEBUG (0, "seek format %d, %08x", GST_EVENT_SEEK_FORMAT (event), stream->strh.type); GST_DEBUG (0, "seek format %d, %08x", GST_EVENT_SEEK_FORMAT (event), stream->strh.type);
switch (GST_EVENT_SEEK_FORMAT (event)) { switch (GST_EVENT_SEEK_FORMAT (event)) {
@ -1060,12 +1064,14 @@ gst_avi_demux_handle_src_event (GstPad *pad, GstEvent *event)
gint64 desired_offset = GST_EVENT_SEEK_OFFSET (event); gint64 desired_offset = GST_EVENT_SEEK_OFFSET (event);
guint32 flags; guint32 flags;
guint64 min_index; guint64 min_index;
/* no seek on audio yet */ /* no seek on audio yet */
if (stream->strh.type == GST_RIFF_FCC_auds) { if (stream->strh.type == GST_RIFF_FCC_auds) {
res = FALSE; res = FALSE;
goto done; goto done;
} }
GST_DEBUG (0, "seeking to %lld", desired_offset);
flags = GST_RIFF_IF_KEYFRAME; flags = GST_RIFF_IF_KEYFRAME;
@ -1344,27 +1350,34 @@ gst_avi_demux_process_chunk (GstAviDemux *avi_demux, guint64 *filepos,
stream->current_byte += *chunksize; stream->current_byte += *chunksize;
if (stream->skip) { if (stream->skip) {
stream->skip--; stream->skip--;
} }
else { else {
if (stream->pad && GST_PAD_IS_CONNECTED (stream->pad)) { if (GST_PAD_IS_USABLE (stream->pad)) {
GstBuffer *buf; if (next_ts >= stream->end_pos) {
guint32 got_bytes; gst_pad_push (stream->pad, GST_BUFFER (gst_event_new (GST_EVENT_EOS)));
GST_DEBUG (0, "end stream %d: %lld %d %lld", stream_id, next_ts, stream->current_frame - 1,
if (*chunksize) { stream->end_pos);
got_bytes = gst_bytestream_peek (bs, &buf, *chunksize);
GST_BUFFER_TIMESTAMP (buf) = next_ts;
if (stream->need_flush) {
/* FIXME, do some flush event here */
stream->need_flush = FALSE;
}
GST_DEBUG (0, "send stream %d: %lld %d %lld %08x", stream_id, next_ts, stream->current_frame - 1,
stream->delay, *chunksize);
gst_pad_push(stream->pad, buf);
} }
else {
GstBuffer *buf;
guint32 got_bytes;
if (*chunksize) {
got_bytes = gst_bytestream_peek (bs, &buf, *chunksize);
GST_BUFFER_TIMESTAMP (buf) = next_ts;
if (stream->need_flush) {
/* FIXME, do some flush event here */
stream->need_flush = FALSE;
}
GST_DEBUG (0, "send stream %d: %lld %d %lld %08x", stream_id, next_ts, stream->current_frame - 1,
stream->delay, *chunksize);
gst_pad_push(stream->pad, buf);
}
}
} }
} }

1
gst/avi/gstavidemux.h
View file

@ -74,6 +74,7 @@ typedef struct
guint64 delay; guint64 delay;
gboolean need_flush; gboolean need_flush;
guint32 av_bps; guint32 av_bps;
guint64 end_pos;
guint64 total_bytes; guint64 total_bytes;
guint32 total_frames; guint32 total_frames;