mirror of https://github.com/apache/cloudstack.git
remodel storage
This commit is contained in:
Edison Su
parent
5150aff356
commit
d001a5316f
|
|
@ -1,898 +1,77 @@
|
|||
package com.cloud.storage.orchestra;
|
||||
|
||||
import java.net.URISyntaxException;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
import javax.naming.ConfigurationException;
|
||||
|
||||
import org.apache.log4j.Logger;
|
||||
|
||||
import com.cloud.agent.api.Answer;
|
||||
import com.cloud.agent.api.AttachIsoCommand;
|
||||
import com.cloud.agent.api.AttachVolumeAnswer;
|
||||
import com.cloud.agent.api.AttachVolumeCommand;
|
||||
import com.cloud.agent.api.CreateVolumeFromSnapshotAnswer;
|
||||
import com.cloud.agent.api.CreateVolumeFromSnapshotCommand;
|
||||
import com.cloud.agent.api.UpgradeSnapshotCommand;
|
||||
import com.cloud.agent.api.storage.CopyVolumeAnswer;
|
||||
import com.cloud.agent.api.storage.CopyVolumeCommand;
|
||||
import com.cloud.agent.api.storage.CreateAnswer;
|
||||
import com.cloud.agent.api.storage.CreateCommand;
|
||||
import com.cloud.agent.api.storage.DestroyCommand;
|
||||
import com.cloud.agent.api.to.VolumeTO;
|
||||
import com.cloud.api.BaseCmd;
|
||||
import com.cloud.api.commands.AttachVolumeCmd;
|
||||
import com.cloud.api.commands.CancelPrimaryStorageMaintenanceCmd;
|
||||
import com.cloud.api.commands.CopyTemplateCmd;
|
||||
import com.cloud.api.commands.CreateSnapshotPolicyCmd;
|
||||
import com.cloud.api.commands.CreateStoragePoolCmd;
|
||||
import com.cloud.api.commands.CreateVolumeCmd;
|
||||
import com.cloud.api.commands.DeleteIsoCmd;
|
||||
import com.cloud.api.commands.DeletePoolCmd;
|
||||
import com.cloud.api.commands.DeleteSnapshotPoliciesCmd;
|
||||
import com.cloud.api.commands.DeleteTemplateCmd;
|
||||
import com.cloud.api.commands.DeleteVolumeCmd;
|
||||
import com.cloud.api.commands.DetachVolumeCmd;
|
||||
import com.cloud.api.commands.ExtractIsoCmd;
|
||||
import com.cloud.api.commands.ExtractTemplateCmd;
|
||||
import com.cloud.api.commands.ListRecurringSnapshotScheduleCmd;
|
||||
import com.cloud.api.commands.ListSnapshotPoliciesCmd;
|
||||
import com.cloud.api.commands.ListSnapshotsCmd;
|
||||
import com.cloud.api.commands.ListTemplateOrIsoPermissionsCmd;
|
||||
import com.cloud.api.commands.ListVolumesCmd;
|
||||
import com.cloud.api.commands.RegisterIsoCmd;
|
||||
import com.cloud.api.commands.RegisterTemplateCmd;
|
||||
import com.cloud.api.commands.UpdateStoragePoolCmd;
|
||||
import com.cloud.api.commands.UpdateTemplateOrIsoPermissionsCmd;
|
||||
import com.cloud.api.commands.UploadVolumeCmd;
|
||||
import com.cloud.async.AsyncJobExecutor;
|
||||
import com.cloud.async.AsyncJobVO;
|
||||
import com.cloud.async.BaseAsyncJobExecutor;
|
||||
import com.cloud.configuration.Config;
|
||||
import com.cloud.configuration.ConfigurationManager;
|
||||
import com.cloud.configuration.Resource.ResourceType;
|
||||
import com.cloud.configuration.dao.ConfigurationDao;
|
||||
import com.cloud.dc.DataCenterVO;
|
||||
import com.cloud.dc.HostPodVO;
|
||||
import com.cloud.dc.dao.DataCenterDao;
|
||||
import com.cloud.deploy.DeployDestination;
|
||||
import com.cloud.domain.Domain;
|
||||
import com.cloud.event.ActionEvent;
|
||||
import com.cloud.event.EventTypes;
|
||||
import com.cloud.event.UsageEventVO;
|
||||
import com.cloud.event.dao.UsageEventDao;
|
||||
import com.cloud.exception.AgentUnavailableException;
|
||||
import com.cloud.exception.ConcurrentOperationException;
|
||||
import com.cloud.exception.InsufficientCapacityException;
|
||||
import com.cloud.exception.InsufficientStorageCapacityException;
|
||||
import com.cloud.exception.InternalErrorException;
|
||||
import com.cloud.exception.InvalidParameterValueException;
|
||||
import com.cloud.exception.OperationTimedoutException;
|
||||
import com.cloud.exception.PermissionDeniedException;
|
||||
import com.cloud.exception.ResourceAllocationException;
|
||||
import com.cloud.exception.ResourceInUseException;
|
||||
import com.cloud.exception.ResourceUnavailableException;
|
||||
import com.cloud.exception.StorageUnavailableException;
|
||||
import com.cloud.host.HostVO;
|
||||
import com.cloud.hypervisor.Hypervisor;
|
||||
import com.cloud.hypervisor.Hypervisor.HypervisorType;
|
||||
import com.cloud.offering.DiskOffering;
|
||||
import com.cloud.org.Grouping;
|
||||
import com.cloud.resource.ResourceManager;
|
||||
import com.cloud.service.ServiceOfferingVO;
|
||||
import com.cloud.storage.DiskOfferingVO;
|
||||
import com.cloud.storage.SnapshotVO;
|
||||
import com.cloud.storage.StoragePoolVO;
|
||||
import com.cloud.storage.VMTemplateHostVO;
|
||||
import com.cloud.storage.VMTemplateVO;
|
||||
import com.cloud.storage.VolumeHostVO;
|
||||
import com.cloud.storage.VolumeVO;
|
||||
import com.cloud.storage.VMTemplateStorageResourceAssoc.Status;
|
||||
import com.cloud.storage.dao.DiskOfferingDao;
|
||||
import com.cloud.storage.dao.SnapshotDao;
|
||||
import com.cloud.storage.dao.StoragePoolDao;
|
||||
import com.cloud.storage.dao.VMTemplateDao;
|
||||
import com.cloud.storage.dao.VolumeDao;
|
||||
import com.cloud.storage.pool.Storage;
|
||||
import com.cloud.storage.pool.StoragePool;
|
||||
import com.cloud.storage.pool.Storage.ImageFormat;
|
||||
import com.cloud.storage.pool.Storage.StoragePoolType;
|
||||
import com.cloud.storage.pool.Storage.TemplateType;
|
||||
import com.cloud.storage.pool.StoragePoolManager;
|
||||
import com.cloud.storage.snapshot.Snapshot;
|
||||
import com.cloud.storage.snapshot.SnapshotManager;
|
||||
import com.cloud.storage.snapshot.SnapshotPolicy;
|
||||
import com.cloud.storage.snapshot.SnapshotSchedule;
|
||||
import com.cloud.storage.volume.Volume;
|
||||
import com.cloud.storage.volume.VolumeManagerImpl;
|
||||
import com.cloud.storage.volume.Volume.Event;
|
||||
import com.cloud.storage.volume.Volume.Type;
|
||||
import com.cloud.storage.volume.VolumeManager;
|
||||
import com.cloud.template.TemplateManager;
|
||||
import com.cloud.template.VirtualMachineTemplate;
|
||||
import com.cloud.user.Account;
|
||||
import com.cloud.user.AccountManager;
|
||||
import com.cloud.user.ResourceLimitService;
|
||||
import com.cloud.user.UserContext;
|
||||
import com.cloud.user.dao.AccountDao;
|
||||
import com.cloud.uservm.UserVm;
|
||||
import com.cloud.utils.NumbersUtil;
|
||||
import com.cloud.utils.Pair;
|
||||
import com.cloud.utils.component.Inject;
|
||||
import com.cloud.utils.component.Manager;
|
||||
import com.cloud.utils.db.DB;
|
||||
import com.cloud.utils.db.JoinBuilder;
|
||||
import com.cloud.utils.db.SearchBuilder;
|
||||
import com.cloud.utils.db.SearchCriteria;
|
||||
import com.cloud.utils.db.Transaction;
|
||||
import com.cloud.utils.exception.CloudRuntimeException;
|
||||
import com.cloud.utils.fsm.NoTransitionException;
|
||||
import com.cloud.vm.DiskProfile;
|
||||
import com.cloud.vm.UserVmVO;
|
||||
import com.cloud.vm.VMInstanceVO;
|
||||
import com.cloud.vm.VirtualMachine;
|
||||
import com.cloud.vm.VirtualMachineProfile;
|
||||
import com.cloud.vm.VirtualMachine.State;
|
||||
import com.cloud.vm.dao.UserVmDao;
|
||||
import com.cloud.vm.dao.VMInstanceDao;
|
||||
|
||||
public class StorageOrchestraEngineImpl implements StorageOrchestraEngine, Manager {
|
||||
private static final Logger s_logger = Logger.getLogger(StorageOrchestraEngineImpl.class);
|
||||
private int _customDiskOfferingMinSize = 1;
|
||||
private int _customDiskOfferingMaxSize = 1024;
|
||||
private long _maxVolumeSizeInGb;
|
||||
|
||||
@Inject
|
||||
protected VMInstanceDao _vmDao;
|
||||
@Inject
|
||||
protected VolumeDao _volumeDao;
|
||||
@Inject
|
||||
protected AccountDao _accountDao;
|
||||
@Inject
|
||||
protected DiskOfferingDao _diskOfferingDao;
|
||||
@Inject
|
||||
protected DataCenterDao _dcDao;
|
||||
@Inject
|
||||
protected SnapshotDao _snapshotDao;
|
||||
@Inject
|
||||
protected StoragePoolDao _storagePoolDao;
|
||||
@Inject
|
||||
protected UsageEventDao _usageEventDao;
|
||||
@Inject
|
||||
protected UserVmDao _userVmDao;
|
||||
@Inject
|
||||
protected VMTemplateDao _templateDao;
|
||||
@Inject
|
||||
protected ConfigurationDao _configDao;
|
||||
|
||||
@Inject
|
||||
protected StoragePoolManager _storagePoolMgr;
|
||||
@Inject
|
||||
protected SnapshotManager _snapshotMgr;
|
||||
@Inject
|
||||
protected AccountManager _accountMgr;
|
||||
@Inject
|
||||
protected ConfigurationManager _configMgr;
|
||||
@Inject
|
||||
protected ResourceLimitService _resourceLimitMgr;
|
||||
@Inject
|
||||
protected TemplateManager _templateMgr;
|
||||
@Inject
|
||||
protected VolumeManager _volumeMgr;
|
||||
@Inject
|
||||
protected ResourceManager _resourceMgr;
|
||||
|
||||
|
||||
@Override
|
||||
@DB
|
||||
@ActionEvent(eventType = EventTypes.EVENT_VOLUME_CREATE, eventDescription = "creating volume", async = true)
|
||||
public VolumeVO createVolume(CreateVolumeCmd cmd) {
|
||||
VolumeVO volume = _volumeDao.findById(cmd.getEntityId());
|
||||
|
||||
if (cmd.getSnapshotId() != null) {
|
||||
volume = createVolumeFromSnapshot(volume, cmd.getSnapshotId());
|
||||
if (volume == null || volume.getState() != Volume.State.Ready) {
|
||||
s_logger.trace("Decrementing volume resource count for account id=" + volume.getAccountId() + " as volume failed to create on the backend");
|
||||
_resourceLimitMgr.decrementResourceCount(volume.getAccountId(), ResourceType.volume);
|
||||
}
|
||||
}
|
||||
return volume;
|
||||
}
|
||||
|
||||
@DB
|
||||
protected VolumeVO createVolumeFromSnapshot(VolumeVO volume, long snapshotId) {
|
||||
int retry = 0;
|
||||
String volumeUUID = null;
|
||||
|
||||
try {
|
||||
_volumeMgr.processEvent(volume, Volume.Event.CreateRequested);
|
||||
} catch (NoTransitionException e) {
|
||||
s_logger.debug(e.toString());
|
||||
return null;
|
||||
}
|
||||
|
||||
try {
|
||||
String volumeFolder = null;
|
||||
Long volumeId = volume.getId();
|
||||
Account account = _accountDao.findById(volume.getAccountId());
|
||||
final HashSet<StoragePool> poolsToAvoid = new HashSet<StoragePool>();
|
||||
StoragePool pool = null;
|
||||
VolumeVO createdVolume = null;
|
||||
DiskOfferingVO diskOffering = _diskOfferingDao.findByIdIncludingRemoved(volume.getDiskOfferingId());
|
||||
DataCenterVO dc = _dcDao.findById(volume.getDataCenterId());
|
||||
SnapshotVO snapshot = _snapshotDao.findById(snapshotId);
|
||||
DiskProfile dskCh = new DiskProfile(volume, diskOffering, snapshot.getHypervisorType());
|
||||
|
||||
while (retry < 3) {
|
||||
pool = _storagePoolMgr.findStoragePool(dc, dskCh, account, poolsToAvoid);
|
||||
|
||||
volumeFolder = pool.getPath();
|
||||
if (s_logger.isDebugEnabled()) {
|
||||
s_logger.debug("Attempting to create volume from snapshotId: " + snapshot.getId() + " on storage pool " + pool.getName() + " retry: " + retry);
|
||||
}
|
||||
|
||||
try {
|
||||
volumeUUID = _snapshotMgr.createVolumeFromSnapshot(UserContext.current().getCallerUserId(), snapshot, pool);
|
||||
} catch (CloudRuntimeException e) {
|
||||
s_logger.warn("Unable to create volume on pool " + pool.getName() + ", reason: " + e.toString());
|
||||
}
|
||||
|
||||
if (volumeUUID != null) {
|
||||
if (s_logger.isDebugEnabled()) {
|
||||
s_logger.debug("Volume with UUID " + volumeUUID + " was created on storage pool " + pool.getName());
|
||||
}
|
||||
break;
|
||||
}
|
||||
retry++;
|
||||
}
|
||||
|
||||
if (volumeUUID != null) {
|
||||
createdVolume = _volumeDao.findById(volumeId);
|
||||
createdVolume.setPodId(pool.getPodId());
|
||||
createdVolume.setPoolId(pool.getId());
|
||||
createdVolume.setPoolType(pool.getPoolType());
|
||||
createdVolume.setFolder(volumeFolder);
|
||||
createdVolume.setPath(volumeUUID);
|
||||
createdVolume.setDomainId(account.getDomainId());
|
||||
|
||||
_volumeMgr.processEvent(createdVolume, Volume.Event.OperationSucceeded);
|
||||
}
|
||||
return createdVolume;
|
||||
} catch (NoTransitionException e) {
|
||||
s_logger.debug(e.toString());
|
||||
return null;
|
||||
} catch (CloudRuntimeException e) {
|
||||
s_logger.debug(e.toString());
|
||||
return null;
|
||||
} finally {
|
||||
if (volumeUUID == null) {
|
||||
try {
|
||||
_volumeMgr.processEvent(volume, Volume.Event.OperationFailed);
|
||||
} catch (NoTransitionException e) {
|
||||
s_logger.debug(e.toString());
|
||||
}
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private boolean validateVolumeSizeRange(long size) {
|
||||
if (size < 0 || (size > 0 && size < (1024 * 1024 * 1024))) {
|
||||
throw new InvalidParameterValueException("Please specify a size of at least 1 Gb.");
|
||||
} else if (size > (_maxVolumeSizeInGb * 1024 * 1024 * 1024)) {
|
||||
throw new InvalidParameterValueException("volume size " + size + ", but the maximum size allowed is " + _maxVolumeSizeInGb + " Gb.");
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
@DB
|
||||
@ActionEvent(eventType = EventTypes.EVENT_VOLUME_CREATE, eventDescription = "creating volume", create = true)
|
||||
public VolumeVO allocVolume(CreateVolumeCmd cmd) throws ResourceAllocationException {
|
||||
Account caller = UserContext.current().getCaller();
|
||||
|
||||
long ownerId = cmd.getEntityOwnerId();
|
||||
|
||||
_accountMgr.checkAccess(caller, null, true, _accountMgr.getActiveAccountById(ownerId));
|
||||
|
||||
_resourceLimitMgr.checkResourceLimit(_accountMgr.getAccount(ownerId), ResourceType.volume);
|
||||
|
||||
Long zoneId = cmd.getZoneId();
|
||||
Long diskOfferingId = null;
|
||||
Long size = null;
|
||||
|
||||
// validate input parameters before creating the volume
|
||||
if ((cmd.getSnapshotId() == null && cmd.getDiskOfferingId() == null) || (cmd.getSnapshotId() != null && cmd.getDiskOfferingId() != null)) {
|
||||
throw new InvalidParameterValueException("Either disk Offering Id or snapshot Id must be passed whilst creating volume");
|
||||
}
|
||||
|
||||
if (cmd.getSnapshotId() == null) {// create a new volume
|
||||
|
||||
diskOfferingId = cmd.getDiskOfferingId();
|
||||
size = cmd.getSize();
|
||||
Long sizeInGB = size;
|
||||
if (size != null) {
|
||||
if (size > 0) {
|
||||
size = size * 1024 * 1024 * 1024; // user specify size in GB
|
||||
} else {
|
||||
throw new InvalidParameterValueException("Disk size must be larger than 0");
|
||||
}
|
||||
}
|
||||
if (diskOfferingId == null) {
|
||||
throw new InvalidParameterValueException("Missing parameter(s),either a positive volume size or a valid disk offering id must be specified.");
|
||||
}
|
||||
// Check that the the disk offering is specified
|
||||
DiskOfferingVO diskOffering = _diskOfferingDao.findById(diskOfferingId);
|
||||
if ((diskOffering == null) || diskOffering.getRemoved() != null || !DiskOfferingVO.Type.Disk.equals(diskOffering.getType())) {
|
||||
throw new InvalidParameterValueException("Please specify a valid disk offering.");
|
||||
}
|
||||
|
||||
if (diskOffering.isCustomized()) {
|
||||
if (size == null) {
|
||||
throw new InvalidParameterValueException("This disk offering requires a custom size specified");
|
||||
}
|
||||
if ((sizeInGB < _customDiskOfferingMinSize) || (sizeInGB > _customDiskOfferingMaxSize)) {
|
||||
throw new InvalidParameterValueException("Volume size: " + sizeInGB + "GB is out of allowed range. Max: " + _customDiskOfferingMaxSize + " Min:" + _customDiskOfferingMinSize);
|
||||
}
|
||||
}
|
||||
|
||||
if (!diskOffering.isCustomized() && size != null) {
|
||||
throw new InvalidParameterValueException("This disk offering does not allow custom size");
|
||||
}
|
||||
|
||||
if (diskOffering.getDomainId() == null) {
|
||||
// do nothing as offering is public
|
||||
} else {
|
||||
_configMgr.checkDiskOfferingAccess(caller, diskOffering);
|
||||
}
|
||||
|
||||
if (diskOffering.getDiskSize() > 0) {
|
||||
size = diskOffering.getDiskSize();
|
||||
}
|
||||
|
||||
if (!validateVolumeSizeRange(size)) {// convert size from mb to gb for validation
|
||||
throw new InvalidParameterValueException("Invalid size for custom volume creation: " + size + " ,max volume size is:" + _maxVolumeSizeInGb);
|
||||
}
|
||||
} else { // create volume from snapshot
|
||||
Long snapshotId = cmd.getSnapshotId();
|
||||
SnapshotVO snapshotCheck = _snapshotDao.findById(snapshotId);
|
||||
if (snapshotCheck == null) {
|
||||
throw new InvalidParameterValueException("unable to find a snapshot with id " + snapshotId);
|
||||
}
|
||||
|
||||
if (snapshotCheck.getStatus() != Snapshot.Status.BackedUp) {
|
||||
throw new InvalidParameterValueException("Snapshot id=" + snapshotId + " is not in " + Snapshot.Status.BackedUp + " state yet and can't be used for volume creation");
|
||||
}
|
||||
|
||||
diskOfferingId = (cmd.getDiskOfferingId() != null) ? cmd.getDiskOfferingId() : snapshotCheck.getDiskOfferingId();
|
||||
zoneId = snapshotCheck.getDataCenterId();
|
||||
size = snapshotCheck.getSize(); // ; disk offering is used for tags purposes
|
||||
|
||||
// check snapshot permissions
|
||||
_accountMgr.checkAccess(caller, null, true, snapshotCheck);
|
||||
}
|
||||
|
||||
// Verify that zone exists
|
||||
DataCenterVO zone = _dcDao.findById(zoneId);
|
||||
if (zone == null) {
|
||||
throw new InvalidParameterValueException("Unable to find zone by id " + zoneId);
|
||||
}
|
||||
|
||||
// Check if zone is disabled
|
||||
if (Grouping.AllocationState.Disabled == zone.getAllocationState() && !_accountMgr.isRootAdmin(caller.getType())) {
|
||||
throw new PermissionDeniedException("Cannot perform this operation, Zone is currently disabled: " + zoneId);
|
||||
}
|
||||
long domainId = ((caller == null) ? Domain.ROOT_DOMAIN : caller.getDomainId());
|
||||
|
||||
VolumeVO volume = _volumeMgr.allocateDiskVolume(cmd.getVolumeName(), zoneId, ownerId, domainId, diskOfferingId, size);
|
||||
|
||||
if(cmd.getSnapshotId() == null) {
|
||||
//for volume created from snapshot, create usage event after volume creation
|
||||
UsageEventVO usageEvent = new UsageEventVO(EventTypes.EVENT_VOLUME_CREATE, volume.getAccountId(), volume.getDataCenterId(), volume.getId(), volume.getName(), diskOfferingId, null, size);
|
||||
_usageEventDao.persist(usageEvent);
|
||||
}
|
||||
|
||||
UserContext.current().setEventDetails("Volume Id: " + volume.getId());
|
||||
|
||||
_resourceLimitMgr.incrementResourceCount(volume.getAccountId(), ResourceType.volume);
|
||||
return volume;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void allocateVolume(Long vmId,
|
||||
Pair<? extends DiskOffering, Long> rootDiskOffering,
|
||||
List<Pair<DiskOffering, Long>> dataDiskOfferings, Long templateId, Account owner) {
|
||||
_volumeMgr.allocateVolume(vmId, rootDiskOffering, dataDiskOfferings, templateId, owner);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepare(VirtualMachineProfile<? extends VirtualMachine> vm, DeployDestination dest, boolean recreate) throws StorageUnavailableException, InsufficientStorageCapacityException,
|
||||
ConcurrentOperationException {
|
||||
if (dest == null) {
|
||||
throw new CloudRuntimeException("Unable to prepare Volume for vm because DeployDestination is null, vm:" + vm);
|
||||
}
|
||||
|
||||
List<VolumeVO> vols = _volumeDao.findUsableVolumesForInstance(vm.getId());
|
||||
if (s_logger.isDebugEnabled()) {
|
||||
s_logger.debug("Prepare " + vols.size() + " volumes for " + vm);
|
||||
}
|
||||
|
||||
for (VolumeVO vol : vols) {
|
||||
DiskOfferingVO diskOffering = _diskOfferingDao.findById(vol.getDiskOfferingId());
|
||||
StoragePool destPool = dest.getStorageForDisks().get(vol);
|
||||
VolumeVO created = _volumeMgr.createVolume(vol, vm.getTemplateId(), diskOffering, vm.getHypervisorType(), destPool);
|
||||
vm.addDisk(new VolumeTO(created, destPool));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void prepareForMigration(VirtualMachineProfile<? extends VirtualMachine> vm, DeployDestination dest) {
|
||||
List<VolumeVO> vols = _volumeDao.findUsableVolumesForInstance(vm.getId());
|
||||
if (s_logger.isDebugEnabled()) {
|
||||
s_logger.debug("Preparing " + vols.size() + " volumes for " + vm);
|
||||
}
|
||||
|
||||
for (VolumeVO vol : vols) {
|
||||
StoragePool pool = _storagePoolDao.findById(vol.getPoolId());
|
||||
vm.addDisk(new VolumeTO(vol, pool));
|
||||
}
|
||||
|
||||
if (vm.getType() == VirtualMachine.Type.User) {
|
||||
UserVmVO userVM = (UserVmVO) vm.getVirtualMachine();
|
||||
if (userVM.getIsoId() != null) {
|
||||
long isoId = userVM.getIsoId();
|
||||
VMTemplateVO iso = _templateDao.findById(isoId);
|
||||
Map<String, String> isoPathPair = _templateMgr.getAbsoluteIsoPath(iso, userVM.getDataCenterIdToDeployIn());
|
||||
if (!isoPathPair.isEmpty()) {
|
||||
String isoPath = isoPathPair.get("isoPath");
|
||||
VolumeTO isoTO = new VolumeTO(vm.getId(), Volume.Type.ISO, StoragePoolType.ISO, null, null, null, isoPath, 0, null, null);
|
||||
vm.addDisk(isoTO);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean configure(String name, Map<String, Object> params)
|
||||
throws ConfigurationException {
|
||||
String _customDiskOfferingMinSizeStr = _configDao.getValue(Config.CustomDiskOfferingMinSize.toString());
|
||||
_customDiskOfferingMinSize = NumbersUtil.parseInt(_customDiskOfferingMinSizeStr, Integer.parseInt(Config.CustomDiskOfferingMinSize.getDefaultValue()));
|
||||
|
||||
String _customDiskOfferingMaxSizeStr = _configDao.getValue(Config.CustomDiskOfferingMaxSize.toString());
|
||||
_customDiskOfferingMaxSize = NumbersUtil.parseInt(_customDiskOfferingMaxSizeStr, Integer.parseInt(Config.CustomDiskOfferingMaxSize.getDefaultValue()));
|
||||
|
||||
String maxVolumeSizeInGbString = _configDao.getValue("storage.max.volume.size");
|
||||
_maxVolumeSizeInGb = NumbersUtil.parseLong(maxVolumeSizeInGbString, 2000);
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean start() {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean stop() {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getName() {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void release(VirtualMachineProfile<? extends VirtualMachine> profile) {
|
||||
List<VolumeTO> volumes = profile.getDisks();
|
||||
for (VolumeTO volumeT : volumes) {
|
||||
long volumeId = volumeT.getId();
|
||||
VolumeVO volume = _volumeDao.findById(volumeId);
|
||||
_volumeMgr.release(volume);
|
||||
}
|
||||
}
|
||||
package com.cloud.storage.orchestra;
|
||||
import com.cloud.storage.storageCore.DataStore;
|
||||
import com.cloud.storage.storageCore.DataStore.StoreType;
|
||||
import com.cloud.storage.storageCore.Snapshot;
|
||||
import com.cloud.storage.storageCore.StorageCore;
|
||||
import com.cloud.storage.storageCore.Template;
|
||||
import com.cloud.storage.storageCore.Volume;
|
||||
import com.cloud.utils.component.Inject;
|
||||
import com.cloud.utils.exception.CloudRuntimeException;
|
||||
|
||||
|
||||
@Override
|
||||
public boolean vmStorageMigration(VirtualMachineProfile<? extends VirtualMachine> vm, StoragePool destPool) throws ConcurrentOperationException {
|
||||
List<VolumeVO> vols = _volumeDao.findUsableVolumesForInstance(vm.getId());
|
||||
List<Volume> volumesNeedToMigrate = new ArrayList<Volume>();
|
||||
|
||||
for (VolumeVO volume : vols) {
|
||||
if (volume.getState() != Volume.State.Ready) {
|
||||
s_logger.debug("volume: " + volume.getId() + " is in " + volume.getState() + " state");
|
||||
throw new CloudRuntimeException("volume: " + volume.getId() + " is in " + volume.getState() + " state");
|
||||
}
|
||||
|
||||
if (volume.getPoolId() == destPool.getId()) {
|
||||
s_logger.debug("volume: " + volume.getId() + " is on the same storage pool: " + destPool.getId());
|
||||
continue;
|
||||
}
|
||||
|
||||
volumesNeedToMigrate.add(volume);
|
||||
}
|
||||
|
||||
if (volumesNeedToMigrate.isEmpty()) {
|
||||
s_logger.debug("No volume need to be migrated");
|
||||
return true;
|
||||
}
|
||||
|
||||
return _volumeMgr.migrateVolumes(volumesNeedToMigrate, destPool);
|
||||
}
|
||||
|
||||
|
||||
@DB
|
||||
@Override
|
||||
public Volume migrateVolume(Long volumeId, Long storagePoolId) throws ConcurrentOperationException {
|
||||
VolumeVO vol = _volumeDao.findById(volumeId);
|
||||
if (vol == null) {
|
||||
throw new InvalidParameterValueException("Failed to find the volume id: " + volumeId);
|
||||
}
|
||||
|
||||
if (vol.getState() != Volume.State.Ready) {
|
||||
throw new InvalidParameterValueException("Volume must be in ready state");
|
||||
}
|
||||
|
||||
if (vol.getInstanceId() != null) {
|
||||
throw new InvalidParameterValueException("Volume needs to be dettached from VM");
|
||||
}
|
||||
|
||||
StoragePool destPool = _storagePoolMgr.getStoragePool(storagePoolId);
|
||||
if (destPool == null) {
|
||||
throw new InvalidParameterValueException("Faild to find the destination storage pool: " + storagePoolId);
|
||||
}
|
||||
|
||||
List<Volume> vols = new ArrayList<Volume>();
|
||||
vols.add(vol);
|
||||
|
||||
_volumeMgr.migrateVolumes(vols, destPool);
|
||||
return vol;
|
||||
}
|
||||
|
||||
@Override
|
||||
@ActionEvent(eventType = EventTypes.EVENT_VOLUME_ATTACH, eventDescription = "attaching volume", async = true)
|
||||
public Volume attachVolumeToVM(AttachVolumeCmd command) {
|
||||
Account caller = UserContext.current().getCaller();
|
||||
Long vmId = command.getVirtualMachineId();
|
||||
Long volumeId = command.getId();
|
||||
Long deviceId = command.getDeviceId();
|
||||
VolumeVO volume = _volumeDao.findById(volumeId);
|
||||
|
||||
if (volume == null || volume.getVolumeType() != Volume.Type.DATADISK) {
|
||||
throw new InvalidParameterValueException("Please specify a valid data volume.");
|
||||
}
|
||||
|
||||
UserVmVO vm = _userVmDao.findById(vmId);
|
||||
if (vm == null || vm.getType() != VirtualMachine.Type.User) {
|
||||
throw new InvalidParameterValueException("Please specify a valid User VM.");
|
||||
}
|
||||
_accountMgr.checkAccess(caller, null, true, volume, vm);
|
||||
|
||||
try {
|
||||
return _volumeMgr.attachVolumeToVM(volume, vm, deviceId);
|
||||
} catch (StorageUnavailableException e) {
|
||||
s_logger.debug("Failed to attache volume " + volume + ", due to " + e.toString());
|
||||
return null;
|
||||
} catch (AgentUnavailableException e) {
|
||||
s_logger.debug("Failed to attache volume " + volume + ", due to " + e.toString());
|
||||
return null;
|
||||
} catch (ConcurrentOperationException e) {
|
||||
s_logger.debug("Failed to attache volume " + volume + ", due to " + e.toString());
|
||||
return null;
|
||||
} catch (OperationTimedoutException e) {
|
||||
s_logger.debug("Failed to attache volume " + volume + ", due to " + e.toString());
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
@ActionEvent(eventType = EventTypes.EVENT_ISO_ATTACH, eventDescription = "attaching ISO", async = true)
|
||||
public boolean attachIsoToVm(long isoId, long vmId) {
|
||||
Account caller = UserContext.current().getCaller();
|
||||
|
||||
UserVmVO vm = _userVmDao.findById(vmId);
|
||||
if (vm == null) {
|
||||
throw new InvalidParameterValueException("Unable to find a virtual machine with id " + vmId);
|
||||
}
|
||||
|
||||
VMTemplateVO iso = _templateDao.findById(isoId);
|
||||
if (iso == null || iso.getRemoved() != null) {
|
||||
throw new InvalidParameterValueException("Unable to find an ISO with id " + isoId);
|
||||
}
|
||||
|
||||
_accountMgr.checkAccess(caller, null, false, iso, vm);
|
||||
|
||||
Account vmOwner = _accountDao.findById(vm.getAccountId());
|
||||
_accountMgr.checkAccess(vmOwner, null, false, iso, vm);
|
||||
|
||||
_volumeMgr.attachISOToVm(vm, iso);
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
@ActionEvent(eventType = EventTypes.EVENT_ISO_DETACH, eventDescription = "detaching ISO", async = true)
|
||||
public boolean detachIsoToVm(long vmId) {
|
||||
Account caller = UserContext.current().getCaller();
|
||||
Long userId = UserContext.current().getCallerUserId();
|
||||
|
||||
UserVmVO vm = _userVmDao.findById(vmId);
|
||||
if (vm == null) {
|
||||
throw new InvalidParameterValueException ("Unable to find a virtual machine with id " + vmId);
|
||||
}
|
||||
|
||||
Long isoId = vm.getIsoId();
|
||||
if (isoId == null) {
|
||||
throw new InvalidParameterValueException("The specified VM has no ISO attached to it.");
|
||||
}
|
||||
|
||||
_accountMgr.checkAccess(caller, null, true, vm);
|
||||
UserContext.current().setEventDetails("Vm Id: " + vmId + " ISO Id: " + isoId);
|
||||
|
||||
_volumeMgr.detachISOToVM(vm);
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
@ActionEvent(eventType = EventTypes.EVENT_VOLUME_DETACH, eventDescription = "detaching volume", async = true)
|
||||
public Volume detachVolumeFromVM(DetachVolumeCmd cmd) {
|
||||
Account caller = UserContext.current().getCaller();
|
||||
if ((cmd.getId() == null && cmd.getDeviceId() == null && cmd.getVirtualMachineId() == null) || (cmd.getId() != null && (cmd.getDeviceId() != null || cmd.getVirtualMachineId() != null))
|
||||
|| (cmd.getId() == null && (cmd.getDeviceId() == null || cmd.getVirtualMachineId() == null))) {
|
||||
throw new InvalidParameterValueException("Please provide either a volume id, or a tuple(device id, instance id)");
|
||||
}
|
||||
|
||||
Long volumeId = cmd.getId();
|
||||
VolumeVO volume = null;
|
||||
|
||||
if (volumeId != null) {
|
||||
volume = _volumeDao.findById(volumeId);
|
||||
} else {
|
||||
volume = _volumeDao.findByInstanceAndDeviceId(cmd.getVirtualMachineId(), cmd.getDeviceId()).get(0);
|
||||
}
|
||||
|
||||
if (volume == null) {
|
||||
throw new InvalidParameterValueException("Unable to find volume with ID: " + volumeId);
|
||||
}
|
||||
|
||||
_accountMgr.checkAccess(caller, null, true, volume);
|
||||
|
||||
Long vmId = null;
|
||||
if (cmd.getVirtualMachineId() == null) {
|
||||
vmId = volume.getInstanceId();
|
||||
} else {
|
||||
vmId = cmd.getVirtualMachineId();
|
||||
}
|
||||
|
||||
UserVmVO vm = _userVmDao.findById(vmId);
|
||||
|
||||
return _volumeMgr.detachVolumeFromVM(volume, vm);
|
||||
}
|
||||
|
||||
@Override
|
||||
@DB
|
||||
@ActionEvent(eventType = EventTypes.EVENT_VOLUME_DELETE, eventDescription = "deleting volume")
|
||||
public boolean deleteVolume(DeleteVolumeCmd cmd) {
|
||||
Long volumeId = cmd.getId();
|
||||
Account caller = UserContext.current().getCaller();
|
||||
VolumeVO volume = _volumeDao.findById(volumeId);
|
||||
if (volume == null) {
|
||||
throw new InvalidParameterValueException("Unable to find volume with ID: " + volumeId);
|
||||
}
|
||||
|
||||
_accountMgr.checkAccess(caller, null, true, volume);
|
||||
try {
|
||||
return _volumeMgr.deleteVolume(volume);
|
||||
} catch (ConcurrentOperationException e) {
|
||||
s_logger.debug("Failed to delete volume " + volume + ", due to " + e.toString());
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public StoragePool createPool(CreateStoragePoolCmd cmd) throws ResourceInUseException, IllegalArgumentException, UnknownHostException, ResourceUnavailableException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deletePool(DeletePoolCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public StoragePool prepareStorageForMaintenance(Long primaryStorageId) throws ResourceUnavailableException, InsufficientCapacityException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public StoragePool cancelStorageForMaintenance(CancelPrimaryStorageMaintenanceCmd cmd) throws ResourceUnavailableException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public StoragePool updateStoragePool(UpdateStoragePoolCmd cmd) throws IllegalArgumentException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public StoragePool getStoragePool(long id) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteVolume(long volumeId) throws ConcurrentOperationException {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume copyVolume(Long volumeId, Long destStoragePoolId) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<? extends Volume> searchForVolumes(ListVolumesCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<? extends Snapshot> listSnapshots(ListSnapshotsCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteSnapshot(long snapshotId) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public SnapshotPolicy createPolicy(CreateSnapshotPolicyCmd cmd, Account policyOwner) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<? extends SnapshotSchedule> findRecurringSnapshotSchedule(ListRecurringSnapshotScheduleCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<? extends SnapshotPolicy> listPoliciesforVolume(ListSnapshotPoliciesCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteSnapshotPolicies(DeleteSnapshotPoliciesCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Snapshot allocSnapshot(Long volumeId, Long policyId) throws ResourceAllocationException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Snapshot createSnapshot(Long volumeId, Long policyId, Long snapshotId, Account snapshotOwner) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public VirtualMachineTemplate registerTemplate(RegisterTemplateCmd cmd) throws URISyntaxException, ResourceAllocationException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public VirtualMachineTemplate registerIso(RegisterIsoCmd cmd) throws IllegalArgumentException, ResourceAllocationException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public VirtualMachineTemplate copyTemplate(CopyTemplateCmd cmd) throws StorageUnavailableException, ResourceAllocationException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public VirtualMachineTemplate prepareTemplate(long templateId, long zoneId) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean detachIso(long vmId) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean attachIso(long isoId, long vmId) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteTemplate(DeleteTemplateCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteIso(DeleteIsoCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Long extract(ExtractIsoCmd cmd) throws InternalErrorException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Long extract(ExtractTemplateCmd cmd) throws InternalErrorException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public VirtualMachineTemplate getTemplate(long templateId) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> listTemplatePermissions(ListTemplateOrIsoPermissionsCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean updateTemplateOrIsoPermissions(UpdateTemplateOrIsoPermissionsCmd cmd) {
|
||||
// TODO Auto-generated method stub
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume uploadVolume(UploadVolumeCmd cmd) throws ResourceAllocationException {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void cleanupVolumes(long vmId) throws ConcurrentOperationException {
|
||||
_volumeMgr.cleanupVolumes(vmId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void recreateVolume(long volumeId, long vmId) throws ConcurrentOperationException {
|
||||
VolumeVO volume = _volumeDao.findById(volumeId);
|
||||
_volumeMgr.recreateVolume(volume, vmId);
|
||||
}
|
||||
}
|
||||
public class StorageOrchestraEngineImpl implements StorageOrchestraEngine {
|
||||
@Inject
|
||||
StorageCore _storeCore;
|
||||
|
||||
@Override
|
||||
public Volume createVolume(Volume volume, DataStore storage) {
|
||||
// TODO Auto-generated method stub
|
||||
|
||||
if (_storeCore.exists(volume))
|
||||
return volume;
|
||||
|
||||
if (volume.getTemplateId() != null) {
|
||||
//copy template to storage at first
|
||||
Template template = null; // get template from volume.gettemplateid
|
||||
Volume baseVolume = (Volume)_storeCore.copy(template, template.getStore(), storage);
|
||||
return (Volume)_storeCore.copy(baseVolume, volume, baseVolume.getStore(), storage);
|
||||
} else {
|
||||
return (Volume)_storeCore.create(volume, storage);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume createVolumeFromSnapshot(Volume volume, Snapshot snapshot) {
|
||||
return (Volume)_storeCore.copy(snapshot, volume, snapshot.getStore(), volume.getStore());
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume copyVolume(Volume srcVol, DataStore destPool) {
|
||||
if (!_storeCore.exists(srcVol)) {
|
||||
throw new CloudRuntimeException("volume: " + srcVol + " doesn't exist");
|
||||
}
|
||||
|
||||
Volume vol = (Volume)_storeCore.copy(srcVol, srcVol.getStore(), destPool);
|
||||
if (vol != null) {
|
||||
return vol;
|
||||
}
|
||||
|
||||
//If failed, try another one
|
||||
if (destPool.getType() != StoreType.Backup) {
|
||||
DataStore backupStore = _storeCore.getStore(StoreType.Backup, destPool.getScope());
|
||||
Volume tempVol = (Volume)_storeCore.copy(srcVol, srcVol.getStore(), backupStore);
|
||||
Volume destVol = (Volume)_storeCore.copy(tempVol, tempVol.getStore(), destPool);
|
||||
return destVol;
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume moveVolume(Volume srcVol, DataStore destPool) {
|
||||
Volume destVol = (Volume)this.copyVolume(srcVol, destPool);
|
||||
_storeCore.delete(srcVol, srcVol.getStore());
|
||||
return destVol;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Volume createVolumeFromTemplate(Volume volume, Template template) {
|
||||
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Template createTemplateFromVolume(Template template, Volume volume) {
|
||||
// TODO Auto-generated method stub
|
||||
return null;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue