Package org.infinispan.container.versioning.irac

Class NoOpIracTombstoneManager

java.lang.Object

org.infinispan.container.versioning.irac.NoOpIracTombstoneManager

All Implemented Interfaces:

IracTombstoneManager

public final class NoOpIracTombstoneManager
extends Object
implements IracTombstoneManager

No-op implementation for IracTombstoneManager.

It is used when IRAC is not enabled.

Since:

14.0

Method Summary

Modifier and Type	Method	Description
void	checkStaleTombstone(Collection<? extends IracTombstoneInfo> tombstones)	It receives a Collection of IracTombstoneInfo and sends IracTombstoneCleanupCommand for the tombstone no longer valid.
long	getCurrentDelayMillis()
static NoOpIracTombstoneManager	getInstance()
IracMetadata	getTombstone(Object key)	Returns the tombstone associated to the key or null if it doesn't exist.
boolean	isEmpty()
boolean	isTaskRunning()
void	removeTombstone(Object key)	Removes the tombstone for key.
void	removeTombstone(IracTombstoneInfo tombstone)	Removes the tombstone if it matches.
void	sendStateTo(Address requestor, IntSet segments)	Sends the tombstone belonging to the segments in segment to the originator
int	size()
void	storeTombstone(int segment, Object key, IracMetadata metadata)	Stores a tombstone for a removed key.
void	storeTombstoneIfAbsent(IracTombstoneInfo tombstone)	Same as IracTombstoneManager.storeTombstoneIfAbsent(int, Object, IracMetadata) but with a IracTombstoneInfo instance.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.container.versioning.irac.IracTombstoneManager

storeTombstoneIfAbsent

Method Detail

getInstance

public static NoOpIracTombstoneManager getInstance()

storeTombstone

public void storeTombstone(int segment,
                           Object key,
                           IracMetadata metadata)

Description copied from interface: IracTombstoneManager

Stores a tombstone for a removed key.

It overwrites any previous tombstone associated to the key.

Specified by:

storeTombstone in interface IracTombstoneManager

Parameters:

segment - The key's segment.

key - The key.

metadata - The IracMetadata.

storeTombstoneIfAbsent

public void storeTombstoneIfAbsent(IracTombstoneInfo tombstone)

Description copied from interface: IracTombstoneManager

Same as IracTombstoneManager.storeTombstoneIfAbsent(int, Object, IracMetadata) but with a IracTombstoneInfo instance.

Specified by:

storeTombstoneIfAbsent in interface IracTombstoneManager

Parameters:

tombstone - The tombstone to store.

removeTombstone

public void removeTombstone(IracTombstoneInfo tombstone)

Description copied from interface: IracTombstoneManager

Removes the tombstone if it matches.

Specified by:

removeTombstone in interface IracTombstoneManager

Parameters:

tombstone - The IracTombstoneInfo.

removeTombstone

public void removeTombstone(Object key)

Description copied from interface: IracTombstoneManager

Removes the tombstone for key.

Specified by:

removeTombstone in interface IracTombstoneManager

Parameters:

key - The key.

getTombstone

public IracMetadata getTombstone(Object key)

Description copied from interface: IracTombstoneManager

Returns the tombstone associated to the key or null if it doesn't exist.

Specified by:

getTombstone in interface IracTombstoneManager

Parameters:

key - The key.

Returns:

The tombstone.

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface IracTombstoneManager

Returns:

true if no tombstones are stored.

size

public int size()

Specified by:

size in interface IracTombstoneManager

Returns:

the number of tombstones stored.

isTaskRunning

public boolean isTaskRunning()

Specified by:

isTaskRunning in interface IracTombstoneManager

Returns:

true if the cleanup task is currently running.

getCurrentDelayMillis

public long getCurrentDelayMillis()

Specified by:

getCurrentDelayMillis in interface IracTombstoneManager

Returns:

The current delay between cleanup task in milliseconds.

sendStateTo

public void sendStateTo(Address requestor,
                        IntSet segments)

Description copied from interface: IracTombstoneManager

Sends the tombstone belonging to the segments in segment to the originator

The sending is done asynchronously, and it does not wait for the sending to complete.

Specified by:

sendStateTo in interface IracTombstoneManager

Parameters:

requestor - The requestor Address.

segments - The segments requested.

checkStaleTombstone

public void checkStaleTombstone(Collection<? extends IracTombstoneInfo> tombstones)

Description copied from interface: IracTombstoneManager

It receives a Collection of IracTombstoneInfo and sends IracTombstoneCleanupCommand for the tombstone no longer valid.

Specified by:

checkStaleTombstone in interface IracTombstoneManager

Parameters:

tombstones - The IracTombstoneInfo collection.