* added matchers CheckLatency and CheckLoss -- tobi, from Dylan Vanderhoof DylanV semaphore.com

2 files changed, 193 insertions, 0 deletions

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};
+}