storage: update tokio to fix a bug in mpmc channel

Update tokio to fix the bug: tokio-rs/tokio#4745 Signed-off-by: Jiang Liu <[email protected]>
jiangliu · Jun 12, 2022 · 9555c29 · 9555c29
1 parent 4032fe5
commit 9555c29
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 34 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/storage/src/cache/worker.rs b/storage/src/cache/worker.rs
@@ -121,11 +121,8 @@ impl<T> Channel<T> {
         tokio::pin!(future);
 
         loop {
-            /*
-            // TODO: enable this after https://github.com/tokio-rs/tokio/issues/4745 has been fixed
             // Make sure that no wakeup is lost if we get `None` from `try_recv`.
             future.as_mut().enable();
-             */
 
             if let Some(msg) = self.try_recv() {
                 return Ok(msg);