org.apache.hadoop.hbase.ipc

Class RpcClientImpl.Connection

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

RpcClientImpl

protected class RpcClientImpl.Connection
extends java.lang.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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ConcurrentSkipListMap<java.lang.Integer,Call>	calls
protected org.apache.hadoop.hbase.ipc.RpcClientImpl.Connection.CallSender	callSender
protected java.io.DataInputStream	in
protected java.io.DataOutputStream	out
protected ConnectionId	remoteId
protected java.util.concurrent.atomic.AtomicBoolean	shouldCloseConnection
protected java.net.Socket	socket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

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()
java.net.InetSocketAddress	getRemoteAddress()
protected boolean	markClosed(java.io.IOException e)
protected void	readResponse()
void	run()
protected void	setupConnection()
protected void	setupIOstreams()
protected void	tracedWriteRequest(Call call, int priority, 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 java.net.Socket socket

in

protected java.io.DataInputStream in

out

protected java.io.DataOutputStream out

calls

protected final java.util.concurrent.ConcurrentSkipListMap<java.lang.Integer,Call> calls

shouldCloseConnection

protected final java.util.concurrent.atomic.AtomicBoolean shouldCloseConnection

callSender

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

Method Detail

setupConnection

protected void setupConnection()
                        throws java.io.IOException

Throws:

java.io.IOException

closeConnection

protected void closeConnection()

waitForWork

protected boolean waitForWork()
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getRemoteAddress

public java.net.InetSocketAddress getRemoteAddress()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

setupIOstreams

protected void setupIOstreams()
                       throws java.io.IOException

Throws:

java.io.IOException

close

protected void close()

Close the connection.

tracedWriteRequest

protected void tracedWriteRequest(Call call,
                                  int priority,
                                  Span span)
                           throws java.io.IOException

Throws:

java.io.IOException

readResponse

protected void readResponse()

markClosed

protected boolean markClosed(java.io.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