Package org.opendaylight.lispflowmapping.neutron.intenthandler.util

Class VppNetconfConnectionProbe

java.lang.Object

org.opendaylight.lispflowmapping.neutron.intenthandler.util.VppNetconfConnectionProbe

All Implemented Interfaces:

java.util.EventListener, org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>, org.opendaylight.mdsal.binding.api.DataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>

public class VppNetconfConnectionProbe
extends java.lang.Object
implements org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>

Purpose: verify whether provided netconf node is already connected or wait if not.

VppNetconfConnectionProbe registers istener which catches node-related changes from topology-netconf. A SettableFuture is set Boolean.TRUE, if the node is connected within NODE_CONNECTION_TIMER seconds. Else, proper exception is throws.

Field Summary

Fields

Modifier and Type	Field	Description
static int	NODE_CONNECTION_TIMER

Constructor Summary

Constructors

Constructor	Description
VppNetconfConnectionProbe(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId nodeId, org.opendaylight.mdsal.binding.api.DataBroker dataBroker)

Method Summary

Modifier and Type	Method	Description
void	onDataTreeChanged(java.util.Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> changes)
boolean	startProbing()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opendaylight.mdsal.binding.api.DataTreeChangeListener

onInitialData

Field Detail

NODE_CONNECTION_TIMER

public static final int NODE_CONNECTION_TIMER

See Also:

Constant Field Values

Constructor Detail

VppNetconfConnectionProbe

public VppNetconfConnectionProbe(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId nodeId,
                                 org.opendaylight.mdsal.binding.api.DataBroker dataBroker)

Method Detail

startProbing

public boolean startProbing()
                     throws java.util.concurrent.ExecutionException,
                            java.lang.InterruptedException,
                            java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

java.util.concurrent.TimeoutException

onDataTreeChanged

public void onDataTreeChanged(java.util.Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> changes)

Specified by:

onDataTreeChanged in interface org.opendaylight.mdsal.binding.api.DataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>