elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/statisitcs/ElanStatisticsImpl.java

   1 /*
   2  * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.netvirt.elan.statisitcs;
   9
  10 import com.google.common.base.Optional;
  11 import com.google.common.util.concurrent.Futures;
  12 import com.google.common.util.concurrent.ListenableFuture;
  13 import javax.annotation.Nullable;
  14 import javax.inject.Inject;
  15 import javax.inject.Singleton;
  16 import org.opendaylight.genius.interfacemanager.globals.InterfaceInfo;
  17 import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
  18 import org.opendaylight.netvirt.elan.cache.ElanInterfaceCache;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius._interface.statistics.rev150824.ResultCode;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterface;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.statistics.rev150824.ElanStatisticsService;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.statistics.rev150824.GetElanInterfaceStatisticsInput;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.statistics.rev150824.GetElanInterfaceStatisticsOutput;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.statistics.rev150824.GetElanInterfaceStatisticsOutputBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.statistics.rev150824.get.elan._interface.statistics.output.StatResultBuilder;
  26 import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
  27 import org.opendaylight.yangtools.yang.common.RpcResult;
  28 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 @Singleton
  33 public class ElanStatisticsImpl implements ElanStatisticsService {
  34     private static final Logger LOG = LoggerFactory.getLogger(ElanStatisticsImpl.class);
  35
  36     private final IInterfaceManager interfaceManager;
  37     private final ElanInterfaceCache elanInterfaceCache;
  38
  39     @Inject
  40     public ElanStatisticsImpl(IInterfaceManager interfaceManager,
  41             ElanInterfaceCache elanInterfaceCache) {
  42         this.interfaceManager = interfaceManager;
  43         this.elanInterfaceCache = elanInterfaceCache;
  44     }
  45
  46     @Override
  47     public ListenableFuture<RpcResult<GetElanInterfaceStatisticsOutput>> getElanInterfaceStatistics(
  48         GetElanInterfaceStatisticsInput input) {
  49         String interfaceName = input.getInterfaceName();
  50         LOG.debug("getElanInterfaceStatistics is called for elan interface {}", interfaceName);
  51         RpcResultBuilder<GetElanInterfaceStatisticsOutput> rpcResultBuilder = null;
  52         if (interfaceName == null) {
  53             rpcResultBuilder = RpcResultBuilder.failed();
  54             return getFutureWithAppErrorMessage(rpcResultBuilder, "Interface name is not provided");
  55         }
  56         Optional<ElanInterface> elanInterface = elanInterfaceCache.get(interfaceName);
  57         if (!elanInterface.isPresent()) {
  58             rpcResultBuilder = RpcResultBuilder.failed();
  59             return getFutureWithAppErrorMessage(rpcResultBuilder,
  60                     String.format("Interface %s is not a ELAN interface", interfaceName));
  61         }
  62         InterfaceInfo interfaceInfo = interfaceManager.getInterfaceInfo(interfaceName);
  63         if (!interfaceInfo.isOperational()) {
  64             LOG.debug("interface {} is down and returning with no statistics", interfaceName);
  65             rpcResultBuilder = RpcResultBuilder.success();
  66             return rpcResultBuilder.withResult(new GetElanInterfaceStatisticsOutputBuilder()
  67                             .setStatResult(
  68                                     new StatResultBuilder().setStatResultCode(ResultCode.NotFound).setByteRxCount(0L)
  69                                             .setByteTxCount(0L).setPacketRxCount(0L).setPacketTxCount(0L).build())
  70                             .build()).buildFuture();
  71         }
  72         rpcResultBuilder = RpcResultBuilder.success();
  73         return Futures.immediateFuture(rpcResultBuilder.withResult(queryforElanInterfaceStatistics()).build());
  74     }
  75
  76     @Nullable
  77     private GetElanInterfaceStatisticsOutput queryforElanInterfaceStatistics() {
  78         return null;
  79     }
  80
  81     private ListenableFuture<RpcResult<GetElanInterfaceStatisticsOutput>> getFutureWithAppErrorMessage(
  82         RpcResultBuilder<GetElanInterfaceStatisticsOutput> rpcResultBuilder, String message) {
  83         rpcResultBuilder.withError(ErrorType.APPLICATION, message);
  84         return rpcResultBuilder.buildFuture();
  85     }
  86
  87 }