Modifier and Type | Class and Description |
---|---|
private class |
RpcServer.Listener.Reader |
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private ServerSocketChannel |
acceptChannel |
private int |
backlogLength |
private long |
cleanupInterval |
private int |
currentReader |
private long |
lastCleanupRunTime |
private Random |
rand |
private RpcServer.Listener.Reader[] |
readers |
private ExecutorService |
readPool |
private Selector |
selector |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
RpcServer.Listener(String name) |
Modifier and Type | Method and Description |
---|---|
private void |
cleanupConnections(boolean force)
cleanup connections from connectionList.
|
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) RpcServer.Listener.Reader |
getReader() |
void |
run() |
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
private ServerSocketChannel acceptChannel
private Selector selector
private RpcServer.Listener.Reader[] readers
private int currentReader
private Random rand
private long lastCleanupRunTime
private long cleanupInterval
private int backlogLength
private ExecutorService readPool
public RpcServer.Listener(String name) throws IOException
IOException
private void cleanupConnections(boolean force)
force
- all connections will be looked at for cleanupprivate void closeCurrentConnection(SelectionKey key, Throwable e)
InetSocketAddress getAddress()
void doAccept(SelectionKey key) throws IOException, OutOfMemoryError
IOException
OutOfMemoryError
void doRead(SelectionKey key) throws InterruptedException
InterruptedException
void doStop()
RpcServer.Listener.Reader getReader()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.