X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-compability%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fcompability%2Fimpl%2FMdOpendaylightFlowStatisticsServiceAdapter.java;fp=opendaylight%2Fmd-sal%2Fsal-compability%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fcompability%2Fimpl%2FMdOpendaylightFlowStatisticsServiceAdapter.java;h=0000000000000000000000000000000000000000;hb=4f5a4b3e71e81c6149a1ca78ca418866e152c45b;hp=9a7295281ea25c6032f6697ccdc17ac6c818e905;hpb=058e97d0ed62600f124937fa44ec982503510ac4;p=controller.git

diff --git a/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/impl/MdOpendaylightFlowStatisticsServiceAdapter.java b/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/impl/MdOpendaylightFlowStatisticsServiceAdapter.java
deleted file mode 100644
index 9a7295281e..0000000000
--- a/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/impl/MdOpendaylightFlowStatisticsServiceAdapter.java
+++ /dev/null
@@ -1,159 +0,0 @@
-package org.opendaylight.controller.sal.compability.impl;
-
-import java.util.List;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
-import org.opendaylight.controller.sal.compability.FromSalConversionsUtils;
-import org.opendaylight.controller.sal.core.Node;
-import org.opendaylight.controller.sal.core.NodeConnector;
-import org.opendaylight.controller.sal.core.NodeTable;
-import org.opendaylight.controller.sal.flowprogrammer.Flow;
-import org.opendaylight.controller.sal.reader.*;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.*;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.flow.statistics.Duration;
-import org.opendaylight.yangtools.yang.common.RpcResult;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MdOpendaylightFlowStatisticsServiceAdapter implements IPluginInReadService {
-
-    private static final Logger LOG = LoggerFactory.getLogger(MdOpendaylightFlowStatisticsServiceAdapter.class);
-    private OpendaylightFlowStatisticsService opendaylightFlowStatisticsService;
-
-    @Override
-    public FlowOnNode readFlow(Node node, Flow flow, boolean cached) {
-        FlowOnNode result = null;
-
-        GetFlowStatisticsInput getFlowStatisticsInput = FromSalConversionsUtils.flowStatisticsInput(node,flow);
-        Future<RpcResult<GetFlowStatisticsOutput>> futureStatisticsOutput = opendaylightFlowStatisticsService
-                .getFlowStatistics(getFlowStatisticsInput);
-
-        RpcResult<GetFlowStatisticsOutput> rpcResultStatisticsOutput;
-        GetFlowStatisticsOutput getFlowStatisticsOutput;
-        try {
-            rpcResultStatisticsOutput = futureStatisticsOutput.get();
-            if (rpcResultStatisticsOutput != null) {
-                getFlowStatisticsOutput = rpcResultStatisticsOutput.getResult();
-                if (getFlowStatisticsOutput != null) {
-
-                    long byteCount = getFlowStatisticsOutput.getByteCount().getValue().longValue();
-
-                    Duration duration = getFlowStatisticsOutput.getDuration();
-                    int nanoseconds = duration.getNanosecond().getValue().intValue();
-                    int seconds = duration.getSecond().getValue().intValue();
-                    long packetCount = getFlowStatisticsOutput.getPacketCount().getValue().longValue();
-
-                    result = new FlowOnNode(flow);
-                    result.setByteCount(byteCount);
-                    result.setDurationNanoseconds(nanoseconds);
-                    result.setDurationSeconds(seconds);
-                    result.setPacketCount(packetCount);
-                    return result;
-                }
-            }
-        } catch (InterruptedException | ExecutionException e) {
-            LOG.error("Read flow not processed", e);
-        }
-        return null;
-    }
-
-    @Override
-    public List<FlowOnNode> readAllFlow(Node node, boolean cached) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    @Override
-    public NodeDescription readDescription(Node node, boolean cached) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    @Override
-    public NodeConnectorStatistics readNodeConnector(NodeConnector connector, boolean cached) {
-        NodeConnectorStatistics result = null;
-        GetNodeConnectorStatisticsInput getNodeConnectorStatisticsInput = FromSalConversionsUtils
-                .nodeConnectorStatistics(connector);
-        Future<RpcResult<GetNodeConnectorStatisticsOutput>> future = opendaylightFlowStatisticsService
-                .getNodeConnectorStatistics(getNodeConnectorStatisticsInput);
-        try {
-            RpcResult<GetNodeConnectorStatisticsOutput> rpcResult = future.get();
-            if (rpcResult != null) {
-                GetNodeConnectorStatisticsOutput getNodeConnectorStatisticsOutput = rpcResult.getResult();
-
-                if (getNodeConnectorStatisticsOutput != null) {
-                    result = new NodeConnectorStatistics();
-
-                    long colisionCount = getNodeConnectorStatisticsOutput.getCollisionCount().longValue();
-                    long receiveCrcErrorCount = getNodeConnectorStatisticsOutput.getReceiveCrcError().longValue();
-                    long receiveFrameErrorCount = getNodeConnectorStatisticsOutput.getReceiveFrameError().longValue();
-                    long receiveOverRunError = getNodeConnectorStatisticsOutput.getReceiveOverRunError().longValue();
-
-                    long receiveDropCount = getNodeConnectorStatisticsOutput.getReceiveDrops().longValue();
-                    long receiveErrorCount = getNodeConnectorStatisticsOutput.getReceiveErrors().longValue();
-                    long receivePacketCount = getNodeConnectorStatisticsOutput.getPackets().getReceived().longValue();
-                    long receivedByteCount = getNodeConnectorStatisticsOutput.getBytes().getReceived().longValue();
-
-                    long transmitDropCount = getNodeConnectorStatisticsOutput.getTransmitDrops().longValue();
-                    long transmitErrorCount = getNodeConnectorStatisticsOutput.getTransmitErrors().longValue();
-                    long transmitPacketCount = getNodeConnectorStatisticsOutput.getPackets().getTransmitted()
-                            .longValue();
-                    long transmitByteCount = getNodeConnectorStatisticsOutput.getBytes().getTransmitted().longValue();
-
-                    result.setCollisionCount(colisionCount);
-                    result.setReceiveByteCount(receivedByteCount);
-                    result.setReceiveCRCErrorCount(receiveCrcErrorCount);
-                    result.setReceiveDropCount(receiveDropCount);
-                    result.setReceiveErrorCount(receiveErrorCount);
-                    result.setReceiveFrameErrorCount(receiveFrameErrorCount);
-                    result.setReceiveOverRunErrorCount(receiveOverRunError);
-                    result.setReceivePacketCount(receivePacketCount);
-                    result.setTransmitByteCount(transmitByteCount);
-                    result.setTransmitDropCount(transmitDropCount);
-                    result.setTransmitErrorCount(transmitErrorCount);
-                    result.setTransmitPacketCount(transmitPacketCount);
-                    return result;
-                }
-            }
-        } catch (InterruptedException | ExecutionException e) {
-            LOG.error("Read node connector not processed", e);
-        }
-
-        return result;
-
-    }
-
-    @Override
-    public List<NodeConnectorStatistics> readAllNodeConnector(Node node, boolean cached) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    @Override
-    public NodeTableStatistics readNodeTable(NodeTable table, boolean cached) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    @Override
-    public List<NodeTableStatistics> readAllNodeTable(Node node, boolean cached) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    @Override
-    public long getTransmitRate(NodeConnector connector) {
-        // TODO Auto-generated method stub
-        return 0;
-    }
-
-    public OpendaylightFlowStatisticsService getOpendaylightFlowStatisticsService() {
-        return opendaylightFlowStatisticsService;
-    }
-
-    public void setOpendaylightFlowStatisticsService(OpendaylightFlowStatisticsService opendaylightFlowStatisticsService) {
-        this.opendaylightFlowStatisticsService = opendaylightFlowStatisticsService;
-    }
-
-}