1 package org.opendaylight.openflowplugin.impl.statistics;
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.group.desc.stats.reply.GroupDescStats;
9 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.grouping.BucketsList;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStatsBuilder;
14 import com.google.common.collect.Lists;
15 import org.junit.Test;
16 import org.opendaylight.openflowplugin.api.OFConstants;
17 import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
18 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
19 import org.opendaylight.openflowplugin.openflow.md.util.OpenflowPortsUtil;
20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.AggregateFlowStatisticsUpdate;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.AggregateFlowStatisticsUpdateBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowsStatisticsUpdate;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowsStatisticsUpdateBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.TransactionAware;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Node;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
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;
52 import javax.sql.rowset.spi.TransactionalWriter;
53 import java.math.BigInteger;
54 import java.util.Collections;
55 import java.util.List;
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;
62 public class SinglePurposeMultipartReplyTranslatorTest {
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 GroupType DUMMY_GROUP_TYPE = GroupType.OFPGTALL;
91 public void testTranslateFlow() {
92 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
94 MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyFlow(), MultipartType.OFPMPFLOW);
96 List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(mockedDeviceContext, multipartReplyMessage);
98 DataObject dataObject = validateOutput(result);
99 assertTrue(dataObject instanceof FlowsStatisticsUpdate);
103 public void testTranslateAggregate() {
104 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
106 MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyAggregate(), MultipartType.OFPMPAGGREGATE);
108 List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(mockedDeviceContext, multipartReplyMessage);
110 DataObject dataObject = validateOutput(result);
111 assertTrue(dataObject instanceof AggregateFlowStatisticsUpdate);
112 AggregateFlowStatisticsUpdate message = (AggregateFlowStatisticsUpdate)dataObject;
113 assertEquals(DUMMY_BYTE_COUNT, message.getByteCount().getValue());
114 assertEquals(DUMMY_PACKET_COUNT, message.getPacketCount().getValue());
115 assertEquals(DUMMY_FLOW_COUNT, message.getFlowCount().getValue());
119 public void testTranslatePortStats() {
120 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
122 MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyPortStats(), MultipartType.OFPMPPORTSTATS);
124 OpenflowPortsUtil.init();
125 List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(mockedDeviceContext, multipartReplyMessage);
127 DataObject dataObject = validateOutput(result);
128 assertTrue(dataObject instanceof NodeConnectorStatisticsUpdate);
129 NodeConnectorStatisticsUpdate nodeConnectorStatisticsUpdate = (NodeConnectorStatisticsUpdate)dataObject;
130 List<NodeConnectorStatisticsAndPortNumberMap> nodeConnectorStatisticsAndPortNumberMaps = nodeConnectorStatisticsUpdate.getNodeConnectorStatisticsAndPortNumberMap();
131 assertEquals(1, nodeConnectorStatisticsAndPortNumberMaps.size());
132 NodeConnectorStatisticsAndPortNumberMap nodeConnectorStatisticsAndPortNumberMap = nodeConnectorStatisticsAndPortNumberMaps.get(0);
133 assertEquals("openflow:"+DUMMY_DATAPATH_ID +":"+ DUMMY_PORT_NO, nodeConnectorStatisticsAndPortNumberMap.getNodeConnectorId().getValue());
134 assertEquals(DUMMY_RX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getReceived());
135 assertEquals(DUMMY_TX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getTransmitted());
136 assertEquals(DUMMY_RX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getReceived());
137 assertEquals(DUMMY_TX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getTransmitted());
138 assertEquals(DUMMY_COLLISIONS, nodeConnectorStatisticsAndPortNumberMap.getCollisionCount());
139 assertEquals(DUMMY_RX_CRC_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveCrcError());
140 assertEquals(DUMMY_RX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getReceiveDrops());
141 assertEquals(DUMMY_RX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getReceiveErrors());
142 assertEquals(DUMMY_RX_FRAME_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveFrameError());
143 assertEquals(DUMMY_OVER_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveOverRunError());
144 assertEquals(DUMMY_TX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getTransmitDrops());
145 assertEquals(DUMMY_TX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getTransmitErrors());
149 public void testTranslateGroup() {
150 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
152 MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyGroup(), MultipartType.OFPMPGROUP);
154 List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(mockedDeviceContext, multipartReplyMessage);
156 DataObject dataObject = validateOutput(result);
157 assertTrue(dataObject instanceof GroupStatisticsUpdated);
158 GroupStatisticsUpdated groupStatisticsUpdate = (GroupStatisticsUpdated)dataObject;
159 List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStats> groupStats = groupStatisticsUpdate.getGroupStats();
160 assertEquals(1, groupStats.size());
161 org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStats groupStat = groupStats.get(0);
163 assertEquals(DUMMY_BYTE_COUNT, groupStat.getByteCount().getValue());
164 assertEquals(DUMMY_DURATION_SEC, groupStat.getDuration().getSecond().getValue());
165 assertEquals(DUMMY_DURATION_NSEC, groupStat.getDuration().getNanosecond().getValue());
166 assertEquals(DUMMY_GROUP_ID.getValue(), groupStat.getGroupId().getValue());
167 assertEquals(DUMMY_PACKET_COUNT, groupStat.getPacketCount().getValue());
168 assertEquals(DUMMY_REF_COUNT, groupStat.getRefCount().getValue());
172 public void testTranslateGroupDesc() {
173 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
175 MultipartReplyMessage multipartReplyMessage = prepareMocks(mockedDeviceContext, prepareMultipartReplyGroupDesc(), MultipartType.OFPMPGROUPDESC);
177 List<DataObject> result = singlePurposeMultipartReplyTranslator.translate(mockedDeviceContext, multipartReplyMessage);
179 DataObject dataObject = validateOutput(result);
180 assertTrue(dataObject instanceof GroupDescStatsUpdated);
181 GroupDescStatsUpdated groupStatistics = (GroupDescStatsUpdated) dataObject;
182 List<GroupDescStats> groupDescStats = groupStatistics.getGroupDescStats();
183 assertEquals(1, groupDescStats.size());
184 GroupDescStats groupDescStat = groupDescStats.get(0);
185 assertEquals(DUMMY_GROUP_ID.getValue(),groupDescStat.getGroupId().getValue());
187 // assertEquals(DUMMY_GROUP_TYPE,groupDescStat.getGroupType() );
193 private MultipartReplyBody prepareMultipartReplyGroupDesc() {
194 MultipartReplyGroupDescCaseBuilder multipartReplyGroupDescCaseBuilder = new MultipartReplyGroupDescCaseBuilder();
195 MultipartReplyGroupDescBuilder multipartReplyGroupDescBuilder = new MultipartReplyGroupDescBuilder();
196 GroupDescBuilder groupDescBuilder = new GroupDescBuilder();
197 groupDescBuilder.setGroupId(DUMMY_GROUP_ID);
198 groupDescBuilder.setBucketsList(Collections.<BucketsList>emptyList());
199 groupDescBuilder.setType(DUMMY_GROUP_TYPE);
200 multipartReplyGroupDescBuilder.setGroupDesc(Lists.newArrayList(groupDescBuilder.build()));
201 multipartReplyGroupDescCaseBuilder.setMultipartReplyGroupDesc(multipartReplyGroupDescBuilder.build());
202 return multipartReplyGroupDescCaseBuilder.build();
205 private MultipartReplyBody prepareMultipartReplyGroup() {
206 MultipartReplyGroupCaseBuilder multipartReplyGroupCaseBuilder = new MultipartReplyGroupCaseBuilder();
207 MultipartReplyGroupBuilder multipartReplyGroupBuilder = new MultipartReplyGroupBuilder();
208 GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();
209 groupStatsBuilder.setByteCount(DUMMY_BYTE_COUNT);
210 groupStatsBuilder.setBucketStats(Collections.<BucketStats>emptyList());
211 groupStatsBuilder.setDurationSec(DUMMY_DURATION_SEC);
212 groupStatsBuilder.setDurationNsec(DUMMY_DURATION_NSEC);
213 groupStatsBuilder.setGroupId(DUMMY_GROUP_ID);
214 groupStatsBuilder.setPacketCount(DUMMY_PACKET_COUNT);
215 groupStatsBuilder.setRefCount(DUMMY_REF_COUNT);
218 multipartReplyGroupBuilder.setGroupStats(Lists.newArrayList(groupStatsBuilder.build()));
219 multipartReplyGroupCaseBuilder.setMultipartReplyGroup(multipartReplyGroupBuilder.build());
220 return multipartReplyGroupCaseBuilder.build();
223 private MultipartReplyBody prepareMultipartReplyPortStats() {
224 MultipartReplyPortStatsCaseBuilder multipartReplyPortStatsCaseBuilder = new MultipartReplyPortStatsCaseBuilder();
225 MultipartReplyPortStatsBuilder multipartReplyPortStatsBuilder = new MultipartReplyPortStatsBuilder();
226 PortStatsBuilder dummyPortStatBuilder = new PortStatsBuilder();
227 dummyPortStatBuilder.setPortNo(DUMMY_PORT_NO);
228 dummyPortStatBuilder.setRxBytes(DUMMY_RX_BYTES);
229 dummyPortStatBuilder.setTxBytes(DUMMY_TX_BYTES);
230 dummyPortStatBuilder.setRxPackets(DUMMY_RX_PACKETS);
231 dummyPortStatBuilder.setTxPackets(DUMMY_TX_PACKETS);
232 dummyPortStatBuilder.setCollisions(DUMMY_COLLISIONS);
233 dummyPortStatBuilder.setRxCrcErr(DUMMY_RX_CRC_ERR);
234 dummyPortStatBuilder.setRxDropped(DUMMY_RX_DROPPED);
235 dummyPortStatBuilder.setRxErrors(DUMMY_RX_ERRORS);
236 dummyPortStatBuilder.setRxFrameErr(DUMMY_RX_FRAME_ERR);
237 dummyPortStatBuilder.setRxOverErr(DUMMY_OVER_ERR);
238 dummyPortStatBuilder.setTxDropped(DUMMY_TX_DROPPED);
239 dummyPortStatBuilder.setTxErrors(DUMMY_TX_ERRORS);
241 multipartReplyPortStatsBuilder.setPortStats(Lists.newArrayList(dummyPortStatBuilder.build()));
242 multipartReplyPortStatsCaseBuilder.setMultipartReplyPortStats(multipartReplyPortStatsBuilder.build());
243 return multipartReplyPortStatsCaseBuilder.build();
247 private MultipartReplyBody prepareMultipartReplyAggregate() {
248 MultipartReplyAggregateCaseBuilder multipartReplyAggregateCaseBuilder = new MultipartReplyAggregateCaseBuilder();
249 MultipartReplyAggregateBuilder multipartReplyAggregateBuilder = new MultipartReplyAggregateBuilder();
250 multipartReplyAggregateBuilder.setByteCount(DUMMY_BYTE_COUNT);
251 multipartReplyAggregateBuilder.setPacketCount(DUMMY_PACKET_COUNT);
252 multipartReplyAggregateBuilder.setFlowCount(DUMMY_FLOW_COUNT);
253 multipartReplyAggregateCaseBuilder.setMultipartReplyAggregate(multipartReplyAggregateBuilder.build());
254 return multipartReplyAggregateCaseBuilder.build();
257 private MultipartReplyBody prepareMultipartReplyFlow() {
258 MultipartReplyFlowCaseBuilder multipartReplyFlowCaseBuilder = new MultipartReplyFlowCaseBuilder();
259 MultipartReplyFlowBuilder multipartReplyFlowBuilder = new MultipartReplyFlowBuilder();
260 multipartReplyFlowBuilder.setFlowStats(Collections.<FlowStats>emptyList());
261 multipartReplyFlowCaseBuilder.setMultipartReplyFlow(multipartReplyFlowBuilder.build());
262 return multipartReplyFlowCaseBuilder.build();
265 private MultipartReplyMessage prepareMocks(DeviceContext mockedDeviceContext, MultipartReplyBody multipartReplyBody, final MultipartType multipartType) {
266 ConnectionContext mockedConnectionContext = mock(ConnectionContext.class);
267 FeaturesReply mockedFeaturesReply = mock(FeaturesReply.class);
268 when(mockedFeaturesReply.getVersion()).thenReturn(OFConstants.OFP_VERSION_1_3);
269 when(mockedFeaturesReply.getDatapathId()).thenReturn(DUMMY_DATAPATH_ID);
271 when(mockedConnectionContext.getFeatures()).thenReturn(mockedFeaturesReply);
272 when(mockedDeviceContext.getPrimaryConnectionContext()).thenReturn(mockedConnectionContext);
274 MultipartReplyMessage multipartReplyMessage = mock(MultipartReplyMessage.class);
275 when(multipartReplyMessage.getType()).thenReturn(multipartType);
276 when(multipartReplyMessage.getFlags()).thenReturn(new MultipartRequestFlags(true));
277 when(multipartReplyMessage.getXid()).thenReturn(DUMMY_XID);
278 when(multipartReplyMessage.getMultipartReplyBody()).thenReturn(multipartReplyBody);
279 return multipartReplyMessage;
283 private DataObject validateOutput(List<DataObject> input) {
284 assertEquals(input.size(), 1);
285 DataObject dataObject = input.get(0);
286 assertTrue(dataObject instanceof Node);
287 assertEquals("openflow:" + DUMMY_DATAPATH_ID, ((Node) dataObject).getId().getValue());
288 assertTrue(dataObject instanceof TransactionAware);
289 assertEquals(new BigInteger(DUMMY_XID.toString()), ((TransactionAware) dataObject).getTransactionId().getValue());