block/nfs: Use URI parsing code from glib

Since version 2.66, glib has useful URI parsing functions, too.
Use those instead of the QEMU-internal ones to be finally able
to get rid of the latter.

While we're at it, slightly rephrase one of the error messages:
Use "Invalid value..." instead of "Illegal value..." since the
latter rather sounds like the users were breaking a law here.

Reviewed-by: Eric Blake <eblake@redhat.com>
Message-ID: <20240418101056.302103-12-thuth@redhat.com>
Signed-off-by: Thomas Huth <thuth@redhat.com>
This commit is contained in:
Thomas Huth 2024-04-18 12:10:54 +02:00
parent ad97c011dc
commit f8b74fc55d

View File

@ -38,7 +38,6 @@
#include "qemu/main-loop.h" #include "qemu/main-loop.h"
#include "qemu/module.h" #include "qemu/module.h"
#include "qemu/option.h" #include "qemu/option.h"
#include "qemu/uri.h"
#include "qemu/cutils.h" #include "qemu/cutils.h"
#include "sysemu/replay.h" #include "sysemu/replay.h"
#include "qapi/qapi-visit-block-core.h" #include "qapi/qapi-visit-block-core.h"
@ -79,77 +78,76 @@ typedef struct NFSRPC {
static int nfs_parse_uri(const char *filename, QDict *options, Error **errp) static int nfs_parse_uri(const char *filename, QDict *options, Error **errp)
{ {
URI *uri = NULL; g_autoptr(GUri) uri = g_uri_parse(filename, G_URI_FLAGS_NONE, NULL);
QueryParams *qp = NULL; GUriParamsIter qp;
int ret = -EINVAL, i; const char *uri_server, *uri_path, *uri_query;
char *qp_name, *qp_value;
GError *gerror = NULL;
uri = uri_parse(filename);
if (!uri) { if (!uri) {
error_setg(errp, "Invalid URI specified"); error_setg(errp, "Invalid URI specified");
goto out; return -EINVAL;
} }
if (g_strcmp0(uri->scheme, "nfs") != 0) { if (!g_str_equal(g_uri_get_scheme(uri), "nfs")) {
error_setg(errp, "URI scheme must be 'nfs'"); error_setg(errp, "URI scheme must be 'nfs'");
goto out; return -EINVAL;
} }
if (!uri->server) { uri_server = g_uri_get_host(uri);
if (!uri_server || !uri_server[0]) {
error_setg(errp, "missing hostname in URI"); error_setg(errp, "missing hostname in URI");
goto out; return -EINVAL;
} }
if (!uri->path) { uri_path = g_uri_get_path(uri);
if (!uri_path || !uri_path[0]) {
error_setg(errp, "missing file path in URI"); error_setg(errp, "missing file path in URI");
goto out; return -EINVAL;
} }
qp = query_params_parse(uri->query); qdict_put_str(options, "server.host", uri_server);
if (!qp) {
error_setg(errp, "could not parse query parameters");
goto out;
}
qdict_put_str(options, "server.host", uri->server);
qdict_put_str(options, "server.type", "inet"); qdict_put_str(options, "server.type", "inet");
qdict_put_str(options, "path", uri->path); qdict_put_str(options, "path", uri_path);
for (i = 0; i < qp->n; i++) { uri_query = g_uri_get_query(uri);
uint64_t val; if (uri_query) {
if (!qp->p[i].value) { g_uri_params_iter_init(&qp, uri_query, -1, "&", G_URI_PARAMS_NONE);
error_setg(errp, "Value for NFS parameter expected: %s", while (g_uri_params_iter_next(&qp, &qp_name, &qp_value, &gerror)) {
qp->p[i].name); uint64_t val;
goto out; if (!qp_name || gerror) {
} error_setg(errp, "Failed to parse NFS parameter");
if (parse_uint_full(qp->p[i].value, 0, &val)) { return -EINVAL;
error_setg(errp, "Illegal value for NFS parameter: %s", }
qp->p[i].name); if (!qp_value) {
goto out; error_setg(errp, "Value for NFS parameter expected: %s",
} qp_name);
if (!strcmp(qp->p[i].name, "uid")) { return -EINVAL;
qdict_put_str(options, "user", qp->p[i].value); }
} else if (!strcmp(qp->p[i].name, "gid")) { if (parse_uint_full(qp_value, 0, &val)) {
qdict_put_str(options, "group", qp->p[i].value); error_setg(errp, "Invalid value for NFS parameter: %s",
} else if (!strcmp(qp->p[i].name, "tcp-syncnt")) { qp_name);
qdict_put_str(options, "tcp-syn-count", qp->p[i].value); return -EINVAL;
} else if (!strcmp(qp->p[i].name, "readahead")) { }
qdict_put_str(options, "readahead-size", qp->p[i].value); if (g_str_equal(qp_name, "uid")) {
} else if (!strcmp(qp->p[i].name, "pagecache")) { qdict_put_str(options, "user", qp_value);
qdict_put_str(options, "page-cache-size", qp->p[i].value); } else if (g_str_equal(qp_name, "gid")) {
} else if (!strcmp(qp->p[i].name, "debug")) { qdict_put_str(options, "group", qp_value);
qdict_put_str(options, "debug", qp->p[i].value); } else if (g_str_equal(qp_name, "tcp-syncnt")) {
} else { qdict_put_str(options, "tcp-syn-count", qp_value);
error_setg(errp, "Unknown NFS parameter name: %s", } else if (g_str_equal(qp_name, "readahead")) {
qp->p[i].name); qdict_put_str(options, "readahead-size", qp_value);
goto out; } else if (g_str_equal(qp_name, "pagecache")) {
qdict_put_str(options, "page-cache-size", qp_value);
} else if (g_str_equal(qp_name, "debug")) {
qdict_put_str(options, "debug", qp_value);
} else {
error_setg(errp, "Unknown NFS parameter name: %s", qp_name);
return -EINVAL;
}
} }
} }
ret = 0;
out: return 0;
if (qp) {
query_params_free(qp);
}
uri_free(uri);
return ret;
} }
static bool nfs_has_filename_options_conflict(QDict *options, Error **errp) static bool nfs_has_filename_options_conflict(QDict *options, Error **errp)