Class ExchangeActions

    • Constructor Detail

      • ExchangeActions

        public ExchangeActions()
    • Method Detail

      • clientOnlyExchange

        public boolean clientOnlyExchange()
        Returns:
        True if server nodes should not participate in exchange.
      • completeRequestFutures

        public void completeRequestFutures​(GridCacheSharedContext ctx,
                                           Throwable err)
        Parameters:
        ctx - Context.
        err - Error if any.
      • 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.
      • finalizePartitionCounters

        public boolean finalizePartitionCounters()
        Returns:
        Partitons update counters finalization required.
      • 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.
      • changedClusterState

        public boolean changedClusterState()
        Returns:
        True if cluster state was changed.
      • changedBaseline

        public boolean changedBaseline()
        Returns:
        True if has baseline topology change request.
      • stateChangeRequest

        @Nullable
        public @Nullable StateChangeRequest stateChangeRequest()
        Returns:
        Cluster state change request.
      • cacheGroupStarting

        public boolean cacheGroupStarting​(int grpId)
        Parameters:
        grpId - Group ID.
        Returns:
        True if 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.
      • 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.
      • localJoinContext

        public void localJoinContext​(LocalJoinCachesContext locJoinCtx)
        Parameters:
        locJoinCtx - Caches local join context.