--- a/gst_plugins_base/ext/gio/gstgio.c Wed Mar 31 22:03:18 2010 +0300
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,214 +0,0 @@
-/* GStreamer
- *
- * Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <slomo@circular-chaos.org>
- *
- * 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.
- */
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include "gstgio.h"
-#include "gstgiosink.h"
-#include "gstgiosrc.h"
-#include "gstgiostreamsink.h"
-#include "gstgiostreamsrc.h"
-
-GST_DEBUG_CATEGORY_STATIC (gst_gio_debug);
-#define GST_CAT_DEFAULT gst_gio_debug
-
-/* @func_name: Name of the GIO function, for debugging messages.
- * @err: Error location. *err may be NULL, but err must be non-NULL.
- * @ret: Flow return location. May be NULL. Is set to either #GST_FLOW_ERROR
- * or #GST_FLOW_WRONG_STATE.
- *
- * Returns: TRUE to indicate a handled error. Error at given location err will
- * be freed and *err will be set to NULL. A FALSE return indicates an unhandled
- * error: The err location is unchanged and guaranteed to be != NULL. ret, if
- * given, is set to GST_FLOW_ERROR.
- */
-gboolean
-gst_gio_error (gpointer element, const gchar * func_name, GError ** err,
- GstFlowReturn * ret)
-{
- gboolean handled = TRUE;
-
- if (ret)
- *ret = GST_FLOW_ERROR;
-
- if (GST_GIO_ERROR_MATCHES (*err, CANCELLED)) {
- GST_DEBUG_OBJECT (element, "blocking I/O call cancelled (%s)", func_name);
- if (ret)
- *ret = GST_FLOW_WRONG_STATE;
- } else if (*err != NULL) {
- handled = FALSE;
- } else {
- GST_ELEMENT_ERROR (element, LIBRARY, FAILED, (NULL),
- ("%s call failed without error set", func_name));
- }
-
- if (handled)
- g_clear_error (err);
-
- return handled;
-}
-
-GstFlowReturn
-gst_gio_seek (gpointer element, GSeekable * stream, guint64 offset,
- GCancellable * cancel)
-{
- gboolean success;
- GstFlowReturn ret;
- GError *err = NULL;
-
- GST_LOG_OBJECT (element, "seeking to offset %" G_GINT64_FORMAT, offset);
-
- success = g_seekable_seek (stream, offset, G_SEEK_SET, cancel, &err);
-
- if (success)
- ret = GST_FLOW_OK;
- else if (!gst_gio_error (element, "g_seekable_seek", &err, &ret)) {
- GST_ELEMENT_ERROR (element, RESOURCE, SEEK, (NULL),
- ("Could not seek: %s", err->message));
- g_clear_error (&err);
- }
-
- return ret;
-}
-
-static gchar **
-gst_gio_get_supported_protocols (void)
-{
- return g_strdupv ((gchar **)
- g_vfs_get_supported_uri_schemes (g_vfs_get_default ()));
-}
-
-static GstURIType
-gst_gio_uri_handler_get_type_sink (void)
-{
- return GST_URI_SINK;
-}
-
-static GstURIType
-gst_gio_uri_handler_get_type_src (void)
-{
- return GST_URI_SRC;
-}
-
-static gchar **
-gst_gio_uri_handler_get_protocols (void)
-{
- static gchar **protocols = NULL;
-
- if (!protocols)
- protocols = gst_gio_get_supported_protocols ();
-
- return protocols;
-}
-
-static const gchar *
-gst_gio_uri_handler_get_uri (GstURIHandler * handler)
-{
- GstElement *element = GST_ELEMENT (handler);
- const gchar *uri;
-
- g_return_val_if_fail (GST_IS_ELEMENT (element), NULL);
-
- g_object_get (G_OBJECT (element), "location", &uri, NULL);
-
- return uri;
-}
-
-static gboolean
-gst_gio_uri_handler_set_uri (GstURIHandler * handler, const gchar * uri)
-{
- GstElement *element = GST_ELEMENT (handler);
-
- g_return_val_if_fail (GST_IS_ELEMENT (element), FALSE);
-
- if (GST_STATE (element) == GST_STATE_PLAYING ||
- GST_STATE (element) == GST_STATE_PAUSED)
- return FALSE;
-
- g_object_set (G_OBJECT (element), "location", uri, NULL);
-
- return TRUE;
-}
-
-static void
-gst_gio_uri_handler_init (gpointer g_iface, gpointer iface_data)
-{
- GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface;
- gboolean sink = GPOINTER_TO_INT (iface_data); /* See in do_init below. */
-
- if (sink)
- iface->get_type = gst_gio_uri_handler_get_type_sink;
- else
- iface->get_type = gst_gio_uri_handler_get_type_src;
- iface->get_protocols = gst_gio_uri_handler_get_protocols;
- iface->get_uri = gst_gio_uri_handler_get_uri;
- iface->set_uri = gst_gio_uri_handler_set_uri;
-}
-
-void
-gst_gio_uri_handler_do_init (GType type)
-{
- GInterfaceInfo uri_handler_info = {
- gst_gio_uri_handler_init,
- NULL,
- NULL
- };
-
- /* Store information for uri_handler_init to use for distinguishing the
- * element types. This lets us use a single interface implementation for both
- * classes. */
- uri_handler_info.interface_data = GINT_TO_POINTER (g_type_is_a (type,
- GST_TYPE_BASE_SINK));
-
- g_type_add_interface_static (type, GST_TYPE_URI_HANDLER, &uri_handler_info);
-}
-
-static gboolean
-plugin_init (GstPlugin * plugin)
-{
- gboolean ret = TRUE;
-
- GST_DEBUG_CATEGORY_INIT (gst_gio_debug, "gio", 0, "GIO elements");
-
- /* FIXME: Rank is MARGINAL for now, should be at least SECONDARY+1 in the future
- * to replace gnomevfssink/src. For testing purposes PRIMARY+1 one makes sense
- * so it gets autoplugged and preferred over filesrc/sink. */
-
- ret &= gst_element_register (plugin, "giosink", GST_RANK_MARGINAL,
- GST_TYPE_GIO_SINK);
-
- ret &= gst_element_register (plugin, "giosrc", GST_RANK_MARGINAL,
- GST_TYPE_GIO_SRC);
-
- ret &= gst_element_register (plugin, "giostreamsink", GST_RANK_NONE,
- GST_TYPE_GIO_STREAM_SINK);
-
- ret &= gst_element_register (plugin, "giostreamsrc", GST_RANK_NONE,
- GST_TYPE_GIO_STREAM_SRC);
-
- return ret;
-}
-
-GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, GST_VERSION_MINOR, "gio",
- "GIO elements", plugin_init, VERSION, "LGPL", GST_PACKAGE_NAME,
- GST_PACKAGE_ORIGIN)