diff --git a/gst/debugutils/Makefile.am b/gst/debugutils/Makefile.am index 5da4974572..15060467fa 100644 --- a/gst/debugutils/Makefile.am +++ b/gst/debugutils/Makefile.am @@ -18,7 +18,9 @@ libgstdebugutilsbad_la_SOURCES = \ fpsdisplaysink.c \ debugutilsbad.c \ gstchecksumsink.c \ - gstchecksumsink.h + gstchecksumsink.h \ + gstchopmydata.c \ + gstchopmydata.h nodist_libgstdebugutilsbad_la_SOURCES = $(BUILT_SOURCES) libgstdebugutilsbad_la_CFLAGS = $(GST_CFLAGS) $(GST_BASE_CFLAGS) $(GST_PLUGINS_BASE_CFLAGS) libgstdebugutilsbad_la_LIBADD = $(GST_BASE_LIBS) $(GST_PLUGINS_BASE_LIBS) \ diff --git a/gst/debugutils/debugutilsbad.c b/gst/debugutils/debugutilsbad.c index 6f574b077c..3ceec512ab 100644 --- a/gst/debugutils/debugutilsbad.c +++ b/gst/debugutils/debugutilsbad.c @@ -25,6 +25,7 @@ GType gst_checksum_sink_get_type (void); GType fps_display_sink_get_type (void); +GType gst_chop_my_data_get_type (void); static gboolean plugin_init (GstPlugin * plugin) @@ -33,6 +34,8 @@ plugin_init (GstPlugin * plugin) gst_checksum_sink_get_type ()); gst_element_register (plugin, "fpsdisplaysink", GST_RANK_NONE, fps_display_sink_get_type ()); + gst_element_register (plugin, "chopmydata", GST_RANK_NONE, + gst_chop_my_data_get_type ()); return TRUE; } diff --git a/gst/debugutils/gstchopmydata.c b/gst/debugutils/gstchopmydata.c new file mode 100644 index 0000000000..22eb2ca49c --- /dev/null +++ b/gst/debugutils/gstchopmydata.c @@ -0,0 +1,414 @@ +/* GStreamer + * Copyright (C) 2010 David Schleef + * + * 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. + */ +/** + * SECTION:element-gstchopmydata + * + * The chopmydata element takes an incoming stream and chops it up + * into randomly sized buffers. Size of outgoing buffers are determined + * by the max-size, min-size, and step-size properties. + * + * + * Example launch line + * |[ + * gst-launch -v audiotestsrc num-buffers=10 ! gstchopmydata min-size=100 + * max-size=200 step-size=2 ! fakesink -v + * ]| + * + * This pipeline will create 10 buffers that are by default 2048 bytes + * each (1024 samples each), and chop them up into buffers that range + * in size from 100 bytes to 200 bytes, with the restriction that sizes + * are a multiple of 2. This restriction is important, because the + * default sample size for audiotestsrc is 2 bytes (one channel, 16-bit + * audio). + * + * + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include +#include +#include "gstchopmydata.h" + +/* prototypes */ + + +static void gst_chop_my_data_set_property (GObject * object, + guint property_id, const GValue * value, GParamSpec * pspec); +static void gst_chop_my_data_get_property (GObject * object, + guint property_id, GValue * value, GParamSpec * pspec); +static void gst_chop_my_data_dispose (GObject * object); +static void gst_chop_my_data_finalize (GObject * object); + +static GstStateChangeReturn +gst_chop_my_data_change_state (GstElement * element, GstStateChange transition); + +static GstFlowReturn gst_chop_my_data_chain (GstPad * pad, GstBuffer * buffer); +static gboolean gst_chop_my_data_sink_event (GstPad * pad, GstEvent * event); +static gboolean gst_chop_my_data_src_event (GstPad * pad, GstEvent * event); + +#define DEFAULT_MAX_SIZE 4096 +#define DEFAULT_MIN_SIZE 1 +#define DEFAULT_STEP_SIZE 1 + +enum +{ + PROP_0, + PROP_MAX_SIZE, + PROP_MIN_SIZE, + PROP_STEP_SIZE +}; + +/* pad templates */ + +static GstStaticPadTemplate gst_chop_my_data_sink_template = +GST_STATIC_PAD_TEMPLATE ("sink", + GST_PAD_SINK, + GST_PAD_ALWAYS, + GST_STATIC_CAPS_ANY); + +static GstStaticPadTemplate gst_chop_my_data_src_template = +GST_STATIC_PAD_TEMPLATE ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS_ANY); + +/* class initialization */ + +GST_BOILERPLATE (GstChopMyData, gst_chop_my_data, GstElement, GST_TYPE_ELEMENT); + +static void +gst_chop_my_data_base_init (gpointer g_class) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); + + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&gst_chop_my_data_src_template)); + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&gst_chop_my_data_sink_template)); + + gst_element_class_set_details_simple (element_class, "FIXME", + "Generic", "FIXME", "David Schleef "); +} + +static void +gst_chop_my_data_class_init (GstChopMyDataClass * klass) +{ + GObjectClass *gobject_class = G_OBJECT_CLASS (klass); + GstElementClass *element_class = GST_ELEMENT_CLASS (klass); + + gobject_class->set_property = gst_chop_my_data_set_property; + gobject_class->get_property = gst_chop_my_data_get_property; + gobject_class->dispose = gst_chop_my_data_dispose; + gobject_class->finalize = gst_chop_my_data_finalize; + element_class->change_state = + GST_DEBUG_FUNCPTR (gst_chop_my_data_change_state); + + g_object_class_install_property (gobject_class, PROP_MAX_SIZE, + g_param_spec_int ("max-size", "max-size", + "Maximum size of outgoing buffers", 1, G_MAXINT, + DEFAULT_MAX_SIZE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); + g_object_class_install_property (gobject_class, PROP_MIN_SIZE, + g_param_spec_int ("min-size", "max-size", + "Minimum size of outgoing buffers", 1, G_MAXINT, + DEFAULT_MIN_SIZE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); + g_object_class_install_property (gobject_class, PROP_STEP_SIZE, + g_param_spec_int ("step-size", "step-size", + "Step increment for random buffer sizes", 1, G_MAXINT, + DEFAULT_MAX_SIZE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); +} + +static void +gst_chop_my_data_init (GstChopMyData * chopmydata, + GstChopMyDataClass * chopmydata_class) +{ + + chopmydata->sinkpad = + gst_pad_new_from_static_template (&gst_chop_my_data_sink_template, + "sink"); + gst_pad_set_event_function (chopmydata->sinkpad, + GST_DEBUG_FUNCPTR (gst_chop_my_data_sink_event)); + gst_pad_set_chain_function (chopmydata->sinkpad, + GST_DEBUG_FUNCPTR (gst_chop_my_data_chain)); + gst_pad_set_getcaps_function (chopmydata->sinkpad, gst_pad_proxy_getcaps); + gst_pad_set_setcaps_function (chopmydata->sinkpad, gst_pad_proxy_setcaps); + gst_element_add_pad (GST_ELEMENT (chopmydata), chopmydata->sinkpad); + + chopmydata->srcpad = + gst_pad_new_from_static_template (&gst_chop_my_data_src_template, "src"); + gst_pad_set_event_function (chopmydata->srcpad, + GST_DEBUG_FUNCPTR (gst_chop_my_data_src_event)); + gst_pad_set_getcaps_function (chopmydata->srcpad, gst_pad_proxy_getcaps); + gst_pad_set_setcaps_function (chopmydata->srcpad, gst_pad_proxy_setcaps); + gst_element_add_pad (GST_ELEMENT (chopmydata), chopmydata->srcpad); + + chopmydata->step_size = DEFAULT_STEP_SIZE; + chopmydata->min_size = DEFAULT_MIN_SIZE; + chopmydata->max_size = DEFAULT_MAX_SIZE; +} + +void +gst_chop_my_data_set_property (GObject * object, guint property_id, + const GValue * value, GParamSpec * pspec) +{ + GstChopMyData *chopmydata; + + g_return_if_fail (GST_IS_CHOP_MY_DATA (object)); + chopmydata = GST_CHOP_MY_DATA (object); + + switch (property_id) { + case PROP_MAX_SIZE: + chopmydata->max_size = g_value_get_int (value); + break; + case PROP_MIN_SIZE: + chopmydata->min_size = g_value_get_int (value); + break; + case PROP_STEP_SIZE: + chopmydata->step_size = g_value_get_int (value); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); + break; + } +} + +void +gst_chop_my_data_get_property (GObject * object, guint property_id, + GValue * value, GParamSpec * pspec) +{ + GstChopMyData *chopmydata; + + g_return_if_fail (GST_IS_CHOP_MY_DATA (object)); + chopmydata = GST_CHOP_MY_DATA (object); + + switch (property_id) { + case PROP_MAX_SIZE: + g_value_set_int (value, chopmydata->max_size); + break; + case PROP_MIN_SIZE: + g_value_set_int (value, chopmydata->min_size); + break; + case PROP_STEP_SIZE: + g_value_set_int (value, chopmydata->step_size); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); + break; + } +} + +void +gst_chop_my_data_dispose (GObject * object) +{ + GstChopMyData *chopmydata; + + g_return_if_fail (GST_IS_CHOP_MY_DATA (object)); + chopmydata = GST_CHOP_MY_DATA (object); + + /* clean up as possible. may be called multiple times */ + + G_OBJECT_CLASS (parent_class)->dispose (object); +} + +void +gst_chop_my_data_finalize (GObject * object) +{ + GstChopMyData *chopmydata; + + g_return_if_fail (GST_IS_CHOP_MY_DATA (object)); + chopmydata = GST_CHOP_MY_DATA (object); + + /* clean up object here */ + + G_OBJECT_CLASS (parent_class)->finalize (object); +} + +static GstStateChangeReturn +gst_chop_my_data_change_state (GstElement * element, GstStateChange transition) +{ + GstChopMyData *chopmydata; + GstStateChangeReturn ret; + + chopmydata = GST_CHOP_MY_DATA (element); + + switch (transition) { + case GST_STATE_CHANGE_NULL_TO_READY: + break; + case GST_STATE_CHANGE_READY_TO_PAUSED: + GST_OBJECT_LOCK (chopmydata); + chopmydata->adapter = gst_adapter_new (); + chopmydata->rand = g_rand_new (); + chopmydata->next_size = 0; + GST_OBJECT_UNLOCK (chopmydata); + break; + case GST_STATE_CHANGE_PAUSED_TO_PLAYING: + break; + default: + break; + } + + ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition); + + switch (transition) { + case GST_STATE_CHANGE_PLAYING_TO_PAUSED: + break; + case GST_STATE_CHANGE_PAUSED_TO_READY: + GST_OBJECT_LOCK (chopmydata); + g_object_unref (chopmydata->adapter); + chopmydata->adapter = NULL; + g_rand_free (chopmydata->rand); + GST_OBJECT_UNLOCK (chopmydata); + break; + case GST_STATE_CHANGE_READY_TO_NULL: + break; + default: + break; + } + + return ret; +} + +static void +get_next_size (GstChopMyData * chopmydata) +{ + int begin; + int end; + + begin = (chopmydata->min_size + chopmydata->step_size - 1) / + chopmydata->step_size; + end = (chopmydata->max_size + chopmydata->step_size) / chopmydata->step_size; + + if (begin >= end) { + chopmydata->next_size = begin * chopmydata->step_size; + return; + } + + chopmydata->next_size = + g_rand_int_range (chopmydata->rand, begin, end) * chopmydata->step_size; +} + +static GstFlowReturn +gst_chop_my_data_process (GstChopMyData * chopmydata, gboolean flush) +{ + GstFlowReturn ret = GST_FLOW_OK; + GstBuffer *buffer; + + if (chopmydata->next_size == 0) { + get_next_size (chopmydata); + } + + while (gst_adapter_available (chopmydata->adapter) >= chopmydata->next_size) { + buffer = + gst_adapter_take_buffer (chopmydata->adapter, chopmydata->next_size); + + chopmydata->next_size = 0; + + ret = gst_pad_push (chopmydata->srcpad, buffer); + if (ret != GST_FLOW_OK) { + return ret; + } + + get_next_size (chopmydata); + } + + if (flush) { + buffer = gst_adapter_take_buffer (chopmydata->adapter, + gst_adapter_available (chopmydata->adapter)); + ret = gst_pad_push (chopmydata->srcpad, buffer); + } + + return ret; +} + +static GstFlowReturn +gst_chop_my_data_chain (GstPad * pad, GstBuffer * buffer) +{ + GstChopMyData *chopmydata; + GstFlowReturn ret; + + chopmydata = GST_CHOP_MY_DATA (gst_pad_get_parent (pad)); + + GST_DEBUG_OBJECT (chopmydata, "chain"); + + gst_adapter_push (chopmydata->adapter, buffer); + ret = gst_chop_my_data_process (chopmydata, FALSE); + + gst_object_unref (chopmydata); + return ret; +} + +static gboolean +gst_chop_my_data_sink_event (GstPad * pad, GstEvent * event) +{ + GstFlowReturn ret = GST_FLOW_OK; + gboolean res; + GstChopMyData *chopmydata; + + chopmydata = GST_CHOP_MY_DATA (gst_pad_get_parent (pad)); + + GST_DEBUG_OBJECT (chopmydata, "event"); + + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_FLUSH_START: + ret = gst_chop_my_data_process (chopmydata, TRUE); + res = gst_pad_push_event (chopmydata->srcpad, event); + break; + case GST_EVENT_FLUSH_STOP: + res = gst_pad_push_event (chopmydata->srcpad, event); + break; + case GST_EVENT_NEWSEGMENT: + res = gst_pad_push_event (chopmydata->srcpad, event); + break; + case GST_EVENT_EOS: + ret = gst_chop_my_data_process (chopmydata, TRUE); + res = gst_pad_push_event (chopmydata->srcpad, event); + break; + default: + res = gst_pad_push_event (chopmydata->srcpad, event); + break; + } + + gst_object_unref (chopmydata); + return TRUE; +} + +static gboolean +gst_chop_my_data_src_event (GstPad * pad, GstEvent * event) +{ + gboolean res; + GstChopMyData *chopmydata; + + chopmydata = GST_CHOP_MY_DATA (gst_pad_get_parent (pad)); + + GST_DEBUG_OBJECT (chopmydata, "event"); + + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_SEEK: + res = gst_pad_push_event (chopmydata->sinkpad, event); + break; + default: + res = gst_pad_push_event (chopmydata->sinkpad, event); + break; + } + + gst_object_unref (chopmydata); + return TRUE; +} diff --git a/gst/debugutils/gstchopmydata.h b/gst/debugutils/gstchopmydata.h new file mode 100644 index 0000000000..b5fc2b798d --- /dev/null +++ b/gst/debugutils/gstchopmydata.h @@ -0,0 +1,65 @@ +/* GStreamer + * Copyright (C) 2010 REAL_NAME + * + * 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. + */ + +#ifndef _GST_CHOP_MY_DATA_H_ +#define _GST_CHOP_MY_DATA_H_ + +#include +#include +#include + +G_BEGIN_DECLS + +#define GST_TYPE_CHOP_MY_DATA (gst_chop_my_data_get_type()) +#define GST_CHOP_MY_DATA(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CHOP_MY_DATA,GstChopMyData)) +#define GST_CHOP_MY_DATA_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CHOP_MY_DATA,GstChopMyDataClass)) +#define GST_IS_CHOP_MY_DATA(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CHOP_MY_DATA)) +#define GST_IS_CHOP_MY_DATA_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CHOP_MY_DATA)) + +typedef struct _GstChopMyData GstChopMyData; +typedef struct _GstChopMyDataClass GstChopMyDataClass; + +struct _GstChopMyData +{ + GstElement base_chopmydata; + + GstPad *srcpad; + GstPad *sinkpad; + GstAdapter *adapter; + GRand *rand; + + /* properties */ + int step_size; + int min_size; + int max_size; + + /* state */ + int next_size; +}; + +struct _GstChopMyDataClass +{ + GstElementClass base_chopmydata_class; +}; + +GType gst_chop_my_data_get_type (void); + +G_END_DECLS + +#endif