Package | Description |
---|---|
org.hibernate.cache.infinispan.util | |
org.infinispan.affinity | |
org.infinispan.cacheviews | |
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control |
Commands that control and coordinate certain cache operations, such as rehashing, state transfer and locking.
|
org.infinispan.commands.read |
Commands that read data from the cache.
|
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.context |
Contexts contain information of a specific invocation on the cache, such as its origins, scope
(transactional or non-transactional), as well as invocation-specific flags.
|
org.infinispan.context.impl |
This package contains different context implementations, selected dynamically based on the type of invocation.
|
org.infinispan.distexec | |
org.infinispan.distexec.mapreduce | |
org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
org.infinispan.distribution.ch | |
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.locking | |
org.infinispan.manager |
Cache manager package
|
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.notifications.cachelistener.event | |
org.infinispan.notifications.cachemanagerlistener |
CacheManager -specific notifications and eventing. |
org.infinispan.notifications.cachemanagerlistener.event | |
org.infinispan.remoting |
Remote communication between cache instances.
|
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
org.infinispan.remoting.transport |
Transports handle the low-level networking, used by the remoting components.
|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.transaction.xa |
XA transaction support.
|
org.infinispan.transaction.xa.recovery | |
org.infinispan.util |
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
|
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
Modifier and Type | Method and Description |
---|---|
static List<AddressAdapter> |
AddressAdapterImpl.toAddressAdapter(List<Address> ispnAddresses) |
Constructor and Description |
---|
AddressAdapterImpl(Address address) |
Modifier and Type | Method and Description |
---|---|
Map<Address,BlockingQueue<K>> |
KeyAffinityServiceImpl.getAddress2KeysMapping() |
Modifier and Type | Method and Description |
---|---|
K |
KeyAffinityServiceImpl.getKeyForAddress(Address address) |
K |
KeyAffinityService.getKeyForAddress(Address address)
Returns a key that will be distributed on the cluster node identified by address.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Creates a service that would only generate keys for addresses specified in filter.
|
Constructor and Description |
---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
CacheViewInfo.computeLeavers(List<Address> newMembers) |
Set<Address> |
PendingCacheViewChanges.computeMissingJoiners(Collection<Address> newMembers) |
Set<Address> |
PendingCacheViewChanges.getLeavers() |
Set<Address> |
CacheViewsManagerImpl.getLeavers(String cacheName) |
Set<Address> |
CacheViewsManager.getLeavers(String cacheName) |
List<Address> |
CacheView.getMembers() |
Set<Address> |
PendingCacheViewChanges.requestLeave(Collection<Address> leavers)
Signal a leave.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CacheView.contains(Address node) |
void |
CacheViewsManagerImpl.handleRequestJoin(Address sender,
String cacheName)
Handle a join request.
|
void |
CacheViewsManager.handleRequestJoin(Address sender,
String cacheName) |
void |
CacheViewsManagerImpl.handleRequestLeave(Address sender,
String cacheName) |
void |
CacheViewsManager.handleRequestLeave(Address sender,
String cacheName) |
void |
PendingCacheViewChanges.requestJoin(Address joiner)
Signal a join
|
Modifier and Type | Method and Description |
---|---|
List<Address> |
CacheViewInfo.computeLeavers(List<Address> newMembers) |
Set<Address> |
PendingCacheViewChanges.computeMissingJoiners(Collection<Address> newMembers) |
boolean |
CacheView.containsAny(Collection<Address> nodes) |
void |
PendingCacheViewChanges.recoveredViews(Collection<Address> newMembers,
Collection<Address> recoveredJoiners)
Signal a merge
|
void |
PendingCacheViewChanges.recoveredViews(Collection<Address> newMembers,
Collection<Address> recoveredJoiners)
Signal a merge
|
Set<Address> |
PendingCacheViewChanges.requestLeave(Collection<Address> leavers)
Signal a leave.
|
Constructor and Description |
---|
CacheView(int viewId,
List<Address> members) |
Modifier and Type | Method and Description |
---|---|
<T> DistributedExecuteCommand<T> |
CommandsFactoryImpl.buildDistributedExecuteCommand(Callable<T> callable,
Address sender,
Collection keys) |
<T> DistributedExecuteCommand<T> |
CommandsFactory.buildDistributedExecuteCommand(Callable<T> callable,
Address sender,
Collection keys)
Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.
|
InvalidateCommand |
CommandsFactoryImpl.buildInvalidateFromL1Command(Address origin,
boolean forRehash,
Collection<Object> keys) |
InvalidateCommand |
CommandsFactory.buildInvalidateFromL1Command(Address origin,
boolean forRehash,
Collection<Object> keys) |
MapReduceCommand |
CommandsFactoryImpl.buildMapReduceCommand(Mapper m,
Reducer r,
Address sender,
Collection keys) |
MapReduceCommand |
CommandsFactory.buildMapReduceCommand(Mapper m,
Reducer r,
Address sender,
Collection keys)
Builds a MapReduceCommand used for migration and execution of MapReduce tasks.
|
StateTransferControlCommand |
CommandsFactoryImpl.buildStateTransferCommand(StateTransferControlCommand.Type type,
Address sender,
int viewId) |
StateTransferControlCommand |
CommandsFactory.buildStateTransferCommand(StateTransferControlCommand.Type subtype,
Address sender,
int viewId)
Builds a RehashControlCommand for coordinating a rehash event.
|
StateTransferControlCommand |
CommandsFactoryImpl.buildStateTransferCommand(StateTransferControlCommand.Type type,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
StateTransferControlCommand |
CommandsFactory.buildStateTransferCommand(StateTransferControlCommand.Type subtype,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo)
Builds a RehashControlCommand for coordinating a rehash event.
|
Modifier and Type | Method and Description |
---|---|
Address |
CacheViewControlCommand.getOrigin() |
Modifier and Type | Method and Description |
---|---|
void |
CacheViewControlCommand.setOrigin(Address origin) |
Constructor and Description |
---|
CacheViewControlCommand(String cacheName,
CacheViewControlCommand.Type type,
Address sender) |
CacheViewControlCommand(String cacheName,
CacheViewControlCommand.Type type,
Address sender,
int viewId) |
CacheViewControlCommand(String cacheName,
CacheViewControlCommand.Type type,
Address sender,
int newViewId,
List<Address> newMembers,
int oldViewId,
List<Address> oldMembers) |
StateTransferControlCommand(String cacheName,
StateTransferControlCommand.Type type,
Address sender,
int viewId) |
StateTransferControlCommand(String cacheName,
StateTransferControlCommand.Type type,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
Constructor and Description |
---|
CacheViewControlCommand(String cacheName,
CacheViewControlCommand.Type type,
Address sender,
int newViewId,
List<Address> newMembers,
int oldViewId,
List<Address> oldMembers) |
CacheViewControlCommand(String cacheName,
CacheViewControlCommand.Type type,
Address sender,
int newViewId,
List<Address> newMembers,
int oldViewId,
List<Address> oldMembers) |
Modifier and Type | Field and Description |
---|---|
protected Address |
MapReduceCommand.localAddress |
Modifier and Type | Method and Description |
---|---|
void |
MapReduceCommand.init(CommandsFactory factory,
InterceptorChain invoker,
InvocationContextContainer icc,
DistributionManager dm,
Address localAddress) |
Modifier and Type | Method and Description |
---|---|
Address |
CacheRpcCommand.getOrigin()
Get the origin of the command
|
Address |
BaseRpcCommand.getOrigin() |
Modifier and Type | Method and Description |
---|---|
void |
CacheRpcCommand.setOrigin(Address origin)
Set the origin of the command
|
void |
BaseRpcCommand.setOrigin(Address origin) |
Modifier and Type | Method and Description |
---|---|
Address |
AbstractTransactionBoundaryCommand.getOrigin() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransactionBoundaryCommand.setOrigin(Address origin) |
Modifier and Type | Method and Description |
---|---|
boolean |
InvalidateL1Command.isCausedByALocalWrite(Address address)
Returns true if the write that caused the invalidation was performed on this node.
|
Constructor and Description |
---|
InvalidateL1Command(Address writeOrigin,
boolean forRehash,
DataContainer dc,
Configuration config,
DistributionManager dm,
CacheNotifier notifier,
Collection<Object> keys) |
Modifier and Type | Method and Description |
---|---|
Address |
InvocationContextFlagsOverride.getOrigin() |
Address |
InvocationContext.getOrigin()
Get the origin of the command, or null if the command originated locally
|
Modifier and Type | Method and Description |
---|---|
Address |
ImmutableContext.getOrigin() |
Address |
AbstractInvocationContext.getOrigin() |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
LocalTxInvocationContext.getRemoteLocksAcquired() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractInvocationContext.setOrigin(Address origin) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTxInvocationContext.remoteLocksAcquired(Collection<Address> nodes) |
Modifier and Type | Method and Description |
---|---|
protected Address |
DefaultExecutorService.selectExecutionNode() |
protected Address |
DefaultExecutorService.selectExecutionNode(List<Address> candidates) |
Modifier and Type | Method and Description |
---|---|
protected <K> Map<Address,List<K>> |
DefaultExecutorService.mapKeysToNodes(K... input) |
protected List<Address> |
DefaultExecutorService.randomClusterMembers(List<Address> members,
int numNeeded) |
Modifier and Type | Method and Description |
---|---|
protected <T> void |
DefaultExecutorService.executeFuture(Address address,
DefaultExecutorService.DistributedRunnableFuture<T> f) |
Modifier and Type | Method and Description |
---|---|
protected List<Address> |
DefaultExecutorService.randomClusterMembers(List<Address> members,
int numNeeded) |
protected Address |
DefaultExecutorService.selectExecutionNode(List<Address> candidates) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,List<KIn>> |
MapReduceTask.mapKeysToNodes() |
Modifier and Type | Method and Description |
---|---|
Address |
DistributionManagerImpl.getPrimaryLocation(Object key) |
Address |
DistributionManager.getPrimaryLocation(Object key)
Returns the first Address containing the key.
|
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
DistributionManagerImpl.getAffectedNodes(Collection<Object> affectedKeys) |
Collection<Address> |
DistributionManager.getAffectedNodes(Collection<Object> affectedKeys)
A helper method that retrieves a list of nodes affected by operations on a set of keys.
|
List<Address> |
DistributionManagerImpl.locate(Object key) |
List<Address> |
DistributionManager.locate(Object key)
Locates a key in a cluster.
|
Map<Object,List<Address>> |
DistributionManagerImpl.locateAll(Collection<Object> keys) |
Map<Object,List<Address>> |
DistributionManager.locateAll(Collection<Object> keys)
Locates a list of keys in a cluster.
|
Map<Object,List<Address>> |
DistributionManagerImpl.locateAll(Collection<Object> keys,
int numOwners) |
Map<Object,List<Address>> |
DistributionManager.locateAll(Collection<Object> keys,
int numOwners)
Same as
DistributionManager.locateAll(java.util.Collection) , but the list of addresses only contains numOwners owners. |
Modifier and Type | Method and Description |
---|---|
void |
L1ManagerImpl.addRequestor(Object key,
Address origin) |
void |
L1Manager.addRequestor(Object key,
Address requestor)
Records a request that will be cached in another nodes L1
|
NotifyingNotifiableFuture<Object> |
L1ManagerImpl.flushCache(Collection<Object> keys,
Object retval,
Address origin,
boolean assumeOriginKeptEntryInL1) |
NotifyingNotifiableFuture<Object> |
L1Manager.flushCache(Collection<Object> keys,
Object retval,
Address origin,
boolean assumeOriginKeptEntryInL1)
Flushes a cache (using unicast or multicast) for a set of keys
|
Future<Object> |
L1ManagerImpl.flushCacheWithSimpleFuture(Collection<Object> keys,
Object retval,
Address origin,
boolean assumeOriginKeptEntryInL1) |
Future<Object> |
L1Manager.flushCacheWithSimpleFuture(Collection<Object> keys,
Object retval,
Address origin,
boolean assumeOriginKeptEntryInL1) |
Modifier and Type | Class and Description |
---|---|
class |
VirtualAddress
Virtual addresses are used internally by the consistent hashes in order to provide virtual nodes.
|
Modifier and Type | Field and Description |
---|---|
Address |
ExperimentalDefaultConsistentHash.Entry.address |
protected Address[] |
AbstractWheelConsistentHash.positionValues |
Modifier and Type | Field and Description |
---|---|
protected Set<Address> |
AbstractWheelConsistentHash.caches |
Modifier and Type | Method and Description |
---|---|
Address |
VirtualAddress.getRealAddress() |
Address |
ConsistentHash.primaryLocation(Object key)
Should be equivalent to return the first element of
ConsistentHash.locate(Object, int) . |
Address |
AbstractWheelConsistentHash.primaryLocation(Object key) |
Address |
AbstractConsistentHash.primaryLocation(Object key) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ConsistentHash.getBackupsForNode(Address node,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getBackupsForNode(Address node,
int replCount) |
Set<Address> |
UnionConsistentHash.getCaches() |
Set<Address> |
ExperimentalDefaultConsistentHash.getCaches() |
Set<Address> |
ConsistentHash.getCaches()
Should return a collection of cache addresses in the cluster.
|
Set<Address> |
AbstractWheelConsistentHash.getCaches() |
protected Iterator<Address> |
AbstractWheelConsistentHash.getPositionsIterator(int normalizedHash)
Creates an iterator over the positions "map" starting at the index specified by the
normalizedHash . |
List<Address> |
ConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount) |
List<Address> |
ConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount) |
List<Address> |
UnionConsistentHash.locate(Object key,
int replCount) |
List<Address> |
TopologyAwareConsistentHash.locate(Object key,
int replCount) |
List<Address> |
ExperimentalDefaultConsistentHash.locate(Object key,
int replCount) |
List<Address> |
DefaultConsistentHash.locate(Object key,
int replCount) |
List<Address> |
ConsistentHash.locate(Object key,
int replCount)
Locates a key, given a replication count (number of copies).
|
Map<Object,List<Address>> |
ConsistentHash.locateAll(Collection<Object> keys,
int replCount)
The logical equivalent of calling
ConsistentHash.locate(Object, int) multiple times for each key in the collection of
keys. |
Map<Object,List<Address>> |
AbstractConsistentHash.locateAll(Collection<Object> keys,
int replCount) |
Modifier and Type | Method and Description |
---|---|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Address... moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses,
Address... moreAddresses)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash
with the collection of addresses passed in.
|
List<Address> |
ConsistentHash.getBackupsForNode(Address node,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getBackupsForNode(Address node,
int replCount) |
int |
ExperimentalDefaultConsistentHash.getDistance(Address a1,
Address a2)
The distance between the first entries in the address array for two caches, a1 and a2.
|
List<Integer> |
UnionConsistentHash.getHashIds(Address a) |
List<Integer> |
ExperimentalDefaultConsistentHash.getHashIds(Address a) |
List<Integer> |
ConsistentHash.getHashIds(Address a)
Returns a list of values between 0 and the hash space limit, or hash id,
for a particular address.
|
List<Integer> |
AbstractWheelConsistentHash.getHashIds(Address a) |
List<Address> |
ConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount) |
List<Address> |
ConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
Deprecated.
No longer supported. This method doesn't make sense with virtual nodes enabled.
|
List<Address> |
AbstractConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount) |
boolean |
ExperimentalDefaultConsistentHash.isAdjacent(Address a1,
Address a2)
Two hashes are adjacent if they are next to each other in the consistent hash.
|
boolean |
TopologyAwareConsistentHash.isKeyLocalToAddress(Address target,
Object key,
int replCount) |
boolean |
DefaultConsistentHash.isKeyLocalToAddress(Address target,
Object key,
int replCount) |
boolean |
ConsistentHash.isKeyLocalToAddress(Address a,
Object key,
int replCount)
Test to see whether a key is mapped to a given address.
|
boolean |
AbstractConsistentHash.isKeyLocalToAddress(Address a,
Object key,
int replCount) |
static ConsistentHash |
ConsistentHashHelper.removeAddress(ConsistentHash ch,
Address toRemove,
Configuration c)
Returns a new consistent hash of the same type with the given address removed.
|
static UnionConsistentHash |
ConsistentHashHelper.removeAddressFromUnionConsistentHash(UnionConsistentHash uch,
Address toRemove,
Configuration c)
Creates a new UnionConsistentHash instance based on the old instance, removing the provided address from both
target consistent hash instances in the union.
|
Modifier and Type | Method and Description |
---|---|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Address... moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Collection<Address> moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Collection<Address> moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash
with the collection of addresses passed in.
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses,
Address... moreAddresses)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash
with the collection of addresses passed in.
|
void |
ExperimentalDefaultConsistentHash.setCaches(Collection<Address> caches) |
void |
UnionConsistentHash.setCaches(Set<Address> caches) |
void |
TopologyAwareConsistentHash.setCaches(Set<Address> newCaches) |
void |
ExperimentalDefaultConsistentHash.setCaches(Set<Address> caches) |
void |
ConsistentHash.setCaches(Set<Address> caches)
Sets the collection of cache addresses in the cluster.
|
void |
AbstractWheelConsistentHash.setCaches(Set<Address> newCaches) |
Constructor and Description |
---|
ExperimentalDefaultConsistentHash.Entry(Address address,
String string,
int differentiator,
int hash) |
VirtualAddress(Address realAddress,
int id) |
Modifier and Type | Method and Description |
---|---|
protected void |
VersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx,
PrepareCommand command,
Collection<Address> recipients,
boolean ignored) |
protected void |
DistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx,
PrepareCommand command,
Collection<Address> recipients,
boolean sync) |
Modifier and Type | Method and Description |
---|---|
Address |
ClusteringDependentLogic.getAddress() |
Address |
ClusteringDependentLogic.AllNodesLogic.getAddress() |
Address |
ClusteringDependentLogic.DistributionLogic.getAddress() |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
ClusteringDependentLogic.getOwners(Collection<Object> keys) |
Collection<Address> |
ClusteringDependentLogic.AllNodesLogic.getOwners(Collection<Object> keys) |
Collection<Address> |
ClusteringDependentLogic.DistributionLogic.getOwners(Collection<Object> keys) |
Modifier and Type | Method and Description |
---|---|
Address |
EmbeddedCacheManager.getAddress() |
Address |
DefaultCacheManager.getAddress() |
Address |
AbstractDelegatingEmbeddedCacheManager.getAddress() |
Address |
EmbeddedCacheManager.getCoordinator() |
Address |
DefaultCacheManager.getCoordinator() |
Address |
AbstractDelegatingEmbeddedCacheManager.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
EmbeddedCacheManager.getMembers() |
List<Address> |
DefaultCacheManager.getMembers() |
List<Address> |
AbstractDelegatingEmbeddedCacheManager.getMembers() |
Modifier and Type | Method and Description |
---|---|
void |
CacheNotifierImpl.notifyDataRehashed(Collection<Address> oldView,
Collection<Address> newView,
long newViewId,
boolean pre) |
void |
CacheNotifierImpl.notifyDataRehashed(Collection<Address> oldView,
Collection<Address> newView,
long newViewId,
boolean pre) |
void |
CacheNotifier.notifyDataRehashed(Collection<Address> oldView,
Collection<Address> newView,
long newViewId,
boolean pre) |
void |
CacheNotifier.notifyDataRehashed(Collection<Address> oldView,
Collection<Address> newView,
long newViewId,
boolean pre) |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
EventImpl.getMembersAtEnd() |
Collection<Address> |
DataRehashedEvent.getMembersAtEnd() |
Collection<Address> |
EventImpl.getMembersAtStart() |
Collection<Address> |
DataRehashedEvent.getMembersAtStart() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setMembersAtEnd(Collection<Address> membersAtEnd) |
void |
EventImpl.setMembersAtStart(Collection<Address> membersAtStart) |
Modifier and Type | Method and Description |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
List<List<Address>> subgroupsMerged) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId) |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId)
Notifies all registered listeners of a viewChange event.
|
Modifier and Type | Method and Description |
---|---|
Address |
ViewChangedEvent.getLocalAddress() |
Address |
EventImpl.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
ViewChangedEvent.getNewMembers() |
List<Address> |
EventImpl.getNewMembers() |
List<Address> |
ViewChangedEvent.getOldMembers() |
List<Address> |
EventImpl.getOldMembers() |
List<List<Address>> |
MergeEvent.getSubgroupsMerged() |
List<List<Address>> |
EventImpl.getSubgroupsMerged() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setLocalAddress(Address localAddress) |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setNewMembers(List<Address> newMembers) |
void |
EventImpl.setOldMembers(List<Address> oldMembers) |
void |
EventImpl.setSubgroupsMerged(List<List<Address>> subgroupsMerged) |
Constructor and Description |
---|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
Constructor and Description |
---|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId) |
Modifier and Type | Method and Description |
---|---|
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList) |
static Set<Address> |
MembershipArithmetic.getMembersJoined(Set<Address> oldSet,
Set<Address> newSet) |
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList) |
static Set<Address> |
MembershipArithmetic.getMembersLeft(Set<Address> oldSet,
Set<Address> newSet) |
Modifier and Type | Method and Description |
---|---|
Response |
InboundInvocationHandlerImpl.handle(CacheRpcCommand cmd,
Address origin) |
Response |
InboundInvocationHandler.handle(CacheRpcCommand command,
Address origin)
Invokes a command on the cache, from a remote source.
|
Modifier and Type | Method and Description |
---|---|
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList) |
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList) |
static Set<Address> |
MembershipArithmetic.getMembersJoined(Set<Address> oldSet,
Set<Address> newSet) |
static Set<Address> |
MembershipArithmetic.getMembersJoined(Set<Address> oldSet,
Set<Address> newSet) |
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList) |
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList) |
static Set<Address> |
MembershipArithmetic.getMembersLeft(Set<Address> oldSet,
Set<Address> newSet) |
static Set<Address> |
MembershipArithmetic.getMembersLeft(Set<Address> oldSet,
Set<Address> newSet) |
Modifier and Type | Method and Description |
---|---|
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address) |
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address) |
Constructor and Description |
---|
ClusteredGetResponseValidityFilter(Collection<Address> targets,
Address self) |
IgnoreExtraResponsesValidityFilter(Collection<Address> targets,
Address self) |
Constructor and Description |
---|
ClusteredGetResponseValidityFilter(Collection<Address> targets,
Address self) |
IgnoreExtraResponsesValidityFilter(Collection<Address> targets,
Address self) |
Modifier and Type | Method and Description |
---|---|
Address |
RpcManagerImpl.getAddress() |
Address |
RpcManager.getAddress()
Returns the address associated with this RpcManager or null if not part of the cluster.
|
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResponseFilter.isAcceptable(Response response,
Address sender)
Determines whether a response from a given sender should be added to the response list of the request
|
Modifier and Type | Method and Description |
---|---|
void |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync) |
void |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to a specified set of recipients
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster.
|
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
The same as
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l,
long timeout) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout)
The same as
RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand,
boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l,
long timeout,
boolean ignoreLeavers) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout,
boolean ignoreLeavers)
The same as
RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand,
boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture, long) except that you can specify a response mode. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future)
The same as
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned. |
Modifier and Type | Interface and Description |
---|---|
interface |
TopologyAwareAddress
Wraps a TopologyUUID JGroups address
|
Modifier and Type | Method and Description |
---|---|
Address |
Transport.getAddress()
Retrieves the current cache instance's network address
|
Address |
Transport.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
Transport.getMembers()
Returns a list of members in the current cluster view.
|
List<Address> |
Transport.getPhysicalAddresses()
Retrieves the current cache instance's physical network addresses.
|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractTransport.checkResponse(Object responseObject,
Address sender) |
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Throwable exception,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter,
boolean ignoreLeavers) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster.
|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Throwable exception,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter,
boolean ignoreLeavers) |
Modifier and Type | Class and Description |
---|---|
class |
JGroupsAddress
An encapsulation of a JGroups Address
|
class |
JGroupsTopologyAwareAddress
An encapsulation of a JGroups Address
|
Modifier and Type | Field and Description |
---|---|
protected Address |
JGroupsTransport.address |
protected Address |
JGroupsTransport.coordinator |
protected Address |
JGroupsTransport.physicalAddress |
Modifier and Type | Field and Description |
---|---|
protected List<Address> |
JGroupsTransport.members |
Modifier and Type | Method and Description |
---|---|
Address |
JGroupsTransport.getAddress() |
Address |
JGroupsTransport.getCoordinator() |
Address |
SuspectException.getSuspect() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
JGroupsTransport.getMembers() |
List<Address> |
JGroupsTransport.getPhysicalAddresses() |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Modifier and Type | Method and Description |
---|---|
protected static Address |
JGroupsTransport.toJGroupsAddress(Address a) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Constructor and Description |
---|
SuspectException(String msg,
Address suspect) |
SuspectException(String msg,
Address suspect,
Throwable cause) |
Modifier and Type | Field and Description |
---|---|
protected Address |
BaseStateTransferTask.self |
Modifier and Type | Field and Description |
---|---|
protected Collection<Address> |
BaseStateTransferTask.members |
Modifier and Type | Method and Description |
---|---|
protected Address |
BaseStateTransferManagerImpl.getAddress() |
Modifier and Type | Method and Description |
---|---|
void |
StateTransferManager.applyLocks(Collection<LockInfo> locks,
Address sender,
int viewId) |
void |
BaseStateTransferManagerImpl.applyLocks(Collection<LockInfo> lockInfo,
Address sender,
int viewId) |
void |
StateTransferManager.applyState(Collection<InternalCacheEntry> state,
Address sender,
int viewId) |
void |
BaseStateTransferManagerImpl.applyState(Collection<InternalCacheEntry> state,
Address sender,
int viewId) |
Modifier and Type | Method and Description |
---|---|
protected ConsistentHash |
ReplicatedStateTransferManagerImpl.createConsistentHash(List<Address> members) |
protected ConsistentHash |
DummyInvalidationStateTransferManagerImpl.createConsistentHash(List<Address> members)
Deprecated.
|
protected ConsistentHash |
DistributedStateTransferManagerImpl.createConsistentHash(List<Address> members) |
protected abstract ConsistentHash |
BaseStateTransferManagerImpl.createConsistentHash(List<Address> members) |
protected ReplicatedStateTransferTask |
ReplicatedStateTransferManagerImpl.createStateTransferTask(int viewId,
List<Address> members,
boolean initialView) |
protected BaseStateTransferTask |
DummyInvalidationStateTransferManagerImpl.createStateTransferTask(int viewId,
List<Address> members,
boolean initialView)
Deprecated.
|
protected BaseStateTransferTask |
DistributedStateTransferManagerImpl.createStateTransferTask(int viewId,
List<Address> members,
boolean initialView) |
protected abstract BaseStateTransferTask |
BaseStateTransferManagerImpl.createStateTransferTask(int viewId,
List<Address> members,
boolean initialView) |
protected void |
BaseStateTransferTask.pushPartialState(Collection<Address> targets,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
void |
BaseStateTransferManagerImpl.pushStateToNode(NotifyingNotifiableFuture<Object> stateTransferFuture,
int viewId,
Collection<Address> targets,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
boolean |
BaseStateTransferManagerImpl.startStateTransfer(int viewId,
Collection<Address> members,
boolean initialView) |
Constructor and Description |
---|
BaseStateTransferTask(BaseStateTransferManagerImpl stateTransferManager,
RpcManager rpcManager,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
Configuration configuration,
DataContainer dataContainer,
Collection<Address> members,
int newViewId,
ConsistentHash chNew,
ConsistentHash chOld,
boolean initialView) |
DistributedStateTransferTask(RpcManager rpcManager,
Configuration configuration,
DataContainer dataContainer,
DistributedStateTransferManagerImpl stateTransferManager,
DistributionManager dm,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
int newViewId,
Collection<Address> members,
ConsistentHash chOld,
ConsistentHash chNew,
boolean initialView,
TransactionTable transactionTable) |
ReplicatedStateTransferTask(RpcManager rpcManager,
Configuration configuration,
DataContainer dataContainer,
ReplicatedStateTransferManagerImpl stateTransferManager,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
int newViewId,
Collection<Address> members,
ConsistentHash chOld,
ConsistentHash chNew,
boolean initialView) |
Modifier and Type | Method and Description |
---|---|
Collection<Address> |
LocalTransaction.getRemoteLocksAcquired() |
Modifier and Type | Method and Description |
---|---|
void |
LocalTransaction.locksAcquired(Collection<Address> nodes) |
protected void |
TransactionTable.updateStateOnNodesLeaving(Collection<Address> leavers) |
Modifier and Type | Field and Description |
---|---|
protected Address |
GlobalTransaction.addr |
Modifier and Type | Method and Description |
---|---|
Address |
GlobalTransaction.getAddress() |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionFactory.newGlobalTransaction(Address addr,
boolean remote) |
abstract GlobalTransaction |
TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr,
boolean remote,
ClusterIdGenerator clusterIdGenerator,
boolean clustered) |
void |
GlobalTransaction.setAddress(Address address) |
Constructor and Description |
---|
DldGlobalTransaction(Address addr,
boolean remote) |
GlobalTransaction(Address addr,
boolean remote) |
Modifier and Type | Method and Description |
---|---|
Set<Address> |
RecoveryManager.InDoubtTxInfo.getOwners()
Returns the set of nodes where this transaction information is maintained.
|
Set<Address> |
InDoubtTxInfoImpl.getOwners() |
Modifier and Type | Method and Description |
---|---|
void |
InDoubtTxInfoImpl.addOwner(Address owner) |
String |
RecoveryManagerImpl.forceTransactionCompletionFromCluster(Xid xid,
Address where,
boolean commit) |
String |
RecoveryManager.forceTransactionCompletionFromCluster(Xid xid,
Address where,
boolean commit)
This method invokes
RecoveryManager.forceTransactionCompletion(javax.transaction.xa.Xid, boolean) on the specified node. |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryAwareRemoteTransaction.computeOrphan(Collection<Address> leavers)
Check's if this transaction's originator is no longer part of the cluster (orphan transaction) and updates
RecoveryAwareRemoteTransaction.isOrphan() . |
void |
RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> where,
long internalId,
boolean sync) |
void |
RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where,
long internalId,
boolean sync)
Same as
#removeRecoveryInformationFromCluster(java.util.Collection but the transaction
is identified by its internal id, and not by its xid. |
void |
RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> lockOwners,
Xid xid,
boolean sync,
GlobalTransaction gtx) |
void |
RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where,
Xid xid,
boolean sync,
GlobalTransaction gtx)
Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information associated with
these Xids.
|
protected void |
RecoveryAwareTransactionTable.updateStateOnNodesLeaving(Collection<Address> leavers)
First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the
transactions that are not yet prepared.
|
Constructor and Description |
---|
RecoveryAwareDldGlobalTransaction(Address addr,
boolean remote) |
RecoveryAwareGlobalTransaction(Address addr,
boolean remote) |
Modifier and Type | Method and Description |
---|---|
protected long |
ClusterIdGenerator.calculateRank(Address address,
List<Address> members,
long viewId) |
Modifier and Type | Method and Description |
---|---|
protected long |
ClusterIdGenerator.calculateRank(Address address,
List<Address> members,
long viewId) |
Modifier and Type | Method and Description |
---|---|
void |
Log.cannotSelectRandomMembers(int numNeeded,
List<Address> members) |
void |
Log.completedLeaveRehash(Address self,
String duration,
List<Address> leavers) |
void |
Log.expectedJustOneResponse(Map<Address,Response> lr) |
void |
Log.keyDoesNotMapToLocalNode(Object key,
Collection<Address> nodes) |
void |
Log.localAndPhysicalAddress(Address address,
List<Address> physicalAddresses) |
void |
Log.participatingInRehash(Address address,
List<Address> stateProviders,
List<Address> receiversOfLeaverState) |
void |
Log.participatingInRehash(Address address,
List<Address> stateProviders,
List<Address> receiversOfLeaverState) |
void |
Log.stateTransferTimeoutWaitingForJoinConfirmations(int viewId,
Map<Address,Integer> joinConfirmations) |
void |
Log.stateTransferTimeoutWaitingForPushConfirmations(int viewId,
Map<Address,Integer> pushConfirmations) |
void |
Log.viewChangeDetected(List<Address> oldMembers,
List<Address> newMembers) |
void |
Log.viewChangeDetected(List<Address> oldMembers,
List<Address> newMembers) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.