apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

More protective cleanup when exporting snaphost to reduce chances of leaving intermediate files behind under soft error conditions

Browse Source
This commit is contained in:
Kelven Yang 2012-01-26 15:11:24 -08:00
parent 83bc7d1c81
commit f0e048a968
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
vmware-base/src/com/cloud/hypervisor/vmware/mo/VirtualMachineMO.java
View File

@ -1187,15 +1187,16 @@ public class VirtualMachineMO extends BaseMO {
try { try {
if(state == HttpNfcLeaseState.ready) { if(state == HttpNfcLeaseState.ready) {
final HttpNfcLeaseMO.ProgressReporter progressReporter = leaseMo.createProgressReporter(); final HttpNfcLeaseMO.ProgressReporter progressReporter = leaseMo.createProgressReporter();
boolean success = false;
List<String> fileNames = new ArrayList<String>();
try { try {
HttpNfcLeaseInfo leaseInfo = leaseMo.getLeaseInfo(); HttpNfcLeaseInfo leaseInfo = leaseMo.getLeaseInfo();
final long totalBytes = leaseInfo.getTotalDiskCapacityInKB() * 1024; final long totalBytes = leaseInfo.getTotalDiskCapacityInKB() * 1024;
long totalBytesDownloaded = 0; long totalBytesDownloaded = 0;
HttpNfcLeaseDeviceUrl[] deviceUrls = leaseInfo.getDeviceUrl(); HttpNfcLeaseDeviceUrl[] deviceUrls = leaseInfo.getDeviceUrl();
if(deviceUrls != null) { if(deviceUrls != null) {
List<String> fileNames = new ArrayList<String>();
OvfFile[] ovfFiles = new OvfFile[deviceUrls.length]; OvfFile[] ovfFiles = new OvfFile[deviceUrls.length];
for (int i = 0; i < deviceUrls.length; i++) { for (int i = 0; i < deviceUrls.length; i++) {
String deviceId = deviceUrls[i].getKey(); String deviceId = deviceUrls[i].getKey();
@ -1251,19 +1252,25 @@ public class VirtualMachineMO extends BaseMO {
} }
String result = command.execute(); String result = command.execute();
if(result == null) { if(result == null) {
if(leaveOvaFileOnly) { success = true;
for(String name: fileNames) {
new File(name).delete();
}
}
} }
} }
} }
} catch(Throwable e) { } catch(Throwable e) {
s_logger.error("Unexpected exception ", e); s_logger.error("Unexpected exception ", e);
} finally { } finally {
progressReporter.close(); progressReporter.close();
if(leaveOvaFileOnly) {
for(String name : fileNames) {
new File(name).delete();
}
}
if(!success) {
new File(exportDir + File.separator + exportName + ".ova").delete();
}
} }
} }
} finally { } finally {