X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Fframework%2Fmlt_producer.c;h=c07b2b2f8c30c51b026cc738f057719cbd3f7757;hb=80761e7906f1694821044eefb3164b7f07c776e2;hp=8ff5dc1fc8368c6b422f6a5d4573ce08fa17b90c;hpb=52c1bb26fcbb895824cd9237c228ea4834ce1433;p=melted

diff --git a/src/framework/mlt_producer.c b/src/framework/mlt_producer.c
index 8ff5dc1..c07b2b2 100644
--- a/src/framework/mlt_producer.c
+++ b/src/framework/mlt_producer.c
@@ -296,8 +296,18 @@ static int producer_get_frame( mlt_service service, mlt_frame_ptr frame, int ind
 	}
 	else
 	{
+		mlt_properties properties = mlt_producer_properties( this );
+		mlt_filter *filters = mlt_properties_get_data( properties, "_filters", NULL );
+		int count = mlt_properties_get_int( properties, "_filter_count" );
+		int i;
+
 		// Get the frame from the implementation
 		result = this->get_frame( this, frame, index );
+
+		// Process the frame with the attached filters
+		for ( i = 0; i < count; i ++ )
+			if ( filters[ i ] != NULL )
+				mlt_filter_process( filters[ i ], *frame );
 	}
 
 	// Copy the fps and speed of the producer onto the frame
@@ -311,6 +321,96 @@ static int producer_get_frame( mlt_service service, mlt_frame_ptr frame, int ind
 	return 0;
 }
 
+/** Attach a filter.
+*/
+
+int mlt_producer_attach( mlt_producer this, mlt_filter filter )
+{
+	int error = this == NULL || filter == NULL;
+	if ( error == 0 )
+	{
+		int i = 0;
+		int size = 0;
+		mlt_properties properties = mlt_producer_properties( this );
+		mlt_filter *filters = mlt_properties_get_data( properties, "_filters", &size );
+		int count = mlt_properties_get_int( properties, "_filter_count" );
+
+		for ( i = 0; error == 0 && i < count; i ++ )
+			if ( filters[ i ] == filter )
+				error = 1;
+
+		if ( error == 0 )
+		{
+			if ( count == size )
+			{
+				size += 10;
+				filters = realloc( filters, size * sizeof( mlt_filter ) );
+				mlt_properties_set_data( properties, "_filters", filters, size, NULL, NULL );
+			}
+
+			if ( filters != NULL )
+			{
+				mlt_properties_inc_ref( mlt_filter_properties( filter ) );
+				filters[ count ++ ] = filter;
+				mlt_properties_set_int( properties, "_filter_count", count );
+			}
+			else
+			{
+				error = 2;
+			}
+		}
+	}
+	return error;
+}
+
+/** Detach a filter.
+*/
+
+int mlt_producer_detach( mlt_producer this, mlt_filter filter )
+{
+	int error = this == NULL || filter == NULL;
+	if ( error == 0 )
+	{
+		int i = 0;
+		int size = 0;
+		mlt_properties properties = mlt_producer_properties( this );
+		mlt_filter *filters = mlt_properties_get_data( properties, "_filters", &size );
+		int count = mlt_properties_get_int( properties, "_filter_count" );
+
+		for ( i = 0; i < count; i ++ )
+			if ( filters[ i ] == filter )
+				break;
+
+		if ( i < count )
+		{
+			mlt_filter filter = filters[ i ];
+			filters[ i ] = NULL;
+			for ( i ++ ; i < count; i ++ )
+				filters[ i - 1 ] = filters[ i ];
+			mlt_properties_set_int( properties, "_filter_count", -- count );
+			mlt_filter_close( filter );
+		}
+	}
+	return error;
+}
+
+/** Retrieve a filter.
+*/
+
+mlt_filter mlt_producer_filter( mlt_producer this, int index )
+{
+	mlt_filter filter = NULL;
+	if ( this != NULL )
+	{
+		mlt_properties properties = mlt_producer_properties( this );
+		mlt_filter *filters = mlt_properties_get_data( properties, "_filters", NULL );
+		int count = mlt_properties_get_int( properties, "_filter_count" );
+		if ( index >= 0 && index < count )
+			filter = filters[ index ];
+	}
+	return filter;
+}
+
 /** Close the producer.
 */
 
@@ -318,6 +418,13 @@ void mlt_producer_close( mlt_producer this )
 {
 	if ( this != NULL && mlt_properties_dec_ref( mlt_producer_properties( this ) ) <= 0 )
 	{
+		mlt_properties properties = mlt_producer_properties( this );
+		mlt_filter *filters = mlt_properties_get_data( properties, "_filters", NULL );
+		int count = mlt_properties_get_int( properties, "_filter_count" );
+
+		while( count -- )
+			mlt_producer_detach( this, filters[ 0 ] );
+
 		this->parent.close = NULL;
 
 		if ( this->close != NULL )