/* * Copyright (c) Citrix Systems, Inc. * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1) Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2) Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the following * disclaimer in the documentation and/or other materials * provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED * OF THE POSSIBILITY OF SUCH DAMAGE. */ package com.xensource.xenapi; import com.xensource.xenapi.Types.BadServerResponse; import com.xensource.xenapi.Types.VersionException; import com.xensource.xenapi.Types.XenAPIException; import java.io.PrintWriter; import java.io.StringWriter; import java.util.Date; import java.util.HashMap; import java.util.LinkedHashSet; import java.util.Map; import java.util.Set; import org.apache.xmlrpc.XmlRpcException; /** * VM appliance * * @author Citrix Systems, Inc. */ public class VMAppliance extends XenAPIObject { /** * The XenAPI reference (OpaqueRef) to this object. */ protected final String ref; /** * For internal use only. */ VMAppliance(String ref) { this.ref = ref; } /** * @return The XenAPI reference (OpaqueRef) to this object. */ public String toWireString() { return this.ref; } /** * If obj is a VMAppliance, compares XenAPI references for equality. */ @Override public boolean equals(Object obj) { if (obj != null && obj instanceof VMAppliance) { VMAppliance other = (VMAppliance) obj; return other.ref.equals(this.ref); } else { return false; } } @Override public int hashCode() { return ref.hashCode(); } /** * Represents all the fields in a VMAppliance */ public static class Record implements Types.Record { public String toString() { StringWriter writer = new StringWriter(); PrintWriter print = new PrintWriter(writer); print.printf("%1$20s: %2$s\n", "uuid", this.uuid); print.printf("%1$20s: %2$s\n", "nameLabel", this.nameLabel); print.printf("%1$20s: %2$s\n", "nameDescription", this.nameDescription); print.printf("%1$20s: %2$s\n", "allowedOperations", this.allowedOperations); print.printf("%1$20s: %2$s\n", "currentOperations", this.currentOperations); print.printf("%1$20s: %2$s\n", "VMs", this.VMs); return writer.toString(); } /** * Convert a VM_appliance.Record to a Map */ public Map toMap() { Map map = new HashMap(); map.put("uuid", this.uuid == null ? "" : this.uuid); map.put("name_label", this.nameLabel == null ? "" : this.nameLabel); map.put("name_description", this.nameDescription == null ? "" : this.nameDescription); map.put("allowed_operations", this.allowedOperations == null ? new LinkedHashSet() : this.allowedOperations); map.put("current_operations", this.currentOperations == null ? new HashMap() : this.currentOperations); map.put("VMs", this.VMs == null ? new LinkedHashSet() : this.VMs); return map; } /** * Unique identifier/object reference */ public String uuid; /** * a human-readable name */ public String nameLabel; /** * a notes field containing human-readable description */ public String nameDescription; /** * list of the operations allowed in this state. This list is advisory only and the server state may have changed by the time this field is read by a client. */ public Set allowedOperations; /** * links each of the running tasks using this object (by reference) to a current_operation enum which describes the nature of the task. */ public Map currentOperations; /** * all VMs in this appliance */ public Set VMs; } /** * Get a record containing the current state of the given VM_appliance. * * @return all fields from the object */ public VMAppliance.Record getRecord(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_record"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toVMApplianceRecord(result); } /** * Get a reference to the VM_appliance instance with the specified UUID. * * @param uuid UUID of object to return * @return reference to the object */ public static VMAppliance getByUuid(Connection c, String uuid) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_by_uuid"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(uuid)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toVMAppliance(result); } /** * Create a new VM_appliance instance, and return its handle. * * @param record All constructor arguments * @return Task */ public static Task createAsync(Connection c, VMAppliance.Record record) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "Async.VM_appliance.create"; String session = c.getSessionReference(); Map record_map = record.toMap(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(record_map)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Create a new VM_appliance instance, and return its handle. * * @param record All constructor arguments * @return reference to the newly created object */ public static VMAppliance create(Connection c, VMAppliance.Record record) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.create"; String session = c.getSessionReference(); Map record_map = record.toMap(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(record_map)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toVMAppliance(result); } /** * Destroy the specified VM_appliance instance. * * @return Task */ public Task destroyAsync(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "Async.VM_appliance.destroy"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Destroy the specified VM_appliance instance. * */ public void destroy(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.destroy"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); return; } /** * Get all the VM_appliance instances with the given label. * * @param label label of object to return * @return references to objects with matching names */ public static Set getByNameLabel(Connection c, String label) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_by_name_label"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(label)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toSetOfVMAppliance(result); } /** * Get the uuid field of the given VM_appliance. * * @return value of the field */ public String getUuid(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_uuid"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toString(result); } /** * Get the name/label field of the given VM_appliance. * * @return value of the field */ public String getNameLabel(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_name_label"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toString(result); } /** * Get the name/description field of the given VM_appliance. * * @return value of the field */ public String getNameDescription(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_name_description"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toString(result); } /** * Get the allowed_operations field of the given VM_appliance. * * @return value of the field */ public Set getAllowedOperations(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_allowed_operations"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toSetOfVmApplianceOperation(result); } /** * Get the current_operations field of the given VM_appliance. * * @return value of the field */ public Map getCurrentOperations(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_current_operations"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toMapOfStringVmApplianceOperation(result); } /** * Get the VMs field of the given VM_appliance. * * @return value of the field */ public Set getVMs(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_VMs"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toSetOfVM(result); } /** * Set the name/label field of the given VM_appliance. * * @param label New value to set */ public void setNameLabel(Connection c, String label) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.set_name_label"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(label)}; Map response = c.dispatch(method_call, method_params); return; } /** * Set the name/description field of the given VM_appliance. * * @param description New value to set */ public void setNameDescription(Connection c, String description) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.set_name_description"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(description)}; Map response = c.dispatch(method_call, method_params); return; } /** * Start all VMs in the appliance * * @param paused Instantiate all VMs belonging to this appliance in paused state if set to true. * @return Task */ public Task startAsync(Connection c, Boolean paused) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "Async.VM_appliance.start"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(paused)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Start all VMs in the appliance * * @param paused Instantiate all VMs belonging to this appliance in paused state if set to true. */ public void start(Connection c, Boolean paused) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "VM_appliance.start"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(paused)}; Map response = c.dispatch(method_call, method_params); return; } /** * Perform a clean shutdown of all the VMs in the appliance * * @return Task */ public Task cleanShutdownAsync(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "Async.VM_appliance.clean_shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Perform a clean shutdown of all the VMs in the appliance * */ public void cleanShutdown(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "VM_appliance.clean_shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); return; } /** * Perform a hard shutdown of all the VMs in the appliance * * @return Task */ public Task hardShutdownAsync(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "Async.VM_appliance.hard_shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Perform a hard shutdown of all the VMs in the appliance * */ public void hardShutdown(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "VM_appliance.hard_shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); return; } /** * For each VM in the appliance, try to shut it down cleanly. If this fails, perform a hard shutdown of the VM. * * @return Task */ public Task shutdownAsync(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "Async.VM_appliance.shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * For each VM in the appliance, try to shut it down cleanly. If this fails, perform a hard shutdown of the VM. * */ public void shutdown(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException, Types.OperationPartiallyFailed { String method_call = "VM_appliance.shutdown"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref)}; Map response = c.dispatch(method_call, method_params); return; } /** * Assert whether all SRs required to recover this VM appliance are available. * * @param sessionTo The session to which the VM appliance is to be recovered. * @return Task */ public Task assertCanBeRecoveredAsync(Connection c, Session sessionTo) throws BadServerResponse, XenAPIException, XmlRpcException, Types.VmRequiresSr { String method_call = "Async.VM_appliance.assert_can_be_recovered"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(sessionTo)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Assert whether all SRs required to recover this VM appliance are available. * * @param sessionTo The session to which the VM appliance is to be recovered. */ public void assertCanBeRecovered(Connection c, Session sessionTo) throws BadServerResponse, XenAPIException, XmlRpcException, Types.VmRequiresSr { String method_call = "VM_appliance.assert_can_be_recovered"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(sessionTo)}; Map response = c.dispatch(method_call, method_params); return; } /** * Recover the VM appliance * * @param sessionTo The session to which the VM appliance is to be recovered. * @param force Whether the VMs should replace newer versions of themselves. * @return Task */ public Task recoverAsync(Connection c, Session sessionTo, Boolean force) throws BadServerResponse, XenAPIException, XmlRpcException, Types.VmRequiresSr { String method_call = "Async.VM_appliance.recover"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(sessionTo), Marshalling.toXMLRPC(force)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toTask(result); } /** * Recover the VM appliance * * @param sessionTo The session to which the VM appliance is to be recovered. * @param force Whether the VMs should replace newer versions of themselves. */ public void recover(Connection c, Session sessionTo, Boolean force) throws BadServerResponse, XenAPIException, XmlRpcException, Types.VmRequiresSr { String method_call = "VM_appliance.recover"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(this.ref), Marshalling.toXMLRPC(sessionTo), Marshalling.toXMLRPC(force)}; Map response = c.dispatch(method_call, method_params); return; } /** * Return a list of all the VM_appliances known to the system. * * @return references to all objects */ public static Set getAll(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_all"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toSetOfVMAppliance(result); } /** * Return a map of VM_appliance references to VM_appliance records for all VM_appliances known to the system. * * @return records of all objects */ public static Map getAllRecords(Connection c) throws BadServerResponse, XenAPIException, XmlRpcException { String method_call = "VM_appliance.get_all_records"; String session = c.getSessionReference(); Object[] method_params = {Marshalling.toXMLRPC(session)}; Map response = c.dispatch(method_call, method_params); Object result = response.get("Value"); return Types.toMapOfVMApplianceVMApplianceRecord(result); } }