Package com.google.code.yanf4j.nio.impl

Class NioTCPSession

java.lang.Object

com.google.code.yanf4j.core.impl.AbstractSession

com.google.code.yanf4j.nio.impl.AbstractNioSession

com.google.code.yanf4j.nio.impl.NioTCPSession

All Implemented Interfaces:

Session, NioSession

Direct Known Subclasses:

MemcachedTCPSession

public class NioTCPSession
extends AbstractNioSession

Nio tcp connection

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.code.yanf4j.core.Session

Session.SessionStatus

Field Summary

Fields

Modifier and Type	Field	Description
private InetSocketAddress	remoteAddress

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

selectableChannel, selectorManager

Fields inherited from class com.google.code.yanf4j.core.impl.AbstractSession

attributes, closed, currentMessage, decoder, dispatchMessageDispatcher, encoder, handler, handleReadWriteConcurrently, lastOperationTimeStamp, log, loopback, readBuffer, scheduleWritenBytes, sessionIdleTimeout, sessionTimeout, statistics, useBlockingRead, useBlockingWrite, writeLock, writeQueue

Constructor Summary

Constructors

Constructor	Description
NioTCPSession(NioSessionConfig sessionConfig, int readRecvBufferSize)

Method Summary

Modifier and Type	Method	Description
protected final int	blockingRead()	Blocking read using temp selector
protected final Object	blockingWrite(SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer)	Blocking write using temp selector
protected final void	closeChannel()
void	decode()	Decode buffer
private void	decodeAndDispatch()
InetSocketAddress	getRemoteSocketAddress()	Return the remote end's InetSocketAddress
final boolean	isExpired()	Return true if session is expired,session is expired beacause you set the sessionTimeout,if since session's last operation form now is over this vlaue,isExpired return true,and Handler.onExpired() will be invoked.
protected void	readFromBuffer()
Socket	socket()
protected WriteMessage	wrapMessage(Object msg, Future<Boolean> writeFuture)
protected Object	writeToChannel(WriteMessage message)

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

channel, doRealWrite, enableRead, enableWrite, flush, flush0, getLocalAddress, onEvent, onRead, onWrite, registerSession, schduleWriteMessage, start0, unregisterChannel, unregisterSession, writeFromUserCode

Methods inherited from class com.google.code.yanf4j.core.impl.AbstractSession

clearAttributes, clearWriteQueue, close, dispatchReceivedMessage, getAttribute, getDecoder, getDispatchMessageDispatcher, getEncoder, getHandler, getLastOperationTimeStamp, getReadBuffer, getReadBufferByteOrder, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, getStatistics, getWriteLock, getWriteQueue, isClosed, isHandleReadWriteConcurrently, isIdle, isLoopbackConnection, isUseBlockingRead, isUseBlockingWrite, onClosed, onConnected, onCreated, onException, onExpired, onIdle, onStarted, preprocessWriteMessage, removeAttribute, setAttribute, setAttributeIfAbsent, setClosed, setDecoder, setEncoder, setHandleReadWriteConcurrently, setReadBuffer, setReadBufferByteOrder, setSessionIdleTimeout, setSessionTimeout, setUseBlockingRead, setUseBlockingWrite, start, transferFrom, transferTo, updateTimeStamp, write

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.core.Session

clearAttributes, close, getAttribute, getDecoder, getEncoder, getHandler, getLastOperationTimeStamp, getReadBufferByteOrder, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, isClosed, isHandleReadWriteConcurrently, isIdle, isLoopbackConnection, isUseBlockingRead, isUseBlockingWrite, removeAttribute, setAttribute, setAttributeIfAbsent, setDecoder, setEncoder, setHandleReadWriteConcurrently, setReadBufferByteOrder, setSessionIdleTimeout, setSessionTimeout, setUseBlockingRead, setUseBlockingWrite, start, write

Field Details

remoteAddress

private InetSocketAddress remoteAddress

Constructor Details

NioTCPSession

public NioTCPSession(NioSessionConfig sessionConfig,
 int readRecvBufferSize)

Method Details

isExpired

public final boolean isExpired()

Description copied from interface: Session

Return true if session is expired,session is expired beacause you set the sessionTimeout,if since session's last operation form now is over this vlaue,isExpired return true,and Handler.onExpired() will be invoked.

Specified by:

isExpired in interface Session

Overrides:

isExpired in class AbstractSession

Returns:

writeToChannel

protected Object writeToChannel(WriteMessage message)
                         throws IOException

Specified by:

writeToChannel in class AbstractNioSession

Throws:

IOException

getRemoteSocketAddress

public InetSocketAddress getRemoteSocketAddress()

Description copied from interface: Session

Return the remote end's InetSocketAddress

Returns:

blockingWrite

protected final Object blockingWrite(SelectableChannel channel,
 WriteMessage message,
 IoBuffer writeBuffer)
                              throws IOException,
ClosedChannelException

Blocking write using temp selector

Parameters:

channel -

message -

writeBuffer -

Returns:

Throws:

IOException

ClosedChannelException

wrapMessage

protected WriteMessage wrapMessage(Object msg,
 Future<Boolean> writeFuture)

Specified by:

wrapMessage in class AbstractSession

readFromBuffer

protected void readFromBuffer()

Specified by:

readFromBuffer in class AbstractNioSession

decodeAndDispatch

private void decodeAndDispatch()

blockingRead

protected final int blockingRead()
                          throws ClosedChannelException,
IOException

Blocking read using temp selector

Returns:

Throws:

ClosedChannelException

IOException

decode

public void decode()

Decode buffer

Specified by:

decode in class AbstractSession

socket

public Socket socket()

closeChannel

protected final void closeChannel()
                           throws IOException

Overrides:

closeChannel in class AbstractNioSession

Throws:

IOException