X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Fframework%2Fmlt_consumer.c;h=6c751aa655fb27f5f6953a47e3b8a2738e16a935;hb=7fc1fe0a1e996da9ec4b7ff410a16c3560d60982;hp=635ad651c8e5636cdebc0e6008932f442c7b7c0a;hpb=661165812e3410fe2f6f49d7af882b36a0efcf82;p=melted

diff --git a/src/framework/mlt_consumer.c b/src/framework/mlt_consumer.c
index 635ad65..6c751aa 100644
--- a/src/framework/mlt_consumer.c
+++ b/src/framework/mlt_consumer.c
@@ -42,6 +42,14 @@ mlt_service mlt_consumer_service( mlt_consumer this )
 	return &this->parent;
 }
 
+/** Get the consumer properties.
+*/
+
+mlt_properties mlt_consumer_properties( mlt_consumer this )
+{
+	return mlt_service_properties( &this->parent );
+}
+
 /** Connect the consumer to the producer.
 */
 
@@ -50,13 +58,50 @@ int mlt_consumer_connect( mlt_consumer this, mlt_service producer )
 	return mlt_service_connect_producer( &this->parent, producer, 0 );
 }
 
+/** Start the consumer.
+*/
+
+int mlt_consumer_start( mlt_consumer this )
+{
+	if ( this->start != NULL )
+		return this->start( this );
+	return 0;
+}
+
+/** Stop the consumer.
+*/
+
+int mlt_consumer_stop( mlt_consumer this )
+{
+	if ( this->stop != NULL )
+		return this->stop( this );
+	return 0;
+}
+
+/** Determine if the consumer is stopped.
+*/
+
+int mlt_consumer_is_stopped( mlt_consumer this )
+{
+	if ( this->is_stopped != NULL )
+		return this->is_stopped( this );
+	return 0;
+}
+
 /** Close the consumer.
 */
 
 void mlt_consumer_close( mlt_consumer this )
 {
-	if ( this->close != NULL )
-		this->close( this );
+	// Get the childs close function
+	void ( *consumer_close )( ) = this->close;
+
+	// Make sure it only gets called once
+	this->close = NULL;
+
+	// Call the childs close if available
+	if ( consumer_close != NULL )
+		consumer_close( this );
 	else
 		mlt_service_close( &this->parent );
 }