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