Code

amqp plugin: Implement the "StoreRates" option.
[collectd.git] / src / vmem.c
1 /**
2  * collectd - src/vmem.c
3  * Copyright (C) 2008  Florian octo Forster
4  *
5  * This program is free software; you can redistribute it and/or modify it
6  * under the terms of the GNU General Public License as published by the
7  * Free Software Foundation; only version 2 of the License is applicable.
8  *
9  * This program is distributed in the hope that it will be useful, but
10  * WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License along
15  * with this program; if not, write to the Free Software Foundation, Inc.,
16  * 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
17  *
18  * Authors:
19  *   Florian octo Forster <octo at verplant.org>
20  **/
22 #include "collectd.h"
23 #include "common.h"
24 #include "plugin.h"
26 #if KERNEL_LINUX
27 static const char *config_keys[] =
28 {
29   "Verbose"
30 };
31 static int config_keys_num = STATIC_ARRAY_SIZE (config_keys);
33 static int verbose_output = 0;
34 /* #endif KERNEL_LINUX */
36 #else
37 # error "No applicable input method."
38 #endif /* HAVE_LIBSTATGRAB */
40 static void submit (const char *plugin_instance, const char *type,
41     const char *type_instance, value_t *values, int values_len)
42 {
43   value_list_t vl = VALUE_LIST_INIT;
45   vl.values = values;
46   vl.values_len = values_len;
48   sstrncpy (vl.host, hostname_g, sizeof (vl.host));
49   sstrncpy (vl.plugin, "vmem", sizeof (vl.plugin));
50   if (plugin_instance != NULL)
51     sstrncpy (vl.plugin_instance, plugin_instance, sizeof (vl.plugin_instance));
52   sstrncpy (vl.type, type, sizeof (vl.type));
53   if (type_instance != NULL)
54     sstrncpy (vl.type_instance, type_instance, sizeof (vl.type_instance));
56   plugin_dispatch_values (&vl);
57 } /* void vmem_submit */
59 static void submit_two (const char *plugin_instance, const char *type,
60     const char *type_instance, counter_t c0, counter_t c1)
61 {
62   value_t values[2];
64   values[0].counter = c0;
65   values[1].counter = c1;
67   submit (plugin_instance, type, type_instance, values, 2);
68 } /* void submit_one */
70 static void submit_one (const char *plugin_instance, const char *type,
71     const char *type_instance, value_t value)
72 {
73   submit (plugin_instance, type, type_instance, &value, 1);
74 } /* void submit_one */
76 static int vmem_config (const char *key, const char *value)
77 {
78   if (strcasecmp ("Verbose", key) == 0)
79   {
80     if (IS_TRUE (value))
81       verbose_output = 1;
82     else
83       verbose_output = 0;
84   }
85   else
86   {
87     return (-1);
88   }
90   return (0);
91 } /* int vmem_config */
93 static int vmem_read (void)
94 {
95 #if KERNEL_LINUX
96   counter_t pgpgin = 0;
97   counter_t pgpgout = 0;
98   int pgpgvalid = 0;
100   counter_t pswpin = 0;
101   counter_t pswpout = 0;
102   int pswpvalid = 0;
104   counter_t pgfault = 0;
105   counter_t pgmajfault = 0;
106   int pgfaultvalid = 0;
108   FILE *fh;
109   char buffer[1024];
111   fh = fopen ("/proc/vmstat", "r");
112   if (fh == NULL)
113   {
114     char errbuf[1024];
115     ERROR ("vmem plugin: fopen (/proc/vmstat) failed: %s",
116         sstrerror (errno, errbuf, sizeof (errbuf)));
117     return (-1);
118   }
120   while (fgets (buffer, sizeof (buffer), fh) != NULL)
121   {
122     char *fields[4];
123     int fields_num;
124     char *key;
125     char *endptr;
126     counter_t counter;
127     gauge_t gauge;
129     fields_num = strsplit (buffer, fields, STATIC_ARRAY_SIZE (fields));
130     if (fields_num != 2)
131       continue;
133     key = fields[0];
135     endptr = NULL;
136     counter = strtoll (fields[1], &endptr, 10);
137     if (fields[1] == endptr)
138       continue;
140     endptr = NULL;
141     gauge = strtod (fields[1], &endptr);
142     if (fields[1] == endptr)
143       continue;
145     /* 
146      * Number of pages
147      *
148      * The total number of {inst} pages, e. g dirty pages.
149      */
150     if (strncmp ("nr_", key, strlen ("nr_")) == 0)
151     {
152       char *inst = key + strlen ("nr_");
153       value_t value = { .gauge = gauge };
154       submit_one (NULL, "vmpage_number", inst, value);
155     }
157     /* 
158      * Page in and page outs. For memory and swap.
159      */
160     else if (strcmp ("pgpgin", key) == 0)
161     {
162       pgpgin = counter;
163       pgpgvalid |= 0x01;
164     }
165     else if (strcmp ("pgpgout", key) == 0)
166     {
167       pgpgout = counter;
168       pgpgvalid |= 0x02;
169     }
170     else if (strcmp ("pswpin", key) == 0)
171     {
172       pswpin = counter;
173       pswpvalid |= 0x01;
174     }
175     else if (strcmp ("pswpout", key) == 0)
176     {
177       pswpout = counter;
178       pswpvalid |= 0x02;
179     }
181     /*
182      * Pagefaults
183      */
184     else if (strcmp ("pgfault", key) == 0)
185     {
186       pgfault = counter;
187       pgfaultvalid |= 0x01;
188     }
189     else if (strcmp ("pgmajfault", key) == 0)
190     {
191       pgmajfault = counter;
192       pgfaultvalid |= 0x02;
193     }
195     /*
196      * Skip the other statistics if verbose output is disabled.
197      */
198     else if (verbose_output == 0)
199       continue;
201     /*
202      * Number of page allocations, refills, steals and scans. This is collected
203      * ``per zone'', i. e. for DMA, DMA32, normal and possibly highmem.
204      */
205     else if (strncmp ("pgalloc_", key, strlen ("pgalloc_")) == 0)
206     {
207       char *inst = key + strlen ("pgalloc_");
208       value_t value  = { .counter = counter };
209       submit_one (inst, "vmpage_action", "alloc", value);
210     }
211     else if (strncmp ("pgrefill_", key, strlen ("pgrefill_")) == 0)
212     {
213       char *inst = key + strlen ("pgrefill_");
214       value_t value  = { .counter = counter };
215       submit_one (inst, "vmpage_action", "refill", value);
216     }
217     else if (strncmp ("pgsteal_", key, strlen ("pgsteal_")) == 0)
218     {
219       char *inst = key + strlen ("pgsteal_");
220       value_t value  = { .counter = counter };
221       submit_one (inst, "vmpage_action", "steal", value);
222     }
223     else if (strncmp ("pgscan_kswapd_", key, strlen ("pgscan_kswapd_")) == 0)
224     {
225       char *inst = key + strlen ("pgscan_kswapd_");
226       value_t value  = { .counter = counter };
227       submit_one (inst, "vmpage_action", "scan_kswapd", value);
228     }
229     else if (strncmp ("pgscan_direct_", key, strlen ("pgscan_direct_")) == 0)
230     {
231       char *inst = key + strlen ("pgscan_direct_");
232       value_t value  = { .counter = counter };
233       submit_one (inst, "vmpage_action", "scan_direct", value);
234     }
236     /*
237      * Page action
238      *
239      * number of pages moved to the active or inactive lists and freed, i. e.
240      * removed from either list.
241      */
242     else if (strcmp ("pgfree", key) == 0)
243     {
244       value_t value  = { .counter = counter };
245       submit_one (NULL, "vmpage_action", "free", value);
246     }
247     else if (strcmp ("pgactivate", key) == 0)
248     {
249       value_t value  = { .counter = counter };
250       submit_one (NULL, "vmpage_action", "activate", value);
251     }
252     else if (strcmp ("pgdeactivate", key) == 0)
253     {
254       value_t value  = { .counter = counter };
255       submit_one (NULL, "vmpage_action", "deactivate", value);
256     }
257   } /* while (fgets) */
259   fclose (fh);
260   fh = NULL;
262   if (pgfaultvalid == 0x03)
263     submit_two (NULL, "vmpage_faults", NULL, pgfault, pgmajfault);
265   if (pgpgvalid == 0x03)
266     submit_two (NULL, "vmpage_io", "memory", pgpgin, pgpgout);
268   if (pswpvalid == 0x03)
269     submit_two (NULL, "vmpage_io", "swap", pswpin, pswpout);
270 #endif /* KERNEL_LINUX */
272   return (0);
273 } /* int vmem_read */
275 void module_register (void)
277   plugin_register_config ("vmem", vmem_config,
278       config_keys, config_keys_num);
279   plugin_register_read ("vmem", vmem_read);
280 } /* void module_register */
282 /* vim: set sw=2 sts=2 ts=8 : */