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.1 by pajs, Thu Oct 9 15:57:05 2003 UTC vs.
Revision 1.12 by tdb, Tue Oct 21 18:01:15 2003 UTC

#	Line 1 | Line 1
1	+	/*
2	+	* i-scream central monitoring system
3	+	* http://www.i-scream.org
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	+	#ifdef HAVE_CONFIG_H
22	+	#include "config.h"
23	+	#endif
24	+
25		#include <stdio.h>
26		#include <string.h>
27		#include <sys/ioctl.h>
#	Line 10 | Line 34
34		#include <sys/times.h>
35		#include <limits.h>
36		#include <time.h>
37	+
38	+	#ifdef HAVE_NCURSES_H
39	+	#include <ncurses.h>
40	+	#else
41		#include <curses.h>
42	+	#endif
43
44		typedef struct{
45		cpu_percent_t *cpu_percents;
#	Line 73 | Line 102 | char *hr_uptime(time_t time){
102		}
103
104		void display_headings(){
105	+	int line;
106	+
107		move(0,0);
108		printw("Hostname  :");
109		move(0,27);
#	Line 148 | Line 179 | void display_headings(){
179		move(10,28);
180		printw("Write");
181
182	<	/* Network IO */
183	<	move(10, 42);
184	<	printw("Network Interface");
185	<	move(10, 67);
186	<	printw("rx");
187	<	move(10,77);
188	<	printw("tx");
182	>	line = 10;
183	>	if (stats.network_stats != NULL) {
184	>	/* Network IO */
185	>	move(line, 42);
186	>	printw("Network Interface");
187	>	move(line, 67);
188	>	printw("rx");
189	>	move(line, 77);
190	>	printw("tx");
191	>	line += 2 + stats.network_entries;
192	>	}
193
194	<	move(12+stats.network_entries, 42);
194	>	move(line, 42);
195		printw("Mount Point");
196	<	move(12+stats.network_entries, 65);
196	>	move(line, 65);
197		printw("Free");
198	<	move(12+stats.network_entries, 75);
198	>	move(line, 75);
199		printw("Used");
200
201		refresh();
#	Line 170 | Line 205 | void display_data(){
205		char cur_time[20];
206		struct tm *tm_time;
207		time_t epoc_time;
208	<	int counter;
208	>	int counter, line;
209		long long r,w;
210		long long rt, wt;
211		diskio_stat_t *diskio_stat_ptr;
212		network_stat_t *network_stat_ptr;
213		disk_stat_t *disk_stat_ptr;
214	+	/* Size before it will start overwriting "uptime" */
215	+	char hostname[15];
216	+	char *ptr;
217
218	<	move(0,12);
219	<	printw("%s", stats.general_stats->hostname);
220	<	move(0,36);
221	<	printw("%s", hr_uptime(stats.general_stats->uptime));
222	<	epoc_time=time(NULL);
223	<	tm_time = localtime(&epoc_time);
224	<	strftime(cur_time, 20, "%Y-%m-%d %T", tm_time);
225	<	move(0,61);
226	<	printw("%s", cur_time);
218	>	if (stats.general_stats != NULL) {
219	>	move(0,12);
220	>	strncpy(hostname, stats.general_stats->hostname, (sizeof(hostname) - 1));
221	>	/* strncpy does not NULL terminate.. If only strlcpy was on all platforms :) */
222	>	hostname[14] = '\0';
223	>	ptr=strchr(hostname, '.');
224	>	/* Some hosts give back a FQDN for hostname. To avoid this, we'll
225	>	* just blank out everything after the first "."
226	>	*/
227	>	if (ptr != NULL){
228	>	*ptr = '\0';
229	>	}
230	>	printw("%s", hostname);
231	>	move(0,36);
232	>	printw("%s", hr_uptime(stats.general_stats->uptime));
233	>	epoc_time=time(NULL);
234	>	tm_time = localtime(&epoc_time);
235	>	strftime(cur_time, 20, "%Y-%m-%d %T", tm_time);
236	>	move(0,61);
237	>	printw("%s", cur_time);
238	>	}
239
240	<	/* Load */
241	<	move(2,12);
242	<	printw("%6.2f", stats.load_stats->min1);
243	<	move(3,12);
244	<	printw("%6.2f", stats.load_stats->min5);
245	<	move(4,12);
246	<	printw("%6.2f", stats.load_stats->min15);
240	>	if (stats.load_stats != NULL) {
241	>	/* Load */
242	>	move(2,12);
243	>	printw("%6.2f", stats.load_stats->min1);
244	>	move(3,12);
245	>	printw("%6.2f", stats.load_stats->min5);
246	>	move(4,12);
247	>	printw("%6.2f", stats.load_stats->min15);
248	>	}
249
250	<	/* CPU */
251	<	move(2,33);
252	<	printw("%6.2f%%", stats.cpu_percents->idle);
253	<	move(3,33);
254	<	printw("%6.2f%%", (stats.cpu_percents->kernel + stats.cpu_percents->iowait + stats.cpu_percents->swap));
255	<	move(4,33);
256	<	printw("%6.2f%%", (stats.cpu_percents->user + stats.cpu_percents->nice));
250	>	if (stats.cpu_percents != NULL) {
251	>	/* CPU */
252	>	move(2,33);
253	>	printw("%6.2f%%", stats.cpu_percents->idle);
254	>	move(3,33);
255	>	printw("%6.2f%%", (stats.cpu_percents->kernel + stats.cpu_percents->iowait + stats.cpu_percents->swap));
256	>	move(4,33);
257	>	printw("%6.2f%%", (stats.cpu_percents->user + stats.cpu_percents->nice));
258	>	}
259
260	<	/* Process */
261	<	move(2, 54);
262	<	printw("%5d", stats.process_stats->running);
263	<	move(2,74);
264	<	printw("%5d", stats.process_stats->zombie);
265	<	move(3, 54);
266	<	printw("%5d", stats.process_stats->sleeping);
267	<	move(3, 74);
268	<	printw("%5d", stats.process_stats->total);
269	<	move(4, 54);
270	<	printw("%5d", stats.process_stats->stopped);
271	<	move(4,74);
272	<	printw("%5d", stats.user_stats->num_entries);
260	>	if (stats.process_stats != NULL) {
261	>	/* Process */
262	>	move(2, 54);
263	>	printw("%5d", stats.process_stats->running);
264	>	move(2,74);
265	>	printw("%5d", stats.process_stats->zombie);
266	>	move(3, 54);
267	>	printw("%5d", stats.process_stats->sleeping);
268	>	move(3, 74);
269	>	printw("%5d", stats.process_stats->total);
270	>	move(4, 54);
271	>	printw("%5d", stats.process_stats->stopped);
272	>	}
273	>	if (stats.user_stats != NULL) {
274	>	move(4,74);
275	>	printw("%5d", stats.user_stats->num_entries);
276	>	}
277
278	<	/* Mem */
279	<
280	<	move(6, 12);
281	<	printw("%7s", size_conv(stats.mem_stats->total));
282	<	move(7, 12);
283	<	printw("%7s", size_conv(stats.mem_stats->used));
284	<	move(8, 12);
285	<	printw("%7s", size_conv(stats.mem_stats->free));
278	>	if (stats.mem_stats != NULL) {
279	>	/* Mem */
280	>	move(6, 12);
281	>	printw("%7s", size_conv(stats.mem_stats->total));
282	>	move(7, 12);
283	>	printw("%7s", size_conv(stats.mem_stats->used));
284	>	move(8, 12);
285	>	printw("%7s", size_conv(stats.mem_stats->free));
286	>	}
287
288	<	/* Swap */
289	<	move(6, 32);
290	<	printw("%8s", size_conv(stats.swap_stats->total));
291	<	move(7, 32);
292	<	printw("%8s", size_conv(stats.swap_stats->used));
293	<	move(8, 32);
294	<	printw("%8s", size_conv(stats.swap_stats->free));
288	>	if (stats.swap_stats != NULL) {
289	>	/* Swap */
290	>	move(6, 32);
291	>	printw("%8s", size_conv(stats.swap_stats->total));
292	>	move(7, 32);
293	>	printw("%8s", size_conv(stats.swap_stats->used));
294	>	move(8, 32);
295	>	printw("%8s", size_conv(stats.swap_stats->free));
296	>	}
297
298		/* VM */
299	<	move(6, 54);
300	<	printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used)/stats.mem_stats->total));
301	<	move(7, 54);
302	<	printw("%5.2f%%", (100.00 * (float)(stats.swap_stats->used)/stats.swap_stats->total));
303	<	move(8, 54);
304	<	printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used+stats.swap_stats->used)/(stats.mem_stats->total+stats.swap_stats->total)));
299	>	if (stats.mem_stats != NULL) {
300	>	move(6, 54);
301	>	printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used)/stats.mem_stats->total));
302	>	}
303	>	if (stats.swap_stats != NULL) {
304	>	move(7, 54);
305	>	printw("%5.2f%%", (100.00 * (float)(stats.swap_stats->used)/stats.swap_stats->total));
306	>	}
307	>	if (stats.mem_stats != NULL && stats.swap_stats != NULL) {
308	>	move(8, 54);
309	>	printw("%5.2f%%", (100.00 * (float)(stats.mem_stats->used+stats.swap_stats->used)/(stats.mem_stats->total+stats.swap_stats->total)));
310	>	}
311
312	<	/* Paging */
313	<	move(6, 74);
314	<	printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pagein / stats.page_stats->systime): stats.page_stats->pages_pagein);
315	<	move(7, 74);
316	<	printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pageout / stats.page_stats->systime) : stats.page_stats->pages_pageout);
312	>	if (stats.page_stats != NULL) {
313	>	/* Paging */
314	>	move(6, 74);
315	>	printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pagein / stats.page_stats->systime): stats.page_stats->pages_pagein);
316	>	move(7, 74);
317	>	printw("%5d", (stats.page_stats->systime)? (stats.page_stats->pages_pageout / stats.page_stats->systime) : stats.page_stats->pages_pageout);
318	>	}
319
320	<	/* Disk IO */
321	<	diskio_stat_ptr = stats.diskio_stats;
322	<	r=0;
323	<	w=0;
324	<	for(counter=0;counter<stats.diskio_entries;counter++){
325	<	move(11+counter, 0);
326	<	printw("%s", diskio_stat_ptr->disk_name);
327	<	move(11+counter, 12);
328	<	rt = (diskio_stat_ptr->systime)? (diskio_stat_ptr->read_bytes/diskio_stat_ptr->systime): diskio_stat_ptr->read_bytes;
329	<	printw("%7s", size_conv(rt));
330	<	r+=rt;
331	<	move(11+counter, 26);
332	<	wt = (diskio_stat_ptr->systime)? (diskio_stat_ptr->write_bytes/diskio_stat_ptr->systime): diskio_stat_ptr->write_bytes;
333	<	printw("%7s", size_conv(wt));
334	<	w+=wt;
335	<	diskio_stat_ptr++;
320	>	line = 11;
321	>	if (stats.diskio_stats != NULL) {
322	>	/* Disk IO */
323	>	diskio_stat_ptr = stats.diskio_stats;
324	>	r=0;
325	>	w=0;
326	>	for(counter=0;counter<stats.diskio_entries;counter++){
327	>	move(line, 0);
328	>	printw("%s", diskio_stat_ptr->disk_name);
329	>	move(line, 12);
330	>	rt = (diskio_stat_ptr->systime)? (diskio_stat_ptr->read_bytes/diskio_stat_ptr->systime): diskio_stat_ptr->read_bytes;
331	>	printw("%7s", size_conv(rt));
332	>	r+=rt;
333	>	move(line, 26);
334	>	wt = (diskio_stat_ptr->systime)? (diskio_stat_ptr->write_bytes/diskio_stat_ptr->systime): diskio_stat_ptr->write_bytes;
335	>	printw("%7s", size_conv(wt));
336	>	w+=wt;
337	>	diskio_stat_ptr++;
338	>	line++;
339	>	}
340	>	line++;
341	>	move(line, 0);
342	>	printw("Total");
343	>	move(line, 12);
344	>	printw("%7s", size_conv(r));
345	>	move(line, 26);
346	>	printw("%7s", size_conv(w));
347		}
268	–	move(12+counter, 0);
269	–	printw("Total");
270	–	move(12+counter, 12);
271	–	printw("%7s", size_conv(r));
272	–	move(12+counter, 26);
273	–	printw("%7s", size_conv(w));
348
349	<	/* Network */
350	<	network_stat_ptr = stats.network_stats;
351	<	for(counter=0;counter<stats.network_entries;counter++){
352	<	move(11+counter, 42);
353	<	printw("%s", network_stat_ptr->interface_name);
354	<	move(11+counter, 62);
355	<	rt = (network_stat_ptr->systime)? (network_stat_ptr->rx / network_stat_ptr->systime): network_stat_ptr->rx;
356	<	printw("%7s", size_conv(rt));
357	<	move(11+counter, 72);
358	<	wt = (network_stat_ptr->systime)? (network_stat_ptr->tx / network_stat_ptr->systime): network_stat_ptr->tx;
359	<	printw("%7s", size_conv(wt));
360	<	network_stat_ptr++;
349	>	line = 11;
350	>	if (stats.network_stats != NULL) {
351	>	/* Network */
352	>	network_stat_ptr = stats.network_stats;
353	>	for(counter=0;counter<stats.network_entries;counter++){
354	>	move(line, 42);
355	>	printw("%s", network_stat_ptr->interface_name);
356	>	move(line, 62);
357	>	rt = (network_stat_ptr->systime)? (network_stat_ptr->rx / network_stat_ptr->systime): network_stat_ptr->rx;
358	>	printw("%7s", size_conv(rt));
359	>	move(line, 72);
360	>	wt = (network_stat_ptr->systime)? (network_stat_ptr->tx / network_stat_ptr->systime): network_stat_ptr->tx;
361	>	printw("%7s", size_conv(wt));
362	>	network_stat_ptr++;
363	>	line++;
364	>	}
365	>	line += 2;
366		}
367
368	<	disk_stat_ptr = stats.disk_stats;
369	<	for(counter=0;counter<stats.disk_entries;counter++){
370	<	move(13+stats.network_entries+counter, 42);
371	<	printw("%s", disk_stat_ptr->mnt_point);
372	<	move(13+stats.network_entries+counter, 62);
373	<	printw("%7s", size_conv(disk_stat_ptr->avail));
374	<	move(13+stats.network_entries+counter, 73);
375	<	printw("%5.2f%%", 100.00 * ((float)disk_stat_ptr->used / (float)disk_stat_ptr->size));
376	<	disk_stat_ptr++;
368	>	if (stats.disk_stats != NULL) {
369	>	/* Disk */
370	>	disk_stat_ptr = stats.disk_stats;
371	>	for(counter=0;counter<stats.disk_entries;counter++){
372	>	move(line, 42);
373	>	printw("%s", disk_stat_ptr->mnt_point);
374	>	move(line, 62);
375	>	printw("%7s", size_conv(disk_stat_ptr->avail));
376	>	move(line, 73);
377	>	printw("%5.2f%%", 100.00 * ((float) disk_stat_ptr->used / (float) (disk_stat_ptr->used + disk_stat_ptr->avail)));
378	>	disk_stat_ptr++;
379	>	line++;
380	>	}
381		}
382
383		refresh();
#	Line 308 | Line 391 | void sig_winch_handler(int sig){
391		}
392
393		int get_stats(){
394	<	if((stats.cpu_percents = cpu_percent_usage()) == NULL) return 0;
395	<	if((stats.mem_stats = get_memory_stats()) == NULL) return 0;
396	<	if((stats.swap_stats = get_swap_stats()) == NULL) return 0;
397	<	if((stats.load_stats = get_load_stats()) == NULL) return 0;
398	<	if((stats.process_stats = get_process_stats()) == NULL) return 0;
399	<	if((stats.page_stats = get_page_stats_diff()) == NULL) return 0;
400	<	if((stats.network_stats = get_network_stats_diff(&(stats.network_entries))) == NULL) return 0;
401	<	if((stats.diskio_stats = get_diskio_stats_diff(&(stats.diskio_entries))) == NULL) return 0;
402	<	if((stats.disk_stats = get_disk_stats(&(stats.disk_entries))) == NULL) return 0;
403	<	if((stats.general_stats = get_general_stats()) == NULL) return 0;
404	<	if((stats.user_stats = get_user_stats()) == NULL) return 0;
394	>	stats.cpu_percents = cpu_percent_usage();
395	>	stats.mem_stats = get_memory_stats();
396	>	stats.swap_stats = get_swap_stats();
397	>	stats.load_stats = get_load_stats();
398	>	stats.process_stats = get_process_stats();
399	>	stats.page_stats = get_page_stats_diff();
400	>	stats.network_stats = get_network_stats_diff(&(stats.network_entries));
401	>	stats.diskio_stats = get_diskio_stats_diff(&(stats.diskio_entries));
402	>	stats.disk_stats = get_disk_stats(&(stats.disk_entries));
403	>	stats.general_stats = get_general_stats();
404	>	stats.user_stats = get_user_stats();
405
406	<	return 1;
406	>	return 1;
407		}
408
409	+	void version_num(char *progname){
410	+	fprintf(stderr, "%s version %s\n", progname, PACKAGE_VERSION);
411	+	fprintf(stderr, "\nReport bugs to <%s>.\n", PACKAGE_BUGREPORT);
412	+	exit(1);
413	+	}
414	+
415	+	void usage(char *progname){
416	+	fprintf(stderr, "Usage: %s [-d delay] [-v] [-h]\n\n", progname);
417	+	fprintf(stderr, "  -d    Sets the update time in seconds\n");
418	+	fprintf(stderr, "  -v    Prints version number\n");
419	+	fprintf(stderr, "  -h    Displays this help information.\n");
420	+	fprintf(stderr, "\nReport bugs to <%s>.\n", PACKAGE_BUGREPORT);
421	+	exit(1);
422	+	}
423	+
424		int main(int argc, char **argv){
425
426		extern char *optarg;
#	Line 339 | Line 437 | int main(int argc, char **argv){
437		char ch;
438
439		int delay=2;
440	<
441	<	while ((c = getopt(argc, argv, "d:")) != EOF){
440	>	#ifdef ALLBSD
441	>	gid_t gid;
442	>	#endif
443	>	statgrab_init();
444	>	#ifdef ALLBSD
445	>	if((setegid(getgid())) != 0){
446	>	fprintf(stderr, "Failed to lose setgid'ness\n");
447	>	return 1;
448	>	}
449	>	#endif
450	>
451	>	while ((c = getopt(argc, argv, "vhd:")) != EOF){
452		switch (c){
453		case 'd':
454		delay = atoi(optarg);
#	Line 350 | Line 458 | int main(int argc, char **argv){
458		}
459		delay--;
460		break;
461	+	case 'v':
462	+	version_num(argv[0]);
463	+	break;
464	+	case 'h':
465	+	default:
466	+	usage(argv[0]);
467	+	return 1;
468	+	break;
469	+
470		}
471		}
472
#	Line 400 | Line 517 | int main(int argc, char **argv){
517		* frequently than once a second.
518		*/
519		sleep(1);
403	–
520		}
405	–
406	–
521
522		endwin();
523		return 0;

Diff Legend

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