org.apache.bookkeeper.proto
Class NIOServerFactory

java.lang.Object
  extended by java.lang.Thread
      extended by org.apache.bookkeeper.proto.NIOServerFactory
All Implemented Interfaces:
Runnable

public class NIOServerFactory
extends Thread

This class handles communication with clients using NIO. There is one Cnxn per client, but only one thread doing the communication.


Nested Class Summary
 class NIOServerFactory.Cnxn
           
static interface NIOServerFactory.PacketProcessor
           
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
NIOServerFactory(int port, NIOServerFactory.PacketProcessor processor)
           
 
Method Summary
 void clear()
          clear all the connections in the selector
 InetSocketAddress getLocalAddress()
           
 void run()
           
 void shutdown()
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

NIOServerFactory

public NIOServerFactory(int port,
                        NIOServerFactory.PacketProcessor processor)
                 throws IOException
Throws:
IOException
Method Detail

getLocalAddress

public InetSocketAddress getLocalAddress()

run

public void run()
Specified by:
run in interface Runnable
Overrides:
run in class Thread

clear

public void clear()
clear all the connections in the selector


shutdown

public void shutdown()