ABLESTACK V2K 기능을 이요한 Mold UI 병합(1차 HCI - RBD 환경 지원)

Author: jschoiRR

api/src/main/java/com/cloud/hypervisor/HypervisorGuru.java

@@ -117,6 +117,15 @@ boolean attachRestoredVolumeToVirtualMachine(long zoneId, String location, Backu
      */
     Pair<UnmanagedInstanceTO, Boolean> getHypervisorVMOutOfBandAndCloneIfRequired(String hostIp, String vmName, Map<String, String> params);
 
+    /**
+     * Will return the hypervisor VM without cloning it on an external host (if the guru can handle)
+     * @param hostIp VM's source host IP
+     * @param vmName name of the source VM
+     * @param params hypervisor specific additional parameters
+     * @return a reference to the hypervisor VM
+     */
+    UnmanagedInstanceTO getHypervisorVMOutOfBand(String hostIp, String vmName, Map<String, String> params);
+
     /**
      * Removes a VM created as a clone of a VM on an external host
      * @param hostIp VM's source host IP

api/src/main/java/org/apache/cloudstack/api/ApiConstants.java

@@ -298,6 +298,7 @@ public class ApiConstants {
     public static final String ID = "id";
     public static final String IDS = "ids";
     public static final String IMPORT_INSTANCE_HOST_ID = "importinstancehostid";
+    public static final String IMPORT_VM_TASK_ID = "importvmtaskid";
     public static final String INDEX = "index";
     public static final String INSTANCES_DISKS_STATS_RETENTION_ENABLED = "instancesdisksstatsretentionenabled";
     public static final String INSTANCES_DISKS_STATS_RETENTION_TIME = "instancesdisksstatsretentiontime";
@@ -1601,4 +1602,4 @@ public static ApiKeyAccess fromBoolean(Boolean value) {
             }
         }
     }
-}
+}

api/src/main/java/org/apache/cloudstack/api/command/admin/vm/ImportUnmanagedInstanceForAblestackV2KCmd.java

@@ -0,0 +1,69 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+package org.apache.cloudstack.api.command.admin.vm;
+
+import com.cloud.exception.ConcurrentOperationException;
+import com.cloud.exception.InsufficientCapacityException;
+import com.cloud.exception.NetworkRuleConflictException;
+import com.cloud.exception.ResourceAllocationException;
+import com.cloud.exception.ResourceUnavailableException;
+import org.apache.cloudstack.acl.RoleType;
+import org.apache.cloudstack.api.APICommand;
+import org.apache.cloudstack.api.ApiConstants;
+import org.apache.cloudstack.api.Parameter;
+import org.apache.cloudstack.api.ResponseObject;
+import org.apache.cloudstack.api.ServerApiException;
+import org.apache.cloudstack.api.response.UserVmResponse;
+import org.apache.commons.lang3.StringUtils;
+
+@APICommand(name = "importUnmanagedInstanceForAblestackV2K",
+        description = "Import virtual machine from VMware into CloudStack using ablestack-v2k workflow",
+        responseObject = UserVmResponse.class,
+        responseView = ResponseObject.ResponseView.Full,
+        requestHasSensitiveInfo = false,
+        responseHasSensitiveInfo = true,
+        authorized = {RoleType.Admin},
+        since = "4.19.0")
+public class ImportUnmanagedInstanceForAblestackV2KCmd extends ImportVmCmd {
+
+    private static final String DEFAULT_SPLIT_MODE = "phase1";
+
+    @Parameter(name = "split",
+            type = CommandType.STRING,
+            description = "(only for importing VMs from VMware to KVM with ablestack-v2k) split-run mode: phase1 or phase2")
+    private String splitMode;
+
+    @Parameter(name = ApiConstants.IMPORT_VM_TASK_ID,
+            type = CommandType.STRING,
+            description = "(only for phase2 execution) existing import VM task ID to continue on the original conversion host")
+    private String importVmTaskId;
+
+    public String getSplitMode() {
+        return StringUtils.defaultIfBlank(splitMode, DEFAULT_SPLIT_MODE);
+    }
+
+    public String getImportVmTaskId() {
+        return importVmTaskId;
+    }
+
+    @Override
+    public void execute() throws ResourceUnavailableException, InsufficientCapacityException, ServerApiException, ConcurrentOperationException, ResourceAllocationException, NetworkRuleConflictException {
+        UserVmResponse response = vmImportService.importVmForAblestackV2K(this);
+        response.setResponseName(getCommandName());
+        setResponseObject(response);
+    }
+}

api/src/main/java/org/apache/cloudstack/api/response/ImportVMTaskResponse.java

@@ -47,6 +47,14 @@ public class ImportVMTaskResponse extends BaseResponse {
     @Param(description = "the ID of account")
     private String accountId;
 
+    @SerializedName(ApiConstants.CLUSTER_ID)
+    @Param(description = "the cluster ID used by the import task")
+    private String clusterId;
+
+    @SerializedName(ApiConstants.SERVICE_OFFERING_ID)
+    @Param(description = "the service offering ID used by the import task")
+    private String serviceOfferingId;
+
     @SerializedName(ApiConstants.VIRTUAL_MACHINE_ID)
     @Param(description = "the ID of the imported VM (after task is completed)")
     private String virtualMachineId;
@@ -75,6 +83,10 @@ public class ImportVMTaskResponse extends BaseResponse {
     @Param(description = "the current step on the importing VM task")
     private String step;
 
+    @SerializedName("v2kstep")
+    @Param(description = "the current ablestack-v2k step on the importing VM task")
+    private String v2kStep;
+
     @SerializedName("stepduration")
     @Param(description = "the duration of the current step")
     private String stepDuration;
@@ -103,6 +115,26 @@ public class ImportVMTaskResponse extends BaseResponse {
     @Param(description = "the last updated date of the importing task")
     private Date lastUpdated;
 
+    @SerializedName("phase")
+    @Param(description = "the current PHASE from ablestack-v2k status")
+    private String phase;
+
+    @SerializedName("migrationstate")
+    @Param(description = "the current STATE from ablestack-v2k status")
+    private String migrationState;
+
+    @SerializedName("migrationstep")
+    @Param(description = "the current STEP from ablestack-v2k status")
+    private String migrationStep;
+
+    @SerializedName("syncphysical")
+    @Param(description = "the current SYNC(Physical) from ablestack-v2k status")
+    private String syncPhysical;
+
+    @SerializedName("workdir")
+    @Param(description = "the current WORKDIR from ablestack-v2k status")
+    private String workdir;
+
     public String getId() {
         return id;
     }
@@ -143,6 +175,22 @@ public void setAccountId(String accountId) {
         this.accountId = accountId;
     }
 
+    public String getClusterId() {
+        return clusterId;
+    }
+
+    public void setClusterId(String clusterId) {
+        this.clusterId = clusterId;
+    }
+
+    public String getServiceOfferingId() {
+        return serviceOfferingId;
+    }
+
+    public void setServiceOfferingId(String serviceOfferingId) {
+        this.serviceOfferingId = serviceOfferingId;
+    }
+
     public String getVirtualMachineId() {
         return virtualMachineId;
     }
@@ -191,6 +239,14 @@ public void setStep(String step) {
         this.step = step;
     }
 
+    public String getV2kStep() {
+        return v2kStep;
+    }
+
+    public void setV2kStep(String v2kStep) {
+        this.v2kStep = v2kStep;
+    }
+
     public String getStepDuration() {
         return stepDuration;
     }
@@ -254,4 +310,44 @@ public String getState() {
     public void setState(String state) {
         this.state = state;
     }
+
+    public String getPhase() {
+        return phase;
+    }
+
+    public void setPhase(String phase) {
+        this.phase = phase;
+    }
+
+    public String getMigrationState() {
+        return migrationState;
+    }
+
+    public void setMigrationState(String migrationState) {
+        this.migrationState = migrationState;
+    }
+
+    public String getMigrationStep() {
+        return migrationStep;
+    }
+
+    public void setMigrationStep(String migrationStep) {
+        this.migrationStep = migrationStep;
+    }
+
+    public String getSyncPhysical() {
+        return syncPhysical;
+    }
+
+    public void setSyncPhysical(String syncPhysical) {
+        this.syncPhysical = syncPhysical;
+    }
+
+    public String getWorkdir() {
+        return workdir;
+    }
+
+    public void setWorkdir(String workdir) {
+        this.workdir = workdir;
+    }
 }

api/src/main/java/org/apache/cloudstack/vm/ImportVmTask.java

@@ -22,10 +22,16 @@
 import org.apache.cloudstack.api.InternalIdentity;
 
 public interface ImportVmTask extends Identity, InternalIdentity {
+    String V2K_STEP_NONE = "None";
+
     enum Step {
         Prepare, CloningInstance, ConvertingInstance, Importing, Completed
     }
 
+    enum V2KStep {
+        Phase1_In_Progress, Phase1_Completed, Phase2_In_Progress, Phase2_Completed, Completed
+    }
+
     enum TaskState {
         Running, Completed, Failed;
 

api/src/main/java/org/apache/cloudstack/vm/ImportVmTasksManager.java

@@ -23,6 +23,8 @@
 import org.apache.cloudstack.api.response.ImportVMTaskResponse;
 import org.apache.cloudstack.api.response.ListResponse;
 
+import java.util.Map;
+
 public interface ImportVmTasksManager {
 
     ListResponse<ImportVMTaskResponse> listImportVMTasks(ListImportVMTasksCmd cmd);
@@ -34,5 +36,13 @@ ImportVmTask createImportVMTaskRecord(DataCenter zone, Account owner, long userI
     void updateImportVMTaskStep(ImportVmTask importVMTaskVO, DataCenter zone, Account owner, Host convertHost,
                                 Host importHost, Long vmId, ImportVmTask.Step step);
 
+    void updateImportVMTaskV2KStep(ImportVmTask importVMTaskVO, ImportVmTask.V2KStep step);
+
+    void updateImportVMTaskV2KContext(ImportVmTask importVMTaskVO, Long clusterId, Long serviceOfferingId,
+                                      Long targetStoragePoolId, String sourceClusterName, String sourceHostName,
+                                      Long vcenterId, String vcenterUsername, String vcenterPassword,
+                                      Map<String, String> serviceOfferingDetails,
+                                      Map<String, Map<String, String>> nicSelectionMap);
+
     void updateImportVMTaskErrorState(ImportVmTask importVMTaskVO, ImportVmTask.TaskState state, String errorMsg);
 }

api/src/main/java/org/apache/cloudstack/vm/UnmanagedVMsManager.java

@@ -73,4 +73,6 @@ public interface UnmanagedVMsManager extends VmImportService, UnmanageVMService,
     static boolean isSupported(Hypervisor.HypervisorType hypervisorType) {
         return hypervisorType == VMware || hypervisorType == KVM;
     }
+
+    void finalizeAblestackV2KTask(String importVmTaskUuid);
 }

api/src/main/java/org/apache/cloudstack/vm/VmImportService.java

@@ -18,6 +18,7 @@
 package org.apache.cloudstack.vm;
 
 import org.apache.cloudstack.api.command.admin.vm.ImportUnmanagedInstanceCmd;
+import org.apache.cloudstack.api.command.admin.vm.ImportUnmanagedInstanceForAblestackV2KCmd;
 import org.apache.cloudstack.api.command.admin.vm.ImportVmCmd;
 import org.apache.cloudstack.api.command.admin.vm.ListUnmanagedInstancesCmd;
 import org.apache.cloudstack.api.command.admin.vm.ListVmsForImportCmd;
@@ -40,6 +41,7 @@ public String toString() {
     UserVmResponse importUnmanagedInstance(ImportUnmanagedInstanceCmd cmd);
 
     UserVmResponse importVm(ImportVmCmd cmd);
+    UserVmResponse importVmForAblestackV2K(ImportUnmanagedInstanceForAblestackV2KCmd cmd);
 
     ListResponse<UnmanagedInstanceResponse> listVmsForImport(ListVmsForImportCmd cmd);
 }

core/src/main/java/com/cloud/agent/api/AblestackV2KConvertInstanceCommand.java

@@ -0,0 +1,98 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+package com.cloud.agent.api;
+
+import com.cloud.agent.api.to.DataStoreTO;
+
+public class AblestackV2KConvertInstanceCommand extends Command {
+
+    private String vmName;
+    private String vcenter;
+    private String username;
+    private String password;
+    private DataStoreTO targetStorageLocation;
+    private String splitMode;
+    private String targetFormat;
+    private String targetStorage;
+    private String targetMapJson;
+
+    public AblestackV2KConvertInstanceCommand() {
+    }
+
+    public AblestackV2KConvertInstanceCommand(String vmName, String vcenter, String username, String password,
+                                              DataStoreTO targetStorageLocation, String splitMode) {
+        this.vmName = vmName;
+        this.vcenter = vcenter;
+        this.username = username;
+        this.password = password;
+        this.targetStorageLocation = targetStorageLocation;
+        this.splitMode = splitMode;
+    }
+
+    public String getVmName() {
+        return vmName;
+    }
+
+    public String getVcenter() {
+        return vcenter;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public DataStoreTO getTargetStorageLocation() {
+        return targetStorageLocation;
+    }
+
+    public String getSplitMode() {
+        return splitMode;
+    }
+
+    public String getTargetFormat() {
+        return targetFormat;
+    }
+
+    public void setTargetFormat(String targetFormat) {
+        this.targetFormat = targetFormat;
+    }
+
+    public String getTargetStorage() {
+        return targetStorage;
+    }
+
+    public void setTargetStorage(String targetStorage) {
+        this.targetStorage = targetStorage;
+    }
+
+    public String getTargetMapJson() {
+        return targetMapJson;
+    }
+
+    public void setTargetMapJson(String targetMapJson) {
+        this.targetMapJson = targetMapJson;
+    }
+
+    @Override
+    public boolean executeInSequence() {
+        return false;
+    }
+}