elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/cli/l2gw/NetworkL2gwDeviceInfoCli.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 com.google.common.base.Optional;
  12 import java.util.ArrayList;
  13 import java.util.HashMap;
  14 import java.util.HashSet;
  15 import java.util.List;
  16 import java.util.Map;
  17 import java.util.Set;
  18 import org.apache.karaf.shell.commands.Command;
  19 import org.apache.karaf.shell.commands.Option;
  20 import org.apache.karaf.shell.console.OsgiCommandSupport;
  21 import org.eclipse.jdt.annotation.Nullable;
  22 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  23 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  24 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  25 import org.opendaylight.genius.utils.hwvtep.HwvtepSouthboundConstants;
  26 import org.opendaylight.genius.utils.hwvtep.HwvtepUtils;
  27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.ElanInstances;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.instances.ElanInstance;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepGlobalAugmentation;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepLogicalSwitchRef;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalLocatorRef;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalPortAugmentation;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.LocalMcastMacs;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.LocalUcastMacs;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.LogicalSwitches;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.RemoteMcastMacs;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.RemoteUcastMacs;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.Switches;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical.locator.set.attributes.LocatorSet;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical.port.attributes.VlanBindings;
  42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  43 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
  44 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  45 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
  46 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  47 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
  48 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
  49 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  50
  51 /**
  52  * Prints L2Gw devices and Elan details .
  53  * Print result as per each elan instance , printing all Mcast , UCast macs and vlan binding
  54  * for each l2Gw device .
  55  */
  56 @Command(scope = "l2gw", name = "dump", description = "Provide l2gw info per network")
  57 public class NetworkL2gwDeviceInfoCli extends OsgiCommandSupport {
  58
  59     private static final String GAP = "                              ";
  60     private static final String HEADINGUCAST = "    Mac " + GAP + "          Locator";
  61     private static final String HEADINGMCAST = "    Mac " + GAP + "          Locator Set";
  62     private static final String HEADINGVLAN = "    TepId " + GAP + "          Vlan ID";
  63
  64     @Option(name = "-elan", aliases = {"--elan"}, description = "elan name",
  65             required = false, multiValued = false)
  66     String elanName;
  67
  68     @Option(name = "-nodeId", aliases = {"--nodeId"}, description = "hwvtep node id",
  69             required = false, multiValued = false)
  70     String nodeId;
  71
  72     private static InstanceIdentifier<Topology> createHwvtepTopologyInstanceIdentifier() {
  73         return InstanceIdentifier.create(NetworkTopology.class).child(Topology.class,
  74                 new TopologyKey(HwvtepSouthboundConstants.HWVTEP_TOPOLOGY_ID));
  75     }
  76
  77     private static InstanceIdentifier<Node> createInstanceIdentifier(NodeId nodeId) {
  78         return InstanceIdentifier.create(NetworkTopology.class).child(Topology.class,
  79                 new TopologyKey(HwvtepSouthboundConstants.HWVTEP_TOPOLOGY_ID)).child(Node.class, new NodeKey(nodeId));
  80     }
  81
  82     Map<NodeId, Node> opNodes = new HashMap<>();
  83     Map<NodeId, Node> configNodes = new HashMap<>();
  84     Map<NodeId, Node> opPSNodes = new HashMap<>();
  85     Map<NodeId, Node> configPSNodes = new HashMap<>();
  86
  87     private DataBroker dataBroker;
  88
  89     public void setDataBroker(DataBroker dataBroker) {
  90         this.dataBroker = dataBroker;
  91     }
  92
  93     @Override
  94     @Nullable
  95     protected Object doExecute() {
  96         List<Node> nodes = new ArrayList<>();
  97         Set<String> networks = new HashSet<>();
  98         if (nodeId == null) {
  99             Optional<Topology> topologyOptional = MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL,
 100                     createHwvtepTopologyInstanceIdentifier());
 101             if (topologyOptional.isPresent()) {
 102                 nodes.addAll(topologyOptional.get().nonnullNode());
 103             }
 104         } else {
 105             Optional<Node> nodeOptional = MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL,
 106                     createInstanceIdentifier(new NodeId(new Uri(nodeId))));
 107             if (nodeOptional.isPresent()) {
 108                 nodes.add(nodeOptional.get());
 109             }
 110         }
 111         if (elanName == null) {
 112             //get all elan instance
 113             //get all device node id
 114             //print result
 115             Optional<ElanInstances> elanInstancesOptional = MDSALUtil.read(dataBroker,
 116                     LogicalDatastoreType.CONFIGURATION,
 117                     InstanceIdentifier.builder(ElanInstances.class).build());
 118             if (elanInstancesOptional.isPresent()) {
 119                 List<ElanInstance> elans = elanInstancesOptional.get().getElanInstance();
 120                 if (elans != null) {
 121                     for (ElanInstance elan : elans) {
 122                         networks.add(elan.getElanInstanceName());
 123                     }
 124                 }
 125             }
 126         } else {
 127             networks.add(elanName);
 128         }
 129
 130         if (nodes != null) {
 131             for (Node node : nodes) {
 132                 if (node.getNodeId().getValue().contains("physicalswitch")) {
 133                     continue;
 134                 }
 135                 Node hwvtepConfigNode =
 136                         HwvtepUtils.getHwVtepNode(dataBroker, LogicalDatastoreType.CONFIGURATION, node.getNodeId());
 137                 Node hwvtepOpPsNode = getPSnode(node, LogicalDatastoreType.OPERATIONAL);
 138                 Node hwvtepConfigPsNode = null;
 139                 if (hwvtepOpPsNode != null) {
 140                     hwvtepConfigPsNode = HwvtepUtils.getHwVtepNode(dataBroker, LogicalDatastoreType.CONFIGURATION,
 141                             hwvtepOpPsNode.getNodeId());
 142                     opPSNodes.put(node.getNodeId(), hwvtepOpPsNode);
 143                 }
 144                 opNodes.put(node.getNodeId(), node);
 145                 configNodes.put(node.getNodeId(), hwvtepConfigNode);
 146
 147                 if (hwvtepConfigPsNode != null) {
 148                     configPSNodes.put(node.getNodeId(), hwvtepConfigPsNode);
 149                 }
 150             }
 151         }
 152         if (!networks.isEmpty()) {
 153             for (String network : networks) {
 154                 session.getConsole().println("Network info for " + network);
 155                 for (Node node : nodes) {
 156                     if (node.getNodeId().getValue().contains("physicalswitch")) {
 157                         continue;
 158                     }
 159                     session.getConsole().println("Printing for node " + node.getNodeId().getValue());
 160                     process(node.getNodeId(), network);
 161                 }
 162             }
 163         }
 164         return null;
 165     }
 166
 167     @SuppressWarnings("checkstyle:HiddenField")
 168     void process(NodeId hwvtepNodeId, String elanName) {
 169         Node hwvtepConfigNode = configNodes.get(hwvtepNodeId);
 170         session.getConsole().println("Config Data >>");
 171         printLocalUcastMacs(hwvtepConfigNode, elanName);
 172         session.getConsole().println("Operational Data >>");
 173         Node hwvtepOpNode = opNodes.get(hwvtepNodeId);
 174         printLocalUcastMacs(hwvtepOpNode, elanName);
 175         session.getConsole().println("Config Data >>");
 176         printLocalMcastMacs(hwvtepConfigNode, elanName);
 177         session.getConsole().println("Operational Data >>");
 178         printLocalMcastMacs(hwvtepOpNode, elanName);
 179         session.getConsole().println("Config Data >>");
 180         printRemoteUcastMacs(hwvtepConfigNode, elanName);
 181         session.getConsole().println("Operational Data >>");
 182         printRemoteUcastMacs(hwvtepOpNode, elanName);
 183         session.getConsole().println("Config Data >>");
 184         printRemoteMcastMacs(hwvtepConfigNode, elanName);
 185         session.getConsole().println("Operational Data >>");
 186         printRemoteMcastMacs(hwvtepOpNode, elanName);
 187         Node hwvtepConfigPsNode = configPSNodes.get(hwvtepNodeId);
 188         session.getConsole().println("Config Data >>");
 189         printVlanBindings(hwvtepConfigPsNode, elanName);
 190         session.getConsole().println("Operational Data >>");
 191         Node hwvtepOpPsNode = opPSNodes.get(hwvtepNodeId);
 192         printVlanBindings(hwvtepOpPsNode, elanName);
 193     }
 194
 195     @SuppressWarnings("checkstyle:HiddenField")
 196     void printRemoteUcastMacs(Node hwvtepNode, String elanName) {
 197         session.getConsole().println("RemoteUCast macs :");
 198         session.getConsole().println(HEADINGUCAST);
 199         if (hwvtepNode == null || hwvtepNode.augmentation(HwvtepGlobalAugmentation.class) == null) {
 200             return;
 201         }
 202         List<RemoteUcastMacs> remoteUcastMacs =
 203                 hwvtepNode.augmentation(HwvtepGlobalAugmentation.class).getRemoteUcastMacs();
 204         if (remoteUcastMacs == null || remoteUcastMacs.isEmpty()) {
 205             return;
 206         }
 207         for (RemoteUcastMacs remoteMac : remoteUcastMacs) {
 208             String lsFromRemoteMac = getLogicalSwitchValue(remoteMac.getLogicalSwitchRef());
 209             if (elanName.equals(lsFromRemoteMac)) {
 210                 String mac = remoteMac.getMacEntryKey().getValue();
 211                 String locator = getLocatorValue(remoteMac.getLocatorRef());
 212                 session.getConsole().println(mac + GAP + locator);
 213             }
 214         }
 215
 216
 217     }
 218
 219     @SuppressWarnings("checkstyle:HiddenField")
 220     void printLocalUcastMacs(Node hwvtepNode, String elanName) {
 221         session.getConsole().println("LocalUCast macs :");
 222         session.getConsole().println(HEADINGUCAST);
 223         if (hwvtepNode == null || hwvtepNode.augmentation(HwvtepGlobalAugmentation.class) == null) {
 224             return;
 225         }
 226         List<LocalUcastMacs> localUcastMacs =
 227                 hwvtepNode.augmentation(HwvtepGlobalAugmentation.class).getLocalUcastMacs();
 228         if (localUcastMacs == null || localUcastMacs.isEmpty()) {
 229             return;
 230         }
 231         for (LocalUcastMacs localMac : localUcastMacs) {
 232             String lsFromLocalMac = getLogicalSwitchValue(localMac.getLogicalSwitchRef());
 233             if (elanName.equals(lsFromLocalMac)) {
 234                 String mac = localMac.getMacEntryKey().getValue();
 235                 String locator = getLocatorValue(localMac.getLocatorRef());
 236                 session.getConsole().println(mac + GAP + locator);
 237             }
 238         }
 239
 240
 241     }
 242
 243     @SuppressWarnings("checkstyle:HiddenField")
 244     void printLocalMcastMacs(Node hwvtepNode, String elanName) {
 245         session.getConsole().println("LocalMcast macs :");
 246         session.getConsole().println(HEADINGMCAST);
 247         if (hwvtepNode == null || hwvtepNode.augmentation(HwvtepGlobalAugmentation.class) == null) {
 248             return;
 249         }
 250         List<LocalMcastMacs> localMcastMacs =
 251                 hwvtepNode.augmentation(HwvtepGlobalAugmentation.class).getLocalMcastMacs();
 252         if (localMcastMacs == null || localMcastMacs.isEmpty()) {
 253             return;
 254         }
 255         for (LocalMcastMacs localMac : localMcastMacs) {
 256             String lsFromLocalMac = getLogicalSwitchValue(localMac.getLogicalSwitchRef());
 257             if (elanName.equals(lsFromLocalMac)) {
 258                 String mac = localMac.getMacEntryKey().getValue();
 259                 List<String> locatorsets = new ArrayList<>();
 260                 for (LocatorSet locatorSet : localMac.nonnullLocatorSet()) {
 261                     locatorsets.add(getLocatorValue(locatorSet.getLocatorRef()));
 262                 }
 263                 session.getConsole().println(mac + GAP + locatorsets.toString());
 264             }
 265         }
 266
 267
 268     }
 269
 270     @SuppressWarnings("checkstyle:HiddenField")
 271     void printRemoteMcastMacs(Node hwvtepNode, String elanName) {
 272         session.getConsole().println("RemoteMCast macs :");
 273         session.getConsole().println(HEADINGMCAST);
 274         if (hwvtepNode == null || hwvtepNode.augmentation(HwvtepGlobalAugmentation.class) == null) {
 275             return;
 276         }
 277         List<RemoteMcastMacs> remoteMcastMacs =
 278                 hwvtepNode.augmentation(HwvtepGlobalAugmentation.class).getRemoteMcastMacs();
 279         if (remoteMcastMacs == null || remoteMcastMacs.isEmpty()) {
 280             return;
 281         }
 282         for (RemoteMcastMacs remoteMac : remoteMcastMacs) {
 283             String lsFromremoteMac = getLogicalSwitchValue(remoteMac.getLogicalSwitchRef());
 284             if (elanName.equals(lsFromremoteMac)) {
 285                 String mac = remoteMac.getMacEntryKey().getValue();
 286                 List<String> locatorsets = new ArrayList<>();
 287                 for (LocatorSet locatorSet : remoteMac.nonnullLocatorSet()) {
 288                     locatorsets.add(getLocatorValue(locatorSet.getLocatorRef()));
 289                 }
 290                 session.getConsole().println(mac + GAP + locatorsets.toString());
 291             }
 292         }
 293
 294
 295     }
 296
 297     @SuppressWarnings("checkstyle:HiddenField")
 298     void printVlanBindings(Node psNode, String elanName) {
 299         session.getConsole().println("Vlan Bindings :");
 300         session.getConsole().println(HEADINGVLAN);
 301         if (psNode == null) {
 302             return;
 303         }
 304         List<TerminationPoint> terminationPoints = psNode.getTerminationPoint();
 305         if (terminationPoints == null || terminationPoints.isEmpty()) {
 306             return;
 307         }
 308         for (TerminationPoint terminationPoint : terminationPoints) {
 309             HwvtepPhysicalPortAugmentation aug =
 310                     terminationPoint.augmentation(HwvtepPhysicalPortAugmentation.class);
 311             if (aug == null || aug.getVlanBindings() == null) {
 312                 continue;
 313             }
 314             for (VlanBindings vlanBindings : aug.getVlanBindings()) {
 315                 String lsFromremoteMac = getLogicalSwitchValue(vlanBindings.getLogicalSwitchRef());
 316                 if (elanName.equals(lsFromremoteMac)) {
 317                     session.getConsole().println(terminationPoint.getTpId().getValue()
 318                             + GAP + vlanBindings.getVlanIdKey().toString());
 319                 }
 320             }
 321         }
 322
 323
 324     }
 325
 326     @Nullable
 327     String getLocatorValue(HwvtepPhysicalLocatorRef locatorRef) {
 328         if (locatorRef == null) {
 329             return null;
 330         }
 331         return locatorRef.getValue()
 332                 .firstKeyOf(TerminationPoint.class).getTpId().getValue();
 333     }
 334
 335     @Nullable
 336     String getLogicalSwitchValue(HwvtepLogicalSwitchRef logicalSwitchRef) {
 337         if (logicalSwitchRef == null) {
 338             return null;
 339         }
 340         return logicalSwitchRef.getValue()
 341                 .firstKeyOf(LogicalSwitches.class).getHwvtepNodeName().getValue();
 342     }
 343
 344     @Nullable
 345     Node getPSnode(Node hwvtepNode, LogicalDatastoreType datastoreType) {
 346         if (hwvtepNode.augmentation(HwvtepGlobalAugmentation.class) != null) {
 347             List<Switches> switches = hwvtepNode.augmentation(HwvtepGlobalAugmentation.class).getSwitches();
 348             if (switches != null) {
 349                 return HwvtepUtils.getHwVtepNode(dataBroker, datastoreType,
 350                     switches.iterator().next().getSwitchRef().getValue().firstKeyOf(Node.class).getNodeId());
 351             }
 352         }
 353         return null;
 354     }
 355 }