Struct cjdns_snode::server::nodes::Nodes

pub(super) struct Nodes {
    peers: Arc<Peers>,
    nodes_by_ip: RwLock<HashMap<CJDNS_IP6, Arc<Node>>>,
}

Fields

peers: Arc<Peers>

nodes_by_ip: RwLock<HashMap<CJDNS_IP6, Arc<Node>>>

Shared state guarded by a regular sync mutex (since we don't need to keep the lock between .await points)

Implementations

impl Nodes

pub fn new(peers: Arc<Peers>) -> Self

pub fn all_ips(&self) -> Vec<CJDNS_IP6>

pub fn by_ip(&self, ip: &CJDNS_IP6) -> Option<Arc<Node>>

pub fn count(&self) -> usize

pub fn anns_dump(&self) -> Vec<u8>

pub fn keep_table_clean(&self)

pub(super) fn new_node(
    &self,
    version: u16,
    key: CJDNSPublicKey,
    encoding_scheme: Option<Arc<EncodingScheme>>,
    timestamp: SystemTime,
    ipv6: CJDNS_IP6,
    announcement: Option<Announcement>
) -> Result<Node, Error>

pub(super) fn add_node(
    &self,
    node: Node,
    overwrite: bool
) -> Result<Arc<Node>, ()>

fn forget_node(&self, node: Arc<Node>)