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
9 package org.opendaylight.openflowplugin.impl.statistics.services.compatibility;
11 import com.google.common.annotations.VisibleForTesting;
12 import java.util.ArrayList;
13 import java.util.List;
14 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
15 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
16 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.Counter32;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.TransactionId;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.duration.DurationBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.node.connector.statistics.BytesBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.node.connector.statistics.PacketsBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReply;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsCase;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.MultipartReplyPortStats;
25 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.PortStats;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdate;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdateBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMap;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMapBuilder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMapKey;
33 * pulled out port stats to notification transformation
35 public class NodeConnectorStatisticsToNotificationTransformer {
38 * @param mpReplyList raw multipart response from device
39 * @param deviceContext device context
40 * @param ofVersion device version
42 * @return notification containing flow stats
44 public static NodeConnectorStatisticsUpdate transformToNotification(final List<MultipartReply> mpReplyList,
45 final DeviceContext deviceContext,
46 final OpenflowVersion ofVersion,
47 final TransactionId emulatedTxId) {
49 NodeConnectorStatisticsUpdateBuilder notification = new NodeConnectorStatisticsUpdateBuilder();
50 notification.setId(deviceContext.getDeviceState().getNodeId());
51 notification.setMoreReplies(Boolean.FALSE);
52 notification.setTransactionId(emulatedTxId);
54 notification.setNodeConnectorStatisticsAndPortNumberMap(new ArrayList<NodeConnectorStatisticsAndPortNumberMap>());
55 for (MultipartReply mpReply : mpReplyList) {
56 MultipartReplyPortStatsCase caseBody = (MultipartReplyPortStatsCase) mpReply.getMultipartReplyBody();
58 MultipartReplyPortStats replyBody = caseBody.getMultipartReplyPortStats();
59 for (PortStats portStats : replyBody.getPortStats()) {
60 NodeConnectorStatisticsAndPortNumberMapBuilder statsBuilder =
61 processSingleNodeConnectorStats(deviceContext, ofVersion, portStats);
62 notification.getNodeConnectorStatisticsAndPortNumberMap().add(statsBuilder.build());
65 return notification.build();
69 static NodeConnectorStatisticsAndPortNumberMapBuilder processSingleNodeConnectorStats(DeviceContext deviceContext, OpenflowVersion ofVersion, PortStats portStats) {
70 NodeConnectorStatisticsAndPortNumberMapBuilder statsBuilder =
71 new NodeConnectorStatisticsAndPortNumberMapBuilder();
72 statsBuilder.setNodeConnectorId(
73 InventoryDataServiceUtil.nodeConnectorIdfromDatapathPortNo(
74 deviceContext.getDeviceState().getFeatures().getDatapathId(),
75 portStats.getPortNo(), ofVersion));
77 BytesBuilder bytesBuilder = new BytesBuilder();
78 bytesBuilder.setReceived(portStats.getRxBytes());
79 bytesBuilder.setTransmitted(portStats.getTxBytes());
80 statsBuilder.setBytes(bytesBuilder.build());
82 PacketsBuilder packetsBuilder = new PacketsBuilder();
83 packetsBuilder.setReceived(portStats.getRxPackets());
84 packetsBuilder.setTransmitted(portStats.getTxPackets());
85 statsBuilder.setPackets(packetsBuilder.build());
87 DurationBuilder durationBuilder = new DurationBuilder();
88 if (portStats.getDurationSec() != null) {
89 durationBuilder.setSecond(new Counter32(portStats.getDurationSec()));
91 if (portStats.getDurationNsec() != null) {
92 durationBuilder.setNanosecond(new Counter32(portStats.getDurationNsec()));
94 statsBuilder.setDuration(durationBuilder.build());
95 statsBuilder.setCollisionCount(portStats.getCollisions());
96 statsBuilder.setKey(new NodeConnectorStatisticsAndPortNumberMapKey(statsBuilder.getNodeConnectorId()));
97 statsBuilder.setReceiveCrcError(portStats.getRxCrcErr());
98 statsBuilder.setReceiveDrops(portStats.getRxDropped());
99 statsBuilder.setReceiveErrors(portStats.getRxErrors());
100 statsBuilder.setReceiveFrameError(portStats.getRxFrameErr());
101 statsBuilder.setReceiveOverRunError(portStats.getRxOverErr());
102 statsBuilder.setTransmitDrops(portStats.getTxDropped());
103 statsBuilder.setTransmitErrors(portStats.getTxErrors());