2000-12-29 05:38:06 +00:00
|
|
|
/* GStreamer
|
|
|
|
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
|
|
|
|
* 2000 Wim Taymans <wtay@chello.be>
|
|
|
|
*
|
|
|
|
* gstfakesrc.c:
|
2000-01-30 09:03:00 +00:00
|
|
|
*
|
|
|
|
* 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 <gstfakesrc.h>
|
|
|
|
|
|
|
|
|
|
|
|
GstElementDetails gst_fakesrc_details = {
|
|
|
|
"Fake Source",
|
|
|
|
"Source",
|
|
|
|
"Push empty (no data) buffers around",
|
|
|
|
VERSION,
|
2001-01-14 14:43:57 +00:00
|
|
|
"Erik Walthinsen <omega@cse.ogi.edu>\n"
|
2001-07-11 15:51:40 +00:00
|
|
|
"Wim Taymans <wim.taymans@chello.be>",
|
2000-01-30 09:03:00 +00:00
|
|
|
"(C) 1999",
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
/* FakeSrc signals and args */
|
|
|
|
enum {
|
|
|
|
/* FILL ME */
|
2000-12-22 23:23:10 +00:00
|
|
|
SIGNAL_HANDOFF,
|
2000-01-30 09:03:00 +00:00
|
|
|
LAST_SIGNAL
|
|
|
|
};
|
|
|
|
|
|
|
|
enum {
|
|
|
|
ARG_0,
|
2000-12-20 09:39:43 +00:00
|
|
|
ARG_NUM_SOURCES,
|
2000-12-27 04:16:01 +00:00
|
|
|
ARG_LOOP_BASED,
|
2000-12-28 00:18:26 +00:00
|
|
|
ARG_OUTPUT,
|
2001-01-14 14:43:57 +00:00
|
|
|
ARG_PATTERN,
|
2001-01-02 01:44:53 +00:00
|
|
|
ARG_NUM_BUFFERS,
|
2001-05-25 21:00:07 +00:00
|
|
|
ARG_EOS,
|
2001-05-09 04:12:09 +00:00
|
|
|
ARG_SILENT
|
2000-01-30 09:03:00 +00:00
|
|
|
};
|
|
|
|
|
2001-07-11 15:51:40 +00:00
|
|
|
GST_PADTEMPLATE_FACTORY (fakesrc_src_factory,
|
|
|
|
"src%d",
|
|
|
|
GST_PAD_SRC,
|
|
|
|
GST_PAD_REQUEST,
|
|
|
|
NULL /* no caps */
|
|
|
|
);
|
|
|
|
|
2000-12-28 00:18:26 +00:00
|
|
|
#define GST_TYPE_FAKESRC_OUTPUT (gst_fakesrc_output_get_type())
|
2001-06-25 01:20:11 +00:00
|
|
|
static GType
|
2001-07-11 15:51:40 +00:00
|
|
|
gst_fakesrc_output_get_type (void)
|
|
|
|
{
|
2001-06-25 01:20:11 +00:00
|
|
|
static GType fakesrc_output_type = 0;
|
|
|
|
static GEnumValue fakesrc_output[] = {
|
2000-12-28 00:18:26 +00:00
|
|
|
{ FAKESRC_FIRST_LAST_LOOP, "1", "First-Last loop"},
|
|
|
|
{ FAKESRC_LAST_FIRST_LOOP, "2", "Last-First loop"},
|
|
|
|
{ FAKESRC_PING_PONG, "3", "Ping-Pong"},
|
|
|
|
{ FAKESRC_ORDERED_RANDOM, "4", "Ordered Random"},
|
|
|
|
{ FAKESRC_RANDOM, "5", "Random"},
|
2001-01-14 14:43:57 +00:00
|
|
|
{ FAKESRC_PATTERN_LOOP, "6", "Patttern loop"},
|
|
|
|
{ FAKESRC_PING_PONG_PATTERN, "7", "Ping-Pong Pattern"},
|
2000-12-28 00:18:26 +00:00
|
|
|
{ FAKESRC_GET_ALWAYS_SUCEEDS, "8", "'_get' Always succeeds"},
|
|
|
|
{0, NULL, NULL},
|
|
|
|
};
|
|
|
|
if (!fakesrc_output_type) {
|
2001-07-11 15:51:40 +00:00
|
|
|
fakesrc_output_type = g_enum_register_static ("GstFakeSrcOutput", fakesrc_output);
|
2000-12-28 00:18:26 +00:00
|
|
|
}
|
|
|
|
return fakesrc_output_type;
|
|
|
|
}
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-07-11 14:56:16 +00:00
|
|
|
static void gst_fakesrc_class_init (GstFakeSrcClass *klass);
|
|
|
|
static void gst_fakesrc_init (GstFakeSrc *fakesrc);
|
2000-12-20 09:39:43 +00:00
|
|
|
|
2001-07-11 15:51:40 +00:00
|
|
|
static GstPad* gst_fakesrc_request_new_pad (GstElement *element, GstPadTemplate *templ);
|
2001-06-25 01:20:11 +00:00
|
|
|
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);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-07-11 14:56:16 +00:00
|
|
|
static GstBuffer* gst_fakesrc_get (GstPad *pad);
|
|
|
|
static void gst_fakesrc_loop (GstElement *element);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2000-12-29 02:28:04 +00:00
|
|
|
static GstElementClass *parent_class = NULL;
|
2000-12-22 23:23:10 +00:00
|
|
|
static guint gst_fakesrc_signals[LAST_SIGNAL] = { 0 };
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
GType
|
2000-11-25 14:18:47 +00:00
|
|
|
gst_fakesrc_get_type (void)
|
|
|
|
{
|
2001-06-25 01:20:11 +00:00
|
|
|
static GType fakesrc_type = 0;
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
if (!fakesrc_type) {
|
2001-06-25 01:20:11 +00:00
|
|
|
static const GTypeInfo fakesrc_info = {
|
2000-01-30 09:03:00 +00:00
|
|
|
sizeof(GstFakeSrcClass),
|
2001-06-25 01:20:11 +00:00
|
|
|
NULL,
|
|
|
|
NULL,
|
|
|
|
(GClassInitFunc)gst_fakesrc_class_init,
|
|
|
|
NULL,
|
|
|
|
NULL,
|
|
|
|
sizeof(GstFakeSrc),
|
|
|
|
0,
|
|
|
|
(GInstanceInitFunc)gst_fakesrc_init,
|
2000-01-30 09:03:00 +00:00
|
|
|
};
|
2001-06-25 01:20:11 +00:00
|
|
|
fakesrc_type = g_type_register_static (GST_TYPE_ELEMENT, "GstFakeSrc", &fakesrc_info, 0);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
return fakesrc_type;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2000-11-25 14:18:47 +00:00
|
|
|
gst_fakesrc_class_init (GstFakeSrcClass *klass)
|
|
|
|
{
|
2001-06-25 01:20:11 +00:00
|
|
|
GObjectClass *gobject_class;
|
2001-07-11 15:51:40 +00:00
|
|
|
GstElementClass *gstelement_class;
|
2001-06-25 01:20:11 +00:00
|
|
|
|
|
|
|
gobject_class = (GObjectClass*)klass;
|
2001-07-11 15:51:40 +00:00
|
|
|
gstelement_class = (GstElementClass*)klass;
|
2001-06-25 01:20:11 +00:00
|
|
|
|
|
|
|
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
|
|
|
|
|
2001-07-11 15:51:40 +00:00
|
|
|
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_SOURCES,
|
|
|
|
g_param_spec_int ("num_sources", "num_sources", "num_sources",
|
|
|
|
1, G_MAXINT, 1, G_PARAM_READABLE));
|
2001-06-25 01:20:11 +00:00
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_LOOP_BASED,
|
|
|
|
g_param_spec_boolean("loop_based","loop_based","loop_based",
|
2001-07-11 19:22:20 +00:00
|
|
|
FALSE, G_PARAM_READWRITE)); // CHECKME
|
2001-06-25 01:20:11 +00:00
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_OUTPUT,
|
|
|
|
g_param_spec_enum("output","output","output",
|
|
|
|
GST_TYPE_FAKESRC_OUTPUT,FAKESRC_FIRST_LAST_LOOP,G_PARAM_READWRITE)); // CHECKME!
|
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_PATTERN,
|
|
|
|
g_param_spec_string("pattern","pattern","pattern",
|
|
|
|
NULL, G_PARAM_READWRITE)); // CHECKME
|
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_NUM_BUFFERS,
|
|
|
|
g_param_spec_int("num_buffers","num_buffers","num_buffers",
|
|
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_EOS,
|
|
|
|
g_param_spec_boolean("eos","eos","eos",
|
|
|
|
TRUE,G_PARAM_READWRITE)); // CHECKME
|
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_SILENT,
|
|
|
|
g_param_spec_boolean("silent","silent","silent",
|
2001-07-11 14:56:16 +00:00
|
|
|
FALSE, G_PARAM_READWRITE)); // CHECKME
|
2000-12-22 23:23:10 +00:00
|
|
|
|
|
|
|
gst_fakesrc_signals[SIGNAL_HANDOFF] =
|
2001-06-25 01:20:11 +00:00
|
|
|
g_signal_newc ("handoff", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST,
|
|
|
|
G_STRUCT_OFFSET (GstFakeSrcClass, handoff), NULL, NULL,
|
|
|
|
g_cclosure_marshal_VOID__POINTER, G_TYPE_NONE, 1,
|
|
|
|
G_TYPE_POINTER);
|
2000-12-22 23:23:10 +00:00
|
|
|
|
2001-07-11 15:51:40 +00:00
|
|
|
gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_fakesrc_set_property);
|
|
|
|
gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_fakesrc_get_property);
|
|
|
|
|
|
|
|
gstelement_class->request_new_pad = GST_DEBUG_FUNCPTR (gst_fakesrc_request_new_pad);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2000-12-27 04:16:01 +00:00
|
|
|
static void
|
|
|
|
gst_fakesrc_init (GstFakeSrc *fakesrc)
|
|
|
|
{
|
2000-12-20 09:39:43 +00:00
|
|
|
GstPad *pad;
|
|
|
|
|
|
|
|
// set the default number of
|
|
|
|
fakesrc->numsrcpads = 1;
|
|
|
|
|
|
|
|
// create our first output pad
|
2001-07-11 14:56:16 +00:00
|
|
|
pad = gst_pad_new ("src", GST_PAD_SRC);
|
|
|
|
gst_element_add_pad (GST_ELEMENT (fakesrc), pad);
|
|
|
|
fakesrc->srcpads = g_slist_append (NULL, pad);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-07-11 19:22:20 +00:00
|
|
|
fakesrc->loop_based = FALSE;
|
2001-01-14 14:43:57 +00:00
|
|
|
|
|
|
|
if (fakesrc->loop_based)
|
2001-07-11 15:51:40 +00:00
|
|
|
gst_element_set_loop_function (GST_ELEMENT (fakesrc), GST_DEBUG_FUNCPTR (gst_fakesrc_loop));
|
2001-01-14 14:43:57 +00:00
|
|
|
else
|
2001-07-11 15:51:40 +00:00
|
|
|
gst_pad_set_get_function (pad, GST_DEBUG_FUNCPTR (gst_fakesrc_get));
|
2001-01-14 14:43:57 +00:00
|
|
|
|
2001-01-02 01:44:53 +00:00
|
|
|
fakesrc->num_buffers = -1;
|
2001-07-11 14:56:16 +00:00
|
|
|
fakesrc->buffer_count = 0;
|
2001-05-09 04:12:09 +00:00
|
|
|
fakesrc->silent = FALSE;
|
2000-07-17 17:14:15 +00:00
|
|
|
// we're ready right away, since we don't have any args...
|
|
|
|
// gst_element_set_state(GST_ELEMENT(fakesrc),GST_STATE_READY);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-07-11 15:51:40 +00:00
|
|
|
static GstPad*
|
|
|
|
gst_fakesrc_request_new_pad (GstElement *element, GstPadTemplate *templ)
|
|
|
|
{
|
|
|
|
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", fakesrc->numsrcpads);
|
|
|
|
|
|
|
|
srcpad = gst_pad_new_from_template (templ, name);
|
|
|
|
gst_element_add_pad (GST_ELEMENT (fakesrc), srcpad);
|
|
|
|
|
|
|
|
fakesrc->srcpads = g_slist_prepend (fakesrc->srcpads, srcpad);
|
|
|
|
fakesrc->numsrcpads++;
|
|
|
|
|
|
|
|
return srcpad;
|
|
|
|
}
|
|
|
|
|
2000-12-27 04:16:01 +00:00
|
|
|
static void
|
|
|
|
gst_fakesrc_update_functions (GstFakeSrc *src)
|
|
|
|
{
|
|
|
|
GSList *pads;
|
|
|
|
|
2001-07-11 22:52:48 +00:00
|
|
|
if (src->loop_based) {
|
|
|
|
gst_element_set_loop_function (GST_ELEMENT (src), GST_DEBUG_FUNCPTR (gst_fakesrc_loop));
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
gst_element_set_loop_function (GST_ELEMENT (src), NULL);
|
|
|
|
}
|
|
|
|
|
2000-12-27 04:16:01 +00:00
|
|
|
pads = src->srcpads;
|
|
|
|
while (pads) {
|
|
|
|
GstPad *pad = GST_PAD (pads->data);
|
|
|
|
|
|
|
|
if (src->loop_based) {
|
2000-12-28 00:18:26 +00:00
|
|
|
gst_pad_set_get_function (pad, NULL);
|
2000-12-27 04:16:01 +00:00
|
|
|
}
|
|
|
|
else {
|
2001-07-11 22:52:48 +00:00
|
|
|
gst_pad_set_get_function (pad, GST_DEBUG_FUNCPTR (gst_fakesrc_get));
|
2000-12-27 04:16:01 +00:00
|
|
|
}
|
|
|
|
pads = g_slist_next (pads);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2000-12-20 09:39:43 +00:00
|
|
|
static void
|
2001-06-25 01:20:11 +00:00
|
|
|
gst_fakesrc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
|
2000-12-20 09:39:43 +00:00
|
|
|
{
|
|
|
|
GstFakeSrc *src;
|
|
|
|
|
|
|
|
/* it's not null if we got it, but it might not be ours */
|
|
|
|
src = GST_FAKESRC (object);
|
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
switch (prop_id) {
|
2000-12-27 04:16:01 +00:00
|
|
|
case ARG_LOOP_BASED:
|
2001-06-25 01:20:11 +00:00
|
|
|
src->loop_based = g_value_get_boolean (value);
|
2000-12-27 04:16:01 +00:00
|
|
|
gst_fakesrc_update_functions (src);
|
|
|
|
break;
|
2000-12-28 00:18:26 +00:00
|
|
|
case ARG_OUTPUT:
|
|
|
|
break;
|
2001-01-14 14:43:57 +00:00
|
|
|
case ARG_PATTERN:
|
2000-12-28 00:18:26 +00:00
|
|
|
break;
|
2001-01-02 01:44:53 +00:00
|
|
|
case ARG_NUM_BUFFERS:
|
2001-06-25 01:20:11 +00:00
|
|
|
src->num_buffers = g_value_get_int (value);
|
2001-01-02 01:44:53 +00:00
|
|
|
break;
|
2001-05-25 21:00:07 +00:00
|
|
|
case ARG_EOS:
|
2001-06-25 01:20:11 +00:00
|
|
|
src->eos = g_value_get_boolean (value);
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_INFO (0, "will EOS on next buffer");
|
|
|
|
break;
|
2001-05-09 04:12:09 +00:00
|
|
|
case ARG_SILENT:
|
2001-06-25 01:20:11 +00:00
|
|
|
src->silent = g_value_get_boolean (value);
|
2001-05-09 04:12:09 +00:00
|
|
|
break;
|
2000-12-20 09:39:43 +00:00
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2001-06-25 01:20:11 +00:00
|
|
|
gst_fakesrc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
|
2000-12-20 09:39:43 +00:00
|
|
|
{
|
|
|
|
GstFakeSrc *src;
|
|
|
|
|
|
|
|
/* it's not null if we got it, but it might not be ours */
|
|
|
|
g_return_if_fail (GST_IS_FAKESRC (object));
|
|
|
|
|
|
|
|
src = GST_FAKESRC (object);
|
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
switch (prop_id) {
|
2000-12-20 09:39:43 +00:00
|
|
|
case ARG_NUM_SOURCES:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_int (value, src->numsrcpads);
|
2000-12-20 09:39:43 +00:00
|
|
|
break;
|
2000-12-27 04:16:01 +00:00
|
|
|
case ARG_LOOP_BASED:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_boolean (value, src->loop_based);
|
2000-12-27 04:16:01 +00:00
|
|
|
break;
|
2000-12-28 00:18:26 +00:00
|
|
|
case ARG_OUTPUT:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_int (value, src->output);
|
2000-12-28 00:18:26 +00:00
|
|
|
break;
|
2001-01-14 14:43:57 +00:00
|
|
|
case ARG_PATTERN:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_string (value, src->pattern);
|
2000-12-28 00:18:26 +00:00
|
|
|
break;
|
2001-01-02 01:44:53 +00:00
|
|
|
case ARG_NUM_BUFFERS:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_int (value, src->num_buffers);
|
2001-01-02 01:44:53 +00:00
|
|
|
break;
|
2001-05-25 21:00:07 +00:00
|
|
|
case ARG_EOS:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_boolean (value, src->eos);
|
|
|
|
break;
|
2001-05-09 04:12:09 +00:00
|
|
|
case ARG_SILENT:
|
2001-06-25 01:20:11 +00:00
|
|
|
g_value_set_boolean (value, src->silent);
|
2001-05-09 04:12:09 +00:00
|
|
|
break;
|
2000-12-20 09:39:43 +00:00
|
|
|
default:
|
2001-06-25 01:20:11 +00:00
|
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
2000-12-20 09:39:43 +00:00
|
|
|
break;
|
|
|
|
}
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
}
|
|
|
|
|
2000-12-20 09:39:43 +00:00
|
|
|
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
/**
|
WARNING: Don't grab this updated unless you're really, REALLY sure.
Original commit message from CVS:
WARNING: Don't grab this updated unless you're really, REALLY sure.
WARNING: Wait for the next one.
Whole lotta changes here, including a few random bits:
examples/*/Makefile: updated to use `libtool gcc`, not just `gcc`
gst/
gstbuffer.h: updated to new flag style
gst.c, gstdebug.h: added new debugging for function ptrs
gstpipeline.c: set type of parent_class to the class, not the object
gstthread.c: ditto
plugins/
cdparanoia/cdparanoia.c: added an argument type, updated some defaults
cobin/spindentity.c: updated to new do/while loopfunction style
mp3encode/lame/gstlame.c: argument types, whole lotta lame options
tests/: various changes
Now, for the big changes: Once again, the scheduling system has changed.
And once again, it broke a whole bunch of things. The gist of the change
is that there is now a function pointer for gst_pad_push and gst_pad_pull,
instead of a hard-wired function. Well, currently they are functions, but
that's for debugging purposes only, they just call the function pointer
after spewing lots of DEBUG().
This changed the GstPad structure a bit, and the GstPad API as well.
Where elements used to provide chain() and pull() functions, they provide
chain() and get() functions. gst_pad_set_pull[region]_function has been
changed to get_pad_set_get[region]_function. This means all the elements
out there that used to have pull functions need to be updated. The calls
to that function have been changed in the normal elements, but the names
of the functions passed is still _pull[region](), which is an aesthetic
issue more than anything.
As for what doesn't work yet, just about anything dealing with Connections
is hosed, meaning threaded stuff won't work. This will be fixed about 12
hours from now, after I've slept, etc. The simplefake.c test works in
both cothreaded and chained cases, but not much else will work due to the
Connection problem. Needless to say, don't grab this unless you *need*
these features *now*, else wait to update this stuff until tomorrow.
I'm going to sleep now.
2000-12-16 10:18:09 +00:00
|
|
|
* gst_fakesrc_get:
|
|
|
|
* @src: the faksesrc to get
|
2000-03-27 19:53:43 +00:00
|
|
|
*
|
2000-12-28 00:18:26 +00:00
|
|
|
* generate an empty buffer and return it
|
|
|
|
*
|
|
|
|
* Returns: a new empty buffer
|
2000-03-27 19:53:43 +00:00
|
|
|
*/
|
2000-12-20 09:39:43 +00:00
|
|
|
static GstBuffer *
|
|
|
|
gst_fakesrc_get(GstPad *pad)
|
|
|
|
{
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
GstFakeSrc *src;
|
2000-01-30 09:03:00 +00:00
|
|
|
GstBuffer *buf;
|
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
g_return_val_if_fail (pad != NULL, NULL);
|
|
|
|
|
|
|
|
src = GST_FAKESRC (gst_pad_get_parent (pad));
|
|
|
|
|
|
|
|
g_return_val_if_fail (GST_IS_FAKESRC (src), NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-02 01:44:53 +00:00
|
|
|
if (src->num_buffers == 0) {
|
|
|
|
gst_pad_set_eos (pad);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
if (src->num_buffers > 0)
|
|
|
|
src->num_buffers--;
|
|
|
|
}
|
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
if (src->eos) {
|
|
|
|
GST_INFO (0, "fakesrc is setting eos on pad");
|
|
|
|
gst_pad_set_eos (pad);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
buf = gst_buffer_new();
|
2001-07-11 14:56:16 +00:00
|
|
|
GST_BUFFER_TIMESTAMP (buf) = src->buffer_count++;
|
|
|
|
|
|
|
|
if (!src->silent)
|
2001-07-11 19:22:20 +00:00
|
|
|
g_print("fakesrc: get ******* (%s:%s)> (%d bytes, %llu) \n",
|
2001-07-11 14:56:16 +00:00
|
|
|
GST_DEBUG_PAD_NAME (pad), GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
|
2000-12-22 23:23:10 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0,
|
2001-05-10 20:28:51 +00:00
|
|
|
buf);
|
2000-12-22 23:23:10 +00:00
|
|
|
|
2000-12-20 09:39:43 +00:00
|
|
|
return buf;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
2000-12-27 04:16:01 +00:00
|
|
|
|
|
|
|
/**
|
2000-12-28 00:18:26 +00:00
|
|
|
* gst_fakesrc_loop:
|
|
|
|
* @element: the faksesrc to loop
|
2000-12-27 04:16:01 +00:00
|
|
|
*
|
|
|
|
* generate an empty buffer and push it to the next element.
|
|
|
|
*/
|
|
|
|
static void
|
|
|
|
gst_fakesrc_loop(GstElement *element)
|
|
|
|
{
|
|
|
|
GstFakeSrc *src;
|
|
|
|
|
|
|
|
g_return_if_fail(element != NULL);
|
|
|
|
g_return_if_fail(GST_IS_FAKESRC(element));
|
|
|
|
|
|
|
|
src = GST_FAKESRC (element);
|
|
|
|
|
|
|
|
do {
|
|
|
|
GSList *pads;
|
|
|
|
|
|
|
|
pads = src->srcpads;
|
|
|
|
|
|
|
|
while (pads) {
|
|
|
|
GstPad *pad = GST_PAD (pads->data);
|
|
|
|
GstBuffer *buf;
|
|
|
|
|
2001-01-14 14:43:57 +00:00
|
|
|
if (src->num_buffers == 0) {
|
|
|
|
gst_pad_set_eos (pad);
|
2001-01-20 03:28:37 +00:00
|
|
|
return;
|
2001-01-14 14:43:57 +00:00
|
|
|
}
|
|
|
|
else {
|
|
|
|
if (src->num_buffers > 0)
|
2001-05-25 21:00:07 +00:00
|
|
|
src->num_buffers--;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (src->eos) {
|
|
|
|
GST_INFO (0, "fakesrc is setting eos on pad");
|
|
|
|
gst_pad_set_eos (pad);
|
|
|
|
return;
|
2001-01-14 14:43:57 +00:00
|
|
|
}
|
|
|
|
|
2000-12-27 04:16:01 +00:00
|
|
|
buf = gst_buffer_new();
|
2001-07-11 14:56:16 +00:00
|
|
|
GST_BUFFER_TIMESTAMP (buf) = src->buffer_count++;
|
|
|
|
|
2001-05-09 04:12:09 +00:00
|
|
|
if (!src->silent)
|
2001-07-11 19:22:20 +00:00
|
|
|
g_print("fakesrc: loop ******* (%s:%s) > (%d bytes, %llu) \n",
|
2001-07-11 14:56:16 +00:00
|
|
|
GST_DEBUG_PAD_NAME (pad), GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
|
2000-12-27 04:16:01 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0,
|
2001-05-10 20:28:51 +00:00
|
|
|
buf);
|
2000-12-27 04:16:01 +00:00
|
|
|
gst_pad_push (pad, buf);
|
|
|
|
|
2001-01-14 14:43:57 +00:00
|
|
|
pads = g_slist_next (pads);
|
2000-12-27 04:16:01 +00:00
|
|
|
}
|
|
|
|
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING (element));
|
|
|
|
}
|
2001-07-11 15:51:40 +00:00
|
|
|
|
|
|
|
gboolean
|
|
|
|
gst_fakesrc_factory_init (GstElementFactory *factory)
|
|
|
|
{
|
|
|
|
gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (fakesrc_src_factory));
|
|
|
|
|
|
|
|
return TRUE;
|
|
|
|
}
|
|
|
|
|