Package org.infinispan.container.versioning.irac

Class DefaultIracVersionGenerator

java.lang.Object

org.infinispan.container.versioning.irac.DefaultIracVersionGenerator

All Implemented Interfaces:

Lifecycle, IracVersionGenerator

public class DefaultIracVersionGenerator
extends Object
implements IracVersionGenerator

Default implementation of IracVersionGenerator.

Since:

11.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
DefaultIracVersionGenerator(int numberOfSegments)

Method Summary

Modifier and Type	Method	Description
IracMetadata	generateMetadataWithCurrentVersion(int segment)	Generate a new IracMetadata for a given segment.
IracMetadata	generateNewMetadata(int segment)	Generates a new IracMetadata for a given segment.
IracMetadata	generateNewMetadata(int segment, IracEntryVersion versionSeen)	Same as IracVersionGenerator.generateNewMetadata(int) but it makes sure the new version is higher than versionSeen.
void	onTopologyChange(CacheTopology newTopology)	Invoked when a topology change occurs in the cluster.
Map<Integer,IracEntryVersion>	peek()
void	start()	Invoked on component start
void	stop()	Invoked on component stop
void	updateVersion(int segment, IracEntryVersion remoteVersion)	Updates the version for the segment with a new remoteVersion seen.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultIracVersionGenerator

public DefaultIracVersionGenerator(int numberOfSegments)

Method Details

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

generateNewMetadata

public IracMetadata generateNewMetadata(int segment)

Description copied from interface: IracVersionGenerator

Generates a new IracMetadata for a given segment.

The IracEntryVersion created is always higher than the previous one for the same segment.

Specified by:

generateNewMetadata in interface IracVersionGenerator

Parameters:

segment - The segment.

Returns:

The IracMetadata created.

generateMetadataWithCurrentVersion

public IracMetadata generateMetadataWithCurrentVersion(int segment)

Description copied from interface: IracVersionGenerator

Generate a new IracMetadata for a given segment.

The IracEntryVersion created will be the same as the previous one for the same segment. If there was no version prior then it will create an initial version.

Specified by:

generateMetadataWithCurrentVersion in interface IracVersionGenerator

Parameters:

segment - The segment.

Returns:

The IracMetadata created.

generateNewMetadata

public IracMetadata generateNewMetadata(int segment,
 IracEntryVersion versionSeen)

Description copied from interface: IracVersionGenerator

Same as IracVersionGenerator.generateNewMetadata(int) but it makes sure the new version is higher than versionSeen.

Specified by:

generateNewMetadata in interface IracVersionGenerator

Parameters:

segment - The segment.

versionSeen - The IracEntryVersion seen before. Can be null.

Returns:

The IracMetadata created.

updateVersion

public void updateVersion(int segment,
 IracEntryVersion remoteVersion)

Description copied from interface: IracVersionGenerator

Updates the version for the segment with a new remoteVersion seen.

This method should merge both the current version internally stored and the remoteVersion to achieve an IracEntryVersion higher than both.

Specified by:

updateVersion in interface IracVersionGenerator

Parameters:

segment - The segment.

remoteVersion - The remote IracEntryVersion received.

onTopologyChange

public void onTopologyChange(CacheTopology newTopology)

Description copied from interface: IracVersionGenerator

Invoked when a topology change occurs in the cluster.

Specified by:

onTopologyChange in interface IracVersionGenerator

Parameters:

newTopology - The new CacheTopology

peek

public Map<Integer,IracEntryVersion> peek()