Mercurial > mplayer.hg
annotate libaf/af.c @ 9851:6a348d3ed626
A new control called upon stream reset.
author | albeu |
---|---|
date | Sun, 06 Apr 2003 16:34:26 +0000 |
parents | a892e5f051e1 |
children | 2167ac4c1d72 |
rev | line source |
---|---|
7568 | 1 #include <stdio.h> |
2 #include <stdlib.h> | |
3 #include <string.h> | |
4 | |
5 #ifdef HAVE_MALLOC_H | |
6 #include <malloc.h> | |
7 #endif | |
8 | |
9 #include "af.h" | |
10 | |
11 // Static list of filters | |
12 extern af_info_t af_info_dummy; | |
13 extern af_info_t af_info_delay; | |
14 extern af_info_t af_info_channels; | |
15 extern af_info_t af_info_format; | |
16 extern af_info_t af_info_resample; | |
7974
db1f16543379
enable volume filter and fix nonsense default volume (still not usable
rfelker
parents:
7745
diff
changeset
|
17 extern af_info_t af_info_volume; |
8073 | 18 extern af_info_t af_info_equalizer; |
8607 | 19 extern af_info_t af_info_gate; |
20 extern af_info_t af_info_comp; | |
21 extern af_info_t af_info_pan; | |
8678 | 22 extern af_info_t af_info_surround; |
8832
a1578b329cc0
Adding sub-woofer filter, use this filter to add a sub channel to the audio stream
anders
parents:
8711
diff
changeset
|
23 extern af_info_t af_info_sub; |
7568 | 24 |
25 static af_info_t* filter_list[]={ \ | |
26 &af_info_dummy,\ | |
27 &af_info_delay,\ | |
28 &af_info_channels,\ | |
29 &af_info_format,\ | |
30 &af_info_resample,\ | |
7974
db1f16543379
enable volume filter and fix nonsense default volume (still not usable
rfelker
parents:
7745
diff
changeset
|
31 &af_info_volume,\ |
8073 | 32 &af_info_equalizer,\ |
8607 | 33 &af_info_gate,\ |
34 &af_info_comp,\ | |
35 &af_info_pan,\ | |
8678 | 36 &af_info_surround,\ |
8832
a1578b329cc0
Adding sub-woofer filter, use this filter to add a sub channel to the audio stream
anders
parents:
8711
diff
changeset
|
37 &af_info_sub,\ |
7568 | 38 NULL \ |
39 }; | |
40 | |
8167 | 41 // Message printing |
42 af_msg_cfg_t af_msg_cfg={0,NULL,NULL}; | |
43 | |
44 // CPU speed | |
45 int* af_cpu_speed = NULL; | |
46 | |
7568 | 47 /* Find a filter in the static list of filters using it's name. This |
48 function is used internally */ | |
49 af_info_t* af_find(char*name) | |
50 { | |
51 int i=0; | |
52 while(filter_list[i]){ | |
53 if(!strcmp(filter_list[i]->name,name)) | |
54 return filter_list[i]; | |
55 i++; | |
56 } | |
8167 | 57 af_msg(AF_MSG_ERROR,"Couldn't find audio filter '%s'\n",name); |
7568 | 58 return NULL; |
59 } | |
60 | |
7615 | 61 /* Find filter in the dynamic filter list using it's name This |
62 function is used for finding already initialized filters */ | |
63 af_instance_t* af_get(af_stream_t* s, char* name) | |
64 { | |
65 af_instance_t* af=s->first; | |
66 // Find the filter | |
67 while(af != NULL){ | |
68 if(!strcmp(af->info->name,name)) | |
69 return af; | |
70 af=af->next; | |
71 } | |
72 return NULL; | |
73 } | |
74 | |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
75 /*/ Function for creating a new filter of type name. The name may |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
76 contain the commandline parameters for the filter */ |
7615 | 77 af_instance_t* af_create(af_stream_t* s, char* name) |
7568 | 78 { |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
79 char* cmdline = name; |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
80 char* delim = "="; |
7998
d48a06d07afb
Adding commandline options for filters and fixing stupid bug in cfg
anders
parents:
7993
diff
changeset
|
81 |
7568 | 82 // Allocate space for the new filter and reset all pointers |
83 af_instance_t* new=malloc(sizeof(af_instance_t)); | |
84 if(!new){ | |
8607 | 85 af_msg(AF_MSG_ERROR,"[libaf] Could not allocate memory\n"); |
7568 | 86 return NULL; |
87 } | |
88 memset(new,0,sizeof(af_instance_t)); | |
89 | |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
90 // Check for commandline parameters |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
91 strsep(&cmdline, delim); |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
92 |
7568 | 93 // Find filter from name |
7615 | 94 if(NULL == (new->info=af_find(name))) |
95 return NULL; | |
96 | |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
97 /* Make sure that the filter is not already in the list if it is |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
98 non-reentrant */ |
7615 | 99 if(new->info->flags & AF_FLAGS_NOT_REENTRANT){ |
100 if(af_get(s,name)){ | |
8607 | 101 af_msg(AF_MSG_ERROR,"[libaf] There can only be one instance of" |
102 " the filter '%s' in each stream\n",name); | |
7615 | 103 free(new); |
104 return NULL; | |
105 } | |
106 } | |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
107 |
8607 | 108 af_msg(AF_MSG_VERBOSE,"[libaf] Adding filter %s \n",name); |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
109 |
7568 | 110 // Initialize the new filter |
7745
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
111 if(AF_OK == new->info->open(new) && |
7993
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
112 AF_ERROR < new->control(new,AF_CONTROL_POST_CREATE,&s->cfg)){ |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
113 if(cmdline){ |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
114 if(AF_ERROR<new->control(new,AF_CONTROL_COMMAND_LINE,cmdline)) |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
115 return new; |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
116 } |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
117 else |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
118 return new; |
ea0680d87f3f
Changing the behavour of the commandline parameter -af to conform with -vop. Adding new commanline parameter -af-adv for advanced af options. Adding changes to volume control to support commandline parameters.
anders
parents:
7974
diff
changeset
|
119 } |
7745
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
120 |
7568 | 121 free(new); |
8607 | 122 af_msg(AF_MSG_ERROR,"[libaf] Couldn't create or open audio filter '%s'\n", |
123 name); | |
7568 | 124 return NULL; |
125 } | |
126 | |
127 /* Create and insert a new filter of type name before the filter in the | |
128 argument. This function can be called during runtime, the return | |
129 value is the new filter */ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
130 af_instance_t* af_prepend(af_stream_t* s, af_instance_t* af, char* name) |
7568 | 131 { |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
132 // Create the new filter and make sure it is OK |
7615 | 133 af_instance_t* new=af_create(s,name); |
7568 | 134 if(!new) |
135 return NULL; | |
136 // Update pointers | |
137 new->next=af; | |
138 if(af){ | |
139 new->prev=af->prev; | |
140 af->prev=new; | |
141 } | |
142 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
143 s->last=new; |
7568 | 144 if(new->prev) |
145 new->prev->next=new; | |
146 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
147 s->first=new; |
7568 | 148 return new; |
149 } | |
150 | |
151 /* Create and insert a new filter of type name after the filter in the | |
152 argument. This function can be called during runtime, the return | |
153 value is the new filter */ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
154 af_instance_t* af_append(af_stream_t* s, af_instance_t* af, char* name) |
7568 | 155 { |
156 // Create the new filter and make sure it is OK | |
7615 | 157 af_instance_t* new=af_create(s,name); |
7568 | 158 if(!new) |
159 return NULL; | |
160 // Update pointers | |
161 new->prev=af; | |
162 if(af){ | |
163 new->next=af->next; | |
164 af->next=new; | |
165 } | |
166 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
167 s->first=new; |
7568 | 168 if(new->next) |
169 new->next->prev=new; | |
170 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
171 s->last=new; |
7568 | 172 return new; |
173 } | |
174 | |
175 // Uninit and remove the filter "af" | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
176 void af_remove(af_stream_t* s, af_instance_t* af) |
7568 | 177 { |
178 if(!af) return; | |
179 | |
8607 | 180 // Print friendly message |
181 af_msg(AF_MSG_VERBOSE,"[libaf] Removing filter %s \n",af->info->name); | |
182 | |
7745
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
183 // Notify filter before changing anything |
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
184 af->control(af,AF_CONTROL_PRE_DESTROY,0); |
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
185 |
7568 | 186 // Detach pointers |
187 if(af->prev) | |
188 af->prev->next=af->next; | |
189 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
190 s->first=af->next; |
7568 | 191 if(af->next) |
192 af->next->prev=af->prev; | |
193 else | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
194 s->last=af->prev; |
7568 | 195 |
196 // Uninitialize af and free memory | |
197 af->uninit(af); | |
198 free(af); | |
199 } | |
200 | |
7649
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
201 /* Reinitializes all filters downstream from the filter given in the |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
202 argument the return value is AF_OK if success and AF_ERROR if |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
203 failure */ |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
204 int af_reinit(af_stream_t* s, af_instance_t* af) |
7568 | 205 { |
206 if(!af) | |
207 return AF_ERROR; | |
208 | |
209 do{ | |
210 af_data_t in; // Format of the input to current filter | |
211 int rv=0; // Return value | |
212 | |
213 // Check if this is the first filter | |
214 if(!af->prev) | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
215 memcpy(&in,&(s->input),sizeof(af_data_t)); |
7568 | 216 else |
217 memcpy(&in,af->prev->data,sizeof(af_data_t)); | |
218 // Reset just in case... | |
219 in.audio=NULL; | |
220 in.len=0; | |
221 | |
222 rv = af->control(af,AF_CONTROL_REINIT,&in); | |
223 switch(rv){ | |
224 case AF_OK: | |
225 break; | |
226 case AF_FALSE:{ // Configuration filter is needed | |
8167 | 227 // Do auto insertion only if force is not specified |
228 if((AF_INIT_TYPE_MASK & s->cfg.force) != AF_INIT_FORCE){ | |
229 af_instance_t* new = NULL; | |
230 // Insert channels filter | |
231 if((af->prev?af->prev->data->nch:s->input.nch) != in.nch){ | |
232 // Create channels filter | |
233 if(NULL == (new = af_prepend(s,af,"channels"))) | |
234 return AF_ERROR; | |
235 // Set number of output channels | |
236 if(AF_OK != (rv = new->control(new,AF_CONTROL_CHANNELS,&in.nch))) | |
237 return rv; | |
238 // Initialize channels filter | |
239 if(!new->prev) | |
240 memcpy(&in,&(s->input),sizeof(af_data_t)); | |
241 else | |
242 memcpy(&in,new->prev->data,sizeof(af_data_t)); | |
243 if(AF_OK != (rv = new->control(new,AF_CONTROL_REINIT,&in))) | |
244 return rv; | |
245 } | |
246 // Insert format filter | |
247 if(((af->prev?af->prev->data->format:s->input.format) != in.format) || | |
248 ((af->prev?af->prev->data->bps:s->input.bps) != in.bps)){ | |
249 // Create format filter | |
250 if(NULL == (new = af_prepend(s,af,"format"))) | |
251 return AF_ERROR; | |
8607 | 252 // Set output bits per sample |
253 if(AF_OK != (rv = new->control(new,AF_CONTROL_FORMAT_BPS,&in.bps)) || | |
254 AF_OK != (rv = new->control(new,AF_CONTROL_FORMAT_FMT,&in.format))) | |
8167 | 255 return rv; |
256 // Initialize format filter | |
257 if(!new->prev) | |
258 memcpy(&in,&(s->input),sizeof(af_data_t)); | |
259 else | |
260 memcpy(&in,new->prev->data,sizeof(af_data_t)); | |
261 if(AF_OK != (rv = new->control(new,AF_CONTROL_REINIT,&in))) | |
262 return rv; | |
263 } | |
8607 | 264 if(!new){ // Should _never_ happen |
265 af_msg(AF_MSG_ERROR,"[libaf] Unable to correct audio format. " | |
266 "This error should never uccur, please send bugreport.\n"); | |
7568 | 267 return AF_ERROR; |
8607 | 268 } |
8167 | 269 af=new; |
7568 | 270 } |
271 break; | |
272 } | |
273 case AF_DETACH:{ // Filter is redundant and wants to be unloaded | |
8167 | 274 // Do auto remove only if force is not specified |
275 if((AF_INIT_TYPE_MASK & s->cfg.force) != AF_INIT_FORCE){ | |
276 af_instance_t* aft=af->prev; | |
277 af_remove(s,af); | |
278 if(aft) | |
279 af=aft; | |
280 else | |
281 af=s->first; // Restart configuration | |
282 } | |
7568 | 283 break; |
284 } | |
285 default: | |
8607 | 286 af_msg(AF_MSG_ERROR,"[libaf] Reinitialization did not work, audio" |
287 " filter '%s' returned error code %i\n",af->info->name,rv); | |
7568 | 288 return AF_ERROR; |
289 } | |
8607 | 290 // Check if there are any filters left in the list |
291 if(NULL == af){ | |
8711
906f7a2dc085
sig 11 fix in reinit and resample + spelling error fixes
anders
parents:
8678
diff
changeset
|
292 if(!(af=af_append(s,s->first,"dummy"))) |
8607 | 293 return -1; |
294 } | |
295 else | |
296 af=af->next; | |
7568 | 297 }while(af); |
298 return AF_OK; | |
299 } | |
300 | |
301 // Uninit and remove all filters | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
302 void af_uninit(af_stream_t* s) |
7568 | 303 { |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
304 while(s->first) |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
305 af_remove(s,s->first); |
7568 | 306 } |
307 | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
308 /* Initialize the stream "s". This function creates a new filter list |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
309 if necessary according to the values set in input and output. Input |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
310 and output should contain the format of the current movie and the |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
311 formate of the preferred output respectively. The function is |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
312 reentrant i.e. if called with an already initialized stream the |
8969
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
313 stream will be reinitialized. If the binary parameter |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
314 "force_output" is set, the output format will be converted to the |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
315 format given in "s", otherwise the output fromat in the last filter |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
316 will be copied "s". The return value is 0 if success and -1 if |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
317 failure */ |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
318 int af_init(af_stream_t* s, int force_output) |
7568 | 319 { |
320 int i=0; | |
321 | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
322 // Sanity check |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
323 if(!s) return -1; |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
324 |
7568 | 325 // Precaution in case caller is misbehaving |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
326 s->input.audio = s->output.audio = NULL; |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
327 s->input.len = s->output.len = 0; |
7568 | 328 |
329 // Figure out how fast the machine is | |
8167 | 330 if(AF_INIT_AUTO == (AF_INIT_TYPE_MASK & s->cfg.force)) |
331 s->cfg.force = (s->cfg.force & ~AF_INIT_TYPE_MASK) | AF_INIT_TYPE; | |
7568 | 332 |
333 // Check if this is the first call | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
334 if(!s->first){ |
7568 | 335 // Add all filters in the list (if there are any) |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
336 if(!s->cfg.list){ // To make automatic format conversion work |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
337 if(!af_append(s,s->first,"dummy")) |
7568 | 338 return -1; |
339 } | |
340 else{ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
341 while(s->cfg.list[i]){ |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
342 if(!af_append(s,s->last,s->cfg.list[i++])) |
7568 | 343 return -1; |
344 } | |
345 } | |
346 } | |
8607 | 347 |
7568 | 348 // Init filters |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
349 if(AF_OK != af_reinit(s,s->first)) |
7568 | 350 return -1; |
351 | |
8969
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
352 // If force_output isn't set do not compensate for output format |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
353 if(!force_output){ |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
354 memcpy(&s->output, s->last->data, sizeof(af_data_t)); |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
355 return 0; |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
356 } |
a892e5f051e1
Adding support for more logical libaf configuration
anders
parents:
8832
diff
changeset
|
357 |
7568 | 358 // Check output format |
7745
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
359 if((AF_INIT_TYPE_MASK & s->cfg.force) != AF_INIT_FORCE){ |
7568 | 360 af_instance_t* af = NULL; // New filter |
361 // Check output frequency if not OK fix with resample | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
362 if(s->last->data->rate!=s->output.rate){ |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
363 if(NULL==(af=af_get(s,"resample"))){ |
7745
1d3a3dc1f488
Adding volume control and moving control() call parameters to a seperate file
anders
parents:
7665
diff
changeset
|
364 if((AF_INIT_TYPE_MASK & s->cfg.force) == AF_INIT_SLOW){ |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
365 if(!strcmp(s->first->info->name,"format")) |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
366 af = af_append(s,s->first,"resample"); |
7568 | 367 else |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
368 af = af_prepend(s,s->first,"resample"); |
7568 | 369 } |
370 else{ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
371 if(!strcmp(s->last->info->name,"format")) |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
372 af = af_prepend(s,s->last,"resample"); |
7568 | 373 else |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
374 af = af_append(s,s->last,"resample"); |
7568 | 375 } |
376 } | |
377 // Init the new filter | |
8607 | 378 if(!af || (AF_OK != af->control(af,AF_CONTROL_RESAMPLE_RATE, |
379 &(s->output.rate)))) | |
7568 | 380 return -1; |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
381 if(AF_OK != af_reinit(s,af)) |
7568 | 382 return -1; |
383 } | |
384 | |
385 // Check number of output channels fix if not OK | |
386 // If needed always inserted last -> easy to screw up other filters | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
387 if(s->last->data->nch!=s->output.nch){ |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
388 if(!strcmp(s->last->info->name,"format")) |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
389 af = af_prepend(s,s->last,"channels"); |
7568 | 390 else |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
391 af = af_append(s,s->last,"channels"); |
7568 | 392 // Init the new filter |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
393 if(!af || (AF_OK != af->control(af,AF_CONTROL_CHANNELS,&(s->output.nch)))) |
7568 | 394 return -1; |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
395 if(AF_OK != af_reinit(s,af)) |
7568 | 396 return -1; |
397 } | |
398 | |
399 // Check output format fix if not OK | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
400 if((s->last->data->format != s->output.format) || |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
401 (s->last->data->bps != s->output.bps)){ |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
402 if(strcmp(s->last->info->name,"format")) |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
403 af = af_append(s,s->last,"format"); |
7568 | 404 else |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
405 af = s->last; |
7568 | 406 // Init the new filter |
8607 | 407 if(!af ||(AF_OK != af->control(af,AF_CONTROL_FORMAT_BPS,&(s->output.bps))) |
408 || (AF_OK != af->control(af,AF_CONTROL_FORMAT_FMT,&(s->output.format)))) | |
7568 | 409 return -1; |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
410 if(AF_OK != af_reinit(s,af)) |
7568 | 411 return -1; |
412 } | |
413 | |
414 // Re init again just in case | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
415 if(AF_OK != af_reinit(s,s->first)) |
7568 | 416 return -1; |
417 | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
418 if((s->last->data->format != s->output.format) || |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
419 (s->last->data->bps != s->output.bps) || |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
420 (s->last->data->nch != s->output.nch) || |
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
421 (s->last->data->rate != s->output.rate)) { |
7568 | 422 // Something is stuffed audio out will not work |
8607 | 423 af_msg(AF_MSG_ERROR,"[libaf] Unable to setup filter system can not" |
424 " meet sound-card demands, please send bugreport. \n"); | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
425 af_uninit(s); |
7568 | 426 return -1; |
427 } | |
428 } | |
429 return 0; | |
430 } | |
431 | |
7649
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
432 /* Add filter during execution. This function adds the filter "name" |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
433 to the stream s. The filter will be inserted somewhere nice in the |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
434 list of filters. The return value is a pointer to the new filter, |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
435 If the filter couldn't be added the return value is NULL. */ |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
436 af_instance_t* af_add(af_stream_t* s, char* name){ |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
437 af_instance_t* new; |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
438 // Sanity check |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
439 if(!s || !s->first || !name) |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
440 return NULL; |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
441 // Insert the filter somwhere nice |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
442 if(!strcmp(s->first->info->name,"format")) |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
443 new = af_append(s, s->first, name); |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
444 else |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
445 new = af_prepend(s, s->first, name); |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
446 if(!new) |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
447 return NULL; |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
448 |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
449 // Reinitalize the filter list |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
450 if(AF_OK != af_reinit(s, s->first)){ |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
451 free(new); |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
452 return NULL; |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
453 } |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
454 return new; |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
455 } |
90e16aa8ae5f
Adding functionality for adding filters during execution
anders
parents:
7617
diff
changeset
|
456 |
7568 | 457 // Filter data chunk through the filters in the list |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
458 af_data_t* af_play(af_stream_t* s, af_data_t* data) |
7568 | 459 { |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
460 af_instance_t* af=s->first; |
7568 | 461 // Iterate through all filters |
462 do{ | |
463 data=af->play(af,data); | |
464 af=af->next; | |
465 }while(af); | |
466 return data; | |
467 } | |
468 | |
469 /* Helper function used to calculate the exact buffer length needed | |
7589 | 470 when buffers are resized. The returned length is >= than what is |
471 needed */ | |
472 inline int af_lencalc(frac_t mul, af_data_t* d){ | |
473 register int t = d->bps*d->nch; | |
7590 | 474 return t*(((d->len/t)*mul.n)/mul.d + 1); |
7568 | 475 } |
476 | |
477 /* Calculate how long the output from the filters will be given the | |
7589 | 478 input length "len". The calculated length is >= the actual |
479 length. */ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
480 int af_outputlen(af_stream_t* s, int len) |
7568 | 481 { |
7589 | 482 int t = s->input.bps*s->input.nch; |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
483 af_instance_t* af=s->first; |
7589 | 484 register frac_t mul = {1,1}; |
7568 | 485 // Iterate through all filters |
486 do{ | |
487 mul.n *= af->mul.n; | |
488 mul.d *= af->mul.d; | |
489 af=af->next; | |
490 }while(af); | |
7589 | 491 return t * (((len/t)*mul.n + 1)/mul.d); |
7568 | 492 } |
493 | |
494 /* Calculate how long the input to the filters should be to produce a | |
495 certain output length, i.e. the return value of this function is | |
7589 | 496 the input length required to produce the output length "len". The |
497 calculated length is <= the actual length */ | |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
498 int af_inputlen(af_stream_t* s, int len) |
7568 | 499 { |
7589 | 500 int t = s->input.bps*s->input.nch; |
7571
8819fdf88b5d
Adding support for multiple audio streams and removing annoying message from resample and format
anders
parents:
7568
diff
changeset
|
501 af_instance_t* af=s->first; |
7589 | 502 register frac_t mul = {1,1}; |
7568 | 503 // Iterate through all filters |
504 do{ | |
7589 | 505 mul.n *= af->mul.n; |
506 mul.d *= af->mul.d; | |
7568 | 507 af=af->next; |
508 }while(af); | |
7589 | 509 return t * (((len/t) * mul.d - 1)/mul.n); |
7568 | 510 } |
511 | |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
512 /* Calculate how long the input IN to the filters should be to produce |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
513 a certain output length OUT but with the following three constraints: |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
514 1. IN <= max_insize, where max_insize is the maximum possible input |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
515 block length |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
516 2. OUT <= max_outsize, where max_outsize is the maximum possible |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
517 output block length |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
518 3. If possible OUT >= len. |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
519 Return -1 in case of error */ |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
520 int af_calc_insize_constrained(af_stream_t* s, int len, |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
521 int max_outsize,int max_insize) |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
522 { |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
523 int t = s->input.bps*s->input.nch; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
524 int in = 0; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
525 int out = 0; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
526 af_instance_t* af=s->first; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
527 register frac_t mul = {1,1}; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
528 // Iterate through all filters and calculate total multiplication factor |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
529 do{ |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
530 mul.n *= af->mul.n; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
531 mul.d *= af->mul.d; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
532 af=af->next; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
533 }while(af); |
8607 | 534 // Sanity check |
535 if(!mul.n || !mul.d) | |
536 return -1; | |
537 | |
7603
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
538 in = t * (((len/t) * mul.d - 1)/mul.n); |
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
539 |
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
540 if(in>max_insize) in=t*(max_insize/t); |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
541 |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
542 // Try to meet constraint nr 3. |
7612 | 543 while((out=t * (((in/t+1)*mul.n - 1)/mul.d)) <= max_outsize && in<=max_insize){ |
7603
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
544 if( (t * (((in/t)*mul.n))/mul.d) >= len) return in; |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
545 in+=t; |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
546 } |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
547 |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
548 // Could no meet constraint nr 3. |
7603
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
549 while(out > max_outsize || in > max_insize){ |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
550 in-=t; |
7603
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
551 if(in<t) return -1; // Input parameters are probably incorrect |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
552 out = t * (((in/t)*mul.n + 1)/mul.d); |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
553 } |
7603
c89106306f5a
af_calc_insize_constrained() rounding changes, works better for me this way
arpi
parents:
7599
diff
changeset
|
554 return in; |
7598
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
555 } |
48f8c731efb5
Adding function for estimating required buffer length
anders
parents:
7590
diff
changeset
|
556 |
7665
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
557 /* Calculate the total delay [ms] caused by the filters */ |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
558 double af_calc_delay(af_stream_t* s) |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
559 { |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
560 af_instance_t* af=s->first; |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
561 register double delay = 0.0; |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
562 // Iterate through all filters |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
563 while(af){ |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
564 delay += af->delay; |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
565 af=af->next; |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
566 } |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
567 return delay; |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
568 } |
fbd5445cc853
Adding function for calculating the delay caused by the filters
anders
parents:
7649
diff
changeset
|
569 |
7568 | 570 /* Helper function called by the macro with the same name this |
571 function should not be called directly */ | |
572 inline int af_resize_local_buffer(af_instance_t* af, af_data_t* data) | |
573 { | |
574 // Calculate new length | |
7589 | 575 register int len = af_lencalc(af->mul,data); |
8607 | 576 af_msg(AF_MSG_VERBOSE,"[libaf] Reallocating memory in module %s, " |
577 "old len = %i, new len = %i\n",af->info->name,af->data->len,len); | |
7568 | 578 // If there is a buffer free it |
579 if(af->data->audio) | |
580 free(af->data->audio); | |
581 // Create new buffer and check that it is OK | |
582 af->data->audio = malloc(len); | |
583 if(!af->data->audio){ | |
8607 | 584 af_msg(AF_MSG_FATAL,"[libaf] Could not allocate memory \n"); |
7568 | 585 return AF_ERROR; |
586 } | |
587 af->data->len=len; | |
588 return AF_OK; | |
589 } |