From f9b29dbd51981af42db04bee3ec18be0d86a4409 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sun, 27 Mar 2022 03:37:47 +0200 Subject: [PATCH] aquatic_udp_bench: fix compilation error --- aquatic_udp_bench/src/announce.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/aquatic_udp_bench/src/announce.rs b/aquatic_udp_bench/src/announce.rs index e048bf41..769dd219 100644 --- a/aquatic_udp_bench/src/announce.rs +++ b/aquatic_udp_bench/src/announce.rs @@ -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() {