*/
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 io.netty.buffer.Unpooled;
-import java.util.ArrayList;
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.multiprotocol.rev130919.update.attributes.MpReachNlri;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpReachNlriBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpUnreachNlri;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpUnreachNlriBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.reach.nlri.AdvertizedRoutesBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.unreach.nlri.WithdrawnRoutesBuilder;
-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.types.rev130919.next.hop.CNextHop;
-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.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifierWithPredicates;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument;
-import org.opendaylight.yangtools.yang.data.api.schema.ChoiceNode;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild;
import org.opendaylight.yangtools.yang.data.api.schema.DataContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode;
import org.opendaylight.yangtools.yang.data.api.schema.UnkeyedListEntryNode;
import org.opendaylight.yangtools.yang.data.api.schema.UnkeyedListNode;
-import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
-import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
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 NLRI_ROUTES_LIST;
- private final NodeIdentifier PREFIX_TYPE_NID;
- private final NodeIdentifier LABEL_STACK_NID;
- private final NodeIdentifier LV_NID;
- private final NodeIdentifier RD_NID;
- private final NodeIdentifier DESTINATION;
- private final QName ROUTE_KEY;
- private final NodeIdentifier ROUTE;
- private final Class<? extends AddressFamily> ADDRESS_FAMILY_CLAZZ;
- private final QName CONTAINER_CLASS_QNAME;
- private final QName LIST_CLASS_QNAME;
- private final ChoiceNode EMPTY_ROUTES;
+ private final NodeIdentifier nlriRoutesListNid;
+ private final NodeIdentifier prefixTypeNid;
+ private final NodeIdentifier labelStackNid;
+ private final NodeIdentifier lvNid;
+ private final NodeIdentifier rdNid;
+ private final QName routeKey;
/**
* Default constructor. Requires the QName of the container augmented under the routes choice
* @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> addressFamilyClass,
- final QName VPN_DST_CONTAINER_CLASS_QNAME
- ) {
- super(cazeClass, containerClass, listClass);
- CONTAINER_CLASS_QNAME = BindingReflections.findQName(containerClass).intern();
- LIST_CLASS_QNAME =
- QName.create(
- CONTAINER_CLASS_QNAME.getNamespace(), CONTAINER_CLASS_QNAME.getRevision(), BindingReflections.findQName(listClass).intern().getLocalName()
- );
- ROUTE = NodeIdentifier.create(LIST_CLASS_QNAME);
- ROUTE_KEY = QName.create(LIST_CLASS_QNAME, "route-key").intern();
- EMPTY_ROUTES = Builders.choiceBuilder()
- .withNodeIdentifier(YangInstanceIdentifier.NodeIdentifier.create(Routes.QNAME))
- .addChild(
- Builders.containerBuilder()
- .withNodeIdentifier(YangInstanceIdentifier.NodeIdentifier.create(CONTAINER_CLASS_QNAME))
- .addChild(
- ImmutableNodes.mapNodeBuilder(
- LIST_CLASS_QNAME
- ).build()
- ).build()
- ).build();
- final QName VPN_DST_CLASS_QNAME =
- QName.create(
- CONTAINER_CLASS_QNAME.getNamespace(), CONTAINER_CLASS_QNAME.getRevision(), VpnDestination.QNAME.getLocalName()
- );
- NLRI_ROUTES_LIST = NodeIdentifier.create(VPN_DST_CLASS_QNAME);
- PREFIX_TYPE_NID = NodeIdentifier.create(QName.create(VPN_DST_CLASS_QNAME, "prefix").intern());
- LABEL_STACK_NID = NodeIdentifier.create(QName.create(VPN_DST_CLASS_QNAME, "label-stack").intern());
- LV_NID = NodeIdentifier.create(QName.create(VPN_DST_CLASS_QNAME, "label-value").intern());
- RD_NID = NodeIdentifier.create(QName.create(VPN_DST_CLASS_QNAME, "route-distinguisher").intern());
- DESTINATION = NodeIdentifier.create(VPN_DST_CONTAINER_CLASS_QNAME);
- ADDRESS_FAMILY_CLAZZ = addressFamilyClass;
+ 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();
+ this.routeKey = QName.create(routeQName(), ROUTE_KEY).intern();
+ final QName vpnDstClassQname = QName.create(classQname, VpnDestination.QNAME.getLocalName());
+ 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, PREFIX_TYPE_NID))
- .setLabelStack(LabeledUnicastRIBSupport.extractLabel(route, LABEL_STACK_NID, LV_NID))
+ .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(RD_NID).isPresent()) {
- return RouteDistinguisherBuilder.getDefaultInstance((String) route.getChild(RD_NID).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;
}
- @Nonnull
- @Override
- public ChoiceNode emptyRoutes() {
- return EMPTY_ROUTES;
- }
+ protected abstract DestinationType getAdvertisedDestinationType(List<VpnDestination> dests);
- @Nonnull
- @Override
- protected NodeIdentifier destinationContainerIdentifier() {
- return DESTINATION;
- }
+ protected abstract DestinationType getWithdrawnDestinationType(List<VpnDestination> dests);
@Override
- protected void deleteDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination, YangInstanceIdentifier.NodeIdentifier routesNodeId) {
- processDestination(tx, tablePath.node(routesNodeId), destination, null, DELETE_ROUTE);
+ protected DestinationType buildDestination(final Collection<MapEntryNode> routes) {
+ return getAdvertisedDestinationType(extractRoutes(routes));
}
@Override
- protected void putDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination, ContainerNode attributes, YangInstanceIdentifier.NodeIdentifier routesNodeId) {
- processDestination(tx, tablePath.node(routesNodeId), destination, attributes, putRoute);
+ protected DestinationType buildWithdrawnDestination(final Collection<MapEntryNode> routes) {
+ return getWithdrawnDestinationType(extractRoutes(routes));
}
- protected abstract DestinationType getAdvertizedDestinationType(List<VpnDestination> dests);
-
- protected abstract DestinationType getWithdrawnDestinationType(List<VpnDestination> dests);
-
- @Nonnull
- @Override
- protected MpReachNlri buildReach(Collection<MapEntryNode> routes, CNextHop hop) {
- final MpReachNlriBuilder mb = new MpReachNlriBuilder()
- .setAfi(ADDRESS_FAMILY_CLAZZ)
- .setSafi(MplsLabeledVpnSubsequentAddressFamily.class)
- .setCNextHop(hop);
-
- final List<VpnDestination> dests = new ArrayList<>(routes.size());
- dests.addAll(routes.stream().map(this::extractVpnDestination).collect(Collectors.toList()));
-
- mb.setAdvertizedRoutes(
- new AdvertizedRoutesBuilder().setDestinationType(
- getAdvertizedDestinationType(dests)
- ).build()
- ).build();
- return mb.build();
+ private List<VpnDestination> extractRoutes(final Collection<MapEntryNode> routes) {
+ return routes.stream().map(this::extractVpnDestination).collect(Collectors.toList());
}
- @Nonnull
- @Override
- protected MpUnreachNlri buildUnreach(Collection<MapEntryNode> routes) {
- final MpUnreachNlriBuilder mb = new MpUnreachNlriBuilder()
- .setAfi(ADDRESS_FAMILY_CLAZZ)
- .setSafi(MplsLabeledVpnSubsequentAddressFamily.class);
-
- final List<VpnDestination> dests = new ArrayList<>(routes.size());
- dests.addAll(routes.stream().map(this::extractVpnDestination).collect(Collectors.toList()));
-
- mb.setWithdrawnRoutes(new WithdrawnRoutesBuilder().setDestinationType(
- getWithdrawnDestinationType(dests)
- ).build()
- ).build();
- return mb.build();
- }
-
- @Nonnull
@Override
public ImmutableCollection<Class<? extends DataObject>> cacheableAttributeObjects() {
return ImmutableSet.of();
}
- @Nonnull
@Override
public ImmutableCollection<Class<? extends DataObject>> cacheableNlriObjects() {
return ImmutableSet.of();
return true;
}
- private void processDestination(final DOMDataWriteTransaction tx, final YangInstanceIdentifier routesPath,
- final ContainerNode destination, final ContainerNode attributes, final ApplyRoute function) {
+ @Override
+ protected void processDestination(final DOMDataWriteTransaction tx, final YangInstanceIdentifier routesPath,
+ final ContainerNode destination, final ContainerNode attributes, final ApplyRoute function) {
if (destination != null) {
- final Optional<DataContainerChild<? extends PathArgument, ?>> maybeRoutes = destination.getChild(NLRI_ROUTES_LIST);
+ 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(ROUTE);
+ 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);
- final VpnDestination dest = extractVpnDestination(l3vpn);
- AbstractVpnNlriParser.serializeNlri(Collections.singletonList(dest), buffer);
- return new NodeIdentifierWithPredicates(LIST_CLASS_QNAME, ROUTE_KEY, ByteArray.readAllBytes(buffer));
+ return new NodeIdentifierWithPredicates(routeQName(), this.routeKey, ByteArray.encodeBase64(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