-/* GStreamer
- *
+/* GStreamer data:// uri source element
* Copyright (C) 2009 Igalia S.L
* Copyright (C) 2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
*
*
* 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.
+ * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
+ * Boston, MA 02110-1301, USA.
*/
/**
* <refsect2>
* <title>Example launch line</title>
* |[
- * gst-launch-0.10 -v dataurisrc uri="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAAAfElEQVQ4je2MwQnAIAxFgziA4EnczIsO4MEROo/gzZWc4xdTbe1R6LGRR74heYS7iKElzfcMiRnt4hf8gk8EayB6luefue/HzlJfCA50XsNjYRxprZmenXNIKSGEsC+QUqK1hhgj521BzhnWWiilUGvdF5RS4L2HMQZCCJy8sHMm2TYdJAAAAABJRU5ErkJggg==" ! pngdec ! ffmpegcolorspace ! freeze ! ffmpegcolorspace ! autovideosink
+ * gst-launch-1.0 -v dataurisrc uri="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAAAfElEQVQ4je2MwQnAIAxFgziA4EnczIsO4MEROo/gzZWc4xdTbe1R6LGRR74heYS7iKElzfcMiRnt4hf8gk8EayB6luefue/HzlJfCA50XsNjYRxprZmenXNIKSGEsC+QUqK1hhgj521BzhnWWiilUGvdF5RS4L2HMQZCCJy8sHMm2TYdJAAAAABJRU5ErkJggg==" ! pngdec ! videoconvert ! imagefreeze ! videoconvert ! autovideosink
* ]| This pipeline displays a small 16x16 PNG image from the data URI.
* </refsect2>
*/
static void gst_data_uri_src_get_property (GObject * object,
guint prop_id, GValue * value, GParamSpec * pspec);
-static GstCaps *gst_data_uri_src_get_caps (GstBaseSrc * src);
+static GstCaps *gst_data_uri_src_get_caps (GstBaseSrc * src, GstCaps * filter);
static gboolean gst_data_uri_src_get_size (GstBaseSrc * src, guint64 * size);
static gboolean gst_data_uri_src_is_seekable (GstBaseSrc * src);
static GstFlowReturn gst_data_uri_src_create (GstBaseSrc * src, guint64 offset,
guint size, GstBuffer ** buf);
-static gboolean gst_data_uri_src_check_get_range (GstBaseSrc * src);
static gboolean gst_data_uri_src_start (GstBaseSrc * src);
static void gst_data_uri_src_handler_init (gpointer g_iface,
gpointer iface_data);
-static GstURIType gst_data_uri_src_get_uri_type (void);
-static gchar **gst_data_uri_src_get_protocols (void);
-static const gchar *gst_data_uri_src_get_uri (GstURIHandler * handler);
+static GstURIType gst_data_uri_src_get_uri_type (GType type);
+static const gchar *const *gst_data_uri_src_get_protocols (GType type);
+static gchar *gst_data_uri_src_get_uri (GstURIHandler * handler);
static gboolean gst_data_uri_src_set_uri (GstURIHandler * handler,
- const gchar * uri);
-
-static void
-_do_init (GType gtype)
-{
- static const GInterfaceInfo urihandler_info = {
- gst_data_uri_src_handler_init,
- 0, 0
- };
-
- GST_DEBUG_CATEGORY_INIT (data_uri_src_debug, "dataurisrc", 0,
- "data: URI source");
- g_type_add_interface_static (gtype, GST_TYPE_URI_HANDLER, &urihandler_info);
-}
-
-GST_BOILERPLATE_FULL (GstDataURISrc, gst_data_uri_src, GstBaseSrc,
- GST_TYPE_BASE_SRC, _do_init);
-
-static void
-gst_data_uri_src_base_init (gpointer klass)
-{
- GstElementClass *element_class = (GstElementClass *) (klass);
+ const gchar * uri, GError ** error);
- gst_element_class_add_pad_template (element_class,
- gst_static_pad_template_get (&src_template));
- gst_element_class_set_details_simple (element_class,
- "data: URI source element", "Source", "Handles data: uris",
- "Philippe Normand <pnormand@igalia.com>, "
- "Sebastian Dröge <sebastian.droege@collabora.co.uk>");
-}
+#define gst_data_uri_src_parent_class parent_class
+G_DEFINE_TYPE_WITH_CODE (GstDataURISrc, gst_data_uri_src, GST_TYPE_BASE_SRC,
+ G_IMPLEMENT_INTERFACE (GST_TYPE_URI_HANDLER,
+ gst_data_uri_src_handler_init));
static void
gst_data_uri_src_class_init (GstDataURISrcClass * klass)
{
GObjectClass *gobject_class = (GObjectClass *) klass;
+ GstElementClass *element_class = (GstElementClass *) klass;
GstBaseSrcClass *basesrc_class = (GstBaseSrcClass *) klass;
gobject_class->finalize = gst_data_uri_src_finalize;
"URI that should be used",
NULL, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+ gst_element_class_add_static_pad_template (element_class, &src_template);
+ gst_element_class_set_static_metadata (element_class,
+ "data: URI source element", "Source", "Handles data: uris",
+ "Philippe Normand <pnormand@igalia.com>, "
+ "Sebastian Dröge <sebastian.droege@collabora.co.uk>");
+
+ GST_DEBUG_CATEGORY_INIT (data_uri_src_debug, "dataurisrc", 0,
+ "data: URI source");
+
basesrc_class->get_caps = GST_DEBUG_FUNCPTR (gst_data_uri_src_get_caps);
basesrc_class->get_size = GST_DEBUG_FUNCPTR (gst_data_uri_src_get_size);
basesrc_class->is_seekable = GST_DEBUG_FUNCPTR (gst_data_uri_src_is_seekable);
basesrc_class->create = GST_DEBUG_FUNCPTR (gst_data_uri_src_create);
- basesrc_class->check_get_range =
- GST_DEBUG_FUNCPTR (gst_data_uri_src_check_get_range);
basesrc_class->start = GST_DEBUG_FUNCPTR (gst_data_uri_src_start);
}
static void
-gst_data_uri_src_init (GstDataURISrc * src, GstDataURISrcClass * g_class)
+gst_data_uri_src_init (GstDataURISrc * src)
{
- gst_base_src_set_format (GST_BASE_SRC (src), GST_FORMAT_BYTES);
}
static void
switch (prop_id) {
case PROP_URI:
gst_data_uri_src_set_uri (GST_URI_HANDLER (src),
- g_value_get_string (value));
+ g_value_get_string (value), NULL);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
switch (prop_id) {
case PROP_URI:
- g_value_set_string (value,
+ g_value_take_string (value,
gst_data_uri_src_get_uri (GST_URI_HANDLER (src)));
break;
default:
}
static GstCaps *
-gst_data_uri_src_get_caps (GstBaseSrc * basesrc)
+gst_data_uri_src_get_caps (GstBaseSrc * basesrc, GstCaps * filter)
{
GstDataURISrc *src = GST_DATA_URI_SRC (basesrc);
GstCaps *caps;
GST_OBJECT_LOCK (src);
- if (!src->buffer || !GST_BUFFER_CAPS (src->buffer))
- caps = gst_caps_new_empty ();
- else
- caps = gst_buffer_get_caps (src->buffer);
+ caps = gst_pad_get_current_caps (GST_BASE_SRC_PAD (basesrc));
+ if (!caps)
+ caps = gst_caps_new_any ();
GST_OBJECT_UNLOCK (src);
return caps;
*size = -1;
} else {
ret = TRUE;
- *size = GST_BUFFER_SIZE (src->buffer);
+ *size = gst_buffer_get_size (src->buffer);
}
GST_OBJECT_UNLOCK (src);
/* This is only correct because GstBaseSrc already clips size for us to be no
* larger than the max. available size if a segment at the end is requested */
- if (offset + size > GST_BUFFER_SIZE (src->buffer)) {
- ret = GST_FLOW_UNEXPECTED;
+ if (offset + size > gst_buffer_get_size (src->buffer)) {
+ ret = GST_FLOW_EOS;
+ } else if (*buf != NULL) {
+ GstMapInfo src_info;
+ GstMapInfo dest_info;
+ gsize fill_size;
+
+ gst_buffer_map (src->buffer, &src_info, GST_MAP_READ);
+ gst_buffer_map (*buf, &dest_info, GST_MAP_WRITE);
+
+ fill_size = gst_buffer_fill (*buf, 0, src_info.data + offset, size);
+
+ gst_buffer_unmap (*buf, &dest_info);
+ gst_buffer_unmap (src->buffer, &src_info);
+ gst_buffer_set_size (*buf, fill_size);
+ ret = GST_FLOW_OK;
} else {
+ *buf =
+ gst_buffer_copy_region (src->buffer, GST_BUFFER_COPY_ALL, offset, size);
ret = GST_FLOW_OK;
- *buf = gst_buffer_create_sub (src->buffer, offset, size);
- gst_buffer_set_caps (*buf, GST_BUFFER_CAPS (src->buffer));
}
-
GST_OBJECT_UNLOCK (src);
return ret;
}
static gboolean
-gst_data_uri_src_check_get_range (GstBaseSrc * basesrc)
-{
- return TRUE;
-}
-
-static gboolean
gst_data_uri_src_start (GstBaseSrc * basesrc)
{
GstDataURISrc *src = GST_DATA_URI_SRC (basesrc);
}
}
-static void
-gst_data_uri_src_handler_init (gpointer g_iface, gpointer iface_data)
-{
- GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface;
-
- iface->get_type = gst_data_uri_src_get_uri_type;
- iface->get_protocols = gst_data_uri_src_get_protocols;
- iface->get_uri = gst_data_uri_src_get_uri;
- iface->set_uri = gst_data_uri_src_set_uri;
-}
-
static GstURIType
-gst_data_uri_src_get_uri_type (void)
+gst_data_uri_src_get_uri_type (GType type)
{
return GST_URI_SRC;
}
-static gchar **
-gst_data_uri_src_get_protocols (void)
+static const gchar *const *
+gst_data_uri_src_get_protocols (GType type)
{
- static gchar *protocols[] = { (char *) "data", 0 };
+ static const gchar *protocols[] = { "data", 0 };
return protocols;
}
-static const gchar *
+static gchar *
gst_data_uri_src_get_uri (GstURIHandler * handler)
{
GstDataURISrc *src = GST_DATA_URI_SRC (handler);
+ gchar *src_uri = NULL;
- return src->uri;
+ GST_OBJECT_LOCK (src);
+ src_uri = g_strdup (src->uri);
+ GST_OBJECT_UNLOCK (src);
+ return src_uri;
}
static gboolean
-gst_data_uri_src_set_uri (GstURIHandler * handler, const gchar * uri)
+gst_data_uri_src_set_uri (GstURIHandler * handler, const gchar * uri,
+ GError ** error)
{
GstDataURISrc *src = GST_DATA_URI_SRC (handler);
gboolean ret = FALSE;
const gchar *data_start;
const gchar *orig_uri = uri;
GstCaps *caps;
+ GstBuffer *buffer;
gboolean base64 = FALSE;
gchar *charset = NULL;
+ gpointer bdata;
+ gsize bsize;
GST_OBJECT_LOCK (src);
if (GST_STATE (src) >= GST_STATE_PAUSED)
goto wrong_state;
+ GST_OBJECT_UNLOCK (src);
/* uri must be an URI as defined in RFC 2397
* data:[<mediatype>][;base64],<data>
/* Skip comma */
data_start += 1;
if (base64) {
- gsize bsize;
-
- src->buffer = gst_buffer_new ();
- GST_BUFFER_DATA (src->buffer) =
- (guint8 *) g_base64_decode (data_start, &bsize);
- GST_BUFFER_MALLOCDATA (src->buffer) = GST_BUFFER_DATA (src->buffer);
- GST_BUFFER_SIZE (src->buffer) = bsize;
+ bdata = g_base64_decode (data_start, &bsize);
} else {
- gchar *data;
-
/* URI encoded, i.e. "percent" encoding */
- data = g_uri_unescape_string (data_start, NULL);
- if (data == NULL)
+ bdata = g_uri_unescape_string (data_start, NULL);
+ if (bdata == NULL)
goto invalid_uri_encoded_data;
-
- src->buffer = gst_buffer_new ();
- GST_BUFFER_DATA (src->buffer) = (guint8 *) data;
- GST_BUFFER_MALLOCDATA (src->buffer) = GST_BUFFER_DATA (src->buffer);
- GST_BUFFER_SIZE (src->buffer) = strlen (data) + 1;
+ bsize = strlen (bdata) + 1;
}
-
/* Convert to UTF8 */
if (strcmp ("text/plain", mimetype) == 0 &&
- charset && strcasecmp ("US-ASCII", charset) != 0
- && strcasecmp ("UTF-8", charset) != 0) {
+ charset && g_ascii_strcasecmp ("US-ASCII", charset) != 0
+ && g_ascii_strcasecmp ("UTF-8", charset) != 0) {
gsize read;
gsize written;
- gchar *old_data = (gchar *) GST_BUFFER_DATA (src->buffer);
- gchar *data;
+ gpointer data;
data =
- g_convert_with_fallback (old_data, -1, "UTF-8", charset, (char *) "*",
+ g_convert_with_fallback (bdata, -1, "UTF-8", charset, (char *) "*",
&read, &written, NULL);
- g_free (old_data);
- GST_BUFFER_DATA (src->buffer) = GST_BUFFER_MALLOCDATA (src->buffer) =
- (guint8 *) data;
- GST_BUFFER_SIZE (src->buffer) = written;
+ g_free (bdata);
+
+ bdata = data;
+ bsize = written;
}
+ buffer = gst_buffer_new_wrapped (bdata, bsize);
- caps = gst_type_find_helper_for_buffer (GST_OBJECT (src), src->buffer, NULL);
+ caps = gst_type_find_helper_for_buffer (GST_OBJECT (src), buffer, NULL);
if (!caps)
- caps = gst_caps_new_simple (mimetype, NULL);
- gst_buffer_set_caps (src->buffer, caps);
+ caps = gst_caps_new_empty_simple (mimetype);
+ gst_base_src_set_caps (GST_BASE_SRC_CAST (src), caps);
gst_caps_unref (caps);
+ GST_OBJECT_LOCK (src);
+ gst_buffer_replace (&src->buffer, buffer);
+ gst_buffer_unref (buffer);
g_free (src->uri);
src->uri = g_strdup (orig_uri);
+ GST_OBJECT_UNLOCK (src);
ret = TRUE;
out:
- GST_OBJECT_UNLOCK (src);
-
g_free (mimetype);
g_free (charset);
return ret;
-invalid_uri:
- {
- GST_WARNING_OBJECT (src, "invalid URI '%s'", uri);
- goto out;
- }
wrong_state:
{
GST_WARNING_OBJECT (src, "Can't set URI in %s state",
gst_element_state_get_name (GST_STATE (src)));
+ GST_OBJECT_UNLOCK (src);
+ g_set_error (error, GST_URI_ERROR, GST_URI_ERROR_BAD_STATE,
+ "Changing the 'uri' property on dataurisrc while it is running "
+ "is not supported");
+ goto out;
+ }
+invalid_uri:
+ {
+ GST_WARNING_OBJECT (src, "invalid URI '%s'", uri);
+ g_set_error (error, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
+ "Invalid data URI");
goto out;
}
invalid_uri_encoded_data:
{
GST_WARNING_OBJECT (src, "Failed to parse data encoded in URI '%s'", uri);
+ g_set_error (error, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
+ "Could not parse data encoded in data URI");
goto out;
}
}
-static gboolean
-plugin_init (GstPlugin * plugin)
+static void
+gst_data_uri_src_handler_init (gpointer g_iface, gpointer iface_data)
{
- return gst_element_register (plugin, "dataurisrc",
- GST_RANK_PRIMARY, GST_TYPE_DATA_URI_SRC);
-}
+ GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface;
-GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
- GST_VERSION_MINOR,
- "dataurisrc",
- "data: URI source",
- plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN);
+ iface->get_type = gst_data_uri_src_get_uri_type;
+ iface->get_protocols = gst_data_uri_src_get_protocols;
+ iface->get_uri = gst_data_uri_src_get_uri;
+ iface->set_uri = gst_data_uri_src_set_uri;
+}
projects / platform / upstream / gstreamer.git / blobdiff