1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/*
* swrun_procinfo.c:
* hrSWRunTable data access:
* getprocs() interface - AIX
*/
#include <net-snmp/net-snmp-config.h>
#include <stdio.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
#include <procinfo.h>
#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>
int avail = 1024; /* Size of table to allocate */
/* ---------------------------------------------------------------------
*/
void
netsnmp_arch_swrun_init(void)
{
/* Nothing to do */
return;
}
/* ---------------------------------------------------------------------
*/
int
netsnmp_arch_swrun_container_load( netsnmp_container *container, u_int flags)
{
struct procsinfo *proc_table;
pid_t proc_index = 0;
int nprocs, rc, i;
char pentry[128], *ppentry, fullpath[128];
netsnmp_swrun_entry *entry;
/*
* Create a buffer for the process table, based on the size of
* the table the last time we loaded this information.
* If this isn't big enough, keep increasing the size of the
* table until we can retrieve the whole thing.
*/
proc_table = (struct procsinfo *) malloc(avail*(sizeof(struct procsinfo)));
while ( avail == (nprocs = getprocs(proc_table, sizeof(struct procsinfo),
0, sizeof(struct fdsinfo),
&proc_index, avail))) {
avail += 1024;
free( proc_table );
proc_table = (struct procsinfo *) malloc(avail*(sizeof(struct procsinfo)));
}
for ( i=0 ; i<nprocs; i++ ) {
if (0 == proc_table[i].pi_state)
continue; /* Skip unused entries */
entry = netsnmp_swrun_entry_create(proc_table[i].pi_pid);
if (NULL == entry)
continue; /* error already logged by function */
rc = CONTAINER_INSERT(container, entry);
memset(pentry, 0, sizeof(pentry)); /* Empty each time */
if(!(SKPROC & proc_table[i].pi_flags)) { /* Remove kernel processes */
getargs(&proc_table[i], sizeof(struct procsinfo), pentry, sizeof(pentry)); /* Call getargs() */
for(ppentry = pentry; !((*ppentry == '\0') && (*(ppentry+1) == '\0')); ppentry++) { /* Process until 0x00 0x00 */
if((*ppentry == '\0') && (!(*(ppentry+1) == '\0'))) /* if 0x00 !0x00 */
*ppentry = ' '; /* change to 0x20 !0x00 */
}
snprintf(fullpath, sizeof(fullpath)-1, "%.*s", (int)(strchr(pentry, ' ')-pentry), pentry);
entry->hrSWRunPath_len = snprintf(entry->hrSWRunPath,
sizeof(entry->hrSWRunPath), "%s", fullpath);
ppentry = strrchr(fullpath, '/');
if(ppentry == NULL) {
entry->hrSWRunName_len = snprintf(entry->hrSWRunName,
sizeof(entry->hrSWRunName), "%s", fullpath);
}
else {
entry->hrSWRunName_len = snprintf(entry->hrSWRunName,
sizeof(entry->hrSWRunName), "%s", ppentry + 1);
}
ppentry = strchr(pentry, ' ');
entry->hrSWRunParameters_len = snprintf(entry->hrSWRunParameters,
sizeof(entry->hrSWRunParameters), "%.*s", (int)(pentry - ppentry), ppentry + 1);
}
entry->hrSWRunType = (SKPROC & proc_table[i].pi_flags)
? 2 /* kernel process */
: 4 /* application */
;
switch (proc_table[i].pi_state) {
case SACTIVE:
case SRUN: entry->hrSWRunStatus = HRSWRUNSTATUS_RUNNING;
break;
case SSLEEP: entry->hrSWRunStatus = HRSWRUNSTATUS_RUNNABLE;
break;
case SSTOP: entry->hrSWRunStatus = HRSWRUNSTATUS_NOTRUNNABLE;
break;
case SIDL:
case SZOMB:
default: entry->hrSWRunStatus = HRSWRUNSTATUS_INVALID;
break;
}
entry->hrSWRunPerfCPU = (proc_table[i].pi_ru.ru_utime.tv_sec * 100);
entry->hrSWRunPerfCPU += (proc_table[i].pi_ru.ru_utime.tv_usec / 10000000);
entry->hrSWRunPerfCPU += (proc_table[i].pi_ru.ru_stime.tv_sec * 100);
entry->hrSWRunPerfCPU += (proc_table[i].pi_ru.ru_stime.tv_usec / 10000000);
entry->hrSWRunPerfMem = proc_table[i].pi_size;
entry->hrSWRunPerfMem *= (getpagesize()/1024); /* in kB */
}
free(proc_table);
DEBUGMSGTL(("swrun:load:arch"," loaded %d entries\n",
CONTAINER_SIZE(container)));
return 0;
}
|
