private class TerracottaClient.RejoinWorker
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private boolean |
forcedShutdown |
private java.util.concurrent.atomic.AtomicInteger |
rejoinCount |
private TerracottaClient.RejoinRequestHolder |
rejoinRequestHolder |
private TerracottaClient.RejoinStatus |
rejoinStatus |
private java.lang.Object |
rejoinSync |
private java.lang.Thread |
rejoinThread |
private boolean |
shutdown |
Modifier | Constructor and Description |
---|---|
private |
RejoinWorker() |
Modifier and Type | Method and Description |
---|---|
private void |
doRejoin(TerracottaClient.RejoinRequest rejoinRequest) |
private void |
fireClusterRejoinedEvent(ClusterNode oldNodeReference) |
boolean |
getAndClearForcedShutdown() |
private boolean |
isError(java.lang.Throwable t) |
boolean |
isJVMShuttingDown() |
boolean |
isRejoinInProgress() |
void |
run() |
void |
setForcedShutdown() |
void |
shutdown() |
private void |
sleep(long sleepMillis) |
void |
startRejoin(ClusterNode oldNode) |
private void |
waitUntilLatchOpen(java.util.concurrent.CountDownLatch latch) |
private void |
waitUntilRejoinComplete() |
private void |
waitUntilRejoinRequested() |
private final java.lang.Object rejoinSync
private final TerracottaClient.RejoinStatus rejoinStatus
private final java.util.concurrent.atomic.AtomicInteger rejoinCount
private final TerracottaClient.RejoinRequestHolder rejoinRequestHolder
private volatile boolean shutdown
private volatile java.lang.Thread rejoinThread
private volatile boolean forcedShutdown
public void run()
run
in interface java.lang.Runnable
private boolean isError(java.lang.Throwable t)
public boolean getAndClearForcedShutdown()
public void setForcedShutdown()
public boolean isRejoinInProgress()
public boolean isJVMShuttingDown()
private void sleep(long sleepMillis)
public void shutdown()
private void doRejoin(TerracottaClient.RejoinRequest rejoinRequest)
private void fireClusterRejoinedEvent(ClusterNode oldNodeReference)
private void waitUntilLatchOpen(java.util.concurrent.CountDownLatch latch)
private void waitUntilRejoinRequested()
public void startRejoin(ClusterNode oldNode)
private void waitUntilRejoinComplete()