X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fdf.c;h=0f357d8ded8671e7ced051c4b0b01c17760653cd;hb=b6ede5aa427731cfae84225a84af1ed5bc0a4f8e;hp=780197f66fa7a0ec5bfd199167273e44c373c02b;hpb=2d03e4e3df8383b6324845cb24bae021ce76115c;p=collectd.git diff --git a/src/df.c b/src/df.c index 780197f6..0f357d8d 100644 --- a/src/df.c +++ b/src/df.c @@ -1,11 +1,10 @@ /** * collectd - src/df.c - * Copyright (C) 2005 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 - * Free Software Foundation; either version 2 of the License, or (at your - * option) any later version. + * Free Software Foundation; only version 2 of the License is applicable. * * This program is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of @@ -23,94 +22,145 @@ #include "collectd.h" #include "common.h" #include "plugin.h" +#include "configfile.h" #include "utils_mount.h" - -#define MODULE_NAME "df" - -#if HAVE_STATFS || HAVE_STATVFS -# define DF_HAVE_READ 1 +#include "utils_ignorelist.h" + +#if HAVE_STATVFS +# if HAVE_SYS_STATVFS_H +# include +# endif +# define STATANYFS statvfs +# define BLOCKSIZE(s) ((s).f_frsize ? (s).f_frsize : (s).f_bsize) +#elif HAVE_STATFS +# if HAVE_SYS_STATFS_H +# include +# endif +# define STATANYFS statfs +# define BLOCKSIZE(s) (s).f_bsize #else -# define DF_HAVE_READ 0 -#endif - -#if HAVE_STATFS -#define STATANYFS statfs -#define BLOCKSIZE(s) (s).f_bsize - -#elif HAVE_STATVFS -#define STATANYFS statvfs -#define BLOCKSIZE(s) ((s).f_frsize ? (s).f_frsize : (s).f_bsize) +# error "No applicable input method." #endif -static char *filename_template = "df-%s.rrd"; - -/* 104857600 == 100 MB */ -static char *ds_def[] = +static const char *config_keys[] = { - "DS:used:GAUGE:25:0:U", - "DS:free:GAUGE:25:0:U", + "Device", + "MountPoint", + "FSType", + "IgnoreSelected", NULL }; -static int ds_num = 2; +static int config_keys_num = 4; -#define BUFSIZE 512 +static ignorelist_t *il_device = NULL; +static ignorelist_t *il_mountpoint = NULL; +static ignorelist_t *il_fstype = NULL; -static void df_init (void) +static int df_init (void) { - return; + if (il_device == NULL) + il_device = ignorelist_create (1); + if (il_mountpoint == NULL) + il_mountpoint = ignorelist_create (1); + if (il_fstype == NULL) + il_fstype = ignorelist_create (1); + + return (0); } -static void df_write (char *host, char *inst, char *val) +static int df_config (const char *key, const char *value) { - char file[BUFSIZE]; - int status; + df_init (); - status = snprintf (file, BUFSIZE, filename_template, inst); - if (status < 1) - return; - else if (status >= BUFSIZE) - return; + if (strcasecmp (key, "Device") == 0) + { + if (ignorelist_add (il_device, value)) + return (1); + return (0); + } + else if (strcasecmp (key, "MountPoint") == 0) + { + if (ignorelist_add (il_mountpoint, value)) + return (1); + return (0); + } + else if (strcasecmp (key, "FSType") == 0) + { + if (ignorelist_add (il_fstype, value)) + return (1); + return (0); + } + else if (strcasecmp (key, "IgnoreSelected") == 0) + { + if ((strcasecmp (value, "True") == 0) + || (strcasecmp (value, "Yes") == 0) + || (strcasecmp (value, "On") == 0)) + { + ignorelist_set_invert (il_device, 0); + ignorelist_set_invert (il_mountpoint, 0); + ignorelist_set_invert (il_fstype, 0); + } + else + { + ignorelist_set_invert (il_device, 1); + ignorelist_set_invert (il_mountpoint, 1); + ignorelist_set_invert (il_fstype, 1); + } + return (0); + } - rrd_update_file (host, file, val, ds_def, ds_num); + return (-1); } -#if DF_HAVE_READ static void df_submit (char *df_name, - unsigned long long df_used, - unsigned long long df_free) + gauge_t df_used, + gauge_t df_free) { - char buf[BUFSIZE]; + value_t values[2]; + value_list_t vl = VALUE_LIST_INIT; - if (snprintf (buf, BUFSIZE, "%u:%llu:%llu", (unsigned int) curtime, - df_used, df_free) >= BUFSIZE) - return; + values[0].gauge = df_used; + values[1].gauge = df_free; - plugin_submit (MODULE_NAME, df_name, buf); -} + vl.values = values; + vl.values_len = 2; + vl.time = time (NULL); + strcpy (vl.host, hostname_g); + strcpy (vl.plugin, "df"); + strcpy (vl.plugin_instance, ""); + strncpy (vl.type_instance, df_name, sizeof (vl.type_instance)); + + plugin_dispatch_values ("df", &vl); +} /* void df_submit */ -static void df_read (void) +static int df_read (void) { - struct STATANYFS statbuf; +#if HAVE_STATVFS + struct statvfs statbuf; +#elif HAVE_STATFS + struct statfs statbuf; +#endif + /* struct STATANYFS statbuf; */ cu_mount_t *mnt_list; cu_mount_t *mnt_ptr; unsigned long long blocksize; - unsigned long long df_free; - unsigned long long df_used; + gauge_t df_free; + gauge_t df_used; + char mnt_name[256]; mnt_list = NULL; if (cu_mount_getlist (&mnt_list) == NULL) - { - syslog (LOG_WARNING, "cu_mount_getlist returned `NULL'"); - return; - } + return (-1); for (mnt_ptr = mnt_list; mnt_ptr != NULL; mnt_ptr = mnt_ptr->next) { - if (STATANYFS (mnt_ptr->dir, &statbuf) < 0) { - syslog (LOG_ERR, "statv?fs failed: %s", strerror (errno)); + char errbuf[1024]; + ERROR ("statv?fs failed: %s", + sstrerror (errno, errbuf, + sizeof (errbuf))); continue; } @@ -121,20 +171,44 @@ static void df_read (void) df_free = statbuf.f_bfree * blocksize; df_used = (statbuf.f_blocks - statbuf.f_bfree) * blocksize; - syslog (LOG_INFO, "blocksize = %llu, free = %llu, used = %llu, dir = %s", blocksize, df_free, df_used, mnt_ptr->dir); - df_submit ("blahfoo", df_used, df_free); + if (strcmp (mnt_ptr->dir, "/") == 0) + { + strncpy (mnt_name, "root", sizeof (mnt_name)); + } + else + { + int i, len; + + strncpy (mnt_name, mnt_ptr->dir + 1, sizeof (mnt_name)); + len = strlen (mnt_name); + + for (i = 0; i < len; i++) + if (mnt_name[i] == '/') + mnt_name[i] = '-'; + } + + if (ignorelist_match (il_device, + (mnt_ptr->spec_device != NULL) + ? mnt_ptr->spec_device + : mnt_ptr->device)) + continue; + if (ignorelist_match (il_mountpoint, mnt_ptr->dir)) + continue; + if (ignorelist_match (il_fstype, mnt_ptr->type)) + continue; + + df_submit (mnt_name, df_used, df_free); } cu_mount_freelist (mnt_list); -} /* static void df_read (void) */ -#else -# define df_read NULL -#endif /* DF_HAVE_READ */ + + return (0); +} /* int df_read */ void module_register (void) { - plugin_register (MODULE_NAME, df_init, df_read, df_write); -} - -#undef BUFSIZE -#undef MODULE_NAME + plugin_register_config ("df", df_config, + config_keys, config_keys_num); + plugin_register_init ("df", df_init); + plugin_register_read ("df", df_read); +} /* void module_register */