com.hazelcast.internal.partition.impl

Class InternalPartitionImpl

java.lang.Object

com.hazelcast.internal.partition.impl.InternalPartitionImpl

All Implemented Interfaces:

InternalPartition, IPartition

public class InternalPartitionImpl
extends Object
implements InternalPartition

Field Summary

Fields inherited from interface com.hazelcast.internal.partition.InternalPartition

MAX_REPLICA_COUNT

Fields inherited from interface com.hazelcast.spi.partition.IPartition

MAX_BACKUP_COUNT

Constructor Summary

Constructors

Constructor and Description
InternalPartitionImpl(int partitionId, PartitionListener listener, PartitionReplica localReplica, PartitionReplica[] replicas)

Method Summary

Modifier and Type	Method and Description
Address	getOwnerOrNull() Returns the address of the owner of this partition.
PartitionReplica	getOwnerReplicaOrNull() Returns the partition replica of the owner of this partition.
int	getPartitionId() Returns the partition ID.
PartitionReplica	getReplica(int replicaIndex) Returns the partition replica assigned to the replica index.
Address	getReplicaAddress(int replicaIndex) Returns the address of the replica.
int	getReplicaIndex(PartitionReplica replica) Return the index of partition replica for this partition.
boolean	isLocal() Checks if the partition is local.
boolean	isMigrating() Checks if there currently is a migration going on in this partition.
boolean	isOwnerOrBackup(Address address) Checks if given address is owner of primary or backup of this partition.
boolean	isOwnerOrBackup(PartitionReplica replica)
void	resetMigrating() Resets migrating flag.
boolean	setMigrating() Sets migrating flag if it's not set already.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalPartitionImpl

public InternalPartitionImpl(int partitionId,
                             PartitionListener listener,
                             PartitionReplica localReplica,
                             PartitionReplica[] replicas)

Method Detail

getPartitionId

public int getPartitionId()

Description copied from interface: IPartition

Returns the partition ID.

The partition ID will be between 0 and partitionCount (exclusive).

Specified by:

getPartitionId in interface IPartition

Returns:

the ID of the partition

isMigrating

public boolean isMigrating()

Description copied from interface: IPartition

Checks if there currently is a migration going on in this partition.

The returned value could be stale when it is returned.

Specified by:

isMigrating in interface IPartition

Returns:

true if there is a migration going on, false otherwise

setMigrating

public boolean setMigrating()

Sets migrating flag if it's not set already.

Returns:

true if migrating flag is updated, false otherwise

resetMigrating

public void resetMigrating()

Resets migrating flag.

isLocal

public boolean isLocal()

Description copied from interface: IPartition

Checks if the partition is local. A partition is local if and only if the IPartition.getOwnerOrNull() returns the same address as 'this' address of the ClusterService.getThisAddress(). If the address is null or a different address, false is returned.

Specified by:

isLocal in interface IPartition

Returns:

true if local, false otherwise

getOwnerOrNull

public Address getOwnerOrNull()

Description copied from interface: IPartition

Returns the address of the owner of this partition.

If no owner has been set yet, null is returned. So be careful with assuming that a non null value is returned.

The value could be stale when returned.

Specified by:

getOwnerOrNull in interface IPartition

Returns:

the owner

getOwnerReplicaOrNull

public PartitionReplica getOwnerReplicaOrNull()

Description copied from interface: InternalPartition

Returns the partition replica of the owner of this partition.

If no owner has been set yet, null is returned. So be careful with assuming that a non null value is returned.

The value could be stale when returned.

Specified by:

getOwnerReplicaOrNull in interface InternalPartition

Returns:

the owner

getReplicaAddress

public Address getReplicaAddress(int replicaIndex)

Description copied from interface: IPartition

Returns the address of the replica.

The owner has replica index 0.

The returned value could be null if the owner/replica has not yet been set.

The returned value could be stale when it is returned.

Specified by:

getReplicaAddress in interface IPartition

Parameters:

replicaIndex - the index of the replica

Returns:

the address of the replica

getReplica

public PartitionReplica getReplica(int replicaIndex)

Description copied from interface: InternalPartition

Returns the partition replica assigned to the replica index.

The owner has replica index 0.

The returned value could be null if the owner/replica has not yet been set.

The returned value could be stale when it is returned.

Specified by:

getReplica in interface InternalPartition

Parameters:

replicaIndex - the index of the replica

Returns:

the partition replica

isOwnerOrBackup

public boolean isOwnerOrBackup(Address address)

Description copied from interface: IPartition

Checks if given address is owner of primary or backup of this partition.

Specified by:

isOwnerOrBackup in interface IPartition

Parameters:

address - owner address

Returns:

true if address is owner or backup, false otherwise

getReplicaIndex

public int getReplicaIndex(PartitionReplica replica)

Description copied from interface: InternalPartition

Return the index of partition replica for this partition.

Specified by:

getReplicaIndex in interface InternalPartition

Parameters:

replica - partition replica

Returns:

the replica index or -1 if the replica is null or the replica is not in the replica list

isOwnerOrBackup

public boolean isOwnerOrBackup(PartitionReplica replica)

toString

public String toString()

Overrides:

toString in class Object