Package 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
Listens on the socket. Creates jobs for the handler threads
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
Modifier and TypeFieldDescriptionprivate ServerSocketChannel
private int
private final int
private SimpleRpcServer.Listener.Reader[]
private ExecutorService
private Selector
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate void
(package private) void
doAccept
(SelectionKey key) (package private) void
doRead
(SelectionKey key) (package private) void
doStop()
(package private) InetSocketAddress
(package private) SimpleRpcServer.Listener.Reader
void
run()
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Field Details
-
acceptChannel
-
selector
-
readers
-
currentReader
-
readerPendingConnectionQueueLength
-
readPool
-
-
Constructor Details
-
Listener
- Throws:
IOException
-
-
Method Details
-
run
-
closeCurrentConnection
-
getAddress
-
doAccept
-
doRead
- Throws:
InterruptedException
-
doStop
void doStop() -
getReader
-