Class TCPController

java.lang.Object

com.google.code.yanf4j.core.impl.AbstractController

com.google.code.yanf4j.nio.impl.NioController

com.google.code.yanf4j.nio.impl.SocketChannelController

com.google.code.yanf4j.nio.TCPController

All Implemented Interfaces:

Controller, ControllerLifeCycle, SelectionKeyHandler

public class TCPController
extends SocketChannelController

Controller for tcp server

Author:

dennis

Field Summary

Fields inherited from class SocketChannelController

soLingerOn

Fields inherited from class NioController

selectorManager, selectorPoolSize

Fields inherited from class AbstractController

codecFactory, configuration, dispatchMessageDispatcher, dispatchMessageThreadCount, handler, handleReadWriteConcurrently, localSocketAddress, log, readEventDispatcher, readThreadCount, sessionSet, sessionTimeout, socketOptions, soTimeout, started, stateListeners, statistics, statisticsInterval, writeEventDispatcher, writeThreadCount

Constructor Summary

Constructors

Constructor	Description
TCPController()
TCPController(Configuration configuration)
TCPController(Configuration configuration, CodecFactory codecFactory)
TCPController(Configuration configuration, Handler handler, CodecFactory codecFactory)

Method Summary

Modifier and Type	Method	Description
void	closeChannel(Selector selector)
protected void	doStart()	Inner startup
int	getBacklog()
void	onAccept(SelectionKey selectionKey)
void	setBacklog(int backlog)
void	setPerformancePreferences(int connectionTime, int latency, int bandwidth)
void	unbind()

Methods inherited from class SocketChannelController

buildSession, configureSocketChannel, dispatchReadEvent, dispatchWriteEvent, setSoLinger

Methods inherited from class NioController

bind, buildSessionConfig, closeSelectionKey, getSelectorManager, getSelectorPoolSize, initialSelectorManager, onRead, onWrite, setSelectorPoolSize, start0, stop0

Methods inherited from class AbstractController

addStateListener, bind, buildQueue, checkStatisticsForRestart, getCodecFactory, getConfiguration, getDispatchMessageThreadCount, getHandler, getLocalSocketAddress, getPort, getReadThreadCount, getReceiveThroughputLimit, getSendThroughputLimit, getSessionIdleTimeout, getSessionSet, getSessionTimeout, getSocketOption, getSoTimeout, getStatistics, getWriteThreadCount, isHandleReadWriteConcurrently, isStarted, notifyAllSessionClosed, notifyException, notifyReady, notifyStarted, notifyStopped, onConnect, registerSession, removeStateListener, setCodecFactory, setConfiguration, setDispatchMessageThreadCount, setHandler, setHandleReadWriteConcurrently, setLocalSocketAddress, setReadThreadCount, setReceiveThroughputLimit, setSendThroughputLimit, setSessionIdleTimeout, setSessionTimeout, setSocketOption, setSocketOptions, setSoTimeout, setWriteThreadCount, start, stop, unregisterSession

Methods inherited from class Object

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

Methods inherited from interface SelectionKeyHandler

onConnect

Constructor Details

TCPController

public TCPController()

TCPController

public TCPController(Configuration configuration)

TCPController

public TCPController(Configuration configuration,
 CodecFactory codecFactory)

TCPController

public TCPController(Configuration configuration,
 Handler handler,
 CodecFactory codecFactory)

Method Details

getBacklog

public int getBacklog()

setBacklog

public void setBacklog(int backlog)

setPerformancePreferences

public void setPerformancePreferences(int connectionTime,
 int latency,
 int bandwidth)

doStart

protected void doStart()
                throws IOException

Description copied from class: NioController

Inner startup

Specified by:

doStart in class NioController

Throws:

IOException

onAccept

public void onAccept(SelectionKey selectionKey)
              throws IOException

Specified by:

onAccept in interface SelectionKeyHandler

Overrides:

onAccept in class AbstractController

Throws:

IOException

closeChannel

public void closeChannel(Selector selector)
                  throws IOException

Throws:

IOException

unbind

public void unbind()
            throws IOException

Throws:

IOException