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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Method Detail
-
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 entryctx
- the invocation contextversionSeen
- what version has been seen for this entryversionGenerator
- generator to generate a new version if neededrollingUpgrade
-- Returns:
- whether a write skew occurred for this entry
-
clone
public VersionedRepeatableReadEntry<K,V> clone()
-
-