com.gigaspaces.internal.server.space.recovery.group

Class CopyOnlySynchronizeSpaceReplicate

java.lang.Object

com.gigaspaces.internal.server.space.recovery.group.CopyOnlySynchronizeSpaceReplicate

All Implemented Interfaces:

ISpaceCopyReplicaState, ISpaceSynchronizeReplicaState

public class CopyOnlySynchronizeSpaceReplicate
extends Object
implements ISpaceSynchronizeReplicaState

Wraps an ISpaceCopyReplicaState as a ISpaceSynchronizeReplicaState that the sync is considered done after the copy stage

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
CopyOnlySynchronizeSpaceReplicate(ISpaceCopyReplicaState spaceCopyReplica)

Method Summary

Modifier and Type	Method and Description
void	abort(long timeout, TimeUnit unit)
ISpaceCopyResult	getCopyResult()
SpaceReplicaStage	getStage()
ISpaceSynchronizeResult	getSynchronizeResult()
boolean	isDone()
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 Detail

CopyOnlySynchronizeSpaceReplicate

public CopyOnlySynchronizeSpaceReplicate(ISpaceCopyReplicaState spaceCopyReplica)

Method Detail

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

getCopyResult

public ISpaceCopyResult getCopyResult()

Specified by:

getCopyResult in interface ISpaceCopyReplicaState

getStage

public SpaceReplicaStage getStage()

Specified by:

getStage in interface ISpaceCopyReplicaState

isDone

public boolean isDone()

Specified by:

isDone in interface ISpaceCopyReplicaState

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

abort

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

Specified by:

abort in interface ISpaceCopyReplicaState

Throws:

InterruptedException

TimeoutException