gerrit.fd Code Review - honeycomb.git/blob

   1 /*
   2  * Copyright (c) 2016 Cisco and/or its affiliates.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at:
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package io.fd.honeycomb.v3po.translate.v3po.initializers;
  18
  19 import com.google.common.collect.Lists;
  20 import io.fd.honeycomb.v3po.vpp.data.init.AbstractDataTreeConverter;
  21 import javax.annotation.Nonnull;
  22 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.AdminStatus;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentation;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentationBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentation;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanVni;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanGpeVni;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.EthernetBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.L2Builder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.SubInterfaceBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.TapBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VhostUserBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanGpeBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.l2.VlanTagRewriteBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Ethernet;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.SubInterface;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Tap;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.VhostUser;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Vxlan;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.VxlanGpe;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.l2.VlanTagRewrite;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.Interconnection;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBased;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBasedBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.XconnectBased;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.XconnectBasedBuilder;
  56 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  57 import org.slf4j.Logger;
  58 import org.slf4j.LoggerFactory;
  59
  60 /**
  61  * Initializes ietf-interfaces config data based on operational state
  62  */
  63 public class InterfacesInitializer extends AbstractDataTreeConverter<InterfacesState, Interfaces> {
  64     private static final Logger LOG = LoggerFactory.getLogger(InterfacesInitializer.class);
  65
  66     public InterfacesInitializer(@Nonnull final DataBroker bindingDataBroker) {
  67         super(bindingDataBroker, InstanceIdentifier.create(InterfacesState.class),
  68                 InstanceIdentifier.create(Interfaces.class));
  69     }
  70
  71     @Override
  72     protected Interfaces convert(final InterfacesState operationalData) {
  73         LOG.debug("InterfacesInitializer.convert()");
  74         InterfacesBuilder interfacesBuilder = new InterfacesBuilder();
  75         interfacesBuilder
  76             .setInterface(Lists.transform(operationalData.getInterface(), InterfacesInitializer::initialize));
  77         return interfacesBuilder.build();
  78     }
  79
  80     // FIXME https://jira.fd.io/browse/HONEYCOMB-73 this kind of initialization/transformation is bad
  81     // There is no relation to readers, it cannot be extended (readers can) and its hard to keep in sync with readers
  82
  83     // TODO add IP v4/ v6 initializer
  84
  85     private static Interface initialize(
  86         final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input) {
  87         InterfaceBuilder builder = new InterfaceBuilder();
  88         builder.setKey(new InterfaceKey(input.getKey().getName()));
  89         builder.setName(input.getName());
  90         builder.setType(input.getType());
  91         builder.setEnabled(AdminStatus.Up.equals(input.getAdminStatus()));
  92         // builder.setLinkUpDownTrapEnable(); not present in interfaces-state
  93
  94         final VppInterfaceStateAugmentation vppIfcAugmentation =
  95             input.getAugmentation(VppInterfaceStateAugmentation.class);
  96         if(vppIfcAugmentation != null) {
  97             final VppInterfaceAugmentationBuilder augmentBuilder = new VppInterfaceAugmentationBuilder();
  98             builder.setDescription(vppIfcAugmentation.getDescription());
  99
 100             final Vxlan vxlan = vppIfcAugmentation.getVxlan();
 101             if(vxlan != null) {
 102                 setVxlan(augmentBuilder, vxlan);
 103             }
 104
 105             final VxlanGpe vxlanGpe = vppIfcAugmentation.getVxlanGpe();
 106             if(vxlanGpe != null) {
 107                 setVxlanGpe(augmentBuilder, vxlanGpe);
 108             }
 109
 110             final Tap tap = vppIfcAugmentation.getTap();
 111             if(tap != null) {
 112                 setTap(input, augmentBuilder, tap);
 113             }
 114
 115             final VhostUser vhostUser = vppIfcAugmentation.getVhostUser();
 116             if(vhostUser != null) {
 117                 setVhostUser(augmentBuilder, vhostUser);
 118             }
 119
 120             final L2 l2 = vppIfcAugmentation.getL2();
 121             if(l2 != null) {
 122                 setL2(augmentBuilder, l2);
 123             }
 124
 125             final SubInterface subInterface = vppIfcAugmentation.getSubInterface();
 126             if(subInterface != null) {
 127                 setSubinterface(augmentBuilder, subInterface);
 128             }
 129
 130             final Ethernet ethernet = vppIfcAugmentation.getEthernet();
 131             if(ethernet != null) {
 132                 setEthernet(augmentBuilder, ethernet);
 133             }
 134
 135             // TODO set routing, not present in interface-state
 136
 137             builder.addAugmentation(VppInterfaceAugmentation.class, augmentBuilder.build());
 138         }
 139
 140         return builder.build();
 141     }
 142
 143     private static void setSubinterface(final VppInterfaceAugmentationBuilder augmentBuilder,
 144                                         final SubInterface subInterface) {
 145         final SubInterfaceBuilder subIfcBuilder = new SubInterfaceBuilder();
 146
 147         if(subInterface.isDefaultSubif() != null) {
 148             subIfcBuilder.setDefaultSubif(subInterface.isDefaultSubif());
 149         }
 150         if(subInterface.isExactMatch() != null) {
 151             subIfcBuilder.setExactMatch(subInterface.isExactMatch());
 152         }
 153         if(subInterface.isMatchAnyInnerId() != null) {
 154             subIfcBuilder.setMatchAnyInnerId(subInterface.isMatchAnyInnerId());
 155         }
 156         if(subInterface.isMatchAnyOuterId() != null) {
 157             subIfcBuilder.setMatchAnyOuterId(subInterface.isMatchAnyOuterId());
 158         }
 159
 160         subIfcBuilder.setIdentifier(subInterface.getIdentifier());
 161         subIfcBuilder.setInnerId(subInterface.getInnerId());
 162         subIfcBuilder.setNumberOfTags(subInterface.getNumberOfTags());
 163         subIfcBuilder.setOuterId(subInterface.getOuterId());
 164         subIfcBuilder.setSuperInterface(subInterface.getSuperInterface());
 165         subIfcBuilder.setVlanType(subInterface.getVlanType());
 166
 167         augmentBuilder.setSubInterface(subIfcBuilder.build());
 168     }
 169
 170     private static void setEthernet(final VppInterfaceAugmentationBuilder augmentBuilder, final Ethernet ethernet) {
 171         final EthernetBuilder ethernetBuilder = new EthernetBuilder();
 172         ethernetBuilder.setMtu(ethernet.getMtu());
 173         augmentBuilder.setEthernet(ethernetBuilder.build());
 174     }
 175
 176     private static void setL2(final VppInterfaceAugmentationBuilder augmentBuilder, final L2 l2) {
 177         final L2Builder l2Builder = new L2Builder();
 178
 179         final Interconnection interconnection = l2.getInterconnection();
 180         if(interconnection != null) {
 181             if (interconnection instanceof XconnectBased) {
 182                 final XconnectBasedBuilder xconnectBasedBuilder = new XconnectBasedBuilder();
 183                 xconnectBasedBuilder.setXconnectOutgoingInterface(
 184                     ((XconnectBased) interconnection).getXconnectOutgoingInterface());
 185                 l2Builder.setInterconnection(xconnectBasedBuilder.build());
 186             } else if (interconnection instanceof BridgeBased) {
 187                 final BridgeBasedBuilder bridgeBasedBuilder = new BridgeBasedBuilder();
 188                 bridgeBasedBuilder.setBridgeDomain(((BridgeBased) interconnection).getBridgeDomain());
 189                 bridgeBasedBuilder
 190                     .setBridgedVirtualInterface(((BridgeBased) interconnection).isBridgedVirtualInterface());
 191                 bridgeBasedBuilder.setSplitHorizonGroup(((BridgeBased) interconnection).getSplitHorizonGroup());
 192                 l2Builder.setInterconnection(bridgeBasedBuilder.build());
 193             }
 194         }
 195
 196         final VlanTagRewrite vlanTagRewrite = l2.getVlanTagRewrite();
 197         if(vlanTagRewrite != null) {
 198             final VlanTagRewriteBuilder vlanTagRewriteBuilder = new VlanTagRewriteBuilder();
 199             vlanTagRewriteBuilder.setFirstPushed(vlanTagRewrite.getFirstPushed());
 200             vlanTagRewriteBuilder.setRewriteOperation(vlanTagRewrite.getRewriteOperation());
 201             vlanTagRewriteBuilder.setTag1(vlanTagRewrite.getTag1());
 202             vlanTagRewriteBuilder.setTag2(vlanTagRewrite.getTag2());
 203             l2Builder.setVlanTagRewrite(vlanTagRewriteBuilder.build());
 204         }
 205
 206         augmentBuilder.setL2(l2Builder.build());
 207     }
 208
 209     private static void setVhostUser(final VppInterfaceAugmentationBuilder augmentBuilder, final VhostUser vhostUser) {
 210         final VhostUserBuilder vhostUserBuilder = new VhostUserBuilder();
 211         vhostUserBuilder.setRole(vhostUser.getRole());
 212         vhostUserBuilder.setSocket(vhostUser.getSocket());
 213         augmentBuilder.setVhostUser(vhostUserBuilder.build());
 214     }
 215
 216     private static void setTap(
 217         final @Nonnull org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input,
 218         final VppInterfaceAugmentationBuilder augmentBuilder,
 219         final Tap tap) {
 220         final TapBuilder tapBuilder = new TapBuilder();
 221         tapBuilder.setMac(input.getPhysAddress());
 222         tapBuilder.setTapName(tap.getTapName());
 223 //                            tapBuilder.setDeviceInstance();
 224         augmentBuilder.setTap(tapBuilder.build());
 225     }
 226
 227     private static void setVxlan(final VppInterfaceAugmentationBuilder augmentBuilder, final Vxlan vxlan) {
 228         final VxlanBuilder vxlanBuilder = new VxlanBuilder();
 229         vxlanBuilder.setDst(vxlan.getDst());
 230         vxlanBuilder.setSrc(vxlan.getSrc());
 231         vxlanBuilder.setEncapVrfId(vxlan.getEncapVrfId());
 232         vxlanBuilder.setVni(new VxlanVni(vxlan.getVni()));
 233         augmentBuilder.setVxlan(vxlanBuilder.build());
 234     }
 235
 236     private static void setVxlanGpe(final VppInterfaceAugmentationBuilder augmentBuilder, final VxlanGpe vxlanGpe) {
 237         final VxlanGpeBuilder vxlanGpeBuilder = new VxlanGpeBuilder();
 238         vxlanGpeBuilder.setLocal(vxlanGpe.getLocal());
 239         vxlanGpeBuilder.setRemote(vxlanGpe.getRemote());
 240         vxlanGpeBuilder.setVni(new VxlanGpeVni(vxlanGpe.getVni()));
 241         vxlanGpeBuilder.setNextProtocol(vxlanGpe.getNextProtocol());
 242         vxlanGpeBuilder.setEncapVrfId(vxlanGpe.getEncapVrfId());
 243         vxlanGpeBuilder.setDecapVrfId(vxlanGpe.getDecapVrfId());
 244         augmentBuilder.setVxlanGpe(vxlanGpeBuilder.build());
 245     }
 246 }