org.apache.hadoop.hbase.regionserver

Class RemoteProcedureResultReporter

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.regionserver.RemoteProcedureResultReporter

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
class RemoteProcedureResultReporter
extends Thread

A thread which calls reportProcedureDone to tell master the result of a remote procedure.

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
private static int	INIT_PAUSE_TIME_MS
private static org.slf4j.Logger	LOG
private static int	MAX_BATCH
private LinkedBlockingQueue<org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RemoteProcedureResult>	results
private HRegionServer	server

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RemoteProcedureResultReporter(HRegionServer server)

Method Summary

Modifier and Type	Method and Description
void	complete(long procId, Throwable error)
void	run()

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

LOG

private static final org.slf4j.Logger LOG

INIT_PAUSE_TIME_MS

private static final int INIT_PAUSE_TIME_MS

See Also:

Constant Field Values

MAX_BATCH

private static final int MAX_BATCH

See Also:

Constant Field Values

server

private final HRegionServer server

results

private final LinkedBlockingQueue<org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RemoteProcedureResult> results

Constructor Detail

RemoteProcedureResultReporter

public RemoteProcedureResultReporter(HRegionServer server)

Method Detail

complete

public void complete(long procId,
                     Throwable error)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread