org.opendaylight.openflowjava.protocol.impl.core

Class TcpHandler

java.lang.Object

org.opendaylight.openflowjava.protocol.impl.core.TcpHandler

All Implemented Interfaces:

Runnable, OnlineProvider, ServerFacade, ShutdownProvider

public class TcpHandler
extends Object
implements ServerFacade

Class implementing server over TCP / TLS for handling incoming connections.

Author:

michal.polkorab

Constructor Summary

Constructors

Constructor and Description
TcpHandler(InetAddress address, int port, Runnable readyRunnable) Constructor of TCPHandler that listens on selected address and port.
TcpHandler(int port, Runnable readyRunnable) Constructor of TCPHandler that listens on selected port.

Method Summary

Modifier and Type	Method and Description
String	getAddress()
com.google.common.util.concurrent.ListenableFuture<Boolean>	getIsOnlineFuture()
int	getNumberOfConnections() Returns the number of connected clients / channels.
int	getPort()
io.netty.channel.EventLoopGroup	getWorkerGroup()
protected void	initiateEpollEventLoopGroups(ThreadConfiguration threadConfiguration) Initiate Epoll event loop groups with Nio as fall back.
void	initiateEventLoopGroups(ThreadConfiguration threadConfiguration, boolean isEpollEnabled) Initiate event loop groups.
void	initiateNioEventLoopGroups(ThreadConfiguration threadConfiguration) Initiate Nio event loop groups.
void	run() Starts server on selected port.
void	setChannelInitializer(TcpChannelInitializer channelInitializer)
void	setThreadConfig(ThreadConfiguration threadConfig) Sets thread configuration.
com.google.common.util.concurrent.ListenableFuture<Boolean>	shutdown() Shuts down TcpHandler}.

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpHandler

public TcpHandler(int port,
                  Runnable readyRunnable)

Constructor of TCPHandler that listens on selected port.

Parameters:

port - listening port of TCPHandler server

TcpHandler

public TcpHandler(InetAddress address,
                  int port,
                  Runnable readyRunnable)

Constructor of TCPHandler that listens on selected address and port.

Parameters:

address - listening address of TCPHandler server

port - listening port of TCPHandler server

Method Detail

run

public void run()

Starts server on selected port.

Specified by:

run in interface Runnable

shutdown

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

Shuts down TcpHandler}.

Specified by:

shutdown in interface ShutdownProvider

getNumberOfConnections

public int getNumberOfConnections()

Returns the number of connected clients / channels.

Returns:

number of connected clients / channels

getIsOnlineFuture

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

Specified by:

getIsOnlineFuture in interface OnlineProvider

getPort

public int getPort()

getAddress

public String getAddress()

setChannelInitializer

public void setChannelInitializer(TcpChannelInitializer channelInitializer)

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

initiateEventLoopGroups

public void initiateEventLoopGroups(ThreadConfiguration threadConfiguration,
                                    boolean isEpollEnabled)

Initiate event loop groups.

Parameters:

threadConfiguration - number of threads to be created, if not specified in threadConfig

initiateNioEventLoopGroups

public void initiateNioEventLoopGroups(ThreadConfiguration threadConfiguration)

Initiate Nio event loop groups.

Parameters:

threadConfiguration - number of threads to be created, if not specified in threadConfig

initiateEpollEventLoopGroups

protected void initiateEpollEventLoopGroups(ThreadConfiguration threadConfiguration)

Initiate Epoll event loop groups with Nio as fall back.

Parameters:

threadConfiguration - the ThreadConfiguration

getWorkerGroup

public io.netty.channel.EventLoopGroup getWorkerGroup()