Package org.apache.hadoop.hbase.ipc

Class SimpleRpcServerResponder

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder

All Implemented Interfaces:

Runnable

@Deprecated
@Private
class SimpleRpcServerResponder
extends Thread

Deprecated.

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	Description
private final SimpleRpcServer	simpleRpcServer	Deprecated.
private final Selector	writeSelector	Deprecated.
private final Set<SimpleServerRpcConnection>	writingCons	Deprecated.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
SimpleRpcServerResponder(SimpleRpcServer simpleRpcServer)	Deprecated.

Method Summary

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

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 Details

simpleRpcServer

private final SimpleRpcServer simpleRpcServer

Deprecated.

writeSelector

private final Selector writeSelector

Deprecated.

writingCons

private final Set<SimpleServerRpcConnection> writingCons

Deprecated.

Constructor Details

SimpleRpcServerResponder

SimpleRpcServerResponder(SimpleRpcServer simpleRpcServer)
                  throws IOException

Deprecated.

Throws:

IOException

Method Details

run

public void run()

Deprecated.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

registerWrites

private void registerWrites()

Deprecated.

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

registerForWrite

public void registerForWrite(SimpleServerRpcConnection c)

Deprecated.

Add a connection to the list that want to write,

doRunLoop

private void doRunLoop()

Deprecated.

purge

private long purge(long lastPurgeTime)

Deprecated.

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

Deprecated.

Throws:

IOException

wrapWithSasl

private BufferChain wrapWithSasl(HBaseSaslRpcServer saslServer,
 BufferChain bc)
                          throws IOException

Deprecated.

Throws:

IOException

processResponse

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

Deprecated.

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

Deprecated.

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

Deprecated.

Throws:

IOException