ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/libstatgrab/src/saidar/saidar.c

Comparing projects/libstatgrab/src/saidar/saidar.c (file contents):
Revision 1.27 by ats, Mon Apr 5 15:40:17 2004 UTC vs.
Revision 1.36 by tdb, Thu Nov 30 23:42:43 2006 UTC

#	Line 1 | Line 1
1		/*
2	<	* i-scream central monitoring system
2	>	* i-scream libstatgrab
3		* http://www.i-scream.org
4		* Copyright (C) 2000-2004 i-scream
5		*
#	Line 36 | Line 36
36		#include <sys/times.h>
37		#include <limits.h>
38		#include <time.h>
39	+	#include <math.h>
40
41		#ifdef HAVE_NCURSES_H
42		#include <ncurses.h>
#	Line 43 | Line 44
44		#include <curses.h>
45		#endif
46
47	+	#define THRESHOLD_LOAD 1.0
48	+
49	+	#define THRESHOLD_WARN_ZMB 0
50	+
51	+	#define THRESHOLD_WARN_CPU 60.0
52	+	#define THRESHOLD_ALERT_CPU 90.0
53	+
54	+	#define THRESHOLD_WARN_SWAP 75.0
55	+	#define THRESHOLD_ALERT_SWAP 90.0
56	+
57	+	#define THRESHOLD_WARN_MEM 75.0
58	+	#define THRESHOLD_ALERT_MEM 90.0
59	+
60	+	#define THRESHOLD_WARN_DISK 75.0
61	+	#define THRESHOLD_ALERT_DISK 90.0
62	+
63		typedef struct{
64		sg_cpu_percents *cpu_percents;
65		sg_mem_stats *mem_stats;
#	Line 63 | Line 80 | typedef struct{
80		sg_host_info *host_info;
81		sg_user_stats *user_stats;
82		}stats_t;
83	<
83	>
84		stats_t stats;
85
86		char *size_conv(long long number){
87		char type[] = {'B', 'K', 'M', 'G', 'T'};
88		int x=0;
89	+	int sign=1;
90		static char string[10];
91
92	+	if(number < 0){
93	+	sign=-1;
94	+	number=-number;
95	+	}
96	+
97		for(;x<5;x++){
98		if( (number/1024) < (100)) {
99		break;
#	Line 78 | Line 101 | char *size_conv(long long number){
101		number = (number/1024);
102		}
103
104	<	snprintf(string, 10, "%lld%c", number, type[x]);
104	>	number = number*sign;
105	>
106	>	snprintf(string, 10, "%lld%c", number, type[x]);
107		return string;
108	<
108	>
109		}
110
111		char *hr_uptime(time_t time){
112		int day = 0, hour = 0, min = 0;
113		static char uptime_str[25];
114		int sec = (int) time;
115	<
115	>
116		day = sec / (24*60*60);
117		sec = sec % (24*60*60);
118		hour = sec / (60*60);
#	Line 152 | Line 177 | void display_headings(){
177		printw("Mem Free  :");
178
179		/* Swap */
180	<	move(6, 21);
181	<	printw("Swap Total:");
182	<	move(7, 21);
183	<	printw("Swap Used :");
184	<	move(8, 21);
185	<	printw("Swap Free :");
180	>	move(6, 21);
181	>	printw("Swap Total:");
182	>	move(7, 21);
183	>	printw("Swap Used :");
184	>	move(8, 21);
185	>	printw("Swap Free :");
186
187		/* VM */
188		move(6, 42);
#	Line 179 | Line 204 | void display_headings(){
204		move(10,15);
205		printw("Read");
206		move(10,28);
207	<	printw("Write");
207	>	printw("Write");
208
209		line = 10;
210		if (stats.network_io_stats != NULL) {
#	Line 203 | Line 228 | void display_headings(){
228		refresh();
229		}
230
231	<	void display_data(){
231	>	void display_data(int colors){
232		char cur_time[20];
233		struct tm *tm_time;
234		time_t epoc_time;
#	Line 228 | Line 253 | void display_data(){
253		*/
254		if (ptr != NULL){
255		*ptr = '\0';
256	<	}
256	>	}
257	>	if (colors) {
258	>	attron(COLOR_PAIR(1));
259	>	}
260		printw("%s", hostname);
261		move(0,36);
262		printw("%s", hr_uptime(stats.host_info->uptime));
#	Line 237 | Line 265 | void display_data(){
265		strftime(cur_time, 20, "%Y-%m-%d %T", tm_time);
266		move(0,61);
267		printw("%s", cur_time);
268	+	if (colors) {
269	+	attroff(COLOR_PAIR(1));
270	+	}
271		}
272
273		if (stats.load_stats != NULL) {
274		/* Load */
275	+	if (colors) {
276	+	attron(COLOR_PAIR(6));
277	+	}
278		move(2,12);
279	+	if (colors && fabs(stats.load_stats->min1 - stats.load_stats->min5) > THRESHOLD_LOAD) {
280	+	attron(A_BOLD);
281	+	}
282		printw("%6.2f", stats.load_stats->min1);
283	+	if (colors) {
284	+	attroff(A_BOLD);
285	+	}
286		move(3,12);
287	+	if (colors && fabs(stats.load_stats->min5 - stats.load_stats->min15) > THRESHOLD_LOAD) {
288	+	attron(A_BOLD);
289	+	}
290		printw("%6.2f", stats.load_stats->min5);
291	+	if (colors) {
292	+	attroff(A_BOLD);
293	+	}
294		move(4,12);
295	+	if (colors && fabs(stats.load_stats->min1 - stats.load_stats->min15) > THRESHOLD_LOAD) {
296	+	attron(A_BOLD);
297	+	}
298		printw("%6.2f", stats.load_stats->min15);
299	+	if (colors) {
300	+	attroff(A_BOLD);
301	+	}
302		}
303
304		if (stats.cpu_percents != NULL) {
#	Line 256 | Line 308 | void display_data(){
308		move(3,33);
309		printw("%6.2f%%", (stats.cpu_percents->kernel + stats.cpu_percents->iowait + stats.cpu_percents->swap));
310		move(4,33);
311	+	if (colors && stats.cpu_percents->user + stats.cpu_percents->nice > THRESHOLD_ALERT_CPU) {
312	+	attron(A_STANDOUT);
313	+	}
314	+	else if (colors && stats.cpu_percents->user + stats.cpu_percents->nice > THRESHOLD_WARN_CPU) {
315	+	attron(A_BOLD);
316	+	}
317		printw("%6.2f%%", (stats.cpu_percents->user + stats.cpu_percents->nice));
318	+	if(colors) {
319	+	attroff(A_BOLD);
320	+	attroff(A_STANDOUT);
321	+	attron(COLOR_PAIR(6));
322	+	}
323		}
324
325		if (stats.process_count != NULL) {
#	Line 264 | Line 327 | void display_data(){
327		move(2, 54);
328		printw("%5d", stats.process_count->running);
329		move(2,74);
330	+	if (colors && stats.process_count->zombie > THRESHOLD_WARN_ZMB) {
331	+	attron(A_STANDOUT);
332	+	}
333		printw("%5d", stats.process_count->zombie);
334	+	if(colors) {
335	+	attroff(A_STANDOUT);
336	+	attron(COLOR_PAIR(6));
337	+	}
338		move(3, 54);
339		printw("%5d", stats.process_count->sleeping);
340		move(3, 74);
#	Line 277 | Line 347 | void display_data(){
347		printw("%5d", stats.user_stats->num_entries);
348		}
349
350	+	if(colors) {
351	+	attroff(COLOR_PAIR(6));
352	+	attron(COLOR_PAIR(5));
353	+	}
354		if (stats.mem_stats != NULL) {
355		/* Mem */
356		move(6, 12);
357	<	printw("%7s", size_conv(stats.mem_stats->total));
357	>	printw("%7s", size_conv(stats.mem_stats->total));
358		move(7, 12);
359	<	printw("%7s", size_conv(stats.mem_stats->used));
359	>	printw("%7s", size_conv(stats.mem_stats->used));
360		move(8, 12);
361		printw("%7s", size_conv(stats.mem_stats->free));
362		}
363	<
364	<	if (stats.swap_stats != NULL) {
363	>
364	>	if (stats.swap_stats != NULL) {
365		/* Swap */
366		move(6, 32);
367		printw("%8s", size_conv(stats.swap_stats->total));
#	Line 298 | Line 372 | void display_data(){
372		}
373
374		/* VM */
375	<	if (stats.mem_stats != NULL && stats.mem_stats->total != 0) {
375	>	if (stats.mem_stats != NULL && stats.mem_stats->total != 0) {
376	>	float f = 100.00 * (float)(stats.mem_stats->used)/stats.mem_stats->total;
377	>	if (colors && f > THRESHOLD_ALERT_MEM) {
378	>	attron(A_STANDOUT);
379	>	}
380	>	else if (colors && f > THRESHOLD_WARN_MEM) {
381	>	attron(A_BOLD);
382	>	}
383		move(6, 54);
384	<	printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used)/stats.mem_stats->total));
384	>	printw("%5.2f%%", f);
385	>	if (colors) {
386	>	attroff(A_STANDOUT);
387	>	attroff(A_BOLD);
388	>	attron(COLOR_PAIR(5));
389	>	}
390		}
391	<	if (stats.swap_stats != NULL && stats.swap_stats->total != 0) {
391	>	if (stats.swap_stats != NULL && stats.swap_stats->total != 0) {
392	>	float f = 100.00 * (float)(stats.swap_stats->used)/stats.swap_stats->total;
393	>	if (colors && f > THRESHOLD_ALERT_SWAP) {
394	>	attron(A_STANDOUT);
395	>	}
396	>	else if (colors && f > THRESHOLD_WARN_SWAP) {
397	>	attron(A_BOLD);
398	>	}
399		move(7, 54);
400	<	printw("%5.2f%%", (100.00 * (float)(stats.swap_stats->used)/stats.swap_stats->total));
400	>	printw("%5.2f%%", f);
401	>	if (colors) {
402	>	attroff(A_STANDOUT);
403	>	attroff(A_BOLD);
404	>	attron(COLOR_PAIR(5));
405	>	}
406		}
407		if (stats.mem_stats != NULL && stats.swap_stats != NULL &&
408	<	stats.mem_stats->total != 0 && stats.swap_stats->total != 0) {
408	>	stats.mem_stats->total != 0 && stats.swap_stats->total != 0) {
409		move(8, 54);
410		printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used+stats.swap_stats->used)/(stats.mem_stats->total+stats.swap_stats->total)));
411		}
412
413	<	if (stats.page_stats != NULL) {
413	>	if (stats.page_stats != NULL) {
414		/* Paging */
415		move(6, 74);
416		printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pagein / stats.page_stats->systime): stats.page_stats->pages_pagein);
417		move(7, 74);
418		printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pageout / stats.page_stats->systime) : stats.page_stats->pages_pageout);
419		}
420	+	if (colors) {
421	+	attroff(COLOR_PAIR(5));
422	+	}
423
424		line = 11;
425	<	if (stats.disk_io_stats != NULL) {
425	>	if (stats.disk_io_stats != NULL) {
426		/* Disk IO */
427		disk_io_stat_ptr = stats.disk_io_stats;
428		r=0;
429		w=0;
430		for(counter=0;counter<stats.disk_io_entries;counter++){
431	+	char name[12];
432	+	strncpy(name, disk_io_stat_ptr->disk_name, sizeof(name));
433	+	name[sizeof(name)-1] = '\0'; /* strncpy doesn't terminate longer strings */
434		move(line, 0);
435	<	printw("%s", disk_io_stat_ptr->disk_name);
435	>	printw("%s", name);
436		move(line, 12);
437		rt = (disk_io_stat_ptr->systime)? (disk_io_stat_ptr->read_bytes/disk_io_stat_ptr->systime): disk_io_stat_ptr->read_bytes;
438	+	if(colors) {
439	+	attron(COLOR_PAIR(4));
440	+	}
441		printw("%7s", size_conv(rt));
442		r+=rt;
443		move(line, 26);
#	Line 339 | Line 446 | void display_data(){
446		w+=wt;
447		disk_io_stat_ptr++;
448		line++;
449	+	if(colors) {
450	+	attroff(COLOR_PAIR(4));
451	+	}
452		}
453		line++;
454		move(line, 0);
455		printw("Total");
456		move(line, 12);
457	+	if(colors) {
458	+	attron(COLOR_PAIR(4));
459	+	}
460		printw("%7s", size_conv(r));
461		move(line, 26);
462		printw("%7s", size_conv(w));
463	+	if(colors) {
464	+	attroff(COLOR_PAIR(4));
465	+	}
466		}
467
468		line = 11;
469	<	if (stats.network_io_stats != NULL) {
469	>	if (stats.network_io_stats != NULL) {
470		/* Network */
471		network_stat_ptr = stats.network_io_stats;
472		for(counter=0;counter<stats.network_io_entries;counter++){
473	<	move(line, 42);
474	<	printw("%s", network_stat_ptr->interface_name);
473	>	char name[20];
474	>	strncpy(name, network_stat_ptr->interface_name, sizeof(name));
475	>	name[sizeof(name)-1] = '\0'; /* strncpy doesn't terminate longer strings */
476	>	move(line, 42);
477	>	printw("%s", name);
478		move(line, 62);
479		rt = (network_stat_ptr->systime)? (network_stat_ptr->rx / network_stat_ptr->systime): network_stat_ptr->rx;
480	+	if(colors) {
481	+	attron(COLOR_PAIR(4));
482	+	}
483		printw("%7s", size_conv(rt));
484		move(line, 72);
485	<	wt = (network_stat_ptr->systime)? (network_stat_ptr->tx / network_stat_ptr->systime): network_stat_ptr->tx;
485	>	wt = (network_stat_ptr->systime)? (network_stat_ptr->tx / network_stat_ptr->systime): network_stat_ptr->tx;
486		printw("%7s", size_conv(wt));
487		network_stat_ptr++;
488		line++;
489	+	if(colors) {
490	+	attroff(COLOR_PAIR(4));
491	+	}
492		}
493		line += 2;
494		}
495
496	<	if (stats.fs_stats != NULL) {
496	>	if (stats.fs_stats != NULL) {
497		/* Disk */
498		disk_stat_ptr = stats.fs_stats;
499		for(counter=0;counter<stats.fs_entries;counter++){
500	+	char name[20];
501	+	strncpy(name, disk_stat_ptr->mnt_point, sizeof(name));
502	+	name[sizeof(name)-1] = '\0'; /* strncpy doesn't terminate longer strings */
503		move(line, 42);
504	<	printw("%s", disk_stat_ptr->mnt_point);
504	>	printw("%s", name);
505		move(line, 62);
506	+	if(colors) {
507	+	attron(COLOR_PAIR(2));
508	+	}
509		printw("%7s", size_conv(disk_stat_ptr->avail));
510		move(line, 73);
511	<	printw("%5.2f%%", 100.00 * ((float) disk_stat_ptr->used / (float) (disk_stat_ptr->used + disk_stat_ptr->avail)));
511	>	if(colors && 100.00 * ((float) disk_stat_ptr->used / (float) (disk_stat_ptr->used + disk_stat_ptr->avail)) > THRESHOLD_ALERT_DISK) {
512	>	attron(A_STANDOUT);
513	>	} else if (colors && 100.00 * ((float) disk_stat_ptr->used / (float) (disk_stat_ptr->used + disk_stat_ptr->avail)) > THRESHOLD_WARN_DISK) {
514	>	attron(A_BOLD);
515	>	}
516	>	printw("%6.2f%%", 100.00 * ((float) disk_stat_ptr->used / (float) (disk_stat_ptr->used + disk_stat_ptr->avail)));
517		disk_stat_ptr++;
518		line++;
519	+	if(colors) {
520	+	attroff(COLOR_PAIR(2));
521	+	attroff(A_STANDOUT);
522	+	attroff(A_BOLD);
523	+	}
524		}
525		}
526
527		refresh();
528		}
529
530	<	void sig_winch_handler(int sig){
530	>	void sig_winch_handler(int dummy){
531		clear();
532		display_headings();
533	<	display_data();
534	<	signal(SIGWINCH, sig_winch_handler);
533	>	display_data(0);
534	>	signal(SIGWINCH, sig_winch_handler);
535		}
536
537		int get_stats(){
#	Line 416 | Line 557 | void version_num(char *progname){
557		}
558
559		void usage(char *progname){
560	<	fprintf(stderr, "Usage: %s [-d delay] [-v] [-h]\n\n", progname);
561	<	fprintf(stderr, "  -d    Sets the update time in seconds\n");
560	>	fprintf(stderr, "Usage: %s [-d delay] [-c] [-v] [-h]\n\n", progname);
561	>	fprintf(stderr, "  -d    Sets the update time in seconds\n");
562	>	fprintf(stderr, "  -c    Enables coloured output\n");
563		fprintf(stderr, "  -v    Prints version number\n");
564	<	fprintf(stderr, "  -h    Displays this help information.\n");
565	<	fprintf(stderr, "\nReport bugs to <%s>.\n", PACKAGE_BUGREPORT);
566	<	exit(1);
564	>	fprintf(stderr, "  -h    Displays this help information.\n");
565	>	fprintf(stderr, "\nReport bugs to <%s>.\n", PACKAGE_BUGREPORT);
566	>	exit(1);
567		}
568
569		int main(int argc, char **argv){
570	+	extern char *optarg;
571	+	int c;
572	+	int colouron = 0;
573
429	–	extern char *optarg;
430	–	int c;
431	–
574		time_t last_update = 0;
575
576		WINDOW *window;
#	Line 442 | Line 584 | int main(int argc, char **argv){
584		fprintf(stderr, "Failed to drop setuid/setgid privileges\n");
585		return 1;
586		}
587	<
588	<	while ((c = getopt(argc, argv, "vhd:")) != -1){
589	<	switch (c){
590	<	case 'd':
591	<	delay = atoi(optarg);
587	>
588	>	while ((c = getopt(argc, argv, "d:cvh")) != -1){
589	>	switch (c){
590	>	case 'd':
591	>	delay = atoi(optarg);
592		if (delay < 1){
593		fprintf(stderr, "Time must be 1 second or greater\n");
594		exit(1);
595		}
596	<	break;
596	>	break;
597	>	case 'c':
598	>	colouron = 1;
599	>	break;
600		case 'v':
601	<	version_num(argv[0]);
601	>	version_num(argv[0]);
602		break;
603		case 'h':
604		default:
605		usage(argv[0]);
606		return 1;
607		break;
608	<	}
609	<	}
608	>	}
609	>	}
610
611		signal(SIGWINCH, sig_winch_handler);
612	<	initscr();
613	<	nonl();
614	<	cbreak();
615	<	noecho();
612	>	initscr();
613	>	/* turn on colour */
614	>	if (colouron) {
615	>	if (has_colors()) {
616	>	start_color();
617	>	use_default_colors();
618	>	init_pair(1,COLOR_RED,-1);
619	>	init_pair(2,COLOR_GREEN,-1);
620	>	init_pair(3,COLOR_YELLOW,-1);
621	>	init_pair(4,COLOR_BLUE,-1);
622	>	init_pair(5,COLOR_MAGENTA,-1);
623	>	init_pair(6,COLOR_CYAN,-1);
624	>	} else {
625	>	fprintf(stderr, "Colour support disabled: your terminal does not support colour.");
626	>	colouron = 0;
627	>	}
628	>	}
629	>	nonl();
630	>	cbreak();
631	>	noecho();
632		timeout(delay * 1000);
633	<	window=newwin(0, 0, 0, 0);
633	>	window=newwin(0, 0, 0, 0);
634		clear();
635
636		if(!get_stats()){
#	Line 497 | Line 658 | int main(int argc, char **argv){
658		}
659		last_update = now;
660
661	<	display_data();
662	<	}
661	>	display_data(colouron);
662	>	}
663
664		endwin();
665		return 0;
666	<	}
666	>	}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines