Package org.opendaylight.openflowjava.protocol.impl.core

Class TcpConnectionInitializer

java.lang.Object

org.opendaylight.openflowjava.protocol.impl.core.TcpConnectionInitializer

All Implemented Interfaces:

Runnable, ConnectionInitializer, OnlineProvider, ServerFacade, ShutdownProvider

public class TcpConnectionInitializer
extends Object
implements ServerFacade, ConnectionInitializer

Initializes (TCP) connection to device.

Author:

martin.uhlir

Constructor Summary

Constructors

Constructor	Description
TcpConnectionInitializer(io.netty.channel.EventLoopGroup workerGroup, boolean isEpollEnabled)	Constructor.

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<Boolean>	getIsOnlineFuture()
void	initiateConnection(String host, int port)	Initiates connection towards device.
void	run()
void	setChannelInitializer(TcpChannelInitializer channelInitializer)
void	setThreadConfig(ThreadConfiguration threadConfig)	Sets thread configuration.
com.google.common.util.concurrent.ListenableFuture<Boolean>	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpConnectionInitializer

public TcpConnectionInitializer(io.netty.channel.EventLoopGroup workerGroup,
                                boolean isEpollEnabled)

Constructor.

Parameters:

workerGroup - - shared worker group

Method Detail

run

public void run()

Specified by:

run in interface Runnable

shutdown

public com.google.common.util.concurrent.ListenableFuture<Boolean> shutdown()

Specified by:

shutdown in interface ShutdownProvider

getIsOnlineFuture

public com.google.common.util.concurrent.ListenableFuture<Boolean> getIsOnlineFuture()

Specified by:

getIsOnlineFuture in interface OnlineProvider

setThreadConfig

public void setThreadConfig(ThreadConfiguration threadConfig)

Description copied from interface: ServerFacade

Sets thread configuration.

Specified by:

setThreadConfig in interface ServerFacade

Parameters:

threadConfig - desired thread configuration

initiateConnection

public void initiateConnection(String host,
                               int port)

Description copied from interface: ConnectionInitializer

Initiates connection towards device.

Specified by:

initiateConnection in interface ConnectionInitializer

Parameters:

host - - host IP

port - - port number

setChannelInitializer

public void setChannelInitializer(TcpChannelInitializer channelInitializer)