org.infinispan.container
Class EntryFactoryImpl

java.lang.Object
  extended by org.infinispan.container.EntryFactoryImpl
All Implemented Interfaces:
EntryFactory

public class EntryFactoryImpl
extends Object
implements EntryFactory


Constructor Summary
EntryFactoryImpl()
           
 
Method Summary
 boolean acquireLock(InvocationContext ctx, Object key)
          Attempts to lock an entry if the lock isn't already held in the current scope, and records the lock in the context.
 void init()
           
 void injectDependencies(DataContainer dataContainer, LockManager lockManager, Configuration configuration, CacheNotifier notifier)
           
 void releaseLock(Object key)
           
 CacheEntry wrapEntryForReading(InvocationContext ctx, Object key)
          Wraps an entry for reading.
 MVCCEntry wrapEntryForWriting(InvocationContext ctx, InternalCacheEntry entry, boolean createIfAbsent, boolean forceLockIfAbsent, boolean alreadyLocked, boolean forRemoval, boolean undeleteIfNeeded)
          Wraps an entry for writing.
 MVCCEntry wrapEntryForWriting(InvocationContext ctx, Object key, boolean createIfAbsent, boolean forceLockIfAbsent, boolean alreadyLocked, boolean forRemoval, boolean undeleteIfNeeded)
          Wraps an entry for writing.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

EntryFactoryImpl

public EntryFactoryImpl()
Method Detail

injectDependencies

public void injectDependencies(DataContainer dataContainer,
                               LockManager lockManager,
                               Configuration configuration,
                               CacheNotifier notifier)

init

public void init()

wrapEntryForReading

public final CacheEntry wrapEntryForReading(InvocationContext ctx,
                                            Object key)
                                     throws InterruptedException
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
Returns:
an entry for reading
Throws:
InterruptedException - when things go wrong, usually trying to acquire a lock

wrapEntryForWriting

public final MVCCEntry wrapEntryForWriting(InvocationContext ctx,
                                           Object key,
                                           boolean createIfAbsent,
                                           boolean forceLockIfAbsent,
                                           boolean alreadyLocked,
                                           boolean forRemoval,
                                           boolean undeleteIfNeeded)
                                    throws InterruptedException
Description copied from interface: EntryFactory
Wraps an entry for writing. This would typically acquire write locks if necessary, and place the wrapped entry in the invocation context.

Specified by:
wrapEntryForWriting in interface EntryFactory
Parameters:
ctx - current invocation context
key - key to look up and wrap
createIfAbsent - if true, an entry is created if it does not exist in the data container.
forceLockIfAbsent - forces a lock even if the entry is absent
alreadyLocked - if true, this hint prevents the method from acquiring any locks and the existence and ownership of the lock is presumed.
forRemoval - if true, this hint informs this method that the lock is being acquired for removal.
undeleteIfNeeded - if true, if the entry is found in the current scope (perhaps a transaction) and is deleted, it will be undeleted. If false, it will be considered deleted.
Returns:
an MVCCEntry instance
Throws:
InterruptedException - when things go wrong, usually trying to acquire a lock

wrapEntryForWriting

public MVCCEntry wrapEntryForWriting(InvocationContext ctx,
                                     InternalCacheEntry entry,
                                     boolean createIfAbsent,
                                     boolean forceLockIfAbsent,
                                     boolean alreadyLocked,
                                     boolean forRemoval,
                                     boolean undeleteIfNeeded)
                              throws InterruptedException
Description copied from interface: EntryFactory
Wraps an entry for writing. This would typically acquire write locks if necessary, and place the wrapped entry in the invocation context.

Specified by:
wrapEntryForWriting in interface EntryFactory
Parameters:
ctx - current invocation context
entry - an internal entry to wrap
createIfAbsent - if true, an entry is created if it does not exist in the data container.
forceLockIfAbsent - forces a lock even if the entry is absent
alreadyLocked - if true, this hint prevents the method from acquiring any locks and the existence and ownership of the lock is presumed.
forRemoval - if true, this hint informs this method that the lock is being acquired for removal.
undeleteIfNeeded - if true, if the entry is found in the current scope (perhaps a transaction) and is deleted, it will be undeleted. If false, it will be considered deleted. * @return an MVCCEntry instance
Throws:
InterruptedException - when things go wrong, usually trying to acquire a lock

acquireLock

public final boolean acquireLock(InvocationContext ctx,
                                 Object key)
                          throws InterruptedException,
                                 TimeoutException
Attempts to lock an entry if the lock isn't already held in the current scope, and records the lock in the context.

Specified by:
acquireLock in interface EntryFactory
Parameters:
ctx - context
key - Key to lock
Returns:
true if a lock was needed and acquired, false if it didn't need to acquire the lock (i.e., lock was already held)
Throws:
InterruptedException - if interrupted
TimeoutException - if we are unable to acquire the lock after a specified timeout.

releaseLock

public final void releaseLock(Object key)
Specified by:
releaseLock in interface EntryFactory

Google Analytics

Copyright © 2010 JBoss, a division of Red Hat. All Rights Reserved.