]> git.sesse.net Git - mlt/blobdiff - src/miracle/miracle_unit.c
Threading considerations and DVCP WIPE introduced
[mlt] / src / miracle / miracle_unit.c
index ba8bf09839b6f94afa982450f48358815d879dee..a6cb7845d7908a4fae5472e9de99dfbf6e301d1b 100644 (file)
@@ -33,6 +33,7 @@
 #include <string.h>
 #include <errno.h>
 #include <signal.h>
+#include <limits.h>
 
 #include <sys/mman.h>
 
@@ -68,7 +69,6 @@ miracle_unit miracle_unit_init( int index, char *constructor )
                mlt_playlist playlist = mlt_playlist_init( );
                this = calloc( sizeof( miracle_unit_t ), 1 );
                this->properties = mlt_properties_new( );
-               this->producers = mlt_properties_new( );
                mlt_properties_init( this->properties, this );
                mlt_properties_set_int( this->properties, "unit", index );
                mlt_properties_set_int( this->properties, "generation", 0 );
@@ -77,12 +77,27 @@ miracle_unit miracle_unit_init( int index, char *constructor )
                mlt_properties_set( this->properties, "arg", arg );
                mlt_properties_set_data( this->properties, "consumer", consumer, 0, ( mlt_destructor )mlt_consumer_close, NULL );
                mlt_properties_set_data( this->properties, "playlist", playlist, 0, ( mlt_destructor )mlt_playlist_close, NULL );
-               mlt_consumer_connect( consumer, mlt_playlist_service( playlist ) );
+               mlt_consumer_connect( consumer, MLT_PLAYLIST_SERVICE( playlist ) );
        }
 
        return this;
 }
 
+static char *strip_root( miracle_unit unit, char *file )
+{
+       mlt_properties properties = unit->properties;
+       char *root = mlt_properties_get( properties, "root" );
+       if ( file != NULL && root != NULL )
+       {
+               int length = strlen( root );
+               if ( root[ length - 1 ] == '/' )
+                       length --;
+               if ( !strncmp( file, root, length ) )
+                       file += length;
+       }
+       return file;
+}
+
 /** Communicate the current status to all threads waiting on the notifier.
 */
 
@@ -116,7 +131,7 @@ void miracle_unit_set_notifier( miracle_unit this, valerie_notifier notifier, ch
 {
        mlt_properties properties = this->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_properties playlist_properties = mlt_playlist_properties( playlist );
+       mlt_properties playlist_properties = MLT_PLAYLIST_PROPERTIES( playlist );
 
        mlt_properties_set( properties, "root", root_dir );
        mlt_properties_set_data( properties, "notifier", notifier, 0, NULL, NULL );
@@ -129,49 +144,9 @@ void miracle_unit_set_notifier( miracle_unit this, valerie_notifier notifier, ch
 /** Create or locate a producer for the file specified.
 */
 
-static mlt_producer create_producer( miracle_unit unit, char *file )
+static mlt_producer locate_producer( miracle_unit unit, char *file )
 {
-       // Get the unit properties
-       mlt_properties properties = unit->producers;
-
-       // Check if we already have loaded this file
-       mlt_producer result = mlt_properties_get_data( properties, file, NULL );
-
-       if ( result == NULL )
-       {
-               // 1st Line preferences
-               if ( strstr( file, ".mpg" ) )
-                       result = mlt_factory_producer( "mcmpeg", file );
-               else if ( strstr( file, ".mpeg" ) )
-                       result = mlt_factory_producer( "mcmpeg", file );
-               else if ( strstr( file, ".dv" ) )
-                       result = mlt_factory_producer( "mcdv", file );
-               else if ( strstr( file, ".dif" ) )
-                       result = mlt_factory_producer( "mcdv", file );
-               else if ( strstr( file, ".jpg" ) )
-                       result = mlt_factory_producer( "pixbuf", file );
-               else if ( strstr( file, ".JPG" ) )
-                       result = mlt_factory_producer( "pixbuf", file );
-               else if ( strstr( file, ".jpeg" ) )
-                       result = mlt_factory_producer( "pixbuf", file );
-               else if ( strstr( file, ".png" ) )
-                       result = mlt_factory_producer( "pixbuf", file );
-       
-               // 2nd Line fallbacks
-               if ( result == NULL && strstr( file, ".dv" ) )
-                       result = mlt_factory_producer( "libdv", file );
-               else if ( result == NULL && strstr( file, ".dif" ) )
-                       result = mlt_factory_producer( "libdv", file );
-       
-               // 3rd line fallbacks 
-               if ( result == NULL )
-                       result = mlt_factory_producer( "ffmpeg", file );
-
-               // Now store the result
-               mlt_properties_set_data( properties, file, result, 0, ( mlt_destructor )mlt_producer_close, NULL );
-       }
-
-       return result;
+       return mlt_factory_producer( "fezzik", file );
 }
 
 /** Update the generation count.
@@ -191,16 +166,64 @@ static void clear_unit( miracle_unit unit )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_producer producer = mlt_playlist_producer( playlist );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
 
+       mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
        mlt_playlist_clear( playlist );
        mlt_producer_seek( producer, 0 );
+       mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
+
+       update_generation( unit );
+}
+
+/** Wipe all but the playing clip from the unit.
+*/
+
+static void clean_unit( miracle_unit unit )
+{
+       mlt_properties properties = unit->properties;
+       mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
+       mlt_playlist_clip_info info;
+       int current = mlt_playlist_current_clip( playlist );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
+       mlt_position position = mlt_producer_frame( producer );
+       double speed = mlt_producer_get_speed( producer );
+       mlt_playlist_get_clip_info( playlist, &info, current );
 
-       if ( unit->old_producers != NULL )
-               mlt_properties_close( unit->old_producers );
-       unit->old_producers = unit->producers;
-       unit->producers = mlt_properties_new( );
+       if ( info.producer != NULL )
+       {
+               mlt_properties_inc_ref( MLT_PRODUCER_PROPERTIES( info.producer ) );
+               position -= info.start;
+               clear_unit( unit );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_playlist_append_io( playlist, info.producer, info.frame_in, info.frame_out );
+               mlt_producer_seek( producer, position );
+               mlt_producer_set_speed( producer, speed );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_producer_close( info.producer );
+       }
+       
+       update_generation( unit );
+}
+
+/** Remove everything up to the current clip from the unit.
+*/
+
+static void wipe_unit( miracle_unit unit )
+{
+       mlt_properties properties = unit->properties;
+       mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
+       mlt_playlist_clip_info info;
+       int current = mlt_playlist_current_clip( playlist );
+       mlt_playlist_get_clip_info( playlist, &info, current );
 
+       if ( info.producer != NULL && info.start > 0 )
+       {
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_playlist_remove_region( playlist, 0, info.start - 1 );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
+       }
+       
        update_generation( unit );
 }
 
@@ -213,22 +236,27 @@ void miracle_unit_report_list( miracle_unit unit, valerie_response response )
        mlt_properties properties = unit->properties;
        int generation = mlt_properties_get_int( properties, "generation" );
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_producer producer = mlt_playlist_producer( playlist );
 
        valerie_response_printf( response, 1024, "%d\n", generation );
                
        for ( i = 0; i < mlt_playlist_count( playlist ); i ++ )
        {
                mlt_playlist_clip_info info;
+               char *title;
                mlt_playlist_get_clip_info( playlist , &info, i );
-               valerie_response_printf( response, 10240, "%d \"%s\" %lld %lld %lld %lld %.2f\n", 
-                                                                i, info.resource, 
+               title = mlt_properties_get( MLT_PRODUCER_PROPERTIES( info.producer ), "title" );
+               if ( title == NULL )
+                       title = strip_root( unit, info.resource );
+               valerie_response_printf( response, 10240, "%d \"%s\" %d %d %d %d %.2f\n", 
+                                                                i, 
+                                                                title,
                                                                 info.frame_in, 
                                                                 info.frame_out,
-                                                                mlt_producer_frame_position( producer, info.playtime )
-                                                                mlt_producer_frame_position( producer, info.length )
+                                                                info.frame_count
+                                                                info.length
                                                                 info.fps );
        }
+       valerie_response_printf( response, 1024, "\n" );
 }
 
 /** Load a clip into the unit clearing existing play list.
@@ -240,39 +268,46 @@ void miracle_unit_report_list( miracle_unit unit, valerie_response response )
        \param out  The ending frame (-1 for maximum)
 */
 
-valerie_error_code miracle_unit_load( miracle_unit unit, char *clip, int64_t in, int64_t out, int flush )
+valerie_error_code miracle_unit_load( miracle_unit unit, char *clip, int32_t in, int32_t out, int flush )
 {
-       // Have to clear the unit first
-       clear_unit( unit );
-
-       // Now try to create an producer
-       mlt_producer instance = create_producer( unit, clip );
+       // Now try to create a producer
+       mlt_producer instance = locate_producer( unit, clip );
 
        if ( instance != NULL )
        {
                mlt_properties properties = unit->properties;
                mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-               mlt_playlist_append_io( playlist, instance, mlt_producer_time( instance, in ), mlt_producer_time( instance, out ) );
+               int original = mlt_producer_get_playtime( MLT_PLAYLIST_PRODUCER( playlist ) );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_playlist_append_io( playlist, instance, in, out );
+               mlt_playlist_remove_region( playlist, 0, original );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
                miracle_log( LOG_DEBUG, "loaded clip %s", clip );
+               update_generation( unit );
                miracle_unit_status_communicate( unit );
+               mlt_producer_close( instance );
                return valerie_ok;
        }
 
        return valerie_invalid_file;
 }
 
-valerie_error_code miracle_unit_insert( miracle_unit unit, char *clip, int index, int64_t in, int64_t out )
+valerie_error_code miracle_unit_insert( miracle_unit unit, char *clip, int index, int32_t in, int32_t out )
 {
-       mlt_producer instance = create_producer( unit, clip );
+       mlt_producer instance = locate_producer( unit, clip );
 
        if ( instance != NULL )
        {
                mlt_properties properties = unit->properties;
                mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-               mlt_playlist_insert( playlist, instance, index, mlt_producer_time( instance, in ), mlt_producer_time( instance, out ) );
+               fprintf( stderr, "inserting clip %s before %d\n", clip, index );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_playlist_insert( playlist, instance, index, in, out );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
                miracle_log( LOG_DEBUG, "inserted clip %s at %d", clip, index );
                update_generation( unit );
                miracle_unit_status_communicate( unit );
+               mlt_producer_close( instance );
                return valerie_ok;
        }
 
@@ -283,7 +318,9 @@ valerie_error_code miracle_unit_remove( miracle_unit unit, int index )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
+       mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
        mlt_playlist_remove( playlist, index );
+       mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
        miracle_log( LOG_DEBUG, "removed clip at %d", index );
        update_generation( unit );
        miracle_unit_status_communicate( unit );
@@ -292,8 +329,27 @@ valerie_error_code miracle_unit_remove( miracle_unit unit, int index )
 
 valerie_error_code miracle_unit_clean( miracle_unit unit )
 {
-       clear_unit( unit );
+       clean_unit( unit );
        miracle_log( LOG_DEBUG, "Cleaned playlist" );
+       miracle_unit_status_communicate( unit );
+       return valerie_ok;
+}
+
+valerie_error_code miracle_unit_wipe( miracle_unit unit )
+{
+       wipe_unit( unit );
+       miracle_log( LOG_DEBUG, "Wiped playlist" );
+       miracle_unit_status_communicate( unit );
+       return valerie_ok;
+}
+
+valerie_error_code miracle_unit_clear( miracle_unit unit )
+{
+       mlt_consumer consumer = mlt_properties_get_data( unit->properties, "consumer", NULL );
+       clear_unit( unit );
+       mlt_consumer_purge( consumer );
+       miracle_log( LOG_DEBUG, "Cleared playlist" );
+       miracle_unit_status_communicate( unit );
        return valerie_ok;
 }
 
@@ -301,7 +357,9 @@ valerie_error_code miracle_unit_move( miracle_unit unit, int src, int dest )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
+       mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
        mlt_playlist_move( playlist, src, dest );
+       mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
        miracle_log( LOG_DEBUG, "moved clip %d to %d", src, dest );
        update_generation( unit );
        miracle_unit_status_communicate( unit );
@@ -317,27 +375,47 @@ valerie_error_code miracle_unit_move( miracle_unit unit, int src, int dest )
        \param out  The ending frame (-1 for maximum)
 */
 
-valerie_error_code miracle_unit_append( miracle_unit unit, char *clip, int64_t in, int64_t out )
+valerie_error_code miracle_unit_append( miracle_unit unit, char *clip, int32_t in, int32_t out )
 {
-       mlt_producer instance = create_producer( unit, clip );
+       mlt_producer instance = locate_producer( unit, clip );
 
        if ( instance != NULL )
        {
                mlt_properties properties = unit->properties;
                mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-               mlt_playlist_append_io( playlist, instance, mlt_producer_time( instance, in ), mlt_producer_time( instance, out ) );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               mlt_playlist_append_io( playlist, instance, in, out );
                miracle_log( LOG_DEBUG, "appended clip %s", clip );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
                update_generation( unit );
                miracle_unit_status_communicate( unit );
+               mlt_producer_close( instance );
                return valerie_ok;
        }
 
        return valerie_invalid_file;
 }
 
-/** Start playing the clip.
+/** Add an mlt_service to the playlist
+
+    \param unit A miracle_unit handle.
+    \param service the service to add
+*/
+
+valerie_error_code miracle_unit_append_service( miracle_unit unit, mlt_service service )
+{
+       mlt_properties properties = unit->properties;
+       mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
+       mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+       mlt_playlist_append( playlist, ( mlt_producer )service );
+       mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
+       miracle_log( LOG_DEBUG, "appended clip" );
+       update_generation( unit );
+       miracle_unit_status_communicate( unit );
+       return valerie_ok;
+}
 
-    Start a dv-pump and commence dv1394 transmission.
+/** Start playing the unit.
 
     \todo error handling
     \param unit A miracle_unit handle.
@@ -349,8 +427,10 @@ void miracle_unit_play( miracle_unit_t *unit, int speed )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_producer producer = mlt_playlist_producer( playlist );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
+       mlt_consumer consumer = mlt_properties_get_data( unit->properties, "consumer", NULL );
        mlt_producer_set_speed( producer, ( double )speed / 1000 );
+       mlt_consumer_start( consumer );
        miracle_unit_status_communicate( unit );
 }
 
@@ -363,6 +443,12 @@ void miracle_unit_play( miracle_unit_t *unit, int speed )
 
 void miracle_unit_terminate( miracle_unit unit )
 {
+       mlt_consumer consumer = mlt_properties_get_data( unit->properties, "consumer", NULL );
+       mlt_playlist playlist = mlt_properties_get_data( unit->properties, "playlist", NULL );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
+       mlt_producer_set_speed( producer, 0 );
+       mlt_consumer_stop( consumer );
+       miracle_unit_status_communicate( unit );
 }
 
 /** Query the status of unit playback.
@@ -373,7 +459,8 @@ void miracle_unit_terminate( miracle_unit unit )
 
 int miracle_unit_has_terminated( miracle_unit unit )
 {
-       return 0;
+       mlt_consumer consumer = mlt_properties_get_data( unit->properties, "consumer", NULL );
+       return mlt_consumer_is_stopped( consumer );
 }
 
 /** Transfer the currently loaded clip to another unit
@@ -381,6 +468,40 @@ int miracle_unit_has_terminated( miracle_unit unit )
 
 int miracle_unit_transfer( miracle_unit dest_unit, miracle_unit src_unit )
 {
+       int i;
+       mlt_properties dest_properties = dest_unit->properties;
+       mlt_playlist dest_playlist = mlt_properties_get_data( dest_properties, "playlist", NULL );
+       mlt_properties src_properties = src_unit->properties;
+       mlt_playlist src_playlist = mlt_properties_get_data( src_properties, "playlist", NULL );
+       mlt_playlist tmp_playlist = mlt_playlist_init( );
+
+       for ( i = 0; i < mlt_playlist_count( src_playlist ); i ++ )
+       {
+               mlt_playlist_clip_info info;
+               mlt_playlist_get_clip_info( src_playlist, &info, i );
+               if ( info.producer != NULL )
+                       mlt_playlist_append_io( tmp_playlist, info.producer, info.frame_in, info.frame_out );
+       }
+
+       clear_unit( src_unit );
+
+       mlt_service_lock( MLT_PLAYLIST_SERVICE( dest_playlist ) );
+
+       for ( i = 0; i < mlt_playlist_count( tmp_playlist ); i ++ )
+       {
+               mlt_playlist_clip_info info;
+               mlt_playlist_get_clip_info( tmp_playlist, &info, i );
+               if ( info.producer != NULL )
+                       mlt_playlist_append_io( dest_playlist, info.producer, info.frame_in, info.frame_out );
+       }
+
+       mlt_service_unlock( MLT_PLAYLIST_SERVICE( dest_playlist ) );
+
+       update_generation( dest_unit );
+       miracle_unit_status_communicate( dest_unit );
+
+       mlt_playlist_close( tmp_playlist );
+
        return 0;
 }
 
@@ -405,7 +526,7 @@ int miracle_unit_get_status( miracle_unit unit, valerie_status status )
        {
                mlt_properties properties = unit->properties;
                mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-               mlt_producer producer = mlt_playlist_producer( playlist );
+               mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
                mlt_producer clip = mlt_playlist_current( playlist );
 
                mlt_playlist_clip_info info;
@@ -414,25 +535,30 @@ int miracle_unit_get_status( miracle_unit unit, valerie_status status )
 
                if ( info.resource != NULL && strcmp( info.resource, "" ) )
                {
-                       strncpy( status->clip, info.resource, sizeof( status->clip ) );
+                       char *title = mlt_properties_get( MLT_PRODUCER_PROPERTIES( info.producer ), "title" );
+                       if ( title == NULL )
+                               title = strip_root( unit, info.resource );
+                       strncpy( status->clip, title, sizeof( status->clip ) );
                        status->speed = (int)( mlt_producer_get_speed( producer ) * 1000.0 );
                        status->fps = mlt_producer_get_fps( producer );
                        status->in = info.frame_in;
                        status->out = info.frame_out;
-                       status->position = mlt_producer_frame_position( producer, mlt_producer_position( clip ) );
-                       status->length = mlt_producer_frame_position( producer, mlt_producer_get_length( clip ) );
-                       strncpy( status->tail_clip, info.resource, sizeof( status->tail_clip ) );
+                       status->position = mlt_producer_frame( clip );
+                       status->length = mlt_producer_get_length( clip );
+                       strncpy( status->tail_clip, title, sizeof( status->tail_clip ) );
                        status->tail_in = info.frame_in;
                        status->tail_out = info.frame_out;
-                       status->tail_position = mlt_producer_frame_position( producer, mlt_producer_position( clip ) );
-                       status->tail_length = mlt_producer_frame_position( producer, mlt_producer_get_length( clip ) );
+                       status->tail_position = mlt_producer_frame( clip );
+                       status->tail_length = mlt_producer_get_length( clip );
                        status->clip_index = mlt_playlist_current_clip( playlist );
                        status->seek_flag = 1;
                }
 
                status->generation = mlt_properties_get_int( properties, "generation" );
 
-               if ( !strcmp( status->clip, "" ) )
+               if ( miracle_unit_has_terminated( unit ) )
+                       status->status = unit_stopped;
+               else if ( !strcmp( status->clip, "" ) )
                        status->status = unit_not_loaded;
                else if ( status->speed == 0 )
                        status->status = unit_paused;
@@ -452,11 +578,11 @@ int miracle_unit_get_status( miracle_unit unit, valerie_status status )
 /** Change position in the playlist.
 */
 
-void miracle_unit_change_position( miracle_unit unit, int clip, int64_t position )
+void miracle_unit_change_position( miracle_unit unit, int clip, int32_t position )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_producer producer = mlt_playlist_producer( playlist );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
        mlt_playlist_clip_info info;
 
        if ( clip < 0 )
@@ -467,13 +593,13 @@ void miracle_unit_change_position( miracle_unit unit, int clip, int64_t position
        else if ( clip >= mlt_playlist_count( playlist ) )
        {
                clip = mlt_playlist_count( playlist ) - 1;
-               position = 999999999999;
+               position = LONG_MAX;
        }
 
        if ( mlt_playlist_get_clip_info( playlist, &info, clip ) == 0 )
        {
-               int64_t frame_start = mlt_producer_frame_position( info.producer, info.start );
-               int64_t frame_offset = position;
+               int32_t frame_start = info.start;
+               int32_t frame_offset = position;
 
                if ( frame_offset < 0 )
                        frame_offset = info.frame_out;
@@ -482,7 +608,7 @@ void miracle_unit_change_position( miracle_unit unit, int clip, int64_t position
                if ( frame_offset >= info.frame_out )
                        frame_offset = info.frame_out;
                
-               mlt_producer_seek_frame( producer, frame_start + frame_offset - info.frame_in );
+               mlt_producer_seek( producer, frame_start + frame_offset - info.frame_in );
        }
 
        miracle_unit_status_communicate( unit );
@@ -502,7 +628,7 @@ int miracle_unit_get_current_clip( miracle_unit unit )
 /** Set a clip's in point
 */
 
-int miracle_unit_set_clip_in( miracle_unit unit, int index, int64_t position )
+int miracle_unit_set_clip_in( miracle_unit unit, int index, int32_t position )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
@@ -511,8 +637,10 @@ int miracle_unit_set_clip_in( miracle_unit unit, int index, int64_t position )
 
        if ( error == 0 )
        {
-               mlt_timecode in = mlt_producer_time( info.producer, position );
-               error = mlt_playlist_resize_clip( playlist, index, in, info.out );
+               miracle_unit_play( unit, 0 );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               error = mlt_playlist_resize_clip( playlist, index, position, info.frame_out );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
                update_generation( unit );
                miracle_unit_change_position( unit, index, 0 );
        }
@@ -523,7 +651,7 @@ int miracle_unit_set_clip_in( miracle_unit unit, int index, int64_t position )
 /** Set a clip's out point.
 */
 
-int miracle_unit_set_clip_out( miracle_unit unit, int index, int64_t position )
+int miracle_unit_set_clip_out( miracle_unit unit, int index, int32_t position )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
@@ -532,8 +660,10 @@ int miracle_unit_set_clip_out( miracle_unit unit, int index, int64_t position )
 
        if ( error == 0 )
        {
-               mlt_timecode out = mlt_producer_time( info.producer, position );
-               error = mlt_playlist_resize_clip( playlist, index, info.in, out );
+               miracle_unit_play( unit, 0 );
+               mlt_service_lock( MLT_PLAYLIST_SERVICE( playlist ) );
+               error = mlt_playlist_resize_clip( playlist, index, info.frame_in, position );
+               mlt_service_unlock( MLT_PLAYLIST_SERVICE( playlist ) );
                update_generation( unit );
                miracle_unit_status_communicate( unit );
                miracle_unit_change_position( unit, index, -1 );
@@ -545,13 +675,13 @@ int miracle_unit_set_clip_out( miracle_unit unit, int index, int64_t position )
 /** Step by specified position.
 */
 
-void miracle_unit_step( miracle_unit unit, int64_t offset )
+void miracle_unit_step( miracle_unit unit, int32_t offset )
 {
        mlt_properties properties = unit->properties;
        mlt_playlist playlist = mlt_properties_get_data( properties, "playlist", NULL );
-       mlt_producer producer = mlt_playlist_producer( playlist );
-       mlt_timecode position = mlt_producer_position( producer );
-       mlt_producer_seek_frame( producer, mlt_producer_frame_position( producer, position ) + offset );
+       mlt_producer producer = MLT_PLAYLIST_PRODUCER( playlist );
+       mlt_position position = mlt_producer_frame( producer );
+       mlt_producer_seek( producer, position + offset );
 }
 
 /** Set the unit's clip mode regarding in and out points.
@@ -593,6 +723,32 @@ void miracle_unit_step( miracle_unit unit, int64_t offset )
        //return dv_player_get_eof_action( player );
 //}
 
+int miracle_unit_set( miracle_unit unit, char *name_value )
+{
+       mlt_properties properties = NULL;
+
+       if ( strncmp( name_value, "consumer.", 9 ) )
+       {
+               mlt_playlist playlist = mlt_properties_get_data( unit->properties, "playlist", NULL );
+               properties = MLT_PLAYLIST_PROPERTIES( playlist );
+       }
+       else
+       {
+               mlt_consumer consumer = mlt_properties_get_data( unit->properties, "consumer", NULL );
+               properties = MLT_CONSUMER_PROPERTIES( consumer );
+               name_value += 9;
+       }
+
+       return mlt_properties_parse( properties, name_value );
+}
+
+char *miracle_unit_get( miracle_unit unit, char *name )
+{
+       mlt_playlist playlist = mlt_properties_get_data( unit->properties, "playlist", NULL );
+       mlt_properties properties = MLT_PLAYLIST_PROPERTIES( playlist );
+       return mlt_properties_get( properties, name );
+}
+
 /** Release the unit
 
     \todo error handling
@@ -604,10 +760,8 @@ void miracle_unit_close( miracle_unit unit )
        if ( unit != NULL )
        {
                miracle_log( LOG_DEBUG, "closing unit..." );
-               if ( unit->old_producers != NULL )
-                       mlt_properties_close( unit->old_producers );
+               miracle_unit_terminate( unit );
                mlt_properties_close( unit->properties );
-               mlt_properties_close( unit->producers );
                free( unit );
                miracle_log( LOG_DEBUG, "... unit closed." );
        }