compression=<value>.
+ * Valid values: none, zlib, fastlz,
+ * skipz (nbdkit ≥ 1.24, vSphere ≥ 6.5). fastlz
+ * compresses both zero regions and real data at low CPU cost; skipz
+ * only elides zero blocks. Does not affect the staged virt-v2v conversion path.
+ * Data type: String.fastlz
+ */
+ public static final Property-io vddk-thumbprint=<value>.
* If unset, the KVM host computes it at runtime from the vCenter endpoint.
diff --git a/api/src/main/java/com/cloud/agent/api/to/RemoteInstanceTO.java b/api/src/main/java/com/cloud/agent/api/to/RemoteInstanceTO.java
index 7daeb9649177..8aec16d4b101 100644
--- a/api/src/main/java/com/cloud/agent/api/to/RemoteInstanceTO.java
+++ b/api/src/main/java/com/cloud/agent/api/to/RemoteInstanceTO.java
@@ -38,6 +38,7 @@ public class RemoteInstanceTO implements Serializable {
private String datacenterName;
private String clusterName;
private String hostName;
+ private String vmwareMoref;
public RemoteInstanceTO() {
}
@@ -65,6 +66,11 @@ public RemoteInstanceTO(String instanceName, String instancePath, String vcenter
this.hostName = hostName;
}
+ public RemoteInstanceTO(String instanceName, String instancePath, String vcenterHost, String vcenterUsername, String vcenterPassword, String datacenterName, String clusterName, String hostName, String vmwareMoref) {
+ this(instanceName, instancePath, vcenterHost, vcenterUsername, vcenterPassword, datacenterName, clusterName, hostName);
+ this.vmwareMoref = vmwareMoref;
+ }
+
public Hypervisor.HypervisorType getHypervisorType() {
return this.hypervisorType;
}
@@ -100,4 +106,12 @@ public String getClusterName() {
public String getHostName() {
return hostName;
}
+
+ public String getVmwareMoref() {
+ return vmwareMoref;
+ }
+
+ public void setVmwareMoref(String vmwareMoref) {
+ this.vmwareMoref = vmwareMoref;
+ }
}
diff --git a/api/src/main/java/com/cloud/agent/api/to/VmwareCbtChangedBlockRangeTO.java b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtChangedBlockRangeTO.java
new file mode 100644
index 000000000000..ee8fcc59a290
--- /dev/null
+++ b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtChangedBlockRangeTO.java
@@ -0,0 +1,47 @@
+// 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.to;
+
+import java.io.Serializable;
+
+public class VmwareCbtChangedBlockRangeTO implements Serializable {
+
+ private String diskId;
+ private long startOffset;
+ private long length;
+
+ public VmwareCbtChangedBlockRangeTO() {
+ }
+
+ public VmwareCbtChangedBlockRangeTO(String diskId, long startOffset, long length) {
+ this.diskId = diskId;
+ this.startOffset = startOffset;
+ this.length = length;
+ }
+
+ public String getDiskId() {
+ return diskId;
+ }
+
+ public long getStartOffset() {
+ return startOffset;
+ }
+
+ public long getLength() {
+ return length;
+ }
+}
diff --git a/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskSyncResultTO.java b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskSyncResultTO.java
new file mode 100644
index 000000000000..c22ea0bb24c0
--- /dev/null
+++ b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskSyncResultTO.java
@@ -0,0 +1,78 @@
+// 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.to;
+
+import java.io.Serializable;
+
+public class VmwareCbtDiskSyncResultTO implements Serializable {
+
+ private String diskId;
+ private String targetPath;
+ private String changeId;
+ private String snapshotMor;
+ private long changedBytes;
+ private long durationSeconds;
+ private boolean result;
+ private String details;
+
+ public VmwareCbtDiskSyncResultTO() {
+ }
+
+ public VmwareCbtDiskSyncResultTO(String diskId, String targetPath, String changeId, String snapshotMor,
+ long changedBytes, long durationSeconds, boolean result, String details) {
+ this.diskId = diskId;
+ this.targetPath = targetPath;
+ this.changeId = changeId;
+ this.snapshotMor = snapshotMor;
+ this.changedBytes = changedBytes;
+ this.durationSeconds = durationSeconds;
+ this.result = result;
+ this.details = details;
+ }
+
+ public String getDiskId() {
+ return diskId;
+ }
+
+ public String getTargetPath() {
+ return targetPath;
+ }
+
+ public String getChangeId() {
+ return changeId;
+ }
+
+ public String getSnapshotMor() {
+ return snapshotMor;
+ }
+
+ public long getChangedBytes() {
+ return changedBytes;
+ }
+
+ public long getDurationSeconds() {
+ return durationSeconds;
+ }
+
+ public boolean getResult() {
+ return result;
+ }
+
+ public String getDetails() {
+ return details;
+ }
+}
diff --git a/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskTO.java b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskTO.java
new file mode 100644
index 000000000000..e6dcf1bfbca6
--- /dev/null
+++ b/api/src/main/java/com/cloud/agent/api/to/VmwareCbtDiskTO.java
@@ -0,0 +1,85 @@
+// 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.to;
+
+import java.io.Serializable;
+
+public class VmwareCbtDiskTO implements Serializable {
+
+ private String diskId;
+ private Integer diskDeviceKey;
+ private String sourceDiskPath;
+ private String datastoreName;
+ private String targetPath;
+ private String targetFormat;
+ private String changeId;
+ private String snapshotMor;
+ private long capacityBytes;
+
+ public VmwareCbtDiskTO() {
+ }
+
+ public VmwareCbtDiskTO(String diskId, Integer diskDeviceKey, String sourceDiskPath, String datastoreName,
+ String targetPath, String targetFormat, String changeId, String snapshotMor,
+ long capacityBytes) {
+ this.diskId = diskId;
+ this.diskDeviceKey = diskDeviceKey;
+ this.sourceDiskPath = sourceDiskPath;
+ this.datastoreName = datastoreName;
+ this.targetPath = targetPath;
+ this.targetFormat = targetFormat;
+ this.changeId = changeId;
+ this.snapshotMor = snapshotMor;
+ this.capacityBytes = capacityBytes;
+ }
+
+ public String getDiskId() {
+ return diskId;
+ }
+
+ public Integer getDiskDeviceKey() {
+ return diskDeviceKey;
+ }
+
+ public String getSourceDiskPath() {
+ return sourceDiskPath;
+ }
+
+ public String getDatastoreName() {
+ return datastoreName;
+ }
+
+ public String getTargetPath() {
+ return targetPath;
+ }
+
+ public String getTargetFormat() {
+ return targetFormat;
+ }
+
+ public String getChangeId() {
+ return changeId;
+ }
+
+ public String getSnapshotMor() {
+ return snapshotMor;
+ }
+
+ public long getCapacityBytes() {
+ return capacityBytes;
+ }
+}
diff --git a/api/src/main/java/com/cloud/agent/api/to/VmwareVddkSourceDiskTO.java b/api/src/main/java/com/cloud/agent/api/to/VmwareVddkSourceDiskTO.java
new file mode 100644
index 000000000000..b980c611abc9
--- /dev/null
+++ b/api/src/main/java/com/cloud/agent/api/to/VmwareVddkSourceDiskTO.java
@@ -0,0 +1,53 @@
+// 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.to;
+
+import java.io.Serializable;
+
+public class VmwareVddkSourceDiskTO implements Serializable {
+
+ private String diskId;
+ private String sourceDiskPath;
+ private long capacityBytes;
+ private Integer position;
+
+ public VmwareVddkSourceDiskTO() {
+ }
+
+ public VmwareVddkSourceDiskTO(String diskId, String sourceDiskPath, long capacityBytes, Integer position) {
+ this.diskId = diskId;
+ this.sourceDiskPath = sourceDiskPath;
+ this.capacityBytes = capacityBytes;
+ this.position = position;
+ }
+
+ public String getDiskId() {
+ return diskId;
+ }
+
+ public String getSourceDiskPath() {
+ return sourceDiskPath;
+ }
+
+ public long getCapacityBytes() {
+ return capacityBytes;
+ }
+
+ public Integer getPosition() {
+ return position;
+ }
+}
diff --git a/api/src/main/java/com/cloud/event/EventTypes.java b/api/src/main/java/com/cloud/event/EventTypes.java
index f7d13343d469..7f45c8acd3f7 100644
--- a/api/src/main/java/com/cloud/event/EventTypes.java
+++ b/api/src/main/java/com/cloud/event/EventTypes.java
@@ -49,6 +49,8 @@
import org.apache.cloudstack.storage.sharedfs.SharedFS;
import org.apache.cloudstack.usage.Usage;
import org.apache.cloudstack.schedule.ResourceSchedule;
+import org.apache.cloudstack.vm.bootgroup.InstanceBootGroup;
+import org.apache.cloudstack.vm.bootgroup.readiness.InstanceBootGroupReadinessRule;
import com.cloud.dc.DataCenter;
import com.cloud.dc.DataCenterGuestIpv6Prefix;
@@ -127,6 +129,9 @@ public class EventTypes {
public static final String EVENT_VM_RESTORE = "VM.RESTORE";
public static final String EVENT_VM_EXPUNGE = "VM.EXPUNGE";
public static final String EVENT_VM_IMPORT = "VM.IMPORT";
+ public static final String EVENT_VMWARE_CBT_MIGRATION_START = "VMWARE.CBT.MIGRATION.START";
+ public static final String EVENT_VMWARE_CBT_MIGRATION_SYNC = "VMWARE.CBT.MIGRATION.SYNC";
+ public static final String EVENT_VMWARE_CBT_MIGRATION_CUTOVER = "VMWARE.CBT.MIGRATION.CUTOVER";
public static final String EVENT_VM_UNMANAGE = "VM.UNMANAGE";
public static final String EVENT_VM_RECOVER = "VM.RECOVER";
@@ -899,6 +904,21 @@ public class EventTypes {
public static final String EVENT_DNS_RECORD_DELETE = "DNS.RECORD.DELETE";
public static final String EVENT_DNS_NAME_COLLISION = "DNS.NAME.COLLISION";
+ // Instance Boot Group
+ public static final String EVENT_INSTANCE_BOOT_GROUP_CREATE = "INSTANCE.BOOT.GROUP.CREATE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_DELETE = "INSTANCE.BOOT.GROUP.DELETE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_UPDATE = "INSTANCE.BOOT.GROUP.UPDATE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_START = "INSTANCE.BOOT.GROUP.START";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_STOP = "INSTANCE.BOOT.GROUP.STOP";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_REBOOT = "INSTANCE.BOOT.GROUP.REBOOT";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_MEMBER_ADD = "INSTANCE.BOOT.GROUP.MEMBER.ADD";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_MEMBER_REMOVE = "INSTANCE.BOOT.GROUP.MEMBER.REMOVE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_MEMBER_REORDER = "INSTANCE.BOOT.GROUP.MEMBER.REORDER";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_CREATE = "INSTANCE.BOOT.GROUP.READINESS.RULE.CREATE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_UPDATE = "INSTANCE.BOOT.GROUP.READINESS.RULE.UPDATE";
+ public static final String EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_DELETE = "INSTANCE.BOOT.GROUP.READINESS.RULE.DELETE";
+
+
static {
// TODO: need a way to force author adding event types to declare the entity details as well, with out braking
@@ -1468,6 +1488,19 @@ public class EventTypes {
entityEventDetails.put(EVENT_DNS_RECORD_CREATE, DnsRecord.class);
entityEventDetails.put(EVENT_DNS_RECORD_DELETE, DnsRecord.class);
+ // Instance Boot Group
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_CREATE, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_DELETE, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_UPDATE, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_START, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_STOP, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_REBOOT, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_MEMBER_ADD, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_MEMBER_REMOVE, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_MEMBER_REORDER, InstanceBootGroup.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_CREATE, InstanceBootGroupReadinessRule.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_UPDATE, InstanceBootGroupReadinessRule.class);
+ entityEventDetails.put(EVENT_INSTANCE_BOOT_GROUP_READINESS_RULE_DELETE, InstanceBootGroupReadinessRule.class);
}
public static boolean isNetworkEvent(String eventType) {
diff --git a/api/src/main/java/com/cloud/host/Host.java b/api/src/main/java/com/cloud/host/Host.java
index 79bec7a5871a..cca250c2a90f 100644
--- a/api/src/main/java/com/cloud/host/Host.java
+++ b/api/src/main/java/com/cloud/host/Host.java
@@ -62,8 +62,18 @@ public static String[] toStrings(Host.Type... types) {
String HOST_VDDK_SUPPORT = "host.vddk.support";
String HOST_VDDK_LIB_DIR = "vddk.lib.dir";
String HOST_VDDK_VERSION = "host.vddk.version";
+ String HOST_VDDK_BLOCKCOPY_SUPPORT = "host.vddk.blockcopy.support";
+ String HOST_VDDK_BLOCKCOPY_INPLACE_FINALIZATION_SUPPORT = "host.vddk.blockcopy.inplace.finalization.support";
+ String HOST_VDDK_BLOCKCOPY_RBD_SUPPORT = "host.vddk.blockcopy.rbd.support";
+ String HOST_QEMU_IMG_VERSION = "host.qemu.img.version";
+ String HOST_QEMU_NBD_VERSION = "host.qemu.nbd.version";
+ String HOST_QEMU_IO_VERSION = "host.qemu.io.version";
String HOST_OVFTOOL_VERSION = "host.ovftool.version";
String HOST_VIRTV2V_VERSION = "host.virtv2v.version";
+ String HOST_VIRTV2V_INPLACE_VERSION = "host.virtv2v.inplace.version";
+ String HOST_VDDK_RBD_DIRECT_IMPORT_SUPPORT = "host.vddk.rbd.direct.import.support";
+ String HOST_VIRTV2V_INPLACE_SUPPORT = "host.virtv2v.inplace.support";
+ String HOST_QEMU_RBD_SUPPORT = "host.qemu.rbd.support";
String HOST_SSH_PORT = "host.ssh.port";
String HOST_CDROM_MAX_COUNT = "host.cdrom.max.count";
String GUEST_OS_CATEGORY_ID = "guest.os.category.id";
diff --git a/api/src/main/java/org/apache/cloudstack/api/ApiCommandResourceType.java b/api/src/main/java/org/apache/cloudstack/api/ApiCommandResourceType.java
index 2aa97b65a3d5..e12a709e6f5c 100644
--- a/api/src/main/java/org/apache/cloudstack/api/ApiCommandResourceType.java
+++ b/api/src/main/java/org/apache/cloudstack/api/ApiCommandResourceType.java
@@ -22,6 +22,7 @@
import java.util.Map;
import org.apache.cloudstack.region.PortableIp;
+import org.apache.cloudstack.vm.bootgroup.readiness.InstanceBootGroupReadinessRule;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.EnumUtils;
import org.apache.commons.lang3.StringUtils;
@@ -91,7 +92,9 @@ public enum ApiCommandResourceType {
Extension(org.apache.cloudstack.extension.Extension.class),
ExtensionCustomAction(org.apache.cloudstack.extension.ExtensionCustomAction.class),
KmsKey(org.apache.cloudstack.kms.KMSKey.class),
- HsmProfile(org.apache.cloudstack.kms.HSMProfile.class);
+ HsmProfile(org.apache.cloudstack.kms.HSMProfile.class),
+ InstanceBootGroup(org.apache.cloudstack.vm.bootgroup.InstanceBootGroup.class),
+ InstanceBootGroupReadinessRule(InstanceBootGroupReadinessRule.class);
private final Class clazz;
diff --git a/api/src/main/java/org/apache/cloudstack/api/ApiConstants.java b/api/src/main/java/org/apache/cloudstack/api/ApiConstants.java
index f74c46161180..12cc2ba20c25 100644
--- a/api/src/main/java/org/apache/cloudstack/api/ApiConstants.java
+++ b/api/src/main/java/org/apache/cloudstack/api/ApiConstants.java
@@ -93,6 +93,23 @@ public class ApiConstants {
public static final String CAPACITY = "capacity";
public static final String CATEGORY = "category";
public static final String CAN_REVERT = "canrevert";
+ public static final String BOOT_GROUP_ID = "bootgroupid";
+ public static final String BOOT_ORDER = "order";
+ public static final String MEMBER_TYPE = "membertype";
+ public static final String MEMBER_ID = "memberid";
+ public static final String MEMBER_NAME = "membername";
+ public static final String MEMBER_STATE = "memberstate";
+ public static final String CHILDREN = "children";
+ public static final String RULE_TYPE = "ruletype";
+ public static final String INHERITED = "inherited";
+ public static final String READINESS_MODE = "readinessmode";
+ public static final String READINESS_STATUS = "readinessstatus";
+ public static final String READINESS_MESSAGE = "readinessmessage";
+ public static final String READINESS_ATTEMPT_TIMEOUT_SECONDS = "readinessattempttimeoutseconds";
+ public static final String READINESS_MAX_RETRY_ATTEMPTS = "readinessmaxretryattempts";
+ public static final String READINESS_REBOOT_ON_RETRY = "readinessrebootonretry";
+ public static final String READINESS_INITIAL_DELAY_SECONDS = "readinessinitialdelayseconds";
+ public static final String IGNORE_INSTANCE_STATE = "ignoreinstancestate";
public static final String CA_CERTIFICATES = "cacertificates";
public static final String CERTIFICATE = "certificate";
public static final String CERTIFICATE_CHAIN = "certchain";
@@ -322,6 +339,7 @@ public class ApiConstants {
public static final String INTERNAL_DNS2 = "internaldns2";
public static final String INTERNET_PROTOCOL = "internetprotocol";
public static final String INTERVAL_TYPE = "intervaltype";
+ public static final String INSTANCE_GROUP_ID = "instancegroupid";
public static final String INSTANCE_LEASE_DURATION = "leaseduration";
public static final String INSTANCE_LEASE_ENABLED = "instanceleaseenabled";
public static final String INSTANCE_LEASE_EXPIRY_ACTION = "leaseexpiryaction";
@@ -653,6 +671,29 @@ public class ApiConstants {
public static final String USER_SECURITY_GROUP_LIST = "usersecuritygrouplist";
public static final String USER_SECRET_KEY = "usersecretkey";
public static final String USE_VDDK = "usevddk";
+ public static final String VMWARE_MIGRATION_MODE = "vmwaremigrationmode";
+ public static final String VMWARE_CBT_MIGRATION_ID = "vmwarecbtmigrationid";
+ public static final String SOURCE_HOST = "sourcehost";
+ public static final String SOURCE_CLUSTER = "sourcecluster";
+ public static final String SOURCE_VM_NAME = "sourcevmname";
+ public static final String SOURCE_DISK_ID = "sourcediskid";
+ public static final String SOURCE_DISK_DEVICE_KEY = "sourcediskdevicekey";
+ public static final String SOURCE_DISK_PATH = "sourcediskpath";
+ public static final String TARGET_PATH = "targetpath";
+ public static final String TARGET_FORMAT = "targetformat";
+ public static final String CHANGE_ID = "changeid";
+ public static final String SNAPSHOT_MOR = "snapshotmor";
+ public static final String CURRENT_STEP = "currentstep";
+ public static final String LAST_ERROR = "lasterror";
+ public static final String COMPLETED_CYCLES = "completedcycles";
+ public static final String QUIET_CYCLES = "quietcycles";
+ public static final String LAST_CHANGED_BYTES = "lastchangedbytes";
+ public static final String LAST_DIRTY_RATE = "lastdirtyrate";
+ public static final String TOTAL_CHANGED_BYTES = "totalchangedbytes";
+ public static final String CYCLE = "cycle";
+ public static final String CYCLE_NUMBER = "cyclenumber";
+ public static final String CHANGED_BYTES = "changedbytes";
+ public static final String DIRTY_RATE = "dirtyrate";
public static final String USE_VIRTUAL_NETWORK = "usevirtualnetwork";
public static final String USE_VIRTUAL_ROUTER_IP_RESOLVER = "userouteripresolver";
public static final String UPDATE_IN_SEQUENCE = "updateinsequence";
diff --git a/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CancelVmwareCbtMigrationCmd.java b/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CancelVmwareCbtMigrationCmd.java
new file mode 100644
index 000000000000..fa4fc4f7bb6f
--- /dev/null
+++ b/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CancelVmwareCbtMigrationCmd.java
@@ -0,0 +1,73 @@
+// 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 javax.inject.Inject;
+
+import org.apache.cloudstack.acl.RoleType;
+import org.apache.cloudstack.api.APICommand;
+import org.apache.cloudstack.api.ApiConstants;
+import org.apache.cloudstack.api.BaseCmd;
+import org.apache.cloudstack.api.Parameter;
+import org.apache.cloudstack.api.ResponseObject;
+import org.apache.cloudstack.api.ServerApiException;
+import org.apache.cloudstack.api.response.VmwareCbtMigrationResponse;
+import org.apache.cloudstack.context.CallContext;
+import org.apache.cloudstack.vm.VmwareCbtMigrationManager;
+
+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 com.cloud.user.Account;
+
+@APICommand(name = "cancelVmwareCbtMigration",
+ description = "Cancel a VMware CBT migration session",
+ responseObject = VmwareCbtMigrationResponse.class,
+ responseView = ResponseObject.ResponseView.Full,
+ requestHasSensitiveInfo = false,
+ responseHasSensitiveInfo = false,
+ authorized = {RoleType.Admin},
+ since = "4.24.0")
+public class CancelVmwareCbtMigrationCmd extends BaseCmd {
+
+ @Inject
+ public VmwareCbtMigrationManager vmwareCbtMigrationManager;
+
+ @Parameter(name = ApiConstants.ID, type = CommandType.UUID, entityType = VmwareCbtMigrationResponse.class,
+ required = true, description = "the VMware CBT migration ID")
+ private Long id;
+
+ public Long getId() {
+ return id;
+ }
+
+ @Override
+ public void execute() throws ResourceUnavailableException, InsufficientCapacityException, ServerApiException,
+ ConcurrentOperationException, ResourceAllocationException, NetworkRuleConflictException {
+ VmwareCbtMigrationResponse response = vmwareCbtMigrationManager.cancelVmwareCbtMigration(this);
+ response.setResponseName(getCommandName());
+ setResponseObject(response);
+ }
+
+ @Override
+ public long getEntityOwnerId() {
+ Account account = CallContext.current().getCallingAccount();
+ return account == null ? Account.ACCOUNT_ID_SYSTEM : account.getId();
+ }
+}
diff --git a/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CheckVmwareCbtMigrationPrerequisitesCmd.java b/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CheckVmwareCbtMigrationPrerequisitesCmd.java
new file mode 100644
index 000000000000..cbbadc090ce5
--- /dev/null
+++ b/api/src/main/java/org/apache/cloudstack/api/command/admin/vm/CheckVmwareCbtMigrationPrerequisitesCmd.java
@@ -0,0 +1,204 @@
+// 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 java.util.HashMap;
+import java.util.Map;
+
+import javax.inject.Inject;
+
+import org.apache.cloudstack.acl.RoleType;
+import org.apache.cloudstack.api.APICommand;
+import org.apache.cloudstack.api.ApiConstants;
+import org.apache.cloudstack.api.BaseCmd;
+import org.apache.cloudstack.api.Parameter;
+import org.apache.cloudstack.api.ResponseObject;
+import org.apache.cloudstack.api.ServerApiException;
+import org.apache.cloudstack.api.response.ClusterResponse;
+import org.apache.cloudstack.api.response.HostResponse;
+import org.apache.cloudstack.api.response.ServiceOfferingResponse;
+import org.apache.cloudstack.api.response.StoragePoolResponse;
+import org.apache.cloudstack.api.response.VmwareCbtMigrationPreflightResponse;
+import org.apache.cloudstack.api.response.VmwareDatacenterResponse;
+import org.apache.cloudstack.api.response.ZoneResponse;
+import org.apache.cloudstack.context.CallContext;
+import org.apache.cloudstack.vm.VmwareCbtMigrationManager;
+import org.apache.commons.collections.MapUtils;
+
+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 com.cloud.user.Account;
+
+@APICommand(name = "checkVmwareCbtMigrationPrerequisites",
+ description = "Check whether a VMware VM and KVM destination are ready for VMware CBT based migration",
+ responseObject = VmwareCbtMigrationPreflightResponse.class,
+ responseView = ResponseObject.ResponseView.Full,
+ requestHasSensitiveInfo = true,
+ responseHasSensitiveInfo = false,
+ authorized = {RoleType.Admin},
+ since = "4.24.0")
+public class CheckVmwareCbtMigrationPrerequisitesCmd extends BaseCmd {
+
+ @Inject
+ public VmwareCbtMigrationManager vmwareCbtMigrationManager;
+
+ @Parameter(name = ApiConstants.ZONE_ID, type = CommandType.UUID, entityType = ZoneResponse.class,
+ required = true, description = "the destination zone ID")
+ private Long zoneId;
+
+ @Parameter(name = ApiConstants.CLUSTER_ID, type = CommandType.UUID, entityType = ClusterResponse.class,
+ required = true, description = "the destination KVM cluster ID")
+ private Long clusterId;
+
+ @Parameter(name = ApiConstants.SOURCE_VM_NAME, type = CommandType.STRING,
+ required = true, description = "the source VMware VM name")
+ private String sourceVmName;
+
+ @Parameter(name = ApiConstants.EXISTING_VCENTER_ID, type = CommandType.UUID, entityType = VmwareDatacenterResponse.class,
+ description = "UUID of a linked existing vCenter")
+ private Long existingVcenterId;
+
+ @Parameter(name = ApiConstants.VCENTER, type = CommandType.STRING,
+ description = "the source vCenter IP address or FQDN")
+ private String vcenter;
+
+ @Parameter(name = ApiConstants.DATACENTER_NAME, type = CommandType.STRING,
+ description = "the source VMware datacenter name")
+ private String datacenterName;
+
+ @Parameter(name = ApiConstants.CLUSTER_NAME, type = CommandType.STRING,
+ description = "the source VMware cluster name")
+ private String sourceCluster;
+
+ @Parameter(name = ApiConstants.HOST_IP, type = CommandType.STRING,
+ description = "the source VMware ESXi host IP address or FQDN")
+ private String sourceHost;
+
+ @Parameter(name = ApiConstants.USERNAME, type = CommandType.STRING,
+ description = "the username for the source vCenter")
+ private String username;
+
+ @Parameter(name = ApiConstants.PASSWORD, type = CommandType.STRING,
+ description = "the password for the source vCenter")
+ private String password;
+
+ @Parameter(name = ApiConstants.CONVERT_INSTANCE_HOST_ID, type = CommandType.UUID, entityType = HostResponse.class,
+ description = "optional KVM host to perform CBT block replication")
+ private Long convertInstanceHostId;
+
+ @Parameter(name = ApiConstants.CONVERT_INSTANCE_STORAGE_POOL_ID, type = CommandType.UUID, entityType = StoragePoolResponse.class,
+ description = "optional primary storage pool for converted disks")
+ private Long storagePoolId;
+
+ @Parameter(name = ApiConstants.SERVICE_OFFERING_ID, type = CommandType.UUID, entityType = ServiceOfferingResponse.class,
+ description = "optional service offering to validate against the source VM CPU and memory requirements")
+ private Long serviceOfferingId;
+
+ @Parameter(name = ApiConstants.DETAILS, type = CommandType.MAP,
+ description = "optional service offering custom parameters and migration details")
+ private Map details;
+
+ public Long getZoneId() {
+ return zoneId;
+ }
+
+ public Long getClusterId() {
+ return clusterId;
+ }
+
+ public String getSourceVmName() {
+ return sourceVmName;
+ }
+
+ public Long getExistingVcenterId() {
+ return existingVcenterId;
+ }
+
+ public String getVcenter() {
+ return vcenter;
+ }
+
+ public String getDatacenterName() {
+ return datacenterName;
+ }
+
+ public String getSourceCluster() {
+ return sourceCluster;
+ }
+
+ public String getSourceHost() {
+ return sourceHost;
+ }
+
+ public String getUsername() {
+ return username;
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public Long getConvertInstanceHostId() {
+ return convertInstanceHostId;
+ }
+
+ public Long getStoragePoolId() {
+ return storagePoolId;
+ }
+
+ public Long getServiceOfferingId() {
+ return serviceOfferingId;
+ }
+
+ @SuppressWarnings("unchecked")
+ public Map \
+ clustername=