librqbit 8.1.1

The main library used by rqbit torrent client. The binary is just a small wrapper on top of it.
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

use std::sync::atomic::Ordering;

use serde::Serialize;

use crate::torrent_state::{peers::stats::snapshot::AggregatePeerStats, stats::Speed};

use super::SessionStats;

#[derive(Debug, Serialize)]
pub struct SessionStatsSnapshot {
    pub fetched_bytes: u64,
    pub uploaded_bytes: u64,
    pub download_speed: Speed,
    pub upload_speed: Speed,
    pub peers: AggregatePeerStats,
    pub uptime_seconds: u64,
}

impl From<&SessionStats> for SessionStatsSnapshot {
    fn from(s: &SessionStats) -> Self {
        Self {
            download_speed: s.down_speed_estimator.mbps().into(),
            upload_speed: s.up_speed_estimator.mbps().into(),
            fetched_bytes: s.atomic.fetched_bytes.load(Ordering::Relaxed),
            uploaded_bytes: s.atomic.uploaded_bytes.load(Ordering::Relaxed),
            peers: AggregatePeerStats::from(&s.atomic.peers),
            uptime_seconds: s.startup_time.elapsed().as_secs(),
        }
    }
}