diff --git a/aquatic_http/src/workers/socket.rs b/aquatic_http/src/workers/socket.rs index d99062a..7c2e856 100644 --- a/aquatic_http/src/workers/socket.rs +++ b/aquatic_http/src/workers/socket.rs @@ -248,13 +248,9 @@ impl Connection { match Request::from_bytes(&self.request_buffer[..self.request_buffer_position]) { Ok(request) => { - ::log::debug!("received request: {:?}", request); - return Ok(Either::Right(request)); } Err(RequestParseError::Invalid(err)) => { - ::log::debug!("invalid request: {:?}", err); - let response = FailureResponse { failure_reason: "Invalid request".into(), }; diff --git a/aquatic_http/src/workers/swarm.rs b/aquatic_http/src/workers/swarm.rs index 706275d..e1b056d 100644 --- a/aquatic_http/src/workers/swarm.rs +++ b/aquatic_http/src/workers/swarm.rs @@ -344,8 +344,6 @@ pub fn upsert_peer_and_get_response_peers( valid_until, }; - ::log::debug!("peer: {:?}", peer); - let ip_or_key = request .key .map(Either::Right) @@ -356,8 +354,6 @@ pub fn upsert_peer_and_get_response_peers( ip_or_key, }; - ::log::debug!("peer map key: {:?}", peer_map_key); - let opt_removed_peer = match peer_status { PeerStatus::Leeching => { torrent_data.num_leechers += 1; @@ -372,8 +368,6 @@ pub fn upsert_peer_and_get_response_peers( PeerStatus::Stopped => torrent_data.peers.remove(&peer_map_key), }; - ::log::debug!("opt_removed_peer: {:?}", opt_removed_peer); - match opt_removed_peer.map(|peer| peer.status) { Some(PeerStatus::Leeching) => { torrent_data.num_leechers -= 1; @@ -384,8 +378,6 @@ pub fn upsert_peer_and_get_response_peers( _ => {} } - ::log::debug!("peer request numwant: {:?}", request.numwant); - let response_peers = if let PeerStatus::Stopped = peer_status { Vec::new() } else {