|
Packit Service |
963350 |
/* GStreamer
|
|
Packit Service |
963350 |
* Copyright (C) 2004 Wim Taymans <wim@fluendo.com>
|
|
Packit Service |
963350 |
* Copyright (C) 2011 Sebastian Dröge <sebastian.droege@collabora.co.uk>
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* gstiterator.h: Base class for iterating datastructures.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This library is free software; you can redistribute it and/or
|
|
Packit Service |
963350 |
* modify it under the terms of the GNU Library General Public
|
|
Packit Service |
963350 |
* License as published by the Free Software Foundation; either
|
|
Packit Service |
963350 |
* version 2 of the License, or (at your option) any later version.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This library is distributed in the hope that it will be useful,
|
|
Packit Service |
963350 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit Service |
963350 |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit Service |
963350 |
* Library General Public License for more details.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* You should have received a copy of the GNU Library General Public
|
|
Packit Service |
963350 |
* License along with this library; if not, write to the
|
|
Packit Service |
963350 |
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
|
Packit Service |
963350 |
* Boston, MA 02110-1301, USA.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* SECTION:gstiterator
|
|
Packit Service |
963350 |
* @title: GstIterator
|
|
Packit Service |
963350 |
* @short_description: Object to retrieve multiple elements in a threadsafe
|
|
Packit Service |
963350 |
* way.
|
|
Packit Service |
963350 |
* @see_also: #GstElement, #GstBin
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* A GstIterator is used to retrieve multiple objects from another object in
|
|
Packit Service |
963350 |
* a threadsafe way.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Various GStreamer objects provide access to their internal structures using
|
|
Packit Service |
963350 |
* an iterator.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Note that if calling a GstIterator function results in your code receiving
|
|
Packit Service |
963350 |
* a refcounted object (with, say, g_value_get_object()), the refcount for that
|
|
Packit Service |
963350 |
* object will not be increased. Your code is responsible for taking a reference
|
|
Packit Service |
963350 |
* if it wants to continue using it later.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The basic use pattern of an iterator is as follows:
|
|
Packit Service |
963350 |
* |[
|
|
Packit Service |
963350 |
* GstIterator *it = _get_iterator(object);
|
|
Packit Service |
963350 |
* GValue item = G_VALUE_INIT;
|
|
Packit Service |
963350 |
* done = FALSE;
|
|
Packit Service |
963350 |
* while (!done) {
|
|
Packit Service |
963350 |
* switch (gst_iterator_next (it, &item)) {
|
|
Packit Service |
963350 |
* case GST_ITERATOR_OK:
|
|
Packit Service |
963350 |
* ...get/use/change item here...
|
|
Packit Service |
963350 |
* g_value_reset (&item);
|
|
Packit Service |
963350 |
* break;
|
|
Packit Service |
963350 |
* case GST_ITERATOR_RESYNC:
|
|
Packit Service |
963350 |
* ...rollback changes to items...
|
|
Packit Service |
963350 |
* gst_iterator_resync (it);
|
|
Packit Service |
963350 |
* break;
|
|
Packit Service |
963350 |
* case GST_ITERATOR_ERROR:
|
|
Packit Service |
963350 |
* ...wrong parameters were given...
|
|
Packit Service |
963350 |
* done = TRUE;
|
|
Packit Service |
963350 |
* break;
|
|
Packit Service |
963350 |
* case GST_ITERATOR_DONE:
|
|
Packit Service |
963350 |
* done = TRUE;
|
|
Packit Service |
963350 |
* break;
|
|
Packit Service |
963350 |
* }
|
|
Packit Service |
963350 |
* }
|
|
Packit Service |
963350 |
* g_value_unset (&item);
|
|
Packit Service |
963350 |
* gst_iterator_free (it);
|
|
Packit Service |
963350 |
* ]|
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
#include "gst_private.h"
|
|
Packit Service |
963350 |
#include <gst/gstiterator.h>
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_copy:
|
|
Packit Service |
963350 |
* @it: a #GstIterator
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Copy the iterator and its state.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: a new copy of @it.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIterator *
|
|
Packit Service |
963350 |
gst_iterator_copy (const GstIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIterator *copy;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
copy = g_slice_copy (it->size, it);
|
|
Packit Service |
963350 |
if (it->copy)
|
|
Packit Service |
963350 |
it->copy (it, copy);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return copy;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
G_DEFINE_BOXED_TYPE (GstIterator, gst_iterator,
|
|
Packit Service |
963350 |
(GBoxedCopyFunc) gst_iterator_copy, (GBoxedFreeFunc) gst_iterator_free);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_iterator_init (GstIterator * it,
|
|
Packit Service |
963350 |
guint size,
|
|
Packit Service |
963350 |
GType type,
|
|
Packit Service |
963350 |
GMutex * lock,
|
|
Packit Service |
963350 |
guint32 * master_cookie,
|
|
Packit Service |
963350 |
GstIteratorCopyFunction copy,
|
|
Packit Service |
963350 |
GstIteratorNextFunction next,
|
|
Packit Service |
963350 |
GstIteratorItemFunction item,
|
|
Packit Service |
963350 |
GstIteratorResyncFunction resync, GstIteratorFreeFunction free)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
it->size = size;
|
|
Packit Service |
963350 |
it->type = type;
|
|
Packit Service |
963350 |
it->lock = lock;
|
|
Packit Service |
963350 |
it->master_cookie = master_cookie;
|
|
Packit Service |
963350 |
it->cookie = *master_cookie;
|
|
Packit Service |
963350 |
it->copy = copy;
|
|
Packit Service |
963350 |
it->next = next;
|
|
Packit Service |
963350 |
it->item = item;
|
|
Packit Service |
963350 |
it->resync = resync;
|
|
Packit Service |
963350 |
it->free = free;
|
|
Packit Service |
963350 |
it->pushed = NULL;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_new: (skip)
|
|
Packit Service |
963350 |
* @size: the size of the iterator structure
|
|
Packit Service |
963350 |
* @type: #GType of children
|
|
Packit Service |
963350 |
* @lock: pointer to a #GMutex.
|
|
Packit Service |
963350 |
* @master_cookie: pointer to a guint32 that is changed when the items in the
|
|
Packit Service |
963350 |
* iterator changed.
|
|
Packit Service |
963350 |
* @copy: copy function
|
|
Packit Service |
963350 |
* @next: function to get next item
|
|
Packit Service |
963350 |
* @item: function to call on each item retrieved
|
|
Packit Service |
963350 |
* @resync: function to resync the iterator
|
|
Packit Service |
963350 |
* @free: function to free the iterator
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Create a new iterator. This function is mainly used for objects
|
|
Packit Service |
963350 |
* implementing the next/resync/free function to iterate a data structure.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* For each item retrieved, the @item function is called with the lock
|
|
Packit Service |
963350 |
* held. The @free function is called when the iterator is freed.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: the new #GstIterator.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIterator *
|
|
Packit Service |
963350 |
gst_iterator_new (guint size,
|
|
Packit Service |
963350 |
GType type,
|
|
Packit Service |
963350 |
GMutex * lock,
|
|
Packit Service |
963350 |
guint32 * master_cookie,
|
|
Packit Service |
963350 |
GstIteratorCopyFunction copy,
|
|
Packit Service |
963350 |
GstIteratorNextFunction next,
|
|
Packit Service |
963350 |
GstIteratorItemFunction item,
|
|
Packit Service |
963350 |
GstIteratorResyncFunction resync, GstIteratorFreeFunction free)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIterator *result;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_return_val_if_fail (size >= sizeof (GstIterator), NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (g_type_qname (type) != 0, NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (master_cookie != NULL, NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (next != NULL, NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (resync != NULL, NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (free != NULL, NULL);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result = g_slice_alloc0 (size);
|
|
Packit Service |
963350 |
gst_iterator_init (result, size, type, lock, master_cookie, copy, next, item,
|
|
Packit Service |
963350 |
resync, free);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return result;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/*
|
|
Packit Service |
963350 |
* list iterator
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
typedef struct _GstListIterator
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIterator iterator;
|
|
Packit Service |
963350 |
GObject *owner;
|
|
Packit Service |
963350 |
GList **orig;
|
|
Packit Service |
963350 |
GList *list; /* pointer in list */
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
void (*set_value) (GValue * value, gpointer item);
|
|
Packit Service |
963350 |
} GstListIterator;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_list_iterator_copy (const GstListIterator * it, GstListIterator * copy)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (copy->owner)
|
|
Packit Service |
963350 |
g_object_ref (copy->owner);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static GstIteratorResult
|
|
Packit Service |
963350 |
gst_list_iterator_next (GstListIterator * it, GValue * elem)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
gpointer data;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (it->list == NULL)
|
|
Packit Service |
963350 |
return GST_ITERATOR_DONE;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
data = it->list->data;
|
|
Packit Service |
963350 |
it->list = g_list_next (it->list);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
it->set_value (elem, data);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return GST_ITERATOR_OK;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_list_iterator_resync (GstListIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
it->list = *it->orig;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_list_iterator_free (GstListIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (it->owner)
|
|
Packit Service |
963350 |
g_object_unref (it->owner);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_new_list: (skip)
|
|
Packit Service |
963350 |
* @type: #GType of elements
|
|
Packit Service |
963350 |
* @lock: pointer to a #GMutex protecting the list.
|
|
Packit Service |
963350 |
* @master_cookie: pointer to a guint32 that is incremented when the list
|
|
Packit Service |
963350 |
* is changed.
|
|
Packit Service |
963350 |
* @list: pointer to the list
|
|
Packit Service |
963350 |
* @owner: object owning the list
|
|
Packit Service |
963350 |
* @item: function to call on each item retrieved
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Create a new iterator designed for iterating @list.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The list you iterate is usually part of a data structure @owner and is
|
|
Packit Service |
963350 |
* protected with @lock.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The iterator will use @lock to retrieve the next item of the list and it
|
|
Packit Service |
963350 |
* will then call the @item function before releasing @lock again.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* When a concurrent update to the list is performed, usually by @owner while
|
|
Packit Service |
963350 |
* holding @lock, @master_cookie will be updated. The iterator implementation
|
|
Packit Service |
963350 |
* will notice the update of the cookie and will return %GST_ITERATOR_RESYNC to
|
|
Packit Service |
963350 |
* the user of the iterator in the next call to gst_iterator_next().
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: the new #GstIterator for @list.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIterator *
|
|
Packit Service |
963350 |
gst_iterator_new_list (GType type,
|
|
Packit Service |
963350 |
GMutex * lock, guint32 * master_cookie, GList ** list, GObject * owner,
|
|
Packit Service |
963350 |
GstIteratorItemFunction item)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstListIterator *result;
|
|
Packit Service |
963350 |
gpointer set_value;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (g_type_is_a (type, G_TYPE_OBJECT)) {
|
|
Packit Service |
963350 |
set_value = g_value_set_object;
|
|
Packit Service |
963350 |
} else if (g_type_is_a (type, G_TYPE_BOXED)) {
|
|
Packit Service |
963350 |
set_value = g_value_set_boxed;
|
|
Packit Service |
963350 |
} else if (g_type_is_a (type, G_TYPE_POINTER)) {
|
|
Packit Service |
963350 |
set_value = g_value_set_pointer;
|
|
Packit Service |
963350 |
} else if (g_type_is_a (type, G_TYPE_STRING)) {
|
|
Packit Service |
963350 |
set_value = g_value_set_string;
|
|
Packit Service |
963350 |
} else {
|
|
Packit Service |
963350 |
g_critical ("List iterators can only be created for lists containing "
|
|
Packit Service |
963350 |
"instances of GObject, boxed types, pointer types and strings");
|
|
Packit Service |
963350 |
return NULL;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/* no need to lock, nothing can change here */
|
|
Packit Service |
963350 |
result = (GstListIterator *) gst_iterator_new (sizeof (GstListIterator),
|
|
Packit Service |
963350 |
type,
|
|
Packit Service |
963350 |
lock,
|
|
Packit Service |
963350 |
master_cookie,
|
|
Packit Service |
963350 |
(GstIteratorCopyFunction) gst_list_iterator_copy,
|
|
Packit Service |
963350 |
(GstIteratorNextFunction) gst_list_iterator_next,
|
|
Packit Service |
963350 |
(GstIteratorItemFunction) item,
|
|
Packit Service |
963350 |
(GstIteratorResyncFunction) gst_list_iterator_resync,
|
|
Packit Service |
963350 |
(GstIteratorFreeFunction) gst_list_iterator_free);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result->owner = owner ? g_object_ref (owner) : NULL;
|
|
Packit Service |
963350 |
result->orig = list;
|
|
Packit Service |
963350 |
result->list = *list;
|
|
Packit Service |
963350 |
result->set_value = set_value;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return GST_ITERATOR (result);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_iterator_pop (GstIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (it->pushed) {
|
|
Packit Service |
963350 |
gst_iterator_free (it->pushed);
|
|
Packit Service |
963350 |
it->pushed = NULL;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_next:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to iterate
|
|
Packit Service |
963350 |
* @elem: (out caller-allocates): pointer to hold next element
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Get the next item from the iterator in @elem.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Only when this function returns %GST_ITERATOR_OK, @elem will contain a valid
|
|
Packit Service |
963350 |
* value. @elem must have been initialized to the type of the iterator or
|
|
Packit Service |
963350 |
* initialized to zeroes with g_value_unset(). The caller is responsible for
|
|
Packit Service |
963350 |
* unsetting or resetting @elem with g_value_unset() or g_value_reset()
|
|
Packit Service |
963350 |
* after usage.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* When this function returns %GST_ITERATOR_DONE, no more elements can be
|
|
Packit Service |
963350 |
* retrieved from @it.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* A return value of %GST_ITERATOR_RESYNC indicates that the element list was
|
|
Packit Service |
963350 |
* concurrently updated. The user of @it should call gst_iterator_resync() to
|
|
Packit Service |
963350 |
* get the newly updated list.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* A return value of %GST_ITERATOR_ERROR indicates an unrecoverable fatal error.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: The result of the iteration. Unset @elem after usage.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIteratorResult
|
|
Packit Service |
963350 |
gst_iterator_next (GstIterator * it, GValue * elem)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIteratorResult result;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_return_val_if_fail (it != NULL, GST_ITERATOR_ERROR);
|
|
Packit Service |
963350 |
g_return_val_if_fail (elem != NULL, GST_ITERATOR_ERROR);
|
|
Packit Service |
963350 |
g_return_val_if_fail (G_VALUE_TYPE (elem) == G_TYPE_INVALID
|
|
Packit Service |
963350 |
|| G_VALUE_HOLDS (elem, it->type), GST_ITERATOR_ERROR);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (G_VALUE_TYPE (elem) == G_TYPE_INVALID)
|
|
Packit Service |
963350 |
g_value_init (elem, it->type);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
restart:
|
|
Packit Service |
963350 |
if (it->pushed) {
|
|
Packit Service |
963350 |
result = gst_iterator_next (it->pushed, elem);
|
|
Packit Service |
963350 |
if (result == GST_ITERATOR_DONE) {
|
|
Packit Service |
963350 |
/* we are done with this iterator, pop it and
|
|
Packit Service |
963350 |
* fallthrough iterating the main iterator again. */
|
|
Packit Service |
963350 |
gst_iterator_pop (it);
|
|
Packit Service |
963350 |
} else {
|
|
Packit Service |
963350 |
return result;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (G_LIKELY (it->lock))
|
|
Packit Service |
963350 |
g_mutex_lock (it->lock);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (G_UNLIKELY (*it->master_cookie != it->cookie)) {
|
|
Packit Service |
963350 |
result = GST_ITERATOR_RESYNC;
|
|
Packit Service |
963350 |
goto done;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result = it->next (it, elem);
|
|
Packit Service |
963350 |
if (result == GST_ITERATOR_OK && it->item) {
|
|
Packit Service |
963350 |
GstIteratorItem itemres;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
itemres = it->item (it, elem);
|
|
Packit Service |
963350 |
switch (itemres) {
|
|
Packit Service |
963350 |
case GST_ITERATOR_ITEM_SKIP:
|
|
Packit Service |
963350 |
if (G_LIKELY (it->lock))
|
|
Packit Service |
963350 |
g_mutex_unlock (it->lock);
|
|
Packit Service |
963350 |
g_value_reset (elem);
|
|
Packit Service |
963350 |
goto restart;
|
|
Packit Service |
963350 |
case GST_ITERATOR_ITEM_END:
|
|
Packit Service |
963350 |
result = GST_ITERATOR_DONE;
|
|
Packit Service |
963350 |
g_value_reset (elem);
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
case GST_ITERATOR_ITEM_PASS:
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
done:
|
|
Packit Service |
963350 |
if (G_LIKELY (it->lock))
|
|
Packit Service |
963350 |
g_mutex_unlock (it->lock);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return result;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_resync:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to resync
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Resync the iterator. this function is mostly called
|
|
Packit Service |
963350 |
* after gst_iterator_next() returned %GST_ITERATOR_RESYNC.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* When an iterator was pushed on @it, it will automatically be popped again
|
|
Packit Service |
963350 |
* with this function.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
void
|
|
Packit Service |
963350 |
gst_iterator_resync (GstIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
g_return_if_fail (it != NULL);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
gst_iterator_pop (it);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (G_LIKELY (it->lock))
|
|
Packit Service |
963350 |
g_mutex_lock (it->lock);
|
|
Packit Service |
963350 |
it->resync (it);
|
|
Packit Service |
963350 |
it->cookie = *it->master_cookie;
|
|
Packit Service |
963350 |
if (G_LIKELY (it->lock))
|
|
Packit Service |
963350 |
g_mutex_unlock (it->lock);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_free:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to free
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Free the iterator.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
void
|
|
Packit Service |
963350 |
gst_iterator_free (GstIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
g_return_if_fail (it != NULL);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
gst_iterator_pop (it);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
it->free (it);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_slice_free1 (it->size, it);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_push:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to use
|
|
Packit Service |
963350 |
* @other: The #GstIterator to push
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Pushes @other iterator onto @it. All calls performed on @it are
|
|
Packit Service |
963350 |
* forwarded to @other. If @other returns %GST_ITERATOR_DONE, it is
|
|
Packit Service |
963350 |
* popped again and calls are handled by @it again.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This function is mainly used by objects implementing the iterator
|
|
Packit Service |
963350 |
* next function to recurse into substructures.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* When gst_iterator_resync() is called on @it, @other will automatically be
|
|
Packit Service |
963350 |
* popped.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
void
|
|
Packit Service |
963350 |
gst_iterator_push (GstIterator * it, GstIterator * other)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
g_return_if_fail (it != NULL);
|
|
Packit Service |
963350 |
g_return_if_fail (other != NULL);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
it->pushed = other;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
typedef struct _GstIteratorFilter
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIterator iterator;
|
|
Packit Service |
963350 |
GstIterator *slave;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
GMutex *master_lock;
|
|
Packit Service |
963350 |
GCompareFunc func;
|
|
Packit Service |
963350 |
GValue user_data;
|
|
Packit Service |
963350 |
gboolean have_user_data;
|
|
Packit Service |
963350 |
} GstIteratorFilter;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static GstIteratorResult
|
|
Packit Service |
963350 |
filter_next (GstIteratorFilter * it, GValue * elem)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIteratorResult result = GST_ITERATOR_ERROR;
|
|
Packit Service |
963350 |
gboolean done = FALSE;
|
|
Packit Service |
963350 |
GValue item = { 0, };
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
while (G_LIKELY (!done)) {
|
|
Packit Service |
963350 |
result = gst_iterator_next (it->slave, &item);
|
|
Packit Service |
963350 |
switch (result) {
|
|
Packit Service |
963350 |
case GST_ITERATOR_OK:
|
|
Packit Service |
963350 |
if (G_LIKELY (it->master_lock))
|
|
Packit Service |
963350 |
g_mutex_unlock (it->master_lock);
|
|
Packit Service |
963350 |
if (it->func (&item, &it->user_data) == 0) {
|
|
Packit Service |
963350 |
g_value_copy (&item, elem);
|
|
Packit Service |
963350 |
done = TRUE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
g_value_reset (&item);
|
|
Packit Service |
963350 |
if (G_LIKELY (it->master_lock))
|
|
Packit Service |
963350 |
g_mutex_lock (it->master_lock);
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
case GST_ITERATOR_RESYNC:
|
|
Packit Service |
963350 |
case GST_ITERATOR_DONE:
|
|
Packit Service |
963350 |
done = TRUE;
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
default:
|
|
Packit Service |
963350 |
g_assert_not_reached ();
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
g_value_unset (&item);
|
|
Packit Service |
963350 |
return result;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
filter_copy (const GstIteratorFilter * it, GstIteratorFilter * copy)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
copy->slave = gst_iterator_copy (it->slave);
|
|
Packit Service |
963350 |
copy->master_lock = copy->slave->lock ? copy->slave->lock : it->master_lock;
|
|
Packit Service |
963350 |
copy->slave->lock = NULL;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (it->have_user_data) {
|
|
Packit Service |
963350 |
memset (©->user_data, 0, sizeof (copy->user_data));
|
|
Packit Service |
963350 |
g_value_init (©->user_data, G_VALUE_TYPE (&it->user_data));
|
|
Packit Service |
963350 |
g_value_copy (&it->user_data, ©->user_data);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
filter_resync (GstIteratorFilter * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
gst_iterator_resync (it->slave);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
filter_free (GstIteratorFilter * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (it->have_user_data)
|
|
Packit Service |
963350 |
g_value_unset (&it->user_data);
|
|
Packit Service |
963350 |
gst_iterator_free (it->slave);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_filter:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to filter
|
|
Packit Service |
963350 |
* @func: (scope call): the compare function to select elements
|
|
Packit Service |
963350 |
* @user_data: (closure): user data passed to the compare function
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Create a new iterator from an existing iterator. The new iterator
|
|
Packit Service |
963350 |
* will only return those elements that match the given compare function @func.
|
|
Packit Service |
963350 |
* The first parameter that is passed to @func is the #GValue of the current
|
|
Packit Service |
963350 |
* iterator element and the second parameter is @user_data. @func should
|
|
Packit Service |
963350 |
* return 0 for elements that should be included in the filtered iterator.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* When this iterator is freed, @it will also be freed.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: (transfer full): a new #GstIterator.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIterator *
|
|
Packit Service |
963350 |
gst_iterator_filter (GstIterator * it, GCompareFunc func,
|
|
Packit Service |
963350 |
const GValue * user_data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIteratorFilter *result;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_return_val_if_fail (it != NULL, NULL);
|
|
Packit Service |
963350 |
g_return_val_if_fail (func != NULL, NULL);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result = (GstIteratorFilter *) gst_iterator_new (sizeof (GstIteratorFilter),
|
|
Packit Service |
963350 |
it->type, it->lock, it->master_cookie,
|
|
Packit Service |
963350 |
(GstIteratorCopyFunction) filter_copy,
|
|
Packit Service |
963350 |
(GstIteratorNextFunction) filter_next,
|
|
Packit Service |
963350 |
(GstIteratorItemFunction) NULL,
|
|
Packit Service |
963350 |
(GstIteratorResyncFunction) filter_resync,
|
|
Packit Service |
963350 |
(GstIteratorFreeFunction) filter_free);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result->master_lock = it->lock;
|
|
Packit Service |
963350 |
it->lock = NULL;
|
|
Packit Service |
963350 |
result->func = func;
|
|
Packit Service |
963350 |
if (user_data) {
|
|
Packit Service |
963350 |
g_value_init (&result->user_data, G_VALUE_TYPE (user_data));
|
|
Packit Service |
963350 |
g_value_copy (user_data, &result->user_data);
|
|
Packit Service |
963350 |
result->have_user_data = TRUE;
|
|
Packit Service |
963350 |
} else {
|
|
Packit Service |
963350 |
result->have_user_data = FALSE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
result->slave = it;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return GST_ITERATOR (result);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_fold:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to fold over
|
|
Packit Service |
963350 |
* @func: (scope call): the fold function
|
|
Packit Service |
963350 |
* @ret: the seed value passed to the fold function
|
|
Packit Service |
963350 |
* @user_data: (closure): user data passed to the fold function
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Folds @func over the elements of @iter. That is to say, @func will be called
|
|
Packit Service |
963350 |
* as @func (object, @ret, @user_data) for each object in @it. The normal use
|
|
Packit Service |
963350 |
* of this procedure is to accumulate the results of operating on the objects in
|
|
Packit Service |
963350 |
* @ret.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This procedure can be used (and is used internally) to implement the
|
|
Packit Service |
963350 |
* gst_iterator_foreach() and gst_iterator_find_custom() operations.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The fold will proceed as long as @func returns %TRUE. When the iterator has no
|
|
Packit Service |
963350 |
* more arguments, %GST_ITERATOR_DONE will be returned. If @func returns %FALSE,
|
|
Packit Service |
963350 |
* the fold will stop, and %GST_ITERATOR_OK will be returned. Errors or resyncs
|
|
Packit Service |
963350 |
* will cause fold to return %GST_ITERATOR_ERROR or %GST_ITERATOR_RESYNC as
|
|
Packit Service |
963350 |
* appropriate.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The iterator will not be freed.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: A #GstIteratorResult, as described above.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIteratorResult
|
|
Packit Service |
963350 |
gst_iterator_fold (GstIterator * it, GstIteratorFoldFunction func,
|
|
Packit Service |
963350 |
GValue * ret, gpointer user_data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GValue item = { 0, };
|
|
Packit Service |
963350 |
GstIteratorResult result;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_return_val_if_fail (it != NULL, GST_ITERATOR_ERROR);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
while (1) {
|
|
Packit Service |
963350 |
result = gst_iterator_next (it, &item);
|
|
Packit Service |
963350 |
switch (result) {
|
|
Packit Service |
963350 |
case GST_ITERATOR_OK:
|
|
Packit Service |
963350 |
if (!func (&item, ret, user_data))
|
|
Packit Service |
963350 |
goto fold_done;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_value_reset (&item);
|
|
Packit Service |
963350 |
break;
|
|
Packit Service |
963350 |
case GST_ITERATOR_RESYNC:
|
|
Packit Service |
963350 |
case GST_ITERATOR_ERROR:
|
|
Packit Service |
963350 |
goto fold_done;
|
|
Packit Service |
963350 |
case GST_ITERATOR_DONE:
|
|
Packit Service |
963350 |
goto fold_done;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
fold_done:
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
#if GLIB_CHECK_VERSION (2, 48, 0)
|
|
Packit Service |
963350 |
g_value_unset (&item);
|
|
Packit Service |
963350 |
#else
|
|
Packit Service |
963350 |
if (item.g_type != 0)
|
|
Packit Service |
963350 |
g_value_unset (&item);
|
|
Packit Service |
963350 |
#endif
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return result;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
typedef struct
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIteratorForeachFunction func;
|
|
Packit Service |
963350 |
gpointer user_data;
|
|
Packit Service |
963350 |
} ForeachFoldData;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static gboolean
|
|
Packit Service |
963350 |
foreach_fold_func (const GValue * item, GValue * unused, ForeachFoldData * data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
data->func (item, data->user_data);
|
|
Packit Service |
963350 |
return TRUE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_foreach:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to iterate
|
|
Packit Service |
963350 |
* @func: (scope call): the function to call for each element.
|
|
Packit Service |
963350 |
* @user_data: (closure): user data passed to the function
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Iterate over all element of @it and call the given function @func for
|
|
Packit Service |
963350 |
* each element.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: the result call to gst_iterator_fold(). The iterator will not be
|
|
Packit Service |
963350 |
* freed.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIteratorResult
|
|
Packit Service |
963350 |
gst_iterator_foreach (GstIterator * it, GstIteratorForeachFunction func,
|
|
Packit Service |
963350 |
gpointer user_data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
ForeachFoldData data;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
data.func = func;
|
|
Packit Service |
963350 |
data.user_data = user_data;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return gst_iterator_fold (it, (GstIteratorFoldFunction) foreach_fold_func,
|
|
Packit Service |
963350 |
NULL, &data);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
typedef struct
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GCompareFunc func;
|
|
Packit Service |
963350 |
gpointer user_data;
|
|
Packit Service |
963350 |
gboolean found;
|
|
Packit Service |
963350 |
} FindCustomFoldData;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static gboolean
|
|
Packit Service |
963350 |
find_custom_fold_func (const GValue * item, GValue * ret,
|
|
Packit Service |
963350 |
FindCustomFoldData * data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (data->func (item, data->user_data) == 0) {
|
|
Packit Service |
963350 |
data->found = TRUE;
|
|
Packit Service |
963350 |
g_value_copy (item, ret);
|
|
Packit Service |
963350 |
return FALSE;
|
|
Packit Service |
963350 |
} else {
|
|
Packit Service |
963350 |
return TRUE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_find_custom:
|
|
Packit Service |
963350 |
* @it: The #GstIterator to iterate
|
|
Packit Service |
963350 |
* @func: (scope call): the compare function to use
|
|
Packit Service |
963350 |
* @elem: (out): pointer to a #GValue where to store the result
|
|
Packit Service |
963350 |
* @user_data: (closure): user data passed to the compare function
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Find the first element in @it that matches the compare function @func.
|
|
Packit Service |
963350 |
* @func should return 0 when the element is found. The first parameter
|
|
Packit Service |
963350 |
* to @func will be the current element of the iterator and the
|
|
Packit Service |
963350 |
* second parameter will be @user_data.
|
|
Packit Service |
963350 |
* The result will be stored in @elem if a result is found.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* The iterator will not be freed.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This function will return %FALSE if an error happened to the iterator
|
|
Packit Service |
963350 |
* or if the element wasn't found.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: Returns %TRUE if the element was found, else %FALSE.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* MT safe.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
gboolean
|
|
Packit Service |
963350 |
gst_iterator_find_custom (GstIterator * it, GCompareFunc func,
|
|
Packit Service |
963350 |
GValue * elem, gpointer user_data)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIteratorResult res;
|
|
Packit Service |
963350 |
FindCustomFoldData data;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_return_val_if_fail (G_VALUE_TYPE (elem) == G_TYPE_INVALID
|
|
Packit Service |
963350 |
|| G_VALUE_HOLDS (elem, it->type), GST_ITERATOR_ERROR);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (G_VALUE_TYPE (elem) == G_TYPE_INVALID)
|
|
Packit Service |
963350 |
g_value_init (elem, it->type);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
data.func = func;
|
|
Packit Service |
963350 |
data.user_data = user_data;
|
|
Packit Service |
963350 |
data.found = FALSE;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
do {
|
|
Packit Service |
963350 |
res =
|
|
Packit Service |
963350 |
gst_iterator_fold (it, (GstIteratorFoldFunction) find_custom_fold_func,
|
|
Packit Service |
963350 |
elem, &data);
|
|
Packit Service |
963350 |
if (res == GST_ITERATOR_RESYNC)
|
|
Packit Service |
963350 |
gst_iterator_resync (it);
|
|
Packit Service |
963350 |
} while (res == GST_ITERATOR_RESYNC);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (!data.found)
|
|
Packit Service |
963350 |
g_value_unset (elem);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return data.found;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
typedef struct
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstIterator parent;
|
|
Packit Service |
963350 |
GValue object;
|
|
Packit Service |
963350 |
gboolean visited;
|
|
Packit Service |
963350 |
gboolean empty;
|
|
Packit Service |
963350 |
} GstSingleObjectIterator;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static guint32 _single_object_dummy_cookie = 0;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_single_object_iterator_copy (const GstSingleObjectIterator * it,
|
|
Packit Service |
963350 |
GstSingleObjectIterator * copy)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (!it->empty) {
|
|
Packit Service |
963350 |
memset (©->object, 0, sizeof (copy->object));
|
|
Packit Service |
963350 |
g_value_init (©->object, it->parent.type);
|
|
Packit Service |
963350 |
g_value_copy (&it->object, ©->object);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static GstIteratorResult
|
|
Packit Service |
963350 |
gst_single_object_iterator_next (GstSingleObjectIterator * it, GValue * result)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (it->visited || it->empty)
|
|
Packit Service |
963350 |
return GST_ITERATOR_DONE;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
g_value_copy (&it->object, result);
|
|
Packit Service |
963350 |
it->visited = TRUE;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return GST_ITERATOR_OK;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_single_object_iterator_resync (GstSingleObjectIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
it->visited = FALSE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
static void
|
|
Packit Service |
963350 |
gst_single_object_iterator_free (GstSingleObjectIterator * it)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
if (!it->empty)
|
|
Packit Service |
963350 |
g_value_unset (&it->object);
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
/**
|
|
Packit Service |
963350 |
* gst_iterator_new_single:
|
|
Packit Service |
963350 |
* @type: #GType of the passed object
|
|
Packit Service |
963350 |
* @object: object that this iterator should return
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* This #GstIterator is a convenient iterator for the common
|
|
Packit Service |
963350 |
* case where a #GstIterator needs to be returned but only
|
|
Packit Service |
963350 |
* a single object has to be considered. This happens often
|
|
Packit Service |
963350 |
* for the #GstPadIterIntLinkFunction.
|
|
Packit Service |
963350 |
*
|
|
Packit Service |
963350 |
* Returns: the new #GstIterator for @object.
|
|
Packit Service |
963350 |
*/
|
|
Packit Service |
963350 |
GstIterator *
|
|
Packit Service |
963350 |
gst_iterator_new_single (GType type, const GValue * object)
|
|
Packit Service |
963350 |
{
|
|
Packit Service |
963350 |
GstSingleObjectIterator *result;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
result = (GstSingleObjectIterator *)
|
|
Packit Service |
963350 |
gst_iterator_new (sizeof (GstSingleObjectIterator),
|
|
Packit Service |
963350 |
type, NULL, &_single_object_dummy_cookie,
|
|
Packit Service |
963350 |
(GstIteratorCopyFunction) gst_single_object_iterator_copy,
|
|
Packit Service |
963350 |
(GstIteratorNextFunction) gst_single_object_iterator_next,
|
|
Packit Service |
963350 |
(GstIteratorItemFunction) NULL,
|
|
Packit Service |
963350 |
(GstIteratorResyncFunction) gst_single_object_iterator_resync,
|
|
Packit Service |
963350 |
(GstIteratorFreeFunction) gst_single_object_iterator_free);
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
if (object) {
|
|
Packit Service |
963350 |
g_value_init (&result->object, type);
|
|
Packit Service |
963350 |
g_value_copy (object, &result->object);
|
|
Packit Service |
963350 |
result->empty = FALSE;
|
|
Packit Service |
963350 |
} else {
|
|
Packit Service |
963350 |
result->empty = TRUE;
|
|
Packit Service |
963350 |
}
|
|
Packit Service |
963350 |
result->visited = FALSE;
|
|
Packit Service |
963350 |
|
|
Packit Service |
963350 |
return GST_ITERATOR (result);
|
|
Packit Service |
963350 |
}
|