Package org.infinispan.interceptors.distribution
package org.infinispan.interceptors.distribution
Interceptors dealing with command replication in distributed/replicated mode.
- THIS IS NOT PUBLIC API! This is a private implementation detail and must not be referenced by user code.
-
ClassDescriptionBase class for distribution of entries across a cluster.Collector<T>Represents the ack collector for a write operation in triangle algorithm.Thrown when the version of entry has changed between loading the entry to the context and committing new value.L1 based interceptor that flushes the L1 cache at the end after a transaction/entry is committed to the data container but before the lock has been released.Interceptor that handles L1 logic for non-transactional caches.Interceptor that handles L1 logic for transactional caches.A write synchronizer that allows for a single thread to run the L1 update while others can block until it is completed.Non-transactional interceptor used by distributed caches that support concurrent writes.A
Collectorimplementation that only waits for the primary owner.Return the first successful response for a staggered remote get, used in dist mode.Non-transactional interceptor used by distributed caches that supports concurrent writes.Handles the distribution of the transactional caches.A version of theTxDistributionInterceptorthat adds logic to handling prepares when entries are versioned.WARNING: Generated code!WARNING: Generated code!WriteManyCommandHelper<C extends WriteCommand, Container, Item>