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

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       root       34: 
1.1.1.5   root       35: #if defined(TARGET_I386)
1.1.1.4   root       36: static PCIDevice *qemu_pci_hot_add_nic(Monitor *mon,
1.1.1.5   root       37:                                        const char *devaddr,
                     38:                                        const char *opts_str)
1.1       root       39: {
1.1.1.5   root       40:     QemuOpts *opts;
                     41:     PCIBus *bus;
                     42:     int ret, devfn;
                     43: 
                     44:     bus = pci_get_bus_devfn(&devfn, devaddr);
                     45:     if (!bus) {
                     46:         monitor_printf(mon, "Invalid PCI device address %s\n", devaddr);
                     47:         return NULL;
                     48:     }
                     49:     if (!((BusState*)bus)->allow_hotplug) {
                     50:         monitor_printf(mon, "PCI bus doesn't support hotplug\n");
                     51:         return NULL;
                     52:     }
                     53: 
1.1.1.6 ! root       54:     opts = qemu_opts_parse(&qemu_net_opts, opts_str ? opts_str : "", 0);
1.1.1.5   root       55:     if (!opts) {
                     56:         return NULL;
                     57:     }
1.1       root       58: 
1.1.1.5   root       59:     qemu_opt_set(opts, "type", "nic");
                     60: 
                     61:     ret = net_client_init(mon, opts, 0);
1.1.1.3   root       62:     if (ret < 0)
1.1       root       63:         return NULL;
1.1.1.4   root       64:     if (nd_table[ret].devaddr) {
                     65:         monitor_printf(mon, "Parameter addr not supported\n");
                     66:         return NULL;
                     67:     }
                     68:     return pci_nic_init(&nd_table[ret], "rtl8139", devaddr);
1.1       root       69: }
                     70: 
1.1.1.6 ! root       71: static int scsi_hot_add(Monitor *mon, DeviceState *adapter,
        !            72:                         DriveInfo *dinfo, int printinfo)
1.1.1.5   root       73: {
                     74:     SCSIBus *scsibus;
                     75:     SCSIDevice *scsidev;
                     76: 
                     77:     scsibus = DO_UPCAST(SCSIBus, qbus, QLIST_FIRST(&adapter->child_bus));
                     78:     if (!scsibus || strcmp(scsibus->qbus.info->name, "SCSI") != 0) {
1.1.1.6 ! root       79:         error_report("Device is not a SCSI adapter");
1.1.1.5   root       80:         return -1;
                     81:     }
                     82: 
                     83:     /*
                     84:      * drive_init() tries to find a default for dinfo->unit.  Doesn't
                     85:      * work at all for hotplug though as we assign the device to a
                     86:      * specific bus instead of the first bus with spare scsi ids.
                     87:      *
                     88:      * Ditch the calculated value and reload from option string (if
                     89:      * specified).
                     90:      */
                     91:     dinfo->unit = qemu_opt_get_number(dinfo->opts, "unit", -1);
1.1.1.6 ! root       92:     scsidev = scsi_bus_legacy_add_drive(scsibus, dinfo->bdrv, dinfo->unit);
        !            93:     if (!scsidev) {
        !            94:         return -1;
        !            95:     }
1.1.1.5   root       96:     dinfo->unit = scsidev->id;
                     97: 
                     98:     if (printinfo)
1.1.1.6 ! root       99:         monitor_printf(mon, "OK bus %d, unit %d\n",
        !           100:                        scsibus->busnr, scsidev->id);
1.1.1.5   root      101:     return 0;
                    102: }
                    103: 
                    104: void drive_hot_add(Monitor *mon, const QDict *qdict)
1.1       root      105: {
                    106:     int dom, pci_bus;
                    107:     unsigned slot;
1.1.1.6 ! root      108:     int type;
1.1       root      109:     PCIDevice *dev;
1.1.1.5   root      110:     DriveInfo *dinfo = NULL;
                    111:     const char *pci_addr = qdict_get_str(qdict, "pci_addr");
                    112:     const char *opts = qdict_get_str(qdict, "opts");
                    113: 
                    114:     dinfo = add_init_drive(opts);
                    115:     if (!dinfo)
                    116:         goto err;
                    117:     if (dinfo->devaddr) {
1.1.1.4   root      118:         monitor_printf(mon, "Parameter addr not supported\n");
1.1.1.5   root      119:         goto err;
1.1.1.4   root      120:     }
1.1.1.5   root      121:     type = dinfo->type;
1.1       root      122: 
                    123:     switch (type) {
                    124:     case IF_SCSI:
1.1.1.5   root      125:         if (pci_read_devaddr(mon, pci_addr, &dom, &pci_bus, &slot)) {
                    126:             goto err;
                    127:         }
1.1.1.6 ! root      128:         dev = pci_find_device(pci_find_root_bus(dom), pci_bus, slot, 0);
1.1.1.5   root      129:         if (!dev) {
                    130:             monitor_printf(mon, "no pci device with address %s\n", pci_addr);
                    131:             goto err;
                    132:         }
1.1.1.6 ! root      133:         if (scsi_hot_add(mon, &dev->qdev, dinfo, 1) != 0) {
1.1.1.5   root      134:             goto err;
                    135:         }
                    136:         break;
                    137:     case IF_NONE:
                    138:         monitor_printf(mon, "OK\n");
1.1       root      139:         break;
                    140:     default:
1.1.1.4   root      141:         monitor_printf(mon, "Can't hot-add drive to type %d\n", type);
1.1.1.5   root      142:         goto err;
1.1       root      143:     }
1.1.1.5   root      144:     return;
1.1       root      145: 
1.1.1.5   root      146: err:
                    147:     if (dinfo)
                    148:         drive_uninit(dinfo);
1.1       root      149:     return;
                    150: }
                    151: 
1.1.1.4   root      152: static PCIDevice *qemu_pci_hot_add_storage(Monitor *mon,
                    153:                                            const char *devaddr,
                    154:                                            const char *opts)
1.1       root      155: {
1.1.1.4   root      156:     PCIDevice *dev;
1.1.1.5   root      157:     DriveInfo *dinfo = NULL;
                    158:     int type = -1;
1.1       root      159:     char buf[128];
1.1.1.5   root      160:     PCIBus *bus;
                    161:     int devfn;
1.1       root      162: 
                    163:     if (get_param_value(buf, sizeof(buf), "if", opts)) {
                    164:         if (!strcmp(buf, "scsi"))
                    165:             type = IF_SCSI;
                    166:         else if (!strcmp(buf, "virtio")) {
                    167:             type = IF_VIRTIO;
1.1.1.2   root      168:         } else {
1.1.1.4   root      169:             monitor_printf(mon, "type %s not a hotpluggable PCI device.\n", buf);
                    170:             return NULL;
1.1       root      171:         }
                    172:     } else {
1.1.1.4   root      173:         monitor_printf(mon, "no if= specified\n");
                    174:         return NULL;
1.1       root      175:     }
                    176: 
                    177:     if (get_param_value(buf, sizeof(buf), "file", opts)) {
1.1.1.5   root      178:         dinfo = add_init_drive(opts);
                    179:         if (!dinfo)
1.1.1.4   root      180:             return NULL;
1.1.1.5   root      181:         if (dinfo->devaddr) {
1.1.1.4   root      182:             monitor_printf(mon, "Parameter addr not supported\n");
                    183:             return NULL;
                    184:         }
1.1.1.5   root      185:     } else {
                    186:         dinfo = NULL;
                    187:     }
                    188: 
                    189:     bus = pci_get_bus_devfn(&devfn, devaddr);
                    190:     if (!bus) {
                    191:         monitor_printf(mon, "Invalid PCI device address %s\n", devaddr);
                    192:         return NULL;
                    193:     }
                    194:     if (!((BusState*)bus)->allow_hotplug) {
                    195:         monitor_printf(mon, "PCI bus doesn't support hotplug\n");
1.1.1.4   root      196:         return NULL;
1.1       root      197:     }
                    198: 
                    199:     switch (type) {
                    200:     case IF_SCSI:
1.1.1.5   root      201:         dev = pci_create(bus, devfn, "lsi53c895a");
                    202:         if (qdev_init(&dev->qdev) < 0)
                    203:             dev = NULL;
                    204:         if (dev && dinfo) {
1.1.1.6 ! root      205:             if (scsi_hot_add(mon, &dev->qdev, dinfo, 0) != 0) {
1.1.1.5   root      206:                 qdev_unplug(&dev->qdev);
                    207:                 dev = NULL;
                    208:             }
                    209:         }
1.1       root      210:         break;
                    211:     case IF_VIRTIO:
1.1.1.5   root      212:         if (!dinfo) {
                    213:             monitor_printf(mon, "virtio requires a backing file/device.\n");
                    214:             return NULL;
                    215:         }
                    216:         dev = pci_create(bus, devfn, "virtio-blk-pci");
1.1.1.6 ! root      217:         if (qdev_prop_set_drive(&dev->qdev, "drive", dinfo->bdrv) < 0) {
        !           218:             qdev_free(&dev->qdev);
        !           219:             dev = NULL;
        !           220:             break;
        !           221:         }
1.1.1.5   root      222:         if (qdev_init(&dev->qdev) < 0)
                    223:             dev = NULL;
1.1       root      224:         break;
1.1.1.4   root      225:     default:
                    226:         dev = NULL;
1.1       root      227:     }
1.1.1.4   root      228:     return dev;
1.1       root      229: }
                    230: 
1.1.1.6 ! root      231: void pci_device_hot_add(Monitor *mon, const QDict *qdict)
1.1       root      232: {
                    233:     PCIDevice *dev = NULL;
1.1.1.5   root      234:     const char *pci_addr = qdict_get_str(qdict, "pci_addr");
                    235:     const char *type = qdict_get_str(qdict, "type");
                    236:     const char *opts = qdict_get_try_str(qdict, "opts");
1.1       root      237: 
1.1.1.4   root      238:     /* strip legacy tag */
                    239:     if (!strncmp(pci_addr, "pci_addr=", 9)) {
                    240:         pci_addr += 9;
1.1       root      241:     }
                    242: 
1.1.1.4   root      243:     if (!opts) {
                    244:         opts = "";
1.1       root      245:     }
                    246: 
1.1.1.4   root      247:     if (!strcmp(pci_addr, "auto"))
                    248:         pci_addr = NULL;
                    249: 
1.1.1.6 ! root      250:     if (strcmp(type, "nic") == 0) {
1.1.1.4   root      251:         dev = qemu_pci_hot_add_nic(mon, pci_addr, opts);
1.1.1.6 ! root      252:     } else if (strcmp(type, "storage") == 0) {
1.1.1.4   root      253:         dev = qemu_pci_hot_add_storage(mon, pci_addr, opts);
1.1.1.6 ! root      254:     } else {
1.1.1.4   root      255:         monitor_printf(mon, "invalid type: %s\n", type);
1.1.1.6 ! root      256:     }
1.1       root      257: 
                    258:     if (dev) {
1.1.1.6 ! root      259:         monitor_printf(mon, "OK domain %d, bus %d, slot %d, function %d\n",
        !           260:                        pci_find_domain(dev->bus),
        !           261:                        pci_bus_num(dev->bus), PCI_SLOT(dev->devfn),
        !           262:                        PCI_FUNC(dev->devfn));
1.1       root      263:     } else
1.1.1.4   root      264:         monitor_printf(mon, "failed to add %s\n", opts);
1.1       root      265: }
                    266: #endif
                    267: 
1.1.1.6 ! root      268: static int pci_device_hot_remove(Monitor *mon, const char *pci_addr)
1.1       root      269: {
                    270:     PCIDevice *d;
                    271:     int dom, bus;
                    272:     unsigned slot;
                    273: 
1.1.1.4   root      274:     if (pci_read_devaddr(mon, pci_addr, &dom, &bus, &slot)) {
1.1.1.6 ! root      275:         return -1;
1.1       root      276:     }
                    277: 
1.1.1.6 ! root      278:     d = pci_find_device(pci_find_root_bus(dom), bus, slot, 0);
1.1       root      279:     if (!d) {
1.1.1.4   root      280:         monitor_printf(mon, "slot %d empty\n", slot);
1.1.1.6 ! root      281:         return -1;
1.1       root      282:     }
1.1.1.6 ! root      283:     return qdev_unplug(&d->qdev);
1.1       root      284: }
                    285: 
1.1.1.6 ! root      286: void do_pci_device_hot_remove(Monitor *mon, const QDict *qdict)
1.1       root      287: {
1.1.1.5   root      288:     pci_device_hot_remove(mon, qdict_get_str(qdict, "pci_addr"));
1.1       root      289: }

unix.superglobalmegacorp.com

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