com.hazelcast.internal.partition.impl

Class PartitionReplicaManager

java.lang.Object

com.hazelcast.internal.partition.impl.PartitionReplicaManager

public class PartitionReplicaManager
extends Object

Maintains the version values for the partition replicas and manages the replica-related operations for partitions

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelReplicaSync(int partitionId)
void	clearPartitionReplicaVersions(int partitionId)
void	clearReplicaSyncRequest(int partitionId, int replicaIndex)
void	finalizeReplicaSync(int partitionId, int replicaIndex, long[] versions)
long[]	getPartitionReplicaVersions(int partitionId)
void	releaseReplicaSyncPermit()
void	setPartitionReplicaVersions(int partitionId, long[] versions, int replicaOffset)
void	triggerPartitionReplicaSync(int partitionId, int replicaIndex, long delayMillis)
boolean	tryToAcquireReplicaSyncPermit()

Methods inherited from class java.lang.Object

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

Method Detail

triggerPartitionReplicaSync

public void triggerPartitionReplicaSync(int partitionId,
                               int replicaIndex,
                               long delayMillis)

getPartitionReplicaVersions

public long[] getPartitionReplicaVersions(int partitionId)

setPartitionReplicaVersions

public void setPartitionReplicaVersions(int partitionId,
                               long[] versions,
                               int replicaOffset)

clearPartitionReplicaVersions

public void clearPartitionReplicaVersions(int partitionId)

finalizeReplicaSync

public void finalizeReplicaSync(int partitionId,
                       int replicaIndex,
                       long[] versions)

clearReplicaSyncRequest

public void clearReplicaSyncRequest(int partitionId,
                           int replicaIndex)

cancelReplicaSync

public void cancelReplicaSync(int partitionId)

tryToAcquireReplicaSyncPermit

public boolean tryToAcquireReplicaSyncPermit()

releaseReplicaSyncPermit

public void releaseReplicaSyncPermit()