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

udp: socket worker: send responses: use previous design

Browse source 
It seems to perform better
This commit is contained in:
Joakim Frostegård 2022-04-14 17:49:17 +02:00
parent ebe612a560
commit 82e468de35
1 changed files with 10 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

43
aquatic_udp/src/workers/socket.rs
View file

@ -399,40 +399,17 @@ fn send_responses(
}
for (response, addr) in response_receiver.try_iter() {
match response {
ConnectedResponse::Scrape(r) => {
if let Some(response) = pending_scrape_responses.add_and_get_finished(r) {
send_response(
state,
config,
socket,
buffer,
Response::Scrape(response),
addr,
);
}
}
ConnectedResponse::AnnounceIpv4(r) => {
send_response(
state,
config,
socket,
buffer,
Response::AnnounceIpv4(r),
addr,
);
}
ConnectedResponse::AnnounceIpv6(r) => {
send_response(
state,
config,
socket,
buffer,
Response::AnnounceIpv6(r),
addr,
);
}
let opt_response = match response {
ConnectedResponse::Scrape(r) => pending_scrape_responses
.add_and_get_finished(r)
.map(Response::Scrape),
ConnectedResponse::AnnounceIpv4(r) => Some(Response::AnnounceIpv4(r)),
ConnectedResponse::AnnounceIpv6(r) => Some(Response::AnnounceIpv6(r)),
};
if let Some(response) = opt_response {
send_response(state, config, socket, buffer, response, addr);
}
}
}