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

decklinksrc: pause streaming thread and send EOS event on error

Browse Source 
Instead of just posting an EOS message and continuing,
actually pause the thread.
This commit is contained in:
Tim-Philipp Müller 2013-03-16 21:34:57 +00:00
parent 7b268f6965
commit 5eb8188e55
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
sys/decklink/gstdecklinksrc.cpp
View File

@ -762,6 +762,7 @@ gst_decklink_src_task (void *priv)
GST_ELEMENT_ERROR (decklinksrc, STREAM, FAILED, GST_ELEMENT_ERROR (decklinksrc, STREAM, FAILED,
("Internal data stream error."), ("Internal data stream error."),
("stream stopped, reason %s", gst_flow_get_name (ret))); ("stream stopped, reason %s", gst_flow_get_name (ret)));
goto pause;
} }
if (gst_pad_is_linked (decklinksrc->audiosrcpad)) { if (gst_pad_is_linked (decklinksrc->audiosrcpad)) {
@ -789,10 +790,47 @@ gst_decklink_src_task (void *priv)
GST_ELEMENT_ERROR (decklinksrc, STREAM, FAILED, GST_ELEMENT_ERROR (decklinksrc, STREAM, FAILED,
("Internal data stream error."), ("Internal data stream error."),
("stream stopped, reason %s", gst_flow_get_name (ret))); ("stream stopped, reason %s", gst_flow_get_name (ret)));
goto pause;
} }
} }
done:
if (audio_frame) if (audio_frame)
audio_frame->Release (); audio_frame->Release ();
return;
pause:
{
const gchar *reason = gst_flow_get_name (ret);
GstEvent *event = NULL;
GST_DEBUG_OBJECT (decklinksrc, "pausing task, reason %s", reason);
gst_task_pause (decklinksrc->task);
if (ret == GST_FLOW_EOS) {
/* perform EOS logic (very crude, we don't even keep a GstSegment) */
event = gst_event_new_eos ();
} else if (ret == GST_FLOW_NOT_LINKED || ret < GST_FLOW_EOS) {
event = gst_event_new_eos ();
/* for fatal errors we post an error message, post the error
* first so the app knows about the error first.
* Also don't do this for FLUSHING because it happens
* due to flushing and posting an error message because of
* that is the wrong thing to do, e.g. when we're doing
* a flushing seek. */
GST_ELEMENT_ERROR (decklinksrc, STREAM, FAILED,
("Internal data flow error."),
("streaming task paused, reason %s (%d)", reason, ret));
}
if (event != NULL) {
GST_INFO_OBJECT (decklinksrc->videosrcpad, "pushing EOS event");
gst_pad_push_event (decklinksrc->videosrcpad, gst_event_ref (event));
GST_INFO_OBJECT (decklinksrc->audiosrcpad, "pushing EOS event");
gst_pad_push_event (decklinksrc->audiosrcpad, event);
}
goto done;
}
} }
#if 0 #if 0