mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-03-12 06:42:00 +00:00
Code Issues 1 Projects Releases Wiki Activity

decklinkvideosink: Add some more debug output for when frames are scheduled

Browse source
This commit is contained in:
Sebastian Dröge 2014-12-19 13:52:08 +01:00
parent ec90bbb6f3
commit b9e17c5605
1 changed files with 91 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

93
sys/decklink/gstdecklinkvideosink.cpp
View file

@ -256,8 +256,8 @@ gst_decklink_video_sink_prepare (GstBaseSink * bsink, GstBuffer * buffer)
//g_assert_not_reached (); //g_assert_not_reached ();
} }
GST_LOG_OBJECT (self, "Scheduling video frame at %" GST_TIME_FORMAT GST_LOG_OBJECT (self, "Scheduling video frame %p at %" GST_TIME_FORMAT
" with duration %" GST_TIME_FORMAT, GST_TIME_ARGS (running_time), " with duration %" GST_TIME_FORMAT, frame, GST_TIME_ARGS (running_time),
GST_TIME_ARGS (running_time_duration)); GST_TIME_ARGS (running_time_duration));
ret = self->output->output->ScheduleVideoFrame (frame, ret = self->output->output->ScheduleVideoFrame (frame,
@ -283,6 +283,91 @@ out:
return flow_ret; return flow_ret;
} }
class GStreamerVideoOutputCallback:public IDeckLinkVideoOutputCallback
{
public:
GStreamerVideoOutputCallback (GstDecklinkVideoSink * sink)
{
m_sink = GST_DECKLINK_VIDEO_SINK_CAST (gst_object_ref (sink));
g_mutex_init (&m_mutex);
}
virtual HRESULT QueryInterface (REFIID, LPVOID *)
{
return E_NOINTERFACE;
}
virtual ULONG AddRef (void)
{
ULONG ret;
g_mutex_lock (&m_mutex);
m_refcount++;
ret = m_refcount;
g_mutex_unlock (&m_mutex);
return ret;
}
virtual ULONG Release (void)
{
ULONG ret;
g_mutex_lock (&m_mutex);
m_refcount--;
ret = m_refcount;
g_mutex_unlock (&m_mutex);
if (ret == 0) {
delete this;
}
return ret;
}
virtual HRESULT ScheduledFrameCompleted (IDeckLinkVideoFrame * completedFrame,
BMDOutputFrameCompletionResult result)
{
switch (result) {
case bmdOutputFrameCompleted:
GST_LOG_OBJECT (m_sink, "Completed frame %p", completedFrame);
break;
case bmdOutputFrameDisplayedLate:
GST_INFO_OBJECT (m_sink, "Late Frame %p", completedFrame);
break;
case bmdOutputFrameDropped:
GST_INFO_OBJECT (m_sink, "Dropped Frame %p", completedFrame);
break;
case bmdOutputFrameFlushed:
GST_DEBUG_OBJECT (m_sink, "Flushed Frame %p", completedFrame);
break;
default:
GST_INFO_OBJECT (m_sink, "Unknown Frame %p: %d", completedFrame,
(gint) result);
break;
}
return S_OK;
}
virtual HRESULT ScheduledPlaybackHasStopped (void)
{
GST_LOG_OBJECT (m_sink, "Scheduled playback stopped");
return S_OK;
}
virtual ~ GStreamerVideoOutputCallback () {
gst_object_unref (m_sink);
g_mutex_clear (&m_mutex);
}
private:
GstDecklinkVideoSink * m_sink;
GMutex m_mutex;
gint m_refcount;
};
static gboolean static gboolean
gst_decklink_video_sink_open (GstBaseSink * bsink) gst_decklink_video_sink_open (GstBaseSink * bsink)
{ {
@ -301,6 +386,9 @@ gst_decklink_video_sink_open (GstBaseSink * bsink)
return FALSE; return FALSE;
} }
self->output->output->SetScheduledFrameCompletionCallback (new
GStreamerVideoOutputCallback (self));
mode = gst_decklink_get_mode (self->mode); mode = gst_decklink_get_mode (self->mode);
g_assert (mode != NULL); g_assert (mode != NULL);
@ -337,6 +425,7 @@ gst_decklink_video_sink_close (GstBaseSink * bsink)
g_mutex_unlock (&self->output->lock); g_mutex_unlock (&self->output->lock);
self->output->output->DisableVideoOutput (); self->output->output->DisableVideoOutput ();
self->output->output->SetScheduledFrameCompletionCallback (NULL);
gst_decklink_release_nth_output (self->device_number, gst_decklink_release_nth_output (self->device_number,
GST_ELEMENT_CAST (self), FALSE); GST_ELEMENT_CAST (self), FALSE);
self->output = NULL; self->output = NULL;