-my ($pid, $rdr) = spawn;
-
-sub tryspeed {
- my ($l, $n) = @_;
- my $speed = 2 ** 16;
- my $ok = 0;
- my @alpha = ('a' .. 'z');
- my $msg = join '', map { $alpha[rand @alpha] } 1 .. $l;
- my $desc_base = "$l bytes sent $n times";
- while (($ok < $n) && (($speed /= 2) >= 1)) {
- my $desc = "$desc_base at $speed bits/s";
- diag("try $desc...");
-TRY:
- for (1 .. $n) {
- my $r = '';
- eval {
- local $SIG{ALRM} = sub { die 'timeout' };
- local $SIG{__WARN__} = sub { die 'do not want warnings' };
- my $a = (int(100 * (3 * $l) / $speed) || 1);
- $a = 10 if $a > 10;
- alarm $a;
- kill SIGHUP => $pid;
- msend $msg => $pid, speed => $speed;
- $r = <$rdr>;
- };
- kill SIGHUP => $pid if $@;
- alarm 0;
- if (!defined $r) { # Something bad happened, respawn
- close $rdr or die "close() failed: $!";
- slaughter $pid;
- ($pid, $rdr) = spawn;
- redo TRY; # Retry this send
- } else {
- chomp $r;
- if ($r eq $msg) {
- ++$ok;
- } else {
- kill SIGHUP => $pid;
- last TRY;
- }
- }
- }
- }
- ok($ok >= $n, $desc_base);
- push @res, $desc_base . (($speed) ? ' at ' . $speed . ' bits/s' : ' failed');
-}