#!/opt/bin/perl

use Socket;
use Getopt::Long;
use Net::FPing;
use AnyEvent;

my $ipv6 = eval { require Socket6; 1 };

Getopt::Long::Configure ("bundling", "no_ignore_case");

my $count = 1;
my $rate  = 0;
my $wait  = 1;

GetOptions (
   "count|c=i" => \$count,
   "rate|p=n"  => \$kbps,
   "wait|w=n"  => \$wait,
) or exit 1;

my @ranges;

for (@ARGV) {
   my ($lo, $hi, $kbps) = split /,/;
   my $pktsz;

   $hi = $lo unless $hi;

   if ($lo =~ /:/) {
      # ipv6
      $ipv6 or die "Socket6 module missing, no ipv6 support available.\n";
      $lo = inet_pton (AF_INET6, $lo);
      $hi = inet_pton (AF_INET6, $hi);
      $pktsz = Net::FPing::icmp6_pkt_size;
   } else {
      $lo = inet_aton $lo;
      $hi = inet_aton $hi;
      $pktsz = Net::FPing::icmp4_pkt_size;
   }

   push @ranges, [$lo, $hi, $kbps && $pktsz / ($kbps * 1000)];
}

Net::FPing::register_cb {
   use Data::Dumper;
   warn Dumper \@_;
};

for (0 .. $count - 1) {
   my $done = AnyEvent->condvar;
   Net::FPing::icmp_ping \@ranges, $rate && 1 / $rate, $_, sub { $done->broadcast };
   $done->wait;
}

{
   my $done = AnyEvent->condvar;
   my $wait_w = AnyEvent->timer (after => $wait, cb => sub { $done->broadcast });
   $done->wait;
}