[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH for-9.1 7/9] block/nfs: Use URI parsing code from glib
From: |
Thomas Huth |
Subject: |
[PATCH for-9.1 7/9] block/nfs: Use URI parsing code from glib |
Date: |
Thu, 28 Mar 2024 15:06:04 +0100 |
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.
Signed-off-by: Thomas Huth <thuth@redhat.com>
---
block/nfs.c | 102 ++++++++++++++++++++++++++--------------------------
1 file changed, 52 insertions(+), 50 deletions(-)
diff --git a/block/nfs.c b/block/nfs.c
index f737e19cd3..9550063695 100644
--- a/block/nfs.c
+++ b/block/nfs.c
@@ -38,7 +38,6 @@
#include "qemu/main-loop.h"
#include "qemu/module.h"
#include "qemu/option.h"
-#include "qemu/uri.h"
#include "qemu/cutils.h"
#include "sysemu/replay.h"
#include "qapi/qapi-visit-block-core.h"
@@ -79,76 +78,79 @@ typedef struct NFSRPC {
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);
+ GUri *uri;
+ GUriParamsIter qp;
+ const char *uri_server, *uri_path, *uri_query;
+ char *qp_name, *qp_value;
+ GError *gerror = NULL;
+ int ret = -EINVAL;
+
+ uri = g_uri_parse(filename, G_URI_FLAGS_NONE, NULL);
if (!uri) {
error_setg(errp, "Invalid URI specified");
goto out;
}
- 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'");
goto out;
}
- if (!uri->server) {
+ uri_server = g_uri_get_host(uri);
+ if (!uri_server || !uri_server[0]) {
error_setg(errp, "missing hostname in URI");
goto out;
}
- if (!uri->path) {
+ uri_path = g_uri_get_path(uri);
+ if (!uri_path || !uri_path[0]) {
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;
- }
-
- qdict_put_str(options, "server.host", uri->server);
+ qdict_put_str(options, "server.host", uri_server);
qdict_put_str(options, "server.type", "inet");
- qdict_put_str(options, "path", uri->path);
-
- for (i = 0; i < qp->n; i++) {
- uint64_t val;
- if (!qp->p[i].value) {
- error_setg(errp, "Value for NFS parameter expected: %s",
- qp->p[i].name);
- goto out;
- }
- if (parse_uint_full(qp->p[i].value, 0, &val)) {
- error_setg(errp, "Illegal value for NFS parameter: %s",
- qp->p[i].name);
- goto out;
- }
- if (!strcmp(qp->p[i].name, "uid")) {
- qdict_put_str(options, "user", qp->p[i].value);
- } else if (!strcmp(qp->p[i].name, "gid")) {
- qdict_put_str(options, "group", qp->p[i].value);
- } else if (!strcmp(qp->p[i].name, "tcp-syncnt")) {
- qdict_put_str(options, "tcp-syn-count", qp->p[i].value);
- } else if (!strcmp(qp->p[i].name, "readahead")) {
- qdict_put_str(options, "readahead-size", qp->p[i].value);
- } else if (!strcmp(qp->p[i].name, "pagecache")) {
- qdict_put_str(options, "page-cache-size", qp->p[i].value);
- } else if (!strcmp(qp->p[i].name, "debug")) {
- qdict_put_str(options, "debug", qp->p[i].value);
- } else {
- error_setg(errp, "Unknown NFS parameter name: %s",
- qp->p[i].name);
- goto out;
+ qdict_put_str(options, "path", uri_path);
+
+ uri_query = g_uri_get_query(uri);
+ if (uri_query) {
+ g_uri_params_iter_init(&qp, uri_query, -1, "&", G_URI_PARAMS_NONE);
+ while (g_uri_params_iter_next(&qp, &qp_name, &qp_value, &gerror)) {
+ uint64_t val;
+ if (!qp_name || gerror) {
+ error_setg(errp, "Failed to parse NFS parameter");
+ goto out;
+ }
+ if (!qp_value) {
+ error_setg(errp, "Value for NFS parameter expected: %s",
+ qp_name);
+ goto out;
+ }
+ if (parse_uint_full(qp_value, 0, &val)) {
+ error_setg(errp, "Illegal value for NFS parameter: %s",
+ qp_name);
+ goto out;
+ }
+ if (g_str_equal(qp_name, "uid")) {
+ qdict_put_str(options, "user", qp_value);
+ } else if (g_str_equal(qp_name, "gid")) {
+ qdict_put_str(options, "group", qp_value);
+ } else if (g_str_equal(qp_name, "tcp-syncnt")) {
+ qdict_put_str(options, "tcp-syn-count", qp_value);
+ } else if (g_str_equal(qp_name, "readahead")) {
+ qdict_put_str(options, "readahead-size", qp_value);
+ } 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);
+ goto out;
+ }
}
}
ret = 0;
out:
- if (qp) {
- query_params_free(qp);
- }
- uri_free(uri);
+ g_uri_unref(uri);
return ret;
}
--
2.44.0
- [PATCH for-9.1 0/9] Switch to glib URI parsing code, Thomas Huth, 2024/03/28
- [PATCH for-9.1 1/9] tests: Remove Ubuntu 20.04 container, Thomas Huth, 2024/03/28
- [PATCH for-9.1 3/9] tests: Update our CI to use CentOS Stream 9 instead of 8, Thomas Huth, 2024/03/28
- [PATCH for-9.1 4/9] Bump minimum glib version to v2.66, Thomas Huth, 2024/03/28
- [PATCH for-9.1 5/9] block/gluster: Use URI parsing code from glib, Thomas Huth, 2024/03/28
- [PATCH for-9.1 2/9] tests/lcitool/libvirt-ci: Update to the latest master branch, Thomas Huth, 2024/03/28
- [PATCH for-9.1 7/9] block/nfs: Use URI parsing code from glib,
Thomas Huth <=
- [PATCH for-9.1 6/9] block/nbd: Use URI parsing code from glib, Thomas Huth, 2024/03/28
- Re: [PATCH for-9.1 6/9] block/nbd: Use URI parsing code from glib, Eric Blake, 2024/03/28
[PATCH for-9.1 8/9] block/ssh: Use URI parsing code from glib, Thomas Huth, 2024/03/28
[PATCH for-9.1 9/9] util/uri: Remove the old URI parsing code, Thomas Huth, 2024/03/28