qemu_hotplug.c 120.6 KB
Newer Older
1 2 3
/*
 * qemu_hotplug.h: QEMU device hotplug management
 *
4
 * Copyright (C) 2006-2013 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17
 * Copyright (C) 2006 Daniel P. Berrange
 *
 * 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
18
 * License along with this library.  If not, see
O
Osier Yang 已提交
19
 * <http://www.gnu.org/licenses/>.
20 21 22 23 24 25 26 27
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */


#include <config.h>

#include "qemu_hotplug.h"
28
#include "qemu_hotplugpriv.h"
29 30 31 32 33
#include "qemu_capabilities.h"
#include "qemu_domain.h"
#include "qemu_command.h"
#include "qemu_bridge_filter.h"
#include "qemu_hostdev.h"
34
#include "domain_audit.h"
35
#include "domain_nwfilter.h"
36
#include "virlog.h"
37
#include "datatypes.h"
38
#include "virerror.h"
39
#include "viralloc.h"
40
#include "virpci.h"
E
Eric Blake 已提交
41
#include "virfile.h"
42
#include "virprocess.h"
43
#include "qemu_cgroup.h"
44
#include "locking/domain_lock.h"
45
#include "network/bridge_driver.h"
46 47
#include "virnetdev.h"
#include "virnetdevbridge.h"
A
Ansis Atteka 已提交
48
#include "virnetdevtap.h"
49
#include "device_conf.h"
50
#include "virstoragefile.h"
51
#include "virstring.h"
52
#include "virtime.h"
53 54

#define VIR_FROM_THIS VIR_FROM_QEMU
55
#define CHANGE_MEDIA_RETRIES 10
56

57 58 59 60
/* Wait up to 5 seconds for device removal to finish. */
unsigned long long qemuDomainRemoveDeviceWaitTime = 1000ull * 5;


61
int qemuDomainChangeEjectableMedia(virQEMUDriverPtr driver,
62 63
                                   virDomainObjPtr vm,
                                   virDomainDiskDefPtr disk,
64
                                   virDomainDiskDefPtr origdisk,
65 66
                                   bool force)
{
67
    int ret = -1;
68
    char *driveAlias = NULL;
69
    qemuDomainObjPrivatePtr priv = vm->privateData;
70
    int retries = CHANGE_MEDIA_RETRIES;
71
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
72 73

    if (!origdisk->info.alias) {
74 75
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("missing disk device alias name for %s"), origdisk->dst);
76
        goto cleanup;
77 78 79 80
    }

    if (origdisk->device != VIR_DOMAIN_DISK_DEVICE_FLOPPY &&
        origdisk->device != VIR_DOMAIN_DISK_DEVICE_CDROM) {
81 82
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Removable media not supported for %s device"),
83
                       virDomainDiskDeviceTypeToString(disk->device));
84
        goto cleanup;
85 86
    }

87
    if (virDomainLockDiskAttach(driver->lockManager, cfg->uri,
88
                                vm, disk) < 0)
89
        goto cleanup;
90

91
    if (virSecurityManagerSetImageLabel(driver->securityManager,
92
                                        vm->def, disk) < 0) {
93 94
        if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
            VIR_WARN("Unable to release lock on %s", disk->src);
95
        goto cleanup;
96
    }
97

98
    if (!(driveAlias = qemuDeviceDriveHostAlias(origdisk, priv->qemuCaps)))
99 100
        goto error;

101
    qemuDomainObjEnterMonitor(driver, vm);
102
    ret = qemuMonitorEjectMedia(priv->mon, driveAlias, force);
103
    qemuDomainObjExitMonitor(driver, vm);
104

105
    virObjectRef(vm);
106
    /* we don't want to report errors from media tray_open polling */
107
    while (retries) {
108 109 110
        if (origdisk->tray_status == VIR_DOMAIN_DISK_TRAY_OPEN)
            break;

111
        retries--;
112
        virObjectUnlock(vm);
113 114
        VIR_DEBUG("Waiting 500ms for tray to open. Retries left %d", retries);
        usleep(500 * 1000); /* sleep 500ms */
115
        virObjectLock(vm);
116
    }
117
    virObjectUnref(vm);
118

119 120 121
    if (retries <= 0) {
        if (ret == 0) {
            /* If ret == -1, EjectMedia already set an error message */
122
            virReportError(VIR_ERR_OPERATION_FAILED, "%s",
123
                           _("Unable to eject media"));
124
        }
125 126 127 128 129 130 131 132
        goto audit;
    }
    ret = 0;

    if (disk->src) {
        /* deliberately don't depend on 'ret' as 'eject' may have failed the
         * first time and we are going to check the drive state anyway */
        const char *format = NULL;
133

134
        if (disk->type != VIR_DOMAIN_DISK_TYPE_DIR) {
135 136 137 138
            if (disk->format > 0)
                format = virStorageFileFormatTypeToString(disk->format);
            else if (origdisk->format > 0)
                format = virStorageFileFormatTypeToString(origdisk->format);
139
        }
140
        qemuDomainObjEnterMonitor(driver, vm);
141 142 143
        ret = qemuMonitorChangeMedia(priv->mon,
                                     driveAlias,
                                     disk->src, format);
144
        qemuDomainObjExitMonitor(driver, vm);
145
    }
146
audit:
147
    virDomainAuditDisk(vm, origdisk->src, disk->src, "update", ret >= 0);
148 149 150 151

    if (ret < 0)
        goto error;

152
    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
153
                                            vm->def, origdisk) < 0)
154 155
        VIR_WARN("Unable to restore security label on ejected image %s", origdisk->src);

156 157 158
    if (virDomainLockDiskDetach(driver->lockManager, vm, origdisk) < 0)
        VIR_WARN("Unable to release lock on disk %s", origdisk->src);

159 160 161 162 163 164 165 166
    VIR_FREE(origdisk->src);
    origdisk->src = disk->src;
    disk->src = NULL;
    origdisk->type = disk->type;


    virDomainDiskDefFree(disk);

167 168 169
cleanup:
    VIR_FREE(driveAlias);
    virObjectUnref(cfg);
170 171 172
    return ret;

error:
173
    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
174
                                            vm->def, disk) < 0)
175
        VIR_WARN("Unable to restore security label on new media %s", disk->src);
176 177 178 179

    if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
        VIR_WARN("Unable to release lock on %s", disk->src);

180
    goto cleanup;
181 182
}

183
int
184
qemuDomainCheckEjectableMedia(virQEMUDriverPtr driver,
185 186
                             virDomainObjPtr vm,
                             enum qemuDomainAsyncJob asyncJob)
187 188
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
189
    virHashTablePtr table = NULL;
190
    int ret = -1;
191
    size_t i;
192

193 194
    if (qemuDomainObjEnterMonitorAsync(driver, vm, asyncJob) == 0) {
        table = qemuMonitorGetBlockInfo(priv->mon);
195
        qemuDomainObjExitMonitor(driver, vm);
196
    }
197 198 199 200

    if (!table)
        goto cleanup;

201 202
    for (i = 0; i < vm->def->ndisks; i++) {
        virDomainDiskDefPtr disk = vm->def->disks[i];
203
        struct qemuDomainDiskInfo *info;
204

205 206
        if (disk->device == VIR_DOMAIN_DISK_DEVICE_DISK ||
            disk->device == VIR_DOMAIN_DISK_DEVICE_LUN) {
207
                 continue;
208
        }
209

210 211
        info = qemuMonitorBlockInfoLookup(table, disk->info.alias);
        if (!info)
212 213
            goto cleanup;

214
        if (info->tray_open && disk->src)
215 216 217 218 219 220
            VIR_FREE(disk->src);
    }

    ret = 0;

cleanup:
221
    virHashFree(table);
222 223 224
    return ret;
}

225 226 227 228 229
static int
qemuDomainAttachVirtioDiskDevice(virConnectPtr conn,
                                 virQEMUDriverPtr driver,
                                 virDomainObjPtr vm,
                                 virDomainDiskDefPtr disk)
230
{
231 232
    size_t i;
    int ret = -1;
233 234 235 236
    const char* type = virDomainDiskBusTypeToString(disk->bus);
    qemuDomainObjPrivatePtr priv = vm->privateData;
    char *devstr = NULL;
    char *drivestr = NULL;
237
    bool releaseaddr = false;
238
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
239

240 241 242 243 244 245 246 247
    if (!disk->info.type) {
        if (STREQLEN(vm->def->os.machine, "s390-ccw", 8) &&
            virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_CCW))
            disk->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_CCW;
        else if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_S390))
            disk->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_VIRTIO_S390;
    }

248
    for (i = 0; i < vm->def->ndisks; i++) {
249
        if (STREQ(vm->def->disks[i]->dst, disk->dst)) {
250 251
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("target %s already exists"), disk->dst);
252
            goto cleanup;
253 254 255
        }
    }

256
    if (virDomainLockDiskAttach(driver->lockManager, cfg->uri,
257
                                vm, disk) < 0)
258
        goto cleanup;
259

260
    if (virSecurityManagerSetImageLabel(driver->securityManager,
261
                                        vm->def, disk) < 0) {
262 263
        if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
            VIR_WARN("Unable to release lock on %s", disk->src);
264
        goto cleanup;
265
    }
266

267
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
268 269 270 271
        if (disk->info.type == VIR_DOMAIN_DEVICE_ADDRESS_TYPE_CCW) {
            if (qemuDomainCCWAddressAssign(&disk->info, priv->ccwaddrs,
                                           !disk->info.addr.ccw.assigned) < 0)
                goto error;
272 273
        } else if (!disk->info.type ||
                    disk->info.type == VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI) {
274 275 276
            if (qemuDomainPCIAddressEnsureAddr(priv->pciaddrs, &disk->info) < 0)
                goto error;
        }
277
        releaseaddr = true;
278
        if (qemuAssignDeviceDiskAlias(vm->def, disk, priv->qemuCaps) < 0)
279 280
            goto error;

281
        if (!(drivestr = qemuBuildDriveStr(conn, disk, false, priv->qemuCaps)))
282 283
            goto error;

284
        if (!(devstr = qemuBuildDriveDevStr(vm->def, disk, 0, priv->qemuCaps)))
285 286 287
            goto error;
    }

288
    if (VIR_REALLOC_N(vm->def->disks, vm->def->ndisks+1) < 0)
289 290
        goto error;

291
    qemuDomainObjEnterMonitor(driver, vm);
292
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
293 294 295 296
        ret = qemuMonitorAddDrive(priv->mon, drivestr);
        if (ret == 0) {
            ret = qemuMonitorAddDevice(priv->mon, devstr);
            if (ret < 0) {
297 298 299 300 301 302 303 304 305 306
                virErrorPtr orig_err = virSaveLastError();
                if (qemuMonitorDriveDel(priv->mon, drivestr) < 0) {
                    VIR_WARN("Unable to remove drive %s (%s) after failed "
                             "qemuMonitorAddDevice",
                             drivestr, devstr);
                }
                if (orig_err) {
                    virSetError(orig_err);
                    virFreeError(orig_err);
                }
307 308
            }
        }
309 310
    } else if (!disk->info.type ||
                disk->info.type == VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI) {
311
        virDevicePCIAddress guestAddr = disk->info.addr.pci;
312 313 314 315
        ret = qemuMonitorAddPCIDisk(priv->mon,
                                    disk->src,
                                    type,
                                    &guestAddr);
316 317
        if (ret == 0) {
            disk->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI;
318
            memcpy(&disk->info.addr.pci, &guestAddr, sizeof(guestAddr));
319
        }
320
    }
321
    qemuDomainObjExitMonitor(driver, vm);
322

323
    virDomainAuditDisk(vm, NULL, disk->src, "attach", ret >= 0);
324 325 326 327 328 329

    if (ret < 0)
        goto error;

    virDomainDiskInsertPreAlloced(vm->def, disk);

330
cleanup:
331 332
    VIR_FREE(devstr);
    VIR_FREE(drivestr);
333 334
    virObjectUnref(cfg);
    return ret;
335 336

error:
337 338
    if (releaseaddr)
        qemuDomainReleaseDeviceAddress(vm, &disk->info, disk->src);
339

340
    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
341
                                            vm->def, disk) < 0)
342 343
        VIR_WARN("Unable to restore security label on %s", disk->src);

344 345 346
    if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
        VIR_WARN("Unable to release lock on %s", disk->src);

347
    goto cleanup;
348 349 350
}


351
int qemuDomainAttachPciControllerDevice(virQEMUDriverPtr driver,
352
                                        virDomainObjPtr vm,
353
                                        virDomainControllerDefPtr controller)
354 355 356 357 358
{
    int ret = -1;
    const char* type = virDomainControllerTypeToString(controller->type);
    char *devstr = NULL;
    qemuDomainObjPrivatePtr priv = vm->privateData;
359
    bool releaseaddr = false;
360

361 362 363 364 365
    if (virDomainControllerFind(vm->def, controller->type, controller->idx) > 0) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("target %s:%d already exists"),
                       type, controller->idx);
        return -1;
366 367
    }

368
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
369 370
        if (qemuDomainPCIAddressEnsureAddr(priv->pciaddrs, &controller->info) < 0)
            goto cleanup;
371
        releaseaddr = true;
372 373 374
        if (qemuAssignDeviceControllerAlias(controller) < 0)
            goto cleanup;

375 376
        if (controller->type == VIR_DOMAIN_CONTROLLER_TYPE_USB &&
            controller->model == -1 &&
377
            !virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_PIIX3_USB_UHCI)) {
378 379
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("USB controller hotplug unsupported in this QEMU binary"));
380 381 382
            goto cleanup;
        }

383
        if (!(devstr = qemuBuildControllerDevStr(vm->def, controller, priv->qemuCaps, NULL))) {
384 385 386 387
            goto cleanup;
        }
    }

388
    if (VIR_REALLOC_N(vm->def->controllers, vm->def->ncontrollers+1) < 0)
389 390
        goto cleanup;

391
    qemuDomainObjEnterMonitor(driver, vm);
392
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
393 394 395 396 397 398
        ret = qemuMonitorAddDevice(priv->mon, devstr);
    } else {
        ret = qemuMonitorAttachPCIDiskController(priv->mon,
                                                 type,
                                                 &controller->info.addr.pci);
    }
399
    qemuDomainObjExitMonitor(driver, vm);
400 401 402 403 404 405 406

    if (ret == 0) {
        controller->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI;
        virDomainControllerInsertPreAlloced(vm->def, controller);
    }

cleanup:
407 408
    if (ret != 0 && releaseaddr)
        qemuDomainReleaseDeviceAddress(vm, &controller->info, NULL);
409 410 411 412 413 414

    VIR_FREE(devstr);
    return ret;
}

static virDomainControllerDefPtr
415
qemuDomainFindOrCreateSCSIDiskController(virQEMUDriverPtr driver,
416
                                         virDomainObjPtr vm,
417
                                         int controller)
418
{
419
    size_t i;
420
    virDomainControllerDefPtr cont;
421

422
    for (i = 0; i < vm->def->ncontrollers; i++) {
423 424 425 426 427 428 429 430 431 432 433
        cont = vm->def->controllers[i];

        if (cont->type != VIR_DOMAIN_CONTROLLER_TYPE_SCSI)
            continue;

        if (cont->idx == controller)
            return cont;
    }

    /* No SCSI controller present, for backward compatibility we
     * now hotplug a controller */
434
    if (VIR_ALLOC(cont) < 0)
435 436
        return NULL;
    cont->type = VIR_DOMAIN_CONTROLLER_TYPE_SCSI;
437
    cont->idx = controller;
438 439
    cont->model = -1;

440
    VIR_INFO("No SCSI controller present, hotplugging one");
441
    if (qemuDomainAttachPciControllerDevice(driver,
442
                                            vm, cont) < 0) {
443 444 445 446 447
        VIR_FREE(cont);
        return NULL;
    }

    if (!virDomainObjIsActive(vm)) {
448 449
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("guest unexpectedly quit"));
450 451 452 453 454 455 456 457 458
        /* cont doesn't need freeing here, since the reference
         * now held in def->controllers */
        return NULL;
    }

    return cont;
}


459 460 461 462 463
static int
qemuDomainAttachSCSIDisk(virConnectPtr conn,
                         virQEMUDriverPtr driver,
                         virDomainObjPtr vm,
                         virDomainDiskDefPtr disk)
464
{
465
    size_t i;
466 467 468 469 470
    qemuDomainObjPrivatePtr priv = vm->privateData;
    virDomainControllerDefPtr cont = NULL;
    char *drivestr = NULL;
    char *devstr = NULL;
    int ret = -1;
471
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
472

473
    for (i = 0; i < vm->def->ndisks; i++) {
474
        if (STREQ(vm->def->disks[i]->dst, disk->dst)) {
475 476
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("target %s already exists"), disk->dst);
477
            goto cleanup;
478 479 480
        }
    }

481
    if (virDomainLockDiskAttach(driver->lockManager, cfg->uri,
482
                                vm, disk) < 0)
483
        goto cleanup;
484

485
    if (virSecurityManagerSetImageLabel(driver->securityManager,
486
                                        vm->def, disk) < 0) {
487 488
        if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
            VIR_WARN("Unable to release lock on %s", disk->src);
489
        goto cleanup;
490
    }
491 492 493

    /* We should have an address already, so make sure */
    if (disk->info.type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_DRIVE) {
494 495 496
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected disk address type %s"),
                       virDomainDeviceAddressTypeToString(disk->info.type));
497 498 499
        goto error;
    }

500 501
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
        if (qemuAssignDeviceDiskAlias(vm->def, disk, priv->qemuCaps) < 0)
502
            goto error;
503
        if (!(devstr = qemuBuildDriveDevStr(vm->def, disk, 0, priv->qemuCaps)))
504 505 506
            goto error;
    }

507
    if (!(drivestr = qemuBuildDriveStr(conn, disk, false, priv->qemuCaps)))
508 509
        goto error;

510
    for (i = 0; i <= disk->info.addr.drive.controller; i++) {
511
        cont = qemuDomainFindOrCreateSCSIDiskController(driver, vm, i);
512 513 514 515 516 517 518
        if (!cont)
            goto error;
    }

    /* Tell clang that "cont" is non-NULL.
       This is because disk->info.addr.driver.controller is unsigned,
       and hence the above loop must iterate at least once.  */
519
    sa_assert(cont);
520 521

    if (cont->info.type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI) {
522 523
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("SCSI controller %d was missing its PCI address"), cont->idx);
524 525 526
        goto error;
    }

527
    if (VIR_REALLOC_N(vm->def->disks, vm->def->ndisks+1) < 0)
528 529
        goto error;

530
    qemuDomainObjEnterMonitor(driver, vm);
531
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551
        ret = qemuMonitorAddDrive(priv->mon, drivestr);
        if (ret == 0) {
            ret = qemuMonitorAddDevice(priv->mon, devstr);
            if (ret < 0) {
                VIR_WARN("qemuMonitorAddDevice failed on %s (%s)",
                         drivestr, devstr);
                /* XXX should call 'drive_del' on error but this does not
                   exist yet */
            }
        }
    } else {
        virDomainDeviceDriveAddress driveAddr;
        ret = qemuMonitorAttachDrive(priv->mon,
                                     drivestr,
                                     &cont->info.addr.pci,
                                     &driveAddr);
        if (ret == 0) {
            /* XXX we should probably validate that the addr matches
             * our existing defined addr instead of overwriting */
            disk->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_DRIVE;
552 553
            disk->info.addr.drive.bus = driveAddr.bus;
            disk->info.addr.drive.unit = driveAddr.unit;
554 555
        }
    }
556
    qemuDomainObjExitMonitor(driver, vm);
557

558
    virDomainAuditDisk(vm, NULL, disk->src, "attach", ret >= 0);
559 560 561 562 563 564

    if (ret < 0)
        goto error;

    virDomainDiskInsertPreAlloced(vm->def, disk);

565
cleanup:
566 567
    VIR_FREE(devstr);
    VIR_FREE(drivestr);
568 569
    virObjectUnref(cfg);
    return ret;
570 571

error:
572
    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
573
                                            vm->def, disk) < 0)
574 575
        VIR_WARN("Unable to restore security label on %s", disk->src);

576 577 578
    if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
        VIR_WARN("Unable to release lock on %s", disk->src);

579
    goto cleanup;
580 581 582
}


583 584 585 586 587
static int
qemuDomainAttachUsbMassstorageDevice(virConnectPtr conn,
                                     virQEMUDriverPtr driver,
                                     virDomainObjPtr vm,
                                     virDomainDiskDefPtr disk)
588 589
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
590 591
    size_t i;
    int ret = -1;
592 593
    char *drivestr = NULL;
    char *devstr = NULL;
594
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
595

596
    for (i = 0; i < vm->def->ndisks; i++) {
597
        if (STREQ(vm->def->disks[i]->dst, disk->dst)) {
598 599
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("target %s already exists"), disk->dst);
600
            goto cleanup;
601 602 603
        }
    }

604
    if (virDomainLockDiskAttach(driver->lockManager, cfg->uri,
605
                                vm, disk) < 0)
606
        goto cleanup;
607

608
    if (virSecurityManagerSetImageLabel(driver->securityManager,
609
                                        vm->def, disk) < 0) {
610 611
        if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
            VIR_WARN("Unable to release lock on %s", disk->src);
612
        goto cleanup;
613
    }
614

615
    /* XXX not correct once we allow attaching a USB CDROM */
616
    if (!disk->src) {
617 618
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("disk source path is missing"));
619 620 621
        goto error;
    }

622 623
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
        if (qemuAssignDeviceDiskAlias(vm->def, disk, priv->qemuCaps) < 0)
624
            goto error;
625
        if (!(drivestr = qemuBuildDriveStr(conn, disk, false, priv->qemuCaps)))
626
            goto error;
627
        if (!(devstr = qemuBuildDriveDevStr(vm->def, disk, 0, priv->qemuCaps)))
628 629 630
            goto error;
    }

631
    if (VIR_REALLOC_N(vm->def->disks, vm->def->ndisks+1) < 0)
632 633
        goto error;

634
    qemuDomainObjEnterMonitor(driver, vm);
635
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
636 637 638 639 640 641 642 643 644 645 646 647 648
        ret = qemuMonitorAddDrive(priv->mon, drivestr);
        if (ret == 0) {
            ret = qemuMonitorAddDevice(priv->mon, devstr);
            if (ret < 0) {
                VIR_WARN("qemuMonitorAddDevice failed on %s (%s)",
                         drivestr, devstr);
                /* XXX should call 'drive_del' on error but this does not
                   exist yet */
            }
        }
    } else {
        ret = qemuMonitorAddUSBDisk(priv->mon, disk->src);
    }
649
    qemuDomainObjExitMonitor(driver, vm);
650

651
    virDomainAuditDisk(vm, NULL, disk->src, "attach", ret >= 0);
652 653 654 655 656 657

    if (ret < 0)
        goto error;

    virDomainDiskInsertPreAlloced(vm->def, disk);

658
cleanup:
659 660
    VIR_FREE(devstr);
    VIR_FREE(drivestr);
661 662
    virObjectUnref(cfg);
    return ret;
663 664

error:
665
    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
666
                                            vm->def, disk) < 0)
667 668
        VIR_WARN("Unable to restore security label on %s", disk->src);

669 670 671
    if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
        VIR_WARN("Unable to release lock on %s", disk->src);

672
    goto cleanup;
673 674 675
}


676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 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 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790
int
qemuDomainAttachDeviceDiskLive(virConnectPtr conn,
                               virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
                               virDomainDeviceDefPtr dev)
{
    virDomainDiskDefPtr disk = dev->data.disk;
    virDomainDiskDefPtr orig_disk = NULL;
    virDomainDeviceDefPtr dev_copy = NULL;
    virDomainDiskDefPtr tmp = NULL;
    virCgroupPtr cgroup = NULL;
    virCapsPtr caps = NULL;
    int ret = -1;

    if (disk->driverName != NULL && !STREQ(disk->driverName, "qemu")) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("unsupported driver name '%s' for disk '%s'"),
                       disk->driverName, disk->src);
        goto end;
    }

    if (qemuTranslateDiskSourcePool(conn, disk) < 0)
        goto end;

    if (qemuAddSharedDevice(driver, dev, vm->def->name) < 0)
        goto end;

    if (qemuSetUnprivSGIO(dev) < 0)
        goto end;

    if (qemuDomainDetermineDiskChain(driver, disk, false) < 0)
        goto end;

    if (qemuSetupDiskCgroup(vm, disk) < 0)
        goto end;

    switch (disk->device)  {
    case VIR_DOMAIN_DISK_DEVICE_CDROM:
    case VIR_DOMAIN_DISK_DEVICE_FLOPPY:
        if (!(orig_disk = virDomainDiskFindByBusAndDst(vm->def,
                                                       disk->bus, disk->dst))) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("No device with bus '%s' and target '%s'"),
                           virDomainDiskBusTypeToString(disk->bus),
                           disk->dst);
            goto end;
        }

        if (!(caps = virQEMUDriverGetCapabilities(driver, false)))
            goto end;

        tmp = dev->data.disk;
        dev->data.disk = orig_disk;

        if (!(dev_copy = virDomainDeviceDefCopy(dev, vm->def,
                                                caps, driver->xmlopt))) {
            dev->data.disk = tmp;
            goto end;
        }
        dev->data.disk = tmp;

        ret = qemuDomainChangeEjectableMedia(driver, vm, disk, orig_disk, false);
        /* 'disk' must not be accessed now - it has been free'd.
         * 'orig_disk' now points to the new disk, while 'dev_copy'
         * now points to the old disk */

        /* Need to remove the shared disk entry for the original disk src
         * if the operation is either ejecting or updating.
         */
        if (ret == 0)
            ignore_value(qemuRemoveSharedDevice(driver, dev_copy,
                                                vm->def->name));
        break;
    case VIR_DOMAIN_DISK_DEVICE_DISK:
    case VIR_DOMAIN_DISK_DEVICE_LUN:
        if (disk->bus == VIR_DOMAIN_DISK_BUS_USB) {
            if (disk->device == VIR_DOMAIN_DISK_DEVICE_LUN) {
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("disk device='lun' is not supported for usb bus"));
                break;
            }
            ret = qemuDomainAttachUsbMassstorageDevice(conn, driver, vm,
                                                       disk);
        } else if (disk->bus == VIR_DOMAIN_DISK_BUS_VIRTIO) {
            ret = qemuDomainAttachVirtioDiskDevice(conn, driver, vm, disk);
        } else if (disk->bus == VIR_DOMAIN_DISK_BUS_SCSI) {
            ret = qemuDomainAttachSCSIDisk(conn, driver, vm, disk);
        } else {
            virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
                           _("disk bus '%s' cannot be hotplugged."),
                           virDomainDiskBusTypeToString(disk->bus));
        }
        break;
    default:
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
                       _("disk device type '%s' cannot be hotplugged"),
                       virDomainDiskDeviceTypeToString(disk->device));
        break;
    }

    if (ret != 0 && cgroup) {
        if (qemuTeardownDiskCgroup(vm, disk) < 0)
            VIR_WARN("Failed to teardown cgroup for disk path %s",
                     NULLSTR(disk->src));
    }

end:
    if (ret != 0)
        ignore_value(qemuRemoveSharedDevice(driver, dev, vm->def->name));
    virObjectUnref(caps);
    virDomainDeviceDefFree(dev_copy);
    return ret;
}


791 792
/* XXX conn required for network -> bridge resolution */
int qemuDomainAttachNetDevice(virConnectPtr conn,
793
                              virQEMUDriverPtr driver,
794
                              virDomainObjPtr vm,
795
                              virDomainNetDefPtr net)
796 797
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
798 799 800 801 802 803
    char **tapfdName = NULL;
    int *tapfd = NULL;
    int tapfdSize = 0;
    char **vhostfdName = NULL;
    int *vhostfd = NULL;
    int vhostfdSize = 0;
804 805
    char *nicstr = NULL;
    char *netstr = NULL;
A
Ansis Atteka 已提交
806
    virNetDevVPortProfilePtr vport = NULL;
807
    int ret = -1;
808
    virDevicePCIAddress guestAddr;
809
    int vlan;
810
    bool releaseaddr = false;
811 812
    bool iface_connected = false;
    int actualType;
813
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
814
    size_t i;
815

816
    /* preallocate new slot for device */
817
    if (VIR_REALLOC_N(vm->def->nets, vm->def->nnets+1) < 0)
818
        goto cleanup;
819

820 821 822 823 824
    /* If appropriate, grab a physical device from the configured
     * network's pool of devices, or resolve bridge device name
     * to the one defined in the network definition.
     */
    if (networkAllocateActualDevice(net) < 0)
825
        goto cleanup;
826 827

    actualType = virDomainNetGetActualType(net);
828 829 830 831 832 833 834 835 836 837 838 839

    if (actualType == VIR_DOMAIN_NET_TYPE_HOSTDEV) {
        /* This is really a "smart hostdev", so it should be attached
         * as a hostdev (the hostdev code will reach over into the
         * netdev-specific code as appropriate), then also added to
         * the nets list (see cleanup:) if successful.
         */
        ret = qemuDomainAttachHostDevice(driver, vm,
                                         virDomainNetGetActualHostdev(net));
        goto cleanup;
    }

840
    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_HOST_NET_ADD)) {
841 842
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("installed qemu version does not support host_net_add"));
843 844 845
        goto cleanup;
    }

846 847 848 849 850 851 852 853 854 855
    /* Currently nothing besides TAP devices supports multiqueue. */
    if (net->driver.virtio.queues > 0 &&
        !(actualType == VIR_DOMAIN_NET_TYPE_NETWORK ||
          actualType == VIR_DOMAIN_NET_TYPE_BRIDGE)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Multiqueue network is not supported for: %s"),
                       virDomainNetTypeToString(actualType));
        return -1;
    }

856 857
    if (actualType == VIR_DOMAIN_NET_TYPE_BRIDGE ||
        actualType == VIR_DOMAIN_NET_TYPE_NETWORK) {
858 859 860 861
        tapfdSize = vhostfdSize = net->driver.virtio.queues;
        if (!tapfdSize)
            tapfdSize = vhostfdSize = 1;
        if (VIR_ALLOC_N(tapfd, tapfdSize) < 0 ||
862
            VIR_ALLOC_N(vhostfd, vhostfdSize) < 0)
863 864 865
            goto cleanup;
        if (qemuNetworkIfaceConnect(vm->def, conn, driver, net,
                                    priv->qemuCaps, tapfd, &tapfdSize) < 0)
866 867
            goto cleanup;
        iface_connected = true;
868
        if (qemuOpenVhostNet(vm->def, net, priv->qemuCaps, vhostfd, &vhostfdSize) < 0)
869
            goto cleanup;
870
    } else if (actualType == VIR_DOMAIN_NET_TYPE_DIRECT) {
871
        tapfdSize = vhostfdSize = 1;
872
        if (VIR_ALLOC(tapfd) < 0 || VIR_ALLOC(vhostfd) < 0)
873 874 875 876
            goto cleanup;
        if ((tapfd[0] = qemuPhysIfaceConnect(vm->def, driver, net,
                                             priv->qemuCaps,
                                             VIR_NETDEV_VPORT_PROFILE_OP_CREATE)) < 0)
877 878
            goto cleanup;
        iface_connected = true;
879
        if (qemuOpenVhostNet(vm->def, net, priv->qemuCaps, vhostfd, &vhostfdSize) < 0)
880
            goto cleanup;
881
    } else if (actualType == VIR_DOMAIN_NET_TYPE_ETHERNET) {
882
        vhostfdSize = 1;
883
        if (VIR_ALLOC(vhostfd) < 0)
884 885
            goto cleanup;
        if (qemuOpenVhostNet(vm->def, net, priv->qemuCaps, vhostfd, &vhostfdSize) < 0)
886
            goto cleanup;
887 888
    }

889 890
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NET_NAME) ||
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
891 892 893 894
        if (qemuAssignDeviceNetAlias(vm->def, net, -1) < 0)
            goto cleanup;
    }

895 896 897 898 899 900 901 902 903 904 905 906
    if (STREQLEN(vm->def->os.machine, "s390-ccw", 8) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_CCW)) {
        net->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_CCW;
        if (qemuDomainCCWAddressAssign(&net->info, priv->ccwaddrs,
                                       !net->info.addr.ccw.assigned) < 0)
            goto cleanup;
    } else if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_S390))
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                        _("virtio-s390 net device cannot be hotplugged."));
    else if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE) &&
             qemuDomainPCIAddressEnsureAddr(priv->pciaddrs, &net->info) < 0)
             goto cleanup;
907

908 909
    releaseaddr = true;

910 911
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
912 913 914 915 916
        vlan = -1;
    } else {
        vlan = qemuDomainNetVLAN(net);

        if (vlan < 0) {
917 918
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("Unable to attach network devices without vlan"));
919 920 921 922
            goto cleanup;
        }
    }

923
    if (VIR_ALLOC_N(tapfdName, tapfdSize) < 0 ||
924
        VIR_ALLOC_N(vhostfdName, vhostfdSize) < 0)
925 926 927
        goto cleanup;

    for (i = 0; i < tapfdSize; i++) {
928
        if (virAsprintf(&tapfdName[i], "fd-%s%zu", net->info.alias, i) < 0)
929
            goto cleanup;
930 931
    }

932
    for (i = 0; i < vhostfdSize; i++) {
933
        if (virAsprintf(&vhostfdName[i], "vhostfd-%s%zu", net->info.alias, i) < 0)
934
            goto cleanup;
935 936
    }

937 938
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
939
        if (!(netstr = qemuBuildHostNetStr(net, driver,
940 941 942
                                           ',', -1,
                                           tapfdName, tapfdSize,
                                           vhostfdName, vhostfdSize)))
943
            goto cleanup;
944
    } else {
945
        if (!(netstr = qemuBuildHostNetStr(net, driver,
946 947 948
                                           ' ', vlan,
                                           tapfdName, tapfdSize,
                                           vhostfdName, vhostfdSize)))
949
            goto cleanup;
950 951
    }

952
    qemuDomainObjEnterMonitor(driver, vm);
953 954
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
955 956 957
        if (qemuMonitorAddNetdev(priv->mon, netstr,
                                 tapfd, tapfdName, tapfdSize,
                                 vhostfd, vhostfdName, vhostfdSize) < 0) {
958
            qemuDomainObjExitMonitor(driver, vm);
959
            virDomainAuditNet(vm, NULL, net, "attach", false);
960
            goto cleanup;
961 962
        }
    } else {
963 964 965
        if (qemuMonitorAddHostNetwork(priv->mon, netstr,
                                      tapfd, tapfdName, tapfdSize,
                                      vhostfd, vhostfdName, vhostfdSize) < 0) {
966
            qemuDomainObjExitMonitor(driver, vm);
967
            virDomainAuditNet(vm, NULL, net, "attach", false);
968
            goto cleanup;
969 970
        }
    }
971
    qemuDomainObjExitMonitor(driver, vm);
972

973 974 975 976
    for (i = 0; i < tapfdSize; i++)
        VIR_FORCE_CLOSE(tapfd[i]);
    for (i = 0; i < vhostfdSize; i++)
        VIR_FORCE_CLOSE(vhostfd[i]);
977 978

    if (!virDomainObjIsActive(vm)) {
979 980
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("guest unexpectedly quit"));
981 982 983
        goto cleanup;
    }

984
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
985 986 987 988
        bool multiqueue = tapfdSize > 1 || vhostfdSize > 1;

        if (!(nicstr = qemuBuildNicDevStr(vm->def, net, vlan, 0,
                                          multiqueue, priv->qemuCaps)))
989 990 991 992 993 994
            goto try_remove;
    } else {
        if (!(nicstr = qemuBuildNicStr(net, NULL, vlan)))
            goto try_remove;
    }

995
    qemuDomainObjEnterMonitor(driver, vm);
996
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
997
        if (qemuMonitorAddDevice(priv->mon, nicstr) < 0) {
998
            qemuDomainObjExitMonitor(driver, vm);
999
            virDomainAuditNet(vm, NULL, net, "attach", false);
1000 1001 1002
            goto try_remove;
        }
    } else {
1003
        guestAddr = net->info.addr.pci;
1004 1005
        if (qemuMonitorAddPCINetwork(priv->mon, nicstr,
                                     &guestAddr) < 0) {
1006
            qemuDomainObjExitMonitor(driver, vm);
1007
            virDomainAuditNet(vm, NULL, net, "attach", false);
1008 1009 1010 1011 1012
            goto try_remove;
        }
        net->info.type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI;
        memcpy(&net->info.addr.pci, &guestAddr, sizeof(guestAddr));
    }
1013
    qemuDomainObjExitMonitor(driver, vm);
1014

1015 1016 1017
    /* set link state */
    if (net->linkstate == VIR_DOMAIN_NET_INTERFACE_LINK_STATE_DOWN) {
        if (!net->info.alias) {
1018 1019
            virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                           _("device alias not found: cannot set link state to down"));
1020
        } else {
1021
            qemuDomainObjEnterMonitor(driver, vm);
1022

1023
            if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV)) {
1024
                if (qemuMonitorSetLink(priv->mon, net->info.alias, VIR_DOMAIN_NET_INTERFACE_LINK_STATE_DOWN) < 0) {
1025
                    qemuDomainObjExitMonitor(driver, vm);
1026 1027 1028 1029
                    virDomainAuditNet(vm, NULL, net, "attach", false);
                    goto try_remove;
                }
            } else {
1030
                virReportError(VIR_ERR_OPERATION_FAILED, "%s",
1031
                               _("setting of link state not supported: Link is up"));
1032 1033
            }

1034
            qemuDomainObjExitMonitor(driver, vm);
1035 1036 1037 1038
        }
        /* link set to down */
    }

1039
    virDomainAuditNet(vm, NULL, net, "attach", true);
1040 1041 1042 1043

    ret = 0;

cleanup:
1044 1045 1046
    if (!ret) {
        vm->def->nets[vm->def->nnets++] = net;
    } else {
1047 1048
        if (releaseaddr)
            qemuDomainReleaseDeviceAddress(vm, &net->info, NULL);
1049

1050
        if (iface_connected) {
1051
            virDomainConfNWFilterTeardown(net);
1052

1053 1054 1055 1056 1057 1058 1059 1060 1061 1062
            if (virDomainNetGetActualType(net) == VIR_DOMAIN_NET_TYPE_DIRECT) {
                ignore_value(virNetDevMacVLanDeleteWithVPortProfile(
                                 net->ifname, &net->mac,
                                 virDomainNetGetActualDirectDev(net),
                                 virDomainNetGetActualDirectMode(net),
                                 virDomainNetGetActualVirtPortProfile(net),
                                 cfg->stateDir));
                VIR_FREE(net->ifname);
            }

1063 1064 1065 1066 1067
            vport = virDomainNetGetActualVirtPortProfile(net);
            if (vport && vport->virtPortType == VIR_NETDEV_VPORT_PROFILE_OPENVSWITCH)
               ignore_value(virNetDevOpenvswitchRemovePort(
                               virDomainNetGetActualBridgeName(net), net->ifname));
        }
A
Ansis Atteka 已提交
1068

1069 1070
        networkReleaseActualDevice(net);
    }
1071 1072 1073

    VIR_FREE(nicstr);
    VIR_FREE(netstr);
1074
    for (i = 0; tapfd && i < tapfdSize; i++) {
1075
        VIR_FORCE_CLOSE(tapfd[i]);
1076 1077
        if (tapfdName)
            VIR_FREE(tapfdName[i]);
1078 1079 1080
    }
    VIR_FREE(tapfd);
    VIR_FREE(tapfdName);
1081
    for (i = 0; vhostfd && i < vhostfdSize; i++) {
1082
        VIR_FORCE_CLOSE(vhostfd[i]);
1083 1084
        if (vhostfdName)
            VIR_FREE(vhostfdName[i]);
1085 1086 1087
    }
    VIR_FREE(vhostfd);
    VIR_FREE(vhostfdName);
1088
    virObjectUnref(cfg);
1089 1090 1091 1092 1093 1094 1095 1096

    return ret;

try_remove:
    if (!virDomainObjIsActive(vm))
        goto cleanup;

    if (vlan < 0) {
1097 1098
        if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV) &&
            virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
1099 1100
            char *netdev_name;
            if (virAsprintf(&netdev_name, "host%s", net->info.alias) < 0)
1101
                goto cleanup;
1102
            qemuDomainObjEnterMonitor(driver, vm);
1103 1104 1105
            if (qemuMonitorRemoveNetdev(priv->mon, netdev_name) < 0)
                VIR_WARN("Failed to remove network backend for netdev %s",
                         netdev_name);
1106
            qemuDomainObjExitMonitor(driver, vm);
1107 1108
            VIR_FREE(netdev_name);
        } else {
1109
            VIR_WARN("Unable to remove network backend");
1110 1111 1112 1113
        }
    } else {
        char *hostnet_name;
        if (virAsprintf(&hostnet_name, "host%s", net->info.alias) < 0)
1114
            goto cleanup;
1115
        qemuDomainObjEnterMonitor(driver, vm);
1116 1117 1118
        if (qemuMonitorRemoveHostNetwork(priv->mon, vlan, hostnet_name) < 0)
            VIR_WARN("Failed to remove network backend for vlan %d, net %s",
                     vlan, hostnet_name);
1119
        qemuDomainObjExitMonitor(driver, vm);
1120 1121 1122 1123 1124 1125
        VIR_FREE(hostnet_name);
    }
    goto cleanup;
}


1126
int qemuDomainAttachHostPciDevice(virQEMUDriverPtr driver,
1127
                                  virDomainObjPtr vm,
1128
                                  virDomainHostdevDefPtr hostdev)
1129 1130 1131 1132 1133 1134
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
    int ret;
    char *devstr = NULL;
    int configfd = -1;
    char *configfd_name = NULL;
1135
    bool releaseaddr = false;
1136

1137
    if (VIR_REALLOC_N(vm->def->hostdevs, vm->def->nhostdevs+1) < 0)
1138 1139
        return -1;

1140 1141
    if (qemuPrepareHostdevPCIDevices(driver, vm->def->name, vm->def->uuid,
                                     &hostdev, 1) < 0)
1142 1143
        return -1;

1144
    if (hostdev->source.subsys.u.pci.backend
1145
        == VIR_DOMAIN_HOSTDEV_PCI_BACKEND_VFIO) {
1146 1147 1148 1149 1150 1151
        if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE_VFIO_PCI)) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("VFIO PCI device assignment is not "
                             "supported by this version of qemu"));
            goto error;
        }
1152 1153 1154 1155

        /* VFIO requires all of the guest's memory to be locked resident.
         * In this case, the guest's memory may already be locked, but it
         * doesn't hurt to "change" the limit to the same value.
1156
         */
1157 1158
        vm->def->hostdevs[vm->def->nhostdevs++] = hostdev;
        virProcessSetMaxMemLock(vm->pid,
1159
                                vm->def->mem.hard_limit * 1024);
1160
        vm->def->hostdevs[vm->def->nhostdevs--] = NULL;
1161 1162
    }

1163
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
1164 1165
        if (qemuAssignDeviceHostdevAlias(vm->def, hostdev, -1) < 0)
            goto error;
1166
        if (qemuDomainPCIAddressEnsureAddr(priv->pciaddrs, hostdev->info) < 0)
1167
            goto error;
1168
        releaseaddr = true;
1169
        if ((hostdev->source.subsys.u.pci.backend
1170
             != VIR_DOMAIN_HOSTDEV_PCI_BACKEND_VFIO) &&
1171
            virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_PCI_CONFIGFD)) {
1172 1173 1174
            configfd = qemuOpenPCIConfig(hostdev);
            if (configfd >= 0) {
                if (virAsprintf(&configfd_name, "fd-%s",
1175
                                hostdev->info->alias) < 0)
1176 1177 1178 1179 1180
                    goto error;
            }
        }

        if (!virDomainObjIsActive(vm)) {
1181 1182
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("guest unexpectedly quit during hotplug"));
1183 1184 1185
            goto error;
        }

1186
        if (!(devstr = qemuBuildPCIHostdevDevStr(vm->def, hostdev, configfd_name,
1187
                                                 priv->qemuCaps)))
1188 1189
            goto error;

1190
        qemuDomainObjEnterMonitor(driver, vm);
1191 1192
        ret = qemuMonitorAddDeviceWithFd(priv->mon, devstr,
                                         configfd, configfd_name);
1193
        qemuDomainObjExitMonitor(driver, vm);
1194
    } else {
1195
        virDevicePCIAddress guestAddr = hostdev->info->addr.pci;
1196

1197
        qemuDomainObjEnterMonitor(driver, vm);
1198
        ret = qemuMonitorAddPCIHostDevice(priv->mon,
1199
                                          &hostdev->source.subsys.u.pci.addr,
1200
                                          &guestAddr);
1201
        qemuDomainObjExitMonitor(driver, vm);
1202

1203 1204
        hostdev->info->type = VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI;
        memcpy(&hostdev->info->addr.pci, &guestAddr, sizeof(guestAddr));
1205
    }
1206
    virDomainAuditHostdev(vm, hostdev, "attach", ret == 0);
1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218
    if (ret < 0)
        goto error;

    vm->def->hostdevs[vm->def->nhostdevs++] = hostdev;

    VIR_FREE(devstr);
    VIR_FREE(configfd_name);
    VIR_FORCE_CLOSE(configfd);

    return 0;

error:
1219 1220
    if (releaseaddr)
        qemuDomainReleaseDeviceAddress(vm, hostdev->info, NULL);
1221

1222
    qemuDomainReAttachHostdevDevices(driver, vm->def->name, &hostdev, 1);
1223 1224 1225 1226 1227 1228 1229 1230 1231

    VIR_FREE(devstr);
    VIR_FREE(configfd_name);
    VIR_FORCE_CLOSE(configfd);

    return -1;
}


1232
int qemuDomainAttachRedirdevDevice(virQEMUDriverPtr driver,
1233 1234 1235 1236 1237
                                   virDomainObjPtr vm,
                                   virDomainRedirdevDefPtr redirdev)
{
    int ret;
    qemuDomainObjPrivatePtr priv = vm->privateData;
1238
    virDomainDefPtr def = vm->def;
1239 1240
    char *devstr = NULL;

1241
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
1242 1243
        if (qemuAssignDeviceRedirdevAlias(vm->def, redirdev, -1) < 0)
            goto error;
1244
        if (!(devstr = qemuBuildRedirdevDevStr(def, redirdev, priv->qemuCaps)))
1245 1246 1247
            goto error;
    }

1248
    if (VIR_REALLOC_N(vm->def->redirdevs, vm->def->nredirdevs+1) < 0)
1249 1250
        goto error;

1251
    qemuDomainObjEnterMonitor(driver, vm);
1252
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE))
1253 1254 1255 1256
        ret = qemuMonitorAddDevice(priv->mon, devstr);
    else
        goto error;

1257
    qemuDomainObjExitMonitor(driver, vm);
1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273
    virDomainAuditRedirdev(vm, redirdev, "attach", ret == 0);
    if (ret < 0)
        goto error;

    vm->def->redirdevs[vm->def->nredirdevs++] = redirdev;

    VIR_FREE(devstr);

    return 0;

error:
    VIR_FREE(devstr);
    return -1;

}

1274 1275 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 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345
int
qemuDomainChrInsert(virDomainDefPtr vmdef,
                    virDomainChrDefPtr chr)
{
    if (chr->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE &&
        chr->targetType == VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_SERIAL) {
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
                       _("attaching serial console is not supported"));
        return -1;
    }

    if (virDomainChrFind(vmdef, chr)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("chardev already exists"));
        return -1;
    }

    if (virDomainChrInsert(vmdef, chr) < 0)
        return -1;

    /* Due to some crazy backcompat stuff, the first serial device is an alias
     * to the first console too. If this is the case, the definition must be
     * duplicated as first console device. */
    if (vmdef->nserials == 1 && vmdef->nconsoles == 0) {
        if ((!vmdef->consoles && VIR_ALLOC(vmdef->consoles) < 0) ||
            VIR_ALLOC(vmdef->consoles[0]) < 0) {
            virDomainChrRemove(vmdef, chr);
            return -1;
        }
        vmdef->nconsoles = 1;

        /* Create an console alias for the serial port */
        vmdef->consoles[0]->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE;
        vmdef->consoles[0]->targetType = VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_SERIAL;
    }

    return 0;
}

virDomainChrDefPtr
qemuDomainChrRemove(virDomainDefPtr vmdef,
                    virDomainChrDefPtr chr)
{
    virDomainChrDefPtr ret;
    bool removeCompat;

    if (chr->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE &&
        chr->targetType == VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_SERIAL) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("detaching serial console is not supported"));
        return NULL;
    }

    /* Due to some crazy backcompat stuff, the first serial device is an alias
     * to the first console too. If this is the case, the definition must be
     * duplicated as first console device. */
    removeCompat = vmdef->nserials && vmdef->nconsoles &&
        vmdef->consoles[0]->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE &&
        vmdef->consoles[0]->targetType == VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_SERIAL &&
        virDomainChrEquals(vmdef->serials[0], chr);

    if (!(ret = virDomainChrRemove(vmdef, chr))) {
        virReportError(VIR_ERR_INVALID_ARG, "%s",
                       _("device not present in domain configuration"));
            return NULL;
    }

    if (removeCompat)
        VIR_DELETE_ELEMENT(vmdef->consoles, 0, vmdef->nconsoles);

    return ret;
}
1346 1347 1348 1349 1350 1351 1352 1353 1354 1355

int qemuDomainAttachChrDevice(virQEMUDriverPtr driver,
                              virDomainObjPtr vm,
                              virDomainChrDefPtr chr)
{
    int ret = -1;
    qemuDomainObjPrivatePtr priv = vm->privateData;
    virDomainDefPtr vmdef = vm->def;
    char *devstr = NULL;
    char *charAlias = NULL;
1356
    bool need_remove = false;
1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376

    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("qemu does not support -device"));
        return ret;
    }

    if (qemuAssignDeviceChrAlias(vmdef, chr, -1) < 0)
        return ret;

    if (qemuBuildChrDeviceStr(&devstr, vm->def, chr, priv->qemuCaps) < 0)
        return ret;

    if (virAsprintf(&charAlias, "char%s", chr->info.alias) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (qemuDomainChrInsert(vmdef, chr) < 0)
        goto cleanup;
1377
    need_remove = true;
1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394

    qemuDomainObjEnterMonitor(driver, vm);
    if (qemuMonitorAttachCharDev(priv->mon, charAlias, &chr->source) < 0) {
        qemuDomainObjExitMonitor(driver, vm);
        goto cleanup;
    }

    if (devstr && qemuMonitorAddDevice(priv->mon, devstr) < 0) {
        /* detach associated chardev on error */
        qemuMonitorDetachCharDev(priv->mon, charAlias);
        qemuDomainObjExitMonitor(driver, vm);
        goto cleanup;
    }
    qemuDomainObjExitMonitor(driver, vm);

    ret = 0;
cleanup:
1395
    if (ret < 0 && need_remove)
1396 1397 1398 1399 1400 1401
        qemuDomainChrRemove(vmdef, chr);
    VIR_FREE(charAlias);
    VIR_FREE(devstr);
    return ret;
}

1402
int qemuDomainAttachHostUsbDevice(virQEMUDriverPtr driver,
1403
                                  virDomainObjPtr vm,
1404
                                  virDomainHostdevDefPtr hostdev)
1405 1406
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
1407 1408
    virUSBDeviceList *list = NULL;
    virUSBDevicePtr usb = NULL;
1409
    char *devstr = NULL;
1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426
    bool added = false;
    int ret = -1;

    if (qemuFindHostdevUSBDevice(hostdev, true, &usb) < 0)
        return -1;

    if (!(list = virUSBDeviceListNew()))
        goto cleanup;

    if (virUSBDeviceListAdd(list, usb) < 0)
        goto cleanup;

    if (qemuPrepareHostdevUSBDevices(driver, vm->def->name, list) < 0)
        goto cleanup;

    added = true;
    virUSBDeviceListSteal(list, usb);
1427

1428
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
1429
        if (qemuAssignDeviceHostdevAlias(vm->def, hostdev, -1) < 0)
1430
            goto cleanup;
1431
        if (!(devstr = qemuBuildUSBHostdevDevStr(vm->def, hostdev, priv->qemuCaps)))
1432
            goto cleanup;
1433 1434
    }

1435
    if (VIR_REALLOC_N(vm->def->hostdevs, vm->def->nhostdevs+1) < 0)
1436
        goto cleanup;
1437

1438
    qemuDomainObjEnterMonitor(driver, vm);
1439
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE))
1440 1441 1442 1443 1444
        ret = qemuMonitorAddDevice(priv->mon, devstr);
    else
        ret = qemuMonitorAddUSBDeviceExact(priv->mon,
                                           hostdev->source.subsys.u.usb.bus,
                                           hostdev->source.subsys.u.usb.device);
1445
    qemuDomainObjExitMonitor(driver, vm);
1446
    virDomainAuditHostdev(vm, hostdev, "attach", ret == 0);
1447
    if (ret < 0)
1448
        goto cleanup;
1449 1450 1451

    vm->def->hostdevs[vm->def->nhostdevs++] = hostdev;

1452 1453 1454 1455 1456 1457
    ret = 0;
cleanup:
    if (added)
        virUSBDeviceListSteal(driver->activeUsbHostdevs, usb);
    virUSBDeviceFree(usb);
    virObjectUnref(list);
1458
    VIR_FREE(devstr);
1459
    return ret;
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
static int
qemuDomainAttachHostScsiDevice(virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
                               virDomainHostdevDefPtr hostdev)
{
    int ret = -1;
    qemuDomainObjPrivatePtr priv = vm->privateData;
    char *devstr = NULL;
    char *drvstr = NULL;

    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DRIVE) ||
        !virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE) ||
        !virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE_SCSI_GENERIC)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("SCSI passthrough is not supported by this version of qemu"));
        return -1;
    }

    if (qemuPrepareHostdevSCSIDevices(driver, vm->def->name,
                                      &hostdev, 1)) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unable to prepare scsi hostdev: %s:%d:%d:%d"),
                       hostdev->source.subsys.u.scsi.adapter,
                       hostdev->source.subsys.u.scsi.bus,
                       hostdev->source.subsys.u.scsi.target,
                       hostdev->source.subsys.u.scsi.unit);
        return -1;
    }

1491
    if (qemuAssignDeviceHostdevAlias(vm->def, hostdev, -1) < 0)
1492 1493
        goto cleanup;

1494 1495
    if (!(drvstr = qemuBuildSCSIHostdevDrvStr(hostdev, priv->qemuCaps,
                                              &buildCommandLineCallbacks)))
1496 1497 1498 1499 1500
        goto cleanup;

    if (!(devstr = qemuBuildSCSIHostdevDevStr(vm->def, hostdev, priv->qemuCaps)))
        goto cleanup;

1501
    if (VIR_REALLOC_N(vm->def->hostdevs, vm->def->nhostdevs + 1) < 0)
1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534
        goto cleanup;

    qemuDomainObjEnterMonitor(driver, vm);
    if ((ret = qemuMonitorAddDrive(priv->mon, drvstr)) == 0) {
        if ((ret = qemuMonitorAddDevice(priv->mon, devstr)) < 0) {
            virErrorPtr orig_err = virSaveLastError();
            if (qemuMonitorDriveDel(priv->mon, drvstr) < 0)
                VIR_WARN("Unable to remove drive %s (%s) after failed "
                         "qemuMonitorAddDevice",
                         drvstr, devstr);
            if (orig_err) {
                virSetError(orig_err);
                virFreeError(orig_err);
            }
        }
    }
    qemuDomainObjExitMonitor(driver, vm);

    virDomainAuditHostdev(vm, hostdev, "attach", ret == 0);
    if (ret < 0)
        goto cleanup;

    vm->def->hostdevs[vm->def->nhostdevs++] = hostdev;

    ret = 0;
cleanup:
    if (ret < 0)
        qemuDomainReAttachHostScsiDevices(driver, vm->def->name, &hostdev, 1);
    VIR_FREE(drvstr);
    VIR_FREE(devstr);
    return ret;
}

1535
int qemuDomainAttachHostDevice(virQEMUDriverPtr driver,
1536
                               virDomainObjPtr vm,
1537
                               virDomainHostdevDefPtr hostdev)
1538 1539
{
    if (hostdev->mode != VIR_DOMAIN_HOSTDEV_MODE_SUBSYS) {
1540 1541 1542
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("hostdev mode '%s' not supported"),
                       virDomainHostdevModeTypeToString(hostdev->mode));
1543 1544 1545
        return -1;
    }

1546
    if (qemuSetupHostdevCGroup(vm, hostdev) < 0)
1547
        return -1;
1548

1549
    if (virSecurityManagerSetHostdevLabel(driver->securityManager,
1550
                                          vm->def, hostdev, NULL) < 0)
1551
        goto cleanup;
1552 1553 1554 1555

    switch (hostdev->source.subsys.type) {
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI:
        if (qemuDomainAttachHostPciDevice(driver, vm,
1556
                                          hostdev) < 0)
1557 1558 1559 1560 1561
            goto error;
        break;

    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB:
        if (qemuDomainAttachHostUsbDevice(driver, vm,
1562
                                          hostdev) < 0)
1563 1564 1565
            goto error;
        break;

1566 1567 1568 1569 1570 1571
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_SCSI:
        if (qemuDomainAttachHostScsiDevice(driver, vm,
                                           hostdev) < 0)
            goto error;
        break;

1572
    default:
1573 1574 1575
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("hostdev subsys type '%s' not supported"),
                       virDomainHostdevSubsysTypeToString(hostdev->source.subsys.type));
1576 1577 1578 1579 1580 1581
        goto error;
    }

    return 0;

error:
1582
    if (virSecurityManagerRestoreHostdevLabel(driver->securityManager,
1583
                                              vm->def, hostdev, NULL) < 0)
1584
        VIR_WARN("Unable to restore host device labelling on hotplug fail");
1585

1586
cleanup:
1587 1588
    if (qemuTeardownHostdevCgroup(vm, hostdev) < 0)
        VIR_WARN("Unable to remove host device cgroup ACL on hotplug fail");
1589 1590 1591
    return -1;
}

1592 1593
static virDomainNetDefPtr *qemuDomainFindNet(virDomainObjPtr vm,
                                             virDomainNetDefPtr dev)
1594
{
1595
    size_t i;
1596 1597

    for (i = 0; i < vm->def->nnets; i++) {
1598
        if (virMacAddrCmp(&vm->def->nets[i]->mac, &dev->mac) == 0)
1599
            return &vm->def->nets[i];
1600 1601 1602 1603 1604
    }

    return NULL;
}

1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618
static char *
qemuDomainNetGetBridgeName(virConnectPtr conn, virDomainNetDefPtr net)
{
    char *brname = NULL;
    int actualType = virDomainNetGetActualType(net);

    if (actualType == VIR_DOMAIN_NET_TYPE_BRIDGE) {
        const char *tmpbr = virDomainNetGetActualBridgeName(net);
        if (!tmpbr) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("interface is missing bridge name"));
            goto cleanup;
        }
        /* we need a copy, not just a pointer to the original */
1619
        if (VIR_STRDUP(brname, tmpbr) < 0)
1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647
            goto cleanup;
    } else if (actualType == VIR_DOMAIN_NET_TYPE_NETWORK) {
        int active;
        virErrorPtr errobj;
        virNetworkPtr network;

        if (!(network = virNetworkLookupByName(conn, net->data.network.name))) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Couldn't find network '%s'"),
                           net->data.network.name);
            goto cleanup;
        }

        active = virNetworkIsActive(network);
        if (active == 1) {
            brname = virNetworkGetBridgeName(network);
        } else if (active == 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Network '%s' is not active."),
                           net->data.network.name);
        }

        /* Make sure any above failure is preserved */
        errobj = virSaveLastError();
        virNetworkFree(network);
        virSetError(errobj);
        virFreeError(errobj);

1648 1649 1650 1651
    } else {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Interface type %d has no bridge name"),
                       virDomainNetGetActualType(net));
1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662
    }

cleanup:
    return brname;
}

static int
qemuDomainChangeNetBridge(virConnectPtr conn,
                          virDomainObjPtr vm,
                          virDomainNetDefPtr olddev,
                          virDomainNetDefPtr newdev)
1663 1664
{
    int ret = -1;
1665 1666 1667 1668 1669 1670 1671
    char *oldbridge = NULL, *newbridge = NULL;

    if (!(oldbridge = qemuDomainNetGetBridgeName(conn, olddev)))
        goto cleanup;

    if (!(newbridge = qemuDomainNetGetBridgeName(conn, newdev)))
        goto cleanup;
1672 1673 1674 1675 1676

    VIR_DEBUG("Change bridge for interface %s: %s -> %s",
              olddev->ifname, oldbridge, newbridge);

    if (virNetDevExists(newbridge) != 1) {
1677 1678
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("bridge %s doesn't exist"), newbridge);
1679
        goto cleanup;
1680 1681 1682 1683 1684
    }

    if (oldbridge) {
        ret = virNetDevBridgeRemovePort(oldbridge, olddev->ifname);
        virDomainAuditNet(vm, olddev, NULL, "detach", ret == 0);
1685 1686 1687 1688 1689 1690 1691 1692
        if (ret < 0) {
            /* warn but continue - possibly the old network
             * had been destroyed and reconstructed, leaving the
             * tap device orphaned.
             */
            VIR_WARN("Unable to detach device %s from bridge %s",
                     olddev->ifname, oldbridge);
        }
1693 1694 1695
    }

    ret = virNetDevBridgeAddPort(newbridge, olddev->ifname);
1696
    virDomainAuditNet(vm, NULL, newdev, "attach", ret == 0);
1697 1698 1699 1700
    if (ret < 0) {
        ret = virNetDevBridgeAddPort(oldbridge, olddev->ifname);
        virDomainAuditNet(vm, NULL, olddev, "attach", ret == 0);
        if (ret < 0) {
1701
            virReportError(VIR_ERR_OPERATION_FAILED,
1702
                           _("unable to recover former state by adding port "
1703
                             "to bridge %s"), oldbridge);
1704
        }
1705
        goto cleanup;
1706
    }
1707 1708 1709
    /* caller will replace entire olddev with newdev in domain nets list */
    ret = 0;
cleanup:
1710
    VIR_FREE(oldbridge);
1711 1712
    VIR_FREE(newbridge);
    return ret;
1713 1714
}

1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751
static int
qemuDomainChangeNetFilter(virConnectPtr conn,
                          virDomainObjPtr vm,
                          virDomainNetDefPtr olddev,
                          virDomainNetDefPtr newdev)
{
    /* make sure this type of device supports filters. */
    switch (virDomainNetGetActualType(newdev)) {
    case VIR_DOMAIN_NET_TYPE_ETHERNET:
    case VIR_DOMAIN_NET_TYPE_BRIDGE:
    case VIR_DOMAIN_NET_TYPE_NETWORK:
        break;
    default:
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("filters not supported on interfaces of type %s"),
                       virDomainNetTypeToString(virDomainNetGetActualType(newdev)));
        return -1;
    }

    virDomainConfNWFilterTeardown(olddev);

    if (virDomainConfNWFilterInstantiate(conn, vm->def->uuid, newdev) < 0) {
        virErrorPtr errobj;

        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("failed to add new filter rules to '%s' "
                         "- attempting to restore old rules"),
                       olddev->ifname);
        errobj = virSaveLastError();
        ignore_value(virDomainConfNWFilterInstantiate(conn, vm->def->uuid, olddev));
        virSetError(errobj);
        virFreeError(errobj);
        return -1;
    }
    return 0;
}

1752
int qemuDomainChangeNetLinkState(virQEMUDriverPtr driver,
1753 1754 1755 1756 1757 1758 1759 1760 1761 1762
                                 virDomainObjPtr vm,
                                 virDomainNetDefPtr dev,
                                 int linkstate)
{
    int ret = -1;
    qemuDomainObjPrivatePtr priv = vm->privateData;

    VIR_DEBUG("dev: %s, state: %d", dev->info.alias, linkstate);

    if (!dev->info.alias) {
1763 1764
        virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                       _("can't change link state: device alias not found"));
1765 1766 1767
        return -1;
    }

1768
    qemuDomainObjEnterMonitor(driver, vm);
1769 1770 1771 1772 1773 1774 1775 1776 1777

    ret = qemuMonitorSetLink(priv->mon, dev->info.alias, linkstate);
    if (ret < 0)
        goto cleanup;

    /* modify the device configuration */
    dev->linkstate = linkstate;

cleanup:
1778
    qemuDomainObjExitMonitor(driver, vm);
1779 1780 1781 1782

    return ret;
}

1783
int
1784
qemuDomainChangeNet(virQEMUDriverPtr driver,
1785 1786 1787
                    virDomainObjPtr vm,
                    virDomainPtr dom,
                    virDomainDeviceDefPtr dev)
1788
{
1789 1790 1791 1792 1793 1794
    virDomainNetDefPtr newdev = dev->data.net;
    virDomainNetDefPtr *devslot = qemuDomainFindNet(vm, newdev);
    virDomainNetDefPtr olddev;
    int oldType, newType;
    bool needReconnect = false;
    bool needBridgeChange = false;
1795
    bool needFilterChange = false;
1796 1797 1798
    bool needLinkStateChange = false;
    bool needReplaceDevDef = false;
    int ret = -1;
1799

1800
    if (!devslot || !(olddev = *devslot)) {
1801
        virReportError(VIR_ERR_OPERATION_FAILED, "%s",
1802
                       _("cannot find existing network device to modify"));
1803 1804 1805 1806 1807 1808
        goto cleanup;
    }

    oldType = virDomainNetGetActualType(olddev);
    if (oldType == VIR_DOMAIN_NET_TYPE_HOSTDEV) {
        /* no changes are possible to a type='hostdev' interface */
1809
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831
                       _("cannot change config of '%s' network type"),
                       virDomainNetTypeToString(oldType));
        goto cleanup;
    }

    /* Check individual attributes for changes that can't be done to a
     * live netdev. These checks *mostly* go in order of the
     * declarations in virDomainNetDef in order to assure nothing is
     * omitted. (exceptiong where noted in comments - in particular,
     * some things require that a new "actual device" be allocated
     * from the network driver first, but we delay doing that until
     * after we've made as many other checks as possible)
     */

    /* type: this can change (with some restrictions), but the actual
     * type of the new device connection isn't known until after we
     * allocate the "actual" device.
     */

    if (virMacAddrCmp(&olddev->mac, &newdev->mac)) {
        char oldmac[VIR_MAC_STRING_BUFLEN], newmac[VIR_MAC_STRING_BUFLEN];

1832
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
1833 1834 1835 1836 1837 1838 1839 1840
                       _("cannot change network interface mac address "
                         "from %s to %s"),
                       virMacAddrFormat(&olddev->mac, oldmac),
                       virMacAddrFormat(&newdev->mac, newmac));
        goto cleanup;
    }

    if (STRNEQ_NULLABLE(olddev->model, newdev->model)) {
1841
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
1842 1843 1844 1845
                       _("cannot modify network device model from %s to %s"),
                       olddev->model ? olddev->model : "(default)",
                       newdev->model ? newdev->model : "(default)");
        goto cleanup;
1846 1847
    }

1848 1849 1850 1851 1852
    if (olddev->model && STREQ(olddev->model, "virtio") &&
        (olddev->driver.virtio.name != newdev->driver.virtio.name ||
         olddev->driver.virtio.txmode != newdev->driver.virtio.txmode ||
         olddev->driver.virtio.ioeventfd != newdev->driver.virtio.ioeventfd ||
         olddev->driver.virtio.event_idx != newdev->driver.virtio.event_idx)) {
1853
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1854 1855 1856 1857 1858 1859 1860 1861 1862 1863
                       _("cannot modify virtio network device driver attributes"));
        goto cleanup;
    }

    /* data: this union will be examined later, after allocating new actualdev */
    /* virtPortProfile: will be examined later, after allocating new actualdev */

    if (olddev->tune.sndbuf_specified != newdev->tune.sndbuf_specified ||
        olddev->tune.sndbuf != newdev->tune.sndbuf) {
        needReconnect = true;
1864 1865
    }

1866
    if (STRNEQ_NULLABLE(olddev->script, newdev->script)) {
1867
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1868 1869
                       _("cannot modify network device script attribute"));
        goto cleanup;
1870 1871
    }

1872
    /* ifname: check if it's set in newdev. If not, retain the autogenerated one */
1873
    if (!newdev->ifname && VIR_STRDUP(newdev->ifname, olddev->ifname) < 0)
1874 1875
        goto cleanup;
    if (STRNEQ_NULLABLE(olddev->ifname, newdev->ifname)) {
1876
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1877 1878 1879
                       _("cannot modify network device tap name"));
        goto cleanup;
    }
1880

1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893
    /* info: if newdev->info is empty, fill it in from olddev,
     * otherwise verify that it matches - nothing is allowed to
     * change. (There is no helper function to do this, so
     * individually check the few feidls of virDomainDeviceInfo that
     * are relevant in this case).
     */
    if (!virDomainDeviceAddressIsValid(&newdev->info,
                                       VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI) &&
        virDomainDeviceInfoCopy(&newdev->info, &olddev->info) < 0) {
        goto cleanup;
    }
    if (!virDevicePCIAddressEqual(&olddev->info.addr.pci,
                                  &newdev->info.addr.pci)) {
1894
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1895 1896 1897 1898
                       _("cannot modify network device guest PCI address"));
        goto cleanup;
    }
    /* grab alias from olddev if not set in newdev */
1899 1900
    if (!newdev->info.alias &&
        VIR_STRDUP(newdev->info.alias, olddev->info.alias) < 0)
1901 1902
        goto cleanup;
    if (STRNEQ_NULLABLE(olddev->info.alias, newdev->info.alias)) {
1903
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1904 1905 1906 1907
                       _("cannot modify network device alias"));
        goto cleanup;
    }
    if (olddev->info.rombar != newdev->info.rombar) {
1908
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1909 1910 1911 1912
                       _("cannot modify network device rom bar setting"));
        goto cleanup;
    }
    if (STRNEQ_NULLABLE(olddev->info.romfile, newdev->info.romfile)) {
1913
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1914 1915 1916 1917
                       _("cannot modify network rom file"));
        goto cleanup;
    }
    if (olddev->info.bootIndex != newdev->info.bootIndex) {
1918
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
1919 1920 1921 1922
                       _("cannot modify network device boot index setting"));
        goto cleanup;
    }
    /* (end of device info checks) */
1923

1924 1925 1926 1927
    if (STRNEQ_NULLABLE(olddev->filter, newdev->filter) ||
        !virNWFilterHashTableEqual(olddev->filterparams, newdev->filterparams)) {
        needFilterChange = true;
    }
1928

1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944
    /* bandwidth can be modified, and will be checked later */
    /* vlan can be modified, and will be checked later */
    /* linkstate can be modified */

    /* allocate new actual device to compare to old - we will need to
     * free it if we fail for any reason
     */
    if (newdev->type == VIR_DOMAIN_NET_TYPE_NETWORK &&
        networkAllocateActualDevice(newdev) < 0) {
        goto cleanup;
    }

    newType = virDomainNetGetActualType(newdev);

    if (newType == VIR_DOMAIN_NET_TYPE_HOSTDEV) {
        /* can't turn it into a type='hostdev' interface */
1945
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
1946 1947 1948 1949 1950 1951
                       _("cannot change network interface type to '%s'"),
                       virDomainNetTypeToString(newType));
        goto cleanup;
    }

    if (olddev->type == newdev->type && oldType == newType) {
1952

1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964
        /* if type hasn't changed, check the relevant fields for the type */
        switch (newdev->type) {
        case VIR_DOMAIN_NET_TYPE_USER:
            break;

        case VIR_DOMAIN_NET_TYPE_ETHERNET:
            if (STRNEQ_NULLABLE(olddev->data.ethernet.dev,
                                newdev->data.ethernet.dev) ||
                STRNEQ_NULLABLE(olddev->data.ethernet.ipaddr,
                                newdev->data.ethernet.ipaddr)) {
                needReconnect = true;
            }
1965 1966
        break;

1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 1990 1991 1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002
        case VIR_DOMAIN_NET_TYPE_SERVER:
        case VIR_DOMAIN_NET_TYPE_CLIENT:
        case VIR_DOMAIN_NET_TYPE_MCAST:
            if (STRNEQ_NULLABLE(olddev->data.socket.address,
                                newdev->data.socket.address) ||
                olddev->data.socket.port != newdev->data.socket.port) {
                needReconnect = true;
            }
            break;

        case VIR_DOMAIN_NET_TYPE_NETWORK:
            if (STRNEQ(olddev->data.network.name, newdev->data.network.name)) {
                if (virDomainNetGetActualVirtPortProfile(newdev))
                    needReconnect = true;
                else
                    needBridgeChange = true;
            }
            /* other things handled in common code directly below this switch */
            break;

        case VIR_DOMAIN_NET_TYPE_BRIDGE:
            /* all handled in bridge name checked in common code below */
            break;

        case VIR_DOMAIN_NET_TYPE_INTERNAL:
            if (STRNEQ_NULLABLE(olddev->data.internal.name,
                                newdev->data.internal.name)) {
                needReconnect = true;
            }
            break;

        case VIR_DOMAIN_NET_TYPE_DIRECT:
            /* all handled in common code directly below this switch */
            break;

        default:
2003
            virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
2004 2005 2006
                           _("unable to change config on '%s' network type"),
                           virDomainNetTypeToString(newdev->type));
            break;
2007

2008
        }
2009 2010 2011 2012 2013 2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039
    } else {
        /* interface type has changed. There are a few special cases
         * where this can only require a minor (or even no) change,
         * but in most cases we need to do a full reconnection.
         *
         * If we switch (in either direction) between type='bridge'
         * and type='network' (for a traditional managed virtual
         * network that uses a host bridge, i.e. forward
         * mode='route|nat'), we just need to change the bridge.
         */
        if ((oldType == VIR_DOMAIN_NET_TYPE_NETWORK &&
             newType == VIR_DOMAIN_NET_TYPE_BRIDGE) ||
            (oldType == VIR_DOMAIN_NET_TYPE_BRIDGE &&
             newType == VIR_DOMAIN_NET_TYPE_NETWORK)) {

            needBridgeChange = true;

        } else if (oldType == VIR_DOMAIN_NET_TYPE_DIRECT &&
                   newType == VIR_DOMAIN_NET_TYPE_DIRECT) {

            /* this is the case of switching from type='direct' to
             * type='network' for a network that itself uses direct
             * (macvtap) devices. If the physical device and mode are
             * the same, this doesn't require any actual setup
             * change. If the physical device or mode *does* change,
             * that will be caught in the common section below */

        } else {

            /* for all other combinations, we'll need a full reconnect */
            needReconnect = true;
2040 2041

        }
2042
    }
2043

2044 2045 2046 2047 2048 2049 2050 2051 2052 2053 2054
    /* now several things that are in multiple (but not all)
     * different types, and can be safely compared even for those
     * cases where they don't apply to a particular type.
     */
    if (STRNEQ_NULLABLE(virDomainNetGetActualBridgeName(olddev),
                        virDomainNetGetActualBridgeName(newdev))) {
        if (virDomainNetGetActualVirtPortProfile(newdev))
            needReconnect = true;
        else
            needBridgeChange = true;
    }
2055

2056 2057 2058 2059 2060 2061 2062 2063 2064 2065
    if (STRNEQ_NULLABLE(virDomainNetGetActualDirectDev(olddev),
                        virDomainNetGetActualDirectDev(newdev)) ||
        virDomainNetGetActualDirectMode(olddev) != virDomainNetGetActualDirectMode(olddev) ||
        !virNetDevVPortProfileEqual(virDomainNetGetActualVirtPortProfile(olddev),
                                    virDomainNetGetActualVirtPortProfile(newdev)) ||
        !virNetDevBandwidthEqual(virDomainNetGetActualBandwidth(olddev),
                                 virDomainNetGetActualBandwidth(newdev)) ||
        !virNetDevVlanEqual(virDomainNetGetActualVlan(olddev),
                            virDomainNetGetActualVlan(newdev))) {
        needReconnect = true;
2066 2067
    }

2068 2069 2070 2071 2072 2073
    if (olddev->linkstate != newdev->linkstate)
        needLinkStateChange = true;

    /* FINALLY - actually perform the required actions */

    if (needReconnect) {
2074
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
2075 2076 2077
                       _("unable to change config on '%s' network type"),
                       virDomainNetTypeToString(newdev->type));
        goto cleanup;
2078 2079
    }

2080 2081 2082 2083 2084
    if (needBridgeChange) {
        if (qemuDomainChangeNetBridge(dom->conn, vm, olddev, newdev) < 0)
            goto cleanup;
        /* we successfully switched to the new bridge, and we've
         * determined that the rest of newdev is equivalent to olddev,
2085 2086 2087 2088 2089 2090 2091 2092 2093 2094
         * so move newdev into place */
        needReplaceDevDef = true;
    }

    if (needFilterChange) {
        if (qemuDomainChangeNetFilter(dom->conn, vm, olddev, newdev) < 0)
            goto cleanup;
        /* we successfully switched to the new filter, and we've
         * determined that the rest of newdev is equivalent to olddev,
         * so move newdev into place */
2095
        needReplaceDevDef = true;
2096 2097
    }

2098 2099 2100
    if (needLinkStateChange &&
        qemuDomainChangeNetLinkState(driver, vm, olddev, newdev->linkstate) < 0) {
        goto cleanup;
2101 2102
    }

2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115
    if (needReplaceDevDef) {
        /* the changes above warrant replacing olddev with newdev in
         * the domain's nets list.
         */
        networkReleaseActualDevice(olddev);
        virDomainNetDefFree(olddev);
        /* move newdev into the nets list, and NULL it out from the
         * virDomainDeviceDef that we were given so that the caller
         * won't delete it on return.
         */
        *devslot = newdev;
        newdev = dev->data.net = NULL;
        dev->type = VIR_DOMAIN_DEVICE_NONE;
2116 2117
    }

2118 2119 2120 2121 2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140
    ret = 0;
cleanup:
    /* When we get here, we will be in one of these two states:
     *
     * 1) newdev has been moved into the domain's list of nets and
     *    newdev set to NULL, and dev->data.net will be NULL (and
     *    dev->type is NONE). olddev will have been completely
     *    released and freed. (aka success) In this case no extra
     *    cleanup is needed.
     *
     * 2) newdev has *not* been moved into the domain's list of nets,
     *    and dev->data.net == newdev (and dev->type == NET). In this *
     *    case, we need to at least release the "actual device" from *
     *    newdev (the caller will free dev->data.net a.k.a. newdev, and
     *    the original olddev is still in used)
     *
     * Note that case (2) isn't necessarily a failure. It may just be
     * that the changes were minor enough that we didn't need to
     * replace the entire device object.
     */
    if (newdev)
        networkReleaseActualDevice(newdev);

2141 2142 2143 2144
    return ret;
}


2145 2146 2147 2148

static virDomainGraphicsDefPtr qemuDomainFindGraphics(virDomainObjPtr vm,
                                                      virDomainGraphicsDefPtr dev)
{
2149
    size_t i;
2150

2151
    for (i = 0; i < vm->def->ngraphics; i++) {
2152 2153 2154 2155 2156 2157 2158 2159 2160
        if (vm->def->graphics[i]->type == dev->type)
            return vm->def->graphics[i];
    }

    return NULL;
}


int
2161
qemuDomainChangeGraphics(virQEMUDriverPtr driver,
2162 2163 2164 2165 2166
                         virDomainObjPtr vm,
                         virDomainGraphicsDefPtr dev)
{
    virDomainGraphicsDefPtr olddev = qemuDomainFindGraphics(vm, dev);
    int ret = -1;
2167
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
2168
    size_t i;
2169 2170

    if (!olddev) {
2171 2172
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("cannot find existing graphics device to modify"));
2173
        goto cleanup;
2174 2175
    }

2176 2177 2178 2179 2180 2181 2182
    if (dev->nListens != olddev->nListens) {
        virReportError(VIR_ERR_INVALID_ARG, "%s",
                       _("cannot change the number of listen addresses"));
        goto cleanup;
    }

    for (i = 0; i < dev->nListens; i++) {
J
Jim Fehlig 已提交
2183
        virDomainGraphicsListenDefPtr newlisten = &dev->listens[i];
2184 2185
        virDomainGraphicsListenDefPtr oldlisten = &olddev->listens[i];

J
Jim Fehlig 已提交
2186
        if (newlisten->type != oldlisten->type) {
2187 2188 2189 2190 2191
            virReportError(VIR_ERR_INVALID_ARG, "%s",
                           _("cannot change the type of listen address"));
            goto cleanup;
        }

J
Jim Fehlig 已提交
2192
        switch ((enum virDomainGraphicsListenType) newlisten->type) {
2193
        case VIR_DOMAIN_GRAPHICS_LISTEN_TYPE_ADDRESS:
J
Jim Fehlig 已提交
2194
            if (STRNEQ_NULLABLE(newlisten->address, oldlisten->address)) {
2195 2196 2197 2198 2199 2200 2201 2202 2203
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               dev->type == VIR_DOMAIN_GRAPHICS_TYPE_VNC ?
                               _("cannot change listen address setting on vnc graphics") :
                               _("cannot change listen address setting on spice graphics"));
                goto cleanup;
            }
            break;

        case VIR_DOMAIN_GRAPHICS_LISTEN_TYPE_NETWORK:
J
Jim Fehlig 已提交
2204
            if (STRNEQ_NULLABLE(newlisten->network, oldlisten->network)) {
2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216 2217 2218
                virReportError(VIR_ERR_INVALID_ARG, "%s",
                               dev->type == VIR_DOMAIN_GRAPHICS_TYPE_VNC ?
                           _("cannot change listen network setting on vnc graphics") :
                           _("cannot change listen network setting on spice graphics"));
                goto cleanup;
            }
            break;

        case VIR_DOMAIN_GRAPHICS_LISTEN_TYPE_NONE:
        case VIR_DOMAIN_GRAPHICS_LISTEN_TYPE_LAST:
            /* nada */
            break;
        }
    }
2219

2220 2221 2222
    switch (dev->type) {
    case VIR_DOMAIN_GRAPHICS_TYPE_VNC:
        if ((olddev->data.vnc.autoport != dev->data.vnc.autoport) ||
E
Eric Blake 已提交
2223 2224
            (!dev->data.vnc.autoport &&
             (olddev->data.vnc.port != dev->data.vnc.port))) {
2225 2226
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("cannot change port settings on vnc graphics"));
2227
            goto cleanup;
2228 2229
        }
        if (STRNEQ_NULLABLE(olddev->data.vnc.keymap, dev->data.vnc.keymap)) {
2230 2231
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("cannot change keymap setting on vnc graphics"));
2232
            goto cleanup;
2233 2234
        }

2235 2236 2237
        /* If a password lifetime was, or is set, or action if connected has
         * changed, then we must always run, even if new password matches
         * old password */
2238 2239
        if (olddev->data.vnc.auth.expires ||
            dev->data.vnc.auth.expires ||
2240
            olddev->data.vnc.auth.connected != dev->data.vnc.auth.connected ||
E
Eric Blake 已提交
2241 2242 2243
            STRNEQ_NULLABLE(olddev->data.vnc.auth.passwd,
                            dev->data.vnc.auth.passwd)) {
            VIR_DEBUG("Updating password on VNC server %p %p",
2244
                      dev->data.vnc.auth.passwd, cfg->vncPassword);
E
Eric Blake 已提交
2245 2246 2247
            ret = qemuDomainChangeGraphicsPasswords(driver, vm,
                                                    VIR_DOMAIN_GRAPHICS_TYPE_VNC,
                                                    &dev->data.vnc.auth,
2248
                                                    cfg->vncPassword);
2249
            if (ret < 0)
2250
                goto cleanup;
2251 2252 2253 2254 2255

            /* Steal the new dev's  char * reference */
            VIR_FREE(olddev->data.vnc.auth.passwd);
            olddev->data.vnc.auth.passwd = dev->data.vnc.auth.passwd;
            dev->data.vnc.auth.passwd = NULL;
2256 2257
            olddev->data.vnc.auth.validTo = dev->data.vnc.auth.validTo;
            olddev->data.vnc.auth.expires = dev->data.vnc.auth.expires;
2258
            olddev->data.vnc.auth.connected = dev->data.vnc.auth.connected;
2259 2260 2261 2262 2263
        } else {
            ret = 0;
        }
        break;

2264 2265
    case VIR_DOMAIN_GRAPHICS_TYPE_SPICE:
        if ((olddev->data.spice.autoport != dev->data.spice.autoport) ||
E
Eric Blake 已提交
2266 2267 2268 2269
            (!dev->data.spice.autoport &&
             (olddev->data.spice.port != dev->data.spice.port)) ||
            (!dev->data.spice.autoport &&
             (olddev->data.spice.tlsPort != dev->data.spice.tlsPort))) {
2270 2271
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("cannot change port settings on spice graphics"));
2272
            goto cleanup;
2273
        }
E
Eric Blake 已提交
2274 2275
        if (STRNEQ_NULLABLE(olddev->data.spice.keymap,
                            dev->data.spice.keymap)) {
2276
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
2277
                            _("cannot change keymap setting on spice graphics"));
2278
            goto cleanup;
2279 2280
        }

2281 2282 2283 2284 2285
        /* We must reset the password if it has changed but also if:
         * - password lifetime is or was set
         * - the requested action has changed
         * - the action is "disconnect"
         */
2286 2287
        if (olddev->data.spice.auth.expires ||
            dev->data.spice.auth.expires ||
2288
            olddev->data.spice.auth.connected != dev->data.spice.auth.connected ||
2289 2290
            dev->data.spice.auth.connected ==
            VIR_DOMAIN_GRAPHICS_AUTH_CONNECTED_DISCONNECT ||
E
Eric Blake 已提交
2291 2292 2293
            STRNEQ_NULLABLE(olddev->data.spice.auth.passwd,
                            dev->data.spice.auth.passwd)) {
            VIR_DEBUG("Updating password on SPICE server %p %p",
2294
                      dev->data.spice.auth.passwd, cfg->spicePassword);
E
Eric Blake 已提交
2295 2296 2297
            ret = qemuDomainChangeGraphicsPasswords(driver, vm,
                                                    VIR_DOMAIN_GRAPHICS_TYPE_SPICE,
                                                    &dev->data.spice.auth,
2298
                                                    cfg->spicePassword);
E
Eric Blake 已提交
2299

2300
            if (ret < 0)
2301
                goto cleanup;
2302

E
Eric Blake 已提交
2303
            /* Steal the new dev's char * reference */
2304 2305 2306 2307 2308
            VIR_FREE(olddev->data.spice.auth.passwd);
            olddev->data.spice.auth.passwd = dev->data.spice.auth.passwd;
            dev->data.spice.auth.passwd = NULL;
            olddev->data.spice.auth.validTo = dev->data.spice.auth.validTo;
            olddev->data.spice.auth.expires = dev->data.spice.auth.expires;
2309
            olddev->data.spice.auth.connected = dev->data.spice.auth.connected;
2310
        } else {
2311
            VIR_DEBUG("Not updating since password didn't change");
2312 2313
            ret = 0;
        }
E
Eric Blake 已提交
2314
        break;
2315

2316
    default:
2317 2318 2319
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unable to change config on '%s' graphics type"),
                       virDomainGraphicsTypeToString(dev->type));
2320 2321 2322
        break;
    }

2323 2324
cleanup:
    virObjectUnref(cfg);
2325 2326 2327 2328
    return ret;
}


2329
static int qemuComparePCIDevice(virDomainDefPtr def ATTRIBUTE_UNUSED,
2330
                                virDomainDeviceDefPtr device ATTRIBUTE_UNUSED,
2331
                                virDomainDeviceInfoPtr info1,
2332 2333
                                void *opaque)
{
2334
    virDomainDeviceInfoPtr info2 = opaque;
2335

2336 2337
    if (info1->type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI ||
        info2->type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI)
2338 2339
        return 0;

2340 2341 2342
    if (info1->addr.pci.domain == info2->addr.pci.domain &&
        info1->addr.pci.bus == info2->addr.pci.bus &&
        info1->addr.pci.slot == info2->addr.pci.slot &&
2343
        info1->addr.pci.function != info2->addr.pci.function)
2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355
        return -1;
    return 0;
}

static bool qemuIsMultiFunctionDevice(virDomainDefPtr def,
                                      virDomainDeviceInfoPtr dev)
{
    if (virDomainDeviceInfoIterate(def, qemuComparePCIDevice, dev) < 0)
        return true;
    return false;
}

2356

2357 2358 2359 2360 2361 2362
static void
qemuDomainRemoveDiskDevice(virQEMUDriverPtr driver,
                           virDomainObjPtr vm,
                           virDomainDiskDefPtr disk)
{
    virDomainDeviceDef dev;
2363
    virDomainEventPtr event;
2364 2365 2366 2367 2368 2369 2370
    size_t i;

    VIR_DEBUG("Removing disk %s from domain %p %s",
              disk->info.alias, vm, vm->def->name);

    virDomainAuditDisk(vm, disk->src, NULL, "detach", true);

2371 2372 2373 2374
    event = virDomainEventDeviceRemovedNewFromObj(vm, disk->info.alias);
    if (event)
        qemuDomainEventQueue(driver, event);

2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401
    for (i = 0; i < vm->def->ndisks; i++) {
        if (vm->def->disks[i] == disk) {
            virDomainDiskRemove(vm->def, i);
            break;
        }
    }

    qemuDomainReleaseDeviceAddress(vm, &disk->info, disk->src);

    if (virSecurityManagerRestoreImageLabel(driver->securityManager,
                                            vm->def, disk) < 0)
        VIR_WARN("Unable to restore security label on %s", disk->src);

    if (qemuTeardownDiskCgroup(vm, disk) < 0)
        VIR_WARN("Failed to tear down cgroup for disk path %s", disk->src);

    if (virDomainLockDiskDetach(driver->lockManager, vm, disk) < 0)
        VIR_WARN("Unable to release lock on %s", disk->src);

    dev.type = VIR_DOMAIN_DEVICE_DISK;
    dev.data.disk = disk;
    ignore_value(qemuRemoveSharedDevice(driver, &dev, vm->def->name));

    virDomainDiskDefFree(disk);
}


2402
static void
2403
qemuDomainRemoveControllerDevice(virQEMUDriverPtr driver,
2404 2405 2406
                                 virDomainObjPtr vm,
                                 virDomainControllerDefPtr controller)
{
2407
    virDomainEventPtr event;
2408 2409 2410 2411 2412
    size_t i;

    VIR_DEBUG("Removing controller %s from domain %p %s",
              controller->info.alias, vm, vm->def->name);

2413 2414 2415 2416
    event = virDomainEventDeviceRemovedNewFromObj(vm, controller->info.alias);
    if (event)
        qemuDomainEventQueue(driver, event);

2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428
    for (i = 0; i < vm->def->ncontrollers; i++) {
        if (vm->def->controllers[i] == controller) {
            virDomainControllerRemove(vm->def, i);
            break;
        }
    }

    qemuDomainReleaseDeviceAddress(vm, &controller->info, NULL);
    virDomainControllerDefFree(controller);
}


2429 2430 2431 2432 2433 2434 2435
static void
qemuDomainRemoveNetDevice(virQEMUDriverPtr driver,
                          virDomainObjPtr vm,
                          virDomainNetDefPtr net)
{
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
    virNetDevVPortProfilePtr vport;
2436
    virDomainEventPtr event;
2437 2438 2439 2440 2441 2442 2443
    size_t i;

    VIR_DEBUG("Removing network interface %s from domain %p %s",
              net->info.alias, vm, vm->def->name);

    virDomainAuditNet(vm, net, NULL, "detach", true);

2444 2445 2446 2447
    event = virDomainEventDeviceRemovedNewFromObj(vm, net->info.alias);
    if (event)
        qemuDomainEventQueue(driver, event);

2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476 2477 2478 2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489
    for (i = 0; i < vm->def->nnets; i++) {
        if (vm->def->nets[i] == net) {
            virDomainNetRemove(vm->def, i);
            break;
        }
    }

    qemuDomainReleaseDeviceAddress(vm, &net->info, NULL);
    virDomainConfNWFilterTeardown(net);

    if (virDomainNetGetActualType(net) == VIR_DOMAIN_NET_TYPE_DIRECT) {
        ignore_value(virNetDevMacVLanDeleteWithVPortProfile(
                         net->ifname, &net->mac,
                         virDomainNetGetActualDirectDev(net),
                         virDomainNetGetActualDirectMode(net),
                         virDomainNetGetActualVirtPortProfile(net),
                         cfg->stateDir));
        VIR_FREE(net->ifname);
    }

    if (cfg->macFilter && (net->ifname != NULL)) {
        if ((errno = networkDisallowMacOnPort(driver,
                                              net->ifname,
                                              &net->mac))) {
            virReportSystemError(errno,
             _("failed to remove ebtables rule on '%s'"),
                                 net->ifname);
        }
    }

    vport = virDomainNetGetActualVirtPortProfile(net);
    if (vport && vport->virtPortType == VIR_NETDEV_VPORT_PROFILE_OPENVSWITCH)
        ignore_value(virNetDevOpenvswitchRemovePort(
                        virDomainNetGetActualBridgeName(net),
                        net->ifname));

    networkReleaseActualDevice(net);
    virDomainNetDefFree(net);
    virObjectUnref(cfg);
}


2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563
static void
qemuDomainRemovePCIHostDevice(virQEMUDriverPtr driver,
                              virDomainObjPtr vm,
                              virDomainHostdevDefPtr hostdev)
{
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
    virDomainHostdevSubsysPtr subsys = &hostdev->source.subsys;
    virPCIDevicePtr pci;
    virPCIDevicePtr activePci;

    /*
     * For SRIOV net host devices, unset mac and port profile before
     * reset and reattach device
     */
    if (hostdev->parent.data.net)
        qemuDomainHostdevNetConfigRestore(hostdev, cfg->stateDir);

    virObjectLock(driver->activePciHostdevs);
    virObjectLock(driver->inactivePciHostdevs);
    pci = virPCIDeviceNew(subsys->u.pci.addr.domain, subsys->u.pci.addr.bus,
                          subsys->u.pci.addr.slot, subsys->u.pci.addr.function);
    if (pci) {
        activePci = virPCIDeviceListSteal(driver->activePciHostdevs, pci);
        if (activePci &&
            virPCIDeviceReset(activePci, driver->activePciHostdevs,
                              driver->inactivePciHostdevs) == 0) {
            qemuReattachPciDevice(activePci, driver);
        } else {
            /* reset of the device failed, treat it as if it was returned */
            virPCIDeviceFree(activePci);
        }
        virPCIDeviceFree(pci);
    }
    virObjectUnlock(driver->activePciHostdevs);
    virObjectUnlock(driver->inactivePciHostdevs);

    qemuDomainReleaseDeviceAddress(vm, hostdev->info, NULL);
    virObjectUnref(cfg);
}

static void
qemuDomainRemoveUSBHostDevice(virQEMUDriverPtr driver,
                              virDomainObjPtr vm ATTRIBUTE_UNUSED,
                              virDomainHostdevDefPtr hostdev)
{
    virDomainHostdevSubsysPtr subsys = &hostdev->source.subsys;
    virUSBDevicePtr usb;

    usb = virUSBDeviceNew(subsys->u.usb.bus, subsys->u.usb.device, NULL);
    if (usb) {
        virObjectLock(driver->activeUsbHostdevs);
        virUSBDeviceListDel(driver->activeUsbHostdevs, usb);
        virObjectUnlock(driver->activeUsbHostdevs);
        virUSBDeviceFree(usb);
    } else {
        VIR_WARN("Unable to find device %03d.%03d in list of used USB devices",
                 subsys->u.usb.bus, subsys->u.usb.device);
    }
}

static void
qemuDomainRemoveSCSIHostDevice(virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
                               virDomainHostdevDefPtr hostdev)
{
    qemuDomainReAttachHostScsiDevices(driver, vm->def->name, &hostdev, 1);
}

static void
qemuDomainRemoveHostDevice(virQEMUDriverPtr driver,
                           virDomainObjPtr vm,
                           virDomainHostdevDefPtr hostdev)
{
    virDomainNetDefPtr net = NULL;
2564
    virDomainEventPtr event;
2565 2566 2567 2568 2569
    size_t i;

    VIR_DEBUG("Removing host device %s from domain %p %s",
              hostdev->info->alias, vm, vm->def->name);

2570 2571 2572 2573
    event = virDomainEventDeviceRemovedNewFromObj(vm, hostdev->info->alias);
    if (event)
        qemuDomainEventQueue(driver, event);

2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624
    if (hostdev->parent.type == VIR_DOMAIN_DEVICE_NET) {
        net = hostdev->parent.data.net;

        for (i = 0; i < vm->def->nnets; i++) {
            if (vm->def->nets[i] == net) {
                virDomainNetRemove(vm->def, i);
                break;
            }
        }
    }

    for (i = 0; i < vm->def->nhostdevs; i++) {
        if (vm->def->hostdevs[i] == hostdev) {
            virDomainHostdevRemove(vm->def, i);
            break;
        }
    }

    virDomainAuditHostdev(vm, hostdev, "detach", true);

    switch ((enum virDomainHostdevSubsysType) hostdev->source.subsys.type) {
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI:
        qemuDomainRemovePCIHostDevice(driver, vm, hostdev);
        break;
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB:
        qemuDomainRemoveUSBHostDevice(driver, vm, hostdev);
        break;
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_SCSI:
        qemuDomainRemoveSCSIHostDevice(driver, vm, hostdev);
        break;
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_LAST:
        break;
    }

    if (qemuTeardownHostdevCgroup(vm, hostdev) < 0)
        VIR_WARN("Failed to remove host device cgroup ACL");

    if (virSecurityManagerRestoreHostdevLabel(driver->securityManager,
                                              vm->def, hostdev, NULL) < 0) {
        VIR_WARN("Failed to restore host device labelling");
    }

    virDomainHostdevDefFree(hostdev);

    if (net) {
        networkReleaseActualDevice(net);
        virDomainNetDefFree(net);
    }
}


2625
static void
2626
qemuDomainRemoveChrDevice(virQEMUDriverPtr driver,
2627 2628 2629
                          virDomainObjPtr vm,
                          virDomainChrDefPtr chr)
{
2630 2631
    virDomainEventPtr event;

2632 2633 2634
    VIR_DEBUG("Removing character device %s from domain %p %s",
              chr->info.alias, vm, vm->def->name);

2635 2636 2637 2638
    event = virDomainEventDeviceRemovedNewFromObj(vm, chr->info.alias);
    if (event)
        qemuDomainEventQueue(driver, event);

2639 2640 2641 2642 2643
    qemuDomainChrRemove(vm->def, chr);
    virDomainChrDefFree(chr);
}


2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725
void
qemuDomainRemoveDevice(virQEMUDriverPtr driver,
                       virDomainObjPtr vm,
                       virDomainDeviceDefPtr dev)
{
    switch ((virDomainDeviceType) dev->type) {
    case VIR_DOMAIN_DEVICE_DISK:
        qemuDomainRemoveDiskDevice(driver, vm, dev->data.disk);
        break;
    case VIR_DOMAIN_DEVICE_CONTROLLER:
        qemuDomainRemoveControllerDevice(driver, vm, dev->data.controller);
        break;
    case VIR_DOMAIN_DEVICE_NET:
        qemuDomainRemoveNetDevice(driver, vm, dev->data.net);
        break;
    case VIR_DOMAIN_DEVICE_HOSTDEV:
        qemuDomainRemoveHostDevice(driver, vm, dev->data.hostdev);
        break;

    case VIR_DOMAIN_DEVICE_CHR:
        qemuDomainRemoveChrDevice(driver, vm, dev->data.chr);
        break;

    case VIR_DOMAIN_DEVICE_NONE:
    case VIR_DOMAIN_DEVICE_LEASE:
    case VIR_DOMAIN_DEVICE_FS:
    case VIR_DOMAIN_DEVICE_INPUT:
    case VIR_DOMAIN_DEVICE_SOUND:
    case VIR_DOMAIN_DEVICE_VIDEO:
    case VIR_DOMAIN_DEVICE_WATCHDOG:
    case VIR_DOMAIN_DEVICE_GRAPHICS:
    case VIR_DOMAIN_DEVICE_HUB:
    case VIR_DOMAIN_DEVICE_REDIRDEV:
    case VIR_DOMAIN_DEVICE_SMARTCARD:
    case VIR_DOMAIN_DEVICE_MEMBALLOON:
    case VIR_DOMAIN_DEVICE_NVRAM:
    case VIR_DOMAIN_DEVICE_RNG:
    case VIR_DOMAIN_DEVICE_LAST:
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
                       _("don't know how to remove a %s device"),
                       virDomainDeviceTypeToString(dev->type));
        break;
    }
}


static void
qemuDomainMarkDeviceForRemoval(virDomainObjPtr vm,
                               virDomainDeviceInfoPtr info)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;

    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE_DEL_EVENT))
        priv->unpluggingDevice = info->alias;
    else
        priv->unpluggingDevice = NULL;
}

static void
qemuDomainResetDeviceRemoval(virDomainObjPtr vm)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
    priv->unpluggingDevice = NULL;
}

/* Returns:
 *  -1 on error
 *   0 when DEVICE_DELETED event is unsupported
 *   1 when device removal finished
 *   2 device removal did not finish in QEMU_REMOVAL_WAIT_TIME
 */
static int
qemuDomainWaitForDeviceRemoval(virDomainObjPtr vm)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
    unsigned long long until;

    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE_DEL_EVENT))
        return 0;

    if (virTimeMillisNow(&until) < 0)
        return -1;
2726
    until += qemuDomainRemoveDeviceWaitTime;
2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756

    while (priv->unpluggingDevice) {
        if (virCondWaitUntil(&priv->unplugFinished,
                             &vm->parent.lock, until) < 0) {
            if (errno == ETIMEDOUT) {
                return 2;
            } else {
                virReportSystemError(errno, "%s",
                                     _("Unable to wait on unplug condition"));
                return -1;
            }
        }
    }

    return 1;
}

void
qemuDomainSignalDeviceRemoval(virDomainObjPtr vm,
                              const char *devAlias)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;

    if (STREQ_NULLABLE(priv->unpluggingDevice, devAlias)) {
        qemuDomainResetDeviceRemoval(vm);
        virCondSignal(&priv->unplugFinished);
    }
}


2757 2758 2759 2760
static int
qemuDomainDetachVirtioDiskDevice(virQEMUDriverPtr driver,
                                 virDomainObjPtr vm,
                                 virDomainDiskDefPtr detach)
2761
{
2762
    int ret = -1;
2763 2764 2765
    qemuDomainObjPrivatePtr priv = vm->privateData;
    char *drivestr = NULL;

2766
    if (qemuIsMultiFunctionDevice(vm->def, &detach->info)) {
2767 2768
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("cannot hot unplug multifunction PCI device: %s"),
2769
                       detach->dst);
2770 2771 2772
        goto cleanup;
    }

2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787
    if (STREQLEN(vm->def->os.machine, "s390-ccw", 8) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_CCW)) {
        if (!virDomainDeviceAddressIsValid(&detach->info,
                                           VIR_DOMAIN_DEVICE_ADDRESS_TYPE_CCW)) {
            virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                           _("device cannot be detached without a valid CCW address"));
            goto cleanup;
        }
    } else {
        if (!virDomainDeviceAddressIsValid(&detach->info,
                                           VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI)) {
            virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                           _("device cannot be detached without a valid PCI address"));
            goto cleanup;
        }
2788 2789 2790 2791 2792
    }

    /* build the actual drive id string as the disk->info.alias doesn't
     * contain the QEMU_DRIVE_HOST_PREFIX that is passed to qemu */
    if (virAsprintf(&drivestr, "%s%s",
2793
                    QEMU_DRIVE_HOST_PREFIX, detach->info.alias) < 0)
2794 2795
        goto cleanup;

2796 2797
    qemuDomainMarkDeviceForRemoval(vm, &detach->info);

2798
    qemuDomainObjEnterMonitor(driver, vm);
2799
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
2800
        if (qemuMonitorDelDevice(priv->mon, detach->info.alias) < 0) {
2801
            qemuDomainObjExitMonitor(driver, vm);
2802
            virDomainAuditDisk(vm, detach->src, NULL, "detach", false);
2803 2804 2805 2806 2807
            goto cleanup;
        }
    } else {
        if (qemuMonitorRemovePCIDevice(priv->mon,
                                       &detach->info.addr.pci) < 0) {
2808
            qemuDomainObjExitMonitor(driver, vm);
2809
            virDomainAuditDisk(vm, detach->src, NULL, "detach", false);
2810 2811 2812 2813 2814 2815 2816
            goto cleanup;
        }
    }

    /* disconnect guest from host device */
    qemuMonitorDriveDel(priv->mon, drivestr);

2817
    qemuDomainObjExitMonitor(driver, vm);
2818

2819 2820
    if (!qemuDomainWaitForDeviceRemoval(vm))
        qemuDomainRemoveDiskDevice(driver, vm, detach);
2821 2822 2823
    ret = 0;

cleanup:
2824
    qemuDomainResetDeviceRemoval(vm);
2825 2826 2827 2828
    VIR_FREE(drivestr);
    return ret;
}

2829 2830 2831 2832
static int
qemuDomainDetachDiskDevice(virQEMUDriverPtr driver,
                           virDomainObjPtr vm,
                           virDomainDiskDefPtr detach)
2833
{
2834
    int ret = -1;
2835 2836 2837
    qemuDomainObjPrivatePtr priv = vm->privateData;
    char *drivestr = NULL;

2838
    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
2839 2840
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("Underlying qemu does not support %s disk removal"),
2841
                       virDomainDiskBusTypeToString(detach->bus));
2842 2843 2844
        goto cleanup;
    }

E
Eric Blake 已提交
2845 2846 2847 2848 2849 2850 2851
    if (detach->mirror) {
        virReportError(VIR_ERR_BLOCK_COPY_ACTIVE,
                       _("disk '%s' is in an active block copy job"),
                       detach->dst);
        goto cleanup;
    }

2852 2853 2854
    /* build the actual drive id string as the disk->info.alias doesn't
     * contain the QEMU_DRIVE_HOST_PREFIX that is passed to qemu */
    if (virAsprintf(&drivestr, "%s%s",
2855
                    QEMU_DRIVE_HOST_PREFIX, detach->info.alias) < 0)
2856 2857
        goto cleanup;

2858 2859
    qemuDomainMarkDeviceForRemoval(vm, &detach->info);

2860
    qemuDomainObjEnterMonitor(driver, vm);
2861
    if (qemuMonitorDelDevice(priv->mon, detach->info.alias) < 0) {
2862
        qemuDomainObjExitMonitor(driver, vm);
2863
        virDomainAuditDisk(vm, detach->src, NULL, "detach", false);
2864 2865 2866 2867 2868 2869
        goto cleanup;
    }

    /* disconnect guest from host device */
    qemuMonitorDriveDel(priv->mon, drivestr);

2870
    qemuDomainObjExitMonitor(driver, vm);
2871

2872 2873
    if (!qemuDomainWaitForDeviceRemoval(vm))
        qemuDomainRemoveDiskDevice(driver, vm, detach);
2874 2875 2876
    ret = 0;

cleanup:
2877
    qemuDomainResetDeviceRemoval(vm);
2878 2879 2880 2881
    VIR_FREE(drivestr);
    return ret;
}

2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934
static int
qemuFindDisk(virDomainDefPtr def, const char *dst)
{
    size_t i;

    for (i = 0; i < def->ndisks; i++) {
        if (STREQ(def->disks[i]->dst, dst)) {
            return i;
        }
    }

    return -1;
}

int
qemuDomainDetachDeviceDiskLive(virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
                               virDomainDeviceDefPtr dev)
{
    virDomainDiskDefPtr disk;
    int ret = -1;
    int idx;

    if ((idx = qemuFindDisk(vm->def, dev->data.disk->dst)) < 0) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("disk %s not found"), dev->data.disk->dst);
        return -1;
    }
    disk = vm->def->disks[idx];

    switch (disk->device) {
    case VIR_DOMAIN_DISK_DEVICE_DISK:
    case VIR_DOMAIN_DISK_DEVICE_LUN:
        if (disk->bus == VIR_DOMAIN_DISK_BUS_VIRTIO)
            ret = qemuDomainDetachVirtioDiskDevice(driver, vm, disk);
        else if (disk->bus == VIR_DOMAIN_DISK_BUS_SCSI ||
                 disk->bus == VIR_DOMAIN_DISK_BUS_USB)
            ret = qemuDomainDetachDiskDevice(driver, vm, disk);
        else
            virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
                           _("This type of disk cannot be hot unplugged"));
        break;
    default:
        virReportError(VIR_ERR_OPERATION_UNSUPPORTED,
                       _("disk device type '%s' cannot be detached"),
                       virDomainDiskDeviceTypeToString(disk->device));
        break;
    }

    return ret;
}


2935 2936 2937
static bool qemuDomainDiskControllerIsBusy(virDomainObjPtr vm,
                                           virDomainControllerDefPtr detach)
{
2938
    size_t i;
2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984
    virDomainDiskDefPtr disk;

    for (i = 0; i < vm->def->ndisks; i++) {
        disk = vm->def->disks[i];
        if (disk->info.type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_DRIVE)
            /* the disk does not use disk controller */
            continue;

        /* check whether the disk uses this type controller */
        if (disk->bus == VIR_DOMAIN_DISK_BUS_IDE &&
            detach->type != VIR_DOMAIN_CONTROLLER_TYPE_IDE)
            continue;
        if (disk->bus == VIR_DOMAIN_DISK_BUS_FDC &&
            detach->type != VIR_DOMAIN_CONTROLLER_TYPE_FDC)
            continue;
        if (disk->bus == VIR_DOMAIN_DISK_BUS_SCSI &&
            detach->type != VIR_DOMAIN_CONTROLLER_TYPE_SCSI)
            continue;

        if (disk->info.addr.drive.controller == detach->idx)
            return true;
    }

    return false;
}

static bool qemuDomainControllerIsBusy(virDomainObjPtr vm,
                                       virDomainControllerDefPtr detach)
{
    switch (detach->type) {
    case VIR_DOMAIN_CONTROLLER_TYPE_IDE:
    case VIR_DOMAIN_CONTROLLER_TYPE_FDC:
    case VIR_DOMAIN_CONTROLLER_TYPE_SCSI:
        return qemuDomainDiskControllerIsBusy(vm, detach);

    case VIR_DOMAIN_CONTROLLER_TYPE_SATA:
    case VIR_DOMAIN_CONTROLLER_TYPE_VIRTIO_SERIAL:
    case VIR_DOMAIN_CONTROLLER_TYPE_CCID:
    default:
        /* libvirt does not support sata controller, and does not support to
         * detach virtio and smart card controller.
         */
        return true;
    }
}

2985
int qemuDomainDetachPciControllerDevice(virQEMUDriverPtr driver,
2986
                                        virDomainObjPtr vm,
2987
                                        virDomainDeviceDefPtr dev)
2988
{
2989
    int idx, ret = -1;
2990 2991 2992
    virDomainControllerDefPtr detach = NULL;
    qemuDomainObjPrivatePtr priv = vm->privateData;

2993 2994 2995
    if ((idx = virDomainControllerFind(vm->def,
                                       dev->data.controller->type,
                                       dev->data.controller->idx)) < 0) {
2996
        virReportError(VIR_ERR_OPERATION_FAILED,
2997
                       _("controller %s:%d not found"),
2998 2999
                       virDomainControllerTypeToString(dev->data.controller->type),
                       dev->data.controller->idx);
3000 3001 3002
        goto cleanup;
    }

3003 3004
    detach = vm->def->controllers[idx];

3005 3006
    if (!virDomainDeviceAddressIsValid(&detach->info,
                                       VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI)) {
3007 3008
        virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                       _("device cannot be detached without a PCI address"));
3009 3010 3011
        goto cleanup;
    }

3012
    if (qemuIsMultiFunctionDevice(vm->def, &detach->info)) {
3013 3014 3015
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("cannot hot unplug multifunction PCI device: %s"),
                       dev->data.disk->dst);
3016 3017 3018
        goto cleanup;
    }

3019
    if (qemuDomainControllerIsBusy(vm, detach)) {
3020 3021
        virReportError(VIR_ERR_OPERATION_FAILED, "%s",
                       _("device cannot be detached: device is busy"));
3022 3023 3024
        goto cleanup;
    }

3025
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3026 3027 3028 3029
        if (qemuAssignDeviceControllerAlias(detach) < 0)
            goto cleanup;
    }

3030 3031
    qemuDomainMarkDeviceForRemoval(vm, &detach->info);

3032
    qemuDomainObjEnterMonitor(driver, vm);
3033
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3034
        if (qemuMonitorDelDevice(priv->mon, detach->info.alias)) {
3035
            qemuDomainObjExitMonitor(driver, vm);
3036 3037 3038 3039 3040
            goto cleanup;
        }
    } else {
        if (qemuMonitorRemovePCIDevice(priv->mon,
                                       &detach->info.addr.pci) < 0) {
3041
            qemuDomainObjExitMonitor(driver, vm);
3042 3043 3044
            goto cleanup;
        }
    }
3045
    qemuDomainObjExitMonitor(driver, vm);
3046

3047 3048
    if (!qemuDomainWaitForDeviceRemoval(vm))
        qemuDomainRemoveControllerDevice(driver, vm, detach);
3049 3050 3051 3052

    ret = 0;

cleanup:
3053
    qemuDomainResetDeviceRemoval(vm);
3054 3055 3056
    return ret;
}

3057
static int
3058
qemuDomainDetachHostPciDevice(virQEMUDriverPtr driver,
3059
                              virDomainObjPtr vm,
3060
                              virDomainHostdevDefPtr detach)
3061 3062
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
3063
    virDomainHostdevSubsysPtr subsys = &detach->source.subsys;
3064
    int ret;
3065

3066
    if (qemuIsMultiFunctionDevice(vm->def, detach->info)) {
3067 3068
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("cannot hot unplug multifunction PCI device: %.4x:%.2x:%.2x.%.1x"),
3069 3070
                       subsys->u.pci.addr.domain, subsys->u.pci.addr.bus,
                       subsys->u.pci.addr.slot, subsys->u.pci.addr.function);
3071
        return -1;
3072 3073
    }

3074
    if (!virDomainDeviceAddressIsValid(detach->info,
3075
                                       VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI)) {
3076 3077
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("device cannot be detached without a PCI address"));
3078
        return -1;
3079 3080
    }

3081 3082
    qemuDomainMarkDeviceForRemoval(vm, detach->info);

3083
    qemuDomainObjEnterMonitor(driver, vm);
3084
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3085
        ret = qemuMonitorDelDevice(priv->mon, detach->info->alias);
3086
    } else {
3087
        ret = qemuMonitorRemovePCIDevice(priv->mon, &detach->info->addr.pci);
3088
    }
3089
    qemuDomainObjExitMonitor(driver, vm);
3090 3091 3092 3093

    return ret;
}

3094
static int
3095
qemuDomainDetachHostUsbDevice(virQEMUDriverPtr driver,
3096
                              virDomainObjPtr vm,
3097
                              virDomainHostdevDefPtr detach)
3098 3099
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
3100
    int ret;
3101

3102
    if (!detach->info->alias) {
3103 3104
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("device cannot be detached without a device alias"));
3105 3106 3107
        return -1;
    }

3108
    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3109 3110
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("device cannot be detached with this QEMU version"));
3111 3112 3113
        return -1;
    }

3114 3115
    qemuDomainMarkDeviceForRemoval(vm, detach->info);

3116
    qemuDomainObjEnterMonitor(driver, vm);
3117
    ret = qemuMonitorDelDevice(priv->mon, detach->info->alias);
3118
    qemuDomainObjExitMonitor(driver, vm);
3119 3120 3121 3122

    return ret;
}

3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143 3144
static int
qemuDomainDetachHostScsiDevice(virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
                               virDomainHostdevDefPtr detach)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
    char *drvstr = NULL;
    char *devstr = NULL;
    int ret = -1;

    if (!detach->info->alias) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("device cannot be detached without a device alias"));
        return -1;
    }

    if (!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("device cannot be detached with this QEMU version"));
        return -1;
    }

3145 3146
    if (!(drvstr = qemuBuildSCSIHostdevDrvStr(detach, priv->qemuCaps,
                                              &buildCommandLineCallbacks)))
3147 3148 3149 3150
        goto cleanup;
    if (!(devstr = qemuBuildSCSIHostdevDevStr(vm->def, detach, priv->qemuCaps)))
        goto cleanup;

3151 3152
    qemuDomainMarkDeviceForRemoval(vm, detach->info);

3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 3170 3171 3172 3173 3174 3175 3176 3177
    qemuDomainObjEnterMonitor(driver, vm);
    if ((ret = qemuMonitorDelDevice(priv->mon, detach->info->alias)) == 0) {
        if ((ret = qemuMonitorDriveDel(priv->mon, drvstr)) < 0) {
            virErrorPtr orig_err = virSaveLastError();
            if (qemuMonitorAddDevice(priv->mon, devstr) < 0)
                VIR_WARN("Unable to add device %s (%s) after failed "
                         "qemuMonitorDriveDel",
                         drvstr, devstr);
            if (orig_err) {
                virSetError(orig_err);
                virFreeError(orig_err);
            }
        }
    }
    qemuDomainObjExitMonitor(driver, vm);

cleanup:
    VIR_FREE(drvstr);
    VIR_FREE(devstr);
    return ret;
}

static int
qemuDomainDetachThisHostDevice(virQEMUDriverPtr driver,
                               virDomainObjPtr vm,
3178
                               virDomainHostdevDefPtr detach)
3179
{
3180
    int ret = -1;
3181

3182
    switch (detach->source.subsys.type) {
3183
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI:
3184 3185
        ret = qemuDomainDetachHostPciDevice(driver, vm, detach);
        break;
3186
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB:
3187
        ret = qemuDomainDetachHostUsbDevice(driver, vm, detach);
3188
        break;
3189 3190 3191
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_SCSI:
        ret = qemuDomainDetachHostScsiDevice(driver, vm, detach);
        break;
3192
    default:
3193 3194 3195
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("hostdev subsys type '%s' not supported"),
                       virDomainHostdevSubsysTypeToString(detach->source.subsys.type));
3196 3197 3198
        return -1;
    }

3199 3200
    if (ret < 0)
        virDomainAuditHostdev(vm, detach, "detach", false);
3201
    else if (!qemuDomainWaitForDeviceRemoval(vm))
3202
        qemuDomainRemoveHostDevice(driver, vm, detach);
3203

3204 3205
    qemuDomainResetDeviceRemoval(vm);

3206 3207
    return ret;
}
3208

3209
/* search for a hostdev matching dev and detach it */
3210
int qemuDomainDetachHostDevice(virQEMUDriverPtr driver,
3211 3212 3213 3214 3215 3216 3217 3218 3219
                               virDomainObjPtr vm,
                               virDomainDeviceDefPtr dev)
{
    virDomainHostdevDefPtr hostdev = dev->data.hostdev;
    virDomainHostdevSubsysPtr subsys = &hostdev->source.subsys;
    virDomainHostdevDefPtr detach = NULL;
    int idx;

    if (hostdev->mode != VIR_DOMAIN_HOSTDEV_MODE_SUBSYS) {
3220 3221 3222
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("hostdev mode '%s' not supported"),
                       virDomainHostdevModeTypeToString(hostdev->mode));
3223 3224 3225 3226 3227 3228
        return -1;
    }

    idx = virDomainHostdevFind(vm->def, hostdev, &detach);

    if (idx < 0) {
3229
        switch (subsys->type) {
3230
        case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI:
3231 3232
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("host pci device %.4x:%.2x:%.2x.%.1x not found"),
3233 3234
                           subsys->u.pci.addr.domain, subsys->u.pci.addr.bus,
                           subsys->u.pci.addr.slot, subsys->u.pci.addr.function);
3235 3236 3237
            break;
        case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB:
            if (subsys->u.usb.bus && subsys->u.usb.device) {
3238 3239 3240
                virReportError(VIR_ERR_OPERATION_FAILED,
                               _("host usb device %03d.%03d not found"),
                               subsys->u.usb.bus, subsys->u.usb.device);
3241
            } else {
3242 3243 3244
                virReportError(VIR_ERR_OPERATION_FAILED,
                               _("host usb device vendor=0x%.4x product=0x%.4x not found"),
                               subsys->u.usb.vendor, subsys->u.usb.product);
3245 3246
            }
            break;
3247 3248 3249 3250 3251 3252
        case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_SCSI:
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("host scsi device %s:%d:%d.%d not found"),
                           subsys->u.scsi.adapter, subsys->u.scsi.bus,
                           subsys->u.scsi.target, subsys->u.scsi.unit);
            break;
3253
        default:
3254 3255
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unexpected hostdev type %d"), subsys->type);
3256 3257 3258 3259 3260
            break;
        }
        return -1;
    }

3261 3262 3263 3264 3265 3266
    /* If this is a network hostdev, we need to use the higher-level detach
     * function so that mac address / virtualport are reset
     */
    if (detach->parent.type == VIR_DOMAIN_DEVICE_NET)
        return qemuDomainDetachNetDevice(driver, vm, &detach->parent);
    else
3267
        return qemuDomainDetachThisHostDevice(driver, vm, detach);
3268 3269
}

3270
int
3271
qemuDomainDetachNetDevice(virQEMUDriverPtr driver,
3272 3273 3274
                          virDomainObjPtr vm,
                          virDomainDeviceDefPtr dev)
{
3275
    int detachidx, ret = -1;
3276 3277 3278 3279
    virDomainNetDefPtr detach = NULL;
    qemuDomainObjPrivatePtr priv = vm->privateData;
    int vlan;
    char *hostnet_name = NULL;
3280
    char mac[VIR_MAC_STRING_BUFLEN];
3281

3282 3283 3284 3285 3286 3287
    detachidx = virDomainNetFindIdx(vm->def, dev->data.net);
    if (detachidx == -2) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("multiple devices matching mac address %s found"),
                       virMacAddrFormat(&dev->data.net->mac, mac));
        goto cleanup;
3288
    }
3289
    else if (detachidx < 0) {
3290
        virReportError(VIR_ERR_OPERATION_FAILED,
3291 3292
                       _("network device %s not found"),
                       virMacAddrFormat(&dev->data.net->mac, mac));
3293 3294
        goto cleanup;
    }
3295
    detach = vm->def->nets[detachidx];
3296

3297
    if (virDomainNetGetActualType(detach) == VIR_DOMAIN_NET_TYPE_HOSTDEV) {
3298
        /* coverity[negative_returns] */
3299
        ret = qemuDomainDetachThisHostDevice(driver, vm,
3300
                                             virDomainNetGetActualHostdev(detach));
3301 3302
        goto cleanup;
    }
3303 3304 3305 3306 3307 3308 3309 3310 3311 3312 3313 3314 3315 3316 3317
    if (STREQLEN(vm->def->os.machine, "s390-ccw", 8) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_VIRTIO_CCW)) {
        if (!virDomainDeviceAddressIsValid(&detach->info,
                                           VIR_DOMAIN_DEVICE_ADDRESS_TYPE_CCW)) {
            virReportError(VIR_ERR_OPERATION_FAILED,
                            "%s", _("device cannot be detached without a CCW address"));
            goto cleanup;
        }
    } else {
        if (!virDomainDeviceAddressIsValid(&detach->info,
                                           VIR_DOMAIN_DEVICE_ADDRESS_TYPE_PCI)) {
            virReportError(VIR_ERR_OPERATION_FAILED,
                            "%s", _("device cannot be detached without a PCI address"));
            goto cleanup;
        }
3318

3319 3320 3321 3322 3323 3324
        if (qemuIsMultiFunctionDevice(vm->def, &detach->info)) {
            virReportError(VIR_ERR_OPERATION_FAILED,
                            _("cannot hot unplug multifunction PCI device :%s"),
                            dev->data.disk->dst);
            goto cleanup;
        }
3325 3326 3327
    }

    if ((vlan = qemuDomainNetVLAN(detach)) < 0) {
3328 3329
        virReportError(VIR_ERR_OPERATION_FAILED,
                       "%s", _("unable to determine original VLAN"));
3330 3331 3332
        goto cleanup;
    }

3333
    if (virAsprintf(&hostnet_name, "host%s", detach->info.alias) < 0)
3334 3335
        goto cleanup;

3336 3337
    qemuDomainMarkDeviceForRemoval(vm, &detach->info);

3338
    qemuDomainObjEnterMonitor(driver, vm);
3339
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3340
        if (qemuMonitorDelDevice(priv->mon, detach->info.alias) < 0) {
3341
            qemuDomainObjExitMonitor(driver, vm);
3342 3343 3344 3345 3346 3347
            virDomainAuditNet(vm, detach, NULL, "detach", false);
            goto cleanup;
        }
    } else {
        if (qemuMonitorRemovePCIDevice(priv->mon,
                                       &detach->info.addr.pci) < 0) {
3348
            qemuDomainObjExitMonitor(driver, vm);
3349 3350 3351 3352 3353
            virDomainAuditNet(vm, detach, NULL, "detach", false);
            goto cleanup;
        }
    }

3354 3355
    if (virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_NETDEV) &&
        virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_DEVICE)) {
3356
        if (qemuMonitorRemoveNetdev(priv->mon, hostnet_name) < 0) {
3357
            qemuDomainObjExitMonitor(driver, vm);
3358 3359 3360 3361 3362
            virDomainAuditNet(vm, detach, NULL, "detach", false);
            goto cleanup;
        }
    } else {
        if (qemuMonitorRemoveHostNetwork(priv->mon, vlan, hostnet_name) < 0) {
3363
            qemuDomainObjExitMonitor(driver, vm);
3364 3365 3366 3367
            virDomainAuditNet(vm, detach, NULL, "detach", false);
            goto cleanup;
        }
    }
3368
    qemuDomainObjExitMonitor(driver, vm);
3369

3370 3371 3372
    if (!qemuDomainWaitForDeviceRemoval(vm))
        qemuDomainRemoveNetDevice(driver, vm, detach);

3373
    ret = 0;
3374

3375
cleanup:
3376
    qemuDomainResetDeviceRemoval(vm);
3377 3378 3379 3380
    VIR_FREE(hostnet_name);
    return ret;
}

3381
int
3382
qemuDomainChangeGraphicsPasswords(virQEMUDriverPtr driver,
3383 3384 3385 3386 3387 3388 3389 3390
                                  virDomainObjPtr vm,
                                  int type,
                                  virDomainGraphicsAuthDefPtr auth,
                                  const char *defaultPasswd)
{
    qemuDomainObjPrivatePtr priv = vm->privateData;
    time_t now = time(NULL);
    char expire_time [64];
3391
    const char *connected = NULL;
3392 3393
    int ret = -1;
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);
3394

3395
    if (!auth->passwd && !defaultPasswd) {
3396 3397 3398
        ret = 0;
        goto cleanup;
    }
3399

3400 3401 3402
    if (auth->connected)
        connected = virDomainGraphicsAuthConnectedTypeToString(auth->connected);

3403
    qemuDomainObjEnterMonitor(driver, vm);
3404 3405 3406
    ret = qemuMonitorSetPassword(priv->mon,
                                 type,
                                 auth->passwd ? auth->passwd : defaultPasswd,
3407
                                 connected);
3408 3409 3410

    if (ret == -2) {
        if (type != VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
3411 3412
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("Graphics password only supported for VNC"));
3413 3414 3415 3416 3417 3418
            ret = -1;
        } else {
            ret = qemuMonitorSetVNCPassword(priv->mon,
                                            auth->passwd ? auth->passwd : defaultPasswd);
        }
    }
3419
    if (ret != 0)
3420
        goto end_job;
3421

3422 3423 3424
    if (auth->expires) {
        time_t lifetime = auth->validTo - now;
        if (lifetime <= 0)
3425
            snprintf(expire_time, sizeof(expire_time), "now");
3426
        else
3427
            snprintf(expire_time, sizeof(expire_time), "%lu", (long unsigned)auth->validTo);
3428
    } else {
3429
        snprintf(expire_time, sizeof(expire_time), "never");
3430 3431 3432 3433 3434 3435 3436
    }

    ret = qemuMonitorExpirePassword(priv->mon, type, expire_time);

    if (ret == -2) {
        /* XXX we could fake this with a timer */
        if (auth->expires) {
3437 3438
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("Expiry of passwords is not supported"));
3439
            ret = -1;
3440 3441
        } else {
            ret = 0;
3442 3443 3444
        }
    }

3445
end_job:
3446
    qemuDomainObjExitMonitor(driver, vm);
3447 3448
cleanup:
    virObjectUnref(cfg);
3449 3450
    return ret;
}
3451

3452
int qemuDomainAttachLease(virQEMUDriverPtr driver,
3453 3454 3455
                          virDomainObjPtr vm,
                          virDomainLeaseDefPtr lease)
{
3456 3457 3458
    int ret = -1;
    virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(driver);

3459
    if (virDomainLeaseInsertPreAlloc(vm->def) < 0)
3460
        goto cleanup;
3461

3462
    if (virDomainLockLeaseAttach(driver->lockManager, cfg->uri,
3463
                                 vm, lease) < 0) {
3464
        virDomainLeaseInsertPreAlloced(vm->def, NULL);
3465
        goto cleanup;
3466 3467 3468
    }

    virDomainLeaseInsertPreAlloced(vm->def, lease);
3469 3470 3471 3472 3473
    ret = 0;

cleanup:
    virObjectUnref(cfg);
    return ret;
3474 3475
}

3476
int qemuDomainDetachLease(virQEMUDriverPtr driver,
3477 3478 3479
                          virDomainObjPtr vm,
                          virDomainLeaseDefPtr lease)
{
3480
    virDomainLeaseDefPtr det_lease;
3481
    int idx;
3482

3483
    if ((idx = virDomainLeaseIndex(vm->def, lease)) < 0) {
3484 3485 3486
        virReportError(VIR_ERR_INVALID_ARG,
                       _("Lease %s in lockspace %s does not exist"),
                       lease->key, NULLSTR(lease->lockspace));
3487 3488 3489 3490 3491 3492
        return -1;
    }

    if (virDomainLockLeaseDetach(driver->lockManager, vm, lease) < 0)
        return -1;

3493
    det_lease = virDomainLeaseRemoveAt(vm->def, idx);
3494
    virDomainLeaseDefFree(det_lease);
3495 3496
    return 0;
}
3497 3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512 3513 3514 3515 3516 3517

int qemuDomainDetachChrDevice(virQEMUDriverPtr driver,
                              virDomainObjPtr vm,
                              virDomainChrDefPtr chr)
{
    int ret = -1;
    qemuDomainObjPrivatePtr priv = vm->privateData;
    virDomainDefPtr vmdef = vm->def;
    virDomainChrDefPtr tmpChr;
    char *charAlias = NULL;
    char *devstr = NULL;

    if (!(tmpChr = virDomainChrFind(vmdef, chr))) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("device not present in domain configuration"));
        return ret;
    }

    if (qemuBuildChrDeviceStr(&devstr, vm->def, chr, priv->qemuCaps) < 0)
        return ret;

3518 3519
    if (virAsprintf(&charAlias, "char%s", tmpChr->info.alias) < 0)
        goto cleanup;
3520

3521 3522
    qemuDomainMarkDeviceForRemoval(vm, &tmpChr->info);

3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533 3534
    qemuDomainObjEnterMonitor(driver, vm);
    if (devstr && qemuMonitorDelDevice(priv->mon, tmpChr->info.alias) < 0) {
        qemuDomainObjExitMonitor(driver, vm);
        goto cleanup;
    }

    if (qemuMonitorDetachCharDev(priv->mon, charAlias) < 0) {
        qemuDomainObjExitMonitor(driver, vm);
        goto cleanup;
    }
    qemuDomainObjExitMonitor(driver, vm);

3535 3536
    if (!qemuDomainWaitForDeviceRemoval(vm))
        qemuDomainRemoveChrDevice(driver, vm, tmpChr);
3537 3538 3539
    ret = 0;

cleanup:
3540
    qemuDomainResetDeviceRemoval(vm);
3541 3542 3543 3544
    VIR_FREE(devstr);
    VIR_FREE(charAlias);
    return ret;
}