org.apache.hadoop.hbase.ipc

类 RpcClientImpl.Connection

java.lang.Object

java.lang.Thread

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

所有已实现的接口:

Runnable

封闭类:

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.

嵌套类概要

从类继承的嵌套类/接口 java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

字段概要

字段

限定符和类型	字段和说明
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

从类继承的字段 java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

方法概要

方法

限定符和类型	方法和说明
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 boolean	readResponse()
void	run()
protected void	setupConnection()
protected void	setupIOstreams()
protected void	tracedWriteRequest(Call call, int priority, org.apache.htrace.Span span)
protected org.apache.hadoop.hbase.ipc.RpcClientImpl.WaitForWorkResult	waitForWork()

从类继承的方法 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

从类继承的方法 java.lang.Object

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

字段详细资料

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

方法详细资料

setupConnection

protected void setupConnection()
                        throws IOException

抛出:

IOException

closeConnection

protected void closeConnection()

waitForWork

protected org.apache.hadoop.hbase.ipc.RpcClientImpl.WaitForWorkResult waitForWork()
                                                                           throws InterruptedException

抛出:

InterruptedException

getRemoteAddress

public InetSocketAddress getRemoteAddress()

run

public void run()

指定者:

run 在接口中 Runnable

覆盖:

run 在类中 Thread

setupIOstreams

protected void setupIOstreams()
                       throws IOException

抛出:

IOException

close

protected void close()

Close the connection.

tracedWriteRequest

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

抛出:

IOException

readResponse

protected boolean readResponse()

markClosed

protected boolean markClosed(IOException e)

cleanupCalls

protected void cleanupCalls(boolean allCalls)

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

参数:

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