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_ws: run rustfmt

Browse source
This commit is contained in:
Joakim Frostegård 2021-10-16 01:47:10 +02:00
parent 71c43aca47
commit c02d7f2113
3 changed files with 5 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

7
aquatic_ws/src/lib/common.rs
View file

@ -95,11 +95,7 @@ impl TorrentMaps {
Self::clean_torrent_map(config, &self.access_list, &mut self.ipv6); Self::clean_torrent_map(config, &self.access_list, &mut self.ipv6);
} }
fn clean_torrent_map( fn clean_torrent_map(config: &Config, access_list: &AccessList, torrent_map: &mut TorrentMap) {
config: &Config,
access_list: &AccessList,
torrent_map: &mut TorrentMap
) {
let now = Instant::now(); let now = Instant::now();
torrent_map.retain(|info_hash, torrent_data| { torrent_map.retain(|info_hash, torrent_data| {
@ -133,7 +129,6 @@ impl TorrentMaps {
torrent_map.shrink_to_fit(); torrent_map.shrink_to_fit();
} }
} }
#[derive(Clone)] #[derive(Clone)]

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

@ -102,14 +102,14 @@ pub fn handle_announce_requests(
let info_hash_allowed = torrent_maps let info_hash_allowed = torrent_maps
.access_list .access_list
.allows(config.access_list.mode, &request.info_hash.0); .allows(config.access_list.mode, &request.info_hash.0);
if !info_hash_allowed { if !info_hash_allowed {
let response = OutMessage::ErrorResponse(ErrorResponse { let response = OutMessage::ErrorResponse(ErrorResponse {
failure_reason: "Info hash not allowed".into(), failure_reason: "Info hash not allowed".into(),
action: Some(ErrorResponseAction::Announce), action: Some(ErrorResponseAction::Announce),
info_hash: Some(request.info_hash), info_hash: Some(request.info_hash),
}); });
out_message_sender.send(request_sender_meta, response); out_message_sender.send(request_sender_meta, response);
wake_socket_workers[request_sender_meta.worker_index] = true; wake_socket_workers[request_sender_meta.worker_index] = true;

4
aquatic_ws_load_test/src/network.rs
View file

@ -156,11 +156,11 @@ impl Connection {
.statistics .statistics
.responses_error .responses_error
.fetch_add(1, Ordering::SeqCst); .fetch_add(1, Ordering::SeqCst);
eprintln!("received error response: {:?}", response.failure_reason); eprintln!("received error response: {:?}", response.failure_reason);
self.can_send = true; self.can_send = true;
}, }
Err(err) => { Err(err) => {
eprintln!("error deserializing offer: {:?}", err); eprintln!("error deserializing offer: {:?}", err);
} }