com.hazelcast.internal.partition.impl

Class InternalPartitionServiceImpl

java.lang.Object

com.hazelcast.internal.partition.impl.InternalPartitionServiceImpl

All Implemented Interfaces:

InternalPartitionService, CoreService, EventPublishingService<PartitionEvent,PartitionEventListener<PartitionEvent>>, ManagedService, IPartitionService, PartitionAwareService

public class InternalPartitionServiceImpl
extends Object
implements InternalPartitionService, ManagedService, EventPublishingService<PartitionEvent,PartitionEventListener<PartitionEvent>>, PartitionAwareService

The InternalPartitionService implementation.

Field Summary

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

DEFAULT_REPLICA_SYNC_DELAY, MIGRATION_EVENT_TOPIC, MIGRATION_RETRY_COUNT, MIGRATION_RETRY_PAUSE, PARTITION_LOST_EVENT_TOPIC, REPLICA_SYNC_RETRY_DELAY

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

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
InternalPartitionServiceImpl(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
String	addLocalPartitionLostListener(PartitionLostListener listener)
String	addMigrationListener(MigrationListener listener)
void	addPartitionListener(PartitionListener listener)
String	addPartitionLostListener(PartitionLostListener listener)
void	cancelReplicaSyncRequestsTo(Address deadAddress)
PartitionRuntimeState	createPartitionState()
PartitionRuntimeState	createPartitionStateInternal()
void	dispatchEvent(PartitionEvent partitionEvent, PartitionEventListener partitionEventListener)
void	firstArrangement()
InternalMigrationListener	getInternalMigrationListener()
InternalPartition[]	getInternalPartitions()
int	getMaxAllowedBackupCount() Returns maximum allowed backup count according to current cluster formation and partition group configuration.
int	getMemberGroupsSize()
List<Integer>	getMemberPartitions(Address target)
Map<Address,List<Integer>>	getMemberPartitionsMap() Gets member partition IDs.
MigrationManager	getMigrationManager()
long	getMigrationQueueSize()
List<ReplicaSyncInfo>	getOngoingReplicaSyncRequests()
InternalPartition	getPartition(int partitionId) Returns the IPartition for a given partitionId.
InternalPartition	getPartition(int partitionId, boolean triggerOwnerAssignment) Returns the IPartition for a given partitionId.
int	getPartitionCount() Returns the number of partitions.
PartitionEventManager	getPartitionEventManager()
int	getPartitionId(Data key) Returns the partition id for a Data key.
int	getPartitionId(Object key) Returns the partition id for a given object.
long	getPartitionMigrationTimeout()
Address	getPartitionOwner(int partitionId) Gets the owner of the partition if it's set.
Address	getPartitionOwnerOrWait(int partitionId) Gets the owner of the partition.
PartitionReplicaStateChecker	getPartitionReplicaStateChecker()
long[]	getPartitionReplicaVersions(int partitionId)
IPartition[]	getPartitions()
PartitionServiceProxy	getPartitionServiceProxy()
PartitionStateManager	getPartitionStateManager()
int	getPartitionStateVersion()
PartitionReplicaManager	getReplicaManager()
List<ScheduledEntry<Integer,ReplicaSyncInfo>>	getScheduledReplicaSyncRequests()
boolean	hasOnGoingMigration() Checks if there are any cluster-wide migrations.
boolean	hasOnGoingMigrationLocal() Checks if there are any local migrations.
long[]	incrementPartitionReplicaVersions(int partitionId, int backupCount)
void	init(NodeEngine nodeEngine, Properties properties) Initializes this ManagedService
boolean	isMemberAllowedToJoin(Address address)
boolean	isMemberStateSafe() Query and return if this member in a safe state or not.
boolean	isPartitionOwner(int partitionId) Check if this node is the owner of a partition
boolean	isPartitionReplicaVersionStale(int partitionId, long[] versions, int replicaIndex)
boolean	isReplicaSyncAllowed()
void	memberAdded(MemberImpl member)
void	memberRemoved(MemberImpl member)
void	onPartitionLost(IPartitionLostEvent event) Invoked when a partition lost is detected
void	onShutdownRequest(Address address)
void	onShutdownResponse()
void	pauseMigration()
boolean	prepareToSafeShutdown(long timeout, TimeUnit unit)
boolean	processPartitionRuntimeState(PartitionRuntimeState partitionState)
boolean	removeMigrationListener(String registrationId)
boolean	removePartitionLostListener(String registrationId)
void	reset() reset this ManagedService back to initial state.
void	resetInternalMigrationListener()
void	resumeMigration()
void	setInitialState(Address[][] newState, int partitionStateVersion)
void	setInternalMigrationListener(InternalMigrationListener listener)
void	shutdown(boolean terminate) Shuts down this ManagedService.
String	toString()
void	updatePartitionReplicaVersions(int partitionId, long[] versions, int replicaIndex)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalPartitionServiceImpl

public InternalPartitionServiceImpl(Node node)

Method Detail

init

public void init(NodeEngine nodeEngine,
        Properties properties)

Description copied from interface: ManagedService

Initializes this ManagedService

Specified by:

init in interface ManagedService

Parameters:

nodeEngine - the NodeEngine that this ManagedService belongs to.

properties - the Properties. Can be used to pass settings to the service.

getPartitionOwner

public Address getPartitionOwner(int partitionId)

Description copied from interface: IPartitionService

Gets the owner of the partition if it's set. Otherwise it will trigger partition assignment.

Specified by:

getPartitionOwner in interface IPartitionService

Parameters:

partitionId - the partitionId

Returns:

owner of partition or null if it's not set yet.

getPartitionOwnerOrWait

public Address getPartitionOwnerOrWait(int partitionId)

Description copied from interface: IPartitionService

Gets the owner of the partition. If none is set, it will wait till the owner is set.

Specified by:

getPartitionOwnerOrWait in interface IPartitionService

Parameters:

partitionId - the partitionId

Returns:

owner of partition

firstArrangement

public void firstArrangement()

Specified by:

firstArrangement in interface InternalPartitionService

setInitialState

public void setInitialState(Address[][] newState,
                   int partitionStateVersion)

getMemberGroupsSize

public int getMemberGroupsSize()

Specified by:

getMemberGroupsSize in interface InternalPartitionService

getMaxAllowedBackupCount

public int getMaxAllowedBackupCount()

Description copied from interface: IPartitionService

Returns maximum allowed backup count according to current cluster formation and partition group configuration.

Returned number will be in range of [0, IPartition.MAX_BACKUP_COUNT].

Specified by:

getMaxAllowedBackupCount in interface IPartitionService

Returns:

max allowed backup count

isMemberAllowedToJoin

public boolean isMemberAllowedToJoin(Address address)

Specified by:

isMemberAllowedToJoin in interface InternalPartitionService

memberAdded

public void memberAdded(MemberImpl member)

Specified by:

memberAdded in interface InternalPartitionService

memberRemoved

public void memberRemoved(MemberImpl member)

Specified by:

memberRemoved in interface InternalPartitionService

cancelReplicaSyncRequestsTo

public void cancelReplicaSyncRequestsTo(Address deadAddress)

createPartitionState

public PartitionRuntimeState createPartitionState()

Specified by:

createPartitionState in interface InternalPartitionService

createPartitionStateInternal

public PartitionRuntimeState createPartitionStateInternal()

processPartitionRuntimeState

public boolean processPartitionRuntimeState(PartitionRuntimeState partitionState)

getPartitions

public IPartition[] getPartitions()

Specified by:

getPartitions in interface IPartitionService

Returns:

copy of array with IPartition objects create new array on each invocation, not recommended to use in high-loaded parts of code

getInternalPartitions

public InternalPartition[] getInternalPartitions()

Specified by:

getInternalPartitions in interface InternalPartitionService

getPartition

public InternalPartition getPartition(int partitionId)

Description copied from interface: IPartitionService

Returns the IPartition for a given partitionId. If owner of the partition is not set yet, it will trigger partition assignment.

The IPartition for a given partitionId will never change, so it can be cached safely.

Specified by:

getPartition in interface InternalPartitionService

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partitionId

Returns:

the IPartition.

getPartition

public InternalPartition getPartition(int partitionId,
                             boolean triggerOwnerAssignment)

Description copied from interface: IPartitionService

Returns the IPartition for a given partitionId. If owner of the partition is not set yet and triggerOwnerAssignment is true, it will trigger partition assignment.

The IPartition for a given partitionId will never change, so it can be cached safely.

Specified by:

getPartition in interface InternalPartitionService

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partitionId

triggerOwnerAssignment - flag to trigger partition assignment

Returns:

the IPartition.

prepareToSafeShutdown

public boolean prepareToSafeShutdown(long timeout,
                            TimeUnit unit)

Specified by:

prepareToSafeShutdown in interface InternalPartitionService

onShutdownRequest

public void onShutdownRequest(Address address)

onShutdownResponse

public void onShutdownResponse()

isMemberStateSafe

public boolean isMemberStateSafe()

Description copied from interface: IPartitionService

Query and return if this member in a safe state or not. This method just checks for a safe state, it doesn't force this member to be in a safe state.

Specified by:

isMemberStateSafe in interface IPartitionService

Returns:

true if this member in a safe state, otherwise false

hasOnGoingMigration

public boolean hasOnGoingMigration()

Description copied from interface: IPartitionService

Checks if there are any cluster-wide migrations.

Specified by:

hasOnGoingMigration in interface IPartitionService

Returns:

true if there are migrations, false otherwise.

hasOnGoingMigrationLocal

public boolean hasOnGoingMigrationLocal()

Description copied from interface: IPartitionService

Checks if there are any local migrations.

Specified by:

hasOnGoingMigrationLocal in interface IPartitionService

Returns:

true if there are migrations, false otherwise.

getPartitionId

public final int getPartitionId(Data key)

Description copied from interface: IPartitionService

Returns the partition id for a Data key.

Specified by:

getPartitionId in interface IPartitionService

Parameters:

key - the Data key.

Returns:

the partition id.

getPartitionId

public final int getPartitionId(Object key)

Description copied from interface: IPartitionService

Returns the partition id for a given object.

Specified by:

getPartitionId in interface IPartitionService

Parameters:

key - the object key.

Returns:

the partition id.

getPartitionCount

public final int getPartitionCount()

Description copied from interface: IPartitionService

Returns the number of partitions.

Specified by:

getPartitionCount in interface IPartitionService

Returns:

the number of partitions.

getPartitionMigrationTimeout

public long getPartitionMigrationTimeout()

incrementPartitionReplicaVersions

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

Specified by:

incrementPartitionReplicaVersions in interface InternalPartitionService

updatePartitionReplicaVersions

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

Specified by:

updatePartitionReplicaVersions in interface InternalPartitionService

isPartitionReplicaVersionStale

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

Specified by:

isPartitionReplicaVersionStale in interface InternalPartitionService

getPartitionReplicaVersions

public long[] getPartitionReplicaVersions(int partitionId)

Specified by:

getPartitionReplicaVersions in interface InternalPartitionService

getMemberPartitionsMap

public Map<Address,List<Integer>> getMemberPartitionsMap()

Description copied from interface: IPartitionService

Gets member partition IDs. Blocks until partitions are assigned.

Specified by:

getMemberPartitionsMap in interface IPartitionService

Returns:

map of member address to partition Ids

getMemberPartitions

public List<Integer> getMemberPartitions(Address target)

Specified by:

getMemberPartitions in interface IPartitionService

reset

public void reset()

Description copied from interface: ManagedService

reset this ManagedService back to initial state. todo: what is the purpose of reset

Specified by:

reset in interface ManagedService

pauseMigration

public void pauseMigration()

Specified by:

pauseMigration in interface InternalPartitionService

resumeMigration

public void resumeMigration()

Specified by:

resumeMigration in interface InternalPartitionService

isReplicaSyncAllowed

public boolean isReplicaSyncAllowed()

shutdown

public void shutdown(boolean terminate)

Description copied from interface: ManagedService

Shuts down this ManagedService. todo: what is the purpose of the terminate variable.

Specified by:

shutdown in interface ManagedService

Parameters:

terminate - true to shut down the ManagedService

getMigrationQueueSize

public long getMigrationQueueSize()

Specified by:

getMigrationQueueSize in interface IPartitionService

getPartitionServiceProxy

public PartitionServiceProxy getPartitionServiceProxy()

addMigrationListener

public String addMigrationListener(MigrationListener listener)

Specified by:

addMigrationListener in interface IPartitionService

removeMigrationListener

public boolean removeMigrationListener(String registrationId)

Specified by:

removeMigrationListener in interface IPartitionService

addPartitionLostListener

public String addPartitionLostListener(PartitionLostListener listener)

Specified by:

addPartitionLostListener in interface IPartitionService

addLocalPartitionLostListener

public String addLocalPartitionLostListener(PartitionLostListener listener)

Specified by:

addLocalPartitionLostListener in interface IPartitionService

removePartitionLostListener

public boolean removePartitionLostListener(String registrationId)

Specified by:

removePartitionLostListener in interface IPartitionService

dispatchEvent

public void dispatchEvent(PartitionEvent partitionEvent,
                 PartitionEventListener partitionEventListener)

Specified by:

dispatchEvent in interface EventPublishingService<PartitionEvent,PartitionEventListener<PartitionEvent>>

addPartitionListener

public void addPartitionListener(PartitionListener listener)

isPartitionOwner

public boolean isPartitionOwner(int partitionId)

Description copied from interface: IPartitionService

Check if this node is the owner of a partition

Specified by:

isPartitionOwner in interface IPartitionService

Returns:

true if it owns the partition. false if it doesn't or the partition hasn't been assigned yet.

getPartitionStateVersion

public int getPartitionStateVersion()

Specified by:

getPartitionStateVersion in interface IPartitionService

onPartitionLost

public void onPartitionLost(IPartitionLostEvent event)

Description copied from interface: PartitionAwareService

Invoked when a partition lost is detected

Specified by:

onPartitionLost in interface PartitionAwareService

Parameters:

event - The event object that contains the partition id and the number of replicas that is lost

setInternalMigrationListener

public void setInternalMigrationListener(InternalMigrationListener listener)

getInternalMigrationListener

public InternalMigrationListener getInternalMigrationListener()

resetInternalMigrationListener

public void resetInternalMigrationListener()

getOngoingReplicaSyncRequests

public List<ReplicaSyncInfo> getOngoingReplicaSyncRequests()

Returns:

copy of ongoing replica-sync operations

getScheduledReplicaSyncRequests

public List<ScheduledEntry<Integer,ReplicaSyncInfo>> getScheduledReplicaSyncRequests()

Returns:

copy of scheduled replica-sync requests

getPartitionStateManager

public PartitionStateManager getPartitionStateManager()

getMigrationManager

public MigrationManager getMigrationManager()

getReplicaManager

public PartitionReplicaManager getReplicaManager()

getPartitionReplicaStateChecker

public PartitionReplicaStateChecker getPartitionReplicaStateChecker()

getPartitionEventManager

public PartitionEventManager getPartitionEventManager()

toString

public String toString()

Overrides:

toString in class Object