Package 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	Description
protected static final org.slf4j.Logger	_logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

_logger

protected static final org.slf4j.Logger _logger

Constructor Details

ReplicationNodeReplicaHandler

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

Method Details

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()