Add a refresh property to videostab2 filter.

[mlt] / src / modules / resample / filter_resample.c

diff --git a/src/modules/resample/filter_resample.c b/src/modules/resample/filter_resample.c
index 8a4543ee40ffad7ab8839e91d40c3bb7065daccb..c2d56bdba902d1467c7aaac4171db6d3b9da3c4e 100644 (file)
--- a/src/modules/resample/filter_resample.c
+++ b/src/modules/resample/filter_resample.c
@@ -27,7 +27,9 @@
 #include <samplerate.h>
 #include <string.h>
 
-#define BUFFER_LEN 20480
+// BUFFER_LEN is based on a maximum of 96KHz, 5 fps, 8 channels
+// TODO: dynamically allocate larger buffer size
+#define BUFFER_LEN ((96000/5) * 8 * sizeof(float))
 #define RESAMPLE_TYPE SRC_SINC_FASTEST
 
 /** Get the audio.
@@ -43,31 +45,30 @@ static int resample_get_audio( mlt_frame frame, void **buffer, mlt_audio_format
 
        // Get the resample information
        int output_rate = mlt_properties_get_int( filter_properties, "frequency" );
-       int error = 0;
 
        // If no resample frequency is specified, default to requested value
        if ( output_rate == 0 )
                output_rate = *frequency;
 
        // Get the producer's audio
-       if ( *format != mlt_audio_s16 )
-               *format = mlt_audio_float;
-       mlt_frame_get_audio( frame, buffer, format, frequency, channels, samples );
+       int error = mlt_frame_get_audio( frame, buffer, format, frequency, channels, samples );
+       if ( error ) return error;
 
        // Return now if no work to do
-       if ( output_rate != *frequency )
+       if ( output_rate != *frequency && *frequency > 0 && *channels > 0 )
        {
+               mlt_log_debug( MLT_FILTER_SERVICE(filter), "channels %d samples %d frequency %d -> %d\n",
+                       *channels, *samples, *frequency, output_rate );
+
                // Do not convert to float unless we need to change the rate
-               if ( *format != mlt_audio_float )
-               {
-                       *format = mlt_audio_float;
-                       mlt_frame_get_audio( frame, buffer, format, frequency, channels, samples );
-               }
-               float *input_buffer = mlt_properties_get_data( filter_properties, "input_buffer", NULL );
-               float *output_buffer = mlt_properties_get_data( filter_properties, "output_buffer", NULL );
+               if ( *format != mlt_audio_f32le )
+                       frame->convert_audio( frame, buffer, format, mlt_audio_f32le );
+
+               mlt_service_lock( MLT_FILTER_SERVICE(filter) );
+
                SRC_DATA data;
-               data.data_in = input_buffer;
-               data.data_out = output_buffer;
+               data.data_in = *buffer;
+               data.data_out = mlt_properties_get_data( filter_properties, "output_buffer", NULL );
                data.src_ratio = ( float ) output_rate / ( float ) *frequency;
                data.input_frames = *samples;
                data.output_frames = BUFFER_LEN / *channels;
@@ -82,46 +83,20 @@ static int resample_get_audio( mlt_frame frame, void **buffer, mlt_audio_format
                        mlt_properties_set_int( filter_properties, "channels", *channels );
                }
 
-               // Convert to interleaved
-               float *q = (float*) *buffer;
-               float *p = input_buffer;
-               int s, c;
-               for ( s = 0; s < *samples; s++ )
-                       for ( c = 0; c < *channels; c++ )
-                               *p++ = *( q + c * *samples + s );
-
                // Resample the audio
                error = src_process( state, &data );
                if ( !error )
                {
-                       int size = data.output_frames_gen * *channels * sizeof(float);
-
-                       // Resize if necessary
-                       if ( data.output_frames_gen > *samples )
-                       {
-                               *buffer = mlt_pool_realloc( *buffer, size );
-                               mlt_frame_set_audio( frame, *buffer, *format, size, mlt_pool_release );
-                       }
-
-                       // Convert to non-interleaved
-                       p = (float*) *buffer;
-                       for ( c = 0; c < *channels; c++ )
-                       {
-                               float *q = output_buffer + c;
-                               int i = data.output_frames_gen + 1;
-                               while ( --i  )
-                               {
-                                       *p++ = *q;
-                                       q += *channels;
-                               }
-                       }
-
                        // Update output variables
                        *samples = data.output_frames_gen;
                        *frequency = output_rate;
+                       *buffer = data.data_out;
                }
                else
+               {
                        mlt_log_error( MLT_FILTER_SERVICE( filter ), "%s %d,%d,%d\n", src_strerror( error ), *frequency, *samples, output_rate );
+               }
+               mlt_service_unlock( MLT_FILTER_SERVICE(filter) );
        }
 
        return error;
@@ -153,14 +128,12 @@ mlt_filter filter_resample_init( mlt_profile profile, mlt_service_type type, con
                SRC_STATE *state = src_new( RESAMPLE_TYPE, 2 /* channels */, &error );
                if ( error == 0 )
                {
-                       void *input_buffer = mlt_pool_alloc( BUFFER_LEN );
                        void *output_buffer = mlt_pool_alloc( BUFFER_LEN );
                        this->process = filter_process;
                        if ( arg != NULL )
                                mlt_properties_set_int( MLT_FILTER_PROPERTIES( this ), "frequency", atoi( arg ) );
                        mlt_properties_set_int( MLT_FILTER_PROPERTIES( this ), "channels", 2 );
                        mlt_properties_set_data( MLT_FILTER_PROPERTIES( this ), "state", state, 0, (mlt_destructor)src_delete, NULL );
-                       mlt_properties_set_data( MLT_FILTER_PROPERTIES( this ), "input_buffer", input_buffer, BUFFER_LEN, mlt_pool_release, NULL );
                        mlt_properties_set_data( MLT_FILTER_PROPERTIES( this ), "output_buffer", output_buffer, BUFFER_LEN, mlt_pool_release, NULL );
                }
                else