org.openspaces.grid.gsm.rebalancing

Class RebalancingUtils

java.lang.Object

org.openspaces.grid.gsm.rebalancing.RebalancingUtils

public class RebalancingUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
RebalancingUtils()

Method Summary

Modifier and Type	Method and Description
static Fraction	getAverageCpuCoresPerPrimary(ProcessingUnit pu, CapacityRequirementsPerAgent aggregatedAllocatedCapacity)
static GridServiceContainer[]	getContainersOnMachines(ProcessingUnit pu)
static Machine[]	getMachinesHostingContainers(GridServiceContainer[] containers)
static Fraction	getNumberOfCpuCores(Machine machine, CapacityRequirementsPerAgent allocatedCapacity)
static int	getNumberOfPrimaryInstancesOnMachine(ProcessingUnit pu, Machine machine)
static Fraction	getNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu, Machine machine, CapacityRequirementsPerAgent allocatedCapacity)
static Set<ProcessingUnitInstance>	getOtherInstancesFromSamePartition(ProcessingUnitInstance instance)
static Set<ProcessingUnitInstance>	getOtherInstancesFromSamePartitionInContainer(GridServiceContainer container, ProcessingUnitInstance instance)
static Set<ProcessingUnitInstance>	getOtherInstancesFromSamePartitionInMachine(Machine machine, ProcessingUnitInstance puInstance)
static int	getPlannedMaximumNumberOfInstancesForContainer(GridServiceContainer container, GridServiceContainer[] approvedContainers, ProcessingUnit pu)
static int	getPlannedMinimumNumberOfInstancesForContainer(GridServiceContainer container, GridServiceContainer[] approvedContainers, ProcessingUnit pu)
static GridServiceContainer[]	getReplicationSourceContainers(ProcessingUnitInstance instance)
static String	gscsToString(List<GridServiceContainer> containers)
static String	gscToString(GridComponent container)
static boolean	isEvenlyDistributedAcrossContainers(ProcessingUnit pu, GridServiceContainer[] containers)
static boolean	isEvenlyDistributedAcrossMachines(ProcessingUnit pu, CapacityRequirementsPerAgent aggregatedAllocatedCapacity)
static boolean	isProcessingUnitHasMinimumNumberOfInstancesPerPartition(ProcessingUnit pu, int minimumNumberOfInstancesPerPartition)
static boolean	isProcessingUnitIntact(ProcessingUnit pu)
static boolean	isProcessingUnitIntact(ProcessingUnit pu, GridServiceContainer[] containers)
static boolean	isProcessingUnitPartitionIntact(ProcessingUnitInstance instance)
static boolean	isProcessingUnitPartitionIntact(ProcessingUnit pu, int instanceId, GridServiceContainer[] containers)
static boolean	isRestartRecommended(ProcessingUnit pu, Machine source, Machine target, Fraction optimalCpuCoresPerPrimary, CapacityRequirementsPerAgent allocatedCapacity)
static String	machineToString(Machine machine)
static String	processingUnitDeploymentToString(ProcessingUnit pu)
static String	puInstancesToString(Collection<ProcessingUnitInstance> instances)
static String	puInstanceToString(ProcessingUnitInstance instance)
static FutureStatefulProcessingUnitInstance	restartProcessingUnitInstanceAsync(ProcessingUnitInstance candidateInstance, org.apache.commons.logging.Log logger, long timeout, TimeUnit timeUnit)
static List<GridServiceContainer>	sortAllContainersByNumberOfInstancesAboveMinimum(ProcessingUnit pu, GridServiceContainer[] approvedContainers) Sorts all of the admin containers based on (number of instances from the specified pu - min number of instances) If the container is not in the specified approved container list then min=0, meaning it will get a higher weight in the sort.
static List<Machine>	sortMachinesByNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu, Machine[] machines, CapacityRequirementsPerAgent allocatedCapacity)

Methods inherited from class java.lang.Object

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

Constructor Detail

RebalancingUtils

public RebalancingUtils()

Method Detail

puInstancesToString

public static String puInstancesToString(Collection<ProcessingUnitInstance> instances)

getReplicationSourceContainers

public static GridServiceContainer[] getReplicationSourceContainers(ProcessingUnitInstance instance)

Returns:

list of containers that are used by the relocated processing unit instance to synchronize all data.

isProcessingUnitIntact

public static boolean isProcessingUnitIntact(ProcessingUnit pu,
                                             GridServiceContainer[] containers)

isProcessingUnitHasMinimumNumberOfInstancesPerPartition

public static boolean isProcessingUnitHasMinimumNumberOfInstancesPerPartition(ProcessingUnit pu,
                                                                              int minimumNumberOfInstancesPerPartition)

isProcessingUnitPartitionIntact

public static boolean isProcessingUnitPartitionIntact(ProcessingUnitInstance instance)

isProcessingUnitIntact

public static boolean isProcessingUnitIntact(ProcessingUnit pu)

isProcessingUnitPartitionIntact

public static boolean isProcessingUnitPartitionIntact(ProcessingUnit pu,
                                                      int instanceId,
                                                      GridServiceContainer[] containers)

getOtherInstancesFromSamePartition

public static Set<ProcessingUnitInstance> getOtherInstancesFromSamePartition(ProcessingUnitInstance instance)

Returns:

all instances from the same partition that is not the specified instance.

getOtherInstancesFromSamePartitionInContainer

public static Set<ProcessingUnitInstance> getOtherInstancesFromSamePartitionInContainer(GridServiceContainer container,
                                                                                        ProcessingUnitInstance instance)

getOtherInstancesFromSamePartitionInMachine

public static Set<ProcessingUnitInstance> getOtherInstancesFromSamePartitionInMachine(Machine machine,
                                                                                      ProcessingUnitInstance puInstance)

isEvenlyDistributedAcrossMachines

public static boolean isEvenlyDistributedAcrossMachines(ProcessingUnit pu,
                                                        CapacityRequirementsPerAgent aggregatedAllocatedCapacity)

isRestartRecommended

public static boolean isRestartRecommended(ProcessingUnit pu,
                                           Machine source,
                                           Machine target,
                                           Fraction optimalCpuCoresPerPrimary,
                                           CapacityRequirementsPerAgent allocatedCapacity)

getContainersOnMachines

public static GridServiceContainer[] getContainersOnMachines(ProcessingUnit pu)

Returns:

all containers that the gsm can deploy the specified pu.

isEvenlyDistributedAcrossContainers

public static boolean isEvenlyDistributedAcrossContainers(ProcessingUnit pu,
                                                          GridServiceContainer[] containers)

Returns:

true if number of instances are evenly distributed across the specified containers

getMachinesHostingContainers

public static Machine[] getMachinesHostingContainers(GridServiceContainer[] containers)

getPlannedMinimumNumberOfInstancesForContainer

public static int getPlannedMinimumNumberOfInstancesForContainer(GridServiceContainer container,
                                                                 GridServiceContainer[] approvedContainers,
                                                                 ProcessingUnit pu)

Parameters:

container - - the container for which planned min number of instances is requested

approvedContainers - - the containers approved for deployment for the specified pu

pu - - the processing unit

Returns:

the planned minimum number of instances for the specified container

getPlannedMaximumNumberOfInstancesForContainer

public static int getPlannedMaximumNumberOfInstancesForContainer(GridServiceContainer container,
                                                                 GridServiceContainer[] approvedContainers,
                                                                 ProcessingUnit pu)

Parameters:

container - - the container for which planned min number of instances is requested

approvedContainers - - the containers approved for deployment for the specified pu

pu - - the processing unit

Returns:

the planned minimum number of instances for the specified container

sortAllContainersByNumberOfInstancesAboveMinimum

public static List<GridServiceContainer> sortAllContainersByNumberOfInstancesAboveMinimum(ProcessingUnit pu,
                                                                                          GridServiceContainer[] approvedContainers)

Sorts all of the admin containers based on (number of instances from the specified pu - min number of instances) If the container is not in the specified approved container list then min=0, meaning it will get a higher weight in the sort.

Returns:

the list of sorted containers

See Also:

getPlannedMinimumNumberOfInstancesForContainer(GridServiceContainer, GridServiceContainer[], ProcessingUnit)

sortMachinesByNumberOfPrimaryInstancesPerCpuCore

public static List<Machine> sortMachinesByNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu,
                                                                             Machine[] machines,
                                                                             CapacityRequirementsPerAgent allocatedCapacity)

getNumberOfPrimaryInstancesPerCpuCore

public static Fraction getNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu,
                                                             Machine machine,
                                                             CapacityRequirementsPerAgent allocatedCapacity)

getNumberOfPrimaryInstancesOnMachine

public static int getNumberOfPrimaryInstancesOnMachine(ProcessingUnit pu,
                                                       Machine machine)

restartProcessingUnitInstanceAsync

public static FutureStatefulProcessingUnitInstance restartProcessingUnitInstanceAsync(ProcessingUnitInstance candidateInstance,
                                                                                      org.apache.commons.logging.Log logger,
                                                                                      long timeout,
                                                                                      TimeUnit timeUnit)

getAverageCpuCoresPerPrimary

public static Fraction getAverageCpuCoresPerPrimary(ProcessingUnit pu,
                                                    CapacityRequirementsPerAgent aggregatedAllocatedCapacity)

getNumberOfCpuCores

public static Fraction getNumberOfCpuCores(Machine machine,
                                           CapacityRequirementsPerAgent allocatedCapacity)

puInstanceToString

public static String puInstanceToString(ProcessingUnitInstance instance)

machineToString

public static String machineToString(Machine machine)

gscToString

public static String gscToString(GridComponent container)

gscsToString

public static String gscsToString(List<GridServiceContainer> containers)

processingUnitDeploymentToString

public static String processingUnitDeploymentToString(ProcessingUnit pu)