theoretically completed the burner ... not in a working state yet though

backend/bin/smokeping.pl

@@ -10,7 +10,7 @@
 
 # loading some modules just to be sure they are 
 # present and can load
-use Smokeping::Command::smoke;
+use Smokeping::Command::burn;
 
 our $VERSION = "0";
 

backend/etc/smokeping.cfg.dist

@@ -1,3 +1,4 @@
+# sample config
 *** General ***
 
 owner    = Peter Random
@@ -88,8 +89,13 @@ max_rtt = 2
 *** Probes ***
 
 + FPing
+binary = /bin/ping
 
-binary = /usr/bin/fping
+++SlowFPing
+step = 200
+
+++FastFPing
+step = 100
 
 *** Slaves ***
 secrets=/tmp/smokeping-31631-build/etc/smokeping_secrets.dist
@@ -103,7 +109,7 @@ color=00ff00
 
 *** Targets ***
 
-probe = FPing
+probe = SlowFPing
 
 menu = Top
 title = Network Latency Grapher
@@ -115,6 +121,7 @@ menu= Targets
 #parents = owner:/Test/James location:/
 
 ++ James
+probe = FastFPing
 
 menu = James
 title =James

backend/lib/Smokeping/Command/burn.pm

@@ -0,0 +1,219 @@
+package Smokeping::Command::burn;
+
+use Mojo::Base 'Mojolicious::Command';
+use Time::HiRes qw(gettimeofday);
+use Getopt::Long qw(GetOptionsFromArray :config no_auto_abbrev no_ignore_case);
+use POSIX qw(strftime);
+use Pod::Usage;
+use Smokeping::Config;
+use POSIX qw(strftime);
+use AnyEvent::Fork;
+use AnyEvent::Fork::RPC;
+
+has description => "run probes according to configuration.\n";
+has usage       => <<"EOF";
+usage: $0 burn [options]
+
+smokeping.pl burn [options]
+
+     --help           Print the manual page.
+
+     --verbose        Send all loging output to the terminal.
+
+     --noaction       Do everything except actually log any data to rrdtool
+
+EOF
+
+has 'config' => sub {
+    my $self = shift;
+    my $conf = Smokeping::Config->new(
+        app => $self->app,
+        file => $ENV{SMOKEPING_CONF} || $self->app->home->rel_file('etc/smokeping.cfg' )
+    );
+    return $conf;
+};
+
+use vars qw(%opt);
+
+sub run {
+    my ($self, @args) = @_;
+
+    GetOptionsFromArray \@args, \%opt,qw(pod verbose noaction) or exit 1;
+
+    if ($opt{help})     { pod2usage(-exitstatus => 0, -verbose => 2) }
+    if ($opt{noaction}) { print STDERR "*** Runnning in NO ACTION mode ***\n"; $opt{verbose}=1 }
+
+    if ($opt{pod}) { print $self->config->pod; exit 0 };
+
+    $self->burn;
+}
+
+
+sub burn {
+    my $self;
+    my $pool = $self->createProbes;
+    my $cfg = $self->config->cfgHash;
+    my $targets = $cfg->{Targets};
+    my %timers;
+    my %running;
+    my %skipped;
+    my %queue;
+    my %rrdqueue;
+    # schedule the tasks for the probes
+    # note that a task can only get scheduled once his old
+    # iteration has completed.
+    for my $task ( @$targets ){
+        $timer{task}{$task} = AnyEvent->timer(
+            interval => $task->{step} || $cfg->{Probes}{$task->{probe}}{step},
+            cb => sub {
+                if ($running{$task}){
+                    $self->log->warn("delay $task->{target} ($task->{probe}): still running");
+                    $skipped{$task} = 1;
+                }
+                else {
+                    $running{$task} = 1;               
+                    push @{$queue{$task->{probe}},$task;
+                }
+           }
+       )
+    }
+    # have the probe look in their task list for work
+    for my $probe (keys %$pool){
+        my $targetcount = $pool->{$probe}{config}->targetcount;
+        $timer{probe}{$probe} = AnyEvent->timer(
+           interval => 1,
+           cb => sub {
+               my $queue = $queue->{$probe};
+               return unless @$queue;
+               my @work;
+               while (push @work = shift @$queue){ 
+                   while (scalar @work < $targetcount and @$queue){
+                        push @work = shift @$queue
+                   }
+                   $pool->{$probe}{worker}->({
+                        cfg => $cfg->{Probes},
+                        work => \@work,
+                   }, sub {
+                        my $result = shift;
+                        for my $path (keys %$results){
+                            $rrdqueue{$path}, $result{$path};
+                        }
+                        for my $task (@work){
+                            if ($skipped{$task}){
+                                $skipped{$task} = 0;    
+                                push @$queue,$task;
+                            }
+                            else {
+                                $running{$task} = 0;
+                           }
+                        }
+                   });
+                }
+           });
+        }
+    }
+
+}
+
+sub createProbes {
+    my $self = shift;
+    my $cfg = $self->config->cfgHash;   
+    my %Probe;
+    for my $key ( keys %{$cfg->{Probes}} ){
+        my $probeModule = $cfg->{Probes}{$key}{probeModule};
+        my $instance = do {
+             no strict 'refs'; ## no critic (ProhibitNoStrict)
+             # for this to work, we need a quoted string here, not something
+             # like 'xxx::'.$value as -> is binding more strongly than .
+             "Smokeping::Probe::${probeModule}::Config"->new;
+        };                                  
+        my $rpc = AnyEvent::Fork
+           ->new
+           ->require ("Smokeping::Probe::$probeModule::Worker")
+           ->AnyEvent::Fork::RPC::run ("Smokeping::Probe::${probeModule}::Worker::run",
+                on_error   => sub { $self->log->error($_[0]) },
+                on_event   => sub { $self->log->warn($_[0]) },  
+                serialiser =>  $AnyEvent::Fork::RPC::JSON_SERIALISER,
+                load => 1,
+                max => $cfg->{Probes}{$key}{workers}
+           );
+        $Probe{$key} = {
+            worker => $rpc,
+            config => $instance
+        };
+    }
+    return \%Probe;
+}
+
+
+
+
+1;
+
+__END__
+
+=head1 NAME
+
+smoke.pm - Smokeping probe runner
+
+=head1 SYNOPSIS
+
+smokeping.pl B<smoke> [I<options>...]
+
+     --man            Print the manual page of osp.
+
+     --verbose        Send all loging output to the terminal.
+
+     --noaction       Do everything except actually perform any changes.
+                      This includes adding entries to  the database
+                      but without commit.   
+
+=head1 DESCRIPTION
+
+In smoke mode, smokeping runs the probes configured, gathers the data and
+updates the appropriate rrd files.
+
+=head1 USAGE
+
+...
+
+=head1 COPYRIGHT
+
+Copyright (c) 2013 by OETIKER+PARTNER AG. All rights reserved.
+
+=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
+
+S<Tobias Oetiker E<lt>tobi@oetiker.chE<gt>>
+
+=head1 HISTORY 
+
+ 2013-09-27 to Initial
+
+=cut
+
+
+# Emacs Configuration
+#
+# Local Variables:
+# mode: cperl
+# eval: (cperl-set-style "PerlStyle")
+# mode: flyspell
+# mode: flyspell-prog
+# End:
+#