vpnservice/sfc/classifier/impl/src/main/java/org/opendaylight/netvirt/sfc/classifier/providers/SfcProvider.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.List;
  12 import java.util.Optional;
  13 import javax.inject.Inject;
  14 import javax.inject.Singleton;
  15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  17 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  18 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.RspName;
  19 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfName;
  20 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.RenderedServicePaths;
  21 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePath;
  22 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePathKey;
  23 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.rendered.service.path.RenderedServicePathHop;
  24 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.ServiceFunctions;
  25 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.function.base.SfDataPlaneLocator;
  26 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.functions.ServiceFunction;
  27 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.functions.ServiceFunctionKey;
  28 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.sfc.sff.logical.rev160620.LogicalInterfaceLocator;
  29 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.sfc.sff.logical.rev160620.service.functions.service.function.sf.data.plane.locator.locator.type.LogicalInterface;
  30 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 @Singleton
  35 public class SfcProvider {
  36
  37     private static final Logger LOG = LoggerFactory.getLogger(SfcProvider.class);
  38     private final DataBroker dataBroker;
  39
  40     @Inject
  41     public SfcProvider(final DataBroker dataBroker) {
  42         this.dataBroker = dataBroker;
  43     }
  44
  45     public Optional<RenderedServicePath> getRenderedServicePath(String rspName) {
  46         RenderedServicePathKey renderedServicePathKey = new RenderedServicePathKey(new RspName(rspName));
  47         InstanceIdentifier<RenderedServicePath> rspIid = InstanceIdentifier.builder(RenderedServicePaths.class)
  48                 .child(RenderedServicePath.class, renderedServicePathKey).build();
  49
  50
  51         return MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL, rspIid).toJavaUtil();
  52     }
  53
  54     public Optional<RenderedServicePath> getRenderedServicePathFromSfc(String sfcName) {
  55         Optional<RenderedServicePath> rsp = Optional.empty();
  56
  57         // TODO need to finish this
  58
  59         return rsp;
  60     }
  61
  62     // This is for Logical SFFs
  63     public Optional<String> getFirstHopSfInterfaceFromRsp(RenderedServicePath rsp) {
  64         Optional<RenderedServicePathHop> firstHop = getRspFirstHop(rsp);
  65         if (!firstHop.isPresent()) {
  66             LOG.warn("getFirstHopSfInterfaceFromRsp RSP [{}] cant get first hop", rsp.getName().getValue());
  67             return Optional.empty();
  68         }
  69
  70         SfName sfName = firstHop.get().getServiceFunctionName();
  71         if (sfName == null) {
  72             LOG.warn("getFirstHopSfInterfaceFromRsp RSP [{}] first hop has no SF", rsp.getName().getValue());
  73             return Optional.empty();
  74         }
  75
  76         Optional<ServiceFunction> sf = getServiceFunction(sfName);
  77         if (!sf.isPresent()) {
  78             LOG.warn("getFirstHopSfInterfaceFromRsp RSP [{}] SF [{}] does not exist", rsp.getName().getValue(),
  79                     sfName.getValue());
  80             return Optional.empty();
  81         }
  82
  83         List<SfDataPlaneLocator> sfDplList = sf.get().getSfDataPlaneLocator();
  84         if (sfDplList == null || sfDplList.isEmpty()) {
  85             LOG.warn("getFirstHopSfInterfaceFromRsp RSP [{}] SF [{}] has no SfDpl", rsp.getName().getValue(),
  86                     sfName.getValue());
  87             return Optional.empty();
  88         }
  89
  90         // Get the first LogicalInterface locator, if there is one
  91         for (SfDataPlaneLocator sfDpl : sfDplList) {
  92             if (sfDpl.getLocatorType() instanceof LogicalInterface) {
  93                 LogicalInterfaceLocator locator = (LogicalInterfaceLocator) sfDpl.getLocatorType();
  94                 if (locator != null) {
  95                     return Optional.ofNullable(locator.getInterfaceName());
  96                 }
  97             }
  98         }
  99
 100         return Optional.empty();
 101     }
 102
 103     private Optional<ServiceFunction> getServiceFunction(SfName name) {
 104         ServiceFunctionKey serviceFunctionKey = new ServiceFunctionKey(new SfName(name));
 105         InstanceIdentifier<ServiceFunction> sfIid = InstanceIdentifier.builder(ServiceFunctions.class)
 106                 .child(ServiceFunction.class, serviceFunctionKey).build();
 107
 108         return MDSALUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, sfIid).toJavaUtil();
 109     }
 110
 111     private Optional<RenderedServicePathHop> getRspFirstHop(RenderedServicePath rsp) {
 112         List<RenderedServicePathHop> hops = rsp.getRenderedServicePathHop();
 113         if (hops == null || hops.isEmpty()) {
 114             LOG.warn("getRspFirstHop RSP [{}] has no hops list", rsp.getName().getValue());
 115             return Optional.empty();
 116         }
 117
 118         return Optional.ofNullable(hops.get(0));
 119     }
 120 }