From 844a50b6443e03effabd1c3e928198ded0247617 Mon Sep 17 00:00:00 2001 From: Dan Gohman Date: Tue, 15 Aug 2023 14:26:15 -0700 Subject: [PATCH] debugging --- crates/wasi/src/preview2/host/tcp.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/crates/wasi/src/preview2/host/tcp.rs b/crates/wasi/src/preview2/host/tcp.rs index bd50d468d5f9..99359bc7e719 100644 --- a/crates/wasi/src/preview2/host/tcp.rs +++ b/crates/wasi/src/preview2/host/tcp.rs @@ -35,11 +35,15 @@ impl tcp::Host for T { let network = table.get_network(network)?; let binder = network.0.tcp_binder(local_address)?; + eprintln!("@@ start_bind"); let clone = socket.clone(); let join = spawn_blocking(move || { + eprintln!("@@ host bind..."); let result = binder.bind_existing_tcp_listener(clone.tcp_socket()); + dbg!(&result); *clone.0.result.lock().unwrap() = Some(result); clone.0.sender.send(()).unwrap(); + eprintln!("@@ bind task done"); }); *tcp_state = HostTcpState::Bind(join); @@ -58,10 +62,13 @@ impl tcp::Host for T { }; if join.is_finished() { + eprintln!("@@ finish_bind"); socket.0.result.lock().unwrap().take().unwrap()?; *tcp_state = HostTcpState::Bound; + eprintln!("@@ finish_bind done"); Ok(()) } else { + eprintln!("@@ bind isn't ready yet!!!"); Err(ErrorCode::WouldBlock.into()) } }