Class LispSouthboundPlugin

java.lang.Object
org.opendaylight.lispflowmapping.southbound.LispSouthboundPlugin
All Implemented Interfaces:
AutoCloseable, IConfigLispSouthboundPlugin, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService, org.opendaylight.yangtools.concepts.Identifiable<org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier>

public class LispSouthboundPlugin extends Object implements IConfigLispSouthboundPlugin, AutoCloseable, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
  • Field Details

    • LOG

      protected static final org.slf4j.Logger LOG
    • LISPFLOWMAPPING_ENTITY_NAME

      public static final String LISPFLOWMAPPING_ENTITY_NAME
      See Also:
    • SERVICE_GROUP_IDENTIFIER

      public static final org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier SERVICE_GROUP_IDENTIFIER
  • Constructor Details

    • LispSouthboundPlugin

      public LispSouthboundPlugin(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService)
  • Method Details

    • init

      public void init()
    • restoreDaoFromDatastore

      public void restoreDaoFromDatastore()
      Restore all keys from MDSAL datastore.
    • handleSerializedLispBuffer

      public void handleSerializedLispBuffer(TransportAddress address, ByteBuffer outBuffer, MessageType packetType)
    • handleSerializedLispBuffer

      public void handleSerializedLispBuffer(InetAddress address, ByteBuffer outBuffer, MessageType packetType, int portNumber, io.netty.channel.Channel senderChannel)
    • setLispAddress

      public void setLispAddress(String address)
      Specified by:
      setLispAddress in interface IConfigLispSouthboundPlugin
    • shouldListenOnXtrPort

      public void shouldListenOnXtrPort(boolean shouldListenOnXtrPort)
      Specified by:
      shouldListenOnXtrPort in interface IConfigLispSouthboundPlugin
    • setXtrPort

      public void setXtrPort(int port)
      Specified by:
      setXtrPort in interface IConfigLispSouthboundPlugin
    • setMapRegisterCacheEnabled

      public void setMapRegisterCacheEnabled(boolean mapRegisterCacheEnabled)
    • setMapRegisterCacheTimeout

      public void setMapRegisterCacheTimeout(long mapRegisterCacheTimeout)
    • setBindingAddress

      public void setBindingAddress(String bindingAddress)
    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception
    • instantiateServiceInstance

      public void instantiateServiceInstance()
      Specified by:
      instantiateServiceInstance in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
    • closeServiceInstance

      public com.google.common.util.concurrent.ListenableFuture<Void> closeServiceInstance()
      Specified by:
      closeServiceInstance in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
    • getIdentifier

      public org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier getIdentifier()
      Specified by:
      getIdentifier in interface org.opendaylight.yangtools.concepts.Identifiable<org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier>
    • sendNotificationIfPossible

      public void sendNotificationIfPossible(org.opendaylight.yangtools.yang.binding.Notification notification) throws InterruptedException
      Throws:
      InterruptedException
    • getAkdb

      public AuthKeyDb getAkdb()
    • getStats

      public ConcurrentLispSouthboundStats getStats()
    • getDataBroker

      public org.opendaylight.mdsal.binding.api.DataBroker getDataBroker()
    • getAuthenticationKeyDataListener

      public AuthenticationKeyDataListener getAuthenticationKeyDataListener()
    • getMapRegisterCache

      public MapRegisterCache getMapRegisterCache()
    • isMapRegisterCacheEnabled

      public boolean isMapRegisterCacheEnabled()
    • getMapRegisterCacheTimeout

      public long getMapRegisterCacheTimeout()