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 com.google.common.collect.Lists;
13 import java.util.ArrayList;
14 import java.util.HashSet;
15 import java.util.List;
17 import java.util.stream.Collectors;
18 import org.opendaylight.openflowplugin.api.openflow.device.DeviceInfo;
19 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
20 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter32;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.TransactionId;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.duration.DurationBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.node.connector.statistics.BytesBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.statistics.types.rev130925.node.connector.statistics.PacketsBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReply;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsCase;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats._case.MultipartReplyPortStats;
29 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;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdate;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdateBuilder;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMap;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMapBuilder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMapKey;
37 * Pulled out port stats to notification transformation.
39 public final class NodeConnectorStatisticsToNotificationTransformer {
41 private NodeConnectorStatisticsToNotificationTransformer() {
42 // Hide implicit constructor
46 * Transform statistics to notification.
48 * @param mpReplyList raw multipart response from device
49 * @param deviceInfo device basic info
50 * @param ofVersion device version
51 * @param emulatedTxId emulated transaction Id
52 * @return notification containing flow stats
54 public static NodeConnectorStatisticsUpdate transformToNotification(final List<MultipartReply> mpReplyList,
55 final DeviceInfo deviceInfo,
56 final OpenflowVersion ofVersion,
57 final TransactionId emulatedTxId) {
59 NodeConnectorStatisticsUpdateBuilder notification = new NodeConnectorStatisticsUpdateBuilder();
60 notification.setId(deviceInfo.getNodeId());
61 notification.setMoreReplies(Boolean.FALSE);
62 notification.setTransactionId(emulatedTxId);
65 .setNodeConnectorStatisticsAndPortNumberMap(new ArrayList<>());
66 for (MultipartReply mpReply : mpReplyList) {
67 MultipartReplyPortStatsCase caseBody = (MultipartReplyPortStatsCase) mpReply.getMultipartReplyBody();
69 MultipartReplyPortStats replyBody = caseBody.getMultipartReplyPortStats();
70 for (PortStats portStats : replyBody.getPortStats()) {
71 NodeConnectorStatisticsAndPortNumberMapBuilder statsBuilder =
72 processSingleNodeConnectorStats(deviceInfo, ofVersion, portStats);
73 if (notification.getNodeConnectorStatisticsAndPortNumberMap() != null) {
74 Set<NodeConnectorStatisticsAndPortNumberMap> stats
75 = new HashSet<>(notification.getNodeConnectorStatisticsAndPortNumberMap().values());
76 stats.add(statsBuilder.build());
77 notification.setNodeConnectorStatisticsAndPortNumberMap(
78 stats.stream().collect(Collectors.toList()));
80 notification.setNodeConnectorStatisticsAndPortNumberMap(Lists.newArrayList(statsBuilder.build()));
84 return notification.build();
88 static NodeConnectorStatisticsAndPortNumberMapBuilder processSingleNodeConnectorStats(DeviceInfo deviceInfo,
89 OpenflowVersion ofVersion,
90 PortStats portStats) {
91 NodeConnectorStatisticsAndPortNumberMapBuilder statsBuilder =
92 new NodeConnectorStatisticsAndPortNumberMapBuilder();
93 statsBuilder.setNodeConnectorId(
94 InventoryDataServiceUtil.nodeConnectorIdfromDatapathPortNo(
95 deviceInfo.getDatapathId(),
96 portStats.getPortNo(), ofVersion));
98 BytesBuilder bytesBuilder = new BytesBuilder();
99 bytesBuilder.setReceived(portStats.getRxBytes());
100 bytesBuilder.setTransmitted(portStats.getTxBytes());
101 statsBuilder.setBytes(bytesBuilder.build());
103 PacketsBuilder packetsBuilder = new PacketsBuilder();
104 packetsBuilder.setReceived(portStats.getRxPackets());
105 packetsBuilder.setTransmitted(portStats.getTxPackets());
106 statsBuilder.setPackets(packetsBuilder.build());
108 DurationBuilder durationBuilder = new DurationBuilder();
109 if (portStats.getDurationSec() != null) {
110 durationBuilder.setSecond(new Counter32(portStats.getDurationSec()));
112 if (portStats.getDurationNsec() != null) {
113 durationBuilder.setNanosecond(new Counter32(portStats.getDurationNsec()));
115 statsBuilder.setDuration(durationBuilder.build());
116 statsBuilder.setCollisionCount(portStats.getCollisions());
117 statsBuilder.withKey(new NodeConnectorStatisticsAndPortNumberMapKey(statsBuilder.getNodeConnectorId()));
118 statsBuilder.setReceiveCrcError(portStats.getRxCrcErr());
119 statsBuilder.setReceiveDrops(portStats.getRxDropped());
120 statsBuilder.setReceiveErrors(portStats.getRxErrors());
121 statsBuilder.setReceiveFrameError(portStats.getRxFrameErr());
122 statsBuilder.setReceiveOverRunError(portStats.getRxOverErr());
123 statsBuilder.setTransmitDrops(portStats.getTxDropped());
124 statsBuilder.setTransmitErrors(portStats.getTxErrors());