org.infinispan.loaders.leveldb

Class LevelDBCacheStore

java.lang.Object

org.infinispan.loaders.AbstractCacheLoader

org.infinispan.loaders.AbstractCacheStore

org.infinispan.loaders.LockSupportCacheStore<Integer>

org.infinispan.loaders.leveldb.LevelDBCacheStore

All Implemented Interfaces:

CacheLoader, CacheStore

@ThreadSafe
public class LevelDBCacheStore
extends LockSupportCacheStore<Integer>

Field Summary

Fields inherited from class org.infinispan.loaders.AbstractCacheStore

multiThreadedPurge, purgerService

Fields inherited from class org.infinispan.loaders.AbstractCacheLoader

cache, marshaller

Constructor Summary

Constructors

Constructor and Description
LevelDBCacheStore()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	clearLockSafe()
protected void	destroyDatabase(String location)
protected void	fromStreamLockSafe(ObjectInput ois)
Class<? extends CacheLoaderConfig>	getConfigurationClass() This method is used by the configuration parser to get a hold of the CacheLoader implementation's corresponding CacheLoaderConfig type.
protected Integer	getLockFromKey(Object key)
void	init(CacheLoaderConfig config, Cache<?,?> cache, StreamingMarshaller m) Used to initialize a cache loader.
protected Set<Object>	loadAllKeysLockSafe(Set<Object> keysToExclude)
protected Set<InternalCacheEntry>	loadAllLockSafe()
protected Set<InternalCacheEntry>	loadLockSafe(int maxEntries)
protected InternalCacheEntry	loadLockSafe(Object key, Integer lockingKey)
protected org.iq80.leveldb.DB	openDatabase(String location, org.iq80.leveldb.Options options) Creates database if it doesn't exist.
protected void	purgeInternal()
protected void	reinitAllDatabases()
protected org.iq80.leveldb.DB	reinitDatabase(String location, org.iq80.leveldb.Options options)
protected boolean	removeLockSafe(Object key, Integer lockingKey)
void	start()
void	stop()
protected void	storeLockSafe(InternalCacheEntry ed, Integer lockingKey)
protected void	toStreamLockSafe(ObjectOutput oos)

Methods inherited from class org.infinispan.loaders.LockSupportCacheStore

acquireGlobalLock, clear, downgradeLock, fromStream, getTotalLockCount, immediateLockForWriting, load, load, loadAll, loadAllKeys, lockForReading, lockForWriting, releaseGlobalLock, remove, store, toStream, unlock, upgradeLock

Methods inherited from class org.infinispan.loaders.AbstractCacheStore

applyModifications, commit, getCacheStoreConfig, getConcurrencyLevel, getMarshaller, prepare, purgeExpired, removeAll, rollback, safeClose, safeClose, supportsMultiThreadedPurge

Methods inherited from class org.infinispan.loaders.AbstractCacheLoader

containsKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.loaders.CacheLoader

containsKey

Constructor Detail

LevelDBCacheStore

public LevelDBCacheStore()

Method Detail

getConfigurationClass

public Class<? extends CacheLoaderConfig> getConfigurationClass()

Description copied from interface: CacheLoader

This method is used by the configuration parser to get a hold of the CacheLoader implementation's corresponding CacheLoaderConfig type. This is usually done by instantiating the CacheLoader and then calling this method. This may result in 2 instances being created, however, since the instance created to get a hold of the configuration type is then discarded and another instance is created for actual use as a CacheLoader when the cache starts.

Since Infinispan 4.1, you can also annotate your CacheLoader implementation with CacheLoaderMetadata and provide this information via the annotation, which will prevent unnecessary instances being created.

Returns:

the type of the CacheLoaderConfig bean used to configure this implementation of CacheLoader.

init

public void init(CacheLoaderConfig config,
        Cache<?,?> cache,
        StreamingMarshaller m)
          throws CacheLoaderException

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<Integer>

Parameters:

config - the cache loader configuration bean

cache - 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.

Throws:

CacheLoaderException

start

public void start()
           throws CacheLoaderException

Specified by:

start in interface CacheLoader

Overrides:

start in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

openDatabase

protected org.iq80.leveldb.DB openDatabase(String location,
                               org.iq80.leveldb.Options options)
                                    throws IOException

Creates database if it doesn't exist.

Returns:

database at location

Throws:

IOException

destroyDatabase

protected void destroyDatabase(String location)
                        throws IOException

Throws:

IOException

reinitDatabase

protected org.iq80.leveldb.DB reinitDatabase(String location,
                                 org.iq80.leveldb.Options options)
                                      throws IOException

Throws:

IOException

reinitAllDatabases

protected void reinitAllDatabases()
                           throws IOException

Throws:

IOException

stop

public void stop()
          throws CacheLoaderException

Specified by:

stop in interface CacheLoader

Overrides:

stop in class AbstractCacheStore

Throws:

CacheLoaderException

clearLockSafe

protected void clearLockSafe()
                      throws CacheLoaderException

Specified by:

clearLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

loadAllLockSafe

protected Set<InternalCacheEntry> loadAllLockSafe()
                                           throws CacheLoaderException

Specified by:

loadAllLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

loadLockSafe

protected Set<InternalCacheEntry> loadLockSafe(int maxEntries)
                                        throws CacheLoaderException

Specified by:

loadLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

loadAllKeysLockSafe

protected Set<Object> loadAllKeysLockSafe(Set<Object> keysToExclude)
                                   throws CacheLoaderException

Specified by:

loadAllKeysLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

toStreamLockSafe

protected void toStreamLockSafe(ObjectOutput oos)
                         throws CacheLoaderException

Specified by:

toStreamLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

fromStreamLockSafe

protected void fromStreamLockSafe(ObjectInput ois)
                           throws CacheLoaderException

Specified by:

fromStreamLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

removeLockSafe

protected boolean removeLockSafe(Object key,
                     Integer lockingKey)
                          throws CacheLoaderException

Specified by:

removeLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

storeLockSafe

protected void storeLockSafe(InternalCacheEntry ed,
                 Integer lockingKey)
                      throws CacheLoaderException

Specified by:

storeLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

loadLockSafe

protected InternalCacheEntry loadLockSafe(Object key,
                              Integer lockingKey)
                                   throws CacheLoaderException

Specified by:

loadLockSafe in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

getLockFromKey

protected Integer getLockFromKey(Object key)
                          throws CacheLoaderException

Specified by:

getLockFromKey in class LockSupportCacheStore<Integer>

Throws:

CacheLoaderException

purgeInternal

protected void purgeInternal()
                      throws CacheLoaderException

Specified by:

purgeInternal in class AbstractCacheStore

Throws:

CacheLoaderException