org.apache.hadoop.hbase.ipc

Class SimpleRpcServerResponder

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
class SimpleRpcServerResponder
extends Thread

Sends responses of RPC back to clients.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private SimpleRpcServer	simpleRpcServer
private Selector	writeSelector
private Set<SimpleServerRpcConnection>	writingCons

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SimpleRpcServerResponder(SimpleRpcServer simpleRpcServer)

Method Summary

Modifier and Type	Method and Description
private void	doAsyncWrite(SelectionKey key)
(package private) void	doRespond(SimpleServerRpcConnection conn, RpcResponse resp)
private void	doRunLoop()
private boolean	processAllResponses(SimpleServerRpcConnection connection) Process all the responses for this connection
private boolean	processResponse(SimpleServerRpcConnection conn, RpcResponse resp) Process the response for this call.
private long	purge(long lastPurgeTime) If there were some calls that have not been sent out for a long time, we close the connection.
void	registerForWrite(SimpleServerRpcConnection c) Add a connection to the list that want to write,
private void	registerWrites() Take the list of the connections that want to write, and register them in the selector.
void	run()

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

simpleRpcServer

private final SimpleRpcServer simpleRpcServer

writeSelector

private final Selector writeSelector

writingCons

private final Set<SimpleServerRpcConnection> writingCons

Constructor Detail

SimpleRpcServerResponder

SimpleRpcServerResponder(SimpleRpcServer simpleRpcServer)
                  throws IOException

Throws:

IOException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

registerWrites

private void registerWrites()

Take the list of the connections that want to write, and register them in the selector.

registerForWrite

public void registerForWrite(SimpleServerRpcConnection c)

Add a connection to the list that want to write,

doRunLoop

private void doRunLoop()

purge

private long purge(long lastPurgeTime)

If there were some calls that have not been sent out for a long time, we close the connection.

Returns:

the time of the purge.

doAsyncWrite

private void doAsyncWrite(SelectionKey key)
                   throws IOException

Throws:

IOException

processResponse

private boolean processResponse(SimpleServerRpcConnection conn,
                                RpcResponse resp)
                         throws IOException

Process the response for this call. You need to have the lock on SimpleServerRpcConnection.responseWriteLock

Returns:

true if we proceed the call fully, false otherwise.

Throws:

IOException

processAllResponses

private boolean processAllResponses(SimpleServerRpcConnection connection)
                             throws IOException

Process all the responses for this connection

Returns:

true if all the calls were processed or that someone else is doing it. false if there * is still some work to do. In this case, we expect the caller to delay us.

Throws:

IOException

doRespond

void doRespond(SimpleServerRpcConnection conn,
               RpcResponse resp)
        throws IOException

Throws:

IOException