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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
|
require 'test_helper'
require 'metriks/histogram'
class HistogramTest < Test::Unit::TestCase
include ThreadHelper
def setup
end
def test_uniform_sample_min
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
@histogram.update(5)
@histogram.update(10)
assert_equal 5, @histogram.min
end
def test_uniform_sample_max
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
@histogram.update(5)
@histogram.update(10)
assert_equal 10, @histogram.max
end
def test_uniform_sample_mean
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
@histogram.update(5)
@histogram.update(10)
assert_equal 7, @histogram.mean
end
def test_uniform_sample_mean_threaded
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
thread 10, :n => 100 do
@histogram.update(5)
@histogram.update(10)
end
assert_equal 7, @histogram.mean
end
def test_uniform_sample_2000
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
2000.times do |idx|
@histogram.update(idx)
end
assert_equal 1999, @histogram.max
end
def test_uniform_sample_2000_threaded
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
t = 10
thread t do |i|
2000.times do |x|
if (x % t) == i
@histogram.update x
end
end
end
assert_equal 1999, @histogram.max
end
def test_uniform_sample_snashot
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
100.times do |idx|
@histogram.update(idx)
end
snapshot = @histogram.snapshot
assert_equal 49.5, snapshot.median
end
def test_uniform_sample_snapshot_threaded
@histogram = Metriks::Histogram.new(Metriks::UniformSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE))
thread 10 do
100.times do |idx|
@histogram.update(idx)
end
end
snapshot = @histogram.snapshot
assert_equal 49.5, snapshot.median
end
def test_exponential_sample_min
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
@histogram.update(5)
@histogram.update(10)
assert_equal 5, @histogram.min
end
def test_exponential_sample_max
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
@histogram.update(5)
@histogram.update(10)
assert_equal 10, @histogram.max
end
def test_exponential_sample_mean
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
@histogram.update(5)
@histogram.update(10)
assert_equal 7, @histogram.mean
end
def test_exponential_sample_mean_threaded
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
thread 10, :n => 100 do
@histogram.update(5)
@histogram.update(10)
end
assert_equal 7, @histogram.mean
end
def test_exponential_sample_2000
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
2000.times do |idx|
@histogram.update(idx)
end
assert_equal 1999, @histogram.max
end
def test_exponential_sample_2000_threaded
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
t = 10
thread t do |i|
2000.times do |idx|
if (idx % t) == i
@histogram.update(idx)
end
end
end
assert_equal 1999, @histogram.max
end
def test_exponential_sample_snashot
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
100.times do |idx|
@histogram.update(idx)
end
snapshot = @histogram.snapshot
assert_equal 49.5, snapshot.median
end
def test_exponential_sample_snapshot_threaded
@histogram = Metriks::Histogram.new(Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA))
thread 10 do
100.times do |idx|
@histogram.update(idx)
end
end
snapshot = @histogram.snapshot
assert_equal 49.5, snapshot.median
end
def test_long_idle_sample
Time.stubs(:now).returns(Time.at(2000))
sample = Metriks::ExponentiallyDecayingSample.new(Metriks::Histogram::DEFAULT_SAMPLE_SIZE, Metriks::Histogram::DEFAULT_ALPHA)
Time.unstub(:now)
@histogram = Metriks::Histogram.new(sample)
@histogram.update(5)
assert_equal 5, @histogram.min
end
end
|
