X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fsal%2Fconnect%2Fnetconf%2Fsal%2FNetconfDeviceTopologyAdapter.java;h=202517fb14d5c98b9950f016dacac6d6190ab494;hb=33d6351332b51e2cfd454daf673c7663b03f096c;hp=8d068bb5487a40ac5994406ec218c5b273c44179;hpb=476cc2164a06b77e7dd38859e0124d82cd2c8847;p=netconf.git diff --git a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceTopologyAdapter.java b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceTopologyAdapter.java index 8d068bb548..202517fb14 100644 --- a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceTopologyAdapter.java +++ b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceTopologyAdapter.java @@ -5,24 +5,20 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.netconf.sal.connect.netconf.sal; -import com.google.common.base.Function; import com.google.common.base.Preconditions; -import com.google.common.collect.FluentIterable; -import com.google.common.util.concurrent.CheckedFuture; import com.google.common.util.concurrent.FutureCallback; -import com.google.common.util.concurrent.Futures; +import com.google.common.util.concurrent.MoreExecutors; import java.util.ArrayList; import java.util.List; -import java.util.Map.Entry; +import java.util.Map; import java.util.concurrent.ExecutionException; import java.util.stream.Collectors; -import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain; -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.TransactionCommitFailedException; +import org.opendaylight.mdsal.binding.api.TransactionChain; +import org.opendaylight.mdsal.binding.api.WriteTransaction; +import org.opendaylight.mdsal.common.api.CommitInfo; +import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.netconf.sal.connect.netconf.listener.NetconfDeviceCapabilities; import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber; @@ -34,7 +30,6 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev15 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.UnavailableCapabilities; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.UnavailableCapabilitiesBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.unavailable.capabilities.UnavailableCapability; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.unavailable.capabilities.UnavailableCapability.FailureReason; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.unavailable.capabilities.UnavailableCapabilityBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.network.topology.topology.topology.types.TopologyNetconf; @@ -54,22 +49,18 @@ import org.opendaylight.yangtools.yang.common.QName; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public final class NetconfDeviceTopologyAdapter implements AutoCloseable { +public class NetconfDeviceTopologyAdapter implements AutoCloseable { private static final Logger LOG = LoggerFactory.getLogger(NetconfDeviceTopologyAdapter.class); - public static final Function, UnavailableCapability> - UNAVAILABLE_CAPABILITY_TRANSFORMER = - input -> new UnavailableCapabilityBuilder() - .setCapability(input.getKey().toString()).setFailureReason(input.getValue()).build(); private final RemoteDeviceId id; - private BindingTransactionChain txChain; + private TransactionChain txChain; private final InstanceIdentifier networkTopologyPath; private final KeyedInstanceIdentifier topologyListPath; private static final String UNKNOWN_REASON = "Unknown reason"; - NetconfDeviceTopologyAdapter(final RemoteDeviceId id, final BindingTransactionChain txChain) { + NetconfDeviceTopologyAdapter(final RemoteDeviceId id, final TransactionChain txChain) { this.id = id; this.txChain = Preconditions.checkNotNull(txChain); @@ -94,61 +85,62 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { nodeBuilder.addAugmentation(NetconfNode.class, netconfNodeBuilder.build()); Node node = nodeBuilder.build(); - LOG.trace( - "{}: Init device state transaction {} putting if absent operational data started.", + LOG.trace("{}: Init device state transaction {} putting if absent operational data started.", id, writeTx.getIdentifier()); writeTx.put(LogicalDatastoreType.OPERATIONAL, path, node); - LOG.trace( - "{}: Init device state transaction {} putting operational data ended.", - id, writeTx.getIdentifier()); - - LOG.trace( - "{}: Init device state transaction {} putting if absent config data started.", - id, writeTx.getIdentifier()); - LOG.trace( - "{}: Init device state transaction {} putting config data ended.", + LOG.trace("{}: Init device state transaction {} putting operational data ended.", id, writeTx.getIdentifier()); + LOG.trace("{}: Init device state transaction {} putting if absent config data started.", id, writeTx.getIdentifier()); + LOG.trace("{}: Init device state transaction {} putting config data ended.", id, writeTx.getIdentifier()); commitTransaction(writeTx, "init"); } - public void updateDeviceData(final boolean up, final NetconfDeviceCapabilities capabilities) { - final NetconfNode data = buildDataForNetconfNode(up, capabilities); + public void updateDeviceData(final ConnectionStatus connectionStatus, + final NetconfDeviceCapabilities capabilities, final LogicalDatastoreType dsType, final NetconfNode node) { + NetconfNode data; + if (node != null && dsType == LogicalDatastoreType.CONFIGURATION) { + data = node; + } else { + data = buildDataForNetconfNode(connectionStatus, capabilities, dsType, node); + } final WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); - LOG.trace( - "{}: Update device state transaction {} merging operational data started.", + LOG.trace("{}: Update device state transaction {} merging operational data started.", id, writeTx.getIdentifier()); - writeTx.put(LogicalDatastoreType.OPERATIONAL, - id.getTopologyBindingPath().augmentation(NetconfNode.class), data, true); - LOG.trace( - "{}: Update device state transaction {} merging operational data ended.", + writeTx.put(dsType, id.getTopologyBindingPath().augmentation(NetconfNode.class), data, true); + LOG.trace("{}: Update device state transaction {} merging operational data ended.", id, writeTx.getIdentifier()); commitTransaction(writeTx, "update"); } + public void updateDeviceData(final boolean up, final NetconfDeviceCapabilities capabilities) { + updateDeviceData(up ? ConnectionStatus.Connected : ConnectionStatus.Connecting, capabilities, + LogicalDatastoreType.OPERATIONAL, null); + } + public void updateClusteredDeviceData(final boolean up, final String masterAddress, final NetconfDeviceCapabilities capabilities) { final NetconfNode data = buildDataForNetconfClusteredNode(up, masterAddress, capabilities); final WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); - LOG.trace( - "{}: Update device state transaction {} merging operational data started.", + LOG.trace("{}: Update device state transaction {} merging operational data started.", id, writeTx.getIdentifier()); writeTx.put(LogicalDatastoreType.OPERATIONAL, id.getTopologyBindingPath().augmentation(NetconfNode.class), data, true); - LOG.trace( - "{}: Update device state transaction {} merging operational data ended.", + LOG.trace("{}: Update device state transaction {} merging operational data ended.", id, writeTx.getIdentifier()); commitTransaction(writeTx, "update"); } public void setDeviceAsFailed(final Throwable throwable) { - String reason = (throwable != null && throwable.getMessage() != null) ? throwable.getMessage() : UNKNOWN_REASON; + String reason = throwable != null && throwable.getMessage() != null ? throwable.getMessage() : UNKNOWN_REASON; final NetconfNode data = new NetconfNodeBuilder() + .setHost(id.getHost()) + .setPort(new PortNumber(id.getAddress().getPort())) .setConnectionStatus(ConnectionStatus.UnableToConnect).setConnectedMessage(reason).build(); final WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); @@ -164,7 +156,8 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { commitTransaction(writeTx, "update-failed-device"); } - private NetconfNode buildDataForNetconfNode(final boolean up, final NetconfDeviceCapabilities capabilities) { + private NetconfNode buildDataForNetconfNode(final ConnectionStatus connectionStatus, + final NetconfDeviceCapabilities capabilities, final LogicalDatastoreType dsType, final NetconfNode node) { List capabilityList = new ArrayList<>(); capabilityList.addAll(capabilities.getNonModuleBasedCapabilities()); capabilityList.addAll(capabilities.getResolvedCapabilities()); @@ -172,18 +165,13 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { final AvailableCapabilitiesBuilder avCapabalitiesBuilder = new AvailableCapabilitiesBuilder(); avCapabalitiesBuilder.setAvailableCapability(capabilityList); - final UnavailableCapabilities unavailableCapabilities = new UnavailableCapabilitiesBuilder() - .setUnavailableCapability(FluentIterable.from(capabilities.getUnresolvedCapabilites().entrySet()) - .transform(UNAVAILABLE_CAPABILITY_TRANSFORMER).toList()).build(); - - final NetconfNodeBuilder netconfNodeBuilder = new NetconfNodeBuilder() - .setHost(id.getHost()) - .setPort(new PortNumber(id.getAddress().getPort())) - .setConnectionStatus(up ? ConnectionStatus.Connected : ConnectionStatus.Connecting) - .setAvailableCapabilities(avCapabalitiesBuilder.build()) - .setUnavailableCapabilities(unavailableCapabilities); - - return netconfNodeBuilder.build(); + return new NetconfNodeBuilder() + .setHost(id.getHost()) + .setPort(new PortNumber(id.getAddress().getPort())) + .setConnectionStatus(connectionStatus) + .setAvailableCapabilities(avCapabalitiesBuilder.build()) + .setUnavailableCapabilities(unavailableCapabilities(capabilities.getUnresolvedCapabilites())) + .build(); } private NetconfNode buildDataForNetconfClusteredNode(final boolean up, final String masterNodeAddress, @@ -194,23 +182,24 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { final AvailableCapabilitiesBuilder avCapabalitiesBuilder = new AvailableCapabilitiesBuilder(); avCapabalitiesBuilder.setAvailableCapability(capabilityList); - final UnavailableCapabilities unavailableCapabilities = - new UnavailableCapabilitiesBuilder().setUnavailableCapability(capabilities.getUnresolvedCapabilites() - .entrySet().stream().map(UNAVAILABLE_CAPABILITY_TRANSFORMER::apply) - .collect(Collectors.toList())).build(); - final NetconfNodeBuilder netconfNodeBuilder = new NetconfNodeBuilder() .setHost(id.getHost()) .setPort(new PortNumber(id.getAddress().getPort())) .setConnectionStatus(up ? ConnectionStatus.Connected : ConnectionStatus.Connecting) .setAvailableCapabilities(avCapabalitiesBuilder.build()) - .setUnavailableCapabilities(unavailableCapabilities) + .setUnavailableCapabilities(unavailableCapabilities(capabilities.getUnresolvedCapabilites())) .setClusteredConnectionStatus( new ClusteredConnectionStatusBuilder().setNetconfMasterNode(masterNodeAddress).build()); return netconfNodeBuilder.build(); } + private static UnavailableCapabilities unavailableCapabilities(final Map input) { + return new UnavailableCapabilitiesBuilder().setUnavailableCapability(input.entrySet().stream().map( + e -> new UnavailableCapabilityBuilder().setCapability(e.getKey().toString()).setFailureReason( + e.getValue()).build()).collect(Collectors.toList())).build(); + } + public void removeDeviceConfiguration() { final WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); @@ -223,7 +212,7 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { id, writeTx.getIdentifier()); try { - writeTx.submit().get(); + writeTx.commit().get(); } catch (InterruptedException | ExecutionException e) { LOG.error("{}: Transaction(close) {} FAILED!", id, writeTx.getIdentifier(), e); throw new IllegalStateException(id + " Transaction(close) not committed correctly", e); @@ -233,25 +222,24 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { private void createNetworkTopologyIfNotPresent(final WriteTransaction writeTx) { final NetworkTopology networkTopology = new NetworkTopologyBuilder().build(); - LOG.trace("{}: Merging {} container to ensure its presence", id, - NetworkTopology.QNAME, writeTx.getIdentifier()); + LOG.trace("{}: Transaction {} merging {} container to ensure its presence", id, writeTx.getIdentifier(), + NetworkTopology.QNAME); writeTx.merge(LogicalDatastoreType.OPERATIONAL, networkTopologyPath, networkTopology); final Topology topology = new TopologyBuilder().setTopologyId(new TopologyId(TopologyNetconf.QNAME.getLocalName())).build(); - LOG.trace("{}: Merging {} container to ensure its presence", id, - Topology.QNAME, writeTx.getIdentifier()); + LOG.trace("{}: Transaction {} merging {} container to ensure its presence", id, writeTx.getIdentifier(), + Topology.QNAME); writeTx.merge(LogicalDatastoreType.OPERATIONAL, topologyListPath, topology); } private void commitTransaction(final WriteTransaction transaction, final String txType) { LOG.trace("{}: Committing Transaction {}:{}", id, txType, transaction.getIdentifier()); - final CheckedFuture result = transaction.submit(); - Futures.addCallback(result, new FutureCallback() { + transaction.commit().addCallback(new FutureCallback() { @Override - public void onSuccess(final Void result) { + public void onSuccess(final CommitInfo result) { LOG.trace("{}: Transaction({}) {} SUCCESSFUL", id, txType, transaction.getIdentifier()); } @@ -263,27 +251,21 @@ public final class NetconfDeviceTopologyAdapter implements AutoCloseable { throw new IllegalStateException( id + " Transaction(" + txType + ") not committed correctly", throwable); } - }); - - } - - private static Node getNodeWithId(final RemoteDeviceId id) { - final NodeBuilder builder = getNodeIdBuilder(id); - return builder.build(); + }, MoreExecutors.directExecutor()); } private static NodeBuilder getNodeIdBuilder(final RemoteDeviceId id) { final NodeBuilder nodeBuilder = new NodeBuilder(); - nodeBuilder.setKey(new NodeKey(new NodeId(id.getName()))); + nodeBuilder.withKey(new NodeKey(new NodeId(id.getName()))); return nodeBuilder; } @Override - public void close() throws Exception { + public void close() { removeDeviceConfiguration(); } - public void setTxChain(final BindingTransactionChain txChain) { + public void setTxChain(final TransactionChain txChain) { this.txChain = Preconditions.checkNotNull(txChain); } }