gerrit.fd Code Review - hc2vpp.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.interfaces._interface.EthernetBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.L2Builder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.SubInterfaceBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.TapBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VhostUserBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.l2.VlanTagRewriteBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.l2.interconnection.BridgeBasedBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.l2.interconnection.XconnectBasedBuilder;
  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.l2.Interconnection;
  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.interfaces.state._interface.l2.interconnection.BridgeBased;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.l2.interconnection.XconnectBased;
  53 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  54 import org.slf4j.Logger;
  55 import org.slf4j.LoggerFactory;
  56
  57 /**
  58  * Initializes ietf-interfaces config data based on operational state
  59  */
  60 public class InterfacesInitializer extends AbstractDataTreeConverter<InterfacesState, Interfaces> {
  61     private static final Logger LOG = LoggerFactory.getLogger(InterfacesInitializer.class);
  62
  63     public InterfacesInitializer(@Nonnull final DataBroker bindingDataBroker) {
  64         super(bindingDataBroker, InstanceIdentifier.create(InterfacesState.class),
  65                 InstanceIdentifier.create(Interfaces.class));
  66     }
  67
  68     @Override
  69     protected Interfaces convert(final InterfacesState operationalData) {
  70         LOG.debug("InterfacesInitializer.convert()");
  71         InterfacesBuilder interfacesBuilder = new InterfacesBuilder();
  72         interfacesBuilder
  73             .setInterface(Lists.transform(operationalData.getInterface(), InterfacesInitializer::initialize));
  74         return interfacesBuilder.build();
  75     }
  76
  77     // FIXME this kind of initialization/transformation is bad
  78     // There is no relation to readers, it cannot be extended (readers can) and its hard to keep in sync with readers
  79
  80     // TODO add IP v4/ v6 initializer
  81
  82     private static Interface initialize(
  83         final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input) {
  84         InterfaceBuilder builder = new InterfaceBuilder();
  85         builder.setKey(new InterfaceKey(input.getKey().getName()));
  86         builder.setName(input.getName());
  87         builder.setType(input.getType());
  88         builder.setEnabled(AdminStatus.Up.equals(input.getAdminStatus()));
  89         // builder.setLinkUpDownTrapEnable(); not present in interfaces-state
  90
  91         final VppInterfaceStateAugmentation vppIfcAugmentation =
  92             input.getAugmentation(VppInterfaceStateAugmentation.class);
  93         if(vppIfcAugmentation != null) {
  94             final VppInterfaceAugmentationBuilder augmentBuilder = new VppInterfaceAugmentationBuilder();
  95             builder.setDescription(vppIfcAugmentation.getDescription());
  96
  97             final Vxlan vxlan = vppIfcAugmentation.getVxlan();
  98             if(vxlan != null) {
  99                 setVxlan(augmentBuilder, vxlan);
 100             }
 101
 102             final Tap tap = vppIfcAugmentation.getTap();
 103             if(tap != null) {
 104                 setTap(input, augmentBuilder, tap);
 105             }
 106
 107             final VhostUser vhostUser = vppIfcAugmentation.getVhostUser();
 108             if(vhostUser != null) {
 109                 setVhostUser(augmentBuilder, vhostUser);
 110             }
 111
 112             final L2 l2 = vppIfcAugmentation.getL2();
 113             if(l2 != null) {
 114                 setL2(augmentBuilder, l2);
 115             }
 116
 117             final SubInterface subInterface = vppIfcAugmentation.getSubInterface();
 118             if(subInterface != null) {
 119                 setSubinterface(augmentBuilder, subInterface);
 120             }
 121
 122             final Ethernet ethernet = vppIfcAugmentation.getEthernet();
 123             if(ethernet != null) {
 124                 setEthernet(augmentBuilder, ethernet);
 125             }
 126
 127             // TODO set routing, not present in interface-state
 128
 129             builder.addAugmentation(VppInterfaceAugmentation.class, augmentBuilder.build());
 130         }
 131
 132         return builder.build();
 133     }
 134
 135     private static void setSubinterface(final VppInterfaceAugmentationBuilder augmentBuilder,
 136                                         final SubInterface subInterface) {
 137         final SubInterfaceBuilder subIfcBuilder = new SubInterfaceBuilder();
 138
 139         if(subInterface.isDefaultSubif() != null) {
 140             subIfcBuilder.setDefaultSubif(subInterface.isDefaultSubif());
 141         }
 142         if(subInterface.isExactMatch() != null) {
 143             subIfcBuilder.setExactMatch(subInterface.isExactMatch());
 144         }
 145         if(subInterface.isMatchAnyInnerId() != null) {
 146             subIfcBuilder.setMatchAnyInnerId(subInterface.isMatchAnyInnerId());
 147         }
 148         if(subInterface.isMatchAnyOuterId() != null) {
 149             subIfcBuilder.setMatchAnyOuterId(subInterface.isMatchAnyOuterId());
 150         }
 151
 152         subIfcBuilder.setIdentifier(subInterface.getIdentifier());
 153         subIfcBuilder.setInnerId(subInterface.getInnerId());
 154         subIfcBuilder.setNumberOfTags(subInterface.getNumberOfTags());
 155         subIfcBuilder.setOuterId(subInterface.getOuterId());
 156         subIfcBuilder.setSuperInterface(subInterface.getSuperInterface());
 157         subIfcBuilder.setVlanType(subInterface.getVlanType());
 158
 159         augmentBuilder.setSubInterface(subIfcBuilder.build());
 160     }
 161
 162     private static void setEthernet(final VppInterfaceAugmentationBuilder augmentBuilder, final Ethernet ethernet) {
 163         final EthernetBuilder ethernetBuilder = new EthernetBuilder();
 164         ethernetBuilder.setMtu(ethernet.getMtu());
 165         augmentBuilder.setEthernet(ethernetBuilder.build());
 166     }
 167
 168     private static void setL2(final VppInterfaceAugmentationBuilder augmentBuilder, final L2 l2) {
 169         final L2Builder l2Builder = new L2Builder();
 170
 171         final Interconnection interconnection = l2.getInterconnection();
 172         if(interconnection != null) {
 173             if (interconnection instanceof XconnectBased) {
 174                 final XconnectBasedBuilder xconnectBasedBuilder = new XconnectBasedBuilder();
 175                 xconnectBasedBuilder.setXconnectOutgoingInterface(
 176                     ((XconnectBased) interconnection).getXconnectOutgoingInterface());
 177                 l2Builder.setInterconnection(xconnectBasedBuilder.build());
 178             } else if (interconnection instanceof BridgeBased) {
 179                 final BridgeBasedBuilder bridgeBasedBuilder = new BridgeBasedBuilder();
 180                 bridgeBasedBuilder.setBridgeDomain(((BridgeBased) interconnection).getBridgeDomain());
 181                 bridgeBasedBuilder
 182                     .setBridgedVirtualInterface(((BridgeBased) interconnection).isBridgedVirtualInterface());
 183                 bridgeBasedBuilder.setSplitHorizonGroup(((BridgeBased) interconnection).getSplitHorizonGroup());
 184                 l2Builder.setInterconnection(bridgeBasedBuilder.build());
 185             }
 186         }
 187
 188         final VlanTagRewrite vlanTagRewrite = l2.getVlanTagRewrite();
 189         if(vlanTagRewrite != null) {
 190             final VlanTagRewriteBuilder vlanTagRewriteBuilder = new VlanTagRewriteBuilder();
 191             vlanTagRewriteBuilder.setFirstPushed(vlanTagRewrite.getFirstPushed());
 192             vlanTagRewriteBuilder.setRewriteOperation(vlanTagRewrite.getRewriteOperation());
 193             vlanTagRewriteBuilder.setTag1(vlanTagRewrite.getTag1());
 194             vlanTagRewriteBuilder.setTag2(vlanTagRewrite.getTag2());
 195             l2Builder.setVlanTagRewrite(vlanTagRewriteBuilder.build());
 196         }
 197
 198         augmentBuilder.setL2(l2Builder.build());
 199     }
 200
 201     private static void setVhostUser(final VppInterfaceAugmentationBuilder augmentBuilder, final VhostUser vhostUser) {
 202         final VhostUserBuilder vhostUserBuilder = new VhostUserBuilder();
 203         vhostUserBuilder.setRole(vhostUser.getRole());
 204         vhostUserBuilder.setSocket(vhostUser.getSocket());
 205         augmentBuilder.setVhostUser(vhostUserBuilder.build());
 206     }
 207
 208     private static void setTap(
 209         final @Nonnull org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input,
 210         final VppInterfaceAugmentationBuilder augmentBuilder,
 211         final Tap tap) {
 212         final TapBuilder tapBuilder = new TapBuilder();
 213         tapBuilder.setMac(input.getPhysAddress());
 214         tapBuilder.setTapName(tap.getTapName());
 215 //                            tapBuilder.setDeviceInstance();
 216         augmentBuilder.setTap(tapBuilder.build());
 217     }
 218
 219     private static void setVxlan(final VppInterfaceAugmentationBuilder augmentBuilder, final Vxlan vxlan) {
 220         final VxlanBuilder vxlanBuilder = new VxlanBuilder();
 221         vxlanBuilder.setDst(vxlan.getDst());
 222         vxlanBuilder.setSrc(vxlan.getSrc());
 223         vxlanBuilder.setEncapVrfId(vxlan.getEncapVrfId());
 224         vxlanBuilder.setVni(new VxlanVni(vxlan.getVni()));
 225         augmentBuilder.setVxlan(vxlanBuilder.build());
 226     }
 227 }