Implemented `LoadDS' which tells plugins to only register their DataSources.

diff --git a/src/apache.c b/src/apache.c
index 887977e..4184247 100644 (file)
--- a/src/apache.c
+++ b/src/apache.c
@@ -354,17 +354,23 @@ static int apache_read (void)
 } /* int apache_read */
 #endif /* APACHE_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&apache_bytes_ds);
-       plugin_register_data_set (&apache_requests_ds);
-       plugin_register_data_set (&apache_scoreboard_ds);
-       plugin_register_data_set (&apache_connections_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&apache_bytes_ds);
+               plugin_register_data_set (&apache_requests_ds);
+               plugin_register_data_set (&apache_scoreboard_ds);
+               plugin_register_data_set (&apache_connections_ds);
+       }
 
 #if APACHE_HAVE_READ
-       plugin_register_config ("apache", config,
-                       config_keys, config_keys_num);
-       plugin_register_init ("apache", init);
-       plugin_register_read ("apache", apache_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("apache", config,
+                               config_keys, config_keys_num);
+               plugin_register_init ("apache", init);
+               plugin_register_read ("apache", apache_read);
+       }
 #endif
-}
+} /* void module_register */

diff --git a/src/apcups.c b/src/apcups.c
index fc94e7d..2539c32 100644 (file)
--- a/src/apcups.c
+++ b/src/apcups.c
@@ -488,16 +488,22 @@ static int apcups_read (void)
        return (0);
 } /* apcups_read */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds_voltage);
-       plugin_register_data_set (&ds_percent);
-       plugin_register_data_set (&ds_timeleft);
-       plugin_register_data_set (&ds_temperature);
-       plugin_register_data_set (&ds_frequency);
-
-       plugin_register_config ("apcups", apcups_config, config_keys, config_keys_num);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&ds_voltage);
+               plugin_register_data_set (&ds_percent);
+               plugin_register_data_set (&ds_timeleft);
+               plugin_register_data_set (&ds_temperature);
+               plugin_register_data_set (&ds_frequency);
+       }
 
-       plugin_register_read ("apcups", apcups_read);
-       plugin_register_shutdown ("apcups", apcups_shutdown);
-}
+       if (load & MR_READ)
+       {
+               plugin_register_config ("apcups", apcups_config, config_keys,
+                               config_keys_num);
+               plugin_register_read ("apcups", apcups_read);
+               plugin_register_shutdown ("apcups", apcups_shutdown);
+       }
+} /* void module_register */

diff --git a/src/apple_sensors.c b/src/apple_sensors.c
index f994b31..6b3cfc5 100644 (file)
--- a/src/apple_sensors.c
+++ b/src/apple_sensors.c
@@ -262,13 +262,19 @@ static int as_read (void)
 } /* int as_read */
 #endif /* IOKIT_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&fanspeed_ds);
-       plugin_register_data_set (&temperature_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&fanspeed_ds);
+               plugin_register_data_set (&temperature_ds);
+       }
 
 #if IOKIT_HAVE_READ
-       plugin_register_init ("apple_sensors", as_init);
-       plugin_register_read ("apple_sensors", as_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("apple_sensors", as_init);
+               plugin_register_read ("apple_sensors", as_read);
+       }
 #endif /* IOKIT_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/battery.c b/src/battery.c
index 53442ce..bdf4619 100644 (file)
--- a/src/battery.c
+++ b/src/battery.c
@@ -555,14 +555,20 @@ static int battery_read (void)
 }
 #endif /* BATTERY_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&charge_ds);
-       plugin_register_data_set (&current_ds);
-       plugin_register_data_set (&voltage_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&charge_ds);
+               plugin_register_data_set (&current_ds);
+               plugin_register_data_set (&voltage_ds);
+       }
 
 #if BATTERY_HAVE_READ
-       plugin_register_init ("battery", battery_init);
-       plugin_register_read ("battery", battery_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("battery", battery_init);
+               plugin_register_read ("battery", battery_read);
+       }
 #endif /* BATTERY_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/configfile.c b/src/configfile.c
index 1d3b895..311ebb3 100644 (file)
--- a/src/configfile.c
+++ b/src/configfile.c
@@ -60,6 +60,7 @@ typedef struct cf_global_option_s
  * Prototypes of callback functions
  */
 static int dispatch_value_plugindir (const oconfig_item_t *ci);
+static int dispatch_value_loadds (const oconfig_item_t *ci);
 static int dispatch_value_loadplugin (const oconfig_item_t *ci);
 
 /*
@@ -70,7 +71,8 @@ static cf_callback_t *first_callback = NULL;
 static cf_value_map_t cf_value_map[] =
 {
        {"PluginDir",  dispatch_value_plugindir},
-       {"LoadPlugin", dispatch_value_loadplugin}
+       {"LoadPlugin", dispatch_value_loadplugin},
+       {"LoadDS", dispatch_value_loadds}
 };
 static int cf_value_map_num = STATIC_ARRAY_LEN (cf_value_map);
 
@@ -182,6 +184,18 @@ static int dispatch_value_plugindir (const oconfig_item_t *ci)
        return (0);
 }
 
+static int dispatch_value_loadds (const oconfig_item_t *ci)
+{
+       assert (strcasecmp (ci->key, "LoadDS") == 0);
+
+       if (ci->values_num != 1)
+               return (-1);
+       if (ci->values[0].type != OCONFIG_TYPE_STRING)
+               return (-1);
+
+       return (plugin_load (ci->values[0].value.string, MR_DATASETS));
+} /* int dispatch_value_loadds */
+
 static int dispatch_value_loadplugin (const oconfig_item_t *ci)
 {
        assert (strcasecmp (ci->key, "LoadPlugin") == 0);
@@ -191,7 +205,7 @@ static int dispatch_value_loadplugin (const oconfig_item_t *ci)
        if (ci->values[0].type != OCONFIG_TYPE_STRING)
                return (-1);
 
-       return (plugin_load (ci->values[0].value.string));
+       return (plugin_load (ci->values[0].value.string, MR_EVERYTHING));
 } /* int dispatch_value_loadplugin */
 
 static int dispatch_value_plugin (const char *plugin, oconfig_item_t *ci)

diff --git a/src/cpu.c b/src/cpu.c
index 1dcbdcd..1dc7865 100644 (file)
--- a/src/cpu.c
+++ b/src/cpu.c
@@ -402,12 +402,16 @@ static int cpu_read (void)
 }
 #endif /* CPU_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
 
 #if CPU_HAVE_READ
-       plugin_register_init ("cpu", init);
-       plugin_register_read ("cpu", cpu_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("cpu", init);
+               plugin_register_read ("cpu", cpu_read);
+       }
 #endif /* CPU_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/cpufreq.c b/src/cpufreq.c
index 5ceaacc..e4caf5f 100644 (file)
--- a/src/cpufreq.c
+++ b/src/cpufreq.c
@@ -155,12 +155,16 @@ static int cpufreq_read (void)
 #endif /* CPUFREQ_HAVE_READ */
 #undef BUFSIZE
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&data_set);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&data_set);
 
 #if CPUFREQ_HAVE_READ
-       plugin_register_init ("cpufreq", cpufreq_init);
-       plugin_register_read ("cpufreq", cpufreq_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("cpufreq", cpufreq_init);
+               plugin_register_read ("cpufreq", cpufreq_read);
+       }
 #endif /* CPUFREQ_HAVE_READ */
 }

diff --git a/src/csv.c b/src/csv.c
index 4379fe5..e67a9ca 100644 (file)
--- a/src/csv.c
+++ b/src/csv.c
@@ -265,9 +265,12 @@ static int csv_write (const data_set_t *ds, const value_list_t *vl)
        return (0);
 } /* int csv_write */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_config ("csv", csv_config,
-                       config_keys, config_keys_num);
-       plugin_register_write ("csv", csv_write);
-}
+       if (load & MR_WRITE)
+       {
+               plugin_register_config ("csv", csv_config,
+                               config_keys, config_keys_num);
+               plugin_register_write ("csv", csv_write);
+       }
+} /* void module_register */

diff --git a/src/df.c b/src/df.c
index 48d58c3..afd3e0b 100644 (file)
--- a/src/df.c
+++ b/src/df.c
@@ -223,13 +223,18 @@ static int df_read (void)
 } /* int df_read */
 #endif /* DF_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
 
 #if DF_HAVE_READ
-       plugin_register_config ("df", df_config, config_keys, config_keys_num);
-       plugin_register_init ("df", df_init);
-       plugin_register_read ("df", df_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("df", df_config,
+                               config_keys, config_keys_num);
+               plugin_register_init ("df", df_init);
+               plugin_register_read ("df", df_read);
+       }
 #endif
 } /* void module_register */

diff --git a/src/disk.c b/src/disk.c
index 2a5b713..c9d2f36 100644 (file)
--- a/src/disk.c
+++ b/src/disk.c
@@ -589,15 +589,21 @@ static int disk_read (void)
 } /* int disk_read */
 #endif /* DISK_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
-       plugin_register_data_set (&operations_ds);
-       plugin_register_data_set (&merged_ds);
-       plugin_register_data_set (&time_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&octets_ds);
+               plugin_register_data_set (&operations_ds);
+               plugin_register_data_set (&merged_ds);
+               plugin_register_data_set (&time_ds);
+       }
 
 #if DISK_HAVE_READ
-       plugin_register_init ("disk", disk_init);
-       plugin_register_read ("disk", disk_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("disk", disk_init);
+               plugin_register_read ("disk", disk_read);
+       }
 #endif /* DISK_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/dns.c b/src/dns.c
index 473003a..c9beb16 100644 (file)
--- a/src/dns.c
+++ b/src/dns.c
@@ -433,16 +433,22 @@ static int dns_read (void)
 } /* int dns_read */
 #endif
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
-       plugin_register_data_set (&qtype_ds);
-       plugin_register_data_set (&opcode_ds);
-       plugin_register_data_set (&rcode_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&octets_ds);
+               plugin_register_data_set (&qtype_ds);
+               plugin_register_data_set (&opcode_ds);
+               plugin_register_data_set (&rcode_ds);
+       }
 
 #if DNS_HAVE_READ
-       plugin_register_config ("dns", dns_config, config_keys, config_keys_num);
-       plugin_register_init ("dns", dns_init);
-       plugin_register_read ("dns", dns_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("dns", dns_config, config_keys, config_keys_num);
+               plugin_register_init ("dns", dns_init);
+               plugin_register_read ("dns", dns_read);
+       }
 #endif
 } /* void module_register */

diff --git a/src/email.c b/src/email.c
index c8c3982..ed58819 100644 (file)
--- a/src/email.c
+++ b/src/email.c
@@ -869,18 +869,23 @@ static int email_read (void)
        return (0);
 } /* int email_read */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&email_count_ds);
-       plugin_register_data_set (&email_size_ds);
-       plugin_register_data_set (&spam_check_ds);
-       plugin_register_data_set (&spam_score_ds);
-
-       plugin_register_config ("email", email_config, config_keys, config_keys_num);
-       plugin_register_init ("email", email_init);
-       plugin_register_read ("email", email_read);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&email_count_ds);
+               plugin_register_data_set (&email_size_ds);
+               plugin_register_data_set (&spam_check_ds);
+               plugin_register_data_set (&spam_score_ds);
+       }
+
+       if (load & MR_READ)
+       {
+               plugin_register_config ("email", email_config, config_keys, config_keys_num);
+               plugin_register_init ("email", email_init);
+               plugin_register_read ("email", email_read);
+       }
        plugin_register_shutdown ("email", email_shutdown);
-} /* void module_register (void) */
+} /* void module_register */
 
 /* vim: set sw=4 ts=4 tw=78 noexpandtab : */
-

diff --git a/src/entropy.c b/src/entropy.c
index 68c57da..fd48c74 100644 (file)
--- a/src/entropy.c
+++ b/src/entropy.c
@@ -88,10 +88,13 @@ static int entropy_read (void)
 }
 #endif /* ENTROPY_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
+
 #if ENTROPY_HAVE_READ
-       plugin_register_read ("entropy", entropy_read);
+       if (load & MR_READ)
+               plugin_register_read ("entropy", entropy_read);
 #endif
-}
+} /* void module_register */

diff --git a/src/exec.c b/src/exec.c
index c7c7202..82c7efa 100644 (file)
--- a/src/exec.c
+++ b/src/exec.c
@@ -356,12 +356,19 @@ static int exec_read (void)
   return (0);
 } /* int exec_read */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-  plugin_register_data_set (&ds_counter);
-  plugin_register_data_set (&ds_gauge);
-  plugin_register_config ("exec", exec_config, config_keys, config_keys_num);
-  plugin_register_read ("exec", exec_read);
+  if (load & MR_DATASETS)
+  {
+    plugin_register_data_set (&ds_counter);
+    plugin_register_data_set (&ds_gauge);
+  }
+
+  if (load & MR_READ)
+  {
+    plugin_register_config ("exec", exec_config, config_keys, config_keys_num);
+    plugin_register_read ("exec", exec_read);
+  }
 } /* void module_register */
 
 /*

diff --git a/src/hddtemp.c b/src/hddtemp.c
index a775861..505d10f 100644 (file)
--- a/src/hddtemp.c
+++ b/src/hddtemp.c
@@ -514,14 +514,18 @@ static int hddtemp_read (void)
 
 /* module_register
    Register collectd plugin. */
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&temperature_ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&temperature_ds);
        
 #if HDDTEMP_HAVE_READ
-       plugin_register_config ("hddtemp", hddtemp_config,
-                       config_keys, config_keys_num);
-       plugin_register_init ("hddtemp", hddtemp_init);
-       plugin_register_read ("hddtemp", hddtemp_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("hddtemp", hddtemp_config,
+                               config_keys, config_keys_num);
+               plugin_register_init ("hddtemp", hddtemp_init);
+               plugin_register_read ("hddtemp", hddtemp_read);
+       }
 #endif /* HDDTEMP_HAVE_READ */
 }

diff --git a/src/interface.c b/src/interface.c
index 308c48f..960cc62 100644 (file)
--- a/src/interface.c
+++ b/src/interface.c
@@ -389,20 +389,25 @@ static int interface_read (void)
 } /* int interface_read */
 #endif /* INTERFACE_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
-       plugin_register_data_set (&packets_ds);
-       plugin_register_data_set (&errors_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&octets_ds);
+               plugin_register_data_set (&packets_ds);
+               plugin_register_data_set (&errors_ds);
+       }
 
        plugin_register_config ("interface", interface_config,
                        config_keys, config_keys_num);
 
+       if (load & MR_READ)
+       {
 #if HAVE_LIBKSTAT
-       plugin_register_init ("interface", interface_init);
+               plugin_register_init ("interface", interface_init);
 #endif
-
 #if INTERFACE_HAVE_READ
-       plugin_register_read ("interface", interface_read);
+               plugin_register_read ("interface", interface_read);
 #endif
-}
+       }
+} /* void module_register */

diff --git a/src/iptables.c b/src/iptables.c
index 47f0e55..1df35fa 100644 (file)
--- a/src/iptables.c
+++ b/src/iptables.c
@@ -358,18 +358,24 @@ static int iptables_shutdown (void)
 } /* int iptables_shutdown */
 #endif /* IPTABLES_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-    plugin_register_data_set (&ipt_bytes_ds);
-    plugin_register_data_set (&ipt_packets_ds);
+    if (load & MR_DATASETS)
+    {
+       plugin_register_data_set (&ipt_bytes_ds);
+       plugin_register_data_set (&ipt_packets_ds);
+    }
 
 #if IPTABLES_HAVE_READ
-    plugin_register_config ("iptables", iptables_config,
-           config_keys, config_keys_num);
-    plugin_register_read ("iptables", iptables_read);
-    plugin_register_shutdown ("iptables", iptables_shutdown);
+    if (load & MR_READ)
+    {
+       plugin_register_config ("iptables", iptables_config,
+               config_keys, config_keys_num);
+       plugin_register_read ("iptables", iptables_read);
+       plugin_register_shutdown ("iptables", iptables_shutdown);
+    }
 #endif
-}
+} /* void module_register */
 
 #undef BUFSIZE
 #undef MODULE_NAME

diff --git a/src/irq.c b/src/irq.c
index e39d0a5..3df9d86 100644 (file)
--- a/src/irq.c
+++ b/src/irq.c
@@ -25,8 +25,6 @@
 #include "plugin.h"
 #include "configfile.h"
 
-#define MODULE_NAME "irq"
-
 #if KERNEL_LINUX
 # define IRQ_HAVE_READ 1
 #else
@@ -216,16 +214,19 @@ static int irq_read (void)
 } /* int irq_read */
 #endif /* IRQ_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds_irq);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds_irq);
 
 #if IRQ_HAVE_READ
-       plugin_register_config ("irq", irq_config,
-                       config_keys, config_keys_num);
-       plugin_register_read ("irq", irq_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("irq", irq_config,
+                               config_keys, config_keys_num);
+               plugin_register_read ("irq", irq_read);
+       }
 #endif /* IRQ_HAVE_READ */
-}
+} /* void module_register */
 
 #undef BUFSIZE
-#undef MODULE_NAME

diff --git a/src/load.c b/src/load.c
index b92e54f..7be594d 100644 (file)
--- a/src/load.c
+++ b/src/load.c
@@ -23,8 +23,6 @@
 #include "common.h"
 #include "plugin.h"
 
-#define MODULE_NAME "load"
-
 #if defined(HAVE_GETLOADAVG) || defined(KERNEL_LINUX) || defined(HAVE_LIBSTATGRAB)
 # define LOAD_HAVE_READ 1
 #else
@@ -151,12 +149,13 @@ static int load_read (void)
 }
 #endif /* LOAD_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
+
 #if LOAD_HAVE_READ
-       plugin_register_read ("load", load_read);
+       if (load & MR_READ)
+               plugin_register_read ("load", load_read);
 #endif
-}
-
-#undef MODULE_NAME
+} /* void module_register */

diff --git a/src/logfile.c b/src/logfile.c
index 4563c89..5cb4091 100644 (file)
--- a/src/logfile.c
+++ b/src/logfile.c
@@ -113,12 +113,11 @@ static void logfile_log (int severity, const char *msg)
        return;
 } /* void logfile_log (int, const char *) */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
        plugin_register_config ("logfile", logfile_config,
                        config_keys, config_keys_num);
        plugin_register_log ("logfile", logfile_log);
-       return;
 } /* void module_register (void) */
 
 /* vim: set sw=4 ts=4 tw=78 noexpandtab : */

diff --git a/src/mbmon.c b/src/mbmon.c
index fcb4cc7..08c49fe 100644 (file)
--- a/src/mbmon.c
+++ b/src/mbmon.c
@@ -339,14 +339,20 @@ static int mbmon_read (void)
 
 /* module_register
    Register collectd plugin. */
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&fanspeed_ds);
-       plugin_register_data_set (&temperature_ds);
-       plugin_register_data_set (&voltage_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&fanspeed_ds);
+               plugin_register_data_set (&temperature_ds);
+               plugin_register_data_set (&voltage_ds);
+       }
 
 #if MBMON_HAVE_READ
-       plugin_register_config ("mbmon", mbmon_config, config_keys, config_keys_num);
-       plugin_register_read ("mbmon", mbmon_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("mbmon", mbmon_config, config_keys, config_keys_num);
+               plugin_register_read ("mbmon", mbmon_read);
+       }
 #endif /* MBMON_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/memory.c b/src/memory.c
index 66bcefa..2187720 100644 (file)
--- a/src/memory.c
+++ b/src/memory.c
@@ -327,12 +327,16 @@ static int memory_read (void)
 }
 #endif /* MEMORY_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
 
 #if MEMORY_HAVE_READ
-       plugin_register_init ("memory", memory_init);
-       plugin_register_read ("memory", memory_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("memory", memory_init);
+               plugin_register_read ("memory", memory_read);
+       }
 #endif /* MEMORY_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/multimeter.c b/src/multimeter.c
index d80c990..02abfc8 100644 (file)
--- a/src/multimeter.c
+++ b/src/multimeter.c
@@ -260,13 +260,17 @@ static int multimeter_shutdown (void)
 }
 #endif /* MULTIMETER_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&data_set);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&data_set);
 
 #if MULTIMETER_HAVE_READ
-       plugin_register_init ("multimeter", multimeter_init);
-       plugin_register_read ("multimeter", multimeter_read);
-       plugin_register_shutdown ("multimeter", multimeter_shutdown);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("multimeter", multimeter_init);
+               plugin_register_read ("multimeter", multimeter_read);
+               plugin_register_shutdown ("multimeter", multimeter_shutdown);
+       }
 #endif /* MULTIMETER_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/mysql.c b/src/mysql.c
index 92b49bf..5fbe5a6 100644 (file)
--- a/src/mysql.c
+++ b/src/mysql.c
@@ -377,16 +377,22 @@ static int mysql_read (void)
 } /* int mysql_read */
 #endif /* MYSQL_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds_commands);
-       plugin_register_data_set (&ds_handler);
-       plugin_register_data_set (&ds_qcache);
-       plugin_register_data_set (&ds_threads);
-       plugin_register_data_set (&ds_octets);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&ds_commands);
+               plugin_register_data_set (&ds_handler);
+               plugin_register_data_set (&ds_qcache);
+               plugin_register_data_set (&ds_threads);
+               plugin_register_data_set (&ds_octets);
+       }
 
 #if MYSQL_HAVE_READ
-       plugin_register_config ("mysql", config, config_keys, config_keys_num);
-       plugin_register_read ("mysql", mysql_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("mysql", config, config_keys, config_keys_num);
+               plugin_register_read ("mysql", mysql_read);
+       }
 #endif /* MYSQL_HAVE_READ */
 } /* void module_register */

diff --git a/src/network.c b/src/network.c
index 6d86c1d..4b50ce2 100644 (file)
--- a/src/network.c
+++ b/src/network.c
@@ -1343,9 +1343,9 @@ static int network_init (void)
        return (0);
 } /* int network_init */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
        plugin_register_config ("network", network_config,
                        config_keys, config_keys_num);
        plugin_register_init   ("network", network_init);
-}
+} /* void module_register */

diff --git a/src/nfs.c b/src/nfs.c
index d54c838..40e4110 100644 (file)
--- a/src/nfs.c
+++ b/src/nfs.c
@@ -24,8 +24,6 @@
 #include "common.h"
 #include "plugin.h"
 
-#define MODULE_NAME "nfs"
-
 /* #if defined(KERNEL_LINUX) || defined(HAVE_LIBKSTAT) */
 #if KERNEL_LINUX
 # define NFS_HAVE_READ 1
@@ -380,13 +378,13 @@ static int nfs_read (void)
 }
 #endif /* NFS_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&procedure_ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&procedure_ds);
 
 #if NFS_HAVE_READ
-       plugin_register_read ("nfs", nfs_read);
+       if (load & MR_READ)
+               plugin_register_read ("nfs", nfs_read);
 #endif
-}
-
-#undef MODULE_NAME
+} /* void module_register */

diff --git a/src/ntpd.c b/src/ntpd.c
index dded360..7f4d62a 100644 (file)
--- a/src/ntpd.c
+++ b/src/ntpd.c
@@ -960,15 +960,22 @@ static int ntpd_read (void)
 } /* int ntpd_read */
 #endif /* NTPD_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&time_offset_ds);
-       plugin_register_data_set (&time_dispersion_ds);
-       plugin_register_data_set (&delay_ds);
-       plugin_register_data_set (&frequency_offset_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&time_offset_ds);
+               plugin_register_data_set (&time_dispersion_ds);
+               plugin_register_data_set (&delay_ds);
+               plugin_register_data_set (&frequency_offset_ds);
+       }
 
 #if NTPD_HAVE_READ
-       plugin_register_config ("ntpd", ntpd_config, config_keys, config_keys_num);
-       plugin_register_read ("ntpd", ntpd_read);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("ntpd", ntpd_config,
+                               config_keys, config_keys_num);
+               plugin_register_read ("ntpd", ntpd_read);
+       }
 #endif /* NTPD_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/ping.c b/src/ping.c
index 7c30a25..6dcd9ec 100644 (file)
--- a/src/ping.c
+++ b/src/ping.c
@@ -239,10 +239,16 @@ static int ping_read (void)
        return (0);
 } /* int ping_read */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
-       plugin_register_init ("ping", ping_init);
-       plugin_register_read ("ping", ping_read);
-       plugin_register_config ("ping", ping_config, config_keys, config_keys_num);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
+
+       if (load & MR_READ)
+       {
+               plugin_register_config ("ping", ping_config,
+                               config_keys, config_keys_num);
+               plugin_register_init ("ping", ping_init);
+               plugin_register_read ("ping", ping_read);
+       }
 } /* void module_register */

diff --git a/src/plugin.c b/src/plugin.c
index 86ffbde..c6762de 100644 (file)
--- a/src/plugin.c
+++ b/src/plugin.c
@@ -118,10 +118,10 @@ static int plugin_unregister (llist_t *list, const char *name)
  * object, but it will bitch about a shared object not having a
  * ``module_register'' symbol..
  */
-static int plugin_load_file (char *file)
+static int plugin_load_file (char *file, modreg_e load)
 {
        lt_dlhandle dlh;
-       void (*reg_handle) (void);
+       void (*reg_handle) (modreg_e mr);
 
        DEBUG ("file = %s", file);
 
@@ -137,7 +137,7 @@ static int plugin_load_file (char *file)
                return (1);
        }
 
-       if ((reg_handle = (void (*) (void)) lt_dlsym (dlh, "module_register")) == NULL)
+       if ((reg_handle = (void (*) (modreg_e)) lt_dlsym (dlh, "module_register")) == NULL)
        {
                WARNING ("Couldn't find symbol ``module_register'' in ``%s'': %s\n",
                                file, lt_dlerror ());
@@ -145,7 +145,7 @@ static int plugin_load_file (char *file)
                return (-1);
        }
 
-       (*reg_handle) ();
+       (*reg_handle) (load);
 
        return (0);
 }
@@ -291,7 +291,7 @@ void plugin_set_dir (const char *dir)
 }
 
 #define BUFSIZE 512
-int plugin_load (const char *type)
+int plugin_load (const char *type, modreg_e mr)
 {
        DIR  *dh;
        const char *dir;
@@ -348,7 +348,7 @@ int plugin_load (const char *type)
                        continue;
                }
 
-               if (plugin_load_file (filename) == 0)
+               if (plugin_load_file (filename, mr) == 0)
                {
                        /* success */
                        ret = 0;

diff --git a/src/plugin.h b/src/plugin.h
index ba6cde2..0164e9c 100644 (file)
--- a/src/plugin.h
+++ b/src/plugin.h
@@ -46,6 +46,15 @@
 /*
  * Public data types
  */
+enum modreg
+{
+       MR_EVERYTHING = 7,
+       MR_DATASETS   = 1,
+       MR_READ       = 2,
+       MR_WRITE      = 4
+};
+typedef enum modreg modreg_e;
+
 typedef unsigned long long counter_t;
 typedef double gauge_t;
 
@@ -119,7 +128,8 @@ void plugin_set_dir (const char *dir);
  *  functions.
  *
  * ARGUMENTS
- *  `type'      Name of the plugin to load.
+ *  `name'      Name of the plugin to load.
+ *  `mr'        Types of functions to request from the plugin.
  *
  * RETURN VALUE
  *  Returns zero upon success, a value greater than zero if no plugin was found
@@ -128,7 +138,7 @@ void plugin_set_dir (const char *dir);
  * NOTES
  *  No attempt is made to re-load an already loaded module.
  */
-int  plugin_load (const char *name);
+int plugin_load (const char *name, modreg_e mr);
 
 void plugin_init_all (void);
 void plugin_read_all (const int *loop);

diff --git a/src/processes.c b/src/processes.c
index 5fd1221..f57f2d3 100644 (file)
--- a/src/processes.c
+++ b/src/processes.c
@@ -1075,21 +1075,26 @@ static int ps_read (void)
 } /* int ps_read */
 #endif /* PROCESSES_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&state_ds);
-       plugin_register_data_set (&rss_ds);
-       plugin_register_data_set (&time_ds);
-       plugin_register_data_set (&count_ds );
-       plugin_register_data_set (&pagefaults_ds );
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&state_ds);
+               plugin_register_data_set (&rss_ds);
+               plugin_register_data_set (&time_ds);
+               plugin_register_data_set (&count_ds);
+               plugin_register_data_set (&pagefaults_ds);
+       }
 
 #if PROCESSES_HAVE_READ
+       if (load & MR_READ)
+       {
 #if HAVE_THREAD_INFO | KERNEL_LINUX
-       plugin_register_config ("processes", ps_config,
-                       config_keys, config_keys_num);
+               plugin_register_config ("processes", ps_config,
+                               config_keys, config_keys_num);
 #endif
-       plugin_register_init ("processes", ps_init);
-       plugin_register_read ("processes", ps_read);
+               plugin_register_init ("processes", ps_init);
+               plugin_register_read ("processes", ps_read);
+       }
 #endif /* PROCESSES_HAVE_READ */
-}
-
+} /* void module_register */

diff --git a/src/rrdtool.c b/src/rrdtool.c
index 6dc14c7..b221341 100644 (file)
--- a/src/rrdtool.c
+++ b/src/rrdtool.c
@@ -817,7 +817,7 @@ static int rrd_init (void)
        return (0);
 } /* int rrd_init */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
        plugin_register_config ("rrdtool", rrd_config,
                        config_keys, config_keys_num);

diff --git a/src/sensors.c b/src/sensors.c
index 4b0fc3d..551d267 100644 (file)
--- a/src/sensors.c
+++ b/src/sensors.c
@@ -449,16 +449,22 @@ static int sensors_read (void)
 } /* int sensors_read */
 #endif /* SENSORS_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&fanspeed_ds);
-       plugin_register_data_set (&temperature_ds);
-       plugin_register_data_set (&voltage_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&fanspeed_ds);
+               plugin_register_data_set (&temperature_ds);
+               plugin_register_data_set (&voltage_ds);
+       }
 
 #if SENSORS_HAVE_READ
-       plugin_register_config ("sensors", sensors_config,
-                       config_keys, config_keys_num);
-       plugin_register_read ("sensors", sensors_read);
-       plugin_register_shutdown ("sensors", sensors_shutdown);
+       if (load & MR_READ)
+       {
+               plugin_register_config ("sensors", sensors_config,
+                               config_keys, config_keys_num);
+               plugin_register_read ("sensors", sensors_read);
+               plugin_register_shutdown ("sensors", sensors_shutdown);
+       }
 #endif
 } /* void module_register */

diff --git a/src/serial.c b/src/serial.c
index 9fb26df..c278672 100644 (file)
--- a/src/serial.c
+++ b/src/serial.c
@@ -136,11 +136,13 @@ static int serial_read (void)
 } /* int serial_read */
 #endif /* SERIAL_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&octets_ds);
 
 #if SERIAL_HAVE_READ
-       plugin_register_read ("serial", serial_read);
+       if (load & MR_READ)
+               plugin_register_read ("serial", serial_read);
 #endif /* SERIAL_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/swap.c b/src/swap.c
index 6b0620c..86bdc35 100644 (file)
--- a/src/swap.c
+++ b/src/swap.c
@@ -312,12 +312,16 @@ static int swap_read (void)
 } /* int swap_read */
 #endif /* SWAP_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&data_set);
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&data_set);
 
 #if SWAP_HAVE_READ
-       plugin_register_init ("swap", swap_init);
-       plugin_register_read ("swap", swap_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("swap", swap_init);
+               plugin_register_read ("swap", swap_read);
+       }
 #endif /* SWAP_HAVE_READ */
-}
+} /* void module_register */

diff --git a/src/syslog.c b/src/syslog.c
index 3123e89..d643e39 100644 (file)
--- a/src/syslog.c
+++ b/src/syslog.c
@@ -86,12 +86,10 @@ static int sl_shutdown (void)
        return (0);
 }
 
-void module_register (void)
+void module_register (modreg_e load)
 {
        plugin_register_config ("syslog", sl_config, config_keys, config_keys_num);
        plugin_register_init ("syslog", sl_init);
        plugin_register_log ("syslog", sl_log);
        plugin_register_shutdown ("syslog", sl_shutdown);
-
-       return;
 } /* void module_register(void) */

diff --git a/src/tape.c b/src/tape.c
index 85a63a8..2345cb3 100644 (file)
--- a/src/tape.c
+++ b/src/tape.c
@@ -162,15 +162,21 @@ static int tape_read (void)
 }
 #endif /* TAPE_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
-       plugin_register_data_set (&operations_ds);
-       plugin_register_data_set (&merged_ds);
-       plugin_register_data_set (&time_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&octets_ds);
+               plugin_register_data_set (&operations_ds);
+               plugin_register_data_set (&merged_ds);
+               plugin_register_data_set (&time_ds);
+       }
 
 #if TAPE_HAVE_READ
-       plugin_register_init ("tape", tape_init);
-       plugin_register_read ("tape", tape_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("tape", tape_init);
+               plugin_register_read ("tape", tape_read);
+       }
 #endif /* TAPE_HAVE_READ */
 }

diff --git a/src/unixsock.c b/src/unixsock.c
index 75f3117..aa5b67c 100644 (file)
--- a/src/unixsock.c
+++ b/src/unixsock.c
@@ -844,7 +844,7 @@ static int us_write (const data_set_t *ds, const value_list_t *vl)
        return (0);
 }
 
-void module_register (void)
+void module_register (modreg_e load)
 {
        plugin_register_config ("unixsock", us_config,
                        config_keys, config_keys_num);

diff --git a/src/users.c b/src/users.c
index 03d6148..e600aab 100644 (file)
--- a/src/users.c
+++ b/src/users.c
@@ -109,9 +109,13 @@ static int users_read (void)
 } /* int users_read */
 #endif /* USERS_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&ds);
-       plugin_register_read ("users", users_read);
-       return;
+       if (load & MR_DATASETS)
+               plugin_register_data_set (&ds);
+
+#if USERS_HAVE_READ
+       if (load & MR_READ)
+               plugin_register_read ("users", users_read);
+#endif
 } /* void module_register(void) */

diff --git a/src/vserver.c b/src/vserver.c
index e4742e9..2e39060 100644 (file)
--- a/src/vserver.c
+++ b/src/vserver.c
@@ -362,17 +362,23 @@ static int vserver_read (void)
 } /* int vserver_read */
 #endif /* VSERVER_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&octets_ds);
-       plugin_register_data_set (&load_ds);
-       plugin_register_data_set (&threads_ds);
-       plugin_register_data_set (&processes_ds);
-       plugin_register_data_set (&memory_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&octets_ds);
+               plugin_register_data_set (&load_ds);
+               plugin_register_data_set (&threads_ds);
+               plugin_register_data_set (&processes_ds);
+               plugin_register_data_set (&memory_ds);
+       }
 
 #if VSERVER_HAVE_READ
-       plugin_register_init ("vserver", vserver_init);
-       plugin_register_read ("vserver", vserver_read);
+       if (load & MR_READ)
+       {
+               plugin_register_init ("vserver", vserver_init);
+               plugin_register_read ("vserver", vserver_read);
+       }
 #endif /* VSERVER_HAVE_READ */
 } /* void module_register(void) */
 

diff --git a/src/wireless.c b/src/wireless.c
index 8ce7854..007272e 100644 (file)
--- a/src/wireless.c
+++ b/src/wireless.c
@@ -167,13 +167,17 @@ static int wireless_read (void)
 } /* int wireless_read */
 #endif /* WIRELESS_HAVE_READ */
 
-void module_register (void)
+void module_register (modreg_e load)
 {
-       plugin_register_data_set (&quality_ds);
-       plugin_register_data_set (&power_ds);
-       plugin_register_data_set (&noise_ds);
+       if (load & MR_DATASETS)
+       {
+               plugin_register_data_set (&quality_ds);
+               plugin_register_data_set (&power_ds);
+               plugin_register_data_set (&noise_ds);
+       }
 
 #if WIRELESS_HAVE_READ
-       plugin_register_read ("wireless", wireless_read);
+       if (load & MR_READ)
+               plugin_register_read ("wireless", wireless_read);
 #endif /* WIRELESS_HAVE_READ */
-}
+} /* void module_register */