[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <176169813930.1427432.10103793123149377393.stgit@frogsfrogsfrogs>
Date: Tue, 28 Oct 2025 18:05:02 -0700
From: "Darrick J. Wong" <djwong@...nel.org>
To: djwong@...nel.org, bschubert@....com
Cc: linux-ext4@...r.kernel.org, linux-fsdevel@...r.kernel.org,
bernd@...ernd.com, miklos@...redi.hu, joannelkoong@...il.com, neal@...pa.dev
Subject: [PATCH 22/22] libfuse: add upper-level filesystem freeze, thaw,
and shutdown events
From: Darrick J. Wong <djwong@...nel.org>
Pass filesystem freeze, thaw, and shutdown requests from the low level
library to the upper level library so that those fuse servers can handle
the events.
Signed-off-by: "Darrick J. Wong" <djwong@...nel.org>
---
include/fuse.h | 15 +++++++++
lib/fuse.c | 95 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
2 files changed, 110 insertions(+)
diff --git a/include/fuse.h b/include/fuse.h
index e53e92786cea08..a10666b78eb1eb 100644
--- a/include/fuse.h
+++ b/include/fuse.h
@@ -903,6 +903,21 @@ struct fuse_operations {
*/
int (*iomap_config) (uint64_t supported_flags, off_t maxbytes,
struct fuse_iomap_config *cfg);
+
+ /**
+ * Freeze the filesystem
+ */
+ int (*freezefs) (const char *path, uint64_t unlinked_files);
+
+ /**
+ * Thaw the filesystem
+ */
+ int (*unfreezefs) (const char *path);
+
+ /**
+ * Shut down the filesystem
+ */
+ int (*shutdownfs) (const char *path, uint64_t flags);
};
/** Extra context that may be needed by some filesystems
diff --git a/lib/fuse.c b/lib/fuse.c
index ed2bd3da212743..b8d4b4600077d7 100644
--- a/lib/fuse.c
+++ b/lib/fuse.c
@@ -2968,6 +2968,38 @@ static int fuse_fs_iomap_config(struct fuse_fs *fs, uint64_t flags,
return fs->op.iomap_config(flags, maxbytes, cfg);
}
+static int fuse_fs_freezefs(struct fuse_fs *fs, const char *path,
+ uint64_t unlinked)
+{
+ fuse_get_context()->private_data = fs->user_data;
+ if (!fs->op.freezefs)
+ return -ENOSYS;
+ if (fs->debug)
+ fuse_log(FUSE_LOG_DEBUG, "freezefs[%s]\n", path);
+ return fs->op.freezefs(path, unlinked);
+}
+
+static int fuse_fs_unfreezefs(struct fuse_fs *fs, const char *path)
+{
+ fuse_get_context()->private_data = fs->user_data;
+ if (!fs->op.unfreezefs)
+ return -ENOSYS;
+ if (fs->debug)
+ fuse_log(FUSE_LOG_DEBUG, "unfreezefs[%s]\n", path);
+ return fs->op.unfreezefs(path);
+}
+
+static int fuse_fs_shutdownfs(struct fuse_fs *fs, const char *path,
+ uint64_t flags)
+{
+ fuse_get_context()->private_data = fs->user_data;
+ if (!fs->op.shutdownfs)
+ return -ENOSYS;
+ if (fs->debug)
+ fuse_log(FUSE_LOG_DEBUG, "shutdownfs[%s]\n", path);
+ return fs->op.shutdownfs(path, flags);
+}
+
static void fuse_lib_setattr(fuse_req_t req, fuse_ino_t ino, struct stat *attr,
int valid, struct fuse_file_info *fi)
{
@@ -4841,6 +4873,66 @@ static void fuse_lib_iomap_config(fuse_req_t req, uint64_t flags,
fuse_reply_iomap_config(req, &cfg);
}
+static void fuse_lib_freezefs(fuse_req_t req, fuse_ino_t ino, uint64_t unlinked)
+{
+ struct fuse *f = req_fuse_prepare(req);
+ struct fuse_intr_data d;
+ char *path;
+ int err;
+
+ err = get_path(f, ino, &path);
+ if (err) {
+ reply_err(req, err);
+ return;
+ }
+
+ fuse_prepare_interrupt(f, req, &d);
+ err = fuse_fs_freezefs(f->fs, path, unlinked);
+ fuse_finish_interrupt(f, req, &d);
+ free_path(f, ino, path);
+ reply_err(req, err);
+}
+
+static void fuse_lib_unfreezefs(fuse_req_t req, fuse_ino_t ino)
+{
+ struct fuse *f = req_fuse_prepare(req);
+ struct fuse_intr_data d;
+ char *path;
+ int err;
+
+ err = get_path(f, ino, &path);
+ if (err) {
+ reply_err(req, err);
+ return;
+ }
+
+ fuse_prepare_interrupt(f, req, &d);
+ err = fuse_fs_unfreezefs(f->fs, path);
+ fuse_finish_interrupt(f, req, &d);
+ free_path(f, ino, path);
+ reply_err(req, err);
+}
+
+static void fuse_lib_shutdownfs(fuse_req_t req, fuse_ino_t ino, uint64_t flags)
+{
+ struct fuse *f = req_fuse_prepare(req);
+ struct fuse_intr_data d;
+ char *path;
+ int err;
+
+ err = get_path(f, ino, &path);
+ if (err) {
+ reply_err(req, err);
+ return;
+ }
+
+ fuse_prepare_interrupt(f, req, &d);
+ err = fuse_fs_shutdownfs(f->fs, path, flags);
+ fuse_finish_interrupt(f, req, &d);
+ free_path(f, ino, path);
+ reply_err(req, err);
+}
+
static int clean_delay(struct fuse *f)
{
/*
@@ -4942,6 +5034,9 @@ static struct fuse_lowlevel_ops fuse_path_ops = {
#ifdef HAVE_STATX
.statx = fuse_lib_statx,
#endif
+ .freezefs = fuse_lib_freezefs,
+ .unfreezefs = fuse_lib_unfreezefs,
+ .shutdownfs = fuse_lib_shutdownfs,
.iomap_begin = fuse_lib_iomap_begin,
.iomap_end = fuse_lib_iomap_end,
.iomap_ioend = fuse_lib_iomap_ioend,
Powered by blists - more mailing lists