org.apache.hadoop.hbase.ipc

Class SimpleRpcServer.Listener

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.SimpleRpcServer.Listener

All Implemented Interfaces:

Runnable

Enclosing class:

SimpleRpcServer

private class SimpleRpcServer.Listener
extends Thread

Listens on the socket. Creates jobs for the handler threads

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SimpleRpcServer.Listener.Reader

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private ServerSocketChannel	acceptChannel
private int	currentReader
private int	readerPendingConnectionQueueLength
private SimpleRpcServer.Listener.Reader[]	readers
private ExecutorService	readPool
private Selector	selector

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Listener(String name)

Method Summary

Modifier and Type	Method and Description
private void	closeCurrentConnection(SelectionKey key, Throwable e)
(package private) void	doAccept(SelectionKey key)
(package private) void	doRead(SelectionKey key)
(package private) void	doStop()
(package private) InetSocketAddress	getAddress()
(package private) SimpleRpcServer.Listener.Reader	getReader()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, 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

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

Field Detail

acceptChannel

private ServerSocketChannel acceptChannel

selector

private Selector selector

readers

private SimpleRpcServer.Listener.Reader[] readers

currentReader

private int currentReader

readerPendingConnectionQueueLength

private final int readerPendingConnectionQueueLength

readPool

private ExecutorService readPool

Constructor Detail

Listener

public Listener(String name)
         throws IOException

Throws:

IOException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

closeCurrentConnection

private void closeCurrentConnection(SelectionKey key,
                                    Throwable e)

getAddress

InetSocketAddress getAddress()

doAccept

void doAccept(SelectionKey key)
       throws InterruptedException,
              IOException,
              OutOfMemoryError

Throws:

InterruptedException

IOException

OutOfMemoryError

doRead

void doRead(SelectionKey key)
     throws InterruptedException

Throws:

InterruptedException

doStop

void doStop()

getReader

SimpleRpcServer.Listener.Reader getReader()