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

adder: add more logging and return value checking

Browse Source
This commit is contained in:
Stefan Kost 2009-05-19 01:13:34 +03:00
parent 705b01aa93
commit c94f952056
1 changed files with 23 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
gst/adder/gstadder.c
View File

@ -644,10 +644,6 @@ gst_adder_src_event (GstPad * pad, GstEvent * event)
adder = GST_ADDER (gst_pad_get_parent (pad)); adder = GST_ADDER (gst_pad_get_parent (pad));
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_QOS:
/* QoS might be tricky */
result = FALSE;
break;
case GST_EVENT_SEEK: case GST_EVENT_SEEK:
{ {
GstSeekFlags flags; GstSeekFlags flags;
@ -667,6 +663,7 @@ gst_adder_src_event (GstPad * pad, GstEvent * event)
* when all pads received a FLUSH_STOP. */ * 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_new_flush_start ());
} }
GST_DEBUG_OBJECT (adder, "handling seek event: %" GST_PTR_FORMAT, event);
/* now wait for the collected to be finished and mark a new /* now wait for the collected to be finished and mark a new
* segment */ * segment */
GST_OBJECT_LOCK (adder->collect); GST_OBJECT_LOCK (adder->collect);
@ -676,16 +673,24 @@ gst_adder_src_event (GstPad * pad, GstEvent * event)
adder->segment_position = 0; adder->segment_position = 0;
adder->segment_pending = TRUE; adder->segment_pending = TRUE;
GST_OBJECT_UNLOCK (adder->collect); GST_OBJECT_UNLOCK (adder->collect);
GST_DEBUG_OBJECT (adder, "forwarding seek event: %" GST_PTR_FORMAT,
event);
result = forward_event (adder, event); result = forward_event (adder, event);
break; break;
} }
case GST_EVENT_QOS:
/* QoS might be tricky */
result = FALSE;
break;
case GST_EVENT_NAVIGATION: case GST_EVENT_NAVIGATION:
/* navigation is rather pointless. */ /* navigation is rather pointless. */
result = FALSE; result = FALSE;
break; break;
default: default:
/* just forward the rest for now */ /* just forward the rest for now */
GST_DEBUG_OBJECT (adder, "forward unhandled event: %s",
GST_EVENT_TYPE_NAME (event));
result = forward_event (adder, event); result = forward_event (adder, event);
break; break;
} }
@ -988,9 +993,18 @@ gst_adder_collected (GstCollectPads * pads, gpointer user_data)
event = gst_event_new_new_segment_full (FALSE, adder->segment_rate, event = gst_event_new_new_segment_full (FALSE, adder->segment_rate,
1.0, GST_FORMAT_TIME, adder->timestamp, -1, adder->segment_position); 1.0, GST_FORMAT_TIME, adder->timestamp, -1, adder->segment_position);
gst_pad_push_event (adder->srcpad, event); if (event) {
adder->segment_pending = FALSE; if (!gst_pad_push_event (adder->srcpad, event)) {
adder->segment_position = 0; GST_WARNING_OBJECT (adder->srcpad, "Sending event %p (%s) failed.",
event, GST_EVENT_TYPE_NAME (event));
}
adder->segment_pending = FALSE;
adder->segment_position = 0;
} else {
GST_WARNING_OBJECT (adder->srcpad, "Creating new segment event for "
"start:%" G_GINT64_FORMAT " pos:%" G_GINT64_FORMAT " failed",
adder->timestamp, adder->segment_position);
}
} }
/* set timestamps on the output buffer */ /* set timestamps on the output buffer */
@ -1016,6 +1030,8 @@ gst_adder_collected (GstCollectPads * pads, gpointer user_data)
GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (outbuf))); GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (outbuf)));
ret = gst_pad_push (adder->srcpad, outbuf); ret = gst_pad_push (adder->srcpad, outbuf);
GST_LOG_OBJECT (adder, "pushed outbuf, result = %s", gst_flow_get_name (ret));
return ret; return ret;
/* ERRORS */ /* ERRORS */