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 java.util.stream.Collectors;
  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.cisco.params.xml.ns.yang.sfc.common.rev151017.RspName;
  20 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfName;
  21 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfpName;
  22 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.RenderedServicePaths;
  23 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePath;
  24 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePathKey;
  25 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.rendered.service.path.RenderedServicePathHop;
  26 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.ServiceFunctions;
  27 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.function.base.SfDataPlaneLocator;
  28 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.functions.ServiceFunction;
  29 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.functions.ServiceFunctionKey;
  30 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.ServiceFunctionPathsState;
  31 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.state.ServiceFunctionPathState;
  32 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.state.ServiceFunctionPathStateKey;
  33 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.sfc.sff.logical.rev160620.LogicalInterfaceLocator;
  34 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;
  35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 @Singleton
  40 public class SfcProvider {
  41
  42     private static final Logger LOG = LoggerFactory.getLogger(SfcProvider.class);
  43     private final DataBroker dataBroker;
  44
  45     @Inject
  46     public SfcProvider(final DataBroker dataBroker) {
  47         this.dataBroker = dataBroker;
  48     }
  49
  50     public Optional<RenderedServicePath> getRenderedServicePath(String rspName) {
  51         RenderedServicePathKey renderedServicePathKey = new RenderedServicePathKey(new RspName(rspName));
  52         InstanceIdentifier<RenderedServicePath> rspIid = InstanceIdentifier.builder(RenderedServicePaths.class)
  53                 .child(RenderedServicePath.class, renderedServicePathKey).build();
  54
  55
  56         return MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL, rspIid).toJavaUtil();
  57     }
  58
  59     public Optional<RenderedServicePath> getRenderedServicePathFromSfc(String sfcName) {
  60         Optional<RenderedServicePath> rsp = Optional.empty();
  61
  62         // TODO need to finish this
  63
  64         return rsp;
  65     }
  66
  67     public Optional<List<String>> readServicePathState(String sfpName) {
  68         ServiceFunctionPathStateKey serviceFunctionPathStateKey = new ServiceFunctionPathStateKey(new SfpName(sfpName));
  69         InstanceIdentifier<ServiceFunctionPathState> sfpIiD;
  70         sfpIiD = InstanceIdentifier.builder(ServiceFunctionPathsState.class)
  71                 .child(ServiceFunctionPathState.class, serviceFunctionPathStateKey)
  72                 .build();
  73         return MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL, sfpIiD)
  74                 .toJavaUtil()
  75                 .map(ServiceFunctionPathState::getSfpRenderedServicePath)
  76                 .map(sfpRenderedServicePaths -> sfpRenderedServicePaths.stream()
  77                         .map(sfpRenderedServicePath -> sfpRenderedServicePath.getName().getValue())
  78                         .collect(Collectors.toList()));
  79     }
  80
  81     public Optional<String> getFirstHopSfInterfaceFromRsp(RenderedServicePath rsp) {
  82         return getRspFirstHop(rsp).flatMap(this::getHopSfInterface);
  83     }
  84
  85     public Optional<String> getLastHopSfInterfaceFromRsp(RenderedServicePath rsp) {
  86         return getRspLastHop(rsp).flatMap(this::getHopSfInterface);
  87     }
  88
  89     public Optional<String> getHopSfInterface(RenderedServicePathHop hop) {
  90
  91         LOG.trace("getHopSfInterface of hop {}", hop);
  92
  93         SfName sfName = hop.getServiceFunctionName();
  94         if (sfName == null) {
  95             LOG.warn("getHopSfInterface hop has no SF");
  96             return Optional.empty();
  97         }
  98
  99         Optional<ServiceFunction> sf = getServiceFunction(sfName);
 100         if (!sf.isPresent()) {
 101             LOG.warn("getHopSfInterface SF [{}] does not exist", sfName.getValue());
 102             return Optional.empty();
 103         }
 104
 105         List<SfDataPlaneLocator> sfDplList = sf.get().getSfDataPlaneLocator();
 106         if (sfDplList == null || sfDplList.isEmpty()) {
 107             LOG.warn("getHopSfInterface SF [{}] has no SfDpl", sfName.getValue());
 108             return Optional.empty();
 109         }
 110
 111         // Get the first LogicalInterface locator, if there is one
 112         for (SfDataPlaneLocator sfDpl : sfDplList) {
 113             if (sfDpl.getLocatorType() instanceof LogicalInterface) {
 114                 LogicalInterfaceLocator locator = (LogicalInterfaceLocator) sfDpl.getLocatorType();
 115                 if (locator != null) {
 116                     return Optional.ofNullable(locator.getInterfaceName());
 117                 }
 118             }
 119         }
 120
 121         return Optional.empty();
 122     }
 123
 124     private Optional<ServiceFunction> getServiceFunction(SfName name) {
 125         ServiceFunctionKey serviceFunctionKey = new ServiceFunctionKey(new SfName(name));
 126         InstanceIdentifier<ServiceFunction> sfIid = InstanceIdentifier.builder(ServiceFunctions.class)
 127                 .child(ServiceFunction.class, serviceFunctionKey).build();
 128
 129         return MDSALUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, sfIid).toJavaUtil();
 130     }
 131
 132     private Optional<RenderedServicePathHop> getRspFirstHop(RenderedServicePath rsp) {
 133         List<RenderedServicePathHop> hops = rsp.getRenderedServicePathHop();
 134         if (hops == null || hops.isEmpty()) {
 135             LOG.warn("getRspFirstHop RSP [{}] has no hops list", rsp.getName().getValue());
 136             return Optional.empty();
 137         }
 138
 139         return Optional.ofNullable(hops.get(0));
 140     }
 141
 142     private Optional<RenderedServicePathHop> getRspLastHop(RenderedServicePath rsp) {
 143         List<RenderedServicePathHop> hops = rsp.getRenderedServicePathHop();
 144         if (hops == null || hops.isEmpty()) {
 145             LOG.warn("getRspLastHop RSP [{}] has no hops list", rsp.getName().getValue());
 146             return Optional.empty();
 147         }
 148
 149         return Optional.ofNullable(hops.get(hops.size() - 1));
 150     }
 151 }