+++ /dev/null
-/* GStreamer buffer-frames conversion plugin
- * Copyright (C) 2004 Andy Wingo <wingo at pobox dot com>
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Library General Public
- * License as published by the Free Software Foundation; either
- * version 2 of the License, or (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Library General Public License for more details.
- *
- * You should have received a copy of the GNU Library General Public
- * License along with this library; if not, write to the
- * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
- * Boston, MA 02111-1307, USA.
- */
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include <string.h>
-#include <gst/gst.h>
-#include "plugin.h"
-
-#define GSTPLUGIN_TYPE_BUFFER_FRAMES_CONVERT \
- (gstplugin_buffer_frames_convert_get_type())
-#define BUFFER_FRAMES_CONVERT(obj) \
- (G_TYPE_CHECK_INSTANCE_CAST ((obj), GSTPLUGIN_TYPE_BUFFER_FRAMES_CONVERT, BufferFramesConvert))
-
-typedef struct _BufferFramesConvert BufferFramesConvert;
-typedef struct _BufferFramesConvertClass BufferFramesConvertClass;
-
-struct _BufferFramesConvert
-{
- GstElement element;
-
- GstPad *sinkpad;
- GstPad *srcpad;
-
- gint in_buffer_samples;
- gint out_buffer_samples;
-
- gboolean passthrough;
- GstBuffer *buf_out;
- gint64 offset;
- gint samples_out_remaining;
-};
-
-struct _BufferFramesConvertClass
-{
- GstElementClass parent_class;
-};
-
-static GstElementDetails details = {
- "buffer-frames conversion",
- "Filter/Converter/Audio",
- "Convert between different values of the buffer-frames stream property",
- "Andy Wingo <wingo at pobox.com>"
-};
-
-static GstStaticPadTemplate sink_static_template =
-GST_STATIC_PAD_TEMPLATE ("sink",
- GST_PAD_SINK,
- GST_PAD_ALWAYS,
- GST_STATIC_CAPS ("audio/x-raw-float,"
- "rate = (int) [ 1, MAX ],"
- "channels = (int) [ 1, MAX ],"
- "endianness = (int) BYTE_ORDER,"
- "width = (int) 32," "buffer-frames = (int) [ 0, MAX ]")
- );
-
-static GstStaticPadTemplate src_static_template =
-GST_STATIC_PAD_TEMPLATE ("src",
- GST_PAD_SRC,
- GST_PAD_ALWAYS,
- GST_STATIC_CAPS ("audio/x-raw-float,"
- "rate = (int) [ 1, MAX ],"
- "channels = (int) [ 1, MAX ],"
- "endianness = (int) BYTE_ORDER,"
- "width = (int) 32," "buffer-frames = (int) [ 0, MAX ]")
- );
-
-static void buffer_frames_convert_class_init (BufferFramesConvertClass * klass);
-static void buffer_frames_convert_base_init (BufferFramesConvertClass * klass);
-static void buffer_frames_convert_init (BufferFramesConvert * this);
-
-static GstStateChangeReturn buffer_frames_convert_change_state (GstElement *
- element, GstStateChange transition);
-
-static GstCaps *buffer_frames_convert_getcaps (GstPad * pad);
-static gboolean buffer_frames_convert_setcaps (GstPad * pad, GstCaps * caps);
-static void buffer_frames_convert_fixate (GstPad * pad, GstCaps * caps);
-
-static GstFlowReturn buffer_frames_convert_chain (GstPad * sinkpad,
- GstBuffer * buffer);
-
-static GstElementClass *parent_class = NULL;
-
-GType
-gstplugin_buffer_frames_convert_get_type (void)
-{
- static GType buffer_frames_convert_type = 0;
-
- if (!buffer_frames_convert_type) {
- static const GTypeInfo buffer_frames_convert_info = {
- sizeof (BufferFramesConvertClass),
- (GBaseInitFunc) buffer_frames_convert_base_init,
- NULL,
- (GClassInitFunc) buffer_frames_convert_class_init,
- NULL,
- NULL,
- sizeof (BufferFramesConvert),
- 0,
- (GInstanceInitFunc) buffer_frames_convert_init,
- };
-
- buffer_frames_convert_type =
- g_type_register_static (GST_TYPE_ELEMENT, "GstBufferFramesConvert",
- &buffer_frames_convert_info, 0);
- }
- return buffer_frames_convert_type;
-}
-
-static void
-buffer_frames_convert_base_init (BufferFramesConvertClass * klass)
-{
- GstElementClass *eclass = GST_ELEMENT_CLASS (klass);
-
- gst_element_class_set_details (eclass, &details);
- gst_element_class_add_pad_template
- (eclass, gst_static_pad_template_get (&src_static_template));
- gst_element_class_add_pad_template
- (eclass, gst_static_pad_template_get (&sink_static_template));
-}
-
-static void
-buffer_frames_convert_class_init (BufferFramesConvertClass * klass)
-{
- GstElementClass *eclass = (GstElementClass *) klass;
-
- parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
-
- eclass->change_state = buffer_frames_convert_change_state;
-}
-
-static void
-buffer_frames_convert_init (BufferFramesConvert * this)
-{
- this->sinkpad = gst_pad_new_from_template
- (gst_static_pad_template_get (&sink_static_template), "sink");
- gst_element_add_pad (GST_ELEMENT (this), this->sinkpad);
- gst_pad_set_setcaps_function (this->sinkpad, buffer_frames_convert_setcaps);
- gst_pad_set_getcaps_function (this->sinkpad, buffer_frames_convert_getcaps);
- gst_pad_set_chain_function (this->sinkpad, buffer_frames_convert_chain);
- gst_pad_set_fixatecaps_function (this->sinkpad, buffer_frames_convert_fixate);
-
- this->srcpad = gst_pad_new_from_template
- (gst_static_pad_template_get (&src_static_template), "src");
- gst_element_add_pad (GST_ELEMENT (this), this->srcpad);
- gst_pad_set_setcaps_function (this->srcpad, buffer_frames_convert_setcaps);
- gst_pad_set_getcaps_function (this->srcpad, buffer_frames_convert_getcaps);
- gst_pad_set_fixatecaps_function (this->sinkpad, buffer_frames_convert_fixate);
-
- this->in_buffer_samples = -1;
- this->out_buffer_samples = -1;
-
- this->buf_out = NULL;
- this->samples_out_remaining = 0;
-}
-
-static GstStateChangeReturn
-buffer_frames_convert_change_state (GstElement * element,
- GstStateChange transition)
-{
- BufferFramesConvert *this = (BufferFramesConvert *) element;
-
- switch (transition) {
- case GST_STATE_CHANGE_READY_TO_PAUSED:
- this->offset = 0;
- break;
-
- case GST_STATE_CHANGE_PAUSED_TO_READY:
- if (this->buf_out)
- gst_buffer_unref (this->buf_out);
- this->buf_out = NULL;
- this->samples_out_remaining = 0;
- break;
-
- default:
- break;
- }
-
- if (parent_class->change_state)
- return parent_class->change_state (element, transition);
- return GST_STATE_CHANGE_SUCCESS;
-}
-
-static GstCaps *
-buffer_frames_convert_getcaps (GstPad * pad)
-{
- BufferFramesConvert *this;
- GstPad *otherpad;
- GstCaps *ret;
- int i;
-
- this = BUFFER_FRAMES_CONVERT (GST_OBJECT_PARENT (pad));
-
- otherpad = pad == this->srcpad ? this->sinkpad : this->srcpad;
- ret = gst_pad_get_allowed_caps (otherpad);
-
- for (i = 0; i < gst_caps_get_size (ret); i++)
- gst_structure_set (gst_caps_get_structure (ret, i),
- "buffer-frames", GST_TYPE_INT_RANGE, 0, G_MAXINT, NULL);
-
- GST_DEBUG ("allowed caps %" GST_PTR_FORMAT, ret);
-
- return ret;
-}
-
-static void
-buffer_frames_convert_fixate (GstPad * pad, GstCaps * caps)
-{
- GstStructure *structure;
-
- structure = gst_caps_get_structure (caps, 0);
-
- gst_caps_structure_fixate_field_nearest_int (structure, "buffer-frames", 256);
-}
-
-static gboolean
-buffer_frames_convert_setcaps (GstPad * pad, GstCaps * caps)
-{
-#if 0
- BufferFramesConvert *this;
- GstCaps *othercaps;
- GstPad *otherpad;
- GstPadLinkReturn ret;
- GstStructure *sinkstructure, *srcstructure;
- gint numchannels;
-
- this = BUFFER_FRAMES_CONVERT (GST_OBJECT_PARENT (pad));
-
- otherpad = pad == this->srcpad ? this->sinkpad : this->srcpad;
-
- /* first try to act as a passthrough */
- ret = gst_pad_set_caps (otherpad, caps);
- if (GST_PAD_LINK_SUCCESSFUL (ret)) {
- this->passthrough = TRUE;
- return ret;
- }
-
- /* then try to set unfixed buffer-frames */
- othercaps = gst_caps_copy (caps);
- gst_caps_set_simple (othercaps, "buffer-frames", GST_TYPE_INT_RANGE, 0,
- G_MAXINT, NULL);
- ret = gst_pad_try_set_caps_nonfixed (otherpad, othercaps);
- if (GST_PAD_LINK_FAILED (ret))
- return ret;
-
- /* it's ok, let's record our data */
- sinkstructure =
- gst_caps_get_structure (pad == this->sinkpad ? caps : othercaps, 0);
- srcstructure =
- gst_caps_get_structure (pad == this->srcpad ? caps : othercaps, 0);
- gst_structure_get_int (sinkstructure, "buffer-frames",
- &this->in_buffer_samples);
- gst_structure_get_int (srcstructure, "buffer-frames",
- &this->out_buffer_samples);
-
- gst_structure_get_int (sinkstructure, "channels", &numchannels);
- this->in_buffer_samples *= numchannels;
- this->out_buffer_samples *= numchannels;
-
- if (this->out_buffer_samples == 0)
- this->passthrough = TRUE;
-#endif
-
- return TRUE;
-}
-
-static GstFlowReturn
-buffer_frames_convert_chain (GstPad * pad, GstBuffer * buf)
-{
- BufferFramesConvert *this;
- GstBuffer *buf_in, *buf_out;
- gfloat *data_in;
- gfloat *data_out;
- gint i, samples_in, samples_in_remaining, samples_out_remaining,
- out_buffer_samples;
- GstFlowReturn ret;
-
-
- this = (BufferFramesConvert *) GST_OBJECT_PARENT (pad);
-
- if (this->passthrough) {
- return gst_pad_push (this->srcpad, buf);
- }
-
- buf_in = buf;
- data_in = (gfloat *) GST_BUFFER_DATA (buf_in);
- samples_in = samples_in_remaining =
- GST_BUFFER_SIZE (buf_in) / sizeof (gfloat);
- out_buffer_samples = this->out_buffer_samples;
-
- /* deal with any leftover buffer */
- if (this->buf_out) {
- samples_out_remaining = this->samples_out_remaining;
- buf_out = this->buf_out;
- data_out = (gfloat *) GST_BUFFER_DATA (buf_out);
- data_out += out_buffer_samples - samples_out_remaining;
-
- i = MIN (samples_out_remaining, samples_in_remaining);
- samples_in_remaining -= i;
- samples_out_remaining -= i;
- while (i--)
- *(data_out++) = *(data_in++);
-
- if (!samples_out_remaining) {
- this->buf_out = NULL;
- this->samples_out_remaining = 0;
- gst_pad_push (this->srcpad, buf_out);
- } else {
- /* we used up the incoming samples, but didn't fill our buffer */
- this->samples_out_remaining = samples_out_remaining;
- gst_buffer_unref (buf_in);
- return GST_FLOW_OK;
- }
- }
-
- /* use a fast subbuffer while we can */
- while (samples_in_remaining > out_buffer_samples) {
- buf_out = gst_buffer_create_sub (buf_in,
- (samples_in - samples_in_remaining) * sizeof (gfloat),
- out_buffer_samples * sizeof (gfloat));
- data_in += out_buffer_samples;
- samples_in_remaining -= out_buffer_samples;
- gst_pad_push (this->srcpad, buf_out);
- }
-
- /* if there's an event coming next, just push what we have */
- if (this->in_buffer_samples && samples_in != this->in_buffer_samples
- && samples_in_remaining) {
- buf_out =
- gst_buffer_create_sub (buf_in,
- (samples_in - samples_in_remaining) * sizeof (gfloat),
- samples_in_remaining * sizeof (gfloat));
- gst_pad_push (this->srcpad, buf_out);
- } else {
- /* otherwise make a leftover buffer if it's necessary */
- if (samples_in_remaining) {
- ret =
- gst_pad_alloc_buffer (this->srcpad, 0,
- out_buffer_samples * sizeof (gfloat), GST_PAD_CAPS (this->srcpad),
- &buf_out);
- if (ret != GST_FLOW_OK)
- goto done;
-
- data_out = (gfloat *) GST_BUFFER_DATA (buf_out);
- this->buf_out = buf_out;
- this->samples_out_remaining = out_buffer_samples - samples_in_remaining;
- while (samples_in_remaining--)
- *(data_out++) = *(data_in++);
- }
- }
- ret = GST_FLOW_OK;
-
-done:
- gst_buffer_unref (buf_in);
-
- return ret;
-}
projects / platform / upstream / gst-plugins-base.git / commitdiff