2007-08-14 13:50:43 +00:00
|
|
|
/* GStreamer
|
|
|
|
* Copyright (C) 2007 Nokia Corporation (contact <stefan.kost@nokia.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.
|
|
|
|
*/
|
|
|
|
/**
|
|
|
|
* SECTION:element-rndbuffersize
|
|
|
|
*
|
|
|
|
* This element pulls buffers with random sizes from the source.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#ifdef HAVE_CONFIG_H
|
2012-05-08 17:45:34 +00:00
|
|
|
#include "config.h"
|
2007-08-14 13:50:43 +00:00
|
|
|
#endif
|
|
|
|
|
|
|
|
#include <gst/gst.h>
|
|
|
|
|
|
|
|
GST_DEBUG_CATEGORY_STATIC (gst_rnd_buffer_size_debug);
|
|
|
|
#define GST_CAT_DEFAULT gst_rnd_buffer_size_debug
|
|
|
|
|
|
|
|
#define GST_TYPE_RND_BUFFER_SIZE (gst_rnd_buffer_size_get_type())
|
|
|
|
#define GST_RND_BUFFER_SIZE(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RND_BUFFER_SIZE,GstRndBufferSize))
|
|
|
|
#define GST_RND_BUFFER_SIZE_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RND_BUFFER_SIZE,GstRndBufferSizeClass))
|
|
|
|
#define GST_IS_RND_BUFFER_SIZE(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RND_BUFFER_SIZE))
|
|
|
|
#define GST_IS_RND_BUFFER_SIZE_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RND_BUFFER_SIZE))
|
|
|
|
|
|
|
|
typedef struct _GstRndBufferSize GstRndBufferSize;
|
|
|
|
typedef struct _GstRndBufferSizeClass GstRndBufferSizeClass;
|
|
|
|
|
|
|
|
struct _GstRndBufferSize
|
|
|
|
{
|
|
|
|
GstElement parent;
|
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
/*< private > */
|
2007-08-14 13:50:43 +00:00
|
|
|
GRand *rand;
|
|
|
|
gulong seed;
|
|
|
|
glong min, max;
|
|
|
|
|
|
|
|
GstPad *sinkpad, *srcpad;
|
|
|
|
guint64 offset;
|
2012-05-08 17:45:34 +00:00
|
|
|
|
|
|
|
gboolean need_newsegment;
|
2007-08-14 13:50:43 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
struct _GstRndBufferSizeClass
|
|
|
|
{
|
|
|
|
GstElementClass parent_class;
|
|
|
|
};
|
|
|
|
|
|
|
|
enum
|
|
|
|
{
|
|
|
|
ARG_SEED = 1,
|
|
|
|
ARG_MINIMUM,
|
|
|
|
ARG_MAXIMUM
|
|
|
|
};
|
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
#define DEFAULT_SEED 0
|
|
|
|
#define DEFAULT_MIN 1
|
|
|
|
#define DEFAULT_MAX (8*1024)
|
|
|
|
|
|
|
|
static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
|
2007-08-14 13:50:43 +00:00
|
|
|
GST_PAD_SRC,
|
|
|
|
GST_PAD_ALWAYS,
|
|
|
|
GST_STATIC_CAPS_ANY);
|
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
|
2007-08-14 13:50:43 +00:00
|
|
|
GST_PAD_SINK,
|
|
|
|
GST_PAD_ALWAYS,
|
|
|
|
GST_STATIC_CAPS_ANY);
|
|
|
|
|
2007-08-16 07:40:48 +00:00
|
|
|
static void gst_rnd_buffer_size_finalize (GObject * object);
|
2007-08-14 13:50:43 +00:00
|
|
|
static void gst_rnd_buffer_size_set_property (GObject * object, guint prop_id,
|
|
|
|
const GValue * value, GParamSpec * pspec);
|
|
|
|
static void gst_rnd_buffer_size_get_property (GObject * object, guint prop_id,
|
|
|
|
GValue * value, GParamSpec * pspec);
|
|
|
|
|
2011-11-18 12:57:20 +00:00
|
|
|
static gboolean gst_rnd_buffer_size_activate (GstPad * pad, GstObject * parent);
|
2011-11-21 12:37:01 +00:00
|
|
|
static gboolean gst_rnd_buffer_size_activate_mode (GstPad * pad,
|
|
|
|
GstObject * parent, GstPadMode mode, gboolean active);
|
2007-08-14 13:50:43 +00:00
|
|
|
static void gst_rnd_buffer_size_loop (GstRndBufferSize * self);
|
|
|
|
static GstStateChangeReturn gst_rnd_buffer_size_change_state (GstElement *
|
|
|
|
element, GstStateChange transition);
|
2012-05-09 10:15:21 +00:00
|
|
|
static gboolean gst_rnd_buffer_size_src_event (GstPad * pad,
|
|
|
|
GstObject * parent, GstEvent * event);
|
2007-08-14 13:50:43 +00:00
|
|
|
|
2010-03-17 17:23:00 +00:00
|
|
|
GType gst_rnd_buffer_size_get_type (void);
|
2011-06-07 10:06:08 +00:00
|
|
|
#define gst_rnd_buffer_size_parent_class parent_class
|
|
|
|
G_DEFINE_TYPE (GstRndBufferSize, gst_rnd_buffer_size, GST_TYPE_ELEMENT);
|
2007-08-14 13:50:43 +00:00
|
|
|
|
|
|
|
static void
|
2011-06-07 10:06:08 +00:00
|
|
|
gst_rnd_buffer_size_class_init (GstRndBufferSizeClass * klass)
|
2007-08-14 13:50:43 +00:00
|
|
|
{
|
2011-06-07 10:06:08 +00:00
|
|
|
GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
|
|
|
|
GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
|
|
|
|
|
|
|
|
GST_DEBUG_CATEGORY_INIT (gst_rnd_buffer_size_debug, "rndbuffersize", 0,
|
|
|
|
"rndbuffersize element");
|
|
|
|
|
|
|
|
gobject_class->set_property = gst_rnd_buffer_size_set_property;
|
|
|
|
gobject_class->get_property = gst_rnd_buffer_size_get_property;
|
|
|
|
gobject_class->finalize = gst_rnd_buffer_size_finalize;
|
2007-08-14 13:50:43 +00:00
|
|
|
|
|
|
|
gst_element_class_add_pad_template (gstelement_class,
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
gst_static_pad_template_get (&sink_template));
|
2007-08-14 13:50:43 +00:00
|
|
|
gst_element_class_add_pad_template (gstelement_class,
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
gst_static_pad_template_get (&src_template));
|
2007-08-14 13:50:43 +00:00
|
|
|
|
2012-04-09 23:51:41 +00:00
|
|
|
gst_element_class_set_static_metadata (gstelement_class, "Random buffer size",
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
"Testing", "pull random sized buffers",
|
2011-04-28 12:37:40 +00:00
|
|
|
"Stefan Kost <stefan.kost@nokia.com>");
|
2007-08-14 13:50:43 +00:00
|
|
|
|
|
|
|
gstelement_class->change_state =
|
|
|
|
GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_change_state);
|
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
/* FIXME 0.11: these should all be int instead of long, to avoid bugs
|
|
|
|
* when passing these as varargs with g_object_set(), and there was no
|
|
|
|
* reason to use long in the first place here */
|
2007-08-14 13:50:43 +00:00
|
|
|
g_object_class_install_property (gobject_class, ARG_SEED,
|
|
|
|
g_param_spec_ulong ("seed", "random number seed",
|
|
|
|
"seed for randomness (initialized when going from READY to PAUSED)",
|
2010-10-13 14:21:23 +00:00
|
|
|
0, G_MAXUINT32, DEFAULT_SEED,
|
|
|
|
G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
|
2007-08-14 13:50:43 +00:00
|
|
|
g_object_class_install_property (gobject_class, ARG_MINIMUM,
|
|
|
|
g_param_spec_long ("min", "mininum", "mininum buffer size",
|
2010-10-13 14:21:23 +00:00
|
|
|
0, G_MAXINT32, DEFAULT_MIN,
|
|
|
|
G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
|
2007-08-14 13:50:43 +00:00
|
|
|
g_object_class_install_property (gobject_class, ARG_MAXIMUM,
|
|
|
|
g_param_spec_long ("max", "maximum", "maximum buffer size",
|
2010-10-13 14:21:23 +00:00
|
|
|
1, G_MAXINT32, DEFAULT_MAX,
|
|
|
|
G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2011-06-07 10:06:08 +00:00
|
|
|
gst_rnd_buffer_size_init (GstRndBufferSize * self)
|
2007-08-14 13:50:43 +00:00
|
|
|
{
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
self->sinkpad = gst_pad_new_from_static_template (&sink_template, "sink");
|
2007-08-14 13:50:43 +00:00
|
|
|
gst_pad_set_activate_function (self->sinkpad,
|
|
|
|
GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_activate));
|
2011-11-21 12:37:01 +00:00
|
|
|
gst_pad_set_activatemode_function (self->sinkpad,
|
|
|
|
GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_activate_mode));
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
gst_element_add_pad (GST_ELEMENT (self), self->sinkpad);
|
2007-08-14 13:50:43 +00:00
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
self->srcpad = gst_pad_new_from_static_template (&src_template, "src");
|
2012-05-08 18:07:04 +00:00
|
|
|
gst_pad_set_event_function (self->srcpad,
|
|
|
|
GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_src_event));
|
2007-08-14 13:50:43 +00:00
|
|
|
gst_element_add_pad (GST_ELEMENT (self), self->srcpad);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2007-08-16 07:40:48 +00:00
|
|
|
static void
|
|
|
|
gst_rnd_buffer_size_finalize (GObject * object)
|
|
|
|
{
|
|
|
|
GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
|
|
|
|
|
|
|
|
if (self->rand) {
|
|
|
|
g_rand_free (self->rand);
|
|
|
|
self->rand = NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
G_OBJECT_CLASS (parent_class)->finalize (object);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2007-08-14 13:50:43 +00:00
|
|
|
static void
|
|
|
|
gst_rnd_buffer_size_set_property (GObject * object, guint prop_id,
|
|
|
|
const GValue * value, GParamSpec * pspec)
|
|
|
|
{
|
|
|
|
GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
|
|
|
|
|
|
|
|
switch (prop_id) {
|
|
|
|
case ARG_SEED:
|
|
|
|
self->seed = g_value_get_ulong (value);
|
|
|
|
break;
|
|
|
|
case ARG_MINIMUM:
|
|
|
|
self->min = g_value_get_long (value);
|
|
|
|
break;
|
|
|
|
case ARG_MAXIMUM:
|
|
|
|
self->max = g_value_get_long (value);
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
gst_rnd_buffer_size_get_property (GObject * object, guint prop_id,
|
|
|
|
GValue * value, GParamSpec * pspec)
|
|
|
|
{
|
|
|
|
GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
|
|
|
|
|
|
|
|
switch (prop_id) {
|
|
|
|
case ARG_SEED:
|
|
|
|
g_value_set_ulong (value, self->seed);
|
|
|
|
break;
|
|
|
|
case ARG_MINIMUM:
|
|
|
|
g_value_set_long (value, self->min);
|
|
|
|
break;
|
|
|
|
case ARG_MAXIMUM:
|
|
|
|
g_value_set_long (value, self->max);
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
static gboolean
|
2011-11-18 12:57:20 +00:00
|
|
|
gst_rnd_buffer_size_activate (GstPad * pad, GstObject * parent)
|
2007-08-14 13:50:43 +00:00
|
|
|
{
|
2011-07-10 09:40:40 +00:00
|
|
|
GstQuery *query;
|
|
|
|
gboolean pull_mode;
|
|
|
|
|
|
|
|
query = gst_query_new_scheduling ();
|
|
|
|
|
|
|
|
if (!gst_pad_peer_query (pad, query)) {
|
|
|
|
gst_query_unref (query);
|
|
|
|
goto no_pull;
|
|
|
|
}
|
|
|
|
|
2011-11-18 16:59:16 +00:00
|
|
|
pull_mode = gst_query_has_scheduling_mode (query, GST_PAD_MODE_PULL);
|
|
|
|
gst_query_unref (query);
|
2011-07-10 09:40:40 +00:00
|
|
|
|
|
|
|
if (!pull_mode)
|
|
|
|
goto no_pull;
|
|
|
|
|
|
|
|
GST_DEBUG_OBJECT (pad, "activating pull");
|
2011-11-21 12:37:01 +00:00
|
|
|
return gst_pad_activate_mode (pad, GST_PAD_MODE_PULL, TRUE);
|
2011-07-10 09:40:40 +00:00
|
|
|
|
|
|
|
/* ERRORS */
|
|
|
|
no_pull:
|
|
|
|
{
|
|
|
|
GST_DEBUG_OBJECT (pad, "pull mode not supported");
|
2007-08-14 13:50:43 +00:00
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
static gboolean
|
2011-11-21 12:37:01 +00:00
|
|
|
gst_rnd_buffer_size_activate_mode (GstPad * pad, GstObject * parent,
|
|
|
|
GstPadMode mode, gboolean active)
|
2007-08-14 13:50:43 +00:00
|
|
|
{
|
2011-11-21 12:37:01 +00:00
|
|
|
gboolean res;
|
2011-11-18 12:57:20 +00:00
|
|
|
GstRndBufferSize *self = GST_RND_BUFFER_SIZE (parent);
|
2007-08-14 13:50:43 +00:00
|
|
|
|
2011-11-21 12:37:01 +00:00
|
|
|
switch (mode) {
|
|
|
|
case GST_PAD_MODE_PULL:
|
|
|
|
if (active) {
|
|
|
|
GST_INFO_OBJECT (self, "starting pull");
|
|
|
|
res =
|
|
|
|
gst_pad_start_task (pad, (GstTaskFunction) gst_rnd_buffer_size_loop,
|
|
|
|
self);
|
2012-05-08 17:45:34 +00:00
|
|
|
self->need_newsegment = TRUE;
|
2011-11-21 12:37:01 +00:00
|
|
|
} else {
|
|
|
|
GST_INFO_OBJECT (self, "stopping pull");
|
|
|
|
res = gst_pad_stop_task (pad);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
res = FALSE;
|
|
|
|
break;
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
2011-11-21 12:37:01 +00:00
|
|
|
return res;
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
|
|
|
|
2012-05-08 18:07:04 +00:00
|
|
|
static gboolean
|
2012-05-09 10:15:21 +00:00
|
|
|
gst_rnd_buffer_size_src_event (GstPad * pad, GstObject * parent,
|
|
|
|
GstEvent * event)
|
2012-05-08 18:07:04 +00:00
|
|
|
{
|
|
|
|
GstRndBufferSize *self;
|
|
|
|
GstSeekType start_type;
|
|
|
|
GstSeekFlags flags;
|
|
|
|
GstFormat format;
|
|
|
|
gint64 start;
|
|
|
|
|
|
|
|
if (GST_EVENT_TYPE (event) != GST_EVENT_SEEK) {
|
|
|
|
GST_WARNING_OBJECT (pad, "dropping %s event", GST_EVENT_TYPE_NAME (event));
|
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
|
2012-05-09 10:15:21 +00:00
|
|
|
self = GST_RND_BUFFER_SIZE (parent);
|
2012-05-08 18:07:04 +00:00
|
|
|
gst_event_parse_seek (event, NULL, &format, &flags, &start_type, &start,
|
|
|
|
NULL, NULL);
|
|
|
|
|
|
|
|
if (format != GST_FORMAT_BYTES) {
|
|
|
|
GST_WARNING_OBJECT (pad, "only BYTE format supported");
|
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
if (start_type != GST_SEEK_TYPE_SET) {
|
|
|
|
GST_WARNING_OBJECT (pad, "only SEEK_TYPE_SET supported");
|
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
|
|
|
|
if ((flags & GST_SEEK_FLAG_FLUSH)) {
|
|
|
|
gst_pad_push_event (self->srcpad, gst_event_new_flush_start ());
|
|
|
|
gst_pad_push_event (self->sinkpad, gst_event_new_flush_start ());
|
|
|
|
} else {
|
|
|
|
gst_pad_pause_task (self->sinkpad);
|
|
|
|
}
|
|
|
|
|
|
|
|
GST_PAD_STREAM_LOCK (self->sinkpad);
|
|
|
|
|
2012-05-09 11:24:37 +00:00
|
|
|
gst_pad_push_event (self->srcpad, gst_event_new_flush_stop (TRUE));
|
|
|
|
gst_pad_push_event (self->sinkpad, gst_event_new_flush_stop (TRUE));
|
|
|
|
|
2012-05-08 18:07:04 +00:00
|
|
|
GST_INFO_OBJECT (pad, "seeking to offset %" G_GINT64_FORMAT, start);
|
|
|
|
|
|
|
|
self->offset = start;
|
|
|
|
self->need_newsegment = TRUE;
|
|
|
|
|
|
|
|
gst_pad_start_task (self->sinkpad, (GstTaskFunction) gst_rnd_buffer_size_loop,
|
|
|
|
self);
|
|
|
|
|
|
|
|
GST_PAD_STREAM_UNLOCK (self->sinkpad);
|
|
|
|
return TRUE;
|
|
|
|
}
|
2007-08-14 13:50:43 +00:00
|
|
|
|
|
|
|
static void
|
|
|
|
gst_rnd_buffer_size_loop (GstRndBufferSize * self)
|
|
|
|
{
|
|
|
|
GstBuffer *buf = NULL;
|
|
|
|
GstFlowReturn ret;
|
2011-07-10 09:40:40 +00:00
|
|
|
guint num_bytes, size;
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
|
|
|
|
if (G_UNLIKELY (self->min > self->max))
|
|
|
|
goto bogus_minmax;
|
|
|
|
|
|
|
|
if (G_UNLIKELY (self->min != self->max)) {
|
|
|
|
num_bytes = g_rand_int_range (self->rand, self->min, self->max);
|
|
|
|
} else {
|
|
|
|
num_bytes = self->min;
|
|
|
|
}
|
|
|
|
|
|
|
|
GST_LOG_OBJECT (self, "pulling %u bytes at offset %" G_GUINT64_FORMAT,
|
|
|
|
num_bytes, self->offset);
|
2007-08-14 13:50:43 +00:00
|
|
|
|
|
|
|
ret = gst_pad_pull_range (self->sinkpad, self->offset, num_bytes, &buf);
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
|
|
|
|
if (ret != GST_FLOW_OK)
|
|
|
|
goto pull_failed;
|
|
|
|
|
2011-07-10 09:40:40 +00:00
|
|
|
size = gst_buffer_get_size (buf);
|
|
|
|
|
|
|
|
if (size < num_bytes) {
|
|
|
|
GST_WARNING_OBJECT (self, "short buffer: %u bytes", size);
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
}
|
|
|
|
|
2012-05-08 17:45:34 +00:00
|
|
|
if (self->need_newsegment) {
|
|
|
|
GstSegment segment;
|
|
|
|
|
|
|
|
gst_segment_init (&segment, GST_FORMAT_BYTES);
|
|
|
|
segment.start = self->offset;
|
|
|
|
gst_pad_push_event (self->srcpad, gst_event_new_segment (&segment));
|
|
|
|
self->need_newsegment = FALSE;
|
|
|
|
}
|
|
|
|
|
2011-07-10 09:40:40 +00:00
|
|
|
self->offset += size;
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
|
|
|
|
ret = gst_pad_push (self->srcpad, buf);
|
|
|
|
|
|
|
|
if (ret != GST_FLOW_OK)
|
|
|
|
goto push_failed;
|
|
|
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
pause_task:
|
|
|
|
{
|
|
|
|
GST_DEBUG_OBJECT (self, "pausing task");
|
|
|
|
gst_pad_pause_task (self->sinkpad);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
pull_failed:
|
|
|
|
{
|
2012-01-03 14:26:21 +00:00
|
|
|
if (ret == GST_FLOW_EOS) {
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
GST_DEBUG_OBJECT (self, "eos");
|
|
|
|
gst_pad_push_event (self->srcpad, gst_event_new_eos ());
|
2007-08-14 13:50:43 +00:00
|
|
|
} else {
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
GST_WARNING_OBJECT (self, "pull_range flow: %s", gst_flow_get_name (ret));
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
goto pause_task;
|
|
|
|
}
|
2007-08-14 13:50:43 +00:00
|
|
|
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
push_failed:
|
|
|
|
{
|
|
|
|
GST_DEBUG_OBJECT (self, "push flow: %s", gst_flow_get_name (ret));
|
2012-01-03 14:26:21 +00:00
|
|
|
if (ret == GST_FLOW_EOS) {
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
GST_DEBUG_OBJECT (self, "eos");
|
2007-08-14 13:50:43 +00:00
|
|
|
gst_pad_push_event (self->srcpad, gst_event_new_eos ());
|
2012-01-03 14:26:21 +00:00
|
|
|
} else if (ret < GST_FLOW_EOS || ret == GST_FLOW_NOT_LINKED) {
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
GST_ELEMENT_ERROR (self, STREAM, FAILED,
|
|
|
|
("Internal data stream error."),
|
|
|
|
("streaming stopped, reason: %s", gst_flow_get_name (ret)));
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
goto pause_task;
|
|
|
|
}
|
|
|
|
|
|
|
|
bogus_minmax:
|
|
|
|
{
|
|
|
|
GST_ELEMENT_ERROR (self, LIBRARY, SETTINGS,
|
|
|
|
("The minimum buffer size is smaller than the maximum buffer size."),
|
2008-04-28 11:16:32 +00:00
|
|
|
("buffer sizes: max=%ld, min=%ld", self->min, self->max));
|
gst/debug/rndbuffersize.c: Bring rndbuffersize element into a state that doesn't require us to move it to -bad immedi...
Original commit message from CVS:
* gst/debug/rndbuffersize.c: (DEFAULT_SEED), (DEFAULT_MIN),
(DEFAULT_MAX), (src_template), (sink_template),
(gst_rnd_buffer_size_base_init), (gst_rnd_buffer_size_class_init),
(gst_rnd_buffer_size_init), (gst_rnd_buffer_size_activate),
(gst_rnd_buffer_size_loop), (gst_rnd_buffer_size_plugin_init):
Bring rndbuffersize element into a state that doesn't require us
to move it to -bad immediately. For one, fix up default min/max
values so that the element actuall works using the default values.
Also, don't ignore flow return values and do some kind of minimal
eos logic. Allow min=max to pull fixed-sized buffers. Bunch of
other gratuitious clean-ups.
2008-04-25 19:34:31 +00:00
|
|
|
goto pause_task;
|
2007-08-14 13:50:43 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static GstStateChangeReturn
|
|
|
|
gst_rnd_buffer_size_change_state (GstElement * element,
|
|
|
|
GstStateChange transition)
|
|
|
|
{
|
|
|
|
GstRndBufferSize *self = GST_RND_BUFFER_SIZE (element);
|
|
|
|
GstStateChangeReturn ret;
|
|
|
|
|
|
|
|
switch (transition) {
|
|
|
|
case GST_STATE_CHANGE_NULL_TO_READY:
|
|
|
|
break;
|
|
|
|
case GST_STATE_CHANGE_READY_TO_PAUSED:
|
|
|
|
self->offset = 0;
|
2007-08-16 07:40:48 +00:00
|
|
|
if (!self->rand) {
|
|
|
|
self->rand = g_rand_new_with_seed (self->seed);
|
|
|
|
}
|
2007-08-14 13:50:43 +00:00
|
|
|
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:
|
2007-08-16 07:40:48 +00:00
|
|
|
if (self->rand) {
|
|
|
|
g_rand_free (self->rand);
|
|
|
|
self->rand = NULL;
|
|
|
|
}
|
2007-08-14 13:50:43 +00:00
|
|
|
break;
|
|
|
|
case GST_STATE_CHANGE_READY_TO_NULL:
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
return ret;
|
|
|
|
}
|