#! /usr/bin/perl
## Warning: this is a BETA-3 / 950816.
##
## This is a Perl version for ``innwatch''.
##
## The original innwatch package, furnished with the INN distribution has
## been written, extended and modified by Mike Cooper, Robert Elz and
## Steve Groom as well as others.
##
## Perl version written and maintained for all those systems who have
## broken shells by Christophe Wolfhugel <wolf@pasteur.fr> (formerly
## working at Herve Schauer Consultants).
## of the Pasteur Institute, Paris, France.
## You might also find this script useful as it sucks much much less CPU
## than its shell equivalent, most functions are Perl builtins and ease
## the work.
##
## Copyright (C) 1993, Christophe Wolfhugel & Herve Schauer Consultants.
## Copyright (C) 1995, Christophe Wolfhugel & Institut Pasteur.
##
## This is free software. Don't sell it. Don't pay to get it.
## Don't distribute this package modified. Send me diffs for inclusion instead.
##
## As with all free software:
##
## ABSOLUTELY NO WARRANTY WITH THIS PACKAGE. USE IT AT YOUR OWN RISKS.
##
##-----------------------------------------------------------------------------
##
## This release as well as any new ones can be retrieved by anonymous ftp
## on ftp.univ-lyon1.fr as
## /pub/systems/unix/news/transport/inn/contrib/innwatch*.pl
## or by using our ftpmail server: ftpmail@grasp.insa-lyon.fr.
##
##-----------------------------------------------------------------------------
##
## INSTALLATION: subst -f config.data innwatch.pl before starting the
## daemon.
##
## Following stuff gets subst'ed to have the path names suitable for your
## site.
## =()<$ctlwatch = '@<_PATH_CTLWATCH>@';>()=
print("You did not run subst -f config.data innwatch.pl. Exiting\n"); exit(0);
## =()<$daily = '@<_PATH_LOCKS>@/LOCK.news.daily';>()=
$daily = '/local/news/LOCK.news.daily';
## =()<$innwstatus = '@<_PATH_INNWSTATUS>@';>()=
$innwstatus = '/local/news/innwatch.status';
## =()<$mailcmd = '@<_PATH_MAILCMD>@';>()=
$mailcmd = '/usr/bin/mail';
## =()<$most_logs = '@<_PATH_MOST_LOGS>@';>()=
$most_logs = '/var/log/news';
## =()<$newsmaster = '@<NEWSMASTER>@';>()=
$newsmaster = 'newsmaster';
## =()<$locks = '@<_PATH_LOCKS>@';>()=
$locks = '/local/news';
## =()<$serverpid = '@<_PATH_SERVERPID>@';>()=
$serverpid = '/local/news/innd/innd.pid';
## =()<$spool = '@<_PATH_SPOOL>@';>()=
$spool = '/news';
## =()<$sleeptime = @<INNWATCH_SLEEPTIME>@;>()=
$sleeptime = 5;
## =()<$watchpid = '@<_PATH_WATCHPID>@';>()=
$watchpid = '/local/news/innwatch.pid';
## Set the path
## =()<$ENV{'PATH'} = "@<_PATH_NEWSBIN>@:$ENV{'PATH'}";>()=
$ENV{'PATH'} = "/usr/local/news/bin:$ENV{'PATH'}";
$progname = "innwatch";
### Where to put the timestamp file (directory and filename).
$timestamp = "$locks/$progname.time";
$lock = "$locks/LOCK.$progname";
### Logfile to watch. Comment out if no logwatch.
$logfile = "$most_logs/news.crit";
## Args for compatibility with the shell verion. But I did not test the
## script with arguments yet, so it is expected to work, but not guaranteed.
while ($_ = $ARGV[0], /^-/) {
shift;
/^-f$/
&& ((@ARGV > 0) || die "Missing argument to \"-f\" option.\n")
&& ($ctlwatch = shift) && next;
/^-f(.+)$/
&& ($ctlwatch = $1) && next;
/^-l$/
&& ((@ARGV > 0) || die "Missing argument to \"-l\" option.\n")
&& ($logfile = shift) && next;
/^-l(.+)$/
&& ($logfile = $1) && next;
/^-t$/
&& ((@ARGV > 0) || die "Missing argument to \"-t\" option.\n")
&& ($sleeptime = shift) && next;
/^-t(.+)$/
&& ($sleeptime = $1) && next;
/^-t$/
&& ((@ARGV > 0) || die "Missing argument to \"-t\" option.\n")
&& ($sleeptime = shift) && next;
/^-t(.+)$/
&& ($sleeptime = $1) && next;
/^-mailonchange$/
&& ($mailonchange = 1) && next;
die "Unknown option \"$_\".\n";
}
## Lock our stuff
if (system("shlock -p $$ -f $lock") !=0) {
open(F1, "$lock");
$_ = <F1>;
close(F1);
chop;
die("$progname: [$$] locked by [$_]");
}
## Load the innwatch.ctl file, interesting parts only. This is much much
## faster than with the shell release as this is done once only at startup.
sub loadctl {
$ctlmtime = (stat($ctlwatch))[9];
return if ($ctlmtime == $oldctlmtime);
$oldctlmtime = $ctlmtime;
@ctline = ();
open(F1, "$ctlwatch") || die("Can't open $ctlwatch");
while (<F1>) {
next if (/^\s*$/ || /^\s*#/);
chop;
push(@ctline, $_);
}
close(F1);
}
$SIG{'INT'} = 'IGNORE';
sub handler1 {
unlink($lock);
unlink($watchpid);
exit(1);
}
$SIG{'HUP'} = 'handler1';
$SIG{'QUIT'} = 'handler1';
$SIG{'TERM'} = 'handler1';
open(F1, "> $watchpid");
print F1 "$$\n";
close(F1);
### The reason why we turned INND off, and its, and our current state.
$reason = '';
$innd = '';
$state = '';
sub handler2 {
open(F1, "> $innwstatus");
print F1 "$progname waiting for INND to start (pid: $$)\n";
print F1 `date`;
close(F1);
}
$SIG{'INT'} = 'handler2';
### We need to remember the process ID of innd, in case one exits
### But we need to wait for innd to start before we can do that
while (! $pid) {
if (!open(F1, "$serverpid")) {
sleep($sleeptime);
next;
}
$pid = <F1>;
close(F1);
chop($pid);
}
sub handler3 {
open(F1, "> $innwstatus");
if ($state eq '') {
print F1 "$progname state RUN interval $sleeptime pid $$\n";
} else {
print F1 "$progname state $state interval $sleeptime pid $$\n";
}
if ($innd eq '') {
$x = "GO";
} else {
$x = $innd;
}
$x = "$x: $reason" if ($reason ne '');
print F1 "INND state $x\n";
print F1 `date`;
close(F1);
}
$SIG{'INT'} = 'handler3';
chdir($spool);
$nextsleep = 1;
$hasexited = "false";
while (sleep($nextsleep) && wait) {
&loadctl;
$nextsleep = $sleeptime;
## If news.daily is running, idle: we don't want to change the
## status of anything while news.daily may be depending on what we
## have done.
next if (-f "$daily");
## Check to see if INND is running.
## Notify NEWSMASTER if it has stopped or just restarted.
if (system("ctlinnd -s -t 120 mode 2>/dev/null") == 0) {
if ($hasexited eq "true") {
$hasexited = "false";
open(F1, "| $mailcmd -s \"INND is now running\" $newsmaster");
close(F1);
}
} else {
if ($hasexited eq "false") {
$hasexited = "true";
open(F1, "| $mailcmd -s \"INND is NOT running\" $newsmaster");
close(F1);
}
next;
}
## If innd has exited & restarted, put the new one into the
## same state the old one was in
if (open(F1, "$serverpid")) {
$npid = <F1>;
close(F1);
chop($npid);
if ($pid != $npid) {
system("ctlinnd -s \"$innd\" \"$reason\"") if ($innd ne "go");
$pid = $npid;
}
}
$value = 0;
$prevexp = '';
$l = 0;
foreach $line (@ctline) {
$l++;
$delim = $1 if ($line =~ /^(.)/);
## Parse the line into seven fields, and assign them to local vars.
## You're welcome to work out what's going on with quoting in
## the next few lines if you feel inclined.
@line = split(/\s*$delim\s*/, $line);
next if ($#line != 7);
$lab = $line[1];
$cnd = $line[2];
$exp = $line[3];
$tst = $line[4];
$lim = $line[5];
$cmd = $line[6];
$cmt = $line[7];
## Change shell tests to perl tests
$tst = "==" if ($tst eq "eq") ;
$tst = "!=" if ($tst eq "ne") ;
$tst = "<" if ($tst eq "lt") ;
$tst = ">" if ($tst eq "gt") ;
$tst = "<=" if ($tst eq "le") ;
$tst = ">=" if ($tst eq "ge") ;
## If there's no label, the label is the line number.
$lab = $l if ($lab eq "");
## Should we act on this line? We will if one (or more) of the
## specified conditions is satisfied.
$yeah = 0;
if ($cnd eq '') {
next if ($state && $state ne $lab);
} else {
foreach $c (split(/\s+/, $cnd)) {
if ($c eq '+') {
next if ($state);
} elsif ($c eq '*') {
;
} elsif ($c eq '-*') {
next if ($state eq $c);
} else {
next if ($state ne $c);
}
$yeah = 1;
last;
}
next if ($yeah == 0);
}
## Evaluate the expression, if there is one, and if that works.
if ($exp && $exp ne $prevexp) {
$value = `$exp`;
chop($value);
if ($? == 0) {
if ($cmd =~ /^(throttle|pause)$/) {
$ok = "n";
} else {
$ok = "y";
}
if (($state eq '' || $state ne $lab || $ok eq "y")
&& eval "$value $tst $lim") {
$r = "$cmt [$progname:$lab] $value $tst $lim";
$o = '';
if ($cmd eq "throttle") {
if ($state eq "" || $state eq "go") {
$reason = $r;
}
$o = $lab;
$arg = $reason;
} elsif ($cmd eq "pause") {
$o = $lab;
$reason = $r;
$arg = $reason;
} elsif ($cmd eq "shutdown") {
$arg = $r;
} elsif ($cmd eq "flush") {
$arg = '';
$o = $state;
$arg = $reason;
} elsif ($cmd eq "go") {
$arg = $reason;
$nextsleep = 1;
$reason = '';
} elsif ($cmd eq "exit") {
exit(0);
}
if (system("ctlinnd -s \"$cmd\" \"$arg\"") == 0) {
$state = $o;
$innd = $cmd;
if ($mailonchange) {
open(F1, "| $mailcmd -s \"INN: $cmd\" $newsmaster");
print F1 "$arg\n";
close(F1);
}
}
last;
} elsif ($state eq $lab
&& ($cmd eq "throttle" || $cmd eq "pause")
&& eval "! ($value $tst $lim)") {
system("ctlinnd -s go \"$reason\"");
$state = '';
$reason = '';
$innd = '';
## If we have started innd, run all tests again quickly in
## case there is some other condition that should stop it.
$nextsleep = 1;
last;
}
}
}
} ## Foreach line
if ($logfile && -f "$logfile") {
if (! -f "$timestamp") {
$doit = $logfile;
} else {
# use stat to print most recently modified file first.
# If that's ${LOGFILE}, it's changed since the last pass.
if ((stat($logfile))[9] > (stat($timestamp))[9]) {
$doit = $logfile;
} else {
$doit = '';
}
}
# If the file has been modified more recently than the timestamp,
# and the file has length greater than 0, send the warning.
if ($doit ne '' && -s "$logfile") {
open(F1, "> $timestamp");
print F1 `date`;
close(F1);
open(F1, "| $mailcmd -s \"$progname warning: messages in $logfile\" $newsmaster");
print F1 "-----\n";
print F1 `ctlinnd -t120 mode`, "\n";
print F1 "-----\n";
print F1 `cat $logfile`;
close(F1);
}
}
}
unlink($lock);
exit(0);