reactor
/
ptth
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

🚨 fix cargo check warnings

main
_ 2021-10-10 14:40:18 +00:00
parent 35cc1d49b7
commit ee31d105c9
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
prototypes/quic_demo/src/bin/quic_demo_client.rs
View File

@ -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 ();

11
prototypes/quic_demo/src/bin/quic_demo_relay_server.rs
View File

@ -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,