LCOV - code coverage report
Current view: top level - ext/musepack - gstmusepackdec.c (source / functions) Hit Total Coverage
Test: GStreamer Bad Plug-ins 0.10.21.1 Lines: 61 269 22.7 %
Date: 2011-03-25 Functions: 9 17 52.9 %
Branches: 9 202 4.5 %

           Branch data     Line data    Source code
       1                 :            : /* GStreamer Musepack decoder plugin
       2                 :            :  * Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net>
       3                 :            :  * Copyright (C) 2006 Tim-Philipp Müller <tim centricular net>
       4                 :            :  * Copyright (C) 2008 Sebastian Dröge <slomo@circular-chaos.org>
       5                 :            :  *
       6                 :            :  * This library is free software; you can redistribute it and/or
       7                 :            :  * modify it under the terms of the GNU Library General Public
       8                 :            :  * License as published by the Free Software Foundation; either
       9                 :            :  * version 2 of the License, or (at your option) any later version.
      10                 :            :  *
      11                 :            :  * This library is distributed in the hope that it will be useful,
      12                 :            :  * but WITHOUT ANY WARRANTY; without even the implied warranty of
      13                 :            :  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      14                 :            :  * Library General Public License for more details.
      15                 :            :  *
      16                 :            :  * You should have received a copy of the GNU Library General Public
      17                 :            :  * License along with this library; if not, write to the
      18                 :            :  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
      19                 :            :  * Boston, MA 02111-1307, USA.
      20                 :            :  */
      21                 :            : 
      22                 :            : #ifdef HAVE_CONFIG_H
      23                 :            : #include "config.h"
      24                 :            : #endif
      25                 :            : 
      26                 :            : #include "gstmusepackdec.h"
      27                 :            : #include "gstmusepackreader.h"
      28                 :            : 
      29                 :            : GST_DEBUG_CATEGORY (musepackdec_debug);
      30                 :            : #define GST_CAT_DEFAULT musepackdec_debug
      31                 :            : 
      32                 :            : static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
      33                 :            :     GST_PAD_SINK,
      34                 :            :     GST_PAD_ALWAYS,
      35                 :            : #ifdef MPC_IS_OLD_API
      36                 :            :     GST_STATIC_CAPS ("audio/x-musepack, streamversion = (int) 7")
      37                 :            : #else
      38                 :            :     GST_STATIC_CAPS ("audio/x-musepack, streamversion = (int) { 7, 8 }")
      39                 :            : #endif
      40                 :            :     );
      41                 :            : 
      42                 :            : #ifdef MPC_FIXED_POINT
      43                 :            : #define BASE_CAPS \
      44                 :            :   "audio/x-raw-int, " \
      45                 :            :     "signed = (bool) TRUE, " \
      46                 :            :     "width = (int) 32, " \
      47                 :            :     "depth = (int) 32"
      48                 :            : #else
      49                 :            : #define BASE_CAPS \
      50                 :            :   "audio/x-raw-float, " \
      51                 :            :     "width = (int) 32"
      52                 :            : #endif
      53                 :            : 
      54                 :            : static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
      55                 :            :     GST_PAD_SRC,
      56                 :            :     GST_PAD_ALWAYS,
      57                 :            :     GST_STATIC_CAPS (BASE_CAPS ", "
      58                 :            :         "endianness = (int) BYTE_ORDER, "
      59                 :            :         "rate = (int) [ 8000, 96000 ], " "channels = (int) [ 1, 2 ]")
      60                 :            :     );
      61                 :            : 
      62                 :            : static void gst_musepackdec_dispose (GObject * obj);
      63                 :            : 
      64                 :            : static gboolean gst_musepackdec_src_event (GstPad * pad, GstEvent * event);
      65                 :            : static const GstQueryType *gst_musepackdec_get_src_query_types (GstPad * pad);
      66                 :            : static gboolean gst_musepackdec_src_query (GstPad * pad, GstQuery * query);
      67                 :            : static gboolean gst_musepackdec_sink_activate (GstPad * sinkpad);
      68                 :            : static gboolean
      69                 :            : gst_musepackdec_sink_activate_pull (GstPad * sinkpad, gboolean active);
      70                 :            : 
      71                 :            : static void gst_musepackdec_loop (GstPad * sinkpad);
      72                 :            : static GstStateChangeReturn
      73                 :            : gst_musepackdec_change_state (GstElement * element, GstStateChange transition);
      74                 :            : 
      75         [ +  + ]:         47 : GST_BOILERPLATE (GstMusepackDec, gst_musepackdec, GstElement, GST_TYPE_ELEMENT);
      76                 :            : 
      77                 :            : static void
      78                 :          6 : gst_musepackdec_base_init (gpointer klass)
      79                 :            : {
      80                 :          6 :   GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
      81                 :            : 
      82                 :          6 :   gst_element_class_add_pad_template (element_class,
      83                 :            :       gst_static_pad_template_get (&src_template));
      84                 :          6 :   gst_element_class_add_pad_template (element_class,
      85                 :            :       gst_static_pad_template_get (&sink_template));
      86                 :            : 
      87                 :          6 :   gst_element_class_set_details_simple (element_class, "Musepack decoder",
      88                 :            :       "Codec/Decoder/Audio",
      89                 :            :       "Musepack decoder", "Ronald Bultje <rbultje@ronald.bitfreak.net>");
      90                 :          6 : }
      91                 :            : 
      92                 :            : static void
      93                 :          6 : gst_musepackdec_class_init (GstMusepackDecClass * klass)
      94                 :            : {
      95                 :          6 :   GST_ELEMENT_CLASS (klass)->change_state =
      96                 :          6 :       GST_DEBUG_FUNCPTR (gst_musepackdec_change_state);
      97                 :            : 
      98                 :          6 :   G_OBJECT_CLASS (klass)->dispose = GST_DEBUG_FUNCPTR (gst_musepackdec_dispose);
      99                 :          6 : }
     100                 :            : 
     101                 :            : static void
     102                 :          3 : gst_musepackdec_init (GstMusepackDec * musepackdec, GstMusepackDecClass * klass)
     103                 :            : {
     104                 :          3 :   musepackdec->offset = 0;
     105                 :          3 :   musepackdec->rate = 0;
     106                 :          3 :   musepackdec->bps = 0;
     107                 :            : 
     108                 :          3 :   musepackdec->r = g_new (mpc_reader, 1);
     109                 :            : #ifdef MPC_IS_OLD_API
     110                 :            :   musepackdec->d = g_new (mpc_decoder, 1);
     111                 :            : #endif
     112                 :            : 
     113                 :          3 :   musepackdec->sinkpad =
     114                 :          3 :       gst_pad_new_from_static_template (&sink_template, "sink");
     115                 :          3 :   gst_pad_set_activate_function (musepackdec->sinkpad,
     116                 :          3 :       GST_DEBUG_FUNCPTR (gst_musepackdec_sink_activate));
     117                 :          3 :   gst_pad_set_activatepull_function (musepackdec->sinkpad,
     118                 :          3 :       GST_DEBUG_FUNCPTR (gst_musepackdec_sink_activate_pull));
     119                 :          3 :   gst_element_add_pad (GST_ELEMENT (musepackdec), musepackdec->sinkpad);
     120                 :            : 
     121                 :          3 :   musepackdec->srcpad = gst_pad_new_from_static_template (&src_template, "src");
     122                 :          3 :   gst_pad_set_event_function (musepackdec->srcpad,
     123                 :          3 :       GST_DEBUG_FUNCPTR (gst_musepackdec_src_event));
     124                 :          3 :   gst_pad_set_query_function (musepackdec->srcpad,
     125                 :          3 :       GST_DEBUG_FUNCPTR (gst_musepackdec_src_query));
     126                 :          3 :   gst_pad_set_query_type_function (musepackdec->srcpad,
     127                 :          3 :       GST_DEBUG_FUNCPTR (gst_musepackdec_get_src_query_types));
     128                 :          3 :   gst_pad_use_fixed_caps (musepackdec->srcpad);
     129                 :          3 :   gst_element_add_pad (GST_ELEMENT (musepackdec), musepackdec->srcpad);
     130                 :          3 : }
     131                 :            : 
     132                 :            : static void
     133                 :          3 : gst_musepackdec_dispose (GObject * obj)
     134                 :            : {
     135                 :          3 :   GstMusepackDec *musepackdec = GST_MUSEPACK_DEC (obj);
     136                 :            : 
     137                 :          3 :   g_free (musepackdec->r);
     138                 :          3 :   musepackdec->r = NULL;
     139                 :            : 
     140                 :            : #ifdef MPC_IS_OLD_API
     141                 :            :   g_free (musepackdec->d);
     142                 :            :   musepackdec->d = NULL;
     143                 :            : #else
     144         [ -  + ]:          3 :   if (musepackdec->d) {
     145                 :          0 :     mpc_demux_exit (musepackdec->d);
     146                 :          0 :     musepackdec->d = NULL;
     147                 :            :   }
     148                 :            : #endif
     149                 :            : 
     150                 :          3 :   G_OBJECT_CLASS (parent_class)->dispose (obj);
     151                 :          3 : }
     152                 :            : 
     153                 :            : static void
     154                 :          0 : gst_musepackdec_send_newsegment (GstMusepackDec * dec)
     155                 :            : {
     156                 :          0 :   GstSegment *s = &dec->segment;
     157                 :          0 :   gint64 stop_time = GST_CLOCK_TIME_NONE;
     158                 :          0 :   gint64 start_time = 0;
     159                 :            : 
     160                 :          0 :   start_time = gst_util_uint64_scale_int (s->start, GST_SECOND, dec->rate);
     161                 :            : 
     162         [ #  # ]:          0 :   if (s->stop != -1)
     163                 :          0 :     stop_time = gst_util_uint64_scale_int (s->stop, GST_SECOND, dec->rate);
     164                 :            : 
     165 [ #  # ][ #  # ]:          0 :   GST_DEBUG_OBJECT (dec, "sending newsegment from %" GST_TIME_FORMAT
         [ #  # ][ #  # ]
         [ #  # ][ #  # ]
         [ #  # ][ #  # ]
                 [ #  # ]
     166                 :            :       " to %" GST_TIME_FORMAT ", rate = %.1f", GST_TIME_ARGS (start_time),
     167                 :            :       GST_TIME_ARGS (stop_time), s->rate);
     168                 :            : 
     169                 :          0 :   gst_pad_push_event (dec->srcpad,
     170                 :            :       gst_event_new_new_segment (FALSE, s->rate, GST_FORMAT_TIME,
     171                 :            :           start_time, stop_time, start_time));
     172                 :          0 : }
     173                 :            : 
     174                 :            : static gboolean
     175                 :          0 : gst_musepackdec_handle_seek_event (GstMusepackDec * dec, GstEvent * event)
     176                 :            : {
     177                 :            :   GstSeekType start_type, stop_type;
     178                 :            :   GstSeekFlags flags;
     179                 :            :   GstSegment segment;
     180                 :            :   GstFormat format;
     181                 :            :   gboolean flush;
     182                 :            :   gdouble rate;
     183                 :            :   gint64 start, stop;
     184                 :            :   gint samplerate;
     185                 :            : 
     186                 :          0 :   gst_event_parse_seek (event, &rate, &format, &flags, &start_type, &start,
     187                 :            :       &stop_type, &stop);
     188                 :            : 
     189 [ #  # ][ #  # ]:          0 :   if (format != GST_FORMAT_TIME && format != GST_FORMAT_DEFAULT) {
     190         [ #  # ]:          0 :     GST_DEBUG_OBJECT (dec, "seek failed: only TIME or DEFAULT format allowed");
     191                 :          0 :     return FALSE;
     192                 :            :   }
     193                 :            : 
     194                 :          0 :   samplerate = g_atomic_int_get (&dec->rate);
     195                 :            : 
     196         [ #  # ]:          0 :   if (format == GST_FORMAT_TIME) {
     197         [ #  # ]:          0 :     if (start_type != GST_SEEK_TYPE_NONE)
     198                 :          0 :       start = gst_util_uint64_scale_int (start, samplerate, GST_SECOND);
     199         [ #  # ]:          0 :     if (stop_type != GST_SEEK_TYPE_NONE)
     200                 :          0 :       stop = gst_util_uint64_scale_int (stop, samplerate, GST_SECOND);
     201                 :            :   }
     202                 :            : 
     203                 :          0 :   flush = ((flags & GST_SEEK_FLAG_FLUSH) == GST_SEEK_FLAG_FLUSH);
     204                 :            : 
     205         [ #  # ]:          0 :   if (flush)
     206                 :          0 :     gst_pad_push_event (dec->srcpad, gst_event_new_flush_start ());
     207                 :            :   else
     208                 :          0 :     gst_pad_pause_task (dec->sinkpad);  /* not _stop_task()? */
     209                 :            : 
     210                 :          0 :   GST_PAD_STREAM_LOCK (dec->sinkpad);
     211                 :            : 
     212                 :            :   /* operate on segment copy until we know the seek worked */
     213                 :          0 :   segment = dec->segment;
     214                 :            : 
     215                 :          0 :   gst_segment_set_seek (&segment, rate, GST_FORMAT_DEFAULT,
     216                 :            :       flags, start_type, start, stop_type, stop, NULL);
     217                 :            : 
     218                 :          0 :   gst_pad_push_event (dec->sinkpad, gst_event_new_flush_stop ());
     219                 :            : 
     220 [ #  # ][ #  # ]:          0 :   GST_DEBUG_OBJECT (dec, "segment: [%" G_GINT64_FORMAT "-%" G_GINT64_FORMAT
         [ #  # ][ #  # ]
         [ #  # ][ #  # ]
         [ #  # ][ #  # ]
                 [ #  # ]
     221                 :            :       "] = [%" GST_TIME_FORMAT "-%" GST_TIME_FORMAT "]",
     222                 :            :       segment.start, segment.stop,
     223                 :            :       GST_TIME_ARGS (segment.start * GST_SECOND / dec->rate),
     224                 :            :       GST_TIME_ARGS (segment.stop * GST_SECOND / dec->rate));
     225                 :            : 
     226         [ #  # ]:          0 :   GST_DEBUG_OBJECT (dec, "performing seek to sample %" G_GINT64_FORMAT,
     227                 :            :       segment.start);
     228                 :            : 
     229 [ #  # ][ #  # ]:          0 :   if (segment.start < 0 || segment.start >= segment.duration) {
     230         [ #  # ]:          0 :     GST_WARNING_OBJECT (dec, "seek out of bounds");
     231                 :          0 :     goto failed;
     232                 :            :   }
     233                 :            : #ifdef MPC_IS_OLD_API
     234                 :            :   if (!mpc_decoder_seek_sample (dec->d, segment.start))
     235                 :            :     goto failed;
     236                 :            : #else
     237         [ #  # ]:          0 :   if (mpc_demux_seek_sample (dec->d, segment.start) != MPC_STATUS_OK)
     238                 :          0 :     goto failed;
     239                 :            : #endif
     240                 :            : 
     241         [ #  # ]:          0 :   if ((flags & GST_SEEK_FLAG_SEGMENT) == GST_SEEK_FLAG_SEGMENT) {
     242         [ #  # ]:          0 :     GST_DEBUG_OBJECT (dec, "posting SEGMENT_START message");
     243                 :            : 
     244                 :          0 :     gst_element_post_message (GST_ELEMENT (dec),
     245                 :          0 :         gst_message_new_segment_start (GST_OBJECT (dec), GST_FORMAT_TIME,
     246                 :          0 :             gst_util_uint64_scale_int (segment.start, GST_SECOND, dec->rate)));
     247                 :            :   }
     248                 :            : 
     249         [ #  # ]:          0 :   if (flush) {
     250                 :          0 :     gst_pad_push_event (dec->srcpad, gst_event_new_flush_stop ());
     251                 :            :   }
     252                 :            : 
     253                 :          0 :   gst_segment_set_last_stop (&segment, GST_FORMAT_DEFAULT, segment.start);
     254                 :          0 :   dec->segment = segment;
     255                 :          0 :   gst_musepackdec_send_newsegment (dec);
     256                 :            : 
     257         [ #  # ]:          0 :   GST_DEBUG_OBJECT (dec, "seek successful");
     258                 :            : 
     259                 :          0 :   gst_pad_start_task (dec->sinkpad,
     260                 :          0 :       (GstTaskFunction) gst_musepackdec_loop, dec->sinkpad);
     261                 :            : 
     262                 :          0 :   GST_PAD_STREAM_UNLOCK (dec->sinkpad);
     263                 :            : 
     264                 :          0 :   return TRUE;
     265                 :            : 
     266                 :            : failed:
     267                 :            :   {
     268         [ #  # ]:          0 :     GST_WARNING_OBJECT (dec, "seek failed");
     269                 :          0 :     GST_PAD_STREAM_UNLOCK (dec->sinkpad);
     270                 :          0 :     return FALSE;
     271                 :            :   }
     272                 :            : }
     273                 :            : 
     274                 :            : static gboolean
     275                 :          0 : gst_musepackdec_src_event (GstPad * pad, GstEvent * event)
     276                 :            : {
     277                 :            :   GstMusepackDec *dec;
     278                 :            :   gboolean res;
     279                 :            : 
     280                 :          0 :   dec = GST_MUSEPACK_DEC (gst_pad_get_parent (pad));
     281                 :            : 
     282         [ #  # ]:          0 :   GST_DEBUG_OBJECT (dec, "handling %s event", GST_EVENT_TYPE_NAME (event));
     283                 :            : 
     284         [ #  # ]:          0 :   switch (GST_EVENT_TYPE (event)) {
     285                 :            :     case GST_EVENT_SEEK:
     286                 :          0 :       res = gst_musepackdec_handle_seek_event (dec, event);
     287                 :          0 :       break;
     288                 :            :     default:
     289                 :          0 :       res = gst_pad_event_default (pad, event);
     290                 :          0 :       break;
     291                 :            :   }
     292                 :            : 
     293                 :          0 :   gst_object_unref (dec);
     294                 :          0 :   return res;
     295                 :            : }
     296                 :            : 
     297                 :            : static const GstQueryType *
     298                 :          0 : gst_musepackdec_get_src_query_types (GstPad * pad)
     299                 :            : {
     300                 :            :   static const GstQueryType query_types[] = {
     301                 :            :     GST_QUERY_POSITION,
     302                 :            :     GST_QUERY_DURATION,
     303                 :            :     GST_QUERY_SEEKING,
     304                 :            :     (GstQueryType) 0
     305                 :            :   };
     306                 :            : 
     307                 :          0 :   return query_types;
     308                 :            : }
     309                 :            : 
     310                 :            : static gboolean
     311                 :          0 : gst_musepackdec_src_query (GstPad * pad, GstQuery * query)
     312                 :            : {
     313                 :          0 :   GstMusepackDec *musepackdec = GST_MUSEPACK_DEC (gst_pad_get_parent (pad));
     314                 :            :   GstFormat format;
     315                 :          0 :   gboolean res = FALSE;
     316                 :            :   gint samplerate;
     317                 :            : 
     318                 :          0 :   samplerate = g_atomic_int_get (&musepackdec->rate);
     319                 :            : 
     320         [ #  # ]:          0 :   if (samplerate == 0)
     321                 :          0 :     goto done;
     322                 :            : 
     323   [ #  #  #  # ]:          0 :   switch (GST_QUERY_TYPE (query)) {
     324                 :            :     case GST_QUERY_POSITION:{
     325                 :            :       gint64 cur, cur_off;
     326                 :            : 
     327                 :          0 :       gst_query_parse_position (query, &format, NULL);
     328                 :            : 
     329                 :          0 :       GST_OBJECT_LOCK (musepackdec);
     330                 :          0 :       cur_off = musepackdec->segment.last_stop;
     331                 :          0 :       GST_OBJECT_UNLOCK (musepackdec);
     332                 :            : 
     333         [ #  # ]:          0 :       if (format == GST_FORMAT_TIME) {
     334                 :          0 :         cur = gst_util_uint64_scale_int (cur_off, GST_SECOND, samplerate);
     335                 :          0 :         gst_query_set_position (query, GST_FORMAT_TIME, cur);
     336                 :          0 :         res = TRUE;
     337         [ #  # ]:          0 :       } else if (format == GST_FORMAT_DEFAULT) {
     338                 :          0 :         gst_query_set_position (query, GST_FORMAT_DEFAULT, cur_off);
     339                 :          0 :         res = TRUE;
     340                 :            :       }
     341                 :          0 :       break;
     342                 :            :     }
     343                 :            :     case GST_QUERY_DURATION:{
     344                 :            :       gint64 len, len_off;
     345                 :            : 
     346                 :          0 :       gst_query_parse_duration (query, &format, NULL);
     347                 :            : 
     348                 :          0 :       GST_OBJECT_LOCK (musepackdec);
     349                 :          0 :       len_off = musepackdec->segment.duration;
     350                 :          0 :       GST_OBJECT_UNLOCK (musepackdec);
     351                 :            : 
     352         [ #  # ]:          0 :       if (format == GST_FORMAT_TIME) {
     353                 :          0 :         len = gst_util_uint64_scale_int (len_off, GST_SECOND, samplerate);
     354                 :          0 :         gst_query_set_duration (query, GST_FORMAT_TIME, len);
     355                 :          0 :         res = TRUE;
     356         [ #  # ]:          0 :       } else if (format == GST_FORMAT_DEFAULT) {
     357                 :          0 :         gst_query_set_duration (query, GST_FORMAT_DEFAULT, len_off);
     358                 :          0 :         res = TRUE;
     359                 :            :       }
     360                 :          0 :       break;
     361                 :            :     }
     362                 :            :     case GST_QUERY_SEEKING:{
     363                 :            :       GstFormat fmt;
     364                 :            : 
     365                 :          0 :       res = TRUE;
     366                 :          0 :       gst_query_parse_seeking (query, &fmt, NULL, NULL, NULL);
     367 [ #  # ][ #  # ]:          0 :       if (fmt == GST_FORMAT_TIME || fmt == GST_FORMAT_DEFAULT)
     368                 :          0 :         gst_query_set_seeking (query, fmt, TRUE, 0, -1);
     369                 :            :       else
     370                 :          0 :         gst_query_set_seeking (query, fmt, FALSE, -1, -1);
     371                 :            : 
     372                 :          0 :       break;
     373                 :            :     }
     374                 :            :     default:
     375                 :          0 :       res = gst_pad_query_default (pad, query);
     376                 :          0 :       break;
     377                 :            :   }
     378                 :            : 
     379                 :            : done:
     380                 :          0 :   gst_object_unref (musepackdec);
     381                 :          0 :   return res;
     382                 :            : }
     383                 :            : 
     384                 :            : static gboolean
     385                 :          0 : gst_musepack_stream_init (GstMusepackDec * musepackdec)
     386                 :            : {
     387                 :            :   mpc_streaminfo i;
     388                 :            :   GstTagList *tags;
     389                 :            :   GstCaps *caps;
     390                 :            : 
     391                 :            :   /* set up reading */
     392                 :          0 :   gst_musepack_init_reader (musepackdec->r, musepackdec);
     393                 :            : 
     394                 :            : #ifdef MPC_IS_OLD_API
     395                 :            :   /* streaminfo */
     396                 :            :   mpc_streaminfo_init (&i);
     397                 :            :   if (mpc_streaminfo_read (&i, musepackdec->r) < 0) {
     398                 :            :     GST_ELEMENT_ERROR (musepackdec, STREAM, WRONG_TYPE, (NULL), (NULL));
     399                 :            :     return FALSE;
     400                 :            :   }
     401                 :            : 
     402                 :            :   /* decoding */
     403                 :            :   mpc_decoder_setup (musepackdec->d, musepackdec->r);
     404                 :            :   mpc_decoder_scale_output (musepackdec->d, 1.0);
     405                 :            :   if (!mpc_decoder_initialize (musepackdec->d, &i)) {
     406                 :            :     GST_ELEMENT_ERROR (musepackdec, STREAM, WRONG_TYPE, (NULL), (NULL));
     407                 :            :     return FALSE;
     408                 :            :   }
     409                 :            : #else
     410                 :          0 :   musepackdec->d = mpc_demux_init (musepackdec->r);
     411         [ #  # ]:          0 :   if (!musepackdec->d) {
     412 [ #  # ][ #  # ]:          0 :     GST_ELEMENT_ERROR (musepackdec, STREAM, WRONG_TYPE, (NULL), (NULL));
         [ #  # ][ #  # ]
     413                 :          0 :     return FALSE;
     414                 :            :   }
     415                 :            : 
     416                 :          0 :   mpc_demux_get_info (musepackdec->d, &i);
     417                 :            : #endif
     418                 :            : 
     419                 :            :   /* capsnego */
     420                 :          0 :   caps = gst_caps_from_string (BASE_CAPS);
     421                 :          0 :   gst_caps_set_simple (caps,
     422                 :            :       "endianness", G_TYPE_INT, G_BYTE_ORDER,
     423                 :            :       "channels", G_TYPE_INT, i.channels,
     424                 :            :       "rate", G_TYPE_INT, i.sample_freq, NULL);
     425                 :          0 :   gst_pad_use_fixed_caps (musepackdec->srcpad);
     426         [ #  # ]:          0 :   if (!gst_pad_set_caps (musepackdec->srcpad, caps)) {
     427 [ #  # ][ #  # ]:          0 :     GST_ELEMENT_ERROR (musepackdec, CORE, NEGOTIATION, (NULL), (NULL));
         [ #  # ][ #  # ]
     428                 :          0 :     return FALSE;
     429                 :            :   }
     430                 :            : 
     431                 :          0 :   g_atomic_int_set (&musepackdec->bps, 4 * i.channels);
     432                 :          0 :   g_atomic_int_set (&musepackdec->rate, i.sample_freq);
     433                 :            : 
     434                 :          0 :   gst_segment_set_last_stop (&musepackdec->segment, GST_FORMAT_DEFAULT, 0);
     435                 :          0 :   gst_segment_set_duration (&musepackdec->segment, GST_FORMAT_DEFAULT,
     436                 :            :       mpc_streaminfo_get_length_samples (&i));
     437                 :            : 
     438                 :            :   /* send basic tags */
     439                 :          0 :   tags = gst_tag_list_new ();
     440                 :          0 :   gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     441                 :            :       GST_TAG_AUDIO_CODEC, "Musepack", NULL);
     442                 :            : 
     443 [ #  # ][ #  # ]:          0 :   if (i.encoder[0] != '\0' && i.encoder_version > 0) {
     444                 :          0 :     gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     445                 :            :         GST_TAG_ENCODER, i.encoder,
     446                 :            :         GST_TAG_ENCODER_VERSION, i.encoder_version, NULL);
     447                 :            :   }
     448                 :            : 
     449         [ #  # ]:          0 :   if (i.bitrate > 0) {
     450                 :          0 :     gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     451                 :            :         GST_TAG_BITRATE, i.bitrate, NULL);
     452         [ #  # ]:          0 :   } else if (i.average_bitrate > 0.0) {
     453                 :          0 :     gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     454                 :          0 :         GST_TAG_BITRATE, (guint) i.average_bitrate, NULL);
     455                 :            :   }
     456                 :            : 
     457 [ #  # ][ #  # ]:          0 :   if (i.gain_title != 0 || i.gain_album != 0) {
     458                 :          0 :     gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     459                 :          0 :         GST_TAG_TRACK_GAIN, (gdouble) i.gain_title / 100.0,
     460                 :          0 :         GST_TAG_ALBUM_GAIN, (gdouble) i.gain_album / 100.0, NULL);
     461                 :            :   }
     462                 :            : 
     463 [ #  # ][ #  # ]:          0 :   if (i.peak_title != 0 && i.peak_title != 32767 &&
                 [ #  # ]
     464         [ #  # ]:          0 :       i.peak_album != 0 && i.peak_album != 32767) {
     465                 :          0 :     gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
     466                 :          0 :         GST_TAG_TRACK_PEAK, (gdouble) i.peak_title / 32767.0,
     467                 :          0 :         GST_TAG_ALBUM_PEAK, (gdouble) i.peak_album / 32767.0, NULL);
     468                 :            :   }
     469                 :            : 
     470         [ #  # ]:          0 :   GST_LOG_OBJECT (musepackdec, "Posting tags: %" GST_PTR_FORMAT, tags);
     471                 :          0 :   gst_element_found_tags (GST_ELEMENT (musepackdec), tags);
     472                 :            : 
     473                 :          0 :   return TRUE;
     474                 :            : }
     475                 :            : 
     476                 :            : static gboolean
     477                 :         18 : gst_musepackdec_sink_activate (GstPad * sinkpad)
     478                 :            : {
     479         [ +  - ]:         18 :   if (!gst_pad_check_pull_range (sinkpad))
     480                 :         18 :     return FALSE;
     481                 :            : 
     482                 :         18 :   return gst_pad_activate_pull (sinkpad, TRUE);
     483                 :            : }
     484                 :            : 
     485                 :            : static gboolean
     486                 :          0 : gst_musepackdec_sink_activate_pull (GstPad * sinkpad, gboolean active)
     487                 :            : {
     488                 :            :   gboolean result;
     489                 :            : 
     490         [ #  # ]:          0 :   if (active) {
     491                 :          0 :     result = gst_pad_start_task (sinkpad,
     492                 :            :         (GstTaskFunction) gst_musepackdec_loop, sinkpad);
     493                 :            :   } else {
     494                 :          0 :     result = gst_pad_stop_task (sinkpad);
     495                 :            :   }
     496                 :            : 
     497                 :          0 :   return result;
     498                 :            : }
     499                 :            : 
     500                 :            : static void
     501                 :          0 : gst_musepackdec_loop (GstPad * sinkpad)
     502                 :            : {
     503                 :            :   GstMusepackDec *musepackdec;
     504                 :            :   GstFlowReturn flow;
     505                 :            :   GstBuffer *out;
     506                 :            : 
     507                 :            : #ifdef MPC_IS_OLD_API
     508                 :            :   guint32 update_acc, update_bits;
     509                 :            : #else
     510                 :            :   mpc_frame_info frame;
     511                 :            :   mpc_status err;
     512                 :            : #endif
     513                 :            :   gint num_samples, samplerate, bitspersample;
     514                 :            : 
     515                 :          0 :   musepackdec = GST_MUSEPACK_DEC (GST_PAD_PARENT (sinkpad));
     516                 :            : 
     517                 :          0 :   samplerate = g_atomic_int_get (&musepackdec->rate);
     518                 :            : 
     519         [ #  # ]:          0 :   if (samplerate == 0) {
     520         [ #  # ]:          0 :     if (!gst_musepack_stream_init (musepackdec))
     521                 :          0 :       goto pause_task;
     522                 :            : 
     523                 :          0 :     gst_musepackdec_send_newsegment (musepackdec);
     524                 :          0 :     samplerate = g_atomic_int_get (&musepackdec->rate);
     525                 :            :   }
     526                 :            : 
     527                 :          0 :   bitspersample = g_atomic_int_get (&musepackdec->bps);
     528                 :            : 
     529                 :          0 :   flow = gst_pad_alloc_buffer_and_set_caps (musepackdec->srcpad, -1,
     530                 :          0 :       MPC_DECODER_BUFFER_LENGTH * 4, GST_PAD_CAPS (musepackdec->srcpad), &out);
     531                 :            : 
     532         [ #  # ]:          0 :   if (flow != GST_FLOW_OK) {
     533         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "Flow: %s", gst_flow_get_name (flow));
     534                 :          0 :     goto pause_task;
     535                 :            :   }
     536                 :            : #ifdef MPC_IS_OLD_API
     537                 :            :   num_samples = mpc_decoder_decode (musepackdec->d,
     538                 :            :       (MPC_SAMPLE_FORMAT *) GST_BUFFER_DATA (out), &update_acc, &update_bits);
     539                 :            : 
     540                 :            :   if (num_samples < 0) {
     541                 :            :     GST_ERROR_OBJECT (musepackdec, "Failed to decode sample");
     542                 :            :     GST_ELEMENT_ERROR (musepackdec, STREAM, DECODE, (NULL), (NULL));
     543                 :            :     goto pause_task;
     544                 :            :   } else if (num_samples == 0) {
     545                 :            :     goto eos_and_pause;
     546                 :            :   }
     547                 :            : #else
     548                 :          0 :   frame.buffer = (MPC_SAMPLE_FORMAT *) GST_BUFFER_DATA (out);
     549                 :          0 :   err = mpc_demux_decode (musepackdec->d, &frame);
     550                 :            : 
     551         [ #  # ]:          0 :   if (err != MPC_STATUS_OK) {
     552         [ #  # ]:          0 :     GST_ERROR_OBJECT (musepackdec, "Failed to decode sample");
     553 [ #  # ][ #  # ]:          0 :     GST_ELEMENT_ERROR (musepackdec, STREAM, DECODE, (NULL), (NULL));
         [ #  # ][ #  # ]
     554                 :          0 :     goto pause_task;
     555         [ #  # ]:          0 :   } else if (frame.bits == -1) {
     556                 :          0 :     goto eos_and_pause;
     557                 :            :   }
     558                 :            : 
     559                 :          0 :   num_samples = frame.samples;
     560                 :            : #endif
     561                 :            : 
     562                 :          0 :   GST_BUFFER_SIZE (out) = num_samples * bitspersample;
     563                 :            : 
     564                 :          0 :   GST_BUFFER_OFFSET (out) = musepackdec->segment.last_stop;
     565                 :          0 :   GST_BUFFER_TIMESTAMP (out) =
     566                 :          0 :       gst_util_uint64_scale_int (musepackdec->segment.last_stop,
     567                 :            :       GST_SECOND, samplerate);
     568                 :          0 :   GST_BUFFER_DURATION (out) =
     569                 :          0 :       gst_util_uint64_scale_int (num_samples, GST_SECOND, samplerate);
     570                 :            : 
     571                 :          0 :   musepackdec->segment.last_stop += num_samples;
     572                 :            : 
     573 [ #  # ][ #  # ]:          0 :   GST_LOG_OBJECT (musepackdec, "Pushing buffer, timestamp %" GST_TIME_FORMAT,
         [ #  # ][ #  # ]
                 [ #  # ]
     574                 :            :       GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (out)));
     575                 :            : 
     576                 :          0 :   flow = gst_pad_push (musepackdec->srcpad, out);
     577         [ #  # ]:          0 :   if (flow != GST_FLOW_OK) {
     578         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "Flow: %s", gst_flow_get_name (flow));
     579                 :          0 :     goto pause_task;
     580                 :            :   }
     581                 :            : 
     582                 :            :   /* check if we're at the end of a configured segment */
     583 [ #  # ][ #  # ]:          0 :   if (musepackdec->segment.stop != -1 &&
     584                 :          0 :       musepackdec->segment.last_stop >= musepackdec->segment.stop) {
     585                 :            :     gint64 stop_time;
     586                 :            : 
     587         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "Reached end of configured segment");
     588                 :            : 
     589         [ #  # ]:          0 :     if ((musepackdec->segment.flags & GST_SEEK_FLAG_SEGMENT) == 0)
     590                 :          0 :       goto eos_and_pause;
     591                 :            : 
     592         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "Posting SEGMENT_DONE message");
     593                 :            : 
     594                 :          0 :     stop_time = gst_util_uint64_scale_int (musepackdec->segment.stop,
     595                 :            :         GST_SECOND, samplerate);
     596                 :            : 
     597                 :          0 :     gst_element_post_message (GST_ELEMENT (musepackdec),
     598                 :          0 :         gst_message_new_segment_done (GST_OBJECT (musepackdec),
     599                 :            :             GST_FORMAT_TIME, stop_time));
     600                 :            : 
     601                 :          0 :     goto pause_task;
     602                 :            :   }
     603                 :            : 
     604                 :          0 :   return;
     605                 :            : 
     606                 :            : eos_and_pause:
     607                 :            :   {
     608         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "sending EOS event");
     609                 :          0 :     gst_pad_push_event (musepackdec->srcpad, gst_event_new_eos ());
     610                 :            :     /* fall through to pause */
     611                 :            :   }
     612                 :            : 
     613                 :            : pause_task:
     614                 :            :   {
     615         [ #  # ]:          0 :     GST_DEBUG_OBJECT (musepackdec, "Pausing task");
     616                 :          0 :     gst_pad_pause_task (sinkpad);
     617                 :          0 :     return;
     618                 :            :   }
     619                 :            : }
     620                 :            : 
     621                 :            : static GstStateChangeReturn
     622                 :         32 : gst_musepackdec_change_state (GstElement * element, GstStateChange transition)
     623                 :            : {
     624                 :         32 :   GstMusepackDec *musepackdec = GST_MUSEPACK_DEC (element);
     625                 :         32 :   GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
     626                 :            : 
     627         [ +  + ]:         32 :   switch (transition) {
     628                 :            :     case GST_STATE_CHANGE_READY_TO_PAUSED:
     629                 :         18 :       gst_segment_init (&musepackdec->segment, GST_FORMAT_DEFAULT);
     630                 :         18 :       gst_segment_set_last_stop (&musepackdec->segment, GST_FORMAT_DEFAULT, 0);
     631                 :         18 :       break;
     632                 :            :     default:
     633                 :         14 :       break;
     634                 :            :   }
     635                 :            : 
     636         [ +  - ]:         32 :   if (GST_ELEMENT_CLASS (parent_class)->change_state)
     637                 :         32 :     ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
     638                 :            : 
     639         [ -  + ]:         32 :   switch (transition) {
     640                 :            :     case GST_STATE_CHANGE_PAUSED_TO_READY:
     641                 :          0 :       gst_segment_init (&musepackdec->segment, GST_FORMAT_UNDEFINED);
     642                 :          0 :       musepackdec->offset = 0;
     643                 :          0 :       musepackdec->rate = 0;
     644                 :          0 :       musepackdec->bps = 0;
     645                 :          0 :       break;
     646                 :            :     default:
     647                 :         32 :       break;
     648                 :            :   }
     649                 :            : 
     650                 :         32 :   return ret;
     651                 :            : 
     652                 :            : }
     653                 :            : 
     654                 :            : static gboolean
     655                 :          6 : plugin_init (GstPlugin * plugin)
     656                 :            : {
     657         [ +  - ]:          6 :   GST_DEBUG_CATEGORY_INIT (musepackdec_debug, "musepackdec", 0, "mpc decoder");
     658                 :            : 
     659                 :          6 :   return gst_element_register (plugin, "musepackdec",
     660                 :            :       GST_RANK_PRIMARY, GST_TYPE_MUSEPACK_DEC);
     661                 :            : }
     662                 :            : 
     663                 :            : GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
     664                 :            :     GST_VERSION_MINOR,
     665                 :            :     "musepack",
     666                 :            :     "Musepack decoder", plugin_init, VERSION, "LGPL", GST_PACKAGE_NAME,
     667                 :            :     GST_PACKAGE_ORIGIN)

Generated by: LCOV version 1.9