#include "plugin.h"
#if KERNEL_LINUX
- /* _GNU_SOURCE is needed for struct shm_info.used_ids on musl libc */
-# define _GNU_SOURCE
-
- /* X/OPEN tells us to use <sys/{types,ipc,sem}.h> for semctl() */
- /* X/OPEN tells us to use <sys/{types,ipc,msg}.h> for msgctl() */
- /* X/OPEN tells us to use <sys/{types,ipc,shm}.h> for shmctl() */
-# include <sys/types.h>
-# include <sys/ipc.h>
-# include <sys/sem.h>
-# include <sys/msg.h>
-# include <sys/shm.h>
-
- /* For older kernels the same holds for the defines below */
-# ifndef MSG_STAT
-# define MSG_STAT 11
-# define MSG_INFO 12
-# endif
-
-# ifndef SHM_STAT
-# define SHM_STAT 13
-# define SHM_INFO 14
- struct shm_info {
- int used_ids;
- ulong shm_tot; /* total allocated shm */
- ulong shm_rss; /* total resident shm */
- ulong shm_swp; /* total swapped shm */
- ulong swap_attempts;
- ulong swap_successes;
- };
-# endif
-
-# ifndef SEM_STAT
-# define SEM_STAT 18
-# define SEM_INFO 19
-# endif
-
- /* The last arg of semctl is a union semun, but where is it defined?
- X/OPEN tells us to define it ourselves, but until recently
- Linux include files would also define it. */
-# if defined(__GNU_LIBRARY__) && !defined(_SEM_SEMUN_UNDEFINED)
- /* union semun is defined by including <sys/sem.h> */
-# else
- /* according to X/OPEN we have to define it ourselves */
- union semun {
- int val;
- struct semid_ds *buf;
- unsigned short *array;
- struct seminfo *__buf;
- };
-# endif
+/* _GNU_SOURCE is needed for struct shm_info.used_ids on musl libc */
+#define _GNU_SOURCE
+
+/* X/OPEN tells us to use <sys/{types,ipc,sem}.h> for semctl() */
+/* X/OPEN tells us to use <sys/{types,ipc,msg}.h> for msgctl() */
+/* X/OPEN tells us to use <sys/{types,ipc,shm}.h> for shmctl() */
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include <sys/sem.h>
+#include <sys/shm.h>
+#include <sys/types.h>
+
+/* For older kernels the same holds for the defines below */
+#ifndef MSG_STAT
+#define MSG_STAT 11
+#define MSG_INFO 12
+#endif
+
+#ifndef SHM_STAT
+#define SHM_STAT 13
+#define SHM_INFO 14
+struct shm_info {
+ int used_ids;
+ ulong shm_tot; /* total allocated shm */
+ ulong shm_rss; /* total resident shm */
+ ulong shm_swp; /* total swapped shm */
+ ulong swap_attempts;
+ ulong swap_successes;
+};
+#endif
+
+#ifndef SEM_STAT
+#define SEM_STAT 18
+#define SEM_INFO 19
+#endif
+
+/* The last arg of semctl is a union semun, but where is it defined?
+ X/OPEN tells us to define it ourselves, but until recently
+ Linux include files would also define it. */
+#if defined(__GNU_LIBRARY__) && !defined(_SEM_SEMUN_UNDEFINED)
+/* union semun is defined by including <sys/sem.h> */
+#else
+/* according to X/OPEN we have to define it ourselves */
+union semun {
+ int val;
+ struct semid_ds *buf;
+ unsigned short *array;
+ struct seminfo *__buf;
+};
+#endif
static long pagesize_g;
/* #endif KERNEL_LINUX */
#elif KERNEL_AIX
-# include <sys/ipc_info.h>
+#include <sys/ipc_info.h>
/* #endif KERNEL_AIX */
#else
-# error "No applicable input method."
+#error "No applicable input method."
#endif
-__attribute__ ((nonnull(1)))
-static void ipc_submit_g (const char *plugin_instance,
- const char *type,
- const char *type_instance,
- gauge_t value) /* {{{ */
+__attribute__((nonnull(1))) static void
+ipc_submit_g(const char *plugin_instance, const char *type,
+ const char *type_instance, gauge_t value) /* {{{ */
{
value_list_t vl = VALUE_LIST_INIT;
- vl.values = &(value_t) { .gauge = value };
+ vl.values = &(value_t){.gauge = value};
vl.values_len = 1;
- sstrncpy (vl.plugin, "ipc", sizeof (vl.plugin));
- sstrncpy (vl.plugin_instance, plugin_instance, sizeof (vl.plugin_instance));
- sstrncpy (vl.type, type, sizeof (vl.type));
+ sstrncpy(vl.plugin, "ipc", sizeof(vl.plugin));
+ sstrncpy(vl.plugin_instance, plugin_instance, sizeof(vl.plugin_instance));
+ sstrncpy(vl.type, type, sizeof(vl.type));
if (type_instance != NULL)
- sstrncpy (vl.type_instance, type_instance, sizeof (vl.type_instance));
+ sstrncpy(vl.type_instance, type_instance, sizeof(vl.type_instance));
- plugin_dispatch_values (&vl);
+ plugin_dispatch_values(&vl);
} /* }}} */
#if KERNEL_LINUX
-static int ipc_read_sem (void) /* {{{ */
+static int ipc_read_sem(void) /* {{{ */
{
struct seminfo seminfo;
union semun arg;
int status;
- arg.array = (void *) &seminfo;
+ arg.array = (void *)&seminfo;
- status = semctl (/* id = */ 0, /* num = */ 0, SEM_INFO, arg);
- if (status == -1)
- {
+ status = semctl(/* id = */ 0, /* num = */ 0, SEM_INFO, arg);
+ if (status == -1) {
char errbuf[1024];
ERROR("ipc plugin: semctl(2) failed: %s. "
- "Maybe the kernel is not configured for semaphores?",
- sstrerror (errno, errbuf, sizeof (errbuf)));
- return (-1);
+ "Maybe the kernel is not configured for semaphores?",
+ sstrerror(errno, errbuf, sizeof(errbuf)));
+ return -1;
}
ipc_submit_g("sem", "count", "arrays", seminfo.semusz);
ipc_submit_g("sem", "count", "total", seminfo.semaem);
- return (0);
+ return 0;
} /* }}} int ipc_read_sem */
-static int ipc_read_shm (void) /* {{{ */
+static int ipc_read_shm(void) /* {{{ */
{
struct shm_info shm_info;
int status;
- status = shmctl (/* id = */ 0, SHM_INFO, (void *) &shm_info);
- if (status == -1)
- {
+ status = shmctl(/* id = */ 0, SHM_INFO, (void *)&shm_info);
+ if (status == -1) {
char errbuf[1024];
ERROR("ipc plugin: shmctl(2) failed: %s. "
- "Maybe the kernel is not configured for shared memory?",
- sstrerror (errno, errbuf, sizeof (errbuf)));
- return (-1);
+ "Maybe the kernel is not configured for shared memory?",
+ sstrerror(errno, errbuf, sizeof(errbuf)));
+ return -1;
}
ipc_submit_g("shm", "segments", NULL, shm_info.used_ids);
ipc_submit_g("shm", "bytes", "total", shm_info.shm_tot * pagesize_g);
ipc_submit_g("shm", "bytes", "rss", shm_info.shm_rss * pagesize_g);
ipc_submit_g("shm", "bytes", "swapped", shm_info.shm_swp * pagesize_g);
- return (0);
+ return 0;
}
/* }}} int ipc_read_shm */
-static int ipc_read_msg (void) /* {{{ */
+static int ipc_read_msg(void) /* {{{ */
{
struct msginfo msginfo;
- if ( msgctl(0, MSG_INFO, (struct msqid_ds *) (void *) &msginfo) < 0 )
- {
+ if (msgctl(0, MSG_INFO, (struct msqid_ds *)(void *)&msginfo) < 0) {
ERROR("Kernel is not configured for message queues");
- return (-1);
+ return -1;
}
ipc_submit_g("msg", "count", "queues", msginfo.msgmni);
ipc_submit_g("msg", "count", "headers", msginfo.msgmap);
ipc_submit_g("msg", "count", "space", msginfo.msgtql);
- return (0);
+ return 0;
}
/* }}} int ipc_read_msg */
-static int ipc_init (void) /* {{{ */
+static int ipc_init(void) /* {{{ */
{
pagesize_g = sysconf(_SC_PAGESIZE);
- return (0);
+ return 0;
}
/* }}} */
/* #endif KERNEL_LINUX */
#elif KERNEL_AIX
-static caddr_t ipc_get_info (cid_t cid, int cmd, int version, int stsize, int *nmemb) /* {{{ */
+static caddr_t ipc_get_info(cid_t cid, int cmd, int version, int stsize,
+ int *nmemb) /* {{{ */
{
int size = 0;
caddr_t buff = NULL;
- if (get_ipc_info(cid, cmd, version, buff, &size) < 0)
- {
+ if (get_ipc_info(cid, cmd, version, buff, &size) < 0) {
if (errno != ENOSPC) {
char errbuf[1024];
- WARNING ("ipc plugin: get_ipc_info: %s",
- sstrerror (errno, errbuf, sizeof (errbuf)));
- return (NULL);
+ WARNING("ipc plugin: get_ipc_info: %s",
+ sstrerror(errno, errbuf, sizeof(errbuf)));
+ return NULL;
}
}
return NULL;
if (size % stsize) {
- ERROR ("ipc plugin: ipc_get_info: missmatch struct size and buffer size");
- return (NULL);
+ ERROR("ipc plugin: ipc_get_info: missmatch struct size and buffer size");
+ return NULL;
}
*nmemb = size / stsize;
- buff = malloc (size);
- if (buff == NULL) {
- ERROR ("ipc plugin: ipc_get_info malloc failed.");
- return (NULL);
+ buff = malloc(size);
+ if (buff == NULL) {
+ ERROR("ipc plugin: ipc_get_info malloc failed.");
+ return NULL;
}
- if (get_ipc_info(cid, cmd, version, buff, &size) < 0)
- {
+ if (get_ipc_info(cid, cmd, version, buff, &size) < 0) {
char errbuf[1024];
- WARNING ("ipc plugin: get_ipc_info: %s",
- sstrerror (errno, errbuf, sizeof (errbuf)));
+ WARNING("ipc plugin: get_ipc_info: %s",
+ sstrerror(errno, errbuf, sizeof(errbuf)));
free(buff);
- return (NULL);
+ return NULL;
}
return buff;
} /* }}} */
-static int ipc_read_sem (void) /* {{{ */
+static int ipc_read_sem(void) /* {{{ */
{
ipcinfo_sem_t *ipcinfo_sem;
- unsigned short sem_nsems=0;
- unsigned short sems=0;
+ unsigned short sem_nsems = 0;
+ unsigned short sems = 0;
int n;
- ipcinfo_sem = (ipcinfo_sem_t *)ipc_get_info(0,
- GET_IPCINFO_SEM_ALL, IPCINFO_SEM_VERSION, sizeof(ipcinfo_sem_t), &n);
+ ipcinfo_sem = (ipcinfo_sem_t *)ipc_get_info(
+ 0, GET_IPCINFO_SEM_ALL, IPCINFO_SEM_VERSION, sizeof(ipcinfo_sem_t), &n);
if (ipcinfo_sem == NULL)
return -1;
- for (int i=0; i<n; i++) {
+ for (int i = 0; i < n; i++) {
sem_nsems += ipcinfo_sem[i].sem_nsems;
sems++;
}
ipc_submit_g("sem", "count", "arrays", sem_nsems);
ipc_submit_g("sem", "count", "total", sems);
- return (0);
+ return 0;
} /* }}} int ipc_read_sem */
-static int ipc_read_shm (void) /* {{{ */
+static int ipc_read_shm(void) /* {{{ */
{
ipcinfo_shm_t *ipcinfo_shm;
ipcinfo_shm_t *pshm;
- unsigned int shm_segments=0;
- size64_t shm_bytes=0;
- int n;
+ unsigned int shm_segments = 0;
+ size64_t shm_bytes = 0;
+ int i, n;
- ipcinfo_shm = (ipcinfo_shm_t *)ipc_get_info(0,
- GET_IPCINFO_SHM_ALL, IPCINFO_SHM_VERSION, sizeof(ipcinfo_shm_t), &n);
+ ipcinfo_shm = (ipcinfo_shm_t *)ipc_get_info(
+ 0, GET_IPCINFO_SHM_ALL, IPCINFO_SHM_VERSION, sizeof(ipcinfo_shm_t), &n);
if (ipcinfo_shm == NULL)
return -1;
- for (int i=0, pshm=ipcinfo_shm; i<n; i++, pshm++) {
+ for (i = 0, pshm = ipcinfo_shm; i < n; i++, pshm++) {
shm_segments++;
shm_bytes += pshm->shm_segsz;
}
ipc_submit_g("shm", "segments", NULL, shm_segments);
ipc_submit_g("shm", "bytes", "total", shm_bytes);
- return (0);
+ return 0;
}
/* }}} int ipc_read_shm */
-static int ipc_read_msg (void) /* {{{ */
+static int ipc_read_msg(void) /* {{{ */
{
ipcinfo_msg_t *ipcinfo_msg;
- uint32_t msg_used_space=0;
- uint32_t msg_alloc_queues=0;
- msgqnum32_t msg_qnum=0;
+ uint32_t msg_used_space = 0;
+ uint32_t msg_alloc_queues = 0;
+ msgqnum32_t msg_qnum = 0;
int n;
- ipcinfo_msg = (ipcinfo_msg_t *)ipc_get_info(0,
- GET_IPCINFO_MSG_ALL, IPCINFO_MSG_VERSION, sizeof(ipcinfo_msg_t), &n);
+ ipcinfo_msg = (ipcinfo_msg_t *)ipc_get_info(
+ 0, GET_IPCINFO_MSG_ALL, IPCINFO_MSG_VERSION, sizeof(ipcinfo_msg_t), &n);
if (ipcinfo_msg == NULL)
return -1;
- for (int i=0; i<n; i++) {
+ for (int i = 0; i < n; i++) {
msg_alloc_queues++;
msg_used_space += ipcinfo_msg[i].msg_cbytes;
msg_qnum += ipcinfo_msg[i].msg_qnum;
ipc_submit_g("msg", "count", "headers", msg_qnum);
ipc_submit_g("msg", "count", "space", msg_used_space);
- return (0);
+ return 0;
}
/* }}} */
#endif /* KERNEL_AIX */
-static int ipc_read (void) /* {{{ */
+static int ipc_read(void) /* {{{ */
{
int x = 0;
x |= ipc_read_shm();
x |= ipc_read_sem();
x |= ipc_read_msg();
- return (x);
+ return x;
}
/* }}} */
-void module_register (void) /* {{{ */
+void module_register(void) /* {{{ */
{
#ifdef KERNEL_LINUX
- plugin_register_init ("ipc", ipc_init);
+ plugin_register_init("ipc", ipc_init);
#endif
- plugin_register_read ("ipc", ipc_read);
+ plugin_register_read("ipc", ipc_read);
}
/* }}} */
-
-/* vim: set sw=2 sts=2 et fdm=marker : */
projects / collectd.git / blobdiff