public class LogRollBackupSubprocedure extends Subprocedure
Subprocedure.SubprocedureImpl
executionTimeoutTimer, monitor, rpcs, wakeFrequency
Constructor and Description |
---|
LogRollBackupSubprocedure(RegionServerServices rss,
ProcedureMember member,
ForeignExceptionDispatcher errorListener,
long wakeFrequency,
long timeout,
LogRollBackupSubprocedurePool taskManager,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
void |
acquireBarrier()
The implementation of this method should gather and hold required resources (locks, disk
space, etc) to satisfy the Procedures barrier condition.
|
void |
cleanup(java.lang.Exception e)
Cancel threads if they haven't finished.
|
byte[] |
insideBarrier()
do a log roll.
|
void |
releaseBarrier()
Hooray!
|
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted
public LogRollBackupSubprocedure(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, LogRollBackupSubprocedurePool taskManager, byte[] data)
public void acquireBarrier() throws ForeignException
Subprocedure
acquireBarrier
in class Subprocedure
ForeignException
public byte[] insideBarrier() throws ForeignException
insideBarrier
in class Subprocedure
ForeignException
public void cleanup(java.lang.Exception e)
cleanup
in class Subprocedure
public void releaseBarrier()