--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/gst_plugins_base/ext/gio/gstgio.c	Thu Dec 17 08:53:32 2009 +0200
@@ -0,0 +1,214 @@
+/* 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)