bgp/mvpn/src/main/java/org/opendaylight/protocol/bgp/mvpn/impl/nlri/Ipv4NlriHandler.java

   1 /*
   2  * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.protocol.bgp.mvpn.impl.nlri;
  10
  11 import io.netty.buffer.ByteBuf;
  12 import java.util.ArrayList;
  13 import java.util.List;
  14 import org.opendaylight.protocol.bgp.mvpn.spi.pojo.nlri.SimpleMvpnNlriRegistry;
  15 import org.opendaylight.protocol.bgp.parser.spi.PathIdUtil;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.mvpn.destination.MvpnDestination;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.mvpn.destination.MvpnDestinationBuilder;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationMvpnIpv4AdvertizedCase;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationMvpnIpv4AdvertizedCaseBuilder;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update.attributes.mp.reach.nlri.advertized.routes.destination.type.destination.mvpn.ipv4.advertized._case.DestinationMvpnBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update.attributes.mp.unreach.nlri.withdrawn.routes.destination.type.DestinationMvpnIpv4WithdrawnCase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update.attributes.mp.unreach.nlri.withdrawn.routes.destination.type.DestinationMvpnIpv4WithdrawnCaseBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.NlriType;
  24
  25 /**
  26  * Handles Ipv4 Family nlri.
  27  *
  28  * @author Claudio D. Gasparini
  29  */
  30 public final class Ipv4NlriHandler {
  31     private Ipv4NlriHandler() {
  32         throw new UnsupportedOperationException();
  33     }
  34
  35     static DestinationMvpnIpv4AdvertizedCase parseIpv4ReachNlri(
  36         final ByteBuf nlri,
  37         final boolean addPathSupported) {
  38         final List<MvpnDestination> dests = new ArrayList<>();
  39
  40         while (nlri.isReadable()) {
  41             final MvpnDestinationBuilder builder = new MvpnDestinationBuilder();
  42             if (addPathSupported) {
  43                 builder.setPathId(PathIdUtil.readPathId(nlri));
  44             }
  45             final NlriType type = NlriType.forValue(nlri.readUnsignedByte());
  46             final int length = nlri.readUnsignedByte();
  47             final ByteBuf nlriBuf = nlri.readSlice(length);
  48             builder.setMvpnChoice(SimpleMvpnNlriRegistry.getInstance().parseMvpn(type, nlriBuf));
  49             dests.add(builder.build());
  50         }
  51
  52         return new DestinationMvpnIpv4AdvertizedCaseBuilder()
  53             .setDestinationMvpn(new DestinationMvpnBuilder().setMvpnDestination(dests).build()).build();
  54     }
  55
  56     static DestinationMvpnIpv4WithdrawnCase parseIpv4UnreachNlri(
  57         final ByteBuf nlri,
  58         final boolean addPathSupported) {
  59         final List<MvpnDestination> dests = new ArrayList<>();
  60
  61         while (nlri.isReadable()) {
  62             final MvpnDestinationBuilder builder = new MvpnDestinationBuilder();
  63             if (addPathSupported) {
  64                 builder.setPathId(PathIdUtil.readPathId(nlri));
  65             }
  66             final NlriType type = NlriType.forValue(nlri.readUnsignedByte());
  67             final int length = nlri.readUnsignedByte();
  68             final ByteBuf nlriBuf = nlri.readSlice(length);
  69             builder.setMvpnChoice(SimpleMvpnNlriRegistry.getInstance().parseMvpn(type, nlriBuf));
  70             dests.add(builder.build());
  71         }
  72
  73         return new DestinationMvpnIpv4WithdrawnCaseBuilder().setDestinationMvpn(
  74             new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.ipv4.rev180417.update
  75                 .attributes.mp.unreach.nlri.withdrawn.routes.destination.type.destination.mvpn.ipv4
  76                 .withdrawn._case.DestinationMvpnBuilder().setMvpnDestination(dests).build()).build();
  77     }
  78
  79     public static void serializeNlri(final List<MvpnDestination> destinationList, final ByteBuf output) {
  80         for (final MvpnDestination dest : destinationList) {
  81             output.writeBytes(SimpleMvpnNlriRegistry.getInstance().serializeMvpn(dest.getMvpnChoice()));
  82         }
  83     }
  84 }