ptarget = gst_ghost_pad_get_target (GST_GHOST_PAD (GNL_OBJECT_SRC (comp)));
if (ptarget) {
GstEvent *flush_event;
- GstPad *peer = gst_pad_get_peer (GNL_OBJECT_SRC (comp));
/* Make sure that between the flush_start/flush_stop
* and the time we set the current_bin to READY, no
GST_DEBUG_OBJECT (comp, "added event probe %lu", priv->ghosteventprobe);
- if (peer) {
- flush_event = gst_event_new_flush_start ();
- priv->flush_seqnum = gst_event_get_seqnum (flush_event);
- GST_INFO_OBJECT (comp, "sending flushes downstream with seqnum %d",
- priv->flush_seqnum);
- gst_pad_send_event (peer, flush_event);
-
- flush_event = gst_event_new_flush_stop (TRUE);
- gst_event_set_seqnum (flush_event, priv->flush_seqnum);
- gst_pad_send_event (peer, flush_event);
+ flush_event = gst_event_new_flush_start ();
+ priv->flush_seqnum = gst_event_get_seqnum (flush_event);
+ GST_INFO_OBJECT (comp, "sending flushes downstream with seqnum %d",
+ priv->flush_seqnum);
+ gst_pad_push_event (ptarget, flush_event);
- gst_object_unref (peer);
- }
+ flush_event = gst_event_new_flush_stop (TRUE);
+ gst_event_set_seqnum (flush_event, priv->flush_seqnum);
+ gst_pad_push_event (ptarget, flush_event);
}
}