X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fusers.c;h=afe26e1e27fc27a3d155b135b56d3571290bcd46;hb=633c3966f770e4d46651a2fe219a18d8a9907a9f;hp=e600aab3ae01e36b33b2946db50b58211a673f5c;hpb=dc80c73c20ef0e69c3850fd9679a827ad79e61a1;p=collectd.git diff --git a/src/users.c b/src/users.c index e600aab3..781e7787 100644 --- a/src/users.c +++ b/src/users.c @@ -1,11 +1,13 @@ /** * collectd - src/users.c * Copyright (C) 2005-2007 Sebastian Harl + * Copyright (C) 2005 Niki W. Waibel + * Copyright (C) 2005-2007 Florian octo Forster + * Copyright (C) 2008 Oleg King * * 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 @@ -18,39 +20,31 @@ * * Authors: * Sebastian Harl + * Niki W. Waibel + * Florian octo Forster + * Oleg King **/ #include "collectd.h" #include "common.h" #include "plugin.h" +#if HAVE_STATGRAB_H +# include +#endif /* HAVE_STATGRAB_H */ + #if HAVE_UTMPX_H # include -#else /* !HAVE_UTMPX_H */ -# if HAVE_UTMP_H -# include -# endif /* HAVE_UTMP_H */ -#endif /* HAVE_UTMPX_H */ +/* #endif HAVE_UTMPX_H */ -#define MODULE_NAME "users" +#elif HAVE_UTMP_H +# include +/* #endif HAVE_UTMP_H */ -#if HAVE_GETUTXENT || HAVE_GETUTENT -# define USERS_HAVE_READ 1 #else -# define USERS_HAVE_READ 0 +# error "No applicable input method." #endif -static data_source_t dsrc[1] = -{ - {"users", DS_TYPE_GAUGE, 0.0, 65535.0} -}; - -static data_set_t ds = -{ - "users", 1, dsrc -}; - -#if USERS_HAVE_READ static void users_submit (gauge_t value) { value_t values[1]; @@ -60,11 +54,11 @@ static void users_submit (gauge_t value) vl.values = values; vl.values_len = 1; - vl.time = time (NULL); - strcpy (vl.host, hostname_g); - strcpy (vl.plugin, "users"); + sstrncpy (vl.host, hostname_g, sizeof (vl.host)); + sstrncpy (vl.plugin, "users", sizeof (vl.plugin)); + sstrncpy (vl.type, "users", sizeof (vl.plugin)); - plugin_dispatch_values ("users", &vl); + plugin_dispatch_values (&vl); } /* void users_submit */ static int users_read (void) @@ -103,19 +97,26 @@ static int users_read (void) endutent(); users_submit (users); -#endif /* HAVE_GETUTENT */ +/* #endif HAVE_GETUTENT */ + +#elif HAVE_LIBSTATGRAB + sg_user_stats *us; + + us = sg_get_user_stats (); + if (us == NULL) + return (-1); + + users_submit ((gauge_t) us->num_entries); +/* #endif HAVE_LIBSTATGRAB */ + +#else +# error "No applicable input method." +#endif return (0); } /* int users_read */ -#endif /* USERS_HAVE_READ */ -void module_register (modreg_e load) +void module_register (void) { - if (load & MR_DATASETS) - plugin_register_data_set (&ds); - -#if USERS_HAVE_READ - if (load & MR_READ) - plugin_register_read ("users", users_read); -#endif + plugin_register_read ("users", users_read); } /* void module_register(void) */