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
) / 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
);
169 void process_queue( mlt_deque data_queue
, mlt_frame frame
, mlt_filter filter
)
171 if ( data_queue
!= NULL
)
173 // Create a new queue for those that we can't handle
174 mlt_deque temp_queue
= mlt_deque_init( );
176 // Iterate through each entry on the queue
177 while ( mlt_deque_peek_front( data_queue
) != NULL
)
180 mlt_properties feed
= mlt_deque_pop_front( data_queue
);
182 if ( mlt_properties_get( MLT_FILTER_PROPERTIES( filter
), "debug" ) != NULL
)
183 mlt_properties_debug( feed
, mlt_properties_get( MLT_FILTER_PROPERTIES( filter
), "debug" ), stderr
);
185 // Process the data feed...
186 if ( process_feed( feed
, filter
, frame
) == 0 )
187 mlt_properties_close( feed
);
189 mlt_deque_push_back( temp_queue
, feed
);
192 // Now put the unprocessed feeds back on the stack
193 while ( mlt_deque_peek_front( temp_queue
) )
196 mlt_properties feed
= mlt_deque_pop_front( temp_queue
);
198 // Put it back on the data queue
199 mlt_deque_push_back( data_queue
, feed
);
202 // Close the temporary queue
203 mlt_deque_close( temp_queue
);
210 static int filter_get_image( mlt_frame frame
, uint8_t **image
, mlt_image_format
*format
, int *width
, int *height
, int writable
)
213 mlt_filter filter
= mlt_frame_pop_service( frame
);
215 // Get the frame properties
216 mlt_properties frame_properties
= MLT_FRAME_PROPERTIES( frame
);
219 process_queue( mlt_properties_get_data( frame_properties
, "data_queue", NULL
), frame
, filter
);
222 process_queue( mlt_properties_get_data( frame_properties
, "global_queue", NULL
), frame
, filter
);
224 // Need to get the image
225 return mlt_frame_get_image( frame
, image
, format
, width
, height
, 1 );
229 /** Filter processing.
232 static mlt_frame
filter_process( mlt_filter
this, mlt_frame frame
)
235 mlt_frame_push_service( frame
, this );
237 // Register the get image method
238 mlt_frame_push_get_image( frame
, filter_get_image
);
244 /** Constructor for the filter.
247 mlt_filter
filter_data_show_init( char *arg
)
250 mlt_filter
this = mlt_filter_new( );
255 // Get the properties
256 mlt_properties properties
= MLT_FILTER_PROPERTIES( this );
258 // Assign the argument (default to titles)
259 mlt_properties_set( properties
, "resource", arg
== NULL ? NULL
: arg
);
261 // Specify the processing method
262 this->process
= filter_process
;