@InterfaceAudience.Private public class LogRollBackupSubprocedure extends Subprocedure
Modifier and Type | Class and Description |
---|---|
(package private) class |
LogRollBackupSubprocedure.RSRollLogTask
Callable task.
|
Subprocedure.SubprocedureImpl
Modifier and Type | Field and Description |
---|---|
private String |
backupRoot |
private static org.slf4j.Logger |
LOG |
private RegionServerServices |
rss |
private LogRollBackupSubprocedurePool |
taskManager |
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(Exception e)
Cancel threads if they haven't finished.
|
byte[] |
insideBarrier()
do a log roll.
|
void |
releaseBarrier()
Hooray!
|
private void |
rolllog() |
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted
private static final org.slf4j.Logger LOG
private final RegionServerServices rss
private final LogRollBackupSubprocedurePool taskManager
private String backupRoot
public LogRollBackupSubprocedure(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, LogRollBackupSubprocedurePool taskManager, byte[] data)
private void rolllog() throws ForeignException
ForeignException
public void acquireBarrier()
Subprocedure
acquireBarrier
in class Subprocedure
public byte[] insideBarrier() throws ForeignException
insideBarrier
in class Subprocedure
ForeignException
public void cleanup(Exception e)
cleanup
in class Subprocedure
public void releaseBarrier()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.