/* GStreamer * * Copyright (C) 2007 Rene Stadler * Copyright (C) 2007 Sebastian Dröge * * 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. */ /** * SECTION:element-giosink * @short_description: Write a stream to any GIO-supported location * @see_also: #GstFileSink, #GstGnomeVFSSink, #GstGioSrc * * * * This plugin writes incoming data to a local or remote location specified * by an URI. This location can be specified using any protocol supported by * the GIO library or it's VFS backends. Common protocols are 'file', 'ftp', * or 'smb'. * * * Example pipeline: * * gst-launch -v filesrc location=input.xyz ! giosink location=file:///home/joe/out.xyz * * The above pipeline will simply copy a local file. Instead of giosink, * we could just as well have used the filesink element here. * * * Another example pipeline: * * gst-launch -v filesrc location=foo.mp3 ! mad ! flacenc ! giosink location=smb://othercomputer/foo.flac * * The above pipeline will re-encode an mp3 file into FLAC format and store * it on a remote host using the Samba protocol. * * * Another example pipeline: * * gst-launch -v audiotestsrc num-buffers=100 ! vorbisenc ! oggmux ! giosink location=file:///home/foo/bar.ogg * * The above pipeline will encode a 440Hz sine wave to Ogg Vorbis and stores * it in the home directory of user foo. * * */ /* FIXME: We would like to mount the enclosing volume of an URL * if it isn't mounted yet but this is possible async-only. * Unfortunately this requires a running main loop from the * default context and we can't guarantuee this! * * We would also like to do authentication while mounting. */ #ifdef HAVE_CONFIG_H #include #endif #include "gstgiosink.h" GST_DEBUG_CATEGORY_STATIC (gst_gio_sink_debug); #define GST_CAT_DEFAULT gst_gio_sink_debug /* Filter signals and args */ enum { LAST_SIGNAL }; enum { ARG_0, ARG_LOCATION, ARG_FILE }; GST_BOILERPLATE_FULL (GstGioSink, gst_gio_sink, GstGioBaseSink, GST_TYPE_GIO_BASE_SINK, gst_gio_uri_handler_do_init); static void gst_gio_sink_finalize (GObject * object); static void gst_gio_sink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec); static void gst_gio_sink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec); static gboolean gst_gio_sink_start (GstBaseSink * base_sink); static void gst_gio_sink_base_init (gpointer gclass) { GstElementClass *element_class = GST_ELEMENT_CLASS (gclass); GST_DEBUG_CATEGORY_INIT (gst_gio_sink_debug, "gio_sink", 0, "GIO sink"); gst_element_class_set_details_simple (element_class, "GIO sink", "Sink/File", "Write to any GIO-supported location", "Ren\xc3\xa9 Stadler , " "Sebastian Dröge "); } static void gst_gio_sink_class_init (GstGioSinkClass * klass) { GObjectClass *gobject_class; GstElementClass *gstelement_class; GstBaseSinkClass *gstbasesink_class; gobject_class = (GObjectClass *) klass; gstelement_class = (GstElementClass *) klass; gstbasesink_class = (GstBaseSinkClass *) klass; gobject_class->finalize = gst_gio_sink_finalize; gobject_class->set_property = gst_gio_sink_set_property; gobject_class->get_property = gst_gio_sink_get_property; g_object_class_install_property (gobject_class, ARG_LOCATION, g_param_spec_string ("location", "Location", "URI location to write to", NULL, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); /** * GstGioSink:file * * %GFile to write to. * * Since: 0.10.20 **/ g_object_class_install_property (gobject_class, ARG_FILE, g_param_spec_object ("file", "File", "GFile to write to", G_TYPE_FILE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); gstbasesink_class->start = GST_DEBUG_FUNCPTR (gst_gio_sink_start); } static void gst_gio_sink_init (GstGioSink * sink, GstGioSinkClass * gclass) { } static void gst_gio_sink_finalize (GObject * object) { GstGioSink *sink = GST_GIO_SINK (object); if (sink->file) { g_object_unref (sink->file); sink->file = NULL; } GST_CALL_PARENT (G_OBJECT_CLASS, finalize, (object)); } static void gst_gio_sink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec) { GstGioSink *sink = GST_GIO_SINK (object); switch (prop_id) { case ARG_LOCATION:{ const gchar *uri = NULL; if (GST_STATE (sink) == GST_STATE_PLAYING || GST_STATE (sink) == GST_STATE_PAUSED) { GST_WARNING ("Setting a new location or GFile not supported in PLAYING or PAUSED state"); break; } GST_OBJECT_LOCK (GST_OBJECT (sink)); if (sink->file) g_object_unref (sink->file); uri = g_value_get_string (value); if (uri) { sink->file = g_file_new_for_uri (uri); if (!sink->file) { GST_ERROR ("Could not create GFile for URI '%s'", uri); } } else { sink->file = NULL; } GST_OBJECT_UNLOCK (GST_OBJECT (sink)); break; } case ARG_FILE: if (GST_STATE (sink) == GST_STATE_PLAYING || GST_STATE (sink) == GST_STATE_PAUSED) { GST_WARNING ("Setting a new location or GFile not supported in PLAYING or PAUSED state"); break; } GST_OBJECT_LOCK (GST_OBJECT (sink)); if (sink->file) g_object_unref (sink->file); sink->file = g_value_dup_object (value); GST_OBJECT_UNLOCK (GST_OBJECT (sink)); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static void gst_gio_sink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec) { GstGioSink *sink = GST_GIO_SINK (object); switch (prop_id) { case ARG_LOCATION:{ gchar *uri; GST_OBJECT_LOCK (GST_OBJECT (sink)); if (sink->file) { uri = g_file_get_uri (sink->file); g_value_set_string (value, uri); g_free (uri); } else { g_value_set_string (value, NULL); } GST_OBJECT_UNLOCK (GST_OBJECT (sink)); break; } case ARG_FILE: GST_OBJECT_LOCK (GST_OBJECT (sink)); g_value_set_object (value, sink->file); GST_OBJECT_UNLOCK (GST_OBJECT (sink)); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static gboolean gst_gio_sink_start (GstBaseSink * base_sink) { GstGioSink *sink = GST_GIO_SINK (base_sink); GOutputStream *stream; GCancellable *cancel = GST_GIO_BASE_SINK (sink)->cancel; gboolean success; GError *err = NULL; gchar *uri; if (sink->file == NULL) { GST_ELEMENT_ERROR (sink, RESOURCE, OPEN_WRITE, (NULL), ("No location or GFile given")); return FALSE; } uri = g_file_get_uri (sink->file); if (!uri) uri = g_strdup ("(null)"); stream = G_OUTPUT_STREAM (g_file_create (sink->file, G_FILE_CREATE_NONE, cancel, &err)); success = (stream != NULL); if (!success && !gst_gio_error (sink, "g_file_create", &err, NULL)) { /*if (GST_GIO_ERROR_MATCHES (err, EXISTS)) */ /* FIXME: Retry with replace if overwrite == TRUE! */ if (GST_GIO_ERROR_MATCHES (err, NOT_FOUND)) GST_ELEMENT_ERROR (sink, RESOURCE, NOT_FOUND, (NULL), ("Could not open location %s for writing: %s", uri, err->message)); else GST_ELEMENT_ERROR (sink, RESOURCE, OPEN_READ, (NULL), ("Could not open location %s for writing: %s", uri, err->message)); g_free (uri); g_clear_error (&err); } if (!success) return FALSE; GST_DEBUG_OBJECT (sink, "opened location %s", uri); g_free (uri); gst_gio_base_sink_set_stream (GST_GIO_BASE_SINK (sink), stream); return GST_BASE_SINK_CLASS (parent_class)->start (base_sink); }