openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/statistics/SinglePurposeMultipartReplyTranslatorTest.java

   1 package org.opendaylight.openflowplugin.impl.statistics;
   2
   3 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.Counter32;
   4 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.Counter64;
   5 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupDescStatsUpdated;
   6 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupStatisticsUpdated;
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupStatisticsUpdatedBuilder;
   8 //import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupType;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupTypes;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.desc.stats.reply.GroupDescStats;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.*;
  12
  13
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.grouping.BucketsList;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStatsBuilder;
  16 import com.google.common.collect.Lists;
  17 import org.junit.Test;
  18 import org.opendaylight.openflowplugin.api.OFConstants;
  19 import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
  20 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
  21 import org.opendaylight.openflowplugin.openflow.md.util.OpenflowPortsUtil;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.AggregateFlowStatisticsUpdate;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.AggregateFlowStatisticsUpdateBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowsStatisticsUpdate;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowsStatisticsUpdateBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.TransactionAware;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Node;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FeaturesReply;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.MultipartReplyBody;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.*;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.aggregate._case.MultipartReplyAggregate;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.aggregate._case.MultipartReplyAggregateBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow._case.MultipartReplyFlowBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow._case.multipart.reply.flow.FlowStats;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.MultipartReplyGroupBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStats;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.group.stats.BucketStats;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc._case.MultipartReplyGroupDesc;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc._case.MultipartReplyGroupDescBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc._case.multipart.reply.group.desc.GroupDesc;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc._case.multipart.reply.group.desc.GroupDescBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.MultipartReplyPortStats;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.MultipartReplyPortStatsBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.multipart.reply.port.stats.PortStatsBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdate;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdateBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMap;
  50 import org.opendaylight.yangtools.yang.binding.DataObject;
  51
  52 import javax.sql.rowset.spi.TransactionalWriter;
  53 import java.math.BigInteger;
  54 import java.util.Collections;
  55 import java.util.List;
  56
  57 import static org.junit.Assert.assertEquals;
  58 import static org.junit.Assert.assertTrue;
  59 import static org.mockito.Mockito.mock;
  60 import static org.mockito.Mockito.when;
  61
  62 public class SinglePurposeMultipartReplyTranslatorTest {
  63
  64     private static final BigInteger DUMMY_DATAPATH_ID = new BigInteger("21");
  65     private static final Long DUMMY_XID = 1L;
  66     private static final SinglePurposeMultipartReplyTranslator singlePurposeMultipartReplyTranslator = new SinglePurposeMultipartReplyTranslator();
  67     private static final BigInteger DUMMY_BYTE_COUNT = new BigInteger("31");
  68     private static final BigInteger DUMMY_PACKET_COUNT = new BigInteger("41");
  69     private static final Long DUMMY_FLOW_COUNT = 51L;
  70     private static final Long DUMMY_PORT_NO = 154L;
  71     private static final BigInteger DUMMY_RX_BYTES = new BigInteger("155");
  72     private static final BigInteger DUMMY_TX_BYTES = new BigInteger("165");
  73     private static final BigInteger DUMMY_RX_PACKETS = new BigInteger("175");
  74     private static final BigInteger DUMMY_TX_PACKETS = new BigInteger("185");
  75     private static final BigInteger DUMMY_COLLISIONS = new BigInteger("195");
  76     private static final BigInteger DUMMY_RX_CRC_ERR = new BigInteger("205");
  77     private static final BigInteger DUMMY_RX_DROPPED = new BigInteger("215");
  78     private static final BigInteger DUMMY_RX_ERRORS = new BigInteger("225");
  79     private static final BigInteger DUMMY_RX_FRAME_ERR = new BigInteger("235");
  80     private static final BigInteger DUMMY_OVER_ERR = new BigInteger("245");
  81     private static final BigInteger DUMMY_TX_DROPPED = new BigInteger("255");
  82     private static final BigInteger DUMMY_TX_ERRORS = new BigInteger("265");
  83     private static final Long DUMMY_DURATION_SEC = 3453L;
  84     private static final Long DUMMY_DURATION_NSEC = 3343L;
  85     private static final GroupId DUMMY_GROUP_ID = new GroupId(55L);
  86     private static final Long DUMMY_REF_COUNT = 1234L;
  87     private static final GroupTypes DUMMY_GROUPS_TYPE = GroupTypes.GroupAll;
  88     private static final GroupType DUMMY_GROUP_TYPE = GroupType.OFPGTALL;
  89     private static final Long GROUP_ACTION_BITMAP = 0b00000000000000000000000000000000000001111111111111001100000000001L;
  90
  91     @Test
  92     public void testTranslateFlow() {
  93         DeviceContext mockedDeviceContext = mock(DeviceContext.class);
  94
  95         MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyFlow(), MultipartType.OFPMPFLOW);
  96
  97         List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(
  98                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId(),
  99                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getVersion(),
 100                 multipartReplyMessage);
 101
 102         DataObject dataObject = validateOutput(result);
 103         assertTrue(dataObject instanceof FlowsStatisticsUpdate);
 104     }
 105
 106     @Test
 107     public void testTranslateAggregate() {
 108         DeviceContext mockedDeviceContext = mock(DeviceContext.class);
 109
 110         MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyAggregate(), MultipartType.OFPMPAGGREGATE);
 111
 112         List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(
 113                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId(),
 114                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getVersion(),
 115                 multipartReplyMessage);
 116
 117         DataObject dataObject = validateOutput(result);
 118         assertTrue(dataObject instanceof AggregateFlowStatisticsUpdate);
 119         AggregateFlowStatisticsUpdate message = (AggregateFlowStatisticsUpdate)dataObject;
 120         assertEquals(DUMMY_BYTE_COUNT, message.getByteCount().getValue());
 121         assertEquals(DUMMY_PACKET_COUNT, message.getPacketCount().getValue());
 122         assertEquals(DUMMY_FLOW_COUNT, message.getFlowCount().getValue());
 123     }
 124
 125     @Test
 126     public void testTranslatePortStats() {
 127         DeviceContext mockedDeviceContext = mock(DeviceContext.class);
 128
 129         MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyPortStats(), MultipartType.OFPMPPORTSTATS);
 130
 131         OpenflowPortsUtil.init();
 132         List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(
 133                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId(),
 134                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getVersion(),
 135                 multipartReplyMessage);
 136
 137         DataObject dataObject = validateOutput(result);
 138         assertTrue(dataObject instanceof NodeConnectorStatisticsUpdate);
 139         NodeConnectorStatisticsUpdate nodeConnectorStatisticsUpdate = (NodeConnectorStatisticsUpdate)dataObject;
 140         List<NodeConnectorStatisticsAndPortNumberMap> nodeConnectorStatisticsAndPortNumberMaps = nodeConnectorStatisticsUpdate.getNodeConnectorStatisticsAndPortNumberMap();
 141         assertEquals(1, nodeConnectorStatisticsAndPortNumberMaps.size());
 142         NodeConnectorStatisticsAndPortNumberMap nodeConnectorStatisticsAndPortNumberMap = nodeConnectorStatisticsAndPortNumberMaps.get(0);
 143         assertEquals("openflow:"+DUMMY_DATAPATH_ID +":"+ DUMMY_PORT_NO, nodeConnectorStatisticsAndPortNumberMap.getNodeConnectorId().getValue());
 144         assertEquals(DUMMY_RX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getReceived());
 145         assertEquals(DUMMY_TX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getTransmitted());
 146         assertEquals(DUMMY_RX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getReceived());
 147         assertEquals(DUMMY_TX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getTransmitted());
 148         assertEquals(DUMMY_COLLISIONS, nodeConnectorStatisticsAndPortNumberMap.getCollisionCount());
 149         assertEquals(DUMMY_RX_CRC_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveCrcError());
 150         assertEquals(DUMMY_RX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getReceiveDrops());
 151         assertEquals(DUMMY_RX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getReceiveErrors());
 152         assertEquals(DUMMY_RX_FRAME_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveFrameError());
 153         assertEquals(DUMMY_OVER_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveOverRunError());
 154         assertEquals(DUMMY_TX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getTransmitDrops());
 155         assertEquals(DUMMY_TX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getTransmitErrors());
 156     }
 157
 158     @Test
 159     public void testTranslateGroup() {
 160         DeviceContext mockedDeviceContext = mock(DeviceContext.class);
 161
 162         MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyGroup(), MultipartType.OFPMPGROUP);
 163
 164         List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(
 165                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId(),
 166                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getVersion(),
 167                 multipartReplyMessage);
 168
 169         DataObject dataObject = validateOutput(result);
 170         assertTrue(dataObject instanceof GroupStatisticsUpdated);
 171         GroupStatisticsUpdated groupStatisticsUpdate = (GroupStatisticsUpdated)dataObject;
 172         List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStats> groupStats = groupStatisticsUpdate.getGroupStats();
 173         assertEquals(1, groupStats.size());
 174         org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStats groupStat = groupStats.get(0);
 175
 176         assertEquals(DUMMY_BYTE_COUNT, groupStat.getByteCount().getValue());
 177         assertEquals(DUMMY_DURATION_SEC, groupStat.getDuration().getSecond().getValue());
 178         assertEquals(DUMMY_DURATION_NSEC, groupStat.getDuration().getNanosecond().getValue());
 179         assertEquals(DUMMY_GROUP_ID.getValue(), groupStat.getGroupId().getValue());
 180         assertEquals(DUMMY_PACKET_COUNT, groupStat.getPacketCount().getValue());
 181         assertEquals(DUMMY_REF_COUNT, groupStat.getRefCount().getValue());
 182     }
 183
 184     @Test
 185     public void testTranslateGroupDesc() {
 186         DeviceContext mockedDeviceContext = mock(DeviceContext.class);
 187
 188         MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyGroupDesc(), MultipartType.OFPMPGROUPDESC);
 189
 190         List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(
 191                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId(),
 192                 mockedDeviceContext.getPrimaryConnectionContext().getFeatures().getVersion(),
 193                 multipartReplyMessage);
 194
 195         DataObject dataObject = validateOutput(result);
 196         assertTrue(dataObject instanceof GroupDescStatsUpdated);
 197         GroupDescStatsUpdated groupStatistics = (GroupDescStatsUpdated) dataObject;
 198         List<GroupDescStats> groupDescStats = groupStatistics.getGroupDescStats();
 199         assertEquals(1, groupDescStats.size());
 200         GroupDescStats groupDescStat = groupDescStats.get(0);
 201         assertEquals(DUMMY_GROUP_ID.getValue(),groupDescStat.getGroupId().getValue());
 202         assertEquals(DUMMY_GROUPS_TYPE,groupDescStat.getGroupType() );
 203     }
 204
 205     @Test
 206     public void getGroupActionsSupportBitmap() {
 207         ActionType actionSupported = new ActionType(true,true, true, true, true, true, true, true, true, true, true, true, true, true, true, true, true);
 208         final List<Long> groupActionsSupportBitmap = SinglePurposeMultipartReplyTranslator.getGroupActionsSupportBitmap(Lists.newArrayList(actionSupported));
 209         assertEquals(1, groupActionsSupportBitmap.size());
 210         final Long bitmap = groupActionsSupportBitmap.get(0);
 211         assertEquals(GROUP_ACTION_BITMAP, bitmap);
 212     }
 213
 214     private MultipartReplyBody prepareMultipartReplyGroupDesc() {
 215         MultipartReplyGroupDescCaseBuilder multipartReplyGroupDescCaseBuilder = new MultipartReplyGroupDescCaseBuilder();
 216         MultipartReplyGroupDescBuilder multipartReplyGroupDescBuilder = new MultipartReplyGroupDescBuilder();
 217         GroupDescBuilder groupDescBuilder = new GroupDescBuilder();
 218         groupDescBuilder.setGroupId(DUMMY_GROUP_ID);
 219         groupDescBuilder.setBucketsList(Collections.<BucketsList>emptyList());
 220         groupDescBuilder.setType(DUMMY_GROUP_TYPE);
 221         multipartReplyGroupDescBuilder.setGroupDesc(Lists.newArrayList(groupDescBuilder.build()));
 222         multipartReplyGroupDescCaseBuilder.setMultipartReplyGroupDesc(multipartReplyGroupDescBuilder.build());
 223         return multipartReplyGroupDescCaseBuilder.build();
 224     }
 225
 226     private MultipartReplyBody prepareMultipartReplyGroup() {
 227         MultipartReplyGroupCaseBuilder multipartReplyGroupCaseBuilder = new MultipartReplyGroupCaseBuilder();
 228         MultipartReplyGroupBuilder multipartReplyGroupBuilder = new MultipartReplyGroupBuilder();
 229         GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();
 230         groupStatsBuilder.setByteCount(DUMMY_BYTE_COUNT);
 231         groupStatsBuilder.setBucketStats(Collections.<BucketStats>emptyList());
 232         groupStatsBuilder.setDurationSec(DUMMY_DURATION_SEC);
 233         groupStatsBuilder.setDurationNsec(DUMMY_DURATION_NSEC);
 234         groupStatsBuilder.setGroupId(DUMMY_GROUP_ID);
 235         groupStatsBuilder.setPacketCount(DUMMY_PACKET_COUNT);
 236         groupStatsBuilder.setRefCount(DUMMY_REF_COUNT);
 237
 238
 239         multipartReplyGroupBuilder.setGroupStats(Lists.newArrayList(groupStatsBuilder.build()));
 240         multipartReplyGroupCaseBuilder.setMultipartReplyGroup(multipartReplyGroupBuilder.build());
 241         return multipartReplyGroupCaseBuilder.build();
 242     }
 243
 244     private MultipartReplyBody prepareMultipartReplyPortStats() {
 245         MultipartReplyPortStatsCaseBuilder multipartReplyPortStatsCaseBuilder = new MultipartReplyPortStatsCaseBuilder();
 246         MultipartReplyPortStatsBuilder multipartReplyPortStatsBuilder = new MultipartReplyPortStatsBuilder();
 247         PortStatsBuilder dummyPortStatBuilder = new PortStatsBuilder();
 248         dummyPortStatBuilder.setPortNo(DUMMY_PORT_NO);
 249         dummyPortStatBuilder.setRxBytes(DUMMY_RX_BYTES);
 250         dummyPortStatBuilder.setTxBytes(DUMMY_TX_BYTES);
 251         dummyPortStatBuilder.setRxPackets(DUMMY_RX_PACKETS);
 252         dummyPortStatBuilder.setTxPackets(DUMMY_TX_PACKETS);
 253         dummyPortStatBuilder.setCollisions(DUMMY_COLLISIONS);
 254         dummyPortStatBuilder.setRxCrcErr(DUMMY_RX_CRC_ERR);
 255         dummyPortStatBuilder.setRxDropped(DUMMY_RX_DROPPED);
 256         dummyPortStatBuilder.setRxErrors(DUMMY_RX_ERRORS);
 257         dummyPortStatBuilder.setRxFrameErr(DUMMY_RX_FRAME_ERR);
 258         dummyPortStatBuilder.setRxOverErr(DUMMY_OVER_ERR);
 259         dummyPortStatBuilder.setTxDropped(DUMMY_TX_DROPPED);
 260         dummyPortStatBuilder.setTxErrors(DUMMY_TX_ERRORS);
 261
 262         multipartReplyPortStatsBuilder.setPortStats(Lists.newArrayList(dummyPortStatBuilder.build()));
 263         multipartReplyPortStatsCaseBuilder.setMultipartReplyPortStats(multipartReplyPortStatsBuilder.build());
 264         return multipartReplyPortStatsCaseBuilder.build();
 265     }
 266
 267
 268     private MultipartReplyBody prepareMultipartReplyAggregate() {
 269         MultipartReplyAggregateCaseBuilder multipartReplyAggregateCaseBuilder = new MultipartReplyAggregateCaseBuilder();
 270         MultipartReplyAggregateBuilder multipartReplyAggregateBuilder = new MultipartReplyAggregateBuilder();
 271         multipartReplyAggregateBuilder.setByteCount(DUMMY_BYTE_COUNT);
 272         multipartReplyAggregateBuilder.setPacketCount(DUMMY_PACKET_COUNT);
 273         multipartReplyAggregateBuilder.setFlowCount(DUMMY_FLOW_COUNT);
 274         multipartReplyAggregateCaseBuilder.setMultipartReplyAggregate(multipartReplyAggregateBuilder.build());
 275         return multipartReplyAggregateCaseBuilder.build();
 276     }
 277
 278     private MultipartReplyBody prepareMultipartReplyFlow() {
 279         MultipartReplyFlowCaseBuilder multipartReplyFlowCaseBuilder = new MultipartReplyFlowCaseBuilder();
 280         MultipartReplyFlowBuilder multipartReplyFlowBuilder = new MultipartReplyFlowBuilder();
 281         multipartReplyFlowBuilder.setFlowStats(Collections.<FlowStats>emptyList());
 282         multipartReplyFlowCaseBuilder.setMultipartReplyFlow(multipartReplyFlowBuilder.build());
 283         return multipartReplyFlowCaseBuilder.build();
 284     }
 285
 286     private MultipartReplyMessage prepareMocks(DeviceContext mockedDeviceContext, MultipartReplyBody multipartReplyBody, final MultipartType multipartType) {
 287         ConnectionContext mockedConnectionContext = mock(ConnectionContext.class);
 288         FeaturesReply mockedFeaturesReply = mock(FeaturesReply.class);
 289         when(mockedFeaturesReply.getVersion()).thenReturn(OFConstants.OFP_VERSION_1_3);
 290         when(mockedFeaturesReply.getDatapathId()).thenReturn(DUMMY_DATAPATH_ID);
 291
 292         when(mockedConnectionContext.getFeatures()).thenReturn(mockedFeaturesReply);
 293         when(mockedDeviceContext.getPrimaryConnectionContext()).thenReturn(mockedConnectionContext);
 294
 295         MultipartReplyMessage multipartReplyMessage = mock(MultipartReplyMessage.class);
 296         when(multipartReplyMessage.getType()).thenReturn(multipartType);
 297         when(multipartReplyMessage.getFlags()).thenReturn(new MultipartRequestFlags(true));
 298         when(multipartReplyMessage.getXid()).thenReturn(DUMMY_XID);
 299         when(multipartReplyMessage.getMultipartReplyBody()).thenReturn(multipartReplyBody);
 300         return multipartReplyMessage;
 301     }
 302
 303
 304     private DataObject validateOutput(List<DataObject> input) {
 305         assertEquals(input.size(), 1);
 306         DataObject dataObject = input.get(0);
 307         assertTrue(dataObject instanceof Node);
 308         assertEquals("openflow:" + DUMMY_DATAPATH_ID, ((Node) dataObject).getId().getValue());
 309         assertTrue(dataObject instanceof TransactionAware);
 310         assertEquals(new BigInteger(DUMMY_XID.toString()), ((TransactionAware) dataObject).getTransactionId().getValue());
 311         return dataObject;
 312     }
 313 }