org.ovirt.engine.core.bll

Class RunVmCommandBase<T extends VmOperationParameterBase>

java.lang.Object

org.ovirt.engine.core.dal.dbbroker.auditloghandling.TimeoutBase

org.ovirt.engine.core.dal.dbbroker.auditloghandling.AuditLogableBase

org.ovirt.engine.core.bll.CommandBase<T>

org.ovirt.engine.core.bll.VmCommand<T>

org.ovirt.engine.core.bll.RunVmCommandBase<T>

All Implemented Interfaces:

Serializable, IVdsAsyncCommand, RollbackHandler, TransactionMethod<Object>

Direct Known Subclasses:

MigrateVmCommand, RunVmCommand

public abstract class RunVmCommandBase<T extends VmOperationParameterBase>
extends VmCommand<T>
implements IVdsAsyncCommand

Base class for asincronious running process handling

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected VDS	_destinationVds
protected boolean	_isRerun
protected static HashMap<Guid,Integer>	_vds_pending_vm_count

Fields inherited from class org.ovirt.engine.core.bll.VmCommand

MAX_NETWORK_INTERFACES_SUPPORTED

Fields inherited from class org.ovirt.engine.core.bll.CommandBase

BYTES_IN_GB

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RunVmCommandBase(Guid commandId)
	RunVmCommandBase(T parameters)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	DecreasePendingVms(Guid vdsId)
static void	DoCompressionCheck(VDS vds, VmDynamic vm)
protected void	EndVmCommand()
protected void	FailedToRunVm()
boolean	getAutoStart()
Guid	getAutoStartVdsId()
protected Guid	getCurrentVdsId()
static VdsSelectionAlgorithm	getDefaultSelectionAlgorithm()
protected abstract VDS	getDestinationVds()
protected VdsSelector	getVdsSelector()
static boolean	hasCapacityToRunVM(VDS curVds)
static boolean	hasCpuToRunVM(VDS vds, VM vm) Check if the given host has enough CPU to run the VM, without exceeding the high utilization threshold.
static boolean	hasMemoryToRunVM(VDS curVds, VM vm)
void	Rerun() This function called when vds failed to run vm.
protected void	rerunInternal()
void	RunningSucceded() Asyncronious event, send by vds on running vm success.
protected void	setVdsSelector(VdsSelector value)

Methods inherited from class org.ovirt.engine.core.bll.VmCommand

CheckPCIAndIDELimit, ConcreteCreateTask, EndActionOnDisks, EndSuccessfully, EndWithFailure, executeCommand, ExecuteVmCommand, getBlockSparseInitSizeInGB, getChildActionType, getDescription, getNeededDiskSize, getPermissionCheckSubjects, GetTagsAttachedToObject, handleCustomPropertiesError, HandleHibernatedVm, isVmNameValidLength, lockVmWithCompensationIfNeeded, RemoveVmDynamic, RemoveVmInSpm, RemoveVmInSpm, RemoveVmNetwork, RemoveVmStatic, RemoveVmStatistics, RemoveVmUsers, UpdateVmInSpm, UpdateVmInSpm, validateNumberOfNics

Methods inherited from class org.ovirt.engine.core.bll.CommandBase

acquireLock, addCanDoActionMessage, addCanDoActionMessage, addValidationGroup, canDoAction, CanDoActionOnly, compensate, CreateReturnValue, CreateTask, EndAction, endActionInTransactionScope, ExecuteAction, freeLock, getActionReturnValue, getActionState, getActionType, getBusinessEntitySnapshotDAO, getCommandShouldBeLogged, getCompensationContext, getNow, getObjectLockingId, getParameters, getParametersForTask, getReturnValue, getSucceeded, getTaskIdList, getTransactionScopeOption, getTransactionTimeout, getValidationGroups, IsBackwardsCompatible, isInternalExecution, IsUserAutorizedToRunAction, RevertTasks, Rollback, runInTransaction, runVdsCommand, setActionMessageParameters, setActionReturnValue, setCommandShouldBeLogged, setCompensationContext, setDescription, setInternalExecution, setSucceeded, UpdateTasksWithActionParameters, validateInputs

Methods inherited from class org.ovirt.engine.core.dal.dbbroker.auditloghandling.AuditLogableBase

AddCustomValue, AppendCustomValue, DefaultLog, getAuditLogTypeValue, getCurrentUser, GetCustomValue, getCustomValues, getKey, getSnapshotName, getStorageDomain, getStorageDomainDAO, getStorageDomainId, getStorageDomainName, getStoragePool, getStoragePoolDAO, getStoragePoolId, getStoragePoolName, getUserId, getUserName, getVds, getVdsDAO, getVdsGroup, getVdsGroupDAO, getVdsGroupId, getVdsGroupName, getVdsId, getVdsIdRef, getVdsName, getVm, getVmDAO, getVmId, getVmIdRef, getVmName, getVmStaticDAO, getVmStatisticsDAO, getVmTemplate, getVmTemplateDAO, getVmTemplateId, getVmTemplateIdRef, getVmTemplateName, log, setCurrentUser, setSnapshotName, setStorageDomain, setStorageDomainId, setStoragePool, setStoragePoolId, setUserId, setUserName, setVds, setVdsGroup, setVdsGroupId, setVdsId, setVdsIdRef, setVdsName, setVm, setVmId, setVmName, setVmTemplate, setVmTemplateId, setVmTemplateName

Methods inherited from class org.ovirt.engine.core.dal.dbbroker.auditloghandling.TimeoutBase

getEndTime, getLegal, getTimeoutObjectId, getUseTimout, setEndTime, setTimeoutObjectId, setUseTimout

Methods inherited from class java.lang.Object

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

Field Detail

_vds_pending_vm_count

protected static final HashMap<Guid,Integer> _vds_pending_vm_count

_isRerun

protected boolean _isRerun

_destinationVds

protected VDS _destinationVds

Constructor Detail

RunVmCommandBase

protected RunVmCommandBase(Guid commandId)

RunVmCommandBase

public RunVmCommandBase(T parameters)

Method Detail

getVdsSelector

protected VdsSelector getVdsSelector()

setVdsSelector

protected void setVdsSelector(VdsSelector value)

getDefaultSelectionAlgorithm

public static VdsSelectionAlgorithm getDefaultSelectionAlgorithm()

hasCpuToRunVM

public static boolean hasCpuToRunVM(VDS vds,
                    VM vm)

Check if the given host has enough CPU to run the VM, without exceeding the high utilization threshold.

Parameters:

vds - The host to check.

vm - The VM to check.

Returns:

Does this host has enough CPU (without exceeding the threshold) to run the VM.

hasMemoryToRunVM

public static boolean hasMemoryToRunVM(VDS curVds,
                       VM vm)

hasCapacityToRunVM

public static boolean hasCapacityToRunVM(VDS curVds)

DoCompressionCheck

public static void DoCompressionCheck(VDS vds,
                      VmDynamic vm)

Rerun

public final void Rerun()

This function called when vds failed to run vm. Vm will be run on another vds (if exist) that's why the function should be run at a new thread because of it will lock a new VDSM

Specified by:

Rerun in interface IVdsAsyncCommand

rerunInternal

protected void rerunInternal()

FailedToRunVm

protected void FailedToRunVm()

RunningSucceded

public void RunningSucceded()

Asyncronious event, send by vds on running vm success. Vm decided successfully run when it's status turn to Up. If there are vdss, not succeded to run vm - treat them as suspicious.

Specified by:

RunningSucceded in interface IVdsAsyncCommand

EndVmCommand

protected void EndVmCommand()

Overrides:

EndVmCommand in class VmCommand<T extends VmOperationParameterBase>

getCurrentVdsId

protected Guid getCurrentVdsId()

getAutoStart

public boolean getAutoStart()

Specified by:

getAutoStart in interface IVdsAsyncCommand

getAutoStartVdsId

public Guid getAutoStartVdsId()

Specified by:

getAutoStartVdsId in interface IVdsAsyncCommand

getDestinationVds

protected abstract VDS getDestinationVds()

DecreasePendingVms

protected void DecreasePendingVms(Guid vdsId)