dandri/aquatic
1
0
Fork 0
mirror of https://github.com/greatest-ape/aquatic.git synced 2026-08-28 12:54:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

aquatic_udp_bench: fix compilation error

Browse Source
This commit is contained in:
Joakim Frostegård
2022-03-27 03:37:47 +02:00
parent f460dab2b3
commit f9b29dbd51
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
aquatic_udp_bench/src/announce.rs
+4 -3
View File
@@ -39,13 +39,14 @@ pub fn bench_announce_handler(
request_sender
.send((
SocketWorkerIndex(0),
ConnectedRequest::Announce(request.clone()),
ConnectedRequest::Announce(request.clone(), RequestTag::placeholder()),
*src,
))
.unwrap();
}
while let Ok((ConnectedResponse::AnnounceIpv4(r), _)) = response_receiver.try_recv() {
while let Ok((ConnectedResponse::AnnounceIpv4(r, _), _)) = response_receiver.try_recv()
{
num_responses += 1;
if let Some(last_peer) = r.peers.last() {
@@ -57,7 +58,7 @@ pub fn bench_announce_handler(
let total = bench_config.num_announce_requests * (round + 1);
while num_responses < total {
if let Ok((ConnectedResponse::AnnounceIpv4(r), _)) = response_receiver.recv() {
if let Ok((ConnectedResponse::AnnounceIpv4(r, _), _)) = response_receiver.recv() {
num_responses += 1;
if let Some(last_peer) = r.peers.last() {