org.infinispan.xsite.irac

Class NoOpIracManager

java.lang.Object

org.infinispan.xsite.irac.NoOpIracManager

All Implemented Interfaces:

IracManager

public class NoOpIracManager
extends Object
implements IracManager

A no-op implementation of IracManager for cache without asynchronous remote site backups.

Since:

11.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method and Description
void	cleanupKey(Object key, Object lockOwner, IracMetadata tombstone) Sets the key as not changed and remove any tombstone related to it.
static NoOpIracManager	getInstance()
void	onTopologyUpdate(CacheTopology oldCacheTopology, CacheTopology newCacheTopology) Notifies a topology changed.
void	receiveState(Object key, Object lockOwner, IracMetadata tombstone) Receives the state related to the key.
void	requestState(Address origin, IntSet segments) Requests the state stored in this instance for the given segments.
void	trackClear() Sets all keys as removed.
void	trackKeysFromTransaction(Stream<WriteCommand> modifications, GlobalTransaction lockOwner) Sets all keys affected by the transaction as changed.
void	trackUpdatedKey(Object key, Object lockOwner) Sets the key as changed by the lockOwner.
<K> void	trackUpdatedKeys(Collection<K> keys, Object lockOwner) Sets all the keys in keys as changed by the lockOwner.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static NoOpIracManager getInstance()

trackUpdatedKey

public void trackUpdatedKey(Object key,
                            Object lockOwner)

Description copied from interface: IracManager

Sets the key as changed by the lockOwner.

Specified by:

trackUpdatedKey in interface IracManager

Parameters:

key - The key changed.

lockOwner - The lock owner who updated the key.

trackUpdatedKeys

public <K> void trackUpdatedKeys(Collection<K> keys,
                                 Object lockOwner)

Description copied from interface: IracManager

Sets all the keys in keys as changed by the lockOwner.

Specified by:

trackUpdatedKeys in interface IracManager

Parameters:

keys - A Collection of keys changed.

lockOwner - The lock owner who updated the keys.

trackKeysFromTransaction

public void trackKeysFromTransaction(Stream<WriteCommand> modifications,
                                     GlobalTransaction lockOwner)

Description copied from interface: IracManager

Sets all keys affected by the transaction as changed.

Specified by:

trackKeysFromTransaction in interface IracManager

Parameters:

modifications - The Stream of modifications made by the transaction.

lockOwner - The GlobalTransaction.

trackClear

public void trackClear()

Description copied from interface: IracManager

Sets all keys as removed.

Specified by:

trackClear in interface IracManager

cleanupKey

public void cleanupKey(Object key,
                       Object lockOwner,
                       IracMetadata tombstone)

Description copied from interface: IracManager

Sets the key as not changed and remove any tombstone related to it.

If lockOwner isn't the last one who updated the key, this method is a no-op.

Specified by:

cleanupKey in interface IracManager

Parameters:

key - The key.

lockOwner - The lock owner who updated the key.

tombstone - The tombstone (can be null).

onTopologyUpdate

public void onTopologyUpdate(CacheTopology oldCacheTopology,
                             CacheTopology newCacheTopology)

Description copied from interface: IracManager

Notifies a topology changed.

Specified by:

onTopologyUpdate in interface IracManager

Parameters:

oldCacheTopology - The old CacheTopology.

newCacheTopology - The new CacheTopology.

requestState

public void requestState(Address origin,
                         IntSet segments)

Description copied from interface: IracManager

Requests the state stored in this instance for the given segments.

Specified by:

requestState in interface IracManager

Parameters:

origin - The requestor.

segments - The segments requested.

receiveState

public void receiveState(Object key,
                         Object lockOwner,
                         IracMetadata tombstone)

Description copied from interface: IracManager

Receives the state related to the key.

Specified by:

receiveState in interface IracManager

Parameters:

key - The key modified.

lockOwner - The last lockOwner.

tombstone - The tombstone (can be null)