org.opendaylight.lispflowmapping.southbound

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 Summary

Fields

Modifier and Type	Field and Description
static String	LISPFLOWMAPPING_ENTITY_NAME
protected static org.slf4j.Logger	LOG
static org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier	SERVICE_GROUP_IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
LispSouthboundPlugin(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.controller.md.sal.binding.api.NotificationPublishService notificationPublishService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService)

Method Summary

Modifier and Type	Method and Description
void	close()
com.google.common.util.concurrent.ListenableFuture<Void>	closeServiceInstance()
AuthKeyDb	getAkdb()
AuthenticationKeyDataListener	getAuthenticationKeyDataListener()
org.opendaylight.controller.md.sal.binding.api.DataBroker	getDataBroker()
org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier	getIdentifier()
MapRegisterCache	getMapRegisterCache()
long	getMapRegisterCacheTimeout()
ConcurrentLispSouthboundStats	getStats()
void	handleSerializedLispBuffer(InetAddress address, ByteBuffer outBuffer, MessageType packetType, int portNumber, io.netty.channel.Channel senderChannel)
void	handleSerializedLispBuffer(TransportAddress address, ByteBuffer outBuffer, MessageType packetType)
void	init()
void	instantiateServiceInstance()
boolean	isMapRegisterCacheEnabled()
void	restoreDaoFromDatastore() Restore all keys from MDSAL datastore.
void	sendNotificationIfPossible(org.opendaylight.yangtools.yang.binding.Notification notification)
void	setBindingAddress(String bindingAddress)
void	setLispAddress(String address)
void	setMapRegisterCacheEnabled(boolean mapRegisterCacheEnabled)
void	setMapRegisterCacheTimeout(long mapRegisterCacheTimeout)
void	setXtrPort(int port)
void	shouldListenOnXtrPort(boolean shouldListenOnXtrPort)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

LISPFLOWMAPPING_ENTITY_NAME

public static final String LISPFLOWMAPPING_ENTITY_NAME

See Also:

Constant Field Values

SERVICE_GROUP_IDENTIFIER

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

Constructor Detail

LispSouthboundPlugin

public LispSouthboundPlugin(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                            org.opendaylight.controller.md.sal.binding.api.NotificationPublishService notificationPublishService,
                            org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService)

Method Detail

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.controller.md.sal.binding.api.DataBroker getDataBroker()

getAuthenticationKeyDataListener

public AuthenticationKeyDataListener getAuthenticationKeyDataListener()

getMapRegisterCache

public MapRegisterCache getMapRegisterCache()

isMapRegisterCacheEnabled

public boolean isMapRegisterCacheEnabled()

getMapRegisterCacheTimeout

public long getMapRegisterCacheTimeout()