/*
- * producer_libdv.c -- a DV encoder based on libdv
+ * consumer_libdv.c -- a DV encoder based on libdv
* Copyright (C) 2003-2004 Ushodaya Enterprises Limited
* Author: Charles Yates <charles.yates@pandora.be>
*
// Local header files
#include "consumer_libdv.h"
+#include "producer_libdv.h"
// mlt Header files
#include <framework/mlt_frame.h>
// Assign close callback
this->close = consumer_close;
- // Interpret the constructor argument
- if ( arg == NULL || !strcmp( arg, "PAL" ) )
- mlt_properties_set_double( properties, "fps", 25 );
- else
- mlt_properties_set_double( properties, "fps", 29.97 );
+ // Interpret the argument
+ if ( arg != NULL )
+ mlt_properties_set( properties, "target", arg );
// Set the encode and output handling method
mlt_properties_set_data( properties, "video", consumer_encode_video, 0, NULL, NULL );
{
// Allocate a thread
pthread_t *thread = calloc( 1, sizeof( pthread_t ) );
+ pthread_attr_t thread_attributes;
// Assign the thread to properties
mlt_properties_set_data( properties, "thread", thread, sizeof( pthread_t ), free, NULL );
// Set the running state
mlt_properties_set_int( properties, "running", 1 );
+ // Inherit the scheduling priority
+ pthread_attr_init( &thread_attributes );
+ pthread_attr_setinheritsched( &thread_attributes, PTHREAD_INHERIT_SCHED );
+
// Create the thread
- pthread_create( thread, NULL, consumer_thread, this );
+ pthread_create( thread, &thread_attributes, consumer_thread, this );
}
return 0;
}
// Wait for termination
pthread_join( *thread, NULL );
+
+ // Close the output file :-) - this is obtuse - doesn't matter if output file
+ // exists or not - the destructor will kick in if it does
+ mlt_properties_set_data( properties, "output_file", NULL, 0, NULL, NULL );
}
return 0;
// Store the encoder on the properties
mlt_properties_set_data( this_properties, "dv_encoder", encoder, 0, ( mlt_destructor )dv_encoder_free, NULL );
-
- // Convenience for image dimensions
- mlt_properties_set_int( this_properties, "width", 720 );
- mlt_properties_set_int( this_properties, "height", fps == 25 ? 576 : 480 );
}
// Return the encoder
// This will hold the size of the dv frame
int size = 0;
+ // Is the image rendered
+ int rendered = mlt_properties_get_int( mlt_frame_properties( frame ), "rendered" );
+
+ // Get width and height
+ int width = mlt_properties_get_int( this_properties, "width" );
+ int height = mlt_properties_get_int( this_properties, "height" );
+
// If we get an encoder, then encode the image
- if ( encoder != NULL )
+ if ( rendered && encoder != NULL )
{
// Specify desired image properties
mlt_image_format fmt = mlt_image_yuv422;
- int width = mlt_properties_get_int( this_properties, "width" );
- int height = mlt_properties_get_int( this_properties, "height" );
uint8_t *image = NULL;
- int is_test = 0;
-
- if ( mlt_properties_get( this_properties, "rescale" ) != NULL )
- mlt_properties_set( mlt_frame_properties( frame ), "rescale.interp", mlt_properties_get( this_properties, "rescale" ) );
// Get the image
+ mlt_events_fire( this_properties, "consumer-frame-show", frame, NULL );
mlt_frame_get_image( frame, &image, &fmt, &width, &height, 0 );
- // determine if this a test card
- is_test = mlt_frame_is_test_card( frame );
-
// Check that we get what we expected
if ( fmt != mlt_image_yuv422 ||
width != mlt_properties_get_int( this_properties, "width" ) ||
else
{
// Calculate the size of the dv frame
- size = height == 576 ? frame_size_625_50 : frame_size_525_60;
+ size = height == 576 ? FRAME_SIZE_625_50 : FRAME_SIZE_525_60;
}
// Process the frame
- if ( size != 0 && !( mlt_properties_get_int( this_properties, "was_test_card" ) && is_test ) )
+ if ( size != 0 )
{
- if ( mlt_properties_get_int( mlt_frame_properties( frame ), "top_field_first" ) )
- image += width * 2;
-
// Encode the image
dv_encode_full_frame( encoder, &image, e_dv_color_yuv, dv_frame );
-
- // Note test card status
- mlt_properties_set_int( this_properties, "was_test_card", is_test );
}
}
+ else if ( encoder != NULL )
+ {
+ // Calculate the size of the dv frame (duplicate of previous)
+ size = height == 576 ? FRAME_SIZE_625_50 : FRAME_SIZE_525_60;
+ }
return size;
}
// Default audio args
mlt_audio_format fmt = mlt_audio_pcm;
int channels = 2;
- int frequency = 48000;
+ int frequency = mlt_properties_get_int( this_properties, "frequency" );
int samples = mlt_sample_calculator( mlt_properties_get_double( this_properties, "fps" ), frequency, count );
int16_t *pcm = NULL;
int i = 0;
int j = 0;
for ( i = 0 ; i < 4; i ++ )
- audio_buffers[ i ] = calloc( 1, 2 * DV_AUDIO_MAX_SAMPLES );
+ audio_buffers[ i ] = mlt_pool_alloc( 2 * DV_AUDIO_MAX_SAMPLES );
// Get the audio
mlt_frame_get_audio( frame, &pcm, &fmt, &frequency, &channels, &samples );
for ( j = 0; j < channels; j++ )
audio_buffers[ j ][ i ] = *pcm ++;
}
+ else
+ {
+ for ( j = 0; j < channels; j++ )
+ memset( audio_buffers[ j ], 0, 2 * DV_AUDIO_MAX_SAMPLES );
+ }
// Encode audio on frame
dv_encode_full_audio( encoder, audio_buffers, channels, frequency, dv_frame );
// Temporary - free audio buffers
for ( i = 0 ; i < 4; i ++ )
- free( audio_buffers[ i ] );
+ mlt_pool_release( audio_buffers[ i ] );
}
}
int ( *output )( mlt_consumer, uint8_t *, int, mlt_frame ) = mlt_properties_get_data( properties, "output", NULL );
// Allocate a single PAL frame for encoding
- uint8_t *dv_frame = malloc( frame_size_625_50 );
+ uint8_t *dv_frame = mlt_pool_alloc( FRAME_SIZE_625_50 );
- // Get the service associated to the consumer
- mlt_service service = mlt_consumer_service( this );
-
- // Define a frame pointer
- mlt_frame frame;
+ // Frame and size
+ mlt_frame frame = NULL;
+ int size = 0;
// Loop while running
while( mlt_properties_get_int( properties, "running" ) )
{
// Get the frame
- if ( mlt_service_get_frame( service, &frame, 0 ) == 0 )
+ frame = mlt_consumer_rt_frame( this );
+
+ // Check that we have a frame to work with
+ if ( frame != NULL )
{
// Obtain the dv_encoder
if ( libdv_get_encoder( this, frame ) != NULL )
{
// Encode the image
- int size = video( this, dv_frame, frame );
+ size = video( this, dv_frame, frame );
// Encode the audio
if ( size > 0 )
}
// Tidy up
- free( dv_frame );
+ mlt_pool_release( dv_frame );
+
+ mlt_consumer_stopped( this );
return NULL;
}
// Free the memory
free( this );
}
-