public class LispSouthboundPlugin extends Object implements IConfigLispSouthboundPlugin, AutoCloseable, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
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 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) |
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) |
protected static final org.slf4j.Logger LOG
public static final String LISPFLOWMAPPING_ENTITY_NAME
public static final org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier SERVICE_GROUP_IDENTIFIER
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)
public void init()
public void restoreDaoFromDatastore()
public void handleSerializedLispBuffer(TransportAddress address, ByteBuffer outBuffer, MessageType packetType)
public void handleSerializedLispBuffer(InetAddress address, ByteBuffer outBuffer, MessageType packetType, int portNumber, io.netty.channel.Channel senderChannel)
public void setLispAddress(String address)
setLispAddress
in interface IConfigLispSouthboundPlugin
public void shouldListenOnXtrPort(boolean shouldListenOnXtrPort)
shouldListenOnXtrPort
in interface IConfigLispSouthboundPlugin
public void setXtrPort(int port)
setXtrPort
in interface IConfigLispSouthboundPlugin
public void setMapRegisterCacheEnabled(boolean mapRegisterCacheEnabled)
public void setMapRegisterCacheTimeout(long mapRegisterCacheTimeout)
public void setBindingAddress(String bindingAddress)
public void close() throws Exception
close
in interface AutoCloseable
Exception
public void instantiateServiceInstance()
instantiateServiceInstance
in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
public com.google.common.util.concurrent.ListenableFuture<Void> closeServiceInstance()
closeServiceInstance
in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService
public org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier getIdentifier()
getIdentifier
in interface org.opendaylight.yangtools.concepts.Identifiable<org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier>
public void sendNotificationIfPossible(org.opendaylight.yangtools.yang.binding.Notification notification) throws InterruptedException
InterruptedException
public AuthKeyDb getAkdb()
public ConcurrentLispSouthboundStats getStats()
public org.opendaylight.controller.md.sal.binding.api.DataBroker getDataBroker()
public AuthenticationKeyDataListener getAuthenticationKeyDataListener()
public MapRegisterCache getMapRegisterCache()
public boolean isMapRegisterCacheEnabled()
public long getMapRegisterCacheTimeout()
Copyright © 2019 OpenDaylight. All rights reserved.