From 9e787a0211c4220c80e62a4f4a2de4e2c457a2a0 Mon Sep 17 00:00:00 2001 From: Wim Taymans Date: Tue, 21 Dec 2010 15:02:18 +0100 Subject: [PATCH] rtpdepayloade: add support for getting events Add support for intercepting sink events in the depayloader by adding a new vmethod. --- gst-libs/gst/rtp/gstbasertpdepayload.c | 25 +++++++++++++++++++++---- gst-libs/gst/rtp/gstbasertpdepayload.h | 6 +++++- 2 files changed, 26 insertions(+), 5 deletions(-) diff --git a/gst-libs/gst/rtp/gstbasertpdepayload.c b/gst-libs/gst/rtp/gstbasertpdepayload.c index 583754f..d1d3991 100644 --- a/gst-libs/gst/rtp/gstbasertpdepayload.c +++ b/gst-libs/gst/rtp/gstbasertpdepayload.c @@ -97,6 +97,8 @@ static void gst_base_rtp_depayload_set_gst_timestamp (GstBaseRTPDepayload * filter, guint32 rtptime, GstBuffer * buf); static gboolean gst_base_rtp_depayload_packet_lost (GstBaseRTPDepayload * filter, GstEvent * event); +static gboolean gst_base_rtp_depayload_handle_event (GstBaseRTPDepayload * + filter, GstEvent * event); GST_BOILERPLATE (GstBaseRTPDepayload, gst_base_rtp_depayload, GstElement, GST_TYPE_ELEMENT); @@ -142,6 +144,7 @@ gst_base_rtp_depayload_class_init (GstBaseRTPDepayloadClass * klass) klass->set_gst_timestamp = gst_base_rtp_depayload_set_gst_timestamp; klass->packet_lost = gst_base_rtp_depayload_packet_lost; + klass->handle_event = gst_base_rtp_depayload_handle_event; GST_DEBUG_CATEGORY_INIT (basertpdepayload_debug, "basertpdepayload", 0, "Base class for RTP Depayloaders"); @@ -407,14 +410,12 @@ no_process: } static gboolean -gst_base_rtp_depayload_handle_sink_event (GstPad * pad, GstEvent * event) +gst_base_rtp_depayload_handle_event (GstBaseRTPDepayload * filter, + GstEvent * event) { - GstBaseRTPDepayload *filter; gboolean res = TRUE; gboolean forward = TRUE; - filter = GST_BASE_RTP_DEPAYLOAD (GST_OBJECT_PARENT (pad)); - switch (GST_EVENT_TYPE (event)) { case GST_EVENT_FLUSH_STOP: gst_segment_init (&filter->segment, GST_FORMAT_UNDEFINED); @@ -474,6 +475,22 @@ gst_base_rtp_depayload_handle_sink_event (GstPad * pad, GstEvent * event) return res; } +static gboolean +gst_base_rtp_depayload_handle_sink_event (GstPad * pad, GstEvent * event) +{ + gboolean res = FALSE; + GstBaseRTPDepayload *filter; + GstBaseRTPDepayloadClass *bclass; + + filter = GST_BASE_RTP_DEPAYLOAD (GST_OBJECT_PARENT (pad)); + + bclass = GST_BASE_RTP_DEPAYLOAD_GET_CLASS (filter); + if (bclass->handle_event) + res = bclass->handle_event (filter, event); + + return res; +} + static GstEvent * create_segment_event (GstBaseRTPDepayload * filter, gboolean update, GstClockTime position) diff --git a/gst-libs/gst/rtp/gstbasertpdepayload.h b/gst-libs/gst/rtp/gstbasertpdepayload.h index 4ba2fc4..bdd56a3 100644 --- a/gst-libs/gst/rtp/gstbasertpdepayload.h +++ b/gst-libs/gst/rtp/gstbasertpdepayload.h @@ -119,8 +119,12 @@ struct _GstBaseRTPDepayloadClass * The default implementation of this message pushes a segment update. */ gboolean (*packet_lost) (GstBaseRTPDepayload *filter, GstEvent *event); + /* the default implementation does the default actions for events but + * implementation can override. */ + gboolean (*handle_event) (GstBaseRTPDepayload * filter, GstEvent * event); + /*< private >*/ - gpointer _gst_reserved[GST_PADDING-1]; + gpointer _gst_reserved[GST_PADDING-2]; }; GType gst_base_rtp_depayload_get_type (void); -- 2.7.4