Updated Branches: refs/heads/storagerefactor 5150aff35 -> d001a5316
remodel storage Project: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/commit/d001a531 Tree: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/tree/d001a531 Diff: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/diff/d001a531 Branch: refs/heads/storagerefactor Commit: d001a5316f5ad0e60c194568381f92a2103502b7 Parents: 5150aff Author: Edison Su <[email protected]> Authored: Thu Aug 23 18:13:11 2012 -0700 Committer: Edison Su <[email protected]> Committed: Thu Aug 23 18:13:11 2012 -0700 ---------------------------------------------------------------------- .../orchestra/StorageOrchestraEngineImpl.java | 973 ++------------- 1 files changed, 76 insertions(+), 897 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/blob/d001a531/server/src/com/cloud/storage/orchestra/StorageOrchestraEngineImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/orchestra/StorageOrchestraEngineImpl.java b/server/src/com/cloud/storage/orchestra/StorageOrchestraEngineImpl.java index 24fd214..ad1b94a 100644 --- a/server/src/com/cloud/storage/orchestra/StorageOrchestraEngineImpl.java +++ b/server/src/com/cloud/storage/orchestra/StorageOrchestraEngineImpl.java @@ -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; + } +} \ No newline at end of file
