mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 19:51:11 +00:00
Code Issues 1 Projects Releases Wiki Activity

- Added infrastructure to run a filter against plugins, registries and registrypools. This makes it possible to creat...

Browse source 
Original commit message from CVS:
- Added infrastructure to run a filter against plugins, registries and
registrypools. This makes it possible to create custom code to filter
out the plugins/features you're interested in.
This commit is contained in:
Wim Taymans 2003-04-14 18:53:03 +00:00
parent 4c33218ba3
commit eb5536af92
12 changed files with 353 additions and 201 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
gst/gstfilter.c Normal file
View file

@ -0,0 +1,46 @@
/* GStreamer
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
*
* 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 <gst/gstfilter.h>
GList*
gst_filter_run (const GList *list, GstFilterFunc func, gboolean first, gpointer user_data)
{
const GList *walk = list;
GList *result = NULL;
while (walk) {
gboolean res = TRUE;
gpointer data = walk->data;
walk = g_list_next (walk);
if (func)
res = func (data, user_data);
if (res) {
result = g_list_prepend (result, data);
if (first)
break;
}
}
return result;
}

24
gst/gstfilter.h Normal file
View file

@ -0,0 +1,24 @@
/* GStreamer
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
*
* 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 <glib.h>
typedef gboolean (*GstFilterFunc) (gpointer obj, gpointer user_data);
GList* gst_filter_run (const GList *list, GstFilterFunc func, gboolean first, gpointer user_data);

102
gst/gstplugin.c
View file

@ -31,6 +31,7 @@
#include "gstregistrypool.h"
#include "gstlog.h"
#include "config.h"
#include "gstfilter.h"
static GModule *main_module = NULL;
static GList *_gst_plugin_static = NULL;
@ -76,19 +77,10 @@ _gst_plugin_register_static (GstPluginDesc *desc)
void
_gst_plugin_initialize (void)
{
GList *walk;
main_module = g_module_open (NULL, G_MODULE_BIND_LAZY);
/* now register all static plugins */
walk = _gst_plugin_static;
while (walk) {
GstPluginDesc *desc = (GstPluginDesc *) walk->data;
_gst_plugin_register_static (desc);
walk = g_list_next (walk);
}
g_list_foreach (_gst_plugin_static, (GFunc) _gst_plugin_register_static, NULL);
}
static gboolean
@ -283,8 +275,7 @@ gst_plugin_set_name (GstPlugin *plugin, const gchar *name)
{
g_return_if_fail (plugin != NULL);
if (plugin->name)
g_free (plugin->name);
g_free (plugin->name);
plugin->name = g_strdup (name);
}
@ -301,8 +292,7 @@ gst_plugin_set_longname (GstPlugin *plugin, const gchar *longname)
{
g_return_if_fail(plugin != NULL);
if (plugin->longname)
g_free(plugin->longname);
g_free(plugin->longname);
plugin->longname = g_strdup(longname);
}
@ -355,6 +345,64 @@ gst_plugin_is_loaded (GstPlugin *plugin)
return (plugin->module != NULL);
}
GList*
gst_plugin_feature_filter (GstPlugin *plugin,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data)
{
return gst_filter_run (plugin->features, (GstFilterFunc) filter, first, user_data);
}
typedef struct
{
GstPluginFeatureFilter filter;
gboolean first;
gpointer user_data;
GList *result;
} FeatureFilterData;
gboolean
_feature_filter (GstPlugin *plugin, gpointer user_data)
{
GList *result;
FeatureFilterData *data = (FeatureFilterData *) user_data;
result = gst_plugin_feature_filter (plugin, data->filter, data->first, data->user_data);
if (result) {
data->result = g_list_concat (data->result, result);
return TRUE;
}
return FALSE;
}
GList*
gst_plugin_list_feature_filter (GList *list,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data)
{
FeatureFilterData data;
GList *result;
data.filter = filter;
data.first = first;
data.user_data = user_data;
data.result = NULL;
result = gst_filter_run (list, (GstFilterFunc) _feature_filter, first, &data);
g_list_free (result);
return data.result;
}
gboolean
gst_plugin_name_filter (GstPlugin *plugin, const gchar *name)
{
return (plugin->name && !strcmp (plugin->name, name));
}
/**
* gst_plugin_find_feature:
* @plugin: plugin to get the feature from
@ -368,20 +416,23 @@ gst_plugin_is_loaded (GstPlugin *plugin)
GstPluginFeature*
gst_plugin_find_feature (GstPlugin *plugin, const gchar *name, GType type)
{
GList *features = plugin->features;
GList *walk;
GstPluginFeature *result = NULL;
GstTypeNameData data;
g_return_val_if_fail (name != NULL, NULL);
while (features) {
GstPluginFeature *feature = GST_PLUGIN_FEATURE (features->data);
data.type = type;
data.name = name;
if (!strcmp(GST_PLUGIN_FEATURE_NAME (feature), name) && G_OBJECT_TYPE (feature) == type) {
return GST_PLUGIN_FEATURE (feature);
}
walk = gst_filter_run (plugin->features,
(GstFilterFunc) gst_plugin_feature_type_name_filter, TRUE,
&data);
features = g_list_next (features);
}
return NULL;
if (walk)
result = GST_PLUGIN_FEATURE (walk->data);
return result;
}
/**
@ -418,14 +469,14 @@ gst_plugin_add_feature (GstPlugin *plugin, GstPluginFeature *feature)
*
* get a list of all the features that this plugin provides
*
* Returns: a GList of features
* Returns: a GList of features, use g_list_free to free the list.
*/
GList*
gst_plugin_get_feature_list (GstPlugin *plugin)
{
g_return_val_if_fail (plugin != NULL, NULL);
return plugin->features;
return g_list_copy (plugin->features);
}
/**
@ -455,6 +506,7 @@ gst_plugin_load (const gchar *name)
GST_DEBUG (GST_CAT_PLUGIN_LOADING, "Could not find %s in registry pool",
name);
return FALSE;
}

14
gst/gstplugin.h
View file

@ -97,6 +97,10 @@ _gst_plugin_static_init__ ##init (void) \
GST_PLUGIN_DESC_DYNAMIC (major,minor,name,init) \
GST_PLUGIN_DESC_STATIC (major,minor,name,init)
/* function for filters */
typedef gboolean (*GstPluginFilter) (GstPlugin *plugin,
gpointer user_data);
void _gst_plugin_initialize (void);
void _gst_plugin_register_static (GstPluginDesc *desc);
@ -109,6 +113,16 @@ void gst_plugin_set_longname (GstPlugin *plugin, const gchar *longname);
const gchar* gst_plugin_get_filename (GstPlugin *plugin);
gboolean gst_plugin_is_loaded (GstPlugin *plugin);
GList* gst_plugin_feature_filter (GstPlugin *plugin,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data);
GList* gst_plugin_list_feature_filter (GList *list,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data);
gboolean gst_plugin_name_filter (GstPlugin *plugin, const gchar *name);
GList* gst_plugin_get_feature_list (GstPlugin *plugin);
GstPluginFeature* gst_plugin_find_feature (GstPlugin *plugin, const gchar *name, GType type);

8
gst/gstpluginfeature.c
View file

@ -128,5 +128,11 @@ gst_plugin_feature_unload_thyself (GstPluginFeature *feature)
oclass->unload_thyself (feature);
}
gboolean
gst_plugin_feature_type_name_filter (GstPluginFeature *feature,
GstTypeNameData *data)
{
return ((data->type == 0 || data->type == G_OBJECT_TYPE (feature)) &&
(data->name == NULL || !strcmp (data->name, GST_PLUGIN_FEATURE_NAME (feature))));
}

11
gst/gstpluginfeature.h
View file

@ -56,6 +56,14 @@ struct _GstPluginFeatureClass {
void (*unload_thyself) (GstPluginFeature *feature);
};
typedef struct {
const gchar *name;
GType type;
} GstTypeNameData;
/* filter */
typedef gboolean (*GstPluginFeatureFilter) (GstPluginFeature *feature,
gpointer user_data);
/* normal GObject stuff */
GType gst_plugin_feature_get_type (void);
@ -63,6 +71,9 @@ GType gst_plugin_feature_get_type (void);
gboolean gst_plugin_feature_ensure_loaded (GstPluginFeature *feature);
void gst_plugin_feature_unload_thyself (GstPluginFeature *feature);
gboolean gst_plugin_feature_type_name_filter (GstPluginFeature *feature,
GstTypeNameData *data);
G_END_DECLS

83
gst/gstregistry.c
View file

@ -32,6 +32,7 @@
#include "gstregistry.h"
#include "gstlog.h"
#include "gstmarshal.h"
#include "gstfilter.h"
/* Element signals and args */
enum {
@ -215,17 +216,12 @@ gst_registry_unload (GstRegistry *registry)
void
gst_registry_add_path (GstRegistry *registry, const gchar *path)
{
GList *l;
g_return_if_fail (GST_IS_REGISTRY (registry));
g_return_if_fail (path != NULL);
l = registry->paths;
while (l) {
if (strcmp (l->data, path) == 0)
return;
l = g_list_next (l);
if (g_list_find_custom (registry->paths, path, (GCompareFunc) strcmp)) {
g_warning ("path %s already added to registry", path);
return;
}
registry->paths = g_list_append (registry->paths, g_strdup (path));
@ -248,12 +244,6 @@ gst_registry_get_path_list (GstRegistry *registry)
}
static void
free_list_strings_func (gpointer data, gpointer user_data)
{
g_free (data);
}
/**
* gst_registry_clear_paths:
* @registry: the registry to clear the paths of
@ -265,7 +255,7 @@ gst_registry_clear_paths (GstRegistry *registry)
{
g_return_if_fail (GST_IS_REGISTRY (registry));
g_list_foreach (registry->paths, free_list_strings_func, NULL);
g_list_foreach (registry->paths, (GFunc) g_free, NULL);
g_list_free (registry->paths);
registry->paths = NULL;
@ -309,6 +299,28 @@ gst_registry_remove_plugin (GstRegistry *registry, GstPlugin *plugin)
registry->plugins = g_list_remove (registry->plugins, plugin);
}
GList*
gst_registry_plugin_filter (GstRegistry *registry,
GstPluginFilter filter,
gboolean first,
gpointer user_data)
{
g_return_val_if_fail (GST_IS_REGISTRY (registry), NULL);
return gst_filter_run (registry->plugins, (GstFilterFunc) filter, first, user_data);
}
GList*
gst_registry_feature_filter (GstRegistry *registry,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data)
{
g_return_val_if_fail (GST_IS_REGISTRY (registry), NULL);
return gst_plugin_list_feature_filter (registry->plugins, filter, first, user_data);
}
/**
* gst_registry_find_plugin:
* @registry: the registry to search
@ -321,22 +333,22 @@ gst_registry_remove_plugin (GstRegistry *registry, GstPlugin *plugin)
GstPlugin*
gst_registry_find_plugin (GstRegistry *registry, const gchar *name)
{
GList *plugins;
GList *walk;
GstPlugin *result = NULL;
g_return_val_if_fail (GST_IS_REGISTRY (registry), NULL);
g_return_val_if_fail (name != NULL, NULL);
plugins = registry->plugins;
walk = gst_registry_plugin_filter (registry,
(GstPluginFilter) gst_plugin_name_filter,
TRUE,
(gpointer) name);
if (walk)
result = GST_PLUGIN (walk->data);
while (plugins) {
GstPlugin *plugin = (GstPlugin *) (plugins->data);
g_list_free (walk);
if (plugin->name && !strcmp (plugin->name, name))
return plugin;
plugins = g_list_next (plugins);
}
return NULL;
return result;
}
/**
@ -354,22 +366,25 @@ GstPluginFeature*
gst_registry_find_feature (GstRegistry *registry, const gchar *name, GType type)
{
GstPluginFeature *feature = NULL;
GList *plugins;
GList *walk;
GstTypeNameData data;
g_return_val_if_fail (GST_IS_REGISTRY (registry), NULL);
g_return_val_if_fail (name != NULL, NULL);
plugins = registry->plugins;
data.name = name;
data.type = type;
while (plugins) {
GstPlugin *plugin = (GstPlugin *) (plugins->data);
walk = gst_registry_feature_filter (registry,
(GstPluginFeatureFilter) gst_plugin_feature_type_name_filter,
TRUE,
&data);
feature = gst_plugin_find_feature (plugin, name, type);
if (feature)
return feature;
if (walk)
feature = GST_PLUGIN_FEATURE (walk->data);
g_list_free (walk);
plugins = g_list_next (plugins);
}
return feature;
}

9
gst/gstregistry.h
View file

@ -125,6 +125,15 @@ void gst_registry_clear_paths (GstRegistry *registry);
gboolean gst_registry_add_plugin (GstRegistry *registry, GstPlugin *plugin);
void gst_registry_remove_plugin (GstRegistry *registry, GstPlugin *plugin);
GList* gst_registry_plugin_filter (GstRegistry *registry,
GstPluginFilter filter,
gboolean first,
gpointer user_data);
GList* gst_registry_feature_filter (GstRegistry *registry,
GstPluginFeatureFilter filter,
gboolean first,
gpointer user_data);
GstPlugin* gst_registry_find_plugin (GstRegistry *registry, const gchar *name);
GstPluginFeature* gst_registry_find_feature (GstRegistry *registry, const gchar *name, GType type);

169
gst/gstregistrypool.c
View file

@ -25,6 +25,7 @@
#include "gstinfo.h"
#include "gstregistrypool.h"
#include "gstlog.h"
#include "gstfilter.h"
static GList *_gst_registry_pool = NULL;
static GList *_gst_registry_pool_plugins = NULL;
@ -93,6 +94,16 @@ gst_registry_pool_add_plugin (GstPlugin *plugin)
_gst_registry_pool_plugins = g_list_prepend (_gst_registry_pool_plugins, plugin);
}
#ifndef GST_DISABLE_REGISTRY
static void
_registry_load_func (GstRegistry *registry, gpointer user_data)
{
if (registry->flags & GST_REGISTRY_READABLE &&
!(registry->flags & GST_REGISTRY_DELAYED_LOADING)) {
gst_registry_load (registry);
}
}
#endif /* GST_DISABLE_REGISTRY */
/**
* gst_registry_pool_load_all:
@ -104,18 +115,7 @@ void
gst_registry_pool_load_all (void)
{
#ifndef GST_DISABLE_REGISTRY
GList *walk = _gst_registry_pool;
while (walk) {
GstRegistry *registry = GST_REGISTRY (walk->data);
if (registry->flags & GST_REGISTRY_READABLE &&
!(registry->flags & GST_REGISTRY_DELAYED_LOADING)) {
gst_registry_load (registry);
}
walk = g_list_next (walk);
}
g_list_foreach (_gst_registry_pool, (GFunc) _registry_load_func, NULL);
#endif /* GST_DISABLE_REGISTRY */
}
@ -128,31 +128,37 @@ gst_registry_pool_load_all (void)
*/
GList*
gst_registry_pool_plugin_list (void)
{
return gst_registry_pool_plugin_filter (NULL, FALSE, NULL);
}
GList*
gst_registry_pool_plugin_filter (GstPluginFilter filter, gboolean first, gpointer user_data)
{
GList *result = NULL;
GList *walk, *temp;
#ifndef GST_DISABLE_REGISTRY
GList *walk = _gst_registry_pool;
walk = _gst_registry_pool;
while (walk) {
GstRegistry *registry = GST_REGISTRY (walk->data);
/* FIXME only include highest priority plugins */
result = g_list_concat (result, g_list_copy (registry->plugins));
temp = gst_registry_plugin_filter (registry, filter, first, user_data);
if (temp && first)
return temp;
result = g_list_concat (result, temp);
walk = g_list_next (walk);
}
#endif /* GST_DISABLE_REGISTRY */
return g_list_concat (_gst_registry_pool_plugins, result);
}
temp = gst_filter_run (_gst_registry_pool_plugins, (GstFilterFunc) filter, first, user_data);
GstFeatureFilterResult
gst_registry_pool_feature_type_filter (GstPluginFeature *feature, GType type)
{
if (type == 0 || G_OBJECT_TYPE (feature) == type)
return GST_FEATURE_FILTER_OK;
result = g_list_concat (result, temp);
return GST_FEATURE_FILTER_NOK;
return result;
}
/**
@ -166,66 +172,59 @@ gst_registry_pool_feature_type_filter (GstPluginFeature *feature, GType type)
GList*
gst_registry_pool_feature_list (GType type)
{
GstTypeNameData data;
data.name = NULL;
data.type = type;
return gst_registry_pool_feature_filter (
(GstPluginFeatureFilter) gst_registry_pool_feature_type_filter,
GINT_TO_POINTER (type));
(GstPluginFeatureFilter) gst_plugin_feature_type_name_filter,
FALSE,
&data);
}
/**
* gst_registry_pool_feature_filter:
* @filter: the filter to apply to the feature list
* @first: return the first matching feature
* @user_data: data passed to the filter function
*
* Apply the filter function to all features and return a list
* of those features that satisfy the filter.
* of those features that satisfy the filter. If the first flag
* is TRUE, only the first match is returned in a GList with
* one element.
*
* Returns: a GList of pluginfeatures, g_list_free after use.
*/
GList*
gst_registry_pool_feature_filter (GstPluginFeatureFilter filter, gpointer user_data)
gst_registry_pool_feature_filter (GstPluginFeatureFilter filter, gboolean first, gpointer user_data)
{
GList *result = NULL;
GList *plugins, *orig;
gboolean done = FALSE;
GList *walk, *temp;
orig = plugins = gst_registry_pool_plugin_list ();
#ifndef GST_DISABLE_REGISTRY
walk = _gst_registry_pool;
while (plugins && !done) {
GstPlugin *plugin = GST_PLUGIN (plugins->data);
GList *features = plugin->features;
while (walk) {
GstRegistry *registry = GST_REGISTRY (walk->data);
plugins = g_list_next (plugins);
temp = gst_registry_feature_filter (registry, filter, first, user_data);
if (temp && first)
return temp;
while (features && !done) {
GstPluginFeature *feature = GST_PLUGIN_FEATURE (features->data);
gboolean res = GST_FEATURE_FILTER_OK;
result = g_list_concat (result, temp);
features = g_list_next (features);
if (filter)
res = filter (feature, user_data);
switch (res) {
case GST_FEATURE_FILTER_DONE:
done = TRUE;
/* fallthrough */
case GST_FEATURE_FILTER_OK:
result = g_list_prepend (result, feature);
break;
case GST_FEATURE_FILTER_NOK:
default:
break;
}
}
walk = g_list_next (walk);
}
result = g_list_reverse (result);
#endif /* GST_DISABLE_REGISTRY */
g_list_free (orig);
temp = gst_plugin_list_feature_filter (_gst_registry_pool_plugins, filter, first, user_data);
result = g_list_concat (result, temp);
return result;
}
/**
* gst_registry_pool_find_plugin:
* @name: the name of the plugin to find
@ -243,30 +242,14 @@ gst_registry_pool_find_plugin (const gchar *name)
g_return_val_if_fail (name != NULL, NULL);
walk = _gst_registry_pool_plugins;
while (walk) {
result = (GstPlugin *) (walk->data);
walk = gst_registry_pool_plugin_filter ((GstPluginFilter) gst_plugin_name_filter, TRUE, (gpointer) name);
if (result->name && !strcmp (result->name, name))
return result;
if (walk)
result = GST_PLUGIN (walk->data);
walk = g_list_next (walk);
}
g_list_free (walk);
#ifndef GST_DISABLE_REGISTRY
walk = _gst_registry_pool;
while (walk) {
GstRegistry *registry = GST_REGISTRY (walk->data);
/* FIXME only include highest priority plugins */
result = gst_registry_find_plugin (registry, name);
if (result)
return result;
walk = g_list_next (walk);
}
#endif /* GST_DISABLE_REGISTRY */
return NULL;
return result;
}
/**
@ -285,34 +268,22 @@ gst_registry_pool_find_feature (const gchar *name, GType type)
{
GstPluginFeature *result = NULL;
GList *walk;
GstTypeNameData data;
g_return_val_if_fail (name != NULL, NULL);
walk = _gst_registry_pool_plugins;
while (walk) {
GstPlugin *plugin = (GstPlugin *) (walk->data);
data.type = type;
data.name = name;
result = gst_plugin_find_feature (plugin, name, type);
if (result)
return result;
walk = gst_registry_pool_feature_filter ((GstPluginFeatureFilter) gst_plugin_feature_type_name_filter,
TRUE, &data);
walk = g_list_next (walk);
}
if (walk)
result = GST_PLUGIN_FEATURE (walk->data);
#ifndef GST_DISABLE_REGISTRY
walk = _gst_registry_pool;
while (walk) {
GstRegistry *registry = GST_REGISTRY (walk->data);
g_list_free (walk);
/* FIXME only include highest priority plugins */
result = gst_registry_find_feature (registry, name, type);
if (result)
return result;
walk = g_list_next (walk);
}
#endif /* GST_DISABLE_REGISTRY */
return NULL;
return result;
}
/**

26
gst/gstregistrypool.h
View file

@ -24,23 +24,14 @@
#ifndef __GST_REGISTRY_POOL_H__
#define __GST_REGISTRY_POOL_H__
#include <gst/gstregistry.h>
G_BEGIN_DECLS
typedef enum
{
GST_FEATURE_FILTER_OK, /* include feature in list */
GST_FEATURE_FILTER_NOK, /* does not include filter in list */
GST_FEATURE_FILTER_DONE, /* includes filter in list and stop processing */
} GstFeatureFilterResult;
typedef GstFeatureFilterResult (*GstPluginFeatureFilter) (GstPluginFeature *feature,
gpointer user_data);
#include <gst/gstplugin.h>
#include <gst/gstregistry.h>
/* the pool of registries */
GList* gst_registry_pool_list (void);
void gst_registry_pool_add (GstRegistry *registry, guint priority);
void gst_registry_pool_remove (GstRegistry *registry);
@ -48,12 +39,15 @@ void gst_registry_pool_add_plugin (GstPlugin *plugin);
void gst_registry_pool_load_all (void);
/* query the plugins/features */
GList* gst_registry_pool_plugin_filter (GstPluginFilter filter,
gboolean first, gpointer user_data);
GList* gst_registry_pool_feature_filter (GstPluginFeatureFilter filter,
gboolean first, gpointer user_data);
/* some predefined filters */
GList* gst_registry_pool_plugin_list (void);
GList* gst_registry_pool_feature_list (GType type);
GList* gst_registry_pool_feature_filter (GstPluginFeatureFilter filter, gpointer user_data);
GstFeatureFilterResult gst_registry_pool_feature_type_filter (GstPluginFeature *feature, GType type);
GstPlugin* gst_registry_pool_find_plugin (const gchar *name);
GstPluginFeature* gst_registry_pool_find_feature (const gchar *name, GType type);

29
gst/gsturi.c
View file

@ -157,6 +157,18 @@ g_str_has_prefix_glib22 (gchar *haystack, gchar *needle)
return FALSE;
}
gboolean
gst_uri_handler_uri_filter (GstPluginFeature *feature, const gchar *uri)
{
if (G_OBJECT_TYPE (feature) == GST_TYPE_URI_HANDLER) {
GstURIHandler *handler = GST_URI_HANDLER (feature);
if (g_str_has_prefix_glib22 ((gchar *) uri, handler->uri)) {
return TRUE;
}
}
return FALSE;
}
/**
* gst_uri_handler_find_by_uri:
* @uri: the uri to find a handler for
@ -168,23 +180,18 @@ g_str_has_prefix_glib22 (gchar *haystack, gchar *needle)
GstURIHandler*
gst_uri_handler_find_by_uri (const gchar *uri)
{
GList *walk, *orig;
GList *walk;
GstURIHandler *result = NULL;
g_return_val_if_fail (uri != NULL, NULL);
orig = walk = gst_registry_pool_feature_list (GST_TYPE_URI_HANDLER);
walk = gst_registry_pool_feature_filter (
(GstPluginFeatureFilter) gst_uri_handler_uri_filter, TRUE, (gpointer) uri);
while (walk) {
GstURIHandler *handler = GST_URI_HANDLER (walk->data);
if (g_str_has_prefix_glib22 ((gchar *) uri, handler->uri)) {
result = handler;
break;
}
walk = g_list_next (walk);
if (walk) {
result = GST_URI_HANDLER (walk->data);
}
g_list_free (orig);
g_list_free (walk);
return result;
}

3
gst/gsturi.h
View file

@ -67,6 +67,9 @@ GstURIHandler* gst_uri_handler_find_by_uri (const gchar *uri);
GstElement* gst_uri_handler_create (GstURIHandler *handler, const gchar *name);
GstElement* gst_uri_handler_make_by_uri (const gchar *uri, const gchar *name);
/* filters */
gboolean gst_uri_handler_uri_filter (GstPluginFeature *feature, const gchar *uri);
G_END_DECLS
#endif /* __GST_URI_H */