mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-20 04:56:24 +00:00
Code Issues 1 Projects Releases Wiki Activity

ext/ogg/gstoggdemux.c: More cleanups.

Browse source 
Original commit message from CVS:
* ext/ogg/gstoggdemux.c: (gst_ogg_pad_src_query),
(gst_ogg_demux_chain_peer), (gst_ogg_pad_submit_packet),
(gst_ogg_chain_free), (gst_ogg_demux_sink_event),
(gst_ogg_demux_loop):
More cleanups.
Respect segment stop when emiting EOS or SEGMENT_DONE.
Fixes (#337945).
This commit is contained in:
Wim Taymans 2006-04-11 14:42:33 +00:00
parent 77208215d6
commit 1c4d4a09b5
2 changed files with 101 additions and 55 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ChangeLog
View file

@ -1,3 +1,13 @@
2006-04-11 Wim Taymans <wim@fluendo.com>
* ext/ogg/gstoggdemux.c: (gst_ogg_pad_src_query),
(gst_ogg_demux_chain_peer), (gst_ogg_pad_submit_packet),
(gst_ogg_chain_free), (gst_ogg_demux_sink_event),
(gst_ogg_demux_loop):
More cleanups.
Respect segment stop when emiting EOS or SEGMENT_DONE.
Fixes (#337945).
2006-04-11 Tim-Philipp Müller <tim at centricular dot net> 2006-04-11 Tim-Philipp Müller <tim at centricular dot net>
* gst/playback/gststreamselector.c: * gst/playback/gststreamselector.c:

146
ext/ogg/gstoggdemux.c
View file

@ -930,51 +930,77 @@ gst_ogg_demux_chain_peer (GstOggPad * pad, ogg_packet * packet)
GstBuffer *buf; GstBuffer *buf;
GstFlowReturn ret; GstFlowReturn ret;
GstOggDemux *ogg = pad->ogg; GstOggDemux *ogg = pad->ogg;
GstFormat format;
ret = gint64 current_time;
gst_pad_alloc_buffer_and_set_caps (GST_PAD (pad), GST_BUFFER_OFFSET_NONE, GstOggChain *chain;
packet->bytes, GST_PAD_CAPS (pad), &buf);
GST_DEBUG_OBJECT (ogg, GST_DEBUG_OBJECT (ogg,
"%p streaming to peer serial %08lx", pad, pad->serialno); "%p streaming to peer serial %08lx", pad, pad->serialno);
if (ret == GST_FLOW_OK) { ret =
memcpy (buf->data, packet->packet, packet->bytes); gst_pad_alloc_buffer_and_set_caps (GST_PAD (pad), GST_BUFFER_OFFSET_NONE,
packet->bytes, GST_PAD_CAPS (pad), &buf);
if (ret != GST_FLOW_OK)
goto no_buffer;
GST_BUFFER_OFFSET (buf) = -1; /* copy packet in buffer */
GST_BUFFER_OFFSET_END (buf) = packet->granulepos; memcpy (buf->data, packet->packet, packet->bytes);
ret = gst_pad_push (GST_PAD (pad), buf); GST_BUFFER_OFFSET (buf) = -1;
if (ret == GST_FLOW_NOT_LINKED) GST_BUFFER_OFFSET_END (buf) = packet->granulepos;
ret = GST_FLOW_OK;
if (packet->granulepos >= 0) { ret = gst_pad_push (GST_PAD (pad), buf);
GstFormat format; /* ignore not linked */
gint64 current_time; if (ret == GST_FLOW_NOT_LINKED)
ret = GST_FLOW_OK;
ogg->current_granule = packet->granulepos; /* we're done with skeleton stuff */
format = GST_FORMAT_TIME; if (pad->is_skeleton)
if (!pad->is_skeleton) { goto done;
if (!gst_ogg_pad_query_convert (pad,
GST_FORMAT_DEFAULT, packet->granulepos, &format,
(gint64 *) & current_time)) {
GST_WARNING_OBJECT (ogg, "could not convert granulepos to time");
} else {
gst_segment_set_last_stop (&ogg->segment, GST_FORMAT_TIME,
current_time);
GST_DEBUG_OBJECT (ogg, "ogg current time %" GST_TIME_FORMAT,
GST_TIME_ARGS (current_time));
}
}
}
} else {
GST_DEBUG_OBJECT (ogg,
"%p could not get buffer from peer %08lx", pad, pad->serialno);
if (ret == GST_FLOW_NOT_LINKED) /* check if valid granulepos, then we can calculate the current
ret = GST_FLOW_OK; * position */
} if (packet->granulepos < 0)
goto done;
/* store current granule pos */
ogg->current_granule = packet->granulepos;
/* convert to time */
format = GST_FORMAT_TIME;
if (!gst_ogg_pad_query_convert (pad,
GST_FORMAT_DEFAULT, packet->granulepos, &format,
(gint64 *) & current_time))
goto convert_failed;
/* convert to stream time */
if ((chain = pad->chain))
current_time = current_time - chain->segment_start + chain->begin_time;
/* and store as the current position */
gst_segment_set_last_stop (&ogg->segment, GST_FORMAT_TIME, current_time);
GST_DEBUG_OBJECT (ogg, "ogg current time %" GST_TIME_FORMAT,
GST_TIME_ARGS (current_time));
done:
return ret; return ret;
/* special cases */
no_buffer:
{
GST_DEBUG_OBJECT (ogg,
"%p could not get buffer from peer %08lx, %d (%s)", pad,
pad->serialno, ret, gst_flow_get_name (ret));
if (ret == GST_FLOW_NOT_LINKED)
ret = GST_FLOW_OK;
return ret;
}
convert_failed:
{
GST_WARNING_OBJECT (ogg, "could not convert granulepos to time");
return ret;
}
} }
/* submit a packet to the oggpad, this function will run the /* submit a packet to the oggpad, this function will run the
@ -996,7 +1022,6 @@ gst_ogg_pad_submit_packet (GstOggPad * pad, ogg_packet * packet)
!memcmp (packet->packet, "fishead\0", 8)) { !memcmp (packet->packet, "fishead\0", 8)) {
gst_ogg_pad_parse_skeleton_fishead (pad, packet); gst_ogg_pad_parse_skeleton_fishead (pad, packet);
} }
gst_ogg_pad_typefind (pad, packet); gst_ogg_pad_typefind (pad, packet);
pad->have_type = TRUE; pad->have_type = TRUE;
} }
@ -1172,7 +1197,7 @@ gst_ogg_chain_free (GstOggChain * chain)
gst_object_unref (pad); gst_object_unref (pad);
} }
g_array_free (chain->streams, TRUE); g_array_free (chain->streams, TRUE);
chain->streams = NULL; g_free (chain);
} }
static GstOggPad * static GstOggPad *
@ -2609,24 +2634,8 @@ gst_ogg_demux_loop (GstOggPad * pad)
} }
GST_LOG_OBJECT (ogg, "pull data %lld", ogg->offset); GST_LOG_OBJECT (ogg, "pull data %lld", ogg->offset);
if (ogg->offset == ogg->length) { if (ogg->offset == ogg->length)
ret = GST_FLOW_OK; goto eos;
/* segment playback just posts a segment end message instead of
* pushing out EOS. */
/* FIXME, need to be done somewhere else where we
* can check against segment_stop time. */
ogg->segment_running = FALSE;
if (ogg->segment.flags & GST_SEEK_FLAG_SEGMENT) {
GST_LOG_OBJECT (ogg, "Sending segment done, at end of segment");
gst_element_post_message (GST_ELEMENT (ogg),
gst_message_new_segment_done (GST_OBJECT (ogg), GST_FORMAT_TIME,
ogg->total_time));
} else {
GST_LOG_OBJECT (ogg, "Sending EOS, at end of stream");
gst_ogg_demux_send_event (ogg, gst_event_new_eos ());
}
goto pause;
}
ret = gst_pad_pull_range (ogg->sinkpad, ogg->offset, CHUNKSIZE, &buffer); ret = gst_pad_pull_range (ogg->sinkpad, ogg->offset, CHUNKSIZE, &buffer);
if (ret != GST_FLOW_OK) { if (ret != GST_FLOW_OK) {
@ -2642,6 +2651,11 @@ gst_ogg_demux_loop (GstOggPad * pad)
goto pause; goto pause;
} }
/* check for the end of the segment */
if (ogg->segment.stop != -1 && ogg->segment.last_stop != -1)
if (ogg->segment.last_stop > ogg->segment.stop)
goto eos;
return; return;
/* ERRORS */ /* ERRORS */
@ -2651,6 +2665,28 @@ chain_read_failed:
ret = ogg->chain_error; ret = ogg->chain_error;
goto pause; goto pause;
} }
eos:
{
ret = GST_FLOW_OK;
/* segment playback just posts a segment end message instead of
* pushing out EOS. */
ogg->segment_running = FALSE;
if (ogg->segment.flags & GST_SEEK_FLAG_SEGMENT) {
gint64 stop;
if ((stop = ogg->segment.stop) == -1)
stop = ogg->segment.duration;
GST_LOG_OBJECT (ogg, "Sending segment done, at end of segment");
gst_element_post_message (GST_ELEMENT (ogg),
gst_message_new_segment_done (GST_OBJECT (ogg), GST_FORMAT_TIME,
stop));
} else {
GST_LOG_OBJECT (ogg, "Sending EOS, at end of stream");
gst_ogg_demux_send_event (ogg, gst_event_new_eos ());
}
goto pause;
}
pause: pause:
{ {
GST_LOG_OBJECT (ogg, "pausing task, reason %s", gst_flow_get_name (ret)); GST_LOG_OBJECT (ogg, "pausing task, reason %s", gst_flow_get_name (ret));