gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *     http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  *
  21  */
  22 package org.onap.ccsdk.features.sdnr.wt.websocketmanager2.test;
  23
  24 import java.time.Duration;
  25 import java.time.Instant;
  26 import org.junit.Test;
  27 import org.onap.ccsdk.features.sdnr.wt.websocketmanager.utils.RateFilter;
  28 import org.slf4j.Logger;
  29 import org.slf4j.LoggerFactory;
  30
  31 /**
  32  * {@link #RateFilter} Problems of to many notifications during mount of thousand of devices.
  33  *
  34  * <pre>
  35  *  Testcase (e: 17 Event received, rateMaxCount=3)
  36  *         eee                           e  e e e e e  e  e e e e    e         e                e
  37  *  ---//--|--------------|-----//-------|--------------|--------------|--------------|---//----|--------------|
  38  *         P1:1           P2:1           P1:2           P2:2           P3:2          P4:2       P1:3
  39  *         1000-1002      2000           3500 10 millis
  40  *Overload              no             no            yes            yes             no              no
  41  * </pre>
  42  *
  43  */
  44 public class RateFilterTest {
  45
  46     private static final Logger LOG = LoggerFactory.getLogger(RateFilterTest.class.getName());
  47
  48     private static int MILLIS = 1000;
  49     private static long[] now = { 1000, 1001, 1002, //P1:1 0-2
  50             3500, 3550, 3560, 3570, 3580, 3590, 3800, //P1:2 3500 3-9
  51             4510, 4520, 4530, 4540, 4900, //P2:2 4500 10-14
  52             5700, //P3:2 5500 15
  53             7000, 8000};//P1:3 16-17
  54     private static int idx;
  55
  56     @Test
  57     public void test() {
  58         RateFilter rateFilter = new RateFilter(Duration.ofMillis(MILLIS), 4, () -> getNow());
  59         LOG.info("Init done");
  60
  61         for (int t=0; t < 20; t++) {
  62             LOG.info("{}", t);
  63             rateFilter.filterEvent();
  64             LOG.info("{}", rateFilter.getOverloadStatus());
  65         }
  66
  67     }
  68
  69     Instant getNow() {
  70         long res;
  71         if (idx < now.length) {
  72             res = now[idx];
  73         } else {
  74             int lastIdx = now.length - 1;
  75             res = now[lastIdx] + (idx - lastIdx) * MILLIS;
  76         }
  77         idx++;
  78         return Instant.ofEpochMilli(res);
  79     }
  80
  81 }