xs_internal.c 21.6 KB
Newer Older
1 2 3 4 5 6 7 8 9 10
/*
 * xs_internal.c: access to Xen Store
 *
 * Copyright (C) 2006 Red Hat, Inc.
 *
 * See COPYING.LIB for the License of this software
 *
 * Daniel Veillard <veillard@redhat.com>
 */

11
#ifdef WITH_XEN
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/ioctl.h>

#include <stdint.h>

#include <xen/dom0_ops.h>
#include <xen/version.h>
#include <xen/xen.h>

#include <xs.h>

#include "internal.h"
#include "driver.h"
30
#include "xen_unified.h"
31
#include "xs_internal.h"
32
#include "xen_internal.h" /* for xenHypervisorCheckID */
33 34 35

#define XEN_HYPERVISOR_SOCKET "/proc/xen/privcmd"

36
#ifndef PROXY
37 38
static char *xenStoreDomainGetOSType(virDomainPtr domain);

39 40
virDriver xenStoreDriver = {
    -1,
41
    "XenStore",
42 43 44
    (DOM0_INTERFACE_VERSION >> 24) * 1000000 +
    ((DOM0_INTERFACE_VERSION >> 16) & 0xFF) * 1000 +
    (DOM0_INTERFACE_VERSION & 0xFFFF),
45 46 47 48
    xenStoreOpen, /* open */
    xenStoreClose, /* close */
    NULL, /* type */
    NULL, /* version */
49
    NULL, /* getMaxVcpus */
50
    NULL, /* nodeGetInfo */
51
    NULL, /* getCapabilities */
52 53 54 55 56
    xenStoreListDomains, /* listDomains */
    NULL, /* numOfDomains */
    NULL, /* domainCreateLinux */
    NULL, /* domainLookupByID */
    NULL, /* domainLookupByUUID */
57
    xenStoreDomainLookupByName, /* domainLookupByName */
58 59
    NULL, /* domainSuspend */
    NULL, /* domainResume */
60 61
    xenStoreDomainShutdown, /* domainShutdown */
    xenStoreDomainReboot, /* domainReboot */
62
    NULL, /* domainDestroy */
63
    xenStoreDomainGetOSType, /* domainGetOSType */
64
    xenStoreDomainGetMaxMemory, /* domainGetMaxMemory */
65 66
    NULL, /* domainSetMaxMemory */
    xenStoreDomainSetMemory, /* domainSetMemory */
67 68
    xenStoreGetDomainInfo, /* domainGetInfo */
    NULL, /* domainSave */
69
    NULL, /* domainRestore */
D
Daniel Veillard 已提交
70
    NULL, /* domainCoreDump */
71 72
    NULL, /* domainSetVcpus */
    NULL, /* domainPinVcpu */
73
    NULL, /* domainGetVcpus */
74
    NULL, /* domainGetMaxVcpus */
75
    NULL, /* domainDumpXML */
76 77 78 79 80
    NULL, /* listDefinedDomains */
    NULL, /* numOfDefinedDomains */
    NULL, /* domainCreate */
    NULL, /* domainDefineXML */
    NULL, /* domainUndefine */
81 82
    NULL, /* domainAttachDevice */
    NULL, /* domainDetachDevice */
83 84
    NULL, /* domainGetAutostart */
    NULL, /* domainSetAutostart */
85 86
};

87
/**
88
 * xenStoreInit:
89
 *
90
 * Initialisation.
91
 */
92 93
int
xenStoreInit ()
94
{
95
    return 0;
96
}
97
#endif /* ! PROXY */
98

99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115
/**
 * virXenStoreError:
 * @conn: the connection if available
 * @error: the error number
 * @info: extra information string
 *
 * Handle an error at the xend store interface
 */
static void
virXenStoreError(virConnectPtr conn, virErrorNumber error, const char *info)
{
    const char *errmsg;

    if (error == VIR_ERR_OK)
        return;

    errmsg = __virErrorMsg(error, info);
116
    __virRaiseError(conn, NULL, NULL, VIR_FROM_XENSTORE, error, VIR_ERR_ERROR,
117 118 119 120 121 122 123 124
                    errmsg, info, NULL, 0, 0, errmsg, info);
}

/************************************************************************
 *									*
 *		Helper internal APIs					*
 *									*
 ************************************************************************/
125
#ifndef PROXY
126 127 128 129 130 131 132 133 134 135 136 137 138 139
/**
 * virConnectDoStoreList:
 * @conn: pointer to the hypervisor connection
 * @path: the absolute path of the directory in the store to list
 * @nb: OUT pointer to the number of items found
 *
 * Internal API querying the Xenstore for a list
 *
 * Returns a string which must be freed by the caller or NULL in case of error
 */
static char **
virConnectDoStoreList(virConnectPtr conn, const char *path,
                      unsigned int *nb)
{
140 141 142 143 144 145 146
    xenUnifiedPrivatePtr priv;

    if (conn == NULL)
        return NULL;

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL || path == NULL || nb == NULL)
147 148
        return (NULL);

149
    return xs_directory (priv->xshandle, 0, path, nb);
150
}
151
#endif /* ! PROXY */
152 153 154

/**
 * virDomainDoStoreQuery:
155 156
 * @conn: pointer to the hypervisor connection
 * @domid: id of the domain
157 158 159 160 161 162 163
 * @path: the relative path of the data in the store to retrieve
 *
 * Internal API querying the Xenstore for a string value.
 *
 * Returns a string which must be freed by the caller or NULL in case of error
 */
static char *
164
virDomainDoStoreQuery(virConnectPtr conn, int domid, const char *path)
165 166 167
{
    char s[256];
    unsigned int len = 0;
168 169 170 171
    xenUnifiedPrivatePtr priv;

    if (!conn)
        return NULL;
172

173 174
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
175 176
        return (NULL);

177
    snprintf(s, 255, "/local/domain/%d/%s", domid, path);
178 179
    s[255] = 0;

180
    return xs_read(priv->xshandle, 0, &s[0], &len);
181 182
}

183
#ifndef PROXY
184 185 186 187 188 189 190 191 192 193 194 195 196 197 198
/**
 * virDomainDoStoreWrite:
 * @domain: a domain object
 * @path: the relative path of the data in the store to retrieve
 *
 * Internal API setting up a string value in the Xenstore
 * Requires write access to the XenStore
 *
 * Returns 0 in case of success, -1 in case of failure
 */
static int
virDomainDoStoreWrite(virDomainPtr domain, const char *path,
                      const char *value)
{
    char s[256];
199
    xenUnifiedPrivatePtr priv;
200 201 202 203
    int ret = -1;

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (-1);
204 205 206

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
207 208 209 210
        return (-1);
    if (domain->conn->flags & VIR_CONNECT_RO)
        return (-1);

211
    snprintf(s, 255, "/local/domain/%d/%s", domain->id, path);
212 213
    s[255] = 0;

214
    if (xs_write(priv->xshandle, 0, &s[0], value, strlen(value)))
215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233
        ret = 0;

    return (ret);
}

/**
 * virDomainGetVM:
 * @domain: a domain object
 *
 * Internal API extracting a xenstore vm path.
 *
 * Returns the new string or NULL in case of error
 */
char *
virDomainGetVM(virDomainPtr domain)
{
    char *vm;
    char query[200];
    unsigned int len;
234
    xenUnifiedPrivatePtr priv;
235 236 237

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (NULL);
238 239 240

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
241 242 243 244 245
        return (NULL);

    snprintf(query, 199, "/local/domain/%d/vm", virDomainGetID(domain));
    query[199] = 0;

246
    vm = xs_read(priv->xshandle, 0, &query[0], &len);
247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267

    return (vm);
}

/**
 * virDomainGetVMInfo:
 * @domain: a domain object
 * @vm: the xenstore vm path
 * @name: the value's path
 *
 * Internal API extracting one information the device used 
 * by the domain from xensttore
 *
 * Returns the new string or NULL in case of error
 */
char *
virDomainGetVMInfo(virDomainPtr domain, const char *vm, const char *name)
{
    char s[256];
    char *ret = NULL;
    unsigned int len = 0;
268
    xenUnifiedPrivatePtr priv;
269 270 271

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (NULL);
272 273 274

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
275 276 277 278 279
        return (NULL);

    snprintf(s, 255, "%s/%s", vm, name);
    s[255] = 0;

280
    ret = xs_read(priv->xshandle, 0, &s[0], &len);
281 282 283 284

    return (ret);
}

285
#if 0
286 287 288 289 290 291 292 293 294 295 296 297 298
/**
 * virConnectCheckStoreID:
 * @conn: pointer to the hypervisor connection
 * @id: the id number as returned from Xenstore
 *
 * the xenstore sometimes list non-running domains, double check
 * from the hypervisor if we have direct access
 *
 * Returns -1 if the check failed, 0 if successful or not possible to check
 */
static int
virConnectCheckStoreID(virConnectPtr conn, int id)
{
299
    if (conn->id >= 0) {
300 301
        int tmp;

302
        tmp = xenHypervisorCheckID(conn, id);
303 304 305 306 307
        if (tmp < 0)
            return (-1);
    }
    return (0);
}
308
#endif
309
#endif /* ! PROXY */
310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326

/************************************************************************
 *									*
 *		Canonical internal APIs					*
 *									*
 ************************************************************************/
/**
 * xenStoreOpen:
 * @conn: pointer to the connection block
 * @name: URL for the target, NULL for local
 * @flags: combination of virDrvOpenFlag(s)
 *
 * Connects to the Xen hypervisor.
 *
 * Returns 0 or -1 in case of error.
 */
int
327
xenStoreOpen(virConnectPtr conn,
328 329
             const char *name ATTRIBUTE_UNUSED,
             int flags ATTRIBUTE_UNUSED)
330
{
331
    xenUnifiedPrivatePtr priv = (xenUnifiedPrivatePtr) conn->privateData;
332

333
#ifdef PROXY
334
    priv->xshandle = xs_daemon_open_readonly();
335
#else
336
    if (flags & VIR_DRV_OPEN_RO)
337
	priv->xshandle = xs_daemon_open_readonly();
338
    else
339
	priv->xshandle = xs_daemon_open();
340
#endif /* ! PROXY */
341

342
    if (priv->xshandle == NULL) {
343
        virXenStoreError(NULL, VIR_ERR_NO_XEN, 
344
	                     _("failed to connect to Xen Store"));
345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360
        return (-1);
    }
    return (0);
}

/**
 * xenStoreClose:
 * @conn: pointer to the connection block
 *
 * Close the connection to the Xen hypervisor.
 *
 * Returns 0 in case of success or -1 in case of error.
 */
int
xenStoreClose(virConnectPtr conn)
{
361 362
    xenUnifiedPrivatePtr priv;

363 364
    if (conn == NULL) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
365
        return(-1);
366 367
    }

368 369 370 371 372
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
        return(-1);

    xs_daemon_close(priv->xshandle);
373 374 375
    return (0);
}

376
#ifndef PROXY
377 378 379
/**
 * xenStoreGetDomainInfo:
 * @domain: pointer to the domain block
380
 * @info: the place where information should be stored
381
 *
382
 * Do an hypervisor call to get the related set of domain information.
383 384 385 386 387 388 389 390 391
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
xenStoreGetDomainInfo(virDomainPtr domain, virDomainInfoPtr info)
{
    char *tmp, **tmp2;
    unsigned int nb_vcpus;
    char request[200];
392
    xenUnifiedPrivatePtr priv;
393

394 395 396
    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (-1);

397 398 399 400 401
    if ((domain == NULL) || (domain->conn == NULL) || (info == NULL)) {
        virXenStoreError(domain ? domain->conn : NULL, VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
	return(-1);
    }
402 403 404

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
405
        return(-1);
406

407
    if (domain->id == -1)
408
        return(-1);
409

410
    tmp = virDomainDoStoreQuery(domain->conn, domain->id, "running");
411 412 413 414 415 416 417
    if (tmp != NULL) {
        if (tmp[0] == '1')
            info->state = VIR_DOMAIN_RUNNING;
        free(tmp);
    } else {
        info->state = VIR_DOMAIN_NONE;
    }
418
    tmp = virDomainDoStoreQuery(domain->conn, domain->id, "memory/target");
419 420 421 422 423 424 425 426 427 428
    if (tmp != NULL) {
        info->memory = atol(tmp);
        info->maxMem = atol(tmp);
        free(tmp);
    } else {
        info->memory = 0;
        info->maxMem = 0;
    }
#if 0
    /* doesn't seems to work */
429
    tmp = virDomainDoStoreQuery(domain->conn, domain->id, "cpu_time");
430 431 432 433 434 435 436
    if (tmp != NULL) {
        info->cpuTime = atol(tmp);
        free(tmp);
    } else {
        info->cpuTime = 0;
    }
#endif
437
    snprintf(request, 199, "/local/domain/%d/cpu", domain->id);
438 439 440 441 442 443 444 445 446 447
    request[199] = 0;
    tmp2 = virConnectDoStoreList(domain->conn, request, &nb_vcpus);
    if (tmp2 != NULL) {
        info->nrVirtCpu = nb_vcpus;
        free(tmp2);
    }
    return (0);
}

/**
448
 * xenStoreDomainSetMemory:
449 450 451 452 453 454 455 456
 * @domain: pointer to the domain block
 * @memory: the max memory size in kilobytes.
 *
 * Change the maximum amount of memory allowed in the xen store
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
457
xenStoreDomainSetMemory(virDomainPtr domain, unsigned long memory)
458 459 460 461
{
    int ret;
    char value[20];

D
Daniel Veillard 已提交
462 463
    if ((domain == NULL) || (domain->conn == NULL) ||
        (memory < 1024 * MIN_XEN_GUEST_SIZE)) {
464 465 466 467
        virXenStoreError(domain ? domain->conn : NULL, VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
	return(-1);
    }
468
    if (domain->id == -1)
469
        return(-1);
D
Daniel Veillard 已提交
470 471
    if ((domain->id == 0) && (memory < (2 * MIN_XEN_GUEST_SIZE * 1024)))
	return(-1);
472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493
    snprintf(value, 19, "%lu", memory);
    value[19] = 0;
    ret = virDomainDoStoreWrite(domain, "memory/target", &value[0]);
    if (ret < 0)
        return (-1);
    return (0);
}

/**
 * xenStoreDomainGetMaxMemory:
 * @domain: pointer to the domain block
 *
 * Ask the xenstore for the maximum memory allowed for a domain
 *
 * Returns the memory size in kilobytes or 0 in case of error.
 */
unsigned long
xenStoreDomainGetMaxMemory(virDomainPtr domain)
{
    char *tmp;
    unsigned long ret = 0;

494 495
    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (ret);
496
    if (domain->id == -1)
497
        return(-1);
498

499
    tmp = virDomainDoStoreQuery(domain->conn, domain->id, "memory/target");
500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520
    if (tmp != NULL) {
	ret = (unsigned long) atol(tmp);
	free(tmp);
    }
    return(ret);
}

/**
 * xenStoreNumOfDomains:
 * @conn: pointer to the hypervisor connection
 *
 * Provides the number of active domains.
 *
 * Returns the number of domain found or -1 in case of error
 */
int
xenStoreNumOfDomains(virConnectPtr conn)
{
    unsigned int num;
    char **idlist;
    int ret = -1;
521
    xenUnifiedPrivatePtr priv;
522

523
    if (conn == NULL) {
524
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
525
        return -1;
526
    }
527 528 529 530 531 532 533

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
        return(-1);
    }
    idlist = xs_directory(priv->xshandle, 0, "/local/domain", &num);
534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557
    if (idlist) {
        free(idlist);
	ret = num;
    }
    return(ret);
}

/**
 * xenStoreListDomains:
 * @conn: pointer to the hypervisor connection
 * @ids: array to collect the list of IDs of active domains
 * @maxids: size of @ids
 *
 * Collect the list of active domains, and store their ID in @maxids
 *
 * Returns the number of domain found or -1 in case of error
 */
int
xenStoreListDomains(virConnectPtr conn, int *ids, int maxids)
{
    char **idlist = NULL, *endptr;
    unsigned int num, i;
    int ret;
    long id;
558
    xenUnifiedPrivatePtr priv;
559 560 561 562 563

    if ((conn == NULL) || (ids == NULL)) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
	return(-1);
    }
564 565 566

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
567 568
        return(-1);

569
    idlist = xs_directory (priv->xshandle, 0, "/local/domain", &num);
570 571 572 573 574 575 576 577 578
    if (idlist == NULL)
	return(-1);

    for (ret = 0, i = 0; (i < num) && (ret < maxids); i++) {
	id = strtol(idlist[i], &endptr, 10);
	if ((endptr == idlist[i]) || (*endptr != 0)) {
	    ret = -1;
	    break;
	}
579
#if 0
580 581
	if (virConnectCheckStoreID(conn, (int) id) < 0)
	    continue;
582
#endif
583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606
	ids[ret++] = (int) id;
    }
    return(ret);
}

/**
 * xenStoreDomainLookupByName:
 * @conn: A xend instance
 * @name: The name of the domain
 *
 * Try to lookup a domain on the Xen Store based on its name.
 *
 * Returns a new domain object or NULL in case of failure
 */
virDomainPtr
xenStoreDomainLookupByName(virConnectPtr conn, const char *name)
{
    virDomainPtr ret = NULL;
    unsigned int num, i, len;
    long id = -1;
    char **idlist = NULL, *endptr;
    char prop[200], *tmp, *path = NULL;
    int found = 0;
    struct xend_domain *xenddomain = NULL;
607
    xenUnifiedPrivatePtr priv;
608 609 610 611 612

    if ((conn == NULL) || (name == NULL)) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
	return(NULL);
    }
613 614 615

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
616 617
        return(NULL);

618
    idlist = xs_directory(priv->xshandle, 0, "/local/domain", &num);
619 620 621 622 623 624 625 626
    if (idlist == NULL)
	goto done;

    for (i = 0; i < num; i++) {
	id = strtol(idlist[i], &endptr, 10);
	if ((endptr == idlist[i]) || (*endptr != 0)) {
	    goto done;
	}
627
#if 0
628 629
	if (virConnectCheckStoreID(conn, (int) id) < 0)
	    continue;
630
#endif
631 632
	snprintf(prop, 199, "/local/domain/%s/name", idlist[i]);
	prop[199] = 0;
633
	tmp = xs_read(priv->xshandle, 0, prop, &len);
634 635 636 637 638 639 640
	if (tmp != NULL) {
	    found = !strcmp(name, tmp);
	    free(tmp);
	    if (found)
		break;
	}
    }
641
    path = xs_get_domain_path(priv->xshandle, (unsigned int) id);
642 643 644 645

    if (!found)
        return(NULL);

646 647
    ret = virGetDomain(conn, name, NULL);
    if (ret == NULL) {
648
        virXenStoreError(conn, VIR_ERR_NO_MEMORY, _("allocating domain"));
649 650
	if (path != NULL)
	    free(path);
651
	goto done;
652
    }
653
    ret->id = id;
654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682
    ret->path = path;

done:
    if (xenddomain != NULL)
	free(xenddomain);
    if (idlist != NULL)
	free(idlist);

    return(ret);
}

/**
 * xenStoreDomainShutdown:
 * @domain: pointer to the Domain block
 *
 * Shutdown the domain, the OS is requested to properly shutdown
 * and the domain may ignore it.  It will return immediately
 * after queuing the request.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
xenStoreDomainShutdown(virDomainPtr domain)
{
    if ((domain == NULL) || (domain->conn == NULL)) {
        virXenStoreError((domain ? domain->conn : NULL), VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
        return(-1);
    }
683
    if (domain->id == -1 || domain->id == 0)
684
        return(-1);
685 686 687 688 689 690 691
    /*
     * this is very hackish, the domU kernel probes for a special 
     * node in the xenstore and launch the shutdown command if found.
     */
    return(virDomainDoStoreWrite(domain, "control/shutdown", "halt"));
}

692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710
/**
 * xenStoreDomainReboot:
 * @domain: pointer to the Domain block
 * @flags: extra flags for the reboot operation, not used yet
 *
 * Reboot the domain, the OS is requested to properly shutdown
 * and reboot but the domain may ignore it.  It will return immediately
 * after queuing the request.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
xenStoreDomainReboot(virDomainPtr domain, unsigned int flags ATTRIBUTE_UNUSED)
{
    if ((domain == NULL) || (domain->conn == NULL)) {
        virXenStoreError((domain ? domain->conn : NULL), VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
        return(-1);
    }
711
    if (domain->id == -1 || domain->id == 0)
712
        return(-1);
713 714 715 716 717 718
    /*
     * this is very hackish, the domU kernel probes for a special 
     * node in the xenstore and launch the shutdown command if found.
     */
    return(virDomainDoStoreWrite(domain, "control/shutdown", "reboot"));
}
719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746

/*
 * xenStoreDomainGetOSType:
 * @domain: a domain object
 *
 * Get the type of domain operation system.
 *
 * Returns the new string or NULL in case of error, the string must be
 *         freed by the caller.
 */
static char *
xenStoreDomainGetOSType(virDomainPtr domain) {
    char *vm, *str = NULL;

    if ((domain == NULL) || (domain->conn == NULL)) {
        virXenStoreError((domain ? domain->conn : NULL), VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
        return(NULL);
    }

    vm = virDomainGetVM(domain);
    if (vm) {
        str = virDomainGetVMInfo(domain, vm, "image/ostype");
        free(vm);
    }

    return (str);
}
747
#endif /* ! PROXY */
748

749 750
/**
 * xenStoreDomainGetVNCPort:
751 752
 * @conn: the hypervisor connection
 * @domid: id of the domain
753 754 755 756 757 758
 *
 * Return the port number on which the domain is listening for VNC
 * connections. 
 *
 * Returns the port number, -1 in case of error
 */
759
int             xenStoreDomainGetVNCPort(virConnectPtr conn, int domid) {
760 761 762
    char *tmp;
    int ret = -1;

763
    tmp = virDomainDoStoreQuery(conn, domid, "console/vnc-port");
764 765 766 767 768 769 770 771 772 773 774 775
    if (tmp != NULL) {
        char *end;
        ret = strtol(tmp, &end, 10);
        if (ret == 0 && end == tmp)
            ret = -1;
        free(tmp);
    }
    return(ret);
}

/**
 * xenStoreDomainGetConsolePath:
776 777
 * @conn: the hypervisor connection
 * @domid: id of the domain
778 779 780 781 782 783 784 785
 *
 * Return the path to the psuedo TTY on which the guest domain's
 * serial console is attached.
 *
 * Returns the path to the serial console. It is the callers
 * responsibilty to free() the return string. Returns NULL
 * on error
 */
786 787
char *          xenStoreDomainGetConsolePath(virConnectPtr conn, int domid) {
  return virDomainDoStoreQuery(conn, domid, "console/tty");
788
}
789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805

#ifdef PROXY
/*
 * xenStoreDomainGetOSTypeID:
 * @conn: pointer to the connection.
 * @id: the domain id
 *
 * Get the type of domain operation system.
 *
 * Returns the new string or NULL in case of error, the string must be
 *         freed by the caller.
 */
char *
xenStoreDomainGetOSTypeID(virConnectPtr conn, int id) {
    char *vm, *str = NULL;
    char query[200];
    unsigned int len;
806
    xenUnifiedPrivatePtr priv;
807 808 809 810

    if (id < 0)
        return(NULL);

811 812
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
813 814 815 816 817
        return (NULL);

    snprintf(query, 199, "/local/domain/%d/vm", id);
    query[199] = 0;

818
    vm = xs_read(priv->xshandle, 0, &query[0], &len);
819 820 821

    if (vm) {
        snprintf(query, 199, "%s/image/ostype", vm);
822
	str = xs_read(priv->xshandle, 0, &query[0], &len);
823 824
        free(vm);
    }
825 826 827
    if (str == NULL)
        str = strdup("linux");

828 829 830 831

    return (str);
}
#endif /* PROXY */
832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849

/*
 * xenStoreDomainGetNetworkID:
 * @conn: pointer to the connection.
 * @id: the domain id
 * @mac: the mac address
 *
 * Get the reference (i.e. the string number) for the device on that domain
 * which uses the given mac address
 *
 * Returns the new string or NULL in case of error, the string must be
 *         freed by the caller.
 */
char *
xenStoreDomainGetNetworkID(virConnectPtr conn, int id, const char *mac) {
    char dir[80], path[128], **list = NULL, *val = NULL;
    unsigned int maclen, len, i, num;
    char *ret = NULL;
850
    xenUnifiedPrivatePtr priv;
851 852 853

    if (id < 0)
        return(NULL);
854 855 856

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
857 858 859 860 861 862 863
        return (NULL);
    if (mac == NULL)
        return (NULL);
    maclen = strlen(mac);
    if (maclen <= 0)
        return (NULL);

864
    snprintf(dir, sizeof(dir), "/local/domain/0/backend/vif/%d", id);
865
    list = xs_directory(priv->xshandle, 0, dir, &num);
866 867 868
    if (list == NULL)
	return(NULL);
    for (i = 0; i < num; i++) {
869
	snprintf(path, sizeof(path), "%s/%s/%s", dir, list[i], "mac");
870
	val = xs_read(priv->xshandle, 0, path, &len);
871 872 873 874 875
	if (val == NULL)
	    break;
	if ((maclen != len) || memcmp(val, mac, len)) {
	    free(val);
	} else {
876
	    ret = strdup(list[i]);
877 878 879 880 881 882 883
	    free(val);
	    break;
	}
    }
    free(list);
    return(ret);
}
884 885 886 887 888 889 890 891 892 893

#endif /* WITH_XEN */
/*
 * Local variables:
 *  indent-tabs-mode: nil
 *  c-indent-level: 4
 *  c-basic-offset: 4
 *  tab-width: 4
 * End:
 */