static int is_stopped( mlt_consumer consumer );
static void *consumer_thread( void *arg );
static void consumer_close( mlt_consumer consumer );
+static void purge( mlt_consumer consumer );
static mlt_properties normalisers = NULL;
consumer->start = start;
consumer->stop = stop;
consumer->is_stopped = is_stopped;
+ consumer->purge = purge;
}
return consumer;
if ( arg != NULL )
*arg ++ = '\0';
- // The swscale and avcolor_space filters require resolution as arg to test compatibility
- if ( strncmp( effect, "swscale", 7 ) == 0 || strncmp( effect, "avcolo", 6 ) == 0 )
- arg = (char*) mlt_properties_get_int( MLT_SERVICE_PROPERTIES( service ), "meta.media.width" );
-
// We cannot use GLSL-based filters here.
if ( strncmp( effect, "movit.", 6 ) && strncmp( effect, "glsl.", 5 ) )
{
- mlt_filter filter = mlt_factory_filter( profile, id, arg );
- if ( filter != NULL )
+ mlt_filter filter;
+ // The swscale and avcolor_space filters require resolution as arg to test compatibility
+ if ( strncmp( effect, "swscale", 7 ) == 0 || strncmp( effect, "avcolo", 6 ) == 0 )
+ {
+ int width = mlt_properties_get_int( MLT_SERVICE_PROPERTIES( service ), "meta.media.width" );
+ filter = mlt_factory_filter( profile, id, &width );
+ }
+ else
+ {
+ filter = mlt_factory_filter( profile, id, arg );
+ }
+ if ( filter )
{
mlt_properties_set_int( MLT_FILTER_PROPERTIES( filter ), "_loader", 1 );
mlt_service_attach( service, filter );
// put ideal number of samples into cloned frame
int deeply = index > 1 ? 1 : 0;
mlt_frame clone_frame = mlt_frame_clone( frame, deeply );
+ mlt_properties clone_props = MLT_FRAME_PROPERTIES( clone_frame );
int nested_samples = mlt_sample_calculator( nested_fps, frequency, nested_pos );
// -10 is an optimization to avoid tiny amounts of leftover samples
nested_samples = nested_samples > current_samples - 10 ? current_samples : nested_samples;
nested_size = 0;
}
mlt_frame_set_audio( clone_frame, prev_buffer, format, nested_size, mlt_pool_release );
- mlt_properties_set_int( MLT_FRAME_PROPERTIES(clone_frame), "audio_samples", nested_samples );
- mlt_properties_set_int( MLT_FRAME_PROPERTIES(clone_frame), "audio_frequency", frequency );
- mlt_properties_set_int( MLT_FRAME_PROPERTIES(clone_frame), "audio_channels", channels );
+ mlt_properties_set_int( clone_props, "audio_samples", nested_samples );
+ mlt_properties_set_int( clone_props, "audio_frequency", frequency );
+ mlt_properties_set_int( clone_props, "audio_channels", channels );
// chomp the audio
current_samples -= nested_samples;
current_size -= nested_size;
buffer += nested_size;
+ // Fix some things
+ mlt_properties_set_int( clone_props, "meta.media.width",
+ mlt_properties_get_int( MLT_FRAME_PROPERTIES(frame), "width" ) );
+ mlt_properties_set_int( clone_props, "meta.media.height",
+ mlt_properties_get_int( MLT_FRAME_PROPERTIES(frame), "height" ) );
+
// send frame to nested consumer
mlt_consumer_put_frame( nested, clone_frame );
mlt_properties_set_position( nested_props, "_multi_position", ++nested_pos );
return !mlt_properties_get_int( MLT_CONSUMER_PROPERTIES( consumer ), "running" );
}
+/** Purge each of the child consumers.
+*/
+
+static void purge( mlt_consumer consumer )
+{
+ mlt_properties properties = MLT_CONSUMER_PROPERTIES( consumer );
+ if ( mlt_properties_get_int( properties, "running" ) )
+ {
+ mlt_consumer nested = NULL;
+ char key[30];
+ int index = 0;
+
+ do {
+ snprintf( key, sizeof(key), "%d.consumer", index++ );
+ nested = mlt_properties_get_data( properties, key, NULL );
+ if ( nested )
+ mlt_consumer_purge( nested );
+ } while ( nested );
+ }
+}
+
/** The main thread - the argument is simply the consumer.
*/