2014-02-03 09:26:13 +00:00
|
|
|
/*
|
|
|
|
* QEMU Block driver for native access to files on NFS shares
|
|
|
|
*
|
2017-11-27 16:00:07 +00:00
|
|
|
* Copyright (c) 2014-2017 Peter Lieven <pl@kamp.de>
|
2014-02-03 09:26:13 +00:00
|
|
|
*
|
|
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
|
|
* of this software and associated documentation files (the "Software"), to deal
|
|
|
|
* in the Software without restriction, including without limitation the rights
|
|
|
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
|
|
* copies of the Software, and to permit persons to whom the Software is
|
|
|
|
* furnished to do so, subject to the following conditions:
|
|
|
|
*
|
|
|
|
* The above copyright notice and this permission notice shall be included in
|
|
|
|
* all copies or substantial portions of the Software.
|
|
|
|
*
|
|
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
|
|
|
|
* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
|
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
|
|
* THE SOFTWARE.
|
|
|
|
*/
|
|
|
|
|
2016-01-18 18:01:42 +00:00
|
|
|
#include "qemu/osdep.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
|
|
|
|
#include <poll.h>
|
|
|
|
#include "qemu/config-file.h"
|
|
|
|
#include "qemu/error-report.h"
|
2016-03-30 12:46:33 +00:00
|
|
|
#include "qapi/error.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
#include "block/block_int.h"
|
2018-06-14 19:14:28 +00:00
|
|
|
#include "block/qdict.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
#include "trace.h"
|
|
|
|
#include "qemu/iov.h"
|
2018-02-01 11:18:46 +00:00
|
|
|
#include "qemu/option.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
#include "qemu/uri.h"
|
2016-03-30 12:46:34 +00:00
|
|
|
#include "qemu/cutils.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
#include "sysemu/sysemu.h"
|
2018-02-11 09:36:01 +00:00
|
|
|
#include "qapi/qapi-visit-block-core.h"
|
2016-10-31 15:05:49 +00:00
|
|
|
#include "qapi/qmp/qdict.h"
|
|
|
|
#include "qapi/qmp/qstring.h"
|
|
|
|
#include "qapi/qobject-input-visitor.h"
|
|
|
|
#include "qapi/qobject-output-visitor.h"
|
2014-02-03 09:26:13 +00:00
|
|
|
#include <nfsc/libnfs.h>
|
|
|
|
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2015-06-26 11:14:01 +00:00
|
|
|
#define QEMU_NFS_MAX_READAHEAD_SIZE 1048576
|
2016-05-19 12:48:03 +00:00
|
|
|
#define QEMU_NFS_MAX_PAGECACHE_SIZE (8388608 / NFS_BLKSIZE)
|
2015-11-09 07:09:33 +00:00
|
|
|
#define QEMU_NFS_MAX_DEBUG_LEVEL 2
|
2015-06-26 11:14:01 +00:00
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
typedef struct NFSClient {
|
|
|
|
struct nfs_context *context;
|
|
|
|
struct nfsfh *fh;
|
|
|
|
int events;
|
|
|
|
bool has_zero_init;
|
2014-05-08 14:34:44 +00:00
|
|
|
AioContext *aio_context;
|
2017-02-22 18:07:24 +00:00
|
|
|
QemuMutex mutex;
|
2015-08-27 10:30:41 +00:00
|
|
|
blkcnt_t st_blocks;
|
2016-05-19 12:48:02 +00:00
|
|
|
bool cache_used;
|
2016-10-31 15:05:49 +00:00
|
|
|
NFSServer *server;
|
|
|
|
char *path;
|
|
|
|
int64_t uid, gid, tcp_syncnt, readahead, pagecache, debug;
|
2014-02-03 09:26:13 +00:00
|
|
|
} NFSClient;
|
|
|
|
|
|
|
|
typedef struct NFSRPC {
|
2016-10-27 10:48:57 +00:00
|
|
|
BlockDriverState *bs;
|
2014-02-03 09:26:13 +00:00
|
|
|
int ret;
|
|
|
|
int complete;
|
|
|
|
QEMUIOVector *iov;
|
|
|
|
struct stat *st;
|
|
|
|
Coroutine *co;
|
2014-05-08 14:34:44 +00:00
|
|
|
NFSClient *client;
|
2014-02-03 09:26:13 +00:00
|
|
|
} NFSRPC;
|
|
|
|
|
2016-10-31 15:05:49 +00:00
|
|
|
static int nfs_parse_uri(const char *filename, QDict *options, Error **errp)
|
|
|
|
{
|
|
|
|
URI *uri = NULL;
|
|
|
|
QueryParams *qp = NULL;
|
|
|
|
int ret = -EINVAL, i;
|
|
|
|
|
|
|
|
uri = uri_parse(filename);
|
|
|
|
if (!uri) {
|
|
|
|
error_setg(errp, "Invalid URI specified");
|
|
|
|
goto out;
|
|
|
|
}
|
2017-06-13 20:57:26 +00:00
|
|
|
if (g_strcmp0(uri->scheme, "nfs") != 0) {
|
2016-10-31 15:05:49 +00:00
|
|
|
error_setg(errp, "URI scheme must be 'nfs'");
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!uri->server) {
|
|
|
|
error_setg(errp, "missing hostname in URI");
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!uri->path) {
|
|
|
|
error_setg(errp, "missing file path in URI");
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
qp = query_params_parse(uri->query);
|
|
|
|
if (!qp) {
|
|
|
|
error_setg(errp, "could not parse query parameters");
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "server.host", uri->server);
|
|
|
|
qdict_put_str(options, "server.type", "inet");
|
|
|
|
qdict_put_str(options, "path", uri->path);
|
2016-10-31 15:05:49 +00:00
|
|
|
|
|
|
|
for (i = 0; i < qp->n; i++) {
|
2017-02-01 09:53:48 +00:00
|
|
|
unsigned long long val;
|
2016-10-31 15:05:49 +00:00
|
|
|
if (!qp->p[i].value) {
|
|
|
|
error_setg(errp, "Value for NFS parameter expected: %s",
|
|
|
|
qp->p[i].name);
|
|
|
|
goto out;
|
|
|
|
}
|
2017-02-01 09:53:48 +00:00
|
|
|
if (parse_uint_full(qp->p[i].value, &val, 0)) {
|
2016-10-31 15:05:49 +00:00
|
|
|
error_setg(errp, "Illegal value for NFS parameter: %s",
|
|
|
|
qp->p[i].name);
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
if (!strcmp(qp->p[i].name, "uid")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "user", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else if (!strcmp(qp->p[i].name, "gid")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "group", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else if (!strcmp(qp->p[i].name, "tcp-syncnt")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "tcp-syn-count", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else if (!strcmp(qp->p[i].name, "readahead")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "readahead-size", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else if (!strcmp(qp->p[i].name, "pagecache")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "page-cache-size", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else if (!strcmp(qp->p[i].name, "debug")) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(options, "debug", qp->p[i].value);
|
2016-10-31 15:05:49 +00:00
|
|
|
} else {
|
|
|
|
error_setg(errp, "Unknown NFS parameter name: %s",
|
|
|
|
qp->p[i].name);
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ret = 0;
|
|
|
|
out:
|
|
|
|
if (qp) {
|
|
|
|
query_params_free(qp);
|
|
|
|
}
|
|
|
|
if (uri) {
|
|
|
|
uri_free(uri);
|
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static bool nfs_has_filename_options_conflict(QDict *options, Error **errp)
|
|
|
|
{
|
|
|
|
const QDictEntry *qe;
|
|
|
|
|
|
|
|
for (qe = qdict_first(options); qe; qe = qdict_next(options, qe)) {
|
|
|
|
if (!strcmp(qe->key, "host") ||
|
|
|
|
!strcmp(qe->key, "path") ||
|
|
|
|
!strcmp(qe->key, "user") ||
|
|
|
|
!strcmp(qe->key, "group") ||
|
|
|
|
!strcmp(qe->key, "tcp-syn-count") ||
|
|
|
|
!strcmp(qe->key, "readahead-size") ||
|
|
|
|
!strcmp(qe->key, "page-cache-size") ||
|
2016-11-02 16:50:37 +00:00
|
|
|
!strcmp(qe->key, "debug") ||
|
2016-10-31 15:05:49 +00:00
|
|
|
strstart(qe->key, "server.", NULL))
|
|
|
|
{
|
|
|
|
error_setg(errp, "Option %s cannot be used with a filename",
|
|
|
|
qe->key);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_parse_filename(const char *filename, QDict *options,
|
|
|
|
Error **errp)
|
|
|
|
{
|
|
|
|
if (nfs_has_filename_options_conflict(options, errp)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
nfs_parse_uri(filename, options, errp);
|
|
|
|
}
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
static void nfs_process_read(void *arg);
|
|
|
|
static void nfs_process_write(void *arg);
|
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
/* Called with QemuMutex held. */
|
2014-02-03 09:26:13 +00:00
|
|
|
static void nfs_set_events(NFSClient *client)
|
|
|
|
{
|
|
|
|
int ev = nfs_which_events(client->context);
|
|
|
|
if (ev != client->events) {
|
2015-10-23 03:08:05 +00:00
|
|
|
aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context),
|
|
|
|
false,
|
2014-05-08 14:34:44 +00:00
|
|
|
(ev & POLLIN) ? nfs_process_read : NULL,
|
2016-12-01 19:26:41 +00:00
|
|
|
(ev & POLLOUT) ? nfs_process_write : NULL,
|
|
|
|
NULL, client);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
|
|
|
}
|
|
|
|
client->events = ev;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_process_read(void *arg)
|
|
|
|
{
|
|
|
|
NFSClient *client = arg;
|
2017-02-13 13:52:30 +00:00
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_lock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
nfs_service(client->context, POLLIN);
|
|
|
|
nfs_set_events(client);
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_process_write(void *arg)
|
|
|
|
{
|
|
|
|
NFSClient *client = arg;
|
2017-02-13 13:52:30 +00:00
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_lock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
nfs_service(client->context, POLLOUT);
|
|
|
|
nfs_set_events(client);
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:57 +00:00
|
|
|
static void nfs_co_init_task(BlockDriverState *bs, NFSRPC *task)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
|
|
|
*task = (NFSRPC) {
|
2014-05-08 14:34:44 +00:00
|
|
|
.co = qemu_coroutine_self(),
|
2016-10-27 10:48:57 +00:00
|
|
|
.bs = bs,
|
|
|
|
.client = bs->opaque,
|
2014-02-03 09:26:13 +00:00
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_co_generic_bh_cb(void *opaque)
|
|
|
|
{
|
|
|
|
NFSRPC *task = opaque;
|
2017-02-13 13:52:31 +00:00
|
|
|
|
2014-06-10 07:42:47 +00:00
|
|
|
task->complete = 1;
|
2017-02-13 13:52:31 +00:00
|
|
|
aio_co_wake(task->co);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
/* Called (via nfs_service) with QemuMutex held. */
|
2014-02-03 09:26:13 +00:00
|
|
|
static void
|
|
|
|
nfs_co_generic_cb(int ret, struct nfs_context *nfs, void *data,
|
|
|
|
void *private_data)
|
|
|
|
{
|
|
|
|
NFSRPC *task = private_data;
|
|
|
|
task->ret = ret;
|
2016-10-27 10:48:57 +00:00
|
|
|
assert(!task->st);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (task->ret > 0 && task->iov) {
|
|
|
|
if (task->ret <= task->iov->size) {
|
|
|
|
qemu_iovec_from_buf(task->iov, 0, data, task->ret);
|
|
|
|
} else {
|
|
|
|
task->ret = -EIO;
|
|
|
|
}
|
|
|
|
}
|
2014-03-17 08:37:21 +00:00
|
|
|
if (task->ret < 0) {
|
|
|
|
error_report("NFS Error: %s", nfs_get_error(nfs));
|
|
|
|
}
|
2016-10-27 10:48:57 +00:00
|
|
|
aio_bh_schedule_oneshot(task->client->aio_context,
|
|
|
|
nfs_co_generic_bh_cb, task);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2017-02-17 16:39:00 +00:00
|
|
|
static int coroutine_fn nfs_co_preadv(BlockDriverState *bs, uint64_t offset,
|
|
|
|
uint64_t bytes, QEMUIOVector *iov,
|
|
|
|
int flags)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
NFSRPC task;
|
|
|
|
|
2016-10-27 10:48:57 +00:00
|
|
|
nfs_co_init_task(bs, &task);
|
2014-02-03 09:26:13 +00:00
|
|
|
task.iov = iov;
|
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_lock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (nfs_pread_async(client->context, client->fh,
|
2017-02-17 16:39:00 +00:00
|
|
|
offset, bytes, nfs_co_generic_cb, &task) != 0) {
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:56 +00:00
|
|
|
nfs_set_events(client);
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
while (!task.complete) {
|
|
|
|
qemu_coroutine_yield();
|
|
|
|
}
|
|
|
|
|
|
|
|
if (task.ret < 0) {
|
|
|
|
return task.ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* zero pad short reads */
|
|
|
|
if (task.ret < iov->size) {
|
|
|
|
qemu_iovec_memset(iov, task.ret, 0, iov->size - task.ret);
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2017-02-17 16:39:00 +00:00
|
|
|
static int coroutine_fn nfs_co_pwritev(BlockDriverState *bs, uint64_t offset,
|
|
|
|
uint64_t bytes, QEMUIOVector *iov,
|
|
|
|
int flags)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
NFSRPC task;
|
|
|
|
char *buf = NULL;
|
2017-02-17 16:39:01 +00:00
|
|
|
bool my_buffer = false;
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2016-10-27 10:48:57 +00:00
|
|
|
nfs_co_init_task(bs, &task);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2017-02-17 16:39:01 +00:00
|
|
|
if (iov->niov != 1) {
|
|
|
|
buf = g_try_malloc(bytes);
|
|
|
|
if (bytes && buf == NULL) {
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
qemu_iovec_to_buf(iov, 0, buf, bytes);
|
|
|
|
my_buffer = true;
|
|
|
|
} else {
|
|
|
|
buf = iov->iov[0].iov_base;
|
2014-05-20 11:31:20 +00:00
|
|
|
}
|
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_lock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (nfs_pwrite_async(client->context, client->fh,
|
2017-02-17 16:39:00 +00:00
|
|
|
offset, bytes, buf,
|
|
|
|
nfs_co_generic_cb, &task) != 0) {
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2017-02-17 16:39:01 +00:00
|
|
|
if (my_buffer) {
|
|
|
|
g_free(buf);
|
|
|
|
}
|
2014-02-03 09:26:13 +00:00
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:56 +00:00
|
|
|
nfs_set_events(client);
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
while (!task.complete) {
|
|
|
|
qemu_coroutine_yield();
|
|
|
|
}
|
|
|
|
|
2017-02-17 16:39:01 +00:00
|
|
|
if (my_buffer) {
|
|
|
|
g_free(buf);
|
|
|
|
}
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2017-02-17 16:39:00 +00:00
|
|
|
if (task.ret != bytes) {
|
2014-02-03 09:26:13 +00:00
|
|
|
return task.ret < 0 ? task.ret : -EIO;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int coroutine_fn nfs_co_flush(BlockDriverState *bs)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
NFSRPC task;
|
|
|
|
|
2016-10-27 10:48:57 +00:00
|
|
|
nfs_co_init_task(bs, &task);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_lock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (nfs_fsync_async(client->context, client->fh, nfs_co_generic_cb,
|
|
|
|
&task) != 0) {
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:56 +00:00
|
|
|
nfs_set_events(client);
|
2017-02-22 18:07:24 +00:00
|
|
|
qemu_mutex_unlock(&client->mutex);
|
2014-02-03 09:26:13 +00:00
|
|
|
while (!task.complete) {
|
|
|
|
qemu_coroutine_yield();
|
|
|
|
}
|
|
|
|
|
|
|
|
return task.ret;
|
|
|
|
}
|
|
|
|
|
2014-05-08 14:34:44 +00:00
|
|
|
static void nfs_detach_aio_context(BlockDriverState *bs)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
|
2015-10-23 03:08:05 +00:00
|
|
|
aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context),
|
2016-12-01 19:26:41 +00:00
|
|
|
false, NULL, NULL, NULL, NULL);
|
2014-05-08 14:34:44 +00:00
|
|
|
client->events = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_attach_aio_context(BlockDriverState *bs,
|
|
|
|
AioContext *new_context)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
|
|
|
|
client->aio_context = new_context;
|
|
|
|
nfs_set_events(client);
|
|
|
|
}
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
static void nfs_client_close(NFSClient *client)
|
|
|
|
{
|
|
|
|
if (client->context) {
|
|
|
|
if (client->fh) {
|
|
|
|
nfs_close(client->context, client->fh);
|
2017-08-07 22:29:09 +00:00
|
|
|
client->fh = NULL;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
2015-10-23 03:08:05 +00:00
|
|
|
aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context),
|
2016-12-01 19:26:41 +00:00
|
|
|
false, NULL, NULL, NULL, NULL);
|
2014-02-03 09:26:13 +00:00
|
|
|
nfs_destroy_context(client->context);
|
2017-08-07 22:29:09 +00:00
|
|
|
client->context = NULL;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
2017-08-07 22:29:09 +00:00
|
|
|
g_free(client->path);
|
|
|
|
qemu_mutex_destroy(&client->mutex);
|
|
|
|
qapi_free_NFSServer(client->server);
|
|
|
|
client->server = NULL;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void nfs_file_close(BlockDriverState *bs)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
nfs_client_close(client);
|
|
|
|
}
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
static int64_t nfs_client_open(NFSClient *client, BlockdevOptionsNfs *opts,
|
2017-04-21 12:27:05 +00:00
|
|
|
int flags, int open_flags, Error **errp)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
2017-11-27 16:00:07 +00:00
|
|
|
int64_t ret = -EINVAL;
|
2014-02-03 09:26:13 +00:00
|
|
|
struct stat st;
|
|
|
|
char *file = NULL, *strp = NULL;
|
|
|
|
|
2017-08-07 22:29:09 +00:00
|
|
|
qemu_mutex_init(&client->mutex);
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
client->path = g_strdup(opts->path);
|
2016-10-31 15:05:49 +00:00
|
|
|
|
|
|
|
strp = strrchr(client->path, '/');
|
2014-02-03 09:26:13 +00:00
|
|
|
if (strp == NULL) {
|
|
|
|
error_setg(errp, "Invalid URL specified");
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
file = g_strdup(strp);
|
|
|
|
*strp = 0;
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
/* Steal the NFSServer object from opts; set the original pointer to NULL
|
|
|
|
* to avoid use after free and double free. */
|
|
|
|
client->server = opts->server;
|
|
|
|
opts->server = NULL;
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
client->context = nfs_init_context();
|
|
|
|
if (client->context == NULL) {
|
|
|
|
error_setg(errp, "Failed to init NFS context");
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_user) {
|
|
|
|
client->uid = opts->user;
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_uid(client->context, client->uid);
|
|
|
|
}
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_group) {
|
|
|
|
client->gid = opts->group;
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_gid(client->context, client->gid);
|
|
|
|
}
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_tcp_syn_count) {
|
|
|
|
client->tcp_syncnt = opts->tcp_syn_count;
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_tcp_syncnt(client->context, client->tcp_syncnt);
|
|
|
|
}
|
|
|
|
|
|
|
|
#ifdef LIBNFS_FEATURE_READAHEAD
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_readahead_size) {
|
2016-10-31 15:05:49 +00:00
|
|
|
if (open_flags & BDRV_O_NOCACHE) {
|
|
|
|
error_setg(errp, "Cannot enable NFS readahead "
|
|
|
|
"if cache.direct = on");
|
2014-02-03 09:26:13 +00:00
|
|
|
goto fail;
|
|
|
|
}
|
2018-01-31 18:47:48 +00:00
|
|
|
client->readahead = opts->readahead_size;
|
2016-10-31 15:05:49 +00:00
|
|
|
if (client->readahead > QEMU_NFS_MAX_READAHEAD_SIZE) {
|
2017-07-12 13:57:41 +00:00
|
|
|
warn_report("Truncating NFS readahead size to %d",
|
|
|
|
QEMU_NFS_MAX_READAHEAD_SIZE);
|
2016-10-31 15:05:49 +00:00
|
|
|
client->readahead = QEMU_NFS_MAX_READAHEAD_SIZE;
|
2014-06-24 22:06:00 +00:00
|
|
|
}
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_readahead(client->context, client->readahead);
|
2016-05-19 12:48:03 +00:00
|
|
|
#ifdef LIBNFS_FEATURE_PAGECACHE
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_pagecache_ttl(client->context, 0);
|
2016-05-19 12:48:03 +00:00
|
|
|
#endif
|
2016-10-31 15:05:49 +00:00
|
|
|
client->cache_used = true;
|
|
|
|
}
|
2016-05-19 12:48:03 +00:00
|
|
|
#endif
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2016-05-19 12:48:03 +00:00
|
|
|
#ifdef LIBNFS_FEATURE_PAGECACHE
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_page_cache_size) {
|
2016-10-31 15:05:49 +00:00
|
|
|
if (open_flags & BDRV_O_NOCACHE) {
|
|
|
|
error_setg(errp, "Cannot enable NFS pagecache "
|
|
|
|
"if cache.direct = on");
|
|
|
|
goto fail;
|
|
|
|
}
|
2018-01-31 18:47:48 +00:00
|
|
|
client->pagecache = opts->page_cache_size;
|
2016-10-31 15:05:49 +00:00
|
|
|
if (client->pagecache > QEMU_NFS_MAX_PAGECACHE_SIZE) {
|
2017-07-12 13:57:41 +00:00
|
|
|
warn_report("Truncating NFS pagecache size to %d pages",
|
|
|
|
QEMU_NFS_MAX_PAGECACHE_SIZE);
|
2016-10-31 15:05:49 +00:00
|
|
|
client->pagecache = QEMU_NFS_MAX_PAGECACHE_SIZE;
|
|
|
|
}
|
|
|
|
nfs_set_pagecache(client->context, client->pagecache);
|
|
|
|
nfs_set_pagecache_ttl(client->context, 0);
|
|
|
|
client->cache_used = true;
|
|
|
|
}
|
2015-11-09 07:09:33 +00:00
|
|
|
#endif
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2015-11-09 07:09:33 +00:00
|
|
|
#ifdef LIBNFS_FEATURE_DEBUG
|
2018-01-31 18:47:48 +00:00
|
|
|
if (opts->has_debug) {
|
|
|
|
client->debug = opts->debug;
|
2016-10-31 15:05:49 +00:00
|
|
|
/* limit the maximum debug level to avoid potential flooding
|
|
|
|
* of our log files. */
|
|
|
|
if (client->debug > QEMU_NFS_MAX_DEBUG_LEVEL) {
|
2017-07-12 13:57:41 +00:00
|
|
|
warn_report("Limiting NFS debug level to %d",
|
|
|
|
QEMU_NFS_MAX_DEBUG_LEVEL);
|
2016-10-31 15:05:49 +00:00
|
|
|
client->debug = QEMU_NFS_MAX_DEBUG_LEVEL;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
2016-10-31 15:05:49 +00:00
|
|
|
nfs_set_debug(client->context, client->debug);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
2016-10-31 15:05:49 +00:00
|
|
|
#endif
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2016-10-31 15:05:49 +00:00
|
|
|
ret = nfs_mount(client->context, client->server->host, client->path);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (ret < 0) {
|
|
|
|
error_setg(errp, "Failed to mount nfs share: %s",
|
|
|
|
nfs_get_error(client->context));
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (flags & O_CREAT) {
|
|
|
|
ret = nfs_creat(client->context, file, 0600, &client->fh);
|
|
|
|
if (ret < 0) {
|
|
|
|
error_setg(errp, "Failed to create file: %s",
|
|
|
|
nfs_get_error(client->context));
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
ret = nfs_open(client->context, file, flags, &client->fh);
|
|
|
|
if (ret < 0) {
|
|
|
|
error_setg(errp, "Failed to open file : %s",
|
|
|
|
nfs_get_error(client->context));
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
ret = nfs_fstat(client->context, client->fh, &st);
|
|
|
|
if (ret < 0) {
|
|
|
|
error_setg(errp, "Failed to fstat file: %s",
|
|
|
|
nfs_get_error(client->context));
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
ret = DIV_ROUND_UP(st.st_size, BDRV_SECTOR_SIZE);
|
2015-08-27 10:30:41 +00:00
|
|
|
client->st_blocks = st.st_blocks;
|
2014-02-03 09:26:13 +00:00
|
|
|
client->has_zero_init = S_ISREG(st.st_mode);
|
2016-10-31 15:05:49 +00:00
|
|
|
*strp = '/';
|
2014-02-03 09:26:13 +00:00
|
|
|
goto out;
|
2016-10-31 15:05:49 +00:00
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
fail:
|
|
|
|
nfs_client_close(client);
|
|
|
|
out:
|
|
|
|
g_free(file);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2018-01-31 15:27:38 +00:00
|
|
|
static BlockdevOptionsNfs *nfs_options_qdict_to_qapi(QDict *options,
|
|
|
|
Error **errp)
|
2018-01-31 18:47:48 +00:00
|
|
|
{
|
|
|
|
BlockdevOptionsNfs *opts = NULL;
|
|
|
|
QObject *crumpled = NULL;
|
|
|
|
Visitor *v;
|
2018-05-16 16:08:16 +00:00
|
|
|
const QDictEntry *e;
|
2018-01-31 18:47:48 +00:00
|
|
|
Error *local_err = NULL;
|
|
|
|
|
block: Fix -blockdev for certain non-string scalars
Configuration flows through the block subsystem in a rather peculiar
way. Configuration made with -drive enters it as QemuOpts.
Configuration made with -blockdev / blockdev-add enters it as QAPI
type BlockdevOptions. The block subsystem uses QDict, QemuOpts and
QAPI types internally. The precise flow is next to impossible to
explain (I tried for this commit message, but gave up after wasting
several hours). What I can explain is a flaw in the BlockDriver
interface that leads to this bug:
$ qemu-system-x86_64 -blockdev node-name=n1,driver=nfs,server.type=inet,server.host=localhost,path=/foo/bar,user=1234
qemu-system-x86_64: -blockdev node-name=n1,driver=nfs,server.type=inet,server.host=localhost,path=/foo/bar,user=1234: Internal error: parameter user invalid
QMP blockdev-add is broken the same way.
Here's what happens. The block layer passes configuration represented
as flat QDict (with dotted keys) to BlockDriver methods
.bdrv_file_open(). The QDict's members are typed according to the
QAPI schema.
nfs_file_open() converts it to QAPI type BlockdevOptionsNfs, with
qdict_crumple() and a qobject input visitor.
This visitor comes in two flavors. The plain flavor requires scalars
to be typed according to the QAPI schema. That's the case here. The
keyval flavor requires string scalars. That's not the case here.
nfs_file_open() uses the latter, and promptly falls apart for members
@user, @group, @tcp-syn-count, @readahead-size, @page-cache-size,
@debug.
Switching to the plain flavor would fix -blockdev, but break -drive,
because there the scalars arrive in nfs_file_open() as strings.
The proper fix would be to replace the QDict by QAPI type
BlockdevOptions in the BlockDriver interface. Sadly, that's beyond my
reach right now.
Next best would be to fix the block layer to always pass correctly
typed QDicts to the BlockDriver methods. Also beyond my reach.
What I can do is throw another hack onto the pile: have
nfs_file_open() convert all members to string, so use of the keyval
flavor actually works, by replacing qdict_crumple() by new function
qdict_crumple_for_keyval_qiv().
The pattern "pass result of qdict_crumple() to
qobject_input_visitor_new_keyval()" occurs several times more:
* qemu_rbd_open()
Same issue as nfs_file_open(), but since BlockdevOptionsRbd has only
string members, its only a latent bug. Fix it anyway.
* parallels_co_create_opts(), qcow_co_create_opts(),
qcow2_co_create_opts(), bdrv_qed_co_create_opts(),
sd_co_create_opts(), vhdx_co_create_opts(), vpc_co_create_opts()
These work, because they create the QDict with
qemu_opts_to_qdict_filtered(), which creates only string scalars.
The function sports a TODO comment asking for better typing; that's
going to be fun. Use qdict_crumple_for_keyval_qiv() to be safe.
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Kevin Wolf <kwolf@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
2018-06-14 19:14:30 +00:00
|
|
|
crumpled = qdict_crumple_for_keyval_qiv(options, errp);
|
2018-01-31 18:47:48 +00:00
|
|
|
if (crumpled == NULL) {
|
2018-01-31 15:27:38 +00:00
|
|
|
return NULL;
|
2018-01-31 18:47:48 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
v = qobject_input_visitor_new_keyval(crumpled);
|
|
|
|
visit_type_BlockdevOptionsNfs(v, NULL, &opts, &local_err);
|
|
|
|
visit_free(v);
|
2018-04-19 15:01:43 +00:00
|
|
|
qobject_unref(crumpled);
|
2018-01-31 18:47:48 +00:00
|
|
|
|
|
|
|
if (local_err) {
|
2018-05-16 16:10:34 +00:00
|
|
|
error_propagate(errp, local_err);
|
2018-01-31 15:27:38 +00:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2018-05-16 16:08:16 +00:00
|
|
|
/* Remove the processed options from the QDict (the visitor processes
|
|
|
|
* _all_ options in the QDict) */
|
|
|
|
while ((e = qdict_first(options))) {
|
|
|
|
qdict_del(options, e->key);
|
|
|
|
}
|
|
|
|
|
2018-01-31 15:27:38 +00:00
|
|
|
return opts;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int64_t nfs_client_open_qdict(NFSClient *client, QDict *options,
|
|
|
|
int flags, int open_flags, Error **errp)
|
|
|
|
{
|
|
|
|
BlockdevOptionsNfs *opts;
|
|
|
|
int ret;
|
|
|
|
|
|
|
|
opts = nfs_options_qdict_to_qapi(options, errp);
|
|
|
|
if (opts == NULL) {
|
2018-01-31 18:47:48 +00:00
|
|
|
ret = -EINVAL;
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
ret = nfs_client_open(client, opts, flags, open_flags, errp);
|
|
|
|
fail:
|
|
|
|
qapi_free_BlockdevOptionsNfs(opts);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
static int nfs_file_open(BlockDriverState *bs, QDict *options, int flags,
|
|
|
|
Error **errp) {
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
int64_t ret;
|
|
|
|
|
2014-05-08 14:34:44 +00:00
|
|
|
client->aio_context = bdrv_get_aio_context(bs);
|
|
|
|
|
2018-01-31 18:47:48 +00:00
|
|
|
ret = nfs_client_open_qdict(client, options,
|
|
|
|
(flags & BDRV_O_RDWR) ? O_RDWR : O_RDONLY,
|
|
|
|
bs->open_flags, errp);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (ret < 0) {
|
2016-10-31 15:05:49 +00:00
|
|
|
return ret;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
2017-08-07 22:29:09 +00:00
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
bs->total_sectors = ret;
|
2014-08-28 05:56:10 +00:00
|
|
|
ret = 0;
|
|
|
|
return ret;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2014-12-02 17:32:44 +00:00
|
|
|
static QemuOptsList nfs_create_opts = {
|
|
|
|
.name = "nfs-create-opts",
|
|
|
|
.head = QTAILQ_HEAD_INITIALIZER(nfs_create_opts.head),
|
|
|
|
.desc = {
|
|
|
|
{
|
|
|
|
.name = BLOCK_OPT_SIZE,
|
|
|
|
.type = QEMU_OPT_SIZE,
|
|
|
|
.help = "Virtual disk size"
|
|
|
|
},
|
|
|
|
{ /* end of list */ }
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
2018-01-31 15:27:38 +00:00
|
|
|
static int nfs_file_co_create(BlockdevCreateOptions *options, Error **errp)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
2018-01-31 15:27:38 +00:00
|
|
|
BlockdevCreateOptionsNfs *opts = &options->u.nfs;
|
block: Use g_new() & friends where that makes obvious sense
g_new(T, n) is neater than g_malloc(sizeof(T) * n). It's also safer,
for two reasons. One, it catches multiplication overflowing size_t.
Two, it returns T * rather than void *, which lets the compiler catch
more type errors.
Patch created with Coccinelle, with two manual changes on top:
* Add const to bdrv_iterate_format() to keep the types straight
* Convert the allocation in bdrv_drop_intermediate(), which Coccinelle
inexplicably misses
Coccinelle semantic patch:
@@
type T;
@@
-g_malloc(sizeof(T))
+g_new(T, 1)
@@
type T;
@@
-g_try_malloc(sizeof(T))
+g_try_new(T, 1)
@@
type T;
@@
-g_malloc0(sizeof(T))
+g_new0(T, 1)
@@
type T;
@@
-g_try_malloc0(sizeof(T))
+g_try_new0(T, 1)
@@
type T;
expression n;
@@
-g_malloc(sizeof(T) * (n))
+g_new(T, n)
@@
type T;
expression n;
@@
-g_try_malloc(sizeof(T) * (n))
+g_try_new(T, n)
@@
type T;
expression n;
@@
-g_malloc0(sizeof(T) * (n))
+g_new0(T, n)
@@
type T;
expression n;
@@
-g_try_malloc0(sizeof(T) * (n))
+g_try_new0(T, n)
@@
type T;
expression p, n;
@@
-g_realloc(p, sizeof(T) * (n))
+g_renew(T, p, n)
@@
type T;
expression p, n;
@@
-g_try_realloc(p, sizeof(T) * (n))
+g_try_renew(T, p, n)
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Max Reitz <mreitz@redhat.com>
Reviewed-by: Jeff Cody <jcody@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
2014-08-19 08:31:08 +00:00
|
|
|
NFSClient *client = g_new0(NFSClient, 1);
|
2018-01-31 15:27:38 +00:00
|
|
|
int ret;
|
|
|
|
|
|
|
|
assert(options->driver == BLOCKDEV_DRIVER_NFS);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2014-05-08 14:34:44 +00:00
|
|
|
client->aio_context = qemu_get_aio_context();
|
|
|
|
|
2018-01-31 15:27:38 +00:00
|
|
|
ret = nfs_client_open(client, opts->location, O_CREAT, 0, errp);
|
|
|
|
if (ret < 0) {
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
ret = nfs_ftruncate(client->context, client->fh, opts->size);
|
|
|
|
nfs_client_close(client);
|
|
|
|
|
|
|
|
out:
|
|
|
|
g_free(client);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int coroutine_fn nfs_file_co_create_opts(const char *url, QemuOpts *opts,
|
|
|
|
Error **errp)
|
|
|
|
{
|
|
|
|
BlockdevCreateOptions *create_options;
|
|
|
|
BlockdevCreateOptionsNfs *nfs_opts;
|
|
|
|
QDict *options;
|
|
|
|
int ret;
|
|
|
|
|
|
|
|
create_options = g_new0(BlockdevCreateOptions, 1);
|
|
|
|
create_options->driver = BLOCKDEV_DRIVER_NFS;
|
|
|
|
nfs_opts = &create_options->u.nfs;
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
/* Read out options */
|
2018-01-31 15:27:38 +00:00
|
|
|
nfs_opts->size = ROUND_UP(qemu_opt_get_size_del(opts, BLOCK_OPT_SIZE, 0),
|
|
|
|
BDRV_SECTOR_SIZE);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2016-10-31 15:05:49 +00:00
|
|
|
options = qdict_new();
|
|
|
|
ret = nfs_parse_uri(url, options, errp);
|
|
|
|
if (ret < 0) {
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
2018-01-31 15:27:38 +00:00
|
|
|
nfs_opts->location = nfs_options_qdict_to_qapi(options, errp);
|
|
|
|
if (nfs_opts->location == NULL) {
|
|
|
|
ret = -EINVAL;
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
ret = nfs_file_co_create(create_options, errp);
|
2014-02-03 09:26:13 +00:00
|
|
|
if (ret < 0) {
|
|
|
|
goto out;
|
|
|
|
}
|
2018-01-31 15:27:38 +00:00
|
|
|
|
|
|
|
ret = 0;
|
2014-02-03 09:26:13 +00:00
|
|
|
out:
|
2018-04-19 15:01:43 +00:00
|
|
|
qobject_unref(options);
|
2018-01-31 15:27:38 +00:00
|
|
|
qapi_free_BlockdevCreateOptions(create_options);
|
2014-02-03 09:26:13 +00:00
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int nfs_has_zero_init(BlockDriverState *bs)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
return client->has_zero_init;
|
|
|
|
}
|
|
|
|
|
2017-02-22 18:07:24 +00:00
|
|
|
/* Called (via nfs_service) with QemuMutex held. */
|
2016-10-27 10:48:57 +00:00
|
|
|
static void
|
|
|
|
nfs_get_allocated_file_size_cb(int ret, struct nfs_context *nfs, void *data,
|
|
|
|
void *private_data)
|
|
|
|
{
|
|
|
|
NFSRPC *task = private_data;
|
|
|
|
task->ret = ret;
|
|
|
|
if (task->ret == 0) {
|
|
|
|
memcpy(task->st, data, sizeof(struct stat));
|
|
|
|
}
|
|
|
|
if (task->ret < 0) {
|
|
|
|
error_report("NFS Error: %s", nfs_get_error(nfs));
|
|
|
|
}
|
2017-06-05 12:38:54 +00:00
|
|
|
|
|
|
|
/* Set task->complete before reading bs->wakeup. */
|
|
|
|
atomic_mb_set(&task->complete, 1);
|
2016-10-27 10:49:05 +00:00
|
|
|
bdrv_wakeup(task->bs);
|
2016-10-27 10:48:57 +00:00
|
|
|
}
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
static int64_t nfs_get_allocated_file_size(BlockDriverState *bs)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
NFSRPC task = {0};
|
|
|
|
struct stat st;
|
|
|
|
|
2015-08-27 10:30:41 +00:00
|
|
|
if (bdrv_is_read_only(bs) &&
|
|
|
|
!(bs->open_flags & BDRV_O_NOCACHE)) {
|
|
|
|
return client->st_blocks * 512;
|
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:57 +00:00
|
|
|
task.bs = bs;
|
2014-02-03 09:26:13 +00:00
|
|
|
task.st = &st;
|
2016-10-27 10:48:57 +00:00
|
|
|
if (nfs_fstat_async(client->context, client->fh, nfs_get_allocated_file_size_cb,
|
2014-02-03 09:26:13 +00:00
|
|
|
&task) != 0) {
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2016-10-27 10:48:56 +00:00
|
|
|
nfs_set_events(client);
|
2016-10-27 10:48:57 +00:00
|
|
|
BDRV_POLL_WHILE(bs, !task.complete);
|
2014-02-03 09:26:13 +00:00
|
|
|
|
2015-08-20 10:46:47 +00:00
|
|
|
return (task.ret < 0 ? task.ret : st.st_blocks * 512);
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2017-06-13 20:20:52 +00:00
|
|
|
static int nfs_file_truncate(BlockDriverState *bs, int64_t offset,
|
|
|
|
PreallocMode prealloc, Error **errp)
|
2014-02-03 09:26:13 +00:00
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
2017-03-28 20:51:29 +00:00
|
|
|
int ret;
|
|
|
|
|
2017-06-13 20:20:52 +00:00
|
|
|
if (prealloc != PREALLOC_MODE_OFF) {
|
|
|
|
error_setg(errp, "Unsupported preallocation mode '%s'",
|
2017-08-24 08:46:08 +00:00
|
|
|
PreallocMode_str(prealloc));
|
2017-06-13 20:20:52 +00:00
|
|
|
return -ENOTSUP;
|
|
|
|
}
|
|
|
|
|
2017-03-28 20:51:29 +00:00
|
|
|
ret = nfs_ftruncate(client->context, client->fh, offset);
|
|
|
|
if (ret < 0) {
|
|
|
|
error_setg_errno(errp, -ret, "Failed to truncate file");
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
2014-02-03 09:26:13 +00:00
|
|
|
}
|
|
|
|
|
2015-08-27 10:30:41 +00:00
|
|
|
/* Note that this will not re-establish a connection with the NFS server
|
|
|
|
* - it is effectively a NOP. */
|
|
|
|
static int nfs_reopen_prepare(BDRVReopenState *state,
|
|
|
|
BlockReopenQueue *queue, Error **errp)
|
|
|
|
{
|
|
|
|
NFSClient *client = state->bs->opaque;
|
|
|
|
struct stat st;
|
|
|
|
int ret = 0;
|
|
|
|
|
|
|
|
if (state->flags & BDRV_O_RDWR && bdrv_is_read_only(state->bs)) {
|
|
|
|
error_setg(errp, "Cannot open a read-only mount as read-write");
|
|
|
|
return -EACCES;
|
|
|
|
}
|
|
|
|
|
2016-05-19 12:48:02 +00:00
|
|
|
if ((state->flags & BDRV_O_NOCACHE) && client->cache_used) {
|
2016-05-19 12:48:03 +00:00
|
|
|
error_setg(errp, "Cannot disable cache if libnfs readahead or"
|
|
|
|
" pagecache is enabled");
|
2016-05-19 12:48:02 +00:00
|
|
|
return -EINVAL;
|
|
|
|
}
|
|
|
|
|
2015-08-27 10:30:41 +00:00
|
|
|
/* Update cache for read-only reopens */
|
|
|
|
if (!(state->flags & BDRV_O_RDWR)) {
|
|
|
|
ret = nfs_fstat(client->context, client->fh, &st);
|
|
|
|
if (ret < 0) {
|
|
|
|
error_setg(errp, "Failed to fstat file: %s",
|
|
|
|
nfs_get_error(client->context));
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
client->st_blocks = st.st_blocks;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2016-10-31 15:05:49 +00:00
|
|
|
static void nfs_refresh_filename(BlockDriverState *bs, QDict *options)
|
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
QDict *opts = qdict_new();
|
|
|
|
QObject *server_qdict;
|
|
|
|
Visitor *ov;
|
|
|
|
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(opts, "driver", "nfs");
|
2016-10-31 15:05:49 +00:00
|
|
|
|
|
|
|
if (client->uid && !client->gid) {
|
|
|
|
snprintf(bs->exact_filename, sizeof(bs->exact_filename),
|
|
|
|
"nfs://%s%s?uid=%" PRId64, client->server->host, client->path,
|
|
|
|
client->uid);
|
|
|
|
} else if (!client->uid && client->gid) {
|
|
|
|
snprintf(bs->exact_filename, sizeof(bs->exact_filename),
|
|
|
|
"nfs://%s%s?gid=%" PRId64, client->server->host, client->path,
|
|
|
|
client->gid);
|
|
|
|
} else if (client->uid && client->gid) {
|
|
|
|
snprintf(bs->exact_filename, sizeof(bs->exact_filename),
|
|
|
|
"nfs://%s%s?uid=%" PRId64 "&gid=%" PRId64,
|
|
|
|
client->server->host, client->path, client->uid, client->gid);
|
|
|
|
} else {
|
|
|
|
snprintf(bs->exact_filename, sizeof(bs->exact_filename),
|
|
|
|
"nfs://%s%s", client->server->host, client->path);
|
|
|
|
}
|
|
|
|
|
|
|
|
ov = qobject_output_visitor_new(&server_qdict);
|
|
|
|
visit_type_NFSServer(ov, NULL, &client->server, &error_abort);
|
|
|
|
visit_complete(ov, &server_qdict);
|
|
|
|
qdict_put_obj(opts, "server", server_qdict);
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_str(opts, "path", client->path);
|
2016-10-31 15:05:49 +00:00
|
|
|
|
|
|
|
if (client->uid) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "user", client->uid);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
if (client->gid) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "group", client->gid);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
if (client->tcp_syncnt) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "tcp-syn-cnt", client->tcp_syncnt);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
if (client->readahead) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "readahead-size", client->readahead);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
if (client->pagecache) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "page-cache-size", client->pagecache);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
if (client->debug) {
|
2017-04-27 21:58:17 +00:00
|
|
|
qdict_put_int(opts, "debug", client->debug);
|
2016-10-31 15:05:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
visit_free(ov);
|
|
|
|
qdict_flatten(opts);
|
|
|
|
bs->full_open_options = opts;
|
|
|
|
}
|
|
|
|
|
2016-05-19 12:48:03 +00:00
|
|
|
#ifdef LIBNFS_FEATURE_PAGECACHE
|
2018-03-01 16:36:18 +00:00
|
|
|
static void coroutine_fn nfs_co_invalidate_cache(BlockDriverState *bs,
|
|
|
|
Error **errp)
|
2016-05-19 12:48:03 +00:00
|
|
|
{
|
|
|
|
NFSClient *client = bs->opaque;
|
|
|
|
nfs_pagecache_invalidate(client->context, client->fh);
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2014-02-03 09:26:13 +00:00
|
|
|
static BlockDriver bdrv_nfs = {
|
2014-05-08 14:34:44 +00:00
|
|
|
.format_name = "nfs",
|
|
|
|
.protocol_name = "nfs",
|
|
|
|
|
|
|
|
.instance_size = sizeof(NFSClient),
|
2016-10-31 15:05:49 +00:00
|
|
|
.bdrv_parse_filename = nfs_parse_filename,
|
2014-12-02 17:32:44 +00:00
|
|
|
.create_opts = &nfs_create_opts,
|
|
|
|
|
2014-05-08 14:34:44 +00:00
|
|
|
.bdrv_has_zero_init = nfs_has_zero_init,
|
|
|
|
.bdrv_get_allocated_file_size = nfs_get_allocated_file_size,
|
|
|
|
.bdrv_truncate = nfs_file_truncate,
|
|
|
|
|
|
|
|
.bdrv_file_open = nfs_file_open,
|
|
|
|
.bdrv_close = nfs_file_close,
|
2018-01-31 15:27:38 +00:00
|
|
|
.bdrv_co_create = nfs_file_co_create,
|
2018-01-18 12:43:45 +00:00
|
|
|
.bdrv_co_create_opts = nfs_file_co_create_opts,
|
2015-08-27 10:30:41 +00:00
|
|
|
.bdrv_reopen_prepare = nfs_reopen_prepare,
|
2014-05-08 14:34:44 +00:00
|
|
|
|
2017-02-17 16:39:00 +00:00
|
|
|
.bdrv_co_preadv = nfs_co_preadv,
|
|
|
|
.bdrv_co_pwritev = nfs_co_pwritev,
|
2014-05-08 14:34:44 +00:00
|
|
|
.bdrv_co_flush_to_disk = nfs_co_flush,
|
|
|
|
|
|
|
|
.bdrv_detach_aio_context = nfs_detach_aio_context,
|
|
|
|
.bdrv_attach_aio_context = nfs_attach_aio_context,
|
2016-10-31 15:05:49 +00:00
|
|
|
.bdrv_refresh_filename = nfs_refresh_filename,
|
2016-05-19 12:48:03 +00:00
|
|
|
|
|
|
|
#ifdef LIBNFS_FEATURE_PAGECACHE
|
2018-03-01 16:36:18 +00:00
|
|
|
.bdrv_co_invalidate_cache = nfs_co_invalidate_cache,
|
2016-05-19 12:48:03 +00:00
|
|
|
#endif
|
2014-02-03 09:26:13 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
static void nfs_block_init(void)
|
|
|
|
{
|
|
|
|
bdrv_register(&bdrv_nfs);
|
|
|
|
}
|
|
|
|
|
|
|
|
block_init(nfs_block_init);
|