public static class UDPRebooted.ShutdownTsk extends DTask<UDPRebooted.ShutdownTsk>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
ShutdownTsk(H2ONode killer,
int nodeId,
int timeout,
boolean[] confirmations,
int exitCode) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
void |
onAck()
2nd top-level execution hook.
|
void |
onAckAck()
3rd top-level execution hook.
|
copyOver, dinvoke, getDException, hasException, logVerbose, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, onExceptionalCompletion, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
public ShutdownTsk(H2ONode killer, int nodeId, int timeout, boolean[] confirmations, int exitCode)
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<UDPRebooted.ShutdownTsk>
public void onAck()
DTask
onAck
in class DTask<UDPRebooted.ShutdownTsk>
public void onAckAck()
DTask
onAckAck
in class DTask<UDPRebooted.ShutdownTsk>