Package 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

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
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	Description
AbstractNioSession(NioSessionConfig sessionConfig)

Method Summary

Modifier and Type	Method	Description
SelectableChannel	channel()	return the channel for this connection
protected void	closeChannel()
protected final long	doRealWrite(SelectableChannel channel, IoBuffer buffer)
final void	enableRead(Selector selector)	Enable read event
final 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 final void	flush0()
InetAddress	getLocalAddress()
private void	interestRead(SelectionKey key)
private void	interestWrite(SelectionKey key)
final void	onEvent(EventType event, Selector selector)	�ɷ�IO�¼�
protected void	onRead(SelectionKey key)
protected void	onWrite(SelectionKey key)
protected abstract void	readFromBuffer()
protected final void	registerSession()
protected boolean	schduleWriteMessage(WriteMessage writeMessage)
protected void	start0()
protected final 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 Details

selectorManager

protected SelectorManager selectorManager

selectableChannel

protected SelectableChannel selectableChannel

Constructor Details

AbstractNioSession

public AbstractNioSession(NioSessionConfig sessionConfig)

Method Details

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

Parameters:

selector -

interestRead

private void interestRead(SelectionKey key)

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

Parameters:

selector -

interestWrite

private void interestWrite(SelectionKey key)

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

Parameters:

event -

selector -