<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> diff -Nur ./libvirt_org/src/xenapi/xenapi_utils.c ./libvirt/src/xenapi/xenapi_utils.c<o:p></o:p> --- ./libvirt_org/src/xenapi/xenapi_utils.c 1970-01-01 01:00:00.000000000 +0100<o:p></o:p> +++ ./libvirt/src/xenapi/xenapi_utils.c 2010-02-18 16:26:52.000000000 +0000<o:p></o:p> @@ -0,0 +1,507 @@<o:p></o:p> +/*<o:p></o:p> + * xenapi_utils.c: Xen API driver -- utils parts.<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 <stdio.h><o:p></o:p> +#include <string.h><o:p></o:p> +#include <config.h><o:p></o:p> +<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> +/* returns 'file' or 'block' for the storage type */<o:p></o:p> +int <o:p></o:p> +getStorageVolumeType(char *type)<o:p></o:p> +{<o:p></o:p> + if((STREQ(type,"lvmoiscsi")) ||<o:p></o:p> + (STREQ(type,"lvmohba")) ||<o:p></o:p> + (STREQ(type,"lvm")) ||<o:p></o:p> + (STREQ(type,"file")) ||<o:p></o:p> + (STREQ(type,"iso")) ||<o:p></o:p> + (STREQ(type,"ext")) ||<o:p></o:p> + (STREQ(type,"nfs")))<o:p></o:p> + return (int)VIR_STORAGE_VOL_FILE;<o:p></o:p> + else if((STREQ(type,"iscsi")) ||<o:p></o:p> + (STREQ(type,"equal")) ||<o:p></o:p> + (STREQ(type,"hba")) ||<o:p></o:p> + (STREQ(type,"cslg")) ||<o:p></o:p> + (STREQ(type,"udev")) ||<o:p></o:p> + (STREQ(type,"netapp")))<o:p></o:p> + return (int)VIR_STORAGE_VOL_BLOCK;<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* returns error description if any received from the server */<o:p></o:p> +char *<o:p></o:p> +returnErrorFromSession(xen_session *session)<o:p></o:p> +{<o:p></o:p> + int i;<o:p></o:p> + char *buf = NULL;<o:p></o:p> + for (i=0; i<session->error_description_count-1; i++) {<o:p></o:p> + if (buf==NULL) {<o:p></o:p> + buf = (char *)realloc(buf,strlen(session->error_description[i])+1);<o:p></o:p> + strcpy(buf,session->error_description[i]);<o:p></o:p> + } else {<o:p></o:p> + buf = (char *)realloc(buf,strlen(buf)+strlen(session->error_description[i])+2);<o:p></o:p> + strcat(buf,":");<o:p></o:p> + strcat(buf,session->error_description[i]);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + return buf;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* XenAPI error handler - internally calls libvirt error handler after clearing error<o:p></o:p> +flag in session */<o:p></o:p> +void xenapiSessionErrorHandler(virConnectPtr conn, virErrorNumber errNum, <o:p></o:p> + const char *buf, const char *filename, const char *func, size_t lineno)<o:p></o:p> +{<o:p></o:p> + if (buf==NULL) {<o:p></o:p> + char *ret=NULL;<o:p></o:p> + ret = returnErrorFromSession(((struct _xenapiPrivate *)(conn->privateData))->session);<o:p></o:p> + virReportErrorHelper (conn, VIR_FROM_XENAPI, errNum, filename, func, lineno, _("%s\n"), ret);<o:p></o:p> + xen_session_clear_error(((struct _xenapiPrivate *)(conn->privateData))->session);<o:p></o:p> + VIR_FREE(ret);<o:p></o:p> + } else {<o:p></o:p> + virReportErrorHelper (conn, VIR_FROM_XENAPI, errNum, filename, func, lineno, _("%s\n"), buf);<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* converts bitmap to string of the form '1,2...' */<o:p></o:p> +char *<o:p></o:p> +mapDomainPinVcpu(unsigned int vcpu, unsigned char *cpumap, int maplen)<o:p></o:p> +{<o:p></o:p> + char buf[VIR_UUID_BUFLEN], mapstr[sizeof(cpumap_t) * 64];<o:p></o:p> + char *ret=NULL;<o:p></o:p> + int i, j;<o:p></o:p> + mapstr[0] = 0;<o:p></o:p> + for (i = 0; i < maplen; i++) {<o:p></o:p> + for (j = 0; j < 8; j++) {<o:p></o:p> + if (cpumap[i] & (1 << j)) {<o:p></o:p> + snprintf(buf, sizeof(buf), "%d,", (8 * i) + j);<o:p></o:p> + strcat(mapstr, buf);<o:p></o:p> + } <o:p></o:p> + } <o:p></o:p> + }<o:p></o:p> + mapstr[strlen(mapstr) - 1] = 0;<o:p></o:p> + snprintf(buf, sizeof(buf), "%d", vcpu);<o:p></o:p> + ret = strdup(mapstr);<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* obtains the CPU bitmap from the string passed */<o:p></o:p> +void<o:p></o:p> +getCpuBitMapfromString(char *mask, unsigned char *cpumap, int maplen)<o:p></o:p> +{<o:p></o:p> + int pos;<o:p></o:p> + int max_bits = maplen * 8;<o:p></o:p> + char *num = NULL;<o:p></o:p> + bzero(cpumap, maplen);<o:p></o:p> + num = strtok (mask, ",");<o:p></o:p> + while (num != NULL) {<o:p></o:p> + sscanf (num, "%d", &pos);<o:p></o:p> + if (pos<0 || pos>max_bits-1)<o:p></o:p> + printf ("number in str %d exceeds cpumap's max bits %d\n", pos, max_bits);<o:p></o:p> + else<o:p></o:p> + (cpumap)[pos/8] |= (1<<(pos%8));<o:p></o:p> + num = strtok (NULL, ",");<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +/* mapping XenServer power state to Libvirt power state */<o:p></o:p> +virDomainState<o:p></o:p> +mapPowerState(enum xen_vm_power_state state)<o:p></o:p> +{<o:p></o:p> + virDomainState virState;<o:p></o:p> + switch (state) {<o:p></o:p> + case (XEN_VM_POWER_STATE_HALTED):<o:p></o:p> + case (XEN_VM_POWER_STATE_SUSPENDED):<o:p></o:p> + virState = VIR_DOMAIN_SHUTOFF;<o:p></o:p> + break;<o:p></o:p> + case (XEN_VM_POWER_STATE_PAUSED):<o:p></o:p> + virState = VIR_DOMAIN_PAUSED;<o:p></o:p> + break;<o:p></o:p> + case (XEN_VM_POWER_STATE_RUNNING):<o:p></o:p> + virState = VIR_DOMAIN_RUNNING;<o:p></o:p> + break;<o:p></o:p> + case (XEN_VM_POWER_STATE_UNKNOWN):<o:p></o:p> + case (XEN_VM_POWER_STATE_UNDEFINED):<o:p></o:p> + virState = VIR_DOMAIN_NOSTATE;<o:p></o:p> + break;<o:p></o:p> + default:<o:p></o:p> + virState = VIR_DOMAIN_NOSTATE;<o:p></o:p> + break;<o:p></o:p> + }<o:p></o:p> + return virState;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* Gets the value of the child for the current node passed */<o:p></o:p> +char *<o:p></o:p> +getXmlChildValue(xmlDocPtr doc, xmlNodePtr cur, const char *tag)<o:p></o:p> +{<o:p></o:p> + char *key = NULL;<o:p></o:p> + cur = cur->xmlChildrenNode;<o:p></o:p> + while (cur != NULL) {<o:p></o:p> + if ((!xmlStrcmp(cur->name, (const xmlChar *)tag))){<o:p></o:p> + cur = cur->xmlChildrenNode;<o:p></o:p> + key = (char *)xmlNodeListGetString(doc,cur,1);<o:p></o:p> + }<o:p></o:p> + cur = cur->next;<o:p></o:p> + }<o:p></o:p> + return key;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* allocate a flexible array and fill values(key,val) */<o:p></o:p> +int<o:p></o:p> +allocStringMap (xen_string_string_map **strings, char *key, char *val)<o:p></o:p> +{<o:p></o:p> + int sz = ((*strings) == NULL)?0:(*strings)->size;<o:p></o:p> + sz++;<o:p></o:p> + *strings = realloc(*strings,sizeof(xen_string_string_map)+<o:p></o:p> + sizeof(xen_string_string_map_contents)*sz);<o:p></o:p> + (*strings)->size = sz;<o:p></o:p> + (*strings)->contents[sz-1].key = strdup(key);<o:p></o:p> + (*strings)->contents[sz-1].val = strdup(val);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* create boot order string as understood by libvirt */<o:p></o:p> +void<o:p></o:p> +createXmlBootOrderString(char **order, char *key)<o:p></o:p> +{<o:p></o:p> + int sz = ((*order)==NULL)?0:(strlen(*order)+1);<o:p></o:p> + const char *temp=NULL;<o:p></o:p> + if (strcmp(key,"fd")==0)<o:p></o:p> + temp="a";<o:p></o:p> + else if (strcmp(key,"hd")==0)<o:p></o:p> + temp="c";<o:p></o:p> + else if (strcmp(key,"cdrom")==0)<o:p></o:p> + temp="d";<o:p></o:p> + else if (strcmp(key,"network")==0)<o:p></o:p> + temp="n";<o:p></o:p> + if (temp!=NULL) {<o:p></o:p> + *order = (char *)realloc(*order,sz+strlen(temp)+1);<o:p></o:p> + if(sz==0) strcpy(*order,temp);<o:p></o:p> + else strcat(*order,temp);<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +enum xen_on_normal_exit<o:p></o:p> +actionShutdownStringtoEnum(char *str)<o:p></o:p> +{<o:p></o:p> + enum xen_on_normal_exit code = XEN_ON_NORMAL_EXIT_UNDEFINED;<o:p></o:p> + if (STREQ(str, "destroy"))<o:p></o:p> + code = XEN_ON_NORMAL_EXIT_DESTROY;<o:p></o:p> + else if (STREQ(str, "restart"))<o:p></o:p> + code = XEN_ON_NORMAL_EXIT_RESTART;<o:p></o:p> + return code;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +enum xen_on_crash_behaviour<o:p></o:p> +actionCrashStringtoEnum(char *str)<o:p></o:p> +{<o:p></o:p> + enum xen_on_crash_behaviour code = XEN_ON_CRASH_BEHAVIOUR_UNDEFINED;<o:p></o:p> + if (STREQ(str, "destroy"))<o:p></o:p> + code = XEN_ON_CRASH_BEHAVIOUR_DESTROY;<o:p></o:p> + else if (STREQ(str, "restart"))<o:p></o:p> + code = XEN_ON_CRASH_BEHAVIOUR_RESTART;<o:p></o:p> + else if (STREQ(str, "preserve"))<o:p></o:p> + code = XEN_ON_CRASH_BEHAVIOUR_PRESERVE;<o:p></o:p> + else if (STREQ(str, "rename-restart"))<o:p></o:p> + code = XEN_ON_CRASH_BEHAVIOUR_RENAME_RESTART;<o:p></o:p> + return code;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* convert boot order string libvirt format to XenServer format */<o:p></o:p> +const char *<o:p></o:p> +mapXmlBootOrder(char c) {<o:p></o:p> + switch(c) {<o:p></o:p> + case 'a':<o:p></o:p> + return "fd";<o:p></o:p> + case 'c':<o:p></o:p> + return "hd";<o:p></o:p> + case 'd':<o:p></o:p> + return "cdrom";<o:p></o:p> + case 'n':<o:p></o:p> + return "network";<o:p></o:p> + default:<o:p></o:p> + return NULL;<o:p></o:p> + }<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* creates network intereface for VM */<o:p></o:p> +int<o:p></o:p> +createVifNetwork (virConnectPtr conn, xen_vm vm, char *device,<o:p></o:p> + char *bridge, char *mac)<o:p></o:p> +{<o:p></o:p> + xen_vm xvm = NULL;<o:p></o:p> + char *uuid = NULL;<o:p></o:p> + xen_vm_get_uuid(((struct _xenapiPrivate *)(conn->privateData))->session, &uuid, vm);<o:p></o:p> + if (uuid) {<o:p></o:p> + if(!xen_vm_get_by_uuid(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &xvm, uuid))<o:p></o:p> + return -1;<o:p></o:p> + VIR_FREE(uuid);<o:p></o:p> + }<o:p></o:p> + xen_vm_record_opt *vm_opt = xen_vm_record_opt_alloc();<o:p></o:p> + vm_opt->is_record = 0;<o:p></o:p> + vm_opt->u.handle = xvm;<o:p></o:p> + xen_network_set *net_set = NULL;<o:p></o:p> + xen_network_record *net_rec = NULL;<o:p></o:p> + int cnt=0;<o:p></o:p> + if (xen_network_get_all(((struct _xenapiPrivate *)(conn->privateData))->session, &net_set)) {<o:p></o:p> + for(cnt=0;cnt<(net_set->size);cnt++) {<o:p></o:p> + if (xen_network_get_record(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &net_rec, net_set->contents[cnt])) {<o:p></o:p> + if (STREQ(net_rec->bridge,bridge)) {<o:p></o:p> + break;<o:p></o:p> + } else {<o:p></o:p> + xen_network_record_free(net_rec);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + if ( (cnt<net_set->size) && net_rec) {<o:p></o:p> + xen_network network = NULL;<o:p></o:p> + xen_network_get_by_uuid(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &network, net_rec->uuid);<o:p></o:p> + xen_network_record_opt *network_opt = xen_network_record_opt_alloc();<o:p></o:p> + network_opt->is_record = 0;<o:p></o:p> + network_opt->u.handle = network;<o:p></o:p> + xen_vif_record *vif_record = xen_vif_record_alloc();<o:p></o:p> + vif_record->mac = mac;<o:p></o:p> + vif_record->vm = vm_opt;<o:p></o:p> + vif_record->network = network_opt;<o:p></o:p> + xen_vif vif=NULL;<o:p></o:p> +<o:p></o:p> + vif_record->other_config = xen_string_string_map_alloc(0);<o:p></o:p> + vif_record->runtime_properties = xen_string_string_map_alloc(0);<o:p></o:p> + vif_record->qos_algorithm_params = xen_string_string_map_alloc(0);<o:p></o:p> + vif_record->device = strdup(device);<o:p></o:p> + xen_vif_create(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + &vif, vif_record);<o:p></o:p> + if (vif!=NULL) {<o:p></o:p> + xen_vif_free(vif);<o:p></o:p> + xen_vif_record_free(vif_record);<o:p></o:p> + xen_network_record_free(net_rec);<o:p></o:p> + xen_network_set_free(net_set);<o:p></o:p> + return 0;<o:p></o:p> + }<o:p></o:p> + xen_vif_record_free(vif_record);<o:p></o:p> + xen_network_record_free(net_rec);<o:p></o:p> + } <o:p></o:p> + if (net_set!=NULL) xen_network_set_free(net_set);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> +/* Create a VM record from the XML description */<o:p></o:p> +int<o:p></o:p> +createVMRecordFromXml (virConnectPtr conn, const char *xmlDesc,<o:p></o:p> + xen_vm_record **record, xen_vm *vm)<o:p></o:p> +{<o:p></o:p> + xmlDocPtr doc;<o:p></o:p> + xmlNodePtr cur,child,temp;<o:p></o:p> + doc = xmlParseMemory(xmlDesc,strlen(xmlDesc));<o:p></o:p> + if (doc == NULL) {<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_XML_ERROR ,"", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + cur = xmlDocGetRootElement(doc);<o:p></o:p> + if (cur == NULL) {<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_XML_ERROR ,"", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xmlFreeDoc(doc);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + if (xmlStrcmp(cur->name, (const xmlChar *) "domain")) {<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_XML_ERROR ,"root node not domain", __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + xmlFreeDoc(doc);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + *record = xen_vm_record_alloc();<o:p></o:p> + char *name = getXmlChildValue(doc,cur,"name");<o:p></o:p> + (*record)->name_label = strdup(name); <o:p></o:p> + child = cur->xmlChildrenNode;<o:p></o:p> + while (child!=NULL) {<o:p></o:p> + if ((!xmlStrcmp(child->name, (const xmlChar *)"os"))) {<o:p></o:p> + char *ostype = getXmlChildValue(doc,child,"type");<o:p></o:p> + if (ostype!=NULL) {<o:p></o:p> + if (STREQ(ostype,"hvm")) {<o:p></o:p> + (*record)->hvm_boot_policy = strdup("BIOS order");<o:p></o:p> + temp = child;<o:p></o:p> + child = child->xmlChildrenNode;<o:p></o:p> + char *boot_order = NULL;<o:p></o:p> + while (child != NULL) {<o:p></o:p> + if ((!xmlStrcmp(child->name, (const xmlChar *)"boot"))){<o:p></o:p> + xmlChar *key;<o:p></o:p> + key = xmlGetProp(child, (const xmlChar *)"dev");<o:p></o:p> + if (key!=NULL) {<o:p></o:p> + createXmlBootOrderString(&boot_order,(char *)key);<o:p></o:p> + xmlFree(key);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + child = child->next;<o:p></o:p> + }<o:p></o:p> + if (boot_order!=NULL) {<o:p></o:p> + xen_string_string_map *hvm_boot_params=NULL;<o:p></o:p> + allocStringMap(&hvm_boot_params, (char *)"order",boot_order);<o:p></o:p> + //int size = sizeof(xen_string_string_map) +<o:p></o:p> + // (hvm_boot_params->size * sizeof(xen_string_string_map_contents));<o:p></o:p> + //(*record)->hvm_boot_params = (xen_string_string_map *) malloc(size);<o:p></o:p> + //memcpy((char *)(*record)->hvm_boot_params, (char *)hvm_boot_params, size);<o:p></o:p> + (*record)->hvm_boot_params = hvm_boot_params; <o:p></o:p> + VIR_FREE(boot_order);<o:p></o:p> + //freeStringMap(hvm_boot_params);<o:p></o:p> + } <o:p></o:p> + child = temp;<o:p></o:p> + } else if (STREQ(ostype,"linux")) {<o:p></o:p> + (*record)->pv_bootloader = strdup("pygrub");<o:p></o:p> + char *kernel = getXmlChildValue(doc,child,"kernel");<o:p></o:p> + if (kernel != NULL){<o:p></o:p> + (*record)->pv_kernel = kernel;<o:p></o:p> + //strcpy((*record)->pv_kernel,kernel);<o:p></o:p> + //free(kernel);<o:p></o:p> + }<o:p></o:p> + char *initrd = getXmlChildValue(doc,child,"initrd");<o:p></o:p> + if (initrd != NULL) {<o:p></o:p> + (*record)->pv_ramdisk = initrd;//(char *)malloc(strlen(initrd)+1);<o:p></o:p> + //strcpy((*record)->pv_ramdisk,initrd);<o:p></o:p> + //free(initrd);<o:p></o:p> + }<o:p></o:p> + char *cmdline = getXmlChildValue(doc,child,"cmdline");<o:p></o:p> + if (cmdline != NULL) {<o:p></o:p> + (*record)->pv_args = cmdline; //(char *)malloc(strlen(cmdline)+1);<o:p></o:p> + //strcpy((*record)->pv_args,cmdline);<o:p></o:p> + //free(cmdline);<o:p></o:p> + }<o:p></o:p> + (*record)->hvm_boot_params = xen_string_string_map_alloc(0);<o:p></o:p> + }<o:p></o:p> + VIR_FREE(ostype);<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + child = child->next;<o:p></o:p> + } <o:p></o:p> + char *bootload_args = getXmlChildValue(doc,cur,"bootloader_args");<o:p></o:p> + if (bootload_args!=NULL) {<o:p></o:p> + (*record)->pv_bootloader_args =bootload_args; //(char *)malloc(strlen(bootload_args)+1);<o:p></o:p> + //strcpy((*record)->pv_bootloader_args,bootload_args);<o:p></o:p> + //free(bootload_args);<o:p></o:p> + }<o:p></o:p> + char *memory = getXmlChildValue(doc,cur,"memory");<o:p></o:p> + if (memory!=NULL) {<o:p></o:p> + int64_t static_max=0;<o:p></o:p> + static_max = atoll(memory);<o:p></o:p> + (*record)->memory_static_max = static_max * 1024;<o:p></o:p> + VIR_FREE(memory);<o:p></o:p> + }<o:p></o:p> + char *curmemory = getXmlChildValue(doc,cur,"currentmemory");<o:p></o:p> + if (curmemory!=NULL) {<o:p></o:p> + int64_t dy_max=0;<o:p></o:p> + dy_max = atoll(curmemory);<o:p></o:p> + (*record)->memory_dynamic_max = dy_max * 1024;<o:p></o:p> + VIR_FREE(curmemory);<o:p></o:p> + } else {<o:p></o:p> + (*record)->memory_dynamic_max = (*record)->memory_static_max;<o:p></o:p> + }<o:p></o:p> + char *vcpu = getXmlChildValue(doc, cur, "vcpu");<o:p></o:p> + if (vcpu!=NULL) {<o:p></o:p> + (*record)->vcpus_max = atoll(vcpu);<o:p></o:p> + (*record)->vcpus_at_startup = atoll(vcpu);<o:p></o:p> + VIR_FREE(vcpu);<o:p></o:p> + }<o:p></o:p> + char *on_poweroff = getXmlChildValue(doc,cur,"on_poweroff");<o:p></o:p> + if (on_poweroff!=NULL) {<o:p></o:p> + (*record)->actions_after_shutdown = actionShutdownStringtoEnum(on_poweroff);<o:p></o:p> + VIR_FREE(on_poweroff);<o:p></o:p> + }<o:p></o:p> + char *on_reboot = getXmlChildValue(doc,cur,"on_reboot");<o:p></o:p> + if (on_reboot!=NULL) {<o:p></o:p> + (*record)->actions_after_reboot = actionShutdownStringtoEnum(on_reboot);<o:p></o:p> + VIR_FREE(on_reboot);<o:p></o:p> + }<o:p></o:p> + char *on_crash = getXmlChildValue(doc,cur,"on_crash");<o:p></o:p> + if (on_crash!=NULL) {<o:p></o:p> + (*record)->actions_after_crash = actionCrashStringtoEnum(on_crash);<o:p></o:p> + VIR_FREE(on_crash);<o:p></o:p> + }<o:p></o:p> + temp = cur;<o:p></o:p> + cur = cur->xmlChildrenNode;<o:p></o:p> + xen_string_string_map *strings=NULL;<o:p></o:p> + while (cur != NULL) {<o:p></o:p> + if ((!xmlStrcmp(cur->name, (const xmlChar *)"features"))){<o:p></o:p> + for (child=cur->children;child!=NULL;child=child->next) {<o:p></o:p> + allocStringMap(&strings,(char *)child->name,(char *)"true");<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + cur = cur->next;<o:p></o:p> + }<o:p></o:p> + cur = temp;<o:p></o:p> + if (strings!=NULL) {<o:p></o:p> + //int size = sizeof(xen_string_string_map)+ sizeof(xen_string_string_map_contents)*strings->size;<o:p></o:p> + (*record)->platform = strings; //(xen_string_string_map *)malloc(size);<o:p></o:p> + //memcpy((void *)(*record)->platform,(void *)strings,size);<o:p></o:p> + }<o:p></o:p> + (*record)->vcpus_params = xen_string_string_map_alloc(0);<o:p></o:p> + (*record)->other_config = xen_string_string_map_alloc(0);<o:p></o:p> + (*record)->last_boot_cpu_flags = xen_string_string_map_alloc(0);<o:p></o:p> + (*record)->xenstore_data = xen_string_string_map_alloc(0);<o:p></o:p> + (*record)->hvm_shadow_multiplier = 1.000;<o:p></o:p> + if (!xen_vm_create(((struct _xenapiPrivate *)(conn->privateData))->session,<o:p></o:p> + vm, *record)) {<o:p></o:p> + xmlFreeDoc(doc);<o:p></o:p> + xenapiSessionErrorHandler(conn,VIR_ERR_INTERNAL_ERROR ,NULL, __FILE__, __FUNCTION__, __LINE__);<o:p></o:p> + return -1;<o:p></o:p> + }<o:p></o:p> + cur = cur->xmlChildrenNode;<o:p></o:p> + int device_number=0;<o:p></o:p> + xmlChar *bridge=NULL,*mac=NULL;<o:p></o:p> + while (cur != NULL) {<o:p></o:p> + if ((!xmlStrcmp(cur->name, (const xmlChar *)"interface"))){<o:p></o:p> + for (child=cur->children;child!=NULL;child=child->next) {<o:p></o:p> + if ((!xmlStrcmp(child->name, (const xmlChar *)"source"))) {<o:p></o:p> + bridge = xmlGetProp(child, (const xmlChar *)"bridge");<o:p></o:p> + }<o:p></o:p> + if ((!xmlStrcmp(child->name, (const xmlChar *)"mac"))) {<o:p></o:p> + mac = xmlGetProp(child, (const xmlChar *)"address");<o:p></o:p> + }<o:p></o:p> + } <o:p></o:p> + if (mac!=NULL && bridge!=NULL) {<o:p></o:p> + char device[NETWORK_DEVID_SIZE]="\0";<o:p></o:p> + sprintf(device,"%d",device_number);<o:p></o:p> + createVifNetwork(conn, *vm, device, (char *)bridge, (char *)mac);<o:p></o:p> + xmlFree(bridge);<o:p></o:p> + device_number++;<o:p></o:p> + }<o:p></o:p> + }<o:p></o:p> + cur = cur->next;<o:p></o:p> + }<o:p></o:p> + xmlFreeDoc(doc);<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> diff -Nur ./libvirt_org/src/xenapi/xenapi_utils.h ./libvirt/src/xenapi/xenapi_utils.h<o:p></o:p> --- ./libvirt_org/src/xenapi/xenapi_utils.h 1970-01-01 01:00:00.000000000 +0100<o:p></o:p> +++ ./libvirt/src/xenapi/xenapi_utils.h 2010-02-18 16:28:10.000000000 +0000<o:p></o:p> @@ -0,0 +1,94 @@<o:p></o:p> +/*<o:p></o:p> + * xenapi_utils.h: Xen API driver -- utils header <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> +#ifndef _VIR_XENAPI_UTILS_<o:p></o:p> +#define _VIR_XENAPI_UTILS_<o:p></o:p> +<o:p></o:p> +#include <stdio.h><o:p></o:p> +#include <string.h><o:p></o:p> +#include <config.h><o:p></o:p> +<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> +//#include <xen/dom0_ops.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> +<o:p></o:p> +#define NETWORK_DEVID_SIZE (10)<o:p></o:p> +<o:p></o:p> +typedef uint64_t cpumap_t;<o:p></o:p> +<o:p></o:p> +void getCpuBitMapfromString(char *mask, unsigned char *cpumap, int maplen);<o:p></o:p> +<o:p></o:p> +int getStorageVolumeType(char *type);<o:p></o:p> +<o:p></o:p> +char *returnErrorFromSession(xen_session *session);<o:p></o:p> +<o:p></o:p> +void xenapiSessionErrorHandler(virConnectPtr conn, virErrorNumber errNum,<o:p></o:p> + const char *buf, const char *filename, const char *func, size_t lineno);<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +virDomainState<o:p></o:p> +mapPowerState(enum xen_vm_power_state state);<o:p></o:p> +<o:p></o:p> +char *<o:p></o:p> +mapDomainPinVcpu(unsigned int vcpu, unsigned char *cpumap, int maplen);<o:p></o:p> +<o:p></o:p> +char *<o:p></o:p> +getXmlChildValue(xmlDocPtr doc, xmlNodePtr cur, const char *tag);<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +createVMRecordFromXml (virConnectPtr conn, const char *xmlDesc,<o:p></o:p> + xen_vm_record **record, xen_vm *vm);<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +allocStringMap (xen_string_string_map **strings, char *key, char *val);<o:p></o:p> +<o:p></o:p> +void<o:p></o:p> +createXmlBootOrderString(char **order, char *key);<o:p></o:p> +<o:p></o:p> +enum xen_on_normal_exit<o:p></o:p> +actionShutdownStringtoEnum(char *str);<o:p></o:p> +<o:p></o:p> +enum xen_on_crash_behaviour<o:p></o:p> +actionCrashStringtoEnum(char *str);<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +createVifNetwork(virConnectPtr conn, xen_vm vm, char *device,<o:p></o:p> + char *bridge, char *mac);<o:p></o:p> +<o:p></o:p> +const char *<o:p></o:p> +mapXmlBootOrder(char c);<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> +<o:p></o:p> + <o:p></o:p> +#endif //_VIR_XENAPI_UTILS_<o:p></o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> </div> </body> </html>