Examples of org.hibernate.cache.infinispan.access.PutFromLoadValidator

Package org.hibernate.cache.infinispan.access

Examples of org.hibernate.cache.infinispan.access.PutFromLoadValidator

org.hibernate.cache.infinispan.access.PutFromLoadValidator
Encapsulates logic to allow a {@link TransactionalAccessDelegate} to determinewhether a {@link TransactionalAccessDelegate#putFromLoad(Object,Object,long,Object,boolean)}call should be allowed to update the cache. A putFromLoad has the potential to store stale data, since the data may have been removed from the database and the cache between the time when the data was read from the database and the actual call to putFromLoad.
The expected usage of this class by a thread that read the cache and did not find data is:
1. Call {@link #registerPendingPut(Object)}
2. Read the database
3. Call {@link #acquirePutFromLoadLock(Object)}
4. if above returns false, the thread should not cache the data; only if above returns true, put data in the cache and...
5. then call {@link #releasePutFromLoadLock(Object)}
The expected usage by a thread that is taking an action such that any pending putFromLoad may have stale data and should not cache it is to either call
- {@link #invalidateKey(Object)} (for a single key invalidation)
- or {@link #invalidateRegion()} (for a general invalidation all pending puts)
This class also supports the concept of "naked puts", which are calls to {@link #acquirePutFromLoadLock(Object)} without a preceding {@link #registerPendingPut(Object)}call.
@author Brian Stansberry @version $Revision: $

      final TransactionManager remoteTm = remoteCollectionRegion.getTransactionManager();
      withCacheManager(new CacheManagerCallable(
            TestCacheManagerFactory.createLocalCacheManager(false)) {
         @Override
         public void call() {
            PutFromLoadValidator validator = new PutFromLoadValidator(
                  cm, remoteTm, 20000) {
               @Override
               public boolean acquirePutFromLoadLock(Object key) {
                  boolean acquired = super.acquirePutFromLoadLock(key);
                  try {

View Full Code Here

      }
      throw new CacheException("Unsupported access type [" + accessType.getExternalName() + "]");
   }


   public PutFromLoadValidator getPutFromLoadValidator() {
      return new PutFromLoadValidator(cache);
   }

View Full Code Here

    }
    throw new CacheException("Unsupported access type [" + accessType.getExternalName() + "]");
  }


  public PutFromLoadValidator getPutFromLoadValidator() {
    return new PutFromLoadValidator(cache);
  }

View Full Code Here

      }
      throw new CacheException("Unsupported access type [" + accessType.getExternalName() + "]");
   }


   public PutFromLoadValidator getPutFromLoadValidator() {
      return new PutFromLoadValidator(transactionManager);
   }

View Full Code Here

      }
      throw new CacheException("Unsupported access type [" + accessType.getExternalName() + "]");
   }


   public PutFromLoadValidator getPutFromLoadValidator() {
      return new PutFromLoadValidator(transactionManager);
   }

View Full Code Here

        throw new CacheException( "Unsupported access type [" + accessType.getExternalName() + "]" );
    }
  }


  public PutFromLoadValidator getPutFromLoadValidator() {
    return new PutFromLoadValidator( cache );
  }

View Full Code Here

        throw new CacheException( "Unsupported access type [" + accessType.getExternalName() + "]" );
    }
  }


  public PutFromLoadValidator getPutFromLoadValidator() {
    return new PutFromLoadValidator( cache );
  }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.hibernate.cache.infinispan.access.PutFromLoadValidator

org.hibernate.cache.infinispan.collection.CollectionRegionImpl

org.hibernate.cache.infinispan.entity.EntityRegionImpl

org.hibernate.cache.infinispan.naturalid.NaturalIdRegionImpl

org.hibernate.test.cache.infinispan.access.PutFromLoadValidatorUnitTestCase

org.hibernate.test.cache.infinispan.collection.AbstractCollectionRegionAccessStrategyTestCase

org.hibernate.cache.CacheException

javax.transaction.Transaction

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.