com.hazelcast.internal.partition.impl

Class MigrationManager

java.lang.Object

com.hazelcast.internal.partition.impl.MigrationManager

public class MigrationManager
extends Object

Maintains migration system state and manages migration operations performed within the cluster.

Method Summary

Modifier and Type	Method and Description
boolean	acquirePromotionPermit() Acquires promotion commit permit which is needed while running promotion commit to prevent concurrent commits.
MigrationInfo	getActiveMigration()
MigrationStats	getStats()
boolean	isFinalizingMigrationRegistered(int partitionId)
void	releasePromotionPermit() Releases promotion commit permit.
boolean	removeFinalizingMigration(MigrationInfo migration)
MigrationInfo	setActiveMigration(MigrationInfo migrationInfo) Sets the active migration if none is set and returns null, otherwise returns the currently set active migration.

Methods inherited from class java.lang.Object

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

Method Detail

removeFinalizingMigration

public boolean removeFinalizingMigration(MigrationInfo migration)

isFinalizingMigrationRegistered

public boolean isFinalizingMigrationRegistered(int partitionId)

setActiveMigration

public MigrationInfo setActiveMigration(MigrationInfo migrationInfo)

Sets the active migration if none is set and returns null, otherwise returns the currently set active migration. Acquires the partition service lock.

getActiveMigration

public MigrationInfo getActiveMigration()

acquirePromotionPermit

public boolean acquirePromotionPermit()

Acquires promotion commit permit which is needed while running promotion commit to prevent concurrent commits.

Normally, promotions are submitted & executed serially but when the commit operation timeouts, it's retried which can cause concurrent execution (promotion commit operation runs on generic operation threads).

Promotion commit operation is idempotent when executed serially.

Returns:

true if promotion commit is allowed to run, false otherwise

releasePromotionPermit

public void releasePromotionPermit()

Releases promotion commit permit.

See Also:

acquirePromotionPermit()

getStats

public MigrationStats getStats()