memfaultd 1.26.1

Memfault daemon for embedded Linux systems. Observability, logging, crash reporting, and updating all in one service. Learn more at https://docs.memfault.com/
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//
// Copyright (c) Memfault, Inc.
// See License.txt for details
use std::io::{Chain, Cursor, Read};

use crate::util::io::StreamLen;

/// Add a little wrapper around each chunk containing an identifier and the length.
/// This makes it possible to concatenate multiple chunks in one file.
///
/// Format:
///  - 4 identifier bytes: 'C' 'H' 'N' 'K'
///  - Chunk length (4 bytes, big endian)
///
/// /!\ This format is not accepted by memfault API. You have to remove that
/// wrapper before sending the chunks to Memfault!
pub struct ChunkWrapper<R: Read + StreamLen> {
    stream: Chain<Cursor<Vec<u8>>, R>,
}

impl<R: Read + StreamLen> ChunkWrapper<R> {
    pub fn new(chunk: R) -> Self {
        let mut header: [u8; 8] = [0; 8];
        header[0..4].copy_from_slice(b"CHNK");
        header[4..8].copy_from_slice(&(chunk.stream_len() as u32).to_be_bytes());

        Self {
            stream: Cursor::new(header.to_vec()).chain(chunk),
        }
    }
}

impl<R: Read + StreamLen> Read for ChunkWrapper<R> {
    fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
        self.stream.read(buf)
    }
}

impl<R: Read + StreamLen> StreamLen for ChunkWrapper<R> {
    fn stream_len(&self) -> u64 {
        self.stream.stream_len()
    }
}