diff options
Diffstat (limited to 'src/libs/zbxsysinfo/aix/diskio.c')
| -rw-r--r-- | src/libs/zbxsysinfo/aix/diskio.c | 191 |
1 files changed, 191 insertions, 0 deletions
diff --git a/src/libs/zbxsysinfo/aix/diskio.c b/src/libs/zbxsysinfo/aix/diskio.c index 88dc2841dcc..f9da7c476b9 100644 --- a/src/libs/zbxsysinfo/aix/diskio.c +++ b/src/libs/zbxsysinfo/aix/diskio.c @@ -19,8 +19,199 @@ #include "common.h" #include "sysinfo.h" +#include "log.h" + +#define ZBX_DEV_PFX "/dev/" + +typedef struct +{ + zbx_uint64_t nread; + zbx_uint64_t nwritten; + zbx_uint64_t reads; + zbx_uint64_t writes; +} +zbx_perfstat_t; int get_diskstat(const char *devname, zbx_uint64_t *dstat) { return FAIL; } + +static int get_perfstat_io(const char *devname, zbx_perfstat_t *zp, char **error) +{ +#if defined(HAVE_LIBPERFSTAT) + int err; + + if ('\0' != *devname) + { + perfstat_id_t name; + perfstat_disk_t data; + + strscpy(name.name, devname); + + if (0 < (err = perfstat_disk(&name, &data, sizeof(data), 1))) + { + zp->nread = data.rblks * data.bsize; + zp->nwritten = data.wblks * data.bsize; + zp->reads = data.xrate; + zp->writes = data.xfers - data.xrate; + + return SYSINFO_RET_OK; + } + } + else + { + perfstat_disk_total_t data; + + if (0 < (err = perfstat_disk_total(NULL, &data, sizeof(data), 1))) + { + zp->nread = data.rblks * 512; + zp->nwritten = data.wblks * 512; + zp->reads = data.xrate; + zp->writes = data.xfers - data.xrate; + + return SYSINFO_RET_OK; + } + } + + if (0 == err) + *error = zbx_strdup(NULL, "Cannot obtain system information."); + else + *error = zbx_dsprintf(NULL, "Cannot obtain system information: %s", zbx_strerror(errno)); + + return SYSINFO_RET_FAIL; +#else + *error = zbx_strdup(NULL, "Agent was compiled without support for Perfstat API.")); + return SYSINFO_RET_FAIL; +#endif +} + +static int VFS_DEV_READ_BYTES(const char *devname, AGENT_RESULT *result) +{ + zbx_perfstat_t zp; + char *error; + + if (SYSINFO_RET_OK != get_perfstat_io(devname, &zp, &error)) + { + SET_MSG_RESULT(result, error); + return SYSINFO_RET_FAIL; + } + + SET_UI64_RESULT(result, zp.nread); + + return SYSINFO_RET_OK; +} + +static int VFS_DEV_READ_OPERATIONS(const char *devname, AGENT_RESULT *result) +{ + zbx_perfstat_t zp; + char *error; + + if (SYSINFO_RET_OK != get_perfstat_io(devname, &zp, &error)) + { + SET_MSG_RESULT(result, error); + return SYSINFO_RET_FAIL; + } + + SET_UI64_RESULT(result, zp.reads); + + return SYSINFO_RET_OK; +} + +static int VFS_DEV_WRITE_BYTES(const char *devname, AGENT_RESULT *result) +{ + zbx_perfstat_t zp; + char *error; + + if (SYSINFO_RET_OK != get_perfstat_io(devname, &zp, &error)) + { + SET_MSG_RESULT(result, error); + return SYSINFO_RET_FAIL; + } + + SET_UI64_RESULT(result, zp.nwritten); + + return SYSINFO_RET_OK; +} + +static int VFS_DEV_WRITE_OPERATIONS(const char *devname, AGENT_RESULT *result) +{ + zbx_perfstat_t zp; + char *error; + + if (SYSINFO_RET_OK != get_perfstat_io(devname, &zp, &error)) + { + SET_MSG_RESULT(result, error); + return SYSINFO_RET_FAIL; + } + + SET_UI64_RESULT(result, zp.writes); + + return SYSINFO_RET_OK; +} + +int VFS_DEV_READ(AGENT_REQUEST *request, AGENT_RESULT *result) +{ + const char *devname, *type; + int ret; + + if (2 < request->nparam) + { + SET_MSG_RESULT(result, zbx_strdup(NULL, "Too many parameters.")); + return SYSINFO_RET_FAIL; + } + + devname = get_rparam(request, 0); + + if (NULL == devname || 0 == strcmp("all", devname)) + devname = ""; + else if (0 == strncmp(ZBX_DEV_PFX, devname, sizeof(ZBX_DEV_PFX) - 1)) + devname += sizeof(ZBX_DEV_PFX) - 1; + + type = get_rparam(request, 1); + + if (NULL == type || '\0' == *type || 0 == strcmp(type, "operations")) + ret = VFS_DEV_READ_OPERATIONS(devname, result); + else if (0 == strcmp(type, "bytes")) + ret = VFS_DEV_READ_BYTES(devname, result); + else + { + SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid second parameter.")); + return SYSINFO_RET_FAIL; + } + + return ret; +} + +int VFS_DEV_WRITE(AGENT_REQUEST *request, AGENT_RESULT *result) +{ + const char *devname, *type; + int ret; + + if (2 < request->nparam) + { + SET_MSG_RESULT(result, zbx_strdup(NULL, "Too many parameters.")); + return SYSINFO_RET_FAIL; + } + + devname = get_rparam(request, 0); + + if (NULL == devname || 0 == strcmp("all", devname)) + devname = ""; + else if (0 == strncmp(ZBX_DEV_PFX, devname, sizeof(ZBX_DEV_PFX) - 1)) + devname += sizeof(ZBX_DEV_PFX) - 1; + + type = get_rparam(request, 1); + + if (NULL == type || '\0' == *type || 0 == strcmp(type, "operations")) + ret = VFS_DEV_WRITE_OPERATIONS(devname, result); + else if (0 == strcmp(type, "bytes")) + ret = VFS_DEV_WRITE_BYTES(devname, result); + else + { + SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid second parameter.")); + return SYSINFO_RET_FAIL; + } + + return ret; +} |