org.infinispan.container.entries

Class ClusteredRepeatableReadEntry

java.lang.Object

org.infinispan.container.entries.ReadCommittedEntry

org.infinispan.container.entries.RepeatableReadEntry

org.infinispan.container.entries.ClusteredRepeatableReadEntry

All Implemented Interfaces:

Cloneable, Map.Entry, CacheEntry, MetadataAware, MVCCEntry, StateChangingEntry, Versioned

public class ClusteredRepeatableReadEntry
extends RepeatableReadEntry
implements Versioned

A version of RepeatableReadEntry that can perform write-skew checks during prepare.

Since:

5.1

Author:

Manik Surtani

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.container.entries.ReadCommittedEntry

ReadCommittedEntry.Flags

Field Summary

Fields inherited from class org.infinispan.container.entries.ReadCommittedEntry

flags, key, metadata, oldValue, value

Constructor Summary

Constructors

Constructor and Description
ClusteredRepeatableReadEntry(Object key, Object value, Metadata metadata)

Method Summary

Modifier and Type	Method and Description
ClusteredRepeatableReadEntry	clone()
EntryVersion	getVersion()
boolean	isNull() Tests whether the entry represents a null value, typically used for repeatable read.
boolean	performWriteSkewCheck(DataContainer container, PersistenceManager persistenceManager, TxInvocationContext ctx, EntryVersion versionSeen, VersionGenerator versionGenerator, TimeService timeService)
void	setVersion(EntryVersion version) Sets the version on this entry.

Methods inherited from class org.infinispan.container.entries.RepeatableReadEntry

copyForUpdate, performLocalWriteSkewCheck, setSkipLookup, skipLookup

Methods inherited from class org.infinispan.container.entries.ReadCommittedEntry

commit, copyStateFlagsFrom, getKey, getLifespan, getMaxIdle, getMetadata, getStateFlags, getValue, isChanged, isCreated, isEvicted, isExpired, isFlagSet, isLoaded, isRemoved, isValid, rollback, setChanged, setCreated, setEvicted, setExpired, setFlag, setFlag, setLoaded, setMetadata, setRemoved, setValid, setValue, toString, undelete, unsetFlag

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.container.entries.MVCCEntry

copyForUpdate

Methods inherited from interface java.util.Map.Entry

comparingByKey, comparingByKey, comparingByValue, comparingByValue, equals, hashCode

Constructor Detail

ClusteredRepeatableReadEntry

public ClusteredRepeatableReadEntry(Object key,
                                    Object value,
                                    Metadata metadata)

Method Detail

performWriteSkewCheck

public boolean performWriteSkewCheck(DataContainer container,
                                     PersistenceManager persistenceManager,
                                     TxInvocationContext ctx,
                                     EntryVersion versionSeen,
                                     VersionGenerator versionGenerator,
                                     TimeService timeService)

getVersion

public EntryVersion getVersion()

Specified by:

getVersion in interface Versioned

Returns:

the version of the entry. May be null if versioning is not supported, and must never be null if versioning is supported.

setVersion

public void setVersion(EntryVersion version)

Description copied from interface: Versioned

Sets the version on this entry.

Specified by:

setVersion in interface Versioned

Parameters:

version - version to set

isNull

public boolean isNull()

Description copied from interface: CacheEntry

Tests whether the entry represents a null value, typically used for repeatable read.

Specified by:

isNull in interface CacheEntry

Overrides:

isNull in class RepeatableReadEntry

Returns:

true if this represents a null, false otherwise.

clone

public ClusteredRepeatableReadEntry clone()

Specified by:

clone in interface CacheEntry

Overrides:

clone in class RepeatableReadEntry