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

tsbase: add a guard with an atomic boolean when flushing

Browse Source
This commit is contained in:
Josep Torra 2012-11-10 00:08:35 +01:00
parent 6efd611b8c
commit e14e310f71
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
gst/mpegtsdemux/mpegtsbase.c
View File

@ -1362,6 +1362,7 @@ mpegts_base_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
gst_event_unref (event); gst_event_unref (event);
break; break;
case GST_EVENT_FLUSH_START: case GST_EVENT_FLUSH_START:
MPEGTSBASE_SET_FLUSHING (base, TRUE);
mpegts_packetizer_flush (base->packetizer); mpegts_packetizer_flush (base->packetizer);
mpegts_base_flush (base); mpegts_base_flush (base);
res = GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, event); res = GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, event);
@ -1369,6 +1370,9 @@ mpegts_base_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
case GST_EVENT_FLUSH_STOP: case GST_EVENT_FLUSH_STOP:
gst_segment_init (&base->segment, GST_FORMAT_UNDEFINED); gst_segment_init (&base->segment, GST_FORMAT_UNDEFINED);
base->seen_pat = FALSE; base->seen_pat = FALSE;
res = GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, event);
MPEGTSBASE_SET_FLUSHING (base, FALSE);
break;
/* Passthrough */ /* Passthrough */
default: default:
res = GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, event); res = GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, event);
@ -1399,6 +1403,11 @@ mpegts_base_push (MpegTSBase * base, MpegTSPacketizerPacket * packet,
{ {
MpegTSBaseClass *klass = GST_MPEGTS_BASE_GET_CLASS (base); MpegTSBaseClass *klass = GST_MPEGTS_BASE_GET_CLASS (base);
if (G_UNLIKELY (MPEGTSBASE_IS_FLUSHING (base))) {
GST_LOG_OBJECT (base, "Dropping because flushing");
return GST_FLOW_FLUSHING;
}
/* Call implementation */ /* Call implementation */
if (G_UNLIKELY (klass->push == NULL)) { if (G_UNLIKELY (klass->push == NULL)) {
GST_ERROR_OBJECT (base, "Class doesn't have a 'push' implementation !"); GST_ERROR_OBJECT (base, "Class doesn't have a 'push' implementation !");

4
gst/mpegtsdemux/mpegtsbase.h
View File

@ -119,6 +119,7 @@ struct _MpegTSBase {
guint8 *is_pes; guint8 *is_pes;
gboolean disposed; gboolean disposed;
gboolean flushing; /* ATOMIC */
/* size of the MpegTSBaseProgram structure, can be overridden /* size of the MpegTSBaseProgram structure, can be overridden
* by subclasses if they have their own MpegTSBaseProgram subclasses. */ * by subclasses if they have their own MpegTSBaseProgram subclasses. */
@ -183,6 +184,9 @@ struct _MpegTSBaseClass {
#define MPEGTS_BIT_UNSET(field, offs) ((field)[(offs) >> 3] &= ~(1 << ((offs) & 0x7))) #define MPEGTS_BIT_UNSET(field, offs) ((field)[(offs) >> 3] &= ~(1 << ((offs) & 0x7)))
#define MPEGTS_BIT_IS_SET(field, offs) ((field)[(offs) >> 3] & (1 << ((offs) & 0x7))) #define MPEGTS_BIT_IS_SET(field, offs) ((field)[(offs) >> 3] & (1 << ((offs) & 0x7)))
#define MPEGTSBASE_IS_FLUSHING(self) (g_atomic_int_get (&((self)->flushing)))
#define MPEGTSBASE_SET_FLUSHING(self,state) (g_atomic_int_set (&((self)->flushing),state))
G_GNUC_INTERNAL GType mpegts_base_get_type(void); G_GNUC_INTERNAL GType mpegts_base_get_type(void);
G_GNUC_INTERNAL MpegTSBaseProgram *mpegts_base_get_program (MpegTSBase * base, gint program_number); G_GNUC_INTERNAL MpegTSBaseProgram *mpegts_base_get_program (MpegTSBase * base, gint program_number);