
##########################################################################
# $Id: xntpd,v 1.8 2005/10/02 15:00:34 bjorn Exp $
##########################################################################
# $Log: xntpd,v $
# Revision 1.8  2005/10/02 15:00:34  bjorn
# Corrections to last commit
#
# Revision 1.7  2005/10/01 18:30:12  bjorn
# Added filtering for listening and synchronized statements, by Gilles Detillieux
#
# Revision 1.6  2005/09/28 17:39:04  mike
# Patch from David Baldwin, plus a few other tweaks -mgt
#
# Revision 1.5  2005/07/05 22:16:23  mike
# Small patch from Paul Chambers -mgt
#
# Revision 1.4  2005/05/23 17:35:55  bjorn
# Patch for an older ntpd (4.1.1a-9), by Michael Evans
#
# Revision 1.3  2005/05/04 15:52:51  bjorn
# Removed shell path to perl in first line
#
# Revision 1.2  2005/02/24 17:08:05  kirk
# Applying consolidated patches from Mike Tremaine
#
# Revision 1.2  2005/02/16 00:43:28  mgt
# Added #vi tag to everything, updated ignore.conf with comments, added emerge and netopia to the tree from Laurent -mgt
#
# Revision 1.1  2005/02/13 01:25:13  mgt
# Inital code check in from David Baldwin -mgt
#
##########################################################################

########################################################
# This was written and is maintained by:
#    David Baldwin <david.baldwin@anu.edu.au>
#
# Heavily based on sshd script
#
# Please send all comments, suggestions, bug reports,
#    etc, to david.baldwin@anu.edu.au.
########################################################

use Logwatch ':all';

$Debug = $ENV{'LOGWATCH_DEBUG'} || 0;
$Detail = $ENV{'LOGWATCH_DETAIL_LEVEL'} || 0;

# No sense in running if 'xntpd' doesn't even exist on this system...
unless (( -f "/usr/sbin/ntpd" ) or ( -f "/usr/local/sbin/ntpd") or ( -f "/usr/lib/inet/xntpd")) {
   if ( $Debug >= 5 ) {
      print STDERR "\n\nDEBUG: Exiting XNTPD Filter - no ntpd binary on system\n\n";
   }
   exit (0);
}

if ( $Debug >= 5 ) {
         print STDERR "\n\nDEBUG: Inside XNTPD Filter \n\n";
         $DebugCounter = 1;
}


while (defined($ThisLine = <STDIN>)) {
    if ( $Debug >= 5 ) {
       print STDERR "DEBUG($DebugCounter): $ThisLine";
       $DebugCounter++;
    }
    chomp($ThisLine);
    if ( 
        ($ThisLine =~ m/tickadj = /) or # startup
        ($ThisLine =~ m/precision = /) or # startup
        ($ThisLine =~ m/ succeeded/) or # startup
        ($ThisLine =~ m/kernel time (discipline|sync) status/) or # startup
        ($ThisLine =~ m/kernel time sync (dis|en)abled /) or # startup
        ($ThisLine =~ m/frequency initialized/) or # startup
        ($ThisLine =~ m/using kernel phase-lock loop/) # startup
    ) {
       # Ignore these
    } elsif ($ThisLine =~ m/ntpd [\d\-\.\w@]+ ... ... .. ..:..:.. /) {
      $Starts++;
    } elsif ($ThisLine =~ m/ntpd exiting on signal/) {
      $Kills++;
    } elsif ($ThisLine =~ m/synchronisation lost/) {
      $SyncLost++;
    } elsif ( (undef,$TimeStep) = ($ThisLine =~ /time reset(| \(step\)) ([^ ]+) s$/ )) {
       push @TimeReset, $TimeStep;
    } elsif ( (undef,$TimeStep) = ($ThisLine =~ /(step|adjust) time server [^ ]+ offset ([^ ]+) sec$/ )) {
       push @TimeReset, $TimeStep;
# MEv start no leadin to line
    } elsif ( (undef,$TimeStep) = ($ThisLine =~ /(offset) ([^ ]+) sec/ )) {
       push @TimeReset, $TimeStep;
# MEv end no leadin to line
    } elsif ( ($ListenOn) = ($ThisLine =~ /Listening on interface ([^ ]+, [^ ]+)/ )) {
       $Interfaces{$ListenOn}++;
    } elsif ( ($SyncTo,$Stratum) = ($ThisLine =~ /synchronized to ([^ ]+), stratum ([^ ]+)/ )) {
       if ($Detail > 5 && $SyncTo =~ m/^[\d.]+$/) {
           $name = LookupIP($SyncTo);
       } else {
           $name = $SyncTo;
       }
       $name .= " stratum " . $Stratum;
       $Syncs{$name}++;
    } elsif ( ($Host) = ($ThisLine =~ /two instances of default interface for ([^ ]+) in hash table$/ )) {
       if ($Debug >= 5) {
          print STDERR "DEBUG: Found -$1 two instances of default interface\n";
       }
       $name = LookupIP($Host);
       $TwoInst{$name}++;
    } else {
       # Report any unmatched entries...
       push @OtherList, "$ThisLine\n";
    }
}

###########################################################

if ($Kills) {
    print "\nXNTPD Killed: " . $Kills . " Time(s)\n";
}
if ($Starts) {
    print "\nXNTPD Started: " . $Starts . " Time(s)\n";
}
if ($SyncLost) {
    print "\nSync lost: " . $SyncLost . " Time(s)\n";
}

if (@TimeReset > 0) {
    if ($Detail > 5) {
       print "\nTime Reset\n";
       print map "  time stepped $_\n",@TimeReset;
    }
    $t = 0;
    $t += $_ foreach @TimeReset;
    printf "\nTime Reset ".(@TimeReset)." times (total: %.6f s  average: %.6f s)\n", $t, $t/(@TimeReset);
}

if (keys %Interfaces) {
    if ($Detail > 5) {
       print "\nListening on interfaces:\n";
       foreach $i (keys %Interfaces) {
         print "  $i - $Interfaces{$i} times\n";
       }
    }
    $t = 0;
    $lt = 0;
    foreach $i (keys %Interfaces) {
       unless ($i =~ m/^(wildcard|lo)/) {
          $lt++;
       }
       $t++;
    }
    print "\nTotal interfaces ".$t." (non-local: ".$lt.")\n";
}

if (keys %Syncs) {
    if ($Detail > 5) {
       print "\nSynchronized to:\n";
       foreach $h (keys %Syncs) {
         print "  $h - $Syncs{$h} times\n";
       }
    }
    $t = 0;
    $ht = 0;
    foreach $h (keys %Syncs) {
       $ht++;
       $t += $Syncs{$h};
    }
    print "\nTotal synchronizations ".$t." (hosts: ".$ht.")\n";
}

if (keys %TwoInst) {
    print "\nTwo instances error\n";
    foreach $h (keys %TwoInst) {
      print "  $h - $TwoInst{$h} times\n";
    }
}

if ($#OtherList >= 0) {
    print "\n**Unmatched Entries**\n";
    print @OtherList;
}

exit(0);

# vi: shiftwidth=3 tabstop=3 syntax=perl et
