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

Class AbstractMultiSpaceReplicaDataProducer

java.lang.Object

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>, ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

Direct Known Subclasses:

SpaceBroadcastNotifyReplicaDataProducer, SpaceCopyReplicaDataProducer, SynchronizeReplicaDataProducer

public abstract class AbstractMultiSpaceReplicaDataProducer
extends Object
implements ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

Abstraction for a data producers that is a composition of multiple data producers.

Since:

8.0

Version:

1.0

Author:

anna

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.internal.cluster.node.impl.replica.ISingleStageReplicaDataProducer

ISingleStageReplicaDataProducer.CloseStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected SpaceEngine	_engine
protected static org.slf4j.Logger	_logger
protected Object	_requestContext

Fields inherited from interface com.gigaspaces.internal.cluster.node.impl.replica.ISingleStageReplicaDataProducer

FORCED_CLOSE_WAIT_TIME

Constructor Summary

Constructors

Constructor and Description
AbstractMultiSpaceReplicaDataProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, Object requestContext)

Method Summary

Modifier and Type	Method and Description
protected abstract List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>>	buildDataProducers(SpaceCopyReplicaParameters parameters)
ISingleStageReplicaDataProducer.CloseStatus	close(boolean forced) Closes the producer, frees up resources held in order to service the replica request.
String	dumpState()
protected String	getLogPrefix()
CurrentStageInfo	nextReplicaStage()
protected void	onClose()
IExecutableSpaceReplicaData	produceNextData(ISynchronizationCallback synchCallback) Produce next data needed for replica, this call will always be followed by #releaseLockedData(ISpaceReplicaData) if lockedData is true, it should keep that item represented by this data locked until the release is called This is done in order to ensure synchronization correctness

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.replica.ISingleStageReplicaDataProducer

getName, toFilterEntry

Field Detail

_logger

protected static final org.slf4j.Logger _logger

_requestContext

protected final Object _requestContext

_engine

protected final SpaceEngine _engine

Constructor Detail

AbstractMultiSpaceReplicaDataProducer

public AbstractMultiSpaceReplicaDataProducer(SpaceEngine engine,
                                             SpaceCopyReplicaParameters parameters,
                                             Object requestContext)

Method Detail

buildDataProducers

protected abstract List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>> buildDataProducers(SpaceCopyReplicaParameters parameters)

produceNextData

public IExecutableSpaceReplicaData produceNextData(ISynchronizationCallback synchCallback)

Description copied from interface: ISingleStageReplicaDataProducer

Produce next data needed for replica, this call will always be followed by #releaseLockedData(ISpaceReplicaData) if lockedData is true, it should keep that item represented by this data locked until the release is called This is done in order to ensure synchronization correctness

Specified by:

produceNextData in interface ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>

Parameters:

synchCallback - callback to the synchronization processor that needs to be called safely under lock

Returns:

next data needed for replica, null if done. Once null is returns all executive calls must return null!

close

public ISingleStageReplicaDataProducer.CloseStatus close(boolean forced)

Description copied from interface: ISingleStageReplicaDataProducer

Closes the producer, frees up resources held in order to service the replica request.

Specified by:

close in interface ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>

Returns:

true if any thread is trying to close and the lease reaper thread is trying to close at the same time.

onClose

protected void onClose()

nextReplicaStage

public CurrentStageInfo nextReplicaStage()

Specified by:

nextReplicaStage in interface ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

getLogPrefix

protected String getLogPrefix()

dumpState

public String dumpState()

Specified by:

dumpState in interface ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>