diff options
Diffstat (limited to 'agent/mibgroup/host/data_access/swrun_procfs_status.c')
| -rw-r--r-- | agent/mibgroup/host/data_access/swrun_procfs_status.c | 218 |
1 files changed, 218 insertions, 0 deletions
diff --git a/agent/mibgroup/host/data_access/swrun_procfs_status.c b/agent/mibgroup/host/data_access/swrun_procfs_status.c new file mode 100644 index 0000000..80182d0 --- /dev/null +++ b/agent/mibgroup/host/data_access/swrun_procfs_status.c @@ -0,0 +1,218 @@ +/* + * swrun_procfs_linux.c: + * hrSWRunTable data access: + * /proc/{pid}/status interface - Linux + */ +#include <net-snmp/net-snmp-config.h> + +#include <stdio.h> +#include <ctype.h> +#ifdef HAVE_STDLIB_H +#include <stdlib.h> +#endif +#ifdef HAVE_UNISTD_H +#include <unistd.h> +#endif +#ifdef HAVE_SYS_TYPES_H +#include <sys/types.h> +#endif + +#ifdef HAVE_DIRENT_H +#include <dirent.h> +#endif +#ifdef HAVE_LINUX_TASKS_H +#include <linux/tasks.h> +#endif + +#include <net-snmp/net-snmp-includes.h> +#include <net-snmp/agent/net-snmp-agent-includes.h> +#include <net-snmp/library/container.h> +#include <net-snmp/library/snmp_debug.h> +#include <net-snmp/data_access/swrun.h> + +static long pagesize; +static long sc_clk_tck; + +/* --------------------------------------------------------------------- + */ +void +netsnmp_arch_swrun_init(void) +{ +#ifdef HAVE_LINUX_TASKS_H + extern int _swrun_max = NR_TASKS; /* from <linux/tasks.h> */ +#endif + + pagesize = getpagesize(); + sc_clk_tck = sysconf(_SC_CLK_TCK); + return; +} + +/* --------------------------------------------------------------------- + */ +int +netsnmp_arch_swrun_container_load( netsnmp_container *container, u_int flags) +{ + DIR *procdir = NULL; + struct dirent *procentry_p; + FILE *fp; + int pid, i; + unsigned long long cpu; + char buf[BUFSIZ], buf2[BUFSIZ], *cp; + netsnmp_swrun_entry *entry; + + procdir = opendir("/proc"); + if ( NULL == procdir ) { + snmp_log( LOG_ERR, "Failed to open /proc" ); + return -1; + } + + /* + * Walk through the list of processes in the /proc tree + */ + while ( NULL != (procentry_p = readdir( procdir ))) { + pid = atoi( procentry_p->d_name ); + if ( 0 == pid ) + continue; /* Presumably '.' or '..' */ + + entry = netsnmp_swrun_entry_create(pid); + if (NULL == entry) + continue; /* error already logged by function */ + + /* + * Now extract the interesting information + * from the various /proc{PID}/ interface files + */ + + /* + * Name: process name + */ + snprintf( buf2, BUFSIZ, "/proc/%d/status", pid ); + fp = fopen( buf2, "r" ); + if (!fp) { + netsnmp_swrun_entry_free(entry); + continue; /* file (process) probably went away */ + } + memset(buf, 0, sizeof(buf)); + if (fgets( buf, BUFSIZ-1, fp ) == NULL) { + fclose(fp); + netsnmp_swrun_entry_free(entry); + continue; + } + fclose(fp); + + for ( cp = buf; *cp != ':'; cp++ ) + ; + while (isspace(*(++cp))) /* Skip ':' and following spaces */ + ; + entry->hrSWRunName_len = snprintf(entry->hrSWRunName, + sizeof(entry->hrSWRunName)-1, "%s", cp); + if ( '\n' == entry->hrSWRunName[ entry->hrSWRunName_len-1 ]) { + entry->hrSWRunName[ entry->hrSWRunName_len-1 ] = '\0'; + entry->hrSWRunName_len--; /* Stamp on trailing newline */ + } + + /* + * Command Line: + * argv[0] '\0' argv[1] '\0' .... + */ + snprintf( buf2, BUFSIZ, "/proc/%d/cmdline", pid ); + fp = fopen( buf2, "r" ); + if (!fp) { + netsnmp_swrun_entry_free(entry); + continue; /* file (process) probably went away */ + } + memset(buf, 0, sizeof(buf)); + if ((cp = fgets( buf, BUFSIZ-1, fp )) == NULL) { + fclose(fp); + netsnmp_swrun_entry_free(entry); + continue; + } + fclose(fp); + + /* + * argv[0] is hrSWRunPath + */ + entry->hrSWRunPath_len = snprintf(entry->hrSWRunPath, + sizeof(entry->hrSWRunPath)-1, "%s", buf); + /* + * Stitch together argv[1..] to construct hrSWRunParameters + */ + cp = buf + entry->hrSWRunPath_len+1; + while ( 1 ) { + while (*cp) + cp++; + if ( '\0' == *(cp+1)) + break; /* '\0''\0' => End of command line */ + *cp = ' '; + } + entry->hrSWRunParameters_len + = sprintf(entry->hrSWRunParameters, "%.*s", + (int)sizeof(entry->hrSWRunParameters) - 1, + buf + entry->hrSWRunPath_len + 1); + + /* + * XXX - No information regarding system processes vs applications + */ + entry->hrSWRunType = HRSWRUNTYPE_APPLICATION; + + /* + * {xxx} {xxx} STATUS {xxx}*10 UTIME STIME {xxx}*8 RSS + */ + snprintf( buf, BUFSIZ, "/proc/%d/stat", pid ); + fp = fopen( buf, "r" ); + if (!fp) { + netsnmp_swrun_entry_free(entry); + continue; /* file (process) probably went away */ + } + if (fgets( buf, BUFSIZ-1, fp ) == NULL) { + fclose(fp); + netsnmp_swrun_entry_free(entry); + continue; + } + fclose(fp); + + cp = buf; + while ( ' ' != *(cp++)) /* Skip first field */ + ; + while ( ' ' != *(cp++)) /* Skip second field */ + ; + + switch (*cp) { + case 'R': entry->hrSWRunStatus = HRSWRUNSTATUS_RUNNING; + break; + case 'S': entry->hrSWRunStatus = HRSWRUNSTATUS_RUNNABLE; + break; + case 'D': + case 'T': entry->hrSWRunStatus = HRSWRUNSTATUS_NOTRUNNABLE; + break; + case 'Z': + default: entry->hrSWRunStatus = HRSWRUNSTATUS_INVALID; + break; + } + for (i=11; i; i--) { /* Skip STATUS + 10 fields */ + while (' ' != *(++cp)) + ; + cp++; + } + cpu = atol( cp ); /* utime */ + while ( ' ' != *(++cp)) + ; + cpu += atol( cp ); /* +stime */ + entry->hrSWRunPerfCPU = cpu * 100 / sc_clk_tck; + + for (i=9; i; i--) { /* Skip stime + 8 fields */ + while (' ' != *(++cp)) + ; + cp++; + } + entry->hrSWRunPerfMem = atol( cp ); /* rss */ + entry->hrSWRunPerfMem *= (pagesize/1024); /* in kB */ + CONTAINER_INSERT(container, entry); + } + closedir( procdir ); + + DEBUGMSGTL(("swrun:load:arch"," loaded %" NETSNMP_PRIz "d entries\n", + CONTAINER_SIZE(container))); + + return 0; +} |