1019d6b8fSAnthony Liguori /* 2019d6b8fSAnthony Liguori * QEMU Block driver for NBD 3019d6b8fSAnthony Liguori * 4019d6b8fSAnthony Liguori * Copyright (C) 2008 Bull S.A.S. 5019d6b8fSAnthony Liguori * Author: Laurent Vivier <Laurent.Vivier@bull.net> 6019d6b8fSAnthony Liguori * 7019d6b8fSAnthony Liguori * Some parts: 8019d6b8fSAnthony Liguori * Copyright (C) 2007 Anthony Liguori <anthony@codemonkey.ws> 9019d6b8fSAnthony Liguori * 10019d6b8fSAnthony Liguori * Permission is hereby granted, free of charge, to any person obtaining a copy 11019d6b8fSAnthony Liguori * of this software and associated documentation files (the "Software"), to deal 12019d6b8fSAnthony Liguori * in the Software without restriction, including without limitation the rights 13019d6b8fSAnthony Liguori * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 14019d6b8fSAnthony Liguori * copies of the Software, and to permit persons to whom the Software is 15019d6b8fSAnthony Liguori * furnished to do so, subject to the following conditions: 16019d6b8fSAnthony Liguori * 17019d6b8fSAnthony Liguori * The above copyright notice and this permission notice shall be included in 18019d6b8fSAnthony Liguori * all copies or substantial portions of the Software. 19019d6b8fSAnthony Liguori * 20019d6b8fSAnthony Liguori * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 21019d6b8fSAnthony Liguori * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 22019d6b8fSAnthony Liguori * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL 23019d6b8fSAnthony Liguori * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 24019d6b8fSAnthony Liguori * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 25019d6b8fSAnthony Liguori * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 26019d6b8fSAnthony Liguori * THE SOFTWARE. 27019d6b8fSAnthony Liguori */ 28019d6b8fSAnthony Liguori 292302c1caSMarc-André Lureau #include "block/nbd-client.h" 301de7afc9SPaolo Bonzini #include "qemu/uri.h" 31737e150eSPaolo Bonzini #include "block/block_int.h" 321de7afc9SPaolo Bonzini #include "qemu/module.h" 331de7afc9SPaolo Bonzini #include "qemu/sockets.h" 342019d68bSMax Reitz #include "qapi/qmp/qdict.h" 35f53a1febSKevin Wolf #include "qapi/qmp/qjson.h" 36f53a1febSKevin Wolf #include "qapi/qmp/qint.h" 372019d68bSMax Reitz #include "qapi/qmp/qstring.h" 38019d6b8fSAnthony Liguori 39019d6b8fSAnthony Liguori #include <sys/types.h> 40019d6b8fSAnthony Liguori #include <unistd.h> 41019d6b8fSAnthony Liguori 421d45f8b5SLaurent Vivier #define EN_OPTSTR ":exportname=" 431d45f8b5SLaurent Vivier 44019d6b8fSAnthony Liguori typedef struct BDRVNBDState { 452302c1caSMarc-André Lureau NbdClientSession client; 46019d6b8fSAnthony Liguori } BDRVNBDState; 47019d6b8fSAnthony Liguori 48f53a1febSKevin Wolf static int nbd_parse_uri(const char *filename, QDict *options) 491d7d2a9dSPaolo Bonzini { 501d7d2a9dSPaolo Bonzini URI *uri; 511d7d2a9dSPaolo Bonzini const char *p; 521d7d2a9dSPaolo Bonzini QueryParams *qp = NULL; 531d7d2a9dSPaolo Bonzini int ret = 0; 54f53a1febSKevin Wolf bool is_unix; 551d7d2a9dSPaolo Bonzini 561d7d2a9dSPaolo Bonzini uri = uri_parse(filename); 571d7d2a9dSPaolo Bonzini if (!uri) { 581d7d2a9dSPaolo Bonzini return -EINVAL; 591d7d2a9dSPaolo Bonzini } 601d7d2a9dSPaolo Bonzini 611d7d2a9dSPaolo Bonzini /* transport */ 621d7d2a9dSPaolo Bonzini if (!strcmp(uri->scheme, "nbd")) { 63f53a1febSKevin Wolf is_unix = false; 641d7d2a9dSPaolo Bonzini } else if (!strcmp(uri->scheme, "nbd+tcp")) { 65f53a1febSKevin Wolf is_unix = false; 661d7d2a9dSPaolo Bonzini } else if (!strcmp(uri->scheme, "nbd+unix")) { 67f53a1febSKevin Wolf is_unix = true; 681d7d2a9dSPaolo Bonzini } else { 691d7d2a9dSPaolo Bonzini ret = -EINVAL; 701d7d2a9dSPaolo Bonzini goto out; 711d7d2a9dSPaolo Bonzini } 721d7d2a9dSPaolo Bonzini 731d7d2a9dSPaolo Bonzini p = uri->path ? uri->path : "/"; 741d7d2a9dSPaolo Bonzini p += strspn(p, "/"); 751d7d2a9dSPaolo Bonzini if (p[0]) { 76f53a1febSKevin Wolf qdict_put(options, "export", qstring_from_str(p)); 771d7d2a9dSPaolo Bonzini } 781d7d2a9dSPaolo Bonzini 791d7d2a9dSPaolo Bonzini qp = query_params_parse(uri->query); 80f53a1febSKevin Wolf if (qp->n > 1 || (is_unix && !qp->n) || (!is_unix && qp->n)) { 811d7d2a9dSPaolo Bonzini ret = -EINVAL; 821d7d2a9dSPaolo Bonzini goto out; 831d7d2a9dSPaolo Bonzini } 841d7d2a9dSPaolo Bonzini 85f53a1febSKevin Wolf if (is_unix) { 861d7d2a9dSPaolo Bonzini /* nbd+unix:///export?socket=path */ 871d7d2a9dSPaolo Bonzini if (uri->server || uri->port || strcmp(qp->p[0].name, "socket")) { 881d7d2a9dSPaolo Bonzini ret = -EINVAL; 891d7d2a9dSPaolo Bonzini goto out; 901d7d2a9dSPaolo Bonzini } 91f53a1febSKevin Wolf qdict_put(options, "path", qstring_from_str(qp->p[0].value)); 921d7d2a9dSPaolo Bonzini } else { 9323307908SJán Tomko QString *host; 94bebbf7faSKevin Wolf /* nbd[+tcp]://host[:port]/export */ 951d7d2a9dSPaolo Bonzini if (!uri->server) { 961d7d2a9dSPaolo Bonzini ret = -EINVAL; 971d7d2a9dSPaolo Bonzini goto out; 981d7d2a9dSPaolo Bonzini } 99f17c90beSKevin Wolf 10023307908SJán Tomko /* strip braces from literal IPv6 address */ 10123307908SJán Tomko if (uri->server[0] == '[') { 10223307908SJán Tomko host = qstring_from_substr(uri->server, 1, 10323307908SJán Tomko strlen(uri->server) - 2); 10423307908SJán Tomko } else { 10523307908SJán Tomko host = qstring_from_str(uri->server); 10623307908SJán Tomko } 10723307908SJán Tomko 10823307908SJán Tomko qdict_put(options, "host", host); 109bebbf7faSKevin Wolf if (uri->port) { 110bebbf7faSKevin Wolf char* port_str = g_strdup_printf("%d", uri->port); 111f53a1febSKevin Wolf qdict_put(options, "port", qstring_from_str(port_str)); 112f53a1febSKevin Wolf g_free(port_str); 1131d7d2a9dSPaolo Bonzini } 114bebbf7faSKevin Wolf } 1151d7d2a9dSPaolo Bonzini 1161d7d2a9dSPaolo Bonzini out: 1171d7d2a9dSPaolo Bonzini if (qp) { 1181d7d2a9dSPaolo Bonzini query_params_free(qp); 1191d7d2a9dSPaolo Bonzini } 1201d7d2a9dSPaolo Bonzini uri_free(uri); 1211d7d2a9dSPaolo Bonzini return ret; 1221d7d2a9dSPaolo Bonzini } 1231d7d2a9dSPaolo Bonzini 1246963a30dSKevin Wolf static void nbd_parse_filename(const char *filename, QDict *options, 1256963a30dSKevin Wolf Error **errp) 126019d6b8fSAnthony Liguori { 1271d45f8b5SLaurent Vivier char *file; 12833897dc7SNick Thomas char *export_name; 12933897dc7SNick Thomas const char *host_spec; 130019d6b8fSAnthony Liguori const char *unixpath; 131019d6b8fSAnthony Liguori 132681e7ad0SKevin Wolf if (qdict_haskey(options, "host") 133681e7ad0SKevin Wolf || qdict_haskey(options, "port") 134681e7ad0SKevin Wolf || qdict_haskey(options, "path")) 135681e7ad0SKevin Wolf { 136681e7ad0SKevin Wolf error_setg(errp, "host/port/path and a file name may not be specified " 137681e7ad0SKevin Wolf "at the same time"); 138681e7ad0SKevin Wolf return; 139681e7ad0SKevin Wolf } 140681e7ad0SKevin Wolf 1411d7d2a9dSPaolo Bonzini if (strstr(filename, "://")) { 1426963a30dSKevin Wolf int ret = nbd_parse_uri(filename, options); 1436963a30dSKevin Wolf if (ret < 0) { 1446963a30dSKevin Wolf error_setg(errp, "No valid URL specified"); 1456963a30dSKevin Wolf } 1466963a30dSKevin Wolf return; 1471d7d2a9dSPaolo Bonzini } 1481d7d2a9dSPaolo Bonzini 1497267c094SAnthony Liguori file = g_strdup(filename); 1501d45f8b5SLaurent Vivier 15133897dc7SNick Thomas export_name = strstr(file, EN_OPTSTR); 15233897dc7SNick Thomas if (export_name) { 15333897dc7SNick Thomas if (export_name[strlen(EN_OPTSTR)] == 0) { 1541d45f8b5SLaurent Vivier goto out; 1551d45f8b5SLaurent Vivier } 15633897dc7SNick Thomas export_name[0] = 0; /* truncate 'file' */ 15733897dc7SNick Thomas export_name += strlen(EN_OPTSTR); 158f53a1febSKevin Wolf 159f53a1febSKevin Wolf qdict_put(options, "export", qstring_from_str(export_name)); 1601d45f8b5SLaurent Vivier } 1611d45f8b5SLaurent Vivier 16233897dc7SNick Thomas /* extract the host_spec - fail if it's not nbd:... */ 16333897dc7SNick Thomas if (!strstart(file, "nbd:", &host_spec)) { 1646963a30dSKevin Wolf error_setg(errp, "File name string for NBD must start with 'nbd:'"); 1651d45f8b5SLaurent Vivier goto out; 1661d45f8b5SLaurent Vivier } 167019d6b8fSAnthony Liguori 168f53a1febSKevin Wolf if (!*host_spec) { 169f53a1febSKevin Wolf goto out; 170f53a1febSKevin Wolf } 171f53a1febSKevin Wolf 17233897dc7SNick Thomas /* are we a UNIX or TCP socket? */ 17333897dc7SNick Thomas if (strstart(host_spec, "unix:", &unixpath)) { 174f53a1febSKevin Wolf qdict_put(options, "path", qstring_from_str(unixpath)); 175019d6b8fSAnthony Liguori } else { 176f53a1febSKevin Wolf InetSocketAddress *addr = NULL; 177f53a1febSKevin Wolf 1786963a30dSKevin Wolf addr = inet_parse(host_spec, errp); 17992de9012SMarkus Armbruster if (!addr) { 180f17c90beSKevin Wolf goto out; 181f17c90beSKevin Wolf } 182f53a1febSKevin Wolf 183f53a1febSKevin Wolf qdict_put(options, "host", qstring_from_str(addr->host)); 184f53a1febSKevin Wolf qdict_put(options, "port", qstring_from_str(addr->port)); 185f53a1febSKevin Wolf qapi_free_InetSocketAddress(addr); 1861d45f8b5SLaurent Vivier } 1871d45f8b5SLaurent Vivier 1881d45f8b5SLaurent Vivier out: 1897267c094SAnthony Liguori g_free(file); 19033897dc7SNick Thomas } 191f53a1febSKevin Wolf 1927a5ed437SDaniel P. Berrange static SocketAddress *nbd_config(BDRVNBDState *s, QDict *options, char **export, 19377e8b9caSPaolo Bonzini Error **errp) 194f53a1febSKevin Wolf { 1957a5ed437SDaniel P. Berrange SocketAddress *saddr; 196f53a1febSKevin Wolf 197a69d9af4SPaolo Bonzini if (qdict_haskey(options, "path") == qdict_haskey(options, "host")) { 198f53a1febSKevin Wolf if (qdict_haskey(options, "path")) { 19977e8b9caSPaolo Bonzini error_setg(errp, "path and host may not be used at the same time."); 200f53a1febSKevin Wolf } else { 20177e8b9caSPaolo Bonzini error_setg(errp, "one of path and host must be specified."); 202a69d9af4SPaolo Bonzini } 2037a5ed437SDaniel P. Berrange return NULL; 204019d6b8fSAnthony Liguori } 205019d6b8fSAnthony Liguori 2067a5ed437SDaniel P. Berrange saddr = g_new0(SocketAddress, 1); 207f53a1febSKevin Wolf 2087a5ed437SDaniel P. Berrange if (qdict_haskey(options, "path")) { 209*6a8f9661SEric Blake saddr->type = SOCKET_ADDRESS_KIND_UNIX; 210*6a8f9661SEric Blake saddr->u.q_unix = g_new0(UnixSocketAddress, 1); 211*6a8f9661SEric Blake saddr->u.q_unix->path = g_strdup(qdict_get_str(options, "path")); 2127a5ed437SDaniel P. Berrange qdict_del(options, "path"); 2137a5ed437SDaniel P. Berrange } else { 214*6a8f9661SEric Blake saddr->type = SOCKET_ADDRESS_KIND_INET; 215*6a8f9661SEric Blake saddr->u.inet = g_new0(InetSocketAddress, 1); 216*6a8f9661SEric Blake saddr->u.inet->host = g_strdup(qdict_get_str(options, "host")); 2177a5ed437SDaniel P. Berrange if (!qdict_get_try_str(options, "port")) { 218*6a8f9661SEric Blake saddr->u.inet->port = g_strdup_printf("%d", NBD_DEFAULT_PORT); 2197a5ed437SDaniel P. Berrange } else { 220*6a8f9661SEric Blake saddr->u.inet->port = g_strdup(qdict_get_str(options, "port")); 2217a5ed437SDaniel P. Berrange } 2227a5ed437SDaniel P. Berrange qdict_del(options, "host"); 2237a5ed437SDaniel P. Berrange qdict_del(options, "port"); 224f53a1febSKevin Wolf } 225f53a1febSKevin Wolf 226*6a8f9661SEric Blake s->client.is_unix = saddr->type == SOCKET_ADDRESS_KIND_UNIX; 227bebbf7faSKevin Wolf 228e2bc625fSMarc-André Lureau *export = g_strdup(qdict_get_try_str(options, "export")); 229e2bc625fSMarc-André Lureau if (*export) { 230f53a1febSKevin Wolf qdict_del(options, "export"); 231f53a1febSKevin Wolf } 2327a5ed437SDaniel P. Berrange 2337a5ed437SDaniel P. Berrange return saddr; 234f53a1febSKevin Wolf } 235f53a1febSKevin Wolf 236f53a829bSMax Reitz NbdClientSession *nbd_get_client_session(BlockDriverState *bs) 237f53a829bSMax Reitz { 238f53a829bSMax Reitz BDRVNBDState *s = bs->opaque; 239f53a829bSMax Reitz return &s->client; 240f53a829bSMax Reitz } 241f53a829bSMax Reitz 2427a5ed437SDaniel P. Berrange static int nbd_establish_connection(BlockDriverState *bs, 2437a5ed437SDaniel P. Berrange SocketAddress *saddr, 2447a5ed437SDaniel P. Berrange Error **errp) 24533897dc7SNick Thomas { 24633897dc7SNick Thomas BDRVNBDState *s = bs->opaque; 24733897dc7SNick Thomas int sock; 24833897dc7SNick Thomas 2497a5ed437SDaniel P. Berrange sock = socket_connect(saddr, errp, NULL, NULL); 25033897dc7SNick Thomas 251fc19f8a0SPaolo Bonzini if (sock < 0) { 25233897dc7SNick Thomas logout("Failed to establish connection to NBD server\n"); 2532b1f13b9SMax Reitz return -EIO; 25433897dc7SNick Thomas } 25533897dc7SNick Thomas 2567a5ed437SDaniel P. Berrange if (!s->client.is_unix) { 2577a5ed437SDaniel P. Berrange socket_set_nodelay(sock); 2587a5ed437SDaniel P. Berrange } 2597a5ed437SDaniel P. Berrange 2602302c1caSMarc-André Lureau return sock; 26133897dc7SNick Thomas } 26233897dc7SNick Thomas 263015a1036SMax Reitz static int nbd_open(BlockDriverState *bs, QDict *options, int flags, 264015a1036SMax Reitz Error **errp) 26533897dc7SNick Thomas { 26633897dc7SNick Thomas BDRVNBDState *s = bs->opaque; 267e2bc625fSMarc-André Lureau char *export = NULL; 2682302c1caSMarc-André Lureau int result, sock; 2697a5ed437SDaniel P. Berrange SocketAddress *saddr; 270ae255e52SPaolo Bonzini 27133897dc7SNick Thomas /* Pop the config into our state object. Exit if invalid. */ 2727a5ed437SDaniel P. Berrange saddr = nbd_config(s, options, &export, errp); 2737a5ed437SDaniel P. Berrange if (!saddr) { 27477e8b9caSPaolo Bonzini return -EINVAL; 27533897dc7SNick Thomas } 27633897dc7SNick Thomas 27733897dc7SNick Thomas /* establish TCP connection, return error if it fails 27833897dc7SNick Thomas * TODO: Configurable retry-until-timeout behaviour. 27933897dc7SNick Thomas */ 2807a5ed437SDaniel P. Berrange sock = nbd_establish_connection(bs, saddr, errp); 2817a5ed437SDaniel P. Berrange qapi_free_SocketAddress(saddr); 2822302c1caSMarc-André Lureau if (sock < 0) { 2839d0b65e6SGonglei g_free(export); 2842302c1caSMarc-André Lureau return sock; 28533897dc7SNick Thomas } 28633897dc7SNick Thomas 2872302c1caSMarc-André Lureau /* NBD handshake */ 288f53a829bSMax Reitz result = nbd_client_init(bs, sock, export, errp); 289e2bc625fSMarc-André Lureau g_free(export); 290e2bc625fSMarc-André Lureau return result; 291ae255e52SPaolo Bonzini } 292d9b09f13SPaolo Bonzini 293d9b09f13SPaolo Bonzini static int nbd_co_readv(BlockDriverState *bs, int64_t sector_num, 294d9b09f13SPaolo Bonzini int nb_sectors, QEMUIOVector *qiov) 295d9b09f13SPaolo Bonzini { 296f53a829bSMax Reitz return nbd_client_co_readv(bs, sector_num, nb_sectors, qiov); 297d9b09f13SPaolo Bonzini } 298d9b09f13SPaolo Bonzini 299d9b09f13SPaolo Bonzini static int nbd_co_writev(BlockDriverState *bs, int64_t sector_num, 300d9b09f13SPaolo Bonzini int nb_sectors, QEMUIOVector *qiov) 301d9b09f13SPaolo Bonzini { 302f53a829bSMax Reitz return nbd_client_co_writev(bs, sector_num, nb_sectors, qiov); 303d9b09f13SPaolo Bonzini } 304d9b09f13SPaolo Bonzini 3051486d04aSPaolo Bonzini static int nbd_co_flush(BlockDriverState *bs) 3061486d04aSPaolo Bonzini { 307f53a829bSMax Reitz return nbd_client_co_flush(bs); 3081486d04aSPaolo Bonzini } 3091486d04aSPaolo Bonzini 310fa21e6faSDenis V. Lunev static void nbd_refresh_limits(BlockDriverState *bs, Error **errp) 311fa21e6faSDenis V. Lunev { 312fa21e6faSDenis V. Lunev bs->bl.max_discard = UINT32_MAX >> BDRV_SECTOR_BITS; 313fa21e6faSDenis V. Lunev bs->bl.max_transfer_length = UINT32_MAX >> BDRV_SECTOR_BITS; 314fa21e6faSDenis V. Lunev } 315fa21e6faSDenis V. Lunev 3167a706633SPaolo Bonzini static int nbd_co_discard(BlockDriverState *bs, int64_t sector_num, 3177a706633SPaolo Bonzini int nb_sectors) 3187a706633SPaolo Bonzini { 319f53a829bSMax Reitz return nbd_client_co_discard(bs, sector_num, nb_sectors); 3207a706633SPaolo Bonzini } 3217a706633SPaolo Bonzini 322019d6b8fSAnthony Liguori static void nbd_close(BlockDriverState *bs) 323019d6b8fSAnthony Liguori { 324f53a829bSMax Reitz nbd_client_close(bs); 325019d6b8fSAnthony Liguori } 326019d6b8fSAnthony Liguori 327019d6b8fSAnthony Liguori static int64_t nbd_getlength(BlockDriverState *bs) 328019d6b8fSAnthony Liguori { 329019d6b8fSAnthony Liguori BDRVNBDState *s = bs->opaque; 330019d6b8fSAnthony Liguori 3312302c1caSMarc-André Lureau return s->client.size; 332019d6b8fSAnthony Liguori } 333019d6b8fSAnthony Liguori 33469447cd8SStefan Hajnoczi static void nbd_detach_aio_context(BlockDriverState *bs) 33569447cd8SStefan Hajnoczi { 336f53a829bSMax Reitz nbd_client_detach_aio_context(bs); 33769447cd8SStefan Hajnoczi } 33869447cd8SStefan Hajnoczi 33969447cd8SStefan Hajnoczi static void nbd_attach_aio_context(BlockDriverState *bs, 34069447cd8SStefan Hajnoczi AioContext *new_context) 34169447cd8SStefan Hajnoczi { 342f53a829bSMax Reitz nbd_client_attach_aio_context(bs, new_context); 34369447cd8SStefan Hajnoczi } 34469447cd8SStefan Hajnoczi 3452019d68bSMax Reitz static void nbd_refresh_filename(BlockDriverState *bs) 3462019d68bSMax Reitz { 3472019d68bSMax Reitz QDict *opts = qdict_new(); 348ec0de768SMax Reitz const char *path = qdict_get_try_str(bs->options, "path"); 349ec0de768SMax Reitz const char *host = qdict_get_try_str(bs->options, "host"); 350ec0de768SMax Reitz const char *port = qdict_get_try_str(bs->options, "port"); 351ec0de768SMax Reitz const char *export = qdict_get_try_str(bs->options, "export"); 3522019d68bSMax Reitz 3532019d68bSMax Reitz qdict_put_obj(opts, "driver", QOBJECT(qstring_from_str("nbd"))); 3542019d68bSMax Reitz 355ec0de768SMax Reitz if (path && export) { 356ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 357ec0de768SMax Reitz "nbd+unix:///%s?socket=%s", export, path); 358ec0de768SMax Reitz } else if (path && !export) { 359ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 360ec0de768SMax Reitz "nbd+unix://?socket=%s", path); 361ec0de768SMax Reitz } else if (!path && export && port) { 362ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 363ec0de768SMax Reitz "nbd://%s:%s/%s", host, port, export); 364ec0de768SMax Reitz } else if (!path && export && !port) { 365ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 366ec0de768SMax Reitz "nbd://%s/%s", host, export); 367ec0de768SMax Reitz } else if (!path && !export && port) { 368ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 369ec0de768SMax Reitz "nbd://%s:%s", host, port); 370ec0de768SMax Reitz } else if (!path && !export && !port) { 371ec0de768SMax Reitz snprintf(bs->exact_filename, sizeof(bs->exact_filename), 372ec0de768SMax Reitz "nbd://%s", host); 373ec0de768SMax Reitz } 374ec0de768SMax Reitz 3752019d68bSMax Reitz if (path) { 3762019d68bSMax Reitz qdict_put_obj(opts, "path", QOBJECT(qstring_from_str(path))); 377ec0de768SMax Reitz } else if (port) { 3782019d68bSMax Reitz qdict_put_obj(opts, "host", QOBJECT(qstring_from_str(host))); 3792019d68bSMax Reitz qdict_put_obj(opts, "port", QOBJECT(qstring_from_str(port))); 3802019d68bSMax Reitz } else { 3812019d68bSMax Reitz qdict_put_obj(opts, "host", QOBJECT(qstring_from_str(host))); 382ec0de768SMax Reitz } 383ec0de768SMax Reitz if (export) { 384ec0de768SMax Reitz qdict_put_obj(opts, "export", QOBJECT(qstring_from_str(export))); 3852019d68bSMax Reitz } 3862019d68bSMax Reitz 3872019d68bSMax Reitz bs->full_open_options = opts; 3882019d68bSMax Reitz } 3892019d68bSMax Reitz 390019d6b8fSAnthony Liguori static BlockDriver bdrv_nbd = { 391019d6b8fSAnthony Liguori .format_name = "nbd", 3921d7d2a9dSPaolo Bonzini .protocol_name = "nbd", 393019d6b8fSAnthony Liguori .instance_size = sizeof(BDRVNBDState), 3946963a30dSKevin Wolf .bdrv_parse_filename = nbd_parse_filename, 39566f82ceeSKevin Wolf .bdrv_file_open = nbd_open, 396ae255e52SPaolo Bonzini .bdrv_co_readv = nbd_co_readv, 397ae255e52SPaolo Bonzini .bdrv_co_writev = nbd_co_writev, 398019d6b8fSAnthony Liguori .bdrv_close = nbd_close, 3991486d04aSPaolo Bonzini .bdrv_co_flush_to_os = nbd_co_flush, 4007a706633SPaolo Bonzini .bdrv_co_discard = nbd_co_discard, 401fa21e6faSDenis V. Lunev .bdrv_refresh_limits = nbd_refresh_limits, 402019d6b8fSAnthony Liguori .bdrv_getlength = nbd_getlength, 40369447cd8SStefan Hajnoczi .bdrv_detach_aio_context = nbd_detach_aio_context, 40469447cd8SStefan Hajnoczi .bdrv_attach_aio_context = nbd_attach_aio_context, 4052019d68bSMax Reitz .bdrv_refresh_filename = nbd_refresh_filename, 4061d7d2a9dSPaolo Bonzini }; 4071d7d2a9dSPaolo Bonzini 4081d7d2a9dSPaolo Bonzini static BlockDriver bdrv_nbd_tcp = { 4091d7d2a9dSPaolo Bonzini .format_name = "nbd", 4101d7d2a9dSPaolo Bonzini .protocol_name = "nbd+tcp", 4111d7d2a9dSPaolo Bonzini .instance_size = sizeof(BDRVNBDState), 4126963a30dSKevin Wolf .bdrv_parse_filename = nbd_parse_filename, 4131d7d2a9dSPaolo Bonzini .bdrv_file_open = nbd_open, 4141d7d2a9dSPaolo Bonzini .bdrv_co_readv = nbd_co_readv, 4151d7d2a9dSPaolo Bonzini .bdrv_co_writev = nbd_co_writev, 4161d7d2a9dSPaolo Bonzini .bdrv_close = nbd_close, 4171d7d2a9dSPaolo Bonzini .bdrv_co_flush_to_os = nbd_co_flush, 4181d7d2a9dSPaolo Bonzini .bdrv_co_discard = nbd_co_discard, 419fa21e6faSDenis V. Lunev .bdrv_refresh_limits = nbd_refresh_limits, 4201d7d2a9dSPaolo Bonzini .bdrv_getlength = nbd_getlength, 42169447cd8SStefan Hajnoczi .bdrv_detach_aio_context = nbd_detach_aio_context, 42269447cd8SStefan Hajnoczi .bdrv_attach_aio_context = nbd_attach_aio_context, 4232019d68bSMax Reitz .bdrv_refresh_filename = nbd_refresh_filename, 4241d7d2a9dSPaolo Bonzini }; 4251d7d2a9dSPaolo Bonzini 4261d7d2a9dSPaolo Bonzini static BlockDriver bdrv_nbd_unix = { 4271d7d2a9dSPaolo Bonzini .format_name = "nbd", 4281d7d2a9dSPaolo Bonzini .protocol_name = "nbd+unix", 4291d7d2a9dSPaolo Bonzini .instance_size = sizeof(BDRVNBDState), 4306963a30dSKevin Wolf .bdrv_parse_filename = nbd_parse_filename, 4311d7d2a9dSPaolo Bonzini .bdrv_file_open = nbd_open, 4321d7d2a9dSPaolo Bonzini .bdrv_co_readv = nbd_co_readv, 4331d7d2a9dSPaolo Bonzini .bdrv_co_writev = nbd_co_writev, 4341d7d2a9dSPaolo Bonzini .bdrv_close = nbd_close, 4351d7d2a9dSPaolo Bonzini .bdrv_co_flush_to_os = nbd_co_flush, 4361d7d2a9dSPaolo Bonzini .bdrv_co_discard = nbd_co_discard, 437fa21e6faSDenis V. Lunev .bdrv_refresh_limits = nbd_refresh_limits, 4381d7d2a9dSPaolo Bonzini .bdrv_getlength = nbd_getlength, 43969447cd8SStefan Hajnoczi .bdrv_detach_aio_context = nbd_detach_aio_context, 44069447cd8SStefan Hajnoczi .bdrv_attach_aio_context = nbd_attach_aio_context, 4412019d68bSMax Reitz .bdrv_refresh_filename = nbd_refresh_filename, 442019d6b8fSAnthony Liguori }; 443019d6b8fSAnthony Liguori 444019d6b8fSAnthony Liguori static void bdrv_nbd_init(void) 445019d6b8fSAnthony Liguori { 446019d6b8fSAnthony Liguori bdrv_register(&bdrv_nbd); 4471d7d2a9dSPaolo Bonzini bdrv_register(&bdrv_nbd_tcp); 4481d7d2a9dSPaolo Bonzini bdrv_register(&bdrv_nbd_unix); 449019d6b8fSAnthony Liguori } 450019d6b8fSAnthony Liguori 451019d6b8fSAnthony Liguori block_init(bdrv_nbd_init); 452