host/generic/statgrab.pl

#!/usr/bin/perl -w

#-----------------------------------------------------------------
# Machine statistics grabber
#     $Author: pjm2 $
#     $Id: statgrab.pl,v 1.25 2001/02/05 17:05:22 pjm2 Exp $
#
# A Perl script to return various information about a host machine
# by examining the output of some common Unix/Linux commands.
# This is a stopgap to act as a generic way of collecting the
# data.  It is perhaps more reliable than the current Java host
# at doing this and it can obviously be used by a C++ program as
# well until the C++ host is ready to find the information out
# itself.
#-----------------------------------------------------------------


$| = 1;


# You'd be silly not to use this ;)
use strict;

# Paths
my($topbin) = "/usr/local/sbin/top";
my($dfbin) = "/usr/bin/df";
my($usersbin) = "/usr/ucb/users";
my($unamebin) = "/usr/bin/uname";
my($uptimebin) = "/usr/bin/uptime";

# Run the following components: -
&print_ident();
&include_osver();
&include_uptime();
&include_users();
&include_top();
&include_disk();

# End the program normally.
exit(0);


# prints out an identifier for this version of statgrab.pl
# the host should check this when reading data
# means the host must be checked and updated to work with newer versions.
sub print_ident() {
    print 'version statgrab.pl $Revision: 1.25 $';
    print "\n";
}

# sub to print pairs of data, separated by a single space character.
# If the second argument is undefined, then the pair is still printed,
# however, the value shall be displayed as the the 'default' value
# if the passed value was undefined.
sub print_pair($$$) {
    my($default, $name, $value) = @_;

    if (!defined $value) {
        $value = $default;
    }

    # Remove the trailing linefeed if we've not already done so.
    chomp($value);

    # print the pair of data with a space inbetween.
    print "$name $value\n";
}


# sub to find out disk partition information, if it exists.
sub include_disk() {
    
    # Run the df program.
    my(@df) = `$dfbin -ak`;

    # Go through each line of the program, looking for each thing we want.
    my($partition_no) = 0;
    for (my($i) = 0; $i < $#df; $i++) {
        my($line) = $df[$i];
        $line =~ /^(\/[^\s]*)\s*([0-9]*)\s*([0-9]*)\s*([0-9]*)\s*[^\s]*\s*(\/[^\s]*)\s*/;
        # $4 will not match unless everything before it does...
        if (defined $5) {
            my ($filesystem, $kbytes, $used, $avail, $mount) = ($1, $2, $3, $4, $5);
            &print_pair("unknown", "packet.disk.p$partition_no.attributes.name", $filesystem);
            &print_pair(0, "packet.disk.p$partition_no.attributes.kbytes", $kbytes);
            &print_pair(0, "packet.disk.p$partition_no.attributes.used", $used);
            &print_pair(0, "packet.disk.p$partition_no.attributes.avail", $avail);
            &print_pair("unknown", "packet.disk.p$partition_no.attributes.mount", $mount);
            ++$partition_no;
        }
    }
    
}

# sub to find out the list of all (non-unique) usernames logged
# in to the machine and how many their are. (not 
sub include_users() {

    # Find out all users on this machine.
    my($users) = `$usersbin`;
    $users = "\n" unless defined $users;
    chop $users;
    my($users_count) = 0;
    $users_count++ while $users =~ /\w+/g;
    my($users_list) = $users." ";

    &print_pair(0, "packet.users.count", $users_count);
    &print_pair("unknown", "packet.users.list", $users_list);
}


# sub to run a series of regexps on the output of 'top' to
# gather various machine statistics.
sub include_top() {

    # Find out some numbers from top.
    my(@top) = `$topbin -d2 -s1 0`;
    my($top) = join(" ", @top);
    $top =~ s/\n//g;

    &print_pair(0, "packet.load.load1", $top =~ /load averages:\s*([^\s]+?),/);
    &print_pair(0, "packet.load.load5", $top =~ /load averages:\s*.+?,\s*([^\s]+?),/);
    &print_pair(0, "packet.load.load15", $top =~ /load averages:\s*.+?,\s*.+?,\s*([^\s]+?)\s/);
    &print_pair(0, "packet.processes.total", $top =~ /([^\s]+?) processes:/);
    &print_pair(0, "packet.processes.sleeping", $top =~ / ([^\s]+?) sleeping/);
    &print_pair(0, "packet.processes.zombie", $top =~ / ([^\s]+?) zombie/);
    &print_pair(0, "packet.processes.stopped", $top =~ / ([^\s]+?) stopped/);
    &print_pair(0, "packet.processes.cpu", $top =~ /([^\s]+?)\s*on cpu/);
    &print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
    &print_pair(0, "packet.cpu.user", $top =~ /([^\s]+?)% user/);
    &print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% kernel/);
    &print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% iowait/);
    &print_pair(0, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);

    # The following need to be specified in megabytes.
    # If they are preceeded by a G, then multiply by 1024.   

    $top =~ /([^\s]+?)([MG]) real/;
    my($real) = $1;
    $real*=1024 if $2 eq "G";
    &print_pair(0, "packet.memory.total", $real);

    $top =~ /([^\s]+?)([MG]) free/;
    my($free) = $1;
    $free*=1024 if $2 eq "G";
    &print_pair(0, "packet.memory.free", $free);

    $top =~ /([^\s]+?)([MG]) swap in use/;
    my($swap_in_use) = $1;
    $swap_in_use*=1024 if $2 eq "G";
    # DO NOT print this one out... save it for in a moment...

    $top =~ /([^\s]+?)([MG]) swap free/;
    my($swap_free) = $1;
    $swap_free*=1024 if $2 eq "G";
    &print_pair(0, "packet.swap.free", $swap_free);

    # AJ requested total swap instead of swap_in_use, so here we go!
    &print_pair(0, "packet.swap.total", $swap_free + $swap_in_use);
}

# sub to get details of the machine's operating system.
sub include_osver() {

    # Find out details about the operating system
    # If these values remain undefined, then the print_pair
    # function shall show the value to be the string "unknown".
    my($os_name) = `$unamebin -s`;
    my($os_release) = `$unamebin -r`;
    my($os_platform) = `$unamebin -m`;
    my($os_sysname) = `$unamebin -n`;
    my($os_version) = `$unamebin -v`;

    &print_pair("unknown", "packet.os.name", $os_name);
    &print_pair("unknown", "packet.os.release", $os_release);
    &print_pair("unknown", "packet.os.platform", $os_platform);
    &print_pair("unknown", "packet.os.sysname", $os_sysname);
    &print_pair("unknown", "packet.os.version", $os_version);

}

# sub to get system uptime.
sub include_uptime() {

    # grab the uptime
    my($uptime) = `$uptimebin`;

    # work out the days, hours, and minutes
    if ($uptime =~ /hr/) {
      # 0 minutes
        $uptime =~ s/up ([0-9]+) .*, ([0-9]+) .*,/$1:$2:0/;
    }
    elsif ($uptime =~ /min/) {
      # 0 hours
        $uptime =~ s/up ([0-9]+) .*, ([0-9]+) .*,/$1:0:$2/;
    }
    elsif ($uptime =~ /day/) {
      # normal
        $uptime =~ s/up ([0-9]+) .*, ([0-9]+):([0-9]+)/$1:$2:$3/;
    }
    else {
      # 0 days
        $uptime =~ s/up ([0-9]+):([0-9]+)/0:$1:$2/;
    }

    # turn into minutes

    $uptime =~ /([0-9]+):([0-9]+):([0-9]+)/;
    $uptime = $3 + ($2 + $1*24)*60;

    &print_pair("unknown", "packet.os.uptime", $uptime);

}
Revision:	1.26
Committed:	Mon Feb 5 17:13:26 2001 UTC (23 years, 9 months ago) by pjm2
Content type:	text/plain
Branch:	MAIN
Changes since 1.25:	+5 -5 lines
Log Message:	Changed the names of the XML fields that were clashing with the names in teh XMLPacket definition.
#	User	Rev	Content
1	pjm2	1.1	#!/usr/bin/perl -w
2
3			#-----------------------------------------------------------------
4			# Machine statistics grabber
5	pjm2	1.24	# $Author: pjm2 $
6	pjm2	1.26	# $Id: statgrab.pl,v 1.25 2001/02/05 17:05:22 pjm2 Exp $
7	pjm2	1.1	#
8			# A Perl script to return various information about a host machine
9			# by examining the output of some common Unix/Linux commands.
10			# This is a stopgap to act as a generic way of collecting the
11			# data. It is perhaps more reliable than the current Java host
12			# at doing this and it can obviously be used by a C++ program as
13			# well until the C++ host is ready to find the information out
14			# itself.
15			#-----------------------------------------------------------------
16
17
18			$\| = 1;
19
20
21			# You'd be silly not to use this ;)
22			use strict;
23
24	pjm2	1.18	# Paths
25	tdb	1.13	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	tdb	1.17	my($uptimebin) = "/usr/bin/uptime";
30	tdb	1.13
31	pjm2	1.6	# Run the following components: -
32	tdb	1.3	&print_ident();
33	tdb	1.2	&include_osver();
34	tdb	1.17	&include_uptime();
35	pjm2	1.1	&include_users();
36			&include_top();
37	pjm2	1.5	&include_disk();
38	pjm2	1.1
39	pjm2	1.6	# End the program normally.
40	pjm2	1.1	exit(0);
41
42
43
44	pjm2	1.6
45
46
47
48
49	tdb	1.3	# prints out an identifier for this version of statgrab.pl
50			# the host should check this when reading data
51			# means the host must be checked and updated to work with newer versions.
52			sub print_ident() {
53	pjm2	1.26	print 'version statgrab.pl $Revision: 1.25 $';
54	tdb	1.3	print "\n";
55			}
56	pjm2	1.1
57			# sub to print pairs of data, separated by a single space character.
58	pjm2	1.5	# If the second argument is undefined, then the pair is still printed,
59	pjm2	1.25	# however, the value shall be displayed as the the 'default' value
60			# if the passed value was undefined.
61	pjm2	1.8	sub print_pair($$$) {
62	pjm2	1.25	my($default, $name, $value) = @_;
63	pjm2	1.1
64			if (!defined $value) {
65	pjm2	1.25	$value = $default;
66	pjm2	1.1	}
67
68			# Remove the trailing linefeed if we've not already done so.
69			chomp($value);
70
71			# print the pair of data with a space inbetween.
72			print "$name $value\n";
73			}
74
75
76	pjm2	1.5	# sub to find out disk partition information, if it exists.
77			sub include_disk() {
78
79			# Run the df program.
80	tdb	1.13	my(@df) = `$dfbin -ak`;
81	pjm2	1.5
82			# Go through each line of the program, looking for each thing we want.
83			my($partition_no) = 0;
84			for (my($i) = 0; $i < $#df; $i++) {
85			my($line) = $df[$i];
86	pjm2	1.7	$line =~ /^(\/[^\s])\s([0-9])\s([0-9])\s([0-9])\s[^\s]\s(\/[^\s])\s/;
87	pjm2	1.5	# $4 will not match unless everything before it does...
88	pjm2	1.7	if (defined $5) {
89			my ($filesystem, $kbytes, $used, $avail, $mount) = ($1, $2, $3, $4, $5);
90	pjm2	1.25	&print_pair("unknown", "packet.disk.p$partition_no.attributes.name", $filesystem);
91			&print_pair(0, "packet.disk.p$partition_no.attributes.kbytes", $kbytes);
92			&print_pair(0, "packet.disk.p$partition_no.attributes.used", $used);
93			&print_pair(0, "packet.disk.p$partition_no.attributes.avail", $avail);
94			&print_pair("unknown", "packet.disk.p$partition_no.attributes.mount", $mount);
95	pjm2	1.5	++$partition_no;
96			}
97			}
98
99			}
100
101			# sub to find out the list of all (non-unique) usernames logged
102			# in to the machine and how many their are. (not
103	pjm2	1.1	sub include_users() {
104
105			# Find out all users on this machine.
106	tdb	1.13	my($users) = `$usersbin`;
107	pjm2	1.16	$users = "\n" unless defined $users;
108			chop $users;
109	pjm2	1.14	my($users_count) = 0;
110			$users_count++ while $users =~ /\w+/g;
111	pjm2	1.18	my($users_list) = $users." ";
112	pjm2	1.1
113	pjm2	1.25	&print_pair(0, "packet.users.count", $users_count);
114			&print_pair("unknown", "packet.users.list", $users_list);
115	pjm2	1.1	}
116
117
118	pjm2	1.5	# sub to run a series of regexps on the output of 'top' to
119			# gather various machine statistics.
120	pjm2	1.1	sub include_top() {
121
122			# Find out some numbers from top.
123	tdb	1.13	my(@top) = `$topbin -d2 -s1 0`;
124	pjm2	1.1	my($top) = join(" ", @top);
125			$top =~ s/\n//g;
126
127	pjm2	1.25	&print_pair(0, "packet.load.load1", $top =~ /load averages:\s*([^\s]+?),/);
128			&print_pair(0, "packet.load.load5", $top =~ /load averages:\s.+?,\s([^\s]+?),/);
129			&print_pair(0, "packet.load.load15", $top =~ /load averages:\s.+?,\s.+?,\s*([^\s]+?)\s/);
130			&print_pair(0, "packet.processes.total", $top =~ /([^\s]+?) processes:/);
131			&print_pair(0, "packet.processes.sleeping", $top =~ / ([^\s]+?) sleeping/);
132			&print_pair(0, "packet.processes.zombie", $top =~ / ([^\s]+?) zombie/);
133			&print_pair(0, "packet.processes.stopped", $top =~ / ([^\s]+?) stopped/);
134			&print_pair(0, "packet.processes.cpu", $top =~ /([^\s]+?)\s*on cpu/);
135			&print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
136			&print_pair(0, "packet.cpu.user", $top =~ /([^\s]+?)% user/);
137			&print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% kernel/);
138			&print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% iowait/);
139			&print_pair(0, "packet.cpu.swap", $top =~ /([^\s]+?)% swap/);
140	pjm2	1.10
141			# The following need to be specified in megabytes.
142			# If they are preceeded by a G, then multiply by 1024.
143
144			$top =~ /([^\s]+?)([MG]) real/;
145	pjm2	1.11	my($real) = $1;
146			$real*=1024 if $2 eq "G";
147	pjm2	1.26	&print_pair(0, "packet.memory.total", $real);
148	pjm2	1.10
149			$top =~ /([^\s]+?)([MG]) free/;
150	pjm2	1.11	my($free) = $1;
151			$free*=1024 if $2 eq "G";
152	pjm2	1.25	&print_pair(0, "packet.memory.free", $free);
153	pjm2	1.10
154			$top =~ /([^\s]+?)([MG]) swap in use/;
155	pjm2	1.11	my($swap_in_use) = $1;
156			$swap_in_use*=1024 if $2 eq "G";
157	pjm2	1.12	# DO NOT print this one out... save it for in a moment...
158	pjm2	1.10
159			$top =~ /([^\s]+?)([MG]) swap free/;
160	pjm2	1.11	my($swap_free) = $1;
161			$swap_free*=1024 if $2 eq "G";
162	pjm2	1.26	&print_pair(0, "packet.swap.free", $swap_free);
163	pjm2	1.12
164			# AJ requested total swap instead of swap_in_use, so here we go!
165	pjm2	1.26	&print_pair(0, "packet.swap.total", $swap_free + $swap_in_use);
166	tdb	1.2	}
167
168	pjm2	1.5	# sub to get details of the machine's operating system.
169	tdb	1.2	sub include_osver() {
170
171			# Find out details about the operating system
172	pjm2	1.5	# If these values remain undefined, then the print_pair
173			# function shall show the value to be the string "unknown".
174	tdb	1.13	my($os_name) = `$unamebin -s`;
175			my($os_release) = `$unamebin -r`;
176			my($os_platform) = `$unamebin -m`;
177			my($os_sysname) = `$unamebin -n`;
178			my($os_version) = `$unamebin -v`;
179	tdb	1.2
180	pjm2	1.25	&print_pair("unknown", "packet.os.name", $os_name);
181			&print_pair("unknown", "packet.os.release", $os_release);
182			&print_pair("unknown", "packet.os.platform", $os_platform);
183			&print_pair("unknown", "packet.os.sysname", $os_sysname);
184			&print_pair("unknown", "packet.os.version", $os_version);
185	tdb	1.2
186	pjm2	1.1	}
187	tdb	1.17
188			# sub to get system uptime.
189			sub include_uptime() {
190
191	tdb	1.21	# grab the uptime
192	tdb	1.17	my($uptime) = `$uptimebin`;
193	tdb	1.21
194			# work out the days, hours, and minutes
195			if ($uptime =~ /hr/) {
196			# 0 minutes
197	tdb	1.22	$uptime =~ s/up ([0-9]+) ., ([0-9]+) .,/$1:$2:0/;
198	tdb	1.21	}
199			elsif ($uptime =~ /min/) {
200			# 0 hours
201	tdb	1.22	$uptime =~ s/up ([0-9]+) ., ([0-9]+) .,/$1:0:$2/;
202	tdb	1.21	}
203			elsif ($uptime =~ /day/) {
204			# normal
205	tdb	1.22	$uptime =~ s/up ([0-9]+) .*, ([0-9]+):([0-9]+)/$1:$2:$3/;
206	tdb	1.21	}
207			else {
208			# 0 days
209	tdb	1.22	$uptime =~ s/up ([0-9]+):([0-9]+)/0:$1:$2/;
210	tdb	1.21	}
211
212			# turn into minutes
213
214			$uptime =~ /([0-9]+):([0-9]+):([0-9]+)/;
215			$uptime = $3 + ($2 + $124)60;
216	tdb	1.17
217	pjm2	1.25	&print_pair("unknown", "packet.os.uptime", $uptime);
218	tdb	1.17
219	pjm2	1.18	}