treewide: Upgrade tokio to 1.32

Upgrade the version of tokio we depend on to version 1.32, to get the version with tokio-rs/tokio#5925, my fix for a performance issue in `tokio::sync::broadcast`. We use this to notify workers when channels are removed from the channel coordinator, so we want this fix to improve the performance of that process. Change-Id: Id45707e0f95ca0a76ea69952ea23e8c65f846983 Reviewed-on: https://gerrit.readyset.name/c/readyset/+/5883 Tested-by: Buildkite CI Reviewed-by: Luke Osborne <[email protected]>
readysettech · Aug 24, 2023 · 09b705e · 09b705e
1 parent c2e5221
commit 09b705e
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 28 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -73,7 +73,7 @@ postgres-native-tls = {  git = "https://github.com/readysettech/rust-postgres.gi
 postgres-protocol = {  git = "https://github.com/readysettech/rust-postgres.git"}
 postgres-types = {  git = "https://github.com/readysettech/rust-postgres.git"}
 tokio-postgres = {  git = "https://github.com/readysettech/rust-postgres.git"}
-tokio = { version = "1.28",  features = ["full"] }
+tokio = { version = "1.32",  features = ["full"] }
 rocksdb = { git = "https://github.com/readysettech/rust-rocksdb.git", default-features = false, features = ["lz4"] }
 
 [profile.release]

diff --git a/proptest-stateful/Cargo.toml b/proptest-stateful/Cargo.toml
@@ -16,5 +16,5 @@ edition = "2021"
 async-trait = "0.1"
 proptest = "1.0.0"
 rand = "0.8.5"
-tokio = { version = "1.28", features = ["full"] }
+tokio = { version = "1.32", features = ["full"] }
 
diff --git a/readyset-server/src/handle.rs b/readyset-server/src/handle.rs
@@ -66,7 +66,6 @@ impl Handle {
                 .unwrap()
                 .send(HandleRequest::QueryReadiness(tx))
                 .await
-                .ok()
                 .expect("Controller dropped, failed, or panicked");
 
             if rx.await.unwrap() {
@@ -104,7 +103,6 @@ impl Handle {
                 done_tx: fin_tx,
             })
             .await
-            .ok()
             .expect("Controller dropped, failed, or panicked");
 
         fin_rx.await.unwrap().unwrap();