From ee31d105c905f8550fb8c623e0a1004f8315127e Mon Sep 17 00:00:00 2001 From: _ <> Date: Sun, 10 Oct 2021 14:40:18 +0000 Subject: [PATCH] :rotating_light: fix cargo check warnings --- prototypes/quic_demo/src/bin/quic_demo_client.rs | 3 ++- .../quic_demo/src/bin/quic_demo_relay_server.rs | 11 +++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/prototypes/quic_demo/src/bin/quic_demo_client.rs b/prototypes/quic_demo/src/bin/quic_demo_client.rs index 9407d1d..1024ef0 100644 --- a/prototypes/quic_demo/src/bin/quic_demo_client.rs +++ b/prototypes/quic_demo/src/bin/quic_demo_client.rs @@ -50,7 +50,8 @@ async fn main () -> anyhow::Result <()> { // Beginning of per-connection stuff let task_tcp_server = tokio::spawn (async move { - loop { + let running = true; + while running { let (tcp_socket, _) = listener.accept ().await?; let connection = connection.clone (); let server_id = server_id.clone (); diff --git a/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs b/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs index dcb5d5e..9b2dc51 100644 --- a/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs +++ b/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs @@ -89,24 +89,23 @@ async fn main () -> anyhow::Result <()> { let task_tcp_server = { let relay_state = Arc::clone (&relay_state); tokio::spawn (async move { - loop { + let running = true; + while running { let (tcp_socket, _) = tcp_listener.accept ().await?; - let server_id = "bogus_server".to_string (); - let relay_state = Arc::clone (&relay_state); tokio::spawn (async move { - let (client_recv, client_send) = tcp_socket.into_split (); + let (_client_recv, _client_send) = tcp_socket.into_split (); debug! ("Accepted direct TCP connection P1 --> P3"); let p4_server_proxies = relay_state.p4_server_proxies.lock ().await; - let p4 = match p4_server_proxies.get ("bogus_server") { + let _p4 = match p4_server_proxies.get ("bogus_server") { Some (x) => x, None => bail! ("That server isn't connected"), }; - unimplemented! (); + // unimplemented! (); /* p4.req_channel.send (RequestP2ToP4 { client_send,