import java.math.BigInteger;\r
import java.util.ArrayList;\r
import java.util.List;\r
-\r
import org.junit.Assert;\r
import org.junit.Before;\r
import org.junit.Test;\r
import org.mockito.Mock;\r
import org.mockito.MockitoAnnotations;\r
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
+import org.opendaylight.openflowplugin.api.openflow.md.core.ConnectionConductor;\r
import org.opendaylight.openflowplugin.api.openflow.md.core.SwitchConnectionDistinguisher;\r
-import org.opendaylight.openflowplugin.openflow.md.core.ConnectionConductor;\r
-import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;\r
+import org.opendaylight.openflowplugin.api.openflow.md.core.session.SessionContext;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.MeterConfigStatsUpdated;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.MeterStatisticsUpdated;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStats;\r
\r
/**\r
* @author michal.polkorab\r
- *\r
*/\r
public class MultipartReplyTranslatorFifthTest {\r
\r
- @Mock SwitchConnectionDistinguisher cookie;\r
- @Mock SessionContext sc;\r
- @Mock ConnectionConductor conductor;\r
- @Mock GetFeaturesOutput features;\r
+ @Mock\r
+ SwitchConnectionDistinguisher cookie;\r
+ @Mock\r
+ SessionContext sc;\r
+ @Mock\r
+ ConnectionConductor conductor;\r
+ @Mock\r
+ GetFeaturesOutput features;\r
\r
MultipartReplyTranslator translator = new MultipartReplyTranslator();\r
\r
caseBuilder.setMultipartReplyMeter(meterBuilder.build());\r
mpBuilder.setMultipartReplyBody(caseBuilder.build());\r
MultipartReplyMessage message = mpBuilder.build();\r
- \r
+\r
List<DataObject> list = translator.translate(cookie, sc, message);\r
\r
Assert.assertEquals("Wrong list size", 1, list.size());\r
caseBuilder.setMultipartReplyMeter(meterBuilder.build());\r
mpBuilder.setMultipartReplyBody(caseBuilder.build());\r
MultipartReplyMessage message = mpBuilder.build();\r
- \r
+\r
List<DataObject> list = translator.translate(cookie, sc, message);\r
\r
Assert.assertEquals("Wrong list size", 1, list.size());\r
Assert.assertEquals("Wrong transaction-id", 123, statUpdate.getTransactionId().getValue().intValue());\r
Assert.assertEquals("Wrong group stats size", 2, statUpdate.getMeterStats().size());\r
org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply\r
- .MeterStats stat = statUpdate.getMeterStats().get(0);\r
+ .MeterStats stat = statUpdate.getMeterStats().get(0);\r
Assert.assertEquals("Wrong meter-id", 15, stat.getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong flow count", 16, stat.getFlowCount().getValue().intValue());\r
Assert.assertEquals("Wrong packet in count", 17, stat.getPacketInCount().getValue().intValue());\r
caseBuilder.setMultipartReplyMeterConfig(meterBuilder.build());\r
mpBuilder.setMultipartReplyBody(caseBuilder.build());\r
MultipartReplyMessage message = mpBuilder.build();\r
- \r
+\r
List<DataObject> list = translator.translate(cookie, sc, message);\r
\r
Assert.assertEquals("Wrong list size", 1, list.size());\r
caseBuilder.setMultipartReplyMeterConfig(meterBuilder.build());\r
mpBuilder.setMultipartReplyBody(caseBuilder.build());\r
MultipartReplyMessage message = mpBuilder.build();\r
- \r
+\r
List<DataObject> list = translator.translate(cookie, sc, message);\r
\r
Assert.assertEquals("Wrong list size", 1, list.size());\r
Assert.assertEquals("Wrong transaction-id", 123, statUpdate.getTransactionId().getValue().intValue());\r
Assert.assertEquals("Wrong meter config stats size", 2, statUpdate.getMeterConfigStats().size());\r
MeterConfigStats stat = statUpdate.getMeterConfigStats().get(0);\r
- // TODO: fix implementation - add flags creation\r
-// Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterBurst());\r
-// Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterPktps());\r
-// Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterKbps());\r
-// Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterStats());\r
+ Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterBurst());\r
+ Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterPktps());\r
+ Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterKbps());\r
+ Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterStats());\r
Assert.assertEquals("Wrong meter-id", 20, stat.getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong bands size", 2, stat.getMeterBandHeaders().getMeterBandHeader().size());\r
MeterBandHeader header = stat.getMeterBandHeaders().getMeterBandHeader().get(0);\r
Assert.assertEquals("Wrong flag", true, header.getMeterBandTypes().getFlags().isOfpmbtDscpRemark());\r
Assert.assertEquals("Wrong flag", false, header.getMeterBandTypes().getFlags().isOfpmbtExperimenter());\r
stat = statUpdate.getMeterConfigStats().get(1);\r
- // TODO: fix implementation - add flags creation\r
-// Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterBurst());\r
-// Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterPktps());\r
-// Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterKbps());\r
-// Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterStats());\r
+ Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterBurst());\r
+ Assert.assertEquals("Wrong flag", true, stat.getFlags().isMeterPktps());\r
+ Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterKbps());\r
+ Assert.assertEquals("Wrong flag", false, stat.getFlags().isMeterStats());\r
Assert.assertEquals("Wrong meter-id", 26, stat.getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong bands size", 0, stat.getMeterBandHeaders().getMeterBandHeader().size());\r
}\r