/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <sebastian.droege@collabora.co.uk>
+ * Copyright (C) 2007-2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
gst_gio_base_sink_start (GstBaseSink * base_sink)
{
GstGioBaseSink *sink = GST_GIO_BASE_SINK (base_sink);
+ GstGioBaseSinkClass *gbsink_class = GST_GIO_BASE_SINK_GET_CLASS (sink);
- if (!G_IS_OUTPUT_STREAM (sink->stream)) {
+ sink->position = 0;
+
+ /* FIXME: This will likely block */
+ sink->stream = gbsink_class->get_stream (sink);
+ if (G_UNLIKELY (!G_IS_OUTPUT_STREAM (sink->stream))) {
GST_ELEMENT_ERROR (sink, RESOURCE, OPEN_WRITE, (NULL),
- ("No stream given yet"));
+ ("No output stream provided by subclass"));
return FALSE;
}
- sink->position = 0;
-
- GST_DEBUG_OBJECT (sink, "started stream");
+ GST_DEBUG_OBJECT (sink, "started sink");
return TRUE;
}
/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <slomo@circular-chaos.org>
+ * Copyright (C) 2007-2009 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
{
GstBaseSink sink;
+ /* < protected > */
GCancellable *cancel;
guint64 position;
+
+ /* < private > */
GOutputStream *stream;
};
struct _GstGioBaseSinkClass
{
GstBaseSinkClass parent_class;
+
+ GOutputStream * (*get_stream) (GstGioBaseSink *bsink);
};
GType gst_gio_base_sink_get_type (void);
-void gst_gio_base_sink_set_stream (GstGioBaseSink *sink, GOutputStream *stream);
-
G_END_DECLS
#endif /* __GST_GIO_BASE_SINK_H__ */
{
GstBaseSrc src;
+ /* < protected > */
GCancellable *cancel;
guint64 position;
- GInputStream *stream;
+ /* < private > */
+ GInputStream *stream;
GstBuffer *cache;
};
/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <sebastian.droege@collabora.co.uk>
+ * Copyright (C) 2007-2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
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 GOutputStream *gst_gio_sink_get_stream (GstGioBaseSink * base_sink);
static void
gst_gio_sink_base_init (gpointer gclass)
gst_gio_sink_class_init (GstGioSinkClass * klass)
{
GObjectClass *gobject_class = (GObjectClass *) klass;
- GstBaseSinkClass *gstbasesink_class = (GstBaseSinkClass *) klass;
+ GstGioBaseSinkClass *gstgiobasesink_class = (GstGioBaseSinkClass *) klass;
gobject_class->finalize = gst_gio_sink_finalize;
gobject_class->set_property = gst_gio_sink_set_property;
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);
+ gstgiobasesink_class->get_stream =
+ GST_DEBUG_FUNCPTR (gst_gio_sink_get_stream);
}
static void
}
}
-static gboolean
-gst_gio_sink_start (GstBaseSink * base_sink)
+static GOutputStream *
+gst_gio_sink_get_stream (GstGioBaseSink * bsink)
{
- GstGioSink *sink = GST_GIO_SINK (base_sink);
+ GstGioSink *sink = GST_GIO_SINK (bsink);
GOutputStream *stream;
GCancellable *cancel = GST_GIO_BASE_SINK (sink)->cancel;
GError *err = NULL;
if (sink->file == NULL) {
GST_ELEMENT_ERROR (sink, RESOURCE, OPEN_WRITE, (NULL),
("No location or GFile given"));
- return FALSE;
+ return NULL;
}
uri = g_file_get_uri (sink->file);
g_clear_error (&err);
}
g_free (uri);
- return FALSE;
+ return NULL;
}
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);
+ return stream;
}
/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <slomo@circular-chaos.org>
+ * Copyright (C) 2007-2009 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
/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <sebastian.droege@collabora.co.uk>
+ * Copyright (C) 2007-2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
const GValue * value, GParamSpec * pspec);
static void gst_gio_stream_sink_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec);
+static GOutputStream *gst_gio_stream_sink_get_stream (GstGioBaseSink * bsink);
static void
gst_gio_stream_sink_base_init (gpointer gclass)
gst_gio_stream_sink_class_init (GstGioStreamSinkClass * klass)
{
GObjectClass *gobject_class = (GObjectClass *) klass;
+ GstGioBaseSinkClass *ggbsink_class = (GstGioBaseSinkClass *) klass;
gobject_class->finalize = gst_gio_stream_sink_finalize;
gobject_class->set_property = gst_gio_stream_sink_set_property;
g_object_class_install_property (gobject_class, PROP_STREAM,
g_param_spec_object ("stream", "Stream", "Stream to write to",
G_TYPE_OUTPUT_STREAM, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+
+ ggbsink_class->get_stream =
+ GST_DEBUG_FUNCPTR (gst_gio_stream_sink_get_stream);
}
static void
static void
gst_gio_stream_sink_finalize (GObject * object)
{
+ GstGioStreamSink *sink = GST_GIO_STREAM_SINK (object);
+
+ if (sink->stream) {
+ g_object_unref (sink->stream);
+ sink->stream = NULL;
+ }
+
GST_CALL_PARENT (G_OBJECT_CLASS, finalize, (object));
}
}
stream = g_value_dup_object (value);
- if (G_IS_OUTPUT_STREAM (stream))
- gst_gio_base_sink_set_stream (GST_GIO_BASE_SINK (sink),
- G_OUTPUT_STREAM (stream));
-
+ if (sink->stream)
+ g_object_unref (sink->stream);
+ sink->stream = G_OUTPUT_STREAM (stream);
break;
}
default:
break;
}
}
+
+static GOutputStream *
+gst_gio_stream_sink_get_stream (GstGioBaseSink * bsink)
+{
+ GstGioStreamSink *sink = GST_GIO_STREAM_SINK (bsink);
+
+ return (sink->stream) ? g_object_ref (sink->stream) : NULL;
+}
/* GStreamer
*
* Copyright (C) 2007 Rene Stadler <mail@renestadler.de>
- * Copyright (C) 2007 Sebastian Dröge <slomo@circular-chaos.org>
+ * Copyright (C) 2007-2009 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
struct _GstGioStreamSink
{
GstGioBaseSink sink;
+
+ /* < private > */
+ GOutputStream *stream;
};
struct _GstGioStreamSinkClass