Package 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>

@Singleton
public class LispSouthboundPlugin
extends Object
implements IConfigLispSouthboundPlugin, AutoCloseable, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static @interface	LispSouthboundPlugin.Configuration

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
LispSouthboundPlugin(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService)
LispSouthboundPlugin(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService, String bindingAddress, boolean mapRegisterCacheEnabled, long mapRegisterCacheTimeout)
LispSouthboundPlugin(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService, LispSouthboundPlugin.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	close()
com.google.common.util.concurrent.ListenableFuture<Void>	closeServiceInstance()
AuthKeyDb	getAkdb()
AuthenticationKeyDataListener	getAuthenticationKeyDataListener()
org.opendaylight.mdsal.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	setLispAddress(String address)
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 Details

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 Details

LispSouthboundPlugin

@Inject
public LispSouthboundPlugin(org.opendaylight.mdsal.binding.api.DataBroker dataBroker,
 org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService,
 org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider clusterSingletonService)

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,
 LispSouthboundPlugin.Configuration configuration)

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,
 String bindingAddress,
 boolean mapRegisterCacheEnabled,
 long mapRegisterCacheTimeout)

Method Details

init

@PostConstruct
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

close

@PreDestroy
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()