Class ExchangeActions
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.ExchangeActions
-
public class ExchangeActions extends Object
Cache change requests to execute when receiveDynamicCacheChangeBatchevent.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classExchangeActions.CacheActionDatastatic classExchangeActions.CacheGroupActionData
-
Constructor Summary
Constructors Constructor Description ExchangeActions()
-
Method Summary
-
-
-
Method Detail
-
clientOnlyExchange
public boolean clientOnlyExchange()
- Returns:
Trueif server nodes should not participate in exchange.
-
cacheStartRequests
public Collection<ExchangeActions.CacheActionData> cacheStartRequests()
- Returns:
- New caches start requests.
-
cacheStopRequests
public Collection<ExchangeActions.CacheActionData> cacheStopRequests()
- Returns:
- Stop cache requests.
-
completeRequestFutures
public void completeRequestFutures(GridCacheSharedContext ctx, Throwable err)
- Parameters:
ctx- Context.err- Error if any.
-
systemCachesStarting
public boolean systemCachesStarting()
- Returns:
Trueif starting system caches.
-
hasStop
public boolean hasStop()
- Returns:
Trueif have cache stop requests.
-
cachesToResetLostPartitions
public Set<String> cachesToResetLostPartitions()
- Returns:
- Caches to reset lost partitions for.
-
finalizePartitionCounters
public boolean finalizePartitionCounters()
- Returns:
- Partitons update counters finalization required.
-
cacheStopped
public boolean cacheStopped(int cacheId)
- Parameters:
cacheId- Cache ID.- Returns:
Trueif cache stop was requested.
-
cacheStarted
public boolean cacheStarted(int cacheId)
- Parameters:
cacheId- Cache ID.- Returns:
Trueif cache start was requested.
-
stateChangeRequest
public void stateChangeRequest(StateChangeRequest stateChange)
- Parameters:
stateChange- Cluster state change request.
-
deactivate
public boolean deactivate()
- Returns:
Trueif has deactivate request.
-
activate
public boolean activate()
- Returns:
Trueif has activate request.
-
changedClusterState
public boolean changedClusterState()
- Returns:
Trueif cluster state was changed.
-
changedBaseline
public boolean changedBaseline()
- Returns:
Trueif has baseline topology change request.
-
stateChangeRequest
@Nullable public @Nullable StateChangeRequest stateChangeRequest()
- Returns:
- Cluster state change request.
-
addCacheToStop
public void addCacheToStop(DynamicCacheChangeRequest req, DynamicCacheDescriptor desc)
- Parameters:
req- Request.desc- Cache descriptor.
-
cacheGroupsToStart
public List<ExchangeActions.CacheGroupActionData> cacheGroupsToStart()
- Returns:
- Cache groups to start.
-
cacheGroupStarting
public boolean cacheGroupStarting(int grpId)
- Parameters:
grpId- Group ID.- Returns:
Trueif given cache group starting.
-
cacheStartRequiredAliveNodes
public Collection<UUID> cacheStartRequiredAliveNodes()
- Returns:
- Server nodes on which a successful start of the cache(s) is required, if any of these nodes fails when starting the cache(s), the whole procedure is rolled back.
-
cacheStartRequiredAliveNodes
public void cacheStartRequiredAliveNodes(Collection<UUID> cacheStartRequiredAliveNodes)
- Parameters:
cacheStartRequiredAliveNodes- Server nodes on which a successful start of the cache(s) is required, if any of these nodes fails when starting the cache(s), the whole procedure is rolled back.
-
addCacheGroupToStop
public void addCacheGroupToStop(CacheGroupDescriptor grpDesc, boolean destroy)
- Parameters:
grpDesc- Group descriptor.destroy- Destroy flag.
-
cacheGroupsToStop
public List<ExchangeActions.CacheGroupActionData> cacheGroupsToStop()
- Returns:
- Cache groups to start.
-
cacheGroupStopping
public boolean cacheGroupStopping(int grpId)
- Parameters:
grpId- Group ID.- Returns:
Trueif given cache group stopping.
-
empty
public boolean empty()
- Returns:
Trueif there are no cache change actions.
-
localJoinContext
public void localJoinContext(LocalJoinCachesContext locJoinCtx)
- Parameters:
locJoinCtx- Caches local join context.
-
localJoinContext
public LocalJoinCachesContext localJoinContext()
- Returns:
- Caches local join context.
-
-