|
|
902636 |
From 249c02ae54739dc5894ee1b2905bbe8f1e79e909 Mon Sep 17 00:00:00 2001
|
|
|
902636 |
From: "Dr. David Alan Gilbert" <dgilbert@redhat.com>
|
|
|
902636 |
Date: Mon, 27 Jan 2020 19:02:20 +0100
|
|
|
902636 |
Subject: [PATCH 109/116] virtiofsd: prevent FUSE_INIT/FUSE_DESTROY races
|
|
|
902636 |
MIME-Version: 1.0
|
|
|
902636 |
Content-Type: text/plain; charset=UTF-8
|
|
|
902636 |
Content-Transfer-Encoding: 8bit
|
|
|
902636 |
|
|
|
902636 |
RH-Author: Dr. David Alan Gilbert <dgilbert@redhat.com>
|
|
|
902636 |
Message-id: <20200127190227.40942-106-dgilbert@redhat.com>
|
|
|
902636 |
Patchwork-id: 93562
|
|
|
902636 |
O-Subject: [RHEL-AV-8.2 qemu-kvm PATCH 105/112] virtiofsd: prevent FUSE_INIT/FUSE_DESTROY races
|
|
|
902636 |
Bugzilla: 1694164
|
|
|
902636 |
RH-Acked-by: Philippe Mathieu-Daudé <philmd@redhat.com>
|
|
|
902636 |
RH-Acked-by: Stefan Hajnoczi <stefanha@redhat.com>
|
|
|
902636 |
RH-Acked-by: Sergio Lopez Pascual <slp@redhat.com>
|
|
|
902636 |
|
|
|
902636 |
From: Stefan Hajnoczi <stefanha@redhat.com>
|
|
|
902636 |
|
|
|
902636 |
When running with multiple threads it can be tricky to handle
|
|
|
902636 |
FUSE_INIT/FUSE_DESTROY in parallel with other request types or in
|
|
|
902636 |
parallel with themselves. Serialize FUSE_INIT and FUSE_DESTROY so that
|
|
|
902636 |
malicious clients cannot trigger race conditions.
|
|
|
902636 |
|
|
|
902636 |
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
|
|
|
902636 |
Reviewed-by: Masayoshi Mizuma <m.mizuma@jp.fujitsu.com>
|
|
|
902636 |
Signed-off-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
|
|
|
902636 |
(cherry picked from commit cdc497c6925be745bc895355bd4674a17a4b2a8b)
|
|
|
902636 |
Signed-off-by: Miroslav Rezanina <mrezanin@redhat.com>
|
|
|
902636 |
|
|
|
902636 |
tools/virtiofsd/fuse_i.h | 1 +
|
|
|
902636 |
tools/virtiofsd/fuse_lowlevel.c | 18 ++++++++++++++++++
|
|
|
902636 |
2 files changed, 19 insertions(+)
|
|
|
902636 |
|
|
|
902636 |
diff
|
|
|
902636 |
index a20854f..1447d86 100644
|
|
|
902636 |
|
|
|
902636 |
|
|
|
902636 |
@@ -61,6 +61,7 @@ struct fuse_session {
|
|
|
902636 |
struct fuse_req list;
|
|
|
902636 |
struct fuse_req interrupts;
|
|
|
902636 |
pthread_mutex_t lock;
|
|
|
902636 |
+ pthread_rwlock_t init_rwlock;
|
|
|
902636 |
int got_destroy;
|
|
|
902636 |
int broken_splice_nonblock;
|
|
|
902636 |
uint64_t notify_ctr;
|
|
|
902636 |
diff
|
|
|
902636 |
index dab6a31..79a4031 100644
|
|
|
902636 |
|
|
|
902636 |
|
|
|
902636 |
@@ -2428,6 +2428,19 @@ void fuse_session_process_buf_int(struct fuse_session *se,
|
|
|
902636 |
req->ctx.pid = in->pid;
|
|
|
902636 |
req->ch = ch;
|
|
|
902636 |
|
|
|
902636 |
+ /*
|
|
|
902636 |
+ * INIT and DESTROY requests are serialized, all other request types
|
|
|
902636 |
+ * run in parallel. This prevents races between FUSE_INIT and ordinary
|
|
|
902636 |
+ * requests, FUSE_INIT and FUSE_INIT, FUSE_INIT and FUSE_DESTROY, and
|
|
|
902636 |
+ * FUSE_DESTROY and FUSE_DESTROY.
|
|
|
902636 |
+ */
|
|
|
902636 |
+ if (in->opcode == FUSE_INIT || in->opcode == CUSE_INIT ||
|
|
|
902636 |
+ in->opcode == FUSE_DESTROY) {
|
|
|
902636 |
+ pthread_rwlock_wrlock(&se->init_rwlock);
|
|
|
902636 |
+ } else {
|
|
|
902636 |
+ pthread_rwlock_rdlock(&se->init_rwlock);
|
|
|
902636 |
+ }
|
|
|
902636 |
+
|
|
|
902636 |
err = EIO;
|
|
|
902636 |
if (!se->got_init) {
|
|
|
902636 |
enum fuse_opcode expected;
|
|
|
902636 |
@@ -2485,10 +2498,13 @@ void fuse_session_process_buf_int(struct fuse_session *se,
|
|
|
902636 |
} else {
|
|
|
902636 |
fuse_ll_ops[in->opcode].func(req, in->nodeid, &iter);
|
|
|
902636 |
}
|
|
|
902636 |
+
|
|
|
902636 |
+ pthread_rwlock_unlock(&se->init_rwlock);
|
|
|
902636 |
return;
|
|
|
902636 |
|
|
|
902636 |
reply_err:
|
|
|
902636 |
fuse_reply_err(req, err);
|
|
|
902636 |
+ pthread_rwlock_unlock(&se->init_rwlock);
|
|
|
902636 |
}
|
|
|
902636 |
|
|
|
902636 |
#define LL_OPTION(n, o, v) \
|
|
|
902636 |
@@ -2531,6 +2547,7 @@ void fuse_session_destroy(struct fuse_session *se)
|
|
|
902636 |
se->op.destroy(se->userdata);
|
|
|
902636 |
}
|
|
|
902636 |
}
|
|
|
902636 |
+ pthread_rwlock_destroy(&se->init_rwlock);
|
|
|
902636 |
pthread_mutex_destroy(&se->lock);
|
|
|
902636 |
free(se->cuse_data);
|
|
|
902636 |
if (se->fd != -1) {
|
|
|
902636 |
@@ -2610,6 +2627,7 @@ struct fuse_session *fuse_session_new(struct fuse_args *args,
|
|
|
902636 |
list_init_req(&se->list);
|
|
|
902636 |
list_init_req(&se->interrupts);
|
|
|
902636 |
fuse_mutex_init(&se->lock);
|
|
|
902636 |
+ pthread_rwlock_init(&se->init_rwlock, NULL);
|
|
|
902636 |
|
|
|
902636 |
memcpy(&se->op, op, op_size);
|
|
|
902636 |
se->owner = getuid();
|
|
|
902636 |
--
|
|
|
902636 |
1.8.3.1
|
|
|
902636 |
|