chain 函数

链式函数( chain function )是所有数据处理都在其中进行的函数。在简单过滤器的情况下，_chain()函数主要是线性函数—因此对于每个传入缓冲区，也会有一个缓冲区输出。下面是一个非常简单的链式函数实现:

static GstFlowReturn gst_my_filter_chain (GstPad    *pad,GstObject *parent,GstBuffer *buf);[..]static void
gst_my_filter_init (GstMyFilter * filter)
{
[..]/* configure chain function on the pad before adding* the pad to the element */gst_pad_set_chain_function (filter->sinkpad,gst_my_filter_chain);
[..]
}static GstFlowReturn
gst_my_filter_chain (GstPad    *pad,GstObject *parent,GstBuffer *buf)
{GstMyFilter *filter = GST_MY_FILTER (parent);if (!filter->silent)g_print ("Have data of size %" G_GSIZE_FORMAT" bytes!\n",gst_buffer_get_size (buf));return gst_pad_push (filter->srcpad, buf);
}

显然，上述内容没有多大用处。您通常会在那里处理数据，而不是打印数据所在的位置。但是请记住，缓冲区并不总是可写的。
在更高级的元素(进行事件处理的元素)中，您可能希望额外指定一个事件处理函数，该函数将在发送流事件时调用(例如caps, end- stream, newsegment, tags等)。

static void
gst_my_filter_init (GstMyFilter * filter)
{
[..]gst_pad_set_event_function (filter->sinkpad,gst_my_filter_sink_event);
[..]
}static gboolean
gst_my_filter_sink_event (GstPad    *pad,GstObject *parent,GstEvent  *event)
{GstMyFilter *filter = GST_MY_FILTER (parent);switch (GST_EVENT_TYPE (event)) {case GST_EVENT_CAPS:/* we should handle the format here */break;case GST_EVENT_EOS:/* end-of-stream, we should close down all stream leftovers here */gst_my_filter_stop_processing (filter);break;default:break;}return gst_pad_event_default (pad, parent, event);
}static GstFlowReturn
gst_my_filter_chain (GstPad    *pad,GstObject *parent,GstBuffer *buf)
{GstMyFilter *filter = GST_MY_FILTER (parent);GstBuffer *outbuf;outbuf = gst_my_filter_process_data (filter, buf);gst_buffer_unref (buf);if (!outbuf) {/* something went wrong - signal an error */GST_ELEMENT_ERROR (GST_ELEMENT (filter), STREAM, FAILED, (NULL), (NULL));return GST_FLOW_ERROR;}return gst_pad_push (filter->srcpad, outbuf);
}

在某些情况下，元素也可以控制输入数据速率。在这种情况下，您可能希望编写一个所谓的基于循环的元素。Source elements(只有source pads)也可以是基于get的元素。这些概念将在本指南的高级部分和专门讨论source pads (源垫)的部分中进行解释。