apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-12-17 11:04:00 +01:00
Code Issues Packages Projects Releases Wiki Activity

Prepare secondary storage in migration target host before migration happens, unlike primary storage, secondary storage is prepared on-demand

Browse Source
This commit is contained in:
Kelven Yang 2012-02-01 15:20:52 -08:00
parent e6b1929d1a
commit dcee71e923
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/com/cloud/hypervisor/vmware/resource/VmwareResource.java
View File

@ -2149,6 +2149,7 @@ public class VmwareResource implements StoragePoolResource, ServerResource, Vmwa
final String vmName = vm.getName(); final String vmName = vm.getName();
try { try {
VmwareHypervisorHost hyperHost = getHyperHost(getServiceContext()); VmwareHypervisorHost hyperHost = getHyperHost(getServiceContext());
VmwareManager mgr = hyperHost.getContext().getStockObject(VmwareManager.CONTEXT_STOCK_NAME);
// find VM through datacenter (VM is not at the target host yet) // find VM through datacenter (VM is not at the target host yet)
VirtualMachineMO vmMo = hyperHost.findVmOnPeerHyperHost(vmName); VirtualMachineMO vmMo = hyperHost.findVmOnPeerHyperHost(vmName);
@ -2164,6 +2165,19 @@ public class VmwareResource implements StoragePoolResource, ServerResource, Vmwa
prepareNetworkFromNicInfo(new HostMO(getServiceContext(), _morHyperHost), nic); prepareNetworkFromNicInfo(new HostMO(getServiceContext(), _morHyperHost), nic);
} }
String secStoreUrl = mgr.getSecondaryStorageStoreUrl(Long.parseLong(_dcId));
if(secStoreUrl == null) {
String msg = "secondary storage for dc " + _dcId + " is not ready yet?";
throw new Exception(msg);
}
mgr.prepareSecondaryStorageStore(secStoreUrl);
ManagedObjectReference morSecDs = prepareSecondaryDatastoreOnHost(secStoreUrl);
if (morSecDs == null) {
String msg = "Failed to prepare secondary storage on host, secondary store url: " + secStoreUrl;
throw new Exception(msg);
}
synchronized (_vms) { synchronized (_vms) {
_vms.put(vm.getName(), State.Migrating); _vms.put(vm.getName(), State.Migrating);
} }