|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.topology.LocalTopologyManagerImpl
public class LocalTopologyManagerImpl
The LocalTopologyManager
implementation.
Constructor Summary | |
---|---|
LocalTopologyManagerImpl()
|
Method Summary | |
---|---|
void |
confirmRebalance(String cacheName,
int topologyId,
Throwable throwable)
Confirm that the local cache cacheName has finished receiving the new data for topology
topologyId . |
CacheTopology |
getCacheTopology(String cacheName)
|
void |
handleConsistentHashUpdate(String cacheName,
CacheTopology cacheTopology,
int viewId)
Updates the current and/or pending consistent hash, without transferring any state. |
void |
handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId)
Performs the state transfer. |
Map<String,Object[]> |
handleStatusRequest(int viewId)
Recovers the current topology information for all running caches and returns it to the coordinator. |
void |
inject(Transport transport,
ExecutorService asyncTransportExecutor,
GlobalComponentRegistry gcr)
|
CacheTopology |
join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm)
Forwards the join request to the coordinator. |
void |
leave(String cacheName)
Forwards the leave request to the coordinator. |
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public LocalTopologyManagerImpl()
Method Detail |
---|
public void inject(Transport transport, ExecutorService asyncTransportExecutor, GlobalComponentRegistry gcr)
public void start()
public void stop()
public CacheTopology join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm) throws Exception
LocalTopologyManager
join
in interface LocalTopologyManager
Exception
public void leave(String cacheName)
LocalTopologyManager
leave
in interface LocalTopologyManager
public void confirmRebalance(String cacheName, int topologyId, Throwable throwable)
LocalTopologyManager
cacheName
has finished receiving the new data for topology
topologyId
.
The coordinator can change during the state transfer, so we make the rebalance RPC async and we send the response as a different command.
confirmRebalance
in interface LocalTopologyManager
throwable
- null
if local rebalance ended because of an error.public Map<String,Object[]> handleStatusRequest(int viewId)
LocalTopologyManager
handleStatusRequest
in interface LocalTopologyManager
public void handleConsistentHashUpdate(String cacheName, CacheTopology cacheTopology, int viewId) throws InterruptedException
LocalTopologyManager
handleConsistentHashUpdate
in interface LocalTopologyManager
InterruptedException
public void handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId) throws InterruptedException
LocalTopologyManager
handleRebalance
in interface LocalTopologyManager
InterruptedException
public CacheTopology getCacheTopology(String cacheName)
getCacheTopology
in interface LocalTopologyManager
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |