xs_internal.c 21.8 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
struct xenUnifiedDriver xenStoreDriver = {
40 41 42 43
    xenStoreOpen, /* open */
    xenStoreClose, /* close */
    NULL, /* type */
    NULL, /* version */
44 45
    NULL, /* hostname */
    NULL, /* URI */
46
    NULL, /* nodeGetInfo */
47
    NULL, /* getCapabilities */
48 49 50 51 52
    xenStoreListDomains, /* listDomains */
    NULL, /* numOfDomains */
    NULL, /* domainCreateLinux */
    NULL, /* domainSuspend */
    NULL, /* domainResume */
53 54
    xenStoreDomainShutdown, /* domainShutdown */
    xenStoreDomainReboot, /* domainReboot */
55
    NULL, /* domainDestroy */
56
    xenStoreDomainGetOSType, /* domainGetOSType */
57
    xenStoreDomainGetMaxMemory, /* domainGetMaxMemory */
58 59
    NULL, /* domainSetMaxMemory */
    xenStoreDomainSetMemory, /* domainSetMemory */
60 61
    xenStoreGetDomainInfo, /* domainGetInfo */
    NULL, /* domainSave */
62
    NULL, /* domainRestore */
D
Daniel Veillard 已提交
63
    NULL, /* domainCoreDump */
64 65
    NULL, /* domainSetVcpus */
    NULL, /* domainPinVcpu */
66
    NULL, /* domainGetVcpus */
67
    NULL, /* domainGetMaxVcpus */
68
    NULL, /* domainDumpXML */
69 70 71 72 73
    NULL, /* listDefinedDomains */
    NULL, /* numOfDefinedDomains */
    NULL, /* domainCreate */
    NULL, /* domainDefineXML */
    NULL, /* domainUndefine */
74 75
    NULL, /* domainAttachDevice */
    NULL, /* domainDetachDevice */
76 77
    NULL, /* domainGetAutostart */
    NULL, /* domainSetAutostart */
78 79 80
    NULL, /* domainGetSchedulerType */
    NULL, /* domainGetSchedulerParameters */
    NULL, /* domainSetSchedulerParameters */
81 82
};

83
/**
84
 * xenStoreInit:
85
 *
86
 * Initialisation.
87
 */
88 89
int
xenStoreInit ()
90
{
91
    return 0;
92
}
93
#endif /* ! PROXY */
94

95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111
/**
 * 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);
112
    __virRaiseError(conn, NULL, NULL, VIR_FROM_XENSTORE, error, VIR_ERR_ERROR,
113 114 115 116 117 118 119 120
                    errmsg, info, NULL, 0, 0, errmsg, info);
}

/************************************************************************
 *									*
 *		Helper internal APIs					*
 *									*
 ************************************************************************/
121
#ifndef PROXY
122 123 124 125 126 127 128 129 130 131 132 133 134 135
/**
 * 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)
{
136 137 138 139 140 141 142
    xenUnifiedPrivatePtr priv;

    if (conn == NULL)
        return NULL;

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

145
    return xs_directory (priv->xshandle, 0, path, nb);
146
}
147
#endif /* ! PROXY */
148 149 150

/**
 * virDomainDoStoreQuery:
151 152
 * @conn: pointer to the hypervisor connection
 * @domid: id of the domain
153 154 155 156 157 158 159
 * @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 *
160
virDomainDoStoreQuery(virConnectPtr conn, int domid, const char *path)
161 162 163
{
    char s[256];
    unsigned int len = 0;
164 165 166 167
    xenUnifiedPrivatePtr priv;

    if (!conn)
        return NULL;
168

169 170
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
171 172
        return (NULL);

173
    snprintf(s, 255, "/local/domain/%d/%s", domid, path);
174 175
    s[255] = 0;

176
    return xs_read(priv->xshandle, 0, &s[0], &len);
177 178
}

179
#ifndef PROXY
180 181 182 183 184 185 186 187 188 189 190 191 192 193 194
/**
 * 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];
195
    xenUnifiedPrivatePtr priv;
196 197 198 199
    int ret = -1;

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (-1);
200 201 202

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
203 204 205 206
        return (-1);
    if (domain->conn->flags & VIR_CONNECT_RO)
        return (-1);

207
    snprintf(s, 255, "/local/domain/%d/%s", domain->id, path);
208 209
    s[255] = 0;

210
    if (xs_write(priv->xshandle, 0, &s[0], value, strlen(value)))
211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229
        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;
230
    xenUnifiedPrivatePtr priv;
231 232 233

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (NULL);
234 235 236

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
237 238 239 240 241
        return (NULL);

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

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

    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;
264
    xenUnifiedPrivatePtr priv;
265 266 267

    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (NULL);
268 269 270

    priv = (xenUnifiedPrivatePtr) domain->conn->privateData;
    if (priv->xshandle == NULL)
271 272 273 274 275
        return (NULL);

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

276
    ret = xs_read(priv->xshandle, 0, &s[0], &len);
277 278 279 280

    return (ret);
}

281
#if 0
282 283 284 285 286 287 288 289 290 291 292 293 294
/**
 * 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)
{
295
    if (conn->id >= 0) {
296 297
        int tmp;

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

/************************************************************************
 *									*
 *		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
323
xenStoreOpen(virConnectPtr conn,
324 325
             const char *name ATTRIBUTE_UNUSED,
             int flags ATTRIBUTE_UNUSED)
326
{
327
    xenUnifiedPrivatePtr priv = (xenUnifiedPrivatePtr) conn->privateData;
328

329
#ifdef PROXY
330
    priv->xshandle = xs_daemon_open_readonly();
331
#else
332
    if (flags & VIR_DRV_OPEN_RO)
333
	priv->xshandle = xs_daemon_open_readonly();
334
    else
335
	priv->xshandle = xs_daemon_open();
336
#endif /* ! PROXY */
337

338
    if (priv->xshandle == NULL) {
339
        virXenStoreError(NULL, VIR_ERR_NO_XEN, 
340
	                     _("failed to connect to Xen Store"));
341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356
        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)
{
357 358
    xenUnifiedPrivatePtr priv;

359 360
    if (conn == NULL) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
361
        return(-1);
362 363
    }

364 365 366 367 368
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
        return(-1);

    xs_daemon_close(priv->xshandle);
369 370 371
    return (0);
}

372
#ifndef PROXY
373 374 375
/**
 * xenStoreGetDomainInfo:
 * @domain: pointer to the domain block
376
 * @info: the place where information should be stored
377
 *
378
 * Do an hypervisor call to get the related set of domain information.
379 380 381 382 383 384 385 386 387
 *
 * 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];
388
    xenUnifiedPrivatePtr priv;
389

390 391 392
    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (-1);

393 394 395 396 397
    if ((domain == NULL) || (domain->conn == NULL) || (info == NULL)) {
        virXenStoreError(domain ? domain->conn : NULL, VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
	return(-1);
    }
398 399 400

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

403
    if (domain->id == -1)
404
        return(-1);
405

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

/**
444
 * xenStoreDomainSetMemory:
445 446 447 448 449 450 451 452
 * @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
453
xenStoreDomainSetMemory(virDomainPtr domain, unsigned long memory)
454 455 456 457
{
    int ret;
    char value[20];

D
Daniel Veillard 已提交
458 459
    if ((domain == NULL) || (domain->conn == NULL) ||
        (memory < 1024 * MIN_XEN_GUEST_SIZE)) {
460 461 462 463
        virXenStoreError(domain ? domain->conn : NULL, VIR_ERR_INVALID_ARG,
	                 __FUNCTION__);
	return(-1);
    }
464
    if (domain->id == -1)
465
        return(-1);
D
Daniel Veillard 已提交
466 467
    if ((domain->id == 0) && (memory < (2 * MIN_XEN_GUEST_SIZE * 1024)))
	return(-1);
468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489
    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;

490 491
    if (!VIR_IS_CONNECTED_DOMAIN(domain))
        return (ret);
492
    if (domain->id == -1)
493
        return(-1);
494

495
    tmp = virDomainDoStoreQuery(domain->conn, domain->id, "memory/target");
496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516
    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;
517
    xenUnifiedPrivatePtr priv;
518

519
    if (conn == NULL) {
520
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
521
        return -1;
522
    }
523 524 525 526 527 528 529

    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);
530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553
    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;
554
    xenUnifiedPrivatePtr priv;
555 556 557 558 559

    if ((conn == NULL) || (ids == NULL)) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
	return(-1);
    }
560 561 562

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
563 564
        return(-1);

565
    idlist = xs_directory (priv->xshandle, 0, "/local/domain", &num);
566 567 568 569 570 571 572 573 574
    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;
	}
575
#if 0
576 577
	if (virConnectCheckStoreID(conn, (int) id) < 0)
	    continue;
578
#endif
579 580
	ids[ret++] = (int) id;
    }
581
    free(idlist);
582 583 584 585
    return(ret);
}

/**
586
 * xenStoreLookupByName:
587 588 589 590 591 592 593 594
 * @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
595
xenStoreLookupByName(virConnectPtr conn, const char *name)
596 597 598 599 600
{
    virDomainPtr ret = NULL;
    unsigned int num, i, len;
    long id = -1;
    char **idlist = NULL, *endptr;
601
    char prop[200], *tmp;
602 603
    int found = 0;
    struct xend_domain *xenddomain = NULL;
604
    xenUnifiedPrivatePtr priv;
605 606 607 608 609

    if ((conn == NULL) || (name == NULL)) {
        virXenStoreError(conn, VIR_ERR_INVALID_ARG, __FUNCTION__);
	return(NULL);
    }
610 611 612

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
613 614
        return(NULL);

615
    idlist = xs_directory(priv->xshandle, 0, "/local/domain", &num);
616 617 618 619
    if (idlist == NULL)
	goto done;

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

641
    ret = virGetDomain(conn, name, NULL);
642
    if (ret == NULL)
643
        goto done;
644

645
    ret->id = id;
646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673

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);
    }
674
    if (domain->id == -1 || domain->id == 0)
675
        return(-1);
676 677 678 679 680 681 682
    /*
     * 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"));
}

683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701
/**
 * 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);
    }
702
    if (domain->id == -1 || domain->id == 0)
703
        return(-1);
704 705 706 707 708 709
    /*
     * 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"));
}
710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737

/*
 * 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);
}
738
#endif /* ! PROXY */
739

740 741
/**
 * xenStoreDomainGetVNCPort:
742 743
 * @conn: the hypervisor connection
 * @domid: id of the domain
744 745 746 747 748 749
 *
 * Return the port number on which the domain is listening for VNC
 * connections. 
 *
 * Returns the port number, -1 in case of error
 */
750
int             xenStoreDomainGetVNCPort(virConnectPtr conn, int domid) {
751 752 753
    char *tmp;
    int ret = -1;

754
    tmp = virDomainDoStoreQuery(conn, domid, "console/vnc-port");
755 756 757 758 759 760 761 762 763 764 765 766
    if (tmp != NULL) {
        char *end;
        ret = strtol(tmp, &end, 10);
        if (ret == 0 && end == tmp)
            ret = -1;
        free(tmp);
    }
    return(ret);
}

/**
 * xenStoreDomainGetConsolePath:
767 768
 * @conn: the hypervisor connection
 * @domid: id of the domain
769 770 771 772 773 774 775 776
 *
 * 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
 */
777 778
char *          xenStoreDomainGetConsolePath(virConnectPtr conn, int domid) {
  return virDomainDoStoreQuery(conn, domid, "console/tty");
779
}
780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796

#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;
797
    xenUnifiedPrivatePtr priv;
798 799 800 801

    if (id < 0)
        return(NULL);

802 803
    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
804 805 806 807 808
        return (NULL);

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

809
    vm = xs_read(priv->xshandle, 0, &query[0], &len);
810 811 812

    if (vm) {
        snprintf(query, 199, "%s/image/ostype", vm);
813
	str = xs_read(priv->xshandle, 0, &query[0], &len);
814 815
        free(vm);
    }
816 817 818
    if (str == NULL)
        str = strdup("linux");

819 820 821 822

    return (str);
}
#endif /* PROXY */
823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840

/*
 * 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;
841
    xenUnifiedPrivatePtr priv;
842 843 844

    if (id < 0)
        return(NULL);
845 846 847

    priv = (xenUnifiedPrivatePtr) conn->privateData;
    if (priv->xshandle == NULL)
848 849 850 851 852 853 854
        return (NULL);
    if (mac == NULL)
        return (NULL);
    maclen = strlen(mac);
    if (maclen <= 0)
        return (NULL);

855
    snprintf(dir, sizeof(dir), "/local/domain/0/backend/vif/%d", id);
856
    list = xs_directory(priv->xshandle, 0, dir, &num);
857 858 859
    if (list == NULL)
	return(NULL);
    for (i = 0; i < num; i++) {
860
	snprintf(path, sizeof(path), "%s/%s/%s", dir, list[i], "mac");
861
	val = xs_read(priv->xshandle, 0, path, &len);
862 863 864 865 866
	if (val == NULL)
	    break;
	if ((maclen != len) || memcmp(val, mac, len)) {
	    free(val);
	} else {
867
	    ret = strdup(list[i]);
868 869 870 871 872 873 874
	    free(val);
	    break;
	}
    }
    free(list);
    return(ret);
}
875

876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891
char *xenStoreDomainGetName(virConnectPtr conn,
                            int id) {
    char prop[200];
    xenUnifiedPrivatePtr priv;
    unsigned int len;

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

    snprintf(prop, 199, "/local/domain/%d/name", id);
    prop[199] = 0;
    return xs_read(priv->xshandle, 0, prop, &len);
}


892 893 894 895 896 897 898 899 900
#endif /* WITH_XEN */
/*
 * Local variables:
 *  indent-tabs-mode: nil
 *  c-indent-level: 4
 *  c-basic-offset: 4
 *  tab-width: 4
 * End:
 */