plugins/solaris/solaris.c

/* 
 * i-scream central monitoring system
 * http://www.i-scream.org.uk
 * Copyright (C) 2000-2002 i-scream
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */

#include <stdio.h>
#include <sys/types.h>
#include <sys/statvfs.h>
#include <sys/mnttab.h>
#include "ukcprog.h"
#include <sys/utsname.h>
#include <sys/loadavg.h>
#include <utmp.h>
#include <kstat.h>
#include <sys/sysinfo.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/swap.h>
#include <stdlib.h>
#include <strings.h>
#include <time.h>

void die(){
  exit(1);
}


void diskStats(){
  struct mnttab mp;
  struct statvfs df;
  FILE *f;
  int counter=0;
  
  if ((f=fopen("/etc/mnttab", "r" ))==NULL){
      errf("Failed to open mounts (%m)");
      die();
  }
   
  while((getmntent(f, &mp)) == 0){       
    if ((statvfs(mp.mnt_mountp, &df)) !=0){
      errf("Failed to gets fs stats (%m)");
      continue;
    }

    if((((strcmp(mp.mnt_fstype,"ufs"))==0) || (strcmp(mp.mnt_fstype,"tmpfs")) ==0)){
        
      printf("packet.disk.p%d.attributes.mount %s\n", counter, mp.mnt_mountp);
      printf("packet.disk.p%d.attributes.name %s\n", counter, mp.mnt_special);
      printf("packet.disk.p%d.attributes.kbytes %lu\n",counter, ((df.f_frsize/1024) * df.f_blocks));
      printf("packet.disk.p%d.attributes.used %lu\n",counter, (((df.f_frsize/1024) * df.f_blocks) -((df.f_frsize/1024) * df.f_bfree)));
      printf("packet.disk.p%d.attributes.avail %lu\n",counter, (df.f_frsize/1024) * df.f_bavail);
      printf("packet.disk.p%d.attributes.totalinodes %lu\n", counter, df.f_files);
      printf("packet.disk.p%d.attributes.freeinodes %lu\n",counter, df.f_ffree);
    
      counter++;
    }
  }
}

void osStats(){
  struct utsname os;
  
  if((uname(&os)) == -1){
    errf("Failed to get os stats (%m)");
    die();
  }

  printf("packet.os.name %s\n", os.sysname);
  printf("packet.os.release %s\n" , os.release);
  printf("packet.os.version %s\n", os.version);
  printf("packet.os.sysname %s\n" , os.nodename);
  printf("packet.os.platform %s\n", os.machine);

}   
  
void loadStats(){
  double loadav[3];
  
  if((getloadavg(loadav,3)) == -1){
    errf("Failed to get load averages (%m)");
    die();    
  }
  
  printf("packet.load.load1 %.2f\n",loadav[0]);
  printf("packet.load.load5 %.2f\n",loadav[1]);
  printf("packet.load.load15 %.2f\n",loadav[2]);
}

void userStats(){
  int nousers=0;
  struct utmp *entry;
  
  printf("packet.users.list");
  
  while((entry=getutent()) != NULL){
    if(entry->ut_type==USER_PROCESS)
      {
        printf(" %s",entry->ut_user);
        nousers++;
      }
  }
  printf("\npacket.users.count %d\n", nousers);
}

void systemStats(){
  kstat_ctl_t *kc;
  kstat_t *ksp;
  kstat_named_t *kn;
  int pagesize;
  cpu_stat_t cs;
  uint_t cpustats[5][2];
  float usage;
  uint_t user, kernel, idle, iowait, swap, total;
  ulong totalmem, freemem;
  long swaptotal, swapused;
  time_t uptime,curtime;
  
  struct anoninfo ai;

 
  if ((kc = kstat_open()) == NULL) {
    errf("kstat_open failure (%m)");
    die();
  }

  /* Borrowed from gkrellm ;) */

  for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
    if ((strcmp(ksp->ks_module, "cpu_stat")) != 0)
      continue;
    if (kstat_read(kc, ksp, &cs) == -1) {
      perror("kstat_read");
      continue;
    }
  } 

  cpustats[0][0]=cs.cpu_sysinfo.cpu[CPU_USER];
  cpustats[1][0]=cs.cpu_sysinfo.cpu[CPU_WAIT];
  cpustats[2][0]=cs.cpu_sysinfo.cpu[CPU_KERNEL];
  cpustats[3][0]=cs.cpu_sysinfo.cpu[CPU_IDLE];
  cpustats[4][0]=cs.cpu_sysinfo.cpu[CPU_STATES];
  
  sleep(1);
  
  if (kstat_chain_update(kc) == -1) {
    errf("Kstat update failure (%m)");
    die();
  }
  
  for (ksp = kc->kc_chain; ksp!=NULL ; ksp = ksp->ks_next) {
    if ((strcmp(ksp->ks_module, "cpu_stat")) != 0)
      continue;
    if (kstat_read(kc, ksp, &cs) == -1) {
      perror("kstat_read");
      continue;
      }
  }

  cpustats[0][1]=cs.cpu_sysinfo.cpu[CPU_USER];
  cpustats[1][1]=cs.cpu_sysinfo.cpu[CPU_WAIT];
  cpustats[2][1]=cs.cpu_sysinfo.cpu[CPU_KERNEL];
  cpustats[3][1]=cs.cpu_sysinfo.cpu[CPU_IDLE];
  cpustats[4][1]=cs.cpu_sysinfo.cpu[CPU_STATES];

  user=cpustats[0][1]-cpustats[0][0];
  iowait=cpustats[1][1]-cpustats[1][0];
  kernel=cpustats[2][1]-cpustats[2][0];
  idle=cpustats[3][1]-cpustats[3][0];
  swap=cpustats[4][1]-cpustats[4][0];
 
  total=user+kernel+idle+iowait+swap;
  
  usage=((((float)user)/((float)total))*100.00);

  printf("packet.cpu.user %3.2f\n", usage);
  usage=((((float)kernel)/((float)total))*100.00);
  printf("packet.cpu.kernel %3.2f\n", usage);
  usage=((((float)idle)/((float)total))*100.00);
  printf("packet.cpu.idle %3.2f\n", usage);
  usage=((((float)iowait)/((float)total))*100.00);
  printf("packet.cpu.iowait %3.2f\n", usage);
  usage=((((float)swap)/((float)total))*100.00);
  printf("packet.cpu.swap %3.2f\n", usage);
  
  /* MEMORY STATS */
  
  if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
    errf("Failed to get pagesize (%m)");
    die();
  }

  if((totalmem=sysconf(_SC_PHYS_PAGES)) == -1){
    errf("Failed to get total memory");
    die();
  }
  
  totalmem=((totalmem*pagesize)/1024)/1024;
  
  ksp = kstat_lookup(kc, "unix", 0, "system_pages");
  if (kstat_read(kc, ksp, 0) == -1) {
    perror("kstat_read");
    die();
  }  

  if((kn=kstat_data_lookup(ksp, "freemem")) == NULL){
    errf("Failed to get free memory (%m)");
    die();
  }
  
  freemem=(((kn->value.ul)*pagesize)/1024)/1024;

  printf("packet.memory.total %lu\n",totalmem);
  printf("packet.memory.free %lu\n",freemem);
  printf("packet.memory.used %lu\n",(totalmem-freemem));


  if (swapctl(SC_AINFO, &ai) == -1) {
    errf("Failed to get swap details (%m)");
    die();
  }

  swaptotal=((ai.ani_max/1024)*pagesize)/1024;
  swapused=((ai.ani_resv/1024)*pagesize)/1024;

  /* Ok this is actually for TOP combatability, but this is not
     total swap, cos it actually also seems to include memory stats. */
  printf("packet.swap.total %ld\n",swaptotal);
  printf("packet.swap.used %ld\n", swapused);
  printf("packet.swap.free %lu\n", (swaptotal-swapused));

  ksp=kstat_lookup(kc, "unix", -1, "system_misc");
  if (kstat_read(kc, ksp, 0) == -1) {
    errf("Failed to get uptime (%m)");
    die();
  }

  if((kn=kstat_data_lookup(ksp, "boot_time")) == NULL){
    errf("Failed to get uptime (%m)");
    die();
  }

  uptime=(kn->value.ui32);
  time(&curtime);
  printf("packet.os.uptime %ld\n", (curtime-uptime));

}    
  
void processStats() {
    int sleeping=-1;
    int zombie=0;
    int stopped=0;
    int running=0;
    char *line;
    char *line_p;


    FILE *f;

    if((f=popen("/bin/ps -Al" , "r")) == NULL) {
        errf("Failed to get process stats (%m)");
        die();
    }

    while((line=fpgetline(f)) != NULL) {
      line_p=line;
      for(; (*line_p == ' ') && (*line_p != '\0'); line_p++);
      line_p=strchr(line_p, ' ');
      for(; (*line_p == ' ') && (*line_p != '\0'); line_p++);
      if (line_p==NULL) abort();
      /* Ok, we should now be at the state :) .. */
      if (*line_p=='S') sleeping++;
      if (*line_p=='R') running++;
      if (*line_p=='Z') zombie++;
      if (*line_p=='T') stopped++;
    }

    if((pclose(f)) == -1) {
        errf("Failed to close process stats (%m)");
        die();
    }

    printf("packet.processes.sleeping %d\n",sleeping);
    printf("packet.processes.cpu %d\n",running);
    printf("packet.processes.zombie %d\n",zombie);
    printf("packet.processes.stopped %d\n", stopped);
    printf("packet.processes.total %d\n", (sleeping+running+zombie+stopped));

}


int main(){
  diskStats();
  osStats();
  loadStats();
  userStats();
  systemStats();
  processStats();
  return 0;
}

Revision:	1.11
Committed:	Fri Mar 28 16:30:34 2003 UTC (21 years, 7 months ago) by tdb
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.10:	+0 -0 lines
State:	*FILE REMOVED*
Log Message:	Removed some un-used code from CVS. We can always resurrect this later if someone feels they want to work on it. Gone are the old perl ihost which isn't needed now, winhost which is broken and shows no sign of being fixed, and DBReporter. If someone wants to revive them, I'll undelete them :-)
#	Content
1	/*
2	* i-scream central monitoring system
3	* http://www.i-scream.org.uk
4	* Copyright (C) 2000-2002 i-scream
5	*
6	* This program is free software; you can redistribute it and/or
7	* modify it under the terms of the GNU General Public License
8	* as published by the Free Software Foundation; either version 2
9	* of the License, or (at your option) any later version.
10	*
11	* This program is distributed in the hope that it will be useful,
12	* but WITHOUT ANY WARRANTY; without even the implied warranty of
13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14	* GNU General Public License for more details.
15	*
16	* You should have received a copy of the GNU General Public License
17	* along with this program; if not, write to the Free Software
18	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
19	*/
20
21	#include <stdio.h>
22	#include <sys/types.h>
23	#include <sys/statvfs.h>
24	#include <sys/mnttab.h>
25	#include "ukcprog.h"
26	#include <sys/utsname.h>
27	#include <sys/loadavg.h>
28	#include <utmp.h>
29	#include <kstat.h>
30	#include <sys/sysinfo.h>
31	#include <unistd.h>
32	#include <sys/stat.h>
33	#include <sys/swap.h>
34	#include <stdlib.h>
35	#include <strings.h>
36	#include <time.h>
37
38	void die(){
39	exit(1);
40	}
41
42
43	void diskStats(){
44	struct mnttab mp;
45	struct statvfs df;
46	FILE *f;
47	int counter=0;
48
49	if ((f=fopen("/etc/mnttab", "r" ))==NULL){
50	errf("Failed to open mounts (%m)");
51	die();
52	}
53
54	while((getmntent(f, &mp)) == 0){
55	if ((statvfs(mp.mnt_mountp, &df)) !=0){
56	errf("Failed to gets fs stats (%m)");
57	continue;
58	}
59
60	if((((strcmp(mp.mnt_fstype,"ufs"))==0) \|\| (strcmp(mp.mnt_fstype,"tmpfs")) ==0)){
61
62	printf("packet.disk.p%d.attributes.mount %s\n", counter, mp.mnt_mountp);
63	printf("packet.disk.p%d.attributes.name %s\n", counter, mp.mnt_special);
64	printf("packet.disk.p%d.attributes.kbytes %lu\n",counter, ((df.f_frsize/1024) * df.f_blocks));
65	printf("packet.disk.p%d.attributes.used %lu\n",counter, (((df.f_frsize/1024) * df.f_blocks) -((df.f_frsize/1024) * df.f_bfree)));
66	printf("packet.disk.p%d.attributes.avail %lu\n",counter, (df.f_frsize/1024) * df.f_bavail);
67	printf("packet.disk.p%d.attributes.totalinodes %lu\n", counter, df.f_files);
68	printf("packet.disk.p%d.attributes.freeinodes %lu\n",counter, df.f_ffree);
69
70	counter++;
71	}
72	}
73	}
74
75	void osStats(){
76	struct utsname os;
77
78	if((uname(&os)) == -1){
79	errf("Failed to get os stats (%m)");
80	die();
81	}
82
83	printf("packet.os.name %s\n", os.sysname);
84	printf("packet.os.release %s\n" , os.release);
85	printf("packet.os.version %s\n", os.version);
86	printf("packet.os.sysname %s\n" , os.nodename);
87	printf("packet.os.platform %s\n", os.machine);
88
89	}
90
91	void loadStats(){
92	double loadav[3];
93
94	if((getloadavg(loadav,3)) == -1){
95	errf("Failed to get load averages (%m)");
96	die();
97	}
98
99	printf("packet.load.load1 %.2f\n",loadav[0]);
100	printf("packet.load.load5 %.2f\n",loadav[1]);
101	printf("packet.load.load15 %.2f\n",loadav[2]);
102	}
103
104	void userStats(){
105	int nousers=0;
106	struct utmp *entry;
107
108	printf("packet.users.list");
109
110	while((entry=getutent()) != NULL){
111	if(entry->ut_type==USER_PROCESS)
112	{
113	printf(" %s",entry->ut_user);
114	nousers++;
115	}
116	}
117	printf("\npacket.users.count %d\n", nousers);
118	}
119
120	void systemStats(){
121	kstat_ctl_t *kc;
122	kstat_t *ksp;
123	kstat_named_t *kn;
124	int pagesize;
125	cpu_stat_t cs;
126	uint_t cpustats[5][2];
127	float usage;
128	uint_t user, kernel, idle, iowait, swap, total;
129	ulong totalmem, freemem;
130	long swaptotal, swapused;
131	time_t uptime,curtime;
132
133	struct anoninfo ai;
134
135
136	if ((kc = kstat_open()) == NULL) {
137	errf("kstat_open failure (%m)");
138	die();
139	}
140
141	/* Borrowed from gkrellm ;) */
142
143	for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
144	if ((strcmp(ksp->ks_module, "cpu_stat")) != 0)
145	continue;
146	if (kstat_read(kc, ksp, &cs) == -1) {
147	perror("kstat_read");
148	continue;
149	}
150	}
151
152	cpustats[0][0]=cs.cpu_sysinfo.cpu[CPU_USER];
153	cpustats[1][0]=cs.cpu_sysinfo.cpu[CPU_WAIT];
154	cpustats[2][0]=cs.cpu_sysinfo.cpu[CPU_KERNEL];
155	cpustats[3][0]=cs.cpu_sysinfo.cpu[CPU_IDLE];
156	cpustats[4][0]=cs.cpu_sysinfo.cpu[CPU_STATES];
157
158	sleep(1);
159
160	if (kstat_chain_update(kc) == -1) {
161	errf("Kstat update failure (%m)");
162	die();
163	}
164
165	for (ksp = kc->kc_chain; ksp!=NULL ; ksp = ksp->ks_next) {
166	if ((strcmp(ksp->ks_module, "cpu_stat")) != 0)
167	continue;
168	if (kstat_read(kc, ksp, &cs) == -1) {
169	perror("kstat_read");
170	continue;
171	}
172	}
173
174	cpustats[0][1]=cs.cpu_sysinfo.cpu[CPU_USER];
175	cpustats[1][1]=cs.cpu_sysinfo.cpu[CPU_WAIT];
176	cpustats[2][1]=cs.cpu_sysinfo.cpu[CPU_KERNEL];
177	cpustats[3][1]=cs.cpu_sysinfo.cpu[CPU_IDLE];
178	cpustats[4][1]=cs.cpu_sysinfo.cpu[CPU_STATES];
179
180	user=cpustats[0][1]-cpustats[0][0];
181	iowait=cpustats[1][1]-cpustats[1][0];
182	kernel=cpustats[2][1]-cpustats[2][0];
183	idle=cpustats[3][1]-cpustats[3][0];
184	swap=cpustats[4][1]-cpustats[4][0];
185
186	total=user+kernel+idle+iowait+swap;
187
188	usage=((((float)user)/((float)total))*100.00);
189
190	printf("packet.cpu.user %3.2f\n", usage);
191	usage=((((float)kernel)/((float)total))*100.00);
192	printf("packet.cpu.kernel %3.2f\n", usage);
193	usage=((((float)idle)/((float)total))*100.00);
194	printf("packet.cpu.idle %3.2f\n", usage);
195	usage=((((float)iowait)/((float)total))*100.00);
196	printf("packet.cpu.iowait %3.2f\n", usage);
197	usage=((((float)swap)/((float)total))*100.00);
198	printf("packet.cpu.swap %3.2f\n", usage);
199
200	/* MEMORY STATS */
201
202	if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
203	errf("Failed to get pagesize (%m)");
204	die();
205	}
206
207	if((totalmem=sysconf(_SC_PHYS_PAGES)) == -1){
208	errf("Failed to get total memory");
209	die();
210	}
211
212	totalmem=((totalmem*pagesize)/1024)/1024;
213
214	ksp = kstat_lookup(kc, "unix", 0, "system_pages");
215	if (kstat_read(kc, ksp, 0) == -1) {
216	perror("kstat_read");
217	die();
218	}
219
220	if((kn=kstat_data_lookup(ksp, "freemem")) == NULL){
221	errf("Failed to get free memory (%m)");
222	die();
223	}
224
225	freemem=(((kn->value.ul)*pagesize)/1024)/1024;
226
227	printf("packet.memory.total %lu\n",totalmem);
228	printf("packet.memory.free %lu\n",freemem);
229	printf("packet.memory.used %lu\n",(totalmem-freemem));
230
231
232	if (swapctl(SC_AINFO, &ai) == -1) {
233	errf("Failed to get swap details (%m)");
234	die();
235	}
236
237	swaptotal=((ai.ani_max/1024)*pagesize)/1024;
238	swapused=((ai.ani_resv/1024)*pagesize)/1024;
239
240	/* Ok this is actually for TOP combatability, but this is not
241	total swap, cos it actually also seems to include memory stats. */
242	printf("packet.swap.total %ld\n",swaptotal);
243	printf("packet.swap.used %ld\n", swapused);
244	printf("packet.swap.free %lu\n", (swaptotal-swapused));
245
246	ksp=kstat_lookup(kc, "unix", -1, "system_misc");
247	if (kstat_read(kc, ksp, 0) == -1) {
248	errf("Failed to get uptime (%m)");
249	die();
250	}
251
252	if((kn=kstat_data_lookup(ksp, "boot_time")) == NULL){
253	errf("Failed to get uptime (%m)");
254	die();
255	}
256
257	uptime=(kn->value.ui32);
258	time(&curtime);
259	printf("packet.os.uptime %ld\n", (curtime-uptime));
260
261	}
262
263	void processStats() {
264	int sleeping=-1;
265	int zombie=0;
266	int stopped=0;
267	int running=0;
268	char *line;
269	char *line_p;
270
271
272	FILE *f;
273
274	if((f=popen("/bin/ps -Al" , "r")) == NULL) {
275	errf("Failed to get process stats (%m)");
276	die();
277	}
278
279	while((line=fpgetline(f)) != NULL) {
280	line_p=line;
281	for(; (line_p == ' ') && (line_p != '\0'); line_p++);
282	line_p=strchr(line_p, ' ');
283	for(; (line_p == ' ') && (line_p != '\0'); line_p++);
284	if (line_p==NULL) abort();
285	/* Ok, we should now be at the state :) .. */
286	if (*line_p=='S') sleeping++;
287	if (*line_p=='R') running++;
288	if (*line_p=='Z') zombie++;
289	if (*line_p=='T') stopped++;
290	}
291
292	if((pclose(f)) == -1) {
293	errf("Failed to close process stats (%m)");
294	die();
295	}
296
297	printf("packet.processes.sleeping %d\n",sleeping);
298	printf("packet.processes.cpu %d\n",running);
299	printf("packet.processes.zombie %d\n",zombie);
300	printf("packet.processes.stopped %d\n", stopped);
301	printf("packet.processes.total %d\n", (sleeping+running+zombie+stopped));
302
303	}
304
305
306	int main(){
307	diskStats();
308	osStats();
309	loadStats();
310	userStats();
311	systemStats();
312	processStats();
313	return 0;
314	}
315