summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--CHANGES3
-rw-r--r--lib/Smokeping/matchers/CheckLatency.pm97
-rw-r--r--lib/Smokeping/matchers/CheckLoss.pm96
3 files changed, 195 insertions, 1 deletions
diff --git a/CHANGES b/CHANGES
index f8521ca..a80d884 100644
--- a/CHANGES
+++ b/CHANGES
@@ -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};
+}