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

Class SpaceCopyReplicaRunnable

java.lang.Object

com.gigaspaces.internal.utils.concurrent.AsyncCallable

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

All Implemented Interfaces:

AsyncFutureListener<Collection<ISpaceReplicaData>>, Callable<IAsyncHandlerProvider.CycleResult>

public class SpaceCopyReplicaRunnable
extends AsyncCallable
implements AsyncFutureListener<Collection<ISpaceReplicaData>>

Retrieve space copy replica data, can have multiple instances of this class running concurrently to retrieve the replica data

Since:

8.0

Author:

eitany

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor and Description
SpaceCopyReplicaRunnable(ReplicationNode replicationNode, IReplicationMonitoredConnection originConnection, ISpaceReplicaDataConsumer replicaDataProcessor, ISpaceCopyReplicaInFilter inFilter, Object replicaRemoteContext, int fetchBatchSize, SpaceReplicaState state, CyclicAtomicInteger orderProvider)

Method Summary

Modifier and Type	Method and Description
void	abort()
IAsyncHandlerProvider.CycleResult	call()
ISpaceCopyIntermediateResult	getIntermediateResult()
long	getLastIterationTimeStamp()
protected boolean	hasProgress(long lastIterationTimeStamp) returns true if progress has been identified since last iteration timestamp.
void	onResult(AsyncResult<Collection<ISpaceReplicaData>> result) A callback when a result of an async invocation arrives.
protected void	processBatch(Collection<ISpaceReplicaData> copiedData, boolean resumeNow)

Methods inherited from class com.gigaspaces.internal.utils.concurrent.AsyncCallable

getHandler, setHandler

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final org.slf4j.Logger _logger

Constructor Detail

SpaceCopyReplicaRunnable

public SpaceCopyReplicaRunnable(ReplicationNode replicationNode,
                                IReplicationMonitoredConnection originConnection,
                                ISpaceReplicaDataConsumer replicaDataProcessor,
                                ISpaceCopyReplicaInFilter inFilter,
                                Object replicaRemoteContext,
                                int fetchBatchSize,
                                SpaceReplicaState state,
                                CyclicAtomicInteger orderProvider)

Method Detail

getIntermediateResult

public ISpaceCopyIntermediateResult getIntermediateResult()

call

public IAsyncHandlerProvider.CycleResult call()

Specified by:

call in interface Callable<IAsyncHandlerProvider.CycleResult>

getLastIterationTimeStamp

public long getLastIterationTimeStamp()

abort

public void abort()

onResult

public void onResult(AsyncResult<Collection<ISpaceReplicaData>> result)

Description copied from interface: AsyncFutureListener

A callback when a result of an async invocation arrives.

Specified by:

onResult in interface AsyncFutureListener<Collection<ISpaceReplicaData>>

hasProgress

protected boolean hasProgress(long lastIterationTimeStamp)

returns true if progress has been identified since last iteration timestamp.

Parameters:

lastIterationTimeStamp - last timestamp to compare with

Returns:

true if currently in progress or if last timestamp is GT param.

processBatch

protected void processBatch(Collection<ISpaceReplicaData> copiedData,
                            boolean resumeNow)