com.google.code.yanf4j.core
Interface Controller

All Known Subinterfaces:

Connector

All Known Implementing Classes:

AbstractController, MemcachedConnector, NioController, SocketChannelController, TCPController

public interface Controller

Networking Controller

Author:

boyan

Method Summary

void	addStateListener(ControllerStateListener listener)
CodecFactory	getCodecFactory()
int	getDispatchMessageThreadCount()
Handler	getHandler()
java.net.InetSocketAddress	getLocalSocketAddress()
int	getPort()
int	getReadThreadCount()
double	getReceiveThroughputLimit()
double	getSendThroughputLimit()
long	getSessionIdleTimeout()
long	getSessionTimeout()
int	getSoTimeout()
Statistics	getStatistics()
int	getWriteThreadCount()
boolean	isHandleReadWriteConcurrently()
boolean	isStarted()
void	removeStateListener(ControllerStateListener listener)
void	setCodecFactory(CodecFactory codecFactory)
void	setDispatchMessageThreadCount(int dispatchMessageThreadPoolSize)
void	setHandler(Handler handler)
void	setHandleReadWriteConcurrently(boolean handleReadWriteConcurrently)
void	setLocalSocketAddress(java.net.InetSocketAddress inetAddress)
void	setReadThreadCount(int readThreadCount)
void	setReceiveThroughputLimit(double receivePacketRate)
void	setSendThroughputLimit(double sendThroughputLimit)
void	setSessionIdleTimeout(long sessionIdleTimeout)
void	setSessionTimeout(long sessionTimeout)
<T> void	setSocketOption(SocketOption<T> socketOption, T value)
void	setSoTimeout(int timeout)
void	setWriteThreadCount(int writeThreadCount)
void	start()
void	stop()

Method Detail

getSessionTimeout

long getSessionTimeout()

getSessionIdleTimeout

long getSessionIdleTimeout()

setSessionIdleTimeout

void setSessionIdleTimeout(long sessionIdleTimeout)

setSessionTimeout

void setSessionTimeout(long sessionTimeout)

getSoTimeout

int getSoTimeout()

setSoTimeout

void setSoTimeout(int timeout)

addStateListener

void addStateListener(ControllerStateListener listener)

removeStateListener

void removeStateListener(ControllerStateListener listener)

isHandleReadWriteConcurrently

boolean isHandleReadWriteConcurrently()

setHandleReadWriteConcurrently

void setHandleReadWriteConcurrently(boolean handleReadWriteConcurrently)

getReadThreadCount

int getReadThreadCount()

setReadThreadCount

void setReadThreadCount(int readThreadCount)

getHandler

Handler getHandler()

setHandler

void setHandler(Handler handler)

getPort

int getPort()

start

void start()
           throws java.io.IOException

Throws:

java.io.IOException

isStarted

boolean isStarted()

getStatistics

Statistics getStatistics()

getCodecFactory

CodecFactory getCodecFactory()

setCodecFactory

void setCodecFactory(CodecFactory codecFactory)

stop

void stop()
          throws java.io.IOException

Throws:

java.io.IOException

setReceiveThroughputLimit

void setReceiveThroughputLimit(double receivePacketRate)

getReceiveThroughputLimit

double getReceiveThroughputLimit()

getSendThroughputLimit

double getSendThroughputLimit()

setSendThroughputLimit

void setSendThroughputLimit(double sendThroughputLimit)

getLocalSocketAddress

java.net.InetSocketAddress getLocalSocketAddress()

setLocalSocketAddress

void setLocalSocketAddress(java.net.InetSocketAddress inetAddress)

getDispatchMessageThreadCount

int getDispatchMessageThreadCount()

setDispatchMessageThreadCount

void setDispatchMessageThreadCount(int dispatchMessageThreadPoolSize)

getWriteThreadCount

int getWriteThreadCount()

setWriteThreadCount

void setWriteThreadCount(int writeThreadCount)

setSocketOption

<T> void setSocketOption(SocketOption<T> socketOption,
                         T value)