Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.interceptors.locking
Interface ClusteringDependentLogic

All Known Implementing Classes:
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic

public interface ClusteringDependentLogic

Abstractization for logic related to different clustering modes: replicated or distributed. This implements the Bridge pattern as described by the GoF: this plays the role of the Implementor and various LockingInterceptors are the Abstraction.

Since:
5.1
Author:
Mircea Markus

Nested Class Summary
static class ClusteringDependentLogic.AbstractClusteringDependentLogic
           
static class ClusteringDependentLogic.DistributionLogic
          This logic is used in distributed mode caches.
static class ClusteringDependentLogic.InvalidationLogic
          This logic is used in invalidation mode caches.
static class ClusteringDependentLogic.LocalLogic
          This logic is used in local mode caches.
static class ClusteringDependentLogic.ReplicationLogic
          This logic is used in replicated mode caches.
 
Method Summary
 void commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck, InvocationContext ctx)
           
 EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
           
 Address getAddress()
           
 Collection<Address> getOwners(Collection<Object> keys)
           
 Address getPrimaryOwner(Object key)
           
 boolean localNodeIsOwner(Object key)
           
 boolean localNodeIsPrimaryOwner(Object key)
           
 

Method Detail

localNodeIsOwner

boolean localNodeIsOwner(Object key)

localNodeIsPrimaryOwner

boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

Address getPrimaryOwner(Object key)

commitEntry

void commitEntry(CacheEntry entry,
                 EntryVersion newVersion,
                 boolean skipOwnershipCheck,
                 InvocationContext ctx)

getOwners

Collection<Address> getOwners(Collection<Object> keys)

createNewVersionsAndCheckForWriteSkews

EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
                                                        TxInvocationContext context,
                                                        VersionedPrepareCommand prepareCommand)

getAddress

Address getAddress()

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.