ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/host/generic/statgrab.pl
(Generate patch)

Comparing projects/cms/source/host/generic/statgrab.pl (file contents):
Revision 1.31 by tdb, Mon Feb 5 20:27:59 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 25 | Line 44 | use strict;
44   my($ostype) = `uname -s`; chop($ostype);
45  
46   # Decide which paths we should use.
47 < my($topbin); my($dfbin); my($usersbin); my($unamebin); my($uptimebin);
47 > my($topbin); my($dfbin); my($usersbin);
48 > my($unamebin); my($uptimebin); my($sysctlbin);
49  
50   if ($ostype eq "SunOS") {
51      # covers: Solaris 8
# Line 37 | Line 57 | if ($ostype eq "SunOS") {
57   }
58   elsif ($ostype eq "Linux") {
59      # covers: Debian r2.2
60 <    $topbin = "/usr/bin/top -d1 -n0 -b";
60 >    $topbin = "/usr/bin/top -d1 -n2 -b -p0";
61      $dfbin = "/bin/df";
62      $usersbin = "/usr/bin/users";
63      $unamebin = "/bin/uname";
# Line 50 | Line 70 | elsif ($ostype eq "FreeBSD") {
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";
# Line 76 | Line 97 | exit(0);
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  
# Line 103 | 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);
# Line 148 | Line 169 | sub include_top() {
169      # Find out some numbers from top.
170      my(@top) = `$topbin`;
171      my($top) = join(" ", @top);
172 <    $top =~ s/\n//g;
172 >    $top =~ s/\n/ /g;
173  
174 <    &print_pair(0, "packet.processes.total", $top =~ /([^\s]+?) processes:/);
175 <    &print_pair(0, "packet.processes.sleeping", $top =~ / ([^\s]+?) sleeping/);
176 <    &print_pair(0, "packet.processes.zombie", $top =~ / ([^\s]+?) zombie/);
177 <    &print_pair(0, "packet.processes.stopped", $top =~ / ([^\s]+?) stopped/);
178 <    &print_pair(0, "packet.processes.cpu", $top =~ /([^\s]+?)\s*on cpu/);
179 <    &print_pair(0, "packet.cpu.idle", $top =~ /([^\s]+?)% idle/);
180 <    &print_pair(0, "packet.cpu.user", $top =~ /([^\s]+?)% user/);
181 <    &print_pair(0, "packet.cpu.kernel", $top =~ /([^\s]+?)% kernel/);
182 <    &print_pair(0, "packet.cpu.iowait", $top =~ /([^\s]+?)% iowait/);
183 <    &print_pair(0, "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(0, "packet.memory.total", $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(0, "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(0, "packet.swap.free", $swap_free);
295 <
296 <    # AJ requested total swap instead of swap_in_use, so here we go!
297 <    &print_pair(0, "packet.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 231 | Line 361 | sub include_uptime() {
361      # grab the uptime
362      my($uptime) = `$uptimebin`;
363      
364 <    &print_pair(0, "packet.load.load1", $uptime =~ /load average.?:\s*([^\s]+?),/);
365 <    &print_pair(0, "packet.load.load5", $uptime =~ /load average.?:\s*.+?,\s*([^\s]+?),/);
366 <    &print_pair(0, "packet.load.load15", $uptime =~ /load average.?:\s*.+?,\s*.+?,\s*([^\s]+)/);
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      # 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+([0-9]+):([0-9]+)/;
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+([0-9]+)\s+.*,/;
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+([0-9]+)\s+.*,/;
386 >                $uptime =~ /up\s+([0-9]+)\s+[^\s]+,\s+([0-9]+)\s+[^\s]+,/;
387                  $uptime = "$1:0:$2";
388              }
389              else {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines