X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Fframework%2Fmlt_consumer.h;h=82a08b42ce08e7b2805eb55340465272a13ceb7d;hb=161d5c65021c21fff45ad6e8458bdee36c9d61a3;hp=a3e05b5108995f4a42674ac02b645cc23a10ce20;hpb=3bde0c8a0c130db6d3849a94f60d5b5ad234246e;p=melted diff --git a/src/framework/mlt_consumer.h b/src/framework/mlt_consumer.h index a3e05b5..82a08b4 100644 --- a/src/framework/mlt_consumer.h +++ b/src/framework/mlt_consumer.h @@ -49,11 +49,18 @@ struct mlt_consumer_s pthread_t ahead_thread; pthread_mutex_t mutex; pthread_cond_t cond; + pthread_mutex_t put_mutex; + pthread_cond_t put_cond; + mlt_frame put; + int put_active; }; /** Public final methods */ +#define MLT_CONSUMER_SERVICE( consumer ) ( &( consumer )->parent ) +#define MLT_CONSUMER_PROPERTIES( consumer ) MLT_SERVICE_PROPERTIES( MLT_CONSUMER_SERVICE( consumer ) ) + extern int mlt_consumer_init( mlt_consumer self, void *child ); extern mlt_consumer mlt_consumer_new( ); extern mlt_service mlt_consumer_service( mlt_consumer self ); @@ -61,10 +68,13 @@ extern mlt_properties mlt_consumer_properties( mlt_consumer self ); extern int mlt_consumer_connect( mlt_consumer self, mlt_service producer ); extern int mlt_consumer_start( mlt_consumer self ); extern void mlt_consumer_purge( mlt_consumer self ); +extern int mlt_consumer_put_frame( mlt_consumer self, mlt_frame frame ); extern mlt_frame mlt_consumer_get_frame( mlt_consumer self ); extern mlt_frame mlt_consumer_rt_frame( mlt_consumer self ); extern int mlt_consumer_stop( mlt_consumer self ); extern int mlt_consumer_is_stopped( mlt_consumer self ); +extern void mlt_consumer_stopped( mlt_consumer self ); extern void mlt_consumer_close( mlt_consumer ); +extern int mlt_consumer_profile( mlt_properties properties, char *profile ); #endif