flute 1.11.0

File Delivery over Unidirectional Transport (FLUTE)
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

pub mod nocode;
pub mod raptor;
pub mod raptorq;
pub mod rscodec;

use crate::tools::error::Result;

pub trait FecShard: Send + Sync + std::fmt::Debug {
    fn data(&self) -> &[u8];
    fn esi(&self) -> u32;
}

#[derive(Debug)]
pub struct DataFecShard {
    shard: Vec<u8>,
    index: u32,
}

impl FecShard for DataFecShard {
    fn data(&self) -> &[u8] {
        self.shard.as_ref()
    }

    fn esi(&self) -> u32 {
        self.index
    }
}

impl DataFecShard {
    pub fn new(shard: &[u8], index: u32) -> Self {
        DataFecShard {
            shard: shard.to_vec(),
            index,
        }
    }
}

pub trait FecEncoder {
    fn encode(&self, data: &[u8]) -> Result<Vec<Box<dyn FecShard>>>;
}

pub trait FecDecoder {
    fn push_symbol(&mut self, encoding_symbol: &[u8], esi: u32);
    fn can_decode(&self) -> bool;
    fn decode(&mut self) -> bool;
    fn source_block(&self) -> Result<&[u8]>;
}

impl std::fmt::Debug for dyn FecEncoder {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        write!(f, "FecEncoder {{  }}")
    }
}

impl std::fmt::Debug for dyn FecDecoder {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        write!(f, "FecDecoder {{  }}")
    }
}