org.apache.http.impl.nio.reactor
Class AbstractIOReactor

java.lang.Object
  extended byorg.apache.http.impl.nio.reactor.AbstractIOReactor
All Implemented Interfaces:
IOReactor
Direct Known Subclasses:
BaseIOReactor

public abstract class AbstractIOReactor
extends java.lang.Object
implements IOReactor


Field Summary
protected  IOEventDispatch eventDispatch
           
 
Constructor Summary
AbstractIOReactor(long selectTimeout)
           
 
Method Summary
protected abstract  void acceptable(java.nio.channels.SelectionKey key)
           
 void addChannel(ChannelEntry channelEntry)
           
protected abstract  void connectable(java.nio.channels.SelectionKey key)
           
 void execute(IOEventDispatch eventDispatch)
           
protected abstract  IOSession keyCancelled(java.nio.channels.SelectionKey key)
           
protected abstract  void keyCreated(java.nio.channels.SelectionKey key, IOSession session)
           
protected abstract  void readable(java.nio.channels.SelectionKey key)
           
 void shutdown()
           
protected abstract  void timeoutCheck(java.nio.channels.SelectionKey key, long now)
           
protected abstract  void validate(java.util.Set keys)
           
protected abstract  void writable(java.nio.channels.SelectionKey key)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

eventDispatch

protected IOEventDispatch eventDispatch
Constructor Detail

AbstractIOReactor

public AbstractIOReactor(long selectTimeout)
                  throws IOReactorException
Method Detail

acceptable

protected abstract void acceptable(java.nio.channels.SelectionKey key)

connectable

protected abstract void connectable(java.nio.channels.SelectionKey key)

readable

protected abstract void readable(java.nio.channels.SelectionKey key)

writable

protected abstract void writable(java.nio.channels.SelectionKey key)

timeoutCheck

protected abstract void timeoutCheck(java.nio.channels.SelectionKey key,
                                     long now)

validate

protected abstract void validate(java.util.Set keys)

keyCreated

protected abstract void keyCreated(java.nio.channels.SelectionKey key,
                                   IOSession session)

keyCancelled

protected abstract IOSession keyCancelled(java.nio.channels.SelectionKey key)

addChannel

public void addChannel(ChannelEntry channelEntry)

execute

public void execute(IOEventDispatch eventDispatch)
             throws java.io.InterruptedIOException,
                    IOReactorException
Specified by:
execute in interface IOReactor
Throws:
java.io.InterruptedIOException
IOReactorException

shutdown

public void shutdown()
              throws IOReactorException
Specified by:
shutdown in interface IOReactor
Throws:
IOReactorException


Copyright © 2005-2007 Apache Software Foundation. All Rights Reserved.