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

Method Summary

Methods

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 Address of the replica.
int	getReplicaIndex(Address address)
static int	getReplicaIndex(Address[] addresses, Address address)
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

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 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)

Specified by:

getReplicaIndex in interface InternalPartition

getReplicaIndex

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

toString

public String toString()

Overrides:

toString in class Object