aboutsummaryrefslogtreecommitdiffstats
path: root/src/input
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/input/archive_input_plugin.c1
-rw-r--r--src/input/curl_input_plugin.c3
-rw-r--r--src/input/file_input_plugin.c1
-rw-r--r--src/input/mms_input_plugin.c1
-rw-r--r--src/input_plugin.h5
-rw-r--r--src/input_stream.c44
6 files changed, 48 insertions, 7 deletions
diff --git a/src/input/archive_input_plugin.c b/src/input/archive_input_plugin.c
index 31f873aa2..68d790828 100644
--- a/src/input/archive_input_plugin.c
+++ b/src/input/archive_input_plugin.c
@@ -73,5 +73,6 @@ input_archive_open(struct input_stream *is, const char *pathname)
}
const struct input_plugin input_plugin_archive = {
+ .name = "archive",
.open = input_archive_open,
};
diff --git a/src/input/curl_input_plugin.c b/src/input/curl_input_plugin.c
index a80c67d63..21b7144b8 100644
--- a/src/input/curl_input_plugin.c
+++ b/src/input/curl_input_plugin.c
@@ -92,7 +92,7 @@ struct input_curl {
static struct curl_slist *http_200_aliases;
static bool
-input_curl_init(void)
+input_curl_init(G_GNUC_UNUSED const struct config_param *param)
{
CURLcode code = curl_global_init(CURL_GLOBAL_ALL);
if (code != CURLE_OK) {
@@ -954,6 +954,7 @@ input_curl_open(struct input_stream *is, const char *url)
}
const struct input_plugin input_plugin_curl = {
+ .name = "curl",
.init = input_curl_init,
.finish = input_curl_finish,
diff --git a/src/input/file_input_plugin.c b/src/input/file_input_plugin.c
index c857bbd65..c8a5053f8 100644
--- a/src/input/file_input_plugin.c
+++ b/src/input/file_input_plugin.c
@@ -121,6 +121,7 @@ input_file_eof(struct input_stream *is)
}
const struct input_plugin input_plugin_file = {
+ .name = "file",
.open = input_file_open,
.close = input_file_close,
.read = input_file_read,
diff --git a/src/input/mms_input_plugin.c b/src/input/mms_input_plugin.c
index d449d058a..168203a28 100644
--- a/src/input/mms_input_plugin.c
+++ b/src/input/mms_input_plugin.c
@@ -115,6 +115,7 @@ input_mms_seek(G_GNUC_UNUSED struct input_stream *is,
}
const struct input_plugin input_plugin_mms = {
+ .name = "mms",
.open = input_mms_open,
.close = input_mms_close,
.buffer = input_mms_buffer,
diff --git a/src/input_plugin.h b/src/input_plugin.h
index 905596355..6de82653a 100644
--- a/src/input_plugin.h
+++ b/src/input_plugin.h
@@ -25,16 +25,19 @@
#include <stdbool.h>
#include <sys/types.h>
+struct config_param;
struct input_stream;
struct input_plugin {
+ const char *name;
+
/**
* Global initialization. This method is called when MPD starts.
*
* @return true on success, false if the plugin should be
* disabled
*/
- bool (*init)(void);
+ bool (*init)(const struct config_param *param);
/**
* Global deinitialization. Called once before MPD shuts
diff --git a/src/input_stream.c b/src/input_stream.c
index 8896415bb..e07a3ab52 100644
--- a/src/input_stream.c
+++ b/src/input_stream.c
@@ -18,6 +18,7 @@
#include "input_plugin.h"
#include "config.h"
+#include "conf.h"
#include "input/file_input_plugin.h"
@@ -35,6 +36,7 @@
#include <glib.h>
#include <assert.h>
+#include <string.h>
static const struct input_plugin *const input_plugins[] = {
&input_plugin_file,
@@ -54,11 +56,45 @@ static bool input_plugins_enabled[G_N_ELEMENTS(input_plugins)];
static const unsigned num_input_plugins =
sizeof(input_plugins) / sizeof(input_plugins[0]);
+/**
+ * Find the "input" configuration block for the specified plugin.
+ *
+ * @param plugin_name the name of the input plugin
+ * @return the configuration block, or NULL if none was configured
+ */
+static const struct config_param *
+input_plugin_config(const char *plugin_name)
+{
+ const struct config_param *param = NULL;
+
+ while ((param = config_get_next_param(CONF_INPUT, param)) != NULL) {
+ const char *name =
+ config_get_block_string(param, "plugin", NULL);
+ if (name == NULL)
+ g_error("input configuration without 'plugin' name in line %d",
+ param->line);
+
+ if (strcmp(name, plugin_name) == 0)
+ return param;
+ }
+
+ return NULL;
+}
+
void input_stream_global_init(void)
{
- for (unsigned i = 0; i < num_input_plugins; ++i)
- if (input_plugins[i]->init == NULL || input_plugins[i]->init())
+ for (unsigned i = 0; i < num_input_plugins; ++i) {
+ const struct input_plugin *plugin = input_plugins[i];
+ const struct config_param *param =
+ input_plugin_config(plugin->name);
+
+ if (!config_get_block_bool(param, "enabled", true))
+ /* the plugin is disabled in mpd.conf */
+ continue;
+
+ if (plugin->init == NULL || plugin->init(param))
input_plugins_enabled[i] = true;
+ }
}
void input_stream_global_finish(void)
@@ -82,10 +118,8 @@ input_stream_open(struct input_stream *is, const char *url)
for (unsigned i = 0; i < num_input_plugins; ++i) {
const struct input_plugin *plugin = input_plugins[i];
- if (plugin->open(is, url)) {
+ if (input_plugins_enabled[i] && plugin->open(is, url)) {
assert(is->plugin != NULL);
- assert(is->plugin->open == NULL ||
- is->plugin == plugin);
assert(is->plugin->close != NULL);
assert(is->plugin->read != NULL);
assert(is->plugin->eof != NULL);