YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic http and ws: when cleaning torrents, update statistics

Browse source
This commit is contained in:
Joakim Frostegård 2020-08-16 23:24:44 +02:00
parent 3d35bd9bd4
commit 4e0fc68548
2 changed files with 36 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

19
aquatic_http/src/lib/tasks.rs
View file

@ -20,8 +20,25 @@ fn clean_torrent_map<I: Ip>(
let now = Instant::now(); let now = Instant::now();
torrent_map.retain(|_, torrent_data| { torrent_map.retain(|_, torrent_data| {
let num_seeders = &mut torrent_data.num_seeders;
let num_leechers = &mut torrent_data.num_leechers;
torrent_data.peers.retain(|_, peer| { torrent_data.peers.retain(|_, peer| {
peer.valid_until.0 >= now let keep = peer.valid_until.0 >= now;
if !keep {
match peer.status {
PeerStatus::Seeding => {
*num_seeders -= 1;
},
PeerStatus::Leeching => {
*num_leechers -= 1;
},
_ => (),
};
}
keep
}); });
!torrent_data.peers.is_empty() !torrent_data.peers.is_empty()

19
aquatic_ws/src/lib/tasks.rs
View file

@ -12,8 +12,25 @@ pub fn clean_torrents(state: &State){
let now = Instant::now(); let now = Instant::now();
torrent_map.retain(|_, torrent_data| { torrent_map.retain(|_, torrent_data| {
let num_seeders = &mut torrent_data.num_seeders;
let num_leechers = &mut torrent_data.num_leechers;
torrent_data.peers.retain(|_, peer| { torrent_data.peers.retain(|_, peer| {
peer.valid_until.0 >= now let keep = peer.valid_until.0 >= now;
if !keep {
match peer.status {
PeerStatus::Seeding => {
*num_seeders -= 1;
},
PeerStatus::Leeching => {
*num_leechers -= 1;
},
_ => (),
};
}
keep
}); });
!torrent_data.peers.is_empty() !torrent_data.peers.is_empty()