X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fplugin.h;h=7692ebdb0377eb3212a4c3a2da9931c837202d46;hb=f71467d9c2097ddd9eb772a4fdb985663168ec71;hp=0164e9cf9a2d032bf5c5bf683c64db756047cda2;hpb=6dee31bca87a552017791aa97afa9bd40bc0ebfe;p=collectd.git diff --git a/src/plugin.h b/src/plugin.h index 0164e9cf..7692ebdb 100644 --- a/src/plugin.h +++ b/src/plugin.h @@ -1,9 +1,8 @@ #ifndef PLUGIN_H #define PLUGIN_H - /** * collectd - src/plugin.h - * Copyright (C) 2005,2006 Florian octo Forster + * Copyright (C) 2005-2007 Florian octo Forster * * This program is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by the @@ -22,6 +21,9 @@ * Florian octo Forster **/ +#include "collectd.h" +#include "configfile.h" + #define DATA_MAX_NAME_LEN 64 #define DS_TYPE_COUNTER 0 @@ -46,15 +48,6 @@ /* * 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; @@ -70,6 +63,7 @@ struct value_list_s value_t *values; int values_len; time_t time; + int interval; char host[DATA_MAX_NAME_LEN]; char plugin[DATA_MAX_NAME_LEN]; char plugin_instance[DATA_MAX_NAME_LEN]; @@ -77,7 +71,8 @@ struct value_list_s }; typedef struct value_list_s value_list_t; -#define VALUE_LIST_INIT { NULL, 0, 0, "localhost", "", "", "" } +#define VALUE_LIST_INIT { NULL, 0, 0, interval_g, "localhost", "", "", "" } +#define VALUE_LIST_STATIC { NULL, 0, 0, 0, "localhost", "", "", "" } struct data_source_s { @@ -138,7 +133,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, modreg_e mr); +int plugin_load (const char *name); void plugin_init_all (void); void plugin_read_all (const int *loop); @@ -152,6 +147,8 @@ void plugin_shutdown_all (void); int plugin_register_config (const char *name, int (*callback) (const char *key, const char *val), const char **keys, int keys_num); +int plugin_register_complex_config (const char *type, + int (*callback) (oconfig_item_t *)); int plugin_register_init (const char *name, int (*callback) (void)); int plugin_register_read (const char *name, @@ -165,6 +162,7 @@ int plugin_register_log (char *name, void (*callback) (int, const char *)); int plugin_unregister_config (const char *name); +int plugin_unregister_complex_config (const char *name); int plugin_unregister_init (const char *name); int plugin_unregister_read (const char *name); int plugin_unregister_write (const char *name); @@ -172,6 +170,7 @@ int plugin_unregister_shutdown (const char *name); int plugin_unregister_data_set (const char *name); int plugin_unregister_log (const char *name); + /* * NAME * plugin_dispatch_values @@ -187,14 +186,18 @@ int plugin_unregister_log (const char *name); * `vl' Value list of the values that have been read by a `read' * function. */ -int plugin_dispatch_values (const char *name, const value_list_t *vl); +int plugin_dispatch_values (const char *name, value_list_t *vl); void plugin_log (int level, const char *format, ...); #define ERROR(...) plugin_log (LOG_ERR, __VA_ARGS__) #define WARNING(...) plugin_log (LOG_WARNING, __VA_ARGS__) #define NOTICE(...) plugin_log (LOG_NOTICE, __VA_ARGS__) #define INFO(...) plugin_log (LOG_INFO, __VA_ARGS__) -#define DEBUG(...) plugin_log (LOG_DEBUG, __VA_ARGS__) +#if COLLECT_DEBUG +# define DEBUG(...) plugin_log (LOG_DEBUG, __VA_ARGS__) +#else /* COLLECT_DEBUG */ +# define DEBUG(...) /* noop */ +#endif /* ! COLLECT_DEBUG */ /* TODO: Move plugin_{complain,relief} into `utils_complain.[ch]'. -octo */ void plugin_complain (int level, complain_t *c, const char *format, ...);