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

Class EntryReplicaProducer

java.lang.Object

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

Direct Known Subclasses:

DirectPersisntecyEntryReplicaProducer

public class EntryReplicaProducer
extends Object
implements ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

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	Description
protected final SpaceEngine	_engine	keeps already recovered UIDs
protected static final org.slf4j.Logger	_logger

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

FORCED_CLOSE_WAIT_TIME

Constructor Summary

Constructors

Constructor	Description
EntryReplicaProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, ITemplatePacket templatePacket, Object requestContext)

Method Summary

Modifier and Type	Method	Description
ISingleStageReplicaDataProducer.CloseStatus	close(boolean forced)	Closes the producer, frees up resources held in order to service the replica request.
String	dumpState()
SpaceEngine	getEngine()
String	getName()
SpaceCopyReplicaParameters	getParameters()
Object	getRequestContext()
void	increaseGeneratedDataCount()
boolean	isClosed()
boolean	isForcedClose()
protected AbstractEntryReplicaData	produceDataFromEntry(ISynchronizationCallback syncCallback, IEntryHolder entry)
AbstractEntryReplicaData	produceNextData(ISynchronizationCallback syncCallback)	Creates the next entry that will be copied to the source space
IReplicationFilterEntry	toFilterEntry(AbstractEntryReplicaData data)

Methods inherited from class java.lang.Object

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

Field Details

_logger

protected static final org.slf4j.Logger _logger

_engine

protected final SpaceEngine _engine

keeps already recovered UIDs

Constructor Details

EntryReplicaProducer

public EntryReplicaProducer(SpaceEngine engine,
 SpaceCopyReplicaParameters parameters,
 ITemplatePacket templatePacket,
 Object requestContext)

Method Details

getRequestContext

public Object getRequestContext()

produceNextData

public AbstractEntryReplicaData produceNextData(ISynchronizationCallback syncCallback)

Creates the next entry that will be copied to the source space

Specified by:

produceNextData in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

Parameters:

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

Returns:

the next data to replicate or null if there is not more data

produceDataFromEntry

protected AbstractEntryReplicaData produceDataFromEntry(ISynchronizationCallback syncCallback,
 IEntryHolder entry)

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<AbstractEntryReplicaData>

Returns:

CloseStatus - the status of the close operation, can be CLOSED and CLOSING (another thread is closing already)

toFilterEntry

public IReplicationFilterEntry toFilterEntry(AbstractEntryReplicaData data)

Specified by:

toFilterEntry in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

getEngine

public SpaceEngine getEngine()

getParameters

public SpaceCopyReplicaParameters getParameters()

isClosed

public boolean isClosed()

isForcedClose

public boolean isForcedClose()

increaseGeneratedDataCount

public void increaseGeneratedDataCount()

dumpState

public String dumpState()

Specified by:

dumpState in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

getName

public String getName()

Specified by:

getName in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>