mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-08 13:18:52 +00:00
Remove pad_alloc and all references. This can now be done more efficiently and more flexible with the ALLOCATION query and the bufferpool objects. There is no reverse negotiation yet but that will be done with an event later.
230 lines
6 KiB
C
230 lines
6 KiB
C
|
|
#include <gst/base/gstbasetransform.h>
|
|
|
|
typedef struct
|
|
{
|
|
GstPad *srcpad;
|
|
GstPad *sinkpad;
|
|
GList *events;
|
|
GList *buffers;
|
|
GstElement *trans;
|
|
GstBaseTransformClass *klass;
|
|
} TestTransData;
|
|
|
|
static GstStaticPadTemplate gst_test_trans_src_template =
|
|
GST_STATIC_PAD_TEMPLATE ("src",
|
|
GST_PAD_SRC,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS ("foo/x-bar")
|
|
);
|
|
|
|
static GstStaticPadTemplate gst_test_trans_sink_template =
|
|
GST_STATIC_PAD_TEMPLATE ("sink",
|
|
GST_PAD_SINK,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS ("foo/x-bar")
|
|
);
|
|
|
|
typedef struct _GstTestTrans GstTestTrans;
|
|
typedef struct _GstTestTransClass GstTestTransClass;
|
|
|
|
#define GST_TYPE_TEST_TRANS \
|
|
(gst_test_trans_get_type())
|
|
#define GST_TEST_TRANS(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TEST_TRANS,GstTestTrans))
|
|
#define GST_TEST_TRANS_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TEST_TRANS,GstTestTransClass))
|
|
#define GST_TEST_TRANS_GET_CLASS(obj) \
|
|
(G_TYPE_INSTANCE_GET_CLASS((obj), GST_TYPE_TEST_TRANS, GstTestTransClass))
|
|
#define GST_IS_TEST_TRANS(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TEST_TRANS))
|
|
#define GST_IS_TEST_TRANS_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TEST_TRANS))
|
|
|
|
struct _GstTestTrans
|
|
{
|
|
GstBaseTransform element;
|
|
|
|
TestTransData *data;
|
|
};
|
|
|
|
struct _GstTestTransClass
|
|
{
|
|
GstBaseTransformClass parent_class;
|
|
};
|
|
|
|
GType gst_test_trans_get_type (void);
|
|
|
|
G_DEFINE_TYPE (GstTestTrans, gst_test_trans, GST_TYPE_BASE_TRANSFORM);
|
|
|
|
static GstFlowReturn (*klass_transform) (GstBaseTransform * trans,
|
|
GstBuffer * inbuf, GstBuffer * outbuf) = NULL;
|
|
static GstFlowReturn (*klass_transform_ip) (GstBaseTransform * trans,
|
|
GstBuffer * buf) = NULL;
|
|
static gboolean (*klass_set_caps) (GstBaseTransform * trans, GstCaps * incaps,
|
|
GstCaps * outcaps) = NULL;
|
|
static GstCaps *(*klass_transform_caps) (GstBaseTransform * trans,
|
|
GstPadDirection direction, GstCaps * caps) = NULL;
|
|
static gboolean (*klass_transform_size) (GstBaseTransform * trans,
|
|
GstPadDirection direction, GstCaps * caps, gsize size, GstCaps * othercaps,
|
|
gsize * othersize) = NULL;
|
|
static gboolean klass_passthrough_on_same_caps = FALSE;
|
|
|
|
static GstStaticPadTemplate *sink_template = &gst_test_trans_sink_template;
|
|
static GstStaticPadTemplate *src_template = &gst_test_trans_src_template;
|
|
|
|
static void
|
|
gst_test_trans_class_init (GstTestTransClass * klass)
|
|
{
|
|
GstElementClass *element_class;
|
|
GstBaseTransformClass *trans_class;
|
|
|
|
element_class = (GstElementClass *) klass;
|
|
trans_class = (GstBaseTransformClass *) klass;
|
|
|
|
gst_element_class_set_details_simple (element_class, "TestTrans",
|
|
"Filter/Test", "Test transform", "Wim Taymans <wim.taymans@gmail.com>");
|
|
|
|
gst_element_class_add_pad_template (element_class,
|
|
gst_static_pad_template_get (sink_template));
|
|
gst_element_class_add_pad_template (element_class,
|
|
gst_static_pad_template_get (src_template));
|
|
|
|
trans_class->passthrough_on_same_caps = klass_passthrough_on_same_caps;
|
|
trans_class->transform_ip = klass_transform_ip;
|
|
trans_class->transform = klass_transform;
|
|
trans_class->transform_caps = klass_transform_caps;
|
|
trans_class->transform_size = klass_transform_size;
|
|
trans_class->set_caps = klass_set_caps;
|
|
}
|
|
|
|
static void
|
|
gst_test_trans_init (GstTestTrans * this)
|
|
{
|
|
}
|
|
|
|
static void
|
|
gst_test_trans_set_data (GstTestTrans * this, TestTransData * data)
|
|
{
|
|
this->data = data;
|
|
}
|
|
|
|
static GstFlowReturn
|
|
result_sink_chain (GstPad * pad, GstBuffer * buffer)
|
|
{
|
|
TestTransData *data;
|
|
|
|
data = gst_pad_get_element_private (pad);
|
|
|
|
data->buffers = g_list_append (data->buffers, buffer);
|
|
|
|
return GST_FLOW_OK;
|
|
}
|
|
|
|
#if 0
|
|
static GstFlowReturn
|
|
result_buffer_alloc (GstPad * pad, guint64 offset, guint size, GstCaps * caps,
|
|
GstBuffer ** buf)
|
|
{
|
|
GstFlowReturn res;
|
|
TestTransData *data;
|
|
|
|
data = gst_pad_get_element_private (pad);
|
|
|
|
*buf = gst_buffer_new_and_alloc (size);
|
|
gst_buffer_set_caps (*buf, caps);
|
|
res = GST_FLOW_OK;
|
|
|
|
return res;
|
|
}
|
|
#endif
|
|
|
|
static TestTransData *
|
|
gst_test_trans_new (void)
|
|
{
|
|
TestTransData *res;
|
|
GstPad *tmp;
|
|
GstPadTemplate *templ;
|
|
|
|
res = g_new0 (TestTransData, 1);
|
|
res->trans = g_object_new (GST_TYPE_TEST_TRANS, NULL);
|
|
|
|
templ = gst_static_pad_template_get (sink_template);
|
|
templ->direction = GST_PAD_SRC;
|
|
res->srcpad = gst_pad_new_from_template (templ, "src");
|
|
gst_object_unref (templ);
|
|
|
|
templ = gst_static_pad_template_get (src_template);
|
|
templ->direction = GST_PAD_SINK;
|
|
res->sinkpad = gst_pad_new_from_template (templ, "sink");
|
|
gst_object_unref (templ);
|
|
|
|
res->klass = GST_BASE_TRANSFORM_GET_CLASS (res->trans);
|
|
|
|
gst_test_trans_set_data (GST_TEST_TRANS (res->trans), res);
|
|
gst_pad_set_element_private (res->sinkpad, res);
|
|
|
|
gst_pad_set_chain_function (res->sinkpad, result_sink_chain);
|
|
|
|
tmp = gst_element_get_static_pad (res->trans, "sink");
|
|
gst_pad_link (res->srcpad, tmp);
|
|
gst_object_unref (tmp);
|
|
|
|
tmp = gst_element_get_static_pad (res->trans, "src");
|
|
gst_pad_link (tmp, res->sinkpad);
|
|
gst_object_unref (tmp);
|
|
|
|
gst_pad_set_active (res->sinkpad, TRUE);
|
|
gst_element_set_state (res->trans, GST_STATE_PAUSED);
|
|
gst_pad_set_active (res->srcpad, TRUE);
|
|
|
|
return res;
|
|
}
|
|
|
|
static void
|
|
gst_test_trans_free (TestTransData * data)
|
|
{
|
|
GstPad *tmp;
|
|
|
|
gst_pad_set_active (data->sinkpad, FALSE);
|
|
gst_element_set_state (data->trans, GST_STATE_NULL);
|
|
gst_pad_set_active (data->srcpad, FALSE);
|
|
|
|
tmp = gst_element_get_static_pad (data->trans, "src");
|
|
gst_pad_unlink (tmp, data->sinkpad);
|
|
gst_object_unref (tmp);
|
|
|
|
tmp = gst_element_get_static_pad (data->trans, "sink");
|
|
gst_pad_link (data->srcpad, tmp);
|
|
gst_object_unref (tmp);
|
|
|
|
gst_object_unref (data->srcpad);
|
|
gst_object_unref (data->sinkpad);
|
|
gst_object_unref (data->trans);
|
|
|
|
g_free (data);
|
|
}
|
|
|
|
static GstFlowReturn
|
|
gst_test_trans_push (TestTransData * data, GstBuffer * buffer)
|
|
{
|
|
GstFlowReturn ret;
|
|
|
|
ret = gst_pad_push (data->srcpad, buffer);
|
|
|
|
return ret;
|
|
}
|
|
|
|
static GstBuffer *
|
|
gst_test_trans_pop (TestTransData * data)
|
|
{
|
|
GstBuffer *ret;
|
|
|
|
if (data->buffers) {
|
|
ret = data->buffers->data;
|
|
data->buffers = g_list_delete_link (data->buffers, data->buffers);
|
|
} else {
|
|
ret = NULL;
|
|
}
|
|
return ret;
|
|
}
|