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

Modifier and Type	Method and Description
void	cancelReplicaSync(int partitionId)
void	clearPartitionReplicaVersions(int partitionId)
void	clearReplicaSyncRequest(int partitionId, int replicaIndex) Resets the state of the replica synchronization request for the given partition and replica.
void	finalizeReplicaSync(int partitionId, int replicaIndex, long[] versions) Set the new replica versions for the partition with the partitionId and reset any ongoing replica synchronization request for this partition and replica index.
long[]	getPartitionReplicaVersions(int partitionId)
boolean	isPartitionReplicaVersionDirty(int partitionId)
boolean	isPartitionReplicaVersionStale(int partitionId, long[] versions, int replicaIndex)
void	releaseReplicaSyncPermit()
void	setPartitionReplicaVersions(int partitionId, long[] versions, int replicaOffset)
void	triggerPartitionReplicaSync(int partitionId, int replicaIndex, long delayMillis) This method is called on a backup node (replica).
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)

This method is called on a backup node (replica). Given all conditions are satisfied, this method initiates a replica sync operation and registers it to replicaSyncRequest. The operation is scheduled for a future execution if :

• the delayMillis is greater than 0
• if a migration is not allowed (during repartitioning or a node joining the cluster)
• the partition is currently migrating
• another sync request has already been sent
• the maximum number of parallel synchronizations has already been reached

Parameters:

partitionId - the partition which is being synchronized

replicaIndex - the index of the replica which is being synchronized

delayMillis - the delay before the sync operation is sent

Throws:

IllegalArgumentException - if the replica index is not between 0 and InternalPartition.MAX_REPLICA_COUNT

isPartitionReplicaVersionStale

public boolean isPartitionReplicaVersionStale(int partitionId,
                                              long[] versions,
                                              int replicaIndex)

isPartitionReplicaVersionDirty

public boolean isPartitionReplicaVersionDirty(int partitionId)

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)

Set the new replica versions for the partition with the partitionId and reset any ongoing replica synchronization request for this partition and replica index.

Parameters:

partitionId - the partition ID

replicaIndex - the index of the replica

versions - the new replica versions for the partition

clearReplicaSyncRequest

public void clearReplicaSyncRequest(int partitionId,
                                    int replicaIndex)

Resets the state of the replica synchronization request for the given partition and replica. This will cancel the scheduled synchronization, clear the ongoing sync flag and release a synchronization permit.

Parameters:

partitionId - the partition being synchronized

replicaIndex - the index of the replica being synchronized

cancelReplicaSync

public void cancelReplicaSync(int partitionId)

tryToAcquireReplicaSyncPermit

public boolean tryToAcquireReplicaSyncPermit()

releaseReplicaSyncPermit

public void releaseReplicaSyncPermit()