+2005-04-04 Wim Taymans <wim@fluendo.com>
+
+ * gst/base/Makefile.am:
+ * gst/base/README:
+ * gst/base/gstbasesink.c: (gst_basesink_base_init),
+ (gst_basesink_pad_getcaps), (gst_basesink_pad_setcaps),
+ (gst_basesink_pad_buffer_alloc), (gst_basesink_init),
+ (gst_basesink_do_sync), (gst_basesink_chain_unlocked):
+ * gst/base/gstbasesrc.c: (gst_basesrc_get_type),
+ (gst_basesrc_base_init), (gst_basesrc_class_init),
+ (gst_basesrc_init), (gst_basesrc_get_formats),
+ (gst_basesrc_get_query_types), (gst_basesrc_query),
+ (gst_basesrc_get_event_mask), (gst_basesrc_event_handler),
+ (gst_basesrc_set_property), (gst_basesrc_get_property),
+ (gst_basesrc_get_range_unlocked), (gst_basesrc_get_range),
+ (gst_basesrc_loop), (gst_basesrc_activate),
+ (gst_basesrc_change_state):
+ * gst/base/gstbasesrc.h:
+ * gst/elements/gstfakesrc.c: (gst_fakesrc_base_init),
+ (gst_fakesrc_class_init), (gst_fakesrc_init),
+ (gst_fakesrc_event_handler), (gst_fakesrc_set_property),
+ (gst_fakesrc_get_property), (gst_fakesrc_create):
+ * gst/elements/gstfakesrc.h:
+ * gst/elements/gstfilesrc.c: (gst_filesrc_getrange),
+ (gst_filesrc_open_file), (gst_filesrc_loop),
+ (gst_filesrc_activate), (filesrc_find_peek),
+ (gst_filesrc_type_find):
+ Made base source class, make fakesrc extend it.
+ Add comments to basesink class.
+ Some filesrc cleanup.
+
2005-03-31 David Schleef <ds@schleef.org>
* gst/gstplugin.c: (gst_plugin_check_file), (gst_plugin_load_file):
../libgstreamer-@GST_MAJORMINOR@.la
libgstbase_@GST_MAJORMINOR@_la_SOURCES = \
gstbasesink.c \
+ gstbasesrc.c \
gstbasetransform.c
libgstbase_@GST_MAJORMINOR@_la_CFLAGS = $(GST_OBJ_CFLAGS)
libgstbase_@GST_MAJORMINOR@include_HEADERS = \
gstbasesink.h \
+ gstbasesrc.h \
gstbasetransform.h
install-data-local: as-libtool-install-data-local
- does flushing
- push mode
- pull mode if transform can operate on arbitrary data
+
+GstBaseSrc
+
+ Base class for getrange based source elements
+
+ - one sinkpad
+ - handles state changes
+ - pull/push mode
bsink = GST_BASESINK (GST_PAD_PARENT (pad));
bclass = GST_BASESINK_GET_CLASS (bsink);
+
if (bclass->set_caps)
res = bclass->set_caps (bsink, caps);
bsink = GST_BASESINK (GST_PAD_PARENT (pad));
bclass = GST_BASESINK_GET_CLASS (bsink);
+
if (bclass->buffer_alloc)
buffer = bclass->buffer_alloc (bsink, offset, size, caps);
return result;
}
+/* default implementation to calculate the start and end
+ * timestamps on a buffer, subclasses cna override
+ */
static void
gst_basesink_get_times (GstBaseSink * basesink, GstBuffer * buffer,
GstClockTime * start, GstClockTime * end)
}
}
+/* perform synchronisation on a buffer
+ *
+ * 1) check if we have a clock, if not, do nothing
+ * 2) calculate the start and end time of the buffer
+ * 3) create a single shot notification to wait on
+ * the clock, save the entry so we can unlock it
+ * 4) wait on the clock, this blocks
+ * 5) unref the clockid again
+ */
static void
gst_basesink_do_sync (GstBaseSink * basesink, GstBuffer * buffer)
{
gst_clock_id_unref (basesink->clock_id);
basesink->clock_id = NULL;
}
+ /* FIXME, don't mess with end_time here */
basesink->end_time = GST_CLOCK_TIME_NONE;
GST_UNLOCK (basesink);
}
}
+/* handle a buffer
+ *
+ * 1) first sync on the buffer
+ * 2) render the buffer
+ * 3) unref the buffer
+ */
static inline void
gst_basesink_handle_buffer (GstBaseSink * basesink, GstBuffer * buf)
{
return GST_FLOW_UNEXPECTED;
default:
g_assert_not_reached ();
- return GST_FLOW_UNEXPECTED;
+ return GST_FLOW_ERROR;
}
}
return result;
}
+/* FIXME, not all sinks can operate in pull mode
+ */
static void
gst_basesink_loop (GstPad * pad)
{
--- /dev/null
+/* GStreamer
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000 Wim Taymans <wtay@chello.be>
+ * 2005 Wim Taymans <wim@fluendo.com>
+ *
+ * gstbasesrc.c:
+ *
+ * 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.
+ */
+
+
+#include <stdlib.h>
+#include <string.h>
+
+#ifdef HAVE_CONFIG_H
+# include "config.h"
+#endif
+
+#include "gstbasesrc.h"
+#include <gst/gstmarshal.h>
+
+#define DEFAULT_BLOCKSIZE 4096
+
+GST_DEBUG_CATEGORY_STATIC (gst_basesrc_debug);
+#define GST_CAT_DEFAULT gst_basesrc_debug
+
+/* BaseSrc signals and args */
+enum
+{
+ /* FILL ME */
+ LAST_SIGNAL
+};
+
+enum
+{
+ ARG_0,
+ ARG_BLOCKSIZE,
+};
+
+static GstElementClass *parent_class = NULL;
+
+static void gst_basesrc_base_init (gpointer g_class);
+static void gst_basesrc_class_init (GstBaseSrcClass * klass);
+static void gst_basesrc_init (GstBaseSrc * src, gpointer g_class);
+
+GType
+gst_basesrc_get_type (void)
+{
+ static GType basesrc_type = 0;
+
+ if (!basesrc_type) {
+ static const GTypeInfo basesrc_info = {
+ sizeof (GstBaseSrcClass),
+ (GBaseInitFunc) gst_basesrc_base_init,
+ NULL,
+ (GClassInitFunc) gst_basesrc_class_init,
+ NULL,
+ NULL,
+ sizeof (GstBaseSrc),
+ 0,
+ (GInstanceInitFunc) gst_basesrc_init,
+ };
+
+ basesrc_type = g_type_register_static (GST_TYPE_ELEMENT,
+ "GstBaseSrc", &basesrc_info, G_TYPE_FLAG_ABSTRACT);
+ }
+ return basesrc_type;
+}
+
+static gboolean gst_basesrc_activate (GstPad * pad, GstActivateMode mode);
+static void gst_basesrc_set_property (GObject * object, guint prop_id,
+ const GValue * value, GParamSpec * pspec);
+static void gst_basesrc_get_property (GObject * object, guint prop_id,
+ GValue * value, GParamSpec * pspec);
+static gboolean gst_basesrc_event_handler (GstPad * pad, GstEvent * event);
+static const GstEventMask *gst_basesrc_get_event_mask (GstPad * pad);
+static const GstQueryType *gst_basesrc_get_query_types (GstPad * pad);
+static gboolean gst_basesrc_query (GstPad * pad, GstQueryType type,
+ GstFormat * format, gint64 * value);
+static const GstFormat *gst_basesrc_get_formats (GstPad * pad);
+
+static GstElementStateReturn gst_basesrc_change_state (GstElement * element);
+
+static void gst_basesrc_loop (GstPad * pad);
+static GstFlowReturn gst_basesrc_get_range (GstPad * pad, guint64 offset,
+ guint length, GstBuffer ** buf);
+
+static void
+gst_basesrc_base_init (gpointer g_class)
+{
+ GST_DEBUG_CATEGORY_INIT (gst_basesrc_debug, "basesrc", 0, "basesrc element");
+}
+
+static void
+gst_basesrc_class_init (GstBaseSrcClass * klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+
+ gobject_class = (GObjectClass *) klass;
+ gstelement_class = (GstElementClass *) klass;
+
+ parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
+
+ gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_basesrc_set_property);
+ gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_basesrc_get_property);
+
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BLOCKSIZE,
+ g_param_spec_ulong ("blocksize", "Block size",
+ "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
+ G_PARAM_READWRITE));
+
+ gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_basesrc_change_state);
+}
+
+static void
+gst_basesrc_init (GstBaseSrc * basesrc, gpointer g_class)
+{
+ GstPad *pad;
+ GstPadTemplate *pad_template;
+
+ pad_template =
+ gst_element_class_get_pad_template (GST_ELEMENT_CLASS (g_class), "src");
+ g_return_if_fail (pad_template != NULL);
+
+ pad = gst_pad_new_from_template (pad_template, "src");
+
+ gst_pad_set_activate_function (pad, gst_basesrc_activate);
+ gst_pad_set_event_function (pad, gst_basesrc_event_handler);
+ gst_pad_set_event_mask_function (pad, gst_basesrc_get_event_mask);
+ gst_pad_set_query_function (pad, gst_basesrc_query);
+ gst_pad_set_query_type_function (pad, gst_basesrc_get_query_types);
+ gst_pad_set_formats_function (pad, gst_basesrc_get_formats);
+ gst_pad_set_loop_function (pad, gst_basesrc_loop);
+ gst_pad_set_getrange_function (pad, gst_basesrc_get_range);
+ gst_element_add_pad (GST_ELEMENT (basesrc), pad);
+
+ basesrc->segment_start = -1;
+ basesrc->segment_end = -1;
+ basesrc->blocksize = DEFAULT_BLOCKSIZE;
+}
+
+static const GstFormat *
+gst_basesrc_get_formats (GstPad * pad)
+{
+ static const GstFormat formats[] = {
+ GST_FORMAT_DEFAULT,
+ 0,
+ };
+
+ return formats;
+}
+
+static const GstQueryType *
+gst_basesrc_get_query_types (GstPad * pad)
+{
+ static const GstQueryType types[] = {
+ GST_QUERY_TOTAL,
+ GST_QUERY_POSITION,
+ GST_QUERY_START,
+ GST_QUERY_SEGMENT_END,
+ 0,
+ };
+
+ return types;
+}
+
+static gboolean
+gst_basesrc_query (GstPad * pad, GstQueryType type,
+ GstFormat * format, gint64 * value)
+{
+ GstBaseSrc *src = GST_BASESRC (GST_PAD_PARENT (pad));
+
+ switch (type) {
+ case GST_QUERY_START:
+ *value = src->segment_start;
+ break;
+ case GST_QUERY_SEGMENT_END:
+ *value = src->segment_end;
+ break;
+ default:
+ return FALSE;
+ }
+ return TRUE;
+}
+
+static const GstEventMask *
+gst_basesrc_get_event_mask (GstPad * pad)
+{
+ static const GstEventMask masks[] = {
+ {GST_EVENT_SEEK, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SEGMENT_LOOP},
+ {GST_EVENT_FLUSH, 0},
+ {0, 0},
+ };
+
+ return masks;
+}
+
+static gboolean
+gst_basesrc_event_handler (GstPad * pad, GstEvent * event)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (GST_PAD_PARENT (pad));
+
+ switch (GST_EVENT_TYPE (event)) {
+ case GST_EVENT_SEEK:
+ src->segment_start = GST_EVENT_SEEK_OFFSET (event);
+ src->segment_end = GST_EVENT_SEEK_ENDOFFSET (event);
+ src->segment_loop =
+ GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_SEGMENT_LOOP;
+ break;
+ case GST_EVENT_FLUSH:
+ break;
+ default:
+ break;
+ }
+ gst_event_unref (event);
+
+ return TRUE;
+}
+
+static void
+gst_basesrc_set_property (GObject * object, guint prop_id, const GValue * value,
+ GParamSpec * pspec)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (object);
+
+ switch (prop_id) {
+ case ARG_BLOCKSIZE:
+ src->blocksize = g_value_get_int (value);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+gst_basesrc_get_property (GObject * object, guint prop_id, GValue * value,
+ GParamSpec * pspec)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (object);
+
+ switch (prop_id) {
+ case ARG_BLOCKSIZE:
+ g_value_set_int (value, src->blocksize);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static GstFlowReturn
+gst_basesrc_get_range_unlocked (GstPad * pad, guint64 offset, guint length,
+ GstBuffer ** buf)
+{
+ GstFlowReturn ret;
+ GstBaseSrc *src;
+ GstBaseSrcClass *bclass;
+
+ src = GST_BASESRC (GST_OBJECT_PARENT (pad));
+ bclass = GST_BASESRC_GET_CLASS (src);
+
+ if (bclass->create)
+ ret = bclass->create (src, offset, length, buf);
+ else
+ ret = GST_FLOW_ERROR;
+
+ return ret;
+}
+
+static GstFlowReturn
+gst_basesrc_get_range (GstPad * pad, guint64 offset, guint length,
+ GstBuffer ** ret)
+{
+ GstFlowReturn fret;
+
+ GST_STREAM_LOCK (pad);
+
+ fret = gst_basesrc_get_range_unlocked (pad, offset, length, ret);
+
+ GST_STREAM_UNLOCK (pad);
+
+ return fret;
+}
+
+static void
+gst_basesrc_loop (GstPad * pad)
+{
+ GstBaseSrc *src;
+ GstBuffer *buf = NULL;
+ GstFlowReturn ret;
+
+ src = GST_BASESRC (GST_OBJECT_PARENT (pad));
+
+ GST_STREAM_LOCK (pad);
+
+ ret =
+ gst_basesrc_get_range_unlocked (pad, src->offset, DEFAULT_BLOCKSIZE,
+ &buf);
+ if (ret != GST_FLOW_OK)
+ goto pause;
+
+ src->offset += GST_BUFFER_SIZE (buf);
+
+ ret = gst_pad_push (pad, buf);
+ if (ret != GST_FLOW_OK)
+ goto pause;
+
+ GST_STREAM_UNLOCK (pad);
+ return;
+
+pause:
+ {
+ gst_task_pause (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ return;
+ }
+}
+
+static gboolean
+gst_basesrc_activate (GstPad * pad, GstActivateMode mode)
+{
+ gboolean result = FALSE;
+ GstBaseSrc *basesrc;
+
+ basesrc = GST_BASESRC (GST_OBJECT_PARENT (pad));
+
+ switch (mode) {
+ case GST_ACTIVATE_PUSH:
+ /* if we have a scheduler we can start the task */
+ if (GST_ELEMENT_SCHEDULER (basesrc)) {
+ GST_STREAM_LOCK (pad);
+ GST_RPAD_TASK (pad) =
+ gst_scheduler_create_task (GST_ELEMENT_SCHEDULER (basesrc),
+ (GstTaskFunction) gst_basesrc_loop, pad);
+
+ gst_task_start (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ result = TRUE;
+ }
+ break;
+ case GST_ACTIVATE_PULL:
+ result = TRUE;
+ break;
+ case GST_ACTIVATE_NONE:
+ /* step 1, unblock clock sync (if any) */
+
+ /* step 2, make sure streaming finishes */
+ GST_STREAM_LOCK (pad);
+ /* step 3, stop the task */
+ if (GST_RPAD_TASK (pad)) {
+ gst_task_stop (GST_RPAD_TASK (pad));
+ gst_object_unref (GST_OBJECT (GST_RPAD_TASK (pad)));
+ GST_RPAD_TASK (pad) = NULL;
+ }
+ GST_STREAM_UNLOCK (pad);
+
+ result = TRUE;
+ break;
+ }
+ return result;
+}
+
+static GstElementStateReturn
+gst_basesrc_change_state (GstElement * element)
+{
+ GstBaseSrc *basesrc;
+ GstElementStateReturn result = GST_STATE_FAILURE;
+ GstElementState transition;
+
+ basesrc = GST_BASESRC (element);
+
+ transition = GST_STATE_TRANSITION (element);
+
+ switch (transition) {
+ case GST_STATE_NULL_TO_READY:
+ break;
+ case GST_STATE_READY_TO_PAUSED:
+ {
+ basesrc->offset = 0;
+ break;
+ }
+ case GST_STATE_PAUSED_TO_PLAYING:
+ break;
+ default:
+ break;
+ }
+
+ result = GST_ELEMENT_CLASS (parent_class)->change_state (element);
+
+ switch (transition) {
+ case GST_STATE_PLAYING_TO_PAUSED:
+ break;
+ case GST_STATE_PAUSED_TO_READY:
+ break;
+ case GST_STATE_READY_TO_NULL:
+ break;
+ default:
+ break;
+ }
+
+ return result;
+}
--- /dev/null
+/* GStreamer
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000 Wim Taymans <wtay@chello.be>
+ * 2005 Wim Taymans <wim@fluendo.com>
+ *
+ * gstbasesrc.h:
+ *
+ * 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_BASESRC_H__
+#define __GST_BASESRC_H__
+
+#include <gst/gst.h>
+
+G_BEGIN_DECLS
+
+#define GST_TYPE_BASESRC (gst_basesrc_get_type())
+#define GST_BASESRC(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_BASESRC,GstBaseSrc))
+#define GST_BASESRC_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_BASESRC,GstBaseSrcClass))
+#define GST_BASESRC_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GST_TYPE_BASESRC, GstBaseSrcClass))
+#define GST_IS_BASESRC(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_BASESRC))
+#define GST_IS_BASESRC_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_BASESRC))
+
+typedef struct _GstBaseSrc GstBaseSrc;
+typedef struct _GstBaseSrcClass GstBaseSrcClass;
+
+struct _GstBaseSrc {
+ GstElement element;
+
+ gint blocksize;
+
+ gint64 segment_start;
+ gint64 segment_end;
+ gboolean segment_loop;
+
+ guint64 offset;
+};
+
+struct _GstBaseSrcClass {
+ GstElementClass parent_class;
+
+ GstCaps* (*get_caps) (GstBaseSrc *src);
+ gboolean (*set_caps) (GstBaseSrc *src, GstCaps *caps);
+
+ gboolean (*start) (GstBaseSrc *src);
+ gboolean (*stop) (GstBaseSrc *src);
+
+ void (*get_times) (GstBaseSrc *src, GstBuffer *buffer,
+ GstClockTime *start, GstClockTime *end);
+
+ gboolean (*event) (GstBaseSrc *src, GstEvent *event);
+ GstFlowReturn (*create) (GstBaseSrc *src, guint64 offset, guint size,
+ GstBuffer **buf);
+};
+
+GType gst_basesrc_get_type(void);
+
+G_END_DECLS
+
+#endif /* __GST_BASESRC_H__ */
{
ARG_0,
ARG_NUM_SOURCES,
- ARG_HAS_LOOP,
- ARG_HAS_GETRANGE,
ARG_OUTPUT,
ARG_DATA,
ARG_SIZETYPE,
ARG_LAST_MESSAGE
};
-GstStaticPadTemplate fakesrc_src_template = GST_STATIC_PAD_TEMPLATE ("src%d",
- GST_PAD_SRC,
- GST_PAD_REQUEST,
- GST_STATIC_CAPS_ANY);
-
#define GST_TYPE_FAKESRC_OUTPUT (gst_fakesrc_output_get_type())
static GType
gst_fakesrc_output_get_type (void)
#define _do_init(bla) \
GST_DEBUG_CATEGORY_INIT (gst_fakesrc_debug, "fakesrc", 0, "fakesrc element");
-GST_BOILERPLATE_FULL (GstFakeSrc, gst_fakesrc, GstElement, GST_TYPE_ELEMENT,
+GST_BOILERPLATE_FULL (GstFakeSrc, gst_fakesrc, GstBaseSrc, GST_TYPE_BASESRC,
_do_init);
-static GstPad *gst_fakesrc_request_new_pad (GstElement * element,
- GstPadTemplate * templ, const gchar * unused);
-static gboolean gst_fakesrc_activate (GstPad * pad, GstActivateMode mode);
static void gst_fakesrc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec);
static void gst_fakesrc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec);
-static void gst_fakesrc_set_clock (GstElement * element, GstClock * clock);
static GstElementStateReturn gst_fakesrc_change_state (GstElement * element);
-static void gst_fakesrc_loop (GstPad * pad);
-static GstFlowReturn gst_fakesrc_get_range (GstPad * pad, guint64 offset,
+static gboolean gst_fakesrc_event_handler (GstBaseSrc * src, GstEvent * event);
+static GstFlowReturn gst_fakesrc_create (GstBaseSrc * src, guint64 offset,
guint length, GstBuffer ** buf);
static guint gst_fakesrc_signals[LAST_SIGNAL] = { 0 };
gst_element_class_add_pad_template (gstelement_class,
gst_static_pad_template_get (&srctemplate));
+
gst_element_class_set_details (gstelement_class, &gst_fakesrc_details);
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&fakesrc_src_template));
}
static void
{
GObjectClass *gobject_class;
GstElementClass *gstelement_class;
+ GstBaseSrcClass *gstbasesrc_class;
gobject_class = (GObjectClass *) klass;
gstelement_class = (GstElementClass *) klass;
+ gstbasesrc_class = (GstBaseSrcClass *) klass;
gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_fakesrc_set_property);
gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_fakesrc_get_property);
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_SOURCES,
g_param_spec_int ("num-sources", "num-sources", "Number of sources",
1, G_MAXINT, 1, G_PARAM_READABLE));
- g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_HAS_LOOP,
- g_param_spec_boolean ("has-loop", "has-loop",
- "Enable loop-based operation", TRUE,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
- g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_HAS_GETRANGE,
- g_param_spec_boolean ("has-getrange", "has-getrange",
- "Enable getrange-based operation", TRUE,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_OUTPUT,
g_param_spec_enum ("output", "output", "Output method (currently unused)",
GST_TYPE_FAKESRC_OUTPUT, FAKESRC_FIRST_LAST_LOOP, G_PARAM_READWRITE));
gst_fakesrc_signals[SIGNAL_HANDOFF] =
g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
G_STRUCT_OFFSET (GstFakeSrcClass, handoff), NULL, NULL,
- gst_marshal_VOID__BOXED_OBJECT, G_TYPE_NONE, 2,
- GST_TYPE_BUFFER | G_SIGNAL_TYPE_STATIC_SCOPE, GST_TYPE_PAD);
+ gst_marshal_VOID__BOXED_OBJECT, G_TYPE_NONE, 1,
+ GST_TYPE_BUFFER | G_SIGNAL_TYPE_STATIC_SCOPE);
- gstelement_class->request_new_pad =
- GST_DEBUG_FUNCPTR (gst_fakesrc_request_new_pad);
gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_fakesrc_change_state);
- gstelement_class->set_clock = GST_DEBUG_FUNCPTR (gst_fakesrc_set_clock);
+
+ gstbasesrc_class->event = GST_DEBUG_FUNCPTR (gst_fakesrc_event_handler);
+ gstbasesrc_class->create = GST_DEBUG_FUNCPTR (gst_fakesrc_create);
}
static void
gst_fakesrc_init (GstFakeSrc * fakesrc)
{
- GstPad *pad;
-
- /* create our first output pad */
- pad =
- gst_pad_new_from_template (gst_static_pad_template_get (&srctemplate),
- "src");
- gst_element_add_pad (GST_ELEMENT (fakesrc), pad);
-
fakesrc->output = FAKESRC_FIRST_LAST_LOOP;
fakesrc->segment_start = -1;
fakesrc->segment_end = -1;
fakesrc->pad_mode = GST_ACTIVATE_NONE;
}
-static void
-gst_fakesrc_set_clock (GstElement * element, GstClock * clock)
-{
- GstFakeSrc *src;
-
- src = GST_FAKESRC (element);
-
- src->clock = clock;
-}
-
-static const GstFormat *
-gst_fakesrc_get_formats (GstPad * pad)
-{
- static const GstFormat formats[] = {
- GST_FORMAT_DEFAULT,
- 0,
- };
-
- return formats;
-}
-
-static const GstQueryType *
-gst_fakesrc_get_query_types (GstPad * pad)
-{
- static const GstQueryType types[] = {
- GST_QUERY_TOTAL,
- GST_QUERY_POSITION,
- GST_QUERY_START,
- GST_QUERY_SEGMENT_END,
- 0,
- };
-
- return types;
-}
-
-static gboolean
-gst_fakesrc_query (GstPad * pad, GstQueryType type,
- GstFormat * format, gint64 * value)
-{
- GstFakeSrc *src = GST_FAKESRC (GST_PAD_PARENT (pad));
-
- switch (type) {
- case GST_QUERY_TOTAL:
- *value = src->num_buffers;
- break;
- case GST_QUERY_POSITION:
- *value = src->buffer_count;
- break;
- case GST_QUERY_START:
- *value = src->segment_start;
- break;
- case GST_QUERY_SEGMENT_END:
- *value = src->segment_end;
- break;
- default:
- return FALSE;
- }
- return TRUE;
-}
-
-static const GstEventMask *
-gst_fakesrc_get_event_mask (GstPad * pad)
-{
- static const GstEventMask masks[] = {
- {GST_EVENT_SEEK, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SEGMENT_LOOP},
- {GST_EVENT_FLUSH, 0},
- {0, 0},
- };
-
- return masks;
-}
-
static gboolean
-gst_fakesrc_event_handler (GstPad * pad, GstEvent * event)
+gst_fakesrc_event_handler (GstBaseSrc * basesrc, GstEvent * event)
{
GstFakeSrc *src;
- src = GST_FAKESRC (GST_PAD_PARENT (pad));
+ src = GST_FAKESRC (basesrc);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
return TRUE;
}
-static void
-gst_fakesrc_set_pad_functions (GstFakeSrc * src, GstPad * pad)
-{
- gst_pad_set_activate_function (pad, gst_fakesrc_activate);
- gst_pad_set_event_function (pad, gst_fakesrc_event_handler);
- gst_pad_set_event_mask_function (pad, gst_fakesrc_get_event_mask);
- gst_pad_set_query_function (pad, gst_fakesrc_query);
- gst_pad_set_query_type_function (pad, gst_fakesrc_get_query_types);
- gst_pad_set_formats_function (pad, gst_fakesrc_get_formats);
-
- if (src->has_loop)
- gst_pad_set_loop_function (pad, gst_fakesrc_loop);
- else
- gst_pad_set_loop_function (pad, NULL);
-
- if (src->has_getrange)
- gst_pad_set_getrange_function (pad, gst_fakesrc_get_range);
- else
- gst_pad_set_getrange_function (pad, NULL);
-}
-
-static void
-gst_fakesrc_set_all_pad_functions (GstFakeSrc * src)
-{
- GList *l;
-
- for (l = GST_ELEMENT_PADS (src); l; l = l->next)
- gst_fakesrc_set_pad_functions (src, (GstPad *) l->data);
-}
-
-static GstPad *
-gst_fakesrc_request_new_pad (GstElement * element, GstPadTemplate * templ,
- const gchar * unused)
-{
- gchar *name;
- GstPad *srcpad;
- GstFakeSrc *fakesrc;
-
- g_return_val_if_fail (GST_IS_FAKESRC (element), NULL);
-
- if (templ->direction != GST_PAD_SRC) {
- g_warning ("gstfakesrc: request new pad that is not a SRC pad\n");
- return NULL;
- }
-
- fakesrc = GST_FAKESRC (element);
-
- name = g_strdup_printf ("src%d", GST_ELEMENT (fakesrc)->numsrcpads);
-
- srcpad = gst_pad_new_from_template (templ, name);
- gst_element_add_pad (GST_ELEMENT (fakesrc), srcpad);
- gst_fakesrc_set_pad_functions (fakesrc, srcpad);
-
- g_free (name);
-
- return srcpad;
-}
-
static void
gst_fakesrc_alloc_parent (GstFakeSrc * src)
{
src = GST_FAKESRC (object);
switch (prop_id) {
- case ARG_HAS_LOOP:
- src->has_loop = g_value_get_boolean (value);
- gst_fakesrc_set_all_pad_functions (src);
- break;
- case ARG_HAS_GETRANGE:
- src->has_getrange = g_value_get_boolean (value);
- gst_fakesrc_set_all_pad_functions (src);
- break;
case ARG_OUTPUT:
g_warning ("not yet implemented");
break;
case ARG_NUM_SOURCES:
g_value_set_int (value, GST_ELEMENT (src)->numsrcpads);
break;
- case ARG_HAS_LOOP:
- g_value_set_boolean (value, src->has_loop);
- break;
- case ARG_HAS_GETRANGE:
- g_value_set_boolean (value, src->has_getrange);
- break;
case ARG_OUTPUT:
g_value_set_enum (value, src->output);
break;
}
static GstFlowReturn
-gst_fakesrc_get_range_unlocked (GstPad * pad, guint64 offset, guint length,
+gst_fakesrc_create (GstBaseSrc * basesrc, guint64 offset, guint length,
GstBuffer ** ret)
{
GstFakeSrc *src;
GstBuffer *buf;
GstClockTime time;
- src = GST_FAKESRC (GST_OBJECT_PARENT (pad));
+ src = GST_FAKESRC (basesrc);
if (src->buffer_count == src->segment_end) {
- if (src->segment_loop) {
- //gst_pad_push_event (pad, gst_event_new (GST_EVENT_SEGMENT_DONE));
- } else {
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
- return GST_FLOW_UNEXPECTED;
- }
+ return GST_FLOW_UNEXPECTED;
}
if (src->rt_num_buffers == 0) {
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
return GST_FLOW_UNEXPECTED;
} else {
if (src->rt_num_buffers > 0)
if (src->eos) {
GST_INFO ("fakesrc is setting eos on pad");
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
return GST_FLOW_UNEXPECTED;
}
g_free (src->last_message);
src->last_message =
- g_strdup_printf ("get ******* (%s:%s)> (%d bytes, %"
- G_GUINT64_FORMAT " ) %p", GST_DEBUG_PAD_NAME (pad),
+ g_strdup_printf ("get ******* > (%d bytes, %"
+ G_GUINT64_FORMAT " ) %p",
GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
g_object_notify (G_OBJECT (src), "last_message");
if (src->signal_handoffs) {
GST_LOG_OBJECT (src, "pre handoff emit");
- g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0,
- buf, pad);
+ g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0, buf);
GST_LOG_OBJECT (src, "post handoff emit");
}
return GST_FLOW_OK;
}
-static GstFlowReturn
-gst_fakesrc_get_range (GstPad * pad, guint64 offset, guint length,
- GstBuffer ** ret)
-{
- GstFlowReturn fret;
-
- g_assert (GST_FAKESRC (GST_OBJECT_PARENT (pad))->pad_mode ==
- GST_ACTIVATE_PULL);
-
- GST_STREAM_LOCK (pad);
-
- fret = gst_fakesrc_get_range_unlocked (pad, offset, length, ret);
-
- GST_STREAM_UNLOCK (pad);
-
- return fret;
-}
-
-static void
-gst_fakesrc_loop (GstPad * pad)
-{
- GstFakeSrc *src;
- GstBuffer *buf = NULL;
- GstFlowReturn ret;
-
- src = GST_FAKESRC (GST_OBJECT_PARENT (pad));
-
- g_assert (src->pad_mode == GST_ACTIVATE_PUSH);
-
- GST_STREAM_LOCK (pad);
- if (src->need_flush) {
- src->need_flush = FALSE;
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_FLUSH));
- }
-
- ret = gst_fakesrc_get_range_unlocked (pad, src->buffer_count,
- DEFAULT_SIZEMAX, &buf);
- if (ret != GST_FLOW_OK) {
- goto pause;
- }
-
- ret = gst_pad_push (pad, buf);
- if (ret != GST_FLOW_OK) {
- goto pause;
- }
-
- GST_STREAM_UNLOCK (pad);
- return;
-
-pause:
- gst_task_pause (GST_RPAD_TASK (pad));
- GST_STREAM_UNLOCK (pad);
- return;
-}
-
-static gboolean
-gst_fakesrc_activate (GstPad * pad, GstActivateMode mode)
-{
- gboolean result = FALSE;
- GstFakeSrc *fakesrc;
-
- fakesrc = GST_FAKESRC (GST_OBJECT_PARENT (pad));
-
- switch (mode) {
- case GST_ACTIVATE_PUSH:
- /* if we have a scheduler we can start the task */
- g_return_val_if_fail (fakesrc->has_loop, FALSE);
- if (GST_ELEMENT_SCHEDULER (fakesrc)) {
- GST_STREAM_LOCK (pad);
- GST_RPAD_TASK (pad) =
- gst_scheduler_create_task (GST_ELEMENT_SCHEDULER (fakesrc),
- (GstTaskFunction) gst_fakesrc_loop, pad);
-
- gst_task_start (GST_RPAD_TASK (pad));
- GST_STREAM_UNLOCK (pad);
- result = TRUE;
- }
- break;
- case GST_ACTIVATE_PULL:
- g_return_val_if_fail (fakesrc->has_getrange, FALSE);
- result = TRUE;
- break;
- case GST_ACTIVATE_NONE:
- /* step 1, unblock clock sync (if any) */
-
- /* step 2, make sure streaming finishes */
- GST_STREAM_LOCK (pad);
- /* step 3, stop the task */
- if (GST_RPAD_TASK (pad)) {
- gst_task_stop (GST_RPAD_TASK (pad));
- gst_object_unref (GST_OBJECT (GST_RPAD_TASK (pad)));
- GST_RPAD_TASK (pad) = NULL;
- }
- GST_STREAM_UNLOCK (pad);
-
- result = TRUE;
- break;
- }
-
- fakesrc->pad_mode = mode;
-
- return result;
-}
-
static GstElementStateReturn
gst_fakesrc_change_state (GstElement * element)
{
#define __GST_FAKESRC_H__
#include <gst/gst.h>
+#include <gst/base/gstbasesrc.h>
G_BEGIN_DECLS
-
typedef enum {
FAKESRC_FIRST_LAST_LOOP = 1,
FAKESRC_LAST_FIRST_LOOP,
typedef struct _GstFakeSrcClass GstFakeSrcClass;
struct _GstFakeSrc {
- GstElement element;
+ GstBaseSrc element;
gboolean has_loop;
gboolean has_getrange;
};
struct _GstFakeSrcClass {
- GstElementClass parent_class;
+ GstBaseSrcClass parent_class;
/* signals */
void (*handoff) (GstElement *element, GstBuffer *buf, GstPad *pad);
GST_STREAM_LOCK (pad);
result = gst_filesrc_get (pad, &buffer);
- if (result != GST_FLOW_OK) {
- gst_task_pause (GST_RPAD_TASK (pad));
- goto done;
- }
+ if (result != GST_FLOW_OK)
+ goto need_pause;
+
result = gst_pad_push (pad, buffer);
- if (result != GST_FLOW_OK) {
+ if (result != GST_FLOW_OK)
+ goto need_pause;
+
+ GST_STREAM_UNLOCK (pad);
+ return;
+
+need_pause:
+ {
gst_task_pause (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ return;
}
-done:
- GST_STREAM_UNLOCK (pad);
}
../libgstreamer-@GST_MAJORMINOR@.la
libgstbase_@GST_MAJORMINOR@_la_SOURCES = \
gstbasesink.c \
+ gstbasesrc.c \
gstbasetransform.c
libgstbase_@GST_MAJORMINOR@_la_CFLAGS = $(GST_OBJ_CFLAGS)
libgstbase_@GST_MAJORMINOR@include_HEADERS = \
gstbasesink.h \
+ gstbasesrc.h \
gstbasetransform.h
install-data-local: as-libtool-install-data-local
- does flushing
- push mode
- pull mode if transform can operate on arbitrary data
+
+GstBaseSrc
+
+ Base class for getrange based source elements
+
+ - one sinkpad
+ - handles state changes
+ - pull/push mode
bsink = GST_BASESINK (GST_PAD_PARENT (pad));
bclass = GST_BASESINK_GET_CLASS (bsink);
+
if (bclass->set_caps)
res = bclass->set_caps (bsink, caps);
bsink = GST_BASESINK (GST_PAD_PARENT (pad));
bclass = GST_BASESINK_GET_CLASS (bsink);
+
if (bclass->buffer_alloc)
buffer = bclass->buffer_alloc (bsink, offset, size, caps);
return result;
}
+/* default implementation to calculate the start and end
+ * timestamps on a buffer, subclasses cna override
+ */
static void
gst_basesink_get_times (GstBaseSink * basesink, GstBuffer * buffer,
GstClockTime * start, GstClockTime * end)
}
}
+/* perform synchronisation on a buffer
+ *
+ * 1) check if we have a clock, if not, do nothing
+ * 2) calculate the start and end time of the buffer
+ * 3) create a single shot notification to wait on
+ * the clock, save the entry so we can unlock it
+ * 4) wait on the clock, this blocks
+ * 5) unref the clockid again
+ */
static void
gst_basesink_do_sync (GstBaseSink * basesink, GstBuffer * buffer)
{
gst_clock_id_unref (basesink->clock_id);
basesink->clock_id = NULL;
}
+ /* FIXME, don't mess with end_time here */
basesink->end_time = GST_CLOCK_TIME_NONE;
GST_UNLOCK (basesink);
}
}
+/* handle a buffer
+ *
+ * 1) first sync on the buffer
+ * 2) render the buffer
+ * 3) unref the buffer
+ */
static inline void
gst_basesink_handle_buffer (GstBaseSink * basesink, GstBuffer * buf)
{
return GST_FLOW_UNEXPECTED;
default:
g_assert_not_reached ();
- return GST_FLOW_UNEXPECTED;
+ return GST_FLOW_ERROR;
}
}
return result;
}
+/* FIXME, not all sinks can operate in pull mode
+ */
static void
gst_basesink_loop (GstPad * pad)
{
--- /dev/null
+/* GStreamer
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000 Wim Taymans <wtay@chello.be>
+ * 2005 Wim Taymans <wim@fluendo.com>
+ *
+ * gstbasesrc.c:
+ *
+ * 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.
+ */
+
+
+#include <stdlib.h>
+#include <string.h>
+
+#ifdef HAVE_CONFIG_H
+# include "config.h"
+#endif
+
+#include "gstbasesrc.h"
+#include <gst/gstmarshal.h>
+
+#define DEFAULT_BLOCKSIZE 4096
+
+GST_DEBUG_CATEGORY_STATIC (gst_basesrc_debug);
+#define GST_CAT_DEFAULT gst_basesrc_debug
+
+/* BaseSrc signals and args */
+enum
+{
+ /* FILL ME */
+ LAST_SIGNAL
+};
+
+enum
+{
+ ARG_0,
+ ARG_BLOCKSIZE,
+};
+
+static GstElementClass *parent_class = NULL;
+
+static void gst_basesrc_base_init (gpointer g_class);
+static void gst_basesrc_class_init (GstBaseSrcClass * klass);
+static void gst_basesrc_init (GstBaseSrc * src, gpointer g_class);
+
+GType
+gst_basesrc_get_type (void)
+{
+ static GType basesrc_type = 0;
+
+ if (!basesrc_type) {
+ static const GTypeInfo basesrc_info = {
+ sizeof (GstBaseSrcClass),
+ (GBaseInitFunc) gst_basesrc_base_init,
+ NULL,
+ (GClassInitFunc) gst_basesrc_class_init,
+ NULL,
+ NULL,
+ sizeof (GstBaseSrc),
+ 0,
+ (GInstanceInitFunc) gst_basesrc_init,
+ };
+
+ basesrc_type = g_type_register_static (GST_TYPE_ELEMENT,
+ "GstBaseSrc", &basesrc_info, G_TYPE_FLAG_ABSTRACT);
+ }
+ return basesrc_type;
+}
+
+static gboolean gst_basesrc_activate (GstPad * pad, GstActivateMode mode);
+static void gst_basesrc_set_property (GObject * object, guint prop_id,
+ const GValue * value, GParamSpec * pspec);
+static void gst_basesrc_get_property (GObject * object, guint prop_id,
+ GValue * value, GParamSpec * pspec);
+static gboolean gst_basesrc_event_handler (GstPad * pad, GstEvent * event);
+static const GstEventMask *gst_basesrc_get_event_mask (GstPad * pad);
+static const GstQueryType *gst_basesrc_get_query_types (GstPad * pad);
+static gboolean gst_basesrc_query (GstPad * pad, GstQueryType type,
+ GstFormat * format, gint64 * value);
+static const GstFormat *gst_basesrc_get_formats (GstPad * pad);
+
+static GstElementStateReturn gst_basesrc_change_state (GstElement * element);
+
+static void gst_basesrc_loop (GstPad * pad);
+static GstFlowReturn gst_basesrc_get_range (GstPad * pad, guint64 offset,
+ guint length, GstBuffer ** buf);
+
+static void
+gst_basesrc_base_init (gpointer g_class)
+{
+ GST_DEBUG_CATEGORY_INIT (gst_basesrc_debug, "basesrc", 0, "basesrc element");
+}
+
+static void
+gst_basesrc_class_init (GstBaseSrcClass * klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+
+ gobject_class = (GObjectClass *) klass;
+ gstelement_class = (GstElementClass *) klass;
+
+ parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
+
+ gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_basesrc_set_property);
+ gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_basesrc_get_property);
+
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BLOCKSIZE,
+ g_param_spec_ulong ("blocksize", "Block size",
+ "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
+ G_PARAM_READWRITE));
+
+ gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_basesrc_change_state);
+}
+
+static void
+gst_basesrc_init (GstBaseSrc * basesrc, gpointer g_class)
+{
+ GstPad *pad;
+ GstPadTemplate *pad_template;
+
+ pad_template =
+ gst_element_class_get_pad_template (GST_ELEMENT_CLASS (g_class), "src");
+ g_return_if_fail (pad_template != NULL);
+
+ pad = gst_pad_new_from_template (pad_template, "src");
+
+ gst_pad_set_activate_function (pad, gst_basesrc_activate);
+ gst_pad_set_event_function (pad, gst_basesrc_event_handler);
+ gst_pad_set_event_mask_function (pad, gst_basesrc_get_event_mask);
+ gst_pad_set_query_function (pad, gst_basesrc_query);
+ gst_pad_set_query_type_function (pad, gst_basesrc_get_query_types);
+ gst_pad_set_formats_function (pad, gst_basesrc_get_formats);
+ gst_pad_set_loop_function (pad, gst_basesrc_loop);
+ gst_pad_set_getrange_function (pad, gst_basesrc_get_range);
+ gst_element_add_pad (GST_ELEMENT (basesrc), pad);
+
+ basesrc->segment_start = -1;
+ basesrc->segment_end = -1;
+ basesrc->blocksize = DEFAULT_BLOCKSIZE;
+}
+
+static const GstFormat *
+gst_basesrc_get_formats (GstPad * pad)
+{
+ static const GstFormat formats[] = {
+ GST_FORMAT_DEFAULT,
+ 0,
+ };
+
+ return formats;
+}
+
+static const GstQueryType *
+gst_basesrc_get_query_types (GstPad * pad)
+{
+ static const GstQueryType types[] = {
+ GST_QUERY_TOTAL,
+ GST_QUERY_POSITION,
+ GST_QUERY_START,
+ GST_QUERY_SEGMENT_END,
+ 0,
+ };
+
+ return types;
+}
+
+static gboolean
+gst_basesrc_query (GstPad * pad, GstQueryType type,
+ GstFormat * format, gint64 * value)
+{
+ GstBaseSrc *src = GST_BASESRC (GST_PAD_PARENT (pad));
+
+ switch (type) {
+ case GST_QUERY_START:
+ *value = src->segment_start;
+ break;
+ case GST_QUERY_SEGMENT_END:
+ *value = src->segment_end;
+ break;
+ default:
+ return FALSE;
+ }
+ return TRUE;
+}
+
+static const GstEventMask *
+gst_basesrc_get_event_mask (GstPad * pad)
+{
+ static const GstEventMask masks[] = {
+ {GST_EVENT_SEEK, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SEGMENT_LOOP},
+ {GST_EVENT_FLUSH, 0},
+ {0, 0},
+ };
+
+ return masks;
+}
+
+static gboolean
+gst_basesrc_event_handler (GstPad * pad, GstEvent * event)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (GST_PAD_PARENT (pad));
+
+ switch (GST_EVENT_TYPE (event)) {
+ case GST_EVENT_SEEK:
+ src->segment_start = GST_EVENT_SEEK_OFFSET (event);
+ src->segment_end = GST_EVENT_SEEK_ENDOFFSET (event);
+ src->segment_loop =
+ GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_SEGMENT_LOOP;
+ break;
+ case GST_EVENT_FLUSH:
+ break;
+ default:
+ break;
+ }
+ gst_event_unref (event);
+
+ return TRUE;
+}
+
+static void
+gst_basesrc_set_property (GObject * object, guint prop_id, const GValue * value,
+ GParamSpec * pspec)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (object);
+
+ switch (prop_id) {
+ case ARG_BLOCKSIZE:
+ src->blocksize = g_value_get_int (value);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+gst_basesrc_get_property (GObject * object, guint prop_id, GValue * value,
+ GParamSpec * pspec)
+{
+ GstBaseSrc *src;
+
+ src = GST_BASESRC (object);
+
+ switch (prop_id) {
+ case ARG_BLOCKSIZE:
+ g_value_set_int (value, src->blocksize);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static GstFlowReturn
+gst_basesrc_get_range_unlocked (GstPad * pad, guint64 offset, guint length,
+ GstBuffer ** buf)
+{
+ GstFlowReturn ret;
+ GstBaseSrc *src;
+ GstBaseSrcClass *bclass;
+
+ src = GST_BASESRC (GST_OBJECT_PARENT (pad));
+ bclass = GST_BASESRC_GET_CLASS (src);
+
+ if (bclass->create)
+ ret = bclass->create (src, offset, length, buf);
+ else
+ ret = GST_FLOW_ERROR;
+
+ return ret;
+}
+
+static GstFlowReturn
+gst_basesrc_get_range (GstPad * pad, guint64 offset, guint length,
+ GstBuffer ** ret)
+{
+ GstFlowReturn fret;
+
+ GST_STREAM_LOCK (pad);
+
+ fret = gst_basesrc_get_range_unlocked (pad, offset, length, ret);
+
+ GST_STREAM_UNLOCK (pad);
+
+ return fret;
+}
+
+static void
+gst_basesrc_loop (GstPad * pad)
+{
+ GstBaseSrc *src;
+ GstBuffer *buf = NULL;
+ GstFlowReturn ret;
+
+ src = GST_BASESRC (GST_OBJECT_PARENT (pad));
+
+ GST_STREAM_LOCK (pad);
+
+ ret =
+ gst_basesrc_get_range_unlocked (pad, src->offset, DEFAULT_BLOCKSIZE,
+ &buf);
+ if (ret != GST_FLOW_OK)
+ goto pause;
+
+ src->offset += GST_BUFFER_SIZE (buf);
+
+ ret = gst_pad_push (pad, buf);
+ if (ret != GST_FLOW_OK)
+ goto pause;
+
+ GST_STREAM_UNLOCK (pad);
+ return;
+
+pause:
+ {
+ gst_task_pause (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ return;
+ }
+}
+
+static gboolean
+gst_basesrc_activate (GstPad * pad, GstActivateMode mode)
+{
+ gboolean result = FALSE;
+ GstBaseSrc *basesrc;
+
+ basesrc = GST_BASESRC (GST_OBJECT_PARENT (pad));
+
+ switch (mode) {
+ case GST_ACTIVATE_PUSH:
+ /* if we have a scheduler we can start the task */
+ if (GST_ELEMENT_SCHEDULER (basesrc)) {
+ GST_STREAM_LOCK (pad);
+ GST_RPAD_TASK (pad) =
+ gst_scheduler_create_task (GST_ELEMENT_SCHEDULER (basesrc),
+ (GstTaskFunction) gst_basesrc_loop, pad);
+
+ gst_task_start (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ result = TRUE;
+ }
+ break;
+ case GST_ACTIVATE_PULL:
+ result = TRUE;
+ break;
+ case GST_ACTIVATE_NONE:
+ /* step 1, unblock clock sync (if any) */
+
+ /* step 2, make sure streaming finishes */
+ GST_STREAM_LOCK (pad);
+ /* step 3, stop the task */
+ if (GST_RPAD_TASK (pad)) {
+ gst_task_stop (GST_RPAD_TASK (pad));
+ gst_object_unref (GST_OBJECT (GST_RPAD_TASK (pad)));
+ GST_RPAD_TASK (pad) = NULL;
+ }
+ GST_STREAM_UNLOCK (pad);
+
+ result = TRUE;
+ break;
+ }
+ return result;
+}
+
+static GstElementStateReturn
+gst_basesrc_change_state (GstElement * element)
+{
+ GstBaseSrc *basesrc;
+ GstElementStateReturn result = GST_STATE_FAILURE;
+ GstElementState transition;
+
+ basesrc = GST_BASESRC (element);
+
+ transition = GST_STATE_TRANSITION (element);
+
+ switch (transition) {
+ case GST_STATE_NULL_TO_READY:
+ break;
+ case GST_STATE_READY_TO_PAUSED:
+ {
+ basesrc->offset = 0;
+ break;
+ }
+ case GST_STATE_PAUSED_TO_PLAYING:
+ break;
+ default:
+ break;
+ }
+
+ result = GST_ELEMENT_CLASS (parent_class)->change_state (element);
+
+ switch (transition) {
+ case GST_STATE_PLAYING_TO_PAUSED:
+ break;
+ case GST_STATE_PAUSED_TO_READY:
+ break;
+ case GST_STATE_READY_TO_NULL:
+ break;
+ default:
+ break;
+ }
+
+ return result;
+}
--- /dev/null
+/* GStreamer
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000 Wim Taymans <wtay@chello.be>
+ * 2005 Wim Taymans <wim@fluendo.com>
+ *
+ * gstbasesrc.h:
+ *
+ * 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_BASESRC_H__
+#define __GST_BASESRC_H__
+
+#include <gst/gst.h>
+
+G_BEGIN_DECLS
+
+#define GST_TYPE_BASESRC (gst_basesrc_get_type())
+#define GST_BASESRC(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_BASESRC,GstBaseSrc))
+#define GST_BASESRC_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_BASESRC,GstBaseSrcClass))
+#define GST_BASESRC_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GST_TYPE_BASESRC, GstBaseSrcClass))
+#define GST_IS_BASESRC(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_BASESRC))
+#define GST_IS_BASESRC_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_BASESRC))
+
+typedef struct _GstBaseSrc GstBaseSrc;
+typedef struct _GstBaseSrcClass GstBaseSrcClass;
+
+struct _GstBaseSrc {
+ GstElement element;
+
+ gint blocksize;
+
+ gint64 segment_start;
+ gint64 segment_end;
+ gboolean segment_loop;
+
+ guint64 offset;
+};
+
+struct _GstBaseSrcClass {
+ GstElementClass parent_class;
+
+ GstCaps* (*get_caps) (GstBaseSrc *src);
+ gboolean (*set_caps) (GstBaseSrc *src, GstCaps *caps);
+
+ gboolean (*start) (GstBaseSrc *src);
+ gboolean (*stop) (GstBaseSrc *src);
+
+ void (*get_times) (GstBaseSrc *src, GstBuffer *buffer,
+ GstClockTime *start, GstClockTime *end);
+
+ gboolean (*event) (GstBaseSrc *src, GstEvent *event);
+ GstFlowReturn (*create) (GstBaseSrc *src, guint64 offset, guint size,
+ GstBuffer **buf);
+};
+
+GType gst_basesrc_get_type(void);
+
+G_END_DECLS
+
+#endif /* __GST_BASESRC_H__ */
{
ARG_0,
ARG_NUM_SOURCES,
- ARG_HAS_LOOP,
- ARG_HAS_GETRANGE,
ARG_OUTPUT,
ARG_DATA,
ARG_SIZETYPE,
ARG_LAST_MESSAGE
};
-GstStaticPadTemplate fakesrc_src_template = GST_STATIC_PAD_TEMPLATE ("src%d",
- GST_PAD_SRC,
- GST_PAD_REQUEST,
- GST_STATIC_CAPS_ANY);
-
#define GST_TYPE_FAKESRC_OUTPUT (gst_fakesrc_output_get_type())
static GType
gst_fakesrc_output_get_type (void)
#define _do_init(bla) \
GST_DEBUG_CATEGORY_INIT (gst_fakesrc_debug, "fakesrc", 0, "fakesrc element");
-GST_BOILERPLATE_FULL (GstFakeSrc, gst_fakesrc, GstElement, GST_TYPE_ELEMENT,
+GST_BOILERPLATE_FULL (GstFakeSrc, gst_fakesrc, GstBaseSrc, GST_TYPE_BASESRC,
_do_init);
-static GstPad *gst_fakesrc_request_new_pad (GstElement * element,
- GstPadTemplate * templ, const gchar * unused);
-static gboolean gst_fakesrc_activate (GstPad * pad, GstActivateMode mode);
static void gst_fakesrc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec);
static void gst_fakesrc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec);
-static void gst_fakesrc_set_clock (GstElement * element, GstClock * clock);
static GstElementStateReturn gst_fakesrc_change_state (GstElement * element);
-static void gst_fakesrc_loop (GstPad * pad);
-static GstFlowReturn gst_fakesrc_get_range (GstPad * pad, guint64 offset,
+static gboolean gst_fakesrc_event_handler (GstBaseSrc * src, GstEvent * event);
+static GstFlowReturn gst_fakesrc_create (GstBaseSrc * src, guint64 offset,
guint length, GstBuffer ** buf);
static guint gst_fakesrc_signals[LAST_SIGNAL] = { 0 };
gst_element_class_add_pad_template (gstelement_class,
gst_static_pad_template_get (&srctemplate));
+
gst_element_class_set_details (gstelement_class, &gst_fakesrc_details);
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&fakesrc_src_template));
}
static void
{
GObjectClass *gobject_class;
GstElementClass *gstelement_class;
+ GstBaseSrcClass *gstbasesrc_class;
gobject_class = (GObjectClass *) klass;
gstelement_class = (GstElementClass *) klass;
+ gstbasesrc_class = (GstBaseSrcClass *) klass;
gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_fakesrc_set_property);
gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_fakesrc_get_property);
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_SOURCES,
g_param_spec_int ("num-sources", "num-sources", "Number of sources",
1, G_MAXINT, 1, G_PARAM_READABLE));
- g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_HAS_LOOP,
- g_param_spec_boolean ("has-loop", "has-loop",
- "Enable loop-based operation", TRUE,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
- g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_HAS_GETRANGE,
- g_param_spec_boolean ("has-getrange", "has-getrange",
- "Enable getrange-based operation", TRUE,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_OUTPUT,
g_param_spec_enum ("output", "output", "Output method (currently unused)",
GST_TYPE_FAKESRC_OUTPUT, FAKESRC_FIRST_LAST_LOOP, G_PARAM_READWRITE));
gst_fakesrc_signals[SIGNAL_HANDOFF] =
g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
G_STRUCT_OFFSET (GstFakeSrcClass, handoff), NULL, NULL,
- gst_marshal_VOID__BOXED_OBJECT, G_TYPE_NONE, 2,
- GST_TYPE_BUFFER | G_SIGNAL_TYPE_STATIC_SCOPE, GST_TYPE_PAD);
+ gst_marshal_VOID__BOXED_OBJECT, G_TYPE_NONE, 1,
+ GST_TYPE_BUFFER | G_SIGNAL_TYPE_STATIC_SCOPE);
- gstelement_class->request_new_pad =
- GST_DEBUG_FUNCPTR (gst_fakesrc_request_new_pad);
gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_fakesrc_change_state);
- gstelement_class->set_clock = GST_DEBUG_FUNCPTR (gst_fakesrc_set_clock);
+
+ gstbasesrc_class->event = GST_DEBUG_FUNCPTR (gst_fakesrc_event_handler);
+ gstbasesrc_class->create = GST_DEBUG_FUNCPTR (gst_fakesrc_create);
}
static void
gst_fakesrc_init (GstFakeSrc * fakesrc)
{
- GstPad *pad;
-
- /* create our first output pad */
- pad =
- gst_pad_new_from_template (gst_static_pad_template_get (&srctemplate),
- "src");
- gst_element_add_pad (GST_ELEMENT (fakesrc), pad);
-
fakesrc->output = FAKESRC_FIRST_LAST_LOOP;
fakesrc->segment_start = -1;
fakesrc->segment_end = -1;
fakesrc->pad_mode = GST_ACTIVATE_NONE;
}
-static void
-gst_fakesrc_set_clock (GstElement * element, GstClock * clock)
-{
- GstFakeSrc *src;
-
- src = GST_FAKESRC (element);
-
- src->clock = clock;
-}
-
-static const GstFormat *
-gst_fakesrc_get_formats (GstPad * pad)
-{
- static const GstFormat formats[] = {
- GST_FORMAT_DEFAULT,
- 0,
- };
-
- return formats;
-}
-
-static const GstQueryType *
-gst_fakesrc_get_query_types (GstPad * pad)
-{
- static const GstQueryType types[] = {
- GST_QUERY_TOTAL,
- GST_QUERY_POSITION,
- GST_QUERY_START,
- GST_QUERY_SEGMENT_END,
- 0,
- };
-
- return types;
-}
-
-static gboolean
-gst_fakesrc_query (GstPad * pad, GstQueryType type,
- GstFormat * format, gint64 * value)
-{
- GstFakeSrc *src = GST_FAKESRC (GST_PAD_PARENT (pad));
-
- switch (type) {
- case GST_QUERY_TOTAL:
- *value = src->num_buffers;
- break;
- case GST_QUERY_POSITION:
- *value = src->buffer_count;
- break;
- case GST_QUERY_START:
- *value = src->segment_start;
- break;
- case GST_QUERY_SEGMENT_END:
- *value = src->segment_end;
- break;
- default:
- return FALSE;
- }
- return TRUE;
-}
-
-static const GstEventMask *
-gst_fakesrc_get_event_mask (GstPad * pad)
-{
- static const GstEventMask masks[] = {
- {GST_EVENT_SEEK, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SEGMENT_LOOP},
- {GST_EVENT_FLUSH, 0},
- {0, 0},
- };
-
- return masks;
-}
-
static gboolean
-gst_fakesrc_event_handler (GstPad * pad, GstEvent * event)
+gst_fakesrc_event_handler (GstBaseSrc * basesrc, GstEvent * event)
{
GstFakeSrc *src;
- src = GST_FAKESRC (GST_PAD_PARENT (pad));
+ src = GST_FAKESRC (basesrc);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
return TRUE;
}
-static void
-gst_fakesrc_set_pad_functions (GstFakeSrc * src, GstPad * pad)
-{
- gst_pad_set_activate_function (pad, gst_fakesrc_activate);
- gst_pad_set_event_function (pad, gst_fakesrc_event_handler);
- gst_pad_set_event_mask_function (pad, gst_fakesrc_get_event_mask);
- gst_pad_set_query_function (pad, gst_fakesrc_query);
- gst_pad_set_query_type_function (pad, gst_fakesrc_get_query_types);
- gst_pad_set_formats_function (pad, gst_fakesrc_get_formats);
-
- if (src->has_loop)
- gst_pad_set_loop_function (pad, gst_fakesrc_loop);
- else
- gst_pad_set_loop_function (pad, NULL);
-
- if (src->has_getrange)
- gst_pad_set_getrange_function (pad, gst_fakesrc_get_range);
- else
- gst_pad_set_getrange_function (pad, NULL);
-}
-
-static void
-gst_fakesrc_set_all_pad_functions (GstFakeSrc * src)
-{
- GList *l;
-
- for (l = GST_ELEMENT_PADS (src); l; l = l->next)
- gst_fakesrc_set_pad_functions (src, (GstPad *) l->data);
-}
-
-static GstPad *
-gst_fakesrc_request_new_pad (GstElement * element, GstPadTemplate * templ,
- const gchar * unused)
-{
- gchar *name;
- GstPad *srcpad;
- GstFakeSrc *fakesrc;
-
- g_return_val_if_fail (GST_IS_FAKESRC (element), NULL);
-
- if (templ->direction != GST_PAD_SRC) {
- g_warning ("gstfakesrc: request new pad that is not a SRC pad\n");
- return NULL;
- }
-
- fakesrc = GST_FAKESRC (element);
-
- name = g_strdup_printf ("src%d", GST_ELEMENT (fakesrc)->numsrcpads);
-
- srcpad = gst_pad_new_from_template (templ, name);
- gst_element_add_pad (GST_ELEMENT (fakesrc), srcpad);
- gst_fakesrc_set_pad_functions (fakesrc, srcpad);
-
- g_free (name);
-
- return srcpad;
-}
-
static void
gst_fakesrc_alloc_parent (GstFakeSrc * src)
{
src = GST_FAKESRC (object);
switch (prop_id) {
- case ARG_HAS_LOOP:
- src->has_loop = g_value_get_boolean (value);
- gst_fakesrc_set_all_pad_functions (src);
- break;
- case ARG_HAS_GETRANGE:
- src->has_getrange = g_value_get_boolean (value);
- gst_fakesrc_set_all_pad_functions (src);
- break;
case ARG_OUTPUT:
g_warning ("not yet implemented");
break;
case ARG_NUM_SOURCES:
g_value_set_int (value, GST_ELEMENT (src)->numsrcpads);
break;
- case ARG_HAS_LOOP:
- g_value_set_boolean (value, src->has_loop);
- break;
- case ARG_HAS_GETRANGE:
- g_value_set_boolean (value, src->has_getrange);
- break;
case ARG_OUTPUT:
g_value_set_enum (value, src->output);
break;
}
static GstFlowReturn
-gst_fakesrc_get_range_unlocked (GstPad * pad, guint64 offset, guint length,
+gst_fakesrc_create (GstBaseSrc * basesrc, guint64 offset, guint length,
GstBuffer ** ret)
{
GstFakeSrc *src;
GstBuffer *buf;
GstClockTime time;
- src = GST_FAKESRC (GST_OBJECT_PARENT (pad));
+ src = GST_FAKESRC (basesrc);
if (src->buffer_count == src->segment_end) {
- if (src->segment_loop) {
- //gst_pad_push_event (pad, gst_event_new (GST_EVENT_SEGMENT_DONE));
- } else {
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
- return GST_FLOW_UNEXPECTED;
- }
+ return GST_FLOW_UNEXPECTED;
}
if (src->rt_num_buffers == 0) {
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
return GST_FLOW_UNEXPECTED;
} else {
if (src->rt_num_buffers > 0)
if (src->eos) {
GST_INFO ("fakesrc is setting eos on pad");
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_EOS));
return GST_FLOW_UNEXPECTED;
}
g_free (src->last_message);
src->last_message =
- g_strdup_printf ("get ******* (%s:%s)> (%d bytes, %"
- G_GUINT64_FORMAT " ) %p", GST_DEBUG_PAD_NAME (pad),
+ g_strdup_printf ("get ******* > (%d bytes, %"
+ G_GUINT64_FORMAT " ) %p",
GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
g_object_notify (G_OBJECT (src), "last_message");
if (src->signal_handoffs) {
GST_LOG_OBJECT (src, "pre handoff emit");
- g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0,
- buf, pad);
+ g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0, buf);
GST_LOG_OBJECT (src, "post handoff emit");
}
return GST_FLOW_OK;
}
-static GstFlowReturn
-gst_fakesrc_get_range (GstPad * pad, guint64 offset, guint length,
- GstBuffer ** ret)
-{
- GstFlowReturn fret;
-
- g_assert (GST_FAKESRC (GST_OBJECT_PARENT (pad))->pad_mode ==
- GST_ACTIVATE_PULL);
-
- GST_STREAM_LOCK (pad);
-
- fret = gst_fakesrc_get_range_unlocked (pad, offset, length, ret);
-
- GST_STREAM_UNLOCK (pad);
-
- return fret;
-}
-
-static void
-gst_fakesrc_loop (GstPad * pad)
-{
- GstFakeSrc *src;
- GstBuffer *buf = NULL;
- GstFlowReturn ret;
-
- src = GST_FAKESRC (GST_OBJECT_PARENT (pad));
-
- g_assert (src->pad_mode == GST_ACTIVATE_PUSH);
-
- GST_STREAM_LOCK (pad);
- if (src->need_flush) {
- src->need_flush = FALSE;
- gst_pad_push_event (pad, gst_event_new (GST_EVENT_FLUSH));
- }
-
- ret = gst_fakesrc_get_range_unlocked (pad, src->buffer_count,
- DEFAULT_SIZEMAX, &buf);
- if (ret != GST_FLOW_OK) {
- goto pause;
- }
-
- ret = gst_pad_push (pad, buf);
- if (ret != GST_FLOW_OK) {
- goto pause;
- }
-
- GST_STREAM_UNLOCK (pad);
- return;
-
-pause:
- gst_task_pause (GST_RPAD_TASK (pad));
- GST_STREAM_UNLOCK (pad);
- return;
-}
-
-static gboolean
-gst_fakesrc_activate (GstPad * pad, GstActivateMode mode)
-{
- gboolean result = FALSE;
- GstFakeSrc *fakesrc;
-
- fakesrc = GST_FAKESRC (GST_OBJECT_PARENT (pad));
-
- switch (mode) {
- case GST_ACTIVATE_PUSH:
- /* if we have a scheduler we can start the task */
- g_return_val_if_fail (fakesrc->has_loop, FALSE);
- if (GST_ELEMENT_SCHEDULER (fakesrc)) {
- GST_STREAM_LOCK (pad);
- GST_RPAD_TASK (pad) =
- gst_scheduler_create_task (GST_ELEMENT_SCHEDULER (fakesrc),
- (GstTaskFunction) gst_fakesrc_loop, pad);
-
- gst_task_start (GST_RPAD_TASK (pad));
- GST_STREAM_UNLOCK (pad);
- result = TRUE;
- }
- break;
- case GST_ACTIVATE_PULL:
- g_return_val_if_fail (fakesrc->has_getrange, FALSE);
- result = TRUE;
- break;
- case GST_ACTIVATE_NONE:
- /* step 1, unblock clock sync (if any) */
-
- /* step 2, make sure streaming finishes */
- GST_STREAM_LOCK (pad);
- /* step 3, stop the task */
- if (GST_RPAD_TASK (pad)) {
- gst_task_stop (GST_RPAD_TASK (pad));
- gst_object_unref (GST_OBJECT (GST_RPAD_TASK (pad)));
- GST_RPAD_TASK (pad) = NULL;
- }
- GST_STREAM_UNLOCK (pad);
-
- result = TRUE;
- break;
- }
-
- fakesrc->pad_mode = mode;
-
- return result;
-}
-
static GstElementStateReturn
gst_fakesrc_change_state (GstElement * element)
{
#define __GST_FAKESRC_H__
#include <gst/gst.h>
+#include <gst/base/gstbasesrc.h>
G_BEGIN_DECLS
-
typedef enum {
FAKESRC_FIRST_LAST_LOOP = 1,
FAKESRC_LAST_FIRST_LOOP,
typedef struct _GstFakeSrcClass GstFakeSrcClass;
struct _GstFakeSrc {
- GstElement element;
+ GstBaseSrc element;
gboolean has_loop;
gboolean has_getrange;
};
struct _GstFakeSrcClass {
- GstElementClass parent_class;
+ GstBaseSrcClass parent_class;
/* signals */
void (*handoff) (GstElement *element, GstBuffer *buf, GstPad *pad);
GST_STREAM_LOCK (pad);
result = gst_filesrc_get (pad, &buffer);
- if (result != GST_FLOW_OK) {
- gst_task_pause (GST_RPAD_TASK (pad));
- goto done;
- }
+ if (result != GST_FLOW_OK)
+ goto need_pause;
+
result = gst_pad_push (pad, buffer);
- if (result != GST_FLOW_OK) {
+ if (result != GST_FLOW_OK)
+ goto need_pause;
+
+ GST_STREAM_UNLOCK (pad);
+ return;
+
+need_pause:
+ {
gst_task_pause (GST_RPAD_TASK (pad));
+ GST_STREAM_UNLOCK (pad);
+ return;
}
-done:
- GST_STREAM_UNLOCK (pad);
}
projects / platform / upstream / gstreamer.git / commitdiff