Annotation of qemu/hw/pci-hotplug.c, revision 1.1.1.7

1.1       root        1: /*
                      2:  * QEMU PCI hotplug support
                      3:  *
                      4:  * Copyright (c) 2004 Fabrice Bellard
                      5:  *
                      6:  * Permission is hereby granted, free of charge, to any person obtaining a copy
                      7:  * of this software and associated documentation files (the "Software"), to deal
                      8:  * in the Software without restriction, including without limitation the rights
                      9:  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
                     10:  * copies of the Software, and to permit persons to whom the Software is
                     11:  * furnished to do so, subject to the following conditions:
                     12:  *
                     13:  * The above copyright notice and this permission notice shall be included in
                     14:  * all copies or substantial portions of the Software.
                     15:  *
                     16:  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
                     17:  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
                     18:  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
                     19:  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
                     20:  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
                     21:  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
                     22:  * THE SOFTWARE.
                     23:  */
                     24: 
                     25: #include "hw.h"
                     26: #include "boards.h"
                     27: #include "pci.h"
                     28: #include "net.h"
                     29: #include "pc.h"
1.1.1.4   root       30: #include "monitor.h"
1.1.1.5   root       31: #include "scsi.h"
1.1       root       32: #include "virtio-blk.h"
1.1.1.5   root       33: #include "qemu-config.h"
1.1.1.7 ! root       34: #include "blockdev.h"
1.1       root       35: 
1.1.1.5   root       36: #if defined(TARGET_I386)
1.1.1.4   root       37: static PCIDevice *qemu_pci_hot_add_nic(Monitor *mon,
1.1.1.5   root       38:                                        const char *devaddr,
                     39:                                        const char *opts_str)
1.1       root       40: {
1.1.1.5   root       41:     QemuOpts *opts;
                     42:     PCIBus *bus;
                     43:     int ret, devfn;
                     44: 
                     45:     bus = pci_get_bus_devfn(&devfn, devaddr);
                     46:     if (!bus) {
                     47:         monitor_printf(mon, "Invalid PCI device address %s\n", devaddr);
                     48:         return NULL;
                     49:     }
                     50:     if (!((BusState*)bus)->allow_hotplug) {
                     51:         monitor_printf(mon, "PCI bus doesn't support hotplug\n");
                     52:         return NULL;
                     53:     }
                     54: 
1.1.1.7 ! root       55:     opts = qemu_opts_parse(qemu_find_opts("net"), opts_str ? opts_str : "", 0);
1.1.1.5   root       56:     if (!opts) {
                     57:         return NULL;
                     58:     }
1.1       root       59: 
1.1.1.5   root       60:     qemu_opt_set(opts, "type", "nic");
                     61: 
                     62:     ret = net_client_init(mon, opts, 0);
1.1.1.3   root       63:     if (ret < 0)
1.1       root       64:         return NULL;
1.1.1.4   root       65:     if (nd_table[ret].devaddr) {
                     66:         monitor_printf(mon, "Parameter addr not supported\n");
                     67:         return NULL;
                     68:     }
                     69:     return pci_nic_init(&nd_table[ret], "rtl8139", devaddr);
1.1       root       70: }
                     71: 
1.1.1.6   root       72: static int scsi_hot_add(Monitor *mon, DeviceState *adapter,
                     73:                         DriveInfo *dinfo, int printinfo)
1.1.1.5   root       74: {
                     75:     SCSIBus *scsibus;
                     76:     SCSIDevice *scsidev;
                     77: 
                     78:     scsibus = DO_UPCAST(SCSIBus, qbus, QLIST_FIRST(&adapter->child_bus));
                     79:     if (!scsibus || strcmp(scsibus->qbus.info->name, "SCSI") != 0) {
1.1.1.6   root       80:         error_report("Device is not a SCSI adapter");
1.1.1.5   root       81:         return -1;
                     82:     }
                     83: 
                     84:     /*
                     85:      * drive_init() tries to find a default for dinfo->unit.  Doesn't
                     86:      * work at all for hotplug though as we assign the device to a
                     87:      * specific bus instead of the first bus with spare scsi ids.
                     88:      *
                     89:      * Ditch the calculated value and reload from option string (if
                     90:      * specified).
                     91:      */
                     92:     dinfo->unit = qemu_opt_get_number(dinfo->opts, "unit", -1);
1.1.1.7 ! root       93:     dinfo->bus = scsibus->busnr;
        !            94:     scsidev = scsi_bus_legacy_add_drive(scsibus, dinfo->bdrv, dinfo->unit, false);
1.1.1.6   root       95:     if (!scsidev) {
                     96:         return -1;
                     97:     }
1.1.1.5   root       98:     dinfo->unit = scsidev->id;
                     99: 
                    100:     if (printinfo)
1.1.1.6   root      101:         monitor_printf(mon, "OK bus %d, unit %d\n",
                    102:                        scsibus->busnr, scsidev->id);
1.1.1.5   root      103:     return 0;
                    104: }
                    105: 
                    106: void drive_hot_add(Monitor *mon, const QDict *qdict)
1.1       root      107: {
                    108:     int dom, pci_bus;
                    109:     unsigned slot;
1.1.1.6   root      110:     int type;
1.1       root      111:     PCIDevice *dev;
1.1.1.5   root      112:     DriveInfo *dinfo = NULL;
                    113:     const char *pci_addr = qdict_get_str(qdict, "pci_addr");
                    114:     const char *opts = qdict_get_str(qdict, "opts");
                    115: 
                    116:     dinfo = add_init_drive(opts);
                    117:     if (!dinfo)
                    118:         goto err;
                    119:     if (dinfo->devaddr) {
1.1.1.4   root      120:         monitor_printf(mon, "Parameter addr not supported\n");
1.1.1.5   root      121:         goto err;
1.1.1.4   root      122:     }
1.1.1.5   root      123:     type = dinfo->type;
1.1       root      124: 
                    125:     switch (type) {
                    126:     case IF_SCSI:
1.1.1.5   root      127:         if (pci_read_devaddr(mon, pci_addr, &dom, &pci_bus, &slot)) {
                    128:             goto err;
                    129:         }
1.1.1.6   root      130:         dev = pci_find_device(pci_find_root_bus(dom), pci_bus, slot, 0);
1.1.1.5   root      131:         if (!dev) {
                    132:             monitor_printf(mon, "no pci device with address %s\n", pci_addr);
                    133:             goto err;
                    134:         }
1.1.1.6   root      135:         if (scsi_hot_add(mon, &dev->qdev, dinfo, 1) != 0) {
1.1.1.5   root      136:             goto err;
                    137:         }
                    138:         break;
                    139:     case IF_NONE:
                    140:         monitor_printf(mon, "OK\n");
1.1       root      141:         break;
                    142:     default:
1.1.1.4   root      143:         monitor_printf(mon, "Can't hot-add drive to type %d\n", type);
1.1.1.5   root      144:         goto err;
1.1       root      145:     }
1.1.1.5   root      146:     return;
1.1       root      147: 
1.1.1.5   root      148: err:
                    149:     if (dinfo)
1.1.1.7 ! root      150:         drive_put_ref(dinfo);
1.1       root      151:     return;
                    152: }
                    153: 
1.1.1.4   root      154: static PCIDevice *qemu_pci_hot_add_storage(Monitor *mon,
                    155:                                            const char *devaddr,
                    156:                                            const char *opts)
1.1       root      157: {
1.1.1.4   root      158:     PCIDevice *dev;
1.1.1.5   root      159:     DriveInfo *dinfo = NULL;
                    160:     int type = -1;
1.1       root      161:     char buf[128];
1.1.1.5   root      162:     PCIBus *bus;
                    163:     int devfn;
1.1       root      164: 
                    165:     if (get_param_value(buf, sizeof(buf), "if", opts)) {
                    166:         if (!strcmp(buf, "scsi"))
                    167:             type = IF_SCSI;
                    168:         else if (!strcmp(buf, "virtio")) {
                    169:             type = IF_VIRTIO;
1.1.1.2   root      170:         } else {
1.1.1.4   root      171:             monitor_printf(mon, "type %s not a hotpluggable PCI device.\n", buf);
                    172:             return NULL;
1.1       root      173:         }
                    174:     } else {
1.1.1.4   root      175:         monitor_printf(mon, "no if= specified\n");
                    176:         return NULL;
1.1       root      177:     }
                    178: 
                    179:     if (get_param_value(buf, sizeof(buf), "file", opts)) {
1.1.1.5   root      180:         dinfo = add_init_drive(opts);
                    181:         if (!dinfo)
1.1.1.4   root      182:             return NULL;
1.1.1.5   root      183:         if (dinfo->devaddr) {
1.1.1.4   root      184:             monitor_printf(mon, "Parameter addr not supported\n");
                    185:             return NULL;
                    186:         }
1.1.1.5   root      187:     } else {
                    188:         dinfo = NULL;
                    189:     }
                    190: 
                    191:     bus = pci_get_bus_devfn(&devfn, devaddr);
                    192:     if (!bus) {
                    193:         monitor_printf(mon, "Invalid PCI device address %s\n", devaddr);
                    194:         return NULL;
                    195:     }
                    196:     if (!((BusState*)bus)->allow_hotplug) {
                    197:         monitor_printf(mon, "PCI bus doesn't support hotplug\n");
1.1.1.4   root      198:         return NULL;
1.1       root      199:     }
                    200: 
                    201:     switch (type) {
                    202:     case IF_SCSI:
1.1.1.5   root      203:         dev = pci_create(bus, devfn, "lsi53c895a");
                    204:         if (qdev_init(&dev->qdev) < 0)
                    205:             dev = NULL;
                    206:         if (dev && dinfo) {
1.1.1.6   root      207:             if (scsi_hot_add(mon, &dev->qdev, dinfo, 0) != 0) {
1.1.1.5   root      208:                 qdev_unplug(&dev->qdev);
                    209:                 dev = NULL;
                    210:             }
                    211:         }
1.1       root      212:         break;
                    213:     case IF_VIRTIO:
1.1.1.5   root      214:         if (!dinfo) {
                    215:             monitor_printf(mon, "virtio requires a backing file/device.\n");
                    216:             return NULL;
                    217:         }
                    218:         dev = pci_create(bus, devfn, "virtio-blk-pci");
1.1.1.6   root      219:         if (qdev_prop_set_drive(&dev->qdev, "drive", dinfo->bdrv) < 0) {
                    220:             qdev_free(&dev->qdev);
                    221:             dev = NULL;
                    222:             break;
                    223:         }
1.1.1.5   root      224:         if (qdev_init(&dev->qdev) < 0)
                    225:             dev = NULL;
1.1       root      226:         break;
1.1.1.4   root      227:     default:
                    228:         dev = NULL;
1.1       root      229:     }
1.1.1.4   root      230:     return dev;
1.1       root      231: }
                    232: 
1.1.1.6   root      233: void pci_device_hot_add(Monitor *mon, const QDict *qdict)
1.1       root      234: {
                    235:     PCIDevice *dev = NULL;
1.1.1.5   root      236:     const char *pci_addr = qdict_get_str(qdict, "pci_addr");
                    237:     const char *type = qdict_get_str(qdict, "type");
                    238:     const char *opts = qdict_get_try_str(qdict, "opts");
1.1       root      239: 
1.1.1.4   root      240:     /* strip legacy tag */
                    241:     if (!strncmp(pci_addr, "pci_addr=", 9)) {
                    242:         pci_addr += 9;
1.1       root      243:     }
                    244: 
1.1.1.4   root      245:     if (!opts) {
                    246:         opts = "";
1.1       root      247:     }
                    248: 
1.1.1.4   root      249:     if (!strcmp(pci_addr, "auto"))
                    250:         pci_addr = NULL;
                    251: 
1.1.1.6   root      252:     if (strcmp(type, "nic") == 0) {
1.1.1.4   root      253:         dev = qemu_pci_hot_add_nic(mon, pci_addr, opts);
1.1.1.6   root      254:     } else if (strcmp(type, "storage") == 0) {
1.1.1.4   root      255:         dev = qemu_pci_hot_add_storage(mon, pci_addr, opts);
1.1.1.6   root      256:     } else {
1.1.1.4   root      257:         monitor_printf(mon, "invalid type: %s\n", type);
1.1.1.6   root      258:     }
1.1       root      259: 
                    260:     if (dev) {
1.1.1.6   root      261:         monitor_printf(mon, "OK domain %d, bus %d, slot %d, function %d\n",
                    262:                        pci_find_domain(dev->bus),
                    263:                        pci_bus_num(dev->bus), PCI_SLOT(dev->devfn),
                    264:                        PCI_FUNC(dev->devfn));
1.1       root      265:     } else
1.1.1.4   root      266:         monitor_printf(mon, "failed to add %s\n", opts);
1.1       root      267: }
                    268: #endif
                    269: 
1.1.1.6   root      270: static int pci_device_hot_remove(Monitor *mon, const char *pci_addr)
1.1       root      271: {
                    272:     PCIDevice *d;
                    273:     int dom, bus;
                    274:     unsigned slot;
                    275: 
1.1.1.4   root      276:     if (pci_read_devaddr(mon, pci_addr, &dom, &bus, &slot)) {
1.1.1.6   root      277:         return -1;
1.1       root      278:     }
                    279: 
1.1.1.6   root      280:     d = pci_find_device(pci_find_root_bus(dom), bus, slot, 0);
1.1       root      281:     if (!d) {
1.1.1.4   root      282:         monitor_printf(mon, "slot %d empty\n", slot);
1.1.1.6   root      283:         return -1;
1.1       root      284:     }
1.1.1.6   root      285:     return qdev_unplug(&d->qdev);
1.1       root      286: }
                    287: 
1.1.1.6   root      288: void do_pci_device_hot_remove(Monitor *mon, const QDict *qdict)
1.1       root      289: {
1.1.1.5   root      290:     pci_device_hot_remove(mon, qdict_get_str(qdict, "pci_addr"));
1.1       root      291: }

unix.superglobalmegacorp.com

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.