File: WeightedAvgRate.t

package info (click to toggle)
percona-toolkit 3.2.1-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, bullseye, forky, sid, trixie
  • size: 68,916 kB
  • sloc: perl: 241,287; sql: 22,868; sh: 19,746; javascript: 6,799; makefile: 353; awk: 38; python: 30; sed: 1
file content (85 lines) | stat: -rw-r--r-- 1,416 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
#!/usr/bin/perl

BEGIN {
   die "The PERCONA_TOOLKIT_BRANCH environment variable is not set.\n"
      unless $ENV{PERCONA_TOOLKIT_BRANCH} && -d $ENV{PERCONA_TOOLKIT_BRANCH};
   unshift @INC, "$ENV{PERCONA_TOOLKIT_BRANCH}/lib";
};

use strict;
use warnings FATAL => 'all';
use English qw(-no_match_vars);
use Test::More tests => 6;

use WeightedAvgRate;
use PerconaTest;

my $rll = new WeightedAvgRate(
   initial_n => 1000,
   initial_t => 1,
   target_t  => 1,
);

# stay the same
for (1..5) {
   $rll->update(1000, 1);
}
is(
   $rll->update(1000, 1),
   1000,
   "Same rate, same n"
);

# slow down
for (1..5) {
   $rll->update(1000, 2);
}
is(
   $rll->update(1000, 2),
   540,
   "Decrease rate, decrease n"
);

for (1..15) {
   $rll->update(1000, 2);
}
is(
   $rll->update(1000, 2),
   500,
   "limit n=500 decreasing"
);

# speed up
for (1..5) {
   $rll->update(1000, 1);
}
is(
   $rll->update(1000, 1),
   849,
   "Increase rate, increase n"
);

for (1..20) {
   $rll->update(1000, 1);
}
is(
   $rll->update(1000, 1),
   999,
   "limit n=1000 increasing"
);

# #############################################################################
# Done.
# #############################################################################
my $output = '';
{
   local *STDERR;
   open STDERR, '>', \$output;
   $rll->_d('Complete test coverage');
}
like(
   $output,
   qr/Complete test coverage/,
   '_d() works'
);
exit;