Proper error reporting from filter_config

This commit is contained in:
Albin Eldstål-Damlin 2009-12-14 21:46:45 +01:00 committed by Max Kellermann
parent ff3393ebf1
commit 69391dadda
3 changed files with 45 additions and 21 deletions

View File

@ -27,28 +27,43 @@
#include <string.h>
static GQuark
filter_quark(void)
{
return g_quark_from_static_string("filter");
}
/**
* Find the "filter" configuration block for the specified name.
*
* @param filter_template_name the name of the filter template
* @param error_r space to return an error description
* @return the configuration block, or NULL if none was configured
*/
static const struct config_param *
filter_plugin_config(const char *filter_template_name)
filter_plugin_config(const char *filter_template_name, GError **error_r)
{
const struct config_param *param = NULL;
while ((param = config_get_next_param(CONF_AUDIO_FILTER, param)) != NULL) {
const char *name =
config_get_block_string(param, "name", NULL);
if (name == NULL)
g_error("filter configuration without 'name' name in line %d",
if (name == NULL) {
g_set_error(error_r, filter_quark(), 1,
"filter configuration without 'name' name in line %d",
param->line);
return NULL;
}
if (strcmp(name, filter_template_name) == 0)
return param;
}
g_set_error(error_r, filter_quark(), 1,
"filter template not found: %s",
filter_template_name);
return NULL;
}
@ -58,10 +73,11 @@ filter_plugin_config(const char *filter_template_name)
* configured filter sections.
* @param chain the chain to append filters on
* @param spec the filter chain specification
* @param error_r space to return an error description
* @return the number of filters which were successfully added
*/
unsigned int
filter_chain_parse(struct filter *chain, const char *spec)
filter_chain_parse(struct filter *chain, const char *spec, GError **error_r)
{
// Split on comma
@ -80,38 +96,36 @@ filter_chain_parse(struct filter *chain, const char *spec)
// Squeeze whitespace
g_strstrip(*template_names);
cfg = filter_plugin_config(*template_names);
cfg = filter_plugin_config(*template_names, error_r);
if (cfg == NULL) {
g_error("Unable to locate filter template %s",
*template_names);
++template_names;
continue;
// The error has already been set, just stop.
break;
}
// Figure out what kind of a plugin that is
plugin_name = config_get_block_string(cfg, "plugin", NULL);
if (plugin_name == NULL) {
g_error("filter configuration without 'plugin' at line %d",
g_set_error(error_r, filter_quark(), 1,
"filter configuration without 'plugin' at line %d",
cfg->line);
++template_names;
continue;
break;
}
// Instantiate one of those filter plugins with the template name as a hint
fp = filter_plugin_by_name(plugin_name);
if (fp == NULL) {
g_error("filter plugin not found: %s",
g_set_error(error_r, filter_quark(), 2,
"filter plugin not found: %s",
plugin_name);
++template_names;
continue;
break;
}
f = filter_new(fp, cfg, NULL);
if (f == NULL) {
g_error("filter plugin initialization failed: %s",
g_set_error(error_r, filter_quark(), 3,
"filter plugin initialization failed: %s",
plugin_name);
++template_names;
continue;
break;
}
filter_chain_append(chain, f);

View File

@ -38,9 +38,10 @@
* configured filter sections.
* @param chain the chain to append filters on
* @param spec the filter chain specification
* @param error_r space to return an error description
* @return the number of filters which were successfully added
*/
unsigned int
filter_chain_parse(struct filter *chain, const char *spec);
filter_chain_parse(struct filter *chain, const char *spec, GError **error_r);
#endif

View File

@ -193,9 +193,18 @@ audio_output_init(struct audio_output *ao, const struct config_param *param,
ao->filter = filter_chain_new();
assert(ao->filter != NULL);
filter_chain_parse(ao->filter,
config_get_block_string(param, AUDIO_FILTERS, "")
config_get_block_string(param, AUDIO_FILTERS, ""),
&error
);
// It's not really fatal - Part of the filter chain has been set up already
// and even an empty one will work (if only with unexpected behaviour)
if (error != NULL) {
g_warning("Failed to initialize filter chain for '%s': %s",
ao->name, error->message);
g_error_free(error);
}
ao->thread = NULL;
ao->command = AO_COMMAND_NONE;
ao->mutex = g_mutex_new();