2 * collectd - src/ipc.c, based on src/memcached.c
3 * Copyright (C) 2010 Andres J. Diaz <ajdiaz@connectical.com>
4 * Copyright (C) 2010 Manuel L. Sanmartin <manuel.luis@gmail.com>
6 * This program is free software; you can redistribute it and/or modify it
7 * under the terms of the GNU General Public License as published by the
8 * Free Software Foundation; either version 2 of the License, or (at your
9 * option) any later version.
11 * This program is distributed in the hope that it will be useful, but
12 * WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * General Public License for more details.
16 * You should have received a copy of the GNU General Public License along
17 * with this program; if not, write to the Free Software Foundation, Inc.,
18 * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
21 * Andres J. Diaz <ajdiaz@connectical.com>
22 * Manuel L. Sanmartin <manuel.luis@gmail>
25 /* Many of this code is based on busybox ipc implementation, which is:
26 * (C) Rodney Radford <rradford@mindspring.com> and distributed under GPLv2.
32 #include "configfile.h"
35 /* X/OPEN tells us to use <sys/{types,ipc,sem}.h> for semctl() */
36 /* X/OPEN tells us to use <sys/{types,ipc,msg}.h> for msgctl() */
37 /* X/OPEN tells us to use <sys/{types,ipc,shm}.h> for shmctl() */
38 # include <sys/types.h>
44 /* For older kernels the same holds for the defines below */
55 ulong shm_tot; /* total allocated shm */
56 ulong shm_rss; /* total resident shm */
57 ulong shm_swp; /* total swapped shm */
68 /* The last arg of semctl is a union semun, but where is it defined?
69 X/OPEN tells us to define it ourselves, but until recently
70 Linux include files would also define it. */
71 # if defined(__GNU_LIBRARY__) && !defined(_SEM_SEMUN_UNDEFINED)
72 /* union semun is defined by including <sys/sem.h> */
74 /* according to X/OPEN we have to define it ourselves */
78 unsigned short *array;
79 struct seminfo *__buf;
82 static long pagesize_g;
83 /* #endif KERNEL_LINUX */
85 # include <sys/ipc_info.h>
86 /* #endif KERNEL_AIX */
88 # error "No applicable input method."
91 __attribute__ ((nonnull(1)))
92 static void ipc_submit_g (const char *type, gauge_t value) /* {{{ */
95 value_list_t vl = VALUE_LIST_INIT;
97 values[0].gauge = value;
101 sstrncpy (vl.host, hostname_g, sizeof (vl.host));
102 sstrncpy (vl.plugin, "ipc", sizeof (vl.plugin));
103 sstrncpy (vl.type, type, sizeof (vl.type));
105 plugin_dispatch_values (&vl);
109 static caddr_t ipc_get_info (cid_t cid, int cmd, int version, int stsize, int *nmemb) /* {{{ */
114 if (get_ipc_info(cid, cmd, version, buff, &size) < 0)
116 if (errno != ENOSPC) {
118 WARNING ("ipc plugin: get_ipc_info: %s",
119 sstrerror (errno, errbuf, sizeof (errbuf)));
128 ERROR ("ipc plugin: ipc_get_info: missmatch struct size and buffer size");
132 *nmemb = size / stsize;
134 buff = (caddr_t)malloc (size);
136 ERROR ("ipc plugin: ipc_get_info malloc failed.");
140 if (get_ipc_info(cid, cmd, version, buff, &size) < 0)
143 WARNING ("ipc plugin: get_ipc_info: %s",
144 sstrerror (errno, errbuf, sizeof (errbuf)));
151 #endif /* KERNEL_AIX */
153 static int ipc_read_sem (void) /* {{{ */
156 struct seminfo seminfo;
159 arg.array = (ushort *) (void *) &seminfo;
161 if ( semctl(0, 0, SEM_INFO, arg) < 0 )
163 ERROR("Kernel is not configured for semaphores");
167 ipc_submit_g("sem_used_arrays", seminfo.semusz);
168 ipc_submit_g("sem_used", seminfo.semaem);
170 /* #endif KERNEL_LINUX */
172 ipcinfo_sem_t *ipcinfo_sem;
173 unsigned short sem_nsems=0;
174 unsigned short sems=0;
177 ipcinfo_sem = (ipcinfo_sem_t *)ipc_get_info(0,
178 GET_IPCINFO_SEM_ALL, IPCINFO_SEM_VERSION, sizeof(ipcinfo_sem_t), &n);
179 if (ipcinfo_sem == NULL)
182 for (i=0; i<n; i++) {
183 sem_nsems += ipcinfo_sem[i].sem_nsems;
188 ipc_submit_g("sem_used_arrays", sem_nsems);
189 ipc_submit_g("sem_used", sems);
190 #endif /* KERNEL_AIX */
196 static int ipc_read_shm (void) /* {{{ */
199 struct shm_info shm_info;
200 pagesize_g = sysconf(_SC_PAGESIZE);
202 if ( shmctl(0, SHM_INFO, (struct shmid_ds *) (void *) &shm_info) < 0 )
204 ERROR("Kernel is not configured for shared memory");
207 ipc_submit_g("shm_segments", shm_info.used_ids);
208 ipc_submit_g("shm_bytes_total", shm_info.shm_tot * pagesize_g);
209 ipc_submit_g("shm_bytes_rss", shm_info.shm_rss * pagesize_g);
210 ipc_submit_g("shm_bytes_swapped", shm_info.shm_swp * pagesize_g);
211 /* #endif KERNEL_LINUX */
213 ipcinfo_shm_t *ipcinfo_shm;
215 unsigned int shm_segments=0;
216 size64_t shm_bytes=0;
219 ipcinfo_shm = (ipcinfo_shm_t *)ipc_get_info(0,
220 GET_IPCINFO_SHM_ALL, IPCINFO_SHM_VERSION, sizeof(ipcinfo_shm_t), &n);
221 if (ipcinfo_shm == NULL)
224 for (i=0, pshm=ipcinfo_shm; i<n; i++, pshm++) {
226 shm_bytes += pshm->shm_segsz;
230 ipc_submit_g("shm_segments", shm_segments);
231 ipc_submit_g("shm_bytes_total", shm_bytes);
233 #endif /* KERNEL_AIX */
238 static int ipc_read_msg (void) /* {{{ */
241 struct msginfo msginfo;
243 if ( msgctl(0, MSG_INFO, (struct msqid_ds *) (void *) &msginfo) < 0 )
245 ERROR("Kernel is not configured for message queues");
248 ipc_submit_g("msg_alloc_queues", msginfo.msgmni);
249 ipc_submit_g("msg_used_headers", msginfo.msgmap);
250 ipc_submit_g("msg_used_space", msginfo.msgtql);
251 /* #endif KERNEL_LINUX */
253 ipcinfo_msg_t *ipcinfo_msg;
254 uint32_t msg_used_space=0;
255 uint32_t msg_alloc_queues=0;
256 msgqnum32_t msg_qnum=0;
259 ipcinfo_msg = (ipcinfo_msg_t *)ipc_get_info(0,
260 GET_IPCINFO_MSG_ALL, IPCINFO_MSG_VERSION, sizeof(ipcinfo_msg_t), &n);
261 if (ipcinfo_msg == NULL)
264 for (i=0; i<n; i++) {
266 msg_used_space += ipcinfo_msg[i].msg_cbytes;
267 msg_qnum += ipcinfo_msg[i].msg_qnum;
271 ipc_submit_g("msg_alloc_queues", msg_alloc_queues);
272 ipc_submit_g("msg_used_headers", msg_qnum);
273 ipc_submit_g("msg_used_space", msg_used_space);
274 #endif /* KERNEL_AIX */
279 static int ipc_read (void) /* {{{ */
291 static int ipc_init (void) /* {{{ */
293 pagesize_g = sysconf(_SC_PAGESIZE);
297 #endif /* KERNEL_LINUX */
299 void module_register (void) /* {{{ */
302 plugin_register_init ("ipc", ipc_init);
304 plugin_register_read ("ipc", ipc_read);
308 /* vim: set sw=2 sts=2 et fdm=marker : */