cu29_unifiedlog/
noop.rs

1use crate::{
2    SECTION_HEADER_COMPACT_SIZE, SECTION_MAGIC, SectionHandle, SectionHeader, SectionStorage,
3    UnifiedLogStatus, UnifiedLogWrite,
4};
5use bincode::Encode;
6use bincode::config::standard;
7use bincode::enc::EncoderImpl;
8use bincode::enc::write::SizeWriter;
9use bincode::error::EncodeError;
10use cu29_traits::{
11    CuResult, ObservedWriter, UnifiedLogType, abort_observed_encode, begin_observed_encode,
12    finish_observed_encode,
13};
14
15#[derive(Debug, Default)]
16pub struct NoopSectionStorage {
17    bytes_written: usize,
18}
19
20impl SectionStorage for NoopSectionStorage {
21    fn initialize<E: Encode>(&mut self, header: &E) -> Result<usize, EncodeError> {
22        let header_size = encoded_size(header)?;
23        self.bytes_written = header_size;
24        Ok(header_size)
25    }
26
27    fn post_update_header<E: Encode>(&mut self, header: &E) -> Result<usize, EncodeError> {
28        encoded_size(header)
29    }
30
31    fn append<E: Encode>(&mut self, entry: &E) -> Result<usize, EncodeError> {
32        let size = encoded_size(entry)?;
33        self.bytes_written = self.bytes_written.saturating_add(size);
34        Ok(size)
35    }
36
37    fn flush(&mut self) -> CuResult<usize> {
38        Ok(self.bytes_written)
39    }
40}
41
42#[derive(Debug, Default)]
43pub struct NoopLogger {
44    total_used_space: usize,
45    total_allocated_space: usize,
46}
47
48impl NoopLogger {
49    pub fn new() -> Self {
50        Self::default()
51    }
52}
53
54impl UnifiedLogWrite<NoopSectionStorage> for NoopLogger {
55    fn add_section(
56        &mut self,
57        entry_type: UnifiedLogType,
58        requested_section_size: usize,
59    ) -> CuResult<SectionHandle<NoopSectionStorage>> {
60        let allocated_size = requested_section_size.max(SECTION_HEADER_COMPACT_SIZE as usize);
61        let section_header = SectionHeader {
62            magic: SECTION_MAGIC,
63            block_size: SECTION_HEADER_COMPACT_SIZE,
64            entry_type,
65            allocated: allocated_size as u64,
66            next_section: 0,
67            context: crate::SectionContext::default(),
68            used: 0,
69            is_open: true,
70        };
71
72        self.total_allocated_space = self.total_allocated_space.saturating_add(allocated_size);
73        SectionHandle::create(section_header, NoopSectionStorage::default())
74    }
75
76    fn flush_section(&mut self, section: &mut SectionHandle<NoopSectionStorage>) {
77        section.mark_closed();
78        let _ = section.post_update_header();
79        if let Ok(used) = section.get_storage_mut().flush() {
80            self.total_used_space = self.total_used_space.saturating_add(used);
81        }
82    }
83
84    fn seal_metadata<C: Encode>(
85        &mut self,
86        _: &crate::ApplicationMetadata,
87        _: Option<&C>,
88    ) -> CuResult<()> {
89        Ok(())
90    }
91
92    fn status(&self) -> UnifiedLogStatus {
93        UnifiedLogStatus {
94            total_used_space: self.total_used_space,
95            total_allocated_space: self.total_allocated_space,
96        }
97    }
98}
99
100fn encoded_size<E: Encode>(value: &E) -> Result<usize, EncodeError> {
101    begin_observed_encode();
102    let result = (|| {
103        let mut encoder =
104            EncoderImpl::<_, _>::new(ObservedWriter::new(SizeWriter::default()), standard());
105        value.encode(&mut encoder)?;
106        Ok(encoder.into_writer().into_inner().bytes_written)
107    })();
108    match result {
109        Ok(size) => {
110            debug_assert_eq!(size, finish_observed_encode());
111            Ok(size)
112        }
113        Err(err) => {
114            abort_observed_encode();
115            Err(err)
116        }
117    }
118}
cu29_unifiedlog/noop.rs

cu29_unifiedlog/
noop.rs
