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