org.apache.hadoop.hbase.ipc

Class SimpleRpcServer.Listener.Reader

java.lang.Object

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

All Implemented Interfaces:

Runnable

Enclosing class:

SimpleRpcServer.Listener

private class SimpleRpcServer.Listener.Reader
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private LinkedBlockingQueue<SimpleServerRpcConnection>	pendingConnections
private Selector	readSelector

Constructor Summary

Constructors

Constructor and Description
Reader()

Method Summary

Modifier and Type	Method and Description
void	addConnection(SimpleServerRpcConnection conn) Updating the readSelector while it's being used is not thread-safe, so the connection must be queued.
private void	doRunLoop()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

pendingConnections

private final LinkedBlockingQueue<SimpleServerRpcConnection> pendingConnections

readSelector

private final Selector readSelector

Constructor Detail

Reader

Reader()
throws IOException

Throws:

IOException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

doRunLoop

private void doRunLoop()

addConnection

public void addConnection(SimpleServerRpcConnection conn)
                   throws IOException

Updating the readSelector while it's being used is not thread-safe, so the connection must be queued. The reader will drain the queue and update its readSelector before performing the next select

Throws:

IOException