org.apache.ignite.internal.processors.cache

Class ExchangeActions

java.lang.Object

org.apache.ignite.internal.processors.cache.ExchangeActions

public class ExchangeActions
extends Object

Cache change requests to execute when receive DynamicCacheChangeBatch event.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExchangeActions.CacheActionData

Constructor Summary

Constructors

Constructor and Description
ExchangeActions()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	activate()
void	addCacheGroupToStop(CacheGroupDescriptor grpDesc, boolean destroy)
void	addCacheToStop(DynamicCacheChangeRequest req, DynamicCacheDescriptor desc)
boolean	cacheGroupStarting(int grpId)
boolean	cacheGroupStopping(int grpId)
List<org.apache.ignite.internal.processors.cache.ExchangeActions.CacheGroupActionData>	cacheGroupsToStart()
List<org.apache.ignite.internal.processors.cache.ExchangeActions.CacheGroupActionData>	cacheGroupsToStop()
boolean	cacheStarted(int cacheId)
Collection<ExchangeActions.CacheActionData>	cacheStartRequests()
boolean	cacheStopped(int cacheId)
Set<String>	cachesToResetLostPartitions()
boolean	clientOnlyExchange()
void	completeRequestFutures(GridCacheSharedContext ctx)
boolean	deactivate()
boolean	empty()
boolean	hasStop()
StateChangeRequest	stateChangeRequest()
void	stateChangeRequest(StateChangeRequest stateChange)
boolean	systemCachesStarting()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ExchangeActions

public ExchangeActions()

Method Detail

clientOnlyExchange

public boolean clientOnlyExchange()

Returns:

True if server nodes should not participate in exchange.

cacheStartRequests

public Collection<ExchangeActions.CacheActionData> cacheStartRequests()

Returns:

New caches start requests.

completeRequestFutures

public void completeRequestFutures(GridCacheSharedContext ctx)

Parameters:

ctx - Context.

systemCachesStarting

public boolean systemCachesStarting()

Returns:

True if starting system caches.

hasStop

public boolean hasStop()

Returns:

True if have cache stop requests.

cachesToResetLostPartitions

public Set<String> cachesToResetLostPartitions()

Returns:

Caches to reset lost partitions for.

cacheStopped

public boolean cacheStopped(int cacheId)

Parameters:

cacheId - Cache ID.

Returns:

True if cache stop was requested.

cacheStarted

public boolean cacheStarted(int cacheId)

Parameters:

cacheId - Cache ID.

Returns:

True if cache start was requested.

stateChangeRequest

public void stateChangeRequest(StateChangeRequest stateChange)

Parameters:

stateChange - Cluster state change request.

deactivate

public boolean deactivate()

Returns:

True if has deactivate request.

activate

public boolean activate()

Returns:

True if has activate request.

stateChangeRequest

@Nullable
public StateChangeRequest stateChangeRequest()

Returns:

Cluster state change request.

addCacheToStop

public void addCacheToStop(DynamicCacheChangeRequest req,
                  DynamicCacheDescriptor desc)

Parameters:

req - Request.

desc - Cache descriptor.

cacheGroupsToStart

public List<org.apache.ignite.internal.processors.cache.ExchangeActions.CacheGroupActionData> cacheGroupsToStart()

Returns:

Cache groups to start.

cacheGroupStarting

public boolean cacheGroupStarting(int grpId)

Parameters:

grpId - Group ID.

Returns:

True if given cache group starting.

addCacheGroupToStop

public void addCacheGroupToStop(CacheGroupDescriptor grpDesc,
                       boolean destroy)

Parameters:

grpDesc - Group descriptor.

destroy - Destroy flag.

cacheGroupsToStop

public List<org.apache.ignite.internal.processors.cache.ExchangeActions.CacheGroupActionData> cacheGroupsToStop()

Returns:

Cache groups to start.

cacheGroupStopping

public boolean cacheGroupStopping(int grpId)

Parameters:

grpId - Group ID.

Returns:

True if given cache group stopping.

empty

public boolean empty()

Returns:

True if there are no cache change actions.

toString

public String toString()

Overrides:

toString in class Object