Class SocketChannelController

java.lang.Object

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

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

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

All Implemented Interfaces:

Controller, ControllerLifeCycle, SelectionKeyHandler

Direct Known Subclasses:

MemcachedConnector, TCPController

public abstract class SocketChannelController
extends NioController

Nio tcp socket controller

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	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
SocketChannelController()
SocketChannelController(Configuration configuration)
SocketChannelController(Configuration configuration, CodecFactory codecFactory)
SocketChannelController(Configuration configuration, Handler handler, CodecFactory codecFactory)

Method Summary

Modifier and Type	Method	Description
protected NioSession	buildSession(SocketChannel sc)
protected final void	configureSocketChannel(SocketChannel sc)	Confiure socket channel
protected final void	dispatchReadEvent(SelectionKey key)	Dispatch read event
protected final void	dispatchWriteEvent(SelectionKey key)	Dispatch write event
void	setSoLinger(boolean on, int value)

Methods inherited from class NioController

bind, buildSessionConfig, closeSelectionKey, doStart, 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, onAccept, 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

closeChannel, onAccept, onConnect

Field Details

soLingerOn

protected boolean soLingerOn

Constructor Details

SocketChannelController

public SocketChannelController()

SocketChannelController

public SocketChannelController(Configuration configuration)

SocketChannelController

public SocketChannelController(Configuration configuration,
 CodecFactory codecFactory)

SocketChannelController

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

Method Details

setSoLinger

public void setSoLinger(boolean on,
 int value)

dispatchReadEvent

protected final void dispatchReadEvent(SelectionKey key)

Description copied from class: NioController

Dispatch read event

Specified by:

dispatchReadEvent in class NioController

Parameters:

key -

dispatchWriteEvent

protected final void dispatchWriteEvent(SelectionKey key)

Description copied from class: NioController

Dispatch write event

Specified by:

dispatchWriteEvent in class NioController

Parameters:

key -

buildSession

protected NioSession buildSession(SocketChannel sc)

configureSocketChannel

protected final void configureSocketChannel(SocketChannel sc)
                                     throws IOException

Confiure socket channel

Parameters:

sc -

Throws:

IOException