Uses of Class
org.apache.hadoop.hbase.errorhandling.ForeignException
Package
Description
-
Uses of ForeignException in org.apache.hadoop.hbase.backup.regionserver
Modifier and TypeMethodDescriptionbyte[]
LogRollBackupSubprocedure.insideBarrier()
do a log roll.private void
LogRollBackupSubprocedure.rolllog()
boolean
LogRollBackupSubprocedurePool.waitForOutstandingTasks()
Wait for all of the currently outstanding tasks submitted viaLogRollBackupSubprocedurePool.submitTask(Callable)
-
Uses of ForeignException in org.apache.hadoop.hbase.errorhandling
Modifier and TypeMethodDescriptionstatic ForeignException
ForeignException.deserialize
(byte[] bytes) Takes a series of bytes and tries to generate an ForeignException instance for it.ForeignExceptionDispatcher.getException()
ForeignExceptionSnare.getException()
Get the value of the captured exception.Modifier and TypeMethodDescriptionprivate void
ForeignExceptionDispatcher.dispatch
(ForeignException e) Sends an exception to all listeners.void
ForeignExceptionDispatcher.receive
(ForeignException e) void
ForeignExceptionListener.receive
(ForeignException e) Receive a ForeignException.Modifier and TypeMethodDescriptionvoid
ForeignExceptionDispatcher.rethrowException()
void
ForeignExceptionSnare.rethrowException()
Rethrow an exception currently held by theForeignExceptionSnare
. -
Uses of ForeignException in org.apache.hadoop.hbase.master
Modifier and TypeMethodDescriptionSnapshotSentinel.getExceptionIfFailed()
Get the exception that caused the snapshot to fail, if the snapshot has failed.Modifier and TypeMethodDescriptionvoid
SnapshotSentinel.rethrowExceptionIfFailed()
Rethrow the exception returned bySnapshotSentinel.getExceptionIfFailed()
. -
Uses of ForeignException in org.apache.hadoop.hbase.master.snapshot
Modifier and TypeMethodDescriptionTakeSnapshotHandler.getException()
TakeSnapshotHandler.getExceptionIfFailed()
Modifier and TypeMethodDescriptionvoid
TakeSnapshotHandler.rethrowException()
void
TakeSnapshotHandler.rethrowExceptionIfFailed()
-
Uses of ForeignException in org.apache.hadoop.hbase.procedure
Modifier and TypeMethodDescriptionvoid
ProcedureCoordinator.abortProcedure
(String procName, ForeignException reason) Abort the procedure with the given namevoid
Procedure.receive
(ForeignException e) A callback that handles incoming ForeignExceptions.void
ProcedureMember.receiveAbortProcedure
(String procName, ForeignException ee) Send abort to the specified procedurevoid
ProcedureCoordinatorRpcs.sendAbortToMembers
(Procedure procName, ForeignException cause) Notify the members that the coordinator has aborted the procedure and that it should release barrier resources.final void
ZKProcedureCoordinator.sendAbortToMembers
(Procedure proc, ForeignException ee) This is the abort message being sent by the coordinator to member TODO this code isn't actually used but can be used to issue a cancellation from the coordinator.void
ProcedureMemberRpcs.sendMemberAborted
(Subprocedure sub, ForeignException cause) Notify the coordinator that we aborted the specifiedSubprocedure
void
ZKProcedureMemberRpcs.sendMemberAborted
(Subprocedure sub, ForeignException ee) This should be called by the member and should write a serialized root cause exception as to the abort znode.Modifier and TypeMethodDescriptionabstract void
Subprocedure.acquireBarrier()
The implementation of this method should gather and hold required resources (locks, disk space, etc) to satisfy the Procedures barrier condition.void
Subprocedure.SubprocedureImpl.acquireBarrier()
abstract byte[]
Subprocedure.insideBarrier()
The implementation of this method should act with the assumption that the barrier condition has been satisfied.byte[]
Subprocedure.SubprocedureImpl.insideBarrier()
boolean
Procedure.isCompleted()
Check if the entire procedure has globally completed, or has been aborted.private void
Subprocedure.rethrowException()
void
Procedure.sendGlobalBarrierReached()
Sends a message to all members that the global barrier condition has been satisfied.void
Procedure.sendGlobalBarrierStart()
Sends a message to Members to create a newSubprocedure
for this Procedure and execute theSubprocedure.acquireBarrier()
step.void
Procedure.waitForCompleted()
Waits until the entire procedure has globally completed, or has been aborted.Procedure.waitForCompletedWithRet()
Waits until the entire procedure has globally completed, or has been aborted.static void
Procedure.waitForLatch
(CountDownLatch latch, ForeignExceptionSnare monitor, long wakeFrequency, String latchDescription) Wait for latch to count to zero, ignoring any spurious wake-ups, but waking periodically to check for errorsvoid
Subprocedure.waitForLocallyCompleted()
Waits until the entire procedure has globally completed, or has been aborted.(package private) void
Subprocedure.waitForReachedGlobalBarrier()
Wait for the reached global barrier notification. -
Uses of ForeignException in org.apache.hadoop.hbase.procedure.flush
Modifier and TypeMethodDescriptionvoid
FlushTableSubprocedure.acquireBarrier()
Flush the online regions on this rs for the target table.private void
FlushTableSubprocedure.flushRegions()
byte[]
FlushTableSubprocedure.insideBarrier()
(package private) boolean
RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool.waitForOutstandingTasks()
Wait for all of the currently outstanding tasks submitted viaRegionServerFlushTableProcedureManager.FlushTableSubprocedurePool.submitTask(Callable)
. -
Uses of ForeignException in org.apache.hadoop.hbase.regionserver.snapshot
Modifier and TypeMethodDescriptionvoid
FlushSnapshotSubprocedure.acquireBarrier()
do nothing, core of snapshot is executed inFlushSnapshotSubprocedure.insideBarrier()
step.private void
FlushSnapshotSubprocedure.flushSnapshot()
byte[]
FlushSnapshotSubprocedure.insideBarrier()
do a flush snapshot of every region on this rs from the target table.(package private) boolean
RegionServerSnapshotManager.SnapshotSubprocedurePool.waitForOutstandingTasks()
Wait for all of the currently outstanding tasks submitted viaRegionServerSnapshotManager.SnapshotSubprocedurePool.submitTask(Callable)
.