1use crate::fmt;
7use crate::prelude::*;
8use crate::sync::atomic::{Atomic, AtomicBasicOps, AtomicType, Relaxed};
9use crate::sync::Mutex;
10use crate::uaccess::UserSliceReader;
11use core::str::FromStr;
12
13pub trait Writer {
23 fn write(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result;
25}
26
27impl<T: Writer> Writer for Mutex<T> {
28 fn write(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
29 self.lock().write(f)
30 }
31}
32
33impl<T: fmt::Debug> Writer for T {
34 fn write(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
35 writeln!(f, "{self:?}")
36 }
37}
38
39pub trait Reader {
46 fn read_from_slice(&self, reader: &mut UserSliceReader) -> Result;
48}
49
50impl<T: FromStr + Unpin> Reader for Mutex<T> {
51 fn read_from_slice(&self, reader: &mut UserSliceReader) -> Result {
52 let mut buf = [0u8; 128];
53 if reader.len() > buf.len() {
54 return Err(EINVAL);
55 }
56 let n = reader.len();
57 reader.read_slice(&mut buf[..n])?;
58
59 let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?;
60 let val = s.trim().parse::<T>().map_err(|_| EINVAL)?;
61 *self.lock() = val;
62 Ok(())
63 }
64}
65
66impl<T: AtomicType + FromStr> Reader for Atomic<T>
67where
68 T::Repr: AtomicBasicOps,
69{
70 fn read_from_slice(&self, reader: &mut UserSliceReader) -> Result {
71 let mut buf = [0u8; 21]; if reader.len() > buf.len() {
73 return Err(EINVAL);
74 }
75 let n = reader.len();
76 reader.read_slice(&mut buf[..n])?;
77
78 let s = core::str::from_utf8(&buf[..n]).map_err(|_| EINVAL)?;
79 let val = s.trim().parse::<T>().map_err(|_| EINVAL)?;
80 self.store(val, Relaxed);
81 Ok(())
82 }
83}