vz_driver.c 43.0 KB
Newer Older
D
Dmitry Guryanov 已提交
1
/*
2
 * vz_driver.c: core driver functions for managing
D
Dmitry Guryanov 已提交
3 4
 * Parallels Cloud Server hosts
 *
5
 * Copyright (C) 2014-2015 Red Hat, Inc.
D
Dmitry Guryanov 已提交
6 7 8 9 10 11 12 13 14 15 16 17 18
 * Copyright (C) 2012 Parallels, Inc.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
19
 * License along with this library.  If not, see
D
Dmitry Guryanov 已提交
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43
 * <http://www.gnu.org/licenses/>.
 *
 */

#include <config.h>

#include <sys/types.h>
#include <sys/poll.h>
#include <limits.h>
#include <string.h>
#include <stdio.h>
#include <stdarg.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <paths.h>
#include <pwd.h>
#include <sys/wait.h>
#include <sys/time.h>
#include <sys/statvfs.h>

#include "datatypes.h"
44
#include "virerror.h"
45
#include "viralloc.h"
46
#include "virlog.h"
47
#include "vircommand.h"
D
Dmitry Guryanov 已提交
48
#include "configmake.h"
49
#include "virfile.h"
50
#include "virstoragefile.h"
D
Dmitry Guryanov 已提交
51
#include "nodeinfo.h"
52
#include "virstring.h"
53
#include "cpu/cpu.h"
54
#include "virtypedparam.h"
D
Dmitry Guryanov 已提交
55

56 57 58
#include "vz_driver.h"
#include "vz_utils.h"
#include "vz_sdk.h"
D
Dmitry Guryanov 已提交
59 60 61

#define VIR_FROM_THIS VIR_FROM_PARALLELS

62 63
VIR_LOG_INIT("parallels.parallels_driver");

D
Dmitry Guryanov 已提交
64 65
#define PRLCTL                      "prlctl"

66
static int vzConnectClose(virConnectPtr conn);
D
Dmitry Guryanov 已提交
67

D
Dmitry Guryanov 已提交
68
void
69
vzDriverLock(vzConnPtr driver)
D
Dmitry Guryanov 已提交
70 71 72 73
{
    virMutexLock(&driver->lock);
}

D
Dmitry Guryanov 已提交
74
void
75
vzDriverUnlock(vzConnPtr driver)
D
Dmitry Guryanov 已提交
76 77 78 79
{
    virMutexUnlock(&driver->lock);
}

D
Dmitry Guryanov 已提交
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100
static int
vzCapsAddGuestDomain(virCapsPtr caps,
                     virDomainOSType ostype,
                     virArch arch,
                     const char * emulator,
                     virDomainVirtType virt_type)
{
    virCapsGuestPtr guest;

    if ((guest = virCapabilitiesAddGuest(caps, ostype, arch, emulator,
                                         NULL, 0, NULL)) == NULL)
        return -1;


    if (virCapabilitiesAddGuestDomain(guest, virt_type,
                                      NULL, NULL, 0, NULL) == NULL)
        return -1;

    return 0;
}

D
Dmitry Guryanov 已提交
101
static virCapsPtr
102
vzBuildCapabilities(void)
D
Dmitry Guryanov 已提交
103
{
104 105 106 107
    virCapsPtr caps = NULL;
    virCPUDefPtr cpu = NULL;
    virCPUDataPtr data = NULL;
    virNodeInfo nodeinfo;
D
Dmitry Guryanov 已提交
108 109 110 111 112 113 114 115 116 117 118
    virDomainOSType ostypes[] = {
        VIR_DOMAIN_OSTYPE_HVM,
        VIR_DOMAIN_OSTYPE_EXE
    };
    virArch archs[] = { VIR_ARCH_I686, VIR_ARCH_X86_64 };
    const char *const emulators[] = { "parallels", "vz" };
    virDomainVirtType virt_types[] = {
        VIR_DOMAIN_VIRT_PARALLELS,
        VIR_DOMAIN_VIRT_VZ
    };
    size_t i, j, k;
D
Dmitry Guryanov 已提交
119

120
    if ((caps = virCapabilitiesNew(virArchFromHost(),
121
                                   false, false)) == NULL)
122
        return NULL;
D
Dmitry Guryanov 已提交
123

124
    if (nodeCapsInitNUMA(NULL, caps) < 0)
125
        goto error;
D
Dmitry Guryanov 已提交
126

D
Dmitry Guryanov 已提交
127 128 129 130 131 132
    for (i = 0; i < 2; i++)
        for (j = 0; j < 2; j++)
            for (k = 0; k < 2; k++)
                if (vzCapsAddGuestDomain(caps, ostypes[i], archs[j],
                                         emulators[k], virt_types[k]) < 0)
                    goto error;
133

134
    if (nodeGetInfo(NULL, &nodeinfo))
135 136
        goto error;

137
    if (VIR_ALLOC(cpu) < 0)
138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154
        goto error;

    cpu->arch = caps->host.arch;
    cpu->type = VIR_CPU_TYPE_HOST;
    cpu->sockets = nodeinfo.sockets;
    cpu->cores = nodeinfo.cores;
    cpu->threads = nodeinfo.threads;

    caps->host.cpu = cpu;

    if (!(data = cpuNodeData(cpu->arch))
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0) {
        goto cleanup;
    }

 cleanup:
    cpuDataFree(data);
D
Dmitry Guryanov 已提交
155 156
    return caps;

157
 error:
158
    virObjectUnref(caps);
159
    goto cleanup;
D
Dmitry Guryanov 已提交
160 161 162
}

static char *
163
vzConnectGetCapabilities(virConnectPtr conn)
D
Dmitry Guryanov 已提交
164
{
165
    vzConnPtr privconn = conn->privateData;
D
Dmitry Guryanov 已提交
166 167
    char *xml;

168
    vzDriverLock(privconn);
169
    xml = virCapabilitiesFormatXML(privconn->caps);
170
    vzDriverUnlock(privconn);
D
Dmitry Guryanov 已提交
171 172 173
    return xml;
}

174
static int
175
vzDomainDefPostParse(virDomainDefPtr def ATTRIBUTE_UNUSED,
M
Michal Privoznik 已提交
176
                     virCapsPtr caps ATTRIBUTE_UNUSED,
177
                     unsigned int parseFlags ATTRIBUTE_UNUSED,
178
                     void *opaque)
179
{
180 181 182
    if (vzCheckUnsupportedDisks(def, opaque) < 0)
        return -1;

183 184 185
    if (vzCheckUnsupportedControllers(def, opaque) < 0)
        return -1;

186 187 188 189
    return 0;
}

static int
190
vzDomainDeviceDefPostParse(virDomainDeviceDefPtr dev,
M
Michal Privoznik 已提交
191 192
                           const virDomainDef *def,
                           virCapsPtr caps ATTRIBUTE_UNUSED,
193
                           unsigned int parseFlags ATTRIBUTE_UNUSED,
M
Michal Privoznik 已提交
194
                           void *opaque ATTRIBUTE_UNUSED)
195
{
196 197 198 199 200 201
    int ret = -1;

    if (dev->type == VIR_DOMAIN_DEVICE_NET &&
        (dev->data.net->type == VIR_DOMAIN_NET_TYPE_NETWORK ||
         dev->data.net->type == VIR_DOMAIN_NET_TYPE_BRIDGE) &&
        !dev->data.net->model &&
202
        def->os.type == VIR_DOMAIN_OSTYPE_HVM &&
203 204 205 206 207 208
        VIR_STRDUP(dev->data.net->model, "e1000") < 0)
        goto cleanup;

    ret = 0;
 cleanup:
    return ret;
209 210 211
}


212
virDomainDefParserConfig vzDomainDefParserConfig = {
213
    .macPrefix = {0x42, 0x1C, 0x00},
214 215
    .devicesPostParseCallback = vzDomainDeviceDefPostParse,
    .domainPostParseCallback = vzDomainDefPostParse,
216 217 218
};


D
Dmitry Guryanov 已提交
219
static int
220
vzOpenDefault(virConnectPtr conn)
D
Dmitry Guryanov 已提交
221
{
222
    vzConnPtr privconn;
D
Dmitry Guryanov 已提交
223

224
    if (VIR_ALLOC(privconn) < 0)
D
Dmitry Guryanov 已提交
225 226 227 228
        return VIR_DRV_OPEN_ERROR;
    if (virMutexInit(&privconn->lock) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("cannot initialize mutex"));
229 230 231
        goto err_free;
    }

232 233
    privconn->drivername = conn->driver->name;

234
    if (prlsdkInit()) {
235 236
        VIR_DEBUG("%s", _("Can't initialize Parallels SDK"));
        goto err_free;
D
Dmitry Guryanov 已提交
237 238
    }

239 240 241
    if (prlsdkConnect(privconn) < 0)
        goto err_free;

242 243 244
    if (vzInitVersion(privconn) < 0)
        goto error;

245
    if (!(privconn->caps = vzBuildCapabilities()))
D
Dmitry Guryanov 已提交
246 247
        goto error;

248
    vzDomainDefParserConfig.priv = &privconn->vzCaps;
249
    if (!(privconn->xmlopt = virDomainXMLOptionNew(&vzDomainDefParserConfig,
M
Michal Privoznik 已提交
250
                                                   NULL, NULL)))
251 252
        goto error;

253
    if (!(privconn->domains = virDomainObjListNew()))
D
Dmitry Guryanov 已提交
254 255
        goto error;

256 257 258 259 260 261
    if (!(privconn->domainEventState = virObjectEventStateNew()))
        goto error;

    if (prlsdkSubscribeToPCSEvents(privconn))
        goto error;

262 263 264
    if (!(privconn->closeCallback = virNewConnectCloseCallbackData()))
        goto error;

D
Dmitry Guryanov 已提交
265 266
    conn->privateData = privconn;

267
    if (prlsdkLoadDomains(privconn))
268 269
        goto error;

D
Dmitry Guryanov 已提交
270 271
    return VIR_DRV_OPEN_SUCCESS;

272
 error:
273 274
    virObjectUnref(privconn->closeCallback);
    privconn->closeCallback = NULL;
275
    virObjectUnref(privconn->domains);
276
    virObjectUnref(privconn->caps);
277
    virObjectEventStateFree(privconn->domainEventState);
278 279 280
    prlsdkDisconnect(privconn);
    prlsdkDeinit();
 err_free:
281
    conn->privateData = NULL;
D
Dmitry Guryanov 已提交
282 283 284 285 286
    VIR_FREE(privconn);
    return VIR_DRV_OPEN_ERROR;
}

static virDrvOpenStatus
287
vzConnectOpen(virConnectPtr conn,
M
Michal Privoznik 已提交
288 289
              virConnectAuthPtr auth ATTRIBUTE_UNUSED,
              unsigned int flags)
D
Dmitry Guryanov 已提交
290 291 292 293 294 295 296 297
{
    int ret;

    virCheckFlags(VIR_CONNECT_RO, VIR_DRV_OPEN_ERROR);

    if (!conn->uri)
        return VIR_DRV_OPEN_DECLINED;

298 299 300 301 302 303 304 305 306 307 308
    if (!conn->uri->scheme)
        return VIR_DRV_OPEN_DECLINED;

    if (STRNEQ(conn->uri->scheme, "vz") &&
        STRNEQ(conn->uri->scheme, "parallels"))
        return VIR_DRV_OPEN_DECLINED;

    if (STREQ(conn->uri->scheme, "vz") && STRNEQ(conn->driver->name, "vz"))
        return VIR_DRV_OPEN_DECLINED;

    if (STREQ(conn->uri->scheme, "parallels") && STRNEQ(conn->driver->name, "Parallels"))
D
Dmitry Guryanov 已提交
309 310 311 312 313 314 315
        return VIR_DRV_OPEN_DECLINED;

    /* Remote driver should handle these. */
    if (conn->uri->server)
        return VIR_DRV_OPEN_DECLINED;

    /* From this point on, the connection is for us. */
316
    if (STRNEQ_NULLABLE(conn->uri->path, "/system")) {
317
        virReportError(VIR_ERR_INTERNAL_ERROR,
318
                       _("Unexpected Virtuozzo URI path '%s', try vz:///system"),
319
                       conn->uri->path);
D
Dmitry Guryanov 已提交
320 321 322
        return VIR_DRV_OPEN_ERROR;
    }

323
    if ((ret = vzOpenDefault(conn)) != VIR_DRV_OPEN_SUCCESS)
D
Dmitry Guryanov 已提交
324 325 326 327 328 329
        return ret;

    return VIR_DRV_OPEN_SUCCESS;
}

static int
330
vzConnectClose(virConnectPtr conn)
D
Dmitry Guryanov 已提交
331
{
332
    vzConnPtr privconn = conn->privateData;
D
Dmitry Guryanov 已提交
333

334 335 336
    if (!privconn)
        return 0;

337
    vzDriverLock(privconn);
338
    prlsdkUnsubscribeFromPCSEvents(privconn);
339
    virObjectUnref(privconn->caps);
340
    virObjectUnref(privconn->xmlopt);
341
    virObjectUnref(privconn->domains);
342 343
    virObjectUnref(privconn->closeCallback);
    privconn->closeCallback = NULL;
344
    virObjectEventStateFree(privconn->domainEventState);
345
    prlsdkDisconnect(privconn);
D
Dmitry Guryanov 已提交
346
    conn->privateData = NULL;
347
    prlsdkDeinit();
D
Dmitry Guryanov 已提交
348

349
    vzDriverUnlock(privconn);
D
Dmitry Guryanov 已提交
350 351 352 353 354 355 356
    virMutexDestroy(&privconn->lock);

    VIR_FREE(privconn);
    return 0;
}

static int
357
vzConnectGetVersion(virConnectPtr conn, unsigned long *hvVer)
D
Dmitry Guryanov 已提交
358
{
359 360 361
    vzConnPtr privconn = conn->privateData;
    *hvVer = privconn->vzVersion;
    return 0;
362 363
}

364

365
static char *vzConnectGetHostname(virConnectPtr conn ATTRIBUTE_UNUSED)
366 367 368 369 370
{
    return virGetHostname();
}


371
static int
372
vzConnectListDomains(virConnectPtr conn, int *ids, int maxids)
373
{
374
    vzConnPtr privconn = conn->privateData;
375 376
    int n;

377
    vzDriverLock(privconn);
378 379
    n = virDomainObjListGetActiveIDs(privconn->domains, ids, maxids,
                                     NULL, NULL);
380
    vzDriverUnlock(privconn);
381 382 383 384 385

    return n;
}

static int
386
vzConnectNumOfDomains(virConnectPtr conn)
387
{
388
    vzConnPtr privconn = conn->privateData;
389 390
    int count;

391
    vzDriverLock(privconn);
392 393
    count = virDomainObjListNumOfDomains(privconn->domains, true,
                                         NULL, NULL);
394
    vzDriverUnlock(privconn);
395 396 397 398 399

    return count;
}

static int
400
vzConnectListDefinedDomains(virConnectPtr conn, char **const names, int maxnames)
401
{
402
    vzConnPtr privconn = conn->privateData;
403 404
    int n;

405
    vzDriverLock(privconn);
406
    memset(names, 0, sizeof(*names) * maxnames);
407
    n = virDomainObjListGetInactiveNames(privconn->domains, names,
408
                                         maxnames, NULL, NULL);
409
    vzDriverUnlock(privconn);
410 411 412 413 414

    return n;
}

static int
415
vzConnectNumOfDefinedDomains(virConnectPtr conn)
416
{
417
    vzConnPtr privconn = conn->privateData;
418 419
    int count;

420
    vzDriverLock(privconn);
421 422
    count = virDomainObjListNumOfDomains(privconn->domains, false,
                                         NULL, NULL);
423
    vzDriverUnlock(privconn);
424 425 426 427 428

    return count;
}

static int
429
vzConnectListAllDomains(virConnectPtr conn,
M
Michal Privoznik 已提交
430 431
                        virDomainPtr **domains,
                        unsigned int flags)
432
{
433
    vzConnPtr privconn = conn->privateData;
434 435
    int ret = -1;

O
Osier Yang 已提交
436
    virCheckFlags(VIR_CONNECT_LIST_DOMAINS_FILTERS_ALL, -1);
437
    vzDriverLock(privconn);
438 439
    ret = virDomainObjListExport(privconn->domains, conn, domains,
                                 NULL, flags);
440
    vzDriverUnlock(privconn);
441 442 443 444 445

    return ret;
}

static virDomainPtr
446
vzDomainLookupByID(virConnectPtr conn, int id)
447
{
448
    vzConnPtr privconn = conn->privateData;
449 450 451
    virDomainPtr ret = NULL;
    virDomainObjPtr dom;

452
    vzDriverLock(privconn);
453
    dom = virDomainObjListFindByID(privconn->domains, id);
454
    vzDriverUnlock(privconn);
455 456 457 458 459 460 461 462 463 464

    if (dom == NULL) {
        virReportError(VIR_ERR_NO_DOMAIN, NULL);
        goto cleanup;
    }

    ret = virGetDomain(conn, dom->def->name, dom->def->uuid);
    if (ret)
        ret->id = dom->def->id;

465
 cleanup:
466
    if (dom)
467
        virObjectUnlock(dom);
468 469 470 471
    return ret;
}

static virDomainPtr
472
vzDomainLookupByUUID(virConnectPtr conn, const unsigned char *uuid)
473
{
474
    vzConnPtr privconn = conn->privateData;
475 476 477
    virDomainPtr ret = NULL;
    virDomainObjPtr dom;

478
    vzDriverLock(privconn);
479
    dom = virDomainObjListFindByUUID(privconn->domains, uuid);
480
    vzDriverUnlock(privconn);
481 482 483 484 485 486 487 488 489 490 491 492 493

    if (dom == NULL) {
        char uuidstr[VIR_UUID_STRING_BUFLEN];
        virUUIDFormat(uuid, uuidstr);
        virReportError(VIR_ERR_NO_DOMAIN,
                       _("no domain with matching uuid '%s'"), uuidstr);
        goto cleanup;
    }

    ret = virGetDomain(conn, dom->def->name, dom->def->uuid);
    if (ret)
        ret->id = dom->def->id;

494
 cleanup:
495
    if (dom)
496
        virObjectUnlock(dom);
497 498 499 500
    return ret;
}

static virDomainPtr
501
vzDomainLookupByName(virConnectPtr conn, const char *name)
502
{
503
    vzConnPtr privconn = conn->privateData;
504 505 506
    virDomainPtr ret = NULL;
    virDomainObjPtr dom;

507
    vzDriverLock(privconn);
508
    dom = virDomainObjListFindByName(privconn->domains, name);
509
    vzDriverUnlock(privconn);
510 511 512 513 514 515 516 517 518 519 520

    if (dom == NULL) {
        virReportError(VIR_ERR_NO_DOMAIN,
                       _("no domain with matching name '%s'"), name);
        goto cleanup;
    }

    ret = virGetDomain(conn, dom->def->name, dom->def->uuid);
    if (ret)
        ret->id = dom->def->id;

521
 cleanup:
522
    virDomainObjEndAPI(&dom);
523 524 525 526
    return ret;
}

static int
527
vzDomainGetInfo(virDomainPtr domain, virDomainInfoPtr info)
528 529 530 531
{
    virDomainObjPtr privdom;
    int ret = -1;

532
    if (!(privdom = vzDomObjFromDomainRef(domain)))
533 534 535 536
        goto cleanup;

    info->state = virDomainObjGetState(privdom, NULL);
    info->memory = privdom->def->mem.cur_balloon;
537
    info->maxMem = virDomainDefGetMemoryActual(privdom->def);
538
    info->nrVirtCpu = virDomainDefGetVcpus(privdom->def);
539
    info->cpuTime = 0;
540 541 542 543 544

    if (virDomainObjIsActive(privdom)) {
        unsigned long long vtime;
        size_t i;

545
        for (i = 0; i < virDomainDefGetVcpus(privdom->def); ++i) {
546 547 548 549 550 551 552 553
            if (prlsdkGetVcpuStats(privdom, i, &vtime) < 0) {
                virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                               _("cannot read cputime for domain"));
                goto cleanup;
            }
            info->cpuTime += vtime;
        }
    }
554 555
    ret = 0;

556
 cleanup:
557
    virDomainObjEndAPI(&privdom);
558 559 560 561
    return ret;
}

static char *
562
vzDomainGetOSType(virDomainPtr domain)
563 564 565 566 567
{
    virDomainObjPtr privdom;

    char *ret = NULL;

568
    if (!(privdom = vzDomObjFromDomain(domain)))
569 570
        goto cleanup;

571
    ignore_value(VIR_STRDUP(ret, virDomainOSTypeToString(privdom->def->os.type)));
572

573
 cleanup:
574
    if (privdom)
575
        virObjectUnlock(privdom);
576 577 578 579
    return ret;
}

static int
580
vzDomainIsPersistent(virDomainPtr domain)
581 582 583 584
{
    virDomainObjPtr privdom;
    int ret = -1;

585
    if (!(privdom = vzDomObjFromDomain(domain)))
586 587 588 589
        goto cleanup;

    ret = 1;

590
 cleanup:
591
    if (privdom)
592
        virObjectUnlock(privdom);
593 594 595 596
    return ret;
}

static int
597
vzDomainGetState(virDomainPtr domain,
M
Michal Privoznik 已提交
598
                 int *state, int *reason, unsigned int flags)
599 600 601 602 603
{
    virDomainObjPtr privdom;
    int ret = -1;
    virCheckFlags(0, -1);

604
    if (!(privdom = vzDomObjFromDomain(domain)))
605 606 607 608 609
        goto cleanup;

    *state = virDomainObjGetState(privdom, reason);
    ret = 0;

610
 cleanup:
611
    if (privdom)
612
        virObjectUnlock(privdom);
613 614 615 616
    return ret;
}

static char *
617
vzDomainGetXMLDesc(virDomainPtr domain, unsigned int flags)
618
{
619
    vzConnPtr privconn = domain->conn->privateData;
620 621 622 623 624 625
    virDomainDefPtr def;
    virDomainObjPtr privdom;
    char *ret = NULL;

    /* Flags checked by virDomainDefFormat */

626
    if (!(privdom = vzDomObjFromDomain(domain)))
627 628 629 630 631
        goto cleanup;

    def = (flags & VIR_DOMAIN_XML_INACTIVE) &&
        privdom->newDef ? privdom->newDef : privdom->def;

632
    ret = virDomainDefFormat(def, privconn->caps, flags);
633

634
 cleanup:
635
    if (privdom)
636
        virObjectUnlock(privdom);
637 638 639 640
    return ret;
}

static int
641
vzDomainGetAutostart(virDomainPtr domain, int *autostart)
642 643 644 645
{
    virDomainObjPtr privdom;
    int ret = -1;

646
    if (!(privdom = vzDomObjFromDomain(domain)))
647 648 649 650 651
        goto cleanup;

    *autostart = privdom->autostart;
    ret = 0;

652
 cleanup:
653
    if (privdom)
654
        virObjectUnlock(privdom);
655
    return ret;
D
Dmitry Guryanov 已提交
656 657
}

658
static virDomainPtr
659
vzDomainDefineXMLFlags(virConnectPtr conn, const char *xml, unsigned int flags)
660
{
661
    vzConnPtr privconn = conn->privateData;
662
    virDomainPtr retdom = NULL;
663
    virDomainDefPtr def;
664
    virDomainObjPtr olddom = NULL;
665
    virDomainObjPtr newdom = NULL;
666
    unsigned int parse_flags = VIR_DOMAIN_DEF_PARSE_INACTIVE;
667

668 669 670 671
    virCheckFlags(VIR_DOMAIN_DEFINE_VALIDATE, NULL);

    if (flags & VIR_DOMAIN_DEFINE_VALIDATE)
        parse_flags |= VIR_DOMAIN_DEF_PARSE_VALIDATE;
672

673
    vzDriverLock(privconn);
674
    if ((def = virDomainDefParseString(xml, privconn->caps, privconn->xmlopt,
675
                                       parse_flags)) == NULL)
676 677
        goto cleanup;

678 679 680
    olddom = virDomainObjListFindByUUID(privconn->domains, def->uuid);
    if (olddom == NULL) {
        virResetLastError();
681 682 683
        newdom = vzNewDomain(privconn, def->name, def->uuid);
        if (!newdom)
            goto cleanup;
684
        if (def->os.type == VIR_DOMAIN_OSTYPE_HVM) {
685
            if (prlsdkCreateVm(conn, def))
686
                goto cleanup;
687
        } else if (def->os.type == VIR_DOMAIN_OSTYPE_EXE) {
688
            if (prlsdkCreateCt(conn, def))
689 690 691
                goto cleanup;
        } else {
            virReportError(VIR_ERR_INVALID_ARG,
692 693
                           _("Unsupported OS type: %s"),
                           virDomainOSTypeToString(def->os.type));
694
            goto cleanup;
695
        }
696

697
        if (prlsdkLoadDomain(privconn, newdom))
698
            goto cleanup;
699
    } else {
700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724
        int state, reason;

        state = virDomainObjGetState(olddom, &reason);

        if (state == VIR_DOMAIN_SHUTOFF &&
            reason == VIR_DOMAIN_SHUTOFF_SAVED) {

            /* PCS doesn't store domain config in managed save state file.
             * It's forbidden to change config for VMs in this state.
             * It's possible to change config for containers, but after
             * restoring domain will have that new config, not a config,
             * which domain had at the moment of virDomainManagedSave.
             *
             * So forbid this operation, if config is changed. If it's
             * not changed - just do nothing. */

            if (!virDomainDefCheckABIStability(olddom->def, def)) {
                virReportError(VIR_ERR_ARGUMENT_UNSUPPORTED, "%s",
                               _("Can't change domain configuration "
                                 "in managed save state"));
                goto cleanup;
            }
        } else {
            if (prlsdkApplyConfig(conn, olddom, def))
                goto cleanup;
725

726 727 728
            if (prlsdkUpdateDomain(privconn, olddom))
                goto cleanup;
        }
729 730
    }

731 732 733
    retdom = virGetDomain(conn, def->name, def->uuid);
    if (retdom)
        retdom->id = def->id;
734

735
 cleanup:
736 737
    if (olddom)
        virObjectUnlock(olddom);
738 739 740 741 742 743
    if (newdom) {
        if (!retdom)
             virDomainObjListRemove(privconn->domains, newdom);
        else
             virObjectUnlock(newdom);
    }
744
    virDomainDefFree(def);
745
    vzDriverUnlock(privconn);
746
    return retdom;
747 748
}

749
static virDomainPtr
750
vzDomainDefineXML(virConnectPtr conn, const char *xml)
751
{
752
    return vzDomainDefineXMLFlags(conn, xml, 0);
753 754 755
}


756
static int
757
vzNodeGetInfo(virConnectPtr conn ATTRIBUTE_UNUSED,
M
Michal Privoznik 已提交
758
              virNodeInfoPtr nodeinfo)
759
{
760
    return nodeGetInfo(NULL, nodeinfo);
761 762
}

763
static int vzConnectIsEncrypted(virConnectPtr conn ATTRIBUTE_UNUSED)
764 765 766 767 768
{
    /* Encryption is not relevant / applicable to way we talk to PCS */
    return 0;
}

769
static int vzConnectIsSecure(virConnectPtr conn ATTRIBUTE_UNUSED)
770 771 772 773 774
{
    /* We run CLI tools directly so this is secure */
    return 1;
}

775
static int vzConnectIsAlive(virConnectPtr conn ATTRIBUTE_UNUSED)
776 777 778 779
{
    return 1;
}

780

781
static char *
782
vzConnectBaselineCPU(virConnectPtr conn ATTRIBUTE_UNUSED,
M
Michal Privoznik 已提交
783 784 785
                     const char **xmlCPUs,
                     unsigned int ncpus,
                     unsigned int flags)
786 787 788 789 790 791 792
{
    virCheckFlags(VIR_CONNECT_BASELINE_CPU_EXPAND_FEATURES, NULL);

    return cpuBaselineXML(xmlCPUs, ncpus, NULL, 0, flags);
}


793
static int
794
vzDomainGetVcpus(virDomainPtr domain,
M
Michal Privoznik 已提交
795 796 797 798
                 virVcpuInfoPtr info,
                 int maxinfo,
                 unsigned char *cpumaps,
                 int maplen)
799 800 801 802 803
{
    virDomainObjPtr privdom = NULL;
    size_t i;
    int ret = -1;

N
Nikolay Shirokovskiy 已提交
804
    if (!(privdom = vzDomObjFromDomainRef(domain)))
805 806 807 808 809 810 811 812 813 814 815 816 817 818 819
        goto cleanup;

    if (!virDomainObjIsActive(privdom)) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       "%s",
                       _("cannot list vcpu pinning for an inactive domain"));
        goto cleanup;
    }

    if (maxinfo >= 1) {
        if (info != NULL) {
            memset(info, 0, sizeof(*info) * maxinfo);
            for (i = 0; i < maxinfo; i++) {
                info[i].number = i;
                info[i].state = VIR_VCPU_RUNNING;
N
Nikolay Shirokovskiy 已提交
820 821
                if (prlsdkGetVcpuStats(privdom, i, &info[i].cpuTime) < 0)
                    goto cleanup;
822 823 824 825
            }
        }
        if (cpumaps != NULL) {
            memset(cpumaps, 0, maplen * maxinfo);
826 827 828 829
            for (i = 0; i < maxinfo; i++)
                virBitmapToDataBuf(privdom->def->cpumask,
                                   VIR_GET_CPUMAP(cpumaps, maplen, i),
                                   maplen);
830 831 832 833 834 835
        }
    }
    ret = maxinfo;

 cleanup:
    if (privdom)
N
Nikolay Shirokovskiy 已提交
836
        virDomainObjEndAPI(&privdom);
837 838 839 840
    return ret;
}


841
static int
842
vzNodeGetCPUMap(virConnectPtr conn ATTRIBUTE_UNUSED,
M
Michal Privoznik 已提交
843 844 845
                unsigned char **cpumap,
                unsigned int *online,
                unsigned int flags)
846
{
847
    return nodeGetCPUMap(NULL, cpumap, online, flags);
848 849
}

850
static int
851
vzConnectDomainEventRegisterAny(virConnectPtr conn,
M
Michal Privoznik 已提交
852 853 854 855 856
                                virDomainPtr domain,
                                int eventID,
                                virConnectDomainEventGenericCallback callback,
                                void *opaque,
                                virFreeCallback freecb)
857 858
{
    int ret = -1;
859
    vzConnPtr privconn = conn->privateData;
860 861 862 863 864 865 866 867 868
    if (virDomainEventStateRegisterID(conn,
                                      privconn->domainEventState,
                                      domain, eventID,
                                      callback, opaque, freecb, &ret) < 0)
        ret = -1;
    return ret;
}

static int
869
vzConnectDomainEventDeregisterAny(virConnectPtr conn,
M
Michal Privoznik 已提交
870
                                  int callbackID)
871
{
872
    vzConnPtr privconn = conn->privateData;
873 874 875 876 877 878 879 880 881 882 883 884
    int ret = -1;

    if (virObjectEventStateDeregisterID(conn,
                                        privconn->domainEventState,
                                        callbackID) < 0)
        goto cleanup;

    ret = 0;

 cleanup:
    return ret;
}
885

886
static int vzDomainSuspend(virDomainPtr domain)
887 888 889 890
{
    return prlsdkDomainChangeState(domain, prlsdkPause);
}

891
static int vzDomainResume(virDomainPtr domain)
892 893 894 895
{
    return prlsdkDomainChangeState(domain, prlsdkResume);
}

896
static int vzDomainCreate(virDomainPtr domain)
897 898 899 900
{
    return prlsdkDomainChangeState(domain, prlsdkStart);
}

901
static int vzDomainDestroy(virDomainPtr domain)
902 903 904 905
{
    return prlsdkDomainChangeState(domain, prlsdkKill);
}

906
static int vzDomainShutdown(virDomainPtr domain)
907 908 909 910
{
    return prlsdkDomainChangeState(domain, prlsdkStop);
}

911 912 913 914 915 916 917
static int vzDomainReboot(virDomainPtr domain,
                          unsigned int flags)
{
    virCheckFlags(0, -1);
    return prlsdkDomainChangeState(domain, prlsdkRestart);
}

918
static int vzDomainIsActive(virDomainPtr domain)
919 920 921 922
{
    virDomainObjPtr dom = NULL;
    int ret = -1;

923
    if (!(dom = vzDomObjFromDomain(domain)))
924 925 926 927 928 929 930 931
        return -1;

    ret = virDomainObjIsActive(dom);
    virObjectUnlock(dom);

    return ret;
}

932
static int
933
vzDomainCreateWithFlags(virDomainPtr domain, unsigned int flags)
934 935 936 937
{
    /* we don't support any create flags */
    virCheckFlags(0, -1);

938
    return vzDomainCreate(domain);
939 940
}

941
static int
942
vzDomainUndefineFlags(virDomainPtr domain,
M
Michal Privoznik 已提交
943
                      unsigned int flags)
944
{
945
    vzConnPtr privconn = domain->conn->privateData;
946
    virDomainObjPtr dom = NULL;
947
    int ret;
948

949 950
    virCheckFlags(VIR_DOMAIN_UNDEFINE_MANAGED_SAVE |
                  VIR_DOMAIN_UNDEFINE_SNAPSHOTS_METADATA, -1);
951

952
    if (!(dom = vzDomObjFromDomain(domain)))
953 954
        return -1;

955
    ret = prlsdkUnregisterDomain(privconn, dom, flags);
956
    if (ret)
M
Michal Privoznik 已提交
957
        virObjectUnlock(dom);
958 959

    return ret;
960 961 962
}

static int
963
vzDomainUndefine(virDomainPtr domain)
964
{
965
    return vzDomainUndefineFlags(domain, 0);
966 967
}

968
static int
969
vzDomainHasManagedSaveImage(virDomainPtr domain, unsigned int flags)
970 971
{
    virDomainObjPtr dom = NULL;
972 973
    int state, reason;
    int ret = 0;
974 975 976

    virCheckFlags(0, -1);

977
    if (!(dom = vzDomObjFromDomain(domain)))
978 979
        return -1;

980 981 982
    state = virDomainObjGetState(dom, &reason);
    if (state == VIR_DOMAIN_SHUTOFF && reason == VIR_DOMAIN_SHUTOFF_SAVED)
        ret = 1;
983 984
    virObjectUnlock(dom);

985 986 987 988
    return ret;
}

static int
989
vzDomainManagedSave(virDomainPtr domain, unsigned int flags)
990
{
991
    vzConnPtr privconn = domain->conn->privateData;
992 993 994 995 996 997 998
    virDomainObjPtr dom = NULL;
    int state, reason;
    int ret = -1;

    virCheckFlags(VIR_DOMAIN_SAVE_RUNNING |
                  VIR_DOMAIN_SAVE_PAUSED, -1);

999
    if (!(dom = vzDomObjFromDomain(domain)))
1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017
        return -1;

    state = virDomainObjGetState(dom, &reason);

    if (state == VIR_DOMAIN_RUNNING && (flags & VIR_DOMAIN_SAVE_PAUSED)) {
        ret = prlsdkDomainChangeStateLocked(privconn, dom, prlsdkPause);
        if (ret)
            goto cleanup;
    }

    ret = prlsdkDomainChangeStateLocked(privconn, dom, prlsdkSuspend);

 cleanup:
    virObjectUnlock(dom);
    return ret;
}

static int
1018
vzDomainManagedSaveRemove(virDomainPtr domain, unsigned int flags)
1019 1020 1021 1022 1023 1024 1025
{
    virDomainObjPtr dom = NULL;
    int state, reason;
    int ret = -1;

    virCheckFlags(0, -1);

1026
    if (!(dom = vzDomObjFromDomain(domain)))
1027 1028 1029 1030 1031 1032 1033
        return -1;

    state = virDomainObjGetState(dom, &reason);

    if (!(state == VIR_DOMAIN_SHUTOFF && reason == VIR_DOMAIN_SHUTOFF_SAVED))
        goto cleanup;

1034
    ret = prlsdkDomainManagedSaveRemove(dom);
1035 1036 1037 1038

 cleanup:
    virObjectUnlock(dom);
    return ret;
1039 1040
}

1041
static int vzDomainAttachDeviceFlags(virDomainPtr dom, const char *xml,
M
Michal Privoznik 已提交
1042
                                     unsigned int flags)
1043 1044
{
    int ret = -1;
1045
    vzConnPtr privconn = dom->conn->privateData;
1046 1047 1048 1049 1050 1051 1052
    virDomainDeviceDefPtr dev = NULL;
    virDomainObjPtr privdom = NULL;
    bool domactive = false;

    virCheckFlags(VIR_DOMAIN_AFFECT_LIVE |
                  VIR_DOMAIN_AFFECT_CONFIG, -1);

1053
    if (!(privdom = vzDomObjFromDomain(dom)))
1054
        return -1;
1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082

    if (!(flags & VIR_DOMAIN_AFFECT_CONFIG)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("device attach needs VIR_DOMAIN_AFFECT_CONFIG "
                         "flag to be set"));
        goto cleanup;
    }

    domactive = virDomainObjIsActive(privdom);
    if (!domactive && (flags & VIR_DOMAIN_AFFECT_LIVE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("cannot do live update a device on "
                         "inactive domain"));
        goto cleanup;
    }
    if (domactive && !(flags & VIR_DOMAIN_AFFECT_LIVE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("Updates on a running domain need "
                         "VIR_DOMAIN_AFFECT_LIVE flag"));
    }

    dev = virDomainDeviceDefParse(xml, privdom->def, privconn->caps,
                                  privconn->xmlopt, VIR_DOMAIN_XML_INACTIVE);
    if (dev == NULL)
        goto cleanup;

    switch (dev->type) {
    case VIR_DOMAIN_DEVICE_DISK:
M
Mikhail Feoktistov 已提交
1083
        ret = prlsdkAttachVolume(privconn, privdom, dev->data.disk);
1084 1085 1086 1087 1088 1089
        if (ret) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("disk attach failed"));
            goto cleanup;
        }
        break;
1090 1091 1092 1093 1094 1095 1096 1097
    case VIR_DOMAIN_DEVICE_NET:
        ret = prlsdkAttachNet(privdom, privconn, dev->data.net);
        if (ret) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("network attach failed"));
            goto cleanup;
        }
        break;
1098 1099
    default:
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
1100
                       _("device type '%s' cannot be attached"),
1101 1102 1103 1104 1105 1106
                       virDomainDeviceTypeToString(dev->type));
        break;
    }

    ret = 0;
 cleanup:
1107
    virObjectUnlock(privdom);
1108 1109 1110
    return ret;
}

1111
static int vzDomainAttachDevice(virDomainPtr dom, const char *xml)
1112
{
1113
    return vzDomainAttachDeviceFlags(dom, xml,
M
Michal Privoznik 已提交
1114
                                     VIR_DOMAIN_AFFECT_CONFIG | VIR_DOMAIN_AFFECT_LIVE);
1115 1116
}

1117
static int vzDomainDetachDeviceFlags(virDomainPtr dom, const char *xml,
M
Michal Privoznik 已提交
1118
                                     unsigned int flags)
1119 1120
{
    int ret = -1;
1121
    vzConnPtr privconn = dom->conn->privateData;
1122 1123 1124 1125 1126 1127 1128
    virDomainDeviceDefPtr dev = NULL;
    virDomainObjPtr privdom = NULL;
    bool domactive = false;

    virCheckFlags(VIR_DOMAIN_AFFECT_LIVE |
                  VIR_DOMAIN_AFFECT_CONFIG, -1);

1129
    privdom = vzDomObjFromDomain(dom);
1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159
    if (privdom == NULL)
        return -1;

    if (!(flags & VIR_DOMAIN_AFFECT_CONFIG)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("device detach needs VIR_DOMAIN_AFFECT_CONFIG "
                         "flag to be set"));
        goto cleanup;
    }

    domactive = virDomainObjIsActive(privdom);
    if (!domactive && (flags & VIR_DOMAIN_AFFECT_LIVE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("cannot do live update a device on "
                         "inactive domain"));
        goto cleanup;
    }
    if (domactive && !(flags & VIR_DOMAIN_AFFECT_LIVE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("Updates on a running domain need "
                         "VIR_DOMAIN_AFFECT_LIVE flag"));
    }

    dev = virDomainDeviceDefParse(xml, privdom->def, privconn->caps,
                                  privconn->xmlopt, VIR_DOMAIN_XML_INACTIVE);
    if (dev == NULL)
        goto cleanup;

    switch (dev->type) {
    case VIR_DOMAIN_DEVICE_DISK:
1160
        ret = prlsdkDetachVolume(privdom, dev->data.disk);
1161 1162 1163 1164 1165 1166
        if (ret) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("disk detach failed"));
            goto cleanup;
        }
        break;
1167 1168 1169 1170 1171 1172 1173 1174
    case VIR_DOMAIN_DEVICE_NET:
        ret = prlsdkDetachNet(privdom, privconn, dev->data.net);
        if (ret) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("network detach failed"));
            goto cleanup;
        }
        break;
1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187
    default:
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
                       _("device type '%s' cannot be detached"),
                       virDomainDeviceTypeToString(dev->type));
        break;
    }

    ret = 0;
 cleanup:
    virObjectUnlock(privdom);
    return ret;
}

1188
static int vzDomainDetachDevice(virDomainPtr dom, const char *xml)
1189
{
1190
    return vzDomainDetachDeviceFlags(dom, xml,
M
Michal Privoznik 已提交
1191
                                     VIR_DOMAIN_AFFECT_CONFIG | VIR_DOMAIN_AFFECT_LIVE);
1192 1193
}

1194
static unsigned long long
1195
vzDomainGetMaxMemory(virDomainPtr domain)
1196 1197 1198 1199
{
    virDomainObjPtr dom = NULL;
    int ret = -1;

1200
    if (!(dom = vzDomObjFromDomain(domain)))
1201 1202
        return -1;

1203
    ret = virDomainDefGetMemoryActual(dom->def);
1204 1205 1206 1207
    virObjectUnlock(dom);
    return ret;
}

1208
static int
1209
vzDomainBlockStats(virDomainPtr domain, const char *path,
M
Michal Privoznik 已提交
1210
                   virDomainBlockStatsPtr stats)
1211 1212 1213 1214 1215 1216
{
    virDomainObjPtr dom = NULL;
    int ret = -1;
    size_t i;
    int idx;

1217
    if (!(dom = vzDomObjFromDomainRef(domain)))
1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229
        return -1;

    if (*path) {
        if ((idx = virDomainDiskIndexByName(dom->def, path, false)) < 0) {
            virReportError(VIR_ERR_INVALID_ARG, _("invalid path: %s"), path);
            goto cleanup;
        }
        if (prlsdkGetBlockStats(dom, dom->def->disks[idx], stats) < 0)
            goto cleanup;
    } else {
        virDomainBlockStatsStruct s;

M
Michal Privoznik 已提交
1230
#define PARALLELS_ZERO_STATS(VAR, TYPE, NAME)      \
1231 1232 1233 1234 1235 1236 1237 1238 1239 1240
        stats->VAR = 0;

        PARALLELS_BLOCK_STATS_FOREACH(PARALLELS_ZERO_STATS)

#undef PARALLELS_ZERO_STATS

        for (i = 0; i < dom->def->ndisks; i++) {
            if (prlsdkGetBlockStats(dom, dom->def->disks[i], &s) < 0)
                goto cleanup;

1241
#define PARALLELS_SUM_STATS(VAR, TYPE, NAME)        \
M
Michal Privoznik 已提交
1242 1243
    if (s.VAR != -1)                                \
        stats->VAR += s.VAR;
1244

M
Michal Privoznik 已提交
1245
        PARALLELS_BLOCK_STATS_FOREACH(PARALLELS_SUM_STATS)
1246

1247
#undef PARALLELS_SUM_STATS
1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260
        }
    }
    stats->errs = -1;
    ret = 0;

 cleanup:
    if (dom)
        virDomainObjEndAPI(&dom);

    return ret;
}

static int
1261
vzDomainBlockStatsFlags(virDomainPtr domain,
M
Michal Privoznik 已提交
1262 1263 1264 1265
                        const char *path,
                        virTypedParameterPtr params,
                        int *nparams,
                        unsigned int flags)
1266 1267 1268 1269 1270 1271 1272 1273 1274
{
    virDomainBlockStatsStruct stats;
    int ret = -1;
    size_t i;

    virCheckFlags(VIR_TYPED_PARAM_STRING_OKAY, -1);
    /* We don't return strings, and thus trivially support this flag.  */
    flags &= ~VIR_TYPED_PARAM_STRING_OKAY;

1275
    if (vzDomainBlockStats(domain, path, &stats) < 0)
1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309
        goto cleanup;

    if (*nparams == 0) {
#define PARALLELS_COUNT_STATS(VAR, TYPE, NAME)       \
        if ((stats.VAR) != -1)                       \
            ++*nparams;

        PARALLELS_BLOCK_STATS_FOREACH(PARALLELS_COUNT_STATS)

#undef PARALLELS_COUNT_STATS
        ret = 0;
        goto cleanup;
    }

    i = 0;
#define PARALLELS_BLOCK_STATS_ASSIGN_PARAM(VAR, TYPE, NAME)                    \
    if (i < *nparams && (stats.VAR) != -1) {                                   \
        if (virTypedParameterAssign(params + i, TYPE,                          \
                                    VIR_TYPED_PARAM_LLONG, (stats.VAR)) < 0)   \
            goto cleanup;                                                      \
        i++;                                                                   \
    }

    PARALLELS_BLOCK_STATS_FOREACH(PARALLELS_BLOCK_STATS_ASSIGN_PARAM)

#undef PARALLELS_BLOCK_STATS_ASSIGN_PARAM

    *nparams = i;
    ret = 0;

 cleanup:
    return ret;
}

1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325
static int
vzDomainInterfaceStats(virDomainPtr domain,
                         const char *path,
                         virDomainInterfaceStatsPtr stats)
{
    virDomainObjPtr dom = NULL;
    int ret;

    if (!(dom = vzDomObjFromDomainRef(domain)))
        return -1;

    ret = prlsdkGetNetStats(dom, path, stats);
    virDomainObjEndAPI(&dom);

    return ret;
}
1326

N
Nikolay Shirokovskiy 已提交
1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345
static int
vzDomainMemoryStats(virDomainPtr domain,
                    virDomainMemoryStatPtr stats,
                    unsigned int nr_stats,
                    unsigned int flags)
{
    virDomainObjPtr dom = NULL;
    int ret = -1;

    virCheckFlags(0, -1);
    if (!(dom = vzDomObjFromDomainRef(domain)))
        return -1;

    ret = prlsdkGetMemoryStats(dom, stats, nr_stats);
    virDomainObjEndAPI(&dom);

    return ret;
}

1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360
static int
vzDomainGetVcpusFlags(virDomainPtr dom,
                      unsigned int flags)
{
    virDomainObjPtr privdom = NULL;
    int ret = -1;

    virCheckFlags(VIR_DOMAIN_AFFECT_LIVE |
                  VIR_DOMAIN_AFFECT_CONFIG |
                  VIR_DOMAIN_VCPU_MAXIMUM, -1);

    if (!(privdom = vzDomObjFromDomain(dom)))
        goto cleanup;

    if (flags & VIR_DOMAIN_VCPU_MAXIMUM)
1361
        ret = virDomainDefGetVcpusMax(privdom->def);
1362
    else
1363
        ret = virDomainDefGetVcpus(privdom->def);
1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395

 cleanup:
    if (privdom)
        virObjectUnlock(privdom);

    return ret;
}

static int vzDomainGetMaxVcpus(virDomainPtr dom)
{
    return vzDomainGetVcpusFlags(dom, (VIR_DOMAIN_AFFECT_LIVE |
                                       VIR_DOMAIN_VCPU_MAXIMUM));
}

static int vzDomainIsUpdated(virDomainPtr dom)
{
    virDomainObjPtr privdom;
    int ret = -1;

    /* As far as VZ domains are always updated (e.g. current==persistent),
     * we just check for domain existence */
    if (!(privdom = vzDomObjFromDomain(dom)))
        goto cleanup;

    ret = 0;

 cleanup:
    if (privdom)
        virObjectUnlock(privdom);
    return ret;
}

1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408
static int vzConnectGetMaxVcpus(virConnectPtr conn ATTRIBUTE_UNUSED,
                                const char *type)
{
    /* As far as we have no limitation for containers
     * we report maximum */
    if (type == NULL || STRCASEEQ(type, "vz") || STRCASEEQ(type, "parallels"))
        return 1028;

    virReportError(VIR_ERR_INVALID_ARG,
                   _("unknown type '%s'"), type);
    return -1;
}

1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446
static int
vzNodeGetCPUStats(virConnectPtr conn ATTRIBUTE_UNUSED,
                  int cpuNum,
                  virNodeCPUStatsPtr params,
                  int *nparams,
                  unsigned int flags)
{
    return nodeGetCPUStats(cpuNum, params, nparams, flags);
}

static int
vzNodeGetMemoryStats(virConnectPtr conn ATTRIBUTE_UNUSED,
                     int cellNum,
                     virNodeMemoryStatsPtr params,
                     int *nparams,
                     unsigned int flags)
{
    return nodeGetMemoryStats(NULL, cellNum, params, nparams, flags);
}

static int
vzNodeGetCellsFreeMemory(virConnectPtr conn ATTRIBUTE_UNUSED,
                         unsigned long long *freeMems,
                         int startCell,
                         int maxCells)
{
    return nodeGetCellsFreeMemory(freeMems, startCell, maxCells);
}

static unsigned long long
vzNodeGetFreeMemory(virConnectPtr conn ATTRIBUTE_UNUSED)
{
    unsigned long long freeMem;
    if (nodeGetMemory(NULL, &freeMem) < 0)
        return 0;
    return freeMem;
}

1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496
static int
vzConnectRegisterCloseCallback(virConnectPtr conn,
                               virConnectCloseFunc cb,
                               void *opaque,
                               virFreeCallback freecb)
{
    vzConnPtr privconn = conn->privateData;
    int ret = -1;

    vzDriverLock(privconn);

    if (virConnectCloseCallbackDataGetCallback(privconn->closeCallback) != NULL) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("A close callback is already registered"));
        goto cleanup;
    }

    virConnectCloseCallbackDataRegister(privconn->closeCallback, conn, cb,
                                        opaque, freecb);
    ret = 0;

 cleanup:
    vzDriverUnlock(privconn);

    return ret;
}

static int
vzConnectUnregisterCloseCallback(virConnectPtr conn, virConnectCloseFunc cb)
{
    vzConnPtr privconn = conn->privateData;
    int ret = -1;

    vzDriverLock(privconn);

    if (virConnectCloseCallbackDataGetCallback(privconn->closeCallback) != cb) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("A different callback was requested"));
        goto cleanup;
    }

    virConnectCloseCallbackDataUnregister(privconn->closeCallback, cb);
    ret = 0;

 cleanup:
    vzDriverUnlock(privconn);

    return ret;
}

1497 1498
static virHypervisorDriver vzDriver = {
    .name = "vz",
1499 1500 1501 1502
    .connectOpen = vzConnectOpen,            /* 0.10.0 */
    .connectClose = vzConnectClose,          /* 0.10.0 */
    .connectGetVersion = vzConnectGetVersion,   /* 0.10.0 */
    .connectGetHostname = vzConnectGetHostname,      /* 0.10.0 */
1503
    .connectGetMaxVcpus = vzConnectGetMaxVcpus, /* 1.2.21 */
1504
    .nodeGetInfo = vzNodeGetInfo,      /* 0.10.0 */
1505 1506 1507 1508
    .nodeGetCPUStats = vzNodeGetCPUStats,      /* 1.2.21 */
    .nodeGetMemoryStats = vzNodeGetMemoryStats, /* 1.2.21 */
    .nodeGetCellsFreeMemory = vzNodeGetCellsFreeMemory, /* 1.2.21 */
    .nodeGetFreeMemory = vzNodeGetFreeMemory, /* 1.2.21 */
1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531
    .connectGetCapabilities = vzConnectGetCapabilities,      /* 0.10.0 */
    .connectBaselineCPU = vzConnectBaselineCPU, /* 1.2.6 */
    .connectListDomains = vzConnectListDomains,      /* 0.10.0 */
    .connectNumOfDomains = vzConnectNumOfDomains,    /* 0.10.0 */
    .connectListDefinedDomains = vzConnectListDefinedDomains,        /* 0.10.0 */
    .connectNumOfDefinedDomains = vzConnectNumOfDefinedDomains,      /* 0.10.0 */
    .connectListAllDomains = vzConnectListAllDomains, /* 0.10.0 */
    .domainLookupByID = vzDomainLookupByID,    /* 0.10.0 */
    .domainLookupByUUID = vzDomainLookupByUUID,        /* 0.10.0 */
    .domainLookupByName = vzDomainLookupByName,        /* 0.10.0 */
    .domainGetOSType = vzDomainGetOSType,    /* 0.10.0 */
    .domainGetInfo = vzDomainGetInfo,  /* 0.10.0 */
    .domainGetState = vzDomainGetState,        /* 0.10.0 */
    .domainGetXMLDesc = vzDomainGetXMLDesc,    /* 0.10.0 */
    .domainIsPersistent = vzDomainIsPersistent,        /* 0.10.0 */
    .domainGetAutostart = vzDomainGetAutostart,        /* 0.10.0 */
    .domainGetVcpus = vzDomainGetVcpus, /* 1.2.6 */
    .domainSuspend = vzDomainSuspend,    /* 0.10.0 */
    .domainResume = vzDomainResume,    /* 0.10.0 */
    .domainDestroy = vzDomainDestroy,  /* 0.10.0 */
    .domainShutdown = vzDomainShutdown, /* 0.10.0 */
    .domainCreate = vzDomainCreate,    /* 0.10.0 */
    .domainCreateWithFlags = vzDomainCreateWithFlags, /* 1.2.10 */
P
Pavel Hrdina 已提交
1532
    .domainReboot = vzDomainReboot, /* 1.3.0 */
1533 1534 1535 1536 1537 1538 1539 1540 1541
    .domainDefineXML = vzDomainDefineXML,      /* 0.10.0 */
    .domainDefineXMLFlags = vzDomainDefineXMLFlags, /* 1.2.12 */
    .domainUndefine = vzDomainUndefine, /* 1.2.10 */
    .domainUndefineFlags = vzDomainUndefineFlags, /* 1.2.10 */
    .domainAttachDevice = vzDomainAttachDevice, /* 1.2.15 */
    .domainAttachDeviceFlags = vzDomainAttachDeviceFlags, /* 1.2.15 */
    .domainDetachDevice = vzDomainDetachDevice, /* 1.2.15 */
    .domainDetachDeviceFlags = vzDomainDetachDeviceFlags, /* 1.2.15 */
    .domainIsActive = vzDomainIsActive, /* 1.2.10 */
1542 1543 1544
    .domainIsUpdated = vzDomainIsUpdated,     /* 1.2.21 */
    .domainGetVcpusFlags = vzDomainGetVcpusFlags, /* 1.2.21 */
    .domainGetMaxVcpus = vzDomainGetMaxVcpus, /* 1.2.21 */
1545 1546 1547 1548 1549 1550 1551 1552 1553 1554
    .connectDomainEventRegisterAny = vzConnectDomainEventRegisterAny, /* 1.2.10 */
    .connectDomainEventDeregisterAny = vzConnectDomainEventDeregisterAny, /* 1.2.10 */
    .nodeGetCPUMap = vzNodeGetCPUMap, /* 1.2.8 */
    .connectIsEncrypted = vzConnectIsEncrypted, /* 1.2.5 */
    .connectIsSecure = vzConnectIsSecure, /* 1.2.5 */
    .connectIsAlive = vzConnectIsAlive, /* 1.2.5 */
    .domainHasManagedSaveImage = vzDomainHasManagedSaveImage, /* 1.2.13 */
    .domainManagedSave = vzDomainManagedSave, /* 1.2.14 */
    .domainManagedSaveRemove = vzDomainManagedSaveRemove, /* 1.2.14 */
    .domainGetMaxMemory = vzDomainGetMaxMemory, /* 1.2.15 */
1555 1556 1557 1558
    .domainBlockStats = vzDomainBlockStats, /* 1.2.17 */
    .domainBlockStatsFlags = vzDomainBlockStatsFlags, /* 1.2.17 */
    .domainInterfaceStats = vzDomainInterfaceStats, /* 1.2.17 */
    .domainMemoryStats = vzDomainMemoryStats, /* 1.2.17 */
1559 1560
    .connectRegisterCloseCallback = vzConnectRegisterCloseCallback, /* 1.3.2 */
    .connectUnregisterCloseCallback = vzConnectUnregisterCloseCallback, /* 1.3.2 */
D
Dmitry Guryanov 已提交
1561 1562
};

1563 1564
static virConnectDriver vzConnectDriver = {
    .hypervisorDriver = &vzDriver,
1565 1566
};

1567 1568 1569 1570
/* Parallels domain type backward compatibility*/
static virHypervisorDriver parallelsDriver;
static virConnectDriver parallelsConnectDriver;

D
Dmitry Guryanov 已提交
1571
/**
1572
 * vzRegister:
D
Dmitry Guryanov 已提交
1573
 *
1574
 * Registers the vz driver
D
Dmitry Guryanov 已提交
1575 1576
 */
int
1577
vzRegister(void)
D
Dmitry Guryanov 已提交
1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588
{
    char *prlctl_path;

    prlctl_path = virFindFileInPath(PRLCTL);
    if (!prlctl_path) {
        VIR_DEBUG("%s", _("Can't find prlctl command in the PATH env"));
        return 0;
    }

    VIR_FREE(prlctl_path);

1589 1590 1591 1592 1593
    /* Backward compatibility with Parallels domain type */
    parallelsDriver = vzDriver;
    parallelsDriver.name = "Parallels";
    parallelsConnectDriver = vzConnectDriver;
    parallelsConnectDriver.hypervisorDriver = &parallelsDriver;
1594
    if (virRegisterConnectDriver(&parallelsConnectDriver, false) < 0)
D
Dmitry Guryanov 已提交
1595
        return -1;
D
Dmitry Guryanov 已提交
1596

1597 1598 1599
    if (virRegisterConnectDriver(&vzConnectDriver, false) < 0)
        return -1;

D
Dmitry Guryanov 已提交
1600 1601
    return 0;
}