testing fix

Author: Srivastava, Piyush

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/driver/OntapPrimaryDatastoreDriver.java

@@ -103,7 +103,8 @@ public void createAsync(DataStore dataStore, DataObject dataObject, AsyncComplet
             s_logger.info("createAsync: Started for data store [{}] and data object [{}] of type [{}]",
                     dataStore, dataObject, dataObject.getType());
             if (dataObject.getType() == DataObjectType.VOLUME) {
-                path = createCloudStackVolumeForTypeVolume(dataStore, (VolumeInfo)dataObject);
+                VolumeInfo volumeInfo = (VolumeInfo) dataObject;
+                path = createCloudStackVolumeForTypeVolume(dataStore, volumeInfo);
                 createCmdResult = new CreateCmdResult(path, new Answer(null, true, null));
             } else {
                 errMsg = "Invalid DataObjectType (" + dataObject.getType() + ") passed to createAsync";

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/service/UnifiedNASStrategy.java

@@ -26,9 +26,9 @@
 import com.cloud.storage.dao.VolumeDao;
 import com.cloud.utils.exception.CloudRuntimeException;
 import feign.FeignException;
+import org.apache.cloudstack.engine.subsystem.api.storage.DataObject;
 import org.apache.cloudstack.engine.subsystem.api.storage.EndPoint;
 import org.apache.cloudstack.engine.subsystem.api.storage.EndPointSelector;
-import org.apache.cloudstack.engine.subsystem.api.storage.VolumeInfo;
 import org.apache.cloudstack.storage.command.CreateObjectCommand;
 import org.apache.cloudstack.storage.feign.FeignClientFactory;
 import org.apache.cloudstack.storage.feign.client.JobFeignClient;
@@ -82,16 +82,21 @@ public void setOntapStorage(OntapStorage ontapStorage) {
     @Override
     public CloudStackVolume createCloudStackVolume(CloudStackVolume cloudstackVolume) {
         s_logger.info("createCloudStackVolume: Create cloudstack volume " + cloudstackVolume);
-        // Step 1: set cloudstack volume metadata
-        String volumeUuid = updateCloudStackVolumeMetadata(cloudstackVolume.getDatastoreId(), cloudstackVolume.getVolumeInfo());
-        // Step 2: Send command to KVM host to create qcow2 file using qemu-img
-        Answer answer = createVolumeOnKVMHost(cloudstackVolume.getVolumeInfo());
+        try {
+            // Step 1: set cloudstack volume metadata
+            String volumeUuid = updateCloudStackVolumeMetadata(cloudstackVolume.getDatastoreId(), cloudstackVolume.getVolumeInfo());
+            // Step 2: Send command to KVM host to create qcow2 file using qemu-img
+            Answer answer = createVolumeOnKVMHost(cloudstackVolume.getVolumeInfo());
             if (answer == null || !answer.getResult()) {
                 String errMsg = answer != null ? answer.getDetails() : "Failed to create qcow2 on KVM host";
                 s_logger.error("createCloudStackVolumeForTypeVolume: " + errMsg);
                 throw new CloudRuntimeException(errMsg);
             }
             return cloudstackVolume;
+        }catch (Exception e) {
+            s_logger.error("createCloudStackVolumeForTypeVolume: " + e);
+            throw new CloudRuntimeException(e);
+        }
     }
 
     @Override
@@ -374,18 +379,31 @@ private ExportPolicy createExportPolicyRequest(AccessGroup accessGroup,String sv
         return exportPolicy;
     }
 
-    private String updateCloudStackVolumeMetadata(String dataStoreId, VolumeInfo volumeInfo) {
+    private String updateCloudStackVolumeMetadata(String dataStoreId, DataObject volumeInfo) {
         s_logger.info("createManagedNfsVolume called with datastoreID: {} volumeInfo: {} ", dataStoreId, volumeInfo );
-        VolumeVO volume = volumeDao.findById(volumeInfo.getId());
-        String volumeUuid = volumeInfo.getUuid();
-        volume.setPoolType(Storage.StoragePoolType.NetworkFilesystem);
-        volume.setPoolId(Long.parseLong(dataStoreId)); //need to check if volume0 already has this data filled
-        volume.setPath(volumeUuid);  // Filename for qcow2 file
-        volumeDao.update(volume.getId(), volume);
-        return volumeUuid;
+        s_logger.info("line 379");
+       try {
+
+
+           VolumeVO volume = volumeDao.findById(volumeInfo.getTO().getId());
+           s_logger.info("line 381");
+           String volumeUuid = volumeInfo.getUuid();
+           s_logger.info("line 383");
+           volume.setPoolType(Storage.StoragePoolType.NetworkFilesystem);
+           s_logger.info("line 385");
+           volume.setPoolId(Long.parseLong(dataStoreId));//need to check if volume0 already has this data filled
+           volume.setPath(volumeUuid);  // Filename for qcow2 file
+           s_logger.info("starting update");
+           volumeDao.update(volume.getId(), volume);
+           s_logger.info("update succesfful 385");
+           return volumeUuid;
+       }catch (Exception e){
+           s_logger.error("Exception while updating volumeInfo: {} in volume: {}", dataStoreId, volumeInfo.getUuid(), e);
+           throw new CloudRuntimeException("Exception while updating volumeInfo: " + e.getMessage());
+       }
     }
 
-    private Answer createVolumeOnKVMHost(VolumeInfo volumeInfo) {
+    private Answer createVolumeOnKVMHost(DataObject volumeInfo) {
         s_logger.info("createVolumeOnKVMHost called with volumeInfo: {} ", volumeInfo);
 
         try {

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/service/model/CloudStackVolume.java

@@ -19,7 +19,7 @@
 
 package org.apache.cloudstack.storage.service.model;
 
-import org.apache.cloudstack.engine.subsystem.api.storage.VolumeInfo;
+import org.apache.cloudstack.engine.subsystem.api.storage.DataObject;
 import org.apache.cloudstack.storage.feign.model.FileInfo;
 import org.apache.cloudstack.storage.feign.model.Lun;
 
@@ -28,7 +28,7 @@ public class CloudStackVolume {
     private FileInfo file;
     private Lun lun;
     private String datastoreId;
-    private VolumeInfo volumeInfo;
+    private DataObject volumeInfo;
     public FileInfo getFile() {
         return file;
     }
@@ -50,10 +50,10 @@ public String getDatastoreId() {
     public void setDatastoreId(String datastoreId) {
         this.datastoreId = datastoreId;
     }
-    public VolumeInfo getVolumeInfo() {
+    public DataObject getVolumeInfo() {
         return volumeInfo;
     }
-    public void setVolumeInfo(VolumeInfo volumeInfot) {
-        this.volumeInfo = volumeInfot;
+    public void setVolumeInfo(DataObject volumeInfo) {
+        this.volumeInfo = volumeInfo;
     }
 }

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/utils/Utility.java

@@ -21,7 +21,7 @@
 
 import com.cloud.utils.StringUtils;
 import com.cloud.utils.exception.CloudRuntimeException;
-import org.apache.cloudstack.engine.subsystem.api.storage.VolumeInfo;
+import org.apache.cloudstack.engine.subsystem.api.storage.DataObject;
 import org.apache.cloudstack.storage.datastore.db.StoragePoolVO;
 import org.apache.cloudstack.storage.feign.model.Lun;
 import org.apache.cloudstack.storage.feign.model.LunSpace;
@@ -56,7 +56,7 @@ public static String generateAuthHeader (String username, String password) {
         return BASIC + StringUtils.SPACE + new String(encodedBytes);
     }
 
-    public static CloudStackVolume createCloudStackVolumeRequestByProtocol(StoragePoolVO storagePool, Map<String, String> details, VolumeInfo volumeObject) {
+    public static CloudStackVolume createCloudStackVolumeRequestByProtocol(StoragePoolVO storagePool, Map<String, String> details, DataObject volumeObject) {
         CloudStackVolume cloudStackVolumeRequest = null;
 
         String protocol = details.get(Constants.PROTOCOL);