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

aquatic_udp: innetwork, use request_sender.try_send; run rustfmt

Browse source
This commit is contained in:
Joakim Frostegård 2021-10-18 11:10:56 +02:00
parent 07a453b6b3
commit 90d60108c1
2 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
aquatic_udp/src/lib/network.rs
View file

@ -201,10 +201,10 @@ fn read_requests(
.access_list .access_list
.allows(access_list_mode, &request.info_hash.0) .allows(access_list_mode, &request.info_hash.0)
{ {
if let Err(err) = if let Err(err) = request_sender
request_sender.send((ConnectedRequest::Announce(request), src)) .try_send((ConnectedRequest::Announce(request), src))
{ {
::log::warn!("request_sender.send failed: {:?}", err) ::log::warn!("request_sender.try_send failed: {:?}", err)
} }
} else { } else {
let response = Response::Error(ErrorResponse { let response = Response::Error(ErrorResponse {
@ -219,9 +219,9 @@ fn read_requests(
Ok(Request::Scrape(request)) => { Ok(Request::Scrape(request)) => {
if connections.contains(request.connection_id, src) { if connections.contains(request.connection_id, src) {
if let Err(err) = if let Err(err) =
request_sender.send((ConnectedRequest::Scrape(request), src)) request_sender.try_send((ConnectedRequest::Scrape(request), src))
{ {
::log::warn!("request_sender.send failed: {:?}", err) ::log::warn!("request_sender.try_send failed: {:?}", err)
} }
} }
} }

2
aquatic_udp/src/lib/tasks.rs
View file

@ -1,5 +1,5 @@
use std::sync::Arc;
use std::sync::atomic::Ordering; use std::sync::atomic::Ordering;
use std::sync::Arc;
use histogram::Histogram; use histogram::Histogram;