poldercast 1.0.1

Peer to Peer topology management
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

use crate::Profile;
use keynesis::key::ed25519;
use lru::LruCache;
use std::sync::Arc;

pub struct Profiles {
    pub(crate) dirty: LruCache<ed25519::PublicKey, Arc<Profile>>,
    pub(crate) pool: LruCache<ed25519::PublicKey, Arc<Profile>>,
    pub(crate) trusted: LruCache<ed25519::PublicKey, Arc<Profile>>,
}

impl Profiles {
    pub fn new(dirty: usize, pool: usize, trusted: usize) -> Self {
        Self {
            dirty: LruCache::new(dirty),
            pool: LruCache::new(pool),
            trusted: LruCache::new(trusted),
        }
    }

    pub fn promote(&mut self, entry: &ed25519::PublicKey) {
        if let Some(profile) = self.pool.pop(entry) {
            // if there is an overflow coming up, instead of losing
            // the entries we would rotate from the trusted LRU
            // we demote the least used to the lower pool
            while self.trusted.len() >= self.trusted.cap() {
                if let Some((id, profile)) = self.trusted.pop_lru() {
                    self.pool.put(id, profile);
                } else {
                    unreachable!("cap should be greater than 0")
                }
            }

            self.trusted.put(*entry, profile);
        }

        if let Some(profile) = self.dirty.pop(entry) {
            self.pool.put(*entry, profile);
        }
    }

    pub fn demote(&mut self, entry: &ed25519::PublicKey) {
        if let Some(profile) = self.pool.pop(entry) {
            self.dirty.put(*entry, profile);
        } else if let Some(profile) = self.trusted.pop(entry) {
            self.pool.put(*entry, profile);
        }
    }

    pub fn put(&mut self, id: ed25519::PublicKey, profile: Arc<Profile>) -> bool {
        if let Some(entry) = self.dirty.peek(&id).cloned() {
            if entry.last_update() < profile.last_update() {
                self.dirty.put(id, profile);
            }
            false
        } else if let Some(entry) = self.trusted.peek(&id).cloned() {
            if entry.last_update() < profile.last_update() {
                self.trusted.put(id, profile);
                true
            } else {
                false
            }
        } else if let Some(entry) = self.pool.peek(&id).cloned() {
            if entry.last_update() < profile.last_update() {
                self.pool.put(id, profile);
                true
            } else {
                false
            }
        } else {
            self.pool.put(id, profile);
            true
        }
    }

    pub fn get(&mut self, id: &ed25519::PublicKey) -> Option<&Arc<Profile>> {
        if let Some(profile) = self.trusted.get(id) {
            Some(profile)
        } else if let Some(profile) = self.pool.get(id) {
            Some(profile)
        } else if let Some(profile) = self.dirty.get(id) {
            Some(profile)
        } else {
            None
        }
    }
}

impl Default for Profiles {
    fn default() -> Self {
        Self::new(512, 256, 128)
    }
}