view release on metacpan or  search on metacpan

t/author-simple.t  view on Meta::CPAN

#!perl

BEGIN {
  unless ($ENV{AUTHOR_TESTING}) {
    require Test::More;
    Test::More::plan(skip_all => 'these tests are for testing by the author');
  }
}


use strict;
use warnings;
use Test::More;

use AnyEvent;
use AnyEvent::Monitor::CPU qw( monitor_cpu );

#
# This test will steadly increase the CPU load until the watcher triggers,
# and then steadly decrease it until it triggers again
#

## the load generator
my $iters          = 50_000;
my $incr           = 25_000;
my $load_gen_timer = AnyEvent->timer(
  after    => .5,
  interval => .1,
  cb       => sub {
    note("  ... generating $iters count of load") if $ENV{AUTHOR_TESTING};
    my $i = $iters;
    my $a = 0;
    while ($i--) {
      $a += $i * $incr / $iters;
    }
  },
);

## the load modifier
my $direction      = 1;
my $load_mod_timer = AnyEvent->timer(
  after    => 1,
  interval => .2,
  cb       => sub {
    my $delta = $direction * $incr;
    $iters += $delta;
    $iters = 0 if $iters < 0;
    note("  !!! Delta is $delta, iters now $iters") if $ENV{AUTHOR_TESTING};
  },
);


## Test cases
my @cases = (
  ['default_values' => {high => .95, low => .80}],
  ['keep_it_busy'   => {high => .97, low => .95}],
  ['take_it_slow'   => {high => .30, low => .20}],
  ['high_and_low'   => {high => .90, low => .10}],
  [ 'half-empty' => {
      high         => .55,
      low          => .45,
      high_samples => 4,
      low_samples  => 4,
      interval     => .1,
      cycles       => 3
    }
  ],
);

for my $tc (@cases) {
  my ($name, $params) = @$tc;
  my $high_lim = $params->{high};
  my $low_lim  = $params->{low};
  my $cycles   = $params->{cycles} ||= $ENV{WARM_UP_CYCLES} || 1;
  my $cv       = AnyEvent->condvar;

  diag("Starting test '$name': high => $high_lim, low => $low_lim");

  ## Make sure we stop it at some point
  my $secs = 10 * ($cycles || 1);
  my $time_limit = AnyEvent->timer(
    after => $secs,
    cb    => sub {
      $cv->send();
    }
  );

  my $mon = start_load_watcher($name, $cv, $params);
  my $stats = $mon->stats;
  ok(!$stats->{usage_count});
  ok(!$stats->{usage_sum});
  ok(!$stats->{usage_avg});
  is($stats->{usage}, $mon->usage);

  my ($high, $low, $h_iters, $l_iters) = $cv->recv;
  ok($mon->is_running);
  $mon->stop;
  ok(!$mon->is_running);

  if (!$high) {
    fail("Aborted test after $secs seconds");
  }
  else {
    ok($high >= $high_lim,
      "Good high value ($h_iters for $high) in '$name' (target $high_lim)");
    ok($low <= $low_lim,
      "Good low value ($l_iters for $low) in '$name' (target $low_lim)");

    $stats = $mon->stats;
    ok($stats->{usage_count}, "Good final count ($stats->{usage_count})");
    ok($stats->{usage_sum},   "Good final usage sum ($stats->{usage_sum})");
    ok($stats->{usage_avg},   "Good final avg usage ($stats->{usage_avg})");
    is($stats->{usage}, $mon->usage, "Correct usage in stats");
    my $margin = ($high_lim - $low_lim) / 2;
    if ($margin >= .04) {
      ok(