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