public static class Subprocedure.SubprocedureImpl extends Subprocedure
Subprocedure.SubprocedureImpl
executionTimeoutTimer, monitor, rpcs, wakeFrequency
Constructor and Description |
---|
SubprocedureImpl(ProcedureMember member,
String opName,
ForeignExceptionDispatcher monitor,
long wakeFrequency,
long timeout) |
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)
Users should override this method.
|
byte[] |
insideBarrier()
The implementation of this method should act with the assumption that the barrier condition has
been satisfied.
|
call, cancel, getErrorCheckable, getMemberName, getName, isComplete, receiveReachedGlobalBarrier, waitForLocallyCompleted, waitForReachedGlobalBarrier
public SubprocedureImpl(ProcedureMember member, String opName, ForeignExceptionDispatcher monitor, long wakeFrequency, long timeout)
public void acquireBarrier() throws ForeignException
Subprocedure
acquireBarrier
in class Subprocedure
ForeignException
public byte[] insideBarrier() throws ForeignException
Subprocedure
insideBarrier
in class Subprocedure
ForeignException
public void cleanup(Exception e)
Subprocedure
Subprocedure.acquireBarrier()
may have
created. ncleanup
in class Subprocedure
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.