org.infinispan.loader.file
Class FileCacheStore
java.lang.Object
org.infinispan.loader.AbstractCacheLoader
org.infinispan.loader.AbstractCacheStore
org.infinispan.loader.LockSupportCacheStore
org.infinispan.loader.bucket.BucketBasedCacheStore
org.infinispan.loader.file.FileCacheStore
- All Implemented Interfaces:
- CacheLoader, CacheStore
public class FileCacheStore
- extends BucketBasedCacheStore
A filesystem-based implementation of a BucketBasedCacheStore
. This file store stores stuff in the
following format: /{location}/cache name/bucket_number.bucket
- Since:
- 4.0
- Author:
- Manik Surtani, Mircea.Markus@jboss.com
Methods inherited from class org.infinispan.loader.LockSupportCacheStore |
acquireGlobalLock, clear, fromStream, getTotalLockCount, immediateLockForWritting, load, loadAll, lockForReading, lockForWritting, releaseGlobalLock, remove, store, toStream, unlock |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FileCacheStore
public FileCacheStore()
getRoot
public File getRoot()
- Returns:
- root directory where all files for this
CacheStore
are written.
init
public void init(CacheLoaderConfig config,
Cache cache,
Marshaller m)
- Description copied from interface:
CacheLoader
- Used to initialize a cache loader. Typically invoked by the
CacheLoaderManager
when
setting up cache loaders.
- Specified by:
init
in interface CacheLoader
- Overrides:
init
in class LockSupportCacheStore
- Parameters:
config
- the cache loader configuration beancache
- cache associated with this cache loader. Implementations may use this to determine cache name when
selecting where refer to state in storage, for example, a different database table name.m
- marshaller to use when loading state from a stream, if supported by the implementation.
loadAllLockSafe
protected Set<InternalCacheEntry> loadAllLockSafe()
throws CacheLoaderException
- Specified by:
loadAllLockSafe
in class LockSupportCacheStore
- Throws:
CacheLoaderException
fromStreamLockSafe
protected void fromStreamLockSafe(ObjectInput objectInput)
throws CacheLoaderException
- Specified by:
fromStreamLockSafe
in class LockSupportCacheStore
- Throws:
CacheLoaderException
toStreamLockSafe
protected void toStreamLockSafe(ObjectOutput objectOutput)
throws CacheLoaderException
- Specified by:
toStreamLockSafe
in class LockSupportCacheStore
- Throws:
CacheLoaderException
clearLockSafe
protected void clearLockSafe()
throws CacheLoaderException
- Specified by:
clearLockSafe
in class LockSupportCacheStore
- Throws:
CacheLoaderException
purgeInternal
protected void purgeInternal()
throws CacheLoaderException
- Overrides:
purgeInternal
in class AbstractCacheStore
- Throws:
CacheLoaderException
loadBucket
protected Bucket loadBucket(String bucketName)
throws CacheLoaderException
- Description copied from class:
BucketBasedCacheStore
- Loads the bucket from the store, base on the hashcode.
- Specified by:
loadBucket
in class BucketBasedCacheStore
- Throws:
CacheLoaderException
loadBucket
protected Bucket loadBucket(File bucketFile)
throws CacheLoaderException
- Throws:
CacheLoaderException
insertBucket
protected void insertBucket(Bucket bucket)
throws CacheLoaderException
- Specified by:
insertBucket
in class BucketBasedCacheStore
- Throws:
CacheLoaderException
saveBucket
public void saveBucket(Bucket b)
throws CacheLoaderException
- Description copied from class:
BucketBasedCacheStore
- This method assumes that the bucket is already persisted in the database.
- Specified by:
saveBucket
in class BucketBasedCacheStore
- Throws:
CacheLoaderException
- if the bucket is not already present, or something happens while persisting.
getConfigurationClass
public Class<? extends CacheLoaderConfig> getConfigurationClass()
- Returns:
- the type of the
CacheLoaderConfig
bean used to configure this implementation of
CacheLoader
start
public void start()
throws CacheLoaderException
- Specified by:
start
in interface CacheLoader
- Overrides:
start
in class LockSupportCacheStore
- Throws:
CacheLoaderException
loadBucketContainingKey
public Bucket loadBucketContainingKey(String key)
throws CacheLoaderException
- Throws:
CacheLoaderException
Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.