+ Mutex protection (temporary work around of SMP systems)
[melted] / src / modules / gtk2 / producer_pango.c
index b6f733c..601525d 100644 (file)
 
 #include "producer_pango.h"
 #include <framework/mlt_frame.h>
+#include <framework/mlt_geometry.h>
 #include <stdlib.h>
 #include <string.h>
 #include <gdk-pixbuf/gdk-pixbuf.h>
 #include <pango/pangoft2.h>
 #include <freetype/freetype.h>
 #include <iconv.h>
+#include <pthread.h>
+
+static pthread_mutex_t pango_mutex = PTHREAD_MUTEX_INITIALIZER;
 
 struct producer_pango_s
 {
@@ -88,6 +92,8 @@ static int alignment_parse( char* align )
        return ret;
 }
 
+static PangoFT2FontMap *fontmap = NULL;
+
 mlt_producer producer_pango_init( const char *filename )
 {
        producer_pango this = calloc( sizeof( struct producer_pango_s ), 1 );
@@ -95,12 +101,15 @@ mlt_producer producer_pango_init( const char *filename )
        {
                mlt_producer producer = &this->parent;
 
+               pthread_mutex_lock( &pango_mutex );
+               if ( fontmap == NULL )
+                       fontmap = (PangoFT2FontMap*) pango_ft2_font_map_new();
+               g_type_init();
+               pthread_mutex_unlock( &pango_mutex );
+
                producer->get_frame = producer_get_frame;
                producer->close = ( mlt_destructor )producer_close;
 
-               // This is required to initialise gdk-pixbuf
-               g_type_init();
-
                // Get the properties interface
                mlt_properties properties = MLT_PRODUCER_PROPERTIES( &this->parent );
 
@@ -131,6 +140,29 @@ mlt_producer producer_pango_init( const char *filename )
                        mlt_properties_set( properties, "markup", markup );
                        free( copy );
                }
+               else if ( strstr( filename, ".mpl" ) ) 
+               {
+                       int i = 0;
+                       mlt_properties contents = mlt_properties_load( filename );
+                       mlt_geometry key_frames = mlt_geometry_init( );
+                       struct mlt_geometry_item_s item;
+                       mlt_properties_set_data( properties, "contents", contents, 0, ( mlt_destructor )mlt_properties_close, NULL );
+                       mlt_properties_set_data( properties, "key_frames", key_frames, 0, ( mlt_destructor )mlt_geometry_close, NULL );
+
+                       // Make sure we have at least one entry
+                       if ( mlt_properties_get( contents, "0" ) == NULL )
+                               mlt_properties_set( contents, "0", "" );
+
+                       for ( i = 0; i < mlt_properties_count( contents ); i ++ )
+                       {
+                               char *name = mlt_properties_get_name( contents, i );
+                               char *value = mlt_properties_get_value( contents, i );
+                               while ( value != NULL && strchr( value, '~' ) )
+                                       ( *strchr( value, '~' ) ) = '\n';
+                               item.frame = atoi( name );
+                               mlt_geometry_insert( key_frames, &item );
+                       }
+               }
                else
                {
                        FILE *f = fopen( filename, "r" );
@@ -295,9 +327,22 @@ static void refresh_image( mlt_frame frame, int width, int height )
        char *encoding = mlt_properties_get( producer_props, "encoding" );
        int weight = mlt_properties_get_int( producer_props, "weight" );
        int size = mlt_properties_get_int( producer_props, "size" );
+       int property_changed = ( align != this->align );
+
+       // Check for file support
+       int position = mlt_properties_get_position( properties, "pango_position" );
+       mlt_properties contents = mlt_properties_get_data( producer_props, "contents", NULL );
+       mlt_geometry key_frames = mlt_properties_get_data( producer_props, "key_frames", NULL );
+       struct mlt_geometry_item_s item;
+       if ( contents != NULL )
+       {
+               char temp[ 20 ];
+               mlt_geometry_prev_key( key_frames, &item, position );
+               sprintf( temp, "%d", item.frame );
+               markup = mlt_properties_get( contents, temp );
+       }
        
        // See if any properties changed
-       int property_changed = ( align != this->align );
        property_changed = property_changed || ( this->fgcolor == NULL || ( fg && strcmp( fg, this->fgcolor ) ) );
        property_changed = property_changed || ( this->bgcolor == NULL || ( bg && strcmp( bg, this->bgcolor ) ) );
        property_changed = property_changed || ( pad != this->pad );
@@ -419,43 +464,60 @@ static int producer_get_image( mlt_frame frame, uint8_t **buffer, mlt_image_form
        // Obtain properties of frame
        mlt_properties properties = MLT_FRAME_PROPERTIES( frame );
 
+       // We need to know the size of the image to clone it
+       int image_size = 0;
+       int alpha_size = 0;
+
+       // Alpha channel
+       uint8_t *alpha = NULL;
+
        *width = mlt_properties_get_int( properties, "rescale_width" );
        *height = mlt_properties_get_int( properties, "rescale_height" );
 
        // Refresh the image
+       pthread_mutex_lock( &pango_mutex );
        refresh_image( frame, *width, *height );
 
-       // Determine format
-       //mlt_producer this = mlt_properties_get_data( properties, "producer_pango", NULL );
-       //*format = ( mlt_properties_get_int( MLT_PRODUCER_PROPERTIES( this ), "bpp" ) == 4 ) ? mlt_image_rgb24a : mlt_image_rgb24;
-
-       // May need to know the size of the image to clone it
-       int size = 0;
-
        // Get the image
-       uint8_t *image = mlt_properties_get_data( properties, "image", &size );
+       *buffer = mlt_properties_get_data( properties, "image", &image_size );
+       alpha = mlt_properties_get_data( properties, "alpha", &alpha_size );
 
        // Get width and height
        *width = mlt_properties_get_int( properties, "width" );
        *height = mlt_properties_get_int( properties, "height" );
 
-       // Clone if necessary
-       if ( writable )
+       // Always clone here to allow 'animated' text
+       if ( *buffer != NULL )
        {
-               // Clone our image
-               uint8_t *copy = mlt_pool_alloc( size );
-               if ( copy != NULL && image != NULL )
-                       memcpy( copy, image, size );
+               // Clone the image and the alpha
+               uint8_t *image_copy = mlt_pool_alloc( image_size );
+               uint8_t *alpha_copy = mlt_pool_alloc( alpha_size );
 
-               // We're going to pass the copy on
-               image = copy;
+               memcpy( image_copy, *buffer, image_size );
+
+               // Copy or default the alpha
+               if ( alpha != NULL )
+                       memcpy( alpha_copy, alpha, alpha_size );
+               else
+                       memset( alpha_copy, 255, alpha_size );
 
                // Now update properties so we free the copy after
-               mlt_properties_set_data( properties, "image", copy, size, ( mlt_destructor )mlt_pool_release, NULL );
+               mlt_properties_set_data( properties, "image", image_copy, image_size, mlt_pool_release, NULL );
+               mlt_properties_set_data( properties, "alpha", alpha_copy, alpha_size, mlt_pool_release, NULL );
+
+               // We're going to pass the copy on
+               *buffer = image_copy;
+       }
+       else
+       {
+               // TODO: Review all cases of invalid images
+               *buffer = mlt_pool_alloc( 50 * 50 * 2 );
+               mlt_properties_set_data( properties, "image", *buffer, image_size, mlt_pool_release, NULL );
+               *width = 50;
+               *height = 50;
        }
 
-       // Pass on the image
-       *buffer = image;
+       pthread_mutex_unlock( &pango_mutex );
 
        return 0;
 }
@@ -482,8 +544,14 @@ static int producer_get_frame( mlt_producer producer, mlt_frame_ptr frame, int i
        // Set the producer on the frame properties
        mlt_properties_set_data( properties, "producer_pango", this, 0, NULL, NULL );
 
+       // Update timecode on the frame we're creating
+       mlt_frame_set_position( *frame, mlt_producer_position( producer ) );
+       mlt_properties_set_position( properties, "pango_position", mlt_producer_frame( producer ) );
+
        // Refresh the pango image
+       pthread_mutex_lock( &pango_mutex );
        refresh_image( *frame, 0, 0 );
+       pthread_mutex_unlock( &pango_mutex );
 
        // Set producer-specific frame properties
        mlt_properties_set_int( properties, "progressive", 1 );
@@ -495,9 +563,6 @@ static int producer_get_frame( mlt_producer producer, mlt_frame_ptr frame, int i
        // Stack the get image callback
        mlt_frame_push_get_image( *frame, producer_get_image );
 
-       // Update timecode on the frame we're creating
-       mlt_frame_set_position( *frame, mlt_producer_position( producer ) );
-
        // Calculate the next timecode
        mlt_producer_prepare_next( producer );
 
@@ -538,13 +603,8 @@ static void pango_draw_background( GdkPixbuf *pixbuf, rgba_color bg )
        }
 }
 
-static PangoFT2FontMap *fontmap = NULL;
-
 static GdkPixbuf *pango_get_pixbuf( const char *markup, const char *text, const char *font, rgba_color fg, rgba_color bg, int pad, int align, int weight, int size )
 {
-       if ( fontmap == NULL )
-               fontmap = (PangoFT2FontMap*) pango_ft2_font_map_new();
-
        PangoContext *context = pango_ft2_font_map_create_context( fontmap );
        PangoLayout *layout = pango_layout_new( context );
        int w, h, x;