Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
CacheNotifierImpl.notifyTopologyChanged(CacheTopology oldTopology,
CacheTopology newTopology,
int newTopologyId,
boolean pre) |
void |
CacheNotifier.notifyTopologyChanged(CacheTopology oldTopology,
CacheTopology newTopology,
int newTopologyId,
boolean pre) |
Modifier and Type | Method and Description |
---|---|
CacheTopology |
AvailabilityStrategyContext.getCurrentTopology() |
CacheTopology |
PartitionHandlingManager.getLastStableTopology()
Deprecated.
|
CacheTopology |
AvailablePartitionHandlingManager.getLastStableTopology() |
CacheTopology |
PartitionHandlingManagerImpl.getLastStableTopology() |
CacheTopology |
AvailabilityStrategyContext.getStableTopology()
Whenever a new cache topology without a
pendingCH and with at least numOwners owners for each
segment is installed, and the cache is AvailabilityMode.AVAILABLE , the current cache topology is marked
as the stable topology. |
Modifier and Type | Method and Description |
---|---|
protected AvailabilityMode |
PreferConsistencyStrategy.computeAvailabilityAfterMerge(AvailabilityStrategyContext context,
CacheTopology maxStableTopology,
List<Address> newMembers,
AvailabilityMode initialMode) |
void |
PartitionHandlingManager.onTopologyUpdate(CacheTopology cacheTopology)
Notifies the
PartitionHandlingManager that the cache topology was update. |
void |
AvailablePartitionHandlingManager.onTopologyUpdate(CacheTopology cacheTopology) |
void |
PartitionHandlingManagerImpl.onTopologyUpdate(CacheTopology cacheTopology) |
void |
AvailabilityStrategyContext.updateTopologiesAfterMerge(CacheTopology currentTopology,
CacheTopology stableTopology,
AvailabilityMode availabilityMode)
Updates both the stable and the current topologies.
|
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
JavaLog_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
JavaLog_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
CacheTopology |
StateConsumerImpl.getCacheTopology() |
CacheTopology |
StateConsumer.getCacheTopology() |
CacheTopology |
StateTransferManager.getCacheTopology() |
CacheTopology |
StateTransferManagerImpl.getCacheTopology() |
Modifier and Type | Method and Description |
---|---|
void |
StateProviderImpl.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance) |
void |
StateConsumerImpl.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance) |
void |
StateProvider.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
void |
StateConsumer.onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
protected CacheTopology |
ClusterCacheStatus.createInitialCacheTopology() |
CacheTopology |
CacheTopology.Externalizer.doReadObject(ObjectInput unmarshaller) |
CacheTopology |
CacheStatusResponse.getCacheTopology() |
CacheTopology |
LocalTopologyManagerImpl.getCacheTopology(String cacheName) |
CacheTopology |
LocalTopologyManager.getCacheTopology(String cacheName) |
CacheTopology |
ClusterCacheStatus.getCurrentTopology() |
CacheTopology |
LocalTopologyManagerImpl.getStableCacheTopology(String cacheName) |
CacheTopology |
LocalTopologyManager.getStableCacheTopology(String cacheName) |
CacheTopology |
CacheStatusResponse.getStableTopology() |
CacheTopology |
ClusterCacheStatus.getStableTopology() |
CacheTopology |
LocalTopologyManagerImpl.join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm,
PartitionHandlingManager phm) |
CacheTopology |
LocalTopologyManager.join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm,
PartitionHandlingManager phm)
Forwards the join request to the coordinator.
|
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends CacheTopology>> |
CacheTopology.Externalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterTopologyManagerImpl.broadcastRebalanceStart(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
ClusterTopologyManager.broadcastRebalanceStart(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
ClusterTopologyManagerImpl.broadcastStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
ClusterTopologyManager.broadcastStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
ClusterTopologyManagerImpl.broadcastTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
boolean totalOrder,
boolean distributed) |
void |
ClusterTopologyManager.broadcastTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
boolean totalOrder,
boolean distributed) |
protected void |
LocalTopologyManagerImpl.doHandleRebalance(int viewId,
org.infinispan.topology.LocalCacheStatus cacheStatus,
CacheTopology cacheTopology,
String cacheName,
Address sender) |
protected void |
LocalTopologyManagerImpl.doHandleStableTopologyUpdate(String cacheName,
CacheTopology newStableTopology,
int viewId,
Address sender,
org.infinispan.topology.LocalCacheStatus cacheStatus) |
protected boolean |
LocalTopologyManagerImpl.doHandleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender,
org.infinispan.topology.LocalCacheStatus cacheStatus)
Update the cache topology in the LocalCacheStatus and pass it to the CacheTopologyHandler.
|
void |
CacheTopology.Externalizer.doWriteObject(ObjectOutput output,
CacheTopology cacheTopology) |
void |
LocalTopologyManagerImpl.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender) |
void |
LocalTopologyManager.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender)
Performs the state transfer.
|
void |
LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName,
CacheTopology newStableTopology,
Address sender,
int viewId) |
void |
LocalTopologyManager.handleStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
Address sender,
int viewId)
Update the stable cache topology.
|
void |
LocalTopologyManagerImpl.handleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender) |
void |
LocalTopologyManager.handleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender)
Updates the current and/or pending consistent hash, without transferring any state.
|
void |
CacheTopologyHandler.rebalance(CacheTopology cacheTopology)
Invoked when state transfer has to be started.
|
void |
CacheTopologyHandler.updateConsistentHash(CacheTopology cacheTopology)
Invoked when the CH has to be immediately updated because of a leave or when the state transfer has completed
and we have to install a permanent CH (pendingCH == null).
|
void |
ClusterCacheStatus.updateTopologiesAfterMerge(CacheTopology currentTopology,
CacheTopology stableTopology,
AvailabilityMode availabilityMode) |
Constructor and Description |
---|
CacheStatusResponse(CacheJoinInfo cacheJoinInfo,
CacheTopology cacheTopology,
CacheTopology stableTopology,
AvailabilityMode availabilityMode) |
CacheTopologyControlCommand(String cacheName,
CacheTopologyControlCommand.Type type,
Address sender,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String arg0,
CacheTopology arg1) |
Modifier and Type | Method and Description |
---|---|
CacheTopology |
AbstractControlledLocalTopologyManager.getCacheTopology(String cacheName) |
CacheTopology |
AbstractControlledLocalTopologyManager.getStableCacheTopology(String cacheName) |
CacheTopology |
AbstractControlledLocalTopologyManager.join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm,
PartitionHandlingManager phm) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractControlledLocalTopologyManager.beforeHandleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId) |
protected void |
AbstractControlledLocalTopologyManager.beforeHandleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
int viewId) |
void |
AbstractControlledLocalTopologyManager.handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender) |
void |
AbstractControlledLocalTopologyManager.handleStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
Address sender,
int viewId) |
void |
AbstractControlledLocalTopologyManager.handleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.startRebalance(String cacheName,
CacheTopology cacheTopology) |
void |
Log.startRebalance(String cacheName,
CacheTopology cacheTopology) |
Modifier and Type | Method and Description |
---|---|
String |
Messages.unexpectedAvailabilityMode(AvailabilityMode availabilityMode,
CacheTopology cacheTopology) |
String |
Messages_$bundle.unexpectedAvailabilityMode(AvailabilityMode availabilityMode,
CacheTopology cacheTopology) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.