import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
-import com.google.common.util.concurrent.SettableFuture;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.opendaylight.controller.md.sal.binding.api.DataTreeModification;
import org.opendaylight.controller.md.sal.binding.api.MountPoint;
import org.opendaylight.controller.md.sal.binding.api.MountPointService;
-import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.Interface1;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.Ipv4;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ip.rev140616.interfaces._interface.ipv4.Address;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.external.reference.rev160129.ExternalReference;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.Vpp;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentation;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentationBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanTunnel;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.L2;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.L2Builder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.Vxlan;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.VxlanBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces._interface.l2.interconnection.BridgeBasedBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.vpp.BridgeDomains;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.vpp.bridge.domains.BridgeDomainBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.TerminationPointVbridgeAugment;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.TerminationPointVbridgeAugmentBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.TopologyVbridgeAugment;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.TunnelParameters;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.node.BridgeMember;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.node.BridgeMemberBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.node.termination.point.InterfaceType;
*/
final class BridgeDomain implements DataTreeChangeListener<Topology> {
private static final Logger LOG = LoggerFactory.getLogger(BridgeDomain.class);
+
private static final int SOURCE_VPP_INDEX = 0;
private static final int DESTINATION_VPP_INDEX = 1;
private static final String TUNNEL_ID_PREFIX = "vxlan_tunnel";
- private static final String TUNNEL_DESCRIPTION = "virtual interface which interconnects VPPs";
- private static final Long DEFAULT_ENCAP_VRF_ID = 0L;
- private static final String TUNNEL_ID_DEMO = TUNNEL_ID_PREFIX + "0";
+ static final String TUNNEL_ID_DEMO = TUNNEL_ID_PREFIX + "0";
private final KeyedInstanceIdentifier<Topology, TopologyKey> topology;
@GuardedBy("this")
private final BindingTransactionChain chain;
private final ListenerRegistration<?> reg;
private final MountPointService mountService;
+ private final VppModifier vppModifier;
private TopologyVbridgeAugment config;
private final String bridgeDomainName;
private final InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.vpp.bridge.domains.BridgeDomain> iiBridgeDomainOnVPP;
private final String iiBridgeDomainOnVPPRest;
- private final DataBroker dataBroker;
private Multimap<NodeId, KeyedInstanceIdentifier<Node, NodeKey>> nodesToVpps = ArrayListMultimap.create();
private final List<Integer> tunnelIds;
.child(BridgeDomains.class)
.child(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.vpp.bridge.domains.BridgeDomain.class, new BridgeDomainKey(bridgeDomainName));
- this.dataBroker = dataBroker;
reg = dataBroker.registerDataTreeChangeListener(
- new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, topology), this);
+ new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, topology), this);
this.tunnelIds = new ArrayList<>();
+ this.vppModifier = new VppModifier(mountService);
}
private String provideIIBrdigeDomainOnVPPRest() {
// Read configuration
final TopologyVbridgeAugment config = data.getAugmentation(TopologyVbridgeAugment.class);
+ vppModifier.setConfig(config);
if (config != null) {
setConfiguration(config);
} else {
}
}
- private void addTunnel(final NodeId newNode) {
- for (Map.Entry<NodeId, KeyedInstanceIdentifier<Node, NodeKey>> entryToVpp : nodesToVpps.entries()) {
- if (!entryToVpp.getKey().equals(newNode)) {
+ private void addTunnel(final NodeId sourceNode) {
+ final KeyedInstanceIdentifier<Node, NodeKey> iiToSrcVpp = nodesToVpps.get(sourceNode).iterator().next();
+ for (Map.Entry<NodeId, KeyedInstanceIdentifier<Node, NodeKey>> nodeToVpp : nodesToVpps.entries()) {
+ if (!nodeToVpp.getKey().equals(sourceNode)) {
//TODO: check whether returned value from nodesToVpps is not null
- final KeyedInstanceIdentifier<Node, NodeKey> iiToOldVpp = entryToVpp.getValue();
- final KeyedInstanceIdentifier<Node, NodeKey> iiToNewVpp = nodesToVpps.get(newNode).iterator().next();
- final NodeId oldNode = entryToVpp.getKey();
+ final KeyedInstanceIdentifier<Node, NodeKey> iiToDstVpp = nodeToVpp.getValue();
+ final NodeId dstNode = nodeToVpp.getKey();
- final ListenableFuture<List<Optional<Ipv4AddressNoZone>>> ipAddressesFuture = readIpAddressesFromVpps(iiToOldVpp, iiToNewVpp);
+ final ListenableFuture<List<Optional<Ipv4AddressNoZone>>> ipAddressesFuture = vppModifier.readIpAddressesFromVpps(iiToDstVpp, iiToSrcVpp);
Futures.addCallback(ipAddressesFuture, new FutureCallback<List<Optional<Ipv4AddressNoZone>>>() {
@Override
public void onSuccess(List<Optional<Ipv4AddressNoZone>> ipAddresses) {
if (ipAddresses.size() == 2) {
LOG.debug("All required IP addresses for creating tunnel were obtained.");
- final Optional<Ipv4AddressNoZone> ipAddressNewVpp = ipAddresses.get(SOURCE_VPP_INDEX);
- final Optional<Ipv4AddressNoZone> ipAddressOldVpp = ipAddresses.get(DESTINATION_VPP_INDEX);
- if (ipAddressNewVpp != null && ipAddressOldVpp != null) {
- if (ipAddressNewVpp.isPresent() && ipAddressOldVpp.isPresent()) {
- //writing v3po:vxlan container to new node
- Vxlan vxlanData = prepareVxlan(ipAddressOldVpp.get(), ipAddressNewVpp.get());
- Interface intfData = prepareVirtualInterfaceData(vxlanData);
- createVirtualInterfaceOnVpp(intfData, iiToNewVpp);
+ final Optional<Ipv4AddressNoZone> ipAddressSrcVpp = ipAddresses.get(SOURCE_VPP_INDEX);
+ final Optional<Ipv4AddressNoZone> ipAddressDstVpp = ipAddresses.get(DESTINATION_VPP_INDEX);
+ if (ipAddressSrcVpp != null && ipAddressDstVpp != null) {
+ if (ipAddressSrcVpp.isPresent() && ipAddressDstVpp.isPresent()) {
+ //writing v3po:vxlan container to source node
+ vppModifier.createVirtualInterfaceOnVpp(ipAddressSrcVpp.get(), ipAddressDstVpp.get(), iiToSrcVpp);
//writing v3po:vxlan container to existing node
- vxlanData = prepareVxlan(ipAddressNewVpp.get(), ipAddressOldVpp.get());
- intfData = prepareVirtualInterfaceData(vxlanData);
- createVirtualInterfaceOnVpp(intfData, iiToOldVpp);
+ vppModifier.createVirtualInterfaceOnVpp(ipAddressDstVpp.get(), ipAddressSrcVpp.get(), iiToDstVpp);
- addTerminationPoint(topology.child(Node.class, new NodeKey(oldNode)));
- addTerminationPoint(topology.child(Node.class, new NodeKey(newNode)));
+ addTerminationPoint(topology.child(Node.class, new NodeKey(dstNode)));
+ addTerminationPoint(topology.child(Node.class, new NodeKey(sourceNode)));
- addLinkBetweenTerminationPoints(newNode, oldNode);
- addLinkBetweenTerminationPoints(oldNode, newNode);
+ addLinkBetweenTerminationPoints(sourceNode, dstNode);
+ addLinkBetweenTerminationPoints(dstNode, sourceNode);
}
}
}
-
- }
-
- private void createVirtualInterfaceOnVpp(final Interface intfData, final KeyedInstanceIdentifier<Node, NodeKey> iiToVpp) {
- final DataBroker vppDataBroker = resolveDataBrokerForMountPoint(iiToVpp);
- if (vppDataBroker != null) {
- final WriteTransaction wTx = vppDataBroker.newWriteOnlyTransaction();
- final KeyedInstanceIdentifier<Interface, InterfaceKey> iiToInterface
- = InstanceIdentifier.create(Interfaces.class).child(Interface.class, new InterfaceKey(TUNNEL_ID_DEMO));
- wTx.put(LogicalDatastoreType.CONFIGURATION, iiToInterface, intfData);
- final CheckedFuture<Void, TransactionCommitFailedException> submitFuture = wTx.submit();
- Futures.addCallback(submitFuture, new FutureCallback<Void>() {
- @Override
- public void onSuccess(@Nullable Void result) {
- LOG.debug("Writing super virtual interface to {} finished successfully.",iiToVpp.getKey().getNodeId());
- }
-
- @Override
- public void onFailure(Throwable t) {
- LOG.debug("Writing super virtual interface to {} failed.",iiToVpp.getKey().getNodeId());
- }
- });
- } else {
- LOG.debug("Writing virtual interface {} to VPP {} wasn't successfull because missing data broker.",TUNNEL_DESCRIPTION, iiToVpp);
- }
- }
-
- private Interface prepareVirtualInterfaceData(final Vxlan vxlan) {
- final InterfaceBuilder interfaceBuilder = new InterfaceBuilder();
- //TODO implement tunnel counter
- interfaceBuilder.setName(TUNNEL_ID_DEMO);
- interfaceBuilder.setType(VxlanTunnel.class);
- VppInterfaceAugmentationBuilder vppInterfaceAugmentationBuilder = new VppInterfaceAugmentationBuilder();
- vppInterfaceAugmentationBuilder.setVxlan(vxlan);
- interfaceBuilder.addAugmentation(VppInterfaceAugmentation.class, vppInterfaceAugmentationBuilder.build());
- return interfaceBuilder.build();
- }
-
- private Vxlan prepareVxlan(final Ipv4AddressNoZone ipSrc, final Ipv4AddressNoZone ipDst) {
- final VxlanBuilder vxlanBuilder = new VxlanBuilder();
- vxlanBuilder.setSrc(ipSrc);
- vxlanBuilder.setDst(ipDst);
- final TunnelParameters tunnelParameters = config.getTunnelParameters();
- if (tunnelParameters instanceof org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.tunnel.parameters.Vxlan) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.tunnel.parameters.Vxlan vxlan =
- (org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.network.topology.topology.tunnel.parameters.Vxlan) tunnelParameters;
- //TODO: handle NPE
- vxlanBuilder.setVni(vxlan.getVxlan().getVni());
- }
- vxlanBuilder.setEncapVrfId(DEFAULT_ENCAP_VRF_ID);
- return vxlanBuilder.build();
}
@Override
final WriteTransaction wTx = chain.newWriteOnlyTransaction();
wTx.put(LogicalDatastoreType.OPERATIONAL, iiToLink, prepareData(newVpp, odlVpp, linkId),true);
wTx.submit();
-
}
private Link prepareData(final NodeId newVpp, final NodeId oldVpp, final LinkId linkId) {
sourceBuilder.setSourceTp(new TpId(TUNNEL_ID_DEMO));
linkBuilder.setSource(sourceBuilder.build());
-
final DestinationBuilder destinationBuilder = new DestinationBuilder();
destinationBuilder.setDestNode(oldVpp);
destinationBuilder.setDestTp(new TpId(TUNNEL_ID_DEMO));
return linkBuilder.build();
}
- private ListenableFuture<List<Optional<Ipv4AddressNoZone>>> readIpAddressesFromVpps(final KeyedInstanceIdentifier<Node, NodeKey>... iiToVpps) {
- final List<ListenableFuture<Optional<Ipv4AddressNoZone>>> ipv4Futures = new ArrayList<>();
- for (final KeyedInstanceIdentifier<Node, NodeKey> iiToVpp : iiToVpps) {
- ipv4Futures.add(readIpAddressFromVpp(iiToVpp));
- }
- return Futures.successfulAsList(ipv4Futures);
- }
-
- private ListenableFuture<Optional<Ipv4AddressNoZone>> readIpAddressFromVpp(final KeyedInstanceIdentifier<Node, NodeKey> iiToVpp) {
- final SettableFuture<Optional<Ipv4AddressNoZone>> resultFuture = SettableFuture.create();
-
- final DataBroker vppDataBroker = resolveDataBrokerForMountPoint(iiToVpp);
- final ReadOnlyTransaction rTx = vppDataBroker.newReadOnlyTransaction();
- final CheckedFuture<Optional<Interfaces>, ReadFailedException> interfaceStateFuture
- = rTx.read(LogicalDatastoreType.CONFIGURATION, InstanceIdentifier.create(Interfaces.class));
-
- Futures.addCallback(interfaceStateFuture, new FutureCallback<Optional<Interfaces>>() {
- @Override
- public void onSuccess(Optional<Interfaces> optInterfaces) {
- if (optInterfaces.isPresent()) {
- for (org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface intf : optInterfaces.get().getInterface()) {
- final Interface1 interface1 = intf.getAugmentation(Interface1.class);
- if (interface1 != null) {
- final Ipv4 ipv4 = interface1.getIpv4();
- if (ipv4 != null) {
- final List<Address> addresses = ipv4.getAddress();
- if (!addresses.isEmpty()) {
- final Ipv4AddressNoZone ip = addresses.iterator().next().getIp();
- if (ip != null) {
- resultFuture.set(Optional.of(ip));
- break;
- }
- }
- }
- }
- }
- }
- resultFuture.set(Optional.<Ipv4AddressNoZone>absent());
- }
-
- @Override
- public void onFailure(Throwable t) {
- resultFuture.setException(t);
-
- }
- });
- return resultFuture;
- }
private void modifyTerminationPoint(final DataObjectModification<TerminationPoint> nodeChild, final NodeId nodeId) {
Code Review / honeycomb.git / blobdiff