vpnservice/sfc/classifier/impl/src/main/java/org/opendaylight/netvirt/sfc/classifier/providers/NetvirtProvider.java

   1 /*
   2  * Copyright © 2017 Ericsson, Inc. 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.sfc.classifier.providers;
  10
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import java.util.Optional;
  14 import javax.inject.Inject;
  15 import javax.inject.Singleton;
  16 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  17 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  18 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.NetworkMaps;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.networkmaps.NetworkMap;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.networkmaps.NetworkMapKey;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapKey;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.sfc.acl.rev150105.NeutronNetwork;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.Ports;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.PortKey;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  32
  33 @Singleton
  34 public class NetvirtProvider {
  35
  36     private final DataBroker dataBroker;
  37
  38     @Inject
  39     public NetvirtProvider(final DataBroker dataBroker) {
  40         this.dataBroker = dataBroker;
  41     }
  42
  43     public Optional<List<String>> getLogicalInterfacesFromNeutronNetwork(NeutronNetwork nw) {
  44         InstanceIdentifier<NetworkMap> networkMapIdentifier =
  45                 getNetworkMapIdentifier(new Uuid(nw.getNetworkUuid()));
  46
  47         com.google.common.base.Optional<NetworkMap> networkMap =
  48             MDSALUtil.read(LogicalDatastoreType.CONFIGURATION, networkMapIdentifier, dataBroker);
  49         if (!networkMap.isPresent()) {
  50             return Optional.empty();
  51         }
  52
  53         List<String> interfaces = new ArrayList<>();
  54
  55         List<Uuid> subnetUuidList = networkMap.get().getSubnetIdList();
  56         for (Uuid subnetUuid : subnetUuidList) {
  57             InstanceIdentifier<Subnetmap> subnetId = getSubnetMapIdentifier(subnetUuid);
  58             com.google.common.base.Optional<Subnetmap> subnet =
  59                 MDSALUtil.read(LogicalDatastoreType.CONFIGURATION, subnetId, dataBroker);
  60             if (!subnet.isPresent()) {
  61                 continue;
  62             }
  63
  64             // TODO fix
  65             subnet.get().getPortList().forEach((subnetPortUuid) -> interfaces.add(getNeutronPort(subnetPortUuid)));
  66         }
  67
  68         return Optional.of(interfaces);
  69     }
  70
  71     //
  72     // Internal Util methods
  73     //
  74
  75     private InstanceIdentifier<NetworkMap> getNetworkMapIdentifier(Uuid nwUuidStr) {
  76         return InstanceIdentifier.builder(NetworkMaps.class)
  77                 .child(NetworkMap.class,new NetworkMapKey(nwUuidStr)).build();
  78     }
  79
  80     private InstanceIdentifier<Subnetmap> getSubnetMapIdentifier(Uuid subnetUuidStr) {
  81         return InstanceIdentifier.builder(Subnetmaps.class)
  82                 .child(Subnetmap.class, new SubnetmapKey(subnetUuidStr)).build();
  83     }
  84
  85     private String getNeutronPort(Uuid portUuid) {
  86         InstanceIdentifier<Port> instId = InstanceIdentifier.create(Neutron.class).child(Ports.class)
  87                 .child(Port.class, new PortKey(portUuid));
  88         com.google.common.base.Optional<Port> port =
  89             MDSALUtil.read(LogicalDatastoreType.CONFIGURATION, instId, dataBroker);
  90
  91         return port.isPresent() ? port.get().getName() : new String();
  92     }
  93
  94 }