tycho-network 0.3.3

A peer-to-peer networking 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

use crate::dht::{DhtValueMerger, DhtValueSource, StorageError};
use crate::proto::dht::{MergedValue, MergedValueRef};

/// Allows only local values to be stored.
/// Always overwrites the stored value with the new value.
#[derive(Debug, Default, Clone, Copy)]
pub struct PublicOverlayEntriesMerger;

impl DhtValueMerger for PublicOverlayEntriesMerger {
    fn check_value(
        &self,
        source: DhtValueSource,
        _: &MergedValueRef<'_>,
    ) -> Result<(), StorageError> {
        if source != DhtValueSource::Local {
            return Err(StorageError::InvalidSource);
        }

        Ok(())
    }

    fn merge_value(
        &self,
        source: DhtValueSource,
        new: &MergedValueRef<'_>,
        stored: &mut MergedValue,
    ) -> bool {
        if source != DhtValueSource::Local {
            return false;
        }

        *stored = new.as_owned();
        true
    }
}