elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/cli/l2gw/L2GwUtilsCacheCli.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
   9 package org.opendaylight.netvirt.elan.cli.l2gw;
  10
  11 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
  12 import java.io.File;
  13 import java.io.FileOutputStream;
  14 import java.io.IOException;
  15 import java.io.PrintStream;
  16 import java.util.Collection;
  17 import java.util.Map;
  18 import java.util.Map.Entry;
  19 import java.util.concurrent.ConcurrentMap;
  20 import org.apache.karaf.shell.commands.Command;
  21 import org.apache.karaf.shell.commands.Option;
  22 import org.apache.karaf.shell.console.OsgiCommandSupport;
  23 import org.opendaylight.genius.utils.cache.CacheUtil;
  24 import org.opendaylight.genius.utils.hwvtep.HwvtepNodeHACache;
  25 import org.opendaylight.netvirt.elanmanager.utils.ElanL2GwCacheUtils;
  26 import org.opendaylight.netvirt.neutronvpn.api.l2gw.L2GatewayCache;
  27 import org.opendaylight.netvirt.neutronvpn.api.l2gw.L2GatewayDevice;
  28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  29 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  30
  31 @Command(scope = "l2gw", name = "show-cache", description = "display l2gateways cache")
  32 public class L2GwUtilsCacheCli extends OsgiCommandSupport {
  33     private static final String L2GATEWAY_CACHE_NAME = "L2GW";
  34     private static final String DEMARCATION = "=================================";
  35
  36     @Option(name = "-cache", aliases = {"--cache"}, description = "cache name",
  37             required = false, multiValued = false)
  38     String cacheName;
  39
  40     @Option(name = "-elan", aliases = {"--elan"}, description = "elan name",
  41             required = false, multiValued = false)
  42     String elanName;
  43
  44     private final L2GatewayCache l2GatewayCache;
  45     private final HwvtepNodeHACache hwvtepNodeHACache;
  46
  47     public L2GwUtilsCacheCli(L2GatewayCache l2GatewayCache, HwvtepNodeHACache hwvtepNodeHACache) {
  48         this.l2GatewayCache = l2GatewayCache;
  49         this.hwvtepNodeHACache = hwvtepNodeHACache;
  50     }
  51
  52     @Override
  53     protected Object doExecute() throws IOException {
  54         if (cacheName == null) {
  55             session.getConsole().println("Available caches");
  56             session.getConsole().println(ElanL2GwCacheUtils.L2GATEWAY_CONN_CACHE_NAME);
  57             session.getConsole().println(L2GATEWAY_CACHE_NAME);
  58             session.getConsole().println("HA");
  59             session.getConsole().println("HA_EVENTS");
  60             return null;
  61         }
  62         switch (cacheName) {
  63             case ElanL2GwCacheUtils.L2GATEWAY_CONN_CACHE_NAME:
  64                 dumpElanL2GwCache();
  65                 break;
  66             case L2GATEWAY_CACHE_NAME:
  67                 dumpL2GwCache();
  68                 break;
  69             case "HA":
  70                 dumpHACache(session.getConsole());
  71                 break;
  72             case "HA_EVENTS":
  73                 dumpHACacheEvents();
  74                 break;
  75             default:
  76                 break;
  77         }
  78         return null;
  79     }
  80
  81     @SuppressFBWarnings("DM_DEFAULT_ENCODING")
  82     private void dumpHACacheEvents() throws IOException {
  83         try (FileOutputStream fileOutputStream = new FileOutputStream(new File("hwvtep.events.txt"))) {
  84             session.getConsole().println("Dumping to file hwvtep.events.txt");
  85             PrintStream fos = new PrintStream(fileOutputStream);
  86             dumpHACache(fos);
  87             fos.close();
  88             session.getConsole().println("Dumped to file " + new File("hwvtep.events.txt").getAbsolutePath());
  89         }
  90     }
  91
  92     private void dumpHACache(PrintStream printStream) {
  93
  94         printStream.println("HA enabled nodes");
  95         for (InstanceIdentifier<Node> id : hwvtepNodeHACache.getHAChildNodes()) {
  96             String nodeId = id.firstKeyOf(Node.class).getNodeId().getValue();
  97             printStream.println(nodeId);
  98         }
  99
 100         printStream.println("HA parent nodes");
 101         for (InstanceIdentifier<Node> id : hwvtepNodeHACache.getHAParentNodes()) {
 102             String nodeId = id.firstKeyOf(Node.class).getNodeId().getValue();
 103             printStream.println(nodeId);
 104             for (InstanceIdentifier<Node> childId : hwvtepNodeHACache.getChildrenForHANode(id)) {
 105                 nodeId = childId.firstKeyOf(Node.class).getNodeId().getValue();
 106                 printStream.println("    " + nodeId);
 107             }
 108         }
 109
 110         printStream.println("Connected Nodes");
 111         Map<String, Boolean> nodes = hwvtepNodeHACache.getNodeConnectionStatuses();
 112         for (Entry<String, Boolean> entry : nodes.entrySet()) {
 113             printStream.print(entry.getKey());
 114             printStream.print("    : connected : ");
 115             printStream.println(entry.getValue());
 116         }
 117     }
 118
 119     private void dumpL2GwCache() {
 120         Collection<L2GatewayDevice> devices = l2GatewayCache.getAll();
 121         if (devices.isEmpty()) {
 122             session.getConsole().println("no devices are present in cache");
 123             return;
 124         }
 125         for (L2GatewayDevice device : devices) {
 126             session.getConsole().println("device " + device);
 127         }
 128     }
 129
 130     private void dumpElanL2GwCache() {
 131         if (elanName == null) {
 132             ConcurrentMap<String, ConcurrentMap<String, L2GatewayDevice>> cache =
 133                     (ConcurrentMap<String, ConcurrentMap<String, L2GatewayDevice>>) CacheUtil.getCache(
 134                             cacheName);
 135             if (cache == null) {
 136                 session.getConsole().println("no devices are present in elan cache");
 137             } else {
 138                 for (Entry<String, ConcurrentMap<String, L2GatewayDevice>> entry : cache.entrySet()) {
 139                     print(entry.getKey(), entry.getValue());
 140                     session.getConsole().println(DEMARCATION);
 141                     session.getConsole().println(DEMARCATION);
 142                 }
 143             }
 144             return;
 145         }
 146         ConcurrentMap<String, L2GatewayDevice> elanDevices = ElanL2GwCacheUtils
 147                 .getInvolvedL2GwDevices(elanName);
 148         print(elanName, elanDevices);
 149     }
 150
 151     private void print(String elan, ConcurrentMap<String, L2GatewayDevice> devices) {
 152         session.getConsole().println("Elan name : " + elan);
 153         session.getConsole().println("No of devices in elan " + devices.keySet().size());
 154         for (L2GatewayDevice device : devices.values()) {
 155             session.getConsole().println("device " + device);
 156         }
 157     }
 158 }