net.sf.cindy.session.nio
Class AbstractChannelSession.ChannelReactorHandler

java.lang.Object
  net.sf.cindy.session.nio.AbstractChannelSession.ChannelReactorHandler

All Implemented Interfaces:

ReactorHandler

Enclosing class:

AbstractChannelSession

protected abstract class AbstractChannelSession.ChannelReactorHandler
extends java.lang.Object
implements ReactorHandler

Translate reactor events to session events.

Version:

$id$

Author:

Roger Chen

Constructor Summary

protected

AbstractChannelSession.ChannelReactorHandler()

Method Summary

protected void	checkSendPacket(Packet packet) Check send packet.
Session	getSession()
void	onAcceptable()
void	onConnectable()
void	onDeregistered()
void	onReadable()
void	onRegistered()
void	onTimeout()
void	onWritable()
protected void	read() Read packet from channel.
protected boolean	write(Packet packet) Write packet to channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.sf.cindy.session.nio.reactor.ReactorHandler

getChannels

Constructor Detail

AbstractChannelSession.ChannelReactorHandler

protected AbstractChannelSession.ChannelReactorHandler()

Method Detail

getSession

public Session getSession()

Specified by:

getSession in interface ReactorHandler

onTimeout

public void onTimeout()

Specified by:

onTimeout in interface ReactorHandler

onRegistered

public void onRegistered()

Specified by:

onRegistered in interface ReactorHandler

onDeregistered

public void onDeregistered()

Specified by:

onDeregistered in interface ReactorHandler

onAcceptable

public void onAcceptable()

Specified by:

onAcceptable in interface ReactorHandler

onConnectable

public void onConnectable()

Specified by:

onConnectable in interface ReactorHandler

onReadable

public void onReadable()

Specified by:

onReadable in interface ReactorHandler

read

protected void read()
             throws java.io.IOException

Read packet from channel.

Throws:

java.io.IOException - session will be closed

onWritable

public void onWritable()

Specified by:

onWritable in interface ReactorHandler

checkSendPacket

protected void checkSendPacket(Packet packet)

Check send packet.

Parameters:

packet - send packet

write

protected boolean write(Packet packet)
                 throws java.io.IOException

Write packet to channel.

Parameters:

packet - send packet

Returns:

if write succeeded, return true. if kennel buffer is full, return false.

Throws:

java.io.IOException - session will be closed