diff --git a/mixnode/src/node/listener.rs b/mixnode/src/node/listener.rs index 0409a1754d..24b541f2d9 100644 --- a/mixnode/src/node/listener.rs +++ b/mixnode/src/node/listener.rs @@ -49,10 +49,10 @@ async fn process_socket_connection( } Ok(n) => { if n != sphinx::PACKET_SIZE { - warn!("read data of different length than expected sphinx packet size - {} (expected {})", n, sphinx::PACKET_SIZE); + error!("read data of different length than expected sphinx packet size - {} (expected {})", n, sphinx::PACKET_SIZE); continue; } - + warn!("About to process packet. If you see this, we made it past the Sphinx size error"); // we must be able to handle multiple packets from same connection independently tokio::spawn(process_received_packet( buf, @@ -64,7 +64,7 @@ async fn process_socket_connection( )) } Err(e) => { - warn!( + error!( "failed to read from socket. Closing the connection; err = {:?}", e ); diff --git a/mixnode/src/node/packet_processing.rs b/mixnode/src/node/packet_processing.rs index ec6187e9aa..4a2099c55f 100644 --- a/mixnode/src/node/packet_processing.rs +++ b/mixnode/src/node/packet_processing.rs @@ -91,6 +91,7 @@ impl PacketProcessor { match packet.process(self.secret_key.deref().inner()) { Ok(ProcessedPacket::ProcessedPacketForwardHop(packet, address, delay)) => { + warn!("Returning a process packet. We're good."); self.process_forward_hop(packet, address, delay).await } Ok(ProcessedPacket::ProcessedPacketFinalHop(_, _, _)) => { @@ -98,7 +99,7 @@ impl PacketProcessor { Err(MixProcessingError::ReceivedFinalHopError) } Err(e) => { - warn!("Failed to unwrap Sphinx packet: {:?}", e); + error!("Failed to unwrap Sphinx packet: {:?}", e); Err(MixProcessingError::SphinxProcessingError) } } diff --git a/sfw-provider/src/provider/mix_handling/packet_processing.rs b/sfw-provider/src/provider/mix_handling/packet_processing.rs index 12d50c322c..99518f56ad 100644 --- a/sfw-provider/src/provider/mix_handling/packet_processing.rs +++ b/sfw-provider/src/provider/mix_handling/packet_processing.rs @@ -88,11 +88,12 @@ impl PacketProcessor { Err(MixProcessingError::ReceivedForwardHopError) } Ok(ProcessedPacket::ProcessedPacketFinalHop(client_address, surb_id, payload)) => { + warn!("About to process final hop. If you see this we made it past the Failed to unwrap error"); self.process_final_hop(client_address, surb_id, payload) .await } Err(e) => { - warn!("Failed to unwrap Sphinx packet: {:?}", e); + error!("Failed to unwrap Sphinx packet: {:?}", e); Err(MixProcessingError::SphinxProcessingError) } }