summaryrefslogtreecommitdiff
path: root/gst/adder/gstadder.c
diff options
context:
space:
mode:
Diffstat (limited to 'gst/adder/gstadder.c')
-rw-r--r--gst/adder/gstadder.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/gst/adder/gstadder.c b/gst/adder/gstadder.c
index c2bdff26f..0e5a2b6e1 100644
--- a/gst/adder/gstadder.c
+++ b/gst/adder/gstadder.c
@@ -565,7 +565,7 @@ forward_event_func (const GValue * val, GValue * ret, EventData * data)
/* quick hack to unflush the pads, ideally we need a way to just unflush
* this single collect pad */
if (data->flush)
- gst_pad_send_event (pad, gst_event_new_flush_stop (TRUE));
+ gst_pad_send_event (pad, gst_event_flush_stop_new (TRUE));
} else {
g_value_set_boolean (ret, TRUE);
GST_LOG_OBJECT (pad, "Sent event %p (%s).",
@@ -649,7 +649,7 @@ gst_adder_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
gboolean flush;
/* parse the seek parameters */
- gst_event_parse_seek (event, &rate, NULL, &flags, &curtype,
+ gst_event_seek_parse (event, &rate, NULL, &flags, &curtype,
&cur, &endtype, &end);
if ((curtype != GST_SEEK_TYPE_NONE) && (curtype != GST_SEEK_TYPE_SET)) {
@@ -674,7 +674,7 @@ gst_adder_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
/* flushing seek, start flush downstream, the flush will be done
* when all pads received a FLUSH_STOP. */
- gst_pad_push_event (adder->srcpad, gst_event_new_flush_start ());
+ gst_pad_push_event (adder->srcpad, gst_event_flush_start_new ());
/* We can't send FLUSH_STOP here since upstream could start pushing data
* after we unlock adder->collect.
@@ -719,7 +719,7 @@ gst_adder_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
if (g_atomic_int_compare_and_exchange (&adder->flush_stop_pending,
TRUE, FALSE)) {
GST_DEBUG_OBJECT (adder, "pending flush stop");
- gst_pad_push_event (adder->srcpad, gst_event_new_flush_stop (TRUE));
+ gst_pad_push_event (adder->srcpad, gst_event_flush_stop_new (TRUE));
}
break;
}
@@ -760,7 +760,7 @@ gst_adder_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstCaps *caps;
- gst_event_parse_caps (event, &caps);
+ gst_event_caps_parse (event, &caps);
ret = gst_adder_setcaps (adder, pad, caps);
gst_event_unref (event);
@@ -1072,7 +1072,7 @@ gst_adder_collected (GstCollectPads * pads, gpointer user_data)
if (g_atomic_int_compare_and_exchange (&adder->flush_stop_pending,
TRUE, FALSE)) {
GST_DEBUG_OBJECT (adder, "pending flush stop");
- gst_pad_push_event (adder->srcpad, gst_event_new_flush_stop (TRUE));
+ gst_pad_push_event (adder->srcpad, gst_event_flush_stop_new (TRUE));
}
/* get available bytes for reading, this can be 0 which could mean empty
@@ -1183,7 +1183,7 @@ gst_adder_collected (GstCollectPads * pads, gpointer user_data)
* event. We also adjust offset & timestamp acordingly.
* This basically ignores all newsegments sent by upstream.
*/
- event = gst_event_new_segment (&adder->segment);
+ event = gst_event_segment_new (&adder->segment);
if (adder->segment.rate > 0.0) {
adder->segment.position = adder->segment.start;
@@ -1268,7 +1268,7 @@ not_negotiated:
eos:
{
GST_DEBUG_OBJECT (adder, "no data available, must be EOS");
- gst_pad_push_event (adder->srcpad, gst_event_new_eos ());
+ gst_pad_push_event (adder->srcpad, gst_event_eos_new ());
return GST_FLOW_EOS;
}
}