org.apache.hadoop.hbase.ipc

Class RpcClientImpl.Connection

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.RpcClientImpl.Connection

All Implemented Interfaces:

Runnable

Enclosing class:

RpcClientImpl

protected class RpcClientImpl.Connection
extends Thread

Thread that reads responses and notifies callers. Each connection owns a socket connected to a remote address. Calls are multiplexed through this socket: responses may be delivered out of order.

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
protected ConcurrentSkipListMap<Integer,Call>	calls
protected org.apache.hadoop.hbase.ipc.RpcClientImpl.Connection.CallSender	callSender
protected DataInputStream	in
protected DataOutputStream	out
protected ConnectionId	remoteId
protected AtomicBoolean	shouldCloseConnection
protected Socket	socket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Methods

Modifier and Type	Method and Description
protected void	cleanupCalls(boolean allCalls) Cleanup the calls older than a given timeout, in milli seconds.
protected void	close() Close the connection.
protected void	closeConnection()
InetSocketAddress	getRemoteAddress()
protected boolean	markClosed(IOException e)
protected void	readResponse()
void	run()
protected void	setupConnection()
protected void	setupIOstreams()
protected void	tracedWriteRequest(Call call, int priority, org.apache.htrace.Span span)
protected boolean	waitForWork()

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

remoteId

protected ConnectionId remoteId

socket

protected Socket socket

in

protected DataInputStream in

out

protected DataOutputStream out

calls

protected final ConcurrentSkipListMap<Integer,Call> calls

shouldCloseConnection

protected final AtomicBoolean shouldCloseConnection

callSender

protected final org.apache.hadoop.hbase.ipc.RpcClientImpl.Connection.CallSender callSender

Method Detail

setupConnection

protected void setupConnection()
                        throws IOException

Throws:

IOException

closeConnection

protected void closeConnection()

waitForWork

protected boolean waitForWork()
                       throws InterruptedException

Throws:

InterruptedException

getRemoteAddress

public InetSocketAddress getRemoteAddress()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

setupIOstreams

protected void setupIOstreams()
                       throws IOException

Throws:

IOException

close

protected void close()

Close the connection.

tracedWriteRequest

protected void tracedWriteRequest(Call call,
                      int priority,
                      org.apache.htrace.Span span)
                           throws IOException

Throws:

IOException

readResponse

protected void readResponse()

markClosed

protected boolean markClosed(IOException e)

cleanupCalls

protected void cleanupCalls(boolean allCalls)

Cleanup the calls older than a given timeout, in milli seconds.

Parameters:

allCalls - true for all calls, false for only the calls in timeout