ViewVC Help

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

root/i-scream/projects/cms/source/host/generic/statgrab.pl

Comparing projects/cms/source/host/generic/statgrab.pl (file contents):
Revision 1.20 by tdb, Sun Feb 4 22:38:41 2001 UTC vs.
Revision 1.47 by tdb, Sat May 18 18:15:56 2002 UTC

#	Line 1 | Line 1
1		#!/usr/bin/perl -w
2
3	+	#
4	+	# i-scream central monitoring system
5	+	# Copyright (C) 2000-2002 i-scream
6	+	#
7	+	# This program is free software; you can redistribute it and/or
8	+	# modify it under the terms of the GNU General Public License
9	+	# as published by the Free Software Foundation; either version 2
10	+	# of the License, or (at your option) any later version.
11	+	#
12	+	# This program is distributed in the hope that it will be useful,
13	+	# but WITHOUT ANY WARRANTY; without even the implied warranty of
14	+	# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15	+	# GNU General Public License for more details.
16	+	#
17	+	# You should have received a copy of the GNU General Public License
18	+	# along with this program; if not, write to the Free Software
19	+	# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
20	+	#
21	+
22		#-----------------------------------------------------------------
23		# Machine statistics grabber
24		#     $Author$
#	Line 21 | Line 40 | $| = 1;
40		# You'd be silly not to use this ;)
41		use strict;
42
43	<	# Paths
44	<	my($topbin) = "/usr/local/sbin/top";
26	<	my($dfbin) = "/usr/bin/df";
27	<	my($usersbin) = "/usr/ucb/users";
28	<	my($unamebin) = "/usr/bin/uname";
29	<	my($uptimebin) = "/usr/bin/uptime";
43	>	# Have to hope this will work really.
44	>	my($ostype) = `uname -s`; chop($ostype);
45
46	+	# Decide which paths we should use.
47	+	my($topbin); my($dfbin); my($usersbin);
48	+	my($unamebin); my($uptimebin); my($sysctlbin);
49	+
50	+	if ($ostype eq "SunOS") {
51	+	# covers: Solaris 8
52	+	$topbin = "/usr/local/sbin/top -d2 -s1 0";
53	+	$dfbin = "/usr/bin/df";
54	+	$usersbin = "/usr/ucb/users";
55	+	$unamebin = "/usr/bin/uname";
56	+	$uptimebin = "/usr/bin/uptime";
57	+	}
58	+	elsif ($ostype eq "Linux") {
59	+	# covers: Debian r2.2
60	+	$topbin = "/usr/bin/top -d1 -n2 -b -p0";
61	+	$dfbin = "/bin/df";
62	+	$usersbin = "/usr/bin/users";
63	+	$unamebin = "/bin/uname";
64	+	$uptimebin = "/usr/bin/uptime";
65	+	}
66	+	elsif ($ostype eq "FreeBSD") {
67	+	# covers: FreeBSD 4.2-STABLE
68	+	$topbin = "/usr/bin/top -d2 -s1 0";
69	+	$dfbin = "/bin/df";
70	+	$usersbin = "/usr/bin/users";
71	+	$unamebin = "/usr/bin/uname";
72	+	$uptimebin = "/usr/bin/uptime";
73	+	$sysctlbin = "/sbin/sysctl";
74	+	}
75	+	else {
76	+	print "statgrab.pl Error: Unable to identify system type - \"$ostype\".\n";
77	+	print "\"uname -s\" does not report one of the following known types;\n";
78	+	print "      SunOS, Linux, FreeBSD\n";
79	+	exit(1);
80	+	}
81	+
82		# Run the following components: -
83		&print_ident();
84		&include_osver();
#	Line 42 | Line 93 | exit(0);
93
94
95
45	–
46	–
47	–
48	–
96		# prints out an identifier for this version of statgrab.pl
97		# the host should check this when reading data
98		# means the host must be checked and updated to work with newer versions.
99		sub print_ident() {
100	<	print 'version statgrab.pl $Revision$';
100	>	print 'packet.version statgrab.pl $Revision$';
101		print "\n";
102		}
103
104		# sub to print pairs of data, separated by a single space character.
105		# If the second argument is undefined, then the pair is still printed,
106	<	# however, the value shall be displayed as the string "unknown".
107	<	# If $type is non-zero, then "0" is printed instead of "unknown".
106	>	# however, the value shall be displayed as the the 'default' value
107	>	# if the passed value was undefined.
108		sub print_pair($$$) {
109	<	my($type, $name, $value) = @_;
109	>	my($default, $name, $value) = @_;
110
111		if (!defined $value) {
112	<	if ($type) {
66	<	$value = "0.00";
67	<	}
68	<	else {
69	<	$value = "unknown";
70	<	}
112	>	$value = $default;
113		}
114
115		# Remove the trailing linefeed if we've not already done so.
#	Line 82 | Line 124 | sub print_pair($$$) {
124		sub include_disk() {
125
126		# Run the df program.
127	<	my(@df) = `$dfbin -ak`;
127	>	my(@df) = `$dfbin -akl`;
128
129		# Go through each line of the program, looking for each thing we want.
130		my($partition_no) = 0;
131		for (my($i) = 0; $i < $#df; $i++) {
132		my($line) = $df[$i];
133	<	$line =~ /^(\/[^\s]*)\s*([0-9]*)\s*([0-9]*)\s*([0-9]*)\s*[^\s]*\s*(\/[^\s]*)\s*/;
133	>	$line =~ /^([^\s]*)\s*([0-9]*)\s*([0-9]*)\s*([0-9]*)\s*[^\s]*\s*(\/[^\s]*)\s*/;
134		# $4 will not match unless everything before it does...
135		if (defined $5) {
136		my ($filesystem, $kbytes, $used, $avail, $mount) = ($1, $2, $3, $4, $5);
137	<	&print_pair(0, "packet.disk.p$partition_no.attributes.name", $filesystem);
138	<	&print_pair(1, "packet.disk.p$partition_no.attributes.kbytes", $kbytes);
139	<	&print_pair(1, "packet.disk.p$partition_no.attributes.used", $used);
140	<	&print_pair(1, "packet.disk.p$partition_no.attributes.avail", $avail);
141	<	&print_pair(0, "packet.disk.p$partition_no.attributes.mount", $mount);
137	>	&print_pair("unknown", "packet.disk.p$partition_no.attributes.name", $filesystem);
138	>	&print_pair(0, "packet.disk.p$partition_no.attributes.kbytes", $kbytes);
139	>	&print_pair(0, "packet.disk.p$partition_no.attributes.used", $used);
140	>	&print_pair(0, "packet.disk.p$partition_no.attributes.avail", $avail);
141	>	&print_pair("unknown", "packet.disk.p$partition_no.attributes.mount", $mount);
142		++$partition_no;
143		}
144		}
#	Line 115 | Line 157 | sub include_users() {
157		$users_count++ while $users =~ /\w+/g;
158		my($users_list) = $users." ";
159
160	<	&print_pair(1, "packet.users.count", $users_count);
161	<	&print_pair(0, "packet.users.list", $users_list);
160	>	&print_pair(0, "packet.users.count", $users_count);
161	>	&print_pair("unknown", "packet.users.list", $users_list);
162		}
163
164
#	Line 125 | Line 167 | sub include_users() {
167		sub include_top() {
168
169		# Find out some numbers from top.
170	<	my(@top) = `$topbin -d2 -s1 0`;
170	>	my(@top) = `$topbin`;
171		my($top) = join(" ", @top);
172	<	$top =~ s/\n//g;
172	>	$top =~ s/\n/ /g;
173
174	<	&print_pair(1, "packet.load.load1", $top =~ /load averages:\s*([^\s]+?),/);
175	<	&print_pair(1, "packet.load.load5", $top =~ /load averages:\s*.+?,\s*([^\s]+?),/);
176	<	&print_pair(1, "packet.load.load15", $top =~ /load averages:\s*.+?,\s*.+?,\s*([^\s]+?)\s.*/);
177	<	&print_pair(1, "packet.processes.total", $top =~ /([^\s]+?) processes:/);
178	<	&print_pair(1, "packet.processes.sleeping", $top =~ / ([^\s]+?) sleeping/);
179	<	&print_pair(1, "packet.processes.zombie", $top =~ / ([^\s]+?) zombie/);
180	<	&print_pair(1, "packet.processes.stopped", $top =~ / ([^\s]+?) stopped/);
181	<	&print_pair(1, "packet.processes.cpu", $top =~ /([^\s]+?)\s*on cpu/);
182	<	&print_pair(1, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
183	<	&print_pair(1, "packet.cpu.user", $top =~ /([^\s]+?)% user/);
184	<	&print_pair(1, "packet.cpu.kernel", $top =~ /([^\s]+?)% kernel/);
185	<	&print_pair(1, "packet.cpu.iowait", $top =~ /([^\s]+?)% iowait/);
186	<	&print_pair(1, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);
174	>	if($ostype eq "SunOS") {
175	>	&print_pair(0, "packet.processes.total", $top =~ /([0-9]+?) processes:/);
176	>	&print_pair(0, "packet.processes.sleeping", $top =~ /([0-9]+?) sleeping/);
177	>	&print_pair(0, "packet.processes.zombie", $top =~ /([0-9]+?) zombie/);
178	>	&print_pair(0, "packet.processes.stopped", $top =~ /([0-9]+?) stopped/);
179	>	&print_pair(0, "packet.processes.cpu", $top =~ /([0-9]+?)\s*on cpu/);
180	>	&print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
181	>	&print_pair(0, "packet.cpu.user", $top =~ /([^\s]+?)% user/);
182	>	&print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% kernel/);
183	>	&print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% iowait/);
184	>	&print_pair(0, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);
185	>
186	>	# The following need to be specified in megabytes.
187	>	# If they are preceeded by a G, then multiply by 1024.
188	>
189	>	$top =~ /([0-9]+?)([KMG]) real/;
190	>	my($real) = $1;
191	>	$real*=1024 if $2 eq "G";
192	>	$real/=1024 if $2 eq "K";
193	>	&print_pair(0, "packet.memory.total", $real);
194	>
195	>	$top =~ /([0-9]+?)([KMG]) free/;
196	>	my($free) = $1;
197	>	$free*=1024 if $2 eq "G";
198	>	$free/=1024 if $2 eq "K";
199	>	&print_pair(0, "packet.memory.free", $free);
200	>
201	>	$top =~ /([0-9]+?)([KMG]) swap in use/;
202	>	my($swap_in_use) = $1;
203	>	$swap_in_use*=1024 if $2 eq "G";
204	>	$swap_in_use/=1024 if $2 eq "K";
205	>	# DO NOT print this one out... save it for in a moment...
206	>
207	>	$top =~ /([0-9]+?)([KMG]) swap free/;
208	>	my($swap_free) = $1;
209	>	$swap_free*=1024 if $2 eq "G";
210	>	$swap_free/=1024 if $2 eq "K";
211	>	&print_pair(0, "packet.swap.free", $swap_free);
212	>
213	>	&print_pair(0, "packet.swap.total", $swap_free + $swap_in_use);
214	>	}
215	>	elsif ($ostype eq "FreeBSD") {
216	>	&print_pair(0, "packet.processes.total", $top =~ /([0-9]+?) processes:/);
217	>	&print_pair(0, "packet.processes.sleeping", $top =~ /([0-9]+?) sleeping/);
218	>	&print_pair(0, "packet.processes.zombie", $top =~ /([0-9]+?) zombie/);
219	>	&print_pair(0, "packet.processes.stopped", $top =~ /([0-9]+?) stopped/);
220	>	&print_pair(0, "packet.processes.cpu", $top =~ /([0-9]+?)\s*running/);
221	>	&print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
222	>	&print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% system/);
223	>	&print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% interrupt/);
224	>	&print_pair(0, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);
225
226	<	# The following need to be specified in megabytes.
227	<	# If they are preceeded by a G, then multiply by 1024.
226	>	# FreeBSD is a bit different, we need to get user and nice.
227	>	my($user) = 0;
228	>	if($top =~ /([^\s]+?)% user/) { $user += $1; }
229	>	if($top =~ /([^\s]+?)% nice/) { $user += $1; }
230	>	&print_pair(0, "packet.cpu.user", $user);
231	>
232	>	# The following need to be specified in megabytes.
233	>	# If they are preceeded by a G, then multiply by 1024.
234	>
235	>	# get RAM slightly differently
236	>	my($real) = `$sysctlbin -n hw.physmem`;
237	>	my($free) = $real - `$sysctlbin -n hw.usermem`;
238	>
239	>	# turn bytes to megabytes
240	>	$real = ($real / 1024) / 1024;
241	>	$free = ($free / 1024) / 1024;
242	>
243	>	&print_pair(0, "packet.memory.total", $real);
244	>	&print_pair(0, "packet.memory.free", $free);
245	>
246	>	$top =~ /Swap: ([0-9]+?)([KMG]) Total/;
247	>	my($swap_total) = $1;
248	>	$swap_total*=1024 if $2 eq "G";
249	>	$swap_total/=1024 if $2 eq "K";
250	>	&print_pair(0, "packet.swap.total", $swap_total);
251	>
252	>	$top =~ /Swap:.*, ([0-9]+?)([KMG]) Free/;
253	>	my($swap_free) = $1;
254	>	$swap_free*=1024 if $2 eq "G";
255	>	$swap_free/=1024 if $2 eq "K";
256	>	&print_pair(0, "packet.swap.free", $swap_free);
257	>
258	>	my($loads) = `$sysctlbin -n vm.loadavg`;
259	>	$loads =~ /\s+([^\s]+?)\s+([^\s]+?)\s+([^\s]+?)\s+/;
260	>	&print_pair(0, "packet.load.load1", $1);
261	>	&print_pair(0, "packet.load.load5", $2);
262	>	&print_pair(0, "packet.load.load15", $3);
263	>	}
264	>	elsif ($ostype eq "Linux") {
265	>	my ($top) = "";
266	>	foreach my $line (@top) {
267	>	$top = $line . $top;
268	>	}
269	>	$top =~ s/\n/ /g;
270
271	<	$top =~ /([^\s]+?)([MG]) real/;
272	<	my($real) = $1;
273	<	$real*=1024 if $2 eq "G";
274	<	&print_pair(1, "packet.memory.real", $real);
271	>	&print_pair(0, "packet.processes.total", $top =~ /([0-9]+?) processes:/);
272	>	&print_pair(0, "packet.processes.sleeping", $top =~ /([0-9]+?) sleeping/);
273	>	&print_pair(0, "packet.processes.zombie", $top =~ /([0-9]+?) zombie/);
274	>	&print_pair(0, "packet.processes.stopped", $top =~ /([0-9]+?) stopped/);
275	>	&print_pair(0, "packet.processes.cpu", $top =~ /([0-9]+?)\s*running/);
276	>	&print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
277	>	&print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% system/);
278	>	&print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% interrupt/);
279	>	&print_pair(0, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);
280
281	<	$top =~ /([^\s]+?)([MG]) free/;
282	<	my($free) = $1;
283	<	$free*=1024 if $2 eq "G";
284	<	&print_pair(1, "packet.memory.free", $free);
285	<
286	<	$top =~ /([^\s]+?)([MG]) swap in use/;
287	<	my($swap_in_use) = $1;
288	<	$swap_in_use*=1024 if $2 eq "G";
289	<	# DO NOT print this one out... save it for in a moment...
290	<
291	<	$top =~ /([^\s]+?)([MG]) swap free/;
292	<	my($swap_free) = $1;
293	<	$swap_free*=1024 if $2 eq "G";
294	<	&print_pair(1, "packet.memory.swap_free", $swap_free);
295	<
296	<	# AJ requested total swap instead of swap_in_use, so here we go!
297	<	&print_pair(1, "packet.memory.swap_total", $swap_free + $swap_in_use);
281	>	# FreeBSD is a bit different, we need to get user and nice.
282	>	my($user) = 0;
283	>	if($top =~ /([^\s]+?)% user/) { $user += $1; }
284	>	if($top =~ /([^\s]+?)% nice/) { $user += $1; }
285	>	&print_pair(0, "packet.cpu.user", $user);
286	>
287	>	# The following need to be specified in megabytes.
288	>	# If they are preceeded by a G, then multiply by 1024.
289	>
290	>	$top =~ /Mem:.*?([0-9]+)([KMG])\s+(av|total)/;
291	>	my($real) = $1;
292	>	$real*=1024 if $2 eq "G";
293	>	$real/=1024 if $2 eq "K";
294	>	&print_pair(0, "packet.memory.total", int($real));
295	>
296	>	$top =~ /Mem:.*?([0-9]+)([KMG])\s+free/;
297	>	my($free) = $1;
298	>	$free*=1024 if $2 eq "G";
299	>	$free/=1024 if $2 eq "K";
300	>	&print_pair(0, "packet.memory.free", int($free));
301	>
302	>	$top =~ /Swap:.*?([0-9]+)([KMG])\s+(av|total)/;
303	>	my($swap_total) = $1;
304	>	$swap_total*=1024 if $2 eq "G";
305	>	$swap_total/=1024 if $2 eq "K";
306	>	&print_pair(0, "packet.swap.total", int($swap_total));
307	>
308	>	$top =~ /Swap:.*?([0-9]+)([KMG])\s+free/;
309	>	my($swap_free) = $1;
310	>	$swap_free*=1024 if $2 eq "G";
311	>	$swap_free/=1024 if $2 eq "K";
312	>	&print_pair(0, "packet.swap.free", int($swap_free));
313	>	}
314	>	else {
315	>	# we could have some catchall here
316	>	# but as it stands this means we'll just skip top stuff
317	>	# for unknown systems
318	>	}
319		}
320
321		# sub to get details of the machine's operating system.
#	Line 182 | Line 330 | sub include_osver() {
330		my($os_sysname) = `$unamebin -n`;
331		my($os_version) = `$unamebin -v`;
332
333	<	&print_pair(0, "packet.os.name", $os_name);
334	<	&print_pair(0, "packet.os.release", $os_release);
335	<	&print_pair(0, "packet.os.platform", $os_platform);
336	<	&print_pair(0, "packet.os.sysname", $os_sysname);
337	<	&print_pair(0, "packet.os.version", $os_version);
333	>	&print_pair("unknown", "packet.os.name", $os_name);
334	>	&print_pair("unknown", "packet.os.release", $os_release);
335	>	&print_pair("unknown", "packet.os.platform", $os_platform);
336	>	&print_pair("unknown", "packet.os.sysname", $os_sysname);
337	>	&print_pair("unknown", "packet.os.version", $os_version);
338
339		}
340
341	<	# sub to get system uptime.
341	>	# sub to get system uptime in seconds.
342		sub include_uptime() {
343
344	+	# debug stuff, all the different cases
345	+
346	+	# normal
347	+	#my($uptime) = "  4:48pm  up 49 day(s),  6:30,  201 users,  load average: 0.33, 0.35, 0.38\n";
348	+	# 0 days
349	+	#my($uptime) = "  4:48pm  up 6:30,  201 users,  load average: 0.33, 0.35, 0.38\n";
350	+	# 0 hours
351	+	#my($uptime) = "  4:48pm  up 49 day(s),  30 min(s),  201 users,  load average: 0.33, 0.35, 0.38\n";
352	+	# 0 mins
353	+	#my($uptime) = "  4:48pm  up 49 day(s),  6 hr(s),  201 users,  load average: 0.33, 0.35, 0.38\n";
354	+	# 0 days and 0 mins
355	+	#my($uptime) = "  4:48pm  up 6 hr(s),  201 users,  load average: 0.33, 0.35, 0.38\n";
356	+	# 0 days and 0 hours
357	+	#my($uptime) = "  4:48pm  up 30 min(s),  201 users,  load average: 0.33, 0.35, 0.38\n";
358	+	# 0 hours and 0 mins
359	+	#my($uptime) = "  4:48pm  up 49 day(s), 201 users,  load average: 0.33, 0.35, 0.38\n";
360	+
361	+	# grab the uptime
362		my($uptime) = `$uptimebin`;
363	<	$uptime =~ /up ([0-9]+) .*, ([0-9]+:[0-9]+)/;
364	<	$uptime = "$1:$2";
363	>
364	>	if($ostype ne "FreeBSD") {
365	>	&print_pair(0, "packet.load.load1", $uptime =~ /load average.?:\s*([^\s]+?),/);
366	>	&print_pair(0, "packet.load.load5", $uptime =~ /load average.?:\s*.+?,\s*([^\s]+?),/);
367	>	&print_pair(0, "packet.load.load15", $uptime =~ /load average.?:\s*.+?,\s*.+?,\s*([^\s]+)/);
368	>	}
369
370	<	&print_pair(0, "packet.os.uptime", $uptime);
370	>	# work out the days, hours, and minutes
371	>
372	>	if ($uptime =~ /day.*,\s+([0-9]+):([0-9]+)/) {
373	>	# normal
374	>	$uptime =~ /up\s+([0-9]+)\s+[^\s]+,\s+([0-9]+):([0-9]+)/;
375	>	$uptime = "$1:$2:$3";
376	>	}
377	>	else {
378	>	if ($uptime =~ /day/) {
379	>	if ($uptime =~ /hr/) {
380	>	# 0 minutes
381	>	$uptime =~ /up\s+([0-9]+)\s+[^\s]+,\s+([0-9]+)\s+[^\s]+,/;
382	>	$uptime = "$1:$2:0";
383	>	}
384	>	elsif ($uptime =~ /min/) {
385	>	# 0 hours
386	>	$uptime =~ /up\s+([0-9]+)\s+[^\s]+,\s+([0-9]+)\s+[^\s]+,/;
387	>	$uptime = "$1:0:$2";
388	>	}
389	>	else {
390	>	# 0 hours and 0 mins
391	>	$uptime =~ /up\s+([0-9]+)/;
392	>	$uptime = "$1:0:0";
393	>	}
394	>	}
395	>	elsif ($uptime =~ /hr/) {
396	>	# 0 days and 0 minutes
397	>	$uptime =~ /up\s+([0-9]+)\s+/;
398	>	$uptime = "0:$1:0";
399	>	}
400	>	elsif ($uptime =~ /min/) {
401	>	# 0 days and 0 hours
402	>	$uptime =~ /up\s+([0-9]+)\s+/;
403	>	$uptime = "0:0:$1";
404	>	}
405	>	else {
406	>	# 0 days
407	>	$uptime =~ /up\s+([0-9]+):([0-9]+)/;
408	>	$uptime = "0:$1:$2";
409	>	}
410	>	}
411	>
412	>	# turn into seconds
413	>	$uptime =~ /([0-9]+):([0-9]+):([0-9]+)/;
414	>	$uptime = ($3+($2+($1*24))*60)*60;
415	>
416	>	# print the value out
417	>	&print_pair("unknown", "packet.os.uptime", $uptime);
418
419		}

Diff Legend

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