prns-core 0.3.4

Pure Reticulum engine and wire contract for Personal Reticulum
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
64
65
66
67
68
69

use heapless::Vec;

use super::soa::{DirEntry, HeldCold, Probe, SoaColumns, SoaHeldAnnounceTable};
use crate::wire::DestinationHash;

pub type FixedHeldAnnounceTable<const CAP: usize> = SoaHeldAnnounceTable<FixedSoaColumns<CAP>>;

#[derive(Debug)]
pub struct FixedSoaColumns<const CAP: usize> {
    probe: Vec<Probe, CAP>,
    dest: Vec<DestinationHash, CAP>,
    cold: Vec<HeldCold, CAP>,
    dir: [Option<DirEntry>; CAP],
}

impl<const CAP: usize> Default for FixedSoaColumns<CAP> {
    fn default() -> Self {
        Self {
            probe: Vec::new(),
            dest: Vec::new(),
            cold: Vec::new(),
            dir: [None; CAP],
        }
    }
}

impl<const CAP: usize> SoaColumns for FixedSoaColumns<CAP> {
    fn probe(&self) -> &[Probe] {
        &self.probe
    }

    fn dest(&self) -> &[DestinationHash] {
        &self.dest
    }

    fn cold(&self) -> &[HeldCold] {
        &self.cold
    }

    fn dir(&self) -> &[Option<DirEntry>] {
        &self.dir
    }

    fn dir_mut(&mut self) -> &mut [Option<DirEntry>] {
        &mut self.dir
    }

    fn push(&mut self, probe: Probe, dest: DestinationHash, cold: HeldCold) {
        let _ = self.probe.push(probe);
        let _ = self.dest.push(dest);
        let _ = self.cold.push(cold);
    }

    fn overwrite_at(&mut self, slot: usize, probe: Probe, dest: DestinationHash, cold: HeldCold) {
        self.probe[slot] = probe;
        self.dest[slot] = dest;
        self.cold[slot] = cold;
    }

    fn swap_remove(&mut self, slot: usize) {
        self.probe.swap_remove(slot);
        self.dest.swap_remove(slot);
        self.cold.swap_remove(slot);
    }

    fn capacity(&self) -> usize {
        CAP
    }
}