From 15f8d305181b4e24c2946355f51912e43f030d4e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Tue, 25 Oct 2022 02:16:16 +0200 Subject: [PATCH] udp: improve socket worker comments --- aquatic_udp/src/workers/socket/mod.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/aquatic_udp/src/workers/socket/mod.rs b/aquatic_udp/src/workers/socket/mod.rs index 323ddd7..f5a4efb 100644 --- a/aquatic_udp/src/workers/socket/mod.rs +++ b/aquatic_udp/src/workers/socket/mod.rs @@ -104,6 +104,7 @@ impl SocketWorker { } } + // If resend buffer is enabled, send any responses in it if let Some(resend_buffer) = opt_resend_buffer.as_mut() { for (response, addr) in resend_buffer.drain(..) { Self::send_response( @@ -118,6 +119,7 @@ impl SocketWorker { } } + // Send any connect and error responses generated by this socket worker for (response, addr) in local_responses.drain(..) { Self::send_response( &self.config, @@ -130,6 +132,7 @@ impl SocketWorker { ); } + // Check channel for any responses generated by swarm workers for (response, addr) in self.response_receiver.try_iter() { let opt_response = match response { ConnectedResponse::Scrape(r) => self