Package org.infinispan.partitionhandling.impl

Class PartitionHandlingManagerImpl

java.lang.Object

org.infinispan.partitionhandling.impl.PartitionHandlingManagerImpl

All Implemented Interfaces:

PartitionHandlingManager

Direct Known Subclasses:

ScatteredPartitionHandlingManagerImpl

public class PartitionHandlingManagerImpl
extends Object
implements PartitionHandlingManager

Field Summary

Fields

Modifier and Type	Field	Description
protected DistributionManager	distributionManager

Constructor Summary

Constructors

Constructor	Description
PartitionHandlingManagerImpl(Configuration configuration)

Method Summary

Modifier and Type	Method	Description
boolean	addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)	Adds a partially committed transaction.
boolean	addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object,IncrementableEntryVersion> newVersions)	Adds a partially committed transaction.
boolean	addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)	Adds a partially aborted transaction.
boolean	canRollbackTransactionAfterOriginatorLeave(GlobalTransaction globalTransaction)	It checks if the transaction can be aborted when the originator leaves the cluster.
void	checkBulkRead()
void	checkClear()
void	checkRead(Object key, long flagBitSet)
void	checkWrite(Object key)
protected void	doCheck(Object key, boolean isWrite, long flagBitSet)
AvailabilityMode	getAvailabilityMode()
CacheTopology	getLastStableTopology()
Collection<GlobalTransaction>	getPartialTransactions()
protected PartitionHandling	getPartitionHandling()
protected boolean	isKeyOperationAllowed(boolean isWrite, long flagBitSet, LocalizedCacheTopology cacheTopology, Object key)	Check if a read/write operation is allowed with the actual members
boolean	isTransactionPartiallyCommitted(GlobalTransaction globalTransaction)	It checks if the transaction resources (for example locks) can be released.
void	onTopologyUpdate(CacheTopology cacheTopology)	Notifies the PartitionHandlingManager that the cache topology was update.
CompletionStage<Void>	setAvailabilityMode(AvailabilityMode availabilityMode)

Methods inherited from class java.lang.Object

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

Field Details

distributionManager

protected DistributionManager distributionManager

Constructor Details

PartitionHandlingManagerImpl

public PartitionHandlingManagerImpl(Configuration configuration)

Method Details

getAvailabilityMode

public AvailabilityMode getAvailabilityMode()

Specified by:

getAvailabilityMode in interface PartitionHandlingManager

setAvailabilityMode

public CompletionStage<Void> setAvailabilityMode(AvailabilityMode availabilityMode)

Specified by:

setAvailabilityMode in interface PartitionHandlingManager

checkWrite

public void checkWrite(Object key)

Specified by:

checkWrite in interface PartitionHandlingManager

checkRead

public void checkRead(Object key,
 long flagBitSet)

Specified by:

checkRead in interface PartitionHandlingManager

checkClear

public void checkClear()

Specified by:

checkClear in interface PartitionHandlingManager

checkBulkRead

public void checkBulkRead()

Specified by:

checkBulkRead in interface PartitionHandlingManager

getLastStableTopology

public CacheTopology getLastStableTopology()

Specified by:

getLastStableTopology in interface PartitionHandlingManager

addPartialRollbackTransaction

public boolean addPartialRollbackTransaction(GlobalTransaction globalTransaction,
 Collection<Address> affectedNodes,
 Collection<Object> lockedKeys)

Description copied from interface: PartitionHandlingManager

Adds a partially aborted transaction.

The transaction should be registered when it is not sure if the abort happens successfully in all the affected nodes.

Specified by:

addPartialRollbackTransaction in interface PartitionHandlingManager

Parameters:

globalTransaction - the global transaction.

affectedNodes - the nodes involved in the transaction and they must abort the transaction.

lockedKeys - the keys locally locked.

Returns:

true if the PartitionHandlingManager will handle it, false otherwise.

addPartialCommit2PCTransaction

public boolean addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
 Collection<Address> affectedNodes,
 Collection<Object> lockedKeys,
 Map<Object,IncrementableEntryVersion> newVersions)

Description copied from interface: PartitionHandlingManager

Adds a partially committed transaction.

The transaction is committed in the second phase and it is register if it is not sure that the transaction was committed successfully in all the affected nodes.

Specified by:

addPartialCommit2PCTransaction in interface PartitionHandlingManager

Parameters:

globalTransaction - the global transaction.

affectedNodes - the nodes involved in the transaction and they must commit it.

lockedKeys - the keys locally locked.

newVersions - the updated versions. Only used when versioning is enabled.

Returns:

true if the PartitionHandlingManager will handle it, false otherwise.

addPartialCommit1PCTransaction

public boolean addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
 Collection<Address> affectedNodes,
 Collection<Object> lockedKeys,
 List<org.infinispan.commands.write.WriteCommand> modifications)

Description copied from interface: PartitionHandlingManager

Adds a partially committed transaction.

The transaction is committed in one phase and it is register if it is not sure that the transaction was committed successfully in all the affected nodes.

Specified by:

addPartialCommit1PCTransaction in interface PartitionHandlingManager

Parameters:

globalTransaction - the global transaction.

affectedNodes - the nodes involved in the transaction and they must commit it.

lockedKeys - the keys locally locked.

modifications - the transaction's modification log.

Returns:

true if the PartitionHandlingManager will handle it, false otherwise.

isTransactionPartiallyCommitted

public boolean isTransactionPartiallyCommitted(GlobalTransaction globalTransaction)

Description copied from interface: PartitionHandlingManager

It checks if the transaction resources (for example locks) can be released.

The transaction resource can't be released when the transaction is partially committed.

Specified by:

isTransactionPartiallyCommitted in interface PartitionHandlingManager

Parameters:

globalTransaction - the transaction.

Returns:

true if the resources can be released, false otherwise.

getPartialTransactions

public Collection<GlobalTransaction> getPartialTransactions()

Specified by:

getPartialTransactions in interface PartitionHandlingManager

Returns:

a collection of partial committed or aborted transactions.

canRollbackTransactionAfterOriginatorLeave

public boolean canRollbackTransactionAfterOriginatorLeave(GlobalTransaction globalTransaction)

Description copied from interface: PartitionHandlingManager

It checks if the transaction can be aborted when the originator leaves the cluster.

The only case in which it is not possible to abort is when partition handling is enabled and the originator didn't leave gracefully. The transaction will complete when the partition heals.

Specified by:

canRollbackTransactionAfterOriginatorLeave in interface PartitionHandlingManager

Parameters:

globalTransaction - the global transaction.

Returns:

true if the transaction can be aborted, false otherwise.

onTopologyUpdate

public void onTopologyUpdate(CacheTopology cacheTopology)

Description copied from interface: PartitionHandlingManager

Notifies the PartitionHandlingManager that the cache topology was update.

It detects when the partition is merged and tries to complete all the partially completed transactions.

Specified by:

onTopologyUpdate in interface PartitionHandlingManager

Parameters:

cacheTopology - the new cache topology.

doCheck

protected void doCheck(Object key,
 boolean isWrite,
 long flagBitSet)

isKeyOperationAllowed

protected boolean isKeyOperationAllowed(boolean isWrite,
 long flagBitSet,
 LocalizedCacheTopology cacheTopology,
 Object key)

Check if a read/write operation is allowed with the actual members

Parameters:

isWrite - false for reads, true for writes

flagBitSet - reads with the Flag.FORCE_WRITE_LOCK are treated as writes

cacheTopology - actual members, or null for bulk operations

key - key owners, or null for bulk operations

Returns:

true if the operation is allowed, false otherwise.

getPartitionHandling

protected PartitionHandling getPartitionHandling()