|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of CacheLoaderException in org.infinispan.loader |
---|
Methods in org.infinispan.loader that throw CacheLoaderException | |
---|---|
protected void |
LockSupportCacheStore.acquireGlobalLock(boolean exclusive)
Based on the supplied param, acquires a global read(false) or write (true) lock. |
protected void |
AbstractCacheStore.applyModifications(List<? extends Modification> mods)
|
void |
LockSupportCacheStore.clear()
|
void |
CacheStore.clear()
Clears all entries in the store |
protected abstract void |
LockSupportCacheStore.clearLockSafe()
|
void |
CacheStore.commit(Transaction tx)
Commits a transaction that has been previously prepared. |
void |
AbstractCacheStore.commit(Transaction tx)
|
boolean |
CacheLoader.containsKey(Object key)
|
boolean |
AbstractCacheLoader.containsKey(Object key)
This implementation delegates to CacheLoader.load(Object) , to ensure that a response is
returned only if the entry is not expired. |
void |
LockSupportCacheStore.fromStream(ObjectInput objectInput)
|
void |
CacheStore.fromStream(ObjectInput inputStream)
Writes contents of the stream to the store. |
protected abstract void |
LockSupportCacheStore.fromStreamLockSafe(ObjectInput ois)
|
protected abstract String |
LockSupportCacheStore.getLockFromKey(Object key)
|
protected boolean |
LockSupportCacheStore.immediateLockForWritting(String key)
Same as LockSupportCacheStore.lockForWritting(String) , but with 0 timeout. |
InternalCacheEntry |
LockSupportCacheStore.load(Object key)
|
InternalCacheEntry |
CacheLoader.load(Object key)
Loads an entry mapped to by a given key. |
Set<InternalCacheEntry> |
LockSupportCacheStore.loadAll()
|
Set<InternalCacheEntry> |
CacheLoader.loadAll()
Loads all entries in the loader. |
protected abstract Set<InternalCacheEntry> |
LockSupportCacheStore.loadAllLockSafe()
|
protected abstract InternalCacheEntry |
LockSupportCacheStore.loadLockSafe(Object key,
String lockingKey)
|
protected void |
LockSupportCacheStore.lockForReading(String key)
Acquires read lock on the given key. |
protected void |
LockSupportCacheStore.lockForWritting(String key)
Acquires write lock on the given key. |
void |
CacheStore.prepare(List<? extends Modification> modifications,
Transaction tx,
boolean isOnePhase)
Issues a prepare call with a set of modifications to be applied to the cache store |
void |
AbstractCacheStore.prepare(List<? extends Modification> mods,
Transaction tx,
boolean isOnePhase)
|
void |
CacheStore.purgeExpired()
Purges expired entries from the store. |
void |
AbstractCacheStore.purgeExpired()
|
protected void |
AbstractCacheStore.purgeInternal()
|
boolean |
LockSupportCacheStore.remove(Object key)
|
boolean |
CacheStore.remove(Object key)
Removes an entry in the store. |
void |
CacheStore.removeAll(Set<Object> keys)
Bulk remove operation |
void |
AbstractCacheStore.removeAll(Set<Object> keys)
|
protected abstract boolean |
LockSupportCacheStore.removeLockSafe(Object key,
String lockingKey)
|
protected void |
AbstractCacheStore.safeClose(InputStream stream)
|
protected void |
AbstractCacheStore.safeClose(OutputStream stream)
|
void |
LockSupportCacheStore.start()
|
void |
CacheLoader.start()
|
void |
AbstractCacheStore.start()
|
void |
CacheLoader.stop()
|
void |
AbstractCacheStore.stop()
|
void |
LockSupportCacheStore.store(InternalCacheEntry ed)
|
void |
CacheStore.store(InternalCacheEntry entry)
Stores an entry |
protected abstract void |
LockSupportCacheStore.storeLockSafe(InternalCacheEntry ed,
String lockingKey)
|
void |
LockSupportCacheStore.toStream(ObjectOutput objectOutput)
|
void |
CacheStore.toStream(ObjectOutput outputStream)
Loads the entire state into a stream, using whichever format is most efficient for the cache loader implementation. |
protected abstract void |
LockSupportCacheStore.toStreamLockSafe(ObjectOutput oos)
|
Uses of CacheLoaderException in org.infinispan.loader.bdbje |
---|
Methods in org.infinispan.loader.bdbje that throw CacheLoaderException | |
---|---|
protected void |
BdbjeCacheStore.applyModifications(List<? extends Modification> mods)
Perform the mods atomically by creating a worker and invoking
them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker) . |
void |
BdbjeCacheStore.clear()
Clears all entries in the store This implementation delegates to StoredContainer.clear() |
void |
BdbjeCacheStore.commit(Transaction tx)
Commits a transaction that has been previously prepared. This implementation calls completeTransaction with an argument of true. |
protected void |
BdbjeCacheStore.completeTransaction(Transaction tx,
boolean commit)
Looks up the SleepyCat transaction associated with the parameter tx . |
void |
BdbjeCacheStore.fromStream(ObjectInput ois)
Writes contents of the stream to the store. This implementation reads the number of entries to load from the stream, then begins a transaction. |
InternalCacheEntry |
BdbjeCacheStore.load(Object key)
Loads an entry mapped to by a given key. This implementation delegates to StoredMap.get(Object) . |
Set<InternalCacheEntry> |
BdbjeCacheStore.loadAll()
Loads all entries in the loader. This implementation returns a Set from StoredMap.values() |
protected void |
BdbjeCacheStore.prepare(List<? extends Modification> mods,
Transaction tx)
Looks up the SleepyCat transaction associated with tx . |
void |
BdbjeCacheStore.prepare(List<? extends Modification> mods,
Transaction tx,
boolean isOnePhase)
Issues a prepare call with a set of modifications to be applied to the cache store delegates to BdbjeCacheStore.applyModifications(java.util.List) , if isOnePhase . |
protected void |
BdbjeCacheStore.purgeInternal()
Iterate through StoredMap.entrySet() and remove, if expired. |
boolean |
BdbjeCacheStore.remove(Object key)
Removes an entry in the store. This implementation delegates to StoredMap.remove(Object) |
void |
BdbjeCacheStore.start()
Validates configuration, configures and opens the Environment , then opens the databases . |
void |
BdbjeCacheStore.stop()
Stops transaction and purge processing and closes the SleepyCat environment. |
void |
BdbjeCacheStore.store(InternalCacheEntry ed)
Stores an entry This implementation delegates to StoredMap.put(Object, Object) |
void |
BdbjeCacheStore.toStream(ObjectOutput oos)
|
Uses of CacheLoaderException in org.infinispan.loader.bucket |
---|
Methods in org.infinispan.loader.bucket that throw CacheLoaderException | |
---|---|
protected abstract void |
BucketBasedCacheStore.insertBucket(Bucket bucket)
|
protected abstract Bucket |
BucketBasedCacheStore.loadBucket(String keyHashCode)
Loads the bucket from the store, base on the hashcode. |
protected InternalCacheEntry |
BucketBasedCacheStore.loadLockSafe(Object key,
String lockingKey)
Loads the bucket coresponding to the given key, and lookups the key within it. |
protected boolean |
BucketBasedCacheStore.removeLockSafe(Object key,
String keyHashCodeStr)
Lookups a bucket where the given key is stored. |
protected abstract void |
BucketBasedCacheStore.saveBucket(Bucket bucket)
This method assumes that the bucket is already persisted in the database. |
protected void |
BucketBasedCacheStore.storeLockSafe(InternalCacheEntry ed,
String lockingKey)
Tries to find a bucket corresponding to storedEntry's key, and updates it with the storedEntry. |
Uses of CacheLoaderException in org.infinispan.loader.cluster |
---|
Methods in org.infinispan.loader.cluster that throw CacheLoaderException | |
---|---|
InternalCacheEntry |
ClusterCacheLoader.load(Object key)
|
Set<InternalCacheEntry> |
ClusterCacheLoader.loadAll()
|
void |
ClusterCacheLoader.start()
|
void |
ClusterCacheLoader.stop()
|
Uses of CacheLoaderException in org.infinispan.loader.decorators |
---|
Methods in org.infinispan.loader.decorators that throw CacheLoaderException | |
---|---|
protected void |
AsyncStore.applyModificationsSync(List<Modification> mods)
|
void |
SingletonStore.clear()
|
void |
ChainingCacheStore.clear()
|
void |
AbstractDelegatingStore.clear()
|
void |
SingletonStore.commit(Transaction tx)
|
void |
ChainingCacheStore.commit(Transaction tx)
|
void |
AbstractDelegatingStore.commit(Transaction tx)
|
boolean |
ChainingCacheStore.containsKey(Object key)
|
boolean |
AbstractDelegatingStore.containsKey(Object key)
|
void |
SingletonStore.fromStream(ObjectInput inputStream)
|
void |
ChainingCacheStore.fromStream(ObjectInput inputStream)
|
void |
AbstractDelegatingStore.fromStream(ObjectInput inputStream)
|
InternalCacheEntry |
ChainingCacheStore.load(Object key)
|
InternalCacheEntry |
AbstractDelegatingStore.load(Object key)
|
Set<InternalCacheEntry> |
ChainingCacheStore.loadAll()
|
Set<InternalCacheEntry> |
AbstractDelegatingStore.loadAll()
|
void |
SingletonStore.prepare(List<? extends Modification> list,
Transaction tx,
boolean isOnePhase)
|
void |
ChainingCacheStore.prepare(List<? extends Modification> list,
Transaction tx,
boolean isOnePhase)
|
void |
AbstractDelegatingStore.prepare(List<? extends Modification> list,
Transaction tx,
boolean isOnePhase)
|
void |
SingletonStore.purgeExpired()
|
void |
ChainingCacheStore.purgeExpired()
|
void |
AbstractDelegatingStore.purgeExpired()
|
void |
ChainingCacheStore.purgeIfNecessary()
|
boolean |
SingletonStore.remove(Object key)
|
boolean |
ChainingCacheStore.remove(Object key)
|
boolean |
AbstractDelegatingStore.remove(Object key)
|
void |
ChainingCacheStore.removeAll(Set<Object> keys)
|
void |
AbstractDelegatingStore.removeAll(Set<Object> keys)
|
void |
SingletonStore.start()
|
void |
ChainingCacheStore.start()
|
void |
AsyncStore.start()
|
void |
AbstractDelegatingStore.start()
|
void |
ChainingCacheStore.stop()
|
void |
AsyncStore.stop()
|
void |
AbstractDelegatingStore.stop()
|
void |
SingletonStore.store(InternalCacheEntry ed)
|
void |
ChainingCacheStore.store(InternalCacheEntry ed)
|
void |
AbstractDelegatingStore.store(InternalCacheEntry ed)
|
void |
ChainingCacheStore.toStream(ObjectOutput outputStream)
|
void |
AbstractDelegatingStore.toStream(ObjectOutput outputStream)
|
Uses of CacheLoaderException in org.infinispan.loader.file |
---|
Methods in org.infinispan.loader.file that throw CacheLoaderException | |
---|---|
protected void |
FileCacheStore.clearLockSafe()
|
protected void |
FileCacheStore.fromStreamLockSafe(ObjectInput objectInput)
|
protected void |
FileCacheStore.insertBucket(Bucket bucket)
|
protected Set<InternalCacheEntry> |
FileCacheStore.loadAllLockSafe()
|
protected Bucket |
FileCacheStore.loadBucket(File bucketFile)
|
protected Bucket |
FileCacheStore.loadBucket(String bucketName)
|
Bucket |
FileCacheStore.loadBucketContainingKey(String key)
|
protected void |
FileCacheStore.purgeInternal()
|
void |
FileCacheStore.saveBucket(Bucket b)
|
void |
FileCacheStore.start()
|
protected void |
FileCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
|
Uses of CacheLoaderException in org.infinispan.loader.jdbc |
---|
Methods in org.infinispan.loader.jdbc that throw CacheLoaderException | |
---|---|
void |
TableManipulation.createTable(Connection conn)
|
void |
TableManipulation.dropTable(Connection conn)
|
static ByteBuffer |
JdbcUtil.marshall(Marshaller marshaller,
Object bucket)
|
void |
TableManipulation.start(ConnectionFactory connectionFactory)
|
void |
TableManipulation.stop()
|
boolean |
TableManipulation.tableExists(Connection connection)
|
boolean |
TableManipulation.tableExists(Connection connection,
String tableName)
|
static Object |
JdbcUtil.unmarshall(Marshaller marshaller,
InputStream inputStream)
|
Uses of CacheLoaderException in org.infinispan.loader.jdbc.binary |
---|
Methods in org.infinispan.loader.jdbc.binary that throw CacheLoaderException | |
---|---|
protected void |
JdbcBinaryCacheStore.clearLockSafe()
|
void |
JdbcBinaryCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
Keeps a reference to the connection factory for further use. |
protected void |
JdbcBinaryCacheStore.fromStreamLockSafe(ObjectInput objectInput)
|
protected void |
JdbcBinaryCacheStore.insertBucket(Bucket bucket)
|
Set<InternalCacheEntry> |
JdbcBinaryCacheStore.loadAllLockSafe()
|
protected Bucket |
JdbcBinaryCacheStore.loadBucket(String keyHashCode)
|
protected void |
JdbcBinaryCacheStore.logAndThrow(Exception e,
String message)
|
void |
JdbcBinaryCacheStore.purgeInternal()
|
protected void |
JdbcBinaryCacheStore.saveBucket(Bucket bucket)
|
void |
JdbcBinaryCacheStore.start()
|
void |
JdbcBinaryCacheStore.stop()
|
protected void |
JdbcBinaryCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
|
Uses of CacheLoaderException in org.infinispan.loader.jdbc.connectionfactory |
---|
Methods in org.infinispan.loader.jdbc.connectionfactory that throw CacheLoaderException | |
---|---|
Connection |
SimpleConnectionFactory.getConnection()
|
Connection |
PooledConnectionFactory.getConnection()
|
abstract Connection |
ConnectionFactory.getConnection()
Fetches a connection from the factory. |
static ConnectionFactory |
ConnectionFactory.getConnectionFactory(String connectionFactoryClass)
Constructs a ConnectionFactory based on the supplied class name. |
void |
SimpleConnectionFactory.start(ConnectionFactoryConfig config)
|
void |
PooledConnectionFactory.start(ConnectionFactoryConfig config)
|
abstract void |
ConnectionFactory.start(ConnectionFactoryConfig config)
Starts the connection factory. |
Uses of CacheLoaderException in org.infinispan.loader.jdbc.mixed |
---|
Methods in org.infinispan.loader.jdbc.mixed that throw CacheLoaderException | |
---|---|
void |
JdbcMixedCacheStore.clear()
|
void |
JdbcMixedCacheStore.fromStream(ObjectInput inputStream)
|
InternalCacheEntry |
JdbcMixedCacheStore.load(Object key)
|
Set<InternalCacheEntry> |
JdbcMixedCacheStore.loadAll()
|
protected void |
JdbcMixedCacheStore.purgeInternal()
|
boolean |
JdbcMixedCacheStore.remove(Object key)
|
void |
JdbcMixedCacheStore.start()
|
void |
JdbcMixedCacheStore.stop()
|
void |
JdbcMixedCacheStore.store(InternalCacheEntry ed)
|
void |
JdbcMixedCacheStore.toStream(ObjectOutput outputStream)
|
Uses of CacheLoaderException in org.infinispan.loader.jdbc.stringbased |
---|
Subclasses of CacheLoaderException in org.infinispan.loader.jdbc.stringbased | |
---|---|
class |
UnsupportedKeyTypeException
Exception thrown by JdbcStringBasedCacheStore when one tries to persist
a StoredEntry with an unsupported key type. |
Methods in org.infinispan.loader.jdbc.stringbased that throw CacheLoaderException | |
---|---|
protected void |
JdbcStringBasedCacheStore.clearLockSafe()
|
void |
JdbcStringBasedCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
Keeps a reference to the connection factory for further use. |
void |
JdbcStringBasedCacheStore.fromStreamLockSafe(ObjectInput objectInput)
|
protected String |
JdbcStringBasedCacheStore.getLockFromKey(Object key)
|
protected Set<InternalCacheEntry> |
JdbcStringBasedCacheStore.loadAllLockSafe()
|
protected InternalCacheEntry |
JdbcStringBasedCacheStore.loadLockSafe(Object key,
String lockingKey)
|
protected void |
JdbcStringBasedCacheStore.logAndThrow(Exception e,
String message)
|
void |
JdbcStringBasedCacheStore.purgeInternal()
|
boolean |
JdbcStringBasedCacheStore.removeLockSafe(Object key,
String keyStr)
|
void |
JdbcStringBasedCacheStore.start()
|
void |
JdbcStringBasedCacheStore.stop()
|
void |
JdbcStringBasedCacheStore.storeLockSafe(InternalCacheEntry ed,
String lockingKey)
|
protected void |
JdbcStringBasedCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
|
Uses of CacheLoaderException in org.infinispan.loader.s3 |
---|
Subclasses of CacheLoaderException in org.infinispan.loader.s3 | |
---|---|
class |
S3ConnectionException
An exception thrown by a S3Bucket implementation if there are problems reading from S3. |
Methods in org.infinispan.loader.s3 that throw CacheLoaderException | |
---|---|
protected void |
S3CacheStore.clearLockSafe()
|
protected void |
S3CacheStore.fromStreamLockSafe(ObjectInput objectInput)
|
protected void |
S3CacheStore.insertBucket(Bucket bucket)
|
protected Set<InternalCacheEntry> |
S3CacheStore.loadAllLockSafe()
|
protected Bucket |
S3CacheStore.loadBucket(String bucketName)
|
protected void |
S3CacheStore.purgeInternal()
|
protected void |
S3CacheStore.saveBucket(Bucket bucket)
|
void |
S3CacheStore.start()
|
void |
S3CacheStore.stop()
|
protected void |
S3CacheStore.toStreamLockSafe(ObjectOutput objectOutput)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |