private class RpcServer.Listener.Reader extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
private boolean |
adding |
private Selector |
readSelector |
Constructor and Description |
---|
RpcServer.Listener.Reader() |
Modifier and Type | Method and Description |
---|---|
private void |
doRunLoop() |
void |
finishAdd() |
SelectionKey |
registerChannel(SocketChannel channel) |
void |
run() |
void |
startAdd()
This gets reader into the state that waits for the new channel
to be registered with readSelector.
|
private volatile boolean adding
private final Selector readSelector
RpcServer.Listener.Reader() throws IOException
IOException
private void doRunLoop()
public void startAdd()
public SelectionKey registerChannel(SocketChannel channel) throws IOException
IOException
public void finishAdd()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.