Package org.infinispan.container.entries

Class VersionedRepeatableReadEntry<K,V>

java.lang.Object

org.infinispan.container.entries.ReadCommittedEntry<K,V>

org.infinispan.container.entries.RepeatableReadEntry<K,V>

org.infinispan.container.entries.VersionedRepeatableReadEntry<K,V>

All Implemented Interfaces:

Cloneable, Map.Entry<K,V>, CacheEntry<K,V>, MetadataAware, MVCCEntry<K,V>

public class VersionedRepeatableReadEntry<K,V>
extends RepeatableReadEntry<K,V>

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

created, flags, internalMetadata, key, lastUsed, metadata, oldMetadata, oldValue, value

Constructor Summary

Constructors

Constructor	Description
VersionedRepeatableReadEntry(K key, V value, Metadata metadata)

Method Summary

Modifier and Type	Method	Description
VersionedRepeatableReadEntry<K,V>	clone()
CompletionStage<Boolean>	performWriteSkewCheck(EntryLoader<K,V> entryLoader, int segment, TxInvocationContext<?> ctx, EntryVersion versionSeen, VersionGenerator versionGenerator, boolean rollingUpgrade)

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

isRead, setRead, setSkipLookup, setValue, skipLookup

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

commit, commit, getCreated, getInternalMetadata, getKey, getLastUsed, getLifespan, getMaxIdle, getMetadata, getOldMetadata, getOldValue, getValue, isChanged, isCommitted, isCreated, isEvicted, isExpired, isLoaded, isNull, isRemoved, isSkipSharedStore, resetCurrentValue, setChanged, setCommitted, setCreated, setCreated, setEvicted, setExpired, setFlag, setInternalMetadata, setLastUsed, setLoaded, setMetadata, setRemoved, setSkipSharedStore, toString, updatePreviousValue

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Map.Entry

equals, hashCode

Constructor Details

VersionedRepeatableReadEntry

public VersionedRepeatableReadEntry(K key,
 V value,
 Metadata metadata)

Method Details

performWriteSkewCheck

public CompletionStage<Boolean> performWriteSkewCheck(EntryLoader<K,V> entryLoader,
 int segment,
 TxInvocationContext<?> ctx,
 EntryVersion versionSeen,
 VersionGenerator versionGenerator,
 boolean rollingUpgrade)

Parameters:

segment - the segment matching this entry

ctx - the invocation context

versionSeen - what version has been seen for this entry

versionGenerator - generator to generate a new version if needed

rollingUpgrade -

Returns:

whether a write skew occurred for this entry

clone

public VersionedRepeatableReadEntry<K,V> clone()

Specified by:

clone in interface CacheEntry<K,V>

Specified by:

clone in interface MVCCEntry<K,V>

Overrides:

clone in class RepeatableReadEntry<K,V>