static GstStateChangeReturn gst_visual_change_state (GstElement * element,
GstStateChange transition);
-static GstFlowReturn gst_visual_chain (GstPad * pad, GstBuffer * buffer);
-static gboolean gst_visual_sink_event (GstPad * pad, GstEvent * event);
-static gboolean gst_visual_src_event (GstPad * pad, GstEvent * event);
+static GstFlowReturn gst_visual_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
+static gboolean gst_visual_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_visual_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_visual_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
}
static gboolean
-gst_visual_sink_event (GstPad * pad, GstEvent * event)
+gst_visual_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstVisual *visual;
gboolean res;
- visual = GST_VISUAL (GST_PAD_PARENT (pad));
+ visual = GST_VISUAL (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
break;
}
default:
- res = gst_pad_event_default (pad, event);
+ res = gst_pad_event_default (pad, parent, event);
break;
}
}
static gboolean
-gst_visual_src_event (GstPad * pad, GstEvent * event)
+gst_visual_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstVisual *visual;
gboolean res;
- visual = GST_VISUAL (GST_PAD_PARENT (pad));
+ visual = GST_VISUAL (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_QOS:
res = TRUE;
break;
default:
- res = gst_pad_event_default (pad, event);
+ res = gst_pad_event_default (pad, parent, event);
break;
}
}
static GstFlowReturn
-gst_visual_chain (GstPad * pad, GstBuffer * buffer)
+gst_visual_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstBuffer *outbuf = NULL;
guint i;
- GstVisual *visual = GST_VISUAL (GST_PAD_PARENT (pad));
+ GstVisual *visual = GST_VISUAL (parent);
GstFlowReturn ret = GST_FLOW_OK;
guint avail;
gint bpf, rate, channels;
switch (transition) {
case GST_STATE_CHANGE_NULL_TO_READY:
visual->actor =
- visual_actor_new (GST_VISUAL_GET_CLASS (visual)->plugin->
- info->plugname);
+ visual_actor_new (GST_VISUAL_GET_CLASS (visual)->plugin->info->
+ plugname);
visual->video = visual_video_new ();
visual->audio = visual_audio_new ();
/* can't have a play without actors */
static void gst_ogg_avi_parse_finalize (GObject * object);
static GstStateChangeReturn gst_ogg_avi_parse_change_state (GstElement *
element, GstStateChange transition);
-static gboolean gst_ogg_avi_parse_event (GstPad * pad, GstEvent * event);
-static GstFlowReturn gst_ogg_avi_parse_chain (GstPad * pad, GstBuffer * buffer);
+static gboolean gst_ogg_avi_parse_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static GstFlowReturn gst_ogg_avi_parse_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static gboolean gst_ogg_avi_parse_setcaps (GstPad * pad, GstCaps * caps);
static void
}
static gboolean
-gst_ogg_avi_parse_event (GstPad * pad, GstEvent * event)
+gst_ogg_avi_parse_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstOggAviParse *ogg;
gboolean ret;
- ogg = GST_OGG_AVI_PARSE (GST_OBJECT_PARENT (pad));
+ ogg = GST_OGG_AVI_PARSE (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_CAPS:
}
static GstFlowReturn
-gst_ogg_avi_parse_chain (GstPad * pad, GstBuffer * buffer)
+gst_ogg_avi_parse_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstFlowReturn result = GST_FLOW_OK;
GstOggAviParse *ogg;
gchar *oggbuf;
gint ret = -1;
- ogg = GST_OGG_AVI_PARSE (GST_OBJECT_PARENT (pad));
+ ogg = GST_OGG_AVI_PARSE (parent);
size = gst_buffer_get_size (buffer);
static gboolean gst_ogg_pad_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
-static gboolean gst_ogg_pad_event (GstPad * pad, GstEvent * event);
+static gboolean gst_ogg_pad_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static GstOggPad *gst_ogg_chain_get_stream (GstOggChain * chain,
guint32 serialno);
}
static gboolean
-gst_ogg_pad_event (GstPad * pad, GstEvent * event)
+gst_ogg_pad_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res;
GstOggDemux *ogg;
- ogg = GST_OGG_DEMUX (gst_pad_get_parent (pad));
+ ogg = GST_OGG_DEMUX (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
gst_event_unref (event);
break;
default:
- res = gst_pad_event_default (pad, event);
+ res = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (ogg);
return res;
}
static GstFlowReturn gst_ogg_demux_read_end_chain (GstOggDemux * ogg,
GstOggChain * chain);
-static gboolean gst_ogg_demux_sink_event (GstPad * pad, GstEvent * event);
+static gboolean gst_ogg_demux_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static void gst_ogg_demux_loop (GstOggPad * pad);
-static GstFlowReturn gst_ogg_demux_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_ogg_demux_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static gboolean gst_ogg_demux_sink_activate (GstPad * sinkpad);
static gboolean gst_ogg_demux_sink_activate_pull (GstPad * sinkpad,
gboolean active);
}
static gboolean
-gst_ogg_demux_sink_event (GstPad * pad, GstEvent * event)
+gst_ogg_demux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res;
GstOggDemux *ogg;
- ogg = GST_OGG_DEMUX (gst_pad_get_parent (pad));
+ ogg = GST_OGG_DEMUX (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
res = gst_ogg_demux_send_event (ogg, event);
break;
}
- gst_object_unref (ogg);
return res;
}
* the serialno, submit pages and packets to the oggpads
*/
static GstFlowReturn
-gst_ogg_demux_chain (GstPad * pad, GstBuffer * buffer)
+gst_ogg_demux_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstOggDemux *ogg;
gint ret = 0;
GstFlowReturn result = GST_FLOW_OK;
- ogg = GST_OGG_DEMUX (GST_OBJECT_PARENT (pad));
+ ogg = GST_OGG_DEMUX (parent);
GST_DEBUG_OBJECT (ogg, "enter");
result = gst_ogg_demux_submit_buffer (ogg, buffer);
ogg->newsegment = NULL;
}
- ret = gst_ogg_demux_chain (ogg->sinkpad, buffer);
+ ret = gst_ogg_demux_chain (ogg->sinkpad, GST_OBJECT_CAST (ogg), buffer);
if (ret != GST_FLOW_OK) {
GST_LOG_OBJECT (ogg, "Failed demux_chain");
goto done;
static GstFlowReturn
gst_ogg_mux_collected (GstCollectPads2 * pads, GstOggMux * ogg_mux);
-static gboolean gst_ogg_mux_handle_src_event (GstPad * pad, GstEvent * event);
+static gboolean gst_ogg_mux_handle_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static GstPad *gst_ogg_mux_request_new_pad (GstElement * element,
GstPadTemplate * templ, const gchar * name, const GstCaps * caps);
static void gst_ogg_mux_release_pad (GstElement * element, GstPad * pad);
}
static gboolean
-gst_ogg_mux_sink_event (GstPad * pad, GstEvent * event)
+gst_ogg_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
- GstOggMux *ogg_mux = GST_OGG_MUX (gst_pad_get_parent (pad));
+ GstOggMux *ogg_mux = GST_OGG_MUX (parent);
GstOggPadData *ogg_pad = (GstOggPadData *) gst_pad_get_element_private (pad);
gboolean ret = FALSE;
/* now GstCollectPads can take care of the rest, e.g. EOS */
if (event != NULL)
- ret = ogg_pad->collect_event (pad, event);
+ ret = ogg_pad->collect_event (pad, parent, event);
- gst_object_unref (ogg_mux);
return ret;
}
/* handle events */
static gboolean
-gst_ogg_mux_handle_src_event (GstPad * pad, GstEvent * event)
+gst_ogg_mux_handle_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
GstEventType type;
break;
}
- return gst_pad_event_default (pad, event);
+ return gst_pad_event_default (pad, parent, event);
}
static GstBuffer *
static void gst_ogg_parse_dispose (GObject * object);
static GstStateChangeReturn gst_ogg_parse_change_state (GstElement * element,
GstStateChange transition);
-static GstFlowReturn gst_ogg_parse_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_ogg_parse_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static void
gst_ogg_parse_base_init (gpointer g_class)
* pages to output pad.
*/
static GstFlowReturn
-gst_ogg_parse_chain (GstPad * pad, GstBuffer * buffer)
+gst_ogg_parse_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstOggParse *ogg;
GstFlowReturn result = GST_FLOW_OK;
GstBuffer *pagebuffer;
GstClockTime buffertimestamp = GST_BUFFER_TIMESTAMP (buffer);
- ogg = GST_OGG_PARSE (GST_OBJECT_PARENT (pad));
+ ogg = GST_OGG_PARSE (parent);
GST_LOG_OBJECT (ogg,
"Chain function received buffer of size %" G_GSIZE_FORMAT,
static void gst_ogm_audio_parse_init (GstOgmParse * ogm);
static void gst_ogm_text_parse_init (GstOgmParse * ogm);
-static gboolean gst_ogm_parse_sink_event (GstPad * pad, GstEvent * event);
+static gboolean gst_ogm_parse_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_ogm_parse_sink_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean gst_ogm_parse_sink_convert (GstPad * pad, GstFormat src_format,
gint64 src_value, GstFormat * dest_format, gint64 * dest_value);
-static GstFlowReturn gst_ogm_parse_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_ogm_parse_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn gst_ogm_parse_change_state (GstElement * element,
GstStateChange transition);
}
static GstFlowReturn
-gst_ogm_parse_chain (GstPad * pad, GstBuffer * buf)
+gst_ogm_parse_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstFlowReturn ret = GST_FLOW_OK;
- GstOgmParse *ogm = GST_OGM_PARSE (GST_PAD_PARENT (pad));
+ GstOgmParse *ogm = GST_OGM_PARSE (parent);
guint8 *data;
gsize size;
}
static gboolean
-gst_ogm_parse_sink_event (GstPad * pad, GstEvent * event)
+gst_ogm_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
- GstOgmParse *ogm = GST_OGM_PARSE (gst_pad_get_parent (pad));
+ GstOgmParse *ogm = GST_OGM_PARSE (parent);
gboolean res;
GST_LOG_OBJECT (ogm, "processing %s event", GST_EVENT_TYPE_NAME (event));
res = TRUE;
} else {
GST_OBJECT_UNLOCK (ogm);
- res = gst_pad_event_default (pad, event);
+ res = gst_pad_event_default (pad, parent, event);
}
- gst_object_unref (ogm);
return res;
}
static gboolean gst_base_text_overlay_setcaps_txt (GstBaseTextOverlay * overlay,
GstCaps * caps);
static gboolean gst_base_text_overlay_src_event (GstPad * pad,
- GstEvent * event);
+ GstObject * parent, GstEvent * event);
static gboolean gst_base_text_overlay_src_query (GstPad * pad,
GstObject * parent, GstQuery * query);
static gboolean gst_base_text_overlay_video_event (GstPad * pad,
- GstEvent * event);
+ GstObject * parent, GstEvent * event);
static gboolean gst_base_text_overlay_video_query (GstPad * pad,
GstObject * parent, GstQuery * query);
static GstFlowReturn gst_base_text_overlay_video_chain (GstPad * pad,
- GstBuffer * buffer);
+ GstObject * parent, GstBuffer * buffer);
static gboolean gst_base_text_overlay_text_event (GstPad * pad,
- GstEvent * event);
+ GstObject * parent, GstEvent * event);
static GstFlowReturn gst_base_text_overlay_text_chain (GstPad * pad,
- GstBuffer * buffer);
+ GstObject * parent, GstBuffer * buffer);
static GstPadLinkReturn gst_base_text_overlay_text_pad_link (GstPad * pad,
GstPad * peer);
static void gst_base_text_overlay_text_pad_unlink (GstPad * pad);
}
static gboolean
-gst_base_text_overlay_src_event (GstPad * pad, GstEvent * event)
+gst_base_text_overlay_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
gboolean ret = FALSE;
GstBaseTextOverlay *overlay = NULL;
- overlay = GST_BASE_TEXT_OVERLAY (gst_pad_get_parent (pad));
- if (G_UNLIKELY (!overlay)) {
- gst_event_unref (event);
- return FALSE;
- }
+ overlay = GST_BASE_TEXT_OVERLAY (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:{
}
beach:
- gst_object_unref (overlay);
return ret;
}
}
static gboolean
-gst_base_text_overlay_text_event (GstPad * pad, GstEvent * event)
+gst_base_text_overlay_text_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
gboolean ret = FALSE;
GstBaseTextOverlay *overlay = NULL;
- overlay = GST_BASE_TEXT_OVERLAY (gst_pad_get_parent (pad));
- if (G_UNLIKELY (!overlay)) {
- gst_event_unref (event);
- return FALSE;
- }
+ overlay = GST_BASE_TEXT_OVERLAY (parent);
GST_LOG_OBJECT (pad, "received event %s", GST_EVENT_TYPE_NAME (event));
ret = TRUE;
break;
default:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (overlay);
-
return ret;
}
static gboolean
-gst_base_text_overlay_video_event (GstPad * pad, GstEvent * event)
+gst_base_text_overlay_video_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
gboolean ret = FALSE;
GstBaseTextOverlay *overlay = NULL;
- overlay = GST_BASE_TEXT_OVERLAY (gst_pad_get_parent (pad));
- if (G_UNLIKELY (!overlay)) {
- gst_event_unref (event);
- return FALSE;
- }
+ overlay = GST_BASE_TEXT_OVERLAY (parent);
GST_DEBUG_OBJECT (pad, "received event %s", GST_EVENT_TYPE_NAME (event));
("received non-TIME newsegment event on video input"));
}
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
case GST_EVENT_EOS:
GST_INFO_OBJECT (overlay, "video EOS");
overlay->video_eos = TRUE;
GST_OBJECT_UNLOCK (overlay);
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
case GST_EVENT_FLUSH_START:
GST_OBJECT_LOCK (overlay);
overlay->video_flushing = TRUE;
GST_BASE_TEXT_OVERLAY_BROADCAST (overlay);
GST_OBJECT_UNLOCK (overlay);
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
case GST_EVENT_FLUSH_STOP:
GST_OBJECT_LOCK (overlay);
overlay->video_eos = FALSE;
gst_segment_init (&overlay->segment, GST_FORMAT_TIME);
GST_OBJECT_UNLOCK (overlay);
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
default:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (overlay);
-
return ret;
}
If the buffer is in our segment we keep it internally except if another one
is already waiting here, in that case we wait that it gets kicked out */
static GstFlowReturn
-gst_base_text_overlay_text_chain (GstPad * pad, GstBuffer * buffer)
+gst_base_text_overlay_text_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
GstFlowReturn ret = GST_FLOW_OK;
GstBaseTextOverlay *overlay = NULL;
gboolean in_seg = FALSE;
guint64 clip_start = 0, clip_stop = 0;
- overlay = GST_BASE_TEXT_OVERLAY (GST_PAD_PARENT (pad));
+ overlay = GST_BASE_TEXT_OVERLAY (parent);
GST_OBJECT_LOCK (overlay);
}
static GstFlowReturn
-gst_base_text_overlay_video_chain (GstPad * pad, GstBuffer * buffer)
+gst_base_text_overlay_video_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
GstBaseTextOverlayClass *klass;
GstBaseTextOverlay *overlay;
guint64 start, stop, clip_start = 0, clip_stop = 0;
gchar *text = NULL;
- overlay = GST_BASE_TEXT_OVERLAY (GST_PAD_PARENT (pad));
+ overlay = GST_BASE_TEXT_OVERLAY (parent);
klass = GST_BASE_TEXT_OVERLAY_GET_CLASS (overlay);
if (!GST_BUFFER_TIMESTAMP_IS_VALID (buffer))
}
static GstFlowReturn
-gst_text_render_chain (GstPad * pad, GstBuffer * inbuf)
+gst_text_render_chain (GstPad * pad, GstObject * parent, GstBuffer * inbuf)
{
GstTextRender *render;
GstFlowReturn ret;
gint n;
gint xpos, ypos;
- render = GST_TEXT_RENDER (gst_pad_get_parent (pad));
+ render = GST_TEXT_RENDER (parent);
data = gst_buffer_map (inbuf, &size, NULL, GST_MAP_READ);
if (caps)
gst_caps_unref (caps);
gst_buffer_unref (inbuf);
- gst_object_unref (render);
+
return ret;
}
const GValue * value, GParamSpec * pspec);
static gboolean theora_dec_setcaps (GstTheoraDec * dec, GstCaps * caps);
-static gboolean theora_dec_sink_event (GstPad * pad, GstEvent * event);
-static GstFlowReturn theora_dec_chain (GstPad * pad, GstBuffer * buffer);
+static gboolean theora_dec_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static GstFlowReturn theora_dec_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn theora_dec_change_state (GstElement * element,
GstStateChange transition);
-static gboolean theora_dec_src_event (GstPad * pad, GstEvent * event);
+static gboolean theora_dec_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean theora_dec_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean theora_dec_src_convert (GstPad * pad, GstFormat src_format,
}
static gboolean
-theora_dec_src_event (GstPad * pad, GstEvent * event)
+theora_dec_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res = TRUE;
GstTheoraDec *dec;
- dec = GST_THEORA_DEC (gst_pad_get_parent (pad));
+ dec = GST_THEORA_DEC (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
break;
}
done:
- gst_object_unref (dec);
return res;
}
static gboolean
-theora_dec_sink_event (GstPad * pad, GstEvent * event)
+theora_dec_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean ret = FALSE;
GstTheoraDec *dec;
- dec = GST_THEORA_DEC (gst_pad_get_parent (pad));
+ dec = GST_THEORA_DEC (parent);
GST_LOG_OBJECT (dec, "handling event");
switch (GST_EVENT_TYPE (event)) {
break;
}
default:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
done:
- gst_object_unref (dec);
return ret;
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DISCONT);
/* now feed it to the decoder we can ignore the error */
- theora_dec_chain (dec->sinkpad, buf);
+ theora_dec_chain (dec->sinkpad, GST_OBJECT_CAST (dec), buf);
/* skip the data */
left -= psize;
}
static GstFlowReturn
-theora_dec_chain (GstPad * pad, GstBuffer * buf)
+theora_dec_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstTheoraDec *dec;
GstFlowReturn res;
gboolean discont;
- dec = GST_THEORA_DEC (gst_pad_get_parent (pad));
+ dec = GST_THEORA_DEC (parent);
/* peel of DISCONT flag */
discont = GST_BUFFER_IS_DISCONT (buf);
else
res = theora_dec_chain_reverse (dec, discont, buf);
- gst_object_unref (dec);
-
return res;
}
static GstCaps *theora_enc_src_caps;
-static gboolean theora_enc_sink_event (GstPad * pad, GstEvent * event);
-static gboolean theora_enc_src_event (GstPad * pad, GstEvent * event);
-static GstFlowReturn theora_enc_chain (GstPad * pad, GstBuffer * buffer);
+static gboolean theora_enc_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean theora_enc_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static GstFlowReturn theora_enc_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn theora_enc_change_state (GstElement * element,
GstStateChange transition);
static gboolean theora_enc_sink_query (GstPad * pad, GstObject * parent,
}
static gboolean
-theora_enc_sink_event (GstPad * pad, GstEvent * event)
+theora_enc_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstTheoraEnc *enc;
ogg_packet op;
gboolean res;
- enc = GST_THEORA_ENC (GST_PAD_PARENT (pad));
+ enc = GST_THEORA_ENC (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_CAPS:
}
static gboolean
-theora_enc_src_event (GstPad * pad, GstEvent * event)
+theora_enc_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstTheoraEnc *enc;
gboolean res = TRUE;
- enc = GST_THEORA_ENC (GST_PAD_PARENT (pad));
+ enc = GST_THEORA_ENC (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_CUSTOM_UPSTREAM:
}
static GstFlowReturn
-theora_enc_chain (GstPad * pad, GstBuffer * buffer)
+theora_enc_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstTheoraEnc *enc;
ogg_packet op;
GstFlowReturn ret;
gboolean force_keyframe;
- enc = GST_THEORA_ENC (GST_PAD_PARENT (pad));
+ enc = GST_THEORA_ENC (parent);
/* we keep track of two timelines.
* - The timestamps from the incoming buffers, which we copy to the outgoing
static void theora_parse_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec);
-static GstFlowReturn theora_parse_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn theora_parse_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn theora_parse_change_state (GstElement * element,
GstStateChange transition);
-static gboolean theora_parse_sink_event (GstPad * pad, GstEvent * event);
+static gboolean theora_parse_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean theora_parse_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
GstEvent *event;
event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue));
- gst_pad_event_default (parse->sinkpad, event);
+ gst_pad_event_default (parse->sinkpad, GST_OBJECT_CAST (parse), event);
}
}
}
static GstFlowReturn
-theora_parse_chain (GstPad * pad, GstBuffer * buffer)
+theora_parse_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstFlowReturn ret;
GstTheoraParse *parse;
gsize size;
gboolean have_header;
- parse = GST_THEORA_PARSE (gst_pad_get_parent (pad));
+ parse = GST_THEORA_PARSE (parent);
have_header = FALSE;
ret = theora_parse_queue_buffer (parse, buffer);
}
- gst_object_unref (parse);
-
return ret;
}
}
static gboolean
-theora_parse_sink_event (GstPad * pad, GstEvent * event)
+theora_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean ret;
GstTheoraParse *parse;
- parse = GST_THEORA_PARSE (gst_pad_get_parent (pad));
+ parse = GST_THEORA_PARSE (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_STOP:
theora_parse_clear_queue (parse);
parse->prev_keyframe = -1;
parse->prev_frame = -1;
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
case GST_EVENT_EOS:
theora_parse_drain_queue_prematurely (parse);
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
default:
if (parse->send_streamheader && GST_EVENT_IS_SERIALIZED (event))
ret = theora_parse_queue_event (parse, event);
else
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (parse);
-
return ret;
}
#define gst_vorbis_parse_parent_class parent_class
G_DEFINE_TYPE (GstVorbisParse, gst_vorbis_parse, GST_TYPE_ELEMENT);
-static GstFlowReturn vorbis_parse_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn vorbis_parse_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn vorbis_parse_change_state (GstElement * element,
GstStateChange transition);
-static gboolean vorbis_parse_sink_event (GstPad * pad, GstEvent * event);
+static gboolean vorbis_parse_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean vorbis_parse_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean vorbis_parse_convert (GstPad * pad, GstFormat src_format,
GstEvent *event;
event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue));
- gst_pad_event_default (parse->sinkpad, event);
+ gst_pad_event_default (parse->sinkpad, GST_OBJECT_CAST (parse), event);
}
}
}
static GstFlowReturn
-vorbis_parse_chain (GstPad * pad, GstBuffer * buffer)
+vorbis_parse_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstVorbisParseClass *klass;
GstVorbisParse *parse;
- parse = GST_VORBIS_PARSE (GST_PAD_PARENT (pad));
+ parse = GST_VORBIS_PARSE (parent);
klass = GST_VORBIS_PARSE_CLASS (G_OBJECT_GET_CLASS (parse));
g_assert (klass->parse_packet != NULL);
}
static gboolean
-vorbis_parse_sink_event (GstPad * pad, GstEvent * event)
+vorbis_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean ret;
GstVorbisParse *parse;
- parse = GST_VORBIS_PARSE (gst_pad_get_parent (pad));
+ parse = GST_VORBIS_PARSE (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
vorbis_parse_clear_queue (parse);
parse->prev_granulepos = -1;
parse->prev_blocksize = -1;
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
case GST_EVENT_EOS:
vorbis_parse_drain_queue_prematurely (parse);
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
default:
if (!parse->streamheader_sent && GST_EVENT_IS_SERIALIZED (event))
ret = vorbis_parse_queue_event (parse, event);
else
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (parse);
-
return ret;
}
static GstStateChangeReturn gst_audio_decoder_change_state (GstElement *
element, GstStateChange transition);
-static gboolean gst_audio_decoder_sink_event (GstPad * pad, GstEvent * event);
-static gboolean gst_audio_decoder_src_event (GstPad * pad, GstEvent * event);
+static gboolean gst_audio_decoder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_audio_decoder_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_audio_decoder_sink_setcaps (GstAudioDecoder * dec,
GstCaps * caps);
gboolean gst_audio_decoder_src_setcaps (GstAudioDecoder * dec, GstCaps * caps);
-static GstFlowReturn gst_audio_decoder_chain (GstPad * pad, GstBuffer * buf);
+static GstFlowReturn gst_audio_decoder_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buf);
static gboolean gst_audio_decoder_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean gst_audio_decoder_sink_query (GstPad * pad, GstObject * parent,
}
static GstFlowReturn
-gst_audio_decoder_chain (GstPad * pad, GstBuffer * buffer)
+gst_audio_decoder_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstAudioDecoder *dec;
GstFlowReturn ret;
- dec = GST_AUDIO_DECODER (GST_PAD_PARENT (pad));
+ dec = GST_AUDIO_DECODER (parent);
GST_LOG_OBJECT (dec,
"received buffer of size %d with ts %" GST_TIME_FORMAT
}
static gboolean
-gst_audio_decoder_sink_event (GstPad * pad, GstEvent * event)
+gst_audio_decoder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
GstAudioDecoder *dec;
GstAudioDecoderClass *klass;
gboolean handled = FALSE;
gboolean ret = TRUE;
- dec = GST_AUDIO_DECODER (gst_pad_get_parent (pad));
+ dec = GST_AUDIO_DECODER (parent);
klass = GST_AUDIO_DECODER_GET_CLASS (dec);
GST_DEBUG_OBJECT (dec, "received event %d, %s", GST_EVENT_TYPE (event),
if (!GST_EVENT_IS_SERIALIZED (event)
|| GST_EVENT_TYPE (event) == GST_EVENT_EOS
|| GST_EVENT_TYPE (event) == GST_EVENT_FLUSH_STOP) {
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
} else {
GST_AUDIO_DECODER_STREAM_LOCK (dec);
dec->priv->pending_events =
GST_DEBUG_OBJECT (dec, "event handled");
- gst_object_unref (dec);
return ret;
}
}
static gboolean
-gst_audio_decoder_src_event (GstPad * pad, GstEvent * event)
+gst_audio_decoder_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstAudioDecoder *dec;
gboolean res = FALSE;
- dec = GST_AUDIO_DECODER (gst_pad_get_parent (pad));
- if (G_UNLIKELY (dec == NULL)) {
- gst_event_unref (event);
- return FALSE;
- }
+ dec = GST_AUDIO_DECODER (parent);
GST_DEBUG_OBJECT (dec, "received event %d, %s", GST_EVENT_TYPE (event),
GST_EVENT_TYPE_NAME (event));
break;
}
done:
- gst_object_unref (dec);
-
return res;
/* ERRORS */
static GstCaps *gst_audio_encoder_getcaps_default (GstAudioEncoder * enc,
GstCaps * filter);
-static gboolean gst_audio_encoder_sink_event (GstPad * pad, GstEvent * event);
+static gboolean gst_audio_encoder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_audio_encoder_sink_setcaps (GstAudioEncoder * enc,
GstCaps * caps);
-static GstFlowReturn gst_audio_encoder_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_audio_encoder_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static gboolean gst_audio_encoder_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean gst_audio_encoder_sink_query (GstPad * pad, GstObject * parent,
}
static GstFlowReturn
-gst_audio_encoder_chain (GstPad * pad, GstBuffer * buffer)
+gst_audio_encoder_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstAudioEncoder *enc;
GstAudioEncoderPrivate *priv;
gboolean discont;
gsize size;
- enc = GST_AUDIO_ENCODER (GST_OBJECT_PARENT (pad));
+ enc = GST_AUDIO_ENCODER (parent);
priv = enc->priv;
ctx = &enc->priv->ctx;
}
static gboolean
-gst_audio_encoder_sink_event (GstPad * pad, GstEvent * event)
+gst_audio_encoder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
GstAudioEncoder *enc;
GstAudioEncoderClass *klass;
gboolean handled = FALSE;
gboolean ret = TRUE;
- enc = GST_AUDIO_ENCODER (gst_pad_get_parent (pad));
+ enc = GST_AUDIO_ENCODER (parent);
klass = GST_AUDIO_ENCODER_GET_CLASS (enc);
GST_DEBUG_OBJECT (enc, "received event %d, %s", GST_EVENT_TYPE (event),
if (!GST_EVENT_IS_SERIALIZED (event)
|| GST_EVENT_TYPE (event) == GST_EVENT_EOS
|| GST_EVENT_TYPE (event) == GST_EVENT_FLUSH_STOP) {
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
} else {
GST_AUDIO_ENCODER_STREAM_LOCK (enc);
enc->priv->pending_events =
GST_DEBUG_OBJECT (enc, "event handled");
- gst_object_unref (enc);
return ret;
}
guint prop_id, GValue * value, GParamSpec * pspec);
static GstFlowReturn gst_rtp_base_depayload_chain (GstPad * pad,
- GstBuffer * in);
+ GstObject * parent, GstBuffer * in);
static gboolean gst_rtp_base_depayload_handle_sink_event (GstPad * pad,
- GstEvent * event);
+ GstObject * parent, GstEvent * event);
static GstStateChangeReturn gst_rtp_base_depayload_change_state (GstElement *
element, GstStateChange transition);
}
static GstFlowReturn
-gst_rtp_base_depayload_chain (GstPad * pad, GstBuffer * in)
+gst_rtp_base_depayload_chain (GstPad * pad, GstObject * parent, GstBuffer * in)
{
GstRTPBaseDepayload *filter;
GstRTPBaseDepayloadPrivate *priv;
gint gap;
GstRTPBuffer rtp;
- filter = GST_RTP_BASE_DEPAYLOAD (GST_OBJECT_PARENT (pad));
+ filter = GST_RTP_BASE_DEPAYLOAD (parent);
priv = filter->priv;
/* we must have a setcaps first */
}
static gboolean
-gst_rtp_base_depayload_handle_sink_event (GstPad * pad, GstEvent * event)
+gst_rtp_base_depayload_handle_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
gboolean res = FALSE;
GstRTPBaseDepayload *filter;
GstRTPBaseDepayloadClass *bclass;
- filter = GST_RTP_BASE_DEPAYLOAD (gst_pad_get_parent (pad));
- if (G_UNLIKELY (filter == NULL)) {
- gst_event_unref (event);
- return FALSE;
- }
-
+ filter = GST_RTP_BASE_DEPAYLOAD (parent);
bclass = GST_RTP_BASE_DEPAYLOAD_GET_CLASS (filter);
if (bclass->handle_event)
res = bclass->handle_event (filter, event);
else
gst_event_unref (event);
- gst_object_unref (filter);
return res;
}
static gboolean gst_rtp_base_payload_sink_event_default (GstRTPBasePayload *
rtpbasepayload, GstEvent * event);
static gboolean gst_rtp_base_payload_sink_event (GstPad * pad,
- GstEvent * event);
+ GstObject * parent, GstEvent * event);
static gboolean gst_rtp_base_payload_query_default (GstRTPBasePayload *
rtpbasepayload, GstPad * pad, GstQuery * query);
static gboolean gst_rtp_base_payload_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static GstFlowReturn gst_rtp_base_payload_chain (GstPad * pad,
- GstBuffer * buffer);
+ GstObject * parent, GstBuffer * buffer);
static void gst_rtp_base_payload_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec);
static GstElementClass *parent_class = NULL;
-/* FIXME 0.11: API should be changed to gst_base_typ_payload_xyz */
-
GType
gst_rtp_base_payload_get_type (void)
{
gst_rtp_base_payload_sink_event_default (GstRTPBasePayload * rtpbasepayload,
GstEvent * event)
{
+ GstObject *parent = GST_OBJECT_CAST (rtpbasepayload);
gboolean res = FALSE;
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
- res = gst_pad_event_default (rtpbasepayload->sinkpad, event);
+ res = gst_pad_event_default (rtpbasepayload->sinkpad, parent, event);
break;
case GST_EVENT_FLUSH_STOP:
- res = gst_pad_event_default (rtpbasepayload->sinkpad, event);
+ res = gst_pad_event_default (rtpbasepayload->sinkpad, parent, event);
gst_segment_init (&rtpbasepayload->segment, GST_FORMAT_UNDEFINED);
break;
case GST_EVENT_CAPS:
GST_DEBUG_OBJECT (rtpbasepayload,
"configured SEGMENT %" GST_SEGMENT_FORMAT, segment);
- res = gst_pad_event_default (rtpbasepayload->sinkpad, event);
+ res = gst_pad_event_default (rtpbasepayload->sinkpad, parent, event);
break;
}
default:
- res = gst_pad_event_default (rtpbasepayload->sinkpad, event);
+ res = gst_pad_event_default (rtpbasepayload->sinkpad, parent, event);
break;
}
return res;
}
static gboolean
-gst_rtp_base_payload_sink_event (GstPad * pad, GstEvent * event)
+gst_rtp_base_payload_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
GstRTPBasePayload *rtpbasepayload;
GstRTPBasePayloadClass *rtpbasepayload_class;
gboolean res = FALSE;
- rtpbasepayload = GST_RTP_BASE_PAYLOAD (gst_pad_get_parent (pad));
- if (G_UNLIKELY (rtpbasepayload == NULL)) {
- gst_event_unref (event);
- return FALSE;
- }
-
+ rtpbasepayload = GST_RTP_BASE_PAYLOAD (parent);
rtpbasepayload_class = GST_RTP_BASE_PAYLOAD_GET_CLASS (rtpbasepayload);
if (rtpbasepayload_class->sink_event)
else
gst_event_unref (event);
- gst_object_unref (rtpbasepayload);
-
return res;
}
}
static GstFlowReturn
-gst_rtp_base_payload_chain (GstPad * pad, GstBuffer * buffer)
+gst_rtp_base_payload_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
GstRTPBasePayload *rtpbasepayload;
GstRTPBasePayloadClass *rtpbasepayload_class;
GstFlowReturn ret;
- rtpbasepayload = GST_RTP_BASE_PAYLOAD (gst_pad_get_parent (pad));
+ rtpbasepayload = GST_RTP_BASE_PAYLOAD (parent);
rtpbasepayload_class = GST_RTP_BASE_PAYLOAD_GET_CLASS (rtpbasepayload);
if (!rtpbasepayload_class->handle_buffer)
ret = rtpbasepayload_class->handle_buffer (rtpbasepayload, buffer);
- gst_object_unref (rtpbasepayload);
-
return ret;
/* ERRORS */
{
GST_ELEMENT_ERROR (rtpbasepayload, STREAM, NOT_IMPLEMENTED, (NULL),
("subclass did not implement handle_buffer function"));
- gst_object_unref (rtpbasepayload);
gst_buffer_unref (buffer);
return GST_FLOW_ERROR;
}
(is_list) ? -1 : gst_buffer_get_size (GST_BUFFER (obj)),
payload->seqnum, data.rtptime, GST_TIME_ARGS (data.timestamp));
- if (g_atomic_int_compare_and_exchange (&payload->priv->
- notified_first_timestamp, 1, 0)) {
+ if (g_atomic_int_compare_and_exchange (&payload->
+ priv->notified_first_timestamp, 1, 0)) {
g_object_notify (G_OBJECT (payload), "timestamp");
g_object_notify (G_OBJECT (payload), "seqnum");
}
static void gst_tag_demux_dispose (GObject * object);
-static GstFlowReturn gst_tag_demux_chain (GstPad * pad, GstBuffer * buf);
-static gboolean gst_tag_demux_sink_event (GstPad * pad, GstEvent * event);
+static GstFlowReturn gst_tag_demux_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buf);
+static gboolean gst_tag_demux_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_tag_demux_src_activate_pull (GstPad * pad, gboolean active);
static GstFlowReturn gst_tag_demux_read_range (GstTagDemux * tagdemux,
guint64 offset, guint length, GstBuffer ** buffer);
static GstFlowReturn gst_tag_demux_src_getrange (GstPad * srcpad,
- guint64 offset, guint length, GstBuffer ** buffer);
+ GstObject * parent, guint64 offset, guint length, GstBuffer ** buffer);
static void gst_tag_demux_set_src_caps (GstTagDemux * tagdemux,
GstCaps * new_caps);
-static gboolean gst_tag_demux_srcpad_event (GstPad * pad, GstEvent * event);
+static gboolean gst_tag_demux_srcpad_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_tag_demux_sink_activate (GstPad * sinkpad);
static GstStateChangeReturn gst_tag_demux_change_state (GstElement * element,
GstStateChange transition);
}
static GstFlowReturn
-gst_tag_demux_chain (GstPad * pad, GstBuffer * buf)
+gst_tag_demux_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstTagDemux *demux;
gsize size;
- demux = GST_TAG_DEMUX (GST_PAD_PARENT (pad));
+ demux = GST_TAG_DEMUX (parent);
size = gst_buffer_get_size (buf);
}
static gboolean
-gst_tag_demux_sink_event (GstPad * pad, GstEvent * event)
+gst_tag_demux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstTagDemux *demux;
gboolean ret;
- demux = GST_TAG_DEMUX (gst_pad_get_parent (pad));
+ demux = GST_TAG_DEMUX (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_EOS:
GST_WARNING_OBJECT (demux, "EOS before we found a type");
GST_ELEMENT_ERROR (demux, STREAM, TYPE_NOT_FOUND, (NULL), (NULL));
}
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
case GST_EVENT_SEGMENT:
{
}
case GST_EVENT_FLUSH_STOP:
case GST_EVENT_FLUSH_START:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
default:
if (demux->priv->need_newseg && GST_EVENT_IS_SERIALIZED (event)) {
GST_OBJECT_UNLOCK (demux);
ret = TRUE;
} else {
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
}
break;
}
- gst_object_unref (demux);
return ret;
}
}
static gboolean
-gst_tag_demux_srcpad_event (GstPad * pad, GstEvent * event)
+gst_tag_demux_srcpad_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstTagDemux *tagdemux;
gboolean res = FALSE;
- tagdemux = GST_TAG_DEMUX (gst_pad_get_parent (pad));
+ tagdemux = GST_TAG_DEMUX (parent);
/* Handle SEEK events, with adjusted byte offsets and sizes. */
break;
}
- gst_object_unref (tagdemux);
if (event)
gst_event_unref (event);
+
return res;
}
}
static GstFlowReturn
-gst_tag_demux_src_getrange (GstPad * srcpad,
+gst_tag_demux_src_getrange (GstPad * srcpad, GstObject * parent,
guint64 offset, guint length, GstBuffer ** buffer)
{
- GstTagDemux *demux = GST_TAG_DEMUX (GST_PAD_PARENT (srcpad));
+ GstTagDemux *demux = GST_TAG_DEMUX (parent);
/* downstream in pull mode won't miss a newsegment event,
* but it likely appreciates other (tag) events */
static GstStateChangeReturn
gst_tag_mux_change_state (GstElement * element, GstStateChange transition);
-static GstFlowReturn gst_tag_mux_chain (GstPad * pad, GstBuffer * buffer);
-static gboolean gst_tag_mux_sink_event (GstPad * pad, GstEvent * event);
+static GstFlowReturn gst_tag_mux_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
+static gboolean gst_tag_mux_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static void
gst_tag_mux_finalize (GObject * obj)
}
static GstFlowReturn
-gst_tag_mux_chain (GstPad * pad, GstBuffer * buffer)
+gst_tag_mux_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
- GstTagMux *mux = GST_TAG_MUX (GST_OBJECT_PARENT (pad));
+ GstTagMux *mux = GST_TAG_MUX (parent);
GstFlowReturn ret;
int length;
}
static gboolean
-gst_tag_mux_sink_event (GstPad * pad, GstEvent * event)
+gst_tag_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstTagMux *mux;
gboolean result;
- mux = GST_TAG_MUX (gst_pad_get_parent (pad));
+ mux = GST_TAG_MUX (parent);
result = FALSE;
switch (GST_EVENT_TYPE (event)) {
}
/* Now forward EOS */
- result = gst_pad_event_default (pad, event);
+ result = gst_pad_event_default (pad, parent, event);
break;
}
default:
- result = gst_pad_event_default (pad, event);
+ result = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (mux);
-
return result;
}
GstQuery * query);
static gboolean gst_adder_sink_query (GstPad * pad, GstObject * parent,
GstQuery * query);
-static gboolean gst_adder_src_event (GstPad * pad, GstEvent * event);
-static gboolean gst_adder_sink_event (GstPad * pad, GstEvent * event);
+static gboolean gst_adder_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_adder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static GstPad *gst_adder_request_new_pad (GstElement * element,
GstPadTemplate * temp, const gchar * unused, const GstCaps * caps);
}
static gboolean
-gst_adder_src_event (GstPad * pad, GstEvent * event)
+gst_adder_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstAdder *adder;
gboolean result;
- adder = GST_ADDER (gst_pad_get_parent (pad));
+ adder = GST_ADDER (parent);
GST_DEBUG_OBJECT (pad, "Got %s event on src pad",
GST_EVENT_TYPE_NAME (event));
}
done:
- gst_object_unref (adder);
return result;
}
static gboolean
-gst_adder_sink_event (GstPad * pad, GstEvent * event)
+gst_adder_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstAdder *adder;
gboolean ret = TRUE;
- adder = GST_ADDER (gst_pad_get_parent (pad));
+ adder = GST_ADDER (parent);
GST_DEBUG_OBJECT (pad, "Got %s event on sink pad",
GST_EVENT_TYPE_NAME (event));
}
/* now GstCollectPads can take care of the rest, e.g. EOS */
- ret = adder->collect_event (pad, event);
+ ret = adder->collect_event (pad, parent, event);
beach:
- gst_object_unref (adder);
return ret;
}
GST_STATIC_CAPS (GST_AUDIO_CAPS_MAKE (GST_AUDIO_FORMATS_ALL))
);
-static gboolean gst_audio_rate_sink_event (GstPad * pad, GstEvent * event);
-static gboolean gst_audio_rate_src_event (GstPad * pad, GstEvent * event);
-static GstFlowReturn gst_audio_rate_chain (GstPad * pad, GstBuffer * buf);
+static gboolean gst_audio_rate_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_audio_rate_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static GstFlowReturn gst_audio_rate_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buf);
static void gst_audio_rate_set_property (GObject * object,
guint prop_id, const GValue * value, GParamSpec * pspec);
* it will take care of filling */
buf = gst_buffer_new ();
GST_BUFFER_TIMESTAMP (buf) = time;
- gst_audio_rate_chain (audiorate->sinkpad, buf);
+ gst_audio_rate_chain (audiorate->sinkpad, GST_OBJECT_CAST (audiorate), buf);
}
static gboolean
-gst_audio_rate_sink_event (GstPad * pad, GstEvent * event)
+gst_audio_rate_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res;
GstAudioRate *audiorate;
- audiorate = GST_AUDIO_RATE (gst_pad_get_parent (pad));
+ audiorate = GST_AUDIO_RATE (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_CAPS:
break;
}
- gst_object_unref (audiorate);
-
return res;
}
static gboolean
-gst_audio_rate_src_event (GstPad * pad, GstEvent * event)
+gst_audio_rate_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res;
GstAudioRate *audiorate;
- audiorate = GST_AUDIO_RATE (gst_pad_get_parent (pad));
+ audiorate = GST_AUDIO_RATE (parent);
switch (GST_EVENT_TYPE (event)) {
default:
break;
}
- gst_object_unref (audiorate);
-
return res;
}
}
static GstFlowReturn
-gst_audio_rate_chain (GstPad * pad, GstBuffer * buf)
+gst_audio_rate_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstAudioRate *audiorate;
GstClockTime in_time;
GstClockTimeDiff diff;
gint rate, bpf;
- audiorate = GST_AUDIO_RATE (gst_pad_get_parent (pad));
+ audiorate = GST_AUDIO_RATE (parent);
rate = GST_AUDIO_INFO_RATE (&audiorate->info);
bpf = GST_AUDIO_INFO_BPF (&audiorate->info);
if (buf)
gst_buffer_unref (buf);
- gst_object_unref (audiorate);
-
return ret;
/* ERRORS */
static gboolean setup_recoder_pipeline (GstSmartEncoder * smart_encoder);
-static GstFlowReturn gst_smart_encoder_chain (GstPad * pad, GstBuffer * buf);
-static gboolean smart_encoder_sink_event (GstPad * pad, GstEvent * event);
+static GstFlowReturn gst_smart_encoder_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buf);
+static gboolean smart_encoder_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean smart_encoder_sink_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static GstCaps *smart_encoder_sink_getcaps (GstPad * pad, GstCaps * filter);
}
static GstFlowReturn
-gst_smart_encoder_chain (GstPad * pad, GstBuffer * buf)
+gst_smart_encoder_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstSmartEncoder *smart_encoder;
GstFlowReturn res = GST_FLOW_OK;
gboolean discont, keyframe;
- smart_encoder = GST_SMART_ENCODER (gst_object_get_parent (GST_OBJECT (pad)));
+ smart_encoder = GST_SMART_ENCODER (parent);
discont = GST_BUFFER_IS_DISCONT (buf);
keyframe = !GST_BUFFER_FLAG_IS_SET (buf, GST_BUFFER_FLAG_DELTA_UNIT);
GST_TIME_ARGS (smart_encoder->gop_stop));
beach:
- gst_object_unref (smart_encoder);
return res;
}
static gboolean
-smart_encoder_sink_event (GstPad * pad, GstEvent * event)
+smart_encoder_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res = TRUE;
- GstSmartEncoder *smart_encoder = GST_SMART_ENCODER (gst_pad_get_parent (pad));
+ GstSmartEncoder *smart_encoder = GST_SMART_ENCODER (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_STOP:
res = gst_pad_push_event (smart_encoder->srcpad, event);
- gst_object_unref (smart_encoder);
return res;
}
}
static GstFlowReturn
-internal_chain (GstPad * pad, GstBuffer * buf)
+internal_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
GstSmartEncoder *smart_encoder =
g_object_get_qdata ((GObject *) pad, INTERNAL_ELEMENT);
}
static GstFlowReturn
-gst_stream_combiner_chain (GstPad * pad, GstBuffer * buf)
+gst_stream_combiner_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
- GstStreamCombiner *stream_combiner =
- (GstStreamCombiner *) GST_PAD_PARENT (pad);
+ GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;
/* FIXME : IMPLEMENT */
/* with lock taken, check if we're the active stream, if not drop */
}
static gboolean
-gst_stream_combiner_sink_event (GstPad * pad, GstEvent * event)
+gst_stream_combiner_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamCombiner *stream_combiner =
- (GstStreamCombiner *) GST_PAD_PARENT (pad);
+ GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;
/* FIXME : IMPLEMENT */
GST_DEBUG_OBJECT (pad, "Got event %s", GST_EVENT_TYPE_NAME (event));
}
static gboolean
-gst_stream_combiner_src_event (GstPad * pad, GstEvent * event)
+gst_stream_combiner_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamCombiner *stream_combiner =
- (GstStreamCombiner *) GST_PAD_PARENT (pad);
+ GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;
GstPad *sinkpad = NULL;
STREAMS_LOCK (stream_combiner);
}
static GstFlowReturn
-gst_stream_splitter_chain (GstPad * pad, GstBuffer * buf)
+gst_stream_splitter_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
- GstStreamSplitter *stream_splitter =
- (GstStreamSplitter *) GST_PAD_PARENT (pad);
+ GstStreamSplitter *stream_splitter = (GstStreamSplitter *) parent;
GstFlowReturn res;
GstPad *srcpad = NULL;
}
static gboolean
-gst_stream_splitter_sink_event (GstPad * pad, GstEvent * event)
+gst_stream_splitter_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamSplitter *stream_splitter =
- (GstStreamSplitter *) GST_PAD_PARENT (pad);
+ GstStreamSplitter *stream_splitter = (GstStreamSplitter *) parent;
gboolean res = TRUE;
gboolean toall = FALSE;
gboolean store = FALSE;
}
static gboolean
-gst_stream_splitter_src_event (GstPad * pad, GstEvent * event)
+gst_stream_splitter_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamSplitter *stream_splitter =
- (GstStreamSplitter *) GST_PAD_PARENT (pad);
+ GstStreamSplitter *stream_splitter = (GstStreamSplitter *) parent;
GST_DEBUG_OBJECT (pad, "%s", GST_EVENT_TYPE_NAME (event));
G_DEFINE_TYPE_WITH_CODE (GstGDPDepay, gst_gdp_depay,
GST_TYPE_ELEMENT, _do_init);
-static gboolean gst_gdp_depay_sink_event (GstPad * pad, GstEvent * event);
-static gboolean gst_gdp_depay_src_event (GstPad * pad, GstEvent * event);
+static gboolean gst_gdp_depay_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_gdp_depay_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
-static GstFlowReturn gst_gdp_depay_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_gdp_depay_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
static GstStateChangeReturn gst_gdp_depay_change_state (GstElement *
element, GstStateChange transition);
}
static gboolean
-gst_gdp_depay_sink_event (GstPad * pad, GstEvent * event)
+gst_gdp_depay_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstGDPDepay *this;
gboolean res = TRUE;
- this = GST_GDP_DEPAY (gst_pad_get_parent (pad));
+ this = GST_GDP_DEPAY (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
gst_event_unref (event);
break;
}
- gst_object_unref (this);
return res;
}
static gboolean
-gst_gdp_depay_src_event (GstPad * pad, GstEvent * event)
+gst_gdp_depay_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstGDPDepay *this;
gboolean res = TRUE;
- this = GST_GDP_DEPAY (gst_pad_get_parent (pad));
+ this = GST_GDP_DEPAY (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
res = gst_pad_push_event (this->sinkpad, event);
break;
}
- gst_object_unref (this);
return res;
}
static GstFlowReturn
-gst_gdp_depay_chain (GstPad * pad, GstBuffer * buffer)
+gst_gdp_depay_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstGDPDepay *this;
GstFlowReturn ret = GST_FLOW_OK;
GstEvent *event;
guint available;
- this = GST_GDP_DEPAY (gst_pad_get_parent (pad));
+ this = GST_GDP_DEPAY (parent);
/* On DISCONT, get rid of accumulated data. We assume a buffer after the
* DISCONT contains (part of) a new valid header, if not we error because we
}
done:
- gst_object_unref (this);
return ret;
/* ERRORS */
static void gst_gdp_pay_reset (GstGDPPay * this);
-static GstFlowReturn gst_gdp_pay_chain (GstPad * pad, GstBuffer * buffer);
-static gboolean gst_gdp_pay_src_event (GstPad * pad, GstEvent * event);
-static gboolean gst_gdp_pay_sink_event (GstPad * pad, GstEvent * event);
+static GstFlowReturn gst_gdp_pay_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer);
+static gboolean gst_gdp_pay_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_gdp_pay_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static GstStateChangeReturn gst_gdp_pay_change_state (GstElement *
element, GstStateChange transition);
}
static GstFlowReturn
-gst_gdp_pay_chain (GstPad * pad, GstBuffer * buffer)
+gst_gdp_pay_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{
GstGDPPay *this;
#if 0
GstBuffer *outbuffer;
GstFlowReturn ret;
- this = GST_GDP_PAY (gst_pad_get_parent (pad));
+ this = GST_GDP_PAY (parent);
/* we should have received a new_segment before, otherwise it's a bug.
* fake one in that case */
done:
gst_buffer_unref (buffer);
- gst_object_unref (this);
+
return ret;
/* ERRORS */
}
static gboolean
-gst_gdp_pay_sink_event (GstPad * pad, GstEvent * event)
+gst_gdp_pay_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstBuffer *outbuffer;
- GstGDPPay *this = GST_GDP_PAY (gst_pad_get_parent (pad));
+ GstGDPPay *this = GST_GDP_PAY (parent);
GstFlowReturn flowret;
GstCaps *caps;
gboolean ret = TRUE;
done:
gst_event_unref (event);
- gst_object_unref (this);
return ret;
}
static gboolean
-gst_gdp_pay_src_event (GstPad * pad, GstEvent * event)
+gst_gdp_pay_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstGDPPay *this;
gboolean res = TRUE;
- this = GST_GDP_PAY (gst_pad_get_parent (pad));
+ this = GST_GDP_PAY (parent);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
res = gst_pad_push_event (this->sinkpad, event);
break;
}
- gst_object_unref (this);
return res;
}
}
static gboolean
-gst_play_sink_convert_bin_sink_event (GstPad * pad, GstEvent * event)
+gst_play_sink_convert_bin_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstPlaySinkConvertBin *self =
- GST_PLAY_SINK_CONVERT_BIN (gst_pad_get_parent (pad));
+ GstPlaySinkConvertBin *self = GST_PLAY_SINK_CONVERT_BIN (parent);
gboolean ret;
switch (GST_EVENT_TYPE (event)) {
break;
}
- ret = gst_proxy_pad_event_default (pad, gst_event_ref (event));
+ ret = gst_proxy_pad_event_default (pad, parent, gst_event_ref (event));
if (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) {
GstSegment seg;
}
gst_event_unref (event);
- gst_object_unref (self);
return ret;
}
/* srcpad functions */
static gboolean
-gst_stream_synchronizer_src_event (GstPad * pad, GstEvent * event)
+gst_stream_synchronizer_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamSynchronizer *self =
- GST_STREAM_SYNCHRONIZER (gst_pad_get_parent (pad));
+ GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad;
gboolean ret = FALSE;
}
out:
- gst_object_unref (self);
-
return ret;
}
/* sinkpad functions */
static gboolean
-gst_stream_synchronizer_sink_event (GstPad * pad, GstEvent * event)
+gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstStreamSynchronizer *self =
- GST_STREAM_SYNCHRONIZER (gst_pad_get_parent (pad));
+ GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad;
gboolean ret = FALSE;
}
done:
- gst_object_unref (self);
-
return ret;
}
static GstFlowReturn
-gst_stream_synchronizer_sink_chain (GstPad * pad, GstBuffer * buffer)
+gst_stream_synchronizer_sink_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
- GstStreamSynchronizer *self =
- GST_STREAM_SYNCHRONIZER (gst_pad_get_parent (pad));
+ GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad;
GstFlowReturn ret = GST_FLOW_ERROR;
GstStream *stream;
}
done:
-
- gst_object_unref (self);
-
return ret;
}
}
static GstFlowReturn
-gst_subtitle_overlay_src_proxy_chain (GstPad * proxypad, GstBuffer * buffer)
+gst_subtitle_overlay_src_proxy_chain (GstPad * proxypad, GstObject * parent,
+ GstBuffer * buffer)
{
GstPad *ghostpad;
GstSubtitleOverlay *self;
GstFlowReturn ret;
- ghostpad = GST_PAD_CAST (gst_pad_get_parent (proxypad));
+ ghostpad = GST_PAD_CAST (parent);
if (G_UNLIKELY (!ghostpad)) {
gst_buffer_unref (buffer);
return GST_FLOW_ERROR;
return GST_FLOW_ERROR;
}
- ret = gst_proxy_pad_chain_default (proxypad, buffer);
+ ret = gst_proxy_pad_chain_default (proxypad, parent, buffer);
if (IS_VIDEO_CHAIN_IGNORE_ERROR (ret)) {
GST_ERROR_OBJECT (self, "Downstream chain error: %s",
}
gst_object_unref (self);
- gst_object_unref (ghostpad);
return ret;
}
static gboolean
-gst_subtitle_overlay_src_proxy_event (GstPad * proxypad, GstEvent * event)
+gst_subtitle_overlay_src_proxy_event (GstPad * proxypad, GstObject * parent,
+ GstEvent * event)
{
GstPad *ghostpad = NULL;
GstSubtitleOverlay *self = NULL;
gboolean ret = FALSE;
const GstStructure *s;
- ghostpad = GST_PAD_CAST (gst_pad_get_parent (proxypad));
+ ghostpad = GST_PAD_CAST (parent);
if (G_UNLIKELY (!ghostpad))
goto out;
self = GST_SUBTITLE_OVERLAY_CAST (gst_pad_get_parent (ghostpad));
event = NULL;
ret = TRUE;
} else {
- ret = gst_proxy_pad_event_default (proxypad, event);
+ ret = gst_proxy_pad_event_default (proxypad, parent, event);
event = NULL;
}
gst_event_unref (event);
if (self)
gst_object_unref (self);
- if (ghostpad)
- gst_object_unref (ghostpad);
+
return ret;
}
}
static gboolean
-gst_subtitle_overlay_video_sink_event (GstPad * pad, GstEvent * event)
+gst_subtitle_overlay_video_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (gst_pad_get_parent (pad));
+ GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (parent);
gboolean ret;
switch (GST_EVENT_TYPE (event)) {
break;
}
- ret = gst_proxy_pad_event_default (pad, gst_event_ref (event));
+ ret = gst_proxy_pad_event_default (pad, parent, gst_event_ref (event));
if (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) {
GST_DEBUG_OBJECT (pad, "segment event: %" GST_PTR_FORMAT, event);
done:
gst_event_unref (event);
- gst_object_unref (self);
return ret;
}
static GstFlowReturn
-gst_subtitle_overlay_video_sink_chain (GstPad * pad, GstBuffer * buffer)
+gst_subtitle_overlay_video_sink_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
- GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (GST_PAD_PARENT (pad));
- GstFlowReturn ret = gst_proxy_pad_chain_default (pad, buffer);
+ GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (parent);
+ GstFlowReturn ret = gst_proxy_pad_chain_default (pad, parent, buffer);
if (G_UNLIKELY (self->downstream_chain_error) || self->passthrough_identity) {
return ret;
}
static GstFlowReturn
-gst_subtitle_overlay_subtitle_sink_chain (GstPad * pad, GstBuffer * buffer)
+gst_subtitle_overlay_subtitle_sink_chain (GstPad * pad, GstObject * parent,
+ GstBuffer * buffer)
{
- GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (GST_PAD_PARENT (pad));
+ GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (parent);
if (self->subtitle_error) {
gst_buffer_unref (buffer);
return GST_FLOW_OK;
} else {
- GstFlowReturn ret = gst_proxy_pad_chain_default (pad, buffer);
+ GstFlowReturn ret = gst_proxy_pad_chain_default (pad, parent, buffer);
if (IS_SUBTITLE_CHAIN_IGNORE_ERROR (ret)) {
GST_DEBUG_OBJECT (self, "Subtitle chain error: %s",
}
static gboolean
-gst_subtitle_overlay_subtitle_sink_event (GstPad * pad, GstEvent * event)
+gst_subtitle_overlay_subtitle_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event)
{
- GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (gst_pad_get_parent (pad));
+ GstSubtitleOverlay *self = GST_SUBTITLE_OVERLAY (parent);
gboolean ret;
if (GST_EVENT_TYPE (event) == GST_EVENT_CUSTOM_DOWNSTREAM_OOB &&
break;
}
- ret = gst_proxy_pad_event_default (pad, gst_event_ref (event));
+ ret = gst_proxy_pad_event_default (pad, parent, gst_event_ref (event));
if (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) {
GST_DEBUG_OBJECT (pad, "segment event: %" GST_PTR_FORMAT, event);
gst_event_unref (event);
out:
- gst_object_unref (self);
return ret;
}
static GstStateChangeReturn gst_ssa_parse_change_state (GstElement *
element, GstStateChange transition);
static gboolean gst_ssa_parse_setcaps (GstPad * sinkpad, GstCaps * caps);
-static gboolean gst_ssa_parse_src_event (GstPad * pad, GstEvent * event);
-static gboolean gst_ssa_parse_sink_event (GstPad * pad, GstEvent * event);
-static GstFlowReturn gst_ssa_parse_chain (GstPad * sinkpad, GstBuffer * buf);
+static gboolean gst_ssa_parse_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static gboolean gst_ssa_parse_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
+static GstFlowReturn gst_ssa_parse_chain (GstPad * sinkpad, GstObject * parent,
+ GstBuffer * buf);
static void
gst_ssa_parse_dispose (GObject * object)
}
static gboolean
-gst_ssa_parse_src_event (GstPad * pad, GstEvent * event)
+gst_ssa_parse_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
- return gst_pad_event_default (pad, event);
+ return gst_pad_event_default (pad, parent, event);
}
static gboolean
-gst_ssa_parse_sink_event (GstPad * pad, GstEvent * event)
+gst_ssa_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean res;
break;
}
default:
- res = gst_pad_event_default (pad, event);
+ res = gst_pad_event_default (pad, parent, event);
break;
}
return res;
}
static GstFlowReturn
-gst_ssa_parse_chain (GstPad * sinkpad, GstBuffer * buf)
+gst_ssa_parse_chain (GstPad * sinkpad, GstObject * parent, GstBuffer * buf)
{
GstFlowReturn ret;
- GstSsaParse *parse = GST_SSA_PARSE (GST_PAD_PARENT (sinkpad));
+ GstSsaParse *parse = GST_SSA_PARSE (parent);
GstClockTime ts;
gchar *txt;
gchar *data;
);
-static gboolean gst_sub_parse_src_event (GstPad * pad, GstEvent * event);
+static gboolean gst_sub_parse_src_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static gboolean gst_sub_parse_src_query (GstPad * pad, GstObject * parent,
GstQuery * query);
-static gboolean gst_sub_parse_sink_event (GstPad * pad, GstEvent * event);
+static gboolean gst_sub_parse_sink_event (GstPad * pad, GstObject * parent,
+ GstEvent * event);
static GstStateChangeReturn gst_sub_parse_change_state (GstElement * element,
GstStateChange transition);
-static GstFlowReturn gst_sub_parse_chain (GstPad * sinkpad, GstBuffer * buf);
+static GstFlowReturn gst_sub_parse_chain (GstPad * sinkpad, GstObject * parent,
+ GstBuffer * buf);
#define gst_sub_parse_parent_class parent_class
G_DEFINE_TYPE (GstSubParse, gst_sub_parse, GST_TYPE_ELEMENT);
}
static gboolean
-gst_sub_parse_src_event (GstPad * pad, GstEvent * event)
+gst_sub_parse_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
- GstSubParse *self = GST_SUBPARSE (gst_pad_get_parent (pad));
+ GstSubParse *self = GST_SUBPARSE (parent);
gboolean ret = FALSE;
GST_DEBUG ("Handling %s event", GST_EVENT_TYPE_NAME (event));
break;
}
default:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
beach:
- gst_object_unref (self);
-
return ret;
}
}
static GstFlowReturn
-gst_sub_parse_chain (GstPad * sinkpad, GstBuffer * buf)
+gst_sub_parse_chain (GstPad * sinkpad, GstObject * parent, GstBuffer * buf)
{
GstFlowReturn ret;
GstSubParse *self;
- self = GST_SUBPARSE (GST_PAD_PARENT (sinkpad));
+ self = GST_SUBPARSE (parent);
/* Push newsegment if needed */
if (self->need_segment) {
}
static gboolean
-gst_sub_parse_sink_event (GstPad * pad, GstEvent * event)
+gst_sub_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
- GstSubParse *self = GST_SUBPARSE (gst_pad_get_parent (pad));
+ GstSubParse *self = GST_SUBPARSE (parent);
gboolean ret = FALSE;
GST_DEBUG ("Handling %s event", GST_EVENT_TYPE_NAME (event));
gst_buffer_set_size (buf, 2);
GST_BUFFER_OFFSET (buf) = self->offset;
- gst_sub_parse_chain (pad, buf);
+ gst_sub_parse_chain (pad, parent, buf);
}
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
case GST_EVENT_SEGMENT:
{
self->flushing = TRUE;
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
case GST_EVENT_FLUSH_STOP:
{
self->flushing = FALSE;
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
default:
- ret = gst_pad_event_default (pad, event);
+ ret = gst_pad_event_default (pad, parent, event);
break;
}
- gst_object_unref (self);
-
return ret;
}