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

Class ReplicationNodeReplicaHandler

java.lang.Object

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

public class ReplicationNodeReplicaHandler
extends Object

Inner component of the ReplicationNode that is in charge of handling incoming replica requests

Since:

8.0

Author:

eitany

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	_logger

Constructor Summary

Constructors

Constructor and Description
ReplicationNodeReplicaHandler(ReplicationNode replicationNode, ISpaceReplicaDataProducerBuilder<? extends ISpaceReplicaData> replicaDataProducerBuilder, ISpaceCopyReplicaOutFilter outFilter)

Method Summary

Modifier and Type	Method and Description
void	clearFifoBatchesHandler()
void	clearStaleReplicas(long expirationTime)
void	close()
String	dumpState()
DirectPersistencyBackupSyncIteratorHandler	getDirectPersistencyBackupSyncIteratorHandler()
SpaceReplicaFifoBatchesHandler	getFifoBatchesHandler()
IReplicationGroupBacklog	getGroupBacklogByRequestContext(Object requestContext)
Collection<ISpaceReplicaData>	getNextReplicaBatch(Object context, int batchSize)
void	initFifoBatchesHandler()
int	newReplicaRequest(String requesterLookupName, ReplicaRequestPacket replicaRequestPacket)
CurrentStageInfo	nextReplicaState(Object context)
void	setDirectPersistencyBackupSyncIteratorHandler(DirectPersistencyBackupSyncIteratorHandler _directPersistencyBackupSyncIteratorHandler)

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final Logger _logger

Constructor Detail

ReplicationNodeReplicaHandler

public ReplicationNodeReplicaHandler(ReplicationNode replicationNode,
                                     ISpaceReplicaDataProducerBuilder<? extends ISpaceReplicaData> replicaDataProducerBuilder,
                                     ISpaceCopyReplicaOutFilter outFilter)

Method Detail

newReplicaRequest

public int newReplicaRequest(String requesterLookupName,
                             ReplicaRequestPacket replicaRequestPacket)

getGroupBacklogByRequestContext

public IReplicationGroupBacklog getGroupBacklogByRequestContext(Object requestContext)

getNextReplicaBatch

public Collection<ISpaceReplicaData> getNextReplicaBatch(Object context,
                                                         int batchSize)

nextReplicaState

public CurrentStageInfo nextReplicaState(Object context)

clearStaleReplicas

public void clearStaleReplicas(long expirationTime)

close

public void close()

dumpState

public String dumpState()

getDirectPersistencyBackupSyncIteratorHandler

public DirectPersistencyBackupSyncIteratorHandler getDirectPersistencyBackupSyncIteratorHandler()

setDirectPersistencyBackupSyncIteratorHandler

public void setDirectPersistencyBackupSyncIteratorHandler(DirectPersistencyBackupSyncIteratorHandler _directPersistencyBackupSyncIteratorHandler)

getFifoBatchesHandler

public SpaceReplicaFifoBatchesHandler getFifoBatchesHandler()

initFifoBatchesHandler

public void initFifoBatchesHandler()

clearFifoBatchesHandler

public void clearFifoBatchesHandler()