Add support for fuse to fsdist and fsslower tools

Author: xixiliguo

libbpf-tools/.gitignore

@@ -23,6 +23,8 @@
 /ext4slower
 /f2fsdist
 /f2fsslower
+/fusedist
+/fuseslower
 /filelife
 /filetop
 /fsdist

libbpf-tools/Makefile

@@ -100,8 +100,8 @@ APPS = \
 # export variables that are used in Makefile.btfgen as well.
 export OUTPUT BPFTOOL ARCH BTFHUB_ARCHIVE APPS
 
-FSDIST_ALIASES = btrfsdist ext4dist nfsdist xfsdist f2fsdist bcachefsdist zfsdist
-FSSLOWER_ALIASES = btrfsslower ext4slower nfsslower xfsslower f2fsslower bcachefsslower zfsslower
+FSDIST_ALIASES = btrfsdist ext4dist fusedist nfsdist xfsdist f2fsdist bcachefsdist zfsdist
+FSSLOWER_ALIASES = btrfsslower ext4slower fuseslower nfsslower xfsslower f2fsslower bcachefsslower zfsslower
 SIGSNOOP_ALIAS = killsnoop
 APP_ALIASES = $(FSDIST_ALIASES) $(FSSLOWER_ALIASES) ${SIGSNOOP_ALIAS}
 

libbpf-tools/fsdist.c

@@ -39,6 +39,7 @@ enum fs_type {
 	F2FS,
 	BCACHEFS,
 	ZFS,
+	FUSE,
 };
 
 static struct fs_config {
@@ -94,6 +95,13 @@ static struct fs_config {
 		[F_FSYNC] = "zpl_fsync",
 		[F_GETATTR] = NULL, /* not supported */
 	}},
+	[FUSE] = { "fuse", {
+		[F_READ] = "fuse_file_read_iter",
+		[F_WRITE] = "fuse_file_write_iter",
+		[F_OPEN] = "fuse_open",
+		[F_FSYNC] = "fuse_fsync",
+		[F_GETATTR] = "fuse_getattr",
+	}},
 };
 
 static char *file_op_names[] = {
@@ -134,7 +142,7 @@ static const struct argp_option opts[] = {
 	{ "timestamp", 'T', NULL, 0, "Print timestamp", 0 },
 	{ "milliseconds", 'm', NULL, 0, "Millisecond histogram", 0 },
 	{ "pid", 'p', "PID", 0, "Process ID to trace", 0 },
-	{ "type", 't', "Filesystem", 0, "Which filesystem to trace, [btrfs/ext4/nfs/xfs/f2fs/bcachefs/zfs]", 0 },
+	{ "type", 't', "Filesystem", 0, "Which filesystem to trace, [btrfs/ext4/nfs/xfs/f2fs/bcachefs/zfs/fuse]", 0 },
 	{ "verbose", 'v', NULL, 0, "Verbose debug output", 0 },
 	{ NULL, 'h', NULL, OPTION_HIDDEN, "Show the full help", 0 },
 	{},
@@ -169,6 +177,8 @@ static error_t parse_arg(int key, char *arg, struct argp_state *state)
 			fs_type = BCACHEFS;
 		} else if (!strcmp(arg, "zfs")) {
 			fs_type = ZFS;
+		} else if (!strcmp(arg, "fuse")) {
+			fs_type = FUSE;
 		} else {
 			warn("invalid filesystem\n");
 			argp_usage(state);
@@ -229,6 +239,8 @@ static void alias_parse(char *prog)
 		fs_type = BCACHEFS;
 	} else if (strstr(name, "zfsdist")) {
 		fs_type = ZFS;
+	} else if (strstr(name, "fusedist")) {
+		fs_type = FUSE;
 	}
 }
 

libbpf-tools/fsslower.c

@@ -42,6 +42,7 @@ enum fs_type {
 	F2FS,
 	BCACHEFS,
 	ZFS,
+	FUSE,
 };
 
 static struct fs_config {
@@ -90,6 +91,12 @@ static struct fs_config {
 		[F_OPEN] = "zpl_open",
 		[F_FSYNC] = "zpl_fsync",
 	}},
+	[FUSE] = { "fuse", {
+		[F_READ] = "fuse_file_read_iter",
+		[F_WRITE] = "fuse_file_write_iter",
+		[F_OPEN] = "fuse_open",
+		[F_FSYNC] = "fuse_fsync",
+	}},
 };
 
 static char file_op[] = {
@@ -127,7 +134,7 @@ static const struct argp_option opts[] = {
 	{ "duration", 'd', "DURATION", 0, "Total duration of trace in seconds", 0 },
 	{ "pid", 'p', "PID", 0, "Process ID to trace", 0 },
 	{ "min", 'm', "MIN", 0, "Min latency to trace, in ms (default 10)", 0 },
-	{ "type", 't', "Filesystem", 0, "Which filesystem to trace, [btrfs/ext4/nfs/xfs/f2fs/bcachefs/zfs]", 0 },
+	{ "type", 't', "Filesystem", 0, "Which filesystem to trace, [btrfs/ext4/nfs/xfs/f2fs/bcachefs/zfs/fuse]", 0 },
 	{ "verbose", 'v', NULL, 0, "Verbose debug output", 0 },
 	{ NULL, 'h', NULL, OPTION_HIDDEN, "Show the full help", 0 },
 	{},
@@ -172,6 +179,8 @@ static error_t parse_arg(int key, char *arg, struct argp_state *state)
 			fs_type = BCACHEFS;
 		} else if (!strcmp(arg, "zfs")) {
 			fs_type = ZFS;
+		} else if (!strcmp(arg, "fuse")) {
+			fs_type = FUSE;
 		} else {
 			warn("invalid filesystem\n");
 			argp_usage(state);
@@ -212,6 +221,8 @@ static void alias_parse(char *prog)
 		fs_type = BCACHEFS;
 	} else if (!strcmp(name, "zfsslower")) {
 		fs_type = ZFS;
+	} else if (!strcmp(name, "fuseslower")) {
+		fs_type = FUSE;
 	}
 }