Package org.infinispan.partitionhandling.impl

Class AvailablePartitionHandlingManager

java.lang.Object

org.infinispan.partitionhandling.impl.AvailablePartitionHandlingManager

All Implemented Interfaces:

PartitionHandlingManager

public class AvailablePartitionHandlingManager
extends Object
implements PartitionHandlingManager

PartitionHandlingManager implementation when the cluster is always available.

Since:

8.0

Author:

Pedro Ruivo

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)
AvailabilityMode	getAvailabilityMode()
static AvailablePartitionHandlingManager	getInstance()
CacheTopology	getLastStableTopology()
Collection<GlobalTransaction>	getPartialTransactions()
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

Method Details

getInstance

public static AvailablePartitionHandlingManager getInstance()

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.