Package 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	Description
private final LinkedBlockingQueue<SimpleServerRpcConnection>	pendingConnections
private final Selector	readSelector

Constructor Summary

Constructors

Constructor	Description
Reader()

Method Summary

Modifier and Type	Method	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 Details

pendingConnections

private final LinkedBlockingQueue<SimpleServerRpcConnection> pendingConnections

readSelector

private final Selector readSelector

Constructor Details

Reader

Reader()
throws IOException

Throws:

IOException

Method Details

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