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 static io.fd.honeycomb.v3po.translate.v3po.initializers.SubInterfaceInitializationUtils.initializeSubinterfaceStateAugmentation;
  20
  21 import com.google.common.base.Preconditions;
  22 import com.google.common.collect.Lists;
  23 import io.fd.honeycomb.v3po.vpp.data.init.AbstractDataTreeConverter;
  24 import java.util.List;
  25 import java.util.stream.Collectors;
  26 import javax.annotation.Nonnull;
  27 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.AdminStatus;
  35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.Interface1;
  36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.Interface1Builder;
  37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.Interface2;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.Ipv4Builder;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.ipv4.address.Subnet;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.ipv4.address.subnet.PrefixLengthBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces.state._interface.Ipv4;
  42 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces.state._interface.ipv4.Address;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentation;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentationBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentation;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanGpeVni;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanVni;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.EthernetBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.L2Builder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.TapBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VhostUserBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanGpeBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Ethernet;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Tap;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.VhostUser;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Vxlan;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.VxlanGpe;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.Interconnection;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBased;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBasedBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.XconnectBased;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.XconnectBasedBuilder;
  65 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  66 import org.slf4j.Logger;
  67 import org.slf4j.LoggerFactory;
  68
  69 /**
  70  * Initializes ietf-interfaces config data based on operational state
  71  */
  72 public class InterfacesInitializer extends AbstractDataTreeConverter<InterfacesState, Interfaces> {
  73     private static final Logger LOG = LoggerFactory.getLogger(InterfacesInitializer.class);
  74
  75     public InterfacesInitializer(@Nonnull final DataBroker bindingDataBroker) {
  76         super(bindingDataBroker, InstanceIdentifier.create(InterfacesState.class),
  77                 InstanceIdentifier.create(Interfaces.class));
  78     }
  79
  80     @Override
  81     protected Interfaces convert(final InterfacesState operationalData) {
  82         LOG.debug("InterfacesInitializer.convert()");
  83         InterfacesBuilder interfacesBuilder = new InterfacesBuilder();
  84         interfacesBuilder
  85             .setInterface(Lists.transform(operationalData.getInterface(), InterfacesInitializer::initialize));
  86         return interfacesBuilder.build();
  87     }
  88
  89     // FIXME https://jira.fd.io/browse/HONEYCOMB-73 this kind of initialization/transformation is bad
  90     // There is no relation to readers, it cannot be extended (readers can) and its hard to keep in sync with readers
  91
  92     // TODO add IP v4/ v6 initializer
  93
  94     private static Interface initialize(
  95         final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input) {
  96         InterfaceBuilder builder = new InterfaceBuilder();
  97         builder.setKey(new InterfaceKey(input.getKey().getName()));
  98         builder.setName(input.getName());
  99         builder.setType(input.getType());
 100         builder.setEnabled(AdminStatus.Up.equals(input.getAdminStatus()));
 101         // builder.setLinkUpDownTrapEnable(); TODO not present in interfaces-state
 102
 103         initializeVppInterfaceStateAugmentation(input, builder);
 104         initializeSubinterfaceStateAugmentation(input, builder);
 105         initializeIetfIpAugmentation(input, builder);
 106
 107         return builder.build();
 108     }
 109
 110     private static void initializeVppInterfaceStateAugmentation(
 111             final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input,
 112             final InterfaceBuilder builder) {
 113         final VppInterfaceStateAugmentation vppIfcAugmentation =
 114                 input.getAugmentation(VppInterfaceStateAugmentation.class);
 115         if(vppIfcAugmentation != null) {
 116             final VppInterfaceAugmentationBuilder augmentBuilder = new VppInterfaceAugmentationBuilder();
 117             builder.setDescription(vppIfcAugmentation.getDescription());
 118
 119             final Vxlan vxlan = vppIfcAugmentation.getVxlan();
 120             if(vxlan != null) {
 121                 setVxlan(augmentBuilder, vxlan);
 122             }
 123
 124             final VxlanGpe vxlanGpe = vppIfcAugmentation.getVxlanGpe();
 125             if(vxlanGpe != null) {
 126                 setVxlanGpe(augmentBuilder, vxlanGpe);
 127             }
 128
 129             final Tap tap = vppIfcAugmentation.getTap();
 130             if(tap != null) {
 131                 setTap(input, augmentBuilder, tap);
 132             }
 133
 134             final VhostUser vhostUser = vppIfcAugmentation.getVhostUser();
 135             if(vhostUser != null) {
 136                 setVhostUser(augmentBuilder, vhostUser);
 137             }
 138
 139             final L2 l2 = vppIfcAugmentation.getL2();
 140             if(l2 != null) {
 141                 setL2(augmentBuilder, l2);
 142             }
 143
 144             final Ethernet ethernet = vppIfcAugmentation.getEthernet();
 145             if(ethernet != null) {
 146                 setEthernet(augmentBuilder, ethernet);
 147             }
 148
 149             // TODO set routing, not present in interface-state
 150
 151             builder.addAugmentation(VppInterfaceAugmentation.class, augmentBuilder.build());
 152         }
 153     }
 154
 155     private static void initializeIetfIpAugmentation(
 156             final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input,
 157             final InterfaceBuilder builder) {
 158         final Interface2 ietfIpAugmentation = input.getAugmentation(Interface2.class);
 159         if(ietfIpAugmentation != null) {
 160             final Interface1Builder augmentBuilder = new Interface1Builder();
 161
 162             final Ipv4 ipv4 = ietfIpAugmentation.getIpv4();
 163             if(ipv4 != null) {
 164                 final List<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.ipv4.Address> collect =
 165                     ipv4.getAddress().stream()
 166                         .map(address -> new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.ipv4.AddressBuilder()
 167                             .setIp(address.getIp())
 168                             .setSubnet(getSubnet(address))
 169                             .build())
 170                         .collect(Collectors.toList());
 171                 augmentBuilder.setIpv4(new Ipv4Builder().setAddress(collect).build());
 172             }
 173
 174             // TODO ipv6
 175
 176             builder.addAugmentation(Interface1.class, augmentBuilder.build());
 177         }
 178     }
 179
 180     private static Subnet getSubnet(final Address address) {
 181         final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces.state._interface.ipv4.address.Subnet
 182             subnet = address.getSubnet();
 183
 184         // TODO only prefix length supported
 185         Preconditions.checkArgument(
 186             subnet instanceof org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces.state._interface.ipv4.address.subnet.PrefixLength);
 187
 188         return new PrefixLengthBuilder().setPrefixLength(
 189             ((org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces.state._interface.ipv4.address.subnet.PrefixLength) subnet)
 190                 .getPrefixLength()).build();
 191     }
 192
 193     private static void setEthernet(final VppInterfaceAugmentationBuilder augmentBuilder, final Ethernet ethernet) {
 194         final EthernetBuilder ethernetBuilder = new EthernetBuilder();
 195         ethernetBuilder.setMtu(ethernet.getMtu());
 196         augmentBuilder.setEthernet(ethernetBuilder.build());
 197     }
 198
 199     private static void setL2(final VppInterfaceAugmentationBuilder augmentBuilder, final L2 l2) {
 200         final L2Builder l2Builder = new L2Builder();
 201
 202         final Interconnection interconnection = l2.getInterconnection();
 203         if(interconnection != null) {
 204             if (interconnection instanceof XconnectBased) {
 205                 final XconnectBasedBuilder xconnectBasedBuilder = new XconnectBasedBuilder();
 206                 xconnectBasedBuilder.setXconnectOutgoingInterface(
 207                     ((XconnectBased) interconnection).getXconnectOutgoingInterface());
 208                 l2Builder.setInterconnection(xconnectBasedBuilder.build());
 209             } else if (interconnection instanceof BridgeBased) {
 210                 final BridgeBasedBuilder bridgeBasedBuilder = new BridgeBasedBuilder();
 211                 bridgeBasedBuilder.setBridgeDomain(((BridgeBased) interconnection).getBridgeDomain());
 212                 bridgeBasedBuilder
 213                     .setBridgedVirtualInterface(((BridgeBased) interconnection).isBridgedVirtualInterface());
 214                 bridgeBasedBuilder.setSplitHorizonGroup(((BridgeBased) interconnection).getSplitHorizonGroup());
 215                 l2Builder.setInterconnection(bridgeBasedBuilder.build());
 216             }
 217         }
 218
 219         augmentBuilder.setL2(l2Builder.build());
 220     }
 221
 222     private static void setVhostUser(final VppInterfaceAugmentationBuilder augmentBuilder, final VhostUser vhostUser) {
 223         final VhostUserBuilder vhostUserBuilder = new VhostUserBuilder();
 224         vhostUserBuilder.setRole(vhostUser.getRole());
 225         vhostUserBuilder.setSocket(vhostUser.getSocket());
 226         augmentBuilder.setVhostUser(vhostUserBuilder.build());
 227     }
 228
 229     private static void setTap(
 230         final @Nonnull org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface input,
 231         final VppInterfaceAugmentationBuilder augmentBuilder,
 232         final Tap tap) {
 233         final TapBuilder tapBuilder = new TapBuilder();
 234         tapBuilder.setMac(input.getPhysAddress());
 235         tapBuilder.setTapName(tap.getTapName());
 236 //                            tapBuilder.setDeviceInstance();
 237         augmentBuilder.setTap(tapBuilder.build());
 238     }
 239
 240     private static void setVxlan(final VppInterfaceAugmentationBuilder augmentBuilder, final Vxlan vxlan) {
 241         final VxlanBuilder vxlanBuilder = new VxlanBuilder();
 242         vxlanBuilder.setDst(vxlan.getDst());
 243         vxlanBuilder.setSrc(vxlan.getSrc());
 244         vxlanBuilder.setEncapVrfId(vxlan.getEncapVrfId());
 245         vxlanBuilder.setVni(new VxlanVni(vxlan.getVni()));
 246         augmentBuilder.setVxlan(vxlanBuilder.build());
 247     }
 248
 249     private static void setVxlanGpe(final VppInterfaceAugmentationBuilder augmentBuilder, final VxlanGpe vxlanGpe) {
 250         final VxlanGpeBuilder vxlanGpeBuilder = new VxlanGpeBuilder();
 251         vxlanGpeBuilder.setLocal(vxlanGpe.getLocal());
 252         vxlanGpeBuilder.setRemote(vxlanGpe.getRemote());
 253         vxlanGpeBuilder.setVni(new VxlanGpeVni(vxlanGpe.getVni()));
 254         vxlanGpeBuilder.setNextProtocol(vxlanGpe.getNextProtocol());
 255         vxlanGpeBuilder.setEncapVrfId(vxlanGpe.getEncapVrfId());
 256         vxlanGpeBuilder.setDecapVrfId(vxlanGpe.getDecapVrfId());
 257         augmentBuilder.setVxlanGpe(vxlanGpeBuilder.build());
 258     }
 259 }