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, Address thisAddress, Address[] addresses)

Method Summary

Modifier and Type	Method and Description
Address	getOwnerOrNull() Returns the address of the owner of this partition.
int	getPartitionId() Returns the partition ID.
Address	getReplicaAddress(int replicaIndex) Returns the address of the replica.
int	getReplicaIndex(Address address) Return the replica index for this partition.
static int	getReplicaIndex(Address[] addresses, Address address) Returns the index of the address in addresses or -1 if the address is null or not present.
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.
void	setMigrating(boolean isMigrating)
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,
                             Address thisAddress,
                             Address[] addresses)

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 void setMigrating(boolean isMigrating)

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

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

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

Description copied from interface: InternalPartition

Return the replica index for this partition.

Specified by:

getReplicaIndex in interface InternalPartition

Parameters:

address - the replica address

Returns:

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

getReplicaIndex

public static int getReplicaIndex(Address[] addresses,
                                  Address address)

Returns the index of the address in addresses or -1 if the address is null or not present.

toString

public String toString()

Overrides:

toString in class Object