*/
package org.opendaylight.protocol.bgp.l3vpn;
-import com.google.common.base.Optional;
+import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableCollection;
import com.google.common.collect.ImmutableSet;
import io.netty.buffer.ByteBuf;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
+import java.util.Optional;
import java.util.stream.Collectors;
-import javax.annotation.Nonnull;
+import org.opendaylight.bgp.concepts.RouteDistinguisherUtil;
import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
-import org.opendaylight.protocol.bgp.labeled.unicast.LabeledUnicastRIBSupport;
+import org.opendaylight.protocol.bgp.labeled.unicast.LUNlriParser;
+import org.opendaylight.protocol.bgp.labeled.unicast.LabeledUnicastIpv4RIBSupport;
import org.opendaylight.protocol.bgp.rib.spi.AbstractRIBSupport;
import org.opendaylight.protocol.util.ByteArray;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.destination.DestinationType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.Route;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.tables.Routes;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev171207.path.attributes.Attributes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev171207.destination.DestinationType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev171207.Route;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev171207.rib.tables.Routes;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.AddressFamily;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.MplsLabeledVpnSubsequentAddressFamily;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.RouteDistinguisher;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.RouteDistinguisherBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev160413.l3vpn.ip.destination.type.VpnDestination;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev160413.l3vpn.ip.destination.type.VpnDestinationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev171207.l3vpn.ip.destination.type.VpnDestination;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev171207.l3vpn.ip.destination.type.VpnDestinationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev171207.l3vpn.ip.route.VpnRoute;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev171207.l3vpn.ip.route.VpnRouteBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.vpn.rev171207.l3vpn.ip.route.VpnRouteKey;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.util.BindingReflections;
import org.opendaylight.yangtools.yang.common.QName;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @author Kevin Wang
- */
-public abstract class AbstractVpnRIBSupport extends AbstractRIBSupport {
+public abstract class AbstractVpnRIBSupport extends AbstractRIBSupport<VpnRoute, VpnRouteKey> {
private static final Logger LOG = LoggerFactory.getLogger(AbstractVpnRIBSupport.class);
private final NodeIdentifier nlriRoutesListNid;
private final NodeIdentifier prefixTypeNid;
* @param containerClass Binding class of the container in routes choice, must not be null.
* @param listClass Binding class of the route list, nust not be null;
*/
- protected AbstractVpnRIBSupport(Class<? extends Routes> cazeClass, Class<? extends DataObject> containerClass, Class<? extends Route> listClass,
- Class<? extends AddressFamily> afiClass, final QName vpnDstContainerClassQname) {
- super(cazeClass, containerClass, listClass, afiClass, MplsLabeledVpnSubsequentAddressFamily.class, vpnDstContainerClassQname);
+ protected AbstractVpnRIBSupport(final Class<? extends Routes> cazeClass,
+ final Class<? extends DataObject> containerClass, final Class<? extends Route> listClass,
+ final Class<? extends AddressFamily> afiClass, final QName vpnDstContainerClassQname) {
+ super(cazeClass, containerClass, listClass, afiClass,
+ MplsLabeledVpnSubsequentAddressFamily.class, vpnDstContainerClassQname);
final QName classQname = BindingReflections.findQName(containerClass).intern();
- routeKey = QName.create(routeQName(), "route-key").intern();
+ this.routeKey = QName.create(routeQName(), ROUTE_KEY).intern();
final QName vpnDstClassQname = QName.create(classQname, VpnDestination.QNAME.getLocalName());
- nlriRoutesListNid = NodeIdentifier.create(vpnDstClassQname);
- prefixTypeNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "prefix").intern());
- labelStackNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "label-stack").intern());
- lvNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "label-value").intern());
- rdNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "route-distinguisher").intern());
+ this.nlriRoutesListNid = NodeIdentifier.create(vpnDstClassQname);
+ this.prefixTypeNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "prefix").intern());
+ this.labelStackNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "label-stack").intern());
+ this.lvNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "label-value").intern());
+ this.rdNid = NodeIdentifier.create(QName.create(vpnDstClassQname, "route-distinguisher").intern());
}
- private VpnDestination extractVpnDestination(DataContainerNode<? extends PathArgument> route) {
+ private VpnDestination extractVpnDestination(final DataContainerNode<? extends PathArgument> route) {
final VpnDestination dst = new VpnDestinationBuilder()
- .setPrefix(LabeledUnicastRIBSupport.extractPrefix(route, prefixTypeNid))
- .setLabelStack(LabeledUnicastRIBSupport.extractLabel(route, labelStackNid, lvNid))
+ .setPrefix(extractPrefix(route, this.prefixTypeNid))
+ .setLabelStack(LabeledUnicastIpv4RIBSupport.extractLabel(route, this.labelStackNid, this.lvNid))
.setRouteDistinguisher(extractRouteDistinguisher(route))
.build();
return dst;
}
- private RouteDistinguisher extractRouteDistinguisher(final DataContainerNode<? extends YangInstanceIdentifier.PathArgument> route) {
- if (route.getChild(rdNid).isPresent()) {
- return RouteDistinguisherBuilder.getDefaultInstance((String) route.getChild(rdNid).get().getValue());
+ protected abstract IpPrefix extractPrefix(DataContainerNode<? extends PathArgument> route,
+ NodeIdentifier prefixTypeNid);
+
+ private RouteDistinguisher extractRouteDistinguisher(
+ final DataContainerNode<? extends YangInstanceIdentifier.PathArgument> route) {
+ if (route.getChild(this.rdNid).isPresent()) {
+ return RouteDistinguisherBuilder.getDefaultInstance((String) route.getChild(this.rdNid).get().getValue());
}
return null;
}
protected abstract DestinationType getWithdrawnDestinationType(List<VpnDestination> dests);
- @Nonnull
@Override
- protected DestinationType buildDestination(@Nonnull final Collection<MapEntryNode> routes) {
+ protected DestinationType buildDestination(final Collection<MapEntryNode> routes) {
return getAdvertisedDestinationType(extractRoutes(routes));
}
- @Nonnull
@Override
- protected DestinationType buildWithdrawnDestination(@Nonnull final Collection<MapEntryNode> routes) {
+ protected DestinationType buildWithdrawnDestination(final Collection<MapEntryNode> routes) {
return getWithdrawnDestinationType(extractRoutes(routes));
}
return routes.stream().map(this::extractVpnDestination).collect(Collectors.toList());
}
- @Nonnull
@Override
public ImmutableCollection<Class<? extends DataObject>> cacheableAttributeObjects() {
return ImmutableSet.of();
}
- @Nonnull
@Override
public ImmutableCollection<Class<? extends DataObject>> cacheableNlriObjects() {
return ImmutableSet.of();
@Override
protected void processDestination(final DOMDataWriteTransaction tx, final YangInstanceIdentifier routesPath,
- final ContainerNode destination, final ContainerNode attributes, final ApplyRoute function) {
+ final ContainerNode destination, final ContainerNode attributes, final ApplyRoute function) {
if (destination != null) {
- final Optional<DataContainerChild<? extends PathArgument, ?>> maybeRoutes = destination.getChild(this.nlriRoutesListNid);
+ final Optional<DataContainerChild<? extends PathArgument, ?>> maybeRoutes =
+ destination.getChild(this.nlriRoutesListNid);
if (maybeRoutes.isPresent()) {
final DataContainerChild<? extends PathArgument, ?> routes = maybeRoutes.get();
if (routes instanceof UnkeyedListNode) {
- UnkeyedListNode routeListNode = (UnkeyedListNode) routes;
+ final UnkeyedListNode routeListNode = (UnkeyedListNode) routes;
LOG.debug("{} routes are found", routeListNode.getSize());
final YangInstanceIdentifier base = routesPath.node(routesContainerIdentifier()).node(routeNid());
for (final UnkeyedListEntryNode e : routeListNode.getValue()) {
- final NodeIdentifierWithPredicates routeKey = createRouteKey(e);
- LOG.debug("Route {} is processed.", routeKey);
- function.apply(tx, base, routeKey, e, attributes);
+ final NodeIdentifierWithPredicates key = createRouteKey(e);
+ LOG.debug("Route {} is processed.", key);
+ function.apply(tx, base, key, e, attributes);
}
} else {
LOG.warn("Routes {} are not a map", routes);
private NodeIdentifierWithPredicates createRouteKey(final UnkeyedListEntryNode l3vpn) {
final ByteBuf buffer = Unpooled.buffer();
+ final VpnDestination dests = new VpnDestinationBuilder().setPrefix(extractPrefix(l3vpn, this.prefixTypeNid))
+ .setRouteDistinguisher(extractRouteDistinguisher(l3vpn)).build();
+ final ByteBuf nlriByteBuf = Unpooled.buffer();
+
+ for (final VpnDestination dest : Collections.singletonList(dests)) {
+ final IpPrefix prefix = dest.getPrefix();
+ LOG.debug("Serializing Nlri: VpnDestination={}, IpPrefix={}", dest, prefix);
+ AbstractVpnNlriParser.serializeLengtField(prefix, null, nlriByteBuf);
+ RouteDistinguisherUtil.serializeRouteDistinquisher(dest.getRouteDistinguisher(), nlriByteBuf);
+ Preconditions.checkArgument(prefix.getIpv6Prefix() != null || prefix.getIpv4Prefix() != null,
+ "Ipv6 or Ipv4 prefix is missing.");
+ LUNlriParser.serializePrefixField(prefix, nlriByteBuf);
+ }
+ buffer.writeBytes(nlriByteBuf);
+
+ return new NodeIdentifierWithPredicates(routeQName(), this.routeKey, ByteArray.encodeBase64(buffer));
+ }
- final VpnDestination dest = extractVpnDestination(l3vpn);
- AbstractVpnNlriParser.serializeNlri(Collections.singletonList(dest), buffer);
- return new NodeIdentifierWithPredicates(routeQName(), this.routeKey, ByteArray.readAllBytes(buffer));
+ @Override
+ public final VpnRoute createRoute(final VpnRoute route, final VpnRouteKey vpnRouteKey,
+ final long pathId, final Attributes attributes) {
+ final VpnRouteBuilder builder;
+ if (route != null) {
+ builder = new VpnRouteBuilder(route);
+ } else {
+ builder = new VpnRouteBuilder();
+ }
+ return builder.setRouteKey(vpnRouteKey.getRouteKey()).setAttributes(attributes).build();
}
}
Code Review / bgpcep.git / blobdiff