YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 18:55:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_ws: add some fixme comments, update ValidUntil time

Browse source
This commit is contained in:
Joakim Frostegård 2020-05-11 16:22:30 +02:00
parent ddef44fb91
commit f1a20b0c8c
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
aquatic_ws/src/lib/handler.rs
View file

@ -23,12 +23,12 @@ pub fn run_request_worker(
let mut rng = SmallRng::from_entropy(); let mut rng = SmallRng::from_entropy();
let timeout = Duration::from_micros(200); let timeout = Duration::from_micros(200); // FIXME: config
loop { loop {
let mut opt_torrent_map_guard: Option<MutexGuard<TorrentMap>> = None; let mut opt_torrent_map_guard: Option<MutexGuard<TorrentMap>> = None;
for i in 0..1000 { for i in 0..1000 { // FIXME config
let opt_in_message = if i == 0 { let opt_in_message = if i == 0 {
in_message_receiver.recv().ok() in_message_receiver.recv().ok()
} else { } else {
@ -193,7 +193,7 @@ pub fn handle_announce_requests(
} }
let response = OutMessage::AnnounceResponse(AnnounceResponse { let response = OutMessage::AnnounceResponse(AnnounceResponse {
info_hash: info_hash, info_hash,
complete: torrent_data.num_seeders, complete: torrent_data.num_seeders,
incomplete: torrent_data.num_leechers, incomplete: torrent_data.num_leechers,
announce_interval: 120, // FIXME: config announce_interval: 120, // FIXME: config

2
aquatic_ws/src/lib/network.rs
View file

@ -124,7 +124,7 @@ pub fn run_socket_worker(
poll.poll(&mut events, Some(poll_timeout)) poll.poll(&mut events, Some(poll_timeout))
.expect("failed polling"); .expect("failed polling");
let valid_until = ValidUntil::new(600); // FIXME: config let valid_until = ValidUntil::new(180); // FIXME: config
for event in events.iter(){ for event in events.iter(){
let token = event.token(); let token = event.token();