Package com.gigaspaces.internal.cluster.node.impl.replica

Class SpaceReplicaState

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.replica.SpaceReplicaState

All Implemented Interfaces:

ISpaceCopyReplicaState, ISpaceSynchronizeReplicaState

public class SpaceReplicaState
extends Object
implements ISpaceSynchronizeReplicaState

Constructor Summary

Constructors

Constructor	Description
SpaceReplicaState(IReplicationMonitoredConnection originConnection, boolean isSynchronize, long progressTimeout, IReplicationTargetGroup targetGroup)

Method Summary

Modifier and Type	Method	Description
void	abort(long timeout, TimeUnit units)
void	addReplicateConsumer(SpaceCopyReplicaRunnable consumer)
ISpaceCopyResult	getCopyResult()
SpaceReplicaStage	getStage()
ISpaceSynchronizeResult	getSynchronizeResult()
boolean	isDone()
boolean	isFailed()
void	signalCopyStageFailed(Exception error)
void	signalEntireCopyStageDoneSuccessfully()
void	signalSingleCopyStageDone()
void	updateSynchronizationDone()
ISpaceCopyResult	waitForCopyResult()
ISpaceCopyResult	waitForCopyResult(long time, TimeUnit unit)
ISpaceSynchronizeResult	waitForSynchronizeCompletion()
ISpaceSynchronizeResult	waitForSynchronizeCompletion(long time, TimeUnit unit)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SpaceReplicaState

public SpaceReplicaState(IReplicationMonitoredConnection originConnection,
 boolean isSynchronize,
 long progressTimeout,
 IReplicationTargetGroup targetGroup)

Method Details

waitForCopyResult

public ISpaceCopyResult waitForCopyResult()
                                   throws InterruptedException

Specified by:

waitForCopyResult in interface ISpaceCopyReplicaState

Throws:

InterruptedException

waitForCopyResult

public ISpaceCopyResult waitForCopyResult(long time,
 TimeUnit unit)
                                   throws InterruptedException,
TimeoutException

Specified by:

waitForCopyResult in interface ISpaceCopyReplicaState

Throws:

InterruptedException

TimeoutException

isDone

public boolean isDone()

Specified by:

isDone in interface ISpaceCopyReplicaState

isFailed

public boolean isFailed()

updateSynchronizationDone

public void updateSynchronizationDone()

getSynchronizeResult

public ISpaceSynchronizeResult getSynchronizeResult()

Specified by:

getSynchronizeResult in interface ISpaceSynchronizeReplicaState

waitForSynchronizeCompletion

public ISpaceSynchronizeResult waitForSynchronizeCompletion()
                                                     throws InterruptedException

Specified by:

waitForSynchronizeCompletion in interface ISpaceSynchronizeReplicaState

Throws:

InterruptedException

waitForSynchronizeCompletion

public ISpaceSynchronizeResult waitForSynchronizeCompletion(long time,
 TimeUnit unit)
                                                     throws InterruptedException,
TimeoutException

Specified by:

waitForSynchronizeCompletion in interface ISpaceSynchronizeReplicaState

Throws:

InterruptedException

TimeoutException

getStage

public SpaceReplicaStage getStage()

Specified by:

getStage in interface ISpaceCopyReplicaState

getCopyResult

public ISpaceCopyResult getCopyResult()

Specified by:

getCopyResult in interface ISpaceCopyReplicaState

addReplicateConsumer

public void addReplicateConsumer(SpaceCopyReplicaRunnable consumer)

abort

public void abort(long timeout,
 TimeUnit units)
           throws InterruptedException,
TimeoutException

Specified by:

abort in interface ISpaceCopyReplicaState

Throws:

InterruptedException

TimeoutException

signalEntireCopyStageDoneSuccessfully

public void signalEntireCopyStageDoneSuccessfully()

signalSingleCopyStageDone

public void signalSingleCopyStageDone()

signalCopyStageFailed

public void signalCopyStageFailed(Exception error)