X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fmemory.c;h=6ea6205e1ca51a72569bc352294e441cb3e6aed6;hb=de0fdb208de123fe753c5fcf03533833777a5b4a;hp=8830ffe60fc533717a69f44fd9148b0b7e729b9d;hpb=5afa2f82d43e2a7952d8f347f6f40b5778c59db8;p=collectd.git diff --git a/src/memory.c b/src/memory.c index 8830ffe6..6ea6205e 100644 --- a/src/memory.c +++ b/src/memory.c @@ -1,6 +1,6 @@ /** * collectd - src/memory.c - * Copyright (C) 2005-2007 Florian octo Forster + * Copyright (C) 2005-2008 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 @@ -43,17 +43,15 @@ # include #endif -#if defined (HOST_VM_INFO) || HAVE_SYSCTLBYNAME || KERNEL_LINUX || HAVE_LIBKSTAT -# define MEMORY_HAVE_READ 1 -#else -# define MEMORY_HAVE_READ 0 +#if HAVE_STATGRAB_H +# include #endif /* vm_statistics_data_t */ -#if defined(HOST_VM_INFO) +#if HAVE_HOST_STATISTICS static mach_port_t port_host; static vm_size_t pagesize; -/* #endif HOST_VM_INFO */ +/* #endif HAVE_HOST_STATISTICS */ #elif HAVE_SYSCTLBYNAME /* no global variables */ @@ -66,15 +64,22 @@ static vm_size_t pagesize; #elif HAVE_LIBKSTAT static int pagesize; static kstat_t *ksp; -#endif /* HAVE_LIBKSTAT */ +/* #endif HAVE_LIBKSTAT */ + +#elif HAVE_LIBSTATGRAB +/* no global variables */ +/* endif HAVE_LIBSTATGRAB */ + +#else +# error "No applicable input method." +#endif -#if MEMORY_HAVE_READ static int memory_init (void) { -#if defined(HOST_VM_INFO) +#if HAVE_HOST_STATISTICS port_host = mach_host_self (); host_page_size (port_host, &pagesize); -/* #endif HOST_VM_INFO */ +/* #endif HAVE_HOST_STATISTICS */ #elif HAVE_SYSCTLBYNAME /* no init stuff */ @@ -87,8 +92,11 @@ static int memory_init (void) #elif defined(HAVE_LIBKSTAT) /* getpagesize(3C) tells me this does not fail.. */ pagesize = getpagesize (); - if (get_kstat (&ksp, "unix", 0, "system_pages")) + if (get_kstat (&ksp, "unix", 0, "system_pages") != 0) + { ksp = NULL; + return (-1); + } #endif /* HAVE_LIBKSTAT */ return (0); @@ -103,18 +111,17 @@ static void memory_submit (const char *type_instance, gauge_t value) vl.values = values; vl.values_len = 1; - vl.time = time (NULL); - strcpy (vl.host, hostname_g); - strcpy (vl.plugin, "memory"); - strncpy (vl.type_instance, type_instance, sizeof (vl.type_instance)); - vl.type_instance[sizeof (vl.type_instance) - 1] = '\0'; + sstrncpy (vl.host, hostname_g, sizeof (vl.host)); + sstrncpy (vl.plugin, "memory", sizeof (vl.plugin)); + sstrncpy (vl.type, "memory", sizeof (vl.type)); + sstrncpy (vl.type_instance, type_instance, sizeof (vl.type_instance)); - plugin_dispatch_values ("memory", &vl); + plugin_dispatch_values (&vl); } static int memory_read (void) { -#if defined(HOST_VM_INFO) +#if HAVE_HOST_STATISTICS kern_return_t status; vm_statistics_data_t vm_data; mach_msg_type_number_t vm_data_len; @@ -165,7 +172,7 @@ static int memory_read (void) memory_submit ("active", active); memory_submit ("inactive", inactive); memory_submit ("free", free); -/* #endif HOST_VM_INFO */ +/* #endif HAVE_HOST_STATISTICS */ #elif HAVE_SYSCTLBYNAME /* @@ -190,7 +197,6 @@ static int memory_read (void) }; double sysctl_vals[8]; - size_t len; int i; for (i = 0; sysctl_keys[i] != NULL; i++) @@ -202,7 +208,7 @@ static int memory_read (void) NULL, 0) == 0) { sysctl_vals[i] = value; - DEBUG ("memory plugin: %26s: %6i", sysctl_keys[i], sysctl_vals[i]); + DEBUG ("memory plugin: %26s: %g", sysctl_keys[i], sysctl_vals[i]); } else { @@ -222,7 +228,7 @@ static int memory_read (void) memory_submit ("cache", sysctl_vals[6]); /* #endif HAVE_SYSCTLBYNAME */ -#elif defined(KERNEL_LINUX) +#elif KERNEL_LINUX FILE *fh; char buffer[1024]; @@ -280,9 +286,9 @@ static int memory_read (void) memory_submit ("cached", mem_cached); memory_submit ("free", mem_free); } -/* #endif defined(KERNEL_LINUX) */ +/* #endif KERNEL_LINUX */ -#elif defined(HAVE_LIBKSTAT) +#elif HAVE_LIBKSTAT long long mem_used; long long mem_free; long long mem_lock; @@ -306,28 +312,25 @@ static int memory_read (void) memory_submit ("used", mem_used); memory_submit ("free", mem_free); - memory_submit ("locked", mem_locked); -/* #endif defined(HAVE_LIBKSTAT) */ + memory_submit ("locked", mem_lock); +/* #endif HAVE_LIBKSTAT */ -#elif defined(HAVE_LIBSTATGRAB) +#elif HAVE_LIBSTATGRAB sg_mem_stats *ios; if ((ios = sg_get_mem_stats ()) != NULL) { memory_submit ("used", ios->used); - memory_submit ("cached", ios->cached); + memory_submit ("cached", ios->cache); memory_submit ("free", ios->free); } #endif /* HAVE_LIBSTATGRAB */ return (0); } -#endif /* MEMORY_HAVE_READ */ void module_register (void) { -#if MEMORY_HAVE_READ plugin_register_init ("memory", memory_init); plugin_register_read ("memory", memory_read); -#endif /* MEMORY_HAVE_READ */ } /* void module_register */