Package org.opendaylight.netvirt.elan.l2gw.ha.listeners

Class HAOpClusteredListener

  • All Implemented Interfaces:
    java.lang.AutoCloseable, java.util.EventListener, org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>, org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>, org.opendaylight.serviceutils.srm.RecoverableListener
    @Singleton
public class HAOpClusteredListener
extends HwvtepNodeBaseListener<org.opendaylight.genius.infra.Datastore.Operational>
implements org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>, org.opendaylight.serviceutils.srm.RecoverableListener

    • Constructor Summary

      Constructors 
      Constructor Description
      HAOpClusteredListener​(org.opendaylight.controller.md.sal.binding.api.DataBroker db, org.opendaylight.genius.utils.hwvtep.HwvtepNodeHACache hwvtepNodeHACache, org.opendaylight.infrautils.metrics.MetricProvider metricProvider, L2GatewayServiceRecoveryHandler l2GatewayServiceRecoveryHandler, org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry serviceRecoveryRegistry)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void deregisterListener()  
      java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> getConnected​(java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> candidateds)  
      java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> getConnectedNodes()  
      void onGlobalNodeAdd​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> key, org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node updated, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)  
      void registerListener()  
      void runAfterNodeIsConnected​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> iid, java.util.function.Consumer<com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> consumer)  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener

        onDataTreeChanged

    • Constructor Detail

      • HAOpClusteredListener

        @Inject
public HAOpClusteredListener​(org.opendaylight.controller.md.sal.binding.api.DataBroker db,
                             org.opendaylight.genius.utils.hwvtep.HwvtepNodeHACache hwvtepNodeHACache,
                             org.opendaylight.infrautils.metrics.MetricProvider metricProvider,
                             L2GatewayServiceRecoveryHandler l2GatewayServiceRecoveryHandler,
                             org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry serviceRecoveryRegistry)
                      throws java.lang.Exception
        Throws:
        java.lang.Exception

    • Method Detail

      • registerListener

        public void registerListener()
        Specified by:
        registerListener in interface org.opendaylight.serviceutils.srm.RecoverableListener

      • deregisterListener

        public void deregisterListener()
        Specified by:
        deregisterListener in interface org.opendaylight.serviceutils.srm.RecoverableListener

      • getConnectedNodes

        public java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> getConnectedNodes()

      • onGlobalNodeAdd

        public void onGlobalNodeAdd​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> key,
                            org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node updated,
                            org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)

      • getConnected

        public java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> getConnected​(java.util.Set<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> candidateds)

      • runAfterNodeIsConnected

        public void runAfterNodeIsConnected​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> iid,
                                    java.util.function.Consumer<com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> consumer)