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

Author:

dennis

Nested Class Summary

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

Session.SessionStatus

Field Summary

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 int	blockingRead()	Blocking read using temp selector
protected Object	blockingWrite(SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer)	Blocking write using temp selector
protected void	closeChannel()
void	decode()	Decode buffer
InetSocketAddress	getRemoteSocketAddress()	Return the remote end's InetSocketAddress
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

Constructor Detail

NioTCPSession

public NioTCPSession(NioSessionConfig sessionConfig,
                     int readRecvBufferSize)

Method Detail

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

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