ext/vorbis/gstvorbisdec.c

   1 /* GStreamer
   2  * Copyright (C) 2004 Benjamin Otte <in7y118@public.uni-hamburg.de>
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Library General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Library General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Library General Public
  15  * License along with this library; if not, write to the
  16  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  17  * Boston, MA 02111-1307, USA.
  18  */
  19
  20 /**
  21  * SECTION:element-vorbisdec
  22  * @see_also: vorbisenc, oggdemux
  23  *
  24  * This element decodes a Vorbis stream to raw float audio.
  25  * <ulink url="http://www.vorbis.com/">Vorbis</ulink> is a royalty-free
  26  * audio codec maintained by the <ulink url="http://www.xiph.org/">Xiph.org
  27  * Foundation</ulink>.
  28  *
  29  * <refsect2>
  30  * <title>Example pipelines</title>
  31  * |[
  32  * gst-launch -v filesrc location=sine.ogg ! oggdemux ! vorbisdec ! audioconvert ! alsasink
  33  * ]| Decode an Ogg/Vorbis. To create an Ogg/Vorbis file refer to the documentation of vorbisenc.
  34  * </refsect2>
  35  *
  36  * Last reviewed on 2006-03-01 (0.10.4)
  37  */
  38
  39 #ifdef HAVE_CONFIG_H
  40 #  include "config.h"
  41 #endif
  42
  43 #include "gstvorbisdec.h"
  44 #include <string.h>
  45 #include <gst/audio/audio.h>
  46 #include <gst/tag/tag.h>
  47 #include <gst/audio/multichannel.h>
  48
  49 #include "gstvorbiscommon.h"
  50
  51 GST_DEBUG_CATEGORY_EXTERN (vorbisdec_debug);
  52 #define GST_CAT_DEFAULT vorbisdec_debug
  53
  54 static GstStaticPadTemplate vorbis_dec_src_factory =
  55 GST_STATIC_PAD_TEMPLATE ("src",
  56     GST_PAD_SRC,
  57     GST_PAD_ALWAYS,
  58     GST_VORBIS_DEC_SRC_CAPS);
  59
  60 static GstStaticPadTemplate vorbis_dec_sink_factory =
  61 GST_STATIC_PAD_TEMPLATE ("sink",
  62     GST_PAD_SINK,
  63     GST_PAD_ALWAYS,
  64     GST_STATIC_CAPS ("audio/x-vorbis")
  65     );
  66
  67 GST_BOILERPLATE (GST_VORBIS_DEC_GLIB_TYPE_NAME, gst_vorbis_dec, GstElement,
  68     GST_TYPE_ELEMENT);
  69
  70 static void vorbis_dec_finalize (GObject * object);
  71 static gboolean vorbis_dec_sink_event (GstPad * pad, GstEvent * event);
  72 static GstFlowReturn vorbis_dec_chain (GstPad * pad, GstBuffer * buffer);
  73 static GstFlowReturn vorbis_dec_chain_forward (GstVorbisDec * vd,
  74     gboolean discont, GstBuffer * buffer);
  75 static GstFlowReturn vorbis_dec_chain_reverse (GstVorbisDec * vd,
  76     gboolean discont, GstBuffer * buf);
  77 static GstStateChangeReturn vorbis_dec_change_state (GstElement * element,
  78     GstStateChange transition);
  79
  80 static gboolean vorbis_dec_src_event (GstPad * pad, GstEvent * event);
  81 static gboolean vorbis_dec_src_query (GstPad * pad, GstQuery * query);
  82 static gboolean vorbis_dec_convert (GstPad * pad,
  83     GstFormat src_format, gint64 src_value,
  84     GstFormat * dest_format, gint64 * dest_value);
  85
  86 static gboolean vorbis_dec_sink_query (GstPad * pad, GstQuery * query);
  87
  88 static void
  89 gst_vorbis_dec_base_init (gpointer g_class)
  90 {
  91   GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
  92   GstPadTemplate *src_template, *sink_template;
  93
  94   src_template = gst_static_pad_template_get (&vorbis_dec_src_factory);
  95   gst_element_class_add_pad_template (element_class, src_template);
  96
  97   sink_template = gst_static_pad_template_get (&vorbis_dec_sink_factory);
  98   gst_element_class_add_pad_template (element_class, sink_template);
  99
 100   gst_element_class_set_details_simple (element_class,
 101       "Vorbis audio decoder", "Codec/Decoder/Audio",
 102       GST_VORBIS_DEC_DESCRIPTION,
 103       "Benjamin Otte <otte@gnome.org>, Chris Lord <chris@openedhand.com>");
 104 }
 105
 106 static void
 107 gst_vorbis_dec_class_init (GstVorbisDecClass * klass)
 108 {
 109   GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
 110   GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
 111
 112   gobject_class->finalize = vorbis_dec_finalize;
 113
 114   gstelement_class->change_state = GST_DEBUG_FUNCPTR (vorbis_dec_change_state);
 115 }
 116
 117 static const GstQueryType *
 118 vorbis_get_query_types (GstPad * pad)
 119 {
 120   static const GstQueryType vorbis_dec_src_query_types[] = {
 121     GST_QUERY_POSITION,
 122     GST_QUERY_DURATION,
 123     GST_QUERY_CONVERT,
 124     0
 125   };
 126
 127   return vorbis_dec_src_query_types;
 128 }
 129
 130 static void
 131 gst_vorbis_dec_init (GstVorbisDec * dec, GstVorbisDecClass * g_class)
 132 {
 133   dec->sinkpad = gst_pad_new_from_static_template (&vorbis_dec_sink_factory,
 134       "sink");
 135
 136   gst_pad_set_event_function (dec->sinkpad,
 137       GST_DEBUG_FUNCPTR (vorbis_dec_sink_event));
 138   gst_pad_set_chain_function (dec->sinkpad,
 139       GST_DEBUG_FUNCPTR (vorbis_dec_chain));
 140   gst_pad_set_query_function (dec->sinkpad,
 141       GST_DEBUG_FUNCPTR (vorbis_dec_sink_query));
 142   gst_element_add_pad (GST_ELEMENT (dec), dec->sinkpad);
 143
 144   dec->srcpad = gst_pad_new_from_static_template (&vorbis_dec_src_factory,
 145       "src");
 146
 147   gst_pad_set_event_function (dec->srcpad,
 148       GST_DEBUG_FUNCPTR (vorbis_dec_src_event));
 149   gst_pad_set_query_type_function (dec->srcpad,
 150       GST_DEBUG_FUNCPTR (vorbis_get_query_types));
 151   gst_pad_set_query_function (dec->srcpad,
 152       GST_DEBUG_FUNCPTR (vorbis_dec_src_query));
 153   gst_pad_use_fixed_caps (dec->srcpad);
 154   gst_element_add_pad (GST_ELEMENT (dec), dec->srcpad);
 155
 156   dec->queued = NULL;
 157   dec->pendingevents = NULL;
 158   dec->taglist = NULL;
 159 }
 160
 161 static void
 162 vorbis_dec_finalize (GObject * object)
 163 {
 164   /* Release any possibly allocated libvorbis data.
 165    * _clear functions can safely be called multiple times
 166    */
 167   GstVorbisDec *vd = GST_VORBIS_DEC (object);
 168
 169 #ifndef USE_TREMOLO
 170   vorbis_block_clear (&vd->vb);
 171 #endif
 172
 173   vorbis_dsp_clear (&vd->vd);
 174   vorbis_comment_clear (&vd->vc);
 175   vorbis_info_clear (&vd->vi);
 176
 177   G_OBJECT_CLASS (parent_class)->finalize (object);
 178 }
 179
 180 static void
 181 gst_vorbis_dec_reset (GstVorbisDec * dec)
 182 {
 183   dec->last_timestamp = GST_CLOCK_TIME_NONE;
 184   dec->discont = TRUE;
 185   dec->seqnum = gst_util_seqnum_next ();
 186   gst_segment_init (&dec->segment, GST_FORMAT_TIME);
 187
 188   g_list_foreach (dec->queued, (GFunc) gst_mini_object_unref, NULL);
 189   g_list_free (dec->queued);
 190   dec->queued = NULL;
 191   g_list_foreach (dec->gather, (GFunc) gst_mini_object_unref, NULL);
 192   g_list_free (dec->gather);
 193   dec->gather = NULL;
 194   g_list_foreach (dec->decode, (GFunc) gst_mini_object_unref, NULL);
 195   g_list_free (dec->decode);
 196   dec->decode = NULL;
 197   g_list_foreach (dec->pendingevents, (GFunc) gst_mini_object_unref, NULL);
 198   g_list_free (dec->pendingevents);
 199   dec->pendingevents = NULL;
 200
 201   if (dec->taglist)
 202     gst_tag_list_free (dec->taglist);
 203   dec->taglist = NULL;
 204 }
 205
 206
 207 static gboolean
 208 vorbis_dec_convert (GstPad * pad,
 209     GstFormat src_format, gint64 src_value,
 210     GstFormat * dest_format, gint64 * dest_value)
 211 {
 212   gboolean res = TRUE;
 213   GstVorbisDec *dec;
 214   guint64 scale = 1;
 215
 216   if (src_format == *dest_format) {
 217     *dest_value = src_value;
 218     return TRUE;
 219   }
 220
 221   dec = GST_VORBIS_DEC (gst_pad_get_parent (pad));
 222
 223   if (!dec->initialized)
 224     goto no_header;
 225
 226   if (dec->sinkpad == pad &&
 227       (src_format == GST_FORMAT_BYTES || *dest_format == GST_FORMAT_BYTES))
 228     goto no_format;
 229
 230   switch (src_format) {
 231     case GST_FORMAT_TIME:
 232       switch (*dest_format) {
 233         case GST_FORMAT_BYTES:
 234           scale = dec->width * dec->vi.channels;
 235         case GST_FORMAT_DEFAULT:
 236           *dest_value =
 237               scale * gst_util_uint64_scale_int (src_value, dec->vi.rate,
 238               GST_SECOND);
 239           break;
 240         default:
 241           res = FALSE;
 242       }
 243       break;
 244     case GST_FORMAT_DEFAULT:
 245       switch (*dest_format) {
 246         case GST_FORMAT_BYTES:
 247           *dest_value = src_value * dec->width * dec->vi.channels;
 248           break;
 249         case GST_FORMAT_TIME:
 250           *dest_value =
 251               gst_util_uint64_scale_int (src_value, GST_SECOND, dec->vi.rate);
 252           break;
 253         default:
 254           res = FALSE;
 255       }
 256       break;
 257     case GST_FORMAT_BYTES:
 258       switch (*dest_format) {
 259         case GST_FORMAT_DEFAULT:
 260           *dest_value = src_value / (dec->width * dec->vi.channels);
 261           break;
 262         case GST_FORMAT_TIME:
 263           *dest_value = gst_util_uint64_scale_int (src_value, GST_SECOND,
 264               dec->vi.rate * dec->width * dec->vi.channels);
 265           break;
 266         default:
 267           res = FALSE;
 268       }
 269       break;
 270     default:
 271       res = FALSE;
 272   }
 273 done:
 274   gst_object_unref (dec);
 275
 276   return res;
 277
 278   /* ERRORS */
 279 no_header:
 280   {
 281     GST_DEBUG_OBJECT (dec, "no header packets received");
 282     res = FALSE;
 283     goto done;
 284   }
 285 no_format:
 286   {
 287     GST_DEBUG_OBJECT (dec, "formats unsupported");
 288     res = FALSE;
 289     goto done;
 290   }
 291 }
 292
 293 static gboolean
 294 vorbis_dec_src_query (GstPad * pad, GstQuery * query)
 295 {
 296   GstVorbisDec *dec;
 297   gboolean res = FALSE;
 298
 299   dec = GST_VORBIS_DEC (gst_pad_get_parent (pad));
 300   if (G_UNLIKELY (dec == NULL))
 301     return FALSE;
 302
 303   switch (GST_QUERY_TYPE (query)) {
 304     case GST_QUERY_POSITION:
 305     {
 306       gint64 value;
 307       GstFormat format;
 308       gint64 time;
 309
 310       gst_query_parse_position (query, &format, NULL);
 311
 312       /* we start from the last seen time */
 313       time = dec->last_timestamp;
 314       /* correct for the segment values */
 315       time = gst_segment_to_stream_time (&dec->segment, GST_FORMAT_TIME, time);
 316
 317       GST_LOG_OBJECT (dec,
 318           "query %p: our time: %" GST_TIME_FORMAT, query, GST_TIME_ARGS (time));
 319
 320       /* and convert to the final format */
 321       if (!(res =
 322               vorbis_dec_convert (pad, GST_FORMAT_TIME, time, &format, &value)))
 323         goto error;
 324
 325       gst_query_set_position (query, format, value);
 326
 327       GST_LOG_OBJECT (dec,
 328           "query %p: we return %" G_GINT64_FORMAT " (format %u)", query, value,
 329           format);
 330
 331       break;
 332     }
 333     case GST_QUERY_DURATION:
 334     {
 335       res = gst_pad_peer_query (dec->sinkpad, query);
 336       if (!res)
 337         goto error;
 338
 339       break;
 340     }
 341     case GST_QUERY_CONVERT:
 342     {
 343       GstFormat src_fmt, dest_fmt;
 344       gint64 src_val, dest_val;
 345
 346       gst_query_parse_convert (query, &src_fmt, &src_val, &dest_fmt, &dest_val);
 347       if (!(res =
 348               vorbis_dec_convert (pad, src_fmt, src_val, &dest_fmt, &dest_val)))
 349         goto error;
 350       gst_query_set_convert (query, src_fmt, src_val, dest_fmt, dest_val);
 351       break;
 352     }
 353     default:
 354       res = gst_pad_query_default (pad, query);
 355       break;
 356   }
 357 done:
 358   gst_object_unref (dec);
 359
 360   return res;
 361
 362   /* ERRORS */
 363 error:
 364   {
 365     GST_WARNING_OBJECT (dec, "error handling query");
 366     goto done;
 367   }
 368 }
 369
 370 static gboolean
 371 vorbis_dec_sink_query (GstPad * pad, GstQuery * query)
 372 {
 373   GstVorbisDec *dec;
 374   gboolean res;
 375
 376   dec = GST_VORBIS_DEC (gst_pad_get_parent (pad));
 377
 378   switch (GST_QUERY_TYPE (query)) {
 379     case GST_QUERY_CONVERT:
 380     {
 381       GstFormat src_fmt, dest_fmt;
 382       gint64 src_val, dest_val;
 383
 384       gst_query_parse_convert (query, &src_fmt, &src_val, &dest_fmt, &dest_val);
 385       if (!(res =
 386               vorbis_dec_convert (pad, src_fmt, src_val, &dest_fmt, &dest_val)))
 387         goto error;
 388       gst_query_set_convert (query, src_fmt, src_val, dest_fmt, dest_val);
 389       break;
 390     }
 391     default:
 392       res = gst_pad_query_default (pad, query);
 393       break;
 394   }
 395
 396 done:
 397   gst_object_unref (dec);
 398
 399   return res;
 400
 401   /* ERRORS */
 402 error:
 403   {
 404     GST_DEBUG_OBJECT (dec, "error converting value");
 405     goto done;
 406   }
 407 }
 408
 409 static gboolean
 410 vorbis_dec_src_event (GstPad * pad, GstEvent * event)
 411 {
 412   gboolean res = TRUE;
 413   GstVorbisDec *dec;
 414
 415   dec = GST_VORBIS_DEC (gst_pad_get_parent (pad));
 416   if (G_UNLIKELY (dec == NULL)) {
 417     gst_event_unref (event);
 418     return FALSE;
 419   }
 420
 421   switch (GST_EVENT_TYPE (event)) {
 422     case GST_EVENT_SEEK:
 423     {
 424       GstFormat format, tformat;
 425       gdouble rate;
 426       GstEvent *real_seek;
 427       GstSeekFlags flags;
 428       GstSeekType cur_type, stop_type;
 429       gint64 cur, stop;
 430       gint64 tcur, tstop;
 431       guint32 seqnum;
 432
 433       gst_event_parse_seek (event, &rate, &format, &flags, &cur_type, &cur,
 434           &stop_type, &stop);
 435       seqnum = gst_event_get_seqnum (event);
 436       gst_event_unref (event);
 437
 438       /* First bring the requested format to time */
 439       tformat = GST_FORMAT_TIME;
 440       if (!(res = vorbis_dec_convert (pad, format, cur, &tformat, &tcur)))
 441         goto convert_error;
 442       if (!(res = vorbis_dec_convert (pad, format, stop, &tformat, &tstop)))
 443         goto convert_error;
 444
 445       /* then seek with time on the peer */
 446       real_seek = gst_event_new_seek (rate, GST_FORMAT_TIME,
 447           flags, cur_type, tcur, stop_type, tstop);
 448       gst_event_set_seqnum (real_seek, seqnum);
 449
 450       res = gst_pad_push_event (dec->sinkpad, real_seek);
 451       break;
 452     }
 453     default:
 454       res = gst_pad_push_event (dec->sinkpad, event);
 455       break;
 456   }
 457 done:
 458   gst_object_unref (dec);
 459
 460   return res;
 461
 462   /* ERRORS */
 463 convert_error:
 464   {
 465     GST_DEBUG_OBJECT (dec, "cannot convert start/stop for seek");
 466     goto done;
 467   }
 468 }
 469
 470 static gboolean
 471 vorbis_dec_sink_event (GstPad * pad, GstEvent * event)
 472 {
 473   gboolean ret = FALSE;
 474   GstVorbisDec *dec;
 475
 476   dec = GST_VORBIS_DEC (gst_pad_get_parent (pad));
 477
 478   GST_LOG_OBJECT (dec, "handling event");
 479   switch (GST_EVENT_TYPE (event)) {
 480     case GST_EVENT_EOS:
 481       if (dec->segment.rate < 0.0)
 482         vorbis_dec_chain_reverse (dec, TRUE, NULL);
 483       ret = gst_pad_push_event (dec->srcpad, event);
 484       break;
 485     case GST_EVENT_FLUSH_START:
 486       ret = gst_pad_push_event (dec->srcpad, event);
 487       break;
 488     case GST_EVENT_FLUSH_STOP:
 489       /* here we must clean any state in the decoder */
 490 #ifdef HAVE_VORBIS_SYNTHESIS_RESTART
 491       vorbis_synthesis_restart (&dec->vd);
 492 #endif
 493       gst_vorbis_dec_reset (dec);
 494       ret = gst_pad_push_event (dec->srcpad, event);
 495       break;
 496     case GST_EVENT_NEWSEGMENT:
 497     {
 498       GstFormat format;
 499       gdouble rate, arate;
 500       gint64 start, stop, time;
 501       gboolean update;
 502
 503       gst_event_parse_new_segment_full (event, &update, &rate, &arate, &format,
 504           &start, &stop, &time);
 505
 506       /* we need time for now */
 507       if (format != GST_FORMAT_TIME)
 508         goto newseg_wrong_format;
 509
 510       GST_DEBUG_OBJECT (dec,
 511           "newsegment: update %d, rate %g, arate %g, start %" GST_TIME_FORMAT
 512           ", stop %" GST_TIME_FORMAT ", time %" GST_TIME_FORMAT,
 513           update, rate, arate, GST_TIME_ARGS (start), GST_TIME_ARGS (stop),
 514           GST_TIME_ARGS (time));
 515
 516       /* now configure the values */
 517       gst_segment_set_newsegment_full (&dec->segment, update,
 518           rate, arate, format, start, stop, time);
 519       dec->seqnum = gst_event_get_seqnum (event);
 520
 521       if (dec->initialized)
 522         /* and forward */
 523         ret = gst_pad_push_event (dec->srcpad, event);
 524       else {
 525         /* store it to send once we're initialized */
 526         dec->pendingevents = g_list_append (dec->pendingevents, event);
 527         ret = TRUE;
 528       }
 529       break;
 530     }
 531     case GST_EVENT_TAG:
 532     {
 533       if (dec->initialized)
 534         /* and forward */
 535         ret = gst_pad_push_event (dec->srcpad, event);
 536       else {
 537         /* store it to send once we're initialized */
 538         dec->pendingevents = g_list_append (dec->pendingevents, event);
 539         ret = TRUE;
 540       }
 541       break;
 542     }
 543     default:
 544       ret = gst_pad_push_event (dec->srcpad, event);
 545       break;
 546   }
 547 done:
 548   gst_object_unref (dec);
 549
 550   return ret;
 551
 552   /* ERRORS */
 553 newseg_wrong_format:
 554   {
 555     GST_DEBUG_OBJECT (dec, "received non TIME newsegment");
 556     goto done;
 557   }
 558 }
 559
 560 static GstFlowReturn
 561 vorbis_handle_identification_packet (GstVorbisDec * vd)
 562 {
 563   GstCaps *caps;
 564   const GstAudioChannelPosition *pos = NULL;
 565   gint width = GST_VORBIS_DEC_DEFAULT_SAMPLE_WIDTH;
 566
 567   switch (vd->vi.channels) {
 568     case 1:
 569     case 2:
 570       /* nothing */
 571       break;
 572     case 3:
 573     case 4:
 574     case 5:
 575     case 6:
 576     case 7:
 577     case 8:
 578       pos = gst_vorbis_channel_positions[vd->vi.channels - 1];
 579       break;
 580     default:{
 581       gint i;
 582       GstAudioChannelPosition *posn =
 583           g_new (GstAudioChannelPosition, vd->vi.channels);
 584
 585       GST_ELEMENT_WARNING (GST_ELEMENT (vd), STREAM, DECODE,
 586           (NULL), ("Using NONE channel layout for more than 8 channels"));
 587
 588       for (i = 0; i < vd->vi.channels; i++)
 589         posn[i] = GST_AUDIO_CHANNEL_POSITION_NONE;
 590
 591       pos = posn;
 592     }
 593   }
 594
 595   /* negotiate width with downstream */
 596   caps = gst_pad_get_allowed_caps (vd->srcpad);
 597   if (caps) {
 598     if (!gst_caps_is_empty (caps)) {
 599       GstStructure *s;
 600
 601       s = gst_caps_get_structure (caps, 0);
 602       /* template ensures 16 or 32 */
 603       gst_structure_get_int (s, "width", &width);
 604
 605       GST_INFO_OBJECT (vd, "using %s with %d channels and %d bit audio depth",
 606           gst_structure_get_name (s), vd->vi.channels, width);
 607     }
 608     gst_caps_unref (caps);
 609   }
 610   vd->width = width >> 3;
 611
 612   /* select a copy_samples function, this way we can have specialized versions
 613    * for mono/stereo and avoid the depth switch in tremor case */
 614   vd->copy_samples = get_copy_sample_func (vd->vi.channels, vd->width);
 615
 616   caps = gst_caps_copy (gst_pad_get_pad_template_caps (vd->srcpad));
 617   gst_caps_set_simple (caps, "rate", G_TYPE_INT, vd->vi.rate,
 618       "channels", G_TYPE_INT, vd->vi.channels,
 619       "width", G_TYPE_INT, width, NULL);
 620
 621   if (pos) {
 622     gst_audio_set_channel_positions (gst_caps_get_structure (caps, 0), pos);
 623   }
 624
 625   if (vd->vi.channels > 8) {
 626     g_free ((GstAudioChannelPosition *) pos);
 627   }
 628
 629   gst_pad_set_caps (vd->srcpad, caps);
 630   gst_caps_unref (caps);
 631
 632   return GST_FLOW_OK;
 633 }
 634
 635 static GstFlowReturn
 636 vorbis_handle_comment_packet (GstVorbisDec * vd, ogg_packet * packet)
 637 {
 638   guint bitrate = 0;
 639   gchar *encoder = NULL;
 640   GstTagList *list, *old_list;
 641   GstBuffer *buf;
 642
 643   GST_DEBUG_OBJECT (vd, "parsing comment packet");
 644
 645   buf = gst_buffer_new ();
 646   GST_BUFFER_DATA (buf) = gst_ogg_packet_data (packet);
 647   GST_BUFFER_SIZE (buf) = gst_ogg_packet_size (packet);
 648
 649   list =
 650       gst_tag_list_from_vorbiscomment_buffer (buf, (guint8 *) "\003vorbis", 7,
 651       &encoder);
 652
 653   old_list = vd->taglist;
 654   vd->taglist = gst_tag_list_merge (vd->taglist, list, GST_TAG_MERGE_REPLACE);
 655
 656   if (old_list)
 657     gst_tag_list_free (old_list);
 658   gst_tag_list_free (list);
 659   gst_buffer_unref (buf);
 660
 661   if (!vd->taglist) {
 662     GST_ERROR_OBJECT (vd, "couldn't decode comments");
 663     vd->taglist = gst_tag_list_new ();
 664   }
 665   if (encoder) {
 666     if (encoder[0])
 667       gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 668           GST_TAG_ENCODER, encoder, NULL);
 669     g_free (encoder);
 670   }
 671   gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 672       GST_TAG_ENCODER_VERSION, vd->vi.version,
 673       GST_TAG_AUDIO_CODEC, "Vorbis", NULL);
 674   if (vd->vi.bitrate_nominal > 0 && vd->vi.bitrate_nominal <= 0x7FFFFFFF) {
 675     gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 676         GST_TAG_NOMINAL_BITRATE, (guint) vd->vi.bitrate_nominal, NULL);
 677     bitrate = vd->vi.bitrate_nominal;
 678   }
 679   if (vd->vi.bitrate_upper > 0 && vd->vi.bitrate_upper <= 0x7FFFFFFF) {
 680     gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 681         GST_TAG_MAXIMUM_BITRATE, (guint) vd->vi.bitrate_upper, NULL);
 682     if (!bitrate)
 683       bitrate = vd->vi.bitrate_upper;
 684   }
 685   if (vd->vi.bitrate_lower > 0 && vd->vi.bitrate_lower <= 0x7FFFFFFF) {
 686     gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 687         GST_TAG_MINIMUM_BITRATE, (guint) vd->vi.bitrate_lower, NULL);
 688     if (!bitrate)
 689       bitrate = vd->vi.bitrate_lower;
 690   }
 691   if (bitrate) {
 692     gst_tag_list_add (vd->taglist, GST_TAG_MERGE_REPLACE,
 693         GST_TAG_BITRATE, (guint) bitrate, NULL);
 694   }
 695
 696   if (vd->initialized) {
 697     gst_element_found_tags_for_pad (GST_ELEMENT_CAST (vd), vd->srcpad,
 698         vd->taglist);
 699     vd->taglist = NULL;
 700   } else {
 701     /* Only post them as messages for the time being. *
 702      * They will be pushed on the pad once the decoder is initialized */
 703     gst_element_post_message (GST_ELEMENT_CAST (vd),
 704         gst_message_new_tag (GST_OBJECT (vd), gst_tag_list_copy (vd->taglist)));
 705   }
 706
 707   return GST_FLOW_OK;
 708 }
 709
 710 static GstFlowReturn
 711 vorbis_handle_type_packet (GstVorbisDec * vd)
 712 {
 713   GList *walk;
 714   gint res;
 715
 716   g_assert (vd->initialized == FALSE);
 717
 718 #ifdef USE_TREMOLO
 719   if (G_UNLIKELY ((res = vorbis_dsp_init (&vd->vd, &vd->vi))))
 720     goto synthesis_init_error;
 721 #else
 722   if (G_UNLIKELY ((res = vorbis_synthesis_init (&vd->vd, &vd->vi))))
 723     goto synthesis_init_error;
 724
 725   if (G_UNLIKELY ((res = vorbis_block_init (&vd->vd, &vd->vb))))
 726     goto block_init_error;
 727 #endif
 728
 729   vd->initialized = TRUE;
 730
 731   if (vd->pendingevents) {
 732     for (walk = vd->pendingevents; walk; walk = g_list_next (walk))
 733       gst_pad_push_event (vd->srcpad, GST_EVENT_CAST (walk->data));
 734     g_list_free (vd->pendingevents);
 735     vd->pendingevents = NULL;
 736   }
 737
 738   if (vd->taglist) {
 739     /* The tags have already been sent on the bus as messages. */
 740     gst_pad_push_event (vd->srcpad, gst_event_new_tag (vd->taglist));
 741     vd->taglist = NULL;
 742   }
 743   return GST_FLOW_OK;
 744
 745   /* ERRORS */
 746 synthesis_init_error:
 747   {
 748     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 749         (NULL), ("couldn't initialize synthesis (%d)", res));
 750     return GST_FLOW_ERROR;
 751   }
 752 block_init_error:
 753   {
 754     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 755         (NULL), ("couldn't initialize block (%d)", res));
 756     return GST_FLOW_ERROR;
 757   }
 758 }
 759
 760 static GstFlowReturn
 761 vorbis_handle_header_packet (GstVorbisDec * vd, ogg_packet * packet)
 762 {
 763   GstFlowReturn res;
 764   gint ret;
 765
 766   GST_DEBUG_OBJECT (vd, "parsing header packet");
 767
 768   /* Packetno = 0 if the first byte is exactly 0x01 */
 769   packet->b_o_s = ((gst_ogg_packet_data (packet))[0] == 0x1) ? 1 : 0;
 770
 771 #ifdef USE_TREMOLO
 772   if ((ret = vorbis_dsp_headerin (&vd->vi, &vd->vc, packet)))
 773 #else
 774   if ((ret = vorbis_synthesis_headerin (&vd->vi, &vd->vc, packet)))
 775 #endif
 776     goto header_read_error;
 777
 778   switch ((gst_ogg_packet_data (packet))[0]) {
 779     case 0x01:
 780       res = vorbis_handle_identification_packet (vd);
 781       break;
 782     case 0x03:
 783       res = vorbis_handle_comment_packet (vd, packet);
 784       break;
 785     case 0x05:
 786       res = vorbis_handle_type_packet (vd);
 787       break;
 788     default:
 789       /* ignore */
 790       g_warning ("unknown vorbis header packet found");
 791       res = GST_FLOW_OK;
 792       break;
 793   }
 794   return res;
 795
 796   /* ERRORS */
 797 header_read_error:
 798   {
 799     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 800         (NULL), ("couldn't read header packet (%d)", ret));
 801     return GST_FLOW_ERROR;
 802   }
 803 }
 804
 805 static GstFlowReturn
 806 vorbis_dec_push_forward (GstVorbisDec * dec, GstBuffer * buf)
 807 {
 808   GstFlowReturn result;
 809
 810   /* clip */
 811   if (!(buf = gst_audio_buffer_clip (buf, &dec->segment, dec->vi.rate,
 812               dec->vi.channels * dec->width))) {
 813     GST_LOG_OBJECT (dec, "clipped buffer");
 814     return GST_FLOW_OK;
 815   }
 816
 817   if (dec->discont) {
 818     GST_LOG_OBJECT (dec, "setting DISCONT");
 819     GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DISCONT);
 820     dec->discont = FALSE;
 821   }
 822
 823   GST_DEBUG_OBJECT (dec,
 824       "pushing time %" GST_TIME_FORMAT ", dur %" GST_TIME_FORMAT,
 825       GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)),
 826       GST_TIME_ARGS (GST_BUFFER_DURATION (buf)));
 827
 828   result = gst_pad_push (dec->srcpad, buf);
 829
 830   return result;
 831 }
 832
 833 static GstFlowReturn
 834 vorbis_dec_push_reverse (GstVorbisDec * dec, GstBuffer * buf)
 835 {
 836   GstFlowReturn result = GST_FLOW_OK;
 837
 838   dec->queued = g_list_prepend (dec->queued, buf);
 839
 840   return result;
 841 }
 842
 843 static void
 844 vorbis_do_timestamps (GstVorbisDec * vd, GstBuffer * buf, gboolean reverse,
 845     GstClockTime timestamp, GstClockTime duration)
 846 {
 847   /* interpolate reverse */
 848   if (vd->last_timestamp != -1 && duration != -1 && reverse)
 849     vd->last_timestamp -= duration;
 850
 851   /* take buffer timestamp, use interpolated timestamp otherwise */
 852   if (timestamp != -1)
 853     vd->last_timestamp = timestamp;
 854   else
 855     timestamp = vd->last_timestamp;
 856
 857   /* interpolate forwards */
 858   if (vd->last_timestamp != -1 && duration != -1 && !reverse)
 859     vd->last_timestamp += duration;
 860
 861   GST_LOG_OBJECT (vd,
 862       "keeping timestamp %" GST_TIME_FORMAT " ts %" GST_TIME_FORMAT " dur %"
 863       GST_TIME_FORMAT, GST_TIME_ARGS (vd->last_timestamp),
 864       GST_TIME_ARGS (timestamp), GST_TIME_ARGS (duration));
 865
 866   if (buf) {
 867     GST_BUFFER_TIMESTAMP (buf) = timestamp;
 868     GST_BUFFER_DURATION (buf) = duration;
 869   }
 870 }
 871
 872 static GstFlowReturn
 873 vorbis_handle_data_packet (GstVorbisDec * vd, ogg_packet * packet,
 874     GstClockTime timestamp, GstClockTime duration)
 875 {
 876 #ifdef USE_TREMOLO
 877   vorbis_sample_t *pcm;
 878 #else
 879   vorbis_sample_t **pcm;
 880 #endif
 881   guint sample_count;
 882   GstBuffer *out = NULL;
 883   GstFlowReturn result;
 884   gint size;
 885
 886   if (G_UNLIKELY (!vd->initialized))
 887     goto not_initialized;
 888
 889   /* normal data packet */
 890   /* FIXME, we can skip decoding if the packet is outside of the
 891    * segment, this is however not very trivial as we need a previous
 892    * packet to decode the current one so we must be carefull not to
 893    * throw away too much. For now we decode everything and clip right
 894    * before pushing data. */
 895
 896 #ifdef USE_TREMOLO
 897   if (G_UNLIKELY (vorbis_dsp_synthesis (&vd->vd, packet, 1)))
 898     goto could_not_read;
 899 #else
 900   if (G_UNLIKELY (vorbis_synthesis (&vd->vb, packet)))
 901     goto could_not_read;
 902
 903   if (G_UNLIKELY (vorbis_synthesis_blockin (&vd->vd, &vd->vb) < 0))
 904     goto not_accepted;
 905 #endif
 906
 907   /* assume all goes well here */
 908   result = GST_FLOW_OK;
 909
 910   /* count samples ready for reading */
 911 #ifdef USE_TREMOLO
 912   if ((sample_count = vorbis_dsp_pcmout (&vd->vd, NULL, 0)) == 0)
 913 #else
 914   if ((sample_count = vorbis_synthesis_pcmout (&vd->vd, NULL)) == 0)
 915 #endif
 916     goto done;
 917
 918   size = sample_count * vd->vi.channels * vd->width;
 919   GST_LOG_OBJECT (vd, "%d samples ready for reading, size %d", sample_count,
 920       size);
 921
 922   /* alloc buffer for it */
 923   result =
 924       gst_pad_alloc_buffer_and_set_caps (vd->srcpad, GST_BUFFER_OFFSET_NONE,
 925       size, GST_PAD_CAPS (vd->srcpad), &out);
 926   if (G_UNLIKELY (result != GST_FLOW_OK))
 927     goto done;
 928
 929   /* get samples ready for reading now, should be sample_count */
 930 #ifdef USE_TREMOLO
 931   pcm = GST_BUFFER_DATA (out);
 932   if (G_UNLIKELY ((vorbis_dsp_pcmout (&vd->vd, pcm,
 933                   sample_count)) != sample_count))
 934 #else
 935   if (G_UNLIKELY ((vorbis_synthesis_pcmout (&vd->vd, &pcm)) != sample_count))
 936 #endif
 937     goto wrong_samples;
 938
 939 #ifndef USE_TREMOLO
 940   /* copy samples in buffer */
 941   vd->copy_samples ((vorbis_sample_t *) GST_BUFFER_DATA (out), pcm,
 942       sample_count, vd->vi.channels, vd->width);
 943 #endif
 944
 945   GST_LOG_OBJECT (vd, "setting output size to %d", size);
 946   GST_BUFFER_SIZE (out) = size;
 947
 948   /* this should not overflow */
 949   if (duration == -1)
 950     duration = sample_count * GST_SECOND / vd->vi.rate;
 951
 952   vorbis_do_timestamps (vd, out, FALSE, timestamp, duration);
 953
 954   if (vd->segment.rate >= 0.0)
 955     result = vorbis_dec_push_forward (vd, out);
 956   else
 957     result = vorbis_dec_push_reverse (vd, out);
 958
 959 done:
 960   if (out == NULL) {
 961     /* no output, still keep track of timestamps */
 962     vorbis_do_timestamps (vd, NULL, FALSE, timestamp, duration);
 963   }
 964 #ifdef USE_TREMOLO
 965   vorbis_dsp_read (&vd->vd, sample_count);
 966 #else
 967   vorbis_synthesis_read (&vd->vd, sample_count);
 968 #endif
 969
 970   return result;
 971
 972   /* ERRORS */
 973 not_initialized:
 974   {
 975     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 976         (NULL), ("no header sent yet"));
 977     return GST_FLOW_ERROR;
 978   }
 979 could_not_read:
 980   {
 981     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 982         (NULL), ("couldn't read data packet"));
 983     return GST_FLOW_ERROR;
 984   }
 985 not_accepted:
 986   {
 987     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 988         (NULL), ("vorbis decoder did not accept data packet"));
 989     return GST_FLOW_ERROR;
 990   }
 991 wrong_samples:
 992   {
 993     gst_buffer_unref (out);
 994     GST_ELEMENT_ERROR (GST_ELEMENT (vd), STREAM, DECODE,
 995         (NULL), ("vorbis decoder reported wrong number of samples"));
 996     return GST_FLOW_ERROR;
 997   }
 998 }
 999
1000 static GstFlowReturn
1001 vorbis_dec_handle_header_buffer (GstVorbisDec * vd, GstBuffer * buffer)
1002 {
1003   ogg_packet *packet;
1004   ogg_packet_wrapper packet_wrapper;
1005
1006   gst_ogg_packet_wrapper_from_buffer (&packet_wrapper, buffer);
1007   packet = gst_ogg_packet_from_wrapper (&packet_wrapper);
1008
1009   return vorbis_handle_header_packet (vd, packet);
1010 }
1011
1012
1013 #define MIN_NUM_HEADERS 3
1014 static GstFlowReturn
1015 vorbis_dec_handle_header_caps (GstVorbisDec * vd, GstBuffer * buffer)
1016 {
1017   GstFlowReturn result = GST_FLOW_OK;
1018   GstCaps *caps = GST_PAD_CAPS (vd->sinkpad);
1019   GstStructure *s = gst_caps_get_structure (caps, 0);
1020   const GValue *array = gst_structure_get_value (s, "streamheader");
1021
1022   if (array && (gst_value_array_get_size (array) >= MIN_NUM_HEADERS)) {
1023     const GValue *value = NULL;
1024     GstBuffer *buf = NULL;
1025
1026     /* initial header */
1027     value = gst_value_array_get_value (array, 0);
1028     buf = gst_value_get_buffer (value);
1029     if (!buf)
1030       goto null_buffer;
1031     result = vorbis_dec_handle_header_buffer (vd, buf);
1032
1033     /* comment header */
1034     if (result == GST_FLOW_OK) {
1035       value = gst_value_array_get_value (array, 1);
1036       buf = gst_value_get_buffer (value);
1037       if (!buf)
1038         goto null_buffer;
1039       result = vorbis_dec_handle_header_buffer (vd, buf);
1040     }
1041
1042     /* bitstream codebook header */
1043     if (result == GST_FLOW_OK) {
1044       value = gst_value_array_get_value (array, 2);
1045       buf = gst_value_get_buffer (value);
1046       if (!buf)
1047         goto null_buffer;
1048       result = vorbis_dec_handle_header_buffer (vd, buf);
1049     }
1050   } else
1051     goto array_error;
1052
1053 done:
1054   return (result != GST_FLOW_OK ? GST_FLOW_NOT_NEGOTIATED : GST_FLOW_OK);
1055
1056 array_error:
1057   {
1058     GST_WARNING_OBJECT (vd, "streamheader array not found");
1059     result = GST_FLOW_ERROR;
1060     goto done;
1061   }
1062
1063 null_buffer:
1064   {
1065     GST_WARNING_OBJECT (vd, "streamheader with null buffer received");
1066     result = GST_FLOW_ERROR;
1067     goto done;
1068   }
1069 }
1070
1071 static GstFlowReturn
1072 vorbis_dec_decode_buffer (GstVorbisDec * vd, GstBuffer * buffer)
1073 {
1074   ogg_packet *packet;
1075   ogg_packet_wrapper packet_wrapper;
1076   GstFlowReturn result = GST_FLOW_OK;
1077
1078   /* make ogg_packet out of the buffer */
1079   gst_ogg_packet_wrapper_from_buffer (&packet_wrapper, buffer);
1080   packet = gst_ogg_packet_from_wrapper (&packet_wrapper);
1081   /* set some more stuff */
1082   packet->granulepos = -1;
1083   packet->packetno = 0;         /* we don't care */
1084   /* EOS does not matter, it is used in vorbis to implement clipping the last
1085    * block of samples based on the granulepos. We clip based on segments. */
1086   packet->e_o_s = 0;
1087
1088   GST_LOG_OBJECT (vd, "decode buffer of size %ld", packet->bytes);
1089
1090   /* error out on empty header packets, but just skip empty data packets */
1091   if (G_UNLIKELY (packet->bytes == 0)) {
1092     if (vd->initialized)
1093       goto empty_buffer;
1094     else
1095       goto empty_header;
1096   }
1097
1098   /* switch depending on packet type */
1099   if ((gst_ogg_packet_data (packet))[0] & 1) {
1100     if (vd->initialized) {
1101       GST_WARNING_OBJECT (vd, "Already initialized, so ignoring header packet");
1102       goto done;
1103     }
1104     result = vorbis_handle_header_packet (vd, packet);
1105   } else {
1106     GstClockTime timestamp, duration;
1107
1108     /* try to find header in caps so we can initialize the decoder */
1109     if (!vd->initialized) {
1110       result = vorbis_dec_handle_header_caps (vd, buffer);
1111       if (result != GST_FLOW_OK)
1112         goto invalid_caps_header;
1113     }
1114
1115     timestamp = GST_BUFFER_TIMESTAMP (buffer);
1116     duration = GST_BUFFER_DURATION (buffer);
1117
1118     result = vorbis_handle_data_packet (vd, packet, timestamp, duration);
1119   }
1120
1121 done:
1122   return result;
1123
1124 empty_buffer:
1125   {
1126     /* don't error out here, just ignore the buffer, it's invalid for vorbis
1127      * but not fatal. */
1128     GST_WARNING_OBJECT (vd, "empty buffer received, ignoring");
1129     result = GST_FLOW_OK;
1130     goto done;
1131   }
1132
1133 /* ERRORS */
1134 empty_header:
1135   {
1136     GST_ELEMENT_ERROR (vd, STREAM, DECODE, (NULL), ("empty header received"));
1137     result = GST_FLOW_ERROR;
1138     vd->discont = TRUE;
1139     goto done;
1140   }
1141
1142 invalid_caps_header:
1143   {
1144     GST_ELEMENT_ERROR (vd, STREAM, DECODE, (NULL),
1145         ("invalid streamheader in caps"));
1146     goto done;
1147   }
1148 }
1149
1150 /*
1151  * Input:
1152  *  Buffer decoding order:  7  8  9  4  5  6  3  1  2  EOS
1153  *  Discont flag:           D        D        D  D
1154  *
1155  * - Each Discont marks a discont in the decoding order.
1156  *
1157  * for vorbis, each buffer is a keyframe when we have the previous
1158  * buffer. This means that to decode buffer 7, we need buffer 6, which
1159  * arrives out of order.
1160  *
1161  * we first gather buffers in the gather queue until we get a DISCONT. We
1162  * prepend each incomming buffer so that they are in reversed order.
1163  *
1164  *    gather queue:    9  8  7
1165  *    decode queue:
1166  *    output queue:
1167  *
1168  * When a DISCONT is received (buffer 4), we move the gather queue to the
1169  * decode queue. This is simply done be taking the head of the gather queue
1170  * and prepending it to the decode queue. This yields:
1171  *
1172  *    gather queue:
1173  *    decode queue:    7  8  9
1174  *    output queue:
1175  *
1176  * Then we decode each buffer in the decode queue in order and put the output
1177  * buffer in the output queue. The first buffer (7) will not produce any output
1178  * because it needs the previous buffer (6) which did not arrive yet. This
1179  * yields:
1180  *
1181  *    gather queue:
1182  *    decode queue:    7  8  9
1183  *    output queue:    9  8
1184  *
1185  * Then we remove the consumed buffers from the decode queue. Buffer 7 is not
1186  * completely consumed, we need to keep it around for when we receive buffer
1187  * 6. This yields:
1188  *
1189  *    gather queue:
1190  *    decode queue:    7
1191  *    output queue:    9  8
1192  *
1193  * Then we accumulate more buffers:
1194  *
1195  *    gather queue:    6  5  4
1196  *    decode queue:    7
1197  *    output queue:
1198  *
1199  * prepending to the decode queue on DISCONT yields:
1200  *
1201  *    gather queue:
1202  *    decode queue:    4  5  6  7
1203  *    output queue:
1204  *
1205  * after decoding and keeping buffer 4:
1206  *
1207  *    gather queue:
1208  *    decode queue:    4
1209  *    output queue:    7  6  5
1210  *
1211  * Etc..
1212  */
1213 static GstFlowReturn
1214 vorbis_dec_flush_decode (GstVorbisDec * dec)
1215 {
1216   GstFlowReturn res = GST_FLOW_OK;
1217   GList *walk;
1218
1219   walk = dec->decode;
1220
1221   GST_DEBUG_OBJECT (dec, "flushing buffers to decoder");
1222
1223   while (walk) {
1224     GList *next;
1225     GstBuffer *buf = GST_BUFFER_CAST (walk->data);
1226
1227     GST_DEBUG_OBJECT (dec, "decoding buffer %p, ts %" GST_TIME_FORMAT,
1228         buf, GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)));
1229
1230     next = g_list_next (walk);
1231
1232     /* decode buffer, prepend to output queue */
1233     res = vorbis_dec_decode_buffer (dec, buf);
1234
1235     /* if we generated output, we can discard the buffer, else we
1236      * keep it in the queue */
1237     if (dec->queued) {
1238       GST_DEBUG_OBJECT (dec, "decoded buffer to %p", dec->queued->data);
1239       dec->decode = g_list_delete_link (dec->decode, walk);
1240       gst_buffer_unref (buf);
1241     } else {
1242       GST_DEBUG_OBJECT (dec, "buffer did not decode, keeping");
1243     }
1244     walk = next;
1245   }
1246   while (dec->queued) {
1247     GstBuffer *buf = GST_BUFFER_CAST (dec->queued->data);
1248     GstClockTime timestamp, duration;
1249
1250     timestamp = GST_BUFFER_TIMESTAMP (buf);
1251     duration = GST_BUFFER_DURATION (buf);
1252
1253     vorbis_do_timestamps (dec, buf, TRUE, timestamp, duration);
1254     res = vorbis_dec_push_forward (dec, buf);
1255
1256     dec->queued = g_list_delete_link (dec->queued, dec->queued);
1257   }
1258   return res;
1259 }
1260
1261 static GstFlowReturn
1262 vorbis_dec_chain_reverse (GstVorbisDec * vd, gboolean discont, GstBuffer * buf)
1263 {
1264   GstFlowReturn result = GST_FLOW_OK;
1265
1266   /* if we have a discont, move buffers to the decode list */
1267   if (G_UNLIKELY (discont)) {
1268     GST_DEBUG_OBJECT (vd, "received discont");
1269     while (vd->gather) {
1270       GstBuffer *gbuf;
1271
1272       gbuf = GST_BUFFER_CAST (vd->gather->data);
1273       /* remove from the gather list */
1274       vd->gather = g_list_delete_link (vd->gather, vd->gather);
1275       /* copy to decode queue */
1276       vd->decode = g_list_prepend (vd->decode, gbuf);
1277     }
1278     /* flush and decode the decode queue */
1279     result = vorbis_dec_flush_decode (vd);
1280   }
1281
1282   if (G_LIKELY (buf)) {
1283     GST_DEBUG_OBJECT (vd,
1284         "gathering buffer %p of size %u, time %" GST_TIME_FORMAT
1285         ", dur %" GST_TIME_FORMAT, buf, GST_BUFFER_SIZE (buf),
1286         GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)),
1287         GST_TIME_ARGS (GST_BUFFER_DURATION (buf)));
1288
1289     /* add buffer to gather queue */
1290     vd->gather = g_list_prepend (vd->gather, buf);
1291   }
1292
1293   return result;
1294 }
1295
1296 static GstFlowReturn
1297 vorbis_dec_chain_forward (GstVorbisDec * vd, gboolean discont,
1298     GstBuffer * buffer)
1299 {
1300   GstFlowReturn result;
1301
1302   result = vorbis_dec_decode_buffer (vd, buffer);
1303
1304   gst_buffer_unref (buffer);
1305
1306   return result;
1307 }
1308
1309 static GstFlowReturn
1310 vorbis_dec_chain (GstPad * pad, GstBuffer * buffer)
1311 {
1312   GstVorbisDec *vd;
1313   GstFlowReturn result = GST_FLOW_OK;
1314   gboolean discont;
1315
1316   vd = GST_VORBIS_DEC (gst_pad_get_parent (pad));
1317
1318   discont = GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_DISCONT);
1319
1320   /* resync on DISCONT */
1321   if (G_UNLIKELY (discont)) {
1322     GST_DEBUG_OBJECT (vd, "received DISCONT buffer");
1323     vd->last_timestamp = GST_CLOCK_TIME_NONE;
1324 #ifdef HAVE_VORBIS_SYNTHESIS_RESTART
1325     vorbis_synthesis_restart (&vd->vd);
1326 #endif
1327     vd->discont = TRUE;
1328   }
1329
1330   if (vd->segment.rate >= 0.0)
1331     result = vorbis_dec_chain_forward (vd, discont, buffer);
1332   else
1333     result = vorbis_dec_chain_reverse (vd, discont, buffer);
1334
1335   gst_object_unref (vd);
1336
1337   return result;
1338 }
1339
1340 static GstStateChangeReturn
1341 vorbis_dec_change_state (GstElement * element, GstStateChange transition)
1342 {
1343   GstVorbisDec *vd = GST_VORBIS_DEC (element);
1344   GstStateChangeReturn res;
1345
1346   switch (transition) {
1347     case GST_STATE_CHANGE_NULL_TO_READY:
1348       break;
1349     case GST_STATE_CHANGE_READY_TO_PAUSED:
1350       vorbis_info_init (&vd->vi);
1351       vorbis_comment_init (&vd->vc);
1352       vd->initialized = FALSE;
1353       gst_vorbis_dec_reset (vd);
1354       break;
1355     case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
1356       break;
1357     default:
1358       break;
1359   }
1360
1361   res = parent_class->change_state (element, transition);
1362
1363   switch (transition) {
1364     case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
1365       break;
1366     case GST_STATE_CHANGE_PAUSED_TO_READY:
1367       GST_DEBUG_OBJECT (vd, "PAUSED -> READY, clearing vorbis structures");
1368       vd->initialized = FALSE;
1369
1370 #ifndef USE_TREMOLO
1371       vorbis_block_clear (&vd->vb);
1372 #endif
1373
1374       vorbis_dsp_clear (&vd->vd);
1375       vorbis_comment_clear (&vd->vc);
1376       vorbis_info_clear (&vd->vi);
1377       gst_vorbis_dec_reset (vd);
1378       break;
1379     case GST_STATE_CHANGE_READY_TO_NULL:
1380       break;
1381     default:
1382       break;
1383   }
1384
1385   return res;
1386 }