Package org.apache.hadoop.hbase.regionserver

Class RemoteProcedureResultReporter

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.regionserver.RemoteProcedureResultReporter

All Implemented Interfaces:

Runnable

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

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
RemoteProcedureResultReporter(HRegionServer server)

Method Summary

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

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

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

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 Details

RemoteProcedureResultReporter

public RemoteProcedureResultReporter(HRegionServer server)

Method Details

complete

public void complete(long procId,
 Throwable error)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread