From abe21912f59eb1bd87042d8174a2cb48aaa0916d Mon Sep 17 00:00:00 2001 From: Matthew Waters Date: Thu, 26 Feb 2015 18:26:36 +1100 Subject: [PATCH] gl: new glsrcbin element --- ext/gl/Makefile.am | 2 + ext/gl/gstglsrcbin.c | 273 +++++++++++++++++++++++++++++++++++++++++++ ext/gl/gstglsrcbin.h | 71 +++++++++++ ext/gl/gstopengl.c | 6 + 4 files changed, 352 insertions(+) create mode 100644 ext/gl/gstglsrcbin.c create mode 100644 ext/gl/gstglsrcbin.h diff --git a/ext/gl/Makefile.am b/ext/gl/Makefile.am index 9a704d184d..7dc1041921 100644 --- a/ext/gl/Makefile.am +++ b/ext/gl/Makefile.am @@ -9,6 +9,7 @@ libgstopengl_la_SOURCES = \ gstglfilterbin.c \ gstglmixerbin.c \ gstglsinkbin.c \ + gstglsrcbin.c \ gstglimagesink.c \ gstglfiltercube.c \ gstgleffects.c \ @@ -30,6 +31,7 @@ noinst_HEADERS = \ gstglfilterbin.h \ gstglmixerbin.h \ gstglsinkbin.h \ + gstglsrcbin.h \ gstglimagesink.h \ gstglfiltercube.h \ gstgleffects.h \ diff --git a/ext/gl/gstglsrcbin.c b/ext/gl/gstglsrcbin.c new file mode 100644 index 0000000000..58d34c6859 --- /dev/null +++ b/ext/gl/gstglsrcbin.c @@ -0,0 +1,273 @@ +/* + * GStreamer + * Copyright (C) 2015 Matthew Waters + * + * 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., 51 Franklin St, Fifth Floor, + * Boston, MA 02110-1301, USA. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include "gstglsrcbin.h" + +GST_DEBUG_CATEGORY (gst_debug_gl_src_bin); +#define GST_CAT_DEFAULT gst_debug_gl_src_bin + +static void gst_gl_src_bin_finalize (GObject * object); +static void gst_gl_src_bin_set_property (GObject * object, guint prop_id, + const GValue * value, GParamSpec * param_spec); +static void gst_gl_src_bin_get_property (GObject * object, guint prop_id, + GValue * value, GParamSpec * param_spec); + +static GstStateChangeReturn gst_gl_src_bin_change_state (GstElement * element, + GstStateChange transition); + +static GstStaticPadTemplate gst_gl_src_bin_template = +GST_STATIC_PAD_TEMPLATE ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("video/x-raw(ANY)")); + +enum +{ + PROP_0, + PROP_SRC, +}; + +enum +{ + SIGNAL_0, + SIGNAL_CREATE_ELEMENT, + SIGNAL_LAST, +}; + +static guint gst_gl_src_bin_signals[SIGNAL_LAST] = { 0, }; + +#define gst_gl_src_bin_parent_class parent_class +G_DEFINE_TYPE_WITH_CODE (GstGLSrcBin, gst_gl_src_bin, + GST_TYPE_BIN, + GST_DEBUG_CATEGORY_INIT (gst_debug_gl_src_bin, "glsrcbin", 0, + "OpenGL Video Src Bin")); + +static void +gst_gl_src_bin_class_init (GstGLSrcBinClass * klass) +{ + GObjectClass *gobject_class; + GstElementClass *element_class; + + gobject_class = (GObjectClass *) klass; + element_class = GST_ELEMENT_CLASS (klass); + + element_class->change_state = gst_gl_src_bin_change_state; + + gobject_class->set_property = gst_gl_src_bin_set_property; + gobject_class->get_property = gst_gl_src_bin_get_property; + gobject_class->finalize = gst_gl_src_bin_finalize; + + g_object_class_install_property (gobject_class, PROP_SRC, + g_param_spec_object ("src", + "GL src element", + "The GL src chain to use", + GST_TYPE_ELEMENT, + GST_PARAM_MUTABLE_READY | G_PARAM_READWRITE | + G_PARAM_STATIC_STRINGS)); + + /** + * GstGLSrcBin::create-element: + * @object: the #GstGLSrcBin + * + * Will be emitted when we need the processing element/s that this bin will use + * + * Returns: a new #GstElement + */ + gst_gl_src_bin_signals[SIGNAL_CREATE_ELEMENT] = + g_signal_new ("create-element", G_TYPE_FROM_CLASS (klass), + G_SIGNAL_RUN_LAST, 0, NULL, NULL, g_cclosure_marshal_generic, + GST_TYPE_ELEMENT, 0); + + gst_element_class_set_metadata (element_class, + "GL Src Bin", "Src/Video", + "Infrastructure to process GL textures", + "Matthew Waters "); + + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&gst_gl_src_bin_template)); +} + +static void +gst_gl_src_bin_finalize (GObject * object) +{ + G_OBJECT_CLASS (parent_class)->finalize (object); +} + +static void +gst_gl_src_bin_init (GstGLSrcBin * self) +{ + gboolean res = TRUE; + GstPad *pad; + + self->download = gst_element_factory_make ("gldownload", NULL); + self->convert = gst_element_factory_make ("glcolorconvert", NULL); + + res &= gst_bin_add (GST_BIN (self), self->download); + res &= gst_bin_add (GST_BIN (self), self->convert); + + res &= gst_element_link_pads (self->convert, "src", self->download, "sink"); + + pad = gst_element_get_static_pad (self->download, "src"); + if (!pad) { + res = FALSE; + } else { + GST_DEBUG_OBJECT (self, "setting target src pad %" GST_PTR_FORMAT, pad); + self->srcpad = gst_ghost_pad_new ("src", pad); + gst_element_add_pad (GST_ELEMENT_CAST (self), self->srcpad); + gst_object_unref (pad); + } + + if (!res) { + GST_WARNING_OBJECT (self, "Failed to add/connect the necessary machinery"); + } +} + +static gboolean +_connect_src_element (GstGLSrcBin * self) +{ + gboolean res = TRUE; + + gst_object_set_name (GST_OBJECT (self->src), "src"); + res &= gst_bin_add (GST_BIN (self), self->src); + + res &= gst_element_link_pads (self->src, "src", self->convert, "sink"); + + if (!res) + GST_ERROR_OBJECT (self, "Failed to link src element into the pipeline"); + + return res; +} + +void +gst_gl_src_bin_finish_init_with_element (GstGLSrcBin * self, + GstElement * element) +{ + g_return_if_fail (GST_IS_ELEMENT (element)); + + self->src = element; + + if (!_connect_src_element (self)) { + gst_object_unref (self->src); + self->src = NULL; + } +} + +void +gst_gl_src_bin_finish_init (GstGLSrcBin * self) +{ + GstGLSrcBinClass *klass = GST_GL_SRC_BIN_GET_CLASS (self); + GstElement *element = NULL; + + if (klass->create_element) + element = klass->create_element (); + + if (element) + gst_gl_src_bin_finish_init_with_element (self, element); +} + +static void +gst_gl_src_bin_set_property (GObject * object, guint prop_id, + const GValue * value, GParamSpec * pspec) +{ + GstGLSrcBin *self = GST_GL_SRC_BIN (object); + + switch (prop_id) { + case PROP_SRC: + { + GstElement *src = g_value_get_object (value); + if (self->src) + gst_bin_remove (GST_BIN (self), self->src); + self->src = src; + if (src) + _connect_src_element (self); + break; + } + default: + if (self->src) + g_object_set_property (G_OBJECT (self->src), pspec->name, value); + break; + } +} + +static void +gst_gl_src_bin_get_property (GObject * object, guint prop_id, + GValue * value, GParamSpec * pspec) +{ + GstGLSrcBin *self = GST_GL_SRC_BIN (object); + + switch (prop_id) { + case PROP_SRC: + g_value_set_object (value, self->src); + break; + default: + if (self->src) + g_object_get_property (G_OBJECT (self->src), pspec->name, value); + break; + } +} + +static GstStateChangeReturn +gst_gl_src_bin_change_state (GstElement * element, GstStateChange transition) +{ + GstGLSrcBin *self = GST_GL_SRC_BIN (element); + GstGLSrcBinClass *klass = GST_GL_SRC_BIN_GET_CLASS (self); + GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS; + + GST_DEBUG ("changing state: %s => %s", + gst_element_state_get_name (GST_STATE_TRANSITION_CURRENT (transition)), + gst_element_state_get_name (GST_STATE_TRANSITION_NEXT (transition))); + + switch (transition) { + case GST_STATE_CHANGE_NULL_TO_READY: + if (!self->src) { + if (klass->create_element) + self->src = klass->create_element (); + + if (!self->src) + g_signal_emit (element, + gst_gl_src_bin_signals[SIGNAL_CREATE_ELEMENT], 0, &self->src); + + if (!self->src) { + GST_ERROR_OBJECT (element, "Failed to retreive element"); + return GST_STATE_CHANGE_FAILURE; + } + if (!_connect_src_element (self)) + return GST_STATE_CHANGE_FAILURE; + } + break; + default: + break; + } + + ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition); + if (ret == GST_STATE_CHANGE_FAILURE) + return ret; + + switch (transition) { + default: + break; + } + + return ret; +} diff --git a/ext/gl/gstglsrcbin.h b/ext/gl/gstglsrcbin.h new file mode 100644 index 0000000000..42301688f3 --- /dev/null +++ b/ext/gl/gstglsrcbin.h @@ -0,0 +1,71 @@ +/* + * GStreamer + * Copyright (C) 2015 Matthew Waters + * + * 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., 51 Franklin St, Fifth Floor, + * Boston, MA 02110-1301, USA. + */ + +#ifndef _GST_GL_SRC_BIN_H_ +#define _GST_GL_SRC_BIN_H_ + +#include + +#include + +G_BEGIN_DECLS + +GType gst_gl_src_bin_get_type(void); +#define GST_TYPE_GL_SRC_BIN \ + (gst_gl_src_bin_get_type()) +#define GST_GL_SRC_BIN(obj) \ + (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_GL_SRC_BIN,GstGLSrcBin)) +#define GST_GL_SRC_BIN_CLASS(klass) \ + (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_GL_SRC_BIN,GstGLSrcBinClass)) +#define GST_IS_GL_SRC_BIN(obj) \ + (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_GL_SRC_BIN)) +#define GST_IS_GL_SRC_BIN_CLASS(klass) \ + (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_GL_SRC_BIN)) +#define GST_GL_SRC_BIN_GET_CLASS(obj) \ + (G_TYPE_INSTANCE_GET_CLASS((obj) ,GST_TYPE_GL_SRC_BIN,GstGLSrcBinClass)) + +typedef struct _GstGLSrcBin GstGLSrcBin; +typedef struct _GstGLSrcBinClass GstGLSrcBinClass; + +struct _GstGLSrcBin +{ + GstBin parent; + + GstPad *srcpad; + + GstElement *src; + GstElement *convert; + GstElement *download; +}; + +struct _GstGLSrcBinClass +{ + GstBinClass parent_class; + + GstElement * (*create_element) (void); +}; + +void gst_gl_src_bin_finish_init (GstGLSrcBin * self); +void gst_gl_src_bin_finish_init_with_element (GstGLSrcBin * self, + GstElement * element); + +G_END_DECLS + +#endif diff --git a/ext/gl/gstopengl.c b/ext/gl/gstopengl.c index 16dc1af5a2..3878607b39 100644 --- a/ext/gl/gstopengl.c +++ b/ext/gl/gstopengl.c @@ -49,6 +49,7 @@ #include "gstglcolorconvertelement.h" #include "gstglfilterbin.h" #include "gstglsinkbin.h" +#include "gstglsrcbin.h" #include "gstglmixerbin.h" #include "gstglfiltercube.h" @@ -143,6 +144,11 @@ plugin_init (GstPlugin * plugin) return FALSE; } + if (!gst_element_register (plugin, "glsrcbin", + GST_RANK_NONE, GST_TYPE_GL_SRC_BIN)) { + return FALSE; + } + if (!gst_element_register (plugin, "glmixerbin", GST_RANK_NONE, GST_TYPE_GL_MIXER_BIN)) { return FALSE;