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.util.Collections;
17 import java.util.List;
18 import org.junit.Before;
19 import org.junit.Test;
20 import org.opendaylight.openflowplugin.api.OFConstants;
21 import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
22 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
23 import org.opendaylight.openflowplugin.api.openflow.device.DeviceInfo;
24 import org.opendaylight.openflowplugin.impl.common.MultipartReplyTranslatorUtil;
25 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorManager;
26 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorManagerFactory;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowAndStatisticsMapList;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupDescStatsReply;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupStatisticsReply;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupTypes;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.desc.stats.reply.GroupDescStats;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.AggregateFlowStatistics;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FeaturesReply;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.MultipartReplyBody;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateCaseBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowCaseBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupCaseBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupDescCaseBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsCaseBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.aggregate._case.MultipartReplyAggregateBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow._case.MultipartReplyFlowBuilder;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.MultipartReplyGroupBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStatsBuilder;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc._case.MultipartReplyGroupDescBuilder;
50 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;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.MultipartReplyPortStatsBuilder;
52 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;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMap;
54 import org.opendaylight.yangtools.yang.binding.DataContainer;
55 import org.opendaylight.yangtools.yang.common.Uint32;
56 import org.opendaylight.yangtools.yang.common.Uint64;
57 import org.opendaylight.yangtools.yang.common.Uint8;
59 public class MultipartReplyTranslatorTest {
61 private static final Uint64 DUMMY_DATAPATH_ID = Uint64.valueOf(21);
62 private static final Uint32 DUMMY_XID = Uint32.ONE;
63 private static final Uint64 DUMMY_BYTE_COUNT = Uint64.valueOf(31);
64 private static final Uint64 DUMMY_PACKET_COUNT = Uint64.valueOf(41);
65 private static final Uint32 DUMMY_FLOW_COUNT = Uint32.valueOf(51);
66 private static final Long DUMMY_PORT_NO = 154L;
67 private static final Uint64 DUMMY_RX_BYTES = Uint64.valueOf(155);
68 private static final Uint64 DUMMY_TX_BYTES = Uint64.valueOf(165);
69 private static final Uint64 DUMMY_RX_PACKETS = Uint64.valueOf(175);
70 private static final Uint64 DUMMY_TX_PACKETS = Uint64.valueOf(185);
71 private static final Uint64 DUMMY_COLLISIONS = Uint64.valueOf(195);
72 private static final Uint64 DUMMY_RX_CRC_ERR = Uint64.valueOf(205);
73 private static final Uint64 DUMMY_RX_DROPPED = Uint64.valueOf(215);
74 private static final Uint64 DUMMY_RX_ERRORS = Uint64.valueOf(225);
75 private static final Uint64 DUMMY_RX_FRAME_ERR = Uint64.valueOf(235);
76 private static final Uint64 DUMMY_OVER_ERR = Uint64.valueOf(245);
77 private static final Uint64 DUMMY_TX_DROPPED = Uint64.valueOf(255);
78 private static final Uint64 DUMMY_TX_ERRORS = Uint64.valueOf(265);
79 private static final Uint32 DUMMY_DURATION_SEC = Uint32.valueOf(3453);
80 private static final Uint32 DUMMY_DURATION_NSEC = Uint32.valueOf(3343);
81 private static final GroupId DUMMY_GROUP_ID = new GroupId(55L);
82 private static final Uint32 DUMMY_REF_COUNT = Uint32.valueOf(1234);
83 private static final GroupTypes DUMMY_GROUPS_TYPE = GroupTypes.GroupAll;
84 private static final GroupType DUMMY_GROUP_TYPE = GroupType.OFPGTALL;
85 private static final ConvertorManager CONVERTOR_MANAGER = ConvertorManagerFactory.createDefaultManager();
92 public void testTranslateFlow() {
93 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
95 MultipartReplyMessage multipartReplyMessage =
96 prepareMocks(mockedDeviceContext, prepareMultipartReplyFlow(), MultipartType.OFPMPFLOW);
98 DataContainer result = MultipartReplyTranslatorUtil.translate(
99 multipartReplyMessage,
100 mockedDeviceContext.getDeviceInfo(),
102 mockedDeviceContext.oook()).get();
104 DataContainer dataObject = validateOutput(result);
105 assertTrue(dataObject instanceof FlowAndStatisticsMapList);
109 public void testTranslateAggregate() {
110 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
112 MultipartReplyMessage multipartReplyMessage =
113 prepareMocks(mockedDeviceContext, prepareMultipartReplyAggregate(), MultipartType.OFPMPAGGREGATE);
115 DataContainer result = MultipartReplyTranslatorUtil.translate(
116 multipartReplyMessage,
117 mockedDeviceContext.getDeviceInfo(),
119 mockedDeviceContext.oook()).get();
121 DataContainer dataObject = validateOutput(result);
122 assertTrue(dataObject instanceof AggregateFlowStatistics);
123 AggregateFlowStatistics message = (AggregateFlowStatistics)dataObject;
124 assertEquals(DUMMY_BYTE_COUNT, message.getByteCount().getValue());
125 assertEquals(DUMMY_PACKET_COUNT, message.getPacketCount().getValue());
126 assertEquals(DUMMY_FLOW_COUNT, message.getFlowCount().getValue());
130 public void testTranslatePortStats() {
131 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
133 MultipartReplyMessage multipartReplyMessage =
134 prepareMocks(mockedDeviceContext, prepareMultipartReplyPortStats(), MultipartType.OFPMPPORTSTATS);
136 DataContainer result = MultipartReplyTranslatorUtil.translate(
137 multipartReplyMessage,
138 mockedDeviceContext.getDeviceInfo(),
140 mockedDeviceContext.oook()).get();
142 DataContainer dataObject = validateOutput(result);
143 assertTrue(dataObject instanceof org.opendaylight.yang.gen.v1.urn
144 .opendaylight.port.statistics.rev131214.NodeConnectorStatisticsAndPortNumberMap);
145 org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsAndPortNumberMap
146 nodeConnectorStatisticsUpdate = (org.opendaylight.yang.gen.v1.urn
147 .opendaylight.port.statistics.rev131214.NodeConnectorStatisticsAndPortNumberMap) dataObject;
148 List<NodeConnectorStatisticsAndPortNumberMap> nodeConnectorStatisticsAndPortNumberMaps =
149 nodeConnectorStatisticsUpdate.getNodeConnectorStatisticsAndPortNumberMap();
150 assertEquals(1, nodeConnectorStatisticsAndPortNumberMaps.size());
151 NodeConnectorStatisticsAndPortNumberMap nodeConnectorStatisticsAndPortNumberMap =
152 nodeConnectorStatisticsAndPortNumberMaps.get(0);
153 assertEquals("openflow:" + DUMMY_DATAPATH_ID + ":" + DUMMY_PORT_NO,
154 nodeConnectorStatisticsAndPortNumberMap.getNodeConnectorId().getValue());
155 assertEquals(DUMMY_RX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getReceived());
156 assertEquals(DUMMY_TX_BYTES, nodeConnectorStatisticsAndPortNumberMap.getBytes().getTransmitted());
157 assertEquals(DUMMY_RX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getReceived());
158 assertEquals(DUMMY_TX_PACKETS, nodeConnectorStatisticsAndPortNumberMap.getPackets().getTransmitted());
159 assertEquals(DUMMY_COLLISIONS, nodeConnectorStatisticsAndPortNumberMap.getCollisionCount());
160 assertEquals(DUMMY_RX_CRC_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveCrcError());
161 assertEquals(DUMMY_RX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getReceiveDrops());
162 assertEquals(DUMMY_RX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getReceiveErrors());
163 assertEquals(DUMMY_RX_FRAME_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveFrameError());
164 assertEquals(DUMMY_OVER_ERR, nodeConnectorStatisticsAndPortNumberMap.getReceiveOverRunError());
165 assertEquals(DUMMY_TX_DROPPED, nodeConnectorStatisticsAndPortNumberMap.getTransmitDrops());
166 assertEquals(DUMMY_TX_ERRORS, nodeConnectorStatisticsAndPortNumberMap.getTransmitErrors());
170 public void testTranslateGroup() {
171 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
173 MultipartReplyMessage multipartReplyMessage =
174 prepareMocks(mockedDeviceContext, prepareMultipartReplyGroup(), MultipartType.OFPMPGROUP);
176 DataContainer result = MultipartReplyTranslatorUtil.translate(
177 multipartReplyMessage,
178 mockedDeviceContext.getDeviceInfo(),
180 mockedDeviceContext.oook()).get();
182 DataContainer dataObject = validateOutput(result);
183 assertTrue(dataObject instanceof GroupStatisticsReply);
184 GroupStatisticsReply groupStatisticsUpdate = (GroupStatisticsReply)dataObject;
185 List<org.opendaylight.yang.gen.v1.urn
186 .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats> groupStats =
187 groupStatisticsUpdate.getGroupStats();
188 assertEquals(1, groupStats.size());
189 org.opendaylight.yang.gen.v1.urn
190 .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats groupStat = groupStats.get(0);
192 assertEquals(DUMMY_BYTE_COUNT, groupStat.getByteCount().getValue());
193 assertEquals(DUMMY_DURATION_SEC, groupStat.getDuration().getSecond().getValue());
194 assertEquals(DUMMY_DURATION_NSEC, groupStat.getDuration().getNanosecond().getValue());
195 assertEquals(DUMMY_GROUP_ID.getValue(), groupStat.getGroupId().getValue());
196 assertEquals(DUMMY_PACKET_COUNT, groupStat.getPacketCount().getValue());
197 assertEquals(DUMMY_REF_COUNT, groupStat.getRefCount().getValue());
201 public void testTranslateGroupDesc() {
202 DeviceContext mockedDeviceContext = mock(DeviceContext.class);
204 MultipartReplyMessage multipartReplyMessage =
205 prepareMocks(mockedDeviceContext, prepareMultipartReplyGroupDesc(), MultipartType.OFPMPGROUPDESC);
207 DataContainer result = MultipartReplyTranslatorUtil.translate(
208 multipartReplyMessage,
209 mockedDeviceContext.getDeviceInfo(),
211 mockedDeviceContext.oook()).get();
213 DataContainer dataObject = validateOutput(result);
214 assertTrue(dataObject instanceof GroupDescStatsReply);
215 GroupDescStatsReply groupStatistics = (GroupDescStatsReply) dataObject;
216 List<GroupDescStats> groupDescStats = groupStatistics.getGroupDescStats();
217 assertEquals(1, groupDescStats.size());
218 GroupDescStats groupDescStat = groupDescStats.get(0);
219 assertEquals(DUMMY_GROUP_ID.getValue(),groupDescStat.getGroupId().getValue());
220 assertEquals(DUMMY_GROUPS_TYPE,groupDescStat.getGroupType());
223 private MultipartReplyBody prepareMultipartReplyGroupDesc() {
224 GroupDescBuilder groupDescBuilder = new GroupDescBuilder();
225 groupDescBuilder.setGroupId(DUMMY_GROUP_ID);
226 groupDescBuilder.setBucketsList(Collections.emptyList());
227 groupDescBuilder.setType(DUMMY_GROUP_TYPE);
228 MultipartReplyGroupDescBuilder multipartReplyGroupDescBuilder = new MultipartReplyGroupDescBuilder();
229 multipartReplyGroupDescBuilder.setGroupDesc(Lists.newArrayList(groupDescBuilder.build()));
230 MultipartReplyGroupDescCaseBuilder multipartReplyGroupDescCaseBuilder =
231 new MultipartReplyGroupDescCaseBuilder();
232 multipartReplyGroupDescCaseBuilder.setMultipartReplyGroupDesc(multipartReplyGroupDescBuilder.build());
233 return multipartReplyGroupDescCaseBuilder.build();
236 private MultipartReplyBody prepareMultipartReplyGroup() {
237 GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();
238 groupStatsBuilder.setByteCount(DUMMY_BYTE_COUNT);
239 groupStatsBuilder.setBucketStats(Collections.emptyList());
240 groupStatsBuilder.setDurationSec(DUMMY_DURATION_SEC);
241 groupStatsBuilder.setDurationNsec(DUMMY_DURATION_NSEC);
242 groupStatsBuilder.setGroupId(DUMMY_GROUP_ID);
243 groupStatsBuilder.setPacketCount(DUMMY_PACKET_COUNT);
244 groupStatsBuilder.setRefCount(DUMMY_REF_COUNT);
245 MultipartReplyGroupBuilder multipartReplyGroupBuilder = new MultipartReplyGroupBuilder();
246 multipartReplyGroupBuilder.setGroupStats(Lists.newArrayList(groupStatsBuilder.build()));
247 MultipartReplyGroupCaseBuilder multipartReplyGroupCaseBuilder = new MultipartReplyGroupCaseBuilder();
248 multipartReplyGroupCaseBuilder.setMultipartReplyGroup(multipartReplyGroupBuilder.build());
249 return multipartReplyGroupCaseBuilder.build();
252 private MultipartReplyBody prepareMultipartReplyPortStats() {
253 PortStatsBuilder dummyPortStatBuilder = new PortStatsBuilder();
254 dummyPortStatBuilder.setPortNo(DUMMY_PORT_NO);
255 dummyPortStatBuilder.setRxBytes(DUMMY_RX_BYTES);
256 dummyPortStatBuilder.setTxBytes(DUMMY_TX_BYTES);
257 dummyPortStatBuilder.setRxPackets(DUMMY_RX_PACKETS);
258 dummyPortStatBuilder.setTxPackets(DUMMY_TX_PACKETS);
259 dummyPortStatBuilder.setCollisions(DUMMY_COLLISIONS);
260 dummyPortStatBuilder.setRxCrcErr(DUMMY_RX_CRC_ERR);
261 dummyPortStatBuilder.setRxDropped(DUMMY_RX_DROPPED);
262 dummyPortStatBuilder.setRxErrors(DUMMY_RX_ERRORS);
263 dummyPortStatBuilder.setRxFrameErr(DUMMY_RX_FRAME_ERR);
264 dummyPortStatBuilder.setRxOverErr(DUMMY_OVER_ERR);
265 dummyPortStatBuilder.setTxDropped(DUMMY_TX_DROPPED);
266 dummyPortStatBuilder.setTxErrors(DUMMY_TX_ERRORS);
267 MultipartReplyPortStatsBuilder multipartReplyPortStatsBuilder = new MultipartReplyPortStatsBuilder();
268 multipartReplyPortStatsBuilder.setPortStats(Lists.newArrayList(dummyPortStatBuilder.build()));
269 MultipartReplyPortStatsCaseBuilder multipartReplyPortStatsCaseBuilder =
270 new MultipartReplyPortStatsCaseBuilder();
271 multipartReplyPortStatsCaseBuilder.setMultipartReplyPortStats(multipartReplyPortStatsBuilder.build());
272 return multipartReplyPortStatsCaseBuilder.build();
276 private MultipartReplyBody prepareMultipartReplyAggregate() {
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 multipartReplyAggregateCaseBuilder =
282 new MultipartReplyAggregateCaseBuilder();
283 multipartReplyAggregateCaseBuilder.setMultipartReplyAggregate(multipartReplyAggregateBuilder.build());
284 return multipartReplyAggregateCaseBuilder.build();
287 private MultipartReplyBody prepareMultipartReplyFlow() {
288 MultipartReplyFlowCaseBuilder multipartReplyFlowCaseBuilder = new MultipartReplyFlowCaseBuilder();
289 MultipartReplyFlowBuilder multipartReplyFlowBuilder = new MultipartReplyFlowBuilder();
290 multipartReplyFlowBuilder.setFlowStats(Collections.emptyList());
291 multipartReplyFlowCaseBuilder.setMultipartReplyFlow(multipartReplyFlowBuilder.build());
292 return multipartReplyFlowCaseBuilder.build();
295 private MultipartReplyMessage prepareMocks(final DeviceContext mockedDeviceContext,
296 final MultipartReplyBody multipartReplyBody,
297 final MultipartType multipartType) {
298 ConnectionContext mockedConnectionContext = mock(ConnectionContext.class);
299 FeaturesReply mockedFeaturesReply = mock(FeaturesReply.class);
300 when(mockedFeaturesReply.getVersion()).thenReturn(Uint8.valueOf(OFConstants.OFP_VERSION_1_3));
301 when(mockedFeaturesReply.getDatapathId()).thenReturn(DUMMY_DATAPATH_ID);
303 DeviceInfo deviceInfo = mock(DeviceInfo.class);
304 when(deviceInfo.getVersion()).thenReturn(OFConstants.OFP_VERSION_1_3);
305 when(deviceInfo.getDatapathId()).thenReturn(DUMMY_DATAPATH_ID);
306 when(mockedDeviceContext.getDeviceInfo()).thenReturn(deviceInfo);
308 when(mockedConnectionContext.getFeatures()).thenReturn(mockedFeaturesReply);
309 when(mockedDeviceContext.getPrimaryConnectionContext()).thenReturn(mockedConnectionContext);
311 MultipartReplyMessage multipartReplyMessage = mock(MultipartReplyMessage.class);
312 when(multipartReplyMessage.getType()).thenReturn(multipartType);
313 when(multipartReplyMessage.getFlags()).thenReturn(new MultipartRequestFlags(true));
314 when(multipartReplyMessage.getXid()).thenReturn(DUMMY_XID);
315 when(multipartReplyMessage.getMultipartReplyBody()).thenReturn(multipartReplyBody);
316 return multipartReplyMessage;
319 private DataContainer validateOutput(final DataContainer dataObject) {