Merge pull request #292 from nervosnetwork/bump-to-0.3.5

chore: bump to 0.3.5

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 0.3.5
+
+### Bug Fix
+- Fix resolve cpu load issue of prepare_uninitialized_buffer
+
 ## 0.3.4
 
 ### Features

secio/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tentacle-secio"
-version = "0.4.3"
+version = "0.4.4"
 license = "MIT"
 description = "Secio encryption protocol for p2p"
 authors = ["piaoliu <[email protected]>", "Nervos Core Dev <[email protected]>"]

tentacle/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tentacle"
-version = "0.3.4"
+version = "0.3.5"
 license = "MIT"
 description = "Minimal implementation for a multiplexed p2p network framework."
 authors = ["piaoliu <[email protected]>", "Nervos Core Dev <[email protected]>"]
@@ -16,8 +16,8 @@ all-features = false
 no-default-features = true
 
 [dependencies]
-yamux = { path = "../yamux", version = "0.2.9", default-features = false, package = "tokio-yamux"}
-secio = { path = "../secio", version = "0.4.3", package = "tentacle-secio" }
+yamux = { path = "../yamux", version = "0.2.10", default-features = false, package = "tokio-yamux"}
+secio = { path = "../secio", version = "0.4.4", package = "tentacle-secio" }
 
 futures = { version = "0.3.0" }
 tokio = { version = "0.2.0" }

tentacle/src/runtime/async_runtime.rs

@@ -108,6 +108,13 @@ mod os {
         ) -> Poll<Result<usize, io::Error>> {
             AsyncRead::poll_read(Pin::new(&mut self.0), cx, buf)
         }
+
+        unsafe fn prepare_uninitialized_buffer(
+            &self,
+            _buf: &mut [std::mem::MaybeUninit<u8>],
+        ) -> bool {
+            false
+        }
     }
 
     impl AsyncWrite for TcpStream {

tentacle/src/runtime/mod.rs

@@ -112,6 +112,10 @@ where
     ) -> Poll<io::Result<usize>> {
         AsyncRead::poll_read(Pin::new(&mut self.0), cx, buf)
     }
+
+    unsafe fn prepare_uninitialized_buffer(&self, _buf: &mut [std::mem::MaybeUninit<u8>]) -> bool {
+        false
+    }
 }
 
 impl<T> AsyncWrite for CompatStream<T>
@@ -149,6 +153,10 @@ where
     ) -> Poll<io::Result<usize>> {
         FutureAsyncRead::poll_read(self, cx, buf)
     }
+
+    unsafe fn prepare_uninitialized_buffer(&self, _buf: &mut [std::mem::MaybeUninit<u8>]) -> bool {
+        false
+    }
 }
 
 impl<T> AsyncWrite for CompatStream2<T>

tentacle/src/transports/browser.rs

@@ -241,6 +241,10 @@ impl AsyncRead for BrowserStream {
             }
         }
     }
+
+    unsafe fn prepare_uninitialized_buffer(&self, _buf: &mut [std::mem::MaybeUninit<u8>]) -> bool {
+        false
+    }
 }
 
 impl AsyncWrite for BrowserStream {

tentacle/src/transports/ws.rs

@@ -382,6 +382,10 @@ impl AsyncRead for WsStream {
             Poll::Pending => Poll::Pending,
         }
     }
+
+    unsafe fn prepare_uninitialized_buffer(&self, _buf: &mut [std::mem::MaybeUninit<u8>]) -> bool {
+        false
+    }
 }
 
 impl AsyncWrite for WsStream {

yamux/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tokio-yamux"
-version = "0.2.9"
+version = "0.2.10"
 license = "MIT"
 repository = "https://github.com/nervosnetwork/tentacle"
 description = "Rust implementation of Yamux"

yamux/src/session.rs

@@ -873,6 +873,13 @@ mod test {
                 Poll::Ready(Ok(n))
             }
         }
+
+        unsafe fn prepare_uninitialized_buffer(
+            &self,
+            _buf: &mut [std::mem::MaybeUninit<u8>],
+        ) -> bool {
+            false
+        }
     }
 
     impl AsyncWrite for MockSocket {