Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions src/servers/apis/v1/context/auth_key/handlers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ pub async fn delete_auth_key_handler(
match Key::from_str(&seconds_valid_or_key.0) {
Err(_) => invalid_auth_key_param_response(&seconds_valid_or_key.0),
Ok(key) => match tracker.remove_auth_key(&key).await {
Ok(_) => ok_response(),
Ok(()) => ok_response(),
Err(e) => failed_to_delete_key_response(e),
},
}
Expand All @@ -90,7 +90,7 @@ pub async fn delete_auth_key_handler(
/// for more information about this endpoint.
pub async fn reload_keys_handler(State(tracker): State<Arc<Tracker>>) -> Response {
match tracker.load_keys_from_database().await {
Ok(_) => ok_response(),
Ok(()) => ok_response(),
Err(e) => failed_to_reload_keys_response(e),
}
}
6 changes: 3 additions & 3 deletions src/servers/apis/v1/context/whitelist/handlers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ pub async fn add_torrent_to_whitelist_handler(
match InfoHash::from_str(&info_hash.0) {
Err(_) => invalid_info_hash_param_response(&info_hash.0),
Ok(info_hash) => match tracker.add_torrent_to_whitelist(&info_hash).await {
Ok(_) => ok_response(),
Ok(()) => ok_response(),
Err(e) => failed_to_whitelist_torrent_response(e),
},
}
Expand All @@ -53,7 +53,7 @@ pub async fn remove_torrent_from_whitelist_handler(
match InfoHash::from_str(&info_hash.0) {
Err(_) => invalid_info_hash_param_response(&info_hash.0),
Ok(info_hash) => match tracker.remove_torrent_from_whitelist(&info_hash).await {
Ok(_) => ok_response(),
Ok(()) => ok_response(),
Err(e) => failed_to_remove_torrent_from_whitelist_response(e),
},
}
Expand All @@ -71,7 +71,7 @@ pub async fn remove_torrent_from_whitelist_handler(
/// for more information about this endpoint.
pub async fn reload_whitelist_handler(State(tracker): State<Arc<Tracker>>) -> Response {
match tracker.load_whitelist_from_database().await {
Ok(_) => ok_response(),
Ok(()) => ok_response(),
Err(e) => failed_to_reload_whitelist_response(e),
}
}
4 changes: 2 additions & 2 deletions src/servers/http/v1/handlers/announce.rs
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ async fn handle_announce(
if tracker.requires_authentication() {
match maybe_key {
Some(key) => match tracker.authenticate(&key).await {
Ok(_) => (),
Ok(()) => (),
Err(error) => return Err(responses::error::Error::from(error)),
},
None => {
Expand All @@ -100,7 +100,7 @@ async fn handle_announce(

// Authorization
match tracker.authorize(&announce_request.info_hash).await {
Ok(_) => (),
Ok(()) => (),
Err(error) => return Err(responses::error::Error::from(error)),
}

Expand Down
2 changes: 1 addition & 1 deletion src/servers/http/v1/handlers/scrape.rs
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ async fn handle_scrape(
let return_real_scrape_data = if tracker.requires_authentication() {
match maybe_key {
Some(key) => match tracker.authenticate(&key).await {
Ok(_) => true,
Ok(()) => true,
Err(_error) => false,
},
None => false,
Expand Down
6 changes: 3 additions & 3 deletions src/servers/signals.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ pub async fn global_shutdown_signal() {
let terminate = std::future::pending::<()>();

tokio::select! {
_ = ctrl_c => {},
_ = terminate => {}
() = ctrl_c => {},
() = terminate => {}
}
}

Expand All @@ -38,7 +38,7 @@ pub async fn shutdown_signal(stop_receiver: tokio::sync::oneshot::Receiver<u8>)

tokio::select! {
_ = stop => {},
_ = global_shutdown_signal() => {}
() = global_shutdown_signal() => {}
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/servers/udp/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -220,7 +220,7 @@ impl Udp {
let socket = self.socket.clone();

tokio::select! {
_ = &mut shutdown_signal => {
() = &mut shutdown_signal => {
info!("Stopping UDP server: {}..", self.socket.local_addr().unwrap());
break;
}
Expand All @@ -244,7 +244,7 @@ impl Udp {
let mut cursor = Cursor::new(buffer);

match response.write(&mut cursor) {
Ok(_) => {
Ok(()) => {
#[allow(clippy::cast_possible_truncation)]
let position = cursor.position() as usize;
let inner = cursor.get_ref();
Expand Down
2 changes: 1 addition & 1 deletion src/tracker/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -643,7 +643,7 @@ impl Tracker {

for info_hash in info_hashes {
let swarm_metadata = match self.authorize(info_hash).await {
Ok(_) => self.get_swarm_metadata(info_hash).await,
Ok(()) => self.get_swarm_metadata(info_hash).await,
Err(_) => SwarmMetadata::zeroed(),
};
scrape_data.add_file(info_hash, swarm_metadata);
Expand Down
2 changes: 1 addition & 1 deletion tests/servers/udp/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ impl UdpTrackerClient {
let mut cursor = Cursor::new(request_buffer);

let request_data = match request.write(&mut cursor) {
Ok(_) => {
Ok(()) => {
#[allow(clippy::cast_possible_truncation)]
let position = cursor.position() as usize;
let inner_request_buffer = cursor.get_ref();
Expand Down