Changeset 06ef387db9f271a96d600e423633018fe5c2fcd7

Timestamp:

09/22/07 16:53:54 (10 months ago)

Author:

Rémi Denis-Courmont <rem@videolan.org>

git-committer:

Rémi Denis-Courmont <rem@videolan.org> 1190472834 +0000

git-parent:

[4112e0fd7e4c7cc33552fb0bf26e2a38470150f6]

git-author:

Rémi Denis-Courmont <rem@videolan.org> 1190472834 +0000

Message:

Support for decoding Speex from RTP - refs #1291
Patch by Williams Hawkins

Files:

• THANKS (modified) (1 diff)
• modules/codec/speex.c (modified) (15 diffs)

THANKS

@@ -207 +207 @@
-Watanabe Go <go at dsl.gr.jp> - fix for non-ASCII filenames
-Wei Mingzhi <whistler_wmz at users.sourceforge.net> - Simplied Chinese translation
+William Hawkins - Speex RTP payload format
-Xavier Maillard <zedek at fxgsproject.org> - audio converters
-Xavier Marchesini <xav at alarue.net> - Win32 fixes

modules/codec/speex.c

@@ -59 +59 @@
-    SpeexStereoState stereo;
-    void *p_state;
+    unsigned int rtp_rate;
-
-    /*
@@ -86 +87 @@
-
-static void *DecodeBlock  ( decoder_t *, block_t ** );
+static aout_buffer_t *DecodeRtpSpeexPacket( decoder_t *, block_t **);
-static int  ProcessHeaders( decoder_t * );
-static int  ProcessInitialHeader ( decoder_t *, ogg_packet * );
@@ -129 +131 @@
-    decoder_sys_t *p_sys = p_dec->p_sys;
-
-
+
+
-    {
-        return VLC_EGENERIC;
@@ -141 +144 @@
-        return VLC_EGENERIC;
-    }
+    p_dec->p_sys->bits.buf_size = 0;
-    p_dec->p_sys->b_packetizer = VLC_FALSE;
+    p_dec->p_sys->rtp_rate = p_dec->fmt_in.audio.i_rate;
-
-    aout_DateSet( &p_sys->end_date, 0 );
@@ -149 +154 @@
-    p_dec->fmt_out.i_codec = AOUT_FMT_S16_NE;
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    p_dec->pf_packetize    = (block_t *(*)(decoder_t *, block_t **))
-        DecodeBlock;
@@ -213 +233 @@
-    if( p_sys->i_headers == 0 && p_dec->fmt_in.i_extra )
-    {
-        /* Headers already available as extra data */
-        p_sys->i_headers = 2;
-    }
-    else if( oggpacket.bytes && p_sys->i_headers < 2 )
-    {
-        /* Backup headers as extra data */
-        uint8_t *p_extra;
-
@@ -419 +437 @@
-
-    /* Date management */
-
+ 
-        p_block->i_pts != aout_DateGet( &p_sys->end_date ) )
-    {
@@ -436 +454 @@
-    if( p_sys->b_packetizer )
-    {
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    }
-    else
@@ -450 +535 @@
-        return p_aout_buffer;
-    }
+}
+
+static aout_buffer_t *DecodeRtpSpeexPacket( decoder_t *p_dec, block_t **pp_block )
+{
+    block_t *p_speex_bit_block = *pp_block;
+    decoder_sys_t *p_sys = p_dec->p_sys;
+    aout_buffer_t *p_aout_buffer;
+    int i_decode_ret;
+    unsigned int i_speex_frame_size;
+
+    if ( !p_speex_bit_block || p_speex_bit_block->i_pts == 0 ) return NULL;
+
+    /* 
+      If the SpeexBits buffer size is 0 (a default value),
+      we know that a proper initialization has not yet been done.
+    */
+    if ( p_sys->bits.buf_size==0 )
+    {
+    p_sys->p_header = (SpeexHeader *)malloc(sizeof(SpeexHeader));
+    if ( !p_sys->p_header )
+    {
+        msg_Err( p_dec, "Could not allocate a Speex header.");
+        return NULL;
+    }
+    speex_init_header( p_sys->p_header,p_sys->rtp_rate,1,&speex_nb_mode );
+        speex_bits_init( &p_sys->bits );
+    p_sys->p_state = speex_decoder_init( &speex_nb_mode );
+    if ( !p_sys->p_state )
+    {
+        msg_Err( p_dec, "Could not allocate a Speex decoder." );
+        free( p_sys->p_header );
+        return NULL;
+    }
+
+        /*
+      Assume that variable bit rate is enabled. Also assume
+      that there is only one frame per packet. 
+    */
+    p_sys->p_header->vbr = 1;
+    p_sys->p_header->frames_per_packet = 1;
+
+        p_dec->fmt_out.audio.i_channels = p_sys->p_header->nb_channels;
+    p_dec->fmt_out.audio.i_physical_channels = 
+    p_dec->fmt_out.audio.i_original_channels = 
+        pi_channels_maps[p_sys->p_header->nb_channels];
+        p_dec->fmt_out.audio.i_rate = p_sys->p_header->rate;
+
+        if ( speex_mode_query( &speex_nb_mode, 
+        SPEEX_MODE_FRAME_SIZE, 
+        &i_speex_frame_size ) )
+    {
+        msg_Err( p_dec, "Could not determine the frame size." );
+        speex_decoder_destroy( p_sys->p_state );
+        free( p_sys->p_header );
+        return NULL;
+    }
+    p_dec->fmt_out.audio.i_bytes_per_frame = i_speex_frame_size;
+
+    aout_DateInit(&p_sys->end_date, p_sys->p_header->rate);
+    }
+
+    /* 
+      If the SpeexBits are initialized but there is 
+      still no header, an error must be thrown.
+    */
+    if ( !p_sys->p_header )
+    {
+        msg_Err( p_dec, "There is no valid Speex header found." );
+    return NULL;
+    }
+    *pp_block = NULL;
+
+    if ( !aout_DateGet( &p_sys->end_date ) )
+        aout_DateSet( &p_sys->end_date, p_speex_bit_block->i_dts );
+
+    /*
+      Ask for a new audio output buffer and make sure
+      we get one. 
+    */
+    p_aout_buffer = p_dec->pf_aout_buffer_new( p_dec, 
+        p_sys->p_header->frame_size );
+    if ( !p_aout_buffer || p_aout_buffer->i_nb_bytes == 0 )
+    {
+        msg_Err(p_dec, "Oops: No new buffer was returned!");
+    return NULL;
+    }
+
+    /*
+      Read the Speex payload into the SpeexBits buffer.
+    */
+    speex_bits_read_from( &p_sys->bits, 
+        (char*)p_speex_bit_block->p_buffer, 
+        p_speex_bit_block->i_buffer );
+    
+    /* 
+      Decode the input and ensure that no errors 
+      were encountered.
+    */
+    i_decode_ret = 
+        speex_decode_int( p_sys->p_state,&p_sys->bits,p_aout_buffer->p_buffer );
+    if ( i_decode_ret < 0 )
+    {
+        msg_Err( p_dec, "Decoding failed. Perhaps we have a bad stream?" );
+    return NULL;
+    }
+
+    /* 
+      Handle date management on the audio output buffer. 
+    */
+    p_aout_buffer->start_date = aout_DateGet( &p_sys->end_date );
+    p_aout_buffer->end_date = aout_DateIncrement( &p_sys->end_date, 
+        p_sys->p_header->frame_size );
+    
+    
+    p_sys->i_frame_in_packet++;
+    block_Release( p_speex_bit_block );
+
+    return p_aout_buffer;
-}
-
@@ -485 +688 @@
-        {
-            case -2:
-Warn
+Err
-            case -1: /* End of stream */
-                return NULL;
@@ -492 +695 @@
-        if( speex_bits_remaining( &p_sys->bits ) < 0 )
-        {
-Warn
+Err
-        }
-
@@ -503 +706 @@
-        p_aout_buffer->start_date = aout_DateGet( &p_sys->end_date );
-        p_aout_buffer->end_date =
-
+ 
-
-        p_sys->i_frame_in_packet++;
@@ -527 +730 @@
-
-    if( p_sys->i_headers >= p_sys->p_header->extra_headers + 2 )
+    {
-        p_block->i_length =
-            aout_DateIncrement( &p_sys->end_date,
-                                p_sys->p_header->frame_size ) -
-            p_block->i_pts;
+    }
-    else
-        p_block->i_length = 0;
@@ -567 +772 @@
-    if( p_oggpacket->bytes < 8 )
-    {
-Warn
+Err
-        return;
-    }
@@ -574 +779 @@
-    if( i_len > p_oggpacket->bytes - 4 )
-    {
-Warn
+Err
-        return;
-    }