com.google.code.yanf4j.nio.impl

Class AbstractNioSession

java.lang.Object

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

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

All Implemented Interfaces:

Session, NioSession

Direct Known Subclasses:

NioTCPSession

public abstract class AbstractNioSession
extends AbstractSession
implements NioSession

Abstract nio session

Author:

dennis

Nested Class Summary

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

Session.SessionStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected SelectableChannel	selectableChannel
protected SelectorManager	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 and Description
AbstractNioSession(NioSessionConfig sessionConfig)

Method Summary

Methods

Modifier and Type	Method and Description
SelectableChannel	channel() return the channel for this connection
protected void	closeChannel()
protected long	doRealWrite(SelectableChannel channel, IoBuffer buffer)
void	enableRead(Selector selector) Enable read event
void	enableWrite(Selector selector) Enable write event
void	flush() Flush the write queue,this method may be no effect if OP_WRITE is running.
protected void	flush0()
InetAddress	getLocalAddress()
void	onEvent(EventType event, Selector selector) �ɷ�IO�¼�
protected void	onRead(SelectionKey key)
protected void	onWrite(SelectionKey key)
protected abstract void	readFromBuffer()
protected void	registerSession()
protected boolean	schduleWriteMessage(WriteMessage writeMessage)
protected void	start0()
protected void	unregisterChannel()
protected void	unregisterSession()
void	writeFromUserCode(WriteMessage message)
protected abstract Object	writeToChannel(WriteMessage msg)

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

clearAttributes, clearWriteQueue, close, decode, dispatchReceivedMessage, getAttribute, getDecoder, getDispatchMessageDispatcher, getEncoder, getHandler, getLastOperationTimeStamp, getReadBuffer, getReadBufferByteOrder, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, getStatistics, getWriteLock, getWriteQueue, isClosed, isExpired, 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, wrapMessage, 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, getRemoteSocketAddress, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, isClosed, isExpired, isHandleReadWriteConcurrently, isIdle, isLoopbackConnection, isUseBlockingRead, isUseBlockingWrite, removeAttribute, setAttribute, setAttributeIfAbsent, setDecoder, setEncoder, setHandleReadWriteConcurrently, setReadBufferByteOrder, setSessionIdleTimeout, setSessionTimeout, setUseBlockingRead, setUseBlockingWrite, start, write

Field Detail

selectorManager

protected SelectorManager selectorManager

selectableChannel

protected SelectableChannel selectableChannel

Constructor Detail

AbstractNioSession

public AbstractNioSession(NioSessionConfig sessionConfig)

Method Detail

channel

public SelectableChannel channel()

Description copied from interface: NioSession

return the channel for this connection

Specified by:

channel in interface NioSession

Returns:

enableRead

public final void enableRead(Selector selector)

Description copied from interface: NioSession

Enable read event

Specified by:

enableRead in interface NioSession

start0

protected void start0()

Specified by:

start0 in class AbstractSession

getLocalAddress

public InetAddress getLocalAddress()

Specified by:

getLocalAddress in interface Session

writeToChannel

protected abstract Object writeToChannel(WriteMessage msg)
                                  throws ClosedChannelException,
                                         IOException

Throws:

ClosedChannelException

IOException

onWrite

protected void onWrite(SelectionKey key)

enableWrite

public final void enableWrite(Selector selector)

Description copied from interface: NioSession

Enable write event

Specified by:

enableWrite in interface NioSession

onRead

protected void onRead(SelectionKey key)

readFromBuffer

protected abstract void readFromBuffer()

closeChannel

protected void closeChannel()
                     throws IOException

Specified by:

closeChannel in class AbstractSession

Throws:

IOException

unregisterChannel

protected final void unregisterChannel()
                                throws IOException

Throws:

IOException

registerSession

protected final void registerSession()

unregisterSession

protected void unregisterSession()

writeFromUserCode

public void writeFromUserCode(WriteMessage message)

Specified by:

writeFromUserCode in class AbstractSession

schduleWriteMessage

protected boolean schduleWriteMessage(WriteMessage writeMessage)

flush

public void flush()

Description copied from interface: Session

Flush the write queue,this method may be no effect if OP_WRITE is running.

Specified by:

flush in interface Session

flush0

protected final void flush0()

doRealWrite

protected final long doRealWrite(SelectableChannel channel,
               IoBuffer buffer)
                          throws IOException

Throws:

IOException

onEvent

public final void onEvent(EventType event,
           Selector selector)

�ɷ�IO�¼�

Specified by:

onEvent in interface NioSession