/* * Copyright (c) 2016 Brocade Communications Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.netvirt.openstack.sfc.translator.portchain; import com.google.common.base.Preconditions; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfcName; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfpName; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.CreateRenderedPathInput; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.CreateRenderedPathInputBuilder; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.DeleteRenderedPathInput; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.DeleteRenderedPathInputBuilder; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sf.rev140701.service.functions.ServiceFunction; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.ServiceFunctionChain; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.ServiceFunctionChainBuilder; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.ServiceFunctionChainKey; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.service.function.chain.SfcServiceFunction; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.service.function.chain.SfcServiceFunctionBuilder; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfc.rev140701.service.function.chain.grouping.service.function.chain.SfcServiceFunctionKey; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPath; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPathBuilder; import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPathKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.sfc.rev160511.port.chain.attributes.ChainParameters; import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.sfc.rev160511.sfc.attributes.port.chains.PortChain; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.ArrayList; import java.util.List; /** * Class will convert OpenStack Port Chain API yang models present in * neutron northbound project to OpenDaylight SFC yang models. */ public class PortChainTranslator { private static final Logger LOG = LoggerFactory.getLogger(PortChainTranslator.class); private static final String SYMMETRIC_PARAM = "symmetric"; private static final String SFP_NAME_PREFIX = "Path-"; public static ServiceFunctionChain buildServiceFunctionChain( PortChain portChain, List sfList) { ServiceFunctionChainBuilder sfcBuilder = new ServiceFunctionChainBuilder(); sfcBuilder.setName(new SfcName(portChain.getName())); sfcBuilder.setKey(new ServiceFunctionChainKey(sfcBuilder.getName())); //By default set it to false. If user specify it in chain parameters, it //will be overridden. sfcBuilder.setSymmetric(false); //Set service functions List sfcSfList = new ArrayList<>(); for(ServiceFunction sf : sfList) { SfcServiceFunctionBuilder sfcSfBuilder = new SfcServiceFunctionBuilder(); sfcSfBuilder.setName(sf.getName().getValue()); sfcSfBuilder.setType(sf.getType()); sfcSfBuilder.setKey(new SfcServiceFunctionKey(sfcSfBuilder.getName())); //NOTE: no explicit order is set. sfcSfList.add(sfcSfBuilder.build()); } List cpList = portChain.getChainParameters(); if (cpList != null && !cpList.isEmpty()) { for (ChainParameters cp : cpList) { if(cp.getChainParameter().equals(SYMMETRIC_PARAM)) { //Override the symmetric default value. sfcBuilder.setSymmetric(new Boolean(cp.getChainParameterValue())); break; } } } sfcBuilder.setSfcServiceFunction(sfcSfList); return sfcBuilder.build(); } public static ServiceFunctionPath buildServiceFunctionPath(ServiceFunctionChain sfc) { Preconditions.checkNotNull(sfc, "Service Function Chain must not be null"); ServiceFunctionPathBuilder sfpBuilder = new ServiceFunctionPathBuilder(); //Set the name sfpBuilder.setName(new SfpName(SFP_NAME_PREFIX + sfc.getName().getValue())); sfpBuilder.setSymmetric(sfc.isSymmetric()); //Set related SFC name sfpBuilder.setServiceChainName(sfc.getName()); return sfpBuilder.build(); } public static CreateRenderedPathInput buildCreateRenderedServicePathInput(ServiceFunctionPath sfp) { CreateRenderedPathInputBuilder rpInputBuilder = new CreateRenderedPathInputBuilder(); rpInputBuilder.setName(sfp.getName().getValue()); rpInputBuilder.setSymmetric(sfp.isSymmetric()); rpInputBuilder.setParentServiceFunctionPath(sfp.getName().getValue()); return rpInputBuilder.build(); } public static DeleteRenderedPathInput buildDeleteRenderedServicePathInput(ServiceFunctionPathKey sfpKey) { DeleteRenderedPathInputBuilder rpInputBuilder = new DeleteRenderedPathInputBuilder(); rpInputBuilder.setName(sfpKey.getName().getValue()); return rpInputBuilder.build(); } public static ServiceFunctionChainKey getSFCKey(PortChain portChain) { return new ServiceFunctionChainKey(new SfcName(portChain.getName())); } public static ServiceFunctionPathKey getSFPKey(PortChain portChain) { return new ServiceFunctionPathKey(new SfpName(SFP_NAME_PREFIX + portChain.getName())); } }