plugins/solaris/solaris.c

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