import java.util.Collection;
import java.util.Collections;
import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Update;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.UpdateBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.Attributes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.AttributesBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes1;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes1Builder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes2;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes2Builder;
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.path.attributes.mp.reach.nlri.AdvertizedRoutes;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.path.attributes.mp.unreach.nlri.WithdrawnRoutes;
+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.MpUnreachNlri;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.reach.nlri.AdvertizedRoutes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.unreach.nlri.WithdrawnRoutes;
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.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.route.Attributes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.next.hop.CNextHop;
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.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.MapEntryNode;
+import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidateNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final NodeIdentifier ADVERTIZED_ROUTES = new NodeIdentifier(AdvertizedRoutes.QNAME);
private static final NodeIdentifier WITHDRAWN_ROUTES = new NodeIdentifier(WithdrawnRoutes.QNAME);
private static final NodeIdentifier DESTINATION_TYPE = new NodeIdentifier(DestinationType.QNAME);
- protected static final NodeIdentifier ROUTES = new NodeIdentifier(Routes.QNAME);
+ private static final NodeIdentifier ROUTES = new NodeIdentifier(Routes.QNAME);
private final NodeIdentifier routesContainerIdentifier;
private final NodeIdentifier routesListIdentifier;
* @param listClass Binding class of the route list, nust not be null;
*/
protected AbstractRIBSupport(final Class<? extends Routes> cazeClass, final Class<? extends DataObject> containerClass, final Class<? extends Route> listClass) {
- final QName qname = BindingReflections.findQName(containerClass);
+ final QName qname = BindingReflections.findQName(containerClass).intern();
this.routesContainerIdentifier = new NodeIdentifier(qname);
- this.routeAttributesIdentifier = new NodeIdentifier(QName.cachedReference(QName.create(qname, Attributes.QNAME.getLocalName())));
+ this.routeAttributesIdentifier = new NodeIdentifier(QName.create(qname, Attributes.QNAME.getLocalName().intern()));
this.cazeClass = Preconditions.checkNotNull(cazeClass);
this.containerClass = Preconditions.checkNotNull(containerClass);
this.listClass = Preconditions.checkNotNull(listClass);
- this.routesListIdentifier = new NodeIdentifier(BindingReflections.findQName(listClass));
+ this.routesListIdentifier = new NodeIdentifier(BindingReflections.findQName(listClass).intern());
}
@Override
* @param tx DOMDataWriteTransaction to be passed into implementation
* @param tablePath YangInstanceIdentifier to be passed into implementation
* @param destination ContainerNode DOM representation of NLRI in Update message
+ * @param routesNodeId NodeIdentifier
*/
- protected abstract void deleteDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination);
+ protected abstract void deleteDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination, NodeIdentifier routesNodeId);
/**
* Given the destination as ContainerNode, implementation needs to parse the DOM model
* @param tablePath YangInstanceIdentifier to be passed into implementation
* @param destination ContainerNode DOM representation of NLRI in Update message
* @param attributes ContainerNode to be passed into implementation
+ * @param routesNodeId NodeIdentifier
*/
- protected abstract void putDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination, ContainerNode attributes);
+ protected abstract void putDestinationRoutes(DOMDataWriteTransaction tx, YangInstanceIdentifier tablePath, ContainerNode destination, ContainerNode attributes,
+ NodeIdentifier routesNodeId);
private static ContainerNode getDestination(final DataContainerChild<? extends PathArgument, ?> routes, final NodeIdentifier destinationId) {
if (routes instanceof ContainerNode) {
@Override
public final Collection<DataTreeCandidateNode> changedRoutes(final DataTreeCandidateNode routes) {
- LOG.trace("Changed routes called with {} identifier {}", routes, routes.getIdentifier());
final DataTreeCandidateNode myRoutes = routes.getModifiedChild(this.routesContainerIdentifier);
if (myRoutes == null) {
return Collections.emptySet();
}
- LOG.trace("MyRoutes {} identifier {}", myRoutes, myRoutes.getIdentifier());
final DataTreeCandidateNode routesMap = myRoutes.getModifiedChild(this.routesListIdentifier);
if (routesMap == null) {
return Collections.emptySet();
}
- LOG.trace("RoutesMap {} identifier {}", routesMap, routesMap.getIdentifier());
// Well, given the remote possibility of augmentation, we should perform a filter here,
// to make sure the type matches what routeType() reports.
- LOG.trace("Returning children {}", routesMap.getChildNodes());
return routesMap.getChildNodes();
}
@Override
public final void deleteRoutes(final DOMDataWriteTransaction tx, final YangInstanceIdentifier tablePath, final ContainerNode nlri) {
+ deleteRoutes(tx, tablePath, nlri, ROUTES);
+ }
+
+ @Override
+ public final void putRoutes(final DOMDataWriteTransaction tx, final YangInstanceIdentifier tablePath, final ContainerNode nlri, final ContainerNode attributes) {
+ putRoutes(tx, tablePath, nlri, attributes, ROUTES);
+ }
+
+ /**
+ * Build MpReachNlri object from DOM representation.
+ *
+ * @param routes Collection of MapEntryNode DOM representation of routes
+ * @param hop CNextHop as it was parsed from Attributes, to be included in MpReach object
+ * @return MpReachNlri
+ */
+ @Nonnull protected abstract MpReachNlri buildReach(Collection<MapEntryNode> routes, CNextHop hop);
+
+ /**
+ * Build MpUnReachNlri object from DOM representation.
+ *
+ * @param routes Collection of MapEntryNode DOM representation of routes
+ * @return MpUnreachNlri
+ */
+ @Nonnull protected abstract MpUnreachNlri buildUnreach(Collection<MapEntryNode> routes);
+
+ @Override
+ public Update buildUpdate(final Collection<MapEntryNode> advertised, final Collection<MapEntryNode> withdrawn, final Attributes attr) {
+ final UpdateBuilder ub = new UpdateBuilder();
+ final AttributesBuilder ab = new AttributesBuilder(attr);
+ final CNextHop hop = ab.getCNextHop();
+
+ // do not preserve next hop in attributes if we are using MpReach
+ ab.setCNextHop(null);
+
+ if (!advertised.isEmpty()) {
+ final MpReachNlri mb = buildReach(advertised, hop);
+ ab.addAugmentation(Attributes1.class, new Attributes1Builder().setMpReachNlri(mb).build());
+ }
+ if (!withdrawn.isEmpty()) {
+ final MpUnreachNlri mb = buildUnreach(withdrawn);
+ ab.addAugmentation(Attributes2.class, new Attributes2Builder().setMpUnreachNlri(mb).build());
+ }
+
+ ub.setAttributes(ab.build());
+ return ub.build();
+ }
+
+ @Override
+ public final void deleteRoutes(final DOMDataWriteTransaction tx, final YangInstanceIdentifier tablePath, final ContainerNode nlri,
+ final NodeIdentifier routesNodeId) {
final Optional<DataContainerChild<? extends PathArgument, ?>> maybeRoutes = nlri.getChild(WITHDRAWN_ROUTES);
if (maybeRoutes.isPresent()) {
final ContainerNode destination = getDestination(maybeRoutes.get(), destinationContainerIdentifier());
if (destination != null) {
- deleteDestinationRoutes(tx, tablePath, destination);
+ deleteDestinationRoutes(tx, tablePath, destination, routesNodeId);
}
} else {
LOG.debug("Withdrawn routes are not present in NLRI {}", nlri);
}
@Override
- public final void putRoutes(final DOMDataWriteTransaction tx, final YangInstanceIdentifier tablePath, final ContainerNode nlri, final ContainerNode attributes) {
+ public final void putRoutes(final DOMDataWriteTransaction tx, final YangInstanceIdentifier tablePath, final ContainerNode nlri,
+ final ContainerNode attributes, final NodeIdentifier routesNodeId) {
final Optional<DataContainerChild<? extends PathArgument, ?>> maybeRoutes = nlri.getChild(ADVERTIZED_ROUTES);
if (maybeRoutes.isPresent()) {
final ContainerNode destination = getDestination(maybeRoutes.get(), destinationContainerIdentifier());
if (destination != null) {
- putDestinationRoutes(tx, tablePath, destination, attributes);
+ putDestinationRoutes(tx, tablePath, destination, attributes, routesNodeId);
}
} else {
LOG.debug("Advertized routes are not present in NLRI {}", nlri);
}
}
+
+ @Nullable
+ @Override
+ /**
+ * Return null for non supporting Add path models
+ */
+ public PathArgument getRouteIdAddPath(final long pathId, final PathArgument routeId) {
+ return null;
+ }
+
+ @Override
+ public long extractPathId(final NormalizedNode<?, ?> data) {
+ return 0;
+ }
}
Code Review / bgpcep.git / blobdiff