Statistics
| Branch: | Revision:

root / hw / pci-hotplug.c @ 7f5b7d3e

History | View | Annotate | Download (9 kB)

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 "sysemu.h"
30
#include "pc.h"
31
#include "monitor.h"
32
#include "block_int.h"
33
#include "scsi.h"
34
#include "virtio-blk.h"
35
#include "qemu-config.h"
36
#include "qemu-objects.h"
37

    
38
#if defined(TARGET_I386)
39
static PCIDevice *qemu_pci_hot_add_nic(Monitor *mon,
40
                                       const char *devaddr,
41
                                       const char *opts_str)
42
{
43
    QemuOpts *opts;
44
    PCIBus *bus;
45
    int ret, devfn;
46

    
47
    bus = pci_get_bus_devfn(&devfn, devaddr);
48
    if (!bus) {
49
        monitor_printf(mon, "Invalid PCI device address %s\n", devaddr);
50
        return NULL;
51
    }
52
    if (!((BusState*)bus)->allow_hotplug) {
53
        monitor_printf(mon, "PCI bus doesn't support hotplug\n");
54
        return NULL;
55
    }
56

    
57
    opts = qemu_opts_parse(&qemu_net_opts, opts_str ? opts_str : "", 0);
58
    if (!opts) {
59
        return NULL;
60
    }
61

    
62
    qemu_opt_set(opts, "type", "nic");
63

    
64
    ret = net_client_init(mon, opts, 0);
65
    if (ret < 0)
66
        return NULL;
67
    if (nd_table[ret].devaddr) {
68
        monitor_printf(mon, "Parameter addr not supported\n");
69
        return NULL;
70
    }
71
    return pci_nic_init(&nd_table[ret], "rtl8139", devaddr);
72
}
73

    
74
static int scsi_hot_add(Monitor *mon, DeviceState *adapter,
75
                        DriveInfo *dinfo, int printinfo)
76
{
77
    SCSIBus *scsibus;
78
    SCSIDevice *scsidev;
79

    
80
    scsibus = DO_UPCAST(SCSIBus, qbus, QLIST_FIRST(&adapter->child_bus));
81
    if (!scsibus || strcmp(scsibus->qbus.info->name, "SCSI") != 0) {
82
        error_report("Device is not a SCSI adapter");
83
        return -1;
84
    }
85

    
86
    /*
87
     * drive_init() tries to find a default for dinfo->unit.  Doesn't
88
     * work at all for hotplug though as we assign the device to a
89
     * specific bus instead of the first bus with spare scsi ids.
90
     *
91
     * Ditch the calculated value and reload from option string (if
92
     * specified).
93
     */
94
    dinfo->unit = qemu_opt_get_number(dinfo->opts, "unit", -1);
95
    scsidev = scsi_bus_legacy_add_drive(scsibus, dinfo, dinfo->unit);
96
    dinfo->unit = scsidev->id;
97

    
98
    if (printinfo)
99
        monitor_printf(mon, "OK bus %d, unit %d\n",
100
                       scsibus->busnr, scsidev->id);
101
    return 0;
102
}
103

    
104
void drive_hot_add(Monitor *mon, const QDict *qdict)
105
{
106
    int dom, pci_bus;
107
    unsigned slot;
108
    int type;
109
    PCIDevice *dev;
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) {
118
        monitor_printf(mon, "Parameter addr not supported\n");
119
        goto err;
120
    }
121
    type = dinfo->type;
122

    
123
    switch (type) {
124
    case IF_SCSI:
125
        if (pci_read_devaddr(mon, pci_addr, &dom, &pci_bus, &slot)) {
126
            goto err;
127
        }
128
        dev = pci_find_device(pci_find_root_bus(0), pci_bus, slot, 0);
129
        if (!dev) {
130
            monitor_printf(mon, "no pci device with address %s\n", pci_addr);
131
            goto err;
132
        }
133
        if (scsi_hot_add(mon, &dev->qdev, dinfo, 1) != 0) {
134
            goto err;
135
        }
136
        break;
137
    case IF_NONE:
138
        monitor_printf(mon, "OK\n");
139
        break;
140
    default:
141
        monitor_printf(mon, "Can't hot-add drive to type %d\n", type);
142
        goto err;
143
    }
144
    return;
145

    
146
err:
147
    if (dinfo)
148
        drive_uninit(dinfo);
149
    return;
150
}
151

    
152
static PCIDevice *qemu_pci_hot_add_storage(Monitor *mon,
153
                                           const char *devaddr,
154
                                           const char *opts)
155
{
156
    PCIDevice *dev;
157
    DriveInfo *dinfo = NULL;
158
    int type = -1;
159
    char buf[128];
160
    PCIBus *bus;
161
    int devfn;
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;
168
        } else {
169
            monitor_printf(mon, "type %s not a hotpluggable PCI device.\n", buf);
170
            return NULL;
171
        }
172
    } else {
173
        monitor_printf(mon, "no if= specified\n");
174
        return NULL;
175
    }
176

    
177
    if (get_param_value(buf, sizeof(buf), "file", opts)) {
178
        dinfo = add_init_drive(opts);
179
        if (!dinfo)
180
            return NULL;
181
        if (dinfo->devaddr) {
182
            monitor_printf(mon, "Parameter addr not supported\n");
183
            return NULL;
184
        }
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");
196
        return NULL;
197
    }
198

    
199
    switch (type) {
200
    case IF_SCSI:
201
        dev = pci_create(bus, devfn, "lsi53c895a");
202
        if (qdev_init(&dev->qdev) < 0)
203
            dev = NULL;
204
        if (dev && dinfo) {
205
            if (scsi_hot_add(mon, &dev->qdev, dinfo, 0) != 0) {
206
                qdev_unplug(&dev->qdev);
207
                dev = NULL;
208
            }
209
        }
210
        break;
211
    case IF_VIRTIO:
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");
217
        qdev_prop_set_drive(&dev->qdev, "drive", dinfo);
218
        if (qdev_init(&dev->qdev) < 0)
219
            dev = NULL;
220
        break;
221
    default:
222
        dev = NULL;
223
    }
224
    return dev;
225
}
226

    
227
void pci_device_hot_add_print(Monitor *mon, const QObject *data)
228
{
229
    QDict *qdict;
230

    
231
    assert(qobject_type(data) == QTYPE_QDICT);
232
    qdict = qobject_to_qdict(data);
233

    
234
    monitor_printf(mon, "OK domain %d, bus %d, slot %d, function %d\n",
235
                   (int) qdict_get_int(qdict, "domain"),
236
                   (int) qdict_get_int(qdict, "bus"),
237
                   (int) qdict_get_int(qdict, "slot"),
238
                   (int) qdict_get_int(qdict, "function"));
239

    
240
}
241

    
242
/**
243
 * pci_device_hot_add(): Hot add a PCI device
244
 *
245
 * Return a QDict with the following device information:
246
 *
247
 * - "domain": domain number
248
 * - "bus": bus number
249
 * - "slot": slot number
250
 * - "function": function number
251
 *
252
 * Example:
253
 *
254
 * { "domain": 0, "bus": 0, "slot": 5, "function": 0 }
255
 */
256
int pci_device_hot_add(Monitor *mon, const QDict *qdict, QObject **ret_data)
257
{
258
    PCIDevice *dev = NULL;
259
    const char *pci_addr = qdict_get_str(qdict, "pci_addr");
260
    const char *type = qdict_get_str(qdict, "type");
261
    const char *opts = qdict_get_try_str(qdict, "opts");
262

    
263
    /* strip legacy tag */
264
    if (!strncmp(pci_addr, "pci_addr=", 9)) {
265
        pci_addr += 9;
266
    }
267

    
268
    if (!opts) {
269
        opts = "";
270
    }
271

    
272
    if (!strcmp(pci_addr, "auto"))
273
        pci_addr = NULL;
274

    
275
    if (strcmp(type, "nic") == 0) {
276
        dev = qemu_pci_hot_add_nic(mon, pci_addr, opts);
277
    } else if (strcmp(type, "storage") == 0) {
278
        dev = qemu_pci_hot_add_storage(mon, pci_addr, opts);
279
    } else {
280
        monitor_printf(mon, "invalid type: %s\n", type);
281
        return -1;
282
    }
283

    
284
    if (dev) {
285
        *ret_data =
286
        qobject_from_jsonf("{ 'domain': 0, 'bus': %d, 'slot': %d, "
287
                           "'function': %d }", pci_bus_num(dev->bus),
288
                           PCI_SLOT(dev->devfn), PCI_FUNC(dev->devfn));
289
    } else {
290
        monitor_printf(mon, "failed to add %s\n", opts);
291
        return -1;
292
    }
293

    
294
    return 0;
295
}
296
#endif
297

    
298
int pci_device_hot_remove(Monitor *mon, const char *pci_addr)
299
{
300
    PCIDevice *d;
301
    int dom, bus;
302
    unsigned slot;
303

    
304
    if (pci_read_devaddr(mon, pci_addr, &dom, &bus, &slot)) {
305
        return -1;
306
    }
307

    
308
    d = pci_find_device(pci_find_root_bus(0), bus, slot, 0);
309
    if (!d) {
310
        monitor_printf(mon, "slot %d empty\n", slot);
311
        return -1;
312
    }
313
    return qdev_unplug(&d->qdev);
314
}
315

    
316
int do_pci_device_hot_remove(Monitor *mon, const QDict *qdict,
317
                             QObject **ret_data)
318
{
319
    return pci_device_hot_remove(mon, qdict_get_str(qdict, "pci_addr"));
320
}