rustradio 0.16.4

Software defined radio library
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
60
61
62
63

/*! PDU Writer

Writes received PDUs to a directory, with files named according to
receive time.

TODO: in the future the file naming should be configurable.
*/
use crate::Result;
use log::{debug, info};

use std::io::Write;
use std::path::{Path, PathBuf};
use std::time::SystemTime;

use crate::Sample;
use crate::block::{Block, BlockRet};
use crate::stream::NCReadStream;

/** PDU writer

This block takes PDUs (as `Vec<u8>`), and writes them to an output
directory, named as microseconds since epoch.
*/
#[derive(rustradio_macros::Block)]
#[rustradio(crate, new)]
pub struct PduWriter<T: Send + Sync + 'static> {
    #[rustradio(in)]
    src: NCReadStream<Vec<T>>,
    #[rustradio(into)]
    dir: PathBuf,
    #[rustradio(default)]
    files_written: usize,
}

impl<T: Send + Sync + 'static> Drop for PduWriter<T> {
    fn drop(&mut self) {
        info!("PDU Writer: wrote {}", self.files_written);
    }
}

impl<T: Sample> Block for PduWriter<T> {
    fn work(&mut self) -> Result<BlockRet<'_>> {
        let packet = match self.src.pop() {
            None => return Ok(BlockRet::WaitForStream(&self.src, 1)),
            Some((x, _tags)) => x,
        };
        let name = SystemTime::now()
            .duration_since(SystemTime::UNIX_EPOCH)
            .expect("Time went backwards")
            .as_micros()
            .to_string();
        let full = Path::new(&self.dir).join(name);
        debug!("Saving PDU to {full:?}");
        let mut f = std::fs::File::create(full)?;
        let mut v = Vec::with_capacity(T::size() * packet.len());
        for s in &packet {
            v.extend(&s.serialize());
        }
        f.write_all(&v)?;
        self.files_written += 1;
        Ok(BlockRet::Again)
    }
}