3 * Copyright 2005 Thomas Vander Stichele <thomas@apestaart.org>
4 * Copyright 2005 Ronald S. Bultje <rbultje@ronald.bitfreak.net>
5 * Copyright 2008, 2009 Vincent Penquerc'h <ogg.k.ogg.k@googlemail.com>
7 * Permission is hereby granted, free of charge, to any person obtaining a
8 * copy of this software and associated documentation files (the "Software"),
9 * to deal in the Software without restriction, including without limitation
10 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
11 * and/or sell copies of the Software, and to permit persons to whom the
12 * Software is furnished to do so, subject to the following conditions:
14 * The above copyright notice and this permission notice shall be included in
15 * all copies or substantial portions of the Software.
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
20 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
22 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
23 * DEALINGS IN THE SOFTWARE.
25 * Alternatively, the contents of this file may be used under the
26 * GNU Lesser General Public License Version 2.1 (the "LGPL"), in
27 * which case the following provisions apply instead of the ones
30 * This library is free software; you can redistribute it and/or
31 * modify it under the terms of the GNU Library General Public
32 * License as published by the Free Software Foundation; either
33 * version 2 of the License, or (at your option) any later version.
35 * This library is distributed in the hope that it will be useful,
36 * but WITHOUT ANY WARRANTY; without even the implied warranty of
37 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
38 * Library General Public License for more details.
40 * You should have received a copy of the GNU Library General Public
41 * License along with this library; if not, write to the
42 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
43 * Boston, MA 02110-1301, USA.
47 * SECTION:element-katedec
51 * This element decodes Kate streams.
53 * [Kate](http://libkate.googlecode.com/) is a free codec
54 * for text based data, such as subtitles. Any number of kate streams can be
55 * embedded in an Ogg stream.
57 * libkate (see above url) is needed to build this plugin.
61 * This explicitely decodes a Kate stream:
63 * gst-launch-1.0 filesrc location=test.ogg ! oggdemux ! katedec ! fakesink silent=TRUE
66 * This will automatically detect and use any Kate streams multiplexed
69 * gst-launch-1.0 playbin uri=file:///tmp/test.ogg
83 #include "gstkatespu.h"
84 #include "gstkatedec.h"
86 GST_DEBUG_CATEGORY_EXTERN (gst_katedec_debug);
87 #define GST_CAT_DEFAULT gst_katedec_debug
89 /* Filter signals and args */
98 ARG_REMOVE_MARKUP = DECODER_BASE_ARG_COUNT
101 /* We don't accept application/x-kate here on purpose for now, since we're
102 * only really interested in subtitle-like things for playback purposes, not
103 * cracktastic complex overlays or presentation images etc. - those should be
104 * fed into a tiger overlay plugin directly */
105 static GstStaticPadTemplate sink_factory = GST_STATIC_PAD_TEMPLATE ("sink",
108 GST_STATIC_CAPS ("subtitle/x-kate")
111 static GstStaticPadTemplate src_factory = GST_STATIC_PAD_TEMPLATE ("src",
114 GST_STATIC_CAPS ("text/x-raw, format = { pango-markup, utf8 }; "
115 GST_KATE_SPU_MIME_TYPE)
118 #define gst_kate_dec_parent_class parent_class
119 G_DEFINE_TYPE (GstKateDec, gst_kate_dec, GST_TYPE_ELEMENT);
121 static void gst_kate_dec_set_property (GObject * object, guint prop_id,
122 const GValue * value, GParamSpec * pspec);
123 static void gst_kate_dec_get_property (GObject * object, guint prop_id,
124 GValue * value, GParamSpec * pspec);
126 static GstFlowReturn gst_kate_dec_chain (GstPad * pad, GstObject * parent,
128 static GstStateChangeReturn gst_kate_dec_change_state (GstElement * element,
129 GstStateChange transition);
130 static gboolean gst_kate_dec_sink_query (GstPad * pad, GstObject * parent,
132 static gboolean gst_kate_dec_sink_event (GstPad * pad, GstObject * parent,
134 static gboolean gst_kate_dec_sink_handle_event (GstPad * pad,
135 GstObject * parent, GstEvent * event);
136 static gboolean gst_kate_dec_src_query (GstPad * pad, GstObject * parent,
139 /* initialize the plugin's class */
141 gst_kate_dec_class_init (GstKateDecClass * klass)
143 GObjectClass *gobject_class;
144 GstElementClass *gstelement_class;
146 gobject_class = (GObjectClass *) klass;
147 gstelement_class = (GstElementClass *) klass;
149 gobject_class->set_property = gst_kate_dec_set_property;
150 gobject_class->get_property = gst_kate_dec_get_property;
152 gst_kate_util_install_decoder_base_properties (gobject_class);
154 g_object_class_install_property (gobject_class, ARG_REMOVE_MARKUP,
155 g_param_spec_boolean ("remove-markup", "Remove markup",
156 "Remove markup from decoded text ?", FALSE,
157 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
159 gstelement_class->change_state =
160 GST_DEBUG_FUNCPTR (gst_kate_dec_change_state);
162 gst_element_class_add_static_pad_template (gstelement_class, &src_factory);
163 gst_element_class_add_static_pad_template (gstelement_class, &sink_factory);
165 gst_element_class_set_static_metadata (gstelement_class,
166 "Kate stream text decoder", "Codec/Decoder/Subtitle",
167 "Decodes Kate text streams",
168 "Vincent Penquerc'h <ogg.k.ogg.k@googlemail.com>");
171 /* initialize the new element
172 * instantiate pads and add them to element
174 * initialize structure
177 gst_kate_dec_init (GstKateDec * dec)
179 GST_DEBUG_OBJECT (dec, "gst_kate_dec_init");
181 dec->sinkpad = gst_pad_new_from_static_template (&sink_factory, "sink");
182 gst_pad_set_chain_function (dec->sinkpad,
183 GST_DEBUG_FUNCPTR (gst_kate_dec_chain));
184 gst_pad_set_query_function (dec->sinkpad,
185 GST_DEBUG_FUNCPTR (gst_kate_dec_sink_query));
186 gst_pad_set_event_function (dec->sinkpad,
187 GST_DEBUG_FUNCPTR (gst_kate_dec_sink_event));
188 gst_pad_use_fixed_caps (dec->sinkpad);
189 gst_pad_set_caps (dec->sinkpad,
190 gst_static_pad_template_get_caps (&sink_factory));
191 gst_element_add_pad (GST_ELEMENT (dec), dec->sinkpad);
193 dec->srcpad = gst_pad_new_from_static_template (&src_factory, "src");
194 gst_pad_set_query_function (dec->srcpad,
195 GST_DEBUG_FUNCPTR (gst_kate_dec_src_query));
196 gst_element_add_pad (GST_ELEMENT (dec), dec->srcpad);
198 gst_kate_util_decode_base_init (&dec->decoder, TRUE);
200 dec->src_caps = NULL;
201 dec->output_format = GST_KATE_FORMAT_UNDEFINED;
202 dec->remove_markup = FALSE;
206 gst_kate_dec_set_property (GObject * object, guint prop_id,
207 const GValue * value, GParamSpec * pspec)
211 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
217 gst_kate_dec_get_property (GObject * object, guint prop_id,
218 GValue * value, GParamSpec * pspec)
220 GstKateDec *kd = GST_KATE_DEC (object);
223 case ARG_REMOVE_MARKUP:
224 g_value_set_boolean (value, kd->remove_markup);
227 if (!gst_kate_util_decoder_base_get_property (&kd->decoder, object,
228 prop_id, value, pspec)) {
229 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
236 gst_kate_dec_handle_kate_event (GstKateDec * kd, const kate_event * ev)
238 GstFlowReturn rflow = GST_FLOW_OK;
239 GstKateFormat format = GST_KATE_FORMAT_UNDEFINED;
243 gboolean plain = TRUE;
245 if (kd->remove_markup && ev->text_markup_type != kate_markup_none) {
246 size_t len0 = ev->len + 1;
247 escaped = g_strdup (ev->text);
249 kate_text_remove_markup (ev->text_encoding, escaped, &len0);
252 } else if (ev->text_markup_type == kate_markup_none) {
253 /* no pango markup yet, escape text */
254 /* TODO: actually do the pango thing */
255 escaped = g_strdup (ev->text);
258 escaped = g_strdup (ev->text);
262 if (G_LIKELY (escaped)) {
263 len = strlen (escaped);
265 GST_DEBUG_OBJECT (kd, "kate event: %s, escaped %s", ev->text, escaped);
266 buffer = gst_buffer_new_and_alloc (len + 1);
267 if (G_LIKELY (buffer)) {
270 format = GST_KATE_FORMAT_TEXT_UTF8;
272 format = GST_KATE_FORMAT_TEXT_PANGO_MARKUP;
273 if (format != kd->output_format) {
274 caps = gst_caps_new_simple ("text/x-raw", "format", G_TYPE_STRING,
275 (format == GST_KATE_FORMAT_TEXT_UTF8) ? "utf8" : "pango-markup",
277 gst_pad_push_event (kd->srcpad, gst_event_new_caps (caps));
278 gst_caps_unref (caps);
279 kd->output_format = format;
281 /* allocate and copy the NULs, but don't include them in passed size */
282 gst_buffer_fill (buffer, 0, escaped, len + 1);
283 gst_buffer_resize (buffer, 0, len);
284 GST_BUFFER_TIMESTAMP (buffer) = ev->start_time * GST_SECOND;
285 GST_BUFFER_DURATION (buffer) =
286 (ev->end_time - ev->start_time) * GST_SECOND;
287 rflow = gst_pad_push (kd->srcpad, buffer);
288 if (rflow == GST_FLOW_NOT_LINKED) {
289 GST_DEBUG_OBJECT (kd, "source pad not linked, ignored");
290 } else if (rflow != GST_FLOW_OK) {
291 GST_WARNING_OBJECT (kd, "failed to push buffer: %s",
292 gst_flow_get_name (rflow));
295 GST_ELEMENT_ERROR (kd, STREAM, DECODE, (NULL),
296 ("Failed to create buffer"));
297 rflow = GST_FLOW_ERROR;
300 GST_WARNING_OBJECT (kd, "Empty string, nothing to do");
305 GST_ELEMENT_ERROR (kd, STREAM, DECODE, (NULL),
306 ("Failed to allocate string"));
307 rflow = GST_FLOW_ERROR;
310 /* if there's a background paletted bitmap, construct a DVD SPU for it */
311 if (ev->bitmap && ev->palette) {
312 GstBuffer *buffer = gst_kate_spu_encode_spu (kd, ev);
316 GST_BUFFER_TIMESTAMP (buffer) = ev->start_time * GST_SECOND;
317 GST_BUFFER_DURATION (buffer) =
318 (ev->end_time - ev->start_time) * GST_SECOND;
320 if (kd->output_format != GST_KATE_FORMAT_SPU) {
321 caps = gst_caps_new_empty_simple (GST_KATE_SPU_MIME_TYPE);
322 gst_pad_push_event (kd->srcpad, gst_event_new_caps (caps));
323 gst_caps_unref (caps);
324 kd->output_format = GST_KATE_FORMAT_SPU;
327 rflow = gst_pad_push (kd->srcpad, buffer);
328 if (rflow == GST_FLOW_NOT_LINKED) {
329 GST_DEBUG_OBJECT (kd, "source pad not linked, ignored");
330 } else if (rflow != GST_FLOW_OK) {
331 GST_WARNING_OBJECT (kd, "failed to push buffer: %s",
332 gst_flow_get_name (rflow));
335 GST_ELEMENT_ERROR (kd, STREAM, DECODE, (NULL),
336 ("failed to create SPU from paletted bitmap"));
337 rflow = GST_FLOW_ERROR;
343 /* GstElement vmethod implementations */
346 * this function does the actual processing
350 gst_kate_dec_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
352 GstKateDec *kd = GST_KATE_DEC (parent);
353 const kate_event *ev = NULL;
354 GstFlowReturn rflow = GST_FLOW_OK;
356 if (!gst_kate_util_decoder_base_update_segment (&kd->decoder,
357 GST_ELEMENT_CAST (kd), buf)) {
358 GST_WARNING_OBJECT (kd, "Out of segment!");
363 gst_kate_util_decoder_base_chain_kate_packet (&kd->decoder,
364 GST_ELEMENT_CAST (kd), pad, buf, kd->srcpad, kd->srcpad, &kd->src_caps,
366 if (G_UNLIKELY (rflow != GST_FLOW_OK)) {
367 gst_buffer_unref (buf);
372 rflow = gst_kate_dec_handle_kate_event (kd, ev);
376 gst_buffer_unref (buf);
380 static GstStateChangeReturn
381 gst_kate_dec_change_state (GstElement * element, GstStateChange transition)
383 GstStateChangeReturn ret;
384 GstKateDec *kd = GST_KATE_DEC (element);
386 ret = gst_kate_decoder_base_change_state (&kd->decoder, element,
387 parent_class, transition);
389 if (transition == GST_STATE_CHANGE_PAUSED_TO_READY) {
390 gst_caps_replace (&kd->src_caps, NULL);
397 gst_kate_dec_sink_query (GstPad * pad, GstObject * parent, GstQuery * query)
399 GstKateDec *kd = GST_KATE_DEC (parent);
401 gst_kate_decoder_base_sink_query (&kd->decoder, GST_ELEMENT_CAST (kd),
407 gst_kate_dec_set_caps (GstKateDec * kd, GstCaps * caps)
409 GstStructure *structure = gst_caps_get_structure (caps, 0);
410 GstFlowReturn rflow = GST_FLOW_OK;
412 if (gst_structure_has_field (structure, "streamheader")) {
415 const kate_event *ev;
417 value = gst_structure_get_value (structure, "streamheader");
419 if (GST_VALUE_HOLDS_BUFFER (value)) {
420 buf = gst_value_get_buffer (value);
422 gst_kate_util_decoder_base_chain_kate_packet (&kd->decoder,
423 GST_ELEMENT_CAST (kd), kd->sinkpad, buf, kd->srcpad, kd->srcpad,
427 rflow = gst_kate_dec_handle_kate_event (kd, ev);
429 } else if (GST_VALUE_HOLDS_ARRAY (value)) {
430 gint i, size = gst_value_array_get_size (value);
432 for (i = 0; i < size; i++) {
433 const GValue *v = gst_value_array_get_value (value, i);
435 buf = gst_value_get_buffer (v);
436 gst_kate_util_decoder_base_chain_kate_packet (&kd->decoder,
437 GST_ELEMENT_CAST (kd), kd->sinkpad, buf, kd->srcpad, kd->srcpad,
441 rflow = gst_kate_dec_handle_kate_event (kd, ev);
442 if (rflow != GST_FLOW_OK && rflow != GST_FLOW_NOT_LINKED)
447 GST_WARNING_OBJECT (kd, "Unhandled streamheader type: %s",
448 G_VALUE_TYPE_NAME (value));
452 return rflow == GST_FLOW_OK || rflow == GST_FLOW_NOT_LINKED;
456 gst_kate_dec_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
458 GstKateDec *kd = GST_KATE_DEC (parent);
461 GST_LOG_OBJECT (pad, "Event on sink pad: %" GST_PTR_FORMAT, event);
463 switch (GST_EVENT_TYPE (event)) {
464 case GST_EVENT_CAPS:{
467 gst_event_parse_caps (event, &caps);
468 gst_kate_dec_set_caps (kd, caps);
475 /* Delay events till we've set caps */
476 if (gst_kate_util_decoder_base_queue_event (&kd->decoder, event,
477 &gst_kate_dec_sink_handle_event, parent, pad)) {
481 res = gst_kate_dec_sink_handle_event (pad, parent, event);
487 gst_kate_dec_sink_handle_event (GstPad * pad, GstObject * parent,
490 GstKateDec *kd = GST_KATE_DEC (parent);
492 GST_LOG_OBJECT (pad, "Handling event on sink pad: %s",
493 GST_EVENT_TYPE_NAME (event));
495 switch (GST_EVENT_TYPE (event)) {
496 case GST_EVENT_SEGMENT:
499 case GST_EVENT_FLUSH_START:
500 gst_kate_util_decoder_base_set_flushing (&kd->decoder, TRUE);
503 case GST_EVENT_FLUSH_STOP:
504 gst_kate_util_decoder_base_set_flushing (&kd->decoder, FALSE);
509 gst_event_parse_tag (event, &tags);
510 gst_kate_util_decoder_base_add_tags (&kd->decoder, tags, FALSE);
511 gst_event_unref (event);
512 event = gst_kate_util_decoder_base_get_tag_event (&kd->decoder);
519 return gst_pad_event_default (pad, parent, event);
523 gst_kate_dec_src_query (GstPad * pad, GstObject * parent, GstQuery * query)
525 GstKateDec *kd = GST_KATE_DEC (parent);
528 GST_LOG_OBJECT (pad, "Handling query on src pad: %s",
529 GST_QUERY_TYPE_NAME (query));
531 switch (GST_QUERY_TYPE (query)) {
532 case GST_QUERY_CAPS:{
536 GST_DEBUG_OBJECT (kd, "We have src caps %" GST_PTR_FORMAT,
538 caps = gst_caps_copy (kd->src_caps);
540 GST_DEBUG_OBJECT (kd, "We have no src caps, using template caps");
541 caps = gst_static_pad_template_get_caps (&src_factory);
544 gst_query_set_caps_result (query, caps);
545 gst_caps_unref (caps);
549 res = gst_pad_query_default (pad, parent, query);