Extends the `debugfs` API to support creating writable files. This
is done via the `Dir::write_only_file` and `Dir::read_write_file`
methods, which take a data object that implements the `UpdateFromSlice`
trait.
Signed-off-by: Matthew Maurer <mmaurer@google.com>
---
rust/kernel/debugfs.rs | 41 +++++++++++++-
rust/kernel/debugfs/file_ops.rs | 115 +++++++++++++++++++++++++++++++++++++++-
rust/kernel/debugfs/traits.rs | 69 ++++++++++++++++++++++++
3 files changed, 222 insertions(+), 3 deletions(-)
diff --git a/rust/kernel/debugfs.rs b/rust/kernel/debugfs.rs
index 875d433fc3608cc9ffcf022d7c00cb207016f146..62bc2b1d4e5a4b21441a09e03bff74c32c6781d2 100644
--- a/rust/kernel/debugfs.rs
+++ b/rust/kernel/debugfs.rs
@@ -16,10 +16,10 @@
use core::ops::Deref;
mod traits;
-pub use traits::Render;
+pub use traits::{Render, UpdateFromSlice};
mod file_ops;
-use file_ops::{FileOps, ReadFile};
+use file_ops::{FileOps, ReadFile, ReadWriteFile, WriteFile};
#[cfg(CONFIG_DEBUG_FS)]
mod entry;
#[cfg(CONFIG_DEBUG_FS)]
@@ -136,6 +136,43 @@ pub fn read_only_file<'a, T: Render + Send + Sync + 'static, E: 'a, TI: PinInit<
let file_ops = &<T as ReadFile<_>>::FILE_OPS;
self.create_file(name, data, file_ops)
}
+
+ /// Creates a read-write file in this directory.
+ ///
+ /// Reading the file uses the [`Render`] implementation.
+ /// Writing to the file uses the [`UpdateFromSlice`] implementation.
+ pub fn read_write_file<
+ 'a,
+ T: Render + UpdateFromSlice + Send + Sync + 'static,
+ E: 'a,
+ TI: PinInit<T, E> + 'a,
+ >(
+ &'a self,
+ name: &'a CStr,
+ data: TI,
+ ) -> impl PinInit<File<T>, E> + 'a {
+ let file_ops = &<T as ReadWriteFile<_>>::FILE_OPS;
+ self.create_file(name, data, file_ops)
+ }
+
+ /// Creates a write-only file in this directory.
+ ///
+ /// The file owns its backing data. Writing to the file uses the [`UpdateFromSlice`]
+ /// implementation.
+ ///
+ /// The file is removed when the returned [`File`] is dropped.
+ pub fn write_only_file<
+ 'a,
+ T: UpdateFromSlice + Send + Sync + 'static,
+ E: 'a,
+ TI: PinInit<T, E> + 'a,
+ >(
+ &'a self,
+ name: &'a CStr,
+ data: TI,
+ ) -> impl PinInit<File<T>, E> + 'a {
+ self.create_file(name, data, &T::FILE_OPS)
+ }
}
#[pin_data]
diff --git a/rust/kernel/debugfs/file_ops.rs b/rust/kernel/debugfs/file_ops.rs
index 134ac26e80f2e5b9cae53ed5a00462af7ce1aa38..30f6a0532c7f5f4a2974edc8f1100f5485aa8da9 100644
--- a/rust/kernel/debugfs/file_ops.rs
+++ b/rust/kernel/debugfs/file_ops.rs
@@ -1,10 +1,11 @@
// SPDX-License-Identifier: GPL-2.0
// Copyright (C) 2025 Google LLC.
-use super::Render;
+use super::{Render, UpdateFromSlice};
use crate::prelude::*;
use crate::seq_file::SeqFile;
use crate::seq_print;
+use crate::uaccess::UserSlice;
use core::fmt::{Display, Formatter, Result};
use core::marker::PhantomData;
@@ -123,3 +124,115 @@ impl<T: Render + Sync> ReadFile<T> for T {
unsafe { FileOps::new(operations, 0o400) }
};
}
+
+fn update<T: UpdateFromSlice + Sync>(data: &T, buf: *const c_char, count: usize) -> isize {
+ let mut reader = UserSlice::new(UserPtr::from_ptr(buf as *mut c_void), count).reader();
+
+ if let Err(e) = data.update_from_slice(&mut reader) {
+ return e.to_errno() as isize;
+ }
+
+ count as isize
+}
+
+/// # Safety
+///
+/// `file` must be a valid pointer to a `file` struct.
+/// The `private_data` of the file must contain a valid pointer to a `seq_file` whose
+/// `private` data in turn points to a `T` that implements `UpdateFromSlice`.
+/// `buf` must be a valid user-space buffer.
+pub(crate) unsafe extern "C" fn write<T: UpdateFromSlice + Sync>(
+ file: *mut bindings::file,
+ buf: *const c_char,
+ count: usize,
+ _ppos: *mut bindings::loff_t,
+) -> isize {
+ // SAFETY: The file was opened with `single_open`, which sets `private_data` to a `seq_file`.
+ let seq = unsafe { &mut *((*file).private_data.cast::<bindings::seq_file>()) };
+ // SAFETY: By caller precondition, this pointer is live and points to a value of type `T`.
+ let data = unsafe { &*(seq.private as *const T) };
+ update(data, buf, count)
+}
+
+// A trait to get the file operations for a type.
+pub(crate) trait ReadWriteFile<T> {
+ const FILE_OPS: FileOps<T>;
+}
+
+impl<T: Render + UpdateFromSlice + Sync> ReadWriteFile<T> for T {
+ const FILE_OPS: FileOps<T> = {
+ let operations = bindings::file_operations {
+ open: Some(render_open::<T>),
+ read: Some(bindings::seq_read),
+ write: Some(write::<T>),
+ llseek: Some(bindings::seq_lseek),
+ release: Some(bindings::single_release),
+ // SAFETY: `file_operations` supports zeroes in all fields.
+ ..unsafe { core::mem::zeroed() }
+ };
+ // SAFETY: `operations` is all stock `seq_file` implementations except for `render_open`
+ // and `write`.
+ // `render_open`'s only requirement beyond what is provided to all open functions is that
+ // the inode's data pointer must point to a `T` that will outlive it, which matches the
+ // `FileOps` requirements.
+ // `write` only requires that the file's private data pointer points to `seq_file`
+ // which points to a `T` that will outlive it, which matches what `render_open`
+ // provides.
+ unsafe { FileOps::new(operations, 0o600) }
+ };
+}
+
+/// # Safety
+///
+/// `inode` must be a valid pointer to an `inode` struct.
+/// `file` must be a valid pointer to a `file` struct.
+unsafe extern "C" fn write_only_open(
+ inode: *mut bindings::inode,
+ file: *mut bindings::file,
+) -> c_int {
+ // SAFETY: The caller ensures that `inode` and `file` are valid pointers.
+ unsafe {
+ (*file).private_data = (*inode).i_private;
+ }
+ 0
+}
+
+/// # Safety
+///
+/// * `file` must be a valid pointer to a `file` struct.
+/// * The `private_data` of the file must contain a valid pointer to a `T` that implements
+/// `UpdateFromSlice`.
+/// * `buf` must be a valid user-space buffer.
+pub(crate) unsafe extern "C" fn write_only_write<T: UpdateFromSlice + Sync>(
+ file: *mut bindings::file,
+ buf: *const c_char,
+ count: usize,
+ _ppos: *mut bindings::loff_t,
+) -> isize {
+ // SAFETY: The caller ensures that `file` is a valid pointer and that `private_data` holds a
+ // valid pointer to `T`.
+ let data = unsafe { &*((*file).private_data as *const T) };
+ update(data, buf, count)
+}
+
+pub(crate) trait WriteFile<T> {
+ const FILE_OPS: FileOps<T>;
+}
+
+impl<T: UpdateFromSlice + Sync> WriteFile<T> for T {
+ const FILE_OPS: FileOps<T> = {
+ let operations = bindings::file_operations {
+ open: Some(write_only_open),
+ write: Some(write_only_write::<T>),
+ llseek: Some(bindings::noop_llseek),
+ // SAFETY: `file_operations` supports zeroes in all fields.
+ ..unsafe { core::mem::zeroed() }
+ };
+ // SAFETY:
+ // * `write_only_open` populates the file private data with the inode private data
+ // * `write_only_write`'s only requirement is that the private data of the file point to
+ // a `T` and be legal to convert to a shared reference, which `write_only_open`
+ // satisfies.
+ unsafe { FileOps::new(operations, 0o200) }
+ };
+}
diff --git a/rust/kernel/debugfs/traits.rs b/rust/kernel/debugfs/traits.rs
index 2939e18e3dda39571cd7255505e5f605f0e3d154..d64638898faaa1a6a9898c374b8c1114993376c9 100644
--- a/rust/kernel/debugfs/traits.rs
+++ b/rust/kernel/debugfs/traits.rs
@@ -3,8 +3,15 @@
//! Traits for rendering or updating values exported to DebugFS.
+use crate::prelude::*;
use crate::sync::Mutex;
+use crate::uaccess::UserSliceReader;
use core::fmt::{self, Debug, Formatter};
+use core::str::FromStr;
+use core::sync::atomic::{
+ AtomicI16, AtomicI32, AtomicI64, AtomicI8, AtomicIsize, AtomicU16, AtomicU32, AtomicU64,
+ AtomicU8, AtomicUsize, Ordering,
+};
/// A trait for types that can be rendered into a string.
///
@@ -26,3 +33,65 @@ fn render(&self, f: &mut Formatter<'_>) -> fmt::Result {
writeln!(f, "{self:?}")
}
}
+
+/// A trait for types that can be updated from a user slice.
+///
+/// This works similarly to `FromStr`, but operates on a `UserSliceReader` rather than a &str.
+///
+/// It is automatically implemented for all atomic integers, or any type that implements `FromStr`
+/// wrapped in a `Mutex`.
+pub trait UpdateFromSlice {
+ /// Updates the value from the given user slice.
+ fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()>;
+}
+
+impl<T: FromStr> UpdateFromSlice for Mutex<T> {
+ fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()> {
+ let mut buf = [0u8; 128];
+ if reader.len() > buf.len() {
+ return Err(EINVAL);
+ }
+ let n = reader.len();
+ reader.read_slice(&mut buf[..n])?;
+
+ let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?;
+ let val = s.trim().parse::<T>().map_err(|_| EINVAL)?;
+ *self.lock() = val;
+ Ok(())
+ }
+}
+
+macro_rules! impl_update_from_slice_for_atomic {
+ ($(($atomic_type:ty, $int_type:ty)),*) => {
+ $(
+ impl UpdateFromSlice for $atomic_type {
+ fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()> {
+ let mut buf = [0u8; 21]; // Enough for a 64-bit number.
+ if reader.len() > buf.len() {
+ return Err(EINVAL);
+ }
+ let n = reader.len();
+ reader.read_slice(&mut buf[..n])?;
+
+ let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?;
+ let val = s.trim().parse::<$int_type>().map_err(|_| EINVAL)?;
+ self.store(val, Ordering::Relaxed);
+ Ok(())
+ }
+ }
+ )*
+ };
+}
+
+impl_update_from_slice_for_atomic!(
+ (AtomicI16, i16),
+ (AtomicI32, i32),
+ (AtomicI64, i64),
+ (AtomicI8, i8),
+ (AtomicIsize, isize),
+ (AtomicU16, u16),
+ (AtomicU32, u32),
+ (AtomicU64, u64),
+ (AtomicU8, u8),
+ (AtomicUsize, usize)
+);
--
2.51.0.rc1.167.g924127e9c0-goog
On Wed Aug 20, 2025 at 12:53 AM CEST, Matthew Maurer wrote: > + /// Creates a read-write file in this directory. > + /// > + /// Reading the file uses the [`Render`] implementation. > + /// Writing to the file uses the [`UpdateFromSlice`] implementation. > + pub fn read_write_file< > + 'a, > + T: Render + UpdateFromSlice + Send + Sync + 'static, > + E: 'a, > + TI: PinInit<T, E> + 'a, Same comments as in the previous patch, I think using a where clause is a bit cleaner, even though with this formatting it'd be fine too, but this is not guaranteed. > + >( > + &'a self, > + name: &'a CStr, > + data: TI, impl PinInit<T, E> + 'a > + ) -> impl PinInit<File<T>, E> + 'a { > + let file_ops = &<T as ReadWriteFile<_>>::FILE_OPS; > + self.create_file(name, data, file_ops) > + } > +fn update<T: UpdateFromSlice + Sync>(data: &T, buf: *const c_char, count: usize) -> isize { > + let mut reader = UserSlice::new(UserPtr::from_ptr(buf as *mut c_void), count).reader(); This naming is pretty close to what I was about to propose for the UpdateFromSlice trait. :) Given that I proposed debugfs::Writer instead of debugfs::Render, I think we should just rename debugfs::UpdateFromSlice to debugfs::Reader. > + > + if let Err(e) = data.update_from_slice(&mut reader) { > + return e.to_errno() as isize; > + } > + > + count as isize > +} <snip> > +/// # Safety > +/// > +/// `inode` must be a valid pointer to an `inode` struct. > +/// `file` must be a valid pointer to a `file` struct. > +unsafe extern "C" fn write_only_open( > + inode: *mut bindings::inode, > + file: *mut bindings::file, > +) -> c_int { > + // SAFETY: The caller ensures that `inode` and `file` are valid pointers. > + unsafe { > + (*file).private_data = (*inode).i_private; > + } NIT: If you move the semicolon at the end of the unsafe block it goes into a single line. > + 0 > +} <snip> > +impl<T: UpdateFromSlice + Sync> WriteFile<T> for T { > + const FILE_OPS: FileOps<T> = { > + let operations = bindings::file_operations { > + open: Some(write_only_open), > + write: Some(write_only_write::<T>), > + llseek: Some(bindings::noop_llseek), > + // SAFETY: `file_operations` supports zeroes in all fields. > + ..unsafe { core::mem::zeroed() } > + }; > + // SAFETY: > + // * `write_only_open` populates the file private data with the inode private data > + // * `write_only_write`'s only requirement is that the private data of the file point to > + // a `T` and be legal to convert to a shared reference, which `write_only_open` > + // satisfies. > + unsafe { FileOps::new(operations, 0o200) } I think it'd be nice to have an abstraction for file modes, but this can be done separately. > + }; > +} > diff --git a/rust/kernel/debugfs/traits.rs b/rust/kernel/debugfs/traits.rs > index 2939e18e3dda39571cd7255505e5f605f0e3d154..d64638898faaa1a6a9898c374b8c1114993376c9 100644 > --- a/rust/kernel/debugfs/traits.rs > +++ b/rust/kernel/debugfs/traits.rs > @@ -3,8 +3,15 @@ > > //! Traits for rendering or updating values exported to DebugFS. > > +use crate::prelude::*; > use crate::sync::Mutex; > +use crate::uaccess::UserSliceReader; > use core::fmt::{self, Debug, Formatter}; > +use core::str::FromStr; > +use core::sync::atomic::{ > + AtomicI16, AtomicI32, AtomicI64, AtomicI8, AtomicIsize, AtomicU16, AtomicU32, AtomicU64, > + AtomicU8, AtomicUsize, Ordering, > +}; > > /// A trait for types that can be rendered into a string. > /// > @@ -26,3 +33,65 @@ fn render(&self, f: &mut Formatter<'_>) -> fmt::Result { > writeln!(f, "{self:?}") > } > } > + > +/// A trait for types that can be updated from a user slice. > +/// > +/// This works similarly to `FromStr`, but operates on a `UserSliceReader` rather than a &str. > +/// > +/// It is automatically implemented for all atomic integers, or any type that implements `FromStr` > +/// wrapped in a `Mutex`. > +pub trait UpdateFromSlice { As mentioned above, I think we should name this Reader and the Render thing Writer. > + /// Updates the value from the given user slice. > + fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()>; read_from_slice()? > +} > + > +impl<T: FromStr> UpdateFromSlice for Mutex<T> { > + fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()> { > + let mut buf = [0u8; 128]; > + if reader.len() > buf.len() { > + return Err(EINVAL); > + } > + let n = reader.len(); > + reader.read_slice(&mut buf[..n])?; > + > + let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?; > + let val = s.trim().parse::<T>().map_err(|_| EINVAL)?; > + *self.lock() = val; > + Ok(()) > + } > +} > + > +macro_rules! impl_update_from_slice_for_atomic { > + ($(($atomic_type:ty, $int_type:ty)),*) => { > + $( > + impl UpdateFromSlice for $atomic_type { > + fn update_from_slice(&self, reader: &mut UserSliceReader) -> Result<()> { > + let mut buf = [0u8; 21]; // Enough for a 64-bit number. > + if reader.len() > buf.len() { > + return Err(EINVAL); > + } > + let n = reader.len(); > + reader.read_slice(&mut buf[..n])?; > + > + let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?; > + let val = s.trim().parse::<$int_type>().map_err(|_| EINVAL)?; > + self.store(val, Ordering::Relaxed); > + Ok(()) > + } > + } > + )* > + }; > +} > + > +impl_update_from_slice_for_atomic!( > + (AtomicI16, i16), > + (AtomicI32, i32), > + (AtomicI64, i64), > + (AtomicI8, i8), > + (AtomicIsize, isize), > + (AtomicU16, u16), > + (AtomicU32, u32), > + (AtomicU64, u64), > + (AtomicU8, u8), > + (AtomicUsize, usize) > +); > > -- > 2.51.0.rc1.167.g924127e9c0-goog
© 2016 - 2025 Red Hat, Inc.