diff --git a/clients/client-core/src/client/real_messages_control/acknowledgement_control/acknowledgement_listener.rs b/clients/client-core/src/client/real_messages_control/acknowledgement_control/acknowledgement_listener.rs index 2f9a6053ec..9b285d8444 100644 --- a/clients/client-core/src/client/real_messages_control/acknowledgement_control/acknowledgement_listener.rs +++ b/clients/client-core/src/client/real_messages_control/acknowledgement_control/acknowledgement_listener.rs @@ -33,7 +33,7 @@ impl AcknowledgementListener { } async fn on_ack(&mut self, ack_content: Vec) { - debug!("Received an ack"); + trace!("Received an ack"); let frag_id = match recover_identifier(&self.ack_key, &ack_content) .map(FragmentIdentifier::try_from_bytes) { diff --git a/clients/client-core/src/client/received_buffer.rs b/clients/client-core/src/client/received_buffer.rs index 9830f0a869..fa61b9b9a0 100644 --- a/clients/client-core/src/client/received_buffer.rs +++ b/clients/client-core/src/client/received_buffer.rs @@ -208,7 +208,7 @@ impl ReceivedMessagesBuffer { } async fn handle_new_received(&mut self, msgs: Vec>) { - debug!( + trace!( "Processing {:?} new message that might get added to the buffer!", msgs.len() ); diff --git a/common/socks5/proxy-helpers/src/proxy_runner/mod.rs b/common/socks5/proxy-helpers/src/proxy_runner/mod.rs index 64bcf162f2..65b1c91db8 100644 --- a/common/socks5/proxy-helpers/src/proxy_runner/mod.rs +++ b/common/socks5/proxy-helpers/src/proxy_runner/mod.rs @@ -111,7 +111,8 @@ where { let (read_half, write_half) = self.socket.take().unwrap().into_split(); let shutdown_notify = Arc::new(Notify::new()); - let chunker = Some(self.msg_chunker.as_ref().unwrap().clone_box()); + //let chunker = Some(self.msg_chunker.as_ref().unwrap().clone_box()); + let chunker = self.msg_chunker.as_ref().map(|c| c.clone_box()); // should run until either inbound closes or is notified from outbound let inbound_future = inbound::run_inbound(