org.openspaces.grid.gsm.machines
Class MachinesSlaEnforcementState

java.lang.Object
  org.openspaces.grid.gsm.machines.MachinesSlaEnforcementState

public class MachinesSlaEnforcementState
extends Object

Constructor Summary

MachinesSlaEnforcementState()

Method Summary

void	agentGoingDown(ProcessingUnit pu, String agentUid, long timeout, TimeUnit unit)
void	agentShutdownComplete(String agentUid)
void	allocateCapacity(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
void	completedStateRecovery(ProcessingUnit pu)
void	deallocateAgentCapacity(ProcessingUnit pu, String agentUid)
void	deallocateCapacity(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
void	destroyProcessingUnit(ProcessingUnit pu)
void	futureAgents(ProcessingUnit pu, FutureGridServiceAgent[] futureAgents, CapacityRequirements capacityRequirements)
Collection<String>	getAgentUidsGoingDown(ProcessingUnit pu)
Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures>	getAllDoneFutureAgents(ProcessingUnit pu)
ClusterCapacityRequirements	getAllocatedCapacity(ProcessingUnit pu)
Map<ProcessingUnit,ClusterCapacityRequirements>	getAllocatedCapacityPerProcessingUnit()
List<ProcessingUnit>	getAllProcessingUnitsNotCompletedStateRecovery(Admin admin)
Collection<String>	getAllUsedAgentUids() Lists all grid service agents from all processing units including those that are marked for deallocation.
Collection<String>	getAllUsedAgentUidsForPu(ProcessingUnit pu)
ClusterCapacityRequirements	getAllUsedCapacity() Lists all capacity from all processing units including those that are marked for deallocation.
ClusterCapacityRequirements	getCapacityMarkedForDeallocation(ProcessingUnit pu)
Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures>	getFutureAgents(ProcessingUnit pu)
ElasticProcessingUnitMachineIsolation	getMachineIsolation(ProcessingUnit pu)
int	getNumberOfFutureAgents(ProcessingUnit pu)
String[]	getProcessingUnitsOfFutureMachine(ProcessingUnit pu, FutureGridServiceAgent futureAgent)
Collection<String>	getRestrictedAgentUidsForPu(ProcessingUnit pu)
void	initProcessingUnit(ProcessingUnit pu)
boolean	isAgentSharedWithOtherProcessingUnits(ProcessingUnit pu, String agentUid)
boolean	isAgentUidGoingDownTimedOut(String agentUid)
boolean	isCompletedStateRecovery(ProcessingUnit pu)
boolean	isProcessingUnitDestroyed(ProcessingUnit pu)
void	markAgentCapacityForDeallocation(ProcessingUnit pu, String uid)
void	markCapacityForDeallocation(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
void	removeFutureAgents(ProcessingUnit pu, org.openspaces.grid.gsm.machines.GridServiceAgentFutures futureAgents)
void	setMachineIsolation(ProcessingUnit pu, ElasticProcessingUnitMachineIsolation isolation)
void	slaEnforcementComplete(ProcessingUnit pu)
void	slaEnforcementInProgress(ProcessingUnit pu)
void	unmarkCapacityForDeallocation(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)

Methods inherited from class java.lang.Object

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

Constructor Detail

MachinesSlaEnforcementState

public MachinesSlaEnforcementState()

Method Detail

initProcessingUnit

public void initProcessingUnit(ProcessingUnit pu)

destroyProcessingUnit

public void destroyProcessingUnit(ProcessingUnit pu)

isProcessingUnitDestroyed

public boolean isProcessingUnitDestroyed(ProcessingUnit pu)

futureAgents

public void futureAgents(ProcessingUnit pu,
                         FutureGridServiceAgent[] futureAgents,
                         CapacityRequirements capacityRequirements)

allocateCapacity

public void allocateCapacity(ProcessingUnit pu,
                             String agentUid,
                             CapacityRequirements capacity)

markCapacityForDeallocation

public void markCapacityForDeallocation(ProcessingUnit pu,
                                        String agentUid,
                                        CapacityRequirements capacity)

unmarkCapacityForDeallocation

public void unmarkCapacityForDeallocation(ProcessingUnit pu,
                                          String agentUid,
                                          CapacityRequirements capacity)

deallocateCapacity

public void deallocateCapacity(ProcessingUnit pu,
                               String agentUid,
                               CapacityRequirements capacity)

getCapacityMarkedForDeallocation

public ClusterCapacityRequirements getCapacityMarkedForDeallocation(ProcessingUnit pu)

getAllocatedCapacity

public ClusterCapacityRequirements getAllocatedCapacity(ProcessingUnit pu)

getNumberOfFutureAgents

public int getNumberOfFutureAgents(ProcessingUnit pu)

getFutureAgents

public Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getFutureAgents(ProcessingUnit pu)

getAllDoneFutureAgents

public Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getAllDoneFutureAgents(ProcessingUnit pu)

getAllUsedAgentUids

public Collection<String> getAllUsedAgentUids()

Lists all grid service agents from all processing units including those that are marked for deallocation.

getAllUsedCapacity

public ClusterCapacityRequirements getAllUsedCapacity()

Lists all capacity from all processing units including those that are marked for deallocation.

isAgentSharedWithOtherProcessingUnits

public boolean isAgentSharedWithOtherProcessingUnits(ProcessingUnit pu,
                                                     String agentUid)

Returns:

true if processing units other than the specified PU, also use the specified agent. false otherwise.

agentGoingDown

public void agentGoingDown(ProcessingUnit pu,
                           String agentUid,
                           long timeout,
                           TimeUnit unit)

agentShutdownComplete

public void agentShutdownComplete(String agentUid)

getAgentUidsGoingDown

public Collection<String> getAgentUidsGoingDown(ProcessingUnit pu)

isAgentUidGoingDownTimedOut

public boolean isAgentUidGoingDownTimedOut(String agentUid)

markAgentCapacityForDeallocation

public void markAgentCapacityForDeallocation(ProcessingUnit pu,
                                             String uid)

deallocateAgentCapacity

public void deallocateAgentCapacity(ProcessingUnit pu,
                                    String agentUid)

getRestrictedAgentUidsForPu

public Collection<String> getRestrictedAgentUidsForPu(ProcessingUnit pu)

Returns:

all Grid Service Agent UIDs that the specified PU cannot be deploy on due to machine isolation restrictions or due to the fact that the machine is about to be deployed by another PU that started it.

getProcessingUnitsOfFutureMachine

public String[] getProcessingUnitsOfFutureMachine(ProcessingUnit pu,
                                                  FutureGridServiceAgent futureAgent)

Returns:

all processing units that have a share of the specified future machine not implemented yet. See GS-9484

slaEnforcementComplete

public void slaEnforcementComplete(ProcessingUnit pu)

slaEnforcementInProgress

public void slaEnforcementInProgress(ProcessingUnit pu)

removeFutureAgents

public void removeFutureAgents(ProcessingUnit pu,
                               org.openspaces.grid.gsm.machines.GridServiceAgentFutures futureAgents)

getAllUsedAgentUidsForPu

public Collection<String> getAllUsedAgentUidsForPu(ProcessingUnit pu)

setMachineIsolation

public void setMachineIsolation(ProcessingUnit pu,
                                ElasticProcessingUnitMachineIsolation isolation)

getMachineIsolation

public ElasticProcessingUnitMachineIsolation getMachineIsolation(ProcessingUnit pu)

isCompletedStateRecovery

public boolean isCompletedStateRecovery(ProcessingUnit pu)

completedStateRecovery

public void completedStateRecovery(ProcessingUnit pu)

getAllProcessingUnitsNotCompletedStateRecovery

public List<ProcessingUnit> getAllProcessingUnitsNotCompletedStateRecovery(Admin admin)

getAllocatedCapacityPerProcessingUnit

public Map<ProcessingUnit,ClusterCapacityRequirements> getAllocatedCapacityPerProcessingUnit()