sendstream_parser 0.2.2

Parser for BTRFS sendstreams
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

use nom::IResult;

use crate::Sendstream;

static MAGIC_HEADER: &[u8] = b"btrfs-stream\0";

pub(crate) mod cmd;
mod tlv;
use crate::Error;
use crate::Result;

impl<'a> Sendstream<'a> {
    fn parse(input: &'a [u8]) -> IResult<&'a [u8], Self> {
        let (input, _) = nom::bytes::complete::tag(MAGIC_HEADER)(input)?;
        let (input, version) = nom::number::complete::le_u32(input)?;
        assert_eq!(1, version);
        let (input, commands) = nom::multi::many1(crate::Command::parse)(input)?;
        Ok((input, Self { commands }))
    }

    pub fn parse_all(input: &'a [u8]) -> Result<Vec<Self>> {
        match nom::combinator::complete(nom::multi::many1(Sendstream::parse))(input) {
            Ok((left, sendstreams)) => {
                if !left.is_empty() {
                    Err(Error::TrailingData(left.to_vec()))
                } else {
                    Ok(sendstreams)
                }
            }
            Err(e) => match e {
                nom::Err::Error(e) | nom::Err::Failure(e) => Err(e.into()),
                nom::Err::Incomplete(_) => Err(Error::Incomplete),
            },
        }
    }
}