mappingservice/southbound/src/main/java/org/opendaylight/lispflowmapping/southbound/LispSouthboundRPC.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc.  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
   9 package org.opendaylight.lispflowmapping.southbound;
  10
  11 import com.google.common.util.concurrent.Futures;
  12 import java.nio.ByteBuffer;
  13 import java.util.ArrayList;
  14 import java.util.List;
  15 import java.util.concurrent.Future;
  16 import org.opendaylight.lispflowmapping.lisp.serializer.MapNotifySerializer;
  17 import org.opendaylight.lispflowmapping.lisp.serializer.MapRegisterSerializer;
  18 import org.opendaylight.lispflowmapping.lisp.serializer.MapReplySerializer;
  19 import org.opendaylight.lispflowmapping.lisp.serializer.MapRequestSerializer;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.MessageType;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.GetStatsOutput;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.GetStatsOutputBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.OdlLispSbService;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.SendMapNotifyInput;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.SendMapRegisterInput;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.SendMapReplyInput;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.SendMapRequestInput;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.ctrl.msg.stats.ControlMessage;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.ctrl.msg.stats.ControlMessageBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.get.stats.output.ControlMessageStatsBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.sb.rev150904.get.stats.output.MapRegisterCacheStatsBuilder;
  32 import org.opendaylight.yangtools.yang.common.RpcError;
  33 import org.opendaylight.yangtools.yang.common.RpcResult;
  34 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  35 import org.slf4j.Logger;
  36 import org.slf4j.LoggerFactory;
  37
  38 /**
  39  * This class holds all RPCs methods for LispSouthbound Plugin.
  40  *
  41  * <p>
  42  * @author Florin Coras (fcoras@cisco.com)
  43  * @author Lorand Jakab (lojakab@cisco.com)
  44  */
  45
  46 public class LispSouthboundRPC implements OdlLispSbService {
  47
  48     protected static final Logger LOG = LoggerFactory.getLogger(LispSouthboundRPC.class);
  49
  50     private final LispSouthboundPlugin lispSbPlugin;
  51
  52     public LispSouthboundRPC(LispSouthboundPlugin lispSbPlugin) {
  53         this.lispSbPlugin = lispSbPlugin;
  54     }
  55
  56
  57     @Override
  58     public Future<RpcResult<Void>> sendMapNotify(SendMapNotifyInput mapNotifyInput) {
  59         LOG.trace("sendMapNotify called!!");
  60         if (mapNotifyInput != null) {
  61             ByteBuffer outBuffer = MapNotifySerializer.getInstance().serialize(mapNotifyInput.getMapNotify());
  62             lispSbPlugin.handleSerializedLispBuffer(mapNotifyInput.getTransportAddress(), outBuffer,
  63                     MessageType.MapNotify);
  64         } else {
  65             LOG.warn("MapNotify was null");
  66             return Futures.immediateFuture(RpcResultBuilder.<Void>failed().build());
  67         }
  68         return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
  69     }
  70
  71     @Override
  72     public Future<RpcResult<Void>> sendMapReply(SendMapReplyInput mapReplyInput) {
  73         LOG.trace("sendMapReply called!!");
  74         if (mapReplyInput != null) {
  75             ByteBuffer outBuffer = MapReplySerializer.getInstance().serialize(mapReplyInput.getMapReply());
  76             lispSbPlugin.handleSerializedLispBuffer(mapReplyInput.getTransportAddress(), outBuffer,
  77                     MessageType.MapReply);
  78         } else {
  79             LOG.warn("MapReply was null");
  80             return Futures.immediateFuture(RpcResultBuilder.<Void>failed().build());
  81         }
  82         return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
  83     }
  84
  85     @Override
  86     public Future<RpcResult<Void>> sendMapRequest(SendMapRequestInput mapRequestInput) {
  87         LOG.trace("sendMapRequest called!!");
  88         if (mapRequestInput != null) {
  89             ByteBuffer outBuffer = MapRequestSerializer.getInstance().serialize(mapRequestInput.getMapRequest());
  90             lispSbPlugin.handleSerializedLispBuffer(mapRequestInput.getTransportAddress(), outBuffer,
  91                     MessageType.MapRequest);
  92         } else {
  93             LOG.debug("MapRequest was null");
  94             return Futures.immediateFuture(RpcResultBuilder.<Void>failed().build());
  95         }
  96         return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
  97     }
  98
  99     @Override
 100     public Future<RpcResult<Void>> sendMapRegister(SendMapRegisterInput mapRegisterInput) {
 101         LOG.trace("sendMapRegister called!!");
 102         if (mapRegisterInput != null) {
 103             ByteBuffer outBuffer = MapRegisterSerializer.getInstance().serialize(mapRegisterInput.getMapRegister());
 104             lispSbPlugin.handleSerializedLispBuffer(mapRegisterInput.getTransportAddress(), outBuffer,
 105                     MessageType.MapRegister);
 106         } else {
 107             LOG.debug("MapRegister was null");
 108             return Futures.immediateFuture(RpcResultBuilder.<Void>failed().build());
 109         }
 110         return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
 111     }
 112
 113     @Override
 114     public Future<RpcResult<GetStatsOutput>> getStats() {
 115         LOG.trace("getStats called!!");
 116
 117         RpcResultBuilder<GetStatsOutput> rpcResultBuilder;
 118
 119         LispSouthboundStats stats = lispSbPlugin.getStats();
 120
 121         if (stats == null) {
 122             rpcResultBuilder = RpcResultBuilder.<GetStatsOutput>failed()
 123                     .withError(RpcError.ErrorType.APPLICATION, "data-missing", "No stats found");
 124         } else {
 125             rpcResultBuilder = RpcResultBuilder.success(createGetStatsOutput(stats));
 126         }
 127         return Futures.immediateFuture(rpcResultBuilder.build());
 128     }
 129
 130     @Override
 131     public Future<RpcResult<Void>> resetStats() {
 132         LOG.trace("resetStats called!!");
 133
 134         LispSouthboundStats stats = lispSbPlugin.getStats();
 135
 136         if (stats == null) {
 137             return Futures.immediateFuture(RpcResultBuilder.<Void>failed()
 138                     .withError(RpcError.ErrorType.APPLICATION, "data-missing", "No stats found")
 139                     .build());
 140         } else {
 141             stats.resetStats();
 142             return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
 143         }
 144     }
 145
 146     private static GetStatsOutput createGetStatsOutput(LispSouthboundStats stats) {
 147         long[] rxStats = stats.getRx();
 148         long[] txStats = stats.getTx();
 149
 150         ControlMessageStatsBuilder cmsb = new ControlMessageStatsBuilder();
 151         cmsb.setRxUnknown(stats.getRxUnknown());
 152         cmsb.setTxErrors(stats.getTxErrors());
 153
 154         List<ControlMessage> messages = new ArrayList<ControlMessage>();
 155         for (int i = 0; i <= LispSouthboundStats.MAX_LISP_TYPES; i++) {
 156             if (MessageType.forValue(i) == null) {
 157                 continue;
 158             }
 159             ControlMessageBuilder cmb = new ControlMessageBuilder();
 160             cmb.setMsgType(MessageType.forValue(i));
 161             cmb.setRxCount(rxStats[i]);
 162             cmb.setTxCount(txStats[i]);
 163             messages.add(cmb.build());
 164         }
 165
 166         cmsb.setControlMessage(messages);
 167
 168         MapRegisterCacheStatsBuilder mrcsb = new MapRegisterCacheStatsBuilder();
 169         mrcsb.setHits(stats.getCacheHits());
 170         mrcsb.setMisses(stats.getCacheMisses());
 171
 172         return new GetStatsOutputBuilder().setControlMessageStats(cmsb.build())
 173                 .setMapRegisterCacheStats(mrcsb.build()).build();
 174     }
 175 }