Merge pull request #119 from second-state/fix/async_wasi

Fix/async wasi
WasmEdge · Jul 29, 2024 · de735ee · de735ee
2 parents ef01eb6 + da8eb2a
commit de735ee
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/crates/async-wasi/Cargo.toml b/crates/async-wasi/Cargo.toml
@@ -7,7 +7,7 @@ license = "Apache-2.0"
 name = "async-wasi"
 readme = "README.md"
 repository = "https://github.com/WasmEdge/wasmedge-rust-sdk"
-version = "0.2.0"
+version = "0.2.1"
 
 [dependencies]
 log = "0.4"

diff --git a/crates/async-wasi/src/snapshots/common/net/async_tokio.rs b/crates/async-wasi/src/snapshots/common/net/async_tokio.rs
@@ -154,16 +154,16 @@ pub(crate) struct SocketWritable(pub(crate) AtomicI8);
 impl SocketWritable {
     pub(crate) async fn writable(&self) {
         let b = self.0.fetch_sub(1, std::sync::atomic::Ordering::Acquire);
-        SocketWritableFuture(b).await;
+        tokio::time::timeout(Duration::from_secs(10), SocketWritableFuture(b)).await;
     }
 
     pub(crate) fn set_writable(&self) {
-        self.0.store(2, std::sync::atomic::Ordering::Release)
+        self.0.store(5, std::sync::atomic::Ordering::Release)
     }
 }
 impl Default for SocketWritable {
     fn default() -> Self {
-        Self(AtomicI8::new(2))
+        Self(AtomicI8::new(5))
     }
 }