16542aa9cSPeter Lieven /* 26542aa9cSPeter Lieven * QEMU Block driver for native access to files on NFS shares 36542aa9cSPeter Lieven * 46542aa9cSPeter Lieven * Copyright (c) 2014 Peter Lieven <pl@kamp.de> 56542aa9cSPeter Lieven * 66542aa9cSPeter Lieven * Permission is hereby granted, free of charge, to any person obtaining a copy 76542aa9cSPeter Lieven * of this software and associated documentation files (the "Software"), to deal 86542aa9cSPeter Lieven * in the Software without restriction, including without limitation the rights 96542aa9cSPeter Lieven * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 106542aa9cSPeter Lieven * copies of the Software, and to permit persons to whom the Software is 116542aa9cSPeter Lieven * furnished to do so, subject to the following conditions: 126542aa9cSPeter Lieven * 136542aa9cSPeter Lieven * The above copyright notice and this permission notice shall be included in 146542aa9cSPeter Lieven * all copies or substantial portions of the Software. 156542aa9cSPeter Lieven * 166542aa9cSPeter Lieven * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 176542aa9cSPeter Lieven * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 186542aa9cSPeter Lieven * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL 196542aa9cSPeter Lieven * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 206542aa9cSPeter Lieven * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 216542aa9cSPeter Lieven * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 226542aa9cSPeter Lieven * THE SOFTWARE. 236542aa9cSPeter Lieven */ 246542aa9cSPeter Lieven 256542aa9cSPeter Lieven #include "config-host.h" 266542aa9cSPeter Lieven 276542aa9cSPeter Lieven #include <poll.h> 286542aa9cSPeter Lieven #include "qemu-common.h" 296542aa9cSPeter Lieven #include "qemu/config-file.h" 306542aa9cSPeter Lieven #include "qemu/error-report.h" 316542aa9cSPeter Lieven #include "block/block_int.h" 326542aa9cSPeter Lieven #include "trace.h" 336542aa9cSPeter Lieven #include "qemu/iov.h" 346542aa9cSPeter Lieven #include "qemu/uri.h" 356542aa9cSPeter Lieven #include "sysemu/sysemu.h" 366542aa9cSPeter Lieven #include <nfsc/libnfs.h> 376542aa9cSPeter Lieven 386542aa9cSPeter Lieven typedef struct NFSClient { 396542aa9cSPeter Lieven struct nfs_context *context; 406542aa9cSPeter Lieven struct nfsfh *fh; 416542aa9cSPeter Lieven int events; 426542aa9cSPeter Lieven bool has_zero_init; 43471799d1SStefan Hajnoczi AioContext *aio_context; 446542aa9cSPeter Lieven } NFSClient; 456542aa9cSPeter Lieven 466542aa9cSPeter Lieven typedef struct NFSRPC { 476542aa9cSPeter Lieven int ret; 486542aa9cSPeter Lieven int complete; 496542aa9cSPeter Lieven QEMUIOVector *iov; 506542aa9cSPeter Lieven struct stat *st; 516542aa9cSPeter Lieven Coroutine *co; 526542aa9cSPeter Lieven QEMUBH *bh; 53471799d1SStefan Hajnoczi NFSClient *client; 546542aa9cSPeter Lieven } NFSRPC; 556542aa9cSPeter Lieven 566542aa9cSPeter Lieven static void nfs_process_read(void *arg); 576542aa9cSPeter Lieven static void nfs_process_write(void *arg); 586542aa9cSPeter Lieven 596542aa9cSPeter Lieven static void nfs_set_events(NFSClient *client) 606542aa9cSPeter Lieven { 616542aa9cSPeter Lieven int ev = nfs_which_events(client->context); 626542aa9cSPeter Lieven if (ev != client->events) { 63471799d1SStefan Hajnoczi aio_set_fd_handler(client->aio_context, 64471799d1SStefan Hajnoczi nfs_get_fd(client->context), 656542aa9cSPeter Lieven (ev & POLLIN) ? nfs_process_read : NULL, 666542aa9cSPeter Lieven (ev & POLLOUT) ? nfs_process_write : NULL, 676542aa9cSPeter Lieven client); 686542aa9cSPeter Lieven 696542aa9cSPeter Lieven } 706542aa9cSPeter Lieven client->events = ev; 716542aa9cSPeter Lieven } 726542aa9cSPeter Lieven 736542aa9cSPeter Lieven static void nfs_process_read(void *arg) 746542aa9cSPeter Lieven { 756542aa9cSPeter Lieven NFSClient *client = arg; 766542aa9cSPeter Lieven nfs_service(client->context, POLLIN); 776542aa9cSPeter Lieven nfs_set_events(client); 786542aa9cSPeter Lieven } 796542aa9cSPeter Lieven 806542aa9cSPeter Lieven static void nfs_process_write(void *arg) 816542aa9cSPeter Lieven { 826542aa9cSPeter Lieven NFSClient *client = arg; 836542aa9cSPeter Lieven nfs_service(client->context, POLLOUT); 846542aa9cSPeter Lieven nfs_set_events(client); 856542aa9cSPeter Lieven } 866542aa9cSPeter Lieven 876542aa9cSPeter Lieven static void nfs_co_init_task(NFSClient *client, NFSRPC *task) 886542aa9cSPeter Lieven { 896542aa9cSPeter Lieven *task = (NFSRPC) { 906542aa9cSPeter Lieven .co = qemu_coroutine_self(), 91471799d1SStefan Hajnoczi .client = client, 926542aa9cSPeter Lieven }; 936542aa9cSPeter Lieven } 946542aa9cSPeter Lieven 956542aa9cSPeter Lieven static void nfs_co_generic_bh_cb(void *opaque) 966542aa9cSPeter Lieven { 976542aa9cSPeter Lieven NFSRPC *task = opaque; 98a2c0fe2fSPeter Lieven task->complete = 1; 996542aa9cSPeter Lieven qemu_bh_delete(task->bh); 1006542aa9cSPeter Lieven qemu_coroutine_enter(task->co, NULL); 1016542aa9cSPeter Lieven } 1026542aa9cSPeter Lieven 1036542aa9cSPeter Lieven static void 1046542aa9cSPeter Lieven nfs_co_generic_cb(int ret, struct nfs_context *nfs, void *data, 1056542aa9cSPeter Lieven void *private_data) 1066542aa9cSPeter Lieven { 1076542aa9cSPeter Lieven NFSRPC *task = private_data; 1086542aa9cSPeter Lieven task->ret = ret; 1096542aa9cSPeter Lieven if (task->ret > 0 && task->iov) { 1106542aa9cSPeter Lieven if (task->ret <= task->iov->size) { 1116542aa9cSPeter Lieven qemu_iovec_from_buf(task->iov, 0, data, task->ret); 1126542aa9cSPeter Lieven } else { 1136542aa9cSPeter Lieven task->ret = -EIO; 1146542aa9cSPeter Lieven } 1156542aa9cSPeter Lieven } 1166542aa9cSPeter Lieven if (task->ret == 0 && task->st) { 1176542aa9cSPeter Lieven memcpy(task->st, data, sizeof(struct stat)); 1186542aa9cSPeter Lieven } 11920fccb18SPeter Lieven if (task->ret < 0) { 12020fccb18SPeter Lieven error_report("NFS Error: %s", nfs_get_error(nfs)); 12120fccb18SPeter Lieven } 1226542aa9cSPeter Lieven if (task->co) { 123471799d1SStefan Hajnoczi task->bh = aio_bh_new(task->client->aio_context, 124471799d1SStefan Hajnoczi nfs_co_generic_bh_cb, task); 1256542aa9cSPeter Lieven qemu_bh_schedule(task->bh); 126a2c0fe2fSPeter Lieven } else { 127a2c0fe2fSPeter Lieven task->complete = 1; 1286542aa9cSPeter Lieven } 1296542aa9cSPeter Lieven } 1306542aa9cSPeter Lieven 1316542aa9cSPeter Lieven static int coroutine_fn nfs_co_readv(BlockDriverState *bs, 1326542aa9cSPeter Lieven int64_t sector_num, int nb_sectors, 1336542aa9cSPeter Lieven QEMUIOVector *iov) 1346542aa9cSPeter Lieven { 1356542aa9cSPeter Lieven NFSClient *client = bs->opaque; 1366542aa9cSPeter Lieven NFSRPC task; 1376542aa9cSPeter Lieven 1386542aa9cSPeter Lieven nfs_co_init_task(client, &task); 1396542aa9cSPeter Lieven task.iov = iov; 1406542aa9cSPeter Lieven 1416542aa9cSPeter Lieven if (nfs_pread_async(client->context, client->fh, 1426542aa9cSPeter Lieven sector_num * BDRV_SECTOR_SIZE, 1436542aa9cSPeter Lieven nb_sectors * BDRV_SECTOR_SIZE, 1446542aa9cSPeter Lieven nfs_co_generic_cb, &task) != 0) { 1456542aa9cSPeter Lieven return -ENOMEM; 1466542aa9cSPeter Lieven } 1476542aa9cSPeter Lieven 1486542aa9cSPeter Lieven while (!task.complete) { 1496542aa9cSPeter Lieven nfs_set_events(client); 1506542aa9cSPeter Lieven qemu_coroutine_yield(); 1516542aa9cSPeter Lieven } 1526542aa9cSPeter Lieven 1536542aa9cSPeter Lieven if (task.ret < 0) { 1546542aa9cSPeter Lieven return task.ret; 1556542aa9cSPeter Lieven } 1566542aa9cSPeter Lieven 1576542aa9cSPeter Lieven /* zero pad short reads */ 1586542aa9cSPeter Lieven if (task.ret < iov->size) { 1596542aa9cSPeter Lieven qemu_iovec_memset(iov, task.ret, 0, iov->size - task.ret); 1606542aa9cSPeter Lieven } 1616542aa9cSPeter Lieven 1626542aa9cSPeter Lieven return 0; 1636542aa9cSPeter Lieven } 1646542aa9cSPeter Lieven 1656542aa9cSPeter Lieven static int coroutine_fn nfs_co_writev(BlockDriverState *bs, 1666542aa9cSPeter Lieven int64_t sector_num, int nb_sectors, 1676542aa9cSPeter Lieven QEMUIOVector *iov) 1686542aa9cSPeter Lieven { 1696542aa9cSPeter Lieven NFSClient *client = bs->opaque; 1706542aa9cSPeter Lieven NFSRPC task; 1716542aa9cSPeter Lieven char *buf = NULL; 1726542aa9cSPeter Lieven 1736542aa9cSPeter Lieven nfs_co_init_task(client, &task); 1746542aa9cSPeter Lieven 1756542aa9cSPeter Lieven buf = g_malloc(nb_sectors * BDRV_SECTOR_SIZE); 1766542aa9cSPeter Lieven qemu_iovec_to_buf(iov, 0, buf, nb_sectors * BDRV_SECTOR_SIZE); 1776542aa9cSPeter Lieven 1786542aa9cSPeter Lieven if (nfs_pwrite_async(client->context, client->fh, 1796542aa9cSPeter Lieven sector_num * BDRV_SECTOR_SIZE, 1806542aa9cSPeter Lieven nb_sectors * BDRV_SECTOR_SIZE, 1816542aa9cSPeter Lieven buf, nfs_co_generic_cb, &task) != 0) { 1826542aa9cSPeter Lieven g_free(buf); 1836542aa9cSPeter Lieven return -ENOMEM; 1846542aa9cSPeter Lieven } 1856542aa9cSPeter Lieven 1866542aa9cSPeter Lieven while (!task.complete) { 1876542aa9cSPeter Lieven nfs_set_events(client); 1886542aa9cSPeter Lieven qemu_coroutine_yield(); 1896542aa9cSPeter Lieven } 1906542aa9cSPeter Lieven 1916542aa9cSPeter Lieven g_free(buf); 1926542aa9cSPeter Lieven 1936542aa9cSPeter Lieven if (task.ret != nb_sectors * BDRV_SECTOR_SIZE) { 1946542aa9cSPeter Lieven return task.ret < 0 ? task.ret : -EIO; 1956542aa9cSPeter Lieven } 1966542aa9cSPeter Lieven 1976542aa9cSPeter Lieven return 0; 1986542aa9cSPeter Lieven } 1996542aa9cSPeter Lieven 2006542aa9cSPeter Lieven static int coroutine_fn nfs_co_flush(BlockDriverState *bs) 2016542aa9cSPeter Lieven { 2026542aa9cSPeter Lieven NFSClient *client = bs->opaque; 2036542aa9cSPeter Lieven NFSRPC task; 2046542aa9cSPeter Lieven 2056542aa9cSPeter Lieven nfs_co_init_task(client, &task); 2066542aa9cSPeter Lieven 2076542aa9cSPeter Lieven if (nfs_fsync_async(client->context, client->fh, nfs_co_generic_cb, 2086542aa9cSPeter Lieven &task) != 0) { 2096542aa9cSPeter Lieven return -ENOMEM; 2106542aa9cSPeter Lieven } 2116542aa9cSPeter Lieven 2126542aa9cSPeter Lieven while (!task.complete) { 2136542aa9cSPeter Lieven nfs_set_events(client); 2146542aa9cSPeter Lieven qemu_coroutine_yield(); 2156542aa9cSPeter Lieven } 2166542aa9cSPeter Lieven 2176542aa9cSPeter Lieven return task.ret; 2186542aa9cSPeter Lieven } 2196542aa9cSPeter Lieven 2206542aa9cSPeter Lieven /* TODO Convert to fine grained options */ 2216542aa9cSPeter Lieven static QemuOptsList runtime_opts = { 2226542aa9cSPeter Lieven .name = "nfs", 2236542aa9cSPeter Lieven .head = QTAILQ_HEAD_INITIALIZER(runtime_opts.head), 2246542aa9cSPeter Lieven .desc = { 2256542aa9cSPeter Lieven { 2266542aa9cSPeter Lieven .name = "filename", 2276542aa9cSPeter Lieven .type = QEMU_OPT_STRING, 2286542aa9cSPeter Lieven .help = "URL to the NFS file", 2296542aa9cSPeter Lieven }, 2306542aa9cSPeter Lieven { /* end of list */ } 2316542aa9cSPeter Lieven }, 2326542aa9cSPeter Lieven }; 2336542aa9cSPeter Lieven 234471799d1SStefan Hajnoczi static void nfs_detach_aio_context(BlockDriverState *bs) 235471799d1SStefan Hajnoczi { 236471799d1SStefan Hajnoczi NFSClient *client = bs->opaque; 237471799d1SStefan Hajnoczi 238471799d1SStefan Hajnoczi aio_set_fd_handler(client->aio_context, 239471799d1SStefan Hajnoczi nfs_get_fd(client->context), 240471799d1SStefan Hajnoczi NULL, NULL, NULL); 241471799d1SStefan Hajnoczi client->events = 0; 242471799d1SStefan Hajnoczi } 243471799d1SStefan Hajnoczi 244471799d1SStefan Hajnoczi static void nfs_attach_aio_context(BlockDriverState *bs, 245471799d1SStefan Hajnoczi AioContext *new_context) 246471799d1SStefan Hajnoczi { 247471799d1SStefan Hajnoczi NFSClient *client = bs->opaque; 248471799d1SStefan Hajnoczi 249471799d1SStefan Hajnoczi client->aio_context = new_context; 250471799d1SStefan Hajnoczi nfs_set_events(client); 251471799d1SStefan Hajnoczi } 252471799d1SStefan Hajnoczi 2536542aa9cSPeter Lieven static void nfs_client_close(NFSClient *client) 2546542aa9cSPeter Lieven { 2556542aa9cSPeter Lieven if (client->context) { 2566542aa9cSPeter Lieven if (client->fh) { 2576542aa9cSPeter Lieven nfs_close(client->context, client->fh); 2586542aa9cSPeter Lieven } 259471799d1SStefan Hajnoczi aio_set_fd_handler(client->aio_context, 260471799d1SStefan Hajnoczi nfs_get_fd(client->context), 261471799d1SStefan Hajnoczi NULL, NULL, NULL); 2626542aa9cSPeter Lieven nfs_destroy_context(client->context); 2636542aa9cSPeter Lieven } 2646542aa9cSPeter Lieven memset(client, 0, sizeof(NFSClient)); 2656542aa9cSPeter Lieven } 2666542aa9cSPeter Lieven 2676542aa9cSPeter Lieven static void nfs_file_close(BlockDriverState *bs) 2686542aa9cSPeter Lieven { 2696542aa9cSPeter Lieven NFSClient *client = bs->opaque; 2706542aa9cSPeter Lieven nfs_client_close(client); 2716542aa9cSPeter Lieven } 2726542aa9cSPeter Lieven 2736542aa9cSPeter Lieven static int64_t nfs_client_open(NFSClient *client, const char *filename, 2746542aa9cSPeter Lieven int flags, Error **errp) 2756542aa9cSPeter Lieven { 2766542aa9cSPeter Lieven int ret = -EINVAL, i; 2776542aa9cSPeter Lieven struct stat st; 2786542aa9cSPeter Lieven URI *uri; 2796542aa9cSPeter Lieven QueryParams *qp = NULL; 2806542aa9cSPeter Lieven char *file = NULL, *strp = NULL; 2816542aa9cSPeter Lieven 2826542aa9cSPeter Lieven uri = uri_parse(filename); 2836542aa9cSPeter Lieven if (!uri) { 2846542aa9cSPeter Lieven error_setg(errp, "Invalid URL specified"); 2856542aa9cSPeter Lieven goto fail; 2866542aa9cSPeter Lieven } 2875f4d5e1aSMax Reitz if (!uri->server) { 2885f4d5e1aSMax Reitz error_setg(errp, "Invalid URL specified"); 2895f4d5e1aSMax Reitz goto fail; 2905f4d5e1aSMax Reitz } 2916542aa9cSPeter Lieven strp = strrchr(uri->path, '/'); 2926542aa9cSPeter Lieven if (strp == NULL) { 2936542aa9cSPeter Lieven error_setg(errp, "Invalid URL specified"); 2946542aa9cSPeter Lieven goto fail; 2956542aa9cSPeter Lieven } 2966542aa9cSPeter Lieven file = g_strdup(strp); 2976542aa9cSPeter Lieven *strp = 0; 2986542aa9cSPeter Lieven 2996542aa9cSPeter Lieven client->context = nfs_init_context(); 3006542aa9cSPeter Lieven if (client->context == NULL) { 3016542aa9cSPeter Lieven error_setg(errp, "Failed to init NFS context"); 3026542aa9cSPeter Lieven goto fail; 3036542aa9cSPeter Lieven } 3046542aa9cSPeter Lieven 3056542aa9cSPeter Lieven qp = query_params_parse(uri->query); 3066542aa9cSPeter Lieven for (i = 0; i < qp->n; i++) { 3077c24384bSPeter Lieven unsigned long long val; 3086542aa9cSPeter Lieven if (!qp->p[i].value) { 3096542aa9cSPeter Lieven error_setg(errp, "Value for NFS parameter expected: %s", 3106542aa9cSPeter Lieven qp->p[i].name); 3116542aa9cSPeter Lieven goto fail; 3126542aa9cSPeter Lieven } 3137c24384bSPeter Lieven if (parse_uint_full(qp->p[i].value, &val, 0)) { 3147c24384bSPeter Lieven error_setg(errp, "Illegal value for NFS parameter: %s", 3157c24384bSPeter Lieven qp->p[i].name); 3167c24384bSPeter Lieven goto fail; 3177c24384bSPeter Lieven } 3187c24384bSPeter Lieven if (!strcmp(qp->p[i].name, "uid")) { 3197c24384bSPeter Lieven nfs_set_uid(client->context, val); 3207c24384bSPeter Lieven } else if (!strcmp(qp->p[i].name, "gid")) { 3217c24384bSPeter Lieven nfs_set_gid(client->context, val); 3227c24384bSPeter Lieven } else if (!strcmp(qp->p[i].name, "tcp-syncnt")) { 3237c24384bSPeter Lieven nfs_set_tcp_syncnt(client->context, val); 324*f42ca3caSPeter Lieven #ifdef LIBNFS_FEATURE_READAHEAD 325*f42ca3caSPeter Lieven } else if (!strcmp(qp->p[i].name, "readahead")) { 326*f42ca3caSPeter Lieven nfs_set_readahead(client->context, val); 327*f42ca3caSPeter Lieven #endif 3286542aa9cSPeter Lieven } else { 3296542aa9cSPeter Lieven error_setg(errp, "Unknown NFS parameter name: %s", 3306542aa9cSPeter Lieven qp->p[i].name); 3316542aa9cSPeter Lieven goto fail; 3326542aa9cSPeter Lieven } 3336542aa9cSPeter Lieven } 3346542aa9cSPeter Lieven 3356542aa9cSPeter Lieven ret = nfs_mount(client->context, uri->server, uri->path); 3366542aa9cSPeter Lieven if (ret < 0) { 3376542aa9cSPeter Lieven error_setg(errp, "Failed to mount nfs share: %s", 3386542aa9cSPeter Lieven nfs_get_error(client->context)); 3396542aa9cSPeter Lieven goto fail; 3406542aa9cSPeter Lieven } 3416542aa9cSPeter Lieven 3426542aa9cSPeter Lieven if (flags & O_CREAT) { 3436542aa9cSPeter Lieven ret = nfs_creat(client->context, file, 0600, &client->fh); 3446542aa9cSPeter Lieven if (ret < 0) { 3456542aa9cSPeter Lieven error_setg(errp, "Failed to create file: %s", 3466542aa9cSPeter Lieven nfs_get_error(client->context)); 3476542aa9cSPeter Lieven goto fail; 3486542aa9cSPeter Lieven } 3496542aa9cSPeter Lieven } else { 3506542aa9cSPeter Lieven ret = nfs_open(client->context, file, flags, &client->fh); 3516542aa9cSPeter Lieven if (ret < 0) { 3526542aa9cSPeter Lieven error_setg(errp, "Failed to open file : %s", 3536542aa9cSPeter Lieven nfs_get_error(client->context)); 3546542aa9cSPeter Lieven goto fail; 3556542aa9cSPeter Lieven } 3566542aa9cSPeter Lieven } 3576542aa9cSPeter Lieven 3586542aa9cSPeter Lieven ret = nfs_fstat(client->context, client->fh, &st); 3596542aa9cSPeter Lieven if (ret < 0) { 3606542aa9cSPeter Lieven error_setg(errp, "Failed to fstat file: %s", 3616542aa9cSPeter Lieven nfs_get_error(client->context)); 3626542aa9cSPeter Lieven goto fail; 3636542aa9cSPeter Lieven } 3646542aa9cSPeter Lieven 3656542aa9cSPeter Lieven ret = DIV_ROUND_UP(st.st_size, BDRV_SECTOR_SIZE); 3666542aa9cSPeter Lieven client->has_zero_init = S_ISREG(st.st_mode); 3676542aa9cSPeter Lieven goto out; 3686542aa9cSPeter Lieven fail: 3696542aa9cSPeter Lieven nfs_client_close(client); 3706542aa9cSPeter Lieven out: 3716542aa9cSPeter Lieven if (qp) { 3726542aa9cSPeter Lieven query_params_free(qp); 3736542aa9cSPeter Lieven } 3746542aa9cSPeter Lieven uri_free(uri); 3756542aa9cSPeter Lieven g_free(file); 3766542aa9cSPeter Lieven return ret; 3776542aa9cSPeter Lieven } 3786542aa9cSPeter Lieven 3796542aa9cSPeter Lieven static int nfs_file_open(BlockDriverState *bs, QDict *options, int flags, 3806542aa9cSPeter Lieven Error **errp) { 3816542aa9cSPeter Lieven NFSClient *client = bs->opaque; 3826542aa9cSPeter Lieven int64_t ret; 3836542aa9cSPeter Lieven QemuOpts *opts; 3846542aa9cSPeter Lieven Error *local_err = NULL; 3856542aa9cSPeter Lieven 386471799d1SStefan Hajnoczi client->aio_context = bdrv_get_aio_context(bs); 387471799d1SStefan Hajnoczi 3886542aa9cSPeter Lieven opts = qemu_opts_create(&runtime_opts, NULL, 0, &error_abort); 3896542aa9cSPeter Lieven qemu_opts_absorb_qdict(opts, options, &local_err); 3900fb6395cSMarkus Armbruster if (local_err) { 3916542aa9cSPeter Lieven error_propagate(errp, local_err); 3926542aa9cSPeter Lieven return -EINVAL; 3936542aa9cSPeter Lieven } 3946542aa9cSPeter Lieven ret = nfs_client_open(client, qemu_opt_get(opts, "filename"), 3956542aa9cSPeter Lieven (flags & BDRV_O_RDWR) ? O_RDWR : O_RDONLY, 3966542aa9cSPeter Lieven errp); 3976542aa9cSPeter Lieven if (ret < 0) { 3986542aa9cSPeter Lieven return ret; 3996542aa9cSPeter Lieven } 4006542aa9cSPeter Lieven bs->total_sectors = ret; 4016542aa9cSPeter Lieven return 0; 4026542aa9cSPeter Lieven } 4036542aa9cSPeter Lieven 40498c10b81SChunyan Liu static int nfs_file_create(const char *url, QemuOpts *opts, Error **errp) 4056542aa9cSPeter Lieven { 4066542aa9cSPeter Lieven int ret = 0; 4076542aa9cSPeter Lieven int64_t total_size = 0; 4086542aa9cSPeter Lieven NFSClient *client = g_malloc0(sizeof(NFSClient)); 4096542aa9cSPeter Lieven 410471799d1SStefan Hajnoczi client->aio_context = qemu_get_aio_context(); 411471799d1SStefan Hajnoczi 4126542aa9cSPeter Lieven /* Read out options */ 41398c10b81SChunyan Liu total_size = qemu_opt_get_size_del(opts, BLOCK_OPT_SIZE, 0); 4146542aa9cSPeter Lieven 4156542aa9cSPeter Lieven ret = nfs_client_open(client, url, O_CREAT, errp); 4166542aa9cSPeter Lieven if (ret < 0) { 4176542aa9cSPeter Lieven goto out; 4186542aa9cSPeter Lieven } 4196542aa9cSPeter Lieven ret = nfs_ftruncate(client->context, client->fh, total_size); 4206542aa9cSPeter Lieven nfs_client_close(client); 4216542aa9cSPeter Lieven out: 4226542aa9cSPeter Lieven g_free(client); 4236542aa9cSPeter Lieven return ret; 4246542aa9cSPeter Lieven } 4256542aa9cSPeter Lieven 4266542aa9cSPeter Lieven static int nfs_has_zero_init(BlockDriverState *bs) 4276542aa9cSPeter Lieven { 4286542aa9cSPeter Lieven NFSClient *client = bs->opaque; 4296542aa9cSPeter Lieven return client->has_zero_init; 4306542aa9cSPeter Lieven } 4316542aa9cSPeter Lieven 4326542aa9cSPeter Lieven static int64_t nfs_get_allocated_file_size(BlockDriverState *bs) 4336542aa9cSPeter Lieven { 4346542aa9cSPeter Lieven NFSClient *client = bs->opaque; 4356542aa9cSPeter Lieven NFSRPC task = {0}; 4366542aa9cSPeter Lieven struct stat st; 4376542aa9cSPeter Lieven 4386542aa9cSPeter Lieven task.st = &st; 4396542aa9cSPeter Lieven if (nfs_fstat_async(client->context, client->fh, nfs_co_generic_cb, 4406542aa9cSPeter Lieven &task) != 0) { 4416542aa9cSPeter Lieven return -ENOMEM; 4426542aa9cSPeter Lieven } 4436542aa9cSPeter Lieven 4446542aa9cSPeter Lieven while (!task.complete) { 4456542aa9cSPeter Lieven nfs_set_events(client); 446471799d1SStefan Hajnoczi aio_poll(client->aio_context, true); 4476542aa9cSPeter Lieven } 4486542aa9cSPeter Lieven 4496542aa9cSPeter Lieven return (task.ret < 0 ? task.ret : st.st_blocks * st.st_blksize); 4506542aa9cSPeter Lieven } 4516542aa9cSPeter Lieven 4526542aa9cSPeter Lieven static int nfs_file_truncate(BlockDriverState *bs, int64_t offset) 4536542aa9cSPeter Lieven { 4546542aa9cSPeter Lieven NFSClient *client = bs->opaque; 4556542aa9cSPeter Lieven return nfs_ftruncate(client->context, client->fh, offset); 4566542aa9cSPeter Lieven } 4576542aa9cSPeter Lieven 4586542aa9cSPeter Lieven static BlockDriver bdrv_nfs = { 4596542aa9cSPeter Lieven .format_name = "nfs", 4606542aa9cSPeter Lieven .protocol_name = "nfs", 4616542aa9cSPeter Lieven 4626542aa9cSPeter Lieven .instance_size = sizeof(NFSClient), 4636542aa9cSPeter Lieven .bdrv_needs_filename = true, 4646542aa9cSPeter Lieven .bdrv_has_zero_init = nfs_has_zero_init, 4656542aa9cSPeter Lieven .bdrv_get_allocated_file_size = nfs_get_allocated_file_size, 4666542aa9cSPeter Lieven .bdrv_truncate = nfs_file_truncate, 4676542aa9cSPeter Lieven 4686542aa9cSPeter Lieven .bdrv_file_open = nfs_file_open, 4696542aa9cSPeter Lieven .bdrv_close = nfs_file_close, 470c282e1fdSChunyan Liu .bdrv_create = nfs_file_create, 4716542aa9cSPeter Lieven 4726542aa9cSPeter Lieven .bdrv_co_readv = nfs_co_readv, 4736542aa9cSPeter Lieven .bdrv_co_writev = nfs_co_writev, 4746542aa9cSPeter Lieven .bdrv_co_flush_to_disk = nfs_co_flush, 475471799d1SStefan Hajnoczi 476471799d1SStefan Hajnoczi .bdrv_detach_aio_context = nfs_detach_aio_context, 477471799d1SStefan Hajnoczi .bdrv_attach_aio_context = nfs_attach_aio_context, 4786542aa9cSPeter Lieven }; 4796542aa9cSPeter Lieven 4806542aa9cSPeter Lieven static void nfs_block_init(void) 4816542aa9cSPeter Lieven { 4826542aa9cSPeter Lieven bdrv_register(&bdrv_nfs); 4836542aa9cSPeter Lieven } 4846542aa9cSPeter Lieven 4856542aa9cSPeter Lieven block_init(nfs_block_init); 486