org.infinispan.container

Class EntryFactoryImpl

java.lang.Object

org.infinispan.container.EntryFactoryImpl

All Implemented Interfaces:

EntryFactory

Direct Known Subclasses:

IncrementalVersionableEntryFactoryImpl

public class EntryFactoryImpl
extends Object
implements EntryFactory

EntryFactory implementation to be used for optimistic locking scheme.

Since:

5.1

Author:

Mircea Markus

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.container.EntryFactory

EntryFactory.Wrap

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	useRepeatableRead

Constructor Summary

Constructors

Constructor and Description
EntryFactoryImpl()

Method Summary

Modifier and Type	Method and Description
protected MVCCEntry	createWrappedEntry(Object key, CacheEntry cacheEntry, InvocationContext context, boolean skipRead)
void	init()
void	injectDependencies(DataContainer dataContainer, Configuration configuration, DistributionManager distributionManager, TimeService timeService)
MVCCEntry	wrapEntryForClear(InvocationContext ctx, Object key) Deprecated.
CacheEntry	wrapEntryForDelta(InvocationContext ctx, Object deltaKey, Delta delta) Used for wrapping Delta entry to be applied to DeltaAware object stored in cache.
MVCCEntry	wrapEntryForPut(InvocationContext ctx, Object key, InternalCacheEntry icEntry, boolean undeleteIfNeeded, FlagAffectedCommand cmd, boolean skipRead) Used for wrapping a cache entry for addition to cache.
CacheEntry	wrapEntryForReading(InvocationContext ctx, Object key, CacheEntry existing) Wraps an entry for reading.
MVCCEntry	wrapEntryForRemove(InvocationContext ctx, Object key, boolean skipRead, boolean forInvalidation, boolean forceWrap) Used for wrapping a cache entry for removal.
MVCCEntry	wrapEntryForReplace(InvocationContext ctx, ReplaceCommand cmd) Used for wrapping a cache entry for replacement.
MVCCEntry	wrapEntryForWriting(InvocationContext ctx, Object key, EntryFactory.Wrap wrap, boolean skipRead, boolean ignoreOwnership) Insert an entry that exists in the data container into the context.
boolean	wrapExternalEntry(InvocationContext ctx, Object key, CacheEntry externalEntry, EntryFactory.Wrap wrap, boolean skipRead) Insert an external entry (e.g.

Methods inherited from class java.lang.Object

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

Field Detail

useRepeatableRead

protected boolean useRepeatableRead

Constructor Detail

EntryFactoryImpl

public EntryFactoryImpl()

Method Detail

injectDependencies

public void injectDependencies(DataContainer dataContainer,
                               Configuration configuration,
                               DistributionManager distributionManager,
                               TimeService timeService)

init

public void init()

wrapEntryForReading

public final CacheEntry wrapEntryForReading(InvocationContext ctx,
                                            Object key,
                                            CacheEntry existing)

Description copied from interface: EntryFactory

Wraps an entry for reading. Usually this is just a raw CacheEntry but certain combinations of isolation levels and the presence of an ongoing JTA transaction may force this to be a proper, wrapped MVCCEntry. The entry is also typically placed in the invocation context.

Specified by:

wrapEntryForReading in interface EntryFactory

Parameters:

ctx - current invocation context

key - key to look up and wrap

wrapEntryForClear

@Deprecated
public final MVCCEntry wrapEntryForClear(InvocationContext ctx,
                                                     Object key)
                                              throws InterruptedException

Deprecated.

Description copied from interface: EntryFactory

Used for wrapping individual keys when clearing the cache. The wrapped entry is added to the supplied InvocationContext.

Specified by:

wrapEntryForClear in interface EntryFactory

Throws:

InterruptedException

wrapEntryForReplace

public final MVCCEntry wrapEntryForReplace(InvocationContext ctx,
                                           ReplaceCommand cmd)
                                    throws InterruptedException

Description copied from interface: EntryFactory

Used for wrapping a cache entry for replacement. The wrapped entry is added to the supplied InvocationContext.

Specified by:

wrapEntryForReplace in interface EntryFactory

Throws:

InterruptedException

wrapEntryForRemove

public final MVCCEntry wrapEntryForRemove(InvocationContext ctx,
                                          Object key,
                                          boolean skipRead,
                                          boolean forInvalidation,
                                          boolean forceWrap)
                                   throws InterruptedException

Description copied from interface: EntryFactory

Used for wrapping a cache entry for removal. The wrapped entry is added to the supplied InvocationContext.

Specified by:

wrapEntryForRemove in interface EntryFactory

skipRead - if true, if the key is not read during the remove operation. Only used with Repeatable Read + Write Skew + Versioning + Cluster.

Throws:

InterruptedException

wrapEntryForPut

public MVCCEntry wrapEntryForPut(InvocationContext ctx,
                                 Object key,
                                 InternalCacheEntry icEntry,
                                 boolean undeleteIfNeeded,
                                 FlagAffectedCommand cmd,
                                 boolean skipRead)

Description copied from interface: EntryFactory

Used for wrapping a cache entry for addition to cache. The wrapped entry is added to the supplied InvocationContext.

Specified by:

wrapEntryForPut in interface EntryFactory

undeleteIfNeeded - Ignored

skipRead - if true, if the key is not read during the put operation. Only used with Repeatable Read +

wrapEntryForWriting

public MVCCEntry wrapEntryForWriting(InvocationContext ctx,
                                     Object key,
                                     EntryFactory.Wrap wrap,
                                     boolean skipRead,
                                     boolean ignoreOwnership)

Description copied from interface: EntryFactory

Insert an entry that exists in the data container into the context. Doesn't do anything if the key was already wrapped.

Specified by:

wrapEntryForWriting in interface EntryFactory

Returns:

The wrapped entry.

wrapExternalEntry

public boolean wrapExternalEntry(InvocationContext ctx,
                                 Object key,
                                 CacheEntry externalEntry,
                                 EntryFactory.Wrap wrap,
                                 boolean skipRead)

Description copied from interface: EntryFactory

Insert an external entry (e.g. loaded from a cache loader or from a remote node) into the context. Will not replace an existing InternalCacheEntry.

Specified by:

wrapExternalEntry in interface EntryFactory

Returns:

true if the context entry was modified, false otherwise.

wrapEntryForDelta

public CacheEntry wrapEntryForDelta(InvocationContext ctx,
                                    Object deltaKey,
                                    Delta delta)

Description copied from interface: EntryFactory

Used for wrapping Delta entry to be applied to DeltaAware object stored in cache. The wrapped entry is added to the supplied InvocationContext.

Specified by:

wrapEntryForDelta in interface EntryFactory

createWrappedEntry

protected MVCCEntry createWrappedEntry(Object key,
                                       CacheEntry cacheEntry,
                                       InvocationContext context,
                                       boolean skipRead)