X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Fmodules%2Fcore%2Fconsumer_null.c;h=88a7947e9d417eaf15c44fd83f8effe439b6f886;hb=4a16e2d841d4b567d658a35350fe579ea4c8c4ff;hp=ae456b584e10a3936121ce37f49ca3f6df4692b9;hpb=0cbaf64858fe0e9e11b5b14691ff11b7ca8e9027;p=melted

diff --git a/src/modules/core/consumer_null.c b/src/modules/core/consumer_null.c
index ae456b5..88a7947 100644
--- a/src/modules/core/consumer_null.c
+++ b/src/modules/core/consumer_null.c
@@ -67,7 +67,7 @@ mlt_consumer consumer_null_init( char *arg )
 static int consumer_start( mlt_consumer this )
 {
 	// Get the properties
-	mlt_properties properties = mlt_consumer_properties( this );
+	mlt_properties properties = MLT_CONSUMER_PROPERTIES( this );
 
 	// Check that we're not already running
 	if ( !mlt_properties_get_int( properties, "running" ) )
@@ -98,7 +98,7 @@ static int consumer_start( mlt_consumer this )
 static int consumer_stop( mlt_consumer this )
 {
 	// Get the properties
-	mlt_properties properties = mlt_consumer_properties( this );
+	mlt_properties properties = MLT_CONSUMER_PROPERTIES( this );
 
 	// Check that we're running
 	if ( mlt_properties_get_int( properties, "running" ) )
@@ -122,7 +122,7 @@ static int consumer_stop( mlt_consumer this )
 static int consumer_is_stopped( mlt_consumer this )
 {
 	// Get the properties
-	mlt_properties properties = mlt_consumer_properties( this );
+	mlt_properties properties = MLT_CONSUMER_PROPERTIES( this );
 	return !mlt_properties_get_int( properties, "running" );
 }
 
@@ -135,7 +135,7 @@ static void *consumer_thread( void *arg )
 	mlt_consumer this = arg;
 
 	// Get the properties
-	mlt_properties properties = mlt_consumer_properties( this );
+	mlt_properties properties = MLT_CONSUMER_PROPERTIES( this );
 
 	// Frame and size
 	mlt_frame frame = NULL;
@@ -150,10 +150,14 @@ static void *consumer_thread( void *arg )
 		if ( frame != NULL )
 		{
 			// Close the frame
+			mlt_events_fire( properties, "consumer-frame-show", frame, NULL );
 			mlt_frame_close( frame );
 		}
 	}
 
+	// Indicate that the consumer is stopped
+	mlt_consumer_stopped( this );
+
 	return NULL;
 }