<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40"> <head> <META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=us-ascii"> <meta name=Generator content="Microsoft Word 12 (filtered medium)"> <style>  </style>  </head> <body lang=EN-US link=blue vlink=purple> <div class=Section1> Resending patch 3/4 which didn’t reach the first time seemingly. <o:p></o:p> <o:p> </o:p> diff -Nur ./libvirt_org/src/xenapi/xenapi_driver.c ./libvirt/src/xenapi/xenapi_driver.c<o:p></o:p> --- ./libvirt_org/src/xenapi/xenapi_driver.c 1970-01-01 01:00:00.000000000 +0100<o:p></o:p> +++ ./libvirt/src/xenapi/xenapi_driver.c 2010-02-18 16:26:13.000000000 +0000<o:p></o:p> @@ -0,0 +1,1774 @@<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> + * xenapi_driver.c: Xen API driver.<o:p></o:p> + * Copyright (C) 2009 Citrix Ltd.<o:p></o:p> + * Sharadha Prabhakar <sharadha.prabhakar@citrix.com><o:p></o:p> +*/<o:p></o:p> +<o:p></o:p> +#include <config.h><o:p></o:p> +#include <stdint.h><o:p></o:p> +#include <unistd.h><o:p></o:p> +#include <string.h><o:p></o:p> +#include <stdlib.h><o:p></o:p> +#include <errno.h><o:p></o:p> +#include <sys/types.h><o:p></o:p> +#include <libxml/uri.h><o:p></o:p> +#include <xen_internal.h><o:p></o:p> +#include <libxml/parser.h><o:p></o:p> +#include <curl/curl.h><o:p></o:p> +#include <xen/api/xen_common.h><o:p></o:p> +#include <xen/api/xen_vm.h><o:p></o:p> +#include <xen/api/xen_vm.h><o:p></o:p> +#include <xen/api/xen_all.h><o:p></o:p> +#include <xen/api/xen_vm_metrics.h><o:p></o:p> +<o:p></o:p> +#include "libvirt_internal.h"<o:p></o:p> +#include "libvirt/libvirt.h"<o:p></o:p> +#include "virterror_internal.h"<o:p></o:p> +#include "datatypes.h"<o:p></o:p> +#include "xenapi_driver.h"<o:p></o:p> +#include "util.h"<o:p></o:p> +#include "uuid.h"<o:p></o:p> +#include "memory.h"<o:p></o:p> +#include "driver.h"<o:p></o:p> +#include "buf.h"<o:p></o:p> +#include "xenapi_utils.h"<o:p></o:p> +<o:p></o:p> +char *url;<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +*XenapiOpen<o:p></o:p> +*<o:p></o:p> +*Authenticates and creates a session with the server<o:p></o:p> +*Return VIR_DRV_OPEN_SUCCESS on success, else VIR_DRV_OPEN_ERROR<o:p></o:p> +*/<o:p></o:p> +static virDrvOpenStatus<o:p></o:p> +xenapiOpen (virConnectPtr conn, virConnectAuthPtr auth ATTRIBUTE_UNUSED, int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + char *user,*passwd;<o:p></o:p> + char delims[]=":";<o:p></o:p> + xen_session *session;<o:p></o:p> + struct _xenapiPrivate *privP;<o:p></o:p> +<o:p></o:p> + if (!STREQ(conn->uri->scheme,"XenAPI")) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_AUTH_FAILED ,"Check URI format: 'XenAPI://user:password@server'", __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return VIR_DRV_OPEN_ERROR;<o:p></o:p> + }<o:p></o:p> + if (conn->uri->server==NULL) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_AUTH_FAILED ,"Server name not in URI", __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return VIR_DRV_OPEN_ERROR;<o:p></o:p> + } <o:p></o:p> + <o:p></o:p> + user = strtok(conn->uri->user,delims);<o:p></o:p> + passwd = strtok(NULL,delims);<o:p></o:p> +<o:p></o:p> + <o:p></o:p> +<o:p></o:p> + url = (char *)malloc(strlen("https://")+strlen(conn->uri->server)+1);<o:p></o:p> + strcpy(url,"https://");<o:p></o:p> + strcat(url,conn->uri->server);<o:p></o:p> + url[strlen("https://")+strlen(conn->uri->server)]='\0';<o:p></o:p> +<o:p></o:p> + xmlInitParser();<o:p></o:p> + xmlKeepBlanksDefault(0);<o:p></o:p> + xen_init();<o:p></o:p> + curl_global_init(CURL_GLOBAL_ALL);<o:p></o:p> + <o:p></o:p> + session = xen_session_login_with_password( call_func, NULL, user, passwd, xen_api_latest_version);<o:p></o:p> +<o:p></o:p> + if ( session != NULL && session->ok ) {<o:p></o:p> + privP = malloc(sizeof(struct _xenapiPrivate));<o:p></o:p> + privP->session = session;<o:p></o:p> + conn->privateData = privP;<o:p></o:p> + return VIR_DRV_OPEN_SUCCESS;<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_AUTH_FAILED ,"", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return VIR_DRV_OPEN_ERROR;<o:p></o:p> + } <o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiClose:<o:p></o:p> +*<o:p></o:p> +* Returns 0 on successful session logout<o:p></o:p> +*<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiClose (virConnectPtr conn)<o:p></o:p> +{<o:p></o:p> + xen_session_logout(((struct _xenapiPrivate *)(conn->privateData))->session);<o:p></o:p> + VIR_FREE(conn->privateData);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +*<o:p></o:p> +* xenapiSupportsFeature<o:p></o:p> +*<o:p></o:p> +* Returns 0 <o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiSupportsFeature (virConnectPtr conn ATTRIBUTE_UNUSED, int feature)<o:p></o:p> +{<o:p></o:p> + switch (feature) {<o:p></o:p> + case VIR_DRV_FEATURE_MIGRATION_V2:<o:p></o:p> + case VIR_DRV_FEATURE_MIGRATION_P2P:<o:p></o:p> + default:<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiType:<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +*Returns name of the driver<o:p></o:p> +*/<o:p></o:p> +static const char *<o:p></o:p> +xenapiType (virConnectPtr conn ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + return "XenAPI";<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiGetVersion:<o:p></o:p> +*<o:p></o:p> +* Gets the version of XenAPI<o:p></o:p> +*<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiGetVersion (virConnectPtr conn ATTRIBUTE_UNUSED, unsigned long *hvVer)<o:p></o:p> +{<o:p></o:p> + *hvVer = 1;<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiGetHostname:<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +* Returns the hostname on success, or NULL on failure<o:p></o:p> +*/<o:p></o:p> +static char *<o:p></o:p> +xenapiGetHostname (virConnectPtr conn)<o:p></o:p> +{<o:p></o:p> + char *result;<o:p></o:p> + xen_host host;<o:p></o:p> +<o:p></o:p> + if (!(xen_session_get_this_host(((struct _xenapiPrivate *)(conn->privateData))->session, &host,<o:p></o:p> + ((struct _xenapiPrivate *)(conn->privateData))->session))) {<o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) <o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE ,"Unable to find host", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return NULL;<o:p></o:p> + } <o:p></o:p> + xen_host_get_hostname(((struct _xenapiPrivate *)(conn->privateData))->session, &result, host);<o:p></o:p> + xen_host_free(host);<o:p></o:p> + return result;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiGetMAxVcpus:<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +* Returns a hardcoded value for Maximum VCPUS<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiGetMaxVcpus (virConnectPtr conn ATTRIBUTE_UNUSED, const char *type ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + /* this is hardcoded for simplicity and set to a resonable value compared<o:p></o:p> + to the actual value */<o:p></o:p> + return 16;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiNodeGetInfo:<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +* Returns Node details on success or else -1<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiNodeGetInfo (virConnectPtr conn, virNodeInfoPtr info)<o:p></o:p> +{<o:p></o:p> + int64_t memory,mhz;<o:p></o:p> + xen_host_cpu_set *host_cpu_set;<o:p></o:p> + xen_host_cpu host_cpu;<o:p></o:p> + xen_host_metrics_set *xen_met_set;<o:p></o:p> + char *modelname;<o:p></o:p> + info->nodes = 1;<o:p></o:p> + info->threads = 1;<o:p></o:p> + info->sockets = 1;<o:p></o:p> +<o:p></o:p> + if (xen_host_metrics_get_all(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &xen_met_set)) { <o:p></o:p> + xen_host_metrics_get_memory_total(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &memory, xen_met_set->contents[0]);<o:p></o:p> + info->memory = (unsigned long)(memory/1024); <o:p></o:p> + xen_host_metrics_set_free(xen_met_set);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR ,"Unable to get host metric Information",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + if (xen_host_cpu_get_all(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &host_cpu_set)) { <o:p></o:p> + host_cpu = host_cpu_set->contents[0];<o:p></o:p> + xen_host_cpu_get_modelname(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &modelname, host_cpu); <o:p></o:p> + strncpy(info->model, modelname, LIBVIRT_MODELNAME_LEN-2);<o:p></o:p> + info->model[LIBVIRT_MODELNAME_LEN-1]='\0';<o:p></o:p> + xen_host_cpu_get_speed(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &mhz, host_cpu);<o:p></o:p> + info->mhz = (unsigned long)mhz; <o:p></o:p> + info->cpus = host_cpu_set->size;<o:p></o:p> + info->cores = host_cpu_set->size;<o:p></o:p> +<o:p></o:p> + xen_host_cpu_set_free(host_cpu_set);<o:p></o:p> + free(modelname);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR ,"Unable to get Host CPU set",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return -1; <o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiGetCapabilities:<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +* Returns capabilities as an XML string<o:p></o:p> +*/<o:p></o:p> +static char *<o:p></o:p> +xenapiGetCapabilities (virConnectPtr conn ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + virBuffer buf = VIR_BUFFER_INITIALIZER;<o:p></o:p> + virBufferAddLit(&buf, "<capabilities>\n");<o:p></o:p> + virBufferAddLit(&buf, "<host>\n");<o:p></o:p> + virBufferAddLit(&buf, " <cpu></cpu>\n");<o:p></o:p> + virBufferAddLit(&buf, "</host>");<o:p></o:p> + virBufferAddLit(&buf, "<guest>\n");<o:p></o:p> + virBufferAddLit(&buf, "<os_type>hvm</os_type>\n");<o:p></o:p> + virBufferAddLit(&buf, "<arch>\n");<o:p></o:p> + virBufferAddLit(&buf, "<domain type='xenapi'></domain>\n");<o:p></o:p> + virBufferAddLit(&buf, "</arch>\n");<o:p></o:p> + virBufferAddLit(&buf, "</guest>\n");<o:p></o:p> + virBufferAddLit(&buf, "</capabilities>\n");<o:p></o:p> + return virBufferContentAndReset(&buf);<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiListDomains<o:p></o:p> +*<o:p></o:p> +* Collects the list of active domains, and store their ID in @maxids<o:p></o:p> +* Returns the number of domain found or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiListDomains (virConnectPtr conn, int *ids, int maxids)<o:p></o:p> +{<o:p></o:p> + /* vm.list */<o:p></o:p> + int i,list;<o:p></o:p> + xen_host host;<o:p></o:p> + xen_vm_set *result=NULL;<o:p></o:p> + if (xen_session_get_this_host(((struct _xenapiPrivate *)(conn->privateData))->session, &host,<o:p></o:p> + ((struct _xenapiPrivate *)(conn->privateData))->session)) {<o:p></o:p> + xen_host_get_resident_vms(((struct _xenapiPrivate *)(conn->privateData))->session, &result, host);<o:p></o:p> + xen_host_free(host);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE ,NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + } <o:p></o:p> + if (result != NULL) {<o:p></o:p> + for ( i=0; (i < (result->size)) && (i<maxids) ; i++ ) {<o:p></o:p> + int64_t t0;<o:p></o:p> + xen_vm_get_domid(((struct _xenapiPrivate *)(conn->privateData))->session, &t0, result->contents[i]);<o:p></o:p> + ids[i] = (int)(t0 & 0xffffffff);<o:p></o:p> + }<o:p></o:p> + list = result->size;<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + return list;<o:p></o:p> + }<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiNumOfDomains<o:p></o:p> +*<o:p></o:p> +* <o:p></o:p> +* Returns the number of domains found or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiNumOfDomains (virConnectPtr conn)<o:p></o:p> +{<o:p></o:p> + /* #(vm.list) */<o:p></o:p> + xen_vm_set *result=NULL;<o:p></o:p> + xen_host host=NULL;<o:p></o:p> + int numDomains=-1;<o:p></o:p> +<o:p></o:p> + xen_session_get_this_host(((struct _xenapiPrivate *)(conn->privateData))->session, &host,<o:p></o:p> + ((struct _xenapiPrivate *)(conn->privateData))->session); <o:p></o:p> + if ( host!=NULL ) {<o:p></o:p> + xen_host_get_resident_vms(((struct _xenapiPrivate *)(conn->privateData))->session, &result, host);<o:p></o:p> + if ( result != NULL) {<o:p></o:p> + numDomains = result->size;<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + }<o:p></o:p> + xen_host_free(host);<o:p></o:p> + }<o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) <o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return numDomains;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainCreateXML<o:p></o:p> +*<o:p></o:p> +* Launches a new domain based on the XML description<o:p></o:p> +* Returns the domain pointer or NULL in case of error<o:p></o:p> +*/<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainCreateXML (virConnectPtr conn,<o:p></o:p> + const char *xmlDesc, ATTRIBUTE_UNUSED unsigned int flags)<o:p></o:p> +{<o:p></o:p> + xen_vm_record *record=NULL;<o:p></o:p> + xen_vm vm=NULL;<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> + createVMRecordFromXml( conn, xmlDesc, &record, &vm);<o:p></o:p> + if (record!=NULL) {<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virUUIDParse(record->uuid,raw_uuid);<o:p></o:p> + if (vm!=NULL) {<o:p></o:p> + if (xen_vm_start(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + vm, false, false)) {<o:p></o:p> + domP = virGetDomain(conn, record->name_label, raw_uuid);<o:p></o:p> + xen_vm_free(vm);<o:p></o:p> + } <o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + }<o:p></o:p> + xen_vm_record_free(record); <o:p></o:p> + }<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return domP;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainLookupByID<o:p></o:p> +*<o:p></o:p> +* <o:p></o:p> +* Returns a valid domain pointer of the domain with ID same as the one passed<o:p></o:p> +* or NULL in case of error<o:p></o:p> +*/<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainLookupByID (virConnectPtr conn, int id)<o:p></o:p> +{<o:p></o:p> + int i;<o:p></o:p> + int64_t domID;<o:p></o:p> + char *uuid;<o:p></o:p> + xen_host host;<o:p></o:p> + xen_vm_set *result;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> +<o:p></o:p> + xen_session_get_this_host(((struct _xenapiPrivate *)(conn->privateData))->session, &host,<o:p></o:p> + ((struct _xenapiPrivate *)(conn->privateData))->session);<o:p></o:p> + if (host!=NULL && ((struct _xenapiPrivate *)(conn->privateData))->session->ok) { <o:p></o:p> + xen_host_get_resident_vms(((struct _xenapiPrivate *)(conn->privateData))->session, &result, host);<o:p></o:p> + if ( result !=NULL ) {<o:p></o:p> + for( i=0; i < (result->size); i++) {<o:p></o:p> + xen_vm_get_domid(((struct _xenapiPrivate *)(conn->privateData))->session, &domID, result->contents[i]);<o:p></o:p> + if ( domID == id ) {<o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(conn->privateData))->session, <o:p></o:p> + &record, result->contents[i]);<o:p></o:p> + xen_vm_get_uuid(((struct _xenapiPrivate *)(conn->privateData))->session, &uuid, result->contents[i]);<o:p></o:p> + virUUIDParse(uuid,raw_uuid);<o:p></o:p> + domP = virGetDomain(conn, record->name_label, raw_uuid);<o:p></o:p> + if (domP!=NULL) {<o:p></o:p> + int64_t domid=-1;<o:p></o:p> + xen_vm_get_domid(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &domid, result->contents[i]);<o:p></o:p> + domP->id = domid;<o:p></o:p> + }<o:p></o:p> + xen_uuid_free(uuid);<o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + }<o:p></o:p> + xen_host_free(host);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + }<o:p></o:p> + return domP;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainLookupByUUID<o:p></o:p> +*<o:p></o:p> +* Returns the domain pointer of domain with matching UUID <o:p></o:p> +* or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainLookupByUUID (virConnectPtr conn,<o:p></o:p> + const unsigned char *uuid)<o:p></o:p> +{<o:p></o:p> + /* vm.get_by_uuid */<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> + if (xen_vm_get_by_uuid(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &vm, (char *)uuid)) {<o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &record, vm);<o:p></o:p> + if (record != NULL) {<o:p></o:p> + virUUIDParse((char *)uuid,raw_uuid); <o:p></o:p> + domP = virGetDomain(conn, record->name_label, raw_uuid); <o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + }<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_free(vm); <o:p></o:p> + } else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return domP; <o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainLookupByName<o:p></o:p> +*<o:p></o:p> +* Returns the domain pointer of domain with matching name <o:p></o:p> +* or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainLookupByName (virConnectPtr conn,<o:p></o:p> + const char *name)<o:p></o:p> +{<o:p></o:p> + /* vm.get_by_name_label */<o:p></o:p> + xen_vm_set *vms=NULL;<o:p></o:p> + xen_vm vm;<o:p></o:p> + char *uuid=NULL;<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> + <o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &vms, (char *)name);<o:p></o:p> + if (vms!=NULL && vms->size!=0) { <o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + xen_vm_get_uuid(((struct _xenapiPrivate *)(conn->privateData))->session, <o:p></o:p> + &uuid, vm);<o:p></o:p> + if (uuid!=NULL) {<o:p></o:p> + virUUIDParse(uuid,raw_uuid);<o:p></o:p> + domP = virGetDomain(conn, name, raw_uuid); <o:p></o:p> + if (domP != NULL) {<o:p></o:p> + int64_t domid=-1;<o:p></o:p> + xen_vm_get_domid(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &domid, vm);<o:p></o:p> + domP->id = domid;<o:p></o:p> + xen_uuid_free(uuid);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return domP;<o:p></o:p> + } else {<o:p></o:p> + xen_uuid_free(uuid); <o:p></o:p> + xen_vm_set_free(vms); <o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + }<o:p></o:p> + return NULL;<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) {<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_NO_DOMAIN,NULL,__FILE__,__FUNCTION__, __LINE__);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_NO_DOMAIN,"Domain name not found",__FILE__,__FUNCTION__, __LINE__);<o:p></o:p> + }<o:p></o:p> + return NULL;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainSuspend<o:p></o:p> +*<o:p></o:p> +* a VM is paused<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSuspend (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + /* vm.pause() */<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + if (!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn,VIR_ERR_NO_DOMAIN,NULL,__FILE__,__FUNCTION__, __LINE__);<o:p></o:p> + return -1; <o:p></o:p> + } <o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_pause(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainResume<o:p></o:p> +*<o:p></o:p> +* Resumes a VM<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainResume (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + /* vm.unpause() */<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + if (!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1; <o:p></o:p> + } <o:p></o:p> + if (vms!=NULL && vms->size!=0) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_unpause(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1; <o:p></o:p> + } <o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + }<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainShutdown<o:p></o:p> +*<o:p></o:p> +* shutsdown a VM<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainShutdown (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + /* vm.clean_shutdown */<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + if(!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1; <o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_clean_shutdown(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainReboot<o:p></o:p> +*<o:p></o:p> +* Reboots a VM<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainReboot (virDomainPtr dom, unsigned int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + /* vm.clean_reboot */<o:p></o:p> + xen_vm vm;<o:p></o:p> + struct xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms==NULL || vms->size==0) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_clean_reboot(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomaindestroy<o:p></o:p> +*<o:p></o:p> +* A VM is hard shutdown<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainDestroy (virDomainPtr dom)<o:p></o:p> +{ <o:p></o:p> + /* vm.hard_shutdown */<o:p></o:p> + xen_vm vm;<o:p></o:p> + struct xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms==NULL || vms->size==0) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_hard_shutdown(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetOSType<o:p></o:p> +*<o:p></o:p> +* <o:p></o:p> +* Returns OS version on success or NULL in case of error<o:p></o:p> +*/<o:p></o:p> +static char *<o:p></o:p> +xenapiDomainGetOSType (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + /* vm.get_os-version */<o:p></o:p> + int i;<o:p></o:p> + xen_vm vm;<o:p></o:p> + char *os_version=NULL;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + xen_string_string_map *result;<o:p></o:p> + char uuid[VIR_UUID_STRING_BUFLEN];<o:p></o:p> + virUUIDFormat(dom->uuid,uuid);<o:p></o:p> + if (xen_vm_get_by_uuid(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vm, uuid)) { <o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &record, vm);<o:p></o:p> + if (record!=NULL) {<o:p></o:p> + xen_vm_guest_metrics_get_os_version(((struct _xenapiPrivate *)(dom->conn->privateData))->session, &result, <o:p></o:p> + record->guest_metrics->u.handle);<o:p></o:p> + if (result != NULL) {<o:p></o:p> + for (i=0; i<(result->size); i++) {<o:p></o:p> + if (STREQ(result->contents[i].key, "distro")) {<o:p></o:p> + if (STREQ(result->contents[i].val, "windows")) {<o:p></o:p> + os_version = strdup(result->contents[i].val);<o:p></o:p> + } else {<o:p></o:p> + os_version = strdup("linux");<o:p></o:p> + }<o:p></o:p> + } <o:p></o:p> + }<o:p></o:p> + xen_string_string_map_free(result);<o:p></o:p> + } else<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_OS, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + } else<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_free(vm);<o:p></o:p> + }<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + if ( os_version == NULL ) {<o:p></o:p> + os_version = strdup("unknown");<o:p></o:p> + } <o:p></o:p> + return os_version;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetMaxMemory<o:p></o:p> +*<o:p></o:p> +* Returns maximum static memory for VM on success <o:p></o:p> +* or 0 in case of error<o:p></o:p> +*/<o:p></o:p> +static unsigned long<o:p></o:p> +xenapiDomainGetMaxMemory (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + int64_t mem_static_max=0;<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms != NULL && vms->size!=0) {<o:p></o:p> + /* vm.get_memory_static_max */<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + xen_vm_get_memory_static_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &mem_static_max, vm); <o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return (unsigned long)(mem_static_max/1024);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainSetMaxMemory<o:p></o:p> +*<o:p></o:p> +* Sets maximum static memory for VM on success <o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSetMaxMemory (virDomainPtr dom, unsigned long memory)<o:p></o:p> +{<o:p></o:p> + /* vm.set_memory_static_max */<o:p></o:p> + xen_vm vm;<o:p></o:p> + struct xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms!=NULL && vms->size!=0) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!(xen_vm_set_memory_static_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session, <o:p></o:p> + vm, memory))) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSetMemory (virDomainPtr dom, unsigned long memory ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + /* XenAPI doesn't allow this function */<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetInfo:<o:p></o:p> +*<o:p></o:p> +* Fills a structure with domain information<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int <o:p></o:p> +xenapiDomainGetInfo (virDomainPtr dom, virDomainInfoPtr info)<o:p></o:p> +{<o:p></o:p> + int64_t maxmem=0,memory=0,vcpu=0;<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + info->cpuTime = 0; /* CPU time is not advertised */<o:p></o:p> + if (xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + xen_vm_get_memory_static_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &maxmem, vm);<o:p></o:p> + info->maxMem = (maxmem/1024); <o:p></o:p> + enum xen_vm_power_state state = XEN_VM_POWER_STATE_UNKNOWN;<o:p></o:p> + xen_vm_get_power_state(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &state, vm);<o:p></o:p> + info->state = mapPowerState(state); <o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &record, vm);<o:p></o:p> + if (record!=NULL) {<o:p></o:p> + xen_vm_metrics_get_memory_actual(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &memory, record->metrics->u.handle);<o:p></o:p> + info->memory = (memory/1024);<o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + } <o:p></o:p> + xen_vm_get_vcpus_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vcpu, vm);<o:p></o:p> + info->nrVirtCpu = vcpu; <o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainSave<o:p></o:p> +*<o:p></o:p> +* suspends a VM<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSave (virDomainPtr dom, const char *to ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + int ret_code = -1;<o:p></o:p> + ret_code = xenapiDomainSuspend(dom);<o:p></o:p> + return ret_code;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainRestore<o:p></o:p> +*<o:p></o:p> +* Resumes a VM<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainRestore (virConnectPtr conn, const char *from ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + /* resume from : NI */<o:p></o:p> + xen_vm_set *result=NULL;<o:p></o:p> + xen_host host=NULL;<o:p></o:p> + xen_vm_record *record = NULL;<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> + int ret_code=-1;<o:p></o:p> +<o:p></o:p> + xen_session_get_this_host(((struct _xenapiPrivate *)(conn->privateData))->session, &host,<o:p></o:p> + ((struct _xenapiPrivate *)(conn->privateData))->session);<o:p></o:p> + if ( host!=NULL ) {<o:p></o:p> + xen_host_get_resident_vms(((struct _xenapiPrivate *)(conn->privateData))->session, &result, host);<o:p></o:p> + if ( result != NULL ) {<o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &record, result->contents[0]);<o:p></o:p> + if (record!=NULL) { <o:p></o:p> + virUUIDParse(record->uuid,raw_uuid);<o:p></o:p> + domP = virGetDomain(conn, record->name_label, raw_uuid);<o:p></o:p> + if (domP!=NULL) <o:p></o:p> + ret_code = xenapiDomainResume(domP);<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_record_free(record); <o:p></o:p> + } <o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + }<o:p></o:p> + xen_host_free(host);<o:p></o:p> + }<o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok))<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return ret_code;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainCoreDump (virDomainPtr dom, const char *to ATTRIBUTE_UNUSED, int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainSetVcpus<o:p></o:p> +*<o:p></o:p> +* Sets the VCPUs on the domain<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSetVcpus (virDomainPtr dom, unsigned int nvcpus)<o:p></o:p> +{<o:p></o:p> + <o:p></o:p> + /* vm.set_vcpus_max */<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms!=NULL && vms->size!=0) {<o:p></o:p> + vm = vms->contents[0]; <o:p></o:p> + if (xen_vm_set_vcpus_number_live(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + vm, (int64_t)nvcpus)) {<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainPinVcpu<o:p></o:p> +*<o:p></o:p> +* Dynamically change the real CPUs which can be allocated to a virtual CPU<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainPinVcpu (virDomainPtr dom, unsigned int vcpu,<o:p></o:p> + unsigned char *cpumap, int maplen)<o:p></o:p> +{<o:p></o:p> + char *value;<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms!=NULL && vms->size!=0) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + value = mapDomainPinVcpu(vcpu, cpumap, maplen);<o:p></o:p> + xen_vm_remove_from_vcpus_params(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm, (char *)"mask");<o:p></o:p> + if (xen_vm_add_to_vcpus_params(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + vm, (char *)"mask", value)) {<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + } <o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetVcpus<o:p></o:p> +*<o:p></o:p> +* Gets Vcpu information<o:p></o:p> +* Return number of structures filled on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainGetVcpus (virDomainPtr dom,<o:p></o:p> + virVcpuInfoPtr info, int maxinfo,<o:p></o:p> + unsigned char *cpumaps, int maplen)<o:p></o:p> +{<o:p></o:p> +<o:p></o:p> + xen_vm_set *vms=NULL;<o:p></o:p> + xen_vm vm=NULL;<o:p></o:p> + xen_string_string_map *vcpu_params=NULL;<o:p></o:p> + int nvcpus=0,cpus=0,i;<o:p></o:p> + virDomainInfoPtr domInfo;<o:p></o:p> + virNodeInfo nodeInfo;<o:p></o:p> + virVcpuInfoPtr ifptr;<o:p></o:p> + char *mask=NULL;<o:p></o:p> + if((cpumaps!=NULL) && (maplen < 1))<o:p></o:p> + return -1;<o:p></o:p> + domInfo =(struct _virDomainInfo *) malloc(sizeof(struct _virDomainInfo)); <o:p></o:p> + if (virDomainGetInfo(dom,domInfo)==0) {<o:p></o:p> + nvcpus = domInfo->nrVirtCpu;<o:p></o:p> + free(domInfo);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, "Couldn't fetch Domain Information",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + if ( virNodeGetInfo(dom->conn,&nodeInfo)==0)<o:p></o:p> + cpus = nodeInfo.cpus;<o:p></o:p> + else {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, "Couldn't fetch Node Information",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + if(nvcpus > maxinfo) nvcpus = maxinfo;<o:p></o:p> +<o:p></o:p> + if (cpumaps != NULL)<o:p></o:p> + memset(cpumaps, 0, maxinfo * maplen);<o:p></o:p> +<o:p></o:p> + if (!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_get_vcpus_params(((struct _xenapiPrivate *)(dom->conn->privateData))->session, <o:p></o:p> + &vcpu_params, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + for (i=0; i<vcpu_params->size; i++) {<o:p></o:p> + if (STREQ(vcpu_params->contents[i].key,"mask")) {<o:p></o:p> + mask = strdup(vcpu_params->contents[i].val);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + for (i=0,ifptr=info ;i<nvcpus; i++,ifptr++) {<o:p></o:p> + ifptr->number = i;<o:p></o:p> + ifptr->state = VIR_VCPU_RUNNING;<o:p></o:p> + ifptr->cpuTime = 0;<o:p></o:p> + ifptr->cpu = 0;<o:p></o:p> + if (mask !=NULL) <o:p></o:p> + getCpuBitMapfromString(mask,VIR_GET_CPUMAP(cpumaps,maplen,i),maplen);<o:p></o:p> + }<o:p></o:p> + return i;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetMaxVcpus<o:p></o:p> +*<o:p></o:p> +* <o:p></o:p> +* Returns maximum number of Vcpus on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainGetMaxVcpus (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + int64_t maxvcpu=0;<o:p></o:p> + enum xen_vm_power_state state;<o:p></o:p> +<o:p></o:p> + if (xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + xen_vm_get_power_state(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &state, vm);<o:p></o:p> + if(state == XEN_VM_POWER_STATE_RUNNING) {<o:p></o:p> + xen_vm_get_vcpus_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &maxvcpu, vm);<o:p></o:p> + } else {<o:p></o:p> + maxvcpu = xenapiGetMaxVcpus(dom->conn, NULL);<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return (int)maxvcpu;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainDumpXML<o:p></o:p> +*<o:p></o:p> +* <o:p></o:p> +* Returns XML string of the domain configuration on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static char *<o:p></o:p> +xenapiDomainDumpXML (virDomainPtr dom, ATTRIBUTE_UNUSED int flags)<o:p></o:p> +{<o:p></o:p> + virBuffer buf = VIR_BUFFER_INITIALIZER;<o:p></o:p> + char uuid_string[VIR_UUID_STRING_BUFLEN];<o:p></o:p> + xen_vm vm=NULL;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_string_string_map *result=NULL;<o:p></o:p> +<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms==NULL || vms->size==0) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return NULL;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + vm = vms->contents[0]; <o:p></o:p> + virBufferAddLit(&buf, "<domain type='xenapi'>\n");<o:p></o:p> + virBufferEscapeString(&buf, " <name>%s</name>\n", "testVM");<o:p></o:p> + virUUIDFormat(dom->uuid,uuid_string);<o:p></o:p> + virBufferEscapeString(&buf, " <uuid>%s</uuid>\n",uuid_string);<o:p></o:p> +<o:p></o:p> +<o:p></o:p> + virBufferAddLit(&buf, " <os>\n");<o:p></o:p> + char *boot_policy=NULL;<o:p></o:p> + xen_vm_get_hvm_boot_policy(((struct _xenapiPrivate *)(dom->conn->privateData))->session, <o:p></o:p> + &boot_policy, vm);<o:p></o:p> + if (STREQ(boot_policy,"BIOS order")) { <o:p></o:p> + virBufferAddLit(&buf, " <type>hvm</type>\n");<o:p></o:p> + xen_vm_get_hvm_boot_params(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &result, vm);<o:p></o:p> + if (result!=NULL) {<o:p></o:p> + int i;<o:p></o:p> + for (i=0; i<(result->size); i++) {<o:p></o:p> + if (STREQ(result->contents[i].key,"order")) {<o:p></o:p> + int j=0;<o:p></o:p> + while(result->contents[i].val[j]!='\0') {<o:p></o:p> + virBufferEscapeString(&buf, " <boot dev='%s' />\n",<o:p></o:p> + mapXmlBootOrder(result->contents[i].val[j]));<o:p></o:p> + j++; <o:p></o:p> + } <o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + xen_string_string_map_free(result);<o:p></o:p> + }<o:p></o:p> + VIR_FREE(boot_policy); <o:p></o:p> + } else {<o:p></o:p> + virBufferAddLit(&buf, " <type>linux</type>\n");<o:p></o:p> + virBufferAddLit(&buf, " <loader>pygrub</loader>\n");<o:p></o:p> + char *value=NULL;<o:p></o:p> + xen_vm_get_pv_kernel(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &value, vm);<o:p></o:p> + if (!STREQ(value,"")) {<o:p></o:p> + virBufferEscapeString(&buf," <kernel>%s</kernel>\n",value);<o:p></o:p> + VIR_FREE(value);<o:p></o:p> + } <o:p></o:p> + xen_vm_get_pv_ramdisk(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &value, vm);<o:p></o:p> + if (!STREQ(value,"")) {<o:p></o:p> + virBufferEscapeString(&buf," <initrd>%s</initrd>\n",value);<o:p></o:p> + VIR_FREE(value);<o:p></o:p> + }<o:p></o:p> + xen_vm_get_pv_args(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &value, vm);<o:p></o:p> + if (!STREQ(value,"")) {<o:p></o:p> + virBufferEscapeString(&buf," <cmdline>%s</cmdline>\n",value);<o:p></o:p> + VIR_FREE(value);<o:p></o:p> + }<o:p></o:p> + VIR_FREE(boot_policy);<o:p></o:p> + } <o:p></o:p> + virBufferAddLit(&buf, " </os>\n");<o:p></o:p> + virBufferAddLit(&buf, " <bootloader>pygrub</bootloader>\n");<o:p></o:p> + char *val=NULL;<o:p></o:p> + xen_vm_get_pv_bootloader_args(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &val, vm); <o:p></o:p> + if (!STREQ(val,"")) {<o:p></o:p> + virBufferEscapeString(&buf," <bootloader_args>%s</bootloader_args>\n",val);<o:p></o:p> + VIR_FREE(val);<o:p></o:p> + }<o:p></o:p> + unsigned long memory=0;<o:p></o:p> + memory = xenapiDomainGetMaxMemory(dom);<o:p></o:p> + virBufferVSprintf(&buf," <memory>%lu</memory>\n",memory);<o:p></o:p> + int64_t dynamic_mem=0;<o:p></o:p> + if (xen_vm_get_memory_dynamic_max(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &dynamic_mem, vm)) {<o:p></o:p> + virBufferVSprintf(&buf," <currentmemory>%lld</currentmemory>\n",(dynamic_mem/1024));<o:p></o:p> + } else {<o:p></o:p> + virBufferVSprintf(&buf," <currentmemory>%lu</currentmemory>\n",memory);<o:p></o:p> + }<o:p></o:p> + virBufferVSprintf(&buf," <vcpu>%d</vcpu>\n",xenapiDomainGetMaxVcpus(dom));<o:p></o:p> + enum xen_on_normal_exit action;<o:p></o:p> + if (xen_vm_get_actions_after_shutdown(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &action, vm)) {<o:p></o:p> + virBufferEscapeString(&buf," <on_poweroff>%s</on_poweroff>\n",xen_on_normal_exit_to_string(action));<o:p></o:p> + } <o:p></o:p> + if (xen_vm_get_actions_after_reboot(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &action, vm)) {<o:p></o:p> + virBufferEscapeString(&buf," <on_reboot>%s</on_reboot>\n",xen_on_normal_exit_to_string(action));<o:p></o:p> + }<o:p></o:p> + enum xen_on_crash_behaviour crash;<o:p></o:p> + if (xen_vm_get_actions_after_crash(((struct _xenapiPrivate *)(dom->conn->privateData))->session, &crash, vm)) {<o:p></o:p> + virBufferEscapeString(&buf," <on_crash>%s</on_crash>\n",xen_on_crash_behaviour_to_string(crash));<o:p></o:p> + } <o:p></o:p> + xen_vm_get_platform(((struct _xenapiPrivate *)(dom->conn->privateData))->session, <o:p></o:p> + &result, vm); <o:p></o:p> + if (result!=NULL) { <o:p></o:p> + int i;<o:p></o:p> + virBufferAddLit(&buf, " <features>\n");<o:p></o:p> + for(i=0; i< (result->size); i++) {<o:p></o:p> + if (STREQ(result->contents[i].val,"true")) {<o:p></o:p> + virBufferVSprintf(&buf," <%s/>\n",result->contents[i].key);<o:p></o:p> + } <o:p></o:p> + } <o:p></o:p> + virBufferAddLit(&buf, " </features>\n");<o:p></o:p> + xen_string_string_map_free(result);<o:p></o:p> + }<o:p></o:p> + struct xen_vif_set *vif_set=NULL;<o:p></o:p> + xen_vm_get_vifs(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vif_set, vm);<o:p></o:p> + if (vif_set) {<o:p></o:p> + int i;<o:p></o:p> + xen_vif vif;<o:p></o:p> + xen_vif_record *vif_rec=NULL;<o:p></o:p> + xen_network network;<o:p></o:p> + char *bridge=NULL;<o:p></o:p> + for (i=0; i<vif_set->size; i++) {<o:p></o:p> + virBufferAddLit(&buf, " <interface type='bridge'>\n");<o:p></o:p> + vif = vif_set->contents[i];<o:p></o:p> + xen_vif_get_network(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &network, vif);<o:p></o:p> + if (network!=NULL) { <o:p></o:p> + xen_network_get_bridge(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &bridge, network);<o:p></o:p> + if (bridge!=NULL) {<o:p></o:p> + virBufferEscapeString(&buf," <source bridge='%s' />\n",bridge);<o:p></o:p> + VIR_FREE(bridge);<o:p></o:p> + }<o:p></o:p> + xen_network_free(network);<o:p></o:p> + } <o:p></o:p> + xen_vif_get_record(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vif_rec, vif);<o:p></o:p> + if (vif_rec!=NULL) {<o:p></o:p> + virBufferEscapeString(&buf," <mac address='%s' />\n", vif_rec->mac);<o:p></o:p> + xen_vif_record_free(vif_rec);<o:p></o:p> + }<o:p></o:p> + virBufferAddLit(&buf, " </interface>\n");<o:p></o:p> + }<o:p></o:p> + xen_vif_set_free(vif_set);<o:p></o:p> + }<o:p></o:p> + virBufferAddLit(&buf, "</domain>");<o:p></o:p> + if (vms) xen_vm_set_free(vms);<o:p></o:p> + return virBufferContentAndReset(&buf);<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static char *<o:p></o:p> +xenapiDomainXMLFromNative(virConnectPtr conn,<o:p></o:p> + const char *format ATTRIBUTE_UNUSED,<o:p></o:p> + const char *config ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return NULL;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +static char *<o:p></o:p> +xenapiDomainXMLToNative(virConnectPtr conn,<o:p></o:p> + const char *format ATTRIBUTE_UNUSED,<o:p></o:p> + const char *xmlData ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return NULL;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiListDefinedDomains<o:p></o:p> +*<o:p></o:p> +* list the defined but inactive domains, stores the pointers to the names in @names<o:p></o:p> +* Returns number of names provided in the array or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiListDefinedDomains (virConnectPtr conn, char **const names,<o:p></o:p> + int maxnames)<o:p></o:p> +{<o:p></o:p> + int i,j=0,doms;<o:p></o:p> + xen_vm_set *result;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + xen_vm_get_all(((struct _xenapiPrivate *)(conn->privateData))->session, &result);<o:p></o:p> + if (result != NULL) {<o:p></o:p> + for (i=0; i< (result->size) && j< maxnames; i++) {<o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(conn->privateData))->session, <o:p></o:p> + &record, result->contents[i]);<o:p></o:p> + if ( record!=NULL ) { <o:p></o:p> + if ( record->is_a_template == 0 ) {<o:p></o:p> + char *usenames;<o:p></o:p> + usenames = strdup(record->name_label);<o:p></o:p> + names[j++]=usenames;<o:p></o:p> + } <o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, "Couldn't get VM record", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + return -1;<o:p></o:p> + } <o:p></o:p> + }<o:p></o:p> + doms=j;<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + return doms;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiNumOfDefinedDomains<o:p></o:p> +*<o:p></o:p> +* Provides the number of defined but inactive domains<o:p></o:p> +* Returns number of domains found on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiNumOfDefinedDomains (virConnectPtr conn)<o:p></o:p> +{<o:p></o:p> + xen_vm_set *result;<o:p></o:p> + xen_vm_record *record;<o:p></o:p> + int DomNum=0,i;<o:p></o:p> + xen_vm_get_all(((struct _xenapiPrivate *)(conn->privateData))->session, &result);<o:p></o:p> + if ( result != NULL) {<o:p></o:p> + for ( i=0; i< (result->size); i++ ) {<o:p></o:p> + xen_vm_get_record(((struct _xenapiPrivate *)(conn->privateData))->session, <o:p></o:p> + &record, result->contents[i]);<o:p></o:p> + if (record==NULL && !(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + if (record->is_a_template == 0)<o:p></o:p> + DomNum++;<o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(result);<o:p></o:p> + return DomNum;<o:p></o:p> + }<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DEVICE, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainCreate<o:p></o:p> +*<o:p></o:p> +* starts a VM<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainCreate (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name);<o:p></o:p> + if (vms!=NULL && vms->size!=0) {<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_start(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm, false, false)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainDefineXML<o:p></o:p> +*<o:p></o:p> +* Defines a domain from the given XML but does not start it<o:p></o:p> +* Returns 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainDefineXML (virConnectPtr conn, const char *xml)<o:p></o:p> +{<o:p></o:p> + xen_vm_record *record=NULL;<o:p></o:p> + xen_vm vm=NULL;<o:p></o:p> + virDomainPtr domP=NULL;<o:p></o:p> + if(createVMRecordFromXml( conn, xml, &record, &vm)!=0) {<o:p></o:p> + if (!(((struct _xenapiPrivate *)(conn->privateData))->session->ok)) <o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + else<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, "Couldn't get VM information from XML",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return NULL;<o:p></o:p> + }<o:p></o:p> + if (record!=NULL) {<o:p></o:p> + unsigned char raw_uuid[RAW_UUID_BUFLEN];<o:p></o:p> + virUUIDParse(record->uuid,raw_uuid);<o:p></o:p> + domP = virGetDomain(conn, record->name_label, raw_uuid);<o:p></o:p> + if (domP==NULL && !(((struct _xenapiPrivate *)(conn->privateData))->session->ok))<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_record_free(record);<o:p></o:p> + }<o:p></o:p> + else if (vm!=NULL)<o:p></o:p> + xen_vm_free(vm);<o:p></o:p> + return domP;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainUndefine<o:p></o:p> +*<o:p></o:p> +* destroys a domain<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainUndefine (virDomainPtr dom)<o:p></o:p> +{<o:p></o:p> + struct xen_vm_set *vms;<o:p></o:p> + xen_vm vm;<o:p></o:p> + if (!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_destroy(((struct _xenapiPrivate *)(dom->conn->privateData))->session, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__); <o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainAttachDevice (virDomainPtr dom, const char *xml ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainDetachDevice (virDomainPtr dom, const char *xml ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainGetAutostart<o:p></o:p> +*<o:p></o:p> +* Provides a boolean value indicating whether the domain configured<o:p></o:p> +* to be automatically started when the host machine boots<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainGetAutostart (virDomainPtr dom, int *autostart)<o:p></o:p> +{<o:p></o:p> + int i,flag=0;<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm vm;<o:p></o:p> + xen_string_string_map *result;<o:p></o:p> + if(!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + if (!xen_vm_get_other_config(((struct _xenapiPrivate *)(dom->conn->privateData))->session, <o:p></o:p> + &result, vm)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + for (i=0; i < result->size; i++) {<o:p></o:p> + if (STREQ(result->contents[i].key, "auto_poweron")) {<o:p></o:p> + flag=1;<o:p></o:p> + if (STREQ(result->contents[i].val, "true"))<o:p></o:p> + *autostart = 1;<o:p></o:p> + else<o:p></o:p> + *autostart = 0;<o:p></o:p> + } <o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + xen_string_string_map_free(result);<o:p></o:p> + if (flag==0) return -1;<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiDomainSetAutostart<o:p></o:p> +*<o:p></o:p> +* Configure the domain to be automatically started when the host machine boots<o:p></o:p> +* Return 0 on success or -1 in case of error<o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSetAutostart (virDomainPtr dom, int autostart)<o:p></o:p> +{<o:p></o:p> + xen_vm_set *vms;<o:p></o:p> + xen_vm vm;<o:p></o:p> + char *value;<o:p></o:p> + if (!xen_vm_get_by_name_label(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + &vms, dom->name)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_DOMAIN, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + vm = vms->contents[0];<o:p></o:p> + xen_vm_remove_from_other_config(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + vm, (char *)"auto_poweron");<o:p></o:p> + if (autostart==1)<o:p></o:p> + value = (char *)"true";<o:p></o:p> + else<o:p></o:p> + value = (char *)"false";<o:p></o:p> + if (!xen_vm_add_to_other_config(((struct _xenapiPrivate *)(dom->conn->privateData))->session,<o:p></o:p> + vm, (char *)"auto_poweron", value)) {<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_INTERNAL_ERROR, NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xen_vm_set_free(vms);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_vm_set_free(vms); <o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static char *<o:p></o:p> +xenapiDomainGetSchedulerType (virDomainPtr dom ATTRIBUTE_UNUSED, int *nparams)<o:p></o:p> +{<o:p></o:p> + *nparams = 0;<o:p></o:p> + return (char *)"credit";<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainGetSchedulerParameters (virDomainPtr dom,<o:p></o:p> + virSchedParameterPtr params ATTRIBUTE_UNUSED, <o:p></o:p> + int *nparams ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainSetSchedulerParameters (virDomainPtr dom,<o:p></o:p> + virSchedParameterPtr params ATTRIBUTE_UNUSED, <o:p></o:p> + int nparams ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainMigratePrepare (virConnectPtr dconn,<o:p></o:p> + char **cookie ATTRIBUTE_UNUSED,<o:p></o:p> + int *cookielen ATTRIBUTE_UNUSED,<o:p></o:p> + const char *uri_in ATTRIBUTE_UNUSED,<o:p></o:p> + char **uri_out ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long flags ATTRIBUTE_UNUSED,<o:p></o:p> + const char *dname ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long resource ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dconn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainMigratePerform (virDomainPtr dom,<o:p></o:p> + const char *cookie ATTRIBUTE_UNUSED,<o:p></o:p> + int cookielen ATTRIBUTE_UNUSED,<o:p></o:p> + const char *uri ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long flags ATTRIBUTE_UNUSED,<o:p></o:p> + const char *dname ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long resource ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static virDomainPtr<o:p></o:p> +xenapiDomainMigrateFinish (virConnectPtr dconn,<o:p></o:p> + const char *dname,<o:p></o:p> + const char *cookie ATTRIBUTE_UNUSED,<o:p></o:p> + int cookielen ATTRIBUTE_UNUSED,<o:p></o:p> + const char *uri ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + return xenapiDomainLookupByName (dconn, dname);<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainBlockStats (virDomainPtr dom, const char *path ATTRIBUTE_UNUSED,<o:p></o:p> + struct _virDomainBlockStats *stats ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainInterfaceStats (virDomainPtr dom, const char *path ATTRIBUTE_UNUSED,<o:p></o:p> + struct _virDomainInterfaceStats *stats ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainBlockPeek (virDomainPtr dom, const char *path ATTRIBUTE_UNUSED,<o:p></o:p> + unsigned long long offset ATTRIBUTE_UNUSED, size_t size ATTRIBUTE_UNUSED,<o:p></o:p> + void *buffer ATTRIBUTE_UNUSED, unsigned int flags ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dom->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiNodeGetFreeMemory<o:p></o:p> +*<o:p></o:p> +* provides the free memory available on the Node<o:p></o:p> +* Returns memory size on success or 0 in case of error<o:p></o:p> +*/<o:p></o:p> +static unsigned long long<o:p></o:p> +xenapiNodeGetFreeMemory (virConnectPtr conn)<o:p></o:p> +{<o:p></o:p> + xen_host_metrics_set *xen_met_set;<o:p></o:p> + unsigned long long freeMem=0;<o:p></o:p> + xen_host_metrics_get_all(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &xen_met_set);<o:p></o:p> + if (xen_met_set != NULL) {<o:p></o:p> + if (!xen_host_metrics_get_memory_free(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + (int64_t *)&freeMem, xen_met_set->contents[0])) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, "Couldn't get host metrics - memory information",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + freeMem=0;<o:p></o:p> + }<o:p></o:p> + xen_host_metrics_set_free(xen_met_set);<o:p></o:p> + } else {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_INTERNAL_ERROR, "Couldn't get host metrics",<o:p></o:p> + __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + }<o:p></o:p> + return freeMem; <o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* xenapiNodeGetCellsFreeMemory<o:p></o:p> +*<o:p></o:p> +*<o:p></o:p> +* Returns the number of entries filled in freeMems, or -1 in case of error. <o:p></o:p> +*/<o:p></o:p> +static int<o:p></o:p> +xenapiNodeGetCellsFreeMemory (virConnectPtr conn, unsigned long long *freeMems ATTRIBUTE_UNUSED,<o:p></o:p> + int startCell, int maxCells)<o:p></o:p> +{<o:p></o:p> + if (maxCells >1 && startCell >0) {<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + } else {<o:p></o:p> + freeMems[0] = xenapiNodeGetFreeMemory(conn); <o:p></o:p> + return 1;<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainEventRegister (virConnectPtr conn,<o:p></o:p> + virConnectDomainEventCallback callback ATTRIBUTE_UNUSED,<o:p></o:p> + void *opaque ATTRIBUTE_UNUSED,<o:p></o:p> + void (*freefunc)(void *) ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiDomainEventDeregister (virConnectPtr conn,<o:p></o:p> + virConnectDomainEventCallback callback ATTRIBUTE_UNUSED)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiNodeDeviceDettach (virNodeDevicePtr dev)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dev->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiNodeDeviceReAttach (virNodeDevicePtr dev)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dev->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +static int<o:p></o:p> +xenapiNodeDeviceReset (virNodeDevicePtr dev)<o:p></o:p> +{<o:p></o:p> + xenapiSessionErrorHandler(dev->conn, VIR_ERR_NO_SUPPORT, "", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* The interface which we export upwards to libvirt.c. */<o:p></o:p> +static virDriver xenapiDriver = {<o:p></o:p> + VIR_DRV_XENAPI,<o:p></o:p> + "XenAPI",<o:p></o:p> + xenapiOpen, /* open */<o:p></o:p> + xenapiClose, /* close */<o:p></o:p> + xenapiSupportsFeature, /* supports_feature */<o:p></o:p> + xenapiType, /* type */<o:p></o:p> + xenapiGetVersion, /* version */<o:p></o:p> + NULL, /*getlibvirtVersion */<o:p></o:p> + xenapiGetHostname, /* getHostname */<o:p></o:p> + xenapiGetMaxVcpus, /* getMaxVcpus */<o:p></o:p> + xenapiNodeGetInfo, /* nodeGetInfo */<o:p></o:p> + xenapiGetCapabilities, /* getCapabilities */<o:p></o:p> + xenapiListDomains, /* listDomains */<o:p></o:p> + xenapiNumOfDomains, /* numOfDomains */<o:p></o:p> + xenapiDomainCreateXML, /* domainCreateXML */<o:p></o:p> + xenapiDomainLookupByID, /* domainLookupByID */<o:p></o:p> + xenapiDomainLookupByUUID, /* domainLookupByUUID */<o:p></o:p> + xenapiDomainLookupByName, /* domainLookupByName */<o:p></o:p> + xenapiDomainSuspend, /* domainSuspend */<o:p></o:p> + xenapiDomainResume, /* domainResume */<o:p></o:p> + xenapiDomainShutdown, /* domainShutdown */<o:p></o:p> + xenapiDomainReboot, /* domainReboot */<o:p></o:p> + xenapiDomainDestroy, /* domainDestroy */<o:p></o:p> + xenapiDomainGetOSType, /* domainGetOSType */<o:p></o:p> + xenapiDomainGetMaxMemory, /* domainGetMaxMemory */<o:p></o:p> + xenapiDomainSetMaxMemory, /* domainSetMaxMemory */<o:p></o:p> + xenapiDomainSetMemory, /* domainSetMemory */<o:p></o:p> + xenapiDomainGetInfo, /* domainGetInfo */<o:p></o:p> + xenapiDomainSave, /* domainSave */<o:p></o:p> + xenapiDomainRestore, /* domainRestore */<o:p></o:p> + xenapiDomainCoreDump, /* domainCoreDump */<o:p></o:p> + xenapiDomainSetVcpus, /* domainSetVcpus */<o:p></o:p> + xenapiDomainPinVcpu, /* domainPinVcpu */<o:p></o:p> + xenapiDomainGetVcpus, /* domainGetVcpus */<o:p></o:p> + xenapiDomainGetMaxVcpus, /* domainGetMaxVcpus */<o:p></o:p> + NULL, /* domainGetSecurityLabel */<o:p></o:p> + NULL, /* nodeGetSecurityModel */<o:p></o:p> + xenapiDomainDumpXML, /* domainDumpXML */<o:p></o:p> + xenapiDomainXMLFromNative, /* domainXmlFromNative */<o:p></o:p> + xenapiDomainXMLToNative, /* domainXmlToNative */<o:p></o:p> + xenapiListDefinedDomains, /* listDefinedDomains */<o:p></o:p> + xenapiNumOfDefinedDomains, /* numOfDefinedDomains */<o:p></o:p> + xenapiDomainCreate, /* domainCreate */<o:p></o:p> + xenapiDomainDefineXML, /* domainDefineXML */<o:p></o:p> + xenapiDomainUndefine, /* domainUndefine */<o:p></o:p> + xenapiDomainAttachDevice, /* domainAttachDevice */<o:p></o:p> + NULL,<o:p></o:p> + xenapiDomainDetachDevice, /* domainDetachDevice */<o:p></o:p> + NULL,<o:p></o:p> + xenapiDomainGetAutostart, /* domainGetAutostart */<o:p></o:p> + xenapiDomainSetAutostart, /* domainSetAutostart */<o:p></o:p> + xenapiDomainGetSchedulerType, /* domainGetSchedulerType */<o:p></o:p> + xenapiDomainGetSchedulerParameters, /* domainGetSchedulerParameters */<o:p></o:p> + xenapiDomainSetSchedulerParameters, /* domainSetSchedulerParameters */<o:p></o:p> + xenapiDomainMigratePrepare, /* domainMigratePrepare */<o:p></o:p> + xenapiDomainMigratePerform, /* domainMigratePerform */<o:p></o:p> + xenapiDomainMigrateFinish, /* domainMigrateFinish */<o:p></o:p> + xenapiDomainBlockStats, /* domainBlockStats */<o:p></o:p> + xenapiDomainInterfaceStats, /* domainInterfaceStats */<o:p></o:p> + NULL,<o:p></o:p> + xenapiDomainBlockPeek, /* domainBlockPeek */<o:p></o:p> + NULL, /* domainMemoryPeek */<o:p></o:p> + xenapiNodeGetCellsFreeMemory, /* nodeGetCellsFreeMemory */<o:p></o:p> + xenapiNodeGetFreeMemory, /* getFreeMemory */<o:p></o:p> + xenapiDomainEventRegister, /* domainEventRegister */<o:p></o:p> + xenapiDomainEventDeregister, /* domainEventDeregister */<o:p></o:p> + NULL, /* domainMigratePrepare2 */<o:p></o:p> + NULL, /* domainMigrateFinish2 */<o:p></o:p> + xenapiNodeDeviceDettach, /* nodeDeviceDettach */<o:p></o:p> + xenapiNodeDeviceReAttach, /* nodeDeviceReAttach */<o:p></o:p> + xenapiNodeDeviceReset, /* nodeDeviceReset */<o:p></o:p> + NULL,<o:p></o:p> + NULL,<o:p></o:p> + NULL,<o:p></o:p> + NULL,<o:p></o:p> + NULL,<o:p></o:p> + NULL,<o:p></o:p> + NULL<o:p></o:p> +};<o:p></o:p> +<o:p></o:p> +/**<o:p></o:p> + * xenapiRegister:<o:p></o:p> + *<o:p></o:p> + *<o:p></o:p> + * Returns the driver priority or -1 in case of error.<o:p></o:p> + */<o:p></o:p> +int<o:p></o:p> +xenapiRegister (void)<o:p></o:p> +{<o:p></o:p> + return virRegisterDriver (&xenapiDriver);<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* write_func<o:p></o:p> +* used by curl to read data from the server<o:p></o:p> +*/<o:p></o:p> +size_t<o:p></o:p> +write_func(void *ptr, size_t size, size_t nmemb, void *comms_)<o:p></o:p> +{<o:p></o:p> + xen_comms *comms = comms_;<o:p></o:p> + size_t n = size * nmemb;<o:p></o:p> + #ifdef PRINT_XML<o:p></o:p> + printf("\n\n---Result from server -----------------------\n");<o:p></o:p> + printf("%s\n",((char*) ptr));<o:p></o:p> + fflush(stdout);<o:p></o:p> + #endif<o:p></o:p> + return (size_t) (comms->func(ptr, n, comms->handle) ? n : 0);<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/*<o:p></o:p> +* call_func<o:p></o:p> +* sets curl options, used with xen_session_login_with_password<o:p></o:p> +*/<o:p></o:p> +int<o:p></o:p> +call_func(const void *data, size_t len, void *user_handle,<o:p></o:p> + void *result_handle, xen_result_func result_func)<o:p></o:p> +{<o:p></o:p> + (void)user_handle;<o:p></o:p> + #ifdef PRINT_XML<o:p></o:p> +<o:p></o:p> + printf("\n\n---Data to server: -----------------------\n");<o:p></o:p> + printf("%s\n",((char*) data));<o:p></o:p> + fflush(stdout);<o:p></o:p> + #endif<o:p></o:p> + CURL *curl = curl_easy_init();<o:p></o:p> + if (!curl) {<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + xen_comms comms = {<o:p></o:p> + .func = result_func,<o:p></o:p> + .handle = result_handle<o:p></o:p> + };<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_URL, url);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 1);<o:p></o:p> + //curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);<o:p></o:p> + #ifdef CURLOPT_MUTE<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_MUTE, 1);<o:p></o:p> + #endif<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &write_func);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_WRITEDATA, &comms);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_POST, 1);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_POSTFIELDS, data);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, len);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0);<o:p></o:p> + curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0);<o:p></o:p> + CURLcode result = curl_easy_perform(curl);<o:p></o:p> + curl_easy_cleanup(curl);<o:p></o:p> + return result;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> diff -Nur ./libvirt_org/src/xenapi/xenapi_driver.h ./libvirt/src/xenapi/xenapi_driver.h<o:p></o:p> --- ./libvirt_org/src/xenapi/xenapi_driver.h 1970-01-01 01:00:00.000000000 +0100<o:p></o:p> +++ ./libvirt/src/xenapi/xenapi_driver.h 2010-02-18 15:37:49.000000000 +0000<o:p></o:p> @@ -0,0 +1,44 @@<o:p></o:p> +/*<o:p></o:p> + * xenapi.c: Xen API driver.<o:p></o:p> + * Copyright (C) 2009 Citrix Ltd.<o:p></o:p> + * Sharadha Prabhakar <sharadha.prabhakar@citrix.com><o:p></o:p> + */<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +#ifndef __VIR_XENAPI_H__<o:p></o:p> +#define __VIR_XENAPI_H__<o:p></o:p> +<o:p></o:p> +#include <xen/api/xen_common.h><o:p></o:p> +#include <libxml/tree.h><o:p></o:p> +<o:p></o:p> +//#define PRINT_XML<o:p></o:p> +#define RAW_UUID_BUFLEN (16)<o:p></o:p> +#define LIBVIRT_MODELNAME_LEN (32)<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +extern int xenapiRegister (void);<o:p></o:p> +<o:p></o:p> +typedef struct<o:p></o:p> +{<o:p></o:p> + xen_result_func func;<o:p></o:p> + void *handle;<o:p></o:p> +} xen_comms;<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +call_func(const void *data, size_t len, void *user_handle,<o:p></o:p> + void *result_handle, xen_result_func result_func);<o:p></o:p> +size_t<o:p></o:p> +write_func(void *ptr, size_t size, size_t nmemb, void *comms);<o:p></o:p> +<o:p></o:p> +/* xenAPI driver's private data structure */<o:p></o:p> +struct _xenapiPrivate {<o:p></o:p> + xen_session *session;<o:p></o:p> + void *handle;<o:p></o:p> + char *uname;<o:p></o:p> + char *pwd;<o:p></o:p> + xen_api_version version;<o:p></o:p> +};<o:p></o:p> +<o:p></o:p> +#endif /* __VIR_XENAPI_H__ */<o:p></o:p> <o:p> </o:p> </div> </body> </html>