FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

streamsynchronizer: Rename GstStream => GstSyncStream

Browse Source 
Avoid clashes with future GstStream from core
This commit is contained in:
Edward Hervey 2015-07-21 09:58:56 +02:00
parent e47643122c
commit c79bf13bc2
1 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
gst/playback/gststreamsynchronizer.c
View File

@ -80,11 +80,11 @@ typedef struct
guint32 stream_start_seqnum; guint32 stream_start_seqnum;
guint32 segment_seqnum; guint32 segment_seqnum;
guint group_id; guint group_id;
} GstStream; } GstSyncStream;
/* Must be called with lock! */ /* Must be called with lock! */
static inline GstPad * static inline GstPad *
gst_stream_get_other_pad (GstStream * stream, GstPad * pad) gst_stream_get_other_pad (GstSyncStream * stream, GstPad * pad)
{ {
if (stream->sinkpad == pad) if (stream->sinkpad == pad)
return gst_object_ref (stream->srcpad); return gst_object_ref (stream->srcpad);
@ -97,7 +97,7 @@ gst_stream_get_other_pad (GstStream * stream, GstPad * pad)
static GstPad * static GstPad *
gst_stream_get_other_pad_from_pad (GstStreamSynchronizer * self, GstPad * pad) gst_stream_get_other_pad_from_pad (GstStreamSynchronizer * self, GstPad * pad)
{ {
GstStream *stream; GstSyncStream *stream;
GstPad *opad = NULL; GstPad *opad = NULL;
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
@ -156,7 +156,7 @@ gst_stream_synchronizer_src_event (GstPad * pad, GstObject * parent,
GstClockTimeDiff diff; GstClockTimeDiff diff;
GstClockTime timestamp; GstClockTime timestamp;
gint64 running_time_diff = -1; gint64 running_time_diff = -1;
GstStream *stream; GstSyncStream *stream;
gst_event_parse_qos (event, NULL, &proportion, &diff, &timestamp); gst_event_parse_qos (event, NULL, &proportion, &diff, &timestamp);
gst_event_unref (event); gst_event_unref (event);
@ -211,7 +211,7 @@ static gboolean
gst_stream_synchronizer_wait (GstStreamSynchronizer * self, GstPad * pad) gst_stream_synchronizer_wait (GstStreamSynchronizer * self, GstPad * pad)
{ {
gboolean ret = FALSE; gboolean ret = FALSE;
GstStream *stream; GstSyncStream *stream;
while (!self->eos && !self->flushing) { while (!self->eos && !self->flushing) {
stream = gst_pad_get_element_private (pad); stream = gst_pad_get_element_private (pad);
@ -278,7 +278,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_STREAM_START: case GST_EVENT_STREAM_START:
{ {
GstStream *stream, *ostream; GstSyncStream *stream, *ostream;
guint32 seqnum = gst_event_get_seqnum (event); guint32 seqnum = gst_event_get_seqnum (event);
guint group_id; guint group_id;
gboolean have_group_id; gboolean have_group_id;
@ -344,7 +344,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
stream->wait = TRUE; stream->wait = TRUE;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
all_wait = all_wait && ((ostream->flags & GST_STREAM_FLAG_SPARSE) all_wait = all_wait && ((ostream->flags & GST_STREAM_FLAG_SPARSE)
|| (ostream->wait && (!have_group_id || (ostream->wait && (!have_group_id
@ -366,7 +366,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
self->group_id = group_id; self->group_id = group_id;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
gint64 stop_running_time; gint64 stop_running_time;
gint64 position_running_time; gint64 position_running_time;
@ -397,7 +397,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
GST_TIME_ARGS (self->group_start_time)); GST_TIME_ARGS (self->group_start_time));
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
ostream->wait = FALSE; ostream->wait = FALSE;
g_cond_broadcast (&ostream->stream_finish_cond); g_cond_broadcast (&ostream->stream_finish_cond);
} }
@ -408,7 +408,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
break; break;
} }
case GST_EVENT_SEGMENT:{ case GST_EVENT_SEGMENT:{
GstStream *stream; GstSyncStream *stream;
GstSegment segment; GstSegment segment;
gst_event_copy_segment (event, &segment); gst_event_copy_segment (event, &segment);
@ -457,7 +457,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
break; break;
} }
case GST_EVENT_FLUSH_START:{ case GST_EVENT_FLUSH_START:{
GstStream *stream; GstSyncStream *stream;
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
stream = gst_pad_get_element_private (pad); stream = gst_pad_get_element_private (pad);
@ -471,7 +471,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
break; break;
} }
case GST_EVENT_FLUSH_STOP:{ case GST_EVENT_FLUSH_STOP:{
GstStream *stream; GstSyncStream *stream;
GList *l; GList *l;
GstClockTime new_group_start_time = 0; GstClockTime new_group_start_time = 0;
@ -490,7 +490,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
} }
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
GstClockTime start_running_time; GstClockTime start_running_time;
if (ostream == stream) if (ostream == stream)
@ -518,7 +518,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
if (gst_event_has_name (event, "playsink-custom-video-flush") if (gst_event_has_name (event, "playsink-custom-video-flush")
|| gst_event_has_name (event, "playsink-custom-audio-flush") || gst_event_has_name (event, "playsink-custom-audio-flush")
|| gst_event_has_name (event, "playsink-custom-subtitle-flush")) { || gst_event_has_name (event, "playsink-custom-subtitle-flush")) {
GstStream *stream; GstSyncStream *stream;
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
stream = gst_pad_get_element_private (pad); stream = gst_pad_get_element_private (pad);
@ -533,7 +533,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
break; break;
} }
case GST_EVENT_EOS:{ case GST_EVENT_EOS:{
GstStream *stream; GstSyncStream *stream;
GList *l; GList *l;
gboolean all_eos = TRUE; gboolean all_eos = TRUE;
gboolean seen_data; gboolean seen_data;
@ -565,7 +565,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
stream->segment.position = timestamp; stream->segment.position = timestamp;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
all_eos = all_eos && ostream->is_eos; all_eos = all_eos && ostream->is_eos;
if (!all_eos) if (!all_eos)
@ -576,7 +576,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
GST_DEBUG_OBJECT (self, "All streams are EOS -- forwarding"); GST_DEBUG_OBJECT (self, "All streams are EOS -- forwarding");
self->eos = TRUE; self->eos = TRUE;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
/* local snapshot of current pads */ /* local snapshot of current pads */
gst_object_ref (ostream->srcpad); gst_object_ref (ostream->srcpad);
pads = g_slist_prepend (pads, ostream->srcpad); pads = g_slist_prepend (pads, ostream->srcpad);
@ -585,7 +585,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
if (pads) { if (pads) {
GstPad *pad; GstPad *pad;
GSList *epad; GSList *epad;
GstStream *ostream; GstSyncStream *ostream;
ret = TRUE; ret = TRUE;
epad = pads; epad = pads;
@ -650,7 +650,7 @@ gst_stream_synchronizer_sink_chain (GstPad * pad, GstObject * parent,
GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent); GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad; GstPad *opad;
GstFlowReturn ret = GST_FLOW_ERROR; GstFlowReturn ret = GST_FLOW_ERROR;
GstStream *stream; GstSyncStream *stream;
GstClockTime duration = GST_CLOCK_TIME_NONE; GstClockTime duration = GST_CLOCK_TIME_NONE;
GstClockTime timestamp = GST_CLOCK_TIME_NONE; GstClockTime timestamp = GST_CLOCK_TIME_NONE;
GstClockTime timestamp_end = GST_CLOCK_TIME_NONE; GstClockTime timestamp_end = GST_CLOCK_TIME_NONE;
@ -723,7 +723,7 @@ gst_stream_synchronizer_sink_chain (GstPad * pad, GstObject * parent,
} }
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
gint64 position; gint64 position;
if (!ostream->is_eos || ostream->eos_sent || if (!ostream->is_eos || ostream->eos_sent ||
@ -766,14 +766,14 @@ gst_stream_synchronizer_request_new_pad (GstElement * element,
GstPadTemplate * temp, const gchar * name, const GstCaps * caps) GstPadTemplate * temp, const gchar * name, const GstCaps * caps)
{ {
GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (element); GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (element);
GstStream *stream; GstSyncStream *stream;
gchar *tmp; gchar *tmp;
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
GST_DEBUG_OBJECT (self, "Requesting new pad for stream %d", GST_DEBUG_OBJECT (self, "Requesting new pad for stream %d",
self->current_stream_number); self->current_stream_number);
stream = g_slice_new0 (GstStream); stream = g_slice_new0 (GstSyncStream);
stream->transform = self; stream->transform = self;
stream->stream_number = self->current_stream_number; stream->stream_number = self->current_stream_number;
g_cond_init (&stream->stream_finish_cond); g_cond_init (&stream->stream_finish_cond);
@ -830,7 +830,7 @@ gst_stream_synchronizer_request_new_pad (GstElement * element,
/* Must be called with lock! */ /* Must be called with lock! */
static void static void
gst_stream_synchronizer_release_stream (GstStreamSynchronizer * self, gst_stream_synchronizer_release_stream (GstStreamSynchronizer * self,
GstStream * stream) GstSyncStream * stream)
{ {
GList *l; GList *l;
@ -861,7 +861,7 @@ gst_stream_synchronizer_release_stream (GstStreamSynchronizer * self,
gst_element_remove_pad (GST_ELEMENT_CAST (self), stream->sinkpad); gst_element_remove_pad (GST_ELEMENT_CAST (self), stream->sinkpad);
g_cond_clear (&stream->stream_finish_cond); g_cond_clear (&stream->stream_finish_cond);
g_slice_free (GstStream, stream); g_slice_free (GstSyncStream, stream);
/* NOTE: In theory we have to check here if all streams /* NOTE: In theory we have to check here if all streams
* are EOS but the one that was removed wasn't and then * are EOS but the one that was removed wasn't and then
@ -880,7 +880,7 @@ static void
gst_stream_synchronizer_release_pad (GstElement * element, GstPad * pad) gst_stream_synchronizer_release_pad (GstElement * element, GstPad * pad)
{ {
GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (element); GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (element);
GstStream *stream; GstSyncStream *stream;
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
stream = gst_pad_get_element_private (pad); stream = gst_pad_get_element_private (pad);
@ -923,7 +923,7 @@ gst_stream_synchronizer_change_state (GstElement * element,
self->flushing = TRUE; self->flushing = TRUE;
self->shutdown = TRUE; self->shutdown = TRUE;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *ostream = l->data; GstSyncStream *ostream = l->data;
g_cond_broadcast (&ostream->stream_finish_cond); g_cond_broadcast (&ostream->stream_finish_cond);
} }
GST_STREAM_SYNCHRONIZER_UNLOCK (self); GST_STREAM_SYNCHRONIZER_UNLOCK (self);
@ -945,7 +945,7 @@ gst_stream_synchronizer_change_state (GstElement * element,
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *stream = l->data; GstSyncStream *stream = l->data;
/* send GAP event to sink to finished pre-roll. The reason is function /* send GAP event to sink to finished pre-roll. The reason is function
* chain () will be blocked on pad_push (), so can't trigger the track * chain () will be blocked on pad_push (), so can't trigger the track
* which reach EOS to send GAP event. */ * which reach EOS to send GAP event. */
@ -967,7 +967,7 @@ gst_stream_synchronizer_change_state (GstElement * element,
GST_STREAM_SYNCHRONIZER_LOCK (self); GST_STREAM_SYNCHRONIZER_LOCK (self);
self->send_gap_event = FALSE; self->send_gap_event = FALSE;
for (l = self->streams; l; l = l->next) { for (l = self->streams; l; l = l->next) {
GstStream *stream = l->data; GstSyncStream *stream = l->data;
gst_segment_init (&stream->segment, GST_FORMAT_UNDEFINED); gst_segment_init (&stream->segment, GST_FORMAT_UNDEFINED);
stream->gap_duration = GST_CLOCK_TIME_NONE; stream->gap_duration = GST_CLOCK_TIME_NONE;