openflowplugin/src/test/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/MeterStatsResponseConvertorTest.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.openflowplugin.openflow.md.core.sal.convertor;
  10
  11 import static org.junit.Assert.assertEquals;
  12 import static org.junit.Assert.assertFalse;
  13 import static org.junit.Assert.assertTrue;
  14 import java.math.BigInteger;
  15 import java.util.ArrayList;
  16 import java.util.List;
  17 import org.junit.Test;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStats;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.meter.band.stats.BandStat;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply.MeterStats;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply.MeterStatsKey;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterId;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStatsBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.meter.stats.MeterBandStats;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.meter.stats.MeterBandStatsBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.MeterConfig;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.MeterConfigBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.meter.config.Bands;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.meter.config.BandsBuilder;
  31 import org.opendaylight.yangtools.yang.binding.DataContainer;
  32
  33 /**
  34  * Created by Martin Bobak mbobak@cisco.com on 9/18/14.
  35  */
  36 public class MeterStatsResponseConvertorTest {
  37
  38     private static final MeterStatsResponseConvertor METER_STATS_RESPONSE_CONVERTOR = new MeterStatsResponseConvertor();
  39     private static final int PRESET_COUNT = 7;
  40
  41
  42     private static List<org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply
  43             .multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStats> createMeterStatsLit() {
  44
  45         List<org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply
  46                 .multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStats> allMeterStats = new ArrayList<>();
  47         MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();
  48         for (int i = 0; i < PRESET_COUNT; i++) {
  49             meterStatsBuilder.setByteInCount(BigInteger.valueOf(i));
  50             meterStatsBuilder.setDurationNsec((long) 1000 * i);
  51             meterStatsBuilder.setDurationSec((long) 10 * i);
  52             meterStatsBuilder.setFlowCount((long) i);
  53             MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();
  54             List<MeterBandStats> meterBandStatses = new ArrayList<>();
  55             for (int j = 0; j < PRESET_COUNT; j++) {
  56                 meterBandStatsBuilder.setByteBandCount(BigInteger.valueOf(j));
  57                 meterBandStatsBuilder.setPacketBandCount(BigInteger.valueOf(j));
  58                 meterBandStatses.add(meterBandStatsBuilder.build());
  59             }
  60             meterStatsBuilder.setMeterBandStats(meterBandStatses);
  61             meterStatsBuilder.setMeterId(new MeterId((long) i));
  62             meterStatsBuilder.setPacketInCount(BigInteger.valueOf(i));
  63
  64             allMeterStats.add(meterStatsBuilder.build());
  65         }
  66
  67         return allMeterStats;
  68     }
  69
  70     private final List<MeterConfig> createMeterConfigList(){
  71         List<MeterConfig> meterConfigs = new ArrayList<>();
  72         MeterConfigBuilder meterConfigBuilder = new MeterConfigBuilder();
  73         for (int i = 0; i < PRESET_COUNT; i++) {
  74             meterConfigBuilder.setMeterId(new MeterId((long) i));
  75             List<Bands> bandses = new ArrayList<>();
  76             for (int j = 0; j < PRESET_COUNT; j++){
  77                 BandsBuilder bandsBuilder = new BandsBuilder();
  78                 bandsBuilder.setMeterBand(new MockMeterBandBuilder());
  79                 bandses.add(bandsBuilder.build());
  80             }
  81             meterConfigBuilder.setBands(bandses);
  82             meterConfigBuilder.setFlags(new MeterFlags(true, false, true, false));
  83             meterConfigs.add(meterConfigBuilder.build());
  84         }
  85         return meterConfigs;
  86     }
  87     @Test
  88     /**
  89      * Test of basic mapping functionality of {@link MeterStatsResponseConvertor#toSALMeterStatsList(java.util.List)}
  90      */
  91     public void testToSALMeterStatsList() {
  92
  93         List<MeterStats> meterStatsList = METER_STATS_RESPONSE_CONVERTOR.toSALMeterStatsList(createMeterStatsLit());
  94         assertEquals(PRESET_COUNT, meterStatsList.size());
  95
  96         int cnt = 0;
  97         for (MeterStats meterStats : meterStatsList) {
  98             assertEquals((new MeterStatsKey(new org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterId((long) cnt))).getMeterId(), meterStats.getKey().getMeterId());
  99             assertEquals((BigInteger.valueOf(cnt)), meterStats.getByteInCount().getValue());
 100             assertEquals(new Long(1000 * cnt), meterStats.getDuration().getNanosecond().getValue());
 101             assertEquals(new Long(10 * cnt), meterStats.getDuration().getSecond().getValue());
 102
 103             assertEquals(new Long(cnt), meterStats.getFlowCount().getValue());
 104             assertEquals(BigInteger.valueOf(cnt), meterStats.getByteInCount().getValue());
 105
 106             assertEquals(PRESET_COUNT, meterStats.getMeterBandStats().getBandStat().size());
 107             int bandStatCount = 0;
 108             for (BandStat bandStat : meterStats.getMeterBandStats().getBandStat()) {
 109                 assertEquals(BigInteger.valueOf(bandStatCount), bandStat.getByteBandCount().getValue());
 110                 assertEquals(BigInteger.valueOf(bandStatCount), bandStat.getPacketBandCount().getValue());
 111                 bandStatCount++;
 112             }
 113             assertEquals((new MeterStatsKey(new org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterId((long) cnt))).getMeterId(), meterStats.getMeterId());
 114             assertEquals(BigInteger.valueOf(cnt), meterStats.getPacketInCount().getValue());
 115             cnt++;
 116         }
 117     }
 118
 119     @Test
 120     /**
 121      * Test of basic mapping functionality of {@link MeterStatsResponseConvertor#toSALMeterStatsList(java.util.List)}
 122      */
 123     public void testToSALMeterConfigList() {
 124         List<MeterConfigStats> meterConfigs = METER_STATS_RESPONSE_CONVERTOR.toSALMeterConfigList(createMeterConfigList());
 125         assertEquals(PRESET_COUNT, meterConfigs.size());
 126         int cnt = 0;
 127         for (MeterConfigStats meterConfigStats: meterConfigs){
 128             assertEquals(new Long(cnt), meterConfigStats.getMeterId().getValue());
 129             assertTrue(meterConfigStats.getFlags().isMeterBurst());
 130             assertFalse(meterConfigStats.getFlags().isMeterKbps());
 131             assertTrue(meterConfigStats.getFlags().isMeterPktps());
 132             assertFalse(meterConfigStats.getFlags().isMeterStats());
 133
 134             cnt++;
 135         }
 136     }
 137
 138
 139     private final class MockMeterBandBuilder implements org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.MeterBand {
 140
 141         @Override
 142         public Class<? extends DataContainer> getImplementedInterface() {
 143             return MockMeterBandBuilder.class;
 144         }
 145     }
 146
 147 }