因为工作需要,同事写了一个Transform插件,吾写了一个 Sink插件。结果吾在测试的时候,发现数据流结束了,流程一直无法正常结束。再网上反复搜索,连蒙带猜的折腾了一番,还是不行。
昨天发现显存无法正常释放,今天在查找原因。先将两个插件从流程中删除,发现可以正常结束。加上Transform就不能正常结束了。原来问题出在这个插件上这里……于是又开始连蒙带猜……
老兄,咱玩编程,好歹也算是搞科研了,汝这样天天连蒙带猜的,这不是事啊,这能靠谱吗?
吾亦知道有点那个(哪个?),那汝可有好办法?实际上搞科研,开始的时候不都是这样嘛。
所以每次解决问题,吾都喜欢公布解决办法,希望其他人能够顺利一些。
SINK插件的事件处理代码:
static gboolean gh_gstsink_event(GstBaseSink *sink, GstEvent *event)
{
GstElement* element = (GstElement*)sink;
GhGstSink* ghsink = (GhGstSink*) sink;
switch(event-> type)
{
case GST_EVENT_EOS:
break;
case GST_EVENT_FLUSH_START:
case GST_EVENT_FLUSH_STOP:
default:
break;
}
//关键代码。最关键的就是遇到GST_EVENT_EOS要如此调用。
return GST_BASE_SINK_CLASS(parent_class)->event(sink, event);
}
static void gh_gstsink_class_init (GhGstSinkClass * klass)
{
GObjectClass *gobject_class = (GObjectClass *) klass;
GstElementClass *gstelement_class = (GstElementClass *) klass;
GstBaseSinkClass *gstbasesink_class= (GstBaseSinkClass *) klass;
/* Overide base class functions */
//代码对齐,看起来很漂亮专业吧。
gobject_class->set_property = GST_DEBUG_FUNCPTR (gh_gstsink_set_property);
gobject_class->get_property = GST_DEBUG_FUNCPTR (gh_gstsink_get_property);
gstbasesink_class->render = GST_DEBUG_FUNCPTR (gh_gstsink_render);
gstbasesink_class->start = GST_DEBUG_FUNCPTR (gh_gstsink_start);
gstbasesink_class->stop = GST_DEBUG_FUNCPTR (gh_gstsink_stop);
gstbasesink_class->event = GST_DEBUG_FUNCPTR (gh_gstsink_event);
……
}
对于Transform插件(相当于 Filter),事件代码如下:
static gboolean gst_rfcnplugin_sink_event(GstBaseTransform *trans, GstEvent *event)
{
//关键代码。最关键的就是遇到GST_EVENT_EOS要如此调用。
return GST_BASE_TRANSFORM_CLASS(parent_class)->sink_event(trans, event);
}
static gboolean gst_rfcnplugin_src_event(GstBaseTransform *trans, GstEvent *event)
{
//关键代码。最关键的就是遇到GST_EVENT_EOS要如此调用。
return GST_BASE_TRANSFORM_CLASS(parent_class)->src_event(trans, event);
}
static void gst_rfcnplugin_class_init(GstRfcnPluginClass* klass)
{
GObjectClass* gobject_class = (GObjectClass*) klass;
GstElementClass* gstelement_class = (GstElementClass*) klass;
GstBaseTransformClass* gstbasetransform_class = (GstBaseTransformClass*) klass;
/* Overide base class functions */
gobject_class->set_property = GST_DEBUG_FUNCPTR(gst_rfcn_set_property);
gobject_class->get_property = GST_DEBUG_FUNCPTR(gst_rfcnplugin_get_property);
gstbasetransform_class->set_caps = GST_DEBUG_FUNCPTR(gst_rfcnplugin_set_caps);
gstbasetransform_class->start = GST_DEBUG_FUNCPTR(gst_rfcnplugin_start);
gstbasetransform_class->stop = GST_DEBUG_FUNCPTR(gst_rfcnplugin_stop);
gstbasetransform_class->transform_ip = GST_DEBUG_FUNCPTR(gst_rfcnplugin_transform_ip);
gstbasetransform_class->sink_event = GST_DEBUG_FUNCPTR(gst_rfcnplugin_sink_event);
gstbasetransform_class->src_event = GST_DEBUG_FUNCPTR(gst_rfcnplugin_src_event);
……
}
start/stop的正确写法!
static gboolean gh_gstsink_start (GstBaseSink * basesink)
{
//do pre work.
//这样调用会崩溃。
//return GST_BASE_SINK_CLASS(parent_class)->start(basesink);
return TRUE;
}
static gboolean gh_gstsink_stop (GstBaseSink * basesink)
{
//release something.
//这样调用会崩溃。
//return GST_BASE_SINK_CLASS(parent_class)->stop(basesink);
return TRUE;
}