YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-01 10:15:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp: improve socket worker comments

Browse source
This commit is contained in:
Joakim Frostegård 2022-10-25 02:16:16 +02:00
parent aa6be77a98
commit 15f8d30518
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
aquatic_udp/src/workers/socket/mod.rs
View file

@ -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() { if let Some(resend_buffer) = opt_resend_buffer.as_mut() {
for (response, addr) in resend_buffer.drain(..) { for (response, addr) in resend_buffer.drain(..) {
Self::send_response( 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(..) { for (response, addr) in local_responses.drain(..) {
Self::send_response( Self::send_response(
&self.config, &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() { for (response, addr) in self.response_receiver.try_iter() {
let opt_response = match response { let opt_response = match response {
ConnectedResponse::Scrape(r) => self ConnectedResponse::Scrape(r) => self