2 * filter_data_show.c -- data feed filter
3 * Copyright (C) 2004-2005 Ushodaya Enterprises Limited
4 * Author: Charles Yates <charles.yates@pandora.be>
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software Foundation,
18 * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
21 #include "filter_data.h"
22 #include <framework/mlt.h>
26 /** Handle the profile.
29 static mlt_filter obtain_filter( mlt_filter filter, char *type )
32 mlt_filter result = NULL;
34 // Miscelaneous variable
36 int type_len = strlen( type );
38 // Get the properties of the data show filter
39 mlt_properties filter_properties = MLT_FILTER_PROPERTIES( filter );
41 // Get the profile properties
42 mlt_properties profile_properties = mlt_properties_get_data( filter_properties, "profile_properties", NULL );
44 // Obtain the profile_properties if we haven't already
45 if ( profile_properties == NULL )
49 // Get the profile requested
50 char *profile = mlt_properties_get( filter_properties, "resource" );
52 // If none is specified, pick up the default for this normalisation
53 if ( profile == NULL )
54 sprintf( temp, "%s/feeds/%s/data_fx.properties", mlt_factory_prefix( ), mlt_environment( "MLT_NORMALISATION" ) );
55 else if ( strchr( profile, '%' ) )
56 sprintf( temp, "%s/feeds/%s/%s", mlt_factory_prefix( ), mlt_environment( "MLT_NORMALISATION" ), strchr( profile, '%' ) + 1 );
58 strcpy( temp, profile );
60 // Load the specified profile or use the default
61 profile_properties = mlt_properties_load( temp );
63 // Store for later retrieval
64 mlt_properties_set_data( filter_properties, "profile_properties", profile_properties, 0, ( mlt_destructor )mlt_properties_close, NULL );
67 if ( profile_properties != NULL )
69 for ( i = 0; i < mlt_properties_count( profile_properties ); i ++ )
71 char *name = mlt_properties_get_name( profile_properties, i );
72 char *value = mlt_properties_get_value( profile_properties, i );
74 if ( result == NULL && !strcmp( name, type ) && result == NULL )
75 result = mlt_factory_filter( value, NULL );
76 else if ( result != NULL && !strncmp( name, type, type_len ) && name[ type_len ] == '.' )
77 mlt_properties_set( MLT_FILTER_PROPERTIES( result ), name + type_len + 1, value );
78 else if ( result != NULL )
86 /** Process the frame for the requested type
89 static int process_feed( mlt_properties feed, mlt_filter filter, mlt_frame frame )
94 // Get the properties of the data show filter
95 mlt_properties filter_properties = MLT_FILTER_PROPERTIES( filter );
97 // Get the type requested by the feeding filter
98 char *type = mlt_properties_get( feed, "type" );
100 // Fetch the filter associated to this type
101 mlt_filter requested = mlt_properties_get_data( filter_properties, type, NULL );
103 // If it doesn't exist, then create it now
104 if ( requested == NULL )
106 // Source filter from profile
107 requested = obtain_filter( filter, type );
109 // Store it on the properties for subsequent retrieval/destruction
110 mlt_properties_set_data( filter_properties, type, requested, 0, ( mlt_destructor )mlt_filter_close, NULL );
113 // If we have one, then process it now...
114 if ( requested != NULL )
117 mlt_properties properties = MLT_FILTER_PROPERTIES( requested );
118 static char *prefix = "properties.";
119 int len = strlen( prefix );
121 // Determine if this is an absolute or relative feed
122 int absolute = mlt_properties_get_int( feed, "absolute" );
124 // Make do with what we have
125 int length = !absolute ?
126 mlt_properties_get_int( feed, "out" ) - mlt_properties_get_int( feed, "in" ) + 1 :
127 mlt_properties_get_int( feed, "out" ) + 1;
130 int period = mlt_properties_get_int( properties, "period" );
131 period = period == 0 ? 1 : period;
133 // Pass properties from feed into requested
134 for ( i = 0; i < mlt_properties_count( properties ); i ++ )
136 char *name = mlt_properties_get_name( properties, i );
137 char *key = mlt_properties_get_value( properties, i );
138 if ( !strncmp( name, prefix, len ) )
140 if ( !strncmp( name + len, "length[", 7 ) )
142 mlt_properties_set_position( properties, key, length / period );
146 char *value = mlt_properties_get( feed, name + len );
148 mlt_properties_set( properties, key, value );
153 // Set the original position on the frame
155 mlt_frame_set_position( frame, mlt_properties_get_int( feed, "position" ) - mlt_properties_get_int( feed, "in" ) );
157 mlt_frame_set_position( frame, mlt_properties_get_int( feed, "position" ) );
159 // Process the filter
160 mlt_filter_process( requested, frame );
172 static int filter_get_image( mlt_frame frame, uint8_t **image, mlt_image_format *format, int *width, int *height, int writable )
175 mlt_filter filter = mlt_frame_pop_service( frame );
177 // Get the frame properties
178 mlt_properties frame_properties = MLT_FRAME_PROPERTIES( frame );
180 // Fetch the data queue
181 mlt_deque data_queue = mlt_properties_get_data( frame_properties, "data_queue", NULL );
183 // Create a new queue for those that we can't handle
184 mlt_deque temp_queue = mlt_deque_init( );
186 // Iterate through each entry on the queue
187 while ( data_queue != NULL && mlt_deque_peek_front( data_queue ) != NULL )
190 mlt_properties feed = mlt_deque_pop_front( data_queue );
192 // Process the data feed...
193 if ( process_feed( feed, filter, frame ) == 0 )
194 mlt_properties_close( feed );
196 mlt_deque_push_back( temp_queue, feed );
199 // Now put the unprocessed feeds back on the stack
200 while ( data_queue != NULL && mlt_deque_peek_front( temp_queue ) )
203 mlt_properties feed = mlt_deque_pop_front( temp_queue );
205 // Put it back on the data queue
206 mlt_deque_push_back( data_queue, feed );
209 // Close the temporary queue
210 mlt_deque_close( temp_queue );
212 // Need to get the image
213 return mlt_frame_get_image( frame, image, format, width, height, 1 );
217 /** Filter processing.
220 static mlt_frame filter_process( mlt_filter this, mlt_frame frame )
223 mlt_frame_push_service( frame, this );
225 // Register the get image method
226 mlt_frame_push_get_image( frame, filter_get_image );
232 /** Constructor for the filter.
235 mlt_filter filter_data_show_init( char *arg )
238 mlt_filter this = mlt_filter_new( );
243 // Get the properties
244 mlt_properties properties = MLT_FILTER_PROPERTIES( this );
246 // Assign the argument (default to titles)
247 mlt_properties_set( properties, "resource", arg == NULL ? NULL : arg );
249 // Specify the processing method
250 this->process = filter_process;