org.opendaylight.ovsdb.lib.impl

Class OvsdbConnectionService

java.lang.Object

org.opendaylight.ovsdb.lib.impl.OvsdbConnectionService

All Implemented Interfaces:

AutoCloseable, OvsdbConnection

public class OvsdbConnectionService
extends Object
implements AutoCloseable, OvsdbConnection

OvsDBConnectionService provides OVSDB connection management functionality which includes both Active and Passive connections. From the Library perspective, Active OVSDB connections are those that are initiated from the Controller towards the ovsdb-manager. While Passive OVSDB connections are those that are initiated from the ovs towards the controller.

Applications that use OvsDBConnectionService can use the OvsDBConnection class' connect APIs to initiate Active connections and can listen to the asynchronous Passive connections via registerConnectionListener listener API.

The library is designed as Java modular component that can work in both OSGi and non-OSGi environment. Hence a single instance of the service will be active (via Service Registry in OSGi) and a Singleton object in a non-OSGi environment.

Constructor Summary

Constructors

Constructor and Description
OvsdbConnectionService()

Method Summary

Methods

Modifier and Type	Method and Description
static void	channelClosed(OvsdbClient client)
void	close()
OvsdbClient	connect(InetAddress address, int port) connect API can be used by the applications to initiate Active connection from the controller towards ovsdb-server.
OvsdbClient	connectWithSsl(InetAddress address, int port, SSLContext sslContext) connect API can be used by the applications to initiate Active ssl connection from the controller towards ovsdb-server.
void	disconnect(OvsdbClient client) Method to disconnect an existing connection.
OvsdbClient	getClient(io.netty.channel.Channel channel)
Collection<OvsdbClient>	getConnections() Returns a Collection of all the active OVSDB Connections.
static OvsdbConnection	getService()
static void	notifyListenerForPassiveConnection(OvsdbClient client)
void	registerConnectionListener(OvsdbConnectionListener listener) Method to register a Passive Connection Listener with the ConnectionService.
void	setOvsdbRpcTaskTimeout(int interval)
boolean	startOvsdbManager(int ovsdbListenPort) Method that initiates the Passive OVSDB channel listening functionality.
boolean	startOvsdbManagerWithSsl(int ovsdbListenPort, SSLContext sslContext) Method that initiates the Passive OVSDB channel listening functionality with ssl.By default the ovsdb passive connection will listen in port 6640 which can be overridden using the ovsdb.listenPort system property.
void	unregisterConnectionListener(OvsdbConnectionListener listener) Method to unregister a Passive Connection Listener with the ConnectionService.

Methods inherited from class java.lang.Object

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

Constructor Detail

OvsdbConnectionService

public OvsdbConnectionService()

Method Detail

getService

public static OvsdbConnection getService()

connect

public OvsdbClient connect(InetAddress address,
                  int port)

Description copied from interface: OvsdbConnection

connect API can be used by the applications to initiate Active connection from the controller towards ovsdb-server.

Specified by:

connect in interface OvsdbConnection

Parameters:

address - IP Address of the remote server that hosts the ovsdb server.

port - Layer 4 port on which the remote ovsdb server is listening on.

Returns:

OvsDBClient The primary Client interface for the ovsdb connection.

connectWithSsl

public OvsdbClient connectWithSsl(InetAddress address,
                         int port,
                         SSLContext sslContext)

Description copied from interface: OvsdbConnection

connect API can be used by the applications to initiate Active ssl connection from the controller towards ovsdb-server.

Specified by:

connectWithSsl in interface OvsdbConnection

Parameters:

address - IP Address of the remote server that hosts the ovsdb server.

port - Layer 4 port on which the remote ovsdb server is listening on.

sslContext - Netty sslContext for channel configuration

Returns:

OvsDBClient The primary Client interface for the ovsdb connection.

disconnect

public void disconnect(OvsdbClient client)

Description copied from interface: OvsdbConnection

Method to disconnect an existing connection.

Specified by:

disconnect in interface OvsdbConnection

Parameters:

client - that represents the ovsdb connection.

registerConnectionListener

public void registerConnectionListener(OvsdbConnectionListener listener)

Description copied from interface: OvsdbConnection

Method to register a Passive Connection Listener with the ConnectionService.

Specified by:

registerConnectionListener in interface OvsdbConnection

Parameters:

listener - Passive Connection listener interested in Passive OVSDB connection requests.

unregisterConnectionListener

public void unregisterConnectionListener(OvsdbConnectionListener listener)

Description copied from interface: OvsdbConnection

Method to unregister a Passive Connection Listener with the ConnectionService.

Specified by:

unregisterConnectionListener in interface OvsdbConnection

startOvsdbManager

public boolean startOvsdbManager(int ovsdbListenPort)

Method that initiates the Passive OVSDB channel listening functionality. By default the ovsdb passive connection will listen in port 6640 which can be overridden using the ovsdb.listenPort system property.

Specified by:

startOvsdbManager in interface OvsdbConnection

startOvsdbManagerWithSsl

public boolean startOvsdbManagerWithSsl(int ovsdbListenPort,
                               SSLContext sslContext)

Method that initiates the Passive OVSDB channel listening functionality with ssl.By default the ovsdb passive connection will listen in port 6640 which can be overridden using the ovsdb.listenPort system property.

Specified by:

startOvsdbManagerWithSsl in interface OvsdbConnection

channelClosed

public static void channelClosed(OvsdbClient client)

getConnections

public Collection<OvsdbClient> getConnections()

Description copied from interface: OvsdbConnection

Returns a Collection of all the active OVSDB Connections.

Specified by:

getConnections in interface OvsdbConnection

Returns:

Collection of all the active OVSDB Connections

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getClient

public OvsdbClient getClient(io.netty.channel.Channel channel)

Specified by:

getClient in interface OvsdbConnection

notifyListenerForPassiveConnection

public static void notifyListenerForPassiveConnection(OvsdbClient client)

setOvsdbRpcTaskTimeout

public void setOvsdbRpcTaskTimeout(int interval)