chorrent 0.5.5

Peer-to-peer and swarm file transfer over Iroh/QUIC with verified, chunked downloads
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

use crate::error::{Error, Result};
use crate::handler::Registry;
use crate::local::SharedShare;
use std::sync::Arc;

/// A share listed in the node's registry, so peers can fetch from it.
/// Unlisted again when dropped.
pub(crate) struct Registration {
    registry: Registry,
    pub share: SharedShare,
}

impl Registration {
    pub fn new(registry: &Registry, share: SharedShare) -> Result<Self> {
        let mut shares = registry.write().unwrap();
        if shares.contains_key(&share.id) {
            return Err(Error::AlreadySharing);
        }
        shares.insert(share.id, Arc::clone(&share));
        Ok(Self {
            registry: Arc::clone(registry),
            share,
        })
    }
}

impl Drop for Registration {
    fn drop(&mut self) {
        let mut shares = self.registry.write().unwrap();
        if shares
            .get(&self.share.id)
            .is_some_and(|s| Arc::ptr_eq(s, &self.share))
        {
            shares.remove(&self.share.id);
        }
    }
}