Package com.google.code.yanf4j.nio

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 com.google.code.yanf4j.nio.impl.SocketChannelController

soLingerOn

Fields inherited from class com.google.code.yanf4j.nio.impl.NioController

selectorManager, selectorPoolSize

Fields inherited from class com.google.code.yanf4j.core.impl.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 com.google.code.yanf4j.nio.impl.SocketChannelController

buildSession, configureSocketChannel, dispatchReadEvent, dispatchWriteEvent, setSoLinger

Methods inherited from class com.google.code.yanf4j.nio.impl.NioController

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

Methods inherited from class com.google.code.yanf4j.core.impl.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 java.lang.Object

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

Methods inherited from interface com.google.code.yanf4j.nio.SelectionKeyHandler

onConnect

Constructor Detail

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 Detail

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