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.
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
Modifier and TypeFieldDescriptionprivate final SimpleRpcServer
Deprecated.private final Selector
Deprecated.private final Set<SimpleServerRpcConnection>
Deprecated.Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate void
doAsyncWrite
(SelectionKey key) Deprecated.(package private) void
doRespond
(SimpleServerRpcConnection conn, RpcResponse resp) Deprecated.private void
Deprecated.private boolean
processAllResponses
(SimpleServerRpcConnection connection) Deprecated.Process all the responses for this connectionprivate 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
Deprecated.Add a connection to the list that want to write,private void
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, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Field Details
-
simpleRpcServer
Deprecated. -
writeSelector
Deprecated. -
writingCons
Deprecated.
-
-
Constructor Details
-
SimpleRpcServerResponder
SimpleRpcServerResponder(SimpleRpcServer simpleRpcServer) throws IOException Deprecated.- Throws:
IOException
-
-
Method Details
-
run
Deprecated. -
registerWrites
Deprecated.Take the list of the connections that want to write, and register them in the selector. -
registerForWrite
Deprecated.Add a connection to the list that want to write, -
doRunLoop
Deprecated. -
purge
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
Deprecated.- Throws:
IOException
-
wrapWithSasl
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 onSimpleServerRpcConnection.responseWriteLock
- Returns:
- true if we proceed the call fully, false otherwise.
- Throws:
IOException
-
processAllResponses
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
Deprecated.- Throws:
IOException
-