You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cloudstack.apache.org by mt...@apache.org on 2013/12/29 05:44:27 UTC
git commit: updated refs/heads/4.3 to e65fae4
Updated Branches:
refs/heads/4.3 c15cf1230 -> e65fae412
CLOUDSTACK-5662: XenServer can't discover iSCSI targets with different credentials
Project: http://git-wip-us.apache.org/repos/asf/cloudstack/repo
Commit: http://git-wip-us.apache.org/repos/asf/cloudstack/commit/e65fae41
Tree: http://git-wip-us.apache.org/repos/asf/cloudstack/tree/e65fae41
Diff: http://git-wip-us.apache.org/repos/asf/cloudstack/diff/e65fae41
Branch: refs/heads/4.3
Commit: e65fae412cf0fee6260eec6e9424a218f8bb54c4
Parents: c15cf12
Author: Mike Tutkowski <mi...@solidfire.com>
Authored: Sat Dec 28 01:04:18 2013 -0700
Committer: Mike Tutkowski <mi...@solidfire.com>
Committed: Sat Dec 28 21:43:28 2013 -0700
----------------------------------------------------------------------
.../service/VolumeOrchestrationService.java | 2 ++
.../api/storage/PrimaryDataStoreDriver.java | 2 --
.../com/cloud/vm/VirtualMachineManagerImpl.java | 31 ++++++++++----------
.../orchestration/VolumeOrchestrator.java | 20 +++++++++++++
4 files changed, 38 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/e65fae41/engine/api/src/org/apache/cloudstack/engine/orchestration/service/VolumeOrchestrationService.java
----------------------------------------------------------------------
diff --git a/engine/api/src/org/apache/cloudstack/engine/orchestration/service/VolumeOrchestrationService.java b/engine/api/src/org/apache/cloudstack/engine/orchestration/service/VolumeOrchestrationService.java
index 5ac6bb1..92daf88 100644
--- a/engine/api/src/org/apache/cloudstack/engine/orchestration/service/VolumeOrchestrationService.java
+++ b/engine/api/src/org/apache/cloudstack/engine/orchestration/service/VolumeOrchestrationService.java
@@ -93,6 +93,8 @@ public interface VolumeOrchestrationService {
void cleanupVolumes(long vmId) throws ConcurrentOperationException;
+ void disconnectVolumesFromHost(long vmId, long hostId);
+
void migrateVolumes(VirtualMachine vm, VirtualMachineTO vmTo, Host srcHost, Host destHost, Map<Volume, StoragePool> volumeToPool);
boolean storageMigration(VirtualMachineProfile vm, StoragePool destPool) throws StorageUnavailableException;
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/e65fae41/engine/api/src/org/apache/cloudstack/engine/subsystem/api/storage/PrimaryDataStoreDriver.java
----------------------------------------------------------------------
diff --git a/engine/api/src/org/apache/cloudstack/engine/subsystem/api/storage/PrimaryDataStoreDriver.java b/engine/api/src/org/apache/cloudstack/engine/subsystem/api/storage/PrimaryDataStoreDriver.java
index 36091e0..aad9494 100644
--- a/engine/api/src/org/apache/cloudstack/engine/subsystem/api/storage/PrimaryDataStoreDriver.java
+++ b/engine/api/src/org/apache/cloudstack/engine/subsystem/api/storage/PrimaryDataStoreDriver.java
@@ -18,8 +18,6 @@
*/
package org.apache.cloudstack.engine.subsystem.api.storage;
-import java.util.List;
-
import org.apache.cloudstack.framework.async.AsyncCompletionCallback;
import org.apache.cloudstack.storage.command.CommandResult;
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/e65fae41/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
----------------------------------------------------------------------
diff --git a/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java b/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
index 824dc0b..1fec68e 100755
--- a/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
+++ b/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
@@ -483,30 +483,32 @@ public class VirtualMachineManagerImpl extends ManagerBase implements VirtualMac
List<Command> volumeExpungeCommands = hvGuru.finalizeExpungeVolumes(vm);
- if (volumeExpungeCommands != null) {
- Long hostId = vm.getHostId() != null ? vm.getHostId() : vm.getLastHostId();
+ Long hostId = vm.getHostId() != null ? vm.getHostId() : vm.getLastHostId();
- if (hostId != null) {
- Commands cmds = new Commands(Command.OnError.Stop);
+ if (volumeExpungeCommands != null && hostId != null) {
+ Commands cmds = new Commands(Command.OnError.Stop);
- for (Command volumeExpungeCommand : volumeExpungeCommands) {
- cmds.addCommand(volumeExpungeCommand);
- }
+ for (Command volumeExpungeCommand : volumeExpungeCommands) {
+ cmds.addCommand(volumeExpungeCommand);
+ }
- _agentMgr.send(hostId, cmds);
+ _agentMgr.send(hostId, cmds);
- if (!cmds.isSuccessful()) {
- for (Answer answer : cmds.getAnswers()) {
- if (!answer.getResult()) {
- s_logger.warn("Failed to expunge vm due to: " + answer.getDetails());
+ if (!cmds.isSuccessful()) {
+ for (Answer answer : cmds.getAnswers()) {
+ if (!answer.getResult()) {
+ s_logger.warn("Failed to expunge vm due to: " + answer.getDetails());
- throw new CloudRuntimeException("Unable to expunge " + vm + " due to " + answer.getDetails());
- }
+ throw new CloudRuntimeException("Unable to expunge " + vm + " due to " + answer.getDetails());
}
}
}
}
+ if (hostId != null) {
+ volumeMgr.disconnectVolumesFromHost(vm.getId(), hostId);
+ }
+
// Clean up volumes based on the vm's instance id
volumeMgr.cleanupVolumes(vm.getId());
@@ -518,7 +520,6 @@ public class VirtualMachineManagerImpl extends ManagerBase implements VirtualMac
// send hypervisor-dependent commands before removing
List<Command> finalizeExpungeCommands = hvGuru.finalizeExpunge(vm);
if (finalizeExpungeCommands != null && finalizeExpungeCommands.size() > 0) {
- Long hostId = vm.getHostId() != null ? vm.getHostId() : vm.getLastHostId();
if (hostId != null) {
Commands cmds = new Commands(Command.OnError.Stop);
for (Command command : finalizeExpungeCommands) {
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/e65fae41/engine/orchestration/src/org/apache/cloudstack/engine/orchestration/VolumeOrchestrator.java
----------------------------------------------------------------------
diff --git a/engine/orchestration/src/org/apache/cloudstack/engine/orchestration/VolumeOrchestrator.java b/engine/orchestration/src/org/apache/cloudstack/engine/orchestration/VolumeOrchestrator.java
index 7a5dbf6..ff6ace8 100644
--- a/engine/orchestration/src/org/apache/cloudstack/engine/orchestration/VolumeOrchestrator.java
+++ b/engine/orchestration/src/org/apache/cloudstack/engine/orchestration/VolumeOrchestrator.java
@@ -71,6 +71,8 @@ import com.cloud.exception.InsufficientStorageCapacityException;
import com.cloud.exception.InvalidParameterValueException;
import com.cloud.exception.StorageUnavailableException;
import com.cloud.host.Host;
+import com.cloud.host.HostVO;
+import com.cloud.host.dao.HostDao;
import com.cloud.hypervisor.Hypervisor.HypervisorType;
import com.cloud.offering.DiskOffering;
import com.cloud.offering.ServiceOffering;
@@ -140,6 +142,8 @@ public class VolumeOrchestrator extends ManagerBase implements VolumeOrchestrati
SnapshotDataFactory snapshotFactory;
@Inject
ConfigDepot _configDepot;
+ @Inject
+ HostDao _hostDao;
private final StateMachine2<Volume.State, Volume.Event, Volume> _volStateMachine;
protected List<StoragePoolAllocator> _storagePoolAllocators;
@@ -840,6 +844,22 @@ public class VolumeOrchestrator extends ManagerBase implements VolumeOrchestrati
}
@Override
+ public void disconnectVolumesFromHost(long vmId, long hostId) {
+ HostVO host = _hostDao.findById(hostId);
+
+ List<VolumeVO> volumesForVm = _volsDao.findByInstance(vmId);
+
+ if (volumesForVm != null) {
+ for (VolumeVO volumeForVm : volumesForVm) {
+ VolumeInfo volumeInfo = volFactory.getVolume(volumeForVm.getId());
+ DataStore dataStore = dataStoreMgr.getDataStore(volumeForVm.getPoolId(), DataStoreRole.Primary);
+
+ volService.disconnectVolumeFromHost(volumeInfo, host, dataStore);
+ }
+ }
+ }
+
+ @Override
@DB
public Volume migrateVolume(Volume volume, StoragePool destPool) throws StorageUnavailableException {
VolumeInfo vol = volFactory.getVolume(volume.getId());