|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
CacheLoader
that holds common implementations for some methodsCacheStore
that holds common implementations for some methodsAbstractCacheStore
.AbstractDelegatingCache
, but for AdvancedCache
.CacheManagerNotifierImpl
and
CacheNotifierImpl
AbstractConfigurationBean
.GlobalTransaction
TxInvocationContext
.Fqn
under the current node.
AbstractComponentRegistry.Component.injectionMethods
.
Cache
.mods
atomically by creating a worker
and invoking
them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker)
.
AtomicHashMap
to provide reader consistencyCache.startBatch()
and
Cache.endBatch(boolean)
calls.CacheStore
.BdbjeCacheStore
.LinkedHashMap
except that this version makes use of the fact that entries are
bidirectionally linked and can hence be nagigated either from the start or from the end.Executors
except that the factory methods here allow you to specify the
size of the blocking queue that backs the executor.RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean)
except that the task
is passed to the transport executor and a Future is returned.
RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean)
except that
the task is passed to the transport executor and a Future is returned.
CacheEntryActivated
.CacheEntryCreated
.CacheEntryEvicted
.CacheLoader
.CacheEntryLoaded
.CacheEntryModified
CacheEntryPassivated
.CacheEntryRemoved
.CacheEntryVisited
.Cache
fail unexpectedly.Configuration.isExposeJmxStatistics()
is true, then class will register all the MBeans from cache local's
ConfigurationRegistry to the MBean server.CacheLoader
implementation if there are problems reading from a loader.Cache
instance, and is often
used as a starting point to using the Cache
.RpcManager
only replicates commands wrapped in a CacheRpcCommand
.CacheStarted
.CacheStopped
.CacheLoader
interface that can be written to.StoredContainer.clear()
CacheStore.clear()
modificationMap.clear()
.
ClusterCacheLoader
.org.infinispan.loader.cluster.ClusterCacheLoader
.ClusteredGetCommand
s.ReplicableCommand
s.Visitor
interface allowing it to
intercept invocations on VisitableCommand
s.DeltaAware.delta()
) and can be
discarded.
completeTransaction
with an argument of true.
FqnComparator
.
tx
.
ConcurrentHashMap
to deal with the fact that the
JDK does not have a proper concurrent Set implementation that uses efficient lock striping.Configuration
s.ConnectionFactory
.CacheLoader.load(Object)
, to ensure that a response is
returned only if the entry is not expired.
JdbmCacheStoreConfig.setComparatorClassName(String)
.
TxInvocationContext
.
NonTxInvocationContext
with the NonTxInvocationContext.isOriginLocal()
returning true.
NonTxInvocationContext
whose NonTxInvocationContext.isOriginLocal()
flag will be true.
RemoteTransaction
based on the supplied params.
RemoteTxInvocationContext
.
StoredMap
persisted by the database
StoredMap
persisted by the database
Cache
as a parameter
LocalTxInvocationContext
.
Version.getVersionShort()
.
Cache
instance, and is often used as a
starting point to using the Cache
.Key2StringMapper
.DeltaAware
implementation.Modification
objects and
executes it against the CacheStore
. Current commands supported are: STORE CLEAR
REMOVE PURGE_EXPIRED
DummyTransactionManager
.Configuration
as being modifiable even after the cache has started.Cache.startBatch()
.
BucketBasedCacheStore
.FileCacheStore
.Flag
.Node
in a TreeCache
.Fqn.writeExternal(java.io.ObjectOutput)
.
Node
.
null
if this map contains no mapping for the
key.
RuntimeConfig.setAsyncCacheListenerExecutor(java.util.concurrent.ExecutorService)
.
RuntimeConfig.setAsyncSerializationExecutor(ExecutorService)
.
clone
of the Configuration
registered under the given name.
ConnectionFactory
based on the supplied class
name.
RpcManager.retrieveState(String, long)
has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted.
CustomInterceptorConfig
, if any, associated with this configuration
object.
Node
.
Fqn
which represents the location of this Node
in the cache structure.
Configuration
or RuntimeConfig
.
InvocationContext
that is currently associated with the calling thread.
Set
containing the data in this Node
.
Fqn.SEPARATOR
.
BucketBasedCacheStore
s the lock should be acquired at bucket level.
DefaultFactoryFor
annotation that is capable of creating the component
class).
TransactionXaAdapter
corresponding to the supplied transaction.
RemoteTransaction
associated with the supplied transaction id.
Address
objects) that participate within the transaction.
Fqn
passed in exists.
LockSupportCacheStore.lockForWriting(String)
, but with 0 timeout.
ImmortalCacheEntry
Listenable.addListener(Object)
API.BdbjeCacheStoreConfig
note
that the m
is not currently used as SleepyCat has its own efficient solution.
ReplicableCommand
read from a data stream with components specific
to the target cache instance.
Bucket.getBucketName()
Bucket.getBucketName()
InvocationContext
and the calling thread.InvocationContextContainer
.AccessibleObject.setAccessible(boolean)
RpcDispatcher.callRemoteMethods(java.util.Vector, org.jgroups.blocks.MethodCall, int, long, boolean, boolean,
org.jgroups.blocks.RspFilter)
except that this version is aware of ReplicableCommand
objects.
RpcManager.invokeRemotely(java.util.List, org.infinispan.commands.ReplicableCommand, boolean)
except
that the task is passed to the transport executor and a Future is returned.
RpcManager.invokeRemotely(java.util.List, org.infinispan.commands.ReplicableCommand, boolean)
except
that the task is passed to the transport executor and a Future is returned.
TransactionManager
instance from "java:/TransactionManager".JClouds
implementation of S3Bucket
.S3Connection
.BucketBasedCacheStore
implementation that will store all the buckets as rows in database, each row
coresponding to a bucket.JdbcBinaryCacheStore
.JdbcBinaryCacheStore
and JdbcStringBasedCacheStore
.JdbcMixedCacheStore
.CacheStore
implementation that stores the entries in a database.JdbcStringBasedCacheStore
cache store.CacheLoader
based on the JDBM project.JdbmCacheStore
.Marshaller
of the cache.ResponseFilter
.StoredMap.get(Object)
.
StoredMap.values()
null
(i.e.
AbstractCacheStore
adding lock support for consistently acceessing stored data.LockSupportCacheStore
.Log
instances.FileLookup
.
FIFODataContainer
, this implementation
additionally unlinks and re-links entries at the tail whenever entries are visited (using a get()) or are updated (a
put() on an existing key).MarshalledValue
s.DeltaAware
instance, and return a coherent and complete
DeltaAware
instance.
CacheStore
modificationModification
s to be performed atomically via TransactionRunner
.Modification
s that will be applied to the supplied CacheStore
MortalCacheEntry
ComponentName
annotation on the classes requested in Inject
annotated methods.ResponseFilter.isAcceptable(Response, Address)
, this method is called to see whether we are done
with the request and can unblock the caller
named
logical grouping of data in the TreeCache
API of JBoss Cache
.AtomicMap
ComponentRegistry
,
that are resilient to changes in configuration.NotifyingFuture
.ObjectInput
ByteBuffer
, which allows direct access to the byte
array with minimal array copying
ObjectOutput
Cache.startBatch()
and Cache.endBatch(boolean)
API.CacheStore
implementation based on
Oracle's BDBJE storage engine.CacheStore
implementation based on
a JDBC database connection.CacheStore
implementation based on
persisting to JDBM.CacheStore
implementation based on
persisting to Amazon's S3 service.OwnableReentrantLock
s.GlobalConfiguration.getDefaultConfiguration()
This is typically used to configure a DefaultCacheManager
MBeanServerLookup
, will return the platform MBean server.TransactionRunner
, which allows us to prepare a transaction without committing it. The
transaction prepared is accessible via CurrentTransaction.getTransaction()
superclass
and caches a current reference to CurrentTransaction
.
superclass
and caches
a current reference to CurrentTransaction
.
BdbjeCacheStore.applyModifications(java.util.List)
, if isOnePhase
.
SleepyCat transaction
associated with tx
.
run
, except that the
transaction is not committed on success.
StoredMap.entrySet()
and remove, if expired.
Map.put(Object, Object)
, which takes in lifespan parameters.
Map.put(Object, Object)
, which takes in lifespan parameters.
Node
in this cache.
Node
.
Map.putAll(Map)
, which takes in lifespan parameters.
Map.putAll(Map)
, which takes in lifespan parameters.
Map.putAll(Map)
.
Cache.putAll(Map, long, TimeUnit)
.
Cache.putAll(Map, long, TimeUnit, long, TimeUnit)
.
Map.put(Object, Object)
.
Cache.put(Object, Object, long, TimeUnit)
.
Cache.put(Object, Object, long, TimeUnit, long, TimeUnit)
.
ConcurrentMap.putIfAbsent(Object, Object)
, which takes in lifespan parameters.
ConcurrentMap.putIfAbsent(Object, Object)
, which takes in lifespan parameters.
ConcurrentMap.putIfAbsent(Object, Object)
.
Cache.putIfAbsent(Object, Object, long, TimeUnit)
.
Cache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit)
.
Map.put(Object, Object)
XmlConfigHelper.readStringContents(org.w3c.dom.Element,String)
except that it returns a boolean.
XmlConfigHelper.readStringContents(org.w3c.dom.Element,String)
except that it returns a boolean.
ImmutableListCopy.writeExternal(java.io.ObjectOutput)
for serialization format
CacheLoader
, i.e., suppressing all write
methods.AbstractQueuedSynchronizer
.Synchronization
callback with this transaction.
ReplicableCommand
s from a byte stream.StoredMap.remove(Object)
CacheStore.remove(Object)
modificationkey
key
Map.remove(Object)
.
ConcurrentMap.remove(Object, Object)
.
Fqn
.
TransactionXaAdapter
coresponding to the given tx.
Node
indicated by absolute Fqn
.
RemoteTransaction
coresponding to the given tx.
ReadCommittedEntry
that provides Repeatable Read semanticsConcurrentMap.replace(Object, Object)
, which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object, Object)
, which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object)
, which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object, Object)
, which takes in lifespan parameters.
Node.putAll(java.util.Map)
except that it removes any entries that exists in the data map first.
ConcurrentMap.replace(Object, Object)
.
Cache.replace(Object, Object, long, TimeUnit)
.
Cache.replace(Object, Object, long, TimeUnit, long, TimeUnit)
.
ConcurrentMap.replace(Object, Object, Object)
.
Cache.replace(Object, Object, Object, long, TimeUnit)
.
Cache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit)
.
InvocationContext
with the calling thread.
InboundInvocationHandler.generateState(String, java.io.OutputStream)
), and applies this
state to the current cache via the InboundInvocationHandler.applyState(String, java.io.InputStream)
callback.
ReversibleOrderedSet.reverseIterator()
method.CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean)
.
This implementation calls completeTransaction
with an argument of false.
CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean)
.
RootElementBuilder.HORIZON_NS
namespace according to the
configured schema.Transport
.RuntimeConfig
after creating it.Transport
implementation,
and is used to set up the transport and provide lifecycle and dependency hooks into external transport
implementations.S3CacheStore
and Amazon S3.BucketBasedCacheStore
.S3CacheStore
.S3Bucket
implementation if there are problems reading from S3.ConnectionFactory
CommandsFactory
to create a command from raw data read off a stream.
DummyBaseTransactionManager.begin()
method.
DummyBaseTransactionManager.begin()
method.
DummyUserTransaction.begin()
method.
MultipleRpcCommand
, but it only aggregates a single command for
replication.Environment
, then opens the databases
.
StateTransferManager
instances.ComponentStatus.TERMINATED
once it
is done.
StoredMap.put(Object, Object)
CacheStore.store(org.infinispan.container.entries.InternalCacheEntry)
Element
.
Element
.
CacheLoader
implemtations thread safe.StripedLock.StripedLock(int)
with a default concurrency value of 20.
InternalCacheValue
.
key
value
.
Fqn.SEPARATOR
and joining each subsequent
element with a Fqn.SEPARATOR
.
Properties
instance to an instance of TypedProperties
Properties
instance to an instance of TypedProperties, if needed.
TransactionCompleted
.Cache
to use different transactional systems.Synchronization
with a registered TransactionManager
.TransactionRegistered
.RemoteTransaction
and TransactionXaAdapter
s (locally originated trasactions).CacheTransaction
and implementor of an
XAResource
that will be called by tx manager on various tx stages.TransientCacheEntry
TransientMortalCacheEntry
Cache
allowing for efficient tree-style access to cached data.TreeCache
ObjectInput
that delegates all methods except ObjectInput.close()
.ObjectOutput
.ComponentsJmxRegistration.registerMBeans()
.
JdbcStringBasedCacheStore
when one tries to
persist a StoredEntry with an unsupported key type.JBossMarshaller
.ViewChanged
.Map.get(Object)
.
LinkedHashSet
except that it sets the underlying LinkedHashMap
's accessOrder constructor parameter to true, allowing for recording of
visits.Visitor
s, such as CommandInterceptor
s.Inject
annotation, creating more components
as needed based on the Configuration passed in if these additional components don't exist in the ComponentRegistry
.
XmlConfigurationParserImpl.initialize(String)
.
XmlConfigurationParserImpl.initialize(InputStream)
.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |