Lines Matching refs:anomalyTracker
132 AnomalyTracker anomalyTracker(alert, kConfigKey); in TEST() local
154 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0u); in TEST()
155 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, -1LL); in TEST()
158 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 0, bucket0, {}, {keyA, keyB, keyC})); in TEST()
159 detectAndDeclareAnomalies(anomalyTracker, 0, bucket0, eventTimestamp1); in TEST()
160 checkRefractoryTimes(anomalyTracker, eventTimestamp0, refractoryPeriodSec, in TEST()
164 anomalyTracker.addPastBucket(bucket0, 0); in TEST()
165 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3u); in TEST()
166 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 1LL); in TEST()
167 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
168 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
169 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 0LL); in TEST()
172 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 1, bucket1, {}, {keyA, keyB, keyC})); in TEST()
173 detectAndDeclareAnomalies(anomalyTracker, 1, bucket1, eventTimestamp1); in TEST()
174 checkRefractoryTimes(anomalyTracker, eventTimestamp1, refractoryPeriodSec, in TEST()
178 anomalyTracker.addPastBucket(bucket0, 0); in TEST()
179 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3u); in TEST()
180 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 1LL); in TEST()
181 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
182 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
183 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 0LL); in TEST()
184 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 1, bucket1, {}, {keyA, keyB, keyC})); in TEST()
185 detectAndDeclareAnomalies(anomalyTracker, 1, bucket1, eventTimestamp1 + 1); in TEST()
186 checkRefractoryTimes(anomalyTracker, eventTimestamp1, refractoryPeriodSec, in TEST()
190 anomalyTracker.addPastBucket(bucket1, 1); in TEST()
191 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 1L); in TEST()
192 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3UL); in TEST()
193 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 2LL); in TEST()
194 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
195 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
198 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 2, bucket2, {keyB}, {keyA, keyC})); in TEST()
199 detectAndDeclareAnomalies(anomalyTracker, 2, bucket2, eventTimestamp2); in TEST()
200 checkRefractoryTimes(anomalyTracker, eventTimestamp2, refractoryPeriodSec, in TEST()
204 anomalyTracker.addPastBucket(bucket1, 1); in TEST()
205 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 1L); in TEST()
206 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3UL); in TEST()
207 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 2LL); in TEST()
208 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
209 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
211 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 2, bucket2, {keyB}, {keyA, keyC})); in TEST()
212 detectAndDeclareAnomalies(anomalyTracker, 2, bucket2, eventTimestamp2 + 1); in TEST()
213 checkRefractoryTimes(anomalyTracker, eventTimestamp2, refractoryPeriodSec, in TEST()
217 anomalyTracker.addPastBucket(bucket2, 2); in TEST()
218 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 2L); in TEST()
219 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
220 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 1LL); in TEST()
221 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
224 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 3, bucket3, {keyA}, {keyB, keyC})); in TEST()
225 detectAndDeclareAnomalies(anomalyTracker, 3, bucket3, eventTimestamp3); in TEST()
226 checkRefractoryTimes(anomalyTracker, eventTimestamp3, refractoryPeriodSec, in TEST()
230 anomalyTracker.addPastBucket(bucket3, 3L); in TEST()
231 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 3L); in TEST()
232 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
233 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 2LL); in TEST()
234 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
237 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 4, bucket4, {keyB}, {keyA, keyC})); in TEST()
238 detectAndDeclareAnomalies(anomalyTracker, 4, bucket4, eventTimestamp4); in TEST()
239 checkRefractoryTimes(anomalyTracker, eventTimestamp4, refractoryPeriodSec, in TEST()
243 anomalyTracker.addPastBucket(bucket4, 4); in TEST()
244 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 4L); in TEST()
245 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
246 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 2LL); in TEST()
247 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 5LL); in TEST()
250 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 5, bucket5, {keyA, keyB}, {keyC})); in TEST()
251 detectAndDeclareAnomalies(anomalyTracker, 5, bucket5, eventTimestamp5); in TEST()
252 checkRefractoryTimes(anomalyTracker, eventTimestamp5, refractoryPeriodSec, in TEST()
256 anomalyTracker.addPastBucket(bucket5, 5); in TEST()
257 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 5L); in TEST()
258 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
259 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 2LL); in TEST()
260 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 5LL); in TEST()
263 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 6, bucket6, {keyA, keyB}, {keyC})); in TEST()
264 detectAndDeclareAnomalies(anomalyTracker, 6, bucket6, eventTimestamp6); in TEST()
265 checkRefractoryTimes(anomalyTracker, eventTimestamp6, refractoryPeriodSec, in TEST()
277 AnomalyTracker anomalyTracker(alert, kConfigKey); in TEST() local
298 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, -1LL); in TEST()
299 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
300 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 9, bucket9, {}, {keyA, keyB, keyC, keyD})); in TEST()
301 detectAndDeclareAnomalies(anomalyTracker, 9, bucket9, eventTimestamp1); in TEST()
302 checkRefractoryTimes(anomalyTracker, eventTimestamp1, refractoryPeriodSec, in TEST()
306 anomalyTracker.addPastBucket(bucket9, 9); in TEST()
307 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 9L); in TEST()
308 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3UL); in TEST()
309 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 1LL); in TEST()
310 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
311 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
312 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 16, bucket16, {keyB}, {keyA, keyC, keyD})); in TEST()
313 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
314 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 15L); in TEST()
315 detectAndDeclareAnomalies(anomalyTracker, 16, bucket16, eventTimestamp2); in TEST()
316 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
317 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 15L); in TEST()
318 checkRefractoryTimes(anomalyTracker, eventTimestamp2, refractoryPeriodSec, in TEST()
322 anomalyTracker.addPastBucket(bucket16, 16); in TEST()
323 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 16L); in TEST()
324 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 1UL); in TEST()
325 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 4LL); in TEST()
326 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 18, bucket18, {keyB}, {keyA, keyC, keyD})); in TEST()
327 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 1UL); in TEST()
328 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 4LL); in TEST()
330 detectAndDeclareAnomalies(anomalyTracker, 18, bucket18, eventTimestamp3); in TEST()
331 checkRefractoryTimes(anomalyTracker, eventTimestamp3, refractoryPeriodSec, in TEST()
333 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 1UL); in TEST()
334 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 4LL); in TEST()
337 anomalyTracker.addPastBucket(bucket18, 18); in TEST()
338 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 18L); in TEST()
339 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
340 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
341 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
342 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 20, bucket20, {keyB}, {keyA, keyC, keyD})); in TEST()
343 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 19L); in TEST()
344 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
345 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
346 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
347 detectAndDeclareAnomalies(anomalyTracker, 20, bucket20, eventTimestamp4); in TEST()
348 checkRefractoryTimes(anomalyTracker, eventTimestamp4, refractoryPeriodSec, in TEST()
352 anomalyTracker.addPastBucket(bucket18, 18); in TEST()
353 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 19L); in TEST()
354 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
355 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
356 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
357 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 20, bucket20, {keyB}, {keyA, keyC, keyD})); in TEST()
358 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
359 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 1LL); in TEST()
360 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
361 detectAndDeclareAnomalies(anomalyTracker, 20, bucket20, eventTimestamp4 + 1); in TEST()
363 checkRefractoryTimes(anomalyTracker, eventTimestamp4 + 1, refractoryPeriodSec, in TEST()
367 anomalyTracker.addPastBucket(bucket20, 20); in TEST()
368 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 20L); in TEST()
369 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 2UL); in TEST()
370 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 3LL); in TEST()
371 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyC), 1LL); in TEST()
372 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 25, bucket25, {}, {keyA, keyB, keyC, keyD})); in TEST()
373 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 24L); in TEST()
374 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
375 detectAndDeclareAnomalies(anomalyTracker, 25, bucket25, eventTimestamp5); in TEST()
376 checkRefractoryTimes(anomalyTracker, eventTimestamp5, refractoryPeriodSec, in TEST()
380 anomalyTracker.addPastBucket(bucket25, 25); in TEST()
381 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 25L); in TEST()
382 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 1UL); in TEST()
383 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyD), 1LL); in TEST()
384 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 28, bucket28, {}, in TEST()
386 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 27L); in TEST()
387 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
388 detectAndDeclareAnomalies(anomalyTracker, 28, bucket28, eventTimestamp6); in TEST()
389 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
390 checkRefractoryTimes(anomalyTracker, eventTimestamp6, refractoryPeriodSec, in TEST()
395 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 28, bucket28, {keyE}, in TEST()
397 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, 27L); in TEST()
398 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
399 detectAndDeclareAnomalies(anomalyTracker, 28, bucket28, eventTimestamp6 + 7); in TEST()
400 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0UL); in TEST()
401 checkRefractoryTimes(anomalyTracker, eventTimestamp6, refractoryPeriodSec, in TEST()