return TRUE;
}
+ qio_channel_set_name(QIO_CHANNEL(cioc), "nbd-server");
nbd_client_new(NULL, cioc,
nbd_server->tlscreds, NULL,
nbd_client_put);
nbd_server = g_new0(NBDServerData, 1);
nbd_server->watch = -1;
nbd_server->listen_ioc = qio_channel_socket_new();
+ qio_channel_set_name(QIO_CHANNEL(nbd_server->listen_ioc),
+ "nbd-listener");
if (qio_channel_socket_listen_sync(
nbd_server->listen_ioc, addr, errp) < 0) {
goto error;
void qmp_nbd_server_add(const char *device, bool has_writable, bool writable,
Error **errp)
{
- BlockBackend *blk;
+ BlockDriverState *bs = NULL;
+ BlockBackend *on_eject_blk;
NBDExport *exp;
if (!nbd_server) {
return;
}
- blk = blk_by_name(device);
- if (!blk) {
- error_set(errp, ERROR_CLASS_DEVICE_NOT_FOUND,
- "Device '%s' not found", device);
- return;
- }
- if (!blk_is_inserted(blk)) {
- error_setg(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
+ on_eject_blk = blk_by_name(device);
+
+ bs = bdrv_lookup_bs(device, device, errp);
+ if (!bs) {
return;
}
if (!has_writable) {
writable = false;
}
- if (blk_is_read_only(blk)) {
+ if (bdrv_is_read_only(bs)) {
writable = false;
}
- exp = nbd_export_new(blk_bs(blk), 0, -1, writable ? 0 : NBD_FLAG_READ_ONLY,
- NULL, false, blk, errp);
+ exp = nbd_export_new(bs, 0, -1, writable ? 0 : NBD_FLAG_READ_ONLY,
+ NULL, false, on_eject_blk, errp);
if (!exp) {
return;
}