1 | The following changes since commit ca61fa4b803e5d0abaf6f1ceb690f23bb78a4def: | 1 | The following changes since commit 9c125d17e9402c232c46610802e5931b3639d77b: |
---|---|---|---|
2 | 2 | ||
3 | Merge remote-tracking branch 'remotes/quic/tags/pull-hex-20211006' into staging (2021-10-06 12:11:14 -0700) | 3 | Merge tag 'pull-tcg-20220420' of https://gitlab.com/rth7680/qemu into staging (2022-04-20 16:43:11 -0700) |
4 | 4 | ||
5 | are available in the Git repository at: | 5 | are available in the Git repository at: |
6 | 6 | ||
7 | https://gitlab.com/stefanha/qemu.git tags/block-pull-request | 7 | https://gitlab.com/stefanha/qemu.git tags/block-pull-request |
8 | 8 | ||
9 | for you to fetch changes up to 1cc7eada97914f090125e588497986f6f7900514: | 9 | for you to fetch changes up to d45c83328feab2e4083991693160f0a417cfd9b0: |
10 | 10 | ||
11 | iothread: use IOThreadParamInfo in iothread_[set|get]_param() (2021-10-07 15:29:50 +0100) | 11 | virtiofsd: Add docs/helper for killpriv_v2/no_killpriv_v2 option (2022-04-21 12:05:15 +0200) |
12 | 12 | ||
13 | ---------------------------------------------------------------- | 13 | ---------------------------------------------------------------- |
14 | Pull request | 14 | Pull request |
15 | 15 | ||
16 | Small contrib/vhost-user-blk, contrib/vhost-user-scsi, and tools/virtiofsd | ||
17 | improvements. | ||
18 | |||
16 | ---------------------------------------------------------------- | 19 | ---------------------------------------------------------------- |
17 | 20 | ||
18 | Stefano Garzarella (2): | 21 | Liu Yiding (1): |
19 | iothread: rename PollParamInfo to IOThreadParamInfo | 22 | virtiofsd: Add docs/helper for killpriv_v2/no_killpriv_v2 option |
20 | iothread: use IOThreadParamInfo in iothread_[set|get]_param() | ||
21 | 23 | ||
22 | iothread.c | 28 +++++++++++++++------------- | 24 | Sakshi Kaushik (1): |
23 | 1 file changed, 15 insertions(+), 13 deletions(-) | 25 | Implements Backend Program conventions for vhost-user-scsi |
26 | |||
27 | Stefan Hajnoczi (1): | ||
28 | contrib/vhost-user-blk: add missing GOptionEntry NULL terminator | ||
29 | |||
30 | docs/tools/virtiofsd.rst | 5 ++ | ||
31 | contrib/vhost-user-blk/vhost-user-blk.c | 3 +- | ||
32 | contrib/vhost-user-scsi/vhost-user-scsi.c | 77 +++++++++++++++-------- | ||
33 | tools/virtiofsd/helper.c | 3 + | ||
34 | 4 files changed, 62 insertions(+), 26 deletions(-) | ||
24 | 35 | ||
25 | -- | 36 | -- |
26 | 2.31.1 | 37 | 2.35.1 |
27 | |||
28 | |||
29 | diff view generated by jsdifflib |
New patch | |||
---|---|---|---|
1 | From: Sakshi Kaushik <sakshikaushik717@gmail.com> | ||
1 | 2 | ||
3 | Signed-off-by: Sakshi Kaushik <sakshikaushik717@gmail.com> | ||
4 | Message-id: 20220406162410.8536-1-sakshikaushik717@gmail.com | ||
5 | |||
6 | [Name the iSCSI URL long option --iscsi-uri instead of --iscsi_uri for | ||
7 | consistency, fix --fd which was rejected due to an outdated | ||
8 | --socket-path check, and add missing entries[] terminator. | ||
9 | --Stefan] | ||
10 | |||
11 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> | ||
12 | --- | ||
13 | contrib/vhost-user-scsi/vhost-user-scsi.c | 77 +++++++++++++++-------- | ||
14 | 1 file changed, 52 insertions(+), 25 deletions(-) | ||
15 | |||
16 | diff --git a/contrib/vhost-user-scsi/vhost-user-scsi.c b/contrib/vhost-user-scsi/vhost-user-scsi.c | ||
17 | index XXXXXXX..XXXXXXX 100644 | ||
18 | --- a/contrib/vhost-user-scsi/vhost-user-scsi.c | ||
19 | +++ b/contrib/vhost-user-scsi/vhost-user-scsi.c | ||
20 | @@ -XXX,XX +XXX,XX @@ fail: | ||
21 | |||
22 | /** vhost-user-scsi **/ | ||
23 | |||
24 | +static int opt_fdnum = -1; | ||
25 | +static char *opt_socket_path; | ||
26 | +static gboolean opt_print_caps; | ||
27 | +static char *iscsi_uri; | ||
28 | + | ||
29 | +static GOptionEntry entries[] = { | ||
30 | + { "print-capabilities", 'c', 0, G_OPTION_ARG_NONE, &opt_print_caps, | ||
31 | + "Print capabilities", NULL }, | ||
32 | + { "fd", 'f', 0, G_OPTION_ARG_INT, &opt_fdnum, | ||
33 | + "Use inherited fd socket", "FDNUM" }, | ||
34 | + { "iscsi-uri", 'i', 0, G_OPTION_ARG_FILENAME, &iscsi_uri, | ||
35 | + "iSCSI URI to connect to", "FDNUM" }, | ||
36 | + { "socket-path", 's', 0, G_OPTION_ARG_FILENAME, &opt_socket_path, | ||
37 | + "Use UNIX socket path", "PATH" }, | ||
38 | + { NULL, } | ||
39 | +}; | ||
40 | + | ||
41 | int main(int argc, char **argv) | ||
42 | { | ||
43 | VusDev *vdev_scsi = NULL; | ||
44 | - char *unix_fn = NULL; | ||
45 | - char *iscsi_uri = NULL; | ||
46 | - int lsock = -1, csock = -1, opt, err = EXIT_SUCCESS; | ||
47 | + int lsock = -1, csock = -1, err = EXIT_SUCCESS; | ||
48 | |||
49 | - while ((opt = getopt(argc, argv, "u:i:")) != -1) { | ||
50 | - switch (opt) { | ||
51 | - case 'h': | ||
52 | - goto help; | ||
53 | - case 'u': | ||
54 | - unix_fn = g_strdup(optarg); | ||
55 | - break; | ||
56 | - case 'i': | ||
57 | - iscsi_uri = g_strdup(optarg); | ||
58 | - break; | ||
59 | - default: | ||
60 | - goto help; | ||
61 | - } | ||
62 | + GError *error = NULL; | ||
63 | + GOptionContext *context; | ||
64 | + | ||
65 | + context = g_option_context_new(NULL); | ||
66 | + g_option_context_add_main_entries(context, entries, NULL); | ||
67 | + if (!g_option_context_parse(context, &argc, &argv, &error)) { | ||
68 | + g_printerr("Option parsing failed: %s\n", error->message); | ||
69 | + exit(EXIT_FAILURE); | ||
70 | + } | ||
71 | + | ||
72 | + if (opt_print_caps) { | ||
73 | + g_print("{\n"); | ||
74 | + g_print(" \"type\": \"scsi\"\n"); | ||
75 | + g_print("}\n"); | ||
76 | + goto out; | ||
77 | } | ||
78 | - if (!unix_fn || !iscsi_uri) { | ||
79 | + | ||
80 | + if (!iscsi_uri) { | ||
81 | goto help; | ||
82 | } | ||
83 | |||
84 | - lsock = unix_sock_new(unix_fn); | ||
85 | - if (lsock < 0) { | ||
86 | - goto err; | ||
87 | + if (opt_socket_path) { | ||
88 | + lsock = unix_sock_new(opt_socket_path); | ||
89 | + if (lsock < 0) { | ||
90 | + exit(EXIT_FAILURE); | ||
91 | + } | ||
92 | + } else if (opt_fdnum < 0) { | ||
93 | + g_print("%s\n", g_option_context_get_help(context, true, NULL)); | ||
94 | + exit(EXIT_FAILURE); | ||
95 | + } else { | ||
96 | + lsock = opt_fdnum; | ||
97 | } | ||
98 | |||
99 | csock = accept(lsock, NULL, NULL); | ||
100 | @@ -XXX,XX +XXX,XX @@ out: | ||
101 | if (vdev_scsi) { | ||
102 | g_main_loop_unref(vdev_scsi->loop); | ||
103 | g_free(vdev_scsi); | ||
104 | - unlink(unix_fn); | ||
105 | + unlink(opt_socket_path); | ||
106 | } | ||
107 | if (csock >= 0) { | ||
108 | close(csock); | ||
109 | @@ -XXX,XX +XXX,XX @@ out: | ||
110 | if (lsock >= 0) { | ||
111 | close(lsock); | ||
112 | } | ||
113 | - g_free(unix_fn); | ||
114 | + g_free(opt_socket_path); | ||
115 | g_free(iscsi_uri); | ||
116 | |||
117 | return err; | ||
118 | @@ -XXX,XX +XXX,XX @@ err: | ||
119 | goto out; | ||
120 | |||
121 | help: | ||
122 | - fprintf(stderr, "Usage: %s [ -u unix_sock_path -i iscsi_uri ] | [ -h ]\n", | ||
123 | + fprintf(stderr, "Usage: %s [ -s socket-path -i iscsi-uri -f fd -p print-capabilities ] | [ -h ]\n", | ||
124 | argv[0]); | ||
125 | - fprintf(stderr, " -u path to unix socket\n"); | ||
126 | - fprintf(stderr, " -i iscsi uri for lun 0\n"); | ||
127 | + fprintf(stderr, " -s, --socket-path=SOCKET_PATH path to unix socket\n"); | ||
128 | + fprintf(stderr, " -i, --iscsi-uri=ISCSI_URI iscsi uri for lun 0\n"); | ||
129 | + fprintf(stderr, " -f, --fd=FILE_DESCRIPTOR file-descriptor\n"); | ||
130 | + fprintf(stderr, " -p, --print-capabilities=PRINT_CAPABILITIES denotes print-capabilities\n"); | ||
131 | fprintf(stderr, " -h print help and quit\n"); | ||
132 | |||
133 | goto err; | ||
134 | -- | ||
135 | 2.35.1 | diff view generated by jsdifflib |
1 | From: Stefano Garzarella <sgarzare@redhat.com> | 1 | The GLib documentation says "a NULL-terminated array of GOptionEntrys" |
---|---|---|---|
2 | so we'd better make sure there is a terminator that lets | ||
3 | g_option_context_add_main_entries() know when the end of the array has | ||
4 | been reached. | ||
2 | 5 | ||
3 | Commit 0445409d74 ("iothread: generalize | 6 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> |
4 | iothread_set_param/iothread_get_param") moved common code to set and | 7 | Reviewed-by: Michael S. Tsirkin <mst@redhat.com> |
5 | get IOThread parameters in two new functions. | 8 | Message-id: 20220411150057.3009667-1-stefanha@redhat.com |
6 | |||
7 | These functions are called inside callbacks, so we don't need to use an | ||
8 | opaque pointer. Let's replace `void *opaque` parameter with | ||
9 | `IOThreadParamInfo *info`. | ||
10 | |||
11 | Suggested-by: Kevin Wolf <kwolf@redhat.com> | ||
12 | Signed-off-by: Stefano Garzarella <sgarzare@redhat.com> | ||
13 | Reviewed-by: Philippe Mathieu-Daudé <philmd@redhat.com> | ||
14 | Message-id: 20210727145936.147032-3-sgarzare@redhat.com | ||
15 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> | 9 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> |
16 | --- | 10 | --- |
17 | iothread.c | 18 ++++++++++-------- | 11 | contrib/vhost-user-blk/vhost-user-blk.c | 3 ++- |
18 | 1 file changed, 10 insertions(+), 8 deletions(-) | 12 | 1 file changed, 2 insertions(+), 1 deletion(-) |
19 | 13 | ||
20 | diff --git a/iothread.c b/iothread.c | 14 | diff --git a/contrib/vhost-user-blk/vhost-user-blk.c b/contrib/vhost-user-blk/vhost-user-blk.c |
21 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
22 | --- a/iothread.c | 16 | --- a/contrib/vhost-user-blk/vhost-user-blk.c |
23 | +++ b/iothread.c | 17 | +++ b/contrib/vhost-user-blk/vhost-user-blk.c |
24 | @@ -XXX,XX +XXX,XX @@ static IOThreadParamInfo aio_max_batch_info = { | 18 | @@ -XXX,XX +XXX,XX @@ static GOptionEntry entries[] = { |
19 | {"blk-file", 'b', 0, G_OPTION_ARG_FILENAME, &opt_blk_file, | ||
20 | "block device or file path", "PATH"}, | ||
21 | { "read-only", 'r', 0, G_OPTION_ARG_NONE, &opt_read_only, | ||
22 | - "Enable read-only", NULL } | ||
23 | + "Enable read-only", NULL }, | ||
24 | + { NULL, }, | ||
25 | }; | 25 | }; |
26 | 26 | ||
27 | static void iothread_get_param(Object *obj, Visitor *v, | 27 | int main(int argc, char **argv) |
28 | - const char *name, void *opaque, Error **errp) | ||
29 | + const char *name, IOThreadParamInfo *info, Error **errp) | ||
30 | { | ||
31 | IOThread *iothread = IOTHREAD(obj); | ||
32 | - IOThreadParamInfo *info = opaque; | ||
33 | int64_t *field = (void *)iothread + info->offset; | ||
34 | |||
35 | visit_type_int64(v, name, field, errp); | ||
36 | } | ||
37 | |||
38 | static bool iothread_set_param(Object *obj, Visitor *v, | ||
39 | - const char *name, void *opaque, Error **errp) | ||
40 | + const char *name, IOThreadParamInfo *info, Error **errp) | ||
41 | { | ||
42 | IOThread *iothread = IOTHREAD(obj); | ||
43 | - IOThreadParamInfo *info = opaque; | ||
44 | int64_t *field = (void *)iothread + info->offset; | ||
45 | int64_t value; | ||
46 | |||
47 | @@ -XXX,XX +XXX,XX @@ static bool iothread_set_param(Object *obj, Visitor *v, | ||
48 | static void iothread_get_poll_param(Object *obj, Visitor *v, | ||
49 | const char *name, void *opaque, Error **errp) | ||
50 | { | ||
51 | + IOThreadParamInfo *info = opaque; | ||
52 | |||
53 | - iothread_get_param(obj, v, name, opaque, errp); | ||
54 | + iothread_get_param(obj, v, name, info, errp); | ||
55 | } | ||
56 | |||
57 | static void iothread_set_poll_param(Object *obj, Visitor *v, | ||
58 | const char *name, void *opaque, Error **errp) | ||
59 | { | ||
60 | IOThread *iothread = IOTHREAD(obj); | ||
61 | + IOThreadParamInfo *info = opaque; | ||
62 | |||
63 | - if (!iothread_set_param(obj, v, name, opaque, errp)) { | ||
64 | + if (!iothread_set_param(obj, v, name, info, errp)) { | ||
65 | return; | ||
66 | } | ||
67 | |||
68 | @@ -XXX,XX +XXX,XX @@ static void iothread_set_poll_param(Object *obj, Visitor *v, | ||
69 | static void iothread_get_aio_param(Object *obj, Visitor *v, | ||
70 | const char *name, void *opaque, Error **errp) | ||
71 | { | ||
72 | + IOThreadParamInfo *info = opaque; | ||
73 | |||
74 | - iothread_get_param(obj, v, name, opaque, errp); | ||
75 | + iothread_get_param(obj, v, name, info, errp); | ||
76 | } | ||
77 | |||
78 | static void iothread_set_aio_param(Object *obj, Visitor *v, | ||
79 | const char *name, void *opaque, Error **errp) | ||
80 | { | ||
81 | IOThread *iothread = IOTHREAD(obj); | ||
82 | + IOThreadParamInfo *info = opaque; | ||
83 | |||
84 | - if (!iothread_set_param(obj, v, name, opaque, errp)) { | ||
85 | + if (!iothread_set_param(obj, v, name, info, errp)) { | ||
86 | return; | ||
87 | } | ||
88 | |||
89 | -- | 28 | -- |
90 | 2.31.1 | 29 | 2.35.1 |
91 | |||
92 | diff view generated by jsdifflib |
1 | From: Stefano Garzarella <sgarzare@redhat.com> | 1 | From: Liu Yiding <liuyd.fnst@fujitsu.com> |
---|---|---|---|
2 | 2 | ||
3 | Commit 1793ad0247 ("iothread: add aio-max-batch parameter") added | 3 | virtiofsd has introduced killpriv_v2/no_killpriv_v2 for a while. Add |
4 | a new parameter (aio-max-batch) to IOThread and used PollParamInfo | 4 | description of it to docs/helper. |
5 | structure to handle it. | ||
6 | 5 | ||
7 | Since it is not a parameter of the polling mechanism, we rename the | 6 | Signed-off-by: Liu Yiding <liuyd.fnst@fujitsu.com> |
8 | structure to a more generic IOThreadParamInfo. | 7 | Message-Id: <20220421095151.2231099-1-liuyd.fnst@fujitsu.com> |
9 | 8 | ||
10 | Suggested-by: Kevin Wolf <kwolf@redhat.com> | 9 | [Small documentation fixes: s/as client supports/as the client supports/ |
11 | Signed-off-by: Stefano Garzarella <sgarzare@redhat.com> | 10 | and s/. /. /. |
12 | Reviewed-by: Philippe Mathieu-Daudé <philmd@redhat.com> | 11 | --Stefan] |
13 | Message-id: 20210727145936.147032-2-sgarzare@redhat.com | 12 | |
14 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> | 13 | Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com> |
15 | --- | 14 | --- |
16 | iothread.c | 14 +++++++------- | 15 | docs/tools/virtiofsd.rst | 5 +++++ |
17 | 1 file changed, 7 insertions(+), 7 deletions(-) | 16 | tools/virtiofsd/helper.c | 3 +++ |
17 | 2 files changed, 8 insertions(+) | ||
18 | 18 | ||
19 | diff --git a/iothread.c b/iothread.c | 19 | diff --git a/docs/tools/virtiofsd.rst b/docs/tools/virtiofsd.rst |
20 | index XXXXXXX..XXXXXXX 100644 | 20 | index XXXXXXX..XXXXXXX 100644 |
21 | --- a/iothread.c | 21 | --- a/docs/tools/virtiofsd.rst |
22 | +++ b/iothread.c | 22 | +++ b/docs/tools/virtiofsd.rst |
23 | @@ -XXX,XX +XXX,XX @@ static void iothread_complete(UserCreatable *obj, Error **errp) | 23 | @@ -XXX,XX +XXX,XX @@ Options |
24 | typedef struct { | 24 | label. Server will try to set that label on newly created file |
25 | const char *name; | 25 | atomically wherever possible. |
26 | ptrdiff_t offset; /* field's byte offset in IOThread struct */ | 26 | |
27 | -} PollParamInfo; | 27 | + * killpriv_v2|no_killpriv_v2 - |
28 | +} IOThreadParamInfo; | 28 | + Enable/disable ``FUSE_HANDLE_KILLPRIV_V2`` support. KILLPRIV_V2 is enabled |
29 | 29 | + by default as long as the client supports it. Enabling this option helps | |
30 | -static PollParamInfo poll_max_ns_info = { | 30 | + with performance in write path. |
31 | +static IOThreadParamInfo poll_max_ns_info = { | 31 | + |
32 | "poll-max-ns", offsetof(IOThread, poll_max_ns), | 32 | .. option:: --socket-path=PATH |
33 | }; | 33 | |
34 | -static PollParamInfo poll_grow_info = { | 34 | Listen on vhost-user UNIX domain socket at PATH. |
35 | +static IOThreadParamInfo poll_grow_info = { | 35 | diff --git a/tools/virtiofsd/helper.c b/tools/virtiofsd/helper.c |
36 | "poll-grow", offsetof(IOThread, poll_grow), | 36 | index XXXXXXX..XXXXXXX 100644 |
37 | }; | 37 | --- a/tools/virtiofsd/helper.c |
38 | -static PollParamInfo poll_shrink_info = { | 38 | +++ b/tools/virtiofsd/helper.c |
39 | +static IOThreadParamInfo poll_shrink_info = { | 39 | @@ -XXX,XX +XXX,XX @@ void fuse_cmdline_help(void) |
40 | "poll-shrink", offsetof(IOThread, poll_shrink), | 40 | " -o announce_submounts Announce sub-mount points to the guest\n" |
41 | }; | 41 | " -o posix_acl/no_posix_acl Enable/Disable posix_acl. (default: disabled)\n" |
42 | -static PollParamInfo aio_max_batch_info = { | 42 | " -o security_label/no_security_label Enable/Disable security label. (default: disabled)\n" |
43 | +static IOThreadParamInfo aio_max_batch_info = { | 43 | + " -o killpriv_v2/no_killpriv_v2\n" |
44 | "aio-max-batch", offsetof(IOThread, aio_max_batch), | 44 | + " Enable/Disable FUSE_HANDLE_KILLPRIV_V2.\n" |
45 | }; | 45 | + " (default: enabled as long as client supports it)\n" |
46 | 46 | ); | |
47 | @@ -XXX,XX +XXX,XX @@ static void iothread_get_param(Object *obj, Visitor *v, | 47 | } |
48 | const char *name, void *opaque, Error **errp) | ||
49 | { | ||
50 | IOThread *iothread = IOTHREAD(obj); | ||
51 | - PollParamInfo *info = opaque; | ||
52 | + IOThreadParamInfo *info = opaque; | ||
53 | int64_t *field = (void *)iothread + info->offset; | ||
54 | |||
55 | visit_type_int64(v, name, field, errp); | ||
56 | @@ -XXX,XX +XXX,XX @@ static bool iothread_set_param(Object *obj, Visitor *v, | ||
57 | const char *name, void *opaque, Error **errp) | ||
58 | { | ||
59 | IOThread *iothread = IOTHREAD(obj); | ||
60 | - PollParamInfo *info = opaque; | ||
61 | + IOThreadParamInfo *info = opaque; | ||
62 | int64_t *field = (void *)iothread + info->offset; | ||
63 | int64_t value; | ||
64 | 48 | ||
65 | -- | 49 | -- |
66 | 2.31.1 | 50 | 2.35.1 |
67 | |||
68 | diff view generated by jsdifflib |