com.hazelcast.internal.partition.impl

Class PartitionReplicaManager

java.lang.Object

com.hazelcast.internal.partition.impl.PartitionReplicaManager

All Implemented Interfaces:

PartitionReplicaVersionManager

public class PartitionReplicaManager
extends Object
implements PartitionReplicaVersionManager

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

Method Summary

Modifier and Type	Method and Description
int	availableReplicaSyncPermits() Returns the number of available permits.
void	clearPartitionReplicaVersions(int partitionId, ServiceNamespace namespace)
void	clearReplicaSyncRequest(int partitionId, ServiceNamespace namespace, int replicaIndex) Resets the state of the replica synchronization request for the given partition and replica.
void	finalizeReplicaSync(int partitionId, int replicaIndex, ServiceNamespace namespace, 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.
Collection<ServiceNamespace>	getNamespaces(int partitionId) Returns all registered namespaces for given partition ID
long[]	getPartitionReplicaVersions(int partitionId, ServiceNamespace namespace) Returns replica versions for given partition and namespace.
ServiceNamespace	getServiceNamespace(Operation operation) Returns ServiceNamespace for given operation.
long[]	incrementPartitionReplicaVersions(int partitionId, ServiceNamespace namespace, int backupCount) Increments replica versions for given partition and namespace by the number of backup count.
boolean	isPartitionReplicaVersionDirty(int partitionId, ServiceNamespace namespace)
boolean	isPartitionReplicaVersionStale(int partitionId, ServiceNamespace namespace, long[] versions, int replicaIndex) Returns whether given replica version is behind the current version or not.
void	releaseReplicaSyncPermits(int permits) Releases the previously acquired permits.
void	retainNamespaces(int partitionId, Set<ServiceNamespace> namespaces)
void	setPartitionReplicaVersions(int partitionId, ServiceNamespace namespace, long[] versions, int replicaOffset)
void	triggerPartitionReplicaSync(int partitionId, Collection<ServiceNamespace> namespaces, int replicaIndex) This method is called on a backup node (replica).
int	tryAcquireReplicaSyncPermits(int requestedPermits) Tries to acquire requested permits.
void	updatePartitionReplicaVersions(int partitionId, ServiceNamespace namespace, long[] versions, int replicaIndex) Updates the partition replica version and triggers replica sync if the replica is dirty (e.g.

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,
                                        Collection<ServiceNamespace> namespaces,
                                        int replicaIndex)

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

namespaces - namespaces of partition replica fragments

replicaIndex - the index of the replica which is being synchronized

Throws:

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

getServiceNamespace

public ServiceNamespace getServiceNamespace(Operation operation)

Description copied from interface: PartitionReplicaVersionManager

Returns ServiceNamespace for given operation. If operation is instance of ServiceNamespaceAware then ServiceNamespaceAware.getServiceNamespace() will be used. Otherwise NonFragmentedServiceNamespace will be returned.

Specified by:

getServiceNamespace in interface PartitionReplicaVersionManager

Parameters:

operation - operation

Returns:

service namespace for operation

incrementPartitionReplicaVersions

public long[] incrementPartitionReplicaVersions(int partitionId,
                                                ServiceNamespace namespace,
                                                int backupCount)

Description copied from interface: PartitionReplicaVersionManager

Increments replica versions for given partition and namespace by the number of backup count.

Specified by:

incrementPartitionReplicaVersions in interface PartitionReplicaVersionManager

Parameters:

partitionId - partition ID

namespace - replica namespace

backupCount - number of desired backups

Returns:

incremented replica versions

updatePartitionReplicaVersions

public void updatePartitionReplicaVersions(int partitionId,
                                           ServiceNamespace namespace,
                                           long[] versions,
                                           int replicaIndex)

Description copied from interface: PartitionReplicaVersionManager

Updates the partition replica version and triggers replica sync if the replica is dirty (e.g. the received version is not expected and this node might have missed an update)

Specified by:

updatePartitionReplicaVersions in interface PartitionReplicaVersionManager

Parameters:

partitionId - the ID of the partition for which we received a new version

namespace - replica namespace

versions - the received replica versions

replicaIndex - the index of this replica

isPartitionReplicaVersionStale

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

Description copied from interface: PartitionReplicaVersionManager

Returns whether given replica version is behind the current version or not.

Specified by:

isPartitionReplicaVersionStale in interface PartitionReplicaVersionManager

Parameters:

partitionId - partition ID

namespace - replica namespace

versions - replica versions

replicaIndex - specific replica index

Returns:

true if given version is stale, false otherwise

isPartitionReplicaVersionDirty

public boolean isPartitionReplicaVersionDirty(int partitionId,
                                              ServiceNamespace namespace)

getPartitionReplicaVersions

public long[] getPartitionReplicaVersions(int partitionId,
                                          ServiceNamespace namespace)

Description copied from interface: PartitionReplicaVersionManager

Returns replica versions for given partition and namespace.

Specified by:

getPartitionReplicaVersions in interface PartitionReplicaVersionManager

Parameters:

partitionId - partition ID

namespace - replica namespace

Returns:

replica versions

setPartitionReplicaVersions

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

clearPartitionReplicaVersions

public void clearPartitionReplicaVersions(int partitionId,
                                          ServiceNamespace namespace)

finalizeReplicaSync

public void finalizeReplicaSync(int partitionId,
                                int replicaIndex,
                                ServiceNamespace namespace,
                                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,
                                    ServiceNamespace namespace,
                                    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

namespace - namespace

replicaIndex - the index of the replica being synchronized

tryAcquireReplicaSyncPermits

public int tryAcquireReplicaSyncPermits(int requestedPermits)

Tries to acquire requested permits. Less than requested permits may be acquired, if insufficient permits are available. Number of actually acquired permits will be returned to the caller. Acquired permits will be in the range of [0, requestedPermits].

Parameters:

requestedPermits - number of requested permits

Returns:

number of actually acquired permits.

releaseReplicaSyncPermits

public void releaseReplicaSyncPermits(int permits)

Releases the previously acquired permits.

Parameters:

permits - number of permits

availableReplicaSyncPermits

public int availableReplicaSyncPermits()

Returns the number of available permits.

getNamespaces

public Collection<ServiceNamespace> getNamespaces(int partitionId)

Description copied from interface: PartitionReplicaVersionManager

Returns all registered namespaces for given partition ID

Specified by:

getNamespaces in interface PartitionReplicaVersionManager

Parameters:

partitionId - partition ID

Returns:

known namespaces for partition ID

retainNamespaces

public void retainNamespaces(int partitionId,
                             Set<ServiceNamespace> namespaces)