3 * Copyright (C) 2015 Centricular Ltd
4 * @author: Edward Hervey <edward@centricular.com>
5 * @author: Jan Schmidt <jan@centricular.com>
7 * gststreams.c: GstStreamCollection object and methods
9 * This library is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU Library General Public
11 * License as published by the Free Software Foundation; either
12 * version 2 of the License, or (at your option) any later version.
14 * This library is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * Library General Public License for more details.
19 * You should have received a copy of the GNU Library General Public
20 * License along with this library; if not, write to the
21 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
22 * Boston, MA 02110-1301, USA.
28 * SECTION:gststreamcollection
29 * @title: GstStreamCollection
30 * @short_description: Base class for collection of streams
35 #include "gst_private.h"
37 #include "gstenumtypes.h"
39 #include "gststreamcollection.h"
41 GST_DEBUG_CATEGORY_STATIC (stream_collection_debug);
42 #define GST_CAT_DEFAULT stream_collection_debug
44 #define GST_STREAM_COLLECTION_GET_PRIVATE(obj) \
45 (G_TYPE_INSTANCE_GET_PRIVATE ((obj), GST_TYPE_STREAM_COLLECTION, GstStreamCollectionPrivate))
47 struct _GstStreamCollectionPrivate
49 /* Maybe switch this to a GArray if performance is
54 /* stream signals and properties */
68 static guint gst_stream_collection_signals[LAST_SIGNAL] = { 0 };
70 static void gst_stream_collection_dispose (GObject * object);
71 static void gst_stream_collection_finalize (GObject * object);
73 static void gst_stream_collection_set_property (GObject * object, guint prop_id,
74 const GValue * value, GParamSpec * pspec);
75 static void gst_stream_collection_get_property (GObject * object, guint prop_id,
76 GValue * value, GParamSpec * pspec);
79 proxy_stream_notify_cb (GstStream * stream, GParamSpec * pspec,
80 GstStreamCollection * collection);
84 GST_DEBUG_CATEGORY_INIT (stream_collection_debug, "streamcollection", GST_DEBUG_BOLD, \
85 "debugging info for the stream collection objects"); \
89 #define gst_stream_collection_parent_class parent_class
90 G_DEFINE_TYPE_WITH_CODE (GstStreamCollection, gst_stream_collection,
91 GST_TYPE_OBJECT, _do_init);
94 gst_stream_collection_class_init (GstStreamCollectionClass * klass)
96 GObjectClass *gobject_class;
98 gobject_class = (GObjectClass *) klass;
100 g_type_class_add_private (klass, sizeof (GstStreamCollectionPrivate));
102 gobject_class->set_property = gst_stream_collection_set_property;
103 gobject_class->get_property = gst_stream_collection_get_property;
106 * GstStream:upstream-id:
110 g_object_class_install_property (gobject_class, PROP_UPSTREAM_ID,
111 g_param_spec_string ("upstream-id", "Upstream ID",
112 "The stream ID of the parent stream",
114 G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
117 * GstStream::stream-notify:
118 * @collection: a #GstStreamCollection
119 * @prop_stream: the #GstStream that originated the signal
120 * @prop: the property that changed
122 * The stream notify signal is used to be notified of property changes to
123 * streams within the collection.
125 gst_stream_collection_signals[SIG_STREAM_NOTIFY] =
126 g_signal_new ("stream-notify", G_TYPE_FROM_CLASS (klass),
127 G_SIGNAL_RUN_FIRST | G_SIGNAL_NO_RECURSE | G_SIGNAL_DETAILED |
128 G_SIGNAL_NO_HOOKS, G_STRUCT_OFFSET (GstStreamCollectionClass,
129 stream_notify), NULL, NULL, g_cclosure_marshal_generic, G_TYPE_NONE,
130 2, GST_TYPE_STREAM, G_TYPE_PARAM);
132 gobject_class->dispose = gst_stream_collection_dispose;
133 gobject_class->finalize = gst_stream_collection_finalize;
137 gst_stream_collection_init (GstStreamCollection * collection)
139 collection->priv = GST_STREAM_COLLECTION_GET_PRIVATE (collection);
140 collection->priv->streams = g_queue_new ();
144 release_gst_stream (GstStream * stream, GstStreamCollection * collection)
146 g_signal_handlers_disconnect_by_func (stream,
147 proxy_stream_notify_cb, collection);
148 gst_object_unref (stream);
152 gst_stream_collection_dispose (GObject * object)
154 GstStreamCollection *collection = GST_STREAM_COLLECTION_CAST (object);
156 if (collection->upstream_id) {
157 g_free (collection->upstream_id);
158 collection->upstream_id = NULL;
161 if (collection->priv->streams) {
162 g_queue_foreach (collection->priv->streams,
163 (GFunc) release_gst_stream, collection);
164 g_queue_clear (collection->priv->streams);
167 G_OBJECT_CLASS (parent_class)->dispose (object);
171 gst_stream_collection_finalize (GObject * object)
173 GstStreamCollection *collection = GST_STREAM_COLLECTION_CAST (object);
175 if (collection->priv->streams)
176 g_queue_free (collection->priv->streams);
178 G_OBJECT_CLASS (parent_class)->finalize (object);
182 * gst_stream_collection_new:
183 * @upstream_id: (allow-none): The stream id of the parent stream
185 * Create a new #GstStreamCollection.
187 * Returns: (transfer floating): The new #GstStreamCollection.
191 GstStreamCollection *
192 gst_stream_collection_new (const gchar * upstream_id)
194 return g_object_new (GST_TYPE_STREAM_COLLECTION, "upstream-id", upstream_id,
199 gst_stream_collection_set_upstream_id (GstStreamCollection * collection,
200 const gchar * upstream_id)
202 g_return_if_fail (collection->upstream_id == NULL);
204 /* Upstream ID should only be set once on construction, but let's
205 * not leak in case someone does something silly */
206 if (collection->upstream_id)
207 g_free (collection->upstream_id);
210 collection->upstream_id = g_strdup (upstream_id);
214 * gst_stream_collection_get_upstream_id:
215 * @collection: a #GstStreamCollection
217 * Returns the upstream id of the @collection.
219 * Returns: (transfer none): The upstream id
224 gst_stream_collection_get_upstream_id (GstStreamCollection * collection)
228 res = collection->upstream_id;
234 gst_stream_collection_set_property (GObject * object, guint prop_id,
235 const GValue * value, GParamSpec * pspec)
237 GstStreamCollection *collection;
239 collection = GST_STREAM_COLLECTION_CAST (object);
242 case PROP_UPSTREAM_ID:
243 gst_stream_collection_set_upstream_id (collection,
244 g_value_get_string (value));
247 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
253 gst_stream_collection_get_property (GObject * object, guint prop_id,
254 GValue * value, GParamSpec * pspec)
256 GstStreamCollection *collection;
258 collection = GST_STREAM_COLLECTION_CAST (object);
261 case PROP_UPSTREAM_ID:
262 g_value_set_string (value,
263 gst_stream_collection_get_upstream_id (collection));
266 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
272 proxy_stream_notify_cb (GstStream * stream, GParamSpec * pspec,
273 GstStreamCollection * collection)
275 GST_DEBUG_OBJECT (collection, "Stream %" GST_PTR_FORMAT " updated %s",
276 stream, pspec->name);
277 g_signal_emit (collection, gst_stream_collection_signals[SIG_STREAM_NOTIFY],
278 g_quark_from_string (pspec->name), stream, pspec);
282 * gst_stream_collection_add_stream:
283 * @collection: a #GstStreamCollection
284 * @stream: (transfer full): the #GstStream to add
286 * Add the given @stream to the @collection.
288 * Returns: %TRUE if the @stream was properly added, else %FALSE
293 gst_stream_collection_add_stream (GstStreamCollection * collection,
296 g_return_val_if_fail (GST_IS_STREAM_COLLECTION (collection), FALSE);
297 g_return_val_if_fail (GST_IS_STREAM (stream), FALSE);
298 g_return_val_if_fail (collection->priv->streams, FALSE);
300 GST_DEBUG_OBJECT (collection, "Adding stream %" GST_PTR_FORMAT, stream);
302 g_queue_push_tail (collection->priv->streams, stream);
303 g_signal_connect (stream, "notify", (GCallback) proxy_stream_notify_cb,
310 * gst_stream_collection_get_size:
311 * @collection: a #GstStreamCollection
313 * Get the number of streams this collection contains
315 * Returns: The number of streams that @collection contains
320 gst_stream_collection_get_size (GstStreamCollection * collection)
322 g_return_val_if_fail (GST_IS_STREAM_COLLECTION (collection), 0);
323 g_return_val_if_fail (collection->priv->streams, 0);
325 return g_queue_get_length (collection->priv->streams);
329 * gst_stream_collection_get_stream:
330 * @collection: a #GstStreamCollection
331 * @index: Index of the stream to retrieve
333 * Retrieve the #GstStream with index @index from the collection.
335 * The caller should not modify the returned #GstStream
337 * Returns: (transfer none): A #GstStream
342 gst_stream_collection_get_stream (GstStreamCollection * collection, guint index)
344 g_return_val_if_fail (GST_IS_STREAM_COLLECTION (collection), NULL);
345 g_return_val_if_fail (collection->priv->streams, NULL);
347 return g_queue_peek_nth (collection->priv->streams, index);