1 /*
2 * GStreamer
3 * Copyright (C) 2015 Matthew Waters <matthew@centricular.com>
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Library General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
9 *
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Library General Public License for more details.
14 *
15 * You should have received a copy of the GNU Library General Public
16 * License along with this library; if not, write to the
17 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
18 * Boston, MA 02110-1301, USA.
19 */
20
21 #ifdef HAVE_CONFIG_H
22 #include "config.h"
23 #endif
24
25 #include "gstglsrcbin.h"
26
27 GST_DEBUG_CATEGORY (gst_debug_gl_src_bin);
28 #define GST_CAT_DEFAULT gst_debug_gl_src_bin
29
30 static void gst_gl_src_bin_finalize (GObject * object);
31 static void gst_gl_src_bin_set_property (GObject * object, guint prop_id,
32 const GValue * value, GParamSpec * param_spec);
33 static void gst_gl_src_bin_get_property (GObject * object, guint prop_id,
34 GValue * value, GParamSpec * param_spec);
35
36 static GstStateChangeReturn gst_gl_src_bin_change_state (GstElement * element,
37 GstStateChange transition);
38
39 static GstStaticPadTemplate gst_gl_src_bin_template =
40 GST_STATIC_PAD_TEMPLATE ("src",
41 GST_PAD_SRC,
42 GST_PAD_ALWAYS,
43 GST_STATIC_CAPS ("video/x-raw(ANY)"));
44
45 enum
46 {
47 PROP_0,
48 PROP_SRC,
49 };
50
51 enum
52 {
53 SIGNAL_0,
54 SIGNAL_CREATE_ELEMENT,
55 SIGNAL_LAST,
56 };
57
58 static guint gst_gl_src_bin_signals[SIGNAL_LAST] = { 0, };
59
60 #define gst_gl_src_bin_parent_class parent_class
61 G_DEFINE_TYPE_WITH_CODE (GstGLSrcBin, gst_gl_src_bin,
62 GST_TYPE_BIN,
63 GST_DEBUG_CATEGORY_INIT (gst_debug_gl_src_bin, "glsrcbin", 0,
64 "OpenGL Video Src Bin"));
65
66 static void
gst_gl_src_bin_class_init(GstGLSrcBinClass * klass)67 gst_gl_src_bin_class_init (GstGLSrcBinClass * klass)
68 {
69 GObjectClass *gobject_class;
70 GstElementClass *element_class;
71
72 gobject_class = (GObjectClass *) klass;
73 element_class = GST_ELEMENT_CLASS (klass);
74
75 element_class->change_state = gst_gl_src_bin_change_state;
76
77 gobject_class->set_property = gst_gl_src_bin_set_property;
78 gobject_class->get_property = gst_gl_src_bin_get_property;
79 gobject_class->finalize = gst_gl_src_bin_finalize;
80
81 g_object_class_install_property (gobject_class, PROP_SRC,
82 g_param_spec_object ("src",
83 "GL src element",
84 "The GL src chain to use",
85 GST_TYPE_ELEMENT,
86 GST_PARAM_MUTABLE_READY | G_PARAM_READWRITE |
87 G_PARAM_STATIC_STRINGS));
88
89 /**
90 * GstGLSrcBin::create-element:
91 * @object: the #GstGLSrcBin
92 *
93 * Will be emitted when we need the processing element/s that this bin will use
94 *
95 * Returns: a new #GstElement
96 */
97 gst_gl_src_bin_signals[SIGNAL_CREATE_ELEMENT] =
98 g_signal_new ("create-element", G_TYPE_FROM_CLASS (klass),
99 G_SIGNAL_RUN_LAST, 0, NULL, NULL, g_cclosure_marshal_generic,
100 GST_TYPE_ELEMENT, 0);
101
102 gst_element_class_set_metadata (element_class,
103 "GL Src Bin", "Src/Video",
104 "Infrastructure to process GL textures",
105 "Matthew Waters <matthew@centricular.com>");
106
107 gst_element_class_add_static_pad_template (element_class,
108 &gst_gl_src_bin_template);
109 }
110
111 static void
gst_gl_src_bin_init(GstGLSrcBin * self)112 gst_gl_src_bin_init (GstGLSrcBin * self)
113 {
114 gboolean res = TRUE;
115 GstPad *pad;
116
117 self->download = gst_element_factory_make ("gldownload", NULL);
118 self->convert = gst_element_factory_make ("glcolorconvert", NULL);
119
120 res &= gst_bin_add (GST_BIN (self), self->download);
121 res &= gst_bin_add (GST_BIN (self), self->convert);
122
123 res &= gst_element_link_pads (self->convert, "src", self->download, "sink");
124
125 pad = gst_element_get_static_pad (self->download, "src");
126 if (!pad) {
127 res = FALSE;
128 } else {
129 GST_DEBUG_OBJECT (self, "setting target src pad %" GST_PTR_FORMAT, pad);
130 self->srcpad = gst_ghost_pad_new ("src", pad);
131 gst_element_add_pad (GST_ELEMENT_CAST (self), self->srcpad);
132 gst_object_unref (pad);
133 }
134
135 if (!res) {
136 GST_WARNING_OBJECT (self, "Failed to add/connect the necessary machinery");
137 }
138 }
139
140 static void
gst_gl_src_bin_finalize(GObject * object)141 gst_gl_src_bin_finalize (GObject * object)
142 {
143 GstGLSrcBin *self = GST_GL_SRC_BIN (object);
144
145 if (self->src)
146 gst_object_unref (self->src);
147
148 G_OBJECT_CLASS (parent_class)->finalize (object);
149 }
150
151 static gboolean
_connect_src_element(GstGLSrcBin * self)152 _connect_src_element (GstGLSrcBin * self)
153 {
154 gboolean res = TRUE;
155
156 gst_object_set_name (GST_OBJECT (self->src), "src");
157 res &= gst_bin_add (GST_BIN (self), self->src);
158
159 res &= gst_element_link_pads (self->src, "src", self->convert, "sink");
160
161 if (!res)
162 GST_ERROR_OBJECT (self, "Failed to link src element into the pipeline");
163
164 return res;
165 }
166
167 /*
168 * @src: (transfer floating):
169 */
170 static gboolean
gst_gl_src_bin_set_src(GstGLSrcBin * self,GstElement * src)171 gst_gl_src_bin_set_src (GstGLSrcBin * self, GstElement * src)
172 {
173 g_return_val_if_fail (GST_IS_ELEMENT (src), FALSE);
174
175 if (self->src) {
176 gst_element_set_locked_state (self->src, TRUE);
177 gst_bin_remove (GST_BIN (self), self->src);
178 gst_element_set_state (self->src, GST_STATE_NULL);
179 gst_object_unref (self->src);
180 self->src = NULL;
181 }
182 self->src = src;
183
184 gst_object_ref_sink (src);
185
186 if (src && !_connect_src_element (self)) {
187 gst_object_unref (self->src);
188 self->src = NULL;
189 return FALSE;
190 }
191
192 return TRUE;
193 }
194
195 void
gst_gl_src_bin_finish_init_with_element(GstGLSrcBin * self,GstElement * element)196 gst_gl_src_bin_finish_init_with_element (GstGLSrcBin * self,
197 GstElement * element)
198 {
199 gst_gl_src_bin_set_src (self, element);
200 }
201
202 void
gst_gl_src_bin_finish_init(GstGLSrcBin * self)203 gst_gl_src_bin_finish_init (GstGLSrcBin * self)
204 {
205 GstGLSrcBinClass *klass = GST_GL_SRC_BIN_GET_CLASS (self);
206 GstElement *element = NULL;
207
208 if (klass->create_element)
209 element = klass->create_element ();
210
211 if (element)
212 gst_gl_src_bin_finish_init_with_element (self, element);
213 }
214
215 static void
gst_gl_src_bin_set_property(GObject * object,guint prop_id,const GValue * value,GParamSpec * pspec)216 gst_gl_src_bin_set_property (GObject * object, guint prop_id,
217 const GValue * value, GParamSpec * pspec)
218 {
219 GstGLSrcBin *self = GST_GL_SRC_BIN (object);
220
221 switch (prop_id) {
222 case PROP_SRC:
223 gst_gl_src_bin_set_src (self, g_value_get_object (value));
224 break;
225 default:
226 if (self->src)
227 g_object_set_property (G_OBJECT (self->src), pspec->name, value);
228 break;
229 }
230 }
231
232 static void
gst_gl_src_bin_get_property(GObject * object,guint prop_id,GValue * value,GParamSpec * pspec)233 gst_gl_src_bin_get_property (GObject * object, guint prop_id,
234 GValue * value, GParamSpec * pspec)
235 {
236 GstGLSrcBin *self = GST_GL_SRC_BIN (object);
237
238 switch (prop_id) {
239 case PROP_SRC:
240 g_value_set_object (value, self->src);
241 break;
242 default:
243 if (self->src)
244 g_object_get_property (G_OBJECT (self->src), pspec->name, value);
245 break;
246 }
247 }
248
249 static GstStateChangeReturn
gst_gl_src_bin_change_state(GstElement * element,GstStateChange transition)250 gst_gl_src_bin_change_state (GstElement * element, GstStateChange transition)
251 {
252 GstGLSrcBin *self = GST_GL_SRC_BIN (element);
253 GstGLSrcBinClass *klass = GST_GL_SRC_BIN_GET_CLASS (self);
254 GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
255
256 GST_DEBUG ("changing state: %s => %s",
257 gst_element_state_get_name (GST_STATE_TRANSITION_CURRENT (transition)),
258 gst_element_state_get_name (GST_STATE_TRANSITION_NEXT (transition)));
259
260 switch (transition) {
261 case GST_STATE_CHANGE_NULL_TO_READY:
262 if (!self->src) {
263 if (klass->create_element)
264 self->src = klass->create_element ();
265
266 if (!self->src) {
267 g_signal_emit (element,
268 gst_gl_src_bin_signals[SIGNAL_CREATE_ELEMENT], 0, &self->src);
269 if (self->src && g_object_is_floating (self->src))
270 gst_object_ref_sink (self->src);
271 }
272
273 if (!self->src) {
274 GST_ERROR_OBJECT (element, "Failed to retrieve element");
275 return GST_STATE_CHANGE_FAILURE;
276 }
277 if (!_connect_src_element (self))
278 return GST_STATE_CHANGE_FAILURE;
279 }
280 break;
281 default:
282 break;
283 }
284
285 ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
286 if (ret == GST_STATE_CHANGE_FAILURE)
287 return ret;
288
289 switch (transition) {
290 default:
291 break;
292 }
293
294 return ret;
295 }
296