diff options
| -rw-r--r-- | CHANGES | 3 | ||||
| -rw-r--r-- | lib/Smokeping/matchers/CheckLatency.pm | 97 | ||||
| -rw-r--r-- | lib/Smokeping/matchers/CheckLoss.pm | 96 |
3 files changed, 195 insertions, 1 deletions
@@ -1,4 +1,5 @@ -* added TacacsPlus probe -- tobi, Gary.Mikula nasd.com +* added matchers CheckLatency and CheckLoss -- tobi, from Dylan Vanderhoof DylanV semaphore.com +* added TacacsPlus probe -- tobi, from Gary.Mikula * nasd.com 2006/7/14 -- released version 20060714_trunk diff --git a/lib/Smokeping/matchers/CheckLatency.pm b/lib/Smokeping/matchers/CheckLatency.pm new file mode 100644 index 0000000..eef4016 --- /dev/null +++ b/lib/Smokeping/matchers/CheckLatency.pm @@ -0,0 +1,97 @@ +package Smokeping::matchers::CheckLatency; + +=head1 NAME + +Smokeping::matchers::CheckLatency - Edge triggered alert to check latency is under a value for x number of samples + +=head1 DESCRIPTION + +Call the matcher with the following sequence: + + type = matcher + edgetrigger = yes + pattern = CheckLatency(l=>latency to check against,x=>num samples required for a match) + +This will create a matcher which checks for "l" latency or greater over "x" samples before raising, +and will hold the alert until "x" samples under "l" before clearing + +=head1 COPYRIGHT + +Copyright (c) 2006 Dylan C Vanderhoof, Semaphore Corporation + +=head1 LICENSE + +This program is free software; you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation; either version 2 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + +=head1 AUTHOR + +Dylan Vanderhoof <dylanv@semaphore.com> + +=cut + +use strict; +use base qw(Smokeping::matchers::base); +use vars qw($VERSION); +$VERSION = 1.0; +use Carp; + +# I never checked why Median works, but for some reason the first part of the hash was being passed as the rules instead +sub new(@) { + my $class = shift; + my $rules = { + l => '\d+', + x => '\d+' + }; + my $self = $class->SUPER::new( $rules, @_ ); + return $self; +} + +# how many values should we require before raising? +sub Length($) { + my $self = shift; + return $self->{param}{x}; # Because we're edge triggered, we don't need any more than the required samples +} + +sub Desc ($) { + croak "Monitor latency with a cooldown period for clearing the alert"; +} + +sub Test($$) { + my $self = shift; + my $data = shift; # @{$data->{rtt}} and @{$data->{loss}} + my $target = $self->{param}{l} / 1000; # Smokeping reports in seconds + my $count = 0; + my $rtt; + my @rtts = @{ $data->{rtt} }; + foreach $rtt ( @{ $data->{rtt} } ) { + + # If there's an S in the array anywhere, return prevmatch + if ( $rtt =~ /S/ ) { return $data->{prevmatch}; } + if ( $data->{prevmatch} ) { + + # Alert has already been raised. Check to make sure ALL latencies in RTT are less than the target + if ( $rtt < $target ) { $count++; } + } else { + + # Alert is not raised. If all values are over the alert threshold OR unreachable, raise the alert + if ( $rtt >= $target ) { $count++; } + } + } + if ( $count >= $self->{param}{x} ) { + return !$data->{prevmatch}; + } + + return $data->{prevmatch}; +} diff --git a/lib/Smokeping/matchers/CheckLoss.pm b/lib/Smokeping/matchers/CheckLoss.pm new file mode 100644 index 0000000..7642f2d --- /dev/null +++ b/lib/Smokeping/matchers/CheckLoss.pm @@ -0,0 +1,96 @@ +package Smokeping::matchers::CheckLoss; + +=head1 NAME + +Smokeping::matchers::CheckLoss - Edge triggered alert to check loss is under a value for x number of samples + +=head1 DESCRIPTION + +Call the matcher with the following sequence: + + type = matcher + edgetrigger = yes + pattern = CheckLoss(l=>loss to check against,x=>num samples required for a match) + +This will create a matcher which checks for "l" loss or greater over "x" samples before raising, +and will hold the alert until "x" samples under "l" before clearing + +=head1 COPYRIGHT + +Copyright (c) 2006 Dylan C Vanderhoof, Semaphore Corporation + +=head1 LICENSE + +This program is free software; you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation; either version 2 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + +=head1 AUTHOR + +Dylan Vanderhoof <dylanv@semaphore.com> + +=cut + +use strict; +use base qw(Smokeping::matchers::base); +use vars qw($VERSION); +$VERSION = 1.0; +use Carp; + +# I never checked why Median works, but for some reason the first part of the hash was being passed as the rules instead +sub new(@) { + my $class = shift; + my $rules = { + l => '\d+', + x => '\d+' + }; + my $self = $class->SUPER::new( $rules, @_ ); + return $self; +} + +# how many values should we require before raising? +sub Length($) { + my $self = shift; + return $self->{param}{x}; # Because we're edge triggered, we don't need any more than the required samples +} + +sub Desc ($) { + croak "Monitor loss with a cooldown period for clearing the alert"; +} + +sub Test($$) { + my $self = shift; + my $data = shift; # @{$data->{rtt}} and @{$data->{loss}} + my $target = $self->{param}{l}; + my $count = 0; + my $loss; + foreach $loss ( @{ $data->{loss} } ) { + + # If there's an S in the array anywhere, return prevmatch + if ( $loss =~ /S/ ) { return $data->{prevmatch}; } + if ( $data->{prevmatch} ) { + + # Alert has already been raised. Check to make sure ALL latencies in RTT are less than the target + if ( $loss < $target ) { $count++; } + } else { + + # Alert is not raised. If all values are over the alert threshold OR unreachable, raise the alert + if ( $loss >= $target ) { $count++; } + } + } + if ( $count >= $self->{param}{x} ) { + return !$data->{prevmatch}; + } + + return $data->{prevmatch}; +} |